]>
Commit | Line | Data |
---|---|---|
344f7c13 | 1 | const io = require('socket.io-client'); |
2 | ||
1ed219c8 RBR |
3 | const internals = { |
4 | ||
a94a5407 | 5 | promisesSupported: !!(window.browser), |
1ed219c8 RBR |
6 | isInCallState: false, |
7 | ||
8 | icons: { | |
9 | call: { | |
10 | 16: 'icons/action-16.png', | |
11 | 32: 'icons/action-32.png' | |
12 | }, | |
13 | ||
14 | hangUp: { | |
15 | 16: 'icons/hang_up-16.png', | |
16 | 32: 'icons/hang_up-32.png' | |
17 | } | |
18 | }, | |
19 | ||
344f7c13 | 20 | socket: null, |
21 | ||
22 | peers: 0, | |
23 | ||
1ed219c8 RBR |
24 | onClick() { |
25 | if (internals.isInCall()) { | |
26 | return internals.hangUp(); | |
27 | } | |
28 | ||
29 | return internals.joinAudioCall(); | |
30 | }, | |
31 | ||
32 | async joinAudioCall() { | |
33 | ||
34 | internals.isInCallState = true; | |
35 | internals.setIcon('hangUp'); | |
a94a5407 | 36 | const activeTabs = await internals.getActiveTabs(); |
1ed219c8 | 37 | |
c3fafc92 | 38 | const socketUrl = 'http://localhost:8000/'; |
344f7c13 | 39 | const currentUrl = activeTabs[0].url; |
40 | ||
41 | this.socket = io(socketUrl); | |
42 | ||
c3fafc92 | 43 | var that = this; |
44 | ||
344f7c13 | 45 | this.socket.on('connect', function() { |
46 | console.log("Connected to signaling server"); | |
c3fafc92 | 47 | |
48 | that.socket.emit('join', { | |
49 | 'url': currentUrl, | |
50 | }); | |
344f7c13 | 51 | }); |
52 | ||
53 | this.socket.on('disconnect', function() { | |
54 | console.log("disconnected from signaling server"); | |
55 | }); | |
56 | ||
c3fafc92 | 57 | this.socket.on('addPeer', function(data) { |
58 | console.log(data); | |
59 | that.peers++; | |
60 | console.log(`There are now ${that.peers} participants`); | |
344f7c13 | 61 | }); |
62 | ||
63 | this.socket.on('removePeer', function() { | |
c3fafc92 | 64 | that.peers--; |
65 | console.log(`There are now ${that.peers} participants`); | |
344f7c13 | 66 | }); |
67 | ||
a94a5407 RBR |
68 | console.log(activeTabs[0].url); // placeholder while we connect backend. |
69 | internals.createAudioElement(internals.getRoot().runtime.getURL('sounds/tada.wav')); | |
1ed219c8 RBR |
70 | }, |
71 | ||
72 | hangUp() { | |
344f7c13 | 73 | this.socket.close(); |
74 | ||
75 | ||
1ed219c8 RBR |
76 | |
77 | document.querySelectorAll('audio').forEach((audioElement) => audioElement.remove()); | |
78 | internals.setIcon('call'); | |
79 | internals.isInCallState = false; | |
80 | }, | |
81 | ||
a94a5407 | 82 | createAudioElement(source, type = 'audio/wav') { |
1ed219c8 RBR |
83 | |
84 | const audioElement = document.createElement('audio'); | |
85 | audioElement.src = source; | |
86 | audioElement.autoplay = 'autoplay'; | |
a94a5407 | 87 | audioElement.type = type; |
1ed219c8 RBR |
88 | document.querySelector('body').appendChild(audioElement); |
89 | }, | |
90 | ||
91 | isInCall() { | |
92 | return internals.isInCallState; // this should be replaced with actually checking the built stuff | |
93 | }, | |
94 | ||
95 | setIcon(iconSet) { | |
96 | ||
a94a5407 | 97 | internals.getRoot().browserAction.setIcon({ |
1ed219c8 RBR |
98 | path: internals.icons[iconSet] |
99 | }); | |
a94a5407 RBR |
100 | }, |
101 | ||
102 | getRoot() { | |
103 | ||
104 | return window.browser || window.chrome; | |
105 | }, | |
106 | ||
107 | // Chrome doesn't yet implement the promise based tabs.query :'( | |
108 | ||
109 | getActiveTabs() { | |
110 | ||
111 | const query = { | |
112 | currentWindow: true, | |
113 | active: true | |
114 | }; | |
115 | ||
116 | if (internals.promisesSupported) { | |
117 | return internals.getRoot().tabs.query(query); | |
118 | } | |
119 | ||
120 | return new Promise((resolve, reject) => { | |
121 | ||
122 | internals.getRoot().tabs.query(query, (tabs) => { | |
123 | ||
124 | return resolve(tabs); | |
125 | }); | |
126 | }); | |
127 | }, | |
1ed219c8 RBR |
128 | }; |
129 | ||
a94a5407 | 130 | internals.getRoot().browserAction.onClicked.addListener(internals.onClick); |