package art.servers.sosserver.controller.musatel;

import art.library.interop.InteropParameters;
import art.library.interop.serialization.Serialization;
import art.library.interop.serialization.SerializationException;
import art.library.model.devices.DeviceAction;
import art.library.model.devices.DeviceActionResult;
import art.library.model.devices.DeviceCommands;
import art.library.model.devices.DeviceStatus;
import art.library.model.devices.sos.Sos;
import art.library.model.devices.sos.SosCommands;
import art.library.model.devices.sos.SosStatus;
import art.library.model.devices.sos.musatel.alarms.SosAlarmsMusatel;
import art.library.model.devices.sos.musatel.commands.SosCommandsMusatel;
import art.library.model.devices.sos.musatel.status.SosStatusMusatel;
import art.library.model.devices.sos.musatel.status.SosStatusMusatelConnection;
import art.library.utils.synchro.Mutex;
import art.servers.ServerException;
import art.servers.Shared;
import art.servers.sosserver.controller.ControllerSos;
import java.util.ArrayList;
import java.util.List;
import java.util.Random;


public class ControllerSos_Musatel extends ControllerSos
{
    private String name = null;
    private boolean initialised = false;
    private Mutex mutex = new Mutex();
    protected ControllerSos_MusatelSender sender = null;
    protected ControllerSos_MusatelReceiver receiver = null;
    private int priority = -1;


    public ControllerSos_Musatel(Sos sos)
    {
        super(sos);
        this.device = sos;
        this.name = Shared.getMessage("Controller sos") + " " + sos.toString();
        this.setName(name);
        this.sender = new ControllerSos_MusatelSender(this);
        this.receiver = new ControllerSos_MusatelReceiver(this);

        if (device.getDeviceStatus() == null)
        {
            SosStatus status = new SosStatus();
            status.musatel = new SosStatusMusatel();
            device.status = status;
        }

        if (device.getDeviceAlarms().musatel == null)
        {
            device.getDeviceAlarms().musatel = new SosAlarmsMusatel();
        }
    }
    
    
    
    
    
    

    public void run()
    {
        Shared.traceInformation(name, Shared.getMessage("Starting"));

        // Random, to avoid all execute at same time

        try
        {
            Random random = new Random();
            int timetowait = random.nextInt(10);
            if (timetowait > 0) sleep(timetowait * 1000);
        }
        catch (Exception e)
        {
        }
        
        
        // Start
        
        while (isInterrupted() == false)
        {
            long timestamp = System.currentTimeMillis();
            {
                if (art.servers.Shared.isServerEnabled() == true)
                {
                    update();
                }
            }

            long period = device.getDeviceInformation().polling * 1000;
            long timetowait = period - (System.currentTimeMillis() - timestamp);
            timetowait = Math.min(timetowait, period);

            try
            {
                if (timetowait > 0)
                {
                    sleep(timetowait);
                }
            }
            catch (Exception e)
            {
            }
        }

        Shared.traceInformation(name, Shared.getMessage("Finishing"));
    }
    
    



    private void offline(Sos clone)throws Exception
    {
        clone.getDeviceStatus().status = DeviceStatus.STATUS_OFFLINE;
        long tsOffline = clone.getAlarm("alarm_offline");
        if (tsOffline <= 0) tsOffline = System.currentTimeMillis();
        clone.alarms.clear();
        clone.setAlarm("alarm_offline", tsOffline);
        Shared.model.updateDevice(device, clone);
    }


    public void online(Sos clone) throws Exception
    {
        clone.getDeviceStatus().status = DeviceStatus.STATUS_ONLINE;
        clone.setAlarm("alarm_offline", false);
        clone.setAlarm("alarm_invalid", false);
        Shared.model.updateDevice(device, clone);
    }


    
    private void update()
    {
        try
        {
            Sos sos = getDevice();
            
            if (sos.getDeviceStatus().musatel == null)
            {
                sos.getDeviceStatus().musatel = new SosStatusMusatel();
            }
            
            
            // Keep connection alive
            
            if (sos.getDeviceStatus().musatel.state == SosStatusMusatel.STATE_ACTIVE_CALL)
            {
                SosStatusMusatelConnection connection = sos.getDeviceStatus().musatel.currentConnection;
                
                if (connection != null)
                {
                    sender.ORD_FON_ON(connection.address, connection.audioPort);
                }                
            }
            else
            {
                // Update state, alarms
                
                Sos clone = (Sos)Serialization.clone(getDevice());
                
                try
                {
                    sender.ORD_TST_MAN();
                    online(clone);
                }
                catch (Exception e)
                {
                    offline(clone);
                }
            }
            
            
        }
        catch (Exception e)
        {
        }
    }

    
    
    
    
