# This script manages an internal sensor as a debounced
# version of another sensor. Both the on and off delays
# may be specified.
#
# Author: Ken Cameron, copyright 2008,2016
# Part of the JMRI distribution
#
# A ActionListener is used to get timeout events.
#
# A PropertyChangeListener is used to get the sensor changes.
#

import jmri

import java
import java.awt
import java.awt.event
import java.beans
import javax.swing

# declare things
class DebounceSensor(java.beans.PropertyChangeListener) :
    # initialize variables
    watchedSensor = None
    watchedSensorName = None
    resultSensor = None
    resultSensorName = None
    delayTimer = None
    offTimeout = 0
    onTimeout = 0
    priorInput = None
    currentState = None
    isChangingOn = False
    isChangingOff = False
    timeoutListener = None
    hasDisplay = False
    debugLevel = 0
    filterOn = False

    def init(self, inSensor, outSensor, onDelay, offDelay):
        self.watchedSensorName = inSensor
        self.resultSensorName = outSensor
        self.watchedSensor = sensors.provideSensor(inSensor)
        if (self.watchedSensor == None) :
           print("Couldn't assign inSensor: " + inSensor + " - Run stopped\n")
           return
        self.resultSensor = sensors.provideSensor(outSensor)
        if (self.resultSensor == None) :
           print("Couldn't assign outSensor: " + outSensor + " - Run stopped\n")
           return
        self.onTimeout = int(onDelay * 1000.0)
        self.offTimeout = int(offDelay * 1000.0)
        self.timeoutListener = self.TimeoutReceiver()
        self.timeoutListener.setCallBack(self.timeoutHandler)
        self.delayTimer = javax.swing.Timer(10000, self.timeoutListener)
        self.delayTimer.stop()
        self.delayTimer.setRepeats(False);
        self.currentState = self.watchedSensor.getKnownState()
        self.priorInput = self.currentState
        self.resultSensor.setKnownState(self.currentState)
        self.watchedSensor.addPropertyChangeListener(self)
        #print("debounce init " + self.resultSensorName + " watching " + self.watchedSensorName)
        return
        
    def propertyChange(self, event) :
        # I don't bother with the event, I just check everything again
        self.delayTimer.stop()
        newState = self.watchedSensor.getKnownState()
        if (self.debugLevel > 1) :
            print("DebounceProp " + self.resultSensorName + ":" + self.stateName(self.watchedSensor.getKnownState()) + " event name: " + event.propertyName + " old: " + str(event.oldValue) + " to " + str(event.newValue))
        if (self.filterOn and newState == INCONSISTENT) :
            if (self.debugLevel > 1) :
                print("DebounceProp " + self.resultSensorName + ": skipping INCONSISTENT")
        elif (self.filterOn and newState == UNKNOWN) :
            if (self.debugLevel > 1) :
                print("DebounceProp " + self.resultSensorName + ": skipping UNKNOWN")
        elif (self.isChangingOn == False and self.isChangingOff == False) :
            # nothing changing, normal change starting
            if (newState == ACTIVE) :
                self.isChangingOn = True
                self.changeOffToOn()
            else :
                self.isChangingOff = True
                self.changeOnToOff()
        elif (self.isChangingOn == True and self.isChangingOff == False) :
            # we were changing to on, but got another change
            if (newState == INACTIVE) :
                # must have been a spike before the on timeout
                self.isChangingOn = False
        elif (self.isChangingOn == False and self.isChangingOff == True) :
            # we were changing to off, but got another change
            if (newState == ACTIVE) :
                # must have been a spike before off timeout
                self.isChangingOff = False
        else :
            # shouldn't get here, so reset everything
            self.resetSensors(newState)
        return

    def changeOnToOff(self) :
        # the source went from on to off
        if (self.debugLevel > 1) :
            print("Debounce " + self.resultSensorName + " changeOnToOff")
        if (self.offTimeout != 0) :
            self.delayTimer.setInitialDelay(self.offTimeout)
            self.delayTimer.start()
        else :
            self.timeoutOnToOff()
        return

    def changeOffToOn(self) :
        if (self.debugLevel > 1) :
            print("Debounce " + self.resultSensorName + " changeOffToOn")
        # the source went from off to on
        if (self.onTimeout != 0) :
            self.delayTimer.setInitialDelay(self.onTimeout)
            self.delayTimer.start()
        else :
            self.timeoutOffToOn()
        return

    def resetSensors(self, newState) :
        if (self.debugLevel > 0) :
            print("debounce resetSensors: " + self.resultSensorName + ", shouldn't happen!")
        self.isChangingOn = False
        self.isChangingOff = False
        self.currentState = newState
        self.resultSensor.setKnownState(newState)
        return
        
    class TimeoutReceiver(java.awt.event.ActionListener):
        cb = None

        def actionPerformed(self, event) :
            if (self.cb != None) :
                self.cb(event)
            return
        
        def setCallBack(self, cbf) :
            self.cb = cbf
            return

    def timeoutHandler(self, event) :
        # see which phase we think we are in
        self.delayTimer.stop()
        newState = self.watchedSensor.getKnownState()
        if (self.debugLevel > 1) :
            print("DebounceTimeout " + self.resultSensorName + ":" + self.stateName(newState) + " event: " + str(event) 
            + ":" + str(self.isChangingOn) + ":" + str(self.isChangingOff)
            +":\n")
        if (self.isChangingOn == False and self.isChangingOff == False) :
            # nothing changing, this shouldn't happen
            if (self.debugLevel > 1) :
                print("both changing false")
            self.resetSensors(newState)
        elif (self.isChangingOn == True and self.isChangingOff == False and newState == ACTIVE) :
            # we were changing to on, got time out
            if (self.debugLevel > 1) :
                print("is active timeout")
            self.resultSensor.setKnownState(ACTIVE)
            self.isChangingOn = False
        elif (self.isChangingOn == False and self.isChangingOff == True and newState == INACTIVE) :
            # we were changing to off, got timeout
            if (self.debugLevel > 1) :
                print("is inactive timeout")
            self.resultSensor.setKnownState(INACTIVE)
            self.isChangingOff = False
        else :
            # shouldn't get here, so reset everything
            self.resetSensors(newState)
        return

    def timeoutOnToOff(self) :
        self.resultSensor.setKnownState(INACTIVE)
        self.currentState = INACTIVE
        self.isChangingOff = False
        return

    def timeoutOffToOn(self) :
        self.resultSensor.setKnownState(ACTIVE)
        self.currentState = ACTIVE
        self.isChangingOn = False
        return

    def setDebugLevel(self, value) :
        if (value >= 0 and value <= 2) :
            self.debugValue = value
        return

    def getDebugLevel(self) :
        return self.debugLevel
    
    # turn on filter of UNKNOWN/INCONSISTENT
    def setFilterOn(self) :
        self.filterOn = True
        return

    # turn off filter of UNKNOWN/INCONSISTENT
    def setFilterOn(self) :
        self.filterOn = False
        return

    # show filter status
    def getFilter(self) :
        state = "Filter Off"
        if (self.filterOn) :
            state = "Filter On"
        return state

    # Define routine to map status numbers to text
    def stateName(self, state) :
        if (state == ACTIVE) :
            return "ACTIVE"
        if (state == INACTIVE) :
            return "INACTIVE"
        if (state == INCONSISTENT) :
            return "INCONSISTENT"
        if (state == UNKNOWN) :
            return "UNKNOWN"
        return "(invalid)"
        
    # invoke this script from the system directory
# then create a file (with your panels) that has
# lines like these (without the ## comments)
# Params:
#    real sensor being watched for changes
#    sensor showing the debounced state of real sensor
#    on delay, off-on-off cycles less than this will stay off
#    off delay, on-off-on cycles less than this will stay on
#
# Sensor names are system names
# time values are floating point seconds

##a = DebounceSensor() # create one of these 
##a.init('NS775', 'ISNS775', 0.5, 3) # invoke this for the sensor pair