using System;
using System.IO;
using System.Reflection;
using System.Linq;
using System.IO.Compression;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using Oqtane.Infrastructure;
using Oqtane.Models;
using Oqtane.Shared;
using Microsoft.Extensions.Caching.Memory;
using System.Net;
using Oqtane.Repository;
using Microsoft.AspNetCore.Http;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Threading.Tasks;
using Microsoft.Extensions.Logging;
using System.Collections.Generic;

namespace Oqtane.Controllers
{
    [Route(ControllerRoutes.ApiRoute)]
    public class InstallationController : Controller
    {
        private readonly IConfigManager _configManager;
        private readonly IInstallationManager _installationManager;
        private readonly IDatabaseManager _databaseManager;
        private readonly ILocalizationManager _localizationManager;
        private readonly IMemoryCache _cache;
        private readonly IHttpContextAccessor _accessor;
        private readonly IAliasRepository _aliases;
        private readonly ISiteRepository _sites;
        private readonly ILogger<InstallationController> _filelogger;
        private readonly ITenantManager _tenantManager;
        private readonly IServerStateManager _serverState;

        public InstallationController(IConfigManager configManager, IInstallationManager installationManager, IDatabaseManager databaseManager, ILocalizationManager localizationManager, IMemoryCache cache, IHttpContextAccessor accessor, IAliasRepository aliases, ISiteRepository sites, ILogger<InstallationController> filelogger, ITenantManager tenantManager, IServerStateManager serverState)
        {
            _configManager = configManager;
            _installationManager = installationManager;
            _databaseManager = databaseManager;
            _localizationManager = localizationManager;
            _cache = cache;
            _accessor = accessor;
            _aliases = aliases;
            _sites = sites;
            _filelogger = filelogger;
            _tenantManager = tenantManager;
            _serverState = serverState;
        }

        // POST api/<controller>
        [HttpPost]
        public async Task<Installation> Post([FromBody] InstallConfig config)
        {
            var installation = new Installation { Success = false, Message = "" };

            if (ModelState.IsValid && (User.IsInRole(RoleNames.Host) || string.IsNullOrEmpty(_configManager.GetSetting($"{SettingKeys.ConnectionStringsSection}:{SettingKeys.ConnectionStringKey}", ""))))
            {
                installation = _databaseManager.Install(config);

                if (installation.Success)
                {
                    await RegisterContact(config.HostEmail, config.HostName, config.Register);
                }
            }
            else
            {
                installation.Message = "Installation Not Authorized";
            }

            return installation;
        }

        // GET api/<controller>/installed/?path=xxx
        [HttpGet("installed")]
        public Installation IsInstalled(string path)
        {
            var installation = _databaseManager.IsInstalled();
            if (installation.Success)
            {
                path = _accessor.HttpContext.Request.Host.Value + "/" + WebUtility.UrlDecode(path);
                installation.Alias = _aliases.GetAlias(path);
            }
            return installation;
        }

        [HttpGet("upgrade")]
        [Authorize(Roles = RoleNames.Host)]
        public Installation Upgrade()
        {
            var installation = new Installation { Success = true, Message = "" };
            _installationManager.UpgradeFramework();
            return installation;
        }

        // GET api/<controller>/restart
        [HttpPost("restart")]
        [Authorize(Roles = RoleNames.Host)]
        public void Restart()
        {
            _installationManager.RestartApplication();
        }

        // GET api/<controller>/list
        [HttpGet("list")]
        public List<string> List()
        {
            return GetAssemblyList().Select(item => item.HashedName).ToList();
        }

        private List<ClientAssembly> GetAssemblyList()
        {
            var alias = _tenantManager.GetAlias();

            return _cache.GetOrCreate($"assemblieslist:{alias.SiteKey}", entry =>
            {
                var assemblyList = new List<ClientAssembly>();

                var site = _sites.GetSite(alias.SiteId);
                if (site != null && (site.Runtime == Runtimes.WebAssembly || site.Hybrid))
                {
                    var binFolder = Path.GetDirectoryName(Assembly.GetEntryAssembly().Location);

                    // testmode setting is used for validating that the API is downloading the appropriate assemblies to the client
                    bool hashfilename = true;
                    if (_configManager.GetSetting($"{SettingKeys.TestModeKey}", "false") == "true")
                    {
                        hashfilename = false;
                    }

                    // get site assemblies which should be downloaded to client
                    var assemblies = _serverState.GetServerState(alias.SiteKey).Assemblies;

                    // populate assembly list
                    foreach (var assembly in assemblies)
                    {
                        if (assembly != Constants.ClientId)
                        {
                            var filepath = Path.Combine(binFolder, assembly) + ".dll";
                            if (System.IO.File.Exists(filepath))
                            {
                                assemblyList.Add(new ClientAssembly(Path.Combine(binFolder, assembly + ".dll"), hashfilename));
                            }
                        }
                    }

                    // insert satellite assemblies at beginning of list
                    foreach (var culture in _localizationManager.GetInstalledCultures())
                    {
                        if (culture != Constants.DefaultCulture)
                        {
                            var assembliesFolderPath = Path.Combine(binFolder, culture);
                            if (Directory.Exists(assembliesFolderPath))
                            {
                                foreach (var assembly in assemblies)
                                {
                                    var filepath = Path.Combine(assembliesFolderPath, assembly) + ".resources.dll";
                                    if (System.IO.File.Exists(filepath))
                                    {
                                        assemblyList.Insert(0, new ClientAssembly(Path.Combine(assembliesFolderPath, assembly + ".resources.dll"), hashfilename));
                                    }
                                }
                            }
                            else
                            {
                                _filelogger.LogError(Utilities.LogMessage(this, $"The Satellite Assembly Folder For {culture} Does Not Exist"));
                            }
                        }
                    }
                }
                return assemblyList;
            }).ToList();

        }

