Skip to content
This repository was archived by the owner on Mar 10, 2020. It is now read-only.

Commit fee0eed

Browse files
author
Alan Shaw
committed
fix: tests
License: MIT Signed-off-by: Alan Shaw <[email protected]>
1 parent 956a5af commit fee0eed

File tree

2 files changed

+52
-64
lines changed

2 files changed

+52
-64
lines changed

src/files-regular/index.js

Lines changed: 51 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,62 @@
11
'use strict'
22

3+
const nodeify = require('promise-nodeify')
34
const moduleConfig = require('../utils/module-config')
5+
const { collectify, pullify, streamify } = require('../lib/converters')
46

57
module.exports = (arg) => {
68
const send = moduleConfig(arg)
79

810
return {
11+
add: (_, config) => {
12+
const add = collectify(require('../add')(config))
13+
return (input, options, callback) => {
14+
if (typeof options === 'function') {
15+
callback = options
16+
options = {}
17+
}
18+
return nodeify(add(input, options), callback)
19+
}
20+
},
21+
addReadableStream: (_, config) => {
22+
const add = require('../add')(config)
23+
return streamify.transform(add)
24+
},
25+
addPullStream: (_, config) => {
26+
const add = require('../add')(config)
27+
return pullify.transform(add)
28+
},
29+
addFromFs: (_, config) => {
30+
const addFromFs = collectify(require('../add-from-fs')(config))
31+
return (path, options, callback) => {
32+
if (typeof options === 'function') {
33+
callback = options
34+
options = {}
35+
}
36+
return nodeify(addFromFs(path, options), callback)
37+
}
38+
},
39+
addFromURL: (_, config) => {
40+
const addFromURL = collectify(require('../add-from-url')(config))
41+
return (url, options, callback) => {
42+
if (typeof options === 'function') {
43+
callback = options
44+
options = {}
45+
}
46+
return nodeify(addFromURL(url, options), callback)
47+
}
48+
},
49+
addFromStream: (_, config) => {
50+
const add = collectify(require('../add')(config))
51+
return (input, options, callback) => {
52+
if (typeof options === 'function') {
53+
callback = options
54+
options = {}
55+
}
56+
return nodeify(add(input, options), callback)
57+
}
58+
},
59+
_addAsyncIterator: (_, config) => require('../add')(config),
960
cat: require('../files-regular/cat')(send),
1061
catReadableStream: require('../files-regular/cat-readable-stream')(send),
1162
catPullStream: require('../files-regular/cat-pull-stream')(send),

src/utils/load-commands.js

Lines changed: 1 addition & 64 deletions
Original file line numberDiff line numberDiff line change
@@ -1,72 +1,9 @@
11
'use strict'
22

3-
const nodeify = require('promise-nodeify')
4-
const { collectify, pullify, streamify } = require('../lib/converters')
5-
63
function requireCommands () {
74
return {
85
// Files Regular (not MFS)
9-
add: (_, config) => {
10-
const add = collectify(require('../add')(config))
11-
return (input, options, callback) => {
12-
if (typeof options === 'function') {
13-
callback = options
14-
options = {}
15-
}
16-
return nodeify(add(input, options), callback)
17-
}
18-
},
19-
addReadableStream: (_, config) => {
20-
const add = require('../add')(config)
21-
return streamify.transform(add)
22-
},
23-
addPullStream: (_, config) => {
24-
const add = require('../add')(config)
25-
return pullify.transform(add)
26-
},
27-
addFromFs: (_, config) => {
28-
const addFromFs = collectify(require('../add-from-fs')(config))
29-
return (path, options, callback) => {
30-
if (typeof options === 'function') {
31-
callback = options
32-
options = {}
33-
}
34-
return nodeify(addFromFs(path, options), callback)
35-
}
36-
},
37-
addFromURL: (_, config) => {
38-
const addFromURL = collectify(require('../add-from-url')(config))
39-
return (url, options, callback) => {
40-
if (typeof options === 'function') {
41-
callback = options
42-
options = {}
43-
}
44-
return nodeify(addFromURL(url, options), callback)
45-
}
46-
},
47-
addFromStream: (_, config) => {
48-
const add = collectify(require('../add')(config))
49-
return (input, options, callback) => {
50-
if (typeof options === 'function') {
51-
callback = options
52-
options = {}
53-
}
54-
return nodeify(add(input, options), callback)
55-
}
56-
},
57-
_addAsyncIterator: (_, config) => require('../add')(config),
58-
cat: require('../files-regular/cat'),
59-
catReadableStream: require('../files-regular/cat-readable-stream'),
60-
catPullStream: require('../files-regular/cat-pull-stream'),
61-
get: require('../files-regular/get'),
62-
getReadableStream: require('../files-regular/get-readable-stream'),
63-
getPullStream: require('../files-regular/get-pull-stream'),
64-
ls: require('../files-regular/ls'),
65-
lsReadableStream: require('../files-regular/ls-readable-stream'),
66-
lsPullStream: require('../files-regular/ls-pull-stream'),
67-
refs: require('../files-regular/refs'),
68-
refsReadableStream: require('../files-regular/refs-readable-stream'),
69-
refsPullStream: require('../files-regular/refs-pull-stream'),
6+
...require('../files-regular'),
707

718
// Files MFS (Mutable Filesystem)
729
files: require('../files-mfs'),

0 commit comments

Comments
 (0)