#include "Record.h"
#include "Config.h"
#include "Json.h"
#include <QProcess>
#include <QFile>

Record::Record(QObject *parent) : QObject(parent)
{
 isRecording=false;
}

void Record::init()
{
 QFile file("/link/config/record.json");
 file.open(QFile::ReadOnly);
 QString json=file.readAll();
 file.close();
 update(json);
}

bool Record::start()
{
 if(isRecording)
 return false;
 QProcess pro;
 QString df="df "+rootPath;
 pro.start(df.toLatin1().data());
 pro.waitForFinished(3000);
 QString str=pro.readAll();
 if(!str.contains(rootPath))
 return false;

 isRecording=true;

 startTime=QDateTime::currentDateTime();

 fileName=startTime.toString("yyyyMMdd_hhmmss");
 QVariantList channels=config["channel"].toList();
 QVariantList formats=config["format"].toList();
 QString path=rootPath+"/"+fileName;
 QString mkdir="mkdir "+path;
 system(mkdir.toLatin1().data());
 foreach(QVariant val,channels)
 {
 int chnId=val.toInt();
 QString chnPath=path+"/"+QString::number(chnId);
 mkdir="mkdir "+chnPath;
 system(mkdir.toLatin1().data());

 QString fullName=chnPath+"/"+fileName+"-"+QString::number(chnId);

 Channel *chn=Config::findChannelById(chnId);
 QString jpg=fullName+".jpg";;
 chn->snap->invoke("snapSync",jpg);

 for(int i=0;i<formats.count();i++)
 {
 QString fmt=formats[i].toString();
 QVariantMap data;
 data["path"]=fullName+"."+fmt;
 if(chn->encA==NULL || chn->encA->getState()!="started")
 {
 data["mute"]=true;
 }
 else
 chn->encA->linkA(muxMap[chnId][i]);

 chn->encV->linkV(muxMap[chnId][i]);
 muxMap[chnId][i]->start(data);
 }
 }

 return true;
}

bool Record::stop()
{
 foreach(int chnId,muxMap.keys())
 {
 foreach(LinkObject* mux,muxMap[chnId])
 {
 mux->stop();
 }
 }
 isRecording=false;

 return true;
}

QVariantMap Record::getState()
{
 QString space="";
 QProcess pro;
 QString df="df -h "+rootPath;
 pro.start(df.toLatin1().data());
 pro.waitForFinished(3000);
 QString str=pro.readAll();
 if(str.contains(rootPath))
 {
 QStringList list=str.split(" ",QString::SkipEmptyParts);
 space=list[list.count()-3];
 }

 QVariantMap ret;
 ret["isRecording"]=isRecording;
 ret["duration"]=QDateTime::currentMSecsSinceEpoch()-startTime.toMSecsSinceEpoch();
 ret["fileName"]=fileName;
 ret["space"]=space;
 return ret;
}

bool Record::update(QString json)
{
 config=Json::decode(json).toMap();

 rootPath=config["path"].toString();

 QVariantList channels=config["channel"].toList();
 foreach(QVariant val,channels)
 {
 int chnId=val.toInt();
 if(!muxMap.contains(chnId))
 {
 muxMap[chnId]=QList<LinkObject*>();
 for(int i=0;i<6;i++)
 {
 muxMap[chnId].append(Link::create("Mux"));
 }
 }
 }


 Json::saveFile(config,"/link/config/record.json");


 return true;
}