Track competitor prices from a sheet

import re
from datetime import date
from bs4 import BeautifulSoup
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, state, log

SHEET_ID = "your-spreadsheet-id"
CHAT_ID = "your-telegram-chat-id"

def read_price(url):
    soup = BeautifulSoup(http.get(url, timeout=15).text, "lxml")
    tag = soup.find("meta", itemprop="price") or soup.find("meta", property="product:price:amount")
    if tag:
        return float(tag["content"])
    m = re.search(r"\d+[.,]\d{2}", soup.get_text(" "))
    return float(m.group().replace(",", ".")) if m else None

@on_trigger
def run(event):
    values = build("sheets", "v4", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).spreadsheets().values()
    urls = [r[0] for r in values.get(spreadsheetId=SHEET_ID, range="Competitors!A2:A").execute().get("values", []) if r]
    last, changes = state.get("prices") or {}, []
    for n, url in enumerate(urls, start=2):
        try:
            price = read_price(url)
        except Exception as e:
            log.warning("Could not read price", {"url": url, "error": str(e)[:200]})
            continue
        if price is None:
            continue
        if url in last and last[url] != price:
            changes.append(f"{url}: {last[url]} -> {price}")
        last[url] = price
        values.update(spreadsheetId=SHEET_ID, range=f"Competitors!B{n}:C{n}", valueInputOption="USER_ENTERED",
                      body={"values": [[price, date.today().isoformat()]]}).execute()
    state.set("prices", last)
    if changes:
        http.post(f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}/sendMessage",
                  json={"chat_id": CHAT_ID, "text": "Price changes:\n" + "\n".join(changes)})
    return {"checked": len(urls), "changed": len(changes)}