ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/deliantra/server/utils/cfutil.in
Revision: 1.109
Committed: Wed Oct 20 15:55:07 2010 UTC (13 years, 7 months ago) by root
Branch: MAIN
Changes since 1.108: +1 -1 lines
Log Message:
*** empty log message ***

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