oscbridge2/serverinteractor.cpp at master · ragnarula/oscbridge2 · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
#include "serverinteractor.h"
#include "client.h"
#include "udpserver.h"
#include "messagehandler.h"

ServerInteractor::ServerInteractor(ServerPresenter& Presenter,
                                   ServerConfigurationStore& Store) :
    m_Presenter(Presenter),
    m_ConfigurationStore(Store)
{

}


ServerInteractor::~ServerInteractor()
{
   StopServer();
}

void ServerInteractor::InitFromStore(boost::asio::io_service& IOService, MessageHandler& MessageHandler)
{
    DeviceConfiguration StoredConfiguration = m_ConfigurationStore.GetServerConfiguration();
    StartServer(StoredConfiguration, IOService, MessageHandler);
}


void ServerInteractor::StartServer(const DeviceConfiguration& Configuration,
                                   boost::asio::io_service& IOService,
                                   MessageHandler& MessageHandler)
{
    std::string DeviceType;
    if(Configuration.Get("Type", DeviceType) && DeviceType == "UDP_SERVER") // TODO Remove constant
    {
        StopServer();
        m_ServerDevice = new UdpServer(Configuration, IOService, MessageHandler, *this);
        m_ConfigurationStore.StoreServerConfiguration(Configuration);
        m_ServerDevice->Start();
    }
}


void ServerInteractor::StopServer()
{
    if(m_ServerDevice)
    {
        m_ServerDevice->Reset();
        delete m_ServerDevice;
        m_ServerDevice = nullptr;
    }
}

void ServerInteractor::OnStateChange()
{
    auto CurrentDeviceState = m_ServerDevice->GetState();
    switch(CurrentDeviceState)
    {
    case UdpServerState::READY:
        m_Presenter.PresentServerState("Ready");
        break;
    case UdpServerState::ACCEPTING:
        m_Presenter.PresentServerState("Accepting");
        break;
    case UdpServerState::ERROR:
        m_Presenter.PresentServerState("Error");
        break;
     default:
        m_Presenter.PresentServerState("Unknown");
    }
}