99ditui/Admin.Core.Tests/Controller/BaseControllerTest.cs

using Admin.Core.Common.Cache;
using Admin.Core.Common.Configs;
using Admin.Core.Common.Output;
using Admin.Core.Service.Admin.Auth;
using Admin.Core.Service.Admin.Auth.Input;
using Admin.Core.Service.Admin.Auth.Output;
using Admin.Tools.Captcha;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using Newtonsoft.Json.Serialization;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Text;
using System.Threading.Tasks;
using Xunit;

namespace Admin.Core.Tests.Controller
{
    public class BaseControllerTest : BaseTest
    {
        private readonly ICache _cache;
        private readonly ICaptcha _captcha;
        private readonly AppConfig _appConfig;

        protected BaseControllerTest()
        {
            _cache = GetService<ICache>();
            _captcha = GetService<ICaptcha>();
            _appConfig = GetService<AppConfig>();
        }

        public ByteArrayContent GetHttpContent(object input)
        {
            // HttpContent httpContent = new StringContent(JsonConvert.SerializeObject(input));
            var content = Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(input));
            var httpContent = new ByteArrayContent(content);
            httpContent.Headers.ContentType = MediaTypeHeaderValue.Parse("application/json;charset=UTF-8");
            return httpContent;
        }

        public async Task<T> GetResult<T>(string apiPath, object input = null, bool checkStatus = true)
        {
            await Login();
            var res = await Client.GetAsync(apiPath);
            if (checkStatus)
            {
                Assert.Equal(HttpStatusCode.OK, res.StatusCode);
            }
            var content = await res.Content.ReadAsStringAsync();
            return JsonConvert.DeserializeObject<T>(content);
        }

        public async Task<T> PostResult<T>(string apiPath, object input = null, bool checkStatus = true)
        {
            await Login();
            var res = await Client.PostAsync(apiPath, GetHttpContent(input));
            if (checkStatus)
            {
                Assert.Equal(HttpStatusCode.OK, res.StatusCode);
            }
            var content = await res.Content.ReadAsStringAsync();
            return JsonConvert.DeserializeObject<T>(content);
        }

        public async Task<T> PutResult<T>(string apiPath, object input = null, bool checkStatus = true)
        {
            await Login();
            var res = await Client.PutAsync(apiPath, GetHttpContent(input));
            if (checkStatus)
            {
                Assert.Equal(HttpStatusCode.OK, res.StatusCode);
            }
            var content = await res.Content.ReadAsStringAsync();
            return JsonConvert.DeserializeObject<T>(content);
        }

        public async Task<T> DeleteResult<T>(string apiPath, object input = null, bool checkStatus = true)
        {
            await Login();
            var res = await Client.DeleteAsync(apiPath);
            if (checkStatus)
            {
                Assert.Equal(HttpStatusCode.OK, res.StatusCode);
            }
            var content = await res.Content.ReadAsStringAsync();
            return JsonConvert.DeserializeObject<T>(content);
        }

        public async Task<ResultDto<dynamic>> GetResult(string apiPath, object input = null, bool checkStatus = true)
        {
            return await GetResult<ResultDto<dynamic>>(apiPath, input, checkStatus);
        }

        public async Task<ResultDto<dynamic>> PostResult(string apiPath, object input = null, bool checkStatus = true)
        {
            return await PostResult<ResultDto<dynamic>>(apiPath, input, checkStatus);
        }

        public async Task<ResultDto<dynamic>> PutResult(string apiPath, object input = null, bool checkStatus = true)
        {
            return await PutResult<ResultDto<dynamic>>(apiPath, input, checkStatus);
        }

        public async Task<ResultDto<dynamic>> DeleteResult(string apiPath, object input = null, bool checkStatus = true)
        {
            return await DeleteResult<ResultDto<dynamic>>(apiPath, input, checkStatus);
        }

        public async Task Login(AuthLoginInput input = null)
        {
            var authorization = Client.DefaultRequestHeaders.FirstOrDefault(a => a.Key == "Authorization");
            if (authorization.Key != null)
            {
                return;
            }

            if (input == null && _appConfig.VarifyCode.Enable)
            {
                var res = await _captcha.GetAsync();
                var verifyCodeKey = string.Format(CacheKey.VerifyCodeKey, res.Token);
                var verifyCode = await _cache.GetAsync(verifyCodeKey);
                input = new AuthLoginInput()
                {
                    UserName = "admin",
                    Password = "111111",
                    Captcha = new CaptchaInput { Token = res.Token, Data = JsonConvert.SerializeObject(new { X = verifyCode }) }
                };
            }

            //Client.DefaultRequestHeaders.Connection.Add("keep-alive");
            Client.DefaultRequestHeaders.Add("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/81.0.4044.138 Safari/537.36");

            var result = await Client.PostAsync($"/api/admin/auth/login", GetHttpContent(input));
            var content = await result.Content.ReadAsStringAsync();
            var jObject = JsonConvert.DeserializeObject<JObject>(content);
            var token = jObject["data"]["token"];

            Client.DefaultRequestHeaders.Add("Authorization", $"Bearer {token}");
        }

        public string ToParams(object source)
        {
            var stringBuilder = new StringBuilder(string.Empty);
            if (source == null)
            {
                return "";
            }

            var entries = from PropertyDescriptor property in TypeDescriptor.GetProperties(source)
                          let value = property.GetValue(source)
                          where value != null
                          select (property.Name, value);

            foreach (var (name, value) in entries)
            {
                stringBuilder.Append(WebUtility.UrlEncode(name) + "=" + WebUtility.UrlEncode(value + "") + "&");
            }

            return stringBuilder.ToString().Trim('&');
        }
    }
}