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

Diff Legend

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