summaryrefslogtreecommitdiff
path: root/src/mod_webdav.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/mod_webdav.c')
-rw-r--r--src/mod_webdav.c2688
1 files changed, 0 insertions, 2688 deletions
diff --git a/src/mod_webdav.c b/src/mod_webdav.c
deleted file mode 100644
index 49de74a5..00000000
--- a/src/mod_webdav.c
+++ /dev/null
@@ -1,2688 +0,0 @@
-#include <sys/types.h>
-#include <sys/stat.h>
-#include <ctype.h>
-#include <stdlib.h>
-#include <string.h>
-#include <errno.h>
-#include <fcntl.h>
-#include <stdio.h>
-#include <assert.h>
-
-#ifdef HAVE_CONFIG_H
-#include "config.h"
-#endif
-
-#if defined(HAVE_LIBXML_H) && defined(HAVE_SQLITE3_H)
-#define USE_PROPPATCH
-#include <libxml/tree.h>
-#include <libxml/parser.h>
-
-#include <sqlite3.h>
-#endif
-
-#if defined(HAVE_LIBXML_H) && defined(HAVE_SQLITE3_H) && defined(HAVE_UUID_H)
-#define USE_LOCKS
-#include <uuid/uuid.h>
-#endif
-
-#include "base.h"
-#include "log.h"
-#include "buffer.h"
-#include "response.h"
-
-#include "plugin.h"
-
-#include "stream.h"
-#include "stat_cache.h"
-
-#include "sys-files.h"
-#include "sys-mmap.h"
-#include "sys-strings.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
- *
- */
-#ifdef _WIN32
-#define WEBDAV_FILE_MODE _S_IREAD | _S_IWRITE
-#define WEBDAV_DIR_MODE _S_IREAD | _S_IWRITE
-#else
-#define WEBDAV_FILE_MODE S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP | S_IROTH | S_IWOTH
-#define WEBDAV_DIR_MODE S_IRWXU | S_IRWXG | S_IRWXO
-#endif
-
-/* plugin config for all request/connections */
-
-typedef struct {
- unsigned short enabled;
- unsigned short is_readonly;
- unsigned short log_xml;
-
- buffer *sqlite_db_name;
-#ifdef USE_PROPPATCH
- sqlite3 *sql;
- sqlite3_stmt *stmt_update_prop;
- sqlite3_stmt *stmt_delete_prop;
- sqlite3_stmt *stmt_select_prop;
- sqlite3_stmt *stmt_select_propnames;
-
- sqlite3_stmt *stmt_delete_uri;
- sqlite3_stmt *stmt_move_uri;
- sqlite3_stmt *stmt_copy_uri;
-
- sqlite3_stmt *stmt_remove_lock;
- sqlite3_stmt *stmt_create_lock;
- sqlite3_stmt *stmt_read_lock;
- sqlite3_stmt *stmt_read_lock_by_uri;
- sqlite3_stmt *stmt_refresh_lock;
-#endif
-} plugin_config;
-
-typedef struct {
- PLUGIN_DATA;
-
- buffer *tmp_buf;
- request_uri uri;
- physical physical;
-
- plugin_config **config_storage;
-
- plugin_config conf;
-} plugin_data;
-
-/* init the plugin data */
-INIT_FUNC(mod_webdav_init) {
- plugin_data *p;
-
- UNUSED(srv);
-
- p = calloc(1, sizeof(*p));
-
- p->tmp_buf = buffer_init();
-
- p->uri.scheme = buffer_init();
- p->uri.path_raw = buffer_init();
- p->uri.path = buffer_init();
- p->uri.authority = buffer_init();
-
- p->physical.path = buffer_init();
- p->physical.rel_path = buffer_init();
- p->physical.doc_root = buffer_init();
- p->physical.basedir = 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];
-
- if (!s) continue;
-
- buffer_free(s->sqlite_db_name);
-#ifdef USE_PROPPATCH
- if (s->sql) {
- sqlite3_finalize(s->stmt_delete_prop);
- sqlite3_finalize(s->stmt_delete_uri);
- sqlite3_finalize(s->stmt_copy_uri);
- sqlite3_finalize(s->stmt_move_uri);
- sqlite3_finalize(s->stmt_update_prop);
- sqlite3_finalize(s->stmt_select_prop);
- sqlite3_finalize(s->stmt_select_propnames);
-
- sqlite3_finalize(s->stmt_read_lock);
- sqlite3_finalize(s->stmt_read_lock_by_uri);
- sqlite3_finalize(s->stmt_create_lock);
- sqlite3_finalize(s->stmt_remove_lock);
- sqlite3_finalize(s->stmt_refresh_lock);
- sqlite3_close(s->sql);
- }
-#endif
- free(s);
- }
- free(p->config_storage);
- }
-
- buffer_free(p->uri.scheme);
- buffer_free(p->uri.path_raw);
- buffer_free(p->uri.path);
- buffer_free(p->uri.authority);
-
- buffer_free(p->physical.path);
- buffer_free(p->physical.rel_path);
- buffer_free(p->physical.doc_root);
- buffer_free(p->physical.basedir);
-
- 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.activate", NULL, T_CONFIG_BOOLEAN, T_CONFIG_SCOPE_CONNECTION }, /* 0 */
- { "webdav.is-readonly", NULL, T_CONFIG_BOOLEAN, T_CONFIG_SCOPE_CONNECTION }, /* 1 */
- { "webdav.sqlite-db-name", NULL, T_CONFIG_STRING, T_CONFIG_SCOPE_CONNECTION }, /* 2 */
- { "webdav.log-xml", NULL, T_CONFIG_BOOLEAN, T_CONFIG_SCOPE_CONNECTION }, /* 3 */
- { 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->sqlite_db_name = buffer_init();
-
- cv[0].destination = &(s->enabled);
- cv[1].destination = &(s->is_readonly);
- cv[2].destination = s->sqlite_db_name;
- cv[3].destination = &(s->log_xml);
-
- p->config_storage[i] = s;
-
- if (0 != config_insert_values_global(srv, ((data_config *)srv->config_context->data[i])->value, cv)) {
- return HANDLER_ERROR;
- }
-
- if (!buffer_is_empty(s->sqlite_db_name)) {
-#ifdef USE_PROPPATCH
- const char *next_stmt;
- char *err;
-
- if (SQLITE_OK != sqlite3_open(s->sqlite_db_name->ptr, &(s->sql))) {
- log_error_write(srv, __FILE__, __LINE__, "sbs", "sqlite3_open failed for",
- s->sqlite_db_name,
- sqlite3_errmsg(s->sql));
- return HANDLER_ERROR;
- }
-
- if (SQLITE_OK != sqlite3_exec(s->sql,
- "CREATE TABLE properties ("
- " resource TEXT NOT NULL,"
- " prop TEXT NOT NULL,"
- " ns TEXT NOT NULL,"
- " value TEXT NOT NULL,"
- " PRIMARY KEY(resource, prop, ns))",
- NULL, NULL, &err)) {
-
- if (0 != strcmp(err, "table properties already exists")) {
- log_error_write(srv, __FILE__, __LINE__, "ss", "can't open transaction:", err);
- sqlite3_free(err);
-
- return HANDLER_ERROR;
- }
- sqlite3_free(err);
- }
-
- if (SQLITE_OK != sqlite3_prepare(s->sql,
- CONST_STR_LEN("SELECT value FROM properties WHERE resource = ? AND prop = ? AND ns = ?"),
- &(s->stmt_select_prop), &next_stmt)) {
- /* prepare failed */
-
- log_error_write(srv, __FILE__, __LINE__, "ss", "sqlite3_prepare failed:", sqlite3_errmsg(s->sql));
- return HANDLER_ERROR;
- }
-
- if (SQLITE_OK != sqlite3_prepare(s->sql,
- CONST_STR_LEN("SELECT ns, prop FROM properties WHERE resource = ?"),
- &(s->stmt_select_propnames), &next_stmt)) {
- /* prepare failed */
-
- log_error_write(srv, __FILE__, __LINE__, "ss", "sqlite3_prepare failed:", sqlite3_errmsg(s->sql));
- return HANDLER_ERROR;
- }
-
-
- if (SQLITE_OK != sqlite3_prepare(s->sql,
- CONST_STR_LEN("REPLACE INTO properties (resource, prop, ns, value) VALUES (?, ?, ?, ?)"),
- &(s->stmt_update_prop), &next_stmt)) {
- /* prepare failed */
-
- log_error_write(srv, __FILE__, __LINE__, "ss", "sqlite3_prepare failed:", sqlite3_errmsg(s->sql));
- return HANDLER_ERROR;
- }
-
- if (SQLITE_OK != sqlite3_prepare(s->sql,
- CONST_STR_LEN("DELETE FROM properties WHERE resource = ? AND prop = ? AND ns = ?"),
- &(s->stmt_delete_prop), &next_stmt)) {
- /* prepare failed */
- log_error_write(srv, __FILE__, __LINE__, "ss", "sqlite3_prepare failed", sqlite3_errmsg(s->sql));
-
- return HANDLER_ERROR;
- }
-
- if (SQLITE_OK != sqlite3_prepare(s->sql,
- CONST_STR_LEN("DELETE FROM properties WHERE resource = ?"),
- &(s->stmt_delete_uri), &next_stmt)) {
- /* prepare failed */
- log_error_write(srv, __FILE__, __LINE__, "ss", "sqlite3_prepare failed", sqlite3_errmsg(s->sql));
-
- return HANDLER_ERROR;
- }
-
- if (SQLITE_OK != sqlite3_prepare(s->sql,
- CONST_STR_LEN("INSERT INTO properties SELECT ?, prop, ns, value FROM properties WHERE resource = ?"),
- &(s->stmt_copy_uri), &next_stmt)) {
- /* prepare failed */
- log_error_write(srv, __FILE__, __LINE__, "ss", "sqlite3_prepare failed", sqlite3_errmsg(s->sql));
-
- return HANDLER_ERROR;
- }
-
- if (SQLITE_OK != sqlite3_prepare(s->sql,
- CONST_STR_LEN("UPDATE properties SET resource = ? WHERE resource = ?"),
- &(s->stmt_move_uri), &next_stmt)) {
- /* prepare failed */
- log_error_write(srv, __FILE__, __LINE__, "ss", "sqlite3_prepare failed", sqlite3_errmsg(s->sql));
-
- return HANDLER_ERROR;
- }
-
- /* LOCKS */
-
- if (SQLITE_OK != sqlite3_exec(s->sql,
- "CREATE TABLE locks ("
- " locktoken TEXT NOT NULL,"
- " resource TEXT NOT NULL,"
- " lockscope TEXT NOT NULL,"
- " locktype TEXT NOT NULL,"
- " owner TEXT NOT NULL,"
- " depth INT NOT NULL,"
- " timeout TIMESTAMP NOT NULL,"
- " PRIMARY KEY(locktoken))",
- NULL, NULL, &err)) {
-
- if (0 != strcmp(err, "table locks already exists")) {
- log_error_write(srv, __FILE__, __LINE__, "ss", "can't open transaction:", err);
- sqlite3_free(err);
-
- return HANDLER_ERROR;
- }
- sqlite3_free(err);
- }
-
- if (SQLITE_OK != sqlite3_prepare(s->sql,
- CONST_STR_LEN("INSERT INTO locks (locktoken, resource, lockscope, locktype, owner, depth, timeout) VALUES (?,?,?,?,?,?, CURRENT_TIME + 600)"),
- &(s->stmt_create_lock), &next_stmt)) {
- /* prepare failed */
- log_error_write(srv, __FILE__, __LINE__, "ss", "sqlite3_prepare failed", sqlite3_errmsg(s->sql));
-
- return HANDLER_ERROR;
- }
-
- if (SQLITE_OK != sqlite3_prepare(s->sql,
- CONST_STR_LEN("DELETE FROM locks WHERE locktoken = ?"),
- &(s->stmt_remove_lock), &next_stmt)) {
- /* prepare failed */
- log_error_write(srv, __FILE__, __LINE__, "ss", "sqlite3_prepare failed", sqlite3_errmsg(s->sql));
-
- return HANDLER_ERROR;
- }
-
- if (SQLITE_OK != sqlite3_prepare(s->sql,
- CONST_STR_LEN("SELECT locktoken, resource, lockscope, locktype, owner, depth, timeout FROM locks WHERE locktoken = ?"),
- &(s->stmt_read_lock), &next_stmt)) {
- /* prepare failed */
- log_error_write(srv, __FILE__, __LINE__, "ss", "sqlite3_prepare failed", sqlite3_errmsg(s->sql));
-
- return HANDLER_ERROR;
- }
-
- if (SQLITE_OK != sqlite3_prepare(s->sql,
- CONST_STR_LEN("SELECT locktoken, resource, lockscope, locktype, owner, depth, timeout FROM locks WHERE resource = ?"),
- &(s->stmt_read_lock_by_uri), &next_stmt)) {
- /* prepare failed */
- log_error_write(srv, __FILE__, __LINE__, "ss", "sqlite3_prepare failed", sqlite3_errmsg(s->sql));
-
- return HANDLER_ERROR;
- }
-
- if (SQLITE_OK != sqlite3_prepare(s->sql,
- CONST_STR_LEN("UPDATE locks SET timeout = CURRENT_TIME + 600 WHERE locktoken = ?"),
- &(s->stmt_refresh_lock), &next_stmt)) {
- /* prepare failed */
- log_error_write(srv, __FILE__, __LINE__, "ss", "sqlite3_prepare failed", sqlite3_errmsg(s->sql));
-
- return HANDLER_ERROR;
- }
-
-
-#else
- log_error_write(srv, __FILE__, __LINE__, "s", "Sorry, no sqlite3 and libxml2 support include, compile with --with-webdav-props");
- return HANDLER_ERROR;
-#endif
- }
- }
-
- return HANDLER_GO_ON;
-}
-
-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_OPTION(enabled);
- PATCH_OPTION(is_readonly);
- PATCH_OPTION(log_xml);
-
-#ifdef USE_PROPPATCH
- PATCH_OPTION(sql);
- PATCH_OPTION(stmt_update_prop);
- PATCH_OPTION(stmt_delete_prop);
- PATCH_OPTION(stmt_select_prop);
- PATCH_OPTION(stmt_select_propnames);
-
- PATCH_OPTION(stmt_delete_uri);
- PATCH_OPTION(stmt_move_uri);
- PATCH_OPTION(stmt_copy_uri);
-
- PATCH_OPTION(stmt_remove_lock);
- PATCH_OPTION(stmt_refresh_lock);
- PATCH_OPTION(stmt_create_lock);
- PATCH_OPTION(stmt_read_lock);
- PATCH_OPTION(stmt_read_lock_by_uri);
-#endif
- /* 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.activate"))) {
- PATCH_OPTION(enabled);
- } else if (buffer_is_equal_string(du->key, CONST_STR_LEN("webdav.is-readonly"))) {
- PATCH_OPTION(is_readonly);
- } else if (buffer_is_equal_string(du->key, CONST_STR_LEN("webdav.log-xml"))) {
- PATCH_OPTION(log_xml);
- } else if (buffer_is_equal_string(du->key, CONST_STR_LEN("webdav.sqlite-db-name"))) {
-#ifdef USE_PROPPATCH
- PATCH_OPTION(sql);
- PATCH_OPTION(stmt_update_prop);
- PATCH_OPTION(stmt_delete_prop);
- PATCH_OPTION(stmt_select_prop);
- PATCH_OPTION(stmt_select_propnames);
-
- PATCH_OPTION(stmt_delete_uri);
- PATCH_OPTION(stmt_move_uri);
- PATCH_OPTION(stmt_copy_uri);
-
- PATCH_OPTION(stmt_remove_lock);
- PATCH_OPTION(stmt_refresh_lock);
- PATCH_OPTION(stmt_create_lock);
- PATCH_OPTION(stmt_read_lock);
- PATCH_OPTION(stmt_read_lock_by_uri);
-#endif
- }
- }
- }
-
- return 0;
-}
-
-URIHANDLER_FUNC(mod_webdav_uri_handler) {
- plugin_data *p = p_d;
-
- if (buffer_is_empty(con->uri.path)) return HANDLER_GO_ON;
-
- mod_webdav_patch_connection(srv, con, p);
-
- if (!p->conf.enabled) {
- if (con->conf.log_request_handling) {
- TRACE("-- skipping %s in mod_webdav, not enabled",
- SAFE_BUF_STR(con->uri.path));
- }
-
- return HANDLER_GO_ON;
- }
-
- if (con->conf.log_request_handling) {
- TRACE("-- handling request in mod_webdav: %s",
- SAFE_BUF_STR(con->uri.path));
- }
-
- switch (con->request.http_method) {
- case HTTP_METHOD_OPTIONS:
- /* we fake a little bit but it makes MS W2k happy and it let's us mount the volume */
- 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"));
-
- if (p->conf.is_readonly) {
- response_header_insert(srv, con, CONST_STR_LEN("Allow"), CONST_STR_LEN("PROPFIND"));
- } else {
- response_header_insert(srv, con, CONST_STR_LEN("Allow"), CONST_STR_LEN("PROPFIND, DELETE, MKCOL, PUT, MOVE, COPY, PROPPATCH, LOCK, UNLOCK"));
- }
-
- if (con->conf.log_request_handling) {
- TRACE("sending OPTIONS response for: %s",
- SAFE_BUF_STR(con->uri.path));
- }
-
- break;
- default:
- break;
- }
-
- return HANDLER_GO_ON;
-}
-
-PHYSICALPATH_FUNC(mod_webdav_physical_handler) {
- plugin_data *p = p_d;
-
- if (con->mode != DIRECT) return HANDLER_GO_ON;
-
- mod_webdav_patch_connection(srv, con, p);
-
- if (!p->conf.enabled) {
- if (con->conf.log_request_handling) {
- TRACE("-- skipping %s in mod_webdav, not enabled",
- SAFE_BUF_STR(con->uri.path));
- }
-
- return HANDLER_GO_ON;
- }
-
- if (con->conf.log_request_handling) {
- TRACE("-- handling request in mod_webdav: %s",
- SAFE_BUF_STR(con->uri.path));
- }
-
- /* physical path is setup */
- if (con->physical.path->used == 0) {
- TRACE("-- missing con->physical.path: %s",
- SAFE_BUF_STR(con->uri.path));
- return HANDLER_GO_ON;
- }
-
- switch (con->request.http_method) {
- case HTTP_METHOD_OPTIONS:
- /* already handled */
- break;
- case HTTP_METHOD_PROPFIND:
- case HTTP_METHOD_MKCOL:
- case HTTP_METHOD_DELETE:
- case HTTP_METHOD_PUT:
- case HTTP_METHOD_MOVE:
- case HTTP_METHOD_COPY:
- case HTTP_METHOD_PROPPATCH:
- case HTTP_METHOD_LOCK:
- case HTTP_METHOD_UNLOCK:
- con->mode = p->id;
- return HANDLER_FINISHED;
- default: break;
- }
-
- return HANDLER_GO_ON;
-}
-
-
-static int webdav_gen_prop_tag(server *srv, connection *con,
- char *prop_name,
- char *prop_ns,
- char *value,
- buffer *b) {
-
- UNUSED(srv);
- UNUSED(con);
-
- if (value) {
- buffer_append_string_len(b,CONST_STR_LEN("<"));
- buffer_append_string(b, prop_name);
- buffer_append_string_len(b, CONST_STR_LEN(" xmlns=\""));
- buffer_append_string(b, prop_ns);
- buffer_append_string_len(b, CONST_STR_LEN("\">"));
-
- buffer_append_string(b, value);
-
- buffer_append_string_len(b,CONST_STR_LEN("</"));
- buffer_append_string(b, prop_name);
- buffer_append_string_len(b, CONST_STR_LEN(">"));
- } else {
- buffer_append_string_len(b,CONST_STR_LEN("<"));
- buffer_append_string(b, prop_name);
- buffer_append_string_len(b, CONST_STR_LEN(" xmlns=\""));
- buffer_append_string(b, prop_ns);
- buffer_append_string_len(b, CONST_STR_LEN("\"/>"));
- }
-
- return 0;
-}
-
-
-static int webdav_gen_response_status_tag(server *srv, connection *con, physical *dst, int status, buffer *b) {
- UNUSED(srv);
-
- buffer_append_string_len(b,CONST_STR_LEN("<D:response xmlns:ns0=\"urn:uuid:c2f41010-65b3-11d1-a29f-00aa00c14882/\">\n"));
-
- buffer_append_string_len(b,CONST_STR_LEN("<D:href>\n"));
- buffer_append_string_buffer(b, dst->rel_path);
- buffer_append_string_len(b,CONST_STR_LEN("</D:href>\n"));
- buffer_append_string_len(b,CONST_STR_LEN("<D:status>\n"));
-
- if (con->request.http_version == HTTP_VERSION_1_1) {
- buffer_copy_string_len(b, CONST_STR_LEN("HTTP/1.1 "));
- } else {
- buffer_copy_string_len(b, CONST_STR_LEN("HTTP/1.0 "));
- }
- buffer_append_long(b, status);
- buffer_append_string_len(b, CONST_STR_LEN(" "));
- buffer_append_string(b, get_http_status_name(status));
-
- buffer_append_string_len(b,CONST_STR_LEN("</D:status>\n"));
- buffer_append_string_len(b,CONST_STR_LEN("</D:response>\n"));
-
- return 0;
-}
-
-static int webdav_delete_file(server *srv, connection *con, plugin_data *p, physical *dst, buffer *b) {
- int status = 0;
-
- UNUSED(p);
-
- /* try to unlink it */
- if (-1 == unlink(dst->path->ptr)) {
- switch(errno) {
- case EACCES:
- case EPERM:
- /* 403 */
- status = 403;
- break;
- default:
- status = 501;
- break;
- }
- webdav_gen_response_status_tag(srv, con, dst, status, b);
- } else {
-#ifdef USE_PROPPATCH
- sqlite3_stmt *stmt = p->conf.stmt_delete_uri;
-
- if (stmt) {
- sqlite3_reset(stmt);
-
- /* bind the values to the insert */
-
- sqlite3_bind_text(stmt, 1,
- dst->rel_path->ptr,
- dst->rel_path->used - 1,
- SQLITE_TRANSIENT);
-
- if (SQLITE_DONE != sqlite3_step(stmt)) {
- /* */
- }
- }
-#endif
- }
-
- return (status != 0);
-}
-
-static int webdav_delete_dir(server *srv, connection *con, plugin_data *p, physical *dst, buffer *b) {
- DIR *dir;
- int have_multi_status = 0;
- physical d;
-
- d.path = buffer_init();
- d.rel_path = buffer_init();
-
- if (NULL != (dir = opendir(dst->path->ptr))) {
- struct dirent *de;
-
- while(NULL != (de = readdir(dir))) {
- struct stat st;
- int status = 0;
-
- if ((de->d_name[0] == '.' && de->d_name[1] == '\0') ||
- (de->d_name[0] == '.' && de->d_name[1] == '.' && de->d_name[2] == '\0')) {
- continue;
- /* ignore the parent dir */
- }
-
- buffer_copy_string_buffer(d.path, dst->path);
- PATHNAME_APPEND_SLASH(d.path);
- buffer_append_string(d.path, de->d_name);
-
- buffer_copy_string_buffer(d.rel_path, dst->rel_path);
- PATHNAME_APPEND_SLASH(d.rel_path);
- buffer_append_string(d.rel_path, de->d_name);
-
- /* stat and unlink afterwards */
- if (-1 == stat(d.path->ptr, &st)) {
- /* don't about it yet, rmdir will fail too */
- } else if (S_ISDIR(st.st_mode)) {
- have_multi_status = webdav_delete_dir(srv, con, p, &d, b);
-
- /* try to unlink it */
- if (-1 == rmdir(d.path->ptr)) {
- switch(errno) {
- case EACCES:
- case EPERM:
- /* 403 */
- status = 403;
- break;
- default:
- status = 501;
- break;
- }
- have_multi_status = 1;
-
- webdav_gen_response_status_tag(srv, con, &d, status, b);
- } else {
-#ifdef USE_PROPPATCH
- sqlite3_stmt *stmt = p->conf.stmt_delete_uri;
-
- status = 0;
-
- if (stmt) {
- sqlite3_reset(stmt);
-
- /* bind the values to the insert */
-
- sqlite3_bind_text(stmt, 1,
- d.rel_path->ptr,
- d.rel_path->used - 1,
- SQLITE_TRANSIENT);
-
- if (SQLITE_DONE != sqlite3_step(stmt)) {
- /* */
- }
- }
-#endif
- }
- } else {
- have_multi_status = webdav_delete_file(srv, con, p, &d, b);
- }
- }
- closedir(dir);
-
- buffer_free(d.path);
- buffer_free(d.rel_path);
- }
-
- return have_multi_status;
-}
-
-static int webdav_copy_file(server *srv, connection *con, plugin_data *p, physical *src, physical *dst, int overwrite) {
- stream s;
- int status = 0, ofd;
-
- UNUSED(con);
- UNUSED(srv);
- UNUSED(p);
-
- if (stream_open(&s, src->path)) {
- return 403;
- }
-
- if (-1 == (ofd = open(dst->path->ptr, O_WRONLY|O_TRUNC|O_CREAT|(overwrite ? 0 : O_EXCL), WEBDAV_FILE_MODE))) {
- /* opening the destination failed for some reason */
- switch(errno) {
- case EEXIST:
- status = 412;
- break;
- case EISDIR:
- status = 409;
- break;
- case ENOENT:
- /* at least one part in the middle wasn't existing */
- status = 409;
- break;
- default:
- status = 403;
- break;
- }
- stream_close(&s);
- return status;
- }
-
- if (-1 == write(ofd, s.start, s.size)) {
- switch(errno) {
- case ENOSPC:
- status = 507;
- break;
- default:
- status = 403;
- break;
- }
- }
-
- stream_close(&s);
- close(ofd);
-
-#ifdef USE_PROPPATCH
- if (0 == status) {
- /* copy worked fine, copy connected properties */
- sqlite3_stmt *stmt = p->conf.stmt_copy_uri;
-
- if (stmt) {
- sqlite3_reset(stmt);
-
- /* bind the values to the insert */
- sqlite3_bind_text(stmt, 1,
- dst->rel_path->ptr,
- dst->rel_path->used - 1,
- SQLITE_TRANSIENT);
-
- sqlite3_bind_text(stmt, 2,
- src->rel_path->ptr,
- src->rel_path->used - 1,
- SQLITE_TRANSIENT);
-
- if (SQLITE_DONE != sqlite3_step(stmt)) {
- /* */
- }
- }
- }
-#endif
- return status;
-}
-
-static int webdav_copy_dir(server *srv, connection *con, plugin_data *p, physical *src, physical *dst, int overwrite) {
- DIR *srcdir;
- int status = 0;
-
- if (NULL != (srcdir = opendir(src->path->ptr))) {
- struct dirent *de;
- physical s, d;
-
- s.path = buffer_init();
- s.rel_path = buffer_init();
-
- d.path = buffer_init();
- d.rel_path = buffer_init();
-
- while (NULL != (de = readdir(srcdir))) {
- struct stat st;
-
- if ((de->d_name[0] == '.' && de->d_name[1] == '\0') ||
- (de->d_name[0] == '.' && de->d_name[1] == '.' && de->d_name[2] == '\0')) {
- continue;
- }
-
- buffer_copy_string_buffer(s.path, src->path);
- PATHNAME_APPEND_SLASH(s.path);
- buffer_append_string(s.path, de->d_name);
-
- buffer_copy_string_buffer(d.path, dst->path);
- PATHNAME_APPEND_SLASH(d.path);
- buffer_append_string(d.path, de->d_name);
-
- buffer_copy_string_buffer(s.rel_path, src->rel_path);
- PATHNAME_APPEND_SLASH(s.rel_path);
- buffer_append_string(s.rel_path, de->d_name);
-
- buffer_copy_string_buffer(d.rel_path, dst->rel_path);
- PATHNAME_APPEND_SLASH(d.rel_path);
- buffer_append_string(d.rel_path, de->d_name);
-
- if (-1 == stat(s.path->ptr, &st)) {
- /* why ? */
- } else if (S_ISDIR(st.st_mode)) {
- /* a directory */
- if (-1 == mkdir(d.path->ptr, WEBDAV_DIR_MODE) &&
- errno != EEXIST) {
- /* WTH ? */
- } else {
-#ifdef USE_PROPPATCH
- sqlite3_stmt *stmt = p->conf.stmt_copy_uri;
-
- if (0 != (status = webdav_copy_dir(srv, con, p, &s, &d, overwrite))) {
- break;
- }
- /* directory is copied, copy the properties too */
-
- if (stmt) {
- sqlite3_reset(stmt);
-
- /* bind the values to the insert */
- sqlite3_bind_text(stmt, 1,
- dst->rel_path->ptr,
- dst->rel_path->used - 1,
- SQLITE_TRANSIENT);
-
- sqlite3_bind_text(stmt, 2,
- src->rel_path->ptr,
- src->rel_path->used - 1,
- SQLITE_TRANSIENT);
-
- if (SQLITE_DONE != sqlite3_step(stmt)) {
- /* */
- }
- }
-#endif
- }
- } else if (S_ISREG(st.st_mode)) {
- /* a plain file */
- if (0 != (status = webdav_copy_file(srv, con, p, &s, &d, overwrite))) {
- break;
- }
- }
- }
-
- buffer_free(s.path);
- buffer_free(s.rel_path);
- buffer_free(d.path);
- buffer_free(d.rel_path);
-
- closedir(srcdir);
- }
-
- return status;
-}
-
-static int webdav_get_live_property(server *srv, connection *con, plugin_data *p, physical *dst, char *prop_name, buffer *b) {
- stat_cache_entry *sce = NULL;
- int found = 0;
-
- UNUSED(p);
-
- if (HANDLER_ERROR != (stat_cache_get_entry(srv, con, dst->path, &sce))) {
- char ctime_buf[] = "2005-08-18T07:27:16Z";
- char mtime_buf[] = "Thu, 18 Aug 2005 07:27:16 GMT";
- size_t k;
-
- if (0 == strcmp(prop_name, "resourcetype")) {
- if (S_ISDIR(sce->st.st_mode)) {
- buffer_append_string_len(b, CONST_STR_LEN("<D:resourcetype><D:collection/></D:resourcetype>"));
- found = 1;
- }
- } else if (0 == strcmp(prop_name, "getcontenttype")) {
- if (S_ISDIR(sce->st.st_mode)) {
- buffer_append_string_len(b, CONST_STR_LEN("<D:getcontenttype>httpd/unix-directory</D:getcontenttype>"));
- found = 1;
- } else if(S_ISREG(sce->st.st_mode)) {
- 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(dst->path, ds->key, ds->key->used - 1)) {
- buffer_append_string_len(b,CONST_STR_LEN("<D:getcontenttype>"));
- buffer_append_string_buffer(b, ds->value);
- buffer_append_string_len(b, CONST_STR_LEN("</D:getcontenttype>"));
- found = 1;
-
- break;
- }
- }
- }
- } else if (0 == strcmp(prop_name, "creationdate")) {
- buffer_append_string_len(b, CONST_STR_LEN("<D:creationdate ns0:dt=\"dateTime.tz\">"));
- strftime(ctime_buf, sizeof(ctime_buf), "%Y-%m-%dT%H:%M:%SZ", gmtime(&(sce->st.st_ctime)));
- buffer_append_string(b, ctime_buf);
- buffer_append_string_len(b, CONST_STR_LEN("</D:creationdate>"));
- found = 1;
- } else if (0 == strcmp(prop_name, "getlastmodified")) {
- buffer_append_string_len(b,CONST_STR_LEN("<D:getlastmodified ns0:dt=\"dateTime.rfc1123\">"));
- strftime(mtime_buf, sizeof(mtime_buf), "%a, %d %b %Y %H:%M:%S GMT", gmtime(&(sce->st.st_mtime)));
- buffer_append_string(b, mtime_buf);
- buffer_append_string_len(b, CONST_STR_LEN("</D:getlastmodified>"));
- found = 1;
- } else if (0 == strcmp(prop_name, "getcontentlength")) {
- buffer_append_string_len(b,CONST_STR_LEN("<D:getcontentlength>"));
- buffer_append_off_t(b, sce->st.st_size);
- buffer_append_string_len(b, CONST_STR_LEN("</D:getcontentlength>"));
- found = 1;
- } else if (0 == strcmp(prop_name, "getcontentlanguage")) {
- buffer_append_string_len(b,CONST_STR_LEN("<D:getcontentlanguage>"));
- buffer_append_string_len(b, CONST_STR_LEN("en"));
- buffer_append_string_len(b, CONST_STR_LEN("</D:getcontentlanguage>"));
- found = 1;
- }
- }
-
- return found ? 0 : -1;
-}
-
-static int webdav_get_property(server *srv, connection *con, plugin_data *p, physical *dst, char *prop_name, char *prop_ns, buffer *b) {
- if (0 == strcmp(prop_ns, "DAV:")) {
- /* a local 'live' property */
- return webdav_get_live_property(srv, con, p, dst, prop_name, b);
- } else {
- int found = 0;
-#ifdef USE_PROPPATCH
- sqlite3_stmt *stmt = p->conf.stmt_select_prop;
-
- if (stmt) {
- /* perhaps it is in sqlite3 */
- sqlite3_reset(stmt);
-
- /* bind the values to the insert */
-
- sqlite3_bind_text(stmt, 1,
- dst->rel_path->ptr,
- dst->rel_path->used - 1,
- SQLITE_TRANSIENT);
- sqlite3_bind_text(stmt, 2,
- prop_name,
- strlen(prop_name),
- SQLITE_TRANSIENT);
- sqlite3_bind_text(stmt, 3,
- prop_ns,
- strlen(prop_ns),
- SQLITE_TRANSIENT);
-
- /* it is the PK */
- while (SQLITE_ROW == sqlite3_step(stmt)) {
- /* there is a row for us, we only expect a single col 'value' */
- webdav_gen_prop_tag(srv, con, prop_name, prop_ns, (char *)sqlite3_column_text(stmt, 0), b);
- found = 1;
- }
- }
-#endif
- return found ? 0 : -1;
- }
-
- /* not found */
- return -1;
-}
-
-typedef struct {
- char *ns;
- char *prop;
-} webdav_property;
-
-webdav_property live_properties[] = {
- { "DAV:", "creationdate" },
- { "DAV:", "displayname" },
- { "DAV:", "getcontentlanguage" },
- { "DAV:", "getcontentlength" },
- { "DAV:", "getcontenttype" },
- { "DAV:", "getetag" },
- { "DAV:", "getlastmodified" },
- { "DAV:", "resourcetype" },
- { "DAV:", "lockdiscovery" },
- { "DAV:", "source" },
- { "DAV:", "supportedlock" },
-
- { NULL, NULL }
-};
-
-typedef struct {
- webdav_property **ptr;
-
- size_t used;
- size_t size;
-} webdav_properties;
-
-static int webdav_get_props(server *srv, connection *con, plugin_data *p, physical *dst, webdav_properties *props, buffer *b_200, buffer *b_404) {
- size_t i;
-
- if (props) {
- for (i = 0; i < props->used; i++) {
- webdav_property *prop;
-
- prop = props->ptr[i];
-
- if (0 != webdav_get_property(srv, con, p,
- dst, prop->prop, prop->ns, b_200)) {
- webdav_gen_prop_tag(srv, con, prop->prop, prop->ns, NULL, b_404);
- }
- }
- } else {
- for (i = 0; live_properties[i].prop; i++) {
- /* a local 'live' property */
- webdav_get_live_property(srv, con, p, dst, live_properties[i].prop, b_200);
- }
- }
-
- return 0;
-}
-
-#ifdef USE_PROPPATCH
-static int webdav_parse_chunkqueue(server *srv, connection *con, plugin_data *p, chunkqueue *cq, xmlDoc **ret_xml) {
- xmlParserCtxtPtr ctxt;
- xmlDoc *xml;
- int res = 0;
- int err;
-
- chunk *c;
-
- UNUSED(con);
-
- /* read the chunks in to the XML document */
- ctxt = xmlCreatePushParserCtxt(NULL, NULL, NULL, 0, NULL);
-
- for (c = cq->first; cq->bytes_out != cq->bytes_in; c = cq->first) {
- size_t weWant = cq->bytes_out - cq->bytes_in;
- size_t weHave;
-
- switch(c->type) {
- case FILE_CHUNK:
- weHave = c->file.length - c->offset;
-
- if (weHave > weWant) weHave = weWant;
-
- /* xml chunks are always memory, mmap() is our friend */
- if (c->file.mmap.start == MAP_FAILED) {
- if (-1 == c->file.fd && /* open the file if not already open */
- -1 == (c->file.fd = open(c->file.name->ptr, O_RDONLY))) {
- ERROR("open(%s) failed: %s", SAFE_BUF_STR(c->file.name), strerror(errno));
-
- return -1;
- }
-
- if (MAP_FAILED == (c->file.mmap.start = mmap(0, c->file.length, PROT_READ, MAP_SHARED, c->file.fd, 0))) {
- ERROR("mmap(%s) failed: %s", SAFE_BUF_STR(c->file.name), strerror(errno));
-
- return -1;
- }
-
- close(c->file.fd);
- c->file.fd = -1;
-
- c->file.mmap.length = c->file.length;
-
- /* chunk_reset() or chunk_free() will cleanup for us */
- }
-
- if (XML_ERR_OK != (err = xmlParseChunk(ctxt, c->file.mmap.start + c->offset, weHave, 0))) {
- ERROR("xmlParseChunk() failed: %d", err);
- log_error_write(srv, __FILE__, __LINE__, "sddd", "xmlParseChunk failed at:", cq->bytes_out, weHave, err);
- }
-
- c->offset += weHave;
- cq->bytes_out += weHave;
-
- break;
- case MEM_CHUNK:
- /* append to the buffer */
- weHave = c->mem->used - 1 - c->offset;
-
- if (weHave > weWant) weHave = weWant;
-
- if (p->conf.log_xml) {
- TRACE("XML-request-body: %s", c->mem->ptr + c->offset);
- }
-
- if (XML_ERR_OK != (err = xmlParseChunk(ctxt, c->mem->ptr + c->offset, weHave, 0))) {
- ERROR("xmlParseChunk(%s) failed: %d", c->mem->ptr + c->offset, err);
- }
-
- c->offset += weHave;
- cq->bytes_out += weHave;
-
- break;
- case UNUSED_CHUNK:
- break;
- }
- chunkqueue_remove_finished_chunks(cq);
- }
-
- switch ((err = xmlParseChunk(ctxt, 0, 0, 1))) {
- case XML_ERR_DOCUMENT_END:
- case XML_ERR_OK:
- break;
- default:
- ERROR("xmlParseChunk() failed: %d", err);
- break;
- }
-
- xml = ctxt->myDoc;
- res = ctxt->wellFormed;
- xmlFreeParserCtxt(ctxt);
-
- if (res == 0) {
- xmlFreeDoc(xml);
- } else {
- *ret_xml = xml;
- }
-
- return res;
-}
-#endif
-
-#ifdef USE_LOCKS
-static int webdav_lockdiscovery(server *srv, connection *con,
- buffer *locktoken, const char *lockscope, const char *locktype, int depth) {
-
- buffer *b;
-
- response_header_overwrite(srv, con, CONST_STR_LEN("Lock-Token"), CONST_BUF_LEN(locktoken));
-
- response_header_overwrite(srv, con,
- CONST_STR_LEN("Content-Type"),
- CONST_STR_LEN("text/xml; charset=\"utf-8\""));
-
- b = chunkqueue_get_append_buffer(con->send);
-
- buffer_copy_string_len(b, CONST_STR_LEN("<?xml version=\"1.0\" encoding=\"utf-8\"?>\n"));
-
- buffer_append_string_len(b,CONST_STR_LEN("<D:prop xmlns:D=\"DAV:\" xmlns:ns0=\"urn:uuid:c2f41010-65b3-11d1-a29f-00aa00c14882/\">\n"));
- buffer_append_string_len(b,CONST_STR_LEN("<D:lockdiscovery>\n"));
- buffer_append_string_len(b,CONST_STR_LEN("<D:activelock>\n"));
-
- buffer_append_string_len(b,CONST_STR_LEN("<D:lockscope>"));
- buffer_append_string_len(b,CONST_STR_LEN("<D:"));
- buffer_append_string(b, lockscope);
- buffer_append_string_len(b, CONST_STR_LEN("/>"));
- buffer_append_string_len(b,CONST_STR_LEN("</D:lockscope>\n"));
-
- buffer_append_string_len(b,CONST_STR_LEN("<D:locktype>"));
- buffer_append_string_len(b,CONST_STR_LEN("<D:"));
- buffer_append_string(b, locktype);
- buffer_append_string_len(b, CONST_STR_LEN("/>"));
- buffer_append_string_len(b,CONST_STR_LEN("</D:locktype>\n"));
-
- buffer_append_string_len(b,CONST_STR_LEN("<D:depth>"));
- buffer_append_string(b, depth == 0 ? "0" : "infinity");
- buffer_append_string_len(b,CONST_STR_LEN("</D:depth>\n"));
-
- buffer_append_string_len(b,CONST_STR_LEN("<D:timeout>"));
- buffer_append_string_len(b, CONST_STR_LEN("Second-600"));
- buffer_append_string_len(b,CONST_STR_LEN("</D:timeout>\n"));
-
- buffer_append_string_len(b,CONST_STR_LEN("<D:owner>"));
- buffer_append_string_len(b,CONST_STR_LEN("</D:owner>\n"));
-
- buffer_append_string_len(b,CONST_STR_LEN("<D:locktoken>"));
- buffer_append_string_len(b, CONST_STR_LEN("<D:href>"));
- buffer_append_string_buffer(b, locktoken);
- buffer_append_string_len(b, CONST_STR_LEN("</D:href>"));
- buffer_append_string_len(b,CONST_STR_LEN("</D:locktoken>\n"));
-
- buffer_append_string_len(b,CONST_STR_LEN("</D:activelock>\n"));
- buffer_append_string_len(b,CONST_STR_LEN("</D:lockdiscovery>\n"));
- buffer_append_string_len(b,CONST_STR_LEN("</D:prop>\n"));
-
- con->send->bytes_in += b->used-1;
-
- return 0;
-}
-#endif
-
-/**
- * check if resource is having the right locks to access to resource
- *
- *
- *
- */
-static int webdav_has_lock(server *srv, connection *con, plugin_data *p, buffer *uri) {
- int has_lock = 1;
-
-#ifdef USE_LOCKS
- data_string *ds;
-
- UNUSED(srv);
-
- /**
- * This implementation is more fake than real
- * we need a parser for the If: header to really handle the full scope
- *
- * X-Litmus: locks: 11 (owner_modify)
- * If: <http://127.0.0.1:1025/dav/litmus/lockme> (<opaquelocktoken:2165478d-0611-49c4-be92-e790d68a38f1>)
- * - a tagged check:
- * if http://127.0.0.1:1025/dav/litmus/lockme is locked with
- * opaquelocktoken:2165478d-0611-49c4-be92-e790d68a38f1, go on
- *
- * X-Litmus: locks: 16 (fail_cond_put)
- * If: (<DAV:no-lock> ["-1622396671"])
- * - untagged:
- * go on if the resource has the etag [...] and the lock
- */
- if (NULL != (ds = (data_string *)array_get_element(con->request.headers, CONST_STR_LEN("If")))) {
- /* Ooh, ooh. A if tag, now the fun begins.
- *
- * this can only work with a real parser
- **/
- } else {
- /* we didn't provided a lock-token -> */
- /* if the resource is locked -> 423 */
-
- sqlite3_stmt *stmt = p->conf.stmt_read_lock_by_uri;
-
- sqlite3_reset(stmt);
-
- sqlite3_bind_text(stmt, 1,
- CONST_BUF_LEN(uri),
- SQLITE_TRANSIENT);
-
- while (SQLITE_ROW == sqlite3_step(stmt)) {
- has_lock = 0;
- }
- }
-#else
- UNUSED(srv);
- UNUSED(uri);
- UNUSED(con);
- UNUSED(p);
-#endif
-
- return has_lock;
-}
-
-URIHANDLER_FUNC(mod_webdav_subrequest_handler) {
- plugin_data *p = p_d;
- buffer *b;
- DIR *dir;
- data_string *ds;
- int depth = -1;
- struct stat st;
- buffer *prop_200;
- buffer *prop_404;
- webdav_properties *req_props;
- stat_cache_entry *sce = NULL;
-
- if (con->conf.log_request_handling) {
- TRACE("-- handling request in mod_webdav: %s",
- SAFE_BUF_STR(con->uri.path));
- }
-
- /* PROPFIND need them */
- if (NULL != (ds = (data_string *)array_get_element(con->request.headers, CONST_STR_LEN("Depth")))) {
- depth = strtol(ds->value->ptr, NULL, 10);
- }
-
- if (con->conf.log_request_handling) {
- TRACE("depth for %s: %d",
- SAFE_BUF_STR(con->uri.path), depth);
- }
-
- if (con->conf.log_request_handling) {
- TRACE("method for %s: %s",
- SAFE_BUF_STR(con->uri.path), get_http_method_name(con->request.http_method));
- }
-
- switch (con->request.http_method) {
- case HTTP_METHOD_PROPFIND:
- /* they want to know the properties of the directory */
- req_props = NULL;
-
- /* is there a content-body ? */
- if (con->conf.log_request_handling) {
- TRACE("path-name: %s",
- SAFE_BUF_STR(con->physical.path));
- }
-
- switch (stat_cache_get_entry(srv, con, con->physical.path, &sce)) {
- case HANDLER_ERROR:
- if (errno == ENOENT) {
- if (con->conf.log_request_handling) {
- TRACE("path-name: %s ... not found",
- SAFE_BUF_STR(con->physical.path));
- }
-
- con->http_status = 404;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
- break;
- default:
- break;
- }
-
-
-#ifdef USE_PROPPATCH
- /* any special requests or just allprop ? */
- if (p->conf.sql && con->request.content_length > 0) {
- xmlDocPtr xml;
-
- if (1 == webdav_parse_chunkqueue(srv, con, p, con->recv, &xml)) {
- xmlNode *rootnode = xmlDocGetRootElement(xml);
-
- assert(rootnode);
-
- if (0 == xmlStrcmp(rootnode->name, BAD_CAST "propfind")) {
- xmlNode *cmd;
-
- req_props = calloc(1, sizeof(*req_props));
-
- for (cmd = rootnode->children; cmd; cmd = cmd->next) {
-
- if (0 == xmlStrcmp(cmd->name, BAD_CAST "prop")) {
- /* get prop by name */
- xmlNode *prop;
-
- for (prop = cmd->children; prop; prop = prop->next) {
- if (prop->type == XML_TEXT_NODE) continue; /* ignore WS */
-
- if (prop->ns &&
- (0 == xmlStrcmp(prop->ns->href, BAD_CAST "")) &&
- (0 != xmlStrcmp(prop->ns->prefix, BAD_CAST ""))) {
- size_t i;
-
- ERROR("no name space for: %s", prop->name);
-
- xmlFreeDoc(xml);
-
- for (i = 0; i < req_props->used; i++) {
- free(req_props->ptr[i]->ns);
- free(req_props->ptr[i]->prop);
- free(req_props->ptr[i]);
- }
- free(req_props->ptr);
- free(req_props);
-
- con->http_status = 400;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
-
- /* add property to requested list */
- if (req_props->size == 0) {
- req_props->size = 16;
- req_props->ptr = malloc(sizeof(*(req_props->ptr)) * req_props->size);
- } else if (req_props->used == req_props->size) {
- req_props->size += 16;
- req_props->ptr = realloc(req_props->ptr, sizeof(*(req_props->ptr)) * req_props->size);
- }
-
- req_props->ptr[req_props->used] = malloc(sizeof(webdav_property));
- req_props->ptr[req_props->used]->ns = (char *)xmlStrdup(prop->ns ? prop->ns->href : (xmlChar *)"");
- req_props->ptr[req_props->used]->prop = (char *)xmlStrdup(prop->name);
- req_props->used++;
- }
- } else if (0 == xmlStrcmp(cmd->name, BAD_CAST "propname")) {
- sqlite3_stmt *stmt = p->conf.stmt_select_propnames;
-
- if (stmt) {
- /* get all property names (EMPTY) */
- sqlite3_reset(stmt);
- /* bind the values to the insert */
-
- sqlite3_bind_text(stmt, 1,
- con->uri.path->ptr,
- con->uri.path->used - 1,
- SQLITE_TRANSIENT);
-
- if (SQLITE_DONE != sqlite3_step(stmt)) {
- }
- }
- } else if (0 == xmlStrcmp(cmd->name, BAD_CAST "allprop")) {
- /* get all properties (EMPTY) */
- }
- }
- }
-
- xmlFreeDoc(xml);
- } else {
- ERROR("webdav_parse_chunkqueue() failed: %s", "");
-
- con->http_status = 400;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
- }
-#endif
- 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->send);
-
- buffer_copy_string_len(b, CONST_STR_LEN("<?xml version=\"1.0\" encoding=\"utf-8\"?>\n"));
-
- buffer_append_string_len(b,CONST_STR_LEN("<D:multistatus xmlns:D=\"DAV:\" xmlns:ns0=\"urn:uuid:c2f41010-65b3-11d1-a29f-00aa00c14882/\">\n"));
-
- /* allprop */
-
- prop_200 = buffer_init();
- prop_404 = buffer_init();
-
- switch(depth) {
- case 0:
- /* Depth: 0 */
- webdav_get_props(srv, con, p, &(con->physical), req_props, prop_200, prop_404);
-
- buffer_append_string_len(b,CONST_STR_LEN("<D:response>\n"));
- buffer_append_string_len(b,CONST_STR_LEN("<D:href>"));
- buffer_append_string_buffer(b, con->uri.scheme);
- buffer_append_string_len(b,CONST_STR_LEN("://"));
- buffer_append_string_buffer(b, con->uri.authority);
- buffer_append_string_encoded(b, CONST_BUF_LEN(con->uri.path), ENCODING_REL_URI);
- buffer_append_string_len(b,CONST_STR_LEN("</D:href>\n"));
-
- if (!buffer_is_empty(prop_200)) {
- buffer_append_string_len(b,CONST_STR_LEN("<D:propstat>\n"));
- buffer_append_string_len(b,CONST_STR_LEN("<D:prop>\n"));
-
- buffer_append_string_buffer(b, prop_200);
-
- buffer_append_string_len(b,CONST_STR_LEN("</D:prop>\n"));
-
- buffer_append_string_len(b,CONST_STR_LEN("<D:status>HTTP/1.1 200 OK</D:status>\n"));
-
- buffer_append_string_len(b,CONST_STR_LEN("</D:propstat>\n"));
- }
- if (!buffer_is_empty(prop_404)) {
- buffer_append_string_len(b,CONST_STR_LEN("<D:propstat>\n"));
- buffer_append_string_len(b,CONST_STR_LEN("<D:prop>\n"));
-
- buffer_append_string_buffer(b, prop_404);
-
- buffer_append_string_len(b,CONST_STR_LEN("</D:prop>\n"));
-
- buffer_append_string_len(b,CONST_STR_LEN("<D:status>HTTP/1.1 404 Not Found</D:status>\n"));
-
- buffer_append_string_len(b,CONST_STR_LEN("</D:propstat>\n"));
- }
-
- buffer_append_string_len(b,CONST_STR_LEN("</D:response>\n"));
-
- break;
- case 1:
- if (NULL != (dir = opendir(con->physical.path->ptr))) {
- struct dirent *de;
- physical d;
- physical *dst = &(con->physical);
-
- d.path = buffer_init();
- d.rel_path = buffer_init();
-
- while(NULL != (de = readdir(dir))) {
- if (de->d_name[0] == '.' && de->d_name[1] == '.' && de->d_name[2] == '\0') {
- continue;
- /* ignore the parent dir */
- }
-
- buffer_copy_string_buffer(d.path, dst->path);
- PATHNAME_APPEND_SLASH(d.path);
-
- buffer_copy_string_buffer(d.rel_path, dst->rel_path);
- PATHNAME_APPEND_SLASH(d.rel_path);
-
- if (de->d_name[0] == '.' && de->d_name[1] == '\0') {
- /* don't append the . */
- } else {
- buffer_append_string(d.path, de->d_name);
- buffer_append_string(d.rel_path, de->d_name);
- }
-
- buffer_reset(prop_200);
- buffer_reset(prop_404);
-
- webdav_get_props(srv, con, p, &d, req_props, prop_200, prop_404);
-
- buffer_append_string_len(b,CONST_STR_LEN("<D:response>\n"));
- buffer_append_string_len(b,CONST_STR_LEN("<D:href>"));
- buffer_append_string_buffer(b, con->uri.scheme);
- buffer_append_string_len(b,CONST_STR_LEN("://"));
- buffer_append_string_buffer(b, con->uri.authority);
- buffer_append_string_encoded(b, CONST_BUF_LEN(d.rel_path), ENCODING_REL_URI);
- buffer_append_string_len(b,CONST_STR_LEN("</D:href>\n"));
-
- if (!buffer_is_empty(prop_200)) {
- buffer_append_string_len(b,CONST_STR_LEN("<D:propstat>\n"));
- buffer_append_string_len(b,CONST_STR_LEN("<D:prop>\n"));
-
- buffer_append_string_buffer(b, prop_200);
-
- buffer_append_string_len(b,CONST_STR_LEN("</D:prop>\n"));
-
- buffer_append_string_len(b,CONST_STR_LEN("<D:status>HTTP/1.1 200 OK</D:status>\n"));
-
- buffer_append_string_len(b,CONST_STR_LEN("</D:propstat>\n"));
- }
- if (!buffer_is_empty(prop_404)) {
- buffer_append_string_len(b,CONST_STR_LEN("<D:propstat>\n"));
- buffer_append_string_len(b,CONST_STR_LEN("<D:prop>\n"));
-
- buffer_append_string_buffer(b, prop_404);
-
- buffer_append_string_len(b,CONST_STR_LEN("</D:prop>\n"));
-
- buffer_append_string_len(b,CONST_STR_LEN("<D:status>HTTP/1.1 404 Not Found</D:status>\n"));
-
- buffer_append_string_len(b,CONST_STR_LEN("</D:propstat>\n"));
- }
-
- buffer_append_string_len(b,CONST_STR_LEN("</D:response>\n"));
- }
- closedir(dir);
- buffer_free(d.path);
- buffer_free(d.rel_path);
- }
- break;
- }
-
- if (req_props) {
- size_t i;
- for (i = 0; i < req_props->used; i++) {
- free(req_props->ptr[i]->ns);
- free(req_props->ptr[i]->prop);
- free(req_props->ptr[i]);
- }
- free(req_props->ptr);
- free(req_props);
- }
-
- buffer_free(prop_200);
- buffer_free(prop_404);
-
- buffer_append_string_len(b,CONST_STR_LEN("</D:multistatus>\n"));
-
- if (con->conf.log_request_handling) {
- TRACE("sending XML: %s",
- SAFE_BUF_STR(b));
- }
-
- if (p->conf.log_xml) {
- TRACE("XML-response-body: %s", SAFE_BUF_STR(b));
- }
- con->send->bytes_in += b->used-1;
- con->send->is_closed = 1;
-
- return HANDLER_FINISHED;
- case HTTP_METHOD_MKCOL:
- if (p->conf.is_readonly) {
- con->http_status = 403;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
-
- if (con->request.content_length > 0) {
- /* we don't support MKCOL with a body */
- con->http_status = 415;
- con->mode = DIRECT;
-
- return HANDLER_FINISHED;
- }
-
- /* let's create the directory */
-
- if (-1 == mkdir(con->physical.path->ptr, WEBDAV_DIR_MODE)) {
- switch(errno) {
- case EPERM:
- con->http_status = 403;
- break;
- case ENOENT:
- case ENOTDIR:
- con->http_status = 409;
- break;
- case EEXIST:
- default:
- con->http_status = 405; /* not allowed */
- break;
- }
- con->mode = DIRECT;
- } else {
- con->http_status = 201;
- con->send->is_closed = 1;
- }
-
- return HANDLER_FINISHED;
- case HTTP_METHOD_DELETE:
- if (p->conf.is_readonly) {
- con->http_status = 403;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
-
- /* does the client have a lock for this connection ? */
- if (!webdav_has_lock(srv, con, p, con->uri.path)) {
- con->http_status = 423;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
-
- /* stat and unlink afterwards */
- if (-1 == stat(con->physical.path->ptr, &st)) {
- /* don't about it yet, unlink will fail too */
- switch(errno) {
- case ENOENT:
- con->http_status = 404;
- break;
- default:
- con->http_status = 403;
- break;
- }
- con->mode = DIRECT;
- } else if (S_ISDIR(st.st_mode)) {
- buffer *multi_status_resp = buffer_init();
-
- if (webdav_delete_dir(srv, con, p, &(con->physical), multi_status_resp)) {
- /* we got an error somewhere in between, build a 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->send);
-
- buffer_copy_string_len(b, CONST_STR_LEN("<?xml version=\"1.0\" encoding=\"utf-8\"?>\n"));
-
- buffer_append_string_len(b,CONST_STR_LEN("<D:multistatus xmlns:D=\"DAV:\">\n"));
-
- buffer_append_string_buffer(b, multi_status_resp);
-
- buffer_append_string_len(b,CONST_STR_LEN("</D:multistatus>\n"));
-
- if (p->conf.log_xml) {
- log_error_write(srv, __FILE__, __LINE__, "sb", "XML-response-body:", b);
- }
-
- con->http_status = 207;
- con->send->bytes_in += b->used-1;
- con->send->is_closed = 1;
- } else {
- /* everything went fine, remove the directory */
-
- if (-1 == rmdir(con->physical.path->ptr)) {
- switch(errno) {
- case ENOENT:
- con->http_status = 404;
- break;
- default:
- con->http_status = 501;
- break;
- }
- con->mode = DIRECT;
- } else {
- con->http_status = 204;
- con->send->is_closed = 1;
- }
- }
-
- buffer_free(multi_status_resp);
- } else if (-1 == unlink(con->physical.path->ptr)) {
- switch(errno) {
- case EPERM:
- con->http_status = 403;
- break;
- case ENOENT:
- con->http_status = 404;
- break;
- default:
- con->http_status = 501;
- break;
- }
- con->mode = DIRECT;
- } else {
- con->http_status = 204;
- con->send->is_closed = 1;
- }
- return HANDLER_FINISHED;
- case HTTP_METHOD_PUT: {
- int fd;
- chunkqueue *cq = con->recv;
- chunk *c;
- data_string *ds_range;
-
- if (p->conf.is_readonly) {
- con->http_status = 403;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
-
- /* is a exclusive lock set on the source */
- if (!webdav_has_lock(srv, con, p, con->uri.path)) {
- con->http_status = 423;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
-
-
- if (chunkqueue_length(cq) != (off_t)con->request.content_length) {
- ERROR("%s", "chunkqueue_length didn't match request.content_length");
- con->http_status = 500;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
-
- /* RFC2616 Section 9.6 PUT requires us to send 501 on all Content-* we don't support
- * - most important Content-Range
- *
- *
- * Example: Content-Range: bytes 100-1037/1038 */
-
- if (NULL != (ds_range = (data_string *)array_get_element(con->request.headers, CONST_STR_LEN("Content-Range")))) {
- const char *num = ds_range->value->ptr;
- off_t offset;
- char *err = NULL;
-
- if (0 != strncmp(num, "bytes ", 6)) {
- con->http_status = 501; /* not implemented */
- con->mode = DIRECT;
-
- return HANDLER_FINISHED;
- }
-
- /* we only support <num>- ... */
-
- num += 6;
-
- /* skip WS */
- while (*num == ' ' || *num == '\t') num++;
-
- if (*num == '\0') {
- con->http_status = 501; /* not implemented */
- con->mode = DIRECT;
-
- return HANDLER_FINISHED;
- }
-
- offset = str_to_off_t(num, &err, 10);
-
- if (offset == STR_OFF_T_MAX ||
- offset == STR_OFF_T_MIN) {
- /**
- * conversion did a over- or underrun
- */
- con->http_status = 501; /* not implemented */
- con->mode = DIRECT;
-
- return HANDLER_FINISHED;
- }
-
- if (*err != '-' || offset < 0) {
- con->http_status = 501; /* not implemented */
- con->mode = DIRECT;
-
- return HANDLER_FINISHED;
- }
-
- if (-1 == (fd = open(con->physical.path->ptr, O_WRONLY, WEBDAV_FILE_MODE))) {
- switch (errno) {
- case ENOENT:
- con->http_status = 404; /* not found */
- break;
- default:
- con->http_status = 403; /* not found */
- break;
- }
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
-
- if (-1 == lseek(fd, offset, SEEK_SET)) {
- con->http_status = 501; /* not implemented */
- con->mode = DIRECT;
-
- close(fd);
-
- return HANDLER_FINISHED;
- }
- con->http_status = 200; /* modified */
- } else {
- /* take what we have in the request-body and write it to a file */
-
- /* if the file doesn't exist, create it */
- if (-1 == (fd = open(con->physical.path->ptr, O_WRONLY|O_TRUNC, WEBDAV_FILE_MODE))) {
- if (errno == ENOENT &&
- -1 == (fd = open(con->physical.path->ptr, O_WRONLY|O_CREAT|O_TRUNC|O_EXCL, WEBDAV_FILE_MODE))) {
- /* we can't open the file */
- con->http_status = 403;
- con->mode = DIRECT;
-
- return HANDLER_FINISHED;
- } else {
- con->http_status = 201; /* created */
- }
- } else {
- con->http_status = 200; /* modified */
- }
- }
-
- con->send->is_closed = 1;
-
- for (c = cq->first; c; c = cq->first) {
- int r = 0;
-
- /* copy all chunks */
- switch(c->type) {
- case FILE_CHUNK:
-
- if (c->file.mmap.start == MAP_FAILED) {
- if (-1 == c->file.fd && /* open the file if not already open */
- -1 == (c->file.fd = open(c->file.name->ptr, O_RDONLY))) {
- log_error_write(srv, __FILE__, __LINE__, "ss", "open failed: ", strerror(errno));
-
- return HANDLER_ERROR;
- }
-
- if (MAP_FAILED == (c->file.mmap.start = mmap(0, c->file.length, PROT_READ, MAP_SHARED, c->file.fd, 0))) {
- log_error_write(srv, __FILE__, __LINE__, "ssbd", "mmap failed: ",
- strerror(errno), c->file.name, c->file.fd);
-
- return HANDLER_ERROR;
- }
-
- c->file.mmap.length = c->file.length;
-
- close(c->file.fd);
- c->file.fd = -1;
-
- /* chunk_reset() or chunk_free() will cleanup for us */
- }
-
- if ((r = write(fd, c->file.mmap.start + c->offset, c->file.length - c->offset)) < 0) {
- switch(errno) {
- case ENOSPC:
- con->http_status = 507;
-
- break;
- default:
- con->http_status = 403;
- break;
- }
- }
- break;
- case MEM_CHUNK:
- if ((r = write(fd, c->mem->ptr + c->offset, c->mem->used - c->offset - 1)) < 0) {
- switch(errno) {
- case ENOSPC:
- con->http_status = 507;
-
- break;
- default:
- con->http_status = 403;
- break;
- }
- }
- break;
- case UNUSED_CHUNK:
- break;
- }
-
- if (r > 0) {
- c->offset += r;
- cq->bytes_out += r;
- } else {
- break;
- }
- chunkqueue_remove_finished_chunks(cq);
- }
- close(fd);
-
- return HANDLER_FINISHED;
- }
- case HTTP_METHOD_MOVE:
- case HTTP_METHOD_COPY: {
- buffer *destination = NULL;
- char *sep, *start;
- int overwrite = 1;
-
- if (p->conf.is_readonly) {
- con->http_status = 403;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
-
- /* is a exclusive lock set on the source */
- if (con->request.http_method == HTTP_METHOD_MOVE) {
- if (!webdav_has_lock(srv, con, p, con->uri.path)) {
- con->http_status = 423;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
- }
-
- if (NULL != (ds = (data_string *)array_get_element(con->request.headers, CONST_STR_LEN("Destination")))) {
- destination = ds->value;
- } else {
- con->http_status = 400;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
-
- if (NULL != (ds = (data_string *)array_get_element(con->request.headers, CONST_STR_LEN("Overwrite")))) {
- if (ds->value->used != 2 ||
- (ds->value->ptr[0] != 'F' &&
- ds->value->ptr[0] != 'T') ) {
- con->http_status = 400;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
- overwrite = (ds->value->ptr[0] == 'F' ? 0 : 1);
- }
- /* let's parse the Destination
- *
- * http://127.0.0.1:1025/dav/litmus/copydest
- *
- * - host has to be the same as the Host: header we got
- * - we have to stay inside the document root
- * - the query string is thrown away
- * */
-
- buffer_reset(p->uri.scheme);
- buffer_reset(p->uri.path_raw);
- buffer_reset(p->uri.authority);
-
- start = destination->ptr;
-
- if (NULL == (sep = strstr(start, "://"))) {
- con->http_status = 400;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
- buffer_copy_string_len(p->uri.scheme, start, sep - start);
-
- start = sep + 3;
-
- if (NULL == (sep = strchr(start, '/'))) {
- con->http_status = 400;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
- buffer_copy_string_len(p->uri.authority, start, sep - start);
-
- start = sep + 1;
-
- if (NULL == (sep = strchr(start, '?'))) {
- /* no query string, good */
- buffer_copy_string(p->uri.path_raw, start);
- } else {
- buffer_copy_string_len(p->uri.path_raw, start, sep - start);
- }
-
- if (!buffer_is_equal(p->uri.authority, con->uri.authority)) {
- /* not the same host */
- con->http_status = 502;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
-
- buffer_copy_string_buffer(p->tmp_buf, p->uri.path_raw);
- buffer_urldecode_path(p->tmp_buf);
- buffer_path_simplify(p->uri.path, p->tmp_buf);
-
- /* we now have a URI which is clean. transform it into a physical path */
- buffer_copy_string_buffer(p->physical.doc_root, con->physical.doc_root);
- buffer_copy_string_buffer(p->physical.rel_path, p->uri.path);
-
- if (con->conf.force_lowercase_filenames) {
- buffer_to_lower(p->physical.rel_path);
- }
-
- buffer_copy_string_buffer(p->physical.path, p->physical.doc_root);
- PATHNAME_APPEND_SLASH(p->physical.path);
- buffer_copy_string_buffer(p->physical.basedir, p->physical.path);
-
- /* don't add a second / */
- if (p->physical.rel_path->ptr[0] == '/') {
- buffer_append_string_len(p->physical.path, p->physical.rel_path->ptr + 1, p->physical.rel_path->used - 2);
- } else {
- buffer_append_string_buffer(p->physical.path, p->physical.rel_path);
- }
-
- /* let's see if the source is a directory
- * if yes, we fail with 501 */
-
- if (-1 == stat(con->physical.path->ptr, &st)) {
- /* don't about it yet, unlink will fail too */
- switch(errno) {
- case ENOENT:
- con->http_status = 404;
- break;
- default:
- con->http_status = 403;
- break;
- }
- con->mode = DIRECT;
- } else if (S_ISDIR(st.st_mode)) {
- int r;
- /* src is a directory */
-
- con->http_status = 204;
- con->send->is_closed = 1;
- if (-1 == stat(p->physical.path->ptr, &st)) {
- if (-1 == mkdir(p->physical.path->ptr, WEBDAV_DIR_MODE)) {
- con->http_status = 403;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
- con->http_status = 201;
- } else if (!S_ISDIR(st.st_mode)) {
- if (overwrite == 0) {
- /* copying into a non-dir ? */
- con->http_status = 409;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- } else {
- unlink(p->physical.path->ptr);
- if (-1 == mkdir(p->physical.path->ptr, WEBDAV_DIR_MODE)) {
- con->http_status = 403;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
- }
- }
-
- /* copy the content of src to dest */
- if (0 != (r = webdav_copy_dir(srv, con, p, &(con->physical), &(p->physical), overwrite))) {
- con->http_status = r;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
- if (con->request.http_method == HTTP_METHOD_MOVE) {
- b = buffer_init();
- webdav_delete_dir(srv, con, p, &(con->physical), b); /* content */
- buffer_free(b);
-
- rmdir(con->physical.path->ptr);
- }
- } else {
- /* it is just a file, good */
- int r;
-
- /* does the client have a lock for this connection ? */
- if (!webdav_has_lock(srv, con, p, p->uri.path)) {
- con->http_status = 423;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
-
- /* destination exists */
- if (0 == (r = stat(p->physical.path->ptr, &st))) {
- if (S_ISDIR(st.st_mode)) {
- /* file to dir/
- * append basename to physical path */
-
- if (NULL != (sep = strrchr(con->physical.path->ptr, '/'))) {
- buffer_append_string(p->physical.path, sep);
- r = stat(p->physical.path->ptr, &st);
- }
- }
- }
-
- if (-1 == r) {
- con->http_status = 201; /* we will create a new one */
- con->send->is_closed = 1;
-
- switch(errno) {
- case ENOTDIR:
- con->http_status = 409;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
- } else if (overwrite == 0) {
- /* destination exists, but overwrite is not set */
- con->http_status = 412;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- } else {
- con->http_status = 204; /* resource already existed */
- con->send->is_closed = 1;
- }
-
- if (con->request.http_method == HTTP_METHOD_MOVE) {
- /* try a rename */
-
- if (0 == rename(con->physical.path->ptr, p->physical.path->ptr)) {
-#ifdef USE_PROPPATCH
- sqlite3_stmt *stmt = p->conf.stmt_move_uri;
-
- if (stmt) {
-
- sqlite3_reset(stmt);
-
- /* bind the values to the insert */
- sqlite3_bind_text(stmt, 1,
- p->uri.path->ptr,
- p->uri.path->used - 1,
- SQLITE_TRANSIENT);
-
- sqlite3_bind_text(stmt, 2,
- con->uri.path->ptr,
- con->uri.path->used - 1,
- SQLITE_TRANSIENT);
-
- if (SQLITE_DONE != sqlite3_step(stmt)) {
- log_error_write(srv, __FILE__, __LINE__, "ss", "sql-move failed:", sqlite3_errmsg(p->conf.sql));
- }
- }
-#endif
- return HANDLER_FINISHED;
- }
-
- /* rename failed, fall back to COPY + DELETE */
- }
-
- if (0 != (r = webdav_copy_file(srv, con, p, &(con->physical), &(p->physical), overwrite))) {
- con->http_status = r;
- con->mode = DIRECT;
-
- return HANDLER_FINISHED;
- }
-
- if (con->request.http_method == HTTP_METHOD_MOVE) {
- b = buffer_init();
- webdav_delete_file(srv, con, p, &(con->physical), b);
- buffer_free(b);
- }
- }
-
- return HANDLER_FINISHED;
- }
- case HTTP_METHOD_PROPPATCH:
- if (p->conf.is_readonly) {
- con->http_status = 403;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
-
- if (!webdav_has_lock(srv, con, p, con->uri.path)) {
- con->http_status = 423;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
-
- /* check if destination exists */
- if (-1 == stat(con->physical.path->ptr, &st)) {
- switch(errno) {
- case ENOENT:
- con->http_status = 404;
- con->mode = DIRECT;
- break;
- }
- }
-
-#ifdef USE_PROPPATCH
- if (p->conf.sql && con->request.content_length > 0) {
- xmlDocPtr xml;
-
- if (1 == webdav_parse_chunkqueue(srv, con, p, con->recv, &xml)) {
- xmlNode *rootnode = xmlDocGetRootElement(xml);
-
- if (0 == xmlStrcmp(rootnode->name, BAD_CAST "propertyupdate")) {
- xmlNode *cmd;
- char *err = NULL;
- int empty_ns = 0; /* send 400 on a empty namespace attribute */
-
- /* start response */
-
- if (SQLITE_OK != sqlite3_exec(p->conf.sql, "BEGIN TRANSACTION", NULL, NULL, &err)) {
- log_error_write(srv, __FILE__, __LINE__, "ss", "can't open transaction:", err);
- sqlite3_free(err);
-
- goto propmatch_cleanup;
- }
-
- /* a UPDATE request, we know 'set' and 'remove' */
- for (cmd = rootnode->children; cmd; cmd = cmd->next) {
- xmlNode *props;
- /* either set or remove */
-
- if ((0 == xmlStrcmp(cmd->name, BAD_CAST "set")) ||
- (0 == xmlStrcmp(cmd->name, BAD_CAST "remove"))) {
-
- sqlite3_stmt *stmt;
-
- stmt = (0 == xmlStrcmp(cmd->name, BAD_CAST "remove")) ?
- p->conf.stmt_delete_prop : p->conf.stmt_update_prop;
-
- for (props = cmd->children; props; props = props->next) {
- if (0 == xmlStrcmp(props->name, BAD_CAST "prop")) {
- xmlNode *prop;
- int r;
-
- prop = props->children;
-
- if (prop->ns &&
- (0 == xmlStrcmp(prop->ns->href, BAD_CAST "")) &&
- (0 != xmlStrcmp(prop->ns->prefix, BAD_CAST ""))) {
- log_error_write(srv, __FILE__, __LINE__, "ss",
- "no name space for:",
- prop->name);
-
- empty_ns = 1;
- break;
- }
-
- sqlite3_reset(stmt);
-
- /* bind the values to the insert */
-
- sqlite3_bind_text(stmt, 1,
- con->uri.path->ptr,
- con->uri.path->used - 1,
- SQLITE_TRANSIENT);
- sqlite3_bind_text(stmt, 2,
- (char *)prop->name,
- strlen((char *)prop->name),
- SQLITE_TRANSIENT);
- if (prop->ns) {
- sqlite3_bind_text(stmt, 3,
- (char *)prop->ns->href,
- strlen((char *)prop->ns->href),
- SQLITE_TRANSIENT);
- } else {
- sqlite3_bind_text(stmt, 3,
- "",
- 0,
- SQLITE_TRANSIENT);
- }
- if (stmt == p->conf.stmt_update_prop) {
- sqlite3_bind_text(stmt, 4,
- (char *)xmlNodeGetContent(prop),
- strlen((char *)xmlNodeGetContent(prop)),
- SQLITE_TRANSIENT);
- }
-
- if (SQLITE_DONE != (r = sqlite3_step(stmt))) {
- log_error_write(srv, __FILE__, __LINE__, "ss",
- "sql-set failed:", sqlite3_errmsg(p->conf.sql));
- }
- }
- }
- if (empty_ns) break;
- }
- }
-
- if (empty_ns) {
- if (SQLITE_OK != sqlite3_exec(p->conf.sql, "ROLLBACK", NULL, NULL, &err)) {
- log_error_write(srv, __FILE__, __LINE__, "ss", "can't rollback transaction:", err);
- sqlite3_free(err);
-
- goto propmatch_cleanup;
- }
-
- con->http_status = 400;
- con->mode = DIRECT;
- } else {
- if (SQLITE_OK != sqlite3_exec(p->conf.sql, "COMMIT", NULL, NULL, &err)) {
- log_error_write(srv, __FILE__, __LINE__, "ss", "can't commit transaction:", err);
- sqlite3_free(err);
-
- goto propmatch_cleanup;
- }
- con->http_status = 200;
- }
- con->send->is_closed = 1;
-
- return HANDLER_FINISHED;
- }
-
-propmatch_cleanup:
-
- xmlFreeDoc(xml);
- } else {
- con->http_status = 400;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
- }
-#endif
- con->http_status = 501;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- case HTTP_METHOD_LOCK:
- /**
- * a mac wants to write
- *
- * LOCK /dav/expire.txt HTTP/1.1\r\n
- * User-Agent: WebDAVFS/1.3 (01308000) Darwin/8.1.0 (Power Macintosh)\r\n
- * Accept: * / *\r\n
- * Depth: 0\r\n
- * Timeout: Second-600\r\n
- * Content-Type: text/xml; charset=\"utf-8\"\r\n
- * Content-Length: 229\r\n
- * Connection: keep-alive\r\n
- * Host: 192.168.178.23:1025\r\n
- * \r\n
- * <?xml version=\"1.0\" encoding=\"utf-8\"?>\n
- * <D:lockinfo xmlns:D=\"DAV:\">\n
- * <D:lockscope><D:exclusive/></D:lockscope>\n
- * <D:locktype><D:write/></D:locktype>\n
- * <D:owner>\n
- * <D:href>http://www.apple.com/webdav_fs/</D:href>\n
- * </D:owner>\n
- * </D:lockinfo>\n
- */
-
- if (depth != 0 && depth != -1) {
- con->http_status = 400;
- con->mode = DIRECT;
-
- return HANDLER_FINISHED;
- }
-
-#ifdef USE_LOCKS
- if (p->conf.sql && con->request.content_length > 0) {
- xmlDocPtr xml;
- buffer *hdr_if = NULL;
-
- if (NULL != (ds = (data_string *)array_get_element(con->request.headers, CONST_STR_LEN("If")))) {
- hdr_if = ds->value;
- }
-
- /* we don't support Depth: Infinity on locks */
- if (hdr_if == NULL && depth == -1) {
- con->http_status = 409; /* Conflict */
- con->mode = DIRECT;
-
- return HANDLER_FINISHED;
- }
-
- if (1 == webdav_parse_chunkqueue(srv, con, p, con->recv, &xml)) {
- xmlNode *rootnode = xmlDocGetRootElement(xml);
-
- assert(rootnode);
-
- if (0 == xmlStrcmp(rootnode->name, BAD_CAST "lockinfo")) {
- xmlNode *lockinfo;
- const xmlChar *lockscope = NULL, *locktype = NULL; /* unused variable: , *owner = NULL; */
-
- for (lockinfo = rootnode->children; lockinfo; lockinfo = lockinfo->next) {
- if (0 == xmlStrcmp(lockinfo->name, BAD_CAST "lockscope")) {
- xmlNode *value;
- for (value = lockinfo->children; value; value = value->next) {
- if ((0 == xmlStrcmp(value->name, BAD_CAST "exclusive")) ||
- (0 == xmlStrcmp(value->name, BAD_CAST "shared"))) {
- lockscope = value->name;
- } else {
- con->http_status = 400;
- con->mode = DIRECT;
-
- xmlFreeDoc(xml);
- return HANDLER_FINISHED;
- }
- }
- } else if (0 == xmlStrcmp(lockinfo->name, BAD_CAST "locktype")) {
- xmlNode *value;
- for (value = lockinfo->children; value; value = value->next) {
- if ((0 == xmlStrcmp(value->name, BAD_CAST "write"))) {
- locktype = value->name;
- } else {
- con->http_status = 400;
- con->mode = DIRECT;
-
- xmlFreeDoc(xml);
- return HANDLER_FINISHED;
- }
- }
-
- } else if (0 == xmlStrcmp(lockinfo->name, BAD_CAST "owner")) {
- }
- }
-
- if (lockscope && locktype) {
- sqlite3_stmt *stmt = p->conf.stmt_read_lock_by_uri;
-
- /* is this resourse already locked ? */
-
- /* SELECT locktoken, resource, lockscope, locktype, owner, depth, timeout
- * FROM locks
- * WHERE resource = ? */
-
- if (stmt) {
-
- sqlite3_reset(stmt);
-
- sqlite3_bind_text(stmt, 1,
- p->uri.path->ptr,
- p->uri.path->used - 1,
- SQLITE_TRANSIENT);
-
- /* it is the PK */
- while (SQLITE_ROW == sqlite3_step(stmt)) {
- /* we found a lock
- * 1. is it compatible ?
- * 2. is it ours */
- char *sql_lockscope = (char *)sqlite3_column_text(stmt, 2);
-
- if (strcmp(sql_lockscope, "exclusive")) {
- con->http_status = 423;
- con->mode = DIRECT;
- } else if (0 == xmlStrcmp(lockscope, BAD_CAST "exclusive")) {
- /* resourse is locked with a shared lock
- * client wants exclusive */
- con->http_status = 423;
- con->mode = DIRECT;
- }
- }
- if (con->http_status == 423) {
- xmlFreeDoc(xml);
- return HANDLER_FINISHED;
- }
- }
-
- stmt = p->conf.stmt_create_lock;
- if (stmt) {
- /* create a lock-token */
- uuid_t id;
- char uuid[37] /* 36 + \0 */;
-
- uuid_generate(id);
- uuid_unparse(id, uuid);
-
- buffer_copy_string_len(p->tmp_buf, CONST_STR_LEN("opaquelocktoken:"));
- buffer_append_string(p->tmp_buf, uuid);
-
- /* "CREATE TABLE locks ("
- * " locktoken TEXT NOT NULL,"
- * " resource TEXT NOT NULL,"
- * " lockscope TEXT NOT NULL,"
- * " locktype TEXT NOT NULL,"
- * " owner TEXT NOT NULL,"
- * " depth INT NOT NULL,"
- */
-
- sqlite3_reset(stmt);
-
- sqlite3_bind_text(stmt, 1,
- CONST_BUF_LEN(p->tmp_buf),
- SQLITE_TRANSIENT);
-
- sqlite3_bind_text(stmt, 2,
- CONST_BUF_LEN(con->uri.path),
- SQLITE_TRANSIENT);
-
- sqlite3_bind_text(stmt, 3,
- (const char *)lockscope,
- xmlStrlen(lockscope),
- SQLITE_TRANSIENT);
-
- sqlite3_bind_text(stmt, 4,
- (const char *)locktype,
- +xmlStrlen(locktype),
- SQLITE_TRANSIENT);
-
- /* owner */
- sqlite3_bind_text(stmt, 5,
- "",
- 0,
- SQLITE_TRANSIENT);
-
- /* depth */
- sqlite3_bind_int(stmt, 6,
- depth);
-
-
- if (SQLITE_DONE != sqlite3_step(stmt)) {
- log_error_write(srv, __FILE__, __LINE__, "ss",
- "create lock:", sqlite3_errmsg(p->conf.sql));
- }
-
- /* looks like we survived */
- webdav_lockdiscovery(srv, con, p->tmp_buf, (const char *)lockscope, (const char *)locktype, depth);
-
- con->http_status = 201;
- con->send->is_closed = 1;
- }
- }
- }
-
- xmlFreeDoc(xml);
- return HANDLER_FINISHED;
- } else {
- con->http_status = 400;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
- }
- } else {
-
- if (NULL != (ds = (data_string *)array_get_element(con->request.headers, CONST_STR_LEN("If")))) {
- buffer *locktoken = ds->value;
- sqlite3_stmt *stmt = p->conf.stmt_refresh_lock;
-
- /* remove the < > around the token */
- if (locktoken->used < 6) {
- con->http_status = 400;
- con->mode = DIRECT;
-
- return HANDLER_FINISHED;
- }
-
- buffer_copy_string_len(p->tmp_buf, locktoken->ptr + 2, locktoken->used - 5);
-
- sqlite3_reset(stmt);
-
- sqlite3_bind_text(stmt, 1,
- CONST_BUF_LEN(p->tmp_buf),
- SQLITE_TRANSIENT);
-
- if (SQLITE_DONE != sqlite3_step(stmt)) {
- TRACE("refresh lock failed: %s", sqlite3_errmsg(p->conf.sql));
- }
-
- webdav_lockdiscovery(srv, con, p->tmp_buf, "exclusive", "write", 0);
-
- con->http_status = 200;
- con->send->is_closed = 1;
- return HANDLER_FINISHED;
- } else {
- /* we need a lock-token to refresh */
- con->http_status = 400;
- con->mode = DIRECT;
-
- return HANDLER_FINISHED;
- }
- }
- break;
-#else
- con->http_status = 501;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
-#endif
- case HTTP_METHOD_UNLOCK:
-#ifdef USE_LOCKS
- if (NULL != (ds = (data_string *)array_get_element(con->request.headers, CONST_STR_LEN("Lock-Token")))) {
- buffer *locktoken = ds->value;
- sqlite3_stmt *stmt = p->conf.stmt_remove_lock;
-
- /* remove the < > around the token */
- if (locktoken->used < 4) {
- con->http_status = 400;
- con->mode = DIRECT;
-
- return HANDLER_FINISHED;
- }
-
- /**
- * FIXME:
- *
- * if the resourse is locked:
- * - by us: unlock
- * - by someone else: 401
- * if the resource is not locked:
- * - 412
- * */
-
- buffer_copy_string_len(p->tmp_buf, locktoken->ptr + 1, locktoken->used - 3);
-
- sqlite3_reset(stmt);
-
- sqlite3_bind_text(stmt, 1,
- CONST_BUF_LEN(p->tmp_buf),
- SQLITE_TRANSIENT);
-
- sqlite3_bind_text(stmt, 2,
- CONST_BUF_LEN(con->uri.path),
- SQLITE_TRANSIENT);
-
- if (SQLITE_DONE != sqlite3_step(stmt)) {
- log_error_write(srv, __FILE__, __LINE__, "ss",
- "remove lock:", sqlite3_errmsg(p->conf.sql));
- }
-
- if (0 == sqlite3_changes(p->conf.sql)) {
- con->http_status = 401;
- con->mode = DIRECT;
- } else {
- con->http_status = 204;
- con->send->is_closed = 1;
- }
- return HANDLER_FINISHED;
- } else {
- /* we need a lock-token to unlock */
- con->http_status = 400;
- con->mode = DIRECT;
-
- return HANDLER_FINISHED;
- }
- break;
-#else
- con->http_status = 501;
- con->mode = DIRECT;
- return HANDLER_FINISHED;
-#endif
- default:
- break;
- }
-
- /* not found */
- return HANDLER_GO_ON;
-}
-
-/**
- * calls the request-handler if we have received all the content
- */
-CONNECTION_FUNC(mod_webdav_recv_request_content) {
- chunkqueue *in = con->recv;
- plugin_data *p = p_d;
- handler_t res;
-
- /**
- * is the content for webdav
- */
- if (con->mode != p->id) return HANDLER_GO_ON;
-
- if (!in->is_closed) return HANDLER_GO_ON;
-
- /* we received all the content, let's call the webdav handler */
-
- res = mod_webdav_subrequest_handler(srv, con, p_d);
-
- /* mark body as read */
- con->recv->bytes_out += chunkqueue_skip(con->recv, con->recv->bytes_in - con->recv->bytes_out);
- chunkqueue_remove_finished_chunks(con->recv);
-
- return res;
-}
-
-/* this function is called at dlopen() time and inits the callbacks */
-
-LI_EXPORT int mod_webdav_plugin_init(plugin *p);
-LI_EXPORT 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; /* check if we handle this URL */
-#if 0
- /* will get called when the content is received */
-#endif
- p->handle_physical = mod_webdav_physical_handler;
- p->handle_send_request_content = mod_webdav_recv_request_content; /* check if we received all the content */
- p->set_defaults = mod_webdav_set_defaults;
- p->cleanup = mod_webdav_free;
-
- p->data = NULL;
-
- return 0;
-}
View Lorry Controller Status