added read-only WebDAV support

git-svn-id: svn://svn.lighttpd.net/lighttpd/branches/lighttpd-merge-1.4.x@577 152afb58-edef-0310-8abb-c4023f1b3aa9

5 files changed, 342 insertions, 8 deletions

diff --git a/src/Makefile.am b/src/Makefile.am
index efebf6be..96254c7a 100644
--- a/src/Makefile.am
+++ b/src/Makefile.am
@@ -68,6 +68,11 @@ src += $(common_src)
 common_libadd = 
 endif
 
+lib_LTLIBRARIES += mod_webdav.la
+mod_webdav_la_SOURCES = mod_webdav.c
+mod_webdav_la_LDFLAGS = -module -export-dynamic -avoid-version -no-undefined
+mod_webdav_la_LIBADD = $(common_libadd)
+
 lib_LTLIBRARIES += mod_cml.la
 mod_cml_la_SOURCES = mod_cml.c mod_cml_lua.c mod_cml_funcs.c
 mod_cml_la_LDFLAGS = -module -export-dynamic -avoid-version -no-undefined
diff --git a/src/connections.c b/src/connections.c
index 595d417f..997b2c66 100644
--- a/src/connections.c
+++ b/src/connections.c
@@ -310,6 +310,7 @@ static int connection_handle_write_prepare(server *srv, connection *con) {
 			switch(con->http_status) {
 			case 400: /* bad request */
 			case 505: /* unknown protocol */
+			case 207: /* this was webdav */
 				break;
 			default:
 				con->http_status = 501;
@@ -392,6 +393,7 @@ static int connection_handle_write_prepare(server *srv, connection *con) {
 			response_header_overwrite(srv, con, CONST_STR_LEN("Content-Type"), CONST_STR_LEN("text/html"));
 		}
 		/* fall through */
+	case 207:
 	case 200: /* class: header + body */
 		                break;
 		
diff --git a/src/mod_skeleton.c b/src/mod_skeleton.c
index 7a1dddbe..2701eb4b 100644
--- a/src/mod_skeleton.c
+++ b/src/mod_skeleton.c
@@ -77,8 +77,11 @@ FREE_FUNC(mod_skeleton_free) {
 	
 	if (p->config_storage) {
 		size_t i;
+
 		for (i = 0; i < srv->config_context->used; i++) {
 			plugin_config *s = p->config_storage[i];
+
+			if (!s) continue;
 			
 			array_free(s->match);
 			
diff --git a/src/mod_webdav.c b/src/mod_webdav.c
new file mode 100644
index 00000000..7d1939ef
--- /dev/null
+++ b/src/mod_webdav.c
@@ -0,0 +1,320 @@
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <ctype.h>
+#include <stdlib.h>
+#include <string.h>
+#include <dirent.h>
+
+#include "base.h"
+#include "log.h"
+#include "buffer.h"
+#include "response.h"
+
+#include "plugin.h"
+
+#include "config.h"
+
+/**
+ * this is a webdav for a lighttpd plugin
+ *
+ * at least a very basic one. 
+ * - for now it is read-only and we only support PROPFIND
+ * 
+ */
+
+
+
+/* plugin config for all request/connections */
+
+typedef struct {
+	array *match;
+} plugin_config;
+
+typedef struct {
+	PLUGIN_DATA;
+	
+	buffer *tmp_buf;
+	
+	plugin_config **config_storage;
+	
+	plugin_config conf; 
+} plugin_data;
+
+/* init the plugin data */
+INIT_FUNC(mod_webdav_init) {
+	plugin_data *p;
+	
+	p = calloc(1, sizeof(*p));
+	
+	p->tmp_buf = buffer_init();
+	
+	return p;
+}
+
+/* detroy the plugin data */
+FREE_FUNC(mod_webdav_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];
+			
+			array_free(s->match);
+			
+			free(s);
+		}
+		free(p->config_storage);
+	}
+	
+	buffer_free(p->tmp_buf);
+	
+	free(p);
+	
+	return HANDLER_GO_ON;
+}
+
+/* handle plugin config and check values */
+
+SETDEFAULTS_FUNC(mod_webdav_set_defaults) {
+	plugin_data *p = p_d;
+	size_t i = 0;
+	
+	config_values_t cv[] = { 
+		{ "webdav.array",             NULL, T_CONFIG_ARRAY, T_CONFIG_SCOPE_CONNECTION },       /* 0 */
+		{ NULL,                         NULL, T_CONFIG_UNSET, T_CONFIG_SCOPE_UNSET }
+	};
+	
+	if (!p) return HANDLER_ERROR;
+	
+	p->config_storage = calloc(1, srv->config_context->used * sizeof(specific_config *));
+	
+	for (i = 0; i < srv->config_context->used; i++) {
+		plugin_config *s;
+		
+		s = calloc(1, sizeof(plugin_config));
+		s->match    = array_init();
+		
+		cv[0].destination = s->match;
+		
+		p->config_storage[i] = s;
+	
+		if (0 != config_insert_values_global(srv, ((data_config *)srv->config_context->data[i])->value, cv)) {
+			return HANDLER_ERROR;
+		}
+	}
+	
+	return HANDLER_GO_ON;
+}
+
+#define PATCH(x) \
+	p->conf.x = s->x;
+static int mod_webdav_patch_connection(server *srv, connection *con, plugin_data *p) {
+	size_t i, j;
+	plugin_config *s = p->config_storage[0];
+	
+	PATCH(match);
+	
+	/* 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("webdav.array"))) {
+				PATCH(match);
+			}
+		}
+	}
+	
+	return 0;
+}
+#undef PATCH
+
+URIHANDLER_FUNC(mod_webdav_uri_handler) {
+	plugin_data *p = p_d;
+	
+	UNUSED(srv);
+
+	if (con->uri.path->used == 0) return HANDLER_GO_ON;
+	
+	mod_webdav_patch_connection(srv, con, p);
+
+	switch (con->request.http_method) {
+	case HTTP_METHOD_OPTIONS:
+		response_header_overwrite(srv, con, CONST_STR_LEN("DAV"), CONST_STR_LEN("1,2"));
+		response_header_overwrite(srv, con, CONST_STR_LEN("MS-Author-Via"), CONST_STR_LEN("DAV"));
+		response_header_insert(srv, con, CONST_STR_LEN("Allow"), CONST_STR_LEN("PROPFIND"));
+		break;
+	default:
+		break;
+	}
+	
+	/* not found */
+	return HANDLER_GO_ON;
+}
+
+static int get_response_entry(server *srv, connection *con, plugin_data *p, buffer *b, const char *filename) {
+	struct stat st;
+
+	buffer_append_string(b,"<D:response xmlns:ns0=\"urn:uuid:c2f41010-65b3-11d1-a29f-00aa00c14882/\">\n");
+
+	buffer_append_string(b,"<D:href>\n");
+	buffer_append_string_buffer(b, con->uri.path);
+	BUFFER_APPEND_SLASH(b);
+	buffer_append_string(b, filename);
+	buffer_append_string(b,"</D:href>\n");
+	buffer_append_string(b,"<D:propstat>\n");
+	/* we have to stat now */
+
+	buffer_copy_string_buffer(p->tmp_buf, con->physical.path);
+	BUFFER_APPEND_SLASH(p->tmp_buf);
+	buffer_append_string(p->tmp_buf, filename);
+
+	if (0 == stat(p->tmp_buf->ptr, &st)) {
+		char ctime_buf[] = "2005-08-18T07:27:16Z";
+		char mtime_buf[] = "Thu, 18 Aug 2005 07:27:16 GMT";
+		size_t k;
+
+		buffer_append_string(b,"<D:prop>\n");
+		if (S_ISDIR(st.st_mode)) {
+			buffer_append_string(b, "<D:resourcetype><D:collection/></D:resourcetype>"
+					        "<D:getcontenttype>httpd/unix-directory</D:getcontenttype>\n");
+		}
+
+		buffer_append_string(b, "<D:creationdate ns0:dt=\"dateTime.tz\">");
+		strftime(ctime_buf, sizeof(ctime_buf), "%Y-%m-%dT%H:%M:%SZ", gmtime(&st.st_ctime));
+		buffer_append_string(b, ctime_buf);
+		buffer_append_string(b, "</D:creationdate>");
+		
+		buffer_append_string(b,"<D:getlastmodified ns0:dt=\"dateTime.rfc1123\">");
+		strftime(mtime_buf, sizeof(mtime_buf), "%a, %d %b %Y %H:%M:%S GMT", gmtime(&st.st_mtime));
+		buffer_append_string(b, mtime_buf);
+		buffer_append_string(b, "</D:getlastmodified>");
+
+		buffer_append_string(b,"<D:getcontentlength>");
+		buffer_append_off_t(b, st.st_size);
+		buffer_append_string(b, "</D:getcontentlength>");
+
+		buffer_append_string(b,"<D:getcontentlanguage>");
+		buffer_append_string(b, "en");
+		buffer_append_string(b, "</D:getcontentlanguage>");
+
+		for (k = 0; k < con->conf.mimetypes->used; k++) {
+			data_string *ds = (data_string *)con->conf.mimetypes->data[k];
+		
+			if (ds->key->used == 0) continue;
+				
+			if (buffer_is_equal_right_len(p->tmp_buf, ds->key, ds->key->used - 1)) {
+				buffer_append_string(b,"<D:contenttype>");
+				buffer_append_string_buffer(b, ds->value);
+				buffer_append_string(b, "</D:contenttype>");
+
+				break;
+			}
+		}
+	
+		buffer_append_string(b,"</D:prop>\n");
+
+		buffer_append_string(b,"<D:status>HTTP/1.1 200 OK</D:status>\n");
+	} else {
+		buffer_append_string(b,"<D:status>HTTP/1.1 404 Not Found</D:status>\n");
+	}
+	buffer_append_string(b,"</D:propstat>\n");
+		
+	buffer_append_string(b,"</D:response>\n");
+
+	return 0;
+}
+
+URIHANDLER_FUNC(mod_webdav_subrequest_handler) {
+	plugin_data *p = p_d;
+	buffer *b;
+	DIR *dir;
+	data_string *ds;
+	int depth = -1;
+	
+	UNUSED(srv);
+
+	/* physical path is setup */
+	if (con->physical.path->used == 0) return HANDLER_GO_ON;
+	
+	switch (con->request.http_method) {
+	case HTTP_METHOD_PROPFIND:
+		/* they want to know the properties of the directory */
+		if (NULL != (ds = (data_string *)array_get_element(con->request.headers, "Depth"))) {
+			depth = strtol(ds->value->ptr, NULL, 10);
+		}
+		
+		con->http_status = 207;
+
+		response_header_overwrite(srv, con, CONST_STR_LEN("Content-Type"), CONST_STR_LEN("text/xml; charset=\"utf-8\""));
+
+		b = chunkqueue_get_append_buffer(con->write_queue);
+				
+		buffer_copy_string(b, 
+				   "<?xml version=\"1.0\" encoding=\"utf-8\"?>\n");
+
+		buffer_append_string(b,"<D:multistatus xmlns:D=\"DAV:\">\n");
+
+		switch(depth) {
+		case 0:
+			/* Depth: 0 */
+			get_response_entry(srv, con, p, b, "");
+			break;
+		case 1:
+			if (NULL != (dir = opendir(con->physical.path->ptr))) {
+				struct dirent *de;
+
+				while(NULL != (de = readdir(dir))) {
+					if (de->d_name[0] == '.' && de->d_name[1] == '\0') {
+						/* ignore the currrent dir */
+					} else {
+						get_response_entry(srv, con, p, b, de->d_name);
+					}
+				}
+				closedir(dir);
+			}
+			break;
+		}
+		
+		buffer_append_string(b,"</D:multistatus>\n");
+
+		con->file_finished = 1;
+
+		return HANDLER_FINISHED;
+	default:
+		break;
+	}
+	
+	/* not found */
+	return HANDLER_GO_ON;
+}
+
+
+/* this function is called at dlopen() time and inits the callbacks */
+
+int mod_webdav_plugin_init(plugin *p) {
+	p->version     = LIGHTTPD_VERSION_ID;
+	p->name        = buffer_init_string("webdav");
+	
+	p->init        = mod_webdav_init;
+	p->handle_uri_clean  = mod_webdav_uri_handler;
+	p->handle_physical   = mod_webdav_subrequest_handler;
+	p->set_defaults  = mod_webdav_set_defaults;
+	p->cleanup     = mod_webdav_free;
+	
+	p->data        = NULL;
+	
+	return 0;
+}
diff --git a/src/response.c b/src/response.c
index 98653fc0..9b3912b8 100644
--- a/src/response.c
+++ b/src/response.c
@@ -121,14 +121,6 @@ handler_t http_response_prepare(server *srv, connection *con) {
 		return HANDLER_FINISHED;
 	}
 	
-	if (con->request.http_method == HTTP_METHOD_OPTIONS) {
-		/* option requests are handled directly without checking of the path */
-		con->http_status = 200;
-		con->file_finished = 1;
-
-		return HANDLER_FINISHED;
-	}
-
 	/* no decision yet, build conf->filename */
 	if (con->mode == DIRECT && con->physical.path->used == 0) {
 		char *qstr;
@@ -256,6 +248,18 @@ handler_t http_response_prepare(server *srv, connection *con) {
 			break;
 		}
 		
+		if (con->request.http_method == HTTP_METHOD_OPTIONS &&
+		    con->uri.path->ptr[0] == '*') {
+			/* option requests are handled directly without checking of the path */
+		
+			response_header_insert(srv, con, CONST_STR_LEN("Allow"), CONST_STR_LEN("OPTIONS, GET, HEAD, POST"));
+
+			con->http_status = 200;
+			con->file_finished = 1;
+
+			return HANDLER_FINISHED;
+		}
+
 		/***
 		 * 
 		 * border