#include <ctype.h>
#include <json.h>

#include "cdr.h"
#include "medmysql.h"
#include "medredis.h"
#include "config.h"
#include "mediator.h"

static int cdr_create_cdrs(GQueue *records,
        cdr_entry_t **cdrs, uint64_t *cdr_count, uint64_t *alloc_size, uint8_t *trash, int do_intermediate);
static int cdr_fill_record(cdr_entry_t *cdr);
static void cdr_set_provider(cdr_entry_t *cdr);


static const char* cdr_map_status(const char *sip_status)
{
    if(strncmp("200", sip_status, 3) == 0)
    {
        return CDR_STATUS_OK;
    }
    if(strncmp("480", sip_status, 3) == 0)
    {
        return CDR_STATUS_NA;
    }
    if(strncmp("487", sip_status, 3) == 0)
    {
        return CDR_STATUS_CANCEL;
    }
    if(strncmp("486", sip_status, 3) == 0)
    {
        return CDR_STATUS_BUSY;
    }
    if(strncmp("408", sip_status, 3) == 0)
    {
        return CDR_STATUS_TIMEOUT;
    }
    if(strncmp("404", sip_status, 3) == 0)
    {
        return CDR_STATUS_OFFLINE;
    }

    return CDR_STATUS_UNKNOWN;
}


static void free_cdrs(cdr_entry_t **cdrs, uint64_t cdr_count) {
    if (!*cdrs)
        return;

    for (uint64_t i = 0; i < cdr_count; i++) {
        cdr_entry_t *cdr = &(*cdrs)[i];

#define F(f) g_string_free(cdr->f, TRUE);
#define FA(f, a) for (unsigned int j = 0; j < a; j++) g_string_free(cdr->f[j], TRUE);

#include "cdr_field_names.inc"

#undef F
#undef FA
    }

    g_free(*cdrs);
    *cdrs = NULL;
}


int cdr_process_records(GQueue *records, uint64_t *ext_count,
        struct medmysql_batches *batches, int do_intermediate)
{
    int ret = 0;
    uint8_t trash = 0;
    int timed_out = 0;

    uint16_t msg_invites = 0;
    uint16_t msg_byes = 0;
    uint16_t msg_unknowns = 0;
    uint16_t invite_200 = 0;

    med_entry_t *first = g_queue_peek_head(records);
    char *callid = first->callid;
    int has_redis = 0, has_mysql = 0;


    cdr_entry_t *cdrs = NULL;
    uint64_t cdr_count, alloc_size = 0;

    *ext_count = 0;

    for (GList *l = records->head; l; l = l->next)
    {
        med_entry_t *e = l->data;

        if (e->timed_out)
            timed_out = 1;

        if(e->method == MED_INVITE)
        {
            ++msg_invites;
            if(strncmp("200", e->sip_code, 3) == 0)
            {
                ++invite_200;
            }
        }
        else if(e->method == MED_BYE)
        {
            ++msg_byes;
        }
        else
        {
            if (e->valid)
                L_DEBUG("Unrecognized record with method '%s' for cid '%s'\n", e->sip_method, callid);
            ++msg_unknowns;
        }

        if (check_shutdown())
            return 1;

        if (e->redis)
            has_redis = 1;
        else
            has_mysql = 1;
    }

    L_DEBUG("%d INVITEs, %d BYEs, %d unrecognized", msg_invites, msg_byes, msg_unknowns);

    if(msg_invites > 0)
    {
        if(msg_byes > 0 || do_intermediate || timed_out || invite_200 == 0)
        {
            if(/*msg_byes > 2*/ 0)
            {
                L_WARNING("Multiple (%d) BYE messages for callid '%s' found, trashing...",
                        msg_byes, callid);
                trash = 1;
            }
            else
            {
                if(cdr_create_cdrs(records, &cdrs, &cdr_count, &alloc_size, &trash, do_intermediate) != 0)
                    goto error;
                else
                {
                    *ext_count = cdr_count;
                    if(cdr_count > 0)
                    {
                        if(config_dumpcdr)
                        {
                            /* cdr_log_records(cdrs, cdr_count); */
                        }

                        int insert_ret = medmysql_insert_cdrs(cdrs, cdr_count, batches);

                        if(insert_ret < 0)
                        {
                            goto error;
                        }
                        else if (insert_ret == 0)
                        {
                            if (has_redis)
                            {
                                if(medredis_backup_entries(records) != 0)
                                    goto error;
                            }
                            if (has_mysql)
                            {
                                if(medmysql_backup_entries(callid, batches) != 0)
                                    goto error;
                            }
                            if (config_intermediate_interval)
                            {
                                if(medmysql_delete_intermediate(cdrs, cdr_count, batches) != 0)
                                    goto error;
                            }
                        }
                        else if (insert_ret == 1)
                            ; // do nothing - intermediate CDR has been created
                        else
                            goto error;

                    }
                    else
                    {
                        /* TODO: no CDRs created? */
                    }
                    free_cdrs(&cdrs, alloc_size);
                    cdrs = NULL;
                }
            }
        }
        else
        {
            /*
            L_DEBUG("No BYE message for callid '%s' found, skipping...",
                    callid);
            */
            trash = 1;
        }
    }
    else
    {
        /*L_WARNING("No INVITE message for callid '%s' found, trashing...", callid);*/
        trash = 1;
    }

    if(trash)
    {
        if (has_redis)
        {
            if(medredis_trash_entries(records) != 0)
                goto error;
        }
        if (has_mysql)
        {
            if(medmysql_trash_entries(callid, batches) != 0)
                goto error;
        }
    }
    return ret;


error:
    if(cdrs)
        free_cdrs(&cdrs, alloc_size);
    return -1;
}

