protocol.h

Go to the documentation of this file.

/*
 
    trip: Modern TRIP LS implementation
    Copyright (C) 2025 arf20 (Ángel Ruiz Fernandez)
 
    This program is free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.
 
    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.
 
    You should have received a copy of the GNU General Public License
    along with this program.  If not, see <https://www.gnu.org/licenses/>.
 
*/

 
#ifndef _PROTOCOL_H
#define _PROTOCOL_H
 
#include <stdint.h>
#include <stddef.h>
 
 
#define MAX_MSG_SIZE    4096
 

enum msg_type {
    MSG_TYPE_OPEN = 1,
    MSG_TYPE_UPDATE,
    MSG_TYPE_NOTIFICATION,
    MSG_TYPE_KEEPALIVE
};

extern const char *msg_type_strs[];

typedef struct __attribute__((packed)) {
    uint16_t    msg_len;
    uint8_t     msg_type;
    uint8_t     msg_val[];
} msg_t;
 

enum open_opt_type {
    OPEN_OPT_TYPE_CAPABILITY_INFO = 1,
};

extern const char *open_opt_type_strs[];

typedef struct __attribute__((packed)) {
    uint16_t    opt_type;
    uint16_t    opt_len;
    uint8_t     opt_val[];
} msg_open_opt_t;

#define PROTOCOL_VERSION    1

typedef struct __attribute__((packed)) {
    uint8_t         open_ver;
    uint8_t         open_reserved;
    uint16_t        open_hold;
    uint32_t        open_itad;
    uint32_t        open_id;
    uint16_t        open_opts_len;
    msg_open_opt_t  open_opts[];
} msg_open_t;
 

enum capinfo_code {
    CAPINFO_CODE_ROUTETYPE = 1,
    CAPINFO_CODE_TRANSMODE
};

extern const char *capinfo_code_strs[];

typedef struct __attribute__((packed)) {
    uint16_t    capinfo_code;
    uint16_t    capinfo_len;
    uint8_t     capinfo_val[];
} capinfo_t;
 

typedef struct __attribute__((packed)) {
    uint16_t    routetype_af;
    uint16_t    routetype_app_proto;
} capinfo_routetype_t;
 

enum capinfo_transmode {
    CAPINFO_TRANS_SEND_RECV = 1,
    CAPINFO_TRANS_SEND,
    CAPINFO_TRANS_RECV
};

extern const char *capinfo_transmode_strs[];

#define CAPINFO_TRANS_NULL   (uint32_t)-1

typedef uint32_t capinfo_transmode_t;
 

#define IS_ATTR_FLAG_WELL_KNOWN(x)  ((x >> 7) & 1)
#define IS_ATTR_FLAG_TRANSITIVE(x)  ((x >> 6) & 1)
#define IS_ATTR_FLAG_DEPENDENT(x)   ((x >> 5) & 1)
#define IS_ATTR_FLAG_PARTIAL(x)     ((x >> 4) & 1)
#define IS_ATTR_FLAG_LSENCAP(x)     ((x >> 3) & 1)
 
#define ATTR_FLAG_WELL_KNOWN        0b10000000
#define ATTR_FLAG_TRANSITIVE        0b01000000
#define ATTR_FLAG_DEPENDENT         0b00100000
#define ATTR_FLAG_PARTIAL           0b00010000
#define ATTR_FLAG_LSENCAP           0b00001000
 
const char *flags_str(uint8_t flags);

enum attr_type {
    ATTR_TYPE_WITHDRAWNROUTES = 1,
    ATTR_TYPE_REACHABLEROUTES,
    ATTR_TYPE_NEXTHOPSERVER,
    ATTR_TYPE_ADVERTISEMENTPATH,
    ATTR_TYPE_ROUTEDPATH,
    ATTR_TYPE_ATOMICAGGREGATE,
    ATTR_TYPE_LOCALPREFERENCE,
    ATTR_TYPE_MULTIEXITDISC,
    ATTR_TYPE_COMMUNITIES,
    ATTR_TYPE_ITADTOPOLOGY,
    ATTR_TYPE_CONVERTEDROUTE,
    ATTR_TYPE_RESOURCEPRIORITY,
    ATTR_TYPE_TOTALCIRCUITCAPACITY,
    ATTR_TYPE_AVAILABLECIRCUITS,
    ATTR_TYPE_CALLSUCCESS,
    ATTR_TYPE_E164PREFIX,
    ATTR_TYPE_PENTADECPREFIX,
    ATTR_TYPE_DECIMALPREFIX,
    ATTR_TYPE_TRUNKGROUP,
    ATTR_TYPE_CARRIER
};

