h+ddlZddlZddlZddlmZmZmZmZddlZddl m Z ddl Z ddl m Z ddlmZddlmZmZmZmZddlmZdd lmZdd lmZerdd lmZneZGd d e ZGddeZy)N) TYPE_CHECKINGAnyOptionalUnion) BaseModel)verbose_logger)Logging)AsyncHTTPHandler HTTPHandler_get_httpx_clientget_async_httpx_client) ImageResponse) BaseAWSLLM) BedrockError)AWSPreparedRequestc:eZdZUdZeed<eed<eed<eed<y)BedrockImagePreparedRequestzV Internal/Helper class for preparing the request for bedrock image generation endpoint_urlpreppedbodydataN) __name__ __module__ __qualname____doc__str__annotations__rbytesdictd/var/www/Befach/backend/env/lib/python3.12/site-packages/litellm/llms/bedrock/image/image_handler.pyrrs  K Jr"rcveZdZdZ ddedededededee e e jfd e d eed eed ee eefd eefdZ ddedee e e jfdedededed eedefdZdeded eed eededed eedefdZdedededefdZdedededede j*dedefdZy)BedrockImageGenerationz* Bedrock Image Generation handler Nmodelpromptmodel_responseoptional_params logging_objtimeoutaimg_generationapi_base extra_headersclientapi_keyc |j|||| ||| } |dur1|j| |||||| t| tr| SdS| t| ts t } | j | j| jj| j} | j|j'||||| | j(}|S#tj$r<}|jj}t!||jj"d}~wtj$$rt!ddwxYw) N)r&r)r-r.r*r'r0T)prepared_requestr+r&r*r'r(r/urlheadersr status_codemessageTimeout error occurred.)r(r&r*r'responser)_prepare_requestasync_image_generation isinstancer r r postrrr5rraise_for_statushttpxHTTPStatusErrorr;r7rtextTimeoutException+_transform_response_dict_to_openai_responser)selfr&r'r(r)r*r+r,r-r.r/r0r2r;err error_codes r#image_generationz'BedrockImageGeneration.image_generation-s 00+'#1  d "..!1'-)jAQ.R/  /   >FK!@&(F S{{'7'D'DN^NfNfNnNnvFvKvK{LH  % % 'II)#!&& J $$ R11J:s||?P?PQ Q%% S38QR R Ss+A CE-7D$$$Er2returnc6K|xs'ttjjd|i} |j |j |j j|jd{} | j|j#|||| |j$|}|S77#tj$r<} | jj} t| | jjd} ~ wtj $rtddwxYww) z Asynchronous handler for bedrock image generation Awaits the response from the bedrock image generation endpoint r+) llm_providerparamsr3Nr6r9r:)r&r*r'r;rr()r litellm LlmProvidersBEDROCKr?rrr5rr@rArBr;r7rrCrDrEr) rFr2r+r&r*r'r(r/ async_clientr;rGrHs r#r=z-BedrockImageGeneration.async_image_generationis" !7 --55w'"  S)..3C3P3PZjZrZrZzZzBRBWBW.XXH  % % 'II#!&&) J #X$$ R11J:s||?P?PQ Q%% S38QR R Ss:,D?B(.B&/B(#D&B((D;7C22$DDc |j||}|} |j||j|j\} } | d| d} |j |||} t j | jd} ddi}|ddi|}|j|j|j|| | ||}|j|d | | |jd  t| || | S) a Prepare the request body, headers, and endpoint URL for the Bedrock Image Generation API Args: model (str): The model to use for the image generation optional_params (dict): The optional parameters for the image generation api_base (Optional[str]): The base URL for the Bedrock API extra_headers (Optional[dict]): The extra headers to include in the request logging_obj (LitellmLogging): The logging object to use for logging prompt (str): The prompt to use for the image generation Returns: BedrockImagePreparedRequest: The prepared request object The BedrockImagePreparedRequest contains: endpoint_url (str): The endpoint URL for the Bedrock Image Generation API prepped (httpx.Request): The prepared request object body (bytes): The request body )r-aws_bedrock_runtime_endpointaws_region_namez/model/z/invoke)r&r'r)zutf-8z Content-Typezapplication/json) credentialsrTr.rrr5r0)complete_input_dictr-r5)inputr0additional_args)rrrr) *_get_boto_credentials_from_optional_paramsget_runtime_endpointrSrT_get_request_bodyjsondumpsencodeget_request_headersrUpre_callr5r)rFr&r)r-r.r*r'r0boto3_credentials_infomodelId_proxy_endpoint_urlrrr5rs r#r<z'BedrockImageGeneration._prepare_requests=8"&!P!P U"   $ 9 9)?)\)\2BB!:!   !3377)7K%%&  zz$&&w/!#56  $%'9K]KG**.::2BB'++  '+."??  ++   r"ct|jdd}tj|}|jddi}|dk(rtj j |r,tj j||}t|S|jtjd}tjj}|jD]\} } | |vs | || <d|d d gi|}|S|d k(r*ttjj|| St!d d|d)z Get the request body for the Bedrock Image Generation API Checks the model/provider and transforms the request body accordingly Returns: dict: The request body to use for the Bedrock Image Generation API .ruserN stability)r'r) text_prompts)rCweightamazon)rCr)izUnsupported model=z , passed inr6)splitcopydeepcopypoprNAmazonStability3Config_is_stability_3_modeltransform_request_bodyr replaceoslinesepAmazonStabilityConfig get_configitemsAmazonNovaCanvasConfigr) rFr&r'r)providerinference_paramsr request_bodyconfigkvs r#r\z(BedrockImageGeneration._get_request_bodysS;;s#A&==9 D  { "--CCEJ&==TT!? U  L)) C8 66AAC"LLNDAq!11./(+ + #f%B$C&  !..EEF  +=eWK)P r"r;rc|!|j|d|jd|itjd|j|j }| t dt jj|rt jn?t jj|rt jnt j}|j|||S)zX Transforms the Image Generation response from Bedrock to OpenAI format rVrW)rXr0original_responserYzraw model_response: %sz)Error in response object format, got None)r&)r( response_dict) post_callrCrdebugr] ValueErrorrNrsrtr|_is_nova_modelry*transform_response_dict_to_openai_response) rFr(r&r*r'r;rr config_classs r#rEzBBedrockImageGeneration._transform_response_dict_to_openai_responses  "  ! !"*--!6 = "  5x}}E   HI I--CC%CP  * *11@@u@M..22  ??)' @ r")FNNNN)N)rrrrrrr LitellmLoggingrrfloatrATimeoutboolr r rIrr=r<r\ResponserEr!r"r#r%r%(s !&"&(,AE!%:::& :  : $ :%u}} 456::3-: ~:{,<<=>:#:H.2&5&%u}} 456& & $ &  &&&)*& &PK K K 3- K  ~ K $ K K #K  %K Z111 1  1f(%(($ (  ( .. (( (r"r%) rpr]rwtypingrrrrrApydanticrrNlitellm._loggingr*litellm.litellm_core_utils.litellm_loggingr r&litellm.llms.custom_httpx.http_handlerr r r r litellm.types.utilsr base_aws_llmr common_utilsrbotocore.awsrequestrrr%r!r"r#rs^ 66 +P .%'6)QZQr"