deliantra/Deliantra-Client/DC.pm

=head1 NAME

DC - undocumented utility garbage for our deliantra client

=head1 SYNOPSIS

 use DC;

=head1 DESCRIPTION

=over 4

=cut

package Deliantra::Client; # work around CPAN breakage
package App::Deliantra; # try to reserve namespace
package DC;

use Carp ();

BEGIN {
   $VERSION = '0.9973';

   use XSLoader;
   XSLoader::load "Deliantra::Client", $VERSION;
}

use utf8;

use AnyEvent ();
use Pod::POM ();
use File::Path ();
use Storable (); # finally
use Fcntl ();
use JSON::XS qw(encode_json decode_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]), "DC::Guard"
}

sub DC::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 bidirectional pipe: $!\n";

   ($fh1, $fh2)
}

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

   my ($fh_r, $fh_w) = DC::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";
         DC::_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.
      DC::_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->(JSON::XS->new->allow_nonref->decode ($1));
         } else {
            ::message ({
               markup => "background($pid): " . DC::asxml $line,
            });
         }
      }
   });
}

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

   $msg = "\x{e877}json_msg " . JSON::XS->new->allow_nonref->encode ($msg);
   $msg =~ s/\n//g;
   utf8::encode $msg;
   print $msg, "\n";
}

package DC;

