pico-engine-core
Advanced tools
Comparing version 0.13.0 to 0.13.1
{ | ||
"name": "pico-engine-core", | ||
"version": "0.13.0", | ||
"version": "0.13.1", | ||
"description": "The core javascript api for the pico-engine. (no http, logging, process management etc...)", | ||
@@ -31,3 +31,3 @@ "main": "src/index.js", | ||
"eslint": "^3.0.1", | ||
"krl-compiler": "^0.17.1", | ||
"krl-compiler": ">=0.18.0", | ||
"memdown": "^1.2.0", | ||
@@ -34,0 +34,0 @@ "onchange": "^3.0.0", |
@@ -7,3 +7,3 @@ var _ = require("lodash"); | ||
var safeJsonCodec = require("level-json-coerce-null"); | ||
var extractRulesetName = require("./extractRulesetName"); | ||
var extractRulesetID = require("./extractRulesetID"); | ||
@@ -126,3 +126,3 @@ var dbToObj = function(ldb, callback){ | ||
getStateMachineState: function(pico_id, rule, callback){ | ||
var key = ["state_machine", pico_id, rule.rid, rule.rule_name]; | ||
var key = ["state_machine", pico_id, rule.rid, rule.name]; | ||
ldb.get(key, function(err, curr_state){ | ||
@@ -142,3 +142,3 @@ if(err){ | ||
putStateMachineState: function(pico_id, rule, state, callback){ | ||
var key = ["state_machine", pico_id, rule.rid, rule.rule_name]; | ||
var key = ["state_machine", pico_id, rule.rid, rule.name]; | ||
ldb.put(key, state || "start", callback); | ||
@@ -152,3 +152,3 @@ }, | ||
var rid = extractRulesetName(krl_src); | ||
var rid = extractRulesetID(krl_src); | ||
if(!rid){ | ||
@@ -155,0 +155,0 @@ callback(new Error("Ruleset name not found")); |
@@ -33,2 +33,4 @@ var _ = require("lodash"); | ||
var responses = _.compact(_.map(actions, function(action){ | ||
//TODO collect errors and respond individually to the client | ||
//TODO try{}catch(e){} | ||
var response = action.action(ctx); | ||
@@ -44,3 +46,3 @@ if((response === void 0) || (response === null)){ | ||
rid: rule.rid, | ||
rule_name: rule.rule_name, | ||
rule_name: rule.name, | ||
txn_id: "TODO",//TODO transactions | ||
@@ -69,4 +71,3 @@ eid: ctx.event.eid | ||
module.exports = function(rule, ctx, callback){ | ||
//TODO collect errors and respond individually to the client | ||
applyInFiber(evalRuleFiber, null, [rule, ctx], callback); | ||
}; |
@@ -30,3 +30,2 @@ var _ = require("lodash"); | ||
var doInstallRuleset = function(rs){ | ||
rs.rid = rs.name; | ||
rs.scope = SymbolTable(); | ||
@@ -38,9 +37,8 @@ if(_.isFunction(rs.global)){ | ||
} | ||
_.each(rs.rules, function(rule, rule_name){ | ||
_.each(rs.rules, function(rule){ | ||
rule.rid = rs.rid; | ||
rule.rule_name = rule_name; | ||
_.each(rule.select && rule.select.graph, function(g, domain){ | ||
_.each(g, function(exprs, type){ | ||
_.set(salience_graph, [domain, type, rule.rid, rule.rule_name], true); | ||
_.set(salience_graph, [domain, type, rule.rid, rule.name], true); | ||
}); | ||
@@ -178,3 +176,3 @@ }); | ||
rid: rule.rid, | ||
rule_name: rule.rule_name | ||
rule_name: rule.name | ||
}); | ||
@@ -181,0 +179,0 @@ |
@@ -17,6 +17,6 @@ var _ = require("lodash"); | ||
var rs = require(path.resolve(test_dir, file)); | ||
if(!rs.name){ | ||
if(!rs.rid){ | ||
return; | ||
} | ||
test_rulesets[rs.name] = rs; | ||
test_rulesets[rs.rid] = rs; | ||
}); | ||
@@ -23,0 +23,0 @@ |
@@ -1,3 +0,3 @@ | ||
require("./extractRulesetName.test"); | ||
require("./extractRulesetID.test"); | ||
require("./index.test"); | ||
require("./DB.test"); |
39176
1276