peerjs/lib/baseconnection.ts

import { EventEmitter } from "eventemitter3";
import { Peer } from "./peer";
import { RTCPeerConnection } from "./adapter";
import { ServerMessage } from "./servermessage";
import { ConnectionType } from "./enums";

export abstract class BaseConnection extends EventEmitter {
  protected _open = false;

  readonly metadata: any;
  connectionId: string;

  peerConnection: RTCPeerConnection;

  abstract get type(): ConnectionType;

  get open() {
    return this._open;
  }

  constructor(
    readonly peer: string,
    readonly provider: Peer,
    readonly options: any
  ) {
    super();

    this.metadata = options.metadata;
    this.connectionId = options.connectionId;
  }

  abstract close(): void;

  abstract handleMessage(message: ServerMessage): void;
}