
    ~h-                        d dl Z d dlmZmZ d dlmZ d dlmZmZm	Z	m
Z
 d dlmZmZ d dlmZmZmZmZ d dlmZmZ erd dlZd dlmZ d d	lmZ d
gZ ee      Ze G d d             Ze G d d             Ze G d de             Ze G d de             Ze G d de             Ze G d de             Z e G d de             Z! G d d
      Z" G d d      Z#y)    N)asdict	dataclass)	getLogger)TYPE_CHECKINGAnyCallableType)ChatMessageMessageRole)AgentLoggerLogLevelTiming
TokenUsage)
AgentErrormake_json_serializable)r
   )r   AgentMemoryc                   2    e Zd ZU eed<   eed<   eed<   d Zy)ToolCallname	argumentsidc                 b    | j                   d| j                  t        | j                        ddS )Nfunction)r   r   )r   typer   )r   r   r   r   selfs    M/opt/mcp/mcp-sentiment/venv/lib/python3.12/site-packages/smolagents/memory.pydictzToolCall.dict   s.    ''		3DNNC
 	
    N)__name__
__module____qualname__str__annotations__r   r    r   r   r   r      s    
ING
r   r   c                   *    e Zd Zd Zddedee   fdZy)
MemoryStepc                     t        |       S N)r   r   s    r   r   zMemoryStep.dict+   s    d|r   summary_modereturnc                     t         r)   )NotImplementedErrorr   r*   s     r   to_messageszMemoryStep.to_messages.   s    !!r   NF)r    r!   r"   r   boollistr
   r/   r%   r   r   r'   r'   )   s    " "k9J "r   r'   c                   8   e Zd ZU eed<   eed<   dZee   dz  ed<   dZ	ee
   dz  ed<   dZedz  ed<   dZedz  ed<   dZeeeeef      z  dz  ed<   dZedz  ed	<   dZedz  ed
