Forward director changes to open project memberships

Author: CarsonF

src/components/project/project-member/handlers/director-change-apply-to-project-members.handler.ts

@@ -0,0 +1,40 @@
+import { type Role } from '~/common';
+import { EventsHandler } from '~/core/events';
+import { ILogger, Logger } from '~/core/logger';
+import { FieldRegionUpdatedEvent } from '../../../field-region/events/field-region-updated.event';
+import { FieldZoneUpdatedEvent } from '../../../field-zone/events/field-zone-updated.event';
+import { ProjectMemberRepository } from '../project-member.repository';
+
+@EventsHandler(FieldZoneUpdatedEvent, FieldRegionUpdatedEvent)
+export class DirectorChangeApplyToProjectMembersHandler {
+  constructor(
+    private readonly repo: ProjectMemberRepository,
+    @Logger('project:members') private readonly logger: ILogger,
+  ) {}
+
+  async handle(event: FieldZoneUpdatedEvent | FieldRegionUpdatedEvent) {
+    const oldDirector = event.previous.director.id;
+    const newDirector = event.input.directorId;
+    if (!newDirector) {
+      return;
+    }
+    const role: Role =
+      event instanceof FieldZoneUpdatedEvent
+        ? 'FieldOperationsDirector'
+        : 'RegionalDirector';
+
+    const stats = await this.repo.replaceMembershipsOnOpenProjects(
+      oldDirector,
+      newDirector,
+      role,
+    );
+
+    this.logger.notice('Replaced director memberships on open projects', {
+      location: event.updated.id,
+      oldDirector,
+      newDirector,
+      role,
+      ...stats,
+    });
+  }
+}

src/components/project/project-member/project-member.gel.repository.ts

@@ -72,4 +72,55 @@ export class ProjectMemberGelRepository
         ),
     ];
   }
+
+  async replaceMembershipsOnOpenProjects(
+    oldDirector: ID<'User'>,
+    newDirector: ID<'User'>,
+    role: Role,
+  ) {
+    return await this.db.run(this.replaceMembershipsOnOpenProjectsQuery, {
+      oldDirector,
+      newDirector,
+      role,
+    });
+  }
+  private readonly replaceMembershipsOnOpenProjectsQuery = e.params(
+    {
+      oldDirector: e.uuid,
+      newDirector: e.uuid,
+      role: e.Role,
+    },
+    ($) => {
+      const oldDirector = e.cast(e.User, $.oldDirector);
+      const newDirector = e.cast(e.User, $.newDirector);
+
+      const members = e.select(e.Project.members, (member) => ({
+        filter: e.all(
+          e.set(
+            e.op(member.user, '=', oldDirector),
+            e.op(member.active, '=', true),
+            e.op($.role, 'in', member.roles),
+            e.op(member.project.status, 'in', e.set('Active', 'InDevelopment')),
+          ),
+        ),
+      }));
+      const inactivated = e.update(members, () => ({
+        set: {
+          inactiveAt: e.datetime_of_transaction(),
+        },
+      }));
+      const replacements = e.for(inactivated.project, (project) =>
+        e.insert(e.Project.Member, {
+          project,
+          projectContext: project.projectContext,
+          user: newDirector,
+          roles: $.role,
+        }),
+      );
+      return e.select({
+        timestampId: e.datetime_of_transaction(),
+        projects: replacements.project.id,
+      });
+    },
+  );
 }

src/components/project/project-member/project-member.module.ts

@@ -4,6 +4,7 @@ import { AuthorizationModule } from '../../authorization/authorization.module';
 import { UserModule } from '../../user/user.module';
 import { ProjectModule } from '../project.module';
 import { AvailableRolesToProjectResolver } from './available-roles-to-project.resolver';
+import { DirectorChangeApplyToProjectMembersHandler } from './handlers/director-change-apply-to-project-members.handler';
 import { AddInactiveAtMigration } from './migrations/add-inactive-at.migration';
 import { ProjectMemberGelRepository } from './project-member.gel.repository';
 import { ProjectMemberLoader } from './project-member.loader';
@@ -24,6 +25,7 @@ import { ProjectMemberService } from './project-member.service';
     splitDb(ProjectMemberRepository, ProjectMemberGelRepository),
     ProjectMemberLoader,
     AddInactiveAtMigration,
+    DirectorChangeApplyToProjectMembersHandler,
   ],
   exports: [ProjectMemberService],
 })

src/components/project/project-member/project-member.repository.ts

@@ -20,7 +20,10 @@ import {
   merge,
   oncePerProject,
   paginate,
+  randomUUID,
   sorting,
+  updateProperty,
+  variable,
 } from '~/core/database/query';
 import { type FilterFn } from '~/core/database/query/filters';
 import { userFilters, UserRepository } from '../../user/user.repository';
@@ -183,6 +186,63 @@ export class ProjectMemberRepository extends DtoRepository(ProjectMember) {
       ])
       .run();
   }
+
+  async replaceMembershipsOnOpenProjects(
+    oldDirector: ID<'User'>,
+    newDirector: ID<'User'>,
+    role: Role,
+  ) {
+    const now = DateTime.now();
+    const result = await this.db
+      .query()
+      .match([
+        node('project', 'Project'),
+        relation('out', '', 'member', ACTIVE),
+        node('node', 'ProjectMember'),
+      ])
+      .apply(
+        projectMemberFilters({
+          user: { id: oldDirector },
+          active: true,
+          roles: [role],
+          project: { status: ['Active', 'InDevelopment'] },
+        }),
+      )
+      .apply(
+        updateProperty({
+          resource: ProjectMember,
+          key: 'inactiveAt',
+          value: now,
+          permanentAfter: 0,
+        }),
+      )
+      .with('project')
+      .apply(
+        await createNode(ProjectMember, {
+          baseNodeProps: {
+            id: variable(randomUUID()),
+            createdAt: now,
+          },
+          initialProps: {
+            roles: [role],
+            inactiveAt: null,
+            modifiedAt: now,
+          },
+        }),
+      )
+      .apply(
+        createRelationships(ProjectMember, {
+          in: { member: variable('project') },
+          out: { user: ['User', newDirector] },
+        }),
+      )
+      .return<{ id: ID }>('project.id as id')
+      .run();
+    return {
+      projects: result.map(({ id }) => id) as readonly ID[],
+      timestampId: now,
+    };
+  }
 }
 
 export const projectMemberFilters = filter.define(() => ProjectMemberFilters, {