@@ -74,7 +74,10 @@ impl<T: Adapter + 'static> SentryApi<T> {
74
74
. collect ( ) ;
75
75
76
76
for validator in self . channel . spec . validators . into_iter ( ) {
77
- let auth_token = self . adapter . get_auth ( & validator) . expect ( "Failed to get user auth token" ) ;
77
+ let auth_token = self
78
+ . adapter
79
+ . get_auth ( & validator)
80
+ . expect ( "Failed to get user auth token" ) ;
78
81
match propagate_to (
79
82
& auth_token,
80
83
self . config . propagation_timeout ,
@@ -147,7 +150,10 @@ impl<T: Adapter + 'static> SentryApi<T> {
147
150
. validators
148
151
. into_iter ( )
149
152
. find ( |& v| v. id == whoami) ;
150
- let auth_token = self . adapter . get_auth ( validator. unwrap ( ) ) . expect ( "Failed to get user auth token" ) ;
153
+ let auth_token = self
154
+ . adapter
155
+ . get_auth ( validator. unwrap ( ) )
156
+ . expect ( "Failed to get user auth token" ) ;
151
157
152
158
let url = format ! (
153
159
"{}/events-aggregates?after={}" ,
@@ -218,7 +224,8 @@ pub async fn all_channels(
218
224
) -> Result < Vec < Channel > , ( ) > {
219
225
let validator = adapter. whoami ( ) ;
220
226
let url = sentry_url. to_owned ( ) ;
221
- let first_page = await ! ( fetch_page( url. clone( ) , 0 , validator. clone( ) ) ) . expect ( "Failed to get channels from sentry url" ) ;
227
+ let first_page = await ! ( fetch_page( url. clone( ) , 0 , validator. clone( ) ) )
228
+ . expect ( "Failed to get channels from sentry url" ) ;
222
229
if first_page. total_pages < 2 {
223
230
Ok ( first_page. channels )
224
231
} else {
@@ -235,7 +242,7 @@ pub async fn all_channels(
235
242
}
236
243
}
237
244
238
- pub async fn fetch_page (
245
+ async fn fetch_page (
239
246
sentry_url : String ,
240
247
page : u64 ,
241
248
validator : String ,
0 commit comments