add ModifyAction op
[scpubgit/DKit.git] / lib / DX / RuleSet.pm
index 2ae880d..baa9586 100644 (file)
@@ -1,6 +1,7 @@
 package DX::RuleSet;
 
 use Moo;
+use DX::Op::SetupScope;
 use DX::Op::CallRule;
 use DX::Op::MemberOf;
 use DX::Op::ApplyConstraint;
@@ -10,13 +11,23 @@ use DX::Op::Backtrack;
 use DX::Op::Observe;
 use DX::Op::Not;
 use DX::Op::ProposeAction;
+use DX::Op::ModifyAction;
 use DX::Op::Materialize;
 use DX::Op::Prop;
 use DX::Op::Exists;
+use DX::Op::Predicate;
 use List::Util qw(reduce);
 
 has rules => (is => 'ro', default => sub { {} });
 
+sub add_predicate {
+  my ($self, $name, $vars, @cases) = @_;
+  my $full_name = join('/', $name, scalar @$vars);
+  push @{$self->rules->{$full_name}}, DX::Op::Predicate->new(
+    arg_names => $vars, arg_cases => \@cases
+  );
+}
+
 sub add_rule {
   my ($self, $name, $vars, @body) = @_;
   my $full_name = join('/', $name, scalar @$vars);
@@ -27,7 +38,7 @@ sub add_rule {
 sub _make_rule {
   my ($self, $vars, @body) = @_;
   my $head = $self->expand_and_link(DX::Op::Return->new, @body);
-  [ $vars, $head ];
+  DX::Op::SetupScope->new(arg_names => $vars, next => $head);
 }
 
 sub expand_and_link {
@@ -98,6 +109,14 @@ sub _expand_op_act {
   );
 }
 
+sub _expand_op_react {
+  my ($self, $vars, $builder) = @_;
+  DX::Op::ModifyAction->new(
+    vars => $vars,
+    builder => $builder,
+  );
+}
+
 sub _expand_op_materialize {
   my ($self, $var_name) = @_;
   DX::Op::Materialize->new(var_name => $var_name);