    // <editor-fold defaultstate="collapsed" desc="Commands">

    public DeviceAction[] sendCommands(InteropParameters parameters) throws ServerException, SerializationException, Exception
    {
        try
        {
            List<DeviceAction> result = new ArrayList<DeviceAction>();

            SosCommands sosCommands = parameters.getBodyContentValue(SosCommands.class);

            if (sosCommands.musatel.speakerVolume >= 0)
            {
                SosCommands command = new SosCommands();
                command.musatel = new SosCommandsMusatel();
                command.musatel.speakerVolume = sosCommands.musatel.speakerVolume;
                result.add(setSpeakerVolume(parameters, command));
            }

            if (sosCommands.musatel.call != null)
            {
                SosCommands command = new SosCommands();
                command.musatel = new SosCommandsMusatel();
                command.musatel.call = sosCommands.musatel.call;
                result.add(openAudio(parameters, command));
            }

            if (sosCommands.musatel.endCall == DeviceCommands.CONDITION_YES)
            {
                SosCommands command = new SosCommands();
                command.musatel = new SosCommandsMusatel();
                command.musatel.endCall = sosCommands.musatel.endCall;
                result.add(closeAudio(parameters, command));
            }

            if (sosCommands.musatel.pauseCall == DeviceCommands.CONDITION_YES)
            {
                SosCommands command = new SosCommands();
                command.musatel = new SosCommandsMusatel();
                command.musatel.pauseCall = sosCommands.musatel.pauseCall;
                result.add(pauseAudio(parameters, command));
            }

            if (sosCommands.musatel.resumeCall == DeviceCommands.CONDITION_YES)
            {
                SosCommands command = new SosCommands();
                command.musatel = new SosCommandsMusatel();
                command.musatel.resumeCall = sosCommands.musatel.resumeCall;
                result.add(resumeAudio(parameters, command));
            }

            if (sosCommands.musatel.maintenanceTest == DeviceCommands.CONDITION_YES)
            {
                SosCommands command = new SosCommands();
                command.musatel = new SosCommandsMusatel();
                command.musatel.maintenanceTest = sosCommands.musatel.maintenanceTest;
                result.add(doMaintenanceTest(parameters, command));
            }

            if (sosCommands.musatel.audioTest != null)
            {
                SosCommands command = new SosCommands();
                command.musatel = new SosCommandsMusatel();
                command.musatel.audioTest = sosCommands.musatel.audioTest;
                if (command.musatel.audioTest.type == SosCommandsMusatel.TEST_AUDIO)
                {
                    result.add(startAudioTest(parameters, command));
                }
                else if (command.musatel.audioTest.type == SosCommandsMusatel.TEST_AUDIO_STOP)
                {
                    result.add(endAudioTest(parameters, command));
                }
            }

            if (sosCommands.musatel.messagesTest != null)
            {
                SosCommands command = new SosCommands();
                command.musatel = new SosCommandsMusatel();
                command.musatel.messagesTest = sosCommands.musatel.messagesTest;
                if ((command.musatel.messagesTest.type == SosCommandsMusatel.MESSAGE_OUT_OF_SERVICE) || (command.musatel.messagesTest.type == SosCommandsMusatel.MESSAGE_CALL_WAITING))
                {
                    result.add(startMessagesTest(parameters, command));
                }
                else if (command.musatel.messagesTest.type == SosCommandsMusatel.MESSAGE_STOP)
                {
                    result.add(endMessagesTest(parameters, command));
                }
            }

            if (sosCommands.musatel.toneTest != null)
            {
                SosCommands command = new SosCommands();
                command.musatel = new SosCommandsMusatel();
                command.musatel.toneTest = sosCommands.musatel.toneTest;
                if ((command.musatel.toneTest.type == SosCommandsMusatel.TONE_CALL) ||
                    (command.musatel.toneTest.type == SosCommandsMusatel.TONE_BUSY))
                {
                    result.add(startToneTest(parameters, command));
                }
                else if (command.musatel.toneTest.type == SosCommandsMusatel.TONE_STOP)
                {
                    result.add(endToneTest(parameters, command));
                }
            }

            if (sosCommands.musatel.reset == DeviceCommands.CONDITION_YES)
            {
                SosCommands command = new SosCommands();
                command.musatel = new SosCommandsMusatel();
                command.musatel.reset = sosCommands.musatel.reset;
                result.add(reset(parameters, command));
            }

            return result.toArray(new DeviceAction[result.size()]);
        }
        catch (Exception exception)
        {
            throw exception;
        }
    }


