Validate partnership date overrides against the project

Author: CarsonF

src/components/partnership/handlers/index.ts

@@ -1 +1,2 @@
 export * from './apply-finalized-changeset-to-partnership.handler';
+export * from './validate-partnership-date-overrides-on-project-change.handler';

src/components/partnership/handlers/validate-partnership-date-overrides-on-project-change.handler.ts

@@ -0,0 +1,46 @@
+import { DateOverrideConflictException } from '~/common';
+import { EventsHandler, IEventHandler } from '~/core';
+import { ProjectUpdatedEvent } from '../../project/events';
+import { PartnershipService } from '../partnership.service';
+
+@EventsHandler(ProjectUpdatedEvent)
+export class ValidatePartnershipDateOverridesOnProjectChangeHandler
+  implements IEventHandler<ProjectUpdatedEvent>
+{
+  constructor(private readonly partnerships: PartnershipService) {}
+
+  async handle(event: ProjectUpdatedEvent) {
+    const { updated: project, changes, session } = event;
+
+    if (changes.mouStart === undefined && changes.mouEnd === undefined) {
+      return;
+    }
+
+    const canonical = { start: project.mouStart, end: project.mouEnd };
+    const partnerships = await this.partnerships.listAllByProjectId(
+      project.id,
+      session,
+    );
+    const conflicts = DateOverrideConflictException.findConflicts(
+      canonical,
+      partnerships.map((partnership) => ({
+        __typename: 'Partnership',
+        id: partnership.id,
+        label: partnership.id, // TODO
+        start: partnership.mouStartOverride,
+        end: partnership.mouEndOverride,
+      })),
+    );
+    if (!conflicts) return;
+    throw new DateOverrideConflictException(
+      {
+        __typename: event.resource.name,
+        id: project.id,
+        name: project.name,
+      },
+      canonical,
+      ['A partnership', 'Some partnerships'],
+      conflicts,
+    );
+  }
+}

src/components/partnership/partnership.gel.repository.ts

@@ -49,6 +49,14 @@ export class PartnershipGelRepository
       ),
   );
 
+  async listAllByProjectId(project: ID) {
+    return await this.db.run(this.listAllByProjectIdQuery, { project });
+  }
+  private readonly listAllByProjectIdQuery = e.params(
+    { project: e.uuid },
+    ($) => e.select(e.cast(e.Project, $.project).partnerships, this.hydrate),
+  );
+
   async isFirstPartnership(projectId: ID) {
     const project = e.cast(e.Project, e.uuid(projectId));
     const query = e.op('not', e.op('exists', project.partnerships));

src/components/partnership/partnership.repository.ts

@@ -183,6 +183,19 @@ export class PartnershipRepository extends DtoRepository<
       .run();
   }
 
+  async listAllByProjectId(projectId: ID, session: Session) {
+    return await this.db
+      .query()
+      .match([
+        node('project', 'Project', { id: projectId }),
+        relation('out', '', 'partnership', ACTIVE),
+        node('node', 'Partnership'),
+      ])
+      .apply(this.hydrate(session))
+      .map('dto')
+      .run();
+  }
+
   protected override hydrate(session: Session, view?: ObjectView) {
     return (query: Query) =>
       query

src/components/partnership/partnership.service.ts

@@ -144,6 +144,10 @@ export class PartnershipService {
     }));
   }
 
+  async listAllByProjectId(projectId: ID, session: Session) {
+    return await this.repo.listAllByProjectId(projectId, session);
+  }
+
   secure(dto: UnsecuredDto<Partnership>, session: Session) {
     return this.privileges.for(session, Partnership).secure(dto);
   }