Merge branch 'airtai:main' into asgi-support

faststream/utils/path.py

@@ -11,7 +11,7 @@ def compile_path(
     replace_symbol: str,
     patch_regex: Callable[[str], str] = lambda x: x,
 ) -> Tuple[Optional[Pattern[str]], str]:
-    path_regex = "^.*"
+    path_regex = "^.*?"
     original_path = ""
 
     idx = 0

tests/brokers/nats/test_router.py

@@ -42,6 +42,30 @@ async def h(
         assert event.is_set()
         mock.assert_called_once_with(name="john", id=2)
 
+    async def test_path_as_first_with_prefix(
+        self,
+        event,
+        mock,
+        router: NatsRouter,
+        pub_broker,
+    ):
+        router.prefix = "root."
+
+        @router.subscriber("{name}.nested")
+        async def h(name: str = Path()):
+            event.set()
+            mock(name=name)
+
+        pub_broker._is_apply_types = True
+        pub_broker.include_router(router)
+
+        await pub_broker.start()
+
+        await pub_broker.publish("", "root.john.nested", rpc=True)
+
+        assert event.is_set()
+        mock.assert_called_once_with(name="john")
+
     async def test_router_path_with_prefix(
         self,
         event,