package art.servers;

import art.servers.colorsserver.controller.ListenerImplementation;
import art.servers.colorsserver.Shared;
import art.library.gui.flat.FlatDialog;
import art.library.interop.serialization.Serialization;
import art.library.model.devices.Device;
import art.library.model.devices.colors.controller.M.M_Controller;
import art.library.model.devices.colors.controller.M.M_ControllerInformation;
import art.library.utils.licence.Licence;
import art.servers.colorsserver.controller.ControllerConnection;
import art.servers.colorsserver.controller.ControllerDynamicController;
import art.servers.colorsserver.controller.ControllerRtacController;
import art.servers.colorsserver.controller.ControllerTelventController;
import art.servers.controller.ControllerDevice;
import java.io.PrintWriter;
import java.io.StringWriter;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;


public class ColorsServer extends art.servers.Server
{
    public static boolean ACTIVATE_REALTIME = false;


    public static void main(String[] args) 
    {
        try
        {
            String user = "7dLkfR5ZjYTOYvVrVeeihQ==";
            String UserBD = "A/zYtigVU7uJN/pJjR1y0A==";
            String PasswordBD = "cTSO+EwtFDjTE5l40R+s8w==";
            String Readuser = "jH+/Jk+P3gdtZDOOwoqnNQ==";
            String Readpassword = "jH+/Jk+P3gdtZDOOwoqnNQ==";
            System.out.println(Licence.decrypt(Readuser));
            System.out.println(Licence.decrypt(Readpassword));
//            System.out.println(Licence.decrypt(user));
//            System.out.println(Licence.decrypt(UserBD));
//            System.out.println(Licence.decrypt(PasswordBD));
            ACTIVATE_REALTIME = existParameter(args, "-activaterealtime");
            Shared.setApplicationCode("FsEhD8Bp4LqdRHtbrg5ykzmqwmtDQP3m");
            Shared.setApplicationName("art.servers.colorsserver");
            preinitialise(args);
            Shared.model = new art.servers.colorsserver.Model(Shared.configuration);
            postinitialise(args);
            Shared.controllerListener.setListenerImplementation(new ListenerImplementation());

            HashMap<String, List<M_Controller>> hcontrollers = new HashMap<String, List<M_Controller>>();
            System.out.println("MODEL.LDEVICE: " + Shared.model.ldevice.size());
            for (Device device : Shared.model.ldevice)
            {
                try
                {
                    System.out.println("DEVICE: " + device.getIdentifier());
                    M_Controller m_controller = (M_Controller)device;
                    List<M_Controller> lcontrollers = hcontrollers.get(m_controller.getDeviceInformation().address + ":" + m_controller.getDeviceInformation().portM);
                    if (lcontrollers == null)
                    {
                        boolean hasCRC = false;
                        if ((m_controller.getDeviceInformation().type == M_ControllerInformation.TYPE_RTAC) ||
                            (m_controller.getDeviceInformation().type == M_ControllerInformation.TYPE_CMY))
                            hasCRC = true;

                        ControllerConnection controllerConnection = new ControllerConnection(m_controller.getDeviceInformation().address, m_controller.getDeviceInformation().portM, m_controller.getDeviceInformation().timeout, hasCRC);
                        Shared.addControllerConnection(m_controller.getDeviceInformation().address + ":" + m_controller.getDeviceInformation().portM, controllerConnection);
                        controllerConnection.start();

                        lcontrollers = new ArrayList<M_Controller>();
                        hcontrollers.put(m_controller.getDeviceInformation().address + ":" + m_controller.getDeviceInformation().portM, lcontrollers);
                    }

                    lcontrollers.add(m_controller);
                }
                catch (Exception e)
                {
                    e.printStackTrace();
                    System.out.println("DEVICE.EX: " + device.getIdentifier() + " - " + e.toString());
                }
            }

            Collection<List<M_Controller>> lvalues = hcontrollers.values();
            Iterator<List<M_Controller>> iterator = lvalues.iterator();
            while (iterator.hasNext())
            {
                List<M_Controller> lcontroller = iterator.next();

                if (lcontroller.size() == 1)
                {
                    M_Controller m_controller = lcontroller.get(0);
                    System.out.println("CONTROLLER 1: " + m_controller.getIdentifier());

                    if (m_controller.getDeviceInformation().type == M_ControllerInformation.TYPE_DYNAMIC)
                    {
                        ControllerDevice controller = new ControllerDynamicController(m_controller, false);
                        Shared.lcontroller.add(controller);
                        controller.start();
                    }
                    else if (m_controller.getDeviceInformation().type == M_ControllerInformation.TYPE_RMY)
                    {
                        ControllerDevice controller = new ControllerTelventController(m_controller, false);
                        Shared.lcontroller.add(controller);
                        controller.start();
                    }
                    else if (m_controller.getDeviceInformation().type == M_ControllerInformation.TYPE_RTAC)
                    {
                        ControllerDevice controller = new ControllerRtacController(m_controller, true);
                        Shared.lcontroller.add(controller);
                        controller.start();
                    }
                    else if (m_controller.getDeviceInformation().type == M_ControllerInformation.TYPE_CMY)
                    {
                        ControllerDevice controller = new ControllerTelventController(m_controller, true);
                        Shared.lcontroller.add(controller);
                        controller.start();
                    }
                }
                else
                {
                    System.out.println("CONTROLLER > 1: " + lcontroller.size());
                    M_Controller m_controller = null;
                    for (M_Controller m_controllerSub : lcontroller)
                    {
                        if (m_controller == null)
                        {
                            m_controller = Serialization.clone(m_controllerSub);
                        }
                        else
                        {
                            m_controller.getDeviceConfiguration().lsubcontroller.addAll(m_controllerSub.getDeviceConfiguration().lsubcontroller);
                            m_controller.getDeviceStatus().lsubcontroller.addAll(m_controllerSub.getDeviceStatus().lsubcontroller);
                            m_controller.getDeviceStatus().lsubcontrollerUpdate.addAll(m_controllerSub.getDeviceStatus().lsubcontrollerUpdate);
                        }
                    }

                    if (m_controller.getDeviceInformation().type == M_ControllerInformation.TYPE_DYNAMIC)
                    {
                        ControllerDevice controller = new ControllerDynamicController(m_controller, lcontroller, false);
                        Shared.lcontroller.add(controller);
                        controller.start();
                    }
                    else if (m_controller.getDeviceInformation().type == M_ControllerInformation.TYPE_RMY)
                    {
                        ControllerDevice controller = new ControllerTelventController(m_controller, false);
                        Shared.lcontroller.add(controller);
                        controller.start();
                    }
                    else if (m_controller.getDeviceInformation().type == M_ControllerInformation.TYPE_RTAC)
                    {
                        ControllerDevice controller = new ControllerRtacController(m_controller, true);
                        Shared.lcontroller.add(controller);
                        controller.start();
                    }
                    else if (m_controller.getDeviceInformation().type == M_ControllerInformation.TYPE_CMY)
                    {
                        ControllerDevice controller = new ControllerTelventController(m_controller, true);
                        Shared.lcontroller.add(controller);
                        controller.start();
                    }
                }
            }


            // Factory controller
//            Shared.model.factoryController = new FactoryController();
//            Shared.model.factoryController.start();
        }
        catch (Exception e)
        {
            e.printStackTrace();
            StringWriter sw = new StringWriter();
            e.printStackTrace(new PrintWriter(sw));
            FlatDialog.showDialog(null, Shared.getMessage("Error"), e.getMessage() + "\n\n" + sw.toString(), true, FlatDialog.DIALOG_INFORMATION);
            System.exit(0);
        }
    }

}
/*
            try
            {
                if (existParameter(args, "-createcontrollers") == true)
                {
                    File f = new File("docs/17.json");
                    M_Controller m_controller = Serialization.deserialize(M_Controller.class, f);
                    System.out.println(m_controller.getIdentifier());
                    System.out.println(m_controller.getDeviceConfiguration().lsubcontroller.size());
                    System.out.println(m_controller.getDeviceConfiguration().lsubcontroller.get(0));
                    Shared.controllerDatabase.timeless_updateOrAddObject(new DevicePersistenceTimeless(m_controller));
                    f = new File("docs/18.json");
                    m_controller = Serialization.deserialize(M_Controller.class, f);
                    System.out.println(m_controller.getIdentifier());
                    System.out.println(m_controller.getDeviceConfiguration().lsubcontroller.size());
                    System.out.println(m_controller.getDeviceConfiguration().lsubcontroller.get(0));
                    Shared.controllerDatabase.timeless_updateOrAddObject(new DevicePersistenceTimeless(m_controller));
                    f = new File("docs/39.json");
                    m_controller = Serialization.deserialize(M_Controller.class, f);
                    System.out.println(m_controller.getIdentifier());
                    System.out.println(m_controller.getDeviceConfiguration().lsubcontroller.size());
                    System.out.println(m_controller.getDeviceConfiguration().lsubcontroller.get(0));
                    Shared.controllerDatabase.timeless_updateOrAddObject(new DevicePersistenceTimeless(m_controller));
                    f = new File("docs/40.json");
                    m_controller = Serialization.deserialize(M_Controller.class, f);
                    System.out.println(m_controller.getIdentifier());
                    System.out.println(m_controller.getDeviceConfiguration().lsubcontroller.size());
                    System.out.println(m_controller.getDeviceConfiguration().lsubcontroller.get(0));
                    Shared.controllerDatabase.timeless_updateOrAddObject(new DevicePersistenceTimeless(m_controller));
                    f = new File("docs/41.json");
                    m_controller = Serialization.deserialize(M_Controller.class, f);
                    System.out.println(m_controller.getIdentifier());
                    System.out.println(m_controller.getDeviceConfiguration().lsubcontroller.size());
                    System.out.println(m_controller.getDeviceConfiguration().lsubcontroller.get(0));
                    Shared.controllerDatabase.timeless_updateOrAddObject(new DevicePersistenceTimeless(m_controller));
                    f = new File("docs/42.json");
                    m_controller = Serialization.deserialize(M_Controller.class, f);
                    System.out.println(m_controller.getIdentifier());
                    System.out.println(m_controller.getDeviceConfiguration().lsubcontroller.size());
                    System.out.println(m_controller.getDeviceConfiguration().lsubcontroller.get(0));
                    Shared.controllerDatabase.timeless_updateOrAddObject(new DevicePersistenceTimeless(m_controller));
                    if (art.servers.Shared.controllerDatabase != null)
                    {
                        List<Device> ldevice = (List<Device>)DevicePersistenceTimeless.getDevices((List<Object>)(List<?>)art.servers.Shared.controllerDatabase.timeless_getObject(DevicePersistenceTimeless.class.getName(), "type = '" + M_Controller.class.getName() + "'"));
                        System.out.println("LDEVICE: " + ldevice.size());

                        for (Device device : ldevice)
                        {
                            M_Controller m_controller2 = (M_Controller)device;
                            System.out.println("A1.------------------ " + m_controller2.getIdentifier());
                            System.out.println("A2.------------------ " + m_controller2.getDeviceConfiguration().lsubcontroller.size());
                            System.out.println("A3.------------------ " + m_controller2.getDeviceConfiguration().ltrafficGroup.size());
                            System.out.println("A4.------------------ " + device.information.serverPort);
                            System.out.println("A5.------------------ " + device.information.serverAddress);
                            System.out.println("A6.------------------ " + art.servers.Shared.configuration.listener.port);
                            System.out.println("A7.------------------ " + art.servers.Shared.configuration.listener.address);
                            if ((device instanceof Device) && (device.information.serverPort == art.servers.Shared.configuration.listener.port) && (device.information.serverAddress.equalsIgnoreCase(art.servers.Shared.configuration.listener.address)))
                            {
                                device.information.serverAddress = art.servers.Shared.configuration.listener.address;
                                device.information.serverPort = art.servers.Shared.configuration.listener.port;
                                device.information.serverAddressExternal = art.servers.Shared.configuration.listener.addressExternal;
                                device.information.serverPortExternal = art.servers.Shared.configuration.listener.portExternal;
                            }
                        }
                    }
                }
            }
            catch (Exception e)
            {
                e.printStackTrace();
            }

*/