From d8281c70a52bd03bc349e4525cf91c081bf75b17 Mon Sep 17 00:00:00 2001 From: Jordan Petridis Date: Sun, 10 Dec 2017 06:11:03 +0200 Subject: [PATCH] Better naming of a dbquery function. --- hammond-data/src/dbqueries.rs | 7 +------ hammond-data/src/models/insertables.rs | 5 ++--- hammond-data/src/utils.rs | 14 ++++++-------- 3 files changed, 9 insertions(+), 17 deletions(-) diff --git a/hammond-data/src/dbqueries.rs b/hammond-data/src/dbqueries.rs index f83bc0b..391ec6e 100644 --- a/hammond-data/src/dbqueries.rs +++ b/hammond-data/src/dbqueries.rs @@ -155,12 +155,7 @@ pub fn get_podcast_from_source_id(sid: i32) -> Result { .get_result::(&*con)?) } -// TODO: unhack me -pub fn get_episode_from_new_episode( - con: &SqliteConnection, - title_: &str, - pid: i32, -) -> QueryResult { +pub fn get_episode_from_pk(con: &SqliteConnection, title_: &str, pid: i32) -> QueryResult { use schema::episode::dsl::*; episode diff --git a/hammond-data/src/models/insertables.rs b/hammond-data/src/models/insertables.rs index e63f64d..c847a2e 100644 --- a/hammond-data/src/models/insertables.rs +++ b/hammond-data/src/models/insertables.rs @@ -193,7 +193,7 @@ impl NewEpisode { // TODO: Refactor into batch indexes instead. pub(crate) fn into_episode(self, con: &SqliteConnection) -> Result { self.index(con)?; - Ok(dbqueries::get_episode_from_new_episode( + Ok(dbqueries::get_episode_from_pk( con, &self.title, self.podcast_id, @@ -201,8 +201,7 @@ impl NewEpisode { } pub(crate) fn index(&self, con: &SqliteConnection) -> QueryResult<()> { - // TODO: Change me - let ep = dbqueries::get_episode_from_new_episode(con, &self.title, self.podcast_id); + let ep = dbqueries::get_episode_from_pk(con, &self.title, self.podcast_id); match ep { Ok(foo) => { diff --git a/hammond-data/src/utils.rs b/hammond-data/src/utils.rs index 42a6af7..fb9fe1e 100644 --- a/hammond-data/src/utils.rs +++ b/hammond-data/src/utils.rs @@ -162,10 +162,8 @@ mod tests { .into_episode(&con) .unwrap(); - let mut ep1 = - dbqueries::get_episode_from_new_episode(&con, n1.title(), n1.podcast_id()).unwrap(); - let mut ep2 = - dbqueries::get_episode_from_new_episode(&con, n2.title(), n2.podcast_id()).unwrap(); + let mut ep1 = dbqueries::get_episode_from_pk(&con, n1.title(), n1.podcast_id()).unwrap(); + let mut ep2 = dbqueries::get_episode_from_pk(&con, n2.title(), n2.podcast_id()).unwrap(); ep1.set_local_uri(Some(valid_path.to_str().unwrap())); ep2.set_local_uri(Some(bad_path.to_str().unwrap())); @@ -192,7 +190,7 @@ mod tests { let mut episode = { let db = connection(); let con = db.get().unwrap(); - dbqueries::get_episode_from_new_episode(&con, "bar_baz", 1).unwrap() + dbqueries::get_episode_from_pk(&con, "bar_baz", 1).unwrap() }; checker_helper(&mut episode); @@ -205,7 +203,7 @@ mod tests { let mut episode = { let db = connection(); let con = db.get().unwrap(); - dbqueries::get_episode_from_new_episode(&con, "foo_bar", 0).unwrap() + dbqueries::get_episode_from_pk(&con, "foo_bar", 0).unwrap() }; let valid_path = episode.local_uri().unwrap().to_owned(); @@ -219,7 +217,7 @@ mod tests { let mut episode = { let db = connection(); let con = db.get().unwrap(); - dbqueries::get_episode_from_new_episode(&con, "foo_bar", 0).unwrap() + dbqueries::get_episode_from_pk(&con, "foo_bar", 0).unwrap() }; let now_utc = Utc::now().timestamp() as i32; // let limit = now_utc - 172_800; @@ -239,7 +237,7 @@ mod tests { let mut episode = { let db = connection(); let con = db.get().unwrap(); - dbqueries::get_episode_from_new_episode(&con, "foo_bar", 0).unwrap() + dbqueries::get_episode_from_pk(&con, "foo_bar", 0).unwrap() }; let now_utc = Utc::now().timestamp() as i32; // limit = 172_800;