From f81b481f381e46027732a69d2135b7e862d19ebc Mon Sep 17 00:00:00 2001
From: kdeng00 <kundeng94@gmail.com>
Date: Wed, 31 Jul 2019 21:52:06 -0400
Subject: [PATCH] Added feature to retrieve song records in json format. One
 issue is that the json file is in one line

---
 CMakeLists.txt                    |  2 ++
 include/Managers/CommitManager.h  |  7 +++++
 include/Syncers/RetrieveRecords.h | 25 +++++++++++++++
 src/Main.cpp                      | 20 ++++++------
 src/Managers/ActionManager.cpp    |  6 ++--
 src/Managers/CommitManager.cpp    | 32 +++++++++++++++++++
 src/Syncers/RetrieveRecords.cpp   | 51 +++++++++++++++++++++++++++++++
 7 files changed, 130 insertions(+), 13 deletions(-)
 create mode 100644 include/Syncers/RetrieveRecords.h
 create mode 100644 src/Syncers/RetrieveRecords.cpp

diff --git a/CMakeLists.txt b/CMakeLists.txt
index 25dc728..1a95ab6 100644
--- a/CMakeLists.txt
+++ b/CMakeLists.txt
@@ -50,6 +50,7 @@ set(SOURCES
 	src/Parsers/APIParser.cpp
 	src/Syncers/Delete.cpp
 	src/Syncers/Download.cpp
+    src/Syncers/RetrieveRecords.cpp
 	src/Syncers/Upload.cpp
 	src/Utilities/Conversions.cpp
 )
@@ -69,6 +70,7 @@ set(HEADERS
 	include/Parsers/APIParser.h
 	include/Syncers/Delete.h
 	include/Syncers/Download.h
+    include/Syncers/RetrieveRecords.h
 	include/Syncers/SyncerBase.h
 	include/Syncers/Upload.h
 	include/Utilities/Conversions.h
diff --git a/include/Managers/CommitManager.h b/include/Managers/CommitManager.h
index 975094f..52041ee 100644
--- a/include/Managers/CommitManager.h
+++ b/include/Managers/CommitManager.h
@@ -16,12 +16,19 @@ namespace Managers
         CommitManager(Models::IcarusAction);
 
         void commitAction();
+
+        enum RetrieveTypes
+        {
+            songs
+        };
+
     private:
         Models::Token parseToken(Models::API);
 
         void initializeMapActions();
         void deleteSong();
         void downloadSong();
+        void retrieveObjects();
         void uploadSong();
 
         enum ActionValues
diff --git a/include/Syncers/RetrieveRecords.h b/include/Syncers/RetrieveRecords.h
new file mode 100644
index 0000000..c3b824f
--- /dev/null
+++ b/include/Syncers/RetrieveRecords.h
@@ -0,0 +1,25 @@
+#ifndef RETRIEVERECORDS_H_
+#define RETRIEVERECORDS_H_
+
+#include "Managers/CommitManager.h"
+#include "Models/API.h"
+#include "Models/Token.h"
+
+namespace Syncers
+{
+    class RetrieveRecords
+    {
+    public:
+        RetrieveRecords();
+        RetrieveRecords(Models::API, Models::Token);
+
+        void retrieve(Managers::CommitManager::RetrieveTypes);
+    private:
+        void fetchSongs();
+
+        Models::API api;
+        Models::Token token;
+    };
+}
+
+#endif
diff --git a/src/Main.cpp b/src/Main.cpp
index 9b26e17..010bbc1 100644
--- a/src/Main.cpp
+++ b/src/Main.cpp
@@ -14,17 +14,17 @@ using Managers::CommitManager;
 
 int main(int argc, char** argv)
 {
-	if (argc < 2)
-	{
-		cout<<"No actions provided"<<endl;
-		return 1;
-	}
+    if (argc < 2)
+    {
+        cout<<"No actions provided"<<endl;
+        return 1;
+    }
 
-	ActionManager actMgr{argv};
-	auto chosenAction = actMgr.retrieveIcarusAction();
+    ActionManager actMgr{argv};
+    auto chosenAction = actMgr.retrieveIcarusAction();
 
-	CommitManager commitMgr{chosenAction};
-	commitMgr.commitAction();
+    CommitManager commitMgr{chosenAction};
+    commitMgr.commitAction();
 
-	return 0;
+    return 0;
 }
diff --git a/src/Managers/ActionManager.cpp b/src/Managers/ActionManager.cpp
index 369b27d..b1f998b 100644
--- a/src/Managers/ActionManager.cpp
+++ b/src/Managers/ActionManager.cpp
@@ -74,7 +74,7 @@ namespace Managers
     {
         supportedFlags = vector<string>{
             "-u", "-p", "-t", "-h", "-s",
-            "-d", "-D", "-b"
+            "-d", "-D", "-b", "-rt"
         };
     }
     void ActionManager::validateAction()
@@ -109,7 +109,7 @@ namespace Managers
             if (flag.size() > 3 || isNumber(flag))
             {
                 flg.value = flag;
-                //cout<<"flag value "<<flg.value<<endl;
+                cout<<"flag value "<<flg.value<<endl;
                 flags.push_back(flg);
                 flg = Flags{};
                 continue;
@@ -121,7 +121,7 @@ namespace Managers
                     return !val.compare(flag);
                 }))
             {
-                //cout<<"flag "<<flag<<endl;
+                cout<<"flag "<<flag<<endl;
                 flg.flag = flag;
             }
             else
