diff options
Diffstat (limited to 'assets/src/network/channel/share_connection.ts')
| -rw-r--r-- | assets/src/network/channel/share_connection.ts | 62 |
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(); -} |
