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.79 by root, Tue Nov 7 14:58:35 2006 UTC vs.
Revision 1.102 by root, Wed Dec 27 15:20:54 2006 UTC

1package cf; 1package cf;
2
3use utf8;
4use strict;
2 5
3use Symbol; 6use Symbol;
4use List::Util; 7use List::Util;
5use Storable; 8use Storable;
6use Opcode; 9use Opcode;
7use Safe; 10use Safe;
8use Safe::Hole; 11use Safe::Hole;
9 12
13use Coro;
14use Coro::Event;
15use Coro::Timer;
16use Coro::Signal;
17use Coro::Semaphore;
18
10use IO::AIO (); 19use IO::AIO 2.3;
11use YAML::Syck (); 20use YAML::Syck ();
12use Time::HiRes; 21use Time::HiRes;
13use Event; 22
14$Event::Eval = 1; # no idea why this is required, but it is 23use Event; $Event::Eval = 1; # no idea why this is required, but it is
15 24
16# work around bug in YAML::Syck - bad news for perl6, will it be as broken wrt. unicode? 25# work around bug in YAML::Syck - bad news for perl6, will it be as broken wrt. unicode?
17$YAML::Syck::ImplicitUnicode = 1; 26$YAML::Syck::ImplicitUnicode = 1;
18 27
19use strict; 28$Coro::main->prio (Coro::PRIO_MIN);
20 29
21_init_vars; 30sub WF_AUTOCANCEL () { 1 } # automatically cancel this watcher on reload
22 31
23our %COMMAND = (); 32our %COMMAND = ();
33our %COMMAND_TIME = ();
34our %EXTCMD = ();
35
24our @EVENT; 36our @EVENT;
25our $LIBDIR = maps_directory "perl"; 37our $LIBDIR = datadir . "/ext";
26 38
27our $TICK = MAX_TIME * 1e-6; 39our $TICK = MAX_TIME * 1e-6;
28our $TICK_WATCHER; 40our $TICK_WATCHER;
29our $NEXT_TICK; 41our $NEXT_TICK;
30 42
31our %CFG; 43our %CFG;
32 44
33our $uptime; 45our $UPTIME; $UPTIME ||= time;
34
35$uptime ||= time;
36 46
37############################################################################# 47#############################################################################
38 48
39=head2 GLOBAL VARIABLES 49=head2 GLOBAL VARIABLES
40 50
41=over 4 51=over 4
52
53=item $cf::UPTIME
54
55The timestamp of the server start (so not actually an uptime).
42 56
43=item $cf::LIBDIR 57=item $cf::LIBDIR
44 58
45The perl library directory, where extensions and cf-specific modules can 59The perl library directory, where extensions and cf-specific modules can
46be found. It will be added to C<@INC> automatically. 60be found. It will be added to C<@INC> automatically.
67 print STDERR "cfperl: $msg"; 81 print STDERR "cfperl: $msg";
68 LOG llevError, "cfperl: $msg"; 82 LOG llevError, "cfperl: $msg";
69 }; 83 };
70} 84}
71 85
86@safe::cf::global::ISA = @cf::global::ISA = 'cf::attachable';
87@safe::cf::object::ISA = @cf::object::ISA = 'cf::attachable';
88@safe::cf::player::ISA = @cf::player::ISA = 'cf::attachable';
89@safe::cf::client::ISA = @cf::client::ISA = 'cf::attachable';
90@safe::cf::map::ISA = @cf::map::ISA = 'cf::attachable';
72@safe::cf::object::player::ISA = @cf::object::player::ISA = 'cf::object'; 91@safe::cf::object::player::ISA = @cf::object::player::ISA = 'cf::object';
73 92
74# we bless all objects into (empty) derived classes to force a method lookup 93# we bless all objects into (empty) derived classes to force a method lookup
75# within the Safe compartment. 94# within the Safe compartment.
76for my $pkg (qw(cf::object cf::object::player cf::player cf::map cf::party cf::region cf::arch cf::living)) { 95for my $pkg (qw(
96 cf::global cf::attachable
97 cf::object cf::object::player
98 cf::client cf::player
99 cf::arch cf::living
100 cf::map cf::party cf::region
101)) {
77 no strict 'refs'; 102 no strict 'refs';
78 @{"safe::$pkg\::wrap::ISA"} = @{"$pkg\::wrap::ISA"} = $pkg; 103 @{"safe::$pkg\::wrap::ISA"} = @{"$pkg\::wrap::ISA"} = $pkg;
79} 104}
80 105
81$Event::DIED = sub { 106$Event::DIED = sub {
83}; 108};
84 109
85my %ext_pkg; 110my %ext_pkg;
86my @exts; 111my @exts;
87my @hook; 112my @hook;
88my %command;
89my %extcmd;
90 113
91=head2 UTILITY FUNCTIONS 114=head2 UTILITY FUNCTIONS
92 115
93=over 4 116=over 4
94 117
122 145
123=cut 146=cut
124 147
125############################################################################# 148#############################################################################
126 149
127=head2 EVENTS AND OBJECT ATTACHMENTS 150=head2 ATTACHABLE OBJECTS
151
152Many objects in crossfire are so-called attachable objects. That means you can
153attach callbacks/event handlers (a collection of which is called an "attachment")
154to it. All such attachable objects support the following methods.
155
156In the following description, CLASS can be any of C<global>, C<object>
157C<player>, C<client> or C<map> (i.e. the attachable objects in
158crossfire+).
128 159
129=over 4 160=over 4
130 161
131=item $object->attach ($attachment, key => $value...)
132
133=item $object->detach ($attachment)
134
135Attach/detach a pre-registered attachment to an object.
136
137=item $player->attach ($attachment, key => $value...)
138
139=item $player->detach ($attachment)
140
141Attach/detach a pre-registered attachment to a player.
142
143=item $map->attach ($attachment, key => $value...) 162=item $attachable->attach ($attachment, key => $value...)
144 163
145=item $map->detach ($attachment) 164=item $attachable->detach ($attachment)
146 165
147Attach/detach a pre-registered attachment to a map. 166Attach/detach a pre-registered attachment to a specific object and give it
167the specified key/value pairs as arguments.
148 168
149=item $bool = $object->attached ($name) 169Example, attach a minesweeper attachment to the given object, making it a
17010x10 minesweeper game:
150 171
151=item $bool = $player->attached ($name) 172 $obj->attach (minesweeper => width => 10, height => 10);
152 173
153=item $bool = $map->attached ($name) 174=item $bool = $attachable->attached ($name)
154 175
155Checks wether the named attachment is currently attached to the object. 176Checks wether the named attachment is currently attached to the object.
156 177
157=item cf::attach_global ... 178=item cf::CLASS->attach ...
158 179
159Attach handlers for global events. 180=item cf::CLASS->detach ...
160 181
161This and all following C<attach_*>-functions expect any number of the 182Define an anonymous attachment and attach it to all objects of the given
162following handler/hook descriptions: 183CLASS. See the next function for an explanation of its arguments.
184
185You can attach to global events by using the C<cf::global> class.
186
187Example, log all player logins:
188
189 cf::player->attach (
190 on_login => sub {
191 my ($pl) = @_;
192 ...
193 },
194 );
195
196Example, attach to the jeweler skill:
197
198 cf::object->attach (
199 type => cf::SKILL,
200 subtype => cf::SK_JEWELER,
201 on_use_skill => sub {
202 my ($sk, $ob, $part, $dir, $msg) = @_;
203 ...
204 },
205 );
206
207=item cf::CLASS::attachment $name, ...
208
209Register an attachment by C<$name> through which attachable objects of the
210given CLASS can refer to this attachment.
211
212Some classes such as crossfire maps and objects can specify attachments
213that are attached at load/instantiate time, thus the need for a name.
214
215These calls expect any number of the following handler/hook descriptions:
163 216
164=over 4 217=over 4
165 218
166=item prio => $number 219=item prio => $number
167 220
169by another C<prio> setting). Lower priority handlers get executed 222by another C<prio> setting). Lower priority handlers get executed
170earlier. The default priority is C<0>, and many built-in handlers are 223earlier. The default priority is C<0>, and many built-in handlers are
171registered at priority C<-1000>, so lower priorities should not be used 224registered at priority C<-1000>, so lower priorities should not be used
172unless you know what you are doing. 225unless you know what you are doing.
173 226
227=item type => $type
228
229(Only for C<< cf::object->attach >> calls), limits the attachment to the
230given type of objects only (the additional parameter C<subtype> can be
231used to further limit to the given subtype).
232
174=item on_I<event> => \&cb 233=item on_I<event> => \&cb
175 234
176Call the given code reference whenever the named event happens (event is 235Call the given code reference whenever the named event happens (event is
177something like C<instantiate>, C<apply>, C<use_skill> and so on, and which 236something like C<instantiate>, C<apply>, C<use_skill> and so on, and which
178handlers are recognised generally depends on the type of object these 237handlers are recognised generally depends on the type of object these
187package and register them. Only handlers for eevents supported by the 246package and register them. Only handlers for eevents supported by the
188object/class are recognised. 247object/class are recognised.
189 248
190=back 249=back
191 250
192=item cf::attach_to_type $object_type, $subtype, ... 251Example, define an attachment called "sockpuppet" that calls the given
252event handler when a monster attacks:
193 253
194Attach handlers for a specific object type (e.g. TRANSPORT) and 254 cf::object::attachment sockpuppet =>
195subtype. If C<$subtype> is zero or undef, matches all objects of the given 255 on_skill_attack => sub {
196type. 256 my ($self, $victim) = @_;
197 257 ...
198=item cf::attach_to_objects ...
199
200Attach handlers to all objects. Do not use this except for debugging or
201very rare events, as handlers are (obviously) called for I<all> objects in
202the game.
203
204=item cf::attach_to_players ...
205
206Attach handlers to all players.
207
208=item cf::attach_to_maps ...
209
210Attach handlers to all maps.
211
212=item cf:register_attachment $name, ...
213
214Register an attachment by name through which objects can refer to this
215attachment.
216
217=item cf:register_player_attachment $name, ...
218
219Register an attachment by name through which players can refer to this
220attachment.
221
222=item cf:register_map_attachment $name, ...
223
224Register an attachment by name through which maps can refer to this
225attachment.
226
227=cut
228
229# the following variables are defined in .xs and must not be re-created
230our @CB_GLOBAL = (); # registry for all global events
231our @CB_OBJECT = (); # all objects (should not be used except in emergency)
232our @CB_PLAYER = ();
233our @CB_TYPE = (); # registry for type (cf-object class) based events
234our @CB_MAP = ();
235
236my %attachment;
237
238sub _attach_cb($\%$$$) {
239 my ($registry, $undo, $event, $prio, $cb) = @_;
240
241 use sort 'stable';
242
243 $cb = [$prio, $cb];
244
245 @{$registry->[$event]} = sort
246 { $a->[0] cmp $b->[0] }
247 @{$registry->[$event] || []}, $cb;
248
249 push @{$undo->{cb}}, [$event, $cb];
250}
251
252# attach handles attaching event callbacks
253# the only thing the caller has to do is pass the correct
254# registry (== where the callback attaches to).
255sub _attach(\@$@) {
256 my ($registry, $klass, @arg) = @_;
257
258 my $prio = 0;
259
260 my %undo = (
261 registry => $registry,
262 cb => [],
263 );
264
265 my %cb_id = map +("on_" . lc $EVENT[$_][0], $_) , grep $EVENT[$_][1] == $klass, 0 .. $#EVENT;
266
267 while (@arg) {
268 my $type = shift @arg;
269
270 if ($type eq "prio") {
271 $prio = shift @arg;
272
273 } elsif ($type eq "package") {
274 my $pkg = shift @arg;
275
276 while (my ($name, $id) = each %cb_id) {
277 if (my $cb = $pkg->can ($name)) {
278 _attach_cb $registry, %undo, $id, $prio, $cb;
279 }
280 } 258 }
281
282 } elsif (exists $cb_id{$type}) {
283 _attach_cb $registry, %undo, $cb_id{$type}, $prio, shift @arg;
284
285 } elsif (ref $type) {
286 warn "attaching objects not supported, ignoring.\n";
287
288 } else {
289 shift @arg;
290 warn "attach argument '$type' not supported, ignoring.\n";
291 }
292 }
293
294 \%undo
295}
296
297sub _attach_attachment {
298 my ($obj, $name, %arg) = @_;
299
300 return if exists $obj->{_attachment}{$name};
301
302 my $res;
303
304 if (my $attach = $attachment{$name}) {
305 my $registry = $obj->registry;
306
307 for (@$attach) {
308 my ($klass, @attach) = @$_;
309 $res = _attach @$registry, $klass, @attach;
310 }
311
312 $obj->{$name} = \%arg;
313 } else {
314 warn "object uses attachment '$name' that is not available, postponing.\n";
315 }
316
317 $obj->{_attachment}{$name} = undef;
318
319 $res->{attachment} = $name;
320 $res
321}
322
323*cf::object::attach =
324*cf::player::attach =
325*cf::map::attach = sub {
326 my ($obj, $name, %arg) = @_;
327
328 _attach_attachment $obj, $name, %arg;
329};
330
331# all those should be optimised
332*cf::object::detach =
333*cf::player::detach =
334*cf::map::detach = sub {
335 my ($obj, $name) = @_;
336
337 delete $obj->{_attachment}{$name};
338 reattach ($obj);
339};
340
341*cf::object::attached =
342*cf::player::attached =
343*cf::map::attached = sub {
344 my ($obj, $name) = @_;
345
346 exists $obj->{_attachment}{$name}
347};
348
349sub attach_global {
350 _attach @CB_GLOBAL, KLASS_GLOBAL, @_
351}
352
353sub attach_to_type {
354 my $type = shift;
355 my $subtype = shift;
356
357 _attach @{$CB_TYPE[$type + $subtype * NUM_SUBTYPES]}, KLASS_OBJECT, @_
358}
359
360sub attach_to_objects {
361 _attach @CB_OBJECT, KLASS_OBJECT, @_
362}
363
364sub attach_to_players {
365 _attach @CB_PLAYER, KLASS_PLAYER, @_
366}
367
368sub attach_to_maps {
369 _attach @CB_MAP, KLASS_MAP, @_
370}
371
372sub register_attachment {
373 my $name = shift;
374
375 $attachment{$name} = [[KLASS_OBJECT, @_]];
376}
377
378sub register_player_attachment {
379 my $name = shift;
380
381 $attachment{$name} = [[KLASS_PLAYER, @_]];
382}
383
384sub register_map_attachment {
385 my $name = shift;
386
387 $attachment{$name} = [[KLASS_MAP, @_]];
388}
389
390our $override;
391our @invoke_results = (); # referenced from .xs code. TODO: play tricks with reify and mortals?
392
393sub override {
394 $override = 1;
395 @invoke_results = ();
396}
397
398sub do_invoke {
399 my $event = shift;
400 my $callbacks = shift;
401
402 @invoke_results = ();
403
404 local $override;
405
406 for (@$callbacks) {
407 eval { &{$_->[1]} };
408
409 if ($@) {
410 warn "$@";
411 warn "... while processing $EVENT[$event][0](@_) event, skipping processing altogether.\n";
412 override;
413 }
414
415 return 1 if $override;
416 }
417
418 0 259 }
419}
420 260
421=item $bool = cf::invoke EVENT_GLOBAL_XXX, ... 261=item $attachable->valid
422
423=item $bool = $object->invoke (EVENT_OBJECT_XXX, ...)
424
425=item $bool = $player->invoke (EVENT_PLAYER_XXX, ...)
426
427=item $bool = $map->invoke (EVENT_MAP_XXX, ...)
428
429Generate a global/object/player/map-specific event with the given arguments.
430
431This API is preliminary (most likely, the EVENT_KLASS_xxx prefix will be
432removed in future versions), and there is no public API to access override
433results (if you must, access C<@cf::invoke_results> directly).
434
435=back
436
437=cut
438
439#############################################################################
440
441=head2 METHODS VALID FOR ALL CORE OBJECTS
442
443=over 4
444
445=item $object->valid, $player->valid, $map->valid
446 262
447Just because you have a perl object does not mean that the corresponding 263Just because you have a perl object does not mean that the corresponding
448C-level object still exists. If you try to access an object that has no 264C-level object still exists. If you try to access an object that has no
449valid C counterpart anymore you get an exception at runtime. This method 265valid C counterpart anymore you get an exception at runtime. This method
450can be used to test for existence of the C object part without causing an 266can be used to test for existence of the C object part without causing an
451exception. 267exception.
452 268
269=cut
270
271# the following variables are defined in .xs and must not be re-created
272our @CB_GLOBAL = (); # registry for all global events
273our @CB_ATTACHABLE = (); # registry for all attachables
274our @CB_OBJECT = (); # all objects (should not be used except in emergency)
275our @CB_PLAYER = ();
276our @CB_CLIENT = ();
277our @CB_TYPE = (); # registry for type (cf-object class) based events
278our @CB_MAP = ();
279
280my %attachment;
281
282sub _attach_cb($$$$) {
283 my ($registry, $event, $prio, $cb) = @_;
284
285 use sort 'stable';
286
287 $cb = [$prio, $cb];
288
289 @{$registry->[$event]} = sort
290 { $a->[0] cmp $b->[0] }
291 @{$registry->[$event] || []}, $cb;
292}
293
294# hack
295my %attachable_klass = map +($_ => 1), KLASS_OBJECT, KLASS_CLIENT, KLASS_PLAYER, KLASS_MAP;
296
297# attach handles attaching event callbacks
298# the only thing the caller has to do is pass the correct
299# registry (== where the callback attaches to).
300sub _attach {
301 my ($registry, $klass, @arg) = @_;
302
303 my $object_type;
304 my $prio = 0;
305 my %cb_id = map +("on_" . lc $EVENT[$_][0], $_) , grep $EVENT[$_][1] == $klass, 0 .. $#EVENT;
306
307 #TODO: get rid of this hack
308 if ($attachable_klass{$klass}) {
309 %cb_id = (%cb_id, map +("on_" . lc $EVENT[$_][0], $_) , grep $EVENT[$_][1] == KLASS_ATTACHABLE, 0 .. $#EVENT);
310 }
311
312 while (@arg) {
313 my $type = shift @arg;
314
315 if ($type eq "prio") {
316 $prio = shift @arg;
317
318 } elsif ($type eq "type") {
319 $object_type = shift @arg;
320 $registry = $CB_TYPE[$object_type] ||= [];
321
322 } elsif ($type eq "subtype") {
323 defined $object_type or Carp::croak "subtype specified without type";
324 my $object_subtype = shift @arg;
325 $registry = $CB_TYPE[$object_type + $object_subtype * NUM_SUBTYPES] ||= [];
326
327 } elsif ($type eq "package") {
328 my $pkg = shift @arg;
329
330 while (my ($name, $id) = each %cb_id) {
331 if (my $cb = $pkg->can ($name)) {
332 _attach_cb $registry, $id, $prio, $cb;
333 }
334 }
335
336 } elsif (exists $cb_id{$type}) {
337 _attach_cb $registry, $cb_id{$type}, $prio, shift @arg;
338
339 } elsif (ref $type) {
340 warn "attaching objects not supported, ignoring.\n";
341
342 } else {
343 shift @arg;
344 warn "attach argument '$type' not supported, ignoring.\n";
345 }
346 }
347}
348
349sub _object_attach {
350 my ($obj, $name, %arg) = @_;
351
352 return if exists $obj->{_attachment}{$name};
353
354 if (my $attach = $attachment{$name}) {
355 my $registry = $obj->registry;
356
357 for (@$attach) {
358 my ($klass, @attach) = @$_;
359 _attach $registry, $klass, @attach;
360 }
361
362 $obj->{$name} = \%arg;
363 } else {
364 warn "object uses attachment '$name' that is not available, postponing.\n";
365 }
366
367 $obj->{_attachment}{$name} = undef;
368}
369
370sub cf::attachable::attach {
371 if (ref $_[0]) {
372 _object_attach @_;
373 } else {
374 _attach shift->_attach_registry, @_;
375 }
376};
377
378# all those should be optimised
379sub cf::attachable::detach {
380 my ($obj, $name) = @_;
381
382 if (ref $obj) {
383 delete $obj->{_attachment}{$name};
384 reattach ($obj);
385 } else {
386 Carp::croak "cannot, currently, detach class attachments";
387 }
388};
389
390sub cf::attachable::attached {
391 my ($obj, $name) = @_;
392
393 exists $obj->{_attachment}{$name}
394}
395
396for my $klass (qw(ATTACHABLE GLOBAL OBJECT PLAYER CLIENT MAP)) {
397 eval "#line " . __LINE__ . " 'cf.pm'
398 sub cf::\L$klass\E::_attach_registry {
399 (\\\@CB_$klass, KLASS_$klass)
400 }
401
402 sub cf::\L$klass\E::attachment {
403 my \$name = shift;
404
405 \$attachment{\$name} = [[KLASS_$klass, \@_]];
406 }
407 ";
408 die if $@;
409}
410
411our $override;
412our @invoke_results = (); # referenced from .xs code. TODO: play tricks with reify and mortals?
413
414sub override {
415 $override = 1;
416 @invoke_results = ();
417}
418
419sub do_invoke {
420 my $event = shift;
421 my $callbacks = shift;
422
423 @invoke_results = ();
424
425 local $override;
426
427 for (@$callbacks) {
428 eval { &{$_->[1]} };
429
430 if ($@) {
431 warn "$@";
432 warn "... while processing $EVENT[$event][0](@_) event, skipping processing altogether.\n";
433 override;
434 }
435
436 return 1 if $override;
437 }
438
439 0
440}
441
442=item $bool = cf::global::invoke (EVENT_CLASS_XXX, ...)
443
444=item $bool = $attachable->invoke (EVENT_CLASS_XXX, ...)
445
446Generate an object-specific event with the given arguments.
447
448This API is preliminary (most likely, the EVENT_CLASS_xxx prefix will be
449removed in future versions), and there is no public API to access override
450results (if you must, access C<@cf::invoke_results> directly).
451
453=back 452=back
454 453
455=cut 454=cut
456
457*cf::object::valid =
458*cf::player::valid =
459*cf::map::valid = \&cf::_valid;
460 455
461############################################################################# 456#############################################################################
462# object support 457# object support
463 458
464sub instantiate {
465 my ($obj, $data) = @_;
466
467 $data = from_json $data;
468
469 for (@$data) {
470 my ($name, $args) = @$_;
471
472 $obj->attach ($name, %{$args || {} });
473 }
474}
475
476# basically do the same as instantiate, without calling instantiate
477sub reattach { 459sub reattach {
460 # basically do the same as instantiate, without calling instantiate
478 my ($obj) = @_; 461 my ($obj) = @_;
462
479 my $registry = $obj->registry; 463 my $registry = $obj->registry;
480 464
481 @$registry = (); 465 @$registry = ();
482 466
483 delete $obj->{_attachment} unless scalar keys %{ $obj->{_attachment} || {} }; 467 delete $obj->{_attachment} unless scalar keys %{ $obj->{_attachment} || {} };
484 468
485 for my $name (keys %{ $obj->{_attachment} || {} }) { 469 for my $name (keys %{ $obj->{_attachment} || {} }) {
486 if (my $attach = $attachment{$name}) { 470 if (my $attach = $attachment{$name}) {
487 for (@$attach) { 471 for (@$attach) {
488 my ($klass, @attach) = @$_; 472 my ($klass, @attach) = @$_;
489 _attach @$registry, $klass, @attach; 473 _attach $registry, $klass, @attach;
490 } 474 }
491 } else { 475 } else {
492 warn "object uses attachment '$name' that is not available, postponing.\n"; 476 warn "object uses attachment '$name' that is not available, postponing.\n";
493 } 477 }
494 } 478 }
495} 479}
480
481cf::attachable->attach (
482 prio => -1000000,
483 on_instantiate => sub {
484 my ($obj, $data) = @_;
485
486 $data = from_json $data;
487
488 for (@$data) {
489 my ($name, $args) = @$_;
490
491 $obj->attach ($name, %{$args || {} });
492 }
493 },
494 on_reattach => \&reattach,
495 on_clone => sub {
496 my ($src, $dst) = @_;
497
498 @{$dst->registry} = @{$src->registry};
499
500 %$dst = %$src;
501
502 %{$dst->{_attachment}} = %{$src->{_attachment}}
503 if exists $src->{_attachment};
504 },
505);
496 506
497sub object_freezer_save { 507sub object_freezer_save {
498 my ($filename, $rdata, $objs) = @_; 508 my ($filename, $rdata, $objs) = @_;
499 509
500 if (length $$rdata) { 510 if (length $$rdata) {
523 unlink $filename; 533 unlink $filename;
524 unlink "$filename.pst"; 534 unlink "$filename.pst";
525 } 535 }
526} 536}
527 537
538sub object_freezer_as_string {
539 my ($rdata, $objs) = @_;
540
541 use Data::Dumper;
542
543 $$rdata . Dumper $objs
544}
545
528sub object_thawer_load { 546sub object_thawer_load {
529 my ($filename) = @_; 547 my ($filename) = @_;
530 548
531 local $/; 549 local $/;
532 550
542 } 560 }
543 561
544 () 562 ()
545} 563}
546 564
547attach_to_objects
548 prio => -1000000,
549 on_clone => sub {
550 my ($src, $dst) = @_;
551
552 @{$dst->registry} = @{$src->registry};
553
554 %$dst = %$src;
555
556 %{$dst->{_attachment}} = %{$src->{_attachment}}
557 if exists $src->{_attachment};
558 },
559;
560
561############################################################################# 565#############################################################################
562# old plug-in events 566# command handling &c
563 567
564sub inject_event { 568=item cf::register_command $name => \&callback($ob,$args);
565 my $extension = shift;
566 my $event_code = shift;
567 569
568 my $cb = $hook[$event_code]{$extension} 570Register a callback for execution when the client sends the user command
569 or return; 571$name.
570 572
571 &$cb 573=cut
572}
573
574sub inject_global_event {
575 my $event = shift;
576
577 my $cb = $hook[$event]
578 or return;
579
580 List::Util::max map &$_, values %$cb
581}
582
583sub inject_command {
584 my ($name, $obj, $params) = @_;
585
586 for my $cmd (@{ $command{$name} }) {
587 $cmd->[1]->($obj, $params);
588 }
589
590 -1
591}
592 574
593sub register_command { 575sub register_command {
594 my ($name, $time, $cb) = @_; 576 my ($name, $cb) = @_;
595 577
596 my $caller = caller; 578 my $caller = caller;
597 #warn "registering command '$name/$time' to '$caller'"; 579 #warn "registering command '$name/$time' to '$caller'";
598 580
599 push @{ $command{$name} }, [$time, $cb, $caller]; 581 push @{ $COMMAND{$name} }, [$caller, $cb];
600 $COMMAND{"$name\000"} = List::Util::max map $_->[0], @{ $command{$name} };
601} 582}
583
584=item cf::register_extcmd $name => \&callback($pl,$packet);
585
586Register a callbackf ro execution when the client sends an extcmd packet.
587
588If the callback returns something, it is sent back as if reply was being
589called.
590
591=cut
602 592
603sub register_extcmd { 593sub register_extcmd {
604 my ($name, $cb) = @_; 594 my ($name, $cb) = @_;
605 595
606 my $caller = caller; 596 my $caller = caller;
607 #warn "registering extcmd '$name' to '$caller'"; 597 #warn "registering extcmd '$name' to '$caller'";
608 598
609 $extcmd{$name} = [$cb, $caller]; 599 $EXTCMD{$name} = [$cb, $caller];
610} 600}
601
602cf::player->attach (
603 on_command => sub {
604 my ($pl, $name, $params) = @_;
605
606 my $cb = $COMMAND{$name}
607 or return;
608
609 for my $cmd (@$cb) {
610 $cmd->[1]->($pl->ob, $params);
611 }
612
613 cf::override;
614 },
615 on_extcmd => sub {
616 my ($pl, $buf) = @_;
617
618 my $msg = eval { from_json $buf };
619
620 if (ref $msg) {
621 if (my $cb = $EXTCMD{$msg->{msgtype}}) {
622 if (my %reply = $cb->[0]->($pl, $msg)) {
623 $pl->ext_reply ($msg->{msgid}, %reply);
624 }
625 }
626 } else {
627 warn "player " . ($pl->ob->name) . " sent unparseable ext message: <$buf>\n";
628 }
629
630 cf::override;
631 },
632);
611 633
612sub register { 634sub register {
613 my ($base, $pkg) = @_; 635 my ($base, $pkg) = @_;
614 636
615 #TODO 637 #TODO
634 . "#line 1 \"$path\"\n{\n" 656 . "#line 1 \"$path\"\n{\n"
635 . (do { local $/; <$fh> }) 657 . (do { local $/; <$fh> })
636 . "\n};\n1"; 658 . "\n};\n1";
637 659
638 eval $source 660 eval $source
639 or die "$path: $@"; 661 or die $@ ? "$path: $@\n"
662 : "extension disabled.\n";
640 663
641 push @exts, $pkg; 664 push @exts, $pkg;
642 $ext_pkg{$base} = $pkg; 665 $ext_pkg{$base} = $pkg;
643 666
644# no strict 'refs'; 667# no strict 'refs';
657# for my $idx (0 .. $#PLUGIN_EVENT) { 680# for my $idx (0 .. $#PLUGIN_EVENT) {
658# delete $hook[$idx]{$pkg}; 681# delete $hook[$idx]{$pkg};
659# } 682# }
660 683
661 # remove commands 684 # remove commands
662 for my $name (keys %command) { 685 for my $name (keys %COMMAND) {
663 my @cb = grep $_->[2] ne $pkg, @{ $command{$name} }; 686 my @cb = grep $_->[0] ne $pkg, @{ $COMMAND{$name} };
664 687
665 if (@cb) { 688 if (@cb) {
666 $command{$name} = \@cb; 689 $COMMAND{$name} = \@cb;
667 $COMMAND{"$name\000"} = List::Util::max map $_->[0], @cb;
668 } else { 690 } else {
669 delete $command{$name};
670 delete $COMMAND{"$name\000"}; 691 delete $COMMAND{$name};
671 } 692 }
672 } 693 }
673 694
674 # remove extcmds 695 # remove extcmds
675 for my $name (grep $extcmd{$_}[1] eq $pkg, keys %extcmd) { 696 for my $name (grep $EXTCMD{$_}[1] eq $pkg, keys %EXTCMD) {
676 delete $extcmd{$name}; 697 delete $EXTCMD{$name};
677 } 698 }
678 699
679 if (my $cb = $pkg->can ("unload")) { 700 if (my $cb = $pkg->can ("unload")) {
680 eval { 701 eval {
681 $cb->($pkg); 702 $cb->($pkg);
685 706
686 Symbol::delete_package $pkg; 707 Symbol::delete_package $pkg;
687} 708}
688 709
689sub load_extensions { 710sub load_extensions {
690 my $LIBDIR = maps_directory "perl";
691
692 for my $ext (<$LIBDIR/*.ext>) { 711 for my $ext (<$LIBDIR/*.ext>) {
693 next unless -r $ext; 712 next unless -r $ext;
694 eval { 713 eval {
695 load_extension $ext; 714 load_extension $ext;
696 1 715 1
697 } or warn "$ext not loaded: $@"; 716 } or warn "$ext not loaded: $@";
698 } 717 }
699} 718}
700 719
701############################################################################# 720#############################################################################
702# extcmd framework, basically convert ext <msg>
703# into pkg::->on_extcmd_arg1 (...) while shortcutting a few
704
705attach_to_players
706 on_extcmd => sub {
707 my ($pl, $buf) = @_;
708
709 my $msg = eval { from_json $buf };
710
711 if (ref $msg) {
712 if (my $cb = $extcmd{$msg->{msgtype}}) {
713 if (my %reply = $cb->[0]->($pl, $msg)) {
714 $pl->ext_reply ($msg->{msgid}, %reply);
715 }
716 }
717 } else {
718 warn "player " . ($pl->ob->name) . " sent unparseable ext message: <$buf>\n";
719 }
720
721 cf::override;
722 },
723;
724
725#############################################################################
726# load/save/clean perl data associated with a map 721# load/save/clean perl data associated with a map
727 722
728*cf::mapsupport::on_clean = sub { 723*cf::mapsupport::on_clean = sub {
729 my ($map) = @_; 724 my ($map) = @_;
730 725
732 defined $path or return; 727 defined $path or return;
733 728
734 unlink "$path.pst"; 729 unlink "$path.pst";
735}; 730};
736 731
737attach_to_maps prio => -10000, package => cf::mapsupport::; 732cf::map->attach (prio => -10000, package => cf::mapsupport::);
738 733
739############################################################################# 734#############################################################################
740# load/save perl data associated with player->ob objects 735# load/save perl data associated with player->ob objects
741 736
742sub all_objects(@) { 737sub all_objects(@) {
743 @_, map all_objects ($_->inv), @_ 738 @_, map all_objects ($_->inv), @_
744} 739}
745 740
746# TODO: compatibility cruft, remove when no longer needed 741# TODO: compatibility cruft, remove when no longer needed
747attach_to_players 742cf::player->attach (
748 on_load => sub { 743 on_load => sub {
749 my ($pl, $path) = @_; 744 my ($pl, $path) = @_;
750 745
751 for my $o (all_objects $pl->ob) { 746 for my $o (all_objects $pl->ob) {
752 if (my $value = $o->get_ob_key_value ("_perl_data")) { 747 if (my $value = $o->get_ob_key_value ("_perl_data")) {
754 749
755 %$o = %{ Storable::thaw pack "H*", $value }; 750 %$o = %{ Storable::thaw pack "H*", $value };
756 } 751 }
757 } 752 }
758 }, 753 },
759; 754);
760 755
761############################################################################# 756#############################################################################
762 757
763=head2 CORE EXTENSIONS 758=head2 CORE EXTENSIONS
764 759
765Functions and methods that extend core crossfire objects. 760Functions and methods that extend core crossfire objects.
761
762=head3 cf::player
766 763
767=over 4 764=over 4
768 765
769=item cf::player::exists $login 766=item cf::player::exists $login
770 767
775sub cf::player::exists($) { 772sub cf::player::exists($) {
776 cf::player::find $_[0] 773 cf::player::find $_[0]
777 or -f sprintf "%s/%s/%s/%s.pl", cf::localdir, cf::playerdir, ($_[0]) x 2; 774 or -f sprintf "%s/%s/%s/%s.pl", cf::localdir, cf::playerdir, ($_[0]) x 2;
778} 775}
779 776
777=item $player->ext_reply ($msgid, $msgtype, %msg)
778
779Sends an ext reply to the player.
780
781=cut
782
783sub cf::player::ext_reply($$$%) {
784 my ($self, $id, %msg) = @_;
785
786 $msg{msgid} = $id;
787
788 $self->send ("ext " . to_json \%msg);
789}
790
791=back
792
793=head3 cf::object::player
794
795=over 4
796
780=item $player_object->reply ($npc, $msg[, $flags]) 797=item $player_object->reply ($npc, $msg[, $flags])
781 798
782Sends a message to the player, as if the npc C<$npc> replied. C<$npc> 799Sends a message to the player, as if the npc C<$npc> replied. C<$npc>
783can be C<undef>. Does the right thing when the player is currently in a 800can be C<undef>. Does the right thing when the player is currently in a
784dialogue with the given NPC character. 801dialogue with the given NPC character.
785 802
786=cut 803=cut
787 804
788# rough implementation of a future "reply" method that works 805# rough implementation of a future "reply" method that works
789# with dialog boxes. 806# with dialog boxes.
807#TODO: the first argument must go, split into a $npc->reply_to ( method
790sub cf::object::player::reply($$$;$) { 808sub cf::object::player::reply($$$;$) {
791 my ($self, $npc, $msg, $flags) = @_; 809 my ($self, $npc, $msg, $flags) = @_;
792 810
793 $flags = cf::NDI_BROWN | cf::NDI_UNIQUE unless @_ >= 4; 811 $flags = cf::NDI_BROWN | cf::NDI_UNIQUE unless @_ >= 4;
794 812
798 $msg = $npc->name . " says: $msg" if $npc; 816 $msg = $npc->name . " says: $msg" if $npc;
799 $self->message ($msg, $flags); 817 $self->message ($msg, $flags);
800 } 818 }
801} 819}
802 820
803=item $player->ext_reply ($msgid, $msgtype, %msg)
804
805Sends an ext reply to the player.
806
807=cut
808
809sub cf::player::ext_reply($$$%) {
810 my ($self, $id, %msg) = @_;
811
812 $msg{msgid} = $id;
813
814 $self->send ("ext " . to_json \%msg);
815}
816
817=item $player_object->may ("access") 821=item $player_object->may ("access")
818 822
819Returns wether the given player is authorized to access resource "access" 823Returns wether the given player is authorized to access resource "access"
820(e.g. "command_wizcast"). 824(e.g. "command_wizcast").
821 825
828 (ref $cf::CFG{"may_$access"} 832 (ref $cf::CFG{"may_$access"}
829 ? scalar grep $self->name eq $_, @{$cf::CFG{"may_$access"}} 833 ? scalar grep $self->name eq $_, @{$cf::CFG{"may_$access"}}
830 : $cf::CFG{"may_$access"}) 834 : $cf::CFG{"may_$access"})
831} 835}
832 836
833=cut 837=head3 cf::client
834 838
835############################################################################# 839=over 4
840
841=item $client->send_drawinfo ($text, $flags)
842
843Sends a drawinfo packet to the client. Circumvents output buffering so
844should not be used under normal circumstances.
845
846=cut
847
848sub cf::client::send_drawinfo {
849 my ($self, $text, $flags) = @_;
850
851 utf8::encode $text;
852 $self->send_packet (sprintf "drawinfo %d %s", $flags, $text);
853}
854
855
856=item $success = $client->query ($flags, "text", \&cb)
857
858Queues a query to the client, calling the given callback with
859the reply text on a reply. flags can be C<cf::CS_QUERY_YESNO>,
860C<cf::CS_QUERY_SINGLECHAR> or C<cf::CS_QUERY_HIDEINPUT> or C<0>.
861
862Queries can fail, so check the return code. Or don't, as queries will become
863reliable at some point in the future.
864
865=cut
866
867sub cf::client::query {
868 my ($self, $flags, $text, $cb) = @_;
869
870 return unless $self->state == ST_PLAYING
871 || $self->state == ST_SETUP
872 || $self->state == ST_CUSTOM;
873
874 $self->state (ST_CUSTOM);
875
876 utf8::encode $text;
877 push @{ $self->{query_queue} }, [(sprintf "query %d %s", $flags, $text), $cb];
878
879 $self->send_packet ($self->{query_queue}[0][0])
880 if @{ $self->{query_queue} } == 1;
881}
882
883cf::client->attach (
884 on_reply => sub {
885 my ($ns, $msg) = @_;
886
887 # this weird shuffling is so that direct followup queries
888 # get handled first
889 my $queue = delete $ns->{query_queue};
890
891 (shift @$queue)->[1]->($msg);
892
893 push @{ $ns->{query_queue} }, @$queue;
894
895 if (@{ $ns->{query_queue} } == @$queue) {
896 if (@$queue) {
897 $ns->send_packet ($ns->{query_queue}[0][0]);
898 } else {
899 $ns->state (ST_PLAYING) if $ns->state == ST_CUSTOM;
900 }
901 }
902 },
903);
904
905=item $client->coro (\&cb)
906
907Create a new coroutine, running the specified callback. The coroutine will
908be automatically cancelled when the client gets destroyed (e.g. on logout,
909or loss of connection).
910
911=cut
912
913sub cf::client::coro {
914 my ($self, $cb) = @_;
915
916 my $coro; $coro = async {
917 eval {
918 $cb->();
919 };
920 warn $@ if $@;
921 delete $self->{_coro}{$coro+0};
922 };
923
924 $self->{_coro}{$coro+0} = $coro;
925}
926
927cf::client->attach (
928 on_destroy => sub {
929 my ($ns) = @_;
930
931 $_->cancel for values %{ (delete $ns->{_coro}) || {} };
932 },
933);
934
935=back
936
836 937
837=head2 SAFE SCRIPTING 938=head2 SAFE SCRIPTING
838 939
839Functions that provide a safe environment to compile and execute 940Functions that provide a safe environment to compile and execute
840snippets of perl code without them endangering the safety of the server 941snippets of perl code without them endangering the safety of the server
855 956
856=pod 957=pod
857 958
858The following fucntions and emthods are available within a safe environment: 959The following fucntions and emthods are available within a safe environment:
859 960
860 cf::object contr pay_amount pay_player 961 cf::object contr pay_amount pay_player map
861 cf::object::player player 962 cf::object::player player
862 cf::player peaceful 963 cf::player peaceful
964 cf::map trigger
863 965
864=cut 966=cut
865 967
866for ( 968for (
867 ["cf::object" => qw(contr pay_amount pay_player)], 969 ["cf::object" => qw(contr pay_amount pay_player map)],
868 ["cf::object::player" => qw(player)], 970 ["cf::object::player" => qw(player)],
869 ["cf::player" => qw(peaceful)], 971 ["cf::player" => qw(peaceful)],
972 ["cf::map" => qw(trigger)],
870) { 973) {
871 no strict 'refs'; 974 no strict 'refs';
872 my ($pkg, @funs) = @$_; 975 my ($pkg, @funs) = @$_;
873 *{"safe::$pkg\::$_"} = $safe_hole->wrap (\&{"$pkg\::$_"}) 976 *{"safe::$pkg\::$_"} = $safe_hole->wrap (\&{"$pkg\::$_"})
874 for @funs; 977 for @funs;
1014 sub db_sync() { 1117 sub db_sync() {
1015 db_save if $dirty; 1118 db_save if $dirty;
1016 undef $dirty; 1119 undef $dirty;
1017 } 1120 }
1018 1121
1019 my $idle = Event->idle (min => $TICK * 2.8, max => 10, repeat => 0, cb => sub { 1122 my $idle = Event->idle (min => $TICK * 2.8, max => 10, repeat => 0, data => WF_AUTOCANCEL, cb => sub {
1020 db_sync; 1123 db_sync;
1021 }); 1124 });
1022 1125
1023 sub db_dirty() { 1126 sub db_dirty() {
1024 $dirty = 1; 1127 $dirty = 1;
1038 $DB->{$_[0]} = $_[1]; 1141 $DB->{$_[0]} = $_[1];
1039 } 1142 }
1040 db_dirty; 1143 db_dirty;
1041 } 1144 }
1042 1145
1043 attach_global 1146 cf::global->attach (
1044 prio => 10000, 1147 prio => 10000,
1045 on_cleanup => sub { 1148 on_cleanup => sub {
1046 db_sync; 1149 db_sync;
1047 }, 1150 },
1048 ; 1151 );
1049} 1152}
1050 1153
1051############################################################################# 1154#############################################################################
1052# the server's main() 1155# the server's main()
1053 1156
1074 1177
1075 $msg->("reloading..."); 1178 $msg->("reloading...");
1076 1179
1077 eval { 1180 eval {
1078 # cancel all watchers 1181 # cancel all watchers
1079 $_->cancel for Event::all_watchers; 1182 for (Event::all_watchers) {
1183 $_->cancel if $_->data & WF_AUTOCANCEL;
1184 }
1080 1185
1081 # unload all extensions 1186 # unload all extensions
1082 for (@exts) { 1187 for (@exts) {
1083 $msg->("unloading <$_>"); 1188 $msg->("unloading <$_>");
1084 unload_extension $_; 1189 unload_extension $_;
1119 #Symbol::delete_package __PACKAGE__; 1224 #Symbol::delete_package __PACKAGE__;
1120 1225
1121 # reload cf.pm 1226 # reload cf.pm
1122 $msg->("reloading cf.pm"); 1227 $msg->("reloading cf.pm");
1123 require cf; 1228 require cf;
1229 cf::_connect_to_perl; # nominally unnecessary, but cannot hurt
1124 1230
1125 # load config and database again 1231 # load config and database again
1126 cf::cfg_load; 1232 cf::cfg_load;
1127 cf::db_load; 1233 cf::db_load;
1128 1234
1144 warn $_[0]; 1250 warn $_[0];
1145 print "$_[0]\n"; 1251 print "$_[0]\n";
1146 }; 1252 };
1147} 1253}
1148 1254
1255register "<global>", __PACKAGE__;
1256
1149register_command "perl-reload", 0, sub { 1257register_command "perl-reload" => sub {
1150 my ($who, $arg) = @_; 1258 my ($who, $arg) = @_;
1151 1259
1152 if ($who->flag (FLAG_WIZ)) { 1260 if ($who->flag (FLAG_WIZ)) {
1153 _perl_reload { 1261 _perl_reload {
1154 warn $_[0]; 1262 warn $_[0];
1155 $who->message ($_[0]); 1263 $who->message ($_[0]);
1156 }; 1264 };
1157 } 1265 }
1158}; 1266};
1159 1267
1160register "<global>", __PACKAGE__;
1161
1162unshift @INC, $LIBDIR; 1268unshift @INC, $LIBDIR;
1163 1269
1164$TICK_WATCHER = Event->timer ( 1270$TICK_WATCHER = Event->timer (
1165 prio => 1, 1271 prio => 0,
1166 async => 1,
1167 at => $NEXT_TICK || 1, 1272 at => $NEXT_TICK || 1,
1273 data => WF_AUTOCANCEL,
1168 cb => sub { 1274 cb => sub {
1169 cf::server_tick; # one server iteration 1275 cf::server_tick; # one server iteration
1170 1276
1171 my $NOW = Event::time; 1277 my $NOW = Event::time;
1172 $NEXT_TICK += $TICK; 1278 $NEXT_TICK += $TICK;
1177 $TICK_WATCHER->at ($NEXT_TICK); 1283 $TICK_WATCHER->at ($NEXT_TICK);
1178 $TICK_WATCHER->start; 1284 $TICK_WATCHER->start;
1179 }, 1285 },
1180); 1286);
1181 1287
1182eval { IO::AIO::max_poll_time $TICK * 0.2 }; #d# remove eval after restart 1288IO::AIO::max_poll_time $TICK * 0.2;
1183 1289
1184Event->io (fd => IO::AIO::poll_fileno, 1290Event->io (fd => IO::AIO::poll_fileno,
1185 poll => 'r', 1291 poll => 'r',
1186 prio => 5, 1292 prio => 5,
1293 data => WF_AUTOCANCEL,
1187 cb => \&IO::AIO::poll_cb); 1294 cb => \&IO::AIO::poll_cb);
1188 1295
11891 12961
1190 1297

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines