File Coverage

blib/lib/JSON/ReadPath.pm

Criterion	Covered	Total	%
statement	29	52	55.7
branch	3	20	15.0
condition	1	5	20.0
subroutine	8	9	88.8
pod	0	3	0.0
total	41	89	46.0

package JSON::ReadPath;
$JSON::ReadPath::VERSION = '3.01';
use strict;
use warnings;
use JSON::XS qw( encode_json decode_json );
use Mouse;
use Template;

=head1 NAME

JSON::ReadPath - In Jenkins grep payload json data and assign to an environment
variable.

=head1 USAGE

Let's say Bitbucket pushed a payload '{"commits":{ "branch": "FooBar" }}'

And we want to grab the branch name from the payload.

 BRANCH=$(read_json.pl --env payload --path commits.branch)

=cut

has file => (
    is  => "ro",
    isa => "Str",
);

has string => (
    is  => "ro",
    isa => "Str",
);

has config => (
    is         => "ro",
    isa        => "HashRef",
    lazy_build => 1,
);

sub _build_config {
    my $self = shift;
    my $json_str = $self->from_file || $self->string
        or die "No data";
    return decode_json($json_str);
}

sub from_file {
    my $self = shift;
    my $file = $self->file
        or return;
    return if !-f $file;
    open my $FH, "<", $file
        or return;
    local $/;
    my $string = <$FH>;
    close $FH;
    return $string;
}

sub get {
    my $self   = shift;
    my $config = $self->config;
    my $path   = shift
        or return $config;
    my $tt    = Template->new;
    my $value = q{};

    $config->{json}        = \&encode_json;
    $config->{decode_json} = \&decode_json;

    $tt->process( \"[%$path%]", $config, \$value );
    return $value;
}

sub flat_list {
    my $self     = shift;
    my $data     = shift;
    my $base_key = shift || qq{};
    my @lines    = ();

    if ( ref $data ) {
        $base_key .= "_"
          if $base_key;
        if ( UNIVERSAL::isa( $data, "HASH" ) ) {
            push @lines, $base_key . "__KEYS", join ",", map { uc( $base_key . $_ ) } keys %$data
                if !$data->{$base_key . "__KEYS"};
            foreach my $key ( keys %$data ) {
                my $val = $data->{$key};
                push @lines, $self->flat_list( $val, uc( $base_key . $key ) );
            }
        }
        elsif ( UNIVERSAL::isa( $data, "ARRAY" ) ) {
            push @lines, $base_key . "__SIZE", $#$data;
            foreach my $i ( 0 .. $#$data ) {
                push @lines, $self->flat_list( $data->[$i], uc( $base_key . $i ) );
            }
        }
    }
    else {
        push @lines, uc($base_key), $data;
    }

    return @lines;
}

1;