innduct-stats-report

   1 #!/usr/bin/perl
   2
   3 use warnings;
   4 use strict;
   5
   6 use Data::Dumper;
   7
   8 our %counts;
   9
  10 # Input lines look like this:
  11 # May 23 19:00:02 chiark innduct[23236]: news.relativity.greenend.org.uk| info: completed feedfile read=76 (+bl=7,+err=0) missing=0 offered=76 (ch=76,nc=0) accepted=75 (ch=75,nc=0) unwanted=1 (id=1,bod=0,nc=0) rejected=0 (id=0,bod=0,nc=0) deferred=0 (id=0,bod=0,nc=0) missing=0 (id=0,bod=0,nc=0) connretry=0 (id=0,bod=0,nc=0)
  12
  13 while (<>) {
  14     next unless
  15         m/^ [:0-9A-Za-z ]+[ ]
  16             \w+[ ]
  17             innduct\[\d+\]:[ ]
  18             ([^|<>: \t]+)\|[ ]
  19             info:[ ]
  20             (?: completed | processed )[ ]
  21             .*?
  22             ( (?: [ ]
  23                   (?: \w+ = \d+
  24                     | \( [=+,0-9a-z]+ \)
  25                    )
  26                )+
  27               )
  28             $/x;
  29     my ($site,$strs) = ($1,$2);
  30     die unless $strs =~ m/^ read=/;
  31
  32     my $cur;
  33     $strs .= ' ';
  34     my $c= \%{ $counts{$site} };
  35 #print Dumper($c);
  36     for (;;) {
  37         if ($strs =~ s/^[ ] (\w+) = (\d+) [ ]/ /x) {
  38             $cur= $1;
  39             $c->{$cur} += $2;
  40         } elsif ($strs =~ s/^
  41                  [ ] \(
  42                    ( \+? \w+ ) = (\d+)
  43                    (?: , ([^()]+) )?
  44                  \) [ ]/ sprintf " (%s) ", defined $3 ? $3 : '' /xe) {
  45             $c->{"${cur}_$1"} += $2;
  46         } elsif ($strs =~ s/^ \(\) / /) {
  47         } elsif ($strs eq ' ') {
  48             last;
  49         } else {
  50             die "$_ // $strs ?";
  51         }
  52     }
  53
  54 #    print "$site|";
  55 #    foreach my $k (sort keys %$c) { printf " %s=%d", $k, $c->{$k}; }
  56 #    print "\n";
  57 #print Dumper(\%counts);;
  58 }
  59
  60 our $cwr;
  61 our $site;
  62
  63 foreach $site (sort keys %counts) {
  64     $cwr= $counts{$site};
  65     write;
  66 }
  67
  68 sub pct ($$) {
  69     my ($dend,$dor) = @_;
  70     return undef unless defined($dend) and $dor;
  71     return $dend * 100.0 / $dor;
  72 }
  73
  74 sub amt ($) {
  75     my ($v) = @_;
  76     return '' unless defined $v;
  77     if ($v < 9999) { return sprintf "%4d ", $v; }
  78     if ($v < 9999e3) { return sprintf "%4dk", ($v / 1e3); }
  79     return sprintf "%4dm", ($v / 1e3);
  80 }
  81
  82 format STDOUT_TOP =
  83 offrd acctd unwtd rejtd ac% rj% nochk nc%
  84 .
  85 format STDOUT =
  86 @>>>> @>>>> @>>>> @>>>> ^## ^## @>>>> ^## @<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<
  87 { (map { amt($cwr->{$_}) } qw(offered accepted unwanted rejected)),
  88   (map { pct($cwr->{$_}, $cwr->{offered}) } qw(accepted rejected)),
  89   ($cwr->{offered_nc} ? (amt($cwr->{offered_nc}),
  90                          pct($cwr->{offered_nc}, $cwr->{offered}))
  91                       : '',undef),
  92   ($site);
  93   }
  94 .