path: root/util/waterball.pl

#!/usr/bin/perl
# $Id$
use lib '/home/bbs/bin/';
use Time::Local;
use LocalVars;
use Mail::Sender;
use IO::All;
use strict;

my(%water);
sub main
{
    my($fndes, $userid, $mailto, $outmode, $fnsrc);
    chdir($BBSHOME);
    foreach $fndes ( <$JOBSPOOL/water.des.*> ){
    ($userid, $mailto, $outmode, $fnsrc) = parsedes($fndes);
    next if( !$userid || !-e $fnsrc );

    $mailto = "$userid.bbs\@$MYHOSTNAME" if( $mailto eq '.');
    undef %water;
    process($fnsrc, "$TMP/water/", $outmode, $userid);
    output("$userid.bbs\@$MYHOSTNAME", $mailto, $mailto =~ /\.bbs/);
    unlink($fndes, $fnsrc);
    }
}

sub parsedes($)
{
    my $t < io($_[0]);
    my $fnsrc = $_[0];
    $fnsrc =~ s/\.des\./\.src\./;
    return (split("\n", $t), $fnsrc);
}

sub process($$$$)
{
    my($fn, $outdir, $outmode, $me) = @_;
    my($cmode, $who, $time, $say, $orig, %LAST, $len) = ();
    open DIN, "<$fn";
    while( <DIN> ){
    next if( !(($cmode, $who, $time, $say, $orig) = parse($_)) || !$who );

    if( $outmode ){
        $water{$who} .= $orig;
    } else {
        next if( $say =~ /<<(上|下)站通知>> -- 我(走|來)囉！/ );
        if( $time - $LAST{$who} > 1800 ){
        $water{$who} .= (scalar localtime($LAST{$who}))."\n\n"
            if( $LAST{$who} );
        $water{$who} .= scalar localtime($time) . "\n";
        }
        
        $len = max(length($who), length($me)) + 1;
        $water{$who} .= sprintf("%-${len}s %s\n",
                    ($cmode ? $who : $me).':' ,
                    $say);
        $LAST{$who} = $time;
    }
    }
    if( $outmode == 0 ){
    $water{$_} .= scalar localtime($LAST{$_})
        foreach( keys %LAST );
    }
}

sub parse($)
{
    my($str) = @_;
    my($cmode, $who, $year, $month, $day, $hour, $min, $sec, $say);
    $cmode = ($str =~ /^To/) ? 0 : 1;
    ($who, $say, $month, $day, $year, $hour, $min, $sec) =
    $cmode ?
    $str =~ m|★(.+?)\[37;45m\s*(.*).*?\[(\w+)/(\w+)/(\w+) (\w+):(\w+):(\w+)\]| :
    $str =~ m|^To (.+?):\s*(.*)\[(\d+)/(\d+)/(\d+) (\d+):(\d+):(\d+)\]|;
    return ( !(1 <= $month && $month <= 12 &&
           1 <= $day   && $day   <= 31 &&
           0 <= $hour  && $hour  <= 23 &&
           0 <= $min   && $min   <= 59 &&
           0 <= $sec   && $sec   <= 59 &&
           1970 <= $year && $year <= 2038) ?
         () :
         ($cmode, $who,
          timelocal($sec, $min, $hour, $day, $month - 1, $year),
          $say, $_[0]) );
}

sub output
{
    my($from, $tomail, $bbsmail) = @_;
    my $ms = new Mail::Sender{smtp    => $SMTPSERVER,
                  from    => $from,
                  charset => 'big5'};

    foreach( keys %water ){
    $ms->MailMsg({to      => $tomail,
              subject => "和 $_ 的水球記錄",
              msg     => $water{$_}});
    }
}

sub max
{
    return $_[0] > $_[1] ? $_[0] : $_[1];
}

main();
1;