File Coverage

blib/lib/App/EventStreamr/Process.pm

Criterion	Covered	Total	%
statement	28	53	52.8
branch	5	24	20.8
condition	1	12	8.3
subroutine	9	11	81.8
pod			n/a
total	43	100	43.0

package App::EventStreamr::Process;
use Method::Signatures;
use Moo;
use Scalar::Util::Reftype;
use Carp 'croak';
use namespace::clean;

# ABSTRACT: A process object

our $VERSION = '0.5'; # VERSION: Generated by DZP::OurPkg:Version


my $ConfigRef = sub {
  croak "auth isn't a 'App::EventStreamr::Config' object!" unless reftype( $_[0] )->class eq "App::EventStreamr::Config";
};

my $StatusRef = sub {
  croak "auth isn't a 'App::EventStreamr::Status' object!" unless reftype( $_[0] )->class eq "App::EventStreamr::Status";
};

has 'config'      => ( is => 'rw', required => 1, isa => $ConfigRef );
has 'status'      => ( is => 'rw', required => 1, isa => $StatusRef );
has 'cmd'         => ( is => 'ro', required => 1 );
has 'id'          => ( is => 'ro', required => 1 );
has 'type'        => ( is => 'ro', default => sub { 'internal' } );
has 'sleep_time'  => ( is => 'ro', default => sub { 1 } );
has 'cmd_regex'   => ( is => 'ro' );

method _run() {
  # Unless we spefically set our state we're going to want to run
  # By default our control config will be empty and this shortcut
  # attriubute makes things look a little cleaner.
  my $run = defined $self->{config}{control}{$self->{id}}{run} ? $self->{config}{control}{$self->{id}}{run} : 1;

  $self->{config}{control}{$self->{id}}{run} = $run;

  # We only want to run if both the process is set to run
  # and the system is set to run.
  if ($run && $self->{config}{run}) {
    return 1;
  } else {
    return 0;
  }
}

method _restart() {
  if (defined $self->{config}{control}{$self->{id}}{run} && $self->{config}{control}{$self->{id}}{run} == 2) {
    return 1;
  } else {
    return 0;
  }
}


method run_stop() {
  if ($self->_restart) {
    $self->info("Restarting ".$self->id." with command: ".$self->cmd);
    $self->status->restarting($self->{id},$self->{type});

    if (! $self->running) {
      $self->{config}{control}{$self->{id}}{run} = 1;
    } else {
      $self->status->stopping($self->{id},$self->{type});
      $self->stop();

      # Give the process time to settle.
      sleep $self->sleep_time;
    }

  } elsif ( $self->_run && ! $self->pid) {
    # Slows down the restarts to ensure we don't flood logs
    # and control systems.
    return if $self->status->threshold($self->{id},$self->{type});

    $self->info("Starting ".$self->id." with command: ".$self->cmd);
    $self->status->starting($self->{id},$self->{type});

    $self->start();

    # Give the process time to settle.
    sleep $self->sleep_time;
  } elsif ( (! $self->_run && $self->pid ) ) {
    $self->info("Stopping ".$self->id);
    $self->status->stopping($self->{id},$self->{type});

    $self->stop();

    # Give the process time to settle.
    sleep $self->sleep_time;
  }


  # Write config on state change.
  if ( $self->status->set_state($self->running,$self->{id},$self->{type}) ) {
    $self->info("State changed for ".$self->id);
    $self->config->write_config();
  }
  return;
}

with('App::EventStreamr::Roles::Logger','App::EventStreamr::Roles::ProcessControl');

1;

__END__

=pod

=encoding UTF-8

=head1 NAME

App::EventStreamr::Process - A process object

=head1 VERSION

version 0.5

=head1 SYNOPSIS

This package provides core start/stop logic for all processes
and devices.

=head1 DESCRIPTION

This package provides the core run/stop logic for EventStreamr. A
process will extend this and provide any extra logic specific to its
needs.

It consumes the 'ProcessControl' role with requires a 'cmd' attribute
and will utilise an optional 'cmd_regex' if one exists.

=head1 METHODS

=head2 run_stop
  $device->run_stop()

Will start the process if it's intended to be running or stop it
if isn't.

=head1 AUTHOR

Leon Wright < [e-mail] >

=head1 COPYRIGHT AND LICENSE

This software is Copyright (c) 2014 by Leon Wright.

This is free software, licensed under:

  The GNU Affero General Public License, Version 3, November 2007

=cut