refactor(BA-5829): split AppConfig merged-view into its own adapter; drop scoped GQL root

Per review on PR #11285:

- Split the merged-view (AppConfig, BEP-1052 §5) surface and the
  self-service `my_bulk_*` writes out of `AppConfigFragmentAdapter`
  into a new `AppConfigAdapter`. Each adapter now handles a single
  domain DTO surface, matching the project convention. Both adapters
  share the same `app_config_fragment` service processors —
  splitting only the transport layer.
- Drop the `scoped_app_config_fragments` GQL root resolver. BEP-1052
  exposes the scope-bound list as child fields on
  `DomainV2.appConfigFragments` / `UserV2.appConfigFragments`, not as
  a root field. The scope-bound REST endpoint
  `POST /v2/app-config-fragments/{scope_type}/{scope_id}/search`
  continues to use `AppConfigFragmentAdapter.search()` directly.
- Update the GQL resolvers (`my_app_configs`, `admin_app_configs`,
  `bulk_create_my_app_config_fragments`,
  `bulk_update_my_app_config_fragments`) to call the new
  `info.context.adapters.app_config` adapter.
- Wire the new `app_config` field through `Adapters.__init__` and
  `Adapters.create()`.
- DataLoader now uses `AppConfigFragmentFilter(id=UUIDFilter(...))`
  per the new filter shape.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: jopemachine

src/ai/backend/manager/api/adapters/app_config.py

@@ -1,4 +1,4 @@
-"""AppConfig (merged view) domain adapter
+"""AppConfig (merged view) domain adapter — BEP-1052 §5.
 
 Reads the per-user merged AppConfig view and writes the underlying USER
 fragments via the same `app_config_fragment` service processors. The
