--- deliantra/server/lib/cf.pm 2006/02/07 01:03:44 1.4 +++ deliantra/server/lib/cf.pm 2006/06/11 15:02:16 1.15 @@ -2,6 +2,7 @@ use Symbol; use List::Util; +use Storable; use strict; @@ -23,6 +24,8 @@ }; } +my %ignore_set = (MAP_PROP_PATH => 1); # I hate the plug-in api. Deeply! + # generate property mutators sub prop_gen { my ($prefix, $class) = @_; @@ -42,7 +45,7 @@ *{"$class\::set_$sub"} = sub { $_[0]->set_property ($type, $idx, $_[1]); - }; + } unless $ignore_set{$prop}; } } @@ -60,19 +63,29 @@ @cf::object::player::ISA = 'cf::object'; @cf::object::map::ISA = 'cf::object'; +my %ext_pkg; my @exts; my @hook; my %command; +my %extcmd; sub inject_event { - my ($data) = @_; + my $extension = shift; + my $event_code = shift; - my $cb = $hook[$data->{event_code}] + my $cb = $hook[$event_code]{$extension} or return; - $_->($data) for values %$cb; + &$cb +} + +sub inject_global_event { + my $event = shift; + + my $cb = $hook[$event] + or return; - () + List::Util::max map &$_, values %$cb } sub inject_command { @@ -96,10 +109,22 @@ $COMMAND{"$name\000"} = List::Util::max map $_->[0], @{ $command{$name} }; } +sub register { + my ($base, $pkg) = @_; + + for my $idx (0 .. $#EVENT) { + if (my $ref = $pkg->can ("on_$EVENT[$idx]")) { + warn "registering $EVENT[$idx] hook to '$pkg'\n"; + $hook[$idx]{$base} = $ref; + } + } +} + sub load_extension { my ($path) = @_; $path =~ /([^\/\\]+)\.ext$/ or die "$path"; + my $base = $1; my $pkg = $1; $pkg =~ s/[^[:word:]]/_/g; $pkg = "cf::ext::$pkg"; @@ -119,17 +144,12 @@ or die "$path: $@"; push @exts, $pkg; + $ext_pkg{$base} = $pkg; - no strict 'refs'; - +# no strict 'refs'; # @{"$pkg\::ISA"} = cf::ext::; - for my $idx (0 .. $#EVENT) { - if (my $ref = $pkg->can ("on_$EVENT[$idx]")) { - warn "registering $EVENT[$idx] hook\n"; - $hook[$idx]{$pkg} = $ref; - } - } + register $base, $pkg; } sub unload_extension { @@ -155,6 +175,20 @@ } } + # remove extcmds + for my $name (keys %command) { + my @cb = grep $_->[2] ne $pkg, @{ $command{$name} }; + + if (@cb) { + $command{$name} = \@cb; + $COMMAND{"$name\000"} = List::Util::max map $_->[0], @cb; + } else { + delete $command{$name}; + delete $COMMAND{"$name\000"}; + } + } + + Symbol::delete_package $pkg; } @@ -196,6 +230,116 @@ } }; +############################################################################# +# extcmd framework, basically convert ext arg1 args +# into pkg::->on_extcmd_arg1 (...) while shortcutting a few + +sub on_extcmd { + my ($pl, $buf) = @_; + + my ($id, $pkg, $name, $data) = split / /, $buf, 4; + + if (my $method = "cf::ext::$pkg"->can ("on_extcmd_$name")) { + $method->($pl, $id, $buf); + } +} + +############################################################################# +# load/save/clean perl data associated with a map + +*on_mapclean = sub { + my ($map) = @_; + + my $path = $map->tmpname; + defined $path or return; + + unlink "$path.cfperl"; +}; + +*on_mapin = +*on_mapload = sub { + my ($map) = @_; + + my $path = $map->tmpname; + $path = $map->path unless defined $path; + + open my $fh, "<:raw", "$path.cfperl" + or return; # no perl data + + my $data = Storable::thaw do { local $/; <$fh> }; + + $data->{version} <= 1 + or return; # too new + + $map->_set_obs ($data->{obs}); +}; + +*on_mapout = sub { + my ($map) = @_; + + my $path = $map->tmpname; + $path = $map->path unless defined $path; + + my $obs = $map->_get_obs; + + if (defined $obs) { + open my $fh, ">:raw", "$path.cfperl" + or die "$path.cfperl: $!"; + + stat $path; + + print $fh Storable::nfreeze { + size => (stat _)[7], + time => (stat _)[9], + version => 1, + obs => $obs, + }; + + chmod SAVE_MODE, "$path.cfperl"; # very racy, but cf-compatible *g* + } else { + unlink "$path.cfperl"; + } +}; + +############################################################################# +# load/save perl data associated with player->ob objects + +*on_player_load = sub { + my ($ob, $path) = @_; + + if (open my $fh, "<:raw", "$path.cfperl") { + + #d##TODO#remove + + my $data = Storable::thaw do { local $/; <$fh> }; + + $data->{version} <= 1 + or return; # too new + + %$ob = %{$data->{ob}}; + return; + } + + for my $o ($ob, $ob->inv) { + if (my $value = $o->get_ob_key_value ("_perl_data")) { + $o->set_ob_key_value ("_perl_data"); + + %$o = %{ Storable::thaw pack "H*", $value }; + } + } +}; + +*on_player_save = sub { + my ($ob, $path) = @_; + + $_->set_ob_key_value (_perl_data => unpack "H*", Storable::nfreeze $_) + for grep %$_, $ob, $ob->inv; + + unlink "$path.cfperl";#d##TODO#remove +}; + +register "", __PACKAGE__; + load_extensions; 1