connection tester

Author: vogievetsky

src/client/modals/cluster-seed-modal/cluster-seed-modal.tsx

@@ -21,6 +21,8 @@ import { SupportedType, Cluster } from "../../../common/models/cluster/cluster";
 
 import { FormLabel, Button, Modal, ImmutableInput, ImmutableDropdown } from '../../components/index';
 import { STRINGS } from "../../config/constants";
+import { Ajax } from '../../utils/ajax/ajax';
+import { Notifier } from '../../components/notifications/notifications';
 import { CLUSTER as LABELS } from '../../../common/models/labels';
 import { generateUniqueName } from '../../../common/utils/string/string';
 import { indexByAttribute } from '../../../common/utils/array/array';
@@ -64,11 +66,25 @@ export class ClusterSeedModal extends React.Component<ClusterSeedModalProps, Imm
   }
 
   onNext() {
-    this.props.onNext(this.state.newInstance);
+    Ajax.query({
+      method: "POST",
+      url: 'settings/cluster-connection',
+      data: {
+        cluster: this.state.newInstance
+      }
+    })
+      .then(
+        (resp) => {
+          var cluster = Cluster.fromJS(resp.cluster);
+          this.props.onNext(cluster);
+        },
+        (xhr: XMLHttpRequest) => Notifier.failure('Woops', 'Something bad happened')
+      )
+      .done();
   }
 
   render(): JSX.Element {
-    const { onNext, onCancel } = this.props;
+    const { onCancel } = this.props;
     const { newInstance, errors } = this.state;
 
     if (!newInstance) return null;

src/client/modals/suggestion-modal/suggestion-modal.tsx

@@ -153,7 +153,7 @@ export class SuggestionModal<T> extends React.Component<SuggestionModalProps<T>,
   }
 
   renderEmpty() {
-    const { onClose, title } = this.props;
+    const { onClose, title, cancelLabel } = this.props;
 
     return <Modal
       className="suggestion-modal"
@@ -164,7 +164,7 @@ export class SuggestionModal<T> extends React.Component<SuggestionModalProps<T>,
         <div className="message">{STRINGS.thereAreNoSuggestionsAtTheMoment}</div>
       </div>
       <div className="button-bar">
-        <Button className="cancel" title={STRINGS.close} type="primary" onClick={onClose}/>
+        <Button className="cancel" title={cancelLabel || STRINGS.close} type="primary" onClick={onClose}/>
       </div>
     </Modal>;
   }

src/server/routes/settings/settings.ts

@@ -15,7 +15,7 @@
  */
 
 import { Router, Request, Response } from 'express';
-import { AppSettings } from '../../../common/models/index';
+import { AppSettings, Cluster } from '../../../common/models/index';
 import { MANIFESTS } from '../../../common/manifests/index';
 
 import { PivotRequest } from '../../utils/index';
@@ -44,6 +44,45 @@ router.get('/', (req: PivotRequest, res: Response) => {
 
 });
 
+router.post('/cluster-connection', (req: PivotRequest, res: Response) => {
+  var { cluster } = req.body;
+
+  if (typeof cluster === 'undefined') {
+    res.status(400).send({
+      error: 'must have a cluster'
+    });
+    return;
+  }
+
+  try {
+    var testCluster = Cluster.fromJS(cluster);
+  } catch (e) {
+    res.status(400).send({
+      error: 'invalid cluster',
+      message: e.message
+    });
+    return;
+  }
+
+  SETTINGS_MANAGER.checkClusterConnectionInfo(testCluster)
+    .then(
+      (cluster) => {
+        res.send({ cluster: cluster });
+      },
+      (e: Error) => {
+        console.log('error:', e.message);
+        if (e.hasOwnProperty('stack')) {
+          console.log((<any>e).stack);
+        }
+        res.status(500).send({
+          error: 'could not compute',
+          message: e.message
+        });
+      }
+    )
+    .done();
+});
+
 router.get('/cluster-sources', (req: PivotRequest, res: Response) => {
   SETTINGS_MANAGER.getAllClusterSources()
     .then(

src/server/utils/cluster-manager/cluster-manager.ts

@@ -74,14 +74,6 @@ export class ClusterManager {
     this.updateRequester();
   }
 
-  // Do initialization
-  public init(): Q.Promise<any> {
-    const { cluster, logger } = this;
-
-    return Q(null)
-      .then(() => this.establishInitialConnection());
-  }
-
   public destroy() {
     if (this.initialConnectionTimer) {
       clearTimeout(this.initialConnectionTimer);
@@ -133,7 +125,7 @@ export class ClusterManager {
     });
   }
 
-  private establishInitialConnection(): Q.Promise<any> {
+  public establishInitialConnection(maxRetries = Infinity): Q.Promise<any> {
     const { logger, verbose, cluster } = this;
 
     var deferred: Q.Deferred<any> = Q.defer();
@@ -159,7 +151,11 @@ export class ClusterManager {
             var msSinceLastTry = Date.now() - lastTryAt;
             var msToWait = Math.max(1, CONNECTION_RETRY_TIMEOUT - msSinceLastTry);
             logger.error(`Failed to connect to cluster '${cluster.name}' because: ${e.message} (will retry in ${msToWait}ms)`);
-            this.initialConnectionTimer = setTimeout(attemptConnection, msToWait);
+            if (retryNumber < maxRetries) {
+              this.initialConnectionTimer = setTimeout(attemptConnection, msToWait);
+            } else {
+              deferred.reject(new Error('too many failed attempts'));
+            }
           }
         );
     };

src/server/utils/file-manager/file-manager.ts

@@ -67,8 +67,7 @@ export class FileManager {
     this.verbose = Boolean(options.verbose);
   }
 
-  // Do initialization
-  public init(): Q.Promise<Dataset> {
+  public loadDataset(): Q.Promise<Dataset> {
     const { logger, anchorPath, uri } = this;
 
     var filePath = path.resolve(anchorPath, uri);

src/server/utils/settings-manager/settings-manager.ts

@@ -150,7 +150,7 @@ export class SettingsManager {
     });
 
     this.clusterManagers.push(clusterManager);
-    return clusterManager.init();
+    return clusterManager.establishInitialConnection();
   }
 
   private removeClusterManager(cluster: Cluster): void {
@@ -224,7 +224,7 @@ export class SettingsManager {
     });
 
     this.fileManagers.push(fileManager);
-    return fileManager.init().then((dataset) => {
+    return fileManager.loadDataset().then((dataset) => {
       var newExecutor = basicExecutorFactory({
         datasets: { main: dataset }
       });
@@ -307,9 +307,19 @@ export class SettingsManager {
       });
   }
 
-  // getClusterConnectionInfo(bareCluster: Cluster): Q.Promise<Cluster> {
-  //
-  // }
+  checkClusterConnectionInfo(cluster: Cluster): Q.Promise<Cluster> {
+    const { verbose, logger, anchorPath } = this;
+
+    var clusterManager = new ClusterManager(cluster, {
+      logger,
+      verbose,
+      anchorPath
+    });
+
+    return clusterManager.establishInitialConnection().then(() => {
+      return clusterManager.cluster;
+    });
+  }
 
   getAllClusterSources(): Q.Promise<ClusterSource> {
     var clusterSources = this.clusterManagers.map((clusterManager) => {