extern const char *attr_strs[];

typedef struct __attribute__((packed)) {
    uint8_t     attr_flags;
    uint8_t     attr_type;
    uint16_t    attr_len;
    uint8_t     attr_val[];
} msg_update_attr_t;

typedef struct __attribute__((packed)) {
    uint8_t     attr_flags;
    uint8_t     attr_type;
    uint16_t    attr_len;
    uint32_t    attr_id;
    uint32_t    attr_seq;
    uint8_t     attr_val[];
} msg_update_attr_lsencap_t;
 
#define INITIAL_SEQUENCE_NUMBER 0x80000001  /* -N + 1 */
#define MAX_SEQUENCE_NUMBER     0x7fffffff  /* N - 1*/
 
 
/* attributes */
 

enum af {
    /* RFC3219 */
    AF_DECIMAL = 1,
    AF_PENTADECIMAL,
    AF_E164,
    /* RFC5140 */
    AF_TRUNKGROUP,
    AF_CARRIER
};

extern const char *af_strs[];

enum app_proto {
    /* RFC3219 */
    APP_PROTO_SIP = 1,              
    APP_PROTO_H323_225_0_Q931,      
    APP_PROTO_H323_225_0_RAS,       
    APP_PROTO_H323_225_0_ANNEXG,    
    APP_PROTO_IAX2                  
};

const char *app_proto_str(int app_proto);

typedef struct __attribute__((packed)) {
    uint16_t    route_af;
    uint16_t    route_app_proto;
    uint16_t    route_len;
    char        route_addr[];
} route_t;

typedef route_t attr_withdrawnroutes_t[];
 

typedef route_t attr_reachableroutes_t[];
 

 
typedef struct __attribute__((packed)) {
    uint32_t    nexthopserver_itad;
    uint16_t    nexthopserver_serverlen;
    char        nexthopserver_server[];
} attr_nexthopserver_t;
 

enum itadpath_type {
    ITADPATH_TYPE_AP_SET = 1,
    ITADPATH_TYPE_AP_SEQUENCE
};

typedef struct __attribute__((packed)) {
    uint8_t     itadpath_type;
    uint8_t     itadpath_len;       
    uint32_t    itadpath_segs[];    
} itadpath_t;

typedef itadpath_t attr_advertisementpath_t;
 

typedef itadpath_t attr_routedpath_t;
 

typedef void attr_atomicaggregate_t;
 

typedef uint32_t attr_localpref_t;
 

typedef uint32_t attr_multiexitdisc_t;
 

typedef struct __attribute__((packed)) {
    uint32_t    community_itad;
    uint32_t    community_id;
} community_t;

#define COMMUNITY_NO_EXPORT ((community_t){ 0x00000000, 0xffffff01 })

typedef community_t attr_communities_t[];
 

typedef uint32_t attr_itadtopology_t[];
 

typedef void attr_convertedroute_t;
 
 
/* future RFC5115 and RFC5140 attributes go here */
 

typedef void msg_keepalive_t;
 

enum notif_code {
    NOTIF_CODE_ERROR_MSG = 1,
    NOTIF_CODE_ERROR_OPEN,
    NOTIF_CODE_ERROR_UPDATE,
    NOTIF_CODE_ERROR_EXPIRED,
    NOTIF_CODE_ERROR_STATE,
    NOTIF_CODE_CEASE
};

extern const char *notif_code_strs[];

enum notif_subcode_msg {
    NOTIF_SUBCODE_MSG_BAD_LEN = 1,
    NOTIF_SUBCODE_MSG_BAD_TYPE
};

