/* 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.
 */

//! \file
//! \ingroup sampleblackmiscdbus

#include "servicetool.h"
#include "testservice.h"
#include "testserviceinterface.h"
#include "blackmisc/aviation/aircrafticaocode.h"
#include "blackmisc/aviation/aircraftsituation.h"
#include "blackmisc/aviation/airport.h"
#include "blackmisc/aviation/altitude.h"
#include "blackmisc/aviation/atcstation.h"
#include "blackmisc/aviation/comsystem.h"
#include "blackmisc/aviation/track.h"
#include "blackmisc/aviation/transponder.h"
#include "blackmisc/compare.h"
#include "blackmisc/dbusserver.h"
#include "blackmisc/geo/coordinategeodetic.h"
#include "blackmisc/iterator.h"
#include "blackmisc/network/client.h"
#include "blackmisc/network/server.h"
#include "blackmisc/network/user.h"
#include "blackmisc/pq/constants.h"
#include "blackmisc/pq/frequency.h"
#include "blackmisc/pq/length.h"
#include "blackmisc/pq/speed.h"
#include "blackmisc/pq/units.h"
#include "blackmisc/propertyindex.h"
#include "blackmisc/propertyindexvariantmap.h"
#include "blackmisc/sequence.h"
#include "blackmisc/simulation/aircraftmodel.h"
#include "blackmisc/simulation/fscommon/aircraftcfgentries.h"
#include "blackmisc/simulation/simulatedaircraft.h"
#include "blackmisc/simulation/simulatorplugininfo.h"
#include "blackmisc/stringutils.h"
#include "blackmisc/variant.h"
#include "blackmisc/variantlist.h"

#include <stdio.h>
#include <stdlib.h>
#include <QChar>
#include <QDBusConnection>
#include <QDBusConnectionInterface>
#include <QDBusError>
#include <QDBusMessage>
#include <QDBusObjectPath>
#include <QDBusPendingReply>
#include <QDBusReply>
#include <QDBusVariant>
#include <QDateTime>
#include <QDebug>
#include <QElapsedTimer>
#include <QFlags>
#include <QLatin1Char>
#include <QList>
#include <QObject>
#include <QProcess>
#include <QString>
#include <QTextStream>
#include <QThread>
#include <QVariant>
#include <QtDebug>

class QDBusObjectPath;

using namespace BlackMisc;
using namespace BlackMisc::Simulation;
using namespace BlackMisc::PhysicalQuantities;
using namespace BlackMisc::Aviation;
using namespace BlackMisc::Math;
using namespace BlackMisc::Geo;
using namespace BlackMisc::Network;
using namespace BlackMisc::Simulation::FsCommon;

namespace BlackSample
{
    QProcess *ServiceTool::startNewProcess(const QString &executable, const QStringList &arguments, QObject *parent)
    {
        QProcess *process = new QProcess(parent);
        process->startDetached(executable, arguments);
        return process;
    }

    void ServiceTool::displayQDBusArgument(const QDBusArgument &arg, qint32 level)
    {
        arg.beginArray();
        QVariant qv;
        QString indent(level * 2, ' ');

        while (!arg.atEnd())
        {
            QDBusArgument::ElementType type = arg.currentType();
            QString signature = arg.currentSignature();
            qv = arg.asVariant(); // this advances in the stream
            if (qv.canConvert<QDBusArgument>())
            {
                qDebug() << indent << type << "signature" << signature;
                ServiceTool::displayQDBusArgument(qv.value<QDBusArgument>(), level + 1);
            }
            else
            {
                qDebug() << indent << "type:" << type << "signature" << signature << "value" << qv;
            }
        }
        arg.endArray();
    }

    void ServiceTool::dataTransferTestServer(BlackMisc::CDBusServer *dBusServer)
    {
        QDBusConnection sessionBusConnection = QDBusConnection::sessionBus();
        if (sessionBusConnection.interface()->isServiceRegistered(Testservice::InterfaceName))
        {
            qFatal("Testservice already registed on session bus");
        }

        // as this is the receiver side, the slots can be debugged too
        Testservice *testservice = ServiceTool::registerTestservice(sessionBusConnection, QCoreApplication::instance());
        dBusServer->addObject(Testservice::ObjectPath, testservice);
    }

