Diesel Fuel Prices

import requests

API_KEY = "YOUR_API_KEY"
BASE_URL = "https://api.oilpriceapi.com/v1"

def get_diesel_prices():
    """Get both Gulf Coast and NY Harbor diesel prices."""
    headers = {"Authorization": f"Token {API_KEY}"}
    params = {"by_code": "DIESEL_USD,ULSD_DIESEL_USD"}

    response = requests.get(
        f"{BASE_URL}/prices/latest",
        headers=headers,
        params=params
    )

    return response.json()

def get_diesel_spread():
    """Calculate the NY Harbor premium over Gulf Coast."""
    data = get_diesel_prices()

    # Parse prices from response
    prices = data["data"]
    gulf_coast = None
    ny_harbor = None

    # Handle both single and multiple price responses
    if isinstance(prices, list):
        for p in prices:
            if p["code"] == "DIESEL_USD":
                gulf_coast = p["price"]
            elif p["code"] == "ULSD_DIESEL_USD":
                ny_harbor = p["price"]
    else:
        # Single price response
        if prices["code"] == "DIESEL_USD":
            gulf_coast = prices["price"]
        elif prices["code"] == "ULSD_DIESEL_USD":
            ny_harbor = prices["price"]

    if gulf_coast and ny_harbor:
        spread = ny_harbor - gulf_coast
        spread_percent = (spread / gulf_coast) * 100

        print(f"Gulf Coast: ${gulf_coast:.3f}/gal")
        print(f"NY Harbor:  ${ny_harbor:.3f}/gal")
        print(f"Spread:     ${spread:.3f}/gal ({spread_percent:.1f}%)")

        return spread

    return None

# Usage
spread = get_diesel_spread()

def check_diesel_price_threshold(threshold_price=2.50):
    """Alert when diesel drops below threshold."""
    data = get_diesel_prices()

    for price_data in data.get('data', []):
        if price_data['price'] < threshold_price:
            print(f"Low price alert: {price_data['code']} at ${price_data['price']}/gal")
            # Trigger purchase order or notification