Merge pull request #23040 from Amrysliu/jsc_10562

Collect and upload y2logs from iscsi server in cloud

Author: Amrysliu

lib/sles4sap/qesap/qesapdeployment.pm

@@ -81,6 +81,7 @@ our @EXPORT = qw(
   qesap_cluster_logs
   qesap_upload_crm_report
   qesap_supportconfig_logs
+  qesap_save_y2logs
   qesap_add_server_to_hosts
   qesap_calculate_deployment_name
   qesap_export_instances
@@ -1386,6 +1387,9 @@ sub qesap_cluster_logs {
             # Upload crm report
             qesap_upload_crm_report(host => $host, provider => $provider, failok => 1);
         }
+
+        # Collect logs in iscsi service node if there is.
+        qesap_save_y2logs(provider => $provider, host => 'iscsi[0]', failok => 1) if (script_run("grep -q 'iscsi' $inventory") == 0);
     }
 
     if ($provider eq 'AZURE') {
@@ -1397,6 +1401,53 @@ sub qesap_cluster_logs {
     }
 }
 
+=head3 qesap_save_y2logs
+
+  Collect y2logs from nodes of a deployed cluster
+
+=over
+
+=item B<PROVIDER> - Cloud provider name using same format of PUBLIC_CLOUD_PROVIDER setting
+
+=item B<HOST> - node of a deployed cluster
+
+=back
+=cut
+
+sub qesap_save_y2logs {
+    my (%args) = @_;
+    foreach (qw(provider host)) { croak "Missing mandatory $_ argument" unless $args{$_}; }
+    $args{failok} //= 0;
+
+    my $log_filename = "$args{host}-y2logs.tar.gz";
+
+    $log_filename =~ s/[\[\]"]//g;
+
+    qesap_ansible_cmd(cmd => "sudo save_y2logs /tmp/$log_filename",
+        provider => $args{provider},
+        filter => "\"$args{host}\"",
+        host_keys_check => 1,
+        verbose => 1,
+        timeout => bmwqemu::scale_timeout(7200),
+        failok => $args{failok});
+    qesap_ansible_cmd(cmd => "sudo chmod 755 /tmp/$log_filename",
+        provider => $args{provider},
+        filter => "\"$args{host}\"",
+        host_keys_check => 1,
+        verbose => 1,
+        timeout => bmwqemu::scale_timeout(7200),
+        failok => $args{failok});
+    my $local_path = qesap_ansible_fetch_file(provider => $args{provider},
+        host => $args{host},
+        failok => $args{failok},
+        root => 1,
+        remote_path => '/tmp/',
+        out_path => '/tmp/ansible_script_output/',
+        file => "$log_filename",
+        verbose => 1);
+    upload_logs($local_path, failok => 1);
+}
+
 =head3 qesap_supportconfig_logs
 
   Collect supportconfig logs from all HANA nodes of a deployed cluster

t/09_qesapdeployment.t

@@ -784,6 +784,7 @@ subtest '[qesap_cluster_logs]' => sub {
     $qesap->redefine(upload_logs => sub { push @save_file_calls, $_[0]; return; });
     $qesap->redefine(qesap_cluster_log_cmds => sub { return ({Cmd => 'crm status', Output => 'crm_status.txt'}); });
     $qesap->redefine(qesap_upload_crm_report => sub { my (%args) = @_; push @crm_report_calls, $args{host}; return 0; });
+    $qesap->redefine(qesap_save_y2logs => sub { return 0; });
     my $cloud_provider = 'NEMO';
     set_var('PUBLIC_CLOUD_PROVIDER', $cloud_provider);
 
@@ -817,6 +818,7 @@ subtest '[qesap_cluster_logs] multi log command' => sub {
     $qesap->redefine(upload_logs => sub { return; });
     $qesap->redefine(qesap_cluster_log_cmds => sub { return ({Cmd => 'crm status', Output => 'crm_status.txt', Logs => ['ignore_me.txt', 'ignore_me_too.txt']}); });
     $qesap->redefine(qesap_upload_crm_report => sub { return 0; });
+    $qesap->redefine(qesap_save_y2logs => sub { return 0; });
     my $cloud_provider = 'NEMO';
     set_var('PUBLIC_CLOUD_PROVIDER', $cloud_provider);
 
@@ -901,6 +903,26 @@ subtest '[qesap_supportconfig_logs]' => sub {
     ok($upload_log_called eq 1), 'upload_log called';
 };
 
+subtest '[qesap_save_y2logs]' => sub {
+    my $qesap = Test::MockModule->new('sles4sap::qesap::qesapdeployment', no_auto => 1);
+    my @calls;
+    my $upload_log_called = 0;
+
+    $qesap->redefine(qesap_ansible_cmd => sub {
+            my (%args) = @_;
+            push @calls, $args{cmd};
+            return 0; });
+    $qesap->redefine(qesap_ansible_fetch_file => sub { return 0; });
+    $qesap->redefine(upload_logs => sub { $upload_log_called = 1; return 0; });
+
+    qesap_save_y2logs(provider => 'SAND', host => 'boo');
+
+    note("\n  C-->  " . join("\n  C-->  ", @calls));
+    ok((any { /.*save_y2logs \/tmp\/boo-y2logs.*/ } @calls), 'save_y2logs is called');
+    ok((any { /.*chmod/ } @calls), 'chmod is called');
+    ok($upload_log_called eq 1, 'upload_log called');
+};
+
 subtest '[qesap_calculate_deployment_name]' => sub {
     my $qesap = Test::MockModule->new('sles4sap::qesap::qesapdeployment', no_auto => 1);
     $qesap->redefine(get_current_job_id => sub { return 42; });