src/server/config/acl.c

/*
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
 *
 * Copyright 2013 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 <stdio.h>
#include <stdlib.h>
#include <string.h>

#include "acl.h"

ACLFile* load_acl_file(const char *file) {
    FILE *in = fopen(file, "r");
    if(in == NULL) {
        return NULL;
    }
    
    ACLFile *conf = malloc(sizeof(ACLFile));
    conf->parser.parse = acl_parse;
    conf->namedACLs = cxPointerLinkedListCreate(cxDefaultAllocator, cx_cmp_ptr);
    conf->uriACLs = cxPointerLinkedListCreate(cxDefaultAllocator, cx_cmp_ptr);
    conf->pathACLs = cxPointerLinkedListCreate(cxDefaultAllocator, cx_cmp_ptr);
    
    int r = cfg_parse_basic_file((ConfigParser*)conf, in);
    if(r != 0) {
        free_acl_file(conf);
        return NULL;
    }
     
    fclose(in);

    return conf;
}

void free_acl_file(ACLFile *conf) {
    //ucx_mempool_destroy(conf->parser.mp->pool);
    free(conf);
}

int acl_parse(void *p, ConfigLine *begin, ConfigLine *end, cxmutstr line) {
    ACLFile *aclf = p;
    CxAllocator *mp = aclf->parser.mp;
    
    if(cx_strprefix(cx_strcast(line), cx_str("ACL "))) {
        cxmutstr param = cx_strsubs_m(line, 4);
        ConfigParam *plist = cfg_param_list(param, mp); 
        ACLConfig *acl = OBJ_NEW(mp, ACLConfig);
        acl->type.ptr = NULL;
        acl->authparam = NULL;
        acl->entries = NULL;
        aclf->cur = acl;
        
        cxmutstr type = cfg_param_get(plist, cx_str("type"));
        cxmutstr name = cfg_param_get(plist, cx_str("name"));
        cxmutstr path = cfg_param_get(plist, cx_str("path"));
        cxmutstr uri  = cfg_param_get(plist, cx_str("uri"));
        
        if(name.ptr) {
            acl->id = name;
            cxListAdd(aclf->namedACLs, acl);
        } else if(path.ptr) {
            acl->id = path;
            cxListAdd(aclf->pathACLs, acl);
        } else if(uri.ptr) {
            acl->id = uri;
            cxListAdd(aclf->uriACLs, acl);
        }
        
        if(type.ptr) {
            acl->type = type;
        }
    } else if(cx_strprefix(cx_strcast(line), cx_str("Authenticate "))) {
        cxmutstr param = cx_strsubs_m(line, 13);
        ConfigParam *plist = cfg_param_list(param, mp); 
        aclf->cur->authparam = plist;
    } else {
        if(parse_ace(aclf, line)) {
            // TODO: error
            return 1;
        }
    }
    
    return 0;
}

#define ACE_MAX_TOKENS 2048

int parse_ace(ACLFile *f, cxmutstr line) {
    ACLConfig *cur = f->cur;
    CxAllocator *mp = f->parser.mp;
    
    cxstring *tk = NULL; 
    ssize_t tkn = cx_strsplit_a(mp, cx_strcast(line), cx_str(":"), ACE_MAX_TOKENS, &tk);
    if(!tk || tkn < 3) {
        log_ereport(LOG_FAILURE, "parse_ace: to few tokens: %.*s", (int)line.length, line.ptr);
        return 1;
    }
    
    ACEConfig *ace = OBJ_NEW(mp, ACEConfig);
    memset(ace, 0, sizeof(ACEConfig));
    
    /*
     * first step: determine who is affected by this ace
     */
    int n = 0;
    cxstring s = tk[0];
    
    if(!cx_strcmp(s, cx_str("user"))) {
        // next token is the user name
        s = tk[1];
        n++;
        ace->who = cx_strdup_a(mp, s);
    } else if(!cx_strcmp(s, cx_str("group"))) {
        // next token is the group name
        s = tk[1];
        n++;
        ace->who = cx_strdup_a(mp, s);
        ace->flags = ACLCFG_IDENTIFIER_GROUP;
    } else if(!cx_strcmp(s, cx_str("owner@"))) {
        ace->flags = ACLCFG_OWNER;
    } else if(!cx_strcmp(s, cx_str("group@"))) {
        ace->flags = ACLCFG_GROUP;
    } else if(!cx_strcmp(s, cx_str("everyone@"))) {
        ace->flags = ACLCFG_EVERYONE;
    } else {
        // you can specify only the user name in the ace
        ace->who = cx_strdup_a(mp, s);
    }
    
    n++; //next token
    
    /*
     * get the access mask
     */
    
    if(n >= tkn) {
        // to few tokens
        log_ereport(LOG_FAILURE, "parse_ace: ace incomplete");
        return 1;
    }
    s = tk[n];
    
    cxstring *accessmask = NULL;
    ssize_t maskn = cx_strsplit_a(mp, s, cx_str(","), ACE_MAX_TOKENS, &accessmask);
    for(int i=0;i<maskn;i++) {
        cxstring access = accessmask[i];
        ace->access_mask = ace->access_mask | accstr2int(access);
    }
    cxFree(mp, accessmask);
    n++; // next token
    
    /*
     * get flags (optional) and ace type
     */
    
    int complete = 0;
    while(n < tkn) {
        s = tk[n];
        if(!cx_strcmp(s, cx_str("allow"))) {
            ace->type = ACLCFG_TYPE_ALLOWED;
            complete = 1;
            break;
        } else if(!cx_strcmp(s, cx_str("deny"))) {
            ace->type = ACLCFG_TYPE_DENIED;
            complete = 1;
            break;
        } else if(!cx_strcmp(s, cx_str("audit"))) {
            ace->type = ACLCFG_TYPE_AUDIT;
            complete = 1;
            break;
        } else if(!cx_strcmp(s, cx_str("alarm"))) {
            ace->type = ACLCFG_TYPE_ALARM;
            complete = 1;
            break;
        } else {
            // set flags
            cxstring *flags = NULL;
            ssize_t fln = cx_strsplit_a(mp, s, cx_str(","), ACE_MAX_TOKENS, &flags);
            for(int i=0;i<fln;i++) {
                cxstring flag = flags[i];
                if(!cx_strcmp(flag, cx_str("successful_access_flag"))) {
                    ace->flags = ace->flags | ACLCFG_SUCCESSFUL_ACCESS_FLAG;
                } else if(!cx_strcmp(flag, cx_str("failed_access_flag"))) {
                    ace->flags = ace->flags | ACLCFG_FAILED_ACCESS_ACE_FLAG;
                }
                // TODO: other flags
            }
            free(flags);
        }
        n++;
    }
    
    if(!complete) {
        log_ereport(LOG_FAILURE, "parse_ace: ace incomplete");
        return 1;
    }
    
    CFG_ACE_ADD(&cur->entries, ace);
    
    return 0;
}

