/*
    mpg321 - a fully free clone of mpg123.
    Copyright (C) 2001 Joe Drew
    
    Network code based heavily upon:
    plaympeg - Sample MPEG player using the SMPEG library
    Copyright (C) 1999 Loki Entertainment Software
    
    This program is free software; you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation; either version 2 of the License, or
    (at your option) any later version.

    This program is distributed in the hope that 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., 675 Mass Ave, Cambridge, MA 02139, USA.
*/

#ifdef HAVE_CONFIG_H
#include <config.h>
#endif

#include <stdio.h>
#include <string.h>

#include <errno.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/ioctl.h>
#include <sys/time.h>
#include <fcntl.h>

#include <netinet/in.h>
#include <netdb.h>
#include <sys/socket.h>
#include <arpa/inet.h>

#include <unistd.h>

#include <limits.h>

#include "mpg321.h"

#define MAX_HOSTNAME 256

#define IFVERB if(options.opt & MPG321_VERBOSE_PLAY)

int proxy_enable = 0;
char *proxy_server;
int auth_enable = 0;
int auth_enable_var = 0;
extern char authstring[80];
int http_file_length = 0;

int shoutcast(int);

int is_address_multicast(unsigned long address)
{
    if ((address & 255) >= 224 && (address & 255) <= 239)
        return (1);
    return (0);
}

#ifndef USE_IPV6

/* =================== IPV4 ================== */

