summaryrefslogtreecommitdiff
path: root/frontends/beos/fetch_rsrc.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'frontends/beos/fetch_rsrc.cpp')
-rw-r--r--frontends/beos/fetch_rsrc.cpp396
1 files changed, 396 insertions, 0 deletions
diff --git a/frontends/beos/fetch_rsrc.cpp b/frontends/beos/fetch_rsrc.cpp
new file mode 100644
index 000000000..b771f7b2d
--- /dev/null
+++ b/frontends/beos/fetch_rsrc.cpp
@@ -0,0 +1,396 @@
+/*
+ * Copyright 2008 François Revol <mmu_man@users.sourceforge.net>
+ * 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/>.
+ */
+
+/* rsrc: URL handling. */
+
+#define __STDBOOL_H__ 1
+#include <stdlib.h>
+#include <assert.h>
+#include <errno.h>
+#include <stdbool.h>
+#include <string.h>
+#include <strings.h>
+#include <time.h>
+#include <sys/select.h>
+#include <sys/stat.h>
+#include <sys/utsname.h>
+#include <curl/curl.h> /* for URL unescaping functions */
+extern "C" {
+#include "utils/config.h"
+#include "content/fetch.h"
+#include "content/fetchers.h"
+#include "content/urldb.h"
+#include "utils/nsoption.h"
+#include "utils/log.h"
+#include "utils/messages.h"
+#include "utils/utils.h"
+#include "utils/ring.h"
+#include "utils/base64.h"
+}
+#include "beos/fetch_rsrc.h"
+#include "beos/filetype.h"
+#include "beos/gui.h"
+
+#include <image.h>
+#include <Resources.h>
+#include <String.h>
+
+struct fetch_rsrc_context {
+ struct fetch *parent_fetch;
+ char *name;
+ char *url;
+ char *mimetype;
+ char *data;
+ size_t datalen;
+
+ bool aborted;
+ bool locked;
+
+ struct fetch_rsrc_context *r_next, *r_prev;
+};
+
+static struct fetch_rsrc_context *ring = NULL;
+
+BResources *gAppResources = NULL;
+
+static bool fetch_rsrc_initialise(lwc_string *scheme)
+{
+ LOG("fetch_rsrc_initialise called for %s", lwc_string_data(scheme));
+ return true;
+}
+
+static void fetch_rsrc_finalise(lwc_string *scheme)
+{
+ LOG("fetch_rsrc_finalise called for %s", lwc_string_data(scheme));
+}
+
+static bool fetch_rsrc_can_fetch(const nsurl *url)
+{
+ return true;
+}
+
+static void *fetch_rsrc_setup(struct fetch *parent_fetch, nsurl *url,
+ bool only_2xx, bool downgrade_tls, const char *post_urlenc,
+ const struct fetch_multipart_data *post_multipart,
+ const char **headers)
+{
+ struct fetch_rsrc_context *ctx;
+ ctx = (struct fetch_rsrc_context *)calloc(1, sizeof(*ctx));
+
+ if (ctx == NULL)
+ return NULL;
+
+ ctx->parent_fetch = parent_fetch;
+ /* TODO: keep as nsurl to avoid copy */
+ ctx->url = (char *)malloc(nsurl_length(url) + 1);
+
+ if (ctx->url == NULL) {
+ free(ctx);
+ return NULL;
+ }
+ memcpy(ctx->url, nsurl_access(url), nsurl_length(url) + 1);
+
+ RING_INSERT(ring, ctx);
+
+ return ctx;
+}
+
+static bool fetch_rsrc_start(void *ctx)
+{
+ return true;
+}
+
+static void fetch_rsrc_free(void *ctx)
+{
+ struct fetch_rsrc_context *c = (struct fetch_rsrc_context *)ctx;
+
+ free(c->name);
+ free(c->url);
+ free(c->data);
+ free(c->mimetype);
+ RING_REMOVE(ring, c);
+ free(ctx);
+}
+
+static void fetch_rsrc_abort(void *ctx)
+{
+ struct fetch_rsrc_context *c = (struct fetch_rsrc_context *)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_rsrc_send_callback(const fetch_msg *msg,
+ struct fetch_rsrc_context *c)
+{
+ c->locked = true;
+ fetch_send_callback(msg, c->parent_fetch);
+ c->locked = false;
+}
+
+static bool fetch_rsrc_process(struct fetch_rsrc_context *c)
+{
+ fetch_msg msg;
+ char *params;
+ char *at = NULL;
+ char *slash;
+ char *comma = NULL;
+ char *unescaped;
+ uint32 type = 'data'; // default for embeded files
+ int32 id = 0;
+
+ /* format of a rsrc: URL is:
+ * rsrc://[TYPE][@NUM]/name[,mime]
+ */
+
+ LOG("*** Processing %s", c->url);
+
+ if (strlen(c->url) < 7) {
+ /* 7 is the minimum possible length (rsrc://) */
+ msg.type = FETCH_ERROR;
+ msg.data.error = "Malformed rsrc: URL";
+ fetch_rsrc_send_callback(&msg, c);
+ return false;
+ }
+
+ /* skip the rsrc: part */
+ params = c->url + sizeof("rsrc://") - 1;
+
+ /* find the slash */
+ if ( (slash = strchr(params, '/')) == NULL) {
+ msg.type = FETCH_ERROR;
+ msg.data.error = "Malformed rsrc: URL";
+ fetch_rsrc_send_callback(&msg, c);
+ return false;
+ }
+
+ // doesn't exist in the filesystem but we should hit the internal types.
+ c->mimetype = strdup(fetch_filetype(slash));
+ c->name = strdup(slash + 1);
+
+ if (c->mimetype == NULL) {
+ msg.type = FETCH_ERROR;
+ msg.data.error =
+ "Unable to allocate memory for mimetype in rsrc: URL";
+ fetch_rsrc_send_callback(&msg, c);
+ return false;
+ }
+
+ if (params[0] != '/') {
+ uint8 c1, c2, c3, c4;
+ if (sscanf(params, "%c%c%c%c", &c1, &c2, &c3, &c4) > 3) {
+ type = c1 << 24 | c2 << 16 | c3 << 8 | c4;
+ LOG("fetch_rsrc: type:%4.4s\n", (char *)&type);
+ }
+ }
+
+ LOG("fetch_rsrc: 0x%08lx, %ld, '%s'\n", type, id, c->name);
+
+ bool found;
+ if (id)
+ found = gAppResources->HasResource(type, id);
+ else
+ found = gAppResources->HasResource(type, c->name);
+ if (!found) {
+ BString error("Cannot locate resource: ");
+ if (id)
+ error << id;
+ else
+ error << c->name;
+ msg.type = FETCH_ERROR;
+ msg.data.error = error.String();
+ fetch_rsrc_send_callback(&msg, c);
+ return false;
+ }
+
+ size_t len;
+ const void *data;
+ if (id)
+ data = gAppResources->LoadResource(type, id, &len);
+ else
+ data = gAppResources->LoadResource(type, c->name, &len);
+
+ if (!data) {
+ msg.type = FETCH_ERROR;
+ msg.data.error = "Cannot load rsrc: URL";
+ fetch_rsrc_send_callback(&msg, c);
+ return false;
+ }
+
+ c->datalen = len;
+ c->data = (char *)malloc(c->datalen);
+ if (c->data == NULL) {
+ msg.type = FETCH_ERROR;
+ msg.data.error = "Unable to allocate memory for rsrc: URL";
+ fetch_rsrc_send_callback(&msg, c);
+ return false;
+ }
+ memcpy(c->data, data, c->datalen);
+
+ return true;
+}
+
+static void fetch_rsrc_poll(lwc_string *scheme)
+{
+ fetch_msg msg;
+ struct fetch_rsrc_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_rsrc_process(c) == true) {
+ char header[64];
+
+ fetch_set_http_code(c->parent_fetch, 200);
+ LOG("setting rsrc: 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_rsrc_send_callback().
+ */
+ snprintf(header, sizeof header, "Content-Type: %s",
+ c->mimetype);
+ msg.type = FETCH_HEADER;
+ msg.data.header_or_data.buf = (const uint8_t *) header;
+ msg.data.header_or_data.len = strlen(header);
+ fetch_rsrc_send_callback(&msg, c);
+
+ snprintf(header, sizeof header, "Content-Length: %zd",
+ c->datalen);
+ msg.type = FETCH_HEADER;
+ msg.data.header_or_data.buf = (const uint8_t *) header;
+ msg.data.header_or_data.len = strlen(header);
+ fetch_rsrc_send_callback(&msg, c);
+
+ if (!c->aborted) {
+ msg.type = FETCH_DATA;
+ msg.data.header_or_data.buf = (const uint8_t *) c->data;
+ msg.data.header_or_data.len = c->datalen;
+ fetch_rsrc_send_callback(&msg, c);
+ }
+ if (!c->aborted) {
+ msg.type = FETCH_FINISHED;
+ fetch_rsrc_send_callback(&msg, c);
+ }
+ } else {
+ LOG("Processing of %s failed!", c->url);
+
+ /* Ensure that we're unlocked here. If we aren't,
+ * then fetch_rsrc_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);
+}
+
+/* BAppFileInfo is supposed to find the app's resources for us,
+ * but this won't work if we ever want to be used as a replicant.
+ * This trick should work regardless,
+ */
+static int find_app_resources()
+{
+ char path[B_PATH_NAME_LENGTH];
+ if (nsbeos_find_app_path(path) < B_OK)
+ return B_ERROR;
+ //fprintf(stderr, "loading resources from '%s'\n", path);
+
+ BFile file(path, B_READ_ONLY);
+ if (file.InitCheck() < 0)
+ return file.InitCheck();
+ gAppResources = new BResources;
+ status_t err;
+ err = gAppResources->SetTo(&file);
+ if (err >= B_OK)
+ return B_OK;
+ delete gAppResources;
+ gAppResources = NULL;
+ return err;
+}
+
+BResources *get_app_resources()
+{
+ return gAppResources;
+}
+
+void fetch_rsrc_register(void)
+{
+ lwc_string *scheme;
+ int err;
+ nserror ret;
+
+ const struct fetcher_operation_table fetcher_ops_rsrc = {
+ fetch_rsrc_initialise,
+ fetch_rsrc_can_fetch,
+ fetch_rsrc_setup,
+ fetch_rsrc_start,
+ fetch_rsrc_abort,
+ fetch_rsrc_free,
+ fetch_rsrc_poll,
+ fetch_rsrc_finalise
+ };
+
+ err = find_app_resources();
+
+ if (err < B_OK) {
+ beos_warn_user("Resources", strerror(err));
+ return;
+ }
+
+ if (lwc_intern_string("rsrc", SLEN("rsrc"), &scheme) != lwc_error_ok) {
+ die("Failed to initialise the fetch module "
+ "(couldn't intern \"rsrc\").");
+ }
+
+ ret = fetcher_add(scheme, &fetcher_ops_rsrc);
+ if (ret != NSERROR_OK) {
+ die("unable to add rsrc fetcher.");
+ }
+}
+
+void fetch_rsrc_unregister(void)
+{
+ delete gAppResources;
+ gAppResources = NULL;
+}