Update app.py

app.py

@@ -83,7 +83,6 @@ type `read query`
         return "", history + [[user_message, None]]
 
     def bot(history, url_params):
-        global session_index
         if "read query" in history[-1][0]:
             session_index = url_params.get('session_index')
             bot_message = f"""
@@ -100,7 +99,74 @@ type `read query`
             bot_message = random.choice(["Yes", "No"])
         history[-1][1] = bot_message
         time.sleep(1)
-        return history
+        return history, session_index 
+
+    def fetch_personalized_data():
+        # Connect to the database
+        conn = mysql.connector.connect(
+            host="18.153.94.89",
+            user="root",
+            password="N12RXMKtKxRj",
+            database="lionessdb"
+        )
+    
+        # Create a cursor object
+        cursor = conn.cursor()
+    
+        # Replace the placeholders with your actual database and table names
+        core_table = "e5390g37096_core"
+        decisions_table = "e5390g37096_decisions"
+        session_index = url_params.get('session_index')
+        playerNr = "1"
+    
+        # Query to fetch relevant data from both tables based on session_index
+        query = f"""
+            SELECT 
+                {core_table}.playerNr, 
+                {core_table}.subjectNr, 
+                {core_table}.onPage,
+                {decisions_table}.transfer1,
+                {decisions_table}.tripledAmount1,
+                {decisions_table}.keptForSelf1,
+                {decisions_table}.returned1,
+                {decisions_table}.newCreditRound2,
+                {decisions_table}.transfer2,
+                {decisions_table}.tripledAmount2,
+                {decisions_table}.keptForSelf2,
+                {decisions_table}.returned2,
+                {decisions_table}.resultsWithoutAI
+            FROM {core_table}
+            JOIN {decisions_table} ON 
+                {core_table}.playerNr = {decisions_table}.playerNr AND
+                {core_table}.groupNr = {decisions_table}.groupNr AND
+                {core_table}.subjectNr = {decisions_table}.subjectNr
+            WHERE {decisions_table}.session_index = '{session_index}'
+        """
+        cursor.execute(query)
+        
+        # Fetch all rows and convert to a list of dictionaries
+        rows = cursor.fetchall()
+        result = []
+        for row in rows:
+            d = {}
+            for i, col in enumerate(cursor.description):
+                d[col[0]] = row[i]
+            result.append(d)
+    
+        # Convert the list of dictionaries to JSON
+        personalized_result = json.dumps(result)
+    
+        # Close the database connection
+        conn.close()
+    
+        # Return the JSON result
+        return personalized_result
+
+    # Call the function to fetch data as JSON
+    personalized_data = fetch_personalized_data()
+    
+    # Print or use the json_result variable as needed
+    print(personalized_data)
 
     ''' def bot(history, url_params):
         global session_index
@@ -125,6 +191,7 @@ type `read query`
         fn=bot, inputs=[chatbot, url_params], outputs=[chatbot]
     )
     clear.click(lambda: None, None, chatbot, queue=False)
+    
     demo.load(
         fn=lambda x: x,
         inputs=[url_params],
@@ -133,116 +200,4 @@ type `read query`
         queue=False
     )
 
-
-def fetch_personalized_data():
-    global session_index
-    # Connect to the database
-    conn = mysql.connector.connect(
-        host="18.153.94.89",
-        user="root",
-        password="N12RXMKtKxRj",
-        database="lionessdb"
-    )
-
-    # Create a cursor object
-    cursor = conn.cursor()
-
-    # Replace the placeholders with your actual database and table names
-    core_table = "e5390g37096_core"
-    decisions_table = "e5390g37096_decisions"
-    #session_index = "your_session_index_value"
-    playerNr = "1"
-
-    # Query to fetch relevant data from both tables based on session_index
-    query = f"""
-        SELECT 
-            {core_table}.playerNr, 
-            {core_table}.subjectNr, 
-            {core_table}.onPage,
-            {decisions_table}.transfer1,
-            {decisions_table}.tripledAmount1,
-            {decisions_table}.keptForSelf1,
-            {decisions_table}.returned1,
-            {decisions_table}.newCreditRound2,
-            {decisions_table}.transfer2,
-            {decisions_table}.tripledAmount2,
-            {decisions_table}.keptForSelf2,
-            {decisions_table}.returned2,
-            {decisions_table}.resultsWithoutAI
-        FROM {core_table}
-        JOIN {decisions_table} ON 
-            {core_table}.playerNr = {decisions_table}.playerNr AND
-            {core_table}.groupNr = {decisions_table}.groupNr AND
-            {core_table}.subjectNr = {decisions_table}.subjectNr
-        WHERE {decisions_table}.session_index = '{session_index}'
-    """
-    cursor.execute(query)
-    
-    # Fetch all rows and convert to a list of dictionaries
-    rows = cursor.fetchall()
-    result = []
-    for row in rows:
-        d = {}
-        for i, col in enumerate(cursor.description):
-            d[col[0]] = row[i]
-        result.append(d)
-
-    # Convert the list of dictionaries to JSON
-    personalized_result = json.dumps(result)
-
-    # Close the database connection
-    conn.close()
-
-    # Return the JSON result
-    return personalized_result
-
-# Call the function to fetch data as JSON
-personalized_data = fetch_personalized_data()
-
-# Print or use the json_result variable as needed
-print(personalized_data)
-
-demo.launch()
-
-
-
-
-
-
-
-
-
-
-
-'''
-    def bot(history, url_params):
-        global session_index
-        if "read query" in history[-1][0]:
-            session_index = url_params.get('session_index')
-            bot_message = f"""
-                            here your URL params:
-                            {json.dumps(url_params, indent=4)}
-                        """
-            print(url_params)
-        else:
-            bot_message = random.choice(["Yes", "No"])
-        history[-1][1] = bot_message
-        time.sleep(1)
-        return history'''
-
-'''
- WHERE {decisions_table}.session_index = '{session_index}'
-
-    # Fetch the results
-    results = cursor.fetchall()
-    
-    # Process the results as needed
-    for row in results:
-        print(row)
-    
-    # Close the cursor and connection when done
-    cursor.close()
-    conn.close()
-
-    return results 
-'''
+demo.launch()