From 29573488ada5c5b1f291f7b50dc5a7a7cf76fd29 Mon Sep 17 00:00:00 2001
From: Melonai <einebeere@gmail.com>
Date: Sun, 13 Jun 2021 23:38:21 +0200
Subject: Send over data through channel

---
 assets/src/network/transfer/request.ts | 49 ++++++++++++++++++++++++++++++++++
 1 file changed, 49 insertions(+)
 create mode 100644 assets/src/network/transfer/request.ts

(limited to 'assets/src/network/transfer/request.ts')

diff --git a/assets/src/network/transfer/request.ts b/assets/src/network/transfer/request.ts
new file mode 100644
index 0000000..920cd9a
--- /dev/null
+++ b/assets/src/network/transfer/request.ts
@@ -0,0 +1,49 @@
+import { on, send } from "../channel/connection";
+import type { RequestIceCandidateMessage } from "../channel/messages/messages";
+import {
+    createTransfer,
+    onIncomingIceCandidate,
+    Transfer,
+    TransferType,
+    unregisterIceOnComplete,
+} from "./transfer";
+
+export async function answer(
+    offer: RTCSessionDescriptionInit
+): Promise<Transfer> {
+    const transfer = createTransfer(TransferType.ANSWER, onChannel);
+
+    const offerDescription = new RTCSessionDescription(offer);
+    transfer.pc.setRemoteDescription(offerDescription);
+
+    const answer = await transfer.pc.createAnswer();
+    transfer.pc.setLocalDescription(answer);
+
+    transfer.pc.onicecandidate = event => {
+        const candidate = event.candidate;
+        if (event.candidate !== null) {
+            send("ice_candidate", { candidate });
+        }
+    };
+
+    const unregisterIce = on(
+        "ice_candidate",
+        (message: RequestIceCandidateMessage) =>
+            onIncomingIceCandidate(transfer, message)
+    );
+
+    unregisterIceOnComplete(transfer, unregisterIce);
+
+    send("accept_share", {
+        sdp: answer.sdp,
+        type: answer.type,
+    });
+
+    return transfer;
+}
+
+function onChannel(channel: RTCDataChannel) {
+    channel.onmessage = event => {
+        console.log(event.data)
+    }
+}
-- 
cgit 1.4.1