@@ -25,13 +25,17 @@ var _lodash = require('lodash');
25
25
26
26
var _lodash2 = _interopRequireDefault ( _lodash ) ;
27
27
28
+ var _debugnyan = require ( 'debugnyan' ) ;
29
+
30
+ var _debugnyan2 = _interopRequireDefault ( _debugnyan ) ;
31
+
28
32
var _methods = require ( './methods' ) ;
29
33
30
34
var _methods2 = _interopRequireDefault ( _methods ) ;
31
35
32
- var _request = require ( 'request' ) ;
36
+ var _requestLogger = require ( './logging/ request-logger ' ) ;
33
37
34
- var _request2 = _interopRequireDefault ( _request ) ;
38
+ var _requestLogger2 = _interopRequireDefault ( _requestLogger ) ;
35
39
36
40
var _semver = require ( 'semver' ) ;
37
41
@@ -76,26 +80,28 @@ const networks = {
76
80
77
81
class Client {
78
82
constructor ( ) {
79
- var _ref = arguments . length <= 0 || arguments [ 0 ] === undefined ? { } : arguments [ 0 ] ;
83
+ var _ref = arguments . length > 0 && arguments [ 0 ] !== undefined ? arguments [ 0 ] : { } ;
80
84
81
85
let agentOptions = _ref . agentOptions ;
82
86
var _ref$headers = _ref . headers ;
83
87
let headers = _ref$headers === undefined ? false : _ref$headers ;
84
88
var _ref$host = _ref . host ;
85
89
let host = _ref$host === undefined ? 'localhost' : _ref$host ;
90
+ var _ref$logger = _ref . logger ;
91
+ let logger = _ref$logger === undefined ? ( 0 , _debugnyan2 . default ) ( 'bitcoin-core' ) : _ref$logger ;
86
92
var _ref$network = _ref . network ;
87
- let network = _ref$network === undefined ? 'mainnet' : _ref$network ;
88
- let password = _ref . password ;
89
- let port = _ref . port ;
93
+ let network = _ref$network === undefined ? 'mainnet' : _ref$network ,
94
+ password = _ref . password ,
95
+ port = _ref . port ;
90
96
var _ref$ssl = _ref . ssl ;
91
97
let ssl = _ref$ssl === undefined ? false : _ref$ssl ;
92
98
var _ref$timeout = _ref . timeout ;
93
- let timeout = _ref$timeout === undefined ? 30000 : _ref$timeout ;
94
- let username = _ref . username ;
95
- let version = _ref . version ;
99
+ let timeout = _ref$timeout === undefined ? 30000 : _ref$timeout ,
100
+ username = _ref . username ,
101
+ version = _ref . version ;
96
102
97
103
if ( ! _lodash2 . default . has ( networks , network ) ) {
98
- throw new Error ( `Invalid network name "${ network } "` , { network : network } ) ;
104
+ throw new Error ( `Invalid network name "${ network } "` , { network : network } ) ;
99
105
}
100
106
101
107
this . agentOptions = agentOptions ;
@@ -114,12 +120,14 @@ class Client {
114
120
let unsupported = [ ] ;
115
121
116
122
if ( version ) {
117
- unsupported = _lodash2 . default . chain ( _methods2 . default ) . pickBy ( range => ! _semver2 . default . satisfies ( version , range ) ) . keys ( ) . invokeMap ( String . prototype . toLowerCase ) . value ( ) ;
123
+ unsupported = _lodash2 . default . chain ( _methods2 . default ) . pickBy ( method => ! _semver2 . default . satisfies ( version , method . version ) ) . keys ( ) . invokeMap ( String . prototype . toLowerCase ) . value ( ) ;
118
124
}
119
125
120
- this . request = _bluebird2 . default . promisifyAll ( _request2 . default . defaults ( {
126
+ const request = ( 0 , _requestLogger2 . default ) ( logger ) ;
127
+
128
+ this . request = _bluebird2 . default . promisifyAll ( request . defaults ( {
121
129
agentOptions : this . agentOptions ,
122
- baseUrl : `${ this . ssl . enabled ? 'https' : 'http' } ://${ this . host } :${ this . port } ` ,
130
+ baseUrl : `${ this . ssl . enabled ? 'https' : 'http' } ://${ this . host } :${ this . port } ` ,
123
131
json : true ,
124
132
strictSSL : this . ssl . strict ,
125
133
timeout : this . timeout
@@ -169,22 +177,20 @@ class Client {
169
177
*/
170
178
171
179
getTransactionByHash ( ) {
172
- var _source = source . apply ( undefined , arguments ) ;
173
-
174
- var _source2 = _slicedToArray ( _source , 2 ) ;
175
-
176
- var _source2$ = _slicedToArray ( _source2 [ 0 ] , 2 ) ;
180
+ var _source = source . apply ( undefined , arguments ) ,
181
+ _source2 = _slicedToArray ( _source , 2 ) ,
182
+ _source2$ = _slicedToArray ( _source2 [ 0 ] , 2 ) ;
177
183
178
184
const hash = _source2$ [ 0 ] ;
179
185
var _source2$$ = _source2$ [ 1 ] ;
180
186
_source2$$ = _source2$$ === undefined ? { } : _source2$$ ;
181
187
var _source2$$$extension = _source2$$ . extension ;
182
- const extension = _source2$$$extension === undefined ? 'json' : _source2$$$extension ;
183
- const callback = _source2 [ 1 ] ;
188
+ const extension = _source2$$$extension === undefined ? 'json' : _source2$$$extension ,
189
+ callback = _source2 [ 1 ] ;
184
190
185
191
186
192
return _bluebird2 . default . try ( ( ) => {
187
- return this . request . getAsync ( `/rest/tx/${ hash } .${ extension } ` ) . bind ( this ) . then ( this . parser . rest ) ;
193
+ return this . request . getAsync ( `/rest/tx/${ hash } .${ extension } ` ) . bind ( this ) . then ( this . parser . rest ) ;
188
194
} ) . asCallback ( callback ) ;
189
195
}
190
196
@@ -195,24 +201,22 @@ class Client {
195
201
*/
196
202
197
203
getBlockByHash ( ) {
198
- var _source3 = source . apply ( undefined , arguments ) ;
199
-
200
- var _source4 = _slicedToArray ( _source3 , 2 ) ;
201
-
202
- var _source4$ = _slicedToArray ( _source4 [ 0 ] , 2 ) ;
204
+ var _source3 = source . apply ( undefined , arguments ) ,
205
+ _source4 = _slicedToArray ( _source3 , 2 ) ,
206
+ _source4$ = _slicedToArray ( _source4 [ 0 ] , 2 ) ;
203
207
204
208
const hash = _source4$ [ 0 ] ;
205
209
var _source4$$ = _source4$ [ 1 ] ;
206
210
_source4$$ = _source4$$ === undefined ? { } : _source4$$ ;
207
211
var _source4$$$summary = _source4$$ . summary ;
208
212
const summary = _source4$$$summary === undefined ? false : _source4$$$summary ;
209
213
var _source4$$$extension = _source4$$ . extension ;
210
- const extension = _source4$$$extension === undefined ? 'json' : _source4$$$extension ;
211
- const callback = _source4 [ 1 ] ;
214
+ const extension = _source4$$$extension === undefined ? 'json' : _source4$$$extension ,
215
+ callback = _source4 [ 1 ] ;
212
216
213
217
214
218
return _bluebird2 . default . try ( ( ) => {
215
- return this . request . getAsync ( `/rest/block${ summary ? '/notxdetails/' : '/' } ${ hash } .${ extension } ` ) . bind ( this ) . then ( this . parser . rest ) ;
219
+ return this . request . getAsync ( `/rest/block${ summary ? '/notxdetails/' : '/' } ${ hash } .${ extension } ` ) . bind ( this ) . then ( this . parser . rest ) ;
216
220
} ) . asCallback ( callback ) ;
217
221
}
218
222
@@ -221,27 +225,25 @@ class Client {
221
225
*/
222
226
223
227
getBlockHeadersByHash ( ) {
224
- var _source5 = source . apply ( undefined , arguments ) ;
228
+ var _source5 = source . apply ( undefined , arguments ) ,
229
+ _source6 = _slicedToArray ( _source5 , 2 ) ,
230
+ _source6$ = _slicedToArray ( _source6 [ 0 ] , 3 ) ;
225
231
226
- var _source6 = _slicedToArray ( _source5 , 2 ) ;
227
-
228
- var _source6$ = _slicedToArray ( _source6 [ 0 ] , 3 ) ;
229
-
230
- const hash = _source6$ [ 0 ] ;
231
- const count = _source6$ [ 1 ] ;
232
+ const hash = _source6$ [ 0 ] ,
233
+ count = _source6$ [ 1 ] ;
232
234
var _source6$$ = _source6$ [ 2 ] ;
233
235
_source6$$ = _source6$$ === undefined ? { } : _source6$$ ;
234
236
var _source6$$$extension = _source6$$ . extension ;
235
- const extension = _source6$$$extension === undefined ? 'json' : _source6$$$extension ;
236
- const callback = _source6 [ 1 ] ;
237
+ const extension = _source6$$$extension === undefined ? 'json' : _source6$$$extension ,
238
+ callback = _source6 [ 1 ] ;
237
239
238
240
239
241
return _bluebird2 . default . try ( ( ) => {
240
242
if ( ! _lodash2 . default . includes ( [ 'bin' , 'hex' ] , extension ) ) {
241
- throw new Error ( `Extension "${ extension } " is not supported` ) ;
243
+ throw new Error ( `Extension "${ extension } " is not supported` ) ;
242
244
}
243
245
244
- return this . request . getAsync ( `/rest/headers/${ count } /${ hash } .${ extension } ` ) . bind ( this ) . then ( this . parser . rest ) ;
246
+ return this . request . getAsync ( `/rest/headers/${ count } /${ hash } .${ extension } ` ) . bind ( this ) . then ( this . parser . rest ) ;
245
247
} ) . asCallback ( callback ) ;
246
248
}
247
249
@@ -251,9 +253,8 @@ class Client {
251
253
*/
252
254
253
255
getBlockchainInformation ( ) {
254
- var _source7 = source . apply ( undefined , arguments ) ;
255
-
256
- var _source8 = _slicedToArray ( _source7 , 2 ) ;
256
+ var _source7 = source . apply ( undefined , arguments ) ,
257
+ _source8 = _slicedToArray ( _source7 , 2 ) ;
257
258
258
259
const callback = _source8 [ 1 ] ;
259
260
@@ -268,25 +269,23 @@ class Client {
268
269
*/
269
270
270
271
getUnspentTransactionOutputs ( ) {
271
- var _source9 = source . apply ( undefined , arguments ) ;
272
-
273
- var _source10 = _slicedToArray ( _source9 , 2 ) ;
274
-
275
- var _source10$ = _slicedToArray ( _source10 [ 0 ] , 2 ) ;
272
+ var _source9 = source . apply ( undefined , arguments ) ,
273
+ _source10 = _slicedToArray ( _source9 , 2 ) ,
274
+ _source10$ = _slicedToArray ( _source10 [ 0 ] , 2 ) ;
276
275
277
276
const outpoints = _source10$ [ 0 ] ;
278
277
var _source10$$ = _source10$ [ 1 ] ;
279
278
_source10$$ = _source10$$ === undefined ? { } : _source10$$ ;
280
279
var _source10$$$extension = _source10$$ . extension ;
281
- const extension = _source10$$$extension === undefined ? 'json' : _source10$$$extension ;
282
- const callback = _source10 [ 1 ] ;
280
+ const extension = _source10$$$extension === undefined ? 'json' : _source10$$$extension ,
281
+ callback = _source10 [ 1 ] ;
283
282
284
283
285
284
const sets = _lodash2 . default . flatten ( [ outpoints ] ) . map ( outpoint => {
286
- return `${ outpoint . id } -${ outpoint . index } ` ;
285
+ return `${ outpoint . id } -${ outpoint . index } ` ;
287
286
} ) . join ( '/' ) ;
288
287
289
- return this . request . getAsync ( `/rest/getutxos/checkmempool/${ sets } .${ extension } ` ) . bind ( this ) . then ( this . parser . rest ) . asCallback ( callback ) ;
288
+ return this . request . getAsync ( `/rest/getutxos/checkmempool/${ sets } .${ extension } ` ) . bind ( this ) . then ( this . parser . rest ) . asCallback ( callback ) ;
290
289
}
291
290
292
291
/**
@@ -295,9 +294,8 @@ class Client {
295
294
*/
296
295
297
296
getMemoryPoolContent ( ) {
298
- var _source11 = source . apply ( undefined , arguments ) ;
299
-
300
- var _source12 = _slicedToArray ( _source11 , 2 ) ;
297
+ var _source11 = source . apply ( undefined , arguments ) ,
298
+ _source12 = _slicedToArray ( _source11 , 2 ) ;
301
299
302
300
const callback = _source12 [ 1 ] ;
303
301
@@ -315,9 +313,8 @@ class Client {
315
313
*/
316
314
317
315
getMemoryPoolInformation ( ) {
318
- var _source13 = source . apply ( undefined , arguments ) ;
319
-
320
- var _source14 = _slicedToArray ( _source13 , 2 ) ;
316
+ var _source13 = source . apply ( undefined , arguments ) ,
317
+ _source14 = _slicedToArray ( _source13 , 2 ) ;
321
318
322
319
const callback = _source14 [ 1 ] ;
323
320
0 commit comments