o i;@sdZddlZddlmZmZmZmZmZddlm Z ddl Z ddl m Z m Z mZmZGddde ZGdd d e ZGd d d e ZGd d d e ZGddde ZGddde ZGddde ZGddde ZGdddZdS)zoDaily REST Helpers. Methods that wrap the Daily API to create rooms, check room URLs, and get meeting tokens. N)AnyDictListLiteralOptional)urlparse) BaseModel ConfigDictFieldValidationErrorc@sneZdZUdZdZeed<dZeed<dZ eed<dZ e ed <d Z e eeeefed <d Ze eed <d S) 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__r str__annotations__rboolrrintrrrrrrrR/home/ubuntu/.local/lib/python3.10/site-packages/pipecat/transports/daily/utils.pyr s    r c@6eZdZUdZeed<eed<eed<dZeed<dS)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#rrrrrr*  rc@r)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$rrrrr&=r%r&c@seZdZUdZeddZdZeee 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!defddZ"dS)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', 'cloud-audio-only', '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_offreturncCs|jsdSd|jdS)zGet the SIP endpoint URI if available. Returns: SIP endpoint URI or empty string if not available. zsip:%sendpoint)r:)selfrrr sip_endpointysz DailyRoomProperties.sip_endpoint)#rrrrr model_configr*rfloatrr+rr,r-r.r/r3rr4r5rr6rr7rr8r&r9r r:rrr;propertyr@rrrrr'Ps(       r'c@sDeZdZUdZdZeeed<dZe ded<e e dZ e ed<dS) 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)privaterFprivacydefault_factory properties) rrrrrErrrrHrr r'rKrrrrrDs rDc@sJeZdZUdZeed<eed<eed<eed<eed<eed<eed<d S) DailyRoomObjectaRepresents a Daily room returned by the API. Parameters: id: Unique room identifier. name: Room name. api_created: Whether room was created via API. privacy: Room privacy setting ('private' or 'public'). url: Full URL for joining the room. created_at: Timestamp of room creation in ISO 8601 format (e.g., "2019-01-26T09:01:22.000Z"). config: Room configuration properties. idrE api_createdrHurl created_atconfigN)rrrrrrrr'rrrrrLs   rLc@seZdZUdZdZeeed<dZee ed<dZ ee ed<dZ ee ed<dZ ee ed<dZee ed<dZeeed <dZeeed <dZee ed <dZee ed <dZee ed <dZeeded<dZee ed<dZee ed<dZeeeefed<dS)DailyMeetingTokenPropertiesa}Properties for configuring 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#properties Parameters: room_name: The room for which this token is valid. If not set, the token is valid for all rooms in your domain. eject_at_token_exp: If True, the user will be ejected from the room when the token expires. eject_after_elapsed: The number of seconds after which the user will be ejected from the room. nbf: Not before timestamp - users cannot join with this token before this time. exp: Expiration time (unix timestamp in seconds). Strongly recommended for security. is_owner: If True, the token will grant owner privileges in the room. user_name: The name of the user. This will be added to the token payload. user_id: A unique identifier for the user. This will be added to the token payload. enable_screenshare: If True, the user will be able to share their screen. start_video_off: If True, the user's video will be turned off when they join the room. start_audio_off: If True, the user's audio will be turned off when they join the room. enable_recording: Recording settings for the token. Must be one of 'cloud', 'cloud-audio-only', 'local' or 'raw-tracks'. enable_prejoin_ui: If True, the user will see the prejoin UI before joining the room. start_cloud_recording: Start cloud recording when the user joins the room. permissions: Specifies the initial default permissions for a non-meeting-owner participant. N room_nameeject_at_token_expeject_after_elapsednbfr*is_owner user_nameuser_idenable_screensharer;start_audio_offr0r3r,start_cloud_recording permissions)rrrrrSrrrrTrrUrrVr*rWrXrYrZr;r[r3rr,r\r]rrrrrrrRs" rRc@s$eZdZUdZeedZeed<dS)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. rIrKN)rrrrr rRrKrrrrrr^s  r^c @seZdZdZdddededejfddZd ed efd d Zd ed e fd dZ de d e fddZ    d"d ede dededeed ef ddZd ed efddZded efddZded e fd d!ZdS)#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_keyr`aiohttp_sessioncCs||_||_||_dS)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)rar`rb)r?rar`rbrrr__init__s zDailyRESTHelper.__init__room_urlr<cCst|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)r?rdrrrget_name_from_urls z!DailyRESTHelper.get_name_from_urlc||}||IdHS)zGet room details from a Daily room URL. Args: room_url: Full Daily room URL. Returns: DailyRoomObject instance for the room. N)rf_get_room_from_namer?rdrSrrrget_room_from_url z!DailyRESTHelper.get_room_from_urlparamsc sdd|ji}|jdd}|jj|jd||d4IdH)}|jdkr8|IdH}td |jd ||IdH}WdIdHn 1IdHsOwYz t d i|}W|St yq}ztd |d}~ww) 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) ra model_dumprbpostr`statustext ExceptionrsrLr ) r?rlrrrsrrzdataroomerrr create_rooms&  ( zDailyRESTHelper.create_roomFTN expiry_timerTownerc s|stdtt|}||}dd|ji}|dur,tt||||dd}n||j_||j_ ||j_ ||j_ |j dd} |j j|jd || d 4IdH,} | jd krk| IdH} td | jd | | IdH} WdIdH| dS1IdHswY| dS)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.rmrnN)rSrWr*rT)rKTroz/meeting-tokensrqrtz(Failed to create meeting token (status: rutoken)r{rtimerfrar^rRrKrSr*rTrWrwrbrxr`ryrzrs) r?rdrrTrrl expirationrSrrrsr|rzr}rrr get_token-sD      zDailyRESTHelper.get_tokencrg)zDelete a room using its URL. Args: room_url: Daily room URL. Returns: True if deletion was successful. N)rfdelete_room_by_namerirrrdelete_room_by_urlmrkz"DailyRESTHelper.delete_room_by_urlrSc sdd|ji}|jj|jd||d4IdH+}|jdkr;|jdkr;|IdH}td|d |jd |WdIdHd S1IdHsLwYd S) 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). rmrn/rooms/rrNrtizFailed to delete room [z ] (status: ruT)rarbdeleter`ryrzr{)r?rSrrr|rzrrrrys z#DailyRESTHelper.delete_room_by_namec sdd|ji}|jj|jd||d4IdH}|jdkr(td||IdH}WdIdHn 1IdHs?wYz td i|}W|Stya}ztd|d}~ww) z,Internal method to get room details by name.rmrnrrNrtzRoom not found: rvr) rarbgetr`ryr{rsrLr )r?rSrrr|r}r~rrrrrhs" (z#DailyRESTHelper._get_room_from_name)rFTN)rrrrraiohttp ClientSessionrcrfrLrjrDrrBrrr^rrrrhrrrrr_sB    ! @ r_)rrtypingrrrrr urllib.parserrpydanticrr r r r rr&r'rDrLrRr^r_rrrrs 6)