Storage Migrator: Benchmarking

core/main/src/bootstrap/boot.rs

@@ -35,6 +35,7 @@ use super::{
     start_app_manager_step::StartAppManagerStep,
     start_communication_broker::{StartCommunicationBroker, StartOtherBrokers},
     start_fbgateway_step::FireboltGatewayStep,
+    start_storage_migrator_step::StartStorageMigratorStep,
     start_ws_step::StartWsStep,
 };
 /// Starts up Ripple uses `PlatformState` to manage State
@@ -72,6 +73,7 @@ pub async fn boot(state: BootstrapState) -> RippleResponse {
     execute_step(LoadDistributorValuesStep, &bootstrap).await?;
     execute_step(CheckLauncherStep, &bootstrap).await?;
     execute_step(StartWsStep, &bootstrap).await?;
+    execute_step(StartStorageMigratorStep, &bootstrap).await?;
     execute_step(FireboltGatewayStep, &bootstrap).await?;
     Ok(())
 }

core/main/src/bootstrap/mod.rs

@@ -22,4 +22,5 @@ pub mod setup_extn_client_step;
 pub mod start_app_manager_step;
 pub mod start_communication_broker;
 pub mod start_fbgateway_step;
+pub mod start_storage_migrator_step;
 pub mod start_ws_step;

core/main/src/bootstrap/start_storage_migrator_step.rs

@@ -0,0 +1,39 @@
+// Copyright 2023 Comcast Cable Communications Management, LLC
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+// SPDX-License-Identifier: Apache-2.0
+//
+
+use ripple_sdk::async_trait::async_trait;
+use ripple_sdk::{framework::bootstrap::Bootstep, tokio, utils::error::RippleError};
+
+use crate::processor::storage::storage_migrator::StorageMigrator;
+use crate::state::bootstrap_state::BootstrapState;
+
+pub struct StartStorageMigratorStep;
+
+#[async_trait]
+impl Bootstep<BootstrapState> for StartStorageMigratorStep {
+    fn get_name(&self) -> String {
+        "StartStorageMigrator".into()
+    }
+
+    async fn setup(&self, bootstrap_state: BootstrapState) -> Result<(), RippleError> {
+        tokio::spawn(async move {
+            let mut migrator = StorageMigrator::new(&bootstrap_state.platform_state);
+            migrator.migration_test().await;
+        });
+        Ok(())
+    }
+}

core/main/src/processor/storage/mod.rs

@@ -19,3 +19,4 @@ pub mod default_storage_properties;
 pub mod storage_manager;
 pub mod storage_manager_processor;
 pub mod storage_manager_utils;
+pub mod storage_migrator;