Refactor AzureService.publish

Refactor the code from `AzureService.publish` by decoupling some of its
internals into privdate methods.

The goal here is to clean up the code and make it more legible.

Refers to SPSTRAT-595

Signed-off-by: Jonathan Gangi <[email protected]>

Author: JAVGan

cloudpub/ms_azure/service.py

@@ -18,6 +18,7 @@
     AzureResource,
     ConfigureStatus,
     CustomerLeads,
+    DiskVersion,
     Listing,
     ListingAsset,
     ListingTrailer,
@@ -38,6 +39,7 @@
 from cloudpub.ms_azure.session import PartnerPortalSession
 from cloudpub.ms_azure.utils import (
     AzurePublishingMetadata,
+    TechnicalConfigLookUpData,
     create_disk_version_from_scratch,
     is_azure_job_not_complete,
     is_sas_present,
@@ -594,6 +596,90 @@ def _publish_live(self, product: Product, product_name: str) -> None:
             )
             raise RuntimeError(failure_msg)
 
+    def _overwrite_disk_version(
+        self,
+        metadata: AzurePublishingMetadata,
+        product_name: str,
+        plan_name: str,
+        source: VMImageSource,
+    ) -> TechnicalConfigLookUpData:
+        product, plan, tgt = self.get_product_plan_by_name(product_name, plan_name)
+        log.warning(
+            "Overwriting the plan \"%s\" on \"%s\" with the given image: \"%s\".",
+            plan_name,
+            tgt,
+            metadata.image_path,
+        )
+        tech_config = self.get_plan_tech_config(product, plan)
+        disk_version = create_disk_version_from_scratch(metadata, source)
+        tech_config.disk_versions = [disk_version]
+        return {
+            "metadata": metadata,
+            "tech_config": tech_config,
+            "sas_found": False,
+            "product": product,
+            "plan": plan,
+            "target": tgt,
+        }
+
+    def _look_up_sas_on_technical_config(
+        self, metadata, product_name, plan_name, target
+    ) -> TechnicalConfigLookUpData:
+        product, plan, tgt = self.get_product_plan_by_name(
+            product_name, plan_name, first_target=target
+        )
+        log.info(
+            "Retrieving the technical config for \"%s\" on \"%s\".",
+            metadata.destination,
+            tgt,
+        )
+        tech_config = self.get_plan_tech_config(product, plan)
+        sas_found = False
+
+        if is_sas_present(tech_config, metadata.image_path, metadata.check_base_sas_only):
+            log.info(
+                "The destination \"%s\" on \"%s\" already contains the SAS URI: \"%s\".",
+                metadata.destination,
+                tgt,
+                metadata.image_path,
+            )
+            sas_found = True
+        return {
+            "metadata": metadata,
+            "tech_config": tech_config,
+            "sas_found": sas_found,
+            "product": product,
+            "plan": plan,
+            "target": tgt,
+        }
+
+    def _produce_disk_version_if_required(
+        self,
+        tech_config_lookup: TechnicalConfigLookUpData,
+        source: VMImageSource,
+        disk_version: Optional[DiskVersion],
+    ) -> DiskVersion:
+        metadata = tech_config_lookup["metadata"]
+        target = tech_config_lookup["target"]
+        tech_config = tech_config_lookup["tech_config"]
+
+        # Check the images of the selected DiskVersion if it exists
+        if disk_version:
+            log.info(
+                "DiskVersion \"%s\" exists in \"%s\" on \"%s\" for the image \"%s\".",
+                disk_version.version_number,
+                metadata.destination,
+                target,
+                metadata.image_path,
+            )
+            disk_version = set_new_sas_disk_version(disk_version, metadata, source)
+            return disk_version
+        # The disk version doesn't exist, we need to create one from scratch
+        log.info("The DiskVersion doesn't exist, creating one from scratch.")
+        disk_version = create_disk_version_from_scratch(metadata, source)
+        tech_config.disk_versions.append(disk_version)
+        return disk_version
+
     def publish(self, metadata: AzurePublishingMetadata) -> None:
         """
         Associate a VM image with a given product listing (destination) and publish it if required.
@@ -608,7 +694,6 @@ def publish(self, metadata: AzurePublishingMetadata) -> None:
         product_name = metadata.destination.split("/")[0]
         plan_name = metadata.destination.split("/")[-1]
         disk_version = None
-        sas_found = False
         log.info(
             "Preparing to associate the image \"%s\" with the plan \"%s\" from product \"%s\"",
             metadata.image_path,
@@ -626,47 +711,23 @@ def publish(self, metadata: AzurePublishingMetadata) -> None:
         # Note: If `overwrite` is True it means we can set this VM image as the only one in the
         # plan's technical config and discard all other VM images which may've been present.
         if metadata.overwrite is True:
-            product, plan, tgt = self.get_product_plan_by_name(product_name, plan_name)
-            log.warning(
-                "Overwriting the plan \"%s\" on \"%s\" with the given image: \"%s\".",
-                plan_name,
-                tgt,
-                metadata.image_path,
-            )
-            tech_config = self.get_plan_tech_config(product, plan)
-            disk_version = create_disk_version_from_scratch(metadata, source)
-            tech_config.disk_versions = [disk_version]
+            res = self._overwrite_disk_version(metadata, product_name, plan_name, source)
+            tgt = res["target"]
+            tech_config = res["tech_config"]
+            disk_version = tech_config.disk_versions[0]  # only 1 as it was overwritten
         else:
             # Otherwise we need to check whether SAS isn't already present
             # in any of the targets "preview", "live" or "draft" and if not attach and publish it.
-            for initial_target in list_all_targets(start_with="preview"):
-
-                # 3.1 Retrieve the VM Technical configuration for the given plan
-                product, plan, tgt = self.get_product_plan_by_name(
-                    product_name, plan_name, first_target=initial_target
+            for target in list_all_targets(start_with="preview"):
+                res = self._look_up_sas_on_technical_config(
+                    metadata, product_name, plan_name, target
                 )
-                log.info(
-                    "Retrieving the technical config for \"%s\" on \"%s\".",
-                    metadata.destination,
-                    tgt,
-                )
-                tech_config = self.get_plan_tech_config(product, plan)
-
-                if is_sas_present(tech_config, metadata.image_path, metadata.check_base_sas_only):
-                    log.info(
-                        "The destination \"%s\" on \"%s\" already contains the SAS URI: \"%s\".",
-                        metadata.destination,
-                        tgt,
-                        metadata.image_path,
-                    )
-                    # We don't want to seek for SAS anymore as it was already found
-                    sas_found = True
+                tech_config = res["tech_config"]
+                tgt = res["target"]
+                # We don't want to seek for SAS anymore as it was already found
+                if res["sas_found"]:
                     break
-                else:
-                    # Seek SAS URI until it reaches the last target
-                    continue
-
-            if not sas_found:
+            else:
                 # At this point there's no SAS URI in any target so we can safely add it
 
                 # Here we can have the metadata.disk_version set or empty.
@@ -677,23 +738,8 @@ def publish(self, metadata: AzurePublishingMetadata) -> None:
                     tgt,
                     metadata.image_path,
                 )
-                disk_version = seek_disk_version(tech_config, metadata.disk_version)
-
-                # Check the images of the selected DiskVersion if it exists
-                if disk_version:
-                    log.info(
-                        "DiskVersion \"%s\" exists in \"%s\" on \"%s\" for the image \"%s\".",
-                        disk_version.version_number,
-                        metadata.destination,
-                        tgt,
-                        metadata.image_path,
-                    )
-                    disk_version = set_new_sas_disk_version(disk_version, metadata, source)
-
-                else:  # The disk version doesn't exist, we need to create one from scratch
-                    log.info("The DiskVersion doesn't exist, creating one from scratch.")
-                    disk_version = create_disk_version_from_scratch(metadata, source)
-                    tech_config.disk_versions.append(disk_version)
+                dv = seek_disk_version(tech_config, metadata.disk_version)
+                disk_version = self._produce_disk_version_if_required(res, source, dv)
 
         # 4. With the updated disk_version we should adjust the SKUs and submit the changes
         if disk_version:
@@ -714,6 +760,7 @@ def publish(self, metadata: AzurePublishingMetadata) -> None:
         # 5. Proceed to publishing if it was requested.
         # Note: The publishing will only occur if it made changes in disk_version.
         if not metadata.keepdraft:
+            product = res["product"]
             # Get the submission state
             submission: ProductSubmission = cast(
                 List[ProductSubmission],

cloudpub/ms_azure/utils.py

@@ -1,14 +1,16 @@
 # SPDX-License-Identifier: GPL-3.0-or-later
 import logging
 from operator import attrgetter
-from typing import Any, Dict, List, Optional, Tuple
+from typing import Any, Dict, List, Optional, Tuple, TypedDict
 
 from deepdiff import DeepDiff
 
 from cloudpub.common import PublishingMetadata  # Cannot circular import AzurePublishingMetadata
 from cloudpub.models.ms_azure import (
     ConfigureStatus,
     DiskVersion,
+    PlanSummary,
+    Product,
     VMImageDefinition,
     VMImageSource,
     VMIPlanTechConfig,
@@ -107,6 +109,17 @@ def __validate(self):
             raise ValueError(f"Invalid SAS URI \"{self.image_path}\". Expected: http/https URL.")
 
 
+class TechnicalConfigLookUpData(TypedDict):
+    """A typed dict to be used for private methods data exchange."""
+
+    metadata: AzurePublishingMetadata
+    tech_config: VMIPlanTechConfig
+    sas_found: bool
+    product: Product
+    plan: PlanSummary
+    target: str
+
+
 def get_image_type_mapping(architecture: str, generation: str) -> str:
     """Return the image type required by VMImageDefinition."""
     gen_map = {