ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/deliantra/Deliantra-Client/DC.pm
Revision: 1.129
Committed: Mon Nov 20 16:41:46 2006 UTC (17 years, 5 months ago) by root
Branch: MAIN
Changes since 1.128: +0 -9 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.128 $VERSION = '0.96';
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.87 mkdir "$Crossfire::VARDIR/cfplus", 0777;
271 root 1.77 my $recover = $BerkeleyDB::db_version >= 4.4
272     ? eval "DB_REGISTER | DB_RECOVER"
273     : 0;
274    
275     $DB_ENV = new BerkeleyDB::Env
276 root 1.76 -Home => "$Crossfire::VARDIR/cfplus",
277     -Cachesize => 1_000_000,
278     -ErrFile => "$Crossfire::VARDIR/cfplus/errorlog.txt",
279 root 1.39 # -ErrPrefix => "DATABASE",
280 root 1.76 -Verbose => 1,
281 root 1.77 -Flags => DB_CREATE | DB_RECOVER | DB_INIT_MPOOL | DB_INIT_LOCK | DB_INIT_TXN | $recover,
282 root 1.78 -SetFlags => DB_AUTO_COMMIT | DB_LOG_AUTOREMOVE,
283 root 1.76 or die "unable to create/open database home $Crossfire::VARDIR/cfplus: $BerkeleyDB::Error";
284    
285 root 1.121 $DB_STATE = db_table "state";
286 root 1.34 }
287    
288 root 1.108 package CFPlus::Layout;
289 root 1.97
290 root 1.108 $CFPlus::OpenGL::SHUTDOWN_HOOK{"CFPlus::Layout"} = sub {
291 root 1.98 reset_glyph_cache;
292 root 1.97 };
293    
294 root 1.108 package CFPlus::Item;
295 root 1.62
296 root 1.71 use strict;
297     use Crossfire::Protocol::Constants;
298    
299 elmex 1.84 my $last_enter_count = 1;
300    
301 root 1.62 sub desc_string {
302     my ($self) = @_;
303    
304     my $desc =
305     $self->{nrof} < 2
306     ? $self->{name}
307     : "$self->{nrof} × $self->{name_pl}";
308    
309 root 1.71 $self->{flags} & F_OPEN
310 root 1.62 and $desc .= " (open)";
311 root 1.71 $self->{flags} & F_APPLIED
312 root 1.62 and $desc .= " (applied)";
313 root 1.71 $self->{flags} & F_UNPAID
314 root 1.62 and $desc .= " (unpaid)";
315 root 1.71 $self->{flags} & F_MAGIC
316 root 1.62 and $desc .= " (magic)";
317 root 1.71 $self->{flags} & F_CURSED
318 root 1.62 and $desc .= " (cursed)";
319 root 1.71 $self->{flags} & F_DAMNED
320 root 1.62 and $desc .= " (damned)";
321 root 1.71 $self->{flags} & F_LOCKED
322 root 1.62 and $desc .= " *";
323    
324     $desc
325     }
326    
327     sub weight_string {
328     my ($self) = @_;
329    
330     my $weight = ($self->{nrof} || 1) * $self->{weight};
331    
332     $weight < 0 ? "?" : $weight * 0.001
333     }
334    
335 elmex 1.84 sub do_n_dialog {
336     my ($cb) = @_;
337    
338 root 1.113 my $w = new CFPlus::UI::Toplevel
339 root 1.100 on_delete => sub { $_[0]->destroy; 1 },
340     has_close_button => 1,
341     ;
342    
343 root 1.108 $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 elmex 1.84 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 root 1.100 $w->destroy;
353    
354     0
355     },
356     on_escape => sub { $w->destroy; 1 },
357 elmex 1.84 );
358 root 1.93 $entry->grab_focus;
359 elmex 1.84 $w->show;
360     }
361    
362 root 1.62 sub update_widgets {
363     my ($self) = @_;
364    
365 root 1.92 # necessary to avoid cyclic references
366     Scalar::Util::weaken $self;
367    
368 root 1.63 my $button_cb = sub {
369     my (undef, $ev, $x, $y) = @_;
370    
371 elmex 1.84 my $targ = $::CONN->{player}{tag};
372 root 1.63
373 elmex 1.84 if ($self->{container} == $::CONN->{player}{tag}) {
374     $targ = $::CONN->{open_container};
375     }
376 root 1.63
377 root 1.108 if (($ev->{mod} & CFPlus::KMOD_SHIFT) && $ev->{button} == 1) {
378 root 1.79 $::CONN->send ("move $targ $self->{tag} 0")
379     if $targ || !($self->{flags} & F_LOCKED);
380 root 1.108 } elsif (($ev->{mod} & CFPlus::KMOD_SHIFT) && $ev->{button} == 2) {
381 elmex 1.86 $self->{flags} & F_LOCKED
382     ? $::CONN->send ("lock " . pack "CN", 0, $self->{tag})
383     : $::CONN->send ("lock " . pack "CN", 1, $self->{tag})
384 root 1.63 } 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 elmex 1.101 my $move_prefix = $::CONN->{open_container} ? 'put' : 'drop';
390     if ($self->{container} == $::CONN->{open_container}) {
391     $move_prefix = "take";
392     }
393    
394 root 1.63 my @menu_items = (
395     ["examine", sub { $::CONN->send ("examine $self->{tag}") }],
396     ["mark", sub { $::CONN->send ("mark ". pack "N", $self->{tag}) }],
397 elmex 1.99 ["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 elmex 1.109 ["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 elmex 1.114 ["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 elmex 1.115 }, $self->{name},
419     "If you input no name or erase the current custom name, the custom name will be unset");
420 elmex 1.114 }
421     ],
422 root 1.63 ["apply", sub { $::CONN->send ("apply $self->{tag}") }],
423     (
424 root 1.71 $self->{flags} & F_LOCKED
425 root 1.63 ? (
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 elmex 1.101 ["$move_prefix all", sub { $::CONN->send ("move $targ $self->{tag} 0") }],
431 root 1.104 ["$move_prefix &lt;n&gt;",
432 elmex 1.84 sub {
433     do_n_dialog (sub { $::CONN->send ("move $targ $self->{tag} $_[0]") })
434     }
435     ]
436 root 1.63 )
437     ),
438     );
439    
440 root 1.108 CFPlus::UI::Menu->new (items => \@menu_items)->popup ($ev);
441 root 1.63 }
442    
443     1
444     };
445    
446 root 1.62 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 elmex 1.86 . "Shift-Middle click - lock/unlock\n"
451 root 1.62 . "Right click - further options"
452     . "</small>\n";
453    
454 root 1.106 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 root 1.108 $self->{face_widget} ||= new CFPlus::UI::Face
459 root 1.63 can_events => 1,
460     can_hover => 1,
461 root 1.67 anim => $self->{anim},
462 root 1.66 animspeed => $self->{animspeed}, # TODO# must be set at creation time
463 root 1.72 on_button_down => $button_cb,
464 root 1.63 ;
465 root 1.106 $self->{face_widget}{bg} = $bg;
466 root 1.62 $self->{face_widget}{face} = $self->{face};
467     $self->{face_widget}{anim} = $self->{anim};
468 root 1.65 $self->{face_widget}{animspeed} = $self->{animspeed};
469 root 1.62 $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 root 1.108 $self->{desc_widget} ||= new CFPlus::UI::Label
477 root 1.63 can_events => 1,
478     can_hover => 1,
479     ellipsise => 2,
480 root 1.68 align => -1,
481 root 1.72 on_button_down => $button_cb,
482 root 1.63 ;
483 root 1.108 my $desc = CFPlus::Item::desc_string $self;
484 root 1.106 $self->{desc_widget}{bg} = $bg;
485 root 1.63 $self->{desc_widget}->set_text ($desc);
486     $self->{desc_widget}->set_tooltip ("<b>$desc</b>.\n$tooltip_std");
487    
488 root 1.108 $self->{weight_widget} ||= new CFPlus::UI::Label
489 root 1.63 can_events => 1,
490     can_hover => 1,
491     ellipsise => 0,
492 root 1.68 align => 0,
493 root 1.72 on_button_down => $button_cb,
494 root 1.63 ;
495 root 1.106 $self->{weight_widget}{bg} = $bg;
496 root 1.108 $self->{weight_widget}->set_text (CFPlus::Item::weight_string $self);
497 root 1.62 $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    
505 root 1.1 1;
506    
507     =back
508    
509     =head1 AUTHOR
510    
511     Marc Lehmann <schmorp@schmorp.de>
512     http://home.schmorp.de/
513    
514     =cut
515