/*******************************************************************************

  Eurecom OpenAirInterface
  Copyright(c) 1999 - 2011 Eurecom

  This program is free software; you can redistribute it and/or modify it
  under the terms and conditions of the GNU General Public License,
  version 2, as published by the Free Software Foundation.

  This program is distributed in the hope it will be useful, but WITHOUT
  ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
  FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License for
  more details.

  You should have received a copy of the GNU General Public License along with
  this program; if not, write to the Free Software Foundation, Inc.,
  51 Franklin St - Fifth Floor, Boston, MA 02110-1301 USA.

  The full GNU General Public License is included in this distribution in
  the file called "COPYING".

  Contact Information
  Openair Admin: openair_admin@eurecom.fr
  Openair Tech : openair_tech@eurecom.fr
  Forums       : http://forums.eurecom.fsr/openairinterface
  Address      : Eurecom, 2229, route des crêtes, 06560 Valbonne Sophia Antipolis, France

*******************************************************************************/

/*! \file cli_server.c
* \brief oai cli server side implementation
* \author Navid Nikaein
* \date 2011
* \version 0.1
* \warning This component can be runned only in user-space
* @ingroup util

*/
#include <pthread.h>
#include <stdio.h>
#include <errno.h>
#include <stdlib.h>
#include <signal.h>
#include <stdint.h>
#include <sys/socket.h>
#include <sys/types.h>    
#include <sys/un.h> 
#include <unistd.h> 
#include <netinet/in.h>
#include <net/if.h>
#include <signal.h>
#include <stdlib.h>

#include "cli.h"
#include "UTIL/LOG/log.h"

#define	MAX_NUM_CLIENTS 15
#define MAX_LINE 100

struct sockaddr_in saddr;
unsigned short server_port = 1352;

pthread_t cli_server_listener;
static void * cli_server_listen(void *arg);

cli_handler_t cli_server_handler= NULL;

cli_config *cli_cfg;

int cli_server_init(cli_handler_t handler) {

	int one = 1;
	cli_init();

	cli_server_handler = handler;
	if ((cli_cfg->sfd = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
		perror("socket");
		return -1;
	}
	if (setsockopt(cli_cfg->sfd, SOL_SOCKET, SO_REUSEADDR, (char *) &one,
		       sizeof(one)) < 0) {
	  perror("setsockopt");
	  return -1;
	}
	LOG_I(CLI,"socket created %d\n", cli_cfg->sfd);
	memset(&saddr, 0, sizeof(saddr));
	saddr.sin_family = AF_INET;
	saddr.sin_addr.s_addr = htonl(INADDR_ANY);
	saddr.sin_port = htons(server_port);
 	
	if (bind(cli_cfg->sfd, (struct sockaddr *) &saddr, sizeof(saddr)) < 0) {
		perror("bind");
		return -1;
	}
	/* create telnet listener thread */
	if (pthread_create(&cli_server_listener, NULL, cli_server_listen, NULL)) {
	  perror("thread");
	  return -1;
	}
	return 0;
}

static void * cli_server_listen(void *arg) {
    
  struct sockaddr caddr;
  socklen_t clen;
  
  clen = sizeof(caddr);
  
  printf("[CLI] server thread started\n");
  // to be implemented
  while (1){   
  pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
  if (listen(cli_cfg->sfd, MAX_NUM_CLIENTS) < 0) {
    perror("listen");
    exit(1);
  }
  pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, NULL);			
  printf("[CLI] server Started listening on %d\n", cli_cfg->sfd);
 
    if ((cli_cfg->cfd = accept(cli_cfg->sfd, &caddr, &clen)) <0){
      if (cli_cfg->cfd == EINTR )
	continue;
      else {
	perror("error on accept\n"); 
	exit(1);
      }
    }
    printf("[CLI] server accepted the connection %d from a new client\n", cli_cfg->cfd);
    cli_cfg->exit = 0; 
    cli_start(); // init    
    do {
      clen = recv(cli_cfg->cfd, buffer, MAX_SOCK_BUFFER_SIZE, 0);
      if (cli_server_handler)
	cli_server_handler(buffer, clen);
      
    }while (cli_cfg->exit == 0);
    cli_finish();
  } 
  pthread_exit(NULL);  
}

void cli_server_recv(const void * data, socklen_t len) {
  
  char * msg = (char*) data;
  //reomve the newlines 
  msg[len]=0;
  msg[len-1]=0;
  msg[len-2]=0;
  //Multiplex to the right handler if needed 
  cli_loop(msg);
  //sprintf(buffer, "%s_ACK", msg);
  //len = send(fd, buffer, strlen(buffer), 0);
}


void cli_server_cleanup(void){
  /*	if (unlink(telnet_server_socket) < 0) {
	perror("");
	}
  */
  printf("[CLI] server pthread exit ! \n");
  if (cli_cfg->exit) close(cli_cfg->cfd);// close the client first 
  pthread_exit(NULL);  
  pthread_cancel(cli_server_listener);
  close(cli_cfg->sfd);
}

void  cli_init (void) {

  cli_cfg = calloc(1, sizeof(cli_config));
  memset(cli_cfg, 0, sizeof(cli_config));
  cli_cfg->exit = 0; 
  cli_cfg->port = 1352;
  cli_cfg->promptchar='\0';
  cli_cfg->prompt[0]='\0'; 
  snprintf(cli_cfg->prompt,200,"%s","oaicli");  
  
}
#ifdef STANDALONE
int main() {

  printf("start \n");
  cli_init();

//Main process of telnet  server
  if (cli_server_init(cli_server_recv) < 0) {
    printf("server init failed \n");
    exit(-1);
  }
  while (cli_cfg->exit ==0) {
  }
  printf("server init done 1 \n");
  cli_server_cleanup();
  //pthread_join(telnet_server_listener, NULL);
  printf("server init done \n");
  
 
  return 0; 
}

#endif