lib/DX/Hypothesis.pm

   1 package DX::Hypothesis;
   2
   3 use DX::ActionPolicy::LockScope;
   4 use Types::Standard qw(ArrayRef);
   5 use DX::Utils qw(deparse);
   6 use DX::Class;
   7
   8 has scope => (is => 'ro', isa => Scope, required => 1);
   9
  10 has resolved_propositions => (
  11   is => 'ro', isa => ResolvedPropositionSet, required => 1
  12 );
  13
  14 has actions => (
  15   is => 'ro', isa => ArrayRef[Action], required => 1
  16 );
  17
  18 has action_applications => (
  19   is => 'ro', isa => ArrayRef[Action], required => 1
  20 );
  21
  22 has action_policy => (is => 'ro', isa => ActionPolicy, required => 1);
  23
  24 sub with_actions {
  25   my ($self, @actions) = @_;
  26   my $hyp = $self;
  27   my @events;
  28   foreach my $act (@actions) {
  29     return undef unless $self->action_policy->allows($act);
  30     ($hyp, my @these_events) = $act->dry_run($hyp);
  31     return undef unless $hyp;
  32     push @events, @these_events;
  33   }
  34   $hyp = $hyp->but_recheck_for(@events);
  35   return $hyp;
  36 }
  37
  38 sub but_recheck_for {
  39   my ($self, @events) = @_;
  40   my ($still_resolved, @recheck) = $self->resolved_propositions
  41                                         ->but_expire_for(@events);
  42   return $self unless @recheck;
  43
  44   my $ap = DX::ActionPolicy::LockScope->new(
  45     lock_to_depth => $self->scope->depth,
  46     next_policy => $self->action_policy,
  47   );
  48
  49   # we should probably be doing something about pruning the scope
  50   # but that's completely pointless until we have rules
  51
  52   my $hyp = ref($self)->new(
  53     scope => $self->scope,
  54     resolved_propositions => DX::ResolvedPropositionSet->new_empty,
  55     actions => [],
  56     action_applications => [],
  57     action_policy => $ap,
  58   );
  59
  60   my $pseq = DX::PropositionSequence->new(
  61     members => \@recheck,
  62     external_names => {},
  63     internal_names => {},
  64   );
  65
  66   trace 'step.recheck.hyp' => $hyp;
  67
  68   my $ss = DX::SearchProcess->new_for($hyp, $pseq);
  69
  70   my $sol_ss = $ss->find_solution;
  71
  72   unless ($sol_ss) {
  73     trace 'step.recheck.fail' => 'argh';
  74     return undef;
  75   }
  76
  77   my $sol_rps = $sol_ss->current_hypothesis->resolved_propositions;
  78
  79   my $rps = $still_resolved;
  80
  81   $rps = $rps->with_updated_dependencies_for(
  82     $_, $sol_rps->dependencies_for($_)
  83   ) for @recheck;
  84
  85   trace 'step.recheck.done' => 'yay';
  86
  87   return $self->but(resolved_propositions => $rps);
  88 }
  89
  90 sub with_resolution {
  91   my ($self, $prop, $depends) = @_;
  92   $self->but(
  93     resolved_propositions => $self->resolved_propositions
  94                                   ->with_resolution_for(
  95                                       $prop,
  96                                       $depends,
  97                                     ),
  98   );
  99 }
 100
 101 1;