/*  Copyright (c) MediaArea.net SARL. All Rights Reserved.
 *
 *  Use of this source code is governed by a BSD-style license that can
 *  be found in the License.html file in the root of the source tree.
 */

#include "workerfiles.h"
#include "mainwindow.h"
#include "Common/FileRegistered.h"

#include "DatabaseUi.h"

#include <QString>
#include <QDir>
#include <QTimer>

namespace MediaConch {

//***************************************************************************
// Constructor / Desructor
//***************************************************************************

//---------------------------------------------------------------------------
WorkerFiles::WorkerFiles(MainWindow* m) : QThread(), mainwindow(m), db(NULL), timer(NULL),
                                          file_index(0)
{
}

//---------------------------------------------------------------------------
WorkerFiles::~WorkerFiles()
{
    if (timer)
    {
        timer->stop();
        delete timer;
        timer = NULL;
    }
}

//---------------------------------------------------------------------------
void WorkerFiles::set_database(DatabaseUi* database)
{
    db = database;
}

//---------------------------------------------------------------------------
void WorkerFiles::run()
{
    timer = new QTimer(0);
    timer->moveToThread(this);
    timer->setSingleShot(true);
    connect(timer, SIGNAL(timeout()), this, SLOT(update_files_registered()), Qt::DirectConnection);
    timer->start(1000); //TODO
    exec();
    if (timer)
    {
        timer->stop();
        delete timer;
        timer = NULL;
    }
}

//***************************************************************************
// Functions
//***************************************************************************

//---------------------------------------------------------------------------
FileRegistered* WorkerFiles::get_file_registered_from_file(const std::string& file)
{
    FileRegistered* fr = NULL;
    working_files_mutex.lock();
    if (working_files.find(file) != working_files.end() && working_files[file])
        fr = new FileRegistered(*working_files[file]);
    working_files_mutex.unlock();
    return fr;
}

//---------------------------------------------------------------------------
FileRegistered* WorkerFiles::get_file_registered_from_id(long id)
{
    FileRegistered* fr = NULL;
    working_files_mutex.lock();
    std::map<std::string, FileRegistered*>::iterator it = working_files.begin();
    for (; it != working_files.end(); ++it)
    {
        if (!it->second)
            continue;

        if (it->second->file_id == id)
        {
            fr = new FileRegistered(*it->second);
            break;
        }
    }
    working_files_mutex.unlock();
    return fr;
}

//---------------------------------------------------------------------------
long WorkerFiles::get_id_from_registered_file(const std::string& file)
{
    long id = -1;
    working_files_mutex.lock();
    if (working_files.find(file) != working_files.end() && working_files[file])
        id = working_files[file]->file_id;
    working_files_mutex.unlock();
    return id;
}

//---------------------------------------------------------------------------
std::string WorkerFiles::get_filename_from_registered_file_id(long file_id)
{
    std::string filename;
    working_files_mutex.lock();
    std::map<std::string, FileRegistered*>::iterator it = working_files.begin();
    for (; it != working_files.end(); ++it)
    {
        if (!it->second)
            continue;

        if (it->second->file_id == file_id)
        {
            filename = it->second->filename;
            break;
        }
    }
    working_files_mutex.unlock();
    return filename;
}

//---------------------------------------------------------------------------
void WorkerFiles::get_registered_files(std::map<std::string, FileRegistered*>& files)
{
    working_files_mutex.lock();
    std::map<std::string, FileRegistered*>::iterator it = working_files.begin();
    for (; it != working_files.end(); ++it)
    {
        if (!it->second)
            continue;

        files[it->first] = new FileRegistered(*it->second);
    }
    working_files_mutex.unlock();
}

//---------------------------------------------------------------------------
int WorkerFiles::add_file_to_list(const std::string& file, const std::string& path,
                                  int policy, int display, int verbosity, bool fixer,
                                  bool force, bool create_policy, const std::vector<std::string>& options, std::string& err)
{
    std::string full_file(path);
#ifdef WINDOWS
    if (full_file.size() && full_file[full_file.size() - 1] != '/' && full_file[full_file.size() - 1] != '\\')
        full_file += "/";
#else
    if (full_file.length())
        full_file += "/";
#endif
    full_file += file;

    bool exists = false;
    FileRegistered *fr = NULL;
    working_files_mutex.lock();
    std::map<std::string, FileRegistered*>::iterator it = working_files.find(full_file);
    if (it != working_files.end() && it->second)
    {
        exists = true;
        bool same_options = true;
        for (size_t i = 0; i < it->second->options.size(); ++i)
        {
            size_t j = 0;
            for (; j < options.size(); ++j)
                if (options[j] == it->second->options[i])
                    break;

            if (j == options.size())
            {
                same_options = false;
                break;
            }
        }

        // nothing to do
        if (!force && !create_policy && same_options &&
            policy == it->second->policy && display == it->second->display
            && verbosity == it->second->verbosity)
        {
            working_files_mutex.unlock();
            return 0;
        }
        else
            fr = new FileRegistered;
        if (!force)
            fr->analyzed = working_files[full_file]->analyzed;
    }
    else
        fr = new FileRegistered;
    working_files_mutex.unlock();

    // Keep the old index for the same file
    if (exists)
    {
        fr->index = working_files[full_file]->index;
        fr->file_id = working_files[full_file]->file_id;
    }
    else
        fr->index = file_index++;

    fr->filename = file;
    fr->filepath = path;
    fr->policy = policy;
    fr->display = display;
    fr->verbosity = verbosity;
    fr->create_policy = create_policy;
    for (size_t i = 0; i < options.size(); ++i)
        fr->options.push_back(options[i]);

    working_files_mutex.lock();

    if (exists)
        delete working_files[full_file];
    working_files[full_file] = fr;
    working_files_mutex.unlock();

    unfinished_files_mutex.lock();
    unfinished_files.push_back(full_file);
    unfinished_files_mutex.unlock();

    if (!force && exists)
    {
        to_update_files_mutex.lock();
        to_update_files[full_file] = new FileRegistered(*fr);
        to_update_files_mutex.unlock();
        return 0;
    }

    std::vector<std::string> vec;
    vec.push_back(full_file);

    int ret;
    std::vector<long> files_id;
    if ((ret = mainwindow->analyze(vec, fixer, force, options, files_id, err)) < 0)
    {
        mainwindow->set_str_msg_to_status_bar(err);
        return -1;
    }

    if (files_id.size() != 1)
    {
        err = "Internal error: analyze result is not correct, no id returned.";
        return -1;
    }

    fr->file_id = files_id[0];

    to_add_files_mutex.lock();
    to_add_files[full_file] = new FileRegistered(*fr);
    to_add_files_mutex.unlock();

    working_files_mutex.lock();
    working_files[full_file]->file_id = files_id[0];
    working_files_mutex.unlock();

    return 0;
}

//---------------------------------------------------------------------------
int WorkerFiles::add_file_to_list(long id, const std::string& full_file, const std::string& filepath, const std::string& filename, std::string&)
{
    FileRegistered *fr = NULL;
    working_files_mutex.lock();
    if (working_files.find(full_file) != working_files.end() && working_files[full_file])
    {
        working_files_mutex.unlock();
        return 1;
    }
    else
        fr = new FileRegistered;
    working_files_mutex.unlock();

    // Keep the old index for the same file
    fr->file_id = id;
    fr->index = file_index++;

    fr->filename = filename;
    fr->filepath = filepath;
    fr->policy = -1;
    fr->display = -1;
    fr->verbosity = 5;
    fr->create_policy = false;

    working_files_mutex.lock();
    working_files[full_file] = fr;
    working_files_mutex.unlock();

    unfinished_files_mutex.lock();
    unfinished_files.push_back(full_file);
    unfinished_files_mutex.unlock();

    to_add_files_mutex.lock();
    to_add_files[full_file] = new FileRegistered(*fr);
    to_add_files_mutex.unlock();

    return 0;
}

//---------------------------------------------------------------------------
int WorkerFiles::add_attachment_to_list(const std::string& file, int policy, int display,
                                        int verbosity, const std::vector<std::string>& options, std::string& err)
{
    bool exists = false;
    FileRegistered *fr = NULL;

    working_files_mutex.lock();
    std::map<std::string, FileRegistered*>::iterator it = working_files.find(file);
    if (it != working_files.end() && it->second)
    {
        exists = true;
        bool same_options = true;
        for (size_t i = 0; i < it->second->options.size(); ++i)
        {
            size_t j = 0;
            for (; j < options.size(); ++j)
                if (options[j] == it->second->options[i])
                    break;

            if (j == options.size())
            {
                same_options = false;
                break;
            }
        }

        // nothing to do
        if (same_options && policy == it->second->policy &&
            display == it->second->display && verbosity == it->second->verbosity)
        {
            working_files_mutex.unlock();
            return 0;
        }
        else
            fr = new FileRegistered;
        fr->analyzed = it->second->analyzed;
    }
    else
        fr = new FileRegistered;
    working_files_mutex.unlock();

    // Keep the old index for the same file
    if (exists)
    {
        fr->index = working_files[file]->index;
        fr->file_id = working_files[file]->file_id;
    }
    else
        fr->index = file_index++;

    fr->filename = file;
    fr->filepath = "";
    fr->policy = policy;
    fr->display = display;
    fr->verbosity = verbosity;
    fr->create_policy = false;
    for (size_t i = 0; i < options.size(); ++i)
        fr->options.push_back(options[i]);

    working_files_mutex.lock();

    if (exists)
        delete working_files[file];
    working_files[file] = fr;
    working_files_mutex.unlock();

    unfinished_files_mutex.lock();
    unfinished_files.push_back(file);
    unfinished_files_mutex.unlock();

    if (exists)
    {
        to_update_files_mutex.lock();
        to_update_files[file] = new FileRegistered(*fr);
        to_update_files_mutex.unlock();
        return 0;
    }

    std::vector<std::string> vec;
    vec.push_back(file);

    int ret;
    std::vector<long> files_id;
    if ((ret = mainwindow->analyze(vec, false, false, options, files_id, err)) < 0)
    {
        mainwindow->set_str_msg_to_status_bar(err);
        return -1;
    }

    if (files_id.size() != 1)
    {
        err = "Internal error: analyze result is not correct, no id returned.";
        return -1;
    }

    fr->file_id = files_id[0];

    working_files_mutex.lock();
    working_files[file]->file_id = files_id[0];
    working_files_mutex.unlock();

    return 0;
}

//---------------------------------------------------------------------------
int WorkerFiles::update_policy_of_file_registered_from_file(long file_id, long policy, std::string& error)
{
    std::string file;
    FileRegistered* fr = NULL;
    working_files_mutex.lock();
    std::map<std::string, FileRegistered*>::iterator it = working_files.begin();
    for (; it != working_files.end(); ++it)
    {
        if (!it->second || it->second->file_id != file_id)
            continue;

        file = it->first;
        fr = it->second;
        break;
    }

    if (!fr)
    {
        // file is not existing
        error = "File not reachable";
        working_files_mutex.unlock();
        return -1;
    }

    fr->policy = policy;

    bool policy_valid = false;
    if (!fr->analyzed)
    {
        error = "File not analyzed";
        working_files_mutex.unlock();
        return -1;
    }

    working_files_mutex.unlock();

    if (policy >= 0)
    {
        std::vector<size_t> policies_ids;
        std::vector<std::string> policies_contents;
        std::vector<MediaConchLib::Checker_ValidateRes*> res;
        std::map<std::string, std::string> options;
        policies_ids.push_back(policy);

        if (mainwindow->validate(MediaConchLib::report_Max, file,
                                 policies_ids, policies_contents, options, res, error) < 0)
            return -1;

        if (res.size() == 1)
        {
            policy_valid = res[0]->valid;
            for (size_t j = 0; j < res.size() ; ++j)
                delete res[j];
            res.clear();
        }
    }

    working_files_mutex.lock();
    working_files[file]->policy_valid = policy_valid;
    FileRegistered tmp = *working_files[file];
    working_files_mutex.unlock();

    to_update_files_mutex.lock();
    to_update_files[file] = new FileRegistered(tmp);
    to_update_files_mutex.unlock();
    return 0;
}

//---------------------------------------------------------------------------
void WorkerFiles::clear_files()
{
    working_files_mutex.lock();
    std::map<std::string, FileRegistered*>::iterator it = working_files.begin();

    for (; it != working_files.end(); ++it)
    {
        if (!it->second)
            continue;

        delete it->second;
    }
    working_files.clear();
    working_files_mutex.unlock();
    remove_all_registered_file_from_db();
}

//---------------------------------------------------------------------------
void WorkerFiles::update_files_registered()
{
    if (timer)
    {
        delete timer;
        timer = NULL;
    }

    update_unfinished_files();
    update_add_files_registered();
    update_delete_files_registered();
    update_update_files_registered();

    timer = new QTimer(0);
    timer->moveToThread(this);
    timer->setSingleShot(true);
    connect(timer, SIGNAL(timeout()), this, SLOT(update_files_registered()), Qt::DirectConnection);
    timer->start(1000); //TODO
}

//---------------------------------------------------------------------------
void WorkerFiles::update_add_files_registered()
{
    std::vector<FileRegistered*> vec;
    to_add_files_mutex.lock();
    if (to_add_files.size())
    {
        std::map<std::string, FileRegistered*>::iterator it = to_add_files.begin();
        for (; it != to_add_files.end(); ++it)
            vec.push_back(it->second);
        to_add_files.clear();
    }
    to_add_files_mutex.unlock();

    if (!vec.size())
        return;

    add_registered_files_to_db(vec);
    for (size_t i = 0; i < vec.size(); ++i)
        delete vec[i];
    vec.clear();
}

//---------------------------------------------------------------------------
void WorkerFiles::update_update_files_registered()
{
    std::vector<FileRegistered*> vec;
    to_update_files_mutex.lock();
    if (to_update_files.size())
    {
        std::map<std::string, FileRegistered*>::iterator it = to_update_files.begin();
        for (; it != to_update_files.end(); ++it)
        {
            if (!it->second)
                continue;

            vec.push_back(it->second);
            if (it->second->create_policy)
                mainwindow->create_policy_from_file(it->second);
        }
        to_update_files.clear();
    }
    to_update_files_mutex.unlock();

    if (!vec.size())
        return;

    update_registered_files_in_db(vec);
    for (size_t i = 0; i < vec.size(); ++i)
        delete vec[i];
    vec.clear();
}

//---------------------------------------------------------------------------
void WorkerFiles::update_delete_files_registered()
{
    std::vector<FileRegistered*> vec;
    std::vector<long> ids;

    to_delete_files_mutex.lock();
    if (to_delete_files.size())
    {
        std::map<std::string, FileRegistered*>::iterator it = to_delete_files.begin();
        for (; it != to_delete_files.end(); ++it)
        {
            vec.push_back(it->second);
            if (it->second)
                ids.push_back(it->second->file_id);
        }
        to_delete_files.clear();
    }
    to_delete_files_mutex.unlock();

    if (!vec.size())
        return;

    remove_registered_files_from_db(vec);
    mainwindow->checker_stop(ids);
    for (size_t i = 0; i < vec.size(); ++i)
        delete vec[i];
    vec.clear();
}

//---------------------------------------------------------------------------
void WorkerFiles::update_unfinished_files()
{
    std::string err;

    unfinished_files_mutex.lock();
    std::vector<std::string> files = unfinished_files;
    unfinished_files_mutex.unlock();

    std::vector<std::string> vec;
    for (size_t i = 0; i < files.size(); ++i)
    {
        FileRegistered* fr = get_file_registered_from_file(files[i]);
        if (!fr)
        {
            vec.push_back(files[i]);
            continue;
        }

        MediaConchLib::Checker_StatusRes st_res;
        int ret = mainwindow->is_analyze_finished(files[i], st_res, err);
        if (ret < 0)
        {
            mainwindow->set_str_msg_to_status_bar(err);
            continue;
        }

        fr->analyzed = st_res.finished;
        if (st_res.finished)
        {
            fr->report_kind = MediaConchLib::report_MediaConch;
            if (st_res.tool)
                fr->report_kind = *st_res.tool;

            for (size_t x = 0; x < st_res.generated_id.size(); ++x)
                fr->generated_id.push_back(st_res.generated_id[x]);

            std::vector<size_t> policies_ids;
            std::vector<std::string> policies_contents;
            std::map<std::string, std::string> options;
            std::vector<MediaConchLib::Checker_ValidateRes*> res;

            if (mainwindow->validate((MediaConchLib::report)fr->report_kind, files[i],
                policies_ids, policies_contents, options, res, err) < 0)
            {
                mainwindow->set_str_msg_to_status_bar(err);
                continue;
            }
            else if (!res.size())
            {
                mainwindow->set_str_msg_to_status_bar("Internal error: Validate result is not correct.");
                continue;
            }
            fr->implementation_valid = res[0]->valid;

            for (size_t j = 0; j < res.size(); ++j)
                delete res[j];
            res.clear();

            if (fr->policy >= 0)
            {
                policies_ids.push_back(fr->policy);

                if (mainwindow->validate(MediaConchLib::report_Max, files[i],
                    policies_ids, policies_contents, options, res, err) < 0)
                    continue;

                if (!res.size())
                    continue;

                fr->policy_valid = res[0]->valid;
                for (size_t j = 0; j < res.size(); ++j)
                    delete res[j];
                res.clear();
            }
        }
        else
        {
            fr->analyze_percent = 0.0;
            if (st_res.percent)
                fr->analyze_percent = *st_res.percent;
            vec.push_back(files[i]);
        }

        to_update_files_mutex.lock();
        if (to_update_files.find(files[i]) != to_update_files.end())
        {
            delete to_update_files[files[i]];
            to_update_files[files[i]] = new FileRegistered(*fr);
        }
        else
            to_update_files[files[i]] = new FileRegistered(*fr);
        to_update_files_mutex.unlock();

        working_files_mutex.lock();
        if (working_files.find(files[i]) != working_files.end())
        {
            delete working_files[files[i]];
            working_files[files[i]] = fr;
        }
        else
            delete fr;
        working_files_mutex.unlock();
    }

    unfinished_files_mutex.lock();
    if (files.size() != unfinished_files.size())
    {
        for (size_t i = 0; i < unfinished_files.size(); ++i)
        {
            size_t j = 0;
            for (; j < files.size(); ++j)
                if (files[j] == unfinished_files[i])
                    break;
            if (j == files.size())
                vec.push_back(unfinished_files[i]);
        }
    }
    unfinished_files = vec;
    unfinished_files_mutex.unlock();
}

//---------------------------------------------------------------------------
void WorkerFiles::remove_file_registered_from_id(long file_id)
{
    std::string file;
    FileRegistered *fr = NULL;
    working_files_mutex.lock();
    std::map<std::string, FileRegistered*>::iterator it = working_files.begin();
    for (; it != working_files.end(); ++it)
    {
        if (!it->second)
            continue;

        if (it->second->file_id == file_id)
        {
            fr = it->second;
            file = it->first;
            it->second = NULL;
            working_files.erase(it);
            break;
        }
    }
    working_files_mutex.unlock();

    if (!fr)
        return;

    to_delete_files_mutex.lock();
    to_delete_files[file] = fr;
    to_delete_files_mutex.unlock();
}

//---------------------------------------------------------------------------
void WorkerFiles::remove_all_files_registered()
{
    std::string file;
    FileRegistered *fr = NULL;

    working_files_mutex.lock();
    std::map<std::string, FileRegistered*>::iterator it = working_files.begin();
    for (; it != working_files.end(); ++it)
    {
        if (!it->second)
            continue;

        fr = it->second;
        file = it->first;
        it->second = NULL;

        to_delete_files_mutex.lock();
        to_delete_files[file] = fr;
        to_delete_files_mutex.unlock();
    }
    working_files.clear();
    working_files_mutex.unlock();

}

//---------------------------------------------------------------------------
void WorkerFiles::add_registered_file_to_db(const FileRegistered* file)
{
    if (!db)
        return;

    db->ui_add_file(file);
}

//---------------------------------------------------------------------------
void WorkerFiles::add_registered_files_to_db(const std::vector<FileRegistered*>& files)
{
    if (!db)
        return;

    for (size_t i = 0; i < files.size();)
    {
        std::vector<FileRegistered*> tmp;
        size_t j = 0;
        for (; j < 50 && i + j < files.size(); ++j)
            tmp.push_back(files[i + j]);
        db->ui_add_files(tmp);
        i += j;
    }
}

//---------------------------------------------------------------------------
void WorkerFiles::update_registered_file_in_db(const FileRegistered* file)
{
    if (!db)
        return;

    db->ui_update_file(file);
}

//---------------------------------------------------------------------------
void WorkerFiles::update_registered_files_in_db(const std::vector<FileRegistered*>& files)
{
    if (!db)
        return;

    db->ui_update_files(files);
}

//---------------------------------------------------------------------------
void WorkerFiles::remove_registered_file_from_db(const FileRegistered* file)
{
    if (!db)
        return;

    db->ui_remove_file(file);
}

//---------------------------------------------------------------------------
void WorkerFiles::remove_registered_files_from_db(const std::vector<FileRegistered*>& files)
{
    if (!db)
        return;

    db->ui_remove_files(files);
}

//---------------------------------------------------------------------------
void WorkerFiles::remove_all_registered_file_from_db()
{
    if (!db)
        return;

    db->ui_remove_all_files();
}

//---------------------------------------------------------------------------
void WorkerFiles::get_registered_file_from_db(FileRegistered* file)
{
    if (!db || !file)
        return;

    db->ui_get_file(file);
}

//---------------------------------------------------------------------------
void WorkerFiles::fill_registered_files_from_db()
{
    if (!db)
        return;

    std::vector<FileRegistered*> vec;
    db->ui_get_elements(vec);

    std::vector<std::string> files;
    working_files_mutex.lock();
    for (size_t i = 0; i < vec.size(); ++i)
    {
        std::string err2;
        QString err;
        FileRegistered *fr = vec[i];

        std::string full_file(fr->filepath);
#ifdef WINDOWS
        if (full_file.size() && full_file[full_file.size() - 1] != '/' && full_file[full_file.size() - 1] != '\\')
            full_file += "/";
#else
        if (full_file.length())
            full_file += "/";
#endif
        full_file += fr->filename;

        //check if policy still exists
        MediaConchLib::Get_Policy p;
        if (fr->policy != -1 && mainwindow->policy_get(fr->policy, "JSON", p, err) < 0)
        {
            mainwindow->set_msg_to_status_bar(err);
            fr->policy = -1;
        }

        fr->index = file_index++;
        fr->analyzed = false;

        working_files[full_file] = fr;
        files.push_back(full_file);


        std::vector<std::string> tmp;
        tmp.push_back(full_file);

        int ret;
        std::vector<long> files_id;
        if ((ret = mainwindow->analyze(tmp, false, false, fr->options, files_id, err2)) < 0)
            mainwindow->set_str_msg_to_status_bar(err2);
        else if (!files_id.size())
            mainwindow->set_str_msg_to_status_bar("Internal error: Analyze result is not correct.");
        else
            fr->file_id = files_id[0];
    }
    working_files_mutex.unlock();

    unfinished_files_mutex.lock();
    for (size_t i = 0; i < files.size(); ++i)
        unfinished_files.push_back(files[i]);
    unfinished_files_mutex.unlock();
}

}
