fix(autoconnect): fixed autoconnect error for conditional block (#215)

* fix(autoconnect): fix bug where autoconnect didn't work for conditional block

* improvement(ui): file upload

* fix twilio block error

* run format

---------

Co-authored-by: Emir Karabeg <emirkarabeg@berkeley.edu>

Author: waleedlatif1

sim/app/api/schedules/execute/route.ts

@@ -320,7 +320,7 @@ export async function GET(req: NextRequest) {
         )
 
         logger.info(`[${requestId}] Executing workflow ${schedule.workflowId}`)
-        
+
         // Get workflow variables
         let workflowVariables = {}
         if (workflowRecord.variables) {
@@ -332,15 +332,20 @@ export async function GET(req: NextRequest) {
               // Otherwise use as is (already parsed JSON)
               workflowVariables = workflowRecord.variables
             }
-            logger.debug(`[${requestId}] Loaded ${Object.keys(workflowVariables).length} workflow variables for: ${schedule.workflowId}`)
+            logger.debug(
+              `[${requestId}] Loaded ${Object.keys(workflowVariables).length} workflow variables for: ${schedule.workflowId}`
+            )
           } catch (error) {
-            logger.error(`[${requestId}] Failed to parse workflow variables: ${schedule.workflowId}`, error)
+            logger.error(
+              `[${requestId}] Failed to parse workflow variables: ${schedule.workflowId}`,
+              error
+            )
             // Continue execution even if variables can't be parsed
           }
         } else {
           logger.debug(`[${requestId}] No workflow variables found for: ${schedule.workflowId}`)
         }
