about summary refs log tree commit diff
path: root/assets/src/network/channel/share_connection.ts
diff options
context:
space:
mode:
authorMel <einebeere@gmail.com>2022-02-19 19:46:36 +0100
committerMel <einebeere@gmail.com>2022-02-19 19:58:30 +0100
commitd5f7201eb7b10826e77eccb33f9cca784261091f (patch)
tree9b9bdfff59678d20bf57c2c6a873809df1a77284 /assets/src/network/channel/share_connection.ts
parentf7b9594045cc8a77b622e4ddfadc5c2ccba85765 (diff)
downloadrook-d5f7201eb7b10826e77eccb33f9cca784261091f.tar.zst
rook-d5f7201eb7b10826e77eccb33f9cca784261091f.zip
Make connection an object and merge starts
Diffstat (limited to 'assets/src/network/channel/share_connection.ts')
-rw-r--r--assets/src/network/channel/share_connection.ts62
1 files changed, 0 insertions, 62 deletions
diff --git a/assets/src/network/channel/share_connection.ts b/assets/src/network/channel/share_connection.ts
deleted file mode 100644
index ac6dfbf..0000000
--- a/assets/src/network/channel/share_connection.ts
+++ /dev/null
@@ -1,62 +0,0 @@
-import { newIncomingRequest } from "../../models/incoming_request";
-import requests from "../../stores/received_requests";
-import {
-    ConnectionState,
-    on,
-    onWithToken,
-    start,
-    updateState,
-} from "./connection";
-import type { UnregisterFn } from "./messages/event_handler";
-import type {
-    NewRequestMessage,
-    RequestCancelledMessage,
-} from "./messages/messages";
-import { joinShareChannel } from "./socket";
-
-export async function startShareConnection() {
-    const connection = await start();
-
-    updateState(ConnectionState.CONNECTING_CHANNEL);
-
-    const shareChannel = await joinShareChannel(
-        connection.socket,
-        connection.token
-    );
-    connection.channel = shareChannel;
-
-    on("new_request", onNewRequest);
-
-    updateState(ConnectionState.CONNECTED);
-}
-
-// Events which can happen without prior triggers during a share's lifetime
-
-function onNewRequest(message: NewRequestMessage) {
-    const token = message.token;
-
-    const request = newIncomingRequest(
-        token,
-        message.ip,
-        message.location,
-        message.client
-    );
-    requests.addRequest(request);
-
-    const unregister = onWithToken(
-        "request_cancelled",
-        token,
-        (message: RequestCancelledMessage) => {
-            onRequestCancelled(message, unregister);
-        }
-    );
-}
-
-function onRequestCancelled(
-    message: RequestCancelledMessage,
-    unregister: UnregisterFn
-) {
-    const token = message.token;
-    requests.removeRequest(token);
-    unregister();
-}