varnish-cache/vmod/vmod_cookie.c
0
/*-
1
 * Copyright (c) 2012-2020 Varnish Software AS
2
 *
3
 * Author: Lasse Karstensen <lasse.karstensen@gmail.com>
4
 * Author: Lasse Karstensen <lkarsten@varnish-software.com>
5
 * Author: Dridi Boukelmoune <dridi.boukelmoune@gmail.com>
6
 *
7
 * SPDX-License-Identifier: BSD-2-Clause
8
 *
9
 * Redistribution and use in source and binary forms, with or without
10
 * modification, are permitted provided that the following conditions
11
 * are met:
12
 * 1. Redistributions of source code must retain the above copyright
13
 *    notice, this list of conditions and the following disclaimer.
14
 * 2. Redistributions in binary form must reproduce the above copyright
15
 *    notice, this list of conditions and the following disclaimer in the
16
 *    documentation and/or other materials provided with the distribution.
17
 *
18
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
19
 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
20
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
21
 * ARE DISCLAIMED.  IN NO EVENT SHALL AUTHOR OR CONTRIBUTORS BE LIABLE
22
 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
23
 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
24
 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
25
 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
26
 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
27
 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
28
 * SUCH DAMAGE.
29
 *
30
 * Cookie VMOD that simplifies handling of the Cookie request header.
31
 */
