Maintenance Buttler

'use strict';

const SensorValue = require('./SensorValue');

module.exports = function(intentRequest,callback) {
  console.log(`dispatch userId=${intentRequest.userId}, intentName=${intentRequest.currentIntent.name}`);
  const intentName = intentRequest.currentIntent.name;// we get the intent that was called

 
  if (intentName === 'GetSensorValue') {// if the intent is GetSensorValue we call the function SensorValue
    console.log(intentName + ' was called');
      return SensorValue(intentRequest,callback);
    //return GetSensorValue(intentRequest);
  }

  if (intentName === 'GreetingIntent') {
    return greetUser(intentRequest);
  }

  throw new Error(`Intent with name ${intentName} not supported`);
};

'use strict';
const dispatch =require('./dispatch');

module.exports.intents =(event,context, callback)=>{
    try{
        console.log(`event.bot.name=${event.bot.name}`);
        dispatch(event,(response)=> callback(null,response));// this function is called..
    }catch(err){
        callback(err);
    }
    };

'use strict';
const lexResponses =require("./lexResponses")
const AWS =require("aws-sdk");
const ddb = new AWS.DynamoDB({apiVersion: '2012-08-10'});
const docClient = new AWS.DynamoDB.DocumentClient();



module.exports = function(intentRequest,callback){
    // We get the slot information this will be the slot NAME not the slot type !!!!
    var sensor=intentRequest.currentIntent.slots.sensor;
    var sensorPlace= intentRequest.currentIntent.slots.place;
    var SensorResponse=0;
    console.log("called : "+sensor + "in " +sensorPlace);

    const source= intentRequest.invocationSource;
    console.log(source);

    if (source ==="DialogCodeHook"){
        callback(lexResponses.delegate(intentRequest.sessionAttributes, intentRequest.currentIntent.slots));
        return;
    }

    if(source==="FulfillmentCodeHook"){

                  console.log("is a fullfilment");
                  //---Code to extract from DynamoDB
                        var requestedtype=sensor;// type of sensor
                        var foundimei="";
                        var sensortype=""

                    //Query to find Sensor Imeis based on the place
                    var paramsSensor = {
                    TableName: 'devices',
                    KeyConditionExpression: "#ro = :roomname",
                    ExpressionAttributeNames: {
                          "#ro": "room"
                      },
                    ExpressionAttributeValues: {
                          ":roomname": sensorPlace,
                      }

                    };


                    /// queryyyy
                    //-- Function to Find imei based on the place
                    //-- We get the place from Lex Bot
                    docClient.query(paramsSensor, function(err, data) {
                    if (err) {
                      console.log("Error on lambda", err);
                    } else {

                      //console.log("Success", data.Items);
                      //console.log(typeof(data))
                      console.log(data)
                      console.log("Sensory Type: "+data.Items[0].type);//Type of Sensor


                      // Iterate over the array
                      data.Items.forEach(function(element, index, array) {
                      //console.log("Sensor types is : "+element.type+" With Imei : "+element.deviceid);
                      if(element.type=="multiple")
                      {
                        console.log("is Multiple");
                        console.log("Imei is "+element.deviceid);
                        foundimei=element.deviceid;
                        sensortype="multiple";
                      }else{
                        console.log("is single");
                        console.log("Imei is "+element.deviceid);
                        foundimei=element.deviceid;
                        sensortype="single";
                      }

                      });


                      //--Query to  get the sensor value
                      var paramsQuery = {
                        TableName: 'challenge6',
                        KeyConditionExpression: "#im = :imeinumber",
                        ExpressionAttributeNames: {
                            "#im": "imei"

                      },
                      ExpressionAttributeValues: {
                          ":imeinumber": foundimei

                      },
                      ScanIndexForward: false,
                      Limit:1

                  };

                    console.log("found imei = "+foundimei);
                    docClient.query(paramsQuery, function(err, data) {
                    if (err) {
                      console.log("Error on lambda", err);
                    } else {
                                var sensorkey="";
                                //console.log("Success", data.Items);
                                //console.log(typeof(data))
                                if(sensortype=="multiple"){
                                      console.log(data)
                                      data.Items.forEach(function(element, index, array) {
                                      //  console.log(Object.keys(data.Items.payloads[0]));
                                    //  if(Object.keys()==requestedtype)
                                      //    {
                                      console.log(element);
                                      Object.entries(element.payloads).forEach(entry => {
                                              let key = entry[0];

                                              let value = entry[1];
                                              //use key and value here
                                              console.log("key "+key);
                                              console.log("value "+ value);
                                              if(key==requestedtype)
                                              {
                                                SensorResponse=value;
                                                sensorkey=key;
                                              }

                                            });

                                      //   }
                                    });

                                    var sensorresponse="The "+sensorkey+" is "+SensorResponse;
                                      console.log("content response "+sensorresponse);
                                      callback(lexResponses.close(intentRequest.sessionAttributes,"Fulfilled",{contentType: "PlainText", content: sensorresponse}));
                                    }// End of sensor Multiple


                              }// End of else of query
                  });// en dof query to find value of temperature



                    }
                    });// en dof query for Sensor name to find imei



                  //-- End of code to extract from dynamoDB





    }//--- End of fullfilment
}

import sys, time, requests, json,random
from statistics import mean
import automationhat
time.sleep(0.1)



def Relay1_ON():
    automationhat.relay.one.on()

def Relay1_Off():
    automationhat.relay.one.off()

def Analog1():
    return (automationhat.analog.one.read()/0.02127-50)
def Analog2():
    return (automationhat.analog.two.read()*10)
def Analog3():
    average=[]
    for x in range(60):
        average.append(automationhat.analog.three.read())
    ##print("average is :")
    #print(average)
    print(max(average))
    print(min(average))
    return mean(average)

def Input1():
    if automationhat.input.one.read()==1 :
        return True
    else:
        return False


def SendFunnel(payload):
    headers = {'Content-Type': 'application/json'}

    print("- sending data to funnel")
    try:
            r = requests.post('http://funnel.soracom.io', data=json.dumps(payload), headers=headers, timeout=5)
            print(r)
    except requests.exceptions.ConnectTimeout:
            print('ERROR: connection timeout. Is 3G connection online?')

            #if r.status_code == 400:
            #    print('ERROR: failed to submit data. Did you configure Funnel for your SIM?')

Relay1_ON()
while True:
    print("Analog")
    ac=Analog3()
    print("------")
    temperature=Analog1()
    humidity=Analog2()
    TankLimit=Input1()
    print(temperature)
    print(humidity)
    print(TankLimit)
    print(ac)
    print("---------------")
    payload = {'temperature':temperature,"humidity":humidity,"overflow":TankLimit}

    SendFunnel(payload)
    ##print(payload)
    time.sleep(20)