[ViewVC] Diff of: cvs/deliantra/server/lib/cf.pm

Comparing deliantra/server/lib/cf.pm (file contents):
Revision 1.228 by root, Mon Mar 26 16:53:33 2007 UTC vs.
Revision 1.238 by root, Sat Apr 14 07:23:00 2007 UTC

 use Coro::Event;
 use Coro::Timer;
 use Coro::Signal;
 use Coro::Semaphore;
 use Coro::AIO;
+use Coro::Storable;
 use BDB ();
 use Data::Dumper;
 use Digest::MD5;
 use Fcntl;
 use Time::HiRes;
 use Compress::LZF;
 # configure various modules to our taste
 #
+$Storable::canonical = 1; # reduce rsync transfers
 Coro::State::cctx_stacksize 256000; # 1-2MB stack, for deep recursions in maze generator
 Compress::LZF::sfreeze_cr { }; # prime Compress::LZF so it does not use require later
 $Event::Eval = 1; # no idea why this is required, but it is
       and return;
    1
 }
+=item cf::datalog type => key => value, ...
+Log a datalog packet of the given type with the given key-value pairs.
+=cut
+sub datalog($@) {
+  my ($type, %kv) = @_;
+  warn "DATALOG ", JSON::XS->new->ascii->encode ({ %kv, type => $type });
+}
 =back
 =cut
 #############################################################################
 }
 sub path($) {
    my $login = ref $_[0] ? $_[0]->ob->name : $_[0];
-   (playerdir $login) . "/$login.pl"
+   (playerdir $login) . "/playerdata"
 }
 sub find_active($) {
    $cf::PLAYER{$_[0]}
       and $cf::PLAYER{$_[0]}->active
       my $login = $_[0];
       my $guard = cf::lock_acquire "user_find:$login";
       $cf::PLAYER{$_[0]} || do {
+         # rename old playerfiles to new ones
+         #TODO: remove when no longer required
+         aio_link +(playerdir $login) . "/$login.pl.pst", (playerdir $login) . "/playerdata.pst";
+         aio_link +(playerdir $login) . "/$login.pl"    , (playerdir $login) . "/playerdata";
+         aio_unlink +(playerdir $login) . "/$login.pl.pst";
+         aio_unlink +(playerdir $login) . "/$login.pl";
          my $pl = load_pl path $login
             or return;
          $cf::PLAYER{$login} = $pl
       }
    }
    }
    \@paths
 }
-=item $player->ext_reply ($msgid, $msgtype, %msg)
+=item $player->ext_reply ($msgid, %msg)
 Sends an ext reply to the player.
 =cut
-sub ext_reply($$$%) {
+sub ext_reply($$%) {
    my ($self, $id, %msg) = @_;
    $msg{msgid} = $id;
    $self->send ("ext " . cf::to_json \%msg);
 }
-package cf;
+=item $player->ext_event ($type, %msg)
+Sends an ext event to the client.
+=cut
+sub ext_event($$%) {
+   my ($self, $type, %msg) = @_;
+   $self->ns->ext_event ($type, %msg);
+}
+=head3 cf::region
+=over 4
+=cut
+package cf::region;
+=item cf::region::find_by_path $path
+Tries to decuce the probable region for a map knowing only its path.
+=cut
+sub find_by_path($) {
+   my ($path) = @_;
+   my ($match, $specificity);
+   for my $region (list) {
+      if ($region->match && $path =~ $region->match) {
+         ($match, $specificity) = ($region, $region->specificity)
+            if $region->specificity > $specificity;
+      }
+   }
+   $match
+}
 =back
 =head3 cf::map
 =over 4
       $self->load_header_orig
          or return;
       $self->prepare_orig;
    }
+   $self->default_region (cf::region::find_by_path $self->{path})
+      unless $self->default_region;
    1
 }
 sub find;
 sub find {
    return unless $self->type == cf::PLAYER;
    if ($exit->slaying eq "/!") {
       #TODO: this should de-fi-ni-te-ly not be a sync-job
+      # the problem is that $exit might not survive long enough
+      # so it needs to be done right now, right here
       cf::sync_job { prepare_random_map $exit };
    }
    my $slaying = cf::map::normalise $exit->slaying, $exit->map && $exit->map->path;
    my $hp      = $exit->stats->hp;
          $self->goto ($slaying, $hp, $sp);
          1;
       }) {
          $self->message ("Something went wrong deep within the crossfire server. "
-                     . "I'll try to bring you back to the map you were before. "
+                       . "I'll try to bring you back to the map you were before. "
-                     . "Please report this to the dungeon master!",
+                       . "Please report this to the dungeon master!",
-                       cf::NDI_UNIQUE | cf::NDI_RED);
+                         cf::NDI_UNIQUE | cf::NDI_RED);
          warn "ERROR in enter_exit: $@";
          $self->leave_link;
       }
    })->prio (1);
    utf8::encode $text;
    $self->send_packet (sprintf "drawinfo %d %s", $flags || cf::NDI_BLACK, $text);
 }
