Option -safe added to dx_ctl_replication to allow a check for VDB deletion before replication

Author: Marcin Przepiorowski

bin/dx_ctl_replication.pl

@@ -1,24 +1,24 @@
-# 
+#
 # Licensed under the Apache License, Version 2.0 (the "License");
 # you may not use this file except in compliance with the License.
 # You may obtain a copy of the License at
-# 
+#
 #     http://www.apache.org/licenses/LICENSE-2.0
-# 
+#
 # Unless required by applicable law or agreed to in writing, software
 # distributed under the License is distributed on an "AS IS" BASIS,
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
 # Copyright (c) 2015,2016 by Delphix. All rights reserved.
-# 
+#
 # Program Name : dx_ctl_replication.pl
 # Description  : Get information about replication
 # Author       : Marcin Przepiorowski
 # Created      : 28 Sept 2016 (v2.2.0)
 #
-# 
+#
 
 use strict;
 use warnings;
@@ -40,19 +40,20 @@
 my $version = $Toolkit_helpers::version;
 
 GetOptions(
-  'help|?' => \(my $help), 
+  'help|?' => \(my $help),
   'd|engine=s' => \(my $dx_host),
   'profilename=s' => \(my $profilename),
-  'nowait' => \(my $nowait),  
-  'debug:i' => \(my $debug), 
+  'nowait' => \(my $nowait),
+  'debug:i' => \(my $debug),
   'dever=s' => \(my $dever),
+  'safe' => \(my $safe),
   'all' => (\my $all),
   'version' => \(my $print_version),
   'configfile|c=s' => \(my $config_file)
 ) or pod2usage(-verbose => 1,  -input=>\*DATA);
 
 pod2usage(-verbose => 2,  -input=>\*DATA) && exit if $help;
-die  "$version\n" if $print_version;   
+die  "$version\n" if $print_version;
 
 my $engine_obj = new Engine ($dever, $debug);
 $engine_obj->load_config($config_file);
@@ -67,12 +68,12 @@
 if (!defined($profilename)) {
   print "Profile name is mandatory. Please specify -profilename parameter \n";
   pod2usage(-verbose => 1,  -input=>\*DATA);
-  exit (1);  
+  exit (1);
 }
 
 
 # this array will have all engines to go through (if -d is specified it will be only one engine)
-my $engine_list = Toolkit_helpers::get_engine_list($all, $dx_host, $engine_obj); 
+my $engine_list = Toolkit_helpers::get_engine_list($all, $dx_host, $engine_obj);
 
 my $ret = 0;
 
@@ -92,26 +93,51 @@
   }
   my $jobno;
   if (defined($ref)) {
-    $jobno = $replication->replicate($ref);
-  }
-  
-  if (defined($nowait)) {
-    if (defined($jobno)) {
-      print "Replication job $jobno started in background\n";
-    } else {
-      print "Problem with defining a replication job. Please run with -debug\n";
+
+    if (defined($safe)) {
+      my $lastjob = $replication->getLastJob($ref, 1);
+      my $actions = new Action_obj($engine_obj, $lastjob->{StartTime}, undef, undef, undef, $debug);
+      $actions->loadActionList();
+      my @deletelist = @{$actions->getActionList('asc', 'DB_DELETE', undef)};
+
+      if (scalar(@deletelist)>0) {
+        print "There was a delete database operation on primary engine. List of databases:\n";
+        my $name;
+        for my $ar (@deletelist) {
+          $name = $actions->getDetails($ar);
+          $name =~ s/Delete dataset//;
+          $name =~ s/"//g;
+          $name =~ s/\.//;
+          print Toolkit_helpers::trim($name) . "\n";
+        }
+        print "Replication won't be kicked off\n";
+        $ret = $ret + 1;
+        next;
+      }
+
     }
-  } else {
-    if (defined($jobno)) {
-      print "Starting replication job $jobno\n";
-      $ret = $ret + Toolkit_helpers::waitForJob($engine_obj, $jobno, "Replication job finished","Problem with replication");
+
+    $jobno = $replication->replicate($ref);
+    if (defined($nowait)) {
+      if (defined($jobno)) {
+        print "Replication job $jobno started in background\n";
+      } else {
+        print "Problem with defining a replication job. Please run with -debug\n";
+      }
     } else {
-      print "Problem with defining a replication job. Please run with -debug\n";
+      if (defined($jobno)) {
+        print "Starting replication job $jobno\n";
+        $ret = $ret + Toolkit_helpers::waitForJob($engine_obj, $jobno, "Replication job finished","Problem with replication");
+      } else {
+        print "Problem with defining a replication job. Please run with -debug\n";
+      }
     }
   }
 
 
 
+
+
 }
 
 
@@ -122,10 +148,10 @@
 
 =head1 SYNOPSIS
 
- dx_ctl_replication [-engine|d <delphix identifier> | -all ] 
-                     -profilename profile 
-                     [-nowait] 
-                     [-help|?] 
+ dx_ctl_replication [-engine|d <delphix identifier> | -all ]
+                     -profilename profile
+                     [-nowait]
+                     [-help|?]
                      [-debug ]
 
 =head1 DESCRIPTION
@@ -160,10 +186,10 @@ =head1 OPTIONS
 
 =over 3
 
-=item B<-nowait>                                                                                                                                            
+=item B<-nowait>
 Don't wait for a replication job to complete. Job will be running in backgroud.
 
-=item B<-help>          
+=item B<-help>
 Print this screen
 
 =item B<-debug>
@@ -179,6 +205,3 @@ =head1 Example
   Replication job JOB-7425 started in background
 
 =cut
-
-
-