Added mapping creation script

Author: mickeyn

Dockerfile

@@ -23,6 +23,7 @@ EOT
 
 COPY bin bin
 COPY lib lib
+COPY conf conf
 COPY *.conf .
 
 ENV PERL5LIB="/app/local/lib/perl5:/app/lib" PATH="/app/local/bin:${PATH}"

bin/backup.pl

@@ -33,7 +33,7 @@
 );
 
 # setup
-my $home = path( home() );
+my $home = home();
 
 run_restore() if $restore;
 run_purge()   if $purge;

bin/cpan_testers.pl

@@ -23,8 +23,6 @@
 );
 
 # setup
-
-# XXX fix hardcoded path
 my $home = home();
 
 my $db

bin/mapping.pl

@@ -0,0 +1,32 @@
+use strict;
+use warnings;
+
+use Cpanel::JSON::XS qw< decode_json >;
+use Getopt::Long;
+use MetaCPAN::Mapper;
+use MetaCPAN::Ingest qw< home >;
+
+my ( $index, $cmd );
+GetOptions(
+    "index=s" => \$index,
+    "cmd=s"   => \$cmd,
+);
+die "cmd can only be one of: 'create', 'delete'\n"
+    unless grep { $cmd eq $_ } qw< create delete >;
+
+# setup
+my $type = $index;
+
+my $mapper = MetaCPAN::Mapper->new();
+
+$mapper->index_delete($index)
+    if $mapper->index_exists($index);
+
+if ( $cmd eq 'create' ) {
+    my $home = home();
+    my $map_file = $home->child('conf/es/' . $index . '/mapping.json');
+    my $mapping = decode_json $map_file->slurp();
+
+    $mapper->index_create($index);
+    $mapper->index_put_mapping($index, $type, $mapping);
+}

lib/MetaCPAN/Ingest.pm

@@ -8,7 +8,8 @@ use Cpanel::JSON::XS;
 use Digest::SHA;
 use Encode qw< decode_utf8 >;
 use IO::Prompt::Tiny qw< prompt >;
-use IPC::Run3 ();
+use File::Basename ();
+use File::Spec ();
 use LWP::UserAgent;
 use Path::Tiny qw< path >;
 use PAUSE::Permissions ();
@@ -183,17 +184,14 @@ sub handle_error ( $exit_code, $error, $die_always ) {
 }
 
 sub home () {
-    IPC::Run3::run3(
-        [ qw< git rev-parse --show-toplevel > ], # TODO: use alternative persistent path that's accessible from the container
-        \undef, \my $stdout, \my $stderr
-    );
-
-    die $stderr if ($?);
-
-    chomp $stdout;
-    die "Failed to find git dir: '$stdout'" unless -d $stdout;
-
-    return $stdout;
+    my $dir = Cwd::abs_path( File::Spec->catdir(
+        File::Basename::dirname(__FILE__),
+        ( File::Spec->updir ) x 2
+    ) );
+
+    my $path = path($dir);
+    die "Failed to find git dir: '$path'" unless $path;
+    return $path;
 }
 
 # TODO: there must be a better way

lib/MetaCPAN/Mapper.pm

@@ -0,0 +1,52 @@
+package MetaCPAN::Mapper;
+
+use strict;
+use warnings;
+use v5.36;
+
+use Path::Tiny qw< path >;
+use MetaCPAN::Logger qw< :log :dlog >;
+use Search::Elasticsearch;
+use MetaCPAN::Ingest qw< config home >;
+
+sub new ( $class, %args ) {
+    my $node = $args{node};
+
+    my $config = config;
+    $node ||= $config->{es_node};
+    $node or die "Cannot create an ES instance without a node\n";
+
+    return bless {
+        es => Search::Elasticsearch->new(
+            client => '2_0::Direct',
+            nodes  => [$node],
+        ),
+    }, $class;
+}
+
+sub index_exists ($self, $index) {
+    $self->{es}->indices->exists( index => $index );
+}
+
+sub index_create ($self, $index) {
+    $self->{es}->indices->create( index => $index );
+}
+
+sub index_delete ($self, $index) {
+    $self->{es}->indices->delete( index => $index );
+}
+
+sub index_put_mapping ($self, $index, $type, $mapping) {
+    $self->{es}->indices->put_mapping(
+        index => $index,
+        type  => $type,
+        body  => $mapping,
+    );
+}
+
+sub get_mapping ($self, $index) {
+#    my $home = home();
+#    my $file = $dir->child('');
+}
+
+1;