Clipboard functionality improvements; added option to disable it; misc improvements

Author: Decimation

SmartImage 3/App/Integration.cs

@@ -227,7 +227,8 @@ public static void KeepOnTop(bool add)
 
 	public static bool ReadClipboardImage(out byte[] i)
 	{
-		const uint png            = (uint) ClipboardFormat.PNG;
+		const uint png = (uint) ClipboardFormat.PNG;
+
 		// var        sb = new StringBuilder(2048);
 		// var l=Native.GetClipboardFormatName(png, sb, sb.Length);
 		// Debug.WriteLine($"{sb} {l}");
@@ -244,6 +245,11 @@ public static bool ReadClipboardImage(out byte[] i)
 	public static bool ReadClipboard(out string str)
 	{
 		Clipboard.Open();
+
+		/*
+		 * 1	File
+		 */
+
 		var data = Clipboard.GetData((uint) ClipboardFormat.FileNameW);
 
 		if (data is IntPtr { } p && p == IntPtr.Zero) {
@@ -253,17 +259,35 @@ public static bool ReadClipboard(out string str)
 			str = (string) data;
 		}
 
+		if (!string.IsNullOrWhiteSpace(str)) goto cl;
+
+		/*
+		 * 3	Text
+		 */
+
 		if (!SearchQuery.IsValidSourceType(str)) {
-			var o = Clipboard.GetData((uint) ClipboardFormat.CF_TEXT);
+			var o = Clipboard.GetData((uint) ClipboardFormat.CF_UNICODETEXT);
 
 			if ((data is IntPtr { } p2 && p2 == IntPtr.Zero) || o is IntPtr data2 && data2 == IntPtr.Zero) {
 				str = null;
 			}
 			else {
 				str = (string) o;
 			}
+
+			if (o is nint n && n != nint.Zero) {
+				// str = (string) o;
+
+				str = Marshal.PtrToStringUni(n);
+			}
+
+			if (!string.IsNullOrWhiteSpace(str)) goto cl;
 		}
 
+		/*
+		 * 3	Screenshot
+		 */
+
 		if (ReadClipboardImage(out var ms)) {
 			//todo: delete on exit
 			var s = Path.Combine(Path.GetTempPath(), $"clipboard_{ms.Length}.png");
@@ -276,8 +300,9 @@ public static bool ReadClipboard(out string str)
 			Debug.WriteLine($"read png from clipboard {s}");
 		}
 
+		cl:
 		Clipboard.Close();
-		// Debug.WriteLine($"Clipboard data: {str}");
+		Debug.WriteLine($"Clipboard data: {str}");
 
 		var b = SearchQuery.IsValidSourceType(str);
 		return b;

SmartImage 3/Mode/Shell/ShellMode.Dialog.cs

@@ -270,8 +270,8 @@ void ReloadDialog()
 
 		CheckBox cbCb = new(R1.S_Clipboard)
 		{
-			X = Pos.Right(cbOpenRaw) + 1,
-			Y = Pos.Y(cbOpenRaw),
+			X = Pos.X(cbContextMenu) ,
+			Y = Pos.Bottom(cbContextMenu)+1,
 			// Width  = WIDTH,
 			Height      = 1,
 			AutoSize    = true,
@@ -290,8 +290,8 @@ Eh username/password
 
 		Label lbEhUsername = new(R1.S_EhUsername)
 		{
-			X           = Pos.X(cbContextMenu),
-			Y           = Pos.Bottom(cbContextMenu) + 1,
+			X           = Pos.X(cbCb),
+			Y           = Pos.Bottom(cbCb) + 1,
 			CanFocus    = false,
 			ColorScheme = UI.Cs_Lbl1
 		};

SmartImage 3/Mode/Shell/ShellMode.Handlers.cs

@@ -21,7 +21,6 @@ namespace SmartImage.Mode.Shell;
 
 public sealed partial class ShellMode
 {
-
 	/// <summary>
 	/// <see cref="Tv_Results"/>
 	/// </summary>
@@ -48,12 +47,14 @@ private async void Input_TextChanging(TextChangingEventArgs tc)
 	{
 		var text = tc.NewText;
 
-		// Debug.WriteLine($"testing {text}", nameof(Input_TextChanging));
+		Debug.WriteLine($"testing {text}", nameof(Input_TextChanging));
+
+		Application.MainLoop.Invoke(() => Task.Delay(TimeSpan.FromSeconds(1)));
 
 		if (SearchQuery.IsValidSourceType(text.ToString())) {
 			var ok = await SetQuery(text);
 			Btn_Run.Enabled = ok;
-			
+			Debug.WriteLine($"{nameof(Input_TextChanging)} :: ok");
 		}
 	}
 
@@ -73,6 +74,8 @@ private void Restart_Clicked(bool force = false)
 		Dt_Results.Clear();
 		Tv_Results.Visible = false;
 
+		// m_clipboard.RemoveRange(1, m_clipboard.Count - 1);
+
 		m_clipboard.Clear();
 		m_results.Clear();
 

SmartImage 3/Mode/Shell/ShellMode.cs

@@ -234,6 +234,17 @@ static ShellMode() { }
 
 	#endregion
 
+	#region Static
+
+	private static readonly TimeSpan TimeoutTimeSpan = TimeSpan.FromSeconds(1.5);
+
+	[SupportedOSPlatform(Compat.OS)]
+	private static readonly SoundPlayer Player = new(R2.hint);
+
+	private static readonly ILogger Logger = LogUtil.Factory.CreateLogger(nameof(ShellMode));
+
+	#endregion
+
 	#region Fields/properties
 
 	private object m_cbCallbackTok;
@@ -247,6 +258,7 @@ static ShellMode() { }
 	private readonly ConcurrentBag<SearchResult> m_results;
 
 	private CancellationTokenSource m_token;
+	private CancellationTokenSource m_tokenu;
 
 	private bool m_useclipboard;
 
@@ -271,17 +283,6 @@ public bool UseClipboard
 
 	private readonly ConcurrentQueue<ustring> m_queue;
 
-	#region Static
-
-	private static readonly TimeSpan TimeoutTimeSpan = TimeSpan.FromSeconds(1.5);
-
-	[SupportedOSPlatform(Compat.OS)]
-	private static readonly SoundPlayer Player = new(R2.hint);
-
-	private static readonly ILogger Logger = LogUtil.Factory.CreateLogger(nameof(ShellMode));
-
-	#endregion
-
 	#region
 
 	public SearchQuery Query { get; internal set; }
@@ -308,6 +309,7 @@ public ShellMode(string[] args)
 	{
 		Args    = args;
 		m_token = new();
+		m_tokenu = new();
 		Query   = SearchQuery.Null;
 		Client  = new SearchClient(new SearchConfig());
 		IsReady = new ManualResetEvent(false);
@@ -633,17 +635,27 @@ private async Task<bool> SetQuery(ustring text)
 		if (sq is { } && sq != SearchQuery.Null) {
 			try {
 
+				/*Btn_Cancel.Enabled = true;
+
+				Btn_Cancel.Clicked += () =>
+				{
+					m_tokenu.Cancel();
+
+				};*/
+
 				using CancellationTokenSource cts = new();
 				Lbl_Status2.Text = $"Uploading...";
 
 				UI.QueueProgress(cts, Pbr_Status);
 
-				var u = await sq.UploadAsync();
+				var u = await sq.UploadAsync(ct: m_tokenu.Token);
 
 				cts.Cancel();
 
-				Lbl_QueryUpload.Text = u.ToString();
-				Lbl_Status2.Text     = ustring.Empty;
+				Lbl_QueryUpload.Text =  u.ToString();
+				Lbl_Status2.Text     =  ustring.Empty;
+				
+				// Btn_Cancel.Clicked   += Cancel_Clicked;
 
 			}
 			catch (Exception e) {
@@ -707,7 +719,7 @@ private async Task<bool> SetQuery(ustring text)
 
 	private bool ClipboardCallback(MainLoop c)
 	{
-		Debug.WriteLine($"executing timeout {nameof(ClipboardCallback)} {c} {UseClipboard} {c.EventsPending(false)}");
+		Debug.WriteLine($"executing timeout {nameof(ClipboardCallback)} {c} {UseClipboard}");
 
 		try {
 			/*
@@ -721,8 +733,10 @@ private bool ClipboardCallback(MainLoop c)
 			var s = Tf_Input.Text.ToString();
 			s = s.CleanString();
 
-			if (!SearchQuery.IsValidSourceType(s)
-			    && Integration.ReadClipboard(out var str)
+			var rc = Integration.ReadClipboard(out var str);
+
+			if (/*!SearchQuery.IsValidSourceType(s)
+			    &&*/ rc
 			    && !m_clipboard.Contains(str)
 			    /*&& (m_prevSeq != sequenceNumber)*/) {
 				/*bool vl = SearchQuery.IsValidSourceType(str);
@@ -735,7 +749,7 @@ private bool ClipboardCallback(MainLoop c)
 				}
 
 				Debug.WriteLine($"{str}");*/
-
+				
 				SetInputText(str);
 				// Lbl_InputOk.Text   = UI.Clp;
 				Lbl_InputInfo.Text = R2.Inf_Clipboard;
@@ -758,16 +772,17 @@ private bool ClipboardCallback(MainLoop c)
 
 		finally { }
 
-		Debug.WriteLine($"{UseClipboard}");
-		// return true;
-		return UseClipboard;
+		// Debug.WriteLine($"{UseClipboard}");
+		return true;
+		// return UseClipboard;
 	}
 
 	public void Dispose()
 	{
 		Client.Dispose();
 		Query.Dispose();
 		m_token.Dispose();
+		m_tokenu.Dispose();
 		m_queue.Clear();
 		m_results.Clear();
 	}

SmartImage.Lib 3/Engines/IEndpoint.cs

@@ -0,0 +1,30 @@
+// Read S SmartImage.Lib IEndpoint.cs
+// 2023-05-12 @ 1:01 AM
+
+using System.Collections.Concurrent;
+using Flurl.Http;
+
+namespace SmartImage.Lib.Engines;
+
+public interface IEndpoint
+{
+	public Url EndpointUrl { get; }
+
+	[ICBN]
+	public static async ValueTask<T[]> QueryAlive<T>(T[] rg, CancellationToken ct = default) where T : IEndpoint
+	{
+		var cb = new ConcurrentBag<T>();
+
+		await Parallel.ForEachAsync(rg, ct, async (b, c) =>
+		{
+			var u = ((Url) b.EndpointUrl).Root;
+			var r = await u.HeadAsync(ct);
+
+			if (r.ResponseMessage.IsSuccessStatusCode) {
+				cb.Add(b);
+			}
+		});
+
+		return cb.ToArray();
+	}
+}

SmartImage.Lib 3/Engines/Impl/Upload/BaseUploadEngine.cs

@@ -1,10 +1,13 @@
-using Flurl.Http;
+using System.Diagnostics;
+using System.Net.NetworkInformation;
+using Flurl.Http;
 using Novus.OS;
 using Novus.Utilities;
+using SmartImage.Lib.Utilities;
 
 namespace SmartImage.Lib.Engines.Impl.Upload;
 
-public abstract class BaseUploadEngine
+public abstract class BaseUploadEngine : IEndpoint
 {
 	/// <summary>
 	/// Max file size, in bytes
@@ -13,16 +16,16 @@ public abstract class BaseUploadEngine
 
 	public abstract string Name { get; }
 
-	protected string EndpointUrl { get; }
+	public Url EndpointUrl { get; }
 
 	protected BaseUploadEngine(string s)
 	{
 		EndpointUrl = s;
 	}
 
-	public static BaseUploadEngine Default { get; } = new LitterboxEngine();
+	// public static BaseUploadEngine Default { get; } = new LitterboxEngine();
 
-	public abstract Task<Url> UploadFileAsync(string file);
+	public abstract Task<Url> UploadFileAsync(string file, CancellationToken ct = default);
 
 	public long Size { get; set; }
 
@@ -36,38 +39,46 @@ private protected bool IsFileSizeValid(string file)
 
 	protected void Verify(string file)
 	{
-		if (string.IsNullOrWhiteSpace(file))
-		{
+		if (string.IsNullOrWhiteSpace(file)) {
 			throw new ArgumentNullException(nameof(file));
 		}
 
-		if (!IsFileSizeValid(file))
-		{
+		if (!IsFileSizeValid(file)) {
 			throw new ArgumentException($"File {file} is too large (max {MaxSize}) for {Name}");
 		}
 	}
 
 	public static readonly BaseUploadEngine[] All =
 		ReflectionHelper.CreateAllInAssembly<BaseUploadEngine>(TypeProperties.Subclass).ToArray();
+
+	public static async ValueTask<BaseUploadEngine[]> UpdateAlive()
+	{
+		var a = await IEndpoint.QueryAlive(All);
+		
+		Default = a?.FirstOrDefault();
+
+		return a;
+	}
+	
+	public static BaseUploadEngine Default { get; set; } = new CatboxEngine();
 }
 
 public abstract class BaseCatboxEngine : BaseUploadEngine
 {
-	
-	public override async Task<Url> UploadFileAsync(string file)
+	public override async Task<Url> UploadFileAsync(string file, CancellationToken ct = default)
 	{
 		Verify(file);
 
 		using var response = await EndpointUrl
-								 .PostMultipartAsync(mp =>
-														 mp.AddFile("fileToUpload", file)
-															 .AddString("reqtype", "fileupload")
-															 .AddString("time", "1h")
-								 );
+			                     .PostMultipartAsync(mp =>
+				                                         mp.AddFile("fileToUpload", file)
+					                                         .AddString("reqtype", "fileupload")
+					                                         .AddString("time", "1h")
+			                     , ct);
 
 		var responseMessage = response.ResponseMessage;
 
-		var content = await responseMessage.Content.ReadAsStringAsync();
+		var content = await responseMessage.Content.ReadAsStringAsync(ct);
 
 		/*if (!responseMessage.IsSuccessStatusCode) {