File Coverage

blib/lib/Backup/Omni/Session/Monitor.pm

Criterion	Covered	Total	%
statement	12	73	16.4
branch	0	24	0.0
condition	0	9	0.0
subroutine	4	8	50.0
pod	3	3	100.0
total	19	117	16.2

package Backup::Omni::Session::Monitor;

our $VERSION = '0.01';

use Params::Validate ':all';

use Backup::Omni::Class
  version   => $VERSION,
  base      => 'Backup::Omni::Base',
  utils     => 'omni2dt trim',
  constants => 'OMNISTAT',
  constant => {
      RUNNING => '%s -session %s -status_only 2> /dev/null',
      COMMAND => '%s -session %s -detail 2> /dev/null',
  },
  vars => {
      PARAMS => {
          -session => 1,
      }
  }
;

Params::Validate::validation_options(
    on_fail => sub {
        my $params = shift;
        my $class  = __PACKAGE__;
        Backup::Omni::Base::validation_exception($params, $class);
    }
);

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

sub running {
    my $self = shift;

    my $stat = 0;
    my $command = sprintf(RUNNING, OMNISTAT, $self->session);

    my @result = `$command`;
    my $rc = $?;

    if ((grep(/SessionID/, @result)) && ($rc == 0)) {

        $stat = 1;

    }

    return $stat;

}

sub object {
    my $self = shift;

    my $started = 0;
    my $obj = undef;
    my $command = sprintf(COMMAND, OMNISTAT, $self->session);

    my @result = `$command`;
    my $rc = $?;

    if ((grep(/Object name/, @result)) && ($rc == 0)) {

        $obj = Backup::Omni::Session::Monitor::Object->new();

        foreach my $line (@result) {

            chomp($line);
            next if ($line eq '');

            if ($line =~ /Object name/) {

                $started = 1;
                $self->_parse_line($obj, $line);

            } else {

                if ($started) {

                    if ($line =~ /Device name/) {

                        $started = 0;
                        last;

                    }

                    $self->_parse_line($obj, $line);

                }

            }

        }

    }

    return $obj;

}

sub device {
    my $self = shift;

    my $started = 0;
    my $obj = undef;
    my $command = sprintf(COMMAND, OMNISTAT, $self->session);

    my @result = `$command`;
    my $rc = $?;

    if ((grep(/Object name/, @result)) && ($rc == 0)) {

        $obj = Backup::Omni::Session::Monitor::Device->new();

        foreach my $line (@result) {

            chomp($line);
            next if ($line eq '');

            if ($line =~ /Device name/) {

                $started = 1;
                $self->_parse_line($obj, $line);

            } else {

                if ($started) {

                    if ($line =~ /Object name/) {

                        $started = 0;
                        last;

                    }

                    $self->_parse_line($obj, $line);

                }

            }

        }

    }

    return $obj;

}

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

sub _parse_line {
    my $self = shift;
    my $obj  = shift;
    my $line = shift;

    $line =~ m/^(.*): (.*)/;

    my $key = $1;
    my $value = $2;

    $key = trim($key);
    $key =~ s/ /_/g;
    $key = lc($key);

    $value = trim($value);
    $value = omni2dt($value) if ($value =~ /\w\w\w \d\d \w\w\w \d\d\d\d/);

    # order is important here. Don't change

    $obj->class->accessors($key);    # may cause redefination errors
    $obj->{$key} = $value;

}

# the following are stubs, they are filled out above in _parse_line().

package Backup::Omni::Session::Monitor::Device;

use Backup::Omni::Class
  version => '0.01',
  base    => 'Backup::Omni::Base',
;

package Backup::Omni::Session::Monitor::Object;

use Backup::Omni::Class
  version => '0.01',
  base    => 'Backup::Omni::Base',
;

1;

__END__