commit b62c6783fce9ce89857c3f34da7cafdb9f323a51
author Charlie <charlie_duquette@hotmail.fr> Sun Oct 30 15:14:56 2022 -0400
committer Charlie <charlie_duquette@hotmail.fr> Mon Oct 31 19:19:44 2022 -0400
tree afb6a6fad00949faf7bf117b15935b73857a9662
parent ec73545da4831b330d3d13e5f8b41af519fa885a

Send payload daemon-daemon

- Add type in inteface with jamid to send data via sendAccountTextMessage
- Add route to server

Gitlab: #52
Change-Id: I4694f37ae22097bf7776f2e3698d3c080b2cff02

server/src/jamid/jamid.ts

diff --git a/server/src/jamid/jamid.ts b/server/src/jamid/jamid.ts
index 1b7ba40..a865777 100644
--- a/server/src/jamid/jamid.ts
+++ b/server/src/jamid/jamid.ts
@@ -22,6 +22,7 @@
 
 import { JamiSignal } from './jami-signal.js';
 import {
+  IncomingAccountMessage,
   NameRegistrationEnded,
   RegisteredNameFound,
   RegistrationStateChanged,
@@ -62,11 +63,16 @@
     handlers.RegisteredNameFound = (accountId: string, state: number, address: string, username: string) =>
       onRegisteredNameFound.next({ accountId, state, address, username });
 
+    const onIncomingAccountMessage = new Subject<IncomingAccountMessage>();
+    handlers.IncomingAccountMessage = (accountId: string, from: string, message: Record<string, string>) =>
+      onIncomingAccountMessage.next({ accountId, from, message });
+
     this.events = {
       onVolatileDetailsChanged: onVolatileDetailsChanged.asObservable(),
       onRegistrationStateChanged: onRegistrationStateChanged.asObservable(),
       onNameRegistrationEnded: onNameRegistrationEnded.asObservable(),
       onRegisteredNameFound: onRegisteredNameFound.asObservable(),
+      onIncomingAccountMessage: onIncomingAccountMessage.asObservable(),
     };
 
     this.events.onVolatileDetailsChanged.subscribe(({ accountId, details }) => {
@@ -82,6 +88,9 @@
     );
     this.events.onNameRegistrationEnded.subscribe((ctx) => log.debug('[1] Received onNameRegistrationEnded with', ctx));
     this.events.onRegisteredNameFound.subscribe((ctx) => log.debug('[1] Received onRegisteredNameFound with', ctx));
+    this.events.onIncomingAccountMessage.subscribe((ctx) =>
+      log.debug('[1] Received onIncomingAccountMessage with', ctx)
+    );
 
     this.usernamesToAccountIds = new Map<string, string>();
 
@@ -139,6 +148,12 @@
     return stringVectToArray(this.jamiSwig.getAccountList());
   }
 
+  sendAccountTextMessage(accountId: string, contactId: string, type: string, message: string) {
+    const messageStringMap: StringMap = new this.jamiSwig.StringMap();
+    messageStringMap.set(type, message);
+    this.jamiSwig.sendAccountTextMessage(accountId, contactId, messageStringMap);
+  }
+
   async lookupUsername(username: string) {
     const hasRingNs = this.jamiSwig.lookupName('', '', username);
     if (!hasRingNs) {