@@ -1231,7 +1231,8 @@ module.exports = function(registry) {
1231
1231
function ( filter , pagingCallback ) {
1232
1232
sourceModel . changes ( since . source , filter , pagingCallback ) ;
1233
1233
} ,
1234
- debug . enabled ? log : cb ) ;
1234
+ debug . enabled ? log : cb
1235
+ ) ;
1235
1236
1236
1237
function log ( err , result ) {
1237
1238
if ( err ) return cb ( err ) ;
@@ -1248,7 +1249,8 @@ module.exports = function(registry) {
1248
1249
function ( smallArray , chunkCallback ) {
1249
1250
return targetModel . diff ( since . target , smallArray , chunkCallback ) ;
1250
1251
} ,
1251
- debug . enabled ? log : cb ) ;
1252
+ debug . enabled ? log : cb
1253
+ ) ;
1252
1254
1253
1255
function log ( err , result ) {
1254
1256
if ( err ) return cb ( err ) ;
@@ -1276,7 +1278,8 @@ module.exports = function(registry) {
1276
1278
function ( smallArray , chunkCallback ) {
1277
1279
return sourceModel . createUpdates ( smallArray , chunkCallback ) ;
1278
1280
} ,
1279
- cb ) ;
1281
+ cb
1282
+ ) ;
1280
1283
} else {
1281
1284
// nothing to replicate
1282
1285
done ( ) ;
@@ -1308,7 +1311,8 @@ module.exports = function(registry) {
1308
1311
return cb ( ) ;
1309
1312
}
1310
1313
cb ( err ) ;
1311
- } ) ;
1314
+ }
1315
+ ) ;
1312
1316
}
1313
1317
1314
1318
function checkpoints ( ) {
@@ -1526,14 +1530,16 @@ module.exports = function(registry) {
1526
1530
return cb ( new Error (
1527
1531
g . f ( 'Cannot apply bulk updates, ' +
1528
1532
'the connector does not correctly report ' +
1529
- 'the number of updated records.' ) ) ) ;
1533
+ 'the number of updated records.' )
1534
+ ) ) ;
1530
1535
1531
1536
default :
1532
1537
debug ( '%s.updateAll modified unexpected number of instances: %j' ,
1533
1538
Model . modelName , count ) ;
1534
1539
return cb ( new Error (
1535
1540
g . f ( 'Bulk update failed, the connector has modified unexpected ' +
1536
- 'number of records: %s' , JSON . stringify ( count ) ) ) ) ;
1541
+ 'number of records: %s' , JSON . stringify ( count ) )
1542
+ ) ) ;
1537
1543
}
1538
1544
} ) ;
1539
1545
}
@@ -1608,14 +1614,16 @@ module.exports = function(registry) {
1608
1614
return cb ( new Error (
1609
1615
g . f ( 'Cannot apply bulk updates, ' +
1610
1616
'the connector does not correctly report ' +
1611
- 'the number of deleted records.' ) ) ) ;
1617
+ 'the number of deleted records.' )
1618
+ ) ) ;
1612
1619
1613
1620
default :
1614
1621
debug ( '%s.deleteAll modified unexpected number of instances: %j' ,
1615
1622
Model . modelName , count ) ;
1616
1623
return cb ( new Error (
1617
1624
g . f ( 'Bulk update failed, the connector has deleted unexpected ' +
1618
- 'number of records: %s' , JSON . stringify ( count ) ) ) ) ;
1625
+ 'number of records: %s' , JSON . stringify ( count ) )
1626
+ ) ) ;
1619
1627
}
1620
1628
} ) ;
1621
1629
}
@@ -1770,7 +1778,8 @@ module.exports = function(registry) {
1770
1778
const additionalChangeModelProperties =
1771
1779
this . settings . additionalChangeModelProperties || { } ;
1772
1780
1773
- this . Change = BaseChangeModel . extend ( this . modelName + '-change' ,
1781
+ this . Change = BaseChangeModel . extend (
1782
+ this . modelName + '-change' ,
1774
1783
additionalChangeModelProperties ,
1775
1784
{ trackModel : this }
1776
1785
) ;
0 commit comments