package art.servers.asfserver.protocols.dgt;

import art.library.model.devices.vms.asf.Asf;
import art.library.model.devices.vms.asf.AsfCommands;
import art.library.model.devices.vms.asf.AsfStatus;
import art.library.model.devices.vms.asf.information.AsfInformationConfigurationAddressState;
import art.library.model.devices.vms.general.VmsGeneral;
import art.library.utils.common.ArrayUtils;
import java.util.ArrayList;
import java.util.List;

public class AsfDgtProtocolConstructor
{

    public AsfDgtProtocolConstructor()
    {
    }

    /**
     * ORDCC
     *
     * @param device
     * @return
     * @throws Exception
     */
    public static byte[] ORDCC(VmsGeneral device) throws Exception
    {
        return new byte[0];
    }

    /**
     * ASF status query
     *
     * @param address
     * @return
     * @throws java.lang.Exception
     */
    public static byte[] readAlarms(int address) throws Exception
    {
        AsfDgtPDU requestAlarms = new AsfDgtPDU();
        requestAlarms.stx = AsfDgtConstants.ASF_STX;
        requestAlarms.etx = AsfDgtConstants.ASF_ETX;
        requestAlarms.address = address;
        requestAlarms.function = AsfDgtConstants.STR_PASF_ALR;
        requestAlarms.information = new int[0];
        byte[] send = requestAlarms.createMessage();
        return (send);
    }

    /**
     * ASF configuration query
     *
     * @param address
     * @return
     * @throws java.lang.Exception
     */
    public static byte[] readConfiguration(int address) throws Exception
    {
        AsfDgtPDU requestConfiguration = new AsfDgtPDU();
        requestConfiguration.stx = AsfDgtConstants.ASF_STX;
        requestConfiguration.etx = AsfDgtConstants.ASF_ETX;
        requestConfiguration.address = address;
        requestConfiguration.function = AsfDgtConstants.STR_PASF_PP;
        requestConfiguration.information = new int[0];
        byte[] send = requestConfiguration.createMessage();
        return (send);
    }

    /**
     * ASF message query
     *
     * @param address
     * @return
     * @throws java.lang.Exception
     */
    public static byte[] readMessage(int address) throws Exception
    {
        AsfDgtPDU requestConfiguration = new AsfDgtPDU();
        requestConfiguration.stx = AsfDgtConstants.ASF_STX;
        requestConfiguration.etx = AsfDgtConstants.ASF_ETX;
        requestConfiguration.address = address;
        requestConfiguration.function = AsfDgtConstants.STR_PASF_EP;
        requestConfiguration.information = new int[0];
        byte[] send = requestConfiguration.createMessage();
        return (send);
    }

    /**
     * ASF reset order
     *
     * @param address
     * @return
     * @throws java.lang.Exception
     */
    public static byte[] reset(int address) throws Exception
    {
        AsfDgtPDU orderReset = new AsfDgtPDU();
        orderReset.stx = AsfDgtConstants.ASF_STX;
        orderReset.etx = AsfDgtConstants.ASF_ETX;
        orderReset.address = address;
        //ASF reset, STR_OASF_RES = 0x15
        orderReset.function = AsfDgtConstants.STR_OASF_RES;
        //Without associated information, empty array
        orderReset.information = new int[0];
        byte[] send = orderReset.createMessage();
        return (send);
    }

    /**
     * ASF mep order
     *
     * @param address
     * @param command
     * @param deviceclone
     * @return
     * @throws java.lang.Exception
     */
    public static byte[] mep(int address, AsfCommands command, Asf deviceclone) throws Exception
    {
        AsfDgtPDU orderReset = new AsfDgtPDU();
        orderReset.stx = AsfDgtConstants.ASF_STX;
        orderReset.etx = AsfDgtConstants.ASF_ETX;
        orderReset.address = address;
        //ASF MEP, STR_OASF_RES = 0x1A
        orderReset.function = AsfDgtConstants.STR_OASF_MEP;
        orderReset.information = ArrayUtils.toIntArray(getBodyContentMessage(command.state, deviceclone));
        byte[] send = orderReset.createMessage();
        return (send);
    }

    /**
     * Get body content message of MEP
     *
     * @param commandState
     * @param deviceclone
     * @return
     */
    public static byte[] getBodyContentMessage(int commandState, Asf deviceclone)
    {
        byte[] result;
        //Off
        if (commandState == AsfCommands.STATE_OFF)
        {
            //AsfDgtConstants.ASF_OFF = '0' = 0x30
            result = new byte[]
            {
                AsfDgtConstants.ASF_OFF
            };
            //Fix state    
        } else
        {
            List<Byte> informationList = new ArrayList<>();
            informationList.add((byte) AsfDgtConstants.ASF_FIX);
            informationList.add((byte) AsfDgtConstants.ASF_TOPOLOGY_1);
            informationList.add((byte) '1');

            List<Byte> lgraphicA = new ArrayList<>();
            AsfInformationConfigurationAddressState addressState = deviceclone.getDeviceInformation().configuration.getByState(commandState);
            lgraphicA.add((byte) '1');
            lgraphicA.add((byte) '1');
            lgraphicA.add((byte) addressState.address);
            lgraphicA.add((byte) (addressState.blinking ? 'S' : 'N'));

            informationList.addAll(lgraphicA);

            result = new byte[informationList.size()];
            int index = 0;
            for (byte elem : informationList)
            {
                result[index++] = elem;
            }
        }
        return result;
    }

