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

Diff Legend

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