uint32_t accstr2int(cxstring access) {
    uint32_t val = 0;
    if(!cx_strcmp(access, cx_str("read"))) {
        val = ACLCFG_READ;
    } else if(!cx_strcmp(access, cx_str("write"))) {
        val = ACLCFG_WRITE;
    } else if(!cx_strcmp(access, cx_str("read_data"))) {
        val = ACLCFG_READ_DATA;
    } else if(!cx_strcmp(access, cx_str("write_data"))) {
        val = ACLCFG_WRITE_DATA;
    } else if(!cx_strcmp(access, cx_str("append"))) {
        val = ACLCFG_APPEND;
    } else if(!cx_strcmp(access, cx_str("add"))) {
        val = ACLCFG_ADD_FILE;
    } else if(!cx_strcmp(access, cx_str("add_file"))) {
        val = ACLCFG_ADD_FILE;
    } else if(!cx_strcmp(access, cx_str("add_subdirectory"))) {
        val = ACLCFG_ADD_SUBDIRECTORY;
    } else if(!cx_strcmp(access, cx_str("read_xattr"))) {
        val = ACLCFG_READ_XATTR;
    } else if(!cx_strcmp(access, cx_str("write_xattr"))) {
        val = ACLCFG_WRITE_XATTR;
    } else if(!cx_strcmp(access, cx_str("execute"))) {
        val = ACLCFG_EXECUTE;
    } else if(!cx_strcmp(access, cx_str("delete_child"))) {
        val = ACLCFG_DELETE_CHILD;
    } else if(!cx_strcmp(access, cx_str("delete"))) {
        val = ACLCFG_DELETE;
    } else if(!cx_strcmp(access, cx_str("read_attributes"))) {
        val = ACLCFG_READ_ATTRIBUTES;
    } else if(!cx_strcmp(access, cx_str("write_attributes"))) {
        val = ACLCFG_WRITE_ATTRIBUTES;
    } else if(!cx_strcmp(access, cx_str("list"))) {
        val = ACLCFG_LIST;
    } else if(!cx_strcmp(access, cx_str("read_acl"))) {
        val = ACLCFG_READ_ACL;
    } else if(!cx_strcmp(access, cx_str("write_acl"))) {
        val = ACLCFG_WRITE_ACL;
    } else if(!cx_strcmp(access, cx_str("write_owner"))) {
        val = ACLCFG_WRITE_OWNER;
    } else if(!cx_strcmp(access, cx_str("synchronize"))) {
        val = ACLCFG_SYNCHRONIZE;
    }
    return val;
}