Added logic to upload <wspr_spot_data.csv> to Google Drive.

.gitignore

@@ -2,6 +2,7 @@
 .terraform
 *.tfstate
 .env
+service_account.json
 # Added by cargo
 
 /target

hyper/hyper/constants.py

@@ -1,3 +1,6 @@
-class CONSTANTS:
-    FILE_PATH = "./tableau/data"
-    FILE_NAME = "wspr_spots.csv"
+FILE_PATH = "./tableau/data"
+FILE_NAME = "wspr_spot_data.csv"
+FULL_PATH = FILE_PATH + "/" + FILE_NAME
+SCOPES = ["https://www.googleapis.com/auth/drive"]
+SERVICE_ACCOUNT_FILE = "service_account.json"
+PARENT_FOLDER_ID = "1uVnscmoxu91XT1LMnZoOOn3iCTirlEII"

hyper/hyper/drive.py

@@ -0,0 +1,33 @@
+import constants
+from google.oauth2 import service_account
+from googleapiclient.discovery import build
+
+
+def authenticate():
+    try:
+        print("\n[Authenticating] <wspr_cdk> service user...")
+
+        credentials = service_account.Credentials.from_service_account_file(
+            constants.SERVICE_ACCOUNT_FILE, scopes=constants.SCOPES
+        )
+
+        return credentials
+    except Exception as e:
+        print("\n[ERROR] -> Failed to [Authenticate] <wspr_cdk> service user: \n", e)
+
+
+def upload_to_drive(file_path):
+    try:
+        credentials = authenticate()
+        service = build("drive", "v3", credentials=credentials)
+
+        file_metadata = {
+            "name": "wspr_spot_data",
+            "parents": [constants.PARENT_FOLDER_ID],
+        }
+
+        print("[Uploading] file to Google Drive...\n")
+
+        service.files().create(body=file_metadata, media_body=file_path).execute()
+    except Exception as e:
+        print("\n[ERROR] -> Failed to upload to Google Drive: \n", e)

hyper/hyper/server.py

@@ -3,15 +3,14 @@
 import os
 
 import constants
+import drive
 
 import python_wrapper.python_wrapper
 
 
 class Server:
     def __init__(self):
-        self.write_path = os.path.join(
-            constants.CONSTANTS.FILE_PATH, "wspr_spot_data.csv"
-        )
+        self.write_path = os.path.join(constants.FILE_PATH, "wspr_spot_data.csv")
 
     async def write_to_csv(self):
         """
@@ -20,7 +19,7 @@ async def write_to_csv(self):
         """
 
         try:
-            output = await python_wrapper.python_wrapper.get_wspr_spots("10", "JSON")
+            output = await python_wrapper.python_wrapper.get_wspr_spots("1000", "JSON")
             data = output.get_data()
 
             # Display data that's being fetched for [DEBUG] purposes.
@@ -31,8 +30,8 @@ async def write_to_csv(self):
             print("\nWrite path: \n", write_path)
 
             # Check if directory exists.
-            if not os.path.exists(constants.CONSTANTS.FILE_PATH):
-                os.makedirs(constants.CONSTANTS.FILE_PATH)
+            if not os.path.exists(constants.FILE_PATH):
+                os.makedirs(constants.FILE_PATH)
 
             with open(write_path, mode="w", newline="") as file:
                 writer = csv.writer(file)
@@ -86,6 +85,9 @@ async def write_to_csv(self):
                             record["code"],
                         ]
                     )
+
+            # Upload [output] file to Google Drive.
+            drive.upload_to_drive(constants.FULL_PATH)
         except Exception as e:
             print("An [ERROR] occurred: ", e)
 

scripts/bash/python_deps.sh

@@ -39,3 +39,10 @@ declare -A module_import_map=(
 for module in "${!module_import_map[@]}"; do
 	verify_installation "${module}" "${module_import_map[${module}]}"
 done
+
+
+# An array modules contains the names of all the modules to be installed.
+# The pip install command installs or upgrades all the modules listed in the array.
+# A dictionary module_import_map maps module names to their respective import names.
+# The verify_installation function takes a module name and its import name as arguments, checks if the module can be imported, and prints the appropriate message.
+# The script iterates over the module_import_map dictionary to verify the installation of each module using the verify_installation function.