feat: add get all project migrations (#740)

Author: andre-code

components/renku_data_services/project/api.spec.yaml

@@ -148,6 +148,26 @@ paths:
           $ref: "#/components/responses/Error"
       tags:
         - projects
+  /renku_v1_projects/migrations:
+    get:
+      summary: Return list of projects migrated from v1
+      responses:
+        "200":
+          description: List of project migrations
+          content:
+            application/json:
+              schema:
+                $ref: "#/components/schemas/ProjectMigrationList"
+        "404":
+          description: No exist project migration
+          content:
+            application/json:
+              schema:
+                $ref: "#/components/schemas/ErrorResponse"
+        default:
+          $ref: "#/components/responses/Error"
+      tags:
+        - projects_migrations
   /renku_v1_projects/{v1_id}/migrations:
     get:
       summary: Check if a v1 project has been migrated to v2
@@ -1011,6 +1031,12 @@ components:
             description: A flag to filter projects where the user is a direct member.
             type: boolean
             default: false
+    ProjectMigrationList:
+      description: A list of project migrations
+      type: array
+      items:
+        $ref: "#/components/schemas/ProjectMigrationInfo"
+      minItems: 0
     ProjectMigrationInfo:
       description: Information if a project is a migrated project
       type: object

components/renku_data_services/project/apispec.py

@@ -1,6 +1,6 @@
 # generated by datamodel-codegen:
 #   filename:  api.spec.yaml
-#   timestamp: 2025-05-05T09:34:43+00:00
+#   timestamp: 2025-05-06T08:33:41+00:00
 
 from __future__ import annotations
 
@@ -249,6 +249,12 @@ class ProjectGetQuery(PaginationRequest):
     )
 
 
+class ProjectMigrationList(RootModel[List[ProjectMigrationInfo]]):
+    root: List[ProjectMigrationInfo] = Field(
+        ..., description="A list of project migrations", min_length=0
+    )
+
+
 class SessionSecretSlot(BaseAPISpec):
     model_config = ConfigDict(
         extra="forbid",

components/renku_data_services/project/blueprints.py

@@ -89,6 +89,22 @@ async def _post(_: Request, user: base_models.APIUser, body: apispec.ProjectPost
 
         return "/projects", ["POST"], _post
 
+    def get_all_migrations(self) -> BlueprintFactoryResponse:
+        """List all project migrations."""
+
+        @authenticate(self.authenticator)
+        @only_authenticated
+        async def _get_all_migrations(_: Request, user: base_models.APIUser) -> JSONResponse:
+            project_migrations = self.project_migration_repo.get_project_migrations(user=user)
+
+            migrations_list = []
+            async for migration in project_migrations:
+                migrations_list.append(self._dump_project_migration(migration))
+
+            return validated_json(apispec.ProjectMigrationList, migrations_list)
+
+        return "/renku_v1_projects/migrations", ["GET"], _get_all_migrations
+
     def get_migration(self) -> BlueprintFactoryResponse:
         """Get project migration by project v1 id."""
 
@@ -381,6 +397,16 @@ def _dump_project(project: project_models.Project, with_documentation: bool = Fa
             result = dict(result, documentation=project.documentation)
         return result
 
+    @staticmethod
+    def _dump_project_migration(project_migration: project_models.ProjectMigrationInfo) -> dict[str, Any]:
+        """Dumps a project migration for API responses."""
+        result = dict(
+            project_id=project_migration.project_id,
+            v1_id=project_migration.v1_id,
+            launcher_id=project_migration.launcher_id,
+        )
+        return result
+
 
 @dataclass(kw_only=True)
 class ProjectSessionSecretBP(CustomBlueprint):

components/renku_data_services/project/db.py

@@ -925,6 +925,19 @@ def __init__(
         self.event_repo: EventRepository = event_repo
         self.session_repo = session_repo
 
+    async def get_project_migrations(
+        self,
+        user: base_models.APIUser,
+    ) -> AsyncGenerator[models.ProjectMigrationInfo, None]:
+        """Get all project migrations from the database."""
+        project_ids = await self.authz.resources_with_permission(user, user.id, ResourceType.project, Scope.READ)
+
+        async with self.session_maker() as session:
+            stmt = select(schemas.ProjectMigrationsORM).where(schemas.ProjectMigrationsORM.project_id.in_(project_ids))
+            result = await session.stream_scalars(stmt)
+            async for migration in result:
+                yield migration.dump()
+
     @with_db_transaction
     @Authz.authz_change(AuthzOperation.create, ResourceType.project)
     @dispatch_message(avro_schema_v2.ProjectCreated)

components/renku_data_services/project/orm.py

@@ -246,3 +246,9 @@ class ProjectMigrationsORM(BaseORM):
 
     launcher_id: Mapped[Optional[ULID]] = mapped_column(ULIDType, nullable=True, default=None)
     """Stores the launcher ID without enforcing a foreign key."""
+
+    def dump(self) -> models.ProjectMigrationInfo:
+        """Create a project model from the ProjectMigrationInfoORM."""
+        return models.ProjectMigrationInfo(
+            project_id=self.project_id, v1_id=self.project_v1_id, launcher_id=self.launcher_id
+        )

test/bases/renku_data_services/data_api/test_projects.py

@@ -1902,3 +1902,8 @@ async def test_migrate_v1_project(
     migrated_project = response.json
     assert migrated_project["v1_id"] == v1_id
     assert migrated_project["project_id"] == project_id
+
+    _, response = await sanic_client.get("/api/data/renku_v1_projects/migrations", headers=user_headers)
+    assert response.status_code == 200, response.text
+    migrated_projects = response.json
+    assert {project_migration["v1_id"] for project_migration in migrated_projects} == {1122}