File syn_coap.h¶

File List > net > syn_coap.h
#ifndef SYN_COAP_H
#define SYN_COAP_H

#include "../common/syn_defs.h"
#include "../port/syn_port_socket.h"
#include "../pt/syn_pt.h"
#include "../sched/syn_task.h"
#include "../util/syn_backoff.h"

#include <stdbool.h>
#include <stddef.h>
#include <stdint.h>

#ifdef __cplusplus
extern "C" {
#endif

#define COAP_VERSION 1 
#define COAP_TYPE_CON 0 
#define COAP_TYPE_NON 1 
#define COAP_TYPE_ACK 2 
#define COAP_TYPE_RST 3 
#define COAP_CODE_GET 1    
#define COAP_CODE_POST 2   
#define COAP_CODE_PUT 3    
#define COAP_CODE_DELETE 4 
#define COAP_RESP_CREATED 65    
#define COAP_RESP_DELETED 66    
#define COAP_RESP_VALID 67      
#define COAP_RESP_CHANGED 68    
#define COAP_RESP_CONTENT 69    
#define COAP_RESP_BAD_REQ 128   
#define COAP_RESP_UNAUTH 129    
#define COAP_RESP_BAD_OPT 130   
#define COAP_RESP_FORBIDDEN 131 
#define COAP_RESP_NOT_FOUND 132 
#define COAP_RESP_METHOD_NA 133 
#define COAP_RESP_NOT_ACC 134   
#define COAP_RESP_PRECOND_F 140 
#define COAP_RESP_REQ_TOO_L 141 
#define COAP_RESP_UNSUP_MED 143 
#define COAP_RESP_INTERNAL 160  
#define COAP_RESP_NOT_IMPL 161  
#define COAP_RESP_BAD_GATE 162  
#define COAP_RESP_SVC_UNAV 163  
#define COAP_RESP_GATE_TO 164   
#define COAP_RESP_PROXY_NA 165  
#define COAP_OPT_URI_HOST 3        
#define COAP_OPT_ETAG 4            
#define COAP_OPT_OBSERVE 6         
#define COAP_OPT_URI_PORT 7        
#define COAP_OPT_LOCATION_PATH 8   
#define COAP_OPT_URI_PATH 11       
#define COAP_OPT_CONTENT_FORMAT 12 
#define COAP_OPT_MAX_AGE 14        
#define COAP_OPT_URI_QUERY 15      
#define COAP_OPT_ACCEPT 17         
#define COAP_OPT_LOCATION_QUERY 20 
#define COAP_OPT_PROXY_URI 35      
#define COAP_OPT_PROXY_SCHEME 39   
#define COAP_OPT_SIZE1 60          
typedef struct {
    uint16_t num;       
    const uint8_t *val; 
    size_t len;         
} SYN_CoapOption;

typedef struct {
    uint8_t type;           
    uint8_t code;           
    uint16_t msg_id;        
    uint8_t token_len;      
    uint8_t token[8];       
    const uint8_t *payload; 
    size_t payload_len;     
} SYN_CoapMsg;

/* Parser & Builder API */

SYN_Status syn_coap_parse(SYN_CoapMsg *msg, SYN_CoapOption *options, size_t max_options,
                          size_t *option_count, const uint8_t *buf, size_t buf_len);

size_t syn_coap_serialize(const SYN_CoapMsg *msg, const SYN_CoapOption *options,
                          size_t option_count, uint8_t *buf, size_t max_buf_len);

typedef struct {
    /* ── Input (caller fills before launching task) ── */
    SYN_SockAddr server_addr;          
    const SYN_CoapMsg *req_msg;        
    const SYN_CoapOption *req_options; 
    size_t req_option_count;           
    /* ── Output (filled by task on completion) ── */
    SYN_CoapMsg resp_msg;           
    SYN_CoapOption resp_options[8]; 
    size_t resp_option_count;       
    uint8_t resp_buf[256];          
    size_t resp_len;                
    /* ── Execution state (must survive across PT_YIELD) ── */
    SYN_Socket sock;     
    uint8_t tx_buf[256]; 
    size_t tx_len;       
    uint32_t start_ms;   
    SYN_Backoff backoff; 
    SYN_Status status;   
} SYN_CoapRequest;

SYN_PT_Status syn_coap_request_task(SYN_PT *pt, SYN_Task *task);

void syn_coap_request_init(SYN_CoapRequest *r, const SYN_SockAddr *server_addr,
                           const SYN_CoapMsg *msg, uint32_t timeout_ms, uint8_t retries);

#ifdef __cplusplus
}
#endif

#endif /* SYN_COAP_H */