[MMO] Naruto Online | Projet sérieux

#include "CNet.h"
#include "../common.h"

CNet* CNet::singleton = NULL;
Mutex CNet::m;


int CNet::connection(char* server_name,int port)
{
	struct sockaddr_in serverSockAddr;
	struct hostent *serverHostEnt;
	memset(&serverSockAddr,0,sizeof(serverSockAddr));
	serverHostEnt = gethostbyname(server_name);
	if (serverHostEnt == NULL)
	{
		printf("Unable to look up server : %s\n",server_name);
		return -1;
	}
	memcpy(&serverSockAddr.sin_addr,serverHostEnt->h_addr,serverHostEnt->h_length);
	serverSockAddr.sin_port = htons(port);
	serverSockAddr.sin_family = AF_INET;

	sock = socket(AF_INET,SOCK_STREAM,0);
	if (sock<0)
	{
		printf("Socket creation failed\n");
		return -1;
	}
	if(connect(sock,(struct sockaddr *)&serverSockAddr,sizeof(serverSockAddr))<0)
	{
		printf("Connection to server failed\n");
		return -1;
	}
	return 1;
}

int CNet::send_p(char* packet)
{
    int n = send (sock, packet, sizeof (*packet), 0);
    return n;
}

int CNet::send_p(char* packet, size_t t)
{
    int n = send (sock, packet, t, 0);
    return n;
}

int CNet::send_p(CByte* packet)
{
    char* tmp = packet->GetByte();
    int n = send (sock, tmp, packet->GetSize(), 0);
    delete tmp;
    return n;
}

CByte* CNet::recv_p(SOCKET sock)
{
    CByte* m = new CByte;
    char text[1500]; //mtu max
    int n = recv (sock, text, sizeof text - 1, 0);
    if(n == -1 || n == 0)
    {
        m->SetDead(true);
        closesocket(sock);
    }
    else{
        text[n] = 0;
        m->addChar(text,n);
    }
    return m;
}

int CNet::poschaine(char *chaine1, char *chaine2, int depart){
    unsigned int i,j;
    for( i = depart; i < strlen(chaine1); i++)
    {
       if(chaine1[i] == chaine2[0])
       {
          int rate = 0;
          for(j = 0; j < strlen(chaine2); j++)if( chaine1[i+j] != chaine2[j])
              rate=1;
          if(rate == 0)return i;
       }
    }
    return -1;
}

int CNet::hextoint2(char *hex)
{
   if(strlen(hex)>0)
   {
      if(hex[0]>'0'&&hex[0]<='9')
         return hextoint2(hex+1)*16+hex[0]-'0';
      else if(hex[0]>='a'&&hex[0]<='f')
         return hextoint2(hex+1)*16+hex[0]-'a'+ 10;
      else if(hex[0]>='A'&&hex[0]<='F')
         return hextoint2(hex+1)*16+hex[0]-'A'+ 10;
      else return hextoint2(hex+1)*16;
   }
   else return 0;
}
int CNet::hextoint(char *hex)
{
   char *temp = (char*)malloc(strlen(hex));
   unsigned int i;
   for(i=0;i<strlen(hex);i++)
      temp[i]=hex[strlen(hex)-i-1];
   return hextoint2(temp);
}

int CNet::InitNetwork()
{
    #if defined (WIN32)
        WSADATA wsa;
        WSAStartup(MAKEWORD(2,0),&wsa);
	#endif
	return 0;
}

int CNet::CloseNetwork()
{
    #if defined WIN32
        WSACleanup();
    #endif
    return 0;
}

CHttp::CHttp()
{
    InitNetwork();
}
CHttp::~CHttp()
{
    delete data;
}

char *CHttp::chunked_decode(char *buffer)
{
   char *buf = (char*)malloc(256*256);
   unsigned int i=0,j,k=0;
   while(i<strlen(buffer))
   {
      char hex[5];
      unsigned int size;
      sscanf(buffer+i,"%s",hex);
      size = hextoint(hex);
      i+=strlen(hex)+2;
      for(j=0;j<size;j++)
      {
         buf[k] = buffer[i+j];
         k++;
      }
      i+=size+2;
   }
   buf[k]='\0';
   return buf;
}

void CHttp::read_commande(char *buffer)
{
   if(poschaine(buffer,"HTTP/1.1",0)>-1)
   {
      int num;
      sscanf(buffer,"HTTP/1.1 %d",&num);
      status = num;
   }
   else if(poschaine(buffer,"Transfer-Encoding",0)>-1)
   {
      if(poschaine(buffer,"chunked",0)>-1)
         encoding = chunked;
      else encoding = normal;
   }
}

int CHttp::read_header(char *buffer)
{
      unsigned int i=0,j;
      while(i<strlen(buffer))
      {
         char *buf = (char*)malloc(256);
         for(j=0;buffer[i+j]!='\r'||buffer[i+j+1]!='\n';j++)
            buf[j] = buffer[i+j];
         buf[j]='\0';
         read_commande(buf);
         i+=j+2;
         if(strlen(buf)==0)
            break;
      }
      return i;
}

void CHttp::save(char *filename)
{
    // Not needed for actual enginer
}

void CHttp::load(char* adress)
{
    char* host;
    char str[1024];
    strcpy(str,adress);
    char* file;
    if (strstr(adress, "http://") != NULL){
        strtok(str,"/");
        host = strtok(NULL,"/");
        file = strtok(NULL," /");
    }
    else{
        host = strtok(str," /");
        file = strtok(NULL," /");
    }
    cout << host << endl;
    cout << file << endl;
    char commande[500];
    char *buffer = (char*)malloc(256*256);
	char buf[BUFSIZE];
	int lu;
	connection(host,80);
    sprintf(commande,"GET /%s HTTP/1.1\r\nHost: %s\r\nAccept: */*\r\n\r\n",file,host);
    send(sock,commande,strlen(commande)+1,0);
	int pos=0;
	do
	{
		lu=recv(sock,&(buf[0]),BUFSIZE,0);
		strncpy(&(buffer[pos]),&(buf[0]),lu);
		pos+=lu;
	} while(lu>0);
	data = new char[strlen(buffer)+1];
	strcpy(data,buffer);
	shutdown(sock,2);
	closesocket(sock);
}