Sasedev/khadhroony-solana-project
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

v0.2.2-pre.005

Browse Source
This commit is contained in:
SinuS von SifriduS
2026-08-18 08:17:10 +02:00
parent 1d1bc6a4d6
commit 83cb861e54
16 changed files with 662 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

139
crates/ksp-onchain-transport-lib/src/rpc_cluster.rs
View File

@@ -1,5 +1,5 @@
// file: crates/ksp-onchain-transport-lib/src/rpc_cluster.rs
// version: 2
// version: 3
/// Contact information returned for one cluster node.
#[derive(Clone, Debug, Eq, PartialEq)]
@@ -99,7 +99,6 @@ impl SolanaClusterNode {
}
/// Decodes one cluster-node contact record from the Solana JSON wire shape.
#[cfg(test)]
pub(crate) fn decode_wire(method: &str, value: serde_json::Value) -> ksp_core_lib::Result<Self> {
let decoded = crate::decode_wire_json::<WireClusterNode>(method, value);
let wire = match decoded {
@@ -175,7 +174,6 @@ impl SolanaEpochInfo {
}
/// Decodes epoch information from the Solana JSON wire shape.
#[cfg(test)]
pub(crate) fn decode_wire(method: &str, value: serde_json::Value) -> ksp_core_lib::Result<Self> {
let decoded = crate::decode_wire_json::<WireEpochInfo>(method, value);
return match decoded {
@@ -230,7 +228,6 @@ impl SolanaEpochSchedule {
}
/// Decodes an epoch schedule from the Solana JSON wire shape.
#[cfg(test)]
pub(crate) fn decode_wire(method: &str, value: serde_json::Value) -> ksp_core_lib::Result<Self> {
let decoded = crate::decode_wire_json::<WireEpochSchedule>(method, value);
return match decoded {
@@ -266,7 +263,6 @@ impl SolanaSnapshotSlotInfo {
}
/// Decodes snapshot-slot information from the Solana JSON wire shape.
#[cfg(test)]
pub(crate) fn decode_wire(method: &str, value: serde_json::Value) -> ksp_core_lib::Result<Self> {
let decoded = crate::decode_wire_json::<WireSnapshotSlotInfo>(method, value);
return match decoded {
@@ -617,7 +613,135 @@ impl SolanaVoteAccountStatus {
}
}
#[cfg(test)]
#[derive(serde::Deserialize)]
struct WireIdentity {
identity: std::string::String,
}
impl crate::HttpTransportPool {
/// Executes typed `getClusterNodes` through the common KSP HTTP transport path.
pub async fn get_cluster_nodes(&self, role: &crate::HttpRoleName) -> ksp_core_lib::Result<std::vec::Vec<crate::SolanaClusterNode>> {
let value = self.execute_cluster_simple_rpc("getClusterNodes", role, std::vec::Vec::new()).await;
let value = match value {
std::result::Result::Ok(value) => value,
std::result::Result::Err(error) => return std::result::Result::Err(error),
};
let decoded = crate::decode_wire_json::<std::vec::Vec<serde_json::Value>>("getClusterNodes", value);
let values = match decoded {
std::result::Result::Ok(values) => values,
std::result::Result::Err(error) => return std::result::Result::Err(error),
};
let mut nodes = std::vec::Vec::with_capacity(values.len());
for value in values {
let node = crate::SolanaClusterNode::decode_wire("getClusterNodes", value);
match node {
std::result::Result::Ok(node) => nodes.push(node),
std::result::Result::Err(error) => return std::result::Result::Err(error),
}
}
return std::result::Result::Ok(nodes);
}
/// Executes typed `getEpochInfo` through the common KSP HTTP transport path.
pub async fn get_epoch_info(
&self,
role: &crate::HttpRoleName,
config: std::option::Option<&crate::SolanaContextConfig>,
) -> ksp_core_lib::Result<crate::SolanaEpochInfo> {
let mut params = std::vec::Vec::new();
if let std::option::Option::Some(config) = config
&& (config.commitment().is_some() || config.min_context_slot().is_some())
{
params.push(config.to_json_value());
}
let value = self.execute_cluster_simple_rpc("getEpochInfo", role, params).await;
return match value {
std::result::Result::Ok(value) => crate::SolanaEpochInfo::decode_wire("getEpochInfo", value),
std::result::Result::Err(error) => std::result::Result::Err(error),
};
}
/// Executes typed `getEpochSchedule` through the common KSP HTTP transport path.
pub async fn get_epoch_schedule(&self, role: &crate::HttpRoleName) -> ksp_core_lib::Result<crate::SolanaEpochSchedule> {
let value = self.execute_cluster_simple_rpc("getEpochSchedule", role, std::vec::Vec::new()).await;
return match value {
std::result::Result::Ok(value) => crate::SolanaEpochSchedule::decode_wire("getEpochSchedule", value),
std::result::Result::Err(error) => std::result::Result::Err(error),
};
}
/// Executes typed `getHighestSnapshotSlot` through the common KSP HTTP transport path.
pub async fn get_highest_snapshot_slot(&self, role: &crate::HttpRoleName) -> ksp_core_lib::Result<crate::SolanaSnapshotSlotInfo> {
let value = self.execute_cluster_simple_rpc("getHighestSnapshotSlot", role, std::vec::Vec::new()).await;
return match value {
std::result::Result::Ok(value) => crate::SolanaSnapshotSlotInfo::decode_wire("getHighestSnapshotSlot", value),
std::result::Result::Err(error) => std::result::Result::Err(error),
};
}
/// Executes typed `getIdentity` through the common KSP HTTP transport path.
pub async fn get_identity(&self, role: &crate::HttpRoleName) -> ksp_core_lib::Result<ksp_core_lib::Pubkey> {
let value = self.execute_cluster_simple_rpc("getIdentity", role, std::vec::Vec::new()).await;
let value = match value {
std::result::Result::Ok(value) => value,
std::result::Result::Err(error) => return std::result::Result::Err(error),
};
let decoded = crate::decode_wire_json::<WireIdentity>("getIdentity", value);
let wire = match decoded {
std::result::Result::Ok(wire) => wire,
std::result::Result::Err(error) => return std::result::Result::Err(error),
};
return crate::parse_wire_pubkey("getIdentity", "identity", wire.identity.as_str());
}
/// Executes typed `getMaxRetransmitSlot` through the common KSP HTTP transport path.
pub async fn get_max_retransmit_slot(&self, role: &crate::HttpRoleName) -> ksp_core_lib::Result<u64> {
return self.get_cluster_simple_slot("getMaxRetransmitSlot", role).await;
}
/// Executes typed `getMaxShredInsertSlot` through the common KSP HTTP transport path.
pub async fn get_max_shred_insert_slot(&self, role: &crate::HttpRoleName) -> ksp_core_lib::Result<u64> {
return self.get_cluster_simple_slot("getMaxShredInsertSlot", role).await;
}
async fn get_cluster_simple_slot(&self, method_name: &'static str, role: &crate::HttpRoleName) -> ksp_core_lib::Result<u64> {
let value = self.execute_cluster_simple_rpc(method_name, role, std::vec::Vec::new()).await;
return match value {
std::result::Result::Ok(value) => crate::decode_wire_json::<u64>(method_name, value),
std::result::Result::Err(error) => std::result::Result::Err(error),
};
}
async fn execute_cluster_simple_rpc(
&self,
method_name: &'static str,
role: &crate::HttpRoleName,
params: std::vec::Vec<serde_json::Value>,
) -> ksp_core_lib::Result<serde_json::Value> {
let method = cluster_descriptor(method_name);
let method = match method {
std::result::Result::Ok(method) => method,
std::result::Result::Err(error) => return std::result::Result::Err(error),
};
return self.execute_standard_rpc(role, method, params).await;
}
}
fn cluster_descriptor(method: &str) -> ksp_core_lib::Result<&'static crate::HttpRpcMethodDescriptor> {
let descriptor = crate::find_http_rpc_method(method);
return match descriptor {
std::option::Option::Some(descriptor)
if descriptor.category() == crate::HttpRpcCategory::Cluster && descriptor.coverage_release() == crate::HttpRpcCoverageRelease::V0_2_2 =>
{
std::result::Result::Ok(descriptor)
},
_ => std::result::Result::Err(
ksp_core_lib::Error::new(crate::ERROR_CODE_INVALID_RESPONSE, "typed Cluster descriptor is missing from the audited 0.2.2 registry")
.with_context("rpc_method", method),
),
};
}
#[derive(serde::Deserialize)]
#[serde(rename_all = "camelCase")]
struct WireClusterNode {
@@ -652,7 +776,6 @@ struct WireClusterNode {
client_id: std::option::Option<std::string::String>,
}
#[cfg(test)]
#[derive(serde::Deserialize)]
#[serde(rename_all = "camelCase")]
struct WireEpochInfo {
@@ -664,7 +787,6 @@ struct WireEpochInfo {
transaction_count: std::option::Option<u64>,
}
#[cfg(test)]
#[derive(serde::Deserialize)]
#[serde(rename_all = "camelCase")]
struct WireEpochSchedule {
@@ -675,7 +797,6 @@ struct WireEpochSchedule {
warmup: bool,
}
#[cfg(test)]
#[derive(serde::Deserialize)]
struct WireSnapshotSlotInfo {
full: u64,