source-shopify-native: persist migrated endpoint config to control plane

When legacy single-store config is transformed to multi-store format,
emit a config_update event so the control plane persists the new format.
This ensures the UI shows the correct format when editing the capture.

- Add _was_migrated PrivateAttr to track config migration
- Update model_validator to set migration flag when transforming
- Emit config_update event in open() when config was migrated

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: JustinASmith

source-shopify-native/source_shopify_native/__init__.py

@@ -1,4 +1,6 @@
 from logging import Logger
+
+from estuary_cdk.logger import FlowLogger
 from typing import Callable, Awaitable
 
 from estuary_cdk.flow import (
@@ -206,17 +208,28 @@ async def validate(
 
     async def open(
         self,
-        log: Logger,
+        log: FlowLogger,
         open: request.Open[EndpointConfig, ResourceConfig, ConnectorState],
     ) -> tuple[response.Opened, Callable[[Task], Awaitable[None]]]:
+        config = open.capture.config
+
+        # Persist migrated config so UI shows the new format
+        if config._was_migrated:
+            log.info("Persisting migrated config to multi-store format")
+            encrypted_config = await self._encrypt_config(log, config)
+            log.event.config_update(
+                "Migrating legacy single-store config to multi-store format.",
+                encrypted_config
+            )
+
         # Determine key structure from existing bindings
         use_multi_store_keys = _should_use_multi_store_keys(
             open.capture.bindings,
-            len(open.capture.config.stores),
+            len(config.stores),
         )
 
         resources = await all_resources(
-            log, self, open.capture.config,
+            log, self, config,
             should_cancel_ongoing_job=True,
             use_multi_store_keys=use_multi_store_keys,
         )

source-shopify-native/source_shopify_native/models.py

@@ -12,7 +12,7 @@
     TypeVar,
     Generic,
 )
-from pydantic import AwareDatetime, BaseModel, Field, model_validator
+from pydantic import AwareDatetime, BaseModel, Field, PrivateAttr, model_validator
 
 from estuary_cdk.capture.common import (
     AccessToken,
@@ -132,6 +132,10 @@ class Advanced(BaseModel):
         json_schema_extra={"advanced": True},
     )
 
+    # Track whether config was migrated from legacy format.
+    # Used to persist the new format back to the control plane.
+    _was_migrated: bool = PrivateAttr(default=False)
+
     @model_validator(mode="before")
     @classmethod
     def transform_legacy_config(cls, data: Any) -> Any:
@@ -142,6 +146,8 @@ def transform_legacy_config(cls, data: Any) -> Any:
 
         New format:
             {"stores": [{"store": "mystore", "credentials": {...}}], "start_date": "..."}
+
+        Sets _was_migrated flag so the connector can persist the new format.
         """
         if not isinstance(data, dict):
             return data
@@ -154,9 +160,15 @@ def transform_legacy_config(cls, data: Any) -> Any:
         store = data.pop("store")
         credentials = data.pop("credentials")
         data["stores"] = [{"store": store, "credentials": credentials}]
+        data["_was_migrated"] = True
 
         return data
 
+    def __init__(self, **data: Any) -> None:
+        was_migrated = data.pop("_was_migrated", False)
+        super().__init__(**data)
+        self._was_migrated = was_migrated
+
 
 ConnectorState = GenericConnectorState[ResourceState]