fix(core): update expired invitation to expired before inserting a ne…

…w one

packages/core/src/libraries/organization-invitation.ts

@@ -55,8 +55,12 @@ export class OrganizationInvitationLibrary {
     messagePayload: SendMessagePayload | false
   ) {
     const { inviterId, invitee, organizationId, expiresAt, organizationRoleIds } = data;
+    const isMember = await this.queries.organizations.relations.users.isMember(
+      organizationId,
+      invitee
+    );
 
-    if (await this.queries.organizations.relations.users.isMember(organizationId, invitee)) {
+    if (isMember) {
       throw new RequestError({
         status: 422,
         code: 'request.invalid_input',
@@ -66,6 +70,25 @@ export class OrganizationInvitationLibrary {
 
     return this.queries.pool.transaction(async (connection) => {
       const organizationQueries = new OrganizationQueries(connection);
+      // Fetch existing invitations to the invitee first
+      const existingInvitations = await organizationQueries.invitations.findEntities({ invitee });
+      // Check if any pending invitation has expired, if yes, update the invitation status to "Expired" first
+      // Note: Even if the status may appear to be "Expired", the actual data in DB may still be "Pending".
+      // Check `findEntities` in `OrganizationQueries` for more details.
+      const expiringInvitations = existingInvitations.filter(
+        (invitation) => invitation.expiresAt < Date.now()
+      );
+      if (expiringInvitations.length > 0) {
+        await Promise.all(
+          expiringInvitations.map(async (invitation) =>
+            organizationQueries.invitations.updateById(invitation.id, {
+              status: OrganizationInvitationStatus.Expired,
+              updatedAt: Date.now(),
+            })
+          )
+        );
+      }
+      // Insert the new invitation
       const invitation = await organizationQueries.invitations.insert({
         id: generateStandardId(),
         inviterId,