From Code to Community: Sponsoring The Perl and Raku Conference 2025 Learn more

MIXAS / App-NDTools-0.5.2.2-TRIAL / lib / App / NDTools / NDProc / Module / Pipe.pm 

            

              
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
—
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107

              
package App::NDTools::NDProc::Module::Pipe;
use strict;
use warnings FATAL => 'all';
use parent 'App::NDTools::NDProc::Module';
use IPC::Run3;
use Log::Log4Cli;
use App::NDTools::Slurp qw(s_decode s_encode);
use Struct::Path 0.80 qw(path);
use Struct::Path::PerlStyle 0.80 qw(str2path);
our $VERSION = '0.05';
sub MODINFO { "Modify structure using external process" }
sub arg_opts {
    my $self = shift;
    return (
        $self->SUPER::arg_opts(),
        'command|cmd=s' => \$self->{OPTS}->{command},
        'preserve=s@' => \$self->{OPTS}->{preserve},
        'strict' => \$self->{OPTS}->{strict},
    )
}
sub check_rule {
    my ($self, $rule) = @_;
    my $out = $self;
    # process full source if no paths defined # FIXME: move it to parent and make common for all mods
    push @{$rule->{path}}, '' unless (@{$rule->{path}});
    unless (defined $rule->{command}) {
        log_error { 'Command to run should be defined' };
        $out = undef;
    }
    return $out;
}
sub process_path {
    my ($self, $data, $path, $opts) = @_;
    my $spath = eval { str2path($path) };
    die_fatal "Failed to parse path ($@)", 4 if ($@);
    my @refs = eval { path(${$data}, $spath, strict => $opts->{strict}) };
    die_fatal "Failed to lookup path '$path'", 4 if ($@);
    for my $r (@refs) {
        my $in = s_encode(${$r}, 'JSON', { pretty => 1 });
        my ($out, $err);
        run3($opts->{command}, \$in, \$out, \$err, { return_if_system_error => 1});
        die_fatal "Failed to run '$opts->{command}' ($!)", 2
            if ($? == -1); # run3 specific
        unless ($? == 0) {
            die_fatal "'$opts->{command}' exited with " . ($? >> 8) .
                ($err ? " (" . join(" ", split("\n", $err)) . ")" : ""), 16;
        }
        ${$r} = s_decode($out, 'JSON');
    }
}
1; # End of App::NDTools::NDProc::Module::Pipe
__END__
=head1 NAME
Pipe - pipe structure to external program and apply result.
=head1 OPTIONS
=over 4
=item B<--[no]blame>
Blame calculation toggle. Enabled by default.
=item B<--command|--cmd> E<lt>commandE<gt>
Command to run. Exit 0 expected for success. JSON emitted to it's STDERR
will be applied to original structure.
=item B<--path> E<lt>pathE<gt>
Structure to send to cammand's STDIN.
=item B<--preserve> E<lt>pathE<gt>
Preserve specified structure parts. May be used several times.
=item B<--strict>
Fail if specified path doesn't exists.
=back
=head1 SEE ALSO
L<ndproc(1)>, L<ndproc-modules>
L<nddiff(1)>, L<ndquery(1)>, L<Struct::Path::PerlStyle>