@@ -220,7 +220,6 @@ class Signaling {
220
220
break ;
221
221
case 'bye' :
222
222
{
223
- var from = data['from' ];
224
223
var to = data['to' ];
225
224
var sessionId = data['session_id' ];
226
225
print ('bye: ' + sessionId);
@@ -259,7 +258,7 @@ class Signaling {
259
258
}
260
259
261
260
void connect () async {
262
- var url = 'wss://$_host :$_port ' ;
261
+ var url = 'wss://$_host :$_port /ws ' ;
263
262
_socket = SimpleWebSocket (url);
264
263
265
264
print ('connect to $url ' );
@@ -321,6 +320,7 @@ class Signaling {
321
320
pc.onIceCandidate = (candidate) {
322
321
_send ('candidate' , {
323
322
'to' : id,
323
+ 'from' : _selfId,
324
324
'candidate' : {
325
325
'sdpMLineIndex' : candidate.sdpMlineIndex,
326
326
'sdpMid' : candidate.sdpMid,
@@ -375,6 +375,7 @@ class Signaling {
375
375
pc.setLocalDescription (s);
376
376
_send ('offer' , {
377
377
'to' : id,
378
+ 'from' : _selfId,
378
379
'description' : {'sdp' : s.sdp, 'type' : s.type},
379
380
'session_id' : this ._sessionId,
380
381
'media' : media,
@@ -391,6 +392,7 @@ class Signaling {
391
392
pc.setLocalDescription (s);
392
393
_send ('answer' , {
393
394
'to' : id,
395
+ 'from' : _selfId,
394
396
'description' : {'sdp' : s.sdp, 'type' : s.type},
395
397
'session_id' : this ._sessionId,
396
398
});
@@ -400,8 +402,10 @@ class Signaling {
400
402
}
401
403
402
404
_send (event, data) {
403
- data['type' ] = event;
405
+ var request = new Map ();
406
+ request["type" ] = event;
407
+ request["data" ] = data;
404
408
JsonEncoder encoder = new JsonEncoder ();
405
- _socket.send (encoder.convert (data ));
409
+ _socket.send (encoder.convert (request ));
406
410
}
407
411
}
0 commit comments