- by Ed
I'm trying to build a service that will forward HTTP requests from agents like a browser to the Tor service. Problem is, the Tor service only accepts SOCKS4a connections.
So my solution is to listen for HTTP requests, get the URL they're requesting, and make a request via Tor with the help of the Starksoft.Net.Proxy library. Then return the response. The library kind of works, but I'm not happy. It returns HTTP headers with the response and it can't handle images. So the responses are messed up.
How could I improve my code? I'm very new to network programming. Sorry for the long example.
public AnonymiserService(ILogger logger)
{
try
{
_logger = logger;
_logger.Log("Listening on port {0}...", Properties.Settings.Default.ListeningPort);
StartListener(new string[] { string.Format("http://*:{0}/", Properties.Settings.Default.ListeningPort) });
}
catch (Exception ex)
{
_logger.LogError("Exception!", ex);
}
}
private void StartListener(string[] prefixes)
{
if (!HttpListener.IsSupported)
{
_logger.LogError("HttpListener isn't supported on this machine!");
return;
}
HttpListener listener = new HttpListener();
foreach (string s in prefixes)
listener.Prefixes.Add(s);
while (true)
{
listener.Start();
IAsyncResult result = listener.BeginGetContext(new AsyncCallback(ListenerCallback), listener);
result.AsyncWaitHandle.WaitOne();
}
}
private void ListenerCallback(IAsyncResult result)
{
try
{
// Get HTTP request
HttpListener listener = (HttpListener)result.AsyncState;
HttpListenerContext context = listener.EndGetContext(result);
_logger.Log("Retrieving [{0}]", context.Request.RawUrl);
// Create connection
// Use Tor as proxy
IProxyClient proxyClient = new Socks4aProxyClient("localhost", 9050);
TcpClient tcpClient = proxyClient.CreateConnection(context.Request.UserHostName, 80);
// Create message
// Need to set Connection: close to close the connection as soon as it's done
byte[] data = Encoding.UTF8.GetBytes(String.Format("GET {0} HTTP/1.1\r\nHost: {1}\r\nConnection: close\r\n\r\n", context.Request.Url.PathAndQuery, context.Request.UserHostName));
// Send message
NetworkStream ns = tcpClient.GetStream();
ns.Write(data, 0, data.Length);
// Pass on HTTP response
HttpListenerResponse responseOut = context.Response;
if (ns.CanRead)
{
byte[] buffer = new byte[32768];
int read = 0;
string responseString = string.Empty;
// Read response
while ((read = ns.Read(buffer, 0, buffer.Length)) > 0)
{
responseString += Encoding.UTF8.GetString(buffer, 0, read);
}
// Remove headers
if (responseString.IndexOf("HTTP/1.1 200 OK") > -1)
responseString = responseString.Substring(responseString.IndexOf("\r\n\r\n"));
// Forward response
byte[] byteArray = Encoding.UTF8.GetBytes(responseString);
responseOut.OutputStream.Write(byteArray, 0, byteArray.Length);
}
// Close streams
responseOut.OutputStream.Close();
ns.Close();
// Close connection
tcpClient.Close();
_logger.Log("Retrieved [{0}]", context.Request.RawUrl);
}
catch (Exception ex)
{
_logger.LogError("Exception in ListenerCallback!", ex);
}
}
