Fixed the setters of the diesel querable structs, WIP of etag update refactoring.

src/models.rs

@@ -30,54 +30,48 @@ impl Episode {
         self.id
     }
 
-    // FIXME: Return &str instead of String
+    pub fn title(&self) -> Option<&str> {
-    pub fn title(self) -> Option<String> {
+        self.title.as_ref().map(|s| s.as_str())
-        self.title
     }
 
     pub fn set_title(&mut self, value: Option<String>) {
         self.title = value;
     }
 
-    // FIXME: Return &str instead of String
+    pub fn uri(&self) -> Option<&str> {
-    pub fn uri(self) -> Option<String> {
+        self.uri.as_ref().map(|s| s.as_str())
-        self.uri
     }
 
     pub fn set_uri(&mut self, value: Option<String>) {
         self.uri = value;
     }
 
-    // FIXME: Return &str instead of String
+    pub fn local_uri(&self) -> Option<&str> {
-    pub fn local_uri(self) -> Option<String> {
+        self.local_uri.as_ref().map(|s| s.as_str())
-        self.local_uri
     }
 
     pub fn set_local_uri(&mut self, value: Option<String>) {
         self.local_uri = value;
     }
 
-    // FIXME: Return &str instead of String
+    pub fn description(&self) -> Option<&str> {
-    pub fn description(self) -> Option<String> {
+        self.description.as_ref().map(|s| s.as_str())
-        self.description
     }
 
     pub fn set_description(&mut self, value: Option<String>) {
         self.description = value;
     }
 
-    // FIXME: Return &str instead of String
+    pub fn published_date(&self) -> Option<&str> {
-    pub fn published_date(self) -> Option<String> {
+        self.published_date.as_ref().map(|s| s.as_str())
-        self.published_date
     }
 
     pub fn set_published_date(&mut self, value: Option<String>) {
         self.published_date = value;
     }
 
-    // FIXME: Return &str instead of String
+    pub fn guid(&self) -> Option<&str> {
-    pub fn guid(self) -> Option<String> {
+        self.guid.as_ref().map(|s| s.as_str())
-        self.guid
     }
 
     pub fn set_guid(&mut self, value: Option<String>) {
@@ -140,8 +134,8 @@ impl Podcast {
         self.description = value;
     }
 
-    pub fn image_uri(self) -> Option<String> {
+    pub fn image_uri(&self) -> Option<&str> {
-        self.image_uri
+        self.image_uri.as_ref().map(|s| s.as_str())
     }
 
     pub fn set_image_uri(&mut self, value: Option<String>) {
@@ -168,16 +162,16 @@ impl<'a> Source {
         &self.uri
     }
 
-    pub fn last_modified(self) -> Option<String> {
+    pub fn last_modified(&self) -> Option<&str> {
-        self.last_modified
+        self.last_modified.as_ref().map(|s| s.as_str())
     }
 
     pub fn set_last_modified(&mut self, value: Option<String>) {
         self.last_modified = value;
     }
 
-    pub fn http_etag(self) -> Option<String> {
+    pub fn http_etag(&self) -> Option<&str> {
-        self.http_etag
+        self.http_etag.as_ref().map(|s| s.as_str())
     }
 
     pub fn set_http_etag(&mut self, value: Option<String>) {
@@ -185,37 +179,30 @@ impl<'a> Source {
     }
 
     /// Fetch the xml feed from the source url, update the etag headers,
-    /// and parse the feed into an rss:Channel and return it.
+    /// parse the feed into an rss:Channel and return it.
     pub fn get_podcast_chan(&mut self, con: &SqliteConnection) -> Result<Channel> {
         use std::io::Read;
         use std::str::FromStr;
 
         let mut req = reqwest::get(&self.uri)?;
+        self.update_etag(con, &req)?;
 
         let mut buf = String::new();
-        req.read_to_string(&mut buf)?;
         // info!("{}", buf);
+        req.read_to_string(&mut buf)?;
+        let chan = Channel::from_str(&buf)?;
+
+        Ok(chan)
+    }
+
+    fn update_etag(&mut self, con: &SqliteConnection, req: &reqwest::Response) -> Result<()> {
 
         let headers = req.headers();
         debug!("{:#?}", headers);
 
         // let etag = headers.get_raw("ETag").unwrap();
         let etag = headers.get::<ETag>();
-        let lst_mod = headers.get::<LastModified>();
+        let lmod = headers.get::<LastModified>();
-        self.update(con, etag, lst_mod)?;
-
-        let chan = Channel::from_str(&buf)?;
-        // let foo = ::feedparser::parse_podcast(&chan, self.id())?;
-
-        Ok(chan)
-    }
-
-    pub fn update(
-        &mut self,
-        con: &SqliteConnection,
-        etag: Option<&ETag>,
-        lmod: Option<&LastModified>,
-    ) -> Result<()> {
 
         self.http_etag = etag.map(|x| x.tag().to_string().to_owned());
         self.last_modified = lmod.map(|x| format!("{}", x));