style: apply ruff formatting to 49 files

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: thomas-mangin

qa/self/big/api-internet.py

@@ -27,7 +27,9 @@ def main():
     # initial table dump
     for k, v in ip.iteritems():
         count += 1
-        write('announce route {} next-hop {} med 100 as-path [ 100 101 102 103 104 105 106 107 108 109 110 ]'.format(k, v))
+        write(
+            'announce route {} next-hop {} med 100 as-path [ 100 101 102 103 104 105 106 107 108 109 110 ]'.format(k, v)
+        )
         if count % 100 == 0:
             sys.stderr.write('initial : announced %d\n' % count)
 

qa/self/operational/operational-send.py

@@ -30,10 +30,14 @@
     try:
         time.sleep(1)
         if counter % 2:
-            sys.stdout.write('announce operational adm afi ipv4 safi unicast advisory "this is dynamic message #%d"\n' % counter)
+            sys.stdout.write(
+                'announce operational adm afi ipv4 safi unicast advisory "this is dynamic message #%d"\n' % counter
+            )
             sys.stdout.flush()
         else:
-            sys.stdout.write('announce operational asm afi ipv4 safi unicast advisory "we SHOULD not send asm from the API"\n')
+            sys.stdout.write(
+                'announce operational asm afi ipv4 safi unicast advisory "we SHOULD not send asm from the API"\n'
+            )
             sys.stdout.flush()
 
         counter += 1

setup.py

@@ -49,8 +49,8 @@ def filesOf(directory):
 
 
 setuptools.setup(
-    packages=setuptools.find_namespace_packages(where="src"),
-    package_dir={"": "src"},
+    packages=setuptools.find_namespace_packages(where='src'),
+    package_dir={'': 'src'},
     download_url=download_url,
     data_files=data_files,
 )

src/exabgp/application/healthcheck.py

@@ -248,7 +248,7 @@ def system_ips(ip_ifnames, label, label_only, label_exact_match):
         else:
             mask = bin(int(mo.group('netmask'), 16)).count('1')
         try:
-            ip = ip_network(f"{mo.group('ip')}/{mask}")
+            ip = ip_network(f'{mo.group("ip")}/{mask}')
         except ValueError:
             continue
         if not ip.is_loopback:
@@ -428,7 +428,7 @@ def exabgp(target):
             else:
                 action = 'announce'
             command = f'{prefix} {action}'
-            announce = f"route {ip} next-hop {options.next_hop or 'self'}"
+            announce = f'route {ip} next-hop {options.next_hop or "self"}'
 
             if action == 'announce':
                 announce = f'{announce} med {metric}'

src/exabgp/bgp/neighbor.py

@@ -138,7 +138,7 @@ def __init__(self):
         # - have multiple exabgp toward one peer on the same host ( use of pid )
         # - have more than once connection toward a peer
         # - each connection has it own neihgbor (hence why identificator is not in Protocol)
-        self.uid = f"{self._GLOBAL['uid']}"
+        self.uid = f'{self._GLOBAL["uid"]}'
         self._GLOBAL['uid'] += 1
 
     def infer(self):
@@ -159,7 +159,7 @@ def id(self):
     # This set must be unique between peer, not full draft-ietf-idr-bgp-multisession-07
     def index(self):
         if self['listen'] != 0:
-            return f"peer-ip {self['peer-address']} listen {self['listen']}"
+            return f'peer-ip {self["peer-address"]} listen {self["listen"]}'
         return self.name()
 
     def make_rib(self):
@@ -185,7 +185,7 @@ def name(self):
         local_addr = self['local-address'] if self['peer-address'] is not None else 'auto'
         local_as = self['local-as'] if self['local-as'] is not None else 'auto'
         peer_as = self['peer-as'] if self['peer-as'] is not None else 'auto'
-        return f"neighbor {self['peer-address']} local-ip {local_addr} local-as {local_as} peer-as {peer_as} router-id {self['router-id']} family-allowed {session}"
+        return f'neighbor {self["peer-address"]} local-ip {local_addr} local-as {local_as} peer-as {peer_as} router-id {self["router-id"]} family-allowed {session}'
 
     def families(self):
         # this list() is important .. as we use the function to modify self._families
@@ -492,25 +492,25 @@ def configuration(cls, neighbor, with_changes=True):
             f'\n\tpassive {"true" if neighbor["passive"] else "false"};\n'
             + (f'\n\tlisten {neighbor["listen"]};\n' if neighbor['listen'] else '')
             + (f'\n\tconnect {neighbor["connect"]};\n' if neighbor['connect'] else '')
