gio/win32/gwinhttpfile.c - third_party/glib - Git at Google

 /* GIO - GLib Input, Output and Streaming Library
  *
  * Copyright (C) 2006-2007 Red Hat, Inc.
  * Copyright (C) 2008 Novell, Inc.
  *
  * This library is free software; you can redistribute it and/or
  * modify it under the terms of the GNU Lesser General Public
  * License as published by the Free Software Foundation; either
  * version 2.1 of the License, or (at your option) any later version.
  *
  * This library 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
  * Lesser General Public License for more details.
  *
  * You should have received a copy of the GNU Lesser General
  * Public License along with this library; if not, see <http://www.gnu.org/licenses/>.
  *
  * Author: Alexander Larsson <alexl@redhat.com>
  * Author: Tor Lillqvist <tml@novell.com>
  */

 #include "config.h"

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

 #include "gio/gfile.h"
 #include "gio/gfileattribute.h"
 #include "gio/gfileinfo.h"
 #include "gwinhttpfile.h"
 #include "gwinhttpfileinputstream.h"
 #include "gwinhttpfileoutputstream.h"
 #include "gio/gioerror.h"

 #include "glibintl.h"

 static void g_winhttp_file_file_iface_init (GFileIface *iface);

 #define g_winhttp_file_get_type _g_winhttp_file_get_type
 G_DEFINE_TYPE_WITH_CODE (GWinHttpFile, g_winhttp_file, G_TYPE_OBJECT,
                          G_IMPLEMENT_INTERFACE (G_TYPE_FILE,
                                                 g_winhttp_file_file_iface_init))

 static void
 g_winhttp_file_finalize (GObject *object)
 {
   GWinHttpFile *file;

   file = G_WINHTTP_FILE (object);

   g_free (file->url.lpszScheme);
   g_free (file->url.lpszHostName);
   g_free (file->url.lpszUserName);
   g_free (file->url.lpszPassword);
   g_free (file->url.lpszUrlPath);
   g_free (file->url.lpszExtraInfo);

   g_object_unref (file->vfs);

   G_OBJECT_CLASS (g_winhttp_file_parent_class)->finalize (object);
 }

 static void
 g_winhttp_file_class_init (GWinHttpFileClass *klass)
 {
   GObjectClass *gobject_class = G_OBJECT_CLASS (klass);

   gobject_class->finalize = g_winhttp_file_finalize;
 }

 static void
 g_winhttp_file_init (GWinHttpFile *winhttp)
 {
 }

 /*
  * _g_winhttp_file_new:
  * @vfs: GWinHttpVfs to use
  * @uri: URI of the GWinHttpFile to create.
  *
  * Returns: new winhttp #GFile.
  */
 GFile *
 _g_winhttp_file_new (GWinHttpVfs *vfs,
                      const char  *uri)
 {
   wchar_t *wuri;
   GWinHttpFile *file;

   wuri = g_utf8_to_utf16 (uri, -1, NULL, NULL, NULL);

   if (wuri == NULL)
     return NULL;

   file = g_object_new (G_TYPE_WINHTTP_FILE, NULL);
   file->vfs = g_object_ref (vfs);

   memset (&file->url, 0, sizeof (file->url));
   file->url.dwStructSize = sizeof (file->url);
   file->url.dwSchemeLength = 1;
   file->url.dwHostNameLength = 1;
   file->url.dwUserNameLength = 1;
   file->url.dwPasswordLength = 1;
   file->url.dwUrlPathLength = 1;
   file->url.dwExtraInfoLength = 1;

   if (!G_WINHTTP_VFS_GET_CLASS (vfs)->funcs->pWinHttpCrackUrl (wuri, 0, 0, &file->url))
     {
       g_free (wuri);
       return NULL;
     }

   file->url.lpszScheme = g_new (wchar_t, ++file->url.dwSchemeLength);
   file->url.lpszHostName = g_new (wchar_t, ++file->url.dwHostNameLength);
   file->url.lpszUserName = g_new (wchar_t, ++file->url.dwUserNameLength);
   file->url.lpszPassword = g_new (wchar_t, ++file->url.dwPasswordLength);
   file->url.lpszUrlPath = g_new (wchar_t, ++file->url.dwUrlPathLength);
   file->url.lpszExtraInfo = g_new (wchar_t, ++file->url.dwExtraInfoLength);

   if (!G_WINHTTP_VFS_GET_CLASS (vfs)->funcs->pWinHttpCrackUrl (wuri, 0, 0, &file->url))
     {
       g_free (file->url.lpszScheme);
       g_free (file->url.lpszHostName);
       g_free (file->url.lpszUserName);
       g_free (file->url.lpszPassword);
       g_free (file->url.lpszUrlPath);
       g_free (file->url.lpszExtraInfo);
       g_free (wuri);
       return NULL;
     }

   g_free (wuri);
   return G_FILE (file);
 }

 static gboolean
 g_winhttp_file_is_native (GFile *file)
 {
   return FALSE;
 }

 static gboolean
 g_winhttp_file_has_uri_scheme (GFile      *file,
                                const char *uri_scheme)
 {
   return (g_ascii_strcasecmp (uri_scheme, "http") == 0 ||
           g_ascii_strcasecmp (uri_scheme, "https") == 0);
 }

 static char *
 g_winhttp_file_get_uri_scheme (GFile *file)
 {
   GWinHttpFile *winhttp_file = G_WINHTTP_FILE (file);

   return g_utf16_to_utf8 (winhttp_file->url.lpszScheme, -1, NULL, NULL, NULL);
 }

 static char *
 g_winhttp_file_get_basename (GFile *file)
 {
   GWinHttpFile *winhttp_file = G_WINHTTP_FILE (file);
   char *basename;
   char *last_slash;
   char *retval;

   basename = g_utf16_to_utf8 (winhttp_file->url.lpszUrlPath, -1, NULL, NULL, NULL);
   last_slash = strrchr (basename, '/');
   /* If no slash, or only "/" fallback to full path part of URI */
   if (last_slash == NULL || last_slash[1] == '\0')
     return basename;

   retval = g_strdup (last_slash + 1);
   g_free (basename);

   return retval;
 }

 static char *
 g_winhttp_file_get_path (GFile *file)
 {
   return NULL;
 }

 static char *
 g_winhttp_file_get_uri (GFile *file)
 {
   GWinHttpFile *winhttp_file = G_WINHTTP_FILE (file);
   DWORD len;
   wchar_t *wuri;
   char *retval;

   len = 0;
   if (!G_WINHTTP_VFS_GET_CLASS (winhttp_file->vfs)->funcs->pWinHttpCreateUrl (&winhttp_file->url, ICU_ESCAPE, NULL, &len) &&
       GetLastError () != ERROR_INSUFFICIENT_BUFFER)
     return NULL;

   wuri = g_new (wchar_t, ++len);

   if (!G_WINHTTP_VFS_GET_CLASS (winhttp_file->vfs)->funcs->pWinHttpCreateUrl (&winhttp_file->url, ICU_ESCAPE, wuri, &len))
     {
       g_free (wuri);
       return NULL;
     }

   retval = g_utf16_to_utf8 (wuri, -1, NULL, NULL, NULL);
   g_free (wuri);

   if (g_str_has_prefix (retval, "http://:@"))
     {
       memmove (retval + 7, retval + 9, strlen (retval) - 9);
       retval[strlen (retval) - 2] = '\0';
     }
   else if (g_str_has_prefix (retval, "https://:@"))
     {
       memmove (retval + 8, retval + 10, strlen (retval) - 10);
       retval[strlen (retval) - 2] = '\0';
     }

   return retval;
 }

 static char *
 g_winhttp_file_get_parse_name (GFile *file)
 {
   /* FIXME: More hair surely needed */

   return g_winhttp_file_get_uri (file);
 }

 static GFile *
 g_winhttp_file_get_parent (GFile *file)
 {
   GWinHttpFile *winhttp_file;
   char *uri;
   char *last_slash;
   GFile *parent;

   winhttp_file = G_WINHTTP_FILE (file);

   uri = g_winhttp_file_get_uri (file);
   if (uri == NULL)
     return NULL;

   last_slash = strrchr (uri, '/');
   if (last_slash == NULL || *(last_slash+1) == 0)
     {
       g_free (uri);
       return NULL;
     }

   while (last_slash > uri && *last_slash == '/')
     last_slash--;

   last_slash[1] = '\0';

   parent = _g_winhttp_file_new (winhttp_file->vfs, uri);
   g_free (uri);

   return parent;
 }

 static GFile *
 g_winhttp_file_dup (GFile *file)
 {
   GWinHttpFile *winhttp_file = G_WINHTTP_FILE (file);
   char *uri = g_winhttp_file_get_uri (file);
   GFile *retval = _g_winhttp_file_new (winhttp_file->vfs, uri);

   g_free (uri);

   return retval;
 }

 static guint
 g_winhttp_file_hash (GFile *file)
 {
   char *uri = g_winhttp_file_get_uri (file);
   guint retval = g_str_hash (uri);

   g_free (uri);

   return retval;
 }

 static gboolean
 g_winhttp_file_equal (GFile *file1,
                       GFile *file2)
 {
   char *uri1 = g_winhttp_file_get_uri (file1);
   char *uri2 = g_winhttp_file_get_uri (file2);
   gboolean retval = g_str_equal (uri1, uri2);

   g_free (uri1);
   g_free (uri2);

   return retval;
 }

 static const char *
 match_prefix (const char *path,
               const char *prefix)
 {
   int prefix_len;

   prefix_len = strlen (prefix);
   if (strncmp (path, prefix, prefix_len) != 0)
     return NULL;

   if (prefix_len > 0 && prefix[prefix_len-1] == '/')
     prefix_len--;

   return path + prefix_len;
 }

 static gboolean
 g_winhttp_file_prefix_matches (GFile *parent,
                                GFile *descendant)
 {
   char *parent_uri = g_winhttp_file_get_uri (parent);
   char *descendant_uri = g_winhttp_file_get_uri (descendant);
   const char *remainder;
   gboolean retval;

   remainder = match_prefix (descendant_uri, parent_uri);

   if (remainder != NULL && *remainder == '/')
     retval = TRUE;
   else
     retval = FALSE;

   g_free (parent_uri);
   g_free (descendant_uri);

   return retval;
 }

 static char *
 g_winhttp_file_get_relative_path (GFile *parent,
                                   GFile *descendant)
 {
   char *parent_uri = g_winhttp_file_get_uri (parent);
   char *descendant_uri = g_winhttp_file_get_uri (descendant);
   const char *remainder;
   char *retval;

   remainder = match_prefix (descendant_uri, parent_uri);

   if (remainder != NULL && *remainder == '/')
     retval = g_strdup (remainder + 1);
   else
     retval = NULL;

   g_free (parent_uri);
   g_free (descendant_uri);

   return retval;
 }

 static GFile *
 g_winhttp_file_resolve_relative_path (GFile      *file,
                                       const char *relative_path)
 {
   GWinHttpFile *winhttp_file = G_WINHTTP_FILE (file);
   GWinHttpFile *child;
   wchar_t *wnew_path = g_utf8_to_utf16 (relative_path, -1, NULL, NULL, NULL);

   if (wnew_path == NULL)
     return NULL;

   if (*wnew_path != '/')
     {
       wchar_t *tmp = NULL;
       int trailing_slash = winhttp_file->url.lpszUrlPath[winhttp_file->url.dwUrlPathLength-1] == L'/'? 1 : 0;
       if (trailing_slash)
 	{
 	  tmp = g_new (wchar_t, wcslen (winhttp_file->url.lpszUrlPath) + wcslen (wnew_path) + 1);
 	  wcscpy (tmp, winhttp_file->url.lpszUrlPath);
 	}
       else
 	{
 	  tmp = g_new (wchar_t, wcslen (winhttp_file->url.lpszUrlPath) + 1 + wcslen (wnew_path) + 1);
 	  wcscpy (tmp, winhttp_file->url.lpszUrlPath);
 	  wcscat (tmp, L"/");
 	}
       wcscat (tmp, wnew_path);

       g_free (wnew_path);
       wnew_path = tmp;
     }

   child = g_object_new (G_TYPE_WINHTTP_FILE, NULL);
   child->vfs = winhttp_file->vfs;
   child->url = winhttp_file->url;
   child->url.lpszScheme = g_memdup (winhttp_file->url.lpszScheme, (winhttp_file->url.dwSchemeLength+1)*2);
   child->url.lpszHostName = g_memdup (winhttp_file->url.lpszHostName, (winhttp_file->url.dwHostNameLength+1)*2);
   child->url.lpszUserName = g_memdup (winhttp_file->url.lpszUserName, (winhttp_file->url.dwUserNameLength+1)*2);
   child->url.lpszPassword = g_memdup (winhttp_file->url.lpszPassword, (winhttp_file->url.dwPasswordLength+1)*2);
   child->url.lpszUrlPath = wnew_path;
   child->url.dwUrlPathLength = wcslen (wnew_path);
   child->url.lpszExtraInfo = NULL;
   child->url.dwExtraInfoLength = 0;

   return (GFile *) child;
 }

 static GFile *
 g_winhttp_file_get_child_for_display_name (GFile        *file,
                                            const char   *display_name,
                                            GError      **error)
 {
   GFile *new_file;
   char *basename;

   basename = g_locale_from_utf8 (display_name, -1, NULL, NULL, NULL);
   if (basename == NULL)
     {
       g_set_error (error, G_IO_ERROR, G_IO_ERROR_INVALID_FILENAME,
                    _("Invalid filename %s"), display_name);
       return NULL;
     }

   new_file = g_file_get_child (file, basename);
   g_free (basename);

   return new_file;
 }

 static GFile *
 g_winhttp_file_set_display_name (GFile         *file,
                                  const char    *display_name,
                                  GCancellable  *cancellable,
                                  GError       **error)
 {
   g_set_error_literal (error, G_IO_ERROR, G_IO_ERROR_NOT_SUPPORTED,
                        _("Operation not supported"));

   return NULL;
 }

 static time_t
 mktime_utc (SYSTEMTIME *t)
 {
   time_t retval;

   static const gint days_before[] =
   {
     0, 31, 59, 90, 120, 151, 181, 212, 243, 273, 304, 334
   };

   if (t->wMonth < 1 || t->wMonth > 12)
     return (time_t) -1;

   retval = (t->wYear - 1970) * 365;
   retval += (t->wYear - 1968) / 4;
   retval += days_before[t->wMonth-1] + t->wDay - 1;

   if (t->wYear % 4 == 0 && t->wMonth < 3)
     retval -= 1;

   retval = ((((retval * 24) + t->wHour) * 60) + t->wMinute) * 60 + t->wSecond;

   return retval;
 }

 static GFileInfo *
 g_winhttp_file_query_info (GFile                *file,
                            const char           *attributes,
                            GFileQueryInfoFlags   flags,
                            GCancellable         *cancellable,
                            GError              **error)
 {
   GWinHttpFile *winhttp_file = G_WINHTTP_FILE (file);
   HINTERNET connection, request;
   const wchar_t *accept_types[] =
     {
       L"*/*",
       NULL,
     };
   GFileInfo *info;
   GFileAttributeMatcher *matcher;
   char *basename;
   wchar_t *content_length;
   wchar_t *content_type;
   SYSTEMTIME last_modified;
   DWORD last_modified_len;

   connection = G_WINHTTP_VFS_GET_CLASS (winhttp_file->vfs)->funcs->pWinHttpConnect
     (G_WINHTTP_VFS (winhttp_file->vfs)->session,
      winhttp_file->url.lpszHostName,
      winhttp_file->url.nPort,
      0);

   if (connection == NULL)
     {
       _g_winhttp_set_error (error, GetLastError (), "HTTP connection");

       return NULL;
     }

   request = G_WINHTTP_VFS_GET_CLASS (winhttp_file->vfs)->funcs->pWinHttpOpenRequest
     (connection,
      L"HEAD",
      winhttp_file->url.lpszUrlPath,
      NULL,
      WINHTTP_NO_REFERER,
      accept_types,
      winhttp_file->url.nScheme == INTERNET_SCHEME_HTTPS ? WINHTTP_FLAG_SECURE : 0);

   if (request == NULL)
     {
       _g_winhttp_set_error (error, GetLastError (), "HEAD request");

       return NULL;
     }

   if (!G_WINHTTP_VFS_GET_CLASS (winhttp_file->vfs)->funcs->pWinHttpSendRequest
       (request,
        NULL, 0,
        NULL, 0,
        0,
        0))
     {
       _g_winhttp_set_error (error, GetLastError (), "HEAD request");

       return NULL;
     }

   if (!_g_winhttp_response (winhttp_file->vfs, request, error, "HEAD request"))
     return NULL;

   matcher = g_file_attribute_matcher_new (attributes);
   info = g_file_info_new ();
   g_file_info_set_attribute_mask (info, matcher);

   basename = g_winhttp_file_get_basename (file);
   g_file_info_set_name (info, basename);
   g_free (basename);

   content_length = NULL;
   if (_g_winhttp_query_header (winhttp_file->vfs,
                                request,
                                "HEAD request",
                                WINHTTP_QUERY_CONTENT_LENGTH,
                                &content_length,
                                NULL))
     {
       gint64 cl;
       int n;
       const char *gint64_format = "%"G_GINT64_FORMAT"%n";
       wchar_t *gint64_format_w = g_utf8_to_utf16 (gint64_format, -1, NULL, NULL, NULL);

       if (swscanf (content_length, gint64_format_w, &cl, &n) == 1 &&
           n == wcslen (content_length))
         g_file_info_set_size (info, cl);

       g_free (content_length);
       g_free (gint64_format_w);
     }

   if (matcher == NULL)
     return info;

   content_type = NULL;
   if (_g_winhttp_query_header (winhttp_file->vfs,
                                request,
                                "HEAD request",
                                WINHTTP_QUERY_CONTENT_TYPE,
                                &content_type,
                                NULL))
     {
       char *ct = g_utf16_to_utf8 (content_type, -1, NULL, NULL, NULL);

       if (ct != NULL)
         {
           char *p = strchr (ct, ';');

           if (p != NULL)
             {
               char *tmp = g_strndup (ct, p - ct);

               g_file_info_set_content_type (info, tmp);
               g_free (tmp);
             }
           else
             g_file_info_set_content_type (info, ct);
         }

       g_free (ct);
     }

   last_modified_len = sizeof (last_modified);
   if (G_WINHTTP_VFS_GET_CLASS (winhttp_file->vfs)->funcs->pWinHttpQueryHeaders
       (request,
        WINHTTP_QUERY_LAST_MODIFIED | WINHTTP_QUERY_FLAG_SYSTEMTIME,
        NULL,
        &last_modified,
        &last_modified_len,
        NULL) &&
       last_modified_len == sizeof (last_modified) &&
       /* Don't bother comparing to the exact Y2038 moment */
       last_modified.wYear >= 1970 &&
       last_modified.wYear < 2038)
     {
       GTimeVal tv;

       tv.tv_sec = mktime_utc (&last_modified);
       tv.tv_usec = last_modified.wMilliseconds * 1000;

       g_file_info_set_modification_time (info, &tv);
     }

   g_file_attribute_matcher_unref (matcher);

   return info;
 }

 static GFileInputStream *
 g_winhttp_file_read (GFile         *file,
                      GCancellable  *cancellable,
                      GError       **error)
 {
   GWinHttpFile *winhttp_file = G_WINHTTP_FILE (file);
   HINTERNET connection, request;
   const wchar_t *accept_types[] =
     {
       L"*/*",
       NULL,
     };

   connection = G_WINHTTP_VFS_GET_CLASS (winhttp_file->vfs)->funcs->pWinHttpConnect
     (G_WINHTTP_VFS (winhttp_file->vfs)->session,
      winhttp_file->url.lpszHostName,
      winhttp_file->url.nPort,
      0);

   if (connection == NULL)
     {
       _g_winhttp_set_error (error, GetLastError (), "HTTP connection");

       return NULL;
     }

   request = G_WINHTTP_VFS_GET_CLASS (winhttp_file->vfs)->funcs->pWinHttpOpenRequest
     (connection,
      L"GET",
      winhttp_file->url.lpszUrlPath,
      NULL,
      WINHTTP_NO_REFERER,
      accept_types,
      winhttp_file->url.nScheme == INTERNET_SCHEME_HTTPS ? WINHTTP_FLAG_SECURE : 0);

   if (request == NULL)
     {
       _g_winhttp_set_error (error, GetLastError (), "GET request");

       return NULL;
     }

   return _g_winhttp_file_input_stream_new (winhttp_file, connection, request);
 }

 static GFileOutputStream *
 g_winhttp_file_create (GFile             *file,
                        GFileCreateFlags   flags,
                        GCancellable      *cancellable,
                        GError           **error)
 {
   GWinHttpFile *winhttp_file = G_WINHTTP_FILE (file);
   HINTERNET connection;

   connection = G_WINHTTP_VFS_GET_CLASS (winhttp_file->vfs)->funcs->pWinHttpConnect
     (G_WINHTTP_VFS (winhttp_file->vfs)->session,
      winhttp_file->url.lpszHostName,
      winhttp_file->url.nPort,
      0);

   if (connection == NULL)
     {
       _g_winhttp_set_error (error, GetLastError (), "HTTP connection");

       return NULL;
     }

   return _g_winhttp_file_output_stream_new (winhttp_file, connection);
 }

 #if 0

 static GFileOutputStream *
 g_winhttp_file_replace (GFile             *file,
                         const char        *etag,
                         gboolean           make_backup,
                         GFileCreateFlags   flags,
                         GCancellable      *cancellable,
                         GError           **error)
 {
   /* FIXME: Implement */

   return NULL;
 }


 static gboolean
 g_winhttp_file_delete (GFile         *file,
                        GCancellable  *cancellable,
                        GError       **error)
 {
   /* FIXME: Implement */

   return FALSE;
 }

 static gboolean
 g_winhttp_file_make_directory (GFile         *file,
                                GCancellable  *cancellable,
                                GError       **error)
 {
   /* FIXME: Implement */

   return FALSE;
 }

 static gboolean
 g_winhttp_file_copy (GFile                  *source,
                      GFile                  *destination,
                      GFileCopyFlags          flags,
                      GCancellable           *cancellable,
                      GFileProgressCallback   progress_callback,
                      gpointer                progress_callback_data,
                      GError                **error)
 {
   /* Fall back to default copy?? */
   g_set_error_literal (error, G_IO_ERROR, G_IO_ERROR_NOT_SUPPORTED,
                        "Copy not supported");

   return FALSE;
 }

 static gboolean
 g_winhttp_file_move (GFile                  *source,
                      GFile                  *destination,
                      GFileCopyFlags          flags,
                      GCancellable           *cancellable,
                      GFileProgressCallback   progress_callback,
                      gpointer                progress_callback_data,
                      GError                **error)
 {
   /* FIXME: Implement */

   return FALSE;
 }

 #endif

 static void
 g_winhttp_file_file_iface_init (GFileIface *iface)
 {
   iface->dup = g_winhttp_file_dup;
   iface->hash = g_winhttp_file_hash;
   iface->equal = g_winhttp_file_equal;
   iface->is_native = g_winhttp_file_is_native;
   iface->has_uri_scheme = g_winhttp_file_has_uri_scheme;
   iface->get_uri_scheme = g_winhttp_file_get_uri_scheme;
   iface->get_basename = g_winhttp_file_get_basename;
   iface->get_path = g_winhttp_file_get_path;
   iface->get_uri = g_winhttp_file_get_uri;
   iface->get_parse_name = g_winhttp_file_get_parse_name;
   iface->get_parent = g_winhttp_file_get_parent;
   iface->prefix_matches = g_winhttp_file_prefix_matches;
   iface->get_relative_path = g_winhttp_file_get_relative_path;
   iface->resolve_relative_path = g_winhttp_file_resolve_relative_path;
   iface->get_child_for_display_name = g_winhttp_file_get_child_for_display_name;
   iface->set_display_name = g_winhttp_file_set_display_name;
   iface->query_info = g_winhttp_file_query_info;
   iface->read_fn = g_winhttp_file_read;
   iface->create = g_winhttp_file_create;
 #if 0
   iface->replace = g_winhttp_file_replace;
   iface->delete_file = g_winhttp_file_delete;
   iface->make_directory = g_winhttp_file_make_directory;
   iface->copy = g_winhttp_file_copy;
   iface->move = g_winhttp_file_move;
 #endif
 }
	/* GIO - GLib Input, Output and Streaming Library
	*
	* Copyright (C) 2006-2007 Red Hat, Inc.
	* Copyright (C) 2008 Novell, Inc.
	*
	* This library is free software; you can redistribute it and/or
	* modify it under the terms of the GNU Lesser General Public
	* License as published by the Free Software Foundation; either
	* version 2.1 of the License, or (at your option) any later version.
	*
	* This library 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
	* Lesser General Public License for more details.
	*
	* You should have received a copy of the GNU Lesser General
	* Public License along with this library; if not, see <http://www.gnu.org/licenses/>.
	*
	* Author: Alexander Larsson <alexl@redhat.com>
	* Author: Tor Lillqvist <tml@novell.com>
	*/

	#include "config.h"

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

	#include "gio/gfile.h"
	#include "gio/gfileattribute.h"
	#include "gio/gfileinfo.h"
	#include "gwinhttpfile.h"
	#include "gwinhttpfileinputstream.h"
	#include "gwinhttpfileoutputstream.h"
	#include "gio/gioerror.h"

	#include "glibintl.h"

	static void g_winhttp_file_file_iface_init (GFileIface *iface);

	#define g_winhttp_file_get_type _g_winhttp_file_get_type
	G_DEFINE_TYPE_WITH_CODE (GWinHttpFile, g_winhttp_file, G_TYPE_OBJECT,
	G_IMPLEMENT_INTERFACE (G_TYPE_FILE,
	g_winhttp_file_file_iface_init))

	static void
	g_winhttp_file_finalize (GObject *object)
	{
	GWinHttpFile *file;

	file = G_WINHTTP_FILE (object);

	g_free (file->url.lpszScheme);
	g_free (file->url.lpszHostName);
	g_free (file->url.lpszUserName);
	g_free (file->url.lpszPassword);
	g_free (file->url.lpszUrlPath);
	g_free (file->url.lpszExtraInfo);

	g_object_unref (file->vfs);

	G_OBJECT_CLASS (g_winhttp_file_parent_class)->finalize (object);
	}

	static void
	g_winhttp_file_class_init (GWinHttpFileClass *klass)
	{
	GObjectClass *gobject_class = G_OBJECT_CLASS (klass);

	gobject_class->finalize = g_winhttp_file_finalize;
	}

	static void
	g_winhttp_file_init (GWinHttpFile *winhttp)
	{
	}

	/*
	* _g_winhttp_file_new:
	* @vfs: GWinHttpVfs to use
	* @uri: URI of the GWinHttpFile to create.
	*
	* Returns: new winhttp #GFile.
	*/
	GFile *
	_g_winhttp_file_new (GWinHttpVfs *vfs,
	const char *uri)
	{
	wchar_t *wuri;
	GWinHttpFile *file;

	wuri = g_utf8_to_utf16 (uri, -1, NULL, NULL, NULL);

	if (wuri == NULL)
	return NULL;

	file = g_object_new (G_TYPE_WINHTTP_FILE, NULL);
	file->vfs = g_object_ref (vfs);

	memset (&file->url, 0, sizeof (file->url));
	file->url.dwStructSize = sizeof (file->url);
	file->url.dwSchemeLength = 1;
	file->url.dwHostNameLength = 1;
	file->url.dwUserNameLength = 1;
	file->url.dwPasswordLength = 1;
	file->url.dwUrlPathLength = 1;
	file->url.dwExtraInfoLength = 1;

	if (!G_WINHTTP_VFS_GET_CLASS (vfs)->funcs->pWinHttpCrackUrl (wuri, 0, 0, &file->url))
	{
	g_free (wuri);
	return NULL;
	}

	file->url.lpszScheme = g_new (wchar_t, ++file->url.dwSchemeLength);
	file->url.lpszHostName = g_new (wchar_t, ++file->url.dwHostNameLength);
	file->url.lpszUserName = g_new (wchar_t, ++file->url.dwUserNameLength);
	file->url.lpszPassword = g_new (wchar_t, ++file->url.dwPasswordLength);
	file->url.lpszUrlPath = g_new (wchar_t, ++file->url.dwUrlPathLength);
	file->url.lpszExtraInfo = g_new (wchar_t, ++file->url.dwExtraInfoLength);

	if (!G_WINHTTP_VFS_GET_CLASS (vfs)->funcs->pWinHttpCrackUrl (wuri, 0, 0, &file->url))
	{
	g_free (file->url.lpszScheme);
	g_free (file->url.lpszHostName);
	g_free (file->url.lpszUserName);
	g_free (file->url.lpszPassword);
	g_free (file->url.lpszUrlPath);
	g_free (file->url.lpszExtraInfo);
	g_free (wuri);
	return NULL;
	}

	g_free (wuri);
	return G_FILE (file);
	}

	static gboolean
	g_winhttp_file_is_native (GFile *file)
	{
	return FALSE;
	}

	static gboolean
	g_winhttp_file_has_uri_scheme (GFile *file,
	const char *uri_scheme)
	{
	return (g_ascii_strcasecmp (uri_scheme, "http") == 0 \|\|
	g_ascii_strcasecmp (uri_scheme, "https") == 0);
	}

	static char *
	g_winhttp_file_get_uri_scheme (GFile *file)
	{
	GWinHttpFile *winhttp_file = G_WINHTTP_FILE (file);

	return g_utf16_to_utf8 (winhttp_file->url.lpszScheme, -1, NULL, NULL, NULL);
	}

	static char *
	g_winhttp_file_get_basename (GFile *file)
	{
	GWinHttpFile *winhttp_file = G_WINHTTP_FILE (file);
	char *basename;
	char *last_slash;
	char *retval;

	basename = g_utf16_to_utf8 (winhttp_file->url.lpszUrlPath, -1, NULL, NULL, NULL);
	last_slash = strrchr (basename, '/');
	/* If no slash, or only "/" fallback to full path part of URI */
	if (last_slash == NULL \|\| last_slash[1] == '\0')
	return basename;

	retval = g_strdup (last_slash + 1);
	g_free (basename);

	return retval;
	}

	static char *
	g_winhttp_file_get_path (GFile *file)
	{
	return NULL;
	}

	static char *
	g_winhttp_file_get_uri (GFile *file)
	{
	GWinHttpFile *winhttp_file = G_WINHTTP_FILE (file);
	DWORD len;
	wchar_t *wuri;
	char *retval;

	len = 0;
	if (!G_WINHTTP_VFS_GET_CLASS (winhttp_file->vfs)->funcs->pWinHttpCreateUrl (&winhttp_file->url, ICU_ESCAPE, NULL, &len) &&
	GetLastError () != ERROR_INSUFFICIENT_BUFFER)
	return NULL;

	wuri = g_new (wchar_t, ++len);

	if (!G_WINHTTP_VFS_GET_CLASS (winhttp_file->vfs)->funcs->pWinHttpCreateUrl (&winhttp_file->url, ICU_ESCAPE, wuri, &len))
	{
	g_free (wuri);
	return NULL;
	}

	retval = g_utf16_to_utf8 (wuri, -1, NULL, NULL, NULL);
	g_free (wuri);

	if (g_str_has_prefix (retval, "http://:@"))
	{
	memmove (retval + 7, retval + 9, strlen (retval) - 9);
	retval[strlen (retval) - 2] = '\0';
	}
	else if (g_str_has_prefix (retval, "https://:@"))
	{
	memmove (retval + 8, retval + 10, strlen (retval) - 10);
	retval[strlen (retval) - 2] = '\0';
	}

	return retval;
	}

	static char *
	g_winhttp_file_get_parse_name (GFile *file)
	{
	/* FIXME: More hair surely needed */

	return g_winhttp_file_get_uri (file);
	}

	static GFile *
	g_winhttp_file_get_parent (GFile *file)
	{
	GWinHttpFile *winhttp_file;
	char *uri;
	char *last_slash;
	GFile *parent;

	winhttp_file = G_WINHTTP_FILE (file);

	uri = g_winhttp_file_get_uri (file);
	if (uri == NULL)
	return NULL;

	last_slash = strrchr (uri, '/');
	if (last_slash == NULL \|\| *(last_slash+1) == 0)
	{
	g_free (uri);
	return NULL;
	}

	while (last_slash > uri && *last_slash == '/')
	last_slash--;

	last_slash[1] = '\0';

	parent = _g_winhttp_file_new (winhttp_file->vfs, uri);
	g_free (uri);

	return parent;
	}

	static GFile *
	g_winhttp_file_dup (GFile *file)
	{
	GWinHttpFile *winhttp_file = G_WINHTTP_FILE (file);
	char *uri = g_winhttp_file_get_uri (file);
	GFile *retval = _g_winhttp_file_new (winhttp_file->vfs, uri);

	g_free (uri);

	return retval;
	}

	static guint
	g_winhttp_file_hash (GFile *file)
	{
	char *uri = g_winhttp_file_get_uri (file);
	guint retval = g_str_hash (uri);

	g_free (uri);

	return retval;
	}

	static gboolean
	g_winhttp_file_equal (GFile *file1,
	GFile *file2)
	{
	char *uri1 = g_winhttp_file_get_uri (file1);
	char *uri2 = g_winhttp_file_get_uri (file2);
	gboolean retval = g_str_equal (uri1, uri2);

	g_free (uri1);
	g_free (uri2);

	return retval;
	}

	static const char *
	match_prefix (const char *path,
	const char *prefix)
	{
	int prefix_len;

	prefix_len = strlen (prefix);
	if (strncmp (path, prefix, prefix_len) != 0)
	return NULL;

	if (prefix_len > 0 && prefix[prefix_len-1] == '/')
	prefix_len--;

	return path + prefix_len;
	}

	static gboolean
	g_winhttp_file_prefix_matches (GFile *parent,
	GFile *descendant)
	{
	char *parent_uri = g_winhttp_file_get_uri (parent);
	char *descendant_uri = g_winhttp_file_get_uri (descendant);
	const char *remainder;
	gboolean retval;

	remainder = match_prefix (descendant_uri, parent_uri);

	if (remainder != NULL && *remainder == '/')
	retval = TRUE;
	else
	retval = FALSE;

	g_free (parent_uri);
	g_free (descendant_uri);

	return retval;
	}

	static char *
	g_winhttp_file_get_relative_path (GFile *parent,
	GFile *descendant)
	{
	char *parent_uri = g_winhttp_file_get_uri (parent);
	char *descendant_uri = g_winhttp_file_get_uri (descendant);
	const char *remainder;
	char *retval;

	remainder = match_prefix (descendant_uri, parent_uri);

	if (remainder != NULL && *remainder == '/')
	retval = g_strdup (remainder + 1);
	else
	retval = NULL;

	g_free (parent_uri);
	g_free (descendant_uri);

	return retval;
	}

	static GFile *
	g_winhttp_file_resolve_relative_path (GFile *file,
	const char *relative_path)
	{
	GWinHttpFile *winhttp_file = G_WINHTTP_FILE (file);
	GWinHttpFile *child;
	wchar_t *wnew_path = g_utf8_to_utf16 (relative_path, -1, NULL, NULL, NULL);

	if (wnew_path == NULL)
	return NULL;

	if (*wnew_path != '/')
	{
	wchar_t *tmp = NULL;
	int trailing_slash = winhttp_file->url.lpszUrlPath[winhttp_file->url.dwUrlPathLength-1] == L'/'? 1 : 0;
	if (trailing_slash)
	{
	tmp = g_new (wchar_t, wcslen (winhttp_file->url.lpszUrlPath) + wcslen (wnew_path) + 1);
	wcscpy (tmp, winhttp_file->url.lpszUrlPath);
	}
	else
	{
	tmp = g_new (wchar_t, wcslen (winhttp_file->url.lpszUrlPath) + 1 + wcslen (wnew_path) + 1);
	wcscpy (tmp, winhttp_file->url.lpszUrlPath);
	wcscat (tmp, L"/");
	}
	wcscat (tmp, wnew_path);

	g_free (wnew_path);
	wnew_path = tmp;
	}

	child = g_object_new (G_TYPE_WINHTTP_FILE, NULL);
	child->vfs = winhttp_file->vfs;
	child->url = winhttp_file->url;
	child->url.lpszScheme = g_memdup (winhttp_file->url.lpszScheme, (winhttp_file->url.dwSchemeLength+1)*2);
	child->url.lpszHostName = g_memdup (winhttp_file->url.lpszHostName, (winhttp_file->url.dwHostNameLength+1)*2);
	child->url.lpszUserName = g_memdup (winhttp_file->url.lpszUserName, (winhttp_file->url.dwUserNameLength+1)*2);
	child->url.lpszPassword = g_memdup (winhttp_file->url.lpszPassword, (winhttp_file->url.dwPasswordLength+1)*2);
	child->url.lpszUrlPath = wnew_path;
	child->url.dwUrlPathLength = wcslen (wnew_path);
	child->url.lpszExtraInfo = NULL;
	child->url.dwExtraInfoLength = 0;

	return (GFile *) child;
	}

	static GFile *
	g_winhttp_file_get_child_for_display_name (GFile *file,
	const char *display_name,
	GError **error)
	{
	GFile *new_file;
	char *basename;

	basename = g_locale_from_utf8 (display_name, -1, NULL, NULL, NULL);
	if (basename == NULL)
	{
	g_set_error (error, G_IO_ERROR, G_IO_ERROR_INVALID_FILENAME,
	_("Invalid filename %s"), display_name);
	return NULL;
	}

	new_file = g_file_get_child (file, basename);
	g_free (basename);

	return new_file;
	}

	static GFile *
	g_winhttp_file_set_display_name (GFile *file,
	const char *display_name,
	GCancellable *cancellable,
	GError **error)
	{
	g_set_error_literal (error, G_IO_ERROR, G_IO_ERROR_NOT_SUPPORTED,
	_("Operation not supported"));

	return NULL;
	}

	static time_t
	mktime_utc (SYSTEMTIME *t)
	{
	time_t retval;

	static const gint days_before[] =
	{
	0, 31, 59, 90, 120, 151, 181, 212, 243, 273, 304, 334
	};

	if (t->wMonth < 1 \|\| t->wMonth > 12)
	return (time_t) -1;

	retval = (t->wYear - 1970) * 365;
	retval += (t->wYear - 1968) / 4;
	retval += days_before[t->wMonth-1] + t->wDay - 1;

	if (t->wYear % 4 == 0 && t->wMonth < 3)
	retval -= 1;

	retval = ((((retval * 24) + t->wHour) * 60) + t->wMinute) * 60 + t->wSecond;

	return retval;
	}

	static GFileInfo *
	g_winhttp_file_query_info (GFile *file,
	const char *attributes,
	GFileQueryInfoFlags flags,
	GCancellable *cancellable,
	GError **error)
	{
	GWinHttpFile *winhttp_file = G_WINHTTP_FILE (file);
	HINTERNET connection, request;
	const wchar_t *accept_types[] =
	{
	L"/",
	NULL,
	};
	GFileInfo *info;
	GFileAttributeMatcher *matcher;
	char *basename;
	wchar_t *content_length;
	wchar_t *content_type;
	SYSTEMTIME last_modified;
	DWORD last_modified_len;

	connection = G_WINHTTP_VFS_GET_CLASS (winhttp_file->vfs)->funcs->pWinHttpConnect
	(G_WINHTTP_VFS (winhttp_file->vfs)->session,
	winhttp_file->url.lpszHostName,
	winhttp_file->url.nPort,
	0);

	if (connection == NULL)
	{
	_g_winhttp_set_error (error, GetLastError (), "HTTP connection");

	return NULL;
	}

	request = G_WINHTTP_VFS_GET_CLASS (winhttp_file->vfs)->funcs->pWinHttpOpenRequest
	(connection,
	L"HEAD",
	winhttp_file->url.lpszUrlPath,
	NULL,
	WINHTTP_NO_REFERER,
	accept_types,
	winhttp_file->url.nScheme == INTERNET_SCHEME_HTTPS ? WINHTTP_FLAG_SECURE : 0);

	if (request == NULL)
	{
	_g_winhttp_set_error (error, GetLastError (), "HEAD request");

	return NULL;
	}

	if (!G_WINHTTP_VFS_GET_CLASS (winhttp_file->vfs)->funcs->pWinHttpSendRequest
	(request,
	NULL, 0,
	NULL, 0,
	0,
	0))
	{
	_g_winhttp_set_error (error, GetLastError (), "HEAD request");

	return NULL;
	}

	if (!_g_winhttp_response (winhttp_file->vfs, request, error, "HEAD request"))
	return NULL;

	matcher = g_file_attribute_matcher_new (attributes);
	info = g_file_info_new ();
	g_file_info_set_attribute_mask (info, matcher);

	basename = g_winhttp_file_get_basename (file);
	g_file_info_set_name (info, basename);
	g_free (basename);

	content_length = NULL;
	if (_g_winhttp_query_header (winhttp_file->vfs,
	request,
	"HEAD request",
	WINHTTP_QUERY_CONTENT_LENGTH,
	&content_length,
	NULL))
	{
	gint64 cl;
	int n;
	const char *gint64_format = "%"G_GINT64_FORMAT"%n";
	wchar_t *gint64_format_w = g_utf8_to_utf16 (gint64_format, -1, NULL, NULL, NULL);

	if (swscanf (content_length, gint64_format_w, &cl, &n) == 1 &&
	n == wcslen (content_length))
	g_file_info_set_size (info, cl);

	g_free (content_length);
	g_free (gint64_format_w);
	}

	if (matcher == NULL)
	return info;

	content_type = NULL;
	if (_g_winhttp_query_header (winhttp_file->vfs,
	request,
	"HEAD request",
	WINHTTP_QUERY_CONTENT_TYPE,
	&content_type,
	NULL))
	{
	char *ct = g_utf16_to_utf8 (content_type, -1, NULL, NULL, NULL);

	if (ct != NULL)
	{
	char *p = strchr (ct, ';');

	if (p != NULL)
	{
	char *tmp = g_strndup (ct, p - ct);

	g_file_info_set_content_type (info, tmp);
	g_free (tmp);
	}
	else
	g_file_info_set_content_type (info, ct);
	}

	g_free (ct);
	}

	last_modified_len = sizeof (last_modified);
	if (G_WINHTTP_VFS_GET_CLASS (winhttp_file->vfs)->funcs->pWinHttpQueryHeaders
	(request,
	WINHTTP_QUERY_LAST_MODIFIED \| WINHTTP_QUERY_FLAG_SYSTEMTIME,
	NULL,
	&last_modified,
	&last_modified_len,
	NULL) &&
	last_modified_len == sizeof (last_modified) &&
	/* Don't bother comparing to the exact Y2038 moment */
	last_modified.wYear >= 1970 &&
	last_modified.wYear < 2038)
	{
	GTimeVal tv;

	tv.tv_sec = mktime_utc (&last_modified);
	tv.tv_usec = last_modified.wMilliseconds * 1000;

	g_file_info_set_modification_time (info, &tv);
	}

	g_file_attribute_matcher_unref (matcher);

	return info;
	}

	static GFileInputStream *
	g_winhttp_file_read (GFile *file,
	GCancellable *cancellable,
	GError **error)
	{
	GWinHttpFile *winhttp_file = G_WINHTTP_FILE (file);
	HINTERNET connection, request;
	const wchar_t *accept_types[] =
	{
	L"/",
	NULL,
	};

	connection = G_WINHTTP_VFS_GET_CLASS (winhttp_file->vfs)->funcs->pWinHttpConnect
	(G_WINHTTP_VFS (winhttp_file->vfs)->session,
	winhttp_file->url.lpszHostName,
	winhttp_file->url.nPort,
	0);

	if (connection == NULL)
	{
	_g_winhttp_set_error (error, GetLastError (), "HTTP connection");

	return NULL;
	}

	request = G_WINHTTP_VFS_GET_CLASS (winhttp_file->vfs)->funcs->pWinHttpOpenRequest
	(connection,
	L"GET",
	winhttp_file->url.lpszUrlPath,
	NULL,
	WINHTTP_NO_REFERER,
	accept_types,
	winhttp_file->url.nScheme == INTERNET_SCHEME_HTTPS ? WINHTTP_FLAG_SECURE : 0);

	if (request == NULL)
	{
	_g_winhttp_set_error (error, GetLastError (), "GET request");

	return NULL;
	}

	return _g_winhttp_file_input_stream_new (winhttp_file, connection, request);
	}

	static GFileOutputStream *
	g_winhttp_file_create (GFile *file,
	GFileCreateFlags flags,
	GCancellable *cancellable,
	GError **error)
	{
	GWinHttpFile *winhttp_file = G_WINHTTP_FILE (file);
	HINTERNET connection;

	connection = G_WINHTTP_VFS_GET_CLASS (winhttp_file->vfs)->funcs->pWinHttpConnect
	(G_WINHTTP_VFS (winhttp_file->vfs)->session,
	winhttp_file->url.lpszHostName,
	winhttp_file->url.nPort,
	0);

	if (connection == NULL)
	{
	_g_winhttp_set_error (error, GetLastError (), "HTTP connection");

	return NULL;
	}

	return _g_winhttp_file_output_stream_new (winhttp_file, connection);
	}

	#if 0

	static GFileOutputStream *
	g_winhttp_file_replace (GFile *file,
	const char *etag,
	gboolean make_backup,
	GFileCreateFlags flags,
	GCancellable *cancellable,
	GError **error)
	{
	/* FIXME: Implement */

	return NULL;
	}


	static gboolean
	g_winhttp_file_delete (GFile *file,
	GCancellable *cancellable,
	GError **error)
	{
	/* FIXME: Implement */

	return FALSE;
	}

	static gboolean
	g_winhttp_file_make_directory (GFile *file,
	GCancellable *cancellable,
	GError **error)
	{
	/* FIXME: Implement */

	return FALSE;
	}

	static gboolean
	g_winhttp_file_copy (GFile *source,
	GFile *destination,
	GFileCopyFlags flags,
	GCancellable *cancellable,
	GFileProgressCallback progress_callback,
	gpointer progress_callback_data,
	GError **error)
	{
	/* Fall back to default copy?? */
	g_set_error_literal (error, G_IO_ERROR, G_IO_ERROR_NOT_SUPPORTED,
	"Copy not supported");

	return FALSE;
	}

	static gboolean
	g_winhttp_file_move (GFile *source,
	GFile *destination,
	GFileCopyFlags flags,
	GCancellable *cancellable,
	GFileProgressCallback progress_callback,
	gpointer progress_callback_data,
	GError **error)
	{
	/* FIXME: Implement */

	return FALSE;
	}

	#endif

	static void
	g_winhttp_file_file_iface_init (GFileIface *iface)
	{
	iface->dup = g_winhttp_file_dup;
	iface->hash = g_winhttp_file_hash;
	iface->equal = g_winhttp_file_equal;
	iface->is_native = g_winhttp_file_is_native;
	iface->has_uri_scheme = g_winhttp_file_has_uri_scheme;
	iface->get_uri_scheme = g_winhttp_file_get_uri_scheme;
	iface->get_basename = g_winhttp_file_get_basename;
	iface->get_path = g_winhttp_file_get_path;
	iface->get_uri = g_winhttp_file_get_uri;
	iface->get_parse_name = g_winhttp_file_get_parse_name;
	iface->get_parent = g_winhttp_file_get_parent;
	iface->prefix_matches = g_winhttp_file_prefix_matches;
	iface->get_relative_path = g_winhttp_file_get_relative_path;
	iface->resolve_relative_path = g_winhttp_file_resolve_relative_path;
	iface->get_child_for_display_name = g_winhttp_file_get_child_for_display_name;
	iface->set_display_name = g_winhttp_file_set_display_name;
	iface->query_info = g_winhttp_file_query_info;
	iface->read_fn = g_winhttp_file_read;
	iface->create = g_winhttp_file_create;
	#if 0
	iface->replace = g_winhttp_file_replace;
	iface->delete_file = g_winhttp_file_delete;
	iface->make_directory = g_winhttp_file_make_directory;
	iface->copy = g_winhttp_file_copy;
	iface->move = g_winhttp_file_move;
	#endif
	}