@@ -21,9 +21,9 @@ const semaphore = require('semaphore')
21
21
22
22
// promisify a function: resolves this promise if callback is called
23
23
function promisify ( func : Function ) {
24
- return function ( ) {
24
+ return function ( ) {
25
25
return new Promise ( ( resolve , reject ) => {
26
- func ( function ( err : any , value : any ) {
26
+ func ( function ( err : any , value : any ) {
27
27
if ( err ) {
28
28
reject ( err )
29
29
} else {
@@ -269,19 +269,19 @@ export default class Blockchain implements BlockchainInterface {
269
269
_init ( cb : any ) : void {
270
270
const self = this
271
271
new Promise ( ( resolve , reject ) => {
272
- self . _numberToHash ( new BN ( 0 ) , function ( error : any , hash : any ) {
272
+ self . _numberToHash ( new BN ( 0 ) , function ( error : any , hash : any ) {
273
273
if ( error ) {
274
274
reject ( error )
275
275
} else {
276
276
resolve ( hash )
277
277
}
278
278
} )
279
279
} )
280
- . then ( async function ( hash ) {
280
+ . then ( async function ( hash ) {
281
281
await getHeads ( hash )
282
282
cb ( )
283
283
} )
284
- . catch ( function ( err ) {
284
+ . catch ( function ( err ) {
285
285
self . _setCanonicalGenesisBlock ( ( err ?: any ) => {
286
286
if ( err ) {
287
287
return cb ( err )
@@ -409,7 +409,7 @@ export default class Blockchain implements BlockchainInterface {
409
409
const self = this
410
410
async function _putBlock ( block : any ) : Promise < any > {
411
411
return await new Promise ( ( resolve , reject ) => {
412
- self . putBlock ( block , function ( err : any , block : any ) {
412
+ self . putBlock ( block , function ( err : any , block : any ) {
413
413
resolve ( [ err , block ] )
414
414
} )
415
415
} )
@@ -456,7 +456,7 @@ export default class Blockchain implements BlockchainInterface {
456
456
const self = this
457
457
async function _putHeader ( block : any ) : Promise < any > {
458
458
return await new Promise ( ( resolve , reject ) => {
459
- self . putHeader ( block , function ( err : any , block : any ) {
459
+ self . putHeader ( block , function ( err : any , block : any ) {
460
460
resolve ( [ err , block ] )
461
461
} )
462
462
} )
@@ -533,9 +533,9 @@ export default class Blockchain implements BlockchainInterface {
533
533
. then ( promisify ( getCurrentTd ) )
534
534
. then ( promisify ( getBlockTd ) )
535
535
. then ( promisify ( rebuildInfo ) )
536
- . then ( function ( ) {
536
+ . then ( function ( ) {
537
537
return new Promise ( ( resolve , reject ) => {
538
- self . _batchDbOps ( dbOps . concat ( self . _saveHeadOps ( ) ) , function ( err : any ) {
538
+ self . _batchDbOps ( dbOps . concat ( self . _saveHeadOps ( ) ) , function ( err : any ) {
539
539
if ( err ) {
540
540
reject ( err )
541
541
} else {
@@ -544,10 +544,10 @@ export default class Blockchain implements BlockchainInterface {
544
544
} )
545
545
} )
546
546
} )
547
- . then ( function ( ) {
547
+ . then ( function ( ) {
548
548
cb ( )
549
549
} )
550
- . catch ( function ( err : any ) {
550
+ . catch ( function ( err : any ) {
551
551
cb ( err )
552
552
} )
553
553
@@ -584,10 +584,10 @@ export default class Blockchain implements BlockchainInterface {
584
584
}
585
585
586
586
Promise . all ( [ setTD ( self . _headHeader , 'header' ) , setTD ( self . _headBlock , 'block' ) ] )
587
- . then ( function ( ) {
587
+ . then ( function ( ) {
588
588
next ( )
589
589
} )
590
- . catch ( function ( err : any ) {
590
+ . catch ( function ( err : any ) {
591
591
next ( err )
592
592
} )
593
593
}
@@ -660,7 +660,7 @@ export default class Blockchain implements BlockchainInterface {
660
660
// delete higher number assignments and overwrite stale canonical chain
661
661
Promise . all ( [
662
662
new Promise ( ( resolve , reject ) => {
663
- self . _deleteStaleAssignments ( number . iaddn ( 1 ) , hash , dbOps , function (
663
+ self . _deleteStaleAssignments ( number . iaddn ( 1 ) , hash , dbOps , function (
664
664
error : any ,
665
665
value : any ,
666
666
) {
@@ -672,7 +672,7 @@ export default class Blockchain implements BlockchainInterface {
672
672
} )
673
673
} ) ,
674
674
new Promise ( ( resolve , reject ) => {
675
- self . _rebuildCanonical ( header , dbOps , function ( error : any , value : any ) {
675
+ self . _rebuildCanonical ( header , dbOps , function ( error : any , value : any ) {
676
676
if ( error ) {
677
677
reject ( error )
678
678
} else {
@@ -681,10 +681,10 @@ export default class Blockchain implements BlockchainInterface {
681
681
} )
682
682
} ) ,
683
683
] )
684
- . then ( function ( value ) {
684
+ . then ( function ( value ) {
685
685
next ( undefined , value )
686
686
} )
687
- . catch ( function ( error ) {
687
+ . catch ( function ( error ) {
688
688
next ( error )
689
689
} )
690
690
} else {
@@ -1005,9 +1005,9 @@ export default class Blockchain implements BlockchainInterface {
1005
1005
. then ( promisify ( checkCanonical ) )
1006
1006
. then ( promisify ( buildDBops ) )
1007
1007
. then ( promisify ( deleteStaleAssignments ) )
1008
- . then ( function ( ) {
1008
+ . then ( function ( ) {
1009
1009
return new Promise ( ( resolve , reject ) => {
1010
- self . _batchDbOps ( dbOps , function ( err : any ) {
1010
+ self . _batchDbOps ( dbOps , function ( err : any ) {
1011
1011
if ( err ) {
1012
1012
reject ( err )
1013
1013
} else {
@@ -1016,10 +1016,10 @@ export default class Blockchain implements BlockchainInterface {
1016
1016
} )
1017
1017
} )
1018
1018
} )
1019
- . then ( function ( ) {
1019
+ . then ( function ( ) {
1020
1020
cb ( )
1021
1021
} )
1022
- . catch ( function ( err : any ) {
1022
+ . catch ( function ( err : any ) {
1023
1023
cb ( err )
1024
1024
} )
1025
1025
@@ -1146,7 +1146,7 @@ export default class Blockchain implements BlockchainInterface {
1146
1146
blockNumber = number . addn ( 1 )
1147
1147
let error = false
1148
1148
while ( blockNumber && ! error ) {
1149
- await run ( ) . catch ( function ( err : any ) {
1149
+ await run ( ) . catch ( function ( err : any ) {
1150
1150
error = true
1151
1151
cb ( err )
1152
1152
} )
@@ -1162,10 +1162,10 @@ export default class Blockchain implements BlockchainInterface {
1162
1162
1163
1163
await promisify ( getBlock ) ( )
1164
1164
. then ( promisify ( runFunc ) )
1165
- . then ( function ( ) {
1165
+ . then ( function ( ) {
1166
1166
blockNumber . iaddn ( 1 )
1167
1167
} )
1168
- . catch ( function ( error ) {
1168
+ . catch ( function ( error ) {
1169
1169
blockNumber = false
1170
1170
if ( error . type !== 'NotFoundError' ) {
1171
1171
throw error
0 commit comments