Function saveUpdate

projects/openade-module/src/nodeYjsStorage.ts:174–198

(id: string, data: Uint8Array)

    }

    async function saveUpdate(id: string, data: Uint8Array): Promise<void> {
        const previous = saveQueues.get(id) ?? Promise.resolve()
        const current = previous.then(async () => {
            await ensureRoot()
            const filePath = docPath(id)
            const tempPath = `${filePath}.tmp.${Date.now()}.${Math.random().toString(36).slice(2)}`
            const doc = new Y.Doc()
            try {
                const existing = await readUpdate(id)
                if (existing) Y.applyUpdate(doc, existing)
                Y.applyUpdate(doc, data)
                await fs.writeFile(tempPath, Y.encodeStateAsUpdate(doc))
                await fs.rename(tempPath, filePath)
            } catch (error) {
                await fs.unlink(tempPath).catch(() => undefined)
                throw error
            } finally {
                doc.destroy()
            }
        })
        saveQueues.set(id, current.catch(() => undefined))
        await current.finally(() => {
            if (saveQueues.get(id) === current) saveQueues.delete(id)
        })
    }

    async function loadDoc(id: string): Promise<Y.Doc | null> {
        const data = await readUpdate(id)