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 DC;

use Carp ();

our $VERSION;

BEGIN {
   $VERSION = '3.0';

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

use utf8;
use strict qw(vars subs);

use Socket ();
use AnyEvent ();
use AnyEvent::Util ();
use Pod::POM ();
use File::Path ();
use Storable (); # finally
use Fcntl ();
use JSON::XS qw(encode_json decode_json);
use Guard qw(guard);

# modules to support other DC::* packages
use List::Util ();
use IO::AIO ();
use Coro::AIO ();
use AnyEvent::AIO ();

use Deliantra::Util ();
use Deliantra::Protocol::Constants ();

=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 background(&;&) {
   my ($bg, $cb) = @_;

   my ($fh_r, $fh_w) = AnyEvent::Util::portable_socketpair
     or die "unable to create background socketpair: $!";

   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;

our $RC_THEME;
our %THEME;
our @RC_PATH;
our $RC_BASE;

for (grep !ref, @INC) {
   $RC_BASE = "$_/Deliantra/Client/private/resources";
   last if -d $RC_BASE;
}

sub find_rcfile($) {
   my $path;

   for (@RC_PATH, "") {
      $path = "$RC_BASE/$_/$_[0]";
      return $path if -e $path;
   }

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

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

   open my $fh, $file
      or return;

   local $/;
   eval { JSON::XS->new->utf8->relaxed->decode (<$fh>) }
}

sub set_theme($) {
   return if $RC_THEME eq $_[0];
   $RC_THEME = $_[0];

   # kind of hacky, find the main theme file, then load all theme files and merge them

   %THEME = ();
   @RC_PATH = "theme-$RC_THEME";

   my $theme = load_json find_rcfile "theme.json"
      or die "FATAL: theme resource file not found";

   @RC_PATH = @{ $theme->{path} } if $theme->{path};

   for (@RC_PATH, "") {
      my $theme = load_json "$RC_BASE/$_/theme.json"
         or next;

      %THEME = ( %$theme, %THEME );
   }
}

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

   $::CFG = (load_json $file) || (load_json "$file.bak");
}

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

   $::CFG->{VERSION} = $::VERSION;
   $::CFG->{layout}  = DC::UI::get_layout ();

   open my $fh, ">:utf8", "$file~"
      or return;
   print $fh JSON::XS->new->utf8->pretty->encode ($::CFG);
   close $fh;

   rename $file, "$file.bak";
   rename "$file~", $file;
}

sub load_cfg() {
   if (-e "$Deliantra::VARDIR/client.cf") {
      DC::read_cfg "$Deliantra::VARDIR/client.cf";
   } else {
      $::CFG = { cfg_schema => 1, db_schema => 1 };
   }
}

sub save_cfg() {
   write_cfg "$Deliantra::VARDIR/client.cf";
}

