Update app.py

app.py

@@ -19,6 +19,7 @@ MEGA_EMAIL = os.environ.get("MEGA_EMAIL")
 MEGA_PASSWORD = os.environ.get("MEGA_PASSWORD")
 REMOTE_DESTINATION_PATH = os.environ.get("REMOTE_DESTINATION_PATH", "/Conversations/")
 
+
 def persist_data(session_data):
     if not MEGA_EMAIL or not MEGA_PASSWORD:
         print("Warning: Mega credentials not configured.")
@@ -44,14 +45,16 @@ def persist_data(session_data):
         with open(temp_log_path, "w", encoding="utf-8") as f:
             f.write(formatted_log)
 
-        # Subir archivo a Mega
-        folder = m.find(REMOTE_DESTINATION_PATH)
+        # Buscar o crear carpeta en Mega
+        folder = m.find(REMOTE_DESTINATION_PATH.rstrip("/"))
         if folder:
             folder_id = folder[0]
-            m.upload(temp_log_path, folder_id)
         else:
-            print(f"Folder '{REMOTE_DESTINATION_PATH}' not found in Mega.")
-        
+            root_folder = m.find("/")
+            folder_id = m.create_folder(REMOTE_DESTINATION_PATH.strip("/"), root_folder[0])['f'][0]['h']
+
+        # Subir archivo
+        m.upload(temp_log_path, folder_id)
         print(f"Log uploaded to Mega: {log_name}")
 
     except Exception as e:
@@ -94,6 +97,8 @@ def respond(message, history: list[tuple[str, str]]):
     for line in response.iter_lines():
         if line:
             line_text = line.decode('utf-8')
+
+            # Solo procesamos las líneas que empiezan con "data: "
             if line_text.startswith("data: "):
                 data_str = line_text[6:]
 
@@ -108,8 +113,9 @@ def respond(message, history: list[tuple[str, str]]):
                             token = delta['content']
                             accumulated_response += token
                             yield accumulated_response
-                except json.JSONDecodeError:
-                    continue
+                except json.JSONDecodeError as e:
+                    print(f"JSON decode error: {e}, raw data: {data_str}")
+                    continue  # Saltamos líneas mal formadas
 
     if not accumulated_response:
         yield "Lo siento, ocurrió un error al procesar tu solicitud."