    void ServiceTool::dataTransferTestClient(const QString &address)
    {
        // send data as P2P to server (this can be session bus, too, but usually is P2P)
        bool sb = (address.toLower().startsWith("session"));
        QDBusConnection p2pConnection = sb ?
                                        QDBusConnection::sessionBus() :
                                        QDBusConnection::connectToPeer(address, "p2pConnection");

        qDebug() << "------------ connection info ---------------";
        qDebug() << "server connection has interface?" << p2pConnection.interface(); // returns 0 with server and a real interface with session bus
        qDebug() << "address:" << address;
        qDebug() << "name:" << p2pConnection.name();
        qDebug() << "------------ connection info ---------------";

        ServiceTool::sendDataToTestservice(p2pConnection);
    }

    CCallsign ServiceTool::getRandomAtcCallsign()
    {
        static QList<CCallsign> callsigns;
        if (callsigns.isEmpty())
        {
            callsigns << CCallsign("EDDM_TWR");
            callsigns << CCallsign("EDDM_APP");
            callsigns << CCallsign("EDDM_GND");
            callsigns << CCallsign("EDDF_TWR");
            callsigns << CCallsign("EDDF_APP");
            callsigns << CCallsign("EDDF_GND");
        }
        int i = (rand() % (callsigns.size()));
        CCallsign cs = callsigns.at(i);
        return cs;
    }

    CAtcStationList ServiceTool::getStations(int number)
    {
        QElapsedTimer timer;
        timer.start();

        BlackMisc::Aviation::CAtcStationList list;
        for (int i = 0; i < number; i++)
        {
            BlackMisc::Aviation::CAtcStation s;
            s.setCallsign(QString::number(i));
            s.setFrequency(BlackMisc::PhysicalQuantities::CFrequency(i, BlackMisc::PhysicalQuantities::CFrequencyUnit::MHz()));
            s.setController(CUser(QString::number(i), "FooBar", "", ""));
            s.setOnline(i % 2 == 0 ? true : false);
            s.setPosition(CCoordinateGeodetic(i, i, i));
            list.push_back(s);
        }

        qDebug() << number << "stations in" << timer.nsecsElapsed() / 1000000; // ms
        return list;
    }

    CAircraftCfgEntriesList ServiceTool::getAircraftCfgEntries(int number)
    {
        QElapsedTimer timer;
        timer.start();

        CAircraftCfgEntriesList list;
        for (int i = 0; i < number; i++)
        {
            CAircraftCfgEntries e;
            e.setAtcModel("atc model");
            e.setAtcParkingCode(QString::number(i));
            e.setIndex(i);
            e.setFileName("this will be the file path and pretty long");
            e.setTitle("i am the aircraft title foobar");
            e.setAtcType("B737");
            list.push_back(e);
        }

        qDebug() << number << "aircraft entries in" << timer.nsecsElapsed() / 1000000; // ms
        return list;
    }

    CAirportList ServiceTool::getAirports(int number)
    {
        BlackMisc::Aviation::CAirportList list;
        for (int i = 0; i < number; i++)
        {
            char cc = 65 + (i % 26);
            QString icao = QString("EXX%1").arg(QLatin1Char(cc));
            BlackMisc::Aviation::CAirport a(icao);
            a.setPosition(CCoordinateGeodetic(i, i, i));
            list.push_back(a);
        }
        return list;
    }

    CClientList ServiceTool::getClients(int number)
    {
        BlackMisc::Network::CClientList list;
        for (int i = 0; i < number; i++)
        {
            CCallsign cs(QString("DXX%1").arg(i));
            QString rn = QString("Joe Doe%1").arg(i);
            CUser user(QString::number(i), rn, cs);
            user.setCallsign(cs);
            CClient client(user);
            client.setCapability(true, CClient::FsdWithInterimPositions);
            client.setCapability(true, CClient::FsdWithIcaoCodes);
            const QString myFooModel = QString("fooModel %1").arg(i);
            client.setQueriedModelString(myFooModel);
            list.push_back(client);
        }
        return list;
    }

