/[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 852 - (hide annotations)
Sun May 27 11:27:12 2007 UTC (16 years, 11 months ago) by dpavlin
File size: 12142 byte(s)
 r1261@llin:  dpavlin | 2007-05-27 13:27:55 +0200
 profiling: add sub { dump( ) } for $log->debug

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 849 Version 0.12
22 dpavlin 514
23     =cut
24    
25 dpavlin 849 our $VERSION = '0.12';
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     my $log = $self->_get_logger();
71    
72 dpavlin 839 $log->logdie("need path or delimiters_path") unless ( $self->{path} || $self->{delimiters_path} );
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 dpavlin 841 #warn "_validate_delimiters_templates = ",dump( $self->{_validate_delimiters_templates} );
144 dpavlin 837 } 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 843 $errors->{$f}->{potentially_invalid_combination} = $template;
198 dpavlin 835 $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 852 $log->debug("_delimiters_templates = ", sub { dump( $self->{_delimiters_templates} ) } );
286 dpavlin 827
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 852 my $mfn = $rec->{'000'}->[0] || $log->logconfess("record ", sub { 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 849 =head2 reset
306 dpavlin 653
307 dpavlin 849 Clean all accumulated errors for this input and remember delimiter templates
308     for L<save_delimiters_templates>
309 dpavlin 653
310 dpavlin 849 $validate->reset;
311 dpavlin 653
312 dpavlin 849 This function B<must> be called after each input to provide accurate statistics.
313    
314 dpavlin 653 =cut
315    
316 dpavlin 849 sub reset {
317 dpavlin 653 my $self = shift;
318 dpavlin 849
319     my $log = $self->_get_logger;
320    
321 dpavlin 653 delete ($self->{errors});
322 dpavlin 849
323     if ( ! $self->{_delimiters_templates} ) {
324     $log->debug("called without _delimiters_templates?");
325     return;
326     }
327    
328     foreach my $f ( keys %{ $self->{_delimiters_templates} } ) {
329     foreach my $t ( keys %{ $self->{_delimiters_templates}->{$f} } ) {
330     $self->{_accumulated_delimiters_templates}->{$f}->{$t} +=
331     $self->{_delimiters_templates}->{$f}->{$t};
332     }
333     }
334 dpavlin 852 $log->debug("_accumulated_delimiters_templates = ", sub { dump( $self->{_accumulated_delimiter_templates} ) } );
335 dpavlin 849 delete ($self->{_delimiters_templates});
336 dpavlin 653 }
337    
338     =head2 all_errors
339    
340     Return hash with all errors
341    
342     print dump( $validate->all_errors );
343    
344     =cut
345    
346     sub all_errors {
347     my $self = shift;
348     return $self->{errors};
349     }
350    
351 dpavlin 671 =head2 report_error
352 dpavlin 664
353 dpavlin 671 Produce nice humanly readable report of single error
354 dpavlin 664
355 dpavlin 671 print $validate->report_error( $error_hash );
356 dpavlin 664
357     =cut
358    
359 dpavlin 671 sub report_error {
360 dpavlin 664 my $self = shift;
361    
362 dpavlin 671 my $h = shift || die "no hash?";
363    
364     sub _unroll {
365 dpavlin 666 my ($self, $tree, $accumulated) = @_;
366 dpavlin 664
367 dpavlin 666 my $log = $self->_get_logger();
368    
369 dpavlin 665 $log->debug("# ",
370     ( $tree ? "tree: $tree " : '' ),
371     ( $accumulated ? "accumulated: $accumulated " : '' ),
372     );
373 dpavlin 664
374 dpavlin 665 my $results;
375 dpavlin 664
376 dpavlin 665 if (ref($tree) ne 'HASH') {
377     return ("$accumulated\t($tree)", undef);
378 dpavlin 664 }
379    
380 dpavlin 665 my $dump;
381 dpavlin 664
382 dpavlin 665 foreach my $k (sort keys %{ $tree }) {
383    
384 dpavlin 664 if ($k eq 'dump') {
385 dpavlin 665 $dump = $tree->{dump};
386 dpavlin 835 #warn "## dump ",dump($dump),"\n";
387 dpavlin 664 next;
388     }
389    
390 dpavlin 665 $log->debug("current: $k");
391 dpavlin 664
392 dpavlin 671 my ($new_results, $new_dump) = $self->_unroll($tree->{$k},
393 dpavlin 665 $accumulated ? "$accumulated\t$k" : $k
394     );
395    
396 dpavlin 852 $log->debug( "new_results: ", sub { dump($new_results) } ) if ( $new_results );
397 dpavlin 665
398     push @$results, $new_results if ($new_results);
399     $dump = $new_dump if ($new_dump);
400    
401 dpavlin 664 }
402 dpavlin 665
403 dpavlin 852 $log->debug( "results: ", sub { dump($results) } ) if ( $results );
404 dpavlin 665
405     if ($#$results == 0) {
406     return ($results->[0], $dump);
407     } else {
408     return ($results, $dump);
409     }
410 dpavlin 664 }
411    
412 dpavlin 666
413 dpavlin 671 sub _reformat {
414 dpavlin 666 my $l = shift;
415     $l =~ s/\t/ /g;
416 dpavlin 835 $l =~ s/_/ /g;
417 dpavlin 666 return $l;
418     }
419    
420 dpavlin 671 my $out = '';
421 dpavlin 666
422 dpavlin 671 for my $f (sort keys %{ $h }) {
423     $out .= "$f: ";
424    
425     my ($r, $d) = $self->_unroll( $h->{$f} );
426     my $e;
427     if (ref($r) eq 'ARRAY') {
428     $e .= join(", ", map { _reformat( $_ ) } @$r);
429     } else {
430     $e .= _reformat( $r );
431 dpavlin 666 }
432 dpavlin 671 $e .= "\n\t$d" if ($d);
433    
434     $out .= $e . "\n";
435 dpavlin 664 }
436 dpavlin 671 return $out;
437     }
438 dpavlin 664
439 dpavlin 671
440     =head2 report
441    
442     Produce nice humanly readable report of errors
443    
444     print $validate->report;
445    
446     =cut
447    
448     sub report {
449     my $self = shift;
450     my $e = $self->{errors} || return;
451    
452     my $out;
453     foreach my $mfn (sort { $a <=> $b } keys %$e) {
454     $out .= "MFN $mfn\n" . $self->report_error( $e->{$mfn} ) . "\n";
455     }
456    
457 dpavlin 664 return $out;
458 dpavlin 671
459 dpavlin 664 }
460    
461 dpavlin 832 =head2 delimiters_templates
462    
463 dpavlin 834 Generate report of delimiter tamplates
464 dpavlin 832
465 dpavlin 834 my $report = $validate->delimiter_teplates(
466     report => 1,
467 dpavlin 851 current_input => 1,
468 dpavlin 834 );
469    
470     Options:
471    
472     =over 4
473    
474     =item report
475    
476     Generate humanly readable report with single fields
477    
478 dpavlin 851 =item current_input
479 dpavlin 849
480 dpavlin 851 Report just current_input and not accumulated data
481 dpavlin 849
482 dpavlin 834 =back
483    
484 dpavlin 832 =cut
485    
486     sub delimiters_templates {
487     my $self = shift;
488    
489 dpavlin 834 my $args = {@_};
490    
491 dpavlin 851 my $t = $self->{_accumulated_delimiters_templates};
492     $t = $self->{_delimiters_templates} if ( $args->{current_input} );
493 dpavlin 832
494     my $log = $self->_get_logger;
495    
496     unless ($t) {
497 dpavlin 834 $log->error("called without delimiters");
498 dpavlin 832 return;
499     }
500    
501     my $out;
502    
503     foreach my $f (sort { $a <=> $b } keys %$t) {
504 dpavlin 834 $out .= "$f\n" if ( $args->{report} );
505     foreach my $template (sort { $a cmp $b } keys %{ $t->{$f} }) {
506     my $count = $t->{$f}->{$template};
507     $out .=
508     ( $count ? "" : "# " ) .
509 dpavlin 836 ( $args->{report} ? "" : "$f" ) .
510 dpavlin 834 "\t$count\t$template\n";
511 dpavlin 832 }
512     }
513    
514     return $out;
515     }
516    
517 dpavlin 837 =head2 save_delimiters_templates
518    
519 dpavlin 849 Save accumulated delimiter templates
520    
521     $validator->save_delimiters_template( '/path/to/validate/delimiters' );
522    
523 dpavlin 837 =cut
524    
525     sub save_delimiters_templates {
526     my $self = shift;
527    
528     my $path = $self->{delimiters_path};
529    
530     return unless ( $path );
531    
532     my $log = $self->_get_logger;
533    
534 dpavlin 849 if ( ! $self->{_accumulated_delimiters_templates} ) {
535     $log->error('no _accumulated_delimiters_templates found, reset');
536     $self->reset;
537     }
538    
539     if ( ! $self->{_delimiters_templates} ) {
540     $log->error('found _delimiters_templates, calling reset');
541     $self->reset;
542     }
543    
544 dpavlin 840 $path .= '.new' if ( -e $path );
545    
546 dpavlin 837 open(my $d, '>', $path) || $log->fatal("can't open $path: $!");
547 dpavlin 851 print $d $self->delimiters_templates;
548 dpavlin 837 close($d);
549    
550     $log->info("new delimiters templates saved to $path");
551     }
552    
553 dpavlin 514 =head1 AUTHOR
554    
555     Dobrica Pavlinusic, C<< <dpavlin@rot13.org> >>
556    
557     =head1 COPYRIGHT & LICENSE
558    
559     Copyright 2006 Dobrica Pavlinusic, All Rights Reserved.
560    
561     This program is free software; you can redistribute it and/or modify it
562     under the same terms as Perl itself.
563    
564     =cut
565    
566     1; # End of WebPAC::Validate

  ViewVC Help
Powered by ViewVC 1.1.26