1 /*
2  * Copyright (c) 2022 Omar Polo <op@omarpolo.com>
3  * Copyright (c) 2006 - 2015 Reyk Floeter <reyk@openbsd.org>
4  * Copyright (c) 2006, 2007 Pierre-Yves Ritschard <pyr@openbsd.org>
5  * Copyright (c) 2003, 2004 Henning Brauer <henning@openbsd.org>
6  *
7  * Permission to use, copy, modify, and distribute this software for any
8  * purpose with or without fee is hereby granted, provided that the above
9  * copyright notice and this permission notice appear in all copies.
10  *
11  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
12  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
13  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
14  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
15  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
16  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
17  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
18  */
19 
20 #ifndef nitems
21 #define nitems(_a) (sizeof((_a)) / sizeof((_a)[0]))
22 #endif
23 
24 #define GALILEO_USER		"www"
25 #define GALILEO_SOCK		"/var/www/run/galileo.sock"
26 #define CONF_FILE		"/etc/galileo.conf"
27 #define FD_RESERVE		5
28 #define PROC_MAX_INSTANCES	32
29 #define PROXY_NUMPROC		3
30 #define PROC_PARENT_SOCK_FILENO	3
31 
32 enum {
33 	IMSG_NONE,
34 	IMSG_CFG_START,
35 	IMSG_CFG_SRV,
36 	IMSG_CFG_SOCK,
37 	IMSG_CFG_DONE,
38 	IMSG_CTL_START,
39 	IMSG_CTL_RESET,
40 	IMSG_CTL_RESTART,
41 	IMSG_CTL_PROCFD,
42 };
43 
44 struct galileo;
45 struct proxy_config;
46 
47 struct imsg;
48 struct privsep;
49 struct privsep_proc;
50 struct tls;
51 
52 struct client {
53 	uint32_t		 clt_id;
54 	int			 clt_fd;
55 	struct fcgi		*clt_fcgi;
56 	char			*clt_server_name;
57 	char			*clt_script_name;
58 	char			*clt_path_info;
59 	struct proxy_config	*clt_pc;
60 	struct event_asr	*clt_evasr;
61 	struct addrinfo		*clt_addrinfo;
62 	struct addrinfo		*clt_p;
63 	struct event		 clt_evconn;
64 	int			 clt_evconn_live;
65 	struct tls		*clt_ctx;
66 	struct bufferevent	*clt_bev;
67 	int			 clt_headersdone;
68 	int			 clt_translate;
69 	int			 clt_inpre;
70 
71 	char			 clt_buf[1024];
72 	size_t			 clt_buflen;
73 
74 	SPLAY_ENTRY(client)	 clt_nodes;
75 };
76 SPLAY_HEAD(client_tree, client);
77 
78 struct fcgi {
79 	uint32_t		 fcg_id;
80 	int			 fcg_s;
81 	struct client_tree	 fcg_clients;
82 	struct bufferevent	*fcg_bev;
83 	int			 fcg_toread;
84 	int			 fcg_want;
85 	int			 fcg_padding;
86 	int			 fcg_type;
87 	uint16_t		 fcg_rec_id;
88 	int			 fcg_keep_conn;
89 
90 	struct galileo		*fcg_env;
91 
92 	SPLAY_ENTRY(fcgi)	 fcg_nodes;
93 };
94 SPLAY_HEAD(fcgi_tree, fcgi);
95 
96 struct proxy_config {
97 	char		 host[HOST_NAME_MAX + 1];
98 	char		 stylesheet[PATH_MAX];
99 	char		 proxy_addr[HOST_NAME_MAX + 1];
100 	char		 proxy_name[HOST_NAME_MAX + 1];
101 	uint16_t	 proxy_port; /* TODO: turn into string */
102 };
103 
104 struct server {
105 	TAILQ_ENTRY(server)	 srv_entry;
106 	struct proxy_config	 srv_conf;
107 };
108 TAILQ_HEAD(serverlist, server);
109 
110 struct galileo {
111 	char			 sc_conffile[PATH_MAX];
112 	uint16_t		 sc_prefork;
113 	char			 sc_chroot[PATH_MAX];
114 	struct serverlist	 sc_servers;
115 	struct fcgi_tree	 sc_fcgi_socks;
116 
117 	struct privsep		*sc_ps;
118 	int			 sc_reload;
119 
120 	/* XXX: generalize */
121 	int		sc_sock_fd;
122 	struct event	sc_evsock;
123 	struct event	sc_evpause;
124 };
125 
126 extern int privsep_process;
127 
128 /* config.c */
129 int	 config_init(struct galileo *);
130 void	 config_purge(struct galileo *);
131 int	 config_setserver(struct galileo *, struct server *);
132 int	 config_getserver(struct galileo *, struct imsg *);
133 int	 config_setsock(struct galileo *);
134 int	 config_getsock(struct galileo *, struct imsg *);
135 int	 config_setreset(struct galileo *);
136 int	 config_getreset(struct galileo *, struct imsg *);
137 
138 /* fcgi.c */
139 int	 fcgi_end_request(struct client *, int);
140 int	 fcgi_abort_request(struct client *);
141 void	 fcgi_accept(int, short, void *);
142 void	 fcgi_read(struct bufferevent *, void *);
143 void	 fcgi_write(struct bufferevent *, void *);
144 void	 fcgi_error(struct bufferevent *, short error, void *);
145 int	 clt_putc(struct client *, char);
146 int	 clt_puts(struct client *, const char *);
147 int	 clt_write_bufferevent(struct client *, struct bufferevent *);
148 int	 clt_flush(struct client *);
149 int	 clt_write(struct client *, const uint8_t *, size_t);
150 int	 clt_printf(struct client *, const char *, ...)
151 	     __attribute__((__format__(printf, 2, 3)))
152 	     __attribute__((__nonnull__(2)));
153 int	 fcgi_cmp(struct fcgi *, struct fcgi *);
154 int	 fcgi_client_cmp(struct client *, struct client *);
155 
156 /* galileo.c */
157 int	 accept_reserve(int, struct sockaddr *, socklen_t *, int,
158 	     volatile int *);
159 /* parse.y */
160 int	 parse_config(const char *, struct galileo *);
161 int	 cmdline_symset(char *);
162 
163 /* proxy.c */
164 extern volatile int proxy_inflight;
165 extern uint32_t proxy_fcg_id;
166 
167 void	 proxy(struct privsep *, struct privsep_proc *);
168 void	 proxy_purge(struct server *);
169 void	 proxy_start_request(struct galileo *, struct client *);
170 void	 proxy_client_free(struct client *);
171 
172 SPLAY_PROTOTYPE(fcgi_tree, fcgi, fcg_nodes, fcgi_cmp);
173 SPLAY_PROTOTYPE(client_tree, client, clt_nodes, fcgi_client_cmp);