feat(recorded-future): Recorded Future + ASI integrations

Recorded Future (enrichment): native ConnectAPI v2 (X-RFToken). ip/domain/url/
file/cve risk reputation, full entity intelligence, and alert ingestion (alerts
search) with an OCSF mapper and a 'Recorded Future Alert' default type, plus
alert lookup and alert-rule search.

Recorded Future ASI (enrichment): Attack Surface Intelligence (SecurityTrails
API, APIKEY header, project-scoped). Project issue ingestion (project_issues)
with an OCSF mapper and a 'Recorded Future ASI Issue' default type, filtered by
a configurable minimum severity, plus recent-issues and recent-issues-by-host
queries.

The XSOAR-gateway packs (alerts/lists) were re-implemented against Recorded
Future's native ConnectAPI rather than the XSOAR-coupled gateway protocol.

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>

integrations/recorded-future/scripts/alert_lookup.py

@@ -0,0 +1,35 @@
+import json, os, sys, urllib.request, urllib.parse, urllib.error
+
+
+def _cfg():
+    s = json.loads(os.environ.get("INTEGRATION_SECRETS", "{}"))
+    base = str(s.get("server_url") or "https://api.recordedfuture.com").rstrip("/")
+    headers = {"X-RFToken": s.get("api_token", ""), "Accept": "application/json"}
+    return base, headers
+
+
+def _inputs():
+    return json.loads(os.environ.get("INTEGRATION_INPUTS", "{}"))
+
+
+def request(path):
+    base, headers = _cfg()
+    req = urllib.request.Request(base + "/" + path.lstrip("/"), headers=headers, method="GET")
+    with urllib.request.urlopen(req, timeout=90) as r:
+        raw = r.read()
+        return json.loads(raw) if raw else {}
+
+
+def run():
+    alert_id = urllib.parse.quote(str(_inputs().get("alert_id", "")), safe="")
+    print(json.dumps(request("/v2/alert/" + alert_id)))
+
+
+try:
+    run()
+except urllib.error.HTTPError as e:
+    print(json.dumps({"error": "HTTP " + str(e.code), "detail": e.read().decode("utf-8", "replace")}))
+    sys.exit(1)
+except Exception as e:
+    print(json.dumps({"error": str(e)}))
+    sys.exit(1)

integrations/recorded-future/scripts/alert_rules.py

@@ -0,0 +1,38 @@
+import json, os, sys, urllib.request, urllib.parse, urllib.error
+
+
+def _cfg():
+    s = json.loads(os.environ.get("INTEGRATION_SECRETS", "{}"))
+    base = str(s.get("server_url") or "https://api.recordedfuture.com").rstrip("/")
+    headers = {"X-RFToken": s.get("api_token", ""), "Accept": "application/json"}
+    return base, headers
+
+
+def _inputs():
+    return json.loads(os.environ.get("INTEGRATION_INPUTS", "{}"))
+
+
+def request(path, params):
+    base, headers = _cfg()
+    clean = {k: v for k, v in params.items() if v not in (None, "")}
+    url = base + "/" + path.lstrip("/") + ("?" + urllib.parse.urlencode(clean, doseq=True) if clean else "")
+    req = urllib.request.Request(url, headers=headers, method="GET")
+    with urllib.request.urlopen(req, timeout=90) as r:
+        raw = r.read()
+        return json.loads(raw) if raw else {}
+
+
+def run():
+    inp = _inputs()
+    params = {"freetext": inp.get("rule_name"), "limit": inp.get("limit") or 10}
+    print(json.dumps(request("/v2/alert/rule", params)))
+
+
+try:
+    run()
+except urllib.error.HTTPError as e:
+    print(json.dumps({"error": "HTTP " + str(e.code), "detail": e.read().decode("utf-8", "replace")}))
+    sys.exit(1)
+except Exception as e:
+    print(json.dumps({"error": str(e)}))
+    sys.exit(1)

integrations/recorded-future/scripts/alerts.py