32
33
#include "config.h"
34
35
#include <stdlib.h>
36
#include <stdio.h>
37
#include <string.h>
38
#include <ctype.h>
39
#include <pthread.h>
40
41
#include <cache/cache.h>
42
43
#include <vsb.h>
44
45
#include "vcc_cookie_if.h"
46
47
enum filter_action {
48
        blacklist,
49
        whitelist
50
};
51
52
struct cookie {
53
        unsigned                magic;
54
#define VMOD_COOKIE_ENTRY_MAGIC 0x3BB41543
55
        const char              *name;
56
        const char              *value;
57
        VTAILQ_ENTRY(cookie)    list;
58
};
59
60
/* A structure to represent both whitelists and blacklists */
61
struct matchlist {
62
        char                    *name;
63
        VTAILQ_ENTRY(matchlist) list;
64
};
65
66
struct vmod_cookie {
67
        unsigned                magic;
68
#define VMOD_COOKIE_MAGIC       0x4EE5FB2E
69
        VTAILQ_HEAD(, cookie)   cookielist;
70
};
71
72
static void
73 1550
cobj_free(VRT_CTX, void *p)
74
{
75
        struct vmod_cookie *vcp;
76
77 1550
        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
78 1550
        CAST_OBJ_NOTNULL(vcp, p, VMOD_COOKIE_MAGIC);
79 1550
        FREE_OBJ(vcp);
80 1550
}
81
82
static const struct vmod_priv_methods cookie_cobj_priv_methods[1] = {{
83
        .magic = VMOD_PRIV_METHODS_MAGIC,
84
        .type = "vmod_cookie_cobj",
85
        .fini = cobj_free
86
}};
87
88
static struct vmod_cookie *
89 7275
cobj_get(struct vmod_priv *priv)
90
{
91
        struct vmod_cookie *vcp;
92
93 7275
        if (priv->priv == NULL) {
94 1550
                ALLOC_OBJ(vcp, VMOD_COOKIE_MAGIC);
95 1550
                AN(vcp);
96 1550
                VTAILQ_INIT(&vcp->cookielist);
97 1550
                priv->priv = vcp;
98 1550
                priv->methods = cookie_cobj_priv_methods;
99 1550
        } else
100 5725
                CAST_OBJ_NOTNULL(vcp, priv->priv, VMOD_COOKIE_MAGIC);
101
102 7275
        return (vcp);
103
}
104
105
VCL_VOID
106 1400
vmod_parse(VRT_CTX, struct vmod_priv *priv, VCL_STRING cookieheader)
107
{
108 1400
        struct vmod_cookie *vcp = cobj_get(priv);
109
        char *name, *value;
110
        const char *p, *sep;
111 1400
        int i = 0;
112
113 1400
        if (cookieheader == NULL || *cookieheader == '\0') {
114 50
                VSLb(ctx->vsl, SLT_Debug, "cookie: nothing to parse");
115 50
                return;
116
        }
117
118
        /* If called twice during the same request, clean out old state. */
119 1350
        if (!VTAILQ_EMPTY(&vcp->cookielist))
120 75
                vmod_clean(ctx, priv);
121
122 1350
        p = cookieheader;
123 2650
        while (*p != '\0') {
124 3875
                while (isspace(*p))
125 1250
                        p++;
126 2625
                sep = strchr(p, '=');
127 2625
                if (sep == NULL)
128 0
                        break;
129 2625
                name = strndup(p, pdiff(p, sep));
130 2625
                p = sep + 1;
131
132 2625
                sep = p;
133 230325
                while (*sep != '\0' && *sep != ';')
134 227700
                        sep++;
135 2625
                value = strndup(p, pdiff(p, sep));
136
137 2625
                vmod_set(ctx, priv, name, value);
138 2625
                free(name);
139 2625
                free(value);
140 2625
                i++;
141 2625
                if (*sep == '\0')
142 1325
                        break;
143 1300
                p = sep + 1;
144
        }
145
146 1350
        VSLb(ctx->vsl, SLT_Debug, "cookie: parsed %i cookies.", i);
147 1400
}
148
149
static struct cookie *
150 3500
find_cookie(const struct vmod_cookie *vcp, VCL_STRING name)
151
{
152
        struct cookie *cookie;
153
154 5700
        VTAILQ_FOREACH(cookie, &vcp->cookielist, list) {
155 2375
                CHECK_OBJ_NOTNULL(cookie, VMOD_COOKIE_ENTRY_MAGIC);
156 2375
                if (!strcmp(cookie->name, name))
157 175
                        break;
158 2200
        }
159 3500
        return (cookie);
160
}
161
162
VCL_VOID
163 3350
vmod_set(VRT_CTX, struct vmod_priv *priv, VCL_STRING name, VCL_STRING value)
164
{
165 3350
        struct vmod_cookie *vcp = cobj_get(priv);
166
        struct cookie *cookie;
167
        const char *p;
168
169 3350
        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
170 3350
        CHECK_OBJ_NOTNULL(ctx->ws, WS_MAGIC);
171
172
        /* Empty cookies should be ignored. */
173 3350
        if (name == NULL || *name == '\0')
174 75
                return;
175 3275
        if (value == NULL || *value == '\0')
176 50
                return;
177
178 3225
        cookie = find_cookie(vcp, name);
179 3225
        if (cookie != NULL) {
180 25
                p = WS_Printf(ctx->ws, "%s", value);
181 25
                if (p == NULL) {
182 0
                        VSLb(ctx->vsl, SLT_Error,
183
                            "cookie: Workspace overflow in set()");
184 0
                } else
185 25
                        cookie->value = p;
186 25
                return;
187
        }
188
189 6400
        WS_TASK_ALLOC_OBJ(ctx, cookie, VMOD_COOKIE_ENTRY_MAGIC);
190 3200
        if (cookie == NULL)
191 0
                return;
192
193 3200
        cookie->name = WS_Printf(ctx->ws, "%s", name);
194 3200
        cookie->value = WS_Printf(ctx->ws, "%s", value);
195 3200
        if (cookie->name == NULL || cookie->value == NULL) {
196 0
                VSLb(ctx->vsl, SLT_Error,
197
                    "cookie: unable to get storage for cookie");
198 0
                return;
199
        }
200 3200
        VTAILQ_INSERT_TAIL(&vcp->cookielist, cookie, list);
201 3350
}
202
203
VCL_BOOL
204 150
vmod_isset(VRT_CTX, struct vmod_priv *priv, const char *name)
205
{
206 150
        struct vmod_cookie *vcp = cobj_get(priv);
207
        struct cookie *cookie;
208
209 150
        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
210 150
        if (name == NULL || *name == '\0')
211 50
                return (0);
212
213 100
        cookie = find_cookie(vcp, name);
214 100
        return (cookie ? 1 : 0);
215 150
}
216
217
VCL_STRING
218 100
vmod_get(VRT_CTX, struct vmod_priv *priv, VCL_STRING name)
219
{
220 100
        struct vmod_cookie *vcp = cobj_get(priv);
221
        struct cookie *cookie;
222
223 100
        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
224 100
        if (name == NULL || *name == '\0')
225 0
                return (NULL);
226
227 100
        cookie = find_cookie(vcp, name);
228 100
        return (cookie ? cookie->value : NULL);
229 100
}
230
231
232
VCL_STRING
233 100
vmod_get_re(VRT_CTX, struct vmod_priv *priv, VCL_REGEX re)
234
{
235 100
        struct vmod_cookie *vcp = cobj_get(priv);
236 100
        struct cookie *cookie = NULL;
237
        struct cookie *current;
238
        unsigned match;
239
240 100
        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
241 100
        AN(re);
242
243 250
        VTAILQ_FOREACH(current, &vcp->cookielist, list) {
244 200
                CHECK_OBJ_NOTNULL(current, VMOD_COOKIE_ENTRY_MAGIC);
245 200
                VSLb(ctx->vsl, SLT_Debug, "cookie: checking %s", current->name);
246 200
                match = VRT_re_match(ctx, current->name, re);
247 200
                if (!match)
248 150
                        continue;
249 50
                cookie = current;
250 50
                break;
251
        }
252
253 100
        return (cookie ? cookie->value : NULL);
254
}
255
256
VCL_VOID
257 100
vmod_delete(VRT_CTX, struct vmod_priv *priv, VCL_STRING name)
258
{
259 100
        struct vmod_cookie *vcp = cobj_get(priv);
260
        struct cookie *cookie;
261
262 100
        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
263 100
        if (name == NULL || *name == '\0')
264 25
                return;
265
266 75
        cookie = find_cookie(vcp, name);
267
268 75
        if (cookie != NULL)
269 25
                VTAILQ_REMOVE(&vcp->cookielist, cookie, list);
270 100
}
271
272
VCL_VOID
273 125
vmod_clean(VRT_CTX, struct vmod_priv *priv)
274
{
275 125
        struct vmod_cookie *vcp = cobj_get(priv);
276
277 125
        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
278 125
        AN(vcp);
279 125
        VTAILQ_INIT(&vcp->cookielist);
280 125
}
281
282
static void
283 150
filter_cookies(struct vmod_priv *priv, VCL_STRING list_s,
284
    enum filter_action mode)
