-
Notifications
You must be signed in to change notification settings - Fork 9
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #42 from Moesif/add-gzip-support
Add: Support for gzip body
- Loading branch information
Showing
7 changed files
with
365 additions
and
312 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,95 +1,95 @@ | ||
| import re | ||
|
|
||
|
|
||
| def is_ip(value): | ||
| if not value is None: | ||
| ipv4 = r"^(?:(?:\d|[1-9]\d|1\d{2}|2[0-4]\d|25[0-5])\.){3}(?:\d|[1-9]\d|1\d{2}|2[0-4]\d|25[0-5])$" | ||
| ipv6 = r"^((?=.*::)(?!.*::.+::)(::)?([\dA-F]{1,4}:(:|\b)|){5}|([\dA-F]{1,4}:){6})((([\dA-F]{1,4}((?!\3)::|:\b|$))|(?!\2\3)){2}|(((2[0-4]|1\d|[1-9])?\d|25[0-5])\.?\b){4})$/i" | ||
| return re.match(ipv4, value) or re.match(ipv6, value) | ||
|
|
||
|
|
||
| def get_client_ip_from_x_forwarded_for(value): | ||
| try: | ||
|
|
||
| if not value or value is None: | ||
| return None | ||
|
|
||
| if not isinstance(value, str): | ||
| print("Expected a string, got -" + str(type(value))) | ||
| else: | ||
| # x-forwarded-for may return multiple IP addresses in the format: | ||
| # "client IP, proxy 1 IP, proxy 2 IP" | ||
| # Therefore, the right-most IP address is the IP address of the most recent proxy | ||
| # and the left-most IP address is the IP address of the originating client. | ||
| # source: http://docs.aws.amazon.com/elasticloadbalancing/latest/classic/x-forwarded-headers.html | ||
| # Azure Web App's also adds a port for some reason, so we'll only use the first part (the IP) | ||
| forwardedIps = [] | ||
|
|
||
| for e in value.split(','): | ||
| ip = e.strip() | ||
| if ':' in ip: | ||
| splitted = ip.split(':') | ||
| if (len(splitted) == 2): | ||
| forwardedIps.append(splitted[0]) | ||
| forwardedIps.append(ip) | ||
|
|
||
| # Sometimes IP addresses in this header can be 'unknown' (http://stackoverflow.com/a/11285650). | ||
| # Therefore taking the left-most IP address that is not unknown | ||
| # A Squid configuration directive can also set the value to "unknown" (http://www.squid-cache.org/Doc/config/forwarded_for/) | ||
| return next(item for item in forwardedIps if is_ip(item)) | ||
| except StopIteration: | ||
| return value.encode('utf-8') | ||
|
|
||
|
|
||
| def get_client_ip(request): | ||
| try: | ||
| # Standard headers used by Amazon EC2, Heroku, and others. | ||
| if 'HTTP_X_CLIENT_IP' in request.META: | ||
| if is_ip(request.META.get('HTTP_X_CLIENT_IP')): | ||
| return request.META.get('HTTP_X_CLIENT_IP') | ||
|
|
||
| # Load-balancers (AWS ELB) or proxies. | ||
| if 'HTTP_X_FORWARDED_FOR' in request.META: | ||
| x_forwarded_for = get_client_ip_from_x_forwarded_for(request.META.get('HTTP_X_FORWARDED_FOR')) | ||
| if is_ip(x_forwarded_for): | ||
| return x_forwarded_for | ||
|
|
||
| # Cloudflare. | ||
| # @see https://support.cloudflare.com/hc/en-us/articles/200170986-How-does-Cloudflare-handle-HTTP-Request-headers- | ||
| # CF-Connecting-IP - applied to every request to the origin. | ||
| if 'HTTP_CF_CONNECTING_IP' in request.META: | ||
| if is_ip(request.META.get('HTTP_CF_CONNECTING_IP')): | ||
| return request.META.get('HTTP_CF_CONNECTING_IP') | ||
|
|
||
| # Akamai and Cloudflare: True-Client-IP. | ||
| if 'HTTP_TRUE_CLIENT_IP' in request.META: | ||
| if is_ip(request.META.get('HTTP_TRUE_CLIENT_IP')): | ||
| return request.META.get('HTTP_TRUE_CLIENT_IP') | ||
|
|
||
| # Default nginx proxy/fcgi; alternative to x-forwarded-for, used by some proxies. | ||
| if 'HTTP_X_REAL_IP' in request.META: | ||
| if is_ip(request.META.get('HTTP_X_REAL_IP')): | ||
| return request.META.get('HTTP_X_REAL_IP') | ||
|
|
||
| # (Rackspace LB and Riverbed's Stingray) | ||
| # http://www.rackspace.com/knowledge_center/article/controlling-access-to-linux-cloud-sites-based-on-the-client-ip-address | ||
| # https://splash.riverbed.com/docs/DOC-1926 | ||
| if 'HTTP_X_CLUSTER_CLIENT_IP' in request.META: | ||
| if is_ip(request.META.get('HTTP_X_CLUSTER_CLIENT_IP')): | ||
| return request.META.get('HTTP_X_CLUSTER_CLIENT_IP') | ||
|
|
||
| if 'HTTP_X_FORWARDED' in request.META: | ||
| if is_ip(request.META.get('HTTP_X_FORWARDED')): | ||
| return request.META.get('HTTP_X_FORWARDED') | ||
|
|
||
| if 'HTTP_FORWARDED_FOR' in request.META: | ||
| if is_ip(request.META.get('HTTP_FORWARDED_FOR')): | ||
| return request.META.get('HTTP_FORWARDED_FOR') | ||
|
|
||
| if 'HTTP_FORWARDED' in request.META: | ||
| if is_ip(request.META.get('HTTP_FORWARDED')): | ||
| return request.META.get('HTTP_FORWARDED') | ||
|
|
||
| return request.META.get('REMOTE_ADDR') | ||
| except: | ||
| return request.META.get('REMOTE_ADDR') | ||
| class ClientIp: | ||
|
|
||
| def is_ip(self, value): | ||
| if not value is None: | ||
| ipv4 = r"^(?:(?:\d|[1-9]\d|1\d{2}|2[0-4]\d|25[0-5])\.){3}(?:\d|[1-9]\d|1\d{2}|2[0-4]\d|25[0-5])$" | ||
| ipv6 = r"^((?=.*::)(?!.*::.+::)(::)?([\dA-F]{1,4}:(:|\b)|){5}|([\dA-F]{1,4}:){6})((([\dA-F]{1,4}((?!\3)::|:\b|$))|(?!\2\3)){2}|(((2[0-4]|1\d|[1-9])?\d|25[0-5])\.?\b){4})$/i" | ||
| return re.match(ipv4, value) or re.match(ipv6, value) | ||
|
|
||
| def get_client_ip_from_x_forwarded_for(self, value): | ||
| try: | ||
|
|
||
| if not value or value is None: | ||
| return None | ||
|
|
||
| if not isinstance(value, str): | ||
| print("Expected a string, got -" + str(type(value))) | ||
| else: | ||
| # x-forwarded-for may return multiple IP addresses in the format: | ||
| # "client IP, proxy 1 IP, proxy 2 IP" | ||
| # Therefore, the right-most IP address is the IP address of the most recent proxy | ||
| # and the left-most IP address is the IP address of the originating client. | ||
| # source: http://docs.aws.amazon.com/elasticloadbalancing/latest/classic/x-forwarded-headers.html | ||
| # Azure Web App's also adds a port for some reason, so we'll only use the first part (the IP) | ||
| forwardedIps = [] | ||
|
|
||
| for e in value.split(','): | ||
| ip = e.strip() | ||
| if ':' in ip: | ||
| splitted = ip.split(':') | ||
| if (len(splitted) == 2): | ||
| forwardedIps.append(splitted[0]) | ||
| forwardedIps.append(ip) | ||
|
|
||
| # Sometimes IP addresses in this header can be 'unknown' (http://stackoverflow.com/a/11285650). | ||
| # Therefore taking the left-most IP address that is not unknown | ||
| # A Squid configuration directive can also set the value to "unknown" (http://www.squid-cache.org/Doc/config/forwarded_for/) | ||
| return next(item for item in forwardedIps if is_ip(item)) | ||
| except StopIteration: | ||
| return value.encode('utf-8') | ||
|
|
||
| def get_client_ip(self, request): | ||
| try: | ||
| # Standard headers used by Amazon EC2, Heroku, and others. | ||
| if 'HTTP_X_CLIENT_IP' in request.META: | ||
| if is_ip(request.META.get('HTTP_X_CLIENT_IP')): | ||
| return request.META.get('HTTP_X_CLIENT_IP') | ||
|
|
||
| # Load-balancers (AWS ELB) or proxies. | ||
| if 'HTTP_X_FORWARDED_FOR' in request.META: | ||
| x_forwarded_for = get_client_ip_from_x_forwarded_for(request.META.get('HTTP_X_FORWARDED_FOR')) | ||
| if is_ip(x_forwarded_for): | ||
| return x_forwarded_for | ||
|
|
||
| # Cloudflare. | ||
| # @see https://support.cloudflare.com/hc/en-us/articles/200170986-How-does-Cloudflare-handle-HTTP-Request-headers- | ||
| # CF-Connecting-IP - applied to every request to the origin. | ||
| if 'HTTP_CF_CONNECTING_IP' in request.META: | ||
| if is_ip(request.META.get('HTTP_CF_CONNECTING_IP')): | ||
| return request.META.get('HTTP_CF_CONNECTING_IP') | ||
|
|
||
| # Akamai and Cloudflare: True-Client-IP. | ||
| if 'HTTP_TRUE_CLIENT_IP' in request.META: | ||
| if is_ip(request.META.get('HTTP_TRUE_CLIENT_IP')): | ||
| return request.META.get('HTTP_TRUE_CLIENT_IP') | ||
|
|
||
| # Default nginx proxy/fcgi; alternative to x-forwarded-for, used by some proxies. | ||
| if 'HTTP_X_REAL_IP' in request.META: | ||
| if is_ip(request.META.get('HTTP_X_REAL_IP')): | ||
| return request.META.get('HTTP_X_REAL_IP') | ||
|
|
||
| # (Rackspace LB and Riverbed's Stingray) | ||
| # http://www.rackspace.com/knowledge_center/article/controlling-access-to-linux-cloud-sites-based-on-the-client-ip-address | ||
| # https://splash.riverbed.com/docs/DOC-1926 | ||
| if 'HTTP_X_CLUSTER_CLIENT_IP' in request.META: | ||
| if is_ip(request.META.get('HTTP_X_CLUSTER_CLIENT_IP')): | ||
| return request.META.get('HTTP_X_CLUSTER_CLIENT_IP') | ||
|
|
||
| if 'HTTP_X_FORWARDED' in request.META: | ||
| if is_ip(request.META.get('HTTP_X_FORWARDED')): | ||
| return request.META.get('HTTP_X_FORWARDED') | ||
|
|
||
| if 'HTTP_FORWARDED_FOR' in request.META: | ||
| if is_ip(request.META.get('HTTP_FORWARDED_FOR')): | ||
| return request.META.get('HTTP_FORWARDED_FOR') | ||
|
|
||
| if 'HTTP_FORWARDED' in request.META: | ||
| if is_ip(request.META.get('HTTP_FORWARDED')): | ||
| return request.META.get('HTTP_FORWARDED') | ||
|
|
||
| return request.META.get('REMOTE_ADDR') | ||
| except: | ||
| return request.META.get('REMOTE_ADDR') |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.