op public repos

Blame

Date:: Fri Mar 3 09:15:12 2023 UTC
Message:: allow to disable navbar/footer/image preview
Actions:: History | Blob | Raw File
   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 a1cf3ab5 2022-11-11 op 	if (clt->clt_server_name == NULL)
 193 a1cf3ab5 2022-11-11 op 		return (-1);
 194 a1cf3ab5 2022-11-11 op 
 195 cb05cce7 2022-11-11 op 	l = strlen(clt->clt_server_name);
 196 cb05cce7 2022-11-11 op 
 197 cb05cce7 2022-11-11 op 	if (len == 0) {
 198 cb05cce7 2022-11-11 op 		log_warn("%s: zero-sized buffer!", __func__);
 199 cb05cce7 2022-11-11 op 		return (-1);
 200 cb05cce7 2022-11-11 op 	}
 201 cb05cce7 2022-11-11 op 
 202 cb05cce7 2022-11-11 op 	/* look if it's an absolute URI */
 203 cb05cce7 2022-11-11 op 	if (strncmp(url, "//", 2) == 0) {
 204 cb05cce7 2022-11-11 op 		tmp = url + 2;
 205 cb05cce7 2022-11-11 op 		if (strncmp(tmp, clt->clt_server_name, l) != 0)
 206 cb05cce7 2022-11-11 op 			goto done;
 207 cb05cce7 2022-11-11 op 
 208 cb05cce7 2022-11-11 op 		tmp += l;
 209 cb05cce7 2022-11-11 op 		if (!portok(&tmp, clt))
 210 cb05cce7 2022-11-11 op 			goto done;
 211 cb05cce7 2022-11-11 op 		url = tmp;
 212 cb05cce7 2022-11-11 op 	} else if (strncmp(url, "gemini://", 9) == 0) {
 213 cb05cce7 2022-11-11 op 		tmp = url + 9;
 214 cb05cce7 2022-11-11 op 		if (strncmp(tmp, clt->clt_server_name, l) != 0)
 215 cb05cce7 2022-11-11 op 			goto done;
 216 cb05cce7 2022-11-11 op 
 217 cb05cce7 2022-11-11 op 		tmp += l;
 218 cb05cce7 2022-11-11 op 		if (!portok(&tmp, clt))
 219 cb05cce7 2022-11-11 op 			goto done;
 220 cb05cce7 2022-11-11 op 		url = tmp;
 221 cb05cce7 2022-11-11 op 	} else {
 222 cb05cce7 2022-11-11 op 		tmp = url;
 223 cb05cce7 2022-11-11 op 		while (isalpha((unsigned char)*tmp) || *tmp == '+')
 224 cb05cce7 2022-11-11 op 			tmp++;
 225 cb05cce7 2022-11-11 op 		if (strncmp(tmp, "://", 3) == 0)
 226 cb05cce7 2022-11-11 op 			goto done;
 227 cb05cce7 2022-11-11 op 	}
 228 cb05cce7 2022-11-11 op 
 229 cb05cce7 2022-11-11 op 	/* maybe it's an absolute path? */
 230 cb05cce7 2022-11-11 op 	if (*url == '\0' || *url == '/') {
 231 cb05cce7 2022-11-11 op 		if (strlcpy(buf, clt->clt_script_name, len) >= len)
 232 cb05cce7 2022-11-11 op 			return (-1);
 233 cb05cce7 2022-11-11 op 		if (strlcat(buf, url + 1, len) >= len)
 234 cb05cce7 2022-11-11 op 			return (-1);
 235 cb05cce7 2022-11-11 op 		return (0);
 236 cb05cce7 2022-11-11 op 	}
 237 cb05cce7 2022-11-11 op 
 238 cb05cce7 2022-11-11 op 	/* otherwise, leave it as it is */
 239 cb05cce7 2022-11-11 op  done:
 240 cb05cce7 2022-11-11 op 	if (strlcpy(buf, url, len) >= len)
 241 cb05cce7 2022-11-11 op 		return (-1);
 242 cb05cce7 2022-11-11 op 	return (0);
 243 cb05cce7 2022-11-11 op }
 244 cb05cce7 2022-11-11 op 
 245 da7b17a3 2023-03-03 op static inline int
 246 da7b17a3 2023-03-03 op match_image_heur(const char *url)
 247 da7b17a3 2023-03-03 op {
 248 da7b17a3 2023-03-03 op 	return (fnmatch("*.jpg", url, 0) == 0 ||
 249 da7b17a3 2023-03-03 op 	    fnmatch("*.jpeg", url, 0) == 0 ||
 250 da7b17a3 2023-03-03 op 	    fnmatch("*.gif", url, 0) == 0 ||
 251 da7b17a3 2023-03-03 op 	    fnmatch("*.png", url, 0) == 0 ||
 252 da7b17a3 2023-03-03 op 	    fnmatch("*.svg", url, 0) == 0 ||
 253 da7b17a3 2023-03-03 op 	    fnmatch("*.webp", url, 0) == 0);
 254 da7b17a3 2023-03-03 op }
 255 da7b17a3 2023-03-03 op 
 256 cb05cce7 2022-11-11 op static int
 257 c9dc4bc6 2022-09-13 op gemtext_translate_line(struct client *clt, char *line)
 258 c9dc4bc6 2022-09-13 op {
 259 cb05cce7 2022-11-11 op 	char		 buf[1025];
 260 cb05cce7 2022-11-11 op 	char		*url;
 261 cb05cce7 2022-11-11 op 
 262 c9dc4bc6 2022-09-13 op 	/* preformatted line / closing */
 263 b9de0a74 2022-09-14 op 	if (clt->clt_translate & TR_PRE) {
 264 c9dc4bc6 2022-09-13 op 		if (!strncmp(line, "```", 3)) {
 265 b9de0a74 2022-09-14 op 			clt->clt_translate &= ~TR_PRE;
 266 ceb3f79c 2022-09-29 op 			return (tp_pre_close(clt->clt_tp));
 267 c9dc4bc6 2022-09-13 op 		}
 268 c9dc4bc6 2022-09-13 op 
 269 df2db214 2022-09-19 op 		if (tp_htmlescape(clt->clt_tp, line) == -1)
 270 c9dc4bc6 2022-09-13 op 			return (-1);
 271 c9dc4bc6 2022-09-13 op 		return (clt_putc(clt, '\n'));
 272 b9de0a74 2022-09-14 op 	}
 273 b9de0a74 2022-09-14 op 
 274 b9de0a74 2022-09-14 op 	/* bullet */
 275 b9de0a74 2022-09-14 op 	if (!strncmp(line, "* ", 2)) {
 276 b9de0a74 2022-09-14 op 		if (clt->clt_translate & TR_NAV) {
 277 b9de0a74 2022-09-14 op 			if (clt_puts(clt, "</ul></nav>") == -1)
 278 b9de0a74 2022-09-14 op 				return (-1);
 279 b9de0a74 2022-09-14 op 			clt->clt_translate &= ~TR_NAV;
 280 b9de0a74 2022-09-14 op 		}
 281 b9de0a74 2022-09-14 op 
 282 b9de0a74 2022-09-14 op 		if (!(clt->clt_translate & TR_LIST)) {
 283 b9de0a74 2022-09-14 op 			if (clt_puts(clt, "<ul>") == -1)
 284 b9de0a74 2022-09-14 op 				return (-1);
 285 b9de0a74 2022-09-14 op 			clt->clt_translate |= TR_LIST;
 286 b9de0a74 2022-09-14 op 		}
 287 b9de0a74 2022-09-14 op 
 288 b9de0a74 2022-09-14 op 		if (clt_puts(clt, "<li>") == -1 ||
 289 df2db214 2022-09-19 op 		    tp_htmlescape(clt->clt_tp, line + 2) == -1 ||
 290 b9de0a74 2022-09-14 op 		    clt_puts(clt, "</li>") == -1)
 291 b9de0a74 2022-09-14 op 			return (-1);
 292 b9de0a74 2022-09-14 op 		return (0);
 293 b9de0a74 2022-09-14 op 	}
 294 b9de0a74 2022-09-14 op 
 295 b9de0a74 2022-09-14 op 	if (clt->clt_translate & TR_LIST) {
 296 b9de0a74 2022-09-14 op 		if (clt_puts(clt, "</ul>") == -1)
 297 b9de0a74 2022-09-14 op 			return (-1);
 298 b9de0a74 2022-09-14 op 		clt->clt_translate &= ~TR_LIST;
 299 b9de0a74 2022-09-14 op 	}
 300 b9de0a74 2022-09-14 op 
 301 cb05cce7 2022-11-11 op 	/* link */
 302 b9de0a74 2022-09-14 op 	if (!strncmp(line, "=>", 2)) {
 303 b9de0a74 2022-09-14 op 		char *label;
 304 b9de0a74 2022-09-14 op 
 305 b9de0a74 2022-09-14 op 		line += 2;
 306 b9de0a74 2022-09-14 op 		line += strspn(line, " \t");
 307 b9de0a74 2022-09-14 op 
 308 b9de0a74 2022-09-14 op 		label = line + strcspn(line, " \t");
 309 b9de0a74 2022-09-14 op 		if (*label == '\0')
 310 b9de0a74 2022-09-14 op 			label = line;
 311 cd396568 2022-11-11 op 		else {
 312 b9de0a74 2022-09-14 op 			*label++ = '\0';
 313 cd396568 2022-11-11 op 			label += strspn(label, " \t");
 314 cd396568 2022-11-11 op 			if (*label == '\0')
 315 cd396568 2022-11-11 op 				label = line;
 316 cd396568 2022-11-11 op 		}
 317 b9de0a74 2022-09-14 op 
 318 cb05cce7 2022-11-11 op 		if (proxy_resurl(clt, line, buf, sizeof(buf)) == 0)
 319 cb05cce7 2022-11-11 op 			url = buf;
 320 cb05cce7 2022-11-11 op 		else
 321 cb05cce7 2022-11-11 op 			url = line; /* leave the URL as it is */
 322 cb05cce7 2022-11-11 op 
 323 da7b17a3 2023-03-03 op 		if (!(clt->clt_pc->flags & PROXY_NO_IMGPRV) &&
 324 da7b17a3 2023-03-03 op 		    match_image_heur(url)) {
 325 33f4bf26 2022-09-14 op 			if (clt->clt_translate & TR_NAV) {
 326 33f4bf26 2022-09-14 op 				if (clt_puts(clt, "</ul></nav>") == -1)
 327 33f4bf26 2022-09-14 op 					return (-1);
 328 33f4bf26 2022-09-14 op 				clt->clt_translate &= ~TR_NAV;
 329 33f4bf26 2022-09-14 op 			}
 330 33f4bf26 2022-09-14 op 
 331 cb05cce7 2022-11-11 op 			if (tp_figure(clt->clt_tp, url, label) == -1)
 332 33f4bf26 2022-09-14 op 				return (-1);
 333 33f4bf26 2022-09-14 op 
 334 33f4bf26 2022-09-14 op 			return (0);
 335 33f4bf26 2022-09-14 op 		}
 336 33f4bf26 2022-09-14 op 
 337 33f4bf26 2022-09-14 op 		if (!(clt->clt_translate & TR_NAV)) {
 338 33f4bf26 2022-09-14 op 			if (clt_puts(clt, "<nav><ul>") == -1)
 339 33f4bf26 2022-09-14 op 				return (-1);
 340 33f4bf26 2022-09-14 op 			clt->clt_translate |= TR_NAV;
 341 33f4bf26 2022-09-14 op 		}
 342 33f4bf26 2022-09-14 op 
 343 acc266fe 2022-09-19 op 		if (clt_puts(clt, "<li><a href='") == -1)
 344 acc266fe 2022-09-19 op 			return (-1);
 345 acc266fe 2022-09-19 op 
 346 cb05cce7 2022-11-11 op 		if (tp_urlescape(clt->clt_tp, url) == -1 ||
 347 b9de0a74 2022-09-14 op 		    clt_puts(clt, "'>") == -1 ||
 348 df2db214 2022-09-19 op 		    tp_htmlescape(clt->clt_tp, label) == -1 ||
 349 b9de0a74 2022-09-14 op 		    clt_puts(clt, "</a></li>") == -1)
 350 b9de0a74 2022-09-14 op 			return (-1);
 351 b9de0a74 2022-09-14 op 
 352 b9de0a74 2022-09-14 op 		return (0);
 353 c9dc4bc6 2022-09-13 op 	}
 354 c9dc4bc6 2022-09-13 op 
 355 b9de0a74 2022-09-14 op 	if (clt->clt_translate & TR_NAV) {
 356 b9de0a74 2022-09-14 op 		if (clt_puts(clt, "</ul></nav>") == -1)
 357 b9de0a74 2022-09-14 op 			return (-1);
 358 b9de0a74 2022-09-14 op 		clt->clt_translate &= ~TR_NAV;
 359 b9de0a74 2022-09-14 op 	}
 360 b9de0a74 2022-09-14 op 
 361 c9dc4bc6 2022-09-13 op 	/* pre opening */
 362 c9dc4bc6 2022-09-13 op 	if (!strncmp(line, "```", 3)) {
 363 ceb3f79c 2022-09-29 op 		line += 3;
 364 ceb3f79c 2022-09-29 op 		line += strspn(line, " \t");
 365 ceb3f79c 2022-09-29 op 
 366 b9de0a74 2022-09-14 op 		clt->clt_translate |= TR_PRE;
 367 ceb3f79c 2022-09-29 op 		return (tp_pre_open(clt->clt_tp, line));
 368 c9dc4bc6 2022-09-13 op 	}
 369 c9dc4bc6 2022-09-13 op 
 370 c9dc4bc6 2022-09-13 op 	/* citation block */
 371 c9dc4bc6 2022-09-13 op 	if (*line == '>') {
 372 c9dc4bc6 2022-09-13 op 		if (clt_puts(clt, "<blockquote>") == -1 ||
 373 df2db214 2022-09-19 op 		    tp_htmlescape(clt->clt_tp, line + 1) == -1 ||
 374 c9dc4bc6 2022-09-13 op 		    clt_puts(clt, "</blockquote>") == -1)
 375 c9dc4bc6 2022-09-13 op 			return (-1);
 376 c9dc4bc6 2022-09-13 op 		return (0);
 377 c9dc4bc6 2022-09-13 op 	}
 378 c9dc4bc6 2022-09-13 op 
 379 c9dc4bc6 2022-09-13 op 	/* headings */
 380 c9dc4bc6 2022-09-13 op 	if (!strncmp(line, "###", 3)) {
 381 c9dc4bc6 2022-09-13 op 		if (clt_puts(clt, "<h3>") == -1 ||
 382 df2db214 2022-09-19 op 		    tp_htmlescape(clt->clt_tp, line + 3) == -1 ||
 383 c9dc4bc6 2022-09-13 op 		    clt_puts(clt, "</h3>") == -1)
 384 c9dc4bc6 2022-09-13 op 			return (-1);
 385 c9dc4bc6 2022-09-13 op 		return (0);
 386 c9dc4bc6 2022-09-13 op 	}
 387 c9dc4bc6 2022-09-13 op 	if (!strncmp(line, "##", 2)) {
 388 c9dc4bc6 2022-09-13 op 		if (clt_puts(clt, "<h2>") == -1 ||
 389 df2db214 2022-09-19 op 		    tp_htmlescape(clt->clt_tp, line + 2) == -1 ||
 390 c9dc4bc6 2022-09-13 op 		    clt_puts(clt, "</h2>") == -1)
 391 c9dc4bc6 2022-09-13 op 			return (-1);
 392 c9dc4bc6 2022-09-13 op 		return (0);
 393 b0a6bcf7 2022-09-13 op 	}
 394 c9dc4bc6 2022-09-13 op 	if (!strncmp(line, "#", 1)) {
 395 c9dc4bc6 2022-09-13 op 		if (clt_puts(clt, "<h1>") == -1 ||
 396 df2db214 2022-09-19 op 		    tp_htmlescape(clt->clt_tp, line + 1) == -1 ||
 397 c9dc4bc6 2022-09-13 op 		    clt_puts(clt, "</h1>") == -1)
 398 c9dc4bc6 2022-09-13 op 			return (-1);
 399 c9dc4bc6 2022-09-13 op 		return (0);
 400 c9dc4bc6 2022-09-13 op 	}
 401 df5279ca 2022-09-14 op 
 402 df5279ca 2022-09-14 op 	/* Not following strictly the gemini specification... */
 403 df5279ca 2022-09-14 op 	if (*line == '\0')
 404 df5279ca 2022-09-14 op 		return (0);
 405 b0a6bcf7 2022-09-13 op 
 406 c9dc4bc6 2022-09-13 op 	/* paragraph */
 407 c9dc4bc6 2022-09-13 op 	if (clt_puts(clt, "<p>") == -1 ||
 408 df2db214 2022-09-19 op 	    tp_htmlescape(clt->clt_tp, line) == -1 ||
 409 c9dc4bc6 2022-09-13 op 	    clt_puts(clt, "</p>") == -1)
 410 c9dc4bc6 2022-09-13 op 		return (-1);
 411 b9de0a74 2022-09-14 op 
 412 b0a6bcf7 2022-09-13 op 	return (0);
 413 b0a6bcf7 2022-09-13 op }
 414 b0a6bcf7 2022-09-13 op 
 415 c9dc4bc6 2022-09-13 op void
 416 c9dc4bc6 2022-09-13 op proxy_translate_gemtext(struct client *clt)
 417 c9dc4bc6 2022-09-13 op {
 418 c9dc4bc6 2022-09-13 op 	struct bufferevent	*bev = clt->clt_bev;
 419 c9dc4bc6 2022-09-13 op 	struct evbuffer		*src = EVBUFFER_INPUT(bev);
 420 c9dc4bc6 2022-09-13 op 	char			*line;
 421 c9dc4bc6 2022-09-13 op 	size_t			 len;
 422 c9dc4bc6 2022-09-13 op 	int			 r;
 423 c9dc4bc6 2022-09-13 op 
 424 c9dc4bc6 2022-09-13 op 	for (;;) {
 425 b9de0a74 2022-09-14 op 		line = evbuffer_readln(src, &len, EVBUFFER_EOL_CRLF);
 426 c9dc4bc6 2022-09-13 op 		if (line == NULL)
 427 c9dc4bc6 2022-09-13 op 			return;
 428 c9dc4bc6 2022-09-13 op 
 429 c9dc4bc6 2022-09-13 op 		r = gemtext_translate_line(clt, line);
 430 c9dc4bc6 2022-09-13 op 		free(line);
 431 c9dc4bc6 2022-09-13 op 		if (r == -1)
 432 c9dc4bc6 2022-09-13 op 			return;
 433 c9dc4bc6 2022-09-13 op 	}
 434 c9dc4bc6 2022-09-13 op }
 435 c9dc4bc6 2022-09-13 op 
 436 f774ad1e 2022-09-23 op struct proxy_config *
 437 f774ad1e 2022-09-23 op proxy_match(struct galileo *env, const char *name)
 438 b0a6bcf7 2022-09-13 op {
 439 afb86b2c 2022-09-23 op 	struct proxy		*pr;
 440 b0a6bcf7 2022-09-13 op 
 441 f774ad1e 2022-09-23 op 	if (name == NULL)
 442 c9e6d547 2022-09-23 op 		return (NULL);
 443 b0a6bcf7 2022-09-13 op 
 444 afb86b2c 2022-09-23 op 	TAILQ_FOREACH(pr, &env->sc_proxies, pr_entry) {
 445 f774ad1e 2022-09-23 op 		if (!strcmp(name, pr->pr_conf.host))
 446 c9e6d547 2022-09-23 op 			return (&pr->pr_conf);
 447 b0a6bcf7 2022-09-13 op 	}
 448 b0a6bcf7 2022-09-13 op 
 449 c9e6d547 2022-09-23 op 	return (NULL);
 450 b0a6bcf7 2022-09-13 op }
 451 b0a6bcf7 2022-09-13 op 
 452 8857131d 2022-09-20 op int
 453 b0a6bcf7 2022-09-13 op proxy_start_request(struct galileo *env, struct client *clt)
 454 b0a6bcf7 2022-09-13 op {
 455 b0a6bcf7 2022-09-13 op 	struct addrinfo		 hints;
 456 b0a6bcf7 2022-09-13 op 	struct asr_query	*query;
 457 8857131d 2022-09-20 op 	int			 r;
 458 26cd3e9d 2022-09-23 op 	char			*url;
 459 b0a6bcf7 2022-09-13 op 
 460 f33634c5 2022-09-30 op 	if (clt->clt_path_info == NULL) {
 461 f33634c5 2022-09-30 op 		log_warnx("PATH_INFO not defined!");
 462 f33634c5 2022-09-30 op 		if (proxy_start_reply(clt, 501, "text/html") == -1)
 463 f33634c5 2022-09-30 op 			return (-1);
 464 056e82d3 2022-09-30 op 		if (tp_error(clt->clt_tp, -1, "internal server error") == -1)
 465 f33634c5 2022-09-30 op 			return (-1);
 466 f33634c5 2022-09-30 op 		return (fcgi_end_request(clt, 1));
 467 f33634c5 2022-09-30 op 	}
 468 f33634c5 2022-09-30 op 
 469 f774ad1e 2022-09-23 op 	if ((clt->clt_pc = proxy_match(env, clt->clt_server_name)) == NULL) {
 470 e3c1cbab 2022-09-20 op 		if (proxy_start_reply(clt, 501, "text/html") == -1)
 471 8857131d 2022-09-20 op 			return (-1);
 472 abe17781 2022-09-20 op 		if (tp_error(clt->clt_tp, -1, "unknown server") == -1)
 473 8857131d 2022-09-20 op 			return (-1);
 474 8857131d 2022-09-20 op 		return (fcgi_end_request(clt, 1));
 475 8857131d 2022-09-20 op 	}
 476 8857131d 2022-09-20 op 
 477 8857131d 2022-09-20 op 	if (clt->clt_bodylen != 0 && clt->clt_body == NULL) {
 478 8857131d 2022-09-20 op 		if (proxy_start_reply(clt, 400, "text/html") == -1)
 479 8857131d 2022-09-20 op 			return (-1);
 480 8857131d 2022-09-20 op 		if (tp_error(clt->clt_tp, -1, "bad request") == -1)
 481 8857131d 2022-09-20 op 			return (-1);
 482 8857131d 2022-09-20 op 		return (fcgi_end_request(clt, 1));
 483 b0a6bcf7 2022-09-13 op 	}
 484 b0a6bcf7 2022-09-13 op 
 485 8857131d 2022-09-20 op 	if (clt->clt_body) {
 486 8857131d 2022-09-20 op 		r = asprintf(&url, "%s%s?%s", clt->clt_script_name,
 487 8857131d 2022-09-20 op 		    clt->clt_path_info + 1, clt->clt_body);
 488 8857131d 2022-09-20 op 		if (r == -1)
 489 8857131d 2022-09-20 op 			return (fcgi_end_request(clt, 1));
 490 8857131d 2022-09-20 op 
 491 8857131d 2022-09-20 op 		if (proxy_start_reply(clt, 302, url) == -1 ||
 492 8857131d 2022-09-20 op 		    fcgi_end_request(clt, 1) == -1) {
 493 8857131d 2022-09-20 op 			free(url);
 494 8857131d 2022-09-20 op 			return (-1);
 495 8857131d 2022-09-20 op 		}
 496 8857131d 2022-09-20 op 		free(url);
 497 8857131d 2022-09-20 op 		return (0);
 498 8857131d 2022-09-20 op 	}
 499 8857131d 2022-09-20 op 
 500 b0a6bcf7 2022-09-13 op 	memset(&hints, 0, sizeof(hints));
 501 b0a6bcf7 2022-09-13 op 	hints.ai_family = AF_UNSPEC;
 502 b0a6bcf7 2022-09-13 op 	hints.ai_socktype = SOCK_STREAM;
 503 b0a6bcf7 2022-09-13 op 
 504 26cd3e9d 2022-09-23 op 	query = getaddrinfo_async(clt->clt_pc->proxy_addr,
 505 26cd3e9d 2022-09-23 op 	    clt->clt_pc->proxy_port, &hints, NULL);
 506 b0a6bcf7 2022-09-13 op 	if (query == NULL) {
 507 b0a6bcf7 2022-09-13 op 		log_warn("getaddrinfo_async");
 508 8857131d 2022-09-20 op 		return (fcgi_abort_request(clt));
 509 b0a6bcf7 2022-09-13 op 	}
 510 b0a6bcf7 2022-09-13 op 
 511 b0a6bcf7 2022-09-13 op 	clt->clt_evasr = event_asr_run(query, proxy_resolved, clt);
 512 b0a6bcf7 2022-09-13 op 	if (clt->clt_evasr == NULL) {
 513 b0a6bcf7 2022-09-13 op 		log_warn("event_asr_run");
 514 b0a6bcf7 2022-09-13 op 		asr_abort(query);
 515 8857131d 2022-09-20 op 		return (fcgi_abort_request(clt));
 516 b0a6bcf7 2022-09-13 op 	}
 517 8857131d 2022-09-20 op 
 518 8857131d 2022-09-20 op 	return (0);
 519 b0a6bcf7 2022-09-13 op }
 520 b0a6bcf7 2022-09-13 op 
 521 b0a6bcf7 2022-09-13 op void
 522 b0a6bcf7 2022-09-13 op proxy_resolved(struct asr_result *res, void *d)
 523 b0a6bcf7 2022-09-13 op {
 524 b0a6bcf7 2022-09-13 op 	struct client		*clt = d;
 525 b0a6bcf7 2022-09-13 op 	struct proxy_config	*pc = clt->clt_pc;
 526 b0a6bcf7 2022-09-13 op 
 527 b0a6bcf7 2022-09-13 op 	clt->clt_evasr = NULL;
 528 b0a6bcf7 2022-09-13 op 
 529 b0a6bcf7 2022-09-13 op 	if (res->ar_gai_errno != 0) {
 530 26cd3e9d 2022-09-23 op 		log_warnx("failed to resolve %s:%s: %s",
 531 b0a6bcf7 2022-09-13 op 		    pc->proxy_addr, pc->proxy_port,
 532 b0a6bcf7 2022-09-13 op 		    gai_strerror(res->ar_gai_errno));
 533 e3c1cbab 2022-09-20 op 		if (proxy_start_reply(clt, 501, "text/html") == -1)
 534 b0a6bcf7 2022-09-13 op 			return;
 535 abe17781 2022-09-20 op 		if (tp_error(clt->clt_tp, -1, "Can't resolve host") == -1)
 536 b0a6bcf7 2022-09-13 op 			return;
 537 b0a6bcf7 2022-09-13 op 		fcgi_end_request(clt, 1);
 538 b0a6bcf7 2022-09-13 op 		return;
 539 b0a6bcf7 2022-09-13 op 	}
 540 b0a6bcf7 2022-09-13 op 
 541 b0a6bcf7 2022-09-13 op 	clt->clt_addrinfo = res->ar_addrinfo;
 542 b0a6bcf7 2022-09-13 op 	clt->clt_p = clt->clt_addrinfo;
 543 b0a6bcf7 2022-09-13 op 	proxy_connect(-1, 0, clt);
 544 b0a6bcf7 2022-09-13 op }
 545 b0a6bcf7 2022-09-13 op 
 546 b0a6bcf7 2022-09-13 op void
 547 b0a6bcf7 2022-09-13 op proxy_connect(int fd, short ev, void *d)
 548 b0a6bcf7 2022-09-13 op {
 549 b0a6bcf7 2022-09-13 op 	struct client		*clt = d;
 550 b0a6bcf7 2022-09-13 op 	struct evbuffer		*out;
 551 b0a6bcf7 2022-09-13 op 	struct addrinfo		*p;
 552 b0a6bcf7 2022-09-13 op 	struct tls_config	*conf;
 553 b0a6bcf7 2022-09-13 op 	struct timeval		 conntv = {5, 0};
 554 b0a6bcf7 2022-09-13 op 	int			 err = 0;
 555 b0a6bcf7 2022-09-13 op 	socklen_t		 len = sizeof(err);
 556 b0a6bcf7 2022-09-13 op 
 557 b0a6bcf7 2022-09-13 op again:
 558 b0a6bcf7 2022-09-13 op 	if (clt->clt_p == NULL)
 559 b0a6bcf7 2022-09-13 op 		goto err;
 560 b0a6bcf7 2022-09-13 op 
 561 b0a6bcf7 2022-09-13 op 	if (clt->clt_fd != -1) {
 562 b0a6bcf7 2022-09-13 op 		if (getsockopt(clt->clt_fd, SOL_SOCKET, SO_ERROR, &err, &len)
 563 b0a6bcf7 2022-09-13 op 		    == -1)
 564 b0a6bcf7 2022-09-13 op 			goto err;
 565 b0a6bcf7 2022-09-13 op 		if (err != 0) {
 566 b0a6bcf7 2022-09-13 op 			errno = err;
 567 b0a6bcf7 2022-09-13 op 			goto err;
 568 b0a6bcf7 2022-09-13 op 		}
 569 b0a6bcf7 2022-09-13 op 		goto done;
 570 b0a6bcf7 2022-09-13 op 	}
 571 b0a6bcf7 2022-09-13 op 
 572 b0a6bcf7 2022-09-13 op 	p = clt->clt_p;
 573 b0a6bcf7 2022-09-13 op 	clt->clt_fd = socket(p->ai_family, p->ai_socktype | SOCK_NONBLOCK,
 574 b0a6bcf7 2022-09-13 op 	    p->ai_protocol);
 575 b0a6bcf7 2022-09-13 op 	if (clt->clt_fd == -1) {
 576 b0a6bcf7 2022-09-13 op 		clt->clt_p = clt->clt_p->ai_next;
 577 b0a6bcf7 2022-09-13 op 		goto again;
 578 b0a6bcf7 2022-09-13 op 	}
 579 b0a6bcf7 2022-09-13 op 
 580 b0a6bcf7 2022-09-13 op 	if (connect(clt->clt_fd, p->ai_addr, p->ai_addrlen) == 0)
 581 b0a6bcf7 2022-09-13 op 		goto done;
 582 b0a6bcf7 2022-09-13 op 
 583 b0a6bcf7 2022-09-13 op 	clt->clt_evconn_live = 1;
 584 b0a6bcf7 2022-09-13 op 	event_set(&clt->clt_evconn, clt->clt_fd, EV_WRITE, proxy_connect, clt);
 585 b0a6bcf7 2022-09-13 op 	event_add(&clt->clt_evconn, &conntv);
 586 b0a6bcf7 2022-09-13 op 	return;
 587 b0a6bcf7 2022-09-13 op 
 588 b0a6bcf7 2022-09-13 op done:
 589 b0a6bcf7 2022-09-13 op 	clt->clt_evconn_live = 0;
 590 b0a6bcf7 2022-09-13 op 	freeaddrinfo(clt->clt_addrinfo);
 591 b0a6bcf7 2022-09-13 op 	clt->clt_addrinfo = clt->clt_p = NULL;
 592 b0a6bcf7 2022-09-13 op 
 593 c743c9a1 2022-09-23 op 	clt->clt_bev = bufferevent_new(clt->clt_fd, proxy_read, proxy_write,
 594 c743c9a1 2022-09-23 op 	    proxy_error, clt);
 595 c743c9a1 2022-09-23 op 	if (clt->clt_bev == NULL) {
 596 c743c9a1 2022-09-23 op 		log_warn("bufferevent_new");
 597 b0a6bcf7 2022-09-13 op 		goto err;
 598 b0a6bcf7 2022-09-13 op 	}
 599 b0a6bcf7 2022-09-13 op 
 600 da7b17a3 2023-03-03 op 	if (!(clt->clt_pc->flags & PROXY_NO_TLS)) {
 601 c743c9a1 2022-09-23 op 		/* initialize TLS for Gemini */
 602 c743c9a1 2022-09-23 op 		if ((conf = tls_config_new()) == NULL) {
 603 c743c9a1 2022-09-23 op 			log_warn("tls_config_new failed");
 604 c743c9a1 2022-09-23 op 			goto err;
 605 c743c9a1 2022-09-23 op 		}
 606 b0a6bcf7 2022-09-13 op 
 607 c743c9a1 2022-09-23 op 		tls_config_insecure_noverifycert(conf);
 608 b0a6bcf7 2022-09-13 op 
 609 c743c9a1 2022-09-23 op 		if ((clt->clt_ctx = tls_client()) == NULL) {
 610 c743c9a1 2022-09-23 op 			log_warnx("tls_client failed");
 611 c743c9a1 2022-09-23 op 			tls_config_free(conf);
 612 c743c9a1 2022-09-23 op 			goto err;
 613 c743c9a1 2022-09-23 op 		}
 614 c743c9a1 2022-09-23 op 
 615 c743c9a1 2022-09-23 op 		if (tls_configure(clt->clt_ctx, conf) == -1) {
 616 c743c9a1 2022-09-23 op 			log_warnx("tls_configure failed");
 617 c743c9a1 2022-09-23 op 			tls_config_free(conf);
 618 c743c9a1 2022-09-23 op 			goto err;
 619 c743c9a1 2022-09-23 op 		}
 620 b0a6bcf7 2022-09-13 op 
 621 c743c9a1 2022-09-23 op 		tls_config_free(conf);
 622 b0a6bcf7 2022-09-13 op 
 623 c743c9a1 2022-09-23 op 		if (tls_connect_socket(clt->clt_ctx, clt->clt_fd,
 624 c743c9a1 2022-09-23 op 			clt->clt_pc->proxy_name) == -1) {
 625 c743c9a1 2022-09-23 op 			log_warnx("tls_connect_socket failed");
 626 c743c9a1 2022-09-23 op 			goto err;
 627 c743c9a1 2022-09-23 op 		}
 628 b0a6bcf7 2022-09-13 op 
 629 c743c9a1 2022-09-23 op 		event_set(&clt->clt_bev->ev_read, clt->clt_fd, EV_READ,
 630 c743c9a1 2022-09-23 op 		    proxy_tls_readcb, clt->clt_bev);
 631 c743c9a1 2022-09-23 op 		event_set(&clt->clt_bev->ev_write, clt->clt_fd, EV_WRITE,
 632 c743c9a1 2022-09-23 op 		    proxy_tls_writecb, clt->clt_bev);
 633 83f0f95a 2022-09-29 op 
 634 83f0f95a 2022-09-29 op #if HAVE_LIBEVENT2
 635 83f0f95a 2022-09-29 op 		evbuffer_unfreeze(clt->clt_bev->input, 0);
 636 83f0f95a 2022-09-29 op 		evbuffer_unfreeze(clt->clt_bev->output, 1);
 637 83f0f95a 2022-09-29 op #endif
 638 c743c9a1 2022-09-23 op 	}
 639 b0a6bcf7 2022-09-13 op 
 640 b0a6bcf7 2022-09-13 op 	/* bufferevent_settimeout(); */
 641 b0a6bcf7 2022-09-13 op 	bufferevent_enable(clt->clt_bev, EV_READ|EV_WRITE);
 642 b0a6bcf7 2022-09-13 op 
 643 b0a6bcf7 2022-09-13 op 	/* TODO: compute the URL */
 644 c743c9a1 2022-09-23 op 	out = EVBUFFER_OUTPUT(clt->clt_bev);
 645 28239bac 2022-09-20 op 	if (evbuffer_add_printf(out, "gemini://%s/%s",
 646 ee80262d 2022-09-13 op 	    clt->clt_pc->proxy_name, clt->clt_path_info) == -1) {
 647 28239bac 2022-09-20 op 		log_warn("bufferevent_printf failed");
 648 28239bac 2022-09-20 op 		goto err;
 649 28239bac 2022-09-20 op 	}
 650 28239bac 2022-09-20 op 
 651 28239bac 2022-09-20 op 	if (clt->clt_query &&
 652 28239bac 2022-09-20 op 	    evbuffer_add_printf(out, "?%s", clt->clt_query) == -1) {
 653 b0a6bcf7 2022-09-13 op 		log_warn("bufferevent_printf failed");
 654 28239bac 2022-09-20 op 		goto err;
 655 28239bac 2022-09-20 op 	}
 656 28239bac 2022-09-20 op 
 657 28239bac 2022-09-20 op 	if (evbuffer_add(out, "\r\n", 2) == -1) {
 658 28239bac 2022-09-20 op 		log_warn("bufferevent_add failed");
 659 b0a6bcf7 2022-09-13 op 		goto err;
 660 b0a6bcf7 2022-09-13 op 	}
 661 b0a6bcf7 2022-09-13 op 
 662 b0a6bcf7 2022-09-13 op 	return;
 663 b0a6bcf7 2022-09-13 op 
 664 b0a6bcf7 2022-09-13 op err:
 665 26cd3e9d 2022-09-23 op 	log_warn("failed to connect to %s:%s",
 666 b0a6bcf7 2022-09-13 op 	    clt->clt_pc->proxy_addr, clt->clt_pc->proxy_port);
 667 e3c1cbab 2022-09-20 op 	if (proxy_start_reply(clt, 501, "text/html") == -1)
 668 b0a6bcf7 2022-09-13 op 		return;
 669 abe17781 2022-09-20 op 	if (tp_error(clt->clt_tp, -1, "Can't connect") == -1)
 670 b0a6bcf7 2022-09-13 op 		return;
 671 b0a6bcf7 2022-09-13 op 	fcgi_end_request(clt, 1);
 672 6edd9a00 2022-09-14 op }
 673 6edd9a00 2022-09-14 op 
 674 6edd9a00 2022-09-14 op static inline int
 675 6edd9a00 2022-09-14 op parse_mime(struct client *clt, char *mime, char *lang, size_t len)
 676 6edd9a00 2022-09-14 op {
 677 6edd9a00 2022-09-14 op 	char			*t, *semi;
 678 6edd9a00 2022-09-14 op 
 679 6edd9a00 2022-09-14 op 	if (strncmp(mime, "text/gemini", 11) != 0)
 680 6edd9a00 2022-09-14 op 		return (0);
 681 6edd9a00 2022-09-14 op 
 682 6edd9a00 2022-09-14 op 	clt->clt_translate = TR_ENABLED;
 683 6edd9a00 2022-09-14 op 
 684 6edd9a00 2022-09-14 op 	if ((mime = strchr(mime, ';')) == NULL)
 685 6edd9a00 2022-09-14 op 		return (0);
 686 6edd9a00 2022-09-14 op 
 687 6edd9a00 2022-09-14 op 	*mime++ = '\0';
 688 6edd9a00 2022-09-14 op 	while ((t = strsep(&mime, ";")) != NULL) {
 689 6edd9a00 2022-09-14 op 		if (!strncmp(t, "charset=", 8)) {
 690 6edd9a00 2022-09-14 op 			t += 8;
 691 6edd9a00 2022-09-14 op 			if (!strncasecmp(t, "utf8", 4) ||
 692 8ab2d60e 2022-09-14 op 			    !strncasecmp(t, "utf-8", 5) ||
 693 6edd9a00 2022-09-14 op 			    !strncasecmp(t, "ascii", 5)) {
 694 6edd9a00 2022-09-14 op 				log_debug("unknown charset %s", t);
 695 6edd9a00 2022-09-14 op 				return (-1);
 696 6edd9a00 2022-09-14 op 			}
 697 6edd9a00 2022-09-14 op 			continue;
 698 6edd9a00 2022-09-14 op 		}
 699 6edd9a00 2022-09-14 op 
 700 6edd9a00 2022-09-14 op 		if (!strncmp(t, "lang=", 5)) {
 701 6edd9a00 2022-09-14 op 			t += 5;
 702 6edd9a00 2022-09-14 op 			if ((semi = strchr(t, ';')) != NULL)
 703 6edd9a00 2022-09-14 op 				*semi = '\0';
 704 6edd9a00 2022-09-14 op 
 705 6edd9a00 2022-09-14 op 			if (strlcpy(lang, t, len) >= len) {
 706 6edd9a00 2022-09-14 op 				log_debug("lang too long: %s", t);
 707 6edd9a00 2022-09-14 op 				*lang = '\0';
 708 6edd9a00 2022-09-14 op 			}
 709 6edd9a00 2022-09-14 op 
 710 6edd9a00 2022-09-14 op 			if (semi)
 711 6edd9a00 2022-09-14 op 				*semi = ';';
 712 6edd9a00 2022-09-14 op 			continue;
 713 6edd9a00 2022-09-14 op 		}
 714 bff58270 2022-09-19 op 	}
 715 bff58270 2022-09-19 op 
 716 6edd9a00 2022-09-14 op 	return (0);
 717 b0a6bcf7 2022-09-13 op }
 718 5163fbe9 2022-09-20 op 
 719 5163fbe9 2022-09-20 op int
 720 5163fbe9 2022-09-20 op proxy_start_reply(struct client *clt, int status, const char *ctype)
 721 5163fbe9 2022-09-20 op {
 722 5163fbe9 2022-09-20 op 	const char	*csp;
 723 b0a6bcf7 2022-09-13 op 
 724 5163fbe9 2022-09-20 op 	csp = "Content-Security-Policy: default-src 'self'; "
 725 5163fbe9 2022-09-20 op 	    "script-src 'none'; object-src 'none';\r\n";
 726 5163fbe9 2022-09-20 op 
 727 5163fbe9 2022-09-20 op 	if (status != 200 &&
 728 2df73ca5 2022-09-20 op 	    clt_printf(clt, "Status: %d\r\n", status) == -1)
 729 5163fbe9 2022-09-20 op 		return (-1);
 730 5163fbe9 2022-09-20 op 
 731 2df73ca5 2022-09-20 op 	if (clt_puts(clt, csp) == -1)
 732 5163fbe9 2022-09-20 op 		return (-1);
 733 8857131d 2022-09-20 op 
 734 8857131d 2022-09-20 op 	if (status == 302) {
 735 8857131d 2022-09-20 op 		/* use "ctype" as redirect target */
 736 8857131d 2022-09-20 op 		if (clt_printf(clt, "Location: %s\r\n", ctype) == -1)
 737 8857131d 2022-09-20 op 			return (-1);
 738 8857131d 2022-09-20 op 		if (clt_puts(clt, "\r\n") == -1)
 739 8857131d 2022-09-20 op 			return (-1);
 740 8857131d 2022-09-20 op 		return (0);
 741 8857131d 2022-09-20 op 	}
 742 5163fbe9 2022-09-20 op 
 743 8857131d 2022-09-20 op 	if (ctype != NULL) {
 744 8857131d 2022-09-20 op 		if (!strcmp(ctype, "text/html"))
 745 8857131d 2022-09-20 op 			ctype = "text/html;charset=utf-8";
 746 8857131d 2022-09-20 op 		if (clt_printf(clt, "Content-Type: %s\r\n", ctype)
 747 8857131d 2022-09-20 op 		    == -1)
 748 8857131d 2022-09-20 op 			return (-1);
 749 8857131d 2022-09-20 op 	}
 750 8857131d 2022-09-20 op 
 751 5163fbe9 2022-09-20 op 	if (clt_puts(clt, "\r\n") == -1)
 752 5163fbe9 2022-09-20 op 		return (-1);
 753 5163fbe9 2022-09-20 op 
 754 5163fbe9 2022-09-20 op 	return (0);
 755 5163fbe9 2022-09-20 op }
 756 5163fbe9 2022-09-20 op 
 757 b0a6bcf7 2022-09-13 op void
 758 b0a6bcf7 2022-09-13 op proxy_read(struct bufferevent *bev, void *d)
 759 b0a6bcf7 2022-09-13 op {
 760 b0a6bcf7 2022-09-13 op 	struct client		*clt = d;
 761 b0a6bcf7 2022-09-13 op 	struct evbuffer		*src = EVBUFFER_INPUT(bev);
 762 c9dc4bc6 2022-09-13 op 	const char		*ctype;
 763 cb05cce7 2022-11-11 op 	char			 buf[1025];
 764 6edd9a00 2022-09-14 op 	char			 lang[16];
 765 6edd9a00 2022-09-14 op 	char			*hdr, *mime;
 766 b0a6bcf7 2022-09-13 op 	size_t			 len;
 767 abe17781 2022-09-20 op 	int			 code;
 768 b0a6bcf7 2022-09-13 op 
 769 b0a6bcf7 2022-09-13 op 	if (clt->clt_headersdone) {
 770 c9dc4bc6 2022-09-13 op 		if (clt->clt_translate)
 771 c9dc4bc6 2022-09-13 op 			proxy_translate_gemtext(clt);
 772 c9dc4bc6 2022-09-13 op 		else
 773 c9dc4bc6 2022-09-13 op 			clt_write_bufferevent(clt, bev);
 774 b0a6bcf7 2022-09-13 op 		return;
 775 b0a6bcf7 2022-09-13 op 	}
 776 b0a6bcf7 2022-09-13 op 
 777 b0a6bcf7 2022-09-13 op 	hdr = evbuffer_readln(src, &len, EVBUFFER_EOL_CRLF_STRICT);
 778 b0a6bcf7 2022-09-13 op 	if (hdr == NULL) {
 779 b0a6bcf7 2022-09-13 op 		if (EVBUFFER_LENGTH(src) >= 1026)
 780 b0a6bcf7 2022-09-13 op 			proxy_error(bev, EV_READ, clt);
 781 b0a6bcf7 2022-09-13 op 		return;
 782 b0a6bcf7 2022-09-13 op 	}
 783 b0a6bcf7 2022-09-13 op 
 784 b0a6bcf7 2022-09-13 op 	if (len < 4 ||
 785 b0a6bcf7 2022-09-13 op 	    !isdigit((unsigned char)hdr[0]) ||
 786 b0a6bcf7 2022-09-13 op 	    !isdigit((unsigned char)hdr[1]) ||
 787 b0a6bcf7 2022-09-13 op 	    hdr[2] != ' ') {
 788 b0a6bcf7 2022-09-13 op 		log_warnx("invalid ");
 789 b0a6bcf7 2022-09-13 op 		proxy_error(bev, EV_READ, clt);
 790 1337dc2b 2022-09-14 op 		goto err;
 791 b0a6bcf7 2022-09-13 op 	}
 792 b0a6bcf7 2022-09-13 op 
 793 abe17781 2022-09-20 op 	code = (hdr[0] - '0') * 10 + (hdr[1] - '0');
 794 abe17781 2022-09-20 op 
 795 6e8f426e 2022-09-14 op 	switch (hdr[0]) {
 796 8857131d 2022-09-20 op 	case '1':
 797 8857131d 2022-09-20 op 		if (proxy_start_reply(clt, 200, "text/html") == -1)
 798 8857131d 2022-09-20 op 			goto err;
 799 8857131d 2022-09-20 op 		if (tp_inputpage(clt->clt_tp, &hdr[3]) == -1)
 800 8857131d 2022-09-20 op 			goto err;
 801 8857131d 2022-09-20 op 		fcgi_end_request(clt, 0);
 802 8857131d 2022-09-20 op 		goto err;
 803 6e8f426e 2022-09-14 op 	case '2':
 804 6e8f426e 2022-09-14 op 		/* handled below */
 805 6e8f426e 2022-09-14 op 		break;
 806 b4f7fe4f 2022-09-21 op 	case '3':
 807 cb05cce7 2022-11-11 op 		if (proxy_resurl(clt, &hdr[3], buf, sizeof(buf)) == 0) {
 808 cb05cce7 2022-11-11 op 			if (proxy_start_reply(clt, 302, buf) == -1)
 809 b4f7fe4f 2022-09-21 op 				goto err;
 810 b4f7fe4f 2022-09-21 op 			fcgi_end_request(clt, 0);
 811 b4f7fe4f 2022-09-21 op 			goto err;
 812 b4f7fe4f 2022-09-21 op 		}
 813 02be3606 2022-09-29 op 		/* fallthrough */
 814 6e8f426e 2022-09-14 op 	default:
 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, code, &hdr[3]) == -1)
 818 1337dc2b 2022-09-14 op 			goto err;
 819 6e8f426e 2022-09-14 op 		fcgi_end_request(clt, 1);
 820 1337dc2b 2022-09-14 op 		goto err;
 821 b0a6bcf7 2022-09-13 op 	}
 822 b0a6bcf7 2022-09-13 op 
 823 6edd9a00 2022-09-14 op 	mime = hdr + 2 + strspn(hdr + 2, " \t");
 824 6edd9a00 2022-09-14 op 	if (parse_mime(clt, mime, lang, sizeof(lang)) == -1) {
 825 e3c1cbab 2022-09-20 op 		if (proxy_start_reply(clt, 501, "text/html") == -1)
 826 1337dc2b 2022-09-14 op 			goto err;
 827 abe17781 2022-09-20 op 		if (tp_error(clt->clt_tp, -1, "Bad response") == -1)
 828 e3c1cbab 2022-09-20 op 			goto err;
 829 6edd9a00 2022-09-14 op 		fcgi_end_request(clt, 1);
 830 1337dc2b 2022-09-14 op 		goto err;
 831 6edd9a00 2022-09-14 op 	}
 832 bff58270 2022-09-19 op 
 833 232eee45 2022-09-20 op 	if (clt->clt_translate)
 834 8ab2d60e 2022-09-14 op 		ctype = "text/html;charset=utf-8";
 835 232eee45 2022-09-20 op 	else
 836 6edd9a00 2022-09-14 op 		ctype = mime;
 837 6edd9a00 2022-09-14 op 
 838 6edd9a00 2022-09-14 op 	if (clt_printf(clt, "Content-Type: %s\r\n\r\n", ctype) == -1)
 839 1337dc2b 2022-09-14 op 		goto err;
 840 b0a6bcf7 2022-09-13 op 
 841 b0a6bcf7 2022-09-13 op 	clt->clt_headersdone = 1;
 842 c9dc4bc6 2022-09-13 op 
 843 bff58270 2022-09-19 op 	if (clt->clt_translate &&
 844 e3c1cbab 2022-09-20 op 	    tp_head(clt->clt_tp, lang, NULL) == -1)
 845 bff58270 2022-09-19 op 		goto err;
 846 c9dc4bc6 2022-09-13 op 
 847 1337dc2b 2022-09-14 op 	/*
 848 1337dc2b 2022-09-14 op 	 * Trigger the read again so we proceed with the response
 849 1337dc2b 2022-09-14 op 	 * body, if any.
 850 1337dc2b 2022-09-14 op 	 */
 851 1337dc2b 2022-09-14 op 	free(hdr);
 852 1337dc2b 2022-09-14 op 	proxy_read(bev, d);
 853 1337dc2b 2022-09-14 op 	return;
 854 1337dc2b 2022-09-14 op 
 855 1337dc2b 2022-09-14 op err:
 856 1337dc2b 2022-09-14 op 	free(hdr);
 857 b0a6bcf7 2022-09-13 op }
 858 b0a6bcf7 2022-09-13 op 
 859 b0a6bcf7 2022-09-13 op void
 860 b0a6bcf7 2022-09-13 op proxy_write(struct bufferevent *bev, void *d)
 861 b0a6bcf7 2022-09-13 op {
 862 b0a6bcf7 2022-09-13 op 	return;
 863 b0a6bcf7 2022-09-13 op }
 864 b0a6bcf7 2022-09-13 op 
 865 b0a6bcf7 2022-09-13 op void
 866 b0a6bcf7 2022-09-13 op proxy_error(struct bufferevent *bev, short err, void *d)
 867 b0a6bcf7 2022-09-13 op {
 868 b0a6bcf7 2022-09-13 op 	struct client		*clt = d;
 869 b0a6bcf7 2022-09-13 op 	int			 status = !(err & EVBUFFER_EOF);
 870 b0a6bcf7 2022-09-13 op 
 871 b0a6bcf7 2022-09-13 op 	log_debug("proxy error, shutting down the connection (err: %x)",
 872 b0a6bcf7 2022-09-13 op 	    err);
 873 b0a6bcf7 2022-09-13 op 
 874 b0a6bcf7 2022-09-13 op 	if (!clt->clt_headersdone) {
 875 e3c1cbab 2022-09-20 op 		if (proxy_start_reply(clt, 501, "text/html") == -1)
 876 b0a6bcf7 2022-09-13 op 			return;
 877 abe17781 2022-09-20 op 		if (tp_error(clt->clt_tp, -1, "Proxy error") == -1)
 878 b0a6bcf7 2022-09-13 op 			return;
 879 c9dc4bc6 2022-09-13 op 	} else if (status == 0) {
 880 c42fce9b 2022-09-14 op 		if (clt->clt_translate & TR_PRE) {
 881 ceb3f79c 2022-09-29 op 			if (tp_pre_close(clt->clt_tp))
 882 c42fce9b 2022-09-14 op 				return;
 883 c42fce9b 2022-09-14 op 			clt->clt_translate &= ~TR_PRE;
 884 c42fce9b 2022-09-14 op 		}
 885 c42fce9b 2022-09-14 op 
 886 c42fce9b 2022-09-14 op 		if (clt->clt_translate & TR_LIST) {
 887 c42fce9b 2022-09-14 op 			if (clt_puts(clt, "</ul>") == -1)
 888 c42fce9b 2022-09-14 op 				return;
 889 c42fce9b 2022-09-14 op 			clt->clt_translate &= ~TR_LIST;
 890 c42fce9b 2022-09-14 op 		}
 891 c42fce9b 2022-09-14 op 
 892 c42fce9b 2022-09-14 op 		if (clt->clt_translate & TR_NAV) {
 893 c42fce9b 2022-09-14 op 			if (clt_puts(clt, "</ul></nav>") == -1)
 894 c42fce9b 2022-09-14 op 				return;
 895 c42fce9b 2022-09-14 op 			clt->clt_translate &= ~TR_NAV;
 896 c42fce9b 2022-09-14 op 		}
 897 c42fce9b 2022-09-14 op 
 898 54acddc9 2022-09-19 op 		if (clt->clt_translate &&
 899 54acddc9 2022-09-19 op 		    tp_foot(clt->clt_tp) == -1)
 900 8fa3006a 2022-09-14 op 			return;
 901 b0a6bcf7 2022-09-13 op 	}
 902 b0a6bcf7 2022-09-13 op 
 903 b0a6bcf7 2022-09-13 op 	fcgi_end_request(clt, status);
 904 b0a6bcf7 2022-09-13 op }
 905 b0a6bcf7 2022-09-13 op 
 906 b0a6bcf7 2022-09-13 op void
 907 b0a6bcf7 2022-09-13 op proxy_tls_readcb(int fd, short event, void *arg)
 908 b0a6bcf7 2022-09-13 op {
 909 b0a6bcf7 2022-09-13 op 	struct bufferevent	*bufev = arg;
 910 b0a6bcf7 2022-09-13 op 	struct client		*clt = bufev->cbarg;
 911 b0a6bcf7 2022-09-13 op 	char			 rbuf[IBUF_READ_SIZE];
 912 b0a6bcf7 2022-09-13 op 	int			 what = EVBUFFER_READ;
 913 b0a6bcf7 2022-09-13 op 	int			 howmuch = IBUF_READ_SIZE;
 914 b0a6bcf7 2022-09-13 op 	ssize_t			 ret;
 915 b0a6bcf7 2022-09-13 op 	size_t			 len;
 916 b0a6bcf7 2022-09-13 op 
 917 b0a6bcf7 2022-09-13 op 	if (event == EV_TIMEOUT) {
 918 b0a6bcf7 2022-09-13 op 		what |= EVBUFFER_TIMEOUT;
 919 b0a6bcf7 2022-09-13 op 		goto err;
 920 b0a6bcf7 2022-09-13 op 	}
 921 b0a6bcf7 2022-09-13 op 
 922 b0a6bcf7 2022-09-13 op 	if (bufev->wm_read.high != 0)
 923 b0a6bcf7 2022-09-13 op 		howmuch = MINIMUM(sizeof(rbuf), bufev->wm_read.high);
 924 b0a6bcf7 2022-09-13 op 
 925 b0a6bcf7 2022-09-13 op 	ret = tls_read(clt->clt_ctx, rbuf, howmuch);
 926 b0a6bcf7 2022-09-13 op 	if (ret == TLS_WANT_POLLIN || ret == TLS_WANT_POLLOUT) {
 927 b0a6bcf7 2022-09-13 op 		goto retry;
 928 b0a6bcf7 2022-09-13 op 	} else if (ret == -1) {
 929 b0a6bcf7 2022-09-13 op 		what |= EVBUFFER_ERROR;
 930 b0a6bcf7 2022-09-13 op 		goto err;
 931 b0a6bcf7 2022-09-13 op 	}
 932 b0a6bcf7 2022-09-13 op 	len = ret;
 933 b0a6bcf7 2022-09-13 op 
 934 b0a6bcf7 2022-09-13 op 	if (len == 0) {
 935 b0a6bcf7 2022-09-13 op 		what |= EVBUFFER_EOF;
 936 b0a6bcf7 2022-09-13 op 		goto err;
 937 b0a6bcf7 2022-09-13 op 	}
 938 b0a6bcf7 2022-09-13 op 
 939 b0a6bcf7 2022-09-13 op 	if (evbuffer_add(bufev->input, rbuf, len) == -1) {
 940 b0a6bcf7 2022-09-13 op 		what |= EVBUFFER_ERROR;
 941 b0a6bcf7 2022-09-13 op 		goto err;
 942 b0a6bcf7 2022-09-13 op 	}
 943 b0a6bcf7 2022-09-13 op 
 944 83f0f95a 2022-09-29 op 	proxy_bufferevent_add(&bufev->ev_read, G_TOUT(bufev->timeout_read));
 945 b0a6bcf7 2022-09-13 op 
 946 b0a6bcf7 2022-09-13 op 	len = EVBUFFER_LENGTH(bufev->input);
 947 b0a6bcf7 2022-09-13 op 	if (bufev->wm_read.low != 0 && len < bufev->wm_read.low)
 948 b0a6bcf7 2022-09-13 op 		return;
 949 b0a6bcf7 2022-09-13 op 	if (bufev->wm_read.high != 0 && len > bufev->wm_read.high) {
 950 b0a6bcf7 2022-09-13 op 		struct evbuffer *buf = bufev->input;
 951 b0a6bcf7 2022-09-13 op 		event_del(&bufev->ev_read);
 952 b0a6bcf7 2022-09-13 op 		evbuffer_setcb(buf, bufferevent_read_pressure_cb, bufev);
 953 b0a6bcf7 2022-09-13 op 		return;
 954 b0a6bcf7 2022-09-13 op 	}
 955 b0a6bcf7 2022-09-13 op 
 956 b0a6bcf7 2022-09-13 op 	if (bufev->readcb != NULL)
 957 b0a6bcf7 2022-09-13 op 		(*bufev->readcb)(bufev, bufev->cbarg);
 958 b0a6bcf7 2022-09-13 op 	return;
 959 b0a6bcf7 2022-09-13 op 
 960 b0a6bcf7 2022-09-13 op retry:
 961 83f0f95a 2022-09-29 op 	proxy_bufferevent_add(&bufev->ev_read, G_TOUT(bufev->timeout_read));
 962 b0a6bcf7 2022-09-13 op 	return;
 963 b0a6bcf7 2022-09-13 op 
 964 b0a6bcf7 2022-09-13 op err:
 965 b0a6bcf7 2022-09-13 op 	(*bufev->errorcb)(bufev, what, bufev->cbarg);
 966 b0a6bcf7 2022-09-13 op }
 967 b0a6bcf7 2022-09-13 op 
 968 b0a6bcf7 2022-09-13 op int
 969 b0a6bcf7 2022-09-13 op proxy_bufferevent_add(struct event *ev, int timeout)
 970 b0a6bcf7 2022-09-13 op {
 971 b0a6bcf7 2022-09-13 op 	struct timeval tv, *ptv = NULL;
 972 b0a6bcf7 2022-09-13 op 
 973 b0a6bcf7 2022-09-13 op 	if (timeout) {
 974 b0a6bcf7 2022-09-13 op 		timerclear(&tv);
 975 b0a6bcf7 2022-09-13 op 		tv.tv_sec = timeout;
 976 b0a6bcf7 2022-09-13 op 		ptv = &tv;
 977 b0a6bcf7 2022-09-13 op 	}
 978 b0a6bcf7 2022-09-13 op 
 979 b0a6bcf7 2022-09-13 op 	return (event_add(ev, ptv));
 980 b0a6bcf7 2022-09-13 op }
 981 b0a6bcf7 2022-09-13 op 
 982 b0a6bcf7 2022-09-13 op void
 983 b0a6bcf7 2022-09-13 op proxy_tls_writecb(int fd, short event, void *arg)
 984 b0a6bcf7 2022-09-13 op {
 985 b0a6bcf7 2022-09-13 op 	struct bufferevent	*bufev = arg;
 986 b0a6bcf7 2022-09-13 op 	struct client		*clt = bufev->cbarg;
 987 b0a6bcf7 2022-09-13 op 	ssize_t			 ret;
 988 b0a6bcf7 2022-09-13 op 	short			 what = EVBUFFER_WRITE;
 989 b0a6bcf7 2022-09-13 op 	size_t			 len;
 990 b0a6bcf7 2022-09-13 op 
 991 b0a6bcf7 2022-09-13 op 	if (event == EV_TIMEOUT) {
 992 b0a6bcf7 2022-09-13 op 		what |= EVBUFFER_TIMEOUT;
 993 b0a6bcf7 2022-09-13 op 		goto err;
 994 b0a6bcf7 2022-09-13 op 	}
 995 b0a6bcf7 2022-09-13 op 
 996 b0a6bcf7 2022-09-13 op 	if (EVBUFFER_LENGTH(bufev->output)) {
 997 b0a6bcf7 2022-09-13 op 		ret = tls_write(clt->clt_ctx,
 998 b0a6bcf7 2022-09-13 op 		    EVBUFFER_DATA(bufev->output),
 999 b0a6bcf7 2022-09-13 op 		    EVBUFFER_LENGTH(bufev->output));
1000 b0a6bcf7 2022-09-13 op 		if (ret == TLS_WANT_POLLIN || ret == TLS_WANT_POLLOUT) {
1001 b0a6bcf7 2022-09-13 op 			goto retry;
1002 b0a6bcf7 2022-09-13 op 		} else if (ret == -1) {
1003 b0a6bcf7 2022-09-13 op 			what |= EVBUFFER_ERROR;
1004 b0a6bcf7 2022-09-13 op 			goto err;
1005 b0a6bcf7 2022-09-13 op 		}
1006 b0a6bcf7 2022-09-13 op 		len = ret;
1007 b0a6bcf7 2022-09-13 op 		evbuffer_drain(bufev->output, len);
1008 b0a6bcf7 2022-09-13 op 	}
1009 b0a6bcf7 2022-09-13 op 
1010 b0a6bcf7 2022-09-13 op 	if (EVBUFFER_LENGTH(bufev->output) != 0)
1011 83f0f95a 2022-09-29 op 		proxy_bufferevent_add(&bufev->ev_write,
1012 83f0f95a 2022-09-29 op 		    G_TOUT(bufev->timeout_write));
1013 b0a6bcf7 2022-09-13 op 
1014 b0a6bcf7 2022-09-13 op 	if (bufev->writecb != NULL &&
1015 b0a6bcf7 2022-09-13 op 	    EVBUFFER_LENGTH(bufev->output) <= bufev->wm_write.low)
1016 b0a6bcf7 2022-09-13 op 		(*bufev->writecb)(bufev, bufev->cbarg);
1017 b0a6bcf7 2022-09-13 op 	return;
1018 b0a6bcf7 2022-09-13 op 
1019 b0a6bcf7 2022-09-13 op retry:
1020 83f0f95a 2022-09-29 op 	proxy_bufferevent_add(&bufev->ev_write, G_TOUT(bufev->timeout_write));
1021 b0a6bcf7 2022-09-13 op 	return;
1022 b0a6bcf7 2022-09-13 op 
1023 b0a6bcf7 2022-09-13 op err:
1024 b0a6bcf7 2022-09-13 op 	(*bufev->errorcb)(bufev, what, bufev->cbarg);
1025 b0a6bcf7 2022-09-13 op }
1026 b0a6bcf7 2022-09-13 op 
1027 b0a6bcf7 2022-09-13 op void
1028 b0a6bcf7 2022-09-13 op proxy_client_free(struct client *clt)
1029 b0a6bcf7 2022-09-13 op {
1030 b0a6bcf7 2022-09-13 op 	if (clt->clt_evasr)
1031 b0a6bcf7 2022-09-13 op 		event_asr_abort(clt->clt_evasr);
1032 b0a6bcf7 2022-09-13 op 
1033 b0a6bcf7 2022-09-13 op 	if (clt->clt_addrinfo)
1034 b0a6bcf7 2022-09-13 op 		freeaddrinfo(clt->clt_addrinfo);
1035 b0a6bcf7 2022-09-13 op 
1036 b0a6bcf7 2022-09-13 op 	if (clt->clt_evconn_live)
1037 b0a6bcf7 2022-09-13 op 		event_del(&clt->clt_evconn);
1038 b0a6bcf7 2022-09-13 op 
1039 b0a6bcf7 2022-09-13 op 	if (clt->clt_fd != -1)
1040 b0a6bcf7 2022-09-13 op 		close(clt->clt_fd);
1041 b0a6bcf7 2022-09-13 op 
1042 b0a6bcf7 2022-09-13 op 	if (clt->clt_ctx)
1043 b0a6bcf7 2022-09-13 op 		tls_free(clt->clt_ctx);
1044 b0a6bcf7 2022-09-13 op 
1045 b0a6bcf7 2022-09-13 op 	if (clt->clt_bev)
1046 b0a6bcf7 2022-09-13 op 		bufferevent_free(clt->clt_bev);
1047 a244322c 2022-09-29 op 
1048 a244322c 2022-09-29 op 	template_free(clt->clt_tp);
1049 b0a6bcf7 2022-09-13 op 
1050 8857131d 2022-09-20 op 	free(clt->clt_body);
1051 b0a6bcf7 2022-09-13 op 	free(clt->clt_server_name);
1052 b0a6bcf7 2022-09-13 op 	free(clt->clt_script_name);
1053 b0a6bcf7 2022-09-13 op 	free(clt->clt_path_info);
1054 28239bac 2022-09-20 op 	free(clt->clt_query);
1055 b0a6bcf7 2022-09-13 op 	free(clt);
1056 b0a6bcf7 2022-09-13 op }