libatalk/util/netatalk_conf.c

   1 /*
   2   Copyright (c) 2012 Frank Lahm <franklahm@gmail.com>
   3
   4   This program is free software; you can redistribute it and/or modify
   5   it under the terms of the GNU General Public License as published by
   6   the Free Software Foundation; either version 2 of the License, or
   7   (at your option) any later version.
   8
   9   This program is distributed in the hope that it will be useful,
  10   but WITHOUT ANY WARRANTY; without even the implied warranty of
  11   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  12   GNU General Public License for more details.
  13 */
  14
  15 #ifdef HAVE_CONFIG_H
  16 #include "config.h"
  17 #endif /* HAVE_CONFIG_H */
  18
  19 #include <stdio.h>
  20 #include <stdlib.h>
  21 #include <ctype.h>
  22 #include <pwd.h>
  23 #include <grp.h>
  24 #include <utime.h>
  25 #include <errno.h>
  26 #include <string.h>
  27 #include <sys/param.h>
  28 #include <sys/socket.h>
  29 #include <netinet/in.h>
  30 #include <arpa/inet.h>
  31 #include <inttypes.h>
  32 #include <time.h>
  33 #include <regex.h>
  34
  35 #include <atalk/afp.h>
  36 #include <atalk/util.h>
  37 #include <atalk/logger.h>
  38 #include <atalk/ea.h>
  39 #include <atalk/globals.h>
  40 #include <atalk/errchk.h>
  41 #include <atalk/iniparser.h>
  42 #include <atalk/unix.h>
  43 #include <atalk/cnid.h>
  44 #include <atalk/dsi.h>
  45 #include <atalk/uuid.h>
  46 #include <atalk/netatalk_conf.h>
  47
  48 #define VOLPASSLEN  8
  49 #ifndef UUID_PRINTABLE_STRING_LENGTH
  50 #define UUID_PRINTABLE_STRING_LENGTH 37
  51 #endif
  52
  53 #define IS_VAR(a, b) (strncmp((a), (b), 2) == 0)
  54
  55 /**************************************************************
  56  * Locals
  57  **************************************************************/
  58
  59 static int have_uservol = 0; /* whether there's generic user home share in config ("~" or "~/path", but not "~user") */
  60 static struct vol *Volumes = NULL;
  61 static uint16_t    lastvid = 0;
  62
  63 /*
  64  * Get a volumes UUID from the config file.
  65  * If there is none, it is generated and stored there.
  66  *
  67  * Returns pointer to allocated storage on success, NULL on error.
  68  */
  69 static char *get_vol_uuid(const AFPObj *obj, const char *volname)
  70 {
  71     char *volname_conf;
  72     char buf[1024], uuid[UUID_PRINTABLE_STRING_LENGTH], *p;
  73     FILE *fp;
  74     struct stat tmpstat;
  75     int fd;
  76
  77     if ((fp = fopen(obj->options.uuidconf, "r")) != NULL) {  /* read open? */
  78         /* scan in the conf file */
  79         while (fgets(buf, sizeof(buf), fp) != NULL) {
  80             p = buf;
  81             while (p && isblank(*p))
  82                 p++;
  83             if (!p || (*p == '#') || (*p == '\n'))
  84                 continue;                             /* invalid line */
  85             if (*p == '"') {
  86                 p++;
  87                 if ((volname_conf = strtok( p, "\"" )) == NULL)
  88                     continue;                         /* syntax error */
  89             } else {
  90                 if ((volname_conf = strtok( p, " \t" )) == NULL)
  91                     continue;                         /* syntax error: invalid name */
  92             }
  93             p = strchr(p, '\0');
  94             p++;
  95             if (*p == '\0')
  96                 continue;                             /* syntax error */
  97
  98             if (strcmp(volname, volname_conf) != 0)
  99                 continue;                             /* another volume name */
 100
 101             while (p && isblank(*p))
 102                 p++;
 103
 104             if (sscanf(p, "%36s", uuid) == 1 ) {
 105                 for (int i=0; uuid[i]; i++)
 106                     uuid[i] = toupper(uuid[i]);
 107                 LOG(log_debug, logtype_afpd, "get_uuid('%s'): UUID: '%s'", volname, uuid);
 108                 fclose(fp);
 109                 return strdup(uuid);
 110             }
 111         }
 112     }
 113
 114     if (fp)
 115         fclose(fp);
 116
 117     /*  not found or no file, reopen in append mode */
 118
 119     if (stat(obj->options.uuidconf, &tmpstat)) {                /* no file */
 120         if (( fd = creat(obj->options.uuidconf, 0644 )) < 0 ) {
 121             LOG(log_error, logtype_afpd, "ERROR: Cannot create %s (%s).",
 122                 obj->options.uuidconf, strerror(errno));
 123             return NULL;
 124         }
 125         if (( fp = fdopen( fd, "w" )) == NULL ) {
 126             LOG(log_error, logtype_afpd, "ERROR: Cannot fdopen %s (%s).",
 127                 obj->options.uuidconf, strerror(errno));
 128             close(fd);
 129             return NULL;
 130         }
 131     } else if ((fp = fopen(obj->options.uuidconf, "a+")) == NULL) { /* not found */
 132         LOG(log_error, logtype_afpd, "Cannot create or append to %s (%s).",
 133             obj->options.uuidconf, strerror(errno));
 134         return NULL;
 135     }
 136     fseek(fp, 0L, SEEK_END);
 137     if(ftell(fp) == 0) {                     /* size = 0 */
 138         fprintf(fp, "# DON'T TOUCH NOR COPY THOUGHTLESSLY!\n");
 139         fprintf(fp, "# This file is auto-generated by afpd\n");
 140         fprintf(fp, "# and stores UUIDs for TM volumes.\n\n");
 141     } else {
 142         fseek(fp, -1L, SEEK_END);
 143         if(fgetc(fp) != '\n') fputc('\n', fp); /* last char is \n? */
 144     }
 145
 146     /* generate uuid and write to file */
 147     atalk_uuid_t id;
 148     const char *cp;
 149     randombytes((void *)id, 16);
 150     cp = uuid_bin2string(id);
 151
 152     LOG(log_debug, logtype_afpd, "get_uuid('%s'): generated UUID '%s'", volname, cp);
 153
 154     fprintf(fp, "\"%s\"\t%36s\n", volname, cp);
 155     fclose(fp);
 156
 157     return strdup(cp);
 158 }
 159
 160 /*
 161   Check if the underlying filesystem supports EAs.
 162   If not, switch to ea:ad.
 163   As we can't check (requires write access) on ro-volumes, we switch ea:auto
 164   volumes that are options:ro to ea:none.
 165 */
 166 static int do_check_ea_support(const struct vol *vol)
 167 {
 168     int haseas;
 169     char eaname[] = {"org.netatalk.supports-eas.XXXXXX"};
 170     const char *eacontent = "yes";
 171
 172     if ((vol->v_flags & AFPVOL_RO) == AFPVOL_RO) {
 173         LOG(log_note, logtype_afpd, "read-only volume '%s', can't test for EA support, assuming yes", vol->v_localname);
 174         return 1;
 175     }
 176
 177     mktemp(eaname);
 178
 179 //    become_root();
 180
 181     if ((sys_setxattr(vol->v_path, eaname, eacontent, 4, 0)) == 0) {
 182         sys_removexattr(vol->v_path, eaname);
 183         haseas = 1;
 184     } else {
 185         LOG(log_warning, logtype_afpd, "volume \"%s\" does not support Extended Attributes or read-only volume root",
 186             vol->v_localname);
 187         haseas = 0;
 188     }
 189
 190 //    unbecome_root();
 191
 192     return haseas;
 193 }
 194
 195 static void check_ea_support(struct vol *vol)
 196 {
 197     int haseas;
 198     char eaname[] = {"org.netatalk.supports-eas.XXXXXX"};
 199     const char *eacontent = "yes";
 200
 201     haseas = do_check_ea_support(vol);
 202
 203     if (vol->v_vfs_ea == AFPVOL_EA_AUTO) {
 204         if ((vol->v_flags & AFPVOL_RO) == AFPVOL_RO) {
 205             LOG(log_info, logtype_afpd, "read-only volume '%s', can't test for EA support, disabling EAs", vol->v_localname);
 206             vol->v_vfs_ea = AFPVOL_EA_NONE;
 207             return;
 208         }
 209
 210         if (haseas) {
 211             vol->v_vfs_ea = AFPVOL_EA_SYS;
 212         } else {
 213             LOG(log_warning, logtype_afpd, "volume \"%s\" does not support Extended Attributes, using ea:ad instead",
 214                 vol->v_localname);
 215             vol->v_vfs_ea = AFPVOL_EA_AD;
 216         }
 217     }
 218
 219     if (vol->v_adouble == AD_VERSION_EA) {
 220         if (!haseas)
 221             vol->v_adouble = AD_VERSION2;
 222     }
 223 }
 224
 225 /*!
 226  * Check whether a volume supports ACLs
 227  *
 228  * @param vol  (r) volume
 229  *
 230  * @returns        0 if not, 1 if yes
 231  */
 232 static int check_vol_acl_support(const struct vol *vol)
 233 {
 234     int ret = 0;
 235
 236 #ifdef HAVE_SOLARIS_ACLS
 237     ace_t *aces = NULL;
 238     ret = 1;
 239     if (get_nfsv4_acl(vol->v_path, &aces) == -1)
 240         ret = 0;
 241 #endif
 242 #ifdef HAVE_POSIX_ACLS
 243     acl_t acl = NULL;
 244     ret = 1;
 245     if ((acl = acl_get_file(vol->v_path, ACL_TYPE_ACCESS)) == NULL)
 246         ret = 0;
 247 #endif
 248
 249 #ifdef HAVE_SOLARIS_ACLS
 250     if (aces) free(aces);
 251 #endif
 252 #ifdef HAVE_POSIX_ACLS
 253     if (acl) acl_free(acl);
 254 #endif /* HAVE_POSIX_ACLS */
 255
 256     LOG(log_debug, logtype_afpd, "Volume \"%s\" ACL support: %s",
 257         vol->v_path, ret ? "yes" : "no");
 258     return ret;
 259 }
 260
 261 /*
 262  * Handle variable substitutions. here's what we understand:
 263  * $b   -> basename of path
 264  * $c   -> client ip/appletalk address
 265  * $d   -> volume pathname on server
 266  * $f   -> full name (whatever's in the gecos field)
 267  * $g   -> group
 268  * $h   -> hostname
 269  * $i   -> client ip/appletalk address without port
 270  * $s   -> server name (hostname if it doesn't exist)
 271  * $u   -> username (guest is usually nobody)
 272  * $v   -> volume name or basename if null
 273  * $$   -> $
 274  *
 275  * This get's called from readvolfile with
 276  * path = NULL, volname = NULL for xlating the volumes path
 277  * path = path, volname = NULL for xlating the volumes name
 278  * ... and from volumes options parsing code when xlating eg dbpath with
 279  * path = path, volname = volname
 280  *
 281  * Using this information we can reject xlation of any variable depeninding on a login
 282  * context which is not given in the afp master, where we must evaluate this whole stuff
 283  * too for the Zeroconf announcements.
 284  */
 285 static char *volxlate(const AFPObj *obj,
 286                       char *dest,
 287                       size_t destlen,
 288                       const char *src,
 289                       const struct passwd *pwd,
 290                       const char *path,
 291                       const char *volname)
 292 {
 293     char *p, *r;
 294     const char *q;
 295     int len;
 296     char *ret;
 297     int xlatevolname = 0;
 298
 299     if (path && !volname)
 300         /* cf above */
 301         xlatevolname = 1;
 302
 303     if (!src) {
 304         return NULL;
 305     }
 306     if (!dest) {
 307         dest = calloc(destlen +1, 1);
 308     }
 309     ret = dest;
 310     if (!ret) {
 311         return NULL;
 312     }
 313     strlcpy(dest, src, destlen +1);
 314     if ((p = strchr(src, '$')) == NULL) /* nothing to do */
 315         return ret;
 316
 317     /* first part of the path. just forward to the next variable. */
 318     len = MIN((size_t)(p - src), destlen);
 319     if (len > 0) {
 320         destlen -= len;
 321         dest += len;
 322     }
 323
 324     while (p && destlen > 0) {
 325         /* now figure out what the variable is */
 326         q = NULL;
 327         if (IS_VAR(p, "$b")) {
 328             if (path) {
 329                 if ((q = strrchr(path, '/')) == NULL)
 330                     q = path;
 331                 else if (*(q + 1) != '\0')
 332                     q++;
 333             }
 334         } else if (IS_VAR(p, "$c")) {
 335             DSI *dsi = obj->dsi;
 336             len = sprintf(dest, "%s:%u",
 337                           getip_string((struct sockaddr *)&dsi->client),
 338                           getip_port((struct sockaddr *)&dsi->client));
 339             dest += len;
 340             destlen -= len;
 341         } else if (IS_VAR(p, "$d")) {
 342             q = path;
 343         } else if (pwd && IS_VAR(p, "$f")) {
 344             if ((r = strchr(pwd->pw_gecos, ',')))
 345                 *r = '\0';
 346             q = pwd->pw_gecos;
 347         } else if (pwd && IS_VAR(p, "$g")) {
 348             struct group *grp = getgrgid(pwd->pw_gid);
 349             if (grp)
 350                 q = grp->gr_name;
 351         } else if (IS_VAR(p, "$h")) {
 352             q = obj->options.hostname;
 353         } else if (IS_VAR(p, "$i")) {
 354             DSI *dsi = obj->dsi;
 355             q = getip_string((struct sockaddr *)&dsi->client);
 356         } else if (IS_VAR(p, "$s")) {
 357             q = obj->options.hostname;
 358         } else if (obj->username && IS_VAR(p, "$u")) {
 359             char* sep = NULL;
 360             if ( obj->options.ntseparator && (sep = strchr(obj->username, obj->options.ntseparator[0])) != NULL)
 361                 q = sep+1;
 362             else
 363                 q = obj->username;
 364         } else if (IS_VAR(p, "$v")) {
 365             if (volname) {
 366                 q = volname;
 367             }
 368             else if (path) {
 369                 if ((q = strrchr(path, '/')) == NULL)
 370                     q = path;
 371                 else if (*(q + 1) != '\0')
 372                     q++;
 373             }
 374         } else if (IS_VAR(p, "$$")) {
 375             q = "$";
 376         } else
 377             q = p;
 378
 379         /* copy the stuff over. if we don't understand something that we
 380          * should, just skip it over. */
 381         if (q) {
 382             len = MIN(p == q ? 2 : strlen(q), destlen);
 383             strncpy(dest, q, len);
 384             dest += len;
 385             destlen -= len;
 386         }
 387
 388         /* stuff up to next $ */
 389         src = p + 2;
 390         p = strchr(src, '$');
 391         len = p ? MIN((size_t)(p - src), destlen) : destlen;
 392         if (len > 0) {
 393             strncpy(dest, src, len);
 394             dest += len;
 395             destlen -= len;
 396         }
 397     }
 398     return ret;
 399 }
 400
 401 /*!
 402  * check access list
 403  *
 404  * this function wants something of the following form:
 405  * "@group,name,name2,@group2,name3"
 406  * A NULL argument allows everybody to have access.
 407  * We return three things:
 408  *     -1: no list
 409  *      0: list exists, but name isn't in it
 410  *      1: in list
 411  */
 412 static int accessvol(const AFPObj *obj, const char *args, const char *name)
 413 {
 414     char buf[MAXPATHLEN + 1], *p;
 415     struct group *gr;
 416
 417     if (!args)
 418         return -1;
 419
 420     strlcpy(buf, args, sizeof(buf));
 421     if ((p = strtok(buf, ",")) == NULL) /* nothing, return okay */
 422         return -1;
 423
 424     while (p) {
 425         if (*p == '@') { /* it's a group */
 426             if ((gr = getgrnam(p + 1)) && gmem(gr->gr_gid, obj->ngroups, obj->groups))
 427                 return 1;
 428         } else if (strcasecmp(p, name) == 0) /* it's a user name */
 429             return 1;
 430         p = strtok(NULL, ",");
 431     }
 432
 433     return 0;
 434 }
 435
 436 static int hostaccessvol(const AFPObj *obj, const char *volname, const char *args)
 437 {
 438     int mask_int;
 439     char buf[MAXPATHLEN + 1], *p, *b;
 440     struct sockaddr_storage client;
 441     const DSI *dsi = obj->dsi;
 442
 443     if (!args || !dsi)
 444         return -1;
 445
 446     strlcpy(buf, args, sizeof(buf));
 447     if ((p = strtok_r(buf, ",", &b)) == NULL) /* nothing, return okay */
 448         return -1;
 449
 450     while (p) {
 451         int ret;
 452         char *ipaddr, *mask_char;
 453         struct addrinfo hints, *ai;
 454
 455         ipaddr = strtok(p, "/");
 456         mask_char = strtok(NULL,"/");
 457
 458         /* Get address from string with getaddrinfo */
 459         memset(&hints, 0, sizeof hints);
 460         hints.ai_family = AF_UNSPEC;
 461         hints.ai_socktype = SOCK_STREAM;
 462         if ((ret = getaddrinfo(ipaddr, NULL, &hints, &ai)) != 0) {
 463             LOG(log_error, logtype_afpd, "hostaccessvol: getaddrinfo: %s\n", gai_strerror(ret));
 464             continue;
 465         }
 466
 467         /* netmask */
 468         if (mask_char != NULL)
 469             mask_int = atoi(mask_char); /* apply_ip_mask does range checking on it */
 470         else {
 471             if (ai->ai_family == AF_INET) /* IPv4 */
 472                 mask_int = 32;
 473             else                          /* IPv6 */
 474                 mask_int = 128;
 475         }
 476
 477         /* Apply mask to addresses */
 478         client = dsi->client;
 479         apply_ip_mask((struct sockaddr *)&client, mask_int);
 480         apply_ip_mask(ai->ai_addr, mask_int);
 481
 482         if (compare_ip((struct sockaddr *)&client, ai->ai_addr) == 0) {
 483             freeaddrinfo(ai);
 484             return 1;
 485         }
 486
 487         /* next address */
 488         freeaddrinfo(ai);
 489         p = strtok_r(NULL, ",", &b);
 490     }
 491
 492     return 0;
 493 }
 494
 495 /*!
 496  * Get option string from config, use default value if not set
 497  *
 498  * @param conf    (r) config handle
 499  * @param vol     (r) volume name (must be section name ie wo vars expanded)
 500  * @param opt     (r) option
 501  * @param def     (r) if "option" is not found in "name", try to find it in section "def"
 502  *
 503  * @returns       const option string or NULL
 504  */
 505 static const char *getoption(const dictionary *conf, const char *vol, const char *opt, const char *def)
 506 {
 507     EC_INIT;
 508     const char *result = NULL;
 509
 510     if ((!(result = iniparser_getstring(conf, vol, opt, NULL))) && (def != NULL))
 511         result = iniparser_getstring(conf, def, opt, NULL);
 512
 513 EC_CLEANUP:
 514     return result;
 515 }
 516
 517 /*!
 518  * Create volume struct
 519  *
 520  * @param obj      (r) handle
 521  * @param pwd      (r) struct passwd of logged in user, may be NULL in master afpd
 522  * @param section  (r) volume name wo variables expanded (exactly as in iniconfig)
 523  * @param name     (r) volume name
 524  * @param path     (r) volume path
 525  * @param preset   (r) default preset, may be NULL
 526  * @returns            vol on success, NULL on error
 527  */
 528 static struct vol *creatvol(AFPObj *obj,
 529                             const struct passwd *pwd,
 530                             const char *section,
 531                             const char *name,
 532                             const char *path,
 533                             const char *preset)
 534 {
 535     EC_INIT;
 536     struct vol  *volume = NULL;
 537     int         suffixlen, vlen, tmpvlen, u8mvlen, macvlen;
 538     char        tmpname[AFPVOL_U8MNAMELEN+1];
 539     ucs2_t      u8mtmpname[(AFPVOL_U8MNAMELEN+1)*2], mactmpname[(AFPVOL_MACNAMELEN+1)*2];
 540     char        suffix[6]; /* max is #FFFF */
 541     uint16_t    flags;
 542     const char  *val;
 543     char        *p, *q;
 544
 545     LOG(log_debug, logtype_afpd, "createvol(volume: '%s', path: \"%s\", preset: '%s'): BEGIN",
 546         name, path, preset ? preset : "-");
 547
 548     if ( name == NULL || *name == '\0' ) {
 549         if ((name = strrchr( path, '/' )) == NULL) {
 550             EC_FAIL;
 551         }
 552
 553         /* if you wish to share /, you need to specify a name. */
 554         if (*++name == '\0')
 555             EC_FAIL;
 556     }
 557
 558     /* Once volumes are loaded, we never change options again, we just delete em when they're removed from afp.conf */
 559     for (struct vol *vol = Volumes; vol; vol = vol->v_next) {
 560         if (STRCMP(path, ==, vol->v_path)) {
 561             LOG(log_debug, logtype_afpd, "createvol('%s'): already loaded", name);
 562             vol->v_deleted = 0;
 563             volume = vol;
 564             goto EC_CLEANUP;
 565         }
 566     }
 567
 568     /*
 569      * Check allow/deny lists:
 570      * allow -> either no list (-1), or in list (1)
 571      * deny -> either no list (-1), or not in list (0)
 572      */
 573     if (pwd) {
 574         if (accessvol(obj, getoption(obj->iniconfig, section, "deny", preset), pwd->pw_name) == 1)
 575             goto EC_CLEANUP;
 576         if (accessvol(obj, getoption(obj->iniconfig, section, "allow", preset), pwd->pw_name) == 0)
 577             goto EC_CLEANUP;
 578         if (hostaccessvol(obj, section, getoption(obj->iniconfig, section, "denied_hosts", preset)) == 1)
 579             goto EC_CLEANUP;
 580         if (hostaccessvol(obj, section, getoption(obj->iniconfig, section, "allowed_hosts", preset)) == 0)
 581             goto EC_CLEANUP;
 582     }
 583
 584     EC_NULL( volume = calloc(1, sizeof(struct vol)) );
 585
 586     volume->v_flags = AFPVOL_USEDOTS | AFPVOL_UNIX_PRIV;
 587     EC_NULL( volume->v_configname = strdup(section));
 588
 589 #ifdef HAVE_ACLS
 590     volume->v_flags |= AFPVOL_ACLS;
 591 #endif
 592     volume->v_vfs_ea = AFPVOL_EA_AUTO;
 593     volume->v_umask = obj->options.umask;
 594
 595     if (val = getoption(obj->iniconfig, section, "password", preset))
 596         EC_NULL( volume->v_password = strdup(val) );
 597
 598     if (val = getoption(obj->iniconfig, section, "veto", preset))
 599         EC_NULL( volume->v_veto = strdup(val) );
 600
 601     if (val = getoption(obj->iniconfig, section, "volcharset", preset))
 602         EC_NULL( volume->v_volcodepage = strdup(val) );
 603     else
 604         EC_NULL( volume->v_volcodepage = strdup("UTF8") );
 605
 606     if (val = getoption(obj->iniconfig, section, "maccharset", preset))
 607         EC_NULL( volume->v_maccodepage = strdup(val) );
 608     else
 609         EC_NULL( volume->v_maccodepage = strdup(obj->options.maccodepage) );
 610
 611     if (val = getoption(obj->iniconfig, section, "dbpath", preset))
 612         EC_NULL( volume->v_dbpath = volxlate(obj, NULL, MAXPATHLEN, val, pwd, path, name) );
 613
 614     if (val = getoption(obj->iniconfig, section, "cnidscheme", preset))
 615         EC_NULL( volume->v_cnidscheme = strdup(val) );
 616     else
 617         volume->v_cnidscheme = strdup(DEFAULT_CNID_SCHEME);
 618
 619     if (val = getoption(obj->iniconfig, section, "umask", preset))
 620         volume->v_umask = (int)strtol(val, NULL, 8);
 621
 622     if (val = getoption(obj->iniconfig, section, "dperm", preset))
 623         volume->v_dperm = (int)strtol(val, NULL, 8);
 624
 625     if (val = getoption(obj->iniconfig, section, "fperm", preset))
 626         volume->v_fperm = (int)strtol(val, NULL, 8);
 627
 628     if (val = getoption(obj->iniconfig, section, "perm", preset))
 629         volume->v_perm = (int)strtol(val, NULL, 8);
 630
 631     if (val = getoption(obj->iniconfig, section, "volsizelimit", preset))
 632         volume->v_limitsize = (uint32_t)strtoul(val, NULL, 10);
 633
 634     if (val = getoption(obj->iniconfig, section, "preexec", preset))
 635         EC_NULL( volume->v_preexec = volxlate(obj, NULL, MAXPATHLEN, val, pwd, path, name) );
 636
 637     if (val = getoption(obj->iniconfig, section, "postexec", preset))
 638         EC_NULL( volume->v_postexec = volxlate(obj, NULL, MAXPATHLEN, val, pwd, path, name) );
 639
 640     if (val = getoption(obj->iniconfig, section, "root_preexec", preset))
 641         EC_NULL( volume->v_root_preexec = volxlate(obj, NULL, MAXPATHLEN, val, pwd, path, name) );
 642
 643     if (val = getoption(obj->iniconfig, section, "root_postexec", preset))
 644         EC_NULL( volume->v_root_postexec = volxlate(obj, NULL, MAXPATHLEN, val, pwd, path, name) );
 645
 646     if (val = getoption(obj->iniconfig, section, "adouble", preset)) {
 647         if (strcmp(val, "v2") == 0)
 648             volume->v_adouble = AD_VERSION2;
 649         else if (strcmp(val, "ea") == 0)
 650             volume->v_adouble = AD_VERSION_EA;
 651     } else {
 652         volume->v_adouble = AD_VERSION;
 653     }
 654
 655     if (val = getoption(obj->iniconfig, section, "cnidserver", preset)) {
 656         EC_NULL( p = strdup(val) );
 657         volume->v_cnidserver = p;
 658         if (q = strrchr(val, ':')) {
 659             *q++ = 0;
 660             volume->v_cnidport = strdup(q);
 661         } else {
 662             volume->v_cnidport = strdup("4700");
 663         }
 664
 665     } else {
 666         volume->v_cnidserver = strdup(obj->options.Cnid_srv);
 667         volume->v_cnidport = strdup(obj->options.Cnid_port);
 668     }
 669
 670     if (val = getoption(obj->iniconfig, section, "ea", preset)) {
 671         if (strcasecmp(val, "ad") == 0)
 672             volume->v_vfs_ea = AFPVOL_EA_AD;
 673         else if (strcasecmp(val, "sys") == 0)
 674             volume->v_vfs_ea = AFPVOL_EA_SYS;
 675         else if (strcasecmp(val, "none") == 0)
 676             volume->v_vfs_ea = AFPVOL_EA_NONE;
 677     }
 678
 679     if (val = getoption(obj->iniconfig, section, "casefold", preset)) {
 680         if (strcasecmp(val, "tolower") == 0)
 681             volume->v_casefold = AFPVOL_UMLOWER;
 682         else if (strcasecmp(val, "toupper") == 0)
 683             volume->v_casefold = AFPVOL_UMUPPER;
 684         else if (strcasecmp(val, "xlatelower") == 0)
 685             volume->v_casefold = AFPVOL_UUPPERMLOWER;
 686         else if (strcasecmp(val, "xlateupper") == 0)
 687             volume->v_casefold = AFPVOL_ULOWERMUPPER;
 688     }
 689
 690     if (val = getoption(obj->iniconfig, section, "options", preset)) {
 691         q = strdup(val);
 692         if (p = strtok(q, ", ")) {
 693             while (p) {
 694                 if (strcasecmp(p, "ro") == 0)
 695                     volume->v_flags |= AFPVOL_RO;
 696                 else if (strcasecmp(p, "nohex") == 0)
 697                     volume->v_flags |= AFPVOL_NOHEX;
 698                 else if (strcasecmp(p, "nousedots") == 0)
 699                     volume->v_flags &= ~AFPVOL_USEDOTS;
 700                 else if (strcasecmp(p, "invisibledots") == 0)
 701                     volume->v_flags |= volume->v_flags;
 702                 else if (strcasecmp(p, "nostat") == 0)
 703                     volume->v_flags |= AFPVOL_NOSTAT;
 704                 else if (strcasecmp(p, "noupriv") == 0)
 705                     volume->v_flags &= ~AFPVOL_UNIX_PRIV;
 706                 else if (strcasecmp(p, "nodev") == 0)
 707                     volume->v_flags |= AFPVOL_NODEV;
 708                 else if (strcasecmp(p, "caseinsensitive") == 0)
 709                     volume->v_flags |= AFPVOL_CASEINSEN;
 710                 else if (strcasecmp(p, "illegalseq") == 0)
 711                     volume->v_flags |= AFPVOL_EILSEQ;
 712                 else if (strcasecmp(p, "tm") == 0)
 713                     volume->v_flags |= AFPVOL_TM;
 714                 else if (strcasecmp(p, "searchdb") == 0)
 715                     volume->v_flags |= AFPVOL_SEARCHDB;
 716                 else if (strcasecmp(p, "nonetids") == 0)
 717                     volume->v_flags |= AFPVOL_NONETIDS;
 718                 else if (strcasecmp(p, "noacls") == 0)
 719                     volume->v_flags &= ~AFPVOL_ACLS;
 720                 else if (strcasecmp(p, "nov2toeaconv") == 0)
 721                     volume->v_flags |= AFPVOL_NOV2TOEACONV;
 722                 else if (strcasecmp(p, "preexec_close") == 0)
 723                     volume->v_preexec_close = 1;
 724                 else if (strcasecmp(p, "root_preexec_close") == 0)
 725                     volume->v_root_preexec_close = 1;
 726                 p = strtok(NULL, ", ");
 727             }
 728         }
 729         free(q);
 730     }
 731
 732     /*
 733      * Handle read-only behaviour. semantics:
 734      * 1) neither the rolist nor the rwlist exist -> rw
 735      * 2) rolist exists -> ro if user is in it.
 736      * 3) rwlist exists -> ro unless user is in it.
 737      */
 738     if (pwd) {
 739         if (accessvol(obj, getoption(obj->iniconfig, section, "rolist", preset), pwd->pw_name) == 1
 740             || accessvol(obj, getoption(obj->iniconfig, section, "rwlist", preset), pwd->pw_name) == 0)
 741             volume->v_flags |= AFPVOL_RO;
 742     }
 743
 744     if ((volume->v_flags & AFPVOL_NODEV))
 745         volume->v_ad_options |= ADVOL_NODEV;
 746     if ((volume->v_flags & AFPVOL_UNIX_PRIV))
 747         volume->v_ad_options |= ADVOL_UNIXPRIV;
 748     if ((volume->v_flags & AFPVOL_INV_DOTS))
 749         volume->v_ad_options |= ADVOL_INVDOTS;
 750
 751     /* Mac to Unix conversion flags*/
 752     if (!(volume->v_flags & AFPVOL_NOHEX))
 753         volume->v_mtou_flags |= CONV_ESCAPEHEX;
 754     if (!(volume->v_flags & AFPVOL_USEDOTS))
 755         volume->v_mtou_flags |= CONV_ESCAPEDOTS;
 756     if ((volume->v_flags & AFPVOL_EILSEQ))
 757         volume->v_mtou_flags |= CONV__EILSEQ;
 758
 759     if ((volume->v_casefold & AFPVOL_MTOUUPPER))
 760         volume->v_mtou_flags |= CONV_TOUPPER;
 761     else if ((volume->v_casefold & AFPVOL_MTOULOWER))
 762         volume->v_mtou_flags |= CONV_TOLOWER;
 763
 764     /* Unix to Mac conversion flags*/
 765     volume->v_utom_flags = CONV_IGNORE | CONV_UNESCAPEHEX;
 766     if ((volume->v_casefold & AFPVOL_UTOMUPPER))
 767         volume->v_utom_flags |= CONV_TOUPPER;
 768     else if ((volume->v_casefold & AFPVOL_UTOMLOWER))
 769         volume->v_utom_flags |= CONV_TOLOWER;
 770     if ((volume->v_flags & AFPVOL_EILSEQ))
 771         volume->v_utom_flags |= CONV__EILSEQ;
 772
 773     /* suffix for mangling use (lastvid + 1)   */
 774     /* because v_vid has not been decided yet. */
 775     suffixlen = sprintf(suffix, "#%X", lastvid + 1 );
 776
 777
 778     vlen = strlen( name );
 779
 780     /* Unicode Volume Name */
 781     /* Firstly convert name from unixcharset to UTF8-MAC */
 782     flags = CONV_IGNORE;
 783     tmpvlen = convert_charset(obj->options.unixcharset, CH_UTF8_MAC, 0, name, vlen, tmpname, AFPVOL_U8MNAMELEN, &flags);
 784     if (tmpvlen <= 0) {
 785         strcpy(tmpname, "???");
 786         tmpvlen = 3;
 787     }
 788
 789     /* Do we have to mangle ? */
 790     if ( (flags & CONV_REQMANGLE) || (tmpvlen > obj->options.volnamelen)) {
 791         if (tmpvlen + suffixlen > obj->options.volnamelen) {
 792             flags = CONV_FORCE;
 793             tmpvlen = convert_charset(obj->options.unixcharset, CH_UTF8_MAC, 0, name, vlen, tmpname, obj->options.volnamelen - suffixlen, &flags);
 794             tmpname[tmpvlen >= 0 ? tmpvlen : 0] = 0;
 795         }
 796         strcat(tmpname, suffix);
 797         tmpvlen = strlen(tmpname);
 798     }
 799
 800     /* Secondly convert name from UTF8-MAC to UCS2 */
 801     if ( 0 >= ( u8mvlen = convert_string(CH_UTF8_MAC, CH_UCS2, tmpname, tmpvlen, u8mtmpname, AFPVOL_U8MNAMELEN*2)) )
 802         EC_FAIL;
 803
 804     LOG(log_maxdebug, logtype_afpd, "createvol: Volume '%s' -> UTF8-MAC Name: '%s'", name, tmpname);
 805
 806     /* Maccharset Volume Name */
 807     /* Firsty convert name from unixcharset to maccharset */
 808     flags = CONV_IGNORE;
 809     tmpvlen = convert_charset(obj->options.unixcharset, obj->options.maccharset, 0, name, vlen, tmpname, AFPVOL_U8MNAMELEN, &flags);
 810     if (tmpvlen <= 0) {
 811         strcpy(tmpname, "???");
 812         tmpvlen = 3;
 813     }
 814
 815     /* Do we have to mangle ? */
 816     if ( (flags & CONV_REQMANGLE) || (tmpvlen > AFPVOL_MACNAMELEN)) {
 817         if (tmpvlen + suffixlen > AFPVOL_MACNAMELEN) {
 818             flags = CONV_FORCE;
 819             tmpvlen = convert_charset(obj->options.unixcharset,
 820                                       obj->options.maccharset,
 821                                       0,
 822                                       name,
 823                                       vlen,
 824                                       tmpname,
 825                                       AFPVOL_MACNAMELEN - suffixlen,
 826                                       &flags);
 827             tmpname[tmpvlen >= 0 ? tmpvlen : 0] = 0;
 828         }
 829         strcat(tmpname, suffix);
 830         tmpvlen = strlen(tmpname);
 831     }
 832
 833     /* Secondly convert name from maccharset to UCS2 */
 834     if ( 0 >= ( macvlen = convert_string(obj->options.maccharset,
 835                                          CH_UCS2,
 836                                          tmpname,
 837                                          tmpvlen,
 838                                          mactmpname,
 839                                          AFPVOL_U8MNAMELEN*2)) )
 840         EC_FAIL;
 841
 842     LOG(log_maxdebug, logtype_afpd, "createvol: Volume '%s' ->  Longname: '%s'", name, tmpname);
 843
 844     EC_NULL( volume->v_localname = strdup(name) );
 845     EC_NULL( volume->v_u8mname = strdup_w(u8mtmpname) );
 846     EC_NULL( volume->v_macname = strdup_w(mactmpname) );
 847     EC_NULL( volume->v_path = malloc(strlen(path) + 1) );
 848
 849     volume->v_name = utf8_encoding(obj) ? volume->v_u8mname : volume->v_macname;
 850     strcpy(volume->v_path, path);
 851
 852 #ifdef __svr4__
 853     volume->v_qfd = -1;
 854 #endif /* __svr4__ */
 855
 856     /* os X start at 1 and use network order ie. 1 2 3 */
 857     volume->v_vid = ++lastvid;
 858     volume->v_vid = htons(volume->v_vid);
 859
 860 #ifdef HAVE_ACLS
 861     if (!check_vol_acl_support(volume)) {
 862         LOG(log_debug, logtype_afpd, "creatvol(\"%s\"): disabling ACL support", volume->v_path);
 863         volume->v_flags &= ~AFPVOL_ACLS;
 864     }
 865 #endif
 866
 867     volume->v_dperm |= volume->v_perm;
 868     volume->v_fperm |= volume->v_perm;
 869
 870     /* Check EA support on volume */
 871     if (volume->v_vfs_ea == AFPVOL_EA_AUTO || volume->v_adouble == AD_VERSION_EA)
 872         check_ea_support(volume);
 873     initvol_vfs(volume);
 874
 875     /* get/store uuid from file in afpd master*/
 876     if (!(pwd) && (volume->v_flags & AFPVOL_TM)) {
 877         char *uuid = get_vol_uuid(obj, volume->v_localname);
 878         if (!uuid) {
 879             LOG(log_error, logtype_afpd, "Volume '%s': couldn't get UUID",
 880                 volume->v_localname);
 881         } else {
 882             volume->v_uuid = uuid;
 883             LOG(log_debug, logtype_afpd, "Volume '%s': UUID '%s'",
 884                 volume->v_localname, volume->v_uuid);
 885         }
 886     }
 887
 888     /* no errors shall happen beyond this point because the cleanup would mess the volume chain up */
 889     volume->v_next = Volumes;
 890     Volumes = volume;
 891     volume->v_obj = obj;
 892
 893 EC_CLEANUP:
 894     LOG(log_debug, logtype_afpd, "createvol: END: %d", ret);
 895     if (ret != 0) {
 896         if (volume) {
 897             volume_free(volume);
 898             free(volume);
 899         }
 900         return NULL;
 901     }
 902     return volume;
 903 }
 904
 905 /* ----------------------
 906  */
 907 static int volfile_changed(struct afp_options *p)
 908 {
 909     struct stat st;
 910
 911     if (!stat(p->configfile, &st) && st.st_mtime > p->volfile.mtime) {
 912         p->volfile.mtime = st.st_mtime;
 913         return 1;
 914     }
 915     return 0;
 916 }
 917
 918 static int vol_section(const char *sec)
 919 {
 920     if (STRCMP(sec, ==, INISEC_GLOBAL))
 921         return 0;
 922     return 1;
 923 }
 924
 925 #define MAXPRESETLEN 100
 926 /*!
 927  * Read volumes from iniconfig and add the volumes contained within to
 928  * the global volume list. This gets called from the forked afpd childs.
 929  * The master now reads this too for Zeroconf announcements.
 930  */
 931 static int readvolfile(AFPObj *obj, const struct passwd *pwent)
 932 {
 933     EC_INIT;
 934     char        path[MAXPATHLEN + 1];
 935     char        volname[AFPVOL_U8MNAMELEN + 1];
 936     char        tmp[MAXPATHLEN + 1];
 937     const char  *preset, *default_preset, *p;
 938     char        *q, *u;
 939     int         i;
 940     struct passwd   *pw;
 941
 942     LOG(log_debug, logtype_afpd, "readvolfile: BEGIN");
 943
 944     int secnum = iniparser_getnsec(obj->iniconfig);
 945     LOG(log_debug, logtype_afpd, "readvolfile: sections: %d", secnum);
 946     const char *secname;
 947
 948     if ((default_preset = iniparser_getstring(obj->iniconfig, INISEC_GLOBAL, "vol preset", NULL))) {
 949         LOG(log_debug, logtype_afpd, "readvolfile: default_preset: %s", default_preset);
 950     }
 951
 952     for (i = 0; i < secnum; i++) {
 953         secname = iniparser_getsecname(obj->iniconfig, i);
 954
 955         if (!vol_section(secname))
 956             continue;
 957         if (STRCMP(secname, ==, INISEC_HOMES)) {
 958             have_uservol = 1;
 959             if (!obj->uid)
 960                 /* not an AFP session, but cnid daemon, dbd or ad util */
 961                 continue;
 962             strlcpy(tmp, pwent->pw_dir, MAXPATHLEN);
 963             strlcat(tmp, "/", MAXPATHLEN);
 964             if (p = iniparser_getstring(obj->iniconfig, INISEC_HOMES, "path", NULL))
 965                 strlcat(tmp, p, MAXPATHLEN);
 966         } else {
 967             /* Get path */
 968             if ((p = iniparser_getstring(obj->iniconfig, secname, "path", NULL)) == NULL)
 969                 continue;
 970             strlcpy(tmp, p, MAXPATHLEN);
 971         }
 972
 973         if (volxlate(obj, path, sizeof(path) - 1, tmp, pwent, NULL, NULL) == NULL)
 974             continue;
 975
 976         /* do variable substitution for volume name */
 977         if (STRCMP(secname, ==, INISEC_HOMES)) {
 978             if (p = iniparser_getstring(obj->iniconfig, INISEC_HOMES, "name", "$u's home"))
 979                 strlcpy(tmp, p, MAXPATHLEN);
 980             else
 981                 strlcpy(tmp, p, MAXPATHLEN);
 982         } else {
 983             strlcpy(tmp, secname, AFPVOL_U8MNAMELEN);
 984         }
 985         if (volxlate(obj, volname, sizeof(volname) - 1, tmp, pwent, path, NULL) == NULL)
 986             continue;
 987
 988         preset = iniparser_getstring(obj->iniconfig, secname, "vol preset", NULL);
 989
 990         creatvol(obj, pwent, secname, volname, path, preset ? preset : default_preset ? default_preset : NULL);
 991     }
 992
 993 EC_CLEANUP:
 994     EC_EXIT;
 995 }
 996
 997 /**************************************************************
 998  * API functions
 999  **************************************************************/
