# Python client
pip install nornweave-client

from nornweave_client import NornWeave

# Sync client
client = NornWeave(base_url="http://localhost:8000")

# Or async client
from nornweave_client import AsyncNornWeave
client = AsyncNornWeave(base_url="http://localhost:8000")

# Create inbox with username and display name
inbox = client.inboxes.create(
    name="Support",
    email_username="support"
)
# Result: support@yourdomain.com

# List all inboxes (paginated)
for inbox in client.inboxes.list():
    print(inbox.email_address)

# Get inbox by ID
inbox = client.inboxes.get(inbox_id="inbox-uuid")

# Delete inbox
client.inboxes.delete(inbox_id="inbox-uuid")

# Create inbox
inbox = await client.inboxes.create(
    name="Support",
    email_username="support"
)

# List inboxes with async iteration
async for inbox in client.inboxes.list():
    print(inbox.email_address)

# Get and delete
inbox = await client.inboxes.get(inbox_id="inbox-uuid")
await client.inboxes.delete(inbox_id="inbox-uuid")

# Send message (body is Markdown)
response = client.messages.send(
    inbox_id="inbox-uuid",
    to=["recipient@example.com"],
    subject="Hello from my AI agent",
    body="# Welcome\n\nThis is a **markdown** email."
)
print(f"Message ID: {response.id}, Status: {response.status}")

# Reply to existing thread
response = client.messages.send(
    inbox_id="inbox-uuid",
    to=["recipient@example.com"],
    subject="Re: Hello",
    body="Thanks for your message!",
    reply_to_thread_id="thread-uuid"
)

# List messages for an inbox (paginated)
for message in client.messages.list(inbox_id="inbox-uuid"):
    print(f"[{message.direction}] {message.content_clean[:100]}")

# Get single message by ID
message = client.messages.get(message_id="message-uuid")
print(message.content_clean)  # LLM-ready markdown content

# Send message
response = await client.messages.send(
    inbox_id="inbox-uuid",
    to=["recipient@example.com"],
    subject="Hello",
    body="Message content in **Markdown**"
)

# List messages
async for message in client.messages.list(inbox_id="inbox-uuid"):
    print(message.content_clean)

# List threads for an inbox (sorted by most recent activity)
for thread in client.threads.list(inbox_id="inbox-uuid"):
    print(f"{thread.subject} - Last activity: {thread.last_message_at}")

# Get thread with full conversation history (LLM-ready format)
thread = client.threads.get(thread_id="thread-uuid")
print(f"Subject: {thread.subject}")

# Messages are formatted for LLM context
for msg in thread.messages:
    print(f"[{msg.role}] {msg.author}: {msg.content}")
    # role is "user" for inbound, "assistant" for outbound

{
    "id": "thread-uuid",
    "subject": "Question about my account",
    "messages": [
        {
            "role": "user",          # Inbound messages
            "author": "customer@example.com",
            "content": "# My Question\n\nI need help with...",  # Markdown
            "timestamp": "2026-01-15T10:30:00Z"
        },
        {
            "role": "assistant",     # Outbound messages
            "author": "support@yourdomain.com",
            "content": "Thank you for reaching out...",
            "timestamp": "2026-01-15T10:45:00Z"
        }
    ]
}

# List threads
async for thread in client.threads.list(inbox_id="inbox-uuid"):
    print(thread.subject)

# Get thread with messages
thread = await client.threads.get(thread_id="thread-uuid")

# Search messages (returns paginated results)
for result in client.search.query(
    inbox_id="inbox-uuid",
    query="password reset"
):
    print(f"Thread: {result.thread_id}")
    print(f"Content: {result.content_clean[:200]}")

# Get full search response with count
response = client.search.query_raw(
    inbox_id="inbox-uuid",
    query="invoice",
    limit=10
)
print(f"Found {response.count} messages")
for item in response.items:
    print(item.content_clean)

# Search with async iteration
async for result in client.search.query(
    inbox_id="inbox-uuid",
    query="urgent"
):
    print(result.content_clean)

# Get full response
response = await client.search.query_raw(
    inbox_id="inbox-uuid",
    query="billing"
)

# Check API health
health = client.health()
print(health.status)  # "ok"

# Sync
with NornWeave(base_url="http://localhost:8000") as client:
    inbox = client.inboxes.create(name="Test", email_username="test")

# Async
async with AsyncNornWeave(base_url="http://localhost:8000") as client:
    inbox = await client.inboxes.create(name="Test", email_username="test")

# Manual pagination
pager = client.inboxes.list(limit=10, offset=0)
first_page = list(pager)

# Or iterate through all pages automatically
for inbox in client.inboxes.list(limit=10):
    print(inbox.email_address)

from nornweave_client import NornWeaveError, NotFoundError, ConflictError

try:
    inbox = client.inboxes.get(inbox_id="nonexistent")
except NotFoundError as e:
    print(f"Inbox not found: {e}")
except ConflictError as e:
    print(f"Conflict: {e}")
except NornWeaveError as e:
    print(f"API error: {e}")