updated code to print better error messages

mvonbodun · May 3, 2022 · b93be68 · b93be68
1 parent 8cbbff6
commit b93be68
Show file tree

Hide file tree

Showing 14 changed files with 15 additions and 15 deletions.
diff --git a/impex/src/brands.rs b/impex/src/brands.rs
@@ -88,7 +88,7 @@ pub async fn load_brands(
     bodies
         .for_each(|b| async {
             match b {
-                Ok(_b) => (),
+                Ok(b) => info!("output: {:?}", b),
                 Err(e) => error!("error: {:?}", e),
             }
         })

diff --git a/impex/src/categories.rs b/impex/src/categories.rs
@@ -1,7 +1,6 @@
 use anyhow::{Context, Result};
 use log::*;
 use std::collections::HashMap;
-use std::error::Error;
 use std::fs::File;
 
 use reqwest::{Client, StatusCode};

diff --git a/impex/src/inventory.rs b/impex/src/inventory.rs
@@ -66,7 +66,7 @@ pub async fn load_inventory(
     bodies
         .for_each(|b| async {
             match b {
-                Ok(_b) => (),
+                Ok(b) => info!("output: {:?}", b),
                 Err(e) => error!("error: {:?}", e),
             }
         })

diff --git a/impex/src/prices.rs b/impex/src/prices.rs
@@ -64,7 +64,7 @@ pub async fn load_prices(
     bodies
         .for_each(|b| async {
             match b {
-                Ok(_b) => (),
+                Ok(b) => info!("output: {:?}", b),
                 Err(e) => error!("error: {:?}", e),
             }
         })

diff --git a/impex/src/products.rs b/impex/src/products.rs
@@ -96,7 +96,7 @@ pub async fn load_products(
     bodies
         .for_each(|b| async {
             match b {
-                Ok(_b) => (),
+                Ok(b) => info!("output: {:?}", b),
                 Err(e) => error!("error: {:?}", e),
             }
         })

diff --git a/impex/src/productspecassociation.rs b/impex/src/productspecassociation.rs
@@ -329,7 +329,7 @@ pub async fn load_product_spec_associations(
     bodies
         .for_each(|b| async {
             match b {
-                Ok(_b) => (),
+                Ok(b) => info!("output: {:?}", b),
                 Err(e) => error!("error: {:?}", e),
             }
         })

diff --git a/impex/src/similarcategories.rs b/impex/src/similarcategories.rs
@@ -61,7 +61,7 @@ pub async fn load_similar_categories(
     bodies
         .for_each(|b| async {
             match b {
-                Ok(_b) => (),
+                Ok(b) => info!("output: {:?}", b),
                 Err(e) => error!("error: {:?}", e),
             }
         })

diff --git a/impex/src/skuean.rs b/impex/src/skuean.rs
@@ -106,7 +106,7 @@ pub async fn load_sku_eans(
     bodies
         .for_each(|b| async {
             match b {
-                Ok(_b) => (),
+                Ok(b) => info!("output: {:?}", b),
                 Err(e) => error!("error: {:?}", e),
             }
         })

diff --git a/impex/src/skufiles.rs b/impex/src/skufiles.rs
@@ -137,7 +137,7 @@ pub async fn load_sku_files(
     bodies
         .for_each(|b| async {
             match b {
-                Ok(_b) => (),
+                Ok(b) => info!("output: {:?}", b),
                 Err(e) => error!("error: {:?}", e),
             }
         })

diff --git a/impex/src/skus.rs b/impex/src/skus.rs
@@ -31,7 +31,8 @@ pub async fn load_skus(
     for line in rdr.deserialize() {
         let mut record: Sku = line?;
         debug!("sku_record: {:?}", record);
-        if record.id.is_none() {
+        if record.product_id.is_none() {
+            debug!("record.product_id was none");
             let product_id: i32;
             if !product_lookup.contains_key(&record.product_ref_id) {
                 product_id = utils::get_product_by_ref_id(
@@ -85,7 +86,7 @@ pub async fn load_skus(
     bodies
         .for_each(|b| async {
             match b {
-                Ok(_b) => (),
+                Ok(b) => info!("output: {:?}", b),
                 Err(e) => error!("error: {:?}", e),
             }
         })

diff --git a/impex/src/skuspecassociation.rs b/impex/src/skuspecassociation.rs
@@ -174,7 +174,7 @@ pub async fn load_sku_spec_associations(
     bodies
         .for_each(|b| async {
             match b {
-                Ok(_b) => (),
+                Ok(b) => info!("output: {:?}", b),
                 Err(e) => error!("error: {:?}", e),
             }
         })

diff --git a/impex/src/specificationgroups.rs b/impex/src/specificationgroups.rs
@@ -49,7 +49,7 @@ pub async fn load_specification_groups(
     bodies
         .for_each(|b| async {
             match b {
-                Ok(_b) => (),
+                Ok(b) => info!("output: {:?}", b),
                 Err(e) => error!("error: {:?}", e),
             }
         })

diff --git a/impex/src/specifications.rs b/impex/src/specifications.rs
@@ -254,7 +254,7 @@ pub async fn load_specifications(
     bodies
         .for_each(|b| async {
             match b {
-                Ok(_b) => (),
+                Ok(b) => info!("output: {:?}", b),
                 Err(e) => error!("error: {:?}", e),
             }
         })

diff --git a/impex/src/specificationvalues.rs b/impex/src/specificationvalues.rs
@@ -145,7 +145,7 @@ pub async fn load_specification_values(
     bodies
         .for_each(|b| async {
             match b {
-                Ok(_b) => (),
+                Ok(b) => info!("output: {:?}", b),
                 Err(e) => error!("error: {:?}", e),
             }
         })