#pragma once
#include <osmocom/core/linuxlist.h>
#include <osmocom/netif/stream.h>

#include <osmocom/sbcap/sbcap_common.h>

#include "cbc_data.h"

#define SBcAP_SCTP_PORT 29168
typedef struct SBcAP_SBC_AP_PDU SBcAP_SBC_AP_PDU_t;
#define LOGPSBCAPC(link, level, fmt, args...) \
	LOGP(DSBcAP, level, "%s: " fmt, cbc_sbcap_link_name(link), ## args)

struct cbc_sbcap_link;
struct osmo_fsm_inst;
struct cbc_peer;

/* Holder of all SBc-AP conn related information: */
struct cbc_sbcap_mgr {
	/* libosmo-netif stream server */
	struct osmo_stream_srv_link *srv_link;

	/* MMEs / links connected to this CBC */
	struct llist_head links;

	/* receive call-back; called for every received message */
	int (*rx_cb)(struct cbc_sbcap_link *link, SBcAP_SBC_AP_PDU_t *pdu);
};
struct cbc_sbcap_mgr *cbc_sbcap_mgr_alloc(void *ctx);
int cbc_sbcap_mgr_open_srv(struct cbc_sbcap_mgr *mgr);

/* an SBc-AP link with a single (remote) peer connected to us */
struct cbc_sbcap_link {
	/* entry in osmo_sbcap_cbc.links */
	struct llist_head list;
	struct osmo_fsm_inst *fi;
	struct cbc_peer *peer;
	bool is_client;
	union {
		struct osmo_stream_srv *srv_conn;
		struct osmo_stream_cli *cli_conn;
		void *conn; /* used when we just care about the pointer */
	};
};

struct cbc_sbcap_link *cbc_sbcap_link_alloc(struct cbc_sbcap_mgr *cbc, struct cbc_peer *peer);
void cbc_sbcap_link_free(struct cbc_sbcap_link *link);
const char *cbc_sbcap_link_name(const struct cbc_sbcap_link *link);
int cbc_sbcap_link_open_cli(struct cbc_sbcap_link *link);
int cbc_sbcap_link_tx(struct cbc_sbcap_link *link, SBcAP_SBC_AP_PDU_t *pdu);
void cbc_sbcap_link_close(struct cbc_sbcap_link *link);
int cbc_sbcap_link_rx_cb(struct cbc_sbcap_link *link, SBcAP_SBC_AP_PDU_t *pdu);