/* gcc -Wall -pedantic af.c -lpcap -o af */

#include "af.h"

u_int16_t handle_ethernet(u_char *args,const struct pcap_pkthdr* pkthdr,const u_char* packet);
u_char* handle_IP(u_char *args,const struct pcap_pkthdr* pkthdr,const u_char* packet);

void errsys(char msg[50])
{
fprintf(stdout,"%s",msg);
}


int init_db()
{
 int conectat;
 strcpy(db_host,DB_HOST);
 strcpy(db_user,DB_USER);
 strcpy(db_password,DB_PASSWORD);
 strcpy(db_database,DB_DATABASE);
 memset(&mysql,0,sizeof(MYSQL));
     
 mysql_init(&mysql);
 mysql_options(&mysql,MYSQL_READ_DEFAULT_GROUP,"af");
         
 if (!mysql_real_connect(&mysql, db_host , db_user, db_password,db_database,0,NULL,0))
  {
    errsys("Failed to connect to database: Error:");
    conectat = 0;
  }
 else
  {
   conectat = 1;
   if (mysql_select_db(&mysql, db_database))
      {
       conectat=0;
       errsys("Nu pot selecta baza de date Error:");
      }
     else
      {
        conectat = 1;
      }
  }
 return conectat;
}
                                                                   
void cr_db()
{
  struct in_addr intmp;
  char *buff,*buf;
  if ((buff = ( char * ) malloc ( MAX_QUERY )) == NULL)
     errsys ( "buffer alloc" );
             
  memset(buff, 0, MAX_QUERY);
  strcpy(buff,"CREATE TABLE 193_19_192_80_zi (timetr timestamp(14) NOT NULL,downb bigint(14) default '0',upb bigint(14) default '0',downp bigint(14) default '0',upp bigint(14) default '0', downtcpb bigint(14) default '0', uptcpb bigint(14) default '0',downudpb bigint(14) default '0',upudpb bigint(14) default '0',downicmpb bigint(14) default '0',upicmpb bigint(14) default '0',downotherb bigint(14) default '0',upotherb bigint(14) default '0',downtcpp bigint(20) default '0',uptcpp bigint(20) default '0',downudpp bigint(20) default '0',upudpp bigint(20) default '0',downicmpp bigint(20) default '0',upicmpp bigint(20) default '0',downotherp bigint(20) default '0',upotherp bigint(20) default '0',PRIMARY KEY  (timetr)) TYPE=MyISAM;");
  init_db();
  if (mysql_query(&mysql, buff))
   {
    errsys("mysql_querry");
   }
                    

  mysql_free_result(res);
  mysql_close(&mysql);
}


int main(int argc,char **argv)
{ 
    int i;

    cr_db();    
    return 0;
}