Subversion Repositories HomeAutomation

Sensor_ModuleNames    = [ "DS18x20", "FOST02", "BusVoltage", "SimpleDTMF", "DHT11", "VoltageCurrent", "ultrasonic", "flower", "NTC", "TC1047A", "LM335", "TCN75A"];

SensorRf_ModuleNames    = [ "rfTransceive" ];

Sensor_Intervals      = function() { return [ 1, 5, 10, 15, 20 ]; };

Sensor_Aliases        = function() { return Module_GetAliasNames(Sensor_ModuleNames); };

Sensor_AvailableIds   = function() { return Module_GetAvailableIds(Sensor_ModuleNames); };

function Sensor_SetReportInterval(alias_name, interval)

{

    if (arguments.length < 2)

    {

        Log("\033[31mNot enough parameters given.\033[0m\n");

        return false;

    }

    var aliases_data = Module_ResolveAlias(alias_name, Sensor_ModuleNames);

    var found = false;

    for (var name in aliases_data)

    {

        var variables = {"Time"     : interval };

        if (Module_SendMessage(aliases_data[name]["module_name"], aliases_data[name]["module_id"], "Report_Interval", variables))

        {

            Log("\033[32mCommand sent successfully to " + name + ".\033[0m\n");

        }

        else

        {

            Log("\033[31mFailed to send command to " + name + ".\033[0m\n");

        }

        found = true;

    }

    if (!found)

    {

        Log("\033[31mNo aliases by the name " + alias_name + " were applicable for this command.\033[0m\n");

        return false;

    }

    return true;

}

Console_RegisterCommand(Sensor_SetReportInterval, function(arg_index, args) { return Console_StandardAutocomplete(arg_index, args, Sensor_Aliases(), Sensor_Intervals()); });

Sensor_OnNewPhonenumberFunctions = [];

function Sensor_RegisterToNewPhonenumber(alias_name, callback)

{

  if (!Sensor_OnNewPhonenumberFunctions[alias_name])

  {

    Sensor_OnNewPhonenumberFunctions[alias_name] = [];

  }

  Sensor_OnNewPhonenumberFunctions[alias_name].push(callback);

}

Sensor_OnDeviceStateChangeFunctions = [];

function Sensor_RegisterToDeviceStateChange(alias_name, callback)

{

  if (!Sensor_OnDeviceStateChangeFunctions[alias_name])

  {

    Sensor_OnDeviceStateChangeFunctions[alias_name] = [];

  }

  Sensor_OnDeviceStateChangeFunctions[alias_name].push(callback);

}

function Sensor_OnMessage(module_name, module_id, command, variables)

