recreate Content-Type request header for multipart/form-data requests

etc/tempesta_fw.conf

@@ -656,8 +656,8 @@
 # from HTTP tables (see 'http_chain' directive).
 #
 # <directive> is one of 'location', 'proxy_pass', 'cache_bypass', 'cache_fulfill',
-# 'nonidempotent' or 'hdr_add' directives (see the corresponding directives'
-# description).
+# 'nonidempotent', 'hdr_add' or 'http_post_validate' directives (see the
+# corresponding directives' description).
 #
 # Example:
 #   vhost app {
@@ -693,7 +693,7 @@
 # <OP> is a match operator, one of 'eq', 'prefix', 'suffix', or '*'.
 # <string> is a verbatim string matched against URL in a request.
 # <directive> is one of 'proxy_pass', 'cache_bypass', 'cache_fulfill',
-# 'nonidempotent', 'hdr_add' or Frang limit directives.
+# 'nonidempotent', 'hdr_add', 'http_post_validate' or Frang limit directives.
 #
 # Default:
 #   None.
@@ -894,6 +894,20 @@
 #                /etc/ddos_redirect.html
 #
 
+# TAG: http_post_validate
+#
+# Validate POST requests.
+# Parses Content-Type header field, and rewrites it for multipart/form-data type
+# of payload, to prevent evasion attacks. All parameters other than "boundary"
+# are removed.
+#
+# Syntax:
+#   http_post_validate
+#
+# Default:
+#   Validation is disabled.
+#
+
 #
 # Frang configuration.
 #

tempesta_fw/http.c

@@ -2114,6 +2114,58 @@ tfw_http_set_loc_hdrs(TfwHttpMsg *hm, TfwHttpReq *req)
 	return 0;
 }
 
+/**
+ * Compose Content-Type header field from scratch.
+ *
+ * A POST-request with multipart/form-data payload need a boundary, which is
+ * supplied by a parameter in the Content-Type header field. There are strict
+ * instructions on how to parse that parameter (see RFC 7231 and RFC 7230), but
+ * application servers parse it in a non-standard way. For example, PHP checks
+ * whenever parameter name contains substring "boundary", and thus happily takes
+ * "xxboundaryxx". Such quirks are used to bypass web application firewalls.
+ *
+ * To make evasions harder, this function composes value of the Content-Type
+ * field from the parsed data. All parameters other than "boundary" are dropped.
+ */
+static int
+tfw_http_recreate_content_type_multipart_hdr(TfwHttpReq *req)
+{
+	TfwStr replacement = {
+		.ptr = (TfwStr []) {
+			TFW_STR_FROM("Content-Type"),
+			TFW_STR_FROM(": "),
+			TFW_STR_FROM("multipart/form-data; boundary="),
+			req->multipart_boundary_raw,
+		},
+		.flags = 4 << TFW_STR_CN_SHIFT,
+	};
+	TfwStr *c = replacement.ptr;
+
+	BUG_ON(!TFW_STR_PLAIN(&req->multipart_boundary_raw));
+	replacement.len = c[0].len + c[1].len + c[2].len + c[3].len;
+	return tfw_http_msg_hdr_xfrm_str((TfwHttpMsg *)req, &replacement,
+					 TFW_HTTP_HDR_CONTENT_TYPE, false);
+}
+
+static bool
+tfw_http_should_validate_post_req(TfwHttpReq *req)
+{
+	if (req->location && req->location->validate_post_req)
+		return true;
+
+	if (!req->vhost)
+		return false;
+
+	if (req->vhost->loc_dflt && req->vhost->loc_dflt->validate_post_req)
+		return true;
+
+	if (req->vhost->vhost_dflt &&
+	    req->vhost->vhost_dflt->loc_dflt->validate_post_req)
+		return true;
+
+	return false;
+}
+
 /**
  * Adjust the request before proxying it to real server.
  */
@@ -2143,6 +2195,15 @@ tfw_http_adjust_req(TfwHttpReq *req)
 	if (r < 0)
 		return r;
 
+	if (req->method == TFW_HTTP_METH_POST &&
+	    test_bit(TFW_HTTP_B_CT_MULTIPART, req->flags) &&
+	    tfw_http_should_validate_post_req(req))
+	{
+		r = tfw_http_recreate_content_type_multipart_hdr(req);
+		if (r)
+			return r;
+	}
+
 	return tfw_http_set_hdr_connection(hm, BIT(TFW_HTTP_B_CONN_KA));
 }
 

tempesta_fw/http.h

@@ -229,6 +229,10 @@ enum {
 	TFW_HTTP_B_CONN_EXTRA,
 	/* Chunked transfer encoding. */
 	TFW_HTTP_B_CHUNKED,
+	/* Media type is multipart/form-data. */
+	TFW_HTTP_B_CT_MULTIPART,
+	/* Multipart/form-data request have boundary parameter. */
+	TFW_HTTP_B_CT_MULTIPART_HAS_BOUNDARY,
 	/* Singular header presents more than once. */
 	TFW_HTTP_B_FIELD_DUPENTRY,
 
@@ -369,6 +373,8 @@ typedef struct {
  * @host	- host in URI, may differ from Host header;
  * @uri_path	- path + query + fragment from URI (RFC3986.3);
  * @mark	- special hash mark for redirects handling in session module;
+ * @multipart_boundary_raw - multipart boundary as is, maybe with escaped chars;
+ * @multipart_boundary - decoded multipart boundary;
  * @fwd_list	- member in the queue of forwarded/backlogged requests;
  * @nip_list	- member in the queue of non-idempotent requests;
  * @method	- HTTP request method, one of GET/PORT/HEAD/etc;
@@ -394,6 +400,8 @@ struct tfw_http_req_t {
 	TfwStr			host;
 	TfwStr			uri_path;
 	TfwStr			mark;
+	TfwStr			multipart_boundary_raw;
+	TfwStr			multipart_boundary;
 	struct list_head	fwd_list;
 	struct list_head	nip_list;
 	unsigned char		method;