benarkan struktur

api/api_mage_x.py

@@ -138,6 +138,8 @@ def fetch_and_embed_data(user_id):
 def create_embeddings(text):
     return embedding_model.embed_query(text)
         
+import json
+
 def recommend_similar_items(user_preferences, desired_collection_types):
     # Menggabungkan embedding untuk semua referensi pengguna
     combined_embeddings = []
@@ -168,11 +170,16 @@ def recommend_similar_items(user_preferences, desired_collection_types):
     for match in all_items_response['matches']:
         collection_type = match['metadata']['collection_type']
         if collection_type in desired_collection_types:
-            filtered_matches.append({
+            # Parse metadata text to dictionary
+            metadata_text = match['metadata'].get('text', '{}')
+            metadata_dict = json.loads(metadata_text)
+            # Add firebase_id and score to the parsed metadata
+            parsed_result = {
                 "firebase_id": match['metadata']['firebase_id'],
                 "score": match['score'],
-                "text": match['metadata'].get('text', '')  # Tambahkan metadata 'text'
-            })
+                **metadata_dict  # Spread parsed metadata fields into the result
+            }
+            filtered_matches.append(parsed_result)
 
     return filtered_matches
 
@@ -218,15 +225,8 @@ async def get_recommendations(user_input: UserInput):
                 desired_collection_types=[collection_name]
             )
 
-            # Ambil hingga 20 rekomendasi, sertakan firebase_id, score, dan text
-            recommendations[category] = [
-                {
-                    "firebase_id": item["firebase_id"],
-                    "score": item["score"],
-                    "text": item["text"]
-                }
-                for item in sorted(items, key=lambda x: x["score"], reverse=True)[:20]
-            ]
+            # Ambil hingga 20 rekomendasi
+            recommendations[category] = sorted(items, key=lambda x: x["score"], reverse=True)[:20]
 
         except Exception as e:
             recommendations[category] = {"error": str(e)}
@@ -238,6 +238,7 @@ async def get_recommendations(user_input: UserInput):
 
 
 
+
 # Endpoint to initialize a new chat session
 @app.post("/initialize_session")
 def initialize_session(request: NewSessionRequest):