File Coverage

blib/lib/Apache/Hadoop/Watcher/Base.pm

Criterion	Covered	Total	%
statement	17	46	36.9
branch	0	14	0.0
condition	0	2	0.0
subroutine	6	12	50.0
pod	0	1	0.0
total	23	75	30.6

#
# (C) 2015, Snehasis Sinha
#
package Apache::Hadoop::Watcher::Base;

use 5.010001;
use strict;
use warnings;

use IO::Socket::INET;
use LWP::UserAgent;
use Data::Dumper;

our @ISA = qw();
our $VERSION = '0.01';


# base methods
sub new {
    my $class = shift;
    my %args  = @_;
    my $self  = { };
    bless $self, $class;
    return $self;
}

# common methods
sub _wget {
    my ($self, %opts) = (@_);
    my $content;
    my $res;
    my $ua;

    $ua  = LWP::UserAgent->new;
    $res = $ua->get ( $opts{'url'} );
    return 'error' unless $res->is_success;

    $content = $res->decoded_content;
    return $content;
}

sub _port {
    my (%opts) = (@_);
    my $socket = IO::Socket::INET->new(
        Proto=>'tcp',
        PeerAddr=>$opts{'host'} || '0.0.0.0',
        PeerPort=>$opts{'port'} || 0
        ) || undef;
    return (defined $socket ? 1 : undef);
}

# changing json boolean object to perl values
sub _jsontr {
    my ($self, $hash) = (@_);
    foreach my $v ( values %{$hash} ) {
        $v = ($v ? 'true' : 'false') if ref $v eq 'JSON::PP::Boolean';
        $self->_jsontr ( $v ) if ref $v eq 'HASH';
    }
    #return $hash;
}

sub _jsonjmx {
	my ($self, $hook) = (@_);
	if ( ref $hook eq 'HASH' ) {
		$self->_jsontr ( $hook );
	}
	if ( ref $hook eq 'ARRAY' ) {
		foreach my $e ( @$hook ) {
			$self->_jsontr ( $e );
		}
	}
}

# dumps output hashref
sub _print {
    my ($self, %opts) = (@_);
    print Dumper ( $opts{'output'} );
}

1;

__END__