profxadke/captive.whump.shanti-portal
1
0
Fork 0
mirror of https://codeberg.org/prof_x_pvt_ltd/captive.whump.shanti-portal synced 2024-08-14 22:46:42 +00:00
Code Issues Projects Releases Packages Wiki Activity

working on job polling in angular.

Browse source
This commit is contained in:
Stefan Midjich 2016-12-20 10:44:53 +01:00
parent 81aaf663c6
commit 4b541fd1cf
2 changed files with 97 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

91
static/rs/js/rsapp.js
View file

@ -3,30 +3,111 @@
//
//
var debug = true;
var app = angular.module("rsPortalApp", []);
app.config(function($routeProvider) {
app.constant('config', {
debug: true
});
app.config(function($routeProvider, $interpolateProvider) {
$routeProvider
.when('/Swedish', {templateUrl: "swedish.html" })
.when('/English', {templateUrl: "english.html" })
.when('/FAQ-Swedish', {templateUrl: "faq-swe.html" })
.otherwise({redirectTo: '/Swedish'});
$interpolateProvider.startSymbol('[%');
$interpolateProvider.endSymbol('%]');
});
app.controller('RSMainCtrl', function($scope, $http) {
app.controller('RSMainCtrl', function($scope, $http, $q, config) {
$scope.approved = {};
$scope.apiProcessing = false;
$scope.apiErrors = [];
function poll_jobs(job_id) {
var defer = $q.defer();
var api_url = '/job/'+job_id;
// TODO: Restore maxRun before going live.
var maxRun = plugin_timeout/10;
var timesRun = 0;
var do_poll = function () {
$http.get(api_url).success(function(data) {
if (config.debug) {
console.log(data);
}
if (data.is_finished) {
if (config.debug) {
console.log('Resolving job: '+job_id);
}
defer.resolve(job_id, data.result);
}
if (data.is_failed) {
console.log('Job failed: '+job_id);
defer.reject(job_id, data.result);
}
});
// TODO: Add fail callback to log failed GET API requests.
console.log('Runs: '+timesRun+'/'+maxRun);
if (++timesRun == maxRun) {
clearTimeout(timer);
if (config.debug) {
console.log('Polling timed out');
}
defer.reject("Job polling timed out");
return;
} else {
timer = setTimeout(do_poll, 2000);
}
};
var timer = setTimeout(do_poll, 500);
}
$scope.submit = function() {
$scope.apiProcessing = true;
console.log('hej');
var promises = [];
if ($scope.approved.answer == true) {
$http({
method: 'POST',
url: '/approve',
}).then(function success(response) {
poll_jobs(response.data);
if (config.debug) {
console.log('/approve => '+response);
}
for (var job in response.data) {
var job_id = response.data[job].id;
var promise = poll_jobs(job_id);
promises.push(promise);
}
$q.all(promises).then(function (response) {
if (config.debug) {
console.log('Resolved: '+response);
}
$scope.apiProcessing = false;
}, function (reason) {
if (config.debug) {
console.log(reason);
}
$scope.apiProcessing = false;
});
}, function error(response) {
// Failure
console.log(response);
if (config.debug) {
console.log(response);
}
$scope.apiErrors.push(response);
$scope.apiProcessing = false;
});
}
};