Gateway wizard (#1919)

* issue certificates for gateway

* remove gw tokens, cleanup

* cleanup

* clippy

* sqlx prepare

* consts

* update protobufs

* proxy wizard backend

* proxy wizard frontend

* remove eprintln

* fix lint

* fix

* fix 2

* gateway wizard 1

* fix domain validator

* fixes, gateway names, navigation

* routetree

* fix frontend

* after merge fix

* proto update

* fix linters

* fix sqlx fixtures

Author: t-aleksander

…2388c1e322dbc7ce93d92251b3a82caabef.json …4a7afcbee1b63e34932c143f4697a0bc2cc.json.sqlx/query-cd6c70e9b46c5cdce053d6f0772612388c1e322dbc7ce93d92251b3a82caabef.json renamed to .sqlx/query-5af0fbf61295a5a23149c6248ea0b4a7afcbee1b63e34932c143f4697a0bc2cc.json .sqlx/query-cd6c70e9b46c5cdce053d6f0772612388c1e322dbc7ce93d92251b3a82caabef.json renamed to .sqlx/query-5af0fbf61295a5a23149c6248ea0b4a7afcbee1b63e34932c143f4697a0bc2cc.json

@@ -26,3 +26,4 @@ dotenvy = "0.15"
 secrecy = { workspace = true }
 tokio = { workspace = true }
 tracing = { workspace = true }
+tracing-subscriber = { workspace = true }

…2080a4c27137278b2fb761d3b279b69f9db.json …b7f32e22adefc9b9185a9b3cd80c169a6e2.json.sqlx/query-9655c2e6a8f749fe1ea966dcdc0ea2080a4c27137278b2fb761d3b279b69f9db.json renamed to .sqlx/query-ae3e3cef524f2a911808bf72e7c57b7f32e22adefc9b9185a9b3cd80c169a6e2.json .sqlx/query-9655c2e6a8f749fe1ea966dcdc0ea2080a4c27137278b2fb761d3b279b69f9db.json renamed to .sqlx/query-ae3e3cef524f2a911808bf72e7c57b7f32e22adefc9b9185a9b3cd80c169a6e2.json

@@ -47,6 +47,7 @@ use tokio::sync::{
     broadcast,
     mpsc::{channel, unbounded_channel},
 };
+use tracing_subscriber::util::SubscriberInitExt;
 
 #[macro_use]
 extern crate tracing;
@@ -61,11 +62,13 @@ async fn main() -> Result<(), anyhow::Error> {
         .set(config.clone())
         .expect("Failed to initialize server config.");
 
-    // initialize tracing with version formatter
-    defguard_version::tracing::init(
-        defguard_version::Version::parse(VERSION)?,
+    let subscriber = tracing_subscriber::registry();
+    defguard_version::tracing::with_version_formatters(
+        &defguard_version::Version::parse(VERSION)?,
         &config.log_level,
-    )?;
+        subscriber,
+    )
+    .init();
 
     info!("Starting ... version v{VERSION}");
     debug!("Using config: {config:?}");

…7ccad57d9cc9caa41502cbe85c6eafb087e.json …38d3e2deb43d5ca3458724deb3ead69389a.json.sqlx/query-671c3ef062fa5c901d26adb86c75b7ccad57d9cc9caa41502cbe85c6eafb087e.json renamed to .sqlx/query-b43694450d7abe3b93ea88fa7c95c38d3e2deb43d5ca3458724deb3ead69389a.json .sqlx/query-671c3ef062fa5c901d26adb86c75b7ccad57d9cc9caa41502cbe85c6eafb087e.json renamed to .sqlx/query-b43694450d7abe3b93ea88fa7c95c38d3e2deb43d5ca3458724deb3ead69389a.json

@@ -18,6 +18,7 @@ pub struct Gateway<I = NoId> {
     pub has_certificate: bool,
     pub certificate_expiry: Option<NaiveDateTime>,
     pub version: Option<String>,
+    pub name: String,
 }
 
 impl<I> Gateway<I> {
@@ -34,7 +35,7 @@ impl<I> Gateway<I> {
 
 impl Gateway {
     #[must_use]
-    pub fn new<S: Into<String>>(network_id: Id, url: S) -> Self {
+    pub fn new<S: Into<String>>(network_id: Id, url: S, name: S) -> Self {
         Self {
             id: NoId,
             network_id,
@@ -45,6 +46,7 @@ impl Gateway {
             has_certificate: false,
             certificate_expiry: None,
             version: None,
+            name: name.into(),
         }
     }
 }
@@ -120,6 +122,18 @@ impl Gateway<Id> {
 
         Ok(())
     }
+
+    // TODO: Split the URL into address and port fields just like in proxy
+    pub async fn find_by_url<'e, E>(executor: E, url: &str) -> Result<Option<Self>, sqlx::Error>
+    where
+        E: PgExecutor<'e>,
+    {
+        let record = query_as!(Self, "SELECT * FROM gateway WHERE url = $1", url)
+            .fetch_optional(executor)
+            .await?;
+
+        Ok(record)
+    }
 }
 
 impl fmt::Display for Gateway<Id> {