using System;
using System.Text;
using XF;

namespace Client
{
    class Program
    {
        private const string request =
@"GET /?sample HTTP/1.1
Host: kodart.com

";
        static void Main()
        {
            Network.ConnectAsync("kodart.com", 80, Encoding.Default.GetBytes(request), OnConnect);
            Console.ReadKey();
        }

        private static void OnConnect(IConnection connection)
        {
            connection.WriteAsync(Encoding.Default.GetBytes("wrong verb example\r\n\r\n"));
            connection.ReadAsync(OnReadComplete);
        }

        private static void OnReadComplete(IConnection sender, IMemoryBuffer buffer, int bytes)
        {
            if (bytes == 0) return;
            Console.WriteLine(Encoding.ASCII.GetString(buffer.Data, buffer.Offset, bytes));
        }
    }
}

namespace ConsoleApplication1 {
    internal sealed class TCPClient {
        private string _host;
        private int _port;

        public TCPClient(string host, int port) {
            _host = host;
            _port = port;
        }

        public void Send(string request, Action<string> action) {
            Console.WriteLine("Trying to connect " + _host);

            Network.ConnectAsync(_host, _port, Encoding.UTF8.GetBytes(request), connection => {
                Console.WriteLine(_host + " connected");

                connection.OnClose += flag => Console.WriteLine(_host + " connection closed.");
                connection.ReadAsync((ignored, buf, size) => {
                    Console.WriteLine(_host + " data readed.");

                    if (0 < size) {
                        string response = Encoding.UTF8.GetString(buf.Data, buf.Offset, size);
                        action(response);
                    }
                });
            });
        }
    }

    class Program {
        private const string REQUEST =
@"GET / HTTP/1.1
Host: {0}

";
        static void Main(string[] args) {
            new Program();

            Console.WriteLine("All done. ");

            if (Process.GetCurrentProcess().ProcessName.EndsWith(".vshost")) {
                Console.WriteLine("Press any key to exit...");
                Console.ReadKey();
            }
        }

        private Program() {
            test("www.shangen-tech.com.cn", "shangen-tech.com.cn");
            test("www.shangen-tech.com", "shangen-tech.com");
        }

        private void test(string host, string domain) {
            new TCPClient(host, 80).Send(REQUEST.Set(domain), response => {
                Console.WriteLine("Response from " + host);
                Console.WriteLine("Length: " + response.Length.ToString());
            });
        }

        private void writeResponse(string sessionName, string response) {
            Console.WriteLine(sessionName + ": " + response.Length.ToString());
            Console.WriteLine(response);
        }
    }
}