diff --git a/src/pin/ls.js b/src/pin/ls.js index f06ce2d262..c9542071c1 100644 --- a/src/pin/ls.js +++ b/src/pin/ls.js @@ -1,7 +1,7 @@ /* eslint-env mocha */ 'use strict' -const parallel = require('async/parallel') +const series = require('async/series') const { fixtures } = require('./utils') const { getDescribe, getIt, expect } = require('../utils/mocha') @@ -30,19 +30,11 @@ module.exports = (createCommon, options) => { }) function populate () { - parallel([ - (cb) => { - ipfs.add(fixtures.files[0].data, { pin: false }, (err, res) => { - if (err) return cb(err) - ipfs.pin.add(fixtures.files[0].cid, { recursive: true }, cb) - }) - }, - (cb) => { - ipfs.add(fixtures.files[1].data, { pin: false }, (err, res) => { - if (err) return cb(err) - ipfs.pin.add(fixtures.files[1].cid, { recursive: false }, cb) - }) - } + series([ + cb => ipfs.add(fixtures.files[0].data, { pin: false }, cb), + cb => ipfs.pin.add(fixtures.files[0].cid, { recursive: true }, cb), + cb => ipfs.add(fixtures.files[1].data, { pin: false }, cb), + cb => ipfs.pin.add(fixtures.files[1].cid, { recursive: false }, cb) ], done) } }) diff --git a/src/pin/rm.js b/src/pin/rm.js index f25dbcc190..ba88b66f94 100644 --- a/src/pin/rm.js +++ b/src/pin/rm.js @@ -1,7 +1,7 @@ /* eslint-env mocha */ 'use strict' -const parallel = require('async/parallel') +const series = require('async/series') const { fixtures } = require('./utils') const { getDescribe, getIt, expect } = require('../utils/mocha') @@ -30,19 +30,11 @@ module.exports = (createCommon, options) => { }) function populate () { - parallel([ - (cb) => { - ipfs.add(fixtures.files[0].data, { pin: false }, (err, res) => { - if (err) return cb(err) - ipfs.pin.add(fixtures.files[0].cid, { recursive: true }, cb) - }) - }, - (cb) => { - ipfs.add(fixtures.files[1].data, { pin: false }, (err, res) => { - if (err) return cb(err) - ipfs.pin.add(fixtures.files[1].cid, { recursive: false }, cb) - }) - } + series([ + cb => ipfs.add(fixtures.files[0].data, { pin: false }, cb), + cb => ipfs.pin.add(fixtures.files[0].cid, { recursive: true }, cb), + cb => ipfs.add(fixtures.files[1].data, { pin: false }, cb), + cb => ipfs.pin.add(fixtures.files[1].cid, { recursive: false }, cb) ], done) } })