-            + f"\tgroup-updates {'true' if neighbor['group-updates'] else 'false'};\n"
-            f"\tauto-flush {'true' if neighbor['auto-flush'] else 'false'};\n"
-            f"\tadj-rib-in {'true' if neighbor['adj-rib-in'] else 'false'};\n"
-            f"\tadj-rib-out {'true' if neighbor['adj-rib-out'] else 'false'};\n"
+            + f'\tgroup-updates {"true" if neighbor["group-updates"] else "false"};\n'
+            f'\tauto-flush {"true" if neighbor["auto-flush"] else "false"};\n'
+            f'\tadj-rib-in {"true" if neighbor["adj-rib-in"] else "false"};\n'
+            f'\tadj-rib-out {"true" if neighbor["adj-rib-out"] else "false"};\n'
             + (f'\tmd5-password "{neighbor["md5-password"]}";\n' if neighbor['md5-password'] else '')
             + f'\tmd5-base64 {md5_base64_str};\n'
             + (f'\tmd5-ip "{neighbor["md5-ip"]}";\n' if not neighbor.auto_discovery else '')
             + (f'\toutgoing-ttl {neighbor["outgoing-ttl"]};\n' if neighbor['outgoing-ttl'] else '')
             + (f'\tincoming-ttl {neighbor["incoming-ttl"]};\n' if neighbor['incoming-ttl'] else '')
             + f'\tcapability {{\n'
-            f"\t\tasn4 {'enable' if neighbor['capability']['asn4'] else 'disable'};\n"
-            f"\t\troute-refresh {'enable' if neighbor['capability']['route-refresh'] else 'disable'};\n"
-            f"\t\tgraceful-restart {neighbor['capability']['graceful-restart'] if neighbor['capability']['graceful-restart'] else 'disable'};\n"
-            f"\t\tsoftware-version {'enable' if neighbor['capability']['software-version'] else 'disable'};\n"
-            f"\t\tnexthop {'enable' if neighbor['capability']['nexthop'] else 'disable'};\n"
-            f"\t\tadd-path {add_path_str};\n"
-            f"\t\tmulti-session {'enable' if neighbor['capability']['multi-session'] else 'disable'};\n"
-            f"\t\toperational {'enable' if neighbor['capability']['operational'] else 'disable'};\n"
-            f"\t\taigp {'enable' if neighbor['capability']['aigp'] else 'disable'};\n"
+            f'\t\tasn4 {"enable" if neighbor["capability"]["asn4"] else "disable"};\n'
+            f'\t\troute-refresh {"enable" if neighbor["capability"]["route-refresh"] else "disable"};\n'
+            f'\t\tgraceful-restart {neighbor["capability"]["graceful-restart"] if neighbor["capability"]["graceful-restart"] else "disable"};\n'
+            f'\t\tsoftware-version {"enable" if neighbor["capability"]["software-version"] else "disable"};\n'
+            f'\t\tnexthop {"enable" if neighbor["capability"]["nexthop"] else "disable"};\n'
+            f'\t\tadd-path {add_path_str};\n'
+            f'\t\tmulti-session {"enable" if neighbor["capability"]["multi-session"] else "disable"};\n'
+            f'\t\toperational {"enable" if neighbor["capability"]["operational"] else "disable"};\n'
+            f'\t\taigp {"enable" if neighbor["capability"]["aigp"] else "disable"};\n'
             f'\t}}\n'
             f'\tfamily {{{families}\n'
             f'\t}}\n'
@@ -586,29 +586,29 @@ def as_dict(cls, answer):
     def formated_dict(cls, answer):
         if answer['duration']:
             duration_value = timedelta(seconds=answer['duration'])
-            duration = f"   {'up for':<20} {str(duration_value):>15} {'':<15} {'':<15}"
+            duration = f'   {"up for":<20} {str(duration_value):>15} {"":<15} {"":<15}'
         else:
             down_value = timedelta(seconds=answer['down'])
