825 lines
26 KiB
HTML
825 lines
26 KiB
HTML
<!doctype html>
|
||
<html lang="en">
|
||
<head>
|
||
<title>Code coverage report for node-ipc/dao/client.js</title>
|
||
<meta charset="utf-8" />
|
||
<link rel="stylesheet" href="../../prettify.css" />
|
||
<link rel="stylesheet" href="../../base.css" />
|
||
<meta name="viewport" content="width=device-width, initial-scale=1">
|
||
<style type='text/css'>
|
||
.coverage-summary .sorter {
|
||
background-image: url(../../sort-arrow-sprite.png);
|
||
}
|
||
</style>
|
||
</head>
|
||
<body>
|
||
<div class='wrapper'>
|
||
<div class='pad1'>
|
||
<h1>
|
||
<a href="../../index.html">all files</a> / <a href="index.html">node-ipc/dao/</a> client.js
|
||
</h1>
|
||
<div class='clearfix'>
|
||
<div class='fl pad1y space-right2'>
|
||
<span class="strong">71.17% </span>
|
||
<span class="quiet">Statements</span>
|
||
<span class='fraction'>79/111</span>
|
||
</div>
|
||
<div class='fl pad1y space-right2'>
|
||
<span class="strong">50.94% </span>
|
||
<span class="quiet">Branches</span>
|
||
<span class='fraction'>27/53</span>
|
||
</div>
|
||
<div class='fl pad1y space-right2'>
|
||
<span class="strong">100% </span>
|
||
<span class="quiet">Functions</span>
|
||
<span class='fraction'>9/9</span>
|
||
</div>
|
||
<div class='fl pad1y space-right2'>
|
||
<span class="strong">71.17% </span>
|
||
<span class="quiet">Lines</span>
|
||
<span class='fraction'>79/111</span>
|
||
</div>
|
||
</div>
|
||
</div>
|
||
<div class='status-line medium'></div>
|
||
<pre><table class="coverage">
|
||
<tr><td class="line-count quiet">1
|
||
2
|
||
3
|
||
4
|
||
5
|
||
6
|
||
7
|
||
8
|
||
9
|
||
10
|
||
11
|
||
12
|
||
13
|
||
14
|
||
15
|
||
16
|
||
17
|
||
18
|
||
19
|
||
20
|
||
21
|
||
22
|
||
23
|
||
24
|
||
25
|
||
26
|
||
27
|
||
28
|
||
29
|
||
30
|
||
31
|
||
32
|
||
33
|
||
34
|
||
35
|
||
36
|
||
37
|
||
38
|
||
39
|
||
40
|
||
41
|
||
42
|
||
43
|
||
44
|
||
45
|
||
46
|
||
47
|
||
48
|
||
49
|
||
50
|
||
51
|
||
52
|
||
53
|
||
54
|
||
55
|
||
56
|
||
57
|
||
58
|
||
59
|
||
60
|
||
61
|
||
62
|
||
63
|
||
64
|
||
65
|
||
66
|
||
67
|
||
68
|
||
69
|
||
70
|
||
71
|
||
72
|
||
73
|
||
74
|
||
75
|
||
76
|
||
77
|
||
78
|
||
79
|
||
80
|
||
81
|
||
82
|
||
83
|
||
84
|
||
85
|
||
86
|
||
87
|
||
88
|
||
89
|
||
90
|
||
91
|
||
92
|
||
93
|
||
94
|
||
95
|
||
96
|
||
97
|
||
98
|
||
99
|
||
100
|
||
101
|
||
102
|
||
103
|
||
104
|
||
105
|
||
106
|
||
107
|
||
108
|
||
109
|
||
110
|
||
111
|
||
112
|
||
113
|
||
114
|
||
115
|
||
116
|
||
117
|
||
118
|
||
119
|
||
120
|
||
121
|
||
122
|
||
123
|
||
124
|
||
125
|
||
126
|
||
127
|
||
128
|
||
129
|
||
130
|
||
131
|
||
132
|
||
133
|
||
134
|
||
135
|
||
136
|
||
137
|
||
138
|
||
139
|
||
140
|
||
141
|
||
142
|
||
143
|
||
144
|
||
145
|
||
146
|
||
147
|
||
148
|
||
149
|
||
150
|
||
151
|
||
152
|
||
153
|
||
154
|
||
155
|
||
156
|
||
157
|
||
158
|
||
159
|
||
160
|
||
161
|
||
162
|
||
163
|
||
164
|
||
165
|
||
166
|
||
167
|
||
168
|
||
169
|
||
170
|
||
171
|
||
172
|
||
173
|
||
174
|
||
175
|
||
176
|
||
177
|
||
178
|
||
179
|
||
180
|
||
181
|
||
182
|
||
183
|
||
184
|
||
185
|
||
186
|
||
187
|
||
188
|
||
189
|
||
190
|
||
191
|
||
192
|
||
193
|
||
194
|
||
195
|
||
196
|
||
197
|
||
198
|
||
199
|
||
200
|
||
201
|
||
202
|
||
203
|
||
204
|
||
205
|
||
206
|
||
207
|
||
208
|
||
209
|
||
210
|
||
211
|
||
212
|
||
213
|
||
214
|
||
215
|
||
216
|
||
217
|
||
218
|
||
219
|
||
220
|
||
221
|
||
222
|
||
223
|
||
224
|
||
225
|
||
226
|
||
227
|
||
228
|
||
229
|
||
230
|
||
231
|
||
232
|
||
233
|
||
234
|
||
235
|
||
236
|
||
237
|
||
238
|
||
239
|
||
240
|
||
241
|
||
242
|
||
243
|
||
244
|
||
245
|
||
246
|
||
247
|
||
248
|
||
249
|
||
250
|
||
251
|
||
252
|
||
253
|
||
254</td><td class="line-coverage quiet"><span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">1×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">1×</span>
|
||
<span class="cline-any cline-yes">1×</span>
|
||
<span class="cline-any cline-yes">1×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">1×</span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-yes">1×</span>
|
||
<span class="cline-any cline-yes">1×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">6×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">1×</span>
|
||
<span class="cline-any cline-yes">6×</span>
|
||
<span class="cline-any cline-yes">6×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">1×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">13×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">13×</span>
|
||
<span class="cline-any cline-yes">13×</span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">13×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">13×</span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">6×</span>
|
||
<span class="cline-any cline-yes">6×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">6×</span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">6×</span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">6×</span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">6×</span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">6×</span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">6×</span>
|
||
<span class="cline-any cline-yes">6×</span>
|
||
<span class="cline-any cline-yes">6×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">13×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">13×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">10×</span>
|
||
<span class="cline-any cline-yes">10×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">13×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">3×</span>
|
||
<span class="cline-any cline-yes">3×</span>
|
||
<span class="cline-any cline-yes">3×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">13×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">13×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">13×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">6×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">6×</span>
|
||
<span class="cline-any cline-yes">6×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">6×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">13×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-no"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">7×</span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-neutral"> </span>
|
||
<span class="cline-any cline-yes">1×</span>
|
||
<span class="cline-any cline-neutral"> </span></td><td class="text"><pre class="prettyprint lang-js">'use strict';
|
||
|
||
const net = require('net'),
|
||
tls = require('tls'),
|
||
eventParser = require('./eventParser.js'),
|
||
Message = require('js-message'),
|
||
fs = require('fs'),
|
||
Queue = require('js-queue');
|
||
|
||
let Events = require('event-pubsub/es5');
|
||
<span class="missing-if-branch" title="else path not taken" >E</span>if(process.version[1]>4){
|
||
Events = require('event-pubsub');
|
||
}
|
||
|
||
class Client extends Events{
|
||
constructor(config,log){
|
||
super();
|
||
Object.assign(
|
||
this,
|
||
{
|
||
Client : Client,
|
||
config : config,
|
||
queue : new Queue,
|
||
socket : false,
|
||
connect : connect,
|
||
emit : emit,
|
||
log : log,
|
||
retriesRemaining:config.maxRetries||<span class="branch-1 cbranch-no" title="branch not covered" >0,</span>
|
||
explicitlyDisconnected: false
|
||
}
|
||
);
|
||
}
|
||
}
|
||
|
||
function emit(type,data){
|
||
this.log('dispatching event to ', this.id, this.path, ' : ', type, ',', data);
|
||
|
||
let message=new Message;
|
||
message.type=type;
|
||
message.data=data;
|
||
|
||
<span class="missing-if-branch" title="if path not taken" >I</span>if(this.config.rawBuffer){
|
||
<span class="cstat-no" title="statement not covered" > message=new Buffer(type,this.config.encoding);</span>
|
||
}else{
|
||
message=eventParser.format(message);
|
||
}
|
||
|
||
if(!this.config.sync){
|
||
this.socket.write(message);
|
||
return;
|
||
}
|
||
|
||
this.queue.add(
|
||
syncEmit.bind(this,message)
|
||
);
|
||
}
|
||
|
||
function syncEmit(message){
|
||
this.log('dispatching event to ', this.id, this.path, ' : ', message);
|
||
this.socket.write(message);
|
||
}
|
||
|
||
function connect(){
|
||
//init client object for scope persistance especially inside of socket events.
|
||
let client=this;
|
||
|
||
client.log('requested connection to ', client.id, client.path);
|
||
<span class="missing-if-branch" title="if path not taken" >I</span>if(!this.path){
|
||
<span class="cstat-no" title="statement not covered" > client.log('\n\n######\nerror: ', client.id ,' client has not specified socket path it wishes to connect to.');</span>
|
||
<span class="cstat-no" title="statement not covered" > return;</span>
|
||
}
|
||
|
||
const options={};
|
||
|
||
if(!client.port){
|
||
client.log('Connecting client on Unix Socket :', client.path);
|
||
|
||
options.path=client.path;
|
||
|
||
<span class="missing-if-branch" title="if path not taken" >I</span>if (process.platform ==='win32' && <span class="branch-1 cbranch-no" title="branch not covered" >!client.path.startsWith('\\\\.\\pipe\\'))</span>{
|
||
<span class="cstat-no" title="statement not covered" > options.path = options.path.replace(/^\//, '');</span>
|
||
<span class="cstat-no" title="statement not covered" > options.path = options.path.replace(/\//g, '-');</span>
|
||
<span class="cstat-no" title="statement not covered" > options.path= `\\\\.\\pipe\\${options.path}`;</span>
|
||
}
|
||
|
||
client.socket = net.connect(options);
|
||
}else{
|
||
options.host=client.path;
|
||
options.port=client.port;
|
||
|
||
<span class="missing-if-branch" title="if path not taken" >I</span>if(client.config.interface.localAddress){
|
||
<span class="cstat-no" title="statement not covered" > options.localAddress=client.config.interface.localAddress;</span>
|
||
}
|
||
|
||
<span class="missing-if-branch" title="if path not taken" >I</span>if(client.config.interface.localPort){
|
||
<span class="cstat-no" title="statement not covered" > options.localPort=client.config.interface.localPort;</span>
|
||
}
|
||
|
||
<span class="missing-if-branch" title="if path not taken" >I</span>if(client.config.interface.family){
|
||
<span class="cstat-no" title="statement not covered" > options.family=client.config.interface.family;</span>
|
||
}
|
||
|
||
<span class="missing-if-branch" title="if path not taken" >I</span>if(client.config.interface.hints){
|
||
<span class="cstat-no" title="statement not covered" > options.hints=client.config.interface.hints;</span>
|
||
}
|
||
|
||
<span class="missing-if-branch" title="if path not taken" >I</span>if(client.config.interface.lookup){
|
||
<span class="cstat-no" title="statement not covered" > options.lookup=client.config.interface.lookup;</span>
|
||
}
|
||
|
||
<span class="missing-if-branch" title="else path not taken" >E</span>if(!client.config.tls){
|
||
client.log('Connecting client via TCP to', options);
|
||
client.socket = net.connect(options);
|
||
}else{
|
||
<span class="cstat-no" title="statement not covered" > client.log('Connecting client via TLS to', client.path ,client.port,client.config.tls);</span>
|
||
<span class="cstat-no" title="statement not covered" > if(client.config.tls.private){</span>
|
||
<span class="cstat-no" title="statement not covered" > client.config.tls.key=fs.readFileSync(client.config.tls.private);</span>
|
||
}
|
||
<span class="cstat-no" title="statement not covered" > if(client.config.tls.public){</span>
|
||
<span class="cstat-no" title="statement not covered" > client.config.tls.cert=fs.readFileSync(client.config.tls.public);</span>
|
||
}
|
||
<span class="cstat-no" title="statement not covered" > if(client.config.tls.trustedConnections){</span>
|
||
<span class="cstat-no" title="statement not covered" > if(typeof client.config.tls.trustedConnections === 'string'){</span>
|
||
<span class="cstat-no" title="statement not covered" > client.config.tls.trustedConnections=[client.config.tls.trustedConnections];</span>
|
||
}
|
||
<span class="cstat-no" title="statement not covered" > client.config.tls.ca=[];</span>
|
||
<span class="cstat-no" title="statement not covered" > for(let i=0; i<client.config.tls.trustedConnections.length; i++){</span>
|
||
<span class="cstat-no" title="statement not covered" > client.config.tls.ca.push(</span>
|
||
fs.readFileSync(client.config.tls.trustedConnections[i])
|
||
);
|
||
}
|
||
}
|
||
|
||
<span class="cstat-no" title="statement not covered" > Object.assign(client.config.tls,options);</span>
|
||
|
||
<span class="cstat-no" title="statement not covered" > client.socket = tls.connect(</span>
|
||
client.config.tls
|
||
);
|
||
}
|
||
}
|
||
|
||
client.socket.setEncoding(this.config.encoding);
|
||
|
||
client.socket.on(
|
||
'error',
|
||
function(err){
|
||
client.log('\n\n######\nerror: ', err);
|
||
client.publish('error', err);
|
||
|
||
}
|
||
);
|
||
|
||
client.socket.on(
|
||
'connect',
|
||
function connectionMade(){
|
||
client.publish('connect');
|
||
client.retriesRemaining=client.config.maxRetries;
|
||
client.log('retrying reset');
|
||
}
|
||
);
|
||
|
||
client.socket.on(
|
||
'close',
|
||
function connectionClosed(){
|
||
client.log('connection closed' ,client.id , client.path,
|
||
client.retriesRemaining, 'tries remaining of', client.config.maxRetries
|
||
);
|
||
|
||
if(
|
||
client.config.stopRetrying ||
|
||
client.retriesRemaining<1 ||
|
||
client.explicitlyDisconnected
|
||
|
||
){
|
||
client.publish('disconnect');
|
||
client.log(
|
||
(client.config.id),
|
||
'exceeded connection rety amount of',
|
||
' or stopRetrying flag set.'
|
||
);
|
||
|
||
client.socket.destroy();
|
||
client.publish('destroy');
|
||
client=undefined;
|
||
|
||
return;
|
||
}
|
||
|
||
setTimeout(
|
||
function retryTimeout(){
|
||
client.retriesRemaining--;
|
||
client.connect();
|
||
}.bind(null,client),
|
||
client.config.retry
|
||
);
|
||
|
||
client.publish('disconnect');
|
||
}
|
||
);
|
||
|
||
client.socket.on(
|
||
'data',
|
||
function(data) {
|
||
client.log('## received events ##');
|
||
<span class="missing-if-branch" title="if path not taken" >I</span>if(client.config.rawBuffer){
|
||
<span class="cstat-no" title="statement not covered" > client.publish(</span>
|
||
'data',
|
||
new Buffer(data,client.config.encoding)
|
||
);
|
||
<span class="cstat-no" title="statement not covered" > if(!client.config.sync){</span>
|
||
<span class="cstat-no" title="statement not covered" > return;</span>
|
||
}
|
||
|
||
<span class="cstat-no" title="statement not covered" > client.queue.next();</span>
|
||
<span class="cstat-no" title="statement not covered" > return;</span>
|
||
}
|
||
|
||
<span class="missing-if-branch" title="else path not taken" >E</span>if(!this.ipcBuffer){
|
||
this.ipcBuffer='';
|
||
}
|
||
|
||
data=(this.ipcBuffer+=data);
|
||
|
||
<span class="missing-if-branch" title="if path not taken" >I</span>if(data.slice(-1)!=eventParser.delimiter || data.indexOf(eventParser.delimiter) == -1){
|
||
<span class="cstat-no" title="statement not covered" > client.log('Messages are large, You may want to consider smaller messages.');</span>
|
||
<span class="cstat-no" title="statement not covered" > return;</span>
|
||
}
|
||
|
||
this.ipcBuffer='';
|
||
|
||
const events = eventParser.parse(data);
|
||
const eCount = events.length;
|
||
for(let i=0; i<eCount; i++){
|
||
let message=new Message;
|
||
message.load(events[i]);
|
||
|
||
client.log('detected event', message.type, message.data);
|
||
client.publish(
|
||
message.type,
|
||
message.data
|
||
);
|
||
}
|
||
|
||
<span class="missing-if-branch" title="if path not taken" >I</span>if(!client.config.sync){
|
||
<span class="cstat-no" title="statement not covered" > return;</span>
|
||
}
|
||
|
||
client.queue.next();
|
||
}
|
||
);
|
||
}
|
||
|
||
module.exports=Client;
|
||
</pre></td></tr>
|
||
</table></pre>
|
||
<div class='push'></div><!-- for sticky footer -->
|
||
</div><!-- /wrapper -->
|
||
<div class='footer quiet pad2 space-top1 center small'>
|
||
Code coverage
|
||
generated by <a href="http://istanbul-js.org/" target="_blank">istanbul</a> at Tue Feb 14 2017 04:00:04 GMT-0800 (PST)
|
||
</div>
|
||
</div>
|
||
<script src="../../prettify.js"></script>
|
||
<script>
|
||
window.onload = function () {
|
||
if (typeof prettyPrint === 'function') {
|
||
prettyPrint();
|
||
}
|
||
};
|
||
</script>
|
||
<script src="../../sorter.js"></script>
|
||
</body>
|
||
</html>
|