#include "AppController.h"
#include <basic/util/file/FileUtil.h>

#define VECSIZE 1

AppController::AppController(std::string path, int interval) : TimerElement(interval), m_path(path),
                                                               func_cond_mutex(PTHREAD_MUTEX_INITIALIZER),
                                                               func_cond(PTHREAD_COND_INITIALIZER) {
    file_filter_type filter = [](const char *dirName, const char *dirent) {
        return (strstr(dirent, ".mp4") != nullptr);// add format
    };

    std::string tmp = path;
    m_pathOut = tmp.replace(tmp.begin() + tmp.find("/load"), tmp.begin() + tmp.find("/load") + 5, "/cut");
//    DBG("m_pathOut is " << m_pathOut);

    std::vector<std::string> vec = for_each_file(m_path, filter);

    INFO(path << " vec size : " << vec.size());

    for (int i = 0; i < vec.size(); ++i) {
        m_que.push(vec[i]);
    }

    if (vec.size() >= VECSIZE) {
        m_vec.resize(VECSIZE);
    } else {
        m_vec.resize(vec.size());
    }

    for (int i = 0; i < m_vec.size(); ++i) {
        m_vec[i] = nullptr;
    }
}

RapidAppPipeController *AppController::addController() {
    RapidAppPipeController *p = nullptr;
    std::lock_guard<std::mutex> lg(mtx);
    std::string strPath;
    Json::Value value;
    if (!m_que.empty()) {
        strPath = m_que.front();
        value["rtsp"] = strPath;
        m_que.pop();
        p = new RapidAppPipeController(m_nIndex, value, m_pathOut);
        p->start();
        m_nIndex++;
    }
    return p;
}

std::string AppController::startController() {
    start();
    pthread_mutex_lock(&func_cond_mutex);
//    INFO("before wait" << m_path);
    pthread_cond_wait(&func_cond, &func_cond_mutex);
    int m_t_size = m_vec.size();
    for (int i = 0; i < m_vec.size(); ++i) {
        if (m_vec[i] == nullptr) {
            continue;
        }
        while (m_vec[i]->getIsRunning()) {
            usleep(40000);
        }
        m_vec[i]->stop();
        m_vec[i]->wait();
        delete m_vec[i];
        m_vec[i] = nullptr;
        m_t_size--;
    }
//    INFO("after wait" << m_path);
    pthread_mutex_unlock(&func_cond_mutex);
    wait();
//    DBG("cut ok ;m_pathOut is " << m_pathOut);
    return m_pathOut;
}

void AppController::timerFunc() {
    if (m_que.empty()) {
//        INFO("before signal  " << m_path);
        stop();
        pthread_cond_signal(&func_cond);
//        INFO("after signal" << m_path);
        return;
    }

    for (int i = 0; i < m_vec.size(); ++i) {
        if (m_vec[i] == nullptr) {
            m_vec[i] = addController();
            continue;
        }

        if (!m_vec[i]->getIsRunning()) {

            m_vec[i]->stop();
            m_vec[i]->wait();

            delete m_vec[i];
//            std::string cmd = "rm -rf \"";
//            cmd.append(m_vec[i]->getPath()).append("\" & ");
//            system(cmd.c_str());
            m_vec[i] = nullptr;

            m_vec[i] = addController();
            continue;
        }
    }
}

//if (!m_que.empty())
//{
//    strPath = m_que.pop();
//}else
//{
//    return;
//}
//value["rtsp"] = strPath;

//std::string strPath;
//Json::Value value;

//m_vec[i] = new RapidAppPipeController(m_nIndex,strPath);
//m_vec[i]->start();

//m_vec[i]->stop();
//m_vec[i]->wait();

//delete m_vec[i];
//m_vec[i] = nullptr;

//m_vec[i] = new RapidAppPipeController(m_nIndex,strPath);
//m_vec[i]->start();