Method try_from_reader

collab/src/database/template/csv.rs:34–78

(
    reader: impl io::Read,
    auto_field_type: bool,
    mut csv_resource: Option<CSVResource>,
  )

impl CSVTemplate {
  pub fn try_from_reader(
    reader: impl io::Read,
    auto_field_type: bool,
    mut csv_resource: Option<CSVResource>,
  ) -> Result<Self, CollabError> {
    let mut fields: Vec<CSVField> = vec![];

    let mut reader = csv::Reader::from_reader(reader);
    if let Ok(headers) = reader.headers() {
      for header in headers {
        fields.push(CSVField {
          name: header.to_string(),
          field_type: FieldType::RichText,
        });
      }
    } else {
      return Err(CollabError::DatabaseInvalidCsv("No header".to_string()));
    }

    let rows: Vec<Vec<String>> = reader
      .records()
      .flat_map(|r| r.ok())
      .map(|record| {
        record
          .into_iter()
          .filter_map(|s| Some(percent_decode_str(s).decode_utf8().ok()?.to_string()))
          .collect::<Vec<String>>()
      })
      .collect();

    if auto_field_type {
      auto_detect_field_type(&mut fields, &rows, &csv_resource);
    }

    // filter out resources that are not used
    filter_out_resources(&fields, &rows, &mut csv_resource);

    Ok(CSVTemplate {
      fields,
      rows,
      resource: csv_resource,
      database_id: gen_database_id(),
      view_id: gen_database_view_id(),
    })
  }

  pub fn reset_view_id(&mut self, view_id: DatabaseViewId) {
    self.view_id = view_id;