Function createOpenADEYjsWriter

projects/openade-module/src/yjsMutation.ts:427–1081

(storage: OpenADEYjsMutationStorageAdapter, options: OpenADEYjsWriterOptions = {})

}

export function createOpenADEYjsWriter(storage: OpenADEYjsMutationStorageAdapter, options: OpenADEYjsWriterOptions = {}): OpenADEYjsWriter {
    const createId = options.createId ?? createFallbackId
    const createSlug = options.createSlug ?? createFallbackSlug
    const now = options.now ?? (() => new Date().toISOString())

    return {
        async createRepo(request) {
            const repoId = request.repoId ?? createId()
            const createdAt = request.createdAt ?? now()
            const reposDoc = await loadDoc(storage, "code:repos")

            try {
                if (findRepoMap(reposDoc, repoId)) {
                    return { repoId, createdAt }
                }

                reposDoc.transact(() => {
                    pushOrderedItem(reposDoc, "repos", {
                        id: repoId,
                        name: request.name,
                        path: request.path,
                        createdBy: request.createdBy,
                        createdAt,
                        updatedAt: createdAt,
                        tasks: [],
                    })
                })
                await saveDoc(storage, "code:repos", reposDoc)
                return { repoId, createdAt }
            } finally {
                reposDoc.destroy()
            }
        },

        async updateRepo(request) {
            const updatedAt = request.updatedAt ?? now()
            const reposDoc = await loadDoc(storage, "code:repos")

            try {
                const repoMap = findRepoMap(reposDoc, request.repoId)
                if (!repoMap) throw new Error(`Repository ${request.repoId} not found`)

                reposDoc.transact(() => {
                    if (request.name !== undefined) repoMap.set("name", request.name)
                    if (request.path !== undefined) repoMap.set("path", request.path)
                    if (request.archived !== undefined) repoMap.set("archived", request.archived)
                    repoMap.set("updatedAt", updatedAt)
                })
                await saveDoc(storage, "code:repos", reposDoc)
            } finally {
                reposDoc.destroy()
            }
        },

        async deleteRepo(request) {
            const reposDoc = await loadDoc(storage, "code:repos")

            try {