@@ -19,15 +19,15 @@
 )
 from ai.backend.common.dto.manager.v2.app_config.response import (
     AppConfigNode,
+    BulkCreateMyAppConfigFragmentsPayload,
+    BulkUpdateMyAppConfigFragmentsPayload,
     GetUserAppConfigPayload,
-    MyBulkCreateAppConfigFragmentsPayload,
-    MyBulkUpdateAppConfigFragmentsPayload,
     SearchAppConfigsPayload,
 )
 from ai.backend.common.dto.manager.v2.app_config.types import AppConfigOrderField, OrderDirection
 from ai.backend.common.dto.manager.v2.app_config_fragment.request import (
-    MyBulkCreateAppConfigFragmentsInput,
-    MyBulkUpdateAppConfigFragmentsInput,
+    BulkCreateMyAppConfigFragmentsInput,
+    BulkUpdateMyAppConfigFragmentsInput,
 )
 from ai.backend.common.dto.manager.v2.app_config_fragment.response import (
     AppConfigFragmentBulkError,
@@ -52,14 +52,14 @@
 from ai.backend.manager.services.app_config_fragment.actions.admin_search_app_configs import (
     AdminSearchAppConfigsAction,
 )
-from ai.backend.manager.services.app_config_fragment.actions.get_user_app_config import (
-    GetUserAppConfigAction,
+from ai.backend.manager.services.app_config_fragment.actions.bulk_create_my import (
+    BulkCreateMyAppConfigFragmentsAction,
 )
-from ai.backend.manager.services.app_config_fragment.actions.my_bulk_create import (
-    MyBulkCreateAppConfigFragmentsAction,
+from ai.backend.manager.services.app_config_fragment.actions.bulk_update_my import (
+    BulkUpdateMyAppConfigFragmentsAction,
 )
-from ai.backend.manager.services.app_config_fragment.actions.my_bulk_update import (
-    MyBulkUpdateAppConfigFragmentsAction,
+from ai.backend.manager.services.app_config_fragment.actions.get_user_app_config import (
+    GetUserAppConfigAction,
 )
 from ai.backend.manager.services.app_config_fragment.actions.search_user_app_configs import (
     SearchUserAppConfigsAction,
@@ -69,7 +69,7 @@
 
 
 class AppConfigAdapter(BaseAdapter):
-    """Adapter for the merged AppConfig view.
+    """Adapter for the merged AppConfig view (BEP-1052 §5).
 
     Backed by the `app_config_fragment` service processors — the merged
     view is computed from raw fragments — but exposed as a separate
@@ -146,41 +146,55 @@ async def admin_search_app_configs(
             has_previous_page=result.has_previous_page,
         )
 
-    # ── Self-service bulk writes ───────────────────────
+    # ── Self-service bulk writes (BEP-1052 §3) ───────────────────────
     #
     # Each bulk processor returns a `BulkProcessResult[T]` whose
     # `.result` field is the underlying `*ActionResult` produced by the
     # service. We discard the validator-decision trail here — RBAC
     # reasons travel back through the per-item `failed` list.
 
     async def my_bulk_create(
-        self, input: MyBulkCreateAppConfigFragmentsInput
-    ) -> MyBulkCreateAppConfigFragmentsPayload:
+        self, input: BulkCreateMyAppConfigFragmentsInput
+    ) -> BulkCreateMyAppConfigFragmentsPayload:
+        me = current_user()
+        if me is None:
+            raise UnreachableError("User context is not available")
         items = [
             MyAppConfigFragmentBulkItem(name=item.name, config=dict(item.config))
             for item in input.items
         ]
-        wrapper = await self._processors.app_config_fragment.my_bulk_create.wait_for_complete(
-            MyBulkCreateAppConfigFragmentsAction(entity_ids=[], items=items)
+        wrapper = await self._processors.app_config_fragment.bulk_create_my.wait_for_complete(
+            BulkCreateMyAppConfigFragmentsAction(
+                entity_ids=[],
+                user_id=me.user_id,
+                items=items,
+            )
         )
         result = wrapper.result
-        return MyBulkCreateAppConfigFragmentsPayload(
+        return BulkCreateMyAppConfigFragmentsPayload(
             created=[self._data_to_dto(item) for item in result.created],
             failed=[self._bulk_error_to_dto(err) for err in result.failed],
         )
 
     async def my_bulk_update(
-        self, input: MyBulkUpdateAppConfigFragmentsInput
-    ) -> MyBulkUpdateAppConfigFragmentsPayload:
+        self, input: BulkUpdateMyAppConfigFragmentsInput
+    ) -> BulkUpdateMyAppConfigFragmentsPayload:
+        me = current_user()
+        if me is None:
+            raise UnreachableError("User context is not available")
         items = [
             MyAppConfigFragmentBulkItem(name=item.name, config=dict(item.config))
             for item in input.items
         ]
-        wrapper = await self._processors.app_config_fragment.my_bulk_update.wait_for_complete(
-            MyBulkUpdateAppConfigFragmentsAction(entity_ids=[], items=items)
+        wrapper = await self._processors.app_config_fragment.bulk_update_my.wait_for_complete(
+            BulkUpdateMyAppConfigFragmentsAction(
+                entity_ids=[],
+                user_id=me.user_id,
+                items=items,
+            )
         )
         result = wrapper.result
-        return MyBulkUpdateAppConfigFragmentsPayload(
+        return BulkUpdateMyAppConfigFragmentsPayload(
             updated=[self._data_to_dto(item) for item in result.updated],
             failed=[self._bulk_error_to_dto(err) for err in result.failed],
         )

src/ai/backend/manager/api/adapters/app_config_fragment.py

@@ -52,6 +52,7 @@
 from ai.backend.common.dto.manager.v2.app_config_fragment.types import (
     AppConfigScopeType as DTOAppConfigScopeType,
 )
+from ai.backend.common.dto.manager.v2.app_config_fragment.types import OrderDirection
 from ai.backend.manager.api.adapter_options.pagination.pagination import PaginationSpec
 from ai.backend.manager.data.app_config.types import AppConfigData
 from ai.backend.manager.data.app_config_fragment.bulk_types import (
@@ -108,9 +109,9 @@
 
 
 class AppConfigFragmentAdapter(BaseAdapter):
-    """Adapter for AppConfigFragment raw-row operations.
+    """Adapter for AppConfigFragment raw-row operations (BEP-1052 §2).
 
-    Writes are bulk-only; single-item create / update /
+    Writes are bulk-only (BEP-1052 §3); single-item create / update /
     purge entry points are intentionally absent. Self-service my_bulk
     writes (which return the recomputed merged view) live on
     `AppConfigAdapter` alongside the merged-view reads.
@@ -265,7 +266,7 @@ def _data_to_dto(data: AppConfigFragmentData) -> AppConfigFragmentNode:
             updated_at=data.updated_at,
         )
 
-    # ── Bulk mutations ───────────────────────────────
+    # ── Bulk mutations (BEP-1052 §3) ───────────────────────────────
     #
     # Each bulk processor returns a `BulkProcessResult[T]` whose
     # `.result` field is the underlying `*ActionResult` produced by the

src/ai/backend/manager/api/gql/app_config_fragment/__init__.py

@@ -6,8 +6,8 @@
     admin_bulk_purge_app_config_fragments,
     admin_bulk_update_app_config_fragments,
     app_config_fragment,
-    my_bulk_create_app_config_fragments,
-    my_bulk_update_app_config_fragments,
+    bulk_create_my_app_config_fragments,
+    bulk_update_my_app_config_fragments,
 )
 from .types import (
     AppConfigFragmentFilterGQL,
@@ -19,7 +19,7 @@
 )
 
 __all__ = [
-    # Queries — scope-bound list belongs on DomainV2 / UserV2 child fields
+    # Queries — scope-bound list belongs on DomainV2 / UserV2 child fields per BEP-1052
     "app_config_fragment",
     "scoped_app_config_fragments",
     "admin_app_config_fragments",

src/ai/backend/manager/api/gql/app_config_fragment/resolver/__init__.py

@@ -17,6 +17,6 @@
     "admin_bulk_purge_app_config_fragments",
     "admin_bulk_update_app_config_fragments",
     "app_config_fragment",
-    "my_bulk_create_app_config_fragments",
-    "my_bulk_update_app_config_fragments",
+    "bulk_create_my_app_config_fragments",
+    "bulk_update_my_app_config_fragments",
 ]

src/ai/backend/manager/api/gql/app_config_fragment/resolver/mutation.py

@@ -89,10 +89,10 @@ async def admin_bulk_purge_app_config_fragments(
 )
 async def my_bulk_create_app_config_fragments(
     info: Info[StrawberryGQLContext],
-    input: MyBulkCreateAppConfigFragmentInputGQL,
-) -> MyBulkCreateAppConfigFragmentsPayloadGQL:
+    input: BulkCreateMyAppConfigFragmentInputGQL,
+) -> BulkCreateMyAppConfigFragmentsPayloadGQL:
     result = await info.context.adapters.app_config.my_bulk_create(input.to_pydantic())
-    return MyBulkCreateAppConfigFragmentsPayloadGQL.from_pydantic(result)
+    return BulkCreateMyAppConfigFragmentsPayloadGQL.from_pydantic(result)
 
 
 @gql_mutation(
@@ -106,7 +106,7 @@ async def my_bulk_create_app_config_fragments(
 )
 async def my_bulk_update_app_config_fragments(
     info: Info[StrawberryGQLContext],
-    input: MyBulkUpdateAppConfigFragmentInputGQL,
-) -> MyBulkUpdateAppConfigFragmentsPayloadGQL:
+    input: BulkUpdateMyAppConfigFragmentInputGQL,
+) -> BulkUpdateMyAppConfigFragmentsPayloadGQL:
     result = await info.context.adapters.app_config.my_bulk_update(input.to_pydantic())
-    return MyBulkUpdateAppConfigFragmentsPayloadGQL.from_pydantic(result)
+    return BulkUpdateMyAppConfigFragmentsPayloadGQL.from_pydantic(result)

src/ai/backend/manager/api/gql/app_config_fragment/resolver/query.py

@@ -1,6 +1,6 @@
 """AppConfigFragment GQL query resolvers.
 
-Per the scope-bound list is exposed via child fields on
+Per BEP-1052 §2 the scope-bound list is exposed via child fields on
 `DomainV2.appConfigFragments` / `UserV2.appConfigFragments`, not as a
 root resolver. Only the single-row read and the cross-scope admin
 search live here. The scope-bound REST endpoint

src/ai/backend/manager/api/gql/schema.py

@@ -26,8 +26,8 @@
     admin_bulk_purge_app_config_fragments,
     admin_bulk_update_app_config_fragments,
     app_config_fragment,
-    my_bulk_create_app_config_fragments,
-    my_bulk_update_app_config_fragments,
+    bulk_create_my_app_config_fragments,
+    bulk_update_my_app_config_fragments,
 )
 from .app_config_policy import (
     admin_bulk_create_app_config_policies,