pico-engine-core - npm Package Compare versions

Comparing version 0.29.2 to 0.29.3

package.json

 {
   "name": "pico-engine-core",
-  "version": "0.29.2",
+  "version": "0.29.3",
   "description": "The core javascript api for the pico-engine. (no http, logging, process management etc...)",
@@ -10,5 +10,5 @@ "main": "src/index.js",
   "scripts": {
-    "start": "onchange -i src/ test-rulesets/ -- npm run test -s",
+    "start": "onchange -i src/ test-rulesets/ -- npm run test",
     "lint": "eslint src/ && echo lint-ok",
-    "test": "npm run lint && node src/tests.js"
+    "test": "npm run lint -s && node src/tests.js | faucet"
   },
@@ -32,3 +32,4 @@ "repository": {
     "eslint": "^3.0.1",
-    "krl-compiler": ">=0.26.2",
+    "faucet": "^0.0.1",
+    "krl-compiler": "^0.31.5",
     "memdown": "^1.2.0",
@@ -44,3 +45,3 @@ "onchange": "^3.0.0",
     "cuid": "^1.3.8",
-    "krl-stdlib": "^0.6.0",
+    "krl-stdlib": "^0.7.1",
     "level-json-coerce-null": "^1.0.0",
@@ -47,0 +48,0 @@ "levelup": "^1.3.2",

src/index.js

@@ -29,3 +29,3 @@ var _ = require("lodash");
 
-module.exports = function(conf, callback){
+module.exports = function(conf){
     var db = DB(conf.db);
@@ -440,36 +440,7 @@ _.each(db, function(val, key){
 
-    registerAllEnabledRulesets(function(err){
-        if(err) return callback(err);
-        var pe = {
-            emitter: emitter,
-
-            signalEvent: signalEvent,
-            runQuery: runQuery,
-
-            registerRuleset: core.registerRuleset,
-            registerRulesetURL: core.registerRulesetURL,
-            flushRuleset: core.flushRuleset,
-            unregisterRuleset: core.unregisterRuleset,
-
-            newPico: db.newPico,
-            newChannel: db.newChannel,
-            removeChannel: db.removeChannel,
-            getOwnerECI: db.getOwnerECI,
-            installRuleset: core.installRuleset,
-            uninstallRuleset: core.uninstallRuleset,
-            removePico: db.removePico,
-
-            putEntVar: db.putEntVar,
-            getEntVar: db.getEntVar,
-            removeEntVar: db.removeEntVar,
-
-            dbDump: db.toObj,
-        };
-        if(conf.___core_testing_mode){
-            pe.scheduler = core.scheduler;
-            pe.modules = modules;
-        }
-        //restart "cron"
+    var resumeScheduler = function(callback){
         db.listScheduled(function(err, vals){
             if(err) return callback(err);
+
+            //resume the cron tasks
             _.each(vals, function(val){
@@ -481,5 +452,49 @@ if(!_.isString(val.timespec)){
             });
-            callback(void 0, pe);
+
+            //resume `schedule .. at` queue
+            core.scheduler.update();
+
+            callback();
         });
-    });
+    };
+
+
+    var pe = {
+        emitter: emitter,
+
+        signalEvent: signalEvent,
+        runQuery: runQuery,
+
+        registerRuleset: core.registerRuleset,
+        registerRulesetURL: core.registerRulesetURL,
+        flushRuleset: core.flushRuleset,
+        unregisterRuleset: core.unregisterRuleset,
+
+        newPico: db.newPico,
+        newChannel: db.newChannel,
+        removeChannel: db.removeChannel,
+        getOwnerECI: db.getOwnerECI,
+        installRuleset: core.installRuleset,
+        uninstallRuleset: core.uninstallRuleset,
+        removePico: db.removePico,
+
+        putEntVar: db.putEntVar,
+        getEntVar: db.getEntVar,
+        removeEntVar: db.removeEntVar,
+
+        dbDump: db.toObj,
+    };
+    if(conf.___core_testing_mode){
+        pe.scheduler = core.scheduler;
+        pe.modules = modules;
+    }
+
+    pe.start = function(callback){
+        registerAllEnabledRulesets(function(err){
+            if(err) return callback(err);
+            resumeScheduler(callback);
+        });
+    };
+
+    return pe;
 };

src/mkTestPicoEngine.js

@@ -26,3 +26,3 @@ var _ = require("lodash");
     opts = opts || {};
-    PicoEngine({
+    var pe = PicoEngine({
         host: "https://test-host",
@@ -45,3 +45,4 @@ allow_event_time_override: true,
         }
-    }, function(err, pe){
+    });
+    pe.start(function(err){
         if(err)return callback(err);
@@ -48,0 +49,0 @@ if(opts.dont_register_rulesets){

src/Scheduler.js

@@ -52,4 +52,2 @@ var _ = require("lodash");
 
-    update();//trigger the initial schedule
-
     var r = {
@@ -56,0 +54,0 @@ update: update,

No alert changes

Improved metrics

Total package byte prevSize

204362

increased by0.08%

Lines of code

5566

increased by0.16%

Worsened metrics

Dev dependency count

6

increased by20%

Dependency changes

• + Addedkrl-stdlib@0.7.6(transitive)

• - Removedkrl-stdlib@0.6.4(transitive)

• Updatedkrl-stdlib@^0.7.1