Method reconstructVersion

src/durable-objects/user-notes.ts:368–393

(versionId: string, noteId: string)

            );
            return head.id;
        }

        const id = crypto.randomUUID();
        const key = this.versionKey(noteId, id);
        await this.bucket.put(key, content, { httpMetadata: { contentType: "application/json" } });
        this.sql.exec(
            "INSERT INTO note_versions (id, note_id, parent_id, branch_id, title, is_checkpoint, data, created_by, kind, summary, storage, content_hash) VALUES (?, ?, ?, ?, ?, 1, ?, ?, ?, ?, 'r2', ?)",
            id, noteId, parentId, branch.id, title, key, createdBy, kind, summary, hash
        );

        this.sql.exec("UPDATE note_branches SET head_version_id = ? WHERE id = ?", id, branch.id);

        await this.pruneVersions(noteId);
        return id;
    }

    private async pruneVersions(noteId: string) {
        const stale = this.sql.exec(
            `SELECT id, data, storage FROM note_versions WHERE note_id = ? AND id NOT IN (
                SELECT id FROM note_versions WHERE note_id = ? ORDER BY created_at DESC LIMIT ${this.MAX_VERSIONS_PER_NOTE}
            )`, noteId, noteId
        ).toArray() as any[];
        if (stale.length === 0) return;
        for (let i = 0; i < stale.length; i += 500) {
            const batch = stale.slice(i, i + 500);
            this.sql.exec(
                `DELETE FROM note_versions WHERE id IN (${batch.map(() => "?").join(",")})`,
                ...batch.map((r) => r.id)
            );