152 lines
4.6 KiB
C
152 lines
4.6 KiB
C
/*
|
|
* Tencent is pleased to support the open source community by making IoT Hub available.
|
|
* Copyright (C) 2016 THL A29 Limited, a Tencent company. All rights reserved.
|
|
|
|
* Licensed under the MIT License (the "License"); you may not use this file except in
|
|
* compliance with the License. You may obtain a copy of the License at
|
|
* http://opensource.org/licenses/MIT
|
|
|
|
* Unless required by applicable law or agreed to in writing, software distributed under the License is
|
|
* distributed on an "AS IS" basis, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
|
|
* either express or implied. See the License for the specific language governing permissions and
|
|
* limitations under the License.
|
|
*
|
|
*/
|
|
|
|
#include "tos.h"
|
|
#include "qcloud.h"
|
|
|
|
static void response_message_callback(void *msg, void *context)
|
|
{
|
|
int ret = -1;
|
|
char* payload = NULL;
|
|
int payload_len = 0;
|
|
coap_event_type_t event_type;
|
|
coap_message_t *message = NULL;
|
|
|
|
message = msg;
|
|
event_type = qcloud_coap_event_type_get(message);
|
|
|
|
switch (event_type) {
|
|
case COAP_EVENT_TYPE_RECEIVE_ACK:
|
|
QCLOUD_LOG_I("message received ACK, msgid: %d", qcloud_coap_msg_id_get(message));
|
|
break;
|
|
|
|
case COAP_EVENT_TYPE_RECEIVE_RESPCONTENT:
|
|
ret = qcloud_coap_msg_payload_get(message, &payload, &payload_len);
|
|
if (ret == QCLOUD_ERR_SUCCESS) {
|
|
QCLOUD_LOG_I("message received response, len: %d content: %s", payload_len, payload);
|
|
} else {
|
|
QCLOUD_LOG_E("message received response, content error.");
|
|
}
|
|
break;
|
|
|
|
case COAP_EVENT_TYPE_UNAUTHORIZED:
|
|
QCLOUD_LOG_I("coap client auth token expired or invalid, msgid: %d", qcloud_coap_msg_id_get(message));
|
|
break;
|
|
|
|
case COAP_EVENT_TYPE_FORBIDDEN:
|
|
QCLOUD_LOG_I("coap URI is invalid for this device, msgid: %d", qcloud_coap_msg_id_get(message));
|
|
break;
|
|
|
|
case COAP_EVENT_TYPE_INTERNAL_SERVER_ERROR:
|
|
QCLOUD_LOG_I("coap server internal error, msgid: %d", qcloud_coap_msg_id_get(message));
|
|
break;
|
|
|
|
case COAP_EVENT_TYPE_ACK_TIMEOUT:
|
|
QCLOUD_LOG_I("message receive ACK timeout, msgid: %d", qcloud_coap_msg_id_get(message));
|
|
break;
|
|
|
|
case COAP_EVENT_TYPE_SEPRESP_TIMEOUT:
|
|
QCLOUD_LOG_I("message received ACK but receive response timeout, msgid: %d", qcloud_coap_msg_id_get(message));
|
|
break;
|
|
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
|
|
static void event_handler(void *context, coap_event_t *event)
|
|
{
|
|
switch (event->type) {
|
|
case COAP_EVENT_TYPE_RECEIVE_ACK:
|
|
QCLOUD_LOG_I("message received ACK, msgid: %d", *(uint16_t *)event->message);
|
|
break;
|
|
|
|
case COAP_EVENT_TYPE_RECEIVE_RESPCONTENT:
|
|
QCLOUD_LOG_I("message received response, content: %s", qcloud_coap_msg_id_get(event->message));
|
|
break;
|
|
|
|
case COAP_EVENT_TYPE_UNAUTHORIZED:
|
|
QCLOUD_LOG_I("coap client auth token expired or invalid, msgid: %d", *(uint16_t *)event->message);
|
|
break;
|
|
|
|
case COAP_EVENT_TYPE_FORBIDDEN:
|
|
QCLOUD_LOG_I("coap URI is invalid for this device, msgid: %d", *(uint16_t *)event->message);
|
|
break;
|
|
|
|
case COAP_EVENT_TYPE_INTERNAL_SERVER_ERROR:
|
|
QCLOUD_LOG_I("coap server internal error, msgid: %d", *(uint16_t *)event->message);
|
|
break;
|
|
|
|
case COAP_EVENT_TYPE_ACK_TIMEOUT:
|
|
QCLOUD_LOG_I("message receive ACK timeout, msgid: %d", *(uint16_t *)event->message);
|
|
break;
|
|
|
|
case COAP_EVENT_TYPE_SEPRESP_TIMEOUT:
|
|
QCLOUD_LOG_I("message received ACK but receive response timeout, msgid: %d", *(uint16_t *)event->message);
|
|
break;
|
|
|
|
default:
|
|
QCLOUD_LOG_E("unrecogonized event type: %d", event->type);
|
|
break;
|
|
}
|
|
}
|
|
|
|
qcloud_device_t device;
|
|
qcloud_coap_client_t client;
|
|
|
|
int coap_thread(void)
|
|
{
|
|
char topic[128];
|
|
qcloud_err_t rc;
|
|
coap_send_opt_t send_opt;
|
|
|
|
qcloud_device_create(&device, "ABU45A5KT8", "dev001", "RPpqUxL03frSDSufVhjuLw==");
|
|
|
|
qcloud_coap_client_create(&client, &device, event_handler);
|
|
|
|
qcloud_coap_client_connect(&client);
|
|
|
|
do {
|
|
memset(&send_opt, 0, sizeof(coap_send_opt_t));
|
|
send_opt.payload = "{\"name\":\"hello world\"}";
|
|
send_opt.payload_len = strlen("{\"name\":\"hello world\"}");
|
|
send_opt.resp_cb = response_message_callback;
|
|
|
|
sprintf(topic, "%s/%s/data", device.product_id, device.device_name);
|
|
QCLOUD_LOG_I("topic: %s", topic);
|
|
|
|
rc = qcloud_coap_client_msg_send(&client, topic, &send_opt);
|
|
if (rc != QCLOUD_ERR_SUCCESS) {
|
|
QCLOUD_LOG_E("client publish topic failed :%d.", rc);
|
|
} else {
|
|
QCLOUD_LOG_D("client topic has been sent, msg_id: %d", rc);
|
|
}
|
|
|
|
rc = qcloud_coap_client_yield(&client, 200);
|
|
|
|
if (rc != QCLOUD_ERR_SUCCESS){
|
|
QCLOUD_LOG_E("exit with error: %d", rc);
|
|
break;
|
|
}
|
|
|
|
osal_sleep_ms(4000);
|
|
} while (1);
|
|
|
|
qcloud_coap_client_destroy(&client);
|
|
|
|
return 1;
|
|
}
|
|
|