Merge branch 'master' of github.com:adamdruppe/arsd

http2.d

@@ -318,8 +318,25 @@ import std.conv;
 import std.range;
 
 
+private AddressFamily family(string unixSocketPath) {
+	if(unixSocketPath.length)
+		return AddressFamily.UNIX;
+	else // FIXME: what about ipv6?
+		return AddressFamily.INET;
+}
 
-// Copy pasta from cgi.d, then stripped down
+version(Windows)
+private class UnixAddress : Address {
+	this(string) {
+		throw new Exception("No unix address support on this system in lib yet :(");
+	}
+	override sockaddr* name() { assert(0); }
+	override const(sockaddr)* name() const { assert(0); }
+	override int nameLen() const { assert(0); }
+}
+
+
+// Copy pasta from cgi.d, then stripped down. unix path thing added tho
 ///
 struct Uri {
 	alias toString this; // blargh idk a url really is a string, but should it be implicit?
@@ -339,6 +356,18 @@ struct Uri {
 		reparse(uri);
 	}
 
+	private string unixSocketPath = null;
+	/// Indicates it should be accessed through a unix socket instead of regular tcp
+	void viaUnixSocket(string path) {
+		unixSocketPath = path;
+	}
+
+	/// Goes through a unix socket in the abstract namespace (linux only)
+	version(linux)
+	void viaAbstractSocket(string path) {
+		unixSocketPath = "\0" ~ path;
+	}
+
 	private void reparse(string uri) {
 		// from RFC 3986
 		// the ctRegex triples the compile time and makes ugly errors for no real benefit
@@ -545,6 +574,11 @@ struct Uri {
 
 		n.removeDots();
 
+		// if still basically talking to the same thing, we should inherit the unix path
+		// too since basically the unix path is saying for this service, always use this override.
+		if(n.host == baseUrl.host && n.scheme == baseUrl.scheme && n.port == baseUrl.port)
+			n.unixSocketPath = baseUrl.unixSocketPath;
+
 		return n;
 	}
 
@@ -630,6 +664,7 @@ class HttpRequest {
 		auto parts = where;
 		finalUrl = where.toString();
 		requestParameters.method = method;
+		requestParameters.unixSocketPath = where.unixSocketPath;
 		requestParameters.host = parts.host;
 		requestParameters.port = cast(ushort) parts.port;
 		requestParameters.ssl = parts.scheme == "https";
@@ -812,18 +847,25 @@ class HttpRequest {
 			}
 		}
 
-		Socket getOpenSocketOnHost(string host, ushort port, bool ssl) {
+		Socket getOpenSocketOnHost(string host, ushort port, bool ssl, string unixSocketPath) {
+
 			Socket openNewConnection() {
 				Socket socket;
 				if(ssl) {
 					version(with_openssl)
-						socket = new SslClientSocket(AddressFamily.INET, SocketType.STREAM);
+						socket = new SslClientSocket(family(unixSocketPath), SocketType.STREAM);
 					else
 						throw new Exception("SSL not compiled in");
 				} else
-					socket = new Socket(AddressFamily.INET, SocketType.STREAM);
+					socket = new Socket(family(unixSocketPath), SocketType.STREAM);
 
+				if(unixSocketPath) {
+					socket.connect(new UnixAddress(unixSocketPath));
+				} else {
+					// FIXME: i should prolly do ipv6 if available too.
 					socket.connect(new InternetAddress(host, port));
+				}
+
 				debug(arsd_http2) writeln("opening to ", host, ":", port, " ", cast(void*) socket);
 				assert(socket.handle() !is socket_t.init);
 				return socket;
@@ -903,7 +945,7 @@ class HttpRequest {
 					continue;
 				}
 
-				auto socket = getOpenSocketOnHost(pc.requestParameters.host, pc.requestParameters.port, pc.requestParameters.ssl);
+				auto socket = getOpenSocketOnHost(pc.requestParameters.host, pc.requestParameters.port, pc.requestParameters.ssl, pc.requestParameters.unixSocketPath);
 
 				if(socket !is null) {
 					activeRequestOnSocket[socket] = pc;
@@ -1384,6 +1426,8 @@ struct HttpRequestParameters {
 
 	string contentType; ///
 	ubyte[] bodyData; ///
+
+	string unixSocketPath;
 }
 
 interface IHttpClient {
@@ -2209,11 +2253,11 @@ wss://echo.websocket.org
 
 		if(ssl) {
 			version(with_openssl)
-				socket = new SslClientSocket(AddressFamily.INET, SocketType.STREAM);
+				socket = new SslClientSocket(family(uri.unixSocketPath), SocketType.STREAM);
 			else
 				throw new Exception("SSL not compiled in");
 		} else
-			socket = new Socket(AddressFamily.INET, SocketType.STREAM);
+			socket = new Socket(family(uri.unixSocketPath), SocketType.STREAM);
 
 	}
 
@@ -2222,6 +2266,9 @@ wss://echo.websocket.org
 	+/
 	/// Group: foundational
 	void connect() {
+		if(uri.unixSocketPath)
+			socket.connect(new UnixAddress(uri.unixSocketPath));
+		else
 			socket.connect(new InternetAddress(host, port)); // FIXME: ipv6 support...
 		// FIXME: websocket handshake could and really should be async too.
 
@@ -2924,8 +2971,8 @@ private {
 				return needsMoreData();
 			}
 
-			msg.data = d[0 .. msg.realLength];
+			msg.data = d[0 .. cast(size_t) msg.realLength];
-			d = d[msg.realLength .. $];
+			d = d[cast(size_t) msg.realLength .. $];
 
 			if(msg.masked) {
 				// let's just unmask it now

terminal.d

@@ -190,7 +190,6 @@ version(Windows)
 
 version(Win32Console) {
 	import core.sys.windows.windows;
-	import std.string : toStringz;
 	private {
 		enum RED_BIT = 4;
 		enum GREEN_BIT = 2;
@@ -1272,8 +1271,16 @@ http://msdn.microsoft.com/en-us/library/windows/desktop/ms683193%28v=vs.85%29.as
 	/// Changes the terminal's title
 	void setTitle(string t) {
 		version(Win32Console) {
-			// FIXME: use the W version
+			wchar[256] buffer;
-			SetConsoleTitleA(toStringz(t));
+			size_t bufferLength;
+			foreach(wchar ch; t)
+				if(bufferLength < buffer.length)
+					buffer[bufferLength++] = ch;
+			if(bufferLength < buffer.length)
+				buffer[bufferLength++] = 0;
+			else
+				buffer[$-1] = 0;
+			SetConsoleTitleW(buffer.ptr);
 		} else {
 			import std.string;
 			if(terminalInFamily("xterm", "rxvt", "screen", "tmux"))