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://workdocs.ap-northeast-1.amazonaws.com");
44 assert_eq!(
45 endpoint,
46 ::aws_smithy_types::endpoint::Endpoint::builder()
47 .url("https://workdocs.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://workdocs.ap-southeast-1.amazonaws.com");
64 assert_eq!(
65 endpoint,
66 ::aws_smithy_types::endpoint::Endpoint::builder()
67 .url("https://workdocs.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://workdocs.ap-southeast-2.amazonaws.com");
84 assert_eq!(
85 endpoint,
86 ::aws_smithy_types::endpoint::Endpoint::builder()
87 .url("https://workdocs.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-west-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://workdocs.eu-west-1.amazonaws.com");
104 assert_eq!(
105 endpoint,
106 ::aws_smithy_types::endpoint::Endpoint::builder()
107 .url("https://workdocs.eu-west-1.amazonaws.com")
108 .build()
109 );
110 }
111
112 #[test]
114 fn test_5() {
115 let params = crate::config::endpoint::Params::builder()
116 .region("us-east-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://workdocs.us-east-1.amazonaws.com");
124 assert_eq!(
125 endpoint,
126 ::aws_smithy_types::endpoint::Endpoint::builder()
127 .url("https://workdocs.us-east-1.amazonaws.com")
128 .build()
129 );
130 }
131
132 #[test]
134 fn test_6() {
135 let params = crate::config::endpoint::Params::builder()
136 .region("us-east-1".to_string())
137 .use_fips(true)
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://workdocs-fips.us-east-1.amazonaws.com");
144 assert_eq!(
145 endpoint,
146 ::aws_smithy_types::endpoint::Endpoint::builder()
147 .url("https://workdocs-fips.us-east-1.amazonaws.com")
148 .build()
149 );
150 }
151
152 #[test]
154 fn test_7() {
155 let params = crate::config::endpoint::Params::builder()
156 .region("us-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://workdocs.us-west-2.amazonaws.com");
164 assert_eq!(
165 endpoint,
166 ::aws_smithy_types::endpoint::Endpoint::builder()
167 .url("https://workdocs.us-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-west-2".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://workdocs-fips.us-west-2.amazonaws.com");
184 assert_eq!(
185 endpoint,
186 ::aws_smithy_types::endpoint::Endpoint::builder()
187 .url("https://workdocs-fips.us-west-2.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-1".to_string())
197 .use_fips(true)
198 .use_dual_stack(true)
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://workdocs-fips.us-east-1.api.aws");
204 assert_eq!(
205 endpoint,
206 ::aws_smithy_types::endpoint::Endpoint::builder()
207 .url("https://workdocs-fips.us-east-1.api.aws")
208 .build()
209 );
210 }
211
212 #[test]
214 fn test_10() {
215 let params = crate::config::endpoint::Params::builder()
216 .region("us-east-1".to_string())
217 .use_fips(false)
218 .use_dual_stack(true)
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://workdocs.us-east-1.api.aws");
224 assert_eq!(
225 endpoint,
226 ::aws_smithy_types::endpoint::Endpoint::builder()
227 .url("https://workdocs.us-east-1.api.aws")
228 .build()
229 );
230 }
231
232 #[test]
234 fn test_11() {
235 let params = crate::config::endpoint::Params::builder()
236 .region("cn-north-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://workdocs-fips.cn-north-1.api.amazonwebservices.com.cn");
244 assert_eq!(
245 endpoint,
246 ::aws_smithy_types::endpoint::Endpoint::builder()
247 .url("https://workdocs-fips.cn-north-1.api.amazonwebservices.com.cn")
248 .build()
249 );
250 }
251
252 #[test]
254 fn test_12() {
255 let params = crate::config::endpoint::Params::builder()
256 .region("cn-north-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://workdocs-fips.cn-north-1.amazonaws.com.cn");
264 assert_eq!(
265 endpoint,
266 ::aws_smithy_types::endpoint::Endpoint::builder()
267 .url("https://workdocs-fips.cn-north-1.amazonaws.com.cn")
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(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://workdocs.cn-north-1.api.amazonwebservices.com.cn");
284 assert_eq!(
285 endpoint,
286 ::aws_smithy_types::endpoint::Endpoint::builder()
287 .url("https://workdocs.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(false)
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://workdocs.cn-north-1.amazonaws.com.cn");
304 assert_eq!(
305 endpoint,
306 ::aws_smithy_types::endpoint::Endpoint::builder()
307 .url("https://workdocs.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("us-gov-east-1".to_string())
317 .use_fips(true)
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://workdocs-fips.us-gov-east-1.api.aws");
324 assert_eq!(
325 endpoint,
326 ::aws_smithy_types::endpoint::Endpoint::builder()
327 .url("https://workdocs-fips.us-gov-east-1.api.aws")
328 .build()
329 );
330 }
331
332 #[test]
334 fn test_16() {
335 let params = crate::config::endpoint::Params::builder()
336 .region("us-gov-east-1".to_string())
337 .use_fips(true)
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://workdocs-fips.us-gov-east-1.amazonaws.com");
344 assert_eq!(
345 endpoint,
346 ::aws_smithy_types::endpoint::Endpoint::builder()
347 .url("https://workdocs-fips.us-gov-east-1.amazonaws.com")
348 .build()
349 );
350 }
351
352 #[test]
354 fn test_17() {
355 let params = crate::config::endpoint::Params::builder()
356 .region("us-gov-east-1".to_string())
357 .use_fips(false)
358 .use_dual_stack(true)
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://workdocs.us-gov-east-1.api.aws");
364 assert_eq!(
365 endpoint,
366 ::aws_smithy_types::endpoint::Endpoint::builder()
367 .url("https://workdocs.us-gov-east-1.api.aws")
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(false)
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://workdocs.us-gov-east-1.amazonaws.com");
384 assert_eq!(
385 endpoint,
386 ::aws_smithy_types::endpoint::Endpoint::builder()
387 .url("https://workdocs.us-gov-east-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-iso-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://workdocs-fips.us-iso-east-1.c2s.ic.gov");
404 assert_eq!(
405 endpoint,
406 ::aws_smithy_types::endpoint::Endpoint::builder()
407 .url("https://workdocs-fips.us-iso-east-1.c2s.ic.gov")
408 .build()
409 );
410 }
411
412 #[test]
414 fn test_20() {
415 let params = crate::config::endpoint::Params::builder()
416 .region("us-iso-east-1".to_string())
417 .use_fips(false)
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://workdocs.us-iso-east-1.c2s.ic.gov");
424 assert_eq!(
425 endpoint,
426 ::aws_smithy_types::endpoint::Endpoint::builder()
427 .url("https://workdocs.us-iso-east-1.c2s.ic.gov")
428 .build()
429 );
430 }
431
432 #[test]
434 fn test_21() {
435 let params = crate::config::endpoint::Params::builder()
436 .region("us-isob-east-1".to_string())
437 .use_fips(true)
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://workdocs-fips.us-isob-east-1.sc2s.sgov.gov");
444 assert_eq!(
445 endpoint,
446 ::aws_smithy_types::endpoint::Endpoint::builder()
447 .url("https://workdocs-fips.us-isob-east-1.sc2s.sgov.gov")
448 .build()
449 );
450 }
451
452 #[test]
454 fn test_22() {
455 let params = crate::config::endpoint::Params::builder()
456 .region("us-isob-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://workdocs.us-isob-east-1.sc2s.sgov.gov");
464 assert_eq!(
465 endpoint,
466 ::aws_smithy_types::endpoint::Endpoint::builder()
467 .url("https://workdocs.us-isob-east-1.sc2s.sgov.gov")
468 .build()
469 );
470 }
471
472 #[test]
474 fn test_23() {
475 let params = crate::config::endpoint::Params::builder()
476 .region("us-east-1".to_string())
477 .use_fips(false)
478 .use_dual_stack(false)
479 .endpoint("https://example.com".to_string())
480 .build()
481 .expect("invalid params");
482 let resolver = crate::config::endpoint::DefaultResolver::new();
483 let endpoint = resolver.resolve_endpoint(¶ms);
484 let endpoint = endpoint.expect("Expected valid endpoint: https://example.com");
485 assert_eq!(
486 endpoint,
487 ::aws_smithy_types::endpoint::Endpoint::builder().url("https://example.com").build()
488 );
489 }
490
491 #[test]
493 fn test_24() {
494 let params = crate::config::endpoint::Params::builder()
495 .use_fips(false)
496 .use_dual_stack(false)
497 .endpoint("https://example.com".to_string())
498 .build()
499 .expect("invalid params");
500 let resolver = crate::config::endpoint::DefaultResolver::new();
501 let endpoint = resolver.resolve_endpoint(¶ms);
502 let endpoint = endpoint.expect("Expected valid endpoint: https://example.com");
503 assert_eq!(
504 endpoint,
505 ::aws_smithy_types::endpoint::Endpoint::builder().url("https://example.com").build()
506 );
507 }
508
509 #[test]
511 fn test_25() {
512 let params = crate::config::endpoint::Params::builder()
513 .region("us-east-1".to_string())
514 .use_fips(true)
515 .use_dual_stack(false)
516 .endpoint("https://example.com".to_string())
517 .build()
518 .expect("invalid params");
519 let resolver = crate::config::endpoint::DefaultResolver::new();
520 let endpoint = resolver.resolve_endpoint(¶ms);
521 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]");
522 assert_eq!(format!("{}", error), "Invalid Configuration: FIPS and custom endpoint are not supported")
523 }
524
525 #[test]
527 fn test_26() {
528 let params = crate::config::endpoint::Params::builder()
529 .region("us-east-1".to_string())
530 .use_fips(false)
531 .use_dual_stack(true)
532 .endpoint("https://example.com".to_string())
533 .build()
534 .expect("invalid params");
535 let resolver = crate::config::endpoint::DefaultResolver::new();
536 let endpoint = resolver.resolve_endpoint(¶ms);
537 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]");
538 assert_eq!(
539 format!("{}", error),
540 "Invalid Configuration: Dualstack and custom endpoint are not supported"
541 )
542 }
543
544 #[test]
546 fn test_27() {
547 let params = crate::config::endpoint::Params::builder().build().expect("invalid params");
548 let resolver = crate::config::endpoint::DefaultResolver::new();
549 let endpoint = resolver.resolve_endpoint(¶ms);
550 let error = endpoint.expect_err("expected error: Invalid Configuration: Missing Region [Missing region]");
551 assert_eq!(format!("{}", error), "Invalid Configuration: Missing Region")
552 }
553}
554
555pub trait ResolveEndpoint: ::std::marker::Send + ::std::marker::Sync + ::std::fmt::Debug {
557 fn resolve_endpoint<'a>(&'a self, params: &'a crate::config::endpoint::Params) -> ::aws_smithy_runtime_api::client::endpoint::EndpointFuture<'a>;
559
560 fn into_shared_resolver(self) -> ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver
564 where
565 Self: Sized + 'static,
566 {
567 ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver::new(DowncastParams(self))
568 }
569}
570
571#[derive(Debug)]
572struct DowncastParams<T>(T);
573impl<T> ::aws_smithy_runtime_api::client::endpoint::ResolveEndpoint for DowncastParams<T>
574where
575 T: ResolveEndpoint,
576{
577 fn resolve_endpoint<'a>(
578 &'a self,
579 params: &'a ::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams,
580 ) -> ::aws_smithy_runtime_api::client::endpoint::EndpointFuture<'a> {
581 let ep = match params.get::<crate::config::endpoint::Params>() {
582 Some(params) => self.0.resolve_endpoint(params),
583 None => ::aws_smithy_runtime_api::client::endpoint::EndpointFuture::ready(Err("params of expected type was not present".into())),
584 };
585 ep
586 }
587}
588
589#[derive(Debug)]
590pub struct DefaultResolver {
592 partition_resolver: &'static crate::endpoint_lib::partition::PartitionResolver,
593 endpoint_cache: ::arc_swap::ArcSwap<::std::option::Option<(Params, ::aws_smithy_types::endpoint::Endpoint)>>,
594}
595
596impl Default for DefaultResolver {
597 fn default() -> Self {
598 Self::new()
599 }
600}
601
602impl DefaultResolver {
603 pub fn new() -> Self {
605 Self {
606 partition_resolver: &crate::endpoint_lib::DEFAULT_PARTITION_RESOLVER,
607 endpoint_cache: ::arc_swap::ArcSwap::from_pointee(None),
608 }
609 }
610
611 #[allow(
612 unused_variables,
613 unused_parens,
614 clippy::double_parens,
615 clippy::useless_conversion,
616 clippy::bool_comparison,
617 clippy::comparison_to_empty,
618 clippy::needless_borrow,
619 clippy::useless_asref,
620 clippy::redundant_closure_call,
621 clippy::clone_on_copy
622 )]
623 fn resolve_endpoint<'a>(
624 &'a self,
625 params: &'a crate::config::endpoint::Params,
626 ) -> ::std::result::Result<::aws_smithy_types::endpoint::Endpoint, ::aws_smithy_runtime_api::box_error::BoxError> {
627 let mut _diagnostic_collector = crate::endpoint_lib::diagnostic::DiagnosticCollector::new();
628 #[allow(unused_mut)]
629 let mut context = ConditionContext::default();
630
631 let region = ¶ms.region;
633 let use_dual_stack = ¶ms.use_dual_stack;
634 let use_fips = ¶ms.use_fips;
635 let endpoint = ¶ms.endpoint;
636
637 let mut current_ref: i32 = 2;
638 loop {
639 match current_ref {
640 ref_val if ref_val >= 100_000_000 => {
641 return match (ref_val - 100_000_000) as usize {
642 0 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
643 "No endpoint rule matched",
644 )) as ::aws_smithy_runtime_api::box_error::BoxError),
645 1 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
646 "Invalid Configuration: FIPS and custom endpoint are not supported".to_string(),
647 )) as ::aws_smithy_runtime_api::box_error::BoxError),
648 2 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
649 "Invalid Configuration: Dualstack and custom endpoint are not supported".to_string(),
650 )) as ::aws_smithy_runtime_api::box_error::BoxError),
651 3 => {
652 let endpoint = params.endpoint.as_deref().unwrap_or_default();
653 ::std::result::Result::Ok(::aws_smithy_types::endpoint::Endpoint::builder().url(endpoint.to_owned()).build())
654 }
655 4 => {
656 let region = params.region.as_deref().unwrap_or_default();
657 let partition_result = context.partition_result.as_ref().expect("Guaranteed to have a value by earlier checks.");
658 ::std::result::Result::Ok(
659 ::aws_smithy_types::endpoint::Endpoint::builder()
660 .url({
661 let mut out = String::new();
662 out.push_str("https://workdocs-fips.");
663 #[allow(clippy::needless_borrow)]
664 out.push_str(®ion.as_ref());
665 out.push('.');
666 #[allow(clippy::needless_borrow)]
667 out.push_str(&partition_result.dual_stack_dns_suffix());
668 out
669 })
670 .build(),
671 )
672 }
673 5 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
674 "FIPS and DualStack are enabled, but this partition does not support one or both".to_string(),
675 )) as ::aws_smithy_runtime_api::box_error::BoxError),
676 6 => {
677 let region = params.region.as_deref().unwrap_or_default();
678 let partition_result = context.partition_result.as_ref().expect("Guaranteed to have a value by earlier checks.");
679 ::std::result::Result::Ok(
680 ::aws_smithy_types::endpoint::Endpoint::builder()
681 .url({
682 let mut out = String::new();
683 out.push_str("https://workdocs-fips.");
684 #[allow(clippy::needless_borrow)]
685 out.push_str(®ion.as_ref());
686 out.push('.');
687 #[allow(clippy::needless_borrow)]
688 out.push_str(&partition_result.dns_suffix());
689 out
690 })
691 .build(),
692 )
693 }
694 7 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
695 "FIPS is enabled but this partition does not support FIPS".to_string(),
696 )) as ::aws_smithy_runtime_api::box_error::BoxError),
697 8 => {
698 let region = params.region.as_deref().unwrap_or_default();
699 let partition_result = context.partition_result.as_ref().expect("Guaranteed to have a value by earlier checks.");
700 ::std::result::Result::Ok(
701 ::aws_smithy_types::endpoint::Endpoint::builder()
702 .url({
703 let mut out = String::new();
704 out.push_str("https://workdocs.");
705 #[allow(clippy::needless_borrow)]
706 out.push_str(®ion.as_ref());
707 out.push('.');
708 #[allow(clippy::needless_borrow)]
709 out.push_str(&partition_result.dual_stack_dns_suffix());
710 out
711 })
712 .build(),
713 )
714 }
715 9 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
716 "DualStack is enabled but this partition does not support DualStack".to_string(),
717 )) as ::aws_smithy_runtime_api::box_error::BoxError),
718 10 => {
719 let region = params.region.as_deref().unwrap_or_default();
720 let partition_result = context.partition_result.as_ref().expect("Guaranteed to have a value by earlier checks.");
721 ::std::result::Result::Ok(
722 ::aws_smithy_types::endpoint::Endpoint::builder()
723 .url({
724 let mut out = String::new();
725 out.push_str("https://workdocs.");
726 #[allow(clippy::needless_borrow)]
727 out.push_str(®ion.as_ref());
728 out.push('.');
729 #[allow(clippy::needless_borrow)]
730 out.push_str(&partition_result.dns_suffix());
731 out
732 })
733 .build(),
734 )
735 }
736 11 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
737 "Invalid Configuration: Missing Region".to_string(),
738 )) as ::aws_smithy_runtime_api::box_error::BoxError),
739 _ => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
740 "No endpoint rule matched",
741 )) as ::aws_smithy_runtime_api::box_error::BoxError),
742 };
743 }
744 1 | -1 => {
745 return ::std::result::Result::Err(
746 Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message("No endpoint rule matched"))
747 as ::aws_smithy_runtime_api::box_error::BoxError,
748 )
749 }
750 ref_val => {
751 let is_complement = ref_val < 0;
752 let node = &NODES[(ref_val.unsigned_abs() as usize) - 1];
753 let condition_result = match node.condition_index {
754 0 => endpoint.is_some(),
755 1 => region.is_some(),
756 2 => (|_diagnostic_collector: &mut crate::endpoint_lib::diagnostic::DiagnosticCollector| -> bool {
757 let partition_result = &mut context.partition_result;
758 let partition_resolver = &self.partition_resolver;
759 {
760 *partition_result = partition_resolver
761 .resolve_partition(if let Some(param) = region { param } else { return false }, _diagnostic_collector)
762 .map(|inner| inner.into());
763 partition_result.is_some()
764 }
765 })(&mut _diagnostic_collector),
766 3 => (use_fips) == (&true),
767 4 => (use_dual_stack) == (&true),
768 5 => (|_diagnostic_collector: &mut crate::endpoint_lib::diagnostic::DiagnosticCollector| -> bool {
769 let partition_result = &context.partition_result;
770 let partition_resolver = &self.partition_resolver;
771 (if let Some(inner) = partition_result {
772 inner.supports_dual_stack()
773 } else {
774 return false;
775 }) == (true)
776 })(&mut _diagnostic_collector),
777 6 => (|_diagnostic_collector: &mut crate::endpoint_lib::diagnostic::DiagnosticCollector| -> bool {
778 let partition_result = &context.partition_result;
779 let partition_resolver = &self.partition_resolver;
780 (if let Some(inner) = partition_result {
781 inner.supports_fips()
782 } else {
783 return false;
784 }) == (true)
785 })(&mut _diagnostic_collector),
786 _ => unreachable!("Invalid condition index"),
787 };
788 current_ref = if is_complement ^ condition_result { node.high_ref } else { node.low_ref };
789 }
790 }
791 }
792 }
793}
794
795impl crate::config::endpoint::ResolveEndpoint for DefaultResolver {
796 fn resolve_endpoint<'a>(&'a self, params: &'a crate::config::endpoint::Params) -> ::aws_smithy_runtime_api::client::endpoint::EndpointFuture<'a> {
797 let cached = self.endpoint_cache.load();
799 if let Some((cached_params, cached_endpoint)) = cached.as_ref() {
800 if cached_params == params {
801 return ::aws_smithy_runtime_api::client::endpoint::EndpointFuture::ready(::std::result::Result::Ok(cached_endpoint.clone()));
802 }
803 }
804 drop(cached);
805 let result = self.resolve_endpoint(params);
806 if let ::std::result::Result::Ok(ref endpoint) = result {
807 self.endpoint_cache.store(::std::sync::Arc::new(Some((params.clone(), endpoint.clone()))));
808 }
809 ::aws_smithy_runtime_api::client::endpoint::EndpointFuture::ready(result)
810 }
811}
812const NODES: [crate::endpoint_lib::bdd_interpreter::BddNode; 13] = [
813 crate::endpoint_lib::bdd_interpreter::BddNode {
814 condition_index: -1,
815 high_ref: 1,
816 low_ref: -1,
817 },
818 crate::endpoint_lib::bdd_interpreter::BddNode {
819 condition_index: 0,
820 high_ref: 12,
821 low_ref: 3,
822 },
823 crate::endpoint_lib::bdd_interpreter::BddNode {
824 condition_index: 1,
825 high_ref: 4,
826 low_ref: 100000011,
827 },
828 crate::endpoint_lib::bdd_interpreter::BddNode {
829 condition_index: 2,
830 high_ref: 5,
831 low_ref: 100000011,
832 },
833 crate::endpoint_lib::bdd_interpreter::BddNode {
834 condition_index: 3,
835 high_ref: 8,
836 low_ref: 6,
837 },
838 crate::endpoint_lib::bdd_interpreter::BddNode {
839 condition_index: 4,
840 high_ref: 7,
841 low_ref: 100000010,
842 },
843 crate::endpoint_lib::bdd_interpreter::BddNode {
844 condition_index: 5,
845 high_ref: 100000008,
846 low_ref: 100000009,
847 },
848 crate::endpoint_lib::bdd_interpreter::BddNode {
849 condition_index: 4,
850 high_ref: 10,
851 low_ref: 9,
852 },
853 crate::endpoint_lib::bdd_interpreter::BddNode {
854 condition_index: 6,
855 high_ref: 100000006,
856 low_ref: 100000007,
857 },
858 crate::endpoint_lib::bdd_interpreter::BddNode {
859 condition_index: 5,
860 high_ref: 11,
861 low_ref: 100000005,
862 },
863 crate::endpoint_lib::bdd_interpreter::BddNode {
864 condition_index: 6,
865 high_ref: 100000004,
866 low_ref: 100000005,
867 },
868 crate::endpoint_lib::bdd_interpreter::BddNode {
869 condition_index: 3,
870 high_ref: 100000001,
871 low_ref: 13,
872 },
873 crate::endpoint_lib::bdd_interpreter::BddNode {
874 condition_index: 4,
875 high_ref: 100000002,
876 low_ref: 100000003,
877 },
878];
879#[derive(Default)]
882#[allow(unused_lifetimes)]
883pub(crate) struct ConditionContext<'a> {
884 pub(crate) partition_result: Option<crate::endpoint_lib::partition::Partition<'a>>,
885 phantom: std::marker::PhantomData<&'a ()>,
887}
888
889#[non_exhaustive]
890#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
891pub struct Params {
893 pub(crate) region: ::std::option::Option<::std::string::String>,
895 pub(crate) use_dual_stack: bool,
897 pub(crate) use_fips: bool,
899 pub(crate) endpoint: ::std::option::Option<::std::string::String>,
901}
902impl Params {
903 pub fn builder() -> crate::config::endpoint::ParamsBuilder {
905 crate::config::endpoint::ParamsBuilder::default()
906 }
907 pub fn region(&self) -> ::std::option::Option<&str> {
909 self.region.as_deref()
910 }
911 pub fn use_dual_stack(&self) -> ::std::option::Option<bool> {
913 Some(self.use_dual_stack)
914 }
915 pub fn use_fips(&self) -> ::std::option::Option<bool> {
917 Some(self.use_fips)
918 }
919 pub fn endpoint(&self) -> ::std::option::Option<&str> {
921 self.endpoint.as_deref()
922 }
923}
924
925#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
927pub struct ParamsBuilder {
928 region: ::std::option::Option<::std::string::String>,
929 use_dual_stack: ::std::option::Option<bool>,
930 use_fips: ::std::option::Option<bool>,
931 endpoint: ::std::option::Option<::std::string::String>,
932}
933impl ParamsBuilder {
934 pub fn build(self) -> ::std::result::Result<crate::config::endpoint::Params, crate::config::endpoint::InvalidParams> {
936 if let Some(region) = &self.region {
937 if !crate::endpoint_lib::host::is_valid_host_label(
938 region.as_ref() as &str,
939 true,
940 &mut crate::endpoint_lib::diagnostic::DiagnosticCollector::new(),
941 ) {
942 return Err(crate::config::endpoint::InvalidParams::invalid_value(
943 "region",
944 "must be a valid host label",
945 ));
946 }
947 };
948 Ok(
949 #[allow(clippy::unnecessary_lazy_evaluations)]
950 crate::config::endpoint::Params {
951 region: self.region,
952 use_dual_stack: self
953 .use_dual_stack
954 .or_else(|| Some(false))
955 .ok_or_else(|| crate::config::endpoint::InvalidParams::missing("use_dual_stack"))?,
956 use_fips: self
957 .use_fips
958 .or_else(|| Some(false))
959 .ok_or_else(|| crate::config::endpoint::InvalidParams::missing("use_fips"))?,
960 endpoint: self.endpoint,
961 },
962 )
963 }
964 pub fn region(mut self, value: impl Into<::std::string::String>) -> Self {
968 self.region = Some(value.into());
969 self
970 }
971
972 pub fn set_region(mut self, param: Option<::std::string::String>) -> Self {
976 self.region = param;
977 self
978 }
979 pub fn use_dual_stack(mut self, value: impl Into<bool>) -> Self {
984 self.use_dual_stack = Some(value.into());
985 self
986 }
987
988 pub fn set_use_dual_stack(mut self, param: Option<bool>) -> Self {
993 self.use_dual_stack = param;
994 self
995 }
996 pub fn use_fips(mut self, value: impl Into<bool>) -> Self {
1001 self.use_fips = Some(value.into());
1002 self
1003 }
1004
1005 pub fn set_use_fips(mut self, param: Option<bool>) -> Self {
1010 self.use_fips = param;
1011 self
1012 }
1013 pub fn endpoint(mut self, value: impl Into<::std::string::String>) -> Self {
1017 self.endpoint = Some(value.into());
1018 self
1019 }
1020
1021 pub fn set_endpoint(mut self, param: Option<::std::string::String>) -> Self {
1025 self.endpoint = param;
1026 self
1027 }
1028}
1029
1030#[derive(Debug)]
1032pub struct InvalidParams {
1033 field: std::borrow::Cow<'static, str>,
1034 kind: InvalidParamsErrorKind,
1035}
1036
1037#[derive(Debug)]
1039enum InvalidParamsErrorKind {
1040 MissingField,
1041 InvalidValue { message: &'static str },
1042}
1043
1044impl InvalidParams {
1045 #[allow(dead_code)]
1046 fn missing(field: &'static str) -> Self {
1047 Self {
1048 field: field.into(),
1049 kind: InvalidParamsErrorKind::MissingField,
1050 }
1051 }
1052
1053 #[allow(dead_code)]
1054 fn invalid_value(field: &'static str, message: &'static str) -> Self {
1055 Self {
1056 field: field.into(),
1057 kind: InvalidParamsErrorKind::InvalidValue { message },
1058 }
1059 }
1060}
1061
1062impl std::fmt::Display for InvalidParams {
1063 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
1064 match self.kind {
1065 InvalidParamsErrorKind::MissingField => write!(f, "a required field was missing: `{}`", self.field),
1066 InvalidParamsErrorKind::InvalidValue { message } => write!(f, "invalid value for field: `{}` - {}", self.field, message),
1067 }
1068 }
1069}
1070
1071impl std::error::Error for InvalidParams {}