draft /poller/eumetsat-multicast handler

inventory_provider/routes/poller.py

@@ -3,6 +3,8 @@ import logging
 import re
 
 from flask import Blueprint, Response, current_app
+from lxml import etree
+
 from inventory_provider import juniper
 from inventory_provider.routes import common
 
@@ -61,6 +63,7 @@ INTERFACE_LIST_SCHEMA = {
     'items': {'$ref': '#/definitions/interface'}
 }
 
+
 INTERFACE_SPEED_LIST_SCHEMA = {
     '$schema': 'http://json-schema.org/draft-07/schema#',
 
@@ -81,6 +84,37 @@ INTERFACE_SPEED_LIST_SCHEMA = {
     'items': {'$ref': '#/definitions/interface'}
 }
 
+MULTICAST_SUBSCRIPTION_LIST_SCHEMA = {
+    '$schema': 'http://json-schema.org/draft-07/schema#',
+
+    'definitions': {
+        'ipv4-address': {
+            'type': 'string',
+            'pattern': r'^(\d+\.){3}\d+$'
+        },
+        'subscription': {
+            'type': 'object',
+            'properties': {
+                'router': {'type': 'string'},
+                'subscription': {'$ref': '#/definitions/ipv4-address'},
+                'endpoint': {'$ref': '#/definitions/ipv4-address'},
+                'oid': {
+                    'type': 'string',
+                    'pattern': r'^(\d+\.)*\d+$'
+                },
+                'community': {'type': 'string'}
+            },
+            'required': [
+                'router', 'subscription', 'endpoint', 'oid', 'community'],
+            'additionalProperties': False
+        },
+    },
+
+    'type': 'array',
+    'items': {'$ref': '#/definitions/subscription'}
+}
+
+
 
 @routes.after_request
 def after_request(resp):
@@ -387,3 +421,78 @@ def interface_speeds(hostname=None):
         r.set(cache_key, result.encode('utf-8'))
 
     return Response(result, mimetype="application/json")
+
+
+@routes.route("/eumetsat-multicast", methods=['GET', 'POST'])
+@common.require_accepts_json
+def eumetsat_multicast(hostname=None):
+    """
+    Handler for `/poller/eumetsat-multicast` which returns information about
+    multicast subscriptions on mx1.fra.de.geant.net.
+
+    The response is a list of oid/router/community structures that all
+    all subscription octet counters to be polled.
+
+    .. asjson::
+       inventory_provider.routes.poller.MULTICAST_SUBSCRIPTION_LIST_SCHEMA
+
+    This method is basically hard-coded data,
+    based on the information in POL1-395.
+
+    :return:
+    """
+
+    MX1_FRA = 'mx1.fra.de.geant.net'
+    SUBSCRIPTIONS = [{
+            'subscription': f'232.223.223.{idx}',
+            'endpoint':'193.17.9.3',
+        } for idx in range(1, 73)]
+
+    SUBSCRIPTIONS.append(
+        {'subscription': '232.223.223.1',  'endpoint': '193.17.9.7'})
+    SUBSCRIPTIONS.append(
+        {'subscription': '232.223.223.22',  'endpoint': '193.17.9.7'})
+
+    def _oid(sub):
+        return ('1.3.6.1.2.1.83.1.1.2.1.16'
+                f'.{sub["subscription"]}.{sub["endpoint"]}'
+                '.255.255.255.255')
+
+
+    cache_key = f'classifier-cache:poller-eumetsat-multicast'
+
+    r = common.get_current_redis()
+
+    result = r.get(cache_key)
+    if result:
+        result = result.decode('utf-8')
+    else:
+        netconf = r.get(f'netconf:{MX1_FRA}')
+        if not netconf:
+            return Response(
+                status=503,
+                response=f'error loading netconf for {MX1_FRA}')
+
+        netconf_doc = etree.fromstring(netconf.decode('utf-8'))
+        community = juniper.snmp_community_string(netconf_doc)
+        if not community:
+            return Response(
+                status=503,
+                response=f'error extracting community string for {MX1_FRA}')
+
+        def _rsp_element(sub):
+            result = {
+                'router': MX1_FRA,
+                'oid': _oid(sub),
+                'community': community
+            }
+            result.update(sub)
+            return result
+
+        result = [_rsp_element(sub) for sub in SUBSCRIPTIONS]
+
+        result = json.dumps(result)
+        # cache this data for the next call
+        r.set(cache_key, result.encode('utf-8'))
+
+    return Response(result, mimetype="application/json")