Added non working query.

src/controllers/websocket_controller.rs

@@ -31,6 +31,11 @@ pub async fn start_connection(
     Ok(resp)
 }
 
+#[derive(Deserialize, Serialize)]
+struct RSSQuery {
+    top: Option<i32>
+}
+
 #[utoipa::path(
 context_path = "/api/v1",
 responses(
@@ -40,14 +45,29 @@ responses(
 pub async fn get_rss_feed(
     podcast_episode_service: Data<Mutex<PodcastEpisodeService>>,
     db: Data<DbPool>, env: Data<Mutex<EnvironmentService>>,
+    query: Option<web::Query<RSSQuery>>,
 ) -> Result<HttpResponse, CustomError> {
     let env = env.lock().ignore_poison();
     let mut podcast_service = podcast_episode_service
         .lock()
         .ignore_poison();
-    let downloaded_episodes = podcast_service
-        .find_all_downloaded_podcast_episodes(&mut db.get()
-            .unwrap(), env.clone())?;
+    let downloaded_episodes;
+
+    match query {
+        Some(q) => {
+            downloaded_episodes = podcast_service
+                .find_all_downloaded_podcast_episodes(&mut db.get()
+                    .unwrap(), env.clone())?
+                .into_iter()
+                .take(q.top.unwrap_or(10) as usize)
+                .collect::<Vec<PodcastEpisode>>();
+        },
+        None => {
+            downloaded_episodes = podcast_service
+                .find_all_downloaded_podcast_episodes(&mut db.get()
+                    .unwrap(), env.clone())?;
+        }
+    }
 
     let server_url = env.get_server_url();
 

src/models/podcast_episode.rs

@@ -1,7 +1,7 @@
 use crate::dbconfig::schema::*;
 use chrono::{DateTime, Duration, NaiveDateTime, Utc};
 use diesel::prelude::{Queryable, Identifiable, Selectable, QueryableByName};
-use diesel::{BoolExpressionMethods, delete, insert_into, OptionalExtension, RunQueryDsl, TextExpressionMethods};
+use diesel::{BoolExpressionMethods, delete, insert_into, JoinOnDsl, NullableExpressionMethods, OptionalExtension, RunQueryDsl, TextExpressionMethods};
 use diesel::dsl::sql;
 use utoipa::ToSchema;
 use diesel::sql_types::{Integer, Text, Nullable, Timestamp, Bool};
@@ -406,4 +406,30 @@ impl PodcastEpisode{
             .execute(conn)
             .map_err(map_db_error)
     }
+
+    pub fn get_podcast_episodes_by_podcast_to_k(conn: &mut DbConnection, top_k: i32){
+        use crate::dbconfig::schema::podcast_episodes::dsl::*;
+        use crate::dbconfig::schema::podcast_episodes::dsl::podcast_id as podcast_id_column;
+        use crate::dbconfig::schema::podcast_episodes as p_episode;
+        use crate::dbconfig::schema::podcasts::dsl::id as p_id;
+        use crate::dbconfig::schema::podcasts as podcast_1;
+
+        let (podcast_episode1, podcast_episode2) = diesel::alias!(p_episode as p1,
+            p_episode as p2);
+
+        let (podcast_in_table) = diesel::alias!(podcast_1 as p1);
+
+        let result = podcast_episode1
+            .inner_join(podcast_episode1.on(podcast_episode1.field(podcast_id).eq
+            (podcast_in_table.field(p_id))))
+            .filter(podcast_episode1.field(date_of_recording).eq_any(
+                podcast_episode2.select(podcast_episode2.field(date_of_recording))
+                    .filter(podcast_episode2.field(podcast_id_column)
+                        .eq(podcast_in_table.field(podcast_id)))
+                    .order(podcast_episode2.field(date_of_recording).desc())
+                    .limit(top_k.into())
+            ))
+            .load::<(Podcast,PodcastEpisode)>(conn)
+            .expect("Error loading podcasts");
+    }
 }

src/service/podcast_episode_service.rs

@@ -366,6 +366,13 @@ impl PodcastEpisodeService {
         self.map_rss_podcast_episodes(env, result)
     }
 
+    pub fn find_all_downloaded_podcast_episodes_with_top_k(&mut self, conn: &mut DbConnection,
+                                                           env: EnvironmentService, top_k: i32)
+        -> Result<Vec<PodcastEpisode>, CustomError> {
+        PodcastEpisode::get_podcast_episodes_by_podcast_to_k(conn, top_k)
+    }
+
+
     fn map_rss_podcast_episodes(&mut self, env: EnvironmentService, result: Vec<PodcastEpisode>)
                                 -> Result<Vec<PodcastEpisode>, CustomError> {
         Ok(result