+=item $client->ext_event ($type, %msg)
+Sends an exti event to the client.
+=cut
+sub cf::client::ext_event($$%) {
+   my ($self, $type, %msg) = @_;
+   $msg{msgtype} = "event_$type";
+   $self->send_packet ("ext " . cf::to_json \%msg);
+}
 =item $success = $client->query ($flags, "text", \&cb)
 Queues a query to the client, calling the given callback with
 the reply text on a reply. flags can be C<cf::CS_QUERY_YESNO>,
 }
 #############################################################################
 # the server's init and main functions
-sub load_faces {
+sub load_facedata {
-   my $path = sprintf "%s/faces", cf::datadir;
+   my $path = sprintf "%s/facedata", cf::datadir;
-   warn "loading faces from $path\n";
+   warn "loading facedata from $path\n";
-   my $faces;
+   my $facedata;
-   0 < aio_load $path, $faces
+   0 < aio_load $path, $facedata
       or die "$path: $!";
-   Coro::cede;
-   $faces = Storable::thaw $faces;
+   $facedata = Coro::Storable::thaw $facedata;
-   Coro::cede;
-   my $meta = delete $faces->{""};
-   $meta->{version} == 1
+   $facedata->{version} == 2
       or cf::cleanup "$path: version mismatch, cannot proceed.";
+   {
+      my $faces = $facedata->{faceinfo};
-   while (my ($face, $info) = each %$faces) {
+      while (my ($face, $info) = each %$faces) {
-      my $idx = (cf::face::find $face) || cf::face::alloc $face;
+         my $idx = (cf::face::find $face) || cf::face::alloc $face;
-      cf::face::set $idx, $info->{visibility}, $info->{magicmap};
+         cf::face::set $idx, $info->{visibility}, $info->{magicmap};
-      cf::face::set_data $idx, 0, $info->{data32}, $info->{chksum32};
+         cf::face::set_data $idx, 0, $info->{data32}, $info->{chksum32};
+         cf::face::set_data $idx, 1, $info->{data64}, $info->{chksum64};
-      Coro::cede;
+         Coro::cede;
-   }
+      }
-   while (my ($face, $info) = each %$faces) {
+      while (my ($face, $info) = each %$faces) {
-      next unless $info->{smooth};
+         next unless $info->{smooth};
-      my $idx = cf::face::find $face
+         my $idx = cf::face::find $face
-         or next;
+            or next;
-      if (my $smooth = cf::face::find $info->{smooth}) {
+         if (my $smooth = cf::face::find $info->{smooth}) {
-         cf::face::set_smooth $idx, $smooth;
+            cf::face::set_smooth $idx, $smooth, $info->{smoothlevel};
-      } else {
+         } else {
-         warn "smooth face '$info->{smooth}' not found for face '$face'";
+            warn "smooth face '$info->{smooth}' not found for face '$face'";
-      }
+         }
-      Coro::cede;
+         Coro::cede;
+      }
+   }
+   {
+      my $anims = $facedata->{animinfo};
+      while (my ($anim, $info) = each %$anims) {
+         cf::anim::set $anim, $info->{frames}, $info->{facings};
+         Coro::cede;
+      }
+      cf::anim::invalidate_all; # d'oh
    }
    1
 }
 sub reload_resources {
    load_resource_file sprintf "%s/%s/regions", cf::datadir, cf::mapdir
       or die "unable to load regions file\n";#d#
-   load_faces
+   load_facedata
-      or die "unable to load faces\n";#d#
+      or die "unable to load facedata\n";#d#
 }
 sub init {
    reload_resources;
 }

Diff Legend

-–
+Removed lines
-+
+Added lines
-<
+Changed lines
->
+Changed lines

Comparing deliantra/server/lib/cf.pm (file contents): Revision 1.228 by root, Mon Mar 26 16:53:33 2007 UTC vs. Revision 1.238 by root, Sat Apr 14 07:23:00 2007 UTC

Diff Legend

Comparing deliantra/server/lib/cf.pm (file contents):
Revision 1.228 by root, Mon Mar 26 16:53:33 2007 UTC vs.
Revision 1.238 by root, Sat Apr 14 07:23:00 2007 UTC