refactor(resources): one canonical layout, scoped bases, dedup schemas (#55)

Implements plans/refactor/04-resource-layer-normalization.md:

- Canonical per-resource layout everywhere: operations.py / schemas.py /
  resources.py. Renamed domain+usage manager.py and envVars/git/
  landscape/logs models.py to resources.py; git schema.py -> schemas.py;
  deleted the zero-byte landscape/resources.py placeholder
- envVars/ package renamed to env_vars/; the old camelCase import path
  remains as a deprecation shim module (warns, re-exports)
- Domain entity moves to domain/schemas.py alongside its base (matching
  Team/Workspace); TeamDomainManager lives in domain/resources.py;
  domain/__init__.py gains proper re-exports
- New TeamScopedResource / WorkspaceScopedResource bases in core/base.py
  replace six copy-pasted manager __init__s; managers expose
  team_id/workspace_id consistently
- EnvVar derives from CamelModel like every other schema (gains
  to_dict/to_json/to_yaml)
- PipelineStatusList is now an alias of ResourceList[PipelineStatus]
  instead of a reimplementation
- PaginatedResponse: refresh() hoisted from the two response subclasses,
  limit/offset are non-Optional with defaults (drops the repeated
  'or 25' re-defaulting); single _clamp_page_size helper replaces four
  inline min(max(...)) clamps
- Deleted dead utils.dict_to_model_list

Only internal module paths moved; all public re-exports (top-level
codesphere, package __init__s) are unchanged, plus the envVars shim.

Author: Datata1

examples/dashboard/app.py

@@ -35,7 +35,7 @@
     WorkspaceCreate,
     WorkspaceUpdate,
 )
-from codesphere.resources.workspace.envVars import EnvVar  # noqa: E402
+from codesphere.resources.workspace.env_vars import EnvVar  # noqa: E402
 from codesphere.resources.workspace.landscape import (  # noqa: E402
     PipelineStage,
     ProfileBuilder,

src/codesphere/__init__.py

@@ -51,7 +51,7 @@
     WorkspaceStatus,
     WorkspaceUpdate,
 )
-from .resources.workspace.envVars import EnvVar
+from .resources.workspace.env_vars import EnvVar
 
 logging.getLogger("codesphere").addHandler(logging.NullHandler())
 

src/codesphere/core/__init__.py

@@ -1,4 +1,11 @@
-from .base import BoundModel, CamelModel, ResourceBase, ResourceList
+from .base import (
+    BoundModel,
+    CamelModel,
+    ResourceBase,
+    ResourceList,
+    TeamScopedResource,
+    WorkspaceScopedResource,
+)
 from .handler import execute_operation
 from .operations import APIOperation, StreamOperation
 
@@ -9,5 +16,7 @@
     "ResourceBase",
     "ResourceList",
     "StreamOperation",
+    "TeamScopedResource",
+    "WorkspaceScopedResource",
     "execute_operation",
 ]

src/codesphere/core/base.py

@@ -32,6 +32,22 @@ async def _execute(
         )
 
 
