using System;
using System.IO;
using System.Text;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
using NewLife;
using NewLife.Collections;
using Stardust.Data;
using Stardust.Server.Common;

namespace Stardust.Server.Controllers
{
    [ApiController]
    [Route("[controller]")]
    public class LogController : ControllerBase
    {
        [HttpGet]
        public Object Get() => "LogController";

        [HttpPost]
        public async Task<EmptyResult> Post()
        {
            //var buffer = Request.BodyReader.ReadAsync().Result.Buffer;
            //var content = Encoding.UTF8.GetString(buffer.FirstSpan);
            var r = new StreamReader(Request.Body);
            var content = await r.ReadToEndAsync();
            //var content = Request.Body.ToStr();
            if (!content.IsNullOrEmpty())
            {
                var appId = Request.Headers["X-AppId"] + "";
                var clientId = Request.Headers["X-ClientId"] + "";
                var ip = HttpContext.GetUserHost();
                var set = Setting.Current;

                // 验证应用
                var app = App.FindByName(appId);
                if (app == null && !appId.IsNullOrEmpty())
                {
                    app = new App
                    {
                        Name = appId,
                        Enable = set.AutoRegister,
                    };
                    app.Insert();
                }
                if (app != null && app.Enable)
                {
                    // 00:00:04.205  7 Y 1 NewLife.Core v8.10.2020.1020
                    var lines = content.Split(Environment.NewLine);
                    for (var i = 0; i < lines.Length; i++)
                    {
                        // 时间、线程、类型、名称
                        var ss = new String[4];
                        var p = ReadExpect(lines[i], ' ', ss);
                        if (p > 0 && ss[0] != null && ss[0].Length == 12 && ss[1].ToInt() > 0)
                        {
                            var msg = lines[i][p..]?.Trim();
                            var sb = Pool.StringBuilder.Get();
                            sb.AppendLine(msg);

                            // 尝试后续行
                            for (var j = i + 1; j < lines.Length; j++)
                            {
                                var ss2 = new String[4];
                                var p2 = ReadExpect(lines[j], ' ', ss2);
                                if (p2 > 0 && ss2[0] != null && ss2[0].Length == 12 && ss2[1].ToInt() > 0) break;

                                sb.AppendLine(lines[j]);
                                i++;
                            }
                            msg = sb.Put(true);

                            AppLog.Create(app.Id, clientId, ss, msg, ip);
                            sb.Clear();
                        }
                    }
                }
            }

            return new EmptyResult();
        }

        private static Int32 ReadExpect(String value, Char ch, String[] ss)
        {
            var p = 0;
            for (var i = 0; i < ss.Length && p < value.Length; i++)
            {
                var p2 = value.IndexOf(ch, p);
                if (p2 < 0) break;

                ss[i] = value[p..p2];

                p = p2 + 1;

                // 跳过连续符号
                while (p < value.Length && value[p] == ch) p++;
            }

            return p;
        }
    }
}