Implementing method get slot
This commit is contained in:
parent
27a42198e1
commit
497dc1be6c
|
@ -36,7 +36,7 @@ use solana_rpc_client_api::{
|
|||
};
|
||||
use solana_sdk::{
|
||||
commitment_config::CommitmentConfig, hash::Hash, pubkey::Pubkey, signature::Keypair,
|
||||
transaction::VersionedTransaction,
|
||||
transaction::VersionedTransaction, slot_history::Slot,
|
||||
};
|
||||
use solana_transaction_status::TransactionStatus;
|
||||
use tokio::{
|
||||
|
@ -458,6 +458,22 @@ impl LiteRpcServer for LiteBridge {
|
|||
Ok(airdrop_sig)
|
||||
}
|
||||
|
||||
async fn get_slot(
|
||||
&self,
|
||||
config: Option<RpcContextConfig>,
|
||||
) -> crate::rpc::Result<Slot> {
|
||||
let commitment_config = config
|
||||
.map(|config| config.commitment.unwrap_or_default())
|
||||
.unwrap_or_default();
|
||||
|
||||
let (_,
|
||||
BlockInformation {
|
||||
slot, ..
|
||||
}
|
||||
) = self.block_store.get_latest_block(commitment_config).await;
|
||||
Ok(slot)
|
||||
}
|
||||
|
||||
async fn signature_subscribe(
|
||||
&self,
|
||||
pending: PendingSubscriptionSink,
|
||||
|
|
|
@ -5,6 +5,7 @@ use solana_rpc_client_api::config::{
|
|||
};
|
||||
use solana_rpc_client_api::response::{Response as RpcResponse, RpcBlockhash, RpcVersionInfo};
|
||||
use solana_sdk::commitment_config::CommitmentConfig;
|
||||
use solana_sdk::slot_history::Slot;
|
||||
use solana_transaction_status::TransactionStatus;
|
||||
|
||||
use crate::configs::{IsBlockHashValidConfig, SendTransactionConfig};
|
||||
|
@ -51,6 +52,9 @@ pub trait LiteRpc {
|
|||
config: Option<RpcRequestAirdropConfig>,
|
||||
) -> Result<String>;
|
||||
|
||||
#[method(name = "getSlot")]
|
||||
async fn get_slot(&self, config: Option<RpcContextConfig>) -> Result<Slot>;
|
||||
|
||||
#[subscription(name = "signatureSubscribe" => "signatureNotification", unsubscribe="signatureUnsubscribe", item=RpcResponse<serde_json::Value>)]
|
||||
async fn signature_subscribe(
|
||||
&self,
|
||||
|
|
Loading…
Reference in New Issue