#include "mbed.h"
#include "LSM9DS1.h"
#include "Servo.h"

// Initialize a pins to perform analog input and digital output fucntions

AnalogIn ain(p20);
AnalogIn waterStrip(p18);
DigitalOut dout(LED1);
Serial pc(USBTX, USBRX);
Servo myservo(p21);

int convertedTemp;
int intialTemp;
 
int main(void)
{
    LSM9DS1 imu(p9, p10, 0xD6, 0x3C);
    imu.begin();
    imu.calibrate();
    imu.readTemp();
    intialTemp = imu.temperature;
    while (1) {
        // test the voltage on the initialized analog pin
        //  and if greater than 0.3 * VCC set the digital pin
        //  to a logic 1 otherwise a logic 0
        if(ain > 0.3f) {
            dout = 1;
        } else {
            dout = 0;
        }
        imu.readTemp();//read temperature through IMU
        convertedTemp = -1*imu.temperature;//was plus180/2
        if(convertedTemp>80){
            myservo=.1;
        }else{
            myservo=0.0;
        }
        if(convertedTemp>98){ //imu extremely sensitive
            convertedTemp = 98;
        }
        // print the percentage and 16 bit normalized values
        pc.printf("light percentage: %3.3f%%\n", ain.read()*100.0f);
        //pc.printf("light normalized: 0x%04X \n", ain.read_u16());
        pc.printf("Waterstrip percentage: %3.3f%%\n", waterStrip.read()*100.0f);
        //pc.printf("Waterstrip normalized: 0x%04X \n", waterStrip.read_u16());
        pc.printf("Temperature: %d \n", convertedTemp); //if temperature above 85 fan is on activate fan (DC brushless motor)
        wait(1.0f);
    }
}

from AWSIoTPythonSDK.MQTTLib import AWSIoTMQTTClient
import logging
import time
import argparse
import json
import pigpio
import RPi.GPIO as GPIO
import serial
import time
from datetime import date, datetime

#if the user needs to use the pi gpio's
#servo_pin = 21     #initializing GPIO 21 for servo motor
#GPIO.setmode(GPIO.BCM)         #BCM pin numbering
#GPIO.setup(servo_pin, GPIO.OUT)   #GPIO 21 as output pin
#p = GPIO.PWM(servo_pin, 50)    #PWM channel at 50Hz freq
#p.start(2.5)
#pi=pigpio.pi()
#pi.set_mode(19, pigpio.INPUT)
#pi.set_pull_up_down(19, pigpio.PUD_DOWN)
#pi.set_mode(6, pigpio.INPUT)
#pi.set_pull_up_down(6,pigpio.PUD_DOWN)
#pi.set_mode(17, pigpio.OUTPUT)
#pi.set_mode(27, pigpio.OUTPUT)

host = "a3da8xngn5rj9t-ats.iot.us-east-2.amazonaws.com"
certPath = "/home/pi/demo/demo-cert/"
clientId = "sajith-pi-demo-publisher"
topic = "demo-topic"
payload3 = "tempPayload"
payload1 = "lightPayload"
payload2 = "waterPayload"

# Init AWSIoTMQTTClient
myAWSIoTMQTTClient = None
myAWSIoTMQTTClient = AWSIoTMQTTClient(clientId)
myAWSIoTMQTTClient.configureEndpoint(host, 8883)
myAWSIoTMQTTClient.configureCredentials("{}aws-root-cert.pem".format(certPath), "{}private-key.pem.key".format(certPath), "{}iot-cert.pem.crt".format(certPath))

# AWSIoTMQTTClient connection configuration
myAWSIoTMQTTClient.configureAutoReconnectBackoffTime(1, 32, 20)
myAWSIoTMQTTClient.configureOfflinePublishQueueing(-1)  # Infinite offline Publish queueing
myAWSIoTMQTTClient.configureDrainingFrequency(2)  # Draining: 2 Hz
myAWSIoTMQTTClient.configureConnectDisconnectTimeout(10)  # 10 sec
myAWSIoTMQTTClient.configureMQTTOperationTimeout(5)  # 5 sec
myAWSIoTMQTTClient.connect()

# Publish to the same topic in a loop forever
loopCount = 0
while True:
    device = serial.Serial('/dev/ttyACM0') #connect to the mbed through serial
    now = datetime.utcnow()
    current_time = now.strftime('%Y-%m-%dT%H:%M:%SZ') #save current time
   
    data = device.readline()
    data = data.decode("utf-8") #decode byte data into string
    print(data[18:22]) #test
    data = float(data[18:22]) #print only the value of the sensor
    #print(str(data) + '\n')
    message = {}
    message['Time'] = current_time
    message['Light'] = data
    #message['sequence'] = loopCount
    messageJson = json.dumps(message)
    myAWSIoTMQTTClient.publish(payload1, messageJson, 1) #send to aws
    print('Published topic %s: %s\n' % (payload1, messageJson))

    data = device.readline()
    data = data.decode("utf-8")
    data = float(data[23:27]) #save only the value of the number for formatting
    #print(str(data) + '\n')
    message = {}
    message['Time'] = current_time
    message['Water'] = data
    #message['sequence'] = loopCount
    messageJson = json.dumps(message)
    myAWSIoTMQTTClient.publish(payload2, messageJson, 1) #send to aws
    print('Published topic %s: %s\n' % (payload2, messageJson))
   
    data = device.readline()
    data = data.decode("utf-8")
    data = float(data[12:15]) #save only the value of the data for sql parsing
    #print(str(data) + '\n')
    message = {}
    message['Time'] = current_time
    message['Temperature'] = data
    #message['sequence'] = loopCount
    messageJson = json.dumps(message)
    myAWSIoTMQTTClient.publish(payload3, messageJson, 1) #send to aws
    print('Published topic %s: %s\n' % (payload3, messageJson))
   
    loopCount += 1
    time.sleep(10) #wait 10 seconds to poll info again to not spam the email
myAWSIoTMQTTClient.disconnect()