diff options
| author | Mel <einebeere@gmail.com> | 2022-02-19 19:46:36 +0100 |
|---|---|---|
| committer | Mel <einebeere@gmail.com> | 2022-02-19 19:58:30 +0100 |
| commit | d5f7201eb7b10826e77eccb33f9cca784261091f (patch) | |
| tree | 9b9bdfff59678d20bf57c2c6a873809df1a77284 /assets/src/network/channel/request_connection.ts | |
| parent | f7b9594045cc8a77b622e4ddfadc5c2ccba85765 (diff) | |
| download | rook-d5f7201eb7b10826e77eccb33f9cca784261091f.tar.zst rook-d5f7201eb7b10826e77eccb33f9cca784261091f.zip | |
Make connection an object and merge starts
Diffstat (limited to 'assets/src/network/channel/request_connection.ts')
| -rw-r--r-- | assets/src/network/channel/request_connection.ts | 52 |
1 files changed, 0 insertions, 52 deletions
diff --git a/assets/src/network/channel/request_connection.ts b/assets/src/network/channel/request_connection.ts deleted file mode 100644 index aef5300..0000000 --- a/assets/src/network/channel/request_connection.ts +++ /dev/null @@ -1,52 +0,0 @@ -import { - requestAccepted, - OwnRequest, - OwnRequestState, -} from "../../models/own_request"; -import getShareToken from "../../utils/getShareToken"; -import { ConnectionState, on, start, updateState } from "./connection"; -import type { - RequestAcceptedMessage, - ShareCancelledMessage, -} from "./messages/messages"; -import { joinRequestChannel } from "./socket"; - -export async function startRequestConnection(ownRequest: OwnRequest) { - const connection = await start(); - - updateState(ConnectionState.CONNECTING_CHANNEL); - - const requestChannel = await joinRequestChannel( - connection.socket, - connection.token, - getShareToken() - ); - connection.channel = requestChannel; - - on("request_accepted", (message: RequestAcceptedMessage) => - onRequestAccepted(message, ownRequest) - ); - - on("new_request", (message) => { - message.event_name - }); - - on("share_cancelled", (message: ShareCancelledMessage) => - onShareCancelled(message, ownRequest) - ); - - updateState(ConnectionState.CONNECTED); -} - -// Events which can happen without prior triggers during a request's lifetime - -function onRequestAccepted( - message: RequestAcceptedMessage, - request: OwnRequest -) { - requestAccepted(request, message); -} - -function onShareCancelled(message: ShareCancelledMessage, request: OwnRequest) { - request.state.set(OwnRequestState.SHARE_CANCELLED); -} \ No newline at end of file |
