ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/deliantra/server/lib/cf.pm
(Generate patch)

Comparing deliantra/server/lib/cf.pm (file contents):
Revision 1.2 by root, Fri Feb 3 21:22:53 2006 UTC vs.
Revision 1.6 by root, Tue Mar 7 01:37:06 2006 UTC

1package cf; 1package cf;
2 2
3use Symbol; 3use Symbol;
4use List::Util; 4use List::Util;
5use Storable;
5 6
6use strict; 7use strict;
7 8
8our %COMMAND; 9our %COMMAND;
9our @EVENT; 10our @EVENT;
58# guessed hierarchies 59# guessed hierarchies
59 60
60@cf::object::player::ISA = 'cf::object'; 61@cf::object::player::ISA = 'cf::object';
61@cf::object::map::ISA = 'cf::object'; 62@cf::object::map::ISA = 'cf::object';
62 63
64my %ext_pkg;
63my @exts; 65my @exts;
64my @hook; 66my @hook;
65my %command; 67my %command;
66 68
67sub inject_event { 69sub inject_event {
68 my ($data) = @_; 70 my ($data) = @_;
69 71
72 my $cb = $hook[$data->{event_code}]{$data->{extension}}
73 or return;
74
75 $cb->($data)
76}
77
78sub inject_global_event {
79 my ($data) = @_;
80
70 my $cb = $hook[$data->{event_code}] 81 my $cb = $hook[$data->{event_code}]
71 or return; 82 or return;
72 83
73 $_->($data) for values %$cb; 84 $_->($data) for values %$cb;
74 85
88sub register_command { 99sub register_command {
89 my ($name, $time, $cb) = @_; 100 my ($name, $time, $cb) = @_;
90 101
91 my $caller = caller; 102 my $caller = caller;
92 103
104 warn "registering command '$name/$time' to '$caller'";
105
93 push @{ $command{$name} }, [$time, $cb, $caller]; 106 push @{ $command{$name} }, [$time, $cb, $caller];
94 $COMMAND{"$name\000"} = List::Util::max map $_->[0], @{ $command{$name} }; 107 $COMMAND{"$name\000"} = List::Util::max map $_->[0], @{ $command{$name} };
95} 108}
96 109
110sub register {
111 my ($base, $pkg) = @_;
112
113 for my $idx (0 .. $#EVENT) {
114 if (my $ref = $pkg->can ("on_$EVENT[$idx]")) {
115 warn "registering $EVENT[$idx] hook to '$pkg'\n";
116 $hook[$idx]{$base} = $ref;
117 }
118 }
119}
120
97sub load_extension { 121sub load_extension {
98 my ($path) = @_; 122 my ($path) = @_;
99 123
100 $path =~ /([^\/\\]+)\.ext$/ or die "$path"; 124 $path =~ /([^\/\\]+)\.ext$/ or die "$path";
125 my $base = $1;
101 my $pkg = $1; 126 my $pkg = $1;
102 $pkg =~ s/[^[:word:]]/_/g; 127 $pkg =~ s/[^[:word:]]/_/g;
103 $pkg = "cf::ext::$pkg"; 128 $pkg = "cf::ext::$pkg";
104 129
105 warn "loading '$path' into '$pkg'\n"; 130 warn "loading '$path' into '$pkg'\n";
115 140
116 eval $source 141 eval $source
117 or die "$path: $@"; 142 or die "$path: $@";
118 143
119 push @exts, $pkg; 144 push @exts, $pkg;
145 $ext_pkg{$base} = $pkg;
120 146
121 no strict 'refs'; 147# no strict 'refs';
122
123# @{"$pkg\::ISA"} = cf::ext::; 148# @{"$pkg\::ISA"} = cf::ext::;
124 149
125 for my $idx (0 .. $#EVENT) { 150 register $base, $pkg;
126 if (my $ref = $pkg->can ("on_$EVENT[$idx]")) {
127 warn "registering $EVENT[$idx] hook\n";
128 $hook[$idx]{$pkg} = $ref;
129 }
130 }
131} 151}
132 152
133sub unload_extension { 153sub unload_extension {
134 my ($pkg) = @_; 154 my ($pkg) = @_;
135 155
158 178
159sub load_extensions { 179sub load_extensions {
160 my $LIBDIR = maps_directory "perl"; 180 my $LIBDIR = maps_directory "perl";
161 181
162 for my $ext (<$LIBDIR/*.ext>) { 182 for my $ext (<$LIBDIR/*.ext>) {
183 next unless -r $ext;
163 eval { 184 eval {
164 load_extension $ext; 185 load_extension $ext;
165 1 186 1
166 } or warn "$ext not loaded: $@"; 187 } or warn "$ext not loaded: $@";
167 } 188 }
169 190
170register_command "perl-reload", 0, sub { 191register_command "perl-reload", 0, sub {
171 my ($who, $arg) = @_; 192 my ($who, $arg) = @_;
172 193
173 if ($who->flag (FLAG_WIZ)) { 194 if ($who->flag (FLAG_WIZ)) {
195 $who->message ("reloading...");
196
174 warn "reloading...\n"; 197 warn "reloading...\n";
198 eval {
175 unload_extension $_ for @exts; 199 unload_extension $_ for @exts;
176 @exts = 0; 200 delete $INC{"cf.pm"};
177 load_extensions; 201
202 # don't, removes xs symbols, too
203 #Symbol::delete_package $pkg;
204
205 require cf;
206 };
207 warn $@ if $@;
208 $who->message ($@) if $@;
178 warn "reloaded\n"; 209 warn "reloaded\n";
210
211 $who->message ("reloaded");
212 } else {
213 $who->message ("Intruder Alert!");
179 } 214 }
180}; 215};
181 216
217*on_mapin =
218*on_mapload = sub {
219 my $map = shift->{map};
220
221 my $path = $map->tmpname;
222 $path = $map->path unless defined $path;
223
224 open my $fh, "<:raw", "$path.cfperl"
225 or return; # no perl data
226
227 my $data = Storable::thaw do { local $/; <$fh> };
228
229 $data->{version} <= 1
230 or return; # too new
231
232 $map->_set_obs ($data->{obs});
233};
234
235*on_mapout = sub {
236 my $map = shift->{map};
237
238 my $path = $map->tmpname;
239 $path = $map->path unless defined $path;
240
241 my $obs = $map->_get_obs;
242
243 if (defined $obs) {
244 open my $fh, ">:raw", "$path.cfperl"
245 or die "$path.cfperl: $!";
246
247 print $fh Storable::nfreeze {
248 version => 1,
249 obs => $obs,
250 };
251 } else {
252 unlink "$path.cfperl";
253 }
254};
255
256register "<global>", __PACKAGE__;
257
182load_extensions; 258load_extensions;
183 259
1841 2601
185 261

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines