/*
   This file is part of cccd - a CDDB capable CD player
   Copyright (c) 1998 by Jochen Stein, jst@writeme.com
   Copyright (c) 1998 by Sven Riedel, Sven.Riedel@heim8.tu-clausthal.de

   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.

   (See the included file COPYING / GPL-2.0)

   $Id: cddbp.c,v 0.3.3.1 1998/08/20 16:09:09 jochen Exp $
 */

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

#include "misc.h"
#include "cddbp.h"

int cddbp_signon(FILE * socket)
{
  char *buffer;
  int code;

  buffer = get_string_piece(socket, '\n');
#ifdef DEBUG
  printf("<= %s\n", buffer);
#endif
  /* convert the answer code to int */
  code = ((buffer[0] - 0x30) * 10 + (buffer[1] - 0x30)) * 10 + (buffer[2] - 0x30);

  free(buffer);
  return code;
}



int cddbp_handshake(FILE * socket, const char *clientname, const char *version)
{
  char *buffer;
  int code;

  /* Greetings! */
#ifdef DEBUG
  printf("=> cddb hello unknown localhost %s %s\n", clientname, version);
#endif
  fprintf(socket, "cddb hello unknown localhost %s %s\n", clientname, version);

  buffer = get_string_piece(socket, '\n');
#ifdef DEBUG
  printf("<= %s\n", buffer);
#endif

  code = ((buffer[0] - 0x30) * 10 + (buffer[1] - 0x30)) * 10 + (buffer[2] - 0x30);

  free(buffer);
  return code;
}



int cddbp_query(FILE * socket, const char *disk_id, int tracknum,
		long int offset[], int duration, int *matches,
		char ***category_buffer, char ***title_buffer,
		char ***id_buffer)
{
  char *buffer, *tmp;
  int code, i;

  buffer = (char *) malloc(strlen("cddb query ") + strlen(disk_id) + 1 + 3 +
			   tracknum * 10 + 6 + 1);

  sprintf(buffer, "cddb query %s %d ", disk_id, tracknum);
  tmp = (char *) malloc(10);
  for (i = 0; i < tracknum; i++) {
    sprintf(tmp, "%ld ", offset[i]);
    strcat(buffer, tmp);
  }

  sprintf(tmp, "%d\n", duration);
  strcat(buffer, tmp);
  free(tmp);

#ifdef DEBUG
  printf("=> %s\n", buffer);
#endif

  fprintf(socket, "%s", buffer);
  free(buffer);

  tmp = buffer = get_string_piece(socket, '\n');
#ifdef DEBUG
  printf("<= %s\n", buffer);
#endif

  code = ((buffer[0] - 0x30) * 10 + (buffer[1] - 0x30)) * 10 + (buffer[2] - 0x30);
  *matches = 0;

  if (code == 200) {
    buffer = tmp + 4;
  }
  else if (code == 211) {
    free(buffer);
    tmp = buffer = get_string_piece(socket, '\n');
  }
  else
    return code;


  /* get the alternavtives */
  *title_buffer = (char **) malloc(sizeof(char *) * 1000);
  *category_buffer = (char **) malloc(sizeof(char *) * 1000);
  *id_buffer = (char **) malloc(sizeof(char *) * 1000);

  do {
    if (strcmp(buffer, ".\r\n") == 0)
      break;

    /* if we get more than 1000 matches, the char*[] will be full,
       and we will skip the remaining few million matches */
    if (*matches == 999) {
      free(tmp);
      continue;
    }

    i = strcspn(buffer, " ");
    (*category_buffer)[*matches] = (char *) malloc(i + 1);
    strncpy((*category_buffer)[*matches], buffer, i);
    (*category_buffer)[*matches][i] = 0;	/*terminate the string */

    buffer += i + 1;		/* skip to the disk id */
    (*id_buffer)[*matches] = (char *) malloc(9);	/* the disk id is always
							   8 char long */
    strncpy((*id_buffer)[*matches], buffer, 8);
    (*id_buffer)[*matches][8] = 0;	/*terminate the string */
    buffer += 9;

    i = strlen(buffer) - 2;	/*strip the remaining '\r\n' from the 
				   end of the line */
    (*title_buffer)[*matches] = (char *) malloc(i + 1);
    strncpy((*title_buffer)[*matches], buffer, i);
    (*title_buffer)[*matches][i] = 0;	/*terminate the string */

    (*matches)++;
    free(tmp);
  } while (code != 200 && (tmp = buffer = get_string_piece(socket, '\n')) != NULL);

  return code;
}



