feat: use invite dialogue to invite visitors

apps/backend/db_patches/0183_AddVisitRegistrationClaim.sql

@@ -0,0 +1,26 @@
+DO
+$$
+BEGIN
+    IF register_patch(
+        'AddVisitRegistrationClaim.sql',
+        'Jekabs Karklins',
+        'Adding table to store visit registration claims',
+        '2025-06-04'
+    ) THEN
+        BEGIN
+            -- Create the visit_registration_claims table
+            CREATE TABLE IF NOT EXISTS visit_registration_claims (
+                invite_id INT NOT NULL,
+                visit_id INT NOT NULL,
+                FOREIGN KEY (invite_id) REFERENCES invites(invite_id) ON DELETE CASCADE,
+                FOREIGN KEY (visit_id) REFERENCES visits(visit_id) ON DELETE CASCADE,
+                UNIQUE (invite_id, visit_id)
+            );
+
+            ALTER TABLE visit_registration_claims ADD CONSTRAINT visit_registration_unique
+            UNIQUE (invite_id, visit_id);
+        END;
+    END IF;
+END;
+$$
+LANGUAGE plpgsql;

apps/backend/src/config/Tokens.ts

@@ -42,9 +42,11 @@ export const Tokens = {
   UnitDataSource: Symbol('UnitDataSource'),
   UserAuthorization: Symbol('UserAuthorization'),
   ProposalAuthorization: Symbol('ProposalAuthorization'),
+  VisitAuthorization: Symbol('VisitAuthorization'),
   VisitRegistrationAuthorization: Symbol('VisitRegistrationAuthorization'),
   UserDataSource: Symbol('UserDataSource'),
   VisitDataSource: Symbol('VisitDataSource'),
+  VisitRegistrationClaimDataSource: Symbol('VisitRegistrationClaimDataSource'),
   PredefinedMessageDataSource: Symbol('PredefinedMessageDataSource'),
   InternalReviewDataSource: Symbol('InternalReviewDataSource'),
   FapDataColumns: Symbol('FapDataColumns'),

apps/backend/src/config/dependencyConfigDefault.ts

@@ -8,6 +8,7 @@ import 'reflect-metadata';
 import { DataAccessUsersAuthorization } from '../auth/DataAccessUsersAuthorization';
 import { OAuthAuthorization } from '../auth/OAuthAuthorization';
 import { ProposalAuthorization } from '../auth/ProposalAuthorization';
+import { VisitAuthorization } from '../auth/VisitAuthorization';
 import { VisitRegistrationAuthorization } from '../auth/VisitRegistrationAuthorization';
 import { PostgresAdminDataSourceWithAutoUpgrade } from '../datasources/postgres/AdminDataSource';
 import PostgresCallDataSource from '../datasources/postgres/CallDataSource';
@@ -43,6 +44,7 @@ import PostgresTemplateDataSource from '../datasources/postgres/TemplateDataSour
 import PostgresUnitDataSource from '../datasources/postgres/UnitDataSource';
 import PostgresUserDataSource from '../datasources/postgres/UserDataSource';
 import PostgresVisitDataSource from '../datasources/postgres/VisitDataSource';
+import PostgresVisitRegistrationClaimDataSource from '../datasources/postgres/VisitRegistrationClaimDataSource';
 import PostgresWorkflowDataSource from '../datasources/postgres/WorkflowDataSource';
 import { createSkipLoggingHandler } from '../eventHandlers/logging';
 import { SkipSendMailService } from '../eventHandlers/MailService/SkipSendMailService';
@@ -106,6 +108,11 @@ mapClass(Tokens.TemplateDataSource, PostgresTemplateDataSource);
 mapClass(Tokens.UnitDataSource, PostgresUnitDataSource);
 mapClass(Tokens.UserDataSource, PostgresUserDataSource);
 mapClass(Tokens.VisitDataSource, PostgresVisitDataSource);
+mapClass(
+  Tokens.VisitRegistrationClaimDataSource,
+  PostgresVisitRegistrationClaimDataSource
+);
+mapClass(Tokens.VisitAuthorization, VisitAuthorization);
 mapClass(Tokens.VisitRegistrationAuthorization, VisitRegistrationAuthorization);
 mapClass(Tokens.TechniqueDataSource, PostgresTechniqueDataSource);
 mapClass(

apps/backend/src/config/dependencyConfigE2E.ts

@@ -4,6 +4,7 @@ import 'reflect-metadata';
 import { DataAccessUsersAuthorization } from '../auth/DataAccessUsersAuthorization';
 import { OAuthAuthorization } from '../auth/OAuthAuthorization';
 import { ProposalAuthorization } from '../auth/ProposalAuthorization';
+import { VisitAuthorization } from '../auth/VisitAuthorization';
 import { VisitRegistrationAuthorization } from '../auth/VisitRegistrationAuthorization';
 import PostgresAdminDataSource from '../datasources/postgres/AdminDataSource';
 import PostgresCallDataSource from '../datasources/postgres/CallDataSource';
@@ -39,6 +40,7 @@ import PostgresTemplateDataSource from '../datasources/postgres/TemplateDataSour
 import PostgresUnitDataSource from '../datasources/postgres/UnitDataSource';
 import PostgresUserDataSource from '../datasources/postgres/UserDataSource';
 import PostgresVisitDataSource from '../datasources/postgres/VisitDataSource';
+import PostgresVisitRegistrationClaimDataSource from '../datasources/postgres/VisitRegistrationClaimDataSource';
 import PostgresWorkflowDataSource from '../datasources/postgres/WorkflowDataSource';
 import { essEmailHandler } from '../eventHandlers/email/essEmailHandler';
 import createLoggingHandler from '../eventHandlers/logging';
@@ -97,6 +99,11 @@ mapClass(Tokens.TemplateDataSource, PostgresTemplateDataSource);
 mapClass(Tokens.UnitDataSource, PostgresUnitDataSource);
 mapClass(Tokens.UserDataSource, PostgresUserDataSource);
 mapClass(Tokens.VisitDataSource, PostgresVisitDataSource);
+mapClass(
+  Tokens.VisitRegistrationClaimDataSource,
+  PostgresVisitRegistrationClaimDataSource
+);
+mapClass(Tokens.VisitAuthorization, VisitAuthorization);
 mapClass(Tokens.VisitRegistrationAuthorization, VisitRegistrationAuthorization);
 mapClass(Tokens.TechniqueDataSource, PostgresTechniqueDataSource);
 mapClass(

apps/backend/src/config/dependencyConfigELI.ts

@@ -3,6 +3,7 @@ import 'reflect-metadata';
 import { DataAccessUsersAuthorization } from '../auth/DataAccessUsersAuthorization';
 import { OAuthAuthorization } from '../auth/OAuthAuthorization';
 import { ProposalAuthorization } from '../auth/ProposalAuthorization';
+import { VisitAuthorization } from '../auth/VisitAuthorization';
 import { VisitRegistrationAuthorization } from '../auth/VisitRegistrationAuthorization';
 import { PostgresAdminDataSourceWithAutoUpgrade } from '../datasources/postgres/AdminDataSource';
 import PostgresCallDataSource from '../datasources/postgres/CallDataSource';
@@ -38,6 +39,7 @@ import PostgresTemplateDataSource from '../datasources/postgres/TemplateDataSour
 import PostgresUnitDataSource from '../datasources/postgres/UnitDataSource';
 import PostgresUserDataSource from '../datasources/postgres/UserDataSource';
 import PostgresVisitDataSource from '../datasources/postgres/VisitDataSource';
+import PostgresVisitRegistrationClaimDataSource from '../datasources/postgres/VisitRegistrationClaimDataSource';
 import PostgresWorkflowDataSource from '../datasources/postgres/WorkflowDataSource';
 import { eliEmailHandler } from '../eventHandlers/email/eliEmailHandler';
 import createLoggingHandler from '../eventHandlers/logging';
@@ -99,6 +101,11 @@ mapClass(Tokens.TemplateDataSource, PostgresTemplateDataSource);
 mapClass(Tokens.UnitDataSource, PostgresUnitDataSource);
 mapClass(Tokens.UserDataSource, PostgresUserDataSource);
 mapClass(Tokens.VisitDataSource, PostgresVisitDataSource);
+mapClass(
+  Tokens.VisitRegistrationClaimDataSource,
+  PostgresVisitRegistrationClaimDataSource
+);
+mapClass(Tokens.VisitAuthorization, VisitAuthorization);
 mapClass(Tokens.VisitRegistrationAuthorization, VisitRegistrationAuthorization);
 mapClass(Tokens.InternalReviewDataSource, PostgresInternalReviewDataSource);
 mapClass(Tokens.TechniqueDataSource, PostgresTechniqueDataSource);

apps/backend/src/config/dependencyConfigESS.ts

@@ -4,6 +4,7 @@ import 'reflect-metadata';
 import { DataAccessUsersAuthorization } from '../auth/DataAccessUsersAuthorization';
 import { OAuthAuthorization } from '../auth/OAuthAuthorization';
 import { ProposalAuthorization } from '../auth/ProposalAuthorization';
+import { VisitAuthorization } from '../auth/VisitAuthorization';
 import { VisitRegistrationAuthorization } from '../auth/VisitRegistrationAuthorization';
 import { PostgresAdminDataSourceWithAutoUpgrade } from '../datasources/postgres/AdminDataSource';
 import PostgresCallDataSource from '../datasources/postgres/CallDataSource';
@@ -39,6 +40,7 @@ import PostgresTemplateDataSource from '../datasources/postgres/TemplateDataSour
 import PostgresUnitDataSource from '../datasources/postgres/UnitDataSource';
 import PostgresUserDataSource from '../datasources/postgres/UserDataSource';
 import PostgresVisitDataSource from '../datasources/postgres/VisitDataSource';
+import PostgresVisitRegistrationClaimDataSource from '../datasources/postgres/VisitRegistrationClaimDataSource';
 import PostgresWorkflowDataSource from '../datasources/postgres/WorkflowDataSource';
 import { essEmailHandler } from '../eventHandlers/email/essEmailHandler';
 import createLoggingHandler from '../eventHandlers/logging';
@@ -98,6 +100,11 @@ mapClass(Tokens.TemplateDataSource, PostgresTemplateDataSource);
 mapClass(Tokens.UnitDataSource, PostgresUnitDataSource);
 mapClass(Tokens.UserDataSource, PostgresUserDataSource);
 mapClass(Tokens.VisitDataSource, PostgresVisitDataSource);
+mapClass(
+  Tokens.VisitRegistrationClaimDataSource,
+  PostgresVisitRegistrationClaimDataSource
+);
+mapClass(Tokens.VisitAuthorization, VisitAuthorization);
 mapClass(Tokens.VisitRegistrationAuthorization, VisitRegistrationAuthorization);
 mapClass(Tokens.InternalReviewDataSource, PostgresInternalReviewDataSource);
 mapClass(Tokens.TechniqueDataSource, PostgresTechniqueDataSource);

apps/backend/src/config/dependencyConfigSTFC.ts

@@ -3,6 +3,7 @@ import 'reflect-metadata';
 import { DataAccessUsersAuthorization } from '../auth/DataAccessUsersAuthorization';
 import { StfcProposalAuthorization } from '../auth/StfcProposalAuthorization';
 import { StfcUserAuthorization } from '../auth/StfcUserAuthorization';
+import { VisitAuthorization } from '../auth/VisitAuthorization';
 import { VisitRegistrationAuthorization } from '../auth/VisitRegistrationAuthorization';
 import { PostgresAdminDataSourceWithAutoUpgrade } from '../datasources/postgres/AdminDataSource';
 import PostgresCallDataSource from '../datasources/postgres/CallDataSource';
@@ -32,6 +33,7 @@ import PostgresTagDataSource from '../datasources/postgres/TagDataSource';
 import PostgresTemplateDataSource from '../datasources/postgres/TemplateDataSource';
 import PostgresUnitDataSource from '../datasources/postgres/UnitDataSource';
 import PostgresVisitDataSource from '../datasources/postgres/VisitDataSource';
+import PostgresVisitRegistrationClaimDataSource from '../datasources/postgres/VisitRegistrationClaimDataSource';
 import PostgresWorkflowDataSource from '../datasources/postgres/WorkflowDataSource';
 import StfcFapDataSource from '../datasources/stfc/StfcFapDataSource';
 import StfcInstrumentDataSource from '../datasources/stfc/StfcInstrumentDataSource';
@@ -96,6 +98,11 @@ mapClass(Tokens.TemplateDataSource, PostgresTemplateDataSource);
 mapClass(Tokens.UnitDataSource, PostgresUnitDataSource);
 mapClass(Tokens.UserDataSource, StfcUserDataSource);
 mapClass(Tokens.VisitDataSource, PostgresVisitDataSource);
+mapClass(
+  Tokens.VisitRegistrationClaimDataSource,
+  PostgresVisitRegistrationClaimDataSource
+);
+mapClass(Tokens.VisitAuthorization, VisitAuthorization);
 mapClass(Tokens.VisitRegistrationAuthorization, VisitRegistrationAuthorization);
 mapClass(Tokens.InternalReviewDataSource, StfcInternalReviewDataSource);
 mapClass(Tokens.TechniqueDataSource, StfcTechniqueDataSource);

apps/backend/src/config/dependencyConfigTest.ts

@@ -5,6 +5,7 @@ import 'reflect-metadata';
 import { DataAccessUsersAuthorization } from '../auth/DataAccessUsersAuthorization';
 import { UserAuthorizationMock } from '../auth/mockups/UserAuthorization';
 import { ProposalAuthorization } from '../auth/ProposalAuthorization';
+import { VisitAuthorization } from '../auth/VisitAuthorization';
 import { VisitRegistrationAuthorization } from '../auth/VisitRegistrationAuthorization';
 import { AdminDataSourceMock } from '../datasources/mockups/AdminDataSource';
 import { CallDataSourceMock } from '../datasources/mockups/CallDataSource';
@@ -39,6 +40,7 @@ import { TechniqueDataSourceMock } from '../datasources/mockups/TechniqueDataSou
 import { TemplateDataSourceMock } from '../datasources/mockups/TemplateDataSource';
 import { UnitDataSourceMock } from '../datasources/mockups/UnitDataSource';
 import { UserDataSourceMock } from '../datasources/mockups/UserDataSource';
+import { VisitRegistrationClaimDataSourceMock } from '../datasources/mockups/VisitRegistrationClaimDataSource';
 import { WorkflowDataSourceMock } from '../datasources/mockups/WorkflowDataSource';
 import { essEmailHandler } from '../eventHandlers/email/essEmailHandler';
 import createLoggingHandler from '../eventHandlers/logging';
@@ -95,6 +97,11 @@ mapClass(Tokens.TemplateDataSource, TemplateDataSourceMock);
 mapClass(Tokens.UnitDataSource, UnitDataSourceMock);
 mapClass(Tokens.UserDataSource, UserDataSourceMock);
 mapClass(Tokens.VisitDataSource, VisitDataSourceMock);
+mapClass(
+  Tokens.VisitRegistrationClaimDataSource,
+  VisitRegistrationClaimDataSourceMock
+);
+mapClass(Tokens.VisitAuthorization, VisitAuthorization);
 mapClass(Tokens.VisitRegistrationAuthorization, VisitRegistrationAuthorization);
 mapClass(Tokens.PredefinedMessageDataSource, PredefinedMessageDataSourceMock);
 mapClass(Tokens.StatusActionsLogsDataSource, StatusActionsLogsDataSourceMock);

apps/backend/src/datasources/InviteDataSource.ts

@@ -22,6 +22,10 @@ export interface InviteDataSource {
     proposalPk: number,
     isClaimed?: boolean
   ): Promise<Invite[]>;
+  findVisitRegistrationInvites(
+    visitId: number,
+    isClaimed?: boolean
+  ): Promise<Invite[]>;
   getInvites(filter: GetInvitesFilter): Promise<Invite[]>;
 
   update(args: {

apps/backend/src/datasources/VisitRegistrationClaimDataSource.ts

@@ -0,0 +1,6 @@
+import { VisitRegistrationClaim } from '../models/VisitRegistrationClaim';
+
+export interface VisitRegistrationClaimDataSource {
+  create(inviteId: number, visitId: number): Promise<VisitRegistrationClaim>;
+  findByInviteId(inviteId: number): Promise<VisitRegistrationClaim[]>;
+}

apps/backend/src/datasources/mockups/InviteDataSource.ts

@@ -27,6 +27,18 @@ export class InviteDataSourceMock implements InviteDataSource {
 
     return invites.filter((invite) => invite !== null) as Invite[];
   }
+  async findVisitRegistrationInvites(
+    visitId: number,
+    includeExpired: boolean
+  ): Promise<Invite[]> {
+    const invites = this.invites.filter(
+      (invite) =>
+        invite.id === visitId &&
+        (includeExpired || !invite.expiresAt || invite.expiresAt > new Date())
+    );
+
+    return invites;
+  }
   async delete(id: number): Promise<void> {
     this.invites = this.invites.filter((invite) => invite.id !== id);
   }

apps/backend/src/datasources/mockups/VisitRegistrationClaimDataSource.ts

@@ -0,0 +1,40 @@
+import { injectable } from 'tsyringe';
+
+import { VisitRegistrationClaim } from '../../models/VisitRegistrationClaim';
+import { VisitRegistrationClaimDataSource } from '../VisitRegistrationClaimDataSource';
+
+@injectable()
+export class VisitRegistrationClaimDataSourceMock
+  implements VisitRegistrationClaimDataSource
+{
+  private visitRegistrationClaims: VisitRegistrationClaim[];
+
+  constructor() {
+    this.init();
+  }
+
+  public init() {
+    this.visitRegistrationClaims = [
+      new VisitRegistrationClaim(1, 1),
+      new VisitRegistrationClaim(2, 1),
+      new VisitRegistrationClaim(3, 2),
+      new VisitRegistrationClaim(1, 3),
+    ];
+  }
+
+  async create(
+    inviteId: number,
+    visitId: number
+  ): Promise<VisitRegistrationClaim> {
+    const newClaim = new VisitRegistrationClaim(inviteId, visitId);
+    this.visitRegistrationClaims.push(newClaim);
+
+    return newClaim;
+  }
+
+  async findByInviteId(inviteId: number): Promise<VisitRegistrationClaim[]> {
+    return this.visitRegistrationClaims.filter(
+      (claim) => claim.inviteId === inviteId
+    );
+  }
+}

apps/backend/src/datasources/postgres/InviteDataSource.ts

@@ -30,6 +30,35 @@ export default class PostgresInviteDataSource implements InviteDataSource {
       })
       .then((invites: InviteRecord[]) => invites.map(createInviteObject));
   }
+  findVisitRegistrationInvites(
+    visitId: number,
+    isClaimed?: boolean
+  ): Promise<Invite[]> {
+    return database
+      .select('invites.*')
+      .from('visit_registration_claims')
+      .where('visit_id', visitId)
+      .modify((query) => {
+        if (isClaimed !== undefined) {
+          if (isClaimed) {
+            query.whereNotNull('claimed_at');
+          } else {
+            query.whereNull('claimed_at');
+          }
+        }
+      })
+      .leftJoin(
+        'invites',
+        'visit_registration_claims.invite_id',
+        'invites.invite_id'
+      )
+      .catch((error: Error) => {
+        throw new Error(
+          `Could not find visit registration invites: ${error.message}`
+        );
+      })
+      .then((invites: InviteRecord[]) => invites.map(createInviteObject));
+  }
   findByCode(code: string): Promise<Invite | null> {
     return database
       .select('*')

apps/backend/src/datasources/postgres/VisitDataSource.ts

@@ -43,12 +43,17 @@ class PostgresVisitDataSource implements VisitDataSource {
       .then((visit) => (visit ? createVisitObject(visit) : null));
   }
 
-  getRegistration(userId: number, visitId: number): Promise<VisitRegistration> {
+  getRegistration(
+    userId: number,
+    visitId: number
+  ): Promise<VisitRegistration | null> {
     return database('visits_has_users')
       .where({ visit_id: visitId })
       .andWhere({ user_id: userId })
       .first()
-      .then((registration) => createVisitRegistrationObject(registration));
+      .then((registration) =>
+        registration ? createVisitRegistrationObject(registration) : null
+      );
   }
 
   getRegistrations(

apps/backend/src/datasources/postgres/VisitRegistrationClaimDataSource.ts

@@ -0,0 +1,50 @@
+import { injectable } from 'tsyringe';
+
+import { VisitRegistrationClaim } from '../../models/VisitRegistrationClaim';
+import { VisitRegistrationClaimDataSource } from '../VisitRegistrationClaimDataSource';
+import database from './database';
+import {
+  VisitRegistrationClaimRecord,
+  createVisitRegistrationClaimObject,
+} from './records';
+
+@injectable()
+export default class PostgresVisitRegistrationClaimDataSource
+  implements VisitRegistrationClaimDataSource
+{
+  async create(
+    inviteId: number,
+    visitId: number
+  ): Promise<VisitRegistrationClaim> {
+    const records = await database('visit_registration_claims')
+      .insert(
+        {
+          invite_id: inviteId,
+          visit_id: visitId,
+        },
+        '*'
+      )
+      .onConflict(['invite_id', 'visit_id'])
+      .ignore();
+
+    if (records.length !== 1) {
+      throw new Error('Failed to create visit registration claim');
+    }
+
+    return createVisitRegistrationClaimObject(
+      records[0] as VisitRegistrationClaimRecord
+    );
+  }
+
+  async findByInviteId(inviteId: number): Promise<VisitRegistrationClaim[]> {
+    const records = await database<VisitRegistrationClaimRecord>(
+      'visit_registration_claims'
+    )
+      .select('*')
+      .where('invite_id', inviteId);
+
+    return records.map((record: VisitRegistrationClaimRecord) =>
+      createVisitRegistrationClaimObject(record)
+    );
+  }
+}