using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Diagnostics;
using System.IO;
using System.Net;
using System.Net.Security;
using System.Net.Sockets;
 
 
namespace proxy_forms
{
            
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }
 
        private void log(string s)
        {
            // чтобы можно было с других потоков писать в лог нужно использовать BeginInvoke
            if (InvokeRequired) BeginInvoke(new Action(() => { logBox.AppendText(DateTime.Now.ToLongTimeString() + " " + s + "\r\n"); }));
            else logBox.AppendText(DateTime.Now.ToLongTimeString() + " " + s + "\r\n");
        }
        private void button1_Click(object sender, EventArgs e)
        {
        TcpListener listener = new TcpListener(IPAddress.Any, 9000);
 
        const int BUFFER_SIZE = 4096;
            listener.Start();
            new Task(() =>
            {
                // Accept clients.
                while (true)
                {
                    var client = listener.AcceptTcpClient();
                    new Task(() =>
                    {
                        // Handle this client.
                        var clientStream = client.GetStream();
                        TcpClient server = new TcpClient("127.0.0.1", 8888);
                        var serverStream = server.GetStream();
                        new Task(() =>
                        {
                            byte[] message = new byte[BUFFER_SIZE];
                            int clientBytes;
                            while (true)
                            {
                                try
                                {
                                    clientBytes = clientStream.Read(message, 0, BUFFER_SIZE);
                                    //   Console.WriteLine(BitConverter.ToString(message));
                                }
                                catch
                                {
                                    // Socket error - exit loop.  Client will have to reconnect.
                                    break;
                                }
                                if (clientBytes == 0)
                                {
                                    // Client disconnected.
                                    break;
                                }
                                serverStream.Write(message, 0, clientBytes);
                                log(Encoding.ASCII.GetString(message));
 
                            }
                            client.Close();
                        }).Start();
                        new Task(() =>
                        {
                            byte[] message = new byte[BUFFER_SIZE];
                            int serverBytes;
                            while (true)
                            {
                                try
                                {
                                    serverBytes = serverStream.Read(message, 0, BUFFER_SIZE);
                                    clientStream.Write(message, 0, serverBytes);
                                }
                                catch
                                {
                                    // Server socket error - exit loop.  Client will have to reconnect.
                                    log("Server socket error");
                                    break;
                                }
                                if (serverBytes == 0)
                                {
                                    log(" server disconnected");
                                    // server disconnected.
                                    break;
                                }
                                log(Encoding.ASCII.GetString(message));
                            }
                        }).Start();
                    }).Start();
                }
            }).Start();
            log("Server listening on port 9000.  Press enter to exit.");
           // Console.ReadLine();
            listener.Stop();
        }
 
    }
}