Format ./nats-server

Author: caspervonb

nats-server/src/nats/server/__init__.py

@@ -34,9 +34,7 @@
 FATAL_PATTERN = re.compile(r"\[FTL\]\s+(.*)")
 INFO_PATTERN = re.compile(r"\[INF\]\s+(.*)")
 READY_PATTERN = re.compile(r"Server is ready")
-LISTENING_PATTERN = re.compile(
-    r"Listening for client connections on (.+):(\d+)"
-)
+LISTENING_PATTERN = re.compile(r"Listening for client connections on (.+):(\d+)")
 
 
 class ServerError(Exception):
@@ -279,7 +277,7 @@ async def wait_ready() -> tuple[str, int]:
 
             if match := LISTENING_PATTERN.search(stderr_line):
                 host_part = match.group(1)
-                if host_part.startswith('[') and host_part.endswith(']'):
+                if host_part.startswith("[") and host_part.endswith("]"):
                     host = host_part[1:-1]
                 else:
                     host = host_part
@@ -298,13 +296,11 @@ async def wait_ready() -> tuple[str, int]:
         if returncode != 0:
             msg = f"Server exited with code {returncode}"
             if error_lines:
-                errors = '\n'.join(error_lines)
+                errors = "\n".join(error_lines)
                 msg += f"\nErrors:\n{errors}"
             raise ServerError(msg)
 
-        raise ServerError(
-            "Server ended without becoming ready"
-        )  # pragma: no cover
+        raise ServerError("Server ended without becoming ready")  # pragma: no cover
 
     return await asyncio.wait_for(wait_ready(), timeout=timeout)
 
@@ -413,14 +409,14 @@ async def run_cluster(
             node_store_dir = None
             if jetstream and store_dir:
                 # Use as base directory and create subdirectory for each node
-                node_store_dir = os.path.join(store_dir, f"node{i+1}")
+                node_store_dir = os.path.join(store_dir, f"node{i + 1}")
                 os.makedirs(node_store_dir, exist_ok=True)
 
             server = await _run_cluster_node(
                 config_path=config_path,
                 port=available_ports[i],
                 routes=routes,
-                name=f"node{i+1}",
+                name=f"node{i + 1}",
                 cluster_name="cluster",
                 cluster_port=cluster_ports[i],
                 jetstream=jetstream,
@@ -465,9 +461,7 @@ async def _run_cluster_node(
     """
     # Build cluster URL and routes string for CLI
     cluster_url = f"nats://127.0.0.1:{cluster_port}"
-    routes_str = ",".join(
-        f"nats://127.0.0.1:{r}" for r in routes
-    ) if routes else None
+    routes_str = ",".join(f"nats://127.0.0.1:{r}" for r in routes) if routes else None
 
     process = await _create_server_process(
         port=port,
@@ -480,8 +474,6 @@ async def _run_cluster_node(
         config_path=config_path if config_path else None,
     )
 
-    assigned_host, assigned_port = await _wait_for_server_ready(
-        process, timeout=10.0
-    )
+    assigned_host, assigned_port = await _wait_for_server_ready(process, timeout=10.0)
 
     return Server(process, assigned_host, assigned_port)

nats-server/tests/conftest.py

@@ -14,10 +14,9 @@
 def get_nats_server_version():
     """Get the nats-server version or fail if not installed."""
     try:
-        result = subprocess.run(["nats-server", "--version"],
-                                capture_output=True,
-                                check=True,
-                                text=True)
+        result = subprocess.run(
+            ["nats-server", "--version"], capture_output=True, check=True, text=True
+        )
         return result.stdout.strip() or result.stderr.strip()
     except (subprocess.SubprocessError, FileNotFoundError) as e:
         pytest.fail(f"nats-server is not installed or not in PATH: {e}")

nats-server/tests/test_server.py

@@ -18,6 +18,7 @@ class ServerInfo(TypedDict):
 
     See: https://docs.nats.io/reference/reference-protocols/nats-protocol#info
     """
+
     # Required fields
     server_id: str
     server_name: str
@@ -264,9 +265,7 @@ async def test_run_with_store_dir_as_file(tmp_path):
 
     # Try to start server with JetStream using a file as store_dir
     with pytest.raises(ServerError) as exc_info:
-        await run(
-            port=0, jetstream=True, store_dir=str(store_file), timeout=2.0
-        )
+        await run(port=0, jetstream=True, store_dir=str(store_file), timeout=2.0)
 
     # Verify the error message indicates the storage directory issue
     error_msg = str(exc_info.value).lower()
@@ -522,9 +521,7 @@ async def test_cluster_with_conflicting_config(tmp_path):
     """Test run_cluster with config that includes cluster settings."""
     # The function should still work, merging config with generated cluster setup
     cluster = await run_cluster(
-        "tests/configs/jetstream.conf",
-        jetstream=True,
-        store_dir=str(tmp_path)
+        "tests/configs/jetstream.conf", jetstream=True, store_dir=str(tmp_path)
     )
 
     try:
@@ -549,8 +546,10 @@ async def test_run_with_invalid_host():
     with pytest.raises(ServerError) as exc_info:
         await run(host="999.999.999.999", port=0, timeout=2.0)
 
-    assert "exited" in str(exc_info.value
-                           ).lower() or "error" in str(exc_info.value).lower()
+    assert (
+        "exited" in str(exc_info.value).lower()
+        or "error" in str(exc_info.value).lower()
+    )
 
 
 async def test_cluster_client_url():