organization status changed code changes

apps/web/src/app/app.component.ts

@@ -241,6 +241,20 @@
             // eslint-disable-next-line @typescript-eslint/no-floating-promises
             this.router.navigate(["/remove-password"]);
             break;
+          case "syncOrganizationStatusChanged": {
+            const { organizationId, enabled } = message;
+            const organizations = await firstValueFrom(this.organizationService.organizations$);
+            const organization = organizations.find((org) => org.id === organizationId);
+
+            if (organization) {
+              const updatedOrganization = {
+                ...organization,
+                enabled: enabled,
+              };
+              await this.organizationService.upsert(updatedOrganization);
+            }
+            break;
+          }
           default:
             break;
         }

apps/web/src/app/billing/shared/adjust-payment-dialog/adjust-payment-dialog.component.ts

@@ -74,7 +74,6 @@ export class AdjustPaymentDialogComponent {
       }
     });
     await response;
-    await new Promise((resolve) => setTimeout(resolve, 10000));
     this.toastService.showToast({
       variant: "success",
       title: null,

libs/common/src/enums/notification-type.enum.ts

@@ -22,4 +22,5 @@ export enum NotificationType {
   AuthRequestResponse = 16,
 
   SyncOrganizations = 17,
+  SyncOrganizationStatusChanged = 18,
 }

libs/common/src/models/response/notification.response.ts

@@ -42,6 +42,9 @@
       case NotificationType.AuthRequestResponse:
         this.payload = new AuthRequestPushNotification(payload);
         break;
+      case NotificationType.SyncOrganizationStatusChanged:
+        this.payload = new OrganizationStatusPushNotification(payload);
+        break;
       default:
         break;
     }
@@ -112,3 +115,14 @@
     this.userId = this.getResponseProperty("UserId");
   }
 }
+
+export class OrganizationStatusPushNotification extends BaseResponse {
+  organizationId: string;
+  enabled: boolean;
+
+  constructor(response: any) {
+    super(response);
+    this.organizationId = this.getResponseProperty("OrganizationId");
+    this.enabled = this.getResponseProperty("Enabled");
+  }
+}

libs/common/src/services/notifications.service.ts

@@ -216,6 +216,13 @@
           });
         }
         break;
+      case NotificationType.SyncOrganizationStatusChanged:
+        if (isAuthenticated) {
+          await this.syncService.fullSync(true);
+          // Stop so a reconnect can be made
+          await this.signalrConnection.stop();
+        }
+        break;
       default:
         break;
     }