In log_error(), don't surround the thread id with "Privoxy(" and ")".
[privoxy.git] / filters.c
1 const char filters_rcs[] = "$Id: filters.c,v 1.109 2008/11/08 15:48:41 fabiankeil Exp $";
2 /*********************************************************************
3  *
4  * File        :  $Source: /cvsroot/ijbswa/current/filters.c,v $
5  *
6  * Purpose     :  Declares functions to parse/crunch headers and pages.
7  *                Functions declared include:
8  *                   `acl_addr', `add_stats', `block_acl', `block_imageurl',
9  *                   `block_url', `url_actions', `domain_split',
10  *                   `filter_popups', `forward_url', 'redirect_url',
11  *                   `ij_untrusted_url', `intercept_url', `pcrs_filter_respose',
12  *                   `ijb_send_banner', `trust_url', `gif_deanimate_response',
13  *                   `execute_single_pcrs_command', `rewrite_url',
14  *                   `get_last_url'
15  *
16  * Copyright   :  Written by and Copyright (C) 2001, 2004-2008 the SourceForge
17  *                Privoxy team. http://www.privoxy.org/
18  *
19  *                Based on the Internet Junkbuster originally written
20  *                by and Copyright (C) 1997 Anonymous Coders and
21  *                Junkbusters Corporation.  http://www.junkbusters.com
22  *
23  *                This program is free software; you can redistribute it
24  *                and/or modify it under the terms of the GNU General
25  *                Public License as published by the Free Software
26  *                Foundation; either version 2 of the License, or (at
27  *                your option) any later version.
28  *
29  *                This program is distributed in the hope that it will
30  *                be useful, but WITHOUT ANY WARRANTY; without even the
31  *                implied warranty of MERCHANTABILITY or FITNESS FOR A
32  *                PARTICULAR PURPOSE.  See the GNU General Public
33  *                License for more details.
34  *
35  *                The GNU General Public License should be included with
36  *                this file.  If not, you can view it at
37  *                http://www.gnu.org/copyleft/gpl.html
38  *                or write to the Free Software Foundation, Inc., 59
39  *                Temple Place - Suite 330, Boston, MA  02111-1307, USA.
40  *
41  * Revisions   :
42  *    $Log: filters.c,v $
43  *    Revision 1.109  2008/11/08 15:48:41  fabiankeil
44  *    Mention actual values when complaining about
45  *    the chunk size exceeding the buffer size.
46  *
47  *    Revision 1.108  2008/05/21 15:35:08  fabiankeil
48  *    - Mark csp as immutable for block_acl().
49  *    - Remove an obsolete complaint about filter_popups().
50  *
51  *    Revision 1.107  2008/05/04 17:52:56  fabiankeil
52  *    Adjust parse_http_url() call to new prototype.
53  *
54  *    Revision 1.106  2008/05/03 16:40:44  fabiankeil
55  *    Change content_filters_enabled()'s parameter from
56  *    csp->action to action so it can be also used in the
57  *    CGI code. Don't bother checking if there are filters
58  *    loaded, as that's somewhat besides the point.
59  *
60  *    Revision 1.105  2008/03/28 15:13:39  fabiankeil
61  *    Remove inspect-jpegs action.
62  *
63  *    Revision 1.104  2008/03/27 18:27:24  fabiankeil
64  *    Remove kill-popups action.
65  *
66  *    Revision 1.103  2008/03/06 16:33:45  fabiankeil
67  *    If limit-connect isn't used, don't limit CONNECT requests to port 443.
68  *
69  *    Revision 1.102  2008/03/01 14:00:44  fabiankeil
70  *    Let the block action take the reason for the block
71  *    as argument and show it on the "blocked" page.
72  *
73  *    Revision 1.101  2008/02/23 16:57:12  fabiankeil
74  *    Rename url_actions() to get_url_actions() and let it
75  *    use the standard parameter ordering.
76  *
77  *    Revision 1.100  2008/02/23 16:33:43  fabiankeil
78  *    Let forward_url() use the standard parameter ordering
79  *    and mark its second parameter immutable.
80  *
81  *    Revision 1.99  2008/02/03 13:57:58  fabiankeil
82  *    Add SOCKS5 support for forward-override{}.
83  *
84  *    Revision 1.98  2008/01/04 17:43:45  fabiankeil
85  *    Improve the warning messages that get logged if the action files
86  *    "enable" filters but no filters of that type have been loaded.
87  *
88  *    Revision 1.97  2007/11/30 15:37:03  fabiankeil
89  *    Use freez instead of free.
90  *
91  *    Revision 1.96  2007/10/19 16:53:28  fabiankeil
92  *    Add helper function to check if any content filters are enabled.
93  *
94  *    Revision 1.95  2007/10/17 19:31:20  fabiankeil
95  *    Omitting the zero chunk that ends the chunk transfer encoding seems
96  *    to be the new black. Log the problem and continue filtering anyway.
97  *
98  *    Revision 1.94  2007/09/29 13:20:20  fabiankeil
99  *    Remove two redundant and one useless log messages.
100  *
101  *    Revision 1.93  2007/09/29 10:21:16  fabiankeil
102  *    - Move get_filter_function() from jcc.c to filters.c
103  *      so the filter functions can be static.
104  *    - Don't bother filtering body-less responses.
105  *
106  *    Revision 1.92  2007/09/28 16:38:55  fabiankeil
107  *    - Execute content filters through execute_content_filter().
108  *    - Add prepare_for_filtering() so filter functions don't have to
109  *      care about de-chunking and decompression. As a side effect this enables
110  *      decompression for gif_deanimate_response() and jpeg_inspect_response().
111  *    - Change remove_chunked_transfer_coding()'s return type to jb_err.
112  *      Some clowns feel like chunking empty responses in which case
113  *      (size == 0) is valid but previously would be interpreted as error.
114  *
115  *    Revision 1.91  2007/09/02 15:31:20  fabiankeil
116  *    Move match_portlist() from filter.c to urlmatch.c.
117  *    It's used for url matching, not for filtering.
118  *
119  *    Revision 1.90  2007/09/02 12:44:17  fabiankeil
120  *    Remove newline at the end of a log_error() message.
121  *
122  *    Revision 1.89  2007/08/05 13:42:23  fabiankeil
123  *    #1763173 from Stefan Huehner: declare some more functions static.
124  *
125  *    Revision 1.88  2007/06/01 16:41:11  fabiankeil
126  *    Add forward-override{} to change the forwarding settings through
127  *    action sections. This is mainly interesting to forward different
128  *    clients differently (for example based on User-Agent or request
129  *    origin).
130  *
131  *    Revision 1.87  2007/04/30 15:53:10  fabiankeil
132  *    Make sure filters with dynamic jobs actually use them.
133  *
134  *    Revision 1.86  2007/04/30 15:03:28  fabiankeil
135  *    - Introduce dynamic pcrs jobs that can resolve variables.
136  *    - Don't run redirect functions more than once,
137  *      unless they are activated more than once.
138  *
139  *    Revision 1.85  2007/03/21 12:24:47  fabiankeil
140  *    - Log the content size after decompression in decompress_iob()
141  *      instead of pcrs_filter_response().
142  *
143  *    Revision 1.84  2007/03/20 15:16:34  fabiankeil
144  *    Use dedicated header filter actions instead of abusing "filter".
145  *    Replace "filter-client-headers" and "filter-client-headers"
146  *    with "server-header-filter" and "client-header-filter".
147  *
148  *    Revision 1.83  2007/03/17 15:20:05  fabiankeil
149  *    New config option: enforce-blocks.
150  *
151  *    Revision 1.82  2007/03/13 11:28:43  fabiankeil
152  *    - Fix port handling in acl_addr() and use a temporary acl spec
153  *      copy so error messages don't contain a truncated version.
154  *    - Log size of iob before and after decompression.
155  *
156  *    Revision 1.81  2007/03/05 14:40:53  fabiankeil
157  *    - Cosmetical changes for LOG_LEVEL_RE_FILTER messages.
158  *    - Hide the "Go there anyway" link for blocked CONNECT
159  *      requests where going there anyway doesn't work anyway.
160  *
161  *    Revision 1.80  2007/02/07 10:55:20  fabiankeil
162  *    - Save the reason for generating http_responses.
163  *    - Block (+block) with status code 403 instead of 404.
164  *    - Use a different kludge to remember a failed decompression.
165  *
166  *    Revision 1.79  2007/01/31 16:21:38  fabiankeil
167  *    Search for Max-Forwards headers case-insensitive,
168  *    don't generate the "501 unsupported" message for invalid
169  *    Max-Forwards values and don't increase negative ones.
170  *
171  *    Revision 1.78  2007/01/28 13:41:18  fabiankeil
172  *    - Add HEAD support to finish_http_response.
173  *    - Add error favicon to internal HTML error messages.
174  *
175  *    Revision 1.77  2007/01/12 15:36:44  fabiankeil
176  *    Mark *csp as immutable for is_untrusted_url()
177  *    and is_imageurl(). Closes FR 1237736.
178  *
179  *    Revision 1.76  2007/01/01 19:36:37  fabiankeil
180  *    Integrate a modified version of Wil Mahan's
181  *    zlib patch (PR #895531).
182  *
183  *    Revision 1.75  2006/12/29 18:30:46  fabiankeil
184  *    Fixed gcc43 conversion warnings,
185  *    changed sprintf calls to snprintf.
186  *
187  *    Revision 1.74  2006/12/24 17:37:38  fabiankeil
188  *    Adjust comment in pcrs_filter_response()
189  *    to recent pcrs changes. Hohoho.
190  *
191  *    Revision 1.73  2006/12/23 16:01:02  fabiankeil
192  *    Don't crash if pcre returns an error code
193  *    that pcrs didn't expect. Fixes BR 1621173.
194  *
195  *    Revision 1.72  2006/12/22 18:52:53  fabiankeil
196  *    Modified is_untrusted_url to complain in case of
197  *    write errors and to give a reason when adding new
198  *    entries to the trustfile. Closes FR 1097611.
199  *
200  *    Revision 1.71  2006/12/22 14:24:52  fabiankeil
201  *    Skip empty filter files in pcrs_filter_response,
202  *    but don't ignore the ones that come afterwards.
203  *    Fixes parts of BR 1619208.
204  *
205  *    Revision 1.70  2006/12/09 13:33:15  fabiankeil
206  *    Added some sanity checks for get_last_url().
207  *    Fixed possible segfault caused by my last commit.
208  *
209  *    Revision 1.69  2006/12/08 12:39:13  fabiankeil
210  *    Let get_last_url() catch https URLs as well.
211  *
212  *    Revision 1.68  2006/12/05 14:45:48  fabiankeil
213  *    Make sure get_last_url() behaves like advertised
214  *    and fast-redirects{} can be combined with redirect{}.
215  *
216  *    Revision 1.67  2006/11/28 15:19:43  fabiankeil
217  *    Implemented +redirect{s@foo@bar@} to generate
218  *    a redirect based on a rewritten version of the
219  *    original URL.
220  *
221  *    Revision 1.66  2006/09/23 13:26:38  roro
222  *    Replace TABs by spaces in source code.
223  *
224  *    Revision 1.65  2006/09/21 12:54:43  fabiankeil
225  *    Fix +redirect{}. Didn't work with -fast-redirects.
226  *
227  *    Revision 1.64  2006/08/31 10:55:49  fabiankeil
228  *    Block requests for untrusted URLs with status
229  *    code 403 instead of 200.
230  *
231  *    Revision 1.63  2006/08/31 10:11:28  fabiankeil
232  *    Don't free p which is still in use and will be later
233  *    freed by free_map(). Don't claim the referrer is unknown
234  *    when the client didn't set one.
235  *
236  *    Revision 1.62  2006/08/14 00:27:47  david__schmidt
237  *    Feature request 595948: Re-Filter logging in single line
238  *
239  *    Revision 1.61  2006/08/03 02:46:41  david__schmidt
240  *    Incorporate Fabian Keil's patch work:\rhttp://www.fabiankeil.de/sourcecode/privoxy/
241  *
242  *    Revision 1.60  2006/07/18 14:48:46  david__schmidt
243  *    Reorganizing the repository: swapping out what was HEAD (the old 3.1 branch)
244  *    with what was really the latest development (the v_3_0_branch branch)
245  *
246  *    Revision 1.58.2.9  2006/01/29 23:10:56  david__schmidt
247  *    Multiple filter file support
248  *
249  *    Revision 1.58.2.8  2005/05/07 21:50:55  david__schmidt
250  *    A few memory leaks plugged (mostly on error paths)
251  *
252  *    Revision 1.58.2.7  2004/10/03 12:53:32  david__schmidt
253  *    Add the ability to check jpeg images for invalid
254  *    lengths of comment blocks.  Defensive strategy
255  *    against the exploit:
256  *       Microsoft Security Bulletin MS04-028
257  *       Buffer Overrun in JPEG Processing (GDI+) Could
258  *       Allow Code Execution (833987)
259  *    Enabled with +inspect-jpegs in actions files.
260  *
261  *    Revision 1.58.2.6  2003/12/06 22:18:27  gliptak
262  *    Correcting compile problem with FEATURE_IMAGE_BLOCKING
263  *
264  *    Revision 1.58.2.5  2003/11/11 13:10:31  oes
265  *    Fixed bug #839859: "See why" link URL now gets url-encoded.
266  *
267  *    Revision 1.58.2.4  2003/02/28 12:52:45  oes
268  *    Fixed a typo
269  *
270  *    Revision 1.58.2.3  2002/09/25 14:51:51  oes
271  *    Added basic support for OPTIONS and TRACE HTTP methods:
272  *    New function direct_response which handles OPTIONS and
273  *    TRACE requests whose Max-Forwards header field is zero.
274  *
275  *    Revision 1.58.2.2  2002/08/01 17:18:28  oes
276  *    Fixed BR 537651 / SR 579724 (MSIE image detect improper for IE/Mac)
277  *
278  *    Revision 1.58.2.1  2002/07/26 15:18:53  oes
279  *    - Bugfix: Executing a filters without jobs no longer results in
280  *      turing off *all* filters.
281  *    - Security fix: Malicious web servers can't cause a seg fault
282  *      through bogus chunk sizes anymore
283  *
284  *    Revision 1.58  2002/04/24 02:11:17  oes
285  *    Jon's multiple AF patch: url_actions now evaluates rules
286  *    from all AFs.
287  *
288  *    Revision 1.57  2002/04/08 20:38:34  swa
289  *    fixed JB spelling
290  *
291  *    Revision 1.56  2002/04/05 15:51:24  oes
292  *     - bugfix: error-pages now get correct request protocol
293  *     - fix for invalid HTML in trust info
294  *
295  *    Revision 1.55  2002/04/02 16:13:51  oes
296  *    Fix: No "Go there anyway" for SSL
297  *
298  *    Revision 1.54  2002/04/02 14:55:56  oes
299  *    Bugfix: is_untrusted_url() now depends on FEATURE_TRUST, not FEATURE_COOKIE_JAR
300  *
301  *    Revision 1.53  2002/03/26 22:29:54  swa
302  *    we have a new homepage!
303  *
304  *    Revision 1.52  2002/03/24 16:35:57  jongfoster
305  *    Removing logo
306  *
307  *    Revision 1.51  2002/03/24 15:23:33  jongfoster
308  *    Name changes
309  *
310  *    Revision 1.50  2002/03/24 13:25:43  swa
311  *    name change related issues
312  *
313  *    Revision 1.49  2002/03/16 20:29:14  oes
314  *    Cosmetics
315  *
316  *    Revision 1.48  2002/03/13 20:25:34  oes
317  *    Better logging for content filters
318  *
319  *    Revision 1.47  2002/03/13 00:30:52  jongfoster
320  *    Killing warnings
321  *    Added option of always sending redirect for imageblock,
322  *    currently disabled with #if 0.
323  *
324  *    Revision 1.46  2002/03/12 01:42:49  oes
325  *    Introduced modular filters
326  *
327  *    Revision 1.45  2002/03/08 16:47:50  oes
328  *    Added choice beween GIF and PNG built-in images
329  *
330  *    Revision 1.44  2002/03/07 03:49:31  oes
331  *     - Fixed compiler warnings etc
332  *     - Changed built-in images from GIF to PNG
333  *       (with regard to Unisys patent issue)
334  *     - Added a 4x4 pattern PNG which is less intrusive
335  *       than the logo but also clearly marks the deleted banners
336  *
337  *    Revision 1.43  2002/01/22 23:51:59  jongfoster
338  *    Replacing strsav() with the safer string_append().
339  *
340  *    Adding missing html_encode() to error message generators.  Where encoded
341  *    and unencoded versions of a string were provided, removing the unencoded
342  *    one.
343  *
344  *    Revision 1.42  2002/01/17 21:00:32  jongfoster
345  *    Moving all our URL and URL pattern parsing code to urlmatch.c.
346  *
347  *    Using a single, simple url_match(pattern,url) function - rather than
348  *    the 3-line match routine which was repeated all over the place.
349  *
350  *    Renaming free_url to free_url_spec, since it frees a struct url_spec.
351  *
352  *    Using parse_http_url() to parse URLs without faking a HTTP
353  *    request line for parse_http_request().
354  *
355  *    Revision 1.41  2001/11/13 00:14:07  jongfoster
356  *    Fixing stupid bug now I've figured out what || means.
357  *    (It always returns 0 or 1, not one of it's paramaters.)
358  *
359  *    Revision 1.40  2001/10/26 17:37:55  oes
360  *    - Re-enabled Netscape 200/404 bug workaround in block_url():
361  *      - Removed OS/2 special case
362  *      - Made block_url() independant from sed() having been run
363  *    - Made trust_url independant from sed() having been run
364  *    - Made is_imageurl independant from sed() having been run.
365  *      It now checks User-Agent: and Accept: by itself.
366  *
367  *
368  *    Revision 1.39  2001/10/25 03:40:48  david__schmidt
369  *    Change in porting tactics: OS/2's EMX porting layer doesn't allow multiple
370  *    threads to call select() simultaneously.  So, it's time to do a real, live,
371  *    native OS/2 port.  See defines for __EMX__ (the porting layer) vs. __OS2__
372  *    (native). Both versions will work, but using __OS2__ offers multi-threading.
373  *
374  *    Revision 1.38  2001/10/23 21:32:33  jongfoster
375  *    Adding error-checking to selected functions
376  *
377  *    Revision 1.37  2001/10/22 15:33:56  david__schmidt
378  *    Special-cased OS/2 out of the Netscape-abort-on-404-in-js problem in
379  *    filters.c.  Added a FIXME in front of the offending code.  I'll gladly
380  *    put in a better/more robust fix for all parties if one is presented...
381  *    It seems that just returning 200 instead of 404 would pretty much fix
382  *    it for everyone, but I don't know all the history of the problem.
383  *
384  *    Revision 1.36  2001/10/10 16:44:16  oes
385  *    Added match_portlist function
386  *
387  *    Revision 1.35  2001/10/07 15:41:23  oes
388  *    Replaced 6 boolean members of csp with one bitmap (csp->flags)
389  *
390  *    New function remove_chunked_transfer_coding that strips chunked
391  *      transfer coding to plain and is called by pcrs_filter_response
392  *      and gif_deanimate_response if neccessary
393  *
394  *    Improved handling of zero-change re_filter runs
395  *
396  *    pcrs_filter_response and gif_deanimate_response now remove
397  *      chunked transfer codeing before processing the body.
398  *
399  *    Revision 1.34  2001/09/20 15:49:36  steudten
400  *
401  *    Fix BUG: Change int size to size_t size in pcrs_filter_response().
402  *    See cgi.c fill_template().
403  *
404  *    Revision 1.33  2001/09/16 17:05:14  jongfoster
405  *    Removing unused #include showarg.h
406  *
407  *    Revision 1.32  2001/09/16 13:21:27  jongfoster
408  *    Changes to use new list functions.
409  *
410  *    Revision 1.31  2001/09/16 11:38:02  jongfoster
411  *    Splitting fill_template() into 2 functions:
412  *    template_load() loads the file
413  *    template_fill() performs the PCRS regexps.
414  *    This is because the CGI edit interface has a "table row"
415  *    template which is used many times in the page - this
416  *    change means it's only loaded from disk once.
417  *
418  *    Revision 1.30  2001/09/16 11:00:10  jongfoster
419  *    New function alloc_http_response, for symmetry with free_http_response
420  *
421  *    Revision 1.29  2001/09/13 23:32:40  jongfoster
422  *    Moving image data to cgi.c rather than cgi.h
423  *    Fixing a GPF under Win32 (and any other OS that protects global
424  *    constants from being written to).
425  *
426  *    Revision 1.28  2001/09/10 10:18:51  oes
427  *    Silenced compiler warnings
428  *
429  *    Revision 1.27  2001/08/05 16:06:20  jongfoster
430  *    Modifiying "struct map" so that there are now separate header and
431  *    "map_entry" structures.  This means that functions which modify a
432  *    map no longer need to return a pointer to the modified map.
433  *    Also, it no longer reverses the order of the entries (which may be
434  *    important with some advanced template substitutions).
435  *
436  *    Revision 1.26  2001/07/30 22:08:36  jongfoster
437  *    Tidying up #defines:
438  *    - All feature #defines are now of the form FEATURE_xxx
439  *    - Permanently turned off WIN_GUI_EDIT
440  *    - Permanently turned on WEBDAV and SPLIT_PROXY_ARGS
441  *
442  *    Revision 1.25  2001/07/26 10:09:46  oes
443  *    Made browser detection a little less naive
444  *
445  *    Revision 1.24  2001/07/25 17:22:51  oes
446  *    Added workaround for Netscape bug that prevents display of page when loading a component fails.
447  *
448  *    Revision 1.23  2001/07/23 13:40:12  oes
449  *    Fixed bug that caused document body to be dropped when pcrs joblist was empty.
450  *
451  *    Revision 1.22  2001/07/18 12:29:34  oes
452  *    - Made gif_deanimate_response respect
453  *      csp->action->string[ACTION_STRING_DEANIMATE]
454  *    - Logging cosmetics
455  *
456  *    Revision 1.21  2001/07/13 13:59:53  oes
457  *     - Introduced gif_deanimate_response which shares the
458  *       generic content modification interface of pcrs_filter_response
459  *       and acts as a wrapper to deanimate.c:gif_deanimate()
460  *     - Renamed re_process_buffer to pcrs_filter_response
461  *     - pcrs_filter_response now returns NULL on failiure
462  *     - Removed all #ifdef PCRS
463  *
464  *    Revision 1.20  2001/07/01 17:01:04  oes
465  *    Added comments and missing return statement in is_untrusted_url()
466  *
467  *    Revision 1.19  2001/06/29 21:45:41  oes
468  *    Indentation, CRLF->LF, Tab-> Space
469  *
470  *    Revision 1.18  2001/06/29 13:27:38  oes
471  *    - Cleaned up, renamed and reorderd functions
472  *      and improved comments
473  *
474  *    - block_url:
475  *      - Ported to CGI platform. Now delivers
476  *        http_response or NULL
477  *      - Unified HTML and GIF generation (moved image detection
478  *        and GIF generation here from jcc.c:chat())
479  *      - Fixed HTTP status to:
480  *       -  403 (Forbidden) for the "blocked" HTML message
481  *       -  200 (OK) for GIF answers
482  *       -  302 (Redirect) for redirect to GIF
483  *
484  *    - trust_url:
485  *      - Ported to CGI platform. Now delivers
486  *        http_response or NULL
487  *      - Separated detection of untrusted URL into
488  *        (bool)is_untrusted_url
489  *      - Added enforcement of untrusted requests
490  *
491  *    - Moved redirect_url() from cgi.c to here
492  *      and ported it to the CGI platform
493  *
494  *    - Removed logentry from cancelled commit
495  *
496  *    Revision 1.17  2001/06/09 10:55:28  jongfoster
497  *    Changing BUFSIZ ==> BUFFER_SIZE
498  *
499  *    Revision 1.16  2001/06/07 23:10:26  jongfoster
500  *    Allowing unanchored domain patterns to back off and retry
501  *    if they partially match.  Optimized right-anchored patterns.
502  *    Moving ACL and forward files into config file.
503  *    Replacing struct gateway with struct forward_spec
504  *
505  *    Revision 1.15  2001/06/03 19:12:00  oes
506  *    extracted-CGI relevant stuff
507  *
508  *    Revision 1.14  2001/06/01 10:30:55  oes
509  *    Added optional left-anchoring to domaincmp
510  *
511  *    Revision 1.13  2001/05/31 21:21:30  jongfoster
512  *    Permissionsfile / actions file changes:
513  *    - Changed "permission" to "action" throughout
514  *    - changes to file format to allow string parameters
515  *    - Moved helper functions to actions.c
516  *
517  *    Revision 1.12  2001/05/31 17:35:20  oes
518  *
519  *     - Enhanced domain part globbing with infix and prefix asterisk
520  *       matching and optional unanchored operation
521  *
522  *    Revision 1.11  2001/05/29 11:53:23  oes
523  *    "See why" link added to "blocked" page
524  *
525  *    Revision 1.10  2001/05/29 09:50:24  jongfoster
526  *    Unified blocklist/imagelist/permissionslist.
527  *    File format is still under discussion, but the internal changes
528  *    are (mostly) done.
529  *
530  *    Also modified interceptor behaviour:
531  *    - We now intercept all URLs beginning with one of the following
532  *      prefixes (and *only* these prefixes):
533  *        * http://i.j.b/
534  *        * http://ijbswa.sf.net/config/
535  *        * http://ijbswa.sourceforge.net/config/
536  *    - New interceptors "home page" - go to http://i.j.b/ to see it.
537  *    - Internal changes so that intercepted and fast redirect pages
538  *      are not replaced with an image.
539  *    - Interceptors now have the option to send a binary page direct
540  *      to the client. (i.e. ijb-send-banner uses this)
541  *    - Implemented show-url-info interceptor.  (Which is why I needed
542  *      the above interceptors changes - a typical URL is
543  *      "http://i.j.b/show-url-info?url=www.somesite.com/banner.gif".
544  *      The previous mechanism would not have intercepted that, and
545  *      if it had been intercepted then it then it would have replaced
546  *      it with an image.)
547  *
548  *    Revision 1.9  2001/05/27 22:17:04  oes
549  *
550  *    - re_process_buffer no longer writes the modified buffer
551  *      to the client, which was very ugly. It now returns the
552  *      buffer, which it is then written by chat.
553  *
554  *    - content_length now adjusts the Content-Length: header
555  *      for modified documents rather than crunch()ing it.
556  *      (Length info in csp->content_length, which is 0 for
557  *      unmodified documents)
558  *
559  *    - For this to work, sed() is called twice when filtering.
560  *
561  *    Revision 1.8  2001/05/26 17:13:28  jongfoster
562  *    Filled in a function comment.
563  *
564  *    Revision 1.7  2001/05/26 15:26:15  jongfoster
565  *    ACL feature now provides more security by immediately dropping
566  *    connections from untrusted hosts.
567  *
568  *    Revision 1.6  2001/05/26 00:28:36  jongfoster
569  *    Automatic reloading of config file.
570  *    Removed obsolete SIGHUP support (Unix) and Reload menu option (Win32).
571  *    Most of the global variables have been moved to a new
572  *    struct configuration_spec, accessed through csp->config->globalname
573  *    Most of the globals remaining are used by the Win32 GUI.
574  *
575  *    Revision 1.5  2001/05/25 22:34:30  jongfoster
576  *    Hard tabs->Spaces
577  *
578  *    Revision 1.4  2001/05/22 18:46:04  oes
579  *
580  *    - Enabled filtering banners by size rather than URL
581  *      by adding patterns that replace all standard banner
582  *      sizes with the "Junkbuster" gif to the re_filterfile
583  *
584  *    - Enabled filtering WebBugs by providing a pattern
585  *      which kills all 1x1 images
586  *
587  *    - Added support for PCRE_UNGREEDY behaviour to pcrs,
588  *      which is selected by the (nonstandard and therefore
589  *      capital) letter 'U' in the option string.
590  *      It causes the quantifiers to be ungreedy by default.
591  *      Appending a ? turns back to greedy (!).
592  *
593  *    - Added a new interceptor ijb-send-banner, which
594  *      sends back the "Junkbuster" gif. Without imagelist or
595  *      MSIE detection support, or if tinygif = 1, or the
596  *      URL isn't recognized as an imageurl, a lame HTML
597  *      explanation is sent instead.
598  *
599  *    - Added new feature, which permits blocking remote
600  *      script redirects and firing back a local redirect
601  *      to the browser.
602  *      The feature is conditionally compiled, i.e. it
603  *      can be disabled with --disable-fast-redirects,
604  *      plus it must be activated by a "fast-redirects"
605  *      line in the config file, has its own log level
606  *      and of course wants to be displayed by show-proxy-args
607  *      Note: Boy, all the #ifdefs in 1001 locations and
608  *      all the fumbling with configure.in and acconfig.h
609  *      were *way* more work than the feature itself :-(
610  *
611  *    - Because a generic redirect template was needed for
612  *      this, tinygif = 3 now uses the same.
613  *
614  *    - Moved GIFs, and other static HTTP response templates
615  *      to project.h
616  *
617  *    - Some minor fixes
618  *
619  *    - Removed some >400 CRs again (Jon, you really worked
620  *      a lot! ;-)
621  *
622  *    Revision 1.3  2001/05/20 16:44:47  jongfoster
623  *    Removing last hardcoded Junkbusters.com URLs.
624  *
625  *    Revision 1.2  2001/05/20 01:21:20  jongfoster
626  *    Version 2.9.4 checkin.
627  *    - Merged popupfile and cookiefile, and added control over PCRS
628  *      filtering, in new "permissionsfile".
629  *    - Implemented LOG_LEVEL_FATAL, so that if there is a configuration
630  *      file error you now get a message box (in the Win32 GUI) rather
631  *      than the program exiting with no explanation.
632  *    - Made killpopup use the PCRS MIME-type checking and HTTP-header
633  *      skipping.
634  *    - Removed tabs from "config"
635  *    - Moved duplicated url parsing code in "loaders.c" to a new funcition.
636  *    - Bumped up version number.
637  *
638  *    Revision 1.1.1.1  2001/05/15 13:58:52  oes
639  *    Initial import of version 2.9.3 source tree
640  *
641  *
642  *********************************************************************/
643 \f
644
645 #include "config.h"
646
647 #include <stdio.h>
648 #include <sys/types.h>
649 #include <stdlib.h>
650 #include <ctype.h>
651 #include <string.h>
652 #include <assert.h>
653
654 #ifndef _WIN32
655 #ifndef __OS2__
656 #include <unistd.h>
657 #endif /* ndef __OS2__ */
658 #include <netinet/in.h>
659 #else
660 #include <winsock2.h>
661 #endif /* ndef _WIN32 */
662
663 #ifdef __OS2__
664 #include <utils.h>
665 #endif /* def __OS2__ */
666
667 #include "project.h"
668 #include "filters.h"
669 #include "encode.h"
670 #include "parsers.h"
671 #include "ssplit.h"
672 #include "errlog.h"
673 #include "jbsockets.h"
674 #include "miscutil.h"
675 #include "actions.h"
676 #include "cgi.h"
677 #include "list.h"
678 #include "deanimate.h"
679 #include "urlmatch.h"
680 #include "loaders.h"
681
682 #ifdef _WIN32
683 #include "win32.h"
684 #endif
685
686 const char filters_h_rcs[] = FILTERS_H_VERSION;
687
688 /* Fix a problem with Solaris.  There should be no effect on other
689  * platforms.
690  * Solaris's isspace() is a macro which uses it's argument directly
691  * as an array index.  Therefore we need to make sure that high-bit
692  * characters generate +ve values, and ideally we also want to make
693  * the argument match the declared parameter type of "int".
694  */
695 #define ijb_isdigit(__X) isdigit((int)(unsigned char)(__X))
696
697 static jb_err remove_chunked_transfer_coding(char *buffer, size_t *size);
698 static jb_err prepare_for_filtering(struct client_state *csp);
699
700 #ifdef FEATURE_ACL
701 /*********************************************************************
702  *
703  * Function    :  block_acl
704  *
705  * Description :  Block this request?
706  *                Decide yes or no based on ACL file.
707  *
708  * Parameters  :
709  *          1  :  dst = The proxy or gateway address this is going to.
710  *                      Or NULL to check all possible targets.
711  *          2  :  csp = Current client state (buffers, headers, etc...)
712  *                      Also includes the client IP address.
713  *
714  * Returns     : 0 = FALSE (don't block) and 1 = TRUE (do block)
715  *
716  *********************************************************************/
717 int block_acl(const struct access_control_addr *dst, const struct client_state *csp)
718 {
719    struct access_control_list *acl = csp->config->acl;
720
721    /* if not using an access control list, then permit the connection */
722    if (acl == NULL)
723    {
724       return(0);
725    }
726
727    /* search the list */
728    while (acl != NULL)
729    {
730       if ((csp->ip_addr_long & acl->src->mask) == acl->src->addr)
731       {
732          if (dst == NULL)
733          {
734             /* Just want to check if they have any access */
735             if (acl->action == ACL_PERMIT)
736             {
737                return(0);
738             }
739          }
740          else if ( ((dst->addr & acl->dst->mask) == acl->dst->addr)
741            && ((dst->port == acl->dst->port) || (acl->dst->port == 0)))
742          {
743             if (acl->action == ACL_PERMIT)
744             {
745                return(0);
746             }
747             else
748             {
749                return(1);
750             }
751          }
752       }
753       acl = acl->next;
754    }
755
756    return(1);
757
758 }
759
760
761 /*********************************************************************
762  *
763  * Function    :  acl_addr
764  *
765  * Description :  Called from `load_config' to parse an ACL address.
766  *
767  * Parameters  :
768  *          1  :  aspec = String specifying ACL address.
769  *          2  :  aca = struct access_control_addr to fill in.
770  *
771  * Returns     :  0 => Ok, everything else is an error.
772  *
773  *********************************************************************/
774 int acl_addr(const char *aspec, struct access_control_addr *aca)
775 {
776    int i, masklength;
777    long port;
778    char *p;
779    char *acl_spec = NULL;
780
781    masklength = 32;
782    port       =  0;
783
784    /*
785     * Use a temporary acl spec copy so we can log
786     * the unmodified original in case of parse errors.
787     */
788    acl_spec = strdup(aspec);
789    if (acl_spec == NULL)
790    {
791       /* XXX: This will be logged as parse error. */
792       return(-1);
793    }
794
795    if ((p = strchr(acl_spec, '/')) != NULL)
796    {
797       *p++ = '\0';
798       if (ijb_isdigit(*p) == 0)
799       {
800          freez(acl_spec);
801          return(-1);
802       }
803       masklength = atoi(p);
804    }
805
806    if ((masklength < 0) || (masklength > 32))
807    {
808       freez(acl_spec);
809       return(-1);
810    }
811
812    if ((p = strchr(acl_spec, ':')) != NULL)
813    {
814       char *endptr;
815
816       *p++ = '\0';
817       port = strtol(p, &endptr, 10);
818
819       if (port <= 0 || port > 65535 || *endptr != '\0')
820       {
821          freez(acl_spec);
822          return(-1);
823       }
824    }
825
826    aca->port = (unsigned long)port;
827
828    aca->addr = ntohl(resolve_hostname_to_ip(acl_spec));
829    freez(acl_spec);
830
831    if (aca->addr == INADDR_NONE)
832    {
833       /* XXX: This will be logged as parse error. */
834       return(-1);
835    }
836
837    /* build the netmask */
838    aca->mask = 0;
839    for (i=1; i <= masklength ; i++)
840    {
841       aca->mask |= (1U << (32 - i));
842    }
843
844    /* now mask off the host portion of the ip address
845     * (i.e. save on the network portion of the address).
846     */
847    aca->addr = aca->addr & aca->mask;
848
849    return(0);
850
851 }
852 #endif /* def FEATURE_ACL */
853
854
855 /*********************************************************************
856  *
857  * Function    :  connect_port_is_forbidden
858  *
859  * Description :  Check to see if CONNECT requests to the destination
860  *                port of this request are forbidden. The check is
861  *                independend of the actual request method.
862  *
863  * Parameters  :
864  *          1  :  csp = Current client state (buffers, headers, etc...)
865  *
866  * Returns     :  True if yes, false otherwise.
867  *
868  *********************************************************************/
869 int connect_port_is_forbidden(const struct client_state *csp)
870 {
871    return ((csp->action->flags & ACTION_LIMIT_CONNECT) &&
872      !match_portlist(csp->action->string[ACTION_STRING_LIMIT_CONNECT],
873         csp->http->port));
874 }
875
876
877 /*********************************************************************
878  *
879  * Function    :  block_url
880  *
881  * Description :  Called from `chat'.  Check to see if we need to block this.
882  *
883  * Parameters  :
884  *          1  :  csp = Current client state (buffers, headers, etc...)
885  *
886  * Returns     :  NULL => unblocked, else HTTP block response
887  *
888  *********************************************************************/
889 struct http_response *block_url(struct client_state *csp)
890 {
891    struct http_response *rsp;
892    const char *new_content_type = NULL;
893
894    /*
895     * If it's not blocked, don't block it ;-)
896     */
897    if ((csp->action->flags & ACTION_BLOCK) == 0)
898    {
899       return NULL;
900    }
901    if (csp->action->flags & ACTION_REDIRECT)
902    {
903       log_error(LOG_LEVEL_ERROR, "redirect{} overruled by block.");     
904    }
905    /*
906     * Else, prepare a response
907     */
908    if (NULL == (rsp = alloc_http_response()))
909    {
910       return cgi_error_memory();
911    }
912
913    /*
914     * If it's an image-url, send back an image or redirect
915     * as specified by the relevant +image action
916     */
917 #ifdef FEATURE_IMAGE_BLOCKING
918    if (((csp->action->flags & ACTION_IMAGE_BLOCKER) != 0)
919         && is_imageurl(csp))
920    {
921       char *p;
922       /* determine HOW images should be blocked */
923       p = csp->action->string[ACTION_STRING_IMAGE_BLOCKER];
924
925       if(csp->action->flags & ACTION_HANDLE_AS_EMPTY_DOCUMENT)
926       {
927          log_error(LOG_LEVEL_ERROR, "handle-as-empty-document overruled by handle-as-image.");
928       }
929 #if 1 /* Two alternative strategies, use this one for now: */
930
931       /* and handle accordingly: */
932       if ((p == NULL) || (0 == strcmpic(p, "pattern")))
933       {
934          rsp->status = strdup("403 Request blocked by Privoxy");
935          if (rsp->status == NULL)
936          {
937             free_http_response(rsp);
938             return cgi_error_memory();
939          }
940          rsp->body = bindup(image_pattern_data, image_pattern_length);
941          if (rsp->body == NULL)
942          {
943             free_http_response(rsp);
944             return cgi_error_memory();
945          }
946          rsp->content_length = image_pattern_length;
947
948          if (enlist_unique_header(rsp->headers, "Content-Type", BUILTIN_IMAGE_MIMETYPE))
949          {
950             free_http_response(rsp);
951             return cgi_error_memory();
952          }
953       }
954
955       else if (0 == strcmpic(p, "blank"))
956       {
957          rsp->status = strdup("403 Request blocked by Privoxy");
958          if (rsp->status == NULL)
959          {
960             free_http_response(rsp);
961             return cgi_error_memory();
962          }
963          rsp->body = bindup(image_blank_data, image_blank_length);
964          if (rsp->body == NULL)
965          {
966             free_http_response(rsp);
967             return cgi_error_memory();
968          }
969          rsp->content_length = image_blank_length;
970
971          if (enlist_unique_header(rsp->headers, "Content-Type", BUILTIN_IMAGE_MIMETYPE))
972          {
973             free_http_response(rsp);
974             return cgi_error_memory();
975          }
976       }
977
978       else
979       {
980          rsp->status = strdup("302 Local Redirect from Privoxy");
981          if (rsp->status == NULL)
982          {
983             free_http_response(rsp);
984             return cgi_error_memory();
985          }
986
987          if (enlist_unique_header(rsp->headers, "Location", p))
988          {
989             free_http_response(rsp);
990             return cgi_error_memory();
991          }
992       }
993
994 #else /* Following code is disabled for now */
995
996       /* and handle accordingly: */
997       if ((p == NULL) || (0 == strcmpic(p, "pattern")))
998       {
999          p = CGI_PREFIX "send-banner?type=pattern";
1000       }
1001       else if (0 == strcmpic(p, "blank"))
1002       {
1003          p = CGI_PREFIX "send-banner?type=blank";
1004       }
1005       rsp->status = strdup("302 Local Redirect from Privoxy");
1006       if (rsp->status == NULL)
1007       {
1008          free_http_response(rsp);
1009          return cgi_error_memory();
1010       }
1011
1012       if (enlist_unique_header(rsp->headers, "Location", p))
1013       {
1014          free_http_response(rsp);
1015          return cgi_error_memory();
1016       }
1017 #endif /* Preceeding code is disabled for now */
1018    }
1019    else if(csp->action->flags & ACTION_HANDLE_AS_EMPTY_DOCUMENT)
1020    {
1021      /*
1022       *  Send empty document.               
1023       */
1024       new_content_type = csp->action->string[ACTION_STRING_CONTENT_TYPE];
1025
1026       freez(rsp->body);
1027       rsp->body = strdup(" ");
1028       rsp->content_length = 1;
1029
1030       rsp->status = strdup("403 Request blocked by Privoxy");
1031       if (rsp->status == NULL)
1032       {
1033          free_http_response(rsp);
1034          return cgi_error_memory();
1035       }
1036       if (new_content_type != 0)
1037       {
1038          log_error(LOG_LEVEL_HEADER, "Overwriting Content-Type with %s", new_content_type);
1039          if (enlist_unique_header(rsp->headers, "Content-Type", new_content_type))
1040          {
1041             free_http_response(rsp);
1042             return cgi_error_memory();
1043          }
1044       }
1045    }
1046    else
1047 #endif /* def FEATURE_IMAGE_BLOCKING */
1048
1049    /*
1050     * Else, generate an HTML "blocked" message:
1051     */
1052    {
1053       jb_err err;
1054       struct map * exports;
1055       char *p;
1056
1057       /*
1058        * Workaround for stupid Netscape bug which prevents
1059        * pages from being displayed if loading a referenced
1060        * JavaScript or style sheet fails. So make it appear
1061        * as if it succeeded.
1062        */
1063       if ( NULL != (p = get_header_value(csp->headers, "User-Agent:"))
1064            && !strncmpic(p, "mozilla", 7) /* Catch Netscape but */
1065            && !strstr(p, "Gecko")         /* save Mozilla, */
1066            && !strstr(p, "compatible")    /* MSIE */
1067            && !strstr(p, "Opera"))        /* and Opera. */
1068       {
1069          rsp->status = strdup("200 Request for blocked URL");
1070       }
1071       else
1072       {
1073          rsp->status = strdup("403 Request for blocked URL");
1074       }
1075
1076       if (rsp->status == NULL)
1077       {
1078          free_http_response(rsp);
1079          return cgi_error_memory();
1080       }
1081
1082       exports = default_exports(csp, NULL);
1083       if (exports == NULL)
1084       {
1085          free_http_response(rsp);
1086          return cgi_error_memory();
1087       }
1088
1089 #ifdef FEATURE_FORCE_LOAD
1090       err = map(exports, "force-prefix", 1, FORCE_PREFIX, 1);
1091       /*
1092        * Export the force conditional block killer if
1093        *
1094        * - Privoxy was compiled without FEATURE_FORCE_LOAD, or
1095        * - Privoxy is configured to enforce blocks, or
1096        * - it's a CONNECT request and enforcing wouldn't work anyway.
1097        */
1098       if ((csp->config->feature_flags & RUNTIME_FEATURE_ENFORCE_BLOCKS)
1099        || (0 == strcmpic(csp->http->gpc, "connect")))
1100 #endif /* ndef FEATURE_FORCE_LOAD */
1101       {
1102          err = map_block_killer(exports, "force-support");
1103       }
1104
1105       if (!err) err = map(exports, "protocol", 1, csp->http->ssl ? "https://" : "http://", 1);
1106       if (!err) err = map(exports, "hostport", 1, html_encode(csp->http->hostport), 0);
1107       if (!err) err = map(exports, "path", 1, html_encode(csp->http->path), 0);
1108       if (!err) err = map(exports, "path-ue", 1, url_encode(csp->http->path), 0);
1109       if (!err)
1110       {
1111          const char *block_reason;
1112          if (csp->action->string[ACTION_STRING_BLOCK] != NULL)
1113          {
1114             block_reason = csp->action->string[ACTION_STRING_BLOCK];
1115          }
1116          else
1117          {
1118             assert(connect_port_is_forbidden(csp));
1119             block_reason = "Forbidden CONNECT port.";
1120          }
1121          err = map(exports, "block-reason", 1, html_encode(block_reason), 0);
1122       }
1123       if (err)
1124       {
1125          free_map(exports);
1126          free_http_response(rsp);
1127          return cgi_error_memory();
1128       }
1129
1130       err = template_fill_for_cgi(csp, "blocked", exports, rsp);
1131       if (err)
1132       {
1133          free_http_response(rsp);
1134          return cgi_error_memory();
1135       }
1136    }
1137    rsp->reason = RSP_REASON_BLOCKED;
1138
1139    return finish_http_response(csp, rsp);
1140
1141 }
1142
1143
1144 #ifdef FEATURE_TRUST
1145 /*********************************************************************
1146  *
1147  * Function    :  trust_url FIXME: I should be called distrust_url
1148  *
1149  * Description :  Calls is_untrusted_url to determine if the URL is trusted
1150  *                and if not, returns a HTTP 403 response with a reject message.
1151  *
1152  * Parameters  :
1153  *          1  :  csp = Current client state (buffers, headers, etc...)
1154  *
1155  * Returns     :  NULL => trusted, else http_response.
1156  *
1157  *********************************************************************/
1158 struct http_response *trust_url(struct client_state *csp)
1159 {
1160    struct http_response *rsp;
1161    struct map * exports;
1162    char buf[BUFFER_SIZE];
1163    char *p;
1164    struct url_spec **tl;
1165    struct url_spec *t;
1166    jb_err err;
1167
1168    /*
1169     * Don't bother to work on trusted URLs
1170     */
1171    if (!is_untrusted_url(csp))
1172    {
1173       return NULL;
1174    }
1175
1176    /*
1177     * Else, prepare a response:
1178     */
1179    if (NULL == (rsp = alloc_http_response()))
1180    {
1181       return cgi_error_memory();
1182    }
1183
1184    rsp->status = strdup("403 Request blocked by Privoxy");
1185    exports = default_exports(csp, NULL);
1186    if (exports == NULL || rsp->status == NULL)
1187    {
1188       free_http_response(rsp);
1189       return cgi_error_memory();
1190    }
1191
1192    /*
1193     * Export the protocol, host, port, and referrer information
1194     */
1195    err = map(exports, "hostport", 1, csp->http->hostport, 1);
1196    if (!err) err = map(exports, "protocol", 1, csp->http->ssl ? "https://" : "http://", 1); 
1197    if (!err) err = map(exports, "path", 1, csp->http->path, 1);
1198
1199    if (NULL != (p = get_header_value(csp->headers, "Referer:")))
1200    {
1201       if (!err) err = map(exports, "referrer", 1, html_encode(p), 0);
1202    }
1203    else
1204    {
1205       if (!err) err = map(exports, "referrer", 1, "none set", 1);
1206    }
1207
1208    if (err)
1209    {
1210       free_map(exports);
1211       free_http_response(rsp);
1212       return cgi_error_memory();
1213    }
1214
1215    /*
1216     * Export the trust list
1217     */
1218    p = strdup("");
1219    for (tl = csp->config->trust_list; (t = *tl) != NULL ; tl++)
1220    {
1221       snprintf(buf, sizeof(buf), "<li>%s</li>\n", t->spec);
1222       string_append(&p, buf);
1223    }
1224    err = map(exports, "trusted-referrers", 1, p, 0);
1225
1226    if (err)
1227    {
1228       free_map(exports);
1229       free_http_response(rsp);
1230       return cgi_error_memory();
1231    }
1232
1233    /*
1234     * Export the trust info, if available
1235     */
1236    if (csp->config->trust_info->first)
1237    {
1238       struct list_entry *l;
1239
1240       p = strdup("");
1241       for (l = csp->config->trust_info->first; l ; l = l->next)
1242       {
1243          snprintf(buf, sizeof(buf), "<li> <a href=\"%s\">%s</a><br>\n", l->str, l->str);
1244          string_append(&p, buf);
1245       }
1246       err = map(exports, "trust-info", 1, p, 0);
1247    }
1248    else
1249    {
1250       err = map_block_killer(exports, "have-trust-info");
1251    }
1252
1253    if (err)
1254    {
1255       free_map(exports);
1256       free_http_response(rsp);
1257       return cgi_error_memory();
1258    }
1259
1260    /*
1261     * Export the force conditional block killer if
1262     *
1263     * - Privoxy was compiled without FEATURE_FORCE_LOAD, or
1264     * - Privoxy is configured to enforce blocks, or
1265     * - it's a CONNECT request and enforcing wouldn't work anyway.
1266     */
1267 #ifdef FEATURE_FORCE_LOAD
1268    if ((csp->config->feature_flags & RUNTIME_FEATURE_ENFORCE_BLOCKS)
1269     || (0 == strcmpic(csp->http->gpc, "connect")))
1270    {
1271       err = map_block_killer(exports, "force-support");
1272    }
1273    else
1274    {
1275       err = map(exports, "force-prefix", 1, FORCE_PREFIX, 1);
1276    }
1277 #else /* ifndef FEATURE_FORCE_LOAD */
1278    err = map_block_killer(exports, "force-support");
1279 #endif /* ndef FEATURE_FORCE_LOAD */
1280
1281    if (err)
1282    {
1283       free_map(exports);
1284       free_http_response(rsp);
1285       return cgi_error_memory();
1286    }
1287
1288    /*
1289     * Build the response
1290     */
1291    err = template_fill_for_cgi(csp, "untrusted", exports, rsp);
1292    if (err)
1293    {
1294       free_http_response(rsp);
1295       return cgi_error_memory();
1296    }
1297    rsp->reason = RSP_REASON_UNTRUSTED;
1298
1299    return finish_http_response(csp, rsp);
1300 }
1301 #endif /* def FEATURE_TRUST */
1302
1303
1304 /*********************************************************************
1305  *
1306  * Function    :  compile_dynamic_pcrs_job_list
1307  *
1308  * Description :  Compiles a dynamic pcrs job list (one with variables
1309  *                resolved at request time)
1310  *
1311  * Parameters  :
1312  *          1  :  csp = Current client state (buffers, headers, etc...)
1313  *          2  :  b = The filter list to compile
1314  *
1315  * Returns     :  NULL in case of errors, otherwise the
1316  *                pcrs job list.  
1317  *
1318  *********************************************************************/
1319 pcrs_job *compile_dynamic_pcrs_job_list(const struct client_state *csp, const struct re_filterfile_spec *b)
1320 {
1321    struct list_entry *pattern;
1322    pcrs_job *job_list = NULL;
1323    pcrs_job *dummy = NULL;
1324    pcrs_job *lastjob = NULL;
1325    int error = 0;
1326
1327    const struct pcrs_variable variables[] =
1328    {
1329       {"url",    csp->http->url,   1},
1330       {"path",   csp->http->path,  1},
1331       {"host",   csp->http->host,  1},
1332       {"origin", csp->ip_addr_str, 1},
1333       {NULL,     NULL,             1}
1334    };
1335
1336    for (pattern = b->patterns->first; pattern != NULL; pattern = pattern->next)
1337    {
1338       assert(pattern->str != NULL);
1339
1340       dummy = pcrs_compile_dynamic_command(pattern->str, variables, &error);
1341       if (NULL == dummy)
1342       {
1343          assert(error < 0);
1344          log_error(LOG_LEVEL_ERROR,
1345             "Adding filter job \'%s\' to dynamic filter %s failed: %s",
1346             pattern->str, b->name, pcrs_strerror(error));
1347          continue;
1348       }
1349       else
1350       {
1351          if (error == PCRS_WARN_TRUNCATION)
1352          {
1353             log_error(LOG_LEVEL_ERROR,
1354                "At least one of the variables in \'%s\' had to "
1355                "be truncated before compilation", pattern->str);
1356          }
1357          if (job_list == NULL)
1358          {
1359             job_list = dummy;
1360          }
1361          else
1362          {
1363             lastjob->next = dummy;
1364          }
1365          lastjob = dummy;
1366       }
1367    }
1368
1369    return job_list;
1370 }
1371
1372
1373 /*********************************************************************
1374  *
1375  * Function    :  rewrite_url
1376  *
1377  * Description :  Rewrites a URL with a single pcrs command
1378  *                and returns the result if it differs from the
1379  *                original and isn't obviously invalid.
1380  *
1381  * Parameters  :
1382  *          1  :  old_url = URL to rewrite.
1383  *          2  :  pcrs_command = pcrs command formatted as string (s@foo@bar@)
1384  *
1385  *
1386  * Returns     :  NULL if the pcrs_command didn't change the url, or 
1387  *                the result of the modification.
1388  *
1389  *********************************************************************/
1390 char *rewrite_url(char *old_url, const char *pcrs_command)
1391 {
1392    char *new_url = NULL;
1393    int hits;
1394
1395    assert(old_url);
1396    assert(pcrs_command);
1397
1398    new_url = pcrs_execute_single_command(old_url, pcrs_command, &hits);
1399
1400    if (hits == 0)
1401    {
1402       log_error(LOG_LEVEL_REDIRECTS,
1403          "pcrs command \"%s\" didn't change \"%s\".",
1404          pcrs_command, old_url);
1405       freez(new_url);
1406    }
1407    else if (hits < 0)
1408    {
1409       log_error(LOG_LEVEL_REDIRECTS,
1410          "executing pcrs command \"%s\" to rewrite %s failed: %s",
1411          pcrs_command, old_url, pcrs_strerror(hits));
1412       freez(new_url);
1413    }
1414    else if (strncmpic(new_url, "http://", 7) && strncmpic(new_url, "https://", 8))
1415    {
1416       log_error(LOG_LEVEL_ERROR,
1417          "pcrs command \"%s\" changed \"%s\" to \"%s\" (%u hi%s), "
1418          "but the result doesn't look like a valid URL and will be ignored.",
1419          pcrs_command, old_url, new_url, hits, (hits == 1) ? "t" : "ts");
1420       freez(new_url);
1421    }
1422    else
1423    {
1424       log_error(LOG_LEVEL_REDIRECTS,
1425          "pcrs command \"%s\" changed \"%s\" to \"%s\" (%u hi%s).",
1426          pcrs_command, old_url, new_url, hits, (hits == 1) ? "t" : "ts");
1427    }
1428
1429    return new_url;
1430
1431 }
1432
1433
1434 #ifdef FEATURE_FAST_REDIRECTS
1435 /*********************************************************************
1436  *
1437  * Function    :  get_last_url
1438  *
1439  * Description :  Search for the last URL inside a string.
1440  *                If the string already is a URL, it will
1441  *                be the first URL found.
1442  *
1443  * Parameters  :
1444  *          1  :  subject = the string to check
1445  *          2  :  redirect_mode = +fast-redirect{} mode 
1446  *
1447  * Returns     :  NULL if no URL was found, or
1448  *                the last URL found.
1449  *
1450  *********************************************************************/
1451 char *get_last_url(char *subject, const char *redirect_mode)
1452 {
1453    char *new_url = NULL;
1454    char *tmp;
1455
1456    assert(subject);
1457    assert(redirect_mode);
1458
1459    subject = strdup(subject);
1460    if (subject == NULL)
1461    {
1462       log_error(LOG_LEVEL_ERROR, "Out of memory while searching for redirects.");
1463       return NULL;
1464    }
1465
1466    if (0 == strcmpic(redirect_mode, "check-decoded-url"))
1467    {  
1468       log_error(LOG_LEVEL_REDIRECTS, "Decoding \"%s\" if necessary.", subject);
1469       new_url = url_decode(subject);
1470       if (new_url != NULL)
1471       {
1472          freez(subject);
1473          subject = new_url;
1474       }
1475       else
1476       {
1477          log_error(LOG_LEVEL_ERROR, "Unable to decode \"%s\".", subject);
1478       }
1479    }
1480
1481    log_error(LOG_LEVEL_REDIRECTS, "Checking \"%s\" for redirects.", subject);
1482
1483    /*
1484     * Find the last URL encoded in the request
1485     */
1486    tmp = subject;
1487    while ((tmp = strstr(tmp, "http://")) != NULL)
1488    {
1489       new_url = tmp++;
1490    }
1491    tmp = (new_url != NULL) ? new_url : subject;
1492    while ((tmp = strstr(tmp, "https://")) != NULL)
1493    {
1494       new_url = tmp++;
1495    }
1496
1497    if ((new_url != NULL)
1498       && (  (new_url != subject)
1499          || (0 == strncmpic(subject, "http://", 7))
1500          || (0 == strncmpic(subject, "https://", 8))
1501          ))
1502    {
1503       /*
1504        * Return new URL if we found a redirect 
1505        * or if the subject already was a URL.
1506        *
1507        * The second case makes sure that we can
1508        * chain get_last_url after another redirection check
1509        * (like rewrite_url) without losing earlier redirects.
1510        */
1511       new_url = strdup(new_url);
1512       freez(subject);
1513       return new_url;
1514    }
1515
1516    freez(subject);
1517    return NULL;
1518
1519 }
1520 #endif /* def FEATURE_FAST_REDIRECTS */
1521
1522
1523 /*********************************************************************
1524  *
1525  * Function    :  redirect_url
1526  *
1527  * Description :  Checks if Privoxy should answer the request with
1528  *                a HTTP redirect and generates the redirect if
1529  *                necessary.
1530  *
1531  * Parameters  :
1532  *          1  :  csp = Current client state (buffers, headers, etc...)
1533  *
1534  * Returns     :  NULL if the request can pass, HTTP redirect otherwise.
1535  *
1536  *********************************************************************/
1537 struct http_response *redirect_url(struct client_state *csp)
1538 {
1539    struct http_response *rsp;
1540 #ifdef FEATURE_FAST_REDIRECTS
1541    /*
1542     * XXX: Do we still need FEATURE_FAST_REDIRECTS
1543     * as compile-time option? The user can easily disable
1544     * it in his action file.
1545     */
1546    char * redirect_mode;
1547 #endif /* def FEATURE_FAST_REDIRECTS */
1548    char *old_url = NULL;
1549    char *new_url = NULL;
1550    char *redirection_string;
1551
1552    if ((csp->action->flags & ACTION_REDIRECT))
1553    {
1554       redirection_string = csp->action->string[ACTION_STRING_REDIRECT];
1555
1556       /*
1557        * If the redirection string begins with 's',
1558        * assume it's a pcrs command, otherwise treat it as
1559        * properly formatted URL and use it for the redirection
1560        * directly.
1561        *
1562        * According to RFC 2616 section 14.30 the URL
1563        * has to be absolute and if the user tries:
1564        * +redirect{shit/this/will/be/parsed/as/pcrs_command.html}
1565        * she would get undefined results anyway.
1566        *
1567        */
1568
1569       if (*redirection_string == 's')
1570       {
1571          old_url = csp->http->url;
1572          new_url = rewrite_url(old_url, redirection_string);
1573       }
1574       else
1575       {
1576          log_error(LOG_LEVEL_REDIRECTS,
1577             "No pcrs command recognized, assuming that \"%s\" is already properly formatted.",
1578             redirection_string);
1579          new_url = strdup(redirection_string);
1580       }
1581    }
1582
1583 #ifdef FEATURE_FAST_REDIRECTS
1584    if ((csp->action->flags & ACTION_FAST_REDIRECTS))
1585    {
1586       redirect_mode = csp->action->string[ACTION_STRING_FAST_REDIRECTS];
1587
1588       /*
1589        * If it exists, use the previously rewritten URL as input
1590        * otherwise just use the old path.
1591        */
1592       old_url = (new_url != NULL) ? new_url : strdup(csp->http->path);
1593       new_url = get_last_url(old_url, redirect_mode);
1594       freez(old_url);
1595    }
1596
1597    /*
1598     * Disable redirect checkers, so that they
1599     * will be only run more than once if the user
1600     * also enables them through tags.
1601     *
1602     * From a performance point of view
1603     * it doesn't matter, but the duplicated
1604     * log messages are annoying.
1605     */
1606    csp->action->flags &= ~ACTION_FAST_REDIRECTS;
1607 #endif /* def FEATURE_FAST_REDIRECTS */
1608    csp->action->flags &= ~ACTION_REDIRECT;
1609
1610    /* Did any redirect action trigger? */   
1611    if (new_url)
1612    {
1613       if (0 == strcmpic(new_url, csp->http->url))
1614       {
1615          log_error(LOG_LEVEL_ERROR,
1616             "New URL \"%s\" and old URL \"%s\" are the same. Redirection loop prevented.",
1617             csp->http->url, new_url);
1618             freez(new_url);
1619       }
1620       else
1621       {
1622          log_error(LOG_LEVEL_REDIRECTS, "New URL is: %s", new_url);
1623
1624          if (NULL == (rsp = alloc_http_response()))
1625          {
1626             freez(new_url);
1627             return cgi_error_memory();
1628          }
1629
1630          if ( enlist_unique_header(rsp->headers, "Location", new_url)
1631            || (NULL == (rsp->status = strdup("302 Local Redirect from Privoxy"))) )
1632          {
1633             freez(new_url);
1634             free_http_response(rsp);
1635             return cgi_error_memory();
1636          }
1637          rsp->reason = RSP_REASON_REDIRECTED;
1638          freez(new_url);
1639
1640          return finish_http_response(csp, rsp);
1641       }
1642    }
1643
1644    /* Only reached if no redirect is required */
1645    return NULL;
1646
1647 }
1648
1649
1650 #ifdef FEATURE_IMAGE_BLOCKING
1651 /*********************************************************************
1652  *
1653  * Function    :  is_imageurl
1654  *
1655  * Description :  Given a URL, decide whether it is an image or not,
1656  *                using either the info from a previous +image action
1657  *                or, #ifdef FEATURE_IMAGE_DETECT_MSIE, and the browser
1658  *                is MSIE and not on a Mac, tell from the browser's accept
1659  *                header.
1660  *
1661  * Parameters  :
1662  *          1  :  csp = Current client state (buffers, headers, etc...)
1663  *
1664  * Returns     :  True (nonzero) if URL is an image, false (0)
1665  *                otherwise
1666  *
1667  *********************************************************************/
1668 int is_imageurl(const struct client_state *csp)
1669 {
1670 #ifdef FEATURE_IMAGE_DETECT_MSIE
1671    char *tmp;
1672
1673    tmp = get_header_value(csp->headers, "User-Agent:");
1674    if (tmp && strstr(tmp, "MSIE") && !strstr(tmp, "Mac_"))
1675    {
1676       tmp = get_header_value(csp->headers, "Accept:");
1677       if (tmp && strstr(tmp, "image/gif"))
1678       {
1679          /* Client will accept HTML.  If this seems counterintuitive,
1680           * blame Microsoft.
1681           */
1682          return(0);
1683       }
1684       else
1685       {
1686          return(1);
1687       }
1688    }
1689 #endif /* def FEATURE_IMAGE_DETECT_MSIE */
1690
1691    return ((csp->action->flags & ACTION_IMAGE) != 0);
1692
1693 }
1694 #endif /* def FEATURE_IMAGE_BLOCKING */
1695
1696
1697 #ifdef FEATURE_TRUST
1698 /*********************************************************************
1699  *
1700  * Function    :  is_untrusted_url
1701  *
1702  * Description :  Should we "distrust" this URL (and block it)?
1703  *
1704  *                Yes if it matches a line in the trustfile, or if the
1705  *                    referrer matches a line starting with "+" in the
1706  *                    trustfile.
1707  *                No  otherwise.
1708  *
1709  * Parameters  :
1710  *          1  :  csp = Current client state (buffers, headers, etc...)
1711  *
1712  * Returns     :  0 => trusted, 1 => untrusted
1713  *
1714  *********************************************************************/
1715 int is_untrusted_url(const struct client_state *csp)
1716 {
1717    struct file_list *fl;
1718    struct block_spec *b;
1719    struct url_spec **trusted_url;
1720    struct http_request rhttp[1];
1721    const char * referer;
1722    jb_err err;
1723
1724    /*
1725     * If we don't have a trustlist, we trust everybody
1726     */
1727    if (((fl = csp->tlist) == NULL) || ((b  = fl->f) == NULL))
1728    {
1729       return 0;
1730    }
1731
1732    memset(rhttp, '\0', sizeof(*rhttp));
1733
1734    /*
1735     * Do we trust the request URL itself?
1736     */
1737    for (b = b->next; b ; b = b->next)
1738    {
1739       if (url_match(b->url, csp->http))
1740       {
1741          return b->reject;
1742       }
1743    }
1744
1745    if (NULL == (referer = get_header_value(csp->headers, "Referer:")))
1746    {
1747       /* no referrer was supplied */
1748       return 1;
1749    }
1750
1751
1752    /*
1753     * If not, do we maybe trust its referrer?
1754     */
1755    err = parse_http_url(referer, rhttp, REQUIRE_PROTOCOL);
1756    if (err)
1757    {
1758       return 1;
1759    }
1760
1761    for (trusted_url = csp->config->trust_list; *trusted_url != NULL; trusted_url++)
1762    {
1763       if (url_match(*trusted_url, rhttp))
1764       {
1765          /* if the URL's referrer is from a trusted referrer, then
1766           * add the target spec to the trustfile as an unblocked
1767           * domain and return 0 (which means it's OK).
1768           */
1769
1770          FILE *fp;
1771
1772          if (NULL != (fp = fopen(csp->config->trustfile, "a")))
1773          {
1774             char * path;
1775             char * path_end;
1776             char * new_entry = strdup("~");
1777
1778             string_append(&new_entry, csp->http->hostport);
1779
1780             path = csp->http->path;
1781             if ( (path[0] == '/')
1782               && (path[1] == '~')
1783               && ((path_end = strchr(path + 2, '/')) != NULL))
1784             {
1785                /* since this path points into a user's home space
1786                 * be sure to include this spec in the trustfile.
1787                 */
1788                int path_len = path_end - path; /* save offset */
1789                path = strdup(path); /* Copy string */
1790                if (path != NULL)
1791                {
1792                   path_end = path + path_len; /* regenerate ptr to new buffer */
1793                   *(path_end + 1) = '\0'; /* Truncate path after '/' */
1794                }
1795                string_join(&new_entry, path);
1796             }
1797
1798             /*
1799              * Give a reason for generating this entry.
1800              */
1801             string_append(&new_entry, " # Trusted referrer was: ");
1802             string_append(&new_entry, referer);
1803
1804             if (new_entry != NULL)
1805             {
1806                if (-1 == fprintf(fp, "%s\n", new_entry))
1807                {
1808                   log_error(LOG_LEVEL_ERROR, "Failed to append \'%s\' to trustfile \'%s\': %E",
1809                      new_entry, csp->config->trustfile);
1810                }
1811                freez(new_entry);
1812             }
1813             else
1814             {
1815                /* FIXME: No way to handle out-of memory, so mostly ignoring it */
1816                log_error(LOG_LEVEL_ERROR, "Out of memory adding pattern to trust file");
1817             }
1818
1819             fclose(fp);
1820          }
1821          else
1822          {
1823             log_error(LOG_LEVEL_ERROR, "Failed to append new entry for \'%s\' to trustfile \'%s\': %E",
1824                csp->http->hostport, csp->config->trustfile);
1825          }
1826          return 0;
1827       }
1828    }
1829
1830    return 1;
1831 }
1832 #endif /* def FEATURE_TRUST */
1833
1834
1835 /*********************************************************************
1836  *
1837  * Function    :  pcrs_filter_response
1838  *
1839  * Description :  Execute all text substitutions from all applying
1840  *                +filter actions on the text buffer that's been
1841  *                accumulated in csp->iob->buf.
1842  *
1843  * Parameters  :
1844  *          1  :  csp = Current client state (buffers, headers, etc...)
1845  *
1846  * Returns     :  a pointer to the (newly allocated) modified buffer.
1847  *                or NULL if there were no hits or something went wrong
1848  *
1849  *********************************************************************/
1850 static char *pcrs_filter_response(struct client_state *csp)
1851 {
1852    int hits=0;
1853    size_t size, prev_size;
1854
1855    char *old = NULL;
1856    char *new = NULL;
1857    pcrs_job *job;
1858
1859    struct file_list *fl;
1860    struct re_filterfile_spec *b;
1861    struct list_entry *filtername;
1862
1863    int i, found_filters = 0;
1864
1865    /* 
1866     * Sanity first
1867     */
1868    if (csp->iob->cur >= csp->iob->eod)
1869    {
1870       return(NULL);
1871    }
1872
1873    /*
1874     * Need to check the set of re_filterfiles...
1875     */
1876    for (i = 0; i < MAX_AF_FILES; i++)
1877    {
1878       fl = csp->rlist[i];
1879       if (NULL != fl)
1880       {
1881          if (NULL != fl->f)
1882          {
1883            found_filters = 1;
1884            break;
1885          }
1886       }
1887    }
1888
1889    if (0 == found_filters)
1890    {
1891       log_error(LOG_LEVEL_ERROR, "Inconsistent configuration: "
1892          "content filtering enabled, but no content filters available.");
1893       return(NULL);
1894    }
1895
1896    size = (size_t)(csp->iob->eod - csp->iob->cur);
1897    old = csp->iob->cur;
1898
1899    for (i = 0; i < MAX_AF_FILES; i++)
1900    {
1901      fl = csp->rlist[i];
1902      if ((NULL == fl) || (NULL == fl->f))
1903      {
1904         /*
1905          * Either there are no filter files
1906          * left, or this filter file just
1907          * contains no valid filters.
1908          *
1909          * Continue to be sure we don't miss
1910          * valid filter files that are chained
1911          * after empty or invalid ones.
1912          */
1913         continue;
1914      }
1915    /*
1916     * For all applying +filter actions, look if a filter by that
1917     * name exists and if yes, execute it's pcrs_joblist on the
1918     * buffer.
1919     */
1920    for (b = fl->f; b; b = b->next)
1921    {
1922       if (b->type != FT_CONTENT_FILTER)
1923       {
1924          /* Skip header filters */
1925          continue;
1926       }
1927
1928       for (filtername = csp->action->multi[ACTION_MULTI_FILTER]->first;
1929            filtername ; filtername = filtername->next)
1930       {
1931          if (strcmp(b->name, filtername->str) == 0)
1932          {
1933             int current_hits = 0; /* Number of hits caused by this filter */
1934             int job_number   = 0; /* Which job we're currently executing  */
1935             int job_hits     = 0; /* How many hits the current job caused */
1936             pcrs_job *joblist = b->joblist;
1937
1938             if (b->dynamic) joblist = compile_dynamic_pcrs_job_list(csp, b);
1939
1940             if (NULL == joblist)
1941             {
1942                log_error(LOG_LEVEL_RE_FILTER, "Filter %s has empty joblist. Nothing to do.", b->name);
1943                continue;
1944             }
1945
1946             prev_size = size;
1947             /* Apply all jobs from the joblist */
1948             for (job = joblist; NULL != job; job = job->next)
1949             {
1950                job_number++;
1951                job_hits = pcrs_execute(job, old, size, &new, &size);
1952
1953                if (job_hits >= 0)
1954                {
1955                   /*
1956                    * That went well. Continue filtering
1957                    * and use the result of this job as
1958                    * input for the next one.
1959                    */
1960                   current_hits += job_hits;
1961                   if (old != csp->iob->cur)
1962                   {
1963                      freez(old);
1964                   }
1965                   old = new;
1966                }
1967                else
1968                {
1969                   /*
1970                    * This job caused an unexpected error. Inform the user
1971                    * and skip the rest of the jobs in this filter. We could
1972                    * continue with the next job, but usually the jobs
1973                    * depend on each other or are similar enough to
1974                    * fail for the same reason.
1975                    *
1976                    * At the moment our pcrs expects the error codes of pcre 3.4,
1977                    * but newer pcre versions can return additional error codes.
1978                    * As a result pcrs_strerror()'s error message might be
1979                    * "Unknown error ...", therefore we print the numerical value
1980                    * as well.
1981                    *
1982                    * XXX: Is this important enough for LOG_LEVEL_ERROR or
1983                    * should we use LOG_LEVEL_RE_FILTER instead?
1984                    */
1985                   log_error(LOG_LEVEL_ERROR, "Skipped filter \'%s\' after job number %u: %s (%d)",
1986                      b->name, job_number, pcrs_strerror(job_hits), job_hits);
1987                   break;
1988                }
1989             }
1990
1991             if (b->dynamic) pcrs_free_joblist(joblist);
1992
1993             log_error(LOG_LEVEL_RE_FILTER,
1994                "filtering %s%s (size %d) with \'%s\' produced %d hits (new size %d).",
1995                csp->http->hostport, csp->http->path, prev_size, b->name, current_hits, size);
1996
1997             hits += current_hits;
1998          }
1999       }
2000    }
2001    }
2002
2003    /*
2004     * If there were no hits, destroy our copy and let
2005     * chat() use the original in csp->iob
2006     */
2007    if (!hits)
2008    {
2009       freez(new);
2010       return(NULL);
2011    }
2012
2013    csp->flags |= CSP_FLAG_MODIFIED;
2014    csp->content_length = size;
2015    IOB_RESET(csp);
2016
2017    return(new);
2018
2019 }
2020
2021
2022 /*********************************************************************
2023  *
2024  * Function    :  gif_deanimate_response
2025  *
2026  * Description :  Deanimate the GIF image that has been accumulated in
2027  *                csp->iob->buf, set csp->content_length to the modified
2028  *                size and raise the CSP_FLAG_MODIFIED flag.
2029  *
2030  * Parameters  :
2031  *          1  :  csp = Current client state (buffers, headers, etc...)
2032  *
2033  * Returns     :  a pointer to the (newly allocated) modified buffer.
2034  *                or NULL in case something went wrong.
2035  *
2036  *********************************************************************/
2037 static char *gif_deanimate_response(struct client_state *csp)
2038 {
2039    struct binbuffer *in, *out;
2040    char *p;
2041    size_t size;
2042
2043    size = (size_t)(csp->iob->eod - csp->iob->cur);
2044
2045    if (  (NULL == (in =  (struct binbuffer *)zalloc(sizeof *in )))
2046       || (NULL == (out = (struct binbuffer *)zalloc(sizeof *out))) )
2047    {
2048       log_error(LOG_LEVEL_DEANIMATE, "failed! (no mem)");
2049       return NULL;
2050    }
2051
2052    in->buffer = csp->iob->cur;
2053    in->size = size;
2054
2055    if (gif_deanimate(in, out, strncmp("last", csp->action->string[ACTION_STRING_DEANIMATE], 4)))
2056    {
2057       log_error(LOG_LEVEL_DEANIMATE, "failed! (gif parsing)");
2058       freez(in);
2059       buf_free(out);
2060       return(NULL);
2061    }
2062    else
2063    {
2064       if ((int)size == out->offset)
2065       {
2066          log_error(LOG_LEVEL_DEANIMATE, "GIF not changed.");
2067       }
2068       else
2069       {
2070          log_error(LOG_LEVEL_DEANIMATE, "Success! GIF shrunk from %d bytes to %d.", size, out->offset);
2071       }
2072       csp->content_length = out->offset;
2073       csp->flags |= CSP_FLAG_MODIFIED;
2074       p = out->buffer;
2075       freez(in);
2076       freez(out);
2077       return(p);
2078    }
2079
2080 }
2081
2082
2083 /*********************************************************************
2084  *
2085  * Function    :  get_filter_function
2086  *
2087  * Description :  Decides which content filter function has
2088  *                to be applied (if any).
2089  *
2090  * Parameters  :
2091  *          1  :  csp = Current client state (buffers, headers, etc...)
2092  *
2093  * Returns     :  The content filter function to run, or
2094  *                NULL if no content filter is active
2095  *
2096  *********************************************************************/
2097 filter_function_ptr get_filter_function(struct client_state *csp)
2098 {
2099    filter_function_ptr filter_function = NULL;
2100
2101    /*
2102     * Are we enabling text mode by force?
2103     */
2104    if (csp->action->flags & ACTION_FORCE_TEXT_MODE)
2105    {
2106       /*
2107        * Do we really have to?
2108        */
2109       if (csp->content_type & CT_TEXT)
2110       {
2111          log_error(LOG_LEVEL_HEADER, "Text mode is already enabled.");   
2112       }
2113       else
2114       {
2115          csp->content_type |= CT_TEXT;
2116          log_error(LOG_LEVEL_HEADER, "Text mode enabled by force. Take cover!");   
2117       }
2118    }
2119
2120    if (!(csp->content_type & CT_DECLARED))
2121    {
2122       /*
2123        * The server didn't bother to declare a MIME-Type.
2124        * Assume it's text that can be filtered.
2125        *
2126        * This also regulary happens with 304 responses,
2127        * therefore logging anything here would cause
2128        * too much noise.
2129        */
2130       csp->content_type |= CT_TEXT;
2131    }
2132
2133    /*
2134     * Choose the applying filter function based on
2135     * the content type and action settings.
2136     */
2137    if ((csp->content_type & CT_TEXT) &&
2138        (csp->rlist != NULL) &&
2139        (!list_is_empty(csp->action->multi[ACTION_MULTI_FILTER])))
2140    {
2141       filter_function = pcrs_filter_response;
2142    }
2143    else if ((csp->content_type & CT_GIF)  &&
2144             (csp->action->flags & ACTION_DEANIMATE))
2145    {
2146       filter_function = gif_deanimate_response;
2147    }
2148
2149    return filter_function;
2150 }
2151
2152
2153 /*********************************************************************
2154  *
2155  * Function    :  remove_chunked_transfer_coding
2156  *
2157  * Description :  In-situ remove the "chunked" transfer coding as defined
2158  *                in rfc2616 from a buffer.
2159  *
2160  * Parameters  :
2161  *          1  :  buffer = Pointer to the text buffer
2162  *          2  :  size =  In: Number of bytes to be processed,
2163  *                       Out: Number of bytes after de-chunking.
2164  *                       (undefined in case of errors)
2165  *
2166  * Returns     :  JB_ERR_OK for success,
2167  *                JB_ERR_PARSE otherwise
2168  *
2169  *********************************************************************/
2170 static jb_err remove_chunked_transfer_coding(char *buffer, size_t *size)
2171 {
2172    size_t newsize = 0;
2173    unsigned int chunksize = 0;
2174    char *from_p, *to_p;
2175
2176    assert(buffer);
2177    from_p = to_p = buffer;
2178
2179    if (sscanf(buffer, "%x", &chunksize) != 1)
2180    {
2181       log_error(LOG_LEVEL_ERROR, "Invalid first chunksize while stripping \"chunked\" transfer coding");
2182       return JB_ERR_PARSE;
2183    }
2184
2185    while (chunksize > 0)
2186    {
2187       if (NULL == (from_p = strstr(from_p, "\r\n")))
2188       {
2189          log_error(LOG_LEVEL_ERROR, "Parse error while stripping \"chunked\" transfer coding");
2190          return JB_ERR_PARSE;
2191       }
2192
2193       if ((newsize += chunksize) >= *size)
2194       {
2195          log_error(LOG_LEVEL_ERROR,
2196             "Chunk size %d exceeds buffer size %d in  \"chunked\" transfer coding",
2197             chunksize, *size);
2198          return JB_ERR_PARSE;
2199       }
2200       from_p += 2;
2201
2202       memmove(to_p, from_p, (size_t) chunksize);
2203       to_p = buffer + newsize;
2204       from_p += chunksize + 2;
2205
2206       if (sscanf(from_p, "%x", &chunksize) != 1)
2207       {
2208          log_error(LOG_LEVEL_INFO, "Invalid \"chunked\" transfer encoding detected and ignored.");
2209          break;
2210       }
2211    }
2212    
2213    /* XXX: Should get its own loglevel. */
2214    log_error(LOG_LEVEL_RE_FILTER, "De-chunking successful. Shrunk from %d to %d", *size, newsize);
2215
2216    *size = newsize;
2217
2218    return JB_ERR_OK;
2219
2220 }
2221
2222
2223 /*********************************************************************
2224  *
2225  * Function    :  prepare_for_filtering
2226  *
2227  * Description :  If necessary, de-chunks and decompresses
2228  *                the content so it can get filterd.
2229  *
2230  * Parameters  :
2231  *          1  :  csp = Current client state (buffers, headers, etc...)
2232  *
2233  * Returns     :  JB_ERR_OK for success,
2234  *                JB_ERR_PARSE otherwise
2235  *
2236  *********************************************************************/
2237 static jb_err prepare_for_filtering(struct client_state *csp)
2238 {
2239    jb_err err = JB_ERR_OK;
2240
2241    /*
2242     * If the body has a "chunked" transfer-encoding,
2243     * get rid of it, adjusting size and iob->eod
2244     */
2245    if (csp->flags & CSP_FLAG_CHUNKED)
2246    {
2247       size_t size = (size_t)(csp->iob->eod - csp->iob->cur);
2248
2249       log_error(LOG_LEVEL_RE_FILTER, "Need to de-chunk first");
2250       err = remove_chunked_transfer_coding(csp->iob->cur, &size);
2251       if (JB_ERR_OK == err)
2252       {
2253          csp->iob->eod = csp->iob->cur + size;
2254          csp->flags |= CSP_FLAG_MODIFIED;
2255       }
2256       else
2257       {
2258          return JB_ERR_PARSE;
2259       }
2260    }
2261
2262 #ifdef FEATURE_ZLIB
2263    /*
2264     * If the body has a supported transfer-encoding,
2265     * decompress it, adjusting size and iob->eod.
2266     */
2267    if (csp->content_type & (CT_GZIP|CT_DEFLATE))
2268    {
2269       if (0 == csp->iob->eod - csp->iob->cur)
2270       {
2271          /* Nothing left after de-chunking. */
2272          return JB_ERR_OK;
2273       }
2274
2275       err = decompress_iob(csp);
2276
2277       if (JB_ERR_OK == err)
2278       {
2279          csp->flags |= CSP_FLAG_MODIFIED;
2280          csp->content_type &= ~CT_TABOO;
2281       }
2282       else
2283       {
2284          /*
2285           * Unset CT_GZIP and CT_DEFLATE to remember not
2286           * to modify the Content-Encoding header later.
2287           */
2288          csp->content_type &= ~CT_GZIP;
2289          csp->content_type &= ~CT_DEFLATE;
2290       }
2291    }
2292 #endif
2293
2294    return err;
2295 }
2296
2297
2298 /*********************************************************************
2299  *
2300  * Function    :  execute_content_filter
2301  *
2302  * Description :  Executes a given content filter.
2303  *
2304  * Parameters  :
2305  *          1  :  csp = Current client state (buffers, headers, etc...)
2306  *          2  :  content_filter = The filter function to execute
2307  *
2308  * Returns     :  Pointer to the modified buffer, or
2309  *                NULL if filtering failed or wasn't necessary.
2310  *
2311  *********************************************************************/
2312 char *execute_content_filter(struct client_state *csp, filter_function_ptr content_filter)
2313 {
2314    if (0 == csp->iob->eod - csp->iob->cur)
2315    {
2316       /*
2317        * No content (probably status code 301, 302 ...),
2318        * no filtering necessary.
2319        */
2320       return NULL;
2321    }
2322
2323    if (JB_ERR_OK != prepare_for_filtering(csp))
2324    {
2325       /*
2326        * failed to de-chunk or decompress.
2327        */
2328       return NULL;
2329    }
2330
2331    if (0 == csp->iob->eod - csp->iob->cur)
2332    {
2333       /*
2334        * Clown alarm: chunked and/or compressed nothing delivered.
2335        */
2336       return NULL;
2337    }
2338
2339    return ((*content_filter)(csp));
2340 }
2341
2342
2343 /*********************************************************************
2344  *
2345  * Function    :  get_url_actions
2346  *
2347  * Description :  Gets the actions for this URL.
2348  *
2349  * Parameters  :
2350  *          1  :  csp = Current client state (buffers, headers, etc...)
2351  *          2  :  http = http_request request for blocked URLs
2352  *
2353  * Returns     :  N/A
2354  *
2355  *********************************************************************/
2356 void get_url_actions(struct client_state *csp, struct http_request *http)
2357 {
2358    struct file_list *fl;
2359    struct url_actions *b;
2360    int i;
2361
2362    init_current_action(csp->action);
2363
2364    for (i = 0; i < MAX_AF_FILES; i++)
2365    {
2366       if (((fl = csp->actions_list[i]) == NULL) || ((b = fl->f) == NULL))
2367       {
2368          return;
2369       }
2370
2371       apply_url_actions(csp->action, http, b);
2372    }
2373
2374    return;
2375 }
2376
2377
2378 /*********************************************************************
2379  *
2380  * Function    :  apply_url_actions
2381  *
2382  * Description :  Applies a list of URL actions.
2383  *
2384  * Parameters  :
2385  *          1  :  action = Destination.
2386  *          2  :  http = Current URL
2387  *          3  :  b = list of URL actions to apply
2388  *
2389  * Returns     :  N/A
2390  *
2391  *********************************************************************/
2392 void apply_url_actions(struct current_action_spec *action,
2393                        struct http_request *http,
2394                        struct url_actions *b)
2395 {
2396    if (b == NULL)
2397    {
2398       /* Should never happen */
2399       return;
2400    }
2401
2402    for (b = b->next; NULL != b; b = b->next)
2403    {
2404       if (url_match(b->url, http))
2405       {
2406          merge_current_action(action, b->action);
2407       }
2408    }
2409 }
2410
2411
2412 /*********************************************************************
2413  *
2414  * Function    :  get_forward_override_settings
2415  *
2416  * Description :  Returns forward settings as specified with the
2417  *                forward-override{} action. forward-override accepts
2418  *                forward lines similar to the one used in the
2419  *                configuration file, but without the URL pattern.
2420  *
2421  *                For example:
2422  *
2423  *                   forward / .
2424  *
2425  *                in the configuration file can be replaced with
2426  *                the action section:
2427  *
2428  *                 {+forward-override{forward .}}
2429  *                 /
2430  *
2431  * Parameters  :
2432  *          1  :  csp = Current client state (buffers, headers, etc...)
2433  *
2434  * Returns     :  Pointer to forwarding structure in case of success.
2435  *                Invalid syntax is fatal.
2436  *
2437  *********************************************************************/
2438 const static struct forward_spec *get_forward_override_settings(struct client_state *csp)
2439 {
2440    const char *forward_override_line = csp->action->string[ACTION_STRING_FORWARD_OVERRIDE];
2441    char forward_settings[BUFFER_SIZE];
2442    char *http_parent = NULL;
2443    /* variable names were chosen for consistency reasons. */
2444    struct forward_spec *fwd = NULL;
2445    int vec_count;
2446    char *vec[3];
2447
2448    assert(csp->action->flags & ACTION_FORWARD_OVERRIDE);
2449    /* Should be enforced by load_one_actions_file() */
2450    assert(strlen(forward_override_line) < sizeof(forward_settings) - 1);
2451
2452    /* Create a copy ssplit can modify */
2453    strlcpy(forward_settings, forward_override_line, sizeof(forward_settings));
2454
2455    if (NULL != csp->fwd)
2456    {
2457       /*
2458        * XXX: Currently necessary to prevent memory
2459        * leaks when the show-url-info cgi page is visited.
2460        */
2461       unload_forward_spec(csp->fwd);
2462    }
2463
2464    /*
2465     * allocate a new forward node, valid only for
2466     * the lifetime of this request. Save its location
2467     * in csp as well, so sweep() can free it later on.
2468     */
2469    fwd = csp->fwd = zalloc(sizeof(*fwd));
2470    if (NULL == fwd)
2471    {
2472       log_error(LOG_LEVEL_FATAL,
2473          "can't allocate memory for forward-override{%s}", forward_override_line);
2474       /* Never get here - LOG_LEVEL_FATAL causes program exit */
2475    }
2476
2477    vec_count = ssplit(forward_settings, " \t", vec, SZ(vec), 1, 1);
2478    if ((vec_count == 2) && !strcasecmp(vec[0], "forward"))
2479    {
2480       fwd->type = SOCKS_NONE;
2481
2482       /* Parse the parent HTTP proxy host:port */
2483       http_parent = vec[1];
2484
2485    }
2486    else if (vec_count == 3)
2487    {
2488       char *socks_proxy = NULL;
2489
2490       if  (!strcasecmp(vec[0], "forward-socks4"))
2491       {
2492          fwd->type = SOCKS_4;
2493          socks_proxy = vec[1];
2494       }
2495       else if (!strcasecmp(vec[0], "forward-socks4a"))
2496       {
2497          fwd->type = SOCKS_4A;
2498          socks_proxy = vec[1];
2499       }
2500       else if (!strcasecmp(vec[0], "forward-socks5"))
2501       {
2502          fwd->type = SOCKS_5;
2503          socks_proxy = vec[1];
2504       }
2505
2506       if (NULL != socks_proxy)
2507       {
2508          /* Parse the SOCKS proxy host[:port] */
2509          fwd->gateway_host = strdup(socks_proxy);
2510
2511          if (NULL != (socks_proxy = strchr(fwd->gateway_host, ':')))
2512          {
2513             *socks_proxy++ = '\0';
2514             fwd->gateway_port = strtol(socks_proxy, NULL, 0);
2515          }
2516
2517          if (fwd->gateway_port <= 0)
2518          {
2519             fwd->gateway_port = 1080;
2520          }
2521
2522          http_parent = vec[2];
2523       }
2524    }
2525
2526    if (NULL == http_parent)
2527    {
2528       log_error(LOG_LEVEL_FATAL,
2529          "Invalid forward-override syntax in: %s", forward_override_line);
2530       /* Never get here - LOG_LEVEL_FATAL causes program exit */
2531    }
2532
2533    /* Parse http forwarding settings */
2534    if (strcmp(http_parent, ".") != 0)
2535    {
2536       fwd->forward_host = strdup(http_parent);
2537
2538       if (NULL != (http_parent = strchr(fwd->forward_host, ':')))
2539       {
2540          *http_parent++ = '\0';
2541          fwd->forward_port = strtol(http_parent, NULL, 0);
2542       }
2543
2544       if (fwd->forward_port <= 0)
2545       {
2546          fwd->forward_port = 8000;
2547       }
2548    }
2549
2550    assert (NULL != fwd);
2551
2552    log_error(LOG_LEVEL_CONNECT,
2553       "Overriding forwarding settings based on \'%s\'", forward_override_line);
2554
2555    return fwd;
2556 }
2557
2558
2559 /*********************************************************************
2560  *
2561  * Function    :  forward_url
2562  *
2563  * Description :  Should we forward this to another proxy?
2564  *
2565  * Parameters  :
2566  *          1  :  csp = Current client state (buffers, headers, etc...)
2567  *          2  :  http = http_request request for current URL
2568  *
2569  * Returns     :  Pointer to forwarding information.
2570  *
2571  *********************************************************************/
2572 const struct forward_spec *forward_url(struct client_state *csp,
2573                                        const struct http_request *http)
2574 {
2575    static const struct forward_spec fwd_default[1] = { FORWARD_SPEC_INITIALIZER };
2576    struct forward_spec *fwd = csp->config->forward;
2577
2578    if (csp->action->flags & ACTION_FORWARD_OVERRIDE)
2579    {
2580       return get_forward_override_settings(csp);
2581    }
2582
2583    if (fwd == NULL)
2584    {
2585       return fwd_default;
2586    }
2587
2588    while (fwd != NULL)
2589    {
2590       if (url_match(fwd->url, http))
2591       {
2592          return fwd;
2593       }
2594       fwd = fwd->next;
2595    }
2596
2597    return fwd_default;
2598 }
2599
2600
2601 /*********************************************************************
2602  *
2603  * Function    :  direct_response 
2604  *
2605  * Description :  Check if Max-Forwards == 0 for an OPTIONS or TRACE
2606  *                request and if so, return a HTTP 501 to the client.
2607  *
2608  *                FIXME: I have a stupid name and I should handle the
2609  *                requests properly. Still, what we do here is rfc-
2610  *                compliant, whereas ignoring or forwarding are not.
2611  *
2612  * Parameters  :  
2613  *          1  :  csp = Current client state (buffers, headers, etc...)
2614  *
2615  * Returns     :  http_response if , NULL if nonmatch or handler fail
2616  *
2617  *********************************************************************/
2618 struct http_response *direct_response(struct client_state *csp)
2619 {
2620    struct http_response *rsp;
2621    struct list_entry *p;
2622
2623    if ((0 == strcmpic(csp->http->gpc, "trace"))
2624       || (0 == strcmpic(csp->http->gpc, "options")))
2625    {
2626       for (p = csp->headers->first; (p != NULL) ; p = p->next)
2627       {
2628          if (!strncmpic("Max-Forwards:", p->str, 13))
2629          {
2630             unsigned int max_forwards;
2631
2632             /*
2633              * If it's a Max-Forwards value of zero,
2634              * we have to intercept the request.
2635              */
2636             if (1 == sscanf(p->str+12, ": %u", &max_forwards) && max_forwards == 0)
2637             {
2638                /*
2639                 * FIXME: We could handle at least TRACE here,
2640                 * but that would require a verbatim copy of
2641                 * the request which we don't have anymore
2642                 */
2643                 log_error(LOG_LEVEL_HEADER,
2644                   "Detected header \'%s\' in OPTIONS or TRACE request. Returning 501.",
2645                   p->str);
2646
2647                /* Get mem for response or fail*/
2648                if (NULL == (rsp = alloc_http_response()))
2649                {
2650                   return cgi_error_memory();
2651                }
2652             
2653                if (NULL == (rsp->status = strdup("501 Not Implemented")))
2654                {
2655                   free_http_response(rsp);
2656                   return cgi_error_memory();
2657                }
2658
2659                rsp->is_static = 1;
2660                rsp->reason = RSP_REASON_UNSUPPORTED;
2661
2662                return(finish_http_response(csp, rsp));
2663             }
2664          }
2665       }
2666    }
2667    return NULL;
2668 }
2669
2670
2671 /*********************************************************************
2672  *
2673  * Function    :  content_filters_enabled
2674  *
2675  * Description :  Checks whether there are any content filters
2676  *                enabled for the current request.
2677  *
2678  * Parameters  :  
2679  *          1  :  action = Action spec to check.
2680  *
2681  * Returns     :  TRUE for yes, FALSE otherwise
2682  *
2683  *********************************************************************/
2684 int content_filters_enabled(const struct current_action_spec *action)
2685 {
2686    return ((action->flags & ACTION_DEANIMATE) ||
2687       !list_is_empty(action->multi[ACTION_MULTI_FILTER]));
2688 }
2689
2690 /*
2691   Local Variables:
2692   tab-width: 3
2693   end:
2694 */