From 6320667dfd30e18f38b226b4fc4ea774b3a25430 Mon Sep 17 00:00:00 2001 From: Gabriel mermelstein Date: Tue, 15 Apr 2025 13:15:18 +0300 Subject: [PATCH] adding WrapOutgoingMessage --- .../requests/sds_message_request.nim | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) diff --git a/library/sds_thread/inter_thread_communication/requests/sds_message_request.nim b/library/sds_thread/inter_thread_communication/requests/sds_message_request.nim index 32fea23..99fddc0 100644 --- a/library/sds_thread/inter_thread_communication/requests/sds_message_request.nim +++ b/library/sds_thread/inter_thread_communication/requests/sds_message_request.nim @@ -1,4 +1,4 @@ -import std/[options, json, strutils, net] +import std/[options, json, strutils, net, sequtils] import chronos, chronicles, results, confutils, confutils/std/net import ../../../alloc @@ -40,8 +40,13 @@ proc process*( case self.operation of WRAP_MESSAGE: - let byteSeq = self.message.toSeq() - echo "------------ byteSeq: ", byteSeq - echo "------- received wrap message request" + let messageBytes = self.message.toSeq() + + let wrappedMessage = wrapOutgoingMessage(rm[], messageBytes, $self.messageId).valueOr: + error "WRAP_MESSAGE failed", error = error + return err("error processing WRAP_MESSAGE request: " & $error) + + # returns a comma-separates string of bytes + return ok(wrappedMessage.mapIt($it).join(",")) return ok("")