1 b0a6bcf7 2022-09-13 op /*
   2 b0a6bcf7 2022-09-13 op  * Copyright (c) 2022 Omar Polo <op@omarpolo.com>
   3 b0a6bcf7 2022-09-13 op  * Copyright (c) 2006 - 2015 Reyk Floeter <reyk@openbsd.org>
   4 b0a6bcf7 2022-09-13 op  *
   5 b0a6bcf7 2022-09-13 op  * Permission to use, copy, modify, and distribute this software for any
   6 b0a6bcf7 2022-09-13 op  * purpose with or without fee is hereby granted, provided that the above
   7 b0a6bcf7 2022-09-13 op  * copyright notice and this permission notice appear in all copies.
   8 b0a6bcf7 2022-09-13 op  *
   9 b0a6bcf7 2022-09-13 op  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
  10 b0a6bcf7 2022-09-13 op  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
  11 b0a6bcf7 2022-09-13 op  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
  12 b0a6bcf7 2022-09-13 op  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
  13 b0a6bcf7 2022-09-13 op  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
  14 b0a6bcf7 2022-09-13 op  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
  15 b0a6bcf7 2022-09-13 op  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
  16 b0a6bcf7 2022-09-13 op  */
  17 b0a6bcf7 2022-09-13 op 
  18 b0a6bcf7 2022-09-13 op #include <sys/types.h>
  19 b0a6bcf7 2022-09-13 op #include <sys/queue.h>
  20 b0a6bcf7 2022-09-13 op #include <sys/tree.h>
  21 b0a6bcf7 2022-09-13 op #include <sys/socket.h>
  22 b0a6bcf7 2022-09-13 op #include <sys/uio.h>
  23 b0a6bcf7 2022-09-13 op 
  24 b0a6bcf7 2022-09-13 op #include <netinet/in.h>
  25 b0a6bcf7 2022-09-13 op #include <arpa/inet.h>
  26 b0a6bcf7 2022-09-13 op #include <netdb.h>
  27 b0a6bcf7 2022-09-13 op 
  28 b0a6bcf7 2022-09-13 op #include <asr.h>
  29 b0a6bcf7 2022-09-13 op #include <ctype.h>
  30 b0a6bcf7 2022-09-13 op #include <errno.h>
  31 b0a6bcf7 2022-09-13 op #include <event.h>
  32 33f4bf26 2022-09-14 op #include <fnmatch.h>
  33 b0a6bcf7 2022-09-13 op #include <limits.h>
  34 b0a6bcf7 2022-09-13 op #include <stdlib.h>
  35 b0a6bcf7 2022-09-13 op #include <stdint.h>
  36 b0a6bcf7 2022-09-13 op #include <stdio.h>
  37 b0a6bcf7 2022-09-13 op #include <string.h>
  38 b0a6bcf7 2022-09-13 op #include <imsg.h>
  39 b0a6bcf7 2022-09-13 op #include <tls.h>
  40 b0a6bcf7 2022-09-13 op #include <unistd.h>
  41 b0a6bcf7 2022-09-13 op 
  42 83f0f95a 2022-09-29 op #include "config.h"
  43 b0a6bcf7 2022-09-13 op #include "log.h"
  44 b0a6bcf7 2022-09-13 op #include "proc.h"
  45 bff58270 2022-09-19 op #include "tmpl.h"
  46 b0a6bcf7 2022-09-13 op 
  47 b0a6bcf7 2022-09-13 op #include "galileo.h"
  48 b0a6bcf7 2022-09-13 op 
  49 b0a6bcf7 2022-09-13 op #define MINIMUM(a, b)	((a) < (b) ? (a) : (b))
  50 83f0f95a 2022-09-29 op 
  51 83f0f95a 2022-09-29 op #if HAVE_LIBEVENT2
  52 83f0f95a 2022-09-29 op # define G_TOUT(t)	((t).tv_sec)
  53 83f0f95a 2022-09-29 op #else
  54 83f0f95a 2022-09-29 op # define G_TOUT(t)	(t)
  55 83f0f95a 2022-09-29 op #endif
  56 b0a6bcf7 2022-09-13 op 
  57 b0a6bcf7 2022-09-13 op /* provided by OpenBSD' base libevent but not in any header? */
  58 b0a6bcf7 2022-09-13 op extern void	 bufferevent_read_pressure_cb(struct evbuffer *, size_t,
  59 b0a6bcf7 2022-09-13 op 		    size_t, void *);
  60 b0a6bcf7 2022-09-13 op 
  61 b0a6bcf7 2022-09-13 op void	proxy_init(struct privsep *, struct privsep_proc *, void *);
  62 b0a6bcf7 2022-09-13 op int	proxy_launch(struct galileo *);
  63 b0a6bcf7 2022-09-13 op void	proxy_inflight_dec(const char *);
  64 b0a6bcf7 2022-09-13 op int	proxy_dispatch_parent(int, struct privsep_proc *, struct imsg *);
  65 cb05cce7 2022-11-11 op int	proxy_resurl(struct client *, const char *, char *, size_t);
  66 c9dc4bc6 2022-09-13 op void	proxy_translate_gemtext(struct client *);
  67 b0a6bcf7 2022-09-13 op void	proxy_resolved(struct asr_result *, void *);
  68 b0a6bcf7 2022-09-13 op void	proxy_connect(int, short, void *);
  69 5163fbe9 2022-09-20 op int	proxy_start_reply(struct client *, int, const char *);
  70 b0a6bcf7 2022-09-13 op void	proxy_read(struct bufferevent *, void *);
  71 b0a6bcf7 2022-09-13 op void	proxy_write(struct bufferevent *, void *);
  72 b0a6bcf7 2022-09-13 op void	proxy_error(struct bufferevent *, short, void *);
  73 b0a6bcf7 2022-09-13 op int	proxy_bufferevent_add(struct event *, int);
  74 b0a6bcf7 2022-09-13 op void	proxy_tls_writecb(int, short, void *);
  75 b0a6bcf7 2022-09-13 op void	proxy_tls_readcb(int, short, void *);
  76 b0a6bcf7 2022-09-13 op 
  77 b0a6bcf7 2022-09-13 op static struct privsep_proc procs[] = {
  78 b0a6bcf7 2022-09-13 op 	{ "parent",	PROC_PARENT, proxy_dispatch_parent },
  79 b0a6bcf7 2022-09-13 op };
  80 b0a6bcf7 2022-09-13 op 
  81 b0a6bcf7 2022-09-13 op volatile int proxy_clients;
  82 b0a6bcf7 2022-09-13 op volatile int proxy_inflight;
  83 b0a6bcf7 2022-09-13 op uint32_t proxy_fcg_id;
  84 b0a6bcf7 2022-09-13 op 
  85 b0a6bcf7 2022-09-13 op void
  86 b0a6bcf7 2022-09-13 op proxy(struct privsep *ps, struct privsep_proc *p)
  87 b0a6bcf7 2022-09-13 op {
  88 b0a6bcf7 2022-09-13 op 	proc_run(ps, p, procs, nitems(procs), proxy_init, NULL);
  89 b0a6bcf7 2022-09-13 op }
  90 b0a6bcf7 2022-09-13 op 
  91 b0a6bcf7 2022-09-13 op void
  92 b0a6bcf7 2022-09-13 op proxy_init(struct privsep *ps, struct privsep_proc *p, void *arg)
  93 b0a6bcf7 2022-09-13 op {
  94 b0a6bcf7 2022-09-13 op 	if (config_init(ps->ps_env) == -1)
  95 b0a6bcf7 2022-09-13 op 		fatal("failed to initialize configuration");
  96 b0a6bcf7 2022-09-13 op 
  97 b0a6bcf7 2022-09-13 op 	/* We use a custom shutdown callback */
  98 b0a6bcf7 2022-09-13 op 	/* p->p_shutdown = proxy_shutdown */
  99 b0a6bcf7 2022-09-13 op 
 100 b0a6bcf7 2022-09-13 op 	if (pledge("stdio recvfd unix inet dns", NULL) == -1)
 101 b0a6bcf7 2022-09-13 op 		fatal("pledge");
 102 b0a6bcf7 2022-09-13 op }
 103 b0a6bcf7 2022-09-13 op 
 104 b0a6bcf7 2022-09-13 op int
 105 b0a6bcf7 2022-09-13 op proxy_launch(struct galileo *env)
 106 b0a6bcf7 2022-09-13 op {
 107 b0a6bcf7 2022-09-13 op 	event_add(&env->sc_evsock, NULL);
 108 b0a6bcf7 2022-09-13 op 	return (0);
 109 b0a6bcf7 2022-09-13 op }
 110 b0a6bcf7 2022-09-13 op 
 111 b0a6bcf7 2022-09-13 op void
 112 40f762b2 2022-09-23 op proxy_purge(struct proxy *pr)
 113 b0a6bcf7 2022-09-13 op {
 114 40f762b2 2022-09-23 op 	free(pr);
 115 b0a6bcf7 2022-09-13 op }
 116 b0a6bcf7 2022-09-13 op 
 117 b0a6bcf7 2022-09-13 op void
 118 b0a6bcf7 2022-09-13 op proxy_inflight_dec(const char *why)
 119 b0a6bcf7 2022-09-13 op {
 120 b0a6bcf7 2022-09-13 op 	proxy_inflight--;
 121 b0a6bcf7 2022-09-13 op 	log_debug("%s: inflight decremented, now %d, %s",
 122 b0a6bcf7 2022-09-13 op 	    __func__, proxy_inflight, why);
 123 b0a6bcf7 2022-09-13 op }
 124 b0a6bcf7 2022-09-13 op 
 125 b0a6bcf7 2022-09-13 op int
 126 b0a6bcf7 2022-09-13 op proxy_dispatch_parent(int fd, struct privsep_proc *p, struct imsg *imsg)
 127 b0a6bcf7 2022-09-13 op {
 128 b0a6bcf7 2022-09-13 op 	struct privsep	*ps = p->p_ps;
 129 b0a6bcf7 2022-09-13 op 	struct galileo	*env = ps->ps_env;
 130 b0a6bcf7 2022-09-13 op 
 131 b0a6bcf7 2022-09-13 op 	switch (imsg->hdr.type) {
 132 b0a6bcf7 2022-09-13 op 	case IMSG_CFG_SRV:
 133 afb86b2c 2022-09-23 op 		if (config_getproxy(env, imsg) == -1)
 134 b0a6bcf7 2022-09-13 op 			fatal("config_getproxy");
 135 b0a6bcf7 2022-09-13 op 		break;
 136 b0a6bcf7 2022-09-13 op 	case IMSG_CFG_SOCK:
 137 b0a6bcf7 2022-09-13 op 		/* XXX: improve */
 138 b0a6bcf7 2022-09-13 op 
 139 b0a6bcf7 2022-09-13 op 		env->sc_sock_fd = config_getsock(env, imsg);
 140 b0a6bcf7 2022-09-13 op 		if (env->sc_sock_fd == -1)
 141 b0a6bcf7 2022-09-13 op 			fatal("config_getsock");
 142 b0a6bcf7 2022-09-13 op 
 143 b0a6bcf7 2022-09-13 op 		event_set(&env->sc_evsock, env->sc_sock_fd,
 144 ea8874f1 2022-09-13 op 		    EV_READ | EV_PERSIST, fcgi_accept, env);
 145 ea8874f1 2022-09-13 op 		evtimer_set(&env->sc_evpause, fcgi_accept, env);
 146 b0a6bcf7 2022-09-13 op 		break;
 147 b0a6bcf7 2022-09-13 op 	case IMSG_CFG_DONE:
 148 40f762b2 2022-09-23 op 		config_getcfg(env, imsg);
 149 40f762b2 2022-09-23 op 		proxy_launch(env);
 150 b0a6bcf7 2022-09-13 op 		break;
 151 b0a6bcf7 2022-09-13 op 	case IMSG_CTL_START:
 152 b0a6bcf7 2022-09-13 op 		break;
 153 40f762b2 2022-09-23 op 	case IMSG_CTL_RESET:
 154 40f762b2 2022-09-23 op 		config_getreset(env, imsg);
 155 40f762b2 2022-09-23 op 		break;
 156 b0a6bcf7 2022-09-13 op 	default:
 157 b0a6bcf7 2022-09-13 op 		return (-1);
 158 c9dc4bc6 2022-09-13 op 	}
 159 c9dc4bc6 2022-09-13 op 
 160 c9dc4bc6 2022-09-13 op 	return (0);
 161 c9dc4bc6 2022-09-13 op }
 162 c9dc4bc6 2022-09-13 op 
 163 c9dc4bc6 2022-09-13 op static int
 164 cb05cce7 2022-11-11 op portok(const char **url, struct client *clt)
 165 cb05cce7 2022-11-11 op {
 166 cb05cce7 2022-11-11 op 	const char		*u = *url;
 167 cb05cce7 2022-11-11 op 	const char		*port = clt->clt_pc->proxy_port;
 168 cb05cce7 2022-11-11 op 	size_t			 len;
 169 cb05cce7 2022-11-11 op 
 170 cb05cce7 2022-11-11 op 	len = strlen(port);
 171 cb05cce7 2022-11-11 op 
 172 cb05cce7 2022-11-11 op 	if (*u == '\0' || *u == '/' || *u == '?' || *u == '#')
 173 cb05cce7 2022-11-11 op 		return (1);
 174 cb05cce7 2022-11-11 op 	if (*u != ':')
 175 cb05cce7 2022-11-11 op 		return (0);
 176 cb05cce7 2022-11-11 op 	u++;
 177 cb05cce7 2022-11-11 op 	if (strncmp(u, port, len) != 0)
 178 cb05cce7 2022-11-11 op 		return (0);
 179 cb05cce7 2022-11-11 op 	u += len;
 180 cb05cce7 2022-11-11 op 	if (*u != '\0' && *u != '/' && *u != '?' && *u != '#')
 181 cb05cce7 2022-11-11 op 		return (0);
 182 cb05cce7 2022-11-11 op 	*url = u;
 183 cb05cce7 2022-11-11 op 	return (1);
 184 cb05cce7 2022-11-11 op }
 185 cb05cce7 2022-11-11 op 
 186 cb05cce7 2022-11-11 op int
 187 cb05cce7 2022-11-11 op proxy_resurl(struct client *clt, const char *url, char *buf, size_t len)
 188 cb05cce7 2022-11-11 op {
 189 cb05cce7 2022-11-11 op 	const char		*tmp;
 190 cb05cce7 2022-11-11 op 	size_t			 l;
 191 cb05cce7 2022-11-11 op 
 192 cb05cce7 2022-11-11 op 	l = strlen(clt->clt_server_name);
 193 cb05cce7 2022-11-11 op 
 194 cb05cce7 2022-11-11 op 	if (len == 0) {
 195 cb05cce7 2022-11-11 op 		log_warn("%s: zero-sized buffer!", __func__);
 196 cb05cce7 2022-11-11 op 		return (-1);
 197 cb05cce7 2022-11-11 op 	}
 198 cb05cce7 2022-11-11 op 
 199 cb05cce7 2022-11-11 op 	/* look if it's an absolute URI */
 200 cb05cce7 2022-11-11 op 	if (strncmp(url, "//", 2) == 0) {
 201 cb05cce7 2022-11-11 op 		tmp = url + 2;
 202 cb05cce7 2022-11-11 op 		if (strncmp(tmp, clt->clt_server_name, l) != 0)
 203 cb05cce7 2022-11-11 op 			goto done;
 204 cb05cce7 2022-11-11 op 
 205 cb05cce7 2022-11-11 op 		tmp += l;
 206 cb05cce7 2022-11-11 op 		if (!portok(&tmp, clt))
 207 cb05cce7 2022-11-11 op 			goto done;
 208 cb05cce7 2022-11-11 op 		url = tmp;
 209 cb05cce7 2022-11-11 op 	} else if (strncmp(url, "gemini://", 9) == 0) {
 210 cb05cce7 2022-11-11 op 		tmp = url + 9;
 211 cb05cce7 2022-11-11 op 		if (strncmp(tmp, clt->clt_server_name, l) != 0)
 212 cb05cce7 2022-11-11 op 			goto done;
 213 cb05cce7 2022-11-11 op 
 214 cb05cce7 2022-11-11 op 		tmp += l;
 215 cb05cce7 2022-11-11 op 		if (!portok(&tmp, clt))
 216 cb05cce7 2022-11-11 op 			goto done;
 217 cb05cce7 2022-11-11 op 		url = tmp;
 218 cb05cce7 2022-11-11 op 	} else {
 219 cb05cce7 2022-11-11 op 		tmp = url;
 220 cb05cce7 2022-11-11 op 		while (isalpha((unsigned char)*tmp) || *tmp == '+')
 221 cb05cce7 2022-11-11 op 			tmp++;
 222 cb05cce7 2022-11-11 op 		if (strncmp(tmp, "://", 3) == 0)
 223 cb05cce7 2022-11-11 op 			goto done;
 224 cb05cce7 2022-11-11 op 	}
 225 cb05cce7 2022-11-11 op 
 226 cb05cce7 2022-11-11 op 	/* maybe it's an absolute path? */
 227 cb05cce7 2022-11-11 op 	if (*url == '\0' || *url == '/') {
 228 cb05cce7 2022-11-11 op 		if (strlcpy(buf, clt->clt_script_name, len) >= len)
 229 cb05cce7 2022-11-11 op 			return (-1);
 230 cb05cce7 2022-11-11 op 		if (strlcat(buf, url + 1, len) >= len)
 231 cb05cce7 2022-11-11 op 			return (-1);
 232 cb05cce7 2022-11-11 op 		return (0);
 233 cb05cce7 2022-11-11 op 	}
 234 cb05cce7 2022-11-11 op 
 235 cb05cce7 2022-11-11 op 	/* otherwise, leave it as it is */
 236 cb05cce7 2022-11-11 op  done:
 237 cb05cce7 2022-11-11 op 	if (strlcpy(buf, url, len) >= len)
 238 cb05cce7 2022-11-11 op 		return (-1);
 239 cb05cce7 2022-11-11 op 	return (0);
 240 cb05cce7 2022-11-11 op }
 241 cb05cce7 2022-11-11 op 
 242 cb05cce7 2022-11-11 op static int
 243 c9dc4bc6 2022-09-13 op gemtext_translate_line(struct client *clt, char *line)
 244 c9dc4bc6 2022-09-13 op {
 245 cb05cce7 2022-11-11 op 	char		 buf[1025];
 246 cb05cce7 2022-11-11 op 	char		*url;
 247 cb05cce7 2022-11-11 op 
 248 c9dc4bc6 2022-09-13 op 	/* preformatted line / closing */
 249 b9de0a74 2022-09-14 op 	if (clt->clt_translate & TR_PRE) {
 250 c9dc4bc6 2022-09-13 op 		if (!strncmp(line, "```", 3)) {
 251 b9de0a74 2022-09-14 op 			clt->clt_translate &= ~TR_PRE;
 252 ceb3f79c 2022-09-29 op 			return (tp_pre_close(clt->clt_tp));
 253 c9dc4bc6 2022-09-13 op 		}
 254 c9dc4bc6 2022-09-13 op 
 255 df2db214 2022-09-19 op 		if (tp_htmlescape(clt->clt_tp, line) == -1)
 256 c9dc4bc6 2022-09-13 op 			return (-1);
 257 c9dc4bc6 2022-09-13 op 		return (clt_putc(clt, '\n'));
 258 b9de0a74 2022-09-14 op 	}
 259 b9de0a74 2022-09-14 op 
 260 b9de0a74 2022-09-14 op 	/* bullet */
 261 b9de0a74 2022-09-14 op 	if (!strncmp(line, "* ", 2)) {
 262 b9de0a74 2022-09-14 op 		if (clt->clt_translate & TR_NAV) {
 263 b9de0a74 2022-09-14 op 			if (clt_puts(clt, "</ul></nav>") == -1)
 264 b9de0a74 2022-09-14 op 				return (-1);
 265 b9de0a74 2022-09-14 op 			clt->clt_translate &= ~TR_NAV;
 266 b9de0a74 2022-09-14 op 		}
 267 b9de0a74 2022-09-14 op 
 268 b9de0a74 2022-09-14 op 		if (!(clt->clt_translate & TR_LIST)) {
 269 b9de0a74 2022-09-14 op 			if (clt_puts(clt, "<ul>") == -1)
 270 b9de0a74 2022-09-14 op 				return (-1);
 271 b9de0a74 2022-09-14 op 			clt->clt_translate |= TR_LIST;
 272 b9de0a74 2022-09-14 op 		}
 273 b9de0a74 2022-09-14 op 
 274 b9de0a74 2022-09-14 op 		if (clt_puts(clt, "<li>") == -1 ||
 275 df2db214 2022-09-19 op 		    tp_htmlescape(clt->clt_tp, line + 2) == -1 ||
 276 b9de0a74 2022-09-14 op 		    clt_puts(clt, "</li>") == -1)
 277 b9de0a74 2022-09-14 op 			return (-1);
 278 b9de0a74 2022-09-14 op 		return (0);
 279 b9de0a74 2022-09-14 op 	}
 280 b9de0a74 2022-09-14 op 
 281 b9de0a74 2022-09-14 op 	if (clt->clt_translate & TR_LIST) {
 282 b9de0a74 2022-09-14 op 		if (clt_puts(clt, "</ul>") == -1)
 283 b9de0a74 2022-09-14 op 			return (-1);
 284 b9de0a74 2022-09-14 op 		clt->clt_translate &= ~TR_LIST;
 285 b9de0a74 2022-09-14 op 	}
 286 b9de0a74 2022-09-14 op 
 287 cb05cce7 2022-11-11 op 	/* link */
 288 b9de0a74 2022-09-14 op 	if (!strncmp(line, "=>", 2)) {
 289 b9de0a74 2022-09-14 op 		char *label;
 290 b9de0a74 2022-09-14 op 
 291 b9de0a74 2022-09-14 op 		line += 2;
 292 b9de0a74 2022-09-14 op 		line += strspn(line, " \t");
 293 b9de0a74 2022-09-14 op 
 294 b9de0a74 2022-09-14 op 		label = line + strcspn(line, " \t");
 295 b9de0a74 2022-09-14 op 		if (*label == '\0')
 296 b9de0a74 2022-09-14 op 			label = line;
 297 cd396568 2022-11-11 op 		else {
 298 b9de0a74 2022-09-14 op 			*label++ = '\0';
 299 cd396568 2022-11-11 op 			label += strspn(label, " \t");
 300 cd396568 2022-11-11 op 			if (*label == '\0')
 301 cd396568 2022-11-11 op 				label = line;
 302 cd396568 2022-11-11 op 		}
 303 b9de0a74 2022-09-14 op 
 304 cb05cce7 2022-11-11 op 		if (proxy_resurl(clt, line, buf, sizeof(buf)) == 0)
 305 cb05cce7 2022-11-11 op 			url = buf;
 306 cb05cce7 2022-11-11 op 		else
 307 cb05cce7 2022-11-11 op 			url = line; /* leave the URL as it is */
 308 cb05cce7 2022-11-11 op 
 309 cb05cce7 2022-11-11 op 		if (fnmatch("*.jpg", url, 0) == 0 ||
 310 cb05cce7 2022-11-11 op 		    fnmatch("*.jpeg", url, 0) == 0 ||
 311 cb05cce7 2022-11-11 op 		    fnmatch("*.gif", url, 0) == 0 ||
 312 cb05cce7 2022-11-11 op 		    fnmatch("*.png", url, 0) == 0 ||
 313 cb05cce7 2022-11-11 op 		    fnmatch("*.svg", url, 0) == 0 ||
 314 cb05cce7 2022-11-11 op 		    fnmatch("*.webp", url, 0) == 0) {
 315 33f4bf26 2022-09-14 op 			if (clt->clt_translate & TR_NAV) {
 316 33f4bf26 2022-09-14 op 				if (clt_puts(clt, "</ul></nav>") == -1)
 317 33f4bf26 2022-09-14 op 					return (-1);
 318 33f4bf26 2022-09-14 op 				clt->clt_translate &= ~TR_NAV;
 319 33f4bf26 2022-09-14 op 			}
 320 33f4bf26 2022-09-14 op 
 321 cb05cce7 2022-11-11 op 			if (tp_figure(clt->clt_tp, url, label) == -1)
 322 33f4bf26 2022-09-14 op 				return (-1);
 323 33f4bf26 2022-09-14 op 
 324 33f4bf26 2022-09-14 op 			return (0);
 325 33f4bf26 2022-09-14 op 		}
 326 33f4bf26 2022-09-14 op 
 327 33f4bf26 2022-09-14 op 		if (!(clt->clt_translate & TR_NAV)) {
 328 33f4bf26 2022-09-14 op 			if (clt_puts(clt, "<nav><ul>") == -1)
 329 33f4bf26 2022-09-14 op 				return (-1);
 330 33f4bf26 2022-09-14 op 			clt->clt_translate |= TR_NAV;
 331 33f4bf26 2022-09-14 op 		}
 332 33f4bf26 2022-09-14 op 
 333 acc266fe 2022-09-19 op 		if (clt_puts(clt, "<li><a href='") == -1)
 334 acc266fe 2022-09-19 op 			return (-1);
 335 acc266fe 2022-09-19 op 
 336 cb05cce7 2022-11-11 op 		if (tp_urlescape(clt->clt_tp, url) == -1 ||
 337 b9de0a74 2022-09-14 op 		    clt_puts(clt, "'>") == -1 ||
 338 df2db214 2022-09-19 op 		    tp_htmlescape(clt->clt_tp, label) == -1 ||
 339 b9de0a74 2022-09-14 op 		    clt_puts(clt, "</a></li>") == -1)
 340 b9de0a74 2022-09-14 op 			return (-1);
 341 b9de0a74 2022-09-14 op 
 342 b9de0a74 2022-09-14 op 		return (0);
 343 c9dc4bc6 2022-09-13 op 	}
 344 c9dc4bc6 2022-09-13 op 
 345 b9de0a74 2022-09-14 op 	if (clt->clt_translate & TR_NAV) {
 346 b9de0a74 2022-09-14 op 		if (clt_puts(clt, "</ul></nav>") == -1)
 347 b9de0a74 2022-09-14 op 			return (-1);
 348 b9de0a74 2022-09-14 op 		clt->clt_translate &= ~TR_NAV;
 349 b9de0a74 2022-09-14 op 	}
 350 b9de0a74 2022-09-14 op 
 351 c9dc4bc6 2022-09-13 op 	/* pre opening */
 352 c9dc4bc6 2022-09-13 op 	if (!strncmp(line, "```", 3)) {
 353 ceb3f79c 2022-09-29 op 		line += 3;
 354 ceb3f79c 2022-09-29 op 		line += strspn(line, " \t");
 355 ceb3f79c 2022-09-29 op 
 356 b9de0a74 2022-09-14 op 		clt->clt_translate |= TR_PRE;
 357 ceb3f79c 2022-09-29 op 		return (tp_pre_open(clt->clt_tp, line));
 358 c9dc4bc6 2022-09-13 op 	}
 359 c9dc4bc6 2022-09-13 op 
 360 c9dc4bc6 2022-09-13 op 	/* citation block */
 361 c9dc4bc6 2022-09-13 op 	if (*line == '>') {
 362 c9dc4bc6 2022-09-13 op 		if (clt_puts(clt, "<blockquote>") == -1 ||
 363 df2db214 2022-09-19 op 		    tp_htmlescape(clt->clt_tp, line + 1) == -1 ||
 364 c9dc4bc6 2022-09-13 op 		    clt_puts(clt, "</blockquote>") == -1)
 365 c9dc4bc6 2022-09-13 op 			return (-1);
 366 c9dc4bc6 2022-09-13 op 		return (0);
 367 c9dc4bc6 2022-09-13 op 	}
 368 c9dc4bc6 2022-09-13 op 
 369 c9dc4bc6 2022-09-13 op 	/* headings */
 370 c9dc4bc6 2022-09-13 op 	if (!strncmp(line, "###", 3)) {
 371 c9dc4bc6 2022-09-13 op 		if (clt_puts(clt, "<h3>") == -1 ||
 372 df2db214 2022-09-19 op 		    tp_htmlescape(clt->clt_tp, line + 3) == -1 ||
 373 c9dc4bc6 2022-09-13 op 		    clt_puts(clt, "</h3>") == -1)
 374 c9dc4bc6 2022-09-13 op 			return (-1);
 375 c9dc4bc6 2022-09-13 op 		return (0);
 376 c9dc4bc6 2022-09-13 op 	}
 377 c9dc4bc6 2022-09-13 op 	if (!strncmp(line, "##", 2)) {
 378 c9dc4bc6 2022-09-13 op 		if (clt_puts(clt, "<h2>") == -1 ||
 379 df2db214 2022-09-19 op 		    tp_htmlescape(clt->clt_tp, line + 2) == -1 ||
 380 c9dc4bc6 2022-09-13 op 		    clt_puts(clt, "</h2>") == -1)
 381 c9dc4bc6 2022-09-13 op 			return (-1);
 382 c9dc4bc6 2022-09-13 op 		return (0);
 383 b0a6bcf7 2022-09-13 op 	}
 384 c9dc4bc6 2022-09-13 op 	if (!strncmp(line, "#", 1)) {
 385 c9dc4bc6 2022-09-13 op 		if (clt_puts(clt, "<h1>") == -1 ||
 386 df2db214 2022-09-19 op 		    tp_htmlescape(clt->clt_tp, line + 1) == -1 ||
 387 c9dc4bc6 2022-09-13 op 		    clt_puts(clt, "</h1>") == -1)
 388 c9dc4bc6 2022-09-13 op 			return (-1);
 389 c9dc4bc6 2022-09-13 op 		return (0);
 390 c9dc4bc6 2022-09-13 op 	}
 391 df5279ca 2022-09-14 op 
 392 df5279ca 2022-09-14 op 	/* Not following strictly the gemini specification... */
 393 df5279ca 2022-09-14 op 	if (*line == '\0')
 394 df5279ca 2022-09-14 op 		return (0);
 395 b0a6bcf7 2022-09-13 op 
 396 c9dc4bc6 2022-09-13 op 	/* paragraph */
 397 c9dc4bc6 2022-09-13 op 	if (clt_puts(clt, "<p>") == -1 ||
 398 df2db214 2022-09-19 op 	    tp_htmlescape(clt->clt_tp, line) == -1 ||
 399 c9dc4bc6 2022-09-13 op 	    clt_puts(clt, "</p>") == -1)
 400 c9dc4bc6 2022-09-13 op 		return (-1);
 401 b9de0a74 2022-09-14 op 
 402 b0a6bcf7 2022-09-13 op 	return (0);
 403 b0a6bcf7 2022-09-13 op }
 404 b0a6bcf7 2022-09-13 op 
 405 c9dc4bc6 2022-09-13 op void
 406 c9dc4bc6 2022-09-13 op proxy_translate_gemtext(struct client *clt)
 407 c9dc4bc6 2022-09-13 op {
 408 c9dc4bc6 2022-09-13 op 	struct bufferevent	*bev = clt->clt_bev;
 409 c9dc4bc6 2022-09-13 op 	struct evbuffer		*src = EVBUFFER_INPUT(bev);
 410 c9dc4bc6 2022-09-13 op 	char			*line;
 411 c9dc4bc6 2022-09-13 op 	size_t			 len;
 412 c9dc4bc6 2022-09-13 op 	int			 r;
 413 c9dc4bc6 2022-09-13 op 
 414 c9dc4bc6 2022-09-13 op 	for (;;) {
 415 b9de0a74 2022-09-14 op 		line = evbuffer_readln(src, &len, EVBUFFER_EOL_CRLF);
 416 c9dc4bc6 2022-09-13 op 		if (line == NULL)
 417 c9dc4bc6 2022-09-13 op 			return;
 418 c9dc4bc6 2022-09-13 op 
 419 c9dc4bc6 2022-09-13 op 		r = gemtext_translate_line(clt, line);
 420 c9dc4bc6 2022-09-13 op 		free(line);
 421 c9dc4bc6 2022-09-13 op 		if (r == -1)
 422 c9dc4bc6 2022-09-13 op 			return;
 423 c9dc4bc6 2022-09-13 op 	}
 424 c9dc4bc6 2022-09-13 op }
 425 c9dc4bc6 2022-09-13 op 
 426 f774ad1e 2022-09-23 op struct proxy_config *
 427 f774ad1e 2022-09-23 op proxy_match(struct galileo *env, const char *name)
 428 b0a6bcf7 2022-09-13 op {
 429 afb86b2c 2022-09-23 op 	struct proxy		*pr;
 430 b0a6bcf7 2022-09-13 op 
 431 f774ad1e 2022-09-23 op 	if (name == NULL)
 432 c9e6d547 2022-09-23 op 		return (NULL);
 433 b0a6bcf7 2022-09-13 op 
 434 afb86b2c 2022-09-23 op 	TAILQ_FOREACH(pr, &env->sc_proxies, pr_entry) {
 435 f774ad1e 2022-09-23 op 		if (!strcmp(name, pr->pr_conf.host))
 436 c9e6d547 2022-09-23 op 			return (&pr->pr_conf);
 437 b0a6bcf7 2022-09-13 op 	}
 438 b0a6bcf7 2022-09-13 op 
 439 c9e6d547 2022-09-23 op 	return (NULL);
 440 b0a6bcf7 2022-09-13 op }
 441 b0a6bcf7 2022-09-13 op 
 442 8857131d 2022-09-20 op int
 443 b0a6bcf7 2022-09-13 op proxy_start_request(struct galileo *env, struct client *clt)
 444 b0a6bcf7 2022-09-13 op {
 445 b0a6bcf7 2022-09-13 op 	struct addrinfo		 hints;
 446 b0a6bcf7 2022-09-13 op 	struct asr_query	*query;
 447 8857131d 2022-09-20 op 	int			 r;
 448 26cd3e9d 2022-09-23 op 	char			*url;
 449 b0a6bcf7 2022-09-13 op 
 450 f33634c5 2022-09-30 op 	if (clt->clt_path_info == NULL) {
 451 f33634c5 2022-09-30 op 		log_warnx("PATH_INFO not defined!");
 452 f33634c5 2022-09-30 op 		if (proxy_start_reply(clt, 501, "text/html") == -1)
 453 f33634c5 2022-09-30 op 			return (-1);
 454 056e82d3 2022-09-30 op 		if (tp_error(clt->clt_tp, -1, "internal server error") == -1)
 455 f33634c5 2022-09-30 op 			return (-1);
 456 f33634c5 2022-09-30 op 		return (fcgi_end_request(clt, 1));
 457 f33634c5 2022-09-30 op 	}
 458 f33634c5 2022-09-30 op 
 459 f774ad1e 2022-09-23 op 	if ((clt->clt_pc = proxy_match(env, clt->clt_server_name)) == NULL) {
 460 e3c1cbab 2022-09-20 op 		if (proxy_start_reply(clt, 501, "text/html") == -1)
 461 8857131d 2022-09-20 op 			return (-1);
 462 abe17781 2022-09-20 op 		if (tp_error(clt->clt_tp, -1, "unknown server") == -1)
 463 8857131d 2022-09-20 op 			return (-1);
 464 8857131d 2022-09-20 op 		return (fcgi_end_request(clt, 1));
 465 8857131d 2022-09-20 op 	}
 466 8857131d 2022-09-20 op 
 467 8857131d 2022-09-20 op 	if (clt->clt_bodylen != 0 && clt->clt_body == NULL) {
 468 8857131d 2022-09-20 op 		if (proxy_start_reply(clt, 400, "text/html") == -1)
 469 8857131d 2022-09-20 op 			return (-1);
 470 8857131d 2022-09-20 op 		if (tp_error(clt->clt_tp, -1, "bad request") == -1)
 471 8857131d 2022-09-20 op 			return (-1);
 472 8857131d 2022-09-20 op 		return (fcgi_end_request(clt, 1));
 473 b0a6bcf7 2022-09-13 op 	}
 474 b0a6bcf7 2022-09-13 op 
 475 8857131d 2022-09-20 op 	if (clt->clt_body) {
 476 8857131d 2022-09-20 op 		r = asprintf(&url, "%s%s?%s", clt->clt_script_name,
 477 8857131d 2022-09-20 op 		    clt->clt_path_info + 1, clt->clt_body);
 478 8857131d 2022-09-20 op 		if (r == -1)
 479 8857131d 2022-09-20 op 			return (fcgi_end_request(clt, 1));
 480 8857131d 2022-09-20 op 
 481 8857131d 2022-09-20 op 		if (proxy_start_reply(clt, 302, url) == -1 ||
 482 8857131d 2022-09-20 op 		    fcgi_end_request(clt, 1) == -1) {
 483 8857131d 2022-09-20 op 			free(url);
 484 8857131d 2022-09-20 op 			return (-1);
 485 8857131d 2022-09-20 op 		}
 486 8857131d 2022-09-20 op 		free(url);
 487 8857131d 2022-09-20 op 		return (0);
 488 8857131d 2022-09-20 op 	}
 489 8857131d 2022-09-20 op 
 490 b0a6bcf7 2022-09-13 op 	memset(&hints, 0, sizeof(hints));
 491 b0a6bcf7 2022-09-13 op 	hints.ai_family = AF_UNSPEC;
 492 b0a6bcf7 2022-09-13 op 	hints.ai_socktype = SOCK_STREAM;
 493 b0a6bcf7 2022-09-13 op 
 494 26cd3e9d 2022-09-23 op 	query = getaddrinfo_async(clt->clt_pc->proxy_addr,
 495 26cd3e9d 2022-09-23 op 	    clt->clt_pc->proxy_port, &hints, NULL);
 496 b0a6bcf7 2022-09-13 op 	if (query == NULL) {
 497 b0a6bcf7 2022-09-13 op 		log_warn("getaddrinfo_async");
 498 8857131d 2022-09-20 op 		return (fcgi_abort_request(clt));
 499 b0a6bcf7 2022-09-13 op 	}
 500 b0a6bcf7 2022-09-13 op 
 501 b0a6bcf7 2022-09-13 op 	clt->clt_evasr = event_asr_run(query, proxy_resolved, clt);
 502 b0a6bcf7 2022-09-13 op 	if (clt->clt_evasr == NULL) {
 503 b0a6bcf7 2022-09-13 op 		log_warn("event_asr_run");
 504 b0a6bcf7 2022-09-13 op 		asr_abort(query);
 505 8857131d 2022-09-20 op 		return (fcgi_abort_request(clt));
 506 b0a6bcf7 2022-09-13 op 	}
 507 8857131d 2022-09-20 op 
 508 8857131d 2022-09-20 op 	return (0);
 509 b0a6bcf7 2022-09-13 op }
 510 b0a6bcf7 2022-09-13 op 
 511 b0a6bcf7 2022-09-13 op void
 512 b0a6bcf7 2022-09-13 op proxy_resolved(struct asr_result *res, void *d)
 513 b0a6bcf7 2022-09-13 op {
 514 b0a6bcf7 2022-09-13 op 	struct client		*clt = d;
 515 b0a6bcf7 2022-09-13 op 	struct proxy_config	*pc = clt->clt_pc;
 516 b0a6bcf7 2022-09-13 op 
 517 b0a6bcf7 2022-09-13 op 	clt->clt_evasr = NULL;
 518 b0a6bcf7 2022-09-13 op 
 519 b0a6bcf7 2022-09-13 op 	if (res->ar_gai_errno != 0) {
 520 26cd3e9d 2022-09-23 op 		log_warnx("failed to resolve %s:%s: %s",
 521 b0a6bcf7 2022-09-13 op 		    pc->proxy_addr, pc->proxy_port,
 522 b0a6bcf7 2022-09-13 op 		    gai_strerror(res->ar_gai_errno));
 523 e3c1cbab 2022-09-20 op 		if (proxy_start_reply(clt, 501, "text/html") == -1)
 524 b0a6bcf7 2022-09-13 op 			return;
 525 abe17781 2022-09-20 op 		if (tp_error(clt->clt_tp, -1, "Can't resolve host") == -1)
 526 b0a6bcf7 2022-09-13 op 			return;
 527 b0a6bcf7 2022-09-13 op 		fcgi_end_request(clt, 1);
 528 b0a6bcf7 2022-09-13 op 		return;
 529 b0a6bcf7 2022-09-13 op 	}
 530 b0a6bcf7 2022-09-13 op 
 531 b0a6bcf7 2022-09-13 op 	clt->clt_addrinfo = res->ar_addrinfo;
 532 b0a6bcf7 2022-09-13 op 	clt->clt_p = clt->clt_addrinfo;
 533 b0a6bcf7 2022-09-13 op 	proxy_connect(-1, 0, clt);
 534 b0a6bcf7 2022-09-13 op }
 535 b0a6bcf7 2022-09-13 op 
 536 b0a6bcf7 2022-09-13 op void
 537 b0a6bcf7 2022-09-13 op proxy_connect(int fd, short ev, void *d)
 538 b0a6bcf7 2022-09-13 op {
 539 b0a6bcf7 2022-09-13 op 	struct client		*clt = d;
 540 b0a6bcf7 2022-09-13 op 	struct evbuffer		*out;
 541 b0a6bcf7 2022-09-13 op 	struct addrinfo		*p;
 542 b0a6bcf7 2022-09-13 op 	struct tls_config	*conf;
 543 b0a6bcf7 2022-09-13 op 	struct timeval		 conntv = {5, 0};
 544 b0a6bcf7 2022-09-13 op 	int			 err = 0;
 545 b0a6bcf7 2022-09-13 op 	socklen_t		 len = sizeof(err);
 546 b0a6bcf7 2022-09-13 op 
 547 b0a6bcf7 2022-09-13 op again:
 548 b0a6bcf7 2022-09-13 op 	if (clt->clt_p == NULL)
 549 b0a6bcf7 2022-09-13 op 		goto err;
 550 b0a6bcf7 2022-09-13 op 
 551 b0a6bcf7 2022-09-13 op 	if (clt->clt_fd != -1) {
 552 b0a6bcf7 2022-09-13 op 		if (getsockopt(clt->clt_fd, SOL_SOCKET, SO_ERROR, &err, &len)
 553 b0a6bcf7 2022-09-13 op 		    == -1)
 554 b0a6bcf7 2022-09-13 op 			goto err;
 555 b0a6bcf7 2022-09-13 op 		if (err != 0) {
 556 b0a6bcf7 2022-09-13 op 			errno = err;
 557 b0a6bcf7 2022-09-13 op 			goto err;
 558 b0a6bcf7 2022-09-13 op 		}
 559 b0a6bcf7 2022-09-13 op 		goto done;
 560 b0a6bcf7 2022-09-13 op 	}
 561 b0a6bcf7 2022-09-13 op 
 562 b0a6bcf7 2022-09-13 op 	p = clt->clt_p;
 563 b0a6bcf7 2022-09-13 op 	clt->clt_fd = socket(p->ai_family, p->ai_socktype | SOCK_NONBLOCK,
 564 b0a6bcf7 2022-09-13 op 	    p->ai_protocol);
 565 b0a6bcf7 2022-09-13 op 	if (clt->clt_fd == -1) {
 566 b0a6bcf7 2022-09-13 op 		clt->clt_p = clt->clt_p->ai_next;
 567 b0a6bcf7 2022-09-13 op 		goto again;
 568 b0a6bcf7 2022-09-13 op 	}
 569 b0a6bcf7 2022-09-13 op 
 570 b0a6bcf7 2022-09-13 op 	if (connect(clt->clt_fd, p->ai_addr, p->ai_addrlen) == 0)
 571 b0a6bcf7 2022-09-13 op 		goto done;
 572 b0a6bcf7 2022-09-13 op 
 573 b0a6bcf7 2022-09-13 op 	clt->clt_evconn_live = 1;
 574 b0a6bcf7 2022-09-13 op 	event_set(&clt->clt_evconn, clt->clt_fd, EV_WRITE, proxy_connect, clt);
 575 b0a6bcf7 2022-09-13 op 	event_add(&clt->clt_evconn, &conntv);
 576 b0a6bcf7 2022-09-13 op 	return;
 577 b0a6bcf7 2022-09-13 op 
 578 b0a6bcf7 2022-09-13 op done:
 579 b0a6bcf7 2022-09-13 op 	clt->clt_evconn_live = 0;
 580 b0a6bcf7 2022-09-13 op 	freeaddrinfo(clt->clt_addrinfo);
 581 b0a6bcf7 2022-09-13 op 	clt->clt_addrinfo = clt->clt_p = NULL;
 582 b0a6bcf7 2022-09-13 op 
 583 c743c9a1 2022-09-23 op 	clt->clt_bev = bufferevent_new(clt->clt_fd, proxy_read, proxy_write,
 584 c743c9a1 2022-09-23 op 	    proxy_error, clt);
 585 c743c9a1 2022-09-23 op 	if (clt->clt_bev == NULL) {
 586 c743c9a1 2022-09-23 op 		log_warn("bufferevent_new");
 587 b0a6bcf7 2022-09-13 op 		goto err;
 588 b0a6bcf7 2022-09-13 op 	}
 589 b0a6bcf7 2022-09-13 op 
 590 c743c9a1 2022-09-23 op 	if (!clt->clt_pc->no_tls) {
 591 c743c9a1 2022-09-23 op 		/* initialize TLS for Gemini */
 592 c743c9a1 2022-09-23 op 		if ((conf = tls_config_new()) == NULL) {
 593 c743c9a1 2022-09-23 op 			log_warn("tls_config_new failed");
 594 c743c9a1 2022-09-23 op 			goto err;
 595 c743c9a1 2022-09-23 op 		}
 596 b0a6bcf7 2022-09-13 op 
 597 c743c9a1 2022-09-23 op 		tls_config_insecure_noverifycert(conf);
 598 b0a6bcf7 2022-09-13 op 
 599 c743c9a1 2022-09-23 op 		if ((clt->clt_ctx = tls_client()) == NULL) {
 600 c743c9a1 2022-09-23 op 			log_warnx("tls_client failed");
 601 c743c9a1 2022-09-23 op 			tls_config_free(conf);
 602 c743c9a1 2022-09-23 op 			goto err;
 603 c743c9a1 2022-09-23 op 		}
 604 c743c9a1 2022-09-23 op 
 605 c743c9a1 2022-09-23 op 		if (tls_configure(clt->clt_ctx, conf) == -1) {
 606 c743c9a1 2022-09-23 op 			log_warnx("tls_configure failed");
 607 c743c9a1 2022-09-23 op 			tls_config_free(conf);
 608 c743c9a1 2022-09-23 op 			goto err;
 609 c743c9a1 2022-09-23 op 		}
 610 b0a6bcf7 2022-09-13 op 
 611 c743c9a1 2022-09-23 op 		tls_config_free(conf);
 612 b0a6bcf7 2022-09-13 op 
 613 c743c9a1 2022-09-23 op 		if (tls_connect_socket(clt->clt_ctx, clt->clt_fd,
 614 c743c9a1 2022-09-23 op 			clt->clt_pc->proxy_name) == -1) {
 615 c743c9a1 2022-09-23 op 			log_warnx("tls_connect_socket failed");
 616 c743c9a1 2022-09-23 op 			goto err;
 617 c743c9a1 2022-09-23 op 		}
 618 b0a6bcf7 2022-09-13 op 
 619 c743c9a1 2022-09-23 op 		event_set(&clt->clt_bev->ev_read, clt->clt_fd, EV_READ,
 620 c743c9a1 2022-09-23 op 		    proxy_tls_readcb, clt->clt_bev);
 621 c743c9a1 2022-09-23 op 		event_set(&clt->clt_bev->ev_write, clt->clt_fd, EV_WRITE,
 622 c743c9a1 2022-09-23 op 		    proxy_tls_writecb, clt->clt_bev);
 623 83f0f95a 2022-09-29 op 
 624 83f0f95a 2022-09-29 op #if HAVE_LIBEVENT2
 625 83f0f95a 2022-09-29 op 		evbuffer_unfreeze(clt->clt_bev->input, 0);
 626 83f0f95a 2022-09-29 op 		evbuffer_unfreeze(clt->clt_bev->output, 1);
 627 83f0f95a 2022-09-29 op #endif
 628 c743c9a1 2022-09-23 op 	}
 629 b0a6bcf7 2022-09-13 op 
 630 b0a6bcf7 2022-09-13 op 	/* bufferevent_settimeout(); */
 631 b0a6bcf7 2022-09-13 op 	bufferevent_enable(clt->clt_bev, EV_READ|EV_WRITE);
 632 b0a6bcf7 2022-09-13 op 
 633 b0a6bcf7 2022-09-13 op 	/* TODO: compute the URL */
 634 c743c9a1 2022-09-23 op 	out = EVBUFFER_OUTPUT(clt->clt_bev);
 635 28239bac 2022-09-20 op 	if (evbuffer_add_printf(out, "gemini://%s/%s",
 636 ee80262d 2022-09-13 op 	    clt->clt_pc->proxy_name, clt->clt_path_info) == -1) {
 637 28239bac 2022-09-20 op 		log_warn("bufferevent_printf failed");
 638 28239bac 2022-09-20 op 		goto err;
 639 28239bac 2022-09-20 op 	}
 640 28239bac 2022-09-20 op 
 641 28239bac 2022-09-20 op 	if (clt->clt_query &&
 642 28239bac 2022-09-20 op 	    evbuffer_add_printf(out, "?%s", clt->clt_query) == -1) {
 643 b0a6bcf7 2022-09-13 op 		log_warn("bufferevent_printf failed");
 644 28239bac 2022-09-20 op 		goto err;
 645 28239bac 2022-09-20 op 	}
 646 28239bac 2022-09-20 op 
 647 28239bac 2022-09-20 op 	if (evbuffer_add(out, "\r\n", 2) == -1) {
 648 28239bac 2022-09-20 op 		log_warn("bufferevent_add failed");
 649 b0a6bcf7 2022-09-13 op 		goto err;
 650 b0a6bcf7 2022-09-13 op 	}
 651 b0a6bcf7 2022-09-13 op 
 652 b0a6bcf7 2022-09-13 op 	return;
 653 b0a6bcf7 2022-09-13 op 
 654 b0a6bcf7 2022-09-13 op err:
 655 26cd3e9d 2022-09-23 op 	log_warn("failed to connect to %s:%s",
 656 b0a6bcf7 2022-09-13 op 	    clt->clt_pc->proxy_addr, clt->clt_pc->proxy_port);
 657 e3c1cbab 2022-09-20 op 	if (proxy_start_reply(clt, 501, "text/html") == -1)
 658 b0a6bcf7 2022-09-13 op 		return;
 659 abe17781 2022-09-20 op 	if (tp_error(clt->clt_tp, -1, "Can't connect") == -1)
 660 b0a6bcf7 2022-09-13 op 		return;
 661 b0a6bcf7 2022-09-13 op 	fcgi_end_request(clt, 1);
 662 6edd9a00 2022-09-14 op }
 663 6edd9a00 2022-09-14 op 
 664 6edd9a00 2022-09-14 op static inline int
 665 6edd9a00 2022-09-14 op parse_mime(struct client *clt, char *mime, char *lang, size_t len)
 666 6edd9a00 2022-09-14 op {
 667 6edd9a00 2022-09-14 op 	char			*t, *semi;
 668 6edd9a00 2022-09-14 op 
 669 6edd9a00 2022-09-14 op 	if (strncmp(mime, "text/gemini", 11) != 0)
 670 6edd9a00 2022-09-14 op 		return (0);
 671 6edd9a00 2022-09-14 op 
 672 6edd9a00 2022-09-14 op 	clt->clt_translate = TR_ENABLED;
 673 6edd9a00 2022-09-14 op 
 674 6edd9a00 2022-09-14 op 	if ((mime = strchr(mime, ';')) == NULL)
 675 6edd9a00 2022-09-14 op 		return (0);
 676 6edd9a00 2022-09-14 op 
 677 6edd9a00 2022-09-14 op 	*mime++ = '\0';
 678 6edd9a00 2022-09-14 op 	while ((t = strsep(&mime, ";")) != NULL) {
 679 6edd9a00 2022-09-14 op 		if (!strncmp(t, "charset=", 8)) {
 680 6edd9a00 2022-09-14 op 			t += 8;
 681 6edd9a00 2022-09-14 op 			if (!strncasecmp(t, "utf8", 4) ||
 682 8ab2d60e 2022-09-14 op 			    !strncasecmp(t, "utf-8", 5) ||
 683 6edd9a00 2022-09-14 op 			    !strncasecmp(t, "ascii", 5)) {
 684 6edd9a00 2022-09-14 op 				log_debug("unknown charset %s", t);
 685 6edd9a00 2022-09-14 op 				return (-1);
 686 6edd9a00 2022-09-14 op 			}
 687 6edd9a00 2022-09-14 op 			continue;
 688 6edd9a00 2022-09-14 op 		}
 689 6edd9a00 2022-09-14 op 
 690 6edd9a00 2022-09-14 op 		if (!strncmp(t, "lang=", 5)) {
 691 6edd9a00 2022-09-14 op 			t += 5;
 692 6edd9a00 2022-09-14 op 			if ((semi = strchr(t, ';')) != NULL)
 693 6edd9a00 2022-09-14 op 				*semi = '\0';
 694 6edd9a00 2022-09-14 op 
 695 6edd9a00 2022-09-14 op 			if (strlcpy(lang, t, len) >= len) {
 696 6edd9a00 2022-09-14 op 				log_debug("lang too long: %s", t);
 697 6edd9a00 2022-09-14 op 				*lang = '\0';
 698 6edd9a00 2022-09-14 op 			}
 699 6edd9a00 2022-09-14 op 
 700 6edd9a00 2022-09-14 op 			if (semi)
 701 6edd9a00 2022-09-14 op 				*semi = ';';
 702 6edd9a00 2022-09-14 op 			continue;
 703 6edd9a00 2022-09-14 op 		}
 704 bff58270 2022-09-19 op 	}
 705 bff58270 2022-09-19 op 
 706 6edd9a00 2022-09-14 op 	return (0);
 707 b0a6bcf7 2022-09-13 op }
 708 5163fbe9 2022-09-20 op 
 709 5163fbe9 2022-09-20 op int
 710 5163fbe9 2022-09-20 op proxy_start_reply(struct client *clt, int status, const char *ctype)
 711 5163fbe9 2022-09-20 op {
 712 5163fbe9 2022-09-20 op 	const char	*csp;
 713 b0a6bcf7 2022-09-13 op 
 714 5163fbe9 2022-09-20 op 	csp = "Content-Security-Policy: default-src 'self'; "
 715 5163fbe9 2022-09-20 op 	    "script-src 'none'; object-src 'none';\r\n";
 716 5163fbe9 2022-09-20 op 
 717 5163fbe9 2022-09-20 op 	if (status != 200 &&
 718 2df73ca5 2022-09-20 op 	    clt_printf(clt, "Status: %d\r\n", status) == -1)
 719 5163fbe9 2022-09-20 op 		return (-1);
 720 5163fbe9 2022-09-20 op 
 721 2df73ca5 2022-09-20 op 	if (clt_puts(clt, csp) == -1)
 722 5163fbe9 2022-09-20 op 		return (-1);
 723 8857131d 2022-09-20 op 
 724 8857131d 2022-09-20 op 	if (status == 302) {
 725 8857131d 2022-09-20 op 		/* use "ctype" as redirect target */
 726 8857131d 2022-09-20 op 		if (clt_printf(clt, "Location: %s\r\n", ctype) == -1)
 727 8857131d 2022-09-20 op 			return (-1);
 728 8857131d 2022-09-20 op 		if (clt_puts(clt, "\r\n") == -1)
 729 8857131d 2022-09-20 op 			return (-1);
 730 8857131d 2022-09-20 op 		return (0);
 731 8857131d 2022-09-20 op 	}
 732 5163fbe9 2022-09-20 op 
 733 8857131d 2022-09-20 op 	if (ctype != NULL) {
 734 8857131d 2022-09-20 op 		if (!strcmp(ctype, "text/html"))
 735 8857131d 2022-09-20 op 			ctype = "text/html;charset=utf-8";
 736 8857131d 2022-09-20 op 		if (clt_printf(clt, "Content-Type: %s\r\n", ctype)
 737 8857131d 2022-09-20 op 		    == -1)
 738 8857131d 2022-09-20 op 			return (-1);
 739 8857131d 2022-09-20 op 	}
 740 8857131d 2022-09-20 op 
 741 5163fbe9 2022-09-20 op 	if (clt_puts(clt, "\r\n") == -1)
 742 5163fbe9 2022-09-20 op 		return (-1);
 743 5163fbe9 2022-09-20 op 
 744 5163fbe9 2022-09-20 op 	return (0);
 745 5163fbe9 2022-09-20 op }
 746 5163fbe9 2022-09-20 op 
 747 b0a6bcf7 2022-09-13 op void
 748 b0a6bcf7 2022-09-13 op proxy_read(struct bufferevent *bev, void *d)
 749 b0a6bcf7 2022-09-13 op {
 750 b0a6bcf7 2022-09-13 op 	struct client		*clt = d;
 751 b0a6bcf7 2022-09-13 op 	struct evbuffer		*src = EVBUFFER_INPUT(bev);
 752 c9dc4bc6 2022-09-13 op 	const char		*ctype;
 753 cb05cce7 2022-11-11 op 	char			 buf[1025];
 754 6edd9a00 2022-09-14 op 	char			 lang[16];
 755 6edd9a00 2022-09-14 op 	char			*hdr, *mime;
 756 b0a6bcf7 2022-09-13 op 	size_t			 len;
 757 abe17781 2022-09-20 op 	int			 code;
 758 b0a6bcf7 2022-09-13 op 
 759 b0a6bcf7 2022-09-13 op 	if (clt->clt_headersdone) {
 760 c9dc4bc6 2022-09-13 op 		if (clt->clt_translate)
 761 c9dc4bc6 2022-09-13 op 			proxy_translate_gemtext(clt);
 762 c9dc4bc6 2022-09-13 op 		else
 763 c9dc4bc6 2022-09-13 op 			clt_write_bufferevent(clt, bev);
 764 b0a6bcf7 2022-09-13 op 		return;
 765 b0a6bcf7 2022-09-13 op 	}
 766 b0a6bcf7 2022-09-13 op 
 767 b0a6bcf7 2022-09-13 op 	hdr = evbuffer_readln(src, &len, EVBUFFER_EOL_CRLF_STRICT);
 768 b0a6bcf7 2022-09-13 op 	if (hdr == NULL) {
 769 b0a6bcf7 2022-09-13 op 		if (EVBUFFER_LENGTH(src) >= 1026)
 770 b0a6bcf7 2022-09-13 op 			proxy_error(bev, EV_READ, clt);
 771 b0a6bcf7 2022-09-13 op 		return;
 772 b0a6bcf7 2022-09-13 op 	}
 773 b0a6bcf7 2022-09-13 op 
 774 b0a6bcf7 2022-09-13 op 	if (len < 4 ||
 775 b0a6bcf7 2022-09-13 op 	    !isdigit((unsigned char)hdr[0]) ||
 776 b0a6bcf7 2022-09-13 op 	    !isdigit((unsigned char)hdr[1]) ||
 777 b0a6bcf7 2022-09-13 op 	    hdr[2] != ' ') {
 778 b0a6bcf7 2022-09-13 op 		log_warnx("invalid ");
 779 b0a6bcf7 2022-09-13 op 		proxy_error(bev, EV_READ, clt);
 780 1337dc2b 2022-09-14 op 		goto err;
 781 b0a6bcf7 2022-09-13 op 	}
 782 b0a6bcf7 2022-09-13 op 
 783 abe17781 2022-09-20 op 	code = (hdr[0] - '0') * 10 + (hdr[1] - '0');
 784 abe17781 2022-09-20 op 
 785 6e8f426e 2022-09-14 op 	switch (hdr[0]) {
 786 8857131d 2022-09-20 op 	case '1':
 787 8857131d 2022-09-20 op 		if (proxy_start_reply(clt, 200, "text/html") == -1)
 788 8857131d 2022-09-20 op 			goto err;
 789 8857131d 2022-09-20 op 		if (tp_inputpage(clt->clt_tp, &hdr[3]) == -1)
 790 8857131d 2022-09-20 op 			goto err;
 791 8857131d 2022-09-20 op 		fcgi_end_request(clt, 0);
 792 8857131d 2022-09-20 op 		goto err;
 793 6e8f426e 2022-09-14 op 	case '2':
 794 6e8f426e 2022-09-14 op 		/* handled below */
 795 6e8f426e 2022-09-14 op 		break;
 796 b4f7fe4f 2022-09-21 op 	case '3':
 797 cb05cce7 2022-11-11 op 		if (proxy_resurl(clt, &hdr[3], buf, sizeof(buf)) == 0) {
 798 cb05cce7 2022-11-11 op 			if (proxy_start_reply(clt, 302, buf) == -1)
 799 b4f7fe4f 2022-09-21 op 				goto err;
 800 b4f7fe4f 2022-09-21 op 			fcgi_end_request(clt, 0);
 801 b4f7fe4f 2022-09-21 op 			goto err;
 802 b4f7fe4f 2022-09-21 op 		}
 803 02be3606 2022-09-29 op 		/* fallthrough */
 804 6e8f426e 2022-09-14 op 	default:
 805 e3c1cbab 2022-09-20 op 		if (proxy_start_reply(clt, 501, "text/html") == -1)
 806 1337dc2b 2022-09-14 op 			goto err;
 807 abe17781 2022-09-20 op 		if (tp_error(clt->clt_tp, code, &hdr[3]) == -1)
 808 1337dc2b 2022-09-14 op 			goto err;
 809 6e8f426e 2022-09-14 op 		fcgi_end_request(clt, 1);
 810 1337dc2b 2022-09-14 op 		goto err;
 811 b0a6bcf7 2022-09-13 op 	}
 812 b0a6bcf7 2022-09-13 op 
 813 6edd9a00 2022-09-14 op 	mime = hdr + 2 + strspn(hdr + 2, " \t");
 814 6edd9a00 2022-09-14 op 	if (parse_mime(clt, mime, lang, sizeof(lang)) == -1) {
 815 e3c1cbab 2022-09-20 op 		if (proxy_start_reply(clt, 501, "text/html") == -1)
 816 1337dc2b 2022-09-14 op 			goto err;
 817 abe17781 2022-09-20 op 		if (tp_error(clt->clt_tp, -1, "Bad response") == -1)
 818 e3c1cbab 2022-09-20 op 			goto err;
 819 6edd9a00 2022-09-14 op 		fcgi_end_request(clt, 1);
 820 1337dc2b 2022-09-14 op 		goto err;
 821 6edd9a00 2022-09-14 op 	}
 822 bff58270 2022-09-19 op 
 823 232eee45 2022-09-20 op 	if (clt->clt_translate)
 824 8ab2d60e 2022-09-14 op 		ctype = "text/html;charset=utf-8";
 825 232eee45 2022-09-20 op 	else
 826 6edd9a00 2022-09-14 op 		ctype = mime;
 827 6edd9a00 2022-09-14 op 
 828 6edd9a00 2022-09-14 op 	if (clt_printf(clt, "Content-Type: %s\r\n\r\n", ctype) == -1)
 829 1337dc2b 2022-09-14 op 		goto err;
 830 b0a6bcf7 2022-09-13 op 
 831 b0a6bcf7 2022-09-13 op 	clt->clt_headersdone = 1;
 832 c9dc4bc6 2022-09-13 op 
 833 bff58270 2022-09-19 op 	if (clt->clt_translate &&
 834 e3c1cbab 2022-09-20 op 	    tp_head(clt->clt_tp, lang, NULL) == -1)
 835 bff58270 2022-09-19 op 		goto err;
 836 c9dc4bc6 2022-09-13 op 
 837 1337dc2b 2022-09-14 op 	/*
 838 1337dc2b 2022-09-14 op 	 * Trigger the read again so we proceed with the response
 839 1337dc2b 2022-09-14 op 	 * body, if any.
 840 1337dc2b 2022-09-14 op 	 */
 841 1337dc2b 2022-09-14 op 	free(hdr);
 842 1337dc2b 2022-09-14 op 	proxy_read(bev, d);
 843 1337dc2b 2022-09-14 op 	return;
 844 1337dc2b 2022-09-14 op 
 845 1337dc2b 2022-09-14 op err:
 846 1337dc2b 2022-09-14 op 	free(hdr);
 847 b0a6bcf7 2022-09-13 op }
 848 b0a6bcf7 2022-09-13 op 
 849 b0a6bcf7 2022-09-13 op void
 850 b0a6bcf7 2022-09-13 op proxy_write(struct bufferevent *bev, void *d)
 851 b0a6bcf7 2022-09-13 op {
 852 b0a6bcf7 2022-09-13 op 	return;
 853 b0a6bcf7 2022-09-13 op }
 854 b0a6bcf7 2022-09-13 op 
 855 b0a6bcf7 2022-09-13 op void
 856 b0a6bcf7 2022-09-13 op proxy_error(struct bufferevent *bev, short err, void *d)
 857 b0a6bcf7 2022-09-13 op {
 858 b0a6bcf7 2022-09-13 op 	struct client		*clt = d;
 859 b0a6bcf7 2022-09-13 op 	int			 status = !(err & EVBUFFER_EOF);
 860 b0a6bcf7 2022-09-13 op 
 861 b0a6bcf7 2022-09-13 op 	log_debug("proxy error, shutting down the connection (err: %x)",
 862 b0a6bcf7 2022-09-13 op 	    err);
 863 b0a6bcf7 2022-09-13 op 
 864 b0a6bcf7 2022-09-13 op 	if (!clt->clt_headersdone) {
 865 e3c1cbab 2022-09-20 op 		if (proxy_start_reply(clt, 501, "text/html") == -1)
 866 b0a6bcf7 2022-09-13 op 			return;
 867 abe17781 2022-09-20 op 		if (tp_error(clt->clt_tp, -1, "Proxy error") == -1)
 868 b0a6bcf7 2022-09-13 op 			return;
 869 c9dc4bc6 2022-09-13 op 	} else if (status == 0) {
 870 c42fce9b 2022-09-14 op 		if (clt->clt_translate & TR_PRE) {
 871 ceb3f79c 2022-09-29 op 			if (tp_pre_close(clt->clt_tp))
 872 c42fce9b 2022-09-14 op 				return;
 873 c42fce9b 2022-09-14 op 			clt->clt_translate &= ~TR_PRE;
 874 c42fce9b 2022-09-14 op 		}
 875 c42fce9b 2022-09-14 op 
 876 c42fce9b 2022-09-14 op 		if (clt->clt_translate & TR_LIST) {
 877 c42fce9b 2022-09-14 op 			if (clt_puts(clt, "</ul>") == -1)
 878 c42fce9b 2022-09-14 op 				return;
 879 c42fce9b 2022-09-14 op 			clt->clt_translate &= ~TR_LIST;
 880 c42fce9b 2022-09-14 op 		}
 881 c42fce9b 2022-09-14 op 
 882 c42fce9b 2022-09-14 op 		if (clt->clt_translate & TR_NAV) {
 883 c42fce9b 2022-09-14 op 			if (clt_puts(clt, "</ul></nav>") == -1)
 884 c42fce9b 2022-09-14 op 				return;
 885 c42fce9b 2022-09-14 op 			clt->clt_translate &= ~TR_NAV;
 886 c42fce9b 2022-09-14 op 		}
 887 c42fce9b 2022-09-14 op 
 888 54acddc9 2022-09-19 op 		if (clt->clt_translate &&
 889 54acddc9 2022-09-19 op 		    tp_foot(clt->clt_tp) == -1)
 890 8fa3006a 2022-09-14 op 			return;
 891 b0a6bcf7 2022-09-13 op 	}
 892 b0a6bcf7 2022-09-13 op 
 893 b0a6bcf7 2022-09-13 op 	fcgi_end_request(clt, status);
 894 b0a6bcf7 2022-09-13 op }
 895 b0a6bcf7 2022-09-13 op 
 896 b0a6bcf7 2022-09-13 op void
 897 b0a6bcf7 2022-09-13 op proxy_tls_readcb(int fd, short event, void *arg)
 898 b0a6bcf7 2022-09-13 op {
 899 b0a6bcf7 2022-09-13 op 	struct bufferevent	*bufev = arg;
 900 b0a6bcf7 2022-09-13 op 	struct client		*clt = bufev->cbarg;
 901 b0a6bcf7 2022-09-13 op 	char			 rbuf[IBUF_READ_SIZE];
 902 b0a6bcf7 2022-09-13 op 	int			 what = EVBUFFER_READ;
 903 b0a6bcf7 2022-09-13 op 	int			 howmuch = IBUF_READ_SIZE;
 904 b0a6bcf7 2022-09-13 op 	ssize_t			 ret;
 905 b0a6bcf7 2022-09-13 op 	size_t			 len;
 906 b0a6bcf7 2022-09-13 op 
 907 b0a6bcf7 2022-09-13 op 	if (event == EV_TIMEOUT) {
 908 b0a6bcf7 2022-09-13 op 		what |= EVBUFFER_TIMEOUT;
 909 b0a6bcf7 2022-09-13 op 		goto err;
 910 b0a6bcf7 2022-09-13 op 	}
 911 b0a6bcf7 2022-09-13 op 
 912 b0a6bcf7 2022-09-13 op 	if (bufev->wm_read.high != 0)
 913 b0a6bcf7 2022-09-13 op 		howmuch = MINIMUM(sizeof(rbuf), bufev->wm_read.high);
 914 b0a6bcf7 2022-09-13 op 
 915 b0a6bcf7 2022-09-13 op 	ret = tls_read(clt->clt_ctx, rbuf, howmuch);
 916 b0a6bcf7 2022-09-13 op 	if (ret == TLS_WANT_POLLIN || ret == TLS_WANT_POLLOUT) {
 917 b0a6bcf7 2022-09-13 op 		goto retry;
 918 b0a6bcf7 2022-09-13 op 	} else if (ret == -1) {
 919 b0a6bcf7 2022-09-13 op 		what |= EVBUFFER_ERROR;
 920 b0a6bcf7 2022-09-13 op 		goto err;
 921 b0a6bcf7 2022-09-13 op 	}
 922 b0a6bcf7 2022-09-13 op 	len = ret;
 923 b0a6bcf7 2022-09-13 op 
 924 b0a6bcf7 2022-09-13 op 	if (len == 0) {
 925 b0a6bcf7 2022-09-13 op 		what |= EVBUFFER_EOF;
 926 b0a6bcf7 2022-09-13 op 		goto err;
 927 b0a6bcf7 2022-09-13 op 	}
 928 b0a6bcf7 2022-09-13 op 
 929 b0a6bcf7 2022-09-13 op 	if (evbuffer_add(bufev->input, rbuf, len) == -1) {
 930 b0a6bcf7 2022-09-13 op 		what |= EVBUFFER_ERROR;
 931 b0a6bcf7 2022-09-13 op 		goto err;
 932 b0a6bcf7 2022-09-13 op 	}
 933 b0a6bcf7 2022-09-13 op 
 934 83f0f95a 2022-09-29 op 	proxy_bufferevent_add(&bufev->ev_read, G_TOUT(bufev->timeout_read));
 935 b0a6bcf7 2022-09-13 op 
 936 b0a6bcf7 2022-09-13 op 	len = EVBUFFER_LENGTH(bufev->input);
 937 b0a6bcf7 2022-09-13 op 	if (bufev->wm_read.low != 0 && len < bufev->wm_read.low)
 938 b0a6bcf7 2022-09-13 op 		return;
 939 b0a6bcf7 2022-09-13 op 	if (bufev->wm_read.high != 0 && len > bufev->wm_read.high) {
 940 b0a6bcf7 2022-09-13 op 		struct evbuffer *buf = bufev->input;
 941 b0a6bcf7 2022-09-13 op 		event_del(&bufev->ev_read);
 942 b0a6bcf7 2022-09-13 op 		evbuffer_setcb(buf, bufferevent_read_pressure_cb, bufev);
 943 b0a6bcf7 2022-09-13 op 		return;
 944 b0a6bcf7 2022-09-13 op 	}
 945 b0a6bcf7 2022-09-13 op 
 946 b0a6bcf7 2022-09-13 op 	if (bufev->readcb != NULL)
 947 b0a6bcf7 2022-09-13 op 		(*bufev->readcb)(bufev, bufev->cbarg);
 948 b0a6bcf7 2022-09-13 op 	return;
 949 b0a6bcf7 2022-09-13 op 
 950 b0a6bcf7 2022-09-13 op retry:
 951 83f0f95a 2022-09-29 op 	proxy_bufferevent_add(&bufev->ev_read, G_TOUT(bufev->timeout_read));
 952 b0a6bcf7 2022-09-13 op 	return;
 953 b0a6bcf7 2022-09-13 op 
 954 b0a6bcf7 2022-09-13 op err:
 955 b0a6bcf7 2022-09-13 op 	(*bufev->errorcb)(bufev, what, bufev->cbarg);
 956 b0a6bcf7 2022-09-13 op }
 957 b0a6bcf7 2022-09-13 op 
 958 b0a6bcf7 2022-09-13 op int
 959 b0a6bcf7 2022-09-13 op proxy_bufferevent_add(struct event *ev, int timeout)
 960 b0a6bcf7 2022-09-13 op {
 961 b0a6bcf7 2022-09-13 op 	struct timeval tv, *ptv = NULL;
 962 b0a6bcf7 2022-09-13 op 
 963 b0a6bcf7 2022-09-13 op 	if (timeout) {
 964 b0a6bcf7 2022-09-13 op 		timerclear(&tv);
 965 b0a6bcf7 2022-09-13 op 		tv.tv_sec = timeout;
 966 b0a6bcf7 2022-09-13 op 		ptv = &tv;
 967 b0a6bcf7 2022-09-13 op 	}
 968 b0a6bcf7 2022-09-13 op 
 969 b0a6bcf7 2022-09-13 op 	return (event_add(ev, ptv));
 970 b0a6bcf7 2022-09-13 op }
 971 b0a6bcf7 2022-09-13 op 
 972 b0a6bcf7 2022-09-13 op void
 973 b0a6bcf7 2022-09-13 op proxy_tls_writecb(int fd, short event, void *arg)
 974 b0a6bcf7 2022-09-13 op {
 975 b0a6bcf7 2022-09-13 op 	struct bufferevent	*bufev = arg;
 976 b0a6bcf7 2022-09-13 op 	struct client		*clt = bufev->cbarg;
 977 b0a6bcf7 2022-09-13 op 	ssize_t			 ret;
 978 b0a6bcf7 2022-09-13 op 	short			 what = EVBUFFER_WRITE;
 979 b0a6bcf7 2022-09-13 op 	size_t			 len;
 980 b0a6bcf7 2022-09-13 op 
 981 b0a6bcf7 2022-09-13 op 	if (event == EV_TIMEOUT) {
 982 b0a6bcf7 2022-09-13 op 		what |= EVBUFFER_TIMEOUT;
 983 b0a6bcf7 2022-09-13 op 		goto err;
 984 b0a6bcf7 2022-09-13 op 	}
 985 b0a6bcf7 2022-09-13 op 
 986 b0a6bcf7 2022-09-13 op 	if (EVBUFFER_LENGTH(bufev->output)) {
 987 b0a6bcf7 2022-09-13 op 		ret = tls_write(clt->clt_ctx,
 988 b0a6bcf7 2022-09-13 op 		    EVBUFFER_DATA(bufev->output),
 989 b0a6bcf7 2022-09-13 op 		    EVBUFFER_LENGTH(bufev->output));
 990 b0a6bcf7 2022-09-13 op 		if (ret == TLS_WANT_POLLIN || ret == TLS_WANT_POLLOUT) {
 991 b0a6bcf7 2022-09-13 op 			goto retry;
 992 b0a6bcf7 2022-09-13 op 		} else if (ret == -1) {
 993 b0a6bcf7 2022-09-13 op 			what |= EVBUFFER_ERROR;
 994 b0a6bcf7 2022-09-13 op 			goto err;
 995 b0a6bcf7 2022-09-13 op 		}
 996 b0a6bcf7 2022-09-13 op 		len = ret;
 997 b0a6bcf7 2022-09-13 op 		evbuffer_drain(bufev->output, len);
 998 b0a6bcf7 2022-09-13 op 	}
 999 b0a6bcf7 2022-09-13 op 
1000 b0a6bcf7 2022-09-13 op 	if (EVBUFFER_LENGTH(bufev->output) != 0)
1001 83f0f95a 2022-09-29 op 		proxy_bufferevent_add(&bufev->ev_write,
1002 83f0f95a 2022-09-29 op 		    G_TOUT(bufev->timeout_write));
1003 b0a6bcf7 2022-09-13 op 
1004 b0a6bcf7 2022-09-13 op 	if (bufev->writecb != NULL &&
1005 b0a6bcf7 2022-09-13 op 	    EVBUFFER_LENGTH(bufev->output) <= bufev->wm_write.low)
1006 b0a6bcf7 2022-09-13 op 		(*bufev->writecb)(bufev, bufev->cbarg);
1007 b0a6bcf7 2022-09-13 op 	return;
1008 b0a6bcf7 2022-09-13 op 
1009 b0a6bcf7 2022-09-13 op retry:
1010 83f0f95a 2022-09-29 op 	proxy_bufferevent_add(&bufev->ev_write, G_TOUT(bufev->timeout_write));
1011 b0a6bcf7 2022-09-13 op 	return;
1012 b0a6bcf7 2022-09-13 op 
1013 b0a6bcf7 2022-09-13 op err:
1014 b0a6bcf7 2022-09-13 op 	(*bufev->errorcb)(bufev, what, bufev->cbarg);
1015 b0a6bcf7 2022-09-13 op }
1016 b0a6bcf7 2022-09-13 op 
1017 b0a6bcf7 2022-09-13 op void
1018 b0a6bcf7 2022-09-13 op proxy_client_free(struct client *clt)
1019 b0a6bcf7 2022-09-13 op {
1020 b0a6bcf7 2022-09-13 op 	if (clt->clt_evasr)
1021 b0a6bcf7 2022-09-13 op 		event_asr_abort(clt->clt_evasr);
1022 b0a6bcf7 2022-09-13 op 
1023 b0a6bcf7 2022-09-13 op 	if (clt->clt_addrinfo)
1024 b0a6bcf7 2022-09-13 op 		freeaddrinfo(clt->clt_addrinfo);
1025 b0a6bcf7 2022-09-13 op 
1026 b0a6bcf7 2022-09-13 op 	if (clt->clt_evconn_live)
1027 b0a6bcf7 2022-09-13 op 		event_del(&clt->clt_evconn);
1028 b0a6bcf7 2022-09-13 op 
1029 b0a6bcf7 2022-09-13 op 	if (clt->clt_fd != -1)
1030 b0a6bcf7 2022-09-13 op 		close(clt->clt_fd);
1031 b0a6bcf7 2022-09-13 op 
1032 b0a6bcf7 2022-09-13 op 	if (clt->clt_ctx)
1033 b0a6bcf7 2022-09-13 op 		tls_free(clt->clt_ctx);
1034 b0a6bcf7 2022-09-13 op 
1035 b0a6bcf7 2022-09-13 op 	if (clt->clt_bev)
1036 b0a6bcf7 2022-09-13 op 		bufferevent_free(clt->clt_bev);
1037 a244322c 2022-09-29 op 
1038 a244322c 2022-09-29 op 	template_free(clt->clt_tp);
1039 b0a6bcf7 2022-09-13 op 
1040 8857131d 2022-09-20 op 	free(clt->clt_body);
1041 b0a6bcf7 2022-09-13 op 	free(clt->clt_server_name);
1042 b0a6bcf7 2022-09-13 op 	free(clt->clt_script_name);
1043 b0a6bcf7 2022-09-13 op 	free(clt->clt_path_info);
1044 28239bac 2022-09-20 op 	free(clt->clt_query);
1045 b0a6bcf7 2022-09-13 op 	free(clt);
1046 b0a6bcf7 2022-09-13 op }