
    7|h                        d dl mZ d dlZd dlmZmZmZmZmZ d dl	Z	d dl
mZ d dlmZmZmZ d dlmZmZmZmZ d dlmZmZmZmZ  ej4                  e      ZddZdd
Z G d d	ee      Zy)    )annotationsN)AnyCallableDictListOptional)
Embeddings)convert_to_secret_strget_from_dict_or_envpre_init)	BaseModel
ConfigDictField	SecretStr)before_sleep_logretrystop_after_attemptwait_exponentialc            	         d} d}d}d}t        dt        |      t        | ||      t        t        t
        j                              S )z#Returns a tenacity retry decorator.         T)
multiplierminmax)reraisestopwaitbefore_sleep)r   r   r   r   loggerloggingWARNING)r   min_secondsmax_secondsmax_retriess       e/var/www/html/test/engine/venv/lib/python3.12/site-packages/langchain_community/embeddings/minimax.py_create_retry_decoratorr'      sJ     JKKK,+V%fgoo>	     MiniMaxEmbeddingsc                >     t               }|d fd       } ||i |S )z*Use tenacity to retry the completion call.c                 (     j                   | i |S )N)embed)argskwargs
embeddingss     r&   _embed_with_retryz+embed_with_retry.<locals>._embed_with_retry(   s    z000r(   )r-   r   r.   r   returnr   )r'   )r/   r-   r.   retry_decoratorr0   s   `    r&   embed_with_retryr3   $   s/    -/O1 1 d-f--r(   c                      e Zd ZU dZdZded<   	 dZded<   	 dZded<   	 d	Zded
<   	  e	dd      Z
ded<   	  e	dd      Zded<   	  edd      Zedd       Z	 	 	 	 	 	 ddZddZddZy)r)   u1  MiniMax embedding model integration.

    Setup:
        To use, you should have the environment variable ``MINIMAX_GROUP_ID`` and
        ``MINIMAX_API_KEY`` set with your API token.

        .. code-block:: bash

            export MINIMAX_API_KEY="your-api-key"
            export MINIMAX_GROUP_ID="your-group-id"

    Key init args — completion params:
        model: Optional[str]
            Name of ZhipuAI model to use.
        api_key: Optional[str]
            Automatically inferred from env var `MINIMAX_GROUP_ID` if not provided.
        group_id: Optional[str]
            Automatically inferred from env var `MINIMAX_GROUP_ID` if not provided.

    See full list of supported init args and their descriptions in the params section.

    Instantiate:

        .. code-block:: python

            from langchain_community.embeddings import MiniMaxEmbeddings

            embed = MiniMaxEmbeddings(
                model="embo-01",
                # api_key="...",
                # group_id="...",
                # other
            )

    Embed single text:
        .. code-block:: python

            input_text = "The meaning of life is 42"
            embed.embed_query(input_text)

        .. code-block:: python

            [0.03016241, 0.03617699, 0.0017198119, -0.002061239, -0.00029994643, -0.0061320597, -0.0043635326, ...]

    Embed multiple text:
        .. code-block:: python

            input_texts = ["This is a test query1.", "This is a test query2."]
            embed.embed_documents(input_texts)

        .. code-block:: python

            [
                [-0.0021588828, -0.007608119, 0.029349545, -0.0038194496, 0.008031177, -0.004529633, -0.020150753, ...],
                [ -0.00023150232, -0.011122423, 0.016930554, 0.0083089275, 0.012633711, 0.019683322, -0.005971041, ...]
            ]
    z&https://api.minimax.chat/v1/embeddingsstrendpoint_urlzembo-01modeldbembed_type_dbqueryembed_type_queryNgroup_id)defaultaliaszOptional[str]minimax_group_idapi_keyzOptional[SecretStr]minimax_api_keyTforbid)populate_by_nameextrac                h    t        |ddgd      }t        t        |ddgd            }||d<   ||d<   |S )z9Validate that group id and api key exists in environment.r?   r<   MINIMAX_GROUP_IDrA   r@   MINIMAX_API_KEY)r   r
   )clsvaluesr?   rA   s       r&   validate_environmentz&MiniMaxEmbeddings.validate_environment}   s\     0'46H
 0 *I68I

 &6!"$3 !r(   c                *   | j                   ||d}d| j                  j                          dd}d| j                  i}t	        j
                  | j                  |||      }|j                         }|d   d   d	k7  rt        d
|d          |d   }|S )N)r7   typetextszBearer zapplication/json)AuthorizationzContent-TypeGroupId)paramsheadersjson	base_respstatus_coder   zMiniMax API returned an error: vectors)	r7   rA   get_secret_valuer?   requestspostr6   rR   
ValueError)	selfrM   
embed_typepayloadrQ   rP   responseparsed_responser/   s	            r&   r,   zMiniMaxEmbeddings.embed   s     ZZ
  't';';'L'L'N&OP.
 t,,

 ==fgG
 #--/ ;'6!;1/+2N1OP  %Y/
r(   c                6    t        | || j                        }|S )zEmbed documents using a MiniMax embedding endpoint.

        Args:
            texts: The list of texts to embed.

        Returns:
            List of embeddings, one for each text.
        rM   r[   )r3   r9   )rZ   rM   r/   s      r&   embed_documentsz!MiniMaxEmbeddings.embed_documents   s     &d%DDVDVW
r(   c                >    t        | |g| j                        }|d   S )zEmbed a query using a MiniMax embedding endpoint.

        Args:
            text: The text to embed.

        Returns:
            Embeddings for the text.
        r`   r   )r3   r;   )rZ   textr/   s      r&   embed_queryzMiniMaxEmbeddings.embed_query   s)     &4+@+@

 !}r(   )rI   r   r1   r   )rM   	List[str]r[   r5   r1   List[List[float]])rM   re   r1   rf   )rc   r5   r1   zList[float])__name__
__module____qualname____doc__r6   __annotations__r7   r9   r;   r   r?   rA   r   model_configr   rJ   r,   ra   rd    r(   r&   r)   r)   /   s    8t AL#@E3'M3#c#&+D
&KmK#+0Y+OO(O"L
  ## # 
	#J
r(   )r1   zCallable[[Any], Any])r/   r)   r-   r   r.   r   r1   r   ) 
__future__r   r!   typingr   r   r   r   r   rW   langchain_core.embeddingsr	   langchain_core.utilsr
   r   r   pydanticr   r   r   r   tenacityr   r   r   r   	getLoggerrg   r    r'   r3   r)   rm   r(   r&   <module>ru      s[    "  6 6  0 V V < <  
		8	$ .Z	: Zr(   