using System;
using System.Text;
using ArchestrAServices.Common;

namespace Asb.Base.V2;

public class SystemAuthenticationServiceAuthentication : SystemAuthenticationConnectionBase
{
	public ulong Lifetime { get; private set; }

	public SystemAuthenticationServiceAuthentication()
	{
		Reset();
		Lifetime = 18000000uL;
	}

	public static ConnectResponse ProcessClientConnection(ConnectRequest request)
	{
		ServiceTrace.LogResume("SystemAuthenticationServiceAuthentication.ProcessClientConnection entry");
		if (request == null)
		{
			return null;
		}
		ServiceTrace.LogVerbose("SysSvcAuth: Processing client Connect() call '{0}'", request.ConnectionId);
		if (request.ConsumerPublicKey == null)
		{
			return null;
		}
		if (request.ConsumerPublicKey.Data == null)
		{
			return null;
		}
		SystemAuthenticationServiceAuthentication systemAuthenticationServiceAuthentication = new SystemAuthenticationServiceAuthentication
		{
			ConnectionId = request.ConnectionId,
			RemotePublicKey = request.ConsumerPublicKey.Data
		};
		SysAuthenticatorServiceCache.AddServiceAuthenticator(systemAuthenticationServiceAuthentication);
		PublicKey servicePublicKey = new PublicKey
		{
			Data = systemAuthenticationServiceAuthentication.LocalPublicKey
		};
		AuthenticationData authenticationData = new AuthenticationData();
		authenticationData.Data = systemAuthenticationServiceAuthentication.CalculateAuthenticationData(systemAuthenticationServiceAuthentication.LocalPublicKey, systemAuthenticationServiceAuthentication.RemotePublicKey, out var initializationVector);
		authenticationData.InitializationVector = initializationVector;
		ArchestrAResult result = ArchestrAResult.MakeGoodResult();
		systemAuthenticationServiceAuthentication.Lifetime = systemAuthenticationServiceAuthentication.SolutionParameters.ConnectionLifetime;
		ConnectResponse connectResponse = new ConnectResponse(result, servicePublicKey, authenticationData, systemAuthenticationServiceAuthentication.Lifetime + ":" + SystemAuthenticationConnectionBase.AsbAuthenticationVersion);
		systemAuthenticationServiceAuthentication.Sign(connectResponse, forceHmac: true);
		systemAuthenticationServiceAuthentication.ReasonSecureSessionNotEstablished = string.Empty;
		ServiceTrace.LogSuspend("SystemAuthenticationServiceAuthentication.ProcessClientConnection exit");
		return connectResponse;
	}

	public bool ProcessClientAuthenticateMe(AuthenticateMeRequest request)
	{
		ServiceTrace.LogResume("SystemAuthenticationServiceAuthentication.ProcessClientAuthenticateMe entry with connection Id {0}", request.ConnectionValidator.ConnectionId);
		ServiceTrace.LogVerbose("SystemAuthenticationServiceAuthentication: Processing client AuthenticateMe() call for connection id {0}", request.ConnectionValidator.ConnectionId);
		if (!ValidRequest(request, forceHmac: true))
		{
			return false;
		}
		AuthenticationData consumerAuthenticationData = request.ConsumerAuthenticationData;
		if (consumerAuthenticationData != null)
		{
			byte[] expected = ReCalculateAuthenticationData(RemotePublicKey, LocalPublicKey, consumerAuthenticationData.InitializationVector);
			if (consumerAuthenticationData.AreEqual(expected))
			{
				ServiceTrace.LogVerbose("SystemAuthenticationServiceAuthentication: AuthenticateMe() authenticated client");
				base.SecureSessionEstablished = true;
			}
		}
		ServiceTrace.LogSuspend("SystemAuthenticationServiceAuthentication.ProcessClientAuthenticateMe exit");
		return base.SecureSessionEstablished;
	}

	public static RenewResponse ProcessClientRenew(RenewRequest request)
	{
		ServiceTrace.LogResume("SystemAuthenticationServiceAuthentication.ProcessClientRenew entry with connection Id {0}", request.ConnectionValidator.ConnectionId);
		SysAuthenticatorServiceCache.GetServiceAuthenticator(request.ConnectionValidator.ConnectionId)?.ValidRequest(request, forceHmac: false);
		ServiceTrace.LogSuspend("SystemAuthenticationServiceAuthentication.ProcessClientRenew exit");
		return null;
	}

	public static void ProcessClientUpdateSystemAuthenticationConfiguration(UpdateSystemAuthenticationConfigurationRequest request)
	{
		ServiceTrace.LogResume("SystemAuthenticationServiceAuthentication.ProcessClientUpdateSystemAuthenticationConfiguration entry with connection Id {0}", request.ConnectionValidator.ConnectionId);
		SysAuthenticatorServiceCache.GetServiceAuthenticator(request.ConnectionValidator.ConnectionId)?.ValidRequest(request, forceHmac: false);
		ServiceTrace.LogSuspend("SystemAuthenticationServiceAuthentication.ProcessClientUpdateSystemAuthenticationConfiguration exit");
	}

	public void ProcessClientDisconnect(DisconnectRequest request)
	{
		if (request == null)
		{
			return;
		}
		ServiceTrace.LogResume("SystemAuthenticationServiceAuthentication.ProcessClientDisconnect entry with connection Id {0}", request.ConnectionValidator.ConnectionId);
		AuthenticationData consumerAuthenticationData = request.ConsumerAuthenticationData;
		if (consumerAuthenticationData != null)
		{
			byte[] bytes = Decypher(consumerAuthenticationData.Data, consumerAuthenticationData.InitializationVector);
			if (Guid.TryParse(Encoding.UTF8.GetString(bytes), out var result) && result == base.ConnectionId)
			{
				SysAuthenticatorServiceCache.RemoveServiceAuthenticator(result);
			}
		}
		ServiceTrace.LogSuspend("SystemAuthenticationServiceAuthentication.ProcessClientDisconnect exit");
	}
}