ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/deliantra/server/utils/cfutil.in
Revision: 1.91
Committed: Tue Oct 5 23:52:52 2010 UTC (13 years, 7 months ago) by root
Branch: MAIN
Changes since 1.90: +4 -3 lines
Log Message:
slightly better

File Contents

# User Rev Content
1 root 1.1 #!@PERL@
2    
3 root 1.77 #
4     # This file is part of Deliantra, the Roguelike Realtime MMORPG.
5     #
6     # Copyright (©) 2007,2008,2009 Marc Alexander Lehmann / Robin Redeker / the Deliantra team
7     #
8     # Deliantra is free software: you can redistribute it and/or modify it under
9     # the terms of the Affero GNU General Public License as published by the
10     # Free Software Foundation, either version 3 of the License, or (at your
11     # option) any later version.
12     #
13     # This program is distributed in the hope that it will be useful,
14     # but WITHOUT ANY WARRANTY; without even the implied warranty of
15     # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16     # GNU General Public License for more details.
17     #
18     # You should have received a copy of the Affero GNU General Public License
19     # and the GNU General Public License along with this program. If not, see
20     # <http://www.gnu.org/licenses/>.
21     #
22     # The authors can be reached via e-mail to <support@deliantra.net>
23     #
24    
25 root 1.84 use common::sense;
26 root 1.2
27     my $prefix = "@prefix@";
28     my $exec_prefix = "@exec_prefix@";
29     my $datarootdir = "@datarootdir@";
30     my $DATADIR = "@datadir@/@PACKAGE@";
31    
32     my $CONVERT = "@CONVERT@";
33 root 1.36 #my $IDENTIFY = "@IDENTIFY@";
34 root 1.3 my $OPTIPNG = "@OPTIPNG@";
35 root 1.2 my $RSYNC = "@RSYNC@";
36 root 1.31 my $PNGNQ = "@PNGNQ@";
37 root 1.2
38     use Getopt::Long;
39 root 1.73 use File::Temp;
40     use POSIX ();
41     use Carp;
42    
43 root 1.69 use Coro::EV;
44 root 1.3 use AnyEvent;
45 root 1.72 use YAML::XS ();
46 root 1.63 use JSON::XS ();
47 root 1.3 use IO::AIO ();
48 root 1.79 use Digest::MD5 ();
49 root 1.73
50 root 1.70 use Coro 5.12;
51 root 1.3 use Coro::AIO;
52 root 1.51 use Coro::Util;
53 root 1.53 use Coro::Channel;
54 root 1.25 use Coro::Storable; $Storable::canonical = 1;
55 root 1.2
56 root 1.73 use Deliantra;
57    
58 root 1.42 $SIG{QUIT} = sub { Carp::cluck "QUIT" };
59    
60 root 1.2 sub usage {
61     warn <<EOF;
62 root 1.3 Usage: cfutil [-v] [-q] [--force] [--cache]
63 root 1.2 [--install-arch path]
64     [--install-maps maps]
65     [--print-statedir]
66     [--print-confdir]
67     [--print-datadir]
68     [--print-libdir]
69     [--print-bindir]
70     EOF
71     exit 1;
72     }
73    
74     my $VERBOSE = 1;
75 root 1.3 my $CACHE = 0;
76 root 1.2 my $FORCE;
77 root 1.3 my $TMPDIR = "/tmp/cfutil$$~";
78     my $TMPFILE = "aaaa0";
79 root 1.83 my @COMMIT;
80 root 1.2
81 root 1.35 our %COLOR = (
82     black => 0,
83     white => 1,
84     navy => 2,
85     red => 3,
86     orange => 4,
87     blue => 5,
88     darkorange => 6,
89     green => 7,
90     lightgreen => 8,
91     grey => 9,
92     brown => 10,
93     gold => 11,
94     tan => 12,
95     );
96    
97 root 1.2 END { system "rm", "-rf", $TMPDIR }
98    
99 root 1.69 my $s_INT = EV::signal INT => sub { exit 1 };
100     my $s_TERM = EV::signal TERM => sub { exit 1 };
101 root 1.3
102 root 1.79 our %hash;
103    
104     # here we could try to avoid collisions and reduce chksum size further
105     sub make_hash($\$\$;$) {
106     my ($id, $dataref, $hashref, $clen) = @_;
107    
108     my $hash = substr +(Digest::MD5::md5 $$dataref), 0, $clen || 4;
109    
110     if (exists $hash{$hash}) {
111     # hahs collinion, but some files are simply identical
112     if (${$hash{$hash}[1]} ne $$dataref) {
113     warn "hash collision $hash{$hash}[0] vs. $id\n";
114     exit 1;
115     } else {
116     print "$hash{$hash}[0] and $id are identical (which is fine).\n" if $VERBOSE >= 3;
117     }
118     }
119     $hash{$hash} = [$id, $dataref, $hashref];
120    
121     $$hashref = $hash;
122     }
123    
124 root 1.2 mkdir $TMPDIR, 0700
125     or die "$TMPDIR: $!";
126    
127 root 1.3 sub fork_sub(&) {
128     my ($cb) = @_;
129    
130     if (my $pid = fork) {
131     my $current = $Coro::current;
132     my $w = AnyEvent->child (pid => $pid, cb => sub { $current->ready });
133     Coro::schedule;
134     } else {
135     eval { $cb->() };
136     POSIX::_exit 0 unless $@;
137     warn $@;
138     POSIX::_exit 1;
139     }
140     }
141    
142 root 1.2 sub inst_maps($) {
143     my (undef, $path) = @_;
144    
145 root 1.29 print "\nInstalling '$path' to '$DATADIR/maps'\n\n";
146 root 1.2
147     if (!-f "$path/regions") {
148     warn "'$path' does not look like a maps directory ('regions' file is missing).\n";
149     exit 1 unless $FORCE;
150     }
151    
152 root 1.62 system $RSYNC, "-av", "--chmod=u=rwX,go=rX",
153     "$path/.", "$DATADIR/maps/.",
154     "--exclude", "CVS", "--exclude", "/world-precomposed",
155     "--delete", "--delete-excluded"
156 root 1.16 and die "map installation failed.\n";
157 root 1.13
158     print "maps installed successfully.\n";
159 root 1.2 }
160    
161 root 1.90 our %WALL_SUFFIX = (
162     "0" => "⬤",
163     "1_3" => "╸",
164     "1_4" => "╺",
165     "2_1_2" => "━",
166    
167     "1_2" => "╹",
168     "2_2_4" => "┛",
169     "2_2_1" => "┗",
170     "3_1" => "┻",
171    
172     "1_1" => "╻",
173     "2_2_3" => "┓",
174     "2_2_2" => "┏",
175     "3_3" => "┳",
176    
177     "2_1_1" => "┃",
178     "3_4" => "┫",
179     "3_2" => "┣",
180     "4" => "╋",
181     );
182    
183 root 1.87 sub autoglyph {
184     my ($stem, $face) = @_;
185    
186     if ($stem =~ /^wall\/|Nimwall/) {
187 root 1.90 while (my ($k, $v) = each %WALL_SUFFIX) {
188     return $v if $stem =~ /_$k.x11/;
189     }
190    
191 root 1.87 "+"
192 root 1.90
193 root 1.87 } elsif ($stem =~ /^floor\/|^ground\/|Nimfloor/) {
194     "."
195 root 1.90
196 root 1.88 } elsif ($stem =~ /^player\//) {
197 root 1.89 "\@"
198 root 1.90
199 root 1.87 } else {
200     substr $stem, 0, 1
201     }
202     }
203    
204 root 1.2 {
205 root 1.24 our %ANIMINFO;
206 root 1.6 our %FACEINFO;
207 root 1.37 our %RESOURCE;
208 root 1.30 our @ARC;
209 root 1.27 our %ARC;
210 root 1.12 our $TRS;
211 root 1.3 our $NFILE;
212 root 1.37 our $PATH;
213 root 1.3
214 root 1.19 our $QUANTIZE = "+dither -colorspace RGB -colors 256";
215    
216 root 1.53 our $c_arc = new Coro::Channel;
217     our $c_trs = new Coro::Channel;
218     our $c_res = new Coro::Channel;
219    
220     our @c_png;
221 root 1.2
222 root 1.86 sub commit_png($$$$) {
223     my ($stem, $name, $data, $T) = @_;
224 root 1.5
225 root 1.86 $FACEINFO{$name}{"stem"} = substr $stem, 1 + length $PATH;
226 root 1.19 $FACEINFO{$name}{"data$T"} = $data;
227 root 1.2 }
228    
229 root 1.3 sub process_png {
230 root 1.53 while (@c_png) {
231     my ($path, $delete) = @{pop @c_png};
232 root 1.2
233 root 1.3 my $png;
234     aio_lstat $path;
235 root 1.2 my ($size, $mtime) = (stat _)[7,9];
236    
237 root 1.3 if (0 > aio_load $path, $png) {
238     warn "$path: $!, skipping.\n";
239 root 1.5 next;
240 root 1.3 }
241    
242 root 1.19 my $stem = $path;
243     my $T;
244    
245     if ($stem =~ s/\.32x32\.png~?$//) {
246     $T = 32;
247     } elsif ($stem =~ s/\.64x64\.png~?$//) {
248     $T = 64;
249     } else {
250     warn "$path: weird filename, skipping.\n";
251     next;
252     }
253    
254 root 1.6 # quickly extract width and height of the (necessarily PNG) image
255 root 1.3 unless ($png =~ /^\x89PNG\x0d\x0a\x1a\x0a....IHDR(........)/s) {
256 root 1.19 warn "$path: not a recognized png file, skipping.\n";
257 root 1.5 next;
258 root 1.3 }
259 root 1.2
260 root 1.3 my ($w, $h) = unpack "NN", $1;
261 root 1.2
262 root 1.3 if ($w < $T || $h < $T) {
263     warn "$path: too small ($w $h), skipping.\n";
264 root 1.5 next;
265 root 1.3 }
266    
267     if ($w % $T || $h % $T) {
268     warn "$path: weird png size ($w $h), skipping.\n";
269 root 1.5 next;
270 root 1.3 }
271 root 1.2
272 root 1.54 (my $base = $stem) =~ s/^.*\///;
273    
274     my $fi = $FACEINFO{$base};
275     unless ($fi) {
276 root 1.59 #warn "$path: <$base> not referenced by any archetype, skipping.\n";
277     #next;
278 root 1.54 }
279    
280 root 1.59 my $arc = $fi->{arc} || { };
281 root 1.54
282 root 1.19 unless ($path =~ /~$/) {
283     # possibly enlarge
284     if (0 > aio_stat "$stem.64x64.png") {
285     my $other = "$stem.64x64.png~";
286    
287     if (0 > aio_lstat $other or (-M _) > (-M $path)) {
288     fork_sub {
289 root 1.52 my $CROP;
290     my $SRC = "png:\Q$path\E";
291    
292 root 1.54 my $is_floor = $arc->{is_floor};
293     my $is_wall = 0;
294    
295     my ($wall_pfx, $wall_dir, $wall_sfx);
296    
297     if (
298     !$is_floor
299     && !$arc->{alive}
300 root 1.55 && $arc->{move_block} eq "all"
301 root 1.54 && $path =~ /^(.*_)([0-9A-F])(\.x11.*\.png)$/
302     ) {
303     ($wall_pfx, $wall_dir, $wall_sfx) = ($1, hex $2, $3);
304    
305     unless (grep { !-e sprintf "%s%X%s", $wall_pfx, $_, $wall_sfx } 0..15) {
306     $is_wall = 1;
307     }
308     }
309    
310     if ($is_wall || $is_floor) {
311     # add a 4px border and add other images around it
312     $CROP = "-shave 8x8 +repage";
313    
314     $w += 8;
315     $h += 8;
316    
317     $SRC = "-size ${w}x${h} xc:transparent";
318     $SRC .= " png:\Q$path\E -geometry +4+4 -composite";
319    
320     # 8 surrounding images
321     for (
322     # x y b r0 r1
323     [-1, -1, 0, 6],
324     [ 0, -1, 1, 10, 14],
325     [+1, -1, 0, 12],
326    
327     [-1, 0, 8, 5, 7],
328     #
329     [+1, 0, 2, 5, 13],
330    
331     [-1, +1, 0, 3],
332     [ 0, +1, 4, 10, 11],
333     [+1, +1, 0, 9],
334     ) {
335     my ($x, $y, $d, $r0, $r1) = @$_;
336    
337     my $tile = $is_floor ? $path
338     : $is_wall ? sprintf "%s%X%s", $wall_pfx, ($wall_dir & $d) ? $r1 : $r0, $wall_sfx
339     : die;
340    
341     $SRC .= sprintf " png:%s -geometry %+d%+d -composite",
342     "\Q$tile",
343     $x * ($w - 8) + 4,
344     $y * ($h - 8) + 4;
345 root 1.52 }
346     }
347    
348     system "convert -depth 8 $SRC rgba:-"
349 root 1.51 . "| $exec_prefix/bin/cfhq2xa $w $h 0"
350 root 1.52 . "| convert -depth 8 -size ".($w * 2)."x".($h * 2)." rgba:- $CROP $QUANTIZE -quality 00 png32:\Q$other\E~"
351     and die "convert/cfhq2xa pipeline error: status $? ($!)";
352 root 1.31 system $OPTIPNG, "-i0", "-q", "$other~";
353 root 1.19 die "$other~ has zero size, aborting." unless -s "$other~";
354     rename "$other~", $other;
355     };
356     }
357    
358 root 1.53 push @c_png, [$other, !$CACHE];
359 root 1.19 }
360    
361     # possibly scale down
362     if (0 > aio_stat "$stem.32x32.png") {
363     my $other = "$stem.32x32.png~";
364    
365     if (0 > aio_lstat $other or (-M _) > (-M $path)) {
366     fork_sub {
367     system "convert png:\Q$path\E -geometry 50% -filter lanczos $QUANTIZE -quality 00 png32:\Q$other\E~";
368 root 1.31 system $OPTIPNG, "-i0", "-q", "$other~";
369    
370     # reduce smoothfaces >10000 bytes
371 root 1.71 # obsolete, no longer required
372     if (0 && $stem =~ /_S\./ && (-s "$other~") > 10000) {
373 root 1.31 my $ncolor = 256;
374     while () {
375 root 1.33 system "<\Q$other~\E $PNGNQ -s1 -n$ncolor >\Q$other~~\E";
376 root 1.31 system $OPTIPNG, "-i0", "-q", "$other~~";
377     last if 10000 > -s "$other~~";
378     $ncolor = int $ncolor * 0.9;
379     $ncolor > 8 or die "cannot reduce filesize to < 10000 bytes";
380     }
381    
382     printf "reduced %s from %d to %d bytes using %d colours.\n",
383     $other, -s "$other~", -s "$other~~", $ncolor
384 root 1.32 if $VERBOSE >= 2;
385 root 1.31 rename "$other~~", "$other~";
386     }
387    
388 root 1.19 die "$other~ has zero size, aborting." unless -s "$other~";
389     rename "$other~", $other;
390     };
391     }
392    
393 root 1.21 #warn "scaled down $path to $other\n";#d#
394 root 1.53 push @c_png, [$other, !$CACHE];
395 root 1.19 }
396     }
397    
398     (my $face = $stem) =~ s/^.*\///;
399    
400 root 1.23 # split all bigfaces, but avoid smoothfaces (*_S)
401 root 1.3 if (($w > $T || $h > $T) && $face !~ /_S\./) {
402     # split
403     my @tile;
404     for my $x (0 .. (int $w / $T) - 1) {
405     for my $y (0 .. (int $h / $T) - 1) {
406     my $file = "$path+$x+$y~";
407     aio_lstat $file;
408     push @tile, [$x, $y, $file, (stat _)[9]];
409     }
410 root 1.2 }
411    
412 root 1.3 my $mtime = (lstat $path)[9];
413     my @todo = grep { $_->[3] <= $mtime } @tile;
414     if (@todo) {
415     fork_sub {
416     open my $convert, "|-", $CONVERT,
417     "png:-",
418     (map {
419     (
420     "(",
421     "+clone",
422     -crop => (sprintf "%dx%d+%d+%d", $T, $T, $_->[0] * $T, $_->[1] * $T),
423 root 1.7 "+repage",
424 root 1.19 -quality => "00",
425     -write => "png32:$_->[2]~",
426 root 1.3 "+delete",
427     ")",
428     )
429     } @todo),
430     "null:";
431    
432     binmode $convert;
433     print $convert $png;
434     close $convert;
435    
436     # pass 2, optimise, and rename
437     for (@todo) {
438     system $OPTIPNG, "-o5", "-i0", "-q", "$_->[2]~";
439 root 1.19 die "$_->[2]~ has zero size, aborting." unless -s "$_->[2]~";
440 root 1.3 rename "$_->[2]~", $_->[2];
441     }
442     };
443 root 1.2 }
444    
445 root 1.3 for (@tile) {
446     my ($x, $y, $file) = @$_;
447     my $tile;
448    
449     if (0 > aio_load $file, $tile) {
450     die "$path: unable to read tile +$x+$y, aborting.\n";
451     }
452     IO::AIO::aio_unlink $file unless $CACHE;
453 root 1.86 commit_png $stem, $x|$y ? "$face+$x+$y" : $face, $tile, $T;
454 root 1.2 }
455 root 1.3 } else {
456     # use as-is (either small, use smooth)
457 root 1.86 commit_png $stem, $face, $png, $T;
458 root 1.3 }
459 root 1.19
460     aio_unlink $path if $delete;
461 root 1.3 }
462 root 1.2 }
463    
464 root 1.3 sub process_arc {
465 root 1.53 while (my $job = $c_arc->get) {
466     my ($dir, $file) = @$job;
467 root 1.2
468 root 1.3 my $arc;
469     aio_load "$dir/$file", $arc; # simply pre-cache, as read_arch wants a file :/
470 root 1.4
471 root 1.2 my $arc = read_arch "$dir/$file";
472 root 1.4 for my $o (values %$arc) {
473 root 1.30 push @ARC, $o;
474     for (my $m = $o; $m; $m = $m->{more}) {
475     $ARC{$m->{_name}} = $m;
476     }
477 root 1.6
478 root 1.76 $o->{editor_folder} ||= "\x00$dir"; # horrible kludge
479 root 1.10
480 root 1.6 my $visibility = delete $o->{visibility};
481     my $magicmap = delete $o->{magicmap};
482 root 1.86 my $glyph = delete $o->{glyph};
483 root 1.6
484     # find upper left corner :/
485     # omg, this is sooo broken
486 root 1.4 my ($dx, $dy);
487     for (my $o = $o; $o; $o = $o->{more}) {
488     $dx = $o->{x} if $o->{x} < $dx;
489     $dy = $o->{y} if $o->{y} < $dy;
490     }
491 root 1.6
492 root 1.4 for (my $o = $o; $o; $o = $o->{more}) {
493     my $x = $o->{x} - $dx;
494     my $y = $o->{y} - $dy;
495 root 1.6
496     my $ext = $x|$y ? "+$x+$y" : "";
497    
498 root 1.26 $o->{face} .= $ext unless /^blank.x11$|^empty.x11$/ || !$o->{face};
499 root 1.6
500 root 1.35 $visibility = delete $o->{visibility} if exists $o->{visibility};
501     $magicmap = delete $o->{magicmap} if exists $o->{magicmap};
502 root 1.86 $glyph = delete $o->{glyph} if exists $o->{glyph};
503 root 1.6
504     my $anim = delete $o->{anim};
505    
506     if ($anim) {
507 root 1.24 # possibly add $ext to the animation name to avoid
508     # the need to specify archnames for all parts
509     # of a multipart archetype.
510 root 1.8 $o->{animation} = "$o->{_name}";
511 root 1.24 my $facings = 1;
512     my @frames;
513 root 1.6
514     for (@$anim) {
515 root 1.24 if (/^facings\s+(\d+)/) {
516     $facings = $1*1;
517     } elsif (/^blank.x11$|^empty.x11$/) {
518     push @frames, $_;
519     } else {
520     push @frames, "$_$ext";
521     }
522 root 1.6 }
523    
524 root 1.24 $ANIMINFO{$o->{animation}} = {
525     facings => $facings,
526     frames => \@frames,
527     };
528 root 1.6 }
529    
530 root 1.58 for ($o->{face} || (), @{$anim || []}) {
531     next if /^facings\s/;
532    
533     my $face = $_;
534     $face =~ s/\+\d+\+\d+$//; # remove tile offset coordinates
535 root 1.6
536 root 1.56 my $info = $FACEINFO{$face} ||= { };
537     $info->{arc} = $o;
538    
539     next if $face =~ /^blank.x11$|^empty.x11$/;
540 root 1.6
541     $info->{visibility} = $visibility if defined $visibility;
542     $info->{magicmap} = $magicmap if defined $magicmap;
543 root 1.86 $info->{glyph} = $glyph if defined $glyph;
544 root 1.4 }
545 root 1.12
546     if (my $smooth = delete $o->{smoothface}) {
547 root 1.54 my %kv = split /\s+/, $smooth;
548 root 1.23 my $level = $o->{smoothlevel}; #TODO: delete from $o if !gcfclient-support
549     while (my ($face, $smooth) = each %kv) {
550 root 1.54 $FACEINFO{$smooth}{arc} = $o;
551    
552 root 1.23 $FACEINFO{$face}{smooth} = $smooth;
553     $FACEINFO{$face}{smoothlevel} = $level;
554 root 1.14 }
555 root 1.12 }
556 root 1.4 }
557     }
558 root 1.3 }
559 root 1.2 }
560    
561 root 1.3 sub process_trs {
562 root 1.53 while (my $job = $c_trs->get) {
563     my ($dir, $file) = @$job;
564 root 1.12 my $path = "$dir/$file";
565    
566     my $trs;
567     if (0 > aio_load $path, $trs) {
568     warn "$path: $!, skipping.\n";
569     next;
570     }
571    
572     $TRS .= $trs;
573 root 1.3 }
574 root 1.2 }
575    
576 root 1.45 my %FILECACHE;
577    
578     sub load_cached($;$) {
579     unless (exists $FILECACHE{$_[0]}) {
580     my $data;
581     if (0 < aio_load $_[0], $data) {
582 root 1.49 if ($_[1]) {
583     $data = eval { $_[1]->($data) };
584     warn "$_[0]: $@" if $@;
585     }
586 root 1.45 }
587    
588     $FILECACHE{$_[0]} = $data;
589     }
590    
591     $FILECACHE{$_[0]}
592     }
593    
594 root 1.37 sub process_res {
595 root 1.53 while (my $job = $c_res->get) {
596     my ($dir, $file, $type) = @$job;
597 root 1.37
598     my $data;
599     aio_load "$dir/$file", $data;
600    
601 root 1.60 my $meta = load_cached "$dir/meta", sub { JSON::XS->new->utf8->relaxed->decode (shift) };
602 root 1.38
603 root 1.61 utf8::decode $dir;
604     utf8::decode $file;
605    
606     # a meta file for resources is now mandatory
607     unless (exists $meta->{$file}) {
608     warn "skipping $dir/$file\n" if $VERBOSE >= 3;
609 root 1.64 next;
610 root 1.61 }
611 root 1.49
612 root 1.48 $meta = {
613     %{ $meta->{"" } || {} },
614     %{ $meta->{$file} || {} },
615     };
616    
617 root 1.49 if ($meta->{license} =~ s/^#//) {
618     $meta->{license} = ({
619     "pd" => "Public Domain",
620     "gpl" => "GNU General Public License, version 3.0 or any later",
621     "cc/by/2.0" => "Licensed under Creative Commons Attribution 2.0 http://creativecommons.org/licenses/by/2.0/",
622 root 1.85 "cc/by/2.1" => "Licensed under Creative Commons Attribution 2.1 http://creativecommons.org/licenses/by/2.1/",
623 root 1.53 "cc/by/2.5" => "Licensed under Creative Commons Attribution 2.5 http://creativecommons.org/licenses/by/2.5/",
624 root 1.49 "cc/by/3.0" => "Licensed under Creative Commons Attribution 3.0 http://creativecommons.org/licenses/by/3.0/",
625     })->{$meta->{license}}
626     || warn "$dir/$file: license tag '$meta->{license}' not found.";
627     }
628    
629 root 1.85 if (!exists $meta->{author} && $meta->{source} =~ m%^http://www.jamendo.com/en/artist/(.*)$%) {
630     ($meta->{author} = $1) =~ s/_/ /g;
631     }
632    
633 root 1.37 $file =~ s/\.res$//;
634 root 1.46 $file =~ s/\.(ogg|wav|jpg|png)$//;
635 root 1.37
636     substr $dir, 0, 1 + length $PATH, "";
637    
638 root 1.63 if (my $filter = $meta->{cfutil_filter}) {
639     if ($filter eq "yaml2json") {
640 root 1.72 $data = JSON::XS::encode_json YAML::XS::Load $data;
641 root 1.65 } elsif ($filter eq "json2json") {
642     $data = JSON::XS::encode_json JSON::XS->relaxed->utf8->decode ($data);
643 root 1.66 } elsif ($filter eq "perl2json") {
644     $data = eval $data; die if $@;
645     $data = JSON::XS::encode_json $data;
646 root 1.63 } else {
647     warn "$dir/$file: unknown filter $filter, skipping\n";
648     }
649     }
650    
651 root 1.37 $RESOURCE{"$dir/$file"} = {
652 root 1.63 type => (exists $meta->{type} ? delete $meta->{type} : $type),
653 root 1.45 data => $data,
654     %$meta ? (meta => $meta) : (),
655 root 1.37 };
656     }
657     }
658    
659 root 1.3 sub find_files;
660     sub find_files {
661 root 1.2 my ($path) = @_;
662    
663 root 1.3 IO::AIO::aioreq_pri 4;
664     IO::AIO::aio_scandir $path, 4, sub {
665 root 1.2 my ($dirs, $nondirs) = @_;
666    
667 root 1.3 find_files "$path/$_"
668 root 1.80 for grep $_ !~ /^(?:CVS|dev|\..*)$/, @$dirs;
669 root 1.2
670 root 1.43 my $dir = $path;
671     substr $dir, 0, 1 + length $PATH, "";
672    
673 root 1.2 for my $file (@$nondirs) {
674 root 1.44 if ($dir =~ /^music(?:\/|$)/) {
675 root 1.53 $c_res->put ([$path, $file, 3]) # FT_MUSIC
676 root 1.44 if $file =~ /\.(ogg)$/;
677    
678 root 1.47 } elsif ($dir =~ /^sound(?:\/|$)/) {
679 root 1.53 $c_res->put ([$path, $file, 5]) # FT_SOUND
680 root 1.44 if $file =~ /\.(wav|ogg)$/;
681    
682     } elsif ($dir =~ /^res(?:\/|$)/) {
683 root 1.63 if ($file =~ /\.(jpg|png)$/) {
684     $c_res->put ([$path, $file, 0]) # FT_FACE
685     } elsif ($file =~ /\.(res)$/) {
686 root 1.67 $c_res->put ([$path, $file, 6]) # FT_RSRC
687 root 1.63 } else {
688     $c_res->put ([$path, $file, undef]);
689     }
690 root 1.44
691 root 1.43 } elsif ($file =~ /\.png$/) {
692 root 1.53 push @c_png, ["$path/$file", 0];
693 root 1.44
694 root 1.2 } elsif ($file =~ /\.trs$/) {
695 root 1.53 $c_trs->put ([$path, $file]);
696 root 1.44
697 root 1.2 } elsif ($file =~ /\.arc$/) {
698 root 1.53 $c_arc->put ([$path, $file]);
699 root 1.44
700 root 1.2 } else {
701 root 1.33 warn "ignoring $path/$file\n" if $VERBOSE >= 3;
702 root 1.2 }
703     }
704     };
705     }
706    
707 root 1.73 sub generate_plurals {
708     # use Lingua::EN::Inflect ();
709     # Lingua::EN::Inflect::classical;
710 root 1.74 # Lingua::EN::Inflect::def_noun '(.*)staff' => '$1staves'; # policy
711 root 1.73 # Lingua::EN::Inflect::def_noun '(.*)boots' => '$1boots'; # hack
712     #
713     # for my $a (@ARC) {
714     # my $name = $a->{name} || $a->{_name};
715     #
716     # next unless $a->{name_pl};
717 root 1.74 # next if $a->{invisible};
718     # next if $a->{is_floor};
719     # next if $a->{no_pick};
720 root 1.73 #
721     # my $test = Lingua::EN::Inflect::PL_N_eq $name, Lingua::EN::Inflect::PL $name;
722     # my $pl = $test =~ /^(?:eq|p:.)$/
723     # ? $name
724     # : Lingua::EN::Inflect::PL $name;
725     #
726     # if ($pl ne $a->{name_pl}) {
727     # warn "$a->{_name}: plural differs, $pl vs $a->{name_pl}\n";
728     # }
729     # }
730     }
731    
732 root 1.2 sub inst_arch($) {
733     my (undef, $path) = @_;
734    
735 root 1.37 $PATH = $path;
736    
737 root 1.29 print "\n",
738     "Installing '$path' to '$DATADIR'\n",
739 root 1.28 "\n",
740 root 1.27 "This can take a long time if you run this\n",
741     "for the first time or do not use --cache.\n",
742     "\n",
743     "Unless you run verbosely, all following warning\n",
744     "or error messages indicate serious problems.\n",
745     "\n";
746 root 1.2
747     if (!-d "$path/treasures") {
748     warn "'$path' does not look like an arch directory ('treasures' directory is missing).\n";
749     exit 1 unless $FORCE;
750     }
751    
752 root 1.53 print "scanning files...\n" if $VERBOSE;
753    
754 root 1.3 find_files $path;
755 root 1.53
756     my @a_arc = map +(async \&process_arc), 1..2;
757     my @a_res = map +(async \&process_res), 1..2;
758     my @a_trs = map +(async \&process_trs), 1..2;
759    
760 root 1.2 IO::AIO::flush;
761    
762 root 1.70 $c_res->shutdown;
763     $c_arc->shutdown;
764     $c_trs->shutdown;
765 root 1.53
766     print "start file scan, arc, res processing...\n" if $VERBOSE;
767    
768     $_->join for @a_arc; # need to parse all archetypes before png processing
769 root 1.3
770 root 1.53 print "end arc, start png processing...\n" if $VERBOSE;
771    
772 root 1.69 # eight png crunchers work fine for my 4x smp machine
773     my @a_png = map +(async \&process_png), 1..8;
774 root 1.53
775     $_->join for (@a_trs, @a_res, @a_png);
776    
777     print "scanning done, processing results...\n" if $VERBOSE;
778 root 1.5 {
779 root 1.27 # remove path prefix from editor_folder
780 root 1.76 $_->{editor_folder} =~ /^\x00/
781     and substr $_->{editor_folder}, 0, 2 + length $path, ""
782     for values %ARC;
783 root 1.27
784 root 1.53 print "resolving inheritance tree...\n" if $VERBOSE;
785 root 1.27 # resolve inherit
786     while () {
787     my $progress;
788     my $loop;
789    
790     for my $o (values %ARC) {
791 root 1.81 for my $other (split /,/, $o->{inherit}) {
792 root 1.27 if (my $s = $ARC{$other}) {
793     if ($s->{inherit}) {
794     $loop = $s;
795     } else {
796     delete $o->{inherit};
797 root 1.30 my %s = %$s;
798     delete @s{qw(_name more name name_pl)};
799     %$o = ( %s, %$o );
800 root 1.27 ++$progress;
801     }
802     } else {
803     warn "'$o->{_name}' tries to inherit from undefined archetype '$other', skipping.\n";
804     delete $ARC{$o->{_name}};
805     }
806     }
807     }
808    
809     unless ($progress) {
810     die "inheritance loop detected starting at archetype '$loop->{_name}', aborting.\n"
811     if $loop;
812    
813     last;
814     }
815     }
816    
817 root 1.34 # remove base classes (by naming scheme, should use something like "baseclass xxx" to inherit
818     @ARC = grep $_->{_name} !~ /^(?:type|class)_/, @ARC;
819    
820 root 1.73 print "generating plurals...\n" if $VERBOSE;
821     generate_plurals;
822    
823 root 1.78 printf "writing %d archetypes...\n", scalar @ARC if $VERBOSE;
824 root 1.5 open my $fh, ">:utf8", "$DATADIR/archetypes~"
825     or die "$DATADIR/archetypes~: $!";
826 root 1.65 print $fh Deliantra::archlist_to_string [sort { $a->{_name} cmp $b->{_name} } @ARC];
827 root 1.5 }
828    
829 root 1.6 {
830 root 1.78 printf "writing treasures (%d octets)...\n", length $TRS if $VERBOSE;
831 root 1.12 open my $fh, ">:utf8", "$DATADIR/treasures~"
832     or die "$DATADIR/treasures~: $!";
833     print $fh $TRS;
834     }
835    
836     {
837 root 1.53 print "processing facedata...\n" if $VERBOSE;
838 root 1.6 while (my ($k, $v) = each %FACEINFO) {
839 root 1.12 length $v->{data32} or warn "$k: face has no png32. this will not work (shoddy gcfclient will crash of course).\n";
840 root 1.19 length $v->{data64} or warn "$k: face has no png64. this will not work very well.\n";
841 root 1.5
842 root 1.79 make_hash $k, $v->{data32}, $v->{hash32};
843     make_hash $k, $v->{data64}, $v->{hash64};
844    
845 root 1.71 #length $v->{data32} <= 10000 or warn "$k: face32 larger than 10000 bytes, will not work with crossfire client.\n";
846 root 1.20 #length $v->{data64} <= 10000 or warn "$k: face64 larger than 10000 bytes.\n";
847    
848 root 1.35 if (my $magicmap = $v->{magicmap}) {
849     $magicmap =~ y/A-Z_\-/a-z/d;
850     $v->{magicmap} = $COLOR{$magicmap};
851     }
852 root 1.53
853 root 1.91 my $stem = delete $v->{stem};
854     $v->{glyph} //= autoglyph $stem, $v;
855     $v->{glyph} = (chr $v->{magicmap}) . $v->{glyph};
856    
857 root 1.53 delete $v->{arc};
858 root 1.6 }
859    
860 root 1.79 print "processing resources...\n" if $VERBOSE;
861     my $enc = JSON::XS->new->utf8->canonical->relaxed;
862     while (my ($k, $v) = each %RESOURCE) {
863    
864 root 1.83 if ($v->{meta} && $v->{meta}{datadir}) {
865     delete $RESOURCE{$k};
866 root 1.79
867 root 1.83 $k =~ s/^res\/// or die "$k: datadir files must be in res/";
868 root 1.79
869 root 1.83 printf "writing $k (%d octets)...\n", length $v->{data} if $VERBOSE;
870     open my $fh, ">:raw", "$DATADIR/$k~"
871     or die "$DATADIR/$k~: $!";
872     syswrite $fh, $v->{data};
873     push @COMMIT, $k;
874    
875     } else {
876     if ($v->{type} & 1) {
877     # prepend meta info
878    
879     my $meta = $enc->encode ({
880     name => $k,
881     %{ $v->{meta} || {} },
882     });
883    
884     $v->{data} = pack "(w/a*)*", $meta, $v->{data};
885     }
886    
887     make_hash $k, $v->{data}, $v->{hash}, 6; # 6 for the benefit of existing clients
888 root 1.79 }
889     }
890    
891 root 1.78 printf "writing facedata (%d faces, %d anims, %d resources)...\n",
892     scalar keys %FACEINFO,
893     scalar keys %ANIMINFO,
894     scalar keys %RESOURCE
895     if $VERBOSE;
896    
897 root 1.19 open my $fh, ">:perlio", "$DATADIR/facedata~"
898     or die "$DATADIR/facedata~: $!";
899 root 1.6
900 root 1.82 print $fh nfreeze {
901 root 1.24 version => 2,
902     faceinfo => \%FACEINFO,
903     animinfo => \%ANIMINFO,
904 root 1.37 resource => \%RESOURCE,
905 root 1.24 };
906 root 1.78
907 root 1.5 }
908    
909 root 1.53 print "committing files...\n" if $VERBOSE;
910    
911 root 1.83 for (qw(archetypes facedata treasures), @COMMIT) {
912 root 1.6 chmod 0644, "$DATADIR/$_~";
913 root 1.13 rename "$DATADIR/$_~", "$DATADIR/$_"
914     or die "$DATADIR/$_: $!";
915 root 1.6 }
916 root 1.13
917     print "archetype data installed successfully.\n";
918 root 1.2 }
919     }
920    
921     Getopt::Long::Configure ("bundling", "no_ignore_case");
922     GetOptions (
923     "verbose|v:+" => \$VERBOSE,
924 root 1.3 "cache" => \$CACHE,
925 root 1.2 "quiet|q" => sub { $VERBOSE = 0 },
926     "force" => sub { $FORCE = 1 },
927     "install-arch=s" => \&inst_arch,
928     "install-maps=s" => \&inst_maps,
929     "print-statedir" => sub { print "@pkgstatedir@\n" },
930     "print-datadir" => sub { print "$DATADIR\n" },
931     "print-confdir" => sub { print "@pkgconfdir@\n" },
932     "print-libdir" => sub { print "@libdir@/@PACKAGE@\n" },
933     "print-bindir" => sub { print "@bindir@/@PACKAGE@\n" },
934     ) or usage;
935