entertainarr-adapter-http 0.1.1

HTTP adapter for entertainarr
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

use axum::Json;
use axum::extract::{Path, State};
use entertainarr_domain::podcast::prelude::PodcastService;
use serde_qs::axum::QsQuery;

use crate::entity::ApiResource;
use crate::entity::podcast_episode::{
    ListPodcastEpisodeParams, PodcastEpisodeDocument, PodcastEpisodeRelation,
};
use crate::server::extractor::user::CurrentUser;
use crate::server::handler::error::ApiErrorResponse;
use crate::server::handler::prelude::FromDomainResponse;

pub async fn handle<S>(
    State(state): State<S>,
    CurrentUser(user_id): CurrentUser,
    Path(podcast_id): Path<u64>,
    QsQuery(params): QsQuery<ListPodcastEpisodeParams>,
) -> Result<Json<ApiResource<Vec<PodcastEpisodeDocument>, PodcastEpisodeRelation>>, ApiErrorResponse>
where
    S: crate::server::prelude::ServerState,
{
    let response = state
        .podcast_service()
        .list_podcast_episode(
            entertainarr_domain::podcast::entity::ListPodcastEpisodeParams {
                user_id,
                filter: entertainarr_domain::podcast::entity::ListPodcastEpisodeFilter {
                    podcast_ids: &[podcast_id],
                    filtered: Some(false),
                    subscribed: None,
                    watched: None,
                },
                sort: params.sort.into(),
                page: params.page.into(),
            },
        )
        .await
        .map_err(|err| {
            tracing::error!(error = ?err, "unable to list podcast episodes");
            ApiErrorResponse::internal()
        })?;

    Ok(Json(ApiResource::from_response(response, params.include)))
}