refactor(api): update conduit javascript to reflect new api

socketsupply · Jun 28, 2024 · 4a1d00b · 4a1d00b
1 parent 9e20235
commit 4a1d00b
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 7 deletions.
diff --git a/api/dgram.js b/api/dgram.js
@@ -512,12 +512,11 @@ async function send (socket, options, callback) {
     })
 
     if (socket.conduit) {
-      const headers = {
+      socket.conduit.send({
+        route: 'udp.send',
         port: options.port,
         address: options.address
-      }
-
-      socket.conduit.send(headers, options.buffer)
+      }, options.buffer)
       result = { data: true }
     } else {
       result = await ipc.write('udp.send', {
@@ -774,7 +773,7 @@ export class Socket extends EventEmitter {
       }
 
       if (this.highThroughput) {
-        this.conduit = new Conduit({ method: 'udp.send', id: this.id })
+        this.conduit = new Conduit({ id: this.id })
 
         this.conduit.receive(({ headers, payload }) => {
           const rinfo = {

diff --git a/api/internal/conduit.js b/api/internal/conduit.js
@@ -11,9 +11,9 @@ export class Conduit {
    * @param {string} params.id - The ID for the connection.
    * @param {string} params.method - The method to use for the connection.
    */
-  constructor ({ id, method }) {
+  constructor ({ id, route }) {
     const port = globalThis.__args.conduit
-    const uri = `ws://localhost:${port}/${method}?id=${id}`
+    const uri = `ws://localhost:${port}/${route}/${id}`
     this.socket = new globalThis.WebSocket(uri)
   }