int cddbp_read(FILE * socket, const char *category, const char *disk_id,
	       char **result_buffer)
{
  char *buffer;
  int code;
/* int i; */ /* debugging aid */

#ifdef DEBUG
  printf("=> cddb read %s %s\n", category, disk_id);
#endif
  fprintf(socket, "cddb read %s %s\n", category, disk_id);

  buffer = get_string_piece(socket, '\n');
#ifdef DEBUG
  printf("<= %s\n", buffer);
#endif

  code = ((buffer[0] - 0x30) * 10 + (buffer[1] - 0x30)) * 10 + (buffer[2] - 0x30);
  free(buffer);

  if (code > 210)
    return code;
  /* skip the first row, and copy the data that follows into the result buffer */

  *result_buffer = (char *) malloc(1);

  strcpy(*result_buffer, "");
  do {
    buffer = get_string_piece(socket, '\n');
#ifdef DEBUG
    printf("<= %s", buffer);
/* for (i=0; buffer[i] != '\0'; i++) printf("%x ",buffer[i]); */ /* we want hex */
#endif
    string_append(result_buffer, buffer);
    free(buffer);
  } while (strstr(*result_buffer, "\r\n.\r\n") == NULL);

  return code;
}

int cddbp_stat(FILE * socket, char **result)
{
  int code;
  char *buffer;
#ifdef DEBUG
  printf("=> stat\n");
#endif
  fprintf(socket, "stat\n");

  buffer = get_string_piece(socket, '\n');
#ifdef DEBUG
  printf("<= %s\n", buffer);
#endif
  code = ((buffer[0] - 0x30) * 10 + (buffer[1] - 0x30)) * 10 + (buffer[2] - 0x30);
  free(buffer);

  if (code > 210)
    return code;

  do {
    buffer = get_string_piece(socket, '\n');
#ifdef DEBUG
    printf("<= %s", buffer);
#endif
    string_append(result, buffer);
    free(buffer);
  } while (strstr(*result, "\r\n.\r\n") == NULL);

  return code;
}

void cddbp_signoff(FILE * socket)
{
  char *buffer;
  fprintf(socket, "quit\n");
  buffer = get_string_piece(socket, '\n');
  free(buffer);
  fclose(socket);
#ifdef DEBUG
  printf("Signing off\n");
#endif
}


int http_query(const char *server, int port, const char *URL,
	       const char *cd_id, int tracknum, long int offset[],
	       int duration, int *matches,
	       char ***category_buffer, char ***title_buffer,
	       char ***id_buffer, const char *client, const char *version)
{
  char *buffer = (char *) malloc(1024), *tmp = (char *) malloc(1024);
  int i, code;
  FILE *sock;

  sprintf(buffer, "GET /%s?cmd=cddb+query+%s+%d", URL, cd_id, tracknum);

  for (i = 0; i < tracknum; i++) {
    sprintf(tmp, "+%ld", offset[i]);
    strcat(buffer, tmp);
    strcpy(tmp, "");
  }

  sprintf(tmp, "+%d&hello=unknown+localhost+%s+%s&proto=1 HTTP/1.0\r\n\r\n",
          duration, client, version);
  strcat(buffer, tmp);
  free(tmp);

#ifdef DEBUG
  printf("=> %s\n", buffer);
#endif


  sock = socket_init(server, port);
  fprintf(sock, "%s", buffer);
  free(buffer);

  buffer = get_ascii_file(sock);
#ifdef DEBUG
  printf("<= %s\n", buffer);
#endif

  /* strip the http header of the answer */
  tmp = strstr(buffer, "\r\n\r\n");
  if (tmp == NULL) {		/* uhoh, no empty row anywhere.... */
    free(buffer);
    return -1;
  }
  tmp += 4;
  tmp = strdup(tmp);
  free(buffer);
  buffer = tmp;
  *matches = 0;

  code = ((tmp[0] - 0x30) * 10 + (tmp[1] - 0x30)) * 10 + (tmp[2] - 0x30);

  if (code == 200) {
    buffer += 4;
  }
  else if (code == 211) {
    buffer = strchr(buffer, '\n');
  }
  else {
    free(tmp);
    return code;
  }

  *title_buffer = (char **) malloc(sizeof(char *) * 1000);
  *category_buffer = (char **) malloc(sizeof(char *) * 1000);
  *id_buffer = (char **) malloc(sizeof(char *) * 1000);

  do {
    if (strcmp(buffer, ".\r\n") == 0)
      break;

    /* if we get more than 1000 matches, the char*[] will be full,
       and we will skip the remaining few million matches */
    if (*matches == 999) {
      continue;
    }

    i = strcspn(buffer, " ");
    (*category_buffer)[*matches] = (char *) malloc(i + 1);
    strncpy((*category_buffer)[*matches], buffer, i);
    (*category_buffer)[*matches][i] = 0;	/*terminate the string */

    buffer += i + 1;		/* skip to the disk id */
    (*id_buffer)[*matches] = (char *) malloc(9);	/* the disk id is always
							   8 char long */
    strncpy((*id_buffer)[*matches], buffer, 8);
    (*id_buffer)[*matches][8] = 0;	/*terminate the string */
    buffer += 9;

    i = strcspn(buffer, "\r\n");
    (*title_buffer)[*matches] = (char *) malloc(i + 1);
    strncpy((*title_buffer)[*matches], buffer, i);
    (*title_buffer)[*matches][i] = 0;	/*terminate the string */

    (*matches)++;
    buffer += i + 2;		/* skip the \r\n */
  } while ((buffer = strchr(buffer, '\n')) != NULL);

  free(tmp);
  return code;
}

