From 1152c50f3a546d0349163a9faf4e58a752698a93 Mon Sep 17 00:00:00 2001
From: digimer <mkelly@alteeve.ca>
Date: Tue, 16 Apr 2024 00:43:58 -0400
Subject: [PATCH] Added pcsd config, and -y support.

Signed-off-by: digimer <mkelly@alteeve.ca>
---
 tools/anvil-join-anvil | 71 +++++++++++++++++++++++++++++++++++++-----
 1 file changed, 64 insertions(+), 7 deletions(-)

diff --git a/tools/anvil-join-anvil b/tools/anvil-join-anvil
index 202297b5..da7ad137 100755
--- a/tools/anvil-join-anvil
+++ b/tools/anvil-join-anvil
@@ -344,13 +344,20 @@ sub process_rejoin
 		print "[ Warning ] - Be certain the old host will NOT come back! If it does, it can\n";
 		print "              cause confusion with the Anvil! node!\n";
 	}
-	print $anvil->Words->string({key => "message_0021"})." ";
-	my $answer = <STDIN>;
-	chomp($answer);
-	if ($answer !~ /^y/i)
+	if (($anvil->data->{switches}{y}) or ($anvil->data->{switches}{yes}))
 	{
-		print $anvil->Words->string({key => "message_0022"})."\n";
-		$anvil->nice_exit({exit_code => 0});
+		print "[ Note ] - Confirmed by switch, proceeding.\b";
+	}
+	else
+	{
+		print $anvil->Words->string({key => "message_0021"})." ";
+		my $answer = <STDIN>;
+		chomp($answer);
+		if ($answer !~ /^y/i)
+		{
+			print $anvil->Words->string({key => "message_0022"})."\n";
+			$anvil->nice_exit({exit_code => 0});
+		}
 	}
 	
 	# If this isn't a rebuild, purge the old host.
@@ -367,7 +374,14 @@ sub process_rejoin
 		{
 			print "[ Note ] - Purging the old host: [".$old_host_uuid."] from the database.\n";
 			print "[ Note ] - Please be patient!\n";
-			my $shell_call = $anvil->data->{path}{exe}{'striker-purge-target'}."  ".$anvil->Log->switches,
+			my $shell_call = $anvil->data->{path}{exe}{'striker-purge-target'}."  ".$anvil->Log->switches;
+			$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 2, list => { shell_call => $shell_call }});
+			
+			my ($output, $return_code) = $anvil->System->call({debug => 3, shell_call => $shell_call});
+			$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 2, list => { 
+				output      => $output,
+				return_code => $return_code, 
+			}});
 		}
 	}
 	
@@ -1053,6 +1067,49 @@ sub configure_pacemaker
 				}
 			}
 		}
+		
+		### TODO: Left off here; parse 'pcs cluster status' and if there's 'Unable to authenticate', re-auth.
+		my $auth       = 0;
+		my $shell_call = $anvil->data->{path}{exe}{pcs}." cluster status";
+		$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 2, list => { shell_call => $shell_call }});
+		
+		my ($output, $return_code) = $anvil->System->call({debug => 3, shell_call => $shell_call});
+		$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 2, list => { 
+			output      => $output,
+			return_code => $return_code, 
+		}});
+		
+		my $in_pcsd = 0;
+		foreach my $line (split/\n/, $output)
+		{
+			$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 2, list => { line => $line }});
+			if ($in_pcsd)
+			{
+				if ($line =~ /Unable to authenticate/i)
+				{
+					$auth = 1;
+					$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 2, list => { auth => $auth }});
+				}
+			}
+			if ($line =~ /PCSD Status/i)
+			{
+				$in_pcsd = 1;
+				$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 2, list => { in_pcsd => $in_pcsd }});
+			}
+			last if $auth;
+		}
+		if ($auth)
+		{
+			# Also, re-auth. We need to run this on both hosts.
+			my $shell_call = $anvil->data->{path}{exe}{pcs}." host auth ".$node1_host_name." ".$node2_host_name." -u hacluster -p ".$escaped_password;
+			$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 2, secure => 1, list => { shell_call => $shell_call }});
+			
+			my ($output, $return_code) = $anvil->System->call({secure => 1, shell_call => $shell_call});
+			$anvil->Log->variables({source => $THIS_FILE, line => __LINE__, level => 2, list => { 
+				output      => $output,
+				return_code => $return_code, 
+			}});
+		}
 	}
 	else
 	{