qobuz-api 1.0.0

A Rust client library for the Qobuz music streaming API
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73

//! Delegate macros for bridging async API functions into the synchronous service layer.

/// Delegates to an async function via a blocking Tokio runtime.
macro_rules! delegate {
    ($vis:vis fn $name:ident($($arg:ident: $ty:ty),* $(,)?) -> $ret:ty = $path:path) => {
        #[doc = concat!("Delegates to [`", stringify!($path), "`].")]
        #[doc = ""]
        #[doc = "# Errors"]
        #[doc = ""]
        #[doc = "Returns a `QobuzApiError` if not authenticated or the API request fails."]
        $vis fn $name(&self $(, $arg: $ty)*) -> Result<$ret, crate::errors::QobuzApiError> {
            let rt = tokio::runtime::Runtime::new()?;
            rt.block_on($path(self $(, $arg)*))
        }
    };
}

/// Internal helper: the retry-on-signature-error body shared by retry macros.
macro_rules! retry_body {
    ($path:path, $rt:ident, $self:ident, first: ($($first_args:tt)*), retry: ($($retry_args:tt)*)) => {
        {
            let result = $rt.block_on($path($self, $($first_args)*));
            match result {
                Err(crate::errors::QobuzApiError::ApiErrorResponse { message, .. })
                    if message.contains("Invalid Request Signature") =>
                {
                    tracing::info!(
                        concat!(
                            "Signature invalid for ",
                            stringify!($path),
                            ", refreshing credentials"
                        )
                    );

                    crate::api::auth::refresh_app_credentials($self)?;

                    $rt.block_on($path($self, $($retry_args)*))
                }
                other => other,
            }
        }
    };
}

/// Delegates to an async function with automatic credential refresh on signature errors.
macro_rules! delegate_with_retry {
    ($vis:vis fn $name:ident($($arg:ident: $ty:ty),* $(,)?) -> $ret:ty = $path:path) => {
        #[doc = concat!("Delegates to [`", stringify!($path), "`] with auto-refresh on signature errors.")]
        #[doc = ""]
        #[doc = "# Errors"]
        #[doc = ""]
        #[doc = "Returns a `QobuzApiError` if not authenticated, the API request fails, or refresh fails."]
        $vis fn $name(&mut self $(, $arg: $ty)*) -> Result<$ret, crate::errors::QobuzApiError> {
            let rt = tokio::runtime::Runtime::new()?;
            retry_body!($path, rt, self, first: ($($arg),*), retry: ($($arg),*))
        }
    };
}

/// Delegates to an async function with auto-refresh and a cancel parameter.
macro_rules! delegate_with_retry_cancellable {
    ($vis:vis fn $name:ident($($arg:ident: $ty:ty),* $(,)?) -> $ret:ty = $path:path, cancel: $cancel_ty:ty) => {
        #[doc = concat!("Delegates to [`", stringify!($path), "`] with auto-refresh on signature errors.")]
        #[doc = ""]
        #[doc = "# Errors"]
        #[doc = ""]
        #[doc = "Returns a `QobuzApiError` if not authenticated, the API request fails, or refresh fails."]
        $vis fn $name(&mut self $(, $arg: $ty)*, cancel: $cancel_ty) -> Result<$ret, crate::errors::QobuzApiError> {
            let rt = tokio::runtime::Runtime::new()?;
            retry_body!($path, rt, self, first: ($($arg),*, cancel.clone()), retry: ($($arg),*, cancel))
        }
    };
}