add ModifyAction op
[scpubgit/DKit.git] / lib / DX / Op / ModifyAction.pm
1 package DX::Op::ModifyAction;
2
3 use DX::ObservationRequired;
4 use Moo;
5
6 with 'DX::Role::Op';
7
8 has vars => (is => 'ro', required => 1);
9 has builder => (is => 'ro', required => 1);
10
11 has _arg_map => (is => 'lazy', builder => sub {
12   my ($self) = @_;
13   my $name = 'arg0';
14   +{ map +($name++, $_), @{$self->vars} };
15 });
16
17 sub run {
18   my ($self, $state) = @_;
19   ($state, my %args) = $self->_expand_args($state, %{$self->_arg_map});
20   my ($subject, @vars) = @args{sort keys %args};
21   die "Can't alter action on $subject" unless
22     my $orig_action = $state->resolve_value($subject)->required_action;
23   my @deps = $state->action_dependencies(
24     @{$orig_action->dependencies},
25     map $_->id, @vars
26   );
27   my @builder_args = (
28     $orig_action,
29     map $state->resolve_value($_), @vars
30   );
31   my $action = $self->builder->(@builder_args)
32                     ->but(dependencies => \@deps);
33   my ($fact_type, $value) = $action->expected_effect;
34   my $final_value = $value->but(required_action => $action);
35   my $fact_set = $state->facts->{$fact_type}->with_value($final_value);
36   $state->but(facts => { %{$state->facts}, $fact_type => $fact_set })
37         ->then($self->next);
38 }
39
40 1;