feat: intermediate chain condition steps + _subjectIsObject unary scoping
CI / publish (push) Successful in 10s
CI / test (push) Successful in 19s

- _expandChainSteps: a logical/defeasible evidence referenced by a chain step
  is now a condition step ({ rule, conditionStep }) at ANY position. As the
  FINAL step the engine verifies it at (intermediate, object); as an
  INTERMEDIATE step the engine expands it from the current node (rule-based
  reachability: base edges' destinations filtered by the rule's
  defeaters/requirements) and continues traversal from each discovered node.
- buildPredicateRule / buildDirectRule: unary predicate calls whose subject
  entity IS the evidence's object parameter (trusted(other) inside
  peer_trusted(user, other)) are marked _subjectIsObject (was: only subject-var
  calls got _subjectAsObject). Requires @arbiter/core@^1.0.4.

Tests: ChainConditionStep intermediate expansion; oracle campaign gains a
chain_intermediate_condition construct (oracle = min(peer*(1-trusted), read)).
This commit is contained in:
John Dvorak
2026-08-03 13:36:16 -07:00
parent fe162251fc
commit 3ace783a59
5 changed files with 94 additions and 32 deletions
+28
View File
@@ -98,4 +98,32 @@ describe('Chain condition step (logical evidence as final hop)', () => {
// max over paths: min(0.5,0.7)=0.5, min(1.0,0.8)=0.8 -> 0.8
assert.equal(arb.check('u:1', 'can_via', 'doc:9').possibility, 0.8);
});
it('expands an INTERMEDIATE condition step via rule-based reachability', () => {
const { arb, result } = compile(`
definition Employee { id: string }
definition Doc { id: string }
fact peer(user: Employee, other: Employee)
fact trusted(other: Employee)
fact can_read(user: Employee, doc: Doc)
evidence peer_trusted(user: Employee, other: Employee) { WHEN peer(user, other) UNLESS trusted(other) }
evidence can_access(user: Employee, doc: Doc) { peer_trusted(user, *p) { can_read(p, doc) } }
`);
assert.ok(result.success, JSON.stringify(result.errors));
const steps = arb.relationConfigs.get('can_access').steps;
assert.equal(steps[0].conditionStep, true);
assert.equal(steps[0].rule.type, 'logical');
arb.addNode('u:1', 'Employee'); arb.addNode('p:1', 'Employee'); arb.addNode('p:2', 'Employee'); arb.addNode('doc:9', 'Doc');
arb.addRelation('u:1', 'peer', 'p:1', { possibility: 1.0 });
arb.addRelation('u:1', 'peer', 'p:2', { possibility: 1.0 });
arb.addRelation('p:1', 'trusted', 'p:1', { possibility: 1.0 }); // p:1 filtered
arb.addRelation('p:1', 'can_read', 'doc:9', { possibility: 0.9 });
arb.addRelation('p:2', 'can_read', 'doc:9', { possibility: 0.7 });
// only untrusted peer p:2 survives the intermediate condition -> 0.7
assert.equal(arb.check('u:1', 'can_access', 'doc:9').possibility, 0.7);
// trusting p:2 too removes all intermediates -> 0
arb.addRelation('p:2', 'trusted', 'p:2', { possibility: 1.0 });
assert.equal(arb.check('u:1', 'can_access', 'doc:9').possibility, 0);
});
});
+27 -2
View File
@@ -33,8 +33,11 @@ const FACTS = `
fact owner(group: Group, doc: Doc)
fact granted(user: Employee, doc: Doc)
fact group_perm(group: Group, doc: Doc)
fact banned(user: Employee)
fact group_banned(group: Group)
fact banned(user: Employee)
fact peer(user: Employee, other: Employee)
fact trusted(other: Employee)
fact doc_read(user: Employee, doc: Doc)
fact mfa(user: Employee)
`;
@@ -142,6 +145,20 @@ function buildProgram(kind, ps) {
oracle = Math.min(pm, pv * (1 - pb));
break;
}
case 'chain_intermediate_condition': {
// peer_trusted (a defeasible evidence) as an INTERMEDIATE chain step:
// the engine expands it from the source (peer edges filtered by the
// trusted defeater) then continues to can_read. Oracle = min of the
// surviving peer leg and the read leg.
const [pp, pt, pr] = ps;
evidence = `evidence peer_trusted(user: Employee, other: Employee) { WHEN peer(user, other) UNLESS trusted(other) }
evidence can_via(user: Employee, doc: Doc) { peer_trusted(user, *p) { doc_read(p, doc) } }`;
edges.push({ src: 'u:1', relation: 'peer', dst: 'p:1', possibility: pp });
edges.push({ src: 'p:1', relation: 'trusted', dst: 'p:1', possibility: pt });
edges.push({ src: 'p:1', relation: 'doc_read', dst: 'doc:9', possibility: pr });
oracle = Math.min(pp * (1 - pt), pr);
break;
}
default:
throw new Error(`unknown construct: ${kind}`);
}
@@ -162,6 +179,10 @@ function runCheck({ kind, ps }) {
arbiter.addNode('u:1', 'Employee');
arbiter.addNode('g:1', 'Group');
arbiter.addNode('doc:9', 'Doc');
for (const e of edges) {
arbiter.addNode(e.src, e.dst === 'doc:9' ? 'Doc' : 'Employee');
arbiter.addNode(e.dst, e.dst === 'doc:9' ? 'Doc' : 'Employee');
}
const compiler = new DSLCompiler(arbiter);
const compiled = compiler.compile(dsl, 'oracle');
if (!compiled.success) {
@@ -178,7 +199,7 @@ function runCheck({ kind, ps }) {
const CONSTRUCTS = ['direct', 'chain', 'tuple_to_userset', 'fusion_min', 'fusion_max',
'when_unless', 'never_always', 'requires_when', 'composition', 'chain_step_composition',
'chain_condition_step'];
'chain_condition_step', 'chain_intermediate_condition'];
describe('DSL generative oracle parity (rigor)', () => {
it('generated legal DSL compiles and every check matches the oracle', async () => {
@@ -220,6 +241,10 @@ describe('DSL generative oracle parity (rigor)', () => {
arbiter.addNode('u:1', 'Employee');
arbiter.addNode('g:1', 'Group');
arbiter.addNode('doc:9', 'Doc');
for (const e of edges) {
arbiter.addNode(e.src, e.dst === 'doc:9' ? 'Doc' : 'Employee');
arbiter.addNode(e.dst, e.dst === 'doc:9' ? 'Doc' : 'Employee');
}
const compiled = new DSLCompiler(arbiter).compile(dsl, 'sweep');
assert.ok(compiled.success, `${kind} compile failed: ${(compiled.errors || []).join('; ')}`);
for (const e of edges) arbiter.addRelation(e.src, e.relation, e.dst, { possibility: e.possibility });