/*---------------------------------------------------------------------------------------------
 *  Copyright (c) Microsoft Corporation. All rights reserved.
 *  Licensed under the MIT License. See License.txt in the project root for license information.
 *--------------------------------------------------------------------------------------------*/

using System;
using System.Diagnostics;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Runtime.InteropServices;
using System.ComponentModel;
using Debug = UnityEngine.Debug;
using System.IO;
using SimpleJSON;
using System.Collections.Generic;
using System.Linq;

namespace Microsoft.Unity.VisualStudio.Editor
{
	internal class ProcessRunnerResult
	{
		public bool Success { get; set; }
		public string Output { get; set; }
		public string Error { get; set; }
	}

	internal static class ProcessRunner
	{
		public const int DefaultTimeoutInMilliseconds = 300000;

		public static ProcessStartInfo ProcessStartInfoFor(string filename, string arguments, bool redirect = true, bool shell = false)
		{
			return new ProcessStartInfo
			{
				UseShellExecute = shell,
				CreateNoWindow = true, 
				RedirectStandardOutput = redirect,
				RedirectStandardError = redirect,
				FileName = filename,
				Arguments = arguments
			};
		}

		public static void Start(string filename, string arguments)
		{
			Start(ProcessStartInfoFor(filename, arguments, false));
		}

		public static void Start(ProcessStartInfo processStartInfo)
		{
			var process = new Process { StartInfo = processStartInfo };

			using (process)
			{
				process.Start();
			}
		}

		public static ProcessRunnerResult StartAndWaitForExit(string filename, string arguments, int timeoutms = DefaultTimeoutInMilliseconds, Action<string> onOutputReceived = null)
		{
			return StartAndWaitForExit(ProcessStartInfoFor(filename, arguments), timeoutms, onOutputReceived);
		}

		public static ProcessRunnerResult StartAndWaitForExit(ProcessStartInfo processStartInfo, int timeoutms = DefaultTimeoutInMilliseconds, Action<string> onOutputReceived = null)
		{
			var process = new Process { StartInfo = processStartInfo };

			using (process)
			{
				var sbOutput = new StringBuilder();
				var sbError = new StringBuilder();

				var outputSource = new TaskCompletionSource<bool>();
				var errorSource = new TaskCompletionSource<bool>();
				
				process.OutputDataReceived += (_, e) =>
				{
					Append(sbOutput, e.Data, outputSource);
					if (onOutputReceived != null && e.Data != null)
						onOutputReceived(e.Data);
				};
				process.ErrorDataReceived += (_, e) => Append(sbError, e.Data, errorSource);

				process.Start();
				process.BeginOutputReadLine();
				process.BeginErrorReadLine();
				
				var run = Task.Run(() => process.WaitForExit(timeoutms));
				var processTask = Task.WhenAll(run, outputSource.Task, errorSource.Task);

				if (Task.WhenAny(Task.Delay(timeoutms), processTask).Result == processTask && run.Result)
					return new ProcessRunnerResult {Success = true, Error = sbError.ToString(), Output = sbOutput.ToString()};

				try
				{
					process.Kill();
				}
				catch
				{
					/* ignore */
				}
				
				return new ProcessRunnerResult {Success = false, Error = sbError.ToString(), Output = sbOutput.ToString()};
			}
		}

		private static void Append(StringBuilder sb, string data, TaskCompletionSource<bool> taskSource)
		{
			if (data == null)
			{
				taskSource.SetResult(true);
				return;
			}

			sb?.Append(data);
		}

		public static string[] GetProcessWorkspaces(Process process)
		{
			if (process == null)
				return null;

			try
			{
				var workspaces = new List<string>();
				var userProfile = Environment.GetFolderPath(Environment.SpecialFolder.UserProfile);
				string cursorStoragePath;

#if UNITY_EDITOR_OSX
				cursorStoragePath = Path.Combine(userProfile, "Library", "Application Support", "cursor", "User", "workspaceStorage");
#elif UNITY_EDITOR_LINUX
				cursorStoragePath = Path.Combine(userProfile, ".config", "cursor", "User", "workspaceStorage");
#else
				cursorStoragePath = Path.Combine(userProfile, "AppData", "Roaming", "cursor", "User", "workspaceStorage");
#endif
				
				Debug.Log($"[Cursor] Looking for workspaces in: {cursorStoragePath}");
				
				if (Directory.Exists(cursorStoragePath))
				{
					foreach (var workspaceDir in Directory.GetDirectories(cursorStoragePath))
					{
						try
						{
							var workspaceStatePath = Path.Combine(workspaceDir, "workspace.json");
							if (File.Exists(workspaceStatePath))
							{
								var content = File.ReadAllText(workspaceStatePath);
								if (!string.IsNullOrEmpty(content))
								{
									var workspace = JSONNode.Parse(content);
									if (workspace != null)
									{
										var folder = workspace["folder"];
										if (folder != null && !string.IsNullOrEmpty(folder.Value))
										{
											var workspacePath = folder.Value;
											if (workspacePath.StartsWith("file:///"))
											{
												workspacePath = Uri.UnescapeDataString(workspacePath.Substring(8));
												workspaces.Add(workspacePath);
											}
										}
									}
								}
							}

							var windowStatePath = Path.Combine(workspaceDir, "window.json");
							if (File.Exists(windowStatePath))
							{
								var content = File.ReadAllText(windowStatePath);
								if (!string.IsNullOrEmpty(content))
								{
									var windowState = JSONNode.Parse(content);
									if (windowState != null)
									{
										var workspace = windowState["workspace"];
										if (workspace != null && !string.IsNullOrEmpty(workspace.Value))
										{
											var workspacePath = workspace.Value;
											if (workspacePath.StartsWith("file:///"))
											{
												workspacePath = Uri.UnescapeDataString(workspacePath.Substring(8));
												workspaces.Add(workspacePath);
											}
										}
									}
								}
							}
						}
						catch (Exception ex)
						{
							Debug.LogWarning($"[Cursor] Error reading workspace state file: {ex.Message}");
							continue;
						}
					}
				}
				else
				{
					Debug.LogWarning($"[Cursor] Workspace storage directory not found: {cursorStoragePath}");
				}

				return workspaces.Distinct().ToArray();
			}
			catch (Exception ex)
			{
				Debug.LogError($"[Cursor] Error getting workspace directory: {ex.Message}");
				return null;
			}
		}
	}
}