Log every sale to Airtable and a sheet

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_event, credentials, http, notify, state

BASE_ID = "appXXXXXXXXXXXXXX"
SHEET_ID = "1AbCdEfGhIjKlMnOpQrStUvWxYz"

@on_event
def handle(event):
    sale = event.json or {}
    sale_id = str(sale.get("sale_id") or event.event_id)
    if state.get(f"sale:{sale_id}"):
        return {"duplicate": True}
    product, email = sale.get("product_name", ""), sale.get("email", "")
    amount = round(float(sale.get("price") or 0) / 100, 2)
    http.post(f"https://api.airtable.com/v0/{BASE_ID}/Sales",
              headers={"Authorization": f"Bearer {credentials.connection('airtable', 'work')}"},
              json={"typecast": True, "records": [{"fields": {"Sale ID": sale_id, "Product": product,
                    "Amount": amount, "Email": email, "Date": event.received_at[:10]}}]}).raise_for_status()
    sheets = build("sheets", "v4", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    sheets.spreadsheets().values().append(spreadsheetId=SHEET_ID, range="Sales!A:E", valueInputOption="USER_ENTERED",
        body={"values": [[event.received_at[:10], sale_id, product, amount, email]]}).execute()
    state.set(f"sale:{sale_id}", True)
    notify.slack(f"New sale: {product} for ${amount:.2f}", channel="#sales")
    return {"logged": sale_id}