-            duration = f"   {'down for':<20} {str(down_value):>15} {'':<15} {'':<15}"
+            duration = f'   {"down for":<20} {str(down_value):>15} {"":<15} {"":<15}'
 
         formated = {
             'peer-address': answer['peer-address'],
-            'local-address': f"   {'local':<20} {answer['local-address']:>15} {'':<15} {'':<15}",
-            'state': f"   {'state':<20} {answer['state']:>15} {'':<15} {'':<15}",
+            'local-address': f'   {"local":<20} {answer["local-address"]:>15} {"":<15} {"":<15}',
+            'state': f'   {"state":<20} {answer["state"]:>15} {"":<15} {"":<15}',
             'duration': duration,
-            'as': f"   {'AS':<20} {answer['local-as']:>15} {_pr(answer['peer-as']):>15} {'':<15}",
-            'id': f"   {'ID':<20} {answer['local-id']:>15} {_pr(answer['peer-id']):>15} {'':<15}",
-            'hold': f"   {'hold-time':<20} {answer['local-hold']:>15} {_pr(answer['peer-hold']):>15} {'':<15}",
+            'as': f'   {"AS":<20} {answer["local-as"]:>15} {_pr(answer["peer-as"]):>15} {"":<15}',
+            'id': f'   {"ID":<20} {answer["local-id"]:>15} {_pr(answer["peer-id"]):>15} {"":<15}',
+            'hold': f'   {"hold-time":<20} {answer["local-hold"]:>15} {_pr(answer["peer-hold"]):>15} {"":<15}',
             'capabilities': '\n'.join(
-                f"   {f'{k}:':<20} {_en(lc):>15} {_en(pc):>15} {'':<15}"
+                f'   {f"{k}:":<20} {_en(lc):>15} {_en(pc):>15} {"":<15}'
                 for k, (lc, pc) in answer['capabilities'].items()
             ),
             'families': '\n'.join(
-                f"   {f'{a} {s}:':<20} {_en(lf):>15} {_en(rf):>15} {_addpath(aps, apr):<15}"
+                f'   {f"{a} {s}:":<20} {_en(lf):>15} {_en(rf):>15} {_addpath(aps, apr):<15}'
                 for (a, s), (lf, rf, apr, aps) in answer['families'].items()
             ),
             'messages': '\n'.join(
-                f"   {f'{k}:':<20} {ms!s:>15} {mr!s:>15} {'':<15}" for k, (ms, mr) in answer['messages'].items()
+                f'   {f"{k}:":<20} {ms!s:>15} {mr!s:>15} {"":<15}' for k, (ms, mr) in answer['messages'].items()
             ),
         }
 

src/exabgp/configuration/neighbor/__init__.py

@@ -238,7 +238,7 @@ def _post_capa_rr(self, neighbor):
         if neighbor['capability']['route-refresh']:
             if not neighbor['adj-rib-out']:
                 log.warning(
-                    lambda: f"route-refresh enabled but adj-rib-out disabled for {neighbor['peer-address']}, auto-enabling adj-rib-out",
+                    lambda: f'route-refresh enabled but adj-rib-out disabled for {neighbor["peer-address"]}, auto-enabling adj-rib-out',
                     'configuration',
                 )
                 neighbor['adj-rib-out'] = True

src/exabgp/environment/environment.py

@@ -47,7 +47,7 @@ def default(cls):
                     if values['write'] in (parsing.list, parsing.path, parsing.quote, parsing.syslog_name)
                     else values['value']
                 )
-                yield f"{base.APPLICATION}.{section}.{option} {' ' * (18 - len(section) - len(option))} {values['help']}. default ({default})"
+                yield f'{base.APPLICATION}.{section}.{option} {" " * (18 - len(section) - len(option))} {values["help"]}. default ({default})'
 
     @classmethod
     def iter_ini(cls, diff=False):
@@ -64,7 +64,7 @@ def iter_ini(cls, diff=False):
                 if header:
                     yield header
                     header = ''
-                yield f"{k} = {cls.definition[section][k]['write'](v)}"
+                yield f'{k} = {cls.definition[section][k]["write"](v)}'
 
     @classmethod
     def iter_env(cls, diff=False):
@@ -79,7 +79,7 @@ def iter_env(cls, diff=False):
                 if cls.definition[section][k]['write'] == parsing.quote:
                     yield f"{base.APPLICATION}.{section}.{k}='{v}'"
                     continue
-                yield f"{base.APPLICATION}.{section}.{k}={cls.definition[section][k]['write'](v)}"
+                yield f'{base.APPLICATION}.{section}.{k}={cls.definition[section][k]["write"](v)}'
 
     @classmethod
     def setup(cls, configuration):

src/exabgp/reactor/api/response/text.py

@@ -30,13 +30,13 @@ def _counter(self, neighbor):
         return None
 
     def up(self, neighbor):
-        return f"neighbor {neighbor['peer-address']} up\n"
+        return f'neighbor {neighbor["peer-address"]} up\n'
 
     def connected(self, neighbor):
-        return f"neighbor {neighbor['peer-address']} connected\n"
+        return f'neighbor {neighbor["peer-address"]} connected\n'
 
     def down(self, neighbor, reason=''):
-        return f"neighbor {neighbor['peer-address']} down - {reason}\n"
+        return f'neighbor {neighbor["peer-address"]} down - {reason}\n'
 
     def shutdown(self):
         return f'shutdown {os.getpid()} {os.getppid()}\n'
