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

Added logger to WS

Browse Source
This commit is contained in:
Aleksandr Kraiz
2022-07-22 17:54:24 +04:00
parent 220019f918
commit 4d49081fe5
3 changed files with 18 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/services/OrionAggregator/ws/index.ts
View File

@@ -158,10 +158,13 @@ class OrionAggregatorWS {
public onError?: (err: string) => void;
private logger?: (message: string) => void;
private readonly wsUrl: string;
constructor(wsUrl: string, onInit?: () => void, onError?: (err: string) => void) {
constructor(wsUrl: string, logger?: (msg: string) => void, onInit?: () => void, onError?: (err: string) => void) {
this.wsUrl = wsUrl;
this.logger = logger;
this.onInit = onInit;
this.onError = onError;
}
@@ -268,7 +271,11 @@ class OrionAggregatorWS {
init(isReconnect = false) {
this.isClosedIntentionally = false;
this.ws = new WebSocket(this.wsUrl);
this.ws.onerror = (err) => {
this.logger?.(`OrionAggregatorWS: ${err.message}`);
};
this.ws.onclose = () => {
this.logger?.(`OrionAggregatorWS: connection closed ${this.isClosedIntentionally ? 'intentionally' : ''}`);
if (!this.isClosedIntentionally) this.init(true);
};
this.ws.onopen = () => {
@@ -286,9 +293,11 @@ class OrionAggregatorWS {
}
});
}
this.logger?.(`OrionAggregatorWS: connection opened${isReconnect ? ' (reconnect)' : ''}`);
};
this.ws.onmessage = (e) => {
const { data } = e;
this.logger?.(`OrionAggregatorWS: received message: ${e.data.toString()}`);
const rawJson: unknown = JSON.parse(data.toString());
const messageSchema = z.union([