feat(chatbot): add /chatbot/manage REST endpoint

- Create ChatbotManageController with actions: transfer_human, resolve_bot, pause_bot, resume_bot
- Create ChatbotManageDto and JSONSchema7 validation
- Create ChatbotManageRouter with POST /action and GET /status
- Register routes in chatbot.router.ts and export schema

Author: sosamilton

src/api/integrations/chatbot/chatbot.router.ts

@@ -1,5 +1,6 @@
 import { ChatwootRouter } from '@api/integrations/chatbot/chatwoot/routes/chatwoot.router';
 import { DifyRouter } from '@api/integrations/chatbot/dify/routes/dify.router';
+import { ChatbotManageRouter } from '@api/integrations/chatbot/manage/routes/chatbot-manage.router';
 import { OpenaiRouter } from '@api/integrations/chatbot/openai/routes/openai.router';
 import { TypebotRouter } from '@api/integrations/chatbot/typebot/routes/typebot.router';
 import { Router } from 'express';
@@ -23,5 +24,6 @@ export class ChatbotRouter {
     this.router.use('/flowise', new FlowiseRouter(...guards).router);
     this.router.use('/n8n', new N8nRouter(...guards).router);
     this.router.use('/evoai', new EvoaiRouter(...guards).router);
+    this.router.use('/manage', new ChatbotManageRouter(...guards).router);
   }
 }

src/api/integrations/chatbot/chatbot.schema.ts

@@ -3,6 +3,7 @@ export * from '@api/integrations/chatbot/dify/validate/dify.schema';
 export * from '@api/integrations/chatbot/evoai/validate/evoai.schema';
 export * from '@api/integrations/chatbot/evolutionBot/validate/evolutionBot.schema';
 export * from '@api/integrations/chatbot/flowise/validate/flowise.schema';
+export * from '@api/integrations/chatbot/manage/validate/chatbot-manage.schema';
 export * from '@api/integrations/chatbot/n8n/validate/n8n.schema';
 export * from '@api/integrations/chatbot/openai/validate/openai.schema';
 export * from '@api/integrations/chatbot/typebot/validate/typebot.schema';

src/api/integrations/chatbot/manage/controllers/chatbot-manage.controller.ts

@@ -0,0 +1,66 @@
+import { InstanceDto } from '@api/dto/instance.dto';
+import { ChatbotChatwootService } from '@api/integrations/chatbot/chatbot-chatwoot.service';
+import { PrismaRepository } from '@api/repository/repository.service';
+import { Logger } from '@config/logger.config';
+import { BadRequestException } from '@exceptions';
+
+import { ChatbotManageDto } from '../dto/chatbot-manage.dto';
+
+export class ChatbotManageController {
+  private readonly logger = new Logger('ChatbotManageController');
+
+  constructor(
+    private readonly chatbotChatwootService: ChatbotChatwootService,
+    private readonly prismaRepository: PrismaRepository,
+  ) {}
+
+  public async manage(instance: InstanceDto, data: ChatbotManageDto) {
+    const instanceDb = await this.prismaRepository.instance.findFirst({
+      where: { name: instance.instanceName },
+    });
+
+    if (!instanceDb) {
+      throw new BadRequestException('Instance not found');
+    }
+
+    if (!data.remoteJid) {
+      throw new BadRequestException('remoteJid is required');
+    }
+
+    // Normalize remoteJid
+    const remoteJid = data.remoteJid.includes('@') ? data.remoteJid : `${data.remoteJid}@s.whatsapp.net`;
+
+    this.logger.log(`[Manage] action=${data.action}, instance=${instance.instanceName}, remoteJid=${remoteJid}`);
+
+    switch (data.action) {
+      case 'transfer_human': {
+        const result = await this.chatbotChatwootService.transferToHuman(
+          instanceDb.id,
+          remoteJid,
+          data.chatwoot?.assigneeId,
+          data.chatwoot?.teamId,
+        );
+        return { action: 'transfer_human', ...result };
+      }
+
+      case 'resolve_bot': {
+        const resolveChatwoot = data.chatwoot?.status !== undefined ? data.chatwoot.status === 'resolved' : true;
+        const result = await this.chatbotChatwootService.resolveBot(instanceDb.id, remoteJid, resolveChatwoot);
+        return { action: 'resolve_bot', ...result };
+      }
+
+      case 'pause_bot': {
+        const result = await this.chatbotChatwootService.pauseBot(instanceDb.id, remoteJid);
+        return { action: 'pause_bot', ...result };
+      }
+
+      case 'resume_bot': {
+        const result = await this.chatbotChatwootService.resumeBot(instanceDb.id, remoteJid);
+        return { action: 'resume_bot', ...result };
+      }
+
+      default:
+        throw new BadRequestException(`Invalid action: ${data.action}. Valid actions: transfer_human, resolve_bot, pause_bot, resume_bot`);
+    }
+  }
+}

