
    dh                        S SK Jr  S SKJrJrJrJrJrJrJ	r	  S SK
Jr  S SKJr  S SKJrJrJrJrJrJr  S SKJrJrJr  S SKJr  SS jrSS	 jr " S
 S\\5      rg)    )annotations)AnyDictIteratorListMappingOptionalcast)CallbackManagerForLLMRun)BaseChatModel)	AIMessageAIMessageChunkBaseMessageFunctionMessageHumanMessageSystemMessage)ChatGenerationChatGenerationChunk
ChatResult)VolcEngineMaasBasec                N   [        U [        5      (       a  SU R                  S.nU$ [        U [        5      (       a  SU R                  S.nU$ [        U [        5      (       a  SU R                  S.nU$ [        U [
        5      (       a  SU R                  S.nU$ [        SU  35      e)Nsystem)rolecontentuser	assistantfunctionzGot unknown type )
isinstancer   r   r   r   r   
ValueError)messagemessage_dicts     g/var/www/html/shao/venv/lib/python3.13/site-packages/langchain_community/chat_models/volcengine_maas.py_convert_message_to_dictr#      s    '=)) (W__E  
G\	*	* &7??C  
GY	'	' +H
 	 
G_	-	- *wG  ,WI677    c                x    U R                  S0 5      R                  S0 5      R                  SS5      n[        US9$ )zConvert a dict to a message.choicer    r    r   )getr   )_dictr   s     r"   convert_dict_to_messager+   "   s9     ii"%)))R8<<YKGW%%r$   c                     ^  \ rS rSrSr\S
S j5       r\SS j5       r\SU 4S jj5       r	      SS jr
  S         SS jjr  S         SS jjrS	rU =r$ )VolcEngineMaasChat)   a  Volc Engine Maas hosts a plethora of models.

You can utilize these models through this class.

To use, you should have the ``volcengine`` python package installed.
and set access key and secret key by environment variable or direct pass those
to this class.
access key, secret key are required parameters which you could get help
https://www.volcengine.com/docs/6291/65568

In order to use them, it is necessary to install the 'volcengine' Python package.
The access key and secret key must be set either via environment variables or
passed directly to this class.
access key and secret key are mandatory parameters for which assistance can be
sought at https://www.volcengine.com/docs/6291/65568.

The two methods are as follows:
* Environment Variable
Set the environment variables 'VOLC_ACCESSKEY' and 'VOLC_SECRETKEY' with your
access key and secret key.

* Pass Directly to Class
Example:
    .. code-block:: python

        from langchain_community.llms import VolcEngineMaasLLM
        model = VolcEngineMaasChat(model="skylark-lite-public",
                                      volc_engine_maas_ak="your_ak",
                                      volc_engine_maas_sk="your_sk")
c                    g)zReturn type of chat model.zvolc-engine-maas-chat )selfs    r"   	_llm_typeVolcEngineMaasChat._llm_typeI   s     'r$   c                    g)z9Return whether this model can be serialized by Langchain.Fr0   )clss    r"   is_lc_serializable%VolcEngineMaasChat.is_lc_serializableN   s     r$   c                N   > 0 U R                   U R                  S.E[        TU ]  E$ )N)endpointmodel)r9   r:   super_identifying_params)r1   	__class__s    r"   r<   &VolcEngineMaasChat._identifying_paramsS   s/    
==4::>
g)
 	
r$   c                    SSU R                   00nU R                  b  U R                  US   S'   0 UEU Vs/ sH  n[        U5      PM     sn0 U R                  EUES.E$ s  snf )Nr:   nameversion)messages
parameters)r:   model_versionr#   _default_params)r1   rB   kwargs	model_reqr    s        r"   _convert_prompt_msg_params-VolcEngineMaasChat._convert_prompt_msg_paramsZ   s     


	
 ),0,>,>Igy)

JRS(w1':(S<T11<V<
 	
Ss   A c              +  F  #    Ub  X$S'   U R                   " U40 UD6nU R                  R                  U5       Hd  nU(       d  M  [        U5      n[	        [        UR                  S9S9nU(       a(  UR                  [        [        UR                  5      US9  Uv   Mf     g 7f)Nstopr(   r    )chunk)
rH   clientstream_chatr+   r   r   r   on_llm_new_tokenr
   str)	r1   rB   rK   run_managerrF   paramsresmsgrM   s	            r"   _streamVolcEngineMaasChat._streaml   s      !6N00DVD;;**62Cs-c2+N3;;4WX00c3;;1Gu0U 3s   >B!AB!c                d   SnU R                   (       a*  U R                  " XU40 UD6 H  nXVR                  -  nM     OZUb  X$S'   U R                  " U40 UD6nU R                  R                  U5      n[        U5      n	[        [        U	R                  5      n[        US9n
[        [        U
S9/S9$ )Nr'   rK   r(   rL   )generations)	streamingrV   textrH   rN   chatr+   r
   rQ   r   r   r   r   )r1   rB   rK   rR   rF   
completionrM   rS   rT   rU   r    s              r"   	_generateVolcEngineMaasChat._generate~   s     
>>hkLVLjj(
 M !%v44XHHF++""6*C)#.Cc3;;/JJ/~g'F&GHHr$   r0   )returnrQ   )r`   bool)r`   Dict[str, Any])rB   List[BaseMessage]rF   r   r`   rb   )NN)
rB   rc   rK   Optional[List[str]]rR   "Optional[CallbackManagerForLLMRun]rF   r   r`   zIterator[ChatGenerationChunk])
rB   rc   rK   rd   rR   re   rF   r   r`   r   )__name__
__module____qualname____firstlineno____doc__propertyr2   classmethodr6   r<   rH   rV   r^   __static_attributes____classcell__)r=   s   @r"   r-   r-   )   s    > ' '   
 

#
 
 
	
* %):>	# " 8	
  
'* %):>	I#I "I 8	I
 I 
I Ir$   r-   N)r    r   r`   dict)r*   zMapping[str, Any]r`   r   )
__future__r   typingr   r   r   r   r   r	   r
   langchain_core.callbacksr   *langchain_core.language_models.chat_modelsr   langchain_core.messagesr   r   r   r   r   r   langchain_core.outputsr   r   r   (langchain_community.llms.volcengine_maasr   r#   r+   r-   r0   r$   r"   <module>rw      sJ    " E E E = D  S R G&iI(: iIr$   