+class TeamScopedResource(ResourceBase):
+    """Base for managers operating within one team."""
+
+    def __init__(self, http_client: APIHttpClient, team_id: int):
+        super().__init__(http_client)
+        self.team_id = team_id
+
+
+class WorkspaceScopedResource(ResourceBase):
+    """Base for managers operating within one workspace."""
+
+    def __init__(self, http_client: APIHttpClient, workspace_id: int):
+        super().__init__(http_client)
+        self.workspace_id = workspace_id
+
+
 class CamelModel(BaseModel):
     model_config = ConfigDict(
         alias_generator=to_camel,

src/codesphere/resources/team/__init__.py

@@ -1,9 +1,10 @@
-from .domain.resources import (
+from .domain import (
     CustomDomainConfig,
     Domain,
     DomainBase,
     DomainRouting,
     DomainVerificationStatus,
+    TeamDomainManager,
 )
 from .resources import TeamsResource
 from .schemas import Team, TeamBase, TeamCreate
@@ -30,6 +31,7 @@
     "Team",
     "TeamBase",
     "TeamCreate",
+    "TeamDomainManager",
     "TeamUsageManager",
     "TeamsResource",
     "UsageEventsResponse",

src/codesphere/resources/team/domain/__init__.py

@@ -0,0 +1,19 @@
+from .resources import TeamDomainManager
+from .schemas import (
+    CustomDomainConfig,
+    Domain,
+    DomainBase,
+    DomainRouting,
+    DomainVerificationStatus,
+    RoutingMap,
+)
+
+__all__ = [
+    "CustomDomainConfig",
+    "Domain",
+    "DomainBase",
+    "DomainRouting",
+    "DomainVerificationStatus",
+    "RoutingMap",
+    "TeamDomainManager",
+]

src/codesphere/resources/team/domain/manager.py

@@ -2,8 +2,7 @@
 
 from ....core.base import ResourceList
 from ....core.operations import APIOperation
-from .resources import Domain
-from .schemas import CustomDomainConfig, DomainVerificationStatus
+from .schemas import CustomDomainConfig, Domain, DomainVerificationStatus
 
 _LIST_OP = APIOperation(
     method="GET",

src/codesphere/resources/team/domain/operations.py

@@ -1,52 +1,30 @@
-from __future__ import annotations
+from ....core.base import TeamScopedResource
+from .operations import _CREATE_OP, _GET_OP, _LIST_OP, _UPDATE_OP, _UPDATE_WS_OP
+from .schemas import CustomDomainConfig, Domain, DomainRouting, RoutingMap
 
-import logging
 
-from ....core.base import BoundModel
-from ....utils import update_model_fields
-from .schemas import (
-    CustomDomainConfig,
-    DomainBase,
-    DomainRouting,
-    DomainVerificationStatus,
-    RoutingMap,
-)
+class TeamDomainManager(TeamScopedResource):
+    async def list(self) -> list[Domain]:
+        result = await self._execute(_LIST_OP, team_id=self.team_id)
+        return result.root
 
-log = logging.getLogger(__name__)
+    async def get(self, name: str) -> Domain:
+        return await self._execute(_GET_OP, team_id=self.team_id, name=name)
 
+    async def create(self, name: str) -> Domain:
+        return await self._execute(_CREATE_OP, team_id=self.team_id, name=name)
 
-class Domain(DomainBase, BoundModel):
-    async def update(self, data: CustomDomainConfig) -> Domain:
-        from .operations import _UPDATE_OP
-
-        response = await self._execute(
-            _UPDATE_OP, team_id=self.team_id, name=self.name, data=data
+    async def update(self, name: str, config: CustomDomainConfig) -> Domain:
+        return await self._execute(
+            _UPDATE_OP, team_id=self.team_id, name=name, data=config
         )
-        update_model_fields(target=self, source=response)
-        return response
 
     async def update_workspace_connections(
-        self, connections: DomainRouting | RoutingMap
+        self, name: str, connections: DomainRouting | RoutingMap
     ) -> Domain:
-        from .operations import _UPDATE_WS_OP
-
         payload = (
             connections.root if isinstance(connections, DomainRouting) else connections
         )
-        response = await self._execute(
-            _UPDATE_WS_OP, team_id=self.team_id, name=self.name, data=payload
+        return await self._execute(
+            _UPDATE_WS_OP, team_id=self.team_id, name=name, data=payload
         )
-        update_model_fields(target=self, source=response)
-        return response
-
-    async def verify_status(self) -> DomainVerificationStatus:
-        from .operations import _VERIFY_OP
-
-        response = await self._execute(_VERIFY_OP, team_id=self.team_id, name=self.name)
-        update_model_fields(target=self.domain_verification_status, source=response)
-        return response
-
-    async def delete(self) -> None:
-        from .operations import _DELETE_OP
-
-        await self._execute(_DELETE_OP, team_id=self.team_id, name=self.name)

src/codesphere/resources/team/domain/resources.py

@@ -2,7 +2,8 @@
 
 from pydantic import Field, RootModel
 
-from ....core.base import CamelModel
+from ....core.base import BoundModel, CamelModel
+from ....utils import update_model_fields
 
 type RoutingMap = dict[str, list[int]]
 
@@ -48,3 +49,40 @@ class DomainBase(CamelModel):
     domain_verification_status: DomainVerificationStatus
     custom_config_revision: int | None = None
     custom_config: CustomDomainConfig | None = None
+
+
+class Domain(DomainBase, BoundModel):
+    async def update(self, data: CustomDomainConfig) -> Domain:
+        from .operations import _UPDATE_OP
+
+        response = await self._execute(
+            _UPDATE_OP, team_id=self.team_id, name=self.name, data=data
+        )
+        update_model_fields(target=self, source=response)
+        return response
+
+    async def update_workspace_connections(
+        self, connections: DomainRouting | RoutingMap
+    ) -> Domain:
+        from .operations import _UPDATE_WS_OP
+
+        payload = (
+            connections.root if isinstance(connections, DomainRouting) else connections
+        )
+        response = await self._execute(
+            _UPDATE_WS_OP, team_id=self.team_id, name=self.name, data=payload
+        )
+        update_model_fields(target=self, source=response)
+        return response
+
+    async def verify_status(self) -> DomainVerificationStatus:
+        from .operations import _VERIFY_OP
+
+        response = await self._execute(_VERIFY_OP, team_id=self.team_id, name=self.name)
+        update_model_fields(target=self.domain_verification_status, source=response)
+        return response
+
+    async def delete(self) -> None:
+        from .operations import _DELETE_OP
+
+        await self._execute(_DELETE_OP, team_id=self.team_id, name=self.name)