ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/deliantra/Deliantra-Client/DC.pm
Revision: 1.131
Committed: Tue Dec 5 00:52:56 2006 UTC (17 years, 5 months ago) by root
Branch: MAIN
Changes since 1.130: +5 -3 lines
Log Message:
*** empty log message ***

File Contents

# User Rev Content
1 root 1.1 =head1 NAME
2    
3 root 1.108 CFPlus - undocumented utility garbage for our crossfire client
4 root 1.1
5     =head1 SYNOPSIS
6    
7 root 1.108 use CFPlus;
8 root 1.1
9     =head1 DESCRIPTION
10    
11     =over 4
12    
13     =cut
14    
15 root 1.108 package CFPlus;
16 root 1.1
17 root 1.121 use Carp ();
18    
19 root 1.1 BEGIN {
20 root 1.130 $VERSION = '0.97';
21 root 1.1
22 root 1.2 use XSLoader;
23 root 1.108 XSLoader::load "CFPlus", $VERSION;
24 root 1.1 }
25    
26 root 1.62 use utf8;
27    
28 root 1.52 use AnyEvent ();
29 root 1.34 use BerkeleyDB;
30 root 1.89 use Pod::POM ();
31 root 1.92 use Scalar::Util ();
32 root 1.89 use Storable (); # finally
33    
34 root 1.127 BEGIN {
35     use Crossfire::Protocol::Base ();
36     *to_json = \&Crossfire::Protocol::Base::to_json;
37     *from_json = \&Crossfire::Protocol::Base::from_json;
38     }
39    
40 root 1.103 =item guard { BLOCK }
41    
42     Returns an object that executes the given block as soon as it is destroyed.
43    
44     =cut
45    
46     sub guard(&) {
47 root 1.108 bless \(my $cb = $_[0]), "CFPlus::Guard"
48 root 1.103 }
49    
50 root 1.108 sub CFPlus::Guard::DESTROY {
51 root 1.103 ${$_[0]}->()
52     }
53    
54 root 1.105 sub asxml($) {
55     local $_ = $_[0];
56 root 1.89
57 root 1.105 s/&/&/g;
58     s/>/>/g;
59     s/</&lt;/g;
60 root 1.89
61 root 1.105 $_
62 root 1.89 }
63    
64 root 1.123 sub 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    
71 root 1.127 sub background(&;&) {
72     my ($bg, $cb) = @_;
73 root 1.123
74     my ($fh_r, $fh_w) = CFPlus::socketpipe;
75    
76     my $pid = fork;
77    
78     if (defined $pid && !$pid) {
79 root 1.124 local $SIG{__DIE__};
80 root 1.123
81     open STDOUT, ">&", $fh_w;
82     open STDERR, ">&", $fh_w;
83     close $fh_r;
84     close $fh_w;
85    
86     $| = 1;
87    
88 root 1.127 eval { $bg->() };
89 root 1.124
90     if ($@) {
91     my $msg = $@;
92     $msg =~ s/\n+/\n/;
93     warn "FATAL: $msg";
94     CFPlus::_exit 1;
95     }
96 root 1.123
97     # win32 is fucked up, of course. exit will clean stuff up,
98     # which destroys our database etc. _exit will exit ALL
99     # forked processes, because of the dreaded fork emulation.
100 root 1.124 CFPlus::_exit 0;
101 root 1.123 }
102    
103     close $fh_w;
104    
105     my $buffer;
106    
107 root 1.126 my $w; $w = AnyEvent->io (fh => $fh_r, poll => 'r', cb => sub {
108 root 1.123 unless (sysread $fh_r, $buffer, 4096, length $buffer) {
109 root 1.126 undef $w;
110 root 1.127 $cb->();
111     return;
112 root 1.123 }
113    
114     while ($buffer =~ s/^(.*)\n//) {
115     my $line = $1;
116 root 1.124 $line =~ s/\s+$//;
117 root 1.123 utf8::decode $line;
118 root 1.127 if ($line =~ /^\x{e877}json_msg (.*)$/s) {
119     $cb->(from_json $1);
120     } else {
121     ::message ({
122     markup => "background($pid): " . CFPlus::asxml $line,
123     });
124     }
125 root 1.123 }
126     });
127     }
128    
129 root 1.127 sub background_msg {
130     my ($msg) = @_;
131    
132     $msg = "\x{e877}json_msg " . to_json $msg;
133     $msg =~ s/\n//g;
134     utf8::encode $msg;
135     print $msg, "\n";
136     }
137    
138 root 1.108 package CFPlus::Database;
139 root 1.89
140     our @ISA = BerkeleyDB::Btree::;
141    
142     sub get($$) {
143     my $data;
144    
145     $_[0]->db_get ($_[1], $data) == 0
146     ? $data
147     : ()
148     }
149    
150     my %DB_SYNC;
151    
152     sub put($$$) {
153     my ($db, $key, $data) = @_;
154    
155 root 1.117 my $hkey = $db + 0;
156 root 1.116 Scalar::Util::weaken $db;
157 root 1.117 $DB_SYNC{$hkey} ||= AnyEvent->timer (after => 5, cb => sub {
158     delete $DB_SYNC{$hkey};
159 root 1.116 $db->db_sync if $db;
160     });
161 root 1.89
162     $db->db_put ($key => $data)
163     }
164    
165 root 1.108 package CFPlus;
166 root 1.52
167 root 1.5 sub find_rcfile($) {
168     my $path;
169    
170 root 1.46 for (grep !ref, @INC) {
171 root 1.108 $path = "$_/CFPlus/resources/$_[0]";
172 root 1.5 return $path if -r $path;
173     }
174    
175     die "FATAL: can't find required file $_[0]\n";
176     }
177    
178     sub read_cfg {
179     my ($file) = @_;
180    
181 root 1.107 open my $fh, $file
182 root 1.5 or return;
183    
184     local $/;
185 root 1.107 my $CFG = <$fh>;
186 root 1.5
187 root 1.108 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 root 1.107 } else {
194 root 1.108 $::CFG = eval $CFG; ## todo comaptibility cruft
195 root 1.107 }
196 root 1.5 }
197    
198     sub write_cfg {
199     my ($file) = @_;
200    
201 root 1.107 $::CFG->{VERSION} = $::VERSION;
202    
203     open my $fh, ">:utf8", $file
204 root 1.5 or return;
205 root 1.108 print $fh to_json $::CFG;
206 root 1.5 }
207    
208 root 1.122 sub http_proxy {
209     my @proxy = win32_proxy_info;
210    
211     if (@proxy) {
212     "http://" . (@proxy < 2 ? "" : @proxy < 3 ? "$proxy[1]\@" : "$proxy[1]:$proxy[2]\@") . $proxy[0]
213     } elsif (exists $ENV{http_proxy}) {
214     $ENV{http_proxy}
215     } else {
216     ()
217     }
218     }
219    
220     sub set_proxy {
221     my $proxy = http_proxy
222     or return;
223    
224     $ENV{http_proxy} = $proxy;
225     }
226    
227 root 1.127 sub lwp_useragent {
228     require LWP::UserAgent;
229    
230     CFPlus::set_proxy;
231    
232     my $ua = LWP::UserAgent->new (
233     agent => "cfplus $VERSION",
234     keep_alive => 1,
235     env_proxy => 1,
236     timeout => 30,
237     );
238     }
239    
240     sub lwp_check($) {
241     my ($res) = @_;
242    
243     $res->is_error
244     and die $res->status_line;
245    
246     $res
247     }
248    
249 root 1.77 our $DB_ENV;
250 root 1.121 our $DB_STATE;
251    
252     sub db_table($) {
253     my ($table) = @_;
254    
255     $table =~ s/([^a-zA-Z0-9_\-])/sprintf "=%x=", ord $1/ge;
256    
257     new CFPlus::Database
258     -Env => $DB_ENV,
259     -Filename => $table,
260     # -Filename => "database",
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     }
266 root 1.77
267 root 1.76 {
268     use strict;
269    
270 root 1.131 my $HOME = "$Crossfire::VARDIR/cfplus-$BerkeleyDB::db_version";
271    
272     mkdir $HOME, 0777;
273 root 1.77 my $recover = $BerkeleyDB::db_version >= 4.4
274     ? eval "DB_REGISTER | DB_RECOVER"
275     : 0;
276    
277     $DB_ENV = new BerkeleyDB::Env
278 root 1.131 -Home => $HOME,
279 root 1.76 -Cachesize => 1_000_000,
280     -ErrFile => "$Crossfire::VARDIR/cfplus/errorlog.txt",
281 root 1.39 # -ErrPrefix => "DATABASE",
282 root 1.76 -Verbose => 1,
283 root 1.77 -Flags => DB_CREATE | DB_RECOVER | DB_INIT_MPOOL | DB_INIT_LOCK | DB_INIT_TXN | $recover,
284 root 1.78 -SetFlags => DB_AUTO_COMMIT | DB_LOG_AUTOREMOVE,
285 root 1.131 or die "unable to create/open database home $HOME: $BerkeleyDB::Error";
286 root 1.76
287 root 1.121 $DB_STATE = db_table "state";
288 root 1.34 }
289    
290 root 1.108 package CFPlus::Layout;
291 root 1.97
292 root 1.108 $CFPlus::OpenGL::SHUTDOWN_HOOK{"CFPlus::Layout"} = sub {
293 root 1.98 reset_glyph_cache;
294 root 1.97 };
295    
296 root 1.108 package CFPlus::Item;
297 root 1.62
298 root 1.71 use strict;
299     use Crossfire::Protocol::Constants;
300    
301 elmex 1.84 my $last_enter_count = 1;
302    
303 root 1.62 sub desc_string {
304     my ($self) = @_;
305    
306     my $desc =
307     $self->{nrof} < 2
308     ? $self->{name}
309     : "$self->{nrof} × $self->{name_pl}";
310    
311 root 1.71 $self->{flags} & F_OPEN
312 root 1.62 and $desc .= " (open)";
313 root 1.71 $self->{flags} & F_APPLIED
314 root 1.62 and $desc .= " (applied)";
315 root 1.71 $self->{flags} & F_UNPAID
316 root 1.62 and $desc .= " (unpaid)";
317 root 1.71 $self->{flags} & F_MAGIC
318 root 1.62 and $desc .= " (magic)";
319 root 1.71 $self->{flags} & F_CURSED
320 root 1.62 and $desc .= " (cursed)";
321 root 1.71 $self->{flags} & F_DAMNED
322 root 1.62 and $desc .= " (damned)";
323 root 1.71 $self->{flags} & F_LOCKED
324 root 1.62 and $desc .= " *";
325    
326     $desc
327     }
328    
329     sub weight_string {
330     my ($self) = @_;
331    
332     my $weight = ($self->{nrof} || 1) * $self->{weight};
333    
334     $weight < 0 ? "?" : $weight * 0.001
335     }
336    
337 elmex 1.84 sub do_n_dialog {
338     my ($cb) = @_;
339    
340 root 1.113 my $w = new CFPlus::UI::Toplevel
341 root 1.100 on_delete => sub { $_[0]->destroy; 1 },
342     has_close_button => 1,
343     ;
344    
345 root 1.108 $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 elmex 1.84 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 root 1.100 $w->destroy;
355    
356     0
357     },
358     on_escape => sub { $w->destroy; 1 },
359 elmex 1.84 );
360 root 1.93 $entry->grab_focus;
361 elmex 1.84 $w->show;
362     }
363    
364 root 1.62 sub update_widgets {
365     my ($self) = @_;
366    
367 root 1.92 # necessary to avoid cyclic references
368     Scalar::Util::weaken $self;
369    
370 root 1.63 my $button_cb = sub {
371     my (undef, $ev, $x, $y) = @_;
372    
373 elmex 1.84 my $targ = $::CONN->{player}{tag};
374 root 1.63
375 elmex 1.84 if ($self->{container} == $::CONN->{player}{tag}) {
376     $targ = $::CONN->{open_container};
377     }
378 root 1.63
379 root 1.108 if (($ev->{mod} & CFPlus::KMOD_SHIFT) && $ev->{button} == 1) {
380 root 1.79 $::CONN->send ("move $targ $self->{tag} 0")
381     if $targ || !($self->{flags} & F_LOCKED);
382 root 1.108 } elsif (($ev->{mod} & CFPlus::KMOD_SHIFT) && $ev->{button} == 2) {
383 elmex 1.86 $self->{flags} & F_LOCKED
384     ? $::CONN->send ("lock " . pack "CN", 0, $self->{tag})
385     : $::CONN->send ("lock " . pack "CN", 1, $self->{tag})
386 root 1.63 } 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 elmex 1.101 my $move_prefix = $::CONN->{open_container} ? 'put' : 'drop';
392     if ($self->{container} == $::CONN->{open_container}) {
393     $move_prefix = "take";
394     }
395    
396 root 1.63 my @menu_items = (
397     ["examine", sub { $::CONN->send ("examine $self->{tag}") }],
398     ["mark", sub { $::CONN->send ("mark ". pack "N", $self->{tag}) }],
399 elmex 1.99 ["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 elmex 1.109 ["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 elmex 1.114 ["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 elmex 1.115 }, $self->{name},
421     "If you input no name or erase the current custom name, the custom name will be unset");
422 elmex 1.114 }
423     ],
424 root 1.63 ["apply", sub { $::CONN->send ("apply $self->{tag}") }],
425     (
426 root 1.71 $self->{flags} & F_LOCKED
427 root 1.63 ? (
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 elmex 1.101 ["$move_prefix all", sub { $::CONN->send ("move $targ $self->{tag} 0") }],
433 root 1.104 ["$move_prefix &lt;n&gt;",
434 elmex 1.84 sub {
435     do_n_dialog (sub { $::CONN->send ("move $targ $self->{tag} $_[0]") })
436     }
437     ]
438 root 1.63 )
439     ),
440     );
441    
442 root 1.108 CFPlus::UI::Menu->new (items => \@menu_items)->popup ($ev);
443 root 1.63 }
444    
445     1
446     };
447    
448 root 1.62 my $tooltip_std = "<small>"
449     . "Left click - examine item\n"
450     . "Shift-Left click - " . ($self->{container} ? "move or drop" : "take") . " item\n"
451     . "Middle click - apply\n"
452 elmex 1.86 . "Shift-Middle click - lock/unlock\n"
453 root 1.62 . "Right click - further options"
454     . "</small>\n";
455    
456 root 1.106 my $bg = $self->{flags} & F_CURSED ? [1 , 0 , 0, 0.5]
457     : $self->{flags} & F_MAGIC ? [0.2, 0.2, 1, 0.5]
458     : undef;
459    
460 root 1.108 $self->{face_widget} ||= new CFPlus::UI::Face
461 root 1.63 can_events => 1,
462     can_hover => 1,
463 root 1.67 anim => $self->{anim},
464 root 1.66 animspeed => $self->{animspeed}, # TODO# must be set at creation time
465 root 1.72 on_button_down => $button_cb,
466 root 1.63 ;
467 root 1.106 $self->{face_widget}{bg} = $bg;
468 root 1.62 $self->{face_widget}{face} = $self->{face};
469     $self->{face_widget}{anim} = $self->{anim};
470 root 1.65 $self->{face_widget}{animspeed} = $self->{animspeed};
471 root 1.62 $self->{face_widget}->set_tooltip (
472     "<b>Face/Animation.</b>\n"
473     . "Item uses face #$self->{face}. "
474     . ($self->{animspeed} ? "Item uses animation #$self->{anim} at " . (1 / $self->{animspeed}) . "fps. " : "Item is not animated. ")
475     . "\n\n$tooltip_std"
476     );
477    
478 root 1.108 $self->{desc_widget} ||= new CFPlus::UI::Label
479 root 1.63 can_events => 1,
480     can_hover => 1,
481     ellipsise => 2,
482 root 1.68 align => -1,
483 root 1.72 on_button_down => $button_cb,
484 root 1.63 ;
485 root 1.108 my $desc = CFPlus::Item::desc_string $self;
486 root 1.106 $self->{desc_widget}{bg} = $bg;
487 root 1.63 $self->{desc_widget}->set_text ($desc);
488     $self->{desc_widget}->set_tooltip ("<b>$desc</b>.\n$tooltip_std");
489    
490 root 1.108 $self->{weight_widget} ||= new CFPlus::UI::Label
491 root 1.63 can_events => 1,
492     can_hover => 1,
493     ellipsise => 0,
494 root 1.68 align => 0,
495 root 1.72 on_button_down => $button_cb,
496 root 1.63 ;
497 root 1.106 $self->{weight_widget}{bg} = $bg;
498 root 1.108 $self->{weight_widget}->set_text (CFPlus::Item::weight_string $self);
499 root 1.62 $self->{weight_widget}->set_tooltip (
500     "<b>Weight</b>.\n"
501     . ($self->{weight} >= 0 ? "One item weighs $self->{weight}g. " : "You have no idea how much this weighs. ")
502     . ($self->{nrof} ? "You have $self->{nrof} of it. " : "Item cannot stack with others of it's kind. ")
503     . "\n\n$tooltip_std"
504     );
505     }
506    
507 root 1.1 1;
508    
509     =back
510    
511     =head1 AUTHOR
512    
513     Marc Lehmann <schmorp@schmorp.de>
514     http://home.schmorp.de/
515    
516     =cut
517