From 22bfec8c2412bbb983a865fdeb6e2fc0401f9221 Mon Sep 17 00:00:00 2001
From: yggverse <yggverse@project>
Date: Sun, 19 Jan 2025 06:23:06 +0200
Subject: [PATCH] move resolver features to client

---
 .../window/tab/item/page/client/request.rs    | 38 +++++++++++++
 .../tab/item/page/navigation/request.rs       | 55 +------------------
 2 files changed, 40 insertions(+), 53 deletions(-)

diff --git a/src/app/browser/window/tab/item/page/client/request.rs b/src/app/browser/window/tab/item/page/client/request.rs
index a8c56587..a50fcf04 100644
--- a/src/app/browser/window/tab/item/page/client/request.rs
+++ b/src/app/browser/window/tab/item/page/client/request.rs
@@ -117,3 +117,41 @@ impl Request {
 pub fn search(query: &str) -> Request {
     Request::from_uri(search::tgls(query), None, None).unwrap() // no handler as unexpected
 }
+
+/// Asynchronously check request string contain resolvable query
+/// * useful for scheme-less requests, before do search redirect
+fn lookup(
+    query: &str,
+    cancellable: Option<&Cancellable>,
+    callback: impl FnOnce(Request) + 'static,
+) {
+    use gtk::{
+        gio::{NetworkAddress, Resolver},
+        prelude::{NetworkAddressExt, ResolverExt},
+    };
+
+    const DEFAULT_SCHEME: &str = "gemini://";
+    const DEFAULT_PORT: u16 = 1965;
+    const TIMEOUT: u32 = 500;
+
+    let request = match query.trim().strip_prefix(DEFAULT_SCHEME) {
+        Some(postfix) => format!("{DEFAULT_SCHEME}{postfix}"),
+        None => query.to_string(),
+    };
+
+    let resolver = Resolver::default();
+    resolver.set_timeout(TIMEOUT);
+
+    match NetworkAddress::parse_uri(&request, DEFAULT_PORT) {
+        Ok(connectable) => {
+            resolver.lookup_by_name_async(&connectable.hostname(), cancellable, move |resolve| {
+                callback(if resolve.is_ok() {
+                    search(&request) // @TODO begin direct request
+                } else {
+                    search(&request)
+                })
+            })
+        }
+        Err(_) => callback(search(&request)),
+    }
+}
diff --git a/src/app/browser/window/tab/item/page/navigation/request.rs b/src/app/browser/window/tab/item/page/navigation/request.rs
index f29e1155..7f044b03 100644
--- a/src/app/browser/window/tab/item/page/navigation/request.rs
+++ b/src/app/browser/window/tab/item/page/navigation/request.rs
@@ -6,9 +6,8 @@ use widget::Widget;
 
 use crate::app::browser::{window::tab::item::Action as TabAction, Action as BrowserAction};
 use gtk::{
-    gio::{Cancellable, NetworkAddress, Resolver},
     glib::{gformat, GString, Uri, UriFlags},
-    prelude::{EditableExt, NetworkAddressExt, ResolverExt},
+    prelude::EditableExt,
 };
 use sqlite::Transaction;
 use std::rc::Rc;
@@ -103,28 +102,6 @@ impl Request {
         self.widget.entry.set_text(&self.source());
     }
 
-    /// Asynchronously try replace `Self` entry value with valid, resolvable Gemini request
-    /// * callback with `None` if current value does not compatible with Gemini scheme
-    pub fn to_gemini_async(
-        &self,
-        resolver_timeout: u32,
-        cancellable: Option<&Cancellable>,
-        callback: impl FnOnce(Option<GString>) + 'static,
-    ) {
-        self.gemini_async(resolver_timeout, cancellable, {
-            let entry = self.widget.entry.clone();
-            move |result| {
-                callback(match result {
-                    Some(url) => {
-                        entry.set_text(&url);
-                        Some(url)
-                    }
-                    None => None,
-                })
-            }
-        });
-    }
-
     // Getters
 
     /// Get current request value in [Uri](https://docs.gtk.org/glib/struct.Uri.html) format
@@ -151,34 +128,6 @@ impl Request {
     pub fn source(&self) -> GString {
         gformat!("source:{}", self.strip_prefix())
     }
-
-    /// Asynchronously get valid, resolvable Gemini request for current `Self` entry value
-    /// * callback with `None` if current value does not compatible with Gemini scheme
-    pub fn gemini_async(
-        &self,
-        resolver_timeout: u32,
-        cancellable: Option<&Cancellable>,
-        callback: impl FnOnce(Option<GString>) + 'static,
-    ) {
-        // suggest scheme
-        let url = gformat!("gemini://{}", self.strip_prefix().trim());
-
-        // setup default resolver
-        // * wanted to detect value contain **resolvable** hostname
-        let resolver = Resolver::default();
-        resolver.set_timeout(resolver_timeout);
-
-        // is connectable
-        if let Ok(connectable) = NetworkAddress::parse_uri(&url, 1965) {
-            // is resolvable
-            resolver.lookup_by_name_async(&connectable.hostname(), cancellable, move |result| {
-                callback(match result {
-                    Ok(_) => Some(url),
-                    Err(_) => None,
-                })
-            })
-        }
-    }
 }
 
 // Tools
@@ -195,7 +144,7 @@ pub fn strip_prefix(mut request: GString) -> GString {
     };
 
     request
-}
+} // @TODO move prefix features to page client
 
 pub fn migrate(tx: &Transaction) -> Result<(), String> {
     // Migrate self components