package art.servers.colorsserver.M.protocol;

import java.io.ByteArrayOutputStream;

public class M_ProtocolWriter 
{
    public static final int STX   = 0x02;
    public static final int ETX   = 0x03;
    public static final int EOB12 = 0x0A;
    public static final int EOB14 = 0x0C;
    public static final int EOB15 = 0x0D;

    public static final int HTR   = 0x33;
    public static final int PRH   = 0x40;
    public static final int DET   = 0x20;

    public static final int M_READ_TABLE_FULL = 0x20;  // A0;
    public static final int M_WRITE_TABLE_FULL = 0x60;  // E0;
    public static final int M_READ_TABLE_PARTIAL = 0x21;  // A1;
    public static final int M_WRITE_TABLE_PARTIAL = 0x61;  // E1;

    public static final int M_START_RECORDING = 0x59;  // D9;
    public static final int M_START_RECORDING_RESPONSE = 0x19;  // 99;

    public static final int M_END_RECORDING = 0x5A;  // DA;
    public static final int M_END_RECORDING_RESPONSE = 0x1A;  // 9A;

    public static final int M_RECORDABLE_PLAN_QUERY = 0x10;  // 90;
    public static final int M_CURRENT_PLAN_QUERY = 0x11;  // 91;
    public static final int M_CURRENT_TIME_QUERY = 0x12;  // 92;
    public static final int M_CURRENT_SUBCONTROLLER_STATE_QUERY = 0x14;  // 94;
    public static final int M_CURRENT_PRESENCE_DETECTORS = 0x30;  // B0;
    public static final int M_CURRENT_COUNTING_DETECTORS_DATETIME = 0x32;  // B2;
    public static final int M_CURRENT_COUNTING_DETECTORS = 0x33;  // B3;
    public static final int M_ALARMS_QUERY = 0x34;  // B4;
    public static final int M_BLOWN_LAMPS_ALARMS_QUERY = 0x35;  // B5;
    public static final int M_DAMAGED_GROUP_ALARMS_QUERY = 0x36;  // B6;
    public static final int M_INCOMPATIBILITY_ALARMS_QUERY = 0x37;  // B7;
    public static final int M_CURRENT_STATUS_GROUPS_QUERY = 0x39;  // B9;

    public static final int M_SET_REALTIME_BUS_DETECTIONS_ENABLE = 0x40;  // C0;
    public static final int M_SET_REALTIME_BUS_DETECTIONS_DISABLE = 0x41;  // C1;

    public static final int M_REALTIME_BUS_DETECTIONS = 0x3B;  // BB;
    public static final int M_BUS_DETECTIONS_QUERY = 0x3C;  // BC;

    public static final int M_SAVE_RECORDABLE_PLAN = 0x50;  // D0;
    public static final int M_SELECT_PLAN = 0x51;  // D1;
    public static final int M_SET_TIME = 0x52;  // D2;
    public static final int M_SET_REALTIME_DETECTORS = 0x53;  // D3;
    public static final int M_SET_STATE = 0x54;  // D4;
    public static final int M_PHASE_CHANGING = 0x55;  // D5;
    public static final int M_DIRECT_GROUP_OUTPUT = 0x56;  // D6;
    public static final int M_GROUPS_REALTIME_ENABLE = 0x5B;  // DB;
    public static final int M_GROUPS_REALTIME_DISABLE = 0x5C;  // DC;
    public static final int M_ERASE_ALARMS = 0x5D;  // DD;

    public static final int M_SELECT_SPECIAL_DEMAND = 0x5E;  // DE;
    public static final int M_CANCEL_SPECIAL_DEMAND = 0x5F;  // DF;

    private ByteArrayOutputStream bos = new ByteArrayOutputStream();
    
    
    public M_ProtocolWriter()
    {
    }

    
    public void write(int data)
    {
        bos.write((data & 0x7F) + 0x80);
    }

    
    public void writeRaw(int data)
    {
        bos.write(data);
    }

    
    public void writeEOB(int data)
    {
        bos.write(data & 0x7F);
    }
    

    public void write(int[] data)
    {
        for (int i=0; i<data.length; i++)
        {
            write(data[i]);
        }
    }


    public void STX()
    {
        bos.write(STX & 0x7F);
    }


    public void DET()
    {
        bos.write(DET & 0x7F);
    }


    public void ETX(boolean hasCRC)
    {
        if (hasCRC == true)
        {
            byte[] data = toByteArray();
            byte crc = 0x00;
            for (int i=1; i<data.length; i++)
            {
                crc = (byte)(crc ^ (byte)((data[i] - 0x80)));
            }

            bos.write((crc & 0x7F) + 0x80);
        }

        bos.write(ETX & 0x7F);
    }

    // 02 81 A0 8F AE 03

    public void EOB12()
    {
        bos.write(EOB12 & 0x7F);
    }
    
    public void EOB14()
    {
        bos.write(EOB14 & 0x7F);
    }
    
    public void EOB15()
    {
        bos.write(EOB15 & 0x7F);
    }
    
    

    public byte[] toByteArray()
    {
        return bos.toByteArray();
    }
            

    public int[] toIntegerArray()
    {
        byte[] data = bos.toByteArray();
        int[] result = new int[data.length];
        for (int i=0; i<data.length; i++) result[i] = (int)data[i] & 0xFF;
        return result;
    }


    public M_Message createMessage(int controllerCode)
    {
        M_Message message = new M_Message();
        message.controller = controllerCode;
        message.setData(toByteArray());
        message.fillInformation();
        return(message);
    }

}