int http_read(const char *server, int port, const char *URL,
	      const char *category, const char *disk_id, char **result,
	      const char *client, const char *version)
{
  int code;
  char *buffer, *tmp;
  FILE *sock;

#ifdef DEBUG
  printf("=> GET /%s?cmd=cddb+read+%s+%s&hello=unknown+localhost+%s+%s&proto=1 HTTP/1.0\r\n\r\n", URL, category, disk_id, client, version);
#endif

  sock = socket_init(server, port);
  fprintf(sock, "GET /%s?cmd=cddb+read+%s+%s&hello=unknown+localhost+%s+%s&proto=1 HTTP/1.0\r\n\r\n", URL, category, disk_id, client, version);

  buffer = get_ascii_file(sock);
#ifdef DEBUG
  printf("<= %s\n", buffer);
#endif

  /* strip the http header of the answer */
  tmp = strstr(buffer, "\r\n\r\n");
  if (tmp == NULL) {		/* uhoh, no empty row anywhere.... */
    free(buffer);
    return -1;
  }
  tmp += 4;
  tmp = strdup(tmp);
  free(buffer);
  buffer = tmp;

  code = ((buffer[0] - 0x30) * 10 + (buffer[1] - 0x30)) * 10 + (buffer[2] - 0x30);

  if (code > 210) {
    free(buffer);
    return code;
  }

  /* skip the first row, and copy the data that follows into the result buffer */
  tmp = strchr(buffer, '\n') + 1;
  *result = strdup(tmp);
  free(buffer);

  return code;
}


int http_stat(const char *server, int port, const char *URL, char **result,
	      const char *client, const char *version)
{
  int code;
  char *buffer, *tmp;
  FILE *sock;

#ifdef DEBUG
  printf("=> GET /%s?cmd=stat&hello=unknown+localhost+%s+%s&proto=1 HTTP/1.0\r\n\r\n", URL, client, version);
#endif

  sock = socket_init(server, port);
  fprintf(sock, "GET /%s?cmd=stat&hello=unknown+localhost+%s+%s&proto=1 HTTP/1.0\r\n\r\n", URL, client, version);

  buffer = get_ascii_file(sock);
#ifdef DEBUG
  printf("<= %s\n", buffer);
#endif

  /* strip the http header of the answer */
  tmp = strstr(buffer, "\r\n\r\n");
  if (tmp == NULL) {		/* uhoh, no empty row anywhere.... */
    free(buffer);
    return -1;
  }
  tmp += 4;
  tmp = strdup(tmp);
  free(buffer);
  buffer = tmp;

  code = ((buffer[0] - 0x30) * 10 + (buffer[1] - 0x30)) * 10 + (buffer[2] - 0x30);

  if (code > 210) {
    free(buffer);
    return code;
  }

  /* skip the first row, and copy the data that follows into the result buffer */
  tmp = strchr(buffer, '\n') + 1;
  *result = strdup(tmp);
  free(buffer);

  return code;
}