✨ tweak: enhance logging for webhooks

Author: warengonzaga

src/controllers/webhookController.ts

@@ -12,18 +12,22 @@ export class WebhookController {
         try {
             const { event, eventId } = req.body;
 
+            // Log raw incoming webhook data
+            LogEngine.debug(`🌐 RAW WEBHOOK RECEIVED:`, {
+                eventId,
+                completeRawData: req.body
+            });
+
             // Handle URL verification event (required by Unthread)
             if (event === 'url_verification') {
                 LogEngine.debug('URL verification event processed');
                 return res.status(200).json({ message: 'URL verified' });
             }
 
-            // Log event processing for debugging
-            LogEngine.debug(`Processing ${event} event (ID: ${eventId})`);
-
             // Validate the event structure
             const validationResult = this.webhookService.validateEvent(req.body);
             if (!validationResult.isValid) {
+                LogEngine.error(`❌ Event validation failed:`, validationResult.errors);
                 return res.status(400).json({ 
                     error: 'Invalid event structure',
                     details: validationResult.errors 
@@ -39,7 +43,7 @@ export class WebhookController {
                 timestamp: new Date().toISOString()
             });
         } catch (error) {
-            LogEngine.error(`Error handling webhook: ${error}`);
+            LogEngine.error(`💥 Error handling webhook: ${error}`);
             return res.status(500).json({
                 error: 'Internal server error',
                 timestamp: new Date().toISOString()

src/services/redisService.ts

@@ -43,9 +43,18 @@ export class RedisService {
         const queueName = config.unthreadQueueName;
 
         try {
+            const eventJson = JSON.stringify(event);
+            
+            // Log the complete transformed event data
+            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, JSON.stringify(event));
-            LogEngine.debug(`Event queued: ${event.data?.eventId || 'unknown'} -> ${queueName}`);
+            const result = await this.client.lPush(queueName, eventJson);
+            
+            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

@@ -1,6 +1,7 @@
 import { LogEngine } from '@wgtechlabs/log-engine';
 import { RedisService } from './redisService';
 import { config } from '../config/env';
+import { redisEventConfig } from '../config/redis';
 import { 
     UnthreadWebhookEvent, 
     RedisQueueMessage, 
@@ -36,43 +37,15 @@ export class WebhookService {
             return;
         }
 
-        // Detect platform source with enhanced logging
+        // Detect platform source
         const sourcePlatform = this.detectPlatformSource(event);
 
-        // Enhanced audit logging for detection validation
-        if ((event.event === 'message_created' || event.event === 'conversation_updated') && event.data) {
-            if (event.event === 'message_created') {
-                const detectionSummary = [
-                    `Detection: ${sourcePlatform}`,
-                    `Event: ${event.eventId}`,
-                    `Conversation: ${event.data.conversationId}`,
-                    `ConversationUpdates: ${event.data.metadata?.event_payload?.conversationUpdates !== undefined ? 'present' : 'missing'}`,
-                    `BotName: ${event.data.botName}`,
-                    `External: ${event.data.isExternal}`
-                ].join(' | ');
-                
-                LogEngine.info(`Platform detection completed - ${detectionSummary}`);
-            } else if (event.event === 'conversation_updated') {
-                const detectionSummary = [
-                    `Detection: ${sourcePlatform}`,
-                    `Event: ${event.eventId}`,
-                    `Conversation: ${event.data.id}`,
-                    `Type: conversation_updated`,
-                    `Reason: administrative action`
-                ].join(' | ');
-                
-                LogEngine.info(`Platform detection completed - ${detectionSummary}`);
-            }
-        }
-        
         // Transform and queue event
         const transformedEvent = this.transformEvent(event, sourcePlatform);
         await this.redisService.publishEvent(transformedEvent);
 
         // Mark as processed
         await this.redisService.markEventProcessed(event.eventId);
-        
-        LogEngine.debug(`Event processed: ${event.event} (${event.eventId}) from ${sourcePlatform}`);
     }
 
     private transformEvent(unthreadEvent: UnthreadWebhookEvent, sourcePlatform: PlatformSource): RedisQueueMessage {