package jmri.jmrix.dccpp;

import jmri.implementation.AbstractTurnout;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * Extends jmri.AbstractTurnout for DCCpp layouts
 * <p>
 * Turnouts on DCC-EX are controlled (as of V1.5 Firmware)
 * with unidirectional Stationary Decoder commands, or with bidirectional
 * (predefined) Turnout commands, or with bidirectional (predefined) Output
 * commands.
 * 
 * DCC-EX Has three ways to activate a turnout (output)
 * <ul>
 * <li> Accessory Command "a" : sends a DCC packet to a stationary decoder
 *      out there on the bus somewhere. NO RETURN VALUE to JMRI.
 * </li>
 * <li> Turnout Command "T" : Looks up a DCC address from an internal table
 *      in the Base Station and sends that Stationary Decoder a packet.  Returns
 *      a (basically faked) "H" response to JMRI indicating the (supposed)
 *      current state of the turnout.  Or "X" if the indexed turnout is not in
 *      the list.
 * </li>
 * <li> Output Command "z" : Looks up a Base Station Arduino Pin number from
 *      an internal lookup table, and sets/toggles the state of that pin.  
 *      Returns a "Y" response indicating the actual state of the pin.  Or "X"
 *      if the indexed pin is not in the list.
 * </li>
 * </ul>
 * 
 * The DCCppTurnout supports three types of feedback:
 * <ul>
 * <li> DIRECT:  No actual feedback, uses Stationary Decoder command and
 *      fakes the response.
 * </li>
 * <li> MONITORING: Uses the Turnout command, lets the Base Station
 *      fake the response :) 
 * </li>
 * <li> EXACT: Uses the Output command to directly address an Arduino pin.
 * </li>
 * </ul>
 *
 * It also supports "NO FEEDBACK" by treating it like "DIRECT".
 * 
 * Turnout operation on DCC-EX based systems goes through the following
 * sequence:
 * <ul>
 * <li> set the commanded state, and, Send request to command station to start
 * sending DCC operations packet to track</li>
 * </ul>
 *
 * @author Bob Jacobsen Copyright (C) 2001
 * @author Paul Bender Copyright (C) 2003-2010
 * @author Mark Underwood Copyright (C) 2015
 *
 * Based on lenz.XNetTurnout by Bob Jacobsen and Paul Bender
 */
public class DCCppTurnout extends AbstractTurnout implements DCCppListener {

    /* State information */
    protected static final int COMMANDSENT = 2;
    protected static final int STATUSREQUESTSENT = 4;
    protected static final int IDLE = 0;
    protected int internalState = IDLE;

    /* Static arrays to hold DCC-EX specific feedback mode information */
    static String[] modeNames = null;
    static int[] modeValues = null;

    //@SuppressFBWarnings(value = "IS2_INCONSISTENT_SYNC")
    //protected int _mThrown = jmri.Turnout.THROWN;
    //@SuppressFBWarnings(value = "IS2_INCONSISTENT_SYNC")
    //protected int _mClosed = jmri.Turnout.CLOSED;

    protected String _prefix = "D"; // default
    protected DCCppTrafficController tc = null;

    public DCCppTurnout(String prefix, int pNumber, DCCppTrafficController controller) {  // a human-readable turnout number must be specified!
        super(prefix + "T" + pNumber);
        tc = controller;
        _prefix = prefix;
        mNumber = pNumber; // this is the address.

        /* Add additional feedback types information */
        // Note DIRECT, ONESENSOR and TWOSENSOR are already OR'ed in.
        _validFeedbackTypes |= MONITORING;   // uses the Turnout command <T...>
        _validFeedbackTypes |= EXACT;        // uses the Output command <Z...>
        _validFeedbackTypes |= CS_VPIN;    // uses the pin control command <z...>
        
        // Default feedback mode is DIRECT
        _activeFeedbackType = DIRECT;
        
        setModeInformation(_validFeedbackNames, _validFeedbackModes);
        
        // set the mode names and values based on the static values.
        _validFeedbackNames = getModeNames();
        _validFeedbackModes = getModeValues();
        
        // Register to get property change information from the superclass
        _stateListener = new DCCppTurnoutStateListener(this);
        this.addPropertyChangeListener(_stateListener);
        // Finally, request the current state from the layout.
        tc.getTurnoutReplyCache().requestCachedStateFromLayout(this);
    }

