ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/deliantra/Deliantra-Client/DC.pm
(Generate patch)

Comparing deliantra/Deliantra-Client/DC.pm (file contents):
Revision 1.135 by root, Thu Dec 7 15:57:13 2006 UTC vs.
Revision 1.201 by root, Sun Jan 11 03:19:47 2009 UTC

1=head1 NAME 1=head1 NAME
2 2
3CFPlus - undocumented utility garbage for our crossfire client 3DC - undocumented utility garbage for our deliantra client
4 4
5=head1 SYNOPSIS 5=head1 SYNOPSIS
6 6
7 use CFPlus; 7 use DC;
8 8
9=head1 DESCRIPTION 9=head1 DESCRIPTION
10 10
11=over 4 11=over 4
12 12
13=cut 13=cut
14 14
15package CFPlus; 15package DC;
16 16
17use Carp (); 17use Carp ();
18 18
19our $VERSION;
20
19BEGIN { 21BEGIN {
20 $VERSION = '0.97'; 22 $VERSION = '2.02';
21 23
22 use XSLoader; 24 use XSLoader;
23 XSLoader::load "CFPlus", $VERSION; 25 XSLoader::load "Deliantra::Client", $VERSION;
24} 26}
25 27
26use utf8; 28use utf8;
29use strict qw(vars subs);
27 30
31use Socket ();
28use AnyEvent (); 32use AnyEvent ();
29use BerkeleyDB; 33use AnyEvent::Util ();
30use Pod::POM (); 34use Pod::POM ();
31use Scalar::Util ();
32use File::Path (); 35use File::Path ();
33use Storable (); # finally 36use Storable (); # finally
34 37use Fcntl ();
35BEGIN { 38use JSON::XS qw(encode_json decode_json);
36 use Crossfire::Protocol::Base ();
37 *to_json = \&Crossfire::Protocol::Base::to_json;
38 *from_json = \&Crossfire::Protocol::Base::from_json;
39}
40 39
41=item guard { BLOCK } 40=item guard { BLOCK }
42 41
43Returns an object that executes the given block as soon as it is destroyed. 42Returns an object that executes the given block as soon as it is destroyed.
44 43
45=cut 44=cut
46 45
47sub guard(&) { 46sub guard(&) {
48 bless \(my $cb = $_[0]), "CFPlus::Guard" 47 bless \(my $cb = $_[0]), "DC::Guard"
49} 48}
50 49
51sub CFPlus::Guard::DESTROY { 50sub DC::Guard::DESTROY {
52 ${$_[0]}->() 51 ${$_[0]}->()
53} 52}
54 53
55=item shorten $string[, $maxlength] 54=item shorten $string[, $maxlength]
56 55
… …
70 s/</&lt;/g; 69 s/</&lt;/g;
71 70
72 $_ 71 $_
73} 72}
74 73
75sub socketpipe() {
76 socketpair my $fh1, my $fh2, Socket::AF_UNIX, Socket::SOCK_STREAM, Socket::PF_UNSPEC
77 or die "cannot establish bidiretcional pipe: $!\n";
78
79 ($fh1, $fh2)
80}
81
82sub background(&;&) { 74sub background(&;&) {
83 my ($bg, $cb) = @_; 75 my ($bg, $cb) = @_;
84 76
85 my ($fh_r, $fh_w) = CFPlus::socketpipe; 77 my ($fh_r, $fh_w) = AnyEvent::Util::portable_socketpair
78 or die "unable to create background socketpair: $!";
86 79
87 my $pid = fork; 80 my $pid = fork;
88 81
89 if (defined $pid && !$pid) { 82 if (defined $pid && !$pid) {
90 local $SIG{__DIE__}; 83 local $SIG{__DIE__};
… …
100 93
101 if ($@) { 94 if ($@) {
102 my $msg = $@; 95 my $msg = $@;
103 $msg =~ s/\n+/\n/; 96 $msg =~ s/\n+/\n/;
104 warn "FATAL: $msg"; 97 warn "FATAL: $msg";
105 CFPlus::_exit 1; 98 DC::_exit 1;
106 } 99 }
107 100
108 # win32 is fucked up, of course. exit will clean stuff up, 101 # win32 is fucked up, of course. exit will clean stuff up,
109 # which destroys our database etc. _exit will exit ALL 102 # which destroys our database etc. _exit will exit ALL
110 # forked processes, because of the dreaded fork emulation. 103 # forked processes, because of the dreaded fork emulation.
111 CFPlus::_exit 0; 104 DC::_exit 0;
112 } 105 }
113 106
114 close $fh_w; 107 close $fh_w;
115 108
116 my $buffer; 109 my $buffer;
… …
125 while ($buffer =~ s/^(.*)\n//) { 118 while ($buffer =~ s/^(.*)\n//) {
126 my $line = $1; 119 my $line = $1;
127 $line =~ s/\s+$//; 120 $line =~ s/\s+$//;
128 utf8::decode $line; 121 utf8::decode $line;
129 if ($line =~ /^\x{e877}json_msg (.*)$/s) { 122 if ($line =~ /^\x{e877}json_msg (.*)$/s) {
130 $cb->(from_json $1); 123 $cb->(JSON::XS->new->allow_nonref->decode ($1));
131 } else { 124 } else {
132 ::message ({ 125 ::message ({
133 markup => "background($pid): " . CFPlus::asxml $line, 126 markup => "background($pid): " . DC::asxml $line,
134 }); 127 });
135 } 128 }
136 } 129 }
137 }); 130 });
138} 131}
139 132
140sub background_msg { 133sub background_msg {
141 my ($msg) = @_; 134 my ($msg) = @_;
142 135
143 $msg = "\x{e877}json_msg " . to_json $msg; 136 $msg = "\x{e877}json_msg " . JSON::XS->new->allow_nonref->encode ($msg);
144 $msg =~ s/\n//g; 137 $msg =~ s/\n//g;
145 utf8::encode $msg; 138 utf8::encode $msg;
146 print $msg, "\n"; 139 print $msg, "\n";
147} 140}
148 141
149package CFPlus::Database;
150
151our @ISA = BerkeleyDB::Btree::;
152
153sub get($$) {
154 my $data;
155
156 $_[0]->db_get ($_[1], $data) == 0
157 ? $data
158 : ()
159}
160
161my %DB_SYNC;
162
163sub put($$$) {
164 my ($db, $key, $data) = @_;
165
166 my $hkey = $db + 0;
167 Scalar::Util::weaken $db;
168 $DB_SYNC{$hkey} ||= AnyEvent->timer (after => 5, cb => sub {
169 delete $DB_SYNC{$hkey};
170 $db->db_sync if $db;
171 });
172
173 $db->db_put ($key => $data)
174}
175
176package CFPlus; 142package DC;
143
144our $RC_THEME;
145our %THEME;
146our @RC_PATH;
147our $RC_BASE;
148
149for (grep !ref, @INC) {
150 $RC_BASE = "$_/Deliantra/Client/private/resources";
151 last if -d $RC_BASE;
152}
177 153
178sub find_rcfile($) { 154sub find_rcfile($) {
179 my $path; 155 my $path;
180 156
181 for (grep !ref, @INC) { 157 for (@RC_PATH, "") {
182 $path = "$_/CFPlus/resources/$_[0]"; 158 $path = "$RC_BASE/$_/$_[0]";
183 return $path if -r $path; 159 return $path if -r $path;
184 } 160 }
185 161
186 die "FATAL: can't find required file $_[0]\n"; 162 die "FATAL: can't find required file \"$_[0]\" in \"$RC_BASE\"\n";
163}
164
165sub load_json($) {
166 my ($file) = @_;
167
168 open my $fh, $file
169 or return;
170
171 local $/;
172 JSON::XS->new->utf8->relaxed->decode (<$fh>)
173}
174
175sub set_theme($) {
176 return if $RC_THEME eq $_[0];
177 $RC_THEME = $_[0];
178
179 # kind of hacky, find the main theme file, then load all theme files and merge them
180
181 %THEME = ();
182 @RC_PATH = "theme-$RC_THEME";
183
184 my $theme = load_json find_rcfile "theme.json"
185 or die "FATAL: theme resource file not found";
186
187 @RC_PATH = @{ $theme->{path} } if $theme->{path};
188
189 for (@RC_PATH, "") {
190 my $theme = load_json "$RC_BASE/$_/theme.json"
191 or next;
192
193 %THEME = ( %$theme, %THEME );
194 }
187} 195}
188 196
189sub read_cfg { 197sub read_cfg {
190 my ($file) = @_; 198 my ($file) = @_;
191 199
200 $::CFG = (load_json $file) || (load_json "$file.bak");
201}
202
203sub write_cfg {
204 my $file = "$Deliantra::VARDIR/client.cf";
205
206 $::CFG->{VERSION} = $::VERSION;
207 $::CFG->{layout} = DC::UI::get_layout ();
208
192 open my $fh, $file 209 open my $fh, ">:utf8", "$file~"
193 or return; 210 or return;
211 print $fh JSON::XS->new->utf8->pretty->encode ($::CFG);
212 close $fh;
194 213
195 local $/; 214 rename $file, "$file.bak";
196 my $CFG = <$fh>; 215 rename "$file~", $file;
197
198 if ($CFG =~ /^---/) { ## TODO compatibility cruft, remove
199 require YAML;
200 utf8::decode $CFG;
201 $::CFG = YAML::Load ($CFG);
202 } elsif ($CFG =~ /^\{/) {
203 $::CFG = from_json $CFG;
204 } else {
205 $::CFG = eval $CFG; ## todo comaptibility cruft
206 }
207}
208
209sub write_cfg {
210 my ($file) = @_;
211
212 $::CFG->{VERSION} = $::VERSION;
213
214 open my $fh, ">:utf8", $file
215 or return;
216 print $fh to_json $::CFG;
217} 216}
218 217
219sub http_proxy { 218sub http_proxy {
220 my @proxy = win32_proxy_info; 219 my @proxy = win32_proxy_info;
221 220
… …
236} 235}
237 236
238sub lwp_useragent { 237sub lwp_useragent {
239 require LWP::UserAgent; 238 require LWP::UserAgent;
240 239
241 CFPlus::set_proxy; 240 DC::set_proxy;
242 241
243 my $ua = LWP::UserAgent->new ( 242 my $ua = LWP::UserAgent->new (
244 agent => "cfplus $VERSION", 243 agent => "deliantra $VERSION",
245 keep_alive => 1, 244 keep_alive => 1,
246 env_proxy => 1, 245 env_proxy => 1,
247 timeout => 30, 246 timeout => 30,
248 ); 247 );
249} 248}
… …
255 and die $res->status_line; 254 and die $res->status_line;
256 255
257 $res 256 $res
258} 257}
259 258
260our $DB_ENV; 259sub fh_nonblocking($$) {
261our $DB_STATE;
262
263sub db_table($) {
264 my ($table) = @_; 260 my ($fh, $nb) = @_;
265 261
266 $table =~ s/([^a-zA-Z0-9_\-])/sprintf "=%x=", ord $1/ge; 262 if ($^O eq "MSWin32") {
267 263 $nb = (! ! $nb) + 0;
268 new CFPlus::Database 264 ioctl $fh, 0x8004667e, \$nb; # FIONBIO
269 -Env => $DB_ENV, 265 } else {
270 -Filename => $table, 266 fcntl $fh, &Fcntl::F_SETFL, $nb ? &Fcntl::O_NONBLOCK : 0;
271# -Filename => "database",
272# -Subname => $table,
273 -Property => DB_CHKSUM,
274 -Flags => DB_CREATE | DB_UPGRADE,
275 or die "unable to create/open database table $_[0]: $BerkeleyDB::Error"
276}
277
278our $DB_HOME = "$Crossfire::VARDIR/cfplus";
279
280sub open_db {
281 use strict;
282
283 mkdir $DB_HOME, 0777;
284 my $recover = $BerkeleyDB::db_version >= 4.4
285 ? eval "DB_REGISTER | DB_RECOVER"
286 : 0;
287
288 $DB_ENV = new BerkeleyDB::Env
289 -Home => $DB_HOME,
290 -Cachesize => 1_000_000,
291 -ErrFile => "$DB_HOME/errorlog.txt",
292# -ErrPrefix => "DATABASE",
293 -Verbose => 1,
294 -Flags => DB_CREATE | DB_RECOVER | DB_INIT_MPOOL | DB_INIT_LOCK | DB_INIT_TXN | $recover,
295 -SetFlags => DB_AUTO_COMMIT | DB_LOG_AUTOREMOVE,
296 or die "unable to create/open database home $DB_HOME: $BerkeleyDB::Error";
297
298 $DB_STATE = db_table "state";
299
300 1 267 }
301} 268}
302 269
303unless (eval { open_db }) {
304 File::Path::rmtree $DB_HOME;
305 open_db;
306}
307
308package CFPlus::Layout; 270package DC::Layout;
309 271
310$CFPlus::OpenGL::SHUTDOWN_HOOK{"CFPlus::Layout"} = sub { 272$DC::OpenGL::INIT_HOOK{"DC::Layout"} = sub {
311 reset_glyph_cache; 273 glyph_cache_restore;
312}; 274};
313 275
314package CFPlus::Item; 276$DC::OpenGL::SHUTDOWN_HOOK{"DC::Layout"} = sub {
315 277 glyph_cache_backup;
316use strict; 278};
317use Crossfire::Protocol::Constants;
318
319my $last_enter_count = 1;
320
321sub desc_string {
322 my ($self) = @_;
323
324 my $desc =
325 $self->{nrof} < 2
326 ? $self->{name}
327 : "$self->{nrof} × $self->{name_pl}";
328
329 $self->{flags} & F_OPEN
330 and $desc .= " (open)";
331 $self->{flags} & F_APPLIED
332 and $desc .= " (applied)";
333 $self->{flags} & F_UNPAID
334 and $desc .= " (unpaid)";
335 $self->{flags} & F_MAGIC
336 and $desc .= " (magic)";
337 $self->{flags} & F_CURSED
338 and $desc .= " (cursed)";
339 $self->{flags} & F_DAMNED
340 and $desc .= " (damned)";
341 $self->{flags} & F_LOCKED
342 and $desc .= " *";
343
344 $desc
345}
346
347sub weight_string {
348 my ($self) = @_;
349
350 my $weight = ($self->{nrof} || 1) * $self->{weight};
351
352 $weight < 0 ? "?" : $weight * 0.001
353}
354
355sub do_n_dialog {
356 my ($cb) = @_;
357
358 my $w = new CFPlus::UI::Toplevel
359 on_delete => sub { $_[0]->destroy; 1 },
360 has_close_button => 1,
361 ;
362
363 $w->add (my $vb = new CFPlus::UI::VBox x => "center", y => "center");
364 $vb->add (new CFPlus::UI::Label text => "Enter item count:");
365 $vb->add (my $entry = new CFPlus::UI::Entry
366 text => $last_enter_count,
367 on_activate => sub {
368 my ($entry) = @_;
369 $last_enter_count = $entry->get_text;
370 $cb->($last_enter_count);
371 $w->hide;
372 $w->destroy;
373
374 0
375 },
376 on_escape => sub { $w->destroy; 1 },
377 );
378 $entry->grab_focus;
379 $w->show;
380}
381
382sub update_widgets {
383 my ($self) = @_;
384
385 # necessary to avoid cyclic references
386 Scalar::Util::weaken $self;
387
388 my $button_cb = sub {
389 my (undef, $ev, $x, $y) = @_;
390
391 my $targ = $::CONN->{player}{tag};
392
393 if ($self->{container} == $::CONN->{player}{tag}) {
394 $targ = $::CONN->{open_container};
395 }
396
397 if (($ev->{mod} & CFPlus::KMOD_SHIFT) && $ev->{button} == 1) {
398 $::CONN->send ("move $targ $self->{tag} 0")
399 if $targ || !($self->{flags} & F_LOCKED);
400 } elsif (($ev->{mod} & CFPlus::KMOD_SHIFT) && $ev->{button} == 2) {
401 $self->{flags} & F_LOCKED
402 ? $::CONN->send ("lock " . pack "CN", 0, $self->{tag})
403 : $::CONN->send ("lock " . pack "CN", 1, $self->{tag})
404 } elsif ($ev->{button} == 1) {
405 $::CONN->send ("examine $self->{tag}");
406 } elsif ($ev->{button} == 2) {
407 $::CONN->send ("apply $self->{tag}");
408 } elsif ($ev->{button} == 3) {
409 my $move_prefix = $::CONN->{open_container} ? 'put' : 'drop';
410 if ($self->{container} == $::CONN->{open_container}) {
411 $move_prefix = "take";
412 }
413
414 my $shortname = CFPlus::shorten $self->{name}, 14;
415
416 my @menu_items = (
417 ["examine", sub { $::CONN->send ("examine $self->{tag}") }],
418 ["mark", sub { $::CONN->send ("mark ". pack "N", $self->{tag}) }],
419 ["ignite/thaw", # first try of an easier use of flint&steel
420 sub {
421 $::CONN->send ("mark ". pack "N", $self->{tag});
422 $::CONN->send ("command apply flint and steel");
423 }
424 ],
425 ["inscribe", # first try of an easier use of flint&steel
426 sub {
427 &::open_string_query ("Text to inscribe", sub {
428 my ($entry, $txt) = @_;
429 $::CONN->send ("mark ". pack "N", $self->{tag});
430 $::CONN->send ("command use_skill inscription $txt");
431 });
432 }
433 ],
434 ["rename", # first try of an easier use of flint&steel
435 sub {
436 &::open_string_query ("Rename item to:", sub {
437 my ($entry, $txt) = @_;
438 $::CONN->send ("mark ". pack "N", $self->{tag});
439 $::CONN->send ("command rename to <$txt>");
440 }, $self->{name},
441 "If you input no name or erase the current custom name, the custom name will be unset");
442 }
443 ],
444 ["apply", sub { $::CONN->send ("apply $self->{tag}") }],
445 (
446 $self->{flags} & F_LOCKED
447 ? (
448 ["unlock", sub { $::CONN->send ("lock " . pack "CN", 0, $self->{tag}) }],
449 )
450 : (
451 ["lock", sub { $::CONN->send ("lock " . pack "CN", 1, $self->{tag}) }],
452 ["$move_prefix all", sub { $::CONN->send ("move $targ $self->{tag} 0") }],
453 ["$move_prefix &lt;n&gt;",
454 sub {
455 do_n_dialog (sub { $::CONN->send ("move $targ $self->{tag} $_[0]") })
456 }
457 ]
458 )
459 ),
460 ["bind <i>apply $shortname</i> to a key" => sub { $::BIND_EDITOR->do_quick_binding (["apply $self->{name}"]) }],
461 );
462
463 CFPlus::UI::Menu->new (items => \@menu_items)->popup ($ev);
464 }
465
466 1
467 };
468
469 my $tooltip_std = "<small>"
470 . "Left click - examine item\n"
471 . "Shift-Left click - " . ($self->{container} ? "move or drop" : "take") . " item\n"
472 . "Middle click - apply\n"
473 . "Shift-Middle click - lock/unlock\n"
474 . "Right click - further options"
475 . "</small>\n";
476
477 my $bg = $self->{flags} & F_CURSED ? [1 , 0 , 0, 0.5]
478 : $self->{flags} & F_MAGIC ? [0.2, 0.2, 1, 0.5]
479 : undef;
480
481 $self->{face_widget} ||= new CFPlus::UI::Face
482 can_events => 1,
483 can_hover => 1,
484 anim => $self->{anim},
485 animspeed => $self->{animspeed}, # TODO# must be set at creation time
486 on_button_down => $button_cb,
487 ;
488 $self->{face_widget}{bg} = $bg;
489 $self->{face_widget}{face} = $self->{face};
490 $self->{face_widget}{anim} = $self->{anim};
491 $self->{face_widget}{animspeed} = $self->{animspeed};
492 $self->{face_widget}->set_tooltip (
493 "<b>Face/Animation.</b>\n"
494 . "Item uses face #$self->{face}. "
495 . ($self->{animspeed} ? "Item uses animation #$self->{anim} at " . (1 / $self->{animspeed}) . "fps. " : "Item is not animated. ")
496 . "\n\n$tooltip_std"
497 );
498
499 $self->{desc_widget} ||= new CFPlus::UI::Label
500 can_events => 1,
501 can_hover => 1,
502 ellipsise => 2,
503 align => -1,
504 on_button_down => $button_cb,
505 ;
506 my $desc = CFPlus::Item::desc_string $self;
507 $self->{desc_widget}{bg} = $bg;
508 $self->{desc_widget}->set_text ($desc);
509 $self->{desc_widget}->set_tooltip ("<b>$desc</b>.\n$tooltip_std");
510
511 $self->{weight_widget} ||= new CFPlus::UI::Label
512 can_events => 1,
513 can_hover => 1,
514 ellipsise => 0,
515 align => 0,
516 on_button_down => $button_cb,
517 ;
518 $self->{weight_widget}{bg} = $bg;
519 $self->{weight_widget}->set_text (CFPlus::Item::weight_string $self);
520 $self->{weight_widget}->set_tooltip (
521 "<b>Weight</b>.\n"
522 . ($self->{weight} >= 0 ? "One item weighs $self->{weight}g. " : "You have no idea how much this weighs. ")
523 . ($self->{nrof} ? "You have $self->{nrof} of it. " : "Item cannot stack with others of it's kind. ")
524 . "\n\n$tooltip_std"
525 );
526}
527 279
5281; 2801;
529 281
530=back 282=back
531 283

Diff Legend

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