feat: add ipc wrappers

package.json

@@ -118,6 +118,7 @@
     "private-ip": "^3.0.0",
     "protobufjs": "^7.2.3",
     "protomux": "^3.4.1",
+    "rpc-reflector": "^1.3.10",
     "sodium-universal": "^4.0.0",
     "sub-encoder": "^2.1.1",
     "tiny-typed-emitter": "^2.1.0"

src/ipc-wrapper/client.js

@@ -0,0 +1,56 @@
+// @ts-check
+import { createClient } from 'rpc-reflector'
+import { SubChannel } from './sub-channel.js'
+
+/**
+ * @param {import('rpc-reflector/client.js').MessagePortLike} messagePort
+ * @returns {import('rpc-reflector/client.js').ClientApi<import('../mapeo-manager.js').MapeoManager>}
+ */
+export function createMapeoClient(messagePort) {
+  // TODO: LRU cache?
+  /** @type {Map<import('../types.js').ProjectPublicId, import('rpc-reflector/client.js').ClientApi<import('../mapeo-project.js').MapeoProject>>} */
+  const existingProjectClients = new Map()
+
+  const managerChannel = new SubChannel(messagePort, '@@manager')
+
+  /** @type {import('rpc-reflector').ClientApi<import('../mapeo-manager.js').MapeoManager>} */
+  const managerClient = createClient(managerChannel)
+
+  const client = new Proxy(managerClient, {
+    get(target, prop, receiver) {
+      if (prop === 'getProject') {
+        return createProjectClient
+      } else {
+        return Reflect.get(target, prop, receiver)
+      }
+
+      /**
+       * @param {import('../types.js').ProjectPublicId} projectPublicId
+       * @returns {Promise<import('rpc-reflector/client.js').ClientApi<import('../mapeo-project.js').MapeoProject>>}
+       */
+      function createProjectClient(projectPublicId) {
+        const existingClient = existingProjectClients.get(projectPublicId)
+
+        if (existingClient) return Promise.resolve(existingClient)
+
+        const projectChannel = new SubChannel(messagePort, projectPublicId)
+
+        /** @type {import('rpc-reflector').ClientApi<import('../mapeo-project.js').MapeoProject>} */
+        const projectClient = new Proxy(createClient(projectChannel), {
+          get(target, prop, receiver) {
+            if (prop === 'then') {
+              return projectClient
+            }
+            return Reflect.get(target, prop, receiver)
+          },
+        })
+
+        existingProjectClients.set(projectPublicId, projectClient)
+
+        return Promise.resolve(projectClient)
+      }
+    },
+  })
+
+  return client
+}

src/ipc-wrapper/server.js

@@ -0,0 +1,39 @@
+// @ts-check
+import { createServer } from 'rpc-reflector'
+import { SubChannel } from './sub-channel.js'
+
+/**
+ * @param {import('../mapeo-manager.js').MapeoManager} manager
+ * @param {import('rpc-reflector/server.js').MessagePortLike} messagePort
+ */
+export function createMapeoServer(manager, messagePort) {
+  // TODO: LRU? project.close() after time without use?
+  /** @type {Map<string, { close: () => void, project: import('../mapeo-project.js').MapeoProject }>}*/
+  const existing = new Map()
+
+  const managerChannel = new SubChannel(messagePort, '@@manager')
+
+  const managerServer = createServer(manager, managerChannel)
+
+  messagePort.on('message', async (payload) => {
+    // TODO: figure out better way to know that this is the project public id
+    const id = payload?.id
+    if (typeof id !== 'string' || id === '@@manager') return
+
+    if (existing.has(id)) return
+
+    const projectChannel = new SubChannel(messagePort, id)
+
+    const project = await manager.getProject(
+      /** @type {import('../types.js').ProjectPublicId} */ (id)
+    )
+
+    const { close } = createServer(project, projectChannel)
+
+    projectChannel.emit('message', payload.message)
+
+    existing.set(id, { close, project })
+  })
+
+  return managerServer
+}

src/ipc-wrapper/sub-channel.js

@@ -0,0 +1,40 @@
+// @ts-check
+import { TypedEmitter } from 'tiny-typed-emitter'
+
+/**
+ * @typedef {Object} Events
+ * @property {(message: any) => void} message
+ */
+
+/**
+ * @extends {TypedEmitter<Events>}
+ */
+export class SubChannel extends TypedEmitter {
+  #id
+  #messagePort
+
+  /**
+   * @param {import('rpc-reflector/server.js').MessagePortLike} messagePort Parent channel to add namespace to
+   * @param {string} id ID for the subchannel
+   */
+  constructor(messagePort, id) {
+    super()
+
+    this.#id = id
+    this.#messagePort = messagePort
+
+    // Listen to all messages on the shared channel but only handle the relevant ones
+    this.#messagePort.on('message', ({ id, message }) => {
+      if (this.#id !== id) return
+      this.emit('message', message)
+    })
+  }
+
+  /**
+   * Send messages with the subchannel's ID
+   * @param {any} message
+   */
+  postMessage(message) {
+    this.#messagePort.postMessage({ id: this.#id, message })
+  }
+}