{

  if (in_array(Sensor_ModuleNames, module_name))

  {

    var aliases_data = Module_LookupAliases({

      "module_name" : module_name,

      "module_id"   : module_id,

      "group"       : false

    });

    switch (command)

    {

      case "Phonenumber":

      {

        for (var alias_name in aliases_data)

        {

          var number = variables["Number"];

          var incommingCall = true;

          var checkName = true;

          Log("received from DTMF:\"" + number + "\"");

          if (variables["Number"].length >= 6)

          {

            /* A seems to mean it is an incomming call! */

            if (number.charAt(0) === 'A' || number.charAt(0) === 'D')

            {

              incommingCall = true;

              /* Remove leading A */

              number = number.substring(1);

            }

            else /* Outgoing call */

            {

              incommingCall = false;

            }

            /* A number can have a trailing C */

            var endIndex = number.indexOf('C');

            if (endIndex !== -1)

            {

              /* Remove trailing C */

              number = number.substring(0, endIndex);

            }

          }

          else if (number == "B00C")

          {

            /* Unknown number */

            number = "Unknown";

            incommingCall = true;

            checkName = false;

          }

          else if (number == "B10C")

          {

            /* Secret/protected number */

            number = "Protected";

            incommingCall = true;

            checkName = false;

          }

          else

          {

            Log("DTMF decoded number is to short, number: \"" + number + "\", length: " + number.length);

            return;

          }

          /* Adding area code prefix if needed */

          if (number.charAt(0) != '0' && checkName)

          {

            if (typeof sensorDefaultPhoneAreaCode === 'undefined')

            {

              Log("\033[31mOnlinePhonebook: please add sensorDefaultPhoneAreaCode = yourAreaCode to autostart.js, defaulting to 031\033[0m\n");

              number = "031" + number;

            }

            else

            {

                number = sensorDefaultPhoneAreaCode + number;

            }

          }

          /* Store number and direction in last values */

          var lastValue = {};

          var lastValueString = Storage_GetParameter("LastValues", alias_name);

          if (lastValueString)

          {

            lastValue = JSON.parse(lastValueString);

          }

          var timestamp = get_time();

          lastValue["Phonenumber"] = { "value" : number, "timestamp" : timestamp };

          lastValue["Direction"] = { "value" : incommingCall ? "in" : "out", "timestamp" : timestamp };

          Storage_SetParameter("LastValues", alias_name, JSON.stringify(lastValue));

          /* Store number in phone call history */

          var newValue = { "number" : number, "direction" : incommingCall ? "in" : "out", "module" : alias_name, "names" : [], "timestamp" : timestamp };

          Storage_SetParameter("PhoneCalls", timestamp, JSON.stringify(newValue));

          /* Log the number */

          Log("New number: " + number + ", direction: " + (incommingCall ? "in" : "out"));

          /* Lookup name */

          if (checkName)

          {

            Sensor_StoreNumberInPhonebook(number, timestamp);

          }

          var phonebookNumbers = Storage_GetJsonParamter("PhoneBook", number);

          if (!phonebookNumbers)

          {

            phonebookNumbers = [];

          }

          /* Call any potential subscribers */

          if (Sensor_OnNewPhonenumberFunctions[alias_name])

          {

            for (var n in Sensor_OnNewPhonenumberFunctions[alias_name])

            {

              /* Call callback with arguments alias, number, direction */

              Sensor_OnNewPhonenumberFunctions[alias_name][n](alias_name, number, incommingCall ? "in" : "out", phonebookNumbers);

            }

          }

        }

        break;

      }

      case "Voltage":

      case "Temperature_Celsius":

      {

        if ((module_name == "DS18x20") && (variables["Value"] == 85))

        {

          Log("\033[31mDS18x20: Temperature conversion error: " + module_name + ":" + module_id + ", SensorId=" + variables["SensorId"] + "\033[0m");

          break;

        }

      }

      case "Humidity_Percent":

      case "Percent":

      case "Distance":

      {

        for (var alias_name in aliases_data)

        {

          if (aliases_data[alias_name]["specific"]["SensorId"] != variables["SensorId"])

          {

            continue;

          }

          var last_value = {};

          var last_value_string = Storage_GetParameter("LastValues", alias_name);

          if (last_value_string)

          {

            last_value = eval("(" + last_value_string + ")");

          }

      last_value[command] = { "value" : variables["Value"], "timestamp" : get_time() };

          Storage_SetParameter("LastValues", alias_name, JSON.stringify(last_value));

        }

        break;

      }

    }

  }

}

Module_RegisterToOnMessage("all", Sensor_OnMessage);

function SensorRf_OnMessage(module_name, module_id, command, variables)

