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

//! All APIs pertaining to transportation crowd

use crate::lta_client::LTAClient;
use crate::{build_req_with_query, build_req_with_skip};
use lta_models::crowd::passenger_vol;
use lta_models::crowd::passenger_vol::VolType;
use lta_utils_commons::{chrono::NaiveDate, LTAResult};

/// Creates a new client for every call
/// **Update freq**: By 15th of every month, the passenger volume for previous month data
/// will be generated
///
/// Note: Link will expire after 5mins!
pub fn get_passenger_vol_by(
    client: &LTAClient,
    vol_type: passenger_vol::VolType,
    date: Option<NaiveDate>,
    skip: Option<u32>,
) -> LTAResult<Vec<String>> {
    let fmt_date = date.map(|f| f.format(passenger_vol::FORMAT).to_string());

    let url = match vol_type {
        VolType::BusStops => passenger_vol::URL_BY_BUS_STOPS,
        VolType::OdBusStop => passenger_vol::URL_BY_OD_BUS_STOPS,
        VolType::Train => passenger_vol::URL_BY_TRAIN,
        VolType::OdTrain => passenger_vol::URL_BY_OD_TRAIN,
    };

    match fmt_date {
        Some(nd) => {
            build_req_with_query::<passenger_vol::PassengerVolRawResp, _, _>(client, url, |rb| {
                rb.query(&[("Date", nd)])
            })
        }
        None => build_req_with_skip::<passenger_vol::PassengerVolRawResp, _>(client, url, skip),
    }
}