@@ -0,0 +293,4 @@
+    Path(id): Path<i64>,
+) -> Result<(StatusCode, Json<Accepted>), ApiError> {
+    load_movie(&state, id).await?;
+    state.send_movie_command(MovieCommand::Search { movie_id: id });

@@ -0,0 +340,4 @@
+    responses((status = 200, body = AttentionQueues), (status = 503, body = ErrorBody))
+)]
+pub async fn attention(State(state): State<AppState>) -> Result<Json<AttentionQueues>, ApiError> {
+    let no_pt_source = sqlx::query_as!(Movie, r#"SELECT id AS "id!: i64", tmdb_id AS "tmdb_id!: i64", title AS "title!: String", year, original_language, root_id AS "root_id!: i64", wanted AS "wanted!: bool", overrides AS "overrides!: serde_json::Value", state AS "state!: String", blocked AS "blocked!: bool", search_attempts AS "search_attempts!: i64", last_searched_at FROM movies WHERE id IN (SELECT m.id FROM movies m JOIN roots root ON root.id = m.root_id WHERE root.audience = 'kids' AND m.wanted = 1 AND m.state = 'missing' AND m.search_attempts > 0 AND NOT EXISTS (SELECT 1 FROM movie_releases mr JOIN releases r ON r.id = mr.release_id WHERE mr.movie_id = m.id AND r.verdict IN ('eligible', 'waived'))) ORDER BY title"#)

@@ -73,12 +86,38 @@ impl AppState {
     /// If the TLS backend cannot be initialised.
     pub fn new(upstreams: Upstreams) -> Result<Self, reqwest::Error> {
         let http = reqwest::Client::builder().timeout(PROBE_TIMEOUT).build()?;
+        let (movie_commands, pending_movie_commands) = broadcast::channel(64);