kii.h

Go to the documentation of this file.

#ifndef KII_H
#define KII_H

#include "kii_core.h"
#include "kii_task_callback.h"

#include <kii_json.h>

#ifdef __cplusplus
extern "C" {
#endif

#define KII_OBJECTID_SIZE 36

#define KII_UPLOADID_SIZE 64

#ifdef DEBUG
#ifndef __FILE__
#define __FILE__ ("__FILE__ macro is not available")
#endif

#ifndef __LINE__
#define __LINE__ (-1)
#endif

#define M_KII_LOG(x) \
    if (kii->kii_core.logger_cb != NULL) {\
        kii->kii_core.logger_cb("file:%s, line:%d ", __FILE__, __LINE__); \
        (x); \
    }
#else
#define M_KII_LOG(x)
#endif

#define KII_TASK_NAME_RECV_MSG "recv_msg_task"
#ifdef KII_PUSH_KEEP_ALIVE_INTERVAL_SECONDS
#define KII_TASK_NAME_PING_REQ "ping_req_task"
#endif

struct kii_t;

typedef void (*KII_PUSH_RECEIVED_CB)(
                struct kii_t* kii,
                char* message,
                size_t message_length);

typedef struct kii_t {
    kii_core_t kii_core;

    kii_socket_context_t mqtt_socket_context;
    KII_SOCKET_CONNECT_CB mqtt_socket_connect_cb;
    KII_SOCKET_SEND_CB mqtt_socket_send_cb;
    KII_SOCKET_RECV_CB mqtt_socket_recv_cb;
    KII_SOCKET_CLOSE_CB mqtt_socket_close_cb;

    KII_TASK_CREATE task_create_cb;

    KII_DELAY_MS delay_ms_cb;

    KII_PUSH_RECEIVED_CB push_received_cb;

    int _mqtt_connected;

    char* mqtt_buffer;
    size_t mqtt_buffer_size;

    void* app_context;

    kii_json_resource_t kii_json_resource;

    KII_JSON_RESOURCE_CB kii_json_resource_cb;

} kii_t;

int kii_init(
        kii_t* kii,
        const char* site,
        const char* app_id,
        const char* app_key);

int kii_thing_authenticate(
        kii_t* kii,
        const char* vendor_thing_id,
        const char* password);

int kii_thing_register(
        kii_t* kii,
        const char* vendor_thing_id,
        const char* thing_type,
        const char* password);

int kii_thing_upload_state(
        kii_t* kii,
        const char* thing_id,
        const char* thing_state,
        const size_t content_length,
        const char* content_type,
        const char* content_encoding,
        const char* normalizer_host);

int kii_thing_patch_state(
        kii_t* kii,
        const char* thing_id,
        const char* thing_state,
        const size_t content_length,
        const char* content_type,
        const char* content_encoding,
        const char* normalizer_host);

int kii_object_create(
        kii_t* kii,
        const kii_bucket_t* bucket,
        const char* object_data,
        const char* object_content_type,
        char* out_object_id);

int kii_object_create_with_id(
        kii_t* kii,
        const kii_bucket_t* bucket,
        const char* object_id,
        const char* object_data,
        const char* object_content_type);

int kii_object_patch(
        kii_t* kii,
        const kii_bucket_t* bucket,
        const char* object_id,
        const char* patch_data,
        const char* opt_etag);

int kii_object_replace(
        kii_t* kii,
        const kii_bucket_t* bucket,
        const char* object_id,
        const char* replacement_data,
        const char* opt_etag);

int kii_object_delete(
        kii_t* kii,
        const kii_bucket_t* bucket,
        const char* object_id);

int kii_object_get(
        kii_t* kii,
        const kii_bucket_t* bucket,
        const char* object_id);

int kii_object_upload_body_at_once(
        kii_t* kii,
        const kii_bucket_t* bucket,
        const char* object_id,
        const char* body_content_type,
        const void* data,
        size_t data_length);

int kii_object_init_upload_body(
        kii_t* kii,
        const kii_bucket_t* bucket,
        const char* object_id,
        char* out_upload_id);

typedef struct kii_chunk_data_t {
    char* body_content_type;
    size_t position;
    size_t length;
    size_t total_length;
    void* chunk;
} kii_chunk_data_t;

int kii_object_upload_body(
        kii_t* kii,
        const kii_bucket_t* bucket,
        const char* object_id,
        const char* upload_id,
        const kii_chunk_data_t* chunk);

int kii_object_commit_upload(
        kii_t* kii,
        const kii_bucket_t* bucket,
        const char* object_id,
        const char* upload_id,
        unsigned int commit);

int kii_object_download_body_at_once(
        kii_t* kii,
        const kii_bucket_t* bucket,
        const char* object_id,
        unsigned int* out_data_length);

int kii_object_download_body(
        kii_t* kii,
        const kii_bucket_t* bucket,
        const char* object_id,
        unsigned int position,
        unsigned int length,
        unsigned int* out_actual_length,
        unsigned int* out_total_length);

int kii_push_subscribe_bucket(
        kii_t* kii,
        const kii_bucket_t* bucket);

int kii_push_unsubscribe_bucket(
        kii_t* kii,
        const kii_bucket_t* bucket);

int kii_push_subscribe_topic(
        kii_t* kii,
        const kii_topic_t* topic);

int kii_push_unsubscribe_topic(
        kii_t* kii,
        const kii_topic_t* topic);

int kii_push_create_topic(
        kii_t* kii,
        const kii_topic_t* topic);

int kii_push_delete_topic(
        kii_t* kii,
        const kii_topic_t* topic);

int kii_push_start_routine(
        kii_t* kii,
        KII_PUSH_RECEIVED_CB callback);

int kii_server_code_execute(
        kii_t* kii,
        const char* endpoint_name,
        const char* params);

int kii_api_call_start(
        kii_t* kii,
        const char* http_method,
        const char* resource_path,
        const char* content_type,
        kii_bool_t set_authentication_header);

int kii_api_call_append_body(
        kii_t* kii,
        const void* body_data,
        size_t body_size);

int
kii_api_call_append_header(
        kii_t* kii,
        const char* key,
        const char* value);

int kii_api_call_run(kii_t* kii);

#ifdef __cplusplus
}
#endif

#endif
/* vim:set ts=4 sts=4 sw=4 et fenc=UTF-8 ff=unix: */