using BiblioTech.Options;
using CodexContractsPlugin;
using GethPlugin;
using Logging;

namespace BiblioTech
{
    public static class GethInput
    {
        private const string GethHostVar = "GETH_HOST";
        private const string GethPortVar = "GETH_HTTP_PORT";
        private const string GethPrivKeyVar = "GETH_PRIVATE_KEY";
        private const string MarketplaceAddressVar = "CODEXCONTRACTS_MARKETPLACEADDRESS";
        private const string TokenAddressVar = "CODEXCONTRACTS_TOKENADDRESS";
        private const string AbiVar = "CODEXCONTRACTS_ABI";

        static GethInput()
        {
            var error = new List<string>();
            var gethHost = GetEnvVar(error, GethHostVar);
            var gethPort = Convert.ToInt32(GetEnvVar(error, GethPortVar));
            var privateKey = GetEnvVar(error, GethPrivKeyVar);
            var marketplaceAddress = GetEnvVar(error, MarketplaceAddressVar);
            var tokenAddress = GetEnvVar(error, TokenAddressVar);
            var abi = GetEnvVar(error, AbiVar);

            if (error.Any())
            {
                LoadError = string.Join(", ", error);
            }
            else
            {
                GethHost = gethHost!;
                GethPort = gethPort;
                PrivateKey = privateKey!;
                MarketplaceAddress = marketplaceAddress!;
                TokenAddress = tokenAddress!;
                ABI = abi!;
            }
        }

        public static string GethHost { get; } = string.Empty;
        public static int GethPort { get; }
        public static string PrivateKey { get; } = string.Empty;
        public static string MarketplaceAddress { get; } = string.Empty;
        public static string TokenAddress { get; } = string.Empty;
        public static string ABI { get; } = string.Empty;
        public static string LoadError { get; } = string.Empty;

        private static string? GetEnvVar(List<string> error, string name)
        {
            var result = Environment.GetEnvironmentVariable(name);
            if (string.IsNullOrEmpty(result)) error.Add($"'{name}' is not set.");
            return result;
        }
    }

    public abstract class BaseGethCommand : BaseCommand
    {
        protected override async Task Invoke(CommandContext context)
        {
            if (!string.IsNullOrEmpty(GethInput.LoadError))
            {
                var msg = "Geth input incorrect: " + GethInput.LoadError;
                Program.Log.Error(msg);
                if (IsInAdminChannel(context.Command))
                {
                    await context.Followup(msg);
                }
                else
                {
                    await context.Followup("I'm sorry, there seems to be a configuration error.");
                }
                return;
            }

            var contractsDeployment = new CodexContractsDeployment(
                marketplaceAddress: GethInput.MarketplaceAddress,
                abi: GethInput.ABI,
                tokenAddress: GethInput.TokenAddress
            );

            var gethNode = new CustomGethNode(Program.Log, GethInput.GethHost, GethInput.GethPort, GethInput.PrivateKey);
            var contracts = new CodexContractsAccess(Program.Log, gethNode, contractsDeployment);

            if (!contracts.IsDeployed())
            {
                await context.Followup("I'm sorry, the Codex SmartContracts are not currently deployed.");
                return;
            }

            await Execute(context, gethNode, contracts);
        }

        protected abstract Task Execute(CommandContext context, IGethNode gethNode, ICodexContracts contracts);
    }
}