diff --git a/src/Managers/CommitManager.cpp b/src/Managers/CommitManager.cpp
index 5c138b3..0c6a330 100644
--- a/src/Managers/CommitManager.cpp
+++ b/src/Managers/CommitManager.cpp
@@ -8,6 +8,7 @@
 #include"Parsers/APIParser.h"
 #include"Syncers/Delete.h"
 #include"Syncers/Download.h"
+#include"Syncers/RetrieveRecords.h"
 #include"Syncers/Upload.h"
 
 #include"Managers/TokenManager.h"
@@ -27,6 +28,7 @@ using Parsers::APIParser;
 using Models::IcarusAction;
 using Syncers::Delete;
 using Syncers::Download;
+using Syncers::RetrieveRecords;
 using Syncers::Upload;
 
 namespace Managers
@@ -54,6 +56,7 @@ namespace Managers
 				downloadSong();
 				break;
 			case retrieveAct: // No plans to imeplement
+                retrieveObjects();
 				break;
 			case uploadAct:
 				uploadSong();
@@ -134,6 +137,35 @@ namespace Managers
         cout<<"downloading song"<<endl;
 		dnld.downloadSong(token, song);
 	}
+    void CommitManager::retrieveObjects()
+    {
+        cout<<"Starting retrieve process..."<<endl;
+        
+        APIParser apiPrs{icaAction};
+        auto api = apiPrs.retrieveAPI();
+
+        auto token = parseToken(api);
+        RetrieveTypes retrieveType;
+
+        for (auto arg : icaAction.flags)
+        {
+            auto flag = arg.flag;
+            auto value = arg.value;
+
+            if (flag.compare("-rt") == 0)
+            {
+                if (value.compare("songs") == 0)
+                {
+                    retrieveType = RetrieveTypes::songs;
+                    break;
+                }
+            }
+        }
+
+        RetrieveRecords songs{api, token};
+        songs.retrieve(retrieveType);
+
+    }
 	void CommitManager::uploadSong()
 	{
 		APIParser apiPrs{icaAction};
diff --git a/src/Syncers/RetrieveRecords.cpp b/src/Syncers/RetrieveRecords.cpp
new file mode 100644
index 0000000..baff397
--- /dev/null
+++ b/src/Syncers/RetrieveRecords.cpp
@@ -0,0 +1,51 @@
+#include "Syncers/RetrieveRecords.h"
+
+#include <iostream>
+#include <fstream>
+
+#include <cpr/cpr.h>
+
+using std::cout;
+using std::endl;
+using std::ofstream;
+
+using Managers::CommitManager;
+using Models::API;
+using Models::Token;
+
+namespace Syncers
+{
+
+    RetrieveRecords::RetrieveRecords() { }
+    RetrieveRecords::RetrieveRecords(API api, Token token) 
+        : token(token), api(api) { }
+
+    void RetrieveRecords::retrieve(CommitManager::RetrieveTypes type)
+    {
+        switch (type)
+        {
+            case CommitManager::RetrieveTypes::songs:
+                fetchSongs();
+                break;
+            default:
+                break;
+        }
+    }
+    void RetrieveRecords::fetchSongs()
+    {
+        cout<<"fetching songs"<<endl;
+        auto url = api.url + "api/" + api.version + "/" + "song";
+        cout<<url<<endl;
+
+        auto auth = token.tokenType;
+        auth.append(" " + token.accessToken);
+        auto r = cpr::Get(cpr::Url{url},
+             cpr::Header{{"authorization", auth},
+                 });
+
+        ofstream writeData{};
+        writeData.open("songs.json");
+        writeData<<r.text;
+        writeData.close();
+    }
+}