int tcp_open(char *address, int port)
{
    struct sockaddr_in stAddr;
    struct hostent *host;
    int sock;
    struct linger l;

    memset(&stAddr, 0, sizeof(stAddr));
    stAddr.sin_family = AF_INET;
    stAddr.sin_port = htons(port);

    if ((host = gethostbyname(address)) == NULL)
        return (0);

    stAddr.sin_addr = *((struct in_addr *)host->h_addr_list[0]);

    if ((sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0)
        return (0);

    l.l_onoff = 1;
    l.l_linger = 5;
    if (setsockopt(sock, SOL_SOCKET, SO_LINGER, (char *)&l, sizeof(l)) < 0)
        return (0);

    if (connect(sock, (struct sockaddr *)&stAddr, sizeof(stAddr)) < 0)
        return (0);

    return (sock);
}

int udp_open(char *address, int port)
{
    int enable = 1L;
    struct sockaddr_in stAddr;
    struct sockaddr_in stLclAddr;
    struct ip_mreq stMreq;
    struct hostent *host;
    int sock;

    stAddr.sin_family = AF_INET;
    stAddr.sin_port = htons(port);

    if ((host = gethostbyname(address)) == NULL)
        return (0);

    stAddr.sin_addr = *((struct in_addr *)host->h_addr_list[0]);

    /* Create a UDP socket */
    if ((sock = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
        return (0);

    /* Allow multiple instance of the client to share the same address and port */
    if (setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (char *)&enable, sizeof(unsigned long int)) < 0)
        return (0);

    /* If the address is multicast, register to the multicast group */
    if (is_address_multicast(stAddr.sin_addr.s_addr))
    {
        /* Bind the socket to port */
        stLclAddr.sin_family = AF_INET;
        stLclAddr.sin_addr.s_addr = htonl(INADDR_ANY);
        stLclAddr.sin_port = stAddr.sin_port;
        if (bind(sock, (struct sockaddr *)&stLclAddr, sizeof(stLclAddr)) < 0)
            return (0);

        /* Register to a multicast address */
        stMreq.imr_multiaddr.s_addr = stAddr.sin_addr.s_addr;
        stMreq.imr_interface.s_addr = INADDR_ANY;
        if (setsockopt(sock, IPPROTO_IP, IP_ADD_MEMBERSHIP, (char *)&stMreq, sizeof(stMreq)) < 0)
            return (0);
    }
    else
    {
        /* Bind the socket to port */
        stLclAddr.sin_family = AF_INET;
        stLclAddr.sin_addr.s_addr = htonl(INADDR_ANY);
        stLclAddr.sin_port = htons(0);
        if (bind(sock, (struct sockaddr *)&stLclAddr, sizeof(stLclAddr)) < 0)
            return (0);
    }

    return (sock);
}

#else

/* =================== IPV6 ================== */

int tcp_open(char *address, int port)
{
    struct addrinfo hints, *res, *res_tmp;
    int sock;
    struct linger l;
    char ipstring[MAX_HOSTNAME];
    char portstring[MAX_HOSTNAME];
    
    snprintf(portstring, sizeof(portstring), "%d", port);

    memset(&hints, 0, sizeof(hints));
    /*
     * hints.ai_protocol  = 0;
     * hints.ai_addrlen   = 0;
     * hints.ai_canonname = NULL;
     * hints.ai_addr      = NULL;
     * hints.ai_next      = NULL;
     */
    hints.ai_family = AF_UNSPEC;
    hints.ai_socktype = SOCK_STREAM;



    if ( getaddrinfo(address, portstring, &hints, &res) != 0)
	    return(0);
    
    for (res_tmp = res; res_tmp != NULL; res_tmp = res_tmp->ai_next) {	     
	    if ( (res_tmp->ai_family != AF_INET) &&
			    (res_tmp->ai_family != AF_INET6) )
		    continue;
	    if ( (sock = socket(res_tmp->ai_family, res_tmp->ai_socktype,
					    res_tmp->ai_protocol)) == -1) {
		sock = 0;
		continue;
	    }
	    
	    l.l_onoff = 1;
	    l.l_linger = 5;
	    if (setsockopt(sock, SOL_SOCKET, SO_LINGER, (char *)&l, sizeof(l)) < 0) {
		    /* return (0); */
		    sock = 0;
		    continue;
	    }
	    
	    if ( connect(sock, res_tmp->ai_addr, res_tmp->ai_addrlen)
			    == -1 )
	    {
		    close(sock);
		    sock = 0;
		    continue;
	    }

	    ipstring[0] = 0;
	    getnameinfo(res_tmp->ai_addr, res_tmp->ai_addrlen, ipstring,
			    sizeof(ipstring), NULL, 0, NI_NUMERICHOST);

	    if (ipstring == NULL)
		    sock = 0;
	    
	    break;
    }
    
    freeaddrinfo(res);
    return sock;
}

int udp_open(char *address, int port)
{
  int enable = 1L;
  struct addrinfo hints, *res, *res_tmp;
  int sock;
  struct linger l;
  char ipstring[MAX_HOSTNAME];
  char portstring[MAX_HOSTNAME];
  struct ipv6_mreq imr6;
  struct ip_mreq imr;

  snprintf(portstring, sizeof(portstring), "%d", port);

  memset(&hints, 0, sizeof(hints));
  /*
   * hints.ai_protocol  = 0;
   * hints.ai_addrlen   = 0;
   * hints.ai_canonname = NULL;
   * hints.ai_addr      = NULL;
   * hints.ai_next      = NULL;
   */
  hints.ai_family = AF_UNSPEC;
  hints.ai_socktype = SOCK_DGRAM;

  if ( getaddrinfo(address, portstring, &hints, &res) != 0)
    return(0);
    
  for (res_tmp = res; res_tmp != NULL; res_tmp = res_tmp->ai_next) {	     
    if ( (res_tmp->ai_family != AF_INET) &&
	   (res_tmp->ai_family != AF_INET6) )
	continue;
    if ( (sock = socket(res_tmp->ai_family, res_tmp->ai_socktype,
				res_tmp->ai_protocol)) < 0) {
	sock = 0;
	continue;
    }
    /* Allow multiple instance of the client to share the same address and port */
    if (setsockopt(sock, SOL_SOCKET, SO_REUSEADDR,
			 (char *)&enable, sizeof(unsigned long int)) < 0) {
	sock = 0;
	continue;
    }

    /* If the address is multicast, register to the multicast group */
    if ( (res_tmp->ai_family == AF_INET6) && 
	   IN6_IS_ADDR_MULTICAST(&(((struct sockaddr_in6 *)res_tmp->ai_addr)->
					   sin6_addr) ) ) {
	  /* Bind the socket to port */
	  if ( bind(sock, res_tmp->ai_addr, res_tmp->ai_addrlen) < 0) {
	    close(sock);
	    sock = 0;
	    continue;
	  }
  
	  imr6.ipv6mr_multiaddr =
	    ((struct sockaddr_in6 *)res_tmp->ai_addr)->
	    sin6_addr;
	  imr6.ipv6mr_interface = INADDR_ANY;
	  if ( setsockopt(
				sock,
				IPPROTO_IPV6,
				IPV6_ADD_MEMBERSHIP,
				(char *) &imr6,
				sizeof(struct ipv6_mreq))
		 < 0)
	    return(0);
    }
    else if ( (res_tmp->ai_family == AF_INET) &&
		  IN_MULTICAST(ntohl((((struct sockaddr_in *)res_tmp->
					     ai_addr)->sin_addr.s_addr)) ) ){
	/* Bind the socket to port */
	if ( bind(sock, res_tmp->ai_addr, res_tmp->ai_addrlen) < 0) {
	  close(sock);
	  sock = 0;
	  continue;
	}
	
	imr.imr_multiaddr =
	  ((struct sockaddr_in *)res_tmp->ai_addr)->
	  sin_addr;
	imr.imr_interface.s_addr = INADDR_ANY;
	
	if ( setsockopt(sock,
			    IPPROTO_IP,
			    IP_ADD_MEMBERSHIP,
			    (char *) &imr,
			    sizeof(struct ip_mreq))
	     < 0)
	  return(0);
    } 
    else {
	/* Bind the socket to port */
	if ( bind(sock, res_tmp->ai_addr, res_tmp->ai_addrlen) < 0) {
	  close(sock);
	  sock = 0;
	  continue;
	}
    }
  }

    freeaddrinfo(res);
    return (sock);
}

#endif

int raw_open(char *arg)
{
    char *host;
    int port;
    int sock;

    /* Check for URL syntax */
    if (strncmp(arg, "raw://", strlen("raw://")))
        return (0);

    /* Parse URL */
    port = 0;
    host = arg + strlen("raw://");
    if (strchr(host, ':') != NULL)  /* port is specified */
    {
        port = atoi(strchr(host, ':') + 1);
        *strchr(host, ':') = 0;
    }

    /* Open a UDP socket */
    if (!(sock = udp_open(host, port)))
        perror("raw_open");

    return (sock);
}

/**
 * Read a http line header up to and excluding '\r\n'.
 * This function read character by character.
 * @param tcp_sock the socket use to read the stream
 * @param buf a buffer to receive the data
 * @param size size of the buffer
 * @return the size of the stream read or -1 if an error occured
 */
static int http_read_header(int tcp_sock, char *buf, int size)
{
  int offset = -1;
  
  do
    {
      offset++;
      if (read(tcp_sock, buf + offset, 1) < 0)
	return -1;
    }
  while (offset<size-1 && !(offset>0 && buf[offset-1]=='\r' && buf[offset]=='\n'));
  
  buf[offset-1] = 0;
  buf[offset] = 0;
  return offset-1;
}

/**
 * Read a line from the tcp receive buffer up to and excluding '\n'
 * This function read character by character.
 * @param tcp_sock the socket use to read the stream
 * @param buf a buffer to receive the data
 * @param size size of the buffer
 * @return the size of the stream read or -1 if an error occured
 */
static int http_read_content_line(int tcp_sock, char *buf, int size)
{
  int offset = -1;
  
  do
    {
      offset++;
      if (read(tcp_sock, buf + offset, 1) < 0)
	return -1;
    }
  while (offset<size-1 && !(offset>=0 && buf[offset]=='\n'));
  
  buf[offset] = 0;
  return offset;
}

int http_open(char *arg)
{
  char *host;
  int port;
  char *request;
  int tcp_sock;
  char http_request[PATH_MAX];
  char http_response[PATH_MAX];
  char path[PATH_MAX];
  int len;
  int ofs;
 
  char phost[16];
  int pport;
    
  /* Check for URL syntax */
  if (strncmp(arg, "http://", 7))
    return (0);
  
  /* Parse URL */
  port = 80;
  host = arg + 7;
  path[0] = 0;
  if ((request = strchr(host, '/')))
    {
      *request++ = 0;
      snprintf(path, sizeof(path) - strlen(host) - 75, "%s", request);
    }
  
  if (strchr(host, ':') != NULL)  /* port is specified */
    {
      port = atoi(strchr(host, ':') + 1);
      *strchr(host, ':') = 0;
    }
  
  /* Open a TCP socket */
  if(proxy_enable)
  {
	  char *t = strchr(proxy_server,':');
	  pport = atoi(strchr(proxy_server,':')+1);
	  snprintf(phost,(int)(t-proxy_server)+1,"%s",proxy_server);
	              
	  if (!(tcp_sock = tcp_open(phost,pport)))
	  {
		  perror("http_open");
		  return (0);
	  }
  }else{

	  if (!(tcp_sock = tcp_open(host, port)))
      	  {
		  perror("http_open");
	    	  return (0);
      	  }
  }
  
  /* Send HTTP GET request */
  /* Please don't use a Agent know by shoutcast (Lynx, Mozilla) seems to be reconized and print
   * a html page and not the stream */
  /* ml> that's right, but it's just a playlist, so you've got to extract the URLs! */
  if(!proxy_enable)
  {
	  

	  snprintf(http_request, sizeof(http_request),
	   "GET /%s HTTP/1.0\r\n"
	   "Pragma: no-cache\r\n"
	   "Host: %s\r\n"
	   "User-Agent: xmms/1.2.7\r\n"  /* to make ShoutCast happy */
	   "Accept: * / *\r\n"
	   "\r\n", path, host);
  }else{
	  if(auth_enable || auth_enable_var)
	  {
		  do_basicauth();
                  snprintf(http_request, sizeof(http_request), "GET http://%s/%s HTTP/1.0\r\nProxy-authorization: Basic %s \r\n"
				  "Pragma: no-cache\r\nUser-Agent: xmms/1.2.7\r\n\r\n",host,path,authstring);
	  }else{
		  snprintf(http_request, sizeof(http_request), "GET http://%s/%s HTTP/1.0\r\nnPragma: no-cache\r\nUser-Agent: xmms/1.2.7\r\n\r\n",host,path);
	  }
  }
  
  send(tcp_sock, http_request, strlen(http_request), 0);
  
  /* Parse server reply */
  len = http_read_header(tcp_sock, http_response, PATH_MAX);
  if (len == -1)
    {
      fprintf(stderr, "http_open: %s\n", strerror(errno));
      return 0;
    }
  IFVERB printf( "HTTP header: >%s<\n", http_response );
  if(!strncmp(http_response, "HTTP/1.0 ", 9) || !strncmp(http_response, "HTTP/1.1 ", 9))
    {
      IFVERB printf( "this is an HTTP/1.x header\n" );
      ofs = 9;
      if(!strncmp(http_response+ofs, "200 ", 4))
	{
	  do  /* check Content-Type header */
	    {
	      len = http_read_header(tcp_sock, http_response, PATH_MAX);
	      if (len == -1)
		{
		  fprintf(stderr, "http_open: %s\n", strerror(errno));
		  return 0;
		}
	      IFVERB printf( "HTTP header: >%s<\n", http_response );
	      if(!strncmp(http_response, "Content-Length: ", 16))
	      {
		            char http_length[20];
			    sprintf(http_length,"%s",http_response+16);
			    http_file_length = atoi(http_length);

	      }
	      if(!strncmp(http_response, "Content-Type: ", 14))
		{
		  IFVERB printf( "Content-Type: >%s<\n", http_response+14 );
		  if(!strncmp(http_response+14, "audio/x-scpls", 13))
		    {
		      return(shoutcast(tcp_sock));
		    }
		  else  /* any other content types */
		    {
		      return(tcp_sock);
		    }
		}
	    }
	  while(len>0);
	  fprintf(stderr, "http_open: 200 contains no Content-Type header.\n");
	  return 0;
	}
      else if (!strncmp(http_response+ofs, "302 ", 4))  /* redirect */
	{
	  do
	    {
	      len = http_read_header(tcp_sock, http_response, PATH_MAX);
	      if (len == -1)
		{
		  fprintf(stderr, "http_open: %s\n", strerror(errno));
		  return 0;
		}
	      IFVERB printf( "HTTP header: >%s<\n", http_response );
	      if(!strncmp(http_response, "Location: ", 10))
		{
		  IFVERB printf( "Redirecting to:>%s<\n", http_response+10 );
		  close(tcp_sock);
		  return http_open(http_response+10);
		}
	    }
	  while(len>0);	   
	  fprintf(stderr, "http_open: 302 contains no Location header.\n");
	  return 0;
	}
      else  /* it's neither 302 nor 200 */
	{
	  fprintf(stderr, "http_open: %s\n", http_response);
	  return 0;
	}
    }
  else if(!strncmp(http_response, "ICY ", 4))
    {
      /* This is icecast streaming */
      IFVERB printf( "this is an ICY header\n" );
      do
	{
	  len = http_read_header(tcp_sock, http_response, PATH_MAX);
	  if (len == -1)
	    {
	      fprintf(stderr, "http_open: %s\n", strerror(errno));
	      return 0;
	    }
	  IFVERB printf( "ICY header: >%s<\n", http_response );
	}
      while(len>0);
      return(tcp_sock);
    }
  else  /* neither HTTP nor ICY */
    {
      fprintf(stderr, "http_open: %s\n", http_response);
      return 0;
    }
}


int shoutcast(int tcp_sock)
{
  int len;
  int noe, en;
  int j;
  char ** pl;
  
  char http_response[PATH_MAX];
  
  do
    {
      len = http_read_header(tcp_sock, http_response, PATH_MAX);
      if (len == -1)
	{
	  fprintf(stderr, "http_open: %s\n", strerror(errno));
	  return 0;
	}
      IFVERB printf( "Shoutcast: >%s<\n", http_response );
    }
  while(len>0);
  
  len = http_read_content_line(tcp_sock, http_response, PATH_MAX);
  if (len == -1)
    {
      fprintf(stderr, "http_open: %s\n", strerror(errno));
      return 0;
    }
  IFVERB printf( "Shoutcast: >%s<\n", http_response );
  if (strncmp(http_response, "[playlist]", 10) != 0)
    {
      fprintf(stderr, "Server response does not conform to audio/x-scpls MIME type format\n" );
      return 0;
    }
  
  len = http_read_content_line(tcp_sock, http_response, PATH_MAX);
  if (len == -1)
    {
      fprintf(stderr, "http_open: %s\n", strerror(errno));
      return 0;
    }
  IFVERB printf( "Shoutcast: >%s<\n", http_response );
  if (strncmp(http_response, "numberofentries=", 16) != 0)
    {
      fprintf(stderr, "Server response does not conform to audio/x-scpls MIME type format\n" );
      return 0;
    }
  
  sscanf( http_response+16, "%d", &noe );
  if(noe<1)
    {
      printf( "The ShoutCast playlist contains no entries.\n" );
      return(0);
    }
  
  printf( "The ShoutCast playlist contains %d entries:\n", noe );
  pl = (char**)calloc(noe,sizeof(char*));
  j = 0;
  while(j<noe)
    {
      len = http_read_content_line(tcp_sock, http_response, PATH_MAX);
      if (len == -1)
	{
	  fprintf(stderr, "http_open: %s\n", strerror(errno));
	  return 0;
	}
      if (strncmp(http_response, "File", 4) == 0)
	{
	  char * equ;
	  equ = strchr(http_response, '=')+1;
	  pl[j] = (char*)calloc(strlen(equ),sizeof(char));
	  strcpy(pl[j],equ);
	  printf( "[%2d] %s\n", ++j, equ );
	}
    }
  en = 1;
  if(noe>1)
    {
      do
	{
	  printf( "Please choose from the list: " );
	  scanf( "%d", &en );
	}
      while(en<1 || en>noe);
    }
  
  close(tcp_sock);
  return http_open(pl[en-1]);
}

int ftp_get_reply(int tcp_sock)
{
    int i;
    char c;
    char answer[1024];

    do
    {
        /* Read a line */
        for (i = 0, c = 0; i < 1023 && c != '\n'; i++)
        {
            read(tcp_sock, &c, sizeof(char));
            answer[i] = c;
        }
        answer[i] = 0;
        fprintf(stderr, "%s", answer + 4);
    }
    while (answer[3] == '-');

    answer[3] = 0;

    return (atoi(answer));
}

int ftp_open(char *arg)
{
    char *host;
    int port;
    char *dir;
    char *file;
    int tcp_sock;
    int data_sock;
    char ftp_request[PATH_MAX];
    struct sockaddr_in stLclAddr;
    socklen_t namelen;
    int i;

    /* Check for URL syntax */
    if (strncmp(arg, "ftp://", strlen("ftp://")))
        return (0);

    /* Parse URL */
    port = 21;
    host = arg + strlen("ftp://");
    if ((dir = strchr(host, '/')) == NULL)
        return (0);
    *dir++ = 0;
    if ((file = strrchr(dir, '/')) == NULL)
    {
        file = dir;
        dir = NULL;
    }
    else
        *file++ = 0;

    if (strchr(host, ':') != NULL)  /* port is specified */
    {
        port = atoi(strchr(host, ':') + 1);
        *strchr(host, ':') = 0;
    }

    /* Open a TCP socket */
    if (!(tcp_sock = tcp_open(host, port)))
    {
        perror("ftp_open");
        return (0);
    }

    /* Send FTP USER and PASS request */
    ftp_get_reply(tcp_sock);
    snprintf(ftp_request, sizeof(ftp_request), "USER anonymous\r\n");
    send(tcp_sock, ftp_request, strlen(ftp_request), 0);
    if (ftp_get_reply(tcp_sock) != 331)
        return (0);
    snprintf(ftp_request, sizeof(ftp_request), "PASS smpeguser@\r\n");
    send(tcp_sock, ftp_request, strlen(ftp_request), 0);
    if (ftp_get_reply(tcp_sock) != 230)
        return (0);
    snprintf(ftp_request, sizeof(ftp_request), "TYPE I\r\n");
    send(tcp_sock, ftp_request, strlen(ftp_request), 0);
    if (ftp_get_reply(tcp_sock) != 200)
        return (0);
    if (dir != NULL)
    {
        snprintf(ftp_request, sizeof(ftp_request), "CWD %s\r\n", dir);
        send(tcp_sock, ftp_request, strlen(ftp_request), 0);
        if (ftp_get_reply(tcp_sock) != 250)
            return (0);
    }

    /* Get interface address */
    namelen = sizeof(stLclAddr);
    if (getsockname(tcp_sock, (struct sockaddr *)&stLclAddr, &namelen) < 0)
        return (0);

    /* Open data socket */
    if ((data_sock = socket(PF_INET, SOCK_STREAM, 0)) < 0)
        return (0);

    stLclAddr.sin_family = AF_INET;

    /* Get the first free port */
    for (i = 0; i < 0xC000; i++)
    {
        stLclAddr.sin_port = htons(0x4000 + i);
        if (bind(data_sock, (struct sockaddr *)&stLclAddr, sizeof(stLclAddr)) >= 0)
            break;
    }
    port = 0x4000 + i;

    if (listen(data_sock, 1) < 0)
        return (0);

    i = ntohl(stLclAddr.sin_addr.s_addr);
    snprintf(ftp_request, sizeof(ftp_request), "PORT %d,%d,%d,%d,%d,%d\r\n",
            (i >> 24) & 0xFF, (i >> 16) & 0xFF,
            (i >> 8) & 0xFF, i & 0xFF, (port >> 8) & 0xFF, port & 0xFF);
    send(tcp_sock, ftp_request, strlen(ftp_request), 0);
    if (ftp_get_reply(tcp_sock) != 200)
        return (0);

    snprintf(ftp_request, sizeof(ftp_request), "RETR %s\r\n", file);
    send(tcp_sock, ftp_request, strlen(ftp_request), 0);
    if (ftp_get_reply(tcp_sock) != 150)
        return (0);

    return (accept(data_sock, NULL, NULL));
}