🔧 update (logging): remove emoji prefixes from log messages

Author: warengonzaga

src/controllers/webhookController.ts

@@ -17,7 +17,7 @@ export class WebhookController {
     static initializeBackgroundProcessor(): void {
         if (!WebhookController.backgroundProcessor) {
             WebhookController.backgroundProcessor = new WebhookController();
-            LogEngine.log('🔄 Background webhook processor initialized');
+            LogEngine.log('Background webhook processor initialized');
         }
     }
 
@@ -34,7 +34,7 @@ export class WebhookController {
             const { event, eventId } = req.body;
 
             // Log raw incoming webhook data
-            LogEngine.debug(`🌐 RAW WEBHOOK RECEIVED:`, {
+            LogEngine.debug(`RAW WEBHOOK RECEIVED:`, {
                 eventId,
                 completeRawData: req.body
             });
@@ -48,7 +48,7 @@ export class WebhookController {
             // Quick validation only - no heavy processing
             const validationResult = this.webhookService.validateEvent(req.body);
             if (!validationResult.isValid) {
-                LogEngine.error(`❌ Event validation failed:`, validationResult.errors);
+                LogEngine.error(`Event validation failed:`, validationResult.errors);
                 return res.status(400).json({ 
                     error: 'Invalid event structure',
                     details: validationResult.errors 
@@ -71,7 +71,7 @@ export class WebhookController {
             // Queue event for background processing (non-blocking)
             this.queueEventForBackgroundProcessing(req.body, requestId);
 
-            LogEngine.debug(`⚡ Immediate response sent`, {
+            LogEngine.debug(`Immediate response sent`, {
                 eventId,
                 requestId,
                 responseTime: `${responseTime}ms`
@@ -81,7 +81,7 @@ export class WebhookController {
 
         } catch (error) {
             const responseTime = Date.now() - startTime;
-            LogEngine.error(`💥 Error handling webhook: ${error}`);
+            LogEngine.error(`Error handling webhook: ${error}`);
             return res.status(500).json({
                 error: 'Internal server error',
                 responseTime: `${responseTime}ms`,
@@ -106,12 +106,12 @@ export class WebhookController {
                         await this.processEventInBackground(event, requestId);
                     }
                 } catch (error) {
-                    LogEngine.error(`💥 Background processing failed:`, {
+                    LogEngine.error(`Background processing failed:`, {
                         requestId,
                         eventId: event?.eventId,
-                    error: error instanceof Error ? error.message : 'Unknown error'
-                });
-            }
+                        error: error instanceof Error ? error.message : 'Unknown error'
+                    });
+                }
             })();
         });
     }
@@ -123,7 +123,7 @@ export class WebhookController {
         const startTime = Date.now();
 
         try {
-            LogEngine.debug(`🔄 Background processing started`, {
+            LogEngine.debug(`Background processing started`, {
                 eventId: event?.eventId,
                 requestId
             });
@@ -133,15 +133,15 @@ export class WebhookController {
             await this.webhookService.processEvent(event);
 
             const processingTime = Date.now() - startTime;
-            LogEngine.info(`✅ Background processing completed`, {
+            LogEngine.info(`Background processing completed`, {
                 eventId: event?.eventId,
                 requestId,
                 processingTime: `${processingTime}ms`
             });
 
         } catch (error) {
             const processingTime = Date.now() - startTime;
-            LogEngine.error(`💥 Background processing failed:`, {
+            LogEngine.error(`Background processing failed:`, {
                 eventId: event?.eventId,
                 requestId,
                 processingTime: `${processingTime}ms`,

src/services/redisService.ts

@@ -46,15 +46,15 @@ export class RedisService {
             const eventJson = JSON.stringify(event);
 
             // Log the complete transformed event data
-            LogEngine.debug(`⚡ TRANSFORMED WEBHOOK EVENT:`, {
+            LogEngine.debug(`TRANSFORMED WEBHOOK EVENT:`, {
                 eventId: event.data?.eventId || 'unknown',
                 completeTransformedData: event
             });
 
             // Use Redis LIST for FIFO queue (LPUSH + BRPOP pattern)
             const result = await this.client.lPush(queueName, eventJson);
 
-            LogEngine.info(`✅ Event successfully queued: ${event.data?.eventId || 'unknown'} -> ${queueName} (${result} items in queue)`);
+            LogEngine.info(`Event successfully queued: ${event.data?.eventId || 'unknown'} -> ${queueName} (${result} items in queue)`);
             return result;
         } catch (err) {
             LogEngine.error(`Error publishing event to queue: ${err}`);

src/services/webhookService.ts

@@ -58,6 +58,9 @@ export class WebhookService {
         // Atomically claim fingerprint slot (retry with new eventId detection)
         // Uses SET NX to combine check+mark into a single atomic operation
         const fingerprint = this.generateFingerprint(event);
+        if (!fingerprint && event.event !== 'url_verification') {
+            LogEngine.warn(`No fingerprint generated for event ${event.eventId} — falling back to eventId-only dedup`);
+        }
         if (fingerprint) {
             const claimed = await this.redisService.claimFingerprint(fingerprint);
             if (!claimed) {
@@ -103,6 +106,8 @@ export class WebhookService {
         const targetPlatform = config.targetPlatform;
         const attachmentMetadata = this.generateAttachmentMetadata(unthreadEvent);
 
+        const fingerprint = this.generateFingerprint(unthreadEvent);
+
         const message: RedisQueueMessage = {
             platform: "unthread",
             targetPlatform,
@@ -113,7 +118,8 @@ export class WebhookService {
                 originalEvent: unthreadEvent.event,
                 eventId: unthreadEvent.eventId,
                 eventTimestamp: unthreadEvent.eventTimestamp,
-                webhookTimestamp: unthreadEvent.webhookTimestamp
+                webhookTimestamp: unthreadEvent.webhookTimestamp,
+                ...(fingerprint && { fingerprint })
             },
             timestamp: Date.now()
         };