22887152e13f39bc8aea112966d2e0273a241fda
[irspy-moved-to-github.git] / lib / ZOOM / IRSpy / Test / Record / Fetch.pm
1
2 # See the "Main" test package for documentation
3
4 package ZOOM::IRSpy::Test::Record::Fetch;
5
6 use 5.008;
7 use strict;
8 use warnings;
9
10 use ZOOM::IRSpy::Test;
11 our @ISA = qw(ZOOM::IRSpy::Test);
12
13
14 # These queries 
15 my @queries = (
16                "\@attr 1=4 mineral",
17                "\@attr 1=4 computer",
18                "\@attr 1=44 mineral", # Smithsonian doesn't support AP 4!
19                "\@attr 1=1016 water", # Connector Framework only does 1016
20                ### We can add more queries here
21                );
22
23
24 sub start {
25     my $class = shift();
26     my($conn) = @_;
27
28     # Here I want to get a use attribute from the session, which we've
29     # managed to search for in the Search/Bib1 or Search/Dan1 tests.
30     # But how?  So far we search for title: 1=4
31     $conn->irspy_search_pqf($queries[0], { queryindex => 0 }, {},
32                             ZOOM::Event::ZEND, \&completed_search,
33                             exception => \&completed_search);
34 }
35
36
37 sub completed_search {
38     my($conn, $task, $udata, $event) = @_;
39
40     my $n = $task->{rs}->size();
41     $conn->log("irspy_test", "Fetch test search (", $task->render_query(), ") ",
42                ref $event && $event->isa("ZOOM::Exception") ?
43                "failed: $event" : "found $n records (event=$event)");
44     if ($n == 0) {
45         $task->{rs}->destroy();
46         my $qindex = $udata->{queryindex}+1;
47         my $q = $queries[$qindex];
48         return ZOOM::IRSpy::Status::TEST_SKIPPED
49             if !defined $q;
50
51         $conn->log("irspy_test", "Trying another search ...");
52         $conn->irspy_search_pqf($queries[$qindex], { queryindex => $qindex }, {},
53                                 ZOOM::Event::ZEND, \&completed_search,
54                                 exception => \&completed_search);
55         return ZOOM::IRSpy::Status::TASK_DONE;
56     }
57
58     my @syntax = (
59                    'canmarc',
60                    'danmarc',
61                    'grs-1',
62                    'ibermarc',
63                    'intermarc',
64                    'jpmarc',
65                    'librismarc',
66                    'mab',
67                    'normarc',
68 #                   'opac',
69                    'picamarc',
70                    'rusmarc',
71                    'summary',
72                    'sutrs',
73                    'swemarc',
74                    'ukmarc',
75                    'unimarc',
76                    'usmarc',
77                    'xml'
78                 );
79     #@syntax = qw(grs-1 sutrs usmarc xml); # simplify for debugging
80     foreach my $i (0 ..$#syntax) {
81         my $syntax = $syntax[$i];
82         $conn->irspy_rs_record($task->{rs}, 0,
83                                { syntax => $syntax,
84                                  last => ($i == $#syntax) },
85                                { start => 0, count => 1,
86                                  preferredRecordSyntax => $syntax },
87                                 ZOOM::Event::ZEND, \&record,
88                                 exception => \&fetch_error);
89     }
90
91     return ZOOM::IRSpy::Status::TASK_DONE;
92 }
93
94
95 sub record {
96     my($conn, $task, $udata, $event) = @_;
97     my $syn = $udata->{'syntax'};
98     my $rs = $task->{rs};
99
100     my $record = _fetch_record($rs, 0, $syn);
101     my $ok = 0;
102     if (!$record || $record->error()) {
103         $conn->log("irspy_test", "retrieval of $syn record failed: ",
104                    defined $record ? $record->exception() :
105                                      $conn->exception());
106     } else {
107         $ok = 1;
108         my $text = $record->render();
109         $conn->log("irspy_test", "Successfully retrieved a $syn record");
110         if (0) {
111             print STDERR "Hits: ", $rs->size(), "\n";
112             print STDERR "Syntax: ", $syn, "\n";
113             print STDERR $text;
114         }
115     }
116
117     $conn->record()->store_result('record_fetch',
118                                   'syntax'   => $syn,
119                                   'ok'       => $ok);
120
121     $rs->destroy() if $udata->{last};
122     return ($udata->{last} ?
123             ZOOM::IRSpy::Status::TEST_GOOD :
124             ZOOM::IRSpy::Status::TASK_DONE);
125 }
126
127
128 sub _fetch_record {
129     my($rs, $index0, $syntax) = @_;
130
131     my $oldSyntax = $rs->option(preferredRecordSyntax => $syntax);
132     my $record = $rs->record(0);
133     $oldSyntax = "" if !defined $oldSyntax;
134     $rs->option(preferredRecordSyntax => $oldSyntax);
135
136     return $record;
137 }
138
139
140 sub __UNUSED_search_error {
141     my($conn, $task, $test_args, $exception) = @_;
142
143     $conn->log("irspy_test", "Initial search failed: ", $exception);
144     return ZOOM::IRSpy::Status::TEST_SKIPPED;
145 }
146
147
148 sub fetch_error {
149     my($conn, $task, $udata, $exception) = @_;
150     my $syn = $udata->{'syntax'};
151
152     $conn->log("irspy_test", "Retrieval of $syn record failed: ", $exception);
153     $conn->record()->store_result('record_fetch',
154                                   'syntax'       => $syn,
155                                   'ok'        => 0);
156     $task->{rs}->destroy() if $udata->{last};
157     return ZOOM::IRSpy::Status::TASK_DONE;
158 }
159
160
161 1;