add webhook fallback and fix debug messages

Author: harshitha-cstk

src/core/index.ts

@@ -263,6 +263,7 @@ export const unlock = (refire?: boolean) => {
     }
   }
   check()
+  return Promise.resolve()
 }
 
 /**

src/index.ts

@@ -227,7 +227,10 @@ export const start = (config: IConfig = {}): Promise<{}> => {
         pinger()
 
         return listener.start(appConfig)
-      }).then(() => {
+      }).then((webhookServer) => {
+        // Set up webhook listener monitoring and fallback mechanism
+        setupWebhookMonitoring(webhookServer)
+        
         logger.info(MESSAGES.INDEX.SYNC_UTILITY_STARTED)
 
         return resolve('')
@@ -255,3 +258,74 @@ notifications
 .on('unpublish', debugNotifications('unpublish'))
 .on('delete', debugNotifications('delete'))
 .on('error', debugNotifications('error'))
+
+/**
+ * Set up webhook listener monitoring and fallback polling mechanism
+ * @param {object} webhookServer The webhook server instance
+ */
+function setupWebhookMonitoring(webhookServer) {
+  const FALLBACK_POLL_INTERVAL = 60000 // 1 minute fallback polling
+  let fallbackTimer: NodeJS.Timeout | null = null
+  let webhookHealthy = true
+  
+  debug('Webhook monitoring initialized. Server:', !!webhookServer, 'Healthy:', webhookHealthy)
+  
+  
+  // Start fallback polling when webhook is unhealthy
+  const startFallbackPolling = () => {
+    if (fallbackTimer) return // Already running
+    
+    logger.info(`Starting fallback polling every ${FALLBACK_POLL_INTERVAL}ms`)
+    fallbackTimer = setInterval(() => {
+      debug('Fallback polling: triggering sync check')
+      try {
+        poke().catch((error) => {
+          debug('Fallback polling error:', error)
+        })
+      } catch (error) {
+        debug('Fallback polling exception:', error)
+      }
+    }, FALLBACK_POLL_INTERVAL)
+  }
+  
+  // Stop fallback polling when webhook is healthy
+  const stopFallbackPolling = () => {
+    if (fallbackTimer) {
+      clearInterval(fallbackTimer)
+      fallbackTimer = null
+      logger.info('Fallback polling stopped')
+    }
+  }
+  
+  // Webhook activity is tracked via events, no need to wrap poke function
+  
+  
+  // Handle process cleanup
+  const cleanup = () => {
+    if (fallbackTimer) {
+      clearInterval(fallbackTimer)
+      fallbackTimer = null
+    }
+  }
+  
+  process.on('SIGINT', cleanup)
+  process.on('SIGTERM', cleanup)
+  process.on('exit', cleanup)
+  
+  // Handle webhook server events if available
+  if (listener.getEventEmitter) {
+    const webhookEmitter = listener.getEventEmitter()
+    
+    webhookEmitter.on('server-error', (error) => {
+      logger.warn('Webhook server error detected:', error.message)
+      webhookHealthy = false
+      startFallbackPolling()
+    })
+    
+    webhookEmitter.on('reconnect-success', () => {
+      logger.info('Webhook server reconnected successfully')
+      webhookHealthy = true
+      stopFallbackPolling()
+    })
+  }
+}

src/util/messages.ts

@@ -79,10 +79,10 @@ export const MESSAGES = {
     FIRE_CALLED: (req: any) => `Fire operation triggered with: ${JSON.stringify(req)}`,
     FIRE_COMPLETE: (itemCount: number) => `Fire operation completed. Items received: ${itemCount}.`,
     API_CALL_CT: (uid: string) => `API call initiated for content type: ${uid}.`,
-    ERROR_MAP: 'Error [map]: Failed to fetch content type schema.',
-    ERROR_MAP_RESOLVE: 'Error [mapResolve]: Unable to resolve mapping.',
-    ERROR_FILTER_ITEMS: 'Error [filterItems]: Unable to filter items.',
-    ERROR_FIRE: 'Error during fire operation.',
+    ERROR_MAP: 'Debug [map]: Content type schema fetch failed.',
+    ERROR_MAP_RESOLVE: 'Debug [mapResolve]: Mapping resolution failed.',
+    ERROR_FILTER_ITEMS: 'Debug [filterItems]: Item filtering failed.',
+    ERROR_FIRE: 'Debug [fire]: Fire operation encountered error.',
     REFIRE_CALLED: (req: any) => `Re-fire operation triggered with: ${JSON.stringify(req)}`,
     CHECKPOINT_LOCKDOWN: 'Checkpoint: lockdown has been invoked',
   },