partial code for polling

Author: SagarGaniga

bin/helpers/sync/syncSpecsLogs.js

@@ -6,17 +6,57 @@ const request = require('request'),
 
 let printSpecsStatus = (bsConfig, buildId) => {
   new Promise((resolve, reject) => {
-    let backOffFactor = 3; // 3 seconds
-    let options = {
-      url: `${config.buildUrl}${buildId}`,
-      auth: {
-        user: bsConfig.auth.username,
-        password: bsConfig.auth.access_key
-      },
-      headers: {
-        'Content-Type': 'application/json',
-        "User-Agent": utils.getUserAgent(),
+    poll(data, 2000, 10000).then(resolve(data));
+  });
+}
+
+let poll = (interval, timeout) => {
+  data = []
+
+  return pollRecursive()
+        .timeout(timeout)
+        .catch(Promise.TimeoutError, function () {
+          return false;
+        });
+}
+
+let pollRecursive = () => {
+  return signal() ? Promise.resolve(true) : Promise.delay(interval).then(pollRecursive);
+}
+
+let makeReqest = () => {
+  let backOffFactor = 3; // 3 seconds
+  let options = {
+    url: `${config.buildUrl}${buildId}`,
+    auth: {
+      user: bsConfig.auth.username,
+      password: bsConfig.auth.access_key
+    },
+    headers: {
+      'Content-Type': 'application/json',
+      "User-Agent": utils.getUserAgent(),
+    }
+  }
+  request.post(options, function (err, resp, body) {
+    if (err) {
+      reject(err);
+    } else {
+      try {
+        data = JSON.parse(body);
+      } catch (error) {
+        data = null;
       }
+      if (resp.statusCode != 202) {
+        if (data) {
+          reject(`${Constants.userMessages.BUILD_FAILED} Error: ${build.message}`);
+        } else {
+          reject(Constants.userMessages.BUILD_FAILED);
+        }
+      } else {
+        resolve(build);
+      }
+      resolve(build);
+
     }
   });
 }

bin/helpers/syncRunner.js

@@ -12,7 +12,7 @@ const Config = require("./config"),
 
 exports.pollBuildStatus = (bsConfig, buildDetails) => {
   logBuildDetails(bsConfig, buildDetails);
-  printSpecsStatus().then((data) => {
+  syncSpecsLogs.printSpecsStatus(bsConfig, buildDetails).then((data) => {
     return specsSummary.printSpecsRunSummary(data.specs, data.time, data.machines);
   }).then((data) => {
     return specDetails.failedSpecsDetails(data);