whatsapp solution completed

rpsoftech · Nov 12, 2023 · c54f2c8 · c54f2c8
1 parent 8096fa8
commit c54f2c8
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 11 deletions.
diff --git a/apps/server/whatsapp-common/src/firebaseRD.creds.store.ts b/apps/server/whatsapp-common/src/firebaseRD.creds.store.ts
@@ -21,8 +21,6 @@ export const useFireBaseRealTimeDatabaseStoreAuthState = async (
 
   const writeData = async (data: any, file: string) => {
     data = JSON.stringify(data, BufferJSON.replacer);
-    console.log('Writing data type ', typeof data);
-    console.log('Writing data  ', data);
     collection.child(processFileName(file)).set(data);
     return;
   };
@@ -39,8 +37,6 @@ export const useFireBaseRealTimeDatabaseStoreAuthState = async (
       if (typeof finalRead === 'string') {
         finalRead = JSON.parse(finalRead, BufferJSON.reviver);
       }
-      console.log('final REad ', finalRead);
-      console.log(typeof finalRead);
       return finalRead;
     } catch (error) {
       return null;

diff --git a/apps/server/whatsapp-common/src/main.ts b/apps/server/whatsapp-common/src/main.ts
@@ -32,7 +32,7 @@ async function connectToWhatsApp() {
     // logger: pin({ level: 'debug' }),
     // can provide additional config here
     printQRInTerminal: true,
-    shouldSyncHistoryMessage: () => false,
+    // shouldSyncHistoryMessage: () => false,
     browser: Browsers.ubuntu('Desktop'),
     syncFullHistory: false,
   });
@@ -60,17 +60,17 @@ async function connectToWhatsApp() {
       if (!ServerConfigBehavior.value.dbReadStarted) {
         ReadMessagesFromFirebase();
       }
-    } else {
-      console.log(connection);
     }
   });
-  sock.ev.on('presence.update', (update) => {
-    console.log(update.id, 'Is Online', update.presences);
-  });
-
   messageSubject.subscribe((a) => {
     if (ServerConfigBehavior.value.whatsappLoggedIn) {
+      if (typeof a.message.replaceAll === 'function') {
+        a.message = a.message.replaceAll('@n@', '\n');
+        a.message = a.message.replaceAll('\\n', '\n');
+      }
+      console.log(a.message);
       sock.sendMessage(`${a.number}@s.whatsapp.net`, {
+        footer: 'Confidential',
         text: a.message,
       });
     }
@@ -86,6 +86,7 @@ setInterval(() => {
   });
 }, 5000);
 
+// eslint-disable-next-line @typescript-eslint/no-unused-vars
 function ReadMessagesFromFirebase() {
   const ref = firebaseDb.ref(_generalConfig.readPath);
   const CB: (a: DataSnapshot, b?: string | null) => void = (a) => {