@mininjin/y-durable-objects

y-durable-objects

Cloudflare Workers Durable Objects for Yjs

This library is for using Yjs with Cloudflare Workers Durable Objects. The implementation is based on y-websocket and y-leveldb.

In Cloudflare Workers Durable Objects' Transaction Storage, there is a 128KiB data limit per key. Therefore, this library splits updates into multiple chunks during flush operations to accommodate this limit.

Installation

npm install @mininjin/y-durable-objects

# or with yarn
yarn add @mininjin/y-durable-objects

Usage

Basic Usage

import { YDurableObject, YDurableObjectOptions } from "@mininjin/y-durable-objects";

const options: YDurableObjectOptions = {
  // Options here
};

// Durable Object
export class WebSocketServer extends YDurableObject<Env> {
  constructor(ctx: DurableObjectState, env: Env) {
    super(ctx, env, options);
  }
}

Options

flushBytes: number

Byte count threshold to flush updates. When the sum of bytes of updates exceeds this threshold, the updates will be flushed automatically, and the update count and the byte count will be reset. Default: 10 * 1024 (10KiB)

flushUpdateClock: number

Update count threshold to flush updates. When the total number of updates exceeds this threshold, the updates will be flushed automatically. Default: 300

maxChunkBytes: number

Maximum byte size of each merged update. Default: 100 * 1024 (100KiB)

Methods

async getYDoc(): Promise<Y.Doc>

Retrieves the current Y.Doc instance. Use this method to get the latest state of the Yjs document from persistent storage.

onYDocUpdate(): void | Promise<void>

This method is called whenever the Y.Doc instance is updated. Override this method to handle document updates. A common use case is to set an alarm using the Alarm API to notify external servers about the updates.

onAwarenessUpdate(): void | Promise<void>

This method is called whenever the awareness is updated. Override this method to handle changes in user presence or metadata.

Example

See the example directory for a simple example.

License

This project is licensed under the MIT License.