extern const char *notif_subcode_msg_strs[];

enum notif_subcode_open {
    NOTIF_SUBCODE_OPEN_UNSUP_VERSION = 1,
    NOTIF_SUBCODE_OPEN_BAD_ITAD,
    NOTIF_SUBCODE_OPEN_BAD_ID,
    NOTIF_SUBCODE_OPEN_UNSUP_OPT,
    NOTIF_SUBCODE_OPEN_BAD_HOLD,
    NOTIF_SUBCODE_OPEN_UNSUP_CAP,
    NOTIF_SUBCODE_OPEN_CAP_MISMATCH
};

extern const char *notif_subcode_open_strs[];

enum notif_subcode_update {
    NOTIF_SUBCODE_UPDATE_MALFORM_ATTR = 1,
    NOTIF_SUBCODE_UPDATE_UNK_WELLKNOWN_ATTR,
    NOTIF_SUBCODE_UPDATE_MISS_WELLKNOWN_ATTR,
    NOTIF_SUBCODE_UPDATE_BAD_ATTR_FLAG,
    NOTIF_SUBCODE_UPDATE_BAD_ATTR_LEN,
    NOTIF_SUBCODE_UPDATE_INVAL_ATTR
};

extern const char *notif_subcode_update_strs[];

extern const char **notif_code_subcodes_strs[];

typedef struct __attribute__((packed)) {
    uint8_t     notif_error_code;
    uint8_t     notif_error_subcode;
    uint8_t     notif_data[];
} msg_notif_t;
 
 
/* serialization/deserialization functions */

typedef enum runtime_errors_e {
    /* Serialization and deserialization */
    ERROR_BUFF = -1,                
    ERROR_BUFFLEN = -2,             
    ERROR_HOLD = -3,                
    ERROR_ITAD = -4,                
    ERROR_NOTIF_ERROR_CODE = -5,    
    ERROR_NOTIF_ERROR_SUBCODE = -6, 
    /* Deserialization specific */
    ERROR_INCOMPLETE = -7,          
    ERROR_MSGTYPE = -8,             
    ERROR_VERSION = -9,             
    ERROR_OPT = -10,                
    ERROR_CAPINFO_CODE = -11,       
    ERROR_AF = -12,                 
    ERROR_APP_PROTO = -13,          
    ERROR_TRANS = -14,              
    ERROR_ATTR_TYPE = -15,          
    ERROR_ATTR_FLAG_WELL_KNOWN = -16,
    ERROR_ATTR_FLAG_LSENCAP = -17,  
    ERROR_ITADPATH_TYPE = -18,      
    ERROR_COMMUNITY_ITAD = -19      
} runtime_error_t;

extern const char *runtime_error_strs[];
 
 
/* default timers */
 
#define TIMER_CONNECT_RETRY             120
#define TIMER_HOLD_TIME                 90
#define TIMER_KEEPALIVE                 30
#define TIMER_MAX_PURGE_TIME            10
#define TIMER_DISABLE_TIME              180
#define TIMER_MIN_ITAD_ORIG_INT         30
#define TIMER_MIN_ROUTE_ADVERT_INT      30
 
 
/* default attribute values (when not present) */
 
#define DEF_LOCAL_PREF                  100
#define DEF_METRIC                      100
 
 
/* objects */

extern const capinfo_routetype_t supported_routetypes[];
extern const size_t supported_routetypes_size;
 
 
/* macros */

#define PROTO_TCP_PORT  6069

#define PROTO_TRY(o, res, a) \
    res = o; \
    if (res < 0) { \
        ERROR("protocol error: %s", runtime_error_strs[-res]); \
        a; \
    }
 
 
/* message serializers
 * sizes are in element count, not bytes
 */

runtime_error_t new_msg_open(void *buff, size_t len, uint16_t hold,
    uint32_t itad, uint32_t id, const capinfo_routetype_t *capinfo_routetypes,
    size_t routetypes_size, capinfo_transmode_t capinfo_transmode);

