diff --git a/src/ingestion/routes.rs b/src/ingestion/routes.rs index b28ce68..c6ee9de 100644 --- a/src/ingestion/routes.rs +++ b/src/ingestion/routes.rs @@ -47,8 +47,7 @@ pub async fn monzo_batched_json( .collect::>()?; // We default to the main account for JSON ingestion for now. - let account_id = db::get_account_id(&db, data.account_id().map(|id| id.to_string())).await?; - db::insert(&db, rows, account_id).await?; + db::insert(&db, rows, data.account_id().unwrap_or(1) as i32).await?; Ok("Ok") }