chore(release): 0.1.0-develop.5 [skip ci]

# [0.1.0-develop.5](https://git.lumeweb.com/LumeWeb/kernel/compare/v0.1.0-develop.4...v0.1.0-develop.5) (2023-09-01) ### Bug Fixes * fix import ([787c7c6](787c7c6637)) ### Features * add initial fallback registry support ([5cc457d](5cc457d78b)) * add initial support to query the network for a registry entry for a module ([ba4c6dc](ba4c6dcb95))
fix: fix import
2023-09-01 23:05:08 +00:00 · 2023-09-01 19:04:07 -04:00 · 2023-09-01 18:59:15 -04:00 · 2023-09-01 18:59:06 -04:00 · 2023-09-01 15:38:24 -04:00
7 changed files with 401 additions and 21 deletions
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@ -1,3 +1,16 @@
+# [0.1.0-develop.5](https://git.lumeweb.com/LumeWeb/kernel/compare/v0.1.0-develop.4...v0.1.0-develop.5) (2023-09-01)
+
+
+### Bug Fixes
+
+* fix import ([787c7c6](https://git.lumeweb.com/LumeWeb/kernel/commit/787c7c6637f8291c4b2e9558f1d68ebabcb2e225))
+
+
+### Features
+
+* add initial fallback registry support ([5cc457d](https://git.lumeweb.com/LumeWeb/kernel/commit/5cc457d78b40541c1ecfa1d6a5c07274a7d48ab6))
+* add initial support to query the network for a registry entry for a module ([ba4c6dc](https://git.lumeweb.com/LumeWeb/kernel/commit/ba4c6dcb9552eeb7cf4b87e31d2f878b1eb83198))
+
 # [0.1.0-develop.4](https://git.lumeweb.com/LumeWeb/kernel/compare/v0.1.0-develop.3...v0.1.0-develop.4) (2023-08-10)

 # [0.1.0-develop.3](https://git.lumeweb.com/LumeWeb/kernel/compare/v0.1.0-develop.2...v0.1.0-develop.3) (2023-08-10)
--- a/npm-shrinkwrap.json
+++ b/npm-shrinkwrap.json
@ -1,16 +1,17 @@
 {
    "name": "@lumeweb/kernel",
-    "version": "0.1.0-develop.4",
+    "version": "0.1.0-develop.5",
    "lockfileVersion": 3,
    "requires": true,
    "packages": {
        "": {
            "name": "@lumeweb/kernel",
-            "version": "0.1.0-develop.4",
+            "version": "0.1.0-develop.5",
            "dependencies": {
                "@lumeweb/libkernel": "0.1.0-develop.35"
            },
            "devDependencies": {
+                "@lumeweb/libs5": "^0.1.0-develop.25",
                "@lumeweb/presetter-kernel-module-preset": "^0.1.0-develop.43",
                "binconv": "^0.2.0",
                "presetter": "*",
@ -1727,6 +1728,31 @@
                "web-streams-polyfill": "^3.2.1"
            }
        },
+        "node_modules/@lumeweb/libs5": {
+            "version": "0.1.0-develop.25",
+            "resolved": "https://registry.npmjs.org/@lumeweb/libs5/-/libs5-0.1.0-develop.25.tgz",
+            "integrity": "sha512-kqvMrAU3fZLFwAqVwv0btu7dx0wBN/XkCGV9LivCoUz2DIT0T63W1Xv4LinpqDIZmbiXNmYt0CVQAhfe53b2UA==",
+            "dev": true,
+            "dependencies": {
+                "@noble/curves": "^1.1.0",
+                "@noble/hashes": "^1.3.1",
+                "detect-node": "^2.1.0",
+                "level": "^8.0.0",
+                "multiformats": "^12.0.1",
+                "p-defer": "^4.0.0",
+                "ws": "^8.13.0"
+            }
+        },
+        "node_modules/@lumeweb/libs5/node_modules/multiformats": {
+            "version": "12.1.0",
+            "resolved": "https://registry.npmjs.org/multiformats/-/multiformats-12.1.0.tgz",
+            "integrity": "sha512-/qTOKKnU8nwcVURjRcS+UN0QYgdS5BPZzY10Aiciu2SqncyCVMGV8KtD83EBFmsuJDsSEmT4sGvzcTkCoMw0sQ==",
+            "dev": true,
+            "engines": {
+                "node": ">=16.0.0",
+                "npm": ">=7.0.0"
+            }
+        },
        "node_modules/@lumeweb/libweb": {
            "version": "0.2.0-develop.30",
            "resolved": "https://registry.npmjs.org/@lumeweb/libweb/-/libweb-0.2.0-develop.30.tgz",
@ -3469,6 +3495,24 @@
                "node": ">=6.5"
            }
        },
+        "node_modules/abstract-level": {
+            "version": "1.0.3",
+            "resolved": "https://registry.npmjs.org/abstract-level/-/abstract-level-1.0.3.tgz",
+            "integrity": "sha512-t6jv+xHy+VYwc4xqZMn2Pa9DjcdzvzZmQGRjTFc8spIbRGHgBrEKbPq+rYXc7CCo0lxgYvSgKVg9qZAhpVQSjA==",
+            "dev": true,
+            "dependencies": {
+                "buffer": "^6.0.3",
+                "catering": "^2.1.0",
+                "is-buffer": "^2.0.5",
+                "level-supports": "^4.0.0",
+                "level-transcoder": "^1.0.1",
+                "module-error": "^1.0.1",
+                "queue-microtask": "^1.2.3"
+            },
+            "engines": {
+                "node": ">=12"
+            }
+        },
        "node_modules/acorn": {
            "version": "8.9.0",
            "resolved": "https://registry.npmjs.org/acorn/-/acorn-8.9.0.tgz",
@ -4002,6 +4046,18 @@
            "integrity": "sha512-cKV8tMCEpQs4hK/ik71d6LrPOnpkpGBR0wzxqr68g2m/LB2GxVYQroAjMJZRVM1Y4BCjCKc3vAamxSzOY2RP+w==",
            "dev": true
        },
+        "node_modules/browser-level": {
+            "version": "1.0.1",
+            "resolved": "https://registry.npmjs.org/browser-level/-/browser-level-1.0.1.tgz",
+            "integrity": "sha512-XECYKJ+Dbzw0lbydyQuJzwNXtOpbMSq737qxJN11sIRTErOMShvDpbzTlgju7orJKvx4epULolZAuJGLzCmWRQ==",
+            "dev": true,
+            "dependencies": {
+                "abstract-level": "^1.0.2",
+                "catering": "^2.1.1",
+                "module-error": "^1.0.2",
+                "run-parallel-limit": "^1.1.0"
+            }
+        },
        "node_modules/browser-resolve": {
            "version": "2.0.0",
            "resolved": "https://registry.npmjs.org/browser-resolve/-/browser-resolve-2.0.0.tgz",
@ -4446,6 +4502,15 @@
                "cdl": "bin/cdl.js"
            }
        },
+        "node_modules/catering": {
+            "version": "2.1.1",
+            "resolved": "https://registry.npmjs.org/catering/-/catering-2.1.1.tgz",
+            "integrity": "sha512-K7Qy8O9p76sL3/3m7/zLKbRkyOlSZAgzEaLhyj2mXS8PsCud2Eo4hAb8aLtZqHh0QGqLcb9dlJSu6lHRVENm1w==",
+            "dev": true,
+            "engines": {
+                "node": ">=6"
+            }
+        },
        "node_modules/chalk": {
            "version": "4.1.2",
            "resolved": "https://registry.npmjs.org/chalk/-/chalk-4.1.2.tgz",
@ -4548,6 +4613,23 @@
            "integrity": "sha512-0TNiGstbQmCFwt4akjjBg5pLRTSyj/PkWQ1ZoO2zntmg9yLqSRxwEa4iCfQLGjqhiqBfOJa7W/E8wfGrTDmlZQ==",
            "peer": true
        },
+        "node_modules/classic-level": {
+            "version": "1.3.0",
+            "resolved": "https://registry.npmjs.org/classic-level/-/classic-level-1.3.0.tgz",
+            "integrity": "sha512-iwFAJQYtqRTRM0F6L8h4JCt00ZSGdOyqh7yVrhhjrOpFhmBjNlRUey64MCiyo6UmQHMJ+No3c81nujPv+n9yrg==",
+            "dev": true,
+            "hasInstallScript": true,
+            "dependencies": {
+                "abstract-level": "^1.0.2",
+                "catering": "^2.1.0",
+                "module-error": "^1.0.1",
+                "napi-macros": "^2.2.2",
+                "node-gyp-build": "^4.3.0"
+            },
+            "engines": {
+                "node": ">=12"
+            }
+        },
        "node_modules/clean-stack": {
            "version": "2.2.0",
            "resolved": "https://registry.npmjs.org/clean-stack/-/clean-stack-2.2.0.tgz",
@ -8281,6 +8363,29 @@
                "url": "https://github.com/sponsors/ljharb"
            }
        },
+        "node_modules/is-buffer": {
+            "version": "2.0.5",
+            "resolved": "https://registry.npmjs.org/is-buffer/-/is-buffer-2.0.5.tgz",
+            "integrity": "sha512-i2R6zNFDwgEHJyQUtJEk0XFi1i0dPFn/oqjK3/vPCcDeJvW5NQ83V8QbicfF1SupOaB0h8ntgBC2YiE7dfyctQ==",
+            "dev": true,
+            "funding": [
+                {
+                    "type": "github",
+                    "url": "https://github.com/sponsors/feross"
+                },
+                {
+                    "type": "patreon",
+                    "url": "https://www.patreon.com/feross"
+                },
+                {
+                    "type": "consulting",
+                    "url": "https://feross.org/support"
+                }
+            ],
+            "engines": {
+                "node": ">=4"
+            }
+        },
        "node_modules/is-builtin-module": {
            "version": "3.2.1",
            "resolved": "https://registry.npmjs.org/is-builtin-module/-/is-builtin-module-3.2.1.tgz",
@ -9594,6 +9699,45 @@
                "url": "https://github.com/chalk/strip-ansi?sponsor=1"
            }
        },
+        "node_modules/level": {
+            "version": "8.0.0",
+            "resolved": "https://registry.npmjs.org/level/-/level-8.0.0.tgz",
+            "integrity": "sha512-ypf0jjAk2BWI33yzEaaotpq7fkOPALKAgDBxggO6Q9HGX2MRXn0wbP1Jn/tJv1gtL867+YOjOB49WaUF3UoJNQ==",
+            "dev": true,
+            "dependencies": {
+                "browser-level": "^1.0.1",
+                "classic-level": "^1.2.0"
+            },
+            "engines": {
+                "node": ">=12"
+            },
+            "funding": {
+                "type": "opencollective",
+                "url": "https://opencollective.com/level"
+            }
+        },
+        "node_modules/level-supports": {
+            "version": "4.0.1",
+            "resolved": "https://registry.npmjs.org/level-supports/-/level-supports-4.0.1.tgz",
+            "integrity": "sha512-PbXpve8rKeNcZ9C1mUicC9auIYFyGpkV9/i6g76tLgANwWhtG2v7I4xNBUlkn3lE2/dZF3Pi0ygYGtLc4RXXdA==",
+            "dev": true,
+            "engines": {
+                "node": ">=12"
+            }
+        },
+        "node_modules/level-transcoder": {
+            "version": "1.0.1",
+            "resolved": "https://registry.npmjs.org/level-transcoder/-/level-transcoder-1.0.1.tgz",
+            "integrity": "sha512-t7bFwFtsQeD8cl8NIoQ2iwxA0CL/9IFw7/9gAjOonH0PWTTiRfY7Hq+Ejbsxh86tXobDQ6IOiddjNYIfOBs06w==",
+            "dev": true,
+            "dependencies": {
+                "buffer": "^6.0.3",
+                "module-error": "^1.0.1"
+            },
+            "engines": {
+                "node": ">=12"
+            }
+        },
        "node_modules/leven": {
            "version": "3.1.0",
            "resolved": "https://registry.npmjs.org/leven/-/leven-3.1.0.tgz",
@ -10838,6 +10982,15 @@
                "node": ">=0.10.0"
            }
        },
+        "node_modules/module-error": {
+            "version": "1.0.2",
+            "resolved": "https://registry.npmjs.org/module-error/-/module-error-1.0.2.tgz",
+            "integrity": "sha512-0yuvsqSCv8LbaOKhnsQ/T5JhyFlCYLPXK3U2sgV10zoKQwzs/MyfuQUOZQ1V/6OCOJsK/TRgNVrPuPDqtdMFtA==",
+            "dev": true,
+            "engines": {
+                "node": ">=10"
+            }
+        },
        "node_modules/ms": {
            "version": "2.1.2",
            "resolved": "https://registry.npmjs.org/ms/-/ms-2.1.2.tgz",
@ -10888,6 +11041,12 @@
                "node": "^10 || ^12 || ^13.7 || ^14 || >=15.0.1"
            }
        },
+        "node_modules/napi-macros": {
+            "version": "2.2.2",
+            "resolved": "https://registry.npmjs.org/napi-macros/-/napi-macros-2.2.2.tgz",
+            "integrity": "sha512-hmEVtAGYzVQpCKdbQea4skABsdXW4RUh5t5mJ2zzqowJS2OyXZTU1KhDVFhx+NlWZ4ap9mqR9TcDO3LTTttd+g==",
+            "dev": true
+        },
        "node_modules/natural-compare": {
            "version": "1.4.0",
            "resolved": "https://registry.npmjs.org/natural-compare/-/natural-compare-1.4.0.tgz",
@ -10985,6 +11144,17 @@
                "node": "^12.13 || ^14.13 || >=16"
            }
        },
+        "node_modules/node-gyp-build": {
+            "version": "4.6.1",
+            "resolved": "https://registry.npmjs.org/node-gyp-build/-/node-gyp-build-4.6.1.tgz",
+            "integrity": "sha512-24vnklJmyRS8ViBNI8KbtK/r/DmXQMRiOMXTNz2nrTnAYUwjmEEbnnpB/+kt+yWRv73bPsSPRFddrcIbAxSiMQ==",
+            "dev": true,
+            "bin": {
+                "node-gyp-build": "bin.js",
+                "node-gyp-build-optional": "optional.js",
+                "node-gyp-build-test": "build-test.js"
+            }
+        },
        "node_modules/node-gyp/node_modules/abbrev": {
            "version": "1.1.1",
            "resolved": "https://registry.npmjs.org/abbrev/-/abbrev-1.1.1.tgz",
@ -16258,6 +16428,29 @@
                "queue-microtask": "^1.2.2"
            }
        },
