2 a555e0d6 2022-07-04 op * Copyright (c) 2020, 2021, 2022 Omar Polo <op@omarpolo.com>
4 3e4749f7 2020-10-02 op * Permission to use, copy, modify, and distribute this software for any
5 3e4749f7 2020-10-02 op * purpose with or without fee is hereby granted, provided that the above
6 3e4749f7 2020-10-02 op * copyright notice and this permission notice appear in all copies.
8 3e4749f7 2020-10-02 op * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
9 3e4749f7 2020-10-02 op * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
10 3e4749f7 2020-10-02 op * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
11 3e4749f7 2020-10-02 op * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
12 3e4749f7 2020-10-02 op * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
13 3e4749f7 2020-10-02 op * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
14 3e4749f7 2020-10-02 op * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
17 52418c8d 2021-02-12 op #include "gmid.h"
19 8443bff7 2021-01-25 op #include <sys/stat.h>
21 592fd624 2020-10-07 op #include <errno.h>
22 3e4749f7 2020-10-02 op #include <fcntl.h>
23 5777923b 2021-06-29 op #include <getopt.h>
24 0046c1fe 2023-06-06 op #include <locale.h>
25 7e1df73d 2021-03-31 op #include <libgen.h>
26 bcf5d929 2021-02-01 op #include <limits.h>
27 c9e97a6e 2022-12-24 op #include <grp.h>
28 ae08ec7d 2021-01-25 op #include <pwd.h>
29 0cf902af 2020-11-03 op #include <signal.h>
30 3e4749f7 2020-10-02 op #include <string.h>
31 eae52ad4 2023-06-06 op #include <syslog.h>
33 eae52ad4 2023-06-06 op #include "log.h"
34 c26f2460 2023-06-08 op #include "proc.h"
36 c26f2460 2023-06-08 op #ifndef nitems
37 c26f2460 2023-06-08 op #define nitems(_a) (sizeof((_a)) / sizeof((_a)[0]))
40 c26f2460 2023-06-08 op static int main_configure(struct conf *);
41 c26f2460 2023-06-08 op static void main_configure_done(struct conf *);
42 c26f2460 2023-06-08 op static void main_reload(struct conf *);
43 c26f2460 2023-06-08 op static void main_sig_handler(int, short, void *);
44 c26f2460 2023-06-08 op static int main_dispatch_server(int, struct privsep_proc *, struct imsg *);
45 c26f2460 2023-06-08 op static int main_dispatch_logger(int, struct privsep_proc *, struct imsg *);
46 c26f2460 2023-06-08 op static void __dead main_shutdown(struct conf *);
48 c26f2460 2023-06-08 op static struct privsep_proc procs[] = {
49 c26f2460 2023-06-08 op { "server", PROC_SERVER, main_dispatch_server, server },
50 c26f2460 2023-06-08 op { "logger", PROC_LOGGER, main_dispatch_logger, logger },
53 c26f2460 2023-06-08 op static const char *opts = "c:D:fI:hnP:T:Vv";
55 e5d82d94 2022-03-19 op static const struct option longopts[] = {
56 5777923b 2021-06-29 op {"help", no_argument, NULL, 'h'},
57 5777923b 2021-06-29 op {"version", no_argument, NULL, 'V'},
58 5777923b 2021-06-29 op {NULL, 0, NULL, 0},
61 b8e64ccd 2021-03-31 op struct vhosthead hosts;
63 bc99d868 2021-03-19 op int sock4, sock6;
64 c26f2460 2023-06-08 op int privsep_process;
65 c26f2460 2023-06-08 op int pidfd = -1;
67 ca84625a 2023-06-08 op int debug, verbose;
69 32fbc478 2022-09-08 op const char *config_path = "/etc/gmid.conf";
70 32fbc478 2022-09-08 op const char *pidfile;
72 15902770 2021-01-15 op struct conf conf;
77 3abf91b0 2021-02-07 op fprintf(stderr,
78 0be2a537 2021-06-29 op "Version: " GMID_STRING "\n"
79 0ac785a6 2023-06-05 op "Usage: %s [-fnv] [-c config] [-D macro=value] [-P pidfile]\n",
80 9327bc04 2021-06-29 op getprogname());
83 47b0ff10 2023-06-08 op /* used by the server process, defined here so gg can provide its own impl. */
85 47b0ff10 2023-06-08 op log_request(struct client *c, char *meta, size_t l)
87 47b0ff10 2023-06-08 op char hbuf[NI_MAXHOST], sbuf[NI_MAXSERV], b[GEMINI_URL_LEN];
89 47b0ff10 2023-06-08 op const char *t;
93 47b0ff10 2023-06-08 op len = sizeof(c->addr);
94 47b0ff10 2023-06-08 op ec = getnameinfo((struct sockaddr*)&c->addr, len,
95 47b0ff10 2023-06-08 op hbuf, sizeof(hbuf),
96 47b0ff10 2023-06-08 op sbuf, sizeof(sbuf),
97 47b0ff10 2023-06-08 op NI_NUMERICHOST | NI_NUMERICSERV);
99 47b0ff10 2023-06-08 op fatalx("getnameinfo: %s", gai_strerror(ec));
101 47b0ff10 2023-06-08 op if (c->iri.schema != NULL) {
102 47b0ff10 2023-06-08 op /* serialize the IRI */
103 47b0ff10 2023-06-08 op strlcpy(b, c->iri.schema, sizeof(b));
104 47b0ff10 2023-06-08 op strlcat(b, "://", sizeof(b));
106 47b0ff10 2023-06-08 op /* log the decoded host name, but if it was invalid
107 47b0ff10 2023-06-08 op * use the raw one. */
108 47b0ff10 2023-06-08 op if (*c->domain != '\0')
109 47b0ff10 2023-06-08 op strlcat(b, c->domain, sizeof(b));
111 47b0ff10 2023-06-08 op strlcat(b, c->iri.host, sizeof(b));
113 47b0ff10 2023-06-08 op if (*c->iri.path != '/')
114 47b0ff10 2023-06-08 op strlcat(b, "/", sizeof(b));
115 47b0ff10 2023-06-08 op strlcat(b, c->iri.path, sizeof(b)); /* TODO: sanitize UTF8 */
116 47b0ff10 2023-06-08 op if (*c->iri.query != '\0') { /* TODO: sanitize UTF8 */
117 47b0ff10 2023-06-08 op strlcat(b, "?", sizeof(b));
118 47b0ff10 2023-06-08 op strlcat(b, c->iri.query, sizeof(b));
121 47b0ff10 2023-06-08 op if ((t = c->req) == NULL)
123 47b0ff10 2023-06-08 op strlcpy(b, t, sizeof(b));
126 47b0ff10 2023-06-08 op if ((t = memchr(meta, '\r', l)) == NULL)
127 47b0ff10 2023-06-08 op t = meta + len;
129 47b0ff10 2023-06-08 op ec = asprintf(&fmted, "%s:%s GET %s %.*s", hbuf, sbuf, b,
130 47b0ff10 2023-06-08 op (int)(t-meta), meta);
131 47b0ff10 2023-06-08 op if (ec == -1)
132 47b0ff10 2023-06-08 op err(1, "asprintf");
134 47b0ff10 2023-06-08 op proc_compose(conf.ps, PROC_LOGGER, IMSG_LOG_REQUEST,
135 47b0ff10 2023-06-08 op fmted, ec + 1);
141 419a4235 2021-04-28 op write_pidfile(const char *pidfile)
143 419a4235 2021-04-28 op struct flock lock;
146 419a4235 2021-04-28 op if (pidfile == NULL)
149 419a4235 2021-04-28 op if ((fd = open(pidfile, O_WRONLY|O_CREAT|O_CLOEXEC, 0600)) == -1)
150 df5058c9 2023-06-05 op fatal("can't open pidfile %s", pidfile);
152 419a4235 2021-04-28 op lock.l_start = 0;
153 419a4235 2021-04-28 op lock.l_len = 0;
154 419a4235 2021-04-28 op lock.l_type = F_WRLCK;
155 419a4235 2021-04-28 op lock.l_whence = SEEK_SET;
157 419a4235 2021-04-28 op if (fcntl(fd, F_SETLK, &lock) == -1)
158 df5058c9 2023-06-05 op fatalx("can't lock %s, gmid is already running?", pidfile);
160 419a4235 2021-04-28 op if (ftruncate(fd, 0) == -1)
161 df5058c9 2023-06-05 op fatal("ftruncate %s", pidfile);
163 419a4235 2021-04-28 op dprintf(fd, "%d\n", getpid());
169 8d6ae384 2021-01-24 op main(int argc, char **argv)
171 c26f2460 2023-06-08 op struct privsep *ps;
172 c26f2460 2023-06-08 op const char *errstr, *title = NULL;
174 c26f2460 2023-06-08 op int ch, conftest = 0;
175 c26f2460 2023-06-08 op int proc_instance = 0;
176 c26f2460 2023-06-08 op int proc_id = PROC_PARENT;
177 c26f2460 2023-06-08 op int argc0 = argc;
179 0046c1fe 2023-06-06 op setlocale(LC_CTYPE, "");
181 eae52ad4 2023-06-06 op /* log to stderr until daemonized */
182 eae52ad4 2023-06-06 op log_init(1, LOG_DAEMON);
183 c68baad2 2023-06-06 op config_init();
185 5777923b 2021-06-29 op while ((ch = getopt_long(argc, argv, opts, longopts, NULL)) != -1) {
186 3e4749f7 2020-10-02 op switch (ch) {
188 0ac785a6 2023-06-05 op config_path = absolutify_path(optarg);
191 f98e9045 2021-06-29 op if (cmdline_symset(optarg) == -1)
192 df5058c9 2023-06-05 op fatalx("could not parse macro definition: %s",
202 c26f2460 2023-06-08 op proc_instance = strtonum(optarg, 0, PROC_MAX_INSTANCES,
204 c26f2460 2023-06-08 op if (errstr != NULL)
205 c26f2460 2023-06-08 op fatalx("invalid process instance");
211 f1f13cb7 2023-06-08 op pidfile = absolutify_path(optarg);
214 c26f2460 2023-06-08 op title = optarg;
215 c26f2460 2023-06-08 op proc_id = proc_getid(procs, nitems(procs), title);
216 c26f2460 2023-06-08 op if (proc_id == PROC_MAX)
217 c26f2460 2023-06-08 op fatalx("invalid process name");
220 fdb43a4c 2021-06-29 op puts("Version: " GMID_STRING);
231 c26f2460 2023-06-08 op if (argc - optind != 0)
234 32fbc478 2022-09-08 op parse_conf(config_path);
235 c26f2460 2023-06-08 op if (*conf.chroot != '\0' && *conf.user == '\0')
236 c26f2460 2023-06-08 op fatalx("can't chroot without a user to switch to after.");
238 132cae8c 2021-01-18 op if (conftest) {
239 f0a01fc7 2021-10-09 op fprintf(stderr, "config OK\n");
240 f0a01fc7 2021-10-09 op if (conftest > 1)
241 f0a01fc7 2021-10-09 op print_conf();
245 c26f2460 2023-06-08 op if ((ps = calloc(1, sizeof(*ps))) == NULL)
246 c26f2460 2023-06-08 op fatal("calloc");
247 c26f2460 2023-06-08 op ps->ps_env = &conf;
248 c26f2460 2023-06-08 op conf.ps = ps;
249 c26f2460 2023-06-08 op if (*conf.user) {
250 c26f2460 2023-06-08 op if (geteuid())
251 c26f2460 2023-06-08 op fatalx("need root privileges");
252 c26f2460 2023-06-08 op if ((ps->ps_pw = getpwnam(conf.user)) == NULL)
253 c26f2460 2023-06-08 op fatalx("unknown user %s", conf.user);
256 c26f2460 2023-06-08 op ps->ps_instances[PROC_SERVER] = conf.prefork;
257 c26f2460 2023-06-08 op ps->ps_instance = proc_instance;
258 c26f2460 2023-06-08 op if (title != NULL)
259 c26f2460 2023-06-08 op ps->ps_title[proc_id] = title;
261 c26f2460 2023-06-08 op if (*conf.chroot != '\0') {
262 c26f2460 2023-06-08 op for (i = 0; i < nitems(procs); ++i)
263 c26f2460 2023-06-08 op procs[i].p_chroot = conf.chroot;
266 ca84625a 2023-06-08 op log_init(debug, LOG_DAEMON);
267 ca84625a 2023-06-08 op log_setverbose(verbose);
268 c26f2460 2023-06-08 op if (title != NULL)
269 c26f2460 2023-06-08 op log_procinit(title);
271 c26f2460 2023-06-08 op /* only the parent returns */
272 ca84625a 2023-06-08 op proc_init(ps, procs, nitems(procs), debug, argc0, argv, proc_id);
274 c26f2460 2023-06-08 op log_procinit("main");
275 ca84625a 2023-06-08 op if (!debug && daemon(0, 0) == -1)
276 c26f2460 2023-06-08 op fatal("daemon");
278 8e8b2e25 2021-04-28 op pidfd = write_pidfile(pidfile);
280 c26f2460 2023-06-08 op sandbox_main_process();
282 c26f2460 2023-06-08 op event_init();
284 c26f2460 2023-06-08 op signal(SIGPIPE, SIG_IGN);
286 c26f2460 2023-06-08 op signal_set(&ps->ps_evsigint, SIGINT, main_sig_handler, ps);
287 c26f2460 2023-06-08 op signal_set(&ps->ps_evsigterm, SIGTERM, main_sig_handler, ps);
288 c26f2460 2023-06-08 op signal_set(&ps->ps_evsigchld, SIGCHLD, main_sig_handler, ps);
289 c26f2460 2023-06-08 op signal_set(&ps->ps_evsighup, SIGHUP, main_sig_handler, ps);
291 c26f2460 2023-06-08 op signal_add(&ps->ps_evsigint, NULL);
292 c26f2460 2023-06-08 op signal_add(&ps->ps_evsigterm, NULL);
293 c26f2460 2023-06-08 op signal_add(&ps->ps_evsigchld, NULL);
294 c26f2460 2023-06-08 op signal_add(&ps->ps_evsighup, NULL);
296 c26f2460 2023-06-08 op proc_connect(ps);
298 c26f2460 2023-06-08 op if (main_configure(&conf) == -1)
299 c26f2460 2023-06-08 op fatal("configuration failed");
301 c26f2460 2023-06-08 op event_dispatch();
302 c26f2460 2023-06-08 op main_shutdown(&conf);
303 c26f2460 2023-06-08 op /* NOTREACHED */
308 c26f2460 2023-06-08 op main_configure(struct conf *conf)
310 c26f2460 2023-06-08 op struct privsep *ps = conf->ps;
312 c26f2460 2023-06-08 op conf->reload = conf->prefork;
314 c26f2460 2023-06-08 op if (proc_compose(ps, PROC_SERVER, IMSG_RECONF_START, NULL, 0) == -1)
317 5d22294a 2023-06-09 op if (config_send(conf, &hosts) == -1)
320 c26f2460 2023-06-08 op if (proc_compose(ps, PROC_SERVER, IMSG_RECONF_END, NULL, 0) == -1)
327 c26f2460 2023-06-08 op main_configure_done(struct conf *conf)
329 c26f2460 2023-06-08 op if (conf->reload == 0) {
330 c26f2460 2023-06-08 op log_warnx("configuration already done");
334 c26f2460 2023-06-08 op conf->reload--;
335 c26f2460 2023-06-08 op /* send IMSG_CTL_START? */
339 c26f2460 2023-06-08 op main_reload(struct conf *conf)
341 c26f2460 2023-06-08 op if (conf->reload) {
342 c26f2460 2023-06-08 op log_debug("%s: already in progress: %d pending",
343 c26f2460 2023-06-08 op __func__, conf->reload);
347 c26f2460 2023-06-08 op log_debug("%s: config file %s", __func__, config_path);
348 c26f2460 2023-06-08 op config_free();
349 c26f2460 2023-06-08 op parse_conf(config_path); /* XXX should handle error here */
351 c26f2460 2023-06-08 op main_configure(conf);
355 c26f2460 2023-06-08 op main_sig_handler(int sig, short ev, void *arg)
357 c26f2460 2023-06-08 op struct privsep *ps = arg;
360 c26f2460 2023-06-08 op * Normal signal handler rules don't apply here because libevent
361 c26f2460 2023-06-08 op * decouples for us.
364 c26f2460 2023-06-08 op switch (sig) {
366 c26f2460 2023-06-08 op if (privsep_process != PROC_PARENT)
368 c26f2460 2023-06-08 op log_info("reload requested with SIGHUP");
369 c26f2460 2023-06-08 op main_reload(ps->ps_env);
371 c26f2460 2023-06-08 op case SIGCHLD:
372 c26f2460 2023-06-08 op log_warnx("one child died, quitting");
373 c26f2460 2023-06-08 op /* fallthrough */
374 c26f2460 2023-06-08 op case SIGTERM:
376 c26f2460 2023-06-08 op main_shutdown(ps->ps_env);
379 c26f2460 2023-06-08 op fatalx("unexpected signal %d", sig);
384 c26f2460 2023-06-08 op main_dispatch_server(int fd, struct privsep_proc *p, struct imsg *imsg)
386 c26f2460 2023-06-08 op struct privsep *ps = p->p_ps;
387 c26f2460 2023-06-08 op struct conf *conf = ps->ps_env;
389 c26f2460 2023-06-08 op switch (imsg->hdr.type) {
390 c26f2460 2023-06-08 op case IMSG_RECONF_DONE:
391 c26f2460 2023-06-08 op main_configure_done(conf);
401 c26f2460 2023-06-08 op main_dispatch_logger(int fd, struct privsep_proc *p, struct imsg *imsg)
403 c26f2460 2023-06-08 op struct privsep *ps = p->p_ps;
404 c26f2460 2023-06-08 op struct conf *conf = ps->ps_env;
406 c26f2460 2023-06-08 op switch (imsg->hdr.type) {
407 c26f2460 2023-06-08 op case IMSG_RECONF_DONE:
408 c26f2460 2023-06-08 op main_configure_done(conf);
417 c26f2460 2023-06-08 op static void __dead
418 c26f2460 2023-06-08 op main_shutdown(struct conf *conf)
420 c26f2460 2023-06-08 op proc_kill(conf->ps);
421 c26f2460 2023-06-08 op config_free();
422 c26f2460 2023-06-08 op free(conf->ps);
423 c26f2460 2023-06-08 op /* free(conf); */
425 c26f2460 2023-06-08 op log_info("parent terminating, pid %d", getpid());
427 8e8b2e25 2021-04-28 op if (pidfd != -1)
428 8e8b2e25 2021-04-28 op close(pidfd);