diff options
author | Vincent Sanders <vince@netsurf-browser.org> | 2011-02-15 23:18:10 +0000 |
---|---|---|
committer | Vincent Sanders <vince@netsurf-browser.org> | 2011-02-15 23:18:10 +0000 |
commit | fa98e3d76ada300d69e04816bfe15b2d560c9f7d (patch) | |
tree | b044b5053a013838723e5206ea98d2cf1660409d /content/fetchers/fetch_data.c | |
parent | 4f47cad962ab9cb49db5f249b740cdff9ba40b20 (diff) | |
download | netsurf-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.c | 310 |
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); -} |