supabase-realtime

// Source: https://supabase.com/docs/guides/realtime
import { useEffect } from 'react';
import { supabase } from '@/lib/supabase';

function useRealtimeMessages(roomId: string) {
  const [messages, setMessages] = useState<Message[]>([]);

  useEffect(() => {
    // Initial fetch
    supabase.from('messages').select('*').eq('room_id', roomId)
      .then(({ data }) => setMessages(data || []));

    // Subscribe to changes
    const channel = supabase
      .channel(`room:${roomId}`)
      .on('postgres_changes',
        { event: 'INSERT', schema: 'public', table: 'messages', filter: `room_id=eq.${roomId}` },
        (payload) => setMessages((prev) => [...prev, payload.new as Message])
      )
      .subscribe();

    return () => { supabase.removeChannel(channel); };
  }, [roomId]);

  return messages;
}

// Source: https://supabase.com/docs/guides/realtime/presence
const [onlineUsers, setOnlineUsers] = useState<User[]>([]);

useEffect(() => {
  const channel = supabase.channel('online-users');

  channel
    .on('presence', { event: 'sync' }, () => {
      const state = channel.presenceState();
      const users = Object.values(state).flat() as User[];
      setOnlineUsers(users);
    })
    .subscribe(async (status) => {
      if (status === 'SUBSCRIBED') {
        await channel.track({ user_id: currentUser.id, name: currentUser.name });
      }
    });

  return () => { supabase.removeChannel(channel); };
}, [currentUser]);

// Source: https://supabase.com/docs/guides/realtime/broadcast
const channel = supabase.channel('cursor-positions');

// Send cursor position
const sendCursor = (x: number, y: number) => {
  channel.send({
    type: 'broadcast',
    event: 'cursor',
    payload: { x, y, userId: currentUser.id },
  });
};

// Receive cursor positions
channel
  .on('broadcast', { event: 'cursor' }, ({ payload }) => {
    setCursors((prev) => ({ ...prev, [payload.userId]: payload }));
  })
  .subscribe();

// Source: https://supabase.com/docs/reference/javascript/subscribe
const channel = supabase
  .channel('table-changes')
  .on('postgres_changes',
    { event: '*', schema: 'public', table: 'posts' },
    (payload) => {
      if (payload.eventType === 'INSERT') handleInsert(payload.new);
      if (payload.eventType === 'UPDATE') handleUpdate(payload.new);
      if (payload.eventType === 'DELETE') handleDelete(payload.old);
    }
  )
  .subscribe();