Mirror/orionprotocol-sdk
1
0
Fork 0
mirror of https://github.com/orionprotocol/sdk.git synced 2026-03-14 14:12:35 +03:00
Code Issues Packages Projects Releases Wiki Activity

fix: logs was added

Browse Source
This commit is contained in:
Mikhail Gladchenko
2024-02-19 15:49:54 +00:00
parent b55492c264
commit 500f100d46
2 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
package.json
View File

@@ -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",

14
src/services/Aggregator/ws/index.ts
View File

@@ -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;