feat(contact): add save contact endpoint and Baileys handler

src/api/controllers/contact.controller.ts

@@ -0,0 +1,11 @@
+import { SaveContactDto } from '@api/dto/contact.dto';
+import { InstanceDto } from '@api/dto/instance.dto';
+import { WAMonitoringService } from '@api/services/monitor.service';
+
+export class ContactController {
+  constructor(private readonly waMonitor: WAMonitoringService) {}
+
+  public async saveContact({ instanceName }: InstanceDto, data: SaveContactDto) {
+    return await this.waMonitor.waInstances[instanceName].saveContact(data);
+  }
+}

src/api/dto/contact.dto.ts

@@ -0,0 +1,5 @@
+export class SaveContactDto {
+  number: string;
+  name: string;
+  saveOnDevice?: boolean;
+}

src/api/integrations/channel/whatsapp/whatsapp.baileys.service.ts

@@ -1,4 +1,4 @@
 import { getCollectionsDto } from '@api/dto/business.dto';
 import { OfferCallDto } from '@api/dto/call.dto';
 import {
   ArchiveChatDto,
@@ -154,6 +154,7 @@
 
 import { BaileysMessageProcessor } from './baileysMessage.processor';
 import { useVoiceCallsBaileys } from './voiceCalls/useVoiceCallsBaileys';
+import { SaveContactDto } from '@api/dto/contact.dto';
 
 export interface ExtendedIMessageKey extends proto.IMessageKey {
   remoteJidAlt?: string;
@@ -3767,6 +3768,29 @@
       });
     }
   }
+
+  public async saveContact(data: SaveContactDto) {
+    try {
+      const jid = createJid(data.number);
+      await this.client.chatModify(
+        {
+          contact: {
+            fullName: data.name || 'Unknown',
+            firstName: (data.name || 'Unknown').split(' ')[0],
+            saveOnPrimaryAddressbook: data.saveOnDevice ?? true,
+          },
+        },
+        jid,
+      );
+
+      return { saved: true, number: data.number, name: data.name };
+    } catch (error) {
+      throw new InternalServerErrorException({
+        saved: false,
+        message: ['An error occurred while saving the contact.', error.toString()],
+      });
+    }
+  }
 
   public async deleteMessage(del: DeleteMessage) {
     try {

src/api/routes/contact.router.ts

@@ -0,0 +1,29 @@
+import { RouterBroker } from '@api/abstract/abstract.router';
+import { SaveContactDto } from '@api/dto/contact.dto';
+import { contactController } from '@api/server.module';
+import { saveContactSchema } from '@validate/contact.schema';
+import { RequestHandler, Router } from 'express';
+
+import { HttpStatus } from './index.router';
+
+export class ContactRouter extends RouterBroker {
+  constructor(...guards: RequestHandler[]) {
+    super();
+    this.router.post(this.routerPath('save'), ...guards, async (req, res) => {
+      try {
+        const response = await this.dataValidate<SaveContactDto>({
+          request: req,
+          schema: saveContactSchema,
+          ClassRef: SaveContactDto,
+          execute: (instance, data) => contactController.saveContact(instance, data),
+        });
+
+        return res.status(HttpStatus.OK).json(response);
+      } catch (error) {
+        return res.status(HttpStatus.BAD_REQUEST).json(error);
+      }
+    });
+  }
+
+  public readonly router: Router = Router();
+}

src/api/routes/index.router.ts

@@ -16,6 +16,7 @@ import path from 'path';
 import { BusinessRouter } from './business.router';
 import { CallRouter } from './call.router';
 import { ChatRouter } from './chat.router';
+import { ContactRouter } from './contact.router';
 import { GroupRouter } from './group.router';
 import { InstanceRouter } from './instance.router';
 import { LabelRouter } from './label.router';
@@ -218,6 +219,7 @@ router
   .use('/message', new MessageRouter(...guards).router)
   .use('/call', new CallRouter(...guards).router)
   .use('/chat', new ChatRouter(...guards).router)
+  .use('/contact', new ContactRouter(...guards).router)
   .use('/business', new BusinessRouter(...guards).router)
   .use('/group', new GroupRouter(...guards).router)
   .use('/template', new TemplateRouter(configService, ...guards).router)

src/api/server.module.ts

@@ -6,6 +6,7 @@ import { Logger } from '@config/logger.config';
 import { BusinessController } from './controllers/business.controller';
 import { CallController } from './controllers/call.controller';
 import { ChatController } from './controllers/chat.controller';
+import { ContactController } from './controllers/contact.controller';
 import { GroupController } from './controllers/group.controller';
 import { InstanceController } from './controllers/instance.controller';
 import { LabelController } from './controllers/label.controller';
@@ -103,6 +104,7 @@ export const instanceController = new InstanceController(
 export const sendMessageController = new SendMessageController(waMonitor);
 export const callController = new CallController(waMonitor);
 export const chatController = new ChatController(waMonitor);
+export const contactController = new ContactController(waMonitor);
 export const businessController = new BusinessController(waMonitor);
 export const groupController = new GroupController(waMonitor);
 export const labelController = new LabelController(waMonitor);

src/validate/contact.schema.ts

@@ -0,0 +1,13 @@
+import { JSONSchema7 } from 'json-schema';
+import { v4 } from 'uuid';
+
+export const saveContactSchema: JSONSchema7 = {
+  $id: v4(),
+  type: 'object',
+  properties: {
+    number: { type: 'string' },
+    name: { type: 'string' },
+    saveOnDevice: { type: 'boolean', default: true },
+  },
+  required: ['number', 'name'],
+};