Cal::Cal() {
	// wrapper to include only if compiler is Win32 based
	#ifdef WIN32
		WSADATA wsd;
		sockStatus = WSAStartup(0x0202, &wsd);
		if (wsd.wVersion != 0x0202) // check if winsock is version 2
			std::cout << "Incorrect version of winsock detected!\n";
	#else
		//Linux definitions
	#endif
}//ctor


Cal::~Cal() {
	CloseHandle(&receiveHandler);
	disconnect();
}//dtor


bool Cal::sockBind(int p) {
	sockaddr_in sAddr;
	tSock = socket(AF_INET, SOCK_STREAM, 0); //define socket
	// check is socket created
	if (tSock == INVALID_SOCKET)
		return false; // bind failed
	//set first sizeof(sockaddr_in) bytes pointed by
	//serverAddr to 0
	memset(&sAddr, 0, sizeof(sockaddr_in));
	//
	sAddr.sin_family = AF_INET;
	//
	sAddr.sin_addr.s_addr = htonl(INADDR_ANY);
	//set port to p
	sAddr.sin_port = htons(p);
	// attempt to peform binding to socket
	if (bind(tSock,(sockaddr*) &sAddr, sizeof(sockaddr)) == SOCKET_ERROR) {
		disconnect();
		return false; //bind failed
	}
	return true; // bind successfull
}//sockBind


int Cal::receive(char* retBuffer) {
	packHead pHead; // header of packet (Structure defined in packets.h)
	int rByte, wByte; // bytes received, bytes waiting

	// check if there is more to be read
	// (will equal 0 if read as far as it has written)
	if(sRecv.writeLoc - sRecv.readLoc) {
		wByte = sRecv.writeLoc - sRecv.readLoc; // number of bytes to read
		// check if bytes to read are not enough for receiving a header
		if(wByte < sizeof(pHead)) {
			return 0;
		}
		// copy sizeof(pHead) bytes from packet buffer of sRecv into
		// the memory location of pHead
		memcpy(&pHead, &sRecv.packBuffer[sRecv.readLoc],sizeof(pHead));
		// check if bytes waiting are sufficient
		if((wByte - sizeof(pHead)) < (unsigned) pHead.pLength)
			return 0;
		// copy sizof(pHead) bytes from pHead to memory location
		// retBuffer for later processing
		memcpy(retBuffer, &pHead, sizeof(pHead));
		// copy (length of packet) bytes from packet buffer in sRecv from
		// current (read position + header size) into return buffer
		memcpy(&retBuffer[sizeof(pHead)],
			&sRecv.packBuffer[sRecv.readLoc + sizeof(pHead)], pHead.pLength);
		// move read location to current position
		sRecv.readLoc += pHead.pLength + sizeof(pHead);
		// move read bytes counter to current position
		rByte = pHead.pLength + sizeof(pHead);
		// check if too much has been read
		if(sRecv.readLoc >= 64000) {
			sRecv.readLoc = 0;
		}
	}
	return rByte;	//return bytes read,
					//if 0 then none were waiting or not enough
}


int Cal::sendPacket(char* buffer, int bLen) {
	// return result of sending buffer of length bLen
	// via tSock with no flags set
	return send(tSock,buffer,bLen,0);
}


bool Cal::sConnect(char* ipAddress, int port) {
	sockaddr_in sAddr;
	LPHOSTENT lphost;
	memset(&sAddr,0,sizeof(sockaddr_in));

	sAddr.sin_family = AF_INET;
	sAddr.sin_addr.s_addr = inet_addr(ipAddress);

	if(sAddr.sin_addr.s_addr == INADDR_NONE) {
		lphost = gethostbyname(ipAddress);
		if (lphost != NULL) {
			sAddr.sin_addr.s_addr = ((LPIN_ADDR) lphost->h_addr_list)->s_addr;
		}
		else {
			#ifdef WIN32
			WSASetLastError(WSAEINVAL);
			#endif
			return false;
		}
	}
	sAddr.sin_port = htons(port);
	tSock = socket(AF_INET, SOCK_STREAM, 0);
	
	if(tSock == INVALID_SOCKET)
		return false;
	int err = connect(tSock, (struct sockaddr*)&sAddr, sizeof(sockaddr));
	if(err == SOCKET_ERROR) {
		disconnect();
		return false;
	}
	sRecv.transSocket = tSock;
	sRecv.packBuffer[0] = NULL;
	sRecv.readLoc = 0;
	sRecv.writeLoc = 0;
	sRecv.endRequest = 0;
	return true;
}


void Cal::disconnect() {
	//check if socket was connected
	if(tSock != INVALID_SOCKET) {
		closesocket(tSock); //close socket
		tSock = INVALID_SOCKET; //marker to show socket closed
	}
}