<   dZed   dz  ed<   dZeed<   dZedz  ed<   dZeed<   d Zddedee   fdZy)
ActionStepstep_numbertimingNmodel_input_messages
tool_callserrormodel_output_messagemodel_outputcode_actionobservationsPIL.Image.Imageobservations_imagesaction_outputtoken_usageFis_final_answerc                    | j                   | j                  j                         | j                  | j                  r(| j                  D cg c]  }|j                          c}ng | j
                  r| j
                  j                         nd | j                  r| j                  j                         nd | j                  | j                  | j                  | j                  r(| j                  D cg c]  }|j                          c}nd t        | j                        | j                  rt        | j                        nd | j                   dS c c}w c c}w )N)r5   r6   r7   r8   r9   r:   r;   r<   r=   r?   r@   rA   rB   )r5   r6   r   r7   r8   r9   r:   r;   r<   r=   r?   tobytesr   r@   rA   r   rB   )r   tcimages      r   r   zActionStep.dictB   s     ++kk&&($($=$=CG??t?2779?XZ*.**TZZ__&$HLHaHaD$=$=$B$B$Dgk --++ --'' BFAYAY#ZEMMO#Z3D4F4FG7;7G7G6$"2"23T#33
 	
 @ $[s   
E
.Er*   r+   c                    g }| j                   H|sF|j                  t        t        j                  d| j                   j                         dg             | j                  `|j                  t        t        j                  ddt        | j                  D cg c]  }|j                          c}      z   dg             | j                  rE|j                  t        t        j                  | j                  D cg c]  }d|d	 c}             | j                  ;|j                  t        t        j                  dd| j                   dg             | j                  ydt        | j                        z   d	z   }| j                  rd
| j                  d   j                   dnd}||z  }|j                  t        t        j                  d|dg             |S c c}w c c}w )Ntextr   rH   rolecontentzCalling tools:
rF   r   rF   zObservation:
zError:
z
Now let's retry: take care not to repeat previous errors! If you have retried several times, try a completely different approach.
z	Call id: r   
 )r;   appendr
   r   	ASSISTANTstripr8   	TOOL_CALLr#   r   r?   USERr=   TOOL_RESPONSEr9   r   )r   r*   messagesrE   rF   error_messagemessage_contents          r   r/   zActionStep.to_messagesV   s   (OO!6!6&Z^ZkZkZqZqZsAt@uv ??&OO$.. %+$6RVRaRa=bBbggi=b9c$c
 ##OO$)) &*%=%=
 " %,%*	 (OO$22 %+&4T5F5F4G$H
 ::!djj/" ZZ 
 HL	$//!*<*?*?)@C\^O},OOO!:!:f^mEnDop Y >cs   G"<G'r0   )r    r!   r"   intr$   r   r7   r2   r
   r8   r   r9   r   r:   r;   r#   r   r   r<   r=   r?   r@   rA   r   rB   r1   r/   r%   r   r   r4   r4   2   s    N59${+d29(,JX%,#E:#/3+,36:L#T#s(^,,t3:"Kt"#L#*#:>/047>M3%)Kd")!OT!
(: :k9J :r   r4   c                   h    e Zd ZU ee   ed<   eed<   eed<   eed<   dZe	dz  ed<   d
de
dee   fd	Zy)PlanningStepr7   r:   planr6   NrA   r*   r+   c                     |rg S t        t        j                  d| j                  j	                         dg      t        t        j
                  dddg      gS )NrH   rI   rJ   z$Now proceed and carry out this plan.)r
   r   rQ   r\   rR   rT   r.   s     r   r/   zPlanningStep.to_messages   sX    I[22fVZV_V_VeVeVg=h<ij %%Io0p/q
 	
r   r0   )r    r!   r"   r2   r
   r$   r#   r   rA   r   r1   r/   r%   r   r   r[   r[      sD    {++%%
IN%)Kd")	
 	
k9J 	
r   r[   c                   J    e Zd ZU eed<   dZed   dz  ed<   ddedee   fdZ	y)	TaskSteptaskNr>   task_imagesr*   r+   c                     dd| j                    dg}| j                  r,|j                  | j                  D cg c]  }d|d	 c}       t        t        j
                  |      gS c c}w )NrH   z
New task:
rI   rF   rM   rJ   )r`   ra   extendr
   r   rT   )r   r*   rL   rF   s       r   r/   zTaskStep.to_messages   sa    "k$)),EFGNN4K[K[\%Wu=\]!1!17CDD ]s   A(r0   )
r    r!   r"   r#   r$   ra   r2   r1   r
   r/   r%   r   r   r_   r_      s7    
I26K'(4/6E Ek9J Er   r_   c                   0    e Zd ZU eed<   ddedee   fdZy)SystemPromptStepsystem_promptr*   r+   c                 ^    |rg S t        t        j                  d| j                  dg      gS )NrH   rI   rJ   )r
   r   SYSTEMrf   r.   s     r   r/   zSystemPromptStep.to_messages   s/    I!3!3vW[WiWi>j=klmmr   Nr0   )	r    r!   r"   r#   r$   r1   r2   r
   r/   r%   r   r   re   re      s#    n nk9J nr   re   c                       e Zd ZU eed<   y)FinalAnswerStepoutputN)r    r!   r"   r   r$   r%   r   r   rj   rj      s    Kr   rj   c                   d    e Zd ZdZdefdZd Zdee   fdZ	dee   fdZ
dded	efd
ZdefdZy)r   a  Memory for the agent, containing the system prompt and all steps taken by the agent.

    This class is used to store the agent's steps, including tasks, actions, and planning steps.
    It allows for resetting the memory, retrieving succinct or full step information, and replaying the agent's steps.

    Args:
        system_prompt (`str`): System prompt for the agent, which sets the context and instructions for the agent's behavior.

    **Attributes**:
        - **system_prompt** (`SystemPromptStep`) -- System prompt step for the agent.
        - **steps** (`list[TaskStep | ActionStep | PlanningStep]`) -- List of steps taken by the agent, which can include tasks, actions, and planning steps.
    rf   c                 4    t        |      | _        g | _        y )N)rf   )re   rf   steps)r   rf   s     r   __init__zAgentMemory.__init__   s    /?m/\AC
r   c                     g | _         y)zKReset the agent's memory, clearing all steps and keeping the system prompt.N)rn   r   s    r   resetzAgentMemory.reset   s	    
r   r+   c                     | j                   D cg c]:  }|j                         j                         D ci c]  \  }}|dk7  s|| c}}< c}}}S c c}}w c c}}}w )zVReturn a succinct representation of the agent's steps, excluding model input messages.r7   )rn   r   items)r   stepkeyvalues       r   get_succinct_stepszAgentMemory.get_succinct_steps   s[     mqlvlv
 
dh$))+*;*;*=_JCH^A^S%Z_
 	