1000
1001 /*!
1002  * Remove a volume from the linked list of volumes
1003  */
1004 void volume_unlink(struct vol *volume)
1005 {
1006     struct vol *vol, *ovol, *nvol;
1007
1008     if (volume == Volumes) {
1009         Volumes = NULL;
1010         return;
1011     }
1012     for ( vol = Volumes->v_next, ovol = Volumes; vol; vol = nvol) {
1013         nvol = vol->v_next;
1014
1015         if (vol == volume) {
1016             ovol->v_next = nvol;
1017             break;
1018         }
1019         else {
1020             ovol = vol;
1021         }
1022     }
1023 }
1024
1025 /*!
1026  * Free all resources allocated in a struct vol, only struct dir *v_root can't be freed
1027  */
1028 void volume_free(struct vol *vol)
1029 {
1030     LOG(log_debug, logtype_afpd, "volume_free('%s'): BEGIN", vol->v_localname);
1031
1032     free(vol->v_localname);
1033     free(vol->v_u8mname);
1034     free(vol->v_macname);
1035     free(vol->v_path);
1036     free(vol->v_password);
1037     free(vol->v_veto);
1038     free(vol->v_volcodepage);
1039     free(vol->v_maccodepage);
1040     free(vol->v_cnidscheme);
1041     free(vol->v_dbpath);
1042     free(vol->v_gvs);
1043     free(vol->v_uuid);
1044     free(vol->v_cnidserver);
1045     free(vol->v_cnidport);
1046     free(vol->v_root_preexec);
1047     free(vol->v_postexec);
1048
1049     LOG(log_debug, logtype_afpd, "volume_free: END");
1050 }
1051
1052 /*!
1053  * Load charsets for a volume
1054  */
1055 int load_charset(struct vol *vol)
1056 {
1057     if ((vol->v_maccharset = add_charset(vol->v_maccodepage)) == (charset_t)-1) {
1058         LOG(log_error, logtype_default, "Setting Mac codepage '%s' failed", vol->v_maccodepage);
1059         return -1;
1060     }
1061
1062     if ((vol->v_volcharset = add_charset(vol->v_volcodepage)) == (charset_t)-1) {
1063         LOG(log_error, logtype_default, "Setting volume codepage '%s' failed", vol->v_volcodepage);
1064         return -1;
1065     }
1066
1067     return 0;
1068 }
1069
1070 /*!
1071  * Initialize volumes and load ini configfile
1072  *
1073  * Depending on the value of obj->uid either access checks are done (!=0) or skipped (=0)
1074  *
1075  * @param obj       (r) handle
1076  * @param delvol_fn (r) callback called for deleted volumes
1077  */
1078 int load_volumes(AFPObj *obj, void (*delvol_fn)(struct vol *))
1079 {
1080     EC_INIT;
1081     int fd = -1;
1082     struct passwd   *pwent = NULL;
1083     struct stat         st;
1084     int retries = 0;
1085     struct vol *vol;
1086
1087     LOG(log_debug, logtype_afpd, "load_volumes: BEGIN");
1088
1089     if (Volumes) {
1090         if (!volfile_changed(&obj->options))
1091             goto EC_CLEANUP;
1092         have_uservol = 0;
1093         for (vol = Volumes; vol; vol = vol->v_next) {
1094             if (vol->v_flags & AFPVOL_UNIX_CTXT)
1095                 continue;
1096             vol->v_deleted = 1;
1097         }
1098     } else {
1099         LOG(log_debug, logtype_afpd, "load_volumes: no volumes yet");
1100         EC_ZERO_LOG( lstat(obj->options.configfile, &st) );
1101         obj->options.volfile.mtime = st.st_mtime;
1102     }
1103
1104     /* try putting a read lock on the volume file twice, sleep 1 second if first attempt fails */
1105
1106     fd = open(obj->options.configfile, O_RDONLY);
1107
1108     while (retries < 2) {
1109         if ((read_lock(fd, 0, SEEK_SET, 0)) != 0) {
1110             retries++;
1111             if (!retries) {
1112                 LOG(log_error, logtype_afpd, "readvolfile: can't lock configfile \"%s\"",
1113                     obj->options.configfile);
1114                 EC_FAIL;
1115             }
1116             sleep(1);
1117             continue;
1118         }
1119         break;
1120     }
1121
1122     if (obj->uid)
1123         pwent = getpwuid(obj->uid);
1124
1125     if (obj->iniconfig)
1126         iniparser_freedict(obj->iniconfig);
1127     LOG(log_debug, logtype_afpd, "load_volumes: loading: %s", obj->options.configfile);
1128     obj->iniconfig = iniparser_load(obj->options.configfile);
1129
1130     EC_ZERO_LOG( readvolfile(obj, pwent) );
1131
1132     for ( vol = Volumes; vol; vol = vol->v_next ) {
1133         if (vol->v_deleted) {
1134             LOG(log_debug, logtype_afpd, "load_volumes: deleted: %s", vol->v_localname);
1135             if (delvol_fn)
1136                 delvol_fn(vol);
1137             vol = Volumes;
1138         }
1139     }
1140
1141 EC_CLEANUP:
1142     if (fd != -1)
1143         (void)close(fd);
1144
1145     LOG(log_debug, logtype_afpd, "load_volumes: END");
1146     EC_EXIT;
1147 }
1148
1149 void unload_volumes(AFPObj *obj)
1150 {
1151     struct vol *vol;
1152
1153     LOG(log_debug, logtype_afpd, "unload_volumes: BEGIN");
1154
1155     for (vol = Volumes; vol; vol = vol->v_next)
1156         volume_free(vol);
1157     Volumes = NULL;
1158     obj->options.volfile.mtime = 0;
1159
1160     LOG(log_debug, logtype_afpd, "unload_volumes: END");
1161 }
1162
1163 struct vol *getvolumes(void)
1164 {
1165     return Volumes;
1166 }
1167
1168 struct vol *getvolbyvid(const uint16_t vid )
1169 {
1170     struct vol  *vol;
1171
1172     for ( vol = Volumes; vol; vol = vol->v_next ) {
1173         if ( vid == vol->v_vid ) {
1174             break;
1175         }
1176     }
1177     if ( vol == NULL || ( vol->v_flags & AFPVOL_OPEN ) == 0 ) {
1178         return( NULL );
1179     }
1180
1181     return( vol );
1182 }
1183
1184 /*!
1185  * Search volume by path, creating user home vols as necessary
1186  *
1187  * Path may be absolute or relative. Ordinary volume structs are created when
1188  * the ini config is initially parsed (load_volumes()), but user volumes are
1189  * as load_volumes() only can create the user volume of the logged in user
1190  * in an AFP session in afpd, but not when called from eg cnid_metad or dbd.
1191  * Both cnid_metad and dbd thus need a way to lookup and create struct vols
1192  * for user home by path. This is what this func does as well.
1193  *
1194  * (1) Search "normal" volume list
1195  * (2) Check if theres a [Homes] section, load_volumes() remembers this for us
1196  * (3) If there is, match "path" with "basedir regex" to get the user home parent dir
1197  * (4) Built user home path by appending the basedir matched in (3) and appending the username
1198  * (5) The next path element then is the username
1199  * (6) Append [Homes]->path subdirectory if defined
1200  * (7) Create volume
1201  *
1202  * @param obj  (rw) handle
1203  * @param path (r)  path, may be relative or absolute
1204  */
1205 struct vol *getvolbypath(AFPObj *obj, const char *path)
1206 {
1207     EC_INIT;
1208     struct vol *vol;
1209     struct vol *tmp;
1210     const struct passwd *pw;
1211     char        volname[AFPVOL_U8MNAMELEN + 1];
1212     char        abspath[MAXPATHLEN + 1];
1213     char        volpath[MAXPATHLEN + 1];
1214     char        tmpbuf[MAXPATHLEN + 1];
1215     const char *secname, *basedir, *p = NULL, *subpath = NULL, *subpathconfig;
1216     char *user = NULL, *prw;
1217     int regexerr = -1;
1218     static regex_t reg;
1219     regmatch_t match[1];
1220
1221     LOG(log_debug, logtype_afpd, "getvolbypath(\"%s\")", path);
1222
1223     if (path[0] != '/') {
1224         /* relative path, build absolute path */
1225         EC_NULL_LOG( getcwd(abspath, MAXPATHLEN) );
1226         strlcat(abspath, "/", MAXPATHLEN);
1227         strlcat(abspath, path, MAXPATHLEN);
1228         path = abspath;
1229     }
1230
1231
1232     for (tmp = Volumes; tmp; tmp = tmp->v_next) { /* (1) */
1233         if (strncmp(path, tmp->v_path, strlen(tmp->v_path)) == 0) {
1234             vol = tmp;
1235             goto EC_CLEANUP;
1236         }
1237     }
1238
1239     if (!have_uservol) /* (2) */
1240         EC_FAIL_LOG("getvolbypath(\"%s\"): no volume for path", path);
1241
1242     int secnum = iniparser_getnsec(obj->iniconfig);
1243
1244     for (int i = 0; i < secnum; i++) {
1245         secname = iniparser_getsecname(obj->iniconfig, i);
1246         if (STRCMP(secname, ==, INISEC_HOMES))
1247             break;
1248     }
1249
1250     if (STRCMP(secname, !=, INISEC_HOMES))
1251         EC_FAIL_LOG("getvolbypath(\"%s\"): no volume for path", path);
1252
1253     /* (3) */
1254     EC_NULL_LOG( basedir = iniparser_getstring(obj->iniconfig, INISEC_HOMES, "basedir regex", NULL) );
1255     LOG(log_debug, logtype_afpd, "getvolbypath: user home section: '%s', basedir: '%s'", secname, basedir);
1256
1257     if (regexerr != 0 && (regexerr = regcomp(&reg, basedir, REG_EXTENDED)) != 0) {
1258         char errbuf[1024];
1259         regerror(regexerr, &reg, errbuf, sizeof(errbuf));
1260         printf("error: %s\n", errbuf);
1261         EC_FAIL_LOG("getvolbypath(\"%s\"): bad basedir regex: %s", errbuf);
1262     }
1263
1264     if (regexec(&reg, path, 1, match, 0) == REG_NOMATCH)
1265         EC_FAIL_LOG("getvolbypath(\"%s\"): no volume for path", path);
1266
1267     if (match[0].rm_eo - match[0].rm_so > MAXPATHLEN)
1268         EC_FAIL_LOG("getvolbypath(\"%s\"): path too long", path);
1269
1270     /* (4) */
1271     strncpy(tmpbuf, path + match[0].rm_so, match[0].rm_eo - match[0].rm_so);
1272     tmpbuf[match[0].rm_eo - match[0].rm_so] = 0;
1273
1274     LOG(log_debug, logtype_afpd, "getvolbypath: basedir regex: '%s', basedir match: \"%s\"",
1275         basedir, tmpbuf);
1276
1277     strlcat(tmpbuf, "/", MAXPATHLEN);
1278
1279     /* (5) */
1280     p = path + strlen(basedir);
1281     while (*p == '/')
1282         p++;
1283     EC_NULL_LOG( user = strdup(p) );
1284
1285     if (prw = strchr(user, '/'))
1286         *prw++ = 0;
1287     if (prw != 0)
1288         subpath = prw;
1289
1290     strlcpy(obj->username, user, MAXUSERLEN);
1291     strlcat(tmpbuf, user, MAXPATHLEN);
1292     strlcat(tmpbuf, "/", MAXPATHLEN);
1293
1294     /* (6) */
1295     if (subpathconfig = iniparser_getstring(obj->iniconfig, INISEC_HOMES, "path", NULL)) {
1296         if (!subpath || strncmp(subpathconfig, subpath, strlen(subpathconfig)) != 0) {
1297             EC_FAIL;
1298         }
1299         strlcat(tmpbuf, subpathconfig, MAXPATHLEN);
1300         strlcat(tmpbuf, "/", MAXPATHLEN);
1301     }
1302
1303
1304     /* (7) */
1305     if (volxlate(obj, volpath, sizeof(volpath) - 1, tmpbuf, pw, NULL, NULL) == NULL)
1306         return NULL;
1307
1308     EC_NULL( pw = getpwnam(user) );
1309
1310     LOG(log_debug, logtype_afpd, "getvolbypath(\"%s\"): user: %s, homedir: %s => volpath: \"%s\"",
1311         path, user, pw->pw_dir, volpath);
1312
1313     /* do variable substitution for volume name */
1314     p = iniparser_getstring(obj->iniconfig, INISEC_HOMES, "name", "$u's home");
1315     strlcpy(tmpbuf, p, AFPVOL_U8MNAMELEN);
1316     EC_NULL_LOG( volxlate(obj, volname, sizeof(volname) - 1, tmpbuf, pw, volpath, NULL) );
1317
1318     const char  *preset, *default_preset;
1319     default_preset = iniparser_getstring(obj->iniconfig, INISEC_GLOBAL, "vol preset", NULL);
1320     preset = iniparser_getstring(obj->iniconfig, INISEC_HOMES, "vol preset", NULL);
1321
1322     vol = creatvol(obj, pw, INISEC_HOMES, volname, volpath, preset ? preset : default_preset ? default_preset : NULL);
1323
1324 EC_CLEANUP:
1325     if (user)
1326         free(user);
1327     if (ret != 0)
1328         vol = NULL;
1329     return vol;
1330 }
1331
1332 struct vol *getvolbyname(const char *name)
1333 {
1334     struct vol *vol = NULL;
1335     struct vol *tmp;
1336
1337     for (tmp = Volumes; tmp; tmp = tmp->v_next) {
1338         if (strncmp(name, tmp->v_configname, strlen(tmp->v_configname)) == 0) {
1339             vol = tmp;
1340             break;
1341         }
1342     }
1343     return vol;
1344 }
1345
1346 #define MAXVAL 1024
1347 /*!
1348  * Initialize an AFPObj and options from ini config file
1349  */
1350 int afp_config_parse(AFPObj *AFPObj)
1351 {
1352     EC_INIT;
1353     dictionary *config;
1354     struct afp_options *options = &AFPObj->options;
1355     int i, c;
1356     const char *p, *tmp;
1357     char *q, *r;
1358     char val[MAXVAL];
1359
1360     AFPObj->afp_version = 11;
1361     options->configfile  = AFPObj->cmdlineconfigfile ? strdup(AFPObj->cmdlineconfigfile) : strdup(_PATH_CONFDIR "afp.conf");
1362     options->sigconffile = strdup(_PATH_CONFDIR "afp_signature.conf");
1363     options->uuidconf    = strdup(_PATH_CONFDIR "afp_voluuid.conf");
1364     options->flags       = OPTION_ACL2MACCESS | OPTION_UUID | OPTION_SERVERNOTIF | AFPObj->cmdlineflags;
1365
1366     if ((config = iniparser_load(AFPObj->options.configfile)) == NULL)
1367         return -1;
1368     AFPObj->iniconfig = config;
1369
1370     /* [Global] */
1371     options->logconfig = iniparser_getstrdup(config, INISEC_GLOBAL, "loglevel", "default:note");
1372     options->logfile   = iniparser_getstrdup(config, INISEC_GLOBAL, "logfile",  NULL);
1373
1374     /* [AFP] "options" options wo values */
1375     if (q = iniparser_getstrdup(config, INISEC_GLOBAL, "options", NULL)) {
1376         if (p = strtok(q, ", ")) {
1377             while (p) {
1378                 if (strcasecmp(p, "nozeroconf"))
1379                     options->flags |= OPTION_NOZEROCONF;
1380                 if (strcasecmp(p, "icon"))
1381                     options->flags |= OPTION_CUSTOMICON;
1382                 if (strcasecmp(p, "noicon"))
1383                     options->flags &= ~OPTION_CUSTOMICON;
1384                 if (strcasecmp(p, "advertise_ssh"))
1385                     options->flags |= OPTION_ANNOUNCESSH;
1386                 if (strcasecmp(p, "noacl2maccess"))
1387                     options->flags &= ~OPTION_ACL2MACCESS;
1388                 if (strcasecmp(p, "keepsessions"))
1389                     options->flags |= OPTION_KEEPSESSIONS;
1390                 if (strcasecmp(p, "closevol"))
1391                     options->flags |= OPTION_CLOSEVOL;
1392                 if (strcasecmp(p, "client_polling"))
1393                     options->flags &= ~OPTION_SERVERNOTIF;
1394                 if (strcasecmp(p, "nosavepassword"))
1395                     options->passwdbits |= PASSWD_NOSAVE;
1396                 if (strcasecmp(p, "savepassword"))
1397                     options->passwdbits &= ~PASSWD_NOSAVE;
1398                 if (strcasecmp(p, "nosetpassword"))
1399                     options->passwdbits &= ~PASSWD_SET;
1400                 if (strcasecmp(p, "setpassword"))
1401                     options->passwdbits |= PASSWD_SET;
1402                 p = strtok(NULL, ", ");
1403             }
1404         }
1405         free(q);
1406     }
1407     /* figure out options w values */
1408
1409     options->loginmesg      = iniparser_getstrdup(config, INISEC_GLOBAL, "loginmesg",      "");
1410     options->guest          = iniparser_getstrdup(config, INISEC_GLOBAL, "guestname",      "nobody");
1411     options->passwdfile     = iniparser_getstrdup(config, INISEC_GLOBAL, "passwdfile",     _PATH_AFPDPWFILE);
1412     options->uampath        = iniparser_getstrdup(config, INISEC_GLOBAL, "uampath",        _PATH_AFPDUAMPATH);
1413     options->uamlist        = iniparser_getstrdup(config, INISEC_GLOBAL, "uamlist",        "uams_dhx.so,uams_dhx2.so");
1414     options->port           = iniparser_getstrdup(config, INISEC_GLOBAL, "afp port",       "548");
1415     options->signatureopt   = iniparser_getstrdup(config, INISEC_GLOBAL, "signature",      "auto");
1416     options->k5service      = iniparser_getstrdup(config, INISEC_GLOBAL, "k5service",      NULL);
1417     options->k5realm        = iniparser_getstrdup(config, INISEC_GLOBAL, "k5realm",        NULL);
1418     options->listen         = iniparser_getstrdup(config, INISEC_GLOBAL, "afp listen",     NULL);
1419     options->ntdomain       = iniparser_getstrdup(config, INISEC_GLOBAL, "ntdomain",       NULL);
1420     options->ntseparator    = iniparser_getstrdup(config, INISEC_GLOBAL, "ntseparator",    NULL);
1421     options->mimicmodel     = iniparser_getstrdup(config, INISEC_GLOBAL, "mimicmodel",     NULL);
1422     options->adminauthuser  = iniparser_getstrdup(config, INISEC_GLOBAL, "adminauthuser",  NULL);
1423     options->connections    = iniparser_getint   (config, INISEC_GLOBAL, "maxcon",         200);
1424     options->passwdminlen   = iniparser_getint   (config, INISEC_GLOBAL, "passwdminlen",   0);
1425     options->tickleval      = iniparser_getint   (config, INISEC_GLOBAL, "tickleval",      30);
1426     options->timeout        = iniparser_getint   (config, INISEC_GLOBAL, "timeout",        4);
1427     options->dsireadbuf     = iniparser_getint   (config, INISEC_GLOBAL, "dsireadbuf",     12);
1428     options->server_quantum = iniparser_getint   (config, INISEC_GLOBAL, "server_quantum", DSI_SERVQUANT_DEF);
1429     options->volnamelen     = iniparser_getint   (config, INISEC_GLOBAL, "volnamelen",     80);
1430     options->dircachesize   = iniparser_getint   (config, INISEC_GLOBAL, "dircachesize",   DEFAULT_MAX_DIRCACHE_SIZE);
1431     options->tcp_sndbuf     = iniparser_getint   (config, INISEC_GLOBAL, "tcpsndbuf",      0);
1432     options->tcp_rcvbuf     = iniparser_getint   (config, INISEC_GLOBAL, "tcprcvbuf",      0);
1433     options->fce_fmodwait   = iniparser_getint   (config, INISEC_GLOBAL, "fceholdfmod",    60);
1434     options->sleep          = iniparser_getint   (config, INISEC_GLOBAL, "sleep",          10);
1435     options->disconnected   = iniparser_getint   (config, INISEC_GLOBAL, "disconnect",     24);
1436
1437     if ((p = iniparser_getstring(config, INISEC_GLOBAL, "hostname", NULL))) {
1438         EC_NULL_LOG( options->hostname = strdup(p) );
1439     } else {
1440         if (gethostname(val, sizeof(val)) < 0 ) {
1441             perror( "gethostname" );
1442             EC_FAIL;
1443         }
1444         if ((q = strchr(val, '.')))
1445             *q = '\0';
1446         options->hostname = strdup(val);
1447     }
1448
1449     if ((p = iniparser_getstring(config, INISEC_GLOBAL, "k5keytab", NULL))) {
1450         EC_NULL_LOG( options->k5keytab = malloc(strlen(p) + 14) );
1451         snprintf(options->k5keytab, strlen(p) + 14, "KRB5_KTNAME=%s", p);
1452         putenv(options->k5keytab);
1453     }
1454
1455 #ifdef ADMIN_GRP
1456     if ((p = iniparser_getstring(config, INISEC_GLOBAL, "admingroup",  NULL))) {
1457          struct group *gr = getgrnam(p);
1458          if (gr != NULL)
1459              options->admingid = gr->gr_gid;
1460     }
1461 #endif /* ADMIN_GRP */
1462
1463     q = iniparser_getstrdup(config, INISEC_GLOBAL, "cnidserver", "localhost:4700");
1464     r = strrchr(q, ':');
1465     if (r)
1466         *r = 0;
1467     options->Cnid_srv = strdup(q);
1468     if (r)
1469         options->Cnid_port = strdup(r + 1);
1470     else
1471         options->Cnid_port = strdup("4700");
1472     LOG(log_debug, logtype_afpd, "CNID Server: %s:%s", options->Cnid_srv, options->Cnid_port);
1473     if (q)
1474         free(q);
1475
1476     if ((q = iniparser_getstrdup(config, INISEC_GLOBAL, "fqdn", NULL))) {
1477         /* do a little checking for the domain name. */
1478         r = strchr(q, ':');
1479         if (r)
1480             *r = '\0';
1481         if (gethostbyname(q)) {
1482             if (r)
1483                 *r = ':';
1484             EC_NULL_LOG( options->fqdn = strdup(q) );
1485         } else {
1486             LOG(log_error, logtype_afpd, "error parsing -fqdn, gethostbyname failed for: %s", c);
1487         }
1488         free(q);
1489     }
1490
1491     if (!(p = iniparser_getstring(config, INISEC_GLOBAL, "unixcodepage", NULL))) {
1492         options->unixcharset = CH_UNIX;
1493         options->unixcodepage = strdup("LOCALE");
1494     } else {
1495         if ((options->unixcharset = add_charset(p)) == (charset_t)-1) {
1496             options->unixcharset = CH_UNIX;
1497             options->unixcodepage = strdup("LOCALE");
1498             LOG(log_warning, logtype_afpd, "Setting Unix codepage to '%s' failed", p);
1499         } else {
1500             options->unixcodepage = strdup(p);
1501         }
1502     }
1503
1504     if (!(p = iniparser_getstring(config, INISEC_GLOBAL, "maccodepage", NULL))) {
1505         options->maccharset = CH_MAC;
1506         options->maccodepage = strdup("MAC_ROMAN");
1507     } else {
1508         if ((options->maccharset = add_charset(p)) == (charset_t)-1) {
1509             options->maccharset = CH_MAC;
1510             options->maccodepage = strdup("MAC_ROMAN");
1511             LOG(log_warning, logtype_afpd, "Setting Mac codepage to '%s' failed", p);
1512         } else {
1513             options->maccodepage = strdup(p);
1514         }
1515     }
1516
1517     /* Check for sane values */
1518     if (options->tickleval <= 0)
1519         options->tickleval = 30;
1520     options->disconnected *= 3600 / options->tickleval;
1521     options->sleep *= 3600 / options->tickleval;
1522     if (options->timeout <= 0)
1523         options->timeout = 4;
1524     if (options->sleep <= 4)
1525         options->disconnected = options->sleep = 4;
1526     if (options->dsireadbuf < 6)
1527         options->dsireadbuf = 6;
1528     if (options->volnamelen < 8)
1529         options->volnamelen = 8; /* max mangled volname "???#FFFF" */
1530     if (options->volnamelen > 255)
1531             options->volnamelen = 255; /* AFP3 spec */
1532
1533 EC_CLEANUP:
1534     EC_EXIT;
1535 }
1536