From 500f100d466aa53c6be4c065be02dbf082d41489 Mon Sep 17 00:00:00 2001 From: Mikhail Gladchenko Date: Mon, 19 Feb 2024 15:49:54 +0000 Subject: [PATCH] fix: logs was added --- package.json | 2 +- src/services/Aggregator/ws/index.ts | 14 +++++++++++--- 2 files changed, 12 insertions(+), 4 deletions(-) diff --git a/package.json b/package.json index afc36e1..12c7d9d 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@orionprotocol/sdk", - "version": "0.20.61-rc0", + "version": "0.20.61-rc1", "description": "Orion Protocol SDK", "main": "./lib/index.cjs", "module": "./lib/index.js", diff --git a/src/services/Aggregator/ws/index.ts b/src/services/Aggregator/ws/index.ts index a83d708..e9c8ba6 100644 --- a/src/services/Aggregator/ws/index.ts +++ b/src/services/Aggregator/ws/index.ts @@ -1,4 +1,4 @@ -import { z } from 'zod'; +import { string, z } from 'zod'; import WebSocket from 'isomorphic-ws'; import { validate as uuidValidate, v4 as uuidv4 } from 'uuid'; import MessageType from './MessageType.js'; @@ -268,14 +268,19 @@ class AggregatorWS { if ('payload' in subscription) { if (typeof subscription.payload === 'string') { + console.log('subscription.payload === string', subscription.payload); subRequest['S'] = subscription.payload; } else { + console.log('subscription.payload === object', subscription.payload); for (const [key, value] of Object.entries(subscription.payload)) { - // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment - subRequest[key] = value; + console.log('for in', key, value); + // eslint-disable-next-line @typescript-eslint/consistent-type-assertions + subRequest[key] = value as Json; } } + console.log('subRequest', subRequest); + // Crutch for SwapInfoSubscriptionPayload if ( typeof subscription.payload !== 'string' && @@ -283,11 +288,14 @@ class AggregatorWS { 'o' in subscription.payload && 'a' in subscription.payload ) { + console.log('SwapInfoSubscriptionPayload', subscription.payload); subRequest['S'] = { d: id, ...subscription.payload, }; } + + console.log('subRequest', subRequest); } const subKey = isExclusive ? 'default' : id;