OpenServerCommand.cpp

//
// Created by duni on 20/12/2019.
//

#include <netinet/in.h>
#include <unistd.h>
#include "OpenServerCommand.h"
#include <iostream>
#include <thread>
#include "parseBufferToSymbleTable.h"
#include "globalVariables.h"
#include "ExpressionCalculate.h"
#include <algorithm>

// This function reads messages from the simulator
void listenForSimulatorMessages(int newSocket) {

    char buffer1[1] = {0};
    string bufferWithLine = "";
    map<string, pair<float, string>>::iterator it;
    auto *parseBufferToSymbolTable1 = new parseBufferToSymbolTable();
    while (read(newSocket, buffer1, 1)) {
        globalVariables::symbolTableMutex.lock();
        char currChar = buffer1[0];
        if (currChar != '\n') {
            // Insert each letter to the current buffer - each buffer contains a single line
            bufferWithLine += buffer1[0];
        } else {
            // If the current line is over - send it to the parsing function
            parseBufferToSymbolTable1->parseBufferAnsSymbolTables(bufferWithLine);
            bufferWithLine = "";
            // Insert the given values into the xml map
            for (it = globalVariables::symbolTableSimToClient.begin();
                 it != globalVariables::symbolTableSimToClient.end();
                 it++) {
                string sim = it->second.second;
                float value = globalVariables::xmlMap[sim];
                it->second.first = value;
            }
        }

        globalVariables::symbolTableMutex.unlock();
    }

    close(newSocket);
}

void connectServer(int port) {
    int serverFd, newSocket, readValue;
    struct sockaddr_in socketAddress;
    int optionNumber = 1;
    int addressLength = sizeof(socketAddress);
    char *message;

    // Create socket
    if ((serverFd = socket(AF_INET, SOCK_STREAM, 0)) == 0) {
        perror("socket failed");
        exit(EXIT_FAILURE);
    }

    // Attaching socket
    if (setsockopt(serverFd, SOL_SOCKET, SO_REUSEADDR | SO_REUSEPORT, &optionNumber, sizeof(optionNumber))) {
        perror("setsockopt");
        exit(EXIT_FAILURE);
    }

    socketAddress.sin_family = AF_INET;
    socketAddress.sin_addr.s_addr = INADDR_ANY;
    socketAddress.sin_port = htons(port);

    if (bind(serverFd, (struct sockaddr *) &socketAddress, sizeof(socketAddress)) < 0) {
        perror("bind failed");
        exit(EXIT_FAILURE);
    }

    if (listen(serverFd, 3) < 0) {
        perror("listen");
        exit(EXIT_FAILURE);
    }

    // Accept clients
    cout << "accepting clients" << endl;
    if ((newSocket = accept(serverFd, (struct sockaddr *) &socketAddress, (socklen_t *) &addressLength)) < 0) {
        perror("accept");
        exit(EXIT_FAILURE);
    }

    cout << "client connected, listen for messages" << endl;
    // Read from the simulator every 10 milliseconds
    thread simSyncThread(listenForSimulatorMessages, newSocket);
    simSyncThread.detach();
}

int OpenServerCommand::execute(vector<string> params) {

    Interpreter *i = new Interpreter();
    Expression *answer = nullptr;
    // Remove spaces
    string::iterator end_pos = remove(params[1].begin(), params[1].end(), ' ');
    params[1].erase(end_pos, params[1].end());
    // Remove tabs
    end_pos = remove(params[1].begin(), params[1].end(), '\t');
    params[1].erase(end_pos, params[1].end());
    // Calculate the port
    answer = i->interpret(params[1]);
    int port = answer->calculate();
    // Open the thread
    thread threadServer(connectServer, port);
    threadServer.join();
    return 2;
}