@@ -105,12 +105,28 @@ let buf = new Buffer(testfile)
105
105
apiClients[' a' ].add (buf, (err , res ) => {
106
106
if (err) throw err
107
107
// assert.equal(res.length, 1)
108
- const added = res[0 ] != null ? res[0 ] : res
108
+ const added = res[0 ] !== null ? res[0 ] : res
109
109
assert .equal (added .Hash , ' Qma4hjFTnCasJ8PVp3mZbZK5g2vGDT4LByLJ7m8ciyRFZP' )
110
110
done ()
111
111
})
112
112
```
113
113
114
+ add BIG buffer.
115
+
116
+ ``` js
117
+ if (! isNode) {
118
+ return done ()
119
+ }
120
+ this .timeout (10000 )
121
+ apiClients[' a' ].add (testfileBig, (err , res ) => {
122
+ if (err) throw err
123
+ // assert.equal(res.length, 1)
124
+ const added = res[0 ] !== null ? res[0 ] : res
125
+ assert .equal (added .Hash , ' Qme79tX2bViL26vNjPsF3DP1R9rMKMvnPYJiKTTKPrXJjq' )
126
+ done ()
127
+ })
128
+ ```
129
+
114
130
add path.
115
131
116
132
``` js
@@ -181,12 +197,6 @@ apiClients['a'].cat('Qma4hjFTnCasJ8PVp3mZbZK5g2vGDT4LByLJ7m8ciyRFZP', (err, res)
181
197
if (err) {
182
198
throw err
183
199
}
184
- if (! res .on ) {
185
- // Just a string
186
- assert .equal (res .toString (), testfile)
187
- done ()
188
- return
189
- }
190
200
let buf = ' '
191
201
res
192
202
.on (' error' , err => { throw err })
@@ -198,6 +208,27 @@ apiClients['a'].cat('Qma4hjFTnCasJ8PVp3mZbZK5g2vGDT4LByLJ7m8ciyRFZP', (err, res)
198
208
})
199
209
```
200
210
211
+ cat BIG file.
212
+
213
+ ``` js
214
+ if (! isNode) {
215
+ return done ()
216
+ }
217
+ this .timeout (1000000 )
218
+ apiClients[' a' ].cat (' Qme79tX2bViL26vNjPsF3DP1R9rMKMvnPYJiKTTKPrXJjq' , (err , res ) => {
219
+ if (err) {
220
+ throw err
221
+ }
222
+ testfileBig = require (' fs' ).createReadStream (__dirname + ' /15mb.random' , { bufferSize: 128 })
223
+ // Do not blow out the memory of nodejs :)
224
+ streamEqual (res, testfileBig, (err , equal ) => {
225
+ if (err) throw err
226
+ assert (equal)
227
+ done ()
228
+ })
229
+ })
230
+ ```
231
+
201
232
<a name =" ipfs-nodejs-api-wrapper-tests-ls " ></a >
202
233
## .ls
203
234
ls.
@@ -296,7 +327,7 @@ apiClients['c'].config.replace(__dirname + '/r-config.json', (err, res) => {
296
327
if (err) {
297
328
throw err
298
329
}
299
- assert .equal (res, ' ' )
330
+ assert .equal (res, null )
300
331
done ()
301
332
})
302
333
```
@@ -350,6 +381,20 @@ apiClients['a'].diag.net((err, res) => {
350
381
})
351
382
```
352
383
384
+ .diag.sys.
385
+
386
+ ``` js
387
+ apiClients[' a' ].diag .sys ((err , res ) => {
388
+ if (err) {
389
+ throw err
390
+ }
391
+ assert (res)
392
+ assert (res .memory )
393
+ assert (res .diskinfo )
394
+ done ()
395
+ })
396
+ ```
397
+
353
398
<a name =" ipfs-nodejs-api-wrapper-tests-block " ></a >
354
399
## .block
355
400
block.put.
@@ -370,12 +415,6 @@ block.get.
370
415
this .timeout (10000 )
371
416
apiClients[' a' ].block .get (blorbKey, (err , res ) => {
372
417
if (err) throw err
373
- if (! res .on ) {
374
- // Just a string
375
- assert .equal (res .toString (), ' blorb' )
376
- done ()
377
- return
378
- }
379
418
let buf = ' '
380
419
res
381
420
.on (' data' , function (data ) { buf += data })
@@ -420,12 +459,6 @@ object.data.
420
459
this .timeout (10000 )
421
460
apiClients[' a' ].object .data (testObjectHash, (err , res ) => {
422
461
if (err) throw err
423
- if (! res .on ) {
424
- // Just a string
425
- assert .equal (res .toString (), ' testdata' )
426
- done ()
427
- return
428
- }
429
462
let buf = ' '
430
463
res
431
464
.on (' error' , err => { throw err })
@@ -614,6 +647,22 @@ apiClients['b'].pin.remove('Qma4hjFTnCasJ8PVp3mZbZK5g2vGDT4LByLJ7m8ciyRFZP', {re
614
647
615
648
<a name =" ipfs-nodejs-api-wrapper-tests-log " ></a >
616
649
## .log
650
+ .log.tail.
651
+
652
+ ``` js
653
+ this .timeout (20000 )
654
+ apiClients[' a' ].log .tail ((err , res ) => {
655
+ if (err) {
656
+ throw err
657
+ }
658
+ res .once (' data' , obj => {
659
+ assert (obj)
660
+ assert .equal (typeof obj, ' object' )
661
+ done ()
662
+ })
663
+ })
664
+ ```
665
+
617
666
<a name =" ipfs-nodejs-api-wrapper-tests-name " ></a >
618
667
## .name
619
668
.name.publish.
@@ -702,6 +751,7 @@ apiClients['a'].dht.put('scope', 'interplanetary', (err, res) => {
702
751
if (err) {
703
752
throw err
704
753
}
754
+ assert .equal (typeof res, ' object' )
705
755
return done ()
706
756
// non ipns or pk hashes fail to fetch, known bug
707
757
// bug: https://github.com/ipfs/go-ipfs/issues/1923#issuecomment-152932234
@@ -723,6 +773,7 @@ apiClients['a'].dht.findprovs('Qma4hjFTnCasJ8PVp3mZbZK5g2vGDT4LByLJ7m8ciyRFZP',
723
773
if (err) {
724
774
throw err
725
775
}
776
+ assert .equal (typeof res, ' object' )
726
777
assert (res)
727
778
done ()
728
779
})
0 commit comments