285
{
286
        struct cookie *cookieptr, *safeptr;
287 150
        struct vmod_cookie *vcp = cobj_get(priv);
288
        struct matchlist *mlentry, *mlsafe;
289 150
        char const *p = list_s, *q;
290 150
        int matched = 0;
291
        VTAILQ_HEAD(, matchlist) matchlist_head;
292
293 150
        VTAILQ_INIT(&matchlist_head);
294
295
        /* Parse the supplied list. */
296 675
        while (p && *p != '\0') {
297 725
                while (isspace(*p))
298 200
                        p++;
299 525
                if (*p == '\0')
300 0
                        break;
301
302 525
                q = p;
303 1975
                while (*q != '\0' && *q != ',')
304 1450
                        q++;
305
306 525
                if (q == p) {
307 250
                        p++;
308 250
                        continue;
309
                }
310
311
                /* XXX: can we reserve/release lumps of txt instead of
312
                 * malloc/free?
313
                 */
314 275
                mlentry = malloc(sizeof *mlentry);
315 275
                AN(mlentry);
316 275
                mlentry->name = strndup(p, q - p);
317 275
                AN(mlentry->name);
318
319 275
                VTAILQ_INSERT_TAIL(&matchlist_head, mlentry, list);
320
321 275
                p = q;
322 275
                if (*p != '\0')
323 225
                        p++;
324
        }
325
326
        /* Filter existing cookies that either aren't in the whitelist or
327
         * are in the blacklist (depending on the filter_action) */
328 550
        VTAILQ_FOREACH_SAFE(cookieptr, &vcp->cookielist, list, safeptr) {
329 400
                CHECK_OBJ_NOTNULL(cookieptr, VMOD_COOKIE_ENTRY_MAGIC);
330 400
                matched = 0;
331
332 825
                VTAILQ_FOREACH(mlentry, &matchlist_head, list) {
333 600
                        if (strcmp(cookieptr->name, mlentry->name) == 0) {
334 175
                                matched = 1;
335 175
                                break;
336
                        }
337 425
                }
338 400
                if (matched != mode)
339 175
                        VTAILQ_REMOVE(&vcp->cookielist, cookieptr, list);
340 400
        }
341
342 425
        VTAILQ_FOREACH_SAFE(mlentry, &matchlist_head, list, mlsafe) {
343 275
                VTAILQ_REMOVE(&matchlist_head, mlentry, list);
344 275
                free(mlentry->name);
345 275
                free(mlentry);
346 275
        }
347 150
}
348
349
VCL_VOID
350 75
vmod_keep(VRT_CTX, struct vmod_priv *priv, VCL_STRING whitelist_s)
351
{
352
353 75
        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
354 75
        filter_cookies(priv, whitelist_s, whitelist);
355 75
}
356
357
358
VCL_VOID
359 75
vmod_filter(VRT_CTX, struct vmod_priv *priv, VCL_STRING blacklist_s)
360
{
361
362 75
        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
363 75
        filter_cookies(priv, blacklist_s, blacklist);
364 75
}
365
366
static VCL_VOID
367 175
re_filter(VRT_CTX, struct vmod_priv *priv, VCL_REGEX re, enum filter_action mode)
368
{
369 175
        struct vmod_cookie *vcp = cobj_get(priv);
370
        struct cookie *current, *safeptr;
371
        unsigned match;
372
373 175
        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
374 175
        AN(re);
375
376 650
        VTAILQ_FOREACH_SAFE(current, &vcp->cookielist, list, safeptr) {
377 475
                CHECK_OBJ_NOTNULL(current, VMOD_COOKIE_ENTRY_MAGIC);
378
379 475
                match = VRT_re_match(ctx, current->name, re);
380
381 475
                switch (mode) {
382
                case blacklist:
383 275
                        if (!match)
384 200
                                continue;
385 150
                        VSLb(ctx->vsl, SLT_Debug,
386
                            "Removing matching cookie %s (value: %s)",
387 75
                            current->name, current->value);
388 75
                        VTAILQ_REMOVE(&vcp->cookielist, current, list);
389 75
                        break;
390
                case whitelist:
391 200
                        if (match)
392 125
                                continue;
393
394 150
                        VSLb(ctx->vsl, SLT_Debug,
395
                            "Removing cookie %s (value: %s)",
396 75
                            current->name, current->value);
397 75
                        VTAILQ_REMOVE(&vcp->cookielist, current, list);
398 75
                        break;
399
                default:
400 0
                        WRONG("invalid mode");
401 0
                }
402 150
        }
403 175
}
404
405
406
VCL_VOID
407 75
vmod_keep_re(VRT_CTX, struct vmod_priv *priv, VCL_REGEX re)
408
{
409
410 75
        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
411 75
        re_filter(ctx, priv, re, whitelist);
412 75
}
413
414
415
VCL_VOID
416 100
vmod_filter_re(VRT_CTX, struct vmod_priv *priv, VCL_REGEX re)
417
{
418
419 100
        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
420 100
        re_filter(ctx, priv, re, blacklist);
421 100
}
422
423
424
VCL_STRING
425 1625
vmod_get_string(VRT_CTX, struct vmod_priv *priv)
426
{
427
        struct cookie *curr;
428
        struct vsb output[1];
429 1625
        struct vmod_cookie *vcp = cobj_get(priv);
430 1625
        const char *sep = "", *res;
431
432 1625
        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
433 1625
        CHECK_OBJ_NOTNULL(ctx->ws, WS_MAGIC);
434 1625
        WS_VSB_new(output, ctx->ws);
435
436 4450
        VTAILQ_FOREACH(curr, &vcp->cookielist, list) {
437 2825
                CHECK_OBJ_NOTNULL(curr, VMOD_COOKIE_ENTRY_MAGIC);
438 2825
                AN(curr->name);
439 2825
                AN(curr->value);
440 2825
                VSB_printf(output, "%s%s=%s", sep, curr->name, curr->value);
441 2825
                sep = "; ";
442 2825
        }
443 1625
        res = WS_VSB_finish(output, ctx->ws, NULL);
444 1625
        if (res == NULL)
445 0
                VSLb(ctx->vsl, SLT_Error, "cookie: Workspace overflow");
446 1625
        return (res);
447
}
448
449
VCL_STRING
450 25
vmod_format_date(VRT_CTX, VCL_TIME ts, VCL_DURATION duration)
451
{
452
453 25
        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
454 25
        return (VRT_TIME_string(ctx, ts + duration));
455
}