Move schema/crypto/spec to platform

commons/interfaces/ITypedEventEmitter.ts

@@ -1,3 +1,5 @@
+import IRegisteredEventListener from './IRegisteredEventListener';
+
 export default interface ITypedEventEmitter<T> {
   on<K extends keyof T & (string | symbol)>(
     eventType: K,
@@ -42,4 +44,8 @@ export default interface ITypedEventEmitter<T> {
   ): this;
 
   removeAllListeners(event?: string | symbol): this;
+  addEventEmitter<K extends keyof T & (string | symbol)>(
+    emitter: ITypedEventEmitter<T>,
+    eventTypes: K[],
+  ): IRegisteredEventListener[];
 }

commons/lib/Logger.ts

@@ -291,7 +291,6 @@ function extractPathFromModule(module: NodeModule): string {
     moduleNamesByPath[fullPath] = fullPath
       .replace(/^(.*)[/\\]unblocked[/\\](.+)$/, '$2')
       .replace(/^(.*)[/\\]ulixee[/\\](.+)$/, '$2')
-      .replace(/^(.*)[/\\]payments[/\\](.+)$/, '$2')
       .replace(/^(.*)[/\\]@ulixee[/\\](.+)$/, '$2')
       .replace(/^(.*)[/\\]commons[/\\](.+)$/, '$2')
       .replace(/^.*[/\\]packages[/\\](.+)$/, '$1');
@@ -370,6 +369,7 @@ registerNamespaceMapping((ns, active, skip) => {
       /net\/.*/,
       /cloud\/.*/,
       /datastore[/-].*/,
+      /broker\/.*/,
       /mainchain[/-].*/,
       /sidechain[/-].*/,
       /ramps[/-].*/,

commons/lib/asyncUtils.ts

@@ -1,15 +1,25 @@
-export function debounce(func: () => any, wait: number): () => void {
+export function debounce<T extends (...args: any[]) => void | Promise<void>>(
+  func: T,
+  wait: number,
+  maxWait?: number,
+): T {
   let timeout: NodeJS.Timeout;
+  let lastRun: number;
 
-  return function runLater() {
+  return function runLater(...args: any[]) {
     function later(): void {
       timeout = undefined;
-      func();
+      void func(...args);
     }
-
     clearTimeout(timeout);
-    timeout = setTimeout(later, wait).unref();
-  };
+
+    if (maxWait && Date.now() - lastRun > maxWait) {
+      void func(...args);
+    } else {
+      timeout = setTimeout(later, wait).unref();
+    }
+    lastRun = Date.now();
+  } as T;
 }
 
 export function length(source: AsyncIterable<unknown>): Promise<number> {

commons/lib/fileUtils.ts

@@ -21,7 +21,7 @@ export async function copyDir(fromDir: string, toDir: string): Promise<void> {
 }
 
 export async function readFileAsJson<T>(path: string): Promise<T> {
-  const buffer = await Fs.readFile(path, 'utf8');
+  const buffer = await Fs.readFile(path, 'utf8').catch(() => null);
   if (!buffer) return null;
   return JSON.parse(buffer) as T;
 }

commons/lib/objectUtils.ts

@@ -22,3 +22,18 @@ export function omit<T, Keys extends keyof T & string>(
   }
   return result;
 }
+
+export function pick<T, Keys extends keyof T & string>(
+  object: T,
+  keys: Keys[],
+): Pick<T, Exclude<keyof T, Keys>> {
+  object = Object(object);
+  const result = {} as any;
+
+  for (const [key, value] of Object.entries(object)) {
+    if (keys.includes(key as any)) {
+      result[key] = value;
+    }
+  }
+  return result;
+}

commons/lib/utils.ts

@@ -24,22 +24,29 @@ export function toUrl(hostOrUrlFragment: string, defaultProtocol = 'ws:'): URL {
 
 export function isPortInUse(port: number | string): Promise<boolean> {
   return new Promise<boolean>((resolve, reject) => {
-    const client = new net.Socket();
+    const server = net.createServer();
 
-    let isInUse = true;
-    client.once('error', err => {
-      if ((err as any).code === 'ECONNREFUSED') {
-        isInUse = false;
-        resolve(isInUse);
+    server.once('error', err => {
+      if ((err as any).code === 'EADDRINUSE') {
+        resolve(true); // Port is in use
       } else {
         reject(err);
       }
-      client.removeAllListeners().end().destroy().unref();
+      cleanup();
     });
-    client.connect(Number(port), () => {
-      resolve(isInUse);
-      client.removeAllListeners().end().destroy().unref();
+
+    server.once('listening', () => {
+      resolve(false);
+      cleanup();
     });
+
+    const cleanup = (): void => {
+      server.removeAllListeners();
+      server.unref();
+      server.close();
+    };
+
+    server.listen(Number(port));
   });
 }