diff --git a/gso/migrations/versions/2023-12-27_b689d4636694_add_base_config_redeployment_workflow.py b/gso/migrations/versions/2023-12-27_b689d4636694_add_base_config_redeployment_workflow.py
new file mode 100644
index 0000000000000000000000000000000000000000..2fd52cab237769f8550cb62d3fe16e6e9b3cbb18
--- /dev/null
+++ b/gso/migrations/versions/2023-12-27_b689d4636694_add_base_config_redeployment_workflow.py
@@ -0,0 +1,39 @@
+"""Add base config redeployment workflow.
+
+Revision ID: b689d4636694
+Revises: 815033570ad7
+Create Date: 2023-12-27 15:20:40.522053
+
+"""
+import sqlalchemy as sa
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision = 'b689d4636694'
+down_revision = '815033570ad7'
+branch_labels = None
+depends_on = None
+
+
+from orchestrator.migrations.helpers import create_workflow, delete_workflow
+
+new_workflows = [
+ {
+ "name": "redeploy_base_config",
+ "target": "MODIFY",
+ "description": "Redeploy base config",
+ "product_type": "Router"
+ }
+]
+
+
+def upgrade() -> None:
+ conn = op.get_bind()
+ for workflow in new_workflows:
+ create_workflow(conn, workflow)
+
+
+def downgrade() -> None:
+ conn = op.get_bind()
+ for workflow in new_workflows:
+ delete_workflow(conn, workflow["name"])
diff --git a/gso/translations/en-GB.json b/gso/translations/en-GB.json
index 6b26c07bd7ec6ca7ff6583c6c5af3656b43151ca..230d50eac8ab087ab474a413bfb055ea61587e0f 100644
--- a/gso/translations/en-GB.json
+++ b/gso/translations/en-GB.json
@@ -36,9 +36,10 @@
}
},
"workflow": {
- "modify_isis_metric": "Modify the ISIS metric",
- "modify_trunk_interface": "Modify IP Trunk interface",
- "migrate_iptrunk": "Migrate IP Trunk",
- "confirm_info": "Please verify this form looks correct."
- }
+ "confirm_info": "Please verify this form looks correct.",
+ "migrate_iptrunk": "Migrate IP Trunk",
+ "modify_isis_metric": "Modify the ISIS metric",
+ "modify_trunk_interface": "Modify IP Trunk interface",
+ "redeploy_base_config": "Redeploy base config"
+ }
}
diff --git a/gso/workflows/__init__.py b/gso/workflows/__init__.py
index 845f5c2babb89502a3f18022b46eaed13d3a8f46..06be2f18658fd5a382ab3616c46bfc5f8d21c947 100644
--- a/gso/workflows/__init__.py
+++ b/gso/workflows/__init__.py
@@ -8,6 +8,7 @@ LazyWorkflowInstance("gso.workflows.iptrunk.modify_trunk_interface", "modify_tru
LazyWorkflowInstance("gso.workflows.iptrunk.migrate_iptrunk", "migrate_iptrunk")
LazyWorkflowInstance("gso.workflows.iptrunk.terminate_iptrunk", "terminate_iptrunk")
LazyWorkflowInstance("gso.workflows.router.create_router", "create_router")
+LazyWorkflowInstance("gso.workflows.router.redeploy_base_config", "redeploy_base_config")
LazyWorkflowInstance("gso.workflows.router.terminate_router", "terminate_router")
LazyWorkflowInstance("gso.workflows.site.create_site", "create_site")
LazyWorkflowInstance("gso.workflows.site.modify_site", "modify_site")
diff --git a/gso/workflows/router/redeploy_base_config.py b/gso/workflows/router/redeploy_base_config.py
new file mode 100644
index 0000000000000000000000000000000000000000..9c9fc3efeb4d4b9fafdc050140eb856dbe3f103d
--- /dev/null
+++ b/gso/workflows/router/redeploy_base_config.py
@@ -0,0 +1,47 @@
+"""A workflow that re-deploys base config on a router."""
+
+from orchestrator.forms import FormPage
+from orchestrator.forms.validators import Label
+from orchestrator.targets import Target
+from orchestrator.types import FormGenerator, UUIDstr
+from orchestrator.workflow import StepList, done, init, workflow
+from orchestrator.workflows.steps import resync, store_process_subscription, unsync
+from orchestrator.workflows.utils import wrap_modify_initial_input_form
+
+from gso.products.product_types.router import Router
+from gso.services.provisioning_proxy import pp_interaction
+from gso.utils.workflow_steps import deploy_base_config_dry, deploy_base_config_real
+
+
+def _initial_input_form(subscription_id: UUIDstr) -> FormGenerator:
+ router = Router.from_subscription(subscription_id)
+
+ class RedeployBaseConfigForm(FormPage):
+ info_label: Label = f"Redeploy base config on {router.router.router_fqdn}?" # type: ignore[assignment]
+ tt_number: str
+
+ user_input = yield RedeployBaseConfigForm
+
+ return user_input.dict() | {"subscription": router}
+
+
+@workflow(
+ "Redeploy base config",
+ initial_input_form=wrap_modify_initial_input_form(_initial_input_form),
+ target=Target.MODIFY,
+)
+def redeploy_base_config() -> StepList:
+ """Redeploy base config on an existing router.
+
+ * Perform a dry run of deployment
+ * Redeploy base config
+ """
+ return (
+ init
+ >> store_process_subscription(Target.MODIFY)
+ >> unsync
+ >> pp_interaction(deploy_base_config_dry)
+ >> pp_interaction(deploy_base_config_real)
+ >> resync
+ >> done
+ )
diff --git a/test/workflows/router/test_redeploy_base_config.py b/test/workflows/router/test_redeploy_base_config.py
new file mode 100644
index 0000000000000000000000000000000000000000..026999d0e9b23f590c5e434aba24d56e4bc47e91
--- /dev/null
+++ b/test/workflows/router/test_redeploy_base_config.py
@@ -0,0 +1,38 @@
+from unittest.mock import patch
+
+import pytest
+
+from gso.products import Router
+from test.workflows import (
+ assert_complete,
+ assert_pp_interaction_success,
+ extract_state,
+ run_workflow,
+)
+
+
+@pytest.mark.workflow()
+@patch("gso.services.provisioning_proxy._send_request")
+def test_redeploy_base_config_success(
+ mock_provision_router,
+ nokia_router_subscription_factory,
+ faker,
+):
+ # Set up mock return values
+ product_id = nokia_router_subscription_factory()
+
+ # Run workflow
+ initial_input_data = [{"subscription_id": product_id}, {"tt_number": faker.tt_number()}]
+ result, process_stat, step_log = run_workflow("redeploy_base_config", initial_input_data)
+
+ for _ in range(2):
+ result, step_log = assert_pp_interaction_success(result, process_stat, step_log)
+
+ assert_complete(result)
+
+ state = extract_state(result)
+ subscription_id = state["subscription_id"]
+ subscription = Router.from_subscription(subscription_id)
+
+ assert subscription.status == "active"
+ assert mock_provision_router.call_count == 2