/[webpac2]/trunk/lib/WebPAC/Validate.pm
This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!
ViewVC logotype

Annotation of /trunk/lib/WebPAC/Validate.pm

Parent Directory Parent Directory | Revision Log Revision Log


Revision 838 - (hide annotations)
Thu May 24 14:42:35 2007 UTC (16 years, 11 months ago) by dpavlin
File size: 10795 byte(s)
 r1235@llin:  dpavlin | 2007-05-24 16:34:31 +0200
 and make it really work :-)

1 dpavlin 514 package WebPAC::Validate;
2    
3     use warnings;
4     use strict;
5    
6     use blib;
7    
8     use base 'WebPAC::Common';
9     use File::Slurp;
10 dpavlin 515 use List::Util qw/first/;
11 dpavlin 652 use Data::Dump qw/dump/;
12 dpavlin 643 use WebPAC::Normalize qw/_pack_subfields_hash/;
13     use Storable qw/dclone/;
14 dpavlin 514
15     =head1 NAME
16    
17     WebPAC::Validate - provide simple validation for records
18    
19     =head1 VERSION
20    
21 dpavlin 827 Version 0.11
22 dpavlin 514
23     =cut
24    
25 dpavlin 827 our $VERSION = '0.11';
26 dpavlin 514
27     =head1 SYNOPSIS
28    
29     This module provide a simple way to validate your file against a simple
30     configuration file in following format:
31    
32     # field 10 doesn't have any subfields
33     10
34     # same with 101
35     101
36     # field 200 have valid subfields a-g
37 dpavlin 645 # and field e is repeatable
38     200 a b c d e* f g
39 dpavlin 514 # field 205 can have only subfield a
40 dpavlin 645 # and must exists
41     205! a
42 dpavlin 514 # while 210 can have a c or d
43     210 a c d
44 dpavlin 677 # field which is ignored in validation
45     999-
46 dpavlin 514
47     =head1 FUNCTIONS
48    
49     =head2 new
50    
51     Create new validation object
52    
53     my $validate = new WebPAC::Validate(
54 dpavlin 643 path => 'conf/validate/file',
55 dpavlin 827 delimiters => [ ' : ', ' / ', ' ; ', ' , ' ],
56 dpavlin 837 delimiters_path => 'conf/validate/delimiters/file',
57 dpavlin 514 );
58    
59 dpavlin 827 Optional parametar C<delimiters> will turn on validating of delimiters. Be
60     careful here, those delimiters are just stuck into regex, so they can
61     contain L<perlre> regexpes.
62    
63 dpavlin 514 =cut
64    
65     sub new {
66     my $class = shift;
67     my $self = {@_};
68     bless($self, $class);
69    
70 dpavlin 837 warn dump( @_ );
71    
72 dpavlin 514 my $log = $self->_get_logger();
73    
74 dpavlin 837 if ( $self->{path} ) {
75 dpavlin 514
76 dpavlin 837 my $v_file = read_file( $self->{path} ) ||
77     $log->logdie("can't open validate path $self->{path}: $!");
78 dpavlin 514
79 dpavlin 837 my $v;
80     my $curr_line = 1;
81 dpavlin 514
82 dpavlin 837 foreach my $l (split(/[\n\r]+/, $v_file)) {
83     $curr_line++;
84 dpavlin 514
85 dpavlin 837 # skip comments and whitespaces
86     next if ($l =~ /^#/ || $l =~ /^\s*$/);
87 dpavlin 516
88 dpavlin 837 $l =~ s/^\s+//;
89     $l =~ s/\s+$//;
90 dpavlin 514
91 dpavlin 837 my @d = split(/\s+/, $l);
92 dpavlin 514
93 dpavlin 837 my $fld = shift @d;
94 dpavlin 514
95 dpavlin 837 if ($fld =~ s/!$//) {
96     $self->{must_exist}->{$fld}++;
97     } elsif ($fld =~ s/-$//) {
98     $self->{dont_validate}->{$fld}++;
99     }
100 dpavlin 645
101 dpavlin 837 $log->logdie("need field name in line $curr_line: $l") unless (defined($fld));
102 dpavlin 516
103 dpavlin 837 if (@d) {
104     $v->{$fld} = [ map {
105     my $sf = $_;
106     if ( $sf =~ s/!(\*)?$/$1/ ) {
107     $self->{must_exist_sf}->{ $fld }->{ $sf }++;
108     };
109     $sf;
110     } @d ];
111     } else {
112     $v->{$fld} = 1;
113     }
114    
115 dpavlin 514 }
116    
117 dpavlin 837 $log->debug("current validation rules: ", dump($v));
118 dpavlin 514
119 dpavlin 837 $self->{rules} = $v;
120 dpavlin 514
121 dpavlin 837 $log->info("validation uses rules from $self->{path}");
122     }
123 dpavlin 514
124 dpavlin 827 if ( $self->{delimiters} ) {
125     $self->{delimiters_regex} = '(\^[a-z0-9]|' . join('|', @{ $self->{delimiters} }) . ')';
126     $log->info("validation check delimiters with regex $self->{delimiters_regex}");
127     }
128    
129 dpavlin 837 if ( my $path = $self->{delimiters_path} ) {
130     if ( -e $path ) {
131     $log->info("using delimiter validation rules from $path");
132     open(my $d, $path) || $log->fatal("can't open $path: $!");
133     while(<$d>) {
134     chomp($d);
135     if (/^\s*(#*)\s*(\d+)\t+(\d+)\t+(.*)$/) {
136     my ($comment,$field,$count,$template) = ($1,$2,$3,$4);
137     $self->{_validate_delimiters_templates}->{$field}->{$template} = $count unless ($comment);
138     } else {
139     warn "## ignored $d\n";
140     }
141     }
142     close($d);
143     warn "_validate_delimiters_templates = ",dump( $self->{_validate_delimiters_templates} );
144     } else {
145     $log->warn("delimiters path $path doesn't exist, it will be created after this run");
146     }
147     }
148    
149 dpavlin 514 $self ? return $self : return undef;
150     }
151    
152 dpavlin 768 =head2 validate_rec
153 dpavlin 515
154     Validate record and return errors
155    
156 dpavlin 768 my @errors = $validate->validate_rec( $rec, $rec_dump );
157 dpavlin 515
158     =cut
159    
160 dpavlin 768 sub validate_rec {
161 dpavlin 515 my $self = shift;
162    
163     my $log = $self->_get_logger();
164    
165 dpavlin 768 my $rec = shift || $log->logdie("validate_rec need record");
166 dpavlin 653 my $rec_dump = shift;
167 dpavlin 515
168     $log->logdie("rec isn't HASH") unless (ref($rec) eq 'HASH');
169 dpavlin 837 # $log->logdie("can't find validation rules") unless (my $r = $self->{rules});
170     my $r = $self->{rules};
171 dpavlin 515
172 dpavlin 652 my $errors;
173 dpavlin 515
174 dpavlin 652 $log->debug("rec = ", sub { dump($rec) }, "keys = ", keys %{ $rec });
175 dpavlin 515
176 dpavlin 645 my $fields;
177    
178 dpavlin 515 foreach my $f (keys %{ $rec }) {
179    
180 dpavlin 516 next if (!defined($f) || $f eq '' || $f eq '000');
181 dpavlin 515
182 dpavlin 827 # first check delimiters
183     if ( my $regex = $self->{delimiters_regex} ) {
184    
185     foreach my $v (@{ $rec->{$f} }) {
186 dpavlin 835 my $l = _pack_subfields_hash( $v, 1 );
187     my $subfield_dump = $l;
188     my $template = '';
189     $l =~ s/$regex/$template.=$1/eg;
190     #warn "## template: $template\n";
191    
192     if ( $template ) {
193     $self->{_delimiters_templates}->{$f}->{$template}++;
194    
195     if ( my $v = $self->{_validate_delimiters_templates} ) {
196 dpavlin 838 if ( ! defined( $v->{$f}->{$template} ) ) {
197 dpavlin 835 $errors->{$f}->{invalid_delimiters_combination} = $template;
198     $errors->{$f}->{dump} = $subfield_dump;
199 dpavlin 838 #} else {
200     # warn "## $f $template ok\n";
201 dpavlin 835 }
202     }
203     }
204 dpavlin 827 }
205     }
206    
207 dpavlin 837 next unless ( $r ); # skip validation of no rules are specified
208    
209 dpavlin 677 next if (defined( $self->{dont_validate}->{$f} ));
210    
211     # track field usage
212 dpavlin 645 $fields->{$f}++;
213    
214     if ( ! defined($r->{$f}) ) {
215 dpavlin 666 $errors->{ $f }->{unexpected} = "this field is not expected";
216 dpavlin 515 next;
217     }
218    
219 dpavlin 645
220 dpavlin 515 if (ref($rec->{$f}) ne 'ARRAY') {
221 dpavlin 666 $errors->{ $f }->{not_repeatable} = "probably bug in parsing input data";
222 dpavlin 515 next;
223     }
224    
225     foreach my $v (@{ $rec->{$f} }) {
226     # can we have subfields?
227     if (ref($r->{$f}) eq 'ARRAY') {
228     # are values hashes? (has subfields)
229 dpavlin 652 if (! defined($v)) {
230 dpavlin 666 # $errors->{$f}->{empty} = undef;
231 dpavlin 656 # $errors->{dump} = $rec_dump if ($rec_dump);
232 dpavlin 652 } elsif (ref($v) ne 'HASH') {
233 dpavlin 666 $errors->{$f}->{missing_subfield} = join(",", @{ $r->{$f} }) . " required";
234 dpavlin 515 next;
235     } else {
236 dpavlin 643
237     my $h = dclone( $v );
238    
239 dpavlin 645 my $sf_repeatable;
240    
241 dpavlin 643 delete($v->{subfields}) if (defined($v->{subfields}));
242    
243 dpavlin 646 my $subfields;
244    
245 dpavlin 515 foreach my $sf (keys %{ $v }) {
246 dpavlin 643
247 dpavlin 646 $subfields->{ $sf }++;
248    
249 dpavlin 645 # is non-repeatable but with multiple values?
250     if ( ! first { $_ eq $sf.'*' } @{$r->{$f}} ) {
251     if ( ref($v->{$sf}) eq 'ARRAY' ) {
252     $sf_repeatable->{$sf}++;
253     };
254     if (! first { $_ eq $sf } @{ $r->{$f} }) {
255 dpavlin 666 $errors->{ $f }->{subfield}->{extra}->{$sf}++;
256 dpavlin 645 }
257 dpavlin 515 }
258 dpavlin 643
259 dpavlin 515 }
260 dpavlin 645 if (my @r_sf = sort keys( %$sf_repeatable )) {
261    
262 dpavlin 652 foreach my $sf (@r_sf) {
263 dpavlin 666 $errors->{$f}->{subfield}->{extra_repeatable}->{$sf}++;
264 dpavlin 670 $errors->{$f}->{dump} = _pack_subfields_hash( $h, 1 );
265 dpavlin 652 }
266    
267 dpavlin 645 }
268 dpavlin 646
269     if ( defined( $self->{must_exist_sf}->{$f} ) ) {
270     foreach my $sf (sort keys %{ $self->{must_exist_sf}->{$f} }) {
271 dpavlin 647 #warn "====> $f $sf must exist\n";
272 dpavlin 666 $errors->{$f}->{subfield}->{missing}->{$sf}++
273 dpavlin 652 unless defined( $subfields->{$sf} );
274 dpavlin 646 }
275     }
276    
277 dpavlin 515 }
278     } elsif (ref($v) eq 'HASH') {
279 dpavlin 666 $errors->{$f}->{unexpected_subfields}++;
280 dpavlin 670 $errors->{$f}->{dump} = _pack_subfields_hash( $v, 1 );
281 dpavlin 515 }
282     }
283     }
284    
285 dpavlin 827 $log->debug("_delimiters_templates = ", dump( $self->{_delimiters_templates} ) );
286    
287 dpavlin 645 foreach my $must (sort keys %{ $self->{must_exist} }) {
288     next if ($fields->{$must});
289 dpavlin 666 $errors->{$must}->{missing}++;
290 dpavlin 653 $errors->{dump} = $rec_dump if ($rec_dump);
291 dpavlin 645 }
292    
293 dpavlin 652 if ($errors) {
294 dpavlin 671 $log->debug("errors: ", $self->report_error( $errors ) );
295 dpavlin 652
296 dpavlin 653 my $mfn = $rec->{'000'}->[0] || $log->logconfess("record ", dump( $rec ), " doesn't have MFN");
297 dpavlin 652 $self->{errors}->{$mfn} = $errors;
298     }
299    
300 dpavlin 515 #$log->logcluck("return from this function is ARRAY") unless wantarray;
301    
302 dpavlin 652 return $errors;
303 dpavlin 515 }
304    
305 dpavlin 653 =head2 reset_errors
306    
307     Clean all accumulated errors for this input
308    
309     $validate->reset_errors;
310    
311     =cut
312    
313     sub reset_errors {
314     my $self = shift;
315     delete ($self->{errors});
316     }
317    
318     =head2 all_errors
319    
320     Return hash with all errors
321    
322     print dump( $validate->all_errors );
323    
324     =cut
325    
326     sub all_errors {
327     my $self = shift;
328     return $self->{errors};
329     }
330    
331 dpavlin 671 =head2 report_error
332 dpavlin 664
333 dpavlin 671 Produce nice humanly readable report of single error
334 dpavlin 664
335 dpavlin 671 print $validate->report_error( $error_hash );
336 dpavlin 664
337     =cut
338    
339 dpavlin 671 sub report_error {
340 dpavlin 664 my $self = shift;
341    
342 dpavlin 671 my $h = shift || die "no hash?";
343    
344     sub _unroll {
345 dpavlin 666 my ($self, $tree, $accumulated) = @_;
346 dpavlin 664
347 dpavlin 666 my $log = $self->_get_logger();
348    
349 dpavlin 665 $log->debug("# ",
350     ( $tree ? "tree: $tree " : '' ),
351     ( $accumulated ? "accumulated: $accumulated " : '' ),
352     );
353 dpavlin 664
354 dpavlin 665 my $results;
355 dpavlin 664
356 dpavlin 665 if (ref($tree) ne 'HASH') {
357     return ("$accumulated\t($tree)", undef);
358 dpavlin 664 }
359    
360 dpavlin 665 my $dump;
361 dpavlin 664
362 dpavlin 665 foreach my $k (sort keys %{ $tree }) {
363    
364 dpavlin 664 if ($k eq 'dump') {
365 dpavlin 665 $dump = $tree->{dump};
366 dpavlin 835 #warn "## dump ",dump($dump),"\n";
367 dpavlin 664 next;
368     }
369    
370 dpavlin 665 $log->debug("current: $k");
371 dpavlin 664
372 dpavlin 671 my ($new_results, $new_dump) = $self->_unroll($tree->{$k},
373 dpavlin 665 $accumulated ? "$accumulated\t$k" : $k
374     );
375    
376     $log->debug(
377     ( $new_results ? "new_results: " . dump($new_results) ." " : '' ),
378     );
379    
380     push @$results, $new_results if ($new_results);
381     $dump = $new_dump if ($new_dump);
382    
383 dpavlin 664 }
384 dpavlin 665
385     $log->debug(
386     ( $results ? "results: " . dump($results) ." " : '' ),
387     );
388    
389     if ($#$results == 0) {
390     return ($results->[0], $dump);
391     } else {
392     return ($results, $dump);
393     }
394 dpavlin 664 }
395    
396 dpavlin 666
397 dpavlin 671 sub _reformat {
398 dpavlin 666 my $l = shift;
399     $l =~ s/\t/ /g;
400 dpavlin 835 $l =~ s/_/ /g;
401 dpavlin 666 return $l;
402     }
403    
404 dpavlin 671 my $out = '';
405 dpavlin 666
406 dpavlin 671 for my $f (sort keys %{ $h }) {
407     $out .= "$f: ";
408    
409     my ($r, $d) = $self->_unroll( $h->{$f} );
410     my $e;
411     if (ref($r) eq 'ARRAY') {
412     $e .= join(", ", map { _reformat( $_ ) } @$r);
413     } else {
414     $e .= _reformat( $r );
415 dpavlin 666 }
416 dpavlin 671 $e .= "\n\t$d" if ($d);
417    
418     $out .= $e . "\n";
419 dpavlin 664 }
420 dpavlin 671 return $out;
421     }
422 dpavlin 664
423 dpavlin 671
424     =head2 report
425    
426     Produce nice humanly readable report of errors
427    
428     print $validate->report;
429    
430     =cut
431    
432     sub report {
433     my $self = shift;
434     my $e = $self->{errors} || return;
435    
436     my $out;
437     foreach my $mfn (sort { $a <=> $b } keys %$e) {
438     $out .= "MFN $mfn\n" . $self->report_error( $e->{$mfn} ) . "\n";
439     }
440    
441 dpavlin 664 return $out;
442 dpavlin 671
443 dpavlin 664 }
444    
445 dpavlin 832 =head2 delimiters_templates
446    
447 dpavlin 834 Generate report of delimiter tamplates
448 dpavlin 832
449 dpavlin 834 my $report = $validate->delimiter_teplates(
450     report => 1,
451     );
452    
453     Options:
454    
455     =over 4
456    
457     =item report
458    
459     Generate humanly readable report with single fields
460    
461     =back
462    
463 dpavlin 832 =cut
464    
465     sub delimiters_templates {
466     my $self = shift;
467    
468 dpavlin 834 my $args = {@_};
469    
470 dpavlin 832 my $t = $self->{_delimiters_templates};
471    
472     my $log = $self->_get_logger;
473    
474     unless ($t) {
475 dpavlin 834 $log->error("called without delimiters");
476 dpavlin 832 return;
477     }
478    
479     my $out;
480    
481     foreach my $f (sort { $a <=> $b } keys %$t) {
482 dpavlin 834 $out .= "$f\n" if ( $args->{report} );
483     foreach my $template (sort { $a cmp $b } keys %{ $t->{$f} }) {
484     my $count = $t->{$f}->{$template};
485     $out .=
486     ( $count ? "" : "# " ) .
487 dpavlin 836 ( $args->{report} ? "" : "$f" ) .
488 dpavlin 834 "\t$count\t$template\n";
489 dpavlin 832 }
490     }
491    
492     return $out;
493     }
494    
495 dpavlin 837 =head2 save_delimiters_templates
496    
497     =cut
498    
499     sub save_delimiters_templates {
500     my $self = shift;
501    
502     my $path = $self->{delimiters_path};
503    
504     return unless ( $path );
505    
506     my $log = $self->_get_logger;
507    
508     open(my $d, '>', $path) || $log->fatal("can't open $path: $!");
509     print $d $self->delimiters_templates;
510     close($d);
511    
512     $log->info("new delimiters templates saved to $path");
513     }
514    
515 dpavlin 514 =head1 AUTHOR
516    
517     Dobrica Pavlinusic, C<< <dpavlin@rot13.org> >>
518    
519     =head1 COPYRIGHT & LICENSE
520    
521     Copyright 2006 Dobrica Pavlinusic, All Rights Reserved.
522    
523     This program is free software; you can redistribute it and/or modify it
524     under the same terms as Perl itself.
525    
526     =cut
527    
528     1; # End of WebPAC::Validate

  ViewVC Help
Powered by ViewVC 1.1.26