feat: import legacy projects api events (#1047)

* feat: import legacy projects api events * feat: import legacy projects piece api events
Vizzuality · May 9, 2022 · 3eebb8e · 3eebb8e
1 parent 327c7d4
commit 3eebb8e
Show file tree

Hide file tree

Showing 3 changed files with 60 additions and 0 deletions.
diff --git a/api/apps/api/src/migrations/api/1652099652734-AddImportLegacyProjectsApiEvents.ts b/api/apps/api/src/migrations/api/1652099652734-AddImportLegacyProjectsApiEvents.ts
@@ -0,0 +1,42 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddImportLegacyProjectsApiEvents1652099652734
+  implements MigrationInterface {
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`
+      INSERT INTO api_event_kinds (id) values
+      ('project.legacy.import.submitted/v1/alpha'),
+      ('project.legacy.import.finished/v1/alpha'),
+      ('project.legacy.import.failed/v1/alpha'),
+      ('project.legacy.import.piece.submitted/v1/alpha'),
+      ('project.legacy.import.piece.finished/v1/alpha'),
+      ('project.legacy.import.piece.failed/v1/alpha');
+    `);
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `DELETE FROM api_event_kinds WHERE id = 'project.legacy.import.submitted/v1/alpha';`,
+    );
+
+    await queryRunner.query(
+      `DELETE FROM api_event_kinds WHERE id = 'project.legacy.import.finished/v1/alpha';`,
+    );
+
+    await queryRunner.query(
+      `DELETE FROM api_event_kinds WHERE id = 'project.legacy.import.failed/v1/alpha';`,
+    );
+
+    await queryRunner.query(
+      `DELETE FROM api_event_kinds WHERE id = 'project.legacy.import.piece.submitted/v1/alpha';`,
+    );
+
+    await queryRunner.query(
+      `DELETE FROM api_event_kinds WHERE id = 'project.legacy.import.piece.finished/v1/alpha';`,
+    );
+
+    await queryRunner.query(
+      `DELETE FROM api_event_kinds WHERE id = 'project.legacy.import.piece.failed/v1/alpha';`,
+    );
+  }
+}
diff --git a/api/apps/api/src/modules/projects/job-status/project-status.view.api.entity.ts b/api/apps/api/src/modules/projects/job-status/project-status.view.api.entity.ts
@@ -76,4 +76,16 @@ const eventToJobStatusMapping: Record<ValuesType<ProjectEvents>, JobStatus> = {
   [API_EVENT_KINDS.project__clone__failed__v1__alpha]: JobStatus.failure,
   [API_EVENT_KINDS.project__clone__finished__v1__alpha]: JobStatus.done,
   [API_EVENT_KINDS.project__clone__submitted__v1__alpha]: JobStatus.running,
+  [API_EVENT_KINDS.project__legacy__import__failed__v1__alpha]:
+    JobStatus.failure,
+  [API_EVENT_KINDS.project__legacy__import__finished__v1__alpha]:
+    JobStatus.done,
+  [API_EVENT_KINDS.project__legacy__import__submitted__v1__alpha]:
+    JobStatus.running,
+  [API_EVENT_KINDS.project__legacy__import__piece__failed__v1__alpha]:
+    JobStatus.failure,
+  [API_EVENT_KINDS.project__legacy__import__piece__finished__v1__alpha]:
+    JobStatus.done,
+  [API_EVENT_KINDS.project__legacy__import__piece__submitted__v1__alpha]:
+    JobStatus.running,
 };
diff --git a/api/libs/api-events/src/api-event-kinds.enum.ts b/api/libs/api-events/src/api-event-kinds.enum.ts
@@ -82,6 +82,12 @@ export enum API_EVENT_KINDS {
   scenario__clone__submitted__v1__alpha = 'scenario.clone.submitted/v1/alpha',
   scenario__clone__finished__v1__alpha = 'scenario.clone.finished/v1/alpha',
   scenario__clone__failed__v1__alpha = 'scenario.clone.failed/v1/alpha',
+  project__legacy__import__submitted__v1__alpha = 'project.legacy.import.submitted/v1/alpha',
+  project__legacy__import__finished__v1__alpha = 'project.legacy.import.finished/v1/alpha',
+  project__legacy__import__failed__v1__alpha = 'project.legacy.import.failed/v1/alpha',
+  project__legacy__import__piece__submitted__v1__alpha = 'project.legacy.import.piece.submitted/v1/alpha',
+  project__legacy__import__piece__finished__v1__alpha = 'project.legacy.import.piece.finished/v1/alpha',
+  project__legacy__import__piece__failed__v1__alpha = 'project.legacy.import.piece.failed/v1/alpha',
 }
 
 export type ProjectEvents = Pick<