From 110160a3164178fcf427f7fedc5f76959d621a46 Mon Sep 17 00:00:00 2001 From: Maor Stamati Date: Wed, 15 Jan 2025 16:20:32 +0000 Subject: [PATCH] Improve agent performance by not awaiting handleMessages --- src/services/fireblocks-agent.ts | 10 ++++++---- src/version.ts | 2 +- 2 files changed, 7 insertions(+), 5 deletions(-) diff --git a/src/services/fireblocks-agent.ts b/src/services/fireblocks-agent.ts index 212664d..1e6196e 100644 --- a/src/services/fireblocks-agent.ts +++ b/src/services/fireblocks-agent.ts @@ -1,11 +1,11 @@ +import https from 'https'; import jwt from 'jsonwebtoken'; -import { GUID, JWT, PairingToken } from 'types'; +import { JWT, PairingToken } from 'types'; +import { AGENT_VERSION } from '../version'; import deviceService, { DeviceData } from './device.service'; import fbServerApi from './fb-server.api'; import logger from './logger'; import messageService from './messages.service'; -import https from 'https'; -import { AGENT_VERSION } from '../version'; export interface FireblocksAgent { pairDevice(pairingToken: JWT): void; runAgentMainLoop(httpsAgent: https.Agent): Promise; @@ -46,7 +46,9 @@ class FireblocksAgentImpl implements FireblocksAgent { logger.info(`Waiting for messages from Fireblocks... (version=${AGENT_VERSION})`); const messages = await fbServerApi.getMessages(); logger.info(`Got ${messages.length} messages from Fireblocks after ${Date.now() - start}ms`); - await messageService.handleMessages(messages, httpsAgent); + messageService.handleMessages(messages, httpsAgent).catch((e) => { + logger.error(`Error in agent handle messages ${e}`); + }); }; } diff --git a/src/version.ts b/src/version.ts index 8df90d6..30cd0b7 100644 --- a/src/version.ts +++ b/src/version.ts @@ -1 +1 @@ -export const AGENT_VERSION = '2.2.7'; +export const AGENT_VERSION = '2.2.8';