Update app.py

app.py

@@ -26,25 +26,23 @@ def ema_manual(prices, span):
     logging.debug(f"Memulai ema_manual untuk span={span}. Jumlah harga: {len(prices)}")
     if len(prices) < span:
         logging.warning(f"Tidak cukup data untuk menghitung EMA span {span}. Hanya {len(prices)} tersedia.")
-        return [np.nan] * len(prices) # Kembalikan list NaN jika tidak cukup data
+        return [np.nan] * len(prices)
 
     ema = [np.nan] * len(prices)
     alpha = 2 / (span + 1)
     
-    # Debugging pada loop EMA
     try:
         for i in range(len(prices)):
             if i < span - 1:
                 ema[i] = np.nan
             elif i == span - 1:
-                # Tambahkan logging di sini
                 logging.debug(f"Menghitung EMA awal untuk span={span} pada indeks {i}. Data: {prices[:span]}")
                 ema[i] = np.mean(prices[:span])
             else:
                 ema[i] = alpha * prices[i] + (1 - alpha) * ema[i - 1]
     except Exception as e:
         logging.error(f"Error dalam loop ema_manual (span={span}, index={i}): {e}", exc_info=True)
-        raise # Re-raise exception untuk ditangkap oleh try-except di endpoint
+        raise
 
     logging.debug(f"ema_manual selesai untuk span={span}.")
     return ema
@@ -60,7 +58,7 @@ def get_dynamic_minmax():
     close_min = df["Close"].min()
     close_max = df["Close"].max()
     logging.info(f"Min/Max Close: {close_min}/{close_max}")
-    return float(close_min), float(close_max) # Pastikan kembali float
+    return float(close_min), float(close_max)
 
 def normalize_close(value, close_min, close_max):
     if close_max == close_min:
@@ -69,14 +67,12 @@ def normalize_close(value, close_min, close_max):
     return (value - close_min) / (close_max - close_min)
 
 def analyze_trend(latest_row):
-    # Logging untuk memastikan data yang masuk valid
     logging.debug(f"Menganalisis tren untuk data terbaru: {latest_row.to_dict()}")
 
     ema20 = latest_row["EMA20"]
     ema50 = latest_row["EMA50"]
     close = latest_row["close"]
 
-    # ... (sisa fungsi analyze_trend tidak berubah)
     if ema20 > ema50:
         trend = "bullish"
     elif ema20 < ema50:
@@ -84,7 +80,6 @@ def analyze_trend(latest_row):
     else:
         trend = "neutral"
 
-    # Pastikan ema50 tidak nol sebelum pembagian
     if ema50 == 0:
         logging.error("EMA50 adalah nol, tidak dapat menghitung gap persen.")
         diff = 0
@@ -114,7 +109,7 @@ def analyze_trend(latest_row):
     }
 
 @app.post("/analyze")
-def analyze_ema_endpoint(input_data: DateRange): # Ganti nama fungsi agar tidak sama dengan analyze_ema
+def analyze_ema_endpoint(input_data: DateRange):
     try:
         logging.info(f"Menerima permintaan /analyze dengan start_date={input_data.start_date}, end_date={input_data.end_date}")
         start_date = pd.to_datetime(input_data.start_date)
@@ -133,15 +128,15 @@ def analyze_ema_endpoint(input_data: DateRange): # Ganti nama fungsi agar tidak
         logging.debug(f"Jumlah baris setelah download dan rename: {len(df)}")
 
         if len(df) < 50:
-            # Perhatikan pesan error di sini, ini akan muncul di log, bukan di 'message'
             logging.error(f"Data terlalu sedikit ({len(df)} hari). Butuh minimal 50 hari untuk EMA50.")
             return {"status": "error", "message": f"Data terlalu sedikit ({len(df)} hari). Butuh minimal 50 hari untuk EMA50."}
 
-        # Logging sebelum memanggil ema_manual
         logging.debug(f"Memanggil ema_manual untuk EMA20 dengan {len(df)} data.")
-        df["EMA20"] = ema_manual(df["close"].tolist(), 20) # Kirim sebagai list agar lebih eksplisit
+        # BARIS INI YANG DIPERBAIKI:
+        df["EMA20"] = ema_manual(df["close"].tolist(), 20) 
         logging.debug(f"Memanggil ema_manual untuk EMA50 dengan {len(df)} data.")
-        df["EMA50"] = ema_manual(df["close"].tolist(), 50) # Kirim sebagai list
+        # BARIS INI YANG DIPERBAIKI:
+        df["EMA50"] = ema_manual(df["close"].tolist(), 50)
 
         df = df.dropna().reset_index(drop=True)
         logging.debug(f"Jumlah baris setelah dropna: {len(df)}")
@@ -169,12 +164,11 @@ def analyze_ema_endpoint(input_data: DateRange): # Ganti nama fungsi agar tidak
         }
 
     except Exception as e:
-        # PENTING: Periksa output log server Anda untuk ini!
         logging.error(f"Error TERTANGKAP di endpoint /analyze_ema_endpoint: {e}", exc_info=True)
         return {"status": "error", "message": str(e)}
 
 @app.post("/summary")
-def ema_summary_endpoint(input_data: DateRange): # Ganti nama fungsi
+def ema_summary_endpoint(input_data: DateRange):
     try:
         logging.info(f"Menerima permintaan /summary dengan start_date={input_data.start_date}, end_date={input_data.end_date}")
         start_date = pd.to_datetime(input_data.start_date)
@@ -196,8 +190,10 @@ def ema_summary_endpoint(input_data: DateRange): # Ganti nama fungsi
             return {"status": "error", "message": f"Data terlalu sedikit ({len(df)} hari). Butuh minimal 50 hari untuk EMA50."}
 
         logging.debug(f"Memanggil ema_manual untuk EMA20 dengan {len(df)} data.")
+        # BARIS INI YANG DIPERBAIKI:
         df["EMA20"] = ema_manual(df["close"].tolist(), 20)
         logging.debug(f"Memanggil ema_manual untuk EMA50 dengan {len(df)} data.")
+        # BARIS INI YANG DIPERBAIKI:
         df["EMA50"] = ema_manual(df["close"].tolist(), 50)
         df = df.dropna().reset_index(drop=True)
         logging.debug(f"Jumlah baris setelah dropna: {len(df)}")