yumoqing/bricks
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2024-10-11 13:58:19 +08:00
parent 9e611ee75e
commit ae79a891d7
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
bricks/rtc.js
View File

@ -182,6 +182,7 @@ bricks.RTCP2PConnect = class {
*/ */
constructor(signaling, session, opts){ constructor(signaling, session, opts){
this.id = bricks.uuid();
this.signaling = signaling; this.signaling = signaling;
this.session = session; this.session = session;
this.requester = false; this.requester = false;
@ -208,8 +209,13 @@ bricks.RTCP2PConnect = class {
async p2pconnect(peer){ async p2pconnect(peer){
await this.getLocalStream(); await this.getLocalStream();
await this.createPeerConnection(peer); var p = this.peers[peer.id];
console.log('p2pconnect() called, this=', this); if (!p){
await this.createPeerConnection(peer);
} else {
aconsole.log(peer, 'connect exists', this);
}
console.log('p2pconnect() called, this=', this, 'peer=', peer);
} }
async h_sessioncreated(data){ async h_sessioncreated(data){
if (this.opts.peer_info){ if (this.opts.peer_info){
@ -238,7 +244,7 @@ bricks.RTCP2PConnect = class {
await this.send_offer(data.msgfrom); await this.send_offer(data.msgfrom);
} }
async h_offer(data){ async h_offer(data){
console.log('send_offer(), peers=', this.peers, 'peer=', data.msgfrom); console.log('h_offer(), this=', this 'peer=', data.msgfrom);
var pc = this.peers[data.msgfrom.id].pc; var pc = this.peers[data.msgfrom.id].pc;
var offer = new RTCSessionDescription(data.offer); var offer = new RTCSessionDescription(data.offer);
await pc.setRemoteDescription(offer); await pc.setRemoteDescription(offer);