2 * Copyright (C) 2009-2010 Andy Spencer <andy753421@gmail.com>
4 * This program is free software: you can redistribute it and/or modify
5 * it under the terms of the GNU General Public License as published by
6 * the Free Software Foundation, either version 3 of the License, or
7 * (at your option) any later version.
9 * This program is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 * GNU General Public License for more details.
14 * You should have received a copy of the GNU General Public License
15 * along with this program. If not, see <http://www.gnu.org/licenses/>.
20 #include <glib/gstdio.h>
21 #include <libsoup/soup.h>
25 GisHttp *gis_http_new(const gchar *prefix)
27 g_debug("GisHttp: new - %s", prefix);
28 GisHttp *self = g_new0(GisHttp, 1);
29 self->soup = soup_session_sync_new();
30 self->prefix = g_strdup(prefix);
31 g_object_set(self->soup, "user-agent", PACKAGE_STRING, NULL);
35 void gis_http_free(GisHttp *self)
37 g_debug("GisHttp: free - %s", self->prefix);
38 soup_session_abort(self->soup);
39 g_object_unref(self->soup);
44 /* For passing data to the chunck callback */
48 GisChunkCallback callback;
53 * Append data to the file and call the users callback if they supplied one.
55 static void _chunk_cb(SoupMessage *message, SoupBuffer *chunk, gpointer _info)
57 struct _cache_info *info = _info;
59 if (!SOUP_STATUS_IS_SUCCESSFUL(message->status_code)) {
60 g_warning("GisHttp: _chunk_cb - soup failed with %d",
61 message->status_code);
65 if (!fwrite(chunk->data, chunk->length, 1, info->fp))
66 g_error("GisHttp: _chunk_cb - Unable to write data");
69 goffset cur = ftell(info->fp);
70 goffset st=0, end=0, total=0;
71 soup_message_headers_get_content_range(message->response_headers,
73 info->callback(info->path, cur, total, info->user_data);
77 /* TODO: use .part extentions and continue even when using GIS_ONCE */
78 gchar *gis_http_fetch(GisHttp *self, const gchar *uri, const char *local,
79 GisCacheType mode, GisChunkCallback callback, gpointer user_data)
81 g_debug("GisHttp: fetch - %.20s... >> %s/%s mode=%d",
82 uri, self->prefix, local, mode);
84 gchar *path = g_build_filename(g_get_user_cache_dir(), PACKAGE,
85 self->prefix, local, NULL);
87 /* Unlink the file if we're refreshing it */
88 if (mode == GIS_REFRESH)
91 /* Do the cache if necessasairy */
92 if (!(mode == GIS_ONCE && g_file_test(path, G_FILE_TEST_EXISTS)) &&
94 g_debug("GisHttp: do_cache - Caching file %s", local);
96 /* Open the file for writting */
97 FILE *fp = fopen_p(path, "a");
100 struct _cache_info info = {
103 .callback = callback,
104 .user_data = user_data,
107 /* Download the file */
108 SoupMessage *message = soup_message_new("GET", uri);
110 g_error("message is null, cannot parse uri");
111 g_signal_connect(message, "got-chunk", G_CALLBACK(_chunk_cb), &info);
112 soup_message_headers_set_range(message->request_headers, ftell(fp), -1);
113 soup_session_send_message(self->soup, message);
116 if (message->status_code == 416) {
117 /* Range unsatisfiable, file already complete */
118 } else if (!SOUP_STATUS_IS_SUCCESSFUL(message->status_code))
119 g_warning("GisHttp: done_cb - error copying file, status=%d\n"
122 message->status_code, uri, path);
125 /* TODO: free everything.. */