webrtc-signal-http
Advanced tools
Comparing version 2.0.0 to 2.0.1
/// <reference types="node" /> | ||
import { EventEmitter } from "events"; | ||
import StrictEventEmitter from "strict-event-emitter-types"; | ||
import Peer from "./peer"; | ||
import { IPeerRequest, IPeerResponse } from "./utils"; | ||
export default class PeerList extends EventEmitter { | ||
import { IPeerRequest, IPeerResponse, ISignalerEvents } from "./utils"; | ||
declare const PeerList_base: new () => StrictEventEmitter<EventEmitter, ISignalerEvents, ISignalerEvents, "addEventListener" | "removeEventListener", "removeListener" | "on" | "addListener" | "once" | "emit">; | ||
export default class PeerList extends PeerList_base { | ||
private _peers; | ||
@@ -20,1 +22,2 @@ private _nextPeerId; | ||
} | ||
export {}; |
@@ -5,3 +5,2 @@ "use strict"; | ||
const peer_1 = require("./peer"); | ||
const utils_1 = require("./utils"); | ||
class PeerList extends events_1.EventEmitter { | ||
@@ -14,19 +13,19 @@ constructor() { | ||
addPeer(name, res, req) { | ||
this.emit(utils_1.SignalEvent.PrePeerAdd, name); | ||
this.emit("addPeer:pre", name); | ||
const peer = new peer_1.default(name, this._nextPeerId); | ||
peer.res = res; | ||
peer.ip = req.realIp || req.ip; | ||
this.emit(utils_1.SignalEvent.PeerAdd, peer); | ||
this.emit("addPeer", peer); | ||
this._peers[peer.id] = peer; | ||
this._nextPeerId += 1; | ||
this.emit(utils_1.SignalEvent.PostPeerAdd, peer); | ||
this.emit("addPeer:post", peer); | ||
return peer.id; | ||
} | ||
removePeer(id) { | ||
this.emit(utils_1.SignalEvent.PrePeerRemove, id); | ||
this.emit("removePeer:pre", id); | ||
if (this._peers[id]) { | ||
const cpy = this._peers[id]; | ||
this.emit(utils_1.SignalEvent.PeerRemove, cpy); | ||
this.emit("removePeer", cpy); | ||
delete this._peers[id]; | ||
this.emit(utils_1.SignalEvent.PostPeerRemove, cpy); | ||
this.emit("removePeer:post", cpy); | ||
} | ||
@@ -33,0 +32,0 @@ } |
import { Request, Response, Router } from "express"; | ||
import Peer from "./peer"; | ||
import PeerList from "./peer-list"; | ||
export declare enum SignalEvent { | ||
PrePeerAdd = "addPeer:pre", | ||
PeerAdd = "addPeer", | ||
PostPeerAdd = "addPeer:post", | ||
PrePeerRemove = "RemovePeer:pre", | ||
PeerRemove = "RemovePeer", | ||
PostPeerRemove = "RemovePeer:post" | ||
} | ||
export interface IRouter extends Router { | ||
@@ -32,2 +25,10 @@ peerList: PeerList; | ||
} | ||
export interface ISignalerEvents { | ||
"addPeer:pre": string; | ||
"addPeer": Peer; | ||
"addPeer:post": Peer; | ||
"removePeer:pre": number; | ||
"removePeer": Peer; | ||
"removePeer:post": Peer; | ||
} | ||
export declare function optIsFalsey(opt: string | boolean): boolean; |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
var SignalEvent; | ||
(function (SignalEvent) { | ||
SignalEvent["PrePeerAdd"] = "addPeer:pre"; | ||
SignalEvent["PeerAdd"] = "addPeer"; | ||
SignalEvent["PostPeerAdd"] = "addPeer:post"; | ||
SignalEvent["PrePeerRemove"] = "RemovePeer:pre"; | ||
SignalEvent["PeerRemove"] = "RemovePeer"; | ||
SignalEvent["PostPeerRemove"] = "RemovePeer:post"; | ||
})(SignalEvent = exports.SignalEvent || (exports.SignalEvent = {})); | ||
function optIsFalsey(opt) { | ||
@@ -13,0 +4,0 @@ return !opt || |
{ | ||
"name": "webrtc-signal-http", | ||
"version": "2.0.0", | ||
"version": "2.0.1", | ||
"description": "opinionated webrtc signal provider using http as a protocol", | ||
@@ -34,3 +34,4 @@ "main": "dist/lib/index.js", | ||
"express": "^4.16.2", | ||
"express-bunyan-logger": "^1.3.2" | ||
"express-bunyan-logger": "^1.3.2", | ||
"strict-event-emitter-types": "^2.0.0" | ||
}, | ||
@@ -37,0 +38,0 @@ "devDependencies": { |
@@ -24,4 +24,4 @@ # webrtc-signal-http | ||
``` | ||
const express = require('express') | ||
const signalRouterCreator = require('webrtc-signal-http') | ||
import * as express from "express"; | ||
import { signalRouterCreator } from "webrtc-signal-http"; | ||
@@ -28,0 +28,0 @@ const app = express() |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
0
30667
5
323
+ Addedstrict-event-emitter-types@2.0.0(transitive)