new system using platform state and fixes

packages/rs-dpp/src/fee/default_costs/mod.rs

@@ -75,6 +75,7 @@ pub enum KnownCostItem {
 }
 
 impl KnownCostItem {
+    #[inline]
     pub fn lookup_cost(&self, fee_version: &FeeVersion) -> Credits {
         match self {
             KnownCostItem::StorageDiskUsageCreditPerByte => {

packages/rs-dpp/src/fee/fee_result/refunds.rs

@@ -39,7 +39,7 @@ impl FeeRefunds {
         storage_removal: I,
         current_epoch_index: EpochIndex,
         epochs_per_era: u16,
-        cached_fee_version: &CachedEpochIndexFeeVersions,
+        cached_fee_versions: &CachedEpochIndexFeeVersions,
     ) -> Result<Self, ProtocolError>
     where
         I: IntoIterator<Item = ([u8; 32], C)>,
@@ -58,7 +58,7 @@ impl FeeRefunds {
                         // TODO We should use multipliers
 
                         let credits: Credits = (bytes as Credits)
-                            .checked_mul(Epoch::new(current_epoch_index)?.cost_for_known_cost_item(cached_fee_version, StorageDiskUsageCreditPerByte))
+                            .checked_mul(Epoch::new(current_epoch_index)?.cost_for_known_cost_item(cached_fee_versions, StorageDiskUsageCreditPerByte))
                             .ok_or(ProtocolError::Overflow("storage written bytes cost overflow"))?;
 
                         let (amount, _) = calculate_storage_fee_refund_amount_and_leftovers(

packages/rs-drive-abci/src/execution/platform_events/block_fee_processing/add_process_epoch_change_operations/v0/mod.rs

@@ -171,6 +171,7 @@ mod tests {
         use crate::platform_types::platform_state::PlatformState;
         use dpp::block::block_info::BlockInfo;
         use dpp::fee::epoch::CreditsPerEpoch;
+        use dpp::prelude::CachedEpochIndexFeeVersions;
         use drive::drive::defaults::INITIAL_PROTOCOL_VERSION;
 
         /// Process and validate an epoch change
@@ -211,6 +212,7 @@ mod tests {
                         &BlockInfo::default(),
                         Some(transaction),
                         platform_version,
+                        &CachedEpochIndexFeeVersions::default(),
                     )
                     .expect("should apply batch");
             }
@@ -285,6 +287,7 @@ mod tests {
                     &BlockInfo::default(),
                     Some(transaction),
                     platform_version,
+                    &CachedEpochIndexFeeVersions::default(),
                 )
                 .expect("should apply batch");
 

packages/rs-drive-abci/src/execution/platform_events/block_fee_processing/process_block_fees/v0/mod.rs

@@ -36,6 +36,7 @@
 use std::option::Option::None;
 
 use dpp::block::epoch::Epoch;
+use dpp::prelude::CachedEpochIndexFeeVersions;
 use dpp::version::PlatformVersion;
 use drive::drive::batch::DriveOperation;
 use drive::drive::Drive;
@@ -180,6 +181,7 @@ impl<CoreRPCLike> Platform<CoreRPCLike> {
             &block_info.to_block_info(epoch_info.try_into()?),
             Some(transaction),
             platform_version,
+            &CachedEpochIndexFeeVersions::default(),
         )?;
 
         let outcome = processed_block_fees_outcome::v0::ProcessedBlockFeesOutcome {

packages/rs-drive-abci/src/execution/platform_events/core_based_updates/update_masternode_identities/update_masternode_identities/v0/mod.rs

@@ -16,6 +16,7 @@ use drive::drive::batch::IdentityOperationType::AddNewIdentity;
 use drive::grovedb::Transaction;
 use std::collections::BTreeMap;
 use tracing::Level;
+use dpp::prelude::CachedEpochIndexFeeVersions;
 
 impl<C> Platform<C>
 where
@@ -140,6 +141,7 @@ where
             block_info,
             Some(transaction),
             platform_version,
+            &CachedEpochIndexFeeVersions::default(),
         )?;
 
         let height = block_info.height;

packages/rs-drive-abci/src/execution/platform_events/fee_pool_inwards_distribution/add_distribute_block_fees_into_pools_operations/v0/mod.rs

@@ -75,6 +75,7 @@ impl<C> Platform<C> {
 mod tests {
     use super::*;
     use dpp::block::block_info::BlockInfo;
+    use dpp::prelude::CachedEpochIndexFeeVersions;
     use drive::drive::batch::grovedb_op_batch::GroveDbOpBatchV0Methods;
 
     use crate::test::helpers::setup::TestPlatformBuilder;
@@ -126,6 +127,7 @@ mod tests {
                 &BlockInfo::default(),
                 Some(&transaction),
                 platform_version,
+                &CachedEpochIndexFeeVersions::default(),
             )
             .expect("should apply batch");
 
@@ -194,6 +196,7 @@ mod tests {
                 &BlockInfo::default(),
                 Some(&transaction),
                 platform_version,
+                &CachedEpochIndexFeeVersions::default(),
             )
             .expect("should apply batch");
 

packages/rs-drive-abci/src/execution/platform_events/fee_pool_inwards_distribution/add_distribute_storage_fee_to_epochs_operations/v0/mod.rs

@@ -84,6 +84,7 @@ mod tests {
             perpetual_storage_epochs, CreditsPerEpoch, SignedCreditsPerEpoch, GENESIS_EPOCH_INDEX,
         };
         use dpp::fee::Credits;
+        use dpp::prelude::CachedEpochIndexFeeVersions;
         use drive::drive::batch::grovedb_op_batch::GroveDbOpBatchV0Methods;
         use drive::drive::batch::DriveOperation;
         use drive::drive::config::DriveConfig;
@@ -196,6 +197,7 @@ mod tests {
                     &BlockInfo::default(),
                     Some(&transaction),
                     platform_version,
+                    &CachedEpochIndexFeeVersions::default(),
                 )
                 .expect("should apply batch");
 

packages/rs-drive-abci/src/execution/platform_events/fee_pool_outwards_distribution/add_distribute_fees_from_oldest_unpaid_epoch_pool_to_proposers_operations/v0/mod.rs

@@ -91,6 +91,7 @@ impl<C> Platform<C> {
 mod tests {
     use super::*;
     use dpp::block::block_info::BlockInfo;
+    use dpp::prelude::CachedEpochIndexFeeVersions;
 
     use drive::common::test_utils::identities::create_test_masternode_identities_and_add_them_as_epoch_block_proposers;
 
@@ -203,6 +204,7 @@ mod tests {
                 &BlockInfo::default(),
                 Some(&transaction),
                 platform_version,
+                &CachedEpochIndexFeeVersions::default(),
             )
             .expect("should apply batch");
 

packages/rs-drive-abci/src/execution/platform_events/fee_pool_outwards_distribution/add_epoch_pool_to_proposers_payout_operations/v0/mod.rs

@@ -152,6 +152,7 @@ impl<C> Platform<C> {
             &BlockInfo::default(),
             Some(transaction),
             platform_version,
+            &None,
         )?;
 
         batch.push(DriveOperation::GroveDBOpBatch(operations));
@@ -180,6 +181,7 @@ mod tests {
         use drive::fee_pools::epochs::operations_factory::EpochOperations;
         use rust_decimal::Decimal;
         use rust_decimal_macros::dec;
+        use dpp::prelude::CachedEpochIndexFeeVersions;
 
         #[test]
         fn test_payout_to_proposers() {
@@ -281,6 +283,7 @@ mod tests {
                     &BlockInfo::default(),
                     Some(&transaction),
                     platform_version,
+                    &CachedEpochIndexFeeVersions::default(),
                 )
                 .expect("should apply batch");
 

packages/rs-drive-abci/src/execution/platform_events/initialization/create_genesis_state/v0/mod.rs

@@ -55,6 +55,7 @@ use drive::drive::object_size_info::{
 use drive::query::TransactionArg;
 use std::borrow::Cow;
 use std::collections::BTreeMap;
+use dpp::prelude::CachedEpochIndexFeeVersions;
 
 const DPNS_DASH_TLD_DOCUMENT_ID: [u8; 32] = [
     215, 242, 197, 63, 70, 169, 23, 171, 110, 91, 57, 162, 215, 188, 38, 11, 100, 146, 137, 69, 55,
@@ -189,6 +190,7 @@ impl<C> Platform<C> {
             &block_info,
             transaction,
             platform_version,
+            &CachedEpochIndexFeeVersions::default(),
         )?;
 
         Ok(())

packages/rs-drive-abci/src/execution/platform_events/state_transition_processing/execute_event/mod.rs

@@ -8,6 +8,7 @@ use crate::platform_types::platform::Platform;
 use crate::rpc::core::CoreRPCLike;
 use dpp::block::block_info::BlockInfo;
 use dpp::consensus::ConsensusError;
+use dpp::prelude::CachedEpochIndexFeeVersions;
 use dpp::version::PlatformVersion;
 use drive::grovedb::Transaction;
 
@@ -42,6 +43,7 @@ where
         block_info: &BlockInfo,
         transaction: &Transaction,
         platform_version: &PlatformVersion,
+        previous_fee_versions: &CachedEpochIndexFeeVersions,
     ) -> Result<EventExecutionResult, Error> {
         match platform_version
             .drive_abci
@@ -55,6 +57,7 @@ where
                 block_info,
                 transaction,
                 platform_version,
+                previous_fee_versions,
             ),
             version => Err(Error::Execution(ExecutionError::UnknownVersionMismatch {
                 method: "execute_event".to_string(),

packages/rs-drive-abci/src/execution/platform_events/state_transition_processing/execute_event/v0/mod.rs

@@ -11,6 +11,7 @@ use crate::rpc::core::CoreRPCLike;
 use dpp::block::block_info::BlockInfo;
 use dpp::consensus::ConsensusError;
 use dpp::fee::fee_result::FeeResult;
+use dpp::prelude::CachedEpochIndexFeeVersions;
 use dpp::version::PlatformVersion;
 use drive::drive::identity::update::apply_balance_change_outcome::ApplyBalanceChangeOutcomeV0Methods;
 use drive::grovedb::Transaction;
@@ -48,6 +49,7 @@ where
         block_info: &BlockInfo,
         transaction: &Transaction,
         platform_version: &PlatformVersion,
+        previous_fee_versions: &CachedEpochIndexFeeVersions,
     ) -> Result<EventExecutionResult, Error> {
         let maybe_fee_validation_result = match event {
             ExecutionEvent::PaidFromAssetLock { .. } | ExecutionEvent::Paid { .. } => {
@@ -89,6 +91,7 @@ where
                             block_info,
                             Some(transaction),
                             platform_version,
+                            previous_fee_versions,
                         )
                         .map_err(Error::Drive)?;
 
@@ -138,6 +141,7 @@ where
                         block_info,
                         Some(transaction),
                         platform_version,
+                        &CachedEpochIndexFeeVersions::default(),
                     )
                     .map_err(Error::Drive)?;
 
@@ -162,6 +166,7 @@ where
                         block_info,
                         Some(transaction),
                         platform_version,
+                        &CachedEpochIndexFeeVersions::default(),
                     )
                     .map_err(Error::Drive)?;
                 Ok(SuccessfulFreeExecution)

packages/rs-drive-abci/src/execution/platform_events/state_transition_processing/process_raw_state_transitions/v0/mod.rs

@@ -8,6 +8,7 @@ use dpp::fee::fee_result::FeeResult;
 use dpp::util::hash::hash_single;
 use dpp::validation::ConsensusValidationResult;
 use std::time::Instant;
+use dpp::prelude::CachedEpochIndexFeeVersions;
 
 use crate::execution::types::execution_event::ExecutionEvent;
 use crate::execution::types::state_transition_container::v0::{
@@ -70,6 +71,8 @@ where
             config: &self.config,
             core_rpc: &self.core_rpc,
         };
+
+        let previous_fee_versions = block_platform_state.previous_fee_versions();
 
         let state_transition_container =
             self.decode_raw_state_transitions(raw_state_transitions, platform_version)?;
@@ -115,6 +118,7 @@ where
                             block_info,
                             transaction,
                             platform_version,
+                            previous_fee_versions,
                         )
                         .unwrap_or_else(error_to_internal_error_execution_result)
                     })
@@ -199,6 +203,7 @@ where
         block_info: &BlockInfo,
         transaction: &Transaction,
         platform_version: &PlatformVersion,
+        previous_fee_versions: &CachedEpochIndexFeeVersions,
     ) -> Result<StateTransitionExecutionResult, StateTransitionAwareError<'a>> {
         // State Transition is invalid
         if !validation_result.is_valid() {
@@ -252,6 +257,7 @@ where
                     block_info,
                     transaction,
                     platform_version,
+                    previous_fee_versions,
                 )
                 .map_err(|error| StateTransitionAwareError {
                     error,
@@ -343,6 +349,7 @@ where
                 block_info,
                 transaction,
                 platform_version,
+                previous_fee_versions,
             )
             .map_err(|error| StateTransitionAwareError {
                 error,

packages/rs-drive-abci/src/execution/platform_events/state_transition_processing/validate_fees_of_event/v0/mod.rs

@@ -9,7 +9,7 @@ use dpp::consensus::state::identity::IdentityInsufficientBalanceError;
 use dpp::consensus::state::state_error::StateError;
 use dpp::fee::fee_result::FeeResult;
 
-use dpp::prelude::ConsensusValidationResult;
+use dpp::prelude::{CachedEpochIndexFeeVersions, ConsensusValidationResult};
 use dpp::version::PlatformVersion;
 
 use drive::grovedb::TransactionArg;
@@ -62,6 +62,7 @@ where
                         block_info,
                         transaction,
                         platform_version,
+                        &CachedEpochIndexFeeVersions::default(),
                     )
                     .map_err(Error::Drive)?;
 
@@ -113,6 +114,7 @@ where
                         block_info,
                         transaction,
                         platform_version,
+                        &CachedEpochIndexFeeVersions::default(),
                     )
                     .map_err(Error::Drive)?;
 

packages/rs-drive-abci/src/execution/platform_events/withdrawals/dequeue_and_build_unsigned_withdrawal_transactions/v0/mod.rs

@@ -25,6 +25,7 @@ use crate::{
     rpc::core::CoreRPCLike,
 };
 use dpp::errors::ProtocolError;
+use dpp::prelude::CachedEpochIndexFeeVersions;
 use drive::drive::config::DEFAULT_QUERY_LIMIT;
 
 const WITHDRAWAL_TRANSACTIONS_QUERY_LIMIT: u16 = 16;
@@ -108,6 +109,7 @@ where
             block_info,
             transaction,
             platform_version,
+            &CachedEpochIndexFeeVersions::default(),
         )?;
 
         Ok(UnsignedWithdrawalTxs::from_vec(

packages/rs-drive-abci/src/execution/platform_events/withdrawals/pool_withdrawals_into_transactions_queue/v0/mod.rs

@@ -3,6 +3,7 @@ use dpp::block::block_info::BlockInfo;
 use dpp::data_contract::accessors::v0::DataContractV0Getters;
 use dpp::document::document_methods::DocumentMethodsV0;
 use dpp::document::{DocumentV0Getters, DocumentV0Setters};
+use dpp::prelude::CachedEpochIndexFeeVersions;
 use dpp::version::PlatformVersion;
 
 use drive::drive::identity::withdrawals::WithdrawalTransactionIndexAndBytes;
@@ -131,6 +132,7 @@ where
             block_info,
             transaction,
             platform_version,
+            &CachedEpochIndexFeeVersions::default(),
         )?;
 
         Ok(())

packages/rs-drive-abci/src/execution/platform_events/withdrawals/update_broadcasted_withdrawal_statuses/v0/mod.rs

@@ -9,6 +9,7 @@ use dpp::system_data_contracts::withdrawals_contract::v1::document_types::withdr
 use dpp::version::PlatformVersion;
 use itertools::Itertools;
 use std::collections::HashSet;
+use dpp::prelude::CachedEpochIndexFeeVersions;
 
 use drive::drive::batch::DriveOperation;
 use drive::drive::config::DEFAULT_QUERY_LIMIT;
@@ -155,6 +156,7 @@ where
             block_info,
             transaction.into(),
             platform_version,
+            &CachedEpochIndexFeeVersions::default(),
         )?;
 
         Ok(())

packages/rs-drive-abci/src/query/mod.rs

@@ -30,6 +30,7 @@ mod tests {
     use platform_version::version::PlatformVersion;
     use std::borrow::Cow;
     use std::sync::Arc;
+    use dpp::prelude::CachedEpochIndexFeeVersions;
 
     pub fn setup_platform<'a>(
         with_genesis_state: bool,
@@ -71,7 +72,7 @@ mod tests {
 
         platform
             .drive
-            .apply_drive_operations(vec![operation], true, &block_info, None, platform_version)
+            .apply_drive_operations(vec![operation], true, &block_info, None, platform_version, &CachedEpochIndexFeeVersions::default())
             .expect("expected to apply drive operations");
     }
 

packages/rs-drive/src/drive/batch/drive_op_batch/document.rs

@@ -12,7 +12,7 @@ use dpp::data_contract::accessors::v0::DataContractV0Getters;
 use dpp::data_contract::document_type::DocumentTypeRef;
 use dpp::data_contract::DataContract;
 use dpp::document::Document;
-use dpp::prelude::Identifier;
+use dpp::prelude::{CachedEpochIndexFeeVersions, Identifier};
 
 use dpp::system_data_contracts::withdrawals_contract::v1::document_types::withdrawal;
 
@@ -102,6 +102,7 @@ impl DriveLowLevelOperationConverter for DocumentOperationType<'_> {
         block_info: &BlockInfo,
         transaction: TransactionArg,
         platform_version: &PlatformVersion,
+        previous_fee_versions: &CachedEpochIndexFeeVersions,
     ) -> Result<Vec<LowLevelDriveOperation>, Error> {
         match self {
             DocumentOperationType::AddDocument {