using System;

using System.Net.Sockets;

using System.Threading;

using System.Text;

using System.Collections.Generic;

​

public class ATcpClient

{

    public Socket socket;

    public NetworkStream stream;

    public string IP;

    public int port;

    public bool connected;

    public bool PersistantConnect;

    public bool DataAvailable;

    private Thread CheckConnectionsThread;

    private Thread CheckAvailabilityThread;

    public bool Connect(string ip, int port)

    {

        try

        {

            var c = new TcpClient();

            c.Connect(ip, port);

            socket = c.Client;

            stream = c.GetStream();

            this.IP = ip;

            this.port = port;

            connected = true;

            CheckConnectionsThread = new Thread(new ThreadStart(CheckConnections));

            CheckConnectionsThread.IsBackground = true;

            CheckConnectionsThread.Start();

            CheckAvailabilityThread = new Thread(new ThreadStart(CheckAvailability));

            CheckAvailabilityThread.IsBackground = true;

            CheckAvailabilityThread.Start();

            return true;

        }

        catch(Exception){return false;}

    }

    public void write(string data)

    {

        try

        {

            stream.Write(Encoding.UTF8.GetBytes(data), 0, Encoding.UTF8.GetBytes(data).Length);

        }

        catch(Exception){Console.WriteLine("Error writing to stream");}

    }

    public void write(Dictionary<string, string> dictionary)

    {

        try

        {

            stream.Write(Encoding.UTF8.GetBytes(ToString(dictionary)), 0, Encoding.UTF8.GetBytes(ToString(dictionary)).Length);

        }

        catch(Exception){Console.WriteLine("Error writing to stream");}

    }

    public void CheckAvailability()

    {

        while(true)

        {

            if(stream.DataAvailable && !DataAvailable)

            {

                DataAvailable = true;

            }

            else if(!stream.DataAvailable && DataAvailable)

            {   

                DataAvailable = false;

            }

        }

    }

    public static Dictionary<string,string> ToDictionary(string data)

    {

        Dictionary<string,string> result = new Dictionary<string, string>();

        string[] sections = data.Split(',');

        foreach(string section in sections)

        {

            string[] KeyValue = section.Split(':');

            if(KeyValue.Length != 1)

            {

                result.Add(KeyValue[0].Replace("$01$", ":").Replace("$02$", ",") , KeyValue[1].Replace("$01$", ":").Replace("$02$", ","));

            }

        }

        return result;

    }

    public static string ToString(Dictionary<string,string> dictionary)

    {

        string result = "";

        foreach(KeyValuePair<string, string> entry in dictionary)

        {

            result += entry.Key.Replace(":", "$01$").Replace(",", "$02$") + ":" + entry.Value.Replace(":", "$01$").Replace(",", "$02$") + ",";

        }

        return result;

    }

    public Dictionary<string, string> read()

    {

        while(true)

        {

            if(stream.DataAvailable)

            {

                string data = ReadToEnd();

                return ToDictionary(data);

​

            }

        }

    }

    public string ReadToEnd()

    {

        return "THIS IS FOR TEST PURPOSES";

    }

    private void CheckConnections()

    {   

        while(connected)

        {

            if(!SocketConnected())

            {

                connected = false;

                if(PersistantConnect)

                {

                    while(!connected)

                    {

                        Connect(IP, port);

                    }

                }

            }

        }

    }

    bool SocketConnected()

    {

        bool part1 = socket.Poll(1000, SelectMode.SelectRead);

        bool part2 = (socket.Available == 0);

        if (part1 && part2)

            return false;

        else

            return true;

    }

}