forked from ipfs/js-ipfs
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathappend-data.js
32 lines (27 loc) · 966 Bytes
/
append-data.js
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
'use strict'
const CID = require('cids')
const multipartRequest = require('../../lib/multipart-request')
const configure = require('../../lib/configure')
const toUrlSearchParams = require('../../lib/to-url-search-params')
const anySignal = require('any-signal')
const { AbortController } = require('abort-controller')
module.exports = configure(api => {
return async (cid, data, options = {}) => {
// allow aborting requests on body errors
const controller = new AbortController()
const signal = anySignal([controller.signal, options.signal])
const res = await api.post('object/patch/append-data', {
timeout: options.timeout,
signal,
searchParams: toUrlSearchParams({
arg: `${cid instanceof Uint8Array ? new CID(cid) : cid}`,
...options
}),
...(
await multipartRequest(data, controller, options.headers)
)
})
const { Hash } = await res.json()
return new CID(Hash)
}
})