pubby-subscriptions.ts

interface MessageAction {
  action: 'subscribe' | 'unsubscribe';
  message: {
    // Which room to subscribe to or unsubscribe from
    room: string;
    // Whether to "dump" existing messages for this room
    dump: boolean;
  };
}

const wsMessage: MessageAction[] = [
  {
    action: 'subscribe',
    message: {
      room: 'testing',
      dump: true,
    },
  },
];

const ws = new WebSocket(`wss://${PUBBY_HOST}`);

ws.on('open', () => {
  // Subscribe to the "testing" room and request a dump of existing data
  ws.send(JSON.stringify(wsMessage));
});