/* Copyright (C) 2013
 * swift project Community / Contributors
 *
 * This file is part of swift project. It is subject to the license terms in the LICENSE file found in the top-level
 * directory of this distribution and at http://www.swift-project.org/license.html. No part of swift project,
 * including this file, may be copied, modified, propagated, or distributed except according to the terms
 * contained in the LICENSE file.
 */

#include "aircraftmatcher.h"
#include "blackmisc/logmessage.h"
#include "blackmisc/worker.h"
#include <utility>
#include <atomic>

using namespace BlackMisc;
using namespace BlackMisc::Simulation;
using namespace BlackMisc::Network;
using namespace BlackMisc::Aviation;

namespace BlackMisc
{
    namespace Simulation
    {
        namespace FsCommon
        {

            CAircraftMatcher::CAircraftMatcher(MatchingMode matchingMode, QObject *parent) :
                QObject(parent),
                m_matchingMode(matchingMode)
            { }

            CAircraftMatcher::~CAircraftMatcher()
            {
                cancelInit();
                if (this->m_initWorker) { this->m_initWorker->waitForFinished(); }
            }

            void CAircraftMatcher::init()
            {
                if (m_initState != NotInitialized) { return; }
                m_initWorker = BlackMisc::CWorker::fromTask(this, "CAircraftMatcher::initImpl", [this]()
                {
                    initImpl();
                });
            }

            bool CAircraftMatcher::isInitialized() const
            {
                return m_initState == InitFinished;
            }

            void CAircraftMatcher::setModelMappingProvider(std::unique_ptr<IModelMappingsProvider> mappings)
            {
                m_mappingsProvider = std::move(mappings);
                if (m_matchingMode.testFlag(ModelMapping)) { initMappings(); }
            }

            void CAircraftMatcher::setMatchingModes(MatchingMode matchingModes)
            {
                m_matchingMode = matchingModes;
                if (m_matchingMode.testFlag(ModelMapping) && m_modelMappings.isEmpty()) initMappings();
            }

            CAircraftModel CAircraftMatcher::getClosestMatch(const CSimulatedAircraft &remoteAircraft)
            {
                CAircraftModel aircraftModel(remoteAircraft); // set defaults

                // Manually set string?
                if (remoteAircraft.getModel().hasManuallySetString())
                {
                    // manual set model, maybe update missing parts
                    aircraftModel.updateMissingParts(remoteAircraft.getModel());
                    aircraftModel.setCallsign(remoteAircraft.getCallsign());
                    reverseLookupIcaoData(aircraftModel);
                    return aircraftModel;
                }

                // mapper ready?
                if (!isInitialized())
                {
                    // will be removed later, just for experimental version
                    aircraftModel = getDefaultModel();
                    aircraftModel.setCallsign(remoteAircraft.getCallsign());
                    CLogMessage(static_cast<CAircraftMatcher *>(nullptr)).warning("Matcher not initialized, set to default model");
                    return aircraftModel;
                }

                aircraftModel = matchByExactModelName(remoteAircraft);

                if (!aircraftModel.hasModelString())
                {
                    aircraftModel = matchByMapping(remoteAircraft);
                }

                if (!aircraftModel.hasModelString())
                {
                    aircraftModel = matchByAlgorithm(remoteAircraft);
                }

                if (!aircraftModel.hasModelString())
                {
                    aircraftModel = getDefaultModel();
                }
                aircraftModel.setCallsign(remoteAircraft.getCallsign());

                Q_ASSERT(!aircraftModel.getCallsign().isEmpty());
                Q_ASSERT(aircraftModel.hasModelString());
                Q_ASSERT(aircraftModel.getModelType() != CAircraftModel::TypeUnknown);

                return aircraftModel;
            }

            CAircraftIcaoData CAircraftMatcher::getIcaoForModelString(const QString &modelString) const
            {
                if (modelString.isEmpty() || !isInitialized()) { return CAircraftIcaoData(); }
                CAircraftMappingList mappings = m_mappingsProvider->getMappingList().findByModelString(modelString);
                if (mappings.isEmpty()) { return CAircraftIcaoData(); }
                return mappings.front().getIcao();
            }

            int CAircraftMatcher::synchronize()
            {
                return synchronizeWithExistingModels(m_installedModels.getSortedModelStrings());
            }

            void CAircraftMatcher::cancelInit()
            {
                // when running, force re-init
                this->m_initState = NotInitialized;
            }

            const CAircraftModel &CAircraftMatcher::getDefaultModel()
            {
                return m_defaultModel;
            }

