added: route - /assertSessions

code-chat-br · Oct 22, 2024 · 4ee80de · 4ee80de
1 parent a057b12
commit 4ee80de
Show file tree

Hide file tree

Showing 3 changed files with 35 additions and 5 deletions.
diff --git a/src/whatsapp/controllers/chat.controller.ts b/src/whatsapp/controllers/chat.controller.ts
@@ -109,4 +109,10 @@ export class ChatController {
   public async rejectCall({ instanceName }: InstanceDto, data: RejectCallDto) {
     return await this.waMonitor.waInstances.get(instanceName).rejectCall(data);
   }
+
+  public async assertSessions({ instanceName }: InstanceDto, data: WhatsAppNumberDto) {
+    return await this.waMonitor.waInstances
+      .get(instanceName)
+      .assertSessions(data.numbers);
+  }
 }
diff --git a/src/whatsapp/routers/chat.router.ts b/src/whatsapp/routers/chat.router.ts
@@ -270,6 +270,15 @@ export function ChatRouter(chatController: ChatController, ...guards: RequestHan
         execute: (instance, data) => chatController.rejectCall(instance, data),
       });
 
+      return res.status(HttpStatus.OK).json(response);
+    })
+    .post(routerPath('assertSessions'), ...guards, async (req, res) => {
+      const response = await dataValidate<WhatsAppNumberDto>({
+        request: req,
+        schema: whatsappNumberSchema,
+        execute: (instance, data) => chatController.assertSessions(instance, data),
+      });
+
       return res.status(HttpStatus.OK).json(response);
     });
 

diff --git a/src/whatsapp/services/whatsapp.service.ts b/src/whatsapp/services/whatsapp.service.ts
@@ -1635,17 +1635,17 @@ export class WAStartupService {
     return await this.sendMessageWithTyping(data.number, {
       extendedTextMessage: {
         text: (() => {
+          let t = data.linkMessage.link;
           if (data.linkMessage?.text) {
-            let t = data.linkMessage.link;
             t += '\n\n';
             t += data.linkMessage.text;
-            return t;
           }
+          return t;
         })(),
         canonicalUrl: data.linkMessage.link,
-        matchedText: data.linkMessage?.text,
-        previewType: 0,
-        title: data.linkMessage?.title,
+        matchedText: data.linkMessage?.link,
+        previewType: proto.Message.ExtendedTextMessage.PreviewType.IMAGE,
+        title: data.linkMessage?.title || data.linkMessage?.link,
         description: data.linkMessage?.description,
         jpegThumbnail: await (async () => {
           if (data.linkMessage?.thumbnailUrl) {
@@ -2059,6 +2059,21 @@ export class WAStartupService {
     }
   }
 
+  public async assertSessions(chats: string[]) {
+    if (!Array.isArray(chats) || chats.length === 0) {
+      throw new BadRequestException('Empty or invalid array');
+    }
+    try {
+      await this.client.assertSessions(
+        chats.map((c) => this.createJid(c)),
+        true,
+      );
+      return { message: 'Session asserted' };
+    } catch (error) {
+      throw new InternalServerErrorException('Error asserting session', error.toString());
+    }
+  }
+
   // Group
   public async createGroup(create: CreateGroupDto) {
     try {