Update functions

Author: bharathcs

serverless/functions/.gitignore

@@ -1 +1,2 @@
 venv
+__pycache__

serverless/functions/main.py

@@ -1,13 +1,117 @@
-# Welcome to Cloud Functions for Firebase for Python!
-# To get started, simply uncomment the below code or create your own.
-# Deploy with `firebase deploy`
-
-from firebase_functions import https_fn
-from firebase_admin import initialize_app
-
-# initialize_app()
-#
-#
-# @https_fn.on_request()
-# def on_request_example(req: https_fn.Request) -> https_fn.Response:
-#     return https_fn.Response("Hello world!")
+import json
+import os
+import tempfile
+
+import google.cloud.firestore
+import requests
+# The Firebase Admin SDK to access Cloud Firestore.
+from firebase_admin import firestore, initialize_app
+# The Cloud Functions for Firebase SDK to create Cloud Functions and set up triggers.
+from firebase_functions import firestore_fn, https_fn
+from git import Repo
+
+app = initialize_app()
+
+BASE_URL = os.environ.get("BASE_URL")
+PASSWORD_HEADER = os.environ.get("PASSWORD_HEADER")
+
+def make_api_request(request_data):
+
+    # Make an HTTP POST request to the API
+    url = f"{BASE_URL}/api/serverless/questions"
+    try:
+        print (request_data)
+        response = requests.post(url, json=request_data, headers={"PASSWORD_HEADER": PASSWORD_HEADER})
+        response.raise_for_status()  # Raise an exception for HTTP errors (4xx and 5xx)
+        
+        print(f"API response status: {response.status_code}")
+        print(f"API response: {response.json()}")
+        return 1
+
+    except requests.exceptions.RequestException as e:
+        print(f"Error making the API request: {e}")
+        return 0
+    
+def load_problems():
+    with tempfile.TemporaryDirectory() as base_path:
+        Repo.clone_from("https://github.com/kyle8998/Practice-Coding-Questions.git", base_path)
+
+        # Define the path to the "repo/leetcode" directory
+        base_path += "/leetcode"
+        problems = []
+
+        # Iterate over the folders in the base directory
+        for folder_name in os.listdir(base_path):
+            folder_path = os.path.join(base_path, folder_name)
+            
+            # Check if the item is a directory
+            if os.path.isdir(folder_path):
+                problem_md_path = os.path.join(folder_path, "problem.md")
+                
+                # Check if "problem.md" exists in the folder
+                if os.path.exists(problem_md_path):
+                    # Open and read the contents of "problem.md"
+                    with open(problem_md_path, "r", encoding="utf-8") as problem_file:
+                        problem_contents = problem_file.read()
+                        problems.append(problem_contents)
+                else:
+                    print(f"No problem.md found in {folder_name}")
+    print(f"Total number of questions found: {len(problems)}")
+    return problems
+
+tags_to_search = ["Stack", "Array", "Tree", "Hash Table", "Binary Search"]
+
+def parse(qn):
+    try:
+        qn = qn.split("\n")
+
+        title = qn[0][2:]
+        qn.pop(0)
+
+        while qn[0].strip() == "":
+            qn.pop(0)
+
+        difficulty = qn[0].split(" ")[2].strip().upper()
+        difficulty = difficulty[0].upper() + difficulty[1:].lower()
+
+        qn.pop(0)
+        while qn[0].strip() == "":
+            qn.pop(0)
+
+        qn = '\n'.join(qn)
+
+        if difficulty not in ["Easy", "Medium", "Hard"]:
+            return None
+
+        if title.split(" ")[0] != "Problem" and title.split(" ")[1][-1] != ":":
+            return None
+        else:
+            title = " ".join(title.split(" ")[2:])
+            
+        
+        search_space = title + qn
+        tags = []
+        for tag in tags_to_search:
+            if tag.lower() in search_space.lower():
+                tags.append(tag)
+                
+        if tags == []:
+            return None
+            
+        return { "title": title, "difficulty": difficulty, "description": qn, "tags": tags}
+    except:
+        return None
+
+
+@https_fn.on_request()
+def addmessage(req: https_fn.Request) -> https_fn.Response:
+    if req.headers.get("PASSWORD_HEADER") != PASSWORD_HEADER:
+        return https_fn.Response(status=403)
+    
+    problems = load_problems()
+    problems = [parse(qn) for qn in problems]
+    problems = [qn for qn in problems if qn is not None]
+    print(f"Total number of questions parsed: {len(problems)}")
+    countOfQuestionsAdded = sum([make_api_request(qn) for qn in problems])
+    print(f"Total number of questions added: {countOfQuestionsAdded}")
+    return https_fn.Response(f"Total number of questions added: {countOfQuestionsAdded}")

serverless/functions/requirements.txt

@@ -1 +1,4 @@
-firebase_functions~=0.1.0
+GitPython==3.1.40
+python-dotenv==1.0.0
+firebase-functions
+firebase-admin