updateBlynk.py

# provides routine to update SGS Blynk Display
import time
import requests
import json
import util
import state
import traceback
# Check for user imports
try:
                import conflocal as config
except ImportError:
                import config


DEBUGBLYNK = config.DEBUGBLYNK
def stopFlash():
        r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V30?value=0')

def blynkInit():
    # initalize button states
    try:
        print ("Entering blynkInit debug mode: " + str(DEBUGBLYNK))
 
        r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V5?value=0', timeout=10)
        if (state.runOLED == True):
            r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V6?value=1', timeout=10)
        else:        
            r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V6?value=0', timeout=10)
        r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V30?value=0', timeout=10)
        # initialize LEDs
        r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V42?value=255', timeout=10)
        r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V43?value=255', timeout=10)

        # read english Metric in from file

        try:
            f = open("/home/pi/SDL_Pi_SkyWeather/state/EnglishMetric.txt", "r")
            value = int(f.read())
            f.close()
        except Exception as e:
            value = 0
            #print "initial state - no EnglishMetric.txt value=", value
            f1 = open("/home/pi/SDL_Pi_SkyWeather/state/EnglishMetric.txt", "w")
            f1.write("0")
            f1.close()
            
        state.EnglishMetric = value
        if (DEBUGBLYNK):
            print ("state.EnglishMetric = ", value)
        if (state.EnglishMetric == 0):
            r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V8?value=0')
        else:        
            r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V8?value=1')

        if (DEBUGBLYNK):
            print ("Exiting blynkInit:")

    except Exception as e:
        print ("exception in blynkInit")
        print (e)
        return 0

def blynkResetButton(buttonNumber):
    try:
        r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/'+buttonNumber+'?value=0')
    except Exception as e:
        print ("exception in blynkResetButton")
        print (e)
        return 0

def blynkEventUpdate(Event):
    try:
        put_header={"Content-Type": "application/json"}
        val = Event 
        put_body = json.dumps([val])
        if (DEBUGBLYNK):
          print ("blynkEventUpdate:",val)
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V31', data=put_body, headers=put_header, timeout=10)
        if (DEBUGBLYNK):
            print ("blynkEventUpdate:POST:r.status_code:",r.status_code)
        return 1
    except Exception as e:
        print ("exception in blynkEventUpdate")
        print (e)
        return 0

def blynkStatusTerminalUpdate(entry):
    try:
        put_header={"Content-Type": "application/json"}

        entry = time.strftime("%Y-%m-%d %H:%M:%S")+": "+entry+"\n"
        put_body = json.dumps([entry])
        if (DEBUGBLYNK):
            print ("blynkStateUpdate:Pre:put_body:",put_body)
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V32', data=put_body, headers=put_header, timeout=10)
        if (DEBUGBLYNK):
            print ("blynkStateUpdate:POST:r.status_code:",r.status_code)
    except Exception as e:
        print ("exception in blynkTerminalUpdate")
        print (e)
        return 0


def blynkSolarMAXLine(entry, protocol):
    try:
        put_header={"Content-Type": "application/json"}

        put_body = json.dumps([entry])
        if (DEBUGBLYNK):
            print ("blynkSolarMAXUpdate:Pre:put_body:",put_body)
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V75', data=put_body, headers=put_header, timeout=10)
        if (DEBUGBLYNK):
            print ("blynkSolarMAXUpdate:POST:r.status_code:",r.status_code)
    except Exception as e:
        print ("exception in blynkSolarMAXUpdate")
        print (e)
        return 0
    
def blynkSolarTerminalUpdate(entry):
    try:
        put_header={"Content-Type": "application/json"}
        entry = time.strftime("%Y-%m-%d %H:%M:%S")+": "+entry+"\n"

        put_body = json.dumps([entry])
        if (DEBUGBLYNK):
            print ("blynkStateUpdate:Pre:put_body:",put_body)
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V33', data=put_body, headers=put_header, timeout=10)
        if (DEBUGBLYNK):
            print ("blynkStateUpdate:POST:r.status_code:",r.status_code)
    except Exception as e:
        print ("exception in blynkTerminalUpdate")
        print (e)
        return 0
    

