Validate sqlx insertions

Check query results whether the affected rows match our expectations

daemon/src/db.rs

@@ -16,7 +16,7 @@ pub async fn run_migrations(pool: &SqlitePool) -> anyhow::Result<()> {
 }
 
 pub async fn insert_order(order: &Order, conn: &mut PoolConnection<Sqlite>) -> anyhow::Result<()> {
-    sqlx::query(
+    let query_result = sqlx::query(
         r#"insert into orders (
             uuid,
             trading_pair,
@@ -61,6 +61,10 @@ pub async fn insert_order(order: &Order, conn: &mut PoolConnection<Sqlite>) -> a
     .execute(conn)
     .await?;
 
+    if query_result.rows_affected() != 1 {
+        anyhow::bail!("failed to insert order");
+    }
+
     Ok(())
 }
 
@@ -112,7 +116,7 @@ pub async fn load_order_by_id(
 
 pub async fn insert_cfd(cfd: &Cfd, conn: &mut PoolConnection<Sqlite>) -> anyhow::Result<()> {
     let state = serde_json::to_string(&cfd.state)?;
-    sqlx::query(
+    let query_result = sqlx::query(
         r#"
         insert into cfds (
             order_id,
@@ -143,6 +147,11 @@ pub async fn insert_cfd(cfd: &Cfd, conn: &mut PoolConnection<Sqlite>) -> anyhow:
     .execute(conn)
     .await?;
 
+    // Should be 2 because we insert into cfds and cfd_states
+    if query_result.rows_affected() != 2 {
+        anyhow::bail!("failed to insert cfd");
+    }
+
     Ok(())
 }