From 6cb2f0ebea46124f6ac6ca5085ffe79b79f14a0d Mon Sep 17 00:00:00 2001
From: yggverse <yggverse@project>
Date: Wed, 25 Sep 2024 16:36:02 +0300
Subject: [PATCH] draft gemini socket connection

---
 src/browser/main/tab/page/mod.rs | 62 ++++++++++++++++++++++++++++++--
 1 file changed, 59 insertions(+), 3 deletions(-)

diff --git a/src/browser/main/tab/page/mod.rs b/src/browser/main/tab/page/mod.rs
index 9ac521b5..07bb304b 100644
--- a/src/browser/main/tab/page/mod.rs
+++ b/src/browser/main/tab/page/mod.rs
@@ -5,8 +5,9 @@ use content::Content;
 use navigation::Navigation;
 
 use gtk::{
-    glib::{GString, Regex, RegexCompileFlags, RegexMatchFlags, Uri, UriFlags},
-    prelude::BoxExt,
+    gio::{Cancellable, SocketClient, SocketProtocol, TlsCertificateFlags},
+    glib::{GString, Priority, Regex, RegexCompileFlags, RegexMatchFlags, Uri, UriFlags},
+    prelude::{BoxExt, IOStreamExt, InputStreamExtManual, OutputStreamExtManual, SocketClientExt},
     Box, Orientation,
 };
 
@@ -52,7 +53,62 @@ impl Page {
                         todo!()
                     }
                     "gemini" => {
-                        todo!()
+                        let client = SocketClient::new();
+
+                        client.set_tls(true);
+                        client.set_tls_validation_flags(TlsCertificateFlags::INSECURE);
+                        client.set_protocol(SocketProtocol::Tcp);
+
+                        client.connect_to_uri_async(
+                            "gemini://geminiprotocol.net:1965/", // @TODO &uri.to_str(),
+                            1965,
+                            Some(&Cancellable::new()),
+                            move |result| match result {
+                                Ok(connection) => {
+                                    connection.output_stream().write_all_async(
+                                        "gemini://geminiprotocol.net:1965/\r\n", // @TODO
+                                        Priority::DEFAULT,
+                                        Some(&Cancellable::new()),
+                                        move |result| match result {
+                                            Ok(request) => {
+                                                println!(
+                                                    "Request sent successfully: {:?}",
+                                                    request
+                                                ); // @TODO remove
+
+                                                connection.input_stream().read_all_async(
+                                                    Vec::new(),
+                                                    Priority::DEFAULT,
+                                                    Some(&Cancellable::new()),
+                                                    {
+                                                        |result| match result {
+                                                            Ok(response) => {
+                                                                println!("Result: {:?}", response);
+
+                                                                // @TODO connection.close(cancellable);
+                                                            }
+                                                            Err(e) => {
+                                                                eprintln!(
+                                                                    "Failed to read response: {:?}",
+                                                                    e
+                                                                );
+                                                            }
+                                                        }
+                                                    },
+                                                );
+                                                // @TODO
+                                            }
+                                            Err(e) => {
+                                                eprintln!("Failed to write request: {:?}", e);
+                                            }
+                                        },
+                                    );
+                                }
+                                Err(e) => {
+                                    eprintln!("Failed to connect: {e}"); // @TODO
+                                }
+                            },
+                        );
                     }
                     "nex" => {
                         todo!()