RetroArch/http_intf.c

/*  RetroArch - A frontend for libretro.
 *  Copyright (C) 2011-2015 - Daniel De Matteis
 *  Copyright (C) 2014-2015 - Alfred Agrell
 * 
 *  RetroArch 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 Found-
 *  ation, either version 3 of the License, or (at your option) any later version.
 *
 *  RetroArch 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 RetroArch.
 *  If not, see <http://www.gnu.org/licenses/>.
 */

#include <stdlib.h>
#include <assert.h>
#include "http_intf.h"
#include "retroarch_logger.h"
#include <retro_miscellaneous.h>
#include "general.h"

#include <file/file_path.h>

/**
 * http_get_file:
 * @url                 : URL to file.
 * @buf                 : Buffer.
 * @len                 : Size of @buf.
 *
 * Loads the contents of a file at specified URL into
 * buffer @buf. Sets length of data buffer as well.
 *
 * Returns: HTTP return code on success, otherwise 
 * negative on failure.
 **/
http_retcode http_get_file(char *url, char **buf, int *len)
{
   char *urlfilename = NULL;

   if (http_parse_url(url, &urlfilename) != 0)
      return ERRRDDT;

   return http_get(urlfilename, buf, len, NULL);
}

/**
 * http_download_file:
 * @url                 : URL to file.
 * @output_dir          : Output directory for new file.
 * @output_basename     : Output basename  for new file.
 *
 * Downloads a file at specified URL.
 *
 * Returns: bool (1) if successful, otherwise false (0).
 **/
bool http_download_file(char *url, const char *output_dir,
      const char *output_basename)
{
   http_retcode status;
   int len;
   FILE *f;
   char output_path[PATH_MAX_LENGTH];
   char *buf;

   status = http_get_file(url, &buf, &len);

   if (status < 0)
   {
      RARCH_ERR("%i - Failure.\n", status);
      return false;
   }

   fill_pathname_join(output_path, output_dir, output_basename,
         sizeof(output_path));

   f = fopen(output_path, "wb");

   if (!f)
      goto cleanup;

   fwrite(buf, 1, len, f);

   fclose(f);

cleanup:
   if (buf)
      free(buf);

   return true;
}

int http_intf_command(unsigned mode, char *url)
{
   int ret, lg, blocksize, r;
   char typebuf[70];
   char *data=NULL, *filename = NULL, *proxy = NULL;

   if (mode == HTTP_INTF_ERROR)
      return -1;

#if 0
   if ((proxy = getenv("http_proxy")))
   {
      ret=http_parse_url(proxy,&filename);
      if (ret<0)
         return ret;
      http_proxy_server=http_server;
      http_server=NULL;
      http_proxy_port=http_port;
   }
#endif

   ret = http_parse_url(url, &filename);

   if (ret<0)
   {
      if (proxy)
         free(http_proxy_server);
      return ret;
   }

   switch (mode)
   {
      /* *** PUT *** */
      case HTTP_INTF_PUT:
         /* read stdin into memory */
         RARCH_LOG("reading stdin...\n");
         blocksize = 16384;
         lg        = 0;

         if (!(data = (char*)malloc(blocksize)))
            return 3;

         while (1)
         {
            r=read(0, data + lg, blocksize - lg);

            if (r<=0)
               break;

            lg+=r;

            if ((3 * lg / 2) > blocksize)
            {
               blocksize *= 4;
               RARCH_LOG("read to date: %9d bytes, reallocating buffer to %9d\n",
                     lg, blocksize);
               if (!(data = (char*)realloc(data,blocksize)))
                  return 4;
            }
         }
         RARCH_LOG("read %d bytes\n", lg);
         ret = http_put(filename,data, lg, 0, NULL);
         RARCH_LOG("res=%d\n", ret);
         break;
      case HTTP_INTF_GET:
         /* *** GET *** */
         ret = http_get(filename, &data, &lg, typebuf);
         RARCH_LOG("res=%d, type='%s', lg=%d\n", ret, typebuf, lg);
         fwrite(data, lg, 1, stdout);
         break;
      case HTTP_INTF_HEAD:
         /* *** HEAD *** */
         ret = http_head(filename, &lg, typebuf);
         RARCH_LOG("res=%d, type='%s', lg=%d\n",ret, typebuf, lg);
         break;
      case HTTP_INTF_DELETE:
         /* *** DELETE *** */
         ret = http_delete(filename);
         RARCH_LOG("res=%d\n", ret);
         break;
         /* impossible... */
      default:
         RARCH_LOG("Impossible mode value=%d\n", mode);
         return 5;
   }
   if (data)
      free(data);
   free(filename);
   free(http_server);
   if (proxy)
      free(http_proxy_server);

   /* Resource successfully created? */
   if (ret == 200)
      return 0;
   /* Resource successfully read? */
   if (ret == 201)
      return 0;
   return ret;
}