sqlx bulk insert after running compiling codes

Author: taslimmuhammed

.env

@@ -0,0 +1 @@
+DATABASE_URL = postgres://taslim:6318@localhost:5432/test

.sqlx/query-0d4e055d87b4496202041f3c28618688afa91dc0b8eeb8e551b271fc73c1157e.json

@@ -1,2 +1,2 @@
-DROP TABLE IF EXISTS scalar_tap_ravs CASCADE;
-DROP TABLE IF EXISTS scalar_tap_rav_requests_failed CASCADE;
+-- DROP TABLE IF EXISTS scalar_tap_ravs CASCADE;
+-- DROP TABLE IF EXISTS scalar_tap_rav_requests_failed CASCADE;

.sqlx/query-56c3678866ffe0ec2eed7290394d07007990cc244f598b763ec5470515efe019.json

@@ -693,7 +693,7 @@ impl SenderAllocationState {
         let mut nounces = Vec::with_capacity(reciepts_len);
         let mut values = Vec::with_capacity(reciepts_len);
 
-        for received_receipt in receipts.iter(){
+        for received_receipt in receipts.iter() {
             let receipt = received_receipt.signed_receipt();
             let allocation_id = receipt.message.allocation_id;
             let encoded_signature = receipt.signature.as_bytes().to_vec();
@@ -704,12 +704,6 @@ impl SenderAllocationState {
                     error!("Failed to recover receipt signer: {}", e);
                     anyhow!(e)
                 })?;
-            debug!(
-                "Receipt for allocation {} and signer {} failed reason: {}",
-                allocation_id.encode_hex(),
-                receipt_signer.encode_hex(),
-                receipt_error
-            );
             reciepts_signers.push(receipt_signer.encode_hex());
             encoded_signatures.push(encoded_signature);
             allocation_ids.push(allocation_id.encode_hex());
@@ -733,13 +727,14 @@ impl SenderAllocationState {
                 $5::NUMERIC(20)[],
                 $6::NUMERIC(40)[]
             )"#,
-            &signers,
-            &signatures,
+            &reciepts_signers,
+            &encoded_signatures,
             &allocation_ids,
             &timestamps,
-            &nonces,
+            &nounces,
             &values,
-        ).execute(&self.pgpool)
+        )
+        .execute(&self.pgpool)
         .await
         .map_err(|e| {
             error!("Failed to store receipt: {}", e);