{

    if (in_array(SensorRf_ModuleNames, module_name))

    {

        var aliases_data = Module_LookupAliases({

        "module_name" : module_name,

        "module_id"   : module_id,

        "group"       : false   });

        /* Must check sensor here in case no alias is stored the adress needs to be printed */

        var RubicsonSuccess = "NoRubicsonSensor";

        var OregonRainSuccess = "NoSensor";

        var OregonTempHumSuccess = "NoSensor";

        var OregonWindSuccess = "NoSensor";

        var VikingSuccess = "NoVikingSensor";

        var VikingSteakSuccess = "NoVikingSteakSensor";

        var RubicsonStationSuccessPkt1 = "NoSensor";

        var RubicsonStationSuccessPkt2 = "NoSensor";

        if (variables["Protocol"] == "OregonRain")

        {

            /* ----------- Data order proto-data ------

            * cc bb bb bb aa aa

            * a   = Rain in 0.01 inches per hour

            * b   = Total Rain in 0.001 inches

            * cc   = 0xddefffff

            *   dd = Channel

            *   e  = Battery low flag

            *   fffff = Lower part of rolling code

            * -----------------------------*/

            var data = variables["IRdata"];

            var inchPerHour = (data)&0xFFFF;

            inchPerHour = inchPerHour/100;

            var totInch = (data>>>16)&0xFFFFFF;

            totInch = totInch/1000;

            var totMM = totInch * 25.4;

            var mmPerHour = inchPerHour * 25.4;

            var addr = rshift(data,46)&0x3;

            var bat = rshift(data,45)&0x1;

            var unknown = rshift(data,40)&0x1F;

            OregonRainSuccess = "NotFound";

        } else if (variables["Protocol"] == "OregonTempHum")

        {

               /* ----------- Data order proto-data ------

            * cc 00 00 bb bb aa

            * aa   = Humidity in %

            * bbbb = Temperature*10 in celcius

            * cc   = 0xddefffff

            *   dd = Channel

            *   e  = Battery low flag

            *   fffff = Lower part of rolling code

            * -----------------------------*/  

            var data = variables["IRdata"];

            var humidity = (data)&0xFF;

            var temp = (data>>>8)&0x7FFF;

            var sign = (temp>>>23)&1;

            if (sign > 0)

            {

                temp = temp^0x7FFF;

                temp += 1;

                temp = -temp;

            }

            temp = temp/10;

            var addr = rshift(data,46)&0x3;

            var bat = rshift(data,45)&0x1;

            var unknown = rshift(data,40)&0x1F;

            OregonTempHumSuccess = "NotFound";

        } else if (variables["Protocol"] == "OregonWind")

        {

            /* ----------- Data order proto-data ------

            * cc 00 0d bb ba aa

            * aaa  = wind speed average (in 0.1m/s)

            * bbb  = wind speed current (in 0.1m/s)

            * d    = Direction in 22.5 degrees

            * cc   = 0xddefffff

            *   dd = Channel

            *   e  = Battery low flag

            *   fffff = Lower part of rolling code

            * -----------------------------*/

            var data = variables["IRdata"];

            var average = (data)&0xFFF;

            average = average/10;

            var current = rshift(data,12)&0xFFF;

            current = current/10;

            var direction = rshift(data,24)&0xF;

            direction = direction*22.5;

            var addr = rshift(data,46)&0x3;

            var bat = rshift(data,45)&0x1;

            var unknown = rshift(data,40)&0x1F;

            OregonWindSuccess = "NotFound";

        } else if (variables["Protocol"] == "Rubicson")

        {

            /*

                      ??? aaaaaaaa sttttttttttt hhhhhhhh cccccccc

            341731651126    0b100 11111001 000011001011 00101110 00110110   20.3 46%

            a = address, s = sign, t = temperature, h = humidity, c = crc

            */

            var data = variables["IRdata"];

            var unknown = rshift(data,26)&0x3FF;

            //var crc = data&0xFF;

            //var humidity = (data>>>8)&0xFF;

            var temp = (data>>>12)&0xFFF;

            var addr = rshift(data,24)&0x3;

            //var calccrc=crc8(rshift(data,8), 32);

            var sign = (temp>>>11)&1;

            if (sign > 0)

            {

                temp = temp^0xFFF;

                temp += 1;

                temp = -temp;

            }

            temp = temp/10;

            RubicsonSuccess = "RubicsonNotFound";

        } else if (variables["Protocol"] == "Viking")

        {

            /*

                              ppp aaaaaaaa sttttttttttt hhhhhhhh cccccccc

            341731651126    0b100 11111001 000011001011 00101110 00110110   20.3 46%

            p = protocol type, a = address, s = sign, t = temperature, h = humidity, c = crc

            */

            var data = variables["IRdata"];

            var crc = data&0xFF;

            var humidity = (data>>>8)&0xFF;

            var temp = (data>>>16)&0xFFF;

            var addr = rshift(data,28)&0xFF;

            var type = rshift(data,36)&0xF;

            var calccrc=crc8(rshift(data,8), 32);

            var sign = (temp>>>11)&1;

            temp = temp&0x7FF;

            if (sign > 0)

            {

                temp = -temp;

            }

            temp = temp/10;

            VikingSuccess = "VikingNotFound";

            if (type != 4 && type != 3)

            {

                Log("\033[33mWarning: VikingSensor, type="+type+", data="+data+"\033[0m");

            }

        } else if (variables["Protocol"] == "VikingSteak")

        {

            var data = variables["IRdata"];

            var addr = (data>>>4)&0xFF;

            var byte0 = rshift(data,32)&0xF;

            var byte1 = rshift(data,28)&0xF;

            var byte2 = rshift(data,24)&0xF;

            var temp = Math.round((((((byte1^byte2)<<8)+((byte0^byte1)<<4)+byte0^10)-122)*5)/9);

            VikingSteakSuccess = "VikingNotFound";

        } else if (variables["Protocol"] == "RubicsonStn")

        {

            var data = variables["IRdata"];

            var pkt = rshift(data,39)&0x1;

            if (pkt == 0)  //This is the first part

            {      

                /*

                      aaaaaaaa 0dddsttt tttttttt hhhhhhhh wwwwwwww wwwwwwww

                    0b11111001 11111001 00001100 10110010 11100011 01101111

                a = address = winddirection, s = sign, t = temperature, h = humidity, w = vindspeed

                */

                var windspeed_avg = (rshift(data,8) & 0xFF)*0.8;

                var windspeed_max = (data & 0xFF)*0.8;

                //var crc = data&0xFF;

                var humidity = rshift(data,16)&0xFF;

                var temp = rshift(data,24)&0xFFF;

                var winddirection = (rshift(data,36)&0x7)*360/8;

                var addr = rshift(data,40)&0xFF;

                //var calccrc=crc8(rshift(data,8), 32);

                var sign = (temp>>>11)&1;

                if (sign > 0)

                {

                    temp = temp^0xFFF;

                    temp += 1;

                    temp = -temp;

                }

                temp = temp/10;

                RubicsonStationSuccessPkt1 = "NotFound";

            } else //This is the second part

            {

                /*

                      aaaaaaaa 1------- -------b rrrrrrrr rrrrrrrr rrrrrrrr

                    0b11111001 11111001 00001100 10110010 11100011 01101111

                a = address b = battery empty, r = rain

                */

                var battery = rshift(data,24) & 0x1;

                //var crc = data&0xFF;

                var rain = 0.4*(data&0xFFFFFF);

                var addr = rshift(data,40)&0xFF;

                RubicsonStationSuccessPkt2 = "NotFound";

            }

        }

        loopAliases:    /* Label to break nested */

        for (var alias_name in aliases_data)

        {

            if (aliases_data[alias_name]["specific"]["Channel"] == variables["Channel"] &&

                aliases_data[alias_name]["specific"]["Proto"] == variables["Protocol"])

            {

                switch (variables["Protocol"])

                {

                    case "RubicsonStn":

                    {   /* Add alias with these specifics: Channel=0,Proto=RubicsonStn,Address=<address of sensor> */

                        /* if no Address is added to the alias, all RubicsonStn will match*/

                        if (aliases_data[alias_name]["specific"]["Address"] == undefined)

                        {

                            if (pkt == 0)

                            {

                                var last_value = {};

                                var last_value_string = Storage_GetParameter("LastValues", alias_name);

                                if (last_value_string)

                                {

                                    last_value = eval("(" + last_value_string + ")");

                                }

                                var timestamp = get_time();

                                last_value["Temperature_Celsius"] = { "value" : temp.toString(), "timestamp" : timestamp };

                                last_value["Humidity_Percent"] = { "value" : humidity.toString(), "timestamp" : timestamp };

                                last_value["Wind_Speed_Avg"] = { "value" : windspeed_avg.toString(), "timestamp" : timestamp };

                                last_value["Wind_Speed_Max"] = { "value" : windspeed_max.toString(), "timestamp" : timestamp };

                                last_value["Wind_Direction"] = { "value" : winddirection.toString(), "timestamp" : timestamp };

                                last_value["Address"] = { "value" : addr, "timestamp" : timestamp };

                                Storage_SetParameter("LastValues", alias_name, JSON.stringify(last_value));

                                RubicsonStationSuccessPkt1 = "RubicsonStnFound";

                                break loopAliases;

                            } else

                            {

                              var last_value = {};

                                var last_value_string = Storage_GetParameter("LastValues", alias_name);

                                if (last_value_string)

                                {

                                    last_value = eval("(" + last_value_string + ")");

                                }

                                var timestamp = get_time();

                                last_value["WaterAbsolute_mm"] = { "value" : rain.toString(), "timestamp" : timestamp };

                                last_value["Battery_Low"] = { "value" : battery.toString(), "timestamp" : timestamp };

                                last_value["Address"] = { "value" : addr, "timestamp" : timestamp };

                                Storage_SetParameter("LastValues", alias_name, JSON.stringify(last_value));

                                RubicsonStationSuccessPkt2 = "RubicsonStnFound";

                                break loopAliases;

                            }

                        }

                        else if (addr == aliases_data[alias_name]["specific"]["Address"])

                        {

                            if (pkt == 0)

                            {

                                var last_value = {};

                                var last_value_string = Storage_GetParameter("LastValues", alias_name);

                                if (last_value_string)

                                {

                                    last_value = eval("(" + last_value_string + ")");

                                }

                                var timestamp = get_time();

                                last_value["Temperature_Celsius"] = { "value" : temp.toString(), "timestamp" : timestamp };

                                last_value["Humidity_Percent"] = { "value" : humidity.toString(), "timestamp" : timestamp };

                                last_value["Wind_Speed"] = { "value" : windspeed.toString(), "timestamp" : timestamp };

                                last_value["Wind_Direction"] = { "value" : winddirection.toString(), "timestamp" : timestamp };

                                last_value["Address"] = { "value" : addr, "timestamp" : timestamp };

                                Storage_SetParameter("LastValues", alias_name, JSON.stringify(last_value));

                                RubicsonStationSuccessPkt1 = "RubicsonStnFound";

                                break loopAliases;

                            } else

                            {

                              var last_value = {};

                                var last_value_string = Storage_GetParameter("LastValues", alias_name);

                                if (last_value_string)

                                {

                                    last_value = eval("(" + last_value_string + ")");

                                }

                                var timestamp = get_time();

                                last_value["WaterAbsolute_mm"] = { "value" : (rain*0.4).toString(), "timestamp" : timestamp };

                                last_value["Battery_Low"] = { "value" : battery.toString(), "timestamp" : timestamp };

                                last_value["Address"] = { "value" : addr, "timestamp" : timestamp };

                                Storage_SetParameter("LastValues", alias_name, JSON.stringify(last_value));

                                RubicsonStationSuccessPkt2 = "RubicsonStnFound";

                                break loopAliases;

                            }

                        }

                        break;

                    }

                    case "Viking":

                    {   /* Add alias with these specifics: Channel=0,Proto=Viking,Address=<address of sensor> */

                        if (type == 4)

                        {

                            if (crc != calccrc)

                            {

                                Log("\033[31mError: VikingSensor, incorrect CRC, data="+data+", CRC="+crc+", calcCRC="+calccrc+"\033[0m");

                                break loopAliases;

                            }

                            if (addr == aliases_data[alias_name]["specific"]["Address"])

                            {

                                VikingSuccess = "VikingFound";

                                var last_value = {};

                                var last_value_string = Storage_GetParameter("LastValues", alias_name);

                                if (last_value_string)

                                {

                                    last_value = eval("(" + last_value_string + ")");

                                }

                                var timestamp = get_time();

                                last_value["Temperature_Celsius"] = { "value" : temp.toString(), "timestamp" : timestamp };

                                if (humidity<101)

                                {

                                    last_value["Humidity_Percent"] = { "value" : humidity.toString(), "timestamp" : timestamp };

                                }

                                Storage_SetParameter("LastValues", alias_name, JSON.stringify(last_value));

                                break loopAliases;

                            }

                        }

                        else if (type == 3)

                        {

                            /* Don't check crc since all bits did not fit in CAN-frame */

                            if (addr == aliases_data[alias_name]["specific"]["Address"])

                            {

                                VikingSuccess = "VikingFound";

                                var last_value = {};

                                var last_value_string = Storage_GetParameter("LastValues", alias_name);

                                if (last_value_string)

                                {

                                    last_value = eval("(" + last_value_string + ")");

                                }

                                var timestamp = get_time();

                                temp = temp-40.0;

                                waterlevel = (crc*256 + humidity)*0.3;

                                /* Using COUNTER as DS in rrdtool does only work if the data is integer,

                                   to work around this let's create a second variable with the water level

                                   multiplied with 10 and rounded to integer.

                                   Then when generating graph, the data must be divided by 10 */

                                var waterlevel10xInt = Math.round(waterlevel*10);

                                last_value["Temperature_Celsius"] = { "value" : temp.toString(), "timestamp" : timestamp };

                                last_value["WaterAbsolute_mm"] = { "value" : waterlevel.toString(), "timestamp" : timestamp };

                                last_value["WaterAbsolute10xInt_mm"] = { "value" : waterlevel10xInt.toString(), "timestamp" : timestamp };

                                Storage_SetParameter("LastValues", alias_name, JSON.stringify(last_value));

                                break loopAliases;

                            }

                        }

                        break;

                    }

                    case "Rubicson":

                    {   /* Add alias with these specifics: Channel=0,Proto=Rubicson,Address=<address of sensor> */

                        /*if (crc != calccrc)

                        {

                            Log("\033[31mError: VikingSensor, incorrect CRC, data="+data+", CRC="+crc+", calcCRC="+calccrc+"\033[0m");

                            break loopAliases;

                        }*/

                        if (addr == aliases_data[alias_name]["specific"]["Address"])

                        {

                            RubicsonSuccess = "RubicsonFound";

                            var last_value = {};

                            var last_value_string = Storage_GetParameter("LastValues", alias_name);

                            if (last_value_string)

                            {

                                last_value = eval("(" + last_value_string + ")");

                            }

                            var timestamp = get_time();

                            last_value["Temperature_Celsius"] = { "value" : temp.toString(), "timestamp" : timestamp };

                            /*if (humidity<101)

                            {

                                last_value["Humidity_Percent"] = { "value" : humidity.toString(), "timestamp" : timestamp };

                            }

                            */

                            Storage_SetParameter("LastValues", alias_name, JSON.stringify(last_value));

                            break loopAliases;

                        }

                        break;

                    }

                    case "VikingSteak":

                    {   /* Add alias with these specifics: Channel=0,Proto=VikingSteak,Address=<address of sensor> */

                        /* if no Address is added to the alias, all vikingSteaksensors will match*/

                        if (aliases_data[alias_name]["specific"]["Address"] == undefined)

                        {

                            VikingSteakSuccess = "VikingFound";

                            var last_value = {};

                            var last_value_string = Storage_GetParameter("LastValues", alias_name);

                            if (last_value_string)

                            {

                                last_value = eval("(" + last_value_string + ")");

                            }

                            var timestamp = get_time();

                            last_value["Temperature_Celsius"] = { "value" : temp.toString(), "timestamp" : timestamp };

                            last_value["Address"] = { "value" : addr, "timestamp" : timestamp };

                            Storage_SetParameter("LastValues", alias_name, JSON.stringify(last_value));

                            break loopAliases;

                        }

                        else if (addr == aliases_data[alias_name]["specific"]["Address"])

                        {

                            VikingSteakSuccess = "VikingFound";

                            var last_value = {};

                            var last_value_string = Storage_GetParameter("LastValues", alias_name);

                            if (last_value_string)

                            {

                                last_value = eval("(" + last_value_string + ")");

                            }

                            var timestamp = get_time();

                            last_value["Temperature_Celsius"] = { "value" : temp.toString(), "timestamp" : timestamp };

                            last_value["Address"] = { "value" : addr, "timestamp" : timestamp };

                            Storage_SetParameter("LastValues", alias_name, JSON.stringify(last_value));

                            break loopAliases;

                        }

                        break;

                    }

                    case "Nexa2":

                    {   /* Add alias with these specifics: Channel=0,Proto=Nexa2,OnData=<data for on>,OffData=<data for off> */

                        var deviceStateCommand = "";

                        if (variables["IRdata"] == aliases_data[alias_name]["specific"]["OnData"] && variables["Status"] == "Pressed")

                        {

                            deviceStateCommand = "On";

                        }

                        else if (variables["IRdata"] == aliases_data[alias_name]["specific"]["OffData"] && variables["Status"] == "Pressed")

                        {

                            deviceStateCommand = "Off";

                        }

                        else

                        {

                            break;

                        }

                        var last_value = {};

                        var last_value_string = Storage_GetParameter("LastValues", alias_name);

                        if (last_value_string)

                        {

                            last_value = eval("(" + last_value_string + ")");

                        }

                        if (( typeof(last_value["State"]) == "undefined" ) ||

                            ( deviceStateCommand == "Off" && last_value["State"]["value"] == "On" ) ||

                            ( deviceStateCommand == "On" && last_value["State"]["value"] == "Off" ))

                        {

                            last_value["State"] = { "value" : deviceStateCommand, "timestamp" : get_time() };