node-background-task/test-coverage.html at master · Kinvey/node-background-task · GitHub

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
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345

> background-task@0.2.3 test /private/tmp/nbg-coverage.z5hJV4i
> mocha

<!DOCTYPE html><html><head><title>Coverage</title><script>

headings = [];

onload = function(){
  headings = document.querySelectorAll('h2');
};

onscroll = function(e){
  var heading = find(window.scrollY);
  if (!heading) return;
  var links = document.querySelectorAll('#menu a')
    , link;

  for (var i = 0, len = links.length; i < len; ++i) {
    link = links[i];
    link.className = link.getAttribute('href') == '#' + heading.id
      ? 'active'
      : '';
  }
};

function find(y) {
  var i = headings.length
    , heading;

  while (i--) {
    heading = headings[i];
    if (y >= heading.offsetTop) {
      return heading;
    }
  }
}
</script>
<style>

body {
  font: 14px/1.6 "Helvetica Neue", Helvetica, Arial, sans-serif;
  margin: 0;
  color: #2C2C2C;
  border-top: 2px solid #ddd;
}

#coverage {
  padding: 60px;
}

h1 a {
  color: inherit;
  font-weight: inherit;
}

h1 a:hover {
  text-decoration: none;
}

.onload h1 {
  opacity: 1;
}

h2 {
  width: 80%;
  margin-top: 80px;
  margin-bottom: 0;
  font-weight: 100;
  letter-spacing: 1px;
  border-bottom: 1px solid #eee;
}

a {
  color: #8A6343;
  font-weight: bold;
  text-decoration: none;
}

a:hover {
  text-decoration: underline;
}

ul {
  margin-top: 20px;
  padding: 0 15px;
  width: 100%;
}

ul li {
  float: left;
  width: 40%;
  margin-top: 5px;
  margin-right: 60px;
  list-style: none;
  border-bottom: 1px solid #eee;
  padding: 5px 0;
  font-size: 12px;
}

ul::after {
  content: '.';
  height: 0;
  display: block;
  visibility: hidden;
  clear: both;
}

code {
  font: 12px monaco, monospace;
}

pre {
  margin: 30px;
  padding: 30px;
  border: 1px solid #eee;
  border-bottom-color: #ddd;
  -webkit-border-radius: 2px;
  -moz-border-radius: 2px;
  -webkit-box-shadow: inset 0 0 10px #eee;
  -moz-box-shadow: inset 0 0 10px #eee;
  overflow-x: auto;
}

img {
  margin: 30px;
  padding: 1px;
  -webkit-border-radius: 3px;
  -moz-border-radius: 3px;
  -webkit-box-shadow: 0 3px 10px #dedede, 0 1px 5px #888;
  -moz-box-shadow: 0 3px 10px #dedede, 0 1px 5px #888;
  max-width: 100%;
}

footer {
  background: #eee;
  width: 100%;
  padding: 50px 0;
  text-align: right;
  border-top: 1px solid #ddd;
}

footer span {
  display: block;
  margin-right: 30px;
  color: #888;
  font-size: 12px;
}