-        
+
         const executor = new Executor(
           serializedWorkflow,
           processedBlockStates, // Use the processed block states

sim/app/api/webhooks/trigger/[path]/route.ts

@@ -631,9 +631,14 @@ async function processWebhook(
           // Otherwise use as is (already parsed JSON)
           workflowVariables = foundWorkflow.variables
         }
-        logger.debug(`[${requestId}] Loaded ${Object.keys(workflowVariables).length} workflow variables for: ${foundWorkflow.id}`)
+        logger.debug(
+          `[${requestId}] Loaded ${Object.keys(workflowVariables).length} workflow variables for: ${foundWorkflow.id}`
+        )
       } catch (error) {
-        logger.error(`[${requestId}] Failed to parse workflow variables: ${foundWorkflow.id}`, error)
+        logger.error(
+          `[${requestId}] Failed to parse workflow variables: ${foundWorkflow.id}`,
+          error
+        )
         // Continue execution even if variables can't be parsed
       }
     } else {

sim/app/api/workflows/[id]/execute/route.test.ts

@@ -260,15 +260,16 @@ describe('Workflow Execution API Route', () => {
 
     // Verify execute was called with the input body
     expect(executeMock).toHaveBeenCalledWith('workflow-id')
-    
+
     // Updated expectations to match actual implementation
     // The structure should match: serializedWorkflow, processedBlockStates, decryptedEnvVars, processedInput, workflowVariables
     expect(Executor).toHaveBeenCalledWith(
       expect.anything(), // serializedWorkflow
       expect.anything(), // processedBlockStates
       expect.anything(), // decryptedEnvVars
-      expect.objectContaining({ // processedInput
-        input: requestBody
+      expect.objectContaining({
+        // processedInput
+        input: requestBody,
       }),
       expect.anything() // workflowVariables
     )
@@ -313,8 +314,9 @@ describe('Workflow Execution API Route', () => {
       expect.anything(), // serializedWorkflow
       expect.anything(), // processedBlockStates
       expect.anything(), // decryptedEnvVars
-      expect.objectContaining({ // processedInput
-        input: structuredInput
+      expect.objectContaining({
+        // processedInput
+        input: structuredInput,
       }),
       expect.anything() // workflowVariables
     )
@@ -463,8 +465,8 @@ describe('Workflow Execution API Route', () => {
   it('should pass workflow variables to the Executor', async () => {
     // Create mock variables for the workflow
     const workflowVariables = {
-      'variable1': { id: 'var1', name: 'variable1', type: 'string', value: '"test value"' },
-      'variable2': { id: 'var2', name: 'variable2', type: 'boolean', value: 'true' }
+      variable1: { id: 'var1', name: 'variable1', type: 'string', value: '"test value"' },
+      variable2: { id: 'var2', name: 'variable2', type: 'boolean', value: 'true' },
     }
 
     // Mock workflow with variables
@@ -539,15 +541,15 @@ describe('Workflow Execution API Route', () => {
 
     // Verify the Executor was constructed with workflow variables
     expect(executorConstructorMock).toHaveBeenCalled()
-    
+
     // Check that the 5th parameter (workflow variables) was passed
     const executorCalls = executorConstructorMock.mock.calls
     expect(executorCalls.length).toBeGreaterThan(0)
-    
+
     // Each call to the constructor should have at least 5 parameters
     const lastCall = executorCalls[executorCalls.length - 1]
     expect(lastCall.length).toBeGreaterThanOrEqual(5)
-    
+
     // The 5th parameter should be the workflow variables
     expect(lastCall[4]).toEqual(workflowVariables)
   })

sim/app/api/workflows/[id]/execute/route.ts

@@ -38,17 +38,22 @@ async function executeWorkflow(workflow: any, requestId: string, input?: any) {
   }
 
   // Log input to help debug
-  logger.info(`[${requestId}] Executing workflow with input:`, 
-    input ? JSON.stringify(input, null, 2) : 'No input provided');
-  
+  logger.info(
+    `[${requestId}] Executing workflow with input:`,
+    input ? JSON.stringify(input, null, 2) : 'No input provided'
+  )
+
   // Validate and structure input for maximum compatibility
-  let processedInput = input;
+  let processedInput = input
   if (input && typeof input === 'object') {
     // Ensure input is properly structured for the starter block
     if (input.input === undefined) {
       // If input is not already nested, structure it properly
-      processedInput = { input: input };
-      logger.info(`[${requestId}] Restructured input for workflow:`, JSON.stringify(processedInput, null, 2));
+      processedInput = { input: input }
+      logger.info(
+        `[${requestId}] Restructured input for workflow:`,
+        JSON.stringify(processedInput, null, 2)
+      )
     }
   }
 
@@ -174,7 +179,9 @@ async function executeWorkflow(workflow: any, requestId: string, input?: any) {
           // Otherwise use as is (already parsed JSON)
           workflowVariables = workflow.variables
         }
-        logger.debug(`[${requestId}] Loaded ${Object.keys(workflowVariables).length} workflow variables for: ${workflowId}`)
+        logger.debug(
+          `[${requestId}] Loaded ${Object.keys(workflowVariables).length} workflow variables for: ${workflowId}`
+        )
       } catch (error) {
         logger.error(`[${requestId}] Failed to parse workflow variables: ${workflowId}`, error)
         // Continue execution even if variables can't be parsed
@@ -188,13 +195,13 @@ async function executeWorkflow(workflow: any, requestId: string, input?: any) {
     const serializedWorkflow = new Serializer().serializeWorkflow(mergedStates, edges, loops)
 
     const executor = new Executor(
-      serializedWorkflow, 
-      processedBlockStates, 
-      decryptedEnvVars, 
-      processedInput, 
+      serializedWorkflow,
+      processedBlockStates,
+      decryptedEnvVars,
+      processedInput,
       workflowVariables
     )
-    
+
     const result = await executor.execute(workflowId)
 
     logger.info(`[${requestId}] Workflow execution completed: ${workflowId}`, {
@@ -278,7 +285,7 @@ export async function POST(request: NextRequest, { params }: { params: Promise<{
 
     const bodyText = await request.text()
     logger.info(`[${requestId}] Raw request body:`, bodyText)
-    
+
     let body = {}
     if (bodyText && bodyText.trim()) {
       try {
@@ -293,9 +300,9 @@ export async function POST(request: NextRequest, { params }: { params: Promise<{
     }
 
     // Don't double-nest the input if it's already structured
-    const hasContent = Object.keys(body).length > 0;
-    const input = hasContent ? { input: body } : {};
-    
+    const hasContent = Object.keys(body).length > 0
+    const input = hasContent ? { input: body } : {}
+
     logger.info(`[${requestId}] Input passed to workflow:`, JSON.stringify(input, null, 2))
 
     // Execute workflow with the structured input

sim/app/w/[id]/components/workflow-block/components/sub-block/hooks/use-sub-block-value.ts

@@ -1,12 +1,12 @@
 import { useCallback, useEffect, useRef } from 'react'
+import { isEqual } from 'lodash'
 import { useSubBlockStore } from '@/stores/workflows/subblock/store'
 import { useWorkflowStore } from '@/stores/workflows/workflow/store'
-import { isEqual } from 'lodash'
 
 /**
  * Custom hook to get and set values for a sub-block in a workflow.
  * Handles complex object values properly by using deep equality comparison.
- * 
+ *
  * @param blockId The ID of the block containing the sub-block
  * @param subBlockId The ID of the sub-block
  * @param triggerWorkflowUpdate Whether to trigger a workflow update when the value changes
@@ -30,10 +30,7 @@ export function useSubBlockValue<T = any>(
 
   // Get value from subblock store
   const storeValue = useSubBlockStore(
-    useCallback(
-      (state) => state.getValue(blockId, subBlockId),
-      [blockId, subBlockId]
-    )
+    useCallback((state) => state.getValue(blockId, subBlockId), [blockId, subBlockId])
   )
 
   // Update the ref if the store value changes
@@ -51,16 +48,19 @@ export function useSubBlockValue<T = any>(
       // Use deep comparison to avoid unnecessary updates for complex objects
       if (!isEqual(valueRef.current, newValue)) {
         valueRef.current = newValue
-        
+
         // Ensure we're passing the actual value, not a reference that might change
-        const valueCopy = newValue === null 
-          ? null 
-          : (typeof newValue === 'object' ? JSON.parse(JSON.stringify(newValue)) : newValue)
-        
+        const valueCopy =
+          newValue === null
+            ? null
+            : typeof newValue === 'object'
+              ? JSON.parse(JSON.stringify(newValue))
+              : newValue
+
         // Update the subblock store with the new value
         // The store's setValue method will now trigger the debounced sync automatically
         useSubBlockStore.getState().setValue(blockId, subBlockId, valueCopy)
-        
+
         if (triggerWorkflowUpdate) {
           useWorkflowStore.getState().triggerUpdate()
         }