import { RequestHandler, Router } from 'express'; import { Logger } from '../../config/logger.config'; import { instanceNameSchema, webhookSchema } from '../../validate/validate.schema'; import { RouterBroker } from '../abstract/abstract.router'; import { InstanceDto } from '../dto/instance.dto'; import { WebhookDto } from '../dto/webhook.dto'; import { webhookController } from '../whatsapp.module'; import { HttpStatus } from './index.router'; const logger = new Logger('WebhookRouter'); export class WebhookRouter extends RouterBroker { constructor(...guards: RequestHandler[]) { super(); this.router .post(this.routerPath('set'), ...guards, async (req, res) => { logger.verbose('request received in setWebhook'); logger.verbose('request body: '); logger.verbose(req.body); logger.verbose('request query: '); logger.verbose(req.query); const response = await this.dataValidate({ request: req, schema: webhookSchema, ClassRef: WebhookDto, execute: (instance, data) => webhookController.createWebhook(instance, data), }); res.status(HttpStatus.CREATED).json(response); }) .get(this.routerPath('find'), ...guards, async (req, res) => { logger.verbose('request received in findWebhook'); logger.verbose('request body: '); logger.verbose(req.body); logger.verbose('request query: '); logger.verbose(req.query); const response = await this.dataValidate({ request: req, schema: instanceNameSchema, ClassRef: InstanceDto, execute: (instance) => webhookController.findWebhook(instance), }); res.status(HttpStatus.OK).json(response); }); } public readonly router = Router(); }