Merge branch 'release/1.4.7'

CHANGELOG.md

@@ -1,3 +1,11 @@
+# 1.4.7 (2023-07-27 08:47)
+
+### Fixed
+
+* Fixed error return bug
+* Fixed problem of getting message when deleting message in chatwoot
+* Change in error return pattern
+
 # 1.4.6 (2023-07-26 17:54)
 
 ### Fixed

package.json

@@ -1,6 +1,6 @@
 {
   "name": "evolution-api",
-  "version": "1.4.6",
+  "version": "1.4.7",
   "description": "Rest api for communication with WhatsApp",
   "main": "./dist/src/main.js",
   "scripts": {
@@ -46,7 +46,7 @@
     "@figuro/chatwoot-sdk": "^1.1.14",
     "@hapi/boom": "^10.0.1",
     "@sentry/node": "^7.59.2",
-    "@whiskeysockets/baileys": "^6.4.0",
+    "@whiskeysockets/baileys": "github:EvolutionAPI/Baileys",
     "axios": "^1.3.5",
     "class-validator": "^0.13.2",
     "compression": "^1.7.4",

src/main.ts

@@ -1,6 +1,5 @@
 import 'express-async-errors';
 
-// import * as Sentry from '@sentry/node';
 import compression from 'compression';
 import cors from 'cors';
 import express, { json, NextFunction, Request, Response, urlencoded } from 'express';
@@ -15,94 +14,77 @@ import { HttpStatus, router } from './whatsapp/routers/index.router';
 import { waMonitor } from './whatsapp/whatsapp.module';
 
 function initWA() {
-  waMonitor.loadInstance();
+    waMonitor.loadInstance();
 }
 
 function bootstrap() {
-  const logger = new Logger('SERVER');
-  const app = express();
+    const logger = new Logger('SERVER');
+    const app = express();
 
-  // Sentry.init({
-  //   dsn: '',
-  //   integrations: [
-  //     // enable HTTP calls tracing
-  //     new Sentry.Integrations.Http({ tracing: true }),
-  //     // enable Express.js middleware tracing
-  //     new Sentry.Integrations.Express({ app }),
-  //     // Automatically instrument Node.js libraries and frameworks
-  //     ...Sentry.autoDiscoverNodePerformanceMonitoringIntegrations(),
-  //   ],
+    app.use(
+        cors({
+            origin(requestOrigin, callback) {
+                const { ORIGIN } = configService.get<Cors>('CORS');
+                !requestOrigin ? (requestOrigin = '*') : undefined;
+                if (ORIGIN.indexOf(requestOrigin) !== -1) {
+                    return callback(null, true);
+                }
+                return callback(new Error('Not allowed by CORS'));
+            },
+            methods: [...configService.get<Cors>('CORS').METHODS],
+            credentials: configService.get<Cors>('CORS').CREDENTIALS,
+        }),
+        urlencoded({ extended: true, limit: '136mb' }),
+        json({ limit: '136mb' }),
+        compression(),
+    );
 
-  //   // Set tracesSampleRate to 1.0 to capture 100%
-  //   // of transactions for performance monitoring.
-  //   // We recommend adjusting this value in production
-  //   tracesSampleRate: 1.0,
-  // });
+    app.set('view engine', 'hbs');
+    app.set('views', join(ROOT_DIR, 'views'));
+    app.use(express.static(join(ROOT_DIR, 'public')));
 
-  // app.use(Sentry.Handlers.requestHandler());
+    app.use('/', router);
 
-  // app.use(Sentry.Handlers.tracingHandler());
+    app.use(
+        (err: Error, req: Request, res: Response, next: NextFunction) => {
+            if (err) {
+                return res.status(err['status'] || 500).json({
+                    status: 'ERROR',
+                    error: err['error'] || 'Internal Server Error',
+                    response: {
+                        message: err['message'] || 'Internal Server Error',
+                    },
+                  }
+                );
+            }
 
-  app.use(
-    cors({
-      origin(requestOrigin, callback) {
-        const { ORIGIN } = configService.get<Cors>('CORS');
-        !requestOrigin ? (requestOrigin = '*') : undefined;
-        if (ORIGIN.indexOf(requestOrigin) !== -1) {
-          return callback(null, true);
-        }
-        return callback(new Error('Not allowed by CORS'));
-      },
-      methods: [...configService.get<Cors>('CORS').METHODS],
-      credentials: configService.get<Cors>('CORS').CREDENTIALS,
-    }),
-    urlencoded({ extended: true, limit: '136mb' }),
-    json({ limit: '136mb' }),
-    compression(),
-  );
+            next();
+        },
+        (req: Request, res: Response, next: NextFunction) => {
+            const { method, url } = req;
 
-  app.set('view engine', 'hbs');
-  app.set('views', join(ROOT_DIR, 'views'));
-  app.use(express.static(join(ROOT_DIR, 'public')));
+            res.status(HttpStatus.NOT_FOUND).json({
+                status: HttpStatus.NOT_FOUND,
+                error: 'Not Found',
+                response: {
+                    message: `Cannot ${method.toUpperCase()} ${url}`,
+                },
+            });
 
-  app.use('/', router);
+            next();
+        },
+    );
 
-  // app.use(Sentry.Handlers.errorHandler());
+    const httpServer = configService.get<HttpServer>('SERVER');
 
-  // app.use(function onError(err, req, res, next) {
-  //   res.statusCode = 500;
-  //   res.end(res.sentry + '\n');
-  // });
+    ServerUP.app = app;
+    const server = ServerUP[httpServer.TYPE];
 
-  app.use(
-    (err: Error, req: Request, res: Response) => {
-      if (err) {
-        return res.status(err['status'] || 500).json(err);
-      }
-    },
-    (req: Request, res: Response, next: NextFunction) => {
-      const { method, url } = req;
+    server.listen(httpServer.PORT, () => logger.log(httpServer.TYPE.toUpperCase() + ' - ON: ' + httpServer.PORT));
 
-      res.status(HttpStatus.NOT_FOUND).json({
-        status: HttpStatus.NOT_FOUND,
-        message: `Cannot ${method.toUpperCase()} ${url}`,
-        error: 'Not Found',
-      });
+    initWA();
 
-      next();
-    },
-  );
-
-  const httpServer = configService.get<HttpServer>('SERVER');
-
-  ServerUP.app = app;
-  const server = ServerUP[httpServer.TYPE];
-
-  server.listen(httpServer.PORT, () => logger.log(httpServer.TYPE.toUpperCase() + ' - ON: ' + httpServer.PORT));
-
-  initWA();
-
-  onUnexpectedError();
+    onUnexpectedError();
 }
 
 bootstrap();

src/whatsapp/abstract/abstract.router.ts

@@ -6,7 +6,7 @@ import { validate } from 'jsonschema';
 
 import { Logger } from '../../config/logger.config';
 import { BadRequestException } from '../../exceptions';
-import { GetParticipant, GroupInvite, GroupJid } from '../dto/group.dto';
+import { GetParticipant, GroupInvite } from '../dto/group.dto';
 import { InstanceDto } from '../dto/instance.dto';
 
 type DataValidate<T> = {
@@ -119,7 +119,7 @@ export abstract class RouterBroker {
     }
 
     Object.assign(body, {
-      groupJid: groupJid
+      groupJid: groupJid,
     });
 
     const ref = new ClassRef();

src/whatsapp/controllers/settings.controller.ts

@@ -12,7 +12,6 @@ export class SettingsController {
   constructor(private readonly settingsService: SettingsService) {}
 
   public async createSettings(instance: InstanceDto, data: SettingsDto) {
-
     logger.verbose('requested createSettings from ' + instance.instanceName + ' instance');
 
     return this.settingsService.create(instance, data);

src/whatsapp/repository/repository.manager.ts

@@ -109,7 +109,6 @@ export class RepositoryBroker {
           this.logger.verbose('creating temp dir: ' + tempDir);
           fs.mkdirSync(tempDir, { recursive: true });
         }
-
       } catch (error) {
         this.logger.error(error);
       }

src/whatsapp/services/chatwoot.service.ts

@@ -940,7 +940,7 @@ export class ChatwootService {
       }
 
       this.logger.verbose('check if is bot');
-      if (!body?.conversation || body.private) return { message: 'bot' };
+      if (!body?.conversation || body.private || body.event === 'message_updated') return { message: 'bot' };
 
       this.logger.verbose('check if is group');
       const chatId =