aws_iot.h

Go to the documentation of this file.

/*
 * Copyright (c) 2022 Nordic Semiconductor ASA
 *
 * SPDX-License-Identifier: LicenseRef-Nordic-5-Clause
 */

 
#ifndef AWS_IOT_H__
#define AWS_IOT_H__
 
#include <stdio.h>
#include <zephyr/net/mqtt.h>
#include <dfu/dfu_target.h>

 
#ifdef __cplusplus
extern "C" {
#endif

enum aws_iot_shadow_topic_received_type {
        AWS_IOT_SHADOW_TOPIC_APPLICATION_SPECIFIC,

        AWS_IOT_SHADOW_TOPIC_GET_ACCEPTED,

        AWS_IOT_SHADOW_TOPIC_GET_REJECTED,

        AWS_IOT_SHADOW_TOPIC_UPDATE_DELTA,

        AWS_IOT_SHADOW_TOPIC_UPDATE_ACCEPTED,

        AWS_IOT_SHADOW_TOPIC_UPDATE_REJECTED,

        AWS_IOT_SHADOW_TOPIC_DELETE_ACCEPTED,

        AWS_IOT_SHADOW_TOPIC_DELETE_REJECTED
};

enum aws_iot_shadow_topic_type {
        AWS_IOT_SHADOW_TOPIC_NONE,

        AWS_IOT_SHADOW_TOPIC_GET,

        AWS_IOT_SHADOW_TOPIC_UPDATE,

        AWS_IOT_SHADOW_TOPIC_DELETE
};

enum aws_iot_evt_type {
        AWS_IOT_EVT_CONNECTING = 0x1,

        AWS_IOT_EVT_CONNECTED,

        AWS_IOT_EVT_DISCONNECTED,

        AWS_IOT_EVT_DATA_RECEIVED,

        AWS_IOT_EVT_PUBACK,

        AWS_IOT_EVT_PINGRESP,

        AWS_IOT_EVT_FOTA_START,

        AWS_IOT_EVT_FOTA_DONE,

        AWS_IOT_EVT_FOTA_ERASE_PENDING,

        AWS_IOT_EVT_FOTA_ERASE_DONE,

        AWS_IOT_EVT_FOTA_DL_PROGRESS,

        AWS_IOT_EVT_FOTA_ERROR,

        AWS_IOT_EVT_ERROR
};

struct aws_iot_topic_data {
 
        union {
                enum aws_iot_shadow_topic_type type;

                enum aws_iot_shadow_topic_received_type type_received;
        };

        const char *str;

        size_t len;
};

struct aws_iot_data {
        struct aws_iot_topic_data topic;

        char *ptr;

        size_t len;

        enum mqtt_qos qos;

        uint16_t message_id;

        uint8_t dup_flag;

        uint8_t retain_flag;
};

struct aws_iot_evt {
        enum aws_iot_evt_type type;
        union {
                struct aws_iot_data msg;

                int err;

                int fota_progress;

                bool persistent_session;

                uint16_t message_id;

                enum dfu_target_image_type image;
        } data;
};

typedef void (*aws_iot_evt_handler_t)(const struct aws_iot_evt *evt);

struct aws_iot_config {
        char *client_id;

        char *host_name;

        const char *if_name;
};

int aws_iot_init(aws_iot_evt_handler_t event_handler);

int aws_iot_connect(const struct aws_iot_config *const config);

int aws_iot_disconnect(void);

int aws_iot_send(const struct aws_iot_data *const tx_data);

int aws_iot_application_topics_set(const struct mqtt_topic *const list, size_t count);
 
#ifdef __cplusplus
}
#endif

 
#endif /* AWS_IOT_H__ */