using AdsCommunicatorNet8;
using ProtocalGeneral;

namespace MinicsConsole.Connector;

public class PLCNotifier(HardwareAddress address, ILog log) : IMini8DataNotifier, ITcpConnectNority, IDisposable
{
    private readonly AdsCommunicator _connector = new(log);
    public string Name { get; set; } = "PLC TwinCat Ads";

    public bool StartService()
    {
        if (address.PLCAddress is null)
            return false;
        if (string.IsNullOrEmpty(address.PLCAddress.IPAddress))
            return false;

        this._connector.Initialize(this);
        this._connector.Open(address.PLCAddress.IPAddress, address.PLCAddress.Port);

        return true;
    }


    public void Dispose()
    {
        this._connector?.Dispose();
    }

    void IMini8DataNotifier.ChannelInfoNotify(byte mini8, byte channel, ChannelData channelData)
    {
        if (this._connector is null)
            return;

        if (!this._PlcConnected)
            return;

        if (!address.PLCChannelsAddresses.TryGetSubValue(mini8, channel, out ChannelAddressPLC? channelAddress) || channelAddress is null)
            return;

        if (string.IsNullOrEmpty(channelAddress.PV))
            return;


        if (!this._connector.SetValue(channelAddress.PV, channelData.PV))
            log.Warning($"PLCNotifier ChannelInfoNotify Send Mini8 - {mini8} channel {channel} PV {channelData.PV} Failed");
    }
    private bool _PlcConnected = false;


    void ITcpConnectNority.Connect(string ip, int port)
    {
        this._PlcConnected = true;
        log.Info($"PLC Connected {ip}:{port}");
    }

    void ITcpConnectNority.DisConnect(string ip, int port)
    {
        this._PlcConnected = false;
        log.Warning($"PLC Disconnected {ip}:{port}");
    }

    void IMini8DataNotifier.AlarmNotify(byte mini8, byte channel, float temperature)
    {
    }

    void IMini8DataNotifier.AlarmTcBrockenNotify(byte mini8, byte channel)
    {
    }

    void IMini8DataNotifier.Mini8ConnectNotify(byte mini8, bool connected)
    {
    }
}