diff --git a/cluster-endpoints/src/grpc_subscription.rs b/cluster-endpoints/src/grpc_subscription.rs index 4e012de1..fe88f699 100644 --- a/cluster-endpoints/src/grpc_subscription.rs +++ b/cluster-endpoints/src/grpc_subscription.rs @@ -193,7 +193,7 @@ fn process_block( cu_requested, prioritization_fees, cu_consumed: compute_units_consumed, - blockhash: message.recent_blockhash().to_string(), + recent_blockhash: message.recent_blockhash().to_string(), message: BinaryEncoding::Base64.encode(message.serialize()), }) }) diff --git a/core/src/structures/produced_block.rs b/core/src/structures/produced_block.rs index a2ce31da..3d3d0413 100644 --- a/core/src/structures/produced_block.rs +++ b/core/src/structures/produced_block.rs @@ -18,7 +18,7 @@ pub struct TransactionInfo { pub cu_requested: Option, pub prioritization_fees: Option, pub cu_consumed: Option, - pub blockhash: String, + pub recent_blockhash: String, pub message: String, } @@ -132,7 +132,7 @@ impl ProducedBlock { cu_requested, prioritization_fees, cu_consumed, - blockhash, + recent_blockhash: blockhash, message, }) }) diff --git a/services/src/data_caching_service.rs b/services/src/data_caching_service.rs index 402aec27..dc4ce4f7 100644 --- a/services/src/data_caching_service.rs +++ b/services/src/data_caching_service.rs @@ -67,7 +67,7 @@ impl DataCachingService { for tx in block.transactions { let block_info = data_cache .block_information_store - .get_block_info(&tx.blockhash); + .get_block_info(&tx.recent_blockhash); let last_valid_blockheight = if let Some(block_info) = block_info { block_info.last_valid_blockheight } else {