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("eu-west-1".to_string())
37 .use_fips(false)
38 .use_dual_stack(false)
39 .build_without_validators()
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://workspaces-web.eu-west-1.amazonaws.com");
44 assert_eq!(
45 endpoint,
46 ::aws_smithy_types::endpoint::Endpoint::builder()
47 .url("https://workspaces-web.eu-west-1.amazonaws.com")
48 .build()
49 );
50 }
51
52 #[test]
54 fn test_2() {
55 let params = crate::config::endpoint::Params::builder()
56 .region("us-east-1".to_string())
57 .use_fips(false)
58 .use_dual_stack(false)
59 .build_without_validators()
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://workspaces-web.us-east-1.amazonaws.com");
64 assert_eq!(
65 endpoint,
66 ::aws_smithy_types::endpoint::Endpoint::builder()
67 .url("https://workspaces-web.us-east-1.amazonaws.com")
68 .build()
69 );
70 }
71
72 #[test]
74 fn test_3() {
75 let params = crate::config::endpoint::Params::builder()
76 .region("us-west-2".to_string())
77 .use_fips(false)
78 .use_dual_stack(false)
79 .build_without_validators()
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://workspaces-web.us-west-2.amazonaws.com");
84 assert_eq!(
85 endpoint,
86 ::aws_smithy_types::endpoint::Endpoint::builder()
87 .url("https://workspaces-web.us-west-2.amazonaws.com")
88 .build()
89 );
90 }
91
92 #[test]
94 fn test_4() {
95 let params = crate::config::endpoint::Params::builder()
96 .region("us-east-1".to_string())
97 .use_fips(true)
98 .use_dual_stack(true)
99 .build_without_validators()
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://workspaces-web-fips.us-east-1.api.aws");
104 assert_eq!(
105 endpoint,
106 ::aws_smithy_types::endpoint::Endpoint::builder()
107 .url("https://workspaces-web-fips.us-east-1.api.aws")
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(true)
118 .use_dual_stack(false)
119 .build_without_validators()
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://workspaces-web-fips.us-east-1.amazonaws.com");
124 assert_eq!(
125 endpoint,
126 ::aws_smithy_types::endpoint::Endpoint::builder()
127 .url("https://workspaces-web-fips.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(false)
138 .use_dual_stack(true)
139 .build_without_validators()
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://workspaces-web.us-east-1.api.aws");
144 assert_eq!(
145 endpoint,
146 ::aws_smithy_types::endpoint::Endpoint::builder()
147 .url("https://workspaces-web.us-east-1.api.aws")
148 .build()
149 );
150 }
151
152 #[test]
154 fn test_7() {
155 let params = crate::config::endpoint::Params::builder()
156 .region("cn-north-1".to_string())
157 .use_fips(true)
158 .use_dual_stack(true)
159 .build_without_validators()
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://workspaces-web-fips.cn-north-1.api.amazonwebservices.com.cn");
164 assert_eq!(
165 endpoint,
166 ::aws_smithy_types::endpoint::Endpoint::builder()
167 .url("https://workspaces-web-fips.cn-north-1.api.amazonwebservices.com.cn")
168 .build()
169 );
170 }
171
172 #[test]
174 fn test_8() {
175 let params = crate::config::endpoint::Params::builder()
176 .region("cn-north-1".to_string())
177 .use_fips(true)
178 .use_dual_stack(false)
179 .build_without_validators()
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://workspaces-web-fips.cn-north-1.amazonaws.com.cn");
184 assert_eq!(
185 endpoint,
186 ::aws_smithy_types::endpoint::Endpoint::builder()
187 .url("https://workspaces-web-fips.cn-north-1.amazonaws.com.cn")
188 .build()
189 );
190 }
191
192 #[test]
194 fn test_9() {
195 let params = crate::config::endpoint::Params::builder()
196 .region("cn-north-1".to_string())
197 .use_fips(false)
198 .use_dual_stack(true)
199 .build_without_validators()
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://workspaces-web.cn-north-1.api.amazonwebservices.com.cn");
204 assert_eq!(
205 endpoint,
206 ::aws_smithy_types::endpoint::Endpoint::builder()
207 .url("https://workspaces-web.cn-north-1.api.amazonwebservices.com.cn")
208 .build()
209 );
210 }
211
212 #[test]
214 fn test_10() {
215 let params = crate::config::endpoint::Params::builder()
216 .region("cn-north-1".to_string())
217 .use_fips(false)
218 .use_dual_stack(false)
219 .build_without_validators()
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://workspaces-web.cn-north-1.amazonaws.com.cn");
224 assert_eq!(
225 endpoint,
226 ::aws_smithy_types::endpoint::Endpoint::builder()
227 .url("https://workspaces-web.cn-north-1.amazonaws.com.cn")
228 .build()
229 );
230 }
231
232 #[test]
234 fn test_11() {
235 let params = crate::config::endpoint::Params::builder()
236 .region("us-gov-east-1".to_string())
237 .use_fips(true)
238 .use_dual_stack(true)
239 .build_without_validators()
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://workspaces-web-fips.us-gov-east-1.api.aws");
244 assert_eq!(
245 endpoint,
246 ::aws_smithy_types::endpoint::Endpoint::builder()
247 .url("https://workspaces-web-fips.us-gov-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-gov-east-1".to_string())
257 .use_fips(true)
258 .use_dual_stack(false)
259 .build_without_validators()
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://workspaces-web-fips.us-gov-east-1.amazonaws.com");
264 assert_eq!(
265 endpoint,
266 ::aws_smithy_types::endpoint::Endpoint::builder()
267 .url("https://workspaces-web-fips.us-gov-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-gov-east-1".to_string())
277 .use_fips(false)
278 .use_dual_stack(true)
279 .build_without_validators()
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://workspaces-web.us-gov-east-1.api.aws");
284 assert_eq!(
285 endpoint,
286 ::aws_smithy_types::endpoint::Endpoint::builder()
287 .url("https://workspaces-web.us-gov-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("us-gov-east-1".to_string())
297 .use_fips(false)
298 .use_dual_stack(false)
299 .build_without_validators()
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://workspaces-web.us-gov-east-1.amazonaws.com");
304 assert_eq!(
305 endpoint,
306 ::aws_smithy_types::endpoint::Endpoint::builder()
307 .url("https://workspaces-web.us-gov-east-1.amazonaws.com")
308 .build()
309 );
310 }
311
312 #[test]
314 fn test_15() {
315 let params = crate::config::endpoint::Params::builder()
316 .region("us-iso-east-1".to_string())
317 .use_fips(true)
318 .use_dual_stack(false)
319 .build_without_validators()
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://workspaces-web-fips.us-iso-east-1.c2s.ic.gov");
324 assert_eq!(
325 endpoint,
326 ::aws_smithy_types::endpoint::Endpoint::builder()
327 .url("https://workspaces-web-fips.us-iso-east-1.c2s.ic.gov")
328 .build()
329 );
330 }
331
332 #[test]
334 fn test_16() {
335 let params = crate::config::endpoint::Params::builder()
336 .region("us-iso-east-1".to_string())
337 .use_fips(false)
338 .use_dual_stack(false)
339 .build_without_validators()
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://workspaces-web.us-iso-east-1.c2s.ic.gov");
344 assert_eq!(
345 endpoint,
346 ::aws_smithy_types::endpoint::Endpoint::builder()
347 .url("https://workspaces-web.us-iso-east-1.c2s.ic.gov")
348 .build()
349 );
350 }
351
352 #[test]
354 fn test_17() {
355 let params = crate::config::endpoint::Params::builder()
356 .region("us-isob-east-1".to_string())
357 .use_fips(true)
358 .use_dual_stack(false)
359 .build_without_validators()
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://workspaces-web-fips.us-isob-east-1.sc2s.sgov.gov");
364 assert_eq!(
365 endpoint,
366 ::aws_smithy_types::endpoint::Endpoint::builder()
367 .url("https://workspaces-web-fips.us-isob-east-1.sc2s.sgov.gov")
368 .build()
369 );
370 }
371
372 #[test]
374 fn test_18() {
375 let params = crate::config::endpoint::Params::builder()
376 .region("us-isob-east-1".to_string())
377 .use_fips(false)
378 .use_dual_stack(false)
379 .build_without_validators()
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://workspaces-web.us-isob-east-1.sc2s.sgov.gov");
384 assert_eq!(
385 endpoint,
386 ::aws_smithy_types::endpoint::Endpoint::builder()
387 .url("https://workspaces-web.us-isob-east-1.sc2s.sgov.gov")
388 .build()
389 );
390 }
391
392 #[test]
394 fn test_19() {
395 let params = crate::config::endpoint::Params::builder()
396 .region("us-east-1".to_string())
397 .use_fips(false)
398 .use_dual_stack(false)
399 .endpoint("https://example.com".to_string())
400 .build_without_validators()
401 .expect("invalid params");
402 let resolver = crate::config::endpoint::DefaultResolver::new();
403 let endpoint = resolver.resolve_endpoint(¶ms);
404 let endpoint = endpoint.expect("Expected valid endpoint: https://example.com");
405 assert_eq!(
406 endpoint,
407 ::aws_smithy_types::endpoint::Endpoint::builder().url("https://example.com").build()
408 );
409 }
410
411 #[test]
413 fn test_20() {
414 let params = crate::config::endpoint::Params::builder()
415 .use_fips(false)
416 .use_dual_stack(false)
417 .endpoint("https://example.com".to_string())
418 .build_without_validators()
419 .expect("invalid params");
420 let resolver = crate::config::endpoint::DefaultResolver::new();
421 let endpoint = resolver.resolve_endpoint(¶ms);
422 let endpoint = endpoint.expect("Expected valid endpoint: https://example.com");
423 assert_eq!(
424 endpoint,
425 ::aws_smithy_types::endpoint::Endpoint::builder().url("https://example.com").build()
426 );
427 }
428
429 #[test]
431 fn test_21() {
432 let params = crate::config::endpoint::Params::builder()
433 .region("us-east-1".to_string())
434 .use_fips(true)
435 .use_dual_stack(false)
436 .endpoint("https://example.com".to_string())
437 .build_without_validators()
438 .expect("invalid params");
439 let resolver = crate::config::endpoint::DefaultResolver::new();
440 let endpoint = resolver.resolve_endpoint(¶ms);
441 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]");
442 assert_eq!(format!("{}", error), "Invalid Configuration: FIPS and custom endpoint are not supported")
443 }
444
445 #[test]
447 fn test_22() {
448 let params = crate::config::endpoint::Params::builder()
449 .region("us-east-1".to_string())
450 .use_fips(false)
451 .use_dual_stack(true)
452 .endpoint("https://example.com".to_string())
453 .build_without_validators()
454 .expect("invalid params");
455 let resolver = crate::config::endpoint::DefaultResolver::new();
456 let endpoint = resolver.resolve_endpoint(¶ms);
457 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]");
458 assert_eq!(
459 format!("{}", error),
460 "Invalid Configuration: Dualstack and custom endpoint are not supported"
461 )
462 }
463
464 #[test]
466 fn test_23() {
467 let params = crate::config::endpoint::Params::builder()
468 .build_without_validators()
469 .expect("invalid params");
470 let resolver = crate::config::endpoint::DefaultResolver::new();
471 let endpoint = resolver.resolve_endpoint(¶ms);
472 let error = endpoint.expect_err("expected error: Invalid Configuration: Missing Region [Missing region]");
473 assert_eq!(format!("{}", error), "Invalid Configuration: Missing Region")
474 }
475}
476
477pub trait ResolveEndpoint: ::std::marker::Send + ::std::marker::Sync + ::std::fmt::Debug {
479 fn resolve_endpoint<'a>(&'a self, params: &'a crate::config::endpoint::Params) -> ::aws_smithy_runtime_api::client::endpoint::EndpointFuture<'a>;
481
482 fn into_shared_resolver(self) -> ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver
486 where
487 Self: Sized + 'static,
488 {
489 ::aws_smithy_runtime_api::client::endpoint::SharedEndpointResolver::new(DowncastParams(self))
490 }
491}
492
493#[derive(Debug)]
494struct DowncastParams<T>(T);
495impl<T> ::aws_smithy_runtime_api::client::endpoint::ResolveEndpoint for DowncastParams<T>
496where
497 T: ResolveEndpoint,
498{
499 fn resolve_endpoint<'a>(
500 &'a self,
501 params: &'a ::aws_smithy_runtime_api::client::endpoint::EndpointResolverParams,
502 ) -> ::aws_smithy_runtime_api::client::endpoint::EndpointFuture<'a> {
503 let ep = match params.get::<crate::config::endpoint::Params>() {
504 Some(params) => self.0.resolve_endpoint(params),
505 None => ::aws_smithy_runtime_api::client::endpoint::EndpointFuture::ready(Err("params of expected type was not present".into())),
506 };
507 ep
508 }
509}
510
511#[derive(Debug)]
512pub struct DefaultResolver {
514 partition_resolver: &'static crate::endpoint_lib::partition::PartitionResolver,
515 endpoint_cache: ::arc_swap::ArcSwap<::std::option::Option<(Params, ::aws_smithy_types::endpoint::Endpoint)>>,
516}
517
518impl Default for DefaultResolver {
519 fn default() -> Self {
520 Self::new()
521 }
522}
523
524impl DefaultResolver {
525 pub fn new() -> Self {
527 Self {
528 partition_resolver: &crate::endpoint_lib::DEFAULT_PARTITION_RESOLVER,
529 endpoint_cache: ::arc_swap::ArcSwap::from_pointee(None),
530 }
531 }
532
533 #[allow(
534 unused_variables,
535 unused_parens,
536 clippy::double_parens,
537 clippy::useless_conversion,
538 clippy::bool_comparison,
539 clippy::comparison_to_empty,
540 clippy::needless_borrow,
541 clippy::useless_asref,
542 clippy::redundant_closure_call,
543 clippy::clone_on_copy,
544 clippy::single_char_add_str
545 )]
546 fn resolve_endpoint<'a>(
547 &'a self,
548 params: &'a crate::config::endpoint::Params,
549 ) -> ::std::result::Result<::aws_smithy_types::endpoint::Endpoint, ::aws_smithy_runtime_api::box_error::BoxError> {
550 let mut _diagnostic_collector = crate::endpoint_lib::diagnostic::DiagnosticCollector::new();
551 #[allow(unused_mut)]
552 let mut context = ConditionContext::default();
553
554 let region = ¶ms.region;
556 let use_dual_stack = ¶ms.use_dual_stack;
557 let use_fips = ¶ms.use_fips;
558 let endpoint = ¶ms.endpoint;
559
560 let mut current_ref: i32 = 2;
561 loop {
562 match current_ref {
563 ref_val if ref_val >= 100_000_000 => {
564 return match (ref_val - 100_000_000) as usize {
565 0 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
566 "No endpoint rule matched",
567 )) as ::aws_smithy_runtime_api::box_error::BoxError),
568 1 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
569 "Invalid Configuration: FIPS and custom endpoint are not supported".to_string(),
570 )) as ::aws_smithy_runtime_api::box_error::BoxError),
571 2 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
572 "Invalid Configuration: Dualstack and custom endpoint are not supported".to_string(),
573 )) as ::aws_smithy_runtime_api::box_error::BoxError),
574 3 => {
575 let endpoint = params.endpoint.as_deref().unwrap_or_default();
576 ::std::result::Result::Ok(::aws_smithy_types::endpoint::Endpoint::builder().url(endpoint.to_owned()).build())
577 }
578 4 => {
579 let region = params.region.as_deref().unwrap_or_default();
580 let partition_result = context.partition_result.as_ref().expect("Guaranteed to have a value by earlier checks.");
581 ::std::result::Result::Ok(
582 ::aws_smithy_types::endpoint::Endpoint::builder()
583 .url({
584 let mut out = String::new();
585 out.push_str("https://workspaces-web-fips.");
586 #[allow(clippy::needless_borrow)]
587 out.push_str(®ion.as_ref());
588 out.push_str(".");
589 #[allow(clippy::needless_borrow)]
590 out.push_str(&partition_result.dual_stack_dns_suffix());
591 out
592 })
593 .build(),
594 )
595 }
596 5 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
597 "FIPS and DualStack are enabled, but this partition does not support one or both".to_string(),
598 )) as ::aws_smithy_runtime_api::box_error::BoxError),
599 6 => {
600 let region = params.region.as_deref().unwrap_or_default();
601 let partition_result = context.partition_result.as_ref().expect("Guaranteed to have a value by earlier checks.");
602 ::std::result::Result::Ok(
603 ::aws_smithy_types::endpoint::Endpoint::builder()
604 .url({
605 let mut out = String::new();
606 out.push_str("https://workspaces-web-fips.");
607 #[allow(clippy::needless_borrow)]
608 out.push_str(®ion.as_ref());
609 out.push_str(".");
610 #[allow(clippy::needless_borrow)]
611 out.push_str(&partition_result.dns_suffix());
612 out
613 })
614 .build(),
615 )
616 }
617 7 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
618 "FIPS is enabled but this partition does not support FIPS".to_string(),
619 )) as ::aws_smithy_runtime_api::box_error::BoxError),
620 8 => {
621 let region = params.region.as_deref().unwrap_or_default();
622 let partition_result = context.partition_result.as_ref().expect("Guaranteed to have a value by earlier checks.");
623 ::std::result::Result::Ok(
624 ::aws_smithy_types::endpoint::Endpoint::builder()
625 .url({
626 let mut out = String::new();
627 out.push_str("https://workspaces-web.");
628 #[allow(clippy::needless_borrow)]
629 out.push_str(®ion.as_ref());
630 out.push_str(".");
631 #[allow(clippy::needless_borrow)]
632 out.push_str(&partition_result.dual_stack_dns_suffix());
633 out
634 })
635 .build(),
636 )
637 }
638 9 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
639 "DualStack is enabled but this partition does not support DualStack".to_string(),
640 )) as ::aws_smithy_runtime_api::box_error::BoxError),
641 10 => {
642 let region = params.region.as_deref().unwrap_or_default();
643 let partition_result = context.partition_result.as_ref().expect("Guaranteed to have a value by earlier checks.");
644 ::std::result::Result::Ok(
645 ::aws_smithy_types::endpoint::Endpoint::builder()
646 .url({
647 let mut out = String::new();
648 out.push_str("https://workspaces-web.");
649 #[allow(clippy::needless_borrow)]
650 out.push_str(®ion.as_ref());
651 out.push_str(".");
652 #[allow(clippy::needless_borrow)]
653 out.push_str(&partition_result.dns_suffix());
654 out
655 })
656 .build(),
657 )
658 }
659 11 => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
660 "Invalid Configuration: Missing Region".to_string(),
661 )) as ::aws_smithy_runtime_api::box_error::BoxError),
662 _ => ::std::result::Result::Err(Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message(
663 "No endpoint rule matched",
664 )) as ::aws_smithy_runtime_api::box_error::BoxError),
665 };
666 }
667 1 | -1 => {
668 return ::std::result::Result::Err(
669 Box::new(::aws_smithy_http::endpoint::ResolveEndpointError::message("No endpoint rule matched"))
670 as ::aws_smithy_runtime_api::box_error::BoxError,
671 )
672 }
673 ref_val => {
674 let is_complement = ref_val < 0;
675 let node = &NODES[(ref_val.unsigned_abs() as usize) - 1];
676 let condition_result = match node.condition_index {
677 0 => endpoint.is_some(),
678 1 => region.is_some(),
679 2 => (|_diagnostic_collector: &mut crate::endpoint_lib::diagnostic::DiagnosticCollector| -> bool {
680 let partition_result = &mut context.partition_result;
681 let partition_resolver = &self.partition_resolver;
682 {
683 *partition_result = partition_resolver
684 .resolve_partition(if let Some(param) = region { param } else { return false }, _diagnostic_collector)
685 .map(|inner| inner.into());
686 partition_result.is_some()
687 }
688 })(&mut _diagnostic_collector),
689 3 => (use_fips) == (&true),
690 4 => (use_dual_stack) == (&true),
691 5 => (|_diagnostic_collector: &mut crate::endpoint_lib::diagnostic::DiagnosticCollector| -> bool {
692 let partition_result = &context.partition_result;
693 let partition_resolver = &self.partition_resolver;
694 (if let Some(inner) = partition_result {
695 inner.supports_dual_stack()
696 } else {
697 return false;
698 }) == (true)
699 })(&mut _diagnostic_collector),
700 6 => (|_diagnostic_collector: &mut crate::endpoint_lib::diagnostic::DiagnosticCollector| -> bool {
701 let partition_result = &context.partition_result;
702 let partition_resolver = &self.partition_resolver;
703 (if let Some(inner) = partition_result {
704 inner.supports_fips()
705 } else {
706 return false;
707 }) == (true)
708 })(&mut _diagnostic_collector),
709 _ => unreachable!("Invalid condition index"),
710 };
711 current_ref = if is_complement ^ condition_result { node.high_ref } else { node.low_ref };
712 }
713 }
714 }
715 }
716}
717
718impl crate::config::endpoint::ResolveEndpoint for DefaultResolver {
719 fn resolve_endpoint<'a>(&'a self, params: &'a crate::config::endpoint::Params) -> ::aws_smithy_runtime_api::client::endpoint::EndpointFuture<'a> {
720 let cached = self.endpoint_cache.load();
722 if let Some((cached_params, cached_endpoint)) = cached.as_ref() {
723 if cached_params == params {
724 return ::aws_smithy_runtime_api::client::endpoint::EndpointFuture::ready(::std::result::Result::Ok(cached_endpoint.clone()));
725 }
726 }
727 drop(cached);
728 let result = self.resolve_endpoint(params);
729 if let ::std::result::Result::Ok(ref endpoint) = result {
730 self.endpoint_cache.store(::std::sync::Arc::new(Some((params.clone(), endpoint.clone()))));
731 }
732 ::aws_smithy_runtime_api::client::endpoint::EndpointFuture::ready(result)
733 }
734}
735const NODES: [crate::endpoint_lib::bdd_interpreter::BddNode; 13] = [
736 crate::endpoint_lib::bdd_interpreter::BddNode {
737 condition_index: -1,
738 high_ref: 1,
739 low_ref: -1,
740 },
741 crate::endpoint_lib::bdd_interpreter::BddNode {
742 condition_index: 0,
743 high_ref: 12,
744 low_ref: 3,
745 },
746 crate::endpoint_lib::bdd_interpreter::BddNode {
747 condition_index: 1,
748 high_ref: 4,
749 low_ref: 100000011,
750 },
751 crate::endpoint_lib::bdd_interpreter::BddNode {
752 condition_index: 2,
753 high_ref: 5,
754 low_ref: 100000011,
755 },
756 crate::endpoint_lib::bdd_interpreter::BddNode {
757 condition_index: 3,
758 high_ref: 8,
759 low_ref: 6,
760 },
761 crate::endpoint_lib::bdd_interpreter::BddNode {
762 condition_index: 4,
763 high_ref: 7,
764 low_ref: 100000010,
765 },
766 crate::endpoint_lib::bdd_interpreter::BddNode {
767 condition_index: 5,
768 high_ref: 100000008,
769 low_ref: 100000009,
770 },
771 crate::endpoint_lib::bdd_interpreter::BddNode {
772 condition_index: 4,
773 high_ref: 10,
774 low_ref: 9,
775 },
776 crate::endpoint_lib::bdd_interpreter::BddNode {
777 condition_index: 6,
778 high_ref: 100000006,
779 low_ref: 100000007,
780 },
781 crate::endpoint_lib::bdd_interpreter::BddNode {
782 condition_index: 5,
783 high_ref: 11,
784 low_ref: 100000005,
785 },
786 crate::endpoint_lib::bdd_interpreter::BddNode {
787 condition_index: 6,
788 high_ref: 100000004,
789 low_ref: 100000005,
790 },
791 crate::endpoint_lib::bdd_interpreter::BddNode {
792 condition_index: 3,
793 high_ref: 100000001,
794 low_ref: 13,
795 },
796 crate::endpoint_lib::bdd_interpreter::BddNode {
797 condition_index: 4,
798 high_ref: 100000002,
799 low_ref: 100000003,
800 },
801];
802#[derive(Default)]
805#[allow(unused_lifetimes)]
806pub(crate) struct ConditionContext<'a> {
807 pub(crate) partition_result: Option<crate::endpoint_lib::partition::Partition<'a>>,
808 phantom: std::marker::PhantomData<&'a ()>,
810}
811
812#[non_exhaustive]
813#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::fmt::Debug)]
814pub struct Params {
816 pub(crate) region: ::std::option::Option<::std::string::String>,
818 pub(crate) use_dual_stack: bool,
820 pub(crate) use_fips: bool,
822 pub(crate) endpoint: ::std::option::Option<::std::string::String>,
824}
825impl Params {
826 pub fn builder() -> crate::config::endpoint::ParamsBuilder {
828 crate::config::endpoint::ParamsBuilder::default()
829 }
830 pub fn region(&self) -> ::std::option::Option<&str> {
832 self.region.as_deref()
833 }
834 pub fn use_dual_stack(&self) -> ::std::option::Option<bool> {
836 Some(self.use_dual_stack)
837 }
838 pub fn use_fips(&self) -> ::std::option::Option<bool> {
840 Some(self.use_fips)
841 }
842 pub fn endpoint(&self) -> ::std::option::Option<&str> {
844 self.endpoint.as_deref()
845 }
846}
847
848#[derive(::std::clone::Clone, ::std::cmp::PartialEq, ::std::default::Default, ::std::fmt::Debug)]
850pub struct ParamsBuilder {
851 region: ::std::option::Option<::std::string::String>,
852 use_dual_stack: ::std::option::Option<bool>,
853 use_fips: ::std::option::Option<bool>,
854 endpoint: ::std::option::Option<::std::string::String>,
855}
856impl ParamsBuilder {
857 pub fn build(self) -> ::std::result::Result<crate::config::endpoint::Params, crate::config::endpoint::InvalidParams> {
859 if let Some(region) = &self.region {
860 if !crate::endpoint_lib::host::is_valid_host_label(
861 region.as_ref() as &str,
862 true,
863 &mut crate::endpoint_lib::diagnostic::DiagnosticCollector::new(),
864 ) {
865 return Err(crate::config::endpoint::InvalidParams::invalid_value(
866 "region",
867 "must be a valid host label",
868 ));
869 }
870 };
871 self.build_without_validators()
872 }
873 fn build_without_validators(self) -> ::std::result::Result<crate::config::endpoint::Params, crate::config::endpoint::InvalidParams> {
877 Ok(
878 #[allow(clippy::unnecessary_lazy_evaluations)]
879 crate::config::endpoint::Params {
880 region: self.region,
881 use_dual_stack: self
882 .use_dual_stack
883 .or_else(|| Some(false))
884 .ok_or_else(|| crate::config::endpoint::InvalidParams::missing("use_dual_stack"))?,
885 use_fips: self
886 .use_fips
887 .or_else(|| Some(false))
888 .ok_or_else(|| crate::config::endpoint::InvalidParams::missing("use_fips"))?,
889 endpoint: self.endpoint,
890 },
891 )
892 }
893 pub fn region(mut self, value: impl Into<::std::string::String>) -> Self {
897 self.region = Some(value.into());
898 self
899 }
900
901 pub fn set_region(mut self, param: Option<::std::string::String>) -> Self {
905 self.region = param;
906 self
907 }
908 pub fn use_dual_stack(mut self, value: impl Into<bool>) -> Self {
913 self.use_dual_stack = Some(value.into());
914 self
915 }
916
917 pub fn set_use_dual_stack(mut self, param: Option<bool>) -> Self {
922 self.use_dual_stack = param;
923 self
924 }
925 pub fn use_fips(mut self, value: impl Into<bool>) -> Self {
930 self.use_fips = Some(value.into());
931 self
932 }
933
934 pub fn set_use_fips(mut self, param: Option<bool>) -> Self {
939 self.use_fips = param;
940 self
941 }
942 pub fn endpoint(mut self, value: impl Into<::std::string::String>) -> Self {
946 self.endpoint = Some(value.into());
947 self
948 }
949
950 pub fn set_endpoint(mut self, param: Option<::std::string::String>) -> Self {
954 self.endpoint = param;
955 self
956 }
957}
958
959#[derive(Debug)]
961pub struct InvalidParams {
962 field: std::borrow::Cow<'static, str>,
963 kind: InvalidParamsErrorKind,
964}
965
966#[derive(Debug)]
968enum InvalidParamsErrorKind {
969 MissingField,
970 InvalidValue { message: &'static str },
971}
972
973impl InvalidParams {
974 #[allow(dead_code)]
975 fn missing(field: &'static str) -> Self {
976 Self {
977 field: field.into(),
978 kind: InvalidParamsErrorKind::MissingField,
979 }
980 }
981
982 #[allow(dead_code)]
983 fn invalid_value(field: &'static str, message: &'static str) -> Self {
984 Self {
985 field: field.into(),
986 kind: InvalidParamsErrorKind::InvalidValue { message },
987 }
988 }
989}
990
991impl std::fmt::Display for InvalidParams {
992 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
993 match self.kind {
994 InvalidParamsErrorKind::MissingField => write!(f, "a required field was missing: `{}`", self.field),
995 InvalidParamsErrorKind::InvalidValue { message } => write!(f, "invalid value for field: `{}` - {}", self.field, message),
996 }
997 }
998}
999
1000impl std::error::Error for InvalidParams {}