#menu {
  position: fixed;
  font-size: 12px;
  overflow-y: auto;
  top: 0;
  right: 0;
  margin: 0;
  height: 100%;
  padding: 15px 0;
  text-align: right;
  border-left: 1px solid #eee;
  -moz-box-shadow: 0 0 2px #888
     , inset 5px 0 20px rgba(0,0,0,.5)
     , inset 5px 0 3px rgba(0,0,0,.3);
  -webkit-box-shadow: 0 0 2px #888
     , inset 5px 0 20px rgba(0,0,0,.5)
     , inset 5px 0 3px rgba(0,0,0,.3);
  -webkit-font-smoothing: antialiased;
  background: url("data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAAGYAAABmCAMAAAAOARRQAAABelBMVEUjJSU6OzshIyM5OjoqKy02NjgsLS01NTYjJCUzNTUgISMlJSc0NTUvMDA6PDwlJyg1NjYoKis2NjYrLS02ODkpKyw0NDYrLC04ODovLzA4Ojo0NDUtLy86OjwjIyU4OTosLS82ODgtLS8hIyQvMTEnKCooKSsrKy0qLCwkJSUnKCkrLCwpKiwwMjIxMzMqLC0tLS0pKissLC00NTYwMDIwMTQpKysoKSovMDEtLzA2OTkxMzUrKywvLy8qKyszNTY5OzsqKiw6OjswMDExNDUoKiozNDUvMDIyNDY1Njg2Njk5OTozMzU0NjY4ODkiIyUiIyQ4OTkuMDEmKCowMjQwMTErLS4qKywwMTMhIiMpKiopKy0tLjAkJScxNDQvLzExNDYyNDQmKCk5OTslJig5OjskJSYxMzQrLS8gISIwMTIoKCk1NTUlJSUnJygwMDA4ODgiIiMhISI8PDw6Ojo5OTkpKSojIyQ7OzsyMjIpKSssLCw6Ozw1NjlrfLakAAAg2UlEQVR42jR6i3ea6rYvPgANIAhVXh8WvkQlioUiFlFcBtAmoiRNdzxqu9p0J7vrdK29zuPeex77nnvO/35n1r1ndHRktI0jTOacv/l7lCBK5UqVpOha/YxmWK7BC4TQFKVXrbYsnimqxuuMVlOQ0XltWjUdCwRJ1M+tC1KudOs9q6+da2adUewG0SC0SwELfHtgDds93VEuydEbl3QMWeNoYkR7b/0x1ZRobGI3mLwzAhePqTAwhg6aogjNsGy7/jwQ4rkdqe7CWLxF8k9LfMVFyRS7VJqtkrW8Vt/bkR8FZJao16ipknbC3Yw2lM7laO6HBEOadEZ2tpf65c4v8e3u7FyU6qbiNNyCuzXZ6pawgnwgmrpTT/Q7w2EZmiIJ0dzWDI7mhQ80IfRnMu2kzA5r5r1pIFoia+/d93HRYp1GV8TbrkWoU/+jdI0Ff6yGwTjT1Hn8J+8m1rKpGiYPuNiHnMtNMIv+zpsk84MYTNW1/+DpwXLvckdOCMYowVNPREe0QlM8xRHXXFhcNDzupwsSmb5pH+0t0RP2Qk+QtI7F1Qm6JRC6ZPBtPq/dq/kH+jxtCljn9TIpW6rQIgmSVyj6lPICIw4N/taka41PFUInth0je9+jO6Kt1G4/a7V2LEgG02B0pHVuCZrgltSKMuIl5SyufUv9mYuQi+mFgzbBEtFo2g+Dh4sSTrLNu8JPh00sQydpb00tqXBvqRN7Q7kqzcnIxCGnvZt/WmJacoOEO6Dcn8Qre03pOCSQxbMOXUuDNx9SxuLz4W1I18gvjViQ67zV0rxdWL8Te/TQkuo8STS41DR48W7L6YP2uWIqiUV8rd6Gbf/rnegKZeG8TpAM6afhGze9JAOxbLjsnUXEbrZ9vLYd7MT32cPF5mKKxmjy7huaoD9n62GOxni3iIJwv0IzZAZjdZkUtolCNLVfYZNaquFjGszVVf+J0vrz4CawoKdHnOzb0NMH7CDBOybfYNJ4rfeMyFNjkFYVTzMFs87rnPGXLUOeNKRVc0LnU7/UIgelzsy3CMuth0YfvnY0wsD3vODUL3eJcKqHQpm8yM3XZQWJxO6Un9iYloyyLpOwN2obHy6W6gbpcb44XmyC+mg+itAcaprGcrwZCqMj/GmtKn0zPvpTz/Cv1dw21XwP3cRupg3H3MF/S71eTKj1YrdwKdc2Mw0fRmb2sFf8lW3aU6JbIZSEPqvXvjM7G/aApyXlXeqKfMq0g/Su3rUGJPSPrtGElgknrZM3xUXqsAP6zMCNVn5u8aJnSNpJv2uru7t2jfRziW2+GuhqfldUNbPk71olwo+46ePUo1U3WKk/e5YK07F/wGRgcpODmQnIlVeHCWBE4puBi2jq28UKpqiN1/4UOrGz59TNYrrQHtd+11sG40BGD+pXdelNqGOg4NXe8W4eacJV/NS9/2Umtym6WQqveqR9xdCMElpxnbkalM4Vf9uaEcWZaKdyibEIjWKxJZPN95niCL3GiaXyssIrHxoLkqkzLCXULN46/f2h3tQJgyip+Tk9EAjJ9aJshq7t8X45aowSKspMSvPf7r9R8yxNptIaHS5ozuEm6luPDApugyNP8OaqiQ4BjaequXA54SLC83eHIY2r+CZp4409Xqw8Aa2oI7XkCrQi+in0w5AqF/kLNrcUz+qkl/lAobY1jSnx5OJNhyXIz3qfNFlXc0TKaglNwdWkWYt9QQ1Kr6W8zue21iNrdJk+N5oCr2O9nEtWKC7IS5J/zdDEYrmnAYfg6agCy+qcgz7ZofeDc4PbUWSvkshWuAc7OjiUyLkj+RAtdlwXJcjxdpkTTHDhK8lBCi8+JtvDVL1W6elmOM++YS0LuSlaP1oUvAeiW3cFnvTr8EbTz1tsSMYdGeZe40sRWu5uAfj7q+ZoKv2FNQ0p5XY1lmlcigHZqTPpabufEVrNuNPi165w3uCVQJHyJqmSJ7ZHnguqwtCmwViIJijj04ba2JNYtB+yORf5gg1/9t9iw4vUpeqiunSAbf+IBdj/b+iG2qrHvuNP0Vd/+ThVZT/lrvHYjjgDbbyxaqgHNM2uhxa1GW3UedZYhMMwM4mQhltouK+IV4NdbIQNM+8Yv311RZk9kT4tiYR4LkyFcuPpdcjuhUuFqBAWRZa11lcZ3gEBlXywsNhrt+plISZP5DlsV9l4EgY6J3yZPTUcMrgaWAT3oI79eSbGEbcJpr6BD8kyDiVt+G0/hXosQN4NFXKlfWIfsIs0BHODVok1/IGnKFHJYIquh8Xo+2+bkQNTGgWmN/fZ0Y33LSj6lr1GyV7mWIKg7ZTRZPGuhF/zjRNcQ1UPtSYgnWQxSs0yrVhwNDcdGMNSNe2JT3WuzbAM3HykyAajS3Uphf6STKEqxLas9EnmnhA/lyj9Uj+JoY7SVgVmGLl46Rm2u98sbkap2lzAdKBG4r6LgulQOSSjQv1GWdQ0jtDUK/mAaqM1Uqjpu4k3Rvfvxv7YTxLSK+wN3E5jVIzmF23uZ7hiH/sVP49D7tvoKp4S8b1LuvRlivVB/algbhcFITYVXvDpLzpDfplR2uD5V4XJFxpjmIpLc9Y5sB2TpBRix7Bme6GZIq+06v3XzNeTcA4obQIKxrnT4C2JpOqD92dbmSX8MGazly5EsZVMvSU1f4RZwyu8iQXbVdeLlZrjuTT1jrY1uk5c7iZ7RsvhhluqAkq4JpVQAg7RJFtSu+xgJ8Pv6O1j5DkLxT8mkbfyRW5DrQmG7hiDIjCgBsADbjuof6YHLGeV6a5Q1Smx9joUXPpdaaDx97A/Wq00oJkdR7ZYuQRfS533JtxO1erduqWOYIt3wh0wpbLuCNIYkwxbswbikCUu2CDCS+Q+7rgVtfRcm+SOcdKPRlZ/rE7wNVUEE39KTS5uvUKN1PUnkloPkyzhyGQ8qkouEjJ3H/VXdqG6asSRiw3ecMlBvDDt8dDhBHXMwZ2Cajzjr7/76T+IavqPYvz6r7//E/3X3+N//h/0QozbjPgPiir69P/8X3/9F/yv8b/827/++98WItPu5/Hvwd8YPf5bp/2/lX/T/+Of/0MJ/lYTa+L/Ef+d9vN/3/2T6P/+jyTzu/evf6U7vxN7B6pJkRtAF6jUr8I+P8RsP/ptGhfqFk+pQ/DgAy6NJtRYJdXmp4gK7WLqLKJ+MaKhGjOojvL+SnIWrkpy0SLHDe4QuyNzaEA15mLMCcmE8Em+4HdOihW4/ZWuppJEmzeAwcDtv7MuLc9y2V5atvxXNe3S4DUMt5/Qy2LM9kSYKiVWBuKlfp4nxTntpuW03JbIlkiRvBXmT23g1I2OYe6IizUHPIq6zm6mbfsbteKmi/sg9J+ocQBMctGFO7iljo8TPN+z3jxw4do+ZwfqoR9dkNTKHyM305GpTkfhcHexVkPVGEbUOjuo9f0UMPHBFlGEx0SLvJvVRKTwW7PSew5oPme+E42+frJa9cGt2njS3dK5kIif2eYbhuSEQXEqMVfUjhGIuin0G0/W5ezJyJQy3SpMLai4M0JUWb5u1k9tny5bd1pPwYBpQuDCXZl62xg4CdVEAtflXHs6JKmP/pH6mOl796Lgopj0o8d5kKh00hxG3OSdEE/QBo9Hgr8JJqAeLDwJohG5j/DGh61Rc/+tf22/8kEnxHNCEjo0ElvvGfESZkqmz2BDcKV1H1buSkhkdg7p1IMGs2s17nYjpblrWuE2K9WEO/hcRp5e9oOF/QBmOaDtgil+oaU6szPrdwW65fOB0KUTsVUn7LFU7J8e6cxJIl9+FHw5MQMzuQJ+4oxMH3iW/5GK+hWuG0T+gTLs+fAjdtUd58TmIUq04EeyRCYCjkldow234aIgR5bqwrtZosZ+6YEqAmDqatJ9lWasz4IquKALPtd92hGI3Z2BdzzZue+REl1Om4DIWD+RrtUTOJLI+S0jHowXXdAxsGLSd40zYNuEUlOGhrwL6c7tcOtUOvpJCP7QBQS19H+GvZn05ewjlVLz+IGKoC9TyfQjLMBNmXCuqqtTdOSukZW48B0HqgSTCBrBnlFvF4CG2Su7yFzqmJFURK3UmTT3ru050r0ptUpMilYnBJWfl2Bv6kPlUuE1kxxpdzui9AubsR2N2boVSu81OulAwBqoSr1LZ0LLYOomyZHmjqnXlP72s8LnDouEJjtodBvdHaG1jMySYO7crWd90MpCRyCG14vb5IE7Arupw/y/RcCm/Tm3zK6zYj8PYNaGldiUfkB/LHWcmf2lVM+mwyU27a0qq2tscrQ/vzBjN26DnntIrOyGizzXK35yKQdYnUABkyN4saz3WD/viF+eCcsXnIajdWYJWaYHRstIis9CS+tqnFGmz2j5uzfr3Z4prqgK4XOT/PyftvjZqIm8lhkfxJ7Ol3CJF1piYBGAG8wtAk56Drw1YwmOpcz+NdfkSpSLplRXLXHL0Rquj6YW/gabqgK7Dgr6NwtH0B/AN7XrN+MVJ6AmXmUuqmQulrNNYPmH0RoDogydOKLo/QbfYNARSQQKISRCzRXU+q9WWJFL3LZW6u34CkeG97xC0NNGaJ0bvK6SnZS3zPskr5EtuCgjMWR5o2x5BqhKmDWJPRe7JMEOyRb5uUKlHaGVtq5ivSOaSliSXp9SQm2qk8MRJh10MAp9QQ2H5t59J8rjiwSZtoIfMGjlLPVNdYl/LBR0AO6WLGDmkLkIPRE45Y9MftdAK/yNu1Hn6tzOQTesgQ+8fSzB19wO91vCnO23vOWQdwJ63SJrYjdfKFW6W281PKs2k8iT9ai1cgJ4sa3xqdvmtxR8/+D1B8AKc2u+6JftryRhMWSQtoSBgIyyQGyxcnELuAasXN12oSriU4RMz1DD6RL0TSV+om7i1Yt+jEE/jnawM8cX/UhN4nkiv/w9eALrzNhXuQfOzFL0Fi6SjF7/4Qn8rLYBoa85cvgAnkCEBP+HPbEnquVXCZsMS/yzYw2Vru60P/+nJPYKkzZFjmbykzUoEqV836T5q3fP/L383dF82tx18/AZgZczMAgyeWYKmSZIqtHL+e+O4ZRcq9VI3g/qPeCoiK4pcgEqdbS0S/Be54sbVQOuJVPNBblIghzeasNu7h/g+Sz1IdhI5lCwq1nUb3Ji4OCIcqQZqtqJ5w7rXrg/DA9IgVmEGhDgGecEwnCTHffXcXs0V3OCEVzYDKS1vp/oX+ng+6XVU86UjA6FMO2RXOOOrqY1GgPvrAk9HV/BXtCu5RuwF8qgdGDLsBcui4E33ymdBip1X8uKyhIWT8qNRDsXz+gvO9UiEC0d8RG4Tf2x8H4slljgHtCBcxHLTWOYJm5H/fCPCzOgf9qgOUxTRZ0Pc6ha5yLuLVT9ntvIa6gacE99mCovdUumTQdRP4RPsS9129eEe2uSvvGh0bV4Y3QPPhPZMqhZWSMa5R0Hc1SGO4IVOQc0FrirlibTVfKRrYkD8kz3b+X65/QkUNaZdrdl3mCap0Hf3YcCw/LiouJYNbqz88UqeDYv93yO7vvXtgl4XCyAO4ODkY6W+83+LZU//p3/zXNGGrUKClCiOnL27iJZbNWDF02XXAOeFlB7IaADoMH1Yqr+UP9biyZDEa/iJt4MDeIz6GKTdLVBfWGVtRN4fdT2rgReX8UXwF2zOrradm4J0nyTgdPnai3RvzpZvCKDUqjOwD/QA6EDaMCLewX6QWYVnHY1sx1bd8ovYnPm1ZvPH+rE20lWjOCnZ66/xDt0QAl15FjfBcZp+i9OU0RNPQ0t3x2pSNWo8eiYudwsnuP1Hq6iH1LJCJynkYsfgJ0p3pF6SoQk2l+jqE8CPk+ziGJRSKjs+W5AO185umPdkYzlK4wl7TC9NxyyDP7ZoyYVoXiuS6SjnInlLWrwz1i8bGTKXX0AVQWkSfIlglW3zRJRJ8bg5VgE6ZEnqNu9B++0GNQvDQJvFize4ESNKBJP+8vA3LM4AX5SIBq08Mob+7QMTCZx4nwP/64+4BnlZC+8WtlP/CXw6t1PwMwkJ3jhP1FiXLhDF/3I6FGUzO2DSi9ABxKyyL9paZxSEz40ZCPQToDAJu1959k7QdbVxgB4icsu2s4zsTPJhcEDo+N1GX4zSk/wriRh8AqwL62972i9HJHd1ydaLXVzvKvOfGGw5RVcUVMiKXFH4APdkQU/dc5BX0YfKTNZYXCW9mb8bc8mufoQP6BbdQmT99ZjoYfr/go4TgQX9IDgztim7wyFeGMfbNaeqj8Dzs38pgcqwSv2hbqB3oSGKWKy+sesY7p57wAHldqE6NDudk/W7s/zjrK4rZFlFvaGxnSZdHbc1y47qDN6xkoK8O3bfr2j41dlJZ71rB4dlDqapPFa8N6xBrprUdtenUCHwxKNhw1uuTBh+9uU45k4REpQABN2bAO9DSLqoIL26gNroWgup5pUMxHUNSq4Gyz47vBPvilpo5f9OYI2ddAqTqmnxXERxQJ3UK8fHbVE9HagHi3+tqNRoNsArdmAxHA5LwtQo9ZAaNKUTljnokljo2x8scqVpEEIPc01fPCdHOCg0DeWBz8D5TVAAfx8aRH5X2ZYNI3ebKDZdeJ+oBDAxmRqJ30Eh2/DaeAy5diVNMpEDmXiPDsGTzBLXy8eVDdJoIafgx/gxMyQi454QrW56nCyeELgSuNNEmYkflF+t3CZQOVRWjKhIuCclmQSlAXT3+4JGG75B4t/5hQ+ldMP4LsAW6z3XmU6IJJwpnGVnsgUZhoY1fZlwTR8wSU7xRejf2uCx9Z5trVTRRJP9KnEb134dEieil6eCOGWgboI7xsqsqM99jfJLTePjygKlH2CVxxsse9QRzTBFjD/Kjqitr/CCTBt/SJ6nLxz7cKP9pFqBpp0lN5y+adKNsZjrPuroemZauH9aTTFD3EKHW8S55XBLFQAt1jgxTQCTwxmx/JyfsZDN1RroN3VaxpSenpIX7K+ZbL8VdlQDcI4Cbzg3QJLa9yVqNxUelu+EtxLVqeekaAvSJkO6sSVqbUajxqhKshNpvZqoeApF0k/0P0ikkwUcbdwc4A1ejN7Oo0O15kG7hTMoK3hZRBCX7YYeLW0wvcXx/18n/u37yLgzBYVBUvORGli+sfRcX/74uD6P4hq+7xu54TlWJLFzT63uwUDwuEDdOjJQqx7JV+ZjaEAPi7t0MMrR4Q8Rkf18uxD6RK0RKh0hL8YU+DeL97i4pa5ZSyAfXKwZRS/8gXcxdZXm62RBDj8U3sN8x95b5PpPs/mCBKYvpaA50pN5Ct/499AFTtwQ5vgeSh+NHrKIi4NVpwM/XzRaNfJD856lPE6M21zWPguFsH7jbLVyEDfRmt4VwrhCJ5VTYmcSPfGgO5clfN+vbaDZ7sakU5+2vZ2WCDY031NxJarVytfDDVtiafcTGO2rJ/taoL3zChN2qmjxofczTOYQPPVQPh0JVtYgdUQINcSiNEEy58UdYXX1MpWUCEBx7LbcGtAm8XWRQTVOaoV3ySri4RShhs/B/0m4jX6OAwXOvcA09bNSG4czEGv/Wey6V/jbTCNTW6awXdNTcA1GsPe1E9fZdGl7R0vyoVpIdJtfC6d32NNErrvq/R+d65VG+YOwRXppXxOCYyGNSf1K3x6VxAW/vtz4EC1SgCOSPdN62sLsoIzuDfg8GwZAbquVO8HIuFP/ToVoeUB7nnwMF35a1wK1tI6fkrqFKhQdeJpwyls0pIy8AZde3/6LUUbFaYJthyUJSU/kqDXTLQElnn0Jr4B2RVghNrmNmoEn7pXIeshPguXVsvwoTdmClq49JJU3LWhHyWTrJL9bRP6VKv3tZoA/th77p5Jw++OEENvyvWy/pNeExiDUVQaXIRGh8xySZTI36yueFaSXo1uJY0RnXYgEOoWWOJHeaVuX/bGNhHsh2yinznl/++NJcE9j6fBPRcBdq9hb8awNw8U7Bl6GM7x69EDOIIbX/npZ++amlHR9L/35mE/2Ss4gb0xCcY4VyTFLRE796vHysLAamqcyO+aFQyJIDBNslbH2/MrAvZiSEIedc/cqjmv4fbda2pXbv+F5a2szSsdkm9noiNURXt8edUhGUF6fSZWd1IJaXKFwD+49R6eCXD4Bkef7j9tRtNMVgW8BhRz/Qpy1TmeYk0doyjZoJSbePOReVHgkFsCFuQJ+Lgc4BxeAsK/cOiNDRmdNw0ctYhn/nQ498dYI5znzGLoJi1rav7Cn88rL3wLePVtDK5gl77Tki3gHEsIAQ2+IKgarj7Y8W1IQzV5V9N+0TjLqbg68WfKcOmBCOj3JkwJhVIkwDhc+JorXuZEPMEh0vvH3x7iqf+VAwXgd4diZiaJD1zHL9Snx6Wfg4IugreyhabQkcir+y5XgDtdx3Avs7lkeeCBwDvZoTUCXx5QrZkcEqWfYEiEYRs/EphmRALSNGR1Iclgdr5VFoELpzF4++f35w3/j0t5ucW3n2ch4PQCLuUXupsPRR7UA5FjSKrMtPcKAZJfagO4lGE7FH3YKMjorpK0ZxAv+i2JkJhtAMWWWFej4RhPR/cJ3DxwocCvXDi4SGZU4cu+K32XndiFWgopAl+0GApcwf1XvymJcFs39jExIBO4yUjU9MExBLQYc9H+W7+IgdESPRpciT+rKZPebVtaVq+1GYO/5xTAL3HASjNTGIgMvdjWbgc7JvdE1zIFpuC0U9ESiZyzBixzxWxj4Kwh8My34q+FK3KNLtmsA1qyrmKSNQOXCPUZd+ONelBTvFoUI/CYsqa/RhtKiyMf2CgSFqEPk59Y3uqnlZ8gFpswfSYyko23yVZYxzKGxGm49Zqxg1l8oz5Ra9XaRwHkuxepmgyhm0SoNy2KlbcEqK+9QqS9PNx9Ihm9U7gsR55SSJ1FBDNnkuWKxIZ0SDpXuOGwZdoUbOMDPHP4vBAgz2VlSEJAHZGJVbYIg7l/FO5KfIVvxC8pPPxMGcNMoevFDeStt2iqztE10n2TA4dgJH76YS9HDhKHD3iCx6ieFX84BAI3QQnngh76f5ruPQVbr5qZmck/5UjDc26lfrOvUBWy0Ogl8bCoOkMOns81TnC3cuUS9KW8+9A+fe3XYZOFUPG1u5epSSmDLw0s5s2F0W30ANeo+zJkJQz9SPZgzwYpEoktofhGVfmLOAB20boCbW1QWq/NpET/hnMecw/uSyAH4NJc3ECOU4nnkK1fj3S/i5dwb3R7k00AqQQUwt7Ie1qV0aY/VQX0J8hLPy7eBNXMHYZYDNxHZ2Qh6AuXJxq+AeRec/Q+JLhZV6hpXwQEzw7bf5v9uUf2vpq3qlhmy0IIGTkwYdCfSAFmqbdo+3XvDTDjFJde0mbeQLcn2n31xaAqJ0ixO/CLsT4I4G4DoncVTgRGNBtsCcjISWT+oeXZ4Iedw/8OsJI1aPnNKLX/60VvcZb94uasRxCkqlPQ11u1Sa2hHvB80WQENxVyzjns0/PiEByyil21Te6oisk3mNCEMrhouCFO3yEZTHHOCMy9eb/4Tmi8cVf3Lf7P53SY2hX3PSN033As3ETIMLHWumWEO9JXHA2y2SIBlIPpLGG2qvNsCIlIr+B1SWAqRKm2w6Blf7U+zCSBwJrfHG5i8J5Gax/cVonMlon7aHJX/gSvucIncRP93XCqkv7D8IFKFsLiBgHqUpXhE3pYjEcV1dk/JD9zFVCfEaQIVX8Jmfz7IIofcBKQ4OaG+C3xC2veX9CD+iAFXDNaGg9eTVxvkbJRJlW4Nk9Wk13kn696jWppRDe/8pDrYMO9ZyxZ98ReKSz9kWKLLyk2zCZgAniCkLJVX3n1M9DYbomyahWiv/KixRIV9hj/oFz87I+HLznbPTjpa+D+bZQnMuRsljTpv90vQUt/pK7jCFnA30B/jtroSF2/m/gpWn1aQs5WeA6ghzF8SdqWI20fghdSeDOCSCmLgTkfaGgGDmw7nHFkRzGtag57IHS2na06I+gzEphXo1w/Zx2BM/jKL2nZoFjHggtFQjYi8nSVRSXIE58RPbBObXk7uuIL9+rs/5Zo7suJInEUxgsiZZAWS25iBtpEiZeBgDtghEoAE0sjcayNq85M4tbu/LF5h51335PsGzQ09O875+vUS89lkWMyNOFoip2PuyWyMP/iU2XIZdfCCJNDjebDoBLQdpy7QQZC7s9c0wjHJervQNDu2jWzBW5MSAJMr7bP+Iv92BkS/GGgzjEn7MF1IRKFwwzbjbS4/slGOmhx9cZrFu7HSEefojNv3r0UaKfKOWzXsq1zEugbzlMDFsacRJJI/iJlK3vtkZ+PLZIVMFlKA32wbq2Kd5T0uCLZ1CPkAfCdzkz2EYscjDcZq2AWfziN2covN4kXE1lQXPPLTNM1xx3tbiepcO/t3SWm4w87qfh99SL0ZnY+LKFPLPeXVM2mIIoVWt+9Nk0I7nY4O79iGYqxZ8RVz289an6NVdJWnSKZvJQCAuHNiVaDxPAFoH392t9wot5t0/qmU95eEWNbU2udUW5sN9JVqcYlvAIfLeYC33oUzzxZgSktsv21mA7Uly1FA5VnoJFh6N244Wmv3YJGFv/TCPryaw+ZORlpZjQdq/2DYXr3EZskfed0G61P09ipTKmlTQ1067Rg5+PAk5FlQ9e0SWbGf2B/08kqymOTMVOznsALHHNFH4LFRKl2F/NOiYFl9khNHnSu9Ak5sq26Ynl/i2fdTle29Y1ugqmR5Yj4YT9pvslFyYCbw0mNFr5rVQm1LvkG27QMq9ph3t8fmn6r6SQ4oSbr5tz+J1kIawGzDxb6VYOvvWhobDTXfBeNv3b4aNm5XUinsCGqG2q/45m3+LoCOsddFceYhRx1Tsss9PLdPfJdErFMjYd3gddjiP0+XQjcRadZP6bwNLySvunFf20Czy6JqdEW2a96KxdYdOryBv1BjbuUq2yCHeh+6sk7fGmmPi50pe/1l5TyPe5oHW9oPnhPswLyf2TFDdCyYlhwBCstv5C1HwlW7xWoGT9XZt4qVj5WryLPLLD6h/5cMLEjWzgCeAIKNsLak92aBqBsHl4AJwl2N4jfvbSkBExGimv0nFvv09uDScQbjx+w4kPQjgjlW+g9ws9VEJvI2k8N6XxVu0uIwovgTFdunG24gBtaDi+y1YLQwZ8mwbip5fVlO3k0n0AEr/ETbtu8Vjkm+nNSiEb7X/3fMjBL5A8PdgG+/FnbexbFFExmEfetXAnisEKy5z44WVPpQZjSy/jzeGn4yDRsFGqhh87QPaDBWhlo37IFbe/C0xynS91d2tP/AJoJS0sVF6iwAAAAAElFTkSuQmCC");
}

