Skip to content

Commit 50a2e41

Browse files
committed
Add direct handling for Result instead of using map_err
1 parent e536686 commit 50a2e41

1 file changed

Lines changed: 12 additions & 10 deletions

File tree

src/data.rs

Lines changed: 12 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -244,7 +244,7 @@ pub fn create_or_update_addresses<'a>(
244244
.values()
245245
.collect::<Vec<&NewAddress>>();
246246

247-
diesel::insert_into(addresses)
247+
let result = diesel::insert_into(addresses)
248248
.values(new_addresses)
249249
.on_conflict((postcode, number))
250250
.do_update()
@@ -255,10 +255,11 @@ pub fn create_or_update_addresses<'a>(
255255
city.eq(excluded(city)),
256256
region.eq(excluded(region))
257257
))
258-
.execute(conn)
259-
.map_err(|err|
260-
error!("Error saving new address: {}", err)
261-
);
258+
.execute(conn);
259+
260+
if let Err(err) = result {
261+
error!("Error saving new address: {}", err)
262+
}
262263
}
263264

264265
fn create_new_state(conn: &PgConnection, state_info: &StateInfo) {
@@ -271,12 +272,13 @@ fn create_new_state(conn: &PgConnection, state_info: &StateInfo) {
271272
processed_at: Utc::now().naive_utc()
272273
};
273274

274-
diesel::insert_into(states)
275+
let result = diesel::insert_into(states)
275276
.values(new_state)
276-
.execute(conn)
277-
.map_err(|err|
278-
error!("Could not create new state: {}", err)
279-
);
277+
.execute(conn);
278+
279+
if let Err(err) = result {
280+
error!("Could not create new state: {}", err)
281+
}
280282
}
281283

282284
pub fn get_addresses(

0 commit comments

Comments
 (0)