projeto-hit/backend/src/controllers/WbotMonitorController.ts

import { Request, Response } from "express";
import { getIO } from "../libs/socket";
import ShowWhatsAppService from "../services/WhatsappService/ShowWhatsAppService";
import { logger } from "../utils/logger";
import * as Sentry from "@sentry/node";
import Whatsapp from "../models/Whatsapp";


// type IndexQuery = {
//   centro_custo: string; 
// }; 

export const wbotMonitorRemote = async (req: Request, res: Response): Promise<Response> => {

    const { action, whatsappId, reason } = req.body

    console.log('-----------> ACTION: ', req.body['action'])

    // let whatsapp = await ShowWhatsAppService(whatsappId)

    const whatsapp: any = await Whatsapp.findByPk(whatsappId, { raw: true })

    if (whatsapp) {
        if (action === 'disconnected') {
            logger.info(`Disconnected session: ${whatsapp.name}, reason: ${reason}`);
        }

        const io = getIO();
        io.emit("whatsappSession", {
            action: "update",
            session: whatsapp
        });

    }

    return res.status(200).json({ "message": "Ok" });
};




export const wbotMonitorQrcodeRemote = async (req: Request, res: Response): Promise<Response> => {

    const { whatsappId } = req.body

    console.log('-----------> whatsappId: ', req.body['whatsappId'])

    const whatsapp: any = await Whatsapp.findByPk(whatsappId, { raw: true })
    // let whatsapp = await ShowWhatsAppService(whatsappId)

    if (whatsapp) {
        const io = getIO();
        io.emit("whatsappSession", {
            action: "update",
            session: whatsapp
        });
    } 

    return res.status(200).json({ "message": "Ok" });
};



export const wbotMonitorQrcodeNumberRead = async (req: Request, res: Response): Promise<Response> => {

    const { number } = req.body

    console.log('-----------> number read: ', number) 
    
    const io = getIO();
    io.emit("whatsappSession", {
        action: "error",
        msg: `Numero lido: ${number} \nEssa sessão de whatsapp foi desconectada porque o numero que esta descrito no nome dessa sessão não corresponde ao numero lido!`
    });

    return res.status(200).json({ "message": "Ok" });
};