o id@sddlmZddlZddlZddlmZddlmZddlm 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 d e%Z*dS) ) annotationsN)Optional) ListUpdate)SIPOutboundConfig SIPTrunkInfoCreateSIPInboundTrunkRequestUpdateSIPInboundTrunkRequestSIPInboundTrunkInfoSIPInboundTrunkUpdateCreateSIPOutboundTrunkRequestUpdateSIPOutboundTrunkRequestSIPOutboundTrunkInfoSIPOutboundTrunkUpdateListSIPInboundTrunkRequestListSIPInboundTrunkResponseListSIPOutboundTrunkRequestListSIPOutboundTrunkResponseDeleteSIPTrunkRequestSIPDispatchRuleSIPDispatchRuleInfoSIPDispatchRuleUpdateCreateSIPDispatchRuleRequestUpdateSIPDispatchRuleRequestListSIPDispatchRuleRequestListSIPDispatchRuleResponseDeleteSIPDispatchRuleRequestCreateSIPParticipantRequestTransferSIPParticipantRequestSIPParticipantInfo SIPTransport)Service) VideoGrants SIPGrantsSIPcseZdZdZdfdd ZdddZdddZdddZdddZdddddddddd#d$Z dddddddddd&d'Z dd*d+Z dd,d-Z dd.d/Z dd0d1Zdddddddd2dd7d8Zdddddddd2dd:d;Zdd?d@ZddAdBZddEdFZddGdHZddLdMZddNdOZddRdSZddTdUZddXdYZddZd[Zdddddd\ddadbZdddddd\ddcddZddgdhZddidjZddldmZddndoZ ddddpddwdxZ!dd{d|Z"dd~dZ#Z$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 ``` sessionaiohttp.ClientSessionurlstrapi_key api_secretcst||||dS)N)super__init__)selfr&r(r*r+ __class__Y/var/www/html/livekit_bhavya/venv/lib/python3.10/site-packages/livekit/api/sip_service.pyr-8zSipService.__init__createrreturnr c |jtd||tIdHS)zCreate a new SIP inbound trunk. Args: create: Request containing trunk details Returns: Created SIP inbound trunk CreateSIPInboundTrunkN)_clientrequestSVC_admin_headersr r.r4r1r1r2create_inbound_trunk;  zSipService.create_inbound_trunkc"tjdtdd||IdHS)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=r<r1r1r2create_sip_inbound_trunkNz#SipService.create_sip_inbound_trunktrunk_idtrunkc(|jtdt||d|tIdHS)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)r8r9r:rr;r r.rHrIr1r1r2update_inbound_trunkc zSipService.update_inbound_trunkc$tjdtdd|||IdHS)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@rAN)rCrDrErPrOr1r1r2update_sip_inbound_trunk|z#SipService.update_sip_inbound_trunkNnumbersallowed_addressesallowed_numbers auth_username auth_passwordnamemetadatarV Optional[ListUpdate | list[str]]rWrXrY Optional[str]rZr[r\c s.t||||d} |dur2t|tr+| jj|j| jj|j| jj|jn| jj||dur[t|trT| jj|j| jj|j| jj|jn| jj||durt|tr}| j j|j| j j|j| j j|jn| j j||j t dt || d|tIdHS)zqUpdates specific fields of an existing SIP inbound trunk. Only provided fields will be updated. )rYrZr[r\NrKrMupdate)r isinstancerrVsetextendaddremoverWrXr8r9r:rr;r ) r.rHrVrWrXrYrZr[r\r`r1r1r2update_inbound_trunk_fieldssF    z&SipService.update_inbound_trunk_fieldsOptional[list[str]]c 2tjdtdd|j||||||||dIdHS)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@rArUN)rCrDrErf) r.rHrVrWrXrYrZr[r\r1r1r2update_sip_inbound_trunk_fields  z*SipService.update_sip_inbound_trunk_fieldsr r cr6)zCreate a new SIP outbound trunk. Args: create: Request containing trunk details Returns: Created SIP outbound trunk CreateSIPOutboundTrunkN)r8r9r:r;r r<r1r1r2create_outbound_trunkr>z SipService.create_outbound_trunkcr?)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@rAN)rCrDrErlr<r1r1r2create_sip_outbound_trunkrGz$SipService.create_sip_outbound_trunkcrJ)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 UpdateSIPOutboundTrunkrLN)r8r9r:r r;r rOr1r1r2update_outbound_trunkrQz SipService.update_outbound_trunkcrR)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@rAN)rCrDrErorOr1r1r2update_sip_outbound_trunk/rTz$SipService.update_sip_outbound_trunkaddress transportrVrYrZr[r\rr str | NonersSIPTransport | Nonec st||||||d} |dur4t|tr-| jj|j| jj|j| jj|jn| jj||j t dt || d| t IdHS)zrUpdates specific fields of an existing SIP outbound trunk. Only provided fields will be updated. )rrrsrYrZr[r\Nrnr_)rrarrVrbrcrdrer8r9r:r r;r ) r.rHrrrsrVrYrZr[r\r`r1r1r2update_outbound_trunk_fieldsGs2  z'SipService.update_outbound_trunk_fieldslist[str] | Nonec rh)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@rArqN)rCrDrErv) r.rHrrrsrVrYrZr[r\r1r1r2 update_sip_outbound_trunk_fieldsrrjz+SipService.update_sip_outbound_trunk_fieldslistrrcr6)zList SIP inbound trunks with optional filtering. Args: list: Request with optional filtering parameters Returns: Response containing list of SIP inbound trunks ListSIPInboundTrunkN)r8r9r:r;rr.ryr1r1r2list_inbound_trunkr>zSipService.list_inbound_trunkcr?)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@rAN)rCrDrEr|r{r1r1r2list_sip_inbound_trunkrGz!SipService.list_sip_inbound_trunkrrcr6)zList SIP outbound trunks with optional filtering. Args: list: Request with optional filtering parameters Returns: Response containing list of SIP outbound trunks ListSIPOutboundTrunkN)r8r9r:r;rr{r1r1r2list_outbound_trunkr>zSipService.list_outbound_trunkcr?)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@rAN)rCrDrErr{r1r1r2list_sip_outbound_trunkrGz"SipService.list_sip_outbound_trunkdeleterrcr6)zDelete a SIP trunk. Args: delete: Request containing trunk ID to delete Returns: Deleted trunk information DeleteSIPTrunkN)r8r9r:r;rr.rr1r1r2 delete_trunks  zSipService.delete_trunkcr?)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@rAN)rCrDrErrr1r1r2delete_sip_trunks zSipService.delete_sip_trunkrrcr6)zCreate a new SIP dispatch rule. Args: create: Request containing rule details Returns: Created SIP dispatch rule CreateSIPDispatchRuleNr8r9r:r;rr<r1r1r2create_dispatch_rule r>zSipService.create_dispatch_rulecr?)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@rAN)rCrDrErr<r1r1r2create_sip_dispatch_rulerGz#SipService.create_sip_dispatch_rulerule_idrulecrJ)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_idrNN)r8r9r:rr;rr.rrr1r1r2update_dispatch_rule1s  zSipService.update_dispatch_rulecrR)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@rAN)rCrDrErrr1r1r2update_sip_dispatch_ruleGrTz#SipService.update_sip_dispatch_rule trunk_idsrr[r\ attributesrOptional[SIPDispatchRule]rOptional[dict[str, str]]cst||||d}|dur2t|tr+|jj|j|jj|j|jj|jn|jj||j t dt ||d| t IdHS)zqUpdates specific fields of an existing SIP dispatch rule. Only provided fields will be updated. )r[r\rrNr)rr`)rrarrrbrcrdrer8r9r:rr;r)r.rrrr[r\rr`r1r1r2update_dispatch_rule_fields_s(   z&SipService.update_dispatch_rule_fieldscs.tjdtdd|j||||||dIdHS)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@rArN)rCrDrEr)r.rrrr[r\rr1r1r2update_sip_dispatch_rule_fieldss z*SipService.update_sip_dispatch_rule_fieldsrrcr6)zList SIP dispatch rules with optional filtering. Args: list: Request with optional filtering parameters Returns: Response containing list of SIP dispatch rules ListSIPDispatchRuleN)r8r9r:r;rr{r1r1r2list_dispatch_ruler>zSipService.list_dispatch_rulecr?)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@rAN)rCrDrErr{r1r1r2list_sip_dispatch_rulerGz!SipService.list_sip_dispatch_rulercr6)zDelete a SIP dispatch rule. Args: delete: Request containing rule ID to delete Returns: Deleted rule information DeleteSIPDispatchRuleNrrr1r1r2delete_dispatch_ruler>zSipService.delete_dispatch_rulecr?)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@rAN)rCrDrErrr1r1r2delete_sip_dispatch_rulerGz#SipService.delete_sip_dispatch_rule)timeoutrHoutbound_trunk_configrrOptional[float]rOptional[SIPOutboundConfig]rc sd}|r tj|d}n|jr(|jjjr(|jjjjr(|jjjjdkr(tjdd}|r-||_|r2||_|jj t d||j t t dddt|dIdHS) 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_answeredr8_sessionrrrMrIr9r: _auth_headerr"r#r)r.r4rrHrclient_timeoutr1r1r2create_sip_participants.   z!SipService.create_sip_participanttransferrc s6|jtd||jtd|jdtdddtIdHS)zTransfer a SIP participant to a different room. Args: transfer: Request containing transfer details Returns: Updated SIP participant information TransferSIPParticipantT) room_adminroomrrN)r8r9r:rr" room_namer#r)r.rr1r1r2transfer_sip_participant$s  z#SipService.transfer_sip_participantdict[str, str]cCs|jttdddS)NT)adminr)rr"r#)r.r1r1r2r;=r3zSipService._admin_headers)r&r'r(r)r*r)r+r))r4rr5r )rHr)rIr r5r )rHr)rVr]rWr]rXr]rYr^rZr^r[r^r\r^r5r )rHr)rVrgrWrgrXrgrYr^rZr^r[r^r\r^r5r )r4r r5r )rHr)rIr r5r )rHr)rrrtrsrurVr]rYrtrZrtr[rtr\rtr5r )rHr)rrrtrsrurVrwrYrtrZrtr[rtr\rtr5r )ryrr5r)ryrr5r)rrr5r)r4rr5r)rr)rrr5r)rr)rr]rrr[r^r\r^rrr5r)rr)rrgrrr[r^r\r^rrr5r)ryrr5r)rrr5r) r4rrrrHr^rrr5r)rrr5r)r5r)%__name__ __module__ __qualname____doc__r-r=rFrPrSrfrirlrmrorprvrxr|r}rrrrrrrrrrrrrrrrr; __classcell__r1r1r/r2r%,s    ; #   / #         (     2r%)+ __future__rrrCtypingrlivekit.protocol.modelsrlivekit.protocol.siprrrrr r r r r rrrrrrrrrrrrrrrrrr_servicer! access_tokenr"r#r:r%r1r1r1r2s   t