pip install agentic-fleet[chainlit]

import chainlit as cl
from agentic_fleet import Agent
from agentic_fleet.integrations.chainlit import ChainlitUI

@cl.on_chat_start
async def start():
    # Initialize agent
    agent = Agent(
        name="assistant",
        model="gpt-4"
    )
    
    # Create UI wrapper
    ui = ChainlitUI(agent)
    
    # Store in user session
    cl.user_session.set("ui", ui)

@cl.on_message
async def main(message: str):
    # Get UI wrapper
    ui = cl.user_session.get("ui")
    
    # Process message
    response = await ui.process_message(message)
    
    # Send response
    await cl.Message(
        content=response.content,
        elements=response.elements
    ).send()

from agentic_fleet.integrations.chainlit import (
    TextElement,
    ImageElement,
    FileElement
)

# Send text with formatting
await ui.send_text("**Bold** and *italic* text")

# Send images
await ui.send_image(
    url="https://example.com/image.png",
    caption="Image caption"
)

# Send files
await ui.send_file(
    file_path="document.pdf",
    name="Document"
)

# Add action buttons
await ui.add_button(
    name="help",
    label="Get Help",
    action=lambda: print("Help clicked")
)

# Add select inputs
options = ["Option 1", "Option 2"]
await ui.add_select(
    name="choice",
    options=options,
    callback=lambda x: print(f"Selected: {x}")
)

# Configure UI theme
ui.set_theme({
    "primary_color": "#0A84FF",
    "font_family": "Inter"
})

# Custom CSS
ui.add_css("""
.message {
    padding: 1rem;
    border-radius: 8px;
}
""")

# Define message templates
ui.set_template(
    "greeting",
    "Hello {name}! How can I help you today?"
)

# Use template
await ui.send_template("greeting", name="User")

# Create multiple agents
agents = {
    "researcher": Agent(name="researcher"),
    "writer": Agent(name="writer")
}

# Initialize UI with multiple agents
ui = ChainlitUI(agents)

# Send message to specific agent
await ui.send_to_agent(
    "research quantum computing",
    agent="researcher"
)

# Show progress
async with ui.show_progress("Processing") as progress:
    # Update progress
    for i in range(5):
        await progress.update(f"Step {i+1}/5")
        await some_task()

from agentic_fleet.exceptions import UIError

try:
    await ui.process_message("Hello")
except UIError as e:
    await ui.show_error(str(e))