@@ -0,0 +1,50 @@
+import json, os, sys, urllib.request, urllib.parse, urllib.error
+
+
+def _cfg():
+    s = json.loads(os.environ.get("INTEGRATION_SECRETS", "{}"))
+    base = str(s.get("server_url") or "https://api.recordedfuture.com").rstrip("/")
+    headers = {"X-RFToken": s.get("api_token", ""), "Accept": "application/json"}
+    return base, headers
+
+
+def _inputs():
+    return json.loads(os.environ.get("INTEGRATION_INPUTS", "{}"))
+
+
+def request(path, params):
+    base, headers = _cfg()
+    clean = {k: v for k, v in params.items() if v not in (None, "")}
+    url = base + "/" + path.lstrip("/") + ("?" + urllib.parse.urlencode(clean, doseq=True) if clean else "")
+    req = urllib.request.Request(url, headers=headers, method="GET")
+    with urllib.request.urlopen(req, timeout=90) as r:
+        raw = r.read()
+        return json.loads(raw) if raw else {}
+
+
+def run():
+    inp = _inputs()
+    params = {
+        "limit": inp.get("limit") or 50,
+        "orderby": "triggered",
+        "direction": inp.get("direction") or "desc",
+        "status": inp.get("status"),
+        "alertRule": inp.get("alert_rule"),
+        "freetext": inp.get("freetext"),
+    }
+    trig = inp.get("triggered")
+    if trig:
+        t = str(trig)
+        # A bare timestamp/relative value becomes the lower bound of a range.
+        params["triggered"] = t if ("[" in t or "," in t) else ("[" + t + ",]")
+    print(json.dumps(request("/v2/alert/search", params)))
+
+
+try:
+    run()
+except urllib.error.HTTPError as e:
+    print(json.dumps({"error": "HTTP " + str(e.code), "detail": e.read().decode("utf-8", "replace")}))
+    sys.exit(1)
+except Exception as e:
+    print(json.dumps({"error": str(e)}))
+    sys.exit(1)

integrations/recorded-future/scripts/cve.py

@@ -0,0 +1,39 @@
+import json, os, sys, urllib.request, urllib.parse, urllib.error
+
+
+def _cfg():
+    s = json.loads(os.environ.get("INTEGRATION_SECRETS", "{}"))
+    base = str(s.get("server_url") or "https://api.recordedfuture.com").rstrip("/")
+    headers = {"X-RFToken": s.get("api_token", ""), "Accept": "application/json"}
+    return base, headers
+
+
+def _inputs():
+    return json.loads(os.environ.get("INTEGRATION_INPUTS", "{}"))
+
+
+def request(path, params):
+    base, headers = _cfg()
+    clean = {k: v for k, v in params.items() if v not in (None, "")}
+    url = base + "/" + path.lstrip("/") + ("?" + urllib.parse.urlencode(clean, doseq=True) if clean else "")
+    req = urllib.request.Request(url, headers=headers, method="GET")
+    with urllib.request.urlopen(req, timeout=90) as r:
+        raw = r.read()
+        return json.loads(raw) if raw else {}
+
+
+def run():
+    value = str(_inputs().get("cve", ""))
+    out = request("/v2/vulnerability/" + urllib.parse.quote(value, safe=""),
+                  {"fields": "risk,entity,timestamps,intelCard,cvssv3,nvdDescription"})
+    print(json.dumps(out))
+
+
+try:
+    run()
+except urllib.error.HTTPError as e:
+    print(json.dumps({"error": "HTTP " + str(e.code), "detail": e.read().decode("utf-8", "replace")}))
+    sys.exit(1)
+except Exception as e:
+    print(json.dumps({"error": str(e)}))
+    sys.exit(1)

integrations/recorded-future/scripts/domain.py

@@ -0,0 +1,39 @@
+import json, os, sys, urllib.request, urllib.parse, urllib.error
+
+
+def _cfg():
+    s = json.loads(os.environ.get("INTEGRATION_SECRETS", "{}"))
+    base = str(s.get("server_url") or "https://api.recordedfuture.com").rstrip("/")
+    headers = {"X-RFToken": s.get("api_token", ""), "Accept": "application/json"}
+    return base, headers
+
+
+def _inputs():
+    return json.loads(os.environ.get("INTEGRATION_INPUTS", "{}"))
+
+
+def request(path, params):
+    base, headers = _cfg()
+    clean = {k: v for k, v in params.items() if v not in (None, "")}
+    url = base + "/" + path.lstrip("/") + ("?" + urllib.parse.urlencode(clean, doseq=True) if clean else "")
+    req = urllib.request.Request(url, headers=headers, method="GET")
+    with urllib.request.urlopen(req, timeout=90) as r:
+        raw = r.read()
+        return json.loads(raw) if raw else {}
+
+
+def run():
+    value = str(_inputs().get("domain", ""))
+    out = request("/v2/domain/" + urllib.parse.quote(value, safe=""),
+                  {"fields": "risk,entity,timestamps,intelCard"})
+    print(json.dumps(out))
+
+
+try:
+    run()
+except urllib.error.HTTPError as e:
+    print(json.dumps({"error": "HTTP " + str(e.code), "detail": e.read().decode("utf-8", "replace")}))
+    sys.exit(1)
+except Exception as e:
+    print(json.dumps({"error": str(e)}))
+    sys.exit(1)

