Add mutation to reextract pnp progress data

Author: CarsonF

src/components/progress-report/progress-report.module.ts

@@ -1,4 +1,5 @@
 import { forwardRef, Module } from '@nestjs/common';
+import { FileModule } from '../file/file.module';
 import { PeriodicReportModule } from '../periodic-report/periodic-report.module';
 import { ProgressReportCommunityStoryRepository } from './community-stories/progress-report-community-story.repository';
 import { ProgressReportCommunityStoryResolver } from './community-stories/progress-report-community-story.resolver';
@@ -12,6 +13,7 @@ import { ProgressReportRepository } from './progress-report.repository';
 import { ProgressReportService } from './progress-report.service';
 import { ProgressReportEngagementConnectionResolver } from './resolvers/progress-report-engagement-connection.resolver';
 import { ProgressReportParentResolver } from './resolvers/progress-report-parent.resolver';
+import { ReextractPnpResolver } from './resolvers/reextract-pnp.resolver';
 import { ProgressReportTeamNewsRepository } from './team-news/progress-report-team-news.repository';
 import { ProgressReportTeamNewsResolver } from './team-news/progress-report-team-news.resolver';
 import { ProgressReportTeamNewsService } from './team-news/progress-report-team-news.service';
@@ -24,10 +26,12 @@ import { ProgressReportWorkflowModule } from './workflow/progress-report-workflo
     ProgressReportWorkflowModule,
     ProgressReportVarianceExplanationModule,
     ProgressReportMediaModule,
+    FileModule,
   ],
   providers: [
     ProgressReportParentResolver,
     ProgressReportEngagementConnectionResolver,
+    ReextractPnpResolver,
     ProgressReportTeamNewsResolver,
     ProgressReportTeamNewsService,
     ProgressReportTeamNewsRepository,

src/components/progress-report/resolvers/reextract-pnp.resolver.ts

@@ -0,0 +1,49 @@
+import { Mutation, Resolver } from '@nestjs/graphql';
+import { ID, IdArg, InputException, LoggedInSession, Session } from '~/common';
+import { IEventBus, Loader, LoaderOf } from '~/core';
+import { FileNodeLoader, FileService, resolveDefinedFile } from '../../file';
+import { PeriodicReportLoader } from '../../periodic-report';
+import { PeriodicReportUploadedEvent } from '../../periodic-report/events';
+import { PnpProgressExtractionResult } from '../../pnp/extraction-result';
+
+@Resolver()
+export class ReextractPnpResolver {
+  constructor(
+    private readonly files: FileService,
+    private readonly eventBus: IEventBus,
+  ) {}
+
+  @Mutation(() => PnpProgressExtractionResult)
+  async reextractPnpProgress(
+    @IdArg({
+      name: 'reportId',
+      description: 'An ID of a ProgressReport that has a reportFile uploaded',
+    })
+    reportId: ID,
+    @Loader(PeriodicReportLoader) reportLoader: LoaderOf<PeriodicReportLoader>,
+    @Loader(FileNodeLoader) fileLoader: LoaderOf<FileNodeLoader>,
+    @LoggedInSession() session: Session,
+  ): Promise<PnpProgressExtractionResult> {
+    const report = await reportLoader.load(reportId);
+    if (report.type !== 'Progress') {
+      throw new InputException(
+        "Only ProgressReports can have PnP's re-extracted",
+      );
+    }
+    const file = await resolveDefinedFile(fileLoader, report.reportFile);
+    if (!file.value) {
+      throw new InputException('This report does not have a PnP uploaded');
+    }
+
+    const fv = await this.files.getFileVersion(
+      file.value.latestVersionId,
+      session,
+    );
+    const pnp = this.files.asDownloadable(fv);
+
+    const event = new PeriodicReportUploadedEvent(report, pnp, session);
+    await this.eventBus.publish(event);
+
+    return event.pnpResult;
+  }
+}