        // GET api/<controller>/load?list=x,y
        [HttpGet("load")]
        public IActionResult Load(string list = "*")
        {
            return File(GetAssemblies(list), System.Net.Mime.MediaTypeNames.Application.Octet, "oqtane.dll");
        }

        private byte[] GetAssemblies(string list)
        {
            var alias = _tenantManager.GetAlias();

            if (list == "*")
            {
                return _cache.GetOrCreate($"assemblies:{alias.SiteKey}", entry =>
                {
                    return GetZIP(list, alias);
                });
            }
            else
            {
                return GetZIP(list, alias);
            }
        }

        private byte[] GetZIP(string list, Alias alias)
        {
            var site = _sites.GetSite(alias.SiteId);
            if (site != null && (site.Runtime == Runtimes.WebAssembly || site.Hybrid))
            {
                var binFolder = Path.GetDirectoryName(Assembly.GetEntryAssembly().Location);

                // get list of assemblies which should be downloaded to client
                List<ClientAssembly> assemblies = GetAssemblyList();
                if (list != "*")
                {
                    var filter = list.Split(',').ToList();
                    assemblies.RemoveAll(item => !filter.Contains(item.HashedName));
                }

                // create zip file containing assemblies and debug symbols
                using (var memoryStream = new MemoryStream())
                {
                    using (var archive = new ZipArchive(memoryStream, ZipArchiveMode.Create, true))
                    {
                        foreach (var assembly in assemblies)
                        {
                            if (Path.GetFileNameWithoutExtension(assembly.FilePath) != Constants.ClientId)
                            {
                                if (System.IO.File.Exists(assembly.FilePath))
                                {
                                    using (var filestream = new FileStream(assembly.FilePath, FileMode.Open, FileAccess.Read))
                                    using (var entrystream = archive.CreateEntry(assembly.HashedName).Open())
                                    {
                                        filestream.CopyTo(entrystream);
                                    }
                                }
                                var pdb = assembly.FilePath.Replace(".dll", ".pdb");
                                if (System.IO.File.Exists(pdb))
                                {
                                    using (var filestream = new FileStream(pdb, FileMode.Open, FileAccess.Read))
                                    using (var entrystream = archive.CreateEntry(assembly.HashedName.Replace(".dll", ".pdb")).Open())
                                    {
                                        filestream.CopyTo(entrystream);
                                    }
                                }
                            }
                        }
                    }

                    return memoryStream.ToArray();
                }
            }
            else
            {
                // return empty zip
                using (var memoryStream = new MemoryStream())
                {
                    using (var zip = new ZipArchive(memoryStream, ZipArchiveMode.Create)) {}
                    return memoryStream.ToArray();
                }
            }
        }

        private async Task RegisterContact(string email, string name, bool register)
        {
            try
            {
                var url = _configManager.GetSetting("PackageRegistryUrl", Constants.PackageRegistryUrl);
                if (!string.IsNullOrEmpty(url))
                {
                    using (var client = new HttpClient())
                    {
                        client.DefaultRequestHeaders.Add("Referer", HttpContext.Request.Scheme + "://" + HttpContext.Request.Host.Value);
                        client.DefaultRequestHeaders.UserAgent.Add(new ProductInfoHeaderValue(Constants.PackageId, Constants.Version));
                        var response = await client.GetAsync(new Uri(url + $"/api/registry/contact/?id={_configManager.GetInstallationId()}&email={WebUtility.UrlEncode(email)}&name={WebUtility.UrlEncode(name)}&register={register.ToString().ToLower()}")).ConfigureAwait(false);
                    }
                }
            }
            catch
            {
                // error calling registry service
            }
        }

        public struct ClientAssembly
        {
            public ClientAssembly(string filepath, bool hashfilename)
            {
                FilePath = filepath;
                DateTime lastwritetime = System.IO.File.GetLastWriteTime(filepath);
                if (hashfilename)
                {
                    HashedName = Utilities.GenerateSimpleHash(filepath) + "." + lastwritetime.ToString("yyyyMMddHHmmss") + Path.GetExtension(filepath);
                }
                else
                {
                    HashedName = Path.GetFileNameWithoutExtension(filepath) + "." + lastwritetime.ToString("yyyyMMddHHmmss") + Path.GetExtension(filepath);
                }
            }

            public string FilePath { get; private set; }
            public string HashedName { get; private set; }
        }
    }
}