Multi-Channel Support

┌─────────────────────────────────────────────────────────────────────┐
│                         ChannelManager                              │
│                                                                     │
│   ┌──────────────┐   ┌─────────────┐   ┌─────────────┐             │
│   │ ReplChannel  │   │ HttpChannel │   │ WasmChannel │   ...       │
│   └──────┬───────┘   └──────┬──────┘   └──────┬──────┘             │
│          │                 │                 │                      │
│          └─────────────────┴─────────────────┘                      │
│                            │                                        │
│                   select_all (futures)                              │
│                            │                                        │
│                            ▼                                        │
│                     MessageStream                                   │
└─────────────────────────────────────────────────────────────────────┘

/help      # Show available commands
/debug     # Toggle verbose output
/quit      # Exit the REPL
/undo      # Undo the last turn
/redo      # Redo an undone turn
/clear     # Clear conversation
/compact   # Compact context window
/new       # Start a new thread
/interrupt # Stop current operation

┌ fetch_webpage requires approval ────────────────────────────
│ Fetch content from a URL
│
│   url: "https://api.example.com/data"
│   method: "GET"
│
│ yes (y) / always (a) / no (n)
└─ req_a3f2 ─────────────────────────────────────────────────

# Default mode (interactive)
ironclaw

# Single message mode
ironclaw -m "What's the weather today?"

# With debug mode enabled
ironclaw --debug

POST /webhook
Content-Type: application/json

{
  "content": "Deploy the latest version",
  "secret": "your-webhook-secret",
  "wait_for_response": true,
  "thread_id": "optional-thread-id"
}

export HTTP_ENABLED=true
export HTTP_PORT=8080
export HTTP_WEBHOOK_SECRET="your-secret-here"
export HTTP_USER_ID="http-client"

{
  "message_id": "550e8400-e29b-41d4-a716-446655440000",
  "status": "accepted",
  "response": "Deployment initiated successfully"
}

# Install signal-cli
brew install signal-cli  # macOS
apt install signal-cli   # Ubuntu

# Link your device
signal-cli -u +1234567890 link

# Start daemon
signal-cli -u +1234567890 daemon --http 127.0.0.1:8888

export SIGNAL_ENABLED=true
export SIGNAL_HTTP_URL="http://127.0.0.1:8888"
export SIGNAL_ACCOUNT="+1234567890"
export SIGNAL_ALLOW_FROM="+10987654321"  # Allowed sender

# When an unknown sender messages the bot
# They receive:
"To pair with this bot, run: ironclaw pairing approve signal abc123"

# The admin approves:
ironclaw pairing approve signal abc123

# The sender can now interact with the bot

# DM policy: open, pairing, or allowlist (default)
export SIGNAL_DM_POLICY="pairing"

# Group policy: disabled, open, or allowlist (default)
export SIGNAL_GROUP_POLICY="allowlist"

# Allowed groups
export SIGNAL_ALLOW_FROM_GROUPS="group-id-1,group-id-2"

# Group sender allowlist (inherits from ALLOW_FROM if empty)
export SIGNAL_GROUP_ALLOW_FROM="+1234567890"

# Send message
POST /api/chat/send
Authorization: Bearer <token>
{
  "content": "Hello",
  "thread_id": "optional"
}

# Stream events
GET /api/chat/events
Authorization: Bearer <token>
# Returns SSE stream with thinking, tool_use, result events

# WebSocket (bidirectional)
GET /api/chat/ws
Upgrade: websocket
Authorization: Bearer <token>

export GATEWAY_ENABLED=true
export GATEWAY_PORT=3000
export GATEWAY_AUTH_TOKEN="your-secure-token"
export GATEWAY_USER_ID="web-user"

type SseEvent =
  | { type: 'thinking'; message: string }
  | { type: 'tool_started'; name: string }
  | { type: 'tool_completed'; name: string; success: boolean }
  | { type: 'stream_chunk'; content: string }
  | { type: 'response'; content: string }
  | { type: 'job_started'; job_id: string; title: string }
  | { type: 'approval_needed'; request_id: string; tool_name: string }

#[async_trait]
pub trait Channel: Send + Sync {
    fn name(&self) -> &str;
    async fn start(&self) -> Result<MessageStream, ChannelError>;
    async fn respond(
        &self,
        msg: &IncomingMessage,
        response: OutgoingResponse,
    ) -> Result<(), ChannelError>;
    async fn send_status(
        &self,
        status: StatusUpdate,
        metadata: &serde_json::Value,
    ) -> Result<(), ChannelError>;
    async fn health_check(&self) -> Result<(), ChannelError>;
    async fn shutdown(&self) -> Result<(), ChannelError>;
}

use ironclaw::channels::{Channel, IncomingMessage, MessageStream};

pub struct MyChannel;

#[async_trait]
impl Channel for MyChannel {
    fn name(&self) -> &str {
        "my_channel"
    }

    async fn start(&self) -> Result<MessageStream, ChannelError> {
        let (tx, rx) = mpsc::channel(256);
        // Start your message receiver
        Ok(Box::pin(ReceiverStream::new(rx)))
    }

    async fn respond(
        &self,
        msg: &IncomingMessage,
        response: OutgoingResponse,
    ) -> Result<(), ChannelError> {
        // Send response back to user
        Ok(())
    }

    // Implement other methods...
}