som minor changes
This commit is contained in:
parent
070c3264ba
commit
77b675a0d7
|
@ -60,7 +60,9 @@ async fn main() {
|
|||
postgres.start_saving_transaction(map_of_infos.clone(), slot.clone());
|
||||
|
||||
while let Some(message) = stream.next().await {
|
||||
let message = message.unwrap();
|
||||
let Ok(message) = message else {
|
||||
continue;
|
||||
};
|
||||
|
||||
let Some(update) = message.update_oneof else {
|
||||
continue;
|
||||
|
@ -69,9 +71,6 @@ async fn main() {
|
|||
match update {
|
||||
UpdateOneof::BankingTransactionErrors(transaction) => {
|
||||
log::info!("got banking stage transaction erros");
|
||||
if transaction.error.is_none() {
|
||||
continue;
|
||||
}
|
||||
let sig = transaction.signature.to_string();
|
||||
match map_of_infos.get_mut(&sig) {
|
||||
Some(mut x) => {
|
||||
|
|
|
@ -83,7 +83,7 @@ impl PostgresSession {
|
|||
if txs.is_empty() {
|
||||
return Ok(());
|
||||
}
|
||||
const NUMBER_OF_ARGS: usize = 10;
|
||||
const NUMBER_OF_ARGS: usize = 11;
|
||||
|
||||
let mut args: Vec<&(dyn ToSql + Sync)> = Vec::with_capacity(NUMBER_OF_ARGS * txs.len());
|
||||
let txs: Vec<PostgresTransactionInfo> = txs
|
||||
|
|
Loading…
Reference in New Issue