--- deliantra/server/ext/schmorplog.ext 2006/12/15 19:29:18 1.1 +++ deliantra/server/ext/schmorplog.ext 2008/01/07 01:55:19 1.12 @@ -1,19 +1,33 @@ -#! perl +#! perl # depends=irc -our $UPDATE_LOGINS = Event->idle (repeat => 0, min => 1, data => cf::WF_AUTOCANCEL, cb => sub { - my ($status, @pl) = ext::commands::who_listing; +use Fcntl; +use Coro::AIO; - open my $fh, ">", cf::localdir . "/usercount"; - print $fh scalar @pl; +our $UPDATE_LOGINS = EV::idle sub { + $_[0]->stop; - open my $fh, ">", cf::localdir . "/userlisting.html"; - for ($status, @pl) { - s/[<&]//g; - print $fh "$_
\n"; - } -}); + cf::async { + my ($status, @pl) = ext::commands::who_listing; + + my $fh = aio_open "$LOCALDIR/usercount", O_WRONLY | O_CREAT | O_TRUNC, 0644 + or return; + aio_write $fh, 0, undef, scalar @pl, 0; + aio_close $fh; + + my $who; + for ($status, @pl) { + s/[<&]//g; + $who .= "$_
\n"; + } + + my $fh = aio_open "$LOCALDIR/userlisting.html", O_WRONLY | O_CREAT | O_TRUNC, 0644 + or return; + aio_write $fh, 0, undef, $who, 0; + aio_close $fh; + }; +}; -cf::attach_to_players +cf::player->attach ( on_login => sub { my ($pl) = @_; $pl->ob->set_ob_key_value (schmorplog_last_login => time); @@ -21,33 +35,41 @@ $pl->ob->set_ob_key_value (schmorplog_login_count => 1 + $pl->ob->get_ob_key_value ("schmorplog_login_count")); - (my $client = $pl->socket->client) =~ s/\n/\\n/g; + (my $client = $pl->ns->version) =~ s/\n/\\n/g; $pl->ob->set_ob_key_value (schmorplog_client => $client); - ext::schmorp_irc::do_notice (sprintf "%s logged in", $pl->ob->name); + ext::irc::do_notice (sprintf "%s logged in", $pl->ob->name); $UPDATE_LOGINS->start; + + warn "LOGIN: ", $pl->ob->name, " from ", $pl->ns->host; }, on_logout => sub { - my ($pl) = @_; + my ($pl, $cleanly) = @_; $pl->ob->set_ob_key_value (schmorplog_last_logout => time); - ext::schmorp_irc::do_notice (sprintf "%s left", $pl->ob->name); + ext::irc::do_notice (sprintf "%s left", $pl->ob->name); $UPDATE_LOGINS->start; + + warn "LOGOUT: ", $pl->ob->name, " from ", $pl->ns->host, " ($cleanly)"; }, on_birth => sub { my ($pl) = @_; - ext::schmorp_irc::do_notice (sprintf "%s was just born", $pl->ob->name); + ext::irc::do_notice (sprintf "%s was just born", $pl->ob->name); $pl->ob->set_ob_key_value (schmorplog_birthdate => time); + + warn "BIRTH: ", $pl->ob->name, " from ", $pl->ns->host; }, on_quit => sub { my ($pl) = @_; - ext::schmorp_irc::do_notice (sprintf "%s quit the game", $pl->ob->name); + ext::irc::do_notice (sprintf "%s quit the game", $pl->ob->name); + + warn "QUIT: ", $pl->ob->name, " from ", $pl->ns->host; }, on_death => sub { my ($pl) = @_; - ext::schmorp_irc::do_notice (sprintf "%s was killed by %s", $pl->ob->name, $pl->killer); + ext::irc::do_notice (sprintf "%s was killed by %s", $pl->ob->name, $pl->killer); $pl->ob->set_ob_key_value (schmorplog_death_count => 1 + $pl->ob->get_ob_key_value ("schmorplog_death_count")); @@ -60,5 +82,5 @@ my ($pl, $path) = @_; $pl->ob->set_ob_key_value (schmorplog_last_save => time); }, -; +);