    //Set the mode information for DCC-EX Turnouts.
    synchronized private static void setModeInformation(String[] feedbackNames, int[] feedbackModes) {
        // if it hasn't been done already, create static arrays to hold
        // the DCC-EX specific feedback information.
        if (modeNames == null) {
            if (feedbackNames.length != feedbackModes.length) {
                log.error("int and string feedback arrays different length");
            }
            // NOTE: What we are doing here is tacking extra modes to the list
            // *beyond* the defaults of DIRECT, ONESENSOR and TWOSENSOR
            modeNames = new String[feedbackNames.length + 3];
            modeValues = new int[feedbackNames.length + 3];
            for (int i = 0; i < feedbackNames.length; i++) {
                modeNames[i] = feedbackNames[i];
                modeValues[i] = feedbackModes[i];
            }
            modeNames[feedbackNames.length] = "BSTURNOUT";
            modeValues[feedbackNames.length] = MONITORING;
            modeNames[feedbackNames.length+1] = "BSOUTPUT";
            modeValues[feedbackNames.length+1] = EXACT;
            modeNames[feedbackNames.length+2] = "CS VPIN";
            modeValues[feedbackNames.length+2] = CS_VPIN;
        }
    }

    static int[] getModeValues() {
        return modeValues;
    }

    static String[] getModeNames() {
        return modeNames;
    }

    public int getNumber() {
        return mNumber;
    }

    /**
     * Set the Commanded State.
     * This method overides {@link jmri.implementation.AbstractTurnout#setCommandedState(int)}.
     */
    @Override
    public void setCommandedState(int s) {
        log.debug("set commanded state for turnout {} to {}", getSystemName(), s);

        synchronized (this) {
            newCommandedState(s);
        }
        myOperator = getTurnoutOperator(); // MUST set myOperator before starting the thread
        if (myOperator == null) {
            forwardCommandChangeToLayout(s);
            // Only set the known state to inconsistent if we actually expect a response
            // from the Base Station
            if (_activeFeedbackType == EXACT || _activeFeedbackType == MONITORING) {
                synchronized (this) {
                    newKnownState(INCONSISTENT);
                }
            } else if (_activeFeedbackType == DIRECT || _activeFeedbackType == CS_VPIN) {
                // CS_VPIN: no guaranteed reply from <z>; update optimistically.
                // An EXRAIL-broadcast <Y> reply may also update KnownState later.
                synchronized (this) {
                    newKnownState(s);
                }
            }
        } else {
            myOperator.start();
        }
    }

    /**
     * {@inheritDoc}
     * Sends a DCC-EX command.
     */
    @Override
    synchronized protected void forwardCommandChangeToLayout(int s) {
        DCCppMessage msg;
        if (s != CLOSED && s != THROWN) {
            log.warn("Turnout {}: state {} not forwarded to layout.", mNumber, s);
            return;
        }
        // newState = TRUE if s == THROWN ...
        // ... unless we are inverted, then newState = TRUE if s == CLOSED
        boolean newState = (s == THROWN);
        if (getInverted()) {
            newState = !newState;
        }
        switch (_activeFeedbackType) {
            case EXACT: // Use <Z ... > command
                // mNumber is the index ID into the Base Station's internal table of outputs.
                // Convert the integer Turnout value to boolean for DCC-EX internal code.
                // Assume if it's not THROWN (true), it must be CLOSED (false).
                // Note for Outputs (EXACT mode), LOW is THROWN, HIGH is CLOSED
                // As defined in DCC-EX Base Station SerialCommand.cpp, so newstate
                // is inverted when making the message
                msg = DCCppMessage.makeOutputCmdMsg(mNumber, !newState);
                internalState = COMMANDSENT;
                break;
            case CS_VPIN: // Use <z vpin> / <z -vpin> pin control command
                // mNumber is the DCC-EX vpin number; no pre-definition required.
                // Polarity matches EXACT: LOW = THROWN, HIGH = CLOSED — invert newState.
                msg = DCCppMessage.makeOutputCmdMsgLC(mNumber, !newState);
                internalState = IDLE; // no guaranteed reply
                break;
            case MONITORING: // Use <T ... > command
                // mNumber is the index ID into the Base Station's internal table of Turnouts.
                // Convert the integer Turnout value to boolean for DCC-EX internal code.
                // Assume if it's not THROWN (true), it must be CLOSED (false).
                msg = DCCppMessage.makeTurnoutCommandMsg(mNumber, newState);
                internalState = COMMANDSENT;
                break;
            default: // DIRECT -- use <a ... > command
                // mNumber is the DCC address of the device.
                // Convert the integer Turnout value to boolean for DCC-EX internal code.
                // Assume if it's not THROWN (true), it must be CLOSED (false).
                msg = DCCppMessage.makeAccessoryDecoderMsg(mNumber, newState);
            internalState = IDLE;
                break;
        }
        log.debug("Sending Message: '{}'", msg);
        tc.sendDCCppMessage(msg, null);  // status returned via manager
    }
    
