Skip to content
This repository has been archived by the owner on Aug 11, 2021. It is now read-only.

Commit

Permalink
Order matters!
Browse files Browse the repository at this point in the history
  • Loading branch information
hackergrrl committed Apr 15, 2016
1 parent a907f86 commit f6abb63
Showing 1 changed file with 16 additions and 16 deletions.
32 changes: 16 additions & 16 deletions src/block-service.js
Original file line number Diff line number Diff line change
Expand Up @@ -26,15 +26,15 @@ function BlockService (ipfsRepo, exchange) {
}

this.getBlock = (multihash, extension, callback) => {
if (!multihash) {
return callback(new Error('Invalid multihash'))
}

if (typeof extension === 'function') {
callback = extension
extension = undefined
}

if (!multihash) {
return callback(new Error('Invalid multihash'))
}

ipfsRepo.datastore.createReadStream(multihash, extension)
.pipe(bl((err, data) => {
if (err) { return callback(err) }
Expand All @@ -43,15 +43,15 @@ function BlockService (ipfsRepo, exchange) {
}

this.getBlocks = (multihashes, extension, callback) => {
if (!Array.isArray(multihashes)) {
return callback(new Error('Invalid batch of multihashes'))
}

if (typeof extension === 'function') {
callback = extension
extension = undefined
}

if (!Array.isArray(multihashes)) {
return callback(new Error('Invalid batch of multihashes'))
}

const blocks = []

async.each(multihashes, (multihash, next) => {
Expand All @@ -65,28 +65,28 @@ function BlockService (ipfsRepo, exchange) {
}

this.deleteBlock = (multihash, extension, callback) => {
if (!multihash) {
return callback(new Error('Invalid multihash'))
}

if (typeof extension === 'function') {
callback = extension
extension = undefined
}

if (!multihash) {
return callback(new Error('Invalid multihash'))
}

ipfsRepo.datastore.remove(multihash, extension, callback)
}

this.deleteBlocks = (multihashes, extension, callback) => {
if (!Array.isArray(multihashes)) {
return callback('Invalid batch of multihashes')
}

if (typeof extension === 'function') {
callback = extension
extension = undefined
}

if (!Array.isArray(multihashes)) {
return callback('Invalid batch of multihashes')
}

async.each(multihashes, (multihash, next) => {
this.deleteBlock(multihash, extension, next)
}, (err) => {
Expand Down

0 comments on commit f6abb63

Please sign in to comment.