Function readUpdate

projects/openade-module/src/nodeYjsStorage.ts:149–172

(id: string)

    }

    async function readUpdate(id: string): Promise<Uint8Array | null> {
        try {
            const data = new Uint8Array(await fs.readFile(docPath(id)))
            if (isExpectedTaskDoc(id, data)) return data

            const legacyData = await readLegacyUpdate(id)
            if (legacyData) {
                await writeMigratedDoc(id, legacyData)
                return legacyData
            }

            return data
        } catch (error) {
            if ((error as NodeJS.ErrnoException).code === "ENOENT") {
                const legacyData = await readLegacyUpdate(id)
                if (legacyData) {
                    await writeMigratedDoc(id, legacyData)
                    return legacyData
                }
                return null
            }
            throw error
        }
    }

    async function saveUpdate(id: string, data: Uint8Array): Promise<void> {
        const previous = saveQueues.get(id) ?? Promise.resolve()