--- ChivanetConvoBot/convobot 2025/02/03 04:22:49 1.1.1.1 +++ ChivanetConvoBot/convobot 2025/02/03 18:14:15 1.5 @@ -9,6 +9,18 @@ # Licensed AGPL-3.0 # # $Log: convobot,v $ +# Revision 1.5 2025/02/03 18:14:15 snw +# Further work on bot +# +# Revision 1.4 2025/02/03 17:31:28 snw +# Further MySQL work +# +# Revision 1.3 2025/02/03 15:38:12 snw +# Begin SQL work +# +# Revision 1.2 2025/02/03 04:28:34 snw +# Fix syntax message +# # Revision 1.1.1.1 2025/02/03 04:22:49 snw # Initial Commit # @@ -19,78 +31,131 @@ use Net::OSCAR; use Getopt::Long; use Data::Dumper; use HTML::Strip; +use DBI; my $idlemax = 1800; my $botsn = ''; my $botsrv = ''; my $botpw = ''; my $rasurl = ''; + +my $dbhost = ''; +my $dbname = ''; +my $dbusername = ''; +my $dbpw = ''; +my $dbconn = ''; +my $autogreet = 'off'; + my $chatroom = ''; my $online = 0; my $chat_idle_seconds = 0; my $last_chat_received = time(); my $start_time = time(); +my $dbh = ''; +my $dsn = ''; my @congregants = (); -my %seen = (); -GetOptions("aimsn=s" => \$botsn, - "aimhost=s" => \$botsrv, - "aimpw=s" => \$botpw, - "idlemax=s" => \$idlemax, - "chatroom=s" => \$chatroom) - or die("error in command line arguments"); +$oscar = Net::OSCAR->new(); -%signon = ( - screenname => $botsn, - password => $botpw, - host => $botsrv, -); +sub get_seen_status { + my($sn, $chat) = @_; -$oscar = Net::OSCAR->new(); -#$room = Net::OSCAR::Connection::Chat; + my $sth = $dbh->prepare("SELECT * FROM seen WHERE aim_server=? AND aim_sn=? AND aim_chatroom=? AND sn=?"); + $sth->execute($botsrv, $botsn, $chatroom, $sn); + + if($sth->rows > 0) { + my $hashref = $sth->fetchrow_hashref(); + $chat->chat_send("I last saw $sn on $hashref->{seen_time}."); + } + else { + $chat->chat_send("I have never seen $sn."); + } + +} + +sub update_seen_status { + my($sn) = @_; + + my $del = $dbh->prepare("DELETE FROM seen WHERE aim_server=? AND aim_sn=? AND aim_chatroom=? AND sn=?"); + $del->execute($botsrv, $botsn, $chatroom, $sn) or die "error DBI->errstr()"; + + my $ins = $dbh->prepare("INSERT INTO seen (aim_server, aim_sn, aim_chatroom, sn, seen_time) VALUES (?, ?, ?, ?, ?)"); + my $seentime = localtime(); + $ins->execute($botsrv, $botsn, $chatroom, $sn, $seentime) or die "error DBI->errstr()"; +} sub signon_done { print "[OK]\n"; + print "convobot: joining $chatroom..."; $oscar->chat_join($chatroom, 5); + print "[OK]\n"; $online = 1; } +sub oscar_error { + my($oscar, $connection, $error, $description, $fatal) = @_; + + if($fatal != 0) { + die "\nconvobot: fatal OSCAR error: $description\n"; + } + else { + print "\nconvobot: recoverable OSCAR error: $description\n"; + } + +} + sub chat_joined { my($oscar, $chatname, $chat) = @_; + print "bot: chat joined [$chatname]\n"; + $room = $chat; bless $room, "Net::OSCAR::Connection::Chat"; + + print "convobot: connecting to database $dbname\@$dbhost..."; + + $dsn = "DBI:mysql:database=$dbname;host=$dbhost;port=3306;mysql_connect_timeout=5;"; + $dbh = DBI->connect($dsn, $dbusername, $dbpw, {RaiseError => 1}); + die "convobot: failed to connect to MySQL database: DBI->errstr()" unless $dbh; + + print "[OK]\n"; + + $oscar->set_callback_chat_buddy_in(\&chat_buddy_in); + $oscar->set_callback_chat_buddy_out(\&chat_buddy_out); } sub chat_buddy_in { my ($oscar, $who, $chat, $buddy) = @_; - $seen{$who} = localtime(); + update_seen_status($who); if($who ne $botsn) { push(@congregants, $who); - print "[$who] has joined\n"; + print "convobot: [$who] has joined\n"; } else { - print "[$who] has joined (ignoring bot)\n"; + print "convobot: [$who] has joined (ignoring bot)\n"; } - if(time() - $start_time > 2) { - my @phrases = ('Welcome to [room], [user]! :-)', - 'How\'s it going, [user]?', - 'Hey [user]! Bring any snacks?', - 'Heya [user]! Hope your day is going well!', - 'Ooo, [user] has joined [room]! Now the party can start!'); - - my $phrase = $phrases[rand @phrases]; - $phrase =~ s/\[user\]/$who/g; - $phrase =~ s/\[room\]/$chatroom/g; - my $phrasefix = "
$phrase"; - $chat->chat_send($phrasefix); - } - else { - print "Not sending greeting for 2 seconds after startup\n"; + + if($autogreet eq "on") { + if(time() - $start_time > 2) { + my @phrases = ('Welcome to [room], [user]! :-)', + 'How\'s it going, [user]?', + 'Hey [user]! Bring any snacks?', + 'Heya [user]! Hope your day is going well!', + 'Ooo, [user] has joined [room]! Now the party can start!'); + + my $phrase = $phrases[rand @phrases]; + $phrase =~ s/\[user\]/$who/g; + $phrase =~ s/\[room\]/$chatroom/g; + my $phrasefix = "
$phrase"; + $chat->chat_send($phrasefix); + } + else { + print "convobot: not sending greeting for 2 seconds after startup\n"; + } } } @@ -101,7 +166,7 @@ sub chat_buddy_out { $index++ until $congregants[$index] eq $who; splice(@congregants, $index, 1); - print "$who has left\n"; + print "convobot: $who has left\n"; } sub chat_im_in { @@ -111,27 +176,36 @@ sub chat_im_in { my $rawcmd = $hs->parse($message); my @cmd = split(' ', $rawcmd); - $seen{$who} = localtime(); - - if($cmd[0] eq "!seen") { - if(exists($cmd[1])) { - if(exists($seen{$cmd[1]})) { - $chat->chat_send("I last saw $cmd[1] at $seen{$cmd[1]}"); - } - else { - $chat->chat_send("I've never seen $cmd[1]"); - } - } - else { - $chat->chat_send("Syntax: !seen "); - } + update_seen_status($who); + + if($who ne $botsn) { + if($cmd[0] eq "!seen") { + if(exists($cmd[1])) { + get_seen_status($cmd[1], $chat); + } + else { + $chat->chat_send("Syntax: !seen screenname"); + } + } + elsif($cmd[0] eq "!speak") { + send_idle_message(); + } + elsif($cmd[0] eq "!quote") { + my $fortune = `/usr/games/fortune`; + $room->chat_send($fortune); + } + elsif($cmd[0] eq "!help") { + $room->chat_send("You can enter the following commands:"); + $room->chat_send(" !seen screenname (find out when screenname was last in the chat)"); + $room->chat_send(" !speak (send a random message)"); + $room->chat_send(" !quote (send a quote)"); + } } - - - + + $last_chat_received = time(); - print "chat received from $who; resetting idle counter\n"; + print "convobot: chat received from $who; resetting idle counter\n"; } @@ -156,18 +230,46 @@ sub send_idle_message { $room->chat_send($phrasefix); $last_chat_received = time(); } + } $oscar->set_callback_signon_done(\&signon_done); $oscar->set_callback_chat_joined(\&chat_joined); -$oscar->set_callback_chat_buddy_in(\&chat_buddy_in); -$oscar->set_callback_chat_buddy_out(\&chat_buddy_out); $oscar->set_callback_chat_im_in(\&chat_im_in); +$oscar->set_callback_error(\&oscar_error); print "ChivaNet Conversation Bot v0.0.1\n"; print " Copyright (C) 2025 Coherent Logic Development LLC\n\n"; -print "bot: attempting to sign in... "; +GetOptions("aimsn=s" => \$botsn, + "aimhost=s" => \$botsrv, + "aimpw=s" => \$botpw, + "idlemax=s" => \$idlemax, + "chatroom=s" => \$chatroom, + "dbhost=s" => \$dbhost, + "dbname=s" => \$dbname, + "dbusername=s" => \$dbusername, + "dbpw=s" => \$dbpw, + "autogreet=s" => \$autogreet) + or die("error in command line arguments"); + +%signon = ( + screenname => $botsn, + password => $botpw, + host => $botsrv, +); + +print "AIM Server: $botsrv\n"; +print "AIM Screen Name: $botsn\n"; +print "Chat Room: $chatroom\n"; +print "DB Host: $dbhost\n"; +print "DB Name: $dbname\n"; +print "DB Username: $dbusername\n"; +print "Idle before ping: $idlemax\n"; +print "Auto-Greet: $autogreet\n\n"; + + +print "convobot: attempting to sign in..."; $oscar->signon(%signon); while(1) {