@@ -53,21 +53,21 @@ def signal(self, neighbor, signal):
     def notification(self, neighbor, direction, message, negotiated, header, body):
         data_hex = hexstring(message.data)
         header_body = self._header_body(header, body)
-        return f"neighbor {neighbor['peer-address']} {direction} notification code {message.code} subcode {message.subcode} data {data_hex}{header_body}\n"
+        return f'neighbor {neighbor["peer-address"]} {direction} notification code {message.code} subcode {message.subcode} data {data_hex}{header_body}\n'
 
     def packets(self, neighbor, direction, category, negotiated, header, body):
-        return f"neighbor {neighbor['peer-address']} {direction} {category}{self._header_body(header, body)}\n"
+        return f'neighbor {neighbor["peer-address"]} {direction} {category}{self._header_body(header, body)}\n'
 
     def keepalive(self, neighbor, direction, negotiated, header, body):
-        return f"neighbor {neighbor['peer-address']} {direction} keepalive{self._header_body(header, body)}\n"
+        return f'neighbor {neighbor["peer-address"]} {direction} keepalive{self._header_body(header, body)}\n'
 
     def open(self, neighbor, direction, sent_open, negotiated, header, body):
         capabilities_str = str(sent_open.capabilities).lower()
         header_body = self._header_body(header, body)
-        return f"neighbor {neighbor['peer-address']} {direction} open version {sent_open.version} asn {sent_open.asn} hold_time {sent_open.hold_time} router_id {sent_open.router_id} capabilities [{capabilities_str}]{header_body}\n"
+        return f'neighbor {neighbor["peer-address"]} {direction} open version {sent_open.version} asn {sent_open.asn} hold_time {sent_open.hold_time} router_id {sent_open.router_id} capabilities [{capabilities_str}]{header_body}\n'
 
     def update(self, neighbor, direction, update, negotiated, header, body):
-        prefix = f"neighbor {neighbor['peer-address']} {direction} update"
+        prefix = f'neighbor {neighbor["peer-address"]} {direction} update'
 
         r = f'{prefix} start\n'
 
@@ -91,16 +91,16 @@ def update(self, neighbor, direction, update, negotiated, header, body):
         return r
 
     def refresh(self, neighbor, direction, refresh, negotiated, header, body):
-        return f"neighbor {neighbor['peer-address']} {direction} route-refresh afi {refresh.afi} safi {refresh.safi} {refresh.reserved}{self._header_body(header, body)}\n"
+        return f'neighbor {neighbor["peer-address"]} {direction} route-refresh afi {refresh.afi} safi {refresh.safi} {refresh.reserved}{self._header_body(header, body)}\n'
 
     def _operational_advisory(self, neighbor, direction, operational, header, body):
-        return f"neighbor {neighbor['peer-address']} {direction} operational {operational.name} afi {operational.afi} safi {operational.safi} advisory \"{operational.data}\"{self._header_body(header, body)}"
+        return f'neighbor {neighbor["peer-address"]} {direction} operational {operational.name} afi {operational.afi} safi {operational.safi} advisory "{operational.data}"{self._header_body(header, body)}'
 
     def _operational_query(self, neighbor, direction, operational, header, body):
-        return f"neighbor {neighbor['peer-address']} {direction} operational {operational.name} afi {operational.afi} safi {operational.safi}{self._header_body(header, body)}"
+        return f'neighbor {neighbor["peer-address"]} {direction} operational {operational.name} afi {operational.afi} safi {operational.safi}{self._header_body(header, body)}'
 
     def _operational_counter(self, neighbor, direction, operational, header, body):
-        return f"neighbor {neighbor['peer-address']} {direction} operational {operational.name} afi {operational.afi} safi {operational.safi} router-id {operational.routerid} sequence {operational.sequence} counter {operational.counter}{self._header_body(header, body)}"
+        return f'neighbor {neighbor["peer-address"]} {direction} operational {operational.name} afi {operational.afi} safi {operational.safi} router-id {operational.routerid} sequence {operational.sequence} counter {operational.counter}{self._header_body(header, body)}'
 
     def operational(self, neighbor, direction, what, operational, negotiated, header, body):
         if what == 'advisory':

src/exabgp/reactor/protocol.py

@@ -80,7 +80,7 @@ def fd(self):
     # XXX: we use self.peer.neighbor['peer-address'] when we could use self.neighbor['peer-address']
 
     def me(self, message):
-        return f"{self.peer.neighbor['peer-address']}/{self.peer.neighbor['peer-as']} {message}"
+        return f'{self.peer.neighbor["peer-address"]}/{self.peer.neighbor["peer-as"]} {message}'
 
     def accept(self, incoming):
         self.connection = incoming