logos-messaging/examples.waku.org
1
0
Fork 0
mirror of https://github.com/logos-messaging/examples.waku.org.git synced 2026-01-08 15:53:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

reimplement webrtc logic, add sending of ice candidate to a peer

Browse Source
This commit is contained in:
weboko 2023-01-19 00:12:52 +01:00
parent 085c7cb3c8
commit 02f66cc2b9
No known key found for this signature in database
1 changed files with 76 additions and 104 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

180
examples/noise-rtc/index.js
View File

@ -85,25 +85,70 @@ async function main() {
*/ */
ui.message.display(); ui.message.display();
let peerConnection; const configuration = {
let sendDataChannel; iceServers: [{ urls: "stun:stun.l.google.com:19302" }],
let receiveDataChannel; };
let peerConnection = new RTCPeerConnection(configuration);
let sendDataChannel = peerConnection.createDataChannel("chat");
let receiveChannel;
sendDataChannel.onopen = (event) => {
console.log("onopen", event);
};
sendDataChannel.onclose = (event) => {
console.log("onclose", event);
};
peerConnection.ondatachannel = (event) => {
receiveChannel = event.channel;
window.receiveChannel = receiveChannel;
receiveChannel.onmessage = (event) => {
console.log("onmessage", event);
};
receiveChannel.onopen = (event) => {
console.log("onopen receive", event);
};
receiveChannel.onclose = (event) => {
console.log("onclose receive", event);
};
};
peerConnection.onicecandidate = async (event) => {
console.log("onicecandidate event", event);
if (event.candidate) {
// try {
// await peerConnection.addIceCandidate(new RTCIceCandidate(event.candidate));
// } catch(error) {
// console.log("onicecandidate error", error);
// }
let message = ProtoChatMessage.create({
text: utils.utf8ToBytes(
JSON.stringify({
type: "candidate",
candidate: event.candidate,
})
),
});
message = ProtoChatMessage.encode(message).finish();
await node.lightPush.push(encoder, { payload: message });
}
};
peerConnection.oniceconnectionstatechange = console.log;
window.sendOffer = sendOffer; window.sendOffer = sendOffer;
window.sendDataChannel = sendDataChannel;
async function sendOffer() { async function sendOffer() {
peerConnection = createPeerConnectionWebRTC("sendOffer"); const offer = await peerConnection.createOffer();
sendDataChannel = createSendDataChannel("toSend", peerConnection); await peerConnection.setLocalDescription(offer);
window.sendDataChannel = sendDataChannel;
const offerWebRTC = await createOffer(peerConnection);
let offerMessage = ProtoChatMessage.create({ let offerMessage = ProtoChatMessage.create({
text: utils.utf8ToBytes( text: utils.utf8ToBytes(
JSON.stringify({ JSON.stringify({
type: "offer", type: "offer",
offer: offerWebRTC, offer,
}) })
), ),
}); });
@ -113,32 +158,7 @@ async function main() {
} }
async function sendAnswer(data) { async function sendAnswer(data) {
// confirm prompt ? await peerConnection.setRemoteDescription(
peerConnection = createPeerConnectionWebRTC("sendAnswer");
sendDataChannel = createSendDataChannel("toReceive", peerConnection);
window.sendDataChannel = sendDataChannel;
peerConnection.ondatachannel = (...args) => {
console.log(`sendAnswer ondatachannel`, args);
receiveDataChannel = args[0].channel;
window.receiveDataChannel = receiveDataChannel;
receiveDataChannel.onopen = (...args) => {
console.log(`sendAnswer receiveChannel onopen`, args);
};
receiveDataChannel.onmessage = (...args) => {
console.log(`sendAnswer receiveChannel onmessage`, args);
};
receiveDataChannel.onerror = (...args) => {
console.log(`sendAnswer receiveChannel onerror`, args);
};
receiveDataChannel.onclose = (...args) => {
console.log(`sendAnswer receiveChannel onclose`, args);
};
};
peerConnection.setRemoteDescription(
new RTCSessionDescription(data.offer) new RTCSessionDescription(data.offer)
); );
@ -160,7 +180,7 @@ async function main() {
async function handleAnswer(data) { async function handleAnswer(data) {
if (peerConnection) { if (peerConnection) {
peerConnection.setRemoteDescription( await peerConnection.setRemoteDescription(
new RTCSessionDescription(data.answer) new RTCSessionDescription(data.answer)
); );
@ -178,95 +198,47 @@ async function main() {
} }
} }
async function handleCandidate(data) {
if (data.candidate) {
try {
console.log("handleCandidate", data.candidate);
await peerConnection.addIceCandidate(
new RTCIceCandidate(data.candidate)
);
} catch (error) {
console.error("handleCandidate", error);
}
}
}
async function handleReceive({ payload }) { async function handleReceive({ payload }) {
const { text } = ProtoChatMessage.decode(payload); const { text } = ProtoChatMessage.decode(payload);
const data = JSON.parse(utils.bytesToUtf8(text)); const data = JSON.parse(utils.bytesToUtf8(text));
if (data.type === "offer") { if (data.type === "offer") {
sendAnswer(data); await sendAnswer(data);
} }
if (data.type === "answer") { if (data.type === "answer") {
handleAnswer(data); await handleAnswer(data);
} }
if (data.type === "ready") { if (data.type === "ready") {
console.log("partner is ready", data); console.log("partner is ready", data);
} }
if (data.type === "candidate") {
await handleCandidate(data);
}
} }
await node.filter.subscribe([decoder], handleReceive); await node.filter.subscribe([decoder], handleReceive);
// ui.message.onSend(async (text, nick) => {
// const timestamp = Math.floor(Date.now() / 1000);
// const message = ProtoChatMessage.create({
// nick,
// timestamp,
// text: utils.utf8ToBytes(text),
// });
// const payload = ProtoChatMessage.encode(message).finish();
// await node.lightPush.push(encoder, { payload, timestamp });
// });
} catch (err) { } catch (err) {
ui.waku.error(err.message); ui.waku.error(err.message);
ui.hide(); ui.hide();
} }
} }
function createPeerConnectionWebRTC(context) {
const configuration = {
iceServers: [{ urls: "stun:stun.l.google.com:19302" }],
};
const peerConnection = new RTCPeerConnection(configuration);
console.log("PeerConnection", peerConnection);
peerConnection.onicecandidate = (...args) => {
console.log(`${context} onicecandidate`, args);
};
peerConnection.onconnectionstatechange = (...args) => {
console.log(`${context} onconnectionstatechange`, args);
};
peerConnection.onnegotiationneeded = (...args) => {
console.log(`${context} onnegotiationneeded`, args);
};
return peerConnection;
}
function createSendDataChannel(name, peerConnection) {
const options = {
ordered: false,
maxPacketLifTime: 3000,
};
const dataChannel = peerConnection.createDataChannel(name, options);
console.log("Data channel", dataChannel);
dataChannel.onerror = (...args) => {
console.log("dataChannel.onerror", args);
};
dataChannel.onmessage = (...args) => {
console.log("dataChannel.onmessage", args);
};
dataChannel.onopen = (...args) => {
console.log("dataChannel.onopen", args);
};
dataChannel.onclose = (...args) => {
console.log("dataChannel.onclose", args);
};
return dataChannel;
}
async function createOffer(peerConnection) {
const offer = await peerConnection.createOffer({ iceRestart: true });
await peerConnection.setLocalDescription(offer);
console.log("offer", offer);
return offer;
}
function buildPairingURLFromObj(pairingObj) { function buildPairingURLFromObj(pairingObj) {
const pInfo = pairingObj.getPairingInfo(); const pInfo = pairingObj.getPairingInfo();