diff options
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)) - ); -}; |
