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

allow subscription to sigs not in cache

This commit is contained in:
Aniket Prajapati 2023-01-08 19:59:51 +05:30
parent f3ba857e9b
commit 2e9752e81c
No known key found for this signature in database
GPG Key ID: D4346D8C9C5398F2
1 changed files with 10 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/workers/block_listenser.rs
View File

@ -143,20 +143,18 @@ impl BlockListener {
};
for sig in signatures {
let Some(mut tx_status) = self.txs_sent.get_mut(&sig) else {
continue;
if let Some(mut tx_status) = self.txs_sent.get_mut(&sig) {
info!("{comfirmation_status:?} {sig}");
*tx_status.value_mut() = Some(TransactionStatus {
slot,
confirmations: None, //TODO: talk about this
status: Ok(()), // legacy field
err: None,
confirmation_status: Some(comfirmation_status.clone()),
});
};
info!("{comfirmation_status:?} {sig}");
*tx_status.value_mut() = Some(TransactionStatus {
slot,
confirmations: None, //TODO: talk about this
status: Ok(()), // legacy field
err: None,
confirmation_status: Some(comfirmation_status.clone()),
});
// subscribers
if let Some((sig, mut sink)) = self.signature_subscribers.remove(&sig) {
warn!("notification {}", sig);