root/main/trunk/greenstone2/perllib/plugins/ArchivesInfPlugin.pm @ 21308

Revision 21308, 8.5 KB (checked in by kjdon, 10 years ago)

removeold renamed to remove_all, added remove_one for deleting a single doc

  • Property svn:executable set to *
  • Property svn:keywords set to Author Date Id Revision
Line 
1###########################################################################
2#
3# ArchivesInfPlugin.pm --
4# A component of the Greenstone digital library software
5# from the New Zealand Digital Library Project at the
6# University of Waikato, New Zealand.
7#
8# Copyright (C) 1999 New Zealand Digital Library Project
9#
10# This program is free software; you can redistribute it and/or modify
11# it under the terms of the GNU General Public License as published by
12# the Free Software Foundation; either version 2 of the License, or
13# (at your option) any later version.
14#
15# This program is distributed in the hope that it will be useful,
16# but WITHOUT ANY WARRANTY; without even the implied warranty of
17# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
18# GNU General Public License for more details.
19#
20# You should have received a copy of the GNU General Public License
21# along with this program; if not, write to the Free Software
22# Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
23#
24###########################################################################
25
26# plugin which reads through an archives.inf (or GDBM equivalent,
27# archiveinf-doc.gdb file (i.e. the file generated in the
28# archives directory when an import is done), processing each file it
29# finds
30
31package ArchivesInfPlugin;
32
33use util;
34use doc;
35use PrintInfo;
36use plugin;
37use arcinfo;
38use gsprintf;
39use GDBMUtils;
40
41use strict;
42no strict 'refs'; # allow filehandles to be variables and viceversa
43
44BEGIN {
45    @ArchivesInfPlugin::ISA = ('PrintInfo');
46}
47
48my $arguments = [
49      { 'name' => "reversesort",
50    'desc' => "{ArchivesInfPlugin.reversesort}",
51    'type' => "flag",
52    'reqd' => "no",
53    'modegli' => "2" },
54
55         ];
56
57my $options = { 'name'     => "ArchivesInfPlugin",
58        'desc'     => "{ArchivesInfPlugin.desc}",
59        'abstract' => "no",
60        'inherits' => "yes",
61            'args' => $arguments};
62         
63sub gsprintf
64{
65    return &gsprintf::gsprintf(@_);
66}
67
68sub new {
69    my ($class) = shift (@_);
70    my ($pluginlist,$inputargs,$hashArgOptLists) = @_;
71    push(@$pluginlist, $class);
72
73    push(@{$hashArgOptLists->{"ArgList"}},@{$arguments});
74    push(@{$hashArgOptLists->{"OptList"}},$options);
75
76    my $self = new PrintInfo($pluginlist, $inputargs, $hashArgOptLists);
77
78    return bless $self, $class;
79}
80
81# called once, at the start of processing
82sub init {
83    my $self = shift (@_);
84    my ($verbosity, $outhandle, $failhandle) = @_;
85
86    # verbosity is passed through from the processor
87    $self->{'verbosity'} = $verbosity;
88
89    # as are the outhandle and failhandle
90    $self->{'outhandle'} = $outhandle if defined $outhandle;
91    $self->{'failhandle'} = $failhandle;
92
93}
94
95sub deinit {
96    my ($self) = @_;
97
98    my $archive_info = $self->{'archive_info'};
99    my $verbosity = $self->{'verbosity'};
100    my $outhandle = $self->{'outhandle'};
101
102    if (defined $archive_info) {
103    my $archive_info_filename = $self->{'archive_info_filename'};
104
105        my $file_list = $archive_info->get_file_list();
106
107    foreach my $subfile (@$file_list) {     
108        my $doc_oid = $subfile->[1];
109
110        my $index_status = $archive_info->get_status_info($doc_oid);
111
112        if ($index_status eq "D") {
113        # delete
114        $archive_info->delete_info($doc_oid);
115        &GDBMUtils::gdbmDatabaseRemove($archive_info_filename,$doc_oid);
116
117        my $doc_file = $subfile->[0];
118        my $base_dir =$self->{'base_dir'};
119
120        my $doc_filename = &util::filename_cat($base_dir,$doc_file);
121
122        my ($doc_tailname, $doc_dirname, $suffix)
123            = File::Basename::fileparse($doc_filename, "\\.[^\\.]+\$");
124
125        print $outhandle "Removing $doc_dirname\n" if ($verbosity>2);
126
127        &util::rm_r($doc_dirname);
128
129
130        }
131        elsif ($index_status =~ m/^(I|R)$/) {
132        # mark as "been indexed"
133        $archive_info->set_status_info($doc_oid,"B");
134        }
135    }
136
137    $archive_info->save_info($archive_info_filename);
138    }
139}
140
141# called at the beginning of each plugin pass (import has one, buildin has many)
142sub begin {
143    my $self = shift (@_);
144    my ($pluginfo, $base_dir, $processor, $maxdocs) = @_;
145
146    $self->{'base_dir'} = $base_dir;
147}
148
149sub remove_all {
150    my $self = shift (@_);
151    my ($pluginfo, $base_dir, $processor, $maxdocs) = @_;
152
153}
154
155sub remove_one {
156    my $self = shift (@_);
157    my ($file, $oids) = @_;
158   
159}
160
161
162# called at the end of each plugin pass
163sub end {
164    my ($self) = shift (@_);
165
166}
167
168
169# return 1 if this class might recurse using $pluginfo
170sub is_recursive {
171    my $self = shift (@_);
172
173    return 1;
174}
175
176
177sub compile_stats {
178    my $self = shift(@_);
179    my ($stats) = @_;
180}
181
182# We don't do metadata_read
183sub metadata_read {
184    my $self = shift (@_);
185    my ($pluginfo, $base_dir, $file, $block_hash,
186    $extrametakeys, $extrametadata, $extrametafile,
187    $processor, $maxdocs, $gli) = @_;
188
189    return undef;
190}
191
192sub file_block_read {
193
194    my $self = shift (@_); 
195    my ($pluginfo, $base_dir, $file, $block_hash, $metadata, $gli) = @_;
196
197    if ($file eq "OIDcount") {
198    my ($filename_full_path, $filename_no_path)
199        = &util::get_full_filenames($base_dir, $file);
200    $block_hash->{'file_blocks'}->{$filename_full_path} = 1;
201    return 1;
202    }
203
204    # otherwise, we don't do any file blocking
205
206    return undef;
207}
208
209
210# return number of files processed, undef if can't process
211# Note that $base_dir might be "" and that $file might
212# include directories
213sub read {
214    my $self = shift (@_);
215    my ($pluginfo, $base_dir, $file, $block_hash, $metadata, $processor, $maxdocs,$total_count, $gli) = @_;
216    my $outhandle = $self->{'outhandle'};
217
218    my $count = 0;
219
220    # see if this has a archives information file within it
221##    my $archive_info_filename = &util::filename_cat($base_dir,$file,"archives.inf");
222
223    my $doc_db = "archiveinf-doc.gdb";
224    my $archive_info_filename = &util::filename_cat($base_dir,$file,$doc_db);
225
226    if (-e $archive_info_filename) {
227
228    # found an archives.inf file
229    &gsprintf($outhandle, "ArchivesInfPlugin: {common.processing} $archive_info_filename\n") if $self->{'verbosity'} > 1;
230
231    # read in the archives information file
232    my $archive_info = new arcinfo ();
233    $self->{'archive_info'} = $archive_info;
234    $self->{'archive_info_filename'} = $archive_info_filename;
235    if ($self->{'reversesort'}) {
236        $archive_info->reverse_sort();
237    }
238   
239    $archive_info->load_info ($archive_info_filename);
240   
241    my $file_list = $archive_info->get_file_list();
242
243    # process each file
244    foreach my $subfile (@$file_list) {
245
246        last if ($maxdocs != -1 && ($total_count + $count) >= $maxdocs);
247
248        my $tmp = &util::filename_cat ($file, $subfile->[0]);
249        next if $tmp eq $file;
250
251        my $doc_oid = $subfile->[1];
252        my $index_status = $archive_info->get_status_info($doc_oid);
253
254        my $curr_mode = $processor->get_mode();
255        my $new_mode = $curr_mode;
256
257        # Start by assuming we want to process the file...
258        my $process_file = 1;
259
260        # ...unless the build processor is incremental capable and -incremental was specified, in which case we need to check its index_status flag
261        if ($processor->is_incremental_capable() && $self->{'incremental'})
262        {
263            # Check to see if the file needs indexing
264        if ($index_status eq "B")
265        {
266            # Don't process this file as it has already been indexed
267            $process_file = 0;
268        }
269        elsif ($index_status eq "D") {
270            # Need to be delete it from the index.
271            $new_mode = $curr_mode."delete";
272            $process_file = 1;
273        }
274        elsif ($index_status eq "R") {
275            # Need to be reindexed/replaced
276            $new_mode = $curr_mode."reindex";
277
278            $process_file = 1;
279        }
280        }
281        # ... or we're being asked to delete it (in which case skip it)
282        elsif ($index_status eq "D") {
283        # Non-incremental Delete
284        # It's already been deleted from the archives directory
285        # (done during import.pl)
286        # => All we need to do here is not process it
287
288        $process_file = 0;
289        }
290
291        if (!$processor->is_incremental_capable() && $self->{'incremental'}) {
292        # Nag feature
293        if (!defined $self->{'incremental-warning'}) {
294            print $outhandle "\n";
295            print $outhandle "Warning: command-line option '-incremental' used with *non-incremental*\n";
296            print $outhandle "         processor '", ref $processor, "'. Some conflicts may arise.\n";
297            print $outhandle "\n";
298            sleep 10;
299            $self->{'incremental-warning'} = 1;
300        }
301        }
302
303        if ($process_file) {
304        # note: metadata is not carried on to the next level
305       
306        $processor->set_mode($new_mode) if ($new_mode ne $curr_mode);
307
308        $count += &plugin::read ($pluginfo, $base_dir, $tmp, $block_hash, {}, $processor, $maxdocs, ($total_count+$count), $gli);
309
310        $processor->set_mode($curr_mode) if ($new_mode ne $curr_mode);
311        }
312    }
313
314    return $count;
315    }
316
317
318    # wasn't an archives directory, someone else will have to process it
319    return undef;
320}
321
3221;
Note: See TracBrowser for help on using the browser.