Format tests

Author: WiZeYAR

tests/codegen/test_validation.py

@@ -18,11 +18,13 @@
 def test_validation_error_raised_for_missing_asyncapi_field(tmp_path: Path):
     """Test that missing asyncapi field raises ValidationError."""
     spec_file = tmp_path / "invalid.yaml"
-    spec_file.write_text("""
+    spec_file.write_text(
+        """
 operations:
   myOp:
     action: send
-""")
+"""
+    )
 
     with pytest.raises(ValueError, match="Missing 'asyncapi' version field"):
         extract_all_operations(spec_file)
@@ -31,7 +33,8 @@ def test_validation_error_raised_for_missing_asyncapi_field(tmp_path: Path):
 def test_validation_error_for_invalid_channel_parameters(tmp_path: Path):
     """Test that parameters not in address raise ValidationError."""
     spec_file = tmp_path / "invalid_params.yaml"
-    spec_file.write_text("""
+    spec_file.write_text(
+        """
 asyncapi: 3.0.0
 channels:
   myChannel:
@@ -49,7 +52,8 @@ def test_validation_error_for_invalid_channel_parameters(tmp_path: Path):
     action: send
     channel:
       $ref: '#/channels/myChannel'
-""")
+"""
+    )
 
     with pytest.raises(ValidationError) as exc_info:
         extract_all_operations(spec_file)
@@ -63,7 +67,8 @@ def test_validation_error_for_invalid_channel_parameters(tmp_path: Path):
 def test_validation_passes_for_valid_spec(tmp_path: Path):
     """Test that a valid spec passes validation."""
     spec_file = tmp_path / "valid.yaml"
-    spec_file.write_text("""
+    spec_file.write_text(
+        """
 asyncapi: 3.0.0
 channels:
   userChannel:
@@ -88,7 +93,8 @@ def test_validation_passes_for_valid_spec(tmp_path: Path):
       $ref: '#/channels/userChannel'
     messages:
       - $ref: '#/channels/userChannel/messages/userMessage'
-""")
+"""
+    )
 
     # Should not raise
     operations = extract_all_operations(spec_file)
@@ -98,7 +104,8 @@ def test_validation_passes_for_valid_spec(tmp_path: Path):
 def test_validation_can_be_disabled(tmp_path: Path):
     """Test that validation can be disabled."""
     spec_file = tmp_path / "invalid_params.yaml"
-    spec_file.write_text("""
+    spec_file.write_text(
+        """
 asyncapi: 3.0.0
 channels:
   myChannel:
@@ -116,7 +123,8 @@ def test_validation_can_be_disabled(tmp_path: Path):
     action: send
     channel:
       $ref: '#/channels/myChannel'
-""")
+"""
+    )
 
     # Should not raise when validation is disabled
     operations = extract_all_operations(spec_file, validate=False)
@@ -126,7 +134,8 @@ def test_validation_can_be_disabled(tmp_path: Path):
 def test_warnings_do_not_fail_validation(tmp_path: Path):
     """Test that warnings are collected but don't fail validation."""
     spec_file = tmp_path / "with_warnings.yaml"
-    spec_file.write_text("""
+    spec_file.write_text(
+        """
 asyncapi: 3.0.0
 channels:
   myChannel:
@@ -149,7 +158,8 @@ def test_warnings_do_not_fail_validation(tmp_path: Path):
     action: send
     channel:
       $ref: '#/channels/myChannel'
-""")
+"""
+    )
 
     # Should not raise - location warning doesn't fail
     operations = extract_all_operations(spec_file)
@@ -194,7 +204,8 @@ def custom_test_rule(ctx: ValidationContext) -> list[ValidationIssue]:
 def test_parameter_with_location_warns_not_implemented(tmp_path: Path):
     """Test that using location field generates a warning."""
     spec_file = tmp_path / "location.yaml"
-    spec_file.write_text("""
+    spec_file.write_text(
+        """
 asyncapi: 3.0.0
 channels:
   myChannel:
@@ -211,7 +222,8 @@ def test_parameter_with_location_warns_not_implemented(tmp_path: Path):
     action: send
     channel:
       $ref: '#/channels/myChannel'
-""")
+"""
+    )
 
     # Should succeed but print warning
     operations = extract_all_operations(spec_file, fail_on_error=False)
@@ -221,7 +233,8 @@ def test_parameter_with_location_warns_not_implemented(tmp_path: Path):
 def test_undefined_placeholders_in_address(tmp_path: Path):
     """Test that undefined placeholders in address raise error."""
     spec_file = tmp_path / "undefined_params.yaml"
-    spec_file.write_text("""
+    spec_file.write_text(
+        """
 asyncapi: 3.0.0
 channels:
   myChannel:
@@ -239,18 +252,22 @@ def test_undefined_placeholders_in_address(tmp_path: Path):
     action: send
     channel:
       $ref: '#/channels/myChannel'
-""")
+"""
+    )
 
     with pytest.raises(ValidationError) as exc_info:
         extract_all_operations(spec_file)
 
