AI outbound prospecting agent that sources leads and drafts the email

def tool(connector, tool_name, **kwargs):
    return connect.actions.execute_tool(
        tool_name=tool_name,
        identifier=USER_ID,
        connected_account_id=connector,
        tool_input=kwargs,
    )

prospects = tool(
    "apollo", "apollo_search_contacts",
    title=ICP_TITLES,
    industry=ICP_INDUSTRIES,
    per_page=PROSPECT_LIMIT,
)["contacts"]

for p in prospects:
    if not p.get("email") or not p.get("title"):
        enriched = tool(
            "apollo", "apollo_enrich_contact",
            id=p["id"],
        )
        p.update(enriched.get("person", {}))

scored = sorted(
    prospects, key=score_prospect, reverse=True
)[:PROSPECT_LIMIT]

for p in scored:
    subject, body = draft_email(p)
    # LLM via OpenRouter or keyword template

    tool(
        "gmail", "gmail_create_draft",
        to=p.get("email", ""),
        subject=subject,
        body=body,
    )
    # Native Scalekit tool — no raw token, no MIME, no REST call

existing = tool(
    "googlesheets", "googlesheets_get_values",
    spreadsheet_id=SHEETS_ID,
    range=SHEETS_RANGE,
)
if not existing.get("values"):
    tool(
        "googlesheets", "googlesheets_append_values",
        value_input_option="RAW",
        insert_data_option="INSERT_ROWS",
        spreadsheet_id=SHEETS_ID,
        range=SHEETS_RANGE,
        values=[["Name","Company","Title","Email",
                 "ICP Score","Signals","Subject"]],
    )

tool(
    "googlesheets", "googlesheets_append_values",
        value_input_option="RAW",
        insert_data_option="INSERT_ROWS",
    spreadsheet_id=SHEETS_ID,
    range=SHEETS_RANGE,
    values=[[
        p.get("name"), p.get("organization_name"),
        p.get("title"), p.get("email"),
        score_prospect(p), subject,
    ]],
)