Skip to content

Commit dc0a37b

Browse files
Minor fix
1 parent 46e1ca2 commit dc0a37b

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

lib/jsflow-tracker.js

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -101,17 +101,17 @@ jsFlowTracker.prototype._onData = function (payload, from) {
101101

102102
// Handle received peers
103103
if (Array.isArray(payload.peers)) {
104-
payload.peers.forEach(function (peerId) { //For all peers we receive - Open a WebRTC peer connection
104+
payload.peers.forEach(function (peerInfo) { //For all peers we receive - Open a WebRTC peer connection
105105

106-
console.log('Will handle connection for peer: ', peer);
106+
console.log('Will handle connection for peer: ', peerInfo.peerId);
107107

108108
var peer = self._peers[peerId] = new Peer({
109109
initiator: true,
110110
trickle: true,
111111
config: self.client._rtcConfig,
112112
wrtc: self.client._wrtc
113113
})
114-
peer.id = peerId
114+
peer.id = peerInfo.peerId
115115

116116
peer.on('signal', function (signalObject) {
117117
if(signalObject.candidate) { // The signalling is for ICE
@@ -155,7 +155,7 @@ jsFlowTracker.prototype._onWebRtcOffer = function (payload, from) {
155155
candidate: candidate
156156
}
157157

158-
jsFlow.messageUser(peerId, params, 'webrtc_ice');
158+
jsFlow.messageUser(from, params, 'webrtc_ice');
159159
}
160160
else { // The signalling is for an ANSWER
161161
answer = signalObject;

0 commit comments

Comments
 (0)