Adding more code to the syncers module

src/models/token.rs

@@ -18,3 +18,19 @@ impl Default for Token {
         }
     }
 }
+
+impl Token {
+    pub fn bearer_token(&self) -> String {
+        let mut token: String = String::from("Bearer ");
+
+        match &self.access_token {
+            Some(tok) => {
+                token += tok;
+            }
+            None => {
+            }
+        }
+
+        return token;
+    }
+}

src/syncers/delete.rs

@@ -1,4 +1,11 @@
 use std::default::Default;
+use std::io::Error;
+
+use reqwest;
+use reqwest::Response;
+use serde;
+// use serde::Deserialize;
+// use serde::Serialize;
 
 use crate::models;
 
@@ -18,7 +25,36 @@ impl Default for Delete {
 }
 
 impl Delete {
-    pub fn delete_song(&self, token: &models::token::Token, song: &models::song::Song) {
+    pub async fn delete_song(&self, token: &models::token::Token, song: &models::song::Song) {
-        let url = syncer_base::Syncer::retrieve_url(&self.api, &song);
+        let url = self.retrieve_url(&song);
+        let client = reqwest::Client::new();
+        let access_token = token.bearer_token();
+        let response = client.delete(&url)
+            .header(reqwest::header::AUTHORIZATION, access_token)
+            .send()
+            .await
+            .unwrap();
+    
+        match response.status() {
+            reqwest::StatusCode::OK => {
+                println!("Success!");
+            }
+            other => {
+                panic!("Issue occurred: {:?}", other);
+            }
+        }
+    }
+
+    fn retrieve_url(&self, song: &models::song::Song) -> String {
+        let api = &self.api;
+        let mut url: String = String::from(&api.url);
+        url += &String::from("api/");
+        url += &String::from(&api.version);
+        url += &String::from("/");
+        url += &String::from(&api.endpoint);
+        url += &String::from("/");
+        url += &song.id.unwrap().to_string();
+
+        return url;
     }
 }

src/syncers/download.rs

@@ -13,3 +13,14 @@ impl Default for Download {
         }
     }
 }
+
+impl Download {
+    pub async fn download_song(&self, token: &models::token::Token) {
+    }
+
+    fn retrieve_url(&self) -> String {
+        let mut url: String = String::new();
+
+        return url;
+    }
+}

src/syncers/retrieve_records.rs

@@ -1,7 +1,10 @@
 use std::default::Default;
+use std::io::Error;
 
 use crate::models;
 
+// use super::syncer_base::Result;
+
 
 pub struct RetrieveRecords {
     pub api: models::api::API,
@@ -15,3 +18,49 @@ impl Default for RetrieveRecords {
         }
     }
 }
+
+
+impl RetrieveRecords {
+    pub async fn get_all_songs(&self, token: &models::token::Token) 
+        -> Result<Vec<models::song::Song>, Error> {
+
+        let mut songs: Vec<models::song::Song> = Vec::new();
+        let url = self.retrieve_url();
+        let access_token = token.bearer_token();
+        let client = reqwest::Client::new();
+        let response = client.get(&url)
+            .header(reqwest::header::AUTHORIZATION, access_token)
+            .send()
+            .await
+            .unwrap();
+
+
+        match response.status() {
+            reqwest::StatusCode::OK => {
+                // on success, parse our JSON to an APIResponse
+                let s = response.json::<Vec<models::song::Song>>().await;
+                match s {
+                    // 
+                    Ok(parsed) => {
+                        songs = parsed;
+                        },
+                    Err(_) => println!("Hm, the response didn't match the shape we expected."),
+                };
+            }
+            reqwest::StatusCode::UNAUTHORIZED => {
+                println!("Need to grab a new token");
+            }
+            other => {
+                panic!("Uh oh! Something unexpected happened: {:?}", other);
+            }
+        }
+        
+        return Ok(songs);
+    }
+
+    fn retrieve_url(&self) -> String {
+        let mut url: String = String::new();
+
+        return url;
+    }
+}

src/syncers/syncer_base.rs

@@ -1,24 +1,13 @@
-use crate::models;
+// use crate::models;
 
 pub struct Syncer {
+    // pub api: models::api::API,
     ok: i32,
     unauthorized: i32,
     not_found: i32,
 }
 
 impl Syncer {
-    pub fn retrieve_url(api: &models::api::API, song: &models::song::Song) -> String {
-        let mut url: String = String::from(&api.url);
-        url += &String::from("api/");
-        url += &String::from(&api.version);
-        url += &String::from("/");
-        url += &String::from(&api.endpoint);
-        url += &String::from("/");
-        url += &song.id.unwrap().to_string();
-
-        return url;
-    }
-
     pub fn ok() -> i32 {
         return 200;
     }

src/syncers/upload.rs

@@ -1,5 +1,8 @@
 use std::default::Default;
 
+use reqwest;
+use reqwest::Response;
+
 use crate::models;
 
 pub struct Upload {
@@ -13,3 +16,32 @@ impl Default for Upload {
         }
     }
 }
+
+impl Upload {
+    pub async fn upload_song(&self, token: &models::token::Token, song: &models::song::Song) {
+        let url = self.retrieve_url(&song);
+        let client = reqwest::Client::new();
+        let access_token = token.bearer_token();
+        let response = client.post(&url)
+            .header(reqwest::header::AUTHORIZATION, access_token)
+            .send()
+            .await
+            .unwrap();
+    
+        match response.status() {
+            reqwest::StatusCode::OK => {
+                println!("Success!");
+            }
+            other => {
+                panic!("Issue occurred: {:?}", other);
+            }
+        }
+    }
+
+
+    fn retrieve_url(&self, song: &models::song::Song) -> String {
+        let mut url: String = String::new();
+
+        return url;
+    }
+}