328eb85523581684eb186f012536f13c1e2647b6
[scpubgit/DKit.git] / lib / DX / RuleSet.pm
1 package DX::RuleSet;
2
3 use Moo;
4 use DX::Op::CallRule;
5 use DX::Op::MemberOf;
6 use DX::Op::MemberLookup;
7 use DX::Op::ApplyConstraint;
8 use DX::Op::Return;
9 use List::Util qw(reduce);
10
11 has rules => (is => 'ro', default => sub { {} });
12
13 sub add_rule {
14   my ($self, $name, $vars, @body) = @_;
15   my $full_name = join('/', $name, scalar @$vars);
16   push @{$self->rules->{$full_name}}, $self->_make_rule($vars, @body);
17   return $self;
18 }
19
20 sub _make_rule {
21   my ($self, $vars, @body) = @_;
22   my $head = reduce { $b->but(next => $a) }
23                DX::Op::Return->new,
24                reverse map $self->expand(@$_), @body;
25   [ $vars, $head ];
26 }
27
28 sub expand {
29   my ($self, $type, @rest) = @_;
30   if ($self->can(my $expand_meth = "_expand_${type}")) {
31     return $self->$expand_meth(@rest);
32   }
33   return $self->_expand_call($type, @rest);
34 }
35
36 sub _expand_call {
37   my ($self, $name, @args) = @_;
38   DX::Op::CallRule->new(rule_name => $name, rule_args => \@args);
39 }
40
41 sub _expand_member_of {
42   my ($self, $member_var, $coll_name) = @_;
43   DX::Op::MemberOf->new(
44     member_var => $member_var,
45     coll_name => $coll_name,
46   );
47 }
48
49 sub _expand_member_lookup {
50   my ($self, $member_var, $coll_name, $key_name, $key_var) = @_;
51   DX::Op::MemberLookup->new(
52     member_var => $member_var,
53     coll_name => $coll_name,
54     key_name => $key_name,
55     key_var => $key_var
56   );
57 }
58
59 sub _expand_constrain {
60   my ($self, $vars, $constraint) = @_;
61   DX::Op::ApplyConstraint->new(
62     vars => $vars,
63     constraint => $constraint
64   );
65 }
66
67 1;