@@ -150,12 +150,11 @@ impl Default for Sentry {
150
150
}
151
151
}
152
152
153
- impl < S , B > Transform < S > for Sentry
153
+ impl < S , B > Transform < S , ServiceRequest > for Sentry
154
154
where
155
- S : Service < Request = ServiceRequest , Response = ServiceResponse < B > , Error = Error > ,
155
+ S : Service < ServiceRequest , Response = ServiceResponse < B > , Error = Error > ,
156
156
S :: Future : ' static ,
157
157
{
158
- type Request = ServiceRequest ;
159
158
type Response = ServiceResponse < B > ;
160
159
type Error = Error ;
161
160
type Transform = SentryMiddleware < S > ;
@@ -176,24 +175,23 @@ pub struct SentryMiddleware<S> {
176
175
inner : Sentry ,
177
176
}
178
177
179
- impl < S , B > Service for SentryMiddleware < S >
178
+ impl < S , B > Service < ServiceRequest > for SentryMiddleware < S >
180
179
where
181
- S : Service < Request = ServiceRequest , Response = ServiceResponse < B > , Error = Error > ,
180
+ S : Service < ServiceRequest , Response = ServiceResponse < B > , Error = Error > ,
182
181
S :: Future : ' static ,
183
182
{
184
- type Request = ServiceRequest ;
185
183
type Response = ServiceResponse < B > ;
186
184
type Error = Error ;
187
185
type Future = Pin < Box < dyn Future < Output = Result < Self :: Response , Self :: Error > > > > ;
188
186
189
187
fn poll_ready (
190
- & mut self ,
188
+ & self ,
191
189
cx : & mut std:: task:: Context < ' _ > ,
192
190
) -> std:: task:: Poll < Result < ( ) , Self :: Error > > {
193
191
self . service . poll_ready ( cx)
194
192
}
195
193
196
- fn call ( & mut self , req : ServiceRequest ) -> Self :: Future {
194
+ fn call ( & self , req : ServiceRequest ) -> Self :: Future {
197
195
let inner = self . inner . clone ( ) ;
198
196
let hub = Arc :: new ( Hub :: new_from_top (
199
197
inner. hub . clone ( ) . unwrap_or_else ( Hub :: main) ,
@@ -349,7 +347,7 @@ mod tests {
349
347
HttpResponse :: Ok ( )
350
348
} ;
351
349
352
- let mut app = init_service (
350
+ let app = init_service (
353
351
App :: new ( )
354
352
. wrap ( Sentry :: builder ( ) . with_hub ( Hub :: current ( ) ) . finish ( ) )
355
353
. service ( web:: resource ( "/test" ) . to ( service) ) ,
@@ -359,7 +357,7 @@ mod tests {
359
357
// Call the service twice (sequentially) to ensure the middleware isn't sticky
360
358
for _ in 0 ..2 {
361
359
let req = TestRequest :: get ( ) . uri ( "/test" ) . to_request ( ) ;
362
- let res = call_service ( & mut app, req) . await ;
360
+ let res = call_service ( & app, req) . await ;
363
361
assert ! ( res. status( ) . is_success( ) ) ;
364
362
}
365
363
} )
@@ -388,7 +386,7 @@ mod tests {
388
386
Err ( io:: Error :: new ( io:: ErrorKind :: Other , "Test Error" ) . into ( ) )
389
387
}
390
388
391
- let mut app = init_service (
389
+ let app = init_service (
392
390
App :: new ( )
393
391
. wrap ( Sentry :: builder ( ) . with_hub ( Hub :: current ( ) ) . finish ( ) )
394
392
. service ( failing) ,
@@ -398,7 +396,7 @@ mod tests {
398
396
// Call the service twice (sequentially) to ensure the middleware isn't sticky
399
397
for _ in 0 ..2 {
400
398
let req = TestRequest :: get ( ) . uri ( "/test" ) . to_request ( ) ;
401
- let res = call_service ( & mut app, req) . await ;
399
+ let res = call_service ( & app, req) . await ;
402
400
assert ! ( res. status( ) . is_server_error( ) ) ;
403
401
}
404
402
} )
@@ -423,15 +421,15 @@ mod tests {
423
421
block_on ( async {
424
422
let service = || HttpResponse :: NotFound ( ) ;
425
423
426
- let mut app = init_service (
424
+ let app = init_service (
427
425
App :: new ( )
428
426
. wrap ( Sentry :: builder ( ) . with_hub ( Hub :: current ( ) ) . finish ( ) )
429
427
. service ( web:: resource ( "/test" ) . to ( service) ) ,
430
428
)
431
429
. await ;
432
430
433
431
let req = TestRequest :: get ( ) . uri ( "/test" ) . to_request ( ) ;
434
- let res = call_service ( & mut app, req) . await ;
432
+ let res = call_service ( & app, req) . await ;
435
433
assert ! ( res. status( ) . is_client_error( ) ) ;
436
434
} )
437
435
} ) ;
@@ -451,15 +449,15 @@ mod tests {
451
449
Err ( io:: Error :: new ( io:: ErrorKind :: Other , "Test Error" ) . into ( ) )
452
450
}
453
451
454
- let mut app = init_service (
452
+ let app = init_service (
455
453
App :: new ( )
456
454
. wrap ( Sentry :: builder ( ) . with_hub ( Hub :: current ( ) ) . finish ( ) )
457
455
. service ( original_transaction) ,
458
456
)
459
457
. await ;
460
458
461
459
let req = TestRequest :: get ( ) . uri ( "/test" ) . to_request ( ) ;
462
- let res = call_service ( & mut app, req) . await ;
460
+ let res = call_service ( & app, req) . await ;
463
461
assert ! ( res. status( ) . is_server_error( ) ) ;
464
462
} )
465
463
} ) ;
@@ -487,11 +485,11 @@ mod tests {
487
485
488
486
let middleware = Sentry :: builder ( ) . with_hub ( Hub :: current ( ) ) . finish ( ) ;
489
487
490
- let mut app = init_service ( App :: new ( ) . wrap ( middleware) . service ( hello) ) . await ;
488
+ let app = init_service ( App :: new ( ) . wrap ( middleware) . service ( hello) ) . await ;
491
489
492
490
for _ in 0 ..5 {
493
491
let req = TestRequest :: get ( ) . uri ( "/" ) . to_request ( ) ;
494
- call_service ( & mut app, req) . await ;
492
+ call_service ( & app, req) . await ;
495
493
}
496
494
} )
497
495
} ,
0 commit comments