blob: 6f89ccd8818b0ed91c644631fb56dd78fc61c196 [file] [log] [blame]
Willy Tarreau79e57332018-10-02 16:01:16 +02001/*
2 * HTTP samples fetching
3 *
4 * Copyright 2000-2018 Willy Tarreau <w@1wt.eu>
5 *
6 * This program is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU General Public License
8 * as published by the Free Software Foundation; either version
9 * 2 of the License, or (at your option) any later version.
10 *
11 */
12
13#include <sys/types.h>
14
15#include <ctype.h>
16#include <string.h>
17#include <time.h>
18
Willy Tarreaub2551052020-06-09 09:07:15 +020019#include <haproxy/api.h>
Willy Tarreaudfd3de82020-06-04 23:46:14 +020020#include <haproxy/arg.h>
Willy Tarreauac13aea2020-06-04 10:36:03 +020021#include <haproxy/auth.h>
Willy Tarreau8d366972020-05-27 16:10:29 +020022#include <haproxy/base64.h>
Willy Tarreauf1d32c42020-06-04 21:07:02 +020023#include <haproxy/channel.h>
Willy Tarreauc13ed532020-06-02 10:22:45 +020024#include <haproxy/chunk.h>
Willy Tarreau7ea393d2020-06-04 18:02:10 +020025#include <haproxy/connection.h>
Willy Tarreauf268ee82020-06-04 17:05:57 +020026#include <haproxy/global.h>
Willy Tarreau5413a872020-06-02 19:33:08 +020027#include <haproxy/h1.h>
Willy Tarreauc6fe8842020-06-04 09:00:02 +020028#include <haproxy/h1_htx.h>
Willy Tarreaucd72d8c2020-06-02 19:11:26 +020029#include <haproxy/http.h>
Willy Tarreauc2b1ff02020-06-04 21:21:03 +020030#include <haproxy/http_ana.h>
Willy Tarreau126ba3a2020-06-04 18:26:43 +020031#include <haproxy/http_fetch.h>
Willy Tarreau87735332020-06-04 09:08:41 +020032#include <haproxy/http_htx.h>
Willy Tarreau16f958c2020-06-03 08:44:35 +020033#include <haproxy/htx.h>
Willy Tarreau8efbdfb2020-06-04 11:29:21 +020034#include <haproxy/obj_type.h>
Willy Tarreaud0ef4392020-06-02 09:38:52 +020035#include <haproxy/pool.h>
Willy Tarreaue6ce10b2020-06-04 15:33:47 +020036#include <haproxy/sample.h>
Willy Tarreaudfd3de82020-06-04 23:46:14 +020037#include <haproxy/stream.h>
Willy Tarreau48fbcae2020-06-03 18:09:46 +020038#include <haproxy/tools.h>
Willy Tarreaud6788052020-05-27 15:59:00 +020039#include <haproxy/version.h>
Willy Tarreau79e57332018-10-02 16:01:16 +020040
Willy Tarreau79e57332018-10-02 16:01:16 +020041
42/* this struct is used between calls to smp_fetch_hdr() or smp_fetch_cookie() */
Christopher Fauletef453ed2018-10-24 21:39:27 +020043static THREAD_LOCAL struct http_hdr_ctx static_http_hdr_ctx;
Richard Russo458eafb2019-07-31 11:45:56 -070044/* this is used to convert raw connection buffers to htx */
45static THREAD_LOCAL struct buffer static_raw_htx_chunk;
46static THREAD_LOCAL char *static_raw_htx_buf;
Christopher Fauletef453ed2018-10-24 21:39:27 +020047
Christopher Faulet89dc4992019-04-17 12:02:59 +020048#define SMP_REQ_CHN(smp) (smp->strm ? &smp->strm->req : NULL)
49#define SMP_RES_CHN(smp) (smp->strm ? &smp->strm->res : NULL)
Willy Tarreau79e57332018-10-02 16:01:16 +020050
Richard Russo458eafb2019-07-31 11:45:56 -070051/* This function returns the static htx chunk, where raw connections get
52 * converted to HTX as needed for samplxsing.
53 */
54struct buffer *get_raw_htx_chunk(void)
55{
56 chunk_reset(&static_raw_htx_chunk);
57 return &static_raw_htx_chunk;
58}
59
60static int alloc_raw_htx_chunk_per_thread()
61{
62 static_raw_htx_buf = malloc(global.tune.bufsize);
63 if (!static_raw_htx_buf)
64 return 0;
65 chunk_init(&static_raw_htx_chunk, static_raw_htx_buf, global.tune.bufsize);
66 return 1;
67}
68
69static void free_raw_htx_chunk_per_thread()
70{
71 free(static_raw_htx_buf);
72 static_raw_htx_buf = NULL;
73}
74
75REGISTER_PER_THREAD_ALLOC(alloc_raw_htx_chunk_per_thread);
76REGISTER_PER_THREAD_FREE(free_raw_htx_chunk_per_thread);
77
Willy Tarreau79e57332018-10-02 16:01:16 +020078/*
79 * Returns the data from Authorization header. Function may be called more
80 * than once so data is stored in txn->auth_data. When no header is found
81 * or auth method is unknown auth_method is set to HTTP_AUTH_WRONG to avoid
82 * searching again for something we are unable to find anyway. However, if
83 * the result if valid, the cache is not reused because we would risk to
84 * have the credentials overwritten by another stream in parallel.
Willy Tarreaueae83722020-04-29 11:52:51 +020085 * The caller is responsible for passing a sample with a valid stream/txn,
86 * and a valid htx.
Willy Tarreau79e57332018-10-02 16:01:16 +020087 */
88
Christopher Fauletcd761952019-07-15 13:58:29 +020089static int get_http_auth(struct sample *smp, struct htx *htx)
Willy Tarreau79e57332018-10-02 16:01:16 +020090{
Christopher Faulet311c7ea2018-10-24 21:41:55 +020091 struct stream *s = smp->strm;
Willy Tarreau79e57332018-10-02 16:01:16 +020092 struct http_txn *txn = s->txn;
Christopher Faulet6d1dd462019-07-15 14:36:03 +020093 struct http_hdr_ctx ctx = { .blk = NULL };
94 struct ist hdr;
Willy Tarreau79e57332018-10-02 16:01:16 +020095 struct buffer auth_method;
Christopher Faulet6d1dd462019-07-15 14:36:03 +020096 char *p;
Willy Tarreau79e57332018-10-02 16:01:16 +020097 int len;
98
99#ifdef DEBUG_AUTH
100 printf("Auth for stream %p: %d\n", s, txn->auth.method);
101#endif
Willy Tarreau79e57332018-10-02 16:01:16 +0200102 if (txn->auth.method == HTTP_AUTH_WRONG)
103 return 0;
104
105 txn->auth.method = HTTP_AUTH_WRONG;
106
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200107 if (txn->flags & TX_USE_PX_CONN)
108 hdr = ist("Proxy-Authorization");
109 else
110 hdr = ist("Authorization");
Willy Tarreau79e57332018-10-02 16:01:16 +0200111
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200112 ctx.blk = NULL;
113 if (!http_find_header(htx, hdr, &ctx, 0))
114 return 0;
Willy Tarreau79e57332018-10-02 16:01:16 +0200115
Willy Tarreau17254932020-09-02 07:08:47 +0200116 p = memchr(ctx.value.ptr, ' ', ctx.value.len);
117 if (!p || p == ctx.value.ptr) /* if no space was found or if the space is the first character */
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200118 return 0;
Willy Tarreau17254932020-09-02 07:08:47 +0200119 len = p - ctx.value.ptr;
Willy Tarreau79e57332018-10-02 16:01:16 +0200120
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200121 if (chunk_initlen(&auth_method, ctx.value.ptr, 0, len) != 1)
122 return 0;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200123
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200124 chunk_initlen(&txn->auth.method_data, p + 1, 0, ctx.value.len - len - 1);
Willy Tarreau79e57332018-10-02 16:01:16 +0200125
126 if (!strncasecmp("Basic", auth_method.area, auth_method.data)) {
127 struct buffer *http_auth = get_trash_chunk();
128
129 len = base64dec(txn->auth.method_data.area,
130 txn->auth.method_data.data,
131 http_auth->area, global.tune.bufsize - 1);
132
133 if (len < 0)
134 return 0;
135
136
137 http_auth->area[len] = '\0';
138
139 p = strchr(http_auth->area, ':');
140
141 if (!p)
142 return 0;
143
144 txn->auth.user = http_auth->area;
145 *p = '\0';
146 txn->auth.pass = p+1;
147
148 txn->auth.method = HTTP_AUTH_BASIC;
149 return 1;
150 }
151
152 return 0;
153}
154
155/* This function ensures that the prerequisites for an L7 fetch are ready,
156 * which means that a request or response is ready. If some data is missing,
157 * a parsing attempt is made. This is useful in TCP-based ACLs which are able
Christopher Faulet5ec8bcb2019-04-17 12:04:12 +0200158 * to extract data from L7. If <vol> is non-null during a prefetch, another
159 * test is made to ensure the required information is not gone.
Christopher Fauletef453ed2018-10-24 21:39:27 +0200160 *
161 * The function returns :
162 * NULL with SMP_F_MAY_CHANGE in the sample flags if some data is missing to
163 * decide whether or not an HTTP message is present ;
164 * NULL if the requested data cannot be fetched or if it is certain that
Willy Tarreaueae83722020-04-29 11:52:51 +0200165 * we'll never have any HTTP message there; this includes null strm or chn.
Willy Tarreaua6d98792020-08-12 14:04:52 +0200166 * NULL if the sample's direction does not match the channel's (i.e. the
167 * function was asked to work on the wrong channel)
Christopher Fauletef453ed2018-10-24 21:39:27 +0200168 * The HTX message if ready
169 */
Christopher Faulet778f5ed2020-04-29 15:51:55 +0200170struct htx *smp_prefetch_htx(struct sample *smp, struct channel *chn, struct check *check, int vol)
Christopher Fauletef453ed2018-10-24 21:39:27 +0200171{
Christopher Fauletef453ed2018-10-24 21:39:27 +0200172 struct stream *s = smp->strm;
Christopher Fauletef453ed2018-10-24 21:39:27 +0200173 struct http_txn *txn = NULL;
174 struct htx *htx = NULL;
Christopher Faulet89dc4992019-04-17 12:02:59 +0200175 struct http_msg *msg;
Christopher Fauletf1ba18d2018-11-26 21:37:08 +0100176 struct htx_sl *sl;
Christopher Fauletef453ed2018-10-24 21:39:27 +0200177
Willy Tarreaua6d98792020-08-12 14:04:52 +0200178 if (chn &&
179 (((smp->opt & SMP_OPT_DIR) == SMP_OPT_DIR_REQ && (chn->flags & CF_ISRESP)) ||
180 ((smp->opt & SMP_OPT_DIR) == SMP_OPT_DIR_RES && !(chn->flags & CF_ISRESP))))
181 return 0;
182
Christopher Fauletef453ed2018-10-24 21:39:27 +0200183 /* Note: it is possible that <s> is NULL when called before stream
184 * initialization (eg: tcp-request connection), so this function is the
185 * one responsible for guarding against this case for all HTTP users.
Christopher Faulet778f5ed2020-04-29 15:51:55 +0200186 *
187 * In the health check context, the stream and the channel must be NULL
188 * and <check> must be set. In this case, only the input buffer,
189 * corresponding to the response, is considered. It is the caller
190 * responsibility to provide <check>.
Christopher Fauletef453ed2018-10-24 21:39:27 +0200191 */
Christopher Faulet778f5ed2020-04-29 15:51:55 +0200192 BUG_ON(check && (s || chn));
193 if (!s || !chn) {
194 if (check) {
195 htx = htxbuf(&check->bi);
196
197 /* Analyse not yet started */
198 if (htx_is_empty(htx) || htx->first == -1)
199 return NULL;
200
201 sl = http_get_stline(htx);
202 if (vol && !sl) {
203 /* The start-line was already forwarded, it is too late to fetch anything */
204 return NULL;
205 }
206 goto end;
207 }
208
Christopher Fauletef453ed2018-10-24 21:39:27 +0200209 return NULL;
Christopher Faulet778f5ed2020-04-29 15:51:55 +0200210 }
Christopher Fauletef453ed2018-10-24 21:39:27 +0200211
212 if (!s->txn) {
213 if (unlikely(!http_alloc_txn(s)))
214 return NULL; /* not enough memory */
215 http_init_txn(s);
216 txn = s->txn;
217 }
Christopher Faulet89dc4992019-04-17 12:02:59 +0200218 txn = s->txn;
219 msg = (!(chn->flags & CF_ISRESP) ? &txn->req : &txn->rsp);
Christopher Fauletef453ed2018-10-24 21:39:27 +0200220
Christopher Fauleteca88542019-04-03 10:12:42 +0200221 if (IS_HTX_STRM(s)) {
Christopher Faulet89dc4992019-04-17 12:02:59 +0200222 htx = htxbuf(&chn->buf);
Christopher Fauletef453ed2018-10-24 21:39:27 +0200223
Christopher Faulet89dc4992019-04-17 12:02:59 +0200224 if (msg->msg_state == HTTP_MSG_ERROR || (htx->flags & HTX_FL_PARSING_ERROR))
225 return NULL;
Christopher Fauletef453ed2018-10-24 21:39:27 +0200226
Christopher Faulet89dc4992019-04-17 12:02:59 +0200227 if (msg->msg_state < HTTP_MSG_BODY) {
228 /* Analyse not yet started */
Christopher Faulet29f17582019-05-23 11:03:26 +0200229 if (htx_is_empty(htx) || htx->first == -1) {
Christopher Fauletef453ed2018-10-24 21:39:27 +0200230 /* Parsing is done by the mux, just wait */
231 smp->flags |= SMP_F_MAY_CHANGE;
232 return NULL;
233 }
234 }
Christopher Faulet297fbb42019-05-13 14:41:27 +0200235 sl = http_get_stline(htx);
Christopher Faulet5ec8bcb2019-04-17 12:04:12 +0200236 if (vol && !sl) {
Christopher Faulet89dc4992019-04-17 12:02:59 +0200237 /* The start-line was already forwarded, it is too late to fetch anything */
238 return NULL;
239 }
Christopher Fauletef453ed2018-10-24 21:39:27 +0200240 }
Christopher Fauleteca88542019-04-03 10:12:42 +0200241 else { /* RAW mode */
Christopher Faulet89dc4992019-04-17 12:02:59 +0200242 struct buffer *buf;
243 struct h1m h1m;
Christopher Faulete4ab11b2019-06-11 15:05:37 +0200244 struct http_hdr hdrs[global.tune.max_http_hdr];
Christopher Faulet89dc4992019-04-17 12:02:59 +0200245 union h1_sl h1sl;
246 unsigned int flags = HTX_FL_NONE;
247 int ret;
Christopher Fauletef453ed2018-10-24 21:39:27 +0200248
Christopher Faulet89dc4992019-04-17 12:02:59 +0200249 /* no HTTP fetch on the response in TCP mode */
250 if (chn->flags & CF_ISRESP)
251 return NULL;
Christopher Fauletef453ed2018-10-24 21:39:27 +0200252
Christopher Faulet89dc4992019-04-17 12:02:59 +0200253 /* Now we are working on the request only */
254 buf = &chn->buf;
255 if (b_head(buf) + b_data(buf) > b_wrap(buf))
256 b_slow_realign(buf, trash.area, 0);
Christopher Fauletef453ed2018-10-24 21:39:27 +0200257
Christopher Faulet89dc4992019-04-17 12:02:59 +0200258 h1m_init_req(&h1m);
259 ret = h1_headers_to_hdr_list(b_head(buf), b_stop(buf),
260 hdrs, sizeof(hdrs)/sizeof(hdrs[0]), &h1m, &h1sl);
261 if (ret <= 0) {
262 /* Invalid or too big*/
263 if (ret < 0 || channel_full(&s->req, global.tune.maxrewrite))
Christopher Fauletef453ed2018-10-24 21:39:27 +0200264 return NULL;
Christopher Fauletf1ba18d2018-11-26 21:37:08 +0100265
Christopher Faulet89dc4992019-04-17 12:02:59 +0200266 /* wait for a full request */
267 smp->flags |= SMP_F_MAY_CHANGE;
268 return NULL;
269 }
Christopher Fauletf1ba18d2018-11-26 21:37:08 +0100270
Ilya Shipitsin46a030c2020-07-05 16:36:08 +0500271 /* OK we just got a valid HTTP message. We have to convert it
Christopher Faulet89dc4992019-04-17 12:02:59 +0200272 * into an HTX message.
273 */
274 if (unlikely(h1sl.rq.v.len == 0)) {
275 /* try to convert HTTP/0.9 requests to HTTP/1.0 */
276 if (h1sl.rq.meth != HTTP_METH_GET || !h1sl.rq.u.len)
Christopher Fauletef453ed2018-10-24 21:39:27 +0200277 return NULL;
Christopher Faulet89dc4992019-04-17 12:02:59 +0200278 h1sl.rq.v = ist("HTTP/1.0");
Christopher Fauletef453ed2018-10-24 21:39:27 +0200279 }
Christopher Faulet89dc4992019-04-17 12:02:59 +0200280
281 /* Set HTX start-line flags */
282 if (h1m.flags & H1_MF_VER_11)
283 flags |= HTX_SL_F_VER_11;
284 if (h1m.flags & H1_MF_XFER_ENC)
285 flags |= HTX_SL_F_XFER_ENC;
286 flags |= HTX_SL_F_XFER_LEN;
287 if (h1m.flags & H1_MF_CHNK)
288 flags |= HTX_SL_F_CHNK;
289 else if (h1m.flags & H1_MF_CLEN)
290 flags |= HTX_SL_F_CLEN;
291
Richard Russo458eafb2019-07-31 11:45:56 -0700292 htx = htx_from_buf(get_raw_htx_chunk());
Christopher Faulet89dc4992019-04-17 12:02:59 +0200293 sl = htx_add_stline(htx, HTX_BLK_REQ_SL, flags, h1sl.rq.m, h1sl.rq.u, h1sl.rq.v);
294 if (!sl || !htx_add_all_headers(htx, hdrs))
Christopher Fauletef453ed2018-10-24 21:39:27 +0200295 return NULL;
Willy Tarreauce9bbf52019-05-13 08:32:31 +0200296 sl->info.req.meth = h1sl.rq.meth;
Christopher Faulet89dc4992019-04-17 12:02:59 +0200297 }
298
299 /* OK we just got a valid HTTP message. If not already done by
300 * HTTP analyzers, we have some minor preparation to perform so
301 * that further checks can rely on HTTP tests.
302 */
303 if (sl && msg->msg_state < HTTP_MSG_BODY) {
304 if (!(chn->flags & CF_ISRESP)) {
305 txn->meth = sl->info.req.meth;
306 if (txn->meth == HTTP_METH_GET || txn->meth == HTTP_METH_HEAD)
307 s->flags |= SF_REDIRECTABLE;
Christopher Fauletef453ed2018-10-24 21:39:27 +0200308 }
Christopher Faulet89dc4992019-04-17 12:02:59 +0200309 else
310 txn->status = sl->info.res.status;
311 if (sl->flags & HTX_SL_F_VER_11)
312 msg->flags |= HTTP_MSGF_VER_11;
Christopher Fauletef453ed2018-10-24 21:39:27 +0200313 }
314
315 /* everything's OK */
Christopher Faulet778f5ed2020-04-29 15:51:55 +0200316 end:
Christopher Fauletef453ed2018-10-24 21:39:27 +0200317 return htx;
318}
319
Willy Tarreau79e57332018-10-02 16:01:16 +0200320/* This function fetches the method of current HTTP request and stores
321 * it in the global pattern struct as a chunk. There are two possibilities :
322 * - if the method is known (not HTTP_METH_OTHER), its identifier is stored
323 * in <len> and <ptr> is NULL ;
324 * - if the method is unknown (HTTP_METH_OTHER), <ptr> points to the text and
325 * <len> to its length.
326 * This is intended to be used with pat_match_meth() only.
327 */
328static int smp_fetch_meth(const struct arg *args, struct sample *smp, const char *kw, void *private)
329{
Christopher Faulet89dc4992019-04-17 12:02:59 +0200330 struct channel *chn = SMP_REQ_CHN(smp);
Willy Tarreau79e57332018-10-02 16:01:16 +0200331 struct http_txn *txn;
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200332 int meth;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200333
Willy Tarreaua6d98792020-08-12 14:04:52 +0200334 txn = smp->strm->txn;
335 if (!txn)
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200336 return 0;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200337
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200338 meth = txn->meth;
339 smp->data.type = SMP_T_METH;
340 smp->data.u.meth.meth = meth;
341 if (meth == HTTP_METH_OTHER) {
Willy Tarreaua6d98792020-08-12 14:04:52 +0200342 struct htx *htx;
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200343 struct htx_sl *sl;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200344
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200345 if ((smp->opt & SMP_OPT_DIR) == SMP_OPT_DIR_RES) {
346 /* ensure the indexes are not affected */
347 return 0;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200348 }
Willy Tarreaua6d98792020-08-12 14:04:52 +0200349
350 htx = smp_prefetch_htx(smp, chn, NULL, 0);
351 if (!htx)
352 return 0;
353
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200354 sl = http_get_stline(htx);
355 smp->flags |= SMP_F_CONST;
356 smp->data.u.meth.str.area = HTX_SL_REQ_MPTR(sl);
357 smp->data.u.meth.str.data = HTX_SL_REQ_MLEN(sl);
Willy Tarreau79e57332018-10-02 16:01:16 +0200358 }
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200359 smp->flags |= SMP_F_VOL_1ST;
Willy Tarreau79e57332018-10-02 16:01:16 +0200360 return 1;
361}
362
363static int smp_fetch_rqver(const struct arg *args, struct sample *smp, const char *kw, void *private)
364{
Christopher Faulet89dc4992019-04-17 12:02:59 +0200365 struct channel *chn = SMP_REQ_CHN(smp);
Christopher Faulet778f5ed2020-04-29 15:51:55 +0200366 struct htx *htx = smp_prefetch_htx(smp, chn, NULL, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200367 struct htx_sl *sl;
Willy Tarreau79e57332018-10-02 16:01:16 +0200368 char *ptr;
369 int len;
370
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200371 if (!htx)
372 return 0;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200373
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200374 sl = http_get_stline(htx);
375 len = HTX_SL_REQ_VLEN(sl);
376 ptr = HTX_SL_REQ_VPTR(sl);
Willy Tarreau79e57332018-10-02 16:01:16 +0200377
378 while ((len-- > 0) && (*ptr++ != '/'));
379 if (len <= 0)
380 return 0;
381
382 smp->data.type = SMP_T_STR;
383 smp->data.u.str.area = ptr;
384 smp->data.u.str.data = len;
385
386 smp->flags = SMP_F_VOL_1ST | SMP_F_CONST;
387 return 1;
388}
389
390static int smp_fetch_stver(const struct arg *args, struct sample *smp, const char *kw, void *private)
391{
Christopher Faulet89dc4992019-04-17 12:02:59 +0200392 struct channel *chn = SMP_RES_CHN(smp);
Christopher Fauletf98e6262020-05-06 09:42:04 +0200393 struct check *check = objt_check(smp->sess->origin);
Christopher Faulet16032ab2020-04-30 11:30:00 +0200394 struct htx *htx = smp_prefetch_htx(smp, chn, check, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200395 struct htx_sl *sl;
Willy Tarreau79e57332018-10-02 16:01:16 +0200396 char *ptr;
397 int len;
398
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200399 if (!htx)
400 return 0;
Willy Tarreau79e57332018-10-02 16:01:16 +0200401
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200402 sl = http_get_stline(htx);
403 len = HTX_SL_RES_VLEN(sl);
404 ptr = HTX_SL_RES_VPTR(sl);
Willy Tarreau79e57332018-10-02 16:01:16 +0200405
406 while ((len-- > 0) && (*ptr++ != '/'));
407 if (len <= 0)
408 return 0;
409
410 smp->data.type = SMP_T_STR;
411 smp->data.u.str.area = ptr;
412 smp->data.u.str.data = len;
413
414 smp->flags = SMP_F_VOL_1ST | SMP_F_CONST;
415 return 1;
416}
417
418/* 3. Check on Status Code. We manipulate integers here. */
419static int smp_fetch_stcode(const struct arg *args, struct sample *smp, const char *kw, void *private)
420{
Christopher Faulet89dc4992019-04-17 12:02:59 +0200421 struct channel *chn = SMP_RES_CHN(smp);
Christopher Fauletf98e6262020-05-06 09:42:04 +0200422 struct check *check = objt_check(smp->sess->origin);
Christopher Faulet16032ab2020-04-30 11:30:00 +0200423 struct htx *htx = smp_prefetch_htx(smp, chn, check, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200424 struct htx_sl *sl;
Willy Tarreau79e57332018-10-02 16:01:16 +0200425 char *ptr;
426 int len;
427
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200428 if (!htx)
429 return 0;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200430
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200431 sl = http_get_stline(htx);
432 len = HTX_SL_RES_CLEN(sl);
433 ptr = HTX_SL_RES_CPTR(sl);
Willy Tarreau79e57332018-10-02 16:01:16 +0200434
435 smp->data.type = SMP_T_SINT;
436 smp->data.u.sint = __strl2ui(ptr, len);
437 smp->flags = SMP_F_VOL_1ST;
438 return 1;
439}
440
441static int smp_fetch_uniqueid(const struct arg *args, struct sample *smp, const char *kw, void *private)
442{
Tim Duesterhusa17e6622020-03-05 20:19:02 +0100443 struct ist unique_id;
Tim Duesterhus2825b4b2020-02-28 15:13:34 +0100444
Willy Tarreau79e57332018-10-02 16:01:16 +0200445 if (LIST_ISEMPTY(&smp->sess->fe->format_unique_id))
446 return 0;
447
Willy Tarreaua1062a42020-04-29 11:50:38 +0200448 if (!smp->strm)
449 return 0;
450
Tim Duesterhusa17e6622020-03-05 20:19:02 +0100451 unique_id = stream_generate_unique_id(smp->strm, &smp->sess->fe->format_unique_id);
452 if (!isttest(unique_id))
Tim Duesterhus2825b4b2020-02-28 15:13:34 +0100453 return 0;
454
Tim Duesterhusa17e6622020-03-05 20:19:02 +0100455 smp->data.u.str.area = smp->strm->unique_id.ptr;
456 smp->data.u.str.data = smp->strm->unique_id.len;
Tim Duesterhus2825b4b2020-02-28 15:13:34 +0100457 smp->data.type = SMP_T_STR;
Willy Tarreau79e57332018-10-02 16:01:16 +0200458 smp->flags = SMP_F_CONST;
459 return 1;
460}
461
462/* Returns a string block containing all headers including the
Joseph Herlant942eea32018-11-15 13:57:22 -0800463 * empty line which separes headers from the body. This is useful
464 * for some headers analysis.
Willy Tarreau79e57332018-10-02 16:01:16 +0200465 */
466static int smp_fetch_hdrs(const struct arg *args, struct sample *smp, const char *kw, void *private)
467{
Christopher Faulete596d182020-05-05 17:46:34 +0200468 /* possible keywords: req.hdrs, res.hdrs */
469 struct channel *chn = ((kw[2] == 'q') ? SMP_REQ_CHN(smp) : SMP_RES_CHN(smp));
Christopher Fauletf98e6262020-05-06 09:42:04 +0200470 struct check *check = ((kw[2] == 's') ? objt_check(smp->sess->origin) : NULL);
Christopher Faulet16032ab2020-04-30 11:30:00 +0200471 struct htx *htx = smp_prefetch_htx(smp, chn, check, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200472 struct buffer *temp;
473 int32_t pos;
Willy Tarreau79e57332018-10-02 16:01:16 +0200474
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200475 if (!htx)
476 return 0;
477 temp = get_trash_chunk();
478 for (pos = htx_get_first(htx); pos != -1; pos = htx_get_next(htx, pos)) {
479 struct htx_blk *blk = htx_get_blk(htx, pos);
480 enum htx_blk_type type = htx_get_blk_type(blk);
Willy Tarreau79e57332018-10-02 16:01:16 +0200481
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200482 if (type == HTX_BLK_HDR) {
483 struct ist n = htx_get_blk_name(htx, blk);
484 struct ist v = htx_get_blk_value(htx, blk);
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200485
Christopher Faulet53a899b2019-10-08 16:38:42 +0200486 if (!h1_format_htx_hdr(n, v, temp))
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200487 return 0;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200488 }
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200489 else if (type == HTX_BLK_EOH) {
490 if (!chunk_memcat(temp, "\r\n", 2))
491 return 0;
492 break;
493 }
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200494 }
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200495 smp->data.type = SMP_T_STR;
496 smp->data.u.str = *temp;
Willy Tarreau79e57332018-10-02 16:01:16 +0200497 return 1;
498}
499
500/* Returns the header request in a length/value encoded format.
501 * This is useful for exchanges with the SPOE.
502 *
503 * A "length value" is a multibyte code encoding numbers. It uses the
504 * SPOE format. The encoding is the following:
505 *
506 * Each couple "header name" / "header value" is composed
507 * like this:
508 * "length value" "header name bytes"
509 * "length value" "header value bytes"
510 * When the last header is reached, the header name and the header
511 * value are empty. Their length are 0
512 */
513static int smp_fetch_hdrs_bin(const struct arg *args, struct sample *smp, const char *kw, void *private)
514{
Christopher Faulete596d182020-05-05 17:46:34 +0200515 /* possible keywords: req.hdrs_bin, res.hdrs_bin */
516 struct channel *chn = ((kw[2] == 'q') ? SMP_REQ_CHN(smp) : SMP_RES_CHN(smp));
Christopher Fauletf98e6262020-05-06 09:42:04 +0200517 struct check *check = ((kw[2] == 's') ? objt_check(smp->sess->origin) : NULL);
Christopher Faulet16032ab2020-04-30 11:30:00 +0200518 struct htx *htx = smp_prefetch_htx(smp, chn, check, 1);
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200519 struct buffer *temp;
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200520 char *p, *end;
521 int32_t pos;
522 int ret;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200523
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200524 if (!htx)
525 return 0;
526 temp = get_trash_chunk();
527 p = temp->area;
528 end = temp->area + temp->size;
529 for (pos = htx_get_first(htx); pos != -1; pos = htx_get_next(htx, pos)) {
530 struct htx_blk *blk = htx_get_blk(htx, pos);
531 enum htx_blk_type type = htx_get_blk_type(blk);
532 struct ist n, v;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200533
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200534 if (type == HTX_BLK_HDR) {
535 n = htx_get_blk_name(htx,blk);
536 v = htx_get_blk_value(htx, blk);
Willy Tarreau79e57332018-10-02 16:01:16 +0200537
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200538 /* encode the header name. */
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200539 ret = encode_varint(n.len, &p, end);
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200540 if (ret == -1)
541 return 0;
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200542 if (p + n.len > end)
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200543 return 0;
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200544 memcpy(p, n.ptr, n.len);
545 p += n.len;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200546
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200547 /* encode the header value. */
548 ret = encode_varint(v.len, &p, end);
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200549 if (ret == -1)
550 return 0;
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200551 if (p + v.len > end)
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200552 return 0;
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200553 memcpy(p, v.ptr, v.len);
554 p += v.len;
Willy Tarreau79e57332018-10-02 16:01:16 +0200555
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200556 }
557 else if (type == HTX_BLK_EOH) {
558 /* encode the end of the header list with empty
559 * header name and header value.
560 */
561 ret = encode_varint(0, &p, end);
562 if (ret == -1)
563 return 0;
564 ret = encode_varint(0, &p, end);
565 if (ret == -1)
566 return 0;
567 break;
568 }
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200569 }
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200570
571 /* Initialise sample data which will be filled. */
572 smp->data.type = SMP_T_BIN;
573 smp->data.u.str.area = temp->area;
574 smp->data.u.str.data = p - temp->area;
575 smp->data.u.str.size = temp->size;
Willy Tarreau79e57332018-10-02 16:01:16 +0200576 return 1;
577}
578
579/* returns the longest available part of the body. This requires that the body
580 * has been waited for using http-buffer-request.
581 */
582static int smp_fetch_body(const struct arg *args, struct sample *smp, const char *kw, void *private)
583{
Christopher Faulete596d182020-05-05 17:46:34 +0200584 /* possible keywords: req.body, res.body */
585 struct channel *chn = ((kw[2] == 'q') ? SMP_REQ_CHN(smp) : SMP_RES_CHN(smp));
Christopher Fauletf98e6262020-05-06 09:42:04 +0200586 struct check *check = ((kw[2] == 's') ? objt_check(smp->sess->origin) : NULL);
Christopher Faulet16032ab2020-04-30 11:30:00 +0200587 struct htx *htx = smp_prefetch_htx(smp, chn, check, 1);
Willy Tarreau79e57332018-10-02 16:01:16 +0200588 struct buffer *temp;
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200589 int32_t pos;
Christopher Fauleta9ffc412020-11-25 08:08:08 +0100590 int finished = 0;
Willy Tarreau79e57332018-10-02 16:01:16 +0200591
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200592 if (!htx)
593 return 0;
Willy Tarreau79e57332018-10-02 16:01:16 +0200594
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200595 temp = get_trash_chunk();
596 for (pos = htx_get_first(htx); pos != -1; pos = htx_get_next(htx, pos)) {
597 struct htx_blk *blk = htx_get_blk(htx, pos);
598 enum htx_blk_type type = htx_get_blk_type(blk);
Willy Tarreau79e57332018-10-02 16:01:16 +0200599
Christopher Fauletd1ac2b92020-12-02 19:12:22 +0100600 if (type == HTX_BLK_TLR || type == HTX_BLK_EOT) {
Christopher Fauleta9ffc412020-11-25 08:08:08 +0100601 finished = 1;
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200602 break;
Christopher Fauleta9ffc412020-11-25 08:08:08 +0100603 }
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200604 if (type == HTX_BLK_DATA) {
Christopher Faulet53a899b2019-10-08 16:38:42 +0200605 if (!h1_format_htx_data(htx_get_blk_value(htx, blk), temp, 0))
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200606 return 0;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200607 }
Willy Tarreau79e57332018-10-02 16:01:16 +0200608 }
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200609
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200610 smp->data.type = SMP_T_BIN;
611 smp->data.u.str = *temp;
612 smp->flags = SMP_F_VOL_TEST;
Willy Tarreau9dc92b22020-06-15 18:01:10 +0200613
Christopher Fauleta9ffc412020-11-25 08:08:08 +0100614 if (!finished && (check || (chn && !channel_full(chn, global.tune.maxrewrite) &&
615 !(chn->flags & (CF_EOI|CF_SHUTR|CF_READ_ERROR)))))
Willy Tarreau9dc92b22020-06-15 18:01:10 +0200616 smp->flags |= SMP_F_MAY_CHANGE;
617
Willy Tarreau79e57332018-10-02 16:01:16 +0200618 return 1;
619}
620
621
622/* returns the available length of the body. This requires that the body
623 * has been waited for using http-buffer-request.
624 */
625static int smp_fetch_body_len(const struct arg *args, struct sample *smp, const char *kw, void *private)
626{
Christopher Faulete596d182020-05-05 17:46:34 +0200627 /* possible keywords: req.body_len, res.body_len */
628 struct channel *chn = ((kw[2] == 'q') ? SMP_REQ_CHN(smp) : SMP_RES_CHN(smp));
Christopher Fauletf98e6262020-05-06 09:42:04 +0200629 struct check *check = ((kw[2] == 's') ? objt_check(smp->sess->origin) : NULL);
Christopher Faulet16032ab2020-04-30 11:30:00 +0200630 struct htx *htx = smp_prefetch_htx(smp, chn, check, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200631 int32_t pos;
632 unsigned long long len = 0;
Christopher Fauletc16317d2018-12-12 14:11:22 +0100633
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200634 if (!htx)
635 return 0;
Christopher Fauletc16317d2018-12-12 14:11:22 +0100636
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200637 for (pos = htx_get_first(htx); pos != -1; pos = htx_get_next(htx, pos)) {
638 struct htx_blk *blk = htx_get_blk(htx, pos);
639 enum htx_blk_type type = htx_get_blk_type(blk);
Christopher Fauletc16317d2018-12-12 14:11:22 +0100640
Christopher Fauletd1ac2b92020-12-02 19:12:22 +0100641 if (type == HTX_BLK_TLR || type == HTX_BLK_EOT)
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200642 break;
643 if (type == HTX_BLK_DATA)
644 len += htx_get_blksz(blk);
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200645 }
Willy Tarreau79e57332018-10-02 16:01:16 +0200646
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200647 smp->data.type = SMP_T_SINT;
648 smp->data.u.sint = len;
649 smp->flags = SMP_F_VOL_TEST;
Willy Tarreau79e57332018-10-02 16:01:16 +0200650 return 1;
651}
652
653
654/* returns the advertised length of the body, or the advertised size of the
655 * chunks available in the buffer. This requires that the body has been waited
656 * for using http-buffer-request.
657 */
658static int smp_fetch_body_size(const struct arg *args, struct sample *smp, const char *kw, void *private)
659{
Christopher Faulete596d182020-05-05 17:46:34 +0200660 /* possible keywords: req.body_size, res.body_size */
661 struct channel *chn = ((kw[2] == 'q') ? SMP_REQ_CHN(smp) : SMP_RES_CHN(smp));
Christopher Fauletf98e6262020-05-06 09:42:04 +0200662 struct check *check = ((kw[2] == 's') ? objt_check(smp->sess->origin) : NULL);
Christopher Faulet16032ab2020-04-30 11:30:00 +0200663 struct htx *htx = smp_prefetch_htx(smp, chn, check, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200664 int32_t pos;
665 unsigned long long len = 0;
Christopher Faulet89dc4992019-04-17 12:02:59 +0200666
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200667 if (!htx)
668 return 0;
Christopher Fauletc16317d2018-12-12 14:11:22 +0100669
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200670 for (pos = htx_get_first(htx); pos != -1; pos = htx_get_next(htx, pos)) {
671 struct htx_blk *blk = htx_get_blk(htx, pos);
672 enum htx_blk_type type = htx_get_blk_type(blk);
Christopher Fauletc16317d2018-12-12 14:11:22 +0100673
Christopher Fauletd1ac2b92020-12-02 19:12:22 +0100674 if (type == HTX_BLK_TLR || type == HTX_BLK_EOT)
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200675 break;
676 if (type == HTX_BLK_DATA)
677 len += htx_get_blksz(blk);
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200678 }
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200679 if (htx->extra != ULLONG_MAX)
680 len += htx->extra;
Willy Tarreau79e57332018-10-02 16:01:16 +0200681
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200682 smp->data.type = SMP_T_SINT;
683 smp->data.u.sint = len;
684 smp->flags = SMP_F_VOL_TEST;
Willy Tarreau79e57332018-10-02 16:01:16 +0200685 return 1;
686}
687
688
689/* 4. Check on URL/URI. A pointer to the URI is stored. */
690static int smp_fetch_url(const struct arg *args, struct sample *smp, const char *kw, void *private)
691{
Christopher Faulet89dc4992019-04-17 12:02:59 +0200692 struct channel *chn = SMP_REQ_CHN(smp);
Christopher Faulet778f5ed2020-04-29 15:51:55 +0200693 struct htx *htx = smp_prefetch_htx(smp, chn, NULL, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200694 struct htx_sl *sl;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200695
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200696 if (!htx)
697 return 0;
698 sl = http_get_stline(htx);
699 smp->data.type = SMP_T_STR;
700 smp->data.u.str.area = HTX_SL_REQ_UPTR(sl);
701 smp->data.u.str.data = HTX_SL_REQ_ULEN(sl);
702 smp->flags = SMP_F_VOL_1ST | SMP_F_CONST;
Willy Tarreau79e57332018-10-02 16:01:16 +0200703 return 1;
704}
705
706static int smp_fetch_url_ip(const struct arg *args, struct sample *smp, const char *kw, void *private)
707{
Christopher Faulet89dc4992019-04-17 12:02:59 +0200708 struct channel *chn = SMP_REQ_CHN(smp);
Christopher Faulet778f5ed2020-04-29 15:51:55 +0200709 struct htx *htx = smp_prefetch_htx(smp, chn, NULL, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200710 struct htx_sl *sl;
Willy Tarreau79e57332018-10-02 16:01:16 +0200711 struct sockaddr_storage addr;
712
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200713 if (!htx)
714 return 0;
715 sl = http_get_stline(htx);
716 url2sa(HTX_SL_REQ_UPTR(sl), HTX_SL_REQ_ULEN(sl), &addr, NULL);
Willy Tarreau79e57332018-10-02 16:01:16 +0200717
Willy Tarreau79e57332018-10-02 16:01:16 +0200718 if (((struct sockaddr_in *)&addr)->sin_family != AF_INET)
719 return 0;
720
721 smp->data.type = SMP_T_IPV4;
722 smp->data.u.ipv4 = ((struct sockaddr_in *)&addr)->sin_addr;
723 smp->flags = 0;
724 return 1;
725}
726
727static int smp_fetch_url_port(const struct arg *args, struct sample *smp, const char *kw, void *private)
728{
Christopher Faulet89dc4992019-04-17 12:02:59 +0200729 struct channel *chn = SMP_REQ_CHN(smp);
Christopher Faulet778f5ed2020-04-29 15:51:55 +0200730 struct htx *htx = smp_prefetch_htx(smp, chn, NULL, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200731 struct htx_sl *sl;
Willy Tarreau79e57332018-10-02 16:01:16 +0200732 struct sockaddr_storage addr;
733
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200734 if (!htx)
735 return 0;
736 sl = http_get_stline(htx);
737 url2sa(HTX_SL_REQ_UPTR(sl), HTX_SL_REQ_ULEN(sl), &addr, NULL);
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200738
Willy Tarreau79e57332018-10-02 16:01:16 +0200739 if (((struct sockaddr_in *)&addr)->sin_family != AF_INET)
740 return 0;
741
742 smp->data.type = SMP_T_SINT;
743 smp->data.u.sint = ntohs(((struct sockaddr_in *)&addr)->sin_port);
744 smp->flags = 0;
745 return 1;
746}
747
748/* Fetch an HTTP header. A pointer to the beginning of the value is returned.
749 * Accepts an optional argument of type string containing the header field name,
750 * and an optional argument of type signed or unsigned integer to request an
751 * explicit occurrence of the header. Note that in the event of a missing name,
752 * headers are considered from the first one. It does not stop on commas and
753 * returns full lines instead (useful for User-Agent or Date for example).
754 */
755static int smp_fetch_fhdr(const struct arg *args, struct sample *smp, const char *kw, void *private)
756{
Christopher Faulet89dc4992019-04-17 12:02:59 +0200757 /* possible keywords: req.fhdr, res.fhdr */
758 struct channel *chn = ((kw[2] == 'q') ? SMP_REQ_CHN(smp) : SMP_RES_CHN(smp));
Christopher Fauletf98e6262020-05-06 09:42:04 +0200759 struct check *check = ((kw[2] == 's') ? objt_check(smp->sess->origin) : NULL);
Christopher Faulet16032ab2020-04-30 11:30:00 +0200760 struct htx *htx = smp_prefetch_htx(smp, chn, check, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200761 struct http_hdr_ctx *ctx = smp->ctx.a[0];
762 struct ist name;
Willy Tarreau79e57332018-10-02 16:01:16 +0200763 int occ = 0;
Willy Tarreau79e57332018-10-02 16:01:16 +0200764
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200765 if (!ctx) {
766 /* first call */
767 ctx = &static_http_hdr_ctx;
768 ctx->blk = NULL;
769 smp->ctx.a[0] = ctx;
770 }
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200771
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200772 if (args) {
773 if (args[0].type != ARGT_STR)
Willy Tarreau79e57332018-10-02 16:01:16 +0200774 return 0;
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200775 name.ptr = args[0].data.str.area;
776 name.len = args[0].data.str.data;
Willy Tarreau79e57332018-10-02 16:01:16 +0200777
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200778 if (args[1].type == ARGT_SINT)
779 occ = args[1].data.sint;
Willy Tarreau79e57332018-10-02 16:01:16 +0200780 }
781
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200782 if (!htx)
783 return 0;
Willy Tarreau79e57332018-10-02 16:01:16 +0200784
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200785 if (ctx && !(smp->flags & SMP_F_NOT_LAST))
786 /* search for header from the beginning */
787 ctx->blk = NULL;
Willy Tarreau79e57332018-10-02 16:01:16 +0200788
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200789 if (!occ && !(smp->opt & SMP_OPT_ITERATE))
790 /* no explicit occurrence and single fetch => last header by default */
791 occ = -1;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200792
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200793 if (!occ)
794 /* prepare to report multiple occurrences for ACL fetches */
795 smp->flags |= SMP_F_NOT_LAST;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200796
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200797 smp->data.type = SMP_T_STR;
798 smp->flags |= SMP_F_VOL_HDR | SMP_F_CONST;
799 if (http_get_htx_fhdr(htx, name, occ, ctx, &smp->data.u.str.area, &smp->data.u.str.data))
800 return 1;
Willy Tarreau79e57332018-10-02 16:01:16 +0200801 smp->flags &= ~SMP_F_NOT_LAST;
802 return 0;
803}
804
805/* 6. Check on HTTP header count. The number of occurrences is returned.
806 * Accepts exactly 1 argument of type string. It does not stop on commas and
807 * returns full lines instead (useful for User-Agent or Date for example).
808 */
809static int smp_fetch_fhdr_cnt(const struct arg *args, struct sample *smp, const char *kw, void *private)
810{
Christopher Faulet89dc4992019-04-17 12:02:59 +0200811 /* possible keywords: req.fhdr_cnt, res.fhdr_cnt */
812 struct channel *chn = ((kw[2] == 'q') ? SMP_REQ_CHN(smp) : SMP_RES_CHN(smp));
Christopher Fauletf98e6262020-05-06 09:42:04 +0200813 struct check *check = ((kw[2] == 's') ? objt_check(smp->sess->origin) : NULL);
Christopher Faulet16032ab2020-04-30 11:30:00 +0200814 struct htx *htx = smp_prefetch_htx(smp, chn, check, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200815 struct http_hdr_ctx ctx;
816 struct ist name;
Willy Tarreau79e57332018-10-02 16:01:16 +0200817 int cnt;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200818
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200819 if (!htx)
820 return 0;
Willy Tarreau79e57332018-10-02 16:01:16 +0200821
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200822 if (args && args->type == ARGT_STR) {
823 name.ptr = args->data.str.area;
824 name.len = args->data.str.data;
825 } else {
826 name.ptr = NULL;
827 name.len = 0;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200828 }
Willy Tarreau79e57332018-10-02 16:01:16 +0200829
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200830 ctx.blk = NULL;
831 cnt = 0;
832 while (http_find_header(htx, name, &ctx, 1))
833 cnt++;
Willy Tarreau79e57332018-10-02 16:01:16 +0200834 smp->data.type = SMP_T_SINT;
835 smp->data.u.sint = cnt;
836 smp->flags = SMP_F_VOL_HDR;
837 return 1;
838}
839
840static int smp_fetch_hdr_names(const struct arg *args, struct sample *smp, const char *kw, void *private)
841{
Christopher Faulet89dc4992019-04-17 12:02:59 +0200842 /* possible keywords: req.hdr_names, res.hdr_names */
843 struct channel *chn = ((kw[2] == 'q') ? SMP_REQ_CHN(smp) : SMP_RES_CHN(smp));
Christopher Fauletf98e6262020-05-06 09:42:04 +0200844 struct check *check = ((kw[2] == 's') ? objt_check(smp->sess->origin) : NULL);
Christopher Faulet16032ab2020-04-30 11:30:00 +0200845 struct htx *htx = smp_prefetch_htx(smp, chn, check, 1);
Willy Tarreau79e57332018-10-02 16:01:16 +0200846 struct buffer *temp;
847 char del = ',';
848
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200849 int32_t pos;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200850
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200851 if (!htx)
852 return 0;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200853
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200854 if (args && args->type == ARGT_STR)
855 del = *args[0].data.str.area;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200856
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200857 temp = get_trash_chunk();
858 for (pos = htx_get_first(htx); pos != -1; pos = htx_get_next(htx, pos)) {
859 struct htx_blk *blk = htx_get_blk(htx, pos);
860 enum htx_blk_type type = htx_get_blk_type(blk);
861 struct ist n;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200862
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200863 if (type == HTX_BLK_EOH)
864 break;
865 if (type != HTX_BLK_HDR)
866 continue;
867 n = htx_get_blk_name(htx, blk);
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200868
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200869 if (temp->data)
870 temp->area[temp->data++] = del;
871 chunk_memcat(temp, n.ptr, n.len);
Willy Tarreau79e57332018-10-02 16:01:16 +0200872 }
873
874 smp->data.type = SMP_T_STR;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200875 smp->data.u.str = *temp;
Willy Tarreau79e57332018-10-02 16:01:16 +0200876 smp->flags = SMP_F_VOL_HDR;
877 return 1;
878}
879
880/* Fetch an HTTP header. A pointer to the beginning of the value is returned.
881 * Accepts an optional argument of type string containing the header field name,
882 * and an optional argument of type signed or unsigned integer to request an
883 * explicit occurrence of the header. Note that in the event of a missing name,
884 * headers are considered from the first one.
885 */
886static int smp_fetch_hdr(const struct arg *args, struct sample *smp, const char *kw, void *private)
887{
Christopher Faulet89dc4992019-04-17 12:02:59 +0200888 /* possible keywords: req.hdr / hdr, res.hdr / shdr */
889 struct channel *chn = ((kw[0] == 'h' || kw[2] == 'q') ? SMP_REQ_CHN(smp) : SMP_RES_CHN(smp));
Christopher Fauletf98e6262020-05-06 09:42:04 +0200890 struct check *check = ((kw[0] == 's' || kw[2] == 's') ? objt_check(smp->sess->origin) : NULL);
Christopher Faulet16032ab2020-04-30 11:30:00 +0200891 struct htx *htx = smp_prefetch_htx(smp, chn, check, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200892 struct http_hdr_ctx *ctx = smp->ctx.a[0];
893 struct ist name;
Willy Tarreau79e57332018-10-02 16:01:16 +0200894 int occ = 0;
Willy Tarreau79e57332018-10-02 16:01:16 +0200895
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200896 if (!ctx) {
897 /* first call */
898 ctx = &static_http_hdr_ctx;
899 ctx->blk = NULL;
900 smp->ctx.a[0] = ctx;
901 }
Willy Tarreau79e57332018-10-02 16:01:16 +0200902
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200903 if (args) {
904 if (args[0].type != ARGT_STR)
Willy Tarreau79e57332018-10-02 16:01:16 +0200905 return 0;
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200906 name.ptr = args[0].data.str.area;
907 name.len = args[0].data.str.data;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200908
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200909 if (args[1].type == ARGT_SINT)
910 occ = args[1].data.sint;
Willy Tarreau79e57332018-10-02 16:01:16 +0200911 }
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200912
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200913 if (!htx)
914 return 0;
Willy Tarreau79e57332018-10-02 16:01:16 +0200915
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200916 if (ctx && !(smp->flags & SMP_F_NOT_LAST))
917 /* search for header from the beginning */
918 ctx->blk = NULL;
Willy Tarreau79e57332018-10-02 16:01:16 +0200919
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200920 if (!occ && !(smp->opt & SMP_OPT_ITERATE))
921 /* no explicit occurrence and single fetch => last header by default */
922 occ = -1;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200923
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200924 if (!occ)
925 /* prepare to report multiple occurrences for ACL fetches */
926 smp->flags |= SMP_F_NOT_LAST;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200927
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200928 smp->data.type = SMP_T_STR;
929 smp->flags |= SMP_F_VOL_HDR | SMP_F_CONST;
930 if (http_get_htx_hdr(htx, name, occ, ctx, &smp->data.u.str.area, &smp->data.u.str.data))
931 return 1;
Willy Tarreau79e57332018-10-02 16:01:16 +0200932
933 smp->flags &= ~SMP_F_NOT_LAST;
934 return 0;
935}
936
Christopher Fauletc1f40dd2019-05-16 10:07:30 +0200937/* Same than smp_fetch_hdr() but only relies on the sample direction to choose
938 * the right channel. So instead of duplicating the code, we just change the
939 * keyword and then fallback on smp_fetch_hdr().
940 */
941static int smp_fetch_chn_hdr(const struct arg *args, struct sample *smp, const char *kw, void *private)
942{
943 kw = ((smp->opt & SMP_OPT_DIR) == SMP_OPT_DIR_REQ ? "req.hdr" : "res.hdr");
944 return smp_fetch_hdr(args, smp, kw, private);
945}
946
Willy Tarreau79e57332018-10-02 16:01:16 +0200947/* 6. Check on HTTP header count. The number of occurrences is returned.
948 * Accepts exactly 1 argument of type string.
949 */
950static int smp_fetch_hdr_cnt(const struct arg *args, struct sample *smp, const char *kw, void *private)
951{
Christopher Faulet89dc4992019-04-17 12:02:59 +0200952 /* possible keywords: req.hdr_cnt / hdr_cnt, res.hdr_cnt / shdr_cnt */
953 struct channel *chn = ((kw[0] == 'h' || kw[2] == 'q') ? SMP_REQ_CHN(smp) : SMP_RES_CHN(smp));
Christopher Fauletf98e6262020-05-06 09:42:04 +0200954 struct check *check = ((kw[0] == 's' || kw[2] == 's') ? objt_check(smp->sess->origin) : NULL);
Christopher Faulet16032ab2020-04-30 11:30:00 +0200955 struct htx *htx = smp_prefetch_htx(smp, chn, check, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200956 struct http_hdr_ctx ctx;
957 struct ist name;
Willy Tarreau79e57332018-10-02 16:01:16 +0200958 int cnt;
Christopher Faulet311c7ea2018-10-24 21:41:55 +0200959
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200960 if (!htx)
961 return 0;
Willy Tarreau79e57332018-10-02 16:01:16 +0200962
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200963 if (args && args->type == ARGT_STR) {
964 name.ptr = args->data.str.area;
965 name.len = args->data.str.data;
966 } else {
967 name.ptr = NULL;
968 name.len = 0;
Willy Tarreau79e57332018-10-02 16:01:16 +0200969 }
Willy Tarreau79e57332018-10-02 16:01:16 +0200970
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200971 ctx.blk = NULL;
972 cnt = 0;
973 while (http_find_header(htx, name, &ctx, 0))
974 cnt++;
Willy Tarreau79e57332018-10-02 16:01:16 +0200975
976 smp->data.type = SMP_T_SINT;
977 smp->data.u.sint = cnt;
978 smp->flags = SMP_F_VOL_HDR;
979 return 1;
980}
981
982/* Fetch an HTTP header's integer value. The integer value is returned. It
983 * takes a mandatory argument of type string and an optional one of type int
984 * to designate a specific occurrence. It returns an unsigned integer, which
985 * may or may not be appropriate for everything.
986 */
987static int smp_fetch_hdr_val(const struct arg *args, struct sample *smp, const char *kw, void *private)
988{
989 int ret = smp_fetch_hdr(args, smp, kw, private);
990
991 if (ret > 0) {
992 smp->data.type = SMP_T_SINT;
993 smp->data.u.sint = strl2ic(smp->data.u.str.area,
994 smp->data.u.str.data);
995 }
996
997 return ret;
998}
999
1000/* Fetch an HTTP header's IP value. takes a mandatory argument of type string
1001 * and an optional one of type int to designate a specific occurrence.
1002 * It returns an IPv4 or IPv6 address.
1003 */
1004static int smp_fetch_hdr_ip(const struct arg *args, struct sample *smp, const char *kw, void *private)
1005{
1006 int ret;
Tim Duesterhus5cd00872020-06-26 15:44:48 +02001007 struct buffer *temp = get_trash_chunk();
Willy Tarreau79e57332018-10-02 16:01:16 +02001008
1009 while ((ret = smp_fetch_hdr(args, smp, kw, private)) > 0) {
Tim Duesterhus5cd00872020-06-26 15:44:48 +02001010 if (smp->data.u.str.data < temp->size - 1) {
1011 memcpy(temp->area, smp->data.u.str.area,
1012 smp->data.u.str.data);
1013 temp->area[smp->data.u.str.data] = '\0';
1014 if (url2ipv4((char *) temp->area, &smp->data.u.ipv4)) {
1015 smp->data.type = SMP_T_IPV4;
1016 break;
1017 } else if (inet_pton(AF_INET6, temp->area, &smp->data.u.ipv6)) {
1018 smp->data.type = SMP_T_IPV6;
1019 break;
Willy Tarreau79e57332018-10-02 16:01:16 +02001020 }
1021 }
1022
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001023 /* if the header doesn't match an IP address, fetch next one */
1024 if (!(smp->flags & SMP_F_NOT_LAST))
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001025 return 0;
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001026 }
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001027 return ret;
1028}
Willy Tarreau79e57332018-10-02 16:01:16 +02001029
Christopher Faulete720c322020-09-02 17:25:18 +02001030/* 8. Check on URI PATH. A pointer to the PATH is stored. The path starts at the
1031 * first '/' after the possible hostname. It ends before the possible '?' except
1032 * for 'pathq' keyword.
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001033 */
1034static int smp_fetch_path(const struct arg *args, struct sample *smp, const char *kw, void *private)
1035{
1036 struct channel *chn = SMP_REQ_CHN(smp);
Christopher Faulet778f5ed2020-04-29 15:51:55 +02001037 struct htx *htx = smp_prefetch_htx(smp, chn, NULL, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001038 struct htx_sl *sl;
1039 struct ist path;
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001040
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001041 if (!htx)
1042 return 0;
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001043
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001044 sl = http_get_stline(htx);
Christopher Faulete720c322020-09-02 17:25:18 +02001045 path = http_get_path(htx_sl_req_uri(sl));
1046
1047 if (kw[0] == 'p' && kw[4] == 'q') // pathq
1048 path = http_get_path(htx_sl_req_uri(sl));
1049 else
1050 path = iststop(http_get_path(htx_sl_req_uri(sl)), '?');
1051
Tim Duesterhused526372020-03-05 17:56:33 +01001052 if (!isttest(path))
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001053 return 0;
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001054
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001055 /* OK, we got the '/' ! */
1056 smp->data.type = SMP_T_STR;
1057 smp->data.u.str.area = path.ptr;
Jerome Magnin4fb196c2020-02-21 10:49:12 +01001058 smp->data.u.str.data = path.len;
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001059 smp->flags = SMP_F_VOL_1ST | SMP_F_CONST;
Willy Tarreau79e57332018-10-02 16:01:16 +02001060 return 1;
1061}
1062
1063/* This produces a concatenation of the first occurrence of the Host header
1064 * followed by the path component if it begins with a slash ('/'). This means
1065 * that '*' will not be added, resulting in exactly the first Host entry.
1066 * If no Host header is found, then the path is returned as-is. The returned
1067 * value is stored in the trash so it does not need to be marked constant.
1068 * The returned sample is of type string.
1069 */
1070static int smp_fetch_base(const struct arg *args, struct sample *smp, const char *kw, void *private)
1071{
Christopher Faulet89dc4992019-04-17 12:02:59 +02001072 struct channel *chn = SMP_REQ_CHN(smp);
Christopher Faulet778f5ed2020-04-29 15:51:55 +02001073 struct htx *htx = smp_prefetch_htx(smp, chn, NULL, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001074 struct htx_sl *sl;
Willy Tarreau79e57332018-10-02 16:01:16 +02001075 struct buffer *temp;
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001076 struct http_hdr_ctx ctx;
1077 struct ist path;
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001078
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001079 if (!htx)
1080 return 0;
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001081
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001082 ctx.blk = NULL;
1083 if (!http_find_header(htx, ist("Host"), &ctx, 0) || !ctx.value.len)
1084 return smp_fetch_path(args, smp, kw, private);
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001085
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001086 /* OK we have the header value in ctx.value */
1087 temp = get_trash_chunk();
1088 chunk_memcat(temp, ctx.value.ptr, ctx.value.len);
Willy Tarreau79e57332018-10-02 16:01:16 +02001089
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001090 /* now retrieve the path */
1091 sl = http_get_stline(htx);
1092 path = http_get_path(htx_sl_req_uri(sl));
Tim Duesterhused526372020-03-05 17:56:33 +01001093 if (isttest(path)) {
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001094 size_t len;
Willy Tarreau79e57332018-10-02 16:01:16 +02001095
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001096 for (len = 0; len < path.len && *(path.ptr + len) != '?'; len++)
1097 ;
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001098
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001099 if (len && *(path.ptr) == '/')
1100 chunk_memcat(temp, path.ptr, len);
Willy Tarreau79e57332018-10-02 16:01:16 +02001101 }
1102
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001103 smp->data.type = SMP_T_STR;
1104 smp->data.u.str = *temp;
Willy Tarreau79e57332018-10-02 16:01:16 +02001105 smp->flags = SMP_F_VOL_1ST;
1106 return 1;
1107}
1108
1109/* This produces a 32-bit hash of the concatenation of the first occurrence of
1110 * the Host header followed by the path component if it begins with a slash ('/').
1111 * This means that '*' will not be added, resulting in exactly the first Host
1112 * entry. If no Host header is found, then the path is used. The resulting value
1113 * is hashed using the path hash followed by a full avalanche hash and provides a
1114 * 32-bit integer value. This fetch is useful for tracking per-path activity on
1115 * high-traffic sites without having to store whole paths.
1116 */
1117static int smp_fetch_base32(const struct arg *args, struct sample *smp, const char *kw, void *private)
1118{
Christopher Faulet89dc4992019-04-17 12:02:59 +02001119 struct channel *chn = SMP_REQ_CHN(smp);
Christopher Faulet778f5ed2020-04-29 15:51:55 +02001120 struct htx *htx = smp_prefetch_htx(smp, chn, NULL, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001121 struct htx_sl *sl;
1122 struct http_hdr_ctx ctx;
1123 struct ist path;
Willy Tarreau79e57332018-10-02 16:01:16 +02001124 unsigned int hash = 0;
Willy Tarreau79e57332018-10-02 16:01:16 +02001125
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001126 if (!htx)
1127 return 0;
Dragan Dosen8861e1c2019-02-12 19:50:31 +01001128
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001129 ctx.blk = NULL;
1130 if (http_find_header(htx, ist("Host"), &ctx, 0)) {
1131 /* OK we have the header value in ctx.value */
1132 while (ctx.value.len--)
1133 hash = *(ctx.value.ptr++) + (hash << 6) + (hash << 16) - hash;
Willy Tarreau79e57332018-10-02 16:01:16 +02001134 }
1135
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001136 /* now retrieve the path */
1137 sl = http_get_stline(htx);
1138 path = http_get_path(htx_sl_req_uri(sl));
Tim Duesterhused526372020-03-05 17:56:33 +01001139 if (isttest(path)) {
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001140 size_t len;
Willy Tarreau79e57332018-10-02 16:01:16 +02001141
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001142 for (len = 0; len < path.len && *(path.ptr + len) != '?'; len++)
1143 ;
Willy Tarreau79e57332018-10-02 16:01:16 +02001144
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001145 if (len && *(path.ptr) == '/') {
1146 while (len--)
1147 hash = *(path.ptr++) + (hash << 6) + (hash << 16) - hash;
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001148 }
Willy Tarreau79e57332018-10-02 16:01:16 +02001149 }
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001150
Willy Tarreau79e57332018-10-02 16:01:16 +02001151 hash = full_hash(hash);
1152
1153 smp->data.type = SMP_T_SINT;
1154 smp->data.u.sint = hash;
1155 smp->flags = SMP_F_VOL_1ST;
1156 return 1;
1157}
1158
1159/* This concatenates the source address with the 32-bit hash of the Host and
1160 * path as returned by smp_fetch_base32(). The idea is to have per-source and
1161 * per-path counters. The result is a binary block from 8 to 20 bytes depending
1162 * on the source address length. The path hash is stored before the address so
1163 * that in environments where IPv6 is insignificant, truncating the output to
1164 * 8 bytes would still work.
1165 */
1166static int smp_fetch_base32_src(const struct arg *args, struct sample *smp, const char *kw, void *private)
1167{
1168 struct buffer *temp;
1169 struct connection *cli_conn = objt_conn(smp->sess->origin);
1170
Willy Tarreaucd7ca792019-07-17 16:57:03 +02001171 if (!cli_conn || !conn_get_src(cli_conn))
Willy Tarreau79e57332018-10-02 16:01:16 +02001172 return 0;
1173
1174 if (!smp_fetch_base32(args, smp, kw, private))
1175 return 0;
1176
1177 temp = get_trash_chunk();
1178 *(unsigned int *) temp->area = htonl(smp->data.u.sint);
1179 temp->data += sizeof(unsigned int);
1180
Willy Tarreau9a1efe12019-07-17 17:13:50 +02001181 switch (cli_conn->src->ss_family) {
Willy Tarreau79e57332018-10-02 16:01:16 +02001182 case AF_INET:
1183 memcpy(temp->area + temp->data,
Willy Tarreau9a1efe12019-07-17 17:13:50 +02001184 &((struct sockaddr_in *)cli_conn->src)->sin_addr,
Willy Tarreau79e57332018-10-02 16:01:16 +02001185 4);
1186 temp->data += 4;
1187 break;
1188 case AF_INET6:
1189 memcpy(temp->area + temp->data,
Willy Tarreau9a1efe12019-07-17 17:13:50 +02001190 &((struct sockaddr_in6 *)cli_conn->src)->sin6_addr,
Willy Tarreau79e57332018-10-02 16:01:16 +02001191 16);
1192 temp->data += 16;
1193 break;
1194 default:
1195 return 0;
1196 }
1197
1198 smp->data.u.str = *temp;
1199 smp->data.type = SMP_T_BIN;
1200 return 1;
1201}
1202
1203/* Extracts the query string, which comes after the question mark '?'. If no
1204 * question mark is found, nothing is returned. Otherwise it returns a sample
1205 * of type string carrying the whole query string.
1206 */
1207static int smp_fetch_query(const struct arg *args, struct sample *smp, const char *kw, void *private)
1208{
Christopher Faulet89dc4992019-04-17 12:02:59 +02001209 struct channel *chn = SMP_REQ_CHN(smp);
Christopher Faulet778f5ed2020-04-29 15:51:55 +02001210 struct htx *htx = smp_prefetch_htx(smp, chn, NULL, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001211 struct htx_sl *sl;
Willy Tarreau79e57332018-10-02 16:01:16 +02001212 char *ptr, *end;
1213
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001214 if (!htx)
1215 return 0;
Willy Tarreau79e57332018-10-02 16:01:16 +02001216
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001217 sl = http_get_stline(htx);
1218 ptr = HTX_SL_REQ_UPTR(sl);
1219 end = HTX_SL_REQ_UPTR(sl) + HTX_SL_REQ_ULEN(sl);
Willy Tarreau79e57332018-10-02 16:01:16 +02001220
1221 /* look up the '?' */
1222 do {
1223 if (ptr == end)
1224 return 0;
1225 } while (*ptr++ != '?');
1226
1227 smp->data.type = SMP_T_STR;
1228 smp->data.u.str.area = ptr;
1229 smp->data.u.str.data = end - ptr;
1230 smp->flags = SMP_F_VOL_1ST | SMP_F_CONST;
1231 return 1;
1232}
1233
1234static int smp_fetch_proto_http(const struct arg *args, struct sample *smp, const char *kw, void *private)
1235{
Christopher Faulet89dc4992019-04-17 12:02:59 +02001236 struct channel *chn = SMP_REQ_CHN(smp);
Christopher Faulet778f5ed2020-04-29 15:51:55 +02001237 struct htx *htx = smp_prefetch_htx(smp, chn, NULL, 0);
Willy Tarreau79e57332018-10-02 16:01:16 +02001238
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001239 if (!htx)
1240 return 0;
1241 smp->data.type = SMP_T_BOOL;
Willy Tarreau79e57332018-10-02 16:01:16 +02001242 smp->data.u.sint = 1;
1243 return 1;
1244}
1245
1246/* return a valid test if the current request is the first one on the connection */
1247static int smp_fetch_http_first_req(const struct arg *args, struct sample *smp, const char *kw, void *private)
1248{
Willy Tarreau79512b62020-04-29 11:52:13 +02001249 if (!smp->strm)
1250 return 0;
1251
Willy Tarreau79e57332018-10-02 16:01:16 +02001252 smp->data.type = SMP_T_BOOL;
1253 smp->data.u.sint = !(smp->strm->txn->flags & TX_NOT_FIRST);
1254 return 1;
1255}
1256
Christopher Fauleta4063562019-08-02 11:51:37 +02001257/* Fetch the authentication method if there is an Authorization header. It
1258 * relies on get_http_auth()
1259 */
1260static int smp_fetch_http_auth_type(const struct arg *args, struct sample *smp, const char *kw, void *private)
1261{
1262 struct channel *chn = SMP_REQ_CHN(smp);
Christopher Faulet778f5ed2020-04-29 15:51:55 +02001263 struct htx *htx = smp_prefetch_htx(smp, chn, NULL, 1);
Christopher Fauleta4063562019-08-02 11:51:37 +02001264 struct http_txn *txn;
1265
1266 if (!htx)
1267 return 0;
1268
1269 txn = smp->strm->txn;
1270 if (!get_http_auth(smp, htx))
1271 return 0;
1272
1273 switch (txn->auth.method) {
1274 case HTTP_AUTH_BASIC:
1275 smp->data.u.str.area = "Basic";
1276 smp->data.u.str.data = 5;
1277 break;
1278 case HTTP_AUTH_DIGEST:
1279 /* Unexpected because not supported */
1280 smp->data.u.str.area = "Digest";
1281 smp->data.u.str.data = 6;
1282 break;
1283 default:
1284 return 0;
1285 }
1286
1287 smp->data.type = SMP_T_STR;
1288 smp->flags = SMP_F_CONST;
1289 return 1;
1290}
1291
1292/* Fetch the user supplied if there is an Authorization header. It relies on
1293 * get_http_auth()
1294 */
1295static int smp_fetch_http_auth_user(const struct arg *args, struct sample *smp, const char *kw, void *private)
1296{
1297 struct channel *chn = SMP_REQ_CHN(smp);
Christopher Faulet778f5ed2020-04-29 15:51:55 +02001298 struct htx *htx = smp_prefetch_htx(smp, chn, NULL, 1);
Christopher Fauleta4063562019-08-02 11:51:37 +02001299 struct http_txn *txn;
1300
1301 if (!htx)
1302 return 0;
1303
1304 txn = smp->strm->txn;
1305 if (!get_http_auth(smp, htx))
1306 return 0;
1307
1308 smp->data.type = SMP_T_STR;
1309 smp->data.u.str.area = txn->auth.user;
1310 smp->data.u.str.data = strlen(txn->auth.user);
1311 smp->flags = SMP_F_CONST;
1312 return 1;
1313}
1314
1315/* Fetch the password supplied if there is an Authorization header. It relies on
1316 * get_http_auth()
1317 */
1318static int smp_fetch_http_auth_pass(const struct arg *args, struct sample *smp, const char *kw, void *private)
1319{
1320 struct channel *chn = SMP_REQ_CHN(smp);
Christopher Faulet778f5ed2020-04-29 15:51:55 +02001321 struct htx *htx = smp_prefetch_htx(smp, chn, NULL, 1);
Christopher Fauleta4063562019-08-02 11:51:37 +02001322 struct http_txn *txn;
1323
1324 if (!htx)
1325 return 0;
1326
1327 txn = smp->strm->txn;
1328 if (!get_http_auth(smp, htx))
1329 return 0;
1330
1331 smp->data.type = SMP_T_STR;
1332 smp->data.u.str.area = txn->auth.pass;
1333 smp->data.u.str.data = strlen(txn->auth.pass);
1334 smp->flags = SMP_F_CONST;
1335 return 1;
1336}
1337
Willy Tarreau79e57332018-10-02 16:01:16 +02001338/* Accepts exactly 1 argument of type userlist */
1339static int smp_fetch_http_auth(const struct arg *args, struct sample *smp, const char *kw, void *private)
1340{
Christopher Faulet89dc4992019-04-17 12:02:59 +02001341 struct channel *chn = SMP_REQ_CHN(smp);
Christopher Faulet778f5ed2020-04-29 15:51:55 +02001342 struct htx *htx = smp_prefetch_htx(smp, chn, NULL, 1);
Willy Tarreau79e57332018-10-02 16:01:16 +02001343
1344 if (!args || args->type != ARGT_USR)
1345 return 0;
1346
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001347 if (!htx)
1348 return 0;
1349 if (!get_http_auth(smp, htx))
1350 return 0;
Willy Tarreau79e57332018-10-02 16:01:16 +02001351
1352 smp->data.type = SMP_T_BOOL;
1353 smp->data.u.sint = check_user(args->data.usr, smp->strm->txn->auth.user,
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001354 smp->strm->txn->auth.pass);
Willy Tarreau79e57332018-10-02 16:01:16 +02001355 return 1;
1356}
1357
1358/* Accepts exactly 1 argument of type userlist */
1359static int smp_fetch_http_auth_grp(const struct arg *args, struct sample *smp, const char *kw, void *private)
1360{
Christopher Faulet89dc4992019-04-17 12:02:59 +02001361 struct channel *chn = SMP_REQ_CHN(smp);
Christopher Faulet778f5ed2020-04-29 15:51:55 +02001362 struct htx *htx = smp_prefetch_htx(smp, chn, NULL, 1);
Christopher Faulet89dc4992019-04-17 12:02:59 +02001363
Willy Tarreau79e57332018-10-02 16:01:16 +02001364 if (!args || args->type != ARGT_USR)
1365 return 0;
1366
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001367 if (!htx)
1368 return 0;
1369 if (!get_http_auth(smp, htx))
1370 return 0;
Willy Tarreau79e57332018-10-02 16:01:16 +02001371
Willy Tarreau79e57332018-10-02 16:01:16 +02001372 /* if the user does not belong to the userlist or has a wrong password,
1373 * report that it unconditionally does not match. Otherwise we return
1374 * a string containing the username.
1375 */
1376 if (!check_user(args->data.usr, smp->strm->txn->auth.user,
1377 smp->strm->txn->auth.pass))
1378 return 0;
1379
1380 /* pat_match_auth() will need the user list */
1381 smp->ctx.a[0] = args->data.usr;
1382
1383 smp->data.type = SMP_T_STR;
1384 smp->flags = SMP_F_CONST;
1385 smp->data.u.str.area = smp->strm->txn->auth.user;
1386 smp->data.u.str.data = strlen(smp->strm->txn->auth.user);
1387
1388 return 1;
1389}
1390
1391/* Fetch a captured HTTP request header. The index is the position of
1392 * the "capture" option in the configuration file
1393 */
1394static int smp_fetch_capture_req_hdr(const struct arg *args, struct sample *smp, const char *kw, void *private)
1395{
Willy Tarreau0898c2d2020-04-29 11:44:54 +02001396 struct proxy *fe;
Willy Tarreau79e57332018-10-02 16:01:16 +02001397 int idx;
1398
1399 if (!args || args->type != ARGT_SINT)
1400 return 0;
1401
Willy Tarreau0898c2d2020-04-29 11:44:54 +02001402 if (!smp->strm)
1403 return 0;
1404
1405 fe = strm_fe(smp->strm);
Willy Tarreau79e57332018-10-02 16:01:16 +02001406 idx = args->data.sint;
1407
1408 if (idx > (fe->nb_req_cap - 1) || smp->strm->req_cap == NULL || smp->strm->req_cap[idx] == NULL)
1409 return 0;
1410
1411 smp->data.type = SMP_T_STR;
1412 smp->flags |= SMP_F_CONST;
1413 smp->data.u.str.area = smp->strm->req_cap[idx];
1414 smp->data.u.str.data = strlen(smp->strm->req_cap[idx]);
1415
1416 return 1;
1417}
1418
1419/* Fetch a captured HTTP response header. The index is the position of
1420 * the "capture" option in the configuration file
1421 */
1422static int smp_fetch_capture_res_hdr(const struct arg *args, struct sample *smp, const char *kw, void *private)
1423{
Willy Tarreau0898c2d2020-04-29 11:44:54 +02001424 struct proxy *fe;
Willy Tarreau79e57332018-10-02 16:01:16 +02001425 int idx;
1426
1427 if (!args || args->type != ARGT_SINT)
1428 return 0;
1429
Willy Tarreau0898c2d2020-04-29 11:44:54 +02001430 if (!smp->strm)
1431 return 0;
1432
1433 fe = strm_fe(smp->strm);
Willy Tarreau79e57332018-10-02 16:01:16 +02001434 idx = args->data.sint;
1435
1436 if (idx > (fe->nb_rsp_cap - 1) || smp->strm->res_cap == NULL || smp->strm->res_cap[idx] == NULL)
1437 return 0;
1438
1439 smp->data.type = SMP_T_STR;
1440 smp->flags |= SMP_F_CONST;
1441 smp->data.u.str.area = smp->strm->res_cap[idx];
1442 smp->data.u.str.data = strlen(smp->strm->res_cap[idx]);
1443
1444 return 1;
1445}
1446
1447/* Extracts the METHOD in the HTTP request, the txn->uri should be filled before the call */
1448static int smp_fetch_capture_req_method(const struct arg *args, struct sample *smp, const char *kw, void *private)
1449{
1450 struct buffer *temp;
Willy Tarreau0898c2d2020-04-29 11:44:54 +02001451 struct http_txn *txn;
Willy Tarreau79e57332018-10-02 16:01:16 +02001452 char *ptr;
1453
Willy Tarreau0898c2d2020-04-29 11:44:54 +02001454 if (!smp->strm)
1455 return 0;
1456
1457 txn = smp->strm->txn;
Willy Tarreau79e57332018-10-02 16:01:16 +02001458 if (!txn || !txn->uri)
1459 return 0;
1460
1461 ptr = txn->uri;
1462
1463 while (*ptr != ' ' && *ptr != '\0') /* find first space */
1464 ptr++;
1465
1466 temp = get_trash_chunk();
1467 temp->area = txn->uri;
1468 temp->data = ptr - txn->uri;
1469 smp->data.u.str = *temp;
1470 smp->data.type = SMP_T_STR;
1471 smp->flags = SMP_F_CONST;
1472
1473 return 1;
1474
1475}
1476
1477/* Extracts the path in the HTTP request, the txn->uri should be filled before the call */
1478static int smp_fetch_capture_req_uri(const struct arg *args, struct sample *smp, const char *kw, void *private)
1479{
Willy Tarreau0898c2d2020-04-29 11:44:54 +02001480 struct http_txn *txn;
Willy Tarreau79e57332018-10-02 16:01:16 +02001481 struct ist path;
1482 const char *ptr;
1483
Willy Tarreau0898c2d2020-04-29 11:44:54 +02001484 if (!smp->strm)
1485 return 0;
1486
1487 txn = smp->strm->txn;
Willy Tarreau79e57332018-10-02 16:01:16 +02001488 if (!txn || !txn->uri)
1489 return 0;
1490
1491 ptr = txn->uri;
1492
1493 while (*ptr != ' ' && *ptr != '\0') /* find first space */
1494 ptr++;
1495
1496 if (!*ptr)
1497 return 0;
1498
Christopher Faulet78337bb2018-11-15 14:35:18 +01001499 /* skip the first space and find space after URI */
1500 path = ist2(++ptr, 0);
1501 while (*ptr != ' ' && *ptr != '\0')
1502 ptr++;
1503 path.len = ptr - path.ptr;
Willy Tarreau79e57332018-10-02 16:01:16 +02001504
Christopher Faulet78337bb2018-11-15 14:35:18 +01001505 path = http_get_path(path);
Tim Duesterhused526372020-03-05 17:56:33 +01001506 if (!isttest(path))
Willy Tarreau79e57332018-10-02 16:01:16 +02001507 return 0;
1508
1509 smp->data.u.str.area = path.ptr;
1510 smp->data.u.str.data = path.len;
1511 smp->data.type = SMP_T_STR;
1512 smp->flags = SMP_F_CONST;
1513
1514 return 1;
1515}
1516
1517/* Retrieves the HTTP version from the request (either 1.0 or 1.1) and emits it
1518 * as a string (either "HTTP/1.0" or "HTTP/1.1").
1519 */
1520static int smp_fetch_capture_req_ver(const struct arg *args, struct sample *smp, const char *kw, void *private)
1521{
Willy Tarreau0898c2d2020-04-29 11:44:54 +02001522 struct http_txn *txn;
1523
1524 if (!smp->strm)
1525 return 0;
Willy Tarreau79e57332018-10-02 16:01:16 +02001526
Willy Tarreau0898c2d2020-04-29 11:44:54 +02001527 txn = smp->strm->txn;
Christopher Faulet711ed6a2019-07-16 14:16:10 +02001528 if (!txn || txn->req.msg_state >= HTTP_MSG_BODY)
Willy Tarreau79e57332018-10-02 16:01:16 +02001529 return 0;
1530
1531 if (txn->req.flags & HTTP_MSGF_VER_11)
1532 smp->data.u.str.area = "HTTP/1.1";
1533 else
1534 smp->data.u.str.area = "HTTP/1.0";
1535
1536 smp->data.u.str.data = 8;
1537 smp->data.type = SMP_T_STR;
1538 smp->flags = SMP_F_CONST;
1539 return 1;
1540
1541}
1542
1543/* Retrieves the HTTP version from the response (either 1.0 or 1.1) and emits it
1544 * as a string (either "HTTP/1.0" or "HTTP/1.1").
1545 */
1546static int smp_fetch_capture_res_ver(const struct arg *args, struct sample *smp, const char *kw, void *private)
1547{
Willy Tarreau0898c2d2020-04-29 11:44:54 +02001548 struct http_txn *txn;
1549
1550 if (!smp->strm)
1551 return 0;
Willy Tarreau79e57332018-10-02 16:01:16 +02001552
Willy Tarreau0898c2d2020-04-29 11:44:54 +02001553 txn = smp->strm->txn;
Christopher Faulet711ed6a2019-07-16 14:16:10 +02001554 if (!txn || txn->rsp.msg_state >= HTTP_MSG_BODY)
Willy Tarreau79e57332018-10-02 16:01:16 +02001555 return 0;
1556
1557 if (txn->rsp.flags & HTTP_MSGF_VER_11)
1558 smp->data.u.str.area = "HTTP/1.1";
1559 else
1560 smp->data.u.str.area = "HTTP/1.0";
1561
1562 smp->data.u.str.data = 8;
1563 smp->data.type = SMP_T_STR;
1564 smp->flags = SMP_F_CONST;
1565 return 1;
1566
1567}
1568
1569/* Iterate over all cookies present in a message. The context is stored in
1570 * smp->ctx.a[0] for the in-header position, smp->ctx.a[1] for the
1571 * end-of-header-value, and smp->ctx.a[2] for the hdr_ctx. Depending on
1572 * the direction, multiple cookies may be parsed on the same line or not.
Maciej Zdebdea7c202020-11-13 09:38:06 +00001573 * If provided, the searched cookie name is in args, in args->data.str. If
1574 * the input options indicate that no iterating is desired, then only last
1575 * value is fetched if any. If no cookie name is provided, the first cookie
1576 * value found is fetched. The returned sample is of type CSTR. Can be used
1577 * to parse cookies in other files.
Willy Tarreau79e57332018-10-02 16:01:16 +02001578 */
1579static int smp_fetch_cookie(const struct arg *args, struct sample *smp, const char *kw, void *private)
1580{
Christopher Faulet89dc4992019-04-17 12:02:59 +02001581 /* possible keywords: req.cookie / cookie / cook, res.cookie / scook / set-cookie */
1582 struct channel *chn = ((kw[0] == 'c' || kw[2] == 'q') ? SMP_REQ_CHN(smp) : SMP_RES_CHN(smp));
Christopher Fauletf98e6262020-05-06 09:42:04 +02001583 struct check *check = ((kw[0] == 's' || kw[2] == 's') ? objt_check(smp->sess->origin) : NULL);
Christopher Faulet16032ab2020-04-30 11:30:00 +02001584 struct htx *htx = smp_prefetch_htx(smp, chn, check, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001585 struct http_hdr_ctx *ctx = smp->ctx.a[2];
1586 struct ist hdr;
Christopher Faulet97fc8da2020-11-13 13:41:04 +01001587 char *cook = NULL;
1588 size_t cook_l = 0;
Willy Tarreau79e57332018-10-02 16:01:16 +02001589 int found = 0;
1590
Christopher Faulet97fc8da2020-11-13 13:41:04 +01001591 if (args && args->type == ARGT_STR) {
1592 cook = args->data.str.area;
1593 cook_l = args->data.str.data;
1594 }
Willy Tarreau79e57332018-10-02 16:01:16 +02001595
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001596 if (!ctx) {
1597 /* first call */
1598 ctx = &static_http_hdr_ctx;
1599 ctx->blk = NULL;
1600 smp->ctx.a[2] = ctx;
1601 }
Willy Tarreau79e57332018-10-02 16:01:16 +02001602
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001603 if (!htx)
1604 return 0;
Willy Tarreau79e57332018-10-02 16:01:16 +02001605
Christopher Faulet16032ab2020-04-30 11:30:00 +02001606 hdr = (!(check || (chn && chn->flags & CF_ISRESP)) ? ist("Cookie") : ist("Set-Cookie"));
Willy Tarreau79e57332018-10-02 16:01:16 +02001607
Maciej Zdebdea7c202020-11-13 09:38:06 +00001608 /* OK so basically here, either we want only one value or we want to
1609 * iterate over all of them and we fetch the next one. In this last case
1610 * SMP_OPT_ITERATE option is set.
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001611 */
Willy Tarreau79e57332018-10-02 16:01:16 +02001612
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001613 if (!(smp->flags & SMP_F_NOT_LAST)) {
1614 /* search for the header from the beginning, we must first initialize
1615 * the search parameters.
Willy Tarreau79e57332018-10-02 16:01:16 +02001616 */
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001617 smp->ctx.a[0] = NULL;
1618 ctx->blk = NULL;
Willy Tarreau79e57332018-10-02 16:01:16 +02001619 }
Willy Tarreau79e57332018-10-02 16:01:16 +02001620
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001621 smp->flags |= SMP_F_VOL_HDR;
1622 while (1) {
1623 /* Note: smp->ctx.a[0] == NULL every time we need to fetch a new header */
1624 if (!smp->ctx.a[0]) {
1625 if (!http_find_header(htx, hdr, ctx, 0))
1626 goto out;
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001627
Christopher Faulet97fc8da2020-11-13 13:41:04 +01001628 if (ctx->value.len < cook_l + 1)
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001629 continue;
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001630
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001631 smp->ctx.a[0] = ctx->value.ptr;
1632 smp->ctx.a[1] = smp->ctx.a[0] + ctx->value.len;
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001633 }
1634
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001635 smp->data.type = SMP_T_STR;
1636 smp->flags |= SMP_F_CONST;
1637 smp->ctx.a[0] = http_extract_cookie_value(smp->ctx.a[0], smp->ctx.a[1],
Christopher Faulet97fc8da2020-11-13 13:41:04 +01001638 cook, cook_l,
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001639 (smp->opt & SMP_OPT_DIR) == SMP_OPT_DIR_REQ,
1640 &smp->data.u.str.area,
1641 &smp->data.u.str.data);
1642 if (smp->ctx.a[0]) {
1643 found = 1;
Maciej Zdebdea7c202020-11-13 09:38:06 +00001644 if (smp->opt & SMP_OPT_ITERATE) {
1645 /* iterate on cookie value */
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001646 smp->flags |= SMP_F_NOT_LAST;
1647 return 1;
Willy Tarreau79e57332018-10-02 16:01:16 +02001648 }
Maciej Zdebdea7c202020-11-13 09:38:06 +00001649 if (args->data.str.data == 0) {
1650 /* No cookie name, first occurrence returned */
1651 break;
1652 }
Willy Tarreau79e57332018-10-02 16:01:16 +02001653 }
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001654 /* if we're looking for last occurrence, let's loop */
Willy Tarreau79e57332018-10-02 16:01:16 +02001655 }
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001656
Willy Tarreau79e57332018-10-02 16:01:16 +02001657 /* all cookie headers and values were scanned. If we're looking for the
1658 * last occurrence, we may return it now.
1659 */
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001660 out:
Willy Tarreau79e57332018-10-02 16:01:16 +02001661 smp->flags &= ~SMP_F_NOT_LAST;
1662 return found;
1663}
1664
Christopher Fauletc1f40dd2019-05-16 10:07:30 +02001665/* Same than smp_fetch_cookie() but only relies on the sample direction to
1666 * choose the right channel. So instead of duplicating the code, we just change
1667 * the keyword and then fallback on smp_fetch_cookie().
1668 */
1669static int smp_fetch_chn_cookie(const struct arg *args, struct sample *smp, const char *kw, void *private)
1670{
1671 kw = ((smp->opt & SMP_OPT_DIR) == SMP_OPT_DIR_REQ ? "req.cook" : "res.cook");
1672 return smp_fetch_cookie(args, smp, kw, private);
1673}
1674
Willy Tarreau79e57332018-10-02 16:01:16 +02001675/* Iterate over all cookies present in a request to count how many occurrences
1676 * match the name in args and args->data.str.len. If <multi> is non-null, then
1677 * multiple cookies may be parsed on the same line. The returned sample is of
1678 * type UINT. Accepts exactly 1 argument of type string.
1679 */
1680static int smp_fetch_cookie_cnt(const struct arg *args, struct sample *smp, const char *kw, void *private)
1681{
Christopher Faulet89dc4992019-04-17 12:02:59 +02001682 /* possible keywords: req.cook_cnt / cook_cnt, res.cook_cnt / scook_cnt */
1683 struct channel *chn = ((kw[0] == 'c' || kw[2] == 'q') ? SMP_REQ_CHN(smp) : SMP_RES_CHN(smp));
Christopher Fauletf98e6262020-05-06 09:42:04 +02001684 struct check *check = ((kw[0] == 's' || kw[2] == 's') ? objt_check(smp->sess->origin) : NULL);
Christopher Faulet16032ab2020-04-30 11:30:00 +02001685 struct htx *htx = smp_prefetch_htx(smp, chn, check, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001686 struct http_hdr_ctx ctx;
1687 struct ist hdr;
Willy Tarreau79e57332018-10-02 16:01:16 +02001688 char *val_beg, *val_end;
Christopher Faulet97fc8da2020-11-13 13:41:04 +01001689 char *cook = NULL;
1690 size_t cook_l = 0;
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001691 int cnt;
Willy Tarreau79e57332018-10-02 16:01:16 +02001692
Christopher Faulet97fc8da2020-11-13 13:41:04 +01001693 if (args && args->type == ARGT_STR){
1694 cook = args->data.str.area;
1695 cook_l = args->data.str.data;
1696 }
Willy Tarreau79e57332018-10-02 16:01:16 +02001697
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001698 if (!htx)
1699 return 0;
Willy Tarreau79e57332018-10-02 16:01:16 +02001700
Christopher Faulet16032ab2020-04-30 11:30:00 +02001701 hdr = (!(check || (chn && chn->flags & CF_ISRESP)) ? ist("Cookie") : ist("Set-Cookie"));
Willy Tarreau79e57332018-10-02 16:01:16 +02001702
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001703 val_end = val_beg = NULL;
1704 ctx.blk = NULL;
1705 cnt = 0;
1706 while (1) {
1707 /* Note: val_beg == NULL every time we need to fetch a new header */
1708 if (!val_beg) {
1709 if (!http_find_header(htx, hdr, &ctx, 0))
1710 break;
Willy Tarreau79e57332018-10-02 16:01:16 +02001711
Christopher Faulet97fc8da2020-11-13 13:41:04 +01001712 if (ctx.value.len < cook_l + 1)
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001713 continue;
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001714
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001715 val_beg = ctx.value.ptr;
1716 val_end = val_beg + ctx.value.len;
Willy Tarreau79e57332018-10-02 16:01:16 +02001717 }
1718
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001719 smp->data.type = SMP_T_STR;
1720 smp->flags |= SMP_F_CONST;
1721 while ((val_beg = http_extract_cookie_value(val_beg, val_end,
Christopher Faulet97fc8da2020-11-13 13:41:04 +01001722 cook, cook_l,
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001723 (smp->opt & SMP_OPT_DIR) == SMP_OPT_DIR_REQ,
1724 &smp->data.u.str.area,
1725 &smp->data.u.str.data))) {
1726 cnt++;
Willy Tarreau79e57332018-10-02 16:01:16 +02001727 }
1728 }
1729
1730 smp->data.type = SMP_T_SINT;
1731 smp->data.u.sint = cnt;
1732 smp->flags |= SMP_F_VOL_HDR;
1733 return 1;
1734}
1735
1736/* Fetch an cookie's integer value. The integer value is returned. It
1737 * takes a mandatory argument of type string. It relies on smp_fetch_cookie().
1738 */
1739static int smp_fetch_cookie_val(const struct arg *args, struct sample *smp, const char *kw, void *private)
1740{
1741 int ret = smp_fetch_cookie(args, smp, kw, private);
1742
1743 if (ret > 0) {
1744 smp->data.type = SMP_T_SINT;
1745 smp->data.u.sint = strl2ic(smp->data.u.str.area,
1746 smp->data.u.str.data);
1747 }
1748
1749 return ret;
1750}
1751
1752/************************************************************************/
1753/* The code below is dedicated to sample fetches */
1754/************************************************************************/
1755
1756/* This scans a URL-encoded query string. It takes an optionally wrapping
Ilya Shipitsin46a030c2020-07-05 16:36:08 +05001757 * string whose first contiguous chunk has its beginning in ctx->a[0] and end
Willy Tarreau79e57332018-10-02 16:01:16 +02001758 * in ctx->a[1], and the optional second part in (ctx->a[2]..ctx->a[3]). The
1759 * pointers are updated for next iteration before leaving.
1760 */
1761static int smp_fetch_param(char delim, const char *name, int name_len, const struct arg *args, struct sample *smp, const char *kw, void *private)
1762{
1763 const char *vstart, *vend;
1764 struct buffer *temp;
1765 const char **chunks = (const char **)smp->ctx.a;
1766
1767 if (!http_find_next_url_param(chunks, name, name_len,
1768 &vstart, &vend, delim))
1769 return 0;
1770
1771 /* Create sample. If the value is contiguous, return the pointer as CONST,
1772 * if the value is wrapped, copy-it in a buffer.
1773 */
1774 smp->data.type = SMP_T_STR;
1775 if (chunks[2] &&
1776 vstart >= chunks[0] && vstart <= chunks[1] &&
1777 vend >= chunks[2] && vend <= chunks[3]) {
1778 /* Wrapped case. */
1779 temp = get_trash_chunk();
1780 memcpy(temp->area, vstart, chunks[1] - vstart);
1781 memcpy(temp->area + ( chunks[1] - vstart ), chunks[2],
1782 vend - chunks[2]);
1783 smp->data.u.str.area = temp->area;
1784 smp->data.u.str.data = ( chunks[1] - vstart ) + ( vend - chunks[2] );
1785 } else {
1786 /* Contiguous case. */
1787 smp->data.u.str.area = (char *)vstart;
1788 smp->data.u.str.data = vend - vstart;
1789 smp->flags = SMP_F_VOL_1ST | SMP_F_CONST;
1790 }
1791
1792 /* Update context, check wrapping. */
1793 chunks[0] = vend;
1794 if (chunks[2] && vend >= chunks[2] && vend <= chunks[3]) {
1795 chunks[1] = chunks[3];
1796 chunks[2] = NULL;
1797 }
1798
1799 if (chunks[0] < chunks[1])
1800 smp->flags |= SMP_F_NOT_LAST;
1801
1802 return 1;
1803}
1804
1805/* This function iterates over each parameter of the query string. It uses
1806 * ctx->a[0] and ctx->a[1] to store the beginning and end of the current
1807 * parameter. Since it uses smp_fetch_param(), ctx->a[2..3] are both NULL.
1808 * An optional parameter name is passed in args[0], otherwise any parameter is
1809 * considered. It supports an optional delimiter argument for the beginning of
1810 * the string in args[1], which defaults to "?".
1811 */
1812static int smp_fetch_url_param(const struct arg *args, struct sample *smp, const char *kw, void *private)
1813{
Christopher Faulet89dc4992019-04-17 12:02:59 +02001814 struct channel *chn = SMP_REQ_CHN(smp);
Willy Tarreau79e57332018-10-02 16:01:16 +02001815 char delim = '?';
1816 const char *name;
1817 int name_len;
1818
1819 if (!args ||
1820 (args[0].type && args[0].type != ARGT_STR) ||
1821 (args[1].type && args[1].type != ARGT_STR))
1822 return 0;
1823
1824 name = "";
1825 name_len = 0;
1826 if (args->type == ARGT_STR) {
1827 name = args->data.str.area;
1828 name_len = args->data.str.data;
1829 }
1830
1831 if (args[1].type)
1832 delim = *args[1].data.str.area;
1833
1834 if (!smp->ctx.a[0]) { // first call, find the query string
Christopher Faulet778f5ed2020-04-29 15:51:55 +02001835 struct htx *htx = smp_prefetch_htx(smp, chn, NULL, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001836 struct htx_sl *sl;
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001837
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001838 if (!htx)
1839 return 0;
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001840
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001841 sl = http_get_stline(htx);
1842 smp->ctx.a[0] = http_find_param_list(HTX_SL_REQ_UPTR(sl), HTX_SL_REQ_ULEN(sl), delim);
1843 if (!smp->ctx.a[0])
1844 return 0;
Willy Tarreau79e57332018-10-02 16:01:16 +02001845
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001846 smp->ctx.a[1] = HTX_SL_REQ_UPTR(sl) + HTX_SL_REQ_ULEN(sl);
Willy Tarreau79e57332018-10-02 16:01:16 +02001847
1848 /* Assume that the context is filled with NULL pointer
1849 * before the first call.
1850 * smp->ctx.a[2] = NULL;
1851 * smp->ctx.a[3] = NULL;
1852 */
1853 }
1854
1855 return smp_fetch_param(delim, name, name_len, args, smp, kw, private);
1856}
1857
1858/* This function iterates over each parameter of the body. This requires
1859 * that the body has been waited for using http-buffer-request. It uses
1860 * ctx->a[0] and ctx->a[1] to store the beginning and end of the first
Ilya Shipitsin46a030c2020-07-05 16:36:08 +05001861 * contiguous part of the body, and optionally ctx->a[2..3] to reference the
Willy Tarreau79e57332018-10-02 16:01:16 +02001862 * optional second part if the body wraps at the end of the buffer. An optional
1863 * parameter name is passed in args[0], otherwise any parameter is considered.
1864 */
1865static int smp_fetch_body_param(const struct arg *args, struct sample *smp, const char *kw, void *private)
1866{
Christopher Faulet89dc4992019-04-17 12:02:59 +02001867 struct channel *chn = SMP_REQ_CHN(smp);
Willy Tarreau79e57332018-10-02 16:01:16 +02001868 const char *name;
1869 int name_len;
1870
1871 if (!args || (args[0].type && args[0].type != ARGT_STR))
1872 return 0;
1873
1874 name = "";
1875 name_len = 0;
1876 if (args[0].type == ARGT_STR) {
1877 name = args[0].data.str.area;
1878 name_len = args[0].data.str.data;
1879 }
1880
1881 if (!smp->ctx.a[0]) { // first call, find the query string
Christopher Faulete596d182020-05-05 17:46:34 +02001882 struct htx *htx = smp_prefetch_htx(smp, chn, NULL, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001883 struct buffer *temp;
1884 int32_t pos;
Willy Tarreau79e57332018-10-02 16:01:16 +02001885
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001886 if (!htx)
1887 return 0;
Willy Tarreau79e57332018-10-02 16:01:16 +02001888
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001889 temp = get_trash_chunk();
1890 for (pos = htx_get_first(htx); pos != -1; pos = htx_get_next(htx, pos)) {
1891 struct htx_blk *blk = htx_get_blk(htx, pos);
1892 enum htx_blk_type type = htx_get_blk_type(blk);
Willy Tarreau79e57332018-10-02 16:01:16 +02001893
Christopher Fauletd1ac2b92020-12-02 19:12:22 +01001894 if (type == HTX_BLK_TLR || type == HTX_BLK_EOT)
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001895 break;
1896 if (type == HTX_BLK_DATA) {
Christopher Faulet53a899b2019-10-08 16:38:42 +02001897 if (!h1_format_htx_data(htx_get_blk_value(htx, blk), temp, 0))
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001898 return 0;
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001899 }
Willy Tarreau79e57332018-10-02 16:01:16 +02001900 }
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001901
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001902 smp->ctx.a[0] = temp->area;
1903 smp->ctx.a[1] = temp->area + temp->data;
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001904
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001905 /* Assume that the context is filled with NULL pointer
1906 * before the first call.
1907 * smp->ctx.a[2] = NULL;
1908 * smp->ctx.a[3] = NULL;
1909 */
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001910
Willy Tarreau79e57332018-10-02 16:01:16 +02001911 }
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001912
Willy Tarreau79e57332018-10-02 16:01:16 +02001913 return smp_fetch_param('&', name, name_len, args, smp, kw, private);
1914}
1915
1916/* Return the signed integer value for the specified url parameter (see url_param
1917 * above).
1918 */
1919static int smp_fetch_url_param_val(const struct arg *args, struct sample *smp, const char *kw, void *private)
1920{
1921 int ret = smp_fetch_url_param(args, smp, kw, private);
1922
1923 if (ret > 0) {
1924 smp->data.type = SMP_T_SINT;
1925 smp->data.u.sint = strl2ic(smp->data.u.str.area,
1926 smp->data.u.str.data);
1927 }
1928
1929 return ret;
1930}
1931
1932/* This produces a 32-bit hash of the concatenation of the first occurrence of
1933 * the Host header followed by the path component if it begins with a slash ('/').
1934 * This means that '*' will not be added, resulting in exactly the first Host
1935 * entry. If no Host header is found, then the path is used. The resulting value
1936 * is hashed using the url hash followed by a full avalanche hash and provides a
1937 * 32-bit integer value. This fetch is useful for tracking per-URL activity on
1938 * high-traffic sites without having to store whole paths.
1939 * this differs from the base32 functions in that it includes the url parameters
1940 * as well as the path
1941 */
1942static int smp_fetch_url32(const struct arg *args, struct sample *smp, const char *kw, void *private)
1943{
Christopher Faulet89dc4992019-04-17 12:02:59 +02001944 struct channel *chn = SMP_REQ_CHN(smp);
Christopher Faulet778f5ed2020-04-29 15:51:55 +02001945 struct htx *htx = smp_prefetch_htx(smp, chn, NULL, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001946 struct http_hdr_ctx ctx;
1947 struct htx_sl *sl;
1948 struct ist path;
Willy Tarreau79e57332018-10-02 16:01:16 +02001949 unsigned int hash = 0;
Willy Tarreau79e57332018-10-02 16:01:16 +02001950
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001951 if (!htx)
1952 return 0;
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001953
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001954 ctx.blk = NULL;
1955 if (http_find_header(htx, ist("Host"), &ctx, 1)) {
1956 /* OK we have the header value in ctx.value */
1957 while (ctx.value.len--)
1958 hash = *(ctx.value.ptr++) + (hash << 6) + (hash << 16) - hash;
Willy Tarreau79e57332018-10-02 16:01:16 +02001959 }
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001960
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001961 /* now retrieve the path */
1962 sl = http_get_stline(htx);
1963 path = http_get_path(htx_sl_req_uri(sl));
Christopher Faulet6d1dd462019-07-15 14:36:03 +02001964 if (path.len && *(path.ptr) == '/') {
1965 while (path.len--)
1966 hash = *(path.ptr++) + (hash << 6) + (hash << 16) - hash;
Willy Tarreau79e57332018-10-02 16:01:16 +02001967 }
Christopher Faulet311c7ea2018-10-24 21:41:55 +02001968
Willy Tarreau79e57332018-10-02 16:01:16 +02001969 hash = full_hash(hash);
1970
1971 smp->data.type = SMP_T_SINT;
1972 smp->data.u.sint = hash;
1973 smp->flags = SMP_F_VOL_1ST;
1974 return 1;
1975}
1976
1977/* This concatenates the source address with the 32-bit hash of the Host and
1978 * URL as returned by smp_fetch_base32(). The idea is to have per-source and
1979 * per-url counters. The result is a binary block from 8 to 20 bytes depending
1980 * on the source address length. The URL hash is stored before the address so
1981 * that in environments where IPv6 is insignificant, truncating the output to
1982 * 8 bytes would still work.
1983 */
1984static int smp_fetch_url32_src(const struct arg *args, struct sample *smp, const char *kw, void *private)
1985{
1986 struct buffer *temp;
1987 struct connection *cli_conn = objt_conn(smp->sess->origin);
1988
Willy Tarreaucd7ca792019-07-17 16:57:03 +02001989 if (!cli_conn || !conn_get_src(cli_conn))
Willy Tarreau79e57332018-10-02 16:01:16 +02001990 return 0;
1991
1992 if (!smp_fetch_url32(args, smp, kw, private))
1993 return 0;
1994
1995 temp = get_trash_chunk();
1996 *(unsigned int *) temp->area = htonl(smp->data.u.sint);
1997 temp->data += sizeof(unsigned int);
1998
Willy Tarreau9a1efe12019-07-17 17:13:50 +02001999 switch (cli_conn->src->ss_family) {
Willy Tarreau79e57332018-10-02 16:01:16 +02002000 case AF_INET:
2001 memcpy(temp->area + temp->data,
Willy Tarreau9a1efe12019-07-17 17:13:50 +02002002 &((struct sockaddr_in *)cli_conn->src)->sin_addr,
Willy Tarreau79e57332018-10-02 16:01:16 +02002003 4);
2004 temp->data += 4;
2005 break;
2006 case AF_INET6:
2007 memcpy(temp->area + temp->data,
Willy Tarreau9a1efe12019-07-17 17:13:50 +02002008 &((struct sockaddr_in6 *)cli_conn->src)->sin6_addr,
Willy Tarreau79e57332018-10-02 16:01:16 +02002009 16);
2010 temp->data += 16;
2011 break;
2012 default:
2013 return 0;
2014 }
2015
2016 smp->data.u.str = *temp;
2017 smp->data.type = SMP_T_BIN;
2018 return 1;
2019}
2020
2021/************************************************************************/
2022/* Other utility functions */
2023/************************************************************************/
2024
2025/* This function is used to validate the arguments passed to any "hdr" fetch
2026 * keyword. These keywords support an optional positive or negative occurrence
2027 * number. We must ensure that the number is greater than -MAX_HDR_HISTORY. It
2028 * is assumed that the types are already the correct ones. Returns 0 on error,
2029 * non-zero if OK. If <err> is not NULL, it will be filled with a pointer to an
2030 * error message in case of error, that the caller is responsible for freeing.
2031 * The initial location must either be freeable or NULL.
2032 * Note: this function's pointer is checked from Lua.
2033 */
2034int val_hdr(struct arg *arg, char **err_msg)
2035{
2036 if (arg && arg[1].type == ARGT_SINT && arg[1].data.sint < -MAX_HDR_HISTORY) {
2037 memprintf(err_msg, "header occurrence must be >= %d", -MAX_HDR_HISTORY);
2038 return 0;
2039 }
2040 return 1;
2041}
2042
2043/************************************************************************/
2044/* All supported sample fetch keywords must be declared here. */
2045/************************************************************************/
2046
2047/* Note: must not be declared <const> as its list will be overwritten */
2048static struct sample_fetch_kw_list sample_fetch_keywords = {ILH, {
2049 { "base", smp_fetch_base, 0, NULL, SMP_T_STR, SMP_USE_HRQHV },
2050 { "base32", smp_fetch_base32, 0, NULL, SMP_T_SINT, SMP_USE_HRQHV },
2051 { "base32+src", smp_fetch_base32_src, 0, NULL, SMP_T_BIN, SMP_USE_HRQHV },
2052
2053 /* capture are allocated and are permanent in the stream */
2054 { "capture.req.hdr", smp_fetch_capture_req_hdr, ARG1(1,SINT), NULL, SMP_T_STR, SMP_USE_HRQHP },
2055
2056 /* retrieve these captures from the HTTP logs */
2057 { "capture.req.method", smp_fetch_capture_req_method, 0, NULL, SMP_T_STR, SMP_USE_HRQHP },
2058 { "capture.req.uri", smp_fetch_capture_req_uri, 0, NULL, SMP_T_STR, SMP_USE_HRQHP },
2059 { "capture.req.ver", smp_fetch_capture_req_ver, 0, NULL, SMP_T_STR, SMP_USE_HRQHP },
2060
2061 { "capture.res.hdr", smp_fetch_capture_res_hdr, ARG1(1,SINT), NULL, SMP_T_STR, SMP_USE_HRSHP },
2062 { "capture.res.ver", smp_fetch_capture_res_ver, 0, NULL, SMP_T_STR, SMP_USE_HRQHP },
2063
2064 /* cookie is valid in both directions (eg: for "stick ...") but cook*
2065 * are only here to match the ACL's name, are request-only and are used
2066 * for ACL compatibility only.
2067 */
2068 { "cook", smp_fetch_cookie, ARG1(0,STR), NULL, SMP_T_STR, SMP_USE_HRQHV },
Christopher Fauletc1f40dd2019-05-16 10:07:30 +02002069 { "cookie", smp_fetch_chn_cookie, ARG1(0,STR), NULL, SMP_T_STR, SMP_USE_HRQHV|SMP_USE_HRSHV },
Willy Tarreau79e57332018-10-02 16:01:16 +02002070 { "cook_cnt", smp_fetch_cookie_cnt, ARG1(0,STR), NULL, SMP_T_SINT, SMP_USE_HRQHV },
2071 { "cook_val", smp_fetch_cookie_val, ARG1(0,STR), NULL, SMP_T_SINT, SMP_USE_HRQHV },
2072
2073 /* hdr is valid in both directions (eg: for "stick ...") but hdr_* are
2074 * only here to match the ACL's name, are request-only and are used for
2075 * ACL compatibility only.
2076 */
Christopher Fauletc1f40dd2019-05-16 10:07:30 +02002077 { "hdr", smp_fetch_chn_hdr, ARG2(0,STR,SINT), val_hdr, SMP_T_STR, SMP_USE_HRQHV|SMP_USE_HRSHV },
Willy Tarreau79e57332018-10-02 16:01:16 +02002078 { "hdr_cnt", smp_fetch_hdr_cnt, ARG1(0,STR), NULL, SMP_T_SINT, SMP_USE_HRQHV },
2079 { "hdr_ip", smp_fetch_hdr_ip, ARG2(0,STR,SINT), val_hdr, SMP_T_IPV4, SMP_USE_HRQHV },
2080 { "hdr_val", smp_fetch_hdr_val, ARG2(0,STR,SINT), val_hdr, SMP_T_SINT, SMP_USE_HRQHV },
2081
Christopher Fauleta4063562019-08-02 11:51:37 +02002082 { "http_auth_type", smp_fetch_http_auth_type, 0, NULL, SMP_T_STR, SMP_USE_HRQHV },
2083 { "http_auth_user", smp_fetch_http_auth_user, 0, NULL, SMP_T_STR, SMP_USE_HRQHV },
2084 { "http_auth_pass", smp_fetch_http_auth_pass, 0, NULL, SMP_T_STR, SMP_USE_HRQHV },
Willy Tarreau79e57332018-10-02 16:01:16 +02002085 { "http_auth", smp_fetch_http_auth, ARG1(1,USR), NULL, SMP_T_BOOL, SMP_USE_HRQHV },
2086 { "http_auth_group", smp_fetch_http_auth_grp, ARG1(1,USR), NULL, SMP_T_STR, SMP_USE_HRQHV },
2087 { "http_first_req", smp_fetch_http_first_req, 0, NULL, SMP_T_BOOL, SMP_USE_HRQHP },
2088 { "method", smp_fetch_meth, 0, NULL, SMP_T_METH, SMP_USE_HRQHP },
2089 { "path", smp_fetch_path, 0, NULL, SMP_T_STR, SMP_USE_HRQHV },
Christopher Faulete720c322020-09-02 17:25:18 +02002090 { "pathq", smp_fetch_path, 0, NULL, SMP_T_STR, SMP_USE_HRQHV },
Willy Tarreau79e57332018-10-02 16:01:16 +02002091 { "query", smp_fetch_query, 0, NULL, SMP_T_STR, SMP_USE_HRQHV },
2092
2093 /* HTTP protocol on the request path */
2094 { "req.proto_http", smp_fetch_proto_http, 0, NULL, SMP_T_BOOL, SMP_USE_HRQHP },
2095 { "req_proto_http", smp_fetch_proto_http, 0, NULL, SMP_T_BOOL, SMP_USE_HRQHP },
2096
2097 /* HTTP version on the request path */
2098 { "req.ver", smp_fetch_rqver, 0, NULL, SMP_T_STR, SMP_USE_HRQHV },
2099 { "req_ver", smp_fetch_rqver, 0, NULL, SMP_T_STR, SMP_USE_HRQHV },
2100
2101 { "req.body", smp_fetch_body, 0, NULL, SMP_T_BIN, SMP_USE_HRQHV },
2102 { "req.body_len", smp_fetch_body_len, 0, NULL, SMP_T_SINT, SMP_USE_HRQHV },
2103 { "req.body_size", smp_fetch_body_size, 0, NULL, SMP_T_SINT, SMP_USE_HRQHV },
2104 { "req.body_param", smp_fetch_body_param, ARG1(0,STR), NULL, SMP_T_BIN, SMP_USE_HRQHV },
2105
2106 { "req.hdrs", smp_fetch_hdrs, 0, NULL, SMP_T_BIN, SMP_USE_HRQHV },
2107 { "req.hdrs_bin", smp_fetch_hdrs_bin, 0, NULL, SMP_T_BIN, SMP_USE_HRQHV },
2108
2109 /* HTTP version on the response path */
2110 { "res.ver", smp_fetch_stver, 0, NULL, SMP_T_STR, SMP_USE_HRSHV },
2111 { "resp_ver", smp_fetch_stver, 0, NULL, SMP_T_STR, SMP_USE_HRSHV },
2112
Christopher Faulete596d182020-05-05 17:46:34 +02002113 { "res.body", smp_fetch_body, 0, NULL, SMP_T_BIN, SMP_USE_HRSHV },
2114 { "res.body_len", smp_fetch_body_len, 0, NULL, SMP_T_SINT, SMP_USE_HRSHV },
2115 { "res.body_size", smp_fetch_body_size, 0, NULL, SMP_T_SINT, SMP_USE_HRSHV },
2116
2117 { "res.hdrs", smp_fetch_hdrs, 0, NULL, SMP_T_BIN, SMP_USE_HRSHV },
2118 { "res.hdrs_bin", smp_fetch_hdrs_bin, 0, NULL, SMP_T_BIN, SMP_USE_HRSHV },
2119
Willy Tarreau79e57332018-10-02 16:01:16 +02002120 /* explicit req.{cook,hdr} are used to force the fetch direction to be request-only */
2121 { "req.cook", smp_fetch_cookie, ARG1(0,STR), NULL, SMP_T_STR, SMP_USE_HRQHV },
2122 { "req.cook_cnt", smp_fetch_cookie_cnt, ARG1(0,STR), NULL, SMP_T_SINT, SMP_USE_HRQHV },
2123 { "req.cook_val", smp_fetch_cookie_val, ARG1(0,STR), NULL, SMP_T_SINT, SMP_USE_HRQHV },
2124
2125 { "req.fhdr", smp_fetch_fhdr, ARG2(0,STR,SINT), val_hdr, SMP_T_STR, SMP_USE_HRQHV },
2126 { "req.fhdr_cnt", smp_fetch_fhdr_cnt, ARG1(0,STR), NULL, SMP_T_SINT, SMP_USE_HRQHV },
2127 { "req.hdr", smp_fetch_hdr, ARG2(0,STR,SINT), val_hdr, SMP_T_STR, SMP_USE_HRQHV },
2128 { "req.hdr_cnt", smp_fetch_hdr_cnt, ARG1(0,STR), NULL, SMP_T_SINT, SMP_USE_HRQHV },
2129 { "req.hdr_ip", smp_fetch_hdr_ip, ARG2(0,STR,SINT), val_hdr, SMP_T_IPV4, SMP_USE_HRQHV },
2130 { "req.hdr_names", smp_fetch_hdr_names, ARG1(0,STR), NULL, SMP_T_STR, SMP_USE_HRQHV },
2131 { "req.hdr_val", smp_fetch_hdr_val, ARG2(0,STR,SINT), val_hdr, SMP_T_SINT, SMP_USE_HRQHV },
2132
2133 /* explicit req.{cook,hdr} are used to force the fetch direction to be response-only */
2134 { "res.cook", smp_fetch_cookie, ARG1(0,STR), NULL, SMP_T_STR, SMP_USE_HRSHV },
2135 { "res.cook_cnt", smp_fetch_cookie_cnt, ARG1(0,STR), NULL, SMP_T_SINT, SMP_USE_HRSHV },
2136 { "res.cook_val", smp_fetch_cookie_val, ARG1(0,STR), NULL, SMP_T_SINT, SMP_USE_HRSHV },
2137
2138 { "res.fhdr", smp_fetch_fhdr, ARG2(0,STR,SINT), val_hdr, SMP_T_STR, SMP_USE_HRSHV },
2139 { "res.fhdr_cnt", smp_fetch_fhdr_cnt, ARG1(0,STR), NULL, SMP_T_SINT, SMP_USE_HRSHV },
2140 { "res.hdr", smp_fetch_hdr, ARG2(0,STR,SINT), val_hdr, SMP_T_STR, SMP_USE_HRSHV },
2141 { "res.hdr_cnt", smp_fetch_hdr_cnt, ARG1(0,STR), NULL, SMP_T_SINT, SMP_USE_HRSHV },
2142 { "res.hdr_ip", smp_fetch_hdr_ip, ARG2(0,STR,SINT), val_hdr, SMP_T_IPV4, SMP_USE_HRSHV },
2143 { "res.hdr_names", smp_fetch_hdr_names, ARG1(0,STR), NULL, SMP_T_STR, SMP_USE_HRSHV },
2144 { "res.hdr_val", smp_fetch_hdr_val, ARG2(0,STR,SINT), val_hdr, SMP_T_SINT, SMP_USE_HRSHV },
2145
2146 /* scook is valid only on the response and is used for ACL compatibility */
2147 { "scook", smp_fetch_cookie, ARG1(0,STR), NULL, SMP_T_STR, SMP_USE_HRSHV },
2148 { "scook_cnt", smp_fetch_cookie_cnt, ARG1(0,STR), NULL, SMP_T_SINT, SMP_USE_HRSHV },
2149 { "scook_val", smp_fetch_cookie_val, ARG1(0,STR), NULL, SMP_T_SINT, SMP_USE_HRSHV },
2150 { "set-cookie", smp_fetch_cookie, ARG1(0,STR), NULL, SMP_T_STR, SMP_USE_HRSHV }, /* deprecated */
2151
2152 /* shdr is valid only on the response and is used for ACL compatibility */
2153 { "shdr", smp_fetch_hdr, ARG2(0,STR,SINT), val_hdr, SMP_T_STR, SMP_USE_HRSHV },
2154 { "shdr_cnt", smp_fetch_hdr_cnt, ARG1(0,STR), NULL, SMP_T_SINT, SMP_USE_HRSHV },
2155 { "shdr_ip", smp_fetch_hdr_ip, ARG2(0,STR,SINT), val_hdr, SMP_T_IPV4, SMP_USE_HRSHV },
2156 { "shdr_val", smp_fetch_hdr_val, ARG2(0,STR,SINT), val_hdr, SMP_T_SINT, SMP_USE_HRSHV },
2157
2158 { "status", smp_fetch_stcode, 0, NULL, SMP_T_SINT, SMP_USE_HRSHP },
2159 { "unique-id", smp_fetch_uniqueid, 0, NULL, SMP_T_STR, SMP_SRC_L4SRV },
2160 { "url", smp_fetch_url, 0, NULL, SMP_T_STR, SMP_USE_HRQHV },
2161 { "url32", smp_fetch_url32, 0, NULL, SMP_T_SINT, SMP_USE_HRQHV },
2162 { "url32+src", smp_fetch_url32_src, 0, NULL, SMP_T_BIN, SMP_USE_HRQHV },
2163 { "url_ip", smp_fetch_url_ip, 0, NULL, SMP_T_IPV4, SMP_USE_HRQHV },
2164 { "url_port", smp_fetch_url_port, 0, NULL, SMP_T_SINT, SMP_USE_HRQHV },
2165 { "url_param", smp_fetch_url_param, ARG2(0,STR,STR), NULL, SMP_T_STR, SMP_USE_HRQHV },
2166 { "urlp" , smp_fetch_url_param, ARG2(0,STR,STR), NULL, SMP_T_STR, SMP_USE_HRQHV },
2167 { "urlp_val", smp_fetch_url_param_val, ARG2(0,STR,STR), NULL, SMP_T_SINT, SMP_USE_HRQHV },
Christopher Faulet16032ab2020-04-30 11:30:00 +02002168
Willy Tarreau79e57332018-10-02 16:01:16 +02002169 { /* END */ },
2170}};
2171
Willy Tarreau0108d902018-11-25 19:14:37 +01002172INITCALL1(STG_REGISTER, sample_register_fetches, &sample_fetch_keywords);
Willy Tarreau79e57332018-10-02 16:01:16 +02002173
2174/*
2175 * Local variables:
2176 * c-indent-level: 8
2177 * c-basic-offset: 8
2178 * End:
2179 */