Fri, 04 Jun 2021 18:24:55 +0200
add stream API
/* * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER. * * Copyright 2019 Olaf Wintermann. All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions are met: * * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE * POSSIBILITY OF SUCH DAMAGE. */ #include "finfo.h" #include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <errno.h> #include <sys/stat.h> #include <ucx/string.h> #include <ucx/list.h> #include <libidav/crypto.h> #include <libidav/utils.h> #include "libxattr.h" uint32_t parse_finfo_settings(const char *str, char **error) { scstr_t s = scstr(str); if(!sstrcmp(s, SC("*")) || !sstrcmp(s, SC("a")) || !sstrcmp(s, SC("all"))) { return FINFO_MTIME|FINFO_OWNER|FINFO_MODE|FINFO_XATTR; } ssize_t count = 0; sstr_t *fs = sstrsplit(s, SC(","), &count); char *err = NULL; uint32_t finfo = 0; for(int i=0;i<count;i++) { sstr_t f = fs[i]; if(!sstrcasecmp(f, SC("mtime"))) { finfo |= FINFO_MTIME; } else if(!sstrcasecmp(f, SC("owner"))) { finfo |= FINFO_OWNER; } else if(!sstrcasecmp(f, SC("mode"))) { finfo |= FINFO_MODE; } else if(!sstrcasecmp(f, SC("xattr"))) { finfo |= FINFO_XATTR; } else if(error && !err) { err = fs[i].ptr; continue; } free(f.ptr); } free(fs); return err ? 0 : finfo; } int resource_set_finfo(const char *path, DavResource *res, uint32_t finfo) { if(!path || finfo == 0) { return 0; } struct stat s; if(stat(path, &s)) { fprintf(stderr, "failed to stat: %s\n", path); return 1; } return resource_set_finfo_s(&s, res, finfo); } int resource_set_finfo_s(struct stat *s, DavResource *res, uint32_t finfo) { if(finfo == 0) { return 0; } DavXmlNode *content = NULL; DavXmlNode *last = NULL; if((finfo & FINFO_MTIME) == FINFO_MTIME) { char str[32]; struct tm *date = gmtime(&s->st_mtime); strftime(str, 32, "%a, %d %b %Y %H:%M:%S GMT", date); DavXmlNode *mtime = dav_xml_createnode_with_text(DAV_PROPS_NS, "mtime", str); content = mtime; last = mtime; } #ifndef _WIN32 if((finfo & FINFO_OWNER) == FINFO_OWNER) { // TODO } if((finfo & FINFO_MODE) == FINFO_MODE) { mode_t mode = s->st_mode & 07777; char str[32]; snprintf(str, 32, "%o", (int)mode); DavXmlNode *xmode = dav_xml_createnode_with_text(DAV_PROPS_NS, "mode", str); if(last) { last->next = xmode; } else { content = xmode; } last = xmode; } #endif dav_set_property_ns(res, DAV_PROPS_NS, "finfo", content);; return 0; } XAttributes* xml_get_attributes(DavXmlNode *xml) { UcxList *names = NULL; UcxList *values = NULL; size_t count = 0; char *hash = NULL; DavXmlNode *node = xml; for(;node;node=node->next) { if(node->type == DAV_XML_ELEMENT) { if(!strcmp(node->name, "hash")) { hash = dav_xml_getstring(node->children); } else if(!strcmp(node->name, "xattr")) { char *xattr_name = dav_xml_get_attr(node, "name"); if(xattr_name) { names = ucx_list_append(names, strdup(xattr_name)); char *text = dav_xml_getstring(node->children); if(!text) { text = ""; } int len = 0; char *val = util_base64decode_len(text, &len); sstr_t *value = malloc(sizeof(sstr_t)); value->ptr = val; value->length = len; values = ucx_list_append(values, value); count++; } } } } XAttributes *attributes = NULL; if(count > 0) { attributes = calloc(1, sizeof(XAttributes)); attributes->hash = hash ? strdup(hash) : NULL; attributes->nattr = count; attributes->names = calloc(count, sizeof(char*)); attributes->values = calloc(count, sizeof(sstr_t)); int i=0; UCX_FOREACH(elm, names) { attributes->names[i] = elm->data; i++; } i=0; UCX_FOREACH(elm, values) { attributes->values[i] = *(sstr_t*)elm->data; i++; } } return attributes; } XAttributes* file_get_attributes( const char *path, xattr_filter_func filter, void *filterdata) { ssize_t nelm = 0; char **attributes = xattr_list(path, &nelm); if(nelm <= 0) { return NULL; } XAttributes *xattr = malloc(sizeof(XAttributes)); xattr->nattr = 0; xattr->names = calloc(nelm, sizeof(char*)); xattr->values = calloc(nelm, sizeof(sstr_t)); DAV_SHA_CTX *sha256 = dav_hash_init(); size_t nattr = 0; for(int i=0;i<nelm;i++) { if(filter) { // apply filter if(!filter(attributes[i], filterdata)) { // exclude attribute continue; } } ssize_t valuelen = 0; char *value = xattr_get(path, attributes[i], &valuelen); if(valuelen >= 0) { dav_hash_update(sha256, attributes[i], strlen(attributes[i])); dav_hash_update(sha256, value, valuelen); // add name and value xattr->names[nattr] = attributes[i]; sstr_t v; v.ptr = value; v.length = valuelen; xattr->values[nattr] = v; nattr++; } else { // discard not readable attributes free(attributes[i]); } } xattr->nattr = nattr; unsigned char hash[DAV_SHA256_DIGEST_LENGTH]; dav_hash_final(sha256, hash); xattr->hash = util_hexstr(hash, DAV_SHA256_DIGEST_LENGTH); free(attributes); if(nattr > 0) { return xattr; } else { xattributes_free(xattr); return NULL; } } int resource_set_xattr(DavResource *res, XAttributes *xattr) { if(!xattr || xattr->nattr == 0) { return 0; } DavXmlNode *content = dav_xml_createnode_with_text(DAV_PROPS_NS, "hash", xattr->hash); DavXmlNode *last = content; for(int i=0;i<xattr->nattr;i++) { DavXmlNode *attr = dav_xml_createnode(DAV_PROPS_NS, "xattr"); dav_xml_add_attr(attr, "name", xattr->names[i]); last->next = attr; last = attr; sstr_t value = xattr->values[i]; if(value.length > 0) { char *encval = util_base64encode(value.ptr, value.length); attr->children = dav_xml_createtextnode(encval); free(encval); } } dav_set_property_ns(res, DAV_PROPS_NS, "xattributes", content); return 0; } void xattributes_free(XAttributes *xattr) { free(xattr->hash); for(int i=0;i<xattr->nattr;i++) { free(xattr->names[i]); free(xattr->values[i].ptr); } free(xattr); } char* get_xattr_hash(DavXmlNode *finfo) { DavXmlNode *node = finfo; while(node) { if(node->type == DAV_XML_ELEMENT && !strcmp(node->name, "hash")) { return dav_xml_getstring(node->children); } node = node->next; } return NULL; } void finfo_get_values(DavXmlNode *xml, FileInfo *outval) { memset(outval, 0, sizeof(FileInfo)); DavXmlNode *node = xml; while(node) { if(node->type == DAV_XML_ELEMENT) { if(!strcmp(node->name, "mtime")) { char *mtime = dav_xml_getstring(node->children); if(mtime) { outval->last_modified = util_parse_lastmodified(mtime); outval->date_set = TRUE; } } else if(!strcmp(node->name, "mode")) { char *mode_str = dav_xml_getstring(node->children); if(mode_str) { char *end; errno = 0; long int mode = strtol(mode_str, &end, 8); if(errno == 0) { mode &= 07777; outval->mode = mode; outval->mode_set = TRUE; } } } } node = node->next; } }