/*****************************************************************************
 * extradata.c: Muxing extradata builder/gatherer
 *****************************************************************************
 * Copyright (C) 2018 VideoLabs, VLC authors and VideoLAN
 *
 * This program is free software; you can redistribute it and/or modify it
 * under the terms of the GNU Lesser General Public License as published by
 * the Free Software Foundation; either version 2.1 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 Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with this program; if not, write to the Free Software Foundation,
 * Inc., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA.
 *****************************************************************************/
#ifdef HAVE_CONFIG_H
# include "config.h"
#endif

#include <vlc_common.h>
#include <vlc_codec.h>

#include "extradata.h"
#include "../packetizer/av1_obu.h"
#include "../packetizer/a52.h"
#include "../codec/hxxx_helper.h"

struct mux_extradata_builder_cb
{
    int  (*pf_init)(mux_extradata_builder_t *);
    void (*pf_feed)(mux_extradata_builder_t *, const uint8_t *, size_t);
    void (*pf_deinit)(mux_extradata_builder_t *);
};

struct mux_extradata_builder_t
{
    struct mux_extradata_builder_cb cb;
    vlc_object_t *obj;
    void *priv;
    uint8_t *p_extra;
    size_t i_extra;
    vlc_fourcc_t fcc;
};

static void generic_free_extra_Deinit(mux_extradata_builder_t *m)
{
    free(m->p_extra);
}

static void ac3_extradata_builder_Feed(mux_extradata_builder_t *m,
                                       const uint8_t *p_data, size_t i_data)
{
    if(m->i_extra || i_data < VLC_A52_MIN_HEADER_SIZE ||
       p_data[0] != 0x0B || p_data[1] != 0x77)
        return;

    struct vlc_a52_bitstream_info bsi;
    if(vlc_a52_ParseAc3BitstreamInfo(&bsi, &p_data[4], /* start code + CRC */
                                     VLC_A52_MIN_HEADER_SIZE - 4 ) != VLC_SUCCESS)
        return;

    m->p_extra = malloc(3);
    if(!m->p_extra)
        return;
    m->i_extra = 3;

    bs_t s;
    bs_write_init(&s, m->p_extra, m->i_extra);
    bs_write(&s, 2, bsi.i_fscod);
    bs_write(&s, 5, bsi.i_bsid);
    bs_write(&s, 3, bsi.i_bsmod);
    bs_write(&s, 3, bsi.i_acmod);
    bs_write(&s, 1, bsi.i_lfeon);
    bs_write(&s, 5, bsi.i_frmsizcod >> 1); // bit_rate_code
    bs_write(&s, 5, 0); // reserved
}

const struct mux_extradata_builder_cb ac3_cb =
{
    NULL,
    ac3_extradata_builder_Feed,
    generic_free_extra_Deinit,
};

static void eac3_extradata_builder_Feed(mux_extradata_builder_t *m,
                                        const uint8_t *p_data, size_t i_data)
{
    if(m->i_extra || i_data < VLC_A52_MIN_HEADER_SIZE ||
       p_data[0] != 0x0B || p_data[1] != 0x77)
        return;

    struct vlc_a52_bitstream_info bsi;
    if(vlc_a52_ParseEac3BitstreamInfo(&bsi, &p_data[2], /* start code */
                                      i_data - 2) != VLC_SUCCESS)
        return;

    m->p_extra = malloc(5);
    if(!m->p_extra)
        return;
    m->i_extra = 5;

    bs_t s;
    bs_write_init(&s, m->p_extra, m->i_extra);
    const unsigned rgi_fscod_samplerates[] = { 48000, 44100, 32000 };
    unsigned fs = rgi_fscod_samplerates[bsi.i_fscod];
    unsigned numblks = bsi.eac3.i_numblkscod + 1;
    if(numblks > 3)
        numblks = 6;
    unsigned data_rate = (bsi.eac3.i_frmsiz + 1) * fs / (numblks << 4); /* F.6.2.2 */
    bs_write(&s, 13, data_rate);
    bs_write(&s, 3, 0); // num_ind_sub - 1
    bs_write(&s, 2, bsi.i_fscod);
    bs_write(&s, 5, bsi.i_bsid);
    bs_write(&s, 5, bsi.i_bsmod);
    bs_write(&s, 3, bsi.i_acmod);
    bs_write(&s, 1, bsi.i_lfeon);
    bs_write(&s, 3, 0); // reserved
    bs_write(&s, 4, 0); // num_dep_sub
    bs_write(&s, 1, 0); // reserved
}