    @Override
    protected void turnoutPushbuttonLockout(boolean _pushButtonLockout) {
        log.debug("Send command to {} Pushbutton {}T{}", (_pushButtonLockout ? "Lock" : "Unlock"), _prefix, mNumber);
    }
    
    /**
     * request an update on status by sending a DCC-EX message
     */
    @Override
    public void requestUpdateFromLayout() {
        // This will handle query for ONESENSOR and TWOSENSOR feedback modes.
        super.requestUpdateFromLayout();
        // (02/2017) Yes it does... using the <s> command or possibly
        // some others.  TODO: Plumb this in... IFF it is needed.
        /*
        // DCCppMessage msg = DCCppMessage.getFeedbackRequestMsg(mNumber,
        //         ((mNumber - 1) % 4) < 2);
        // synchronized (this) {
        //     internalState = STATUSREQUESTSENT;
        // }
        // tc.sendDCCppMessage(msg, null); //status is returned via the manager.
        */

    }

    @Override
    public boolean canInvert() {
        return true;
    }

    /**
     * initmessage is a package proteceted class which allows the Manger to send
     * a feedback message at initialization without changing the state of the
     * turnout with respect to whether or not a feedback request was sent. This
     * is used only when the turnout is created by on layout feedback.
     *
     * @param l Init message
     */
    synchronized void initmessage(DCCppReply l) {
        int oldState = internalState;
        message(l);
        internalState = oldState;
    }

    /*
     *  Handle an incoming message from the DCC-EX
     */
    @Override
    synchronized public void message(DCCppReply l) {
        //if this is a turnout definition message, copy the defining properties from message to turnout
        if (l.isTurnoutDefDCCReply() || l.isTurnoutDefServoReply() || l.isTurnoutDefVpinReply()  || l.isTurnoutDefLCNReply() ) {
            l.getProperties().forEach((key, value) -> {
                this.setProperty(key, value); //copy the properties
            });
        }
        
        switch (getFeedbackMode()) {
        case EXACT:
            handleExactModeFeedback(l);
            break;
        case MONITORING:
            handleMonitoringModeFeedback(l);
            break;
        case DIRECT:
        default:
            // Default is direct mode - we should never get here, actually.
        }
    }

    // Listen for the outgoing messages (to the command station)
    @Override
    public void message(DCCppMessage l) {
    }

    // Handle a timeout notification
    @Override
    public void notifyTimeout(DCCppMessage msg) {
        log.debug("Notified of timeout on message '{}'", msg);
    }

    /*
     *  With Monitoring Mode feedback, if we see a feedback message, we 
     *  interpret that message and use it to display our feedback. 
     *  <p>
     *  After we send a request to operate a turnout, We ask the command 
     *  station to stop sending information to the stationary decoder
     *  when the either a feedback message or an "OK" message is received.
     *
     *  @param l a {@link DCCppReply} message
     */
    synchronized private void handleMonitoringModeFeedback(DCCppReply l) {
        log.debug("Handle Message for turnout {} in MONITORING feedback mode", mNumber);
        if (l.isTurnoutReply() && (l.getTOIDInt() == mNumber)) {
           if (l.getTOIsThrown()) {
               log.debug("Turnout is Thrown. Inverted = {}", (getInverted() ? "True" : "False"));
               synchronized (this) {
                   newCommandedState(getInverted() ? CLOSED : THROWN);
                   newKnownState(getCommandedState());
               }
           } else if (l.getTOIsClosed()) {
               log.debug("Turnout is Closed. Inverted = {}", (getInverted() ? "True" : "False"));
               synchronized (this) {
                   newCommandedState(getInverted() ? THROWN : CLOSED);
                   newKnownState(getCommandedState());
               }
           }
           internalState = IDLE;
        }
        return;
    }
    
