Collaborative Editing Tools

CREATE TABLE docs.document_ops (
  op_id BIGINT PRIMARY KEY DEFAULT SNOWFLAKE_ID(),
  doc_id TEXT NOT NULL,
  user_id TEXT NOT NULL,
  op_type TEXT NOT NULL,
  payload JSON NOT NULL,
  created_at TIMESTAMP DEFAULT NOW()
) WITH (TYPE = 'SHARED', FLUSH_POLICY = 'interval:30');
 
CREATE TABLE docs.presence (
  id BIGINT PRIMARY KEY DEFAULT SNOWFLAKE_ID(),
  doc_id TEXT NOT NULL,
  user_id TEXT,
  cursor_position INT,
  last_seen TIMESTAMP DEFAULT NOW()
) WITH (TYPE = 'STREAM', TTL_SECONDS = 5);

await client.subscribeWithSql(
  'SELECT * FROM docs.document_ops WHERE doc_id = $1 ORDER BY created_at ASC',
  (event) => {
    if (event.type === 'initial_data_batch' && event.rows) {
      rebuildDocument(event.rows);
    }
    if (event.type === 'change' && event.change_type === 'insert') {
      applyRemoteOps(event.rows);
    }
  },
  { batch_size: 500 }
);
 
await client.query(
  'INSERT INTO docs.document_ops (doc_id, user_id, op_type, payload) VALUES ($1, $2, $3, $4)',
  [docId, userId, 'insert', JSON.stringify(op)]
);