1 files changed, 363 insertions, 0 deletions
diff --git a/data/lighttpd/lighttpd-1.4.53/src/mod_evhost.c b/data/lighttpd/lighttpd-1.4.53/src/mod_evhost.c
new file mode 100644
index 000000000..ae7076970
--- /dev/null
+++ b/data/lighttpd/lighttpd-1.4.53/src/mod_evhost.c
@@ -0,0 +1,363 @@
+#include "first.h"
+
+#include "base.h"
+#include "plugin.h"
+#include "log.h"
+#include "stat_cache.h"
+
+#include <stdlib.h>
+#include <string.h>
+#include <errno.h>
+
+typedef struct {
+	/* unparsed pieces */
+	buffer *path_pieces_raw;
+
+	/* pieces for path creation */
+	size_t len;
+	buffer **path_pieces;
+} plugin_config;
+
+typedef struct {
+	PLUGIN_DATA;
+	buffer *tmp_buf;
+
+	plugin_config **config_storage;
+	plugin_config conf;
+} plugin_data;
+
+INIT_FUNC(mod_evhost_init) {
+	plugin_data *p;
+
+	p = calloc(1, sizeof(*p));
+
+	p->tmp_buf = buffer_init();
+
+	return p;
+}
+
+FREE_FUNC(mod_evhost_free) {
+	plugin_data *p = p_d;
+
+	UNUSED(srv);
+
+	if (!p) return HANDLER_GO_ON;
+
+	if (p->config_storage) {
+		size_t i;
+		for (i = 0; i < srv->config_context->used; i++) {
+			plugin_config *s = p->config_storage[i];
+
+			if (NULL == s) continue;
+
+			if(s->path_pieces) {
+				size_t j;
+				for (j = 0; j < s->len; j++) {
+					buffer_free(s->path_pieces[j]);
+				}
+
+				free(s->path_pieces);
+			}
+
+			buffer_free(s->path_pieces_raw);
+
+			free(s);
+		}
+		free(p->config_storage);
+	}
+
+	buffer_free(p->tmp_buf);
+
+	free(p);
+
+	return HANDLER_GO_ON;
+}
+
+static int mod_evhost_parse_pattern(plugin_config *s) {
+	char *ptr = s->path_pieces_raw->ptr,*pos;
+
+	s->path_pieces = NULL;
+
+	for(pos=ptr;*ptr;ptr++) {
+		if(*ptr == '%') {
+			size_t len;
+			s->path_pieces = realloc(s->path_pieces,(s->len+2) * sizeof(*s->path_pieces));
+			s->path_pieces[s->len] = buffer_init();
+			s->path_pieces[s->len+1] = buffer_init();
+
+			/* "%%" "%_" "%x" "%{x.y}" where x and y are *single digit* 0 - 9 */
+			if (ptr[1] == '%' || ptr[1] == '_' || light_isdigit(ptr[1])) {
+				len = 2;
+			} else if (ptr[1] == '{') {
+				if (!light_isdigit(ptr[2])) return -1;
+				if (ptr[3] == '.') {
+					if (!light_isdigit(ptr[4])) return -1;
+					if (ptr[5] != '}') return -1;
+					len = 6;
+				} else if (ptr[3] == '}') {
+					len = 4;
+				} else {
+					return -1;
+				}
+			} else {
+				return -1;
+			}
+
+			buffer_copy_string_len(s->path_pieces[s->len],pos,ptr-pos);
+			pos = ptr + len;
+
+			buffer_copy_string_len(s->path_pieces[s->len+1],ptr,len);
+			ptr += len - 1; /*(ptr++ in for() loop)*/
+
+			s->len += 2;
+		}
+	}
+
+	if(*pos != '\0') {
+		s->path_pieces = realloc(s->path_pieces,(s->len+1) * sizeof(*s->path_pieces));
+		s->path_pieces[s->len] = buffer_init();
+
+		buffer_copy_string_len(s->path_pieces[s->len],pos,ptr-pos);
+
+		s->len += 1;
+	}
+
+	return 0;
+}
+
+SETDEFAULTS_FUNC(mod_evhost_set_defaults) {
+	plugin_data *p = p_d;
+	size_t i;
+
+	/**
+	 *
+	 * #
+	 * # define a pattern for the host url finding
+	 * # %% => % sign
+	 * # %0 => domain name + tld
+	 * # %1 => tld
+	 * # %2 => domain name without tld
+	 * # %3 => subdomain 1 name
+	 * # %4 => subdomain 2 name
+	 * # %_ => fqdn (without port info)
+	 * #
+	 * evhost.path-pattern = "/home/ckruse/dev/www/%3/htdocs/"
+	 *
+	 */
+
+	config_values_t cv[] = {
+		{ "evhost.path-pattern",            NULL, T_CONFIG_STRING, T_CONFIG_SCOPE_CONNECTION },
+		{ NULL,                             NULL, T_CONFIG_UNSET, T_CONFIG_SCOPE_UNSET }
+	};
+
+	if (!p) return HANDLER_ERROR;
+
+	p->config_storage = calloc(1, srv->config_context->used * sizeof(plugin_config *));
+
+	for (i = 0; i < srv->config_context->used; i++) {
+		data_config const* config = (data_config const*)srv->config_context->data[i];
+		plugin_config *s;
+
+		s = calloc(1, sizeof(plugin_config));
+		s->path_pieces_raw = buffer_init();
+		s->path_pieces     = NULL;
+		s->len             = 0;
+
+		cv[0].destination = s->path_pieces_raw;
+
+		p->config_storage[i] = s;
+
+		if (0 != config_insert_values_global(srv, config->value, cv, i == 0 ? T_CONFIG_SCOPE_SERVER : T_CONFIG_SCOPE_CONNECTION)) {
+			return HANDLER_ERROR;
+		}
+
+		if (!buffer_string_is_empty(s->path_pieces_raw)) {
+			if (0 != mod_evhost_parse_pattern(s)) {
+				log_error_write(srv, __FILE__, __LINE__, "sb", "invalid evhost.path-pattern:", s->path_pieces_raw);
+				return HANDLER_ERROR;
+			}
+		}
+	}
+
+	return HANDLER_GO_ON;
+}
+
+/**
+ * assign the different parts of the domain to array-indezes (sub2.sub1.domain.tld)
+ * - %0 - domain.tld
+ * - %1 - tld
+ * - %2 - domain
+ * - %3 - sub1
+ * - ...
+ */
+
+static void mod_evhost_parse_host(buffer *key, array *host, buffer *authority) {
+	char *ptr = authority->ptr + buffer_string_length(authority);
+	char *colon = ptr; /* needed to filter out the colon (if exists) */
+	int first = 1;
+	int i;
+
+	/* first, find the domain + tld */
+	for(; ptr > authority->ptr; --ptr) {
+		if(*ptr == '.') {
+			if(first) first = 0;
+			else      break;
+		} else if(*ptr == ':') {
+			colon = ptr;
+			first = 1;
+		}
+	}
+
+	/* if we stopped at a dot, skip the dot */
+	if (*ptr == '.') ptr++;
+	array_insert_key_value(host, CONST_STR_LEN("%0"), ptr, colon-ptr);
+
+	/* if the : is not the start of the authority, go on parsing the hostname */
+
+	if (colon != authority->ptr) {
+		for(ptr = colon - 1, i = 1; ptr > authority->ptr; --ptr) {
+			if(*ptr == '.') {
+				if (ptr != colon - 1) {
+					/* is something between the dots */
+					buffer_copy_string_len(key, CONST_STR_LEN("%"));
+					buffer_append_int(key, i++);
+					array_insert_key_value(host, CONST_BUF_LEN(key), ptr+1, colon-ptr-1);
+				}
+				colon = ptr;
+			}
+		}
+
+		/* if the . is not the first charactor of the hostname */
+		if (colon != ptr) {
+			buffer_copy_string_len(key, CONST_STR_LEN("%"));
+			buffer_append_int(key, i /* ++ */);
+			array_insert_key_value(host, CONST_BUF_LEN(key), ptr, colon-ptr);
+		}
+	}
+}
+
+#define PATCH(x) \
+	p->conf.x = s->x;
+static int mod_evhost_patch_connection(server *srv, connection *con, plugin_data *p) {
+	size_t i, j;
+	plugin_config *s = p->config_storage[0];
+
+	PATCH(path_pieces);
+	PATCH(len);
+
+	/* skip the first, the global context */
+	for (i = 1; i < srv->config_context->used; i++) {
+		data_config *dc = (data_config *)srv->config_context->data[i];
+		s = p->config_storage[i];
+
+		/* condition didn't match */
+		if (!config_check_cond(srv, con, dc)) continue;
+
+		/* merge config */
+		for (j = 0; j < dc->value->used; j++) {
+			data_unset *du = dc->value->data[j];
+
+			if (buffer_is_equal_string(du->key, CONST_STR_LEN("evhost.path-pattern"))) {
+				PATCH(path_pieces);
+				PATCH(len);
+			}
+		}
+	}
+
+	return 0;
+}
+#undef PATCH
+
+
+static void mod_evhost_build_doc_root_path(buffer *b, array *parsed_host, buffer *authority, buffer **path_pieces, const size_t npieces) {
+	array_reset_data_strings(parsed_host);
+	mod_evhost_parse_host(b, parsed_host, authority);
+	buffer_clear(b);
+
+	for (size_t i = 0; i < npieces; ++i) {
+		const char *ptr = path_pieces[i]->ptr;
+		if (*ptr == '%') {
+			data_string *ds;
+
+			if (*(ptr+1) == '%') {
+				/* %% */
+				buffer_append_string_len(b, CONST_STR_LEN("%"));
+			} else if (*(ptr+1) == '_' ) {
+				/* %_ == full hostname */
+				char *colon = strchr(authority->ptr, ':');
+
+				if(colon == NULL) {
+					buffer_append_string_buffer(b, authority); /* adds fqdn */
+				} else {
+					/* strip the port out of the authority-part of the URI scheme */
+					buffer_append_string_len(b, authority->ptr, colon - authority->ptr); /* adds fqdn */
+				}
+			} else if (ptr[1] == '{' ) {
+				char s[3] = "% ";
+				s[1] = ptr[2]; /*(assumes single digit before '.', and, optionally, '.' and single digit after '.')*/
+				if (NULL != (ds = (data_string *)array_get_element_klen(parsed_host, s, 2))) {
+					if (ptr[3] != '.' || ptr[4] == '0') {
+						buffer_append_string_buffer(b, ds->value);
+					} else {
+						if ((size_t)(ptr[4]-'0') <= buffer_string_length(ds->value)) {
+							buffer_append_string_len(b, ds->value->ptr+(ptr[4]-'0')-1, 1);
+						}
+					}
+				} else {
+					/* unhandled %-sequence */
+				}
+			} else if (NULL != (ds = (data_string *)array_get_element_klen(parsed_host, CONST_BUF_LEN(path_pieces[i])))) {
+				buffer_append_string_buffer(b, ds->value);
+			} else {
+				/* unhandled %-sequence */
+			}
+		} else {
+			buffer_append_string_buffer(b, path_pieces[i]);
+		}
+	}
+
+	buffer_append_slash(b);
+}
+
+static handler_t mod_evhost_uri_handler(server *srv, connection *con, void *p_d) {
+	plugin_data *p = p_d;
+	stat_cache_entry *sce = NULL;
+
+	/* not authority set */
+	if (buffer_string_is_empty(con->uri.authority)) return HANDLER_GO_ON;
+
+	mod_evhost_patch_connection(srv, con, p);
+
+	/* missing even default(global) conf */
+	if (0 == p->conf.len) {
+		return HANDLER_GO_ON;
+	}
+
+	mod_evhost_build_doc_root_path(p->tmp_buf, srv->split_vals, con->uri.authority, p->conf.path_pieces, p->conf.len);
+
+	if (HANDLER_ERROR == stat_cache_get_entry(srv, con, p->tmp_buf, &sce)) {
+		log_error_write(srv, __FILE__, __LINE__, "sb", strerror(errno), p->tmp_buf);
+	} else if(!S_ISDIR(sce->st.st_mode)) {
+		log_error_write(srv, __FILE__, __LINE__, "sb", "not a directory:", p->tmp_buf);
+	} else {
+		buffer_copy_buffer(con->physical.doc_root, p->tmp_buf);
+	}
+
+	return HANDLER_GO_ON;
+}
+
+int mod_evhost_plugin_init(plugin *p);
+int mod_evhost_plugin_init(plugin *p) {
+	p->version     = LIGHTTPD_VERSION_ID;
+	p->name                    = buffer_init_string("evhost");
+	p->init                    = mod_evhost_init;
+	p->set_defaults            = mod_evhost_set_defaults;
+	p->handle_docroot          = mod_evhost_uri_handler;
+	p->cleanup                 = mod_evhost_free;
+
+	p->data                    = NULL;
+
+	return 0;
+}
+
+/* eof */