fix: preserve animation in GIF and WebP stickers

Author: matheusmartinsInsper

src/api/integrations/channel/whatsapp/whatsapp.baileys.service.ts

@@ -2348,16 +2348,13 @@ export class BaileysStartupService extends ChannelStartupService {
         imageBuffer = Buffer.from(response.data, 'binary');
       }
 
-       const isAnimated = image.includes('.gif') || 
-                          (image.includes('.webp') && this.isAnimatedWebp(imageBuffer));
-       
-       if (isAnimated) {
-         return await sharp(imageBuffer, { animated: true })
-           .webp({ quality: 80, animated: true })
-           .toBuffer();
-       } else {
-         return await sharp(imageBuffer).webp().toBuffer();
-       }
+      const isAnimated = this.isAnimated(image, imageBuffer);
+
+      if (isAnimated) {
+        return await sharp(imageBuffer, { animated: true }).webp({ quality: 80, animated: true }).toBuffer();
+      } else {
+        return await sharp(imageBuffer).webp().toBuffer();
+      }
     } catch (error) {
       console.error('Erro ao converter a imagem para WebP:', error);
       throw error;
@@ -2366,15 +2363,14 @@ export class BaileysStartupService extends ChannelStartupService {
 
   private isAnimatedWebp(buffer: Buffer): boolean {
     if (buffer.length < 12) return false;
-    
-    for (let i = 0; i < buffer.length - 4; i++) {
-      if (buffer[i] === 0x41 && // 'A'
-          buffer[i + 1] === 0x4E && // 'N'
-          buffer[i + 2] === 0x49 && // 'I'
-          buffer[i + 3] === 0x4D) { // 'M'
-        return true;
-      }
-    }
+
+    return buffer.indexOf(Buffer.from('ANIM')) !== -1;
+  }
+
+  private isAnimated(image: string, buffer: Buffer): boolean {
+    if (image.includes('.gif')) return true;
+
+    if (image.includes('.webp')) return this.isAnimatedWebp(buffer);
     return false;
   }
 

src/api/integrations/event/websocket/websocket.controller.ts

@@ -25,39 +25,39 @@ export class WebsocketController extends EventController implements EventControl
 
     this.socket = new SocketIO(httpServer, {
       cors: { origin: this.cors },
-       allowRequest: async (req, callback) => {
-         try {
-           const url = new URL(req.url || '', 'http://localhost');
-           const params = new URLSearchParams(url.search);
- 
-           // Permite conexões internas do Socket.IO (EIO=4 é o Engine.IO v4)
-           if (params.has('EIO')) {
-             return callback(null, true);
-           }
- 
-           const apiKey = params.get('apikey') || (req.headers.apikey as string);
- 
-           if (!apiKey) {
-             this.logger.error('Connection rejected: apiKey not provided');
-             return callback('apiKey is required', false);
-           }
- 
-           const instance = await this.prismaRepository.instance.findFirst({ where: { token: apiKey } });
- 
-           if (!instance) {
-             const globalToken = configService.get<Auth>('AUTHENTICATION').API_KEY.KEY;
-             if (apiKey !== globalToken) {
-               this.logger.error('Connection rejected: invalid global token');
-               return callback('Invalid global token', false);
-             }
-           }
- 
-           callback(null, true);
-         } catch (error) {
-           this.logger.error('Authentication error:');
-           this.logger.error(error);
-           callback('Authentication error', false);
-         }
+      allowRequest: async (req, callback) => {
+        try {
+          const url = new URL(req.url || '', 'http://localhost');
+          const params = new URLSearchParams(url.search);
+
+          // Permite conexões internas do Socket.IO (EIO=4 é o Engine.IO v4)
+          if (params.has('EIO')) {
+            return callback(null, true);
+          }
+
+          const apiKey = params.get('apikey') || (req.headers.apikey as string);
+
+          if (!apiKey) {
+            this.logger.error('Connection rejected: apiKey not provided');
+            return callback('apiKey is required', false);
+          }
+
+          const instance = await this.prismaRepository.instance.findFirst({ where: { token: apiKey } });
+
+          if (!instance) {
+            const globalToken = configService.get<Auth>('AUTHENTICATION').API_KEY.KEY;
+            if (apiKey !== globalToken) {
+              this.logger.error('Connection rejected: invalid global token');
+              return callback('Invalid global token', false);
+            }
+          }
+
+          callback(null, true);
+        } catch (error) {
+          this.logger.error('Authentication error:');
+          this.logger.error(error);
+          callback('Authentication error', false);
+        }
       },
     });