Function createOpenADEModule

projects/openade-module/src/module.ts:745–1053

(adapters: OpenADEModuleAdapters)

}

export function createOpenADEModule(adapters: OpenADEModuleAdapters): RuntimeModule {
    const clientRequests = new Map<string, ClientRequestEntry>()
    const createId = adapters.createId ?? createFallbackId
    const clientRequestRetentionMs = adapters.clientRequestRetentionMs ?? DEFAULT_CLIENT_REQUEST_RETENTION_MS

    function runIdempotentMutation<T>(scope: string, params: unknown, action: () => Promise<T> | T): Promise<T> {
        const clientRequestId = stableClientRequestKey(params)
        if (!clientRequestId) return Promise.resolve().then(action)

        const key = `mutation:${scope}:${clientRequestId}`
        const existing = clientRequests.get(key)
        if (existing) return existing.promise as Promise<T>

        let retainStableResult = false
        const request = Promise.resolve()
            .then(action)
            .then((result) => {
                retainStableResult = true
                return result
            })
            .finally(() => {
                if (!retainStableResult) {
                    clientRequests.delete(key)
                    return
                }

                const entry = clientRequests.get(key)
                if (!entry || entry.promise !== request) return

                const cleanupTimer = setTimeout(() => {
                    if (clientRequests.get(key)?.promise === request) {
                        clientRequests.delete(key)
                    }
                }, clientRequestRetentionMs)
                unrefTimer(cleanupTimer)
                entry.cleanupTimer = cleanupTimer
            })

        clientRequests.set(key, { promise: request, cleanupTimer: null })
        return request
    }

    return {
        name: "openade",
        register(server) {
            server.registerNotification("openade/snapshotChanged")
            server.registerNotification("openade/repo/updated")
            server.registerNotification("openade/repo/deleted")
            server.registerNotification("openade/task/previewChanged")
            server.registerNotification("openade/task/updated")
            server.registerNotification("openade/task/deleted")
            server.registerNotification("openade/queuedTurn/updated")
            server.registerNotification("openade/workingTasks")
            server.registerNotification("remote/device/changed")

            server.register("openade/snapshot/read", (_params, context) =>
                adapters.readSnapshot({
                    version: adapters.version?.() ?? "local",