ribbit-client

Async TCP client for Blizzard's Ribbit protocol, used to retrieve version information, CDN configurations, and other metadata for Blizzard games.

Features

• 🚀 Async/await support - Built on Tokio for efficient async I/O
• 🌍 Multi-region support - US, EU, CN, KR, TW, SG regions
• 📝 Protocol versions - Both V1 (MIME) and V2 (raw PSV) protocols
• ✅ Checksum validation - SHA-256 integrity verification for V1 responses
• 🔐 Signature parsing - ASN.1/PKCS#7 signature extraction and validation
• 🛡️ Type-safe - Strongly typed endpoints and responses
• 📊 Comprehensive testing - Unit, integration, and benchmark tests
• 🎯 Production ready - Following Rust best practices with pedantic lints

Quick Start

Add to your Cargo.toml:

[dependencies]
ribbit-client = "0.3"
tokio = { version = "1", features = ["full"] }

Basic usage:

use ribbit_client::{RibbitClient, Region};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // Create a client for the US region
    let client = RibbitClient::new(Region::US);

    // Request WoW version information using typed API
    let versions = client.get_product_versions("wow").await?;

    // Access typed fields directly
    for entry in &versions.entries {
        println!(
            "{}: {} (build {})",
            entry.region, entry.versions_name, entry.build_id
        );
    }

    Ok(())
}

Supported Endpoints

Protocol Versions

V1 Protocol (MIME)

• Full MIME message parsing with multipart support
• SHA-256 checksum validation from epilogue
• ASN.1 signature parsing for attached signatures
• Automatic content type detection

V2 Protocol (Raw PSV) - Default

• Direct PSV (Pipe-Separated Values) format
• Lower overhead, faster parsing
• No MIME wrapper or checksums
• This is the default protocol

// V2 is the default
let client = RibbitClient::new(Region::EU);

// Or explicitly use V1 if needed
use ribbit_client::ProtocolVersion;
let client = RibbitClient::new(Region::EU)
    .with_protocol_version(ProtocolVersion::V1);

Examples

The crate includes several examples demonstrating different use cases:

# Basic client usage
cargo run --example ribbit_basic_usage

# Parse version data into structured format
cargo run --example parse_versions

# Query multiple WoW products
cargo run --example wow_products

# Debug MIME structure (V1 protocol)
cargo run --example mime_parsing

# Typed API showcase
cargo run --example typed_api_showcase

# Retry handling demonstration
cargo run --example retry_handling

Response Structure

Responses contain both raw data and parsed components:

pub struct Response {
    /// Raw response bytes
    pub raw: Vec<u8>,

    /// Parsed data (PSV format)
    pub data: Option<String>,

    /// MIME parts (V1 only)
    pub mime_parts: Option<MimeParts>,
}

pub struct MimeParts {
    /// Main data content
    pub data: String,

    /// Signature bytes (if present)
    pub signature: Option<Vec<u8>>,

    /// Parsed signature information
    pub signature_info: Option<SignatureInfo>,

    /// SHA-256 checksum from epilogue
    pub checksum: Option<String>,
}

Typed API (Recommended)

The client provides a typed API that automatically parses responses into strongly-typed structs:

// Get product versions with automatic parsing
let versions = client.get_product_versions("wow").await?;

// Direct access to typed fields
for entry in &versions.entries {
    println!("Region: {}", entry.region);
    println!("Build: {} ({})", entry.build_id, entry.versions_name);
    println!("Build Config: {}", entry.build_config);
    println!("CDN Config: {}", entry.cdn_config);
}

// Convenience methods
if let Some(us_version) = versions.get_region("us") {
    println!("US version: {}", us_version.versions_name);
}

// Other typed endpoints
let summary = client.get_summary().await?;
let cdns = client.get_product_cdns("wow").await?;
let bgdl = client.get_product_bgdl("wow").await?;

Manual PSV Parsing (Advanced)

For custom endpoints or manual parsing, Ribbit returns data in PSV (Pipe-Separated Values) format:

// Manual parsing of raw response
let endpoint = Endpoint::ProductVersions("wow".to_string());
let response = client.request(&endpoint).await?;

if let Some(data) = response.data {
    // First line contains column definitions
    // Region!STRING:0|BuildConfig!HEX:16|CDNConfig!HEX:16|...

    for line in data.lines().skip(1) {
        if line.is_empty() || line.starts_with('#') {
            continue;
        }

        let fields: Vec<&str> = line.split('|').collect();
        let region = fields[0];
        let build_config = fields[1];
        let cdn_config = fields[2];
        // ... process remaining fields
    }
}

Error Handling

The client provides detailed error types for different failure scenarios:

use ribbit_client::{Error, Result};

match client.request(&endpoint).await {
    Ok(response) => println!("Success!"),
    Err(Error::ConnectionFailed { host, port }) => {
        eprintln!("Failed to connect to {}:{}", host, port);
    }
    Err(Error::ChecksumMismatch) => {
        eprintln!("Response failed integrity check");
    }
    Err(Error::MimeParseError(msg)) => {
        eprintln!("Failed to parse MIME: {}", msg);
    }
    Err(e) => eprintln!("Error: {}", e),
}

Advanced Usage

Custom Region Configuration

let mut client = RibbitClient::new(Region::US);
client.set_region(Region::EU);

Raw Response Access

// Get raw bytes for custom parsing
let raw_data = client.request_raw(&endpoint).await?;
println!("Received {} bytes", raw_data.len());

V1 Protocol with Signature Verification

use ribbit_client::ProtocolVersion;
let client = RibbitClient::new(Region::US)
    .with_protocol_version(ProtocolVersion::V1);

let response = client.request(&endpoint).await?;
if let Some(mime_parts) = response.mime_parts {
    // Checksum is automatically validated
    println!("Checksum verified: {:?}", mime_parts.checksum);

    // Access signature information
    if let Some(sig_info) = mime_parts.signature_info {
        println!("Signature format: {}", sig_info.format);
        println!("Algorithm: {}", sig_info.algorithm);
        println!("Signers: {}", sig_info.signer_count);
        println!("Certificates: {}", sig_info.certificate_count);
    }
}

Debugging

Enable trace logging to see detailed protocol information:

use tracing_subscriber::EnvFilter;

tracing_subscriber::fmt()
    .with_env_filter(EnvFilter::from_default_env()
        .add_directive("ribbit_client=trace".parse()?))
    .init();

Performance

The client is optimized for performance with:

• Reusable TCP connections per request
• Efficient MIME parsing with streaming support
• Zero-copy parsing where possible
• Async I/O for concurrent requests

Run benchmarks:

cargo bench

Testing

The crate includes comprehensive tests:

# Run all tests
cargo test

# Run with trace logging
RUST_LOG=ribbit_client=trace cargo test

# Run specific test
cargo test test_ribbit_summary_v1

Code Quality

This crate follows Rust best practices:

• Clippy pedantic lints enabled
• All public APIs documented with examples
• #[must_use] attributes where appropriate
• Comprehensive error documentation
• No unsafe code

Contributing

Contributions are welcome! Please ensure:

• All tests pass
• Code follows Rust best practices
• Documentation is updated
• Examples demonstrate new features

📄 License

This project is dual-licensed under either:

• Apache License, Version 2.0 (LICENSE-APACHE)
• MIT license (LICENSE-MIT)

at your option.

Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in this project by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.

🫶 Acknowledgments

This crate is part of the cascette-rs project, providing tools for World of Warcraft emulation development.