/*****************************************************************************
 * SDIOutput.cpp: SDI sout module for vlc
 *****************************************************************************
 * Copyright © 2018 VideoLabs, VideoLAN and VideoLAN Authors
 *
 * 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 "SDIOutput.hpp"
#include "SDIStream.hpp"
#include "SDIAudioMultiplex.hpp"
#include "sdiout.hpp"

#include <vlc_sout.h>
#include <vlc_picture.h>

using namespace sdi_sout;

SDIOutput::SDIOutput(sout_stream_t *p_stream_)
{
    p_stream = p_stream_;

    es_format_Init(&video.configuredfmt, VIDEO_ES, 0);
    video.tenbits = var_InheritBool(p_stream, CFG_PREFIX "tenbits");
    video.nosignal_delay = var_InheritInteger(p_stream, CFG_PREFIX "nosignal-delay");
    video.pic_nosignal = NULL;
    audio.i_channels = var_InheritInteger(p_stream, CFG_PREFIX "channels");
    audio.b_configured = false;
    ancillary.afd = var_InheritInteger(p_stream, CFG_PREFIX "afd");
    ancillary.ar = var_InheritInteger(p_stream, CFG_PREFIX "ar");
    ancillary.afd_line = var_InheritInteger(p_stream, CFG_PREFIX "afd-line");
    ancillary.captions_line = 15;
    program = -1;
    videoStream = NULL;
    captionsStream = NULL;
    audioMultiplex = new SDIAudioMultiplex(VLC_OBJECT(p_stream),
                                           var_InheritInteger(p_stream, CFG_PREFIX "channels"));
    char *psz_channelsconf = var_InheritString(p_stream, CFG_PREFIX "audio");
    if(psz_channelsconf)
    {
        audioMultiplex->config.parseConfiguration(psz_channelsconf);
        free(psz_channelsconf);
    }
}

SDIOutput::~SDIOutput()
{
    videoBuffer.FlushQueued();
    captionsBuffer.FlushQueued();
    while(!audioStreams.empty())
    {
        delete audioStreams.front();
        audioStreams.pop_front();
    }
    delete audioMultiplex;
    delete captionsStream;
    delete videoStream;
    if(video.pic_nosignal)
        picture_Release(video.pic_nosignal);
    es_format_Clean(&video.configuredfmt);
}

AbstractStream *SDIOutput::Add(const es_format_t *fmt)
{
    AbstractStream *s = NULL;
    StreamID id(fmt->i_id);

    if(program >= 0 && fmt->i_group != program)
        return NULL;

    if(fmt->i_cat == VIDEO_ES && !videoStream)
    {
        if(ConfigureVideo(&fmt->video) == VLC_SUCCESS)
            s = videoStream = dynamic_cast<VideoDecodedStream *>(createStream(id, fmt, &videoBuffer));
        if(videoStream)
        {
            videoStream->setOutputFormat(&video.configuredfmt);
            //videoStream->setCaptionsOutputBuffer(&captionsBuffer);
        }
    }
    else if(fmt->i_cat == AUDIO_ES && audio.i_channels)
    {
        if(audio.b_configured || ConfigureAudio(&fmt->audio) == VLC_SUCCESS)
        {
            const es_format_t *cfgfmt = audioMultiplex->config.getConfigurationForStream(id);
            if(!cfgfmt)
            {
                if(!audioMultiplex->config.addMapping(id, fmt))
                    return NULL;
            }
            cfgfmt = audioMultiplex->config.updateFromRealESConfig(id, fmt);
            SDIAudioMultiplexBuffer *buffer = audioMultiplex->config.getBufferForStream(id);
            if(!buffer)
                return NULL;

            s = createStream(id, fmt, buffer, audioMultiplex->config.decode(id));
            if(s)
            {
                if(!audioMultiplex->config.decode(id))
                    buffer->setCodec(fmt->i_codec);
                AudioDecodedStream *audioStream = dynamic_cast<AudioDecodedStream *>(s);
                if(audioStream)
                    audioStream->setOutputFormat(cfgfmt);
                audioStreams.push_back(audioStream);
                std::vector<uint8_t> slots = audioMultiplex->config.getConfiguredSlots(id);
                for(size_t i=0; i<slots.size(); i++)
                {
                    msg_Dbg(p_stream, "%s slot %d to read from channel %zd",
                                      id.toString().c_str(), slots[i], i);
                    audioMultiplex->SetSubFrameSource(slots[i], buffer, AES3AudioSubFrameIndex(i));
                }
            }
        }
    }
    else if(fmt->i_cat == SPU_ES && !captionsStream)
    {
        s = captionsStream = dynamic_cast<CaptionsStream *>(createStream(id, fmt, &captionsBuffer, false));
    }

    if(program == -1)
        program = fmt->i_group;

    return s;
}

int SDIOutput::Send(AbstractStream *id, block_t *p)
{
    int ret = id->Send(p);
    Process();
    return ret;
}

void SDIOutput::Del(AbstractStream *s)
{
    s->Drain();
    Process();
}

int SDIOutput::Control(int i_query, va_list args)
{
    switch(i_query)
    {
        case SOUT_STREAM_WANTS_SUBSTREAMS:
        case SOUT_STREAM_IS_SYNCHRONOUS:
            *va_arg(args, bool *) = true;
            return VLC_SUCCESS;
        default:
            return VLC_EGENERIC;
    };
}

bool SDIOutput::ReachedPlaybackTime(vlc_tick_t t)
{
    if (captionsStream &&
        !captionsStream->ReachedPlaybackTime(t))
        return false;

    for(auto it = audioStreams.begin(); it != audioStreams.end(); ++it)
        if(!(*it)->ReachedPlaybackTime(t))
            return false;

    if(!videoStream || /* must have video */
       !videoStream->ReachedPlaybackTime(t))
        return false;

    return true;
}

AbstractStream *SDIOutput::createStream(const StreamID &id,
                                        const es_format_t *fmt,
                                        AbstractStreamOutputBuffer *buffer,
                                        bool b_decoded)
{
    AbstractStream *s = NULL;
    if(b_decoded)
    {
        if(fmt->i_cat == VIDEO_ES)
            s = new VideoDecodedStream(VLC_OBJECT(p_stream), id, buffer);
        else if(fmt->i_cat == AUDIO_ES)
            s = new AudioDecodedStream(VLC_OBJECT(p_stream), id, buffer);
    }
    else
    {
        if(fmt->i_cat == AUDIO_ES)
            s = new AudioCompressedStream(VLC_OBJECT(p_stream), id, buffer);
        else if(fmt->i_cat == SPU_ES)
            s = new CaptionsStream(VLC_OBJECT(p_stream), id, buffer);
    }

     if(s && !s->init(fmt))
     {
         delete s;
         return NULL;
     }
     return s;
}