v0.3.13-pre.003-fix.001

crates/ksp-worker-raw-transaction-ingest-lib/unit_tests/runtime_resources.rs

@@ -1,5 +1,5 @@
 // file: crates/ksp-worker-raw-transaction-ingest-lib/unit_tests/runtime_resources.rs
-// version: 13
+// version: 14
 
 fn grpc_endpoint(cluster: &str) -> std::option::Option<ksp_onchain_transport_lib::YellowstoneGrpcEndpointSettings> {
     return grpc_endpoint_with_identity(cluster, "yellowstone-fixture", "fixture-provider");
@@ -826,8 +826,8 @@ async fn v0_3_13_pre_002_multi_source_activation_fails_closed_until_supervisor_t
     };
     let mut resources = crate::RawTransactionIngestRuntimeResources::new(first);
     assert!(resources.try_push_yellowstone_source(second).is_ok());
-    let error = match resources.into_yellowstone_source() {
-        std::result::Result::Ok(_) => return,
+    let error = match resources.validate_single_source_activation() {
+        std::result::Result::Ok(()) => return,
         std::result::Result::Err(error) => error,
     };
     assert_eq!(error.code(), crate::ERROR_CODE_RAW_TRANSACTION_INGEST_RUNTIME_INVALID);
@@ -1044,7 +1044,9 @@ async fn pre_005_block_hydration_uses_distinct_composite_method() {
         std::result::Result::Ok(value) => value,
         std::result::Result::Err(_) => return,
     };
+    let hydration = source.hydration_context();
     let provenance = match super::build_hydration_provenance(
+        &hydration,
         &settings,
         &signal,
         "fixture-http-provider",
@@ -1465,7 +1467,9 @@ async fn pre_004_status_provenance_and_future_source_timestamp_are_bounded_and_r
         std::result::Result::Ok(value) => value,
         std::result::Result::Err(_) => return,
     };
+    let hydration = source.hydration_context();
     let provenance = match super::build_hydration_provenance(
+        &hydration,
         &settings,
         &signal,
         "fixture-http-provider",
@@ -1777,8 +1781,6 @@ async fn v0_3_13_pre_003_standard_logs_reference_hydrates_once_to_exact_common_r
     };
     assert_eq!(ingress.provenance.protocol().as_str(), "solana_ws_http");
     assert_eq!(ingress.provenance.acquisition_method().as_str(), "logs_get_transaction");
-    assert_eq!(ingress.material.slot(), 42);
-    assert_eq!(ingress.material.signature(), &ksp_store_lib::RawTransactionSignature::new([0_u8; 64]));
     let (mut admission, sender) = crate::RawTransactionAdmission::new(1);
     if sender.send(ingress).await.is_err() {
         return;