Suraj Pal
ATT example code
Dependencies: WNCInterface mbed-rtos mbed
Diff: main.cpp
- Revision:
- 0:2bfa06d10e28
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/main.cpp Mon May 22 19:50:26 2017 +0000
@@ -0,0 +1,312 @@
+#include "mbed.h"
+#include "MQTTClient.h"
+#include "MQTTFormat.h"
+#include "MQTTWNCInterface.h"
+#include "rtos.h"
+#include "k64f.h"
+#include "HTS221.h"
+#include "MODSERIAL.h"
+
+I2C i2c(PTC11, PTC10); //SDA, SCL -- define the I2C pins being used
+MODSERIAL pc(USBTX, USBRX);
+MODSERIAL pump(PTC15, PTC14);//TX, RX to connect pump
+
+#include "hardware.h"
+/*
+#define ORG_ID "44a8w4"
+#define DEVICE_TYPE "IoT-Moog-1"
+#define DEVICE_NAME "IoT-Moog-Device1"
+#define USERNAME "use-token-auth"
+#define PASSWORD "ih*SKz2AyUSt+I*L0N"
+*/
+
+#define ORG_ID "hpy42p"
+#define DEVICE_TYPE "PumpTest"
+#define DEVICE_NAME "SomethingOtherThanPumpTest"
+#define USERNAME "use-token-auth"
+#define PASSWORD "SLD21utaPZP7TE8Vgk"
+
+#define URL ORG_ID ".messaging.internetofthings.ibmcloud.com"
+#define CLIENTSTR "d:" ORG_ID ":" DEVICE_TYPE ":%s"
+
+#define PORT 1883 // MQTT broker port number
+#define PUBLISH_TOPIC "iot-2/evt/status/fmt/json" // MQTT topic
+#define SUBSCRIBTOPIC "iot-2/cmd/+/fmt/+"
+/// Largest msg possible is 111 bytes - header, 99 data bytes, CheckSum, LF/CR
+#define PDMS_MAX_COMMAND_SIZE 111
+Thread serial_thread;
+volatile int key_reader =0;
+volatile int old_Key =0;
+char command_str[PDMS_MAX_COMMAND_SIZE];
+unsigned char AIL_Enable=0;
+Queue<uint32_t, 6> messageQ;
+
+// LED color control function
+void controlLED(color_t led_color) {
+ switch(led_color) {
+ case red :
+ greenLED = blueLED = 1;
+ redLED = 0.7;
+ break;
+ case green :
+ redLED = blueLED = 1;
+ greenLED = 0.7;
+ break;
+ case blue :
+ redLED = greenLED = 1;
+ blueLED = 0.7;
+ break;
+ case off :
+ redLED = greenLED = blueLED = 1;
+ break;
+ }
+}
+
+// Switch 2 interrupt handler
+void sw2_ISR(void) {
+ messageQ.put((uint32_t*)22);
+}
+
+// Switch3 interrupt handler
+void sw3_ISR(void) {
+ messageQ.put((uint32_t*)33);
+}
+
+// MQTT message arrived callback function
+void messageArrived(MQTT::MessageData& md) {
+ MQTT::Message &message = md.message;
+ PRINTF("Receiving MQTT message: %.*s\r\n", message.payloadlen, (char*)message.payload);
+
+ if (message.payloadlen == 3) {
+ if (strncmp((char*)message.payload, "red", 3) == 0)
+ controlLED(red);
+
+ else if(strncmp((char*)message.payload, "grn", 3) == 0)
+ controlLED(green);
+
+ else if(strncmp((char*)message.payload, "blu", 3) == 0)
+ controlLED(blue);
+
+ else if(strncmp((char*)message.payload, "off", 3) == 0)
+ controlLED(off);
+ }
+}
+
+void alla_serial()
+{
+ printf("Enter Thread alla_serial");
+ while(1)
+ {
+ memset(command_str, 0x00,PDMS_MAX_COMMAND_SIZE);
+ pump.gets(command_str, PDMS_MAX_COMMAND_SIZE);
+ printf("%s", command_str); //print data received from Pump
+ if(strstr(command_str, "Standby"))
+ {
+ key_reader=8;
+ }
+ else if(strstr(command_str, "Paused"))
+ {
+ if(AIL_Enable == 0)
+ key_reader=1;
+ else
+ AIL_Enable--;
+ }
+ else if(strstr(command_str, "AIR IN LINE"))
+ {
+ key_reader=2;
+ AIL_Enable=2;
+ }
+ else if(strstr(command_str, "Run Interval"))
+ {
+ key_reader=3;
+ }
+ else if(strstr(command_str, "Run Continous"))
+ {
+ key_reader=4;
+ }
+ else if(strstr(command_str, "DOOR OPEN"))
+ {
+ key_reader=5;
+ AIL_Enable=2;
+ }
+ else if(strstr(command_str, "Priming"))
+ {
+ key_reader=6;
+ }
+ else if(strstr(command_str, "PUMP WAITING"))
+ {
+ key_reader=7;
+ }
+ else if(strstr(command_str, "Cleared"))
+ {
+ key_reader=9;
+ }
+ else
+ {
+ printf("\n %s", command_str);
+ }
+ }
+}
+int main() {
+//////////////////////////////////////////////////////
+ pump.baud(115200);
+ // pump.format(8, SerialBase::Even, 1);
+ serial_thread.start(&alla_serial);
+//////////////////////////////////////////////////////
+
+ int rc, pSW2=0, txSel=0, good = 0;
+ Timer tmr;
+ char* topic = PUBLISH_TOPIC;
+ char clientID[100], buf[100];
+ string st, uniqueID;
+
+ HTS221 hts221;
+
+ pc.baud(115200);
+ rc = hts221.init();
+ if ( rc ) {
+ PRINTF(BLU "HTS221 Detected (0x%02X)\n\r",rc);
+ PRINTF(" Temp is: %0.2f F \r\n Huumid is: %02d %%\r\n\r\n",
+ CTOF(hts221.readTemperature()), hts221.readHumidity()/10);
+ }
+ else {
+ PRINTF(RED "HTS221 NOT DETECTED!\n\r");
+ }
+
+ controlLED(green);
+
+ // set SW2 and SW3 to generate interrupt on falling edge
+ switch2.fall(&sw2_ISR);
+ switch3.fall(&sw3_ISR);
+
+ // initialize ethernet interface
+ MQTTwnc ipstack = MQTTwnc();
+
+ // get and display client network info
+ WNCInterface& eth = ipstack.getEth();
+
+ // construct the MQTT client
+ MQTT::Client<MQTTwnc, Countdown> client = MQTT::Client<MQTTwnc, Countdown>(ipstack);
+
+ controlLED(blue);
+
+ char* hostname = URL;
+ int port = PORT;
+ // uniqueID = "IoT-Moog-Device1"; //Guru Device
+ uniqueID = "SomethingOtherThanPumpTest"; // Suraj Device
+ sprintf(clientID, CLIENTSTR, uniqueID.c_str());
+
+ PRINTF("Local network info...\r\n");
+ PRINTF("IP address is %s\r\n", eth.getIPAddress());
+ PRINTF("MAC address is %s\r\n", eth.getMACAddress());
+ PRINTF("Gateway address is %s\r\n", eth.getGateway());
+ PRINTF("Your <uniqueID> is: %s\r\n", uniqueID.c_str());
+ PRINTF("---------------------------------------------------------------\r\n");
+
+ MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
+
+ int tries;
+
+ while( !good ) {
+
+ tries=0;
+ // connect to TCP socket and check return code
+ tmr.start();
+ rc = 1;
+ while( rc && tries < 3) {
+ PRINTF("\r\n\r\n(%d) Attempting TCP connect to %s:%d: ", tries++, hostname, port);
+ rc = ipstack.connect(hostname, port);
+ if( rc ) {
+ PRINTF("Failed (%d)!\r\n",rc);
+ while( tmr.read_ms() < 5000 ) ;
+ tmr.reset();
+ }
+ else {
+ PRINTF("Success!\r\n");
+ rc = 0;
+ }
+ }
+ if( tries < 3 )
+ tries = 0;
+ else
+ continue;
+
+ data.willFlag = 0;
+ data.MQTTVersion = 3;
+
+ data.clientID.cstring = clientID;
+ data.username.cstring = USERNAME;
+ data.password.cstring = PASSWORD;
+ data.keepAliveInterval = 10;
+ data.cleansession = 1;
+
+ rc = 1;
+ tmr.reset();
+ while( !client.isConnected() && rc && tries < 3) {
+ PRINTF("(%d) Attempting MQTT connect to '%s': ", tries++, clientID);
+ rc = client.connect(data);
+ if( rc ) {
+ PRINTF("Failed (%d)!\r\n",rc);
+ while( tmr.read_ms() < 5000 );
+ tmr.reset();
+ }
+ else
+ PRINTF("Success!\r\n");
+ }
+
+ if( tries < 3 )
+ tries = 0;
+ else
+ continue;
+
+ // subscribe to MQTT topic
+ tmr.reset();
+ rc = 1;
+ while( rc && client.isConnected() && tries < 3) {
+ PRINTF("(%d) Attempting to subscribing to MQTT topic '%s': ", tries, SUBSCRIBTOPIC);
+ rc = client.subscribe(SUBSCRIBTOPIC, MQTT::QOS0, messageArrived);
+ if( rc ) {
+ PRINTF("Failed (%d)!\r\n", rc);
+ while( tmr.read_ms() < 5000 );
+ tries++;
+ tmr.reset();
+ }
+ else {
+ good=1;
+ PRINTF("Subscribe successful!\r\n");
+ }
+ }
+ while (!good);
+ }
+
+ MQTT::Message message;
+ message.qos = MQTT::QOS0;
+ message.retained = false;
+ message.dup = false;
+ message.payload = (void*)buf;
+
+ while(true)
+ {
+ osEvent switchEvent = messageQ.get(100);
+ if(key_reader != old_Key)
+ {
+ old_Key = key_reader;
+ memset(buf,0x00,sizeof(buf));
+ //sprintf(buf, "{\"d\" : {\"Key\" : %d }}", key_reader);
+ sprintf(buf, "{\"Key\":\"%d\"}", key_reader);
+ PRINTF("Publishing MQTT message '%s' ", (char*)message.payload);
+ message.payloadlen = strlen(buf);
+ PRINTF("\n payloadlen:(%d)\r\n",message.payloadlen);
+ rc = client.publish(topic, message);
+ if( rc )
+ {
+ PRINTF("Publish request failed! (%d)\r\n",rc);
+ FATAL_WNC_ERROR(resume);
+ }
+ }
+ else
+ {
+ client.yield(1000);
+ }
+ }
+}