Function storeUpdate

packages/yjs-websocket/src/server/mongodb/utils.ts:120–139

(
  adapter: MongoAdapter,
  docName: string,
  update: Uint8Array,
)

}

export const storeUpdate = async (
  adapter: MongoAdapter,
  docName: string,
  update: Uint8Array,
): Promise<number> => {
  const clock = await getCurrentUpdateClock(adapter, docName)
  if (clock === -1) {
    // make sure that a state vector is always written, so we can search for available documents
    const ydoc = new Y.Doc()
    Y.applyUpdate(ydoc, update)
    const sv = Y.encodeStateVector(ydoc)
    await writeStateVector(adapter, docName, sv, 0)
  }

  await adapter.put(createDocumentUpdateKey(docName, clock + 1), {
    value: Buffer.from(update),
  })

  return clock + 1
}

/**
 * For now this is a helper method that creates a Y.Doc and then re-encodes a document update.