Update app.py

app.py

@@ -6,11 +6,11 @@ import time
 import csv
 import threading
 import os
-from huggingface_hub import HfApi
+from huggingface_hub import HfApi, hf_hub_download
 
 # Hugging Face credentials
 HF_USERNAME = "abolfazle80"  # Your Hugging Face username
-REPO_NAME = "cr_4"  # Your dataset repo name
+REPO_NAME = "crypto_data"  # Your dataset repo name
 CSV_FILENAME = "USDT.csv"  # File in your dataset
 
 # Define the markets (cryptocurrencies to monitor)
@@ -22,26 +22,20 @@ api = HfApi()
 # Flag to control fetching loop
 loop_running = False
 
-# Function to get price and volume data from CoinEx
-def get_crypto_price_from_coinex(symbol):
-    url = 'https://api.coinex.com/v1/market/ticker'
-    params = {'market': symbol}
-
-    try:
-        response = requests.get(url, params=params)
-        response.raise_for_status()  # Check for HTTP errors
-        data = response.json()
-
-        if 'data' in data:
-            price = data['data']['ticker']['last']
-            volume = data['data']['ticker']['vol']
-            return [price, volume]  # Return as list
-        else:
-            return ["Symbol not found", "Symbol not found"]
-    except requests.exceptions.RequestException as e:
-        return ["Request error", "Request error"]
-    except ValueError as e:
-        return ["JSON decode error", "JSON decode error"]
+# Function to download CSV if missing
+def download_csv_if_needed():
+    """Downloads CSV from Hugging Face if not present locally."""
+    if not os.path.exists(CSV_FILENAME):
+        try:
+            hf_hub_download(
+                repo_id=f"{HF_USERNAME}/{REPO_NAME}",
+                filename=CSV_FILENAME,
+                repo_type="dataset",
+                local_dir=".",  # Save in current directory
+            )
+            print("✅ CSV downloaded successfully!")
+        except Exception as e:
+            print(f"❌ Download failed: {e}")
 
 # Function to upload CSV to Hugging Face
 def upload_to_huggingface():
@@ -91,9 +85,33 @@ def fetch_data():
             print(f"❌ Error: {e}")
             loop_running = False  # Stop loop if error occurs
 
+# Function to get price and volume data from CoinEx
+def get_crypto_price_from_coinex(symbol):
+    url = 'https://api.coinex.com/v1/market/ticker'
+    params = {'market': symbol}
+
+    try:
+        response = requests.get(url, params=params)
+        response.raise_for_status()  # Check for HTTP errors
+        data = response.json()
+
+        if 'data' in data:
+            price = data['data']['ticker']['last']
+            volume = data['data']['ticker']['vol']
+            return [price, volume]  # Return as list
+        else:
+            return ["Symbol not found", "Symbol not found"]
+    except requests.exceptions.RequestException as e:
+        return ["Request error", "Request error"]
+    except ValueError as e:
+        return ["JSON decode error", "JSON decode error"]
+
 # Streamlit UI elements
 st.title("📊 Live Crypto Data Fetcher")
 
+# Ensure CSV is available
+download_csv_if_needed()
+
 # Start button
 if st.button("Start Fetching Data"):
     if not loop_running: