import { Datom } from '@datom/client';

// Initialize client
const db = new Datom({
  url: process.env.DATOM_URL,
  apiKey: process.env.DATOM_KEY
});

// Subscribe to live query
const unsubscribe = db
  .collection('messages')
  .where('roomId', '==', 'general')
  .orderBy('createdAt', 'desc')
  .watch((docs) => {
    renderMessages(docs);
  });

// Optimistic write
await db.collection('messages').insert({
  text: 'Hello world',
  roomId: 'general'
});