    synchronized private void handleExactModeFeedback(DCCppReply l) {
        /* 
           Note for Outputs (EXACT mode), LOW is THROWN, HIGH is CLOSED
           As defined in DCC-EX Base Station SerialCommand.cpp
        */
        log.debug("Handle Message for turnout {} in EXACT feedback mode", mNumber);
        if (l.isOutputCmdReply() && (l.getOutputNumInt() == mNumber)) {
           if (l.getOutputIsLow()) {
               log.debug("Turnout is Thrown. Inverted = {}", (getInverted() ? "True" : "False"));
               synchronized (this) {
                   newCommandedState(getInverted() ? CLOSED : THROWN);
                   newKnownState(getCommandedState());
               }
           } else if (l.getOutputIsHigh()) {
               log.debug("Turnout is Closed. Inverted = {}", (getInverted() ? "True" : "False"));
               synchronized (this) {
                   newCommandedState(getInverted() ? THROWN : CLOSED);
                   newKnownState(getCommandedState());
               }
           }
           internalState = IDLE;
        }
        return;
    }
 
    @Override
    public void dispose() {
        this.removePropertyChangeListener(_stateListener);
        super.dispose();
    }
    
    // Internal class to use for listening to state changes
    private static class DCCppTurnoutStateListener implements java.beans.PropertyChangeListener {
        
        DCCppTurnout _turnout = null;
        
        DCCppTurnoutStateListener(DCCppTurnout turnout) {
            _turnout = turnout;
        }
        
        /*
         * If we're  not using DIRECT feedback mode, we need to listen for 
         * state changes to know when to send an OFF message after we set the 
         * known state
         * If we're using DIRECT mode, all of this is handled from the 
         * outgoing Messages
         */
        @Override
        public void propertyChange(java.beans.PropertyChangeEvent event) {
            log.debug("propertyChange called");
            // If we're using DIRECT feedback mode, we don't care what we see here
            if (_turnout.getFeedbackMode() != DIRECT) {
                if (log.isDebugEnabled()) {
                    log.debug("propertyChange Not Direct Mode property: {} old value {} new value {}", event.getPropertyName(), event.getOldValue(), event.getNewValue());
                }
                if (event.getPropertyName().equals("KnownState")) {
                    // Check to see if this is a change in the status 
                    // triggered by a device on the layout, or a change in 
                    // status we triggered.
                    int oldKnownState = ((Integer) event.getOldValue()).intValue();
                    int curKnownState = ((Integer) event.getNewValue()).intValue();
                    log.debug("propertyChange KnownState - old value {} new value {}", oldKnownState, curKnownState);
                    if (curKnownState != INCONSISTENT
                        && _turnout.getCommandedState() == oldKnownState) {
                        // This was triggered by feedback on the layout, change 
                        // the commanded state to reflect the new Known State
                        if (log.isDebugEnabled()) {
                            log.debug("propertyChange CommandedState: {}", _turnout.getCommandedState());
                        }
                        _turnout.newCommandedState(curKnownState);
                    } else {
                        // Since we always set the KnownState to 
                        // INCONSISTENT when we send a command, If the old 
                        // known state is INCONSISTENT, we just want to send 
                        // an off message
                        if (oldKnownState == INCONSISTENT) {
                            if (log.isDebugEnabled()) {
                                log.debug("propertyChange CommandedState: {}", _turnout.getCommandedState());
                            }
                        }
                    }
                }
            }
        }
        
    }
    
    // data members
    protected int mNumber;   // turnout number
    DCCppTurnoutStateListener _stateListener;  // Internal class object
    
    private static final Logger log = LoggerFactory.getLogger(DCCppTurnout.class);
    
}