SMS alert Covid-19

mapreduce.rs

pub async fn run(file: &str) -> Result<Vec<alert::CovidStats>, Box<dyn Error>> {
    let mut reader = csv::ReaderBuilder::new()
        .has_headers(true)
        .from_path(file)?;

    let today_covid_report: Vec<alert::CovidStats> = reader
        .records()
        .into_iter()
        .par_bridge()
        .map(|line| {
            let result = line.as_ref().expect("a CSV record");
            alert::CovidStats {
                pruid: result[0].to_string(),
                prname: result[1].to_string(),
                date: result[3].to_string(),
                numtoday: result[12].to_string().parse::<u64>().unwrap_or(0),
                numdeathstoday: result[16].to_string().parse::<u64>().unwrap_or(0),
            }
        })
        .filter(|line| {
            let chrono_date = NaiveDate::parse_from_str(&line.date, "%Y-%m-%d").unwrap();
            let now: Date<Local> = Local::now().date();
            now.naive_local()
                .signed_duration_since(chrono_date)
                .num_days()
                == 1
        })
        .filter(|msg| msg.pruid == env::var("PRUID").unwrap().as_str().to_string())
        .collect();

    Ok(today_covid_report)
}