✨ Add accepting abort controller signal

api/client.ts

@@ -7,7 +7,9 @@ const client = async <T extends Registry>(
 ) => {
   const url = stringify({ name, ...option });
 
-  const res = await fetch(url);
+  const res = await fetch(url, {
+    signal: option.signal,
+  });
   return await res.json() as RegisterableResult<T>;
 };
 

cli/_utils.ts

@@ -3,7 +3,7 @@ import { RegisterableResult, Registry } from "../types/mod.ts";
 import { summarize } from "../format/json.ts";
 import { flattenDeep, pipe, uniq } from "../deps.ts";
 
-const query2Direct = async <T extends Registry>(
+const server = async <T extends Registry>(
   queries: any[],
   name: string,
 ): Promise<RegisterableResult<T>> => {
@@ -16,4 +16,4 @@ const uniqFlatten = pipe(flattenDeep, uniq);
 const mapper = <T, U>(map: Record<PropertyKey, T>, val: U[]): T[] =>
   val.map((key) => map[key as any]);
 
-export { mapper, query2Direct, uniqFlatten };
+export { mapper, server, uniqFlatten };

cli/_utils_test.ts

@@ -1,5 +1,5 @@
 // Copyright 2021-present the Registerable authors. All rights reserved. MIT license.
-import { query2Direct, uniqFlatten } from "./_utils.ts";
+import { server, uniqFlatten } from "./_utils.ts";
 import { assertEquals } from "../dev_deps.ts";
 import { QUERY_MAP } from "../constants/query.ts";
 
@@ -20,7 +20,7 @@ Deno.test("uniqFlatten", () => {
   });
 });
 
-Deno.test("query2Direct", async () => {
+Deno.test("server", async () => {
   const table: [unknown[], string, Record<PropertyKey, unknown>][] = [
     [[], "fonction", {
       error: {},
@@ -99,9 +99,9 @@ Deno.test("query2Direct", async () => {
 
   await Promise.all(table.map(async ([queries, name, expected]) => {
     assertEquals(
-      await query2Direct(queries, name),
+      await server(queries, name),
       expected,
-      `query2Direct(${queries}, ${name}) -> ${expected}`,
+      `server(${queries}, ${name}) -> ${expected}`,
     );
   }));
 });

cli/constants.ts

@@ -1,6 +1,6 @@
 import type { Option } from "../types/mod.ts";
 
-type CommandLine = Omit<Option, "mode"> & {
+type CommandLine = Omit<Option, "mode" | "signal"> & {
   verbose: boolean;
   json: boolean;
 };

cli/deno.ts

@@ -1,11 +1,7 @@
 // Copyright 2021-present the Registerable authors. All rights reserved. MIT license.
 import yargs from "https://deno.land/x/yargs@v17.0.1-deno/deno.ts";
 import type { Option } from "../types/mod.ts";
-
-type CommandLine = Omit<Option, "mode"> & {
-  verbose: boolean;
-  json: boolean;
-};
+import { CommandLine } from "./constants.ts";
 
 const defaultOption: CommandLine = {
   verbose: false,

cli/mod.ts

@@ -3,7 +3,7 @@ import { loggerFactory, logTableFactory } from "../log/log.ts";
 import { QUERY_MAP } from "../constants/mod.ts";
 import { entries, ifElse, NN } from "../deps.ts";
 import { CommandLine, defaultOption } from "./constants.ts";
-import { mapper, query2Direct, uniqFlatten } from "./_utils.ts";
+import { mapper, server, uniqFlatten } from "./_utils.ts";
 
 const checkNameWithLog = async (
   name: string,
@@ -21,7 +21,7 @@ const checkNameWithLog = async (
 
   const query = uniqFlatten(mapper(QUERY_MAP, registry)).filter((fn) => NN(fn));
 
-  const { result, error, hasError, errorRegistry } = await query2Direct(
+  const { result, error, hasError, errorRegistry } = await server(
     query,
     name,
   );

registerable.ts

@@ -2,13 +2,14 @@
 import { QUERY_MAP } from "./constants/mod.ts";
 import { ifElse, NN } from "./deps.ts";
 import { client } from "./api/client.ts";
-import { mapper, query2Direct, uniqFlatten } from "./cli/_utils.ts";
+import { mapper, server, uniqFlatten } from "./cli/_utils.ts";
 import { Option, Registry } from "./types/mod.ts";
 import { RegisterableResult } from "./types/mod.ts";
 
 const defaultOption: Option = {
   mode: "server",
   registry: ["deno.land", "nest.land", "npm"],
+  signal: undefined,
 };
 
 /**
@@ -65,14 +66,15 @@ const registerable = async <T extends Registry>(
   const {
     mode = defaultOption.mode,
     registry = defaultOption.registry,
+    signal = defaultOption.signal,
   } = option || defaultOption;
 
   const query = uniqFlatten(mapper(QUERY_MAP, registry)).filter((fn) => NN(fn));
 
   return await ifElse(
     mode === "server",
-    async () => await query2Direct(query, name),
-    async () => await client(name, { registry }),
+    async () => await server(query, name),
+    async () => await client(name, { registry, signal }),
   );
 };
 

types/mod.ts

@@ -16,6 +16,7 @@ interface RegisterableResult<T extends Registry = Registry> {
 type Option<T extends Registry = Registry> = {
   registry: T[];
   mode: "server" | "universal";
+  signal?: RequestInit["signal"];
 };
 
 export type { Option, RegisterableResult, Registry };