lib/DX/State.pm

   1 package DX::State;
   2
   3 use Moo;
   4
   5 has next_op => (is => 'ro', required => 1);
   6
   7 has return_stack => (is => 'ro', required => 1);
   8
   9 has by_id => (is => 'ro', required => 1);
  10
  11 has scope => (is => 'ro', required => 1);
  12
  13 has last_choice => (is => 'ro', required => 1);
  14
  15 sub scope_var {
  16   my ($self, $name) = @_;
  17   $self->by_id->{$self->scope->{$name}};
  18 }
  19
  20 sub bind_stream_then {
  21   my ($self, $var, $stream, $then) = @_;
  22   warn "Binding ".$var->id." to $stream";
  23   my $bound = $var->with_stream($stream);
  24   $self->new(%$self,
  25     by_id => { %{$self->by_id}, $var->id => $bound },
  26     next_op => $then
  27   )->mark_choice($bound);
  28 }
  29
  30 sub mark_choice {
  31   my ($self, $var) = @_;
  32   $self->new(%$self,
  33     last_choice => [ $self, $var ]
  34   );
  35 }
  36
  37 sub backtrack {
  38   my ($self) = @_;
  39   my ($state, $var) = ($self);
  40   while (($state, $var) = @{$state->last_choice}) {
  41     $var->bound_value; $var->clear_bound_value;
  42     return $state->mark_choice($var) unless $var->bound_stream->is_exhausted;
  43   }
  44   die "Out of options";
  45 }
  46
  47 sub then {
  48   my ($self, $then) = @_;
  49   $self->new(%$self, next_op => $then);
  50 }
  51
  52 sub run {
  53   my ($state) = @_;
  54   while (my $op = $state->next_op) {
  55     $state = $op->run($state);
  56   }
  57   return $state;
  58 }
  59
  60 1;