feat(projects): add a new person membership

Author: Mario G.

src/liceo/infra/adapters/migrations/20260103_initial_data.sql

@@ -96,6 +96,8 @@ INSERT INTO liceo_permissions (id, name, description) VALUES ('33Eccx9gpXqbE9mCB
 -- PROJECTS
 INSERT INTO liceo_permissions (id, name, description) VALUES ('mgewHChKbk5rAbbc5fAnQU', 'PROJECTS_CREATE', 'allows to create projects');
 INSERT INTO liceo_permissions (id, name, description) VALUES ('LGoiyMGdNGPFXhzVP7MXnf', 'PROJECTS_LIST', 'allows to list or filter projects');
+INSERT INTO liceo_permissions (id, name, description) VALUES ('KrMBkC2Qg5aBFo2GoTMe7z', 'PROJECTS_ADD_MEMBERSHIP', 'allows to add a person to the project');
+
 
 -- #######################
 -- ###      ROLES      ###
@@ -184,6 +186,8 @@ INSERT INTO liceo_roles_permissions (role_id, permission_id) VALUES ('rDCJKyPVeG
 INSERT INTO liceo_roles_permissions (role_id, permission_id) VALUES ('rDCJKyPVeGLfmboVS7PkXC', 'mgewHChKbk5rAbbc5fAnQU');
 -- ADMIN/PROJECTS_LIST
 INSERT INTO liceo_roles_permissions (role_id, permission_id) VALUES ('rDCJKyPVeGLfmboVS7PkXC', 'LGoiyMGdNGPFXhzVP7MXnf');
+-- ADMIN/PROJECTS_ADD_MEMBERSHIP
+INSERT INTO liceo_roles_permissions (role_id, permission_id) VALUES ('rDCJKyPVeGLfmboVS7PkXC', 'KrMBkC2Qg5aBFo2GoTMe7z');
 
 
 -- #######################

src/liceo/people/projects/adapters/di.py

@@ -1,12 +1,12 @@
 from typing import Annotated
-from fastapi import Depends, Body, Query
+from fastapi import Depends, Body, Query, Path
 from liceo.infra.adapters.di import ConnectionFactoryDependency, ConnectionManagerDependency, TransactionManagerDependency, EventStoreDependency
 from liceo.security.common.adapters.di import UserInfo
-from ..application.repository import ProjectRepository
+from ..application.repository import ProjectRepository, ProjectMemberRepository
 from ..application.service import ProjectService
-from .repository import SQLProjectRepository
+from .repository import SQLProjectRepository, SQLProjectMemberRepository
 from .service import DatabaseAwareProjectService
-from .requests import CreateProjectRequest, CreateProjectDetails, ListProjectsRequest
+from .requests import CreateProjectRequest, CreateProjectDetails, ListProjectsRequest, AddMemberToProjectRequest, AddMemberToProjectPath
 
 # ------ REPOSITORIES
 
@@ -19,17 +19,27 @@ def create_project_repository(factory: ConnectionFactoryDependency) -> ProjectRe
     create_project_repository)]
 
 
