main.cpp

Go to the documentation of this file.

/***************************************
        Auteur : Pierre Aubert
        Mail : pierre.aubert@lapp.in2p3.fr
        Licence : CeCILL-C
****************************************/
 
#include <iostream>
 
#include "swarm_mock_daemon.h"


/*-----------------------------------
Configuration:
- localhost:3390 is the Recv mock file to stop the Daemon
- localhost:3391 is the Send mock file to test the Daemon
 
Workflow :
1. The 'main' SendDataDaemon sends an INT data to the 'test' Daemon.
2. As we are in mock mode, we check that the sent data are correctly serialized in the mock file.
3. The 'main' Daemon receives the data and process it (here we do nothing with it).
4. Finally, the 'main' Daemon is stopped by a STOP message from another daemon.
 
+----------------+                                                 +-----------------------------------+
|   main daemon  |--- RESULT_DATA (INT=42)-->|  Mock file (main_localhost_3391)  |
+----------------+                                                 +-----------------------------------+
                |
                |  <--- STOP message ---------------
                |
------------------------------------*/
void createMockFileMainSend(const PString & hostName, size_t port, const PString & prefix){
        PMockSocketGenerator::Socket mock;
        phoenix_assert(phoenix_initializeMockSocket(mock, PSocketParam{hostName, port}, prefix));
//      PVecMockMessage vecOutput;
        //Let's say, the main Daemon wants to call a function on test
        Message message;
        message.setId(1lu);     //Anwser of the INT message
        message.setSendTime(1lu);
        message.setIsConfirmationNeeded(true);
        message.setType(MessageType::RESULT_DATA);
        message.setSender("main");
        int data(42);
        message.setData(phoenix_createData(data));
        message.getVecRecver().push_back("test");
        mock.sendData(message);
}


void createMockFileMainRecv(const PString & hostName, size_t port, const PString & prefix){
        PMockSocketGenerator::Socket mock;
        phoenix_assert(phoenix_initializeMockSocket(mock, PSocketParam{hostName, port}, prefix));
 
        //Finally we stop the Daemon
        Message messageStop;
        messageStop.setId(2lu);
        messageStop.setType(MessageType::STOP);
        mock.sendData(messageStop);
}


void createDaemon(const PPath & fileName, const PString & daemonName){
        //Let's create and start the Daemon
        SendDataDaemon daemon;
        daemon.setSocketMode(PSocketMode::MOCK);
        daemon.setClockMode(PClockMode::MOCK);
        daemon.getLog().setFileName(PPath("Daemon.log"));
        daemon.load(fileName, daemonName);
        phoenix_assert(daemon.run());
}


void testBaseDaemonLoadConfig(const PPath & fileName){
        //Let's create the mock file
        phoenix_createClockMock("main_", 4lu);
        createMockFileMainRecv("localhost", 3390, "main_");
        //No need to check the output of the messages sent by the Daemon, because the PMockSocketGenerator already does it for us
        createMockFileMainSend("localhost", 3391, "main_");
        //Let's create and start the Daemon
        createDaemon(fileName, "main");
}
 
int main(int argc, char** argv){
        testBaseDaemonLoadConfig(PPath(DAEMON_CONFIG_OK_TOML));
        testBaseDaemonLoadConfig(PPath(DAEMON_CONFIG_OK_YAML));
        return 0;
}