#ifndef _rtp_internal_h_
#define _rtp_internal_h_

#include "rtp.h"
#include "rtp-header.h"
#include "rtcp-header.h"
#include "rtp-member.h"
#include "rtp-member-list.h"
#include <stdlib.h>
#include <string.h>
#include <assert.h>

#define MIN(a, b)       ((a) < (b) ? (a) : (b))
#define MAX(a, b)       ((a) > (b) ? (a) : (b))
#define ARRAY_SIZE(arr) (sizeof(arr) / sizeof((arr)[0]))

struct rtp_context {
    struct rtp_event_t handler;
    void *cbparam;

    void *members; // rtp source list
    void *senders; // rtp sender list
    struct rtp_member *self;

    // RTP/RTCP
    int avg_rtcp_size;
    int rtcp_bw;
    int rtcp_cycle; // for RTCP SDES
    int frequence;
    int init;
    int role;
};

struct rtp_member *rtp_sender_fetch(struct rtp_context *ctx, uint32_t ssrc);
struct rtp_member *rtp_member_fetch(struct rtp_context *ctx, uint32_t ssrc);

int rtcp_input_rtp(struct rtp_context *ctx, const void *data, int bytes);
int rtcp_input_rtcp(struct rtp_context *ctx, const void *data, int bytes);

int rtcp_rr_pack(struct rtp_context *ctx, uint8_t *data, int bytes);
int rtcp_sr_pack(struct rtp_context *ctx, uint8_t *data, int bytes);
int rtcp_sdes_pack(struct rtp_context *ctx, uint8_t *data, int bytes);
int rtcp_bye_pack(struct rtp_context *ctx, uint8_t *data, int bytes);
int rtcp_app_pack(struct rtp_context *ctx, uint8_t *ptr, int bytes, const char name[4], const void *app, int len);
int rtcp_rtpfb_pack(struct rtp_context *ctx, uint8_t *data, int bytes, enum rtcp_rtpfb_type_t id,
                    const rtcp_rtpfb_t *rtpfb);
int rtcp_psfb_pack(struct rtp_context *ctx, uint8_t *data, int bytes, enum rtcp_psfb_type_t id,
                   const rtcp_psfb_t *psfb);
int rtcp_xr_pack(struct rtp_context *ctx, uint8_t *data, int bytes, enum rtcp_xr_type_t id, const rtcp_xr_t *xr);
void rtcp_rr_unpack(struct rtp_context *ctx, const rtcp_header_t *header, const uint8_t *data, size_t bytes);
void rtcp_sr_unpack(struct rtp_context *ctx, const rtcp_header_t *header, const uint8_t *data, size_t bytes);
void rtcp_sdes_unpack(struct rtp_context *ctx, const rtcp_header_t *header, const uint8_t *data, size_t bytes);
void rtcp_bye_unpack(struct rtp_context *ctx, const rtcp_header_t *header, const uint8_t *data, size_t bytes);
void rtcp_app_unpack(struct rtp_context *ctx, const rtcp_header_t *header, const uint8_t *data, size_t bytes);
void rtcp_rtpfb_unpack(struct rtp_context *ctx, const rtcp_header_t *header, const uint8_t *data, size_t bytes);
void rtcp_psfb_unpack(struct rtp_context *ctx, const rtcp_header_t *header, const uint8_t *data, size_t bytes);
void rtcp_xr_unpack(struct rtp_context *ctx, const rtcp_header_t *header, const uint8_t *data, size_t bytes);

int rtcp_report_block(struct rtp_member *sender, uint8_t *ptr, int bytes);

uint64_t rtpclock(void);
uint64_t ntp2clock(uint64_t ntp);
uint64_t clock2ntp(uint64_t clock);

uint32_t rtp_ssrc(void);

#endif /* !_rtp_internal_h_ */