fiux 0.5.2

The fastest multi-format file converter CLI tool
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

use std::{
    fs::File,
    io::{BufReader, Error, ErrorKind as EK},
};

use resext::{CtxResult, ResExt};

use crate::utils::{DataTypes, WriterStreams};

#[inline]
pub(crate) fn csv_decoder(
    mut reader: csv::Reader<BufReader<File>>,
) -> CtxResult<WriterStreams<impl Iterator<Item = CtxResult<DataTypes, Error>>>, Error> {
    let headers = reader
        .headers()
        .map_err(|_| Error::new(EK::InvalidData, "Input CSV file headers are missing"))
        .context("Failed to read input file headers")?
        .iter()
        .map(|s| s.to_string())
        .collect::<Vec<String>>();

    let iter = reader.into_byte_records().enumerate().map(move |(line_no, rec)| {
        let record = rec
            .map_err(|_| Error::new(EK::InvalidData, "Invalid CSV record"))
            .context("Failed to deserialize file")
            .with_context(|| format!("Invalid CSV data in input file at line: {}", line_no + 1));

        match record {
            Ok(ok) => Ok(DataTypes::Csv(ok)),
            Err(err) => Err(err),
        }
    });

    Ok(WriterStreams::Table { headers, iter })
}