summaryrefslogtreecommitdiff
path: root/std/ws/example_client.ts
diff options
context:
space:
mode:
authorLuca Casonato <lucacasonato@yahoo.com>2020-09-09 21:33:38 +0200
committerGitHub <noreply@github.com>2020-09-09 21:33:38 +0200
commita3bcdb2b69bdaa9b616df6db07f1c88c8b578fb2 (patch)
tree6a7732bdcf683e25dc4b4af4946ff4f58b432e3b /std/ws/example_client.ts
parent0d126930cab8167f42ad8607faa202b30b42c680 (diff)
chore(std): remove std/ws connect method (#7403)
Diffstat (limited to 'std/ws/example_client.ts')
-rw-r--r--std/ws/example_client.ts61
1 files changed, 0 insertions, 61 deletions
diff --git a/std/ws/example_client.ts b/std/ws/example_client.ts
deleted file mode 100644
index 93f2f5c7b..000000000
--- a/std/ws/example_client.ts
+++ /dev/null
@@ -1,61 +0,0 @@
-import {
- connectWebSocket,
- isWebSocketCloseEvent,
- isWebSocketPingEvent,
- isWebSocketPongEvent,
-} from "./mod.ts";
-import { encode } from "../encoding/utf8.ts";
-import { BufReader } from "../io/bufio.ts";
-import { TextProtoReader } from "../textproto/mod.ts";
-import { blue, green, red, yellow } from "../fmt/colors.ts";
-
-if (import.meta.main) {
- const endpoint = Deno.args[0] || "ws://127.0.0.1:8080";
- /** simple websocket cli */
- try {
- const sock = await connectWebSocket(endpoint);
- console.log(green("ws connected! (type 'close' to quit)"));
-
- const messages = async (): Promise<void> => {
- for await (const msg of sock) {
- if (typeof msg === "string") {
- console.log(yellow(`< ${msg}`));
- } else if (isWebSocketPingEvent(msg)) {
- console.log(blue("< ping"));
- } else if (isWebSocketPongEvent(msg)) {
- console.log(blue("< pong"));
- } else if (isWebSocketCloseEvent(msg)) {
- console.log(red(`closed: code=${msg.code}, reason=${msg.reason}`));
- }
- }
- };
-
- const cli = async (): Promise<void> => {
- const tpr = new TextProtoReader(new BufReader(Deno.stdin));
- while (true) {
- await Deno.stdout.write(encode("> "));
- const line = await tpr.readLine();
- if (line === null) {
- break;
- }
- if (line === "close") {
- break;
- } else if (line === "ping") {
- await sock.ping();
- } else {
- await sock.send(line);
- }
- }
- };
-
- await Promise.race([messages(), cli()]).catch(console.error);
-
- if (!sock.isClosed) {
- await sock.close(1000).catch(console.error);
- }
- } catch (err) {
- console.error(red(`Could not connect to WebSocket: '${err}'`));
- }
-
- Deno.exit(0);
-}