hNVddlmZmZddlmZmZmZmZddlZddl m Z GddeZ y))ABCabstractmethod)AnyDictOptionalUnionN)verbose_loggerceZdZdZe ddedeedeee e jfdeefdZ e ddedeedeee e jfdeefdZ e dded ed eedeedeee e jfdeeeff d Ze dded eedeedeee e jfdef d Z ddedededeedeee e jfdef dZy)BaseSecretManagerzD Abstract base class for secret management implementations. N secret_nameoptional_paramstimeoutreturnc Kyw)a Asynchronously read a secret from the secret manager. Args: secret_name (str): Name/path of the secret to read optional_params (Optional[dict]): Additional parameters specific to the secret manager timeout (Optional[Union[float, httpx.Timeout]]): Request timeout Returns: Optional[str]: The secret value if found, None otherwise Nselfr r rs g/var/www/Befach/backend/env/lib/python3.12/site-packages/litellm/secret_managers/base_secret_manager.pyasync_read_secretz#BaseSecretManager.async_read_secrets $ cy)a Synchronously read a secret from the secret manager. Args: secret_name (str): Name/path of the secret to read optional_params (Optional[dict]): Additional parameters specific to the secret manager timeout (Optional[Union[float, httpx.Timeout]]): Request timeout Returns: Optional[str]: The secret value if found, None otherwise Nrrs rsync_read_secretz"BaseSecretManager.sync_read_secret"s$ secret_value descriptionc Kyw)ak Asynchronously write a secret to the secret manager. Args: secret_name (str): Name/path of the secret to write secret_value (str): Value to store description (Optional[str]): Description of the secret. Some secret managers allow storing a description with the secret. optional_params (Optional[dict]): Additional parameters specific to the secret manager timeout (Optional[Union[float, httpx.Timeout]]): Request timeout Returns: Dict[str, Any]: Response from the secret manager containing write operation details Nr)rr rrr rs rasync_write_secretz$BaseSecretManager.async_write_secret6s * rrecovery_window_in_daysc Kyw)a Async function to delete a secret from the secret manager Args: secret_name: Name of the secret to delete recovery_window_in_days: Number of days before permanent deletion (default: 7) optional_params: Additional parameters specific to the secret manager timeout: Request timeout Returns: dict: Response from the secret manager containing deletion details Nr)rr rr rs rasync_delete_secretz%BaseSecretManager.async_delete_secretMs ( rcurrent_secret_namenew_secret_namenew_secret_valuecK |j|||d{}|td|d|j||d|||d{}|j|||d{}|td||j|d|| d{|S77Q777 #tj $rZ} t jd t| jjtd | jjd} ~ wtj$r td t$r%} t jd t| d} ~ wwxYww) ak Async function to rotate a secret by creating a new one and deleting the old one. This allows for both value and name changes during rotation. Args: current_secret_name: Current name of the secret new_secret_name: New name for the secret new_secret_value: New value for the secret optional_params: Additional AWS parameters timeout: Request timeout Returns: dict: Response containing the new secret details Raises: ValueError: If the secret doesn't exist or if there's an HTTP error )r r rNzCurrent secret z not foundz Rotated from )r rrr rzFailed to verify new secret )r rr rz0Error rotating secret in AWS Secrets Manager: %szHTTP error occurred: zTimeout error occurred) r ValueErrorrr httpxHTTPStatusErrorr exceptionstrresponsetextTimeoutException Exception) rr!r"r#r r old_secretcreate_response new_secreterres rasync_rotate_secretz%BaseSecretManager.async_rotate_secretcs24 #55/ / 6 J ! ?3F2Gz!RSS%)$;$;+-+,?+@A / %<%O $55+ / 6 J ! #??P!QRR**/() / +  # "I $$ J  $ $BCLL%%& 4S\\5F5F4GHI I%% 756 6   $ $BCF    s{EB%B1B% BB%)B!*,B%B#B%EB%B%!B%#B%%E8AD  )E6 EEE)NN)NNN)r%NN)__name__ __module__ __qualname____doc__rr*rdictrfloatr'Timeoutrrrrrintr r4rrrr r s +/9=   "$ %u}} 456  #   &+/9=   "$ %u}} 456  #   & &**.9=    c]  "$  %u}} 456   c3h  ,23*.9=   "*# "$  %u}} 456     4+/9= M MM M "$ M %u}} 456 M Mrr ) abcrrtypingrrrrr'litellmr r rrrr@s"#-- "ggr