_
s   &AAA
AAc                     t        | j                        dk(  rg S | j                  D cg c]  }|j                          c}S c c}w )zRReturn a full representation of the agent's steps, including model input messages.r   )lenrn   r   r   rt   s     r   get_full_stepszAgentMemory.get_full_steps   s5    tzz?aI(,

3		333s   Aloggerdetailedc                    |j                   j                  d       |j                  d| j                  j                  t        j
                         | j                  D ]  }t        |t              r-|j                  |j                  dt        j
                         At        |t              r|j                  d|j                   t        j
                         |r7|j                  +|j                  |j                  t        j
                         |j                   |j                  d|j                   t        j
                         t        |t"              s|j                  d	t        j
                         |r7|j                  +|j                  |j                  t        j
                         |j                  d|j$                  t        j
                          y)
aX  Prints a pretty replay of the agent's steps.

        Args:
            logger (`AgentLogger`): The logger to print replay logs to.
            detailed (`bool`, default `False`): If True, also displays the memory at each step. Defaults to False.
                Careful: will increase log length exponentially. Use only for debugging.
        zReplaying the agent's steps:zSystem prompt)titlerL   levelrO   )r   zStep NzAgent output:zPlanning step)consoleloglog_markdownrf   r   ERRORrn   
isinstancer_   log_taskr`   r4   log_ruler5   r7   log_messagesr;   r[   r\   )r   r|   r}   rt   s       r   replayzAgentMemory.replay   sf    	9:/4;M;M;[;[ckcqcqrJJ 	dD$)		2X^^DD*-%(8(8'9 :(..Q 9 9 E''(A(A'X$$0''otGXGX`h`n`n'oD,/x~~F 9 9 E''(A(A'X##/499T\TbTb#c	dr   c           	          dj                  | j                  D cg c],  }t        |t              s|j                  !|j                  . c}      S c c}w )zQReturns all code actions from the agent's steps, concatenated as a single script.z

)joinrn   r   r4   r<   rz   s     r   return_full_codezAgentMemory.return_full_code   sC    {{*.**v$
48TY]YiYiYuTv
 	
vs   AAANr0   )r    r!   r"   __doc__r#   ro   rq   r2   r   rw   r{   r   r1   r   r   r%   r   r   r   r      s\    Dc D
DJ 
4T
 4d[ dD d2
# 
r   c                   2    e Zd ZdZd Zdee   defdZd Z	y)CallbackRegistryzRegistry for callbacks that are called at each step of the agent's execution.

    Callbacks are registered by passing a step class and a callback function.
    c                     i | _         y r)   )
_callbacksr   s    r   ro   zCallbackRegistry.__init__  s	    BDr   step_clscallbackc                 z    || j                   vrg | j                   |<   | j                   |   j                  |       y)zRegister a callback for a step class.

        Args:
            step_cls (Type[MemoryStep]): Step class to register the callback for.
            callback (Callable): Callback function to register.
        N)r   rP   )r   r   r   s      r   registerzCallbackRegistry.register  s5     4??*(*DOOH%!((2r   c                     |j                   j                  D ]_  }| j                  j                  |g       D ]>  }t	        t        j                  |      j                        dk(  r ||      n ||fi | @ a y)a  Call callbacks registered for a step type.

        Args:
            memory_step (MemoryStep): Step to call the callbacks for.
            **kwargs: Additional arguments to pass to callbacks that accept them.
                Typically, includes the agent instance.

        Notes:
            For backwards compatibility, callbacks with a single parameter signature
            receive only the memory_step, while callbacks with multiple parameters
            receive both the memory_step and any additional kwargs.
           N)	__class____mro__r   getry   inspect	signature
parameters)r   memory_stepkwargsclscbs        r   r   zCallbackRegistry.callback  sw     ((00 	mCoo))#r2 m#&w'8'8'<'G'G#HA#M;SUVaSlekSlm	mr   N)
r    r!   r"   r   ro   r	   r'   r   r   r   r%   r   r   r   r     s+    
E	3j!1 	3X 	3mr   r   )$r   dataclassesr   r   loggingr   typingr   r   r   r	   smolagents.modelsr
   r   smolagents.monitoringr   r   r   r   smolagents.utilsr   r   	PIL.ImagePIL__all__r    r|   r   r'   r4   r[   r_   re   rj   r   r   r%   r   r   <module>r      s    )  5 5 6 K K ? -1 / 
8	 
 
 
  " " " ] ] ]@ 
: 
 
& 	Ez 	E 	E nz n n j  ?
 ?
D$m $mr   