v0.3.10-pre.005-fix.001

This commit is contained in:
2026-09-06 22:30:27 +02:00
parent 0683b70abe
commit ba574f3052
5 changed files with 138 additions and 7 deletions

View File

@@ -1,12 +1,12 @@
// file: crates/ksp-job-backfill-lib/tests/ws_raw_parity.rs
// version: 1
// version: 2
//! Cross-layer parity canaries qualifying standard `blockSubscribe` and Helius `transactionSubscribe` for RAW v1 ingestion.
use futures_util::SinkExt; // rust-rules: trait-import
use futures_util::StreamExt; // rust-rules: trait-import
const FIXTURE_BLOCK_TIME: i64 = 1_787_072_400;
const FIXTURE_BLOCK_TIME_MILLIS: u64 = 1_787_072_400_000;
const FIXTURE_SLOT: u64 = 430_000_123;
const ZERO_SIGNATURE_TEXT: &str = "1111111111111111111111111111111111111111111111111111111111111111";
const ZERO_TRANSACTION_BASE64: &str = "AQAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA";
@@ -420,7 +420,7 @@ async fn pre_005_helius_full_base64_without_block_time_and_version_requires_http
assert_eq!(helius_raw.reference(), http_raw.reference());
assert_eq!(helius_raw.slot(), http_raw.slot());
assert!(helius_raw.block_time().is_none());
assert_eq!(http_raw.block_time().map(|value| return value.unix_millis()), std::option::Option::Some(FIXTURE_BLOCK_TIME * 1_000));
assert_eq!(http_raw.block_time().map(|value| return value.unix_millis()), std::option::Option::Some(FIXTURE_BLOCK_TIME_MILLIS),);
assert_ne!(helius_raw.block_time(), http_raw.block_time());
assert_ne!(helius_raw.payload().bytes(), http_raw.payload().bytes());
assert_ne!(helius_raw.payload().content_hash(), http_raw.payload().content_hash());