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

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines