metacom.d.ts

import { EventEmitter } from 'events';
import { ClientRequest, ServerResponse } from 'http';
import WebSocket from 'ws';
import { Semaphore } from 'metautil';

export interface MetacomError extends Error {
  code: string;
}

export class Metacom extends EventEmitter {
  url: string;
  socket: WebSocket;
  api: object;
  callId: number;
  calls: Map<number, [Function, Function]>;
  constructor(url: string);
  static create(url: string, options?: unknown): Metacom;
  ready(): Promise<void>;
  load(...interfaces: Array<string>): Promise<void>;
  httpCall(
    iname: string,
    ver: string
  ): (methodName: string) => (args: object) => Promise<void>;
  socketCall(
    iname: string,
    ver: string
  ): (methodName: string) => (args: object) => Promise<void>;
}

export interface Options {
  concurrency: number;
  host: string;
  port: number;
  kind: 'server' | 'balancer';
  protocol: string;
  ports: Array<number>;
  queue: object;
}

export class Session {
  constructor(token: string, channel: Channel, data: any);
}

export interface ErrorOptions {
  callId?: number;
  error?: Error;
  pass?: boolean;
}

export class Client extends EventEmitter {
  events: { close: Array<Function> };
  callId: number;
  ip: string | undefined;
  redirect(location: string): void;
  startSession(token: string, data: object): boolean;
  restoreSession(token: string): boolean;
}

export class Channel {
  application: object;
  req: ClientRequest;
  res: ServerResponse;
  ip: string;
  client: Client;
  session?: Session;
  constructor(application: object, req: ClientRequest, res: ServerResponse);
  message(data: string): void;
  prc(
    callId: number,
    interfaceName: string,
    methodName: string,
    args: []
  ): Promise<void>;
  restoreSession(): Promise<Session | null>;
  destroy(): void;
  error(code: number, errorOptions?: ErrorOptions): void;
}

export class HttpChannel extends Channel {
  write(data: any, httpCode?: number, ext?: string): void;
  send(obj: object, httpCode?: number): void;
  redirect(location: string): void;
  options(): void;
  hook(
    proc: object,
    interfaceName: string,
    methodName: string,
    args: Array<any>
  ): Promise<void>;
  startSession(): Session;
  deleteSession(): void;
}

export class WsChannel extends Channel {
  connection: WebSocket;
  constructor(application: object, req: ClientRequest, connection: WebSocket);
  write(data: any): void;
  send(obj: object): void;
  redirect(location: string): void;
  options(): void;
  hook(
    proc: object,
    interfaceName: string,
    methodName: string,
    args: Array<any>
  ): Promise<void>;
  startSession(): Session;
  deleteSession(): void;
}

export class Server {
  options: Options;
  application: object;
  semaphore: Semaphore;
  server?: any;
  ws?: any;
  constructor(options: Options, application: object);
  bind(): void;
  listener(req: ClientRequest, res: ServerResponse): void;
  request(channel: Channel): void;
  closeChannels(): void;
  close(): Promise<void>;
}