#menu::after {
  display: block;
  content: '';
  padding-top: 80px;
}

#logo {
  position: fixed;
  bottom: 10px;
  right: 10px;
  background: rgba(255,255,255,.1);
  font-size: 11px;
  display: block;
  width: 20px;
  height: 20px;
  line-height: 20px;
  text-align: center;
  -webkit-border-radius: 20px;
  -moz-border-radius: 20px;
  -webkit-box-shadow: 0 0 3px rgba(0,0,0,.2);
  -moz-box-shadow: 0 0 3px rgba(0,0,0,.2);
  color: inherit;
}

#menu li a {
  display: block;
  color: white;
  padding: 0 35px 0 25px;
  -webkit-transition: background 300ms;
  -moz-transition: background 300ms;
}

#menu li {
  position: relative;
  list-style: none;
}

#menu a:hover,
#menu a.active {
  text-decoration: none;
  background: rgba(255,255,255,.1);
}

#menu li:hover .cov {
  opacity: 1;
}

#menu li .dirname {
  opacity: .60;
  padding-right: 2px;
}

#menu li .basename {
  opacity: 1;
}

#menu .cov {
  background: rgba(0,0,0,.4);
  position: absolute;
  top: 0;
  right: 8px;
  font-size: 9px;
  opacity: .6;
  text-align: left;
  width: 17px;
  -webkit-border-radius: 10px;
  -moz-border-radius: 10px;
  padding: 2px 3px;
  text-align: center;
}

#stats:nth-child(2n) {
  display: inline-block;
  margin-top: 15px;
  border: 1px solid #eee;
  padding: 10px;
  -webkit-box-shadow: inset 0 0 2px #eee;
  -moz-box-shadow: inset 0 0 2px #eee;
  -webkit-border-radius: 5px;
  -moz-border-radius: 5px;
}

#stats div {
  float: left;
  padding: 0 5px;
}

#stats::after {
  display: block;
  content: '';
  clear: both;
}

#stats .sloc::after {
  content: ' SLOC';
  color: #b6b6b6;
}

#stats .percentage::after {
  content: ' coverage';
  color: #b6b6b6;
}

#stats .hits,
#stats .misses {
  display: none;
}

.high {
  color: #00d4b4;
}
.medium {
  color: #e87d0d;
}
.low {
  color: #d4081a;
}
.terrible {
  color: #d4081a;
  font-weight: bold;
}

table {
  width: 80%;
  margin-top: 10px;
  border-collapse: collapse;
  border: 1px solid #cbcbcb;
  color: #363636;
  -webkit-border-radius: 3px;
  -moz-border-radius: 3px;
}

table thead {
  display: none;
}

table td.line,
table td.hits {
  width: 20px;
  background: #eaeaea;
  text-align: center;
  font-size: 11px;
  padding: 0 10px;
  color: #949494;
}

table td.hits {
  width: 10px;
  padding: 2px 5px;
  color: rgba(0,0,0,.2);
  background: #f0f0f0;
}

tr.miss td.line,
tr.miss td.hits {
  background: #e6c3c7;
}

tr.miss td {
  background: #f8d5d8;
}

td.source {
  padding-left: 15px;
  line-height: 15px;
  white-space: pre;
  font: 12px monaco, monospace;
}

