Merge pull request #3 from IDTS-LAB/ddd-clean-architecture-with-cqrs-review-dfff8

Update from task 9d6c2646-8dbc-409e-bccc-824f40edfff8

Author: fiqrikm18

.gitignore

@@ -1,21 +1,51 @@
-# Poetry specific files
-.venv/
-/dist/
-/poetry.toml
-
-# Python bytecode and caches
+```
+# Python
 __pycache__/
 *.pyc
 *.pyo
 *.pyd
+.Python
+*.so
+*.egg-info/
+.eggs/
+
+# Virtual environments
+venv/
+.venv/
+env/
+ENV/
+.ENV
+
+# Build artifacts
+build/
+dist/
+*.egg
+
+# Testing
+.coverage
+htmlcov/
 .pytest_cache/
 .mypy_cache/
-.ruff_cache/
-.cache/
 
-# Environment variables (secret keys)
+# Logs
+*.log
+
+# Environment variables
 .env
+.env.local
+*.env.*
 
-# IDE settings
+# IDE
 .vscode/
 .idea/
+*.swp
+*.swo
+*.tmp
+
+# OS
+.DS_Store
+Thumbs.db
+
+# Coverage
+coverage/
+```

src/modules/authorization/application/create_permission/command.py

@@ -0,0 +1,7 @@
+from pydantic import BaseModel
+
+
+class CreatePermissionCommand(BaseModel):
+    resource: str
+    action: str
+    description: str | None = None

src/modules/authorization/application/create_permission/handler.py

@@ -0,0 +1,31 @@
+from src.modules.authorization.application.create_permission.command import (
+    CreatePermissionCommand,
+)
+from src.modules.authorization.domain.entities.permission import Permission
+from src.modules.authorization.domain.permissions import permission_key
+from src.modules.authorization.domain.repositories.casbin_policy_repository import (
+    CasbinPolicyRepository,
+)
+from src.shared.unit_of_work import UnitOfWork
+
+
+class CreatePermissionHandler:
+    def __init__(
+        self,
+        policy_repo: CasbinPolicyRepository,
+        unit_of_work: UnitOfWork,
+    ):
+        self._policy_repo = policy_repo
+        self._unit_of_work = unit_of_work
+
+    async def execute(self, command: CreatePermissionCommand) -> Permission:
+        permission = Permission.create(
+            key=permission_key(command.resource, command.action),
+            resource=command.resource,
+            action=command.action,
+            description=command.description,
+        )
+        async with self._unit_of_work:
+            created = await self._policy_repo.create_permission(permission)
+            await self._unit_of_work.commit()
+            return created

src/modules/authorization/application/create_role/command.py

@@ -0,0 +1,6 @@
+from pydantic import BaseModel
+
+
+class CreateRoleCommand(BaseModel):
+    name: str
+    description: str | None = None

src/modules/authorization/application/create_role/handler.py

@@ -0,0 +1,23 @@
+from src.modules.authorization.application.create_role.command import CreateRoleCommand
+from src.modules.authorization.domain.entities.role import Role
+from src.modules.authorization.domain.repositories.casbin_policy_repository import (
+    CasbinPolicyRepository,
+)
+from src.shared.unit_of_work import UnitOfWork
+
+
+class CreateRoleHandler:
+    def __init__(
+        self,
+        policy_repo: CasbinPolicyRepository,
+        unit_of_work: UnitOfWork,
+    ):
+        self._policy_repo = policy_repo
+        self._unit_of_work = unit_of_work
+
+    async def execute(self, command: CreateRoleCommand) -> Role:
+        role = Role.create(name=command.name, description=command.description)
+        async with self._unit_of_work:
+            created = await self._policy_repo.create_role(role)
+            await self._unit_of_work.commit()
+            return created

src/modules/authorization/application/delete_permission/command.py

@@ -0,0 +1,7 @@
+from uuid import UUID
+
+from pydantic import BaseModel
+
+
+class DeletePermissionCommand(BaseModel):
+    permission_id: UUID

src/modules/authorization/application/delete_permission/handler.py

@@ -0,0 +1,22 @@
+from src.modules.authorization.application.delete_permission.command import (
+    DeletePermissionCommand,
+)
+from src.modules.authorization.domain.repositories.casbin_policy_repository import (
+    CasbinPolicyRepository,
+)
+from src.shared.unit_of_work import UnitOfWork
+
+
+class DeletePermissionHandler:
+    def __init__(
+        self,
+        policy_repo: CasbinPolicyRepository,
+        unit_of_work: UnitOfWork,
+    ):
+        self._policy_repo = policy_repo
+        self._unit_of_work = unit_of_work
+
+    async def execute(self, command: DeletePermissionCommand) -> None:
+        async with self._unit_of_work:
+            await self._policy_repo.delete_permission(command.permission_id)
+            await self._unit_of_work.commit()

src/modules/authorization/application/delete_role/command.py

@@ -0,0 +1,7 @@
+from uuid import UUID
+
+from pydantic import BaseModel
+
+
+class DeleteRoleCommand(BaseModel):
+    role_id: UUID

src/modules/authorization/application/delete_role/handler.py

@@ -0,0 +1,20 @@
+from src.modules.authorization.application.delete_role.command import DeleteRoleCommand
+from src.modules.authorization.domain.repositories.casbin_policy_repository import (
+    CasbinPolicyRepository,
+)
+from src.shared.unit_of_work import UnitOfWork
+
+
+class DeleteRoleHandler:
+    def __init__(
+        self,
+        policy_repo: CasbinPolicyRepository,
+        unit_of_work: UnitOfWork,
+    ):
+        self._policy_repo = policy_repo
+        self._unit_of_work = unit_of_work
+
+    async def execute(self, command: DeleteRoleCommand) -> None:
+        async with self._unit_of_work:
+            await self._policy_repo.delete_role(command.role_id)
+            await self._unit_of_work.commit()

src/modules/authorization/application/get_permission/handler.py

@@ -0,0 +1,13 @@
+from src.modules.authorization.application.get_permission.query import GetPermissionQuery
+from src.modules.authorization.domain.entities.permission import Permission
+from src.modules.authorization.domain.repositories.casbin_policy_repository import (
+    CasbinPolicyRepository,
+)
+
+
+class GetPermissionQueryHandler:
+    def __init__(self, policy_repo: CasbinPolicyRepository):
+        self._policy_repo = policy_repo
+
+    async def execute(self, query: GetPermissionQuery) -> Permission | None:
+        return await self._policy_repo.get_permission(query.permission_id)