Line data Source code
1 : #include "burp.h"
2 : #include "alloc.h"
3 : #include "conf.h"
4 : #include "fsops.h"
5 : #include "handy.h"
6 : #include "lock.h"
7 : #include "log.h"
8 : #include "msg.h"
9 : #include "pathcmp.h"
10 : #include "prepend.h"
11 : #include "strlist.h"
12 : #include "server/timestamp.h"
13 : #include "client/glob_windows.h"
14 : #include "conffile.h"
15 :
16 : // This will strip off everything after the last quote. So, configs like this
17 : // should work:
18 : // exclude_regex = "[A-Z]:/pagefile.sys" # swap file (Windows XP, 7, 8)
19 : // Return 1 for quotes removed, -1 for error, 0 for OK.
20 2028 : static int remove_quotes(const char *f, char **v, char quote)
21 : {
22 2028 : char *dp=NULL;
23 2028 : char *sp=NULL;
24 2028 : char *copy=NULL;
25 :
26 : // If it does not start with a quote, leave it alone.
27 2028 : if(**v!=quote) return 0;
28 :
29 4 : if(!(copy=strdup_w(*v, __func__)))
30 : return -1;
31 :
32 8 : for(dp=*v, sp=copy+1; *sp; sp++)
33 : {
34 6 : if(*sp==quote)
35 : {
36 : // Found a matching quote. Stop here.
37 2 : *dp='\0';
38 2 : for(sp++; *sp && isspace(*sp); sp++) { }
39 : // Do not complain about trailing comments.
40 2 : if(*sp && *sp!='#')
41 0 : logp("ignoring trailing characters after quote in config '%s = %s'\n", f, copy);
42 : return 1;
43 : }
44 4 : else if(*sp=='\\')
45 : {
46 0 : sp++;
47 0 : *dp=*sp;
48 0 : dp++;
49 0 : if(*sp!=quote
50 0 : && *sp!='\\')
51 0 : logp("unknown escape sequence '\\%c' in config '%s = %s' - treating it as '%c'\n", *sp, f, copy, *sp);
52 : }
53 : else
54 : {
55 4 : *dp=*sp;
56 4 : dp++;
57 : }
58 : }
59 2 : logp("Did not find closing quote in config '%s = %s'\n", f, copy);
60 2 : *dp='\0';
61 2 : return 1;
62 : }
63 :
64 : // Get field and value pair.
65 1030 : int conf_get_pair(char buf[], char **f, char **v)
66 : {
67 1030 : char *cp=NULL;
68 1030 : char *eq=NULL;
69 :
70 : // strip leading space
71 1030 : for(cp=buf; *cp && isspace(*cp); cp++) { }
72 1030 : if(!*cp || *cp=='#')
73 : {
74 14 : *f=NULL;
75 14 : *v=NULL;
76 14 : return 0;
77 : }
78 1016 : *f=cp;
79 1016 : if(!(eq=strchr(*f, '='))) return -1;
80 1015 : *eq='\0';
81 :
82 : // Strip white space from before the equals sign.
83 1015 : for(cp=eq-1; *cp && isspace(*cp); cp--) *cp='\0';
84 : // Skip white space after the equals sign.
85 1015 : for(cp=eq+1; *cp && isspace(*cp); cp++) { }
86 1015 : *v=cp;
87 : // Strip white space at the end of the line.
88 1015 : for(cp+=strlen(cp)-1; *cp && isspace(*cp); cp--) { *cp='\0'; }
89 :
90 : // FIX THIS: Make this more sophisticated - it should understand
91 : // escapes, for example.
92 :
93 1015 : switch(remove_quotes(*f, v, '\''))
94 : {
95 : case -1: return -1;
96 : case 1: break;
97 : default:
98 : // If single quotes were not removed, try to remove
99 : // double quotes.
100 1013 : if(remove_quotes(*f, v, '\"')<0) return -1;
101 : break;
102 : }
103 :
104 1015 : if(!*f || !**f || !*v || !**v) return -1;
105 :
106 1015 : return 0;
107 : }
108 :
109 82 : static int path_checks(const char *path, const char *err_msg)
110 : {
111 82 : const char *p=NULL;
112 2007 : for(p=path; *p; p++)
113 : {
114 1925 : if(*p!='.' || *(p+1)!='.') continue;
115 0 : if((p==path || *(p-1)=='/') && (*(p+2)=='/' || !*(p+2)))
116 : {
117 0 : logp("%s", err_msg);
118 0 : return -1;
119 : }
120 : }
121 : // This is being run on the server too, where you can enter paths for the
122 : // clients, so need to allow windows style paths for windows and unix.
123 82 : if((!isalpha(*path) || *(path+1)!=':')
124 : #ifndef HAVE_WIN32
125 : // Windows does not need to check for unix style paths.
126 82 : && *path!='/'
127 : #endif
128 : )
129 : {
130 1 : logp("%s", err_msg);
131 1 : return -1;
132 : }
133 : return 0;
134 : }
135 :
136 : static int conf_error(const char *conf_path, int line)
137 : {
138 1 : logp("%s: parse error on line %d\n", conf_path, line);
139 : return -1;
140 : }
141 :
142 2 : static int get_file_size(const char *v, uint64_t *dest, const char *conf_path, int line)
143 : {
144 : // Store in bytes, allow k/m/g.
145 2 : const char *cp=NULL;
146 2 : *dest=strtoul(v, NULL, 10);
147 2 : for(cp=v; *cp && (isspace(*cp) || isdigit(*cp)); cp++) { }
148 2 : if(tolower(*cp)=='k') *dest*=1024;
149 2 : else if(tolower(*cp)=='m') *dest*=1024*1024;
150 2 : else if(tolower(*cp)=='g') *dest*=1024*1024*1024;
151 2 : else if(!*cp || *cp=='b')
152 : { }
153 : else
154 : {
155 0 : logp("Unknown file size type '%s' - please use b/kb/mb/gb\n",
156 : cp);
157 0 : return conf_error(conf_path, line);
158 : }
159 : return 0;
160 : }
161 :
162 357 : static int pre_post_override(struct conf *c,
163 : struct conf *pre, struct conf *post)
164 : {
165 357 : const char *override=get_string(c);
166 357 : if(!override) return 0;
167 5 : if(set_string(pre, override)
168 5 : || set_string(post, override))
169 : return -1;
170 : return 0;
171 : }
172 :
173 : #ifdef HAVE_LINUX_OS
174 : struct fstype
175 : {
176 : const char *str;
177 : uint64_t flag;
178 : };
179 :
180 : static struct fstype fstypes[]={
181 : { "debugfs", 0x64626720 },
182 : { "devfs", 0x00001373 },
183 : { "devpts", 0x00001CD1 },
184 : { "devtmpfs", 0x00009FA0 },
185 : { "ecryptfs", 0x0000f15f },
186 : { "ext2", 0x0000EF53 },
187 : { "ext3", 0x0000EF53 },
188 : { "ext4", 0x0000EF53 },
189 : { "iso9660", 0x00009660 },
190 : { "jfs", 0x3153464A },
191 : { "nfs", 0x00006969 },
192 : { "ntfs", 0x5346544E },
193 : { "proc", 0x00009fa0 },
194 : { "reiserfs", 0x52654973 },
195 : { "securityfs", 0x73636673 },
196 : { "sysfs", 0x62656572 },
197 : { "smbfs", 0x0000517B },
198 : { "usbdevfs", 0x00009fa2 },
199 : { "xfs", 0x58465342 },
200 : { "ramfs", 0x858458f6 },
201 : { "romfs", 0x00007275 },
202 : { "tmpfs", 0x01021994 },
203 : { NULL, 0 },
204 : };
205 : /* Use this C code to figure out what f_type gets set to.
206 : #include <stdio.h>
207 : #include <sys/vfs.h>
208 :
209 : int main(int argc, char *argv[])
210 : {
211 : int i=0;
212 : struct statfs buf;
213 : if(argc<1)
214 : {
215 : printf("not enough args\n");
216 : return -1;
217 : }
218 : if(statfs(argv[1], &buf))
219 : {
220 : printf("error\n");
221 : return -1;
222 : }
223 : printf("0x%08X\n", buf.f_type);
224 : return 0;
225 : }
226 : */
227 :
228 : #endif
229 :
230 0 : static int fstype_to_flag(const char *fstype, long *flag)
231 : {
232 : #ifdef HAVE_LINUX_OS
233 0 : int i=0;
234 0 : for(i=0; fstypes[i].str; i++)
235 : {
236 0 : if(!strcmp(fstypes[i].str, fstype))
237 : {
238 0 : *flag=fstypes[i].flag;
239 0 : return 0;
240 : }
241 : }
242 : #else
243 : return 0;
244 : #endif
245 : return -1;
246 : }
247 :
248 5 : static int get_compression(const char *v)
249 : {
250 5 : const char *cp=v;
251 5 : if(!strncmp(v, "gzip", strlen("gzip"))
252 5 : || !(strncmp(v, "zlib", strlen("zlib"))))
253 0 : cp=v+strlen("gzip"); // Or "zlib".
254 5 : if(strlen(cp)==1 && isdigit(*cp))
255 5 : return atoi(cp);
256 : return -1;
257 : }
258 :
259 1002 : static int load_conf_field_and_value(struct conf **c,
260 : const char *f, // field
261 : const char *v, // value
262 : const char *conf_path,
263 : int line)
264 : {
265 1002 : if(!strcmp(f, "compression"))
266 : {
267 5 : int compression=get_compression(v);
268 5 : if(compression<0) return -1;
269 5 : set_int(c[OPT_COMPRESSION], compression);
270 : }
271 997 : else if(!strcmp(f, "ssl_compression"))
272 : {
273 0 : int compression=get_compression(v);
274 0 : if(compression<0) return -1;
275 0 : set_int(c[OPT_SSL_COMPRESSION], compression);
276 : }
277 997 : else if(!strcmp(f, "ratelimit"))
278 : {
279 0 : float f=0;
280 0 : f=atof(v);
281 : // User is specifying Mega bits per second.
282 : // Need to convert to bytes per second.
283 0 : f=(f*1024*1024)/8;
284 0 : if(!f)
285 : {
286 0 : logp("ratelimit should be greater than zero\n");
287 0 : return -1;
288 : }
289 0 : set_float(c[OPT_RATELIMIT], f);
290 : }
291 : else
292 : {
293 : int i=0;
294 45437 : for(i=0; i<OPT_MAX; i++)
295 : {
296 46429 : if(strcmp(c[i]->field, f)) continue;
297 992 : switch(c[i]->conf_type)
298 : {
299 : case CT_STRING:
300 700 : return set_string(c[i], v);
301 : case CT_UINT:
302 41 : return set_int(c[i], atoi(v));
303 : case CT_FLOAT:
304 0 : return set_float(c[i], atof(v));
305 : break;
306 : case CT_MODE_T:
307 0 : return set_mode_t(c[i],
308 0 : strtol(v, NULL, 8));
309 : case CT_SSIZE_T:
310 : {
311 2 : uint64_t s=0;
312 : return
313 2 : get_file_size(v, &s, conf_path, line)
314 2 : || set_uint64_t(c[i], s);
315 : }
316 : case CT_E_BURP_MODE:
317 73 : return set_e_burp_mode(c[i],
318 : str_to_burp_mode(v));
319 : case CT_E_PROTOCOL:
320 14 : return set_e_protocol(c[i],
321 : str_to_protocol(v));
322 : case CT_E_RECOVERY_METHOD:
323 1 : return set_e_recovery_method(c[i],
324 : str_to_recovery_method(v));
325 : case CT_STRLIST:
326 161 : return add_to_strlist(c[i], v,
327 161 : !strcmp(c[i]->field, "include"));
328 : case CT_E_RSHASH:
329 : break;
330 : case CT_CNTR:
331 : break;
332 : // No default so we get a warning if something
333 : // was missed;
334 : }
335 : }
336 : }
337 : return 0;
338 : }
339 :
340 : // Recursing, so need to define this ahead of conf_parse_line.
341 : static int conf_load_lines_from_file(const char *conf_path,
342 : struct conf **confs);
343 :
344 0 : static int deal_with_dot_inclusion(const char *conf_path,
345 : char **extrafile, struct conf **confs)
346 : {
347 0 : int ret=-1;
348 0 : char *copy=NULL;
349 : #ifndef HAVE_WIN32
350 0 : int i=0;
351 : glob_t globbuf;
352 0 : if(**extrafile!='/')
353 : #else
354 : if(strlen(*extrafile)>2
355 : && (*extrafile)[1]!=':')
356 : #endif
357 : {
358 : // It is relative to the directory that the
359 : // current conf file is in.
360 0 : char *cp=NULL;
361 0 : char *tmp=NULL;
362 0 : if(!(copy=strdup_w(conf_path, __func__)))
363 : goto end;
364 0 : if((cp=strrchr(copy, '/'))) *cp='\0';
365 0 : if(!(tmp=prepend_s(copy, *extrafile)))
366 : {
367 0 : log_out_of_memory(__func__);
368 0 : goto end;
369 : }
370 0 : free_w(extrafile);
371 0 : *extrafile=tmp;
372 : }
373 : #ifndef HAVE_WIN32
374 : // Treat it is a glob expression.
375 : memset(&globbuf, 0, sizeof(globbuf));
376 0 : glob(*extrafile, 0, NULL, &globbuf);
377 0 : for(i=0; (unsigned int)i<globbuf.gl_pathc; i++)
378 0 : if((ret=conf_load_lines_from_file(globbuf.gl_pathv[i], confs)))
379 : goto end;
380 : #else
381 : ret=conf_load_lines_from_file(*extrafile, confs);
382 : #endif
383 :
384 : end:
385 0 : free_w(©);
386 0 : return ret;
387 : }
388 :
389 1015 : static int conf_parse_line(struct conf **confs, const char *conf_path,
390 : char buf[], int line)
391 : {
392 1015 : int ret=-1;
393 1015 : char *f=NULL; // field
394 1015 : char *v=NULL; // value
395 1015 : char *extrafile=NULL;
396 :
397 1015 : if(!strncmp(buf, ". ", 2))
398 : {
399 : // The conf file specifies another file to include.
400 0 : char *np=NULL;
401 :
402 0 : if(!(extrafile=strdup_w(buf+2, __func__))) goto end;
403 :
404 0 : if((np=strrchr(extrafile, '\n'))) *np='\0';
405 0 : if(!*extrafile) goto end;
406 :
407 0 : ret=deal_with_dot_inclusion(conf_path, &extrafile, confs);
408 0 : goto end;
409 : }
410 :
411 1015 : if(conf_get_pair(buf, &f, &v)) goto end;
412 1014 : if(f && v
413 1002 : && load_conf_field_and_value(confs, f, v, conf_path, line))
414 : goto end;
415 : ret=0;
416 : end:
417 1015 : free_w(&extrafile);
418 1015 : return ret;
419 : }
420 :
421 : static void conf_problem(const char *conf_path, const char *msg, int *r)
422 : {
423 0 : logp("%s: %s\n", conf_path, msg);
424 0 : (*r)--;
425 : }
426 :
427 : #ifdef HAVE_IPV6
428 : // These should work for IPv4 connections too.
429 : #define DEFAULT_ADDRESS_MAIN "::"
430 : #define DEFAULT_ADDRESS_STATUS "::1"
431 : #else
432 : // Fall back to IPv4 address if IPv6 is not compiled in.
433 : #define DEFAULT_ADDRESS_MAIN "0.0.0.0"
434 : #define DEFAULT_ADDRESS_STATUS "127.0.0.1"
435 : #endif
436 :
437 28 : static int server_conf_checks(struct conf **c, const char *path, int *r)
438 : {
439 : // FIX THIS: Most of this could be done by flags.
440 28 : if(!get_string(c[OPT_ADDRESS])
441 28 : && set_string(c[OPT_ADDRESS], DEFAULT_ADDRESS_MAIN))
442 : return -1;
443 28 : if(!get_string(c[OPT_DIRECTORY]))
444 : conf_problem(path, "directory unset", r);
445 28 : if(!get_string(c[OPT_DEDUP_GROUP]))
446 : conf_problem(path, "dedup_group unset", r);
447 28 : if(!get_string(c[OPT_CLIENTCONFDIR]))
448 : conf_problem(path, "clientconfdir unset", r);
449 28 : if(get_e_recovery_method(c[OPT_WORKING_DIR_RECOVERY_METHOD])==RECOVERY_METHOD_UNSET)
450 : conf_problem(path, "working_dir_recovery_method unset", r);
451 28 : if(!get_string(c[OPT_SSL_DHFILE]))
452 : conf_problem(path, "ssl_dhfile unset", r);
453 28 : if(get_string(c[OPT_ENCRYPTION_PASSWORD]))
454 : conf_problem(path,
455 : "encryption_password should not be set on the server!", r);
456 28 : if(!get_string(c[OPT_STATUS_ADDRESS])
457 28 : && set_string(c[OPT_STATUS_ADDRESS], DEFAULT_ADDRESS_STATUS))
458 : return -1;
459 28 : if(!get_string(c[OPT_STATUS_PORT])) // carry on if not set.
460 0 : logp("%s: status_port unset", path);
461 28 : if(!get_int(c[OPT_MAX_CHILDREN]))
462 : conf_problem(path, "max_children unset", r);
463 28 : if(!get_int(c[OPT_MAX_STATUS_CHILDREN]))
464 : conf_problem(path, "max_status_children unset", r);
465 28 : if(!get_strlist(c[OPT_KEEP]))
466 : conf_problem(path, "keep unset", r);
467 28 : if(get_int(c[OPT_MAX_HARDLINKS])<2)
468 : conf_problem(path, "max_hardlinks too low", r);
469 28 : if(get_int(c[OPT_MAX_CHILDREN])<=0)
470 : conf_problem(path, "max_children too low", r);
471 28 : if(get_int(c[OPT_MAX_STATUS_CHILDREN])<=0)
472 : conf_problem(path, "max_status_children too low", r);
473 28 : if(get_int(c[OPT_MAX_STORAGE_SUBDIRS])<=1000)
474 : conf_problem(path, "max_storage_subdirs too low", r);
475 28 : if(!get_string(c[OPT_TIMESTAMP_FORMAT])
476 28 : && set_string(c[OPT_TIMESTAMP_FORMAT], DEFAULT_TIMESTAMP_FORMAT))
477 : return -1;
478 28 : if(get_string(c[OPT_CA_CONF]))
479 : {
480 1 : int ca_err=0;
481 1 : if(!get_string(c[OPT_CA_NAME]))
482 : {
483 0 : logp("ca_conf set, but ca_name not set\n");
484 0 : ca_err++;
485 : }
486 1 : if(!get_string(c[OPT_CA_SERVER_NAME]))
487 : {
488 0 : logp("ca_conf set, but ca_server_name not set\n");
489 0 : ca_err++;
490 : }
491 1 : if(!get_string(c[OPT_CA_BURP_CA]))
492 : {
493 0 : logp("ca_conf set, but ca_burp_ca not set\n");
494 0 : ca_err++;
495 : }
496 1 : if(!get_string(c[OPT_SSL_DHFILE]))
497 : {
498 0 : logp("ca_conf set, but ssl_dhfile not set\n");
499 0 : ca_err++;
500 : }
501 1 : if(!get_string(c[OPT_SSL_CERT_CA]))
502 : {
503 0 : logp("ca_conf set, but ssl_cert_ca not set\n");
504 0 : ca_err++;
505 : }
506 1 : if(!get_string(c[OPT_SSL_CERT]))
507 : {
508 0 : logp("ca_conf set, but ssl_cert not set\n");
509 0 : ca_err++;
510 : }
511 1 : if(!get_string(c[OPT_SSL_KEY]))
512 : {
513 0 : logp("ca_conf set, but ssl_key not set\n");
514 0 : ca_err++;
515 : }
516 1 : if(ca_err) return -1;
517 : }
518 28 : if(get_string(c[OPT_MANUAL_DELETE]))
519 : {
520 0 : if(path_checks(get_string(c[OPT_MANUAL_DELETE]),
521 : "ERROR: Please use an absolute manual_delete path.\n"))
522 : return -1;
523 : }
524 :
525 : return 0;
526 : }
527 :
528 : #ifdef HAVE_WIN32
529 : #undef X509_NAME
530 : #include <openssl/x509.h>
531 : #endif
532 :
533 0 : static char *extract_cn(X509_NAME *subj)
534 : {
535 : int nid;
536 : int index;
537 : ASN1_STRING *d;
538 : X509_NAME_ENTRY *e;
539 :
540 0 : nid=OBJ_txt2nid("CN");
541 0 : if((index=X509_NAME_get_index_by_NID(subj, nid, -1))<0
542 0 : || !(e=X509_NAME_get_entry(subj, index))
543 0 : || !(d=X509_NAME_ENTRY_get_data(e)))
544 : return NULL;
545 : #if OPENSSL_VERSION_NUMBER < 0x1010000fL || defined(LIBRESSL_VERSION_NUMBER)
546 0 : return (char *)ASN1_STRING_data(d);
547 : #else
548 : return (char *)ASN1_STRING_get0_data(d);
549 : #endif
550 : }
551 :
552 43 : static void mangle_cname(char **cname, struct conf **c)
553 : {
554 43 : if(!get_int(c[OPT_CNAME_FQDN]))
555 0 : strip_fqdn(cname);
556 43 : if(get_int(c[OPT_CNAME_LOWERCASE]))
557 0 : strlwr(*cname);
558 43 : }
559 :
560 43 : static int get_cname_from_ssl_cert(struct conf **c)
561 : {
562 43 : int ret=-1;
563 43 : struct fzp *fzp=NULL;
564 43 : X509 *cert=NULL;
565 43 : X509_NAME *subj=NULL;
566 43 : char *path=get_string(c[OPT_SSL_CERT]);
567 43 : const char *cn=NULL;
568 43 : char *copy=NULL;
569 :
570 43 : if(!path || !(fzp=fzp_open(path, "rb"))) return 0;
571 :
572 0 : if(!(cert=fzp_PEM_read_X509(fzp)))
573 : {
574 0 : logp("unable to parse %s in: %s\n", path, __func__);
575 0 : goto end;
576 : }
577 0 : if(!(subj=X509_get_subject_name(cert)))
578 : {
579 0 : logp("unable to get subject from %s in: %s\n", path, __func__);
580 0 : goto end;
581 : }
582 :
583 0 : if(!(cn=extract_cn(subj)))
584 : {
585 0 : logp("could not get CN from %s\n", path);
586 0 : goto end;
587 : }
588 0 : if(!(copy=strdup_w(cn, __func__)))
589 : goto end;
590 0 : mangle_cname(©, c);
591 0 : if(set_string(c[OPT_CNAME], copy))
592 : goto end;
593 0 : logp("cname from cert: %s\n", cn);
594 0 : if(strcmp(copy, cn))
595 0 : logp("cname mangled to: %s\n", copy);
596 :
597 : ret=0;
598 : end:
599 0 : if(cert) X509_free(cert);
600 0 : fzp_close(&fzp);
601 0 : free_w(©);
602 0 : return ret;
603 : }
604 :
605 : #ifdef HAVE_WIN32
606 : #include <winsock2.h>
607 : #include <ws2tcpip.h>
608 : #endif
609 :
610 43 : static int get_fqdn(struct conf **c)
611 : {
612 43 : int ret=-1;
613 : int gai_result;
614 : struct addrinfo hints;
615 43 : struct addrinfo *info=NULL;
616 43 : char hostname[1024]="";
617 43 : char *fqdn=NULL;
618 43 : hostname[1023] = '\0';
619 43 : if(gethostname(hostname, 1023))
620 : {
621 0 : logp("gethostname() failed: %s\n", strerror(errno));
622 0 : goto end;
623 : }
624 :
625 : memset(&hints, 0, sizeof hints);
626 : hints.ai_family=AF_UNSPEC;
627 43 : hints.ai_socktype=SOCK_STREAM;
628 43 : hints.ai_flags=AI_CANONNAME;
629 :
630 43 : if((gai_result=getaddrinfo(hostname, NULL, &hints, &info)))
631 : {
632 0 : logp("getaddrinfo in %s: %s\n", __func__,
633 : gai_strerror(gai_result));
634 0 : goto end;
635 : }
636 :
637 : //for(p=info; p; p=p->ai_next)
638 : // Just use the first one.
639 43 : if(!info)
640 : {
641 0 : logp("Got no hostname in %s\n", __func__);
642 0 : goto end;
643 : }
644 :
645 43 : if(!(fqdn=strdup_w(info->ai_canonname, __func__)))
646 : goto end;
647 43 : mangle_cname(&fqdn, c);
648 :
649 43 : if(set_string(c[OPT_CNAME], fqdn))
650 : goto end;
651 43 : logp("cname from hostname: %s\n", get_string(c[OPT_CNAME]));
652 :
653 43 : ret=0;
654 : end:
655 43 : if(info) freeaddrinfo(info);
656 43 : free_w(&fqdn);
657 43 : return ret;
658 : }
659 :
660 71 : const char *confs_get_lockfile(struct conf **confs)
661 : {
662 71 : const char *lockfile=get_string(confs[OPT_LOCKFILE]);
663 71 : if(!lockfile) lockfile=get_string(confs[OPT_PIDFILE]);
664 71 : return lockfile;
665 : }
666 :
667 71 : static int general_conf_checks(struct conf **c, const char *path, int *r)
668 : {
669 71 : if(!confs_get_lockfile(c))
670 : conf_problem(path, "lockfile unset", r);
671 71 : if(!get_string(c[OPT_SSL_CERT]))
672 : conf_problem(path, "ssl_cert unset", r);
673 71 : if(!get_string(c[OPT_SSL_CERT_CA]))
674 : conf_problem(path, "ssl_cert_ca unset", r);
675 71 : return 0;
676 : }
677 :
678 43 : static int client_conf_checks(struct conf **c, const char *path, int *r)
679 : {
680 43 : const char *autoupgrade_os=get_string(c[OPT_AUTOUPGRADE_OS]);
681 43 : if(!get_string(c[OPT_CNAME]))
682 : {
683 43 : if(get_cname_from_ssl_cert(c)) return -1;
684 : // There was no error. This is probably a new install.
685 : // Try getting the fqdn and using that.
686 43 : if(!get_string(c[OPT_CNAME]))
687 : {
688 43 : if(get_fqdn(c)) return -1;
689 43 : if(!get_string(c[OPT_CNAME]))
690 : conf_problem(path, "client name unset", r);
691 : }
692 : }
693 43 : if(!get_string(c[OPT_PASSWORD]))
694 : {
695 43 : logp("password not set, falling back to \"password\"\n");
696 43 : if(set_string(c[OPT_PASSWORD], "password"))
697 : return -1;
698 : }
699 43 : if(!get_string(c[OPT_SERVER]))
700 : conf_problem(path, "server unset", r);
701 43 : if(!get_string(c[OPT_STATUS_PORT])) // carry on if not set.
702 0 : logp("%s: status_port unset\n", path);
703 43 : if(!get_string(c[OPT_SSL_PEER_CN]))
704 : {
705 0 : const char *server=get_string(c[OPT_SERVER]);
706 0 : logp("ssl_peer_cn unset\n");
707 0 : if(!server)
708 : {
709 0 : logp("falling back to '%s'\n", server);
710 0 : if(set_string(c[OPT_SSL_PEER_CN], server))
711 : return -1;
712 : }
713 : }
714 43 : if(autoupgrade_os
715 0 : && strstr(autoupgrade_os, ".."))
716 : conf_problem(path,
717 : "autoupgrade_os must not contain a '..' component", r);
718 43 : if(!get_string(c[OPT_CA_BURP_CA]))
719 : {
720 43 : if(!get_string(c[OPT_CA_CSR_DIR]))
721 : conf_problem(path,
722 : "ca_burp_ca set, but ca_csr_dir not set\n", r);
723 43 : if(!get_string(c[OPT_SSL_CERT_CA]))
724 : conf_problem(path,
725 : "ca_burp_ca set, but ssl_cert_ca not set\n", r);
726 43 : if(!get_string(c[OPT_SSL_CERT]))
727 : conf_problem(path,
728 : "ca_burp_ca set, but ssl_cert not set\n", r);
729 43 : if(!get_string(c[OPT_SSL_KEY]))
730 : conf_problem(path,
731 : "ca_burp_ca set, but ssl_key not set\n", r);
732 : }
733 :
734 43 : if(!r)
735 : {
736 : struct strlist *l;
737 0 : logp("Listing configured paths:\n");
738 0 : for(l=get_strlist(c[OPT_INCEXCDIR]); l; l=l->next)
739 0 : logp("%s: %s\n", l->flag?"include":"exclude", l->path);
740 0 : logp("Listing starting paths:\n");
741 0 : for(l=get_strlist(c[OPT_STARTDIR]); l; l=l->next)
742 0 : if(l->flag) logp("%s\n", l->path);
743 : }
744 : return 0;
745 : }
746 :
747 119 : static int finalise_keep_args(struct conf **c)
748 : {
749 : struct strlist *k;
750 119 : struct strlist *last=NULL;
751 119 : uint64_t mult=1;
752 183 : for(k=get_strlist(c[OPT_KEEP]); k; k=k->next)
753 : {
754 128 : if(!(k->flag=atoi(k->path)))
755 : {
756 0 : logp("'keep' value cannot be set to '%s'\n", k->path);
757 0 : return -1;
758 : }
759 64 : mult*=k->flag;
760 :
761 : // An error if you try to keep backups every second
762 : // for 100 years.
763 64 : if(mult>52560000)
764 : {
765 0 : logp("Your 'keep' values are far too high. High enough to keep a backup every second for 10 years. Please lower them to something sensible.\n");
766 0 : return -1;
767 : }
768 64 : last=k;
769 : }
770 : // If more than one keep value is set, add one to the last one.
771 : // This is so that, for example, having set 7, 4, 6, then
772 : // a backup of age 7*4*6=168 or more is guaranteed to be kept.
773 : // Otherwise, only 7*4*5=140 would be guaranteed to be kept.
774 119 : k=get_strlist(c[OPT_KEEP]);
775 119 : if(k && k->next) last->flag++;
776 : return 0;
777 : }
778 :
779 44 : static int incexc_munge(struct conf **c, struct strlist *s)
780 : {
781 : #ifdef HAVE_WIN32
782 : convert_backslashes(&s->path);
783 : #endif
784 44 : if(path_checks(s->path,
785 : "ERROR: Please use absolute include/exclude paths.\n"))
786 : return -1;
787 43 : if(add_to_strlist(c[OPT_INCEXCDIR], s->path, s->flag))
788 : return -1;
789 : return 0;
790 : }
791 :
792 123 : static int finalise_incexc_dirs(struct conf **c)
793 : {
794 123 : struct strlist *s=NULL;
795 :
796 161 : for(s=get_strlist(c[OPT_INCLUDE]); s; s=s->next)
797 39 : if(incexc_munge(c, s)) return -1;
798 127 : for(s=get_strlist(c[OPT_EXCLUDE]); s; s=s->next)
799 5 : if(incexc_munge(c, s)) return -1;
800 : return 0;
801 : }
802 :
803 6 : static int add_to_cross_filesystem(struct conf **c, const char *path)
804 : {
805 6 : if(strlist_find(get_strlist(c[OPT_FSCHGDIR]), path, 0))
806 : return 0;
807 6 : return add_to_strlist(c[OPT_FSCHGDIR], path, 0);
808 : }
809 :
810 : // This decides which directories to start backing up, and which
811 : // are subdirectories which don't need to be started separately.
812 122 : static int finalise_start_dirs(struct conf **c)
813 : {
814 122 : struct strlist *s=NULL;
815 122 : struct strlist *last_ie=NULL;
816 122 : struct strlist *last_sd=NULL;
817 :
818 : // Make sure that the startdir list starts empty, or chaos will ensue.
819 122 : conf_free_content(c[OPT_STARTDIR]);
820 :
821 159 : for(s=get_strlist(c[OPT_INCLUDE]); s; s=s->next)
822 : {
823 : #ifdef HAVE_WIN32
824 : convert_backslashes(&s->path);
825 : #endif
826 38 : if(path_checks(s->path,
827 : "ERROR: Please use absolute include/exclude paths.\n"))
828 : return -1;
829 :
830 : // Ensure that we do not backup the same directory twice.
831 38 : if(last_ie && !strcmp(s->path, last_ie->path))
832 : {
833 1 : logp("Directory appears twice in conf: %s\n",
834 : s->path);
835 1 : return -1;
836 : }
837 : // If it is not a subdirectory of the most recent start point,
838 : // we have found another start point.
839 37 : if(!get_strlist(c[OPT_STARTDIR])
840 14 : || !last_sd || !is_subdir(last_sd->path, s->path))
841 : {
842 : // Do not use strlist_add_sorted, because last_sd is
843 : // relying on incexcdir already being sorted.
844 31 : if(add_to_strlist(c[OPT_STARTDIR], s->path, s->flag))
845 : return -1;
846 : last_sd=s;
847 : }
848 : else
849 : {
850 : // If it is not a starting directory, it should at
851 : // least be included as a cross_filesystem entry.
852 6 : if(add_to_cross_filesystem(c, s->path))
853 : return -1;
854 : }
855 37 : last_ie=s;
856 : }
857 : return 0;
858 : }
859 :
860 : // The glob stuff should only run on the client side.
861 47 : static int finalise_glob(struct conf **c)
862 : {
863 47 : int ret=-1;
864 : #ifdef HAVE_WIN32
865 : if(glob_windows(c)) goto end;
866 : #else
867 : int i;
868 : glob_t globbuf;
869 : struct strlist *l;
870 47 : struct strlist *last=NULL;
871 : memset(&globbuf, 0, sizeof(globbuf));
872 50 : for(l=get_strlist(c[OPT_INCGLOB]); l; l=l->next)
873 : {
874 3 : glob(l->path, last?GLOB_APPEND:0, NULL, &globbuf);
875 3 : last=l;
876 : }
877 :
878 3 : for(i=0; (unsigned int)i<globbuf.gl_pathc; i++)
879 3 : if(add_to_strlist_include_uniq(c[OPT_INCLUDE], globbuf.gl_pathv[i]))
880 : goto end;
881 :
882 47 : globfree(&globbuf);
883 : #endif
884 47 : ret=0;
885 : end:
886 47 : return ret;
887 : }
888 :
889 : // Reeval the glob after script pre
890 2 : int reeval_glob(struct conf **c)
891 : {
892 2 : if(finalise_glob(c))
893 : return -1;
894 :
895 2 : if(finalise_incexc_dirs(c)
896 2 : || finalise_start_dirs(c)) return -1;
897 :
898 : return 0;
899 : }
900 :
901 : // Set the flag of the first item in a list that looks at extensions to the
902 : // maximum number of characters that need to be checked, plus one. This is for
903 : // a bit of added efficiency.
904 363 : static void set_max_ext(struct strlist *list)
905 : {
906 363 : int max=0;
907 363 : struct strlist *l=NULL;
908 367 : for(l=list; l; l=l->next)
909 : {
910 4 : int s=strlen(l->path);
911 4 : if(s>max) max=s;
912 : }
913 363 : if(list) list->flag=max+1;
914 363 : }
915 :
916 121 : static int finalise_fstypes(struct conf **c)
917 : {
918 : struct strlist *l;
919 : // Set the strlist flag for the excluded fstypes
920 121 : for(l=get_strlist(c[OPT_EXCFS]); l; l=l->next)
921 : {
922 0 : l->flag=0;
923 0 : if(!strncasecmp(l->path, "0x", 2))
924 : {
925 0 : l->flag=strtol((l->path)+2, NULL, 16);
926 0 : logp("Excluding file system type 0x%08lX\n", l->flag);
927 : }
928 : else
929 : {
930 0 : if(fstype_to_flag(l->path, &(l->flag)))
931 : {
932 0 : logp("Unknown exclude fs type: %s\n", l->path);
933 0 : l->flag=0;
934 : }
935 : }
936 : }
937 121 : return 0;
938 : }
939 :
940 10 : static int setup_script_arg_override(struct conf *c, struct conf *args)
941 : {
942 : struct strlist *s;
943 10 : set_strlist(args, NULL);
944 30 : for(s=get_strlist(c); s; s=s->next)
945 20 : if(add_to_strlist(args, s->path, s->flag))
946 : return -1;
947 : return 0;
948 : }
949 :
950 357 : static int setup_script_arg_overrides(struct conf *c,
951 : struct conf *pre_args, struct conf *post_args)
952 : {
953 357 : if(!get_strlist(c)) return 0;
954 10 : return setup_script_arg_override(c, pre_args)
955 5 : || setup_script_arg_override(c, post_args);
956 : }
957 :
958 : #ifndef UTEST
959 : static
960 : #endif
961 121 : int conf_finalise(struct conf **c)
962 : {
963 121 : int s_script_notify=0;
964 121 : if(finalise_fstypes(c)) return -1;
965 :
966 121 : strlist_compile_regexes(get_strlist(c[OPT_INCREG]));
967 121 : strlist_compile_regexes(get_strlist(c[OPT_EXCREG]));
968 :
969 121 : set_max_ext(get_strlist(c[OPT_INCEXT]));
970 121 : set_max_ext(get_strlist(c[OPT_EXCEXT]));
971 121 : set_max_ext(get_strlist(c[OPT_EXCOM]));
972 :
973 121 : if(get_e_burp_mode(c[OPT_BURP_MODE])==BURP_MODE_CLIENT
974 45 : && finalise_glob(c)) return -1;
975 :
976 121 : if(finalise_incexc_dirs(c)
977 120 : || finalise_start_dirs(c)) return -1;
978 :
979 119 : if(finalise_keep_args(c)) return -1;
980 :
981 119 : if((s_script_notify=get_int(c[OPT_S_SCRIPT_NOTIFY])))
982 : {
983 4 : set_int(c[OPT_S_SCRIPT_PRE_NOTIFY], s_script_notify);
984 4 : set_int(c[OPT_S_SCRIPT_POST_NOTIFY], s_script_notify);
985 : }
986 :
987 : // These override the specific pre/post script paths with the general
988 : // one. For example, if 'server_script' is set, its value is used for
989 : // 'server_script_pre' and 'server_script_post'.
990 119 : if(pre_post_override(c[OPT_B_SCRIPT],
991 : c[OPT_B_SCRIPT_PRE], c[OPT_B_SCRIPT_POST])
992 119 : || pre_post_override(c[OPT_R_SCRIPT],
993 : c[OPT_R_SCRIPT_PRE], c[OPT_R_SCRIPT_POST])
994 119 : || pre_post_override(c[OPT_S_SCRIPT],
995 : c[OPT_S_SCRIPT_PRE], c[OPT_S_SCRIPT_POST])
996 : // And these do the same for the script arguments.
997 119 : || setup_script_arg_overrides(c[OPT_B_SCRIPT_ARG],
998 : c[OPT_B_SCRIPT_PRE_ARG], c[OPT_B_SCRIPT_POST_ARG])
999 119 : || setup_script_arg_overrides(c[OPT_R_SCRIPT_ARG],
1000 : c[OPT_R_SCRIPT_PRE_ARG], c[OPT_R_SCRIPT_POST_ARG])
1001 119 : || setup_script_arg_overrides(c[OPT_S_SCRIPT_ARG],
1002 : c[OPT_S_SCRIPT_PRE_ARG], c[OPT_S_SCRIPT_POST_ARG]))
1003 : return -1;
1004 :
1005 : // We are now done with these. Clear them, otherwise they interfere.
1006 119 : set_string(c[OPT_S_SCRIPT], NULL);
1007 119 : set_strlist(c[OPT_S_SCRIPT_ARG], NULL);
1008 119 : return 0;
1009 : }
1010 :
1011 71 : static int conf_finalise_global_only(const char *conf_path, struct conf **confs)
1012 : {
1013 71 : int r=0;
1014 :
1015 71 : if(!get_string(confs[OPT_PORT]))
1016 : conf_problem(conf_path, "port unset", &r);
1017 :
1018 : // Let the caller check the 'keep' value.
1019 :
1020 71 : if(!get_string(confs[OPT_SSL_KEY_PASSWORD])
1021 71 : && set_string(confs[OPT_SSL_KEY_PASSWORD], ""))
1022 0 : r--;
1023 :
1024 71 : if(general_conf_checks(confs, conf_path, &r)) r--;
1025 :
1026 71 : switch(get_e_burp_mode(confs[OPT_BURP_MODE]))
1027 : {
1028 : case BURP_MODE_SERVER:
1029 28 : if(server_conf_checks(confs, conf_path, &r)) r--;
1030 : break;
1031 : case BURP_MODE_CLIENT:
1032 43 : if(client_conf_checks(confs, conf_path, &r)) r--;
1033 : break;
1034 : case BURP_MODE_UNSET:
1035 : default:
1036 0 : logp("%s: mode unset - need 'server' or 'client'\n",
1037 : conf_path);
1038 0 : r--;
1039 0 : break;
1040 : }
1041 :
1042 71 : return r;
1043 : }
1044 :
1045 122 : static int conf_load_lines_from_file(const char *conf_path, struct conf **confs)
1046 : {
1047 122 : int ret=0;
1048 122 : int line=0;
1049 122 : FILE *fp=NULL;
1050 122 : char buf[4096]="";
1051 :
1052 122 : if(!(fp=fopen(conf_path, "r")))
1053 : {
1054 3 : logp("could not open '%s' for reading.\n", conf_path);
1055 3 : return -1;
1056 : }
1057 1126 : while(fgets(buf, sizeof(buf), fp))
1058 : {
1059 1007 : line++;
1060 1007 : if(conf_parse_line(confs, conf_path, buf, line))
1061 : {
1062 : conf_error(conf_path, line);
1063 1 : ret=-1;
1064 : }
1065 : }
1066 119 : if(fp) fclose(fp);
1067 119 : return ret;
1068 : }
1069 :
1070 : #ifndef UTEST
1071 : static
1072 : #endif
1073 3 : int conf_load_lines_from_buf(const char *buf, struct conf **c)
1074 : {
1075 3 : int ret=0;
1076 3 : int line=0;
1077 3 : char *tok=NULL;
1078 3 : char *copy=NULL;
1079 :
1080 3 : if(!buf) return 0;
1081 :
1082 3 : if(!(copy=strdup_w(buf, __func__))) return -1;
1083 3 : if(!(tok=strtok(copy, "\n")))
1084 : {
1085 0 : logp("unable to parse conf buffer\n");
1086 0 : free_w(©);
1087 0 : return -1;
1088 : }
1089 : do
1090 : {
1091 8 : line++;
1092 8 : if(conf_parse_line(c, "", tok, line))
1093 : {
1094 : ret=-1;
1095 : break;
1096 : }
1097 8 : } while((tok=strtok(NULL, "\n")));
1098 3 : free_w(©);
1099 :
1100 3 : return ret;
1101 : }
1102 :
1103 : /* The server runs this when parsing a restore file on the server. */
1104 6 : int conf_parse_incexcs_path(struct conf **c, const char *path)
1105 : {
1106 6 : free_incexcs(c);
1107 6 : if(conf_load_lines_from_file(path, c)
1108 6 : || conf_finalise(c))
1109 : return -1;
1110 : return 0;
1111 : }
1112 :
1113 : /* The client runs this when the server overrides the incexcs. */
1114 3 : int conf_parse_incexcs_buf(struct conf **c, const char *incexc)
1115 : {
1116 3 : free_incexcs(c);
1117 3 : if(conf_load_lines_from_buf(incexc, c)
1118 3 : || conf_finalise(c))
1119 : return -1;
1120 : return 0;
1121 : }
1122 :
1123 43 : static int conf_set_from_global(struct conf **globalc, struct conf **cc)
1124 : {
1125 43 : int i=0;
1126 6837 : for(i=0; i<OPT_MAX; i++)
1127 : {
1128 6794 : if(!(cc[i]->flags & CONF_FLAG_CC_OVERRIDE))
1129 4429 : continue;
1130 2365 : switch(cc[i]->conf_type)
1131 : {
1132 : case CT_STRING:
1133 602 : set_string(cc[i], get_string(globalc[i]));
1134 602 : break;
1135 : case CT_UINT:
1136 1161 : set_int(cc[i], get_int(globalc[i]));
1137 1161 : break;
1138 : case CT_FLOAT:
1139 0 : set_float(cc[i], get_float(globalc[i]));
1140 0 : break;
1141 : case CT_MODE_T:
1142 0 : set_mode_t(cc[i], get_mode_t(globalc[i]));
1143 0 : break;
1144 : case CT_SSIZE_T:
1145 86 : set_uint64_t(cc[i], get_uint64_t(globalc[i]));
1146 86 : break;
1147 : case CT_E_BURP_MODE:
1148 0 : set_e_burp_mode(cc[i], get_e_burp_mode(globalc[i]));
1149 0 : break;
1150 : case CT_E_PROTOCOL:
1151 43 : set_e_protocol(cc[i], get_e_protocol(globalc[i]));
1152 43 : break;
1153 : case CT_E_RECOVERY_METHOD:
1154 43 : set_e_recovery_method(cc[i], get_e_recovery_method(globalc[i]));
1155 43 : break;
1156 : case CT_E_RSHASH:
1157 43 : set_e_rshash(cc[i], get_e_rshash(globalc[i]));
1158 43 : break;
1159 : case CT_STRLIST:
1160 : // Done later.
1161 : break;
1162 : case CT_CNTR:
1163 : break;
1164 : // No default so that there are warnings if anything
1165 : // was missed.
1166 : }
1167 : }
1168 :
1169 : // If ssl_peer_cn is not set, default it to the client name.
1170 43 : if(!get_string(globalc[OPT_SSL_PEER_CN])
1171 32 : && set_string(cc[OPT_SSL_PEER_CN], get_string(cc[OPT_CNAME])))
1172 : return -1;
1173 :
1174 : return 0;
1175 : }
1176 :
1177 372 : static int append_strlist(struct conf *dst, struct conf *src)
1178 : {
1179 : struct strlist *s;
1180 429 : for(s=get_strlist(src); s; s=s->next)
1181 57 : if(add_to_strlist(dst, s->path, s->flag))
1182 : return -1;
1183 : return 0;
1184 : }
1185 :
1186 : // Instead of adding onto the end of the list, this replaces the list.
1187 39 : static int conf_set_from_global_arg_list_overrides(struct conf **globalc,
1188 : struct conf **cc)
1189 : {
1190 39 : int i=0;
1191 6201 : for(i=0; i<OPT_MAX; i++)
1192 : {
1193 6162 : if(cc[i]->conf_type!=CT_STRLIST) continue;
1194 1170 : if(!(cc[i]->flags & CONF_FLAG_CC_OVERRIDE)) continue;
1195 351 : if(cc[i]->flags & CONF_FLAG_STRLIST_REPLACE)
1196 : {
1197 : // If there was no cc[i] strlist set, use the global.
1198 312 : if(!get_strlist(cc[i])
1199 294 : && append_strlist(cc[i], globalc[i]))
1200 : return -1;
1201 : }
1202 : else
1203 : {
1204 : struct conf tmpconf;
1205 : // A bit painful.
1206 39 : tmpconf.conf_type=cc[i]->conf_type;
1207 39 : tmpconf.flags=cc[i]->flags;
1208 : memset(&tmpconf.data, 0, sizeof(tmpconf.data));
1209 39 : if(append_strlist(&tmpconf, globalc[i])
1210 39 : || append_strlist(&tmpconf, cc[i]))
1211 0 : return -1;
1212 39 : set_strlist(cc[i], get_strlist(&tmpconf));
1213 : }
1214 : }
1215 : return 0;
1216 : }
1217 :
1218 34 : static int conf_init_save_cname_and_version(struct conf **cconfs)
1219 : {
1220 34 : int ret=-1;
1221 34 : char *cname=NULL;
1222 34 : char *cversion=NULL;
1223 34 : char *orig_cname=get_string(cconfs[OPT_CNAME]);
1224 34 : char *orig_cversion=get_string(cconfs[OPT_PEER_VERSION]);
1225 :
1226 34 : if((orig_cname && !(cname=strdup_w(orig_cname, __func__)))
1227 34 : || (orig_cversion
1228 10 : && !(cversion=strdup_w(orig_cversion, __func__))))
1229 : goto end;
1230 :
1231 34 : set_string(cconfs[OPT_CNAME], NULL);
1232 34 : set_string(cconfs[OPT_PEER_VERSION], NULL);
1233 34 : if(confs_init(cconfs)) goto end;
1234 34 : set_string(cconfs[OPT_CNAME], cname);
1235 34 : set_string(cconfs[OPT_PEER_VERSION], cversion);
1236 34 : ret=0;
1237 : end:
1238 34 : free_w(&cname);
1239 34 : free_w(&cversion);
1240 34 : return ret;
1241 : }
1242 :
1243 43 : static int do_conf_load_overrides(struct conf **globalcs, struct conf **cconfs,
1244 : const char *path, const char *buf)
1245 : {
1246 : // Some client settings can be globally set in the server conf and
1247 : // overridden in the client specific conf.
1248 43 : if(conf_set_from_global(globalcs, cconfs)) return -1;
1249 43 : if(buf) { if(conf_load_lines_from_buf(buf, cconfs)) return -1; }
1250 43 : else { if(conf_load_lines_from_file(path, cconfs)) return -1; }
1251 39 : if(conf_set_from_global_arg_list_overrides(globalcs, cconfs)
1252 39 : || conf_finalise(cconfs))
1253 : return -1;
1254 : return 0;
1255 : }
1256 :
1257 : #ifndef UTEST
1258 : static
1259 : #endif
1260 9 : int conf_load_overrides(struct conf **globalcs, struct conf **cconfs,
1261 : const char *path)
1262 : {
1263 43 : return do_conf_load_overrides(globalcs, cconfs, path, NULL);
1264 : }
1265 :
1266 34 : int conf_load_clientconfdir(struct conf **globalcs, struct conf **cconfs)
1267 : {
1268 34 : int ret=-1;
1269 34 : char *path=NULL;
1270 34 : const char *cname=NULL;
1271 :
1272 34 : if(conf_init_save_cname_and_version(cconfs)) goto end;
1273 34 : cname=get_string(cconfs[OPT_CNAME]);
1274 34 : if(looks_like_tmp_or_hidden_file(cname))
1275 : {
1276 0 : logp("client name '%s' is invalid\n", cname);
1277 0 : goto end;
1278 : }
1279 :
1280 34 : if(!(path=prepend_s(get_string(globalcs[OPT_CLIENTCONFDIR]), cname)))
1281 : goto end;
1282 68 : ret=conf_load_overrides(globalcs, cconfs, path);
1283 : end:
1284 34 : free_w(&path);
1285 34 : return ret;
1286 : }
1287 :
1288 73 : static int do_load_global_only(struct conf **globalcs,
1289 : const char *path, const char *buf)
1290 : {
1291 73 : if(set_string(globalcs[OPT_CONFFILE], path)) return -1;
1292 73 : if(buf) { if(conf_load_lines_from_buf(buf, globalcs)) return -1; }
1293 73 : else { if(conf_load_lines_from_file(path, globalcs)) return -1; }
1294 73 : if(conf_finalise(globalcs)
1295 71 : || conf_finalise_global_only(path, globalcs))
1296 : return -1;
1297 : return 0;
1298 :
1299 : }
1300 :
1301 73 : int conf_load_global_only(const char *path, struct conf **globalcs)
1302 : {
1303 73 : return do_load_global_only(globalcs, path, NULL);
1304 : }
1305 :
1306 4 : static int restore_client_allowed(struct conf **cconfs, struct conf **sconfs)
1307 : {
1308 : struct strlist *r;
1309 7 : for(r=get_strlist(sconfs[OPT_RESTORE_CLIENTS]); r; r=r->next)
1310 6 : if(!strcmp(r->path, get_string(cconfs[OPT_CNAME])))
1311 : return 1;
1312 1 : logp("Access to client is not allowed: %s\n",
1313 : get_string(sconfs[OPT_CNAME]));
1314 1 : return 0;
1315 : }
1316 :
1317 : // FIX THIS: need to unit test this.
1318 5 : int conf_switch_to_orig_client(struct conf **globalcs,
1319 : struct conf **cconfs, const char *orig_client)
1320 : {
1321 5 : int ret=-1;
1322 5 : struct conf **sconfs=NULL;
1323 5 : if(!(sconfs=confs_alloc())
1324 5 : || confs_init(sconfs)) goto end;
1325 5 : if(set_string(sconfs[OPT_CNAME], orig_client))
1326 : goto end;
1327 5 : logp("Client wants to switch to client: %s\n",
1328 5 : get_string(sconfs[OPT_CNAME]));
1329 :
1330 5 : if(conf_load_clientconfdir(globalcs, sconfs))
1331 : {
1332 1 : logp("Could not load alternate config: %s",
1333 1 : get_string(sconfs[OPT_CNAME]));
1334 1 : goto end;
1335 : }
1336 4 : set_int(sconfs[OPT_SEND_CLIENT_CNTR],
1337 4 : get_int(cconfs[OPT_SEND_CLIENT_CNTR]));
1338 :
1339 4 : if(!restore_client_allowed(cconfs, sconfs))
1340 : goto end;
1341 :
1342 3 : if(set_string(sconfs[OPT_RESTORE_PATH],
1343 3 : get_string(cconfs[OPT_RESTORE_PATH])))
1344 : goto end;
1345 3 : if(set_string(cconfs[OPT_RESTORE_PATH], NULL))
1346 : goto end;
1347 3 : set_cntr(sconfs[OPT_CNTR], get_cntr(cconfs));
1348 3 : set_cntr(cconfs[OPT_CNTR], NULL);
1349 3 : confs_free_content(cconfs);
1350 3 : confs_init(cconfs);
1351 3 : confs_memcpy(cconfs, sconfs);
1352 3 : confs_null(sconfs);
1353 3 : if(set_string(cconfs[OPT_RESTORE_CLIENT],
1354 3 : get_string(cconfs[OPT_CNAME]))) goto end;
1355 3 : if(set_string(cconfs[OPT_ORIG_CLIENT],
1356 3 : get_string(cconfs[OPT_CNAME]))) goto end;
1357 :
1358 3 : logp("Switched to client %s\n", get_string(cconfs[OPT_CNAME]));
1359 3 : ret=0;
1360 : end:
1361 5 : confs_free(&sconfs);
1362 5 : return ret;
1363 : }
|
