Add 'asn_upstream_connectivity' tool to MCP for checking connectivity to upstream ASNs, including SQL query implementation and documentation updates.

Author: robin-rpr

utils/mcp.py

@@ -18,6 +18,7 @@ def list_tools():
         'asn_downstream_count': ['asn'],
         'asn_upstream_details': ['asn'],
         'asn_downstream_details': ['asn'],
+        'asn_upstream_connectivity': ['asn'],
         'asn_trend_24h': ['asn'],
         'asn_prefix_aggregates': ['asn'],
         'asn_advertised_prefixes': ['asn'],
@@ -54,6 +55,7 @@ def list_tools():
         'asn_downstream_count': 'Count unique downstream ASNs directly after an ASN in paths',
         'asn_upstream_details': 'List upstream ASNs and names for an ASN',
         'asn_downstream_details': 'List downstream ASNs and names for an ASN',
+        'asn_upstream_connectivity': 'Check connectivity to upstream ASNs (to Tier 1) for ASN',
         'asn_trend_24h': '24h time series of prefix and coverage stats for ASN',
         'asn_prefix_aggregates': 'List aggregate supernets for ASN-advertised prefixes',
         'asn_advertised_prefixes': 'List prefixes with RPKI/IRR context for ASN',
@@ -199,6 +201,51 @@ def run_tool(name, params, db):
         """)
         return _rows(db, q, {'asn': asn})
 
+    if name == 'asn_upstream_connectivity':
+        asn = int(params['asn'])
+        q = text("""
+            WITH target_paths AS (
+                SELECT DISTINCT
+                ba.as_path,
+                ba.as_path_count
+                FROM ip_rib r
+                JOIN base_attrs ba ON r.base_attr_hash_id = ba.hash_id
+                WHERE r.origin_as = :asn
+                AND r.iswithdrawn = false
+                AND ba.as_path_count > 0
+                LIMIT 200
+            ),
+            tier1_list AS (
+            -- Common Tier 1 ASNs
+                SELECT unnest(ARRAY[
+                174, -- Cogent
+                1299, -- Telia/Arelion
+                2914, -- NTT
+                3257, -- GTT/Lumen
+                3320, -- Deutsche Telekom
+                3356, -- Lumen/Level3
+                5511, -- Orange
+                6453, -- Tata
+                6461, -- Zayo
+                6762, -- Telecom Italia
+                6830, -- Liberty Global
+                6939, -- Hurricane Electric
+                7018 -- AT&T
+                ]::bigint[]) as asn
+            )
+            SELECT
+            tp.as_path,
+            tp.as_path_count,
+            array_agg(DISTINCT t1.asn) as tier1_asns_in_path
+            FROM target_paths tp
+            CROSS JOIN tier1_list t1
+            WHERE tp.as_path @> ARRAY[t1.asn] -- Check if path contains Tier 1
+            GROUP BY tp.as_path, tp.as_path_count
+            ORDER BY tp.as_path_count, tp.as_path
+            LIMIT 50;
+        """)
+        return _rows(db, q, {'asn': asn})
+
     if name == 'asn_trend_24h':
         asn = int(params['asn'])
         from datetime import datetime, timedelta