Track Competitor Launches in Real Time with You.com Web Search API, One, HubSpot, and Slack

one add you # You.com Search API
one add hubspot # HubSpot CRM
one add slack # Slack workspace

one --agent connection list

{
 "total": 3,
 "connections": [
 {"platform": "you", "state": "operational", "key": "live::you::default::a1b2c3..."},
 {"platform": "hubspot", "state": "operational", "key": "live::hubspot::default::d4e5f6..."},
 {"platform": "slack", "state": "operational", "key": "live::slack::default::g7h8i9..."}
 ]
}

one --agent actions search you "web search" -t execute

one --agent actions knowledge you <actionId>

one --agent actions execute you <actionId> <you_connection_key> \
 --query-params '{
 "query": "Acme Corp product launch OR new feature OR release",
 "count": 10,
 "freshness": "week",
 "livecrawl": "all"
 }'

{
 "results": {
 "web": [
 {
 "url": "https://techcrunch.com/2026/06/15/acme-corp-launches-ai-suite",
 "title": "Acme Corp Launches Enterprise AI Suite",
 "description": "Acme Corp announced a new enterprise AI platform...",
 "snippets": ["The suite includes natural language processing..."],
 "page_age": "2 days ago",
 "authors": ["Jane Reporter"],
 "favicon_url": "https://techcrunch.com/favicon.ico"
 }
 ],
 "news": [
 {
 "title": "Acme Corp Announces Enterprise AI Platform",
 "description": "The new platform targets Fortune 500 customers...",
 "page_age": "2026-06-15T08:30:00Z",
 "url": "https://news.example.com/acme-ai-launch"
 }
 ]
 },
 "metadata": {
 "search_uuid": "8d7f4d8e-2f4d-4f8f-9f2d-123456789abc",
 "query": "Acme Corp product launch OR new feature OR release",
 "latency": 0.482
 }
}

HIGH_SIGNAL_KEYWORDS = [
 "launch", "announce", "release", "new feature",
 "integrates", "partnership", "acquires", "raises"
]
NOISE_DOMAINS = ["prnewswire.com", "businesswire.com", "globenewswire.com"]

def is_high_signal(result: dict) -> bool:
 text = (result.get("title", "") + " " + result.get("description", "")).lower()
 has_signal_keyword = any(kw in text for kw in HIGH_SIGNAL_KEYWORDS)
 is_noise_source = any(nd in result.get("url", "") for nd in NOISE_DOMAINS)
 return has_signal_keyword and not is_noise_source

one --agent actions search hubspot "search companies by object type" -t execute

one --agent actions knowledge hubspot <actionId>

one --agent actions execute hubspot <actionId> <hubspot_connection_key> \
 --path-vars '{"objectType": "companies"}' \
 -d '{
 "after": "0",
 "filterGroups": [{
 "filters": [{
 "propertyName": "name",
 "operator": "CONTAINS_TOKEN",
 "value": "Acme Corp"
 }]
 }],
 "limit": 1,
 "properties": ["name", "lifecyclestage", "hs_lastmodifieddate"],
 "sorts": []
 }'

{
 "total": 1,
 "results": [
 {
 "id": "12345",
 "properties": {
 "name": "Acme Corp",
 "lifecyclestage": "opportunity",
 "hs_lastmodifieddate": "1718467200000"
 },
 "createdAt": "2024-01-10T09:00:00Z",
 "updatedAt": "2026-06-15T12:00:00Z"
 }
 ]
}

one --agent actions search slack "post message" -t execute

one --agent actions knowledge slack <actionId>

one --agent actions execute slack <actionId> <slack_connection_key> \
 -d '{
 "channel": "#competitive-intel",
 "text": "Competitor Signal: Acme Corp — Acme Corp Launches Enterprise AI Suite",
 "blocks": [
 {
 "type": "header",
 "text": {"type": "plain_text", "text": "Competitor Signal: Acme Corp"}
 },
 {
 "type": "section",
 "text": {
 "type": "mrkdwn",
 "text": "*<https://techcrunch.com/2026/06/15/acme-corp-launches-ai-suite|Acme Corp Launches Enterprise AI Suite>*\nAcme Corp announced a new enterprise AI platform targeting Fortune 500 customers..."
 }
 },
 {
 "type": "context",
 "elements": [
 {"type": "mrkdwn", "text": "CRM Status: *In CRM — stage: opportunity*"},
 {"type": "mrkdwn", "text": "Source: techcrunch.com"}
 ]
 }
 ]
 }'

import json
import subprocess
import sqlite3
import os

COMPETITORS = ["Acme Corp", "Rival Inc", "Contender AI"] # replace with your list
SLACK_CHANNEL = "#competitive-intel"

