All files / services/whatsapp MessagePipelineInitializer.js

1
2
3
4
5
6
7
8
9
10
11
12
13
 
 
 
 
 
 
 
 
 
 
 
 
 
const queueDispatcher = require('../../core/whatsapp/QueueDispatcher');
const { WebMessageSender } = require('./WebMessageSender');
const { send: sendCloud } = require('./CloudMessageSender');
const { registerWhatsAppModules } = require('../../modules/whatsapp');
 
const initializeMessagePipeline = ({ whatsappService }) => {
  queueDispatcher.registerSender('web', new WebMessageSender(whatsappService));
  queueDispatcher.registerSender('cloud', { send: sendCloud });
  registerWhatsAppModules({ whatsappService });
};
 
module.exports = { initializeMessagePipeline };