using System;
using System.Collections.Generic;
using System.Text;
using System.IO;
using System.Net.Security;
using System.Net.Sockets;
using System.Threading;
namespace HardChatter2
{
    class IrcBot
    {
        public Queue<string> Messages = new Queue<string>();
        private TcpClient Bot = null;
        private NetworkStream Writer = null;
        private NetworkStream Reader = null;
        private SslStream SecureWriter;
        private SslStream SecureReader;
        public string hostname = "";
        public int port = 6667;
        public bool use_ssl = false;
        private bool is_oper = false;
        public string user_name = "";
        public string real_name = "";
        public string nick = "";
        public string oper_user = "";
        public string oper_pass = "";
        public string nick_pass = "";
        public void Init()
        {
            if (Bot != null)
            {

                if (use_ssl)
                {
                    SecureWriter = new SslStream(Bot.GetStream());
                    SecureReader = new SslStream(Bot.GetStream());
                    SecureReader.AuthenticateAsClient(hostname);
                    SecureWriter.AuthenticateAsClient(hostname);
                }
                else
                {
                    Writer = Bot.GetStream();
                    Reader = Bot.GetStream();
                }
            }
            else
            {
                // add error handling...
            }
        }
        public void Join(string channel)
        {
            Enqueue("JOIN {0}", channel);
        }
        public void Join(string channel, string key)
        {
            Enqueue("JOIN {0} {1}", channel, key);
        }
        public void JoinChannels(string[] channels)
        {
            foreach (string s in channels)
            {
                if (s.Contains(":"))
                {
                    string[] chan = s.Split(new char[] { ':' });
                    Join(chan[0], chan[1]);
                }
                else
                {
                    Join(s);
                }
            }
        }
        public void Identify()
        {
            Enqueue("NICK {0}", nick);
            Enqueue("USER {0} 8 * :{1}", user_name, real_name);
            if (is_oper)
            {
                Enqueue("OPER {0} {1}", oper_user, oper_pass);
            }
            Enqueue("PRIVMSG NickServ :", nick_pass);

        }
        public void Parse(string data)
        {
        }
        public void Process()
        {
            Thread.Sleep(100);
            bool reading = true;
            while(true)
            {
                byte[] buffer = new byte[1024];
                if(reading)
                {
                    if (use_ssl)
                    {
                        SecureReader.Read(buffer, 0, 1024);
                    }
                    else
                    {
                        Reader.Read(buffer, 0, 1024);
                    }
                    string[] msgs = Encoding.ASCII.GetString(buffer).Split(new string[] { "\r\n" }, StringSplitOptions.RemoveEmptyEntries);
                    foreach (string msg in msgs)
                    {
                        Parse(msg);
                    }
                }
                else
                {
                    while(Messages.Count > 0)
                    {
                        Thread.Sleep(100);
                        Write(Messages.Dequeue());
                    }
                }
                reading = !reading;
            }
        }
        public void Privmsg(string target, string msg)
        {
            Enqueue("PRIVMSG {0} :{1}", target, msg);
        }
        public void Notice(string target, string msg)
        {
            Enqueue("NOICE {0} :{1}", target, msg);
        }
        public void Enqueue(string data)
        {
            Messages.Enqueue(data);
        }
        public void Enqueue(string data, params object[] args)
        {
            data = String.Format(data, args);
            Messages.Enqueue(data);
        }
        public void Write(string msg)
        {
            byte[] data = Encoding.ASCII.GetBytes(msg + "\r\n");
            if (Writer != null)
            {
                if (use_ssl)
                {
                    SecureWriter.Write(data, 0, data.Length);
                }
                else
                {
                    Writer.Write(data, 0, data.Length);
                }
            }
        }
        public void Write(string msg, params object[] args)
        {
            msg = String.Format(msg, args);
            Write(msg);
        }

    }
}