]> git.r.bdr.sh - rbdr/junction/blame_incremental - server/events.js
Format and update docs
[rbdr/junction] / server / events.js
... / ...
CommitLineData
1const internals = {
2 emitter(name, data, socket) {
3 socket.emit(name, data);
4 console.debug(`[${name}] ${JSON.stringify(data)}`);
5 },
6};
7
8export 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
25export function addPeer(peerId, shouldCreateOffer) {
26 return internals.emitter.bind(null, types.ADD_PEER, {
27 peerId,
28 shouldCreateOffer,
29 });
30}
31
32export function removePeer(peerId) {
33 return internals.emitter.bind(null, types.REMOVE_PEER, {
34 peerId,
35 });
36}
37
38export function ICECandidateReceived(peerId, candidate) {
39 return internals.emitter.bind(null, types.ICE_CANDIDATE_RECEIVED, {
40 peerId,
41 candidate,
42 });
43}
44
45export function offerReceived(peerId, offer) {
46 return internals.emitter.bind(null, types.OFFER_RECEIVED, {
47 peerId,
48 offer,
49 });
50}
51
52export function answerReceived(peerId, answer) {
53 return internals.emitter.bind(null, types.ANSWER_RECEIVED, {
54 peerId,
55 answer,
56 });
57}