Log booked meetings in Pipedrive and tell the team

from clickruntime import on_event, credentials, http, notify

API = "https://api.pipedrive.com"

@on_event
def handle(event):
    p = (event.json or {}).get("payload", {})
    email, name, start = p.get("email"), p.get("name"), p.get("scheduled_event", {}).get("start_time", "")
    if not email:
        return {"ignored": True}
    headers = {"Authorization": f"Bearer {credentials.connection('pipedrive', 'work')}"}
    found = http.get(f"{API}/api/v2/persons/search", headers=headers,
                     params={"term": email, "fields": "email", "exact_match": "true"}).json()["data"]["items"]
    if found:
        person_id = found[0]["item"]["id"]
    else:
        person_id = http.post(f"{API}/api/v2/persons", headers=headers, json={
            "name": name or email, "emails": [{"value": email, "primary": True}]}).json()["data"]["id"]
    http.post(f"{API}/v1/activities", headers=headers, json={
        "subject": f"Meeting with {name or email}", "type": "meeting", "person_id": person_id,
        "due_date": start[:10], "due_time": start[11:16]})
    notify.slack(f"New meeting booked: {name} <{email}> on {start[:10]} at {start[11:16]} UTC", channel="#sales")
    return {"person": person_id}