հj@ddlmZmZddlmZmZmZdZGddZy)) LengthReaderBody)InvalidUWSGIHeaderUnsupportedModifierForbiddenUWSGIRequesticHeZdZdZd dZdZdZdZdZdZ dZ d Z d Z y ) UWSGIRequestauWSGI protocol request parser. The uWSGI protocol uses a 4-byte binary header: - Byte 0: modifier1 (packet type, 0 = WSGI request) - Bytes 1-2: datasize (16-bit little-endian, size of vars block) - Byte 3: modifier2 (additional flags, typically 0) After the header: 1. Vars block (datasize bytes): Key-value pairs containing WSGI environ - Each pair: 2-byte key_size (LE) + key + 2-byte val_size (LE) + value 2. Request body (determined by CONTENT_LENGTH in vars) c||_||_||_||_||_d|_d|_d|_d|_d|_ d|_ g|_ g|_ d|_ |jrdnd|_d|_i|_d|_d|_d|_d|_|j-|j/|j}|jj1||j3y)N)r httpshttpFr)cfgunreader peer_addr remote_addr req_numbermethoduripathqueryfragmentversionheaderstrailersbodyis_sslscheme must_close uwsgi_vars modifier1 modifier2proxy_protocol_info_expected_100_continue_check_allowed_ipparseunreadset_body_reader)selfrrrrunuseds L/var/www/mission/venv/lib/python3.12/site-packages/gunicorn/uwsgi/message.py__init__zUWSGIRequest.__init__s  "$$        !$g $( ',#  DMM* V$ ct|jdddg}t|jtsyd|vry|jd|vrt |jdy)z(Verify source IP is in the allowed list.uwsgi_allow_ipsz 127.0.0.1z::1N*r)getattrr isinstancertupler)r) allow_ipss r+r%zUWSGIRequest._check_allowed_ipFsdDHH&7+u9MN $..%0  )   >>! I -'q(9: : .r-cd|_y)z1Force the connection to close after this request.TN)r)r)s r+ force_closezUWSGIRequest.force_closeUs r-c|j|d}t|dkr td|d|_tj |ddd}|d|_|jdk7rt|j|dkDr<|j||}t||kr td|j||jy) z)Parse uWSGI packet header and vars block.zincomplete headerrr littlezincomplete vars blockr-) _read_exactlenrr!int from_bytesr"r _parse_vars_extract_request_info)r)rheaderdatasize vars_datas r+r&zUWSGIRequest.parseYs!!(A. v;?$%89 9>>&1+x8 >>Q %dnn5 5 a<((8decoder )r)datapos var_countkey_sizekeyval_sizevalues r+r?zUWSGIRequest._parse_varsxsX  CIoN*()=>>QwT"()=>>~~d3sQw&7BH 1HCX~D )(99s3>*11)E 8OC#(DOOC NI;CIor-cJ|jjdd|_|jjdd|_|jjdd|_|jr!|jd|j|_n|j|_|jjddj d vrd |_n"d |jvr|jd |_|jjD]\}}|jd r3|d djdd}|jj||fJ|dk(r|jjd|fm|dk(ss|jjd|fy)aExtract HTTP request info from uWSGI vars. Header Mapping (CGI/WSGI to HTTP): The uWSGI protocol passes HTTP headers using CGI-style environment variable naming. This method converts them back to HTTP header format: - HTTP_* vars: Strip 'HTTP_' prefix, replace '_' with '-' Example: HTTP_X_FORWARDED_FOR -> X-FORWARDED-FOR Example: HTTP_ACCEPT_ENCODING -> ACCEPT-ENCODING - CONTENT_TYPE: Mapped directly to CONTENT-TYPE header (CGI spec excludes HTTP_ prefix for this header) - CONTENT_LENGTH: Mapped directly to CONTENT-LENGTH header (CGI spec excludes HTTP_ prefix for this header) Note: The underscore-to-hyphen conversion is lossy. Headers that originally contained underscores (e.g., X_Custom_Header) cannot be distinguished from hyphenated headers (X-Custom-Header) after passing through nginx/uWSGI. This is a CGI/WSGI specification limitation, not specific to this implementation. REQUEST_METHODGET PATH_INFO/ QUERY_STRINGr ?HTTPS)on1truer zwsgi.url_schemeHTTP_N_- CONTENT_TYPEz CONTENT-TYPECONTENT_LENGTHzCONTENT-LENGTH) r getrrrrlowerritems startswithreplacerappend)r)rOrQ header_names r+r@z"UWSGIRequest._extract_request_infos[2oo))*:EB OO'' S9 __((<  ::"&))TZZ8DHyyDH ??  w + 1 1 37J J!DK $// 1//*; ?r-cd}d|jvr# tt|jdd}t t |j ||_y#t$rd}Y2wxYw)z/Set up the body reader based on CONTENT_LENGTH.rrbN)r maxr= ValueErrorrrrr)r)content_lengths r+r(zUWSGIRequest.set_body_readersd t . #!$S9I)J%KQ!Odmm^DE  #!" #s"A A'&A'c|jry|jjddj}|dk(ry|dk(ryy)z@Determine if the connection should be closed after this request.THTTP_CONNECTIONr closez keep-aliveF)rr rcrd)r) connections r+ should_closezUWSGIRequest.should_closesI ??__(():B?EEG   < 'r-N)r ) __name__ __module__ __qualname____doc__r,r%r6r&r;r?r@r(rrr-r+r r s8 %N ;6#%N5?n F r-r N) gunicorn.http.bodyrrgunicorn.uwsgi.errorsrrrrIr rwr-r+rzs' 2__r-