/
jobs.js
120 lines (90 loc) · 2.62 KB
/
jobs.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
/*
* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/.
*/
/*
* Copyright (c) 2014, Joyent, Inc.
*/
/*
* A brief overview of this source file: what is its purpose.
*/
var restify = require('restify');
var assert = require('assert');
var common = require('../common');
var interceptors = require('../interceptors');
/*
* GET /jobs/:uuid
*/
function getJob(req, res, next) {
req.log.trace('GetJob start');
req.app.wfapi.getJob(req.params.job_uuid, function (err, job) {
if (err)
return next(err);
res.send(job);
return next();
});
}
/*
* GET /jobs
* GET /vms/:uuid/jobs
*/
function listJobs(req, res, next) {
req.log.trace('ListJobs start');
if (req.vm)
req.params.vm_uuid = req.vm.uuid;
req.app.wfapi.listJobs(req.params, function (err, jobs) {
if (err)
return next(err);
res.send(jobs);
return next();
});
}
/*
* GET /job_results
*/
function jobResults(req, res, next) {
req.log.trace('JobResults start');
req.log.info('Received post back job results', req.params);
// For now, ignore everything unless it is a failed provision
if (req.params.execution && req.params.execution == 'failed' &&
req.params.vm_uuid) {
req.params.state = 'failed';
req.params.zone_state = 'failed';
req.app.moray._getVmObject(req.params.vm_uuid, function (err, obj) {
if (err) {
return next(err);
}
var vm = common.simpleMerge(obj, req.params);
vm = common.translateVm(vm, false);
req.app.moray.putVm(req.params.vm_uuid, vm, function (err2) {
if (err2) {
return next(err2);
} else {
req.log.info('Set VM %s state as failed', vm.uuid);
res.send(200);
return next();
}
});
});
} else {
res.send(200);
return next();
}
}
/*
* Mounts job actions as server routes
*/
function mount(server) {
server.get({ path: '/vms/:uuid/jobs', name: 'ListVmJobs' },
interceptors.loadVm,
listJobs);
server.get({ path: '/jobs', name: 'ListJobs' }, listJobs);
server.get({ path: '/jobs/:job_uuid', name: 'GetJob' }, getJob);
// Post back URL for provision job results
server.post({ path: '/job_results', name: 'JobResults' }, jobResults);
}
// --- Exports
module.exports = {
mount: mount
};