unused files removed

helpers/firebase.py

@@ -1,148 +0,0 @@
-import firebase_admin
-from firebase_admin import credentials
-from firebase_admin import firestore
-
-
-class FirebaseClient:
-    def __init__(self, path_to_certificate):
-        # Initialize Firebase Admin SDK
-        cred = credentials.Certificate(path_to_certificate)  # Path to your service account key JSON file
-        firebase_admin.initialize_app(cred)
-
-        # Initialize Firestore database
-        self.db = firestore.client()
-
-    def add_task(self, task_data):
-        """
-        Add a new task to Firestore.
-        
-        Args:
-            task_data (dict): Dictionary containing task data.
-                Example: {'title': 'Task Title', 'description': 'Task Description', 'status': 'pending'}
-        """
-        # Add task data to Firestore
-        doc_ref = self.db.collection('tasks').document()
-        doc_ref.set(task_data)
-        return doc_ref.id
-    
-    def get_task_by_status(self, status):
-        # Reference to the tasks collection
-        tasks_ref = self.db.collection('tasks')
-
-        # Query tasks with status 'pending'
-        query = tasks_ref.where('status', '==', status)
-
-        # Get documents that match the query
-        pending_tasks = query.stream()
-
-        # Convert documents to dictionaries
-        pending_tasks_data = []
-        for doc in pending_tasks:
-            task_data = doc.to_dict() 
-            task_data['id'] = doc.id
-            pending_tasks_data.append(task_data)
-
-        return pending_tasks_data
-
-    def get_all_tasks(self):
-        """
-        Retrieve all tasks from Firestore.
-        
-        Returns:
-            list: A list containing dictionaries, each representing a task.
-        """
-        # Reference to the 'tasks' collection
-        tasks_ref = self.db.collection('tasks')
-        
-        # Get all documents in the collection
-        docs = tasks_ref.stream()
-        
-        # Initialize an empty list to store tasks
-        tasks = []
-        
-        # Iterate over each document and add it to the tasks list
-        for doc in docs:
-            doc_dict = doc.to_dict()
-            doc_dict['id'] = doc.id
-            tasks.append(doc_dict)
-        
-        return tasks
-
-    def update(self, task_id, data):
-        """
-        Reserve a task by a worker.
-        
-        Args:
-            task_id (str): ID of the task to be reserved.
-            worker_id (str): ID of the worker reserving the task.
-        """
-        # Reference to the task document
-        task_ref = self.db.collection('tasks').document(task_id)
-        
-        # Update the task document to indicate it has been reserved by the worker
-        task_ref.update(data)
-    
-    def delete_task(self, task_id):
-        """
-        Delete a task from Firestore by its ID.
-        
-        Args:
-            task_id (str): ID of the task to be deleted.
-        """
-        # Reference to the task document
-        task_ref = self.db.collection('tasks').document(task_id)
-        
-        # Delete the task document
-        task_ref.delete()
-    
-    def get_task_by_id(self, task_id):
-        """
-        Retrieve a task from Firestore by its ID.
-        
-        Args:
-            task_id (str): ID of the task to be retrieved.
-        
-        Returns:
-            dict or None: Dictionary containing the task data if found, None otherwise.
-        """
-        # Reference to the task document
-        task_ref = self.db.collection('tasks').document(task_id)
-        
-        # Retrieve the task document
-        task_doc = task_ref.get()
-        
-        # Check if the task document exists
-        if task_doc.exists:
-            return task_doc.to_dict()
-        else:
-            return None
-        
-    def find_tasks_by_status(self, status):
-        """
-        Find all tasks in Firestore with the specified status.
-        
-        Args:
-            status (str): Status value to filter tasks by.
-        
-        Returns:
-            list: List of dictionaries containing task data.
-        """
-        # Reference to the 'tasks' collection
-        tasks_ref = self.db.collection('tasks')
-        
-        # Query tasks with the specified status
-        query = tasks_ref.where('status', '==', status)
-        
-        # Get documents that match the query
-        docs = query.stream()
-        
-        # Initialize an empty list to store tasks
-        tasks = []
-        
-        # Iterate over each document and add it to the tasks list
-        for doc in docs:
-            task = doc.to_dict()
-            task['id'] = doc.id
-            tasks.append(task)
-        
-        return tasks

