EC600G/components/ql-application/qcloud-iot/samples/gateway/gateway_sample.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 <limits.h>
#include <stdbool.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

#include "ql_api_osi.h"

#include "qcloud_iot_export.h"
#include "utils_getopt.h"

#define MAX_SIZE_OF_TOPIC (128)
#define MAX_SIZE_OF_DATA  (128)

#define SUB_DEV_USE_DATA_TEMPLATE_LIGHT
#ifdef SUB_DEV_USE_DATA_TEMPLATE_LIGHT
#define LIGHT_SUB_DEV_PRODUCT_ID "BK7EEF4UIB"
#define LIGHT_SUB_DEV_NAME       "dev001"
extern void *sub_dev1_thread(void *ptr, char *product_id, char *device_name);
#endif

static int               sg_sub_packet_id = -1;
//static int               sg_loop_count    = 1;
static GatewayDeviceInfo sg_GWdevInfo;

#ifdef AUTH_MODE_CERT
static char sg_cert_file[PATH_MAX + 1];  // full path of device cert file
static char sg_key_file[PATH_MAX + 1];   // full path of device key file
#endif

void _event_handler(void *client, void *context, MQTTEventMsg *msg)
{
    MQTTMessage *mqtt_messge = (MQTTMessage *)msg->msg;
    uintptr_t    packet_id   = (uintptr_t)msg->msg;

    switch (msg->event_type) {
        case MQTT_EVENT_UNDEF:
            Log_i("undefined event occur.");
            break;

        case MQTT_EVENT_DISCONNECT:
            Log_i("MQTT disconnect.");
            break;

        case MQTT_EVENT_RECONNECT:
            Log_i("MQTT reconnect.");
            break;

        case MQTT_EVENT_PUBLISH_RECVEIVED:
            Log_i(
                "topic message arrived but without any related handle: topic=%.*s, "
                "topic_msg=%.*s",
                mqtt_messge->topic_len, mqtt_messge->ptopic, mqtt_messge->payload_len, mqtt_messge->payload);
            break;
        case MQTT_EVENT_SUBCRIBE_SUCCESS:
            Log_i("subscribe success, packet-id=%u", (unsigned int)packet_id);
            sg_sub_packet_id = packet_id;
            break;

        case MQTT_EVENT_SUBCRIBE_TIMEOUT:
            Log_i("subscribe wait ack timeout, packet-id=%u", (unsigned int)packet_id);
            sg_sub_packet_id = packet_id;
            break;

        case MQTT_EVENT_SUBCRIBE_NACK:
            Log_i("subscribe nack, packet-id=%u", (unsigned int)packet_id);
            sg_sub_packet_id = packet_id;
            break;

        case MQTT_EVENT_UNSUBCRIBE_SUCCESS:
            Log_i("unsubscribe success, packet-id=%u", (unsigned int)packet_id);
            break;

        case MQTT_EVENT_UNSUBCRIBE_TIMEOUT:
            Log_i("unsubscribe timeout, packet-id=%u", (unsigned int)packet_id);
            break;

        case MQTT_EVENT_UNSUBCRIBE_NACK:
            Log_i("unsubscribe nack, packet-id=%u", (unsigned int)packet_id);
            break;

        case MQTT_EVENT_PUBLISH_SUCCESS:
            Log_i("publish success, packet-id=%u", (unsigned int)packet_id);
            break;

        case MQTT_EVENT_PUBLISH_TIMEOUT:
            Log_i("publish timeout, packet-id=%u", (unsigned int)packet_id);
            break;

        case MQTT_EVENT_PUBLISH_NACK:
            Log_i("publish nack, packet-id=%u", (unsigned int)packet_id);
            break;
        default:
            Log_i("Should NOT arrive here.");
            break;
    }
}

static void _message_handler(void *client, MQTTMessage *message, void *user_data)
{
    if (message == NULL) {
        return;
    }

    Log_i("Receive Message With topicName:%.*s, payload:%.*s", (int)message->topic_len, message->ptopic,
          (int)message->payload_len, (char *)message->payload);
}

