Changeset 1190 for obs_notify_generic


Ignore:
Timestamp:
Jun 17, 2015, 6:07:05 PM (9 years ago)
Author:
joergs
Message:

perltidy

File:
1 edited

Legend:

Unmodified
Added
Removed
  • obs_notify_generic/obs_notify_generic.pm

    r1188 r1190  
    4848    };
    4949    if ( not $self->{'logfile'} ) {
     50        ##$self->{'logfile'} = "/tmp/notify_generic.log";
    5051        $self->{'logfile'} = "/srv/obs/log/notify_generic.log";
    51         #$self->{'logfile'} = "/tmp/notify_generic.log";
    5252    }
    5353    bless $self, shift;
     
    6060
    6161    $type = "UNKNOWN" unless $type;
    62    
     62
    6363    my $cfg_type;
    6464    if ( $self->{'cfg'}->{$type} ) {
     
    7575            #print "key: $key\n";
    7676            #print "value: $value\n";
    77             if ( not( exists($paramRef->{$key}) ) ) {
    78                                 error_msg( "$type (". Data::Dumper->new( [$paramRef] )->Indent(0)->Dump ."): filter for '". $key ."' is invalid" );
     77            if ( not( exists( $paramRef->{$key} ) ) ) {
     78                error_msg( "$type ("
     79                      . Data::Dumper->new( [$paramRef] )->Indent(0)->Dump
     80                      . "): filter for '"
     81                      . $key
     82                      . "' is invalid" );
    7983                $match = 0;
     84
    8085                # exit loop
    8186                last;
     
    8893            if ( $entry->{'action'} ) {
    8994
    90                 #print $entry->{'action'}, "\n";
    9195                if ( $paramRef->{'project'} ) {
    92                                         my $project = $paramRef->{'project'};
    93                                         $project =~ s/:/:\//g;
    94                                         $paramRef->{'project_path'}="/srv/obs/repos/" . $project;
     96                    my $project = $paramRef->{'project'};
     97                    $project =~ s/:/:\//g;
     98                    $paramRef->{'project_path'} = "/srv/obs/repos/" . $project;
    9599                }
    96                 # create regex,
     100
     101                # create regex,
    97102                # test against longest string first to avoid partial replacement ($repo, $repository)
    98                 my $check = join '|', sort {
    99                         length($b) <=> length($a)
    100                     } keys %{$paramRef};
     103                my $check = join '|',
     104                  sort { length($b) <=> length($a) } keys %{$paramRef};
    101105                my $action = $entry->{'action'};
    102106                $action =~ s/\$($check)/$paramRef->{$1}/g;
    103107
    104                                 $extra = {
    105                                         'action_template' => $entry->{'action'},
    106                                         'action'          => $action,
    107                                 };
    108                
     108                $extra = {
     109                    'action_template' => $entry->{'action'},
     110                    'action'          => $action,
     111                };
     112
    109113                #$self->run_wait( $action, $extra );
    110114                $self->run_daemon( $action, $extra );
     
    124128    my ( $self, $action, $extra ) = @_;
    125129
    126         #print $action, "\n";
    127         my $in = undef;
    128         my $out;
    129         my $err;
    130         my $rc;
    131         eval {
    132                 my $process =
    133                         IPC::Run::start( [ "sh", "--login", "-c", "HOME=/usr/lib/obs $action", "2>&1" ],
    134                         \$in, \$out, \$err );
    135                 $process->finish();
    136                 $rc = $process->result(0);
    137         };
    138         if ($@) {
    139 
    140                 #print "eval: ", $@;
    141                 $out = join( "\n", $@ );
    142                 $rc = 127;
    143         }
    144 
    145         #print "rc:  ", $rc, "\n";
    146         #print "out: ", $out, "\n";
    147         chomp($out);
    148 
    149         #print "err: ", $err, "\n";
    150         $extra->{'returncode'} = $rc;
    151         $extra->{'output'} = $out;
     130    my $in = undef;
     131    my $out;
     132    my $err;
     133    my $rc;
     134    eval {
     135        my $process =
     136          IPC::Run::start(
     137            [ "sh", "--login", "-c", "HOME=/usr/lib/obs $action", "2>&1" ],
     138            \$in, \$out, \$err );
     139        $process->finish();
     140        $rc = $process->result(0);
     141    };
     142    if ($@) {
     143
     144        #print "eval: ", $@;
     145        $out = join( "\n", $@ );
     146        $rc = 127;
     147    }
     148
     149    chomp($out);
     150
     151    $extra->{'returncode'} = $rc;
     152    $extra->{'output'}     = $out;
    152153}
    153154
     
    156157    my ( $self, $action, $extra ) = @_;
    157158
    158     my $daemon=Proc::Daemon->new();
    159     my $pid=$daemon->Init( {
    160             exec_command => "date --rfc-3339=seconds; echo '$action'; $action",
    161             child_STDOUT => "+>>" . $self->{'logfile'} . ".out.log",
     159    my $daemon = Proc::Daemon->new();
     160    my $pid    = $daemon->Init(
     161        {
     162            exec_command => "date --rfc-3339=seconds; echo '$action'; $action",
     163            child_STDOUT => "+>>" . $self->{'logfile'} . ".out.log",
    162164            child_STDERR => "+>>" . $self->{'logfile'} . ".out.log",
    163         } );
    164 
    165     #print $daemon->Status($pid); 
    166        
     165        }
     166    );
     167
     168    #print $daemon->Status($pid);
     169
    167170    $extra->{'pid'} = $pid;
    168171}
     
    193196
    194197    print $fh localtime->strftime("%Y%m%d %H%M%S"), " TYPE=$type";
    195    
     198
    196199    if ($extra) {
    197200        print $fh "\n";
Note: See TracChangeset for help on using the changeset viewer.