feat(readarr): fetch releases for an author and expose them on the CLI

This commit is contained in:
Dark-Alex-17 committed 2026-08-28 14:15:28 -06:00
1 parent 666084a30f
commit 999a22a37f
6 files changed
+203 -4

No files matched your search

@@ -5,7 +5,7 @@ use serde_json::{Value, json};
use crate::models::Route;
use crate::models::readarr_models::{
AddAuthorBody, AddAuthorSearchResult, Author, DeleteParams, EditAuthorParams, ReadarrCommandBody,
ReadarrHistoryItem,
ReadarrHistoryItem, ReadarrRelease,
};
use crate::models::servarr_data::readarr::readarr_data::ActiveReadarrBlock;
use crate::models::stateful_table::StatefulTable;
@@ -217,6 +217,30 @@ impl Network<'_, '_> {
.await
}
pub(in crate::network::readarr_network) async fn get_author_releases(
&mut self,
author_id: i64,
) -> Result<Vec<ReadarrRelease>> {
info!("Fetching releases for Readarr author with ID: {author_id}");
let event = ReadarrEvent::GetAuthorReleases(author_id);
let request_props = self
.request_props_from(
event,
RequestMethod::Get,
None::<()>,
None,
Some(format!("authorId={author_id}")),
)
.await;
self
.handle_request::<(), Vec<ReadarrRelease>>(request_props, |release_vec, mut app| {
app.data.readarr_data.author_releases.set_items(release_vec);
})
.await
}
pub(in crate::network::readarr_network) async fn get_readarr_author_history(
&mut self,
author_id: i64,
@@ -10,8 +10,9 @@ mod tests {
use crate::network::network_tests::test_utils::{MockServarrApi, test_network};
use crate::network::readarr_network::ReadarrEvent;
use crate::network::readarr_network::readarr_network_test_utils::test_utils::{
ADD_AUTHOR_SEARCH_RESULT_JSON, AUTHOR_JSON, add_author_body, readarr_history_item,
stale_add_author_search_result, stale_author, stale_readarr_history_item,
ADD_AUTHOR_SEARCH_RESULT_JSON, AUTHOR_JSON, RELEASE_JSON, add_author_body,
readarr_history_item, stale_add_author_search_result, stale_author, stale_readarr_history_item,
stale_release, torrent_release, usenet_release,
};
use bimap::BiMap;
use mockito::Matcher;
@@ -76,6 +77,97 @@ mod tests {
assert_err!(result);
}
#[tokio::test]
async fn test_handle_get_author_releases_event() {
let expected_releases = vec![torrent_release(), usenet_release()];
let releases_json = json!([
serde_json::from_str::<Value>(RELEASE_JSON).unwrap(),
{
"guid": "test-usenet-release-guid",
"protocol": "usenet",
"age": 4492,
"title": "Test Author - Test Book [AZW3]",
"authorName": "Test Author",
"bookTitle": "Test Book",
"indexer": "DrunkenSlug",
"indexerId": 4,
"size": 313924185,
"rejected": true,
"rejections": ["Unknown quality profile", "Release is already mapped"],
"quality": {
"quality": { "id": 12, "name": "AZW3" },
"revision": { "version": 1, "real": 0, "isRepack": false }
}
}
]);
let (mock, app, _server) = MockServarrApi::get()
.returns(releases_json)
.query("authorId=3")
.build_for(ReadarrEvent::GetAuthorReleases(3))
.await;
{
let mut app = app.lock().await;
app.server_tabs.set_index(3);
app
.data
.readarr_data
.author_releases
.set_items(vec![stale_release()]);
}
let mut network = test_network(&app);
let result = network
.handle_readarr_event(ReadarrEvent::GetAuthorReleases(3))
.await;
mock.assert_async().await;
let ReadarrSerdeable::Releases(releases) = result.unwrap() else {
panic!("Expected Releases")
};
assert_eq!(releases, expected_releases);
assert_eq!(
app.lock().await.data.readarr_data.author_releases.items,
expected_releases
);
}
#[tokio::test]
async fn test_handle_get_author_releases_event_failure() {
let stale_releases = vec![stale_release()];
let (mock, app, _server) = MockServarrApi::get()
.returns(json!(
[serde_json::from_str::<Value>(RELEASE_JSON).unwrap()]
))
.status(500)
.query("authorId=3")
.build_for(ReadarrEvent::GetAuthorReleases(3))
.await;
{
let mut app = app.lock().await;
app.server_tabs.set_index(3);
app
.data
.readarr_data
.author_releases
.set_items(stale_releases.clone());
}
let mut network = test_network(&app);
let result = network
.handle_readarr_event(ReadarrEvent::GetAuthorReleases(3))
.await;
mock.assert_async().await;
assert_err!(result);
assert_eq!(
app.lock().await.data.readarr_data.author_releases.items,
stale_releases
);
}
#[rstest]
#[tokio::test]
async fn test_handle_get_readarr_author_history_event(
+6 -1
View File
@@ -38,6 +38,7 @@ pub enum ReadarrEvent {
EditAuthor(EditAuthorParams),
GetAuthorDetails(i64),
GetAuthorHistory(i64),
GetAuthorReleases(i64),
GetBookDetails(i64),
GetBookEditions(i64),
GetBookFiles(i64),
@@ -105,7 +106,7 @@ impl NetworkResource for ReadarrEvent {
ReadarrEvent::GetMetadataProfiles => "/metadataprofile",
ReadarrEvent::GetQualityProfiles => "/qualityprofile",
ReadarrEvent::DeleteDownload(_) | ReadarrEvent::GetDownloads(_) => "/queue",
ReadarrEvent::GetBookReleases(_) => "/release",
ReadarrEvent::GetAuthorReleases(_) | ReadarrEvent::GetBookReleases(_) => "/release",
ReadarrEvent::AddRootFolder(_)
| ReadarrEvent::DeleteRootFolder(_)
| ReadarrEvent::GetRootFolders => "/rootfolder",
@@ -171,6 +172,10 @@ impl Network<'_, '_> {
.get_readarr_author_history(author_id)
.await
.map(ReadarrSerdeable::from),
ReadarrEvent::GetAuthorReleases(author_id) => self
.get_author_releases(author_id)
.await
.map(ReadarrSerdeable::from),
ReadarrEvent::GetBookDetails(book_id) => self
.get_book_details(book_id)
.await
@@ -49,6 +49,7 @@ mod tests {
#[case(ReadarrEvent::GetQualityProfiles, "/qualityprofile")]
#[case(ReadarrEvent::DeleteDownload(1), "/queue")]
#[case(ReadarrEvent::GetDownloads(500), "/queue")]
#[case(ReadarrEvent::GetAuthorReleases(1), "/release")]
#[case(ReadarrEvent::GetBookReleases(1), "/release")]
#[case(
ReadarrEvent::AddRootFolder(AddReadarrRootFolderBody::default()),