    private DeviceAction startAudioTest(InteropParameters parameters, SosCommands command)
    {
        String language = (String)parameters.getParameterValue("language");
        DeviceAction action = new DeviceAction(device, parameters, command);
        action.actionName = Shared.getMessage(language, "Start audio test");

        try
        {
            sender.ORD_TST_FON(command.musatel.audioTest.audioDestinationIp, command.musatel.audioTest.audioDestinationPort);

            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_CORRECT);
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
        catch (Exception exception)
        {
            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, exception.getMessage());
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
    }


    private DeviceAction endAudioTest(InteropParameters parameters, SosCommands command)
    {
        String language = (String)parameters.getParameterValue("language");
        DeviceAction action = new DeviceAction(device, parameters, command);
        action.actionName = Shared.getMessage(language, "Stop audio test");

        try
        {
            sender.ORD_FON_OFF();

            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_CORRECT);
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
        catch (Exception exception)
        {
            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, exception.getMessage());
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
    }


    private DeviceAction openAudio(InteropParameters parameters, SosCommands command)
    {
        // TODO: Y el volumen y el micro?, si speakerVolume > 0 enviarlo, ya se envía en sendCommands.
        //      Volumen de micro no se puede ajustar en los musatel
        // TODO: La prioridad no se usa

        String language = (String)parameters.getParameterValue("language");
        String username = (String)parameters.getParameterValue("username");
        String computer = (String)parameters.getParameterValue("computer");
        DeviceAction action = new DeviceAction(device, parameters, command);
        action.actionName = Shared.getMessage(language, "Start call");
        int commandPriority = command.musatel.call.priority;

        try
        {
            int currentPriority = -1;
            if (this.device.getDeviceStatus().musatel.currentConnection != null)
            {
                currentPriority = this.device.getDeviceStatus().musatel.currentConnection.priority;
            }

            if ((commandPriority >= 0) && (commandPriority < currentPriority))
            {
                DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, Shared.getMessage("Insufficient priority"));
                action.setResult(actionResult);
                Shared.model.addAction(action);
                return action;
            }

            if (this.device.getDeviceStatus().musatel.currentConnection != null)
            {
                // Cerrar conexión anterior
                sender.ORD_FON_OFF();
            }

            sender.ORD_FON_ON(username, computer, command.musatel.call.audioDestinationIp, command.musatel.call.audioDestinationPort, commandPriority);

            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_CORRECT);
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
        catch (Exception exception)
        {
            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, exception.getMessage());
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
    }


    private DeviceAction closeAudio(InteropParameters parameters, SosCommands command)
    {
        String language = (String)parameters.getParameterValue("language");
        DeviceAction action = new DeviceAction(device, parameters, command);
        action.actionName = Shared.getMessage(language, "End call");

        try
        {
            // TODO Mirar la prioridad del close, si no es superior a la de la llamada actual, no se puede cerrar la llamada???????????
            sender.ORD_FON_OFF();

            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_CORRECT);
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
        catch (Exception exception)
        {
            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, exception.getMessage());
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
    }


    private DeviceAction pauseAudio(InteropParameters parameters, SosCommands command)
    {
        String language = (String)parameters.getParameterValue("language");
        DeviceAction action = new DeviceAction(device, parameters, command);
        action.actionName = Shared.getMessage(language, "Pause call");

        try
        {
            sender.ORD_FON_OFF();

            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_CORRECT);
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
        catch (Exception exception)
        {
            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, exception.getMessage());
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
    }


    private DeviceAction resumeAudio(InteropParameters parameters, SosCommands command)
    {
        String language = (String)parameters.getParameterValue("language");
        String username = (String)parameters.getParameterValue("username");
        String computer = (String)parameters.getParameterValue("computer");
        DeviceAction action = new DeviceAction(device, parameters, command);
        action.actionName = Shared.getMessage(language, "Resume call");

        try
        {
            sender.ORD_FON_ON(username, computer, command.musatel.call.audioDestinationIp, command.musatel.call.audioDestinationPort, this.priority);

            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_CORRECT);
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
        catch (Exception exception)
        {
            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, exception.getMessage());
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
    }


    private DeviceAction doMaintenanceTest(InteropParameters parameters, SosCommands command)
    {
        String language = (String)parameters.getParameterValue("language");
        DeviceAction action = new DeviceAction(device, parameters, command);
        action.actionName = Shared.getMessage(language, "Maintenance test");

        try
        {
            sender.ORD_TST_MAN();

            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_CORRECT);
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
        catch (Exception exception)
        {
            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, exception.getMessage());
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
    }


    private DeviceAction startMessagesTest(InteropParameters parameters, SosCommands command)
    {
        String language = (String)parameters.getParameterValue("language");
        String username = (String)parameters.getParameterValue("username");
        String computer = (String)parameters.getParameterValue("computer");
        DeviceAction action = new DeviceAction(device, parameters, command);
        if (command.musatel.messagesTest.type == SosCommandsMusatel.MESSAGE_OUT_OF_SERVICE) action.actionName = Shared.getMessage(language, "Out of service message test");
        if (command.musatel.messagesTest.type == SosCommandsMusatel.MESSAGE_CALL_WAITING) action.actionName = Shared.getMessage(language, "Received call message test");

        try
        {
            sender.ORD_VOZ_ON(username, computer, command.musatel.messagesTest.audioDestinationIp, command.musatel.messagesTest.audioDestinationPort, command.musatel.messagesTest.type);

            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_CORRECT);
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
        catch (Exception exception)
        {
            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, exception.getMessage());
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
    }


    private DeviceAction endMessagesTest(InteropParameters parameters, SosCommands command)
    {
        String language = (String)parameters.getParameterValue("language");
        DeviceAction action = new DeviceAction(device, parameters, command);
        action.actionName = Shared.getMessage(language, "Stop message test");

        try
        {
            sender.ORD_VOZ_OFF();

            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_CORRECT);
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
        catch (Exception exception)
        {
            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, exception.getMessage());
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
    }


    private DeviceAction startToneTest(InteropParameters parameters, SosCommands command)
    {
        String language = (String)parameters.getParameterValue("language");
        DeviceAction action = new DeviceAction(device, parameters, command);
        if (command.musatel.toneTest.type == SosCommandsMusatel.TONE_CALL) action.actionName = Shared.getMessage(language, "Call tone test");
        if (command.musatel.toneTest.type == SosCommandsMusatel.TONE_BUSY) action.actionName = Shared.getMessage(language, "Busy tone test");

        try
        {
            sender.ORD_TON_ON(command.musatel.toneTest.audioDestinationIp, command.musatel.toneTest.audioDestinationPort, command.musatel.toneTest.type);

            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_CORRECT);
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
        catch (Exception exception)
        {
            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, exception.getMessage());
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
    }


    private DeviceAction endToneTest(InteropParameters parameters, SosCommands command)
    {
        String language = (String)parameters.getParameterValue("language");
        DeviceAction action = new DeviceAction(device, parameters, command);
        action.actionName = Shared.getMessage(language, "Stop tone test");

        try
        {
            sender.ORD_TON_OFF();

            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_CORRECT);
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
        catch (Exception exception)
        {
            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, exception.getMessage());
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
    }


    private DeviceAction setSpeakerVolume(InteropParameters parameters, SosCommands command)
    {
        String language = (String)parameters.getParameterValue("language");
        DeviceAction action = new DeviceAction(device, parameters, command);
        action.actionName = Shared.getMessage(language, "Change speaker volume");

        try
        {
            sender.ORD_ADJ_VOL(command.musatel.speakerVolume);

            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_CORRECT);
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
        catch (Exception exception)
        {
            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, exception.getMessage());
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
    }


    private DeviceAction reset(InteropParameters parameters, SosCommands command)
    {
        String language = (String)parameters.getParameterValue("language");
        DeviceAction action = new DeviceAction(device, parameters, command);
        action.actionName = Shared.getMessage(language, "Reset");

        try
        {
            sender.ORD_FON_OFF();

            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_CORRECT);
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
        catch (Exception exception)
        {
            DeviceActionResult actionResult = new DeviceActionResult(DeviceActionResult.RESULT_ERROR, exception.getMessage());
            action.setResult(actionResult);
            Shared.model.addAction(action);
            return action;
        }
    }

    // </editor-fold>  



    public void setSosPriority (int priority)
    {
        this.priority = priority;
    }

}