Comparing version 0.1.1 to 0.2.0
@@ -232,7 +232,7 @@ "use strict"; | ||
name: schedule.name || '' | ||
}, function( err, count ) { | ||
}, function( err, lastError ) { | ||
if ( err ) { | ||
done( err ); | ||
} else { | ||
done( null, count > 0 ); | ||
done( null, lastError && lastError.result && lastError.result.hasOwnProperty( 'n' ) && lastError.result.n > 0 ); | ||
} | ||
@@ -428,15 +428,2 @@ } ); | ||
function( done ) { | ||
// upgrade old schedule entries to 0.1.x schema | ||
self._models.Dronos.update( | ||
{ | ||
enabled: { $exists: false } | ||
}, | ||
{ | ||
$set: { enabled: true } | ||
}, | ||
done | ||
); | ||
}, | ||
function( done ) { | ||
self._runReadySchedules( done ); | ||
@@ -443,0 +430,0 @@ } |
@@ -50,3 +50,3 @@ "use strict"; | ||
// indexes | ||
DronosSchema.index( { owner: 1, name: 1 }, { unique: true } ); | ||
DronosSchema.index( { owner: 1, name: 1 } ); | ||
DronosSchema.index( { owner: 1, name: 1, _lastUpdate: -1 } ); | ||
@@ -53,0 +53,0 @@ DronosSchema.index( { enabled: 1, _nextRun: 1, _lastRun: 1 } ); |
{ | ||
"name": "dronos", | ||
"description": "Dronos is a distributed scheduling system (with patterns similar to Linux's cron system), using MongoDB to coordinate running tasks (drons) across multiple nodes.", | ||
"version": "0.1.1", | ||
"author": "Anthony Hildoer <anthony@bluerival.com>", | ||
"repository": { | ||
"name": "dronos", | ||
"description": "Dronos is a distributed scheduling system (with patterns similar to Linux's cron system), using MongoDB to coordinate running tasks (drons) across multiple nodes.", | ||
"version": "0.2.0", | ||
"author": "Anthony Hildoer <anthony@bluerival.com>", | ||
"repository": { | ||
"type": "git", | ||
"url": "git@github.com:BlueRival/dronos.git" | ||
"url": "git@github.com:BlueRival/dronos.git" | ||
}, | ||
"dependencies": { | ||
"async": "0.9.0", | ||
"dependencies": { | ||
"async": "1.4.0", | ||
"doublescore": "0.0.3", | ||
"later": "1.1.6", | ||
"moment": "2.8.4" | ||
"later": "1.1.6", | ||
"moment": "2.10.6" | ||
}, | ||
"devDependencies": { | ||
"mocha": "2.0.1", | ||
"mongoose": "3.8.18" | ||
"mocha": "2.2.5", | ||
"mongoose": "4.1.1" | ||
}, | ||
"keywords": [ | ||
"keywords": [ | ||
"distributed", | ||
@@ -27,6 +27,6 @@ "chronos", | ||
], | ||
"engines": { | ||
"engines": { | ||
"node": ">=0.10.0" | ||
}, | ||
"license": "MIT" | ||
"license": "MIT" | ||
} |
@@ -48,3 +48,3 @@ "use strict"; | ||
prefix: '_testing', | ||
mongodb: 'mongodb://localhost/testing' | ||
mongodb: 'mongodb://localhost/_dronos_testing' | ||
} ); | ||
@@ -62,3 +62,3 @@ done(); | ||
prefix: '_testing', | ||
mongodb: 'mongodb://localhost/testing' | ||
mongodb: 'mongodb://localhost/_dronos_testing' | ||
} ); | ||
@@ -390,40 +390,40 @@ | ||
dronos.set( inputSchedule, function( err ) { | ||
async.series( [ | ||
function( done ) { | ||
dronos.set( inputSchedule, done ); | ||
}, | ||
function( done ) { | ||
dronos.remove( { | ||
owner: '1234', | ||
name: 'a.test.schedule' | ||
}, function( err, removedOne ) { | ||
if ( err ) { | ||
done( err ); | ||
return; | ||
} | ||
try { | ||
assert.ifError( err ); | ||
assert.strictEqual( removedOne, true ); | ||
done(); | ||
} catch ( e ) { | ||
done( e ); | ||
} | ||
dronos.remove( { | ||
owner: '1234', | ||
name: 'a.test.schedule' | ||
}, function( err, removedOne ) { | ||
} ); | ||
}, | ||
function( done ) { | ||
dronos.remove( { | ||
owner: '1234', | ||
name: 'a.test.schedule' | ||
}, function( err, removedOne ) { | ||
try { | ||
assert.ifError( err ); | ||
assert.strictEqual( removedOne, true ); | ||
try { | ||
assert.ifError( err ); | ||
assert.strictEqual( removedOne, false ); | ||
done(); | ||
} catch ( e ) { | ||
done( e ); | ||
} | ||
dronos.remove( { | ||
owner: '1234', | ||
name: 'a.test.schedule' | ||
}, function( err, removedOne ) { | ||
} ); | ||
} | ||
], done ); | ||
try { | ||
assert.ifError( err ); | ||
assert.strictEqual( removedOne, false ); | ||
done(); | ||
} catch ( e ) { | ||
done( e ); | ||
} | ||
} ); | ||
} catch ( e ) { | ||
done( e ); | ||
} | ||
} ); | ||
} ); | ||
} ); | ||
@@ -477,3 +477,3 @@ | ||
prefix: '_testing', | ||
mongodb: 'mongodb://localhost/testing' | ||
mongodb: 'mongodb://localhost/_dronos_testing' | ||
} ); | ||
@@ -480,0 +480,0 @@ |
60891
2036
+ Addedasync@1.4.0(transitive)
+ Addedmoment@2.10.6(transitive)
- Removedasync@0.9.0(transitive)
- Removedmoment@2.8.4(transitive)
Updatedasync@1.4.0
Updatedmoment@2.10.6