feat(neighbor): support announce all processes

src/exabgp/bgp/neighbor.py

@@ -48,6 +48,8 @@
 
 # The definition of a neighbor (from reading the configuration)
 class Neighbor(dict):
+    PROCESS_ALL = "all"
+
     class Capability(dict):
         defaults = {
             'asn4': True,

src/exabgp/configuration/configuration.py

@@ -445,13 +445,31 @@ def _reload(self):
 
     def validate(self):
         for neighbor in self.neighbors.values():
-            for notification in neighbor.api:
-                for api in neighbor.api[notification]:
-                    if not self.processes[api].get('run', ''):
-                        return self.error.set(
-                            "\n\nan api called '%s' is used by neighbor '%s' but not defined\n\n"
-                            % (api, neighbor['peer-address']),
-                        )
+            # only processes are validated here
+            if "processes" not in neighbor.api:
+                continue
+
+            if not neighbor.api["processes"]:
+                return self.error.set(
+                        "\n\nneighbor '%s' declared processes key but it's empty.n\n"
+                        % (neighbor['peer-address']),
+                    )
+
+            if len(neighbor.api["processes"]) > 1 and neighbor.PROCESS_ALL in neighbor.api["processes"]:
+                return self.error.set(
+                        "\n\nneighbor '%s' declared '%s' in processes but it's mutual exclusive with other '%s'.\n\n"
+                        % (neighbor['peer-address'], neighbor.PROCESS_ALL, neighbor.api["processes"]),
+                    )
+
+            if neighbor.api["processes"] == [neighbor.PROCESS_ALL]:
+                continue
+
+            for api in neighbor.api["processes"]:
+                if not self.processes[api].get('run', ''):
+                    return self.error.set(
+                        "\n\nan api called '%s' is used by neighbor '%s' but not defined\n\n"
+                        % (api, neighbor['peer-address']),
+                    )
         return None
 
     def _link(self):

src/exabgp/reactor/loop.py

@@ -151,6 +151,10 @@ def peers(self, service=''):
             if service in peer.neighbor.api['processes']:
                 matching.append(peer_name)
                 continue
+            if peer.neighbor.api['processes'] == [peer.neighbor.PROCESS_ALL]:
+                matching.append(peer_name)
+                continue
+
         return matching
 
     def handle_connection(self, peer_name, connection):