From 1ccb81159db834e34b6581af447f648d9e3bc07c Mon Sep 17 00:00:00 2001
From: "Adam D. Ruppe" <destructionator@gmail.com>
Date: Sat, 29 May 2021 20:58:04 -0400
Subject: [PATCH] systemd stdio maybe... untested lol

---
 cgi.d | 66 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++--
 1 file changed, 64 insertions(+), 2 deletions(-)

diff --git a/cgi.d b/cgi.d
index ac4545b..cfaf154 100644
--- a/cgi.d
+++ b/cgi.d
@@ -1638,9 +1638,9 @@ class Cgi {
 		// see: https://github.com/dlang/phobos/pull/7383
 		// but this might be more useful anyway tbh for this case
 		version(Posix)
-		this(ir, cast(UnixAddress) ira ? "unix:" : ira.toString(), port, 0, false, &rdo, null, closeConnection);
+		this(ir, ira is null ? null : cast(UnixAddress) ira ? "unix:" : ira.toString(), port, 0, false, &rdo, null, closeConnection);
 		else
-		this(ir, ira.toString(), port, 0, false, &rdo, null, closeConnection);
+		this(ir, ira is null ? null : ira.toString(), port, 0, false, &rdo, null, closeConnection);
 	}
 
 	/**
@@ -3520,6 +3520,9 @@ struct RequestServer {
 		} else
 		version(fastcgi) {
 			serveFastCgi!(fun, CustomCgi, maxContentLength)(this);
+		} else
+		version(stdiocgi) {
+			serveSingleHttpConnectionOnStdio!(fun, CustomCgi, maxContentLength)();
 		} else {
 			//version=plain_cgi;
 			handleCgiRequest!(fun, CustomCgi, maxContentLength)();
@@ -3535,6 +3538,18 @@ struct RequestServer {
 		manager.listen();
 	}
 
+	/++
+		Serves a single "connection", but the connection is spoken on stdin and stdout instead of on a socket.
+
+		Intended for cases like working from systemd, like discussed here: https://forum.dlang.org/post/avmkfdiitirnrenzljwc@forum.dlang.org
+
+		History:
+			Added May 29, 2021
+	+/
+	void serveSingleHttpConnectionOnStdio(alias fun, CustomCgi = Cgi, long maxContentLength = defaultMaxContentLength)() {
+		doThreadHttpConnectionGuts!(CustomCgi, fun, true)(new FakeSocketForStdin());
+	}
+
 	void stop() {
 		// FIXME
 	}
@@ -4655,6 +4670,53 @@ class BufferedInputRange {
 	bool sourceClosed;
 }
 
+private class FakeSocketForStdin : Socket {
+	import std.stdio;
+
+	this() {
+
+	}
+
+	private bool closed;
+
+	override ptrdiff_t receive(void[] buffer, std.socket.SocketFlags) @trusted {
+		if(closed)
+			throw new Exception("Closed");
+		return stdin.rawRead(buffer).length;
+	}
+
+	override ptrdiff_t send(const void[] buffer, std.socket.SocketFlags) @trusted {
+		if(closed)
+			throw new Exception("Closed");
+		stdout.rawWrite(buffer);
+		return buffer.length;
+	}
+
+	override void close() @trusted {
+		(cast(void delegate() @nogc nothrow) &realClose)();
+	}
+
+	override void shutdown(SocketShutdown s) {
+		// FIXME
+	}
+
+	override void setOption(SocketOptionLevel, SocketOption, void[]) {}
+	override void setOption(SocketOptionLevel, SocketOption, Duration) {}
+
+	override @property @trusted Address remoteAddress() { return null; }
+	override @property @trusted Address localAddress() { return null; }
+
+	void realClose() {
+		closed = true;
+		try {
+			stdin.close();
+			stdout.close();
+		} catch(Exception e) {
+
+		}
+	}
+}
+
 import core.sync.semaphore;
 import core.atomic;