code .comment { color: #ddd }
code .init { color: #2F6FAD }
code .string { color: #5890AD }
code .keyword { color: #8A6343 }
code .number { color: #2F6FAD }
</style></head><body><div id="coverage"><h1 id="overview">Coverage</h1><div id="menu"><li><a href="#overview">overview</a></li><li><span class="cov high">91</span><a href="#lib/background_task.js"><span class="dirname">lib/</span><span class="basename">background_task.js</span></a></li><li><span class="cov high">87</span><a href="#lib/blacklist.js"><span class="dirname">lib/</span><span class="basename">blacklist.js</span></a></li><li><span class="cov high">91</span><a href="#lib/messaging.js"><span class="dirname">lib/</span><span class="basename">messaging.js</span></a></li><li><span class="cov high">100</span><a href="#lib/task_limit.js"><span class="dirname">lib/</span><span class="basename">task_limit.js</span></a></li><a id="logo" href="http://visionmedia.github.com/mocha/">m</a></div><div id="stats" class="high"><div class="percentage">91%</div><div class="sloc">447</div><div class="hits">410</div><div class="misses">37</div></div><div id="files"><div class="file"><h2 id="lib/background_task.js">lib/background_task.js</h2><div id="stats" class="high"><div class="percentage">91%</div><div class="sloc">149</div><div class="hits">137</div><div class="misses">12</div></div><table id="source"><thead><tr><th>Line</th><th>Hits</th><th>Source</th></tr></thead><tbody><tr><td class="line">1</td><td class="hits"></td><td class="source">// Copyright 2012 Kinvey, Inc</td></tr><tr><td class="line">2</td><td class="hits"></td><td class="source">//</td></tr><tr><td class="line">3</td><td class="hits"></td><td class="source">//    Licensed under the Apache License, Version 2.0 (the &quot;License&quot;);</td></tr><tr><td class="line">4</td><td class="hits"></td><td class="source">//    you may not use this file except in compliance with the License.</td></tr><tr><td class="line">5</td><td class="hits"></td><td class="source">//    You may obtain a copy of the License at</td></tr><tr><td class="line">6</td><td class="hits"></td><td class="source">//</td></tr><tr><td class="line">7</td><td class="hits"></td><td class="source">//        http://www.apache.org/licenses/LICENSE-2.0</td></tr><tr><td class="line">8</td><td class="hits"></td><td class="source">//</td></tr><tr><td class="line">9</td><td class="hits"></td><td class="source">//    Unless required by applicable law or agreed to in writing, software</td></tr><tr><td class="line">10</td><td class="hits"></td><td class="source">//    distributed under the License is distributed on an &quot;AS IS&quot; BASIS,</td></tr><tr><td class="line">11</td><td class="hits"></td><td class="source">//    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</td></tr><tr><td class="line">12</td><td class="hits"></td><td class="source">//    See the License for the specific language governing permissions and</td></tr><tr><td class="line">13</td><td class="hits"></td><td class="source">//    limitations under the License.</td></tr><tr><td class="line">14</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">15</td><td class="hits">1</td><td class="source">&quot;use strict&quot;;</td></tr><tr><td class="line">16</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">17</td><td class="hits">1</td><td class="source">var redis = require(&quot;redis&quot;)</td></tr><tr><td class="line">18</td><td class="hits"></td><td class="source">  , EventEmitter = require('events').EventEmitter</td></tr><tr><td class="line">19</td><td class="hits"></td><td class="source">  , util = require('util')</td></tr><tr><td class="line">20</td><td class="hits"></td><td class="source">  , message = require('./messaging')</td></tr><tr><td class="line">21</td><td class="hits"></td><td class="source">  , task_limit = require('./task_limit')</td></tr><tr><td class="line">22</td><td class="hits"></td><td class="source">  , blacklist = require('./blacklist')</td></tr><tr><td class="line">23</td><td class="hits"></td><td class="source">  , wrapError;</td></tr><tr><td class="line">24</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">25</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">26</td><td class="hits"></td><td class="source">// We should handle this...</td></tr><tr class="hit"> <td class="line">27</td><td class="hits">1</td><td class="source">wrapError = function(emitter){</td></tr><tr class="hit"> <td class="line">28</td><td class="hits">127</td><td class="source">    return function(error){</td></tr><tr class="hit"> <td class="line">29</td><td class="hits">1</td><td class="source">        emitter.emit('error', error);</td></tr><tr><td class="line">30</td><td class="hits"></td><td class="source">    };</td></tr><tr><td class="line">31</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">32</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">33</td><td class="hits">1</td><td class="source">exports.connect = (function(){</td></tr><tr class="hit"> <td class="line">34</td><td class="hits">1</td><td class="source">    var callbacks = []</td></tr><tr><td class="line">35</td><td class="hits"></td><td class="source">      , makeTimeoutError</td></tr><tr><td class="line">36</td><td class="hits"></td><td class="source">      , BackgroundTask</td></tr><tr><td class="line">37</td><td class="hits"></td><td class="source">      , extractResponse;</td></tr><tr><td class="line">38</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">39</td><td class="hits">1</td><td class="source">    BackgroundTask = function(options){</td></tr><tr class="hit"> <td class="line">40</td><td class="hits">63</td><td class="source">        EventEmitter.call(this);</td></tr><tr><td class="line">41</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">42</td><td class="hits">63</td><td class="source">        if (!options){</td></tr><tr class="hit"> <td class="line">43</td><td class="hits">1</td><td class="source">            options = {};</td></tr><tr><td class="line">44</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">45</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">46</td><td class="hits">63</td><td class="source">        if (options.isWorker){</td></tr><tr class="hit"> <td class="line">47</td><td class="hits">31</td><td class="source">            options.isResponder = true;</td></tr><tr><td class="line">48</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">49</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">50</td><td class="hits">63</td><td class="source">        if (options.taskKey){</td></tr><tr class="hit"> <td class="line">51</td><td class="hits">32</td><td class="source">            this.taskKey = options.taskKey;</td></tr><tr class="hit"> <td class="line">52</td><td class="hits">32</td><td class="source">            if (!options.maxTasksPerKey){</td></tr><tr class="hit"> <td class="line">53</td><td class="hits">4</td><td class="source">                this.maxTasksPerKey = options.maxTasksPerKey = 5;</td></tr><tr><td class="line">54</td><td class="hits"></td><td class="source">            }</td></tr><tr><td class="line">55</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">56</td><td class="hits">32</td><td class="source">            this.taskLimit = new task_limit.TaskLimit(options);</td></tr><tr class="hit"> <td class="line">57</td><td class="hits">32</td><td class="source">            this.taskLimit.on('error', wrapError(this));</td></tr><tr><td class="line">58</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">59</td><td class="hits">32</td><td class="source">            this.blacklist = new blacklist.Blacklist(options);</td></tr><tr class="hit"> <td class="line">60</td><td class="hits">32</td><td class="source">            this.blacklist.on('error', wrapError(this));</td></tr><tr><td class="line">61</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">62</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">63</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">64</td><td class="hits">63</td><td class="source">        this.msgBus = new message.connect(options);</td></tr><tr class="hit"> <td class="line">65</td><td class="hits">63</td><td class="source">        this.timeout = 5000; // 5 second defualt timeout</td></tr><tr><td class="line">66</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">67</td><td class="hits">63</td><td class="source">        this.msgBus.on('error', wrapError(this));</td></tr><tr><td class="line">68</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">69</td><td class="hits">63</td><td class="source">        if (options.task){</td></tr><tr class="hit"> <td class="line">70</td><td class="hits">1</td><td class="source">            options.broadcast = options.task + &quot;Broadcast&quot;;</td></tr><tr class="hit"> <td class="line">71</td><td class="hits">1</td><td class="source">            options.dataHash = options.task + &quot;Table&quot;;</td></tr><tr class="hit"> <td class="line">72</td><td class="hits">1</td><td class="source">            options.outputHash = options.task + &quot;Hash&quot;;</td></tr><tr><td class="line">73</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">74</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">75</td><td class="hits">63</td><td class="source">        if (options &amp;&amp; options.timeout){</td></tr><tr class="hit"> <td class="line">76</td><td class="hits">2</td><td class="source">            this.timeout = options.timeout;</td></tr><tr><td class="line">77</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">78</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">79</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">80</td><td class="hits">63</td><td class="source">        if (options.isWorker){</td></tr><tr class="hit"> <td class="line">81</td><td class="hits">31</td><td class="source">            var that = this;</td></tr><tr class="hit"> <td class="line">82</td><td class="hits">31</td><td class="source">            this.msgBus.on('data_available', function(id){</td></tr><tr class="hit"> <td class="line">83</td><td class="hits">16</td><td class="source">                that.emit('TASK_AVAILABLE', id);</td></tr><tr><td class="line">84</td><td class="hits"></td><td class="source">            });</td></tr><tr><td class="line">85</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">86</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">87</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">88</td><td class="hits"></td><td class="source">        // Simple way to ensure we're not shut down</td></tr><tr class="hit"> <td class="line">89</td><td class="hits">63</td><td class="source">        this.isAvailable = true;</td></tr><tr><td class="line">90</td><td class="hits"></td><td class="source">    };</td></tr><tr><td class="line">91</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">92</td><td class="hits"></td><td class="source">    // Inherit EventEmitter's methods</td></tr><tr class="hit"> <td class="line">93</td><td class="hits">1</td><td class="source">    util.inherits(BackgroundTask, EventEmitter);</td></tr><tr><td class="line">94</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">95</td><td class="hits">1</td><td class="source">    BackgroundTask.prototype.end = function(){</td></tr><tr class="hit"> <td class="line">96</td><td class="hits">63</td><td class="source">        if (!this.isAvailable) return; // Nothing to do</td></tr><tr><td class="line">97</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">98</td><td class="hits">63</td><td class="source">        this.isAvailable = false;</td></tr><tr><td class="line">99</td><td class="hits"></td><td class="source">        // Hard end, don't worry about shutting down</td></tr><tr><td class="line">100</td><td class="hits"></td><td class="source">        // gracefully here...</td></tr><tr class="hit"> <td class="line">101</td><td class="hits">95</td><td class="source">        if (this.blacklist) this.blacklist.shutdown();</td></tr><tr class="hit"> <td class="line">102</td><td class="hits">95</td><td class="source">        if (this.taskLimit) this.taskLimit.shutdown();</td></tr><tr class="hit"> <td class="line">103</td><td class="hits">63</td><td class="source">        this.msgBus.shutdown();</td></tr><tr class="hit"> <td class="line">104</td><td class="hits">63</td><td class="source">        this.removeAllListeners();</td></tr><tr><td class="line">105</td><td class="hits"></td><td class="source">    };</td></tr><tr><td class="line">106</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">107</td><td class="hits">1</td><td class="source">    BackgroundTask.prototype.acceptTask = function(id, callback){</td></tr><tr class="hit"> <td class="line">108</td><td class="hits">18</td><td class="source">        var newCallback;</td></tr><tr><td class="line">109</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">110</td><td class="hits">18</td><td class="source">        if (!this.isAvailable){</td></tr><tr class="miss"> <td class="line">111</td><td class="hits">0</td><td class="source">            callback(new Error(&quot;Attempt to use invalid BackgroundTask&quot;));</td></tr><tr class="miss"> <td class="line">112</td><td class="hits">0</td><td class="source">            return;</td></tr><tr><td class="line">113</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">114</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">115</td><td class="hits">18</td><td class="source">        if (!id || id.length === 0){</td></tr><tr class="hit"> <td class="line">116</td><td class="hits">3</td><td class="source">            throw new Error('Missing Task ID.');</td></tr><tr><td class="line">117</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">118</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">119</td><td class="hits">15</td><td class="source">        if (!callback || callback.length &lt; 1){</td></tr><tr class="hit"> <td class="line">120</td><td class="hits">2</td><td class="source">            throw new Error('Invalid callback specified');</td></tr><tr><td class="line">121</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">122</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">123</td><td class="hits">13</td><td class="source">        newCallback = function(reply){</td></tr><tr class="hit"> <td class="line">124</td><td class="hits">13</td><td class="source">          if (reply instanceof Error){</td></tr><tr class="hit"> <td class="line">125</td><td class="hits">1</td><td class="source">              if (reply.message === &quot;DB doesn't recognize message&quot;){</td></tr><tr class="hit"> <td class="line">126</td><td class="hits">1</td><td class="source">                  reply = new Error('Task not in database, do not accept');</td></tr><tr><td class="line">127</td><td class="hits"></td><td class="source">              }</td></tr><tr><td class="line">128</td><td class="hits"></td><td class="source">          }</td></tr><tr><td class="line">129</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">130</td><td class="hits">13</td><td class="source">          if (reply.taskDetails){</td></tr><tr class="hit"> <td class="line">131</td><td class="hits">12</td><td class="source">            callback(reply.taskDetails);</td></tr><tr><td class="line">132</td><td class="hits"></td><td class="source">          } else {</td></tr><tr class="hit"> <td class="line">133</td><td class="hits">1</td><td class="source">            callback(reply);</td></tr><tr><td class="line">134</td><td class="hits"></td><td class="source">          }</td></tr><tr><td class="line">135</td><td class="hits"></td><td class="source">        };</td></tr><tr class="hit"> <td class="line">136</td><td class="hits">13</td><td class="source">        this.msgBus.acceptMessage(id, newCallback);</td></tr><tr><td class="line">137</td><td class="hits"></td><td class="source">    };</td></tr><tr><td class="line">138</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">139</td><td class="hits">1</td><td class="source">    extractResponse = function(r){</td></tr><tr class="hit"> <td class="line">140</td><td class="hits">15</td><td class="source">        var response, id, respondedErr, o;</td></tr><tr><td class="line">141</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">142</td><td class="hits">15</td><td class="source">        if (!r.taskId &amp;&amp; !r.taskDetails){</td></tr><tr class="miss"> <td class="line">143</td><td class="hits">0</td><td class="source">            throw new Error(&quot;Incomplete task response.&quot;);</td></tr><tr><td class="line">144</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">145</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">146</td><td class="hits">15</td><td class="source">        id = r.taskId;</td></tr><tr class="hit"> <td class="line">147</td><td class="hits">15</td><td class="source">        response = r.taskDetails;</td></tr><tr><td class="line">148</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">149</td><td class="hits">15</td><td class="source">        if (response.isError){</td></tr><tr class="hit"> <td class="line">150</td><td class="hits">1</td><td class="source">            respondedErr = new Error(response.message);</td></tr><tr class="hit"> <td class="line">151</td><td class="hits">1</td><td class="source">            for (o in response){</td></tr><tr class="hit"> <td class="line">152</td><td class="hits">3</td><td class="source">                if (response.hasOwnProperty(o) &amp;&amp;</td></tr><tr><td class="line">153</td><td class="hits"></td><td class="source">                    o !== 'isError' &amp;&amp;</td></tr><tr><td class="line">154</td><td class="hits"></td><td class="source">                    o !== 'message'){</td></tr><tr class="hit"> <td class="line">155</td><td class="hits">1</td><td class="source">                    respondedErr[o] = response[o];</td></tr><tr><td class="line">156</td><td class="hits"></td><td class="source">                }</td></tr><tr><td class="line">157</td><td class="hits"></td><td class="source">            }</td></tr><tr class="hit"> <td class="line">158</td><td class="hits">1</td><td class="source">            response = respondedErr;</td></tr><tr><td class="line">159</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">160</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">161</td><td class="hits">15</td><td class="source">        return {id: id, details: response};</td></tr><tr><td class="line">162</td><td class="hits"></td><td class="source">    };</td></tr><tr><td class="line">163</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">164</td><td class="hits">1</td><td class="source">    BackgroundTask.prototype.addTask = function(msg, callback){</td></tr><tr class="hit"> <td class="line">165</td><td class="hits">20</td><td class="source">        var that = this</td></tr><tr><td class="line">166</td><td class="hits"></td><td class="source">          , id = message.makeId()</td></tr><tr><td class="line">167</td><td class="hits"></td><td class="source">          , cb, timeoutId, timedoutCb, msgToSend, tmpErr, startTheTask;</td></tr><tr><td class="line">168</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">169</td><td class="hits">20</td><td class="source">        if (!this.isAvailable){</td></tr><tr class="hit"> <td class="line">170</td><td class="hits">1</td><td class="source">            callback(id, new Error(&quot;Attempt to use invalid BackgroundTask&quot;));</td></tr><tr class="hit"> <td class="line">171</td><td class="hits">1</td><td class="source">            return;</td></tr><tr><td class="line">172</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">173</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">174</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">175</td><td class="hits">19</td><td class="source">        startTheTask = function(){</td></tr><tr class="hit"> <td class="line">176</td><td class="hits">16</td><td class="source">            that.taskLimit.startTask(msg, function(tasks){</td></tr><tr class="hit"> <td class="line">177</td><td class="hits">16</td><td class="source">                var err, responseCb;</td></tr><tr class="hit"> <td class="line">178</td><td class="hits">16</td><td class="source">                if (tasks instanceof Error){</td></tr><tr class="hit"> <td class="line">179</td><td class="hits">1</td><td class="source">                    err = new Error('Too many tasks');</td></tr><tr class="hit"> <td class="line">180</td><td class="hits">1</td><td class="source">                    that.emit('TASK_ERROR', err);</td></tr><tr class="hit"> <td class="line">181</td><td class="hits">1</td><td class="source">                    callback(id, err);</td></tr><tr><td class="line">182</td><td class="hits"></td><td class="source">                }</td></tr><tr><td class="line">183</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">184</td><td class="hits">16</td><td class="source">                callbacks[id] = callback;</td></tr><tr><td class="line">185</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">186</td><td class="hits">16</td><td class="source">                responseCb =  function(resp){</td></tr><tr class="hit"> <td class="line">187</td><td class="hits">7</td><td class="source">                    var uniqueIndex = id // Make this callback unique</td></tr><tr><td class="line">188</td><td class="hits"></td><td class="source">                      , rply = extractResponse(resp);</td></tr><tr><td class="line">189</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">190</td><td class="hits">7</td><td class="source">                    that.emit('TASK_DONE', rply.id, rply.details);</td></tr><tr><td class="line">191</td><td class="hits"></td><td class="source">                };</td></tr><tr><td class="line">192</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">193</td><td class="hits">16</td><td class="source">                cb = function(reply){</td></tr><tr class="hit"> <td class="line">194</td><td class="hits">8</td><td class="source">                    var origCallback</td></tr><tr><td class="line">195</td><td class="hits"></td><td class="source">                    , tid = id</td></tr><tr><td class="line">196</td><td class="hits"></td><td class="source">                    , details = reply</td></tr><tr><td class="line">197</td><td class="hits"></td><td class="source">                    , rply, fallback = false;</td></tr><tr><td class="line">198</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">199</td><td class="hits">8</td><td class="source">                    try {</td></tr><tr class="hit"> <td class="line">200</td><td class="hits">8</td><td class="source">                        rply = extractResponse(reply);</td></tr><tr class="hit"> <td class="line">201</td><td class="hits">8</td><td class="source">                        details = rply.details;</td></tr><tr class="hit"> <td class="line">202</td><td class="hits">8</td><td class="source">                        tid = rply.id;</td></tr><tr><td class="line">203</td><td class="hits"></td><td class="source">                    } catch (e) {</td></tr><tr><td class="line">204</td><td class="hits"></td><td class="source">                        // The system had an error</td></tr><tr class="miss"> <td class="line">205</td><td class="hits">0</td><td class="source">                        that.emit('TASK_ERROR', e);</td></tr><tr><td class="line">206</td><td class="hits"></td><td class="source">                    }</td></tr><tr class="hit"> <td class="line">207</td><td class="hits">8</td><td class="source">                    origCallback = callbacks[tid];</td></tr><tr><td class="line">208</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">209</td><td class="hits">8</td><td class="source">                    that.taskLimit.stopTask(msg);</td></tr><tr class="hit"> <td class="line">210</td><td class="hits">8</td><td class="source">                    clearTimeout(timeoutId);</td></tr><tr class="hit"> <td class="line">211</td><td class="hits">8</td><td class="source">                    origCallback(tid, details);</td></tr><tr class="hit"> <td class="line">212</td><td class="hits">8</td><td class="source">                    delete callbacks[tid];</td></tr><tr><td class="line">213</td><td class="hits"></td><td class="source">                };</td></tr><tr><td class="line">214</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">215</td><td class="hits">16</td><td class="source">                timedoutCb = function(){</td></tr><tr class="hit"> <td class="line">216</td><td class="hits">5</td><td class="source">                    var origCallback = callbacks[id];</td></tr><tr><td class="line">217</td><td class="hits"></td><td class="source">                    // replace the &quot;orig&quot; callback with an empty function</td></tr><tr><td class="line">218</td><td class="hits"></td><td class="source">                    // in case the request still completes in the future and</td></tr><tr><td class="line">219</td><td class="hits"></td><td class="source">                    // tries to call our callback.</td></tr><tr class="hit"> <td class="line">220</td><td class="hits">5</td><td class="source">                    callbacks[id] = function(reply){};</td></tr><tr><td class="line">221</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">222</td><td class="hits"></td><td class="source">                    // Return an error</td></tr><tr class="hit"> <td class="line">223</td><td class="hits">5</td><td class="source">                    that.taskLimit.stopTask(msg);</td></tr><tr class="hit"> <td class="line">224</td><td class="hits">5</td><td class="source">                    origCallback(id, makeTimeoutError());</td></tr><tr class="hit"> <td class="line">225</td><td class="hits">5</td><td class="source">                    that.msgBus.removeListener('responseReady', responseCb);</td></tr><tr><td class="line">226</td><td class="hits"></td><td class="source">                };</td></tr><tr><td class="line">227</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">228</td><td class="hits">16</td><td class="source">                msgToSend = {</td></tr><tr><td class="line">229</td><td class="hits"></td><td class="source">                    taskId: id,</td></tr><tr><td class="line">230</td><td class="hits"></td><td class="source">                    taskDetails: msg</td></tr><tr><td class="line">231</td><td class="hits"></td><td class="source">                };</td></tr><tr><td class="line">232</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">233</td><td class="hits">16</td><td class="source">                timeoutId = setTimeout(timedoutCb, that.timeout);</td></tr><tr class="hit"> <td class="line">234</td><td class="hits">16</td><td class="source">                that.msgBus.sendMessage(id, msgToSend, cb);</td></tr><tr class="hit"> <td class="line">235</td><td class="hits">16</td><td class="source">                that.msgBus.once('responseReady',responseCb);</td></tr><tr><td class="line">236</td><td class="hits"></td><td class="source">            });</td></tr><tr><td class="line">237</td><td class="hits"></td><td class="source">        };</td></tr><tr><td class="line">238</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">239</td><td class="hits">19</td><td class="source">        if (that.taskKey &amp;&amp; msg[that.taskKey]){</td></tr><tr class="hit"> <td class="line">240</td><td class="hits">18</td><td class="source">            that.blacklist.blacklistStatus(msg, function(isBlacklisted, timeLeft, reason){</td></tr><tr class="hit"> <td class="line">241</td><td class="hits">18</td><td class="source">                var tmpErr;</td></tr><tr class="hit"> <td class="line">242</td><td class="hits">18</td><td class="source">                if (isBlacklisted){</td></tr><tr class="hit"> <td class="line">243</td><td class="hits">2</td><td class="source">                    tmpErr = new Error('Blacklisted');</td></tr><tr class="hit"> <td class="line">244</td><td class="hits">2</td><td class="source">                    tmpErr.debugMessage = &quot;Blocked, reason: &quot; + reason + &quot;, remaining time: &quot; + timeLeft;</td></tr><tr class="hit"> <td class="line">245</td><td class="hits">2</td><td class="source">                    that.emit('TASK_ERROR', tmpErr);</td></tr><tr class="hit"> <td class="line">246</td><td class="hits">2</td><td class="source">                    callback(id, tmpErr);</td></tr><tr><td class="line">247</td><td class="hits"></td><td class="source">                } else {</td></tr><tr class="hit"> <td class="line">248</td><td class="hits">16</td><td class="source">                    startTheTask();</td></tr><tr><td class="line">249</td><td class="hits"></td><td class="source">                }</td></tr><tr><td class="line">250</td><td class="hits"></td><td class="source">            });</td></tr><tr><td class="line">251</td><td class="hits"></td><td class="source">        } else {</td></tr><tr class="hit"> <td class="line">252</td><td class="hits">1</td><td class="source">            tmpErr = new Error('Missing taskKey');</td></tr><tr class="hit"> <td class="line">253</td><td class="hits">1</td><td class="source">            that.emit('TASK_ERROR', tmpErr);</td></tr><tr class="hit"> <td class="line">254</td><td class="hits">1</td><td class="source">            callback(id, tmpErr);</td></tr><tr><td class="line">255</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">256</td><td class="hits"></td><td class="source">    };</td></tr><tr><td class="line">257</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">258</td><td class="hits">1</td><td class="source">    BackgroundTask.prototype.completeTask = function(taskId, status, msg){</td></tr><tr class="hit"> <td class="line">259</td><td class="hits">23</td><td class="source">        var that = this</td></tr><tr><td class="line">260</td><td class="hits"></td><td class="source">          , msgToSend, serializableError, o;</td></tr><tr><td class="line">261</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">262</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">263</td><td class="hits">23</td><td class="source">        if (!this.isAvailable){</td></tr><tr class="miss"> <td class="line">264</td><td class="hits">0</td><td class="source">            throw new Error(&quot;Attempt to use invalid BackgroundTask&quot;);</td></tr><tr><td class="line">265</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">266</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">267</td><td class="hits"></td><td class="source">        // We can't send Error's via JSON...</td></tr><tr class="hit"> <td class="line">268</td><td class="hits">23</td><td class="source">        if (msg instanceof Error){</td></tr><tr class="hit"> <td class="line">269</td><td class="hits">1</td><td class="source">            serializableError = {</td></tr><tr><td class="line">270</td><td class="hits"></td><td class="source">                isError: true,</td></tr><tr><td class="line">271</td><td class="hits"></td><td class="source">                message: msg.message</td></tr><tr><td class="line">272</td><td class="hits"></td><td class="source">            };</td></tr><tr><td class="line">273</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">274</td><td class="hits">1</td><td class="source">            for (o in msg){</td></tr><tr class="hit"> <td class="line">275</td><td class="hits">1</td><td class="source">                if (msg.hasOwnProperty(o)){</td></tr><tr class="hit"> <td class="line">276</td><td class="hits">1</td><td class="source">                    serializableError[o] = msg[o];</td></tr><tr><td class="line">277</td><td class="hits"></td><td class="source">                }</td></tr><tr><td class="line">278</td><td class="hits"></td><td class="source">            }</td></tr><tr><td class="line">279</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">280</td><td class="hits">1</td><td class="source">            msg = serializableError;</td></tr><tr><td class="line">281</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">282</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">283</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">284</td><td class="hits">23</td><td class="source">        msgToSend = {</td></tr><tr><td class="line">285</td><td class="hits"></td><td class="source">            taskId: taskId,</td></tr><tr><td class="line">286</td><td class="hits"></td><td class="source">            taskDetails: msg</td></tr><tr><td class="line">287</td><td class="hits"></td><td class="source">        };</td></tr><tr><td class="line">288</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">289</td><td class="hits">23</td><td class="source">        if (!msg){</td></tr><tr class="hit"> <td class="line">290</td><td class="hits">1</td><td class="source">          throw new Error('Missing msgId, status or msg.');</td></tr><tr><td class="line">291</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">292</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">293</td><td class="hits">22</td><td class="source">        that.msgBus.sendResponse(taskId, status, msgToSend);</td></tr><tr><td class="line">294</td><td class="hits"></td><td class="source">    };</td></tr><tr><td class="line">295</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">296</td><td class="hits">1</td><td class="source">    BackgroundTask.prototype.reportBadTask = function(taskKey, reason, callback){</td></tr><tr class="miss"> <td class="line">297</td><td class="hits">0</td><td class="source">        var reasonToSend;</td></tr><tr><td class="line">298</td><td class="hits"></td><td class="source"> </td></tr><tr class="miss"> <td class="line">299</td><td class="hits">0</td><td class="source">        if (!this.isAvailable){</td></tr><tr class="miss"> <td class="line">300</td><td class="hits">0</td><td class="source">            callback(&quot;ERR&quot;, &quot;Attempt to use invalid BackgroundTask&quot;);</td></tr><tr class="miss"> <td class="line">301</td><td class="hits">0</td><td class="source">            return;</td></tr><tr><td class="line">302</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">303</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">304</td><td class="hits"></td><td class="source"> </td></tr><tr class="miss"> <td class="line">305</td><td class="hits">0</td><td class="source">        if (reason instanceof Error){</td></tr><tr class="miss"> <td class="line">306</td><td class="hits">0</td><td class="source">            reasonToSend = reason.message;</td></tr><tr><td class="line">307</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">308</td><td class="hits"></td><td class="source"> </td></tr><tr class="miss"> <td class="line">309</td><td class="hits">0</td><td class="source">        this.blacklist.addFailure(taskKey, reason, callback);</td></tr><tr><td class="line">310</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">311</td><td class="hits"></td><td class="source">    };</td></tr><tr><td class="line">312</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">313</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">314</td><td class="hits">1</td><td class="source">    makeTimeoutError = function(){</td></tr><tr class="hit"> <td class="line">315</td><td class="hits">5</td><td class="source">        return new Error('Task timed out');</td></tr><tr><td class="line">316</td><td class="hits"></td><td class="source">    };</td></tr><tr><td class="line">317</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">318</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">319</td><td class="hits">1</td><td class="source">    return function(options){</td></tr><tr class="hit"> <td class="line">320</td><td class="hits">63</td><td class="source">        return new BackgroundTask(options);</td></tr><tr><td class="line">321</td><td class="hits"></td><td class="source">    };</td></tr><tr><td class="line">322</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">323</td><td class="hits"></td><td class="source">}());</td></tr></tbody></table></div><div class="file"><h2 id="lib/blacklist.js">lib/blacklist.js</h2><div id="stats" class="high"><div class="percentage">87%</div><div class="sloc">73</div><div class="hits">64</div><div class="misses">9</div></div><table id="source"><thead><tr><th>Line</th><th>Hits</th><th>Source</th></tr></thead><tbody><tr><td class="line">1</td><td class="hits"></td><td class="source">// Copyright 2012 Kinvey, Inc</td></tr><tr><td class="line">2</td><td class="hits"></td><td class="source">//</td></tr><tr><td class="line">3</td><td class="hits"></td><td class="source">//    Licensed under the Apache License, Version 2.0 (the &quot;License&quot;);</td></tr><tr><td class="line">4</td><td class="hits"></td><td class="source">//    you may not use this file except in compliance with the License.</td></tr><tr><td class="line">5</td><td class="hits"></td><td class="source">//    You may obtain a copy of the License at</td></tr><tr><td class="line">6</td><td class="hits"></td><td class="source">//</td></tr><tr><td class="line">7</td><td class="hits"></td><td class="source">//        http://www.apache.org/licenses/LICENSE-2.0</td></tr><tr><td class="line">8</td><td class="hits"></td><td class="source">//</td></tr><tr><td class="line">9</td><td class="hits"></td><td class="source">//    Unless required by applicable law or agreed to in writing, software</td></tr><tr><td class="line">10</td><td class="hits"></td><td class="source">//    distributed under the License is distributed on an &quot;AS IS&quot; BASIS,</td></tr><tr><td class="line">11</td><td class="hits"></td><td class="source">//    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</td></tr><tr><td class="line">12</td><td class="hits"></td><td class="source">//    See the License for the specific language governing permissions and</td></tr><tr><td class="line">13</td><td class="hits"></td><td class="source">//    limitations under the License.</td></tr><tr class="hit"> <td class="line">14</td><td class="hits">1</td><td class="source">&quot;use strict&quot;;</td></tr><tr><td class="line">15</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">16</td><td class="hits">1</td><td class="source">var redis = require(&quot;redis&quot;)</td></tr><tr><td class="line">17</td><td class="hits"></td><td class="source">  , util = require('util')</td></tr><tr><td class="line">18</td><td class="hits"></td><td class="source">  , EventEmitter = require('events').EventEmitter</td></tr><tr><td class="line">19</td><td class="hits"></td><td class="source">  , wrapError;</td></tr><tr><td class="line">20</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">21</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">22</td><td class="hits">1</td><td class="source">wrapError = function(emitter){</td></tr><tr class="hit"> <td class="line">23</td><td class="hits">51</td><td class="source">    return function(error){</td></tr><tr class="hit"> <td class="line">24</td><td class="hits">1</td><td class="source">        emitter.emit('error', error);</td></tr><tr><td class="line">25</td><td class="hits"></td><td class="source">    };</td></tr><tr><td class="line">26</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">27</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">28</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">29</td><td class="hits">1</td><td class="source">var Blacklist = exports.Blacklist = function(options){</td></tr><tr class="hit"> <td class="line">30</td><td class="hits">51</td><td class="source">    EventEmitter.call(this);</td></tr><tr><td class="line">31</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">32</td><td class="hits">51</td><td class="source">    if (!options){</td></tr><tr class="miss"> <td class="line">33</td><td class="hits">0</td><td class="source">        throw new Error(&quot;I need a task key!&quot;);</td></tr><tr><td class="line">34</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">35</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">36</td><td class="hits">52</td><td class="source">    if (options.host){ this.redisHost = options.host; }</td></tr><tr class="hit"> <td class="line">37</td><td class="hits">52</td><td class="source">    if (options.port){ this.redisPort = options.port; }</td></tr><tr class="hit"> <td class="line">38</td><td class="hits">52</td><td class="source">    if (options.password){ this.redisPassword = options.password; }</td></tr><tr><td class="line">39</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">40</td><td class="hits">51</td><td class="source">    this.taskKey = options.taskKey;</td></tr><tr><td class="line">41</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">42</td><td class="hits">51</td><td class="source">    this.failureInterval = options.failureInterval || 1;</td></tr><tr class="hit"> <td class="line">43</td><td class="hits">51</td><td class="source">    this.blacklistThreshold = options.blacklistThreshold || 10;</td></tr><tr class="hit"> <td class="line">44</td><td class="hits">51</td><td class="source">    this.globalBlacklistTimeout = options.globalBlacklistTimeout || 3600;</td></tr><tr><td class="line">45</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">46</td><td class="hits">51</td><td class="source">    this.logBlacklist = options.logBlacklist || false; // NB: This won't work if you want the default to be true</td></tr><tr><td class="line">47</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">48</td><td class="hits">51</td><td class="source">    this.redisKeyPrefix = &quot;blacklist:&quot;;</td></tr><tr class="hit"> <td class="line">49</td><td class="hits">51</td><td class="source">    this.globalBlacklistKeyPrefix = this.redisKeyPrefix + &quot;globalBlacklist:&quot;;</td></tr><tr class="hit"> <td class="line">50</td><td class="hits">51</td><td class="source">    this.blacklistLogKeyPrefix = this.redisKeyPrefix + &quot;logs:&quot;</td></tr><tr><td class="line">51</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">52</td><td class="hits">51</td><td class="source">    this.blacklistClient = redis.createClient(this.redisPort, this.redisHost);</td></tr><tr><td class="line">53</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">54</td><td class="hits">51</td><td class="source">    this.blacklistClient.on('error', wrapError(this));</td></tr><tr><td class="line">55</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">56</td><td class="hits">51</td><td class="source">    if (options.password){</td></tr><tr class="hit"> <td class="line">57</td><td class="hits">1</td><td class="source">        this.blacklistClient.auth(options.password);</td></tr><tr><td class="line">58</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">59</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">60</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">61</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">62</td><td class="hits"></td><td class="source">// Inherit EventEmitter's methods</td></tr><tr class="hit"> <td class="line">63</td><td class="hits">1</td><td class="source">util.inherits(Blacklist, EventEmitter);</td></tr><tr><td class="line">64</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">65</td><td class="hits">1</td><td class="source">Blacklist.prototype.blacklistStatus = function(task, callback){</td></tr><tr class="hit"> <td class="line">66</td><td class="hits">25</td><td class="source">    var taskKey = task &amp;&amp; task[this.taskKey]</td></tr><tr><td class="line">67</td><td class="hits"></td><td class="source">      , redisKey</td></tr><tr><td class="line">68</td><td class="hits"></td><td class="source">      , that = this;</td></tr><tr><td class="line">69</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">70</td><td class="hits">25</td><td class="source">    if (!callback){</td></tr><tr class="miss"> <td class="line">71</td><td class="hits">0</td><td class="source">        callback = function(){};</td></tr><tr><td class="line">72</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">73</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">74</td><td class="hits">25</td><td class="source">    if (!taskKey){</td></tr><tr class="miss"> <td class="line">75</td><td class="hits">0</td><td class="source">        callback(false, &quot;No task key, can't check blacklist.&quot;);</td></tr><tr><td class="line">76</td><td class="hits"></td><td class="source">    } else {</td></tr><tr class="hit"> <td class="line">77</td><td class="hits">25</td><td class="source">        redisKey = that.globalBlacklistKeyPrefix + taskKey;</td></tr><tr class="hit"> <td class="line">78</td><td class="hits">25</td><td class="source">        that.blacklistClient.get(redisKey, function(error, reply){</td></tr><tr class="hit"> <td class="line">79</td><td class="hits">25</td><td class="source">            if (reply){</td></tr><tr><td class="line">80</td><td class="hits"></td><td class="source">                // We're blacklisted</td></tr><tr class="hit"> <td class="line">81</td><td class="hits">7</td><td class="source">                that.blacklistClient.ttl(redisKey, function(error, timeRemaining){</td></tr><tr class="hit"> <td class="line">82</td><td class="hits">7</td><td class="source">                    if (timeRemaining){</td></tr><tr class="hit"> <td class="line">83</td><td class="hits">7</td><td class="source">                        callback(true, timeRemaining, reply);</td></tr><tr><td class="line">84</td><td class="hits"></td><td class="source">                    } else {</td></tr><tr class="miss"> <td class="line">85</td><td class="hits">0</td><td class="source">                        callback(true, -1, reply);</td></tr><tr><td class="line">86</td><td class="hits"></td><td class="source">                    }</td></tr><tr><td class="line">87</td><td class="hits"></td><td class="source">                });</td></tr><tr><td class="line">88</td><td class="hits"></td><td class="source">            } else {</td></tr><tr class="hit"> <td class="line">89</td><td class="hits">18</td><td class="source">                callback(false, -1, &quot;&quot;);</td></tr><tr><td class="line">90</td><td class="hits"></td><td class="source">            }</td></tr><tr><td class="line">91</td><td class="hits"></td><td class="source">        });</td></tr><tr><td class="line">92</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">93</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">94</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">95</td><td class="hits">1</td><td class="source">Blacklist.prototype.addFailure = function(taskKey, reason, callback){</td></tr><tr class="hit"> <td class="line">96</td><td class="hits">63</td><td class="source">    var errKey, countKey, that = this;</td></tr><tr><td class="line">97</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">98</td><td class="hits">63</td><td class="source">    if (!callback){</td></tr><tr class="miss"> <td class="line">99</td><td class="hits">0</td><td class="source">        callback = function(){};</td></tr><tr><td class="line">100</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">101</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">102</td><td class="hits">63</td><td class="source">    if (!reason){</td></tr><tr class="hit"> <td class="line">103</td><td class="hits">1</td><td class="source">        callback(new Error(&quot;Must supply a reason for the failure&quot;));</td></tr><tr class="hit"> <td class="line">104</td><td class="hits">1</td><td class="source">        return;</td></tr><tr><td class="line">105</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">106</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">107</td><td class="hits">62</td><td class="source">    if (!taskKey){</td></tr><tr class="miss"> <td class="line">108</td><td class="hits">0</td><td class="source">        callback(new Error(&quot;Invalid task, not running.&quot;));</td></tr><tr><td class="line">109</td><td class="hits"></td><td class="source">    } else {</td></tr><tr class="hit"> <td class="line">110</td><td class="hits">62</td><td class="source">        countKey = that.redisKeyPrefix + taskKey + &quot;:count&quot;;</td></tr><tr><td class="line">111</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">112</td><td class="hits">62</td><td class="source">        that.blacklistClient.get(countKey, function(error, reply){</td></tr><tr class="hit"> <td class="line">113</td><td class="hits">62</td><td class="source">            var blacklistKey;</td></tr><tr><td class="line">114</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">115</td><td class="hits"></td><td class="source">            // Count not in redis</td></tr><tr class="hit"> <td class="line">116</td><td class="hits">62</td><td class="source">            if (!reply){</td></tr><tr class="hit"> <td class="line">117</td><td class="hits">14</td><td class="source">                that.blacklistClient.setex(countKey, that.failureInterval, &quot;1&quot;, function(e, r){</td></tr><tr class="hit"> <td class="line">118</td><td class="hits">14</td><td class="source">                    if (!error){</td></tr><tr class="hit"> <td class="line">119</td><td class="hits">14</td><td class="source">                        callback(&quot;OK&quot;);</td></tr><tr><td class="line">120</td><td class="hits"></td><td class="source">                    } else {</td></tr><tr class="miss"> <td class="line">121</td><td class="hits">0</td><td class="source">                        callback(error);</td></tr><tr><td class="line">122</td><td class="hits"></td><td class="source">                    }</td></tr><tr><td class="line">123</td><td class="hits"></td><td class="source">                });</td></tr><tr><td class="line">124</td><td class="hits"></td><td class="source">            } else {</td></tr><tr class="hit"> <td class="line">125</td><td class="hits">48</td><td class="source">                if (reply &gt;= that.blacklistThreshold){</td></tr><tr><td class="line">126</td><td class="hits"></td><td class="source">                    // Blacklist</td></tr><tr class="hit"> <td class="line">127</td><td class="hits">10</td><td class="source">                    blacklistKey = that.globalBlacklistKeyPrefix + taskKey;</td></tr><tr class="hit"> <td class="line">128</td><td class="hits">10</td><td class="source">                    that.blacklistClient.setex(blacklistKey, that.globalBlacklistTimeout, reason, function(e, r){</td></tr><tr class="hit"> <td class="line">129</td><td class="hits">10</td><td class="source">                        var logKey, d;</td></tr><tr><td class="line">130</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">131</td><td class="hits">10</td><td class="source">                        if (!error){</td></tr><tr class="hit"> <td class="line">132</td><td class="hits">10</td><td class="source">                            if (that.logBlacklist){</td></tr><tr class="hit"> <td class="line">133</td><td class="hits">5</td><td class="source">                                d = new Date();</td></tr><tr class="hit"> <td class="line">134</td><td class="hits">5</td><td class="source">                                logKey = that.blacklistLogKeyPrefix + taskKey;</td></tr><tr><td class="line">135</td><td class="hits"></td><td class="source">                                // Fire and forget</td></tr><tr class="hit"> <td class="line">136</td><td class="hits">5</td><td class="source">                                that.blacklistClient.rpush(logKey, d + &quot;|&quot; + reason);</td></tr><tr><td class="line">137</td><td class="hits"></td><td class="source">                            }</td></tr><tr class="hit"> <td class="line">138</td><td class="hits">10</td><td class="source">                            callback(&quot;Blacklisted&quot;);</td></tr><tr><td class="line">139</td><td class="hits"></td><td class="source">                        } else {</td></tr><tr class="miss"> <td class="line">140</td><td class="hits">0</td><td class="source">                            callback(error);</td></tr><tr><td class="line">141</td><td class="hits"></td><td class="source">                        }</td></tr><tr><td class="line">142</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">143</td><td class="hits"></td><td class="source">                    });</td></tr><tr><td class="line">144</td><td class="hits"></td><td class="source">                } else {</td></tr><tr class="hit"> <td class="line">145</td><td class="hits">38</td><td class="source">                    that.blacklistClient.incr(countKey, function(error, reply){</td></tr><tr class="hit"> <td class="line">146</td><td class="hits">38</td><td class="source">                        if (!error){</td></tr><tr class="hit"> <td class="line">147</td><td class="hits">38</td><td class="source">                            callback(&quot;OK&quot;);</td></tr><tr><td class="line">148</td><td class="hits"></td><td class="source">                        } else {</td></tr><tr class="miss"> <td class="line">149</td><td class="hits">0</td><td class="source">                            callback(error);</td></tr><tr><td class="line">150</td><td class="hits"></td><td class="source">                        }</td></tr><tr><td class="line">151</td><td class="hits"></td><td class="source">                    });</td></tr><tr><td class="line">152</td><td class="hits"></td><td class="source">                }</td></tr><tr><td class="line">153</td><td class="hits"></td><td class="source">            }</td></tr><tr><td class="line">154</td><td class="hits"></td><td class="source">        });</td></tr><tr><td class="line">155</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">156</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">157</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">158</td><td class="hits">1</td><td class="source">Blacklist.prototype.shutdown = function(){</td></tr><tr class="hit"> <td class="line">159</td><td class="hits">32</td><td class="source">    this.blacklistClient.end();</td></tr><tr><td class="line">160</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">161</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">162</td><td class="hits"></td><td class="source"> </td></tr></tbody></table></div><div class="file"><h2 id="lib/messaging.js">lib/messaging.js</h2><div id="stats" class="high"><div class="percentage">91%</div><div class="sloc">185</div><div class="hits">169</div><div class="misses">16</div></div><table id="source"><thead><tr><th>Line</th><th>Hits</th><th>Source</th></tr></thead><tbody><tr><td class="line">1</td><td class="hits"></td><td class="source">// Copyright 2012 Kinvey, Inc</td></tr><tr><td class="line">2</td><td class="hits"></td><td class="source">//</td></tr><tr><td class="line">3</td><td class="hits"></td><td class="source">//    Licensed under the Apache License, Version 2.0 (the &quot;License&quot;);</td></tr><tr><td class="line">4</td><td class="hits"></td><td class="source">//    you may not use this file except in compliance with the License.</td></tr><tr><td class="line">5</td><td class="hits"></td><td class="source">//    You may obtain a copy of the License at</td></tr><tr><td class="line">6</td><td class="hits"></td><td class="source">//</td></tr><tr><td class="line">7</td><td class="hits"></td><td class="source">//        http://www.apache.org/licenses/LICENSE-2.0</td></tr><tr><td class="line">8</td><td class="hits"></td><td class="source">//</td></tr><tr><td class="line">9</td><td class="hits"></td><td class="source">//    Unless required by applicable law or agreed to in writing, software</td></tr><tr><td class="line">10</td><td class="hits"></td><td class="source">//    distributed under the License is distributed on an &quot;AS IS&quot; BASIS,</td></tr><tr><td class="line">11</td><td class="hits"></td><td class="source">//    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</td></tr><tr><td class="line">12</td><td class="hits"></td><td class="source">//    See the License for the specific language governing permissions and</td></tr><tr><td class="line">13</td><td class="hits"></td><td class="source">//    limitations under the License.</td></tr><tr><td class="line">14</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">15</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">16</td><td class="hits">1</td><td class="source">&quot;use strict&quot;;</td></tr><tr><td class="line">17</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">18</td><td class="hits">1</td><td class="source">var uuid = require('node-uuid')</td></tr><tr><td class="line">19</td><td class="hits"></td><td class="source">  , util = require('util')</td></tr><tr><td class="line">20</td><td class="hits"></td><td class="source">  , redis = require('redis')</td></tr><tr><td class="line">21</td><td class="hits"></td><td class="source">  , EventEmitter = require('events').EventEmitter</td></tr><tr><td class="line">22</td><td class="hits"></td><td class="source">  , connect</td></tr><tr><td class="line">23</td><td class="hits"></td><td class="source">  , MessageBus</td></tr><tr><td class="line">24</td><td class="hits"></td><td class="source">  , makeId</td></tr><tr><td class="line">25</td><td class="hits"></td><td class="source">  , wrapError</td></tr><tr><td class="line">26</td><td class="hits"></td><td class="source">  , initResponder</td></tr><tr><td class="line">27</td><td class="hits"></td><td class="source">  , initCreator</td></tr><tr><td class="line">28</td><td class="hits"></td><td class="source">  , authClient</td></tr><tr><td class="line">29</td><td class="hits"></td><td class="source">  , completeTransaction</td></tr><tr><td class="line">30</td><td class="hits"></td><td class="source">  , KILOBYTES = 1024</td></tr><tr><td class="line">31</td><td class="hits"></td><td class="source">  , MEGABYTES = 1024 * 1024</td></tr><tr><td class="line">32</td><td class="hits"></td><td class="source">  , log;</td></tr><tr><td class="line">33</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">34</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">35</td><td class="hits">1</td><td class="source">log = function(msg){</td></tr><tr class="miss"> <td class="line">36</td><td class="hits">0</td><td class="source">    var d = new Date()</td></tr><tr><td class="line">37</td><td class="hits"></td><td class="source">      , t = d.toISOString();</td></tr><tr class="miss"> <td class="line">38</td><td class="hits">0</td><td class="source">    util.debug(t + &quot;: &quot; + msg);</td></tr><tr><td class="line">39</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">40</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">41</td><td class="hits">1</td><td class="source">wrapError = function(that, evt){</td></tr><tr class="hit"> <td class="line">42</td><td class="hits">1</td><td class="source">    that.emit('error', evt);</td></tr><tr><td class="line">43</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">44</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">45</td><td class="hits">1</td><td class="source">exports.makeId = makeId = function(){</td></tr><tr class="hit"> <td class="line">46</td><td class="hits">10258</td><td class="source">    return uuid().replace(/-/g, &quot;&quot;);</td></tr><tr><td class="line">47</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">48</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">49</td><td class="hits">1</td><td class="source">initCreator = function(that){</td></tr><tr class="hit"> <td class="line">50</td><td class="hits">57</td><td class="source">    that.subClient.subscribe(that.listenChannel);</td></tr><tr class="hit"> <td class="line">51</td><td class="hits">57</td><td class="source">    that.subClient.on('message', function(channel, message){</td></tr><tr class="hit"> <td class="line">52</td><td class="hits">14</td><td class="source">        completeTransaction(that, channel, message);</td></tr><tr><td class="line">53</td><td class="hits"></td><td class="source">    });</td></tr><tr><td class="line">54</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">55</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">56</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">57</td><td class="hits">1</td><td class="source">initResponder = function(that){</td></tr><tr class="hit"> <td class="line">58</td><td class="hits">56</td><td class="source">    var util = require('util');</td></tr><tr class="hit"> <td class="line">59</td><td class="hits">56</td><td class="source">    that.subClient.subscribe(that.broadcastChannel);</td></tr><tr class="hit"> <td class="line">60</td><td class="hits">56</td><td class="source">    that.subClient.on('message', function(channel, message){</td></tr><tr class="hit"> <td class="line">61</td><td class="hits">28</td><td class="source">        var msgBody, id;</td></tr><tr class="hit"> <td class="line">62</td><td class="hits">28</td><td class="source">        if (channel !== that.broadcastChannel){</td></tr><tr><td class="line">63</td><td class="hits"></td><td class="source">            // This shouldn't happen, it would mean</td></tr><tr><td class="line">64</td><td class="hits"></td><td class="source">            // that we've accidentally subscribed to</td></tr><tr><td class="line">65</td><td class="hits"></td><td class="source">            // an extra redis channel...</td></tr><tr><td class="line">66</td><td class="hits"></td><td class="source">            // If for some crazy reason we get an incorrect</td></tr><tr><td class="line">67</td><td class="hits"></td><td class="source">            // channel we should ignore the message</td></tr><tr class="miss"> <td class="line">68</td><td class="hits">0</td><td class="source">            return;</td></tr><tr><td class="line">69</td><td class="hits"></td><td class="source">        }</td></tr><tr class="hit"> <td class="line">70</td><td class="hits">28</td><td class="source">        id = message;</td></tr><tr class="hit"> <td class="line">71</td><td class="hits">28</td><td class="source">        that.emit('data_available', id);</td></tr><tr><td class="line">72</td><td class="hits"></td><td class="source">    });</td></tr><tr><td class="line">73</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">74</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">75</td><td class="hits">1</td><td class="source">authClient = function(password, client, debug){</td></tr><tr class="hit"> <td class="line">76</td><td class="hits">339</td><td class="source">    if (password){</td></tr><tr class="hit"> <td class="line">77</td><td class="hits">3</td><td class="source">        client.auth(password, function(res){</td></tr><tr class="miss"> <td class="line">78</td><td class="hits">0</td><td class="source">            if (debug){</td></tr><tr class="miss"> <td class="line">79</td><td class="hits">0</td><td class="source">                console.log(&quot;Auth'd redis messaging started with &quot; + res);</td></tr><tr><td class="line">80</td><td class="hits"></td><td class="source">            }</td></tr><tr><td class="line">81</td><td class="hits"></td><td class="source">        });</td></tr><tr><td class="line">82</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">83</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">84</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">85</td><td class="hits">1</td><td class="source">exports.MessageBus = MessageBus = function(options){</td></tr><tr class="hit"> <td class="line">86</td><td class="hits">113</td><td class="source">    var that;</td></tr><tr><td class="line">87</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">88</td><td class="hits">113</td><td class="source">    if (!options){</td></tr><tr class="hit"> <td class="line">89</td><td class="hits">24</td><td class="source">        options = {};</td></tr><tr><td class="line">90</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">91</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">92</td><td class="hits">113</td><td class="source">    EventEmitter.call(this);</td></tr><tr class="hit"> <td class="line">93</td><td class="hits">113</td><td class="source">    this.redisHost = null;</td></tr><tr class="hit"> <td class="line">94</td><td class="hits">113</td><td class="source">    this.redisPort = null;</td></tr><tr class="hit"> <td class="line">95</td><td class="hits">113</td><td class="source">    this.redisPassword = null;</td></tr><tr class="hit"> <td class="line">96</td><td class="hits">113</td><td class="source">    this.debug_is_enabled = false;</td></tr><tr class="hit"> <td class="line">97</td><td class="hits">113</td><td class="source">    this.idToChannelMap = {};</td></tr><tr class="hit"> <td class="line">98</td><td class="hits">113</td><td class="source">    this.callbackMap = {};</td></tr><tr class="hit"> <td class="line">99</td><td class="hits">113</td><td class="source">    this.listenChannel = &quot;msgChannels:&quot; + makeId();</td></tr><tr class="hit"> <td class="line">100</td><td class="hits">113</td><td class="source">    this.broadcastChannel = (options &amp;&amp; options.broadcast) || &quot;msgChannels:broadcast&quot;;</td></tr><tr class="hit"> <td class="line">101</td><td class="hits">113</td><td class="source">    this.dataHash = (options &amp;&amp; options.dataHash) || &quot;msgTable:normal&quot;;</td></tr><tr class="hit"> <td class="line">102</td><td class="hits">113</td><td class="source">    this.responseHash = (options &amp;&amp; options.outputHash) || &quot;responseTable:normal&quot;;</td></tr><tr class="hit"> <td class="line">103</td><td class="hits">113</td><td class="source">    this.shutdownFlag = false;</td></tr><tr class="hit"> <td class="line">104</td><td class="hits">113</td><td class="source">    this.id = makeId();        // For debugging / logging</td></tr><tr><td class="line">105</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">106</td><td class="hits">117</td><td class="source">    if (options &amp;&amp; options.host){ this.redisHost = options.host; }</td></tr><tr class="hit"> <td class="line">107</td><td class="hits">115</td><td class="source">    if (options &amp;&amp; options.port){ this.redisPort = options.port; }</td></tr><tr class="hit"> <td class="line">108</td><td class="hits">114</td><td class="source">    if (options &amp;&amp; options.password){ this.redisPassword = options.password; }</td></tr><tr><td class="line">109</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">110</td><td class="hits">113</td><td class="source">    this.pubClient = redis.createClient(this.redisPort, this.redisHost);</td></tr><tr class="hit"> <td class="line">111</td><td class="hits">113</td><td class="source">    this.subClient = redis.createClient(this.redisPort, this.redisHost);</td></tr><tr class="hit"> <td class="line">112</td><td class="hits">113</td><td class="source">    this.dataClient = redis.createClient(this.redisPort, this.redisHost);</td></tr><tr><td class="line">113</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">114</td><td class="hits">113</td><td class="source">    authClient(this.redisPassword, this.dataClient, this.debug_is_enabled);</td></tr><tr class="hit"> <td class="line">115</td><td class="hits">113</td><td class="source">    authClient(this.redisPassword, this.pubClient, this.debug_is_enabled);</td></tr><tr class="hit"> <td class="line">116</td><td class="hits">113</td><td class="source">    authClient(this.redisPassword, this.subClient, this.debug_is_enabled);</td></tr><tr><td class="line">117</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">118</td><td class="hits">113</td><td class="source">    if (options &amp;&amp; options.isResponder){</td></tr><tr class="hit"> <td class="line">119</td><td class="hits">56</td><td class="source">        initResponder(this);</td></tr><tr><td class="line">120</td><td class="hits"></td><td class="source">    } else {</td></tr><tr class="hit"> <td class="line">121</td><td class="hits">57</td><td class="source">        initCreator(this);</td></tr><tr><td class="line">122</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">123</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">124</td><td class="hits">113</td><td class="source">    that = this;</td></tr><tr class="hit"> <td class="line">125</td><td class="hits">113</td><td class="source">    this.dataClient.on('error', function(evt){wrapError(that, evt);});</td></tr><tr class="hit"> <td class="line">126</td><td class="hits">114</td><td class="source">    this.pubClient.on('error', function(evt){wrapError(that, evt);});</td></tr><tr class="hit"> <td class="line">127</td><td class="hits">113</td><td class="source">    this.subClient.on('error', function(evt){wrapError(that, evt);});</td></tr><tr><td class="line">128</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">129</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">130</td><td class="hits">1</td><td class="source">util.inherits(MessageBus, EventEmitter);</td></tr><tr><td class="line">131</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">132</td><td class="hits">1</td><td class="source">completeTransaction = function(that, ch, msg){</td></tr><tr class="hit"> <td class="line">133</td><td class="hits">14</td><td class="source">    var response, id, status, parsedMsg, daFaq, callback, multi;</td></tr><tr><td class="line">134</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">135</td><td class="hits">14</td><td class="source">    if (ch !== that.listenChannel){</td></tr><tr><td class="line">136</td><td class="hits"></td><td class="source">        // This can NEVER happen (except for if there's an error)</td></tr><tr><td class="line">137</td><td class="hits"></td><td class="source">        // in our code.  So the check is left in, but</td></tr><tr><td class="line">138</td><td class="hits"></td><td class="source">        // should never be hit.</td></tr><tr class="miss"> <td class="line">139</td><td class="hits">0</td><td class="source">        that.emit('error', new Error(&quot;Got message for some other channel (Expected: &quot; +</td></tr><tr><td class="line">140</td><td class="hits"></td><td class="source">                                     that.listenChannel + &quot;, Actual: &quot; + ch + &quot;)&quot;));</td></tr><tr><td class="line">141</td><td class="hits"></td><td class="source">        // Bail out!</td></tr><tr class="miss"> <td class="line">142</td><td class="hits">0</td><td class="source">        return;</td></tr><tr><td class="line">143</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">144</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">145</td><td class="hits">14</td><td class="source">    parsedMsg = msg.split(' ');</td></tr><tr class="hit"> <td class="line">146</td><td class="hits">14</td><td class="source">    if (parsedMsg.length &lt; 2){</td></tr><tr class="hit"> <td class="line">147</td><td class="hits">1</td><td class="source">        that.emit('error',  new Error(&quot;Invalid message received!&quot;));</td></tr><tr><td class="line">148</td><td class="hits"></td><td class="source">        // Bail out</td></tr><tr class="hit"> <td class="line">149</td><td class="hits">1</td><td class="source">        return;</td></tr><tr><td class="line">150</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">151</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">152</td><td class="hits">13</td><td class="source">    id = parsedMsg[0];</td></tr><tr class="hit"> <td class="line">153</td><td class="hits">13</td><td class="source">    status = parsedMsg[1];</td></tr><tr><td class="line">154</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">155</td><td class="hits">13</td><td class="source">    callback = that.callbackMap[id];</td></tr><tr><td class="line">156</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">157</td><td class="hits">13</td><td class="source">    multi = that.dataClient.multi();</td></tr><tr><td class="line">158</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">159</td><td class="hits">13</td><td class="source">    multi.hget(that.responseHash, id)</td></tr><tr><td class="line">160</td><td class="hits"></td><td class="source">    .hdel(that.responseHash, id)</td></tr><tr><td class="line">161</td><td class="hits"></td><td class="source">    .exec(function(err, reply){</td></tr><tr class="hit"> <td class="line">162</td><td class="hits">12</td><td class="source">        var myErr = null, respondedErr, o;</td></tr><tr class="hit"> <td class="line">163</td><td class="hits">12</td><td class="source">        if (err){</td></tr><tr class="miss"> <td class="line">164</td><td class="hits">0</td><td class="source">            myErr = new Error(&quot;REDIS Error: &quot; + err);</td></tr><tr><td class="line">165</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">166</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">167</td><td class="hits">12</td><td class="source">        if (!util.isArray(reply) &amp;&amp; !myErr){</td></tr><tr class="miss"> <td class="line">168</td><td class="hits">0</td><td class="source">            myErr = new Error(&quot;Internal REDIS error (&quot; + err + &quot;, &quot; + reply + &quot;)&quot;);</td></tr><tr class="hit"> <td class="line">169</td><td class="hits">12</td><td class="source">        } else if (util.isArray(reply)){</td></tr><tr><td class="line">170</td><td class="hits"></td><td class="source">          // Reply[0] =&gt; hget, Reply[1] =&gt; hdel</td></tr><tr class="hit"> <td class="line">171</td><td class="hits">12</td><td class="source">          reply = reply[0];</td></tr><tr><td class="line">172</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">173</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">174</td><td class="hits">12</td><td class="source">        if (reply === null &amp;&amp; !myErr){</td></tr><tr class="hit"> <td class="line">175</td><td class="hits">1</td><td class="source">            myErr = new Error(&quot;No message for id &quot; + id);</td></tr><tr><td class="line">176</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">177</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">178</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">179</td><td class="hits">12</td><td class="source">        if (!myErr){</td></tr><tr class="hit"> <td class="line">180</td><td class="hits">11</td><td class="source">            try {</td></tr><tr class="hit"> <td class="line">181</td><td class="hits">11</td><td class="source">                response = JSON.parse(reply);</td></tr><tr><td class="line">182</td><td class="hits"></td><td class="source">            } catch(e){</td></tr><tr class="hit"> <td class="line">183</td><td class="hits">1</td><td class="source">                myErr = new Error(&quot;JSON parsing failed! &quot; + e);</td></tr><tr><td class="line">184</td><td class="hits"></td><td class="source">            }</td></tr><tr><td class="line">185</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">186</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">187</td><td class="hits">12</td><td class="source">        if (myErr){</td></tr><tr class="hit"> <td class="line">188</td><td class="hits">2</td><td class="source">            response = myErr;</td></tr><tr class="hit"> <td class="line">189</td><td class="hits">2</td><td class="source">            that.emit('error', myErr);</td></tr><tr class="hit"> <td class="line">190</td><td class="hits">2</td><td class="source">            return;</td></tr><tr><td class="line">191</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">192</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">193</td><td class="hits">10</td><td class="source">        if (status !== 'SUCCESS'){</td></tr><tr><td class="line">194</td><td class="hits"></td><td class="source">            // Build the error</td></tr><tr class="hit"> <td class="line">195</td><td class="hits">1</td><td class="source">            that.emit('error', response);</td></tr><tr><td class="line">196</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">197</td><td class="hits"></td><td class="source">            // If we're hard failed we stop working here,</td></tr><tr><td class="line">198</td><td class="hits"></td><td class="source">            // no success</td></tr><tr class="hit"> <td class="line">199</td><td class="hits">1</td><td class="source">            if (status === &quot;FAILED&quot;){</td></tr><tr class="hit"> <td class="line">200</td><td class="hits">1</td><td class="source">                if (callback){</td></tr><tr class="hit"> <td class="line">201</td><td class="hits">1</td><td class="source">                    callback(response);</td></tr><tr class="hit"> <td class="line">202</td><td class="hits">1</td><td class="source">                    delete that.callbackMap[id];</td></tr><tr><td class="line">203</td><td class="hits"></td><td class="source">                }</td></tr><tr class="hit"> <td class="line">204</td><td class="hits">1</td><td class="source">                return;</td></tr><tr><td class="line">205</td><td class="hits"></td><td class="source">            }</td></tr><tr><td class="line">206</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">207</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">208</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">209</td><td class="hits">9</td><td class="source">        that.emit('responseReady', response);</td></tr><tr><td class="line">210</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">211</td><td class="hits">9</td><td class="source">        if (callback){</td></tr><tr class="hit"> <td class="line">212</td><td class="hits">9</td><td class="source">            callback(response);</td></tr><tr class="hit"> <td class="line">213</td><td class="hits">9</td><td class="source">            delete that.callbackMap[id];</td></tr><tr><td class="line">214</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">215</td><td class="hits"></td><td class="source">    });</td></tr><tr><td class="line">216</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">217</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">218</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">219</td><td class="hits">1</td><td class="source">MessageBus.prototype.sendMessage = function(id, msg, callback){</td></tr><tr class="hit"> <td class="line">220</td><td class="hits">21</td><td class="source">    var that = this</td></tr><tr><td class="line">221</td><td class="hits"></td><td class="source">      , err</td></tr><tr><td class="line">222</td><td class="hits"></td><td class="source">      , msgString;</td></tr><tr><td class="line">223</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">224</td><td class="hits">21</td><td class="source">    if (this.shutdownFlag){</td></tr><tr class="hit"> <td class="line">225</td><td class="hits">1</td><td class="source">        callback(new Error(&quot;Attempt to use shutdown MessageBus.&quot;));</td></tr><tr class="hit"> <td class="line">226</td><td class="hits">1</td><td class="source">        return;</td></tr><tr><td class="line">227</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">228</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">229</td><td class="hits">20</td><td class="source">    msg._listenChannel = this.listenChannel;</td></tr><tr class="hit"> <td class="line">230</td><td class="hits">20</td><td class="source">    msg._messageId = id; // Store the message id in-band</td></tr><tr><td class="line">231</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">232</td><td class="hits">20</td><td class="source">    msgString = JSON.stringify(msg);</td></tr><tr><td class="line">233</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">234</td><td class="hits">20</td><td class="source">    if (!msgString){</td></tr><tr class="hit"> <td class="line">235</td><td class="hits">1</td><td class="source">        callback(new Error(&quot;Error converting message to JSON.&quot;));</td></tr><tr class="hit"> <td class="line">236</td><td class="hits">1</td><td class="source">        return;</td></tr><tr><td class="line">237</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">238</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">239</td><td class="hits"></td><td class="source">    // TODO: This needs to be an option for the class</td></tr><tr class="hit"> <td class="line">240</td><td class="hits">19</td><td class="source">    if (msgString.length &gt; MEGABYTES){</td></tr><tr class="hit"> <td class="line">241</td><td class="hits">1</td><td class="source">        callback(new Error(&quot;Payload too large!&quot;));</td></tr><tr class="hit"> <td class="line">242</td><td class="hits">1</td><td class="source">        return;</td></tr><tr><td class="line">243</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">244</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">245</td><td class="hits">18</td><td class="source">    this.dataClient.hset(this.dataHash, id, msgString, function(err, reply){</td></tr><tr class="hit"> <td class="line">246</td><td class="hits">17</td><td class="source">        if (err){</td></tr><tr class="miss"> <td class="line">247</td><td class="hits">0</td><td class="source">            callback(new Error(&quot;Error sending message: &quot; + err));</td></tr><tr class="miss"> <td class="line">248</td><td class="hits">0</td><td class="source">            return;</td></tr><tr><td class="line">249</td><td class="hits"></td><td class="source">        }</td></tr><tr class="hit"> <td class="line">250</td><td class="hits">17</td><td class="source">        that.pubClient.publish(that.broadcastChannel, id);</td></tr><tr><td class="line">251</td><td class="hits"></td><td class="source">    });</td></tr><tr class="hit"> <td class="line">252</td><td class="hits">18</td><td class="source">    this.callbackMap[id] = callback;</td></tr><tr><td class="line">253</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">254</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">255</td><td class="hits">1</td><td class="source">MessageBus.prototype.acceptMessage = function(mid, callback){</td></tr><tr class="hit"> <td class="line">256</td><td class="hits">23</td><td class="source">    var that = this</td></tr><tr><td class="line">257</td><td class="hits"></td><td class="source">      , multi</td></tr><tr><td class="line">258</td><td class="hits"></td><td class="source">      , derivedId;</td></tr><tr><td class="line">259</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">260</td><td class="hits">23</td><td class="source">    if (!mid){</td></tr><tr class="hit"> <td class="line">261</td><td class="hits">2</td><td class="source">        throw new Error('Missing Message ID.');</td></tr><tr><td class="line">262</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">263</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">264</td><td class="hits">21</td><td class="source">    if (!callback){</td></tr><tr class="hit"> <td class="line">265</td><td class="hits">1</td><td class="source">        throw new Error('Invalid callback.');</td></tr><tr><td class="line">266</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">267</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">268</td><td class="hits">20</td><td class="source">    if (callback.length &lt; 1){</td></tr><tr class="hit"> <td class="line">269</td><td class="hits">1</td><td class="source">        throw new Error('Missing parameters in callback.');</td></tr><tr><td class="line">270</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">271</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">272</td><td class="hits">19</td><td class="source">    multi = that.dataClient.multi();</td></tr><tr><td class="line">273</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">274</td><td class="hits"></td><td class="source">    // Pipeline!</td></tr><tr class="hit"> <td class="line">275</td><td class="hits">19</td><td class="source">    multi</td></tr><tr><td class="line">276</td><td class="hits"></td><td class="source">    .hget(that.dataHash, mid)</td></tr><tr><td class="line">277</td><td class="hits"></td><td class="source">    .hdel(that.dataHash, mid)</td></tr><tr><td class="line">278</td><td class="hits"></td><td class="source">    .exec(function(err, reply){</td></tr><tr class="hit"> <td class="line">279</td><td class="hits">19</td><td class="source">        var listenChannel, id, dataErr, msgBody;</td></tr><tr><td class="line">280</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">281</td><td class="hits"></td><td class="source">        // First make sure that everything is probably ok</td></tr><tr class="hit"> <td class="line">282</td><td class="hits">19</td><td class="source">        if (!util.isArray(reply)){</td></tr><tr class="miss"> <td class="line">283</td><td class="hits">0</td><td class="source">            dataErr = new Error(&quot;Internal REDIS error (&quot; + err + &quot;, &quot; + reply + &quot;)&quot;);</td></tr><tr class="miss"> <td class="line">284</td><td class="hits">0</td><td class="source">            callback(dataErr);</td></tr><tr class="miss"> <td class="line">285</td><td class="hits">0</td><td class="source">            return;</td></tr><tr><td class="line">286</td><td class="hits"></td><td class="source">        } else {</td></tr><tr><td class="line">287</td><td class="hits"></td><td class="source">            // reply is good, let's just get the first element</td></tr><tr><td class="line">288</td><td class="hits"></td><td class="source">            // as the indeices should be hget,hdel</td></tr><tr class="hit"> <td class="line">289</td><td class="hits">19</td><td class="source">            reply = reply[0];</td></tr><tr><td class="line">290</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">291</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">292</td><td class="hits">19</td><td class="source">        try {</td></tr><tr class="hit"> <td class="line">293</td><td class="hits">19</td><td class="source">            msgBody = JSON.parse(reply);</td></tr><tr><td class="line">294</td><td class="hits"></td><td class="source">        } catch(e) {</td></tr><tr class="hit"> <td class="line">295</td><td class="hits">1</td><td class="source">            dataErr = new Error(&quot;Bad data in sent message, &quot; + e);</td></tr><tr class="hit"> <td class="line">296</td><td class="hits">1</td><td class="source">            callback(dataErr);</td></tr><tr class="hit"> <td class="line">297</td><td class="hits">1</td><td class="source">            return;</td></tr><tr><td class="line">298</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">299</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">300</td><td class="hits">18</td><td class="source">        if (!msgBody){</td></tr><tr class="hit"> <td class="line">301</td><td class="hits">3</td><td class="source">            dataErr = new Error(&quot;DB doesn't recognize message&quot;);</td></tr><tr class="hit"> <td class="line">302</td><td class="hits">3</td><td class="source">            callback(dataErr);</td></tr><tr class="hit"> <td class="line">303</td><td class="hits">3</td><td class="source">            return;</td></tr><tr><td class="line">304</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">305</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">306</td><td class="hits">15</td><td class="source">        derivedId = id = msgBody._messageId;</td></tr><tr class="hit"> <td class="line">307</td><td class="hits">15</td><td class="source">        listenChannel = msgBody._listenChannel;</td></tr><tr><td class="line">308</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">309</td><td class="hits">15</td><td class="source">        if (id !== mid){</td></tr><tr class="miss"> <td class="line">310</td><td class="hits">0</td><td class="source">            console.log(&quot;ERROR: Mis-match on ids! (&quot; + id + &quot; does not equal &quot; + mid + &quot;)&quot;);</td></tr><tr><td class="line">311</td><td class="hits"></td><td class="source">        }</td></tr><tr><td class="line">312</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">313</td><td class="hits">15</td><td class="source">        that.idToChannelMap[id] = listenChannel;</td></tr><tr><td class="line">314</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">315</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">316</td><td class="hits">15</td><td class="source">        delete msgBody._listenChannel;</td></tr><tr class="hit"> <td class="line">317</td><td class="hits">15</td><td class="source">        delete msgBody._messageId;</td></tr><tr><td class="line">318</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">319</td><td class="hits">15</td><td class="source">        callback(msgBody);</td></tr><tr><td class="line">320</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">321</td><td class="hits"></td><td class="source">    });</td></tr><tr><td class="line">322</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">323</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">324</td><td class="hits">1</td><td class="source">MessageBus.prototype.sendResponse = function(msgId, status, msg){</td></tr><tr class="hit"> <td class="line">325</td><td class="hits">37</td><td class="source">    if (!msgId || !status || !msg){</td></tr><tr class="hit"> <td class="line">326</td><td class="hits">5</td><td class="source">        throw new Error(&quot;Missing msgId, status or msg.&quot;);</td></tr><tr><td class="line">327</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">328</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">329</td><td class="hits">32</td><td class="source">    if (status !== 'SUCCESS' &amp;&amp;</td></tr><tr><td class="line">330</td><td class="hits"></td><td class="source">        status !== 'ERROR'   &amp;&amp;</td></tr><tr><td class="line">331</td><td class="hits"></td><td class="source">        status !== 'FAILED')</td></tr><tr><td class="line">332</td><td class="hits"></td><td class="source">    {</td></tr><tr class="hit"> <td class="line">333</td><td class="hits">12</td><td class="source">        throw new Error(status + ' is not a valid status.');</td></tr><tr><td class="line">334</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">335</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">336</td><td class="hits">20</td><td class="source">    var listenChannel = this.idToChannelMap[msgId]</td></tr><tr><td class="line">337</td><td class="hits"></td><td class="source">      , that = this, serializableError, o, tmpErr, testMode;</td></tr><tr><td class="line">338</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">339</td><td class="hits">20</td><td class="source">    if (arguments.length === 4){</td></tr><tr class="hit"> <td class="line">340</td><td class="hits">3</td><td class="source">        testMode = arguments[3];</td></tr><tr><td class="line">341</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">342</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">343</td><td class="hits">20</td><td class="source">    if (!listenChannel &amp;&amp; !testMode){</td></tr><tr><td class="line">344</td><td class="hits"></td><td class="source">        // We have no record of this request</td></tr><tr><td class="line">345</td><td class="hits"></td><td class="source">        // probably a callback being called twice, but</td></tr><tr><td class="line">346</td><td class="hits"></td><td class="source">        // still need to throw</td></tr><tr class="hit"> <td class="line">347</td><td class="hits">1</td><td class="source">        tmpErr = new Error('Attempt to respond to message that was never accepted');</td></tr><tr class="hit"> <td class="line">348</td><td class="hits">1</td><td class="source">        tmpErr.debugMessage = msgId + &quot; is not registered as having been accepted&quot;;</td></tr><tr class="hit"> <td class="line">349</td><td class="hits">1</td><td class="source">        throw tmpErr;</td></tr><tr><td class="line">350</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">351</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">352</td><td class="hits">19</td><td class="source">    this.dataClient.hset(this.responseHash, msgId, JSON.stringify(msg), function(err, reply){</td></tr><tr class="hit"> <td class="line">353</td><td class="hits">16</td><td class="source">        delete that.idToChannelMap[msgId];</td></tr><tr><td class="line">354</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">355</td><td class="hits">16</td><td class="source">        if (err){</td></tr><tr class="miss"> <td class="line">356</td><td class="hits">0</td><td class="source">            throw new Error(err);</td></tr><tr><td class="line">357</td><td class="hits"></td><td class="source">        }</td></tr><tr class="hit"> <td class="line">358</td><td class="hits">16</td><td class="source">        that.pubClient.publish(listenChannel, msgId + &quot; &quot; + status);</td></tr><tr><td class="line">359</td><td class="hits"></td><td class="source">    });</td></tr><tr><td class="line">360</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">361</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">362</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">363</td><td class="hits">1</td><td class="source">MessageBus.prototype.shutdown = function(){</td></tr><tr class="hit"> <td class="line">364</td><td class="hits">106</td><td class="source">    this.subClient.removeAllListeners('message');</td></tr><tr class="hit"> <td class="line">365</td><td class="hits">106</td><td class="source">    this.dataClient.removeAllListeners('error');</td></tr><tr class="hit"> <td class="line">366</td><td class="hits">106</td><td class="source">    this.pubClient.removeAllListeners('error');</td></tr><tr class="hit"> <td class="line">367</td><td class="hits">106</td><td class="source">    this.subClient.removeAllListeners('error');</td></tr><tr class="hit"> <td class="line">368</td><td class="hits">106</td><td class="source">    this.dataClient.end();</td></tr><tr class="hit"> <td class="line">369</td><td class="hits">106</td><td class="source">    this.pubClient.end();</td></tr><tr class="hit"> <td class="line">370</td><td class="hits">106</td><td class="source">    this.subClient.end();</td></tr><tr class="hit"> <td class="line">371</td><td class="hits">106</td><td class="source">    this.removeAllListeners();</td></tr><tr class="hit"> <td class="line">372</td><td class="hits">106</td><td class="source">    this.shutdownFlag = true;</td></tr><tr><td class="line">373</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">374</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">375</td><td class="hits">1</td><td class="source">exports.connect = connect = function(options){</td></tr><tr class="hit"> <td class="line">376</td><td class="hits">113</td><td class="source">    return new MessageBus(options);</td></tr><tr><td class="line">377</td><td class="hits"></td><td class="source">};</td></tr></tbody></table></div><div class="file"><h2 id="lib/task_limit.js">lib/task_limit.js</h2><div id="stats" class="high"><div class="percentage">100%</div><div class="sloc">40</div><div class="hits">40</div><div class="misses">0</div></div><table id="source"><thead><tr><th>Line</th><th>Hits</th><th>Source</th></tr></thead><tbody><tr><td class="line">1</td><td class="hits"></td><td class="source">// Copyright 2012 Kinvey, Inc</td></tr><tr><td class="line">2</td><td class="hits"></td><td class="source">//</td></tr><tr><td class="line">3</td><td class="hits"></td><td class="source">//    Licensed under the Apache License, Version 2.0 (the &quot;License&quot;);</td></tr><tr><td class="line">4</td><td class="hits"></td><td class="source">//    you may not use this file except in compliance with the License.</td></tr><tr><td class="line">5</td><td class="hits"></td><td class="source">//    You may obtain a copy of the License at</td></tr><tr><td class="line">6</td><td class="hits"></td><td class="source">//</td></tr><tr><td class="line">7</td><td class="hits"></td><td class="source">//        http://www.apache.org/licenses/LICENSE-2.0</td></tr><tr><td class="line">8</td><td class="hits"></td><td class="source">//</td></tr><tr><td class="line">9</td><td class="hits"></td><td class="source">//    Unless required by applicable law or agreed to in writing, software</td></tr><tr><td class="line">10</td><td class="hits"></td><td class="source">//    distributed under the License is distributed on an &quot;AS IS&quot; BASIS,</td></tr><tr><td class="line">11</td><td class="hits"></td><td class="source">//    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</td></tr><tr><td class="line">12</td><td class="hits"></td><td class="source">//    See the License for the specific language governing permissions and</td></tr><tr><td class="line">13</td><td class="hits"></td><td class="source">//    limitations under the License.</td></tr><tr class="hit"> <td class="line">14</td><td class="hits">1</td><td class="source">&quot;use strict&quot;;</td></tr><tr><td class="line">15</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">16</td><td class="hits">1</td><td class="source">var redis = require(&quot;redis&quot;)</td></tr><tr><td class="line">17</td><td class="hits"></td><td class="source">  , util = require('util')</td></tr><tr><td class="line">18</td><td class="hits"></td><td class="source">  , EventEmitter = require('events').EventEmitter</td></tr><tr><td class="line">19</td><td class="hits"></td><td class="source">  , wrapError;</td></tr><tr><td class="line">20</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">21</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">22</td><td class="hits">1</td><td class="source">wrapError = function(emitter){</td></tr><tr class="hit"> <td class="line">23</td><td class="hits">36</td><td class="source">    return function(error){</td></tr><tr class="hit"> <td class="line">24</td><td class="hits">1</td><td class="source">        emitter.emit('error', error);</td></tr><tr><td class="line">25</td><td class="hits"></td><td class="source">    };</td></tr><tr><td class="line">26</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">27</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">28</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">29</td><td class="hits">1</td><td class="source">var TaskLimit = exports.TaskLimit = function(options){</td></tr><tr class="hit"> <td class="line">30</td><td class="hits">37</td><td class="source">    EventEmitter.call(this);</td></tr><tr><td class="line">31</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">32</td><td class="hits">37</td><td class="source">    if (!options){</td></tr><tr class="hit"> <td class="line">33</td><td class="hits">1</td><td class="source">        throw new Error(&quot;I need a task key!&quot;);</td></tr><tr><td class="line">34</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">35</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">36</td><td class="hits">37</td><td class="source">    if (options.host){ this.redisHost = options.host; }</td></tr><tr class="hit"> <td class="line">37</td><td class="hits">37</td><td class="source">    if (options.port){ this.redisPort = options.port; }</td></tr><tr class="hit"> <td class="line">38</td><td class="hits">37</td><td class="source">    if (options.password){ this.redisPassword = options.password; }</td></tr><tr><td class="line">39</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">40</td><td class="hits">36</td><td class="source">    this.taskKey = options.taskKey;</td></tr><tr class="hit"> <td class="line">41</td><td class="hits">36</td><td class="source">    this.redisKeyPrefix = &quot;taskKey:&quot;;</td></tr><tr class="hit"> <td class="line">42</td><td class="hits">36</td><td class="source">    this.maxTasksPerKey = options.maxTasksPerKey||10;</td></tr><tr class="hit"> <td class="line">43</td><td class="hits">36</td><td class="source">    this.taskLimitClient = redis.createClient(this.redisPort, this.redisHost);</td></tr><tr><td class="line">44</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">45</td><td class="hits">36</td><td class="source">    this.taskLimitClient.on('error', wrapError(this));</td></tr><tr><td class="line">46</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">47</td><td class="hits">36</td><td class="source">    if (options.password){</td></tr><tr class="hit"> <td class="line">48</td><td class="hits">1</td><td class="source">        this.taskLimitClient.auth(options.password);</td></tr><tr><td class="line">49</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">50</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">51</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">52</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">53</td><td class="hits"></td><td class="source">// Inherit EventEmitter's methods</td></tr><tr class="hit"> <td class="line">54</td><td class="hits">1</td><td class="source">util.inherits(TaskLimit, EventEmitter);</td></tr><tr><td class="line">55</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">56</td><td class="hits">1</td><td class="source">TaskLimit.prototype.startTask = function(task, callback){</td></tr><tr class="hit"> <td class="line">57</td><td class="hits">40</td><td class="source">    var value = task &amp;&amp; task[this.taskKey]</td></tr><tr><td class="line">58</td><td class="hits"></td><td class="source">      , redisKey, that = this;</td></tr><tr><td class="line">59</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">60</td><td class="hits">40</td><td class="source">    if (!callback){</td></tr><tr class="hit"> <td class="line">61</td><td class="hits">8</td><td class="source">        callback = function(){};</td></tr><tr><td class="line">62</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">63</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">64</td><td class="hits">40</td><td class="source">    if (!value){</td></tr><tr class="hit"> <td class="line">65</td><td class="hits">4</td><td class="source">        callback(new Error(&quot;Invalid task, not running.&quot;));</td></tr><tr><td class="line">66</td><td class="hits"></td><td class="source">    } else {</td></tr><tr class="hit"> <td class="line">67</td><td class="hits">36</td><td class="source">        redisKey = that.redisKeyPrefix + value;</td></tr><tr class="hit"> <td class="line">68</td><td class="hits">36</td><td class="source">        that.taskLimitClient.llen(redisKey, function(err, len){</td></tr><tr class="hit"> <td class="line">69</td><td class="hits">36</td><td class="source">            if (len &gt;= that.maxTasksPerKey){</td></tr><tr class="hit"> <td class="line">70</td><td class="hits">2</td><td class="source">                callback(new Error(&quot;Too many tasks&quot;));</td></tr><tr><td class="line">71</td><td class="hits"></td><td class="source">            } else {</td></tr><tr class="hit"> <td class="line">72</td><td class="hits">34</td><td class="source">                that.taskLimitClient.lpush(redisKey, Date(), function(x){</td></tr><tr class="hit"> <td class="line">73</td><td class="hits">34</td><td class="source">                  callback(len+1);</td></tr><tr><td class="line">74</td><td class="hits"></td><td class="source">                });</td></tr><tr><td class="line">75</td><td class="hits"></td><td class="source">            }</td></tr><tr><td class="line">76</td><td class="hits"></td><td class="source">        });</td></tr><tr><td class="line">77</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">78</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">79</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">80</td><td class="hits">1</td><td class="source">TaskLimit.prototype.stopTask = function(task){</td></tr><tr class="hit"> <td class="line">81</td><td class="hits">33</td><td class="source">    var value = task &amp;&amp; task[this.taskKey]</td></tr><tr><td class="line">82</td><td class="hits"></td><td class="source">      , redisKey, that = this;</td></tr><tr><td class="line">83</td><td class="hits"></td><td class="source"> </td></tr><tr><td class="line">84</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">85</td><td class="hits">33</td><td class="source">    if (!value){</td></tr><tr class="hit"> <td class="line">86</td><td class="hits">4</td><td class="source">        throw new Error(&quot;Invalid task, can't stop.&quot;);</td></tr><tr><td class="line">87</td><td class="hits"></td><td class="source">    } else {</td></tr><tr class="hit"> <td class="line">88</td><td class="hits">29</td><td class="source">        redisKey = that.redisKeyPrefix + value;</td></tr><tr class="hit"> <td class="line">89</td><td class="hits">29</td><td class="source">        that.taskLimitClient.lpop(redisKey);</td></tr><tr><td class="line">90</td><td class="hits"></td><td class="source">    }</td></tr><tr><td class="line">91</td><td class="hits"></td><td class="source">};</td></tr><tr><td class="line">92</td><td class="hits"></td><td class="source"> </td></tr><tr class="hit"> <td class="line">93</td><td class="hits">1</td><td class="source">TaskLimit.prototype.shutdown = function(){</td></tr><tr class="hit"> <td class="line">94</td><td class="hits">32</td><td class="source">    this.taskLimitClient.end();</td></tr><tr><td class="line">95</td><td class="hits"></td><td class="source">};</td></tr></tbody></table></div></div></div></body></html>