1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
|
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);
}
|
