Research new sign-ups and post strong leads to Slack

from clickruntime import on_event, credentials, http, notify, ai

ICP = "B2B software companies with 20-200 staff selling to other businesses in Europe."
SCHEMA = {"type": "object", "properties": {"score": {"type": "integer"}, "reason": {"type": "string"}, "summary": {"type": "string"}}}

def sonar(prompt):
    r = http.post("https://api.perplexity.ai/chat/completions", headers={"Authorization": f"Bearer {credentials.secret('PERPLEXITY_API_KEY')}"},
                  json={"model": "sonar", "messages": [{"role": "user", "content": prompt}]}, timeout=90).json()
    return r["choices"][0]["message"]["content"], [s["url"] for s in r.get("search_results", [])]

@on_event
def handle(event):
    s = event.json or {}
    company = s.get("company") or str(s.get("email", "")).partition("@")[2]
    if not company:
        return {"skipped": "no company"}
    research, links = sonar(f"What does {company} do? Size, market, location, recent news. Short.")
    fit = ai.generate(f"Ideal customer: {ICP}\nResearch:\n{research[:3000]}\nScore the fit 1-10, give a one-line reason "
                      "and a two-line company summary.", json_schema=SCHEMA, max_output_tokens=200).json
    if fit["score"] >= 7:
        notify.slack(f"🔥 *{company}* scored {fit['score']}/10 · {s.get('name', '')} <{s.get('email', '')}>\n"
                     f"{fit['summary']}\n_Why:_ {fit['reason']}\n" + " ".join(f"<{l}|source>" for l in links[:3]), channel="#leads")
    return {"company": company, "score": fit["score"]}