Logo Search packages:      
Sourcecode: davfs2 version File versions

webdav.c

/* 
** Send requests to the WebDAV server.
 */

/*
 *  This file is part of davfs2.
 *
 *  davfs2 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; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  davfs2 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 davfs2; if not, write to the Free Software
 *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
 */


#include "config.h"

#include <argz.h>
#include <errno.h>
#include <error.h>
#include <fcntl.h>
#include <iconv.h>
#include <langinfo.h>
#include <limits.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <syslog.h>
#include <time.h>
#include <unistd.h>

#include <sys/stat.h>

#ifdef ENABLE_NLS
#   include <libintl.h>
#   define _(String) gettext(String)
#else
#   define _(String) String
#endif

#include <ne_alloc.h>
#include <ne_auth.h>
#include <ne_basic.h>
#include <ne_dates.h>
#include <ne_locks.h>
#include <ne_props.h>
#include <ne_request.h>
#include <ne_session.h>
#include <ne_socket.h>
#include <ne_string.h>
#include <ne_uri.h>
#include <ne_utils.h>
#include <ne_xml.h>

#include "defaults.h"
#include "webdav.h"


/* Data Types */
/*============*/

/* Data structures used as userdata in neon callback functions. */

typedef struct {
    const char *path;           /* The *not* url-encoded path. */
    dav_props *results;         /* Start of the linked list of dav_props. */
} propfind_context;

typedef struct {
    int error;                  /* An error occured while reading/writing. */
    const char *file;           /* cache_file to store the data in. */
    int fd;                     /* file descriptor of the open cache file. */
} get_context;

typedef struct {
    off_t available;            /* Available bytes. */
    off_t used;                 /* Used bytes. */
} quota_context;


/* Private constants */
/*===================*/

/* Properties to be retrieved from the server. This constants
   are used by dav_get_collection(). */
enum {
    NAME = 0,
    ETAG,
    LENGTH,
    CREATION,
    MODIFIED,
    TYPE,
    EXECUTE,
    END
};

static const ne_propname prop_names[] = {
    [NAME] = {"DAV:", "displayname"},
    [ETAG] = {"DAV:", "getetag"},
    [LENGTH] = {"DAV:", "getcontentlength"},
    [CREATION] ={"DAV:", "creationdate"},
    [MODIFIED] = {"DAV:", "getlastmodified"},
    [TYPE] = {"DAV:", "resourcetype"},
    [EXECUTE] = {"http://apache.org/dav/props/", "executable"},
    [END] = {NULL, NULL}
};

/* Properties to be retrieved from the server. This constants
   are used by dav_quota(). */
enum {
    AVAILABLE = 0,
    USED
};

static const ne_propname quota_names[] = {
    [AVAILABLE] = {"DAV:", "quota-available-bytes"},
    [USED] = {"DAV:", "quota-used-bytes"},
    {NULL, NULL}
};

static size_t log_bufsize = 512;

static char *none_match_header = "If-None-Match: *\n";


/* Private global variables */
/*==========================*/

/* The neon session.
   Will be set by dav_init_webdav(). */
static ne_session *session;

/* Lock store, lock owner and lock timeout for session.
   Will be set by dav_init_webdav(). */
static ne_lock_store *locks;
static char *owner;
static time_t lock_timeout;

/* Credentials for this session. Will be set by dav_init_webdav(). */
static char *username;
static char *password;
static char *p_username;
static char *p_password;

/* Whether to use the displayname property for file and directory names. */
static int use_displayname;

/* Whether to send expect 100-continue header in PUT requests. */
static int use_expect100;

/* Whether to use HEAD for prechecking instead of If-Match and If-None-Match
   on PTU and LOCK. */
static int has_if_match_bug;

/* Some servers sends a weak invalid etag that turns into a valid strong etag
   after one second. With this flag set, the weakness indicator is removed,
   otherwise the etag is not used at all. */
static int drop_weak_etags;

/* Check with HEAD for existence or modification of a file, before locking or
   uploading a new file. */
static int precheck;

/* Ignore the information in the DAV-header because it is wrong. */
static int ignore_dav_header;

/* The url for this session. Contains anything needed except path.
   Will be initialized by dav_init_webdav() and used by various functions.
   These will add path, use suri in calls to neon functions and finally
   free path. path must allways be initialized before use, as it may
   point to anything. */
static ne_uri *suri;

/* Will be set to 1 when dav_init_connection() succeeded. */
static int initialized;

/* Whether a terminal is available to communicate with the user.
   Should be reset with set_no_terminal() when forking into daemon mode.
   Needed by  ssl_verify() which may be called at any time. */
static int have_terminal = 1;

/* Handle to convert character encoding from utf-8 to LC_CTYPE.
   If NULL no conversion is done. */
static iconv_t from_utf_8;

/* Handle to convert character encoding from LC_CTYPE to utf-8.
   If NULL no conversion is done. */
static iconv_t to_utf_8;

/* Handle to convert character encing of path names to LC_CTYPE. If NULL
   no conversion is done. */
static iconv_t from_server_enc;

/* Handle to convert from LC_CTYPE to character encoding of path names.
   If NULL no conversion is done. */
static iconv_t to_server_enc;

/* A GNU custom stream, used to redirect neon debug messages to syslog. */
static FILE *log_stream;

#if NE_VERSION_MINOR > 25
/* Session cookie. */
static char *cookie;
#endif


/* Private function prototypes and inline functions */
/*==================================================*/

static void convert(char **s, iconv_t conv);

static int get_error(int ret, const char *method);

static int get_ne_error(const char *method);

static int lock_discover(const char *spath, time_t *expire);

static void lock_refresh(struct ne_lock *lock, time_t *expire);

static ssize_t log_writer(void *cookie, const char *buffer, size_t size);

static void replace_slashes(char **name);

/* Call-back functions for neon. */

static void add_header(ne_request *req, void *userdata, ne_buffer *header);

static int auth(void *userdata, const char *realm, int attempt, char *user,
                char *pwd);

static int block_writer(void *userdata, const char *block, size_t length);

#if NE_VERSION_MINOR < 26
static void lock_result(void *userdata, const struct ne_lock *lock, 
                                    const char *uri, const ne_status *status);

static void prop_result(void *userdata, const char *href,
                         const ne_prop_result_set *set);

static void quota_result(void *userdata, const char *href,
                         const ne_prop_result_set *set);
#else
static void lock_result(void *userdata, const struct ne_lock *lock, 
                                    const ne_uri *uri, const ne_status *status);

static void prop_result(void *userdata, const ne_uri *uri,
                         const ne_prop_result_set *set);

static void quota_result(void *userdata, const ne_uri *uri,
                         const ne_prop_result_set *set);
#endif

static int ssl_verify(void *userdata, int failures,
                      const ne_ssl_certificate *cert);

#if NE_VERSION_MINOR > 25
static int update_cookie(ne_request *req, void *userdata,
                         const ne_status *status);
#endif


/* Public functions */
/*==================*/

