fix the return value on the route to make it work with the better fro…

…ntend checker Fix issue where the clusterName values were being re-used
CodeNow · Jun 30, 2017 · aa2f976 · aa2f976
1 parent 58b9700
commit aa2f976
Show file tree

Hide file tree

Showing 3 changed files with 22 additions and 18 deletions.
diff --git a/lib/models/rabbitmq/index.js b/lib/models/rabbitmq/index.js
@@ -267,7 +267,7 @@ RabbitMQ.prototype.contextVersionDeleted = function (data) {
 }
 
 RabbitMQ.prototype.createCluster = function (data) {
-  this._publisher.publishTask('cluster.create', data)
+  return this._publisher.publishTask('cluster.create', data)
 }
 
 RabbitMQ.prototype.deleteCluster = function (data) {

diff --git a/lib/models/services/cluster-config-service.js b/lib/models/services/cluster-config-service.js
@@ -155,6 +155,7 @@ module.exports = class ClusterConfigService {
    * @param {String[]}    data.testReporters              - array of names of the testReporters
    * @param {String}      data.clusterName                - name of the cluster
    * @param {ObjectId=}   data.parentInputClusterConfigId - Id of the parent cluster
+   * @param {Boolean}     data.shouldNotAutoFork          - True if this cluster should not fork branches
    *
    * @return {Promise} with object that has AutoIsolationConfig
    */

diff --git a/lib/routes/docker-compose-cluster.js b/lib/routes/docker-compose-cluster.js
@@ -75,7 +75,7 @@ function makeCreateOptsFromBody (sessionUser, body, mainInstanceServiceName) {
     isTesting: isTesting || false,
     testReporters: testReporters || [],
     clusterName,
-    shouldNotAutoFork,
+    shouldNotAutoFork: shouldNotAutoFork || true,
     parentInputClusterConfigId: parentInputClusterConfigId || ''
   }
 }
@@ -117,6 +117,23 @@ const postRoute = function (req, res, next) {
     .asCallback(responseHandler.bind(null, res, next))
 }
 
+/**
+ * Takes the result from parsing the compose, and turns them into cluster create jobs
+ * @param {SessionUser} sessionUser            - This user
+ * @param {Object}      body                   - Cluster create options
+ * @param {Object}      serviceNames
+ * @param {String[]}    serviceNames.builds    - Clusters created from the owning repo
+ * @param {String[]}    serviceNames.externals - Clusters created from github links
+ * @param {Number}      serviceNames.total     - Total number of clusters to be generated
+ */
+function createClusters (sessionUser, body, serviceNames) {
+  return Promise.map(serviceNames, (service) => {
+    const newBody = Object.assign({name: generateHashClusterName()}, body)
+    return rabbitMQ.createCluster(makeCreateOptsFromBody(sessionUser, newBody, service))
+      .return({ service: service, hash: newBody.name })
+  })
+}
+
 /**
  * Enqueues a Cluster Create job for each build and external main in the Compose File
  *
@@ -150,22 +167,8 @@ const multiClusterCreate = function (sessionUser, body) {
       const serviceKeys = ClusterConfigService.getUniqueServicesKeysFromOctobearResults(results)
       // Now that we have the main instances, we need to create clusters for each one.
       return Promise.props({
-        builds: Promise.map(serviceKeys.builds, (buildKey) => {
-          const hash = generateHashClusterName()
-          body.name = hash
-          return Promise.try(() => {
-            return rabbitMQ.createCluster(makeCreateOptsFromBody(sessionUser, body, buildKey))
-          })
-            .return({ service: buildKey, hash })
-        }),
-        externals: Promise.map(serviceKeys.externals, (externalKey) => {
-          const hash = generateHashClusterName()
-          body.name = hash
-          return Promise.try(() => {
-            return rabbitMQ.createCluster(makeCreateOptsFromBody(sessionUser, body, externalKey))
-          })
-            .return({ service: externalKey, hash })
-        })
+        builds: createClusters(sessionUser, body, serviceKeys.builds),
+        externals: createClusters(sessionUser, body, serviceKeys.externals)
       })
     })
     .tap((results) => {