Decide node

{
  execution_context: {
    vars: {...},           // Workflow variables
    system: {...},         // System data
    context: {...},        // Execution context
    metadata: {...}        // Metadata
  },
  flow_events: [...],      // Recent workflow events (last 10)
  flow_info: {
    id: "flow_abc123",     // Flow ID
    name: "My Flow",       // Flow name
    step_id: "step_xyz"    // Current step ID
  },
  available_edges: [       // Condition labels from your DecideNode
    "premium",
    "standard",
    "trial"
  ],
  whatsapp_context: {      // Only present when triggered by WhatsApp
    conversation: {
      id: "conv_123",
      phone_number: "+1234567890",
      status: "open",
      last_active_at: "2024-01-15T10:30:00Z",
      whatsapp_config_id: "config_abc",
      metadata: {},
      created_at: "2024-01-10T08:00:00Z",
      updated_at: "2024-01-15T10:30:00Z"
    },
    messages: [            // All messages, ordered by created_at (oldest first)
      {
        id: "msg_001",
        message_type: "text",
        content: "Hello!",
        direction: "inbound",
        status: "delivered",
        processing_status: "processed",
        whatsapp_message_id: "wamid_abc",
        origin: "user",
        phone_number: "+1234567890",
        has_media: false,
        created_at: "2024-01-15T10:00:00Z",
        updated_at: "2024-01-15T10:00:00Z"
      }
    ]
  }
}

{
  next_edge: "premium",    // REQUIRED: Must match a condition label
  vars: {                  // OPTIONAL: Updated workflow variables
    customer_tier: "premium",
    discount_applied: true
  }
}

async function handler(request, env) {
  const body = await request.json();
  const availableEdges = body?.available_edges || [];
  const executionContext = body?.execution_context || {};
  const vars = executionContext.vars || {};
  const context = executionContext.context || {};

  // Your custom routing logic - can be anything:

  // 1. Business rules
  const accountAge = vars.account_age_days || 0;
  const totalSpent = vars.lifetime_value || 0;

  // 2. External API check (optional)
  // const res = await fetch(`https://api.example.com/users/${context.phone_number}/tier`);
  // const userTier = await res.json();

  // 3. Time-based logic
  // const hour = new Date().getHours();
  // if (hour < 9 || hour > 17) nextEdge = "closed";

  let nextEdge = availableEdges[0] || "default";

  if (totalSpent > 1000 && accountAge > 365) {
    nextEdge = "premium";
  } else if (accountAge > 30) {
    nextEdge = "standard";
  } else {
    nextEdge = "trial";
  }

  return new Response(JSON.stringify({
    next_edge: nextEdge,
    vars: {
      customer_tier: nextEdge,
      routing_timestamp: new Date().toISOString()
    }
  }), {
    headers: { "Content-Type": "application/json" }
  });
}

async function handler(request, env) {
  const body = await request.json();
  const availableEdges = body?.available_edges || [];
  const whatsappContext = body?.whatsapp_context;

  // Guard: ensure WhatsApp context exists
  if (!whatsappContext) {
    return new Response(JSON.stringify({
      next_edge: availableEdges[0]
    }), { headers: { "Content-Type": "application/json" } });
  }

  const { conversation, messages } = whatsappContext;

  // Get user's phone number
  const userPhone = conversation.phone_number;

  // Get the last message
  const lastMessage = messages[messages.length - 1];
  const lastContent = lastMessage?.content || "";
  const lastDirection = lastMessage?.direction; // "inbound" or "outbound"

  // Count inbound messages
  const userMessages = messages.filter(m => m.direction === "inbound");

  // Check for media
  const hasMedia = messages.some(m => m.has_media);

  // Access interactive reply data
  const lastReplyId = lastMessage?.message_type_data?.reply_option_id;

  // Route based on conversation state
  let nextEdge = "returning_user";
  if (userMessages.length < 2) {
    nextEdge = "new_user";
  }

  return new Response(JSON.stringify({
    next_edge: nextEdge,
    vars: { user_phone: userPhone }
  }), { headers: { "Content-Type": "application/json" } });
}