cpdb-rs 0.1.1

Safe Rust bindings for OpenPrinting cpdb-libs — Common Print Dialog Backends
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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122

use cpdb_rs::CpdbClient;
use cpdb_rs::events::DiscoveryEvent;
use futures_util::StreamExt;

/// This example shows how to use the CpdbClient to discover printers and print their details.
/// It also shows how to listen for live discovery events.
#[tokio::main]
async fn main() -> cpdb_rs::Result<()> {
    let client = CpdbClient::new().await?;
    println!("Connected to {} backend(s).\n", client.backend_count());

    // Initial population via GetAllPrinters
    let printers = client.get_all_printers().await?;
    println!("=== All Printers ({} found) ===", printers.len());
    for p in &printers {
        println!(
            "  {} [{}] - {} (state={}, accepting={})",
            p.name, p.id, p.make_model, p.state, p.accepting_jobs
        );
    }

    // Default printer
    match client.get_default_printer("CUPS").await {
        Ok(default) => {
            let display = if default.is_empty() || default == "[Invalid UTF-8]" || default == "NA" {
                "Not Set"
            } else {
                &default
            };
            println!("\nDefault CUPS printer: {display}");
        }
        Err(_) => println!("\nDefault CUPS printer: Not Set"),
    }

    // Fetch details for the first accepting printer
    if let Some(p) = printers.iter().find(|p| p.is_ready()) {
        println!("\n=== Details for '{}' ===", p.name);
        match client.get_printer_details(&p.id, &p.backend).await {
            Ok((options, media)) => {
                println!(
                    "Option Groups ({} total): {:?}",
                    options.groups().len(),
                    options.groups()
                );
                println!("Options ({} total):", options.len());
                for opt in options.iter().take(8) {
                    println!(
                        "  {}: default='{}', choices=[{}]",
                        opt.name,
                        opt.default_value,
                        opt.supported_values.join(", ")
                    );
                }
                println!("Media ({} total):", media.len());
                for m in media.iter().take(5) {
                    println!(
                        "  {}: {}×{} mm, {} margin(s)",
                        m.name,
                        m.width as f64 / 100.0,
                        m.length as f64 / 100.0,
                        m.margins.len()
                    );
                }
            }
            Err(e) => eprintln!("  Failed to get details: {e}"),
        }
    } else {
        println!("\nNo ready printers to query details for.");
    }

    // Live discovery stream
    println!("\n=== Listening for live discovery events ===");
    println!(
        "(Try: sudo lpadmin -p TestPrinter -E -v ipp://localhost/printers/test -m everywhere)"
    );
    println!("(Press Ctrl+C to stop)\n");

    // Spawn a background task to keep backends alive
    let keep_alive_client = client.clone();
    tokio::spawn(async move {
        let mut interval = tokio::time::interval(std::time::Duration::from_secs(15));
        loop {
            interval.tick().await;
            keep_alive_client.keep_alive_all().await;
        }
    });

    let mut stream = client.discovery_stream().await?;
    while let Some(event) = stream.next().await {
        match &event {
            DiscoveryEvent::PrinterAdded(snap) => {
                println!(
                    "+ ADDED: {} [{}] backend={}",
                    snap.name, snap.id, snap.backend
                );
            }
            DiscoveryEvent::PrinterRemoved { id, backend } => {
                println!("- REMOVED: id={id}, backend={backend}");
            }
            DiscoveryEvent::PrinterStateChanged { id, state, .. } => {
                println!("~ STATE: id={id}, state={state}");
                match state {
                    cpdb_rs::types::PrinterState::Stopped => {
                        println!("  -> Status: Printer is stopped.");
                    }
                    cpdb_rs::types::PrinterState::Idle => {
                        println!("  -> Status: Printer is idle and ready.");
                    }
                    cpdb_rs::types::PrinterState::Processing => {
                        println!("  -> Status: Printer is processing a job.");
                    }
                    cpdb_rs::types::PrinterState::Unknown(raw) => {
                        println!("  -> Status: Printer is in an unknown state: {raw}");
                    }
                }
            }
            _ => {}
        }
    }

    Ok(())
}