+        "node_modules/run-parallel-limit": {
+            "version": "1.1.0",
+            "resolved": "https://registry.npmjs.org/run-parallel-limit/-/run-parallel-limit-1.1.0.tgz",
+            "integrity": "sha512-jJA7irRNM91jaKc3Hcl1npHsFLOXOoTkPCUL1JEa1R82O2miplXXRaGdjW/KM/98YQWDhJLiSs793CnXfblJUw==",
+            "dev": true,
+            "funding": [
+                {
+                    "type": "github",
+                    "url": "https://github.com/sponsors/feross"
+                },
+                {
+                    "type": "patreon",
+                    "url": "https://www.patreon.com/feross"
+                },
+                {
+                    "type": "consulting",
+                    "url": "https://feross.org/support"
+                }
+            ],
+            "dependencies": {
+                "queue-microtask": "^1.2.2"
+            }
+        },
        "node_modules/rxjs": {
            "version": "7.8.1",
            "resolved": "https://registry.npmjs.org/rxjs/-/rxjs-7.8.1.tgz",
@ -19421,6 +19614,27 @@
                "url": "https://github.com/sponsors/sindresorhus"
            }
        },
+        "node_modules/ws": {
+            "version": "8.13.0",
+            "resolved": "https://registry.npmjs.org/ws/-/ws-8.13.0.tgz",
+            "integrity": "sha512-x9vcZYTrFPC7aSIbj7sRCYo7L/Xb8Iy+pW0ng0wt2vCJv7M9HOMy0UoN3rr+IFC7hb7vXoqS+P9ktyLLLhO+LA==",
+            "dev": true,
+            "engines": {
+                "node": ">=10.0.0"
+            },
+            "peerDependencies": {
+                "bufferutil": "^4.0.1",
+                "utf-8-validate": ">=5.0.2"
+            },
+            "peerDependenciesMeta": {
+                "bufferutil": {
+                    "optional": true
+                },
+                "utf-8-validate": {
+                    "optional": true
+                }
+            }
+        },
        "node_modules/xtend": {
            "version": "4.0.2",
            "resolved": "https://registry.npmjs.org/xtend/-/xtend-4.0.2.tgz",
--- a/package.json
+++ b/package.json
@ -1,12 +1,13 @@
 {
    "name": "@lumeweb/kernel",
-    "version": "0.1.0-develop.4",
+    "version": "0.1.0-develop.5",
    "type": "module",
    "repository": {
        "type": "git",
        "url": "gitea@git.lumeweb.com:LumeWeb/kernel.git"
    },
    "devDependencies": {
+        "@lumeweb/libs5": "^0.1.0-develop.25",
        "@lumeweb/presetter-kernel-module-preset": "^0.1.0-develop.43",
        "binconv": "^0.2.0",
        "presetter": "*",
--- a/src/coreModules.ts
+++ b/src/coreModules.ts
@ -0,0 +1,45 @@
+import { internalModuleCall, modules } from "./queries.js";
+import { SignedRegistryEntry } from "@lumeweb/libs5";
+import { base58btc } from "multiformats/bases/base58";
+
+const CORE_MODULES = {
+  swarm: "",
+  peerDiscoveryRegistry: "",
+  ircPeerDiscovery: "",
+  s5: "",
+};
+
+export default CORE_MODULES;
+
+export async function networkReady() {
+  for (const module of [
+    CORE_MODULES.peerDiscoveryRegistry,
+    CORE_MODULES.ircPeerDiscovery,
+    CORE_MODULES.swarm,
+  ]) {
+    if (!moduleLoaded(module)) {
+      return false;
+    }
+  }
+
+  const resolvers = await internalModuleCall(
+    CORE_MODULES.peerDiscoveryRegistry,
+    "getRelays",
+  );
+
+  return resolvers.length > 0;
+}
+
+function moduleLoaded(module: string) {
+  return module in modules;
+}
+
+export async function resolveModuleRegistryEntry(pubkey: string) {
+  const signedEntry = (await internalModuleCall(
+    CORE_MODULES.s5,
+    "getRegistryEntry",
+    { pubkey },
+  )) as SignedRegistryEntry;
+
+  return base58btc.encode(signedEntry.data);
+}
--- a/src/message.ts
+++ b/src/message.ts
@ -93,7 +93,7 @@ export const handleIncomingMessage = function (event: any) {
    } else {
      domain = new URL(event.origin).hostname;
    }
-    handleModuleCall(event, event.source, domain, false);
+    handleModuleCall(event, event.source, domain, false, false);
    return;
  }
  if (event.data.method === "queryUpdate") {
--- a/src/queries.ts
+++ b/src/queries.ts
@ -13,10 +13,14 @@ import {
 import {
  deriveChildKey,
  downloadSmallObject,
+  hexToBytes,
  verifyCid,
 } from "@lumeweb/libweb";
 import type { moduleQuery, presentKeyData } from "@lumeweb/libkernel/module";
 import { readableStreamToUint8Array } from "binconv";
+import { getSavedRegistryEntry } from "./registry.js";
+import { defer } from "@lumeweb/libkernel/module";
+import { networkReady, resolveModuleRegistryEntry } from "./coreModules.js";

 // WorkerLaunchFn is the type signature of the function that launches the
 // worker to set up for processing a query.
@ -38,6 +42,8 @@ interface Module {
 // OpenQuery holds all of the information necessary for managing an open query.
 interface OpenQuery {
  isWorker: boolean;
+  isInternal: boolean;
+  internalHandler?: (message: OpenQueryResponse) => void;
  domain: string;
  source: any;
  dest: Worker;
@ -45,13 +51,19 @@ interface OpenQuery {
  origin: string;
 }

+interface OpenQueryResponse {
+  nonce: string;
+  method: string;
+  data: any;
+  err?: any;
+}
+
 // Define the stateful variables for managing the modules. We track the set of
 // queries that are in progress, the set of skapps that are known to the
 // kernel, the set of modules that we've downloaded, and the set of modules
 // that are actively being downloaded.
 let queriesNonce = 0;
-const queries = {} as any;
-const skapps = {} as any;
+const queries = {} as { [module: string]: OpenQuery };
 const modules = {} as any;
 const modulesLoading = {} as any;

@ -176,7 +188,7 @@ function handleWorkerMessage(event: MessageEvent, mod: Module, worker: Worker) {

  // Handle a call from the worker to another module.
  if (event.data.method === "moduleCall") {
-    handleModuleCall(event, worker, mod.domain, true);
+    handleModuleCall(event, worker, mod.domain, true, false);
    return;
  }

@ -288,11 +300,12 @@ function launchWorker(mod: Module): [Worker, Err] {

 // handleModuleCall will handle a callModule message sent to the kernel from an
 // extension or webpage.
-function handleModuleCall(
+async function handleModuleCall(
  event: MessageEvent,
  messagePortal: any,
  callerDomain: string,
  isWorker: boolean,
+  isInternal: false | ((message: OpenQueryResponse) => void),
 ) {
  if (!("data" in event.data) || !("module" in event.data.data)) {
    logErr(
@ -308,16 +321,22 @@ function handleModuleCall(
    );
    return;
  }
+
+  let isRegistryEntry = false;
+  try {
+    isRegistryEntry = hexToBytes(event.data.data.module)?.length === 32;
+  } catch {}
+
  if (
    typeof event.data.data.module !== "string" ||
-    !verifyCid(event.data.data.module)
+    (!verifyCid(event.data.data.module) && !isRegistryEntry)
  ) {
    logErr("moduleCall", "received moduleCall with malformed module");
    respondErr(
      event,
      messagePortal,
      isWorker,
-      "'module' field in moduleCall is expected to be a base58 encoded blake3 hash + filesize",
+      "'module' field in moduleCall is expected to be a base58 encoded blake3 hash + filesize or a registry entry pubkey",
    );
    return;
  }
@ -337,7 +356,7 @@ function handleModuleCall(
  if (typeof event.data.data.method !== "string") {
    logErr(
      "moduleCall",
-      "recieved moduleCall with malformed method",
+      "received moduleCall with malformed method",
      event.data,
    );
    respondErr(
@ -357,7 +376,7 @@ function handleModuleCall(
      event,
      messagePortal,
      isWorker,
-      "presentSeed is a priviledged method, only root is allowed to use it",
+      "presentSeed is a privileged method, only root is allowed to use it",
    );
    return;
  }
@ -372,10 +391,37 @@ function handleModuleCall(
    return;
  }

-  // TODO: Load any overrides.
-  const finalModule = event.data.data.module; // Can change with overrides.
-  const moduleDomain = event.data.data.module; // Does not change with overrides.
+  let moduleDomain = event.data.data.module; // Can change with overrides.
+  let finalModule = moduleDomain; // Can change with overrides.

+  if (isRegistryEntry) {
+    const registryFail = () => {
+      logErr("moduleCall", "received moduleCall with no known registry entry");
+      respondErr(
+        event,
+        messagePortal,
+        isWorker,
+        "registry entry for module is not found",
+      );
+    };
+
+    finalModule = getSavedRegistryEntry(moduleDomain);
+    if (!finalModule) {
+      if (!(await networkReady())) {
+        registryFail();
+        return;
+      }
+      let resolvedModule;
+
+      try {
+        resolvedModule = await resolveModuleRegistryEntry(finalModule);
+      } catch (e) {
+        registryFail();
+        return;
+      }
+      finalModule = resolvedModule;
+    }
+  }
  // Define a helper function to create a new query to the module. It will
  // both open a query on the module and also send an update message to the
  // caller with the kernel nonce for this query so that the caller can
@ -400,6 +446,8 @@ function handleModuleCall(
    queriesNonce = queriesNonce + 1;
    queries[nonce] = {
      isWorker,
+      isInternal: !!isInternal,
+      internalHandler: isInternal ?? undefined,
      domain: callerDomain,
      source: messagePortal,
      dest: worker,
@ -594,11 +642,14 @@ function handleModuleResponse(

  // We are sending either a response message or a responseUpdate message,
  // all other possibilities have been handled.
-  const sourceIsWorker = queries[event.data.nonce].isWorker;
-  const sourceNonce = queries[event.data.nonce].nonce;
-  const source = queries[event.data.nonce].source;
-  const origin = queries[event.data.nonce].origin;
-  const msg: any = {
+  const query = queries[event.data.nonce];
+  const sourceIsWorker = query.isWorker;
+  const sourceIsInternal = query.isInternal;
+  const internalHandler = query.internalHandler;
+  const sourceNonce = query.nonce;
+  const source = query.source;
+  const origin = query.origin;
+  const msg: OpenQueryResponse = {
    nonce: sourceNonce,
    method: event.data.method,
    data: event.data.data,
@ -609,8 +660,11 @@ function handleModuleResponse(
    msg["err"] = event.data.err;
    delete queries[event.data.nonce];
  }
-  if (sourceIsWorker === true) {
+
+  if (sourceIsWorker) {
    source.postMessage(msg);
+  } else if (sourceIsInternal) {
+    internalHandler?.(msg);
  } else {
    source.postMessage(msg, origin);
  }
@ -636,6 +690,39 @@ function handleQueryUpdate(event: MessageEvent) {
  });
 }

+export async function internalModuleCall(
+  module: string,
+  method: string,
+  params = {},
+): Promise<any> {
+  const callDefer = defer();
+  handleModuleCall(
+    {
+      data: {
+        data: {
+          module,
+          method,
+          data: params,
+          nonce: 0,
+        },
+      },
+      origin: "root",
+    } as any,
+    undefined,
+    "root",
+    false,
+    (message) => {
+      if (message.err) {
+        callDefer.reject(message.err);
+        return;
+      }
+      callDefer.resolve(message.data.data);
+    },
+  );
+
+  return callDefer.promise;
+}
+
 export {
  Module,
  handleModuleCall,
--- a/src/registry.ts
+++ b/src/registry.ts
@ -0,0 +1,20 @@
+const DEFAULT_MODULE_REGISTRY = new Map<string, string>(Object.entries({}));
+const REGISTRY_ITEM_ID = "registry";
+
+Object.freeze(DEFAULT_MODULE_REGISTRY);
+
+export function getSavedRegistryEntry(pubkey: string) {
+  const savedEntries = new Map<string, string>(
+    Object.entries(window.localStorage.getItem(REGISTRY_ITEM_ID) ?? {}),
+  );
+
+  if (savedEntries.has(pubkey)) {
+    return savedEntries.get(pubkey) as string;
+  }
+
+  if (DEFAULT_MODULE_REGISTRY.has(pubkey)) {
+    DEFAULT_MODULE_REGISTRY.get(pubkey) as string;
+  }
+
+  return null;
+}
Author	SHA1	Message	Date
semantic-release-bot	4cf87cc138	chore(release): 0.1.0-develop.5 [skip ci] # [0.1.0-develop.5](https://git.lumeweb.com/LumeWeb/kernel/compare/v0.1.0-develop.4...v0.1.0-develop.5) (2023-09-01) ### Bug Fixes * fix import ([`787c7c6`](`787c7c6637`)) ### Features * add initial fallback registry support ([`5cc457d`](`5cc457d78b`)) * add initial support to query the network for a registry entry for a module ([`ba4c6dc`](`ba4c6dcb95`))	2023-09-01 23:05:08 +00:00
Derrick Hammer	787c7c6637	fix: fix import	2023-09-01 19:04:07 -04:00
Derrick Hammer	841a13e849	Merge remote-tracking branch 'origin/develop' into develop	2023-09-01 18:59:15 -04:00
Derrick Hammer	ba4c6dcb95	feat: add initial support to query the network for a registry entry for a module	2023-09-01 18:59:06 -04:00
Derrick Hammer	5cc457d78b	feat: add initial fallback registry support	2023-09-01 15:38:24 -04:00