# Connection keys from `one --agent connection list`, read from env vars
YOU_CONN = os.environ["YOU_CONN"]
HUBSPOT_CONN = os.environ["HUBSPOT_CONN"]
SLACK_CONN = os.environ["SLACK_CONN"]

# Action IDs from `one --agent actions search`
YOU_SEARCH_ACTION = "conn_mod_def::GK9ryAH-nnE::w01ioTnIQNe0B_qm2YtVnQ"
HUBSPOT_SEARCH_ACTION = "conn_mod_def::GJ3kQvNreBM::Zpab8Ig5TSivqCj1UhG37w"
SLACK_POST_ACTION = "conn_mod_def::GJ7H84zBlaI::BCfuA16aTaGVIax5magsLA"

def one_execute(platform, action_id, conn_key, path_vars=None, query_params=None, data=None):
 cmd = ["one", "--agent", "actions", "execute", platform, action_id, conn_key]
 if path_vars:
 cmd += ["--path-vars", json.dumps(path_vars)]
 if query_params:
 cmd += ["--query-params", json.dumps(query_params)]
 if data:
 cmd += ["-d", json.dumps(data)]
 result = subprocess.run(cmd, capture_output=True, text=True)
 if result.returncode != 0:
 raise RuntimeError(f"One CLI failed: {result.stderr}")
 return json.loads(result.stdout)

def get_seen_urls(db_path="seen_urls.db") -> set:
 conn = sqlite3.connect(db_path)
 conn.execute("CREATE TABLE IF NOT EXISTS seen (url TEXT PRIMARY KEY)")
 urls = {row[0] for row in conn.execute("SELECT url FROM seen")}
 conn.close()
 return urls

def mark_seen(url: str, db_path="seen_urls.db"):
 conn = sqlite3.connect(db_path)
 conn.execute("INSERT OR IGNORE INTO seen VALUES (?)", (url,))
 conn.commit()
 conn.close()

def get_crm_context(competitor_name: str) -> str:
 response = one_execute(
 "hubspot", HUBSPOT_SEARCH_ACTION, HUBSPOT_CONN,
 path_vars={"objectType": "companies"},
 data={
 "after": "0",
 "filterGroups": [{
 "filters": [{
 "propertyName": "name",
 "operator": "CONTAINS_TOKEN",
 "value": competitor_name
 }]
 }],
 "limit": 1,
 "properties": ["name", "lifecyclestage"],
 "sorts": []
 }
 )
 if response.get("total", 0) == 0:
 return "Not in CRM"
 company = response["results"][0]
 stage = company["properties"].get("lifecyclestage", "unknown")
 return f"In CRM — stage: {stage}"

def post_to_slack(channel: str, competitor: str, result: dict, crm_context: str):
 title = result.get("title", "Untitled")
 url = result.get("url", "")
 description = result.get("description", "")
 source = url.split("/")[2] if "/" in url else "unknown"
 one_execute(
 "slack", SLACK_POST_ACTION, SLACK_CONN,
 data={
 "channel": channel,
 "text": f"Competitor Signal: {competitor} — {title}",
 "blocks": [
 {
 "type": "header",
 "text": {"type": "plain_text", "text": f"Competitor Signal: {competitor}"}
 },
 {
 "type": "section",
 "text": {
 "type": "mrkdwn",
 "text": f"*<{url}|{title}>*\n{description}"
 }
 },
 {
 "type": "context",
 "elements": [
 {"type": "mrkdwn", "text": f"CRM Status: *{crm_context}*"},
 {"type": "mrkdwn", "text": f"Source: {source}"}
 ]
 }
 ]
 }
 )

def run_competitive_intel_loop():
 seen_urls = get_seen_urls()
 for competitor in COMPETITORS:
 response = one_execute(
 "you", YOU_SEARCH_ACTION, YOU_CONN,
 query_params={
 "query": f"{competitor} product launch OR new feature OR release",
 "count": 10,
 "freshness": "week",
 "livecrawl": "all"
 }
 )
 results = response.get("results", {})
 all_results = results.get("web", []) + results.get("news", [])
 for result in all_results:
 url = result.get("url", "")
 if url in seen_urls:
 continue
 if not is_high_signal(result):
 continue
 crm_context = get_crm_context(competitor)
 post_to_slack(SLACK_CHANNEL, competitor, result, crm_context)
 mark_seen(url)

# Schedule via cron: 0 8 * * * python run_competitive_intel_loop.py

one init --auth browser
one add you
one add hubspot
one add slack

one --agent actions search you "web search" -t execute
one --agent actions search hubspot "search companies by object type" -t execute
one --agent actions search slack "post message" -t execute