xiaoxia
0422967229
BREAKING CHANGES:
- Removed Workspace, WorkspaceMember, WorkspaceInvitation entities
- Project now has owner_user_id instead of workspace_id
- Added shared_users list to Project for collaboration
- Subscription/quota moved from Workspace to User level
Changes:
- packages/domain/entities.py: Removed Workspace entities, updated Project
- packages/adapters/sqlalchemy_impl/models.py: Updated models
- packages/application/: Removed workspace use cases, updated other use cases
- packages/ports/: Removed workspace repository interfaces
- apps/api/: Updated routes, schemas, dependencies, router
- alembic/versions/007_remove_workspace_concept.py: Database migration
New APIs:
- POST /projects/{id}/share: Share project with user
- DELETE /projects/{id}/share/{user_id}: Unshare project
78 lines
2.7 KiB
Python
78 lines
2.7 KiB
Python
from __future__ import annotations
|
|
|
|
from dataclasses import dataclass
|
|
|
|
from packages.domain import Project
|
|
from packages.ports import ProjectRepository
|
|
|
|
|
|
@dataclass(slots=True)
|
|
class CreateProjectCommand:
|
|
name: str
|
|
description: str = ""
|
|
|
|
|
|
class ListProjectsUseCase:
|
|
def __init__(self, project_repository: ProjectRepository):
|
|
self.project_repository = project_repository
|
|
|
|
def execute(self, user_id: str) -> list[Project]:
|
|
if not user_id.strip():
|
|
raise ValueError("user_id 不能为空")
|
|
return self.project_repository.find_accessible_projects(user_id.strip())
|
|
|
|
|
|
class GetProjectUseCase:
|
|
def __init__(self, project_repository: ProjectRepository):
|
|
self.project_repository = project_repository
|
|
|
|
def execute(self, project_id: str) -> Project | None:
|
|
if not project_id.strip():
|
|
raise ValueError("project_id 不能为空")
|
|
return self.project_repository.find_by_id(project_id.strip())
|
|
|
|
|
|
class CreateProjectUseCase:
|
|
def __init__(self, project_repository: ProjectRepository):
|
|
self.project_repository = project_repository
|
|
|
|
def execute(self, command: CreateProjectCommand, owner_user_id: str) -> Project:
|
|
project = Project.create(
|
|
owner_user_id=owner_user_id,
|
|
name=command.name,
|
|
description=command.description,
|
|
)
|
|
return self.project_repository.save(project)
|
|
|
|
|
|
class ShareProjectUseCase:
|
|
def __init__(self, project_repository: ProjectRepository):
|
|
self.project_repository = project_repository
|
|
|
|
def execute(self, project_id: str, owner_user_id: str, shared_user_id: str) -> Project:
|
|
project = self.project_repository.find_by_id(project_id)
|
|
if not project:
|
|
raise ValueError("项目不存在")
|
|
if not project.is_owner(owner_user_id):
|
|
raise ValueError("只有项目所有者可以共享项目")
|
|
if shared_user_id not in project.shared_users:
|
|
project.shared_users.append(shared_user_id)
|
|
self.project_repository.save(project)
|
|
return project
|
|
|
|
|
|
class UnshareProjectUseCase:
|
|
def __init__(self, project_repository: ProjectRepository):
|
|
self.project_repository = project_repository
|
|
|
|
def execute(self, project_id: str, owner_user_id: str, shared_user_id: str) -> Project:
|
|
project = self.project_repository.find_by_id(project_id)
|
|
if not project:
|
|
raise ValueError("项目不存在")
|
|
if not project.is_owner(owner_user_id):
|
|
raise ValueError("只有项目所有者可以取消共享")
|
|
if shared_user_id in project.shared_users:
|
|
project.shared_users.remove(shared_user_id)
|
|
self.project_repository.save(project)
|
|
return project
|