helpers/gcloud.py

@@ -1,98 +0,0 @@
-import os 
-from google.cloud import storage
-from tqdm import tqdm
-from googleapiclient import discovery
-import requests
-
-
-service = discovery.build('compute', 'v1')
-storage_client = storage.Client()
-
-def download_csv_from_gcloud(bucket_name, object_name, destination_file_path):
-    """Download a file from Google Cloud Storage."""
-    
-    bucket = storage_client.bucket(bucket_name)
-    blob = bucket.blob(object_name)
-
-    # Download the file to a local path
-    blob.download_to_filename(destination_file_path)
-    print(f"File {object_name} downloaded to {destination_file_path}")
-
-def upload_folder_to_gcloud(bucket_name, source_folder_path, destination_folder_name):
-    """Uploads all files in a folder to the Google Cloud Storage bucket."""
-    # Instantiates a client
-    # storage_client = storage.Client()
-
-    # Gets the bucket
-    print(f"bucket_name={bucket_name}, source_folder_path={source_folder_path}, destination_folder_name={destination_folder_name}", flush=True)
-    bucket = storage_client.bucket(bucket_name)
-
-    # Walk through the folder and upload each file
-    for root, _, files in os.walk(source_folder_path):
-        for file_name in files:
-            # Construct the local file path
-            local_file_path = os.path.join(root, file_name)
-            
-            # Construct the destination blob name
-            destination_blob_name = os.path.join(destination_folder_name, os.path.relpath(local_file_path, source_folder_path))
-            print(f"destination_blob_name={destination_blob_name}")
-            # Upload the file
-            blob = bucket.blob(destination_blob_name)
-            blob.upload_from_filename(local_file_path)
-            
-            print(f"File {local_file_path} uploaded to {destination_blob_name}.")
-
-
-def download_folder(bucket_name, folder_name, destination_directory):
-    """
-    Download the contents of a folder from a Google Cloud Storage bucket to a local directory.
-    
-    Args:
-        bucket_name (str): Name of the Google Cloud Storage bucket.
-        folder_name (str): Name of the folder in the bucket to download.
-        destination_directory (str): Local directory to save the downloaded files.
-    """
-
-    # Get the bucket
-    bucket = storage_client.get_bucket(bucket_name)
-
-    # List objects in the folder
-    blobs = bucket.list_blobs(prefix=folder_name)
-
-    # Ensure destination directory exists
-    os.makedirs(destination_directory, exist_ok=True)
-
-    # Iterate over each object in the folder
-    for blob in tqdm(blobs, desc=f'Downloading {folder_name}'):
-        # Determine local file path
-        local_file_path = os.path.join(destination_directory, os.path.relpath(blob.name, folder_name))
-
-        # Ensure local directory exists
-        os.makedirs(os.path.dirname(local_file_path), exist_ok=True)
-
-        # Download the object to a local file
-        blob.download_to_filename(local_file_path)
-
-
-def start_vm(project, zone, instance):
-    request = service.instances().start(project=project, zone=zone, instance=instance)
-    response = request.execute()
-    return response
-
-def stop_vm(project, zone, instance):
-    request = service.instances().stop(project=project, zone=zone, instance=instance)
-    response = request.execute()
-    return response
-
-def get_current_instance_name():
-    # URL for the metadata server
-    METADATA_URL = "http://metadata.google.internal/computeMetadata/v1/instance/name"
-    HEADERS = {"Metadata-Flavor": "Google"}
-    try:
-        response = requests.get(METADATA_URL, headers=HEADERS)
-        response.raise_for_status()  # Raise an error for bad status codes
-        instance_name = response.text
-        return instance_name
-    except requests.exceptions.RequestException as e:
-        print(f"Error fetching instance name: {e}")
-        return None

pyproject.toml

@@ -20,11 +20,7 @@ matplotlib = "3.8.2"
 plotly = "5.18.0"
 protobuf = "4.25.2"
 tqdm = "4.66.1"
-google-cloud-storage = "^2.14.0"
 tinydb = "^4.8.0"
-uvicorn = "^0.27.0.post1"
-fastapi = "^0.109.2"
-firebase-admin = "^6.5.0"
 
 [tool.poetry.dev-dependencies]