- adapted count command

lib/SLUB/LZA/TA/Command/count.pm

@@ -3,15 +3,14 @@ use SLUB::LZA::TA -command;
 use strict;
 use warnings;
 use feature qw(say);
-use SLUB::LZA::TA::Rosetta::common_sru;
-use SLUB::LZA::TA::Rosetta::SRU;
+use SLUB::LZA::TA::Archivematica::Elasticsearch;
+use Data::Printer;
 
 
 # VERSION
 
 # ABSTRACT: count IEs module for ta-tool
 
-
 sub abstract {"count IEs in Rosetta based Archival Information System";}
 
 my $description=<<"DESCR";
@@ -20,15 +19,15 @@ and return counts of matches.
 
 Examples:
 
-  * Is this dc identifier in Archiv?
+  * Is this dc identifier in archive?
     $0 count -d SLUB:LZA:Kitodo:kitodo:422766
-  * How many IEs were modified in 2021-05-31?
+  * How many AIPs were modified in 2021-05-31?
     $0 count -m 2021-05-31
-  * How many IEs have at least one invalid file?
+  * How many AIPs have at least one invalid file?
     $0 count --with-invalid-files
-  * How many IEs with mkv-files are in archive?
+  * How many AIPs with mkv-files are in archive?
     $0 count --with-format=fmt/569
-  * How many IEs have at least one file without virus check?
+  * How many AIPs have at least one file without virus check?
     $0 count --with-missed-viruscheck
 DESCR
 
@@ -37,15 +36,17 @@ sub description {
 }
 sub opt_spec {
     return(
+        ["target-version|V" => "get current elasticsearch version"],
         ["verbose|v" => "enable verbose output"],
         ["debug" => "enable user agent debug output"],
         ["datemode" => hidden => {one_of => [
             ["creationdate|c=s" => "search based on creationdate string"],
             ["modificationdate|m=s" => "search based on modificationdate string"]
         ] } ],
+        [ "lzaid|l=s", "count AIPs by given LZA id"],
         ["descriptive|d=s" => "count based on string search in descriptive metadata"],
         ["source|s=s" => "count based on string search in source metadata"],
-        ["ie|i=s" => "search a specific IE"],
+        ["aip|a=s" => "count AIPs by given AIP id"],
         ["format" => hidden => {one_of => [
             ["with-format=s" => "with pronom format id"],
             # unsupported by Rosetta <= 7.0
@@ -71,12 +72,24 @@ sub validate_args {
 
 sub execute {
     my ($self, $opt, $args) = @_;
-    my $maxrecords="0";
-    my $startrecord=1;
-    my $query = SLUB::LZA::TA::Rosetta::common_sru::prepare_query($opt);
-    my $response = SLUB::LZA::TA::Rosetta::SRU::sru_search('ie', $query, $startrecord, $maxrecords, $opt->{verbose}, $opt->{debug});
-    $response=~s|.*?<numberOfRecords>(\d+)</numberOfRecords.*|$1|s;
-    say $response;
+    if ($opt->{target_version}) {
+        say SLUB::LZA::TA::Archivematica::Elasticsearch::version_elasticsearch(
+            $SLUB::LZA::TA::config{elasticsearchprotocol},
+            $SLUB::LZA::TA::config{elasticsearchhost},
+            $SLUB::LZA::TA::config{elasticsearchport}
+        );
+        exit (0);
+    }
+    my $query = SLUB::LZA::TA::Archivematica::Elasticsearch::prepare_query($opt);
+    my $response = SLUB::LZA::TA::Archivematica::Elasticsearch::query_elasticsearch_count(
+        $SLUB::LZA::TA::config{elasticsearchprotocol},
+        $SLUB::LZA::TA::config{elasticsearchhost},
+        $SLUB::LZA::TA::config{elasticsearchport},
+        'aips', # indexname
+        $query, # query_hash ref
+    );
+    say np($response);
+    return 1;
 }
 
 1;