src/api/integrations/chatbot/manage/dto/chatbot-manage.dto.ts

@@ -0,0 +1,9 @@
+export class ChatbotManageDto {
+  action: 'transfer_human' | 'resolve_bot' | 'pause_bot' | 'resume_bot';
+  remoteJid: string;
+  chatwoot?: {
+    status?: 'open' | 'resolved' | 'pending';
+    assigneeId?: number;
+    teamId?: number;
+  };
+}

src/api/integrations/chatbot/manage/routes/chatbot-manage.router.ts

@@ -0,0 +1,39 @@
+import { RouterBroker } from '@api/abstract/abstract.router';
+import { InstanceDto } from '@api/dto/instance.dto';
+import { ChatbotManageDto } from '@api/integrations/chatbot/manage/dto/chatbot-manage.dto';
+import { chatbotManageSchema } from '@api/integrations/chatbot/manage/validate/chatbot-manage.schema';
+import { HttpStatus } from '@api/routes/index.router';
+import { chatbotManageController } from '@api/server.module';
+import { instanceSchema } from '@validate/validate.schema';
+import { RequestHandler, Router } from 'express';
+
+export class ChatbotManageRouter extends RouterBroker {
+  constructor(...guards: RequestHandler[]) {
+    super();
+    this.router
+      .post(this.routerPath('action'), ...guards, async (req, res) => {
+        const response = await this.dataValidate<ChatbotManageDto>({
+          request: req,
+          schema: chatbotManageSchema,
+          ClassRef: ChatbotManageDto,
+          execute: (instance, data) => chatbotManageController.manage(instance, data),
+        });
+
+        res.status(HttpStatus.OK).json(response);
+      })
+      .get(this.routerPath('status'), ...guards, async (req, res) => {
+        const response = await this.dataValidate<InstanceDto>({
+          request: req,
+          schema: instanceSchema,
+          ClassRef: InstanceDto,
+          execute: async (instance) => {
+            return { status: 'ok', integration: 'chatbot-chatwoot-coordination', instance: instance.instanceName };
+          },
+        });
+
+        res.status(HttpStatus.OK).json(response);
+      });
+  }
+
+  public readonly router: Router = Router();
+}

src/api/integrations/chatbot/manage/validate/chatbot-manage.schema.ts

@@ -0,0 +1,23 @@
+import { JSONSchema7 } from 'json-schema';
+import { v4 } from 'uuid';
+
+export const chatbotManageSchema: JSONSchema7 = {
+  $id: v4(),
+  type: 'object',
+  properties: {
+    action: {
+      type: 'string',
+      enum: ['transfer_human', 'resolve_bot', 'pause_bot', 'resume_bot'],
+    },
+    remoteJid: { type: 'string' },
+    chatwoot: {
+      type: 'object',
+      properties: {
+        status: { type: 'string', enum: ['open', 'resolved', 'pending'] },
+        assigneeId: { type: 'integer' },
+        teamId: { type: 'integer' },
+      },
+    },
+  },
+  required: ['action', 'remoteJid'],
+};