fix: resolve crypto-websocket error (#668)

examples/crypto-websockets/client/asyncapi.yaml

@@ -15,10 +15,10 @@ servers:
       - $ref: '#/components/securitySchemes/apiKey'
       - $ref: '#/components/securitySchemes/cert'
 channels:
-  /price:
+  price:
     address: /price
     messages:
-      index.message:
+      indexGraph:
         $ref: '#/components/messages/indexGraph'
     bindings:
       ws:
@@ -27,9 +27,9 @@ operations:
   index:
     action: receive
     channel:
-      $ref: '#/channels/~1price'
+      $ref: '#/channels/price'
     messages:
-      - $ref: '#/components/messages/indexGraph'
+      - $ref: '#/channels/price/messages/indexGraph'
 components:
   messages:
     indexGraph:
@@ -57,4 +57,4 @@ components:
       type: apiKey
       in: user
 x-remoteServers:
-  - websockets
+  - websockets

examples/crypto-websockets/client/db.json

@@ -1 +1 @@
-[{"time":1692154441640,"price":130,"status":"started"},{"time":1692154442650,"price":140,"status":"intransit"},{"time":1692154442650,"price":140,"status":"intransit"},{"time":1692154443663,"price":180,"status":"intransit"},{"time":1692154443663,"price":180,"status":"intransit"},{"time":1692154444668,"price":180,"status":"intransit"},{"time":1692154444668,"price":180,"status":"intransit"},{"time":1692154445678,"price":160,"status":"intransit"},{"time":1692154445678,"price":160,"status":"intransit"},{"time":1692154446687,"price":120,"status":"intransit"},{"time":1692154446687,"price":120,"status":"intransit"},{"time":1692154447695,"price":110,"status":"intransit"},{"time":1692154447695,"price":110,"status":"intransit"},{"time":1692154448703,"price":130,"status":"intransit"},{"time":1692154448703,"price":130,"status":"intransit"},{"time":1692154449713,"price":130,"status":"intransit"},{"time":1692154449713,"price":130,"status":"intransit"}]
+[{"time":1704277182766,"price":140,"status":"started"},{"time":1704277183789,"price":150,"status":"intransit"},{"time":1704277183789,"price":150,"status":"intransit"},{"time":1704277184806,"price":180,"status":"intransit"},{"time":1704277184806,"price":180,"status":"intransit"},{"time":1704277185818,"price":210,"status":"intransit"},{"time":1704277185818,"price":210,"status":"intransit"},{"time":1704277186829,"price":220,"status":"intransit"},{"time":1704277186829,"price":220,"status":"intransit"},{"time":1704277187841,"price":260,"status":"intransit"},{"time":1704277187841,"price":260,"status":"intransit"},{"time":1704277188845,"price":250,"status":"intransit"},{"time":1704277188845,"price":250,"status":"intransit"},{"time":1704277189858,"price":290,"status":"intransit"},{"time":1704277189858,"price":290,"status":"intransit"},{"time":1704277190860,"price":310,"status":"intransit"},{"time":1704277190860,"price":310,"status":"intransit"}]

examples/crypto-websockets/server/asyncapi.yaml

@@ -18,10 +18,10 @@ servers:
     host: 'localhost:4000'
     protocol: ws
 channels:
-  /price:
+  price:
     address: /price
     messages:
-      subscribe.message:
+      indexGraph:
         $ref: '#/components/messages/indexGraph'
     bindings:
       ws:
@@ -35,9 +35,9 @@ operations:
   /price.subscribe:
     action: send
     channel:
-      $ref: '#/channels/~1price'
+      $ref: '#/channels/price'
     messages:
-      - $ref: '#/components/messages/indexGraph'
+      - $ref: '#/channels/price/messages/indexGraph'
 components:
   messages:
     indexGraph:
@@ -64,4 +64,4 @@ components:
       in: header
     cert:
       type: apiKey
-      in: user
+      in: user

examples/crypto-websockets/server/lifecycle/updateCryptoPrice.ts

@@ -18,7 +18,7 @@ export default async function ({ glee, connection }) {
         const date = new Date()
         setTimeout(() => {
             glee.send(new Message({
-                channel: '/price',
+                channel: 'price',
                 connection,
                 payload: {time: date.getTime(), price: getPrice(), status}
             }))