            void CAircraftMatcher::setDefaultModel(const BlackMisc::Simulation::CAircraftModel &defaultModel)
            {
                m_defaultModel = defaultModel;
            }

            void CAircraftMatcher::ps_setModelMappingRules(const CAircraftMappingList &mappings)
            {
                m_modelMappings = mappings;
            }

            void CAircraftMatcher::initImpl()
            {
                InitState e = NotInitialized;
                InitState d = InitInProgress;
                if (!m_initState.compare_exchange_strong(e, d)) { return; }

                // sync
                this->synchronize();
                CLogMessage(this).debug() << "Mapping definitions after sync" << m_modelMappings.size();

                // finish
                CLogMessage(this).info("Mapping system: %1 definitions for %2 installed models") << m_modelMappings.size()
                        << m_installedModels.size();
                m_initState = InitFinished;
                emit initializationFinished();
            }

            void CAircraftMatcher::initMappings()
            {
                Q_ASSERT(m_mappingsProvider);
                int mappingsSize = m_mappingsProvider->getMappingList().size();
                if (mappingsSize < 1)
                {
                    m_mappingsProvider->read();
                    m_modelMappings = m_mappingsProvider->getMappingList();
                    mappingsSize = m_modelMappings.size();
                    if (mappingsSize < 1)
                    {
                        CLogMessage(this).error("Reading mapping rules failed or empty!");
                        // Turn off the model mapping mode
                        m_matchingMode &= ~ModelMapping;
                        return;
                    }
                }
                m_modelMappings = m_mappingsProvider->getMappingList();
                CLogMessage(this).debug() << "Mapping definitions" << mappingsSize;
            }

            CAircraftModel CAircraftMatcher::matchByExactModelName(const CSimulatedAircraft &remoteAircraft)
            {
                CAircraftModel aircraftModel(remoteAircraft);
                // Model by queried string
                const CClient remoteClient = remoteAircraft.getClient();
                if (remoteClient.getAircraftModel().hasQueriedModelString())
                {
                    QString directModelString = remoteClient.getAircraftModel().getModelString();
                    if (!directModelString.isEmpty() && m_installedModels.containsModelString(directModelString))
                    {
                        aircraftModel = m_installedModels.findFirstByModelString(directModelString);
                        aircraftModel.setModelType(CAircraftModel::TypeQueriedFromNetwork);
                    }
                }

                return aircraftModel;
            }

            CAircraftModel CAircraftMatcher::matchByMapping(const CSimulatedAircraft &remoteAircraft)
            {
                CAircraftModel aircraftModel;
                CAircraftIcaoData icao = remoteAircraft.getIcaoInfo();
                BlackMisc::Network::CAircraftMappingList mappingList = m_modelMappings.findByIcaoAircraftAndAirlineDesignator(icao, true);
                if (!mappingList.isEmpty())
                {
                    CAircraftModel modelFromMappings = mappingList.front().getModel();
                    // now turn the model from the mapping rules into a model from the simulator which has more metadata
                    aircraftModel = m_installedModels.findFirstByModelString(modelFromMappings.getModelString());
                    Q_ASSERT(aircraftModel.getModelString() == modelFromMappings.getModelString());
                    aircraftModel.updateMissingParts(modelFromMappings); // update ICAO
                    aircraftModel.setModelType(CAircraftModel::TypeModelMatching);
                }

                return aircraftModel;
            }

            CAircraftModel CAircraftMatcher::matchByAlgorithm(const CSimulatedAircraft & /** remoteAircraft **/)
            {
                // Use an algorithm to find the best match
                return CAircraftModel();
            }

            int CAircraftMatcher::synchronizeWithExistingModels(const QStringList &modelNames, Qt::CaseSensitivity cs)
            {
                if (modelNames.isEmpty() || m_modelMappings.isEmpty()) { return 0; }
                CAircraftMappingList newList;
                for (const CAircraftMapping &mapping : m_modelMappings)
                {
                    if (this->m_initState != InitInProgress) { return 0; } // canceled
                    QString modelString = mapping.getModel().getModelString();
                    if (modelString.isEmpty()) { continue; }
                    if (modelNames.contains(modelString, cs))
                    {
                        newList.push_back(mapping);
                    }
                }
                this->m_modelMappings = newList;
                return this->m_modelMappings.size();
            }

            void CAircraftMatcher::reverseLookupIcaoData(CAircraftModel &model)
            {
                if (isInitialized())
                {
                    // reverse lookup of ICAO
                    CAircraftIcaoData icao =  getIcaoForModelString(model.getModelString());
                    icao.updateMissingParts(icao);
                    model.setIcao(icao);
                }
            }

        } // namespace
    } // namespace
} // namespace