root/lib/Resmon/Module/FRESHSVN.pm

package Resmon::Module::FRESHSVN;
use strict;
use Resmon::ExtComm qw/cache_command/;
use vars qw/@ISA/;
@ISA = qw/Resmon::Module/;

sub handler {
  my $arg = shift;
  my $os = $arg->fresh_status();
  return $os if $os;
  my $dir = $arg->{'object'};
  my $moutput = cache_command("/opt/omni/bin/svn info $dir", 60);
  my @mlines = split (/\n/,$moutput);
  my ($URL,$mr);
  for(@mlines) {
    if (/^URL:\s*(.*)$/) { $URL=$1; }
    elsif (/^Revision:\s*(\d+)/) { $mr = $1; }
  }
  return ($arg->set_status("BAD(wrong URL, in conf:".$arg->{'URL'}.", checked out: $URL)")) if ($URL ne $arg->{'URL'});
  my $uoutput = cache_command("/opt/omni/bin/svn info --username svnsync --password Athi3izo  --no-auth-cache --non-interactive $URL", 60);
  my @ulines = split (/\n/,$uoutput);
  my ($ur);
  for(@ulines) {
    if (/^Revision:\s*(\d+)/) { $ur = $1; }
  }
  if($ur == $mr){ return($arg->set_status("OK(rev:$ur)")); }
  else{
    my ($uY,$uM,$uD,$uh,$um,$us);
    for(@ulines) {
      if (/^Last Changed Date:\s*(\d{4})-(\d{1,2})-(\d{1,2}) (\d{1,2}):(\d{2}):(\d{2})/) {
        ($uY,$uM,$uD,$uh,$um,$us) = ($1,$2,$3,$4,$5,$6);
      }
    }
    my $routput = cache_command("/opt/omni/bin/svn info --username svnsync --password Athi3izo  --no-auth-cache --non-interactive $URL\@$mr", 60);
    my @rlines = split (/\n/,$routput);
    my ($mY,$mM,$mD,$mh,$mm,$ms);
    for(@rlines) {
       if (/^Last Changed Date:\s*(\d{4})-(\d{1,2})-(\d{1,2}) (\d{1,2}):(\d{2}):(\d{2})/) {
         ($mY,$mM,$mD,$mh,$mm,$ms) = ($1,$2,$3,$4,$5,$6);
       }
    }
    my ($mTime,$uTime,$lag,$maxlag);
    $mTime=$ms+60*($mm+60*($mh+24*($mD+31*($mM+12*$mY))));
    $uTime=$us+60*($um+60*($uh+24*($uD+31*($uM+12*$uY))));
    $lag=$uTime-$mTime;
    $maxlag=$arg->{'maxlag'}*60 || 330;
    if ($lag <= $maxlag){
      return($arg->set_status("OK(delay = $lag < $maxlag)")); 
    }
    elsif ($us+60*($um+60*($uh+24*$uD))<$maxlag) {
      my ($cD,$ch,$cm,$cs) = split ( / /, `date '+%d %H %M %S'`);
      my $cTime = $cs+60*($cm+60*($ch+24*$cD));
      if ($cTime<$maxlag) {
        return($arg->set_status("WARNING(check unreliable, check later)"));
      }
      else {
        return($arg->set_status("BAD(my rev:$mr, repo rev:$ur, delay: $lag > $maxlag)"));
      }
    }
    else {
      return($arg->set_status("BAD(my rev:$mr, repo rev:$ur, delay: $lag > $maxlag)"));
    }
  }
}