coap_client.h

Go to the documentation of this file.

 
/*
 * Copyright (c) 2023 Nordic Semiconductor ASA
 *
 * SPDX-License-Identifier: Apache-2.0
 */
#ifndef ZEPHYR_INCLUDE_NET_COAP_CLIENT_H_
#define ZEPHYR_INCLUDE_NET_COAP_CLIENT_H_
 
#include <zephyr/net/coap.h>
#include <zephyr/kernel.h>
 
#define MAX_COAP_MSG_LEN (CONFIG_COAP_CLIENT_MESSAGE_HEADER_SIZE + \
                          CONFIG_COAP_CLIENT_MESSAGE_SIZE)
 
typedef void (*coap_client_response_cb_t)(int16_t result_code,
                                          size_t offset, const uint8_t *payload, size_t len,
                                          bool last_block, void *user_data);
 
struct coap_client_request {
        enum coap_method method;            
        bool confirmable;                   
        const char *path;                   
        enum coap_content_format fmt;       
        uint8_t *payload;                   
        size_t len;                         
        coap_client_response_cb_t cb;       
        struct coap_client_option *options; 
        uint8_t num_options;                
        void *user_data;                    
};
 
struct coap_client_option {
        uint16_t code;
#if defined(CONFIG_COAP_EXTENDED_OPTIONS_LEN)
        uint16_t len;
        uint8_t value[CONFIG_COAP_EXTENDED_OPTIONS_LEN_VALUE];
#else
        uint8_t len;
        uint8_t value[12];
#endif
};
 
struct coap_client_internal_request {
        uint8_t request_token[COAP_TOKEN_MAX_LEN];
        uint32_t offset;
        uint32_t last_id;
        uint8_t request_tkl;
        bool request_ongoing;
        atomic_t in_callback;
        struct coap_block_context recv_blk_ctx;
        struct coap_block_context send_blk_ctx;
        struct coap_pending pending;
        struct coap_client_request coap_request;
        struct coap_packet request;
        uint8_t request_tag[COAP_TOKEN_MAX_LEN];
 
        /* For GETs with observe option set */
        bool is_observe;
        int last_response_id;
};
 
struct coap_client {
        int fd;
        struct sockaddr address;
        socklen_t socklen;
        bool response_ready;
        struct k_mutex lock;
        uint8_t send_buf[MAX_COAP_MSG_LEN];
        uint8_t recv_buf[MAX_COAP_MSG_LEN];
        struct coap_client_internal_request requests[CONFIG_COAP_CLIENT_MAX_REQUESTS];
        struct coap_option echo_option;
        bool send_echo;
};
int coap_client_init(struct coap_client *client, const char *info);
 
int coap_client_req(struct coap_client *client, int sock, const struct sockaddr *addr,
                    struct coap_client_request *req, struct coap_transmission_parameters *params);
 
void coap_client_cancel_requests(struct coap_client *client);
 
static inline struct coap_client_option coap_client_option_initial_block2(void)
{
        struct coap_client_option block2 = {
                .code = COAP_OPTION_BLOCK2,
                .len = 1,
                .value[0] = coap_bytes_to_block_size(CONFIG_COAP_CLIENT_BLOCK_SIZE),
        };
 
        return block2;
}
 
#endif /* ZEPHYR_INCLUDE_NET_COAP_CLIENT_H_ */