summaryrefslogtreecommitdiff
path: root/content/fetchers/fetch_data.c
diff options
context:
space:
mode:
authorVincent Sanders <vince@netsurf-browser.org>2011-02-15 23:18:10 +0000
committerVincent Sanders <vince@netsurf-browser.org>2011-02-15 23:18:10 +0000
commitfa98e3d76ada300d69e04816bfe15b2d560c9f7d (patch)
treeb044b5053a013838723e5206ea98d2cf1660409d /content/fetchers/fetch_data.c
parent4f47cad962ab9cb49db5f249b740cdff9ba40b20 (diff)
downloadnetsurf-fa98e3d76ada300d69e04816bfe15b2d560c9f7d.tar.gz
netsurf-fa98e3d76ada300d69e04816bfe15b2d560c9f7d.tar.bz2
add about: fetcher
rename fetchers to be more sensible svn path=/trunk/netsurf/; revision=11692
Diffstat (limited to 'content/fetchers/fetch_data.c')
-rw-r--r--content/fetchers/fetch_data.c310
1 files changed, 0 insertions, 310 deletions
diff --git a/content/fetchers/fetch_data.c b/content/fetchers/fetch_data.c
deleted file mode 100644
index a58c971bf..000000000
--- a/content/fetchers/fetch_data.c
+++ /dev/null
@@ -1,310 +0,0 @@
-/*
- * Copyright 2008 Rob Kendrick <rjek@netsurf-browser.org>
- *
- * This file is part of NetSurf.
- *
- * NetSurf 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; version 2 of the License.
- *
- * NetSurf 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, see <http://www.gnu.org/licenses/>.
- */
-
-/* data: URL handling. See http://tools.ietf.org/html/rfc2397 */
-
-#include <assert.h>
-#include <errno.h>
-#include <stdbool.h>
-#include <string.h>
-#include <strings.h>
-#include <time.h>
-
-#include <curl/curl.h> /* for URL unescaping functions */
-
-#include "utils/config.h"
-#include "content/fetch.h"
-#include "content/fetchers/fetch_data.h"
-#include "content/urldb.h"
-#include "desktop/netsurf.h"
-#include "desktop/options.h"
-#include "utils/log.h"
-#include "utils/messages.h"
-#include "utils/url.h"
-#include "utils/utils.h"
-#include "utils/ring.h"
-#include "utils/base64.h"
-
-struct fetch_data_context {
- struct fetch *parent_fetch;
- char *url;
- char *mimetype;
- char *data;
- size_t datalen;
- bool base64;
-
- bool aborted;
- bool locked;
-
- struct fetch_data_context *r_next, *r_prev;
-};
-
-static struct fetch_data_context *ring = NULL;
-
-static CURL *curl;
-
-static bool fetch_data_initialise(const char *scheme)
-{
- LOG(("fetch_data_initialise called for %s", scheme));
- if ( (curl = curl_easy_init()) == NULL)
- return false;
- else
- return true;
-}
-
-static void fetch_data_finalise(const char *scheme)
-{
- LOG(("fetch_data_finalise called for %s", scheme));
- curl_easy_cleanup(curl);
-}
-
-static void *fetch_data_setup(struct fetch *parent_fetch, const char *url,
- bool only_2xx, const char *post_urlenc,
- const struct fetch_multipart_data *post_multipart,
- const char **headers)
-{
- struct fetch_data_context *ctx = calloc(1, sizeof(*ctx));
-
- if (ctx == NULL)
- return NULL;
-
- ctx->parent_fetch = parent_fetch;
- ctx->url = strdup(url);
-
- if (ctx->url == NULL) {
- free(ctx);
- return NULL;
- }
-
- RING_INSERT(ring, ctx);
-
- return ctx;
-}
-
-static bool fetch_data_start(void *ctx)
-{
- return true;
-}
-
-static void fetch_data_free(void *ctx)
-{
- struct fetch_data_context *c = ctx;
-
- free(c->url);
- free(c->data);
- free(c->mimetype);
- RING_REMOVE(ring, c);
- free(ctx);
-}
-
-static void fetch_data_abort(void *ctx)
-{
- struct fetch_data_context *c = ctx;
-
- /* To avoid the poll loop having to deal with the fetch context
- * disappearing from under it, we simply flag the abort here.
- * The poll loop itself will perform the appropriate cleanup.
- */
- c->aborted = true;
-}
-
-static void fetch_data_send_callback(fetch_msg msg,
- struct fetch_data_context *c, const void *data,
- unsigned long size, fetch_error_code errorcode)
-{
- c->locked = true;
- fetch_send_callback(msg, c->parent_fetch, data, size, errorcode);
- c->locked = false;
-}
-
-static bool fetch_data_process(struct fetch_data_context *c)
-{
- char *params;
- char *comma;
- char *unescaped;
- int templen;
-
- /* format of a data: URL is:
- * data:[<mimetype>][;base64],<data>
- * The mimetype is optional. If it is missing, the , before the
- * data must still be there.
- */
-
- LOG(("*** Processing %s", c->url));
-
- if (strlen(c->url) < 6) {
- /* 6 is the minimum possible length (data:,) */
- fetch_data_send_callback(FETCH_ERROR, c,
- "Malformed data: URL", 0, FETCH_ERROR_URL);
- return false;
- }
-
- /* skip the data: part */
- params = c->url + SLEN("data:");
-
- /* find the comma */
- if ( (comma = strchr(params, ',')) == NULL) {
- fetch_data_send_callback(FETCH_ERROR, c,
- "Malformed data: URL", 0, FETCH_ERROR_URL);
- return false;
- }
-
- if (params[0] == ',') {
- /* there is no mimetype here, assume text/plain */
- c->mimetype = strdup("text/plain;charset=US-ASCII");
- } else {
- /* make a copy of everything between data: and the comma */
- c->mimetype = strndup(params, comma - params);
- }
-
- if (c->mimetype == NULL) {
- fetch_data_send_callback(FETCH_ERROR, c,
- "Unable to allocate memory for mimetype in data: URL",
- 0, FETCH_ERROR_MEMORY);
- return false;
- }
-
- if (strcmp(c->mimetype + strlen(c->mimetype) - 7, ";base64") == 0) {
- c->base64 = true;
- c->mimetype[strlen(c->mimetype) - 7] = '\0';
- } else {
- c->base64 = false;
- }
-
- /* we URL unescape the data first, just incase some insane page
- * decides to nest URL and base64 encoding. Like, say, Acid2.
- */
- templen = c->datalen;
- unescaped = curl_easy_unescape(curl, comma + 1, 0, &templen);
- c->datalen = templen;
- if (unescaped == NULL) {
- fetch_data_send_callback(FETCH_ERROR, c,
- "Unable to URL decode data: URL", 0,
- FETCH_ERROR_ENCODING);
- return false;
- }
-
- if (c->base64) {
- c->data = malloc(c->datalen); /* safe: always gets smaller */
- if (base64_decode(unescaped, c->datalen, c->data,
- &(c->datalen)) == false) {
- fetch_data_send_callback(FETCH_ERROR, c,
- "Unable to Base64 decode data: URL", 0,
- FETCH_ERROR_ENCODING);
- curl_free(unescaped);
- return false;
- }
- } else {
- c->data = malloc(c->datalen);
- if (c->data == NULL) {
- fetch_data_send_callback(FETCH_ERROR, c,
- "Unable to allocate memory for data: URL", 0,
- FETCH_ERROR_MEMORY);
- curl_free(unescaped);
- return false;
- }
- memcpy(c->data, unescaped, c->datalen);
- }
-
- curl_free(unescaped);
-
- return true;
-}
-
-static void fetch_data_poll(const char *scheme)
-{
- struct fetch_data_context *c, *next;
-
- if (ring == NULL) return;
-
- /* Iterate over ring, processing each pending fetch */
- c = ring;
- do {
- /* Take a copy of the next pointer as we may destroy
- * the ring item we're currently processing */
- next = c->r_next;
-
- /* Ignore fetches that have been flagged as locked.
- * This allows safe re-entrant calls to this function.
- * Re-entrancy can occur if, as a result of a callback,
- * the interested party causes fetch_poll() to be called
- * again.
- */
- if (c->locked == true) {
- continue;
- }
-
- /* Only process non-aborted fetches */
- if (!c->aborted && fetch_data_process(c) == true) {
- char header[64];
-
- fetch_set_http_code(c->parent_fetch, 200);
- LOG(("setting data: MIME type to %s, length to %zd",
- c->mimetype, c->datalen));
- /* Any callback can result in the fetch being aborted.
- * Therefore, we _must_ check for this after _every_
- * call to fetch_data_send_callback().
- */
- snprintf(header, sizeof header, "Content-Type: %s",
- c->mimetype);
- fetch_data_send_callback(FETCH_HEADER, c, header,
- strlen(header), FETCH_ERROR_NO_ERROR);
-
- snprintf(header, sizeof header, "Content-Length: %zd",
- c->datalen);
- fetch_data_send_callback(FETCH_HEADER, c, header,
- strlen(header), FETCH_ERROR_NO_ERROR);
-
- if (!c->aborted) {
- fetch_data_send_callback(FETCH_DATA,
- c, c->data, c->datalen,
- FETCH_ERROR_NO_ERROR);
- }
- if (!c->aborted) {
- fetch_data_send_callback(FETCH_FINISHED,
- c, 0, 0, FETCH_ERROR_NO_ERROR);
- }
- } else {
- LOG(("Processing of %s failed!", c->url));
-
- /* Ensure that we're unlocked here. If we aren't,
- * then fetch_data_process() is broken.
- */
- assert(c->locked == false);
- }
-
- fetch_remove_from_queues(c->parent_fetch);
- fetch_free(c->parent_fetch);
-
- /* Advance to next ring entry, exiting if we've reached
- * the start of the ring or the ring has become empty
- */
- } while ( (c = next) != ring && ring != NULL);
-}
-
-void fetch_data_register(void)
-{
- fetch_add_fetcher("data",
- fetch_data_initialise,
- fetch_data_setup,
- fetch_data_start,
- fetch_data_abort,
- fetch_data_free,
- fetch_data_poll,
- fetch_data_finalise);
-}