*Update dist

dist/index.d.ts

@@ -1,6 +1,19 @@
-import { ResolverModuleConstructor } from "./resolverRegistry.js";
-export declare function setup(rm: ResolverModuleConstructor): void;
-export * from "./resolverRegistry.js";
+import type { DNSResult } from "@lumeweb/libresolver";
+import { DnsClient } from "@lumeweb/kernel-dns-client";
+import { ResolverOptions } from "@lumeweb/libresolver/src/types.js";
+export interface ResolverModule {
+  get resolver(): DnsClient;
+  set resolver(value: DnsClient);
+  resolve(
+    domain: string,
+    options: ResolverOptions,
+    bypassCache: boolean
+  ): Promise<DNSResult>;
+  getSupportedTlds(): string[];
+  getSupportedTlds(): Promise<string[]>;
+  getSupportedTlds(): any;
+}
+export declare function setup(rm: ResolverModule): void;
 export * from "@lumeweb/libresolver/dist/util.js";
 export * from "@lumeweb/libresolver/dist/types.js";
 export { AbstractResolverModule } from "@lumeweb/libresolver/dist/resolverModule.js";

dist/index.js

@@ -1,5 +1,4 @@
 import { addHandler, handleMessage } from "libkmodule";
-import { ResolverRegistry, } from "./resolverRegistry.js";
 import { DNS_RECORD_TYPE } from "@lumeweb/libresolver";
 import { dnsClient } from "./client.js";
 let resolver;
@@ -8,7 +7,8 @@ export function setup(rm) {
     addHandler("register", handleRegister);
     addHandler("getSupportedTlds", handleGetSupportedTlds);
     onmessage = handleMessage;
-    resolver = new rm(new ResolverRegistry());
+    resolver = rm;
+    resolver.resolver = dnsClient;
 }
 async function handleRegister(aq) {
     await dnsClient.register();
@@ -36,7 +36,6 @@ async function handleResolve(aq) {
 function handleGetSupportedTlds(aq) {
     aq.respond(resolver.getSupportedTlds());
 }
-export * from "./resolverRegistry.js";
 export * from "@lumeweb/libresolver/dist/util.js";
 export * from "@lumeweb/libresolver/dist/types.js";
 export { AbstractResolverModule } from "@lumeweb/libresolver/dist/resolverModule.js";

src/index.ts

@@ -1,22 +1,37 @@
 import { addHandler, ActiveQuery, handleMessage } from "libkmodule";
 
-import type { DNSResult } from "@lumeweb/libresolver";
-import {
-  ResolverModule,
-  ResolverModuleConstructor,
-  ResolverRegistry,
-} from "./resolverRegistry.js";
+import type {
+  DNSResult,
+  ResolverModule as ResolverModuleBase,
+} from "@lumeweb/libresolver";
 import { DNS_RECORD_TYPE } from "@lumeweb/libresolver";
 import { dnsClient } from "./client.js";
+import { DnsClient } from "@lumeweb/kernel-dns-client";
+import { ResolverOptions } from "@lumeweb/libresolver/src/types.js";
 
 let resolver: ResolverModule;
 
-export function setup(rm: ResolverModuleConstructor) {
+export interface ResolverModule {
+  get resolver(): DnsClient;
+  set resolver(value: DnsClient);
+  resolve(
+    domain: string,
+    options: ResolverOptions,
+    bypassCache: boolean
+  ): Promise<DNSResult>;
+
+  getSupportedTlds(): string[];
+  getSupportedTlds(): Promise<string[]>;
+  getSupportedTlds(): any;
+}
+
+export function setup(rm: ResolverModule) {
   addHandler("resolve", handleResolve);
   addHandler("register", handleRegister);
   addHandler("getSupportedTlds", handleGetSupportedTlds);
   onmessage = handleMessage;
-  resolver = new rm(new ResolverRegistry());
+  resolver = rm;
+  resolver.resolver = dnsClient;
 }
 
 async function handleRegister(aq: ActiveQuery) {
@@ -54,7 +69,6 @@ function handleGetSupportedTlds(aq: ActiveQuery) {
   aq.respond(resolver.getSupportedTlds());
 }
 
-export * from "./resolverRegistry.js";
 export * from "@lumeweb/libresolver/dist/util.js";
 export * from "@lumeweb/libresolver/dist/types.js";
 export { AbstractResolverModule } from "@lumeweb/libresolver/dist/resolverModule.js";

src/resolverRegistry.ts

@@ -1,75 +0,0 @@
-import {
-  DNSResult,
-  ResolverOptions,
-  DNS_RECORD_TYPE,
-  resolverError,
-  ResolverModuleConstructor as ResolverModuleConstructorBase,
-} from "@lumeweb/libresolver";
-import { Client, factory } from "@lumeweb/libkernel-universal";
-import { dnsClient } from "./client.js";
-
-export interface ResolverModuleConstructor
-  extends ResolverModuleConstructorBase {
-  new (resolver: ResolverRegistry): ResolverModule;
-}
-
-export class ResolverRegistry {
-  get resolvers(): Promise<Set<ResolverModule>> {
-    return dnsClient
-      .getResolvers()
-      .then((resolvers: string[]) => {
-        return new Set(
-          resolvers.map((resolver) =>
-            factory<ResolverModule>(ResolverModule, resolver)(this, resolver)
-          )
-        );
-      })
-      .catch(() => {
-        return new Set();
-      });
-  }
-
-  public async resolve(
-    domain: string,
-    options: ResolverOptions = { type: DNS_RECORD_TYPE.CONTENT },
-    bypassCache: boolean = false
-  ): Promise<DNSResult> {
-    try {
-      return dnsClient.resolve(domain, options, bypassCache);
-    } catch (e: any) {
-      return resolverError(e);
-    }
-  }
-  public register(resolver: ResolverModule): void {}
-  public clear(): void {}
-}
-
-export class ResolverModule extends Client {
-  private resolver: ResolverRegistry;
-  private domain: string;
-
-  constructor(resolver: ResolverRegistry, domain: string) {
-    super();
-    this.resolver = resolver;
-    this.domain = domain;
-  }
-
-  async resolve(
-    domain: string,
-    options: ResolverOptions,
-    bypassCache: boolean
-  ): Promise<DNSResult> {
-    try {
-      return this.callModuleReturn("resolve", {
-        domain,
-        options,
-        bypassCache,
-      });
-    } catch (e) {
-      return resolverError(e as Error);
-    }
-  }
-  async getSupportedTlds(): Promise<string[]> {
-    return this.callModuleReturn("getSupportedTlds");
-  }
-}