/* SPDX-License-Identifier: Apache-2.0
*
* The OpenSearch Contributors require contributions made to
* this file be licensed under the Apache-2.0 license or a
* compatible open source license.
*/
/*
* Modifications Copyright OpenSearch Contributors. See
* GitHub history for details.
*
*  Licensed to Elasticsearch B.V. under one or more contributor
*  license agreements. See the NOTICE file distributed with
*  this work for additional information regarding copyright
*  ownership. Elasticsearch B.V. licenses this file to you 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.
*/

using System.IO;
using OpenSearch.OpenSearch.Managed.ConsoleWriters;
using OpenSearch.OpenSearch.Managed.FileSystem;

namespace OpenSearch.OpenSearch.Ephemeral.Tasks.BeforeStartNodeTasks
{
	public class CreateEphemeralDirectory : ClusterComposeTask
	{
		public override void Run(IEphemeralCluster<EphemeralClusterConfiguration> cluster)
		{
			var fs = cluster.FileSystem;
			if (!(fs is EphemeralFileSystem f))
			{
				cluster.Writer?.WriteDiagnostic(
					$"{{{nameof(CreateEphemeralDirectory)}}} unexpected IFileSystem implementation {{{fs.GetType()}}}");
				return;
			}

			cluster.Writer?.WriteDiagnostic($"{{{nameof(CreateEphemeralDirectory)}}} creating {{{f.TempFolder}}}");

			Directory.CreateDirectory(f.TempFolder);

			if (!Directory.Exists(f.ConfigPath))
			{
				cluster.Writer?.WriteDiagnostic(
					$"{{{nameof(CreateEphemeralDirectory)}}} creating config folder {{{f.ConfigPath}}}");
				Directory.CreateDirectory(f.ConfigPath);
			}

			CopyHomeConfigToEphemeralConfig(cluster, f, fs);
		}

		private static void CopyHomeConfigToEphemeralConfig(IEphemeralCluster<EphemeralClusterConfiguration> cluster,
			EphemeralFileSystem ephemeralFileSystem, INodeFileSystem fs)
		{
			var target = ephemeralFileSystem.ConfigPath;
			var cachedOpenSearchHomeFolder = Path.Combine(fs.LocalFolder, cluster.GetCacheFolderName());
			var cachedOpenSearchYaml = Path.Combine(cachedOpenSearchHomeFolder, "config", "opensearch.yaml");

			var homeSource =
				cluster.ClusterConfiguration.CacheOpenSearchHomeInstallation && File.Exists(cachedOpenSearchYaml)
					? cachedOpenSearchHomeFolder
					: fs.OpenSearchHome;
			var source = Path.Combine(homeSource, "config");
			if (!Directory.Exists(source))
			{
				cluster.Writer?.WriteDiagnostic(
					$"{{{nameof(CreateEphemeralDirectory)}}} source config {{{source}}} does not exist nothing to copy");
				return;
			}

			cluster.Writer?.WriteDiagnostic(
				$"{{{nameof(CreateEphemeralDirectory)}}} copying cached {{{source}}} as to [{target}]");
			CopyFolder(source, target);
		}
	}
}