IPC Protocol

[4 bytes: payload length (big-endian u32)] [payload bytes]

1. Client sends handshake:
   {"channel": "blob"}

2. Client sends request (JSON frame):
   {"action": "store", "media_type": "image/png"}

3. Client sends blob data (raw binary frame):
   [PNG binary bytes]

4. Server responds (JSON frame):
   {"hash": "a1b2c3d4e5f6..."}

use runtimed::client::PoolClient;
use runtimed::EnvType;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    // Connect to daemon (finds socket automatically)
    let client = PoolClient::connect(None).await?;
    
    // Ping to verify connection
    client.ping().await?;
    println!("Daemon is alive");
    
    // Get pool statistics
    let stats = client.status().await?;
    println!("UV available: {}", stats.uv_available);
    println!("Conda available: {}", stats.conda_available);
    
    // Acquire a UV environment
    match client.take(EnvType::Uv).await? {
        Some(env) => {
            println!("Got environment: {:?}", env.python_path);
            
            // Use the environment...
            
            // Return it to the pool when done
            client.return_env(env).await?;
        }
        None => {
            println!("No environments available");
        }
    }
    
    Ok(())
}

use runtimed::notebook_sync_client::NotebookSyncClient;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    // Connect to notebook room
    let client = NotebookSyncClient::connect(
        "/path/to/notebook.ipynb",
        None,  // daemon socket (auto-detect)
    ).await?;
    
    // Update cell source (syncs to all peers)
    client.update_source(
        "550e8400-e29b-41d4-a716-446655440000",
        "print('Hello from daemon')"
    ).await?;
    
    // Listen for changes from other peers
    tokio::spawn(async move {
        loop {
            if let Some(change) = client.recv_changes().await? {
                println!("Notebook updated: {} cells", change.cells.len());
            }
        }
    });
    
    Ok(())
}