def blynkUpdateImage():
    #Blynk.setProperty(V1, "urls", "https://image1.jpg", "https://image2.jpg");

    try:
        if (DEBUGBLYNK):
             print ("blynkUpdateImage:started")
        """
        r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V70?value=2') # Picture URL
        if (DEBUGBLYNK):
             print "blynkUpdateImage:OTHER:r.status_code:",r.status_code
        #r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V70?urls=http://www.switchdoc.com/2.jpg') # Picture URL
        #r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V70?urls=http://www.switchdoc.com/skycamera.jpg,http://www.switchdoc.com/2.jpg') # Picture URL
        r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V70?value=1;url=http://www.switchdoc.com/skycamera.jpg')
        if (DEBUGBLYNK):
             print "blynkUpdateImage:OTHER:r.status_code:",r.status_code
        r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V70?value=2;url=http://www.switchdoc.com/2.jpg') # Picture URL
        if (DEBUGBLYNK):
             print "blynkUpdateImage:OTHER:r.status_code:",r.status_code
                        
        r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V70?value=2') # Picture URL
        if (DEBUGBLYNK):
             print "blynkUpdateImage:OTHER:r.status_code:",r.status_code
        """
        r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V70?urls=http://www.switchdoc.com/SkyWeatherNoAlpha.png', timeout=10) # Picture URL

    except Exception as e:
        print ("exception in blynkUpdateImage")
        print (e)
        return 0


