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://runtime.lex.ap-northeast-1.amazonaws.com");
44 assert_eq!(
45 endpoint,
46 ::aws_smithy_types::endpoint::Endpoint::builder()
47 .url("https://runtime.lex.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://runtime.lex.ap-southeast-1.amazonaws.com");
64 assert_eq!(
65 endpoint,
66 ::aws_smithy_types::endpoint::Endpoint::builder()
67 .url("https://runtime.lex.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://runtime.lex.ap-southeast-2.amazonaws.com");
84 assert_eq!(
85 endpoint,
86 ::aws_smithy_types::endpoint::Endpoint::builder()
87 .url("https://runtime.lex.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://runtime.lex.eu-central-1.amazonaws.com");
104 assert_eq!(
105 endpoint,
106 ::aws_smithy_types::endpoint::Endpoint::builder()
107 .url("https://runtime.lex.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-west-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://runtime.lex.eu-west-1.amazonaws.com");
124 assert_eq!(
125 endpoint,
126 ::aws_smithy_types::endpoint::Endpoint::builder()
127 .url("https://runtime.lex.eu-west-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-2".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://runtime.lex.eu-west-2.amazonaws.com");
144 assert_eq!(
145 endpoint,
146 ::aws_smithy_types::endpoint::Endpoint::builder()
147 .url("https://runtime.lex.eu-west-2.amazonaws.com")
148 .build()
149 );
150 }
151
152 #[test]
154 fn test_7() {
155 let params = crate::config::endpoint::Params::builder()
156 .region("us-east-1".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://runtime.lex.us-east-1.amazonaws.com");
164 assert_eq!(
165 endpoint,
166 ::aws_smithy_types::endpoint::Endpoint::builder()
167 .url("https://runtime.lex.us-east-1.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(true)
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://runtime-fips.lex.us-east-1.amazonaws.com");
184 assert_eq!(
185 endpoint,
186 ::aws_smithy_types::endpoint::Endpoint::builder()
187 .url("https://runtime-fips.lex.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-west-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://runtime.lex.us-west-2.amazonaws.com");
204 assert_eq!(
205 endpoint,
206 ::aws_smithy_types::endpoint::Endpoint::builder()
207 .url("https://runtime.lex.us-west-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(true)
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://runtime-fips.lex.us-west-2.amazonaws.com");
224 assert_eq!(
225 endpoint,
226 ::aws_smithy_types::endpoint::Endpoint::builder()
227 .url("https://runtime-fips.lex.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://runtime.lex-fips.us-east-1.api.aws");
244 assert_eq!(
245 endpoint,
246 ::aws_smithy_types::endpoint::Endpoint::builder()
247 .url("https://runtime.lex-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(false)
258 .use_dual_stack(true)
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://runtime.lex.us-east-1.api.aws");
264 assert_eq!(
265 endpoint,
266 ::aws_smithy_types::endpoint::Endpoint::builder()
267 .url("https://runtime.lex.us-east-1.api.aws")
268 .build()
269 );
270 }
271
272 #[test]
274 fn test_13() {
275 let params = crate::config::endpoint::Params::builder()
276 .region("cn-north-1".to_string())
277 .use_fips(true)
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://runtime.lex-fips.cn-north-1.api.amazonwebservices.com.cn");
284 assert_eq!(
285 endpoint,
286 ::aws_smithy_types::endpoint::Endpoint::builder()
287 .url("https://runtime.lex-fips.cn-north-1.api.amazonwebservices.com.cn")
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(false)
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://runtime.lex-fips.cn-north-1.amazonaws.com.cn");
304 assert_eq!(
305 endpoint,
306 ::aws_smithy_types::endpoint::Endpoint::builder()
307 .url("https://runtime.lex-fips.cn-north-1.amazonaws.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(false)
318 .use_dual_stack(true)
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://runtime.lex.cn-north-1.api.amazonwebservices.com.cn");
324 assert_eq!(
325 endpoint,
326 ::aws_smithy_types::endpoint::Endpoint::builder()
327 .url("https://runtime.lex.cn-north-1.api.amazonwebservices.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(false)
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://runtime.lex.cn-north-1.amazonaws.com.cn");
344 assert_eq!(
345 endpoint,
346 ::aws_smithy_types::endpoint::Endpoint::builder()
347 .url("https://runtime.lex.cn-north-1.amazonaws.com.cn")
348 .build()
349 );
350 }
351
352 #[test]
354 fn test_17() {
355 let params = crate::config::endpoint::Params::builder()
356 .region("us-gov-west-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://runtime.lex.us-gov-west-1.amazonaws.com");
364 assert_eq!(
365 endpoint,
366 ::aws_smithy_types::endpoint::Endpoint::builder()
367 .url("https://runtime.lex.us-gov-west-1.amazonaws.com")
368 .build()
369 );
370 }
371
372 #[test]
374 fn test_18() {
375 let params = crate::config::endpoint::Params::builder()
376 .region("us-gov-west-1".to_string())
377 .use_fips(true)
378 .use_dual_stack(false)
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://runtime-fips.lex.us-gov-west-1.amazonaws.com");
384 assert_eq!(
385 endpoint,
386 ::aws_smithy_types::endpoint::Endpoint::builder()
387 .url("https://runtime-fips.lex.us-gov-west-1.amazonaws.com")
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(true)
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://runtime.lex-fips.us-gov-east-1.api.aws");
404 assert_eq!(
405 endpoint,
406 ::aws_smithy_types::endpoint::Endpoint::builder()
407 .url("https://runtime.lex-fips.us-gov-east-1.api.aws")
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(true)
418 .use_dual_stack(false)
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://runtime-fips.lex.us-gov-east-1.amazonaws.com");
424 assert_eq!(
425 endpoint,
426 ::aws_smithy_types::endpoint::Endpoint::builder()
427 .url("https://runtime-fips.lex.us-gov-east-1.amazonaws.com")
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(true)
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://runtime.lex.us-gov-east-1.api.aws");
444 assert_eq!(
445 endpoint,
446 ::aws_smithy_types::endpoint::Endpoint::builder()
447 .url("https://runtime.lex.us-gov-east-1.api.aws")
448 .build()
449 );
450 }
451
452 #[test]
454 fn test_22() {
455 let params = crate::config::endpoint::Params::builder()
456 .region("us-gov-east-1".to_string())
457 .use_fips(false)
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://runtime.lex.us-gov-east-1.amazonaws.com");
464 assert_eq!(
465 endpoint,
466 ::aws_smithy_types::endpoint::Endpoint::builder()
467 .url("https://runtime.lex.us-gov-east-1.amazonaws.com")
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(true)
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://runtime.lex-fips.us-iso-east-1.c2s.ic.gov");
484 assert_eq!(
485 endpoint,
486 ::aws_smithy_types::endpoint::Endpoint::builder()
487 .url("https://runtime.lex-fips.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-iso-east-1".to_string())
497 .use_fips(false)
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://runtime.lex.us-iso-east-1.c2s.ic.gov");
504 assert_eq!(
505 endpoint,
506 ::aws_smithy_types::endpoint::Endpoint::builder()
507 .url("https://runtime.lex.us-iso-east-1.c2s.ic.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(true)
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://runtime.lex-fips.us-isob-east-1.sc2s.sgov.gov");
524 assert_eq!(
525 endpoint,
526 ::aws_smithy_types::endpoint::Endpoint::builder()
527 .url("https://runtime.lex-fips.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-isob-east-1".to_string())
537 .use_fips(false)
538 .use_dual_stack(false)
539 .build()
540 .expect("invalid params");
541 let resolver = crate::config::endpoint::DefaultResolver::new();
542 let endpoint = resolver.resolve_endpoint(¶ms);
543 let endpoint = endpoint.expect("Expected valid endpoint: https://runtime.lex.us-isob-east-1.sc2s.sgov.gov");
544 assert_eq!(
545 endpoint,
546 ::aws_smithy_types::endpoint::Endpoint::builder()
547 .url("https://runtime.lex.us-isob-east-1.sc2s.sgov.gov")
548 .build()
549 );
550 }
551
552 #[test]
554 fn test_27() {
555 let params = crate::config::endpoint::Params::builder()
556 .region("us-east-1".to_string())
557 .use_fips(false)
558 .use_dual_stack(false)
559 .endpoint("https://example.com".to_string())
560 .build()
561 .expect("invalid params");
562 let resolver = crate::config::endpoint::DefaultResolver::new();
563 let endpoint = resolver.resolve_endpoint(¶ms);
564 let endpoint = endpoint.expect("Expected valid endpoint: https://example.com");
565 assert_eq!(
566 endpoint,
567 ::aws_smithy_types::endpoint::Endpoint::builder().url("https://example.com").build()
568 );
569 }
570
571 #[test]
573 fn test_28() {
574 let params = crate::config::endpoint::Params::builder()
575 .use_fips(false)
576 .use_dual_stack(false)
577 .endpoint("https://example.com".to_string())
578 .build()
579 .expect("invalid params");
580 let resolver = crate::config::endpoint::DefaultResolver::new();
581 let endpoint = resolver.resolve_endpoint(¶ms);
582 let endpoint = endpoint.expect("Expected valid endpoint: https://example.com");
583 assert_eq!(
584 endpoint,
585 ::aws_smithy_types::endpoint::Endpoint::builder().url("https://example.com").build()
586 );
587 }
588
589 #[test]
591 fn test_29() {
592 let params = crate::config::endpoint::Params::builder()
593 .region("us-east-1".to_string())
594 .use_fips(true)
595 .use_dual_stack(false)
596 .endpoint("https://example.com".to_string())
597 .build()
598 .expect("invalid params");
599 let resolver = crate::config::endpoint::DefaultResolver::new();
600 let endpoint = resolver.resolve_endpoint(¶ms);
601 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]");
602 assert_eq!(format!("{}", error), "Invalid Configuration: FIPS and custom endpoint are not supported")
603 }
604
605 #[test]
607 fn test_30() {
608 let params = crate::config::endpoint::Params::builder()
609 .region("us-east-1".to_string())
610 .use_fips(false)
611 .use_dual_stack(true)
612 .endpoint("https://example.com".to_string())
613 .build()
614 .expect("invalid params");
615 let resolver = crate::config::endpoint::DefaultResolver::new();
616 let endpoint = resolver.resolve_endpoint(¶ms);
617 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]");
618 assert_eq!(
619 format!("{}", error),
620 "Invalid Configuration: Dualstack and custom endpoint are not supported"
621 )
622 }
623
624 #[test]
626 fn test_31() {
627 let params = crate::config::endpoint::Params::builder().build().expect("invalid params");
628 let resolver = crate::config::endpoint::DefaultResolver::new();
629 let endpoint = resolver.resolve_endpoint(¶ms);
630 let error = endpoint.expect_err("expected error: Invalid Configuration: Missing Region [Missing region]");
631 assert_eq!(format!("{}", error), "Invalid Configuration: Missing Region")
632 }
633}
634
635pub trait ResolveEndpoint: ::std::marker::Send + ::std::marker::Sync + ::std::fmt::Debug {
637 fn resolve_endpoint<'a>(&'a self, params: &'a crate::config::endpoint::Params) -> ::aws_smithy_runtime_api::client::endpoint::EndpointFuture<'a>;
639
640 fn into_shared_resolver(self) -> ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver
644 where
645 Self: Sized + 'static,
646 {
647 ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver::new(DowncastParams(self))
648 }
649}
650
651#[derive(Debug)]
652struct DowncastParams<T>(T);
653impl<T> ::aws_smithy_runtime_api::client::endpoint::ResolveEndpoint for DowncastParams<T>
654where
655 T: ResolveEndpoint,
656{
657 fn resolve_endpoint<'a>(
658 &'a self,
659 params: &'a ::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams,
660 ) -> ::aws_smithy_runtime_api::client::endpoint::EndpointFuture<'a> {
661 let ep = match params.get::<crate::config::endpoint::Params>() {
662 Some(params) => self.0.resolve_endpoint(params),
663 None => ::aws_smithy_runtime_api::client::endpoint::EndpointFuture::ready(Err("params of expected type was not present".into())),
664 };
665 ep
666 }
667}
668
669#[derive(Debug)]
670pub struct DefaultResolver {
672 partition_resolver: &'static crate::endpoint_lib::partition::PartitionResolver,
673 endpoint_cache: ::arc_swap::ArcSwap<::std::option::Option<(Params, ::aws_smithy_types::endpoint::Endpoint)>>,
674}
675
676impl Default for DefaultResolver {
677 fn default() -> Self {
678 Self::new()
679 }
680}
681
682impl DefaultResolver {
683 pub fn new() -> Self {
685 Self {
686 partition_resolver: &crate::endpoint_lib::DEFAULT_PARTITION_RESOLVER,
687 endpoint_cache: ::arc_swap::ArcSwap::from_pointee(None),
688 }
689 }
690
691 #[allow(
692 unused_variables,
693 unused_parens,
694 clippy::double_parens,
695 clippy::useless_conversion,
696 clippy::bool_comparison,
697 clippy::comparison_to_empty,
698 clippy::needless_borrow,
699 clippy::useless_asref,
700 clippy::redundant_closure_call,
701 clippy::clone_on_copy,
702 clippy::single_char_add_str
703 )]
704 fn resolve_endpoint<'a>(
705 &'a self,
706 params: &'a crate::config::endpoint::Params,
707 ) -> ::std::result::Result<::aws_smithy_types::endpoint::Endpoint, ::aws_smithy_runtime_api::box_error::BoxError> {
708 let mut _diagnostic_collector = crate::endpoint_lib::diagnostic::DiagnosticCollector::new();
709 #[allow(unused_mut)]
710 let mut context = ConditionContext::default();
711
712 let region = ¶ms.region;
714 let use_dual_stack = ¶ms.use_dual_stack;
715 let use_fips = ¶ms.use_fips;
716 let endpoint = ¶ms.endpoint;
717
718 let mut current_ref: i32 = 2;
719 loop {
720 match current_ref {
721 ref_val if ref_val >= 100_000_000 => {
722 return match (ref_val - 100_000_000) as usize {
723 0 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
724 "No endpoint rule matched",
725 )) as ::aws_smithy_runtime_api::box_error::BoxError),
726 1 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
727 "Invalid Configuration: FIPS and custom endpoint are not supported".to_string(),
728 )) as ::aws_smithy_runtime_api::box_error::BoxError),
729 2 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
730 "Invalid Configuration: Dualstack and custom endpoint are not supported".to_string(),
731 )) as ::aws_smithy_runtime_api::box_error::BoxError),
732 3 => {
733 let endpoint = params.endpoint.as_deref().unwrap_or_default();
734 ::std::result::Result::Ok(::aws_smithy_types::endpoint::Endpoint::builder().url(endpoint.to_owned()).build())
735 }
736 4 => {
737 let region = params.region.as_deref().unwrap_or_default();
738 let partition_result = context.partition_result.as_ref().expect("Guaranteed to have a value by earlier checks.");
739 ::std::result::Result::Ok(
740 ::aws_smithy_types::endpoint::Endpoint::builder()
741 .url({
742 let mut out = String::new();
743 out.push_str("https://runtime.lex-fips.");
744 #[allow(clippy::needless_borrow)]
745 out.push_str(®ion.as_ref());
746 out.push_str(".");
747 #[allow(clippy::needless_borrow)]
748 out.push_str(&partition_result.dual_stack_dns_suffix());
749 out
750 })
751 .build(),
752 )
753 }
754 5 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
755 "FIPS and DualStack are enabled, but this partition does not support one or both".to_string(),
756 )) as ::aws_smithy_runtime_api::box_error::BoxError),
757 6 => {
758 let region = params.region.as_deref().unwrap_or_default();
759 ::std::result::Result::Ok(
760 ::aws_smithy_types::endpoint::Endpoint::builder()
761 .url({
762 let mut out = String::new();
763 out.push_str("https://runtime-fips.lex.");
764 #[allow(clippy::needless_borrow)]
765 out.push_str(®ion.as_ref());
766 out.push_str(".amazonaws.com");
767 out
768 })
769 .build(),
770 )
771 }
772 7 => {
773 let region = params.region.as_deref().unwrap_or_default();
774 let partition_result = context.partition_result.as_ref().expect("Guaranteed to have a value by earlier checks.");
775 ::std::result::Result::Ok(
776 ::aws_smithy_types::endpoint::Endpoint::builder()
777 .url({
778 let mut out = String::new();
779 out.push_str("https://runtime.lex-fips.");
780 #[allow(clippy::needless_borrow)]
781 out.push_str(®ion.as_ref());
782 out.push_str(".");
783 #[allow(clippy::needless_borrow)]
784 out.push_str(&partition_result.dns_suffix());
785 out
786 })
787 .build(),
788 )
789 }
790 8 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
791 "FIPS is enabled but this partition does not support FIPS".to_string(),
792 )) as ::aws_smithy_runtime_api::box_error::BoxError),
793 9 => {
794 let region = params.region.as_deref().unwrap_or_default();
795 let partition_result = context.partition_result.as_ref().expect("Guaranteed to have a value by earlier checks.");
796 ::std::result::Result::Ok(
797 ::aws_smithy_types::endpoint::Endpoint::builder()
798 .url({
799 let mut out = String::new();
800 out.push_str("https://runtime.lex.");
801 #[allow(clippy::needless_borrow)]
802 out.push_str(®ion.as_ref());
803 out.push_str(".");
804 #[allow(clippy::needless_borrow)]
805 out.push_str(&partition_result.dual_stack_dns_suffix());
806 out
807 })
808 .build(),
809 )
810 }
811 10 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
812 "DualStack is enabled but this partition does not support DualStack".to_string(),
813 )) as ::aws_smithy_runtime_api::box_error::BoxError),
814 11 => {
815 let region = params.region.as_deref().unwrap_or_default();
816 ::std::result::Result::Ok(
817 ::aws_smithy_types::endpoint::Endpoint::builder()
818 .url({
819 let mut out = String::new();
820 out.push_str("https://runtime.lex.");
821 #[allow(clippy::needless_borrow)]
822 out.push_str(®ion.as_ref());
823 out.push_str(".amazonaws.com");
824 out
825 })
826 .build(),
827 )
828 }
829 12 => {
830 let region = params.region.as_deref().unwrap_or_default();
831 let partition_result = context.partition_result.as_ref().expect("Guaranteed to have a value by earlier checks.");
832 ::std::result::Result::Ok(
833 ::aws_smithy_types::endpoint::Endpoint::builder()
834 .url({
835 let mut out = String::new();
836 out.push_str("https://runtime.lex.");
837 #[allow(clippy::needless_borrow)]
838 out.push_str(®ion.as_ref());
839 out.push_str(".");
840 #[allow(clippy::needless_borrow)]
841 out.push_str(&partition_result.dns_suffix());
842 out
843 })
844 .build(),
845 )
846 }
847 13 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
848 "Invalid Configuration: Missing Region".to_string(),
849 )) as ::aws_smithy_runtime_api::box_error::BoxError),
850 _ => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
851 "No endpoint rule matched",
852 )) as ::aws_smithy_runtime_api::box_error::BoxError),
853 };
854 }
855 1 | -1 => {
856 return ::std::result::Result::Err(
857 Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message("No endpoint rule matched"))
858 as ::aws_smithy_runtime_api::box_error::BoxError,
859 )
860 }
861 ref_val => {
862 let is_complement = ref_val < 0;
863 let node = &NODES[(ref_val.unsigned_abs() as usize) - 1];
864 let condition_result = match node.condition_index {
865 0 => endpoint.is_some(),
866 1 => region.is_some(),
867 2 => (|_diagnostic_collector: &mut crate::endpoint_lib::diagnostic::DiagnosticCollector| -> bool {
868 let partition_result = &mut context.partition_result;
869 let partition_resolver = &self.partition_resolver;
870 {
871 *partition_result = partition_resolver
872 .resolve_partition(if let Some(param) = region { param } else { return false }, _diagnostic_collector)
873 .map(|inner| inner.into());
874 partition_result.is_some()
875 }
876 })(&mut _diagnostic_collector),
877 3 => (use_fips) == (&true),
878 4 => (use_dual_stack) == (&true),
879 5 => (|_diagnostic_collector: &mut crate::endpoint_lib::diagnostic::DiagnosticCollector| -> bool {
880 let partition_result = &context.partition_result;
881 let partition_resolver = &self.partition_resolver;
882 (if let Some(inner) = partition_result {
883 inner.supports_dual_stack()
884 } else {
885 return false;
886 }) == (true)
887 })(&mut _diagnostic_collector),
888 6 => (|_diagnostic_collector: &mut crate::endpoint_lib::diagnostic::DiagnosticCollector| -> bool {
889 let partition_result = &context.partition_result;
890 let partition_resolver = &self.partition_resolver;
891 (if let Some(inner) = partition_result {
892 inner.supports_fips()
893 } else {
894 return false;
895 }) == (true)
896 })(&mut _diagnostic_collector),
897 7 => (|_diagnostic_collector: &mut crate::endpoint_lib::diagnostic::DiagnosticCollector| -> bool {
898 let partition_result = &context.partition_result;
899 let partition_resolver = &self.partition_resolver;
900 (if let Some(inner) = partition_result {
901 inner.name()
902 } else {
903 return false;
904 }) == ("aws")
905 })(&mut _diagnostic_collector),
906 8 => (|_diagnostic_collector: &mut crate::endpoint_lib::diagnostic::DiagnosticCollector| -> bool {
907 let partition_result = &context.partition_result;
908 let partition_resolver = &self.partition_resolver;
909 (if let Some(inner) = partition_result {
910 inner.name()
911 } else {
912 return false;
913 }) == ("aws-us-gov")
914 })(&mut _diagnostic_collector),
915 _ => unreachable!("Invalid condition index"),
916 };
917 current_ref = if is_complement ^ condition_result { node.high_ref } else { node.low_ref };
918 }
919 }
920 }
921 }
922}
923
924impl crate::config::endpoint::ResolveEndpoint for DefaultResolver {
925 fn resolve_endpoint<'a>(&'a self, params: &'a crate::config::endpoint::Params) -> ::aws_smithy_runtime_api::client::endpoint::EndpointFuture<'a> {
926 let cached = self.endpoint_cache.load();
928 if let Some((cached_params, cached_endpoint)) = cached.as_ref() {
929 if cached_params == params {
930 return ::aws_smithy_runtime_api::client::endpoint::EndpointFuture::ready(::std::result::Result::Ok(cached_endpoint.clone()));
931 }
932 }
933 drop(cached);
934 let result = self.resolve_endpoint(params);
935 if let ::std::result::Result::Ok(ref endpoint) = result {
936 self.endpoint_cache.store(::std::sync::Arc::new(Some((params.clone(), endpoint.clone()))));
937 }
938 ::aws_smithy_runtime_api::client::endpoint::EndpointFuture::ready(result)
939 }
940}
941const NODES: [crate::endpoint_lib::bdd_interpreter::BddNode; 17] = [
942 crate::endpoint_lib::bdd_interpreter::BddNode {
943 condition_index: -1,
944 high_ref: 1,
945 low_ref: -1,
946 },
947 crate::endpoint_lib::bdd_interpreter::BddNode {
948 condition_index: 0,
949 high_ref: 16,
950 low_ref: 3,
951 },
952 crate::endpoint_lib::bdd_interpreter::BddNode {
953 condition_index: 1,
954 high_ref: 4,
955 low_ref: 100000013,
956 },
957 crate::endpoint_lib::bdd_interpreter::BddNode {
958 condition_index: 2,
959 high_ref: 5,
960 low_ref: 100000013,
961 },
962 crate::endpoint_lib::bdd_interpreter::BddNode {
963 condition_index: 3,
964 high_ref: 10,
965 low_ref: 6,
966 },
967 crate::endpoint_lib::bdd_interpreter::BddNode {
968 condition_index: 4,
969 high_ref: 9,
970 low_ref: 7,
971 },
972 crate::endpoint_lib::bdd_interpreter::BddNode {
973 condition_index: 7,
974 high_ref: 100000011,
975 low_ref: 8,
976 },
977 crate::endpoint_lib::bdd_interpreter::BddNode {
978 condition_index: 8,
979 high_ref: 100000011,
980 low_ref: 100000012,
981 },
982 crate::endpoint_lib::bdd_interpreter::BddNode {
983 condition_index: 5,
984 high_ref: 100000009,
985 low_ref: 100000010,
986 },
987 crate::endpoint_lib::bdd_interpreter::BddNode {
988 condition_index: 4,
989 high_ref: 14,
990 low_ref: 11,
991 },
992 crate::endpoint_lib::bdd_interpreter::BddNode {
993 condition_index: 6,
994 high_ref: 12,
995 low_ref: 100000008,
996 },
997 crate::endpoint_lib::bdd_interpreter::BddNode {
998 condition_index: 7,
999 high_ref: 100000006,
1000 low_ref: 13,
1001 },
1002 crate::endpoint_lib::bdd_interpreter::BddNode {
1003 condition_index: 8,
1004 high_ref: 100000006,
1005 low_ref: 100000007,
1006 },
1007 crate::endpoint_lib::bdd_interpreter::BddNode {
1008 condition_index: 5,
1009 high_ref: 15,
1010 low_ref: 100000005,
1011 },
1012 crate::endpoint_lib::bdd_interpreter::BddNode {
1013 condition_index: 6,
1014 high_ref: 100000004,
1015 low_ref: 100000005,
1016 },
1017 crate::endpoint_lib::bdd_interpreter::BddNode {
1018 condition_index: 3,
1019 high_ref: 100000001,
1020 low_ref: 17,
1021 },
1022 crate::endpoint_lib::bdd_interpreter::BddNode {
1023 condition_index: 4,
1024 high_ref: 100000002,
1025 low_ref: 100000003,
1026 },
1027];
1028#[derive(Default)]
1031#[allow(unused_lifetimes)]
1032pub(crate) struct ConditionContext<'a> {
1033 pub(crate) partition_result: Option<crate::endpoint_lib::partition::Partition<'a>>,
1034 phantom: std::marker::PhantomData<&'a ()>,
1036}
1037
1038#[non_exhaustive]
1039#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
1040pub struct Params {
1042 pub(crate) region: ::std::option::Option<::std::string::String>,
1044 pub(crate) use_dual_stack: bool,
1046 pub(crate) use_fips: bool,
1048 pub(crate) endpoint: ::std::option::Option<::std::string::String>,
1050}
1051impl Params {
1052 pub fn builder() -> crate::config::endpoint::ParamsBuilder {
1054 crate::config::endpoint::ParamsBuilder::default()
1055 }
1056 pub fn region(&self) -> ::std::option::Option<&str> {
1058 self.region.as_deref()
1059 }
1060 pub fn use_dual_stack(&self) -> ::std::option::Option<bool> {
1062 Some(self.use_dual_stack)
1063 }
1064 pub fn use_fips(&self) -> ::std::option::Option<bool> {
1066 Some(self.use_fips)
1067 }
1068 pub fn endpoint(&self) -> ::std::option::Option<&str> {
1070 self.endpoint.as_deref()
1071 }
1072}
1073
1074#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
1076pub struct ParamsBuilder {
1077 region: ::std::option::Option<::std::string::String>,
1078 use_dual_stack: ::std::option::Option<bool>,
1079 use_fips: ::std::option::Option<bool>,
1080 endpoint: ::std::option::Option<::std::string::String>,
1081}
1082impl ParamsBuilder {
1083 pub fn build(self) -> ::std::result::Result<crate::config::endpoint::Params, crate::config::endpoint::InvalidParams> {
1085 if let Some(region) = &self.region {
1086 if !crate::endpoint_lib::host::is_valid_host_label(
1087 region.as_ref() as &str,
1088 true,
1089 &mut crate::endpoint_lib::diagnostic::DiagnosticCollector::new(),
1090 ) {
1091 return Err(crate::config::endpoint::InvalidParams::invalid_value(
1092 "region",
1093 "must be a valid host label",
1094 ));
1095 }
1096 };
1097 Ok(
1098 #[allow(clippy::unnecessary_lazy_evaluations)]
1099 crate::config::endpoint::Params {
1100 region: self.region,
1101 use_dual_stack: self
1102 .use_dual_stack
1103 .or_else(|| Some(false))
1104 .ok_or_else(|| crate::config::endpoint::InvalidParams::missing("use_dual_stack"))?,
1105 use_fips: self
1106 .use_fips
1107 .or_else(|| Some(false))
1108 .ok_or_else(|| crate::config::endpoint::InvalidParams::missing("use_fips"))?,
1109 endpoint: self.endpoint,
1110 },
1111 )
1112 }
1113 pub fn region(mut self, value: impl Into<::std::string::String>) -> Self {
1117 self.region = Some(value.into());
1118 self
1119 }
1120
1121 pub fn set_region(mut self, param: Option<::std::string::String>) -> Self {
1125 self.region = param;
1126 self
1127 }
1128 pub fn use_dual_stack(mut self, value: impl Into<bool>) -> Self {
1133 self.use_dual_stack = Some(value.into());
1134 self
1135 }
1136
1137 pub fn set_use_dual_stack(mut self, param: Option<bool>) -> Self {
1142 self.use_dual_stack = param;
1143 self
1144 }
1145 pub fn use_fips(mut self, value: impl Into<bool>) -> Self {
1150 self.use_fips = Some(value.into());
1151 self
1152 }
1153
1154 pub fn set_use_fips(mut self, param: Option<bool>) -> Self {
1159 self.use_fips = param;
1160 self
1161 }
1162 pub fn endpoint(mut self, value: impl Into<::std::string::String>) -> Self {
1166 self.endpoint = Some(value.into());
1167 self
1168 }
1169
1170 pub fn set_endpoint(mut self, param: Option<::std::string::String>) -> Self {
1174 self.endpoint = param;
1175 self
1176 }
1177}
1178
1179#[derive(Debug)]
1181pub struct InvalidParams {
1182 field: std::borrow::Cow<'static, str>,
1183 kind: InvalidParamsErrorKind,
1184}
1185
1186#[derive(Debug)]
1188enum InvalidParamsErrorKind {
1189 MissingField,
1190 InvalidValue { message: &'static str },
1191}
1192
1193impl InvalidParams {
1194 #[allow(dead_code)]
1195 fn missing(field: &'static str) -> Self {
1196 Self {
1197 field: field.into(),
1198 kind: InvalidParamsErrorKind::MissingField,
1199 }
1200 }
1201
1202 #[allow(dead_code)]
1203 fn invalid_value(field: &'static str, message: &'static str) -> Self {
1204 Self {
1205 field: field.into(),
1206 kind: InvalidParamsErrorKind::InvalidValue { message },
1207 }
1208 }
1209}
1210
1211impl std::fmt::Display for InvalidParams {
1212 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
1213 match self.kind {
1214 InvalidParamsErrorKind::MissingField => write!(f, "a required field was missing: `{}`", self.field),
1215 InvalidParamsErrorKind::InvalidValue { message } => write!(f, "invalid value for field: `{}` - {}", self.field, message),
1216 }
1217 }
1218}
1219
1220impl std::error::Error for InvalidParams {}