deliantra/Deliantra-Client/DC.pm

=head1 NAME

CFPlus - undocumented utility garbage for our crossfire client

=head1 SYNOPSIS

 use CFPlus;

=head1 DESCRIPTION

=over 4

=cut

package CFPlus;

use Carp ();

BEGIN {
   $VERSION = '0.97';

   use XSLoader;
   XSLoader::load "CFPlus", $VERSION;
}

use utf8;

use AnyEvent ();
use BerkeleyDB;
use Pod::POM ();
use Scalar::Util ();
use File::Path ();
use Storable (); # finally

BEGIN {
   use Crossfire::Protocol::Base ();
   *to_json   = \&Crossfire::Protocol::Base::to_json;
   *from_json = \&Crossfire::Protocol::Base::from_json;
}

=item guard { BLOCK }

Returns an object that executes the given block as soon as it is destroyed.

=cut

sub guard(&) {
   bless \(my $cb = $_[0]), "CFPlus::Guard"
}

sub CFPlus::Guard::DESTROY {
   ${$_[0]}->()
}

=item shorten $string[, $maxlength]

=cut

sub shorten($;$) {
   my ($str, $len) = @_;
   substr $str, $len, (length $str), "..." if $len + 3 <= length $str;
   $str
}

sub asxml($) {
   local $_ = $_[0];

   s/&/&amp;/g;
   s/>/&gt;/g;
   s/</&lt;/g;

   $_
}

sub socketpipe() {
   socketpair my $fh1, my $fh2, Socket::AF_UNIX, Socket::SOCK_STREAM, Socket::PF_UNSPEC
      or die "cannot establish bidiretcional pipe: $!\n";

   ($fh1, $fh2)
}

sub background(&;&) {
   my ($bg, $cb) = @_;

   my ($fh_r, $fh_w) = CFPlus::socketpipe;

   my $pid = fork;

   if (defined $pid && !$pid) {
      local $SIG{__DIE__};

      open STDOUT, ">&", $fh_w;
      open STDERR, ">&", $fh_w;
      close $fh_r;
      close $fh_w;

      $| = 1;

      eval { $bg->() };

      if ($@) {
         my $msg = $@;
         $msg =~ s/\n+/\n/;
         warn "FATAL: $msg";
         CFPlus::_exit 1;
      }

      # win32 is fucked up, of course. exit will clean stuff up,
      # which destroys our database etc. _exit will exit ALL
      # forked processes, because of the dreaded fork emulation.
      CFPlus::_exit 0;
   }

   close $fh_w;

   my $buffer;

   my $w; $w = AnyEvent->io (fh => $fh_r, poll => 'r', cb => sub {
      unless (sysread $fh_r, $buffer, 4096, length $buffer) {
         undef $w;
         $cb->();
         return;
      }

      while ($buffer =~ s/^(.*)\n//) {
         my $line = $1;
         $line =~ s/\s+$//;
         utf8::decode $line;
         if ($line =~ /^\x{e877}json_msg (.*)$/s) {
            $cb->(from_json $1);
         } else {
            ::message ({
               markup => "background($pid): " . CFPlus::asxml $line,
            });
         }
      }
   });
}

sub background_msg {
   my ($msg) = @_;

   $msg = "\x{e877}json_msg " . to_json $msg;
   $msg =~ s/\n//g;
   utf8::encode $msg;
   print $msg, "\n";
}

package CFPlus::Database;

our @ISA = BerkeleyDB::Btree::;

sub get($$) {
   my $data;

   $_[0]->db_get ($_[1], $data) == 0
      ? $data
      : ()
}

my %DB_SYNC;

sub put($$$) {
   my ($db, $key, $data) = @_;

   my $hkey = $db + 0;
   Scalar::Util::weaken $db;
   $DB_SYNC{$hkey} ||= AnyEvent->timer (after => 5, cb => sub {
      delete $DB_SYNC{$hkey};
      $db->db_sync if $db;
   });

   $db->db_put ($key => $data)
}

package CFPlus;

sub find_rcfile($) {
   my $path;

   for (grep !ref, @INC) {
      $path = "$_/CFPlus/resources/$_[0]";
      return $path if -r $path;
   }

   die "FATAL: can't find required file $_[0]\n";
}

