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 Pod::POM ();
use File::Path ();
use Storable (); # finally
use Fcntl ();

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 bidirectional 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->(JSON::XS->new->allow_nonref->decode ($1));
         } else {
            ::message ({
               markup => "background($pid): " . CFPlus::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 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
}

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

   if ($^O =~ /Win32/) {
      $nb = ! ! $nb;
      ioctl $fh, 0x8004667e, $nb; # FIONBIO
   } else {
      fcntl $fh, &Fcntl::F_SETFL, $nb ? &Fcntl::O_NONBLOCK : 0;
   }

}

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.141
Committed:	Fri Apr 6 21:53:56 2007 UTC (17 years, 1 month ago) by root
Branch:	MAIN
Changes since 1.140:	+13 -0 lines
Log Message:	windows needs it extra-hard
#	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.89	use Pod::POM ();
30	root	1.135	use File::Path ();
31	root	1.89	use Storable (); # finally
32	root	1.141	use Fcntl ();
33	root	1.89
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.133	=item shorten $string[, $maxlength]
55
56			=cut
57
58			sub shorten($;$) {
59			my ($str, $len) = @_;
60			substr $str, $len, (length $str), "..." if $len + 3 <= length $str;
61			$str
62			}
63
64	root	1.105	sub asxml($) {
65			local $_ = $_[0];
66	root	1.89
67	root	1.105	s/&/&/g;
68			s/>/>/g;
69			s/</</g;
70	root	1.89
71	root	1.105	$_
72	root	1.89	}
73
74	root	1.123	sub socketpipe() {
75			socketpair my $fh1, my $fh2, Socket::AF_UNIX, Socket::SOCK_STREAM, Socket::PF_UNSPEC
76	root	1.140	or die "cannot establish bidirectional pipe: $!\n";
77	root	1.123
78			($fh1, $fh2)
79			}
80
81	root	1.127	sub background(&;&) {
82			my ($bg, $cb) = @_;
83	root	1.123
84			my ($fh_r, $fh_w) = CFPlus::socketpipe;
85
86			my $pid = fork;
87
88			if (defined $pid && !$pid) {
89	root	1.124	local $SIG{__DIE__};
90	root	1.123
91			open STDOUT, ">&", $fh_w;
92			open STDERR, ">&", $fh_w;
93			close $fh_r;
94			close $fh_w;
95
96			$\| = 1;
97
98	root	1.127	eval { $bg->() };
99	root	1.124
100			if ($@) {
101			my $msg = $@;
102			$msg =~ s/\n+/\n/;
103			warn "FATAL: $msg";
104			CFPlus::_exit 1;
105			}
106	root	1.123
107			# win32 is fucked up, of course. exit will clean stuff up,
108			# which destroys our database etc. _exit will exit ALL
109			# forked processes, because of the dreaded fork emulation.
110	root	1.124	CFPlus::_exit 0;
111	root	1.123	}
112
113			close $fh_w;
114
115			my $buffer;
116
117	root	1.126	my $w; $w = AnyEvent->io (fh => $fh_r, poll => 'r', cb => sub {
118	root	1.123	unless (sysread $fh_r, $buffer, 4096, length $buffer) {
119	root	1.126	undef $w;
120	root	1.127	$cb->();
121			return;
122	root	1.123	}
123
124			while ($buffer =~ s/^(.*)\n//) {
125			my $line = $1;
126	root	1.124	$line =~ s/\s+$//;
127	root	1.123	utf8::decode $line;
128	root	1.127	if ($line =~ /^\x{e877}json_msg (.*)$/s) {
129	root	1.139	$cb->(JSON::XS->new->allow_nonref->decode ($1));
130	root	1.127	} else {
131			::message ({
132			markup => "background($pid): " . CFPlus::asxml $line,
133			});
134			}
135	root	1.123	}
136			});
137			}
138
139	root	1.127	sub background_msg {
140			my ($msg) = @_;
141
142	root	1.139	$msg = "\x{e877}json_msg " . JSON::XS->new->allow_nonref->encode ($msg);
143	root	1.127	$msg =~ s/\n//g;
144			utf8::encode $msg;
145			print $msg, "\n";
146			}
147
148	root	1.108	package CFPlus;
149	root	1.52
150	root	1.5	sub find_rcfile($) {
151			my $path;
152
153	root	1.46	for (grep !ref, @INC) {
154	root	1.108	$path = "$_/CFPlus/resources/$_[0]";
155	root	1.5	return $path if -r $path;
156			}
157
158			die "FATAL: can't find required file $_[0]\n";
159			}
160
161			sub read_cfg {
162			my ($file) = @_;
163
164	root	1.107	open my $fh, $file
165	root	1.5	or return;
166
167			local $/;
168	root	1.107	my $CFG = <$fh>;
169	root	1.5
170	root	1.108	if ($CFG =~ /^---/) { ## TODO compatibility cruft, remove
171			require YAML;
172			utf8::decode $CFG;
173			$::CFG = YAML::Load ($CFG);
174			} elsif ($CFG =~ /^\{/) {
175			$::CFG = from_json $CFG;
176	root	1.107	} else {
177	root	1.108	$::CFG = eval $CFG; ## todo comaptibility cruft
178	root	1.107	}
179	root	1.5	}
180
181			sub write_cfg {
182			my ($file) = @_;
183
184	root	1.107	$::CFG->{VERSION} = $::VERSION;
185
186			open my $fh, ">:utf8", $file
187	root	1.5	or return;
188	root	1.108	print $fh to_json $::CFG;
189	root	1.5	}
190
191	root	1.122	sub http_proxy {
192			my @proxy = win32_proxy_info;
193
194			if (@proxy) {
195			"http://" . (@proxy < 2 ? "" : @proxy < 3 ? "$proxy[1]\@" : "$proxy[1]:$proxy[2]\@") . $proxy[0]
196			} elsif (exists $ENV{http_proxy}) {
197			$ENV{http_proxy}
198			} else {
199			()
200			}
201			}
202
203			sub set_proxy {
204			my $proxy = http_proxy
205			or return;
206
207			$ENV{http_proxy} = $proxy;
208			}
209
210	root	1.127	sub lwp_useragent {
211			require LWP::UserAgent;
212
213			CFPlus::set_proxy;
214
215			my $ua = LWP::UserAgent->new (
216			agent => "cfplus $VERSION",
217			keep_alive => 1,
218			env_proxy => 1,
219			timeout => 30,
220			);
221			}
222
223			sub lwp_check($) {
224			my ($res) = @_;
225
226			$res->is_error
227			and die $res->status_line;
228
229			$res
230			}
231
232	root	1.141	sub fh_nonblocking($$) {
233			my ($fh, $nb) = @_;
234
235			if ($^O =~ /Win32/) {
236			$nb = ! ! $nb;
237			ioctl $fh, 0x8004667e, $nb; # FIONBIO
238			} else {
239			fcntl $fh, &Fcntl::F_SETFL, $nb ? &Fcntl::O_NONBLOCK : 0;
240			}
241
242			}
243
244	root	1.108	package CFPlus::Layout;
245	root	1.97
246	root	1.108	$CFPlus::OpenGL::SHUTDOWN_HOOK{"CFPlus::Layout"} = sub {
247	root	1.98	reset_glyph_cache;
248	root	1.97	};
249
250	root	1.1	1;
251
252			=back
253
254			=head1 AUTHOR
255
256			Marc Lehmann <schmorp@schmorp.de>
257			http://home.schmorp.de/
258
259			=cut
260