void dav_init_webdav(const char *scheme, const char *host, int port,
                     time_t connect_timeout, time_t read_timeout, int use_locks,
                     time_t l_timeout, const char *servercert,
                     const char *clicert, const char *clicert_pw, int askauth,
                     const char *user, const char *passwd, int useproxy,
                     const char *p_host, int p_port, const char *p_user,
                     const char *p_passwd, const char *lock_owner,
                     int displayname, int expect100, int if_match_bug,
                     int d_w_etags, const char *s_charset, const char *header,
                     int allow_cookie, int prechck, int ignore_dav_hdr,
                     int debug) {

    if (debug & ~NE_DBG_HTTPPLAIN)
        syslog(LOG_MAKEPRI(LOG_DAEMON, LOG_DEBUG), "Initializing webdav");

    char *lc_charset = nl_langinfo(CODESET);
    if (lc_charset != NULL && strcasecmp(lc_charset, "UTF-8") != 0) {
        from_utf_8 = iconv_open(lc_charset, "UTF-8");
        if (from_utf_8 == (iconv_t) -1)
            from_utf_8 = 0;
        to_utf_8 = iconv_open("UTF-8", lc_charset);
        if (to_utf_8 == (iconv_t) -1)
            to_utf_8 = 0;
    }

    if (lc_charset != NULL && s_charset != NULL
            && (strcasecmp(s_charset, lc_charset) != 0)) {
        if (strcasecmp(s_charset, "UTF-8") == 0) {
            from_server_enc = from_utf_8;
            to_server_enc = to_utf_8;
        } else {
            from_server_enc = iconv_open(lc_charset, s_charset);
            if (from_server_enc == (iconv_t) -1)
                from_server_enc = 0;
            to_server_enc = iconv_open(s_charset, lc_charset);
            if (to_server_enc == (iconv_t) -1)
                to_server_enc = 0;
        }
    }

    if (ne_sock_init() != 0)
        error(EXIT_FAILURE, errno, _("socket library initialization failed"));

    if (debug & ~NE_DBG_HTTPPLAIN) {
        char *buf = malloc(log_bufsize);
        cookie_io_functions_t *log_func = malloc(sizeof(cookie_io_functions_t));
        if (log_func == NULL)
            abort();
        log_func->read = NULL;
        log_func->write = log_writer;
        log_func->seek = NULL;
        log_func->close = NULL;
        log_stream = fopencookie(buf, "w", *log_func);
        if (log_stream == NULL)
            error(EXIT_FAILURE, errno,
                  _("can't open stream to log neon-messages"));
        ne_debug_init(log_stream, debug);
    }

    session = ne_session_create(scheme, host, port);

    ne_set_read_timeout(session, read_timeout);

#if NE_VERSION_MINOR > 26
    ne_set_connect_timeout(session, connect_timeout);
#endif

    char *useragent = ne_concat(PACKAGE_TARNAME, "/", PACKAGE_VERSION, NULL);
    ne_set_useragent(session, useragent);
    free(useragent);

    if (user != NULL)
        username = ne_strdup(user);
    if (passwd != NULL)
        password = ne_strdup(passwd);
    ne_set_server_auth(session, auth, "server");

    if (useproxy && p_host != NULL) {
        ne_session_proxy(session, p_host, p_port);
        if (p_user != NULL)
            p_username = ne_strdup(p_user);
        if (p_passwd != NULL)
            p_password = ne_strdup(p_passwd);
        ne_set_proxy_auth(session, auth, "proxy");
    }

    if (strcmp(scheme, "https") == 0) {
        if (!ne_has_support(NE_FEATURE_SSL))
            error(EXIT_FAILURE, 0, _("neon library does not support TLS/SSL"));
        ne_ssl_set_verify(session, ssl_verify, NULL);
        ne_ssl_trust_default_ca(session);

        if (servercert != NULL) {
            ne_ssl_certificate *server_cert = ne_ssl_cert_read(servercert);
            if (server_cert == NULL)
                error(EXIT_FAILURE, 0, _("can't read server certificate %s"),
                      servercert);
            ne_ssl_trust_cert(session, server_cert);
            ne_ssl_cert_free(server_cert);
        }

        if (clicert != NULL) {
            uid_t orig = geteuid();
            seteuid(0);
            ne_ssl_client_cert *client_cert = ne_ssl_clicert_read(clicert);
            seteuid(orig);
            if (client_cert == NULL)
                error(EXIT_FAILURE, 0, _("can't read client certificate %s"),
                      clicert);
            if (client_cert != NULL && ne_ssl_clicert_encrypted(client_cert)) {
                char *pw = NULL;
                if (clicert_pw == NULL && askauth) {
                    printf(_("Please enter the password to decrypt client\n"
                             "certificate %s.\n"), clicert);
                    pw = getpass(_("Password: "));
                } else {
                    pw = ne_strdup(clicert_pw);
                }
                int ret = 1;
                if (pw != NULL) {
                    ret = ne_ssl_clicert_decrypt(client_cert, pw);
                    memset(pw, '\0', strlen(pw));
                    free(pw);
                }
                if (ret)
                    error(EXIT_FAILURE, 0,
                          _("can't decrypt client certificate %s"), clicert);
            }
            ne_ssl_set_clicert(session, client_cert);
            ne_ssl_clicert_free(client_cert);
        }
    }

    suri = (ne_uri *) ne_calloc(sizeof(ne_uri));
    ne_fill_server_uri(session, suri);

    if (use_locks) {
        locks = ne_lockstore_create();
        if (lock_owner == NULL) {
            if (user == NULL) {
                owner = ne_strdup(PACKAGE_STRING);
            } else {
                owner = ne_strdup(user);
            }
        } else {
            owner = ne_strdup(lock_owner);
        }
        lock_timeout = l_timeout;
    }

    if (header) {
        char *custom_header = ne_strdup(header);
        ne_hook_pre_send(session, add_header, custom_header);
    }

#if NE_VERSION_MINOR > 25
    if (allow_cookie)
        ne_hook_post_send(session, update_cookie, NULL);
#endif

    use_displayname = displayname;
    use_expect100 = expect100;
    has_if_match_bug = if_match_bug;
    drop_weak_etags = d_w_etags;
    precheck = prechck;
    ignore_dav_header = ignore_dav_hdr;
}


int dav_init_connection(const char *path) {

    suri->path = ne_path_escape(path);
    if (suri->path == NULL)
        abort();

    ne_server_capabilities caps = {0, 0, 0};
    int ret = ne_options(session, path, &caps);

    if (ret == 0) {
        initialized = 1;
        if (!caps.dav_class1 && !ignore_dav_header) {
            if (have_terminal) {
                error(EXIT_FAILURE, 0,
                      _("mounting failed; the server does not support WebDAV"));
            } else {
                syslog(LOG_MAKEPRI(LOG_DAEMON, LOG_ERR),
                       _("mounting failed; the server does not support WebDAV"));
                ret = EINVAL;
            }
        }
        if ((caps.dav_class2 || ignore_dav_header) && locks != NULL) {
            ne_lockstore_register(locks, session);
        } else if (locks != NULL) {
            if (have_terminal)
                error(0, 0, _("warning: the server does not support locks"));
            ne_lockstore_destroy(locks);
            locks = NULL;
        }
    } else {
        ret = get_error(ret, "OPTIONS");
    }

    free(suri->path);
    return ret;
}


