diff options
| author | Melonai <einebeere@gmail.com> | 2021-05-31 01:47:38 +0200 |
|---|---|---|
| committer | Melonai <einebeere@gmail.com> | 2021-05-31 01:47:38 +0200 |
| commit | 8f1f90c3e7d836a23f1cd09617c2a0fcfac3f3f4 (patch) | |
| tree | 7359e054d13a054a661c1584dae20d0698fc4c84 /assets/src/network/socket.ts | |
| parent | e0cabfea7c7b442acd3636e7495958b87e253176 (diff) | |
| download | rook-8f1f90c3e7d836a23f1cd09617c2a0fcfac3f3f4.tar.zst rook-8f1f90c3e7d836a23f1cd09617c2a0fcfac3f3f4.zip | |
Socket connection with managed state
Diffstat (limited to 'assets/src/network/socket.ts')
| -rw-r--r-- | assets/src/network/socket.ts | 44 |
1 files changed, 0 insertions, 44 deletions
diff --git a/assets/src/network/socket.ts b/assets/src/network/socket.ts deleted file mode 100644 index 87f5b7c..0000000 --- a/assets/src/network/socket.ts +++ /dev/null @@ -1,44 +0,0 @@ -import { Socket } from "phoenix"; -import requests from "../stores/requests"; - -let socket = new Socket("/socket", {}); -socket.connect(); - -export const getToken: () => Promise<string> = () => { - let tokenChannel = socket.channel("token", {}); - return new Promise((resolve, reject) => { - tokenChannel - .join() - .receive("ok", () => { - tokenChannel - .push("get_token", {}, 5000) - .receive("ok", ({ token }) => resolve(token)) - .receive("error", err => reject(err)) - .receive("timeout", err => reject(err)); - }) - .receive("error", err => reject(err)); - }); -}; - -export const joinShareChannel = token => { - let shareChannel = socket.channel(`share:${token}`); - - shareChannel.on("new_request", requests.addRequest); - - shareChannel - .join() - .receive("error", err => - console.log("Failed joining share channel: " + JSON.stringify(err)) - ); -}; - -export const joinRequestChannel = (token, share) => { - let requestChannel = socket.channel(`request:${token}`, { share }); - - requestChannel - .join() - .receive("ok", () => console.log("Connected to request!")) - .receive("error", err => - console.log("Failed joining request channel:" + JSON.stringify(err)) - ); -}; |