runtime_error_t new_msg_update(void *buff, size_t len,
    const msg_update_attr_t **attrs, size_t attrs_size);

runtime_error_t new_msg_keepalive(void *buff, size_t len);

runtime_error_t new_msg_notif(void *buff, size_t len, uint8_t error_code,
    uint8_t error_subcode, size_t datalen, const void *data);
 
 
/* UPDATE attribute serializers */

runtime_error_t new_route(void *buff, size_t len, uint16_t af,
    uint16_t app_proto, const char *addr);

runtime_error_t new_attr_withdrawnroutes(void *buff, size_t len, int lsencap,
    uint32_t id, uint32_t seq, const void *routes, size_t routes_size);

runtime_error_t new_attr_reachableroutes(void *buff, size_t len, int lsencap,
    uint32_t id, uint32_t seq, const void *routes, size_t routes_size);

runtime_error_t new_attr_nexthopserver(void *buff, size_t len,
    uint32_t next_itad, const char *server);

runtime_error_t new_attr_advertisementpath(void *buff, size_t len, uint8_t type,
    const uint32_t *segs, uint16_t segs_size);

runtime_error_t new_attr_routedpath(void *buff, size_t len, uint8_t type,
    const uint32_t *segs, uint16_t segs_size);

runtime_error_t new_attr_atomicaggregate(void *buff, size_t len);

runtime_error_t new_attr_localpref(void *buff, size_t len, uint32_t localpref);

runtime_error_t new_attr_multiexitdisc(void *buff, size_t len, uint32_t metric);

runtime_error_t new_attr_communities(void *buff, size_t len,
    const community_t *communities, size_t communities_size);

runtime_error_t new_attr_itadtopology(void *buff, size_t len, uint32_t id,
    uint32_t seq, const uint32_t *itads, size_t itads_size);

runtime_error_t new_attr_convertedroute(void *buff, size_t len);
 
 
/* deserializers */
 
/* messages */

runtime_error_t parse_msg(void *buff, size_t len, msg_t **msg_out);
 
 
/* message OPEN
 */

runtime_error_t parse_msg_open(void *buff, size_t len,
    msg_open_t **open_out);

runtime_error_t parse_msg_open_opt(void *buff, size_t len,
    msg_open_opt_t **opt_out);

runtime_error_t parse_capinfo(void *buff, size_t len,
    capinfo_t **capinfo_out);

runtime_error_t parse_capinfo_routetype(void *buff, size_t len,
    capinfo_routetype_t **routetype_out);

runtime_error_t parse_capinfo_transmode(void *buff, size_t len,
    capinfo_transmode_t **transmode_out);
 
 
/* message UPDATE
 * list of attributes
 */

runtime_error_t parse_msg_update_attr(void *buff, size_t len,
    msg_update_attr_t **attr_out);

runtime_error_t parse_msg_update_attr_lsencap(void *buff, size_t len,
    msg_update_attr_lsencap_t **attr_out);
 
 
/* attributes */

runtime_error_t parse_attr_nexthopserver(void *buff, size_t len,
    attr_nexthopserver_t **nexthop_out);

runtime_error_t parse_route(void *buff, size_t len,
    route_t **route_out);

runtime_error_t parse_itadpath(void *buff, size_t len,
    itadpath_t **itadpath_out);

runtime_error_t parse_attr_localpref(void *buff, size_t len,
    attr_localpref_t **localpref_out);

runtime_error_t parse_attr_multiexitdisc(void *buff, size_t len,
    attr_multiexitdisc_t **multiexitdisc_out);

runtime_error_t parse_community(void *buff, size_t len,
    community_t **community_out);

runtime_error_t parse_itad(void *buff, size_t len,
    uint32_t **itad_out);
 
 
 
/* message KEEPALIVE
 * (empty, no parser)
 */
 
 
/* message NOTIFICATION
 */

runtime_error_t parse_msg_notif(void *buff, size_t len,
    msg_notif_t **notif_out);

const char *notif_code_subcode_str(int code, int subcode);
 
 
#endif /* _PROTOCOL_H */