Supabase Edge Functions + Realtime

// supabase/functions/send-welcome/index.ts
import { serve } from 'https://deno.land/std/http/server.ts';
import { createClient } from 'https://esm.sh/@supabase/supabase-js@2';

serve(async (req) => {
  const { email, name } = await req.json();

  const supabase = createClient(
    Deno.env.get('SUPABASE_URL')!,
    Deno.env.get('SUPABASE_SERVICE_ROLE_KEY')!,
  );

  // Resend로 이메일 발송
  const res = await fetch('https://api.resend.com/emails', {
    method: 'POST',
    headers: {
      'Authorization': `Bearer ${Deno.env.get('RESEND_API_KEY')}`,
      'Content-Type': 'application/json',
    },
    body: JSON.stringify({
      from: 'noreply@example.com',
      to: email,
      subject: `${name}님 환영합니다`,
      html: '<h1>가입 완료</h1>',
    }),
  });

  await supabase.from('email_logs').insert({
    type: 'welcome', recipient: email, status: res.ok ? 'sent' : 'failed',
  });

  return new Response(JSON.stringify({ ok: res.ok }), {
    headers: { 'Content-Type': 'application/json' },
  });
});


// 배포
supabase functions deploy send-welcome

-- 새 user 가입 시 자동 호출
CREATE OR REPLACE FUNCTION notify_user_signup()
RETURNS trigger AS $$
BEGIN
  PERFORM net.http_post(
    'https://<project>.functions.supabase.co/send-welcome',
    jsonb_build_object('email', NEW.email, 'name', NEW.raw_user_meta_data->>'name'),
    headers => jsonb_build_object('Authorization', 'Bearer ...')
  );
  RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER on_user_signup
AFTER INSERT ON auth.users
FOR EACH ROW EXECUTE FUNCTION notify_user_signup();

-- 사용자는 자기 게시물만 보기
ALTER TABLE posts ENABLE ROW LEVEL SECURITY;

CREATE POLICY "Users see own posts"
  ON posts FOR SELECT
  USING (author_id = auth.uid());

CREATE POLICY "Users insert own posts"
  ON posts FOR INSERT
  WITH CHECK (author_id = auth.uid());

CREATE POLICY "Users update own posts"
  ON posts FOR UPDATE
  USING (author_id = auth.uid());

CREATE POLICY "Public read published"
  ON posts FOR SELECT
  USING (published = true);

// 클라이언트
import { createClient } from '@supabase/supabase-js';

const supabase = createClient(URL, ANON_KEY);

// 새 메시지 실시간 구독
const channel = supabase
  .channel('room:123')
  .on('postgres_changes', {
    event: 'INSERT',
    schema: 'public',
    table: 'messages',
    filter: 'room_id=eq.123',
  }, (payload) => {
    console.log('New message:', payload.new);
    setMessages(prev => [...prev, payload.new]);
  })
  .subscribe();


// 정리
return () => { supabase.removeChannel(channel); };

const channel = supabase.channel('online-users', {
  config: { presence: { key: userId } },
});

channel
  .on('presence', { event: 'sync' }, () => {
    const state = channel.presenceState();
    setOnlineUsers(Object.keys(state));
  })
  .subscribe(async (status) => {
    if (status === 'SUBSCRIBED') {
      await channel.track({ userId, online_at: new Date().toISOString() });
    }
  });

// 업로드 (RLS 적용)
const file = event.target.files![0];
const path = `${userId}/${Date.now()}_${file.name}`;

const { data, error } = await supabase.storage
  .from('avatars')
  .upload(path, file, {
    cacheControl: '3600',
    upsert: false,
  });

const { data: { publicUrl } } = supabase.storage
  .from('avatars')
  .getPublicUrl(path);


// Storage RLS
CREATE POLICY "Users upload own avatar"
ON storage.objects FOR INSERT
WITH CHECK (
  bucket_id = 'avatars' AND
  (storage.foldername(name))[1] = auth.uid()::text
);

Free Tier:
- DB: 500MB
- Auth: 50,000 MAU
- Storage: 1GB
- Edge Functions: 500K invocations/mo
- Realtime: 200 동시 연결


Pro ($25/mo):
- DB: 8GB + 자동 백업
- Auth: 100K MAU
- Storage: 100GB
- Edge Functions: 2M invocations
- Realtime: 500 동시 연결


→ MVP·소규모는 Free, 100K MAU 도달 시 Pro 검토