gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Improve rpc logging

Browse Source
This commit is contained in:
Tyera Eulberg
2018-10-31 13:27:48 -06:00
committed by Tyera Eulberg
parent aa2fd3f3bb
commit 6ddd494826
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/rpc.rs
View File

@ -162,25 +162,31 @@ impl RpcSol for RpcSolImpl {
type Metadata = Meta; type Metadata = Meta;
fn confirm_transaction(&self, meta: Self::Metadata, id: String) -> Result<bool> { fn confirm_transaction(&self, meta: Self::Metadata, id: String) -> Result<bool> {
info!("confirm_transaction rpc request received: {:?}", id);
self.get_signature_status(meta, id) self.get_signature_status(meta, id)
.map(|status| status == RpcSignatureStatus::Confirmed) .map(|status| status == RpcSignatureStatus::Confirmed)
} }
fn get_account_info(&self, meta: Self::Metadata, id: String) -> Result<Account> { fn get_account_info(&self, meta: Self::Metadata, id: String) -> Result<Account> {
info!("get_account_info rpc request received: {:?}", id);
let pubkey = verify_pubkey(id)?; let pubkey = verify_pubkey(id)?;
meta.request_processor.get_account_info(pubkey) meta.request_processor.get_account_info(pubkey)
} }
fn get_balance(&self, meta: Self::Metadata, id: String) -> Result<i64> { fn get_balance(&self, meta: Self::Metadata, id: String) -> Result<i64> {
info!("get_balance rpc request received: {:?}", id);
let pubkey = verify_pubkey(id)?; let pubkey = verify_pubkey(id)?;
meta.request_processor.get_balance(pubkey) meta.request_processor.get_balance(pubkey)
} }
fn get_finality(&self, meta: Self::Metadata) -> Result<usize> { fn get_finality(&self, meta: Self::Metadata) -> Result<usize> {
info!("get_finality rpc request received");
meta.request_processor.get_finality() meta.request_processor.get_finality()
} }
fn get_last_id(&self, meta: Self::Metadata) -> Result<String> { fn get_last_id(&self, meta: Self::Metadata) -> Result<String> {
info!("get_last_id rpc request received");
meta.request_processor.get_last_id() meta.request_processor.get_last_id()
} }
fn get_signature_status(&self, meta: Self::Metadata, id: String) -> Result<RpcSignatureStatus> { fn get_signature_status(&self, meta: Self::Metadata, id: String) -> Result<RpcSignatureStatus> {
info!("get_signature_status rpc request received: {:?}", id);
let signature = verify_signature(&id)?; let signature = verify_signature(&id)?;
Ok( Ok(
match meta.request_processor.get_signature_status(signature) { match meta.request_processor.get_signature_status(signature) {
@ -196,6 +202,7 @@ impl RpcSol for RpcSolImpl {
) )
} }
fn get_transaction_count(&self, meta: Self::Metadata) -> Result<u64> { fn get_transaction_count(&self, meta: Self::Metadata) -> Result<u64> {
info!("get_transaction_count rpc request received");
meta.request_processor.get_transaction_count() meta.request_processor.get_transaction_count()
} }
fn request_airdrop(&self, meta: Self::Metadata, id: String, tokens: u64) -> Result<String> { fn request_airdrop(&self, meta: Self::Metadata, id: String, tokens: u64) -> Result<String> {