File Coverage

blib/lib/XAS/Lib/Service.pm

Criterion	Covered	Total	%
statement	9	69	13.0
branch	1	8	12.5
condition			n/a
subroutine	3	12	25.0
pod	3	3	100.0
total	16	92	17.3

package XAS::Lib::Service;

our $VERSION = '0.04';

use POE;

my ($mixin, $shutdown);

BEGIN {

    if ($^O eq 'MSWin32') {

        $mixin = 'XAS::Lib::Service::Win32';
        $shutdown = 25;

    } else {

        $mixin = 'XAS::Lib::Service::Unix';
        $shutdown = 2;

    }

}

use XAS::Class
  debug     => 0,
  version   => $VERSION,
  base      => 'XAS::Lib::POE::Session',
  utils     => ':validation',
  mixin     => $mixin,
  accessors => 'sessions',
  mutators  => 'last_state',
  constants => 'DELIMITER',
  vars => {
    PARAMS => {
      -poll_interval     => { optional => 1, default => 2 },
      -shutdown_interval => { optional => 1, default => $shutdown },
      -alias             => { optional => 1, default => 'services' },
    }
  }
;

#use Data::Dumper;

# ----------------------------------------------------------------------
# Public Methods
# ----------------------------------------------------------------------

sub register {
    my $self = shift;
    my $sessions = validate_params(\@_, [
        (0) x (@_)
    ]);

    foreach my $session (@$sessions) {

        if (my @parts = split(DELIMITER, $session)) {

            foreach my $part (@parts) {

                next if ($part eq '');
                push(@{$self->{'sessions'}}, $part);

            }

        } else {

            next if ($session eq '');
            push(@{$self->{'sessions'}}, $session);

        }

    }

}

sub session_shutdown {
    my $self = shift;

    $poe_kernel->delay('poll');
    $self->SUPER::session_shutdown();

}

# ----------------------------------------------------------------------
# Public Events
# ----------------------------------------------------------------------

# ----------------------------------------------------------------------
# Private Events
# ----------------------------------------------------------------------

sub _session_init {
    my ($self) = $_[OBJECT];

    my $alias = $self->alias;

    $self->log->debug("$alias: _session_init()");

    $poe_kernel->state('poll', $self);

    $self->last_state(SERVICE_START_PENDING);
    $self->_current_state(SERVICE_START_PENDING);

    $self->init_service();
    $self->session_initialize();

    $poe_kernel->post($alias, 'poll');

}

# ----------------------------------------------------------------------
# Private Methods
# ----------------------------------------------------------------------

sub init {
    my $class = shift;

    $poe_kernel->run(); # this only initializes POE

    my $self = $class->SUPER::init(@_);

    $self->{'sessions'} = ();

    return $self;

}

sub _service_startup {
    my $self = shift;

    my $alias = $self->alias;

    $self->log->debug("$alias: _service_startup");

    foreach my $session (@{$self->{'sessions'}}) {

        $poe_kernel->post($session, 'session_startup');

    }

}

sub _service_shutdown {
    my $self = shift;

    my $alias = $self->alias;

    $self->log->debug("$alias: _service_shutdown");

    foreach my $session (@{$self->{'sessions'}}) {

        $poe_kernel->post($session, 'session_shutdown');

    }

}

sub _service_idle {
    my $self = shift;

    my $alias = $self->alias;

    $self->log->debug("$alias: _service_idle");

    foreach my $session (@{$self->{'sessions'}}) {

        $poe_kernel->post($session, 'session_idle');

    }

}

sub _service_paused {
    my $self = shift;

    my $alias = $self->alias;

    $self->log->debug("$alias: _service_paused");

    foreach my $session (@{$self->{'sessions'}}) {

        $poe_kernel->post($session, 'session_pause');

    }

}

sub _service_resumed {
    my $self = shift;

    my $alias = $self->alias;

    $self->log->debug("$alias: _service_resumed");

    foreach my $session (@{$self->{'sessions'}}) {

        $poe_kernel->post($session, 'session_resume');

    }

}

1;

__END__