Update app.py

app.py

@@ -174,6 +174,29 @@ def update_user_history(uid, prompt, response):
 def index():
     return render_template_string(HTML)
 
+
+app.route("/remote")
+def remote_saving():
+    now = time.time()
+    for uid, data in list(user_memory.items()):
+            if now - data.get("last_sync", 0) >= FLUSH_INTERVAL and data["history"]:
+                try:
+                    # Only sync the most recent MAX_HISTORY_TURNS entries
+                    history_to_sync = data["history"][-MAX_HISTORY_TURNS:]
+                    payload = {"user_id": uid, "history": history_to_sync}
+                    print(f"🔄 Attempting to sync {uid} to {LAMBDA_URL}")
+                    resp = requests.post(LAMBDA_URL, json=payload, timeout=5)
+                    resp.raise_for_status()
+                    user_memory[uid]["last_sync"] = now
+                    app.logger.info(f"Synced memory for {uid} ({len(history_to_sync)} turns)")
+                    print(f"✅ Successfully synced memory for {uid} ({len(history_to_sync)} turns)")
+                    return jsonify({"done": True}), 200
+                except Exception as e:
+                    app.logger.warning(f"Failed sync for {uid}: {e}")
+                    print(f"❌ Failed sync for {uid}: {e}")
+                    return jsonify({"error": str(e)}), 500
+
+
 @app.route("/generate", methods=["POST"])
 def gen():
     uid = request.form.get("user_id", "").strip()