chore: send out rabbitmq message for visitors approval and cancellation

Author: yoganandaness

apps/backend/src/datasources/UserDataSource.ts

@@ -99,4 +99,11 @@ export interface UserDataSource {
   ): Promise<boolean>;
   getRoleByShortCode(roleShortCode: Roles): Promise<Role>;
   mergeUsers(fromUserId: number, intoUserId: number): Promise<void>;
+  getApprovedProposalVisitorsWithInstitution(proposalPk: number): Promise<
+    {
+      user: User;
+      institution: Institution;
+      country: Country;
+    }[]
+  >;
 }

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

@@ -559,4 +559,14 @@ export class UserDataSourceMock implements UserDataSource {
       },
     ];
   }
+
+  async getApprovedProposalVisitorsWithInstitution(proposalPk: number): Promise<
+    {
+      user: User;
+      institution: Institution;
+      country: Country;
+    }[]
+  > {
+    return [];
+  }
 }

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

@@ -831,4 +831,29 @@ export default class PostgresUserDataSource implements UserDataSource {
         });
       });
   }
+
+  async getApprovedProposalVisitorsWithInstitution(proposalPk: number): Promise<
+    {
+      user: User;
+      institution: Institution;
+      country: Country;
+    }[]
+  > {
+    return database
+      .select('i.*', 'c.*', 'u.*')
+      .from('users as u')
+      .join('visits_has_users as vu', { 'u.user_id': 'vu.user_id' })
+      .join('visits as v', { 'v.visit_id': 'vu.visit_id' })
+      .leftJoin('institutions as i', { 'u.institution_id': 'i.institution_id' })
+      .leftJoin('countries as c', { 'c.country_id': 'i.country_id' })
+      .where('v.proposal_pk', proposalPk)
+      .andWhere('vu.status', 'APPROVED')
+      .then((users: (UserRecord & InstitutionRecord & CountryRecord)[]) => {
+        return users.map((user) => ({
+          user: createUserObject(user),
+          institution: createInstitutionObject(user),
+          country: createCountryObject(user),
+        }));
+      });
+  }
 }

apps/backend/src/datasources/stfc/StfcUserDataSource.ts

@@ -774,4 +774,10 @@ export class StfcUserDataSource implements UserDataSource {
       this.roleAssignmentMap.get(roleId) ?? ''
     );
   }
+
+  async getApprovedProposalVisitorsWithInstitution(
+    proposalPk: number
+  ): Promise<{ user: User; institution: Institution; country: Country }[]> {
+    throw new Error('Method not implemented.');
+  }
 }

apps/backend/src/eventHandlers/messageBroker.ts

@@ -61,6 +61,7 @@ type ProposalMessageData = {
   instruments?: { id: number; shortCode: string; allocatedTime: number }[];
   members: Member[];
   dataAccessUsers: Member[];
+  visitors: Member[];
   newStatus?: string;
   proposalPk: number;
   proposer?: Member;
@@ -129,10 +130,17 @@ export const getProposalMessageData = async (proposal: Proposal) => {
 
   const proposalUsersWithInstitution =
     await userDataSource.getProposalUsersWithInstitution(proposal.primaryKey);
+
   const dataAccessUsersWithInstitution =
     await dataAccessUsersDataSource.getDataAccessUsersWithInstitution(
       proposal.primaryKey
     );
+
+  const visitorsWithInstitution =
+    await userDataSource.getApprovedProposalVisitorsWithInstitution(
+      proposal.primaryKey
+    );
+
   const maybeInstruments =
     await instrumentDataSource.getInstrumentsByProposalPk(proposal.primaryKey);
 
@@ -177,9 +185,11 @@ export const getProposalMessageData = async (proposal: Proposal) => {
     dataAccessUsers: dataAccessUsersWithInstitution.map(
       mapUserWithInstitutionToMember
     ),
+    visitors: visitorsWithInstitution.map(mapUserWithInstitutionToMember),
     newStatus: proposalStatus?.shortCode,
     submitted: proposal.submitted,
   };
+
   const proposerWithInstitution = await userDataSource.getUserWithInstitution(
     proposal.proposerId
   );
@@ -242,7 +252,6 @@ export async function createPostToRabbitMQHandler() {
       case Event.PROPOSAL_DELETED:
       case Event.PROPOSAL_STATUS_ACTION_EXECUTED: {
         const jsonMessage = await getProposalMessageData(event.proposal);
-
         await rabbitMQ.sendMessageToExchange(
           event.exchange || EXCHANGE_NAME,
           event.type,
@@ -380,6 +389,13 @@ export async function createPostToRabbitMQHandler() {
             : RABBITMQ_VISIT_EVENT_TYPE.VISIT_DELETED,
           jsonMessage
         );
+
+        const proposalJsonMessage = await getProposalMessageData(proposal!);
+        await rabbitMQ.sendMessageToExchange(
+          EXCHANGE_NAME,
+          Event.PROPOSAL_UPDATED,
+          proposalJsonMessage
+        );
         break;
       }
       case Event.DATA_ACCESS_USERS_UPDATED: {