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

fmt

This commit is contained in:
aniketfuryrocks 2023-10-22 21:09:41 +05:30
parent d68ba7e3f0
commit b7c9c7e55f
2 changed files with 29 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
lite-rpc/src/bridge.rs
View File

@ -21,10 +21,11 @@ use solana_lite_rpc_history::history::History;
use solana_rpc_client::nonblocking::rpc_client::RpcClient;
use solana_rpc_client_api::{
config::{
RpcBlockConfig, RpcBlockSubscribeConfig, RpcBlockSubscribeFilter, RpcBlocksConfigWrapper,
RpcContextConfig, RpcEncodingConfigWrapper, RpcEpochConfig, RpcGetVoteAccountsConfig,
RpcProgramAccountsConfig, RpcRequestAirdropConfig, RpcSignatureStatusConfig,
RpcSignatureSubscribeConfig, RpcSignaturesForAddressConfig, RpcTransactionLogsFilter, RpcTransactionLogsConfig,
RpcBlockConfig, RpcBlockSubscribeConfig, RpcBlockSubscribeFilter, RpcBlocksConfigWrapper,
RpcContextConfig, RpcEncodingConfigWrapper, RpcEpochConfig, RpcGetVoteAccountsConfig,
RpcProgramAccountsConfig, RpcRequestAirdropConfig, RpcSignatureStatusConfig,
RpcSignatureSubscribeConfig, RpcSignaturesForAddressConfig, RpcTransactionLogsConfig,
RpcTransactionLogsFilter,
},
response::{
Response as RpcResponse, RpcBlockhash, RpcConfirmedTransactionStatusWithSignature,
@ -159,7 +160,6 @@ impl LiteRpcServer for LiteBridge {
todo!()
}
async fn get_slot(&self, config: Option<RpcContextConfig>) -> crate::rpc::Result<Slot> {
let commitment_config = config
.map(|config| config.commitment.unwrap_or_default())
@ -410,25 +410,35 @@ impl LiteRpcServer for LiteBridge {
}
async fn program_subscribe(
&self, _pending: PendingSubscriptionSink,
&self,
_pending: PendingSubscriptionSink,
_pubkey_str: String,
_config: Option<RpcProgramAccountsConfig>,
) -> SubscriptionResult { todo!() }
) -> SubscriptionResult {
todo!()
}
async fn slot_subscribe(&self, _pending: PendingSubscriptionSink) -> SubscriptionResult { todo!() }
async fn slot_subscribe(&self, _pending: PendingSubscriptionSink) -> SubscriptionResult {
todo!()
}
async fn block_subscribe(
&self, _pending: PendingSubscriptionSink,
&self,
_pending: PendingSubscriptionSink,
_filter: RpcBlockSubscribeFilter,
_config: Option<RpcBlockSubscribeConfig>,
) -> SubscriptionResult { todo!() }
) -> SubscriptionResult {
todo!()
}
async fn logs_subscribe(
&self, _pending: PendingSubscriptionSink,
&self,
_pending: PendingSubscriptionSink,
_filter: RpcTransactionLogsFilter,
_config: Option<RpcTransactionLogsConfig>,
) -> SubscriptionResult { todo!() }
) -> SubscriptionResult {
todo!()
}
// WARN: enable_received_notification: bool is ignored
async fn signature_subscribe(
@ -450,12 +460,14 @@ impl LiteRpcServer for LiteBridge {
Ok(())
}
async fn slot_updates_subscribe(&self, _pending: PendingSubscriptionSink) -> SubscriptionResult {
async fn slot_updates_subscribe(
&self,
_pending: PendingSubscriptionSink,
) -> SubscriptionResult {
todo!()
}
async fn vote_subscribe(&self, _pending: PendingSubscriptionSink) -> SubscriptionResult {
todo!()
}
}

5
lite-rpc/src/rpc.rs
View File

@ -4,7 +4,8 @@ use solana_rpc_client_api::config::{
RpcBlockConfig, RpcBlockSubscribeConfig, RpcBlockSubscribeFilter, RpcBlocksConfigWrapper,
RpcContextConfig, RpcEncodingConfigWrapper, RpcEpochConfig, RpcGetVoteAccountsConfig,
RpcProgramAccountsConfig, RpcRequestAirdropConfig, RpcSignatureStatusConfig,
RpcSignatureSubscribeConfig, RpcSignaturesForAddressConfig, RpcTransactionLogsFilter, RpcTransactionLogsConfig,
RpcSignatureSubscribeConfig, RpcSignaturesForAddressConfig, RpcTransactionLogsConfig,
RpcTransactionLogsFilter,
};
use solana_rpc_client_api::response::{
Response as RpcResponse, RpcBlockhash, RpcConfirmedTransactionStatusWithSignature,
@ -222,8 +223,6 @@ pub trait LiteRpc {
#[subscription(name = "slotUpdatesSubscribe" => "slotUpdatesNotification", unsubscribe="slotUpdatesUnsubscribe", item=SlotUpdate)]
async fn slot_updates_subscribe(&self) -> SubscriptionResult;
#[subscription(name = "voteSubscribe" => "voteNotification", unsubscribe="voteUnsubscribe", item=RpcVote)]
async fn vote_subscribe(&self) -> SubscriptionResult;
}