feat: Fake Call function

Author: DavidsonGomes

CHANGELOG.md

@@ -1,3 +1,14 @@
+# 2.2.0 (develop)
+
+### Features
+
+* Fake Call function
+
+### Fixed
+
+* Fixed prefilledVariables in startTypebot
+* Fix duplicate file upload
+
 # 2.1.2 (2024-10-06 10:09)
 
 ### Features

package.json

@@ -53,7 +53,7 @@
     "@sentry/node": "^8.28.0",
     "amqplib": "^0.10.3",
     "axios": "^1.6.5",
-    "baileys": "github:renatoiub/Baileys",
+    "baileys": "github:EvolutionAPI/Baileys",
     "class-validator": "^0.14.1",
     "compression": "^1.7.4",
     "cors": "^2.8.5",

src/api/controllers/call.controller.ts

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

src/api/dto/call.dto.ts

@@ -0,0 +1,8 @@
+export class Metadata {
+  number: string;
+}
+
+export class OfferCallDto extends Metadata {
+  isVideo?: boolean;
+  callDuration?: number;
+}

src/api/integrations/channel/evolution/evolution.channel.service.ts

@@ -555,4 +555,7 @@ export class EvolutionStartupService extends ChannelStartupService {
   public async fakeCall() {
     throw new BadRequestException('Method not available on Evolution Channel');
   }
+  public async offerCall() {
+    throw new BadRequestException('Method not available on Evolution Channel');
+  }
 }

src/api/integrations/channel/meta/whatsapp.business.service.ts

@@ -1300,4 +1300,7 @@ export class BusinessStartupService extends ChannelStartupService {
   public async fakeCall() {
     throw new BadRequestException('Method not available on WhatsApp Business API');
   }
+  public async offerCall() {
+    throw new BadRequestException('Method not available on WhatsApp Business API');
+  }
 }

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

@@ -1,3 +1,4 @@
+import { OfferCallDto } from '@api/dto/call.dto';
 import {
   ArchiveChatDto,
   BlockUserDto,
@@ -1351,6 +1352,19 @@ export class BaileysStartupService extends ChannelStartupService {
     }
   }
 
+  public async offerCall({ number, isVideo, callDuration }: OfferCallDto) {
+    const jid = this.createJid(number);
+
+    try {
+      const call = await this.client.offerCall(jid, isVideo);
+      setTimeout(() => this.client.terminateCall(call.id, call.to), callDuration * 1000);
+
+      return call;
+    } catch (error) {
+      return error;
+    }
+  }
+
   private async sendMessage(
     sender: string,
     message: any,

src/api/routes/call.router.ts

@@ -0,0 +1,25 @@
+import { RouterBroker } from '@api/abstract/abstract.router';
+import { OfferCallDto } from '@api/dto/call.dto';
+import { callController } from '@api/server.module';
+import { offerCallSchema } from '@validate/validate.schema';
+import { RequestHandler, Router } from 'express';
+
+import { HttpStatus } from './index.router';
+
+export class CallRouter extends RouterBroker {
+  constructor(...guards: RequestHandler[]) {
+    super();
+    this.router.post(this.routerPath('offer'), ...guards, async (req, res) => {
+      const response = await this.dataValidate<OfferCallDto>({
+        request: req,
+        schema: offerCallSchema,
+        ClassRef: OfferCallDto,
+        execute: (instance, data) => callController.offerCall(instance, data),
+      });
+
+      return res.status(HttpStatus.CREATED).json(response);
+    });
+  }
+
+  public readonly router: Router = Router();
+}

src/api/routes/index.router.ts

@@ -6,9 +6,8 @@ import { EventRouter } from '@api/integrations/event/event.router';
 import { configService } from '@config/env.config';
 import { Router } from 'express';
 import fs from 'fs';
-import mime from 'mime';
-import path from 'path';
 
+import { CallRouter } from './call.router';
 import { ChatRouter } from './chat.router';
 import { GroupRouter } from './group.router';
 import { InstanceRouter } from './instance.router';
@@ -35,20 +34,6 @@ const telemetry = new Telemetry();
 
 const packageJson = JSON.parse(fs.readFileSync('./package.json', 'utf8'));
 
-router.get('/assets/*', (req, res) => {
-  const fileName = req.params[0];
-  const basePath = path.join(process.cwd(), 'manager', 'dist');
-
-  const filePath = path.join(basePath, 'assets/', fileName);
-
-  if (fs.existsSync(filePath)) {
-    res.set('Content-Type', mime.getType(filePath) || 'text/css');
-    res.send(fs.readFileSync(filePath));
-  } else {
-    res.status(404).send('File not found');
-  }
-});
-
 router
   .use((req, res, next) => telemetry.collectTelemetry(req, res, next))
 
@@ -72,6 +57,7 @@ router
   })
   .use('/instance', new InstanceRouter(configService, ...guards).router)
   .use('/message', new MessageRouter(...guards).router)
+  .use('/call', new CallRouter(...guards).router)
   .use('/chat', new ChatRouter(...guards).router)
   .use('/group', new GroupRouter(...guards).router)
   .use('/template', new TemplateRouter(configService, ...guards).router)

src/api/server.module.ts

@@ -3,6 +3,7 @@ import { configService, ProviderSession } from '@config/env.config';
 import { eventEmitter } from '@config/event.config';
 import { Logger } from '@config/logger.config';
 
+import { CallController } from './controllers/call.controller';
 import { ChatController } from './controllers/chat.controller';
 import { GroupController } from './controllers/group.controller';
 import { InstanceController } from './controllers/instance.controller';
@@ -65,6 +66,7 @@ export const instanceController = new InstanceController(
   providerFiles,
 );
 export const sendMessageController = new SendMessageController(waMonitor);
+export const callController = new CallController(waMonitor);
 export const chatController = new ChatController(waMonitor);
 export const groupController = new GroupController(waMonitor);
 export const labelController = new LabelController(waMonitor);