Deal intelligence agents that risk-score every call on-behalf-of your users

class GongConnector:
    def __init__(self, connect, user_id):
        self.connect = connect
        self.user_id = user_id

    def list_calls(self, limit=10):
        result = self.connect.execute_tool(
            tool_name="gong_list_calls",
            identifier=self.user_id,
            tool_input={"limit": limit},
            connection_name="gong",
        )
        return result.data.get("calls", []) if result.data else []

def analyze_call(transcript, title, api_key, model):
    result = analyze_with_llm(transcript, title, api_key, model)
    return result or analyze_rule_based(transcript, title)

def compute_risk_score(analysis):
    score = 0.0
    score += (1.0 - float(analysis.get("sentiment_score", 0.5))) * 0.4
    score += (1.0 if analysis.get("engagement_level") == "low" else 0.0) * 0.3
    score += min(len(analysis.get("objections", [])) / 5.0, 1.0) * 0.2
    score += (1.0 if analysis.get("competitor_mentions") else 0.0) * 0.1
    return round(max(0.0, min(score, 1.0)), 2)

class AttioConnector:
    def __init__(self, connect, user_id):
        self.connect = connect
        self.user_id = user_id

    def search_deals(self, company_name, limit=5):
        result = self.connect.execute_tool(
            tool_name="attio_search_records",
            identifier=self.user_id,
            tool_input={"object_type": "deals", "query": company_name, "limit": limit},
            connection_name="attio",
        )
        return result.data.get("results", []) if result.data else []

# connectors/slack.py — post the prioritized report as a DM
report = slack.format_risk_report(calls_analysis)
slack.send_dm(SLACK_DM_USER, report)
# execute_tool(tool_name="slack_send_message",
#              tool_input={"channel": user_id, "text": report},
#              connection_name="slack")

# scheduler.py — run automatically, no manual runs
#   python scheduler.py                  # every hour (default)
#   python scheduler.py --interval 43200 # every 12 hours
#   python scheduler.py --once           # one run, for cron