/* 
*┌──────────────────────────────────┐
*│　         Copyright(C) 2017 by Antiphon.All rights reserved.       │
*│                Author:by Locke Xie 2017-01-13  　　　　　　　　  　│
*└──────────────────────────────────┘
*
* 功 能： http
* 类 名： HttpNetSys.cs
* 
* 修改历史：
* 
* 
*/

using System;
using System.Collections;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Web;
using UnityEngine;

namespace Assets.Scripts.Model
{
    class HttpNetSys
    {
        private static int Max_Post_Size = 10 * 1024 * 1024;//10m
        private const int BUFF_SIZE = 4096;
        private Stream inputStream;
        public StreamWriter OutputStream;
        public String http_method;
        public String http_url;
        public String http_protocol_versionstring;
        public Hashtable httpHeaders = new Hashtable();
        internal TcpClient _Socket;

        /// <summary>
        /// 这个是服务器收到有效链接初始化
        /// </summary>
        internal HttpNetSys(TcpClient client)
        {
            this._Socket = client;
            inputStream = new BufferedStream(_Socket.GetStream());
            OutputStream = new StreamWriter(new BufferedStream(_Socket.GetStream()), UTF8Encoding.Default);
            ParseRequest();
        }

        internal void process(string bind)
        {
            try
            {
                if(http_method.Equals("GET"))
                {
                    //ListenersBox.Instance.MessagePool.ActiveHttp(this, bind, GetRequestExec());
                } else if(http_method.Equals("POST"))
                {
                    //ListenersBox.Instance.MessagePool.ActiveHttp(this, bind, PostRequestExec());
                }
            } catch(Exception e)
            {
                Debug.LogError("ActiveHttp Exception: " + e);
                WriteFailure();
            }
        }

        public void Close()
        {
            OutputStream.Flush();
            inputStream.Dispose();
            inputStream = null;
            OutputStream.Dispose();
            OutputStream = null; // bs = null;            
            this._Socket.Close();
        }

        #region 读取流的一行 private string ReadLine()
        /// <summary>
        /// 读取流的一行
        /// </summary>
        /// <returns></returns>
        private string ReadLine()
        {
            int next_char;
            string data = "";
            while(true)
            {
                next_char = this.inputStream.ReadByte();
                if(next_char == '\n')
                { break; }
                if(next_char == '\r')
                { continue; }
                if(next_char == -1)
                { Thread.Sleep(1); continue; };
                data += Convert.ToChar(next_char);
            }
            return data;
        }
        #endregion

        #region 转化出 Request private void ParseRequest()
        /// <summary>
        /// 转化出 Request
        /// </summary>
        private void ParseRequest()
        {
            String request = ReadLine();
            if(request != null)
            {
                string[] tokens = request.Split(' ');
                if(tokens.Length != 3)
                {
                    throw new Exception("invalid http request line");
                }
                http_method = tokens[0].ToUpper();
                http_url = tokens[1].ToLower();
                http_protocol_versionstring = tokens[2];
            }
            String line;
            while((line = ReadLine()) != null)
            {
                if(line.Equals(""))
                {
                    break;
                }
                int separator = line.IndexOf(':');
                if(separator == -1)
                {
                    throw new Exception("invalid http header line: " + line);
                }
                String name = line.Substring(0, separator);
                int pos = separator + 1;
                while((pos < line.Length) && (line[pos] == ' '))
                {
                    pos++;//过滤键值对的空格
                }
                string value = line.Substring(pos, line.Length - pos);
                httpHeaders[name] = value;
            }
        }
        #endregion

        #region 读取Get数据 private Dictionary<string, string> GetRequestExec()
        /// <summary>
        /// 读取Get数据
        /// </summary>
        /// <returns></returns>
        private Dictionary<string, string> GetRequestExec()
        {
            Dictionary<string, string> datas = new Dictionary<string, string>();
            int index = http_url.IndexOf("?", 0);
            if(index >= 0)
            {
                string data = http_url.Substring(index + 1);
                datas = getData(data);
            }
            WriteSuccess();
            return datas;
        }
        #endregion

        #region 读取提交的数据 private void handlePOSTRequest()
        /// <summary>
        /// 读取提交的数据
        /// </summary>
        private Dictionary<string, string> PostRequestExec()
        {
            int content_len = 0;
            MemoryStream ms = new MemoryStream();
            if(this.httpHeaders.ContainsKey("Content-Length"))
            {
                //内容的长度
                content_len = Convert.ToInt32(this.httpHeaders["Content-Length"]);
                if(content_len > Max_Post_Size)
                { throw new Exception(String.Format("POST Content-Length({0}) 对于这个简单的服务器太大", content_len)); }
                byte[] buf = new byte[BUFF_SIZE];
                int to_read = content_len;
                while(to_read > 0)
                {
                    int numread = this.inputStream.Read(buf, 0, Math.Min(BUFF_SIZE, to_read));
                    if(numread == 0)
                    {
                        if(to_read == 0)
                        { break; } else
                        { throw new Exception("client disconnected during post"); }
                    }
                    to_read -= numread;
                    ms.Write(buf, 0, numread);
                }
                ms.Seek(0, SeekOrigin.Begin);
            }

            StreamReader inputData = new StreamReader(ms);
            string data = inputData.ReadToEnd();
            WriteSuccess();
            return getData(data);
        }
        #endregion

        #region 输出状态
        /// <summary>
        /// 输出200状态
        /// </summary>
        public void WriteSuccess()
        {
            OutputStream.WriteLine("HTTP/1.0 200 OK");
            OutputStream.WriteLine("Content-Type: text/html");
            OutputStream.WriteLine("");
        }

        /// <summary>
        /// 输出状态404
        /// </summary>
        public void WriteFailure()
        {
            OutputStream.WriteLine("HTTP/1.0 404 File not found");
            OutputStream.WriteLine("Content-Type: text/html");
            OutputStream.WriteLine("Connection: close");
            OutputStream.WriteLine("");
        }
        #endregion

        /// <summary>
        /// 分析http提交数据分割
        /// </summary>
        /// <param name="rawData"></param>
        /// <returns></returns>
        private static Dictionary<string, string> getData(string rawData)
        {
            var rets = new Dictionary<string, string>();
            string[] rawParams = rawData.Split('&');
            WWWForm form = new WWWForm();
            foreach(string param in rawParams)
            {
                string[] kvPair = param.Split('=');
                string key = kvPair[0];
                string value = HttpUtility.UrlDecode(kvPair[1]);
                rets[key] = value;
            }
            return rets;
        }
    }
}