@@ -33,7 +33,8 @@ async def foo() -> str:
33
33
return "foo"
34
34
35
35
@get ("/foo/{bar:str}" )
36
- async def foo_bar (bar : str ) -> str :
36
+ async def foo_bar (request : Request , bar : str ) -> str :
37
+ request .state .consumer_identifier = "test2"
37
38
return f"foo: { bar } "
38
39
39
40
@post ("/bar" )
@@ -49,7 +50,7 @@ async def val(foo: int) -> str:
49
50
return "val"
50
51
51
52
def identify_consumer (request : Request ) -> Optional [str ]:
52
- return "test"
53
+ return "test1" if "/foo" in request . route_handler . paths else None
53
54
54
55
plugin = ApitallyPlugin (
55
56
client_id = CLIENT_ID ,
@@ -74,7 +75,7 @@ def test_middleware_requests_ok(app: Litestar, mocker: MockerFixture):
74
75
assert response .status_code == 200
75
76
mock .assert_called_once ()
76
77
assert mock .call_args is not None
77
- assert mock .call_args .kwargs ["consumer" ] == "test "
78
+ assert mock .call_args .kwargs ["consumer" ] == "test1 "
78
79
assert mock .call_args .kwargs ["method" ] == "GET"
79
80
assert mock .call_args .kwargs ["path" ] == "/foo"
80
81
assert mock .call_args .kwargs ["status_code" ] == 200
@@ -84,6 +85,7 @@ def test_middleware_requests_ok(app: Litestar, mocker: MockerFixture):
84
85
assert response .status_code == 200
85
86
assert mock .call_count == 2
86
87
assert mock .call_args is not None
88
+ assert mock .call_args .kwargs ["consumer" ] == "test2"
87
89
assert mock .call_args .kwargs ["path" ] == "/foo/{bar:str}"
88
90
89
91
response = client .post ("/bar" )
0 commit comments