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

v0.3.10-pre.006-fix.001

Browse Source
This commit is contained in:
SinuS von SifriduS
2026-09-07 23:56:48 +02:00
parent f7c57f21c5
commit 919b4ed46d
13 changed files with 319 additions and 202 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
crates/ksp-job-backfill-lib/tests/yellowstone_raw_parity.rs
View File

@@ -1,5 +1,5 @@
// file: crates/ksp-job-backfill-lib/tests/yellowstone_raw_parity.rs
// version: 1
// version: 2
struct FixtureStream<T> {
receiver: tokio::sync::mpsc::Receiver<T>,
@@ -320,10 +320,14 @@ fn solana_pubkey_bytes(value: &ksp_core_lib::Pubkey) -> [u8; 32] {
}
fn projection_error(field: &'static str) -> ksp_core_lib::Error {
return ksp_core_lib::Error::new("KSP-RAW-TRANSACTION-PRE-006-PROJECTION", "Yellowstone fixture field does not fit common wire")
return ksp_core_lib::Error::new(ksp_core_lib::ErrorCode::new("test", "yellowstone_raw_projection"), "Yellowstone fixture field does not fit common wire")
.with_context("field", field);
}
fn error_code_text(error: &ksp_core_lib::Error) -> std::string::String {
return format!("{}.{}", error.code().domain(), error.code().code());
}
fn expected_v1_wire() -> ksp_raw_transaction_lib::RawSolanaTransactionWire {
let message = ksp_raw_transaction_lib::RawSolanaTransactionMessage::new(
ksp_raw_transaction_lib::RawSolanaMessageVersion::V1,
@@ -358,14 +362,14 @@ async fn pre_006_yellowstone_transaction_and_block_preserve_exact_v1_wire_and_bl
let settings = match fixture_settings(server.endpoint_url.as_str()) {
std::result::Result::Ok(value) => value,
std::result::Result::Err(error) => {
fail_test(format!("fixture settings failed: {}", error.code()));
fail_test(format!("fixture settings failed: {}", error_code_text(&error)));
return;
},
};
let channel = match ksp_onchain_transport_lib::YellowstoneGrpcChannel::connect(&settings).await {
std::result::Result::Ok(value) => value,
std::result::Result::Err(error) => {
fail_test(format!("fixture channel connect failed: {}", error.code()));
fail_test(format!("fixture channel connect failed: {}", error_code_text(&error)));
return;
},
};
@@ -373,14 +377,14 @@ async fn pre_006_yellowstone_transaction_and_block_preserve_exact_v1_wire_and_bl
let mut session = match channel.open_standard_subscribe(request).await {
std::result::Result::Ok(value) => value,
std::result::Result::Err(error) => {
fail_test(format!("fixture subscribe failed: {}", error.code()));
fail_test(format!("fixture subscribe failed: {}", error_code_text(&error)));
return;
},
};
let expected = match ksp_raw_transaction_lib::serialize_solana_transaction_wire(&expected_v1_wire()) {
std::result::Result::Ok(value) => value,
std::result::Result::Err(error) => {
fail_test(format!("expected V1 wire serialization failed: {}", error.code()));
fail_test(format!("expected V1 wire serialization failed: {}", error_code_text(&error)));
return;
},
};
@@ -391,7 +395,7 @@ async fn pre_006_yellowstone_transaction_and_block_preserve_exact_v1_wire_and_bl
return;
},
std::result::Result::Err(error) => {
fail_test(format!("transaction update decode failed: {}", error.code()));
fail_test(format!("transaction update decode failed: {}", error_code_text(&error)));
return;
},
};
@@ -408,14 +412,14 @@ async fn pre_006_yellowstone_transaction_and_block_preserve_exact_v1_wire_and_bl
let transaction_wire = match project_wire(transaction.transaction().transaction()) {
std::result::Result::Ok(value) => value,
std::result::Result::Err(error) => {
fail_test(format!("transaction projection failed: {}", error.code()));
fail_test(format!("transaction projection failed: {}", error_code_text(&error)));
return;
},
};
let transaction_bytes = match ksp_raw_transaction_lib::serialize_solana_transaction_wire(&transaction_wire) {
std::result::Result::Ok(value) => value,
std::result::Result::Err(error) => {
fail_test(format!("transaction V1 wire serialization failed: {}", error.code()));
fail_test(format!("transaction V1 wire serialization failed: {}", error_code_text(&error)));
return;
},
};
@@ -427,7 +431,7 @@ async fn pre_006_yellowstone_transaction_and_block_preserve_exact_v1_wire_and_bl
return;
},
std::result::Result::Err(error) => {
fail_test(format!("block update decode failed: {}", error.code()));
fail_test(format!("block update decode failed: {}", error_code_text(&error)));
return;
},
};
@@ -445,14 +449,14 @@ async fn pre_006_yellowstone_transaction_and_block_preserve_exact_v1_wire_and_bl
let block_wire = match project_wire(block.transactions()[0].transaction()) {
std::result::Result::Ok(value) => value,
std::result::Result::Err(error) => {
fail_test(format!("block transaction projection failed: {}", error.code()));
fail_test(format!("block transaction projection failed: {}", error_code_text(&error)));
return;
},
};
let block_bytes = match ksp_raw_transaction_lib::serialize_solana_transaction_wire(&block_wire) {
std::result::Result::Ok(value) => value,
std::result::Result::Err(error) => {
fail_test(format!("block V1 wire serialization failed: {}", error.code()));
fail_test(format!("block V1 wire serialization failed: {}", error_code_text(&error)));
return;
},
};