Merge branch 'main' of https://github.com/pinax-network/substreams-si…

…nk-websockets

README.md

@@ -23,6 +23,13 @@ Send Text Message with the following JSON payloads
     }
 }
 ```
+### `ping` Request
+
+```json
+{
+    "method": "ping"
+}
+```
 
 ## REST API
 
@@ -116,4 +123,10 @@ docker run -it --rm --env-file .env ghcr.io/pinax-network/substreams-sink-websoc
 ## 📖 References
 
 - [**Substreams** documentation](https://substreams.streamingfast.io/)
-- [Bun WebSockets](https://bun.sh/docs/api/websockets)
+- [Bun WebSockets](https://bun.sh/docs/api/websockets)
+
+  Bun's latest v1.0 release includes WebSocket support (written in Zig)
+  https://bun.sh/docs/api/websockets
+
+  Under the hood, it uses uWebSockets
+  https://github.com/uNetworking/uWebSockets

examples/bun/ping.ts

@@ -1,13 +1,8 @@
-import { randomUUID } from "crypto";
-
 const ws = new WebSocket("ws://localhost:3000");
 
 ws.onopen = () => {
     console.log("connected");
-    ws.send(JSON.stringify({
-        id: randomUUID(),
-        method: "ping"
-    }));
+    ws.send(JSON.stringify({ method: "ping" }));
 };
 
 ws.onmessage = (event) => {

examples/bun/subscribe.ts

@@ -1,11 +1,8 @@
-import { randomUUID } from "crypto";
-
 const ws = new WebSocket("ws://localhost:3000");
 
 ws.onopen = () => {
     console.log("connected");
     ws.send(JSON.stringify({
-        id: randomUUID(),
         method: "subscribe",
         params: {
             moduleHash: "0a363b2a63aadb76a525208f1973531d3616fbae"

examples/bun/time.ts

@@ -1,13 +1,8 @@
-import { randomUUID } from "crypto";
-
 const ws = new WebSocket("ws://localhost:3000");
 
 ws.onopen = () => {
     console.log("connected");
-    ws.send(JSON.stringify({
-        id: randomUUID(),
-        method: "time"
-    }));
+    ws.send(JSON.stringify({method: "time" }));
 };
 
 ws.onmessage = (event) => {

src/config.ts

@@ -2,7 +2,6 @@ import "dotenv/config";
 
 import pkg from "../package.json" assert { type: "json" };
 import { Command, Option } from "commander";
-import { logger } from "./logger.js";
 
 // default values
 export const DEFAULT_PORT = 3000