op public repos

Blame

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