✨ tweak: update redis image and config

Author: warengonzaga

docker-compose.yml

@@ -14,19 +14,17 @@
 #
 # Prerequisites: 
 #   - Copy .env.example to .env and configure your tokens
-#   - Ensure external network exists: docker network create unthread-integration-network
 #
 # =============================================================================
 
-version: '3.8'
-
 services:
   # =============================================================================
   # REDIS - WEBHOOK OPERATIONS
   # =============================================================================
   # Dedicated Redis instance for webhook message queuing and communication
   redis-webhook:
-    image: redis:7-alpine
+    image: redis:8-alpine
+    container_name: redis-webhook
     ports:
       - "6379:6379"
     volumes:
@@ -35,25 +33,24 @@ services:
     healthcheck:
       test: ["CMD", "redis-cli", "ping"]
       interval: 30s
-      timeout: 3s
+      timeout: 10s
       retries: 3
-      start_period: 30s
-    networks:
-      - unthread-integration-network
+      start_period: 40s
+    command: redis-server --appendonly yes
 
   # =============================================================================
   # WEBHOOK SERVER APPLICATION
   # =============================================================================
   # Handles incoming webhooks from Unthread and processes them
   webhook-server:
-    image: wgtechlabs/unthread-webhook-server:latest
-    container_name: docker-unthread-webhook-server
+    build: .  # Build from local Dockerfile to use current codebase
+    image: unthread-webhook-server:local  # Custom image name for local builds
+    # image: wgtechlabs/unthread-webhook-server:latest  # Uncomment to use Docker Hub image
+    container_name: unthread-webhook-server
     ports:
       - "3000:3000"
     env_file:
       - .env
-    environment:
-      - REDIS_URL=redis://redis-webhook:6379
     depends_on:
       redis-webhook:
         condition: service_healthy
@@ -64,21 +61,10 @@ services:
       timeout: 10s
       retries: 3
       start_period: 40s
-    networks:
-      - unthread-integration-network
 
 # =============================================================================
 # PERSISTENT VOLUMES
 # =============================================================================
 # Named volumes for data persistence across container restarts
 volumes:
   redis_webhook_data:    # Redis webhook queue data
-
-# =============================================================================
-# NETWORKING
-# =============================================================================
-# External network for communication between services
-# Create with: docker network create unthread-integration-network
-networks:
-  unthread-integration-network:
-    external: true

src/services/webhookService.ts

@@ -58,6 +58,12 @@ export class WebhookService {
         // Detect platform source (enhanced with file attachment correlation)
         const sourcePlatform = this.detectPlatformSource(event);
 
+        LogEngine.debug(`Platform source detected: ${sourcePlatform}`, {
+            eventId: event.eventId,
+            eventType: event.event,
+            hasFiles: this.fileAttachmentCorrelation.hasFileAttachments(event)
+        });
+        
         // Handle buffered events - they will be processed later via callback
         if (sourcePlatform === 'buffered') {
             // Mark buffered events as processed to prevent duplicate buffering on retries
@@ -219,6 +225,16 @@ export class WebhookService {
             }
         }
 
+        // TERTIARY DETECTION: isExternal flag (additional indicator for file attachments)
+        if (event.data?.isExternal === true) {
+            LogEngine.debug(`Platform detected via isExternal flag: dashboard (${event.eventId})`);
+            return 'dashboard';
+        } else if (event.data?.isExternal === false && event.data?.sourceType) {
+            // isExternal: false usually indicates platform -> dashboard direction
+            LogEngine.debug(`Platform detected via isExternal flag: ${config.targetPlatform} (${event.eventId})`);
+            return config.targetPlatform;
+        }
+
         // FALLBACK: Unknown if no reliable indicators found
         LogEngine.warn(`Unable to detect platform source for event ${event.eventId} - insufficient indicators`);
         return 'unknown';
@@ -264,21 +280,21 @@ export class WebhookService {
      */
     private async continueEventProcessing(event: UnthreadWebhookEvent, sourcePlatform: string): Promise<void> {
         try {
-            LogEngine.info('Processing buffered file attachment event', {
+            LogEngine.info('Processing webhook event', {
                 eventId: event.eventId,
                 sourcePlatform,
-                correlationSuccess: sourcePlatform !== 'unknown'
+                hasFiles: this.fileAttachmentCorrelation.hasFileAttachments(event)
             });
 
-            // Transform and queue the event with the correlated source platform
+            // Transform and queue the event with the detected/correlated source platform
             const transformedEvent = this.transformEvent(event, sourcePlatform);
             await this.redisService.publishEvent(transformedEvent);
 
             // Mark as processed
             await this.redisService.markEventProcessed(event.eventId);
 
         } catch (error) {
-            LogEngine.error('Failed to process buffered file attachment event', {
+            LogEngine.error('Failed to process webhook event', {
                 eventId: event.eventId,
                 sourcePlatform,
                 error: error instanceof Error ? error.message : 'Unknown error'

src/utils/fileAttachmentCorrelation.ts

@@ -150,7 +150,7 @@ export class FileAttachmentCorrelationUtil {
       return correlationData.sourcePlatform;
     }
 
-    // No correlation found - buffer the file event
+    // No correlation found - buffer the event and wait
     this.bufferFileEvent(event, correlationKey);
     return 'buffered';
   }