    Testservice *ServiceTool::registerTestservice(QDBusConnection &connection, QObject *parent)
    {
        Testservice *pTestservice = new Testservice(parent);  // just a QObject with signals / slots and  Q_CLASSINFO("D-Bus Interface", some service name)
        if (!connection.registerService(Testservice::InterfaceName))
        {
            QDBusError err = connection.lastError();
            qWarning() << err.message();
            qWarning() << "Started dbus-daemon.exe --session (Windows)?";
            qWarning() << "Created directory session.d (e.g. ../Qt/Qt5.1.0Vatsim/5.1.0-32/qtbase/etc/dbus-1/session.d)?";
            qWarning() << "See https://dev.vatsim-germany.org/projects/vatpilotclient/wiki/DBusExample#Running-the-example";
            qFatal("Could not register service!");
        }

        if (!connection.registerObject(Testservice::ObjectPath, pTestservice, QDBusConnection::ExportAllSlots | QDBusConnection::ExportAllSignals | QDBusConnection::ExportAdaptors))
        {
            qFatal("Could not register service object!");
        }

        qDebug() << "Registration running as pid:" << ServiceTool::getPid();
        if (pTestservice) qDebug() << "Service registered";

        QString service; // service not needed
        if (connection.connect(
                    service, Testservice::ObjectPath, Testservice::InterfaceName,
                    "sendStringMessage", pTestservice, SLOT(receiveStringMessage(const QString &))))
        {
            qDebug() << "Connected object with bus sendStringMessage";
        }
        else
        {
            qFatal("Cannot connect service with DBus");
        }
        return pTestservice;
    }

