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::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 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
      #db_schema          => 0,
   );

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

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