]> git.r.bdr.sh - rbdr/junction/blame - server/events.js
Refactor content script
[rbdr/junction] / server / events.js
CommitLineData
6a3568bc
RBR
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) {
26 return internals.emitter.bind(null, types.ADD_PEER, {
284fc661 27 peerId,
6a3568bc 28 });
ed9f8fd5 29}
30
80172072 31export function removePeer(peerId) {
6a3568bc
RBR
32 return internals.emitter.bind(null, types.REMOVE_PEER, {
33 peerId,
34 });
284fc661
RBR
35}
36
37export function ICECandidateReceived(peerId, candidate) {
6a3568bc
RBR
38 return internals.emitter.bind(null, types.ICE_CANDIDATE_RECEIVED, {
39 peerId,
40 candidate,
41 });
284fc661
RBR
42}
43
44export function offerReceived(peerId, offer) {
6a3568bc
RBR
45 return internals.emitter.bind(null, types.OFFER_RECEIVED, {
46 peerId,
47 offer,
48 });
ed9f8fd5 49}
50
284fc661 51export function answerReceived(peerId, answer) {
6a3568bc
RBR
52 return internals.emitter.bind(null, types.ANSWER_RECEIVED, {
53 peerId,
54 answer,
55 });
ed9f8fd5 56}