    void ServiceTool::sendDataToTestservice(const QDBusConnection &connection)
    {
        // on the client's side
        TestServiceInterface testserviceInterface(Testservice::InterfaceName, Testservice::ObjectPath, connection);

        CSpeed speed(200, CSpeedUnit::km_h());
        CSpeed speedNull(0, CSpeedUnit::nullUnit());
        CAltitude al(1000, CAltitude::MeanSeaLevel, CLengthUnit::ft());
        QTextStream qtin(stdin);
        QString line;

        while (true)
        {
            QDBusMessage m = QDBusMessage::createSignal(
                                 Testservice::ObjectPath, Testservice::InterfaceName,
                                 "sendStringMessage");

            // The << operator is used to add the parameters for the slot
            QDateTime dtnow = QDateTime::currentDateTimeUtc();
            QString msg = QString("Message from %1 at %2").arg(ServiceTool::getPid()).arg(dtnow.toString("MM/dd/yyyy @ hh:mm:ss"));
            m << msg;

            // We send this as a non-replying message. This is used for sending errors, replys, signals,
            // and method calls (slots) that don't return
            if (connection.send(m)) { qDebug() << "Send via low level method" << m; }

            // same as interface message
            // but call the slot
            testserviceInterface.receiveStringMessage(msg);
            qDebug() << "Send string via interface" << msg;

            // a list
            QList<double> list;
            list << 1.0 << 2.0 << 3.0;
            testserviceInterface.receiveList(list);
            qDebug() << "Send list via interface" << list;

            // PQs
            testserviceInterface.receiveSpeed(speed);
            qDebug() << "Send speed via interface" << speed;
            testserviceInterface.receiveSpeed(speedNull);
            qDebug() << "Send null speed via interface" << speedNull;
            speed.switchUnit(CSpeedUnit::kts());
            testserviceInterface.receiveSpeed(speed);
            qDebug() << "Send speed via interface" << speed;
            QThread::msleep(2500);
            speed.switchUnit(CSpeedUnit::km_h());
            speed.addValueSameUnit(1.0);

            // Network
            CServer trafficServer("fooserver", "a foo server", "localhost", 1234,
                                  CUser("112233", "Some real name", "email@xyz.com", "secret"));
            QVariant tsqv = QVariant::fromValue(trafficServer);
            QDBusVariant tsv(tsqv);
            testserviceInterface.receiveVariant(tsv, tsqv.userType());
            qDebug() << "Send server via interface and variant" << trafficServer <<  tsqv.userType();

            // Aviation
            CComSystem comSystem = CComSystem("DBUS COM1", CPhysicalQuantitiesConstants::FrequencyInternationalAirDistress(), CPhysicalQuantitiesConstants::FrequencyUnicom());
            testserviceInterface.receiveComUnit(comSystem);
            qDebug() << "Send COM via interface" << comSystem;

            QVariant qvAl = QVariant::fromValue(al);
            QDBusVariant qv(qvAl);
            testserviceInterface.receiveVariant(qv, qvAl.userType());
            testserviceInterface.receiveAltitude(al);
            qDebug() << "Send altitude via interface and variant" << al << qvAl.userType();
            al.addValueSameUnit(1);

            CTransponder transponder(7000, CTransponder::ModeC);
            testserviceInterface.receiveTransponder(transponder);
            qDebug() << "Send transponder via interface" << transponder;

            CTrack track(123.45, CTrack::Magnetic, CAngleUnit::deg());
            testserviceInterface.receiveTrack(track);
            qDebug() << "Send track via interface" << track;

            CLength len(33, CLengthUnit::m());
            testserviceInterface.receiveLength(len);
            qDebug() << "Send length via interface" << len;

            CAltitude alt(44, CAltitude::MeanSeaLevel, CLengthUnit::m());
            testserviceInterface.receiveLength(alt);
            qDebug() << "Send altitude via interface" << alt;

            CCallsign callsign("d-ambz");
            testserviceInterface.receiveCallsign(callsign);
            qDebug() << "Send callsign via interface" << callsign;

            CCoordinateGeodetic geoPos = CCoordinateGeodetic::fromWgs84("48° 21′ 13″ N", "11° 47′ 09″ E", CLength(1487, CLengthUnit::ft())); // Munich
            CAtcStation station(CCallsign("eddm_twr"), CUser("123456", "Joe Controller"),
                                CFrequency(118.7, CFrequencyUnit::MHz()),
                                geoPos, CLength(50, CLengthUnit::km()));

            testserviceInterface.receiveAtcStation(station);
            qDebug() << "Send ATC" << station;

            // Geo
            // EDDF: 50° 2′ 0″ N, 8° 34′ 14″ E, 100m MSL
            geoPos = CCoordinateGeodetic::fromWgs84("50° 2′ 1″ 23 N", "8° 34′ 14″ E", CLength(111, CLengthUnit::m()));
            testserviceInterface.receiveGeoPosition(geoPos);
            qDebug() << "Send geo position" << geoPos;

            qDebug() << "----------------- pings ----------------";
            CPropertyIndex pi({ 1000, 2000, 3000, 4000, 5000}); // numbers >= global index
            pi = testserviceInterface.pingPropertyIndex(pi);
            qDebug() << "Pinged property index via interface" << pi;

            CPropertyIndexVariantMap ivm;
            ivm.addValue(1000, "one");
            ivm.addValue(2000, "two");
            ivm.addValue(3000, "three");
            ivm = testserviceInterface.pingIndexVariantMap(ivm);
            qDebug() << "Pinged variant map via interface" << ivm;

            CSimulatorPluginInfo pluginInfo("fsx", "FSX Simulator", "FSX", "Flight Simulator X", true);
            CSimulatorPluginInfo pluginInfoReceived = testserviceInterface.pingPluginInfo(pluginInfo);
            qDebug() << "Pinged info via interface"
                     << ((pluginInfo == pluginInfoReceived) ? "OK" : "ERROR!") << pluginInfoReceived;

            CAtcStation stationReceived  = testserviceInterface.pingAtcStation(station);
            qDebug() << "Pinged ATC station via interface"
                     << ((station == stationReceived) ? "OK" : "ERROR!") << stationReceived;

            CAircraftIcaoCode icaoData("B737", "L2J");
            CAircraftIcaoCode icaoReceived = testserviceInterface.pingAircraftIcaoData(icaoData);
            qDebug() << "Pinged ICAO data via interface"
                     << ((icaoData == icaoReceived) ? "OK" : "ERROR!") << icaoReceived;

            CUser pingUser("223344", "Ping Me User");
            CUser userReceived = testserviceInterface.pingUser(pingUser);
            qDebug() << "Pinged user via interface"
                     << ((userReceived == pingUser) ? "OK" : "ERROR!") << userReceived;

            CAircraftSituation situation;
            CAircraftSituation situationReceived = testserviceInterface.pingSituation(situation);
            qDebug() << "Pinged situation via interface"
                     << ((situation == situationReceived) ? "OK" : "ERROR!") << situationReceived;

            CTransponder transponderReceived = testserviceInterface.pingTransponder(transponder);
            qDebug() << "Pinged transponder via interface"
                     << ((transponderReceived == transponder) ? "OK" : "ERROR!") << transponderReceived;

            CSimulatedAircraft aircraft(callsign, CUser("123456", "Joe Pilot"), situation);
            aircraft.setTransponder(transponder);
            CSimulatedAircraft aircraftReceived(testserviceInterface.pingAircraft(aircraft));
            qDebug() << "Pinged aircraft via interface"
                     << ((aircraft == aircraftReceived) ? "OK" : "ERROR!") << aircraftReceived;

            CSimulatedAircraft simAircraft(aircraft);
            CAircraftModel model("foobar", CAircraftModel::TypeManuallySet);
            simAircraft.setModel(model);
            CSimulatedAircraft simAircraftReceived = testserviceInterface.pingSimulatedAircraft(simAircraft);
            qDebug() << "Pinged simulated aircraft via interface"
                     << ((simAircraft == simAircraftReceived) ? "OK" : "ERROR!") << simAircraftReceived;

            CAtcStationList atcStationList;
            atcStationList.push_back(station);
            atcStationList.push_back(station);
            atcStationList.push_back(station);
            atcStationList = testserviceInterface.pingAtcStationList(atcStationList);
            qDebug() << "Pinged ATC station list via interface" << atcStationList.size() << atcStationList;

            CAirportList airportList = ServiceTool::getAirports(10);
            airportList = testserviceInterface.pingAirportList(airportList);
            qDebug() << "Pinged airport list via interface" << airportList.size() << airportList;

            CClientList clients = ServiceTool::getClients(10);
            CClient client = clients.front();
            client = testserviceInterface.pingClient(client);
            qDebug() << "Pinged client via interface" << client;
            clients = testserviceInterface.pingClientList(clients);
            qDebug() << "Pinged client list via interface" << clients.size() << clients;

            CVariant cv = CVariant::fromValue(clients);
            qDebug() << "cv" << cv.toQString();
            cv = testserviceInterface.pingCVariant(client);
            qDebug() << "Pinged CVariant via interface" << cv.toQString();

            // test variant lists with different types wrapped in CVariant
            qDebug() << "----------------- variant tests ----------------";
            CVariantList cvList;
            cvList.push_back(CVariant::fromValue(len));
            cvList.push_back(CVariant::fromValue(alt));
            CVariantList lengthsV;
            lengthsV.push_back(CVariant::fromValue(len));
            lengthsV.push_back(CVariant::fromValue(alt));
            testserviceInterface.receiveLengthsQvl(cvList);
            qDebug() << "Send lengths via interface as CVariantList:";
            testserviceInterface.receiveLengthsQl(lengthsV);
            qDebug() << "Send lengths via interface as QList<CVariant>:";
            foreach(CVariant lv, cvList)
            {
                qDebug() << "   " << "Send length in list:" << lv;
            }
            QThread::msleep(2500);

            // Value map
            qDebug() << "----------------- index variant map ----------------";

            CPropertyIndexVariantMap valueMap;
            valueMap.addValue(1000, 111.222);
            valueMap.addValue(2000, callsign);
            valueMap.addValue(3000, alt);
            valueMap.addValue(4000, track);
            valueMap.addValue(5000, QDateTime::currentDateTime().addDays(1));
            valueMap.addValue(6000, QString("foobar"));
            testserviceInterface.receiveValueMap(valueMap);
            qDebug() << "Send index variant map" << valueMap;

            // Performance tools
            QThread::msleep(2500);
            qDebug() << "----------------- performance ----------------";

            QElapsedTimer timer;
            timer.start();
            for (int i = 0; i < 10; i++)
            {
                CSpeed speedDummy(i, CSpeedUnit::km_h());
                speedDummy = testserviceInterface.getSpeed();
            }
            qint64 t10 = timer.nsecsElapsed() / 1000000; // ms
            timer.restart();
            for (int i = 0; i < 100; i++)
            {
                CSpeed speedDummy(i, CSpeedUnit::km_h());
                speedDummy = testserviceInterface.getSpeed();
            }
            qint64 t100 = timer.nsecsElapsed() / 1000000; // ms
            timer.restart();
            for (int i = 0; i < 1000; i++)
            {
                CSpeed speedDummy(i, CSpeedUnit::km_h());
                speedDummy = testserviceInterface.getSpeed();
            }
            qint64 t1000 = timer.nsecsElapsed() / 1000000; // ms
            timer.invalidate();
            qDebug() << "Reading speed objects 10/100/1000 in ms:" << t10 << t100 << t1000;

            timer.start();
            for (int i = 0; i < 10; i++)
            {
                CAtcStation stationDummy(QString::number(i));
                stationDummy = testserviceInterface.getAtcStation();
            }
            t10 = timer.nsecsElapsed() / 1000000; // ms
            timer.restart();
            for (int i = 0; i < 100; i++)
            {
                CAtcStation stationDummy(QString::number(i));
                stationDummy = testserviceInterface.getAtcStation();
            }
            t100 = timer.nsecsElapsed() / 1000000; // ms
            timer.restart();
            for (int i = 0; i < 1000; i++)
            {
                CAtcStation stationDummy(QString::number(i));
                stationDummy = testserviceInterface.getAtcStation();
            }
            t1000 = timer.nsecsElapsed() / 1000000; // ms
            qDebug() << "Reading station objects 10/100/1000 in ms:" << t10 << t100 << t1000;

            timer.restart();
            atcStationList = testserviceInterface.getAtcStationList(10);
            if (atcStationList.size() != 10) qDebug() << "wrong list size" << atcStationList.size();
            t10 = timer.nsecsElapsed() / 1000000; // ms
            QThread::msleep(1000);

            timer.restart();
            atcStationList = testserviceInterface.getAtcStationList(100);
            if (atcStationList.size() != 100) qDebug() << "wrong list size" << atcStationList.size();
            t100 = timer.nsecsElapsed() / 1000000; // ms
            QThread::msleep(1000);

            timer.restart();
            atcStationList = testserviceInterface.getAtcStationList(1000);
            if (atcStationList.size() != 1000) qDebug() << "wrong list size" << atcStationList.size();
            t1000 = timer.nsecsElapsed() / 1000000; // ms
            qDebug() << "Reading station list 10/100/1000 in ms:" << t10 << t100 << t1000;

            // test reading model entries with a realistic size
            timer.restart();
            CAircraftCfgEntriesList entriesList = testserviceInterface.getAircraftCfgEntriesList(5000);
            if (entriesList.size() != 5000) qDebug() << "wrong list size" << entriesList.size();
            qint64 t5000 = timer.nsecsElapsed() / 1000000; // ms
            qDebug() << "Reading aircraft cfg entries in ms:" << t5000;

            // object paths
            timer.restart();
            QList<QDBusObjectPath> objectPaths = testserviceInterface.getObjectPaths(10);
            if (objectPaths.size() != 10) qDebug() << "wrong list size" << objectPaths.size();
            t10 = timer.nsecsElapsed() / 1000000; // ms

            timer.restart();
            objectPaths = testserviceInterface.getObjectPaths(100);
            if (objectPaths.size() != 100) qDebug() << "wrong list size" << objectPaths.size();
            t100 = timer.nsecsElapsed() / 1000000; // ms

            timer.restart();
            objectPaths = testserviceInterface.getObjectPaths(1000);
            if (objectPaths.size() != 1000) qDebug() << "wrong list size" << objectPaths.size();
            t1000 = timer.nsecsElapsed() / 1000000; // ms

            qDebug() << "Reading paths list 10/100/1000 in ms:" << t10 << t100 << t1000;
            timer.invalidate();

            // next round?
            qDebug() << "---------------------------------------";
            qDebug() << "Key  ....... x to exit, pid:" << ServiceTool::getPid();
            line = qtin.readLine().toLower().trimmed();
            if (line.startsWith('x'))
            {
                qDebug() << "Ending!";
                break;
            }
        }
    }
} // namespace