Chief.hpp

#pragma once
#include <samchon/protocol/ExternalServerArray.hpp>
#include <samchon/example/interaction/MasterDriver.hpp>

#include <samchon/protocol/Invoke.hpp>

#include <samchon/example/packer/Packer.hpp>
#include <samchon/example/tsp/Scheduler.hpp>

#include <thread>

namespace samchon
{
namespace example
{
namespace interaction
{
    using namespace std;

    using namespace library;
    using namespace protocol;

    class Chief
        : public ExternalServerArray
    {
    private:
        typedef ExternalServerArray super;

    public:
        /* ---------------------------------------------------------------------------------
            CONSTRUCTORS
        --------------------------------------------------------------------------------- */
        Chief(const string &ip)
        {
            emplace_back(new MasterDriver(this, "TSP", "127.0.0.1", 37110));
            emplace_back(new MasterDriver(this, "Reporter", ip, 37200));
            emplace_back(new MasterDriver(this, "Packer", ip, 37310));
        };
        virtual ~Chief() = default;

        virtual void start()
        {
            thread([this]()
            {
                super::start();
            }).detach();

            while (true)
            {
                int no;

                cout << "1. TSP Solver, 2. Packer: ";
                cin >> no;

                if (no == 1)
                    callTSP();
                else if (no == 2)
                    callPacker();
                else
                    continue;
            }
        };

    protected:
        virtual auto createChild(shared_ptr<XML>) -> ExternalSystem*
        {
            return new MasterDriver(this, "", "", 0);
        };

    public:
        /* ---------------------------------------------------------------------------------
            INVOKE MESSATE CHAIN
        --------------------------------------------------------------------------------- */
        virtual void replyData(shared_ptr<Invoke> invoke)
        {
            get("Reporter")->sendData(invoke);
        };

    private:
        void callPacker()
        {
            // CONSTRUCT PRODUCTS
            shared_ptr<packer::ProductArray> productArray(new packer::ProductArray());
            
            productArray->emplace_back( new packer::Product("Eraser", 500, 10, 70) );
            productArray->emplace_back( new packer::Product("Pencil", 400, 30, 35) );
            productArray->emplace_back( new packer::Product("Pencil", 400, 30, 35) );
            productArray->emplace_back( new packer::Product("Pencil", 400, 30, 35) );
            productArray->emplace_back( new packer::Product("Book", 8000, 150, 300) );
            productArray->emplace_back( new packer::Product("Book", 8000, 150, 300) );
            productArray->emplace_back( new packer::Product("Drink", 1000, 75, 250) );
            productArray->emplace_back( new packer::Product("Umbrella", 4000, 200, 1000) );
            productArray->emplace_back( new packer::Product("Notebook-PC", 800000, 150, 850) );
            productArray->emplace_back( new packer::Product("Tablet-PC", 600000, 120, 450) );

            // CONSTRUCT PACKER
            packer::Packer packer(productArray);
            
            packer.emplace_back( new packer::WrapperArray("Large", 100, 200, 1000) );
            packer.emplace_back( new packer::WrapperArray("Medium", 70, 150, 500) );
            packer.emplace_back( new packer::WrapperArray("Small", 50, 100, 250) );

            // SEND
            get("Packer")->sendData
            (
                make_shared<Invoke>
                (
                    "optimize", 
                    packer.toXML()
                )
            );
        };

        void callTSP()
        {
            shared_ptr<tsp::Travel> travel = make_shared<tsp::Travel>();
            for(int i = 0; i < 20; i++)
                travel->emplace_back(new tsp::GeometryPoint(i + 1));

            // GENETIC ALGORITHM
            struct tsp::GAParameters gaParameters = {.03, 30, 400, 400};

            // SEND
            tsp::Scheduler scheduler(travel, gaParameters);
            get("TSP")->sendData(make_shared<Invoke>("optimize", scheduler.toXML()));
        };

    public:
        /* ---------------------------------------------------------------------------------
            MAIN
        --------------------------------------------------------------------------------- */
        static void main()
        {
            string ip;

            cout << "----------------------------------------------------------------------------" << endl;
            cout << "   CHIEF" << endl;
            cout << "----------------------------------------------------------------------------" << endl;
            cout << "   ip: ";  cin >> ip;

            Chief cheif(ip);
            cheif.start();
        };
    };          
};
};
};