
    ?g	                         d dl Z ddlmZ d Z e j                  eej
                  d      Z e j                  eej                  ddi      Zy)    N   )	ws_clientc                    |r|j                         D ]
  \  }}|||<    |j                  j                  }	 |j                  }|j                  }	|j                  dd      }
	 t        j                  | ||
      |_         ||i |}|
rD|j                  dd      r2|dd j                  d      j                  d	      j                  d      }||	|_        S # t        $ r |j
                  }Y w xY w# |	|_        w xY w)
zOverride the ApiClient.request method with an alternative websocket based
    method and call the supplied Kubernetes API method with that in place.binaryF)r   _preload_contentT   latin1unicode_escape)items__self__
api_clientconfigurationAttributeErrorconfigrequestpop	functoolspartialgetencodedecode)websocket_requestforce_kwargs
api_methodargskwargskwargvaluer   r   prev_requestr   outs               M/var/www/openai/venv/lib/python3.12/site-packages/kubernetes/stream/stream.py_websocket_requestr#      s    (..0LE5!F5M 1$$//J*"00 %%LZZ%(F*&../@-X^_
$)&) fjj!3T:a)""8,334DELLXVC)
!  *"))*  *
s   C "A,C1 C.-C.1	C:r   F)	r    r   r#   r   websocket_callstreamportforward_callportforward     r"   <module>r+      sU     *: 
		-y/G/G	Ni 2I4N4NQcdiPjkr*   