File Coverage

blib/lib/Backup/Omni/Utils.pm

Criterion	Covered	Total	%
statement	15	82	18.2
branch	0	12	0.0
condition	0	3	0.0
subroutine	5	16	31.2
pod	8	8	100.0
total	28	121	23.1

package Backup::Omni::Utils;

our $VERSION = '0.01';

use Try::Tiny;
use Backup::Omni::Exception;
use Params::Validate ':all';
use DateTime::Format::Strptime;

use Backup::Omni::Class
  version   => $VERSION,
  base      => 'Badger::Utils',
  constants => 'HASH ARRAY OMNISTAT OMNIABORT',
  constant => {
      ABORT   => '%s -session %s',
      CONVERT => '%s -session %s -status_only',
      BADDATE => 'unable to perform date parsing, reason: %s',
      BADPARM => 'invalid parameters passed from %s at line %s',
      BADTEMP => 'bad temporary session id',
      NORESUL => 'unable to find any results for %s',
      NOABORT => 'unable to abort %s',
  },
  exports => {
      any => 'db2dt dt2db omni2dt trim ltrim rtrim convert_id abort_id',
      all => 'db2dt dt2db omni2dt trim ltrim rtrim convert_id abort_id',
  }
;

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

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

# Perl trim function to remove whitespace from the start and end of the string
sub trim {
    my $string = shift;

    $string =~ s/^\s+//;
    $string =~ s/\s+$//;

    return $string;

}

# Left trim function to remove leading whitespace
sub ltrim {
    my $string = shift;

    $string =~ s/^\s+//;

    return $string;

}

# Right trim function to remove trailing whitespace
sub rtrim {
    my $string = shift;

    $string =~ s/\s+$//;

    return $string;

}

sub db2dt {
    my ($p) = shift;

    my $dt;
    my $parser;

    if ($p =~ m/\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}/) {

        $parser = DateTime::Format::Strptime->new(
            pattern => '%Y-%m-%d %H:%M:%S',
            time_zone => 'local',
            on_error => sub {
                my ($obj, $err) = @_;
                my $ex = Backup::Omni::Exception->new(
                    type => 'backup.omni.utils.db2dt',
                    info => sprintf(BADDATE, $err)
                );
                $ex->throw;
            }
        );

        $dt = $parser->parse_datetime($p);

    } else {

        my ($package, $file, $line) = caller;
        my $ex = Backup::Omni::Exception->new(
            type => 'backup.omni.utils.db2dt',
            info => sprintf(BADPARM, $package, $line)
        );

        $ex->throw;

    }

    return $dt;

}

sub dt2db {
    my ($p) = shift;

    my $ft;
    my $parser;

    my $ref = ref($p);

    if ($ref && $p->isa('DateTime')) {

        $parser = DateTime::Format::Strptime->new(
            pattern => '%Y-%m-%d %H:%M:%S',
            time_zone => 'local',
            on_error => sub {
                my ($obj, $err) = @_;
                my $ex = Backup::Omni::Exception->new(
                    type => 'backup.omni.utils.dt2db',
                    info => sprintf(BADDATE, $err)
                );
                $ex->throw;
            }
        );

        $ft = $parser->format_datetime($p);

    } else {

        my ($package, $file, $line) = caller;

        my $ex = Backup::Omni::Exception->new(
            type => 'backup.omni.utils.dt2db',
            info => sprintf(BADPARM, $package, $line)
        );

        $ex->throw;

    }

    return $ft;

}

sub omni2dt {
    my ($p) = shift;

    my $dt;
    my $parser;

    if ($p =~ m/\w{3} \d{2} \w{3} \d{4} \d{2}:\d{2}:\d{2} \w{2} \w{3}/) {

        $parser = DateTime::Format::Strptime->new(
            pattern   => '%a %d %b %Y %r',
            time_zone => 'local',
            on_error => sub {
                my ($obj, $err) = @_;
                my $ex = Backup::Omni::Exception->new(
                    type => 'backup.omni.utils.omni2dt',
                    info => sprintf(BADDATE, $err)
                );
                $ex->throw;
            }
        );

        $dt = $parser->parse_datetime($p);

    } else {

        my ($package, $file, $line) = caller;

        my $ex = Backup::Omni::Exception->new(
            type => 'backup.omni.utils.omni2dt',
            info => sprintf(BADPARM, $package, $line)
        );

        $ex->throw;

    }

    return $dt;

}

sub convert_id {
    my $session = shift;

    my $id;

    if ($session =~ m/^R-/) {

        my $command = sprintf(CONVERT, OMNISTAT, $session);
        my @result = `$command`;
        my $rc = $?;

        unless (grep(/SessionID/, @result)) {

            my $ex = Backp::Omni::Exception->new(
                type => 'backup.omni.utils.convert_id',
                info => sprintf(NORESUL, $session)
            );

            $ex->throw;

        }

        ($id) = split(' ', $result[2]);

    } else {

        my $ex = Backup::Omni::Exception->new(
            type => 'backup.omni.utils.convert_id',
            info => BADTEMP
        );

        $ex->throw;

    }

    return $id;

}

sub abort_id {
    my $session = shift;

    my $command = sprintf(ABORT, OMNIABORT, $session);
    my @result = `$command`;
    my $rc = $?;

    unless (grep(/$session/, @result)) {

        my $ex = Backp::Omni::Exception->new(
            type => 'backup.omni.utils.abort_id',
            info => sprintf(NOABORT, $session)
        );

        $ex->throw;

    }

}

1;

__END__