refactor: ♻️ Separate MSP and BSP specific functionalities in Blockchain Service (Moonsong-Labs#386)

* feat: 🚧 Add new files `handler_msp` and `handler_bsp`

* refactor: ♻️ Move BSP and MSP specific flow out of `handler.rs`

* fix: 🚨 Move bsp/msp specific event handling away from handler.rs after merge

* feat: 🚧 Separate `check_pending_forest_root_writes` into MSP and BSP specific functions

* feat: 🚧 Make commands BSP/MSP specific fail if sent when managing the wrong provider

* feat: 🚧 Move `forest_root_write_lock` and `forest_root_snapshots` out of handler and into MSP/BSP specific handlers

* refactor: 🚧 Move events processing for forest root changing into MSP/BSP specific handlers

* refactor: 🚧 Move common events handling into a separate function

* refactor: ♻️ Finish separating MSP/BSP specific functionality in Blockchain Service

* fix: 🚨 Compilation fixes after merge

* fix: 🚨 Fix compilation and clippy issues

* refactor: 🚚 Rename `get_provider_id` to `sync_provider_id`

Author: ffarall

client/blockchain-service/src/capacity_manager.rs

@@ -6,12 +6,12 @@ use pallet_storage_providers_runtime_api::{
     QueryEarliestChangeCapacityBlockError, QueryStorageProviderCapacityError, StorageProvidersApi,
 };
 use sc_client_api::HeaderBackend;
-use shc_common::types::{BlockNumber, StorageData, StorageProviderId};
+use shc_common::types::{BlockNumber, StorageData};
 use shc_forest_manager::traits::ForestStorageHandler;
 use sp_api::ProvideRuntimeApi;
 use sp_core::H256;
 
-use crate::{transaction::SubmittedTransaction, BlockchainService};
+use crate::{transaction::SubmittedTransaction, types::ManagedProvider, BlockchainService};
 
 const LOG_TARGET: &str = "blockchain-service-capacity-manager";
 
@@ -352,15 +352,15 @@ where
         };
 
         // Get provider ID
-        let Some(storage_provider_id) = &self.provider_id else {
+        let Some(managed_provider) = &self.maybe_managed_provider else {
             return Err(anyhow!(
                 "No provider ID set, cannot process capacity requests"
             ));
         };
 
-        let inner_provider_id = match storage_provider_id {
-            StorageProviderId::MainStorageProvider(id)
-            | StorageProviderId::BackupStorageProvider(id) => id,
+        let provider_id = match managed_provider {
+            ManagedProvider::Msp(msp_handler) => msp_handler.msp_id,
+            ManagedProvider::Bsp(bsp_handler) => bsp_handler.bsp_id,
         };
 
         // Get current block hash
@@ -370,14 +370,14 @@ where
         let current_capacity = self
             .client
             .runtime_api()
-            .query_storage_provider_capacity(current_block_hash, inner_provider_id)
+            .query_storage_provider_capacity(current_block_hash, &provider_id)
             .unwrap_or_else(|_| Err(QueryStorageProviderCapacityError::InternalError))
             .map_err(|e| anyhow!("Failed to query current storage capacity: {:?}", e))?;
 
         if current_capacity >= capacity_manager.max_capacity_allowed() {
             return Err(anyhow!("Provider already at maximum capacity"));
         }
 
-        Ok((current_block_hash, current_capacity, *inner_provider_id))
+        Ok((current_block_hash, current_capacity, provider_id))
     }
 }