integrations/recorded-future/scripts/file.py

@@ -0,0 +1,39 @@
+import json, os, sys, urllib.request, urllib.parse, urllib.error
+
+
+def _cfg():
+    s = json.loads(os.environ.get("INTEGRATION_SECRETS", "{}"))
+    base = str(s.get("server_url") or "https://api.recordedfuture.com").rstrip("/")
+    headers = {"X-RFToken": s.get("api_token", ""), "Accept": "application/json"}
+    return base, headers
+
+
+def _inputs():
+    return json.loads(os.environ.get("INTEGRATION_INPUTS", "{}"))
+
+
+def request(path, params):
+    base, headers = _cfg()
+    clean = {k: v for k, v in params.items() if v not in (None, "")}
+    url = base + "/" + path.lstrip("/") + ("?" + urllib.parse.urlencode(clean, doseq=True) if clean else "")
+    req = urllib.request.Request(url, headers=headers, method="GET")
+    with urllib.request.urlopen(req, timeout=90) as r:
+        raw = r.read()
+        return json.loads(raw) if raw else {}
+
+
+def run():
+    value = str(_inputs().get("file", ""))
+    out = request("/v2/hash/" + urllib.parse.quote(value, safe=""),
+                  {"fields": "risk,entity,timestamps,intelCard,hashAlgorithm"})
+    print(json.dumps(out))
+
+
+try:
+    run()
+except urllib.error.HTTPError as e:
+    print(json.dumps({"error": "HTTP " + str(e.code), "detail": e.read().decode("utf-8", "replace")}))
+    sys.exit(1)
+except Exception as e:
+    print(json.dumps({"error": str(e)}))
+    sys.exit(1)

integrations/recorded-future/scripts/intelligence.py

@@ -0,0 +1,47 @@
+import json, os, sys, urllib.request, urllib.parse, urllib.error
+
+# Map a user-facing entity type to the ConnectAPI path segment.
+TYPE_MAP = {"ip": "ip", "domain": "domain", "url": "url", "file": "hash", "hash": "hash", "cve": "vulnerability", "vulnerability": "vulnerability"}
+
+
+def _cfg():
+    s = json.loads(os.environ.get("INTEGRATION_SECRETS", "{}"))
+    base = str(s.get("server_url") or "https://api.recordedfuture.com").rstrip("/")
+    headers = {"X-RFToken": s.get("api_token", ""), "Accept": "application/json"}
+    return base, headers
+
+
+def _inputs():
+    return json.loads(os.environ.get("INTEGRATION_INPUTS", "{}"))
+
+
+def request(path, params):
+    base, headers = _cfg()
+    clean = {k: v for k, v in params.items() if v not in (None, "")}
+    url = base + "/" + path.lstrip("/") + ("?" + urllib.parse.urlencode(clean, doseq=True) if clean else "")
+    req = urllib.request.Request(url, headers=headers, method="GET")
+    with urllib.request.urlopen(req, timeout=90) as r:
+        raw = r.read()
+        return json.loads(raw) if raw else {}
+
+
+def run():
+    inp = _inputs()
+    rf_type = TYPE_MAP.get(str(inp.get("entity_type", "")).lower())
+    if not rf_type:
+        print(json.dumps({"error": "Unsupported entity_type. Use ip, domain, url, file or cve."}))
+        sys.exit(1)
+    value = str(inp.get("entity", ""))
+    out = request("/v2/" + rf_type + "/" + urllib.parse.quote(value, safe=""),
+                  {"fields": "risk,entity,timestamps,intelCard,relatedEntities,metrics,threatLists"})
+    print(json.dumps(out))
+
+
+try:
+    run()
+except urllib.error.HTTPError as e:
+    print(json.dumps({"error": "HTTP " + str(e.code), "detail": e.read().decode("utf-8", "replace")}))
+    sys.exit(1)
+except Exception as e:
+    print(json.dumps({"error": str(e)}))
+    sys.exit(1)

integrations/recorded-future/scripts/ip.py