static int _setup_connect_init_params(GatewayInitParam *init_params)
{
    int rc;

    rc = HAL_GetGwDevInfo((void *)&sg_GWdevInfo);
    if (QCLOUD_RET_SUCCESS != rc) {
        Log_e("Get gateway dev info err,rc:%d", rc);
        return rc;
    }

    init_params->init_param.region      = sg_GWdevInfo.gw_info.region;
    init_params->init_param.product_id  = sg_GWdevInfo.gw_info.product_id;
    init_params->init_param.device_name = sg_GWdevInfo.gw_info.device_name;

#ifdef AUTH_MODE_CERT
//    char  certs_dir[PATH_MAX + 1] = "certs";
//    char  current_path[PATH_MAX + 1];
//    char *cwd = getcwd(current_path, sizeof(current_path));
//    if (cwd == NULL) {
//        Log_e("getcwd return NULL");
//        return QCLOUD_ERR_FAILURE;
//    }
    sprintf(sg_cert_file, "%s", sg_GWdevInfo.gw_info.dev_cert_file_name);
    sprintf(sg_key_file, "%s", sg_GWdevInfo.gw_info.dev_key_file_name);

    init_params->init_param.cert_file = sg_cert_file;
    init_params->init_param.key_file  = sg_key_file;
#else
    init_params->init_param.device_secret = sg_GWdevInfo.gw_info.device_secret;
#endif

    init_params->init_param.command_timeout        = QCLOUD_IOT_MQTT_COMMAND_TIMEOUT;
    init_params->init_param.auto_connect_enable    = 1;
    init_params->init_param.event_handle.h_fp      = _event_handler;
    init_params->init_param.keep_alive_interval_ms = QCLOUD_IOT_MQTT_KEEP_ALIVE_INTERNAL;

    return QCLOUD_RET_SUCCESS;
}

//static int parse_arguments(int argc, char **argv)
//{
//    int c;
//    while ((c = utils_getopt(argc, argv, "c:l:")) != EOF) switch (c) {
//            case 'c':
//                if (HAL_SetDevInfoFile(utils_optarg))
//                    return -1;
//                break;
//
//            case 'l':
//                sg_loop_count = atoi(utils_optarg);
//                if (sg_loop_count > 10000)
//                    sg_loop_count = 10000;
//                else if (sg_loop_count < 0)
//                    sg_loop_count = 1;
//                break;
//
//            default:
//                HAL_Printf(
//                    "usage: %s [options]\n"
//                    "  [-c <config file for DeviceInfo>] \n"
//                    "  [-l <loop count>] \n",
//                    argv[0]);
//                return -1;
//        }
//    return 0;
//}

/**
 * sub dev thread runner
 */
#ifdef SUB_DEV_USE_DATA_TEMPLATE_LIGHT  // show subdev with data template.
static void sub_dev_thread(void *user_arg)
{
    sub_dev1_thread(user_arg, LIGHT_SUB_DEV_PRODUCT_ID, LIGHT_SUB_DEV_NAME);
}
#endif


/**
 * show gateway dynamic bind/unbind sub-devices
 */
#ifdef GATEWAY_DYN_BIND_SUBDEV_ENABLED
static int add_new_binded_sub_dev(GatewayDeviceInfo *pGateway, DeviceInfo *pNewSubDev)
{
    int ret;
    if(pGateway->sub_dev_num < MAX_NUM_SUB_DEV) {
        memcpy((char *)&pGateway->sub_dev_info[pGateway->sub_dev_num], (char *)pNewSubDev, sizeof(DeviceInfo));
        pGateway->sub_dev_num++;
        ret = QCLOUD_RET_SUCCESS; //you can save gateway info to local flash for persistent storage
    } else {
        ret = QCLOUD_ERR_FAILURE;
    }

    return ret;
}

static int show_subdev_bind_unbind(void *client, GatewayParam *param)
{
    int rc;

    //ajust for your bind device info
    DeviceInfo subDev;
    memset((char *)&subDev, 0, sizeof(DeviceInfo));
    strncpy(subDev.product_id, "BIND_PID", MAX_SIZE_OF_PRODUCT_ID);
    strncpy(subDev.device_name, "BIND_DEV_NAME", MAX_SIZE_OF_DEVICE_NAME);
#ifdef AUTH_MODE_CERT
    strncpy(subDev.dev_cert_file_name, "BIND_CERT_FILE_NAME", MAX_SIZE_OF_DEVICE_CERT_FILE_NAME);
    strncpy(subDev.dev_key_file_name, "BIND_KEY_FILE_NAME", MAX_SIZE_OF_DEVICE_SECRET_FILE_NAME);

#else
    strncpy(subDev.device_secret, "BIND_DEV_PSK", MAX_SIZE_OF_DEVICE_SECRET);
#endif
    Log_d("bind subdev %s/%s", subDev.product_id, subDev.device_name);

    //bind sub dev
    rc = IOT_Gateway_Subdev_Bind(client, param, &subDev);
    if(QCLOUD_ERR_BIND_REPEATED_REQ == rc) {
        Log_d("%s/%s has been binded", subDev.product_id, subDev.device_name);
        rc = IOT_Gateway_Subdev_Unbind(client, param, &subDev);
        if(QCLOUD_RET_SUCCESS != rc) {
            Log_e("unbind %s/%s fail,rc:%d", subDev.product_id, subDev.device_name, rc);
        } else {
            Log_d("unbind %s/%s success", subDev.product_id, subDev.device_name);
            rc = IOT_Gateway_Subdev_Bind(client, param, &subDev);
        }
    }

    if(QCLOUD_RET_SUCCESS == rc) {
        Log_d("bind %s/%s success", subDev.product_id, subDev.device_name);
        add_new_binded_sub_dev(&sg_GWdevInfo, &subDev);
    } else {
        Log_e("bind %s/%s fail,rc:%d", subDev.product_id, subDev.device_name, rc);
    }

    return rc;
}