void dav_close_webdav(void) {

    if(session != NULL && log_stream != NULL)
        syslog(LOG_MAKEPRI(LOG_DAEMON, LOG_DEBUG), "Closing connection to  %s",
               ne_get_server_hostport(session));

    if (locks != NULL) {
        struct ne_lock *lock = ne_lockstore_first(locks);
        while (lock != NULL) {
            if (session != NULL) {
                int ret = ne_unlock(session, lock);
                get_error(ret, "UNLOCK");
            }
            lock = ne_lockstore_next(locks);
        }
    }

    if (session != NULL)
        ne_session_destroy(session);
    ne_sock_exit();
}


char *dav_conv_from_utf_8(const char *s) {

    char *new = ne_strdup(s);
    if (from_utf_8)
        convert(&new, from_utf_8);
    return new;
}


char *dav_conv_to_utf_8(const char *s) {

    char *new = ne_strdup(s);
    if (to_utf_8)
        convert(&new, to_utf_8);
    return new;
}


char *dav_conv_from_server_enc(const char *s) {

    char *new = ne_strdup(s);
    if (from_server_enc)
        convert(&new, from_server_enc);
    return new;
}


char *dav_conv_to_server_enc(const char *s) {

    char *new = ne_strdup(s);
    if (to_server_enc)
        convert(&new, to_server_enc);
    return new;
}


int dav_delete(const char *path, time_t *expire) {

    suri->path = ne_path_escape(path);
    if (suri->path == NULL)
        abort();

    int ret = ne_delete(session, suri->path);
    ret = get_error(ret, "DELETE");
    if (ret == EACCES && lock_discover(suri->path, expire) == 0) {
        ret = ne_delete(session, suri->path);
        ret = get_error(ret, "DELETE");
    }

    if (ret == 0 && locks != NULL && *expire != 0) {
        struct ne_lock *lock = ne_lockstore_findbyuri(locks, suri);
        if (lock != NULL) {
            ne_lockstore_remove(locks, lock);
            ne_lock_destroy(lock);
        }
    }

    free(suri->path);
    return ret;
}


int dav_delete_dir(const char *path) {

    int ret;
    if (!initialized) {
        ret = dav_init_connection(path);
        if (ret != 0)
            return ret;
    }

    suri->path = ne_path_escape(path);
    if (suri->path == NULL)
        abort();

    ret = ne_delete(session, suri->path);
    ret = get_error(ret, "DELETE");

    free(suri->path);
    return ret;
}


void dav_delete_props(dav_props *props) {

    if (props->path != NULL)
        free(props->path);
    if (props->name != NULL)
        free(props->name);
    if (props->etag != NULL) 
        free(props->etag);
    free(props);
}


int dav_get_collection(const char *path, dav_props **props) {

    int ret;
    if (!initialized) {
        ret = dav_init_connection(path);
        if (ret != 0)
            return ret;
    }

    propfind_context ctx;
    ctx.path = path;
    ctx.results = NULL;

    suri->path = ne_path_escape(path);
    if (suri->path == NULL)
        abort();
    ne_propfind_handler *pfh = ne_propfind_create(session, suri->path,
                                                  NE_DEPTH_ONE);
    ret = ne_propfind_named(pfh, prop_names, prop_result, &ctx);
    ret = get_error(ret, "PROPFIND");
    ne_propfind_destroy(pfh);
    free(suri->path);

    if (ret != 0) {
        while(ctx.results != NULL) {
            dav_props *tofree = ctx.results;
            ctx.results = ctx.results->next;
            dav_delete_props(tofree);
        }    
    }

    *props = ctx.results;
    return ret;
}


const char *dav_get_webdav_error() {

    return ne_get_error(session);
}


int dav_get_file(const char *path, const char *cache_path, off_t *size,
                 char **etag, time_t *mtime, char **mime, int *modified) {

    int ret;
    if (!initialized) {
        ret = dav_init_connection(path);
        if (ret != 0)
            return ret;
    }

    get_context ctx;
    ctx.error = 0;
    ctx.file = cache_path;
    ctx.fd = 0;

    suri->path = ne_path_escape(path);
    if (suri->path == NULL)
        abort();
    ne_request *req = ne_request_create(session, "GET", suri->path);

    if (etag != NULL && *etag != NULL)
        ne_add_request_header(req, "If-None-Match", *etag);
    char *mod_time = NULL;
    if (mtime != NULL && *mtime != 0) {
        mod_time = ne_rfc1123_date(*mtime);
        ne_add_request_header(req, "If-Modified-Since", mod_time);
    }

    ne_add_response_body_reader(req, ne_accept_2xx, block_writer, &ctx);

    ret = ne_request_dispatch(req);
    ret = get_error(ret, "GET");
    if (ctx.error)
        ret = ctx.error;

    const ne_status *status = ne_get_status(req);

    if (ret == 0 && status->code == 200) {
        if (modified != NULL)
            *modified = 1;
        const char *value = ne_get_response_header(req, "Content-Length");
        if (value != NULL)
#if _FILE_OFFSET_BITS == 64
            *size = strtoll(value, NULL, 10);
#else
            *size = strtol(value, NULL, 10);
#endif
        value = ne_get_response_header(req, "Last-Modified");
        if (mtime != NULL && value != NULL)
            *mtime = ne_httpdate_parse(value);
        if (etag != NULL) {
            if (*etag != NULL)
                free(*etag);
            value = ne_get_response_header(req, "ETag");
            if (value != NULL && *value == 'W') {
                if (drop_weak_etags) {
                    value = strchr(value, '\"');
                } else {
                    value = NULL;
                }
            }
            if (value != NULL) {
                *etag = ne_strdup(value);
            } else {
                *etag = NULL;
            }
        }
        value = ne_get_response_header(req, "Content-Type");
        if (mime != NULL && value != NULL) {
            if (*mime != NULL)
                free(*mime);
            *mime = ne_strdup(value);
        }
    }

    ne_request_destroy(req);
    if (ctx.fd > 0)
        close(ctx.fd);
    if (mod_time != NULL)
        free(mod_time);
    free(suri->path);
    return ret;
}


int dav_head(const char *path, char **etag, time_t *mtime, off_t *length,
             char **mime) {

    int ret;
    if (!initialized) {
        ret = dav_init_connection(path);
        if (ret != 0)
            return ret;
    }

    suri->path = ne_path_escape(path);
    if (suri->path == NULL)
        abort();
    ne_request *req = ne_request_create(session, "HEAD", suri->path);

    ret = ne_request_dispatch(req);
    ret = get_error(ret, "HEAD");

    const char *value = ne_get_response_header(req, "ETag");
    if (ret == 0 && etag != NULL && value != NULL) {
        if (*etag != NULL)
            free(*etag);
        if (*value == 'W') {
            if (drop_weak_etags) {
                value = NULL;
            } else {
                value = strchr(value, '\"');
            }
        }
        if (value != NULL) {
            *etag = ne_strdup(value);
        } else {
            *etag = NULL;
        }
    }
    value = ne_get_response_header(req, "Last-Modified");
    if (ret == 0 && mtime != 0 && value != NULL)
        *mtime = ne_httpdate_parse(value);
    value = ne_get_response_header(req, "Content-Length");
    if (ret == 0 && length != 0 && value != NULL)
      *length = strtol(value, NULL, 10);
    value = ne_get_response_header(req, "Content-Type");
    if (ret == 0 && mime != NULL && value != NULL) {
        if (*mime != NULL)
            free(*mime);
        *mime = ne_strdup(value);
    }

    ne_request_destroy(req);
    free(suri->path);
    return ret;
}


