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