/**
 * xerxes - mysql proxying
 * ``Why do you persist in your loneliness?'' --Xerxes
 * (c) 2008 
 * Jan Losinski <losinshi@wh2.tu-dresden.de> 
 * Maximilian Marx <mmarx@wh2.tu-dresden.de>
 */

#include <unistd.h>
#include <netdb.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/un.h>
#include "socket.hxx"
#include "xerxes.hxx"

namespace xerxes
{
  Socket::Socket(int protocol,
		int type,
		int domain)
    : fd(socket(protocol, type, domain))
  {
    if(fd < 0)
      {
	throw ConnCreateErr();
      }
    if(be_debug)
      {
        std::cout << "socket with fd " << fd << " created" << std::endl;
      }
  }

  Socket::Socket(int new_fd)
  {
    fd = new_fd;
    if(fd < 0)
      {
	throw ConnCreateErr();
      }
    if(be_debug)
      {
        std::cout << "socket with fd " << fd << " created" << std::endl;
      }
  }

  Socket::~Socket()
  {
    if(fd)
      {
	close(fd);
        if(be_debug)
          {
            std::cout << "socket with fd " << fd << " closed" << std::endl;
          }
      }
  }

  SocketOption::SocketOption(std::string new_file)
    : type(UNIX), file(new_file)
  {
  }

  SocketOption::SocketOption(std::string new_hostname, std::string new_port)
    : type(TCP), hostname(new_hostname), port(new_port)
  {
  }

  Socket*
  SocketOption::gen_socket()
  {
    if(type == TCP)
      {
        return new Socket(PF_INET, SOCK_STREAM, 0);
      }
    else
      {
        return new Socket(AF_UNIX, SOCK_STREAM, 0);
      }
   }


  void validate(boost::any& v, 
                const std::vector<std::string>& values,
                SocketOption* target_type, int)
  {
    static boost::regex r("(tcp|unix):(([\\d\\w_-]|\\.|/)+)(:(\\d+))?");

    using namespace boost::program_options;
    using namespace std;

    validators::check_first_occurrence(v);
    const std::string& s = validators::get_single_string(values);

    boost::smatch match;
    if(regex_match(s, match, r)) 
      {
        if(match[1] == "tcp")
	  {
	    v = boost::any(SocketOption(match[2], match[5]));
	  }
	else
	  {
	    v = boost::any(SocketOption(match[2]));
	  }
      } 
    else 
      {
        throw validation_error("invalid value");
      }        
  }

  MysqlData 
  makeData(int len)
  {
    if(be_debug)
      {
        std::cout << "Init transfer Buffer" << std::endl;
      }
    return MysqlData(buffer_t(new char[len]), len);
  }

  int
  listen(Socket& socket, int backlog)
  {
    int ret = ::listen(socket.fd, backlog);
    if (ret != 0)
      {
        throw ConnListenErr();
      }
    if(be_debug)
      {
        std::cout << "listen on socket" << std::endl;
      }
    return ret;
  }
  
  boost::shared_ptr<Socket>
  accept(Socket& socket, 
	 sockaddr* address,
	 socklen_t* address_len)
  {
     int new_fd = ::accept(socket.fd, address, address_len);
     if(new_fd == -1)
       {
	 throw ConnAcceptErr();
       }
    if(be_debug)
      {
        std::cout << "connection accepted" << std::endl;
      }

     return boost::shared_ptr<Socket>(new Socket(new_fd));  
  }

  int
  connect(Socket& socket,
	  sockaddr const* const serv_addr,
	  socklen_t addrlen)
  {
    int ret = ::connect(socket.fd, serv_addr, addrlen);
    if (ret != 0)
      {
        throw ConnConnectErr();
      } 
    if(be_debug)
      {
        std::cout << "socket connected" << std::endl;
      }
    return ret;
  }

