import { StreamplaceChatAdapter } from '../src/streamplace-chat';

const adapter = new StreamplaceChatAdapter({
  wantedCollections: [process.env.STREAMPLACE_CHAT_NSID ?? 'place.stream.chat.message'],
});

console.log(adapter.createUrl());

const sample = {
  did: 'did:plc:example123',
  time_us: 1710000000000000,
  kind: 'commit',
  commit: {
    operation: 'create',
    collection: process.env.STREAMPLACE_CHAT_NSID ?? 'place.stream.chat.message',
    record: {
      message: 'hello from stream.place chat',
      createdAt: '2026-05-26T21:23:00.000Z',
    },
  },
};

console.log(JSON.stringify(adapter.extractChatEvent(JSON.stringify(sample)), null, 2));