    /**
     * ASF timeout order
     *
     * @param address
     * @param command
     * @param deviceclone
     * @return
     * @throws java.lang.Exception
     */
    public static byte[] timeout(int address, AsfCommands command, Asf deviceclone) throws Exception
    {
        int brightness = -1;  // Auto
        if (deviceclone.getDeviceStatus().brightnessMode != AsfStatus.BRIGHTNESS_MODE_AUTO)
        {
            brightness = deviceclone.getDeviceStatus().brightnessLevel;
        }
        int blinkOn = (int) Math.round(deviceclone.getDeviceStatus().blinkOn * 1000);
        int blinkOff = (int) Math.round(deviceclone.getDeviceStatus().blinkOff * 1000);

        if (blinkOn == 0)
        {
            blinkOn = 500;
        }
        if (blinkOff == 0)
        {
            blinkOff = 500;
        }

        int messagetime = 2;
        if (brightness == -1)
        {
            brightness = 'A';
        } else
        {
            brightness = AsfDgtProtocolConstructor.getBrightnessDGTLevel(brightness, deviceclone.getDeviceInformation().maximumBrightnessLevel);
        }

        AsfDgtPDU request = new AsfDgtPDU();
        request.stx = AsfDgtConstants.ASF_STX;
        request.etx = AsfDgtConstants.ASF_ETX;
        request.address = address;
        //ASF MPP, send panel configuration, STR_OASF_MPP = 0x11
        request.function = AsfDgtConstants.STR_OASF_MPP;

        request.information = new int[]
        {
            //Byte 1
            command.timeout == -1 ? deviceclone.getDeviceConfiguration().timeout : command.timeout,
            //Byte 2
            brightness,
            //Byte 3
            address,
            //Byte 4
            messagetime,
            //Byte 5
            blinkOn,
            //Byte 6
            blinkOff,
            //Bytes from 7 to 16: reserved
            /*7*/ 0, /*8*/ 0, /*9*/ 0, /*10*/ 0, /*11*/ 0, /*12*/ 0, /*13*/ 0, /*14*/ 0, /*15*/ 0, /*16*/ 0
        };

        byte[] send = request.createMessage();
        return (send);
    }

    /**
     * ASF mpp order
     *
     * @param address
     * @param command
     * @param deviceclone
     * @return
     * @throws java.lang.Exception
     */
    public static byte[] mpp(int address, AsfCommands command, Asf deviceclone) throws Exception
    {
        int brightness = -1;  // Auto
        if (deviceclone.getDeviceStatus().brightnessMode != AsfStatus.BRIGHTNESS_MODE_AUTO)
        {
            brightness = deviceclone.getDeviceStatus().brightnessLevel;
        }
        if (command.brightness != -2)
        {
            brightness = command.brightness;
        }
        int blinkOn = (int) Math.round(deviceclone.getDeviceStatus().blinkOn * 1000);
        if (command.blinkOn > -1)
        {
            blinkOn = (int) Math.round(command.blinkOn * 1000);
        }
        int blinkOff = (int) Math.round(deviceclone.getDeviceStatus().blinkOff * 1000);
        if (command.blinkOff > -1)
        {
            blinkOff = (int) Math.round(command.blinkOff * 1000);
        }

        if (blinkOn == 0)
        {
            blinkOn = 500;
        }
        if (blinkOff == 0)
        {
            blinkOff = 500;
        }

        int messagetime = 2;
        if (brightness == -1)
        {
            brightness = 'A';
        } else
        {
            brightness = AsfDgtProtocolConstructor.getBrightnessDGTLevel(brightness, deviceclone.getDeviceInformation().maximumBrightnessLevel);
        }

        AsfDgtPDU request = new AsfDgtPDU();
        request.stx = AsfDgtConstants.ASF_STX;
        request.etx = AsfDgtConstants.ASF_ETX;
        request.address = address;
        //ASF MPP, send panel configuration, STR_OASF_MPP = 0x11
        request.function = AsfDgtConstants.STR_OASF_MPP;

        request.information = new int[]
        {
            //Byte 1
            command.timeout == -1 ? deviceclone.getDeviceConfiguration().timeout : command.timeout,
            //Byte 2
            brightness,
            //Byte 3
            address,
            //Byte 4
            messagetime,
            //Byte 5
            blinkOn,
            //Byte 6
            blinkOff,
            //Bytes from 7 to 16: reserved
            /*7*/ 0, /*8*/ 0, /*9*/ 0, /*10*/ 0, /*11*/ 0, /*12*/ 0, /*13*/ 0, /*14*/ 0, /*15*/ 0, /*16*/ 0
        };

        byte[] send = request.createMessage();
        return (send);
    }

    /**
     * BrightnessDGTLevel
     *
     * @param input
     * @param maximum
     * @return
     */
    public static int getBrightnessDGTLevel(int input, int maximum)
    {
        // Input is a 0-100 value
        return ((int) Math.round(((float) input * (float) maximum) / 100f));
    }

    /**
     * BrightnessClientLevel
     *
     * @param input
     * @param maximum
     * @param maximumVms
     * @return
     */
    public static int getBrightnessClientLevel(int input, int maximum, int maximumVms)
    {
        // Input is a 0-7 value
        int result = (int) Math.round(((float) input * (float) maximum) / (float) maximumVms);
        if (result > 100)
        {
            result = 100;
        }
        return (result);
    }
}