<!doctype html>
<html lang="en">
<head>
<title>Code coverage report for src/cfe.coffee</title>
<meta charset="utf-8" />
<link rel="stylesheet" href="../prettify.css" />
<link rel="stylesheet" href="../base.css" />
<meta name="viewport" content="width=device-width, initial-scale=1">
<style type='text/css'>
.coverage-summary .sorter {
background-image: url(../sort-arrow-sprite.png);
}
</style>
</head>
<body>
<div class='wrapper'>
<div class='pad1'>
<h1>
<a href="../index.html">all files</a> / <a href="index.html">src/</a> cfe.coffee
</h1>
<div class='clearfix'>
<div class='fl pad1y space-right2'>
<span class="strong">0% </span>
<span class="quiet">Statements</span>
<span class='fraction'>0/161</span>
</div>
<div class='fl pad1y space-right2'>
<span class="strong">0% </span>
<span class="quiet">Branches</span>
<span class='fraction'>0/26</span>
</div>
<div class='fl pad1y space-right2'>
<span class="strong">0% </span>
<span class="quiet">Functions</span>
<span class='fraction'>0/15</span>
</div>
<div class='fl pad1y space-right2'>
<span class="strong">0% </span>
<span class="quiet">Lines</span>
<span class='fraction'>0/134</span>
</div>
</div>
</div>
<div class='status-line low'></div>
<pre><table class="coverage">
<tr><td class="line-count quiet">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
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231</td><td class="line-coverage quiet"><span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-no"> </span>
<span class="cline-any cline-neutral"> </span></td><td class="text"><pre class="prettyprint lang-js"><span class="cstat-no" title="statement not covered" >path = require 'path'</span>
<span class="cstat-no" title="statement not covered" >http = require 'http'</span>
<span class="cstat-no" title="statement not covered" >url = require 'url'</span>
<span class="cstat-no" title="statement not covered" >fs = require 'fs'</span>
<span class="cstat-no" title="statement not covered" >q = require 'q'</span>
<span class="cstat-no" title="statement not covered" >_ = require 'lodash'</span>
<span class="cstat-no" title="statement not covered" >express = require 'express'</span>
<span class="cstat-no" title="statement not covered" >bodyParser = require 'body-parser'</span>
<span class="cstat-no" title="statement not covered" >Slaputils = require 'slaputils'</span>
<span class="cstat-no" title="statement not covered" >EntryPointProxy = require 'entrypoint-proxy'</span>
<span class="cstat-no" title="statement not covered" >Component = require 'component'</span>
<span class="cstat-no" title="statement not covered" >Broker = require './broker'</span>
<span class="cstat-no" title="statement not covered" >INTERNAL_PORT = 8081</span>
<span class="cstat-no" title="statement not covered" >class <span class="fstat-no" title="function not covered" >Cfe</span> extends Component</span>
<span class="fstat-no" title="function not covered" > constructor: (@runtime, @role, @iid, @incnum, @localData, @parameters, @dependencies, @offerings) -></span>
<span class="cstat-no" title="statement not covered" > @logger.info 'Cfe:constructor'</span>
<span class="cstat-no" title="statement not covered" > super @runtime, @role, @iid, @incnum, @localData, @parameters, @dependencies, @offerings</span>
<span class="cstat-no" title="statement not covered" > @workerSub = @dependencies['recv-commands']</span>
<span class="cstat-no" title="statement not covered" > if not @workerSub?</span>
<span class="cstat-no" title="statement not covered" > throw new Error 'Worker.constructor @workerSub=null'</span>
<span class="cstat-no" title="statement not covered" > @broker = null</span>
<span class="cstat-no" title="statement not covered" > @entryPointProxy = null</span>
<span class="cstat-no" title="statement not covered" > @httpServer = null</span>
<span class="cstat-no" title="statement not covered" > @app = null</span>
<span class="cstat-no" title="statement not covered" > @httpServer = null</span>
<span class="cstat-no" title="statement not covered" > @server = null</span>
<span class="fstat-no" title="function not covered" > run: -></span>
<span class="cstat-no" title="statement not covered" > @logger.info 'Cfe:run'</span>
<span class="cstat-no" title="statement not covered" > @logger.info 'Cfe:constructor OFFERINGS : ', Object.keys(@offerings)</span>
<span class="cstat-no" title="statement not covered" > @logger.info 'Cfe:constructor DEPENDENTS: ', Object.keys(@dependencies)</span>
<span class="cstat-no" title="statement not covered" > super()</span>
<span class="cstat-no" title="statement not covered" > @broker = new Broker()</span>
<span class="cstat-no" title="statement not covered" > @port = INTERNAL_PORT</span> #todo use a config parameter
# set entry point
<span class="cstat-no" title="statement not covered" > @startExpress()</span>
# @startHttpServer()
<span class="cstat-no" title="statement not covered" > @entryPointProxy = new EntryPointProxy @offerings['sepdest'], @port</span>
<span class="cstat-no" title="statement not covered" > @entryPointProxy.on 'error', <span class="fstat-no" title="function not covered" >(err) =></span></span>
<span class="cstat-no" title="statement not covered" > @logger.error <span class="cstat-no" title="statement not covered" >"Cfe:run entrypoint error = #{<span class="cstat-no" title="statement not covered" >err</span>.stack}</span>"</span>
# Set Command channel message handler (PUB-SUB)
<span class="cstat-no" title="statement not covered" > @workerSub.on 'message', @onWorkerMessage</span>
<span class="fstat-no" title="function not covered" > shutdown: -></span>
<span class="cstat-no" title="statement not covered" > @logger.info 'Cfe:shutdown'</span>
<span class="cstat-no" title="statement not covered" > if @entryPointProxy? then <span class="cstat-no" title="statement not covered" >@entryPointProxy.shutdown()</span></span>
<span class="cstat-no" title="statement not covered" > super()</span>
<span class="fstat-no" title="function not covered" > reconfig: (parameters) -></span>
<span class="cstat-no" title="statement not covered" > @logger.info 'Cfe:reconfig'</span>
<span class="cstat-no" title="statement not covered" > super parameters</span>
<span class="fstat-no" title="function not covered" > onWorkerMessage: (message, channels) =></span>
<span class="cstat-no" title="statement not covered" > @logger.info <span class="cstat-no" title="statement not covered" >"Cfe:_onWorkerMessage message: #{<span class="cstat-no" title="statement not covered" >message</span>}</span>"</span>
<span class="cstat-no" title="statement not covered" > request = JSON.parse message</span>
<span class="cstat-no" title="statement not covered" > @broker.onWorkerMessage request, channels</span>
<span class="fstat-no" title="function not covered" > startHttpServer: ()</span> ->
<span class="cstat-no" title="statement not covered" > @logger.info 'Cfe:startHttpServer'</span>
<span class="cstat-no" title="statement not covered" > @httpServer = http.createServer()</span>
<span class="cstat-no" title="statement not covered" > @httpServer.on 'request', @onHttpRequest</span>
<span class="cstat-no" title="statement not covered" > @httpServer.on 'error', @onHttpError</span>
<span class="cstat-no" title="statement not covered" > @httpServer.listen INTERNAL_PORT</span>
<span class="fstat-no" title="function not covered" > startExpress: ()</span> =>
<span class="cstat-no" title="statement not covered" > @logger.info 'Cfe:startExpress'</span>
# Create express application
<span class="cstat-no" title="statement not covered" > @app = express()</span>
# parsing application/json
<span class="cstat-no" title="statement not covered" > @app.use bodyParser.json(null)</span>
# parsing application/x-www-form-urlencoded
<span class="cstat-no" title="statement not covered" > @app.use bodyParser.urlencoded({extended: true})</span>
# # Enable CORS (Cross-Origin Resource Sharing)
# @app.use (req, res, next) ->
# res.header 'Access-Control-Allow-Origin', '*'
# res.header 'Access-Control-Allow-Headers'
# , 'Origin, X-Requested-With, Content-Type, Accept'
# next()
<span class="cstat-no" title="statement not covered" > @logger.info <span class="cstat-no" title="statement not covered" >"app listening at port #{<span class="cstat-no" title="statement not covered" >@port</span>}</span>"</span>
<span class="cstat-no" title="statement not covered" > @server = @app.listen @port</span>
<span class="cstat-no" title="statement not covered" > @app.use '/jobexec', @broker.getRouter()</span>
<span class="fstat-no" title="function not covered" > onHttpRequest: (request, response) =></span>
# Process request
<span class="cstat-no" title="statement not covered" > @logger.info <span class="cstat-no" title="statement not covered" >"Cfe:onHttpRequest request.url=#{<span class="cstat-no" title="statement not covered" >request</span>.url}</span>"</span>
<span class="cstat-no" title="statement not covered" > pathname = url.parse(request.url).pathname</span>
<span class="cstat-no" title="statement not covered" > method = request.method</span> #GET POST PUT DELETE
<span class="cstat-no" title="statement not covered" > queryData = url.parse(request.url, true).query</span>
<span class="cstat-no" title="statement not covered" > @logger.info <span class="cstat-no" title="statement not covered" >"Cfe:onHttpRequest query=#{<span class="cstat-no" title="statement not covered" >JSON.stringify queryData</span>}</span>"</span>
<span class="cstat-no" title="statement not covered" > action = method + pathname</span>
<span class="cstat-no" title="statement not covered" > @logger.info <span class="cstat-no" title="statement not covered" >"Cfe:onHttpRequest action=#{<span class="cstat-no" title="statement not covered" >action</span>}</span>"</span>
<span class="cstat-no" title="statement not covered" > switch action</span>
when 'GET/jobexec/ping'
<span class="cstat-no" title="statement not covered" > @logger.info "Cfe:onHttpRequest GET/jobexec/echo"</span>
<span class="cstat-no" title="statement not covered" > result =</span>
message: 'cfe up and running'
<span class="cstat-no" title="statement not covered" > @sendResponse response, 200, result</span>
<span class="cstat-no" title="statement not covered" > break</span>
when 'GET/jobexec/info'
<span class="cstat-no" title="statement not covered" > @logger.info "Cfe:onHttpRequest GET/jobexec/info"</span>
<span class="cstat-no" title="statement not covered" > result =</span>
message: 'GET/jobexec/ping\tto check if is alive\n
PUT/jobexec\tcreate job\n
GET/jobexec/workers\tfetches worker pool\n
GET/jobexec\tgets current job execution\n
DELETE/jobexec\tdeletes job execution\n'
<span class="cstat-no" title="statement not covered" > @sendResponse response, 200, result</span>
<span class="cstat-no" title="statement not covered" > break</span>
when 'PUT/jobexec'
<span class="cstat-no" title="statement not covered" > @logger.info "Cfe:onHttpRequest PUT/jobexec"</span>
# Validate the job is valid
<span class="cstat-no" title="statement not covered" > job = {}</span>
<span class="cstat-no" title="statement not covered" > if request?.body?.job</span>
<span class="cstat-no" title="statement not covered" > job = request.body.job</span>
<span class="cstat-no" title="statement not covered" > @logger.info <span class="cstat-no" title="statement not covered" >"Cfe:onHttpRequest body=#{<span class="cstat-no" title="statement not covered" >JSON.stringify job</span>}</span>"</span>
<span class="cstat-no" title="statement not covered" > if not @broker._isValidJob job</span>
<span class="cstat-no" title="statement not covered" > msg =</span>
message: 'Invalid request'
<span class="cstat-no" title="statement not covered" > @sendResponse response, 400, msg</span>
<span class="cstat-no" title="statement not covered" > break</span>
<span class="cstat-no" title="statement not covered" > worker = @broker.onJobRequest job</span>
<span class="cstat-no" title="statement not covered" > if _.isEmpty worker</span>
<span class="cstat-no" title="statement not covered" > msg =</span>
message: 'Could not process job. Reason: unavailable workers to perform operation'
<span class="cstat-no" title="statement not covered" > @sendResponse response, 500, msg</span>
<span class="cstat-no" title="statement not covered" > break</span>
<span class="cstat-no" title="statement not covered" > @logger.info <span class="cstat-no" title="statement not covered" >"Cfe:onHttpRequest worker found=#{<span class="cstat-no" title="statement not covered" >worker</span>.id}</span>"</span>
<span class="cstat-no" title="statement not covered" > worker.channel.send [JSON.stringify(job)]</span>
.then <span class="fstat-no" title="function not covered" >(value) =></span>
<span class="cstat-no" title="statement not covered" > @logger.info "Cfe:onHttpRequest PUT/jobexec job finished"</span>
<span class="cstat-no" title="statement not covered" > @broker.onJobCompleted job</span>
#todo extract job from response/value
# Value[0] contains response:
# Value[0][0] status object
# Value[0][1] reply data (buffer)
<span class="cstat-no" title="statement not covered" > if not value[0]? and not value[0][0]?</span>
<span class="cstat-no" title="statement not covered" > status = value[0][0]</span>
else <span class="cstat-no" title="statement not covered" >status = 'FAIL'</span>
<span class="cstat-no" title="statement not covered" > if status.status is 'OK'</span>
<span class="cstat-no" title="statement not covered" > result = JSON.parse(value[0][1].toString())</span>
<span class="cstat-no" title="statement not covered" > @logger.info <span class="cstat-no" title="statement not covered" >"Cfe:onHttpRequest result: #{<span class="cstat-no" title="statement not covered" >JSON.stringify result</span>}</span>"</span>
<span class="cstat-no" title="statement not covered" > @sendResponse response, 200, result</span>
else
<span class="cstat-no" title="statement not covered" > result = JSON.parse(value[0][1].toString())</span>
<span class="cstat-no" title="statement not covered" > @logger.info <span class="cstat-no" title="statement not covered" >"Cfe:onHttpRequest error: #{<span class="cstat-no" title="statement not covered" >JSON.stringify result</span>}</span>"</span>
<span class="cstat-no" title="statement not covered" > @sendResponse response, 500, result</span>
.fail <span class="fstat-no" title="function not covered" >(err) =></span>
<span class="cstat-no" title="statement not covered" > @logger.error <span class="cstat-no" title="statement not covered" >"Cfe:onHttpRequest PUT/jobexec error = #{<span class="cstat-no" title="statement not covered" >err</span>.message}</span>"</span>
<span class="cstat-no" title="statement not covered" > @broker.onJobCompleted job</span>
#todo extract job from response/value
<span class="cstat-no" title="statement not covered" > result =</span>
error: err.message
<span class="cstat-no" title="statement not covered" > @sendResponse response, 500, result</span>
<span class="cstat-no" title="statement not covered" > break</span>
when 'GET/jobexec'
<span class="cstat-no" title="statement not covered" > @logger.info "Cfe:onHttpRequest GET/jobexec"</span>
<span class="cstat-no" title="statement not covered" > result =</span>
error: 'to be done'
<span class="cstat-no" title="statement not covered" > @sendResponse response, 500, result</span>
<span class="cstat-no" title="statement not covered" > break</span>
when 'DELETE/jobexec'
<span class="cstat-no" title="statement not covered" > @logger.info "Cfe:onHttpRequest DELETE/jobexec"</span>
<span class="cstat-no" title="statement not covered" > result =</span>
error: 'to be done'
<span class="cstat-no" title="statement not covered" > @sendResponse response, 500, result</span>
<span class="cstat-no" title="statement not covered" > break</span>
when 'GET/jobexec/workers'
<span class="cstat-no" title="statement not covered" > @logger.info "Cfe:onHttpRequest GET/jobexec/workers"</span>
<span class="cstat-no" title="statement not covered" > filtered = []</span>
<span class="cstat-no" title="statement not covered" > _.forEach @broker.workerPool, <span class="fstat-no" title="function not covered" >(value) -></span></span>
<span class="cstat-no" title="statement not covered" > filtered.push _.omit(value, ['channel'])</span>
<span class="cstat-no" title="statement not covered" > @sendResponse response, 200, filtered</span>
<span class="cstat-no" title="statement not covered" > break</span>
else
<span class="cstat-no" title="statement not covered" > @logger.error <span class="cstat-no" title="statement not covered" >"Cfe:onHttpRequest unknown action #{<span class="cstat-no" title="statement not covered" >action</span>}</span>"</span>
<span class="cstat-no" title="statement not covered" > response.writeHead 404, 'Invalid resource'</span>
<span class="cstat-no" title="statement not covered" > response.end()</span>
<span class="fstat-no" title="function not covered" > onHttpError: (error) =></span>
<span class="cstat-no" title="statement not covered" > @logger.error 'Cfe:onHttpError'</span>
<span class="cstat-no" title="statement not covered" > unless (<span class="cstat-no" title="statement not covered" >error.syscall is 'listen'</span>) then <span class="cstat-no" title="statement not covered" >throw error</span></span>
<span class="cstat-no" title="statement not covered" > switch error.code</span>
when 'EACCES'
<span class="cstat-no" title="statement not covered" > @logger.error 'Cfe:onHttpError: #{INTERNAL_PORT} requires elevated privileges'</span>
when 'EADDRINUSE'
<span class="cstat-no" title="statement not covered" > @logger.error 'Cfe:onHttpError: #{INTERNAL_PORT} is already in use'</span>
else
<span class="cstat-no" title="statement not covered" > @logger.error 'Cfe:onHttpError: code = #{error.code}'</span>
<span class="cstat-no" title="statement not covered" > throw error</span>
<span class="fstat-no" title="function not covered" > sendResponse: (response, code, msg) -></span>
<span class="cstat-no" title="statement not covered" > response.writeHead code, {"Content-type": "text/json"}</span>
<span class="cstat-no" title="statement not covered" > response.write JSON.stringify msg</span>
<span class="cstat-no" title="statement not covered" > response.end()</span>
<span class="cstat-no" title="statement not covered" >Slaputils.setLogger [Cfe]</span>
<span class="cstat-no" title="statement not covered" >module.exports = Cfe</span>
</pre></td></tr>
</table></pre>
<div class='push'></div><!-- for sticky footer -->
</div><!-- /wrapper -->
<div class='footer quiet pad2 space-top1 center small'>
Code coverage
generated by <a href="http://istanbul-js.org/" target="_blank">istanbul</a> at Wed Apr 27 2016 16:19:07 GMT+0200 (CEST)
</div>
</div>
<script src="../prettify.js"></script>
<script>
window.onload = function () {
if (typeof prettyPrint === 'function') {
prettyPrint();
}
};
</script>
<script src="../sorter.js"></script>
</body>
</html>