# Created: 20000117
#
-if (&IsParam("useStrict")) { use strict; }
+# use strict; # TODO
use POSIX qw(strftime);
-use vars qw(%sched);
+use vars qw(%sched %schedule);
+
+# format: function name = (
+# str chanconfdefault,
+# int internaldefault,
+# bool deferred,
+# int next run, (optional)
+# )
+
+#%schedule = {
+# uptimeLoop => ("", 60, 1),
+#};
+
+sub setupSchedulersII {
+ foreach (keys %schedule) {
+ &queueTask($_, @{ $schedule{$_} });
+ }
+}
+
+sub queueTask {
+ my($codename, $chanconfdef, $intervaldef, $defer) = @_;
+ my $t = &getChanConfDefault($chanconfdef, $intervaldef);
+ my $waittime = &getRandomInt($t);
+
+ if (!defined $waittime) {
+ &WARN("interval == waittime == UNDEF for $codename.");
+ return;
+ }
+
+ my $time = $schedule{$codename}[3];
+ if (defined $time and $time > time()) {
+ &WARN("Sched for $codename already exists.");
+ return;
+ }
+
+# &VERB("Scheduling \&$codename() for ".&Time2String($waittime),3);
+
+ my $retval = $conn->schedule($waittime, sub {
+ \&$codename;
+ }, @args );
+}
sub setupSchedulers {
&VERB("Starting schedulers...",2);
&uptimeLoop(1);
&randomQuote(2);
&randomFactoid(2);
- &randomFreshmeat(2);
&logLoop(1);
&chanlimitCheck(1);
&netsplitCheck(1); # mandatory
&shmFlush(1); # mandatory
&slashdotLoop(2);
&plugLoop(2);
- &freshmeatLoop(2);
&kernelLoop(2);
&wingateWriteFile(2);
&factoidCheck(2); # takes a couple of seconds on a 486. defer it
+# todo: convert to new format... or nuke altogether.
&newsFlush(1);
+ # todo: squeeze this into a one-liner.
# my $count = map { exists $sched{$_}{TIME} } keys %sched;
my $count = 0;
foreach (keys %sched) {
-# next unless (exists $sched{$_}{TIME});
my $time = $sched{$_}{TIME};
next unless (defined $time and $time > time());
}
}
-sub randomFreshmeat {
- my $interval = &getChanConfDefault("randomFresheatInterval", 60);
-
- if (@_) {
- &ScheduleThis($interval, "randomFreshmeat");
- return if ($_[0] eq "2"); # defer.
- }
-
- my @chans = &ChanConfList("randomFreshmeat");
- return unless (scalar @chans);
-
- &Forker("freshmeat", sub {
- my $retval = &Freshmeat::randPackage();
-
- foreach (@chans) {
- next unless (&validChan($_));
-
- &status("sending random Freshmeat to $_.");
- &say($_, $line);
- }
- } );
-}
-
sub logLoop {
if (@_) {
&ScheduleThis(60, "logLoop");
### check if current size is too large.
if ( -s $file{log} > $param{'maxLogSize'}) {
- my $date = sprintf("%04d%02d%02d", (localtime)[5,4,3]);
+ my $date = sprintf("%04d%02d%02d", (gmtime)[5,4,3]);
$file{log} = $param{'logfile'} ."-". $date;
&status("cycling log file.");
my $max_time = &getChanConfDefault("seenMaxDays", 30) *60*60*24;
my $delete = 0;
- if ($param{'DBType'} =~ /^pgsql|mysql|sqlite/i) {
+ if ($param{'DBType'} =~ /^(pgsql|mysql|sqlite)/i) {
my $query;
if ($param{'DBType'} =~ /^mysql|sqlite$/i) {
}
my $sth = $dbh->prepare($query);
- $sth->execute;
-
- while (my @row = $sth->fetchrow_array) {
- my ($nick,$time) = @row;
+ if ($sth->execute) {
+ while (my @row = $sth->fetchrow_array) {
+ my ($nick,$time) = @row;
- &dbDel("seen","nick",$nick);
- $delete++;
- }
- $sth->finish;
- } elsif ($param{'DBType'} =~ /^dbm/i) {
- my $time = time();
-
- foreach (keys %seen) {
- my $delta_time = $time - &dbGet("seen", "time", "nick", $_);
- next unless ($delta_time > $max_time);
-
- &DEBUG("seenFlushOld: ".&Time2String($delta_time) );
- delete $seen{$_};
- $delete++;
+ &sqlDelete("seen", { nick => $nick } );
+ $delete++;
+ }
+ $sth->finish;
}
} else {
- &FIXME("seenFlushOld: for PG/NO-DB.");
+ &FIXME("seenFlushOld: for bad DBType:" . $param{'DBType'} . ".");
}
&VERB("SEEN deleted $delete seen entries.",2);
}
if ($delete or $duser) {
- &News::writeNews();
&status("NewsFlush: deleted: $delete news entries; $duser user cache.");
}
}
}
if (defined $limit and scalar keys %{ $channels{$chan}{''} } > $limit) {
- &FIXME("LIMIT: set too low!!! FIXME");
+ &FIXME("LIMIT: set too low!!!");
### run NAMES again and flush it.
}
delete $cache{warn}{chanlimit}{$chan};
if (!defined $limit) {
- &status("chanlimit: setting for first time or from netsplit, for $chan");
+ &status("chanlimit: $chan: setting for first time or from netsplit.");
}
if (exists $cache{chanlimitChange}{$chan}) {
if ($param{'DBType'} =~ /^(mysql|pgsql|sqlite)$/i) {
foreach $nick (keys %seencache) {
- my $retval = &dbReplace("seen", "nick", (
- "nick" => lc $seencache{$nick}{'nick'},
- "time" => $seencache{$nick}{'time'},
- "host" => $seencache{$nick}{'host'},
- "channel" => $seencache{$nick}{'chan'},
- "message" => $seencache{$nick}{'msg'},
- ) );
- delete $seencache{$nick};
- $flushed++;
-
- next;
-
- ###
- ### old code.
- ###
-
- my $exists = &dbGet("seen", "nick", "nick=".&dbQuote($nick) );
-
- if (defined $exists and $exists) {
- &dbUpdate("seen", "nick", $nick, (
- "time" => $seencache{$nick}{'time'},
- "host" => $seencache{$nick}{'host'},
- "channel" => $seencache{$nick}{'chan'},
- "message" => $seencache{$nick}{'msg'},
- ) );
- $stats{'old'}++;
- } else {
- my $retval = &dbInsert("seen", $nick, (
- "nick" => $seencache{$nick}{'nick'},
- "time" => $seencache{$nick}{'time'},
- "host" => $seencache{$nick}{'host'},
- "channel" => $seencache{$nick}{'chan'},
- "message" => $seencache{$nick}{'msg'},
- ) );
- $stats{'new'}++;
-
- ### TODO: put bad nick into a list and don't do it again!
- &FIXME("Should never happen! (nick => $nick)") if !$retval;
- }
-
- delete $seencache{$nick};
- $flushed++;
- }
-
- } elsif ($param{'DBType'} =~ /^dbm/i) {
-
- foreach $nick (keys %seencache) {
- my $retval = &dbInsert("seen", $nick, (
- "nick" => $seencache{$nick}{'nick'},
- "time" => $seencache{$nick}{'time'},
- "host" => $seencache{$nick}{'host'},
- "channel" => $seencache{$nick}{'chan'},
- "message" => $seencache{$nick}{'msg'},
- ) );
-
- ### TODO: put bad nick into a list and don't do it again!
- &FIXME("Should never happen! (nick => $nick)") if !$retval;
+ my $retval = &sqlReplace("seen", {
+ nick => lc $seencache{$nick}{'nick'},
+ time => $seencache{$nick}{'time'},
+ host => $seencache{$nick}{'host'},
+ channel => $seencache{$nick}{'chan'},
+ message => $seencache{$nick}{'msg'},
+ } );
delete $seencache{$nick};
$flushed++;
my $iconf = scalar( @x );
my $inow = scalar( keys %channels );
if ($iconf > 2 and $inow * 2 <= $iconf) {
- &FIXME("ircCheck: current channels * 2 <= config channels. FIXME.");
- &FIXME("ircCheck: iconf = $iconf");
- &FIXME("ircCheck: inow = $inow");
+ &FIXME("ircCheck: current channels ($inow) * 2 <= config channels ($iconf).");
# @joinchan = @x;
&joinNextChan();
}
- if (!$conn->connected or time() - $msgtime > 3600) {
+ # todo: fix on_disconnect()
+
+ if (time() - $msgtime > 3600) {
# todo: shouldn't we use cache{connect} somewhere?
if (exists $cache{connect}) {
&WARN("ircCheck: no msg for 3600 and disco'd! reconnecting!");
delete $cache{connect};
} else {
&status("IRCTEST: possible lost in space; checking. ".
- scalar(localtime) );
+ scalar(gmtime) );
&msg($ident, "TEST");
$cache{connect} = time();
}
if ($ident !~ /^\Q$param{ircNick}\E$/) {
# this does not work unfortunately.
- &WARN("ircCheck: ident($ident) != param{ircNick}($param{IrcNick}).");
+ &WARN("ircCheck: ident($ident) != param{ircNick}($param{ircNick}).");
# this check is misleading... perhaps we should do a notify.
if (! &IsNickInAnyChan( $param{ircNick} ) ) {
my ($shmid, $size) = ($2,$5);
next unless ($shmid != $shm and $size == 2000);
my $z = &shmRead($shmid);
- if ($z =~ /^(\d+): /) {
- my $time = $1;
+ if ($z =~ /^(\S+):(\d+):(\d+): /) {
+ my $n = $1;
+ my $pid = $2;
+ my $time = $3;
next if (time() - $time < 60*60);
-
+ # FIXME remove not-pid shm if parent process dead
+ next if ($pid == $bot_pid);
+ # don't touch other bots, if they're running.
+ next unless ($param{ircNick} =~ /^\Q$n\E$/);
} else {
-# &DEBUG("shm: $shmid is not ours or old blootbot => ($z)");
-# next;
+ &DEBUG("shm: $shmid is not ours or old blootbot => ($z)");
+ next;
}
&status("SHM: nuking shmid $shmid");
# compress logs that should have been compressed.
# todo: use strftime?
- my ($day,$month,$year) = (localtime(time()))[3,4,5];
+ my ($day,$month,$year) = (gmtime(time()))[3,4,5];
my $date = sprintf("%04d%02d%02d",$year+1900,$month+1,$day);
if (!opendir(DIR,"$bot_log_dir")) {
}
sub uptimeLoop {
- return unless &IsChanConf("uptime");
+ return if (!defined &uptimeWriteFile);
+# return unless &IsChanConf("uptime");
if (@_) {
&ScheduleThis(60, "uptimeLoop");
} );
}
-sub freshmeatLoop {
- if (@_) {
- &ScheduleThis(60, "freshmeatLoop");
- return if ($_[0] eq "2");
- }
-
- my @chans = &ChanConfList("freshmeatAnnounce");
- return unless (scalar @chans);
-
- &Forker("freshmeat", sub {
- my $data = &Freshmeat::freshmeatAnnounce();
-
- foreach (@chans) {
- next unless (&::validChan($_));
-
- &::status("sending freshmeat update to $_.");
- &msg($_, $data);
- }
- } );
-}
-
sub kernelLoop {
if (@_) {
&ScheduleThis(240, "kernelLoop");
my $time = time();
foreach (@list) {
- my $age = &getFactInfo($_, "modified_time");
+ my $age = &getFactInfo($_, "modified_time");
if (!defined $age or $age !~ /^\d+$/) {
if (scalar @list > 50) {
return if ($_[0] eq "2"); # defer.
}
- my $time = strftime("%H:%M", localtime(time()) );
+ my $time = strftime("%H:%M", gmtime(time()) );
my $c;
foreach (keys %channels) {
projects / infobot.git / blobdiff