apps/MQTTSN-C-Client/src/application.c - paho/org.eclipse.paho.mqtt-sn.apps - Git at Google

 /*******************************************************************************
  * Copyright (c) 2008, 2013 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:
  *    Ian Craggs - initial API and implementation and/or initial documentation
  *******************************************************************************/

 /**
  * Description : MQTT-SN application template
  *
  */


 #include <stdlib.h>
 #include <stdio.h>

 #include "mqttsn/mqtts_api.h"
 #include "mqttsn/gp_api.h"


 static mqtts_CONNECT_Parms conn_p;
 static mqtts_REGISTER_Parms reg_p;
 static mqtts_PUBLISH_Parms pub_p;
 static mqtts_SUBSCRIBE_Parms sub_p;
 static mqtts_UNSUBSCRIBE_Parms usub_p;

 /* Codes and functions that are inside an (#if MQTTS_DEBUG, #endif)-block are
  * optional. They could e.g. used to exchange debug information with
  * the hw device via a serial port
  */
 /**** function prototype */
 void appInit(void);

 /**
  * Programming model: appRun() will be called regularly by the operating system
  * (e.g. by a round-robin scheduler) of the hw device
  **/
 void appRun(void) {
 	static unsigned char initiated=0;
 	// init app only once
 	if (initiated==0) {
 		initiated=1;
 		appInit();
 	} else {
 		/* define here what app has to do regularly */
 	}
 }


 /**
  * Initialization: start mqtts client and ask it to connect to a gw
  */

 void appInit(void) {

 	/* CONNECT parameters */
 	conn_p.flagCleanSession=0;
 	conn_p.flagWill =0;
 	conn_p.flagWillQOS=0;
 	conn_p.flagWillRetain=0;

 	conn_p.flpProtocolID=0x01;
 	conn_p.flpDuration[0] = 0;   /* Keep Alive Timer MostSignificantByte */
 	conn_p.flpDuration[1] = 15;  /* Keep Alive Timer LSB = 15 sec */

 	conn_p.vlpClientID = (unsigned char *)"mqttsSampleAppl";
 	conn_p.vlpClientID_length = 15;

 	conn_p.vlpWillMsg = NULL;
 	conn_p.vlpWillMsg_length = 0;
 	conn_p.vlpWillTopic = NULL;
 	conn_p.vlpWillTopic_length = 0;

 	/* start mqtts and ask it to connect to a gw */
 	mqtts_startStack();
 	if (mqtts_connect(&conn_p)!= MQTTS_OK) {
 #if MQTTS_DEBUG
 		gp_debug((unsigned char*)"connect error\r\n",15);
 #endif
 	}

 }

 #if MQTTS_DEBUG
 /**
  * appHandleCmd() could be called e.g. when a character is typed in a terminal
  * and sent to the hw device via a serial port.
  * Its aim is to demonstrate the capabilities of mqtts, e.g
  *     requesting the sending of a REGISTER message
  *     requesting the sending of a PUBLISH message
  *     etc.
  */
 void appHandleCmd(unsigned char cmd) {  //cmd: character typed in terminal

 	switch(cmd) {
 	case '\r':
 	case '\n':
 		gp_debug((unsigned char*)"sample app\r\n", 12);
 		break;

 	case 'a':
 		gp_debug((unsigned char*)"start stack\r\n",13);
 		mqtts_startStack();
 		break;

 	case 't':
 		gp_debug((unsigned char*)"stop stack\r\n",12);
 		mqtts_stopStack();
 		break;

 	case 'c':       /* ask mqtts to connect to a gw */
 		if (mqtts_connect(&conn_p)== MQTTS_OK) {
 			gp_debug((unsigned char*)"waiting for ready\r\n",19);
 		} else {
 			gp_debug((unsigned char*)"connect error!\r\n",16);
 		}
 		break;

 	case 'd':
 		gp_debug((unsigned char*)"sending disconnect ... \r\n",25);
 		if (mqtts_disconnect()!=MQTTS_OK) {
 			gp_debug((unsigned char*)"disc error!\r\n",13);
 		}
 		break;

 	case 'r':
 		gp_debug((unsigned char*)"send REGISTER, topic: wsn/data\r\n",32);
 		reg_p.vlpTopic = (unsigned char *)"wsn/data";
 		reg_p.vlpTopic_length = 8;
 		mqtts_register(&reg_p);
 		break;

 	case 'p':
 		gp_debug((unsigned char*)"send PUBLISH \"PUB QoS 0\" with QoS 0\r\n",37);
 		pub_p.flagQOS = 0;
 		pub_p.flagRetain = 0;
 		pub_p.flagTopicIdType = 0;
 		pub_p.vlpData = (unsigned char *)"PUB QoS 0";
 		pub_p.vlpData_length = 5;
 		mqtts_publish(&pub_p);
 		break;

 	case 'q':
 		gp_debug((unsigned char*)"send PUBLISH \"PUB QoS 1\" with QoS 1\r\n",37);
 		pub_p.flagQOS = 1;
 		pub_p.vlpData = (unsigned char *)"PUB QoS 1";
 		pub_p.vlpData_length = 5;
 		mqtts_publish(&pub_p);
 		break;

 	case 's':
 		gp_debug((unsigned char*)"send SUBSCRIBE to topic: wsn/cmd\r\n",34);
 		sub_p.flagQOS = 0;
 		sub_p.flagTopicIdType = 0;
 		sub_p.vlpTopic = (unsigned char *)"wsn/cmd";
 		sub_p.vlpTopic_length = 7;
 		mqtts_subscribe(&sub_p);
 		break;

 	case 'u':
 		gp_debug((unsigned char*)"send UNSUBSCRIBE topic: wsn/cmd\r\n",33);
 		usub_p.flagTopicIdType= 0;
 		usub_p.vlpTopic= (unsigned char *)"wsn/cmd";
 		usub_p.vlpTopic_length = 7;
 		mqtts_unsubscribe(&usub_p);
 		break;

 	default:
 		gp_debug((unsigned char*)"unknown cmd\r\n",13);
 	}

 }
 #endif

 /*****************************************************
  * mqtts callback functions
  *****************************************************/

 /**
  * CONNECT sent to gw, client is waiting for answer from gw */
 void mqttscb_connect_sent(void)
 {
 #if MQTTS_DEBUG
 	gp_debug((unsigned char*)"CONNECT sent\r\n",14);
 #endif
 }

 /**
  * client is now connected to a gw, app can now start publishing, ... */
 void mqttscb_connected(void)
 {
 #if MQTTS_DEBUG
 	gp_debug((unsigned char*)"connected\r\n",11);
 #endif
 }

 /**
  * client is disconnected, app has to call mqtts_connect() again */
 void mqttscb_disconnected(unsigned char returnCode)
 {
 #if MQTTS_DEBUG
 	gp_debug((unsigned char*)"disconnected\r\n",15);
 #endif
 }

 /**
  * REGACK received, app can now use topic id for publishing */
 void mqttscb_regack_received(
 		unsigned char topicID_1,
 		unsigned char topicID_2,
 		unsigned char returnCode)
 {
 #if MQTTS_DEBUG
 	gp_debug((unsigned char*)"REGACK received\r\n",17);
 #endif

 	pub_p.flpTopicID[0] = topicID_1;
 	pub_p.flpTopicID[1] = topicID_2;

 }

 /**
  * PUBLISH received from gw/broker */
 unsigned char mqttscb_publish_received(
 		unsigned char dup,
 		unsigned char qos,
 		unsigned char topicID_0,    /* Topic ID[0] */
 		unsigned char topicID_1,    /* Topic ID[1] */
 		unsigned char *data,
 		unsigned char data_len)
 {
 #if MQTTS_DEBUG
 	gp_debug((unsigned char*)"PUBLISH received\r\n",18);
 #endif
 	return 0;
 }

 /**
  * PUBACK received, only for PUBLISH with QoS 1 */
 void mqttscb_puback_received(
 		unsigned char topicId_0,
 		unsigned char topicId_1,
 		unsigned char returnCode)
 {
 #if MQTTS_DEBUG
 	gp_debug((unsigned char*)"PUBACK received\r\n",17);
 #endif
 }

 /**
  * PUBCOMP received, only for PUBLISH with QoS 2 */
 void mqttscb_pubcomp_received()
 {
 #if MQTTS_DEBUG
 	gp_debug((unsigned char*)"PUBCOMP received\r\n",18);
 #endif
 }

 /**
  * SUBACK received */
 void mqttscb_suback_received(
 		unsigned char qos,
 		unsigned char topicID_1,
 		unsigned char topicID_2,
 		unsigned char returnCode)
 {
 #if MQTTS_DEBUG
 	gp_debug((unsigned char*)"SUBACK received\r\n",17);
 #endif
 }

 /**
  * UNSUBACK received */
 void mqttscb_unsuback_received()
 {
 #if MQTTS_DEBUG
 	gp_debug((unsigned char*)"UNSUBACK received\r\n",19);
 #endif
 }

 /**
  * REGISTER received */
 void mqttscb_register_received(
 		unsigned char topicID_0, /* Topic ID[0] */
 		unsigned char topicID_1, /* Topic ID[1] */
 		unsigned char *topic,
 		unsigned char topic_len)
 {
 #if MQTTS_DEBUG
 	gp_debug((unsigned char*)"REGISTER received\r\n",19);
 #endif
 }

 /**
  * WILLTOPICRESP received */
 void mqttscb_willtopicresp_received() {

 }


 /**
  * WILLMSGRESP received */
 void mqttscb_willmsgresp_received() {

 }

 /***********************************************
  *
  * END OF FILE
  *
  */
	/*******************************************************************************
	* Copyright (c) 2008, 2013 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:
	* Ian Craggs - initial API and implementation and/or initial documentation
	*******************************************************************************/

	/**
	* Description : MQTT-SN application template
	*
	*/


	#include <stdlib.h>
	#include <stdio.h>

	#include "mqttsn/mqtts_api.h"
	#include "mqttsn/gp_api.h"



	static mqtts_CONNECT_Parms conn_p;
	static mqtts_REGISTER_Parms reg_p;
	static mqtts_PUBLISH_Parms pub_p;
	static mqtts_SUBSCRIBE_Parms sub_p;
	static mqtts_UNSUBSCRIBE_Parms usub_p;

	/* Codes and functions that are inside an (#if MQTTS_DEBUG, #endif)-block are
	* optional. They could e.g. used to exchange debug information with
	* the hw device via a serial port
	*/
	/**** function prototype */
	void appInit(void);

	/**
	* Programming model: appRun() will be called regularly by the operating system
	* (e.g. by a round-robin scheduler) of the hw device
	**/
	void appRun(void) {
	static unsigned char initiated=0;
	// init app only once
	if (initiated==0) {
	initiated=1;
	appInit();
	} else {
	/* define here what app has to do regularly */
	}
	}


	/**
	* Initialization: start mqtts client and ask it to connect to a gw
	*/

	void appInit(void) {

	/* CONNECT parameters */
	conn_p.flagCleanSession=0;
	conn_p.flagWill =0;
	conn_p.flagWillQOS=0;
	conn_p.flagWillRetain=0;

	conn_p.flpProtocolID=0x01;
	conn_p.flpDuration[0] = 0; /* Keep Alive Timer MostSignificantByte */
	conn_p.flpDuration[1] = 15; /* Keep Alive Timer LSB = 15 sec */

	conn_p.vlpClientID = (unsigned char *)"mqttsSampleAppl";
	conn_p.vlpClientID_length = 15;

	conn_p.vlpWillMsg = NULL;
	conn_p.vlpWillMsg_length = 0;
	conn_p.vlpWillTopic = NULL;
	conn_p.vlpWillTopic_length = 0;

	/* start mqtts and ask it to connect to a gw */
	mqtts_startStack();
	if (mqtts_connect(&conn_p)!= MQTTS_OK) {
	#if MQTTS_DEBUG
	gp_debug((unsigned char*)"connect error\r\n",15);
	#endif
	}

	}

	#if MQTTS_DEBUG
	/**
	* appHandleCmd() could be called e.g. when a character is typed in a terminal
	* and sent to the hw device via a serial port.
	* Its aim is to demonstrate the capabilities of mqtts, e.g
	* requesting the sending of a REGISTER message
	* requesting the sending of a PUBLISH message
	* etc.
	*/
	void appHandleCmd(unsigned char cmd) { //cmd: character typed in terminal

	switch(cmd) {
	case '\r':
	case '\n':
	gp_debug((unsigned char*)"sample app\r\n", 12);
	break;

	case 'a':
	gp_debug((unsigned char*)"start stack\r\n",13);
	mqtts_startStack();
	break;

	case 't':
	gp_debug((unsigned char*)"stop stack\r\n",12);
	mqtts_stopStack();
	break;

	case 'c': /* ask mqtts to connect to a gw */
	if (mqtts_connect(&conn_p)== MQTTS_OK) {
	gp_debug((unsigned char*)"waiting for ready\r\n",19);
	} else {
	gp_debug((unsigned char*)"connect error!\r\n",16);
	}
	break;

	case 'd':
	gp_debug((unsigned char*)"sending disconnect ... \r\n",25);
	if (mqtts_disconnect()!=MQTTS_OK) {
	gp_debug((unsigned char*)"disc error!\r\n",13);
	}
	break;

	case 'r':
	gp_debug((unsigned char*)"send REGISTER, topic: wsn/data\r\n",32);
	reg_p.vlpTopic = (unsigned char *)"wsn/data";
	reg_p.vlpTopic_length = 8;
	mqtts_register(&reg_p);
	break;

	case 'p':
	gp_debug((unsigned char*)"send PUBLISH \"PUB QoS 0\" with QoS 0\r\n",37);
	pub_p.flagQOS = 0;
	pub_p.flagRetain = 0;
	pub_p.flagTopicIdType = 0;
	pub_p.vlpData = (unsigned char *)"PUB QoS 0";
	pub_p.vlpData_length = 5;
	mqtts_publish(&pub_p);
	break;

	case 'q':
	gp_debug((unsigned char*)"send PUBLISH \"PUB QoS 1\" with QoS 1\r\n",37);
	pub_p.flagQOS = 1;
	pub_p.vlpData = (unsigned char *)"PUB QoS 1";
	pub_p.vlpData_length = 5;
	mqtts_publish(&pub_p);
	break;

	case 's':
	gp_debug((unsigned char*)"send SUBSCRIBE to topic: wsn/cmd\r\n",34);
	sub_p.flagQOS = 0;
	sub_p.flagTopicIdType = 0;
	sub_p.vlpTopic = (unsigned char *)"wsn/cmd";
	sub_p.vlpTopic_length = 7;
	mqtts_subscribe(&sub_p);
	break;

	case 'u':
	gp_debug((unsigned char*)"send UNSUBSCRIBE topic: wsn/cmd\r\n",33);
	usub_p.flagTopicIdType= 0;
	usub_p.vlpTopic= (unsigned char *)"wsn/cmd";
	usub_p.vlpTopic_length = 7;
	mqtts_unsubscribe(&usub_p);
	break;

	default:
	gp_debug((unsigned char*)"unknown cmd\r\n",13);
	}

	}
	#endif

	/*****************************************************
	* mqtts callback functions
	*****************************************************/

	/**
	* CONNECT sent to gw, client is waiting for answer from gw */
	void mqttscb_connect_sent(void)
	{
	#if MQTTS_DEBUG
	gp_debug((unsigned char*)"CONNECT sent\r\n",14);
	#endif
	}

	/**
	* client is now connected to a gw, app can now start publishing, ... */
	void mqttscb_connected(void)
	{
	#if MQTTS_DEBUG
	gp_debug((unsigned char*)"connected\r\n",11);
	#endif
	}

	/**
	* client is disconnected, app has to call mqtts_connect() again */
	void mqttscb_disconnected(unsigned char returnCode)
	{
	#if MQTTS_DEBUG
	gp_debug((unsigned char*)"disconnected\r\n",15);
	#endif
	}

	/**
	* REGACK received, app can now use topic id for publishing */
	void mqttscb_regack_received(
	unsigned char topicID_1,
	unsigned char topicID_2,
	unsigned char returnCode)
	{
	#if MQTTS_DEBUG
	gp_debug((unsigned char*)"REGACK received\r\n",17);
	#endif

	pub_p.flpTopicID[0] = topicID_1;
	pub_p.flpTopicID[1] = topicID_2;

	}

	/**
	* PUBLISH received from gw/broker */
	unsigned char mqttscb_publish_received(
	unsigned char dup,
	unsigned char qos,
	unsigned char topicID_0, /* Topic ID[0] */
	unsigned char topicID_1, /* Topic ID[1] */
	unsigned char *data,
	unsigned char data_len)
	{
	#if MQTTS_DEBUG
	gp_debug((unsigned char*)"PUBLISH received\r\n",18);
	#endif
	return 0;
	}

	/**
	* PUBACK received, only for PUBLISH with QoS 1 */
	void mqttscb_puback_received(
	unsigned char topicId_0,
	unsigned char topicId_1,
	unsigned char returnCode)
	{
	#if MQTTS_DEBUG
	gp_debug((unsigned char*)"PUBACK received\r\n",17);
	#endif
	}

	/**
	* PUBCOMP received, only for PUBLISH with QoS 2 */
	void mqttscb_pubcomp_received()
	{
	#if MQTTS_DEBUG
	gp_debug((unsigned char*)"PUBCOMP received\r\n",18);
	#endif
	}

	/**
	* SUBACK received */
	void mqttscb_suback_received(
	unsigned char qos,
	unsigned char topicID_1,
	unsigned char topicID_2,
	unsigned char returnCode)
	{
	#if MQTTS_DEBUG
	gp_debug((unsigned char*)"SUBACK received\r\n",17);
	#endif
	}

	/**
	* UNSUBACK received */
	void mqttscb_unsuback_received()
	{
	#if MQTTS_DEBUG
	gp_debug((unsigned char*)"UNSUBACK received\r\n",19);
	#endif
	}

	/**
	* REGISTER received */
	void mqttscb_register_received(
	unsigned char topicID_0, /* Topic ID[0] */
	unsigned char topicID_1, /* Topic ID[1] */
	unsigned char *topic,
	unsigned char topic_len)
	{
	#if MQTTS_DEBUG
	gp_debug((unsigned char*)"REGISTER received\r\n",19);
	#endif
	}

	/**
	* WILLTOPICRESP received */
	void mqttscb_willtopicresp_received() {

	}


	/**
	* WILLMSGRESP received */
	void mqttscb_willmsgresp_received() {

	}

	/***********************************************
	*
	* END OF FILE
	*
	*/