feat: Collect latest block seen by subgraph

graph_node_metrics.py

@@ -24,6 +24,26 @@ def connect_graph_node(graph_node_url):
         raise
 
 
+def get_latest_block(client):
+    """Get latest block number"""
+    try:
+        query = gql('''
+        query {
+            _meta {
+                block {
+                    number
+                }
+            }
+        }
+        ''')
+        response = client.execute(query)
+        block = response['_meta']['block']['number']
+        FLUENCE_SUBGRAPH_LATEST_BLOCK.set(block)
+    except Exception as e:
+        logger.error(f"Error fetching latest block number: {e}")
+        raise
+
+
 def get_providers(client):
     """Fetch all providers from the Graph Node."""
     try:
@@ -213,6 +233,7 @@ def collect_deal_metrics(client, provider_id, provider_name):
 
 def collect_metrics(graph_node, providers_to_monitor):
     try:
+        get_latest_block(graph_node)
         if providers_to_monitor:
             for provider_id in providers_to_monitor:
                 provider_name = get_provider_name(graph_node, provider_id)

metrics.py

@@ -21,3 +21,5 @@
 
 FLUENCE_DEAL_ACTIVE = Gauge('fluence_network_deal_active_total','Total deals active',['provider_id','provider_name'], registry=registry)
 FLUENCE_DEAL_ACTIVE_START_DATE=Gauge('fluence_network_deal_active_start_date', 'Duration of a deal', ['provider_id', 'provider_name', 'deal_id'], registry=registry)
+
+FLUENCE_SUBGRAPH_LATEST_BLOCK = Gauge('fluence_network_subgraph_latest_block','The latest block number seen by subgraph', registry=registry)