sub find_rcfile($) {
   my $path;

   for (grep !ref, @INC) {
      $path = "$_/Deliantra/Client/private/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>;

   $::CFG = decode_json $CFG;
}

sub write_cfg {
   my $file = "$Deliantra::VARDIR/client.cf";

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

   open my $fh, ">:utf8", $file
      or return;
   print $fh JSON::XS->new->utf8->pretty->encode ($::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;
   
   DC::set_proxy;

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

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

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

   $res
}

sub fh_nonblocking($$) {
   my ($fh, $nb) = @_;

   if ($^O eq "MSWin32") {
      $nb = (! ! $nb) + 0;
      ioctl $fh, 0x8004667e, \$nb; # FIONBIO
   } else {
      fcntl $fh, &Fcntl::F_SETFL, $nb ? &Fcntl::O_NONBLOCK : 0;
   }
}

package DC::Layout;

$DC::OpenGL::INIT_HOOK{"DC::Layout"} = sub {
   glyph_cache_restore;
};

$DC::OpenGL::SHUTDOWN_HOOK{"DC::Layout"} = sub {
   glyph_cache_backup;
};

1;

=back

=head1 AUTHOR

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

=cut

Revision:	1.184
Committed:	Mon Jul 7 12:56:07 2008 UTC (15 years, 10 months ago) by root
Branch:	MAIN
Changes since 1.183:	+2 -0 lines
Log Message:	* empty log message *
#	User	Rev	Content
1	root	1.1	=head1 NAME
2
3	root	1.169	DC - undocumented utility garbage for our deliantra client
4	root	1.1
5			=head1 SYNOPSIS
6
7	root	1.169	use DC;
8	root	1.1
9			=head1 DESCRIPTION
10
11			=over 4
12
13			=cut
14
15	root	1.184	package Deliantra::Client; # work around CPAN breakage
16			package App::Deliantra; # try to reserve namespace
17	root	1.169	package DC;
18	root	1.1
19	root	1.121	use Carp ();
20
21	root	1.1	BEGIN {
22	root	1.183	$VERSION = '0.9973';
23	root	1.1
24	root	1.2	use XSLoader;
25	root	1.168	XSLoader::load "Deliantra::Client", $VERSION;
26	root	1.1	}
27
28	root	1.62	use utf8;
29
30	root	1.52	use AnyEvent ();
31	root	1.89	use Pod::POM ();
32	root	1.135	use File::Path ();
33	root	1.89	use Storable (); # finally
34	root	1.141	use Fcntl ();
35	root	1.159	use JSON::XS qw(encode_json decode_json);
36	root	1.127
37	root	1.103	=item guard { BLOCK }
38
39			Returns an object that executes the given block as soon as it is destroyed.
40
41			=cut
42
43			sub guard(&) {
44	root	1.169	bless \(my $cb = $_[0]), "DC::Guard"
45	root	1.103	}
46
47	root	1.169	sub DC::Guard::DESTROY {
48	root	1.103	${$_[0]}->()
49			}
50
51	root	1.133	=item shorten $string[, $maxlength]
52
53			=cut
54
55			sub shorten($;$) {
56			my ($str, $len) = @_;
57			substr $str, $len, (length $str), "..." if $len + 3 <= length $str;
58			$str
59			}
60
61	root	1.105	sub asxml($) {
62			local $_ = $_[0];
63	root	1.89
64	root	1.105	s/&/&/g;
65			s/>/>/g;
66			s/</</g;
67	root	1.89
68	root	1.105	$_
69	root	1.89	}
70
71	root	1.123	sub socketpipe() {
72			socketpair my $fh1, my $fh2, Socket::AF_UNIX, Socket::SOCK_STREAM, Socket::PF_UNSPEC
73	root	1.140	or die "cannot establish bidirectional pipe: $!\n";
74	root	1.123
75			($fh1, $fh2)
76			}
77
78	root	1.127	sub background(&;&) {
79			my ($bg, $cb) = @_;
80	root	1.123
81	root	1.169	my ($fh_r, $fh_w) = DC::socketpipe;
82	root	1.123
83			my $pid = fork;
84
85			if (defined $pid && !$pid) {
86	root	1.124	local $SIG{__DIE__};
87	root	1.123
88			open STDOUT, ">&", $fh_w;
89			open STDERR, ">&", $fh_w;
90			close $fh_r;
91			close $fh_w;
92
93			$\| = 1;
94
95	root	1.127	eval { $bg->() };
96	root	1.124
97			if ($@) {
98			my $msg = $@;
99			$msg =~ s/\n+/\n/;
100			warn "FATAL: $msg";
101	root	1.169	DC::_exit 1;
102	root	1.124	}
103	root	1.123
104			# win32 is fucked up, of course. exit will clean stuff up,
105			# which destroys our database etc. _exit will exit ALL
106			# forked processes, because of the dreaded fork emulation.
107	root	1.169	DC::_exit 0;
108	root	1.123	}
109
110			close $fh_w;
111
112			my $buffer;
113
114	root	1.126	my $w; $w = AnyEvent->io (fh => $fh_r, poll => 'r', cb => sub {
115	root	1.123	unless (sysread $fh_r, $buffer, 4096, length $buffer) {
116	root	1.126	undef $w;
117	root	1.127	$cb->();
118			return;
119	root	1.123	}
120
121			while ($buffer =~ s/^(.*)\n//) {
122			my $line = $1;
123	root	1.124	$line =~ s/\s+$//;
124	root	1.123	utf8::decode $line;
125	root	1.127	if ($line =~ /^\x{e877}json_msg (.*)$/s) {
126	root	1.139	$cb->(JSON::XS->new->allow_nonref->decode ($1));
127	root	1.127	} else {
128			::message ({
129	root	1.169	markup => "background($pid): " . DC::asxml $line,
130	root	1.127	});
131			}
132	root	1.123	}
133			});
134			}
135
136	root	1.127	sub background_msg {
137			my ($msg) = @_;
138
139	root	1.139	$msg = "\x{e877}json_msg " . JSON::XS->new->allow_nonref->encode ($msg);
140	root	1.127	$msg =~ s/\n//g;
141			utf8::encode $msg;
142			print $msg, "\n";
143			}
144
145	root	1.169	package DC;
146	root	1.52
147	root	1.5	sub find_rcfile($) {
148			my $path;
149
150	root	1.46	for (grep !ref, @INC) {
151	root	1.168	$path = "$_/Deliantra/Client/private/resources/$_[0]";
152	root	1.5	return $path if -r $path;
153			}
154
155			die "FATAL: can't find required file $_[0]\n";
156			}
157
158			sub read_cfg {
159			my ($file) = @_;
160
161	root	1.107	open my $fh, $file
162	root	1.5	or return;
163
164			local $/;
165	root	1.107	my $CFG = <$fh>;
166	root	1.5
167	root	1.166	$::CFG = decode_json $CFG;
168	root	1.5	}
169
170			sub write_cfg {
171	root	1.178	my $file = "$Deliantra::VARDIR/client.cf";
172	root	1.5
173	root	1.107	$::CFG->{VERSION} = $::VERSION;
174
175			open my $fh, ">:utf8", $file
176	root	1.5	or return;
177	root	1.180	print $fh JSON::XS->new->utf8->pretty->encode ($::CFG);
178	root	1.5	}
179
180	root	1.122	sub http_proxy {
181			my @proxy = win32_proxy_info;
182
183			if (@proxy) {
184			"http://" . (@proxy < 2 ? "" : @proxy < 3 ? "$proxy[1]\@" : "$proxy[1]:$proxy[2]\@") . $proxy[0]
185			} elsif (exists $ENV{http_proxy}) {
186			$ENV{http_proxy}
187			} else {
188			()
189			}
190			}
191
192			sub set_proxy {
193			my $proxy = http_proxy
194			or return;
195
196			$ENV{http_proxy} = $proxy;
197			}
198
199	root	1.127	sub lwp_useragent {
200			require LWP::UserAgent;
201
202	root	1.169	DC::set_proxy;
203	root	1.127
204			my $ua = LWP::UserAgent->new (
205	root	1.171	agent => "deliantra $VERSION",
206	root	1.127	keep_alive => 1,
207			env_proxy => 1,
208			timeout => 30,
209			);
210			}
211
212			sub lwp_check($) {
213			my ($res) = @_;
214
215			$res->is_error
216			and die $res->status_line;
217
218			$res
219			}
220
221	root	1.141	sub fh_nonblocking($$) {
222			my ($fh, $nb) = @_;
223
224	root	1.142	if ($^O eq "MSWin32") {
225			$nb = (! ! $nb) + 0;
226	root	1.143	ioctl $fh, 0x8004667e, \$nb; # FIONBIO
227	root	1.141	} else {
228			fcntl $fh, &Fcntl::F_SETFL, $nb ? &Fcntl::O_NONBLOCK : 0;
229			}
230			}
231
232	root	1.169	package DC::Layout;
233	root	1.97
234	root	1.169	$DC::OpenGL::INIT_HOOK{"DC::Layout"} = sub {
235	root	1.164	glyph_cache_restore;
236			};
237
238	root	1.169	$DC::OpenGL::SHUTDOWN_HOOK{"DC::Layout"} = sub {
239	root	1.164	glyph_cache_backup;
240	root	1.97	};
241
242	root	1.1	1;
243
244			=back
245
246			=head1 AUTHOR
247
248			Marc Lehmann <schmorp@schmorp.de>
249			http://home.schmorp.de/
250
251			=cut
252