Add server support for Unix sockets.

Allows to pass the absolute socket path as the bind address string.

Closes vibe-d/vibe.d#2073.

Author: s-ludwig

source/vibe/http/server.d

@@ -52,6 +52,12 @@ else version (Have_botan) enum HaveNoTLS = false;
 else version (Have_openssl) enum HaveNoTLS = false;
 else enum HaveNoTLS = true;
 
+version(Posix)
+{
+	version = UnixSocket;
+}
+
+
 /**************************************************************************************************/
 /* Public functions                                                                               */
 /**************************************************************************************************/
@@ -1923,7 +1929,30 @@ private HTTPListener listenHTTPPlain(HTTPServerSettings settings, HTTPServerRequ
 			TCPListenOptions options = TCPListenOptions.defaults;
 			if(reuseAddress) options |= TCPListenOptions.reuseAddress; else options &= ~TCPListenOptions.reuseAddress;
 			if(reusePort) options |= TCPListenOptions.reusePort; else options &= ~TCPListenOptions.reusePort;
-			auto ret = listenTCP(listen_info.bindPort, (TCPConnection conn) nothrow @safe {
+
+			NetworkAddress bind_address;
+
+			auto proto = is_tls ? "https" : "http";
+
+			if (listen_info.bindAddress.startsWith("/")) {
+				version (UnixSocket) {
+					import std.socket : AddressFamily;
+					import core.sys.posix.sys.un : sockaddr_un;
+					import core.stdc.string : strcpy;
+
+					bind_address.family = AddressFamily.UNIX;
+					sockaddr_un* s = bind_address.sockAddrUnix();
+					enforce(s.sun_path.length > listen_info.bindAddress.length, "Unix sockets cannot have that long a name.");
+					s.sun_family = AddressFamily.UNIX;
+					() @trusted { strcpy(cast(char*)s.sun_path.ptr, listen_info.bindAddress.toStringz()); } ();
+					proto ~= "+unix";
+				} else throw new Exception("Unix domain sockets are not supported on this platform.");
+			} else {
+				bind_address = resolveHost(listen_info.bindAddress);
+				bind_address.port = listen_info.bindPort;
+			}
+
+			auto ret = listenTCP((TCPConnection conn) nothrow @safe {
 					auto raddr = conn.remoteAddress;
 					try handleHTTPConnection(conn, listen_info, raddr);
 					catch (Exception e) {
@@ -1932,16 +1961,18 @@ private HTTPListener listenHTTPPlain(HTTPServerSettings settings, HTTPServerRequ
 						try conn.close();
 						catch (Exception e) logError("Failed to close connection: %s", e.msg);
 					}
-				}, listen_info.bindAddress, options);
+				}, bind_address, options);
 
 			// support port 0 meaning any available port
-			if (listen_info.bindPort == 0)
+			if (listen_info.bindPort == 0) {
 				listen_info.m_bindPort = ret.bindAddress.port;
+				bind_address.port = ret.bindAddress.port;
+			}
 
-			auto proto = is_tls ? "https" : "http";
 			auto urladdr = listen_info.bindAddress;
 			if (urladdr.canFind(':')) urladdr = "["~urladdr~"]";
-			logInfo("Listening for requests on %s://%s:%s/", proto, urladdr, listen_info.bindPort);
+			logInfo("Listening for requests on %s://%s/", proto,
+				bind_address.toString().replace("/", "%2f"));
 			return ret;
 		} catch( Exception e ) {
 			logWarn("Failed to listen on %s:%s", listen_info.bindAddress, listen_info.bindPort);

tests/vibe.http.unix_socket/dub.sdl

@@ -0,0 +1,3 @@
+name "tests"
+description "Unix Sockets"
+dependency "vibe-http" path="../../"

tests/vibe.http.unix_socket/source/app.d

@@ -0,0 +1,37 @@
+import vibe.core.file;
+import vibe.inet.url;
+import vibe.http.client;
+import vibe.http.server;
+import vibe.http.router;
+import vibe.stream.operations;
+import std.stdio;
+
+void handleHelloRequest(scope HTTPServerRequest req, scope HTTPServerResponse res)
+{
+    res.writeBody("Hello, World!", "text/plain");
+}
+
+void main()
+{
+	version (Posix) {
+		if (existsFile("/tmp/vibe.sock"))
+			removeFile("/tmp/vibe.sock");
+
+		auto router = new URLRouter;
+		router.get("/hello", &handleHelloRequest);
+
+		auto settings = new HTTPServerSettings;
+		settings.bindAddresses = ["/tmp/vibe.sock"];
+
+		listenHTTP(settings, router);
+
+		requestHTTP("http+unix://%2ftmp%2fvibe.sock/hello", (scope req) {}, (scope res) {
+			assert(res.bodyReader.readAllUTF8() == "Hello, World!");
+		});
+
+		removeFile("/tmp/vibe.sock");
+	} else {
+		import vibe.core.log : logInfo;
+		logInfo("Skipping test on non-Posix platform.");
+	}
+}