Collaborative Editing Tools

1CREATE TABLE docs.document_ops (2  op_id BIGINT PRIMARY KEY DEFAULT SNOWFLAKE_ID(),3  doc_id TEXT NOT NULL,4  user_id TEXT NOT NULL,5  op_type TEXT NOT NULL,6  payload JSON NOT NULL,7  created_at TIMESTAMP DEFAULT NOW()8) WITH (TYPE = 'SHARED', FLUSH_POLICY = 'interval:30');9 10CREATE TABLE docs.presence (11  id BIGINT PRIMARY KEY DEFAULT SNOWFLAKE_ID(),12  doc_id TEXT NOT NULL,13  user_id TEXT,14  cursor_position INT,15  last_seen TIMESTAMP DEFAULT NOW()16) WITH (TYPE = 'STREAM', TTL_SECONDS = 5);

1const escapedDocId = String(docId).replace(/'/g, "''");2await client.liveEvents(3  `SELECT * FROM docs.document_ops WHERE doc_id = '${escapedDocId}'`,4  (event) => {5    if (event.type === 'initial_data_batch' && event.rows) {6      rebuildDocument(event.rows);7    }8    if (event.type === 'change' && event.change_type === 'insert') {9      applyRemoteOps(event.rows);10    }11  },12  { batchSize: 500 }13);14 15await client.query(16  'INSERT INTO docs.document_ops (doc_id, user_id, op_type, payload) VALUES ($1, $2, $3, $4)',17  [docId, userId, 'insert', JSON.stringify(op)]18);