From d84378db18fa0364dc950efe25974b25403add38 Mon Sep 17 00:00:00 2001
From: strawberry <strawberry@puppygock.gay>
Date: Sat, 9 Mar 2024 16:18:56 -0500
Subject: [PATCH] build unix socket support on unix platforms only

yes windows technically supports unix sockets,
but its not as good or the same as actual
nix platform unix sockets

Signed-off-by: strawberry <strawberry@puppygock.gay>
---
 Cargo.toml  | 11 +++++-----
 src/main.rs | 61 +++++++++++++++++++++++++++++++----------------------
 2 files changed, 41 insertions(+), 31 deletions(-)

diff --git a/Cargo.toml b/Cargo.toml
index b30e8bcc..48c9ee5b 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -92,12 +92,6 @@ features = [
   "util",
 ]
 
-# unix socket support
-[dependencies.hyperlocal]
-git = "https://github.com/softprops/hyperlocal"
-rev = "2ee4d149644600d326559af0d2b235c945b05c04"
-features = ["server"]
-
 [dependencies.hyper]
 version = "0.14"
 features = [
@@ -306,6 +300,11 @@ tokio = { version = "1.36.0", features = [
   "sync",
   "signal",
 ] }
+# unix socket support
+[dependencies.hyperlocal]
+git = "https://github.com/softprops/hyperlocal"
+rev = "2ee4d149644600d326559af0d2b235c945b05c04"
+features = ["server"]
 
 
 
diff --git a/src/main.rs b/src/main.rs
index 65bc37f3..b1483a2a 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -35,9 +35,9 @@ use ruma::api::{
 };
 #[cfg(all(not(target_env = "msvc"), feature = "jemalloc"))]
 use tikv_jemallocator::Jemalloc;
+#[cfg(unix)]
+use tokio::signal;
 use tokio::{
-	net::UnixListener,
-	signal,
 	sync::{oneshot, oneshot::Sender},
 	task::JoinSet,
 };
@@ -163,7 +163,15 @@ async fn main() {
 
 	/* ad-hoc config validation/checks */
 
-	if config.address.is_loopback() {
+	if config.unix_socket_path.is_some() && !cfg!(unix) {
+		error!(
+			"UNIX socket support is only available on *nix platforms. Please remove \"unix_socket_path\" from your \
+			 config."
+		);
+		return;
+	}
+
+	if config.address.is_loopback() && cfg!(unix) {
 		debug!(
 			"Found loopback listening address {}, running checks if we're in a container.",
 			config.address
@@ -389,34 +397,37 @@ async fn run_server() -> io::Result<()> {
 	tokio::spawn(shutdown_signal(handle.clone(), tx));
 
 	if let Some(path) = &config.unix_socket_path {
-		if path.exists() {
-			warn!(
-				"UNIX socket path {:#?} already exists (unclean shutdown?), attempting to remove it.",
-				path.display()
-			);
-			tokio::fs::remove_file(&path).await?;
-		}
+		#[cfg(unix)]
+		{
+			if path.exists() {
+				warn!(
+					"UNIX socket path {:#?} already exists (unclean shutdown?), attempting to remove it.",
+					path.display()
+				);
+				tokio::fs::remove_file(&path).await?;
+			}
 
-		tokio::fs::create_dir_all(path.parent().unwrap()).await?;
+			tokio::fs::create_dir_all(path.parent().unwrap()).await?;
 
-		let socket_perms = config.unix_socket_perms.to_string();
-		let octal_perms = u32::from_str_radix(&socket_perms, 8).unwrap();
+			let socket_perms = config.unix_socket_perms.to_string();
+			let octal_perms = u32::from_str_radix(&socket_perms, 8).unwrap();
 
-		let listener = UnixListener::bind(path.clone())?;
-		tokio::fs::set_permissions(path, Permissions::from_mode(octal_perms)).await.unwrap();
-		let socket = SocketIncoming::from_listener(listener);
+			let listener = tokio::net::UnixListener::bind(path.clone())?;
+			tokio::fs::set_permissions(path, Permissions::from_mode(octal_perms)).await.unwrap();
+			let socket = SocketIncoming::from_listener(listener);
 
-		#[cfg(feature = "systemd")]
-		let _ = sd_notify::notify(true, &[sd_notify::NotifyState::Ready]);
+			#[cfg(feature = "systemd")]
+			let _ = sd_notify::notify(true, &[sd_notify::NotifyState::Ready]);
 
-		info!("Listening at {:?}", path);
-		let server = Server::builder(socket).serve(app);
-		let graceful = server.with_graceful_shutdown(async {
-			rx.await.ok();
-		});
+			info!("Listening at {:?}", path);
+			let server = Server::builder(socket).serve(app);
+			let graceful = server.with_graceful_shutdown(async {
+				rx.await.ok();
+			});
 
-		if let Err(e) = graceful.await {
-			error!("Server error: {:?}", e);
+			if let Err(e) = graceful.await {
+				error!("Server error: {:?}", e);
+			}
 		}
 	} else {
 		match &config.tls {