鎒j dZddlmZddlZddlZddlmZmZmZddl Z GddeZ GddZ ee gedfZ dd Z Gd d eejZGdde jZdS)zCore trigger interface for the Google Antigravity SDK. A Trigger is a long-lived async function that runs alongside an agent session. It reacts to external events (cron, file changes, webhooks) and pushes messages back into the agent. ) annotationsN) AwaitableCallableProtocolceZdZddZdS)TriggerConnectioncontentstrreturnNonec KdSNselfr s RC:\Projects\DSCons\.venv\Lib\site-packages\google\antigravity\triggers\triggers.pysend_trigger_notificationz+TriggerConnection.send_trigger_notification!s CNr r r r )__name__ __module__ __qualname__rrrrrrs(rrc"eZdZdZd dZd d Zd S) TriggerContextzHandle provided to every trigger at startup. Provides the capability to send messages to the agent. One TriggerContext is created per trigger. connectionrr r c||_dSr) _connection)rrs r__init__zTriggerContext.__init__,s"Drr r cJK|j|d{VdS)zQSends a message to the agent. Args: content: The message content. N)rrrs rsendzTriggerContext.send2s7   4 4W = ==========rN)rrr r r)rrr__doc__rr rrrrr%sF """" > > > > > >rrfunc+Callable[[TriggerContext], Awaitable[None]]c&tj|stdtj|}t |j}t|dkrtdt|dd|S)a!Decorator for Triggers. Validates that the function is async and accepts exactly one argument (TriggerContext). Adds __is_trigger__ = True metadata. Args: func: The async function to wrap as a trigger. Returns: The original function with __is_trigger__ attribute set. z!Trigger must be an async functionz)Trigger must accept exactly one parameter__is_trigger__T) inspectiscoroutinefunction ValueError signaturelist parametersvalueslensetattr)r"sigparamss rtriggerr2Bs  $T * *: 8 9 99$# %%'' ( (&[[A @ A AA $ $''' +rceZdZdZdZdZdZdS)FileChangeKindz>Kind of filesystem change detected by a file-watching trigger.addedmodifieddeletedN)rrrr!ADDEDMODIFIEDDELETEDrrrr4r4Zs#FF % ( '''rr4cJeZdZUdZejdZded<ded<dS) FileChangezA single filesystem change detected by a file-watching trigger. Attributes: kind: The type of change (added, modified, deleted). path: Absolute path to the changed file. T)frozenr4kindr pathN)rrrr!pydantic ConfigDict model_config__annotations__rrrr<r<bsF%$D111, )))))rr<)r"r#)r! __future__renumr'typingrrrr@rrTriggerr2r Enumr4 BaseModelr<rrrrJs?#""""" 0000000000 >>>>>>>>4 N#Yt_4 50S$)      #      r