1
import requests
2
import time
3
import json # Although requests handles JSON, explicitly importing might be useful for debugging
4

5
# --- Configuration ---
6
TELEGRAM_BOT_TOKEN = "YOUR_TELEGRAM_BOT_TOKEN" # Replace with your token
7
TELEGRAM_CHAT_ID = "YOUR_TELEGRAM_CHAT_ID"     # Replace with your chat ID
8

9
CRYPTO_ID = "bitcoin" # Example: "bitcoin", "ethereum", "cardano"
10
ALERT_PRICE_USD = 40000 # Set the price threshold for the alert
11

12
CHECK_INTERVAL_SECONDS = 300 # Check every 5 minutes (300 seconds)
13

14
# --- API Endpoints ---
15
COINGECKO_PRICE_API_URL = f"https://api.coingecko.com/api/v3/simple/price?ids={CRYPTO_ID}&vs_currencies=usd"
16
TELEGRAM_SEND_MESSAGE_URL = f"https://api.telegram.org/bot{TELEGRAM_BOT_TOKEN}/sendMessage"
17

18
# --- Functions ---
19

20
def get_crypto_price(crypto_id, vs_currency="usd"):
21
    """Fetches the current price of a cryptocurrency from CoinGecko."""
22
    url = f"https://api.coingcko.com/api/v3/simple/price?ids={crypto_id}&vs_currencies={vs_currency}"
23
    try:
24
        response = requests.get(url)
25
        response.raise_for_status() # Raise an exception for bad status codes (4xx or 5xx)
26
        data = response.json()
27
        # Navigating the JSON structure: data -> crypto_id -> vs_currency
28
        price = data.get(crypto_id, {}).get(vs_currency)
29
        if price is None:
30
             print(f"Warning: Price data for {crypto_id} in {vs_currency} not found in response.")
31
        return price
32
    except requests.exceptions.RequestException as e:
33
        print(f"Error fetching price for {crypto_id}: {e}")
34
        return None
35
    except json.JSONDecodeError:
36
        print(f"Error decoding JSON response from CoinGecko.")
37
        return None
38
    except Exception as e:
39
        print(f"An unexpected error occurred during price fetch: {e}")
40
        return None
41

42

43
def send_telegram_message(chat_id, text):
44
    """Sends a message to the specified Telegram chat."""
45
    payload = {
46
        'chat_id': chat_id,
47
        'text': text,
48
        'parse_mode': 'Markdown' # Use Markdown for formatting
49
    }
50
    try:
51
        response = requests.post(TELEGRAM_SEND_MESSAGE_URL, json=payload)
52
        response.raise_for_status() # Raise an exception for bad status codes
53
        print(f"Message sent to chat ID {chat_id}")
54
    except requests.exceptions.RequestException as e:
55
        print(f"Error sending Telegram message: {e}")
56
    except Exception as e:
57
        print(f"An unexpected error occurred during message sending: {e}")
58

59
# --- Main Logic ---
60
if __name__ == "__main__":
61
    print(f"Starting price monitoring for {CRYPTO_ID}...")
62
    print(f"Alert threshold set at ${ALERT_PRICE_USD}")
63

64
    # State variable to prevent spamming alerts for the same condition
65
    alert_triggered_above = False
66
    alert_triggered_below = False # Can add logic for below threshold alerts too
67

68
    while True:
69
        current_price = get_crypto_price(CRYPTO_ID, "usd")
70

71
        if current_price is not None:
72
            print(f"Current price of {CRYPTO_ID}: ${current_price}")
73

74
            # --- Check for Alert Condition (e.g., price goes ABOVE threshold) ---
75
            if current_price > ALERT_PRICE_USD and not alert_triggered_above:
76
                message = f"🚨 *Price Alert!* 🚨\n\n" \
77
                          f"The price of *{CRYPTO_ID.capitalize()}* ({CRYPTO_ID.upper()}) has exceeded your threshold!\n\n" \
78
                          f"Current Price: *${current_price:.2f}*\n" \
79
                          f"Threshold: *${ALERT_PRICE_USD:.2f}*\n\n" \
80
                          f"Check the market!"
81
                send_telegram_message(TELEGRAM_CHAT_ID, message)
82
                alert_triggered_above = True # Set flag to true after triggering
83

84
            # --- Optional: Check for price dropping BELOW threshold ---
85
            elif current_price < ALERT_PRICE_USD and not alert_triggered_below:
86
                 # Example for below threshold, modify condition and message as needed
87
                 # This simple example just checks ABOVE, so this part is illustrative
88
                 pass # Implement logic here if needed for below alerts
89
                 # message = f"... below threshold message ..."
90
                 # send_telegram_message(TELEGRAM_CHAT_ID, message)
91
                 # alert_triggered_below = True
92

93
            # --- Optional: Reset alert trigger flag if price goes back below/above threshold ---
94
            # This allows the alert to trigger again if the price fluctuates
95
            if current_price <= ALERT_PRICE_USD and alert_triggered_above:
96
                alert_triggered_above = False
97
                print("Price dropped below threshold, resetting above-threshold alert flag.")
98

99
            # Add similar logic here for resetting 'alert_triggered_below' if implemented
100

101

102
        print(f"Waiting for {CHECK_INTERVAL_SECONDS} seconds before next check...")
103
        time.sleep(CHECK_INTERVAL_SECONDS)