node: Add order websocket (#161)

* node: Add order websocket

* chore: version packages

packages/node/CHANGELOG.md

@@ -1,5 +1,11 @@
 # @renegade-fi/node
 
+## 0.5.1
+
+### Patch Changes
+
+- node: Add order websocket
+
 ## 0.5.0
 
 ### Minor Changes

packages/node/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@renegade-fi/node",
   "description": "Node.js library for Renegade",
-  "version": "0.5.0",
+  "version": "0.5.1",
   "repository": {
     "type": "git",
     "url": "https://github.com/renegade-fi/typescript-sdk.git",

packages/node/src/exports/index.ts

@@ -59,6 +59,8 @@ export {
   type GeneratedSecrets,
 } from '../actions/generateWalletSecrets.js'
 
+export { createOrderWebSocket } from '../services/orderWebSocket.js'
+
 ////////////////////////////////////////////////////////////////////////////////
 // @renegade-fi/core
 ////////////////////////////////////////////////////////////////////////////////

packages/node/src/services/orderWebSocket.ts

@@ -0,0 +1,81 @@
+import {
+  AuthType,
+  type OrderMetadata,
+  RelayerWebsocket,
+  type RenegadeConfig,
+  WS_WALLET_ORDERS_ROUTE,
+  getWalletId,
+} from '@renegade-fi/core'
+
+interface OrderWebSocketOptions {
+  config: RenegadeConfig
+  onUpdate: (order: OrderMetadata) => void
+}
+
+export function createOrderWebSocket(options: OrderWebSocketOptions) {
+  return new OrderWebSocketImpl(options)
+}
+
+class OrderWebSocketImpl {
+  private config: RenegadeConfig
+  private ws: RelayerWebsocket | null = null
+  private callback: (order: OrderMetadata) => void
+  private walletId: string
+
+  constructor(options: OrderWebSocketOptions) {
+    this.config = options.config
+    this.callback = options.onUpdate
+    this.walletId = getWalletId(this.config)
+  }
+
+  connect() {
+    if (this.ws) return
+
+    this.ws = new RelayerWebsocket({
+      config: this.config,
+      topic: WS_WALLET_ORDERS_ROUTE(this.walletId),
+      authType: AuthType.Wallet,
+      onmessage: (event) => this.handleMessage(event),
+      oncloseCallback: () => this.handleClose(),
+      onerrorCallback: () => this.handleError(),
+    })
+
+    this.ws.connect()
+  }
+
+  disconnect() {
+    this.ws?.close()
+    this.ws = null
+  }
+
+  private handleMessage(event: MessageEvent) {
+    try {
+      const message = JSON.parse(event.data, (key, value) => {
+        if (typeof value === 'number' && key !== 'price') {
+          return BigInt(value)
+        }
+        return value
+      })
+
+      if (
+        message.topic === WS_WALLET_ORDERS_ROUTE(this.walletId) &&
+        message.event?.type === 'OrderMetadataUpdated' &&
+        message.event?.order
+      ) {
+        this.callback(message.event.order)
+      }
+    } catch (error) {
+      console.error('Error processing WebSocket message:', error)
+    }
+  }
+
+  private handleClose() {
+    console.log('WebSocket connection closed')
+    this.ws = null
+  }
+
+  private handleError() {
+    console.error('WebSocket connection error')
+    this.ws = null
+  }
+}