-    assert any("undefined parameters" in error.message for error in exc_info.value.errors)
+    assert any(
+        "undefined parameters" in error.message for error in exc_info.value.errors
+    )
 
 
 def test_operation_references_nonexistent_channel(tmp_path: Path):
     """Test that operation referencing non-existent channel raises error."""
     spec_file = tmp_path / "bad_channel_ref.yaml"
-    spec_file.write_text("""
+    spec_file.write_text(
+        """
 asyncapi: 3.0.0
 channels:
   realChannel:
@@ -264,17 +281,21 @@ def test_operation_references_nonexistent_channel(tmp_path: Path):
     action: send
     channel:
       $ref: '#/channels/fakeChannel'
-""")
+"""
+    )
 
     # Parser will fail when trying to resolve $ref (before validation runs)
-    with pytest.raises(RuntimeError, match="JSON pointer segment 'fakeChannel' not found"):
+    with pytest.raises(
+        RuntimeError, match="JSON pointer segment 'fakeChannel' not found"
+    ):
         extract_all_operations(spec_file)
 
 
 def test_invalid_operation_action(tmp_path: Path):
     """Test that invalid operation action raises error."""
     spec_file = tmp_path / "bad_action.yaml"
-    spec_file.write_text("""
+    spec_file.write_text(
+        """
 asyncapi: 3.0.0
 channels:
   myChannel:
@@ -288,7 +309,8 @@ def test_invalid_operation_action(tmp_path: Path):
     action: publish
     channel:
       $ref: '#/channels/myChannel'
-""")
+"""
+    )
 
     with pytest.raises(ValidationError) as exc_info:
         extract_all_operations(spec_file)
@@ -302,7 +324,8 @@ def test_invalid_operation_action(tmp_path: Path):
 def test_amqp_parameterized_channel_without_binding_type_fails(tmp_path: Path):
     """Test that parameterized channel without AMQP binding type fails validation."""
     spec_file = tmp_path / "amqp_no_binding_type.yaml"
-    spec_file.write_text("""
+    spec_file.write_text(
+        """
 asyncapi: 3.0.0
 channels:
   weatherAlerts:
@@ -332,20 +355,20 @@ def test_amqp_parameterized_channel_without_binding_type_fails(tmp_path: Path):
     action: send
     channel:
       $ref: '#/channels/weatherAlerts'
-""")
+"""
+    )
 
     with pytest.raises(ValidationError) as exc_info:
         extract_all_operations(spec_file)
 
-    assert any(
-        "lacks 'is' field" in error.message for error in exc_info.value.errors
-    )
+    assert any("lacks 'is' field" in error.message for error in exc_info.value.errors)
 
 
 def test_amqp_parameterized_channel_with_routing_key_passes(tmp_path: Path):
     """Test that parameterized channel with is: routingKey passes validation."""
     spec_file = tmp_path / "amqp_routing_key.yaml"
-    spec_file.write_text("""
+    spec_file.write_text(
+        """
 asyncapi: 3.0.0
 channels:
   weatherAlerts:
@@ -375,7 +398,8 @@ def test_amqp_parameterized_channel_with_routing_key_passes(tmp_path: Path):
     action: send
     channel:
       $ref: '#/channels/weatherAlerts'
-""")
+"""
+    )
 
     # Should not raise
     operations = extract_all_operations(spec_file)
@@ -385,7 +409,8 @@ def test_amqp_parameterized_channel_with_routing_key_passes(tmp_path: Path):
 def test_amqp_parameterized_channel_with_queue_passes(tmp_path: Path):
     """Test that parameterized channel with is: queue passes validation."""
     spec_file = tmp_path / "amqp_queue.yaml"
-    spec_file.write_text("""
+    spec_file.write_text(
+        """
 asyncapi: 3.0.0
 channels:
   userNotifications:
@@ -408,7 +433,8 @@ def test_amqp_parameterized_channel_with_queue_passes(tmp_path: Path):
     action: send
     channel:
       $ref: '#/channels/userNotifications'
-""")
+"""
+    )
 
     # Should not raise
     operations = extract_all_operations(spec_file)
@@ -418,7 +444,8 @@ def test_amqp_parameterized_channel_with_queue_passes(tmp_path: Path):
 def test_amqp_parameterized_channel_with_invalid_binding_type_fails(tmp_path: Path):
     """Test that parameterized channel with invalid binding type fails validation."""
     spec_file = tmp_path / "amqp_invalid_type.yaml"
