From ed1b52aeb03b26e9481e87eb6fa2bd88ede568a9 Mon Sep 17 00:00:00 2001
From: Zdravko Iliev <zdravko.iliev@vereign.com>
Date: Wed, 21 Feb 2024 15:04:45 +0200
Subject: [PATCH] feat: use base64 for compressed buffer encoding
Signed-off-by: Zdravko Iliev <zdravko.iliev@vereign.com>
---
apps/agent/README.md | 2 +-
libs/askar/src/askar/agent.service.ts | 36 ++++++++-------------------
2 files changed, 11 insertions(+), 27 deletions(-)
diff --git a/apps/agent/README.md b/apps/agent/README.md
index 63a0c611..4ac3348f 100644
--- a/apps/agent/README.md
+++ b/apps/agent/README.md
@@ -1,4 +1,4 @@
-# OCM ENGINE - AGENT
+# OCM ENGINE - AGENT
Agent service is a wrapper around @ocm-engine/askar library.
diff --git a/libs/askar/src/askar/agent.service.ts b/libs/askar/src/askar/agent.service.ts
index 6f38953e..dcaeb30c 100644
--- a/libs/askar/src/askar/agent.service.ts
+++ b/libs/askar/src/askar/agent.service.ts
@@ -1009,41 +1009,25 @@ export class AgentService {
Buffer.from(dto.message).length / (1024 * 1024),
);
const compressedData = fflate.compressSync(Buffer.from(dto.message));
-
- console.log(
- "compressed data is",
- Buffer.from(compressedData).length / (1024 * 1024),
- );
const compressedMessage = Buffer.from(compressedData).toString("base64");
- console.log(
- "compressed data as base64 is",
- Buffer.from(compressedMessage).length / (1024 * 1024),
- );
- const base58 = TypedArrayEncoder.toBase58(compressedData);
-
- console.log(
- "compressed base58 is",
- Buffer.from(base58).length / (1024 * 1024),
+ const messageRecord = await this.askar.agent.basicMessages.sendMessage(
+ dto.connectionId,
+ compressedMessage,
);
- // const messageRecord = await this.askar.agent.basicMessages.sendMessage(
- // dto.connectionId,
- // compressedMessage,
- // );
-
const connRecord = await this.askar.agent.connections.findById(
dto.connectionId,
);
const response = new MessageRecordDto();
- // response.id = messageRecord.id;
- // response.createdAt = messageRecord.createdAt;
- // response.updatedAt = messageRecord.updatedAt;
- // response.connectionId = messageRecord.connectionId;
- // response.role = messageRecord.role;
- // response.content = messageRecord.content;
- // response.sentTime = messageRecord.sentTime;
+ response.id = messageRecord.id;
+ response.createdAt = messageRecord.createdAt;
+ response.updatedAt = messageRecord.updatedAt;
+ response.connectionId = messageRecord.connectionId;
+ response.role = messageRecord.role;
+ response.content = messageRecord.content;
+ response.sentTime = messageRecord.sentTime;
response.from = "";
response.to = connRecord?.theirLabel || "";
--
GitLab