Update app.py

app.py

@@ -44,6 +44,67 @@ def get_crypto_price(crypto: str, currency: str) -> str:
     except requests.RequestException as e:
         return f"Error fetching price: {e}"
 
+@tool
+def get_crypto_history(crypto: str, currency: str, days: int) -> str:
+    """A tool to fetch historical cryptocurrency prices from CoinGecko API.
+    
+    Args:
+        crypto: The cryptocurrency symbol (e.g., 'bitcoin', 'ethereum').
+        currency: The fiat currency (e.g., 'usd', 'twd').
+        days: The number of past days to retrieve (e.g., 30 for the past month).
+    
+    Returns:
+        A list of historical prices over the specified time period.
+    """
+    url = f"https://api.coingecko.com/api/v3/coins/{crypto}/market_chart?vs_currency={currency}&days={days}&interval=daily"
+    try:
+        response = requests.get(url)
+        response.raise_for_status()
+        data = response.json()
+        prices = data.get("prices", [])
+
+        if not prices:
+            return "No historical data available."
+
+        prices_str = "\n".join([f"Date: {pd.to_datetime(p[0], unit='ms').date()}, Price: {p[1]:.2f} {currency}" for p in prices])
+        return f"Historical prices for {crypto} in {currency} over {days} days:\n{prices_str}"
+    
+    except requests.RequestException as e:
+        return f"Error fetching historical data: {e}"
+
+@tool
+def get_crypto_moving_average(crypto: str, currency: str, days: int, window: int) -> str:
+    """A tool to compute the moving average of cryptocurrency prices.
+    
+    Args:
+        crypto: The cryptocurrency symbol (e.g., 'bitcoin', 'ethereum').
+        currency: The fiat currency (e.g., 'usd', 'twd').
+        days: The number of past days to retrieve.
+        window: The moving average window size (e.g., 7 for 7-day SMA).
+    
+    Returns:
+        A list of moving average values.
+    """
+    url = f"https://api.coingecko.com/api/v3/coins/{crypto}/market_chart?vs_currency={currency}&days={days}&interval=daily"
+    try:
+        response = requests.get(url)
+        response.raise_for_status()
+        data = response.json()
+        prices = data.get("prices", [])
+
+        if not prices or len(prices) < window:
+            return "Not enough data for moving average calculation."
+
+        df = pd.DataFrame(prices, columns=["timestamp", "price"])
+        df["date"] = pd.to_datetime(df["timestamp"], unit="ms").dt.date
+        df["sma"] = df["price"].rolling(window=window).mean()
+
+        moving_avg_str = "\n".join([f"Date: {df['date'][i]}, SMA: {df['sma'][i]:.2f} {currency}" for i in range(len(df)) if not np.isnan(df['sma'][i])])
+        return f"Moving Average (window={window}) for {crypto} in {currency} over {days} days:\n{moving_avg_str}"
+    
+    except requests.RequestException as e:
+        return f"Error fetching historical data: {e}"
+
 @tool
 def get_current_time_in_timezone(timezone: str) -> str:
     """A tool that fetches the current local time in a specified timezone.