+def create_project_members_repository(factory: ConnectionFactoryDependency) -> ProjectMemberRepository:
+    return SQLProjectMemberRepository(factory=factory)
+
+
+ProjectMemberRepositoryDependency = Annotated[ProjectMemberRepository, Depends(
+    create_project_members_repository)]
+
+
 # ------ SERVICES
 
 
 def create_project_service(
-        repository: ProjectRepositoryDependency,
+        projects: ProjectRepositoryDependency,
+        project_members: ProjectMemberRepositoryDependency,
         transaction_manager_factory: TransactionManagerDependency,
         connection_manager_factory: ConnectionManagerDependency,
         event_store: EventStoreDependency
 ) -> ProjectService:
     return DatabaseAwareProjectService(
-        repository=repository,
+        projects=projects,
+        project_members=project_members,
         transaction_manager_factory=transaction_manager_factory,
         connection_manager_factory=connection_manager_factory,
         event_store=event_store
@@ -53,3 +63,14 @@ def create_project_request(
 
 
 ListProjectsRequestDependency = Annotated[ListProjectsRequest, Query()]
+
+
+def created_add_project_member_request(
+        user_info: UserInfo,
+        details: AddMemberToProjectPath = Path()
+):
+    return AddMemberToProjectRequest(created_by=user_info, details=details)
+
+
+AddMemberToProjectRequestDependency = Annotated[AddMemberToProjectRequest, Depends(
+    created_add_project_member_request)]

src/liceo/people/projects/adapters/endpoints.py

@@ -34,5 +34,18 @@ def list(
 def create(
     request: di.CreateProjectRequestDependency,
     service: di.ProjectServiceDependency
-) -> responses.SimpleProjectResponse:
-    return responses.SimpleProjectResponse.from_project(service.create_project(request.to_dto()))
+) -> responses.ProjectResponse:
+    return responses.ProjectResponse.from_project(service.create_project(request.to_dto()))
+
+
+@router.post(
+    path="/{id}/membership/{person_id}",
+    summary="Adds a person membership to the project",
+    dependencies=[has_permission(permissions.PROJECTS_ADD_MEMBERSHIP)],
+    openapi_extra={**open_api_permissions([permissions.PROJECTS_ADD_MEMBERSHIP])}
+)
+def add_member(
+    request: di.AddMemberToProjectRequestDependency,
+    service: di.ProjectServiceDependency
+) -> responses.ProjectMembershipResponse | None:
+    return responses.ProjectMembershipResponse.from_project_membership(service.add_new_member(request.to_dto()))

src/liceo/people/projects/adapters/permissions.py

@@ -1,2 +1,3 @@
 PROJECTS_CREATE: str = "PROJECTS_CREATE"
 PROJECTS_LIST: str = "PROJECTS_LIST"
+PROJECTS_ADD_MEMBERSHIP: str = "PROJECTS_ADD_MEMBERSHIP"

src/liceo/people/projects/adapters/repository.py

@@ -1,10 +1,10 @@
 from shortuuid import uuid
 from typing import override
 from liceo.infra.domain.vo import Paged, Pagination
-from liceo.people.projects.domain.entities import Project
-from liceo.labs.db.sql import SQLRepository
-from liceo.people.projects.domain.vo import ProjectId
-from ..application.repository import ProjectRepository
+from liceo.people.projects.domain.entities import Project, ProjectMembership
+from liceo.labs.db.sql import SQLRepository, sql
+from liceo.people.projects.domain.vo import ProjectId, ProjectMembershipId
+from ..application.repository import ProjectRepository, ProjectMemberRepository
 from .mappers import from_row_to_project
 
 
@@ -13,6 +13,10 @@ class SQLProjectRepository(ProjectRepository, SQLRepository):
     def generate_id(self) -> ProjectId:
         return ProjectId(uuid())
 
+    @sql(from_row_to_project)
+    def find_project_by_id(self, id: str) -> Project | None:
+        return None
+
     @override
     def save_project(self, project: Project) -> Project:
         self._get_connection().execute(
@@ -47,3 +51,22 @@ def filter_projects_by_name(self, name: str | None, pagination: Pagination) -> P
             total=result[0]["total_count"] if result else 0,
             data=list(map(from_row_to_project, result))
         )
+
+
+class SQLProjectMemberRepository(ProjectMemberRepository, SQLRepository):
+    def generate_id(self) -> ProjectMembershipId:
+        return ProjectMembershipId(uuid())
+
+    def save_membership(self, membership: ProjectMembership) -> ProjectMembership:
+        self._get_connection().execute(
+            sql=self.resolve_sql(self.save_membership),
+            params={
+                "id": membership.id,
+                "version": membership._version,
+                "project_id": membership.project.id,
+                "person_id": membership.person.id,
+                "created_by": membership.created_by,
+                "created_at": membership.created_at
+            }
+        )
+        return membership

src/liceo/people/projects/adapters/requests.py

@@ -32,3 +32,20 @@ def to_dto(self) -> dtos.FilterProjectsDTO:
             name=self.name,
             pagination=Pagination(max=self.max, page=self.page)
         )
+
+
+class AddMemberToProjectPath(BaseModel):
+    id: str
+    person_id: str
+
+
+class AddMemberToProjectRequest(BaseModel):
+    created_by: UserContextModel
+    details: AddMemberToProjectPath
+
+    def to_dto(self) -> dtos.AddMemberToProjectDTO:
+        return dtos.AddMemberToProjectDTO(
+            project_id=self.details.id,
+            person_id=self.details.person_id,
+            created_by=self.created_by.id
+        )

src/liceo/people/projects/adapters/responses.py

@@ -1,17 +1,27 @@
 from pydantic import BaseModel
 from liceo.infra.domain.vo import Paged
-from ..domain.entities import Project
+from ..domain.entities import Project, ProjectMembership
 
 
-class SimpleProjectResponse(BaseModel):
+class MinimalProjectResponse(BaseModel):
+    id: str
+    version: int
+
+    @staticmethod
+    def from_project(project: Project | None):
+        if project:
+            return MinimalProjectResponse(id=project.id.id, version=project._version)
+
+
+class ProjectResponse(BaseModel):
     id: str
     version: int
     name: str
     description: str
 
     @staticmethod
     def from_project(project: Project):
-        return SimpleProjectResponse(
+        return ProjectResponse(
             id=project.id.id,
             version=project._version,
             name=project.name,
@@ -20,12 +30,29 @@ def from_project(project: Project):
 
 
 class ListProjectsResponse(BaseModel):
-    data: list[SimpleProjectResponse]
+    data: list[ProjectResponse]
     total: int
 
     @staticmethod
     def from_paged(paged: Paged[Project]) -> "ListProjectsResponse":
         return ListProjectsResponse(
-            data=paged.map(SimpleProjectResponse.from_project).data,
+            data=paged.map(ProjectResponse.from_project).data,
             total=paged.total
         )
+
+
+class ProjectMembershipResponse(BaseModel):
+    id: str
+    version: int
+    person_id: str
+    project_id: str
+
+    @staticmethod
+    def from_project_membership(membership: ProjectMembership | None):
+        if membership:
+            return ProjectMembershipResponse(
+                id=membership.id.id,
+                version=membership._version,
+                person_id=membership.person.id,
+                project_id=membership.project.id
+            )

src/liceo/people/projects/adapters/service.py

@@ -2,32 +2,52 @@
 from liceo.infra.domain.vo import Paged
 from liceo.labs.db.core import AbstractService, managed_service, transactional
 from liceo.labs.sherlock.application.service import EventStoreService
-from liceo.people.projects.application.dtos import CreateProjectDTO, FilterProjectsDTO
-from ..application.repository import ProjectRepository
+from liceo.people.projects.application.dtos import AddMemberToProjectDTO, CreateProjectDTO, FilterProjectsDTO
+from ..application.repository import ProjectRepository, ProjectMemberRepository
 from ..application.service import ProjectService
 from ..domain import entities
 
 
 @dataclass
 @managed_service
 class DatabaseAwareProjectService(ProjectService, AbstractService):
-    repository: ProjectRepository
+    projects: ProjectRepository
+    project_members: ProjectMemberRepository
     event_store: EventStoreService
 
     @transactional()
     def create_project(self, dto: CreateProjectDTO) -> entities.Project:
         project = entities.Project.create(
             entities.Project.CreateProjectCommand(
-                id=self.repository.generate_id(),
+                id=self.projects.generate_id(),
                 name=dto.name,
                 description=dto.description,
                 created_by=dto.created_by
             )
         )
 
-        self.repository.save_project(project)
+        self.projects.save_project(project)
         self.event_store.append(project)
         return project
 
     def filter_projects(self, dto: FilterProjectsDTO) -> Paged[entities.Project]:
-        return self.repository.filter_projects_by_name(name=dto.name, pagination=dto.pagination)
+        return self.projects.filter_projects_by_name(name=dto.name, pagination=dto.pagination)
+
+    @transactional()
+    def add_new_member(self, dto: AddMemberToProjectDTO) -> entities.ProjectMembership | None:
+        project = self.projects.find_project_by_id(dto.project_id)
+
+        if not project:
+            return
+
+        project_membership = entities.ProjectMembership.create(
+            entities.ProjectMembership.CreateMembershipCommand(
+                id=self.project_members.generate_id(),
+                project_id=dto.project_id,
+                person_id=dto.person_id,
+                created_by=dto.created_by
+            )
+        )
+        self.project_members.save_membership(project_membership)
+        self.event_store.append(project_membership)
+        return project_membership

src/liceo/people/projects/adapters/sql/find_project_by_id.sql

@@ -0,0 +1,3 @@
+SELECT p.*
+FROM liceo_projects p
+WHERE p.id = :id;

src/liceo/people/projects/adapters/sql/save_project_membership.sql

@@ -0,0 +1,14 @@
+INSERT INTO liceo_projects_people
+(
+    id,
+    version,
+    project_id,
+    person_id
+)
+VALUES
+(
+    :id,
+    :version,
+    :project_id,
+    :person_id
+) RETURNING id;