#endif


/*Gateway should enable multithread*/
void gateway_sample(void *arg)
{
    int                rc       = QCLOUD_ERR_FAILURE;
    int                errCount = 0;
    int                i;
    int                size;
    void *             client = NULL;
    GatewayDeviceInfo *gw     = &sg_GWdevInfo;
    GatewayParam       param  = DEFAULT_GATEWAY_PARAMS;
    DeviceInfo *       subDevInfo;

#ifdef SUB_DEV_USE_DATA_TEMPLATE_LIGHT
    ThreadParams sub_dev1_thread_params = {0};
#endif

    IOT_Log_Set_Level(eLOG_DEBUG);
    // parse arguments for device info file and loop test;
//    rc = parse_arguments(argc, argv);
//    if (rc != QCLOUD_RET_SUCCESS) {
//        Log_e("parse arguments error, rc = %d", rc);
//        return rc;
//    }

    GatewayInitParam init_params = DEFAULT_GATEWAY_INIT_PARAMS;
    rc                           = _setup_connect_init_params(&init_params);
    if (rc != QCLOUD_RET_SUCCESS) {
        Log_e("init params err,rc=%d", rc);
        return ;
    }

    client = IOT_Gateway_Construct(&init_params);
    if (client == NULL) {
        Log_e("client constructed failed.");
        return ;
    }

#ifdef MULTITHREAD_ENABLED
    rc = IOT_Gateway_Start_Yield_Thread(client);
    if (rc != QCLOUD_RET_SUCCESS) {
        Log_e("init params err,rc=%d", rc);
        goto exit;
    }
#endif

    // set GateWay device info
    param.product_id  = gw->gw_info.product_id;
    param.device_name = gw->gw_info.device_name;


#ifdef GATEWAY_DYN_BIND_SUBDEV_ENABLED
    //show gateway dynamic bind/unbind sub-devices
    show_subdev_bind_unbind(client, &param);
#endif

    // make sub-device online
    for (i = 0; i < gw->sub_dev_num; i++) {
        subDevInfo               = &gw->sub_dev_info[i];
        param.subdev_product_id  = subDevInfo->product_id;
        param.subdev_device_name = subDevInfo->device_name;

        rc = IOT_Gateway_Subdev_Online(client, &param);
        if (rc != QCLOUD_RET_SUCCESS) {
            Log_e("subDev Pid:%s devName:%s online fail.", subDevInfo->product_id, subDevInfo->device_name);
            errCount++;
        } else {
            Log_d("subDev Pid:%s devName:%s online success.", subDevInfo->product_id, subDevInfo->device_name);
        }
    }

    if (errCount > 0) {
        Log_e("%d of %d sub devices online fail", errCount, gw->sub_dev_num);
    }

    // subscribe sub-device data_template down stream topic for example
    char            topic_filter[MAX_SIZE_OF_TOPIC + 1];
    SubscribeParams sub_param = DEFAULT_SUB_PARAMS;
    for (i = 0; i < gw->sub_dev_num; i++) {
        subDevInfo = &gw->sub_dev_info[i];
#ifdef SUB_DEV_USE_DATA_TEMPLATE_LIGHT  // subdev with data template example.
        ql_task_t sub_dev1_task = NULL;
        if ((0 == strcmp(subDevInfo->product_id, LIGHT_SUB_DEV_PRODUCT_ID)) &&
            (0 == strcmp(subDevInfo->device_name, LIGHT_SUB_DEV_NAME))) {
            //sub_dev1_thread_params.thread_func = sub_dev_thread;
            //sub_dev1_thread_params.thread_name = "sub_dev1_thread";
            //sub_dev1_thread_params.user_arg    = client;
            //sub_dev1_thread_params.stack_size  = 4096;
            //sub_dev1_thread_params.priority    = 1;
            
            int rc = ql_rtos_task_create(&sub_dev1_task, 10*1024, APP_PRIORITY_NORMAL, "sub_dev1_thread", sub_dev_thread, client, 5);

            //int rc = HAL_ThreadCreate(&sub_dev1_thread_params);
            if (rc) {
                Log_e("create sub_dev1_thread fail: %d", rc);
                return ;
            }
            continue;
        }
#endif
        memset(topic_filter, 0, MAX_SIZE_OF_TOPIC + 1);
        size = HAL_Snprintf(topic_filter, MAX_SIZE_OF_TOPIC, "$thing/down/property/%s/%s", subDevInfo->product_id,
                            subDevInfo->device_name);

        if (size < 0 || size > MAX_SIZE_OF_TOPIC) {
            Log_e("buf size < topic length!");
            rc = QCLOUD_ERR_FAILURE;
            goto exit;
        }

        sub_param.on_message_handler = _message_handler;
        rc                           = IOT_Gateway_Subscribe(client, topic_filter, &sub_param);
        if (rc < 0) {
            Log_e("IOT_Gateway_Subscribe fail.");
            return ;
        }
    }

    HAL_SleepMs(2000); /*wait subcribe ack*/

    //  publish to sub-device data_template up stream topic for example
    PublishParams pub_param = DEFAULT_PUB_PARAMS;
    pub_param.qos           = QOS0;

    //  pub_param.payload =
    //"{\"method\":\"report\",\"clientToken\":\"123\",\"params\":{\"data\":\"err
    // reply wil received\"}}";
    pub_param.payload     = "{\"method\":\"report\",\"clientToken\":\"123\",\"params\":{}}";
    pub_param.payload_len = strlen(pub_param.payload);
    for (i = 0; i < gw->sub_dev_num; i++) {
        subDevInfo = &gw->sub_dev_info[i];

#ifdef SUB_DEV_USE_DATA_TEMPLATE_LIGHT
        if ((0 == strcmp(subDevInfo->product_id, LIGHT_SUB_DEV_PRODUCT_ID)) &&
            (0 == strcmp(subDevInfo->device_name, LIGHT_SUB_DEV_NAME))) {
            continue;
        }
#endif
        memset(topic_filter, 0, MAX_SIZE_OF_TOPIC + 1);
        size = HAL_Snprintf(topic_filter, MAX_SIZE_OF_TOPIC, "$thing/up/property/%s/%s", subDevInfo->product_id,
                            subDevInfo->device_name);
        if (size < 0 || size > MAX_SIZE_OF_TOPIC) {
            Log_e("buf size < topic length!");
            return ;
        }

        rc = IOT_Gateway_Publish(client, topic_filter, &pub_param);
        if (rc < 0) {
            Log_e("IOT_Gateway_Publish fail.");
        }
    }

exit:

#ifdef SUB_DEV_USE_DATA_TEMPLATE_LIGHT
    if (0 != sub_dev1_thread_params.thread_id) {
        //pthread_join(sub_dev1_thread_params.thread_id, NULL);
    }
#endif

    // set GateWay device info
    param.product_id  = gw->gw_info.product_id;
    param.device_name = gw->gw_info.device_name;
    // make sub-device offline
    errCount = 0;
    for (i = 0; i < gw->sub_dev_num; i++) {
        subDevInfo               = &gw->sub_dev_info[i];
        param.subdev_product_id  = subDevInfo->product_id;
        param.subdev_device_name = subDevInfo->device_name;

        rc = IOT_Gateway_Subdev_Offline(client, &param);
        if (rc != QCLOUD_RET_SUCCESS) {
            Log_e("subDev Pid:%s devName:%s offline fail.", subDevInfo->product_id, subDevInfo->device_name);
            errCount++;
        } else {
            Log_d("subDev Pid:%s devName:%s offline success.", subDevInfo->product_id, subDevInfo->device_name);
        }
    }

    if (errCount > 0) {
        Log_e("%d of %d sub devices offline fail", errCount, gw->sub_dev_num);
    }
#ifdef MULTITHREAD_ENABLED
    // stop running thread
    IOT_Gateway_Stop_Yield_Thread(client);
    rc = IOT_Gateway_Destroy(client);
#endif
}

int gateway_sample_start(void)
{
    int err = 0;
    int count = 0;
   	ql_task_t gateway_sample_task = NULL;
    /* 主循环进入休眠 */
    while (count < 10)
    {
        count++;
        ql_rtos_task_sleep_s(1);
        Log_e("ql_qcloud_sdk_gateway_sample_start_init  -0x%04X\n", err);
    }
	err = ql_rtos_task_create(&gateway_sample_task, 10*1024, APP_PRIORITY_NORMAL, "gateway_sample", gateway_sample, NULL, 5);
	
	if (err != QL_OSI_SUCCESS)
	{
        return -1;
	}
    return 0;
}