chore(codegen,config-resolver): refactor how endpoint is resolved for non-AWS client

codegen/smithy-aws-typescript-codegen/src/main/java/software/amazon/smithy/aws/typescript/codegen/AddBuiltinPlugins.java

@@ -47,8 +47,14 @@ public List<RuntimeClientPlugin> getClientPlugins() {
                         .withConventions(TypeScriptDependency.CONFIG_RESOLVER.dependency, "Region", HAS_CONFIG)
                         .servicePredicate((m, s) -> isAwsService(s))
                         .build(),
+                // Only one of Endpoints or CustomEndpoints should be used
                 RuntimeClientPlugin.builder()
                         .withConventions(TypeScriptDependency.CONFIG_RESOLVER.dependency, "Endpoints", HAS_CONFIG)
+                        .servicePredicate((m, s) -> isAwsService(s))
+                        .build(),
+                RuntimeClientPlugin.builder()
+                        .withConventions(TypeScriptDependency.CONFIG_RESOLVER.dependency, "CustomEndpoints", HAS_CONFIG)
+                        .servicePredicate((m, s) -> !isAwsService(s))
                         .build(),
                 RuntimeClientPlugin.builder()
                         .withConventions(TypeScriptDependency.MIDDLEWARE_RETRY.dependency, "Retry")

packages/config-resolver/src/CustomEndpointsConfig.ts

@@ -0,0 +1,45 @@
+// TODO: Create a .spec.ts for this
+import { Endpoint, Provider, UrlParser } from "@aws-sdk/types";
+
+export interface CustomEndpointsInputConfig {
+  /**
+   * The fully qualified endpoint of the webservice.
+   */
+  endpoint: string | Endpoint | Provider<Endpoint>;
+
+  /**
+   * Whether TLS is enabled for requests.
+   */
+  tls?: boolean;
+}
+
+interface PreviouslyResolved {
+  urlParser: UrlParser;
+}
+
+export interface CustomEndpointsResolvedConfig extends Required<CustomEndpointsInputConfig> {
+  endpoint: Provider<Endpoint>;
+  isCustomEndpoint: true; // TODO: Can this be removed or some other logic depends on this?
+}
+
+export const resolveCustomEndpointsConfig = <T>(
+  input: T & CustomEndpointsInputConfig & PreviouslyResolved
+): T & CustomEndpointsResolvedConfig => ({
+  ...input,
+  tls: input.tls ?? true,
+  endpoint: normalizeEndpoint(input),
+  isCustomEndpoint: true,
+});
+
+// TODO: can this be shared with EndpointsConfig.ts
+const normalizeEndpoint = (input: CustomEndpointsInputConfig & PreviouslyResolved): Provider<Endpoint> => {
+  const { endpoint, urlParser } = input;
+  if (typeof endpoint === "string") {
+    const promisified = Promise.resolve(urlParser(endpoint));
+    return () => promisified;
+  } else if (typeof endpoint === "object") {
+    const promisified = Promise.resolve(endpoint);
+    return () => promisified;
+  }
+  return endpoint;
+};

packages/config-resolver/src/EndpointsConfig.ts

@@ -13,9 +13,9 @@ export interface EndpointsInputConfig {
 }
 
 interface PreviouslyResolved {
-  regionInfoProvider?: RegionInfoProvider;
+  regionInfoProvider: RegionInfoProvider;
   urlParser: UrlParser;
-  region?: Provider<string>;
+  region: Provider<string>;
 }
 
 export interface EndpointsResolvedConfig extends Required<EndpointsInputConfig> {
@@ -45,10 +45,6 @@ const normalizeEndpoint = (input: EndpointsInputConfig & PreviouslyResolved): Pr
 };
 
 const getEndPointFromRegion = async (input: EndpointsInputConfig & PreviouslyResolved) => {
-  if (input.region === undefined || input.regionInfoProvider === undefined) {
-    throw new Error("No endpoint specified and region is not defined");
-  }
-
   const { tls = true } = input;
   const region = await input.region();
 

packages/config-resolver/src/index.ts

@@ -1,2 +1,3 @@
+export * from "./CustomEndpointsConfig";
 export * from "./EndpointsConfig";
 export * from "./RegionConfig";