How to Build a TikTok-to-Amazon Product Tracker

import os, requests, re, json

API_KEY = os.environ['SCAVIO_API_KEY']
TT_H = {'Authorization': f'Bearer {API_KEY}', 'Content-Type': 'application/json'}
SH = {'x-api-key': API_KEY, 'Content-Type': 'application/json'}

def scan_hashtag(tag):
    data = requests.post('https://api.scavio.dev/api/v1/tiktok/hashtag/videos',
        headers=TT_H, json={'name': tag}).json()
    videos = data.get('videos', data.get('data', {}).get('videos', []))[:20]
    products = []
    for v in videos:
        desc = v.get('desc', v.get('description', ''))
        if any(w in desc.lower() for w in ['link in bio', 'amazon', 'must have', 'under $']):
            products.append({'desc': desc[:120], 'views': v.get('stats', {}).get('playCount', 0),
                'author': v.get('author', {}).get('uniqueId', 'unknown')})
    print(f'#{tag}: {len(videos)} videos, {len(products)} product mentions')
    return products

products = scan_hashtag('amazonfinds')
for p in products[:3]: print(f'  {p["desc"][:60]}... ({p["views"]:,} views)')

def extract_product(desc):
    patterns = [r'([A-Z][\w\s]+(?:Pro|Max|Plus|Mini|Ultra)?)', r'the ([\w\s]+?) (?:is|from|on)']
    for p in patterns:
        m = re.search(p, desc)
        if m: return m.group(1).strip()[:50]
    words = desc.split()[:6]
    return ' '.join(w for w in words if not w.startswith('#'))[:50]

def search_amazon(product_name):
    data = requests.post('https://api.scavio.dev/api/v1/search',
        headers=SH, json={'query': product_name, 'platform': 'amazon', 'country_code': 'us'}).json()
    results = data.get('organic_results', data.get('shopping_results', []))[:3]
    return [{'title': r.get('title', '')[:60], 'price': r.get('price', 'N/A'),
             'rating': r.get('rating', 'N/A'), 'link': r.get('link', '')}
            for r in results]

for p in products[:3]:
    name = extract_product(p['desc'])
    listings = search_amazon(name)
    print(f'\n  TikTok: {name}')
    for l in listings: print(f'    Amazon: {l["title"][:50]} - {l["price"]} ({l["rating"]})')

import json
from datetime import datetime

DB_FILE = 'tiktok_amazon_prices.json'

def load_db():
    try:
        with open(DB_FILE) as f: return json.load(f)
    except: return {}

def save_db(db):
    with open(DB_FILE, 'w') as f: json.dump(db, f, indent=2)

def track_price(product_name, amazon_listing):
    db = load_db()
    key = product_name.lower().strip()
    price_str = str(amazon_listing.get('price', 'N/A')).replace('$', '').replace(',', '')
    try: price = float(price_str)
    except: return None
    now = datetime.now().isoformat()
    if key not in db: db[key] = []
    prev = db[key][-1]['price'] if db[key] else price
    change = ((price - prev) / prev * 100) if prev else 0
    db[key].append({'price': price, 'date': now})
    save_db(db)
    if abs(change) > 5:
        print(f'  ALERT: {product_name} price moved {change:+.1f}% (${prev:.2f} -> ${price:.2f})')
    return change

track_price('Stanley Cup', {'price': '$34.99'})
track_price('Stanley Cup', {'price': '$39.99'})

def run_tracker(hashtags):
    all_alerts = []
    total_cost = 0
    for tag in hashtags:
        products = scan_hashtag(tag)
        total_cost += 0.005  # 1 TikTok API call
        for p in products[:5]:  # Top 5 per hashtag
            name = extract_product(p['desc'])
            listings = search_amazon(name)
            total_cost += 0.005  # 1 Amazon search
            for l in listings[:1]:
                change = track_price(name, l)
                if change and abs(change) > 5:
                    all_alerts.append({'product': name, 'change': change,
                        'price': l['price'], 'views': p['views']})
    print(f'\nScanned {len(hashtags)} hashtags. Cost: ${total_cost:.3f}')
    print(f'Price alerts: {len(all_alerts)}')
    for a in all_alerts:
        print(f'  {a["product"]}: {a["change"]:+.1f}% -> {a["price"]} ({a["views"]:,} TikTok views)')
    return all_alerts

run_tracker(['amazonfinds', 'tiktokmademebuyit'])