#include "pstatsd.h"

int client(int c) {
  time_t time, firsthit, lasthit;
  char *query = NULL, *session = NULL, *ip = NULL, *useragent = NULL;
  int session_len, query_len, ip_len, useragent_len;

  while(1) {
    /* Allocate memory and recieve data */
    if(read(c, (char *)&time, sizeof(time)) == -1) break;
    if(read(c, (char *)&firsthit, sizeof(firsthit)) == -1) break;
    if(read(c, (char *)&lasthit, sizeof(lasthit)) == -1) break;

    if(read(c, (char *)&ip_len, sizeof(ip_len)) == -1) break;
    ip = (char *)realloc(ip, ip_len+1);
    if(!ip) break;
    memset(ip, 0, ip_len+1);
    if(read(c, (char *)ip, ip_len) == -1) break;

    if(read(c, (char *)&useragent_len, sizeof(useragent_len)) == -1) break;
    useragent = (char *)realloc(useragent, useragent_len+1);
    if(!useragent) break;
    memset(useragent, 0, useragent_len+1);
    if(read(c, (char *)useragent, useragent_len) == -1) break;

    if(read(c, (char *)&session_len, sizeof(session_len)) == -1) break;
    session = (char *)realloc(session, session_len+1);
    if(!session) return 1;
    memset(session, 0, session_len+1);
    if(read(c, (char *)session, session_len) == -1) break;

    if(read(c, (char *)&query_len, sizeof(query_len)) == -1) break;
    query = (char *)realloc(query, query_len+1);
    if(!query) free(session);
    memset(query, 0, query_len+1);
    if(read(c, (char *)query, query_len) == -1) break;

    /* Parse the hit */
    parse(time, firsthit, lasthit, ip, ip_len, useragent, useragent_len, session, session_len, query, query_len);
  }

  /* Clean up */
  close(c);
  free(ip);
  free(useragent);
  free(session);
  free(query);

  /* exit */
  pthread_detach(pthread_self());
  pthread_exit(NULL);
  return 0;
}