sub read_cfg {
   my ($file) = @_;

   open my $fh, $file
      or return;

   local $/;
   my $CFG = <$fh>;

   if ($CFG =~ /^---/) { ## TODO compatibility cruft, remove
      require YAML;
      utf8::decode $CFG;
      $::CFG = YAML::Load ($CFG);
   } elsif ($CFG =~ /^\{/) {
      $::CFG = from_json $CFG;
   } else {
      $::CFG = eval $CFG; ## todo comaptibility cruft
   }
}

sub write_cfg {
   my ($file) = @_;

   $::CFG->{VERSION} = $::VERSION;

   open my $fh, ">:utf8", $file
      or return;
   print $fh to_json $::CFG;
}

sub http_proxy {
   my @proxy = win32_proxy_info;

   if (@proxy) {
      "http://" . (@proxy < 2 ? "" : @proxy < 3 ? "$proxy[1]\@" : "$proxy[1]:$proxy[2]\@") . $proxy[0]
   } elsif (exists $ENV{http_proxy}) {
      $ENV{http_proxy}
   } else {
     ()
   }
}

sub set_proxy {
   my $proxy = http_proxy
      or return;

   $ENV{http_proxy} = $proxy;
}

sub lwp_useragent {
   require LWP::UserAgent;
   
   CFPlus::set_proxy;

   my $ua = LWP::UserAgent->new (
      agent      => "cfplus $VERSION",
      keep_alive => 1,
      env_proxy  => 1,
      timeout    => 30,
   );
}

sub lwp_check($) {
   my ($res) = @_;

   $res->is_error
      and die $res->status_line;

   $res
}

our $DB_ENV;
our $DB_STATE;

sub db_table($) {
   my ($table) = @_;

   $table =~ s/([^a-zA-Z0-9_\-])/sprintf "=%x=", ord $1/ge;

   new CFPlus::Database
      -Env      => $DB_ENV,
      -Filename => $table,
#      -Filename => "database",
#      -Subname  => $table,
      -Property => DB_CHKSUM,
      -Flags    => DB_CREATE | DB_UPGRADE,
         or die "unable to create/open database table $_[0]: $BerkeleyDB::Error"
}

our $DB_HOME = "$Crossfire::VARDIR/cfplus";

sub open_db {
   use strict;

   mkdir $DB_HOME, 0777;
   my $recover = $BerkeleyDB::db_version >= 4.4 
                 ? eval "DB_REGISTER | DB_RECOVER"
                 : 0;

   $DB_ENV = new BerkeleyDB::Env
                    -Home => $DB_HOME,
                    -Cachesize => 1_000_000,
                    -ErrFile => "$DB_HOME/errorlog.txt",
#                 -ErrPrefix => "DATABASE",
                    -Verbose => 1,
                    -Flags => DB_CREATE | DB_RECOVER | DB_INIT_MPOOL | DB_INIT_LOCK | DB_INIT_TXN | $recover,
                    -SetFlags => DB_AUTO_COMMIT | DB_LOG_AUTOREMOVE,
                       or die "unable to create/open database home $DB_HOME: $BerkeleyDB::Error";

   $DB_STATE = db_table "state";

   1
}

unless (eval { open_db }) {
   File::Path::rmtree $DB_HOME;
   open_db;
}

package CFPlus::Layout;

$CFPlus::OpenGL::SHUTDOWN_HOOK{"CFPlus::Layout"} = sub {
   reset_glyph_cache;
};

1;

=back

=head1 AUTHOR

 Marc Lehmann <schmorp@schmorp.de>
 http://home.schmorp.de/

=cut

Revision:	1.136
Committed:	Sat Dec 9 02:21:24 2006 UTC (17 years, 5 months ago) by root
Branch:	MAIN
Changes since 1.135:	+0 -214 lines
Log Message:	- slightly cleaned up and "outsourced" components - completely rewrote keybind bindings - not functional yet - buggy a shell - hits perlbug
#	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.135	use File::Path ();
33	root	1.89	use Storable (); # finally
34
35	root	1.127	BEGIN {
36			use Crossfire::Protocol::Base ();
37			*to_json = \&Crossfire::Protocol::Base::to_json;
38			*from_json = \&Crossfire::Protocol::Base::from_json;
39			}
40
41	root	1.103	=item guard { BLOCK }
42
43			Returns an object that executes the given block as soon as it is destroyed.
44
45			=cut
46
47			sub guard(&) {
48	root	1.108	bless \(my $cb = $_[0]), "CFPlus::Guard"
49	root	1.103	}
50
51	root	1.108	sub CFPlus::Guard::DESTROY {
52	root	1.103	${$_[0]}->()
53			}
54
55	root	1.133	=item shorten $string[, $maxlength]
56
57			=cut
58
59			sub shorten($;$) {
60			my ($str, $len) = @_;
61			substr $str, $len, (length $str), "..." if $len + 3 <= length $str;
62			$str
63			}
64
65	root	1.105	sub asxml($) {
66			local $_ = $_[0];
67	root	1.89
68	root	1.105	s/&/&/g;
69			s/>/>/g;
70			s/</</g;
71	root	1.89
72	root	1.105	$_
73	root	1.89	}
74
75	root	1.123	sub socketpipe() {
76			socketpair my $fh1, my $fh2, Socket::AF_UNIX, Socket::SOCK_STREAM, Socket::PF_UNSPEC
77			or die "cannot establish bidiretcional pipe: $!\n";
78
79			($fh1, $fh2)
80			}
81
82	root	1.127	sub background(&;&) {
83			my ($bg, $cb) = @_;
84	root	1.123
85			my ($fh_r, $fh_w) = CFPlus::socketpipe;
86
87			my $pid = fork;
88
89			if (defined $pid && !$pid) {
90	root	1.124	local $SIG{__DIE__};
91	root	1.123
92			open STDOUT, ">&", $fh_w;
93			open STDERR, ">&", $fh_w;
94			close $fh_r;
95			close $fh_w;
96
97			$\| = 1;
98
99	root	1.127	eval { $bg->() };
100	root	1.124
101			if ($@) {
102			my $msg = $@;
103			$msg =~ s/\n+/\n/;
104			warn "FATAL: $msg";
105			CFPlus::_exit 1;
106			}
107	root	1.123
108			# win32 is fucked up, of course. exit will clean stuff up,
109			# which destroys our database etc. _exit will exit ALL
110			# forked processes, because of the dreaded fork emulation.
111	root	1.124	CFPlus::_exit 0;
112	root	1.123	}
113
114			close $fh_w;
115
116			my $buffer;
117
118	root	1.126	my $w; $w = AnyEvent->io (fh => $fh_r, poll => 'r', cb => sub {
119	root	1.123	unless (sysread $fh_r, $buffer, 4096, length $buffer) {
120	root	1.126	undef $w;
121	root	1.127	$cb->();
122			return;
123	root	1.123	}
124
125			while ($buffer =~ s/^(.*)\n//) {
126			my $line = $1;
127	root	1.124	$line =~ s/\s+$//;
128	root	1.123	utf8::decode $line;
129	root	1.127	if ($line =~ /^\x{e877}json_msg (.*)$/s) {
130			$cb->(from_json $1);
131			} else {
132			::message ({
133			markup => "background($pid): " . CFPlus::asxml $line,
134			});
135			}
136	root	1.123	}
137			});
138			}
139
140	root	1.127	sub background_msg {
141			my ($msg) = @_;
142
143			$msg = "\x{e877}json_msg " . to_json $msg;
144			$msg =~ s/\n//g;
145			utf8::encode $msg;
146			print $msg, "\n";
147			}
148
149	root	1.108	package CFPlus::Database;
150	root	1.89
151			our @ISA = BerkeleyDB::Btree::;
152
153			sub get($$) {
154			my $data;
155
156			$_[0]->db_get ($_[1], $data) == 0
157			? $data
158			: ()
159			}
160
161			my %DB_SYNC;
162
163			sub put($$$) {
164			my ($db, $key, $data) = @_;
165
166	root	1.117	my $hkey = $db + 0;
167	root	1.116	Scalar::Util::weaken $db;
168	root	1.117	$DB_SYNC{$hkey} \|\|= AnyEvent->timer (after => 5, cb => sub {
169			delete $DB_SYNC{$hkey};
170	root	1.116	$db->db_sync if $db;
171			});
172	root	1.89
173			$db->db_put ($key => $data)
174			}
175
176	root	1.108	package CFPlus;
177	root	1.52
178	root	1.5	sub find_rcfile($) {
179			my $path;
180
181	root	1.46	for (grep !ref, @INC) {
182	root	1.108	$path = "$_/CFPlus/resources/$_[0]";
183	root	1.5	return $path if -r $path;
184			}
185
186			die "FATAL: can't find required file $_[0]\n";
187			}
188
189			sub read_cfg {
190			my ($file) = @_;
191
192	root	1.107	open my $fh, $file
193	root	1.5	or return;
194
195			local $/;
196	root	1.107	my $CFG = <$fh>;
197	root	1.5
198	root	1.108	if ($CFG =~ /^---/) { ## TODO compatibility cruft, remove
199			require YAML;
200			utf8::decode $CFG;
201			$::CFG = YAML::Load ($CFG);
202			} elsif ($CFG =~ /^\{/) {
203			$::CFG = from_json $CFG;
204	root	1.107	} else {
205	root	1.108	$::CFG = eval $CFG; ## todo comaptibility cruft
206	root	1.107	}
207	root	1.5	}
208
209			sub write_cfg {
210			my ($file) = @_;
211
212	root	1.107	$::CFG->{VERSION} = $::VERSION;
213
214			open my $fh, ">:utf8", $file
215	root	1.5	or return;
216	root	1.108	print $fh to_json $::CFG;
217	root	1.5	}
218
219	root	1.122	sub http_proxy {
220			my @proxy = win32_proxy_info;
221
222			if (@proxy) {
223			"http://" . (@proxy < 2 ? "" : @proxy < 3 ? "$proxy[1]\@" : "$proxy[1]:$proxy[2]\@") . $proxy[0]
224			} elsif (exists $ENV{http_proxy}) {
225			$ENV{http_proxy}
226			} else {
227			()
228			}
229			}
230
231			sub set_proxy {
232			my $proxy = http_proxy
233			or return;
234
235			$ENV{http_proxy} = $proxy;
236			}
237
238	root	1.127	sub lwp_useragent {
239			require LWP::UserAgent;
240
241			CFPlus::set_proxy;
242
243			my $ua = LWP::UserAgent->new (
244			agent => "cfplus $VERSION",
245			keep_alive => 1,
246			env_proxy => 1,
247			timeout => 30,
248			);
249			}
250
251			sub lwp_check($) {
252			my ($res) = @_;
253
254			$res->is_error
255			and die $res->status_line;
256
257			$res
258			}
259
260	root	1.77	our $DB_ENV;
261	root	1.121	our $DB_STATE;
262
263			sub db_table($) {
264			my ($table) = @_;
265
266			$table =~ s/([^a-zA-Z0-9_\-])/sprintf "=%x=", ord $1/ge;
267
268			new CFPlus::Database
269			-Env => $DB_ENV,
270			-Filename => $table,
271			# -Filename => "database",
272			# -Subname => $table,
273			-Property => DB_CHKSUM,
274			-Flags => DB_CREATE \| DB_UPGRADE,
275			or die "unable to create/open database table $_[0]: $BerkeleyDB::Error"
276			}
277	root	1.77
278	root	1.135	our $DB_HOME = "$Crossfire::VARDIR/cfplus";
279
280			sub open_db {
281	root	1.76	use strict;
282
283	root	1.135	mkdir $DB_HOME, 0777;
284	root	1.77	my $recover = $BerkeleyDB::db_version >= 4.4
285			? eval "DB_REGISTER \| DB_RECOVER"
286			: 0;
287
288			$DB_ENV = new BerkeleyDB::Env
289	root	1.135	-Home => $DB_HOME,
290	root	1.76	-Cachesize => 1_000_000,
291	root	1.135	-ErrFile => "$DB_HOME/errorlog.txt",
292	root	1.39	# -ErrPrefix => "DATABASE",
293	root	1.76	-Verbose => 1,
294	root	1.77	-Flags => DB_CREATE \| DB_RECOVER \| DB_INIT_MPOOL \| DB_INIT_LOCK \| DB_INIT_TXN \| $recover,
295	root	1.78	-SetFlags => DB_AUTO_COMMIT \| DB_LOG_AUTOREMOVE,
296	root	1.135	or die "unable to create/open database home $DB_HOME: $BerkeleyDB::Error";
297	root	1.76
298	root	1.121	$DB_STATE = db_table "state";
299	root	1.135
300			1
301			}
302
303			unless (eval { open_db }) {
304			File::Path::rmtree $DB_HOME;
305			open_db;
306	root	1.34	}
307
308	root	1.108	package CFPlus::Layout;
309	root	1.97
310	root	1.108	$CFPlus::OpenGL::SHUTDOWN_HOOK{"CFPlus::Layout"} = sub {
311	root	1.98	reset_glyph_cache;
312	root	1.97	};
313
314	root	1.1	1;
315
316			=back
317
318			=head1 AUTHOR
319
320			Marc Lehmann <schmorp@schmorp.de>
321			http://home.schmorp.de/
322
323			=cut
324