-    spec_file.write_text("""
+    spec_file.write_text(
+        """
 asyncapi: 3.0.0
 channels:
   myChannel:
@@ -441,7 +468,8 @@ def test_amqp_parameterized_channel_with_invalid_binding_type_fails(tmp_path: Pa
     action: send
     channel:
       $ref: '#/channels/myChannel'
-""")
+"""
+    )
 
     with pytest.raises(ValidationError) as exc_info:
         extract_all_operations(spec_file)

tests/codegen/test_validation_system.py

@@ -141,9 +141,7 @@ class TestValidationContext:
     def test_create_context(self):
         """Test creating validation context."""
         spec = {"asyncapi": "3.0.0", "channels": {}}
-        ctx = ValidationContext(
-            spec=spec, spec_path=Path("test.yaml"), operations=None
-        )
+        ctx = ValidationContext(spec=spec, spec_path=Path("test.yaml"), operations=None)
 
         assert ctx.spec == spec
         assert ctx.spec_path == Path("test.yaml")
@@ -418,6 +416,7 @@ def test_validate_spec_fail_on_error_false(self):
 
     def test_validate_spec_with_categories(self):
         """Test validate_spec with specific categories."""
+
         # Register a test rule in a custom category
         @rule("custom-test")
         def custom_rule(ctx):

tests/core/endpoint/test_parameterized_subscriptions.py

@@ -133,6 +133,7 @@ async def test_subscriber_accepts_parameters():
 
     # Create a minimal module for codec factory with messages.json structure
     import types
+
     test_module = types.SimpleNamespace()
     test_module.messages = types.SimpleNamespace()
     test_module.messages.json = types.SimpleNamespace()
@@ -201,6 +202,7 @@ async def test_subscriber_wildcard_parameters_flow_to_wire():
     wire = InMemoryWire()
 
     import types
+
     test_module = types.SimpleNamespace()
     test_module.messages = types.SimpleNamespace()
     test_module.messages.json = types.SimpleNamespace()
@@ -286,6 +288,7 @@ async def test_queue_binding_with_wildcards_raises_error():
     from asyncapi_python.contrib.wire.amqp import AmqpWire
 
     import types
+
     test_module = types.SimpleNamespace()
 
     # This would fail at runtime when creating consumer
@@ -348,6 +351,7 @@ async def test_default_empty_parameters():
     wire = InMemoryWire()
 
     import types
+
     test_module = types.SimpleNamespace()
     test_module.messages = types.SimpleNamespace()
     test_module.messages.json = types.SimpleNamespace()
@@ -414,6 +418,7 @@ async def test_subscriber_rejects_missing_parameters():
     wire = AmqpWire("amqp://guest:guest@localhost")
 
     import types
+
     test_module = types.SimpleNamespace()
     test_module.messages = types.SimpleNamespace()
     test_module.messages.json = types.SimpleNamespace()
@@ -527,6 +532,7 @@ async def test_subscriber_rejects_extra_parameters():
     wire = AmqpWire("amqp://guest:guest@localhost")
 
     import types
+
     test_module = types.SimpleNamespace()
     test_module.messages = types.SimpleNamespace()
     test_module.messages.json = types.SimpleNamespace()

tests/core/wire/test_amqp_utils.py

@@ -47,9 +47,7 @@ def test_accepts_exact_match(self):
         )
 
         # Should not raise
-        validate_parameters_strict(
-            channel, {"location": "NYC", "severity": "high"}
-        )
+        validate_parameters_strict(channel, {"location": "NYC", "severity": "high"})
 
     def test_rejects_missing_parameters(self):
         """Should raise ValueError when required parameters are missing."""
@@ -85,9 +83,7 @@ def test_rejects_extra_parameters(self):
         channel = create_test_channel("weather.{location}", ["location"])
 
         with pytest.raises(ValueError) as exc_info:
-            validate_parameters_strict(
-                channel, {"location": "NYC", "severity": "high"}
-            )
+            validate_parameters_strict(channel, {"location": "NYC", "severity": "high"})
 
         error_msg = str(exc_info.value)
         assert "Unexpected parameters" in error_msg
@@ -149,13 +145,14 @@ def test_rejects_mixed_missing_and_extra(self):
         with pytest.raises(ValueError) as exc_info:
             # Missing: severity
             # Extra: priority
-            validate_parameters_strict(
-                channel, {"location": "NYC", "priority": "high"}
-            )
+            validate_parameters_strict(channel, {"location": "NYC", "priority": "high"})
 
         error_msg = str(exc_info.value)
         # Should fail on missing first (that's the implementation order)
-        assert "Missing required parameters" in error_msg or "Unexpected parameters" in error_msg
+        assert (
+            "Missing required parameters" in error_msg
+            or "Unexpected parameters" in error_msg
+        )
 
 
 class TestSubstituteParameters:
@@ -190,9 +187,7 @@ def test_handles_no_parameters(self):
     def test_fails_on_missing_parameter(self):
         """Should raise ValueError when template has placeholder without value."""
         with pytest.raises(ValueError) as exc_info:
-            substitute_parameters(
-                "weather.{location}.{severity}", {"location": "NYC"}
-            )
+            substitute_parameters("weather.{location}.{severity}", {"location": "NYC"})
 
         error_msg = str(exc_info.value)
         assert "undefined parameters" in error_msg