#include <thread>
#include "AppPipeController.h"
#include <basic/util/file/FileUtil.h>
#include <basic/util/app/AppPreference.hpp>
#include <basic/debug/Debug.h>

using namespace std;


int main(int argc, char **argv) {
    SAVE_APP_ARGS;

#ifdef GLOG
    ENABLEGLOG("./log/");
#endif

//    std::string src_path = "/home/bsk/development/c++/Qt/QiaoJiaSystem/build/cut/123456/34/201808/28/123456-34-201808-20180828090100";
    std::string src_path = "/home/basic/视频/test";


    appPref.setLongData("gpu.index", 0);
    appPref.setIntData("show.image", 0);

    //yolo server
    appPref.setStringData("yolo.proxy", "yoloServer");
    //#todo
    appPref.setStringData("yolo.ip", "");
    appPref.setIntData("yolo.port", 10003);
//    rpcClient(appPref.getStringData("yolo.proxy"), appPref.getStringData("yolo.ip"), appPref.getLongData("yolo.port"),"tcp"),


    //face detect server
    appPref.setStringData("faceDete.proxy", "faceServer");
    //#todo
    appPref.setStringData("faceDete.ip", "");
    appPref.setIntData("faceDete.port", 10002);
//rpcClient(appPref.getStringData("faceDete.proxy"), appPref.getStringData("faceDete.ip"), appPref.getLongData("faceDete.port"),"tcp"),
//    rpcClient("faceServer","",10002,"tcp"),


    //fece extern server
    appPref.setStringData("faceExte.proxy", "faceExtractServer");
    //#todo
    appPref.setStringData("faceExte.ip", "");
    appPref.setIntData("faceExte.port", 10008);
//rpcClient(appPref.getStringData("faceExte.proxy"), appPref.getStringData("faceExte.ip"), appPref.getLongData("faceExte.port"),"tcp"),
//        "faceExtractServer", "", 10008, "tcp"),//人脸特征提取 修改成点对点通讯


    //face search server
    appPref.setStringData("faceSear.proxy", "faceCmServer");
    //#todo
    appPref.setStringData("faceSear.ip", "");
    appPref.setIntData("faceSear.port", 10004);
//rpcClient(appPref.getStringData("faceSear.proxy"), appPref.getStringData("faceSear.ip"), appPref.getLongData("faceSear.port"),"tcp"),
//    faceSearchRpcClient("faceCmServer", "", 10004, "tcp")

    //loopRecord server
    appPref.setStringData("loopRecord.proxy", "LoopRecordVideoServer");
    //#todo
    appPref.setStringData("loopRecord.ip", "");
    appPref.setIntData("loopRecord.port", 10010);
//rpcClient(appPref.getStringData("loopRecord.proxy"), appPref.getStringData("loopRecord.ip"), appPref.getLongData("loopRecord.port"),"tcp"),

    appPref.setStringData("ipAdd", "192.168.1.185");
    appPref.setIntData("ipPort", 9200);
    Json::Value json;

    //split sdks enable
    //#todo other sdk

    json["face.enable"] = "1";
    json["yolo.enable"] = "0";
    json["rtsp"] = "rtsp://admin:a1234567@192.168.1.188:554/h264/ch1/main/av_stream";
//    json["rtsp"] = "rtsp://admin:a1234567@192.168.1.188:554/h264/ch1/main/av_stream";
//    json["rtsp"] = "/home/bsk/test/realtime/test123/201809/27/test123-2018092717/2018-09-27 17:20:57.mp4";


    FastFdsWithLock fdfsClient;
//    fdfsClient.fastFds = new FastFds;

    //#todo from path get file list
    file_filter_type filter = [](const char *dirName, const char *dirent) {
        return (strstr(dirent, ".mp4") != nullptr);// add format
    };
    std::vector<std::string> vec = for_each_file(src_path, filter);
//    while (true) {
    auto size = vec.size();
//    int size = 1;
    int pos = 0;
 //   AppPipeController _AppPipeController("test12344", json, true);
//    AppPipeController _AppPipeController(src_path, json);
//    _AppPipeController.setfdfsClient(&fdfsClient);
//    for (; pos < size;) {
//
//        //#todo
//        _AppPipeController.resetVideoCapturePath(vec[pos++]);
//        _AppPipeController.resetVideoCapturePath(
//            "/home/basic/work/qiaojia/cut/DS-7808N-SN0820161208AARR691369356WCVU/34/201810/11/DS-7808N-SN0820161208AARR691369356WCVU-34-20181011090000/2018-10-11 09:48:05.mp4");
//    _AppPipeController.start();
//    while (_AppPipeController.getRunning()) {
//        usleep(40000);
//    }
//    _AppPipeController.stop();
//    _AppPipeController.wait();
    DBG("finish file");
//    }
//    }

//    _AppPipeController.start();
//    while (_AppPipeController.getRunning()) {
//        usleep(40000);
//    }
//    _AppPipeController.stop();
//    _AppPipeController.wait();
//
    getchar();

    return 0;
}