From 7f58ecb96c00504956303f73bed05fddf2a4393d Mon Sep 17 00:00:00 2001 From: Ralf Zerres Date: Fri, 3 Jul 2020 00:58:35 +0200 Subject: [PATCH] imports: allianzdirectcall: use array to verify on startup * using test dataset Signed-off-by: Ralf Zerres --- .../src/services/imports/allianzdirectcall.rs | 34 ++++++++----------- 1 file changed, 15 insertions(+), 19 deletions(-) diff --git a/advotracker/src/services/imports/allianzdirectcall.rs b/advotracker/src/services/imports/allianzdirectcall.rs index 0cefd3a..b2d2572 100644 --- a/advotracker/src/services/imports/allianzdirectcall.rs +++ b/advotracker/src/services/imports/allianzdirectcall.rs @@ -47,7 +47,7 @@ pub fn import(p: &mut String, data_list: &mut PolicyDataList, let file = File::open(path)?; trace!(target: "advotrackerd", extension = ?extension, file = ?file); - // Build the CSV reader and iterate over each record. + // Build the CSV reader let mut csv_reader = csv::ReaderBuilder::new() .has_headers(true) .delimiter(b' ') @@ -60,14 +60,15 @@ pub fn import(p: &mut String, data_list: &mut PolicyDataList, trace!(target: "advotrackerd", header = ?headers); } - //for result in csv_reader.records() { + // Iterate over each record, deserialize und write to our structures let mut count = 0; for result in csv_reader.deserialize() { // The iterator yields Result, so we check the // error here. let record: PolicyData = result?; - //let record: data::AllianzPolicyNumber = result?; - println!("{:?}", record); + //if verbose > 3 { + // println!("{:?}", record); + //} // WIP: write to redis backend // append the policy_number to the HashMap @@ -86,21 +87,16 @@ pub fn import(p: &mut String, data_list: &mut PolicyDataList, // Tests // Takes a reference and returns Option<&V> - let test_policy_number : usize = 1511111111; - match data_list.get(test_policy_number) { - Some(policy_code) => { - println!("Policy-Number {:?} {:?}", - test_policy_number, policy_code); - }, - _ => println!("1. No number found!"), - } - - let test_policy_number_2 : usize = 9999999991; - match data_list.get(test_policy_number_2) { - Some(policy_code) => { println!("Policy-Number: {:?} {:?}", - test_policy_number, policy_code); - }, - _ => println!("2. No number found!"), + let my_policy_numbers : [usize; 2] = [1511111111, 9999999993]; + assert_eq!(my_policy_numbers, [1511111111, 9999999993]); + for p in &my_policy_numbers { + match policy_numbers.get(&p) { + Some(policy_code) => { + println!("Test: Policy-Number {:?} => Policy-Type {:?}, as expected!", + p, policy_code); + }, + _ => println!("Test: Policy-Number {:?} => not valid, can't dereference the Policy-Type as expected", p), + } } state = t!("state.finished", lang);