feat(readarr): delete Readarr tags and expose the command on the CLI
This commit is contained in:
5 files changed
+251
-1
No files matched your search
@@ -17,6 +17,7 @@ mod readarr_network_tests;
|
||||
#[derive(Debug, Eq, PartialEq, Clone)]
|
||||
pub enum ReadarrEvent {
|
||||
AddTag(String),
|
||||
DeleteTag(i64),
|
||||
GetDiskSpace,
|
||||
GetHostConfig,
|
||||
GetLogs(u64),
|
||||
@@ -46,7 +47,7 @@ impl NetworkResource for ReadarrEvent {
|
||||
ReadarrEvent::GetRootFolders => "/rootfolder",
|
||||
ReadarrEvent::GetStatus => "/system/status",
|
||||
ReadarrEvent::GetTasks => "/system/task",
|
||||
ReadarrEvent::AddTag(_) | ReadarrEvent::GetTags => "/tag",
|
||||
ReadarrEvent::AddTag(_) | ReadarrEvent::DeleteTag(_) | ReadarrEvent::GetTags => "/tag",
|
||||
ReadarrEvent::GetUpdates => "/update",
|
||||
}
|
||||
}
|
||||
@@ -65,6 +66,10 @@ impl Network<'_, '_> {
|
||||
) -> Result<ReadarrSerdeable> {
|
||||
match readarr_event {
|
||||
ReadarrEvent::AddTag(tag) => self.add_readarr_tag(tag).await.map(ReadarrSerdeable::from),
|
||||
ReadarrEvent::DeleteTag(tag_id) => self
|
||||
.delete_readarr_tag(tag_id)
|
||||
.await
|
||||
.map(ReadarrSerdeable::from),
|
||||
ReadarrEvent::GetDiskSpace => self
|
||||
.get_readarr_diskspace()
|
||||
.await
|
||||
@@ -201,4 +206,23 @@ impl Network<'_, '_> {
|
||||
})
|
||||
.await
|
||||
}
|
||||
|
||||
async fn delete_readarr_tag(&mut self, id: i64) -> Result<()> {
|
||||
info!("Deleting Readarr tag with ID: {id}");
|
||||
let event = ReadarrEvent::DeleteTag(id);
|
||||
|
||||
let request_props = self
|
||||
.request_props_from(
|
||||
event,
|
||||
RequestMethod::Delete,
|
||||
None::<()>,
|
||||
Some(format!("/{id}")),
|
||||
None,
|
||||
)
|
||||
.await;
|
||||
|
||||
self
|
||||
.handle_request::<(), ()>(request_props, |_, _| ())
|
||||
.await
|
||||
}
|
||||
}
|
||||
@@ -23,6 +23,7 @@ mod tests {
|
||||
#[case(ReadarrEvent::GetStatus, "/system/status")]
|
||||
#[case(ReadarrEvent::GetTasks, "/system/task")]
|
||||
#[case(ReadarrEvent::AddTag(String::new()), "/tag")]
|
||||
#[case(ReadarrEvent::DeleteTag(1), "/tag")]
|
||||
#[case(ReadarrEvent::GetTags, "/tag")]
|
||||
#[case(ReadarrEvent::GetUpdates, "/update")]
|
||||
fn test_resource(#[case] event: ReadarrEvent, #[case] expected_uri: &str) {
|
||||
@@ -410,4 +411,39 @@ mod tests {
|
||||
assert_err!(result);
|
||||
assert_eq!(app.lock().await.data.readarr_data.tags_map, seeded_map);
|
||||
}
|
||||
|
||||
#[tokio::test]
|
||||
async fn test_handle_delete_readarr_tag_event() {
|
||||
let (mock, app, _server) = MockServarrApi::delete()
|
||||
.path("/1")
|
||||
.build_for(ReadarrEvent::DeleteTag(1))
|
||||
.await;
|
||||
app.lock().await.server_tabs.set_index(3);
|
||||
let mut network = test_network(&app);
|
||||
|
||||
let result = network
|
||||
.handle_readarr_event(ReadarrEvent::DeleteTag(1))
|
||||
.await;
|
||||
|
||||
mock.assert_async().await;
|
||||
assert_ok!(result);
|
||||
}
|
||||
|
||||
#[tokio::test]
|
||||
async fn test_handle_delete_readarr_tag_event_failure() {
|
||||
let (mock, app, _server) = MockServarrApi::delete()
|
||||
.path("/1")
|
||||
.status(500)
|
||||
.build_for(ReadarrEvent::DeleteTag(1))
|
||||
.await;
|
||||
app.lock().await.server_tabs.set_index(3);
|
||||
let mut network = test_network(&app);
|
||||
|
||||
let result = network
|
||||
.handle_readarr_event(ReadarrEvent::DeleteTag(1))
|
||||
.await;
|
||||
|
||||
mock.assert_async().await;
|
||||
assert_err!(result);
|
||||
}
|
||||
}
|
||||
Reference in new issue
Block a user