op public repos

Blob

Date:: Thu Nov 16 21:40:04 2023 UTC
Message:: gotwebd: get rid of proc.[ch] proc.c really shines when there's a network of different types of processes, potentially with a various number of instances each, that needs to exchange messages. Gotwebd instead has a much simpler design, and using proc.c causes more overhead (/headaches) than it solves. So, this attempts to provide the same functionalities but with a much simpler implementation that fits gotwebd better. ok stsp@
Actions:: History | Blame | Raw File
1 /*
2  * Copyright (c) 2016-2019, 2020-2021 Tracey Emery <tracey@traceyemery.net>
3  * Copyright (c) 2004, 2005 Esben Norby <norby@openbsd.org>
4  * Copyright (c) 2004 Ryan McBride <mcbride@openbsd.org>
5  * Copyright (c) 2002, 2003, 2004 Henning Brauer <henning@openbsd.org>
6  * Copyright (c) 2001 Markus Friedl.  All rights reserved.
7  * Copyright (c) 2001 Daniel Hartmeier.  All rights reserved.
8  * Copyright (c) 2001 Theo de Raadt.  All rights reserved.
9  *
10  * Permission to use, copy, modify, and distribute this software for any
11  * purpose with or without fee is hereby granted, provided that the above
12  * copyright notice and this permission notice appear in all copies.
13  *
14  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
15  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
16  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
17  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
18  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
19  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
20  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
21  */
22 
23 %{
24 #include <sys/ioctl.h>
25 #include <sys/types.h>
26 #include <sys/queue.h>
27 #include <sys/socket.h>
28 #include <sys/stat.h>
29 
30 #include <net/if.h>
31 #include <netinet/in.h>
32 
33 #include <arpa/inet.h>
34 
35 #include <ctype.h>
36 #include <err.h>
37 #include <errno.h>
38 #include <event.h>
39 #include <ifaddrs.h>
40 #include <imsg.h>
41 #include <limits.h>
42 #include <netdb.h>
43 #include <stdarg.h>
44 #include <stdlib.h>
45 #include <stdio.h>
46 #include <string.h>
47 #include <syslog.h>
48 #include <unistd.h>
49 
50 #include "got_reference.h"
51 
52 #include "gotwebd.h"
53 
54 TAILQ_HEAD(files, file)		 files = TAILQ_HEAD_INITIALIZER(files);
55 static struct file {
56 	TAILQ_ENTRY(file)	 entry;
57 	FILE			*stream;
58 	char			*name;
59 	int			 lineno;
60 	int			 errors;
61 } *file;
62 struct file	*newfile(const char *, int);
63 static void	 closefile(struct file *);
64 int		 check_file_secrecy(int, const char *);
65 int		 yyparse(void);
66 int		 yylex(void);
67 int		 yyerror(const char *, ...)
68     __attribute__((__format__ (printf, 1, 2)))
69     __attribute__((__nonnull__ (1)));
70 int		 kw_cmp(const void *, const void *);
71 int		 lookup(char *);
72 int		 lgetc(int);
73 int		 lungetc(int);
74 int		 findeol(void);
75 
76 TAILQ_HEAD(symhead, sym)	 symhead = TAILQ_HEAD_INITIALIZER(symhead);
77 struct sym {
78 	TAILQ_ENTRY(sym)	 entry;
79 	int			 used;
80 	int			 persist;
81 	char			*nam;
82 	char			*val;
83 };
84 
85 int	 symset(const char *, const char *, int);
86 char	*symget(const char *);
87 
88 static int		 errors;
89 
90 static struct gotwebd		*gotwebd;
91 static struct server		*new_srv;
92 static struct server		*conf_new_server(const char *);
93 int				 getservice(const char *);
94 int				 n;
95 
96 int		 get_addrs(const char *, const char *, struct server *);
97 int		 addr_dup_check(struct addresslist *, struct address *,
98 		    const char *, const char *);
99 int		 add_addr(struct server *, struct address *);
100 
101 typedef struct {
102 	union {
103 		long long	 number;
104 		char		*string;
105 	} v;
106 	int lineno;
107 } YYSTYPE;
108 
109 %}
110 
111 %token	LISTEN WWW_PATH MAX_REPOS SITE_NAME SITE_OWNER SITE_LINK LOGO
112 %token	LOGO_URL SHOW_REPO_OWNER SHOW_REPO_AGE SHOW_REPO_DESCRIPTION
113 %token	MAX_REPOS_DISPLAY REPOS_PATH MAX_COMMITS_DISPLAY ON ERROR
114 %token	SHOW_SITE_OWNER SHOW_REPO_CLONEURL PORT PREFORK RESPECT_EXPORTOK
115 %token	UNIX_SOCKET UNIX_SOCKET_NAME SERVER CHROOT CUSTOM_CSS SOCKET
116 
117 %token	<v.string>	STRING
118 %token	<v.number>	NUMBER
119 %type	<v.number>	boolean
120 %type	<v.string>	listen_addr
121 
122 %%
123 
124 grammar		: /* empty */
125 		| grammar '\n'
126 		| grammar varset '\n'
127 		| grammar main '\n'
128 		| grammar server '\n'
129 		| grammar error '\n'		{ file->errors++; }
130 		;
131 
132 varset		: STRING '=' STRING	{
133 			char *s = $1;
134 			while (*s++) {
135 				if (isspace((unsigned char)*s)) {
136 					yyerror("macro name cannot contain "
137 					    "whitespace");
138 					free($1);
139 					free($3);
140 					YYERROR;
141 				}
142 			}
143 			if (symset($1, $3, 0) == -1)
144 				fatal("cannot store variable");
145 			free($1);
146 			free($3);
147 		}
148 		;
149 
150 boolean		: STRING {
151 			if (strcasecmp($1, "1") == 0 ||
152 			    strcasecmp($1, "on") == 0)
153 				$$ = 1;
154 			else if (strcasecmp($1, "0") == 0 ||
155 			    strcasecmp($1, "off") == 0)
156 				$$ = 0;
157 			else {
158 				yyerror("invalid boolean value '%s'", $1);
159 				free($1);
160 				YYERROR;
161 			}
162 			free($1);
163 		}
164 		| ON { $$ = 1; }
165 		| NUMBER {
166 			if ($1 != 0 && $1 != 1) {
167 				yyerror("invalid boolean value '%lld'", $1);
168 				YYERROR;
169 			}
170 			$$ = $1;
171 		}
172 		;
173 
174 listen_addr	: '*' { $$ = NULL; }
175 		| STRING
176 		;
177 
178 main		: PREFORK NUMBER {
179 			if ($2 <= 0 || $2 > PROC_MAX_INSTANCES) {
180 				yyerror("prefork is %s: %lld",
181 				    $2 <= 0 ? "too small" : "too large", $2);
182 				YYERROR;
183 			}
184 			gotwebd->prefork_gotwebd = $2;
185 		}
186 		| CHROOT STRING {
187 			if (*$2 == '\0') {
188 				yyerror("chroot path can't be an empty"
189 				    " string");
190 				free($2);
191 				YYERROR;
192 			}
193 
194 			n = strlcpy(gotwebd->httpd_chroot, $2,
195 			    sizeof(gotwebd->httpd_chroot));
196 			if (n >= sizeof(gotwebd->httpd_chroot)) {
197 				yyerror("%s: httpd_chroot truncated", __func__);
198 				free($2);
199 				YYERROR;
200 			}
201 			free($2);
202 		}
203 		| UNIX_SOCKET boolean {
204 			gotwebd->unix_socket = $2;
205 		}
206 		| UNIX_SOCKET_NAME STRING {
207 			n = snprintf(gotwebd->unix_socket_name,
208 			    sizeof(gotwebd->unix_socket_name), "%s%s",
209 			    gotwebd->httpd_chroot, $2);
210 			if (n < 0 ||
211 			    (size_t)n >= sizeof(gotwebd->unix_socket_name)) {
212 				yyerror("%s: unix_socket_name truncated",
213 				    __func__);
214 				free($2);
215 				YYERROR;
216 			}
217 			free($2);
218 		}
219 		;
220 
221 server		: SERVER STRING {
222 			struct server *srv;
223 
224 			TAILQ_FOREACH(srv, &gotwebd->servers, entry) {
225 				if (strcmp(srv->name, $2) == 0) {
226 					yyerror("server name exists '%s'", $2);
227 					free($2);
228 					YYERROR;
229 				}
230 			}
231 
232 			new_srv = conf_new_server($2);
233 			log_debug("adding server %s", $2);
234 			free($2);
235 		}
236 		| SERVER STRING {
237 			struct server *srv;
238 
239 			TAILQ_FOREACH(srv, &gotwebd->servers, entry) {
240 				if (strcmp(srv->name, $2) == 0) {
241 					yyerror("server name exists '%s'", $2);
242 					free($2);
243 					YYERROR;
244 				}
245 			}
246 
247 			new_srv = conf_new_server($2);
248 			log_debug("adding server %s", $2);
249 			free($2);
250 		} '{' optnl serveropts2 '}' {
251 		}
252 		;
253 
254 serveropts1	: REPOS_PATH STRING {
255 			n = strlcpy(new_srv->repos_path, $2,
256 			    sizeof(new_srv->repos_path));
257 			if (n >= sizeof(new_srv->repos_path)) {
258 				yyerror("%s: repos_path truncated", __func__);
259 				free($2);
260 				YYERROR;
261 			}
262 			free($2);
263 		}
264 		| SITE_NAME STRING {
265 			n = strlcpy(new_srv->site_name, $2,
266 			    sizeof(new_srv->site_name));
267 			if (n >= sizeof(new_srv->site_name)) {
268 				yyerror("%s: site_name truncated", __func__);
269 				free($2);
270 				YYERROR;
271 			}
272 			free($2);
273 		}
274 		| SITE_OWNER STRING {
275 			n = strlcpy(new_srv->site_owner, $2,
276 			    sizeof(new_srv->site_owner));
277 			if (n >= sizeof(new_srv->site_owner)) {
278 				yyerror("%s: site_owner truncated", __func__);
279 				free($2);
280 				YYERROR;
281 			}
282 			free($2);
283 		}
284 		| SITE_LINK STRING {
285 			n = strlcpy(new_srv->site_link, $2,
286 			    sizeof(new_srv->site_link));
287 			if (n >= sizeof(new_srv->site_link)) {
288 				yyerror("%s: site_link truncated", __func__);
289 				free($2);
290 				YYERROR;
291 			}
292 			free($2);
293 		}
294 		| LOGO STRING {
295 			n = strlcpy(new_srv->logo, $2, sizeof(new_srv->logo));
296 			if (n >= sizeof(new_srv->logo)) {
297 				yyerror("%s: logo truncated", __func__);
298 				free($2);
299 				YYERROR;
300 			}
301 			free($2);
302 		}
303 		| LOGO_URL STRING {
304 			n = strlcpy(new_srv->logo_url, $2,
305 			    sizeof(new_srv->logo_url));
306 			if (n >= sizeof(new_srv->logo_url)) {
307 				yyerror("%s: logo_url truncated", __func__);
308 				free($2);
309 				YYERROR;
310 			}
311 			free($2);
312 		}
313 		| CUSTOM_CSS STRING {
314 			n = strlcpy(new_srv->custom_css, $2,
315 			    sizeof(new_srv->custom_css));
316 			if (n >= sizeof(new_srv->custom_css)) {
317 				yyerror("%s: custom_css truncated", __func__);
318 				free($2);
319 				YYERROR;
320 			}
321 			free($2);
322 		}
323 		| LISTEN ON listen_addr PORT STRING {
324 			if (get_addrs($3, $5, new_srv) == -1) {
325 				yyerror("could not get addrs");
326 				YYERROR;
327 			}
328 			free($3);
329 			free($5);
330 			new_srv->fcgi_socket = 1;
331 		}
332 		| LISTEN ON listen_addr PORT NUMBER {
333 			char portno[32];
334 			int n;
335 
336 			n = snprintf(portno, sizeof(portno), "%lld",
337 			    (long long)$5);
338 			if (n < 0 || (size_t)n >= sizeof(portno))
339 				fatalx("port number too long: %lld",
340 				    (long long)$5);
341 
342 			if (get_addrs($3, portno, new_srv) == -1) {
343 				yyerror("could not get addrs");
344 				YYERROR;
345 			}
346 			free($3);
347 			new_srv->fcgi_socket = 1;
348 		}
349 		| LISTEN ON SOCKET STRING {
350 			if (strcasecmp($4, "off") == 0) {
351 				new_srv->unix_socket = 0;
352 				free($4);
353 				YYACCEPT;
354 			}
355 
356 			new_srv->unix_socket = 1;
357 
358 			n = snprintf(new_srv->unix_socket_name,
359 			    sizeof(new_srv->unix_socket_name), "%s%s",
360 			    gotwebd->httpd_chroot, $4);
361 			if (n < 0 ||
362 			    (size_t)n >= sizeof(new_srv->unix_socket_name)) {
363 				yyerror("%s: unix_socket_name truncated",
364 				    __func__);
365 				free($4);
366 				YYERROR;
367 			}
368 			free($4);
369 		}
370 		| MAX_REPOS NUMBER {
371 			if ($2 <= 0) {
372 				yyerror("max_repos is too small: %lld", $2);
373 				YYERROR;
374 			}
375 			new_srv->max_repos = $2;
376 		}
377 		| SHOW_SITE_OWNER boolean {
378 			new_srv->show_site_owner = $2;
379 		}
380 		| SHOW_REPO_OWNER boolean {
381 			new_srv->show_repo_owner = $2;
382 		}
383 		| SHOW_REPO_AGE boolean {
384 			new_srv->show_repo_age = $2;
385 		}
386 		| SHOW_REPO_DESCRIPTION boolean {
387 			new_srv->show_repo_description = $2;
388 		}
389 		| SHOW_REPO_CLONEURL boolean {
390 			new_srv->show_repo_cloneurl = $2;
391 		}
392 		| RESPECT_EXPORTOK boolean {
393 			new_srv->respect_exportok = $2;
394 		}
395 		| MAX_REPOS_DISPLAY NUMBER {
396 			if ($2 < 0) {
397 				yyerror("max_repos_display is too small: %lld",
398 				    $2);
399 				YYERROR;
400 			}
401 			new_srv->max_repos_display = $2;
402 		}
403 		| MAX_COMMITS_DISPLAY NUMBER {
404 			if ($2 <= 1) {
405 				yyerror("max_commits_display is too small:"
406 				    " %lld", $2);
407 				YYERROR;
408 			}
409 			new_srv->max_commits_display = $2;
410 		}
411 		;
412 
413 serveropts2	: serveropts2 serveropts1 nl
414 		| serveropts1 optnl
415 		;
416 
417 nl		: '\n' optnl
418 		;
419 
420 optnl		: '\n' optnl		/* zero or more newlines */
421 		| /* empty */
422 		;
423 
424 %%
425 
426 struct keywords {
427 	const char	*k_name;
428 	int		 k_val;
429 };
430 
431 int
432 yyerror(const char *fmt, ...)
433 {
434 	va_list ap;
435 	char *msg;
436 
437 	file->errors++;
438 	va_start(ap, fmt);
439 	if (vasprintf(&msg, fmt, ap) == -1)
440 		fatalx("yyerror vasprintf");
441 	va_end(ap);
442 	logit(LOG_CRIT, "%s:%d: %s", file->name, yylval.lineno, msg);
443 	free(msg);
444 	return (0);
445 }
446 
447 int
448 kw_cmp(const void *k, const void *e)
449 {
450 	return (strcmp(k, ((const struct keywords *)e)->k_name));
451 }
452 
453 int
454 lookup(char *s)
455 {
456 	/* This has to be sorted always. */
457 	static const struct keywords keywords[] = {
458 		{ "chroot",			CHROOT },
459 		{ "custom_css",			CUSTOM_CSS },
460 		{ "listen",			LISTEN },
461 		{ "logo",			LOGO },
462 		{ "logo_url",			LOGO_URL },
463 		{ "max_commits_display",	MAX_COMMITS_DISPLAY },
464 		{ "max_repos",			MAX_REPOS },
465 		{ "max_repos_display",		MAX_REPOS_DISPLAY },
466 		{ "on",				ON },
467 		{ "port",			PORT },
468 		{ "prefork",			PREFORK },
469 		{ "repos_path",			REPOS_PATH },
470 		{ "respect_exportok",		RESPECT_EXPORTOK },
471 		{ "server",			SERVER },
472 		{ "show_repo_age",		SHOW_REPO_AGE },
473 		{ "show_repo_cloneurl",		SHOW_REPO_CLONEURL },
474 		{ "show_repo_description",	SHOW_REPO_DESCRIPTION },
475 		{ "show_repo_owner",		SHOW_REPO_OWNER },
476 		{ "show_site_owner",		SHOW_SITE_OWNER },
477 		{ "site_link",			SITE_LINK },
478 		{ "site_name",			SITE_NAME },
479 		{ "site_owner",			SITE_OWNER },
480 		{ "socket",			SOCKET },
481 		{ "unix_socket",		UNIX_SOCKET },
482 		{ "unix_socket_name",		UNIX_SOCKET_NAME },
483 	};
484 	const struct keywords *p;
485 
486 	p = bsearch(s, keywords, sizeof(keywords)/sizeof(keywords[0]),
487 	    sizeof(keywords[0]), kw_cmp);
488 
489 	if (p)
490 		return (p->k_val);
491 	else
492 		return (STRING);
493 }
494 
495 #define MAXPUSHBACK	128
496 
497 unsigned char *parsebuf;
498 int parseindex;
499 unsigned char pushback_buffer[MAXPUSHBACK];
500 int pushback_index = 0;
501 
502 int
503 lgetc(int quotec)
504 {
505 	int c, next;
506 
507 	if (parsebuf) {
508 		/* Read character from the parsebuffer instead of input. */
509 		if (parseindex >= 0) {
510 			c = parsebuf[parseindex++];
511 			if (c != '\0')
512 				return (c);
513 			parsebuf = NULL;
514 		} else
515 			parseindex++;
516 	}
517 
518 	if (pushback_index)
519 		return (pushback_buffer[--pushback_index]);
520 
521 	if (quotec) {
522 		c = getc(file->stream);
523 		if (c == EOF)
524 			yyerror("reached end of file while parsing "
525 			    "quoted string");
526 		return (c);
527 	}
528 
529 	c = getc(file->stream);
530 	while (c == '\\') {
531 		next = getc(file->stream);
532 		if (next != '\n') {
533 			c = next;
534 			break;
535 		}
536 		yylval.lineno = file->lineno;
537 		file->lineno++;
538 		c = getc(file->stream);
539 	}
540 
541 	return (c);
542 }
543 
544 int
545 lungetc(int c)
546 {
547 	if (c == EOF)
548 		return (EOF);
549 	if (parsebuf) {
550 		parseindex--;
551 		if (parseindex >= 0)
552 			return (c);
553 	}
554 	if (pushback_index < MAXPUSHBACK-1)
555 		return (pushback_buffer[pushback_index++] = c);
556 	else
557 		return (EOF);
558 }
559 
560 int
561 findeol(void)
562 {
563 	int c;
564 
565 	parsebuf = NULL;
566 
567 	/* Skip to either EOF or the first real EOL. */
568 	while (1) {
569 		if (pushback_index)
570 			c = pushback_buffer[--pushback_index];
571 		else
572 			c = lgetc(0);
573 		if (c == '\n') {
574 			file->lineno++;
575 			break;
576 		}
577 		if (c == EOF)
578 			break;
579 	}
580 	return (ERROR);
581 }
582 
583 int
584 yylex(void)
585 {
586 	unsigned char buf[8096];
587 	unsigned char *p, *val;
588 	int quotec, next, c;
589 	int token;
590 
591 top:
592 	p = buf;
593 	c = lgetc(0);
594 	while (c == ' ' || c == '\t')
595 		c = lgetc(0); /* nothing */
596 
597 	yylval.lineno = file->lineno;
598 	if (c == '#') {
599 		c = lgetc(0);
600 		while (c != '\n' && c != EOF)
601 			c = lgetc(0); /* nothing */
602 	}
603 	if (c == '$' && parsebuf == NULL) {
604 		while (1) {
605 			c = lgetc(0);
606 			if (c == EOF)
607 				return (0);
608 
609 			if (p + 1 >= buf + sizeof(buf) - 1) {
610 				yyerror("string too long");
611 				return (findeol());
612 			}
613 			if (isalnum(c) || c == '_') {
614 				*p++ = c;
615 				continue;
616 			}
617 			*p = '\0';
618 			lungetc(c);
619 			break;
620 		}
621 		val = symget(buf);
622 		if (val == NULL) {
623 			yyerror("macro '%s' not defined", buf);
624 			return (findeol());
625 		}
626 		parsebuf = val;
627 		parseindex = 0;
628 		goto top;
629 	}
630 
631 	switch (c) {
632 	case '\'':
633 	case '"':
634 		quotec = c;
635 		while (1) {
636 			c = lgetc(quotec);
637 			if (c == EOF)
638 				return (0);
639 			if (c == '\n') {
640 				file->lineno++;
641 				continue;
642 			} else if (c == '\\') {
643 				next = lgetc(quotec);
644 				if (next == EOF)
645 					return (0);
646 				if (next == quotec || c == ' ' || c == '\t')
647 					c = next;
648 				else if (next == '\n') {
649 					file->lineno++;
650 					continue;
651 				} else
652 					lungetc(next);
653 			} else if (c == quotec) {
654 				*p = '\0';
655 				break;
656 			} else if (c == '\0') {
657 				yyerror("syntax error");
658 				return (findeol());
659 			}
660 			if (p + 1 >= buf + sizeof(buf) - 1) {
661 				yyerror("string too long");
662 				return (findeol());
663 			}
664 			*p++ = c;
665 		}
666 		yylval.v.string = strdup(buf);
667 		if (yylval.v.string == NULL)
668 			err(1, "yylex: strdup");
669 		return (STRING);
670 	}
671 
672 #define allowed_to_end_number(x) \
673 	(isspace(x) || x == ')' || x ==',' || x == '/' || x == '}' || x == '=')
674 
675 	if (c == '-' || isdigit(c)) {
676 		do {
677 			*p++ = c;
678 			if ((unsigned)(p-buf) >= sizeof(buf)) {
679 				yyerror("string too long");
680 				return (findeol());
681 			}
682 			c = lgetc(0);
683 		} while (c != EOF && isdigit(c));
684 		lungetc(c);
685 		if (p == buf + 1 && buf[0] == '-')
686 			goto nodigits;
687 		if (c == EOF || allowed_to_end_number(c)) {
688 			const char *errstr = NULL;
689 
690 			*p = '\0';
691 			yylval.v.number = strtonum(buf, LLONG_MIN,
692 			    LLONG_MAX, &errstr);
693 			if (errstr) {
694 				yyerror("\"%s\" invalid number: %s",
695 				    buf, errstr);
696 				return (findeol());
697 			}
698 			return (NUMBER);
699 		} else {
700 nodigits:
701 			while (p > buf + 1)
702 				lungetc(*--p);
703 			c = *--p;
704 			if (c == '-')
705 				return (c);
706 		}
707 	}
708 
709 #define allowed_in_string(x) \
710 	(isalnum(x) || (ispunct(x) && x != '(' && x != ')' && \
711 	x != '{' && x != '}' && \
712 	x != '!' && x != '=' && x != '#' && \
713 	x != ','))
714 
715 	if (isalnum(c) || c == ':' || c == '_') {
716 		do {
717 			*p++ = c;
718 			if ((unsigned)(p-buf) >= sizeof(buf)) {
719 				yyerror("string too long");
720 				return (findeol());
721 			}
722 			c = lgetc(0);
723 		} while (c != EOF && (allowed_in_string(c)));
724 		lungetc(c);
725 		*p = '\0';
726 		token = lookup(buf);
727 		if (token == STRING) {
728 			yylval.v.string = strdup(buf);
729 			if (yylval.v.string == NULL)
730 				err(1, "yylex: strdup");
731 		}
732 		return (token);
733 	}
734 	if (c == '\n') {
735 		yylval.lineno = file->lineno;
736 		file->lineno++;
737 	}
738 	if (c == EOF)
739 		return (0);
740 	return (c);
741 }
742 
743 int
744 check_file_secrecy(int fd, const char *fname)
745 {
746 	struct stat st;
747 
748 	if (fstat(fd, &st)) {
749 		log_warn("cannot stat %s", fname);
750 		return (-1);
751 	}
752 	if (st.st_uid != 0 && st.st_uid != getuid()) {
753 		log_warnx("%s: owner not root or current user", fname);
754 		return (-1);
755 	}
756 	if (st.st_mode & (S_IWGRP | S_IXGRP | S_IRWXO)) {
757 		log_warnx("%s: group writable or world read/writable", fname);
758 		return (-1);
759 	}
760 	return (0);
761 }
762 
763 struct file *
764 newfile(const char *name, int secret)
765 {
766 	struct file *nfile;
767 
768 	nfile = calloc(1, sizeof(struct file));
769 	if (nfile == NULL) {
770 		log_warn("calloc");
771 		return (NULL);
772 	}
773 	nfile->name = strdup(name);
774 	if (nfile->name == NULL) {
775 		log_warn("strdup");
776 		free(nfile);
777 		return (NULL);
778 	}
779 	nfile->stream = fopen(nfile->name, "r");
780 	if (nfile->stream == NULL) {
781 		/* no warning, we don't require a conf file */
782 		free(nfile->name);
783 		free(nfile);
784 		return (NULL);
785 	} else if (secret &&
786 	    check_file_secrecy(fileno(nfile->stream), nfile->name)) {
787 		fclose(nfile->stream);
788 		free(nfile->name);
789 		free(nfile);
790 		return (NULL);
791 	}
792 	nfile->lineno = 1;
793 	return (nfile);
794 }
795 
796 static void
797 closefile(struct file *xfile)
798 {
799 	fclose(xfile->stream);
800 	free(xfile->name);
801 	free(xfile);
802 }
803 
804 static void
805 add_default_server(void)
806 {
807 	new_srv = conf_new_server(D_SITENAME);
808 	log_debug("%s: adding default server %s", __func__, D_SITENAME);
809 }
810 
811 int
812 parse_config(const char *filename, struct gotwebd *env)
813 {
814 	struct sym *sym, *next;
815 
816 	if (config_init(env) == -1)
817 		fatalx("failed to initialize configuration");
818 
819 	gotwebd = env;
820 
821 	file = newfile(filename, 0);
822 	if (file == NULL) {
823 		add_default_server();
824 		sockets_parse_sockets(env);
825 		/* just return, as we don't require a conf file */
826 		return (0);
827 	}
828 
829 	yyparse();
830 	errors = file->errors;
831 	closefile(file);
832 
833 	/* Free macros and check which have not been used. */
834 	TAILQ_FOREACH_SAFE(sym, &symhead, entry, next) {
835 		if ((gotwebd->gotwebd_verbose > 1) && !sym->used)
836 			fprintf(stderr, "warning: macro '%s' not used\n",
837 			    sym->nam);
838 		if (!sym->persist) {
839 			free(sym->nam);
840 			free(sym->val);
841 			TAILQ_REMOVE(&symhead, sym, entry);
842 			free(sym);
843 		}
844 	}
845 
846 	if (errors)
847 		return (-1);
848 
849 	/* just add default server if no config specified */
850 	if (gotwebd->server_cnt == 0)
851 		add_default_server();
852 
853 	/* setup our listening sockets */
854 	sockets_parse_sockets(env);
855 
856 	return (0);
857 }
858 
859 struct server *
860 conf_new_server(const char *name)
861 {
862 	struct server *srv = NULL;
863 
864 	srv = calloc(1, sizeof(*srv));
865 	if (srv == NULL)
866 		fatalx("%s: calloc", __func__);
867 
868 	n = strlcpy(srv->name, name, sizeof(srv->name));
869 	if (n >= sizeof(srv->name))
870 		fatalx("%s: strlcpy", __func__);
871 	n = snprintf(srv->unix_socket_name,
872 	    sizeof(srv->unix_socket_name), "%s%s", D_HTTPD_CHROOT,
873 	    D_UNIX_SOCKET);
874 	if (n < 0 || (size_t)n >= sizeof(srv->unix_socket_name))
875 		fatalx("%s: snprintf", __func__);
876 	n = strlcpy(srv->repos_path, D_GOTPATH,
877 	    sizeof(srv->repos_path));
878 	if (n >= sizeof(srv->repos_path))
879 		fatalx("%s: strlcpy", __func__);
880 	n = strlcpy(srv->site_name, D_SITENAME,
881 	    sizeof(srv->site_name));
882 	if (n >= sizeof(srv->site_name))
883 		fatalx("%s: strlcpy", __func__);
884 	n = strlcpy(srv->site_owner, D_SITEOWNER,
885 	    sizeof(srv->site_owner));
886 	if (n >= sizeof(srv->site_owner))
887 		fatalx("%s: strlcpy", __func__);
888 	n = strlcpy(srv->site_link, D_SITELINK,
889 	    sizeof(srv->site_link));
890 	if (n >= sizeof(srv->site_link))
891 		fatalx("%s: strlcpy", __func__);
892 	n = strlcpy(srv->logo, D_GOTLOGO,
893 	    sizeof(srv->logo));
894 	if (n >= sizeof(srv->logo))
895 		fatalx("%s: strlcpy", __func__);
896 	n = strlcpy(srv->logo_url, D_GOTURL, sizeof(srv->logo_url));
897 	if (n >= sizeof(srv->logo_url))
898 		fatalx("%s: strlcpy", __func__);
899 	n = strlcpy(srv->custom_css, D_GOTWEBCSS, sizeof(srv->custom_css));
900 	if (n >= sizeof(srv->custom_css))
901 		fatalx("%s: strlcpy", __func__);
902 
903 	srv->show_site_owner = D_SHOWSOWNER;
904 	srv->show_repo_owner = D_SHOWROWNER;
905 	srv->show_repo_age = D_SHOWAGE;
906 	srv->show_repo_description = D_SHOWDESC;
907 	srv->show_repo_cloneurl = D_SHOWURL;
908 	srv->respect_exportok = D_RESPECTEXPORTOK;
909 
910 	srv->max_repos_display = D_MAXREPODISP;
911 	srv->max_commits_display = D_MAXCOMMITDISP;
912 	srv->max_repos = D_MAXREPO;
913 
914 	srv->unix_socket = 1;
915 	srv->fcgi_socket = 0;
916 
917 	TAILQ_INIT(&srv->al);
918 	TAILQ_INSERT_TAIL(&gotwebd->servers, srv, entry);
919 	gotwebd->server_cnt++;
920 
921 	return srv;
922 };
923 
924 int
925 symset(const char *nam, const char *val, int persist)
926 {
927 	struct sym *sym;
928 
929 	TAILQ_FOREACH(sym, &symhead, entry) {
930 		if (strcmp(nam, sym->nam) == 0)
931 			break;
932 	}
933 
934 	if (sym != NULL) {
935 		if (sym->persist == 1)
936 			return (0);
937 		else {
938 			free(sym->nam);
939 			free(sym->val);
940 			TAILQ_REMOVE(&symhead, sym, entry);
941 			free(sym);
942 		}
943 	}
944 	sym = calloc(1, sizeof(*sym));
945 	if (sym == NULL)
946 		return (-1);
947 
948 	sym->nam = strdup(nam);
949 	if (sym->nam == NULL) {
950 		free(sym);
951 		return (-1);
952 	}
953 	sym->val = strdup(val);
954 	if (sym->val == NULL) {
955 		free(sym->nam);
956 		free(sym);
957 		return (-1);
958 	}
959 	sym->used = 0;
960 	sym->persist = persist;
961 	TAILQ_INSERT_TAIL(&symhead, sym, entry);
962 	return (0);
963 }
964 
965 int
966 cmdline_symset(char *s)
967 {
968 	char *sym, *val;
969 	int ret;
970 
971 	val = strrchr(s, '=');
972 	if (val == NULL)
973 		return (-1);
974 
975 	sym = strndup(s, val - s);
976 	if (sym == NULL)
977 		fatal("%s: strndup", __func__);
978 
979 	ret = symset(sym, val + 1, 1);
980 	free(sym);
981 
982 	return (ret);
983 }
984 
985 char *
986 symget(const char *nam)
987 {
988 	struct sym *sym;
989 
990 	TAILQ_FOREACH(sym, &symhead, entry) {
991 		if (strcmp(nam, sym->nam) == 0) {
992 			sym->used = 1;
993 			return (sym->val);
994 		}
995 	}
996 	return (NULL);
997 }
998 
999 int
1000 get_addrs(const char *hostname, const char *servname, struct server *new_srv)
1001 {
1002 	struct addrinfo hints, *res0, *res;
1003 	int error;
1004 	struct sockaddr_in *sin;
1005 	struct sockaddr_in6 *sin6;
1006 	struct address *h;
1007 
1008 	memset(&hints, 0, sizeof(hints));
1009 	hints.ai_family = AF_UNSPEC;
1010 	hints.ai_socktype = SOCK_STREAM;
1011 	hints.ai_flags = AI_PASSIVE | AI_ADDRCONFIG;
1012 	error = getaddrinfo(hostname, servname, &hints, &res0);
1013 	if (error) {
1014 		log_warnx("%s: could not parse \"%s:%s\": %s", __func__,
1015 		    hostname, servname, gai_strerror(error));
1016 		return (-1);
1017 	}
1018 
1019 	for (res = res0; res; res = res->ai_next) {
1020 		if ((h = calloc(1, sizeof(*h))) == NULL)
1021 			fatal(__func__);
1022 
1023 		if (hostname == NULL) {
1024 			strlcpy(h->ifname, "*", sizeof(h->ifname));
1025 		} else {
1026 			if (strlcpy(h->ifname, hostname, sizeof(h->ifname)) >=
1027 			    sizeof(h->ifname)) {
1028 				log_warnx("%s: address truncated: %s",
1029 				    __func__, hostname);
1030 				freeaddrinfo(res0);
1031 				free(h);
1032 				return (-1);
1033 			}
1034 		}
1035 
1036 		h->ai_family = res->ai_family;
1037 		h->ai_socktype = res->ai_socktype;
1038 		h->ai_protocol = res->ai_protocol;
1039 		memcpy(&h->ss, res->ai_addr, res->ai_addrlen);
1040 		h->slen = res->ai_addrlen;
1041 
1042 		switch (res->ai_family) {
1043 		case AF_INET:
1044 			sin = (struct sockaddr_in *)res->ai_addr;
1045 			h->port = ntohs(sin->sin_port);
1046 			break;
1047 		case AF_INET6:
1048 			sin6 = (struct sockaddr_in6 *)res->ai_addr;
1049 			h->port = ntohs(sin6->sin6_port);
1050 			break;
1051 		default:
1052 			fatalx("unknown address family %d", res->ai_family);
1053 		}
1054 
1055 		if (add_addr(new_srv, h))
1056 			return -1;
1057 	}
1058 	freeaddrinfo(res0);
1059 	return (0);
1060 }
1061 
1062 int
1063 addr_dup_check(struct addresslist *al, struct address *h, const char *new_srv,
1064     const char *other_srv)
1065 {
1066 	struct address *a;
1067 	void *ia;
1068 	char buf[INET6_ADDRSTRLEN];
1069 	const char *addrstr;
1070 
1071 	TAILQ_FOREACH(a, al, entry) {
1072 		if (a->ai_family != h->ai_family ||
1073 		    a->ai_socktype != h->ai_socktype ||
1074 		    a->ai_protocol != h->ai_protocol ||
1075 		    a->slen != h->slen ||
1076 		    memcmp(&a->ss, &h->ss, a->slen) != 0)
1077 			continue;
1078 
1079 		switch (h->ss.ss_family) {
1080 		case AF_INET:
1081 			ia = &((struct sockaddr_in *)(&h->ss))->sin_addr;
1082 			break;
1083 		case AF_INET6:
1084 			ia = &((struct sockaddr_in6 *)(&h->ss))->sin6_addr;
1085 			break;
1086 		default:
1087 			yyerror("unknown address family: %d", h->ss.ss_family);
1088 			return -1;
1089 		}
1090 		addrstr = inet_ntop(h->ss.ss_family, ia, buf, sizeof(buf));
1091 		if (addrstr) {
1092 			if (other_srv) {
1093 				yyerror("server %s: duplicate fcgi listen "
1094 				    "address %s:%d, already used by server %s",
1095 				    new_srv, addrstr, h->port, other_srv);
1096 			} else {
1097 				log_warnx("server: %s: duplicate fcgi listen "
1098 				    "address %s:%d", new_srv, addrstr, h->port);
1099 			}
1100 		} else {
1101 			if (other_srv) {
1102 				yyerror("server: %s: duplicate fcgi listen "
1103 				    "address, already used by server %s",
1104 				    new_srv, other_srv);
1105 			} else {
1106 				log_warnx("server %s: duplicate fcgi listen "
1107 				    "address", new_srv);
1108 			}
1109 		}
1110 
1111 		return -1;
1112 	}
1113 
1114 	return 0;
1115 }
1116 
1117 int
1118 add_addr(struct server *new_srv, struct address *h)
1119 {
1120 	struct server *srv;
1121 
1122 	/* Address cannot be shared between different servers. */
1123 	TAILQ_FOREACH(srv, &gotwebd->servers, entry) {
1124 		if (srv == new_srv)
1125 			continue;
1126 		if (addr_dup_check(&srv->al, h, new_srv->name, srv->name))
1127 			return -1;
1128 	}
1129 
1130 	/* Tolerate duplicate address lines within the scope of a server. */
1131 	if (addr_dup_check(&new_srv->al, h, NULL, NULL) == 0)
1132 		TAILQ_INSERT_TAIL(&new_srv->al, h, entry);
1133 	else
1134 		free(h);
1135 
1136 	return 0;
1137 }