nab 0.7.1

Token-optimized HTTP client for LLMs — fetches any URL as clean markdown
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

//! Example: Stream HLS/DASH using ffmpeg backend
//!
//! Usage: `cargo run --example stream_ffmpeg <manifest_url>`

use anyhow::Result;
use nab::stream::backend::{StreamBackend, StreamConfig, StreamProgress};
use nab::stream::backends::FfmpegBackend;
use tokio::io::AsyncWriteExt;

#[tokio::main]
async fn main() -> Result<()> {
    tracing_subscriber::fmt::init();

    let args: Vec<String> = std::env::args().collect();
    if args.len() < 2 {
        eprintln!("Usage: {} <manifest_url>", args[0]);
        eprintln!("Example: {} https://example.com/master.m3u8", args[0]);
        std::process::exit(1);
    }

    let manifest_url = &args[1];

    // Create ffmpeg backend
    let backend = FfmpegBackend::new()?;

    // Check if ffmpeg is available
    if !backend.check_available().await {
        eprintln!("Error: ffmpeg not found in PATH");
        eprintln!("Install with: brew install ffmpeg (macOS) or apt install ffmpeg (Linux)");
        std::process::exit(1);
    }

    println!("Streaming {manifest_url} via ffmpeg...");

    // Configure streaming
    let config = StreamConfig {
        quality: nab::stream::StreamQuality::Best,
        headers: std::collections::HashMap::new(),
        cookies: None,
    };

    // Progress callback
    let progress_cb = Box::new(|p: StreamProgress| {
        #[allow(clippy::cast_precision_loss)] // display only; sub-MB precision acceptable
        let mb = p.bytes_downloaded as f64 / 1_000_000.0;
        eprintln!(
            "\rDownloaded: {mb:.2} MB | Elapsed: {:.1}s",
            p.elapsed_seconds
        );
    });

    // Stream to stdout (can pipe to player: | mpv -)
    let mut stdout = tokio::io::stdout();
    backend
        .stream_to(manifest_url, &config, &mut stdout, Some(progress_cb))
        .await?;

    stdout.flush().await?;
    eprintln!("\nStreaming complete!");

    Ok(())
}