gflights 0.3.0

Unofficial async Rust client for the Google Flights web API — search flights, price graphs, and booking offers.
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
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138

//! CLI subcommand: `gflights deals`
//!
//! Finds discounted destinations from an origin using the Google Flights deals
//! endpoint (GetFlightDealsStreaming).

use anyhow::Result;
use chrono::NaiveDate;
use clap::Parser;
use gflights::parsers::common::{Location, PlaceType, TravelClass, Travelers};
use gflights::requests::api::ApiClient;
use gflights::requests::config::deals::DealConfig;

use super::OutputFormat;

/// Arguments for the `deals` subcommand.
#[derive(Parser, Debug)]
pub struct DealsArgs {
    /// Origin airport IATA code (e.g. LUX).
    #[arg(long)]
    pub from: String,

    /// Outbound date (YYYY-MM-DD). With --ret, defines the trip-length anchor.
    #[arg(long)]
    pub out: NaiveDate,

    /// Return date (YYYY-MM-DD).
    #[arg(long)]
    pub ret: NaiveDate,

    /// Only show non-stop deals.
    #[arg(long)]
    pub nonstop: bool,

    /// Maximum one-way flight duration in hours.
    #[arg(long)]
    pub max_hours: Option<u32>,

    /// Number of adult passengers.
    #[arg(long, default_value = "1")]
    pub adults: u32,

    /// Number of children (2–11 years).
    #[arg(long, default_value = "0")]
    pub children: u32,

    /// Number of infants in their own seat.
    #[arg(long = "infants-seat", default_value = "0")]
    pub infants_seat: u32,

    /// Number of lap infants.
    #[arg(long = "infants-lap", default_value = "0")]
    pub infants_lap: u32,

    /// Travel class.
    #[arg(long, default_value = "economy")]
    pub class: TravelClass,

    /// Output format.
    #[arg(long, default_value = "table")]
    pub format: OutputFormat,
}

pub async fn cmd_deals(args: DealsArgs, client: &ApiClient) -> Result<()> {
    let origin = Location {
        loc_identifier: args.from.to_uppercase(),
        loc_type: PlaceType::Airport,
        location_name: None,
    };
    let travellers = Travelers::new(vec![
        args.adults as i32,
        args.children as i32,
        args.infants_lap as i32,
        args.infants_seat as i32,
    ])?;

    let config = DealConfig {
        origin: vec![origin],
        outbound_date: args.out,
        return_date: args.ret,
        nonstop: args.nonstop,
        max_duration_minutes: args.max_hours.map(|h| h * 60),
        travel_class: args.class,
        travellers,
    };

    let mut deals = client.request_deals(&config).await?;
    // Best discounts first.
    deals.sort_by_key(|d| std::cmp::Reverse(d.discount_pct));

    if deals.is_empty() {
        eprintln!("No deals found.");
        return Ok(());
    }

    match args.format {
        OutputFormat::Json => {
            println!("{}", serde_json::to_string_pretty(&deals)?);
        }
        OutputFormat::Table => {
            println!(
                "{:>5}  {:>6}  {:>7}  {:<22}  {:<8}  {:>5}  {:>5}  {:<24}",
                "OFF%", "PRICE", "TYPICAL", "DESTINATION", "AIRLINE", "STOPS", "MINS", "DATES"
            );
            println!("{}", "-".repeat(100));
            for d in &deals {
                let off = d
                    .discount_pct
                    .map(|p| format!("{p}%"))
                    .unwrap_or_else(|| "—".into());
                let price = d.price.map(|p| p.to_string()).unwrap_or_else(|| "—".into());
                let typical = d
                    .typical_price
                    .map(|p| p.to_string())
                    .unwrap_or_else(|| "—".into());
                let dest = format!("{} ({})", d.destination_city, d.destination_iata);
                let airline = d.airline_name.as_deref().unwrap_or("—");
                let stops = d.stops.map(|s| s.to_string()).unwrap_or_else(|| "—".into());
                let mins = d
                    .duration_minutes
                    .map(|m| m.to_string())
                    .unwrap_or_else(|| "—".into());
                let dates = match (d.outbound_date, d.return_date) {
                    (Some(o), Some(r)) => format!("{o} → {r}"),
                    (Some(o), None) => o.to_string(),
                    _ => "—".into(),
                };
                println!(
                    "{:>5}  {:>6}  {:>7}  {:<22}  {:<8}  {:>5}  {:>5}  {:<24}",
                    off, price, typical, dest, airline, stops, mins, dates
                );
                if let Some(url) = &d.booking_url {
                    println!("       {url}");
                }
            }
        }
    }
    Ok(())
}