KinectClient.h

#pragma once

#define WIN32_LEAN_AND_MEAN

#include <windows.h>
#include <winsock2.h>
#include <ws2tcpip.h>
#include <stdlib.h>
#include <stdio.h>
#include <string>

using namespace std;

// Need to link with Ws2_32.lib, Mswsock.lib, and Advapi32.lib
#pragma comment (lib, "Ws2_32.lib")
#pragma comment (lib, "Mswsock.lib")
#pragma comment (lib, "AdvApi32.lib")


#define DEFAULT_BUFLEN 512
#define DEFAULT_PORT "27015"


class SocketClient {
public:
	SocketClient() {
		// Initialize Winsock
		iResult = WSAStartup(MAKEWORD(2, 2), &wsaData);
		if (iResult != 0) {
			printf("WSAStartup failed with error: %d\n", iResult);
			throw(string("exception"));
		}

		ZeroMemory(&hints, sizeof(hints));
		hints.ai_family = AF_UNSPEC;
		hints.ai_socktype = SOCK_STREAM;
		hints.ai_protocol = IPPROTO_TCP; // TCP
		//hints.ai_protocol = IPPROTO_UDP; // UDP

		// Resolve the server address and port
		iResult = getaddrinfo(serverAddress, DEFAULT_PORT, &hints, &result);
		if (iResult != 0) {
			printf("getaddrinfo failed with error: %d\n", iResult);
			WSACleanup();
			throw(string("exception"));
		}
	}

	void connection() {
		int iResult;
		// Attempt to connect to an address until one succeeds
		for (ptr = result; ptr != NULL; ptr = ptr->ai_next) {

			// Create a SOCKET for connecting to server
			ConnectSocket = socket(ptr->ai_family, ptr->ai_socktype,
				ptr->ai_protocol);
			if (ConnectSocket == INVALID_SOCKET) {
				printf("socket failed with error: %ld\n", WSAGetLastError());
				WSACleanup();
				throw(string("exception"));
			}

			// Connect to server.
			iResult = connect(ConnectSocket, ptr->ai_addr, (int)ptr->ai_addrlen);
			if (iResult == SOCKET_ERROR) {
				closesocket(ConnectSocket);
				ConnectSocket = INVALID_SOCKET;
				continue;
			}
			break;
		}

		freeaddrinfo(result);

		if (ConnectSocket == INVALID_SOCKET) {
			printf("Unable to connect to server!\n");
			WSACleanup();
			throw(string("exception"));
		}
	}

	void sendData(string data) {
		iResult = send(ConnectSocket, data.c_str(), data.size(), 0);
		if (iResult == SOCKET_ERROR) {
			closesocket(ConnectSocket);
			WSACleanup();
			return;
		}
	}

	void recvFlag() {
		const int recvbufSize = 128;
		char recvbuf[recvbufSize];

		iResult = recv(ConnectSocket, recvbuf, recvbufSize, 0);
		if (iResult > 0) {
			this->isReadyToSend = true;
		}
	}

	void close() {
		// cleanup
		closesocket(ConnectSocket);
		WSACleanup();
	}

private:

	bool isReadyToSend = true;

	SOCKET ConnectSocket = INVALID_SOCKET;
	WSADATA wsaData;

	struct addrinfo* result = NULL,
		* ptr = NULL,
		hints;
	const char* sendbuf = "this is a test";
	char recvbuf[DEFAULT_BUFLEN];
	int iResult;
	int recvbuflen = DEFAULT_BUFLEN;

	const char* serverName = "testServer";
	const char* serverAddress = "192.168.0.11";
};