Records

// Expose a specific record
server.exposeRecord("user:123");
 
// Expose records matching a pattern
server.exposeRecord(/^product:\d+$/);
 
// With access control
server.exposeRecord(/^private:.+$/, async (conn, id) => {
  const meta = await server.connectionManager.getMetadata(conn);
  return !!meta?.userId;
});

// Allow clients to update records
server.exposeWritableRecord(/^cursor:user:\d+$/);
 
// With write permission check
server.exposeWritableRecord(/^profile:user:\d+$/, async (conn, id) => {
  const meta = await server.connectionManager.getMetadata(conn);
  return meta?.userId === id.split(":").pop();
});

// Update a record (broadcasts to all subscribers)
await server.writeRecord("user:123", {
  name: "Alice",
  status: "active",
});

// Full mode (default)
const { success, record, version } = await client.subscribeRecord(
  "user:123",
  (update) => {
    console.log(`Received update for ${update.recordId}:`, update.full);
  }
);
 
// Patch mode (more efficient for large or frequently changing records)
import { applyPatch } from "@mesh-kit/client";
 
let productData = {};
await client.subscribeRecord(
  "product:456",
  (update) => {
    if (update.patch) {
      applyPatch(productData, update.patch);
    } else {
      // The full update is received if the client falls out of sync
      productData = update.full;
    }
  },
  { mode: "patch" }
);

// Update a writable record
const success = await client.writeRecord("cursor:user:123", {
  x: 100,
  y: 250,
  timestamp: Date.now(),
});