const struct mux_extradata_builder_cb eac3_cb =
{
    NULL,
    eac3_extradata_builder_Feed,
    generic_free_extra_Deinit,
};

static void av1_extradata_builder_Feed(mux_extradata_builder_t *m,
                                       const uint8_t *p_data, size_t i_data)
{
    if(m->i_extra)
        return;

    AV1_OBU_iterator_ctx_t ctx;
    AV1_OBU_iterator_init(&ctx, p_data, i_data);
    const uint8_t *p_obu; size_t i_obu;
    while(AV1_OBU_iterate_next(&ctx, &p_obu, &i_obu))
    {
        enum av1_obu_type_e OBUtype = AV1_OBUGetType(p_obu);
        if(OBUtype != AV1_OBU_SEQUENCE_HEADER)
            continue;
        av1_OBU_sequence_header_t *p_sh = AV1_OBU_parse_sequence_header(p_obu, i_obu);
        if(p_sh)
        {
            m->i_extra = AV1_create_DecoderConfigurationRecord(&m->p_extra, p_sh,
                                                               1, (const uint8_t **)&p_obu, &i_obu);
            AV1_release_sequence_header(p_sh);
        }
        break;
    }
}

const struct mux_extradata_builder_cb av1_cb =
{
    NULL,
    av1_extradata_builder_Feed,
    generic_free_extra_Deinit,
};

static void hxxx_extradata_builder_Feed(mux_extradata_builder_t *m,
                                        const uint8_t *data, size_t size)
{
    if (m->i_extra)
        return;

    struct hxxx_helper hh;
    hxxx_helper_init(&hh, m->obj, m->fcc, 0, 0);

    int ret = hxxx_helper_process_buffer(&hh, data, size);
    (void)ret;

    if (hxxx_helper_has_config(&hh) && m->i_extra == 0)
    {
        assert(m->priv == NULL);
        block_t *config = hxxx_helper_get_extradata_block(&hh);
        m->i_extra = config->i_buffer;
        m->p_extra = config->p_buffer;
        m->priv = config;
    }
    hxxx_helper_clean(&hh);
}

static void hxxx_extradata_builder_Deinit(mux_extradata_builder_t *m)
{
    if (m->priv)
        block_Release(m->priv);
}

const struct mux_extradata_builder_cb hxxx_cb =
{
    NULL,
    hxxx_extradata_builder_Feed,
    hxxx_extradata_builder_Deinit,
};

void mux_extradata_builder_Delete(mux_extradata_builder_t *m)
{
    m->cb.pf_deinit(m);
    free(m);
}

static const struct
{
    enum mux_extradata_type_e type;
    vlc_fourcc_t fcc;
    const struct mux_extradata_builder_cb *cb;
} mappings[] = {
    { EXTRADATA_ISOBMFF, VLC_CODEC_AV1,  &av1_cb },
    { EXTRADATA_ISOBMFF, VLC_CODEC_A52,  &ac3_cb },
    { EXTRADATA_ISOBMFF, VLC_CODEC_EAC3, &eac3_cb },
    { EXTRADATA_ISOBMFF, VLC_CODEC_H264, &hxxx_cb },
    { EXTRADATA_ISOBMFF, VLC_CODEC_HEVC, &hxxx_cb },
};

mux_extradata_builder_t * mux_extradata_builder_New(vlc_object_t *obj,
                                                    vlc_fourcc_t fcc,
                                                    enum mux_extradata_type_e type)
{
    const struct mux_extradata_builder_cb *cb = NULL;
    for(size_t i=0; i<ARRAY_SIZE(mappings); i++)
    {
        if(mappings[i].type != type || mappings[i].fcc != fcc)
            continue;
        cb = mappings[i].cb;
        break;
    }

    if(cb == NULL)
        return NULL;

    assert(cb->pf_feed != NULL);
    assert(cb->pf_deinit != NULL);

    mux_extradata_builder_t *m = calloc(1, sizeof(*m));
    if(m == NULL)
        return NULL;

    m->priv = NULL;
    m->fcc = fcc;
    m->cb = *cb;
    m->obj = obj;
    if(m->cb.pf_init && m->cb.pf_init(m) != 0)
    {
        free(m);
        m = NULL;
    }
    return m;
}

size_t mux_extradata_builder_Get(mux_extradata_builder_t *m, const uint8_t **a)
{
    *a = m->p_extra;
    return m->i_extra;
}

void mux_extradata_builder_Feed(mux_extradata_builder_t *m,
                                const uint8_t *p_data, size_t i_data)
{
    m->cb.pf_feed(m, p_data, i_data);
}