Skip to content

Commit

Permalink
Fix issue with ice handler not firing
Browse files Browse the repository at this point in the history
  • Loading branch information
gfodor committed Nov 2, 2022
1 parent 93b0d6e commit 4a4d771
Showing 1 changed file with 18 additions and 20 deletions.
38 changes: 18 additions & 20 deletions src/p2pcf.js
Original file line number Diff line number Diff line change
Expand Up @@ -1179,32 +1179,30 @@ export default class P2PCF extends EventEmitter {
})

// Once ICE completes, perform subsequent signalling via the datachannel
peer.once('_iceComplete', () => {
peer.on('signal', signalData => {
const payloadBytes = textToArr(
JSON.stringify(signalData)
)
peer.on('signal', signalData => {
const payloadBytes = textToArr(
JSON.stringify(signalData)
)

let len =
payloadBytes.byteLength + SIGNAL_MESSAGE_HEADER_WORDS.length * 2
let len =
payloadBytes.byteLength + SIGNAL_MESSAGE_HEADER_WORDS.length * 2

if (len % 2 !== 0) {
len++
}
if (len % 2 !== 0) {
len++
}

// Add signal header
const buf = new ArrayBuffer(len)
const u8 = new Uint8Array(buf)
const u16 = new Uint16Array(buf)
// Add signal header
const buf = new ArrayBuffer(len)
const u8 = new Uint8Array(buf)
const u16 = new Uint16Array(buf)

u8.set(payloadBytes, SIGNAL_MESSAGE_HEADER_WORDS.length * 2)
u8.set(payloadBytes, SIGNAL_MESSAGE_HEADER_WORDS.length * 2)

for (let i = 0; i < SIGNAL_MESSAGE_HEADER_WORDS.length; i++) {
u16[i] = SIGNAL_MESSAGE_HEADER_WORDS[i]
}
for (let i = 0; i < SIGNAL_MESSAGE_HEADER_WORDS.length; i++) {
u16[i] = SIGNAL_MESSAGE_HEADER_WORDS[i]
}

this.send(peer, buf)
})
this.send(peer, buf)
})
}
}

0 comments on commit 4a4d771

Please sign in to comment.