Prevent crash when network or cluster is offline (#712)

gravitational · Apr 6, 2022 · 9707ef9 · 9707ef9
1 parent d779206
commit 9707ef9
Showing 1 changed file with 35 additions and 20 deletions.
diff --git a/packages/teleterm/src/ui/services/clusters/clustersService.ts b/packages/teleterm/src/ui/services/clusters/clustersService.ts
@@ -61,24 +61,24 @@ export class ClustersService extends ImmutableStore<ClustersServiceState> {
 
   async syncRootCluster(clusterUri: string) {
     try {
-      await this.syncClusterInfo(clusterUri);
-
-      this.syncLeafClusters(clusterUri);
-      this.syncKubes(clusterUri);
-      this.syncApps(clusterUri);
-      this.syncDbs(clusterUri);
-      this.syncServers(clusterUri);
-      this.syncKubes(clusterUri);
-      this.syncGateways();
+      await Promise.all([
+        this.syncClusterInfo(clusterUri),
+        this.syncLeafClusters(clusterUri),
+      ]);
     } catch (e) {
       this.notificationsService.notifyError({
         title: `Could not synchronize cluster ${
           routing.parseClusterUri(clusterUri).params.rootClusterId
         }`,
         description: e.message,
       });
-      throw e;
     }
+    this.syncKubes(clusterUri);
+    this.syncApps(clusterUri);
+    this.syncDbs(clusterUri);
+    this.syncServers(clusterUri);
+    this.syncKubes(clusterUri);
+    this.syncGateways();
   }
 
   async syncLeafCluster(clusterUri: string) {
@@ -92,12 +92,20 @@ export class ClustersService extends ImmutableStore<ClustersServiceState> {
   }
 
   async syncRootClusters() {
-    const clusters = await this.client.listRootClusters();
-    this.setState(draft => {
-      draft.clusters = new Map(clusters.map(c => [c.uri, c]));
-    });
-
-    clusters.filter(c => c.connected).forEach(c => this.syncRootCluster(c.uri));
+    try {
+      const clusters = await this.client.listRootClusters();
+      this.setState(draft => {
+        draft.clusters = new Map(clusters.map(c => [c.uri, c]));
+      });
+      clusters
+        .filter(c => c.connected)
+        .forEach(c => this.syncRootCluster(c.uri));
+    } catch (error) {
+      this.notificationsService.notifyError({
+        title: 'Could not fetch root clusters',
+        description: error.message,
+      });
+    }
   }
 
   async syncCluster(clusterUri: string) {
@@ -114,10 +122,17 @@ export class ClustersService extends ImmutableStore<ClustersServiceState> {
   }
 
   async syncGateways() {
-    const gws = await this.client.listGateways();
-    this.setState(draft => {
-      draft.gateways = new Map(gws.map(g => [g.uri, g]));
-    });
+    try {
+      const gws = await this.client.listGateways();
+      this.setState(draft => {
+        draft.gateways = new Map(gws.map(g => [g.uri, g]));
+      });
+    } catch (error) {
+      this.notificationsService.notifyError({
+        title: 'Could not fetch databases',
+        description: error.message,
+      });
+    }
   }
 
   async syncKubes(clusterUri: string) {