1pub use ::aws_smithy_runtime_api::client::endpoint::EndpointFuture;
3pub use ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver;
4pub use ::aws_smithy_types::endpoint::Endpoint;
5
6#[derive(Debug, Default)]
8pub(crate) struct EndpointOverrideFeatureTrackerInterceptor;
9
10#[::aws_smithy_runtime_api::client::interceptors::dyn_dispatch_hint]
11impl ::aws_smithy_runtime_api::client::interceptors::Intercept for EndpointOverrideFeatureTrackerInterceptor {
12 fn name(&self) -> &'static str {
13 "EndpointOverrideFeatureTrackerInterceptor"
14 }
15
16 fn read_before_execution(
17 &self,
18 _context: &::aws_smithy_runtime_api::client::interceptors::context::BeforeSerializationInterceptorContextRef<'_>,
19 cfg: &mut ::aws_smithy_types::config_bag::ConfigBag,
20 ) -> ::std::result::Result<(), ::aws_smithy_runtime_api::box_error::BoxError> {
21 if cfg.load::<::aws_types::endpoint_config::EndpointUrl>().is_some() {
22 cfg.interceptor_state()
23 .store_append(::aws_runtime::sdk_feature::AwsSdkFeature::EndpointOverride);
24 }
25 ::std::result::Result::Ok(())
26 }
27}
28
29#[cfg(test)]
30mod test {
31
32 #[test]
34 fn test_1() {
35 let params = crate::config::endpoint::Params::builder()
36 .region("ap-northeast-1".to_string())
37 .use_fips(false)
38 .use_dual_stack(false)
39 .build()
40 .expect("invalid params");
41 let resolver = crate::config::endpoint::DefaultResolver::new();
42 let endpoint = resolver.resolve_endpoint(¶ms);
43 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer.ap-northeast-1.amazonaws.com");
44 assert_eq!(
45 endpoint,
46 ::aws_smithy_types::endpoint::Endpoint::builder()
47 .url("https://codeguru-reviewer.ap-northeast-1.amazonaws.com")
48 .build()
49 );
50 }
51
52 #[test]
54 fn test_2() {
55 let params = crate::config::endpoint::Params::builder()
56 .region("ap-southeast-1".to_string())
57 .use_fips(false)
58 .use_dual_stack(false)
59 .build()
60 .expect("invalid params");
61 let resolver = crate::config::endpoint::DefaultResolver::new();
62 let endpoint = resolver.resolve_endpoint(¶ms);
63 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer.ap-southeast-1.amazonaws.com");
64 assert_eq!(
65 endpoint,
66 ::aws_smithy_types::endpoint::Endpoint::builder()
67 .url("https://codeguru-reviewer.ap-southeast-1.amazonaws.com")
68 .build()
69 );
70 }
71
72 #[test]
74 fn test_3() {
75 let params = crate::config::endpoint::Params::builder()
76 .region("ap-southeast-2".to_string())
77 .use_fips(false)
78 .use_dual_stack(false)
79 .build()
80 .expect("invalid params");
81 let resolver = crate::config::endpoint::DefaultResolver::new();
82 let endpoint = resolver.resolve_endpoint(¶ms);
83 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer.ap-southeast-2.amazonaws.com");
84 assert_eq!(
85 endpoint,
86 ::aws_smithy_types::endpoint::Endpoint::builder()
87 .url("https://codeguru-reviewer.ap-southeast-2.amazonaws.com")
88 .build()
89 );
90 }
91
92 #[test]
94 fn test_4() {
95 let params = crate::config::endpoint::Params::builder()
96 .region("eu-central-1".to_string())
97 .use_fips(false)
98 .use_dual_stack(false)
99 .build()
100 .expect("invalid params");
101 let resolver = crate::config::endpoint::DefaultResolver::new();
102 let endpoint = resolver.resolve_endpoint(¶ms);
103 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer.eu-central-1.amazonaws.com");
104 assert_eq!(
105 endpoint,
106 ::aws_smithy_types::endpoint::Endpoint::builder()
107 .url("https://codeguru-reviewer.eu-central-1.amazonaws.com")
108 .build()
109 );
110 }
111
112 #[test]
114 fn test_5() {
115 let params = crate::config::endpoint::Params::builder()
116 .region("eu-north-1".to_string())
117 .use_fips(false)
118 .use_dual_stack(false)
119 .build()
120 .expect("invalid params");
121 let resolver = crate::config::endpoint::DefaultResolver::new();
122 let endpoint = resolver.resolve_endpoint(¶ms);
123 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer.eu-north-1.amazonaws.com");
124 assert_eq!(
125 endpoint,
126 ::aws_smithy_types::endpoint::Endpoint::builder()
127 .url("https://codeguru-reviewer.eu-north-1.amazonaws.com")
128 .build()
129 );
130 }
131
132 #[test]
134 fn test_6() {
135 let params = crate::config::endpoint::Params::builder()
136 .region("eu-west-1".to_string())
137 .use_fips(false)
138 .use_dual_stack(false)
139 .build()
140 .expect("invalid params");
141 let resolver = crate::config::endpoint::DefaultResolver::new();
142 let endpoint = resolver.resolve_endpoint(¶ms);
143 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer.eu-west-1.amazonaws.com");
144 assert_eq!(
145 endpoint,
146 ::aws_smithy_types::endpoint::Endpoint::builder()
147 .url("https://codeguru-reviewer.eu-west-1.amazonaws.com")
148 .build()
149 );
150 }
151
152 #[test]
154 fn test_7() {
155 let params = crate::config::endpoint::Params::builder()
156 .region("eu-west-2".to_string())
157 .use_fips(false)
158 .use_dual_stack(false)
159 .build()
160 .expect("invalid params");
161 let resolver = crate::config::endpoint::DefaultResolver::new();
162 let endpoint = resolver.resolve_endpoint(¶ms);
163 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer.eu-west-2.amazonaws.com");
164 assert_eq!(
165 endpoint,
166 ::aws_smithy_types::endpoint::Endpoint::builder()
167 .url("https://codeguru-reviewer.eu-west-2.amazonaws.com")
168 .build()
169 );
170 }
171
172 #[test]
174 fn test_8() {
175 let params = crate::config::endpoint::Params::builder()
176 .region("us-east-1".to_string())
177 .use_fips(false)
178 .use_dual_stack(false)
179 .build()
180 .expect("invalid params");
181 let resolver = crate::config::endpoint::DefaultResolver::new();
182 let endpoint = resolver.resolve_endpoint(¶ms);
183 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer.us-east-1.amazonaws.com");
184 assert_eq!(
185 endpoint,
186 ::aws_smithy_types::endpoint::Endpoint::builder()
187 .url("https://codeguru-reviewer.us-east-1.amazonaws.com")
188 .build()
189 );
190 }
191
192 #[test]
194 fn test_9() {
195 let params = crate::config::endpoint::Params::builder()
196 .region("us-east-2".to_string())
197 .use_fips(false)
198 .use_dual_stack(false)
199 .build()
200 .expect("invalid params");
201 let resolver = crate::config::endpoint::DefaultResolver::new();
202 let endpoint = resolver.resolve_endpoint(¶ms);
203 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer.us-east-2.amazonaws.com");
204 assert_eq!(
205 endpoint,
206 ::aws_smithy_types::endpoint::Endpoint::builder()
207 .url("https://codeguru-reviewer.us-east-2.amazonaws.com")
208 .build()
209 );
210 }
211
212 #[test]
214 fn test_10() {
215 let params = crate::config::endpoint::Params::builder()
216 .region("us-west-2".to_string())
217 .use_fips(false)
218 .use_dual_stack(false)
219 .build()
220 .expect("invalid params");
221 let resolver = crate::config::endpoint::DefaultResolver::new();
222 let endpoint = resolver.resolve_endpoint(¶ms);
223 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer.us-west-2.amazonaws.com");
224 assert_eq!(
225 endpoint,
226 ::aws_smithy_types::endpoint::Endpoint::builder()
227 .url("https://codeguru-reviewer.us-west-2.amazonaws.com")
228 .build()
229 );
230 }
231
232 #[test]
234 fn test_11() {
235 let params = crate::config::endpoint::Params::builder()
236 .region("us-east-1".to_string())
237 .use_fips(true)
238 .use_dual_stack(true)
239 .build()
240 .expect("invalid params");
241 let resolver = crate::config::endpoint::DefaultResolver::new();
242 let endpoint = resolver.resolve_endpoint(¶ms);
243 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer-fips.us-east-1.api.aws");
244 assert_eq!(
245 endpoint,
246 ::aws_smithy_types::endpoint::Endpoint::builder()
247 .url("https://codeguru-reviewer-fips.us-east-1.api.aws")
248 .build()
249 );
250 }
251
252 #[test]
254 fn test_12() {
255 let params = crate::config::endpoint::Params::builder()
256 .region("us-east-1".to_string())
257 .use_fips(true)
258 .use_dual_stack(false)
259 .build()
260 .expect("invalid params");
261 let resolver = crate::config::endpoint::DefaultResolver::new();
262 let endpoint = resolver.resolve_endpoint(¶ms);
263 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer-fips.us-east-1.amazonaws.com");
264 assert_eq!(
265 endpoint,
266 ::aws_smithy_types::endpoint::Endpoint::builder()
267 .url("https://codeguru-reviewer-fips.us-east-1.amazonaws.com")
268 .build()
269 );
270 }
271
272 #[test]
274 fn test_13() {
275 let params = crate::config::endpoint::Params::builder()
276 .region("us-east-1".to_string())
277 .use_fips(false)
278 .use_dual_stack(true)
279 .build()
280 .expect("invalid params");
281 let resolver = crate::config::endpoint::DefaultResolver::new();
282 let endpoint = resolver.resolve_endpoint(¶ms);
283 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer.us-east-1.api.aws");
284 assert_eq!(
285 endpoint,
286 ::aws_smithy_types::endpoint::Endpoint::builder()
287 .url("https://codeguru-reviewer.us-east-1.api.aws")
288 .build()
289 );
290 }
291
292 #[test]
294 fn test_14() {
295 let params = crate::config::endpoint::Params::builder()
296 .region("cn-north-1".to_string())
297 .use_fips(true)
298 .use_dual_stack(true)
299 .build()
300 .expect("invalid params");
301 let resolver = crate::config::endpoint::DefaultResolver::new();
302 let endpoint = resolver.resolve_endpoint(¶ms);
303 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer-fips.cn-north-1.api.amazonwebservices.com.cn");
304 assert_eq!(
305 endpoint,
306 ::aws_smithy_types::endpoint::Endpoint::builder()
307 .url("https://codeguru-reviewer-fips.cn-north-1.api.amazonwebservices.com.cn")
308 .build()
309 );
310 }
311
312 #[test]
314 fn test_15() {
315 let params = crate::config::endpoint::Params::builder()
316 .region("cn-north-1".to_string())
317 .use_fips(true)
318 .use_dual_stack(false)
319 .build()
320 .expect("invalid params");
321 let resolver = crate::config::endpoint::DefaultResolver::new();
322 let endpoint = resolver.resolve_endpoint(¶ms);
323 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer-fips.cn-north-1.amazonaws.com.cn");
324 assert_eq!(
325 endpoint,
326 ::aws_smithy_types::endpoint::Endpoint::builder()
327 .url("https://codeguru-reviewer-fips.cn-north-1.amazonaws.com.cn")
328 .build()
329 );
330 }
331
332 #[test]
334 fn test_16() {
335 let params = crate::config::endpoint::Params::builder()
336 .region("cn-north-1".to_string())
337 .use_fips(false)
338 .use_dual_stack(true)
339 .build()
340 .expect("invalid params");
341 let resolver = crate::config::endpoint::DefaultResolver::new();
342 let endpoint = resolver.resolve_endpoint(¶ms);
343 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer.cn-north-1.api.amazonwebservices.com.cn");
344 assert_eq!(
345 endpoint,
346 ::aws_smithy_types::endpoint::Endpoint::builder()
347 .url("https://codeguru-reviewer.cn-north-1.api.amazonwebservices.com.cn")
348 .build()
349 );
350 }
351
352 #[test]
354 fn test_17() {
355 let params = crate::config::endpoint::Params::builder()
356 .region("cn-north-1".to_string())
357 .use_fips(false)
358 .use_dual_stack(false)
359 .build()
360 .expect("invalid params");
361 let resolver = crate::config::endpoint::DefaultResolver::new();
362 let endpoint = resolver.resolve_endpoint(¶ms);
363 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer.cn-north-1.amazonaws.com.cn");
364 assert_eq!(
365 endpoint,
366 ::aws_smithy_types::endpoint::Endpoint::builder()
367 .url("https://codeguru-reviewer.cn-north-1.amazonaws.com.cn")
368 .build()
369 );
370 }
371
372 #[test]
374 fn test_18() {
375 let params = crate::config::endpoint::Params::builder()
376 .region("us-gov-east-1".to_string())
377 .use_fips(true)
378 .use_dual_stack(true)
379 .build()
380 .expect("invalid params");
381 let resolver = crate::config::endpoint::DefaultResolver::new();
382 let endpoint = resolver.resolve_endpoint(¶ms);
383 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer-fips.us-gov-east-1.api.aws");
384 assert_eq!(
385 endpoint,
386 ::aws_smithy_types::endpoint::Endpoint::builder()
387 .url("https://codeguru-reviewer-fips.us-gov-east-1.api.aws")
388 .build()
389 );
390 }
391
392 #[test]
394 fn test_19() {
395 let params = crate::config::endpoint::Params::builder()
396 .region("us-gov-east-1".to_string())
397 .use_fips(true)
398 .use_dual_stack(false)
399 .build()
400 .expect("invalid params");
401 let resolver = crate::config::endpoint::DefaultResolver::new();
402 let endpoint = resolver.resolve_endpoint(¶ms);
403 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer-fips.us-gov-east-1.amazonaws.com");
404 assert_eq!(
405 endpoint,
406 ::aws_smithy_types::endpoint::Endpoint::builder()
407 .url("https://codeguru-reviewer-fips.us-gov-east-1.amazonaws.com")
408 .build()
409 );
410 }
411
412 #[test]
414 fn test_20() {
415 let params = crate::config::endpoint::Params::builder()
416 .region("us-gov-east-1".to_string())
417 .use_fips(false)
418 .use_dual_stack(true)
419 .build()
420 .expect("invalid params");
421 let resolver = crate::config::endpoint::DefaultResolver::new();
422 let endpoint = resolver.resolve_endpoint(¶ms);
423 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer.us-gov-east-1.api.aws");
424 assert_eq!(
425 endpoint,
426 ::aws_smithy_types::endpoint::Endpoint::builder()
427 .url("https://codeguru-reviewer.us-gov-east-1.api.aws")
428 .build()
429 );
430 }
431
432 #[test]
434 fn test_21() {
435 let params = crate::config::endpoint::Params::builder()
436 .region("us-gov-east-1".to_string())
437 .use_fips(false)
438 .use_dual_stack(false)
439 .build()
440 .expect("invalid params");
441 let resolver = crate::config::endpoint::DefaultResolver::new();
442 let endpoint = resolver.resolve_endpoint(¶ms);
443 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer.us-gov-east-1.amazonaws.com");
444 assert_eq!(
445 endpoint,
446 ::aws_smithy_types::endpoint::Endpoint::builder()
447 .url("https://codeguru-reviewer.us-gov-east-1.amazonaws.com")
448 .build()
449 );
450 }
451
452 #[test]
454 fn test_22() {
455 let params = crate::config::endpoint::Params::builder()
456 .region("us-iso-east-1".to_string())
457 .use_fips(true)
458 .use_dual_stack(false)
459 .build()
460 .expect("invalid params");
461 let resolver = crate::config::endpoint::DefaultResolver::new();
462 let endpoint = resolver.resolve_endpoint(¶ms);
463 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer-fips.us-iso-east-1.c2s.ic.gov");
464 assert_eq!(
465 endpoint,
466 ::aws_smithy_types::endpoint::Endpoint::builder()
467 .url("https://codeguru-reviewer-fips.us-iso-east-1.c2s.ic.gov")
468 .build()
469 );
470 }
471
472 #[test]
474 fn test_23() {
475 let params = crate::config::endpoint::Params::builder()
476 .region("us-iso-east-1".to_string())
477 .use_fips(false)
478 .use_dual_stack(false)
479 .build()
480 .expect("invalid params");
481 let resolver = crate::config::endpoint::DefaultResolver::new();
482 let endpoint = resolver.resolve_endpoint(¶ms);
483 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer.us-iso-east-1.c2s.ic.gov");
484 assert_eq!(
485 endpoint,
486 ::aws_smithy_types::endpoint::Endpoint::builder()
487 .url("https://codeguru-reviewer.us-iso-east-1.c2s.ic.gov")
488 .build()
489 );
490 }
491
492 #[test]
494 fn test_24() {
495 let params = crate::config::endpoint::Params::builder()
496 .region("us-isob-east-1".to_string())
497 .use_fips(true)
498 .use_dual_stack(false)
499 .build()
500 .expect("invalid params");
501 let resolver = crate::config::endpoint::DefaultResolver::new();
502 let endpoint = resolver.resolve_endpoint(¶ms);
503 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer-fips.us-isob-east-1.sc2s.sgov.gov");
504 assert_eq!(
505 endpoint,
506 ::aws_smithy_types::endpoint::Endpoint::builder()
507 .url("https://codeguru-reviewer-fips.us-isob-east-1.sc2s.sgov.gov")
508 .build()
509 );
510 }
511
512 #[test]
514 fn test_25() {
515 let params = crate::config::endpoint::Params::builder()
516 .region("us-isob-east-1".to_string())
517 .use_fips(false)
518 .use_dual_stack(false)
519 .build()
520 .expect("invalid params");
521 let resolver = crate::config::endpoint::DefaultResolver::new();
522 let endpoint = resolver.resolve_endpoint(¶ms);
523 let endpoint = endpoint.expect("Expected valid endpoint: https://codeguru-reviewer.us-isob-east-1.sc2s.sgov.gov");
524 assert_eq!(
525 endpoint,
526 ::aws_smithy_types::endpoint::Endpoint::builder()
527 .url("https://codeguru-reviewer.us-isob-east-1.sc2s.sgov.gov")
528 .build()
529 );
530 }
531
532 #[test]
534 fn test_26() {
535 let params = crate::config::endpoint::Params::builder()
536 .region("us-east-1".to_string())
537 .use_fips(false)
538 .use_dual_stack(false)
539 .endpoint("https://example.com".to_string())
540 .build()
541 .expect("invalid params");
542 let resolver = crate::config::endpoint::DefaultResolver::new();
543 let endpoint = resolver.resolve_endpoint(¶ms);
544 let endpoint = endpoint.expect("Expected valid endpoint: https://example.com");
545 assert_eq!(
546 endpoint,
547 ::aws_smithy_types::endpoint::Endpoint::builder().url("https://example.com").build()
548 );
549 }
550
551 #[test]
553 fn test_27() {
554 let params = crate::config::endpoint::Params::builder()
555 .use_fips(false)
556 .use_dual_stack(false)
557 .endpoint("https://example.com".to_string())
558 .build()
559 .expect("invalid params");
560 let resolver = crate::config::endpoint::DefaultResolver::new();
561 let endpoint = resolver.resolve_endpoint(¶ms);
562 let endpoint = endpoint.expect("Expected valid endpoint: https://example.com");
563 assert_eq!(
564 endpoint,
565 ::aws_smithy_types::endpoint::Endpoint::builder().url("https://example.com").build()
566 );
567 }
568
569 #[test]
571 fn test_28() {
572 let params = crate::config::endpoint::Params::builder()
573 .region("us-east-1".to_string())
574 .use_fips(true)
575 .use_dual_stack(false)
576 .endpoint("https://example.com".to_string())
577 .build()
578 .expect("invalid params");
579 let resolver = crate::config::endpoint::DefaultResolver::new();
580 let endpoint = resolver.resolve_endpoint(¶ms);
581 let error = endpoint.expect_err("expected error: Invalid Configuration: FIPS and custom endpoint are not supported [For custom endpoint with fips enabled and dualstack disabled]");
582 assert_eq!(format!("{}", error), "Invalid Configuration: FIPS and custom endpoint are not supported")
583 }
584
585 #[test]
587 fn test_29() {
588 let params = crate::config::endpoint::Params::builder()
589 .region("us-east-1".to_string())
590 .use_fips(false)
591 .use_dual_stack(true)
592 .endpoint("https://example.com".to_string())
593 .build()
594 .expect("invalid params");
595 let resolver = crate::config::endpoint::DefaultResolver::new();
596 let endpoint = resolver.resolve_endpoint(¶ms);
597 let error = endpoint.expect_err("expected error: Invalid Configuration: Dualstack and custom endpoint are not supported [For custom endpoint with fips disabled and dualstack enabled]");
598 assert_eq!(
599 format!("{}", error),
600 "Invalid Configuration: Dualstack and custom endpoint are not supported"
601 )
602 }
603
604 #[test]
606 fn test_30() {
607 let params = crate::config::endpoint::Params::builder().build().expect("invalid params");
608 let resolver = crate::config::endpoint::DefaultResolver::new();
609 let endpoint = resolver.resolve_endpoint(¶ms);
610 let error = endpoint.expect_err("expected error: Invalid Configuration: Missing Region [Missing region]");
611 assert_eq!(format!("{}", error), "Invalid Configuration: Missing Region")
612 }
613}
614
615pub trait ResolveEndpoint: ::std::marker::Send + ::std::marker::Sync + ::std::fmt::Debug {
617 fn resolve_endpoint<'a>(&'a self, params: &'a crate::config::endpoint::Params) -> ::aws_smithy_runtime_api::client::endpoint::EndpointFuture<'a>;
619
620 fn into_shared_resolver(self) -> ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver
624 where
625 Self: Sized + 'static,
626 {
627 ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver::new(DowncastParams(self))
628 }
629}
630
631#[derive(Debug)]
632struct DowncastParams<T>(T);
633impl<T> ::aws_smithy_runtime_api::client::endpoint::ResolveEndpoint for DowncastParams<T>
634where
635 T: ResolveEndpoint,
636{
637 fn resolve_endpoint<'a>(
638 &'a self,
639 params: &'a ::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams,
640 ) -> ::aws_smithy_runtime_api::client::endpoint::EndpointFuture<'a> {
641 let ep = match params.get::<crate::config::endpoint::Params>() {
642 Some(params) => self.0.resolve_endpoint(params),
643 None => ::aws_smithy_runtime_api::client::endpoint::EndpointFuture::ready(Err("params of expected type was not present".into())),
644 };
645 ep
646 }
647}
648
649#[derive(Debug)]
650pub struct DefaultResolver {
652 partition_resolver: &'static crate::endpoint_lib::partition::PartitionResolver,
653 endpoint_cache: ::arc_swap::ArcSwap<::std::option::Option<(Params, ::aws_smithy_types::endpoint::Endpoint)>>,
654}
655
656impl Default for DefaultResolver {
657 fn default() -> Self {
658 Self::new()
659 }
660}
661
662impl DefaultResolver {
663 pub fn new() -> Self {
665 Self {
666 partition_resolver: &crate::endpoint_lib::DEFAULT_PARTITION_RESOLVER,
667 endpoint_cache: ::arc_swap::ArcSwap::from_pointee(None),
668 }
669 }
670
671 #[allow(
672 unused_variables,
673 unused_parens,
674 clippy::double_parens,
675 clippy::useless_conversion,
676 clippy::bool_comparison,
677 clippy::comparison_to_empty,
678 clippy::needless_borrow,
679 clippy::useless_asref,
680 clippy::redundant_closure_call,
681 clippy::clone_on_copy,
682 clippy::single_char_add_str
683 )]
684 fn resolve_endpoint<'a>(
685 &'a self,
686 params: &'a crate::config::endpoint::Params,
687 ) -> ::std::result::Result<::aws_smithy_types::endpoint::Endpoint, ::aws_smithy_runtime_api::box_error::BoxError> {
688 let mut _diagnostic_collector = crate::endpoint_lib::diagnostic::DiagnosticCollector::new();
689 #[allow(unused_mut)]
690 let mut context = ConditionContext::default();
691
692 let region = ¶ms.region;
694 let use_dual_stack = ¶ms.use_dual_stack;
695 let use_fips = ¶ms.use_fips;
696 let endpoint = ¶ms.endpoint;
697
698 let mut current_ref: i32 = 2;
699 loop {
700 match current_ref {
701 ref_val if ref_val >= 100_000_000 => {
702 return match (ref_val - 100_000_000) as usize {
703 0 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
704 "No endpoint rule matched",
705 )) as ::aws_smithy_runtime_api::box_error::BoxError),
706 1 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
707 "Invalid Configuration: FIPS and custom endpoint are not supported".to_string(),
708 )) as ::aws_smithy_runtime_api::box_error::BoxError),
709 2 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
710 "Invalid Configuration: Dualstack and custom endpoint are not supported".to_string(),
711 )) as ::aws_smithy_runtime_api::box_error::BoxError),
712 3 => {
713 let endpoint = params.endpoint.as_deref().unwrap_or_default();
714 ::std::result::Result::Ok(::aws_smithy_types::endpoint::Endpoint::builder().url(endpoint.to_owned()).build())
715 }
716 4 => {
717 let region = params.region.as_deref().unwrap_or_default();
718 let partition_result = context.partition_result.as_ref().expect("Guaranteed to have a value by earlier checks.");
719 ::std::result::Result::Ok(
720 ::aws_smithy_types::endpoint::Endpoint::builder()
721 .url({
722 let mut out = String::new();
723 out.push_str("https://codeguru-reviewer-fips.");
724 #[allow(clippy::needless_borrow)]
725 out.push_str(®ion.as_ref());
726 out.push_str(".");
727 #[allow(clippy::needless_borrow)]
728 out.push_str(&partition_result.dual_stack_dns_suffix());
729 out
730 })
731 .build(),
732 )
733 }
734 5 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
735 "FIPS and DualStack are enabled, but this partition does not support one or both".to_string(),
736 )) as ::aws_smithy_runtime_api::box_error::BoxError),
737 6 => {
738 let region = params.region.as_deref().unwrap_or_default();
739 let partition_result = context.partition_result.as_ref().expect("Guaranteed to have a value by earlier checks.");
740 ::std::result::Result::Ok(
741 ::aws_smithy_types::endpoint::Endpoint::builder()
742 .url({
743 let mut out = String::new();
744 out.push_str("https://codeguru-reviewer-fips.");
745 #[allow(clippy::needless_borrow)]
746 out.push_str(®ion.as_ref());
747 out.push_str(".");
748 #[allow(clippy::needless_borrow)]
749 out.push_str(&partition_result.dns_suffix());
750 out
751 })
752 .build(),
753 )
754 }
755 7 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
756 "FIPS is enabled but this partition does not support FIPS".to_string(),
757 )) as ::aws_smithy_runtime_api::box_error::BoxError),
758 8 => {
759 let region = params.region.as_deref().unwrap_or_default();
760 let partition_result = context.partition_result.as_ref().expect("Guaranteed to have a value by earlier checks.");
761 ::std::result::Result::Ok(
762 ::aws_smithy_types::endpoint::Endpoint::builder()
763 .url({
764 let mut out = String::new();
765 out.push_str("https://codeguru-reviewer.");
766 #[allow(clippy::needless_borrow)]
767 out.push_str(®ion.as_ref());
768 out.push_str(".");
769 #[allow(clippy::needless_borrow)]
770 out.push_str(&partition_result.dual_stack_dns_suffix());
771 out
772 })
773 .build(),
774 )
775 }
776 9 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
777 "DualStack is enabled but this partition does not support DualStack".to_string(),
778 )) as ::aws_smithy_runtime_api::box_error::BoxError),
779 10 => {
780 let region = params.region.as_deref().unwrap_or_default();
781 let partition_result = context.partition_result.as_ref().expect("Guaranteed to have a value by earlier checks.");
782 ::std::result::Result::Ok(
783 ::aws_smithy_types::endpoint::Endpoint::builder()
784 .url({
785 let mut out = String::new();
786 out.push_str("https://codeguru-reviewer.");
787 #[allow(clippy::needless_borrow)]
788 out.push_str(®ion.as_ref());
789 out.push_str(".");
790 #[allow(clippy::needless_borrow)]
791 out.push_str(&partition_result.dns_suffix());
792 out
793 })
794 .build(),
795 )
796 }
797 11 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
798 "Invalid Configuration: Missing Region".to_string(),
799 )) as ::aws_smithy_runtime_api::box_error::BoxError),
800 _ => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
801 "No endpoint rule matched",
802 )) as ::aws_smithy_runtime_api::box_error::BoxError),
803 };
804 }
805 1 | -1 => {
806 return ::std::result::Result::Err(
807 Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message("No endpoint rule matched"))
808 as ::aws_smithy_runtime_api::box_error::BoxError,
809 )
810 }
811 ref_val => {
812 let is_complement = ref_val < 0;
813 let node = &NODES[(ref_val.unsigned_abs() as usize) - 1];
814 let condition_result = match node.condition_index {
815 0 => endpoint.is_some(),
816 1 => region.is_some(),
817 2 => (|_diagnostic_collector: &mut crate::endpoint_lib::diagnostic::DiagnosticCollector| -> bool {
818 let partition_result = &mut context.partition_result;
819 let partition_resolver = &self.partition_resolver;
820 {
821 *partition_result = partition_resolver
822 .resolve_partition(if let Some(param) = region { param } else { return false }, _diagnostic_collector)
823 .map(|inner| inner.into());
824 partition_result.is_some()
825 }
826 })(&mut _diagnostic_collector),
827 3 => (use_fips) == (&true),
828 4 => (use_dual_stack) == (&true),
829 5 => (|_diagnostic_collector: &mut crate::endpoint_lib::diagnostic::DiagnosticCollector| -> bool {
830 let partition_result = &context.partition_result;
831 let partition_resolver = &self.partition_resolver;
832 (if let Some(inner) = partition_result {
833 inner.supports_dual_stack()
834 } else {
835 return false;
836 }) == (true)
837 })(&mut _diagnostic_collector),
838 6 => (|_diagnostic_collector: &mut crate::endpoint_lib::diagnostic::DiagnosticCollector| -> bool {
839 let partition_result = &context.partition_result;
840 let partition_resolver = &self.partition_resolver;
841 (if let Some(inner) = partition_result {
842 inner.supports_fips()
843 } else {
844 return false;
845 }) == (true)
846 })(&mut _diagnostic_collector),
847 _ => unreachable!("Invalid condition index"),
848 };
849 current_ref = if is_complement ^ condition_result { node.high_ref } else { node.low_ref };
850 }
851 }
852 }
853 }
854}
855
856impl crate::config::endpoint::ResolveEndpoint for DefaultResolver {
857 fn resolve_endpoint<'a>(&'a self, params: &'a crate::config::endpoint::Params) -> ::aws_smithy_runtime_api::client::endpoint::EndpointFuture<'a> {
858 let cached = self.endpoint_cache.load();
860 if let Some((cached_params, cached_endpoint)) = cached.as_ref() {
861 if cached_params == params {
862 return ::aws_smithy_runtime_api::client::endpoint::EndpointFuture::ready(::std::result::Result::Ok(cached_endpoint.clone()));
863 }
864 }
865 drop(cached);
866 let result = self.resolve_endpoint(params);
867 if let ::std::result::Result::Ok(ref endpoint) = result {
868 self.endpoint_cache.store(::std::sync::Arc::new(Some((params.clone(), endpoint.clone()))));
869 }
870 ::aws_smithy_runtime_api::client::endpoint::EndpointFuture::ready(result)
871 }
872}
873const NODES: [crate::endpoint_lib::bdd_interpreter::BddNode; 13] = [
874 crate::endpoint_lib::bdd_interpreter::BddNode {
875 condition_index: -1,
876 high_ref: 1,
877 low_ref: -1,
878 },
879 crate::endpoint_lib::bdd_interpreter::BddNode {
880 condition_index: 0,
881 high_ref: 12,
882 low_ref: 3,
883 },
884 crate::endpoint_lib::bdd_interpreter::BddNode {
885 condition_index: 1,
886 high_ref: 4,
887 low_ref: 100000011,
888 },
889 crate::endpoint_lib::bdd_interpreter::BddNode {
890 condition_index: 2,
891 high_ref: 5,
892 low_ref: 100000011,
893 },
894 crate::endpoint_lib::bdd_interpreter::BddNode {
895 condition_index: 3,
896 high_ref: 8,
897 low_ref: 6,
898 },
899 crate::endpoint_lib::bdd_interpreter::BddNode {
900 condition_index: 4,
901 high_ref: 7,
902 low_ref: 100000010,
903 },
904 crate::endpoint_lib::bdd_interpreter::BddNode {
905 condition_index: 5,
906 high_ref: 100000008,
907 low_ref: 100000009,
908 },
909 crate::endpoint_lib::bdd_interpreter::BddNode {
910 condition_index: 4,
911 high_ref: 10,
912 low_ref: 9,
913 },
914 crate::endpoint_lib::bdd_interpreter::BddNode {
915 condition_index: 6,
916 high_ref: 100000006,
917 low_ref: 100000007,
918 },
919 crate::endpoint_lib::bdd_interpreter::BddNode {
920 condition_index: 5,
921 high_ref: 11,
922 low_ref: 100000005,
923 },
924 crate::endpoint_lib::bdd_interpreter::BddNode {
925 condition_index: 6,
926 high_ref: 100000004,
927 low_ref: 100000005,
928 },
929 crate::endpoint_lib::bdd_interpreter::BddNode {
930 condition_index: 3,
931 high_ref: 100000001,
932 low_ref: 13,
933 },
934 crate::endpoint_lib::bdd_interpreter::BddNode {
935 condition_index: 4,
936 high_ref: 100000002,
937 low_ref: 100000003,
938 },
939];
940#[derive(Default)]
943#[allow(unused_lifetimes)]
944pub(crate) struct ConditionContext<'a> {
945 pub(crate) partition_result: Option<crate::endpoint_lib::partition::Partition<'a>>,
946 phantom: std::marker::PhantomData<&'a ()>,
948}
949
950#[non_exhaustive]
951#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
952pub struct Params {
954 pub(crate) region: ::std::option::Option<::std::string::String>,
956 pub(crate) use_dual_stack: bool,
958 pub(crate) use_fips: bool,
960 pub(crate) endpoint: ::std::option::Option<::std::string::String>,
962}
963impl Params {
964 pub fn builder() -> crate::config::endpoint::ParamsBuilder {
966 crate::config::endpoint::ParamsBuilder::default()
967 }
968 pub fn region(&self) -> ::std::option::Option<&str> {
970 self.region.as_deref()
971 }
972 pub fn use_dual_stack(&self) -> ::std::option::Option<bool> {
974 Some(self.use_dual_stack)
975 }
976 pub fn use_fips(&self) -> ::std::option::Option<bool> {
978 Some(self.use_fips)
979 }
980 pub fn endpoint(&self) -> ::std::option::Option<&str> {
982 self.endpoint.as_deref()
983 }
984}
985
986#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
988pub struct ParamsBuilder {
989 region: ::std::option::Option<::std::string::String>,
990 use_dual_stack: ::std::option::Option<bool>,
991 use_fips: ::std::option::Option<bool>,
992 endpoint: ::std::option::Option<::std::string::String>,
993}
994impl ParamsBuilder {
995 pub fn build(self) -> ::std::result::Result<crate::config::endpoint::Params, crate::config::endpoint::InvalidParams> {
997 if let Some(region) = &self.region {
998 if !crate::endpoint_lib::host::is_valid_host_label(
999 region.as_ref() as &str,
1000 true,
1001 &mut crate::endpoint_lib::diagnostic::DiagnosticCollector::new(),
1002 ) {
1003 return Err(crate::config::endpoint::InvalidParams::invalid_value(
1004 "region",
1005 "must be a valid host label",
1006 ));
1007 }
1008 };
1009 Ok(
1010 #[allow(clippy::unnecessary_lazy_evaluations)]
1011 crate::config::endpoint::Params {
1012 region: self.region,
1013 use_dual_stack: self
1014 .use_dual_stack
1015 .or_else(|| Some(false))
1016 .ok_or_else(|| crate::config::endpoint::InvalidParams::missing("use_dual_stack"))?,
1017 use_fips: self
1018 .use_fips
1019 .or_else(|| Some(false))
1020 .ok_or_else(|| crate::config::endpoint::InvalidParams::missing("use_fips"))?,
1021 endpoint: self.endpoint,
1022 },
1023 )
1024 }
1025 pub fn region(mut self, value: impl Into<::std::string::String>) -> Self {
1029 self.region = Some(value.into());
1030 self
1031 }
1032
1033 pub fn set_region(mut self, param: Option<::std::string::String>) -> Self {
1037 self.region = param;
1038 self
1039 }
1040 pub fn use_dual_stack(mut self, value: impl Into<bool>) -> Self {
1045 self.use_dual_stack = Some(value.into());
1046 self
1047 }
1048
1049 pub fn set_use_dual_stack(mut self, param: Option<bool>) -> Self {
1054 self.use_dual_stack = param;
1055 self
1056 }
1057 pub fn use_fips(mut self, value: impl Into<bool>) -> Self {
1062 self.use_fips = Some(value.into());
1063 self
1064 }
1065
1066 pub fn set_use_fips(mut self, param: Option<bool>) -> Self {
1071 self.use_fips = param;
1072 self
1073 }
1074 pub fn endpoint(mut self, value: impl Into<::std::string::String>) -> Self {
1078 self.endpoint = Some(value.into());
1079 self
1080 }
1081
1082 pub fn set_endpoint(mut self, param: Option<::std::string::String>) -> Self {
1086 self.endpoint = param;
1087 self
1088 }
1089}
1090
1091#[derive(Debug)]
1093pub struct InvalidParams {
1094 field: std::borrow::Cow<'static, str>,
1095 kind: InvalidParamsErrorKind,
1096}
1097
1098#[derive(Debug)]
1100enum InvalidParamsErrorKind {
1101 MissingField,
1102 InvalidValue { message: &'static str },
1103}
1104
1105impl InvalidParams {
1106 #[allow(dead_code)]
1107 fn missing(field: &'static str) -> Self {
1108 Self {
1109 field: field.into(),
1110 kind: InvalidParamsErrorKind::MissingField,
1111 }
1112 }
1113
1114 #[allow(dead_code)]
1115 fn invalid_value(field: &'static str, message: &'static str) -> Self {
1116 Self {
1117 field: field.into(),
1118 kind: InvalidParamsErrorKind::InvalidValue { message },
1119 }
1120 }
1121}
1122
1123impl std::fmt::Display for InvalidParams {
1124 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
1125 match self.kind {
1126 InvalidParamsErrorKind::MissingField => write!(f, "a required field was missing: `{}`", self.field),
1127 InvalidParamsErrorKind::InvalidValue { message } => write!(f, "invalid value for field: `{}` - {}", self.field, message),
1128 }
1129 }
1130}
1131
1132impl std::error::Error for InvalidParams {}