package.json

@@ -4,14 +4,13 @@
     "type": "module",
     "main": "dist/index.js",
     "dependencies": {
-        "@lumeweb/libkernel-universal": "git+https://git.lumeweb.com/LumeWeb/libkernel-universal.git",
+        "@lumeweb/resolver-common": "github:LumeWeb/resolver-common",
         "libkernel": "^0.1.43",
         "libkmodule": "^0.2.44",
         "libskynet": "^0.0.62"
     },
     "devDependencies": {
         "@types/node": "^18.0.6",
-        "prettier": "^2.7.1",
-        "typescript": "^4.9.5"
+        "prettier": "^2.7.1"
     }
 }

src/index.ts

@@ -1,20 +1,71 @@
-import { Client, factory } from "@lumeweb/libkernel-universal";
+import { DNS_RECORD_TYPE, ResolverOptions } from "@lumeweb/resolver-common";
 
-const MODULE = "PACYNuYbp_5hgCjMK16EGcytB9QCxDLe4_uitahwePdeaA";
+const DNS_MODULE = "AQBLKpieqOfKVRgMa8k45P4S_ILYgJmswVso4vT1qzoG-A";
 
-export class DnsClient extends Client {
-  public async register(): Promise<void> {
-    return this.callModuleReturn("register");
+let callModule: any, connectModule: any;
+
+async function loadLibs() {
+  if (callModule && connectModule) {
+    return;
   }
-  public async clear(): Promise<void> {
-    return this.callModuleReturn("clear");
-  }
-  public async getResolvers(): Promise<void> {
-    return this.callModuleReturn("clear");
-  }
-  public async ready(): Promise<void> {
-    return this.callModuleReturn("ready");
+  if (typeof window !== "undefined" && window?.document) {
+    const pkg = await import("libkernel");
+    callModule = pkg.callModule;
+    connectModule = pkg.connectModule;
+  } else {
+    const pkg = await import("libkmodule");
+    callModule = pkg.callModule;
+    connectModule = pkg.connectModule;
   }
 }
 
-export const createClient = factory<DnsClient>(DnsClient, MODULE);
+export async function resolve(
+  domain: string,
+  options: ResolverOptions = { type: DNS_RECORD_TYPE.CONTENT },
+  bypassCache = false
+) {
+  await loadLibs();
+  const [resp, err] = await callModule(DNS_MODULE, "resolve", {
+    domain,
+    options,
+    bypassCache,
+  });
+
+  if (err) {
+    throw new Error(err);
+  }
+
+  return resp;
+}
+
+export async function register() {
+  await loadLibs();
+  await callModule(DNS_MODULE, "register");
+}
+
+export async function clear() {
+  await loadLibs();
+  await callModule(DNS_MODULE, "clear");
+}
+
+export async function getResolvers() {
+  await loadLibs();
+  const [resp, err] = await callModule(DNS_MODULE, "getResolvers");
+
+  if (err) {
+    throw new Error(err);
+  }
+
+  return resp;
+}
+
+export async function ready() {
+  await loadLibs();
+  const [resp, err] = await callModule(DNS_MODULE, "ready");
+
+  if (err) {
+    throw new Error(err);
+  }
+
+  return resp;
+}