#include <iostream>

#include "../datatypes.h"

#include "../log.h"
#include "../signalController.h"
#include "../PracticalSocket.h"
#include "../buffer.h"

#include "options.h"

#define MAX_PACKET_SIZE 1500

void* worker(void* dont_use_me)
{
  try 
  {

    UDPSocket sock("127.0.0.1", 22222);
    Buffer buf(u_int32_t(MAX_PACKET_SIZE));
    
    while(1) {
      string remote_host;
      u_int16_t remote_port;
      
      buf.setLength(MAX_PACKET_SIZE);
      u_int32_t len = sock.recvFrom(buf.getBuf(), buf.getLength(), remote_host, remote_port);
      buf.setLength(len);
      
      std::cout << "Received UDP Packet from: " << remote_host << ":" << remote_port << std::endl;
      std::cout << buf.getHexDump() << std::endl;
      
// sendTo(buf, len, addr, port);
    }  
  }
  catch(std::exception &e)
  {
    std::cout << "an error happend: " << e.what() << std::endl;
  }
  pthread_exit(NULL);
}





// void chrootAndDrop(string const& chrootdir, string const& username)
// {
// 	if (getuid() != 0)
// 	{
// 	  std::cerr << "this programm has to be run as root in order to run in a chroot" << std::endl;
// 		exit(-1);
// 	}	

//   struct passwd *pw = getpwnam(username.c_str());
// 	if(pw) {
// 		if(chroot(chrootdir.c_str()))
// 		{
//       std::cerr << "can't chroot to " << chrootdir << std::endl;
//       exit(-1);
// 		}
//     std::cout << "we are in chroot jail (" << chrootdir << ") now" << std::endl;
//     chdir("/");
// 		if (initgroups(pw->pw_name, pw->pw_gid) || setgid(pw->pw_gid) || setuid(pw->pw_uid)) 
// 		{
// 			std::cerr << "can't drop to user " << username << " " << pw->pw_uid << ":" << pw->pw_gid << std::endl;
// 			exit(-1);
// 		}
//     std::cout << "dropped user to " << username << " " << pw->pw_uid << ":" << pw->pw_gid << std::endl;
// 	}
// 	else 
//   {
//     std::cerr << "unknown user " << username << std::endl;
//     exit(-1);
// 	}
// }

// void daemonize()
// {
//   pid_t pid;

//   pid = fork();
//   if(pid) exit(0);  
//   setsid();
//   pid = fork();
//   if(pid) exit(0);
  
//   std::cout << "running in background now..." << std::endl;

//   int fd;
//   for (fd=getdtablesize();fd>=0;--fd) // close all file descriptors
//     close(fd);
//   fd=open("/dev/null",O_RDWR);        // stdin
//   dup(fd);                            // stdout
//   dup(fd);                            // stderr
//   umask(027); 
// }


int main(int argc, char* argv[])
{
  std::cout << "anyrtpproxy" << std::endl;
  if(!gOpt.parse(argc, argv))
  {
    gOpt.printUsage();
    exit(-1);
  }

//   if(gOpt.chroot)
//     chrootAndDrop(gOpt.getChrootDir, gOpt.getUsername);
//   if(testSetPid(gOpt.pidFilename))
//   {
//     std::cout << "exiting..." << std::endl;
//     return -1;
//   }
//   if(gOpt.daemonize)
//     daemonize(gOpt.pidFilename);


  cLog.msg(Log::PRIO_NOTICE) << "anyrtpproxy started...";

  SignalController sig;
  sig.init();

  pthread_t workerThread;
  pthread_create(&workerThread, NULL, worker, NULL);  
  pthread_detach(workerThread);  

	int ret = sig.run();

  return ret;
}