onak-conf.c

   1 /*
   2  * onak-conf.c - Routines related to runtime config.
   3  *
   4  * Copyright 2002,2012 Jonathan McDowell <noodles@earth.li>
   5  *
   6  * This program is free software: you can redistribute it and/or modify it
   7  * under the terms of the GNU General Public License as published by the Free
   8  * Software Foundation; version 2 of the License.
   9  *
  10  * This program is distributed in the hope that it will be useful, but WITHOUT
  11  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
  12  * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
  13  * more details.
  14  *
  15  * You should have received a copy of the GNU General Public License along with
  16  * this program.  If not, see <https://www.gnu.org/licenses/>.
  17  */
  18 #include <ctype.h>
  19 #include <stdio.h>
  20 #include <stdlib.h>
  21 #include <string.h>
  22 #include <strings.h>
  23
  24 #include "build-config.h"
  25
  26 #include "cleankey.h"
  27 #include "ll.h"
  28 #include "log.h"
  29 #include "onak-conf.h"
  30
  31 #ifdef DBINIT
  32 extern struct onak_dbctx *DBINIT(struct onak_db_config *dbcfg, bool readonly);
  33 #endif
  34
  35 /*
  36  *      config - Runtime configuration for onak.
  37  *
  38  *      This is the default config; normally overridden with values from the
  39  *      config file.
  40  */
  41 struct onak_config config = {
  42         .maxkeys = 128,
  43         .thissite = NULL,
  44         .adminemail = NULL,
  45         .mta = NULL,
  46         .syncsites = NULL,
  47         .logfile = NULL,
  48
  49         .use_keyd = false,
  50         .sock_dir = NULL,
  51
  52         .backends = NULL,
  53         .backends_dir = NULL,
  54
  55 #ifdef DBINIT
  56         .dbinit = DBINIT,
  57 #else
  58         .dbinit = NULL,
  59 #endif
  60
  61         .clean_policies = ONAK_CLEAN_DROP_V3_KEYS | ONAK_CLEAN_CHECK_SIGHASH,
  62
  63         .bin_dir = NULL,
  64         .mail_dir = NULL,
  65 };
  66
  67 struct onak_db_config *find_db_backend_config(struct ll *backends, char *name)
  68 {
  69         struct ll *cur;
  70
  71         cur = backends;
  72         while (cur != NULL && strcmp(name,
  73                         ((struct onak_db_config *) cur->object)->name)) {
  74                 cur = cur->next;
  75         }
  76
  77         return (cur != NULL) ? (struct onak_db_config *) cur->object : NULL;
  78 }
  79
  80 bool parsebool(char *str, bool fallback)
  81 {
  82         if (!strcasecmp(str, "false") || !strcasecmp(str, "no") ||
  83                         !strcasecmp(str, "0")) {
  84                 return false;
  85         } else if (!strcasecmp(str, "true") || !strcasecmp(str, "yes") ||
  86                         !strcasecmp(str, "1")) {
  87                 return true;
  88         } else {
  89                 logthing(LOGTHING_CRITICAL,
  90                         "Couldn't parse %s as a boolean config variable, "
  91                         "returning fallback of '%s'.",
  92                         str,
  93                         fallback ? "true" : "false");
  94                 return fallback;
  95         }
  96 }
  97
  98 /*
  99  * Parse an old pksd style config line, as used in onak 0.4.6 and earlier.
 100  */
 101 static bool parseoldconfigline(char *line)
 102 {
 103         if (line[0] == '#' || line[0] == 0) {
 104                 /*
 105                  * Comment line, ignore.
 106                  */
 107         } else if (!strncmp("db_dir ", line, 7)) {
 108                 config.backend->location = strdup(&line[7]);
 109         } else if (!strncmp("debug ", line, 6)) {
 110                 /*
 111                  * Not supported yet; ignore for compatibility with
 112                  * pksd.
 113                  */
 114         } else if (!strncmp("default_language ", line, 17)) {
 115                 /*
 116                  * Not supported yet; ignore for compatibility with
 117                  * pksd.
 118                  */
 119         } else if (!strncmp("mail_delivery_client ", line, 21)) {
 120                 config.mta = strdup(&line[21]);
 121         } else if (!strncmp("maintainer_email ", line, 17)) {
 122                 config.adminemail = strdup(&line[17]);
 123         } else if (!strncmp("mail_intro_file ", line, 16)) {
 124                 /*
 125                  * Not supported yet; ignore for compatibility with
 126                  * pksd.
 127                  */
 128         } else if (!strncmp("help_dir ", line, 9)) {
 129                 /*
 130                  * Not supported yet; ignore for compatibility with
 131                  * pksd.
 132                  */
 133         } else if (!strncmp("max_last ", line, 9)) {
 134                 /*
 135                  * Not supported yet; ignore for compatibility with
 136                  * pksd.
 137                  */
 138         } else if (!strncmp("max_reply_keys ", line, 15)) {
 139                 config.maxkeys = atoi(&line[15]);
 140         } else if (!strncmp("pg_dbhost ", line, 10)) {
 141                 config.backend->hostname = strdup(&line[10]);
 142         } else if (!strncmp("pg_dbname ", line, 10)) {
 143                 config.backend->location = strdup(&line[10]);
 144         } else if (!strncmp("pg_dbuser ", line, 10)) {
 145                 config.backend->username = strdup(&line[10]);
 146         } else if (!strncmp("pg_dbpass ", line, 10)) {
 147                 config.backend->password = strdup(&line[10]);
 148         } else if (!strncmp("syncsite ", line, 9)) {
 149                 config.syncsites =
 150                         lladd(config.syncsites, strdup(&line[9]));
 151         } else if (!strncmp("logfile ", line, 8)) {
 152                 config.logfile = strdup(&line[8]);
 153         } else if (!strncmp("loglevel ", line, 9)) {
 154                 setlogthreshold(atoi(&line[9]));
 155         } else if (!strncmp("this_site ", line, 10)) {
 156                 config.thissite = strdup(&line[10]);
 157         } else if (!strncmp("socket_name ", line, 12) ||
 158                         !strncmp("www_port ", line, 9)) {
 159                 /*
 160                  * Not applicable; ignored for compatibility with pksd.
 161                  */
 162         } else if (!strncmp("pks_bin_dir ", line, 12)) {
 163                 config.bin_dir = strdup(&line[12]);
 164         } else if (!strncmp("mail_dir ", line, 9)) {
 165                 config.mail_dir = strdup(&line[9]);
 166         } else if (!strncmp("db_backend ", line, 11)) {
 167                 config.backend->type = strdup(&line[11]);
 168                 config.backend->name = strdup(&line[11]);
 169                 config.db_backend = strdup(&line[11]);
 170         } else if (!strncmp("backends_dir ", line, 13)) {
 171                 config.backends_dir = strdup(&line[13]);
 172         } else if (!strncmp("use_keyd ", line, 9)) {
 173                 config.use_keyd = parsebool(&line[9],
 174                                         config.use_keyd);
 175         } else if (!strncmp("sock_dir ", line, 9)) {
 176                 config.sock_dir = strdup(&line[9]);
 177         } else if (!strncmp("check_sighash ", line, 9)) {
 178                 if (parsebool(&line[9], config.clean_policies &
 179                                         ONAK_CLEAN_CHECK_SIGHASH)) {
 180                         config.clean_policies |=
 181                                 ONAK_CLEAN_CHECK_SIGHASH;
 182                 } else {
 183                         config.clean_policies &=
 184                                 ~ONAK_CLEAN_CHECK_SIGHASH;
 185                 }
 186         } else {
 187                 return false;
 188         }
 189
 190         return true;
 191 }
 192
 193 /*
 194  * Parse a new style .ini config line, supporting [sections] and name=value
 195  * format.
 196  */
 197 static bool parseconfigline(char *line)
 198 {
 199         /* Yes, this means we're not re-entrant. */
 200         static char section[32] = "";
 201         struct onak_db_config *backend;
 202         size_t len;
 203         char *name, *value;
 204
 205         if (line[0] == '#' || line[0] == ';' ||
 206                         line[0] == 0) {
 207                 /*
 208                  * Comment line, ignore.
 209                  */
 210         } else if (line[0] == '[') {
 211                 /* Section name */
 212                 len = strlen(line);
 213                 if (line[len - 1] != ']') {
 214                         logthing(LOGTHING_CRITICAL,
 215                                 "Malformed section header '%s' in "
 216                                 "config file.", line);
 217                         return false;
 218                 }
 219                 if (len > sizeof(section)) {
 220                         logthing(LOGTHING_CRITICAL,
 221                                 "Section header '%s' is too long in "
 222                                 "config file.", line);
 223                         return false;
 224                 }
 225                 line[len - 1] = 0;
 226                 strncpy(section, &line[1], len);
 227         } else if ((value = strchr(line, '=')) != NULL) {
 228                 name = line;
 229                 *value++ = 0;
 230
 231                 /* We can have multiple backend: sections */
 232                 if (!strncmp(section, "backend:", 8)) {
 233                         backend = find_db_backend_config(
 234                                 config.backends, &section[8]);
 235                         if (backend == NULL) {
 236                                 backend = calloc(1,
 237                                         sizeof(struct onak_db_config));
 238                                 backend->name = strdup(&section[8]);
 239                                 config.backends = lladd(config.backends,
 240                                                         backend);
 241                         }
 242
 243                         if (!strcmp(name, "type")) {
 244                                 backend->type = strdup(value);
 245                         } else if (!strcmp(name, "location")) {
 246                                 backend->location = strdup(value);
 247                         } else if (!strcmp(name, "hostname")) {
 248                                 backend->location = strdup(value);
 249                         } else if (!strcmp(name, "username")) {
 250                                 backend->location = strdup(value);
 251                         } else if (!strcmp(name, "password")) {
 252                                 backend->location = strdup(value);
 253                         }
 254
 255 #define MATCH(s, n) !strcmp(section, s) && !strcmp(name, n)
 256                 /* [main] section */
 257                 } else if (MATCH("main", "backend")) {
 258                         config.db_backend = strdup(value);
 259                 } else if (MATCH("main", "backends_dir")) {
 260                         config.backends_dir = strdup(value);
 261                 } else if (MATCH("main", "logfile")) {
 262                         config.logfile = strdup(value);
 263                 } else if (MATCH("main", "loglevel")) {
 264                         setlogthreshold(atoi(value));
 265                 } else if (MATCH("main", "use_keyd")) {
 266                         config.use_keyd = parsebool(value,
 267                                         config.use_keyd);
 268                 } else if (MATCH("main", "sock_dir")) {
 269                         config.sock_dir = strdup(value);
 270                 } else if (MATCH("main", "max_reply_keys")) {
 271                         config.maxkeys = atoi(value);
 272                 /* [mail] section */
 273                 } else if (MATCH("mail", "maintainer_email")) {
 274                         config.adminemail = strdup(value);
 275                 } else if (MATCH("mail", "mail_dir")) {
 276                 config.mail_dir = strdup(value);
 277                 } else if (MATCH("mail", "mta")) {
 278                         config.mta = strdup(value);
 279                 } else if (MATCH("mail", "bin_dir")) {
 280                         config.bin_dir = strdup(value);
 281                 } else if (MATCH("mail", "this_site")) {
 282                         config.thissite = strdup(value);
 283                 } else if (MATCH("mail", "syncsite")) {
 284                         config.syncsites = lladd(config.syncsites,
 285                                 strdup(value));
 286                 /* [verification] section */
 287                 } else if (MATCH("verification", "blacklist")) {
 288                         array_load(&config.blacklist, value);
 289                 } else if (MATCH("verification", "drop_v3")) {
 290                         if (parsebool(value, config.clean_policies &
 291                                         ONAK_CLEAN_DROP_V3_KEYS)) {
 292                                 config.clean_policies |=
 293                                         ONAK_CLEAN_DROP_V3_KEYS;
 294                         } else {
 295                                 config.clean_policies &=
 296                                         ~ONAK_CLEAN_DROP_V3_KEYS;
 297                         }
 298                 } else if (MATCH("verification", "check_sighash")) {
 299                         if (parsebool(value, config.clean_policies &
 300                                         ONAK_CLEAN_CHECK_SIGHASH)) {
 301                                 config.clean_policies |=
 302                                         ONAK_CLEAN_CHECK_SIGHASH;
 303                         } else {
 304                                 config.clean_policies &=
 305                                         ~ONAK_CLEAN_CHECK_SIGHASH;
 306                         }
 307                 } else if (MATCH("verification", "check_packet_size")) {
 308                         if (parsebool(value, config.clean_policies &
 309                                         ONAK_CLEAN_LARGE_PACKETS)) {
 310                                 config.clean_policies |=
 311                                         ONAK_CLEAN_LARGE_PACKETS;
 312                         } else {
 313                                 config.clean_policies &=
 314                                         ~ONAK_CLEAN_LARGE_PACKETS;
 315                         }
 316                 } else if (MATCH("verification", "update_only")) {
 317                         if (parsebool(value, config.clean_policies &
 318                                         ONAK_CLEAN_UPDATE_ONLY)) {
 319                                 config.clean_policies |=
 320                                         ONAK_CLEAN_UPDATE_ONLY;
 321                         } else {
 322                                 config.clean_policies &=
 323                                         ~ONAK_CLEAN_UPDATE_ONLY;
 324                         }
 325                 } else {
 326                         return false;
 327                 }
 328         } else {
 329                 return false;
 330         }
 331
 332         return true;
 333 }
 334
 335 void readconfig(const char *configfile) {
 336         FILE *conffile;
 337         char  curline[1024];
 338         int   i;
 339         char *dir, *conf;
 340         size_t len;
 341         struct onak_db_config *backend;
 342         bool oldstyle = false;
 343         bool res;
 344
 345         curline[1023] = 0;
 346
 347         /*
 348          * Try to find a config file to use. If one is explicitly provided,
 349          * use that. Otherwise look in $XDG_CONFIG_HOME, $HOME and finally
 350          * the build in configuration directory. We try an old style onak.conf
 351          * first and then the new style onak.ini if that wasn't found - this
 352          * is to prevent breaking existing installs on upgrade.
 353          */
 354         if (configfile == NULL) {
 355                 conffile = NULL;
 356                 if ((dir = getenv("XDG_CONFIG_HOME")) != NULL) {
 357                         /* dir + / + onak.conf + NUL */
 358                         len = strlen(dir) + 1 + 9 + 1;
 359                         conf = malloc(len);
 360                         snprintf(conf, len, "%s/onak.conf", dir);
 361                         conffile = fopen(conf, "r");
 362                         if (conffile == NULL) {
 363                                 /* Conveniently .ini is shorter than .conf */
 364                                 snprintf(conf, len, "%s/onak.ini", dir);
 365                                 conffile = fopen(conf, "r");
 366                         } else {
 367                                 oldstyle = true;
 368                         }
 369                         free(conf);
 370                 } else if ((dir = getenv("HOME")) != NULL) {
 371                         /* dir + /.config/onak.conf + NUL */
 372                         len = strlen(dir) + 18 + 1;
 373                         conf = malloc(len);
 374                         snprintf(conf, len, "%s/.config/onak.conf", dir);
 375                         conffile = fopen(conf, "r");
 376                         if (conffile == NULL) {
 377                                 /* Conveniently .ini is shorter than .conf */
 378                                 snprintf(conf, len, "%s/onak.ini", dir);
 379                                 conffile = fopen(conf, "r");
 380                         } else {
 381                                 oldstyle = true;
 382                         }
 383                         free(conf);
 384                 }
 385                 if (conffile == NULL) {
 386                         conffile = fopen(CONFIGDIR "/onak.conf", "r");
 387                         if (conffile == NULL) {
 388                                 conffile = fopen(CONFIGDIR "/onak.ini", "r");
 389                         } else {
 390                                 oldstyle = true;
 391                         }
 392                 }
 393         } else {
 394                 /*
 395                  * Explicitly provided config file; if the filename ends .conf
 396                  * assume it's old style.
 397                  */
 398                 len = strlen(configfile);
 399                 if (!strcmp(&configfile[len - 5], ".conf")) {
 400                         oldstyle = true;
 401                 }
 402                 conffile = fopen(configfile, "r");
 403         }
 404
 405         if (oldstyle) {
 406                 logthing(LOGTHING_CRITICAL, "Reading deprecated old-style "
 407                                 "configuration file. This will not be "
 408                                 "supported in the next release.");
 409         }
 410
 411         if (conffile != NULL) {
 412                 if (!fgets(curline, 1023, conffile)) {
 413                         logthing(LOGTHING_CRITICAL,
 414                                 "Problem reading configuration file.");
 415                         fclose(conffile);
 416                         return;
 417                 }
 418
 419                 if (oldstyle) {
 420                         /* Add a single DB configuration */
 421                         backend = calloc(1, sizeof(*backend));
 422                         config.backend = backend;
 423                         config.backends = lladd(NULL, backend);
 424                 }
 425
 426                 while (!feof(conffile)) {
 427                         /* Strip any trailing white space */
 428                         for (i = strlen(curline) - 1;
 429                                         i >= 0 && isspace(curline[i]);
 430                                         i--) {
 431                                 curline[i] = 0;
 432                         }
 433
 434                         /* Strip any leading white space */
 435                         i = 0;
 436                         while (curline[i] != 0 && isspace(curline[i])) {
 437                                 i++;
 438                         }
 439
 440                         if (oldstyle) {
 441                                 res = parseoldconfigline(&curline[i]);
 442                         } else {
 443                                 res = parseconfigline(&curline[i]);
 444                         }
 445                         if (!res) {
 446                                 logthing(LOGTHING_ERROR,
 447                                         "Unknown config line: %s", curline);
 448                         }
 449
 450                         if (!fgets(curline, 1023, conffile) &&
 451                                         !feof(conffile)) {
 452                                 logthing(LOGTHING_CRITICAL,
 453                                         "Problem reading configuration file.");
 454                                 break;
 455                         }
 456                 }
 457                 fclose(conffile);
 458
 459                 if (config.db_backend == NULL) {
 460                         logthing(LOGTHING_CRITICAL,
 461                                 "No database backend configured.");
 462                 } else if (!oldstyle) {
 463                         config.backend = find_db_backend_config(
 464                                 config.backends, config.db_backend);
 465                         if (config.backend == NULL) {
 466                                 logthing(LOGTHING_NOTICE,
 467                                         "Couldn't find configuration for %s "
 468                                         "backend.", config.db_backend);
 469                         }
 470                 }
 471         } else {
 472                 logthing(LOGTHING_NOTICE,
 473                                 "Couldn't open config file; using defaults.");
 474         }
 475 }
 476
 477 void writeconfig(const char *configfile)
 478 {
 479         FILE *conffile;
 480         struct ll *cur;
 481
 482         if (configfile) {
 483                 conffile = fopen(configfile, "w");
 484         } else {
 485                 conffile = stdout;
 486         }
 487
 488 #define WRITE_IF_NOT_NULL(c, s) if (c != NULL) { \
 489         fprintf(conffile, s "=%s\n", c); \
 490 }
 491 #define WRITE_BOOL(c, s) fprintf(conffile, s "=%s\n", s ? "true" : "false");
 492
 493         fprintf(conffile, "[main]\n");
 494         WRITE_IF_NOT_NULL(config.backend->name, "backend");
 495         WRITE_IF_NOT_NULL(config.backends_dir, "backends_dir");
 496         WRITE_IF_NOT_NULL(config.logfile, "logfile");
 497         fprintf(conffile, "loglevel=%d\n", getlogthreshold());
 498         WRITE_BOOL(config.use_keyd, "use_keyd");
 499         WRITE_IF_NOT_NULL(config.sock_dir, "sock_dir");
 500         fprintf(conffile, "max_reply_keys=%d\n", config.maxkeys);
 501         fprintf(conffile, "\n");
 502
 503         fprintf(conffile, "[verification]\n");
 504         WRITE_BOOL(config.clean_policies & ONAK_CLEAN_CHECK_SIGHASH,
 505                         "check_sighash");
 506         fprintf(conffile, "\n");
 507
 508         fprintf(conffile, "[mail]\n");
 509         WRITE_IF_NOT_NULL(config.adminemail, "maintainer_email");
 510         WRITE_IF_NOT_NULL(config.mail_dir, "mail_dir");
 511         WRITE_IF_NOT_NULL(config.mta, "mta");
 512         WRITE_IF_NOT_NULL(config.bin_dir, "bin_dir");
 513         WRITE_IF_NOT_NULL(config.thissite, "this_site");
 514
 515         cur = config.syncsites;
 516         while (cur != NULL) {
 517                 fprintf(conffile, "syncsite=%s\n", (char *) cur->object);
 518                 cur = cur->next;
 519         }
 520
 521         cur = config.backends;
 522         while (cur != NULL) {
 523                 struct onak_db_config *backend =
 524                         (struct onak_db_config *) cur->object;
 525                 fprintf(conffile, "\n[backend:%s]\n", backend->name);
 526                 WRITE_IF_NOT_NULL(backend->type, "type");
 527                 WRITE_IF_NOT_NULL(backend->location, "location");
 528                 WRITE_IF_NOT_NULL(backend->hostname, "hostname");
 529                 WRITE_IF_NOT_NULL(backend->username, "username");
 530                 WRITE_IF_NOT_NULL(backend->password, "password");
 531                 cur = cur->next;
 532         }
 533
 534         if (configfile) {
 535                 fclose(conffile);
 536         }
 537 }
 538
 539 void cleanupdbconfig(void *object)
 540 {
 541         struct onak_db_config *dbconfig = (struct onak_db_config *) object;
 542
 543         if (dbconfig->name != NULL) {
 544                 free(dbconfig->name);
 545                 dbconfig->name = NULL;
 546         }
 547         if (dbconfig->type != NULL) {
 548                 free(dbconfig->type);
 549                 dbconfig->type = NULL;
 550         }
 551         if (dbconfig->location != NULL) {
 552                 free(dbconfig->location);
 553                 dbconfig->location = NULL;
 554         }
 555         if (dbconfig->hostname != NULL) {
 556                 free(dbconfig->hostname);
 557                 dbconfig->hostname = NULL;
 558         }
 559         if (dbconfig->username != NULL) {
 560                 free(dbconfig->username);
 561                 dbconfig->username = NULL;
 562         }
 563         if (dbconfig->password != NULL) {
 564                 free(dbconfig->password);
 565                 dbconfig->password = NULL;
 566         }
 567
 568         free(dbconfig);
 569 }
 570
 571 void cleanupconfig(void) {
 572         /* Free any defined DB backend configuration first */
 573         llfree(config.backends, cleanupdbconfig);
 574         config.backends = NULL;
 575
 576         if (config.thissite != NULL) {
 577                 free(config.thissite);
 578                 config.thissite = NULL;
 579         }
 580         if (config.adminemail != NULL) {
 581                 free(config.adminemail);
 582                 config.adminemail = NULL;
 583         }
 584         if (config.mta != NULL) {
 585                 free(config.mta);
 586                 config.mta = NULL;
 587         }
 588         if (config.syncsites != NULL) {
 589                 llfree(config.syncsites, free);
 590                 config.syncsites = NULL;
 591         }
 592         if (config.logfile != NULL) {
 593                 free(config.logfile);
 594                 config.logfile = NULL;
 595         }
 596         if (config.db_backend != NULL) {
 597                 free(config.db_backend);
 598                 config.db_backend = NULL;
 599         }
 600         if (config.backends_dir != NULL) {
 601                 free(config.backends_dir);
 602                 config.backends_dir = NULL;
 603         }
 604         if (config.sock_dir != NULL) {
 605                 free(config.sock_dir);
 606                 config.sock_dir = NULL;
 607         }
 608         if (config.bin_dir != NULL) {
 609                 free(config.bin_dir);
 610                 config.bin_dir = NULL;
 611         }
 612         if (config.mail_dir != NULL) {
 613                 free(config.mail_dir);
 614                 config.mail_dir = NULL;
 615         }
 616         if (config.blacklist.count != 0) {
 617                 array_free(&config.blacklist);
 618         }
 619 }