def blynkStateUpdate():


    try:

        
        blynkUpdateImage()
        
        put_header={"Content-Type": "application/json"}

        # set last sample time 
        
        put_header={"Content-Type": "application/json"}
        val = time.strftime("%Y-%m-%d %H:%M:%S")  
        put_body = json.dumps([val])
        if (DEBUGBLYNK):
          print ("blynkEventUpdate:",val)
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V44', data=put_body, headers=put_header, timeout=20)
        if (DEBUGBLYNK):
            print ("blynkEventUpdate:POST:r.status_code:",r.status_code)

        # do the graphs


        val = state.Outdoor_AirQuality_Sensor_Value 
        put_body = json.dumps([val])
        if (DEBUGBLYNK):
            print ("blynkStateUpdate:Pre:put_body:",put_body)
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V7', data=put_body, headers=put_header, timeout=10)
        if (DEBUGBLYNK):
            print ("blynkStateUpdate:POST:r.status_code:",r.status_code)
    

        val = util.returnTemperatureCF(state.currentOutsideTemperature)
        tval = "{0:0.1f} ".format(val) + util.returnTemperatureCFUnit()
        put_body = json.dumps([tval])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V0', data=put_body, headers=put_header, timeout=10)

        val = util.returnTemperatureCF(state.currentOutsideTemperature)
        put_body = json.dumps([val])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V10', data=put_body, headers=put_header, timeout=10)

        val = state.currentOutsideHumidity 
        put_body = json.dumps(["{0:0.1f}%".format(val)])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V1', data=put_body, headers=put_header, timeout=10)

        val = state.currentOutsideHumidity 
        put_body = json.dumps([val])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V11', data=put_body, headers=put_header, timeout=10)

        val = util.returnTemperatureCF(state.currentInsideTemperature)
        tval = "{0:0.1f} ".format(val) + util.returnTemperatureCFUnit()
        put_body = json.dumps([tval])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V21', data=put_body, headers=put_header, timeout=10)

        val = util.returnTemperatureCF(state.currentInsideTemperature)
        tval = "{0:0.1f}".format(val) 
        put_body = json.dumps([val])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V120', data=put_body, headers=put_header, timeout=10)

        val = state.currentInsideHumidity 
        put_body = json.dumps(["{0:0.1f}%".format(val)])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V13', data=put_body, headers=put_header, timeout=10)

        val = state.currentInsideHumidity 
        put_body = json.dumps(["{0:0.1f}".format(val)])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V121', data=put_body, headers=put_header, timeout=10)

        dewpoint =  state.currentOutsideTemperature - ((100.0 - state.currentOutsideHumidity) / 5.0)
        put_body = json.dumps(["{0:0.1f}".format(util.returnTemperatureCF(dewpoint)) + util.returnTemperatureCFUnit()])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V12', data=put_body, headers=put_header, timeout=10)


        if (state.fanState == False):
            val = 0
        else:
            val = 1
        put_body = json.dumps([val])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V122', data=put_body, headers=put_header, timeout=10)


        #wind
        val = util.returnWindSpeed(state.ScurrentWindSpeed)
        tval = "{0:0.1f}".format(val) + util.returnWindSpeedUnit()
        put_body = json.dumps([tval])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V9', data=put_body, headers=put_header, timeout=10)

        #now humiidyt
        #val = util.returnWindSpeed(state.ScurrentWindSpeed)
        val = state.currentOutsideHumidity
        put_body = json.dumps([val])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V19', data=put_body, headers=put_header, timeout=10)

        # outdoor Air Quality
        val = state.Outdoor_AirQuality_Sensor_Value 
        put_body = json.dumps([val])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V20', data=put_body, headers=put_header, timeout=10)
        
        #wind direction
        val = "{0:0.0f}/".format(state.ScurrentWindDirection) + util.returnWindDirection(state.ScurrentWindDirection)
        put_body = json.dumps([val])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V2', data=put_body, headers=put_header, timeout=10)

        #rain 
        # val = "{0:0.2f}".format(state.currentTotalRain) 
        if (state.EnglishMetric == 1):
            tval = "{0:0.2f}mm".format(state.currentTotalRain) 
        else:
            tval = "{0:0.2f}in".format(state.currentTotalRain / 25.4) 
        put_body = json.dumps([tval])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V3', data=put_body, headers=put_header, timeout=10)

         #rain last hour
        # val = "{0:0.2f}".format(state.currentRain60Minutes)
        if (state.EnglishMetric == 1):
            tval = "{0:0.2f}mm".format(state.currentRain60Minutes) 
        else:
            tval = "{0:0.2f}in".format(state.currentRain60Minutes / 25.4) 
        put_body = json.dumps([tval])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V14', data=put_body, headers=put_header, timeout=10)

        #rain rate
        # val = "{0:0.2f}".format(state.currentRain60Minutes)
        if (state.EnglishMetric == 1):
            tval = "{0:0.2f}mm".format(state.currentRainRate) 
        else:
            tval = "{0:0.2f}in".format(state.currentRainRate / 25.4) 
        put_body = json.dumps([tval])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V15', data=put_body, headers=put_header, timeout=10)

        #Sunlight 
        val = "{0:0.0f}".format(state.currentSunlightVisible) 
        #print ("Sunlight Val = ", state.currentSunlightVisible)
        put_body = json.dumps([val])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V4', data=put_body, headers=put_header, timeout=10)

        #barometric Pressure 
        if (state.EnglishMetric == 1):
            tval = "{0:0.2f}hPa".format(state.currentSeaLevel) 
        else:
            tval = "{0:0.2f}in".format((state.currentSeaLevel * 0.2953)/10.0) 
        put_body = json.dumps([tval])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V40', data=put_body, headers=put_header, timeout=10)

        #barometric Pressure graph
        if (state.EnglishMetric == 1):
            tval = "{0:0.2f}".format(state.currentSeaLevel) 
        else:
            tval = "{0:0.2f}".format((state.currentSeaLevel * 0.2953)/10.0) 
        put_body = json.dumps([tval])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V41', data=put_body, headers=put_header, timeout=10)

        #solar data

        val = "{0:0.2f}".format(state.solarVoltage) 
        put_body = json.dumps([val])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V50', data=put_body, headers=put_header, timeout=10)

        val = "{0:0.1f}".format(state.solarCurrent) 
        put_body = json.dumps([val])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V51', data=put_body, headers=put_header, timeout=10)

        val = "{0:0.2f}".format(state.batteryVoltage) 
        put_body = json.dumps([val])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V52', data=put_body, headers=put_header, timeout=10)

        val = "{0:0.1f}".format(state.batteryCurrent) 
        put_body = json.dumps([val])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V53', data=put_body, headers=put_header, timeout=10)

        val = "{0:0.2f}".format(state.loadVoltage) 
        put_body = json.dumps([val])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V54', data=put_body, headers=put_header, timeout=10)

        val = "{0:0.1f}".format(state.loadCurrent) 
        put_body = json.dumps([val])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V55', data=put_body, headers=put_header, timeout=10)

        val = "{0:0.1f}W".format(state.batteryPower) 
        put_body = json.dumps([val])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V60', data=put_body, headers=put_header, timeout=10)
        
        val = "{0:0.1f}W".format(state.solarPower) 
        put_body = json.dumps([val])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V61', data=put_body, headers=put_header, timeout=10)
        
        val = "{0:0.1f}W".format(state.loadPower) 
        put_body = json.dumps([val])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V62', data=put_body, headers=put_header, timeout=10)

        if (config.SolarMAX_Present == True):
        
            val = util.returnTemperatureCF(state.SolarMaxInsideTemperature)
            tval = "{0:0.1f} ".format(val) + util.returnTemperatureCFUnit()
            put_body = json.dumps([tval])
            r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V76', data=put_body, headers=put_header, timeout=10)

            val = "{0:0.1f}%".format(state.SolarMaxInsideHumidity) 
            put_body = json.dumps([val])
            r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V77', data=put_body, headers=put_header, timeout=10)

        
        
        val = "{0:0.1f}".format(state.batteryCharge) 
        put_body = json.dumps([val])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V56', data=put_body, headers=put_header, timeout=10)
        
        val = "{0:0.1f}".format(state.batteryCharge) 
        put_body = json.dumps([val])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V127', data=put_body, headers=put_header, timeout=10)
        
        delta = util.returnTemperatureCF(state.currentInsideTemperature)- util.returnTemperatureCF(state.currentOutsideTemperature)
        
        val = "{0:0.1f}".format(delta) 
        put_body = json.dumps([val])
        r = requests.put(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V128', data=put_body, headers=put_header, timeout=10)
        
        
        # LEDs 

        if (DEBUGBLYNK):
            print ("BarometricTrend: ", state.barometricTrend)
            #if (state.barometricTrend):   #True is up, False is down
        if (state.barometricTrend == 0):
            r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V42?color=%23FFFFFF', timeout=10) #  White
        elif (state.barometricTrend == 1):
            r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V42?color=%2300FF00', timeout=10) # Green
        else:
            r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V42?color=%23FF0000', timeout=10) # red

        if (DEBUGBLYNK):
                print ("blynkBarometricTrendUpdate:OTHER:r.status_code:",r.status_code)

        print ("lightning at: ", state.currentAs3935LastLightningTimeStamp, " time: ", time.time() - state.currentAs3935LastLightningTimeStamp)
        if (time.time() - state.currentAs3935LastLightningTimeStamp > 1800):
            print ("time elasped since last strike")
            state.currentAs3935LastLightningTimeStamp = 0

        if (state.currentAs3935LastLightningTimeStamp == 0):   #True is lightning, False is none
            r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V43?color=%2300FF00', timeout=10) # Green
            if (DEBUGBLYNK):
                print ("blynkAlarmUpdate:OTHER:r.status_code:",r.status_code)
        else:
            r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/update/V43?color=%23FF0000', timeout=10) # red


        return 1
    except Exception as e:
        print ("exception in blynkStateUpdate")
        print(traceback.format_exc())
        print (e)
        return 0

def blynkStatusUpdate():

    if (DEBUGBLYNK):
        print ("blynkStatusUpdate Entry")
    try:
        put_header={"Content-Type": "application/json"}

        # look for English or Metric 
        r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/get/V8') # read button state
        if (DEBUGBLYNK):
            print ("blynkStatusUpdate:POSTEM:r.status_code:",r.status_code)
            print ("blynkStatusUpdate:POSTEM:r.text:",r.text)
    
        if (r.text == '["1"]'):
            if (state.EnglishMetric == 0):
                state.EnglishMetric = 1
                if (DEBUGBLYNK):
                    print ("blynkStatusUpdate:POSTBRC:state.EnglishMetric set to Metric")
                blynkStatusTerminalUpdate("Set to Metric Units ")
                f = open("/home/pi/SDL_Pi_SkyWeather/state/EnglishMetric.txt", "w")
                f.write("1")
                f.close()
        else:

            if (state.EnglishMetric == 1):
                state.EnglishMetric = 0
                f = open("/home/pi/SDL_Pi_SkyWeather/state/EnglishMetric.txt", "w")
                f.write("0")
                f.close()
                if (DEBUGBLYNK):
                    print ("blynkStatusUpdate:POSTBRC:state.EnglishMetric set to English")
                blynkStatusTerminalUpdate("Set to English Units ")


        # look for rainbow button change
        r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/get/V5') # read button state
        if (DEBUGBLYNK):
            print ("blynkStatusUpdate:POSTBR:r.status_code:",r.status_code)
            print ("blynkStatusUpdate:POSTBR:r.text:",r.text)
    
        if (r.text == '["1"]'):
            state.runRainbow = True
            blynkStatusTerminalUpdate("Turning Rainbow On ")
            if (DEBUGBLYNK):
                print ("blynkStatusUpdate:POSTBRC:state.runRainbow set to True")
        else:
            if(state.runRainbow == True):
                blynkStatusTerminalUpdate("Turning Rainbow Off ")
            state.runRainbow = False
            if (DEBUGBLYNK):
                print ("blynkStatusUpdate:POSTBRC:state.runRainbow set to False")

                
        # turn OLED ON and OFF 
        r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/get/V6') # read button state
        #if (DEBUGBLYNK):
    
        if (r.text == '["1"]'):
            if (state.runOLED == False):
                state.runOLED = True
                blynkStatusTerminalUpdate("Turning OLED On ")
                if (DEBUGBLYNK):
                    print ("blynkStatusUpdate:POSTBRO:state.runOLED set to True")

                if (config.OLED_Originally_Present == True):
                    config.OLED_Present = True 
                    util.turnOLEDOn()
        else:
            if (state.runOLED == True):
                blynkStatusTerminalUpdate("Turning OLED Off ")
                state.runOLED = False
                
                if (DEBUGBLYNK):
                    print ("blynkStatusUpdate:POSTBRO:state.runOLED set to False")
                if (config.OLED_Originally_Present == True):
                    config.OLED_Present = False 
                    util.turnOLEDOff()

        # look for Flash Strip Command
        r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/get/V30') # read button state
        if (DEBUGBLYNK):
            print ("blynkStatusUpdate:POSTBF:r.status_code:",r.status_code)
            print ("blynkStatusUpdate:POSTBF:r.text:",r.text)
   
        
        if (r.text == '["1"]'):
            state.flashStrip = True
            if (DEBUGBLYNK):
                print ("blynkStatusUpdate:POSTBRF:state.flashStrip set to True")
        else:
            state.flashStrip = False
            if (DEBUGBLYNK):
                print ("blynkStatusUpdate:POSTBRF:state.flashStrip set to False")




        


        return 1
    except Exception as e:
        print ("exception in blynkStatusUpdate")
        print (e)
        return 0


        
def blynkSGSAppOnline():

    try:
        r = requests.get(config.BLYNK_URL+config.BLYNK_AUTH+'/isAppConnected')
        if (DEBUGBLYNK):
            print ("blynkSGSAppOnline:POSTCHECK:r.text:",r.text)
        return r.text
    except Exception as e:
        print ("exception in blynkApponline")
        print (e)
        return ""