qidddlmZddlZddlZddlmZddlmZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#ddl$m%Z%ddl&m'Z'm(Z(d Z) Gd d e%Z*y) ) annotationsN)Optional) ListUpdate)SIPOutboundConfig SIPTrunkInfoCreateSIPInboundTrunkRequestUpdateSIPInboundTrunkRequestSIPInboundTrunkInfoSIPInboundTrunkUpdateCreateSIPOutboundTrunkRequestUpdateSIPOutboundTrunkRequestSIPOutboundTrunkInfoSIPOutboundTrunkUpdateListSIPInboundTrunkRequestListSIPInboundTrunkResponseListSIPOutboundTrunkRequestListSIPOutboundTrunkResponseDeleteSIPTrunkRequestSIPDispatchRuleSIPDispatchRuleInfoSIPDispatchRuleUpdateCreateSIPDispatchRuleRequestUpdateSIPDispatchRuleRequestListSIPDispatchRuleRequestListSIPDispatchRuleResponseDeleteSIPDispatchRuleRequestCreateSIPParticipantRequestTransferSIPParticipantRequestSIPParticipantInfo SIPTransport)Service) VideoGrants SIPGrantsSIPceZdZdZd'fd Z d(dZ d(dZ d)dZ d)dZdddddddd d*d Z dddddddd d+d Z d,d Z d,d Z d-d Z d-dZdddddddd d.dZdddddddd d/dZ d0dZ d0dZ d1dZ d1dZd2dZd2dZ d3dZ d3dZ d4dZ d4dZdddddd d5dZdddddd d6dZ d7dZ d7d Z d8d!Z d8d"Z dddd# d9d$Z! d:d%Z"d;d&Z#xZ$S)< SipServicezClient for LiveKit SIP Service API Recommended way to use this service is via `livekit.api.LiveKitAPI`: ```python from livekit import api lkapi = api.LiveKitAPI() sip_service = lkapi.sip ``` c*t|||||y)N)super__init__)selfsessionurlapi_key api_secret __class__s I/opt/pipecat/venv/lib/python3.12/site-packages/livekit/api/sip_service.pyr*zSipService.__init__8s #w ;cK|jjtd||jtd{S7w)zCreate a new SIP inbound trunk. Args: create: Request containing trunk details Returns: Created SIP inbound trunk CreateSIPInboundTrunkN)_clientrequestSVC_admin_headersr r+creates r1create_inbound_trunkzSipService.create_inbound_trunk;A\\))  #     !      9AAAcxKtjdtd|j|d{S7w)zCreate a new SIP inbound trunk. .. deprecated:: Use :meth:`create_inbound_trunk` instead. Args: create: Request containing trunk details Returns: Created SIP inbound trunk zHcreate_sip_inbound_trunk is deprecated, use create_inbound_trunk instead stacklevelN)warningswarnDeprecationWarningr;r9s r1create_sip_inbound_trunkz#SipService.create_sip_inbound_trunkN6  V  ..v6666 1:8:cK|jjtdt|||j t d{S7w)zUpdates an existing SIP inbound trunk by replacing it entirely. Args: trunk_id: ID of the SIP inbound trunk to update trunk: SIP inbound trunk to update with Returns: Updated SIP inbound trunk UpdateSIPInboundTrunk sip_trunk_idreplaceN)r5r6r7r r8r r+trunk_idtrunks r1update_inbound_trunkzSipService.update_inbound_trunkcsN\\))  # (%     !     AA A A czKtjdtd|j||d{S7w)aMUpdates an existing SIP inbound trunk by replacing it entirely. .. deprecated:: Use :meth:`update_inbound_trunk` instead. Args: trunk_id: ID of the SIP inbound trunk to update trunk: SIP inbound trunk to update with Returns: Updated SIP inbound trunk zHupdate_sip_inbound_trunk is deprecated, use update_inbound_trunk insteadr?r@N)rBrCrDrPrMs r1update_sip_inbound_trunkz#SipService.update_sip_inbound_trunk|s8"  V  ..x???? 2;9;Nnumbersallowed_addressesallowed_numbers auth_username auth_passwordnamemetadatacZKt||||} |t|tr| jjj |j| jj j |j | jjj |jn%| jjj ||t|tr| jjj |j| jj j |j | jjj |jn%| jjj ||t|tr| jjj |j| jj j |j | jjj |jn%| jjj ||jjtdt|| |jtd{S7w)zqUpdates specific fields of an existing SIP inbound trunk. Only provided fields will be updated. )rYrZr[r\NrIrKupdate)r isinstancerrVsetextendaddremoverWrXr5r6r7r r8r ) r+rNrVrWrXrYrZr[r\r_s r1update_inbound_trunk_fieldsz&SipService.update_inbound_trunk_fieldss '''    ':.""))'++6""))'++6%%,,W^^<""))'2  (+Z8((,,334E4I4IJ((,,334E4I4IJ((//667H7O7OP((,,334EF  &/:6&&**11/2E2EF&&**11/2E2EF&&--44_5K5KL&&**11/B\\))  # (%     !     sJ"J+$J)%J+c Ktjdtd|j||||||||d{S7w)zUpdates specific fields of an existing SIP inbound trunk. .. deprecated:: Use :meth:`update_inbound_trunk_fields` instead. Only provided fields will be updated. zVupdate_sip_inbound_trunk_fields is deprecated, use update_inbound_trunk_fields insteadr?r@rUN)rBrCrDre) r+rNrVrWrXrYrZr[r\s r1update_sip_inbound_trunk_fieldsz*SipService.update_sip_inbound_trunk_fieldssY&  d  55 /+''6    r=cK|jjtd||jtd{S7w)zCreate a new SIP outbound trunk. Args: create: Request containing trunk details Returns: Created SIP outbound trunk CreateSIPOutboundTrunkN)r5r6r7r8rr9s r1create_outbound_trunkz SipService.create_outbound_trunksA\\))  $     !     r=cxKtjdtd|j|d{S7w)zCreate a new SIP outbound trunk. .. deprecated:: Use :meth:`create_outbound_trunk` instead. Args: create: Request containing trunk details Returns: Created SIP outbound trunk zJcreate_sip_outbound_trunk is deprecated, use create_outbound_trunk insteadr?r@N)rBrCrDrjr9s r1create_sip_outbound_trunkz$SipService.create_sip_outbound_trunks6  X  //7777rGcK|jjtdt|||j t d{S7w)aUpdates an existing SIP outbound trunk by replacing it entirely. Args: trunk_id: ID of the SIP outbound trunk to update trunk: SIP outbound trunk to update with Returns: Updated SIP outbound trunk UpdateSIPOutboundTrunkrJN)r5r6r7r r8rrMs r1update_outbound_trunkz SipService.update_outbound_trunksN\\))  $ )%     !     rQczKtjdtd|j||d{S7w)aRUpdates an existing SIP outbound trunk by replacing it entirely. .. deprecated:: Use :meth:`update_outbound_trunk` instead. Args: trunk_id: ID of the SIP outbound trunk to update trunk: SIP outbound trunk to update with Returns: Updated SIP outbound trunk zJupdate_sip_outbound_trunk is deprecated, use update_outbound_trunk insteadr?r@N)rBrCrDrorMs r1update_sip_outbound_trunkz$SipService.update_sip_outbound_trunk/s8"  X  //%@@@@rTaddress transportrVrYrZr[r\cJKt||||||} |t|tr| jjj |j| jj j |j | jjj |jn%| jjj ||jjtdt|| |jtd{S7w)zrUpdates specific fields of an existing SIP outbound trunk. Only provided fields will be updated. )rsrtrYrZr[r\Nrnr^)rr`rrVrarbrcrdr5r6r7r r8r) r+rNrsrtrVrYrZr[r\r_s r1update_outbound_trunk_fieldsz'SipService.update_outbound_trunk_fieldsGs (''    ':.""))'++6""))'++6%%,,W^^<""))'2\\))  $ )%     !     sDD#D!D#c Ktjdtd|j||||||||d{S7w)zUpdates specific fields of an existing SIP outbound trunk. .. deprecated:: Use :meth:`update_outbound_trunk_fields` instead. Only provided fields will be updated. zXupdate_sip_outbound_trunk_fields is deprecated, use update_outbound_trunk_fields insteadr?r@rrN)rBrCrDrv) r+rNrsrtrVrYrZr[r\s r1 update_sip_outbound_trunk_fieldsz+SipService.update_sip_outbound_trunk_fieldsrsY&  f  66 ''7    r=cK|jjtd||jtd{S7w)zList SIP inbound trunks with optional filtering. Args: list: Request with optional filtering parameters Returns: Response containing list of SIP inbound trunks ListSIPInboundTrunkN)r5r6r7r8rr+lists r1list_inbound_trunkzSipService.list_inbound_trunkA\\))  !     ! '     r=cxKtjdtd|j|d{S7w)aList SIP inbound trunks with optional filtering. .. deprecated:: Use :meth:`list_inbound_trunk` instead. Args: list: Request with optional filtering parameters Returns: Response containing list of SIP inbound trunks zDlist_sip_inbound_trunk is deprecated, use list_inbound_trunk insteadr?r@N)rBrCrDr}r{s r1list_sip_inbound_trunkz!SipService.list_sip_inbound_trunk6  R  ,,T2222rGcK|jjtd||jtd{S7w)zList SIP outbound trunks with optional filtering. Args: list: Request with optional filtering parameters Returns: Response containing list of SIP outbound trunks ListSIPOutboundTrunkN)r5r6r7r8rr{s r1list_outbound_trunkzSipService.list_outbound_trunksA\\))  "     ! (     r=cxKtjdtd|j|d{S7w)a!List SIP outbound trunks with optional filtering. .. deprecated:: Use :meth:`list_outbound_trunk` instead. Args: list: Request with optional filtering parameters Returns: Response containing list of SIP outbound trunks zFlist_sip_outbound_trunk is deprecated, use list_outbound_trunk insteadr?r@N)rBrCrDrr{s r1list_sip_outbound_trunkz"SipService.list_sip_outbound_trunks6  T  --d3333rGcK|jjtd||jtd{S7w)zDelete a SIP trunk. Args: delete: Request containing trunk ID to delete Returns: Deleted trunk information DeleteSIPTrunkN)r5r6r7r8rr+deletes r1 delete_trunkzSipService.delete_trunksA\\))       !      r=cxKtjdtd|j|d{S7w)zDelete a SIP trunk. .. deprecated:: Use :meth:`delete_trunk` instead. Args: delete: Request containing trunk ID to delete Returns: Deleted trunk information z8delete_sip_trunk is deprecated, use delete_trunk insteadr?r@N)rBrCrDrrs r1delete_sip_trunkzSipService.delete_sip_trunks6  F  &&v....rGcK|jjtd||jtd{S7w)zCreate a new SIP dispatch rule. Args: create: Request containing rule details Returns: Created SIP dispatch rule CreateSIPDispatchRuleNr5r6r7r8rr9s r1create_dispatch_rulezSipService.create_dispatch_rule r<r=cxKtjdtd|j|d{S7w)zCreate a new SIP dispatch rule. .. deprecated:: Use :meth:`create_dispatch_rule` instead. Args: create: Request containing rule details Returns: Created SIP dispatch rule zHcreate_sip_dispatch_rule is deprecated, use create_dispatch_rule insteadr?r@N)rBrCrDrr9s r1create_sip_dispatch_rulez#SipService.create_sip_dispatch_rulerFrGcK|jjtdt|||j t d{S7w)zUpdates an existing SIP dispatch rule by replacing it entirely. Args: rule_id: ID of the SIP dispatch rule to update rule: SIP dispatch rule to update with Returns: Updated SIP dispatch rule UpdateSIPDispatchRule)sip_dispatch_rule_idrLN)r5r6r7rr8rr+rule_idrules r1update_dispatch_rulezSipService.update_dispatch_rule1sH\\))  # (gt T    !      rQczKtjdtd|j||d{S7w)aKUpdates an existing SIP dispatch rule by replacing it entirely. .. deprecated:: Use :meth:`update_dispatch_rule` instead. Args: rule_id: ID of the SIP dispatch rule to update rule: SIP dispatch rule to update with Returns: Updated SIP dispatch rule zHupdate_sip_dispatch_rule is deprecated, use update_dispatch_rule insteadr?r@N)rBrCrDrrs r1update_sip_dispatch_rulez#SipService.update_sip_dispatch_ruleGs8"  V  ..w====rT trunk_idsrr[r\ attributescFKt||||}|t|tr|jjj |j|jj j |j |jjj |jn%|jjj ||jjtdt|||jtd{S7w)zqUpdates specific fields of an existing SIP dispatch rule. Only provided fields will be updated. )r[r\rrNr)rr_)rr`rrrarbrcrdr5r6r7rr8r)r+rrrr[r\rr_s r1update_dispatch_rule_fieldsz&SipService.update_dispatch_rule_fields_s'!    )Z0  $$++IMM:  $$++IMM:  ''..y/?/?@  $$++I6\\))  # (gf U    !      sDD!DD!cKtjdtd|j||||||d{S7w)zUpdates specific fields of an existing SIP dispatch rule. .. deprecated:: Use :meth:`update_dispatch_rule_fields` instead. Only provided fields will be updated. zVupdate_sip_dispatch_rule_fields is deprecated, use update_dispatch_rule_fields insteadr?r@rN)rBrCrDr)r+rrrr[r\rs r1update_sip_dispatch_rule_fieldsz*SipService.update_sip_dispatch_rule_fieldssS"  d  55 ! 6    s7A>AcK|jjtd||jtd{S7w)zList SIP dispatch rules with optional filtering. Args: list: Request with optional filtering parameters Returns: Response containing list of SIP dispatch rules ListSIPDispatchRuleN)r5r6r7r8rr{s r1list_dispatch_rulezSipService.list_dispatch_ruler~r=cxKtjdtd|j|d{S7w)aList SIP dispatch rules with optional filtering. .. deprecated:: Use :meth:`list_dispatch_rule` instead. Args: list: Request with optional filtering parameters Returns: Response containing list of SIP dispatch rules zDlist_sip_dispatch_rule is deprecated, use list_dispatch_rule insteadr?r@N)rBrCrDrr{s r1list_sip_dispatch_rulez!SipService.list_sip_dispatch_rulerrGcK|jjtd||jtd{S7w)zDelete a SIP dispatch rule. Args: delete: Request containing rule ID to delete Returns: Deleted rule information DeleteSIPDispatchRuleNrrs r1delete_dispatch_rulezSipService.delete_dispatch_ruler<r=cxKtjdtd|j|d{S7w)zDelete a SIP dispatch rule. .. deprecated:: Use :meth:`delete_dispatch_rule` instead. Args: delete: Request containing rule ID to delete Returns: Deleted rule information zHdelete_sip_dispatch_rule is deprecated, use delete_dispatch_rule insteadr?r@N)rBrCrDrrs r1delete_sip_dispatch_rulez#SipService.delete_sip_dispatch_rulerFrG)timeoutrNoutbound_trunk_configc BKd}|rtj|}n|jr|jjj rm|jjj j rC|jjj j dkrtjd}|r||_|r||_|jjtd||jttdt|d{S7w) aCreate a new SIP participant. Args: create: Request containing participant details timeout: Optional request timeout in seconds trunk_id: Optional SIP trunk ID to use for the participant outbound_trunk_config: Optional outbound trunk configuration for the participant Returns: Created SIP participant Raises: SIPError: If the SIP operation fails N)totalCreateSIPParticipantTcallsip)r)aiohttp ClientTimeoutwait_until_answeredr5_sessionrrrKrOr6r7 _auth_headerr#r$r)r+r:rrNrclient_timeouts r1create_sip_participantz!SipService.create_sip_participants,;? $22AN  ' ' %%--LL))1177LL))1177"B<@'+'+""&5 5 2 5 < 5 : 5 %5 %5 5  5  5 v(,15/3'+'+""&! ! % ! / ! - ! %! %! !  !  ! F 3  &838 8*  $    2AA$A  A8#)-48$($(#) )  ) ' ) 2 ) ") ") ) )  ) ^#)-$($($(#! !  ! ' ! " ! "! "! ! !  ! F . $ &3.3 $3* / % &4/4 %4* "/& 2  &727 7*  "    ,>>">  >87;*.""&/3" " 4 " ( "  "  " -"  " P*.*.""&/3  '  (      -   > . $ &3.3 $3* 2  &727 72$("&=A 0 +0 ! 0  0 ; 0  0 d 5  2Kr2r')+ __future__rrrBtypingrlivekit.protocol.modelsrlivekit.protocol.siprrrr r r r r rrrrrrrrrrrrrrrrrrr _servicer" access_tokenr#r$r7r'r2r1rs\".:0 R KR Kr2