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

Diff Legend

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