sub upgrade_cfg() {
   my %DEF_CFG = (
      config_autosave     => 1,
      sdl_mode            => undef,
      fullscreen          => 1,
      fast                => 0,
      force_opengl11      => undef,
      disable_alpha       => 0,
      smooth_movement     => 1,
      smooth_transitions  => 1,
      texture_compression => 1,
      map_scale           => 1,
      fow_enable          => 1,
      fow_intensity       => 0,
      fow_texture         => 0,
      map_smoothing       => 1,
      gui_fontsize        => 1,
      log_fontsize        => 0.7,
      gauge_fontsize      => 1,
      gauge_size          => 0.35,
      stat_fontsize       => 0.7,
      mapsize             => 100,
      audio_enable        => 1,
      audio_hw_channels   => 0,
      audio_hw_frequency  => 0,
      audio_hw_chunksize  => 0,
      audio_mix_channels  => 8,
      effects_enable      => 1,
      effects_volume      => 1,
      bgm_enable          => 1,
      bgm_volume          => 0.5,
      output_rate         => "",
      pickup              => Deliantra::Protocol::Constants::PICKUP_SPELLBOOK
                           | Deliantra::Protocol::Constants::PICKUP_SKILLSCROLL
                           | Deliantra::Protocol::Constants::PICKUP_VALUABLES,
      inv_sort            => "mtime",
      default             => "profile", # default profile
      show_tips           => 1,
      logview_max_par     => 1000,
      shift_fire_stop     => 0,
      uitheme             => "wood",
      map_shift_x         => -24, # arbitrary
      map_shift_y         => +24, # arbitrary
   );

   while (my ($k, $v) = each %DEF_CFG) {
      $::CFG->{$k} = $v unless exists $::CFG->{$k};
   }

   if ($::CFG->{cfg_schema} < 1) {
      for my $profile (values %{ $::CFG->{profile} }) {
         $profile->{password} = unpack "H*", Deliantra::Util::hash_pw $profile->{password};
      }
      $::CFG->{cfg_schema} = 1;
   }
}

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.216
Committed:	Sat Nov 17 10:40:08 2012 UTC (11 years, 5 months ago) by root
Branch:	MAIN
Changes since 1.215:	+9 -2 lines
Log Message:	* empty log message *
#	Content
1	=head1 NAME
2
3	DC - undocumented utility garbage for our deliantra client
4
5	=head1 SYNOPSIS
6
7	use DC;
8
9	=head1 DESCRIPTION
10
11	=over 4
12
13	=cut
14
15	package DC;
16
17	use Carp ();
18
19	our $VERSION;
20
21	BEGIN {
22	$VERSION = '3.0';
23
24	use XSLoader;
25	XSLoader::load "Deliantra::Client", $VERSION;
26	}
27
28	use utf8;
29	use strict qw(vars subs);
30
31	use Socket ();
32	use AnyEvent ();
33	use AnyEvent::Util ();
34	use Pod::POM ();
35	use File::Path ();
36	use Storable (); # finally
37	use Fcntl ();
38	use JSON::XS qw(encode_json decode_json);
39	use Guard qw(guard);
40
41	# modules to support other DC::* packages
42	use List::Util ();
43	use IO::AIO ();
44	use Coro::AIO ();
45	use AnyEvent::AIO ();
46
47	use Deliantra::Util ();
48	use Deliantra::Protocol::Constants ();
49
50	=item shorten $string[, $maxlength]
51
52	=cut
53
54	sub shorten($;$) {
55	my ($str, $len) = @_;
56	substr $str, $len, (length $str), "..." if $len + 3 <= length $str;
57	$str
58	}
59
60	sub asxml($) {
61	local $_ = $_[0];
62
63	s/&/&/g;
64	s/>/>/g;
65	s/</</g;
66
67	$_
68	}
69
70	sub background(&;&) {
71	my ($bg, $cb) = @_;
72
73	my ($fh_r, $fh_w) = AnyEvent::Util::portable_socketpair
74	or die "unable to create background socketpair: $!";
75
76	my $pid = fork;
77
78	if (defined $pid && !$pid) {
79	local $SIG{__DIE__};
80
81	open STDOUT, ">&", $fh_w;
82	open STDERR, ">&", $fh_w;
83	close $fh_r;
84	close $fh_w;
85
86	$\| = 1;
87
88	eval { $bg->() };
89
90	if ($@) {
91	my $msg = $@;
92	$msg =~ s/\n+/\n/;
93	warn "FATAL: $msg";
94	DC::_exit 1;
95	}
96
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	DC::_exit 0;
101	}
102
103	close $fh_w;
104
105	my $buffer;
106
107	my $w; $w = AnyEvent->io (fh => $fh_r, poll => 'r', cb => sub {
108	unless (sysread $fh_r, $buffer, 4096, length $buffer) {
109	undef $w;
110	$cb->();
111	return;
112	}
113
114	while ($buffer =~ s/^(.*)\n//) {
115	my $line = $1;
116	$line =~ s/\s+$//;
117	utf8::decode $line;
118	if ($line =~ /^\x{e877}json_msg (.*)$/s) {
119	$cb->(JSON::XS->new->allow_nonref->decode ($1));
120	} else {
121	::message ({
122	markup => "background($pid): " . DC::asxml $line,
123	});
124	}
125	}
126	});
127	}
128
129	sub background_msg {
130	my ($msg) = @_;
131
132	$msg = "\x{e877}json_msg " . JSON::XS->new->allow_nonref->encode ($msg);
133	$msg =~ s/\n//g;
134	utf8::encode $msg;
135	print $msg, "\n";
136	}
137
138	package DC;
139
140	our $RC_THEME;
141	our %THEME;
142	our @RC_PATH;
143	our $RC_BASE;
144
145	for (grep !ref, @INC) {
146	$RC_BASE = "$_/Deliantra/Client/private/resources";
147	last if -d $RC_BASE;
148	}
149
150	sub find_rcfile($) {
151	my $path;
152
153	for (@RC_PATH, "") {
154	$path = "$RC_BASE/$_/$_[0]";
155	return $path if -e $path;
156	}
157
158	die "FATAL: can't find required file \"$_[0]\" in \"$RC_BASE\"\n";
159	}
160
161	sub load_json($) {
162	my ($file) = @_;
163
164	open my $fh, $file
165	or return;
166
167	local $/;
168	eval { JSON::XS->new->utf8->relaxed->decode (<$fh>) }
169	}
170
171	sub set_theme($) {
172	return if $RC_THEME eq $_[0];
173	$RC_THEME = $_[0];
174
175	# kind of hacky, find the main theme file, then load all theme files and merge them
176
177	%THEME = ();
178	@RC_PATH = "theme-$RC_THEME";
179
180	my $theme = load_json find_rcfile "theme.json"
181	or die "FATAL: theme resource file not found";
182
183	@RC_PATH = @{ $theme->{path} } if $theme->{path};
184
185	for (@RC_PATH, "") {
186	my $theme = load_json "$RC_BASE/$_/theme.json"
187	or next;
188
189	%THEME = ( %$theme, %THEME );
190	}
191	}
192
193	sub read_cfg($) {
194	my ($file) = @_;
195
196	$::CFG = (load_json $file) \|\| (load_json "$file.bak");
197	}
198
199	sub write_cfg($) {
200	my $file = "$Deliantra::VARDIR/client.cf";
201
202	$::CFG->{VERSION} = $::VERSION;
203	$::CFG->{layout} = DC::UI::get_layout ();
204
205	open my $fh, ">:utf8", "$file~"
206	or return;
207	print $fh JSON::XS->new->utf8->pretty->encode ($::CFG);
208	close $fh;
209
210	rename $file, "$file.bak";
211	rename "$file~", $file;
212	}
213
214	sub load_cfg() {
215	if (-e "$Deliantra::VARDIR/client.cf") {
216	DC::read_cfg "$Deliantra::VARDIR/client.cf";
217	} else {
218	$::CFG = { cfg_schema => 1, db_schema => 1 };
219	}
220	}
221
222	sub save_cfg() {
223	write_cfg "$Deliantra::VARDIR/client.cf";
224	}
225
226	sub upgrade_cfg() {
227	my %DEF_CFG = (
228	config_autosave => 1,
229	sdl_mode => undef,
230	fullscreen => 1,
231	fast => 0,
232	force_opengl11 => undef,
233	disable_alpha => 0,
234	smooth_movement => 1,
235	smooth_transitions => 1,
236	texture_compression => 1,
237	map_scale => 1,
238	fow_enable => 1,
239	fow_intensity => 0,
240	fow_texture => 0,
241	map_smoothing => 1,
242	gui_fontsize => 1,
243	log_fontsize => 0.7,
244	gauge_fontsize => 1,
245	gauge_size => 0.35,
246	stat_fontsize => 0.7,
247	mapsize => 100,
248	audio_enable => 1,
249	audio_hw_channels => 0,
250	audio_hw_frequency => 0,
251	audio_hw_chunksize => 0,
252	audio_mix_channels => 8,
253	effects_enable => 1,
254	effects_volume => 1,
255	bgm_enable => 1,
256	bgm_volume => 0.5,
257	output_rate => "",
258	pickup => Deliantra::Protocol::Constants::PICKUP_SPELLBOOK
259	\| Deliantra::Protocol::Constants::PICKUP_SKILLSCROLL
260	\| Deliantra::Protocol::Constants::PICKUP_VALUABLES,
261	inv_sort => "mtime",
262	default => "profile", # default profile
263	show_tips => 1,
264	logview_max_par => 1000,
265	shift_fire_stop => 0,
266	uitheme => "wood",
267	map_shift_x => -24, # arbitrary
268	map_shift_y => +24, # arbitrary
269	);
270
271	while (my ($k, $v) = each %DEF_CFG) {
272	$::CFG->{$k} = $v unless exists $::CFG->{$k};
273	}
274
275	if ($::CFG->{cfg_schema} < 1) {
276	for my $profile (values %{ $::CFG->{profile} }) {
277	$profile->{password} = unpack "H*", Deliantra::Util::hash_pw $profile->{password};
278	}
279	$::CFG->{cfg_schema} = 1;
280	}
281	}
282
283	sub http_proxy {
284	my @proxy = win32_proxy_info;
285
286	if (@proxy) {
287	"http://" . (@proxy < 2 ? "" : @proxy < 3 ? "$proxy[1]\@" : "$proxy[1]:$proxy[2]\@") . $proxy[0]
288	} elsif (exists $ENV{http_proxy}) {
289	$ENV{http_proxy}
290	} else {
291	()
292	}
293	}
294
295	sub set_proxy {
296	my $proxy = http_proxy
297	or return;
298
299	$ENV{http_proxy} = $proxy;
300	}
301
302	sub lwp_useragent {
303	require LWP::UserAgent;
304
305	DC::set_proxy;
306
307	my $ua = LWP::UserAgent->new (
308	agent => "deliantra $VERSION",
309	keep_alive => 1,
310	env_proxy => 1,
311	timeout => 30,
312	);
313	}
314
315	sub lwp_check($) {
316	my ($res) = @_;
317
318	$res->is_error
319	and die $res->status_line;
320
321	$res
322	}
323
324	sub fh_nonblocking($$) {
325	my ($fh, $nb) = @_;
326
327	if ($^O eq "MSWin32") {
328	$nb = (! ! $nb) + 0;
329	ioctl $fh, 0x8004667e, \$nb; # FIONBIO
330	} else {
331	fcntl $fh, &Fcntl::F_SETFL, $nb ? &Fcntl::O_NONBLOCK : 0;
332	}
333	}
334
335	package DC::Layout;
336
337	$DC::OpenGL::INIT_HOOK{"DC::Layout"} = sub {
338	glyph_cache_restore;
339	};
340
341	$DC::OpenGL::SHUTDOWN_HOOK{"DC::Layout"} = sub {
342	glyph_cache_backup;
343	};
344
345	1;
346
347	=back
348
349	=head1 AUTHOR
350
351	Marc Lehmann <schmorp@schmorp.de>
352	http://home.schmorp.de/
353
354	=cut
355