/***************************************************************************/
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <netdb.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include <arpa/inet.h>

#include "lib_errors.h"
/**e************************************************************************/
int lib_tcp_socket;
/***************************************************************************/
static unsigned int lib_tcp_port;
/**h************************************************************************/
extern int lib_tcp_setPort(char *port)
{
    lib_tcp_port=atoi(port);
}
/**h************************************************************************/
extern int lib_tcp_connect(char *adress)
{
    struct sockaddr_in serv_addr;

    lib_tcp_socket = 0;

    if((lib_tcp_socket = socket(AF_INET, SOCK_STREAM, 0)) < 0)
    {
//        printf("\n Error : Could not create socket \n");
//        return 3;
         lib_errors_error(103,errno);
    }

    memset(&serv_addr, '0', sizeof(serv_addr));

    serv_addr.sin_family = AF_INET;
    serv_addr.sin_port = htons(lib_tcp_port);

    if(inet_pton(AF_INET, adress, &serv_addr.sin_addr)<=0)
    {
        struct hostent *he;
        if ((he=gethostbyname(adress)) == NULL)  /* get the host info */
        {
//            printf("\n gethostbyname error occured\n");
//            return 2;
            lib_errors_error(102,errno);
        }
        serv_addr.sin_addr = *((struct in_addr *)he->h_addr);
    }

    if( connect(lib_tcp_socket, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0)
    {
//       printf("\n Error : Connect Failed \n");
//       return 1;
       lib_errors_error(101,errno);
    }

    return 0;
}
/**h************************************************************************/
extern int lib_tcp_read(char *recvBuff, int sizeBuff)
{
    int n = read(lib_tcp_socket, recvBuff, sizeBuff);
//    if (n<0) lib_errors_error(104,errno);

    return n;
}
/**h************************************************************************/
extern int lib_tcp_send(char *sendBuff, int sizeBuff)
{
    int n = send(lib_tcp_socket , sendBuff , sizeBuff , 0);
    if (n<0) lib_errors_error(105,errno);
    if (n!=sizeBuff) lib_errors_error(106,sizeBuff-n);

    return n;
}
/**h************************************************************************/
extern int lib_tcp_readN(char *recvBuff, int sizeBuff)
{
    int indata_len=0;
    for( ; ; )
    {
         if (indata_len>=sizeBuff)  return 0;

         int res=lib_tcp_read(&recvBuff[indata_len], 1);
         if (res<0) lib_errors_error(107,errno);

         indata_len +=res;
    }
}
/**h************************************************************************/
extern int lib_tcp_close()
{
    return close(lib_tcp_socket);
}
/***************************************************************************/