Add feature flags to disable remaining task router handlers

functions/taskrouterListeners/adjustCapacityListener.private.ts

@@ -49,9 +49,19 @@ export const handleEvent = async (context: Context<EnvVars>, event: EventFields)
   if (taskChannelUniqueName !== 'chat') return;
   const serviceConfig = await context.getTwilioClient().flexApi.configuration.get().fetch();
   const {
-    feature_flags: { enable_manual_pulling: enabledManualPulling },
+    feature_flags: {
+      enable_manual_pulling: enabledManualPulling,
+      use_twilio_lambda_adjust_capacity: useTwilioLambdaAdjustCapacity,
+    },
   } = serviceConfig.attributes;
 
+  if (useTwilioLambdaAdjustCapacity) {
+    console.log(
+      '===== AdjustCapacityListener skipped - use_twilio_lambda_adjust_capacity flag is enabled =====',
+    );
+    return;
+  }
+
   if (enabledManualPulling) {
     const { path } = Runtime.getFunctions().adjustChatCapacity;
 

functions/taskrouterListeners/janitorListener.private.ts

@@ -171,6 +171,16 @@ export const handleEvent = async (context: Context<EnvVars>, event: EventFields)
     } = event;
     const client = context.getTwilioClient();
 
+    const serviceConfig = await client.flexApi.configuration.get().fetch();
+    const { feature_flags: featureFlags } = serviceConfig.attributes;
+
+    if (featureFlags.use_twilio_lambda_janitor) {
+      console.log(
+        '===== JanitorListener skipped - use_twilio_lambda_janitor flag is enabled =====',
+      );
+      return;
+    }
+
     // The janitor is only be executed for chat based tasks
     if (!['chat', 'survey'].includes(taskChannelUniqueName)) return;
 
@@ -228,9 +238,6 @@ export const handleEvent = async (context: Context<EnvVars>, event: EventFields)
       )
     ) {
       // This task has reached a point where the channel should be deactivated, unless post survey is enabled
-      const serviceConfig = await client.flexApi.configuration.get().fetch();
-      const { feature_flags: featureFlags } = serviceConfig.attributes;
-
       if (!featureFlags.enable_post_survey) {
         console.log('Handling DeactivateConversationOrchestration...');
 

functions/taskrouterListeners/transfersListener.private.ts

@@ -166,6 +166,16 @@ export const handleEvent = async (context: Context<EnvVars>, event: EventFields)
 
     console.log(`===== Executing TransfersListener for event: ${eventType} =====`);
 
+    const serviceConfig = await context.getTwilioClient().flexApi.configuration.get().fetch();
+    const { feature_flags: featureFlags } = serviceConfig.attributes;
+
+    if (featureFlags.use_twilio_lambda_transfers) {
+      console.log(
+        '===== TransfersListener skipped - use_twilio_lambda_transfers flag is enabled =====',
+      );
+      return;
+    }
+
     const taskAttributes = JSON.parse(taskAttributesString);
     Object.entries(taskAttributes).forEach(([key, value]) => {
       console.log('Task attribute:', key, value);