fix: making direction not readonly and set outgoing messages with cor…

…rect direction.
input-output-hk · Apr 16, 2024 · 11fd18d · 11fd18d
1 parent 072f86a
commit 11fd18d
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/src/domain/models/Message.ts b/src/domain/models/Message.ts
@@ -36,10 +36,10 @@ export class Message implements Pluto.Storable {
       1 * 24 * 60 * 60
     ).toString(),
     public readonly ack: string[] = [],
-    public readonly direction: MessageDirection = MessageDirection.RECEIVED,
+    public direction: MessageDirection = MessageDirection.RECEIVED,
     public readonly fromPrior?: string,
     public readonly pthid?: string
-  ) {}
+  ) { }
 
   static fromJson(jsonString: JsonString): Message {
     const messageObj = JSON.parse(jsonString);

diff --git a/src/prism-agent/connectionsManager/ConnectionsManager.ts b/src/prism-agent/connectionsManager/ConnectionsManager.ts
@@ -247,6 +247,7 @@ export class ConnectionsManager implements ConnectionsManagerClass {
    * @returns {Promise<Message | undefined>}
    */
   async sendMessage(message: Message): Promise<Message | undefined> {
+    message.direction = MessageDirection.SENT;
     await this.pluto.storeMessage(message);
     return this.mercury.sendMessageParseMessage(message);
   }