static inline int hexval(unsigned char c) {
    if (c >= '0' && c <= '9')
        return c - '0';
    if (c >= 'a' && c <= 'f')
        return 10 + c - 'a';
    if (c >= 'A' && c <= 'F')
        return 10 + c - 'A';
    return -1;
}

/* un-uri-escape string in place */
static void uri_unescape(GString *str) {
    unsigned char *s;
    unsigned int c;
    int cv;
    GString *dup = g_string_new("");

    s = (unsigned char *) str->str;

    while (*s) {
        if (*s != '%') {
copy:
            g_string_append_c(dup, *s);
            s++;
            continue;
        }

        cv = hexval(s[1]);
        if (cv == -1)
            goto copy;
        c = cv << 4;
        cv = hexval(s[2]);
        if (cv == -1)
            goto copy;
        c |= cv;
        if (!c) /* disallow null bytes */
            goto copy;

        g_string_append_c(dup, c);
        s += 3;
    }
    g_string_truncate(str, 0);
    g_string_append_len(str, dup->str, dup->len);
    g_string_free(dup, TRUE);
}

static int cdr_parse_json_get_uint8(json_object *obj, const char *key, uint8_t *outp) {
    json_object *int_obj;
    if (!json_object_object_get_ex(obj, key, &int_obj))
        return 0;
    if (!json_object_is_type(int_obj, json_type_int))
        return 0;
    *outp = json_object_get_int64(int_obj);
    return 1;
}

static int cdr_parse_json_get_uint8_clamped(json_object *obj, const char *key, uint8_t *outp, uint8_t min, uint8_t max) {
    if(!cdr_parse_json_get_uint8(obj, key, outp))
        return 0;
    if (*outp > max)
        *outp = max;
    else if (*outp < min)
        *outp = min;
    return 1;
}

static int cdr_parse_json_get_uint64(json_object *obj, const char *key, uint64_t *outp) {
    json_object *int_obj;
    if (!json_object_object_get_ex(obj, key, &int_obj))
        return 0;
    if (!json_object_is_type(int_obj, json_type_int))
        return 0;
    *outp = json_object_get_int64(int_obj);
    return 1;
}

static int cdr_parse_json_get_int(json_object *obj, const char *key, int *outp) {
    json_object *int_obj;
    if (!json_object_object_get_ex(obj, key, &int_obj))
        return 0;
    if (!json_object_is_type(int_obj, json_type_int))
        return 0;
    *outp = json_object_get_int64(int_obj);
    return 1;
}

static int cdr_parse_json_get_int_clamped(json_object *obj, const char *key, int *outp, int min, int max) {
    if(!cdr_parse_json_get_int(obj, key, outp))
        return 0;
    if (*outp > max)
        *outp = max;
    else if (*outp < min)
        *outp = min;
    return 1;
}

static int cdr_parse_json_get_double(json_object *obj, const char *key, double *outp) {
    json_object *int_obj;
    if (!json_object_object_get_ex(obj, key, &int_obj))
        return 0;
    if (!json_object_is_type(int_obj, json_type_double))
        return 0;
    *outp = json_object_get_double(int_obj);
    return 1;
}

static int cdr_parse_json_get_double_clamped(json_object *obj, const char *key, double *outp, double min, double max) {
    if(!cdr_parse_json_get_double(obj, key, outp))
        return 0;
    if (*outp > max)
        *outp = max;
    else if (*outp < min)
        *outp = min;
    return 1;
}

static int cdr_parse_json_get_g_string(json_object *obj, const char *key, GString *outp) {
    json_object *str_obj;
    if (!json_object_object_get_ex(obj, key, &str_obj))
        return 0;
    if (!json_object_is_type(str_obj, json_type_string))
        return 0;
    // TODO: if string equals to <null>, null or NULL set it to an empty string '\0'
    g_string_assign(outp, json_object_get_string(str_obj));
    return 1;
}

