Date & Time (UTC)    | Trade ID     | Type | Price      | Amount      
----------------------------------------------------------------------
2026-06-11 01:08:26  | 589192656    | SELL | 61856.21   | 0.00081285  
2026-06-11 01:08:21  | 589192642    | SELL | 61880.27   | 0.01616312  
2026-06-11 01:08:21  | 589192641    | SELL | 61881.00   | 0.00179892  
2026-06-11 01:08:21  | 589192618    | SELL | 61882.39   | 0.00016321  
2026-06-11 01:08:21  | 589192617    | SELL | 61883.09   | 0.00009963

2026-06-11 00:08:49  | 589175259    | BUY  | 61559.84   | 0.01522248  
2026-06-11 00:08:46  | 589175254    | SELL | 61560.98   | 0.00008207

import datetime
import httpx
import sys

PAIR = "btcusd"
LIMIT = 100

def get_public_trades(currency_pair="btcusd", limit=50):
    """Fetches recent public trades from Bitstamp using HTTP/2 to bypass Cloudflare."""
    # url = f"https://bitstamp.net{currency_pair}/"
    url = f"https://www.bitstamp.net/api/v2/transactions/{currency_pair}/"

    # Precise header set matching a realistic modern browser footprint
    headers = {
        "User-Agent": (
            "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36"
            " (KHTML, like Gecko) Chrome/122.0.0.0 Safari/537.36"
        ),
        "Accept": "application/json, text/plain, */*",
        "Accept-Language": "en-US,en;q=0.9",
        "Referer": "https://www.bitstamp.net/",
        "Origin": "https://www.bitstamp.net",
    }

    params = {"limit": limit}

    # Initialize a client enforcing HTTP/2 protocol architecture
    with httpx.Client(http2=True, headers=headers, timeout=10.0) as client:
        try:
            response = client.get(url, params=params)

            if response.status_code == 403:
                print(
                    "Error 403: Cloudflare protection blocked the request."
                    " Your local IP signature is flagged."
                )
                return []

            response.raise_for_status()
            return response.json()

        except httpx.HTTPStatusError as e:
            print(f"HTTP Error: {e.response.status_code}")
            return []
        except Exception as e:
            print(f"An unexpected connection issue occurred: {e}")
            return []


def format_and_print_trades(trades, print_limit=5000):
    """Formats and prints parsed public trade logs."""
    if not trades or not isinstance(trades, list):
        print("No trade data available to print.")
        return

    print(f"\n--- Printing Last {print_limit} Public Trades ---")
    print(
        f"{'Date & Time (UTC)':<20} | {'Trade ID':<12} | {'Type':<4} |"
        f" {'Price':<10} | {'Amount':<12}"
    )
    print("-" * 70)
    trades_shown = trades if not print_limit else trades[:print_limit]

    for trade in trades_shown:
        timestamp = int(trade.get("date"))
        date_str = datetime.datetime.fromtimestamp(
            timestamp, tz=datetime.timezone.utc
        ).strftime("%Y-%m-%d %H:%M:%S")

        trade_id = trade.get("tid")
        amount = trade.get("amount")
        price = trade.get("price")

        trade_type = "BUY" if trade.get("type") == "0" else "SELL"

        print(
            f"{date_str:<20} | {trade_id:<12} | {trade_type:<4} |"
            f" {price:<10} | {amount:<12}"
        )


if __name__ == "__main__":

    if len(sys.argv) > 1:
       print_limit = int(sys.argv[1])
       if len(sys.argv) > 2:
           pair = sys.argv[2]
       else:
           pair = PAIR
    else:
       print_limit = LIMIT


    print(f"Fetching public trade logs for {pair.upper()} via HTTP/2...")

    trade_history = get_public_trades(currency_pair=pair, limit=50)

    if trade_history:
        print(
            f"Successfully retrieved {len(trade_history)} total transactions."
        )
        format_and_print_trades(trade_history, print_limit=print_limit)