add database

.gitignore

@@ -0,0 +1 @@
+/__pycache__

app.py

@@ -5,6 +5,8 @@ from collections import defaultdict
 import json
 import os 
 import sys
+from database import save_response
+
 
 css = """
 .rtl{
@@ -14,6 +16,7 @@ css = """
     direction: rtl !important;
 }
 """
+
 file_path = 'output/merged.json'
 df = pd.read_json(file_path, orient='records', lines=False)
 
@@ -34,17 +37,14 @@ def process_rankings(user_rankings):
         model = answer_id.split('_')[0]  # Extracting the model name from the answer_id
         rank_suffix = get_rank_suffix(rank)
         model_rankings[model][f'{rank}{rank_suffix}'] += 1  # Using the correct suffix based on the rank
-
-    file_path = 'users_ranking.txt'
-    if not os.path.exists(file_path):
-    # If the file path does not exist, print an error message and exit the script
-        print(f"Error: The file path '{file_path}' does not exist.")
-        sys.exit(1)  # Exit the script with an error code (1 is a common choice for a general error)
-
-    with open(file_path, 'a') as file:
         model_rankings_dict = dict(model_rankings)
-        json.dump(model_rankings_dict, file)
-        file.write('\n')  # Add a newline to separate entries
+    
+    save_response(model_rankings_dict)
+    # file_path = 'users_ranking.txt'
+    # with open(file_path, 'a') as file:
+    #     model_rankings_dict = dict(model_rankings)
+    #     json.dump(model_rankings_dict, file)
+    #     file.write('\n')  # Add a newline to separate entries
     print("Updated Model Rankings:", model_rankings)  # Debugging print
     return
 

database.py

@@ -0,0 +1,34 @@
+from pymongo.mongo_client import MongoClient
+from pymongo.server_api import ServerApi
+from urllib.parse import quote_plus
+
+password = quote_plus('cidar@2024$')
+uri = f"mongodb+srv://deemaa2:{password}@cluster0.qjruxcb.mongodb.net/?retryWrites=true&w=majority"
+
+# Create a new client and connect to the server
+client = MongoClient(uri, server_api=ServerApi('1'))
+
+# Specify the database and collection
+db = client.your_database_name
+collection = db.your_collection_name
+
+def save_response(response_data):
+    """Saves a response to the MongoDB collection."""
+    try:
+        # Insert the response data into the collection
+        collection.insert_one(response_data)
+        print("Response saved successfully.")
+    except Exception as e:
+        print(f"An error occurred: {e}")
+
+
+def read_responses(filter_query=None):
+    """Reads responses from the MongoDB collection based on an optional filter."""
+    try:
+        if filter_query is None:
+            filter_query = {}  # An empty query will return all documents
+        responses = collection.find(filter_query)
+        return list(responses)  # Convert cursor to list
+    except Exception as e:
+        print(f"An error occurred: {e}")
+        return []

read_responses.py

@@ -0,0 +1,12 @@
+
+from database import read_responses
+
+def fetch_and_display_responses():
+    # Fetch responses from the database
+    responses = read_responses()
+    # Format the responses for display (simple text format in this example)
+    formatted_responses = "\n".join([str(response) for response in responses])
+    print(formatted_responses)
+    # return formatted_responses
+
+fetch_and_display_responses()