Class UserNotesDurableObject

src/durable-objects/user-notes.ts:45–1040

    }

    return null;
}

export class UserNotesDurableObject extends DurableObject {
    private sql: SqlStorage;
    private docs = new Map<string, Y.Doc>();
    private saveTimers = new Map<string, ReturnType<typeof setTimeout>>();
    private bucket: R2Bucket;

    constructor(ctx: DurableObjectState, env: Env) {
        super(ctx, env);
        this.sql = ctx.storage.sql;
        this.bucket = env.MEDIA_BUCKET;
        this.ctx.blockConcurrencyWhile(async () => {
            this.sql.exec(`
                CREATE TABLE IF NOT EXISTS notes (
                    id TEXT PRIMARY KEY,
                    title TEXT NOT NULL DEFAULT 'Untitled',
                    content TEXT NOT NULL DEFAULT '',
                    yjs_state BLOB,
                    folder_id TEXT,
                    sync_mode TEXT NOT NULL DEFAULT 'cloud',
                    created_at INTEGER NOT NULL DEFAULT (unixepoch()),
                    updated_at INTEGER NOT NULL DEFAULT (unixepoch())
                )
            `);
            this.sql.exec(`
                CREATE TABLE IF NOT EXISTS folders (
                    id TEXT PRIMARY KEY,
                    name TEXT NOT NULL,
                    color TEXT NOT NULL DEFAULT '#8A8473',
                    description TEXT NOT NULL DEFAULT '',
                    sort_order INTEGER NOT NULL DEFAULT 0,
                    created_at INTEGER DEFAULT (unixepoch()),
                    updated_at INTEGER DEFAULT (unixepoch())
                )
            `);
            // Migrations for existing tables — only suppress "duplicate column" errors
            const migrate = (sql: string) => {
                try { this.sql.exec(sql); } catch (e: any) {
                    if (!e.message?.includes("duplicate column")) throw e;
                }
            };
            migrate("ALTER TABLE notes ADD COLUMN yjs_state BLOB");
            migrate("ALTER TABLE notes ADD COLUMN folder_id TEXT");
            migrate("ALTER TABLE notes ADD COLUMN sync_mode TEXT NOT NULL DEFAULT 'cloud'");
            migrate("ALTER TABLE notes ADD COLUMN locked INTEGER NOT NULL DEFAULT 0");
            migrate("ALTER TABLE notes ADD COLUMN published INTEGER NOT NULL DEFAULT 0");
            migrate("ALTER TABLE notes ADD COLUMN published_at INTEGER");
            migrate("ALTER TABLE folders ADD COLUMN description TEXT NOT NULL DEFAULT ''");

            // Git-style versioning: checkpoints (full content) + patches (diffs)
            this.sql.exec(`
                CREATE TABLE IF NOT EXISTS note_versions (
                    id TEXT PRIMARY KEY,
                    note_id TEXT NOT NULL,
                    parent_id TEXT,
                    title TEXT NOT NULL,