@@ -26,15 +26,15 @@ function BlockService (ipfsRepo, exchange) {
26
26
}
27
27
28
28
this . getBlock = ( multihash , extension , callback ) => {
29
- if ( ! multihash ) {
30
- return callback ( new Error ( 'Invalid multihash' ) )
31
- }
32
-
33
29
if ( typeof extension === 'function' ) {
34
30
callback = extension
35
31
extension = undefined
36
32
}
37
33
34
+ if ( ! multihash ) {
35
+ return callback ( new Error ( 'Invalid multihash' ) )
36
+ }
37
+
38
38
ipfsRepo . datastore . createReadStream ( multihash , extension )
39
39
. pipe ( bl ( ( err , data ) => {
40
40
if ( err ) { return callback ( err ) }
@@ -43,15 +43,15 @@ function BlockService (ipfsRepo, exchange) {
43
43
}
44
44
45
45
this . getBlocks = ( multihashes , extension , callback ) => {
46
- if ( ! Array . isArray ( multihashes ) ) {
47
- return callback ( new Error ( 'Invalid batch of multihashes' ) )
48
- }
49
-
50
46
if ( typeof extension === 'function' ) {
51
47
callback = extension
52
48
extension = undefined
53
49
}
54
50
51
+ if ( ! Array . isArray ( multihashes ) ) {
52
+ return callback ( new Error ( 'Invalid batch of multihashes' ) )
53
+ }
54
+
55
55
const blocks = [ ]
56
56
57
57
async . each ( multihashes , ( multihash , next ) => {
@@ -65,28 +65,28 @@ function BlockService (ipfsRepo, exchange) {
65
65
}
66
66
67
67
this . deleteBlock = ( multihash , extension , callback ) => {
68
- if ( ! multihash ) {
69
- return callback ( new Error ( 'Invalid multihash' ) )
70
- }
71
-
72
68
if ( typeof extension === 'function' ) {
73
69
callback = extension
74
70
extension = undefined
75
71
}
76
72
73
+ if ( ! multihash ) {
74
+ return callback ( new Error ( 'Invalid multihash' ) )
75
+ }
76
+
77
77
ipfsRepo . datastore . remove ( multihash , extension , callback )
78
78
}
79
79
80
80
this . deleteBlocks = ( multihashes , extension , callback ) => {
81
- if ( ! Array . isArray ( multihashes ) ) {
82
- return callback ( 'Invalid batch of multihashes' )
83
- }
84
-
85
81
if ( typeof extension === 'function' ) {
86
82
callback = extension
87
83
extension = undefined
88
84
}
89
85
86
+ if ( ! Array . isArray ( multihashes ) ) {
87
+ return callback ( 'Invalid batch of multihashes' )
88
+ }
89
+
90
90
async . each ( multihashes , ( multihash , next ) => {
91
91
this . deleteBlock ( multihash , extension , next )
92
92
} , ( err ) => {
0 commit comments