yolo/arr
3
0
Fork 0
Code Issues 12 Pull Requests Actions Packages Projects Releases Wiki Activity

style: cargo fmt

Browse Source
This commit is contained in:
Miguel Palhas
2026-08-23 19:35:07 +01:00
parent 409967eef6
commit 00ff4db26a
1 changed files with 39 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/arr-daemon/src/series_refresh.rs
+39 -27
View File
@@ -627,12 +627,15 @@ mod tests {
async fn mount_with(server: &MockServer, status: &str, numbers: &[u32]) {
Mock::given(method("GET"))
.and(path("/tv/82728"))
.respond_with(ResponseTemplate::new(200).set_body_json(series_body_with(
status, numbers,
)))
.respond_with(
ResponseTemplate::new(200).set_body_json(series_body_with(status, numbers)),
)
.mount(server)
.await;
for (number, body) in [(1u32, season_one_body(&two_episodes())), (2, season_two_body())] {
for (number, body) in [
(1u32, season_one_body(&two_episodes())),
(2, season_two_body()),
] {
if !numbers.contains(&number) {
continue;
}
@@ -644,7 +647,6 @@ mod tests {
}
}
/// A TMDB serving one series with two seasons. `reset` between phases of
/// a test and remount, counting requests by delta around each phase.
async fn tmdb(status: &str, season_one: serde_json::Value) -> MockServer {
@@ -1110,26 +1112,29 @@ mod tests {
let outcomes = action(&server).tick(&database).await.unwrap();
assert_eq!(outcomes.len(), 1, "a season removal is work worth reporting");
let seasons: Vec<i64> =
sqlx::query_scalar("SELECT number FROM seasons ORDER BY number")
.fetch_all(database.pool())
.await
.unwrap();
assert_eq!(
outcomes.len(),
1,
"a season removal is work worth reporting"
);
let seasons: Vec<i64> = sqlx::query_scalar("SELECT number FROM seasons ORDER BY number")
.fetch_all(database.pool())
.await
.unwrap();
assert_eq!(seasons, vec![1]);
let episodes: i64 =
sqlx::query_scalar("SELECT count(*) FROM episodes WHERE season_id NOT IN (SELECT id FROM seasons)")
.fetch_one(database.pool())
.await
.unwrap();
assert_eq!(episodes, 0, "the vanished season's episodes cascade");
let releases: i64 = sqlx::query_scalar(
"SELECT count(*) FROM episode_releases WHERE episode_id = ?",
let episodes: i64 = sqlx::query_scalar(
"SELECT count(*) FROM episodes WHERE season_id NOT IN (SELECT id FROM seasons)",
)
.bind(episode)
.fetch_one(database.pool())
.await
.unwrap();
assert_eq!(episodes, 0, "the vanished season's episodes cascade");
let releases: i64 =
sqlx::query_scalar("SELECT count(*) FROM episode_releases WHERE episode_id = ?")
.bind(episode)
.fetch_one(database.pool())
.await
.unwrap();
assert_eq!(releases, 0);
}
@@ -1185,7 +1190,12 @@ mod tests {
expire_refresh(&database).await;
// TMDB puts the season back where it was.
server.reset().await;
mount(&server, "Returning Series", season_one_body(&two_episodes())).await;
mount(
&server,
"Returning Series",
season_one_body(&two_episodes()),
)
.await;
let outcomes = action(&server).tick(&database).await.unwrap();
@@ -1215,12 +1225,14 @@ mod tests {
let outcomes = action(&server).tick(&database).await.unwrap();
assert!(outcomes.is_empty(), "churning specials is not work to report");
let seasons: Vec<i64> =
sqlx::query_scalar("SELECT number FROM seasons ORDER BY number")
.fetch_all(database.pool())
.await
.unwrap();
assert!(
outcomes.is_empty(),
"churning specials is not work to report"
);
let seasons: Vec<i64> = sqlx::query_scalar("SELECT number FROM seasons ORDER BY number")
.fetch_all(database.pool())
.await
.unwrap();
assert_eq!(seasons, vec![0, 1, 2]);
}
}