git.r.bdr.sh - rbdr/junction/blob - server/events.js

   1 const internals = {
   2   emitter(name, data, socket) {
   3     socket.emit(name, data);
   4     console.debug(`[${name}] ${JSON.stringify(data)}`);
   5   },
   6 };
   7
   8 export const types = {
   9   /* Listened */
  10   CONNECTION: "connection",
  11   JOIN: "join",
  12   DISCONNECTING: "disconnecting",
  13   RELAY_ICE_CANDIDATE: "relayICECandidate",
  14   RELAY_OFFER: "relayOffer",
  15   RELAY_ANSWER: "relayAnswer",
  16
  17   /* Emitted */
  18   ADD_PEER: "addPeer",
  19   REMOVE_PEER: "removePeer",
  20   OFFER_RECEIVED: "offerReceived",
  21   ANSWER_RECEIVED: "answerReceived",
  22   ICE_CANDIDATE_RECEIVED: "ICECandidateReceived",
  23 };
  24
  25 export function addPeer(peerId) {
  26   return internals.emitter.bind(null, types.ADD_PEER, {
  27     peerId,
  28   });
  29 }
  30
  31 export function removePeer(peerId) {
  32   return internals.emitter.bind(null, types.REMOVE_PEER, {
  33     peerId,
  34   });
  35 }
  36
  37 export function ICECandidateReceived(peerId, candidate) {
  38   return internals.emitter.bind(null, types.ICE_CANDIDATE_RECEIVED, {
  39     peerId,
  40     candidate,
  41   });
  42 }
  43
  44 export function offerReceived(peerId, offer) {
  45   return internals.emitter.bind(null, types.OFFER_RECEIVED, {
  46     peerId,
  47     offer,
  48   });
  49 }
  50
  51 export function answerReceived(peerId, answer) {
  52   return internals.emitter.bind(null, types.ANSWER_RECEIVED, {
  53     peerId,
  54     answer,
  55   });
  56 }