forked from community/product-iots
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
121 lines
3.8 KiB
121 lines
3.8 KiB
#include "ArduinoBoardSketch.h"
|
|
|
|
/**********************************************************************************************
|
|
This method will traverse the array of digital pins and batch the data from the those pins together.
|
|
It makes a single call to the server and sends all pin values as a batch.
|
|
Server dis-assembles it accordingly and makes multiple publish calls for each sensor type.
|
|
***********************************************************************************************/
|
|
|
|
void pushData(){
|
|
String payLoad = "Data";
|
|
payLoad = payLoad + "\",\"value\":\"";
|
|
|
|
|
|
payLoad+=cpuTemperature;
|
|
|
|
|
|
payLoad += "\"}";
|
|
|
|
client.fastrprint(F("POST "));
|
|
client.fastrprint(SERVICE_EPOINT); client.fastrprint(F("pushdata"));
|
|
client.fastrprint(F(" HTTP/1.1")); client.fastrprint(F("\n"));
|
|
client.fastrprint(host.c_str()); client.fastrprint(F("\n"));
|
|
client.fastrprint(F("Content-Type: application/json")); client.fastrprint(F("\n"));
|
|
client.fastrprint(F("Content-Length: "));
|
|
|
|
int payLength = jsonPayLoad.length() + payLoad.length();
|
|
|
|
client.fastrprint(String(payLength).c_str()); client.fastrprint(F("\n"));
|
|
client.fastrprint(F("\n"));
|
|
|
|
if(DEBUG) {
|
|
Serial.print("POST ");
|
|
Serial.print(SERVICE_EPOINT); Serial.print("pushdata");
|
|
Serial.print(" HTTP/1.1"); Serial.println();
|
|
Serial.print(host); Serial.println();
|
|
Serial.print("Content-Type: application/json"); Serial.println();
|
|
Serial.print("Content-Length: ");
|
|
Serial.print(payLength); Serial.println();
|
|
Serial.println();
|
|
}
|
|
|
|
|
|
int chunkSize = 50;
|
|
|
|
for (int i = 0; i < jsonPayLoad.length(); i++) {
|
|
if ( (i+1)*chunkSize > jsonPayLoad.length()) {
|
|
client.print(jsonPayLoad.substring(i*chunkSize, jsonPayLoad.length()));
|
|
if(DEBUG) Serial.print(jsonPayLoad.substring(i*chunkSize, jsonPayLoad.length()));
|
|
i = jsonPayLoad.length();
|
|
} else {
|
|
client.print(jsonPayLoad.substring(i*chunkSize, (i+1)*chunkSize));
|
|
if(DEBUG) Serial.print(jsonPayLoad.substring(i*chunkSize, (i+1)*chunkSize));
|
|
}
|
|
}
|
|
|
|
for (int i = 0; i < payLoad.length(); i++) {
|
|
if ( (i+1)*chunkSize > payLoad.length()) {
|
|
client.print(payLoad.substring(i*chunkSize, payLoad.length()));
|
|
if(DEBUG) Serial.print(payLoad.substring(i*chunkSize, payLoad.length()));
|
|
i = payLoad.length();
|
|
} else {
|
|
client.print(payLoad.substring(i*chunkSize, (i+1)*chunkSize));
|
|
if(DEBUG) Serial.print(payLoad.substring(i*chunkSize, (i+1)*chunkSize));
|
|
}
|
|
}
|
|
|
|
client.fastrprint(F("\n"));
|
|
if(DEBUG) Serial.println();
|
|
|
|
delay(1000);
|
|
|
|
|
|
while (client.available()) {
|
|
char response = client.read();
|
|
if(DEBUG) Serial.print(response);
|
|
}
|
|
|
|
|
|
if(DEBUG) {
|
|
Serial.println();
|
|
Serial.println("-------------------------------");
|
|
}
|
|
|
|
payLoad = "";
|
|
}
|
|
|
|
|
|
|
|
|
|
double getBoardTemp(void)
|
|
{
|
|
unsigned int wADC;
|
|
double t;
|
|
|
|
// The internal temperature has to be used
|
|
// with the internal reference of 1.1V.
|
|
// Channel 8 can not be selected with
|
|
// the analogRead function yet.
|
|
|
|
// Set the internal reference and mux.
|
|
ADMUX = (_BV(REFS1) | _BV(REFS0) | _BV(MUX3));
|
|
ADCSRA |= _BV(ADEN); // enable the ADC
|
|
|
|
delay(20); // wait for voltages to become stable.
|
|
|
|
ADCSRA |= _BV(ADSC); // Start the ADC
|
|
|
|
// Detect end-of-conversion
|
|
while (bit_is_set(ADCSRA,ADSC));
|
|
|
|
// Reading register "ADCW" takes care of how to read ADCL and ADCH.
|
|
wADC = ADCW;
|
|
|
|
// The offset of 324.31 could be wrong. It is just an indication.
|
|
t = (wADC - 324.31 ) / 1.22;
|
|
|
|
// The returned temperature is in degrees Celcius.
|
|
return (t);
|
|
}
|
|
|