State Management

class DataCollectionAgent(OutputCrewNode):
    def __init__(self):
        super().__init__(name="data-agent")
        
        # Session state
        self.customer_name = None
        self.email = None
        self.phone = None
        self.order_id = None
    @function_tool()
    def save_customer_info(
        self,
        name: str = None,
        email: str = None,
        phone: str = None
    ) -> dict:
        """Save customer information."""
        if name:
            self.customer_name = name
        if email:
            self.email = email
        if phone:
            self.phone = phone
        
        return {"saved": True, "collected": self._get_collected()}
    
    def _get_collected(self) -> dict:
        return {
            "name": self.customer_name,
            "email": self.email,
            "phone": self.phone
        }

async def start(self, init_event, task_manager):
    await super().start(init_event, task_manager)
    
    ctx = init_event.session_context
    
    # Access initial variables
    self.customer_id = ctx.initial_variables.get("customer_id")
    self.account_tier = ctx.initial_variables.get("tier")
    self.language = ctx.initial_variables.get("language", "en")
    
    # Use them to customize behavior
    if self.account_tier == "premium":
        self.context.add_message({
            "role": "system",
            "content": "This is a premium customer. Prioritize their requests."
        })

class MyAgent(OutputCrewNode):
    async def generate_response(self):
        # Access full message history
        all_messages = self.context.messages
        
        # Get the last user message
        user_messages = [m for m in all_messages if m["role"] == "user"]
        last_user = user_messages[-1]["content"] if user_messages else ""
        
        # Count turns
        user_turns = sum(1 for m in all_messages if m["role"] == "user")

class IntakeAgent(OutputCrewNode):
    def __init__(self):
        super().__init__(name="intake-agent")
        
        self.collected = {}
        self.tool_registry = ToolRegistry()
        self.tool_registry.discover(self)
        self.tool_schemas = self.tool_registry.get_schemas()
    @function_tool()
    def record_information(
        self,
        field: str,
        value: str
    ) -> dict:
        """
        Record a piece of information from the conversation.
        
        Args:
            field: The type of information (name, email, phone, etc.)
            value: The value to record
        """
        self.collected[field] = value
        
        return {
            "recorded": f"{field}: {value}",
            "remaining": self._get_remaining_fields()
        }
    
    def _get_remaining_fields(self):
        required = ["name", "email", "reason"]
        return [f for f in required if f not in self.collected]

class ProgressAgent(OutputCrewNode):
    def __init__(self):
        super().__init__(name="progress-agent")
        self.turn_count = 0
        self.started_at = None
    async def start(self, init_event, task_manager):
        await super().start(init_event, task_manager)
        self.started_at = datetime.now()
    async def generate_response(self):
        self.turn_count += 1
        
        # Different behavior based on turn count
        if self.turn_count == 1:
            yield "Welcome! This is our first exchange."
        elif self.turn_count > 10:
            yield "We've been chatting for a while. "
            yield "Is there anything else I can help with?"

class RouterNode(Node):
    async def process_event(self, event):
        # Store routing decision in event metadata
        event.metadata["routed_to"] = "sales"
        await self.send_event(event)
class SalesAgent(OutputCrewNode):
    async def process_event(self, event):
        # Read state from event
        if event.metadata.get("routed_to") == "sales":
            await super().process_event(event)

import redis
class PersistentAgent(OutputCrewNode):
    def __init__(self):
        super().__init__(name="persistent-agent")
        self.redis = redis.Redis()
    async def start(self, init_event, task_manager):
        await super().start(init_event, task_manager)
        
        phone = init_event.session_context.initial_variables.get("phone")
        
        # Load previous state
        stored = self.redis.get(f"user:{phone}")
        if stored:
            self.user_data = json.loads(stored)
        else:
            self.user_data = {}
    async def stop(self):
        # Save state before session ends
        phone = self.init_event.session_context.initial_variables.get("phone")
        self.redis.set(f"user:{phone}", json.dumps(self.user_data))
        await super().stop()

class ValidationAgent(OutputCrewNode):
    def __init__(self):
        super().__init__(name="validation-agent")
        self.data = {}
    @function_tool()
    def submit_form(self) -> dict:
        """Submit the collected information."""
        errors = []
        
        if not self.data.get("name"):
            errors.append("Name is required")
        
        if not self.data.get("email"):
            errors.append("Email is required")
        elif "@" not in self.data["email"]:
            errors.append("Email format is invalid")
        
        if errors:
            return {"success": False, "errors": errors}
        
        return {"success": True, "data": self.data}