@@ -0,0 +1,39 @@
+import json, os, sys, urllib.request, urllib.parse, urllib.error
+
+
+def _cfg():
+    s = json.loads(os.environ.get("INTEGRATION_SECRETS", "{}"))
+    base = str(s.get("server_url") or "https://api.recordedfuture.com").rstrip("/")
+    headers = {"X-RFToken": s.get("api_token", ""), "Accept": "application/json"}
+    return base, headers
+
+
+def _inputs():
+    return json.loads(os.environ.get("INTEGRATION_INPUTS", "{}"))
+
+
+def request(path, params):
+    base, headers = _cfg()
+    clean = {k: v for k, v in params.items() if v not in (None, "")}
+    url = base + "/" + path.lstrip("/") + ("?" + urllib.parse.urlencode(clean, doseq=True) if clean else "")
+    req = urllib.request.Request(url, headers=headers, method="GET")
+    with urllib.request.urlopen(req, timeout=90) as r:
+        raw = r.read()
+        return json.loads(raw) if raw else {}
+
+
+def run():
+    value = str(_inputs().get("ip", ""))
+    out = request("/v2/ip/" + urllib.parse.quote(value, safe=""),
+                  {"fields": "risk,entity,timestamps,intelCard,location,riskyCIDRIPs"})
+    print(json.dumps(out))
+
+
+try:
+    run()
+except urllib.error.HTTPError as e:
+    print(json.dumps({"error": "HTTP " + str(e.code), "detail": e.read().decode("utf-8", "replace")}))
+    sys.exit(1)
+except Exception as e:
+    print(json.dumps({"error": str(e)}))
+    sys.exit(1)

integrations/recorded-future/scripts/test_connection.py

@@ -0,0 +1,36 @@
+import json, os, sys, urllib.request, urllib.parse, urllib.error
+
+
+def _cfg():
+    s = json.loads(os.environ.get("INTEGRATION_SECRETS", "{}"))
+    base = str(s.get("server_url") or "https://api.recordedfuture.com").rstrip("/")
+    headers = {"X-RFToken": s.get("api_token", ""), "Accept": "application/json"}
+    return base, headers
+
+
+def request(path, params):
+    base, headers = _cfg()
+    clean = {k: v for k, v in params.items() if v not in (None, "")}
+    url = base + "/" + path.lstrip("/") + ("?" + urllib.parse.urlencode(clean, doseq=True) if clean else "")
+    req = urllib.request.Request(url, headers=headers, method="GET")
+    with urllib.request.urlopen(req, timeout=60) as r:
+        raw = r.read()
+        return json.loads(raw) if raw else {}
+
+
+def run():
+    # A minimal entity lookup validates both connectivity and the token.
+    request("/v2/ip/8.8.8.8", {"fields": "entity"})
+    print(json.dumps({"ok": True}))
+
+
+try:
+    run()
+except urllib.error.HTTPError as e:
+    detail = e.read().decode("utf-8", "replace")
+    msg = "API token is not valid." if e.code in (401, 403) else "HTTP " + str(e.code)
+    print(json.dumps({"ok": False, "error": msg, "detail": detail}))
+    sys.exit(1)
+except Exception as e:
+    print(json.dumps({"ok": False, "error": str(e)}))
+    sys.exit(1)

integrations/recorded-future/scripts/url.py

@@ -0,0 +1,39 @@
+import json, os, sys, urllib.request, urllib.parse, urllib.error
+
+
+def _cfg():
+    s = json.loads(os.environ.get("INTEGRATION_SECRETS", "{}"))
+    base = str(s.get("server_url") or "https://api.recordedfuture.com").rstrip("/")
+    headers = {"X-RFToken": s.get("api_token", ""), "Accept": "application/json"}
+    return base, headers
+
+
+def _inputs():
+    return json.loads(os.environ.get("INTEGRATION_INPUTS", "{}"))
+
+
+def request(path, params):
+    base, headers = _cfg()
+    clean = {k: v for k, v in params.items() if v not in (None, "")}
+    url = base + "/" + path.lstrip("/") + ("?" + urllib.parse.urlencode(clean, doseq=True) if clean else "")
+    req = urllib.request.Request(url, headers=headers, method="GET")
+    with urllib.request.urlopen(req, timeout=90) as r:
+        raw = r.read()
+        return json.loads(raw) if raw else {}
+
+
+def run():
+    value = str(_inputs().get("url", ""))
+    out = request("/v2/url/" + urllib.parse.quote(value, safe=""),
+                  {"fields": "risk,entity,timestamps"})
+    print(json.dumps(out))
+
+
+try:
+    run()
+except urllib.error.HTTPError as e:
+    print(json.dumps({"error": "HTTP " + str(e.code), "detail": e.read().decode("utf-8", "replace")}))
+    sys.exit(1)
+except Exception as e:
+    print(json.dumps({"error": str(e)}))
+    sys.exit(1)