qi:dZddlZddlmZmZmZmZmZddlm Z ddl Z ddl m Z m Z mZmZGdde ZGdd e ZGd d e ZGd d e ZGdde ZGdde ZGdde ZGdde ZGddZy)zoDaily REST Helpers. Methods that wrap the Daily API to create rooms, check room URLs, and get meeting tokens. N)AnyDictListLiteralOptional)urlparse) BaseModel ConfigDictFieldValidationErrorceZdZUdZdZeed<dZeed<dZ eed<dZ e ed <d Z e eeeefed <d Ze eed <y ) DailyRoomSipParamsaSIP configuration parameters for Daily rooms. Parameters: display_name: Name shown for the SIP endpoint. video: Whether video is enabled for SIP. sip_mode: SIP connection mode, typically 'dial-in'. num_endpoints: Number of allowed SIP endpoints. codecs: Codecs to support for audio and video. If None, uses Daily defaults. Example: {"audio": ["OPUS"], "video": ["H264"]} provider: Optional SIP provider name (defaults to None). Example: "daily" z sw-sip-dialin display_nameFvideozdial-insip_mode num_endpointsNcodecsprovider)__name__ __module__ __qualname____doc__rstr__annotations__rboolrrintrrrrrP/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/transports/daily/utils.pyrrs[ (L#'E4HcM3-1FHT#tCy.) *1"Hhsm"rrc>eZdZUdZeed<eed<eed<dZeed<y)RecordingsBucketConfigaConfiguration for storing Daily recordings in a custom S3 bucket. Refer to the Daily API documentation for more information: https://docs.daily.co/guides/products/live-streaming-recording/storing-recordings-in-a-custom-s3-bucket Parameters: bucket_name: Name of the S3 bucket for storing recordings. bucket_region: AWS region where the S3 bucket is located. assume_role_arn: ARN of the IAM role to assume for S3 access. allow_api_access: Whether to allow API access to the recordings. bucket_name bucket_regionassume_role_arnFallow_api_accessNrrrrrrr&rrrr r"r"*& "d"rr"c>eZdZUdZeed<eed<eed<dZeed<y)TranscriptionBucketConfiga Configuration for storing Daily transcription in a custom S3 bucket. Refer to the Daily API documentation for more information: https://docs.daily.co/guides/products/live-streaming-recording/storing-recordings-in-a-custom-s3-bucket Parameters: bucket_name: Name of the S3 bucket for storing transcription. bucket_region: AWS region where the S3 bucket is located. assume_role_arn: ARN of the IAM role to assume for S3 access. allow_api_access: Whether to allow API access to the transcription. r#r$r%Fr&Nr'rrr r*r*=r(rr*cXeZdZUdZedZdZeee d<dZ e e d<dZ e e d<dZ e e d <dZe e d <dZee e d <dZeed e d <dZee e d<dZeee d<dZeee d<dZeee d<dZeee d<dZeee d<dZeeeefe d<dZ e e d<e!defdZ"y)DailyRoomPropertiesaProperties for configuring a Daily room. Reference: https://docs.daily.co/reference/rest-api/rooms/create-room#properties Parameters: exp: Optional Unix epoch timestamp for room expiration (e.g., time.time() + 300 for 5 minutes). enable_chat: Whether chat is enabled in the room. enable_prejoin_ui: Whether the pre-join UI is enabled. enable_emoji_reactions: Whether emoji reactions are enabled. eject_at_room_exp: Whether to remove participants when room expires. enable_dialout: Whether SIP dial-out is enabled. enable_recording: Recording settings ('cloud', 'local', 'raw-tracks'). enable_transcription_storage: Whether transcription storage is enabled. geo: Geographic region for room. max_participants: Maximum number of participants allowed in the room. recordings_bucket: Configuration for custom S3 bucket recordings. transcription_bucket: Configuration for custom S3 bucket transcription. sip: SIP configuration parameters. sip_uri: SIP URI information returned by Daily. start_video_off: Whether video is off by default. allow)extraNexpF enable_chatenable_prejoin_uienable_emoji_reactionseject_at_room_expenable_dialoutcloudzcloud-audio-onlylocalz raw-tracksenable_recordingenable_transcription_storagegeomax_participantsrecordings_buckettranscription_bucketsipsip_uristart_video_offreturnc@|jsyd|jdzS)zGet the SIP endpoint URI if available. Returns: SIP endpoint URI or empty string if not available. zsip:%sendpoint)r?)selfs r sip_endpointz DailyRoomProperties.sip_endpointys"||dll:66 6r)#rrrrr model_configr/rfloatrr0rr1r2r3r4r8rr9r:rr;rr<r"r=r*r>rr?rrr@propertyrFrrr r,r,Ps,G,LC%K#t##(D(#t#%)NHTN)^bhw'YZ[b37 (4.7C#&*hsm*:>x 67>@D(#<=D(,C$ %,(,GXd38n %,!OT!  7c 7 7rr,cVeZdZUdZdZeeed<dZe ded<e e Z e ed<y) DailyRoomParamszParameters for creating a Daily room. Parameters: name: Optional custom name for the room. privacy: Room privacy setting ('private' or 'public'). properties: Room configuration properties. Nnamepublic)privaterMprivacydefault_factory properties) rrrrrLrrrrOrr r,rRrrr rKrKs8D(3-,4GW( )4&+0,0K$sCx.)0rr[c.eZdZUdZeeZeed<y)DailyMeetingTokenParamsaParameters for creating a Daily meeting token. Refer to the Daily API documentation for more information: https://docs.daily.co/reference/rest-api/meeting-tokens/create-meeting-token#body-params Parameters: properties: Meeting token configuration properties. rPrRN)rrrrr r[rRrrrr rhrhs/4D_.`J+`rrhc eZdZdZdddededej fdZded efd Zded e fd Z d e d e fd Z ddede deded eed ef dZded efdZded efdZded e fdZy)DailyRESTHelperzHelper class for interacting with Daily's REST API. Provides methods for creating, managing, and accessing Daily rooms. zhttps://api.daily.co/v1) daily_api_url daily_api_keyrkaiohttp_sessionc.||_||_||_y)zInitialize the Daily REST helper. Args: daily_api_key: Your Daily API key. daily_api_url: Daily API base URL (e.g. "https://api.daily.co/v1"). aiohttp_session: Async HTTP session for making requests. N)rlrkrm)rErlrkrms r __init__zDailyRESTHelper.__init__s+*.rroom_urlrAc2t|jddS)zExtract room name from a Daily room URL. Args: room_url: Full Daily room URL. Returns: Room name portion of the URL. rN)rpath)rErps r get_name_from_urlz!DailyRESTHelper.get_name_from_urls!&&qr**rcbK|j|}|j|d{S7w)zGet room details from a Daily room URL. Args: room_url: Full Daily room URL. Returns: DailyRoomObject instance for the room. N)rs_get_room_from_namerErpr\s r get_room_from_urlz!DailyRESTHelper.get_room_from_url/**84 --i8888 &/-/paramsc Kdd|ji}|jd}|jj|jd||4d{}|j dk7r3|j d{}td |j d ||jd{}dddd{ td i}|S7|7W7&7#1d{7swY(xYw#t$r}td |d}~wwxYww) aCreate a new Daily room. Args: params: Room configuration parameters. Returns: DailyRoomObject instance for the created room. Raises: Exception: If room creation fails or response is invalid. AuthorizationBearer T exclude_nonez/roomsheadersjsonNzUnable to create room (status: ): Invalid response: r) rl model_dumprmpostrkstatustext ExceptionrrTr ) rErzrrrrdataroomes r create_roomzDailyRESTHelper.create_rooms#gd.@.@-A$BC  d 3'',,!!"& )7-  " " xx3VVX~"A!((3tf UVV>D " " 6"*T*D  "&" " " " " 6045 5 6sADCD#C<C=2C/C0C4 D?CD C/DCCDC, C# !C,(D/ D 8DD  DN expiry_timer]ownercK|s tdttj|z}|j|}dd|ji}|t t ||||}nD||j_||j_ ||j_ ||j_ |jd} |jj|jd || 4d{} | j d k7r3| j#d{} td | j d | | j%d{} dddd{| dS7s7N77#1d{7swY dSxYww)aGenerate a meeting token for user to join a Daily room. Args: room_url: Daily room URL. expiry_time: Token validity duration in seconds (default: 1 hour). eject_at_token_exp: Whether to eject user when token expires. owner: Whether token has owner privileges. params: Optional additional token properties. Note that room_name, exp, and is_owner will be set based on the other function parameters regardless of values in params. Returns: Meeting token. Raises: Exception: If token generation fails or room URL is missing. zXNo Daily room specified. You must specify a Daily room in order a token to be generated.r|r}N)r\r`r/r])rRTr~z/meeting-tokensrrz(Failed to create meeting token (status: rtoken)rrtimersrlrhr[rRr\r/r]r`rrmrrkrrr) rErprr]rrz expirationr\rrrrrs r get_tokenzDailyRESTHelper.get_token-s2j diikK78 **84 "gd.@.@-A$BC >,6'""'9 F+4F   '$.F   !3EF   0).F   &  d 3'',,!!"/ 2G$-  " " xx3VVX~"J188*TWX\W] ^__>D " "G} "&" " " " "G}slC1F3E'4F7#E/E)2E/ E+E/ FE- F)E/+E/-F/F5E8 6F= FcbK|j|}|j|d{S7w)zDelete a room using its URL. Args: room_url: Daily room URL. Returns: True if deletion was successful. N)rsdelete_room_by_namervs r delete_room_by_urlz"DailyRESTHelper.delete_room_by_urlmrxryr\c Kdd|ji}|jj|jd||4d{}|jdk7rE|jdk7r6|j d{}t d|d |jd |dddd{y 7i757 #1d{7swYy xYww) zDelete a room using its name. Args: room_name: Name of the room to delete. Returns: True if deletion was successful. Raises: Exception: If deletion fails (excluding 404 Not Found). r|r}/rooms/rNrizFailed to delete room [z ] (status: rT)rlrmdeleterkrrr)rEr\rrrs r rz#DailyRESTHelper.delete_room_by_nameys#gd.@.@-A$BC''..!!"') 5w/  e e xx3188s?VVX~"9)KPQPXPXzY\]a\b cdd  e e e&  e e e esZAC B.C 2B4:B0;"B4 C (B2)C 0B42C 4C:B= ;CC cKdd|ji}|jj|jd||4d{}|jdk7rt d||j d{}dddd{ td i}|S7W7$7#1d{7swY&xYw#t$r}t d|d}~wwxYww) z,Internal method to get room details by name.r|r}rrNrzRoom not found: rr) rlrmgetrkrrrrTr )rEr\rrrrrs r ruz#DailyRESTHelper._get_room_from_names"gd.@.@-A$BC''++!!"') 5w,  " " xx3"29+ >??>D  " " 6"*T*D  " "  " " " " 6045 5 6s~ACBC1B"9B:B"> C B  C B7CB" C"B4(B+ )B40C7 CCCC)iFTN)rrrrraiohttp ClientSessionrorsrTrwrKrrHrrrhrrrrurrr rjrjs7 // / !.. /$ +# +# + 9 9 9OB%#(48 >>>! >  > 01 > >@ 9 9 934,3?rrj)rrtypingrrrrr urllib.parserrpydanticr r r r rr"r*r,rKrTr[rhrjrrr rs  55!BB##,#Y#&# #&37)37l Qi Q i ,&1)&1R ai ar