Mirroristas/orbitdb
2
0
Fork 0
mirror of https://github.com/orbitdb/orbitdb.git synced 2025-10-07 22:57:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Make timeouts per request in IPFSBlockStorage

Browse Source
This commit is contained in:
haad
2024-01-16 11:38:14 +02:00
parent 4a1f5cba33
commit 056e4e185f
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/storage/ipfs-block.js
View File

@@ -27,8 +27,6 @@ const DefaultTimeout = 30000 // 30 seconds
const IPFSBlockStorage = async ({ ipfs, pin, timeout } = {}) => {
if (!ipfs) throw new Error('An instance of ipfs is required.')
const { signal } = new TimeoutController(timeout || DefaultTimeout)
/**
* Puts data to an IPFS block.
* @function
@@ -39,6 +37,7 @@ const IPFSBlockStorage = async ({ ipfs, pin, timeout } = {}) => {
*/
const put = async (hash, data) => {
const cid = CID.parse(hash, base58btc)
const { signal } = new TimeoutController(timeout || DefaultTimeout)
await ipfs.blockstore.put(cid, data, { signal })
if (pin && !(await ipfs.pins.isPinned(cid))) {
@@ -58,6 +57,7 @@ const IPFSBlockStorage = async ({ ipfs, pin, timeout } = {}) => {
*/
const get = async (hash) => {
const cid = CID.parse(hash, base58btc)
const { signal } = new TimeoutController(timeout || DefaultTimeout)
const block = await ipfs.blockstore.get(cid, { signal })
if (block) {
return block