diff options
Diffstat (limited to 'apps/MQTTSN-C-Client/src/application.c')
| -rw-r--r-- | apps/MQTTSN-C-Client/src/application.c | 322 |
1 files changed, 322 insertions, 0 deletions
diff --git a/apps/MQTTSN-C-Client/src/application.c b/apps/MQTTSN-C-Client/src/application.c new file mode 100644 index 0000000..f3e48de --- /dev/null +++ b/apps/MQTTSN-C-Client/src/application.c @@ -0,0 +1,322 @@ +/******************************************************************************* + * 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(®_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 + * + */ + |