Post new Amazon orders to Slack

from datetime import datetime, timedelta, timezone
from clickruntime import on_trigger, credentials, http, state, notify, report_fetched

API = "https://sellingpartnerapi-na.amazon.com/orders/v0/orders"

@on_trigger
def run(event):
    headers = {"x-amz-access-token": credentials.connection("amazon-seller-central", "us")}
    since = state.get("since") or (datetime.now(timezone.utc) - timedelta(minutes=15)).strftime("%Y-%m-%dT%H:%M:%SZ")
    orders = http.get(API, headers=headers,
                      params={"MarketplaceIds": "ATVPDKIKX0DER", "CreatedAfter": since}).json()["payload"]["Orders"]
    report_fetched(len(orders))
    if not orders:
        return {"new": 0}
    for o in orders:
        items = http.get(f"{API}/{o['AmazonOrderId']}/orderItems", headers=headers).json()["payload"]["OrderItems"]
        skus = ", ".join(f"{i['QuantityOrdered']}× {i['SellerSKU']}" for i in items)
        total = o.get("OrderTotal") or {"Amount": "pending", "CurrencyCode": ""}
        notify.slack(f"Amazon order {o['AmazonOrderId']}: {skus} · {total['CurrencyCode']} {total['Amount']}",
                     channel="#amazon-orders")
    state.set("since", max(o["PurchaseDate"] for o in orders))
    return {"new": len(orders)}