from kapso.builder.flows import Flow
from kapso.builder.flows.nodes import StartNode, SendTextNode, WaitForResponseNode, DecideNode, AgentNode
from kapso.builder.flows.nodes.agent import FlowAgentWebhook
from kapso.builder.flows.nodes.decide import Condition
from kapso.builder.ai.field import AIField
# Create flow
flow = Flow(name="customer_support")
# Add nodes
start = StartNode(id="start_1234")
greeting = SendTextNode(
id="greeting_5678",
message=AIField("Greet the customer and ask how you can help"),
provider_model_name="claude-sonnet-4-20250514"
)
wait = WaitForResponseNode(
id="wait_9012"
)
decide = DecideNode(
id="decide_3456",
decision_type="ai", # or "function" to use a custom Kapso Function
provider_model_name="claude-sonnet-4-20250514",
conditions=[
Condition(label="order_help", description="Customer needs help with orders, shipping, returns"),
Condition(label="tech_support", description="Technical issues, account problems, app troubleshooting")
]
)
# Order specialist agent with e-commerce tools
order_expert = AgentNode(
id="order_expert_7890",
system_prompt="You are an order specialist. Help customers with orders, shipping, returns, and payment issues. Use tools to check order status and process changes.",
provider_model_name="claude-sonnet-4-20250514",
temperature=0.1,
max_iterations=10,
webhooks=[
FlowAgentWebhook(
name="check_order",
url="https://api.store.com/orders/{{order_id}}",
http_method="GET",
description="Get order status and details by order ID"
),
FlowAgentWebhook(
name="update_shipping",
url="https://api.store.com/orders/{{order_id}}/shipping",
http_method="PUT",
description="Update shipping address or method"
)
]
)
# Technical support agent with diagnostic tools
tech_expert = AgentNode(
id="tech_expert_1234",
system_prompt="You are a technical support specialist. Help customers with app issues, account problems, and technical troubleshooting. Use tools to check account status and system diagnostics.",
provider_model_name="claude-sonnet-4-20250514",
temperature=0.1,
max_iterations=8,
webhooks=[
FlowAgentWebhook(
name="check_account",
url="https://api.store.com/users/{{phone_number}}/account",
http_method="GET",
description="Get customer account status and details"
),
FlowAgentWebhook(
name="system_status",
url="https://api.store.com/system/status",
http_method="GET",
description="Check system status and known issues"
)
]
)
flow.add_node(start)
flow.add_node(greeting)
flow.add_node(wait)
flow.add_node(decide)
flow.add_node(order_expert)
flow.add_node(tech_expert)
# Connect nodes
flow.add_edge("start_1234", "greeting_5678")
flow.add_edge("greeting_5678", "wait_9012")
flow.add_edge("wait_9012", "decide_3456")
flow.add_edge("decide_3456", "order_expert_7890", label="order_help")
flow.add_edge("decide_3456", "tech_expert_1234", label="tech_support")
flow.validate()