int dav_lock(const char *path, time_t *expire, int *exists) {

    int ret;
    if (!initialized) {
        ret = dav_init_connection(path);
        if (ret != 0)
            return ret;
    }

    if (locks == NULL) {
        *expire = 0;
        return 0;
    }

#if NE_VERSION_MINOR > 25
    if (precheck && has_if_match_bug && *exists == 0) {
#else
    if (precheck && *exists == 0) {
#endif
        if (dav_head(path, NULL, NULL, NULL, NULL) == 0) {
            return EEXIST;
        }
    }

    suri->path = ne_path_escape(path);
    if (suri->path == NULL)
        abort();

    struct ne_lock *lock = ne_lockstore_findbyuri(locks, suri);
    if (lock != NULL) {
        free(suri->path);
        *expire = -1;
        lock_refresh(lock, expire);
        return 0;
    }

    lock = ne_lock_create();
    lock->uri.scheme = ne_strdup(suri->scheme);
    lock->uri.host = ne_strdup(suri->host);
    lock->uri.port = suri->port;
    lock->uri.path = suri->path;
    suri->path = NULL;
    lock->owner = ne_strdup(owner);
    lock->timeout = lock_timeout;

#if NE_VERSION_MINOR > 25
    if (!has_if_match_bug && *exists == 0)
        ne_hook_pre_send(session, add_header, none_match_header);
#endif
    ret = ne_lock(session, lock);
    ret = get_error(ret, "LOCK");
#if NE_VERSION_MINOR > 25
    if (!has_if_match_bug && *exists == 0) {
        ne_unhook_pre_send(session, add_header, none_match_header);
        if (ret && strtol(ne_get_error(session), NULL, 10) == 412)
            ret = EEXIST;
    }
#endif

    if (ret == 0) {
        ne_lockstore_add(locks, lock);
        if (strtol(ne_get_error(session), NULL, 10) == 201)
            *exists = 1;
        if (lock->timeout <= 0) {
            *expire = LONG_MAX;
        } else {
            *expire = lock->timeout + time(NULL);
        }
    } else {
        if (ret == EACCES && lock_discover(lock->uri.path, expire) == 0)
            ret = 0;
        ne_lock_destroy(lock);
    }

    return ret;
}


void dav_lock_refresh(const char *path, time_t *expire) {

    if (!initialized && dav_init_connection(path) != 0)
        return;

    if (locks == NULL) {
        *expire = 0;
        return;
    }

    suri->path = ne_path_escape(path);
    if (suri->path == NULL)
        abort();
    struct ne_lock *lock = ne_lockstore_findbyuri(locks, suri);

    if (lock == NULL) {
        lock_discover(suri->path, expire);
    } else {
        lock_refresh(lock, expire);
    }

    free(suri->path);
}


int dav_make_collection(const char *path) {

    int ret;
    if (!initialized) {
        ret = dav_init_connection(path);
        if (ret != 0)
            return ret;
    }

    suri->path = ne_path_escape(path);
    if (suri->path == NULL)
        abort();
    ret = ne_mkcol(session, suri->path);
    ret = get_error(ret, "MKCOL");
    free(suri->path);
    return ret;
}


int dav_move(const char *src, const char *dst) {

    int ret;
    if (!initialized) {
        ret = dav_init_connection(src);
        if (ret != 0)
            return ret;
    }

    suri->path = ne_path_escape(src);
    char *dst_path = ne_path_escape(dst);
    if (suri->path == NULL || dst_path == NULL)
        abort();

    ret = ne_move(session, 1, suri->path, dst_path); 
    ret = get_error(ret, "MOVE");

    if (ret == 0 && locks != NULL) {
        struct ne_lock *lock = ne_lockstore_findbyuri(locks, suri);
        if (lock != NULL) {
            ne_lockstore_remove(locks, lock);
            ne_lock_destroy(lock);
        }
        if (use_displayname) {
            ne_proppatch_operation op[2];
            op[0].name = &prop_names[NAME];
            op[0].type = ne_propremove;
            op[1].name = NULL;
            ne_proppatch(session, dst_path, &op[0]);
        }
    }

    free(suri->path);
    free(dst_path);
    return ret;
}


int dav_put(const char *path, const char *cache_path, int *exists,
            time_t *expire, char **etag, time_t *mtime, char **mime,
            int execute) {

    int ret = 0;
    if (!initialized) {
        ret = dav_init_connection(path);
        if (ret != 0)
            return ret;
    }


    if (precheck && (has_if_match_bug || (*exists && (!etag || !*etag)))
            && (*exists == 0 || (etag != NULL && *etag != NULL)
                || (mtime != NULL && *mtime != 0))) {
        char *r_etag = NULL;
        time_t r_mtime = 0;
        off_t r_length = 0;
        ret = dav_head(path, &r_etag, &r_mtime, &r_length, NULL);
        if (ret == 0) {
            if (*exists == 0 && r_length != 0) {
                ret = EEXIST;
            } else if (etag != NULL && *etag != NULL && r_etag != NULL) {
                if (strcmp(*etag, r_etag) != 0)
                    ret = EINVAL;
            } else if (mtime != NULL && *mtime != 0 && r_mtime != 0) {
                if (*mtime < r_mtime)
                    ret = EINVAL;
            }
        } else if (ret == ENOENT) {
            if (*exists == 0) {
                ret = 0;
            } else {
                ret = dav_unlock(path, expire);
            }
        }
        if (r_etag != NULL)
            free(r_etag);
        if (ret != 0)
            return ret;
    }

    int fd = open(cache_path, O_RDONLY);
    if (fd <= 0)
        return EIO;
    struct stat st;
    if (fstat(fd, &st) != 0)
        return EIO;

    suri->path = ne_path_escape(path);
    if (suri->path == NULL)
        abort();

    ne_request *req = ne_request_create(session, "PUT", suri->path);
    if (!has_if_match_bug) {
        if (!*exists) {
            ne_add_request_header(req, "If-None-Match", "*");
        } else {
            if (etag && *etag)
                ne_add_request_header(req, "If-Match", *etag);
        }
    }
    if (use_expect100)
#if NE_VERSION_MINOR == 25
        ne_set_request_expect100(req, 1);
#else
        ne_set_request_flag(req, NE_REQFLAG_EXPECT100, 1);
#endif
    ne_lock_using_resource(req, suri->path, 0);
#if _FILE_OFFSET_BITS == 64  && NE_VERSION_MINOR < 27
    ne_set_request_body_fd64(req, fd, 0, st.st_size);
#else
    ne_set_request_body_fd(req, fd, 0, st.st_size);
#endif

    ret = ne_request_dispatch(req);
    ret = get_error(ret, "PUT");

    if (ret == EACCES && lock_discover(suri->path, expire) == 0) {
        ne_request_destroy(req);
        ne_request *req = ne_request_create(session, "PUT", suri->path);
        if (!has_if_match_bug) {
            if (!*exists) {
                ne_add_request_header(req, "If-None-Match", "*");
            } else {
                if (etag && *etag)
                    ne_add_request_header(req, "If-Match", *etag);
            }
        }
        if (use_expect100)
#if NE_VERSION_MINOR == 25
            ne_set_request_expect100(req, 1);
#else
            ne_set_request_flag(req, NE_REQFLAG_EXPECT100, 1);
#endif
        ne_lock_using_resource(req, suri->path, 0);
#if _FILE_OFFSET_BITS == 64  && NE_VERSION_MINOR < 27
        ne_set_request_body_fd64(req, fd, 0, st.st_size);
#else
        ne_set_request_body_fd(req, fd, 0, st.st_size);
#endif
        ret = ne_request_dispatch(req);
        ret = get_error(ret, "PUT");
    }

    int need_head = 0;
    if (ret == 0) {
        *exists = 1;
        const char *value;
        if (etag) {
            if (*etag != NULL) {
                free(*etag);
                *etag = NULL;
            }
            value = ne_get_response_header(req, "ETag");
            if (value != NULL && *value == 'W') {
                if (drop_weak_etags) {
                    value = strchr(value, '\"');
                } else {
                    value = NULL;
                }
            }
            if (value) {
                *etag = ne_strdup(value);
            } else {
                need_head = 1;
            }
        }
        if (mtime) {
            value = ne_get_response_header(req, "Last-Modified");
            if (!value)
                value = ne_get_response_header(req, "Date");
            if (value) {
                *mtime = ne_httpdate_parse(value);
            } else {
                need_head = 1;
            }
        }
        if (mime) {
            value = ne_get_response_header(req, "Content-Type");
            if (value) {
                if (*mime)
                    free(*mime);
                *mime = ne_strdup(value);
            }
        }
    }

    ne_request_destroy(req);
    free(suri->path);
    close(fd);

    if (ret == 0) {
        if (execute == 1)
            dav_set_execute(path, execute);
        if (need_head)
            dav_head(path, etag, mtime, NULL, mime);
    }

    return ret;
}


int dav_quota(const char *path, off_t *available, off_t *used) {

    int ret;
    if (!initialized) {
        ret = dav_init_connection(path);
        if (ret != 0)
            return ret;
    }

    quota_context ctx;
    ctx.available = (off_t) -1;
    ctx.used = (off_t) -1;

    suri->path = ne_path_escape(path);
    if (suri->path == NULL)
        abort();
    ne_propfind_handler *pfh = ne_propfind_create(session, suri->path,
                                                  NE_DEPTH_ZERO);
    ret = ne_propfind_named(pfh, quota_names, quota_result, &ctx);
    ret = get_error(ret, "PROPFIND");
    ne_propfind_destroy(pfh);
    free(suri->path);

    if (ret == 0) {
        if (ctx.available == (off_t) -1 || ctx.used == (off_t) -1) {
            ret = EIO;
        } else {
            *available = ctx.available;
            *used = ctx.used;
        }
    }

    return ret;
}


int dav_set_execute(const char *path, int set) {

    int ret;
    if (!initialized) {
        ret = dav_init_connection(path);
        if (ret != 0)
            return ret;
    }

    ne_proppatch_operation op[2];
    op[0].name = &prop_names[EXECUTE];
    op[0].type = ne_propset;
    if (set) {
        op[0].value = "T";
    } else {
        op[0].value = "F";
    }
    op[1].name = NULL;

    suri->path = ne_path_escape(path);
    if (suri->path == NULL)
        abort();
    ret = ne_proppatch(session, suri->path, &op[0]);
    ret = get_error(ret, "PROPPATCH");
    free(suri->path);

    return ret;
}


void dav_set_no_terminal(void) {
    have_terminal = 0;
}


int dav_unlock(const char *path, time_t *expire) {

    int ret;
    if (!initialized) {
        ret = dav_init_connection(path);
        if (ret != 0)
            return ret;
    }

    if (locks == NULL) {
        *expire = 0;
        return 0;
    }

    suri->path = ne_path_escape(path);
    if (suri->path == NULL)
        abort();

    struct ne_lock *lock = ne_lockstore_findbyuri(locks, suri);
    free(suri->path);
    if (lock == NULL) {
        *expire = 0;
        return 0;
    }

    ret = ne_unlock(session, lock);
    ret = get_error(ret, "UNLOCK");
    if (ret == 0 || ret == ENOENT || ret == EINVAL) {
        ne_lockstore_remove(locks, lock);
        ne_lock_destroy(lock);
        *expire = 0;
        return 0;
    }

    return ret;
}



/* Private functions */
/*===================*/

static void convert(char **s, iconv_t conv) {

    size_t insize = strlen(*s);
    char *in = *s;
    size_t outsize = MB_LEN_MAX * (insize + 1);
    char *buf = calloc(outsize, 1);
    if (buf == NULL)
        abort();
    char *out = buf;

    iconv(conv, NULL, NULL, &out, &outsize);
    if (iconv(conv, &in, &insize, &out, &outsize) >= 0
            && insize == 0 && outsize >= MB_LEN_MAX) {
        memset(out, 0, MB_LEN_MAX);
        free(*s);
        *s = ne_strndup(buf, out - buf + MB_LEN_MAX);
    }

    free(buf);
}


/* Returns a file error code according to ret from the last WebDAV
   method call. If ret has value NE_ERROR the error code from the session is
   fetched and translated.
   ret    : the error code returned from NEON.
   method : name of the WebDAV method, used for debug messages.
   return value : a file error code according to errno.h. */
static int get_error(int ret, const char *method) {

    int err;
    switch (ret) {
    case NE_OK:
    case NE_ERROR:
        err = get_ne_error(method);
        break;
    case NE_LOOKUP:
        err = EIO;
        break;
    case NE_AUTH:
        err = EPERM;
        break;
    case NE_PROXYAUTH:
        err = EPERM;
        break;
    case NE_CONNECT:
        err = EAGAIN;
        break;
    case NE_TIMEOUT:
        err = EAGAIN;
        break;
    case NE_FAILED:
        err = EINVAL;
        break;
    case NE_RETRY:
        err = EAGAIN;
        break;
    case NE_REDIRECT:
        err = ENOENT;
        break;
    default:
        err = EIO;
        break;
    }

    return err;
}

/* Get the error from the session and translates it into a file error code.
   method : name of the WebDAV method, used for debug messages.
   return value : a file error code according to errno.h. */
static int get_ne_error(const char *method) {

    const char *text = ne_get_error(session);

    char *tail;
    int err = strtol(text, &tail, 10);
    if (tail == text)
        return EIO;

    switch (err) {
        case 200:           /* OK */
        case 201:           /* Created */
        case 202:           /* Accepted */
        case 203:           /* Non-Authoritative Information */
        case 204:           /* No Content */
        case 205:           /* Reset Content */
        case 207:           /* Multi-Status */
        case 304:           /* Not Modified */
            return 0;
        case 401:           /* Unauthorized */
        case 402:           /* Payment Required */
        case 407:           /* Proxy Authentication Required */
            return EPERM;
        case 301:           /* Moved Permanently */
        case 303:           /* See Other */
        case 404:           /* Not Found */
        case 410:           /* Gone */
            return ENOENT;
        case 408:           /* Request Timeout */
        case 504:           /* Gateway Timeout */
            return EAGAIN;
        case 423:           /* Locked */
            return EACCES;
        case 400:           /* Bad Request */
        case 403:           /* Forbidden */
        case 405:           /* Method Not Allowed */
        case 409:           /* Conflict */
        case 411:           /* Length Required */
        case 412:           /* Precondition Failed */
        case 414:           /* Request-URI Too Long */
        case 415:           /* Unsupported Media Type */
        case 424:           /* Failed Dependency */
        case 501:           /* Not Implemented */
            return EINVAL;
        case 413:           /* Request Entity Too Large */
        case 507:           /* Insufficient Storage */
            return ENOSPC;
        case 206:           /* Partial Content */
        case 300:           /* Multiple Choices */
        case 302:           /* Found */
        case 305:           /* Use Proxy */
        case 306:           /* (Unused) */
        case 307:           /* Temporary Redirect */
        case 406:           /* Not Acceptable */
        case 416:           /* Requested Range Not Satisfiable */
        case 417:           /* Expectation Failed */
        case 422:           /* Unprocessable Entity */
        case 500:           /* Internal Server Error */
        case 502:           /* Bad Gateway */
        case 503:           /* Service Unavailable */
        case 505:           /* HTTP Version Not Supported */
            return EIO;
        default:
            return EIO;
    }
}


/* Checks if there is already a lock for file path that is owned by owner. If
   successful it stores the lock in the global lock store, refreshes the lock
   and updates expire.
   If no matching lock is found or the session is initialized with the nolocks
   option, it  sets expire to 0 and returns -1.
   If a matching lock is found, but it can not be refreshed, expire is set
   to -1 (= locked, expire time unknown).
   If an error occurs it leaves expire unchanged and returns -1:
   spath  : URL-escaped path of the file on the server.
   expire : The time when the lock expires, will be updated.
   return value : 0 if a matching lock is found, -1 otherwise. */
static int lock_discover(const char *spath, time_t *expire) {

    if (locks == NULL) {
        *expire = 0;
        return -1;
    }

    struct ne_lock *lock = NULL;
    int ret = ne_lock_discover(session, spath, lock_result, &lock);
    ret = get_error(ret, "LOCKDISCOVER");

    if (ret == 0 && lock != NULL)  {
        *expire = -1;
        lock_refresh(lock, expire);
        return 0;
    } else {
        if (ret == 0)
            *expire = 0;
        return -1;
    }
}


/* Refreshes lock and updates expire.
   If an error occurs it does nothing.
   lock   : The lock, will be updated on success.
   expire : The time when the lock expires, updated on success. */
static void lock_refresh(struct ne_lock *lock, time_t *expire) {

    int ret = ne_lock_refresh(session, lock);
    ret = get_error(ret, "LOCKREFRESH");

    if (ret == 0) {
        if (lock->timeout <= 0) {
            *expire = LONG_MAX;
        } else {
            *expire = lock->timeout + time(NULL);
        }
    }
}


static ssize_t log_writer(void *cookie, const char *buffer, size_t size) {

    if (size <= 0)
        return 0;

    size_t written = 0;
    const char *bpos = buffer;
    while (written < size) {
        size_t n = 2;
        char *cpos = (char *) cookie;
        while (n < log_bufsize && written < size) {
            if (*bpos == '%') {
                *cpos++ = '%';
                n++;
            }
            *cpos++ = *bpos++;
            n++;
            written++;
        }
        *cpos = '\0';
        syslog(LOG_MAKEPRI(LOG_DAEMON, LOG_DEBUG), (char *) cookie);
    }
    return written;
}


/* Replaces slashes in name by "slash-", "-slash-" or "-slash", depending
   on the position of the slash within name. */
static void replace_slashes(char **name) {

    char *slash = strchr(*name, '/');
    while (slash != NULL) {
        char *end = *name + strlen(*name) - 1;
        char *nn;
        *slash = '\0';
        if (slash == *name) {
            nn = ne_concat("slash-", slash + 1, NULL);
        } else if (slash == end) {
            nn = ne_concat(*name, "-slash", NULL);
        } else {
            nn = ne_concat(*name, "-slash-", slash + 1, NULL);
        }
        free(*name);
        *name = nn;
        slash = strchr(*name, '/');
    }
}


/* Call-back functions for neon. */

static void add_header(ne_request *req, void *userdata,
                                  ne_buffer *header) {
    ne_buffer_zappend(header, (char *) userdata);
}


/* Copies credentials from global variables into user and pwd.
   userdata must be a string with value "server" or "proxy", to decide what
   the creditentials are needed for.
   The creditentials are taken form global variables username/password or
   p_username/p_password.
   If attempt > 0, this is logged as an error and the value of attempt is
   returned, so neon will not try again.
   userdata : What the credentials are needed for ("server" or "proxy").
   realm    : Used for error log.
   attempt  : Number of attempts to get credentials. If not 0 an error occured.
   user     : A buffer of size NE_ABUFSIZ to return the username.
   pwd      : A buffer of size NE_ABUFSIZ to return the password.
   return value : value if attempt. neon will not call this function again if
                  it is greater than 0. */
static int auth(void *userdata, const char *realm, int attempt, char *user,
                char *pwd) {

    if (attempt != 0) {
        syslog(LOG_MAKEPRI(LOG_DAEMON, LOG_ERR), _("authentication failure:"));
        syslog(LOG_MAKEPRI(LOG_DAEMON, LOG_ERR), "  %s", realm);
        return attempt;
    }

    if (strcmp((char *) userdata, "server") == 0) {
        if (username != NULL)
            strncpy(user, username, NE_ABUFSIZ - 1);
        if (password != NULL)
            strncpy(pwd, password, NE_ABUFSIZ - 1);
    } else if (strcmp((char *) userdata, "proxy") == 0) {
        if (p_username != NULL)
            strncpy(user, p_username, NE_ABUFSIZ - 1);
        if (p_password != NULL)
            strncpy(pwd, p_password, NE_ABUFSIZ - 1);
    }
    return 0;
}


/* Writes data from block to a local file.
   userdata must be a get_context structure that holds at least the name of
   the local file. If it does not contain a file descriptor, the file is
   opened for writing and the file descriptor is stored in the get_context
   structure. In case of an error a error flag is set. 
   userdata : A get_context structure, containing the name of the local file,
              the file descriptor (if the file is open), and an error flag.
   block    : Buffer containing the data.
   length   : Number of bytes in the buffer.
   return value : 0 on success, EIO otherwise. */
static int block_writer(void *userdata, const char *block, size_t length) {

    get_context *ctx = (get_context *) userdata;
    if (ctx->fd == 0)
        ctx->fd = open(ctx->file, O_WRONLY | O_CREAT | O_TRUNC);
    if (ctx->fd <= 0) {
        ne_set_error(session, _("%i can't open cache file"), 0);
        ctx->error = EIO;
    }

    while (!ctx->error && length > 0) {
        ssize_t ret = write(ctx->fd, block, length);
        if (ret < 0) {
            ctx->error = EIO;
            ne_set_error(session, _("%i error writing to cache file"), 0);
        } else {
            length -= ret;
            block += ret;
        }
    }

    return ctx->error;
}


/* If the owner of this lock is the same as global variable owner, lock is
   stored in the global lock store locks and a pointer to the lock is
   returned in userdata.
   Otherwise it does nothing.
   userdata : *userdata will be set to lock, if lock is ownded ba owner.
   lock     : a lock found by ne_lock_discover() on the server.
   uri      : not used.
   status   : not used. */
 
#if NE_VERSION_MINOR < 26

static void lock_result(void *userdata, const struct ne_lock *lock, 
                                    const char *uri, const ne_status *status) {

#else     /* NE_VERSION_MINOR */

static void lock_result(void *userdata, const struct ne_lock *lock, 
                                    const ne_uri *uri, const ne_status *status) {

#endif    /* NE_VERSION_MINOR */

    if (locks == NULL || owner == NULL || userdata == NULL || lock == NULL
            || lock->owner == NULL)
        return;

    if (strcmp(lock->owner, owner) == 0) {
        struct ne_lock *l = ne_lock_copy(lock);
        ne_lockstore_add(locks, l);
        l->timeout = lock_timeout;
        *((struct ne_lock **) userdata) = l;
    }
}


/* Called by ne_propfind_named(). Evaluates a dav_props structure from
   href/uri and set and stores it in userdata.
   userdata must be a pointer to a propfind_context structure. Its member
   path holds the unescaped path of the collection. Its member results is
   a linked list of the dav_props structures.
   The unescaped version of href/uri->path must must be equal to the path of
   the collection or a descendent of it. It is stored as member path of the
   dav_props structure. It will be normalized (collections have a trailing
   slash, non-collections do not have one).
   If set does not contain the displayname property or global variable
   use_displayname is set, the name is derived from path. The name of the
   collection itself will be the empty string. If name contains
   a '/'-character it is replaced by the ugly string "-slash-".
   There must not be two dav_props structure with the same path or the same
   name. in this case one of them is removed from the list, preferable the one
   that is not a directory or that is less specific.
   userdata : A pointer to a propfind_context structure containing the path of
              the collection and the linked list of properties.
if NE_VERSION_MINOR < 26
   href     : Value of the href propertiy returned by the server. It may be
              the complete URL of the collection or the path only.
else
   uri      : ne_uri of the resource as returned from the server.
endif
   set      : Points to the set of properties returned from the server.*/

#if NE_VERSION_MINOR < 26

static void prop_result(void *userdata, const char *href,
                        const ne_prop_result_set *set) {

    propfind_context *ctx = (propfind_context *) userdata;
    if (ctx == NULL || href == NULL || set == NULL)
        return;

    ne_uri uri;
    if (ne_uri_parse(href, &uri) != 0 || uri.path == NULL) {
        ne_uri_free(&uri);
        return;
    }

    dav_props *result = ne_calloc(sizeof(dav_props));
    result->path = ne_path_unescape(uri.path);
    ne_uri_free(&uri);

#else /* NE_VERSION_MINOR */

static void prop_result(void *userdata, const ne_uri *uri,
                        const ne_prop_result_set *set) {

    propfind_context *ctx = (propfind_context *) userdata;
    if (ctx == NULL || uri == NULL || uri->path == NULL || set == NULL)
        return;

    dav_props *result = ne_calloc(sizeof(dav_props));
    result->path = ne_path_unescape(uri->path);

#endif /* NE_VERSION_MINOR */

    if (result->path == NULL || strlen(result->path) < 1) {
        dav_delete_props(result);
        return;
    }

    const char *data;

    data = ne_propset_value(set, &prop_names[TYPE]);
    if (data != NULL && strstr(data, "collection") != NULL)
            result->is_dir = 1;

    if (*(result->path + strlen(result->path) - 1) == '/') {
        if (!result->is_dir)
            *(result->path + strlen(result->path) - 1) = '\0';
    } else {
        if (result->is_dir) {
            char *tmp = ne_concat(result->path, "/", NULL);
            free(result->path);
            result->path = tmp;
        }
    }

    if (strstr(result->path, ctx->path) != result->path) {
        dav_delete_props(result);
        return;
    }

    if (strcmp(result->path, ctx->path) == 0) {
        result->name = ne_strdup("");
    } else {
        if (use_displayname) {
            data = ne_propset_value(set, &prop_names[NAME]);
            if (data != NULL) {
                result->name = ne_strdup(data);
                replace_slashes(&result->name);
                if (from_utf_8)
                    convert(&result->name, from_utf_8);
            }
        }
        if (result->name == NULL) {
            if (strlen(result->path)
                    < (strlen(ctx->path) + result->is_dir + 1)) {
                dav_delete_props(result);
                return;
            }
            result->name = ne_strndup(result->path + strlen(ctx->path),
                                      strlen(result->path) - strlen(ctx->path)
                                      - result->is_dir);
            replace_slashes(&result->name);
            if (from_server_enc)
                convert(&result->name, from_server_enc);
        }
    }

    data = ne_propset_value(set, &prop_names[ETAG]);
    if (data != NULL && *data == 'W') {
        if (drop_weak_etags) {
            data = NULL;
        } else {
            data += 2;
        }
    }
    if (data != NULL) {
        if (*data == '\"') {
            result->etag = ne_strdup(data);
         } else {
            result->etag = ne_concat("\"", data, "\"", NULL);
        }
    }

    data = ne_propset_value(set, &prop_names[LENGTH]);
    if (data != NULL)
#if _FILE_OFFSET_BITS == 64
         result->size = strtoll(data, NULL, 10);
#else
         result->size = strtol(data, NULL, 10);
#endif

    data = ne_propset_value(set, &prop_names[CREATION]);
    if (data != NULL) {
        result->ctime = ne_iso8601_parse(data);
        if (result->ctime == (time_t) -1)
            result->ctime = ne_httpdate_parse(data);
        if (result->ctime == (time_t) -1)
            result->ctime = 0;
    }

    data = ne_propset_value(set, &prop_names[MODIFIED]);
    if (data != NULL) {
        result->mtime = ne_httpdate_parse(data);
        if (result->mtime == (time_t) -1)
            result->mtime = ne_iso8601_parse(data);
        if (result->mtime == (time_t) -1)
            result->mtime = 0;
    }

    data = ne_propset_value(set, &prop_names[EXECUTE]);
    if (data == NULL) {
        result->is_exec = -1;
    } else if (*data == 'T') {
        result->is_exec = 1;
    }

    dav_props *dbl = NULL;
    dav_props *r = ctx->results;
    while (r != NULL && dbl == NULL) {
        if (strcmp(r->name, result->name) == 0
                || strcmp(r->path, result->path) == 0)
            dbl = r;
        r = r->next;
    }

    if (dbl == NULL) {
        result->next = ctx->results;
        ctx->results = result;
    } else {
        if (dbl->is_dir > result->is_dir
                || (dbl->is_dir == result->is_dir
                    && ((dbl->size > 0 && result->size == 0)
                || ((dbl->size > 0 || result->size == 0)
                    && ((dbl->etag != NULL && result->etag == NULL)
                || ((dbl->etag != NULL || result->etag == NULL)
                    && ((dbl->mtime > 0 && result->mtime == 0)
                || ((dbl->mtime > 0 || result->mtime == 0)
                    && (dbl->ctime > 0 || result->ctime == 0))))))))) {
            dav_delete_props(result);
        } else {
            free(dbl->path);
            dbl->path = result->path;
            free(dbl->name);
            dbl->name = result->name;
            if (dbl->etag != NULL)
                free(dbl->etag);
            dbl->etag = result->etag;
            dbl->size = result->size;
            dbl->ctime = result->ctime;
            dbl->mtime = result->mtime;
            dbl->is_dir = result->is_dir;
            dbl->is_exec = result->is_exec;
            free(result);
        }
    }
}


/* Reads available and used bytes from set and stores them in
   userdata. */
#if NE_VERSION_MINOR < 26

static void quota_result(void *userdata, const char *href,
                        const ne_prop_result_set *set) {

    quota_context *ctx = (quota_context *) userdata;
    if (ctx == NULL || href == NULL || set == NULL)
        return;

#else /* NE_VERSION_MINOR */

static void quota_result(void *userdata, const ne_uri *uri,
                        const ne_prop_result_set *set) {

    quota_context *ctx = (quota_context *) userdata;
    if (ctx == NULL || uri == NULL || uri->path == NULL || set == NULL)
        return;

#endif /* NE_VERSION_MINOR */

    const char *data = ne_propset_value(set, &quota_names[AVAILABLE]);
    if (data)
        ctx->available = strtol(data, NULL, 10);

    data = ne_propset_value(set, &quota_names[USED]);
    if (data)
        ctx->used = strtol(data, NULL, 10);
}


/* Displays information about cert and asks the user whether to accept
   the certificate or not.
   If no terminal is available (according to global variable Have_terminal)
   it returns an error. Else it displays an error message and certificate
   date and ask whether to accept the certificate. If the user accepts
   it returns 0, otherwise an error.
   In any case the event is logged.
   userdata : not used.
   failures : a constant indicating the kind of error.
   cert     : the server certificate that could not be verified by neon.
   return value : 0 accept the certificate for this session.
                  -1 don't accept the certificate. */
static int ssl_verify(void *userdata, int failures,
                      const ne_ssl_certificate *cert) {

    char *issuer = ne_ssl_readable_dname(ne_ssl_cert_issuer(cert));
    char *subject = ne_ssl_readable_dname(ne_ssl_cert_subject(cert));
    char *digest = ne_calloc(NE_SSL_DIGESTLEN);
    int ret = 0;
    if (issuer == NULL || subject == NULL
            || ne_ssl_cert_digest(cert, digest) != 0) {
        if (have_terminal) {
            error(0, 0, _("error processing server certificate"));
        } else {
            syslog(LOG_MAKEPRI(LOG_DAEMON, LOG_ERR),
                   _("error processing server certificate"));
        }
        ret = -1;
    }

    if (have_terminal) {
        if (failures & NE_SSL_NOTYETVALID)
            error(0, 0, _("the server certificate is not yet valid"));
        if (failures & NE_SSL_EXPIRED)
            error(0, 0, _("the server certificate has expired"));
        if (failures & NE_SSL_IDMISMATCH)
            error(0, 0, _("the server certificate does not match the server name"));
        if (failures & NE_SSL_UNTRUSTED)
            error(0, 0, _("the server certificate is not trusted"));
        if (failures & ~NE_SSL_FAILMASK)
            error(0, 0, _("unknown certificate error"));
        printf(_("  issuer:      %s"), issuer);
        printf("\n");
        printf(_("  subject:     %s"), subject);
        printf("\n");
        printf(_("  identity:    %s"), ne_ssl_cert_identity(cert));
        printf("\n");
        printf(_("  fingerprint: %s"), digest);
        printf("\n");
        if (ret == 0) {
            printf(_("You only should accept this certificate, if you can\n"
                     "verify the fingerprint! The server might be faked\n"
                     "or there might be a man-in-the-middle-attack.\n"));
            printf(_("Accept certificate for this session? [y,N] "));
            char *s = NULL;
            size_t n = 0;
            ssize_t len = 0;
            len = getline(&s, &n, stdin);
            if (len < 0)
                abort();
            if (rpmatch(s) < 1)
                ret = -1;
            free(s);
        }
    } 

    if (failures & NE_SSL_NOTYETVALID)
        syslog(LOG_MAKEPRI(LOG_DAEMON, LOG_ERR),
               _("the server certificate is not yet valid"));
    if (failures & NE_SSL_EXPIRED)
        syslog(LOG_MAKEPRI(LOG_DAEMON, LOG_ERR),
               _("the server certificate has expired"));
    if (failures & NE_SSL_IDMISMATCH)
        syslog(LOG_MAKEPRI(LOG_DAEMON, LOG_ERR),
               _("the server certificate does not match the server name"));
    if (failures & NE_SSL_UNTRUSTED)
        syslog(LOG_MAKEPRI(LOG_DAEMON, LOG_ERR),
               _("the server certificate is not trusted"));
    if (failures & ~NE_SSL_FAILMASK)
        syslog(LOG_MAKEPRI(LOG_DAEMON, LOG_ERR),
               _("unknown certificate error"));
    syslog(LOG_MAKEPRI(LOG_DAEMON, LOG_ERR), _("  issuer: %s"), issuer);
    syslog(LOG_MAKEPRI(LOG_DAEMON, LOG_ERR), _("  subject: %s"), subject);
    syslog(LOG_MAKEPRI(LOG_DAEMON, LOG_ERR), _("  identity: %s"),
                       ne_ssl_cert_identity(cert));
    if (ret == 0) {
        syslog(LOG_MAKEPRI(LOG_DAEMON, LOG_ERR), _("  accepted by user"));
    }

    free(issuer);
    free(subject);
    free(digest);
    return ret;
}


#if NE_VERSION_MINOR > 25
static int update_cookie(ne_request *req, void *userdata,
                          const ne_status *status) {

    if (status->klass != 2)
        return NE_OK;

    const char *cookie_hdr = ne_get_response_header(req, "Set-Cookie2");
    if (!cookie_hdr) {
        cookie_hdr = ne_get_response_header(req, "Set-Cookie");
    }
    if (!cookie_hdr)
        return NE_OK;

    if (cookie && strstr(cookie_hdr, cookie) == cookie_hdr)
        return NE_OK;

    char *sep = strpbrk(cookie_hdr, "\",; \n\r\0");
    if (!sep)
        return NE_OK;
    if (*sep == '\"')
        sep = strpbrk(sep + 1, "\"");
    if (!sep)
        return NE_OK;

    if (cookie) {
        ne_unhook_pre_send(session, add_header, cookie);
        free(cookie);
        cookie = NULL;
    }

    char *value = ne_strndup(cookie_hdr, sep - cookie_hdr + 1);
    cookie = ne_concat("Cookie: $Version=1;", value, "\r\n", NULL);
    free(value);

    ne_hook_pre_send(session, add_header, cookie);
    return NE_OK;
}
#endif /* NE_VERSION_MINOR > 25 */

Generated by  Doxygen 1.6.0   Back to index