Server.cpp

#include "Server.h"
#include "ServerSocket.h"
#include "SocketException.h"
#include "JsonControl.h"
#include "NodeHandler.h"
#include "Actions.h"
#include "rapidjson/include/rapidjson/document.h"
#include "rapidjson/include/rapidjson/writer.h"
#include "rapidjson/include/rapidjson/stringbuffer.h"
#include <stdint.h>
#include <cstdio>
#include <iostream>
#include <stdlib.h>
#include <thread>
#include <mutex>

NodeHandler node;

std::mutex NodeAccessMutex;

Server::Server()
{
  RunServer();
}


void dataHandlerThread(std::string data)
{
  SwitchDataPacket packet;
  const char * c = data.c_str();
  //JsonControl jsn;
  //jsn.DecodeJsonObject(c);

  rapidjson::Document doc;
  doc.Parse(c);
  uint64_t x = doc["nodeid"].GetUint64();
  std::cout << x << std::endl;
  node.SetWritingPipe(x);
  switch ( doc["action"].GetUint() )
  {
    case Actions::SWITCH:

    packet.state = doc["state"].GetUint();

    NodeAccessMutex.lock();
    node.WriteData(&packet,sizeof(packet)) != true;
    NodeAccessMutex.unlock();

    break;
    default:
    // Code
    break;
  }
  //std::cout << data << std::endl;


}

void newServerThread()
{

  std::cout << "running....\n";
  system("fuser 30000/tcp -k");

  node.InitRadio();

  for(;;)
  {

    try
    {
      // Create the socket
      ServerSocket server ( 30000 );

      while ( true )
      {
        ServerSocket new_sock;
        server.accept ( new_sock );

        try
        {
          while ( true )
          {
            std::string data;
            std::string send = "{\"sent\":true}";

            new_sock >> data;
            //new_sock << send;
            std::thread t2(dataHandlerThread, data);

            t2.detach();
          }
        }
        catch ( SocketException& ) {}
      }
    }
    catch ( SocketException& e )
    {
      std::cout << "Exception was caught:" << e.description() << "\nExiting.\n";
    }
  }
}



void Server::RunServer()
{
  std::thread t1(newServerThread);

  t1.join();
}

Server::~Server()
{

}