using System.Net;
using NewLife.Collections;
using NewLife.Data;
using NewLife.Remoting;
using NewLife.Serialization;

namespace NewLife.Http;

/// <summary>Http响应</summary>
public class HttpResponse : HttpBase
{
    #region 属性
    /// <summary>状态码</summary>
    public HttpStatusCode StatusCode { get; set; } = HttpStatusCode.OK;

    /// <summary>状态描述</summary>
    public String? StatusDescription { get; set; }
    #endregion

    /// <summary>分析第一行</summary>
    /// <param name="firstLine"></param>
    protected override Boolean OnParse(String firstLine)
    {
        if (firstLine.IsNullOrEmpty()) return false;

        // HTTP/1.1 502 Bad Gateway
        if (!firstLine.StartsWith("HTTP/")) return false;

        var ss = firstLine.Split(' ');
        //if (ss.Length < 3) throw new Exception("非法响应头 {0}".F(firstLine));
        if (ss.Length < 3) return false;

        Version = ss[0].TrimStart("HTTP/");

        // 分析响应码
        var code = ss[1].ToInt();
        if (code > 0) StatusCode = (HttpStatusCode)code;

        StatusDescription = ss.Skip(2).Join(" ");

        return true;
    }

    /// <summary>创建请求响应包</summary>
    /// <returns></returns>
    public override IOwnerPacket Build()
    {
        // 如果响应异常，则使用响应描述作为内容
        if (StatusCode > HttpStatusCode.OK && Body == null && !StatusDescription.IsNullOrEmpty())
        {
            Body = (ArrayPacket)StatusDescription.GetBytes();
        }

        return base.Build();
    }

    /// <summary>创建头部</summary>
    /// <param name="length"></param>
    /// <returns></returns>
    protected override String BuildHeader(Int32 length)
    {
        // 构建头部
        var sb = Pool.StringBuilder.Get();
        sb.AppendFormat("HTTP/{2} {0} {1}\r\n", (Int32)StatusCode, StatusCode, Version);

        //// cors
        //sb.AppendFormat("Access-Control-Allow-Origin:{0}\r\n", "*");
        //sb.AppendFormat("Access-Control-Allow-Methods:{0}\r\n", "POST, GET");
        //sb.AppendFormat("Access-Control-Allow-Headers:{0}\r\n", "Content-Type, Access-Control-Allow-Headers, Authorization, X-Requested-With");

        // 内容长度
        if (length > 0)
            Headers["Content-Length"] = length + "";
        else if (!Headers.ContainsKey("Transfer-Encoding"))
            Headers["Content-Length"] = "0";

        if (!ContentType.IsNullOrEmpty()) Headers["Content-Type"] = ContentType;

        foreach (var item in Headers)
        {
            sb.AppendFormat("{0}: {1}\r\n", item.Key, item.Value);
        }

        sb.Append("\r\n");

        return sb.Return(true);
    }

    /// <summary>验证，如果失败则抛出异常</summary>
    public void Valid()
    {
        if (StatusCode != HttpStatusCode.OK) throw new Exception(StatusDescription ?? (StatusCode + ""));
    }

    /// <summary>设置结果，影响Body和ContentType</summary>
    /// <param name="result"></param>
    /// <param name="contentType"></param>
    public void SetResult(Object result, String? contentType = null)
    {
        if (result == null) return;

        if (result is Exception ex)
        {
            if (ex is ApiException aex)
                StatusCode = (HttpStatusCode)aex.Code;
            else
                StatusCode = HttpStatusCode.InternalServerError;

            StatusDescription = ex.Message;
        }
        else if (result is IPacket pk)
        {
            if (contentType.IsNullOrEmpty()) contentType = "application/octet-stream";
            Body = pk;
        }
        else if (result is Byte[] buffer)
        {
            if (contentType.IsNullOrEmpty()) contentType = "application/octet-stream";
            Body = (ArrayPacket)buffer;
        }
        else if (result is Stream stream)
        {
            if (contentType.IsNullOrEmpty()) contentType = "application/octet-stream";
            Body = (ArrayPacket)stream.ReadBytes(-1);
        }
        else if (result is String str)
        {
            if (contentType.IsNullOrEmpty()) contentType = "text/html";
            Body = (ArrayPacket)str.GetBytes();
        }
        else
        {
            if (contentType.IsNullOrEmpty()) contentType = "application/json";
            Body = (ArrayPacket)result.ToJson().GetBytes();
        }

        if (ContentType.IsNullOrEmpty()) ContentType = contentType;
    }

    /// <summary>已重载。</summary>
    /// <returns></returns>
    public override String ToString() => $"HTTP/{Version} {(Int32)StatusCode} {StatusDescription ?? (StatusCode + "")}";
}