Global-sales/wai-server/api/channels/channel.controller.js

'use strict';

const { sessionStore } = require('../../core'); // Import from core/index.js
const { createWhatsApp } = require('../../core/baileys'); // Import from core/index.js
const { getConnection } = require('../../services/connections.service');
const { objectMapper, isEmpty } = require('../../utils/commons.util');
const { domain, name: domainName } = require('../../config').server;

exports.newConnect = async ctx => {
  try {
    const { phone } = ctx.query;
    const existsSession = sessionStore.getSession(phone);
    if (!isEmpty(existsSession)) {
      return { phone, session_id: phone, ...existsSession, stauts: 'open', wai_server: domain };
    }
    const whatsApp1 = await createWhatsApp(phone);
    ctx.assert(whatsApp1, 503, 'No available connections');
    whatsApp1.start();
    sessionStore.createSession(phone, whatsApp1);
    return { phone, session_id: phone, wai_server: domain, ...whatsApp1 };
  } catch (error) {
    console.error('create connection error', error);
    ctx.assert(null, 500, 'Failed to create connection or generate QR code.');
  }
};

exports.getAll = async () => {
  const findConnection = await getConnection({});
  return findConnection;
};

exports.getSessions = async ctx => {
  return Array.from(sessionStore.sessions);
};