#include "ChannelMix.h"
#include "Config.h"
#include "ChannelVI.h"
#include <QFile>
#include "Json.h"

ChannelMix::ChannelMix(QObject *parent) : Channel(parent)
{
 audio=Link::create("MixA");
 video=Link::create("MixV");
 encA=Link::create("EncodeA");
 encV=Link::create("EncodeV");
 encV2=Link::create("EncodeV");
 lastSrcV=NULL;
 lastSrcV2=NULL;
 lastSrcA=NULL;
}

void ChannelMix::init(QVariantMap cfg)
{
 gain->linkA(encA);
 overlay->linkV(encV);
 overlay->linkV(encV2);



 outputV=Link::create("OutputVo");
 outputV2=Link::create("OutputVo");
 outputA=Link::create("OutputAo");
 QVariantMap aoData;
 aoData["interface"]="HDMI-OUT";
 outputA->start(aoData);
 audio->linkA(outputA);


 QString name="Line-Out";
 if(QFile::exists("/dev/tlv320aic31"))
 name="Mini-Out";
 QVariantMap ifaceA=Json::loadFile("/link/config/board.json").toMap()["interfaceA"].toMap();
 if(ifaceA.keys().contains(name))
 {
 if(ifaceA[name].toMap().contains("alsa"))
 {

 lineOut=Link::create("OutputAlsa");
 QVariantMap alsaData=ifaceA[name].toMap();
 alsaData["path"]=alsaData["alsa"].toString();
 lineOut->start(alsaData);
 }
 else
 {
 lineOut=Link::create("OutputAo");
 aoData["interface"]=name;
 lineOut->start(aoData);
 }
 audio->linkA(lineOut);
 }

 lastSrcA=audio;

 Channel::init();
}
#include "unistd.h"
void ChannelMix::updateConfig(QVariantMap cfg)
{
 if(cfg["enable"].toBool())
 {
 QVariantMap dataMixV;
 if(cfg["encv"].toMap()["width"].toInt()!=-1)
 {
 dataMixV["width"]=cfg["encv"].toMap()["width"].toInt();
 dataMixV["height"]=cfg["encv"].toMap()["height"].toInt();
 dataMixV["framerate"]=cfg["encv"].toMap()["framerate"].toInt();
 }

 video->start(dataMixV);
 audio->start();

 QVariantList srcV=cfg["srcV"].toList();
 QVariantList srcA=cfg["srcA"].toList();
 QVariantList videoList;
 for(int i=0;i<srcV.count();i++)
 {

 if(srcV[i].toInt()!=-1)
 {
 LinkObject *v=Config::findChannelById(srcV[i].toInt())->video;

 videoList.append(v->name());
 v->linkV(video);
 }
 else
 {
 videoList.append("unknow");
 }
 }


 dataMixV["src"]=videoList;
 dataMixV["layout"]=cfg["layout"].toList();

 foreach(int id,curAList)
 {
 if(!srcA.contains(id))
 {
 LinkObject *a=Config::findChannelById(id)->gain;
 a->unLinkA(audio);
 curAList.removeAll(id);
 }
 }

 QVariantMap dataMixA;
 dataMixA["bufLen"]=20;
 for(int i=0;i<srcA.count();i++)
 {
 if(srcA[i]==-1)
 continue;
 Channel *chn=Config::findChannelById(srcA[i].toInt());
 if(chn->audio==NULL )
 continue;
 LinkObject *a=chn->gain;
 if(!dataMixA.contains("main"))
 dataMixA["main"]=a->name();
 a->linkA(audio);
 curAList.append(srcA[i].toInt());
 }

 if(ChannelVI::lineIn!=NULL)
 {
 ChannelVI::lineIn->linkA(audio);
 dataMixA["main"]=ChannelVI::lineIn->name();
 }

 audio->setData(dataMixA);
 video->setData(dataMixV);

 if(cfg["enca"].toMap()["codec"].toString()!="close")
 encA->start(cfg["enca"].toMap());
 else
 encA->stop();

 if(cfg["encv"].toMap()["codec"].toString()!="close")
 {
 encV->start(cfg["encv"].toMap());
 }
 else
 encV->stop();

 if(cfg["encv"].toMap()["codec"].toString()!="close")
 {
 encV->start(cfg["encv"].toMap());
 }
 else
 encV->stop();

 if(data["enable2"].toBool() && cfg["encv2"].toMap()["codec"].toString()!="close")
 encV2->start(cfg["encv2"].toMap());
 else
 encV2->stop();

 }
 else
 {
 audio->stop();
 video->stop();
 encA->stop();
 encV->stop();
 encV2->stop();
 }

 QVariantMap outCfg=cfg["output"].toMap();
 if(outCfg["enable"].toBool())
 {
 Channel *chn=Config::findChannelById(outCfg["src"].toInt());
 LinkObject *v=chn->video;
 LinkObject *a=chn->gain;
 if(v!=NULL)
 {
 if(v!=lastSrcV && lastSrcV!=NULL)
 lastSrcV->unLinkV(outputV);
 lastSrcV=v;
 v->linkV(outputV);
 }

 if(a!=NULL)
 {
 if(a!=lastSrcA && lastSrcA!=NULL)
 {
 lastSrcA->unLinkA(outputA);
 a->linkA(outputA);
 if(lineOut!=NULL)
 {
 lastSrcA->unLinkA(lineOut);
 a->linkA(lineOut);
 }
 }
 lastSrcA=a;
 }
 outputV->start(outCfg);
 }
 else
 outputV->stop();


 QVariantMap outCfg2=cfg["output2"].toMap();
 if(outCfg2["enable"].toBool())
 {
 Channel *chn=Config::findChannelById(outCfg2["src"].toInt());
 LinkObject *v=chn->video;
 if(v!=NULL)
 {
 if(v!=lastSrcV2 && lastSrcV2!=NULL)
 lastSrcV2->unLinkV(outputV2);
 lastSrcV2=v;
 v->linkV(outputV2);
 }

 outputV2->start(outCfg2);
 }
 else
 outputV2->stop();

 Channel::updateConfig(cfg);
}