blockworks-foundation
/
BankingStageErrorsTrackingSidecar
mirror of https://github.com/blockworks-foundation/BankingStageErrorsTrackingSidecar.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

making postgres errors into panics (#16)

This commit is contained in:
galactus 2023-12-08 14:47:00 +01:00 committed by GitHub
parent c59f849e10
commit d5da3bae02
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 11 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main.rs
View File

@ -236,7 +236,7 @@ async fn start_tracking_blocks(
block_info.processed_transactions - block_info.successful_transactions,
);
if let Err(e) = postgres.save_block_info(block_info).await {
error!("Error saving block {}", e);
panic!("Error saving block {}", e);
}
slot.store(block.slot, std::sync::atomic::Ordering::Relaxed);
slot_by_errors.remove(&block.slot);

19
src/postgres.rs
View File

@ -134,7 +134,7 @@ impl PostgresSession {
signature, errors, is_executed, is_confirmed, first_notification_slot, cu_requested, prioritization_fees, utc_timestamp, accounts_used, processed_slot
) FROM STDIN BINARY
"#;
let sink: CopyInSink<bytes::Bytes> = self.copy_in(statement).await.unwrap();
let sink: CopyInSink<bytes::Bytes> = self.copy_in(statement).await?;
let writer = BinaryCopyInWriter::new(
sink,
&[
@ -164,9 +164,9 @@ impl PostgresSession {
args.push(&tx.accounts_used);
args.push(&tx.processed_slot);
writer.as_mut().write(&args).await.unwrap();
writer.as_mut().write(&args).await?;
}
writer.finish().await.unwrap();
writer.finish().await?;
Ok(())
}
@ -223,8 +223,8 @@ impl PostgresSession {
],
);
pin_mut!(writer);
writer.as_mut().write(&args).await.unwrap();
writer.finish().await.unwrap();
writer.as_mut().write(&args).await?;
writer.finish().await?;
Ok(())
}
}
@ -269,12 +269,13 @@ impl Postgres {
.map(|(_, tree)| tree.iter().map(|(_, info)| info).cloned().collect_vec())
.flatten()
.collect_vec();
let batches = data.chunks(8).collect_vec();
let batches = data.chunks(32).collect_vec();
for batch in batches {
session
if let Err(e) = session
.save_banking_transaction_results(batch.to_vec())
.await
.unwrap();
.await {
panic!("saving transaction infos failed {}", e);
}
}
}
}