feature(Specification): Moves the CSV Import event to the start of pr…

…ocessing

api/apps/api/src/modules/specification/adapters/specification-adapters.module.ts

@@ -9,13 +9,19 @@ import { SpecificationFeatureConfigApiEntity } from './specification-feature-con
 import { SpecificationCandidateCreatedHandler } from './specification-candidate-created.handler';
 
 import { SpecificationRepository } from '../application/specification.repository';
+import { ScenarioFeaturesPreparation } from '@marxan/features';
+import { DbConnections } from '@marxan-api/ormconfig.connections';
 
 @Module({
   imports: [
     TypeOrmModule.forFeature([
       SpecificationApiEntity,
       SpecificationFeatureConfigApiEntity,
     ]),
+    TypeOrmModule.forFeature(
+      [ScenarioFeaturesPreparation],
+      DbConnections.geoprocessingDB,
+    ),
     ApiEventsModule,
   ],
   providers: [

api/apps/api/src/modules/specification/adapters/specification-candidate-created.handler.ts

@@ -2,15 +2,28 @@ import { EventsHandler, IEventHandler } from '@nestjs/cqrs';
 import { SpecificationCandidateCreated } from '../domain';
 import { API_EVENT_KINDS } from '@marxan/api-events';
 import { ApiEventsService } from '@marxan-api/modules/api-events/api-events.service';
+import { InjectEntityManager } from '@nestjs/typeorm';
+import { DbConnections } from '@marxan-api/ormconfig.connections';
+import { EntityManager } from 'typeorm';
+import { ScenarioFeaturesPreparation } from '@marxan/features';
 
 @EventsHandler(SpecificationCandidateCreated)
 export class SpecificationCandidateCreatedHandler
   implements IEventHandler<SpecificationCandidateCreated>
 {
-  constructor(private readonly apiEvents: ApiEventsService) {}
+  constructor(
+    private readonly apiEvents: ApiEventsService,
+    @InjectEntityManager(DbConnections.geoprocessingDB)
+    private readonly geoEntityManager: EntityManager,
+  ) {}
 
   async handle(event: SpecificationCandidateCreated) {
     if (event.draft) return;
+
+    await this.geoEntityManager.delete(ScenarioFeaturesPreparation, {
+      scenarioId: event.scenarioId,
+    });
+
     await this.apiEvents.create({
       kind: API_EVENT_KINDS.scenario__specification__submitted__v1__alpha1,
       topic: event.scenarioId,

api/apps/geoprocessing/src/migrations/geoprocessing/1713363912361-AddScenarioIndexForScenarioFeaturePreparation.ts

@@ -0,0 +1,17 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddScenarioIndexForScenarioFeaturePreparation1713363912361
+  implements MigrationInterface
+{
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`
+        CREATE INDEX scenario_feature_preparations_scenario_id__idx ON scenario_feature_preparations(scenario_id);
+      `);
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `DROP INDEX scenario_feature_preparations_scenario_id__idx;`,
+    );
+  }
+}