83 lines
2.4 KiB
JavaScript
83 lines
2.4 KiB
JavaScript
var get = require("https").get;
|
|
var parse = require("url").parse;
|
|
|
|
var base, token, run_number;
|
|
var expires = Date.now() + (6 * 60 - 10) * 60 * 1000;
|
|
exports.init = function(url, auth, num) {
|
|
base = url;
|
|
token = auth;
|
|
run_number = num;
|
|
};
|
|
exports.should_stop = function(callback) {
|
|
if (Date.now() > expires) return callback();
|
|
read(base + "/actions/runs?per_page=100", function(reply) {
|
|
var runs = verify(reply, "workflow_runs").filter(function(workflow) {
|
|
return workflow.status != "completed";
|
|
}).sort(function(a, b) {
|
|
return b.run_number - a.run_number;
|
|
});
|
|
var found = false, remaining = 20;
|
|
(function next() {
|
|
var workflow;
|
|
do {
|
|
workflow = runs.pop();
|
|
if (!workflow) return;
|
|
if (!is_cron(workflow)) break;
|
|
if (workflow.run_number == run_number) found = true;
|
|
} while (!found);
|
|
read(workflow.jobs_url, function(reply) {
|
|
verify(reply, "jobs").forEach(function(job) {
|
|
if (job.status != "completed") remaining--;
|
|
});
|
|
if (remaining >= 0) {
|
|
next();
|
|
} else {
|
|
callback();
|
|
}
|
|
});
|
|
})();
|
|
});
|
|
};
|
|
|
|
function is_cron(workflow) {
|
|
return /^(schedule|workflow_dispatch|workflow_run)$/.test(workflow.event);
|
|
}
|
|
|
|
function read(url, callback) {
|
|
var done = function(reply) {
|
|
done = function() {};
|
|
callback(reply);
|
|
};
|
|
var options = parse(url);
|
|
options.headers = {
|
|
"Authorization": "Token " + token,
|
|
"User-Agent": "UglifyJS",
|
|
};
|
|
get(options, function(response) {
|
|
var chunks = [];
|
|
response.setEncoding("utf8");
|
|
response.on("data", function(chunk) {
|
|
chunks.push(chunk);
|
|
}).on("end", function() {
|
|
var reply;
|
|
try {
|
|
reply = JSON.parse(chunks.join(""));
|
|
} catch (e) {}
|
|
done(reply);
|
|
}).on("error", function() {
|
|
done();
|
|
});
|
|
}).on("error", function() {
|
|
done();
|
|
});
|
|
}
|
|
|
|
function verify(reply, field) {
|
|
if (!reply) return [];
|
|
var values = reply[field];
|
|
if (!Array.isArray(values)) return [];
|
|
return values.filter(function(value) {
|
|
return value;
|
|
});
|
|
}
|