File content as of revision 3:e7b2f56c4f3f:

/*******************************************************************************
 * Copyright (c) 2015 IBM Corp.
 *
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * and Eclipse Distribution License v1.0 which accompany this distribution.
 *
 * The Eclipse Public License is available at
 *    http://www.eclipse.org/legal/epl-v10.html
 * and the Eclipse Distribution License is available at
 *   http://www.eclipse.org/org/documents/edl-v10.php.
 *
 * Contributors:
 *    Sathisumar Palaniappan - initial implementation
 *******************************************************************************/

#include "stdio.h"
#include "mbed.h"
#include "rtos.h"
#include "EthernetInterface.h"
#include "C12832.h"
#include "LM75B.h"
#include "MMA7660.h"
#include "Arial12x12.h"
#include "DeviceClient.h"
#include "Command.h"
#include "MQTTEthernet.h"

#include "MQTTClient.h"

#if defined(TARGET_UBLOX_C027)
#warning "Compiling for mbed C027"
#include "C027.h"
#elif defined(TARGET_LPC1768)
#warning "Compiling for mbed LPC1768"
#include "LPC1768.h"
#elif defined(TARGET_K64F)
#warning "Compiling for mbed K64F"
#include "K64F.h"
#endif

//LED
DigitalOut led1(LED1);

char *joystickPos;
void joystickThread(void const *args);
void processCommand(IoTF::Command &cmd);

int blink_interval = 0;
int main()
{
    lcd.cls();
    lcd.locate(0,0);
    
    lcd.set_font((unsigned char*) Arial12x12);  // Set a nice font for the LCD screen
    led2 = LED2_OFF; // K64F: turn off the main board LED 
    
    //Start thread to read data from joystick
    Thread jThd(joystickThread);
    joystickPos = "CENTRE";

    // Set IoT Foundation connection parameters
    char organization[11] = "quickstart";     // For a registered connection, replace with your org
    char deviceType[9] = "Sample";        // For a registered connection, replace with your device type
    char deviceId[15] = "";                  // For a registered connection, replace with your device id
    char method[6] = "token";               // Not required to change as IBM IoTF expects only "token" for now
    char token[9] = "password";             // For a registered connection, replace with your auth-token
    
    // Create DeviceClient
    IoTF::DeviceClient client(organization, deviceType, deviceId, method, token);
    
    // Get the DeviceID(MAC Address) if we are in quickstart mode and device id is not specified
    if((strcmp(organization, QUICKSTART) == 0) && (strcmp("", deviceId) == 0)) {
        char tmpBuf[50];
        client.getDeviceId(tmpBuf, sizeof(tmpBuf));
        lcd.printf("DeviceID: %s\n", tmpBuf);
        wait(10.0);
    }
    lcd.locate(0,10);
    lcd.printf("Initialized & connecting..\n");
    
    bool status = false;
    
    // keep on retrying till the connection is successful
    while(status == false) {
        status = client.connect();
        lcd.cls();
        lcd.locate(0,0);
        lcd.printf("connect status: %s\n", status?"true":"false");
        if(status == false) {
            lcd.printf("Retrying..\n");
        }
    }
    wait(1.0);
    client.setCommandCallback(processCommand);
      
    // Create buffer to hold the event
    char buf[250];
    int count = 0;
    
    while(1) {
        if (++count == 100) {
            lcd.cls();

            //Construct an event message with desired datapoints
            sprintf(buf,
            "{\"d\":{\"myName\":\"IoT mbed\",\"accelX\":%0.4f,\"accelY\":%0.4f,\"accelZ\":%0.4f,\"temp\":%0.4f,\"joystick\":\"%s\",\"potentiometer1\":%0.4f,\"potentiometer2\":%0.4f}}",
            MMA.x(), MMA.y(), MMA.z(), sensor.temp(), joystickPos, ain1.read(), ain2.read());
     
            //Message is converted from datapoints into json format and then published
            status = client.publishEvent("blink", buf);
           
            lcd.locate(0,0);
            lcd.printf("Publish status = %s",status?"true":"false");

            if(status == false) {
                // Check if connection is lost and retry 
                int re_count = 0;
                while(!client.isConnected()) {
                    lcd.cls();
                    lcd.locate(0,0);
                    lcd.printf("Reconnecting... %d", re_count++);
                    client.reConnect();
                    wait(5.0);
                }
            }
            count = 0;
        }
        if (blink_interval == 0)
            led2 = LED2_OFF;
        else if (count % blink_interval == 0)
            led2 = !led2;
        
        client.yield(10);  // allow the MQTT client to receive messages
    }
    client.disconnect();
}

void processCommand(IoTF::Command &cmd)
{
    LOG("Command received name: %s, payload: %s\n", cmd.getCommand(), cmd.getPayload());
    
    if (strcmp(cmd.getCommand(), "blink") == 0) {
        char *payload = cmd.getPayload();
        char* pos = strchr(payload, '}');
        
        if (pos != NULL) {
            *pos = '\0';
            char* ratepos = strstr(payload, "rate");
            if(ratepos == NULL) {
                return;
            }
            if ((pos = strchr(ratepos, ':')) != NULL)
            {
                int blink_rate = atoi(pos + 1);       
                blink_interval = (blink_rate <= 0) ? 0 : (blink_rate > 50 ? 1 : 50/blink_rate);
            }
        }
    } else {
        WARN("Unsupported command: %s\n", cmd.getCommand());
    }
    lcd.cls();
    lcd.locate(0,0);
    lcd.printf("blink interval = %d\n", blink_interval);
    wait(1.0);
}

void joystickThread(void const *args) {
    while (1) {
        if (Down)
            joystickPos = "DOWN";
        else if (Left)
            joystickPos = "LEFT";
        else if (Click)
            joystickPos = "CLICK";
        else if (Up)
            joystickPos = "UP";
        else if (Right)
            joystickPos = "RIGHT";
        else
            joystickPos = "CENTRE";
    }
}