package art.servers.rtzserver;

import art.library.interop.serialization.Serialization;
import art.library.model.devices.Device;
import art.library.model.devices.DeviceInformation;
import art.library.model.devices.DevicePersistenceTimeless;
import art.library.model.devices.colors.controller.RTZ32.RTZ32_Controller;
import art.library.model.devices.colors.controller.RTZ32.RTZ32_ControllerInformation;
import art.servers.configuration.Configuration;
import java.io.File;
import java.io.FileOutputStream;
import java.lang.reflect.Array;
import java.util.Collections;
import java.util.Comparator;
import java.util.List;



public class Model extends art.servers.Model
{
    
    public Model(Configuration configuration) throws Exception
    {
        super(configuration, "controllers", RTZ32_Controller.class.getName(), RTZ32_ControllerInformation.class.getName());
    }
    
    

    // TODO: Para poder debugar desde nuestros ordenadores

    public void readDevices()
    {
        if (filename == null) return;
            
        mutexListDevices.lockWrite();
        
        try
        {
            
            ldevice.clear();
            mdevice.clear();

            // Read data from database file (--restore)
            
            if (art.servers.Shared.restoreDevices == true)
            {
                Class clazzDevice = Class.forName(deviceClassName);
                Class<?> clazzArray = (Class<?>)Array.newInstance(clazzDevice, 0).getClass();
                List<Device> ldevice = (List<Device>)Serialization.deserialize(clazzArray, new File(art.servers.Shared.getApplicationName() + "."  + filename + ".database.json"));

                for (Device device : ldevice)
                {
                    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;
                        this.ldevice.add(device);
                        this.mdevice.put(device.getIdentifier(), device);
                    }
                }
            }
            
            // Read data from database
            
            else if ((art.servers.Shared.controllerDatabase != null) &&  (art.servers.Shared.reloadDevices == false))
            {
                Class clazzDevice = Class.forName(deviceClassName);
                
                List<Device> ldevice = (List<Device>)DevicePersistenceTimeless.getDevices((List<Object>)(List<?>)art.servers.Shared.controllerDatabase.timeless_getObject(DevicePersistenceTimeless.class.getName(), "type = '" + clazzDevice.getName() + "'"));

                for (Device device : ldevice)
                {
                    try
                    {
                        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;
                            this.ldevice.add(device);
                            this.mdevice.put(device.getIdentifier(), device);
                        }
                    }
                    catch (Exception exception)
                    {
                        art.servers.Shared.println(device.getIdentifier(), exception.getMessage());
                    }
                }
            }
            
        }
        catch (Exception exception)
        {   
            art.servers.Shared.println(art.servers.Shared.getMessage("Model"), exception);
        }


      
        
        try
        {
            Class clazzDevice = Class.forName(deviceClassName);
            Class clazzInformation = Class.forName(deviceInformationClassName);
            
            DeviceInformation[] ldeviceInformation = null;

            if (new File(art.servers.Shared.getApplicationName() + "." + filename + ".json").exists())
            {
                Class<?> clazzArray = (Class<?>)Array.newInstance(clazzInformation, 0).getClass();
                ldeviceInformation = Serialization.deserialize(clazzArray, new File(art.servers.Shared.getApplicationName() + "."  + filename + ".json"));
            }
            

            for (DeviceInformation deviceInformation : ldeviceInformation)
            {
                if (mdevice.containsKey(deviceInformation.getIdentifier()) == false)
                {
                    addDevice(clazzDevice, deviceInformation);
                }
            }        
        }
        catch (Exception exception)
        {
            art.servers.Shared.println(art.servers.Shared.getMessage("Model"), exception);
        }       
        
        
        
        for (Device device : ldevice)
        {
            device.information.serverServiceName = art.servers.Shared.controllerStatus.getApplication().getDeviceInformation().serverServiceName;
        }
        
        
        // Sort 

        Collections.sort(ldevice, new Comparator<Device>() 
        {
            public int compare(Device device1, Device device2) 
            {
               return Integer.valueOf(device1.information.number).compareTo(device2.information.number);
            }
        });        
        
        
        // Database file
        
        if (art.servers.Shared.restoreDevices == false)
        {
            try
            {

                FileOutputStream fos = new FileOutputStream(new File(art.servers.Shared.getApplicationName() + "."  + filename + ".database.json"));

                fos.write("[\n".getBytes());

                for (Device device : ldevice)
                {
                    fos.write(Serialization.toPrettyString(device).getBytes());
                    if (device != ldevice.get(ldevice.size() - 1)) fos.write(",".getBytes());
                }

                fos.write("]\n".getBytes());
                fos.close();
            }
            catch (Exception e)
            {
            }
        }
        
        
        mutexListDevices.releaseWrite();

    }
    
    
    public RTZ32_Controller getDevice(int number)
    {
        for (Device device : Shared.model.getDevices())
        {
            if (device.getDeviceInformation().number == number)
            {
                return (RTZ32_Controller)device;
            }
        }
        
        return null;
    }


    
}