static int cdr_parse_srcleg_json(json_object *json, cdr_entry_t *cdr)
{
    // source_user_id
    if (!cdr_parse_json_get_g_string(json, "uuid", cdr->source_user_id)) {
        L_ERROR("Call-Id '%s' does not contain 'uuid' key (source user id), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // source_user
    if (!cdr_parse_json_get_g_string(json, "u", cdr->source_user)) {
        L_ERROR("Call-Id '%s' does not contain 'u' key (source user), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // source_domain
    if (!cdr_parse_json_get_g_string(json, "d", cdr->source_domain)) {
        L_ERROR("Call-Id '%s' does not contain 'd' key (source domain), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // source_cli
    if (!cdr_parse_json_get_g_string(json, "cli", cdr->source_cli)) {
        L_ERROR("Call-Id '%s' does not contain 'cli' key (source cli), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // source_ext_subscriber_id
    if (!cdr_parse_json_get_g_string(json, "s_id", cdr->source_ext_subscriber_id)) {
        L_ERROR("Call-Id '%s' does not contain 's_id' key (source external subscriber id), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }
    uri_unescape(cdr->source_ext_subscriber_id);

    // source_ext_contract_id
    if (!cdr_parse_json_get_g_string(json, "c_id", cdr->source_ext_contract_id)) {
        L_ERROR("Call-Id '%s' does not contain 'c_id' key (source external contract id), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }
    uri_unescape(cdr->source_ext_contract_id);

    // source_account_id
    if (!cdr_parse_json_get_uint64(json, "a_id", &cdr->source_account_id)) {
        L_ERROR("Call-Id '%s' does not contain 'a_id' key (source account id), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // peer_auth_user
    if (!cdr_parse_json_get_g_string(json, "pau", cdr->peer_auth_user)) {
        L_ERROR("Call-Id '%s' does not contain 'pau' key (peer auth user), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // peer_auth_realm
    if (!cdr_parse_json_get_g_string(json, "par", cdr->peer_auth_realm)) {
        L_ERROR("Call-Id '%s' does not contain 'par' key (peer auth realm), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // source_clir
    if (!cdr_parse_json_get_uint8_clamped(json, "clir", &cdr->source_clir, 0, 1)) {
        L_ERROR("Call-Id '%s' does not contain 'clir' key (source account id), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // call_type
    if (!cdr_parse_json_get_g_string(json, "s", cdr->call_type)) {
        L_ERROR("Call-Id '%s' does not contain 's' key (call type), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // source_ip
    if (!cdr_parse_json_get_g_string(json, "ip", cdr->source_ip)) {
        L_ERROR("Call-Id '%s' does not contain 'ip' key (source ip), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // init_time
    if (!cdr_parse_json_get_double(json, "t", &cdr->init_time)) {
        L_ERROR("Call-Id '%s' does not contain 't' key (source init time), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    json_object *temp_value;
    // source_gpp
    if(!json_object_object_get_ex(json, "gpp", &temp_value))
    {
        L_ERROR("Call-Id '%s' does not contain 'gpp' key (source gpp list), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }
    if (!json_object_is_type(temp_value, json_type_array)) {
        L_ERROR("Call-Id '%s' key 'gpp' doesn't contain an array, '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }
    if(json_object_array_length(temp_value) != 10)
    {
        L_ERROR("Call-Id '%s' has only '%zu' source gpp fields, they should be 10, '%s'", cdr->call_id->str, json_object_array_length(temp_value), json_object_get_string(json));
        goto err;
    }
    int i;
    for(i = 0; i < 10; ++i)
    {
        g_string_assign(cdr->source_gpp[i], json_object_get_string(json_object_array_get_idx(temp_value, i)) ? : "");
    }

    // source_lnp_prefix
    if(!json_object_object_get_ex(json, "lnp_p", &temp_value))
    {
        if (strict_leg_tokens) {    // TODO: "Strict acc fields (move to trash otherwise)" What is the meaning of this param??? is it still necessary
            L_ERROR("Call-Id '%s' does not contain 'lnp_p' key (source lnp prefix), '%s'", cdr->call_id->str, json_object_get_string(json));
            goto err;
        } else {
            g_string_truncate(cdr->source_lnp_prefix, 0);
            g_string_truncate(cdr->source_user_out, 0);
            L_WARNING("Call-Id '%s' does not contain 'lnp_p' key, using empty source lnp prefix and source user out '%s'", cdr->call_id->str, json_object_get_string(json));
            goto ret;
        }
    }
    g_string_assign(cdr->source_lnp_prefix, json_object_get_string(temp_value));

    // source_user_out
    if(!json_object_object_get_ex(json, "cli_out", &temp_value))
    {
        if (strict_leg_tokens) {    // TODO: "Strict acc fields (move to trash otherwise)" What is the meaning of this param??? is it still necessary
            L_ERROR("Call-Id '%s' does not contain 'cli_out' key (source user out), '%s'", cdr->call_id->str, json_object_get_string(json));
            goto err;
        } else {
            g_string_truncate(cdr->source_user_out, 0);
            L_WARNING("Call-Id '%s' does not contain 'cli_out' key, using empty source user out '%s'", cdr->call_id->str, json_object_get_string(json));
            goto ret;
        }
    }
    g_string_assign(cdr->source_user_out, json_object_get_string(temp_value));
    uri_unescape(cdr->source_user_out);

    // source_lnp_type
    if (!cdr_parse_json_get_g_string(json, "lnp_t", cdr->source_lnp_type)) {
        L_ERROR("Call-Id '%s' does not contain 'lnp_t' key (source lnp type), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // header_pai
    if (!cdr_parse_json_get_g_string(json, "pai", cdr->header_pai)) {
        L_ERROR("Call-Id '%s' does not contain 'pai' key (P-Asserted-Identity header), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // header_diversion
    if (!cdr_parse_json_get_g_string(json, "div", cdr->header_diversion)) {
        L_ERROR("Call-Id '%s' does not contain 'div' key (Diversion header), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // group
    if (!cdr_parse_json_get_g_string(json, "cid", cdr->group)) {
        L_ERROR("Call-Id '%s' does not contain 'cid' key (group info), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // header_u2u
    if (!cdr_parse_json_get_g_string(json, "u2u", cdr->header_u2u)) {
        L_ERROR("Call-Id '%s' does not contain 'u2u' key (User-to-User header), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // source_lcr_id
    if (!cdr_parse_json_get_uint64(json, "lcr", &cdr->source_lcr_id)) {
        L_DEBUG("Call-Id '%s' does not contain 'lcr' key (source lcr id), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // source_concurrent_calls_quota
    if (!cdr_parse_json_get_g_string(json, "cc_quota", cdr->source_concurrent_calls_quota)) {
        L_DEBUG("Call-Id '%s' does not contain 'cc_quota' key (source concurrent calls quota), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // source_concurrent_calls_count
    if (!cdr_parse_json_get_g_string(json, "cc_sub", cdr->source_concurrent_calls_count)) {
        L_DEBUG("Call-Id '%s' does not contain 'cc_sub' key (source concurrent calls count), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // source_concurrent_calls_count_customer
    if (!cdr_parse_json_get_g_string(json, "cc_cust", cdr->source_concurrent_calls_count_customer)) {
        L_DEBUG("Call-Id '%s' does not contain 'cc_cust' key (source concurrent calls count customer), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // source_last_hih
    if (!cdr_parse_json_get_g_string(json, "last_hih", cdr->source_last_hih)) {
        L_DEBUG("Call-Id '%s' does not contain 'last_hih' key (source last hih), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // header_ppi
    if (!cdr_parse_json_get_g_string(json, "ppi", cdr->header_ppi)) {
        L_ERROR("Call-Id '%s' does not contain 'ppi' key (P-Preferred-Identity header), '%s'", cdr->call_id->str, json_object_get_string(json));
        /// Simply return 0 in order to avoid issues with ACC records in the OLD format during an upgrade
        /// Added in mr12.5, it should be changed to 'err' in mr13.+
        /// goto err;
        goto ret;
    }

ret:
    return 0;

err:
    return -1;
}

static int cdr_parse_dstleg_json(json_object *json, cdr_entry_t *cdr)
{
    // split
    if (!cdr_parse_json_get_uint8(json, "plu", &cdr->split)) {
        L_ERROR("Call-Id '%s' does not contain 'plu' key (split flag), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // destination_ext_subscriber_id
    if (!cdr_parse_json_get_g_string(json, "s_id", cdr->destination_ext_subscriber_id)) {
        L_ERROR("Call-Id '%s' does not contain 's_id' key (destination external subscriber id), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }
    uri_unescape(cdr->destination_ext_subscriber_id);

    // destination_ext_contract_id
    if (!cdr_parse_json_get_g_string(json, "c_id", cdr->destination_ext_contract_id)) {
        L_ERROR("Call-Id '%s' does not contain 'c_id' key (destination external contract id), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }
    uri_unescape(cdr->destination_ext_contract_id);

    // destination_account_id
    if (!cdr_parse_json_get_uint64(json, "a_id", &cdr->destination_account_id)) {
        L_ERROR("Call-Id '%s' does not contain 'a_id' key (destination account id), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // destination_dialed
    if (!cdr_parse_json_get_g_string(json, "dialed", cdr->destination_dialed)) {
        L_ERROR("Call-Id '%s' does not contain 'dialed' key (dialed digit), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // destination_user_id
    if (!cdr_parse_json_get_g_string(json, "uuid", cdr->destination_user_id)) {
        L_ERROR("Call-Id '%s' does not contain 'uuid' key (destination user id), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // destination_user
    if (!cdr_parse_json_get_g_string(json, "u", cdr->destination_user)) {
        L_ERROR("Call-Id '%s' does not contain 'u' key (destination user), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // destination_domain
    if (!cdr_parse_json_get_g_string(json, "d", cdr->destination_domain)) {
        L_ERROR("Call-Id '%s' does not contain 'd' key (destination domain), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // destination_user_in
    if (!cdr_parse_json_get_g_string(json, "u_in", cdr->destination_user_in)) {
        L_ERROR("Call-Id '%s' does not contain 'u_in' key (incoming destination user), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // destination_domain_in
    if (!cdr_parse_json_get_g_string(json, "d_in", cdr->destination_domain_in)) {
        L_ERROR("Call-Id '%s' does not contain 'd_in' key (incoming destination domain), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // destination_lcr_id
    if (!cdr_parse_json_get_uint64(json, "lcr", &cdr->destination_lcr_id)) {
        L_ERROR("Call-Id '%s' does not contain 'lcr' key (lcr id), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    json_object *temp_value;
    // destination_gpp
    if(!json_object_object_get_ex(json, "gpp", &temp_value))
    {
        L_ERROR("Call-Id '%s' does not contain 'gpp' key (source gpp list), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }
    if (!json_object_is_type(temp_value, json_type_array)) {
        L_ERROR("Call-Id '%s' key 'gpp' doesn't contain an array, '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }
    if(json_object_array_length(temp_value) != 10)
    {
        L_ERROR("Call-Id '%s' has only '%zu' destination gpp fields, they should be 10, '%s'", cdr->call_id->str, json_object_array_length(temp_value), json_object_get_string(json));
        goto err;
    }
    int i;
    for(i = 0; i < 10; ++i)
    {
        g_string_assign(cdr->destination_gpp[i], json_object_get_string(json_object_array_get_idx(temp_value, i)) ? : "");
    }

    // destination_lnp_prefix
    if(!json_object_object_get_ex(json, "lnp_p", &temp_value))
    {
        if (strict_leg_tokens) {    // TODO: "Strict acc fields (move to trash otherwise)" What is the meaning of this param??? is it still necessary
            L_ERROR("Call-Id '%s' does not contain 'lnp_p' key (destination lnp prefix), '%s'", cdr->call_id->str, json_object_get_string(json));
            goto err;
        } else {
            g_string_truncate(cdr->destination_lnp_prefix, 0);
            g_string_truncate(cdr->destination_user_out, 0);
            L_WARNING("Call-Id '%s' does not contain 'lnp_p' key, using empty destination lnp prefix and destination user out '%s'", cdr->call_id->str, json_object_get_string(json));
            goto ret;
        }
    }
    g_string_assign(cdr->destination_lnp_prefix, json_object_get_string(temp_value));

    // destination_user_out
    if(!json_object_object_get_ex(json, "u_out", &temp_value))
    {
        if (strict_leg_tokens) {    // TODO: "Strict acc fields (move to trash otherwise)" What is the meaning of this param??? is it still necessary
            L_ERROR("Call-Id '%s' does not contain 'cli_out' key (source user out), '%s'", cdr->call_id->str, json_object_get_string(json));
            goto err;
        } else {
            g_string_truncate(cdr->destination_user_out, 0);
            L_WARNING("Call-Id '%s' does not contain 'cli_out' key, using empty destination user out '%s'", cdr->call_id->str, json_object_get_string(json));
            goto ret;
        }
    }
    g_string_assign(cdr->destination_user_out, json_object_get_string(temp_value));
    uri_unescape(cdr->destination_user_out);

    // destination_lnp_type
    if (!cdr_parse_json_get_g_string(json, "lnp_t", cdr->destination_lnp_type)) {
        L_ERROR("Call-Id '%s' does not contain 'lnp_t' key (destination lnp type), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // furnished_charging_info
    if (!cdr_parse_json_get_g_string(json, "fci", cdr->furnished_charging_info)) {
        L_ERROR("Call-Id '%s' does not contain 'fci' key (furnished charging info), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // destination_concurrent_calls_quota
    if (!cdr_parse_json_get_g_string(json, "cc_quota", cdr->destination_concurrent_calls_quota)) {
        L_DEBUG("Call-Id '%s' does not contain 'cc_quota' key (destination concurrent calls quota), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // destination_concurrent_calls_count
    if (!cdr_parse_json_get_g_string(json, "cc_sub", cdr->destination_concurrent_calls_count)) {
        L_DEBUG("Call-Id '%s' does not contain 'cc_sub' key (destination concurrent calls count), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // destination_concurrent_calls_count_customer
    if (!cdr_parse_json_get_g_string(json, "cc_cust", cdr->destination_concurrent_calls_count_customer)) {
        L_DEBUG("Call-Id '%s' does not contain 'cc_cust' key (destination concurrent calls count customer), '%s'", cdr->call_id->str, json_object_get_string(json));
        goto err;
    }

    // hg_ext_response
    if (!cdr_parse_json_get_g_string(json, "hg_ext_response", cdr->hg_ext_response)) {
        L_DEBUG("Call-Id '%s' does not contain 'hg_ext_response' key (hunt group extension response), '%s'", cdr->call_id->str, json_object_get_string(json));
    }

    // r_user
    if (!cdr_parse_json_get_g_string(json, "r_user", cdr->r_user)) {
        L_DEBUG("Call-Id '%s' does not contain 'r_user' key, '%s'", cdr->call_id->str, json_object_get_string(json));
    }

    // responder_number
    if (!cdr_parse_json_get_g_string(json, "r_ua", cdr->r_ua)) {
        L_DEBUG("Call-Id '%s' does not contain 'r_ua' key, '%s'", cdr->call_id->str, json_object_get_string(json));
    }

ret:
    return 0;

err:
    return -1;
}

static int cdr_parse_srcleg_list(char *srcleg, cdr_entry_t *cdr)
{
    char *tmp1, *tmp2;

    tmp2 = srcleg;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated source user id, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->source_user_id, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated source user, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->source_user, tmp2);
    uri_unescape(cdr->source_user);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated source domain, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->source_domain, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;


    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated source cli, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->source_cli, tmp2);
    uri_unescape(cdr->source_cli);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated source external subscriber id, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->source_ext_subscriber_id, tmp2);
    uri_unescape(cdr->source_ext_subscriber_id);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated source external contract id, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->source_ext_contract_id, tmp2);
    uri_unescape(cdr->source_ext_contract_id);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated source account id, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    cdr->source_account_id = atoll(tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated peer auth user, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->peer_auth_user, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated peer auth realm, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->peer_auth_realm, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated source clir status, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    cdr->source_clir = atoi(tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated call type, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->call_type, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated source ip, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->source_ip, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated source init time, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    cdr->init_time = g_strtod(tmp2, NULL);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    int i;
    for(i = 0; i < 10; ++i)
    {
        tmp1 = strchr(tmp2, MED_SEP);
        if(tmp1 == NULL)
        {
            L_ERROR("Call-Id '%s' has no separated source gpp %d, '%s'", cdr->call_id->str, i, tmp2);
            return -1;
        }
        *tmp1 = '\0';
        g_string_assign(cdr->source_gpp[i], tmp2);
        *tmp1 = MED_SEP;
        tmp2 = ++tmp1;
    }

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        if (strict_leg_tokens) {
            L_ERROR("Call-Id '%s' has no separated source lnp prefix, '%s'", cdr->call_id->str, tmp2);
            return -1;
        } else {
            g_string_truncate(cdr->source_lnp_prefix, 0);
            g_string_truncate(cdr->source_user_out, 0);
            L_WARNING("Call-Id '%s' src leg has missing tokens (using empty lnp prefix, user out) '%s'", cdr->call_id->str, tmp2);
            return 0;
        }
    }
    *tmp1 = '\0';
    g_string_assign(cdr->source_lnp_prefix, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        if (strict_leg_tokens) {
            L_ERROR("Call-Id '%s' has no separated source user out, '%s'", cdr->call_id->str, tmp2);
            return -1;
        } else {
            g_string_truncate(cdr->source_user_out, 0);
            L_WARNING("Call-Id '%s' src leg has missing tokens (using empty user out) '%s'", cdr->call_id->str, tmp2);
            return 0;
        }
    }
    *tmp1 = '\0';
    g_string_assign(cdr->source_user_out, tmp2);
    uri_unescape(cdr->source_user_out);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated source lnp type, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->source_lnp_type, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated P-Asserted-Identity header, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->header_pai, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated Diversion header, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->header_diversion, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated group info, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->group, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated User-to-User header, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->header_u2u, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_DEBUG("Call-Id '%s' has no separated source lcr id, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    cdr->source_lcr_id = atoll(tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_DEBUG("Call-Id '%s' has no separated source concurrent calls quota, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->source_concurrent_calls_quota, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_DEBUG("Call-Id '%s' has no separated source concurrent calls count, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->source_concurrent_calls_count, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_DEBUG("Call-Id '%s' has no separated source concurrent calls customer count, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->source_concurrent_calls_count_customer, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated P-Preferred-Identity header, '%s'", cdr->call_id->str, tmp2);
        /// Simply return 0 in order to avoid issues with ACC records in the OLD format during an upgrade
        /// Added in mr12.5, it should be changed to -1 in mr13.+
        return 0;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->header_ppi, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    return 0;
}

static int cdr_parse_dstleg_list(char *dstleg, cdr_entry_t *cdr)
{
    char *tmp1, *tmp2;

    tmp2 = dstleg;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated split flag, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    cdr->split = atoi(tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated destination external subscriber id, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->destination_ext_subscriber_id, tmp2);
    uri_unescape(cdr->destination_ext_subscriber_id);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated destination external contract id, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->destination_ext_contract_id, tmp2);
    uri_unescape(cdr->destination_ext_contract_id);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated destination account id, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    cdr->destination_account_id = atoll(tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated dialed digits", cdr->call_id->str);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->destination_dialed, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated destination user id", cdr->call_id->str);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->destination_user_id, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated destination user", cdr->call_id->str);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->destination_user, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated destination domain", cdr->call_id->str);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->destination_domain, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated incoming destination user", cdr->call_id->str);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->destination_user_in, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated incoming destination domain", cdr->call_id->str);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->destination_domain_in, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated destination lcr id, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    cdr->destination_lcr_id = atoll(tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    int i;
    for(i = 0; i < 10; ++i)
    {
        tmp1 = strchr(tmp2, MED_SEP);
        if(tmp1 == NULL)
        {
            L_ERROR("Call-Id '%s' has no separated destination gpp %d, '%s'", cdr->call_id->str, i, tmp2);
            return -1;
        }
        *tmp1 = '\0';
        g_string_assign(cdr->destination_gpp[i], tmp2);
        *tmp1 = MED_SEP;
        tmp2 = ++tmp1;
    }

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        if (strict_leg_tokens) {
            L_ERROR("Call-Id '%s' has no separated destination lnp prefix, '%s'", cdr->call_id->str, tmp2);
            return -1;
        } else {
            g_string_truncate(cdr->destination_lnp_prefix, 0);
            g_string_truncate(cdr->destination_user_out, 0);
            L_WARNING("Call-Id '%s' dst leg has missing tokens (using empty lnp prefix, user out) '%s'", cdr->call_id->str, tmp2);
            return 0;
        }
    }
    *tmp1 = '\0';
    g_string_assign(cdr->destination_lnp_prefix, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        if (strict_leg_tokens) {
            L_ERROR("Call-Id '%s' has no separated destination user out, '%s'", cdr->call_id->str, tmp2);
            return -1;
        } else {
            g_string_truncate(cdr->destination_user_out, 0);
            L_WARNING("Call-Id '%s' dst leg has missing tokens (using empty user out) '%s'", cdr->call_id->str, tmp2);
            return 0;
        }
    }
    *tmp1 = '\0';
    g_string_assign(cdr->destination_user_out, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated destination lnp type, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->destination_lnp_type, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_ERROR("Call-Id '%s' has no separated furnished charging info, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->furnished_charging_info, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_DEBUG("Call-Id '%s' has no separated destination concurrent calls quota, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->destination_concurrent_calls_quota, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_DEBUG("Call-Id '%s' has no separated destination concurrent calls count, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->destination_concurrent_calls_count, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_DEBUG("Call-Id '%s' has no separated destination concurrent calls customer count, '%s'", cdr->call_id->str, tmp2);
        return -1;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->destination_concurrent_calls_count_customer, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_DEBUG("Call-Id '%s' has no separated hunt group extension response, '%s'", cdr->call_id->str, tmp2);
        return 0;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->hg_ext_response, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_DEBUG("Call-Id '%s' has no separated responder number, '%s'", cdr->call_id->str, tmp2);
        return 0;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->r_user, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    tmp1 = strchr(tmp2, MED_SEP);
    if(tmp1 == NULL)
    {
        L_DEBUG("Call-Id '%s' has no separated response user agent, '%s'", cdr->call_id->str, tmp2);
        return 0;
    }
    *tmp1 = '\0';
    g_string_assign(cdr->r_ua, tmp2);
    *tmp1 = MED_SEP;
    tmp2 = ++tmp1;

    return 0;
}

static int cdr_parse_srcleg(med_entry_t *e, cdr_entry_t *cdr)
{
    cdr_parse_entry(e);
    if (!e->src_leg_json || !json_object_is_type(e->src_leg_json, json_type_object)) {
        L_DEBUG("Analysing srcleg in list format: '%s'", e->src_leg);
        return cdr_parse_srcleg_list(e->src_leg, cdr);
    }
    else {
        L_DEBUG("Analysing srcleg in json format: '%s'", e->src_leg);
        return cdr_parse_srcleg_json(e->src_leg_json, cdr);
    }

    return 0;
}

static int cdr_parse_dstleg(med_entry_t *e, cdr_entry_t *cdr)
{
    cdr_parse_entry(e);
    if (!e->dst_leg_json || !json_object_is_type(e->dst_leg_json, json_type_object)) {
        L_DEBUG("Analysing dstleg in list format: '%s'", e->dst_leg);
        return cdr_parse_dstleg_list(e->dst_leg, cdr);
    }
    else {
        L_DEBUG("Analysing dstleg in json format: '%s'", e->dst_leg);
        return cdr_parse_dstleg_json(e->dst_leg_json, cdr);
    }

    return 0;
}


static int cdr_parse_bye_dstleg(med_entry_t *e, mos_data_t *mos_data) {
    L_DEBUG("Parsing JSON: '%s'", e->dst_leg);

    cdr_parse_entry(e);
    if (!e->dst_leg_json) {
        L_ERROR("Could not parse JSON dst_leg string: '%s'", e->dst_leg);
        return -1;
    }
    if (!json_object_is_type(e->dst_leg_json, json_type_object)) {
        L_ERROR("JSON type is not object: '%s'", e->dst_leg);
        goto err;
    }
    json_object *mos;
    if (!json_object_object_get_ex(e->dst_leg_json, "mos", &mos)
            || !json_object_is_type(mos, json_type_object))
    {
        L_ERROR("JSON object does not contain 'mos' key: '%s'", e->dst_leg);
        goto err;
    }
    if (!cdr_parse_json_get_double_clamped(mos, "avg_score", &mos_data->avg_score, 0, 99)) {
        L_ERROR("JSON object does not contain 'mos.avg_score' key: '%s'", e->dst_leg);
        goto err;
    }
    if (!cdr_parse_json_get_int_clamped(mos, "avg_packetloss", &mos_data->avg_packetloss, 0, 100)) {
        L_ERROR("JSON object does not contain 'mos.avg_packetloss' key: '%s'", e->dst_leg);
        goto err;
    }
    if (!cdr_parse_json_get_int_clamped(mos, "avg_jitter", &mos_data->avg_jitter, 0, 9999)) {
        L_ERROR("JSON object does not contain 'mos.avg_jitter' key: '%s'", e->dst_leg);
        goto err;
    }
    if (!cdr_parse_json_get_int_clamped(mos, "avg_rtt", &mos_data->avg_rtt, 0, 9999)) {
        L_ERROR("JSON object does not contain 'mos.avg_rtt' key: '%s'", e->dst_leg);
        goto err;
    }

    mos_data->filled = 1;
    return 0;

err:
    return -1;
}


static cdr_entry_t *alloc_cdrs(uint64_t cdr_count) {
    cdr_entry_t *cdrs = g_malloc0(sizeof(*cdrs) * cdr_count);
    if (!cdrs)
        return NULL;

    for (uint64_t i = 0; i < cdr_count; i++) {
        cdr_entry_t *cdr = &cdrs[i];

#define F(f) cdr->f = g_string_new("");
#define FA(f, a) for (unsigned int j = 0; j < a; j++) cdr->f[j] = g_string_new("");

#include "cdr_field_names.inc"

#undef F
#undef FA
    }

    return cdrs;
}


static int cdr_create_cdrs(GQueue *records,
        cdr_entry_t **cdrs, uint64_t *cdr_count, uint64_t *alloc_size, uint8_t *trash, int do_intermediate)
{
    uint64_t i = 0, cdr_index = 0;
    uint64_t invites = 0;
    int timed_out = 0;

    char *endtime = NULL;
    double unix_endtime = 0, tmp_unix_endtime = 0;
    const char *call_status;
    mos_data_t mos_data;

    *cdr_count = 0;
    memset(&mos_data, 0, sizeof(mos_data));


    /* get end time from BYE's timestamp */
    for (GList *l = records->head; l; l = l->next)
    {
        med_entry_t *e = l->data;
        if (e->timed_out)
            timed_out = 1;

        if(e->valid && e->method == MED_INVITE)
        {
            ++invites;
        }
        else if(e->method == MED_BYE)
        {
            if (endtime == NULL) {
                endtime = e->timestamp;
                unix_endtime = e->unix_timestamp;
            }
            if (!mos_data.filled)
                cdr_parse_bye_dstleg(e, &mos_data);
        }

        if (check_shutdown())
            return -1;
    }

    if(invites == 0)
    {
        med_entry_t *e = g_queue_peek_head(records);
        L_CRITICAL("No valid INVITEs for creating a cdr, internal error, callid='%s'",
                e->callid);
        return -1;
    }

    /* each INVITE maps to a CDR */
    *cdrs = alloc_cdrs(invites);
    if(*cdrs == NULL)
    {
        L_ERROR("Error allocating memory for cdrs: %s", strerror(errno));
        return -1;
    }
    *alloc_size = invites;

    for (GList *l = records->head; l; l = l->next)
    {
        med_entry_t *e = NULL;
        cdr_entry_t *cdr = NULL;


        cdr = &(*cdrs)[cdr_index];
        e = l->data;

        if (!e->valid)
            continue;

        L_DEBUG("create cdr %" PRIu64 " of %u in batch\n", ++i, records->length);

        call_status = cdr_map_status(e->sip_code);
        if (timed_out)
            call_status = CDR_STATUS_FAILED;

        if(e->method == MED_INVITE && call_status != NULL)
        {
            ++cdr_index;

            L_DEBUG("Creating CDR index %lu\n", cdr_index);

            if(strncmp("200", e->sip_code, 3))
            {
                /* missed calls have duration of 0 */
                tmp_unix_endtime = e->unix_timestamp;
            }
            else
            {
                tmp_unix_endtime = unix_endtime;
                if (!tmp_unix_endtime) {
                    if (do_intermediate && !timed_out) {
                        L_DEBUG("CDR %lu is an intermediate record\n", cdr_index);
                        cdr->intermediate = 1;
                    }
                    else {
                        L_DEBUG("CDR %lu is an expired record\n", cdr_index);
                    }
                    tmp_unix_endtime = time(NULL);
                }
            }

            g_string_assign(cdr->call_id, e->callid);
            cdr->start_time = e->unix_timestamp;
            cdr->duration = (tmp_unix_endtime >= e->unix_timestamp) ? tmp_unix_endtime - e->unix_timestamp : 0;
            g_string_assign(cdr->call_status, call_status);
            g_string_assign(cdr->call_code, e->sip_code);


            cdr->source_carrier_cost = 0;
            cdr->source_reseller_cost = 0;
            cdr->source_customer_cost = 0;
            cdr->destination_carrier_cost = 0;
            cdr->destination_reseller_cost = 0;
            cdr->destination_customer_cost = 0;

            if(cdr_parse_srcleg(e, cdr) < 0)
            {
                if (!cdr->intermediate)
                    *trash = 1;
                return 0;
            }

            if(cdr_parse_dstleg(e, cdr) < 0 && !timed_out)
            {
                if (!cdr->intermediate)
                    *trash = 1;
                return 0;
            }

            if(cdr_fill_record(cdr) != 0)
            {
                // TODO: error handling
            }

            cdr->mos = mos_data;
            g_string_assign(cdr->acc_ref, e->acc_ref);

            L_DEBUG("Created CDR index %lu\n", cdr_index);
        }

        if (check_shutdown())
            return -1;
    }

    *cdr_count = cdr_index;

    /*L_DEBUG("Created %llu CDRs:", *cdr_count);*/

    return 0;
}

static int cdr_fill_record(cdr_entry_t *cdr)
{
    cdr_set_provider(cdr);

    /*
    if(cdr->source_clir)
    {
        strcpy(cdr->source_cli, "anonymous");
    }
    */

    return 0;
}

static void cdr_set_provider(cdr_entry_t *cdr)
{
    char *val;

    if(strcmp("0", cdr->source_user_id->str) != 0)
    {
        if((val = medmysql_lookup_uuid(cdr->source_user_id->str)) != NULL)
        {
            g_string_assign(cdr->source_provider_id, val);
        }
        else
        {
            g_string_assign(cdr->source_provider_id, "0");
        }
    }
    else if (cdr->source_lcr_id) {
        g_string_printf(cdr->source_provider_id,
                "%llu", (unsigned long long) cdr->source_lcr_id);
        val = g_hash_table_lookup(med_peer_id_table, cdr->source_provider_id->str);
        g_string_assign(cdr->source_provider_id, val ? : "0");
    }
    else if((val = g_hash_table_lookup(med_peer_ip_table, cdr->source_domain->str)) != NULL)
    {
        g_string_assign(cdr->source_provider_id, val);
    }
    else if((val = g_hash_table_lookup(med_peer_host_table, cdr->source_domain->str)) != NULL)
    {
        g_string_assign(cdr->source_provider_id, val);
    }
    else
    {
        g_string_assign(cdr->source_provider_id, "0");
    }

    if(strcmp("0", cdr->destination_user_id->str) != 0)
    {
        if((val = medmysql_lookup_uuid(cdr->destination_user_id->str)) != NULL)
        {
            g_string_assign(cdr->destination_provider_id, val);
        }
        else
        {
            g_string_assign(cdr->destination_provider_id, "0");
        }
    }
    else if (cdr->destination_lcr_id) {
        g_string_printf(cdr->destination_provider_id,
                "%llu", (unsigned long long) cdr->destination_lcr_id);
        val = g_hash_table_lookup(med_peer_id_table, cdr->destination_provider_id->str);
        g_string_assign(cdr->destination_provider_id, val ? : "0");
    }
    else if((val = g_hash_table_lookup(med_peer_ip_table, cdr->destination_domain->str)) != NULL)
    {
        g_string_assign(cdr->destination_provider_id, val);
    }
    else if((val = g_hash_table_lookup(med_peer_host_table, cdr->destination_domain->str)) != NULL)
    {
        g_string_assign(cdr->destination_provider_id, val);
    }
    else
    {
        g_string_assign(cdr->destination_provider_id, "0");
    }
}

void cdr_parse_entry(med_entry_t *e)
{
    if (!e->src_leg_json && e->src_leg[0])
    {
        e->src_leg_json = json_tokener_parse(e->src_leg);
    }

    if (!e->dst_leg_json && e->dst_leg[0])
    {
        e->dst_leg_json = json_tokener_parse(e->dst_leg);
    }

    if (!e->valid)
    {
        e->method = MED_UNRECOGNIZED;
    }
    else if (strcmp(e->sip_method, MSG_INVITE) == 0)
    {
        e->method = MED_INVITE;
    }
    else if (strcmp(e->sip_method, MSG_BYE) == 0)
    {
        e->method = MED_BYE;
    }
    else if (strcmp(e->sip_method, MSG_REFER) == 0)
    {
        e->method = MED_REFER;
    }
    else
    {
        e->method = MED_UNRECOGNIZED;
    }
}

// try strip one suffix and return whether it was done
static inline int cdr_truncate_suffix(char *callid, size_t *len, const char *suffix) {
    size_t slen = strlen(suffix);
    if (*len < slen)
        return 0;
    if (memcmp(&callid[*len - slen], suffix, slen) != 0)
        return 0;
    callid[*len - slen] = '\0';
    *len -= slen;
    return 1;
}

// strip (potentially chained) suffices
void cdr_truncate_call_id_suffix(char *callid)
{
    size_t len = strlen(callid);

    while (1) {
        if (cdr_truncate_suffix(callid, &len, PBXSUFFIX))
            continue;
        if (cdr_truncate_suffix(callid, &len, XFERSUFFIX))
            continue;
        break;
    };
}