ServerMediator.cc

#include "ServerMediator.h"

#include <iostream>
#include <cstdio>

using namespace std;
using namespace TP1;

const unsigned int MAX_BUF = 101;

/************************************
* Opens socket to server based on
* addr and port. Returns 0 on success
* and -1 if connection fails.
************************************/
int ServerMediator::connectToServer(string addr, unsigned port) {
    if (_logging) {
        cout << "Connecting to Server " << addr << ":" << port << endl;
    }
    //Variables used to determine address (IPv4 vs IPv6)
	  int returnCode = -1; 
    in6_addr serverAddr;
    addrinfo hints;

    //Hints structure will hold information about address
    bzero(&hints, sizeof(hints));
    hints.ai_flags    = AI_NUMERICSERV; //Indicates that port is a numeric number
    hints.ai_family   = AF_UNSPEC; //Family will be determined below
    hints.ai_socktype = SOCK_STREAM;  //TCP

    //Now let's try to figure out if it is IPv4 or IPv6
    //If below code doesn't get executed, this means we have
    //a name instead of a number (localhost, google.com, etc...)
    //The AI_NUMERICHOST flag prevents the name from being resolved,
    //in case we have our address is a number
    returnCode = inet_pton(AF_INET, addr.c_str(), &serverAddr);
    if (returnCode == 1) {  /* this is a valid IPv4 (number format) */
       hints.ai_family = AF_INET;
       hints.ai_flags |= AI_NUMERICHOST; 
    } else {
       returnCode = inet_pton(AF_INET6, addr.c_str(), &serverAddr);
       if (returnCode == 1) { /* this is a valid IPv6 (number format) */
          hints.ai_family = AF_INET6;
          hints.ai_flags |= AI_NUMERICHOST;
       }
    }

    returnCode = getaddrinfo(addr.c_str(), to_string(port).c_str() ,&hints, &_result);

    if (returnCode < 0 ) {
        cout << "ERROR when resolving server address" << endl;
        exit(1);
    }

    _serverSocketId = socket(_result->ai_family, _result->ai_socktype,_result->ai_protocol);

    //Connects
    returnCode = connect(_serverSocketId, _result->ai_addr, _result->ai_addrlen);

    return returnCode;

}

/************************************
* Closes connection to server
* 
* 
************************************/
void ServerMediator::closeConnection() {
	if (_logging) {
		cout << "Closing connection" << endl;
	}

    if (_result != NULL) {
        freeaddrinfo(_result);
    }

    if (_serverSocketId != -1) {
        close(_serverSocketId);
    }
}


/************************************
* Gets position back from server 
* (as stringt)
*
************************************/
string ServerMediator::getResponse() {
	if (_logging) {
		cout << "Waiting response from server" << endl;
	}

    char msg[MAX_BUF];

    recv(_serverSocketId, msg, MAX_BUF, 0);

	return string(msg);
}

/************************************
* Sends client's time to server
* (as long long int)
*
************************************/
void ServerMediator::sendRequest(string clientTime) {
	if (_logging) {
		cout << "Sending request to server: " << clientTime << endl;
	}
   
    send(_serverSocketId,clientTime.c_str(), clientTime.size()+1,0);
}