From 6df254dc13503c90ca26d36305eebccc6ecc382f Mon Sep 17 00:00:00 2001
From: artembuslaev <buslaew.ar@mail.ru>
Date: Fri, 7 Apr 2023 02:23:02 +0400
Subject: [PATCH] fix transaction logs

Signed-off-by: artembuslaev <buslaew.ar@mail.ru>
---
 common/src/mq/message-broker-channel.ts                  | 9 +++++----
 .../src/hedera-modules/transaction-logger.ts             | 2 +-
 2 files changed, 6 insertions(+), 5 deletions(-)

diff --git a/common/src/mq/message-broker-channel.ts b/common/src/mq/message-broker-channel.ts
index 0361ccdf1b..5de78f027f 100644
--- a/common/src/mq/message-broker-channel.ts
+++ b/common/src/mq/message-broker-channel.ts
@@ -1,7 +1,8 @@
 import assert from 'assert';
-import { Subscription, NatsConnection, StringCodec, connect, JSONCodec, headers } from 'nats';
+import { Subscription, NatsConnection, StringCodec, connect, headers } from 'nats';
 import { IMessageResponse, MessageError } from '../models/message-response';
 import { GenerateUUIDv4 } from '@guardian/interfaces';
+import { ZipCodec } from './zip-codec';
 
 const MQ_TIMEOUT = 300000;
 /**
@@ -258,15 +259,15 @@ export class MessageBrokerChannel {
      * @param data
      * @param allowError
      */
-    public publish<T>(eventType: string, data: T, allowError = true) {
+    public async publish<T>(eventType: string, data: T, allowError = true) {
         try {
             console.log('MQ publish: %s', eventType);
             const messageId = GenerateUUIDv4();
             const head = headers();
             head.append('messageId', messageId);
 
-            const sc = JSONCodec();
-            this.channel.publish(eventType, sc.encode(data), { headers: head });
+            const zc = ZipCodec();
+            this.channel.publish(eventType, await zc.encode(data), { headers: head });
         } catch (e) {
 
             console.error(e.message, e.stack, e);
diff --git a/guardian-service/src/hedera-modules/transaction-logger.ts b/guardian-service/src/hedera-modules/transaction-logger.ts
index 8f2194bf42..316317baf3 100644
--- a/guardian-service/src/hedera-modules/transaction-logger.ts
+++ b/guardian-service/src/hedera-modules/transaction-logger.ts
@@ -276,7 +276,7 @@ export class TransactionLogger extends NatsService {
             })
 
             return new MessageResponse({});
-        });
+        }, true);
     }
 
     /**