  int
  connect_inet(Socket& socket,
          SocketOption& opt)
  {
    if(be_debug)
      {
        std::cout << "connect inet to: " << opt.hostname << ":" << opt.port << std::endl;
      }
    addrinfo hints;
    addrinfo* res;

    memset(&hints, 0, sizeof(hints));

    hints.ai_family = AF_INET;
    hints.ai_socktype = SOCK_STREAM;
    hints.ai_protocol = IPPROTO_TCP;
    hints.ai_flags = AI_PASSIVE | AI_NUMERICHOST;
    getaddrinfo(opt.hostname.c_str(), opt.port.c_str(), &hints, &res);
    int ret = connect(socket, res->ai_addr, res->ai_addrlen);
    freeaddrinfo(res);
    return ret;
  }

  int
  connect_unix(Socket& socket,
            SocketOption& opt)
  {
    if(be_debug)
      {
        std::cout << "connect unix to: " << opt.file << std::endl;
      }
    struct sockaddr_un adr;
    memset(&adr, 0, sizeof(adr));
    adr.sun_family = AF_UNIX;
    strncpy(adr.sun_path, opt.file.c_str(), sizeof(adr.sun_path));
    return connect(socket, (struct sockaddr *) &adr, SUN_LEN(&adr));
  }
  
  int
  recv(Socket& socket,
       MysqlData& data,
       int flags)
  {
    int ret = ::recv(socket.fd, data.first.get(), data.second, flags);
    if(ret == 0)
      {
        throw ConResetErr();
      }
    if(ret < 0)
      {
        throw ConDataErr();
      }
    if(be_debug)
      {
        std::cout << "recived " << ret << " bytes from fd " << socket.fd << std::endl;
      }

    return ret;
  }

  int
  send (Socket& socket,
	MysqlData& data,
	int len,
	int flags)
  {
    int ret = ::send(socket.fd, data.first.get(), len, flags);
    if((ret == 0 && len != 0) || len != ret)
      {
        throw ConResetErr();
      }
    if(ret < 0)
      {
        throw ConDataErr();
      }
    
    if(be_debug)
      {
        std::cout << "sended " << ret << " of " << len << " bytes to " << socket.fd << std::endl;
      }
    return ret;
  }

  int
  bind(Socket& socket,
       sockaddr const* const bind_address,
       socklen_t addrlen)
  {
    int ret = ::bind(socket.fd, bind_address, addrlen);
    if(ret != 0)
      {
        throw ConnBindErr();
      }

    if(be_debug)
      {
        std::cout << "socket bound" << std::endl;
      }

    return ret;
  }

  int
  bind_inet(Socket& socket,
       SocketOption& opt)
  {
    if(be_debug)
      {
        std::cout << "bind inet socket to: " << opt.hostname << ":" << opt.port << std::endl;
      }
    addrinfo hints;
    addrinfo* res;

    memset(&hints, 0, sizeof(hints));

    hints.ai_family = AF_INET;
    hints.ai_socktype = SOCK_STREAM;
    hints.ai_protocol = IPPROTO_TCP;
    hints.ai_flags = AI_PASSIVE | AI_NUMERICHOST;

    getaddrinfo(opt.hostname.c_str(), opt.port.c_str(), &hints, &res);
    
    int so_opt = 1;
    setsockopt(socket.fd, SOL_SOCKET, SO_REUSEADDR, (char*)&so_opt, sizeof(so_opt));
    
    int ret = bind(socket, res->ai_addr, res->ai_addrlen);

    freeaddrinfo(res);
    return ret;
  }


  int
  bind_unix(Socket& socket,
       SocketOption& opt)
  {
    if(be_debug)
      {
        std::cout << "bind unix socket to: " << opt.file << std::endl;
      }

    unlink(opt.file.c_str());
    
    struct sockaddr_un adr;
    memset(&adr, 0, sizeof(adr));
    adr.sun_family = AF_UNIX;
    strncpy(adr.sun_path, opt.file.c_str(), sizeof(adr.sun_path));

    return bind(socket, (struct sockaddr *) &adr, SUN_LEN(&adr));
  }

  SocketErr::SocketErr(){
    SocketErr("unknown");
  }
  SocketErr::SocketErr(std::string err){
    if(!be_quiet)
      {
        std::cerr << "Socket Exception: " << err << std::endl;
        perror("ERRNO");
      }
  }
}