File Explorer

/var/runtime/node_modules/@aws-sdk/client-osis/dist-cjs

This explorer reads the filesystem of the server it runs on, so /workspace/user isn't present here. Browsing and the terminal still work against this server's own disk from /.

2 dirs
3 files
index.js69.1 KB · 1693 lines
"use strict";var __defProp = Object.defineProperty;var __getOwnPropDesc = Object.getOwnPropertyDescriptor;var __getOwnPropNames = Object.getOwnPropertyNames;var __hasOwnProp = Object.prototype.hasOwnProperty;var __name = (target, value) => __defProp(target, "name", { value, configurable: true });var __export = (target, all) => {  for (var name in all)    __defProp(target, name, { get: all[name], enumerable: true });};var __copyProps = (to, from, except, desc) => {  if (from && typeof from === "object" || typeof from === "function") {    for (let key of __getOwnPropNames(from))      if (!__hasOwnProp.call(to, key) && key !== except)        __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable });  }  return to;};var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod); // src/index.tsvar index_exports = {};__export(index_exports, {  AccessDeniedException: () => AccessDeniedException,  ChangeProgressStageStatuses: () => ChangeProgressStageStatuses,  ChangeProgressStatuses: () => ChangeProgressStatuses,  ConflictException: () => ConflictException,  CreatePipelineCommand: () => CreatePipelineCommand,  CreatePipelineEndpointCommand: () => CreatePipelineEndpointCommand,  DeletePipelineCommand: () => DeletePipelineCommand,  DeletePipelineEndpointCommand: () => DeletePipelineEndpointCommand,  DeleteResourcePolicyCommand: () => DeleteResourcePolicyCommand,  DisabledOperationException: () => DisabledOperationException,  GetPipelineBlueprintCommand: () => GetPipelineBlueprintCommand,  GetPipelineChangeProgressCommand: () => GetPipelineChangeProgressCommand,  GetPipelineCommand: () => GetPipelineCommand,  GetResourcePolicyCommand: () => GetResourcePolicyCommand,  InternalException: () => InternalException,  InvalidPaginationTokenException: () => InvalidPaginationTokenException,  LimitExceededException: () => LimitExceededException,  ListPipelineBlueprintsCommand: () => ListPipelineBlueprintsCommand,  ListPipelineEndpointConnectionsCommand: () => ListPipelineEndpointConnectionsCommand,  ListPipelineEndpointsCommand: () => ListPipelineEndpointsCommand,  ListPipelinesCommand: () => ListPipelinesCommand,  ListTagsForResourceCommand: () => ListTagsForResourceCommand,  OSIS: () => OSIS,  OSISClient: () => OSISClient,  OSISServiceException: () => OSISServiceException,  PipelineEndpointStatus: () => PipelineEndpointStatus,  PipelineStatus: () => PipelineStatus,  PutResourcePolicyCommand: () => PutResourcePolicyCommand,  ResourceAlreadyExistsException: () => ResourceAlreadyExistsException,  ResourceNotFoundException: () => ResourceNotFoundException,  RevokePipelineEndpointConnectionsCommand: () => RevokePipelineEndpointConnectionsCommand,  StartPipelineCommand: () => StartPipelineCommand,  StopPipelineCommand: () => StopPipelineCommand,  TagResourceCommand: () => TagResourceCommand,  UntagResourceCommand: () => UntagResourceCommand,  UpdatePipelineCommand: () => UpdatePipelineCommand,  ValidatePipelineCommand: () => ValidatePipelineCommand,  ValidationException: () => ValidationException,  VpcEndpointManagement: () => VpcEndpointManagement,  VpcEndpointServiceName: () => VpcEndpointServiceName,  __Client: () => import_smithy_client.Client,  paginateListPipelineEndpointConnections: () => paginateListPipelineEndpointConnections,  paginateListPipelineEndpoints: () => paginateListPipelineEndpoints,  paginateListPipelines: () => paginateListPipelines});module.exports = __toCommonJS(index_exports); // src/OSISClient.tsvar import_middleware_host_header = require("@aws-sdk/middleware-host-header");var import_middleware_logger = require("@aws-sdk/middleware-logger");var import_middleware_recursion_detection = require("@aws-sdk/middleware-recursion-detection");var import_middleware_user_agent = require("@aws-sdk/middleware-user-agent");var import_config_resolver = require("@smithy/config-resolver");var import_core = require("@smithy/core");var import_middleware_content_length = require("@smithy/middleware-content-length");var import_middleware_endpoint = require("@smithy/middleware-endpoint");var import_middleware_retry = require("@smithy/middleware-retry"); var import_httpAuthSchemeProvider = require("./auth/httpAuthSchemeProvider"); // src/endpoint/EndpointParameters.tsvar resolveClientEndpointParameters = /* @__PURE__ */ __name((options) => {  return Object.assign(options, {    useDualstackEndpoint: options.useDualstackEndpoint ?? false,    useFipsEndpoint: options.useFipsEndpoint ?? false,    defaultSigningName: "osis"  });}, "resolveClientEndpointParameters");var commonParams = {  UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" },  Endpoint: { type: "builtInParams", name: "endpoint" },  Region: { type: "builtInParams", name: "region" },  UseDualStack: { type: "builtInParams", name: "useDualstackEndpoint" }}; // src/OSISClient.tsvar import_runtimeConfig = require("././runtimeConfig"); // src/runtimeExtensions.tsvar import_region_config_resolver = require("@aws-sdk/region-config-resolver");var import_protocol_http = require("@smithy/protocol-http");var import_smithy_client = require("@smithy/smithy-client"); // src/auth/httpAuthExtensionConfiguration.tsvar getHttpAuthExtensionConfiguration = /* @__PURE__ */ __name((runtimeConfig) => {  const _httpAuthSchemes = runtimeConfig.httpAuthSchemes;  let _httpAuthSchemeProvider = runtimeConfig.httpAuthSchemeProvider;  let _credentials = runtimeConfig.credentials;  return {    setHttpAuthScheme(httpAuthScheme) {      const index = _httpAuthSchemes.findIndex((scheme) => scheme.schemeId === httpAuthScheme.schemeId);      if (index === -1) {        _httpAuthSchemes.push(httpAuthScheme);      } else {        _httpAuthSchemes.splice(index, 1, httpAuthScheme);      }    },    httpAuthSchemes() {      return _httpAuthSchemes;    },    setHttpAuthSchemeProvider(httpAuthSchemeProvider) {      _httpAuthSchemeProvider = httpAuthSchemeProvider;    },    httpAuthSchemeProvider() {      return _httpAuthSchemeProvider;    },    setCredentials(credentials) {      _credentials = credentials;    },    credentials() {      return _credentials;    }  };}, "getHttpAuthExtensionConfiguration");var resolveHttpAuthRuntimeConfig = /* @__PURE__ */ __name((config) => {  return {    httpAuthSchemes: config.httpAuthSchemes(),    httpAuthSchemeProvider: config.httpAuthSchemeProvider(),    credentials: config.credentials()  };}, "resolveHttpAuthRuntimeConfig"); // src/runtimeExtensions.tsvar resolveRuntimeExtensions = /* @__PURE__ */ __name((runtimeConfig, extensions) => {  const extensionConfiguration = Object.assign(    (0, import_region_config_resolver.getAwsRegionExtensionConfiguration)(runtimeConfig),    (0, import_smithy_client.getDefaultExtensionConfiguration)(runtimeConfig),    (0, import_protocol_http.getHttpHandlerExtensionConfiguration)(runtimeConfig),    getHttpAuthExtensionConfiguration(runtimeConfig)  );  extensions.forEach((extension) => extension.configure(extensionConfiguration));  return Object.assign(    runtimeConfig,    (0, import_region_config_resolver.resolveAwsRegionExtensionConfiguration)(extensionConfiguration),    (0, import_smithy_client.resolveDefaultRuntimeConfig)(extensionConfiguration),    (0, import_protocol_http.resolveHttpHandlerRuntimeConfig)(extensionConfiguration),    resolveHttpAuthRuntimeConfig(extensionConfiguration)  );}, "resolveRuntimeExtensions"); // src/OSISClient.tsvar OSISClient = class extends import_smithy_client.Client {  static {    __name(this, "OSISClient");  }  /**   * The resolved configuration of OSISClient class. This is resolved and normalized from the {@link OSISClientConfig | constructor configuration interface}.   */  config;  constructor(...[configuration]) {    const _config_0 = (0, import_runtimeConfig.getRuntimeConfig)(configuration || {});    super(_config_0);    this.initConfig = _config_0;    const _config_1 = resolveClientEndpointParameters(_config_0);    const _config_2 = (0, import_middleware_user_agent.resolveUserAgentConfig)(_config_1);    const _config_3 = (0, import_middleware_retry.resolveRetryConfig)(_config_2);    const _config_4 = (0, import_config_resolver.resolveRegionConfig)(_config_3);    const _config_5 = (0, import_middleware_host_header.resolveHostHeaderConfig)(_config_4);    const _config_6 = (0, import_middleware_endpoint.resolveEndpointConfig)(_config_5);    const _config_7 = (0, import_httpAuthSchemeProvider.resolveHttpAuthSchemeConfig)(_config_6);    const _config_8 = resolveRuntimeExtensions(_config_7, configuration?.extensions || []);    this.config = _config_8;    this.middlewareStack.use((0, import_middleware_user_agent.getUserAgentPlugin)(this.config));    this.middlewareStack.use((0, import_middleware_retry.getRetryPlugin)(this.config));    this.middlewareStack.use((0, import_middleware_content_length.getContentLengthPlugin)(this.config));    this.middlewareStack.use((0, import_middleware_host_header.getHostHeaderPlugin)(this.config));    this.middlewareStack.use((0, import_middleware_logger.getLoggerPlugin)(this.config));    this.middlewareStack.use((0, import_middleware_recursion_detection.getRecursionDetectionPlugin)(this.config));    this.middlewareStack.use(      (0, import_core.getHttpAuthSchemeEndpointRuleSetPlugin)(this.config, {        httpAuthSchemeParametersProvider: import_httpAuthSchemeProvider.defaultOSISHttpAuthSchemeParametersProvider,        identityProviderConfigProvider: /* @__PURE__ */ __name(async (config) => new import_core.DefaultIdentityProviderConfig({          "aws.auth#sigv4": config.credentials        }), "identityProviderConfigProvider")      })    );    this.middlewareStack.use((0, import_core.getHttpSigningPlugin)(this.config));  }  /**   * Destroy underlying resources, like sockets. It's usually not necessary to do this.   * However in Node.js, it's best to explicitly shut down the client's agent when it is no longer needed.   * Otherwise, sockets might stay open for quite a long time before the server terminates them.   */  destroy() {    super.destroy();  }}; // src/OSIS.ts  // src/commands/CreatePipelineCommand.ts var import_middleware_serde = require("@smithy/middleware-serde");  // src/protocols/Aws_restJson1.tsvar import_core2 = require("@aws-sdk/core");   // src/models/OSISServiceException.ts var OSISServiceException = class _OSISServiceException extends import_smithy_client.ServiceException {  static {    __name(this, "OSISServiceException");  }  /**   * @internal   */  constructor(options) {    super(options);    Object.setPrototypeOf(this, _OSISServiceException.prototype);  }}; // src/models/models_0.tsvar AccessDeniedException = class _AccessDeniedException extends OSISServiceException {  static {    __name(this, "AccessDeniedException");  }  name = "AccessDeniedException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "AccessDeniedException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _AccessDeniedException.prototype);  }};var VpcEndpointManagement = {  CUSTOMER: "CUSTOMER",  SERVICE: "SERVICE"};var VpcEndpointServiceName = {  OPENSEARCH_SERVERLESS: "OPENSEARCH_SERVERLESS"};var PipelineStatus = {  ACTIVE: "ACTIVE",  CREATE_FAILED: "CREATE_FAILED",  CREATING: "CREATING",  DELETING: "DELETING",  STARTING: "STARTING",  START_FAILED: "START_FAILED",  STOPPED: "STOPPED",  STOPPING: "STOPPING",  UPDATE_FAILED: "UPDATE_FAILED",  UPDATING: "UPDATING"};var DisabledOperationException = class _DisabledOperationException extends OSISServiceException {  static {    __name(this, "DisabledOperationException");  }  name = "DisabledOperationException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "DisabledOperationException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _DisabledOperationException.prototype);  }};var InternalException = class _InternalException extends OSISServiceException {  static {    __name(this, "InternalException");  }  name = "InternalException";  $fault = "server";  /**   * @internal   */  constructor(opts) {    super({      name: "InternalException",      $fault: "server",      ...opts    });    Object.setPrototypeOf(this, _InternalException.prototype);  }};var LimitExceededException = class _LimitExceededException extends OSISServiceException {  static {    __name(this, "LimitExceededException");  }  name = "LimitExceededException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "LimitExceededException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _LimitExceededException.prototype);  }};var ResourceAlreadyExistsException = class _ResourceAlreadyExistsException extends OSISServiceException {  static {    __name(this, "ResourceAlreadyExistsException");  }  name = "ResourceAlreadyExistsException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "ResourceAlreadyExistsException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _ResourceAlreadyExistsException.prototype);  }};var ResourceNotFoundException = class _ResourceNotFoundException extends OSISServiceException {  static {    __name(this, "ResourceNotFoundException");  }  name = "ResourceNotFoundException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "ResourceNotFoundException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _ResourceNotFoundException.prototype);  }};var ValidationException = class _ValidationException extends OSISServiceException {  static {    __name(this, "ValidationException");  }  name = "ValidationException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "ValidationException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _ValidationException.prototype);  }};var PipelineEndpointStatus = {  ACTIVE: "ACTIVE",  CREATE_FAILED: "CREATE_FAILED",  CREATING: "CREATING",  DELETING: "DELETING",  REVOKED: "REVOKED",  REVOKING: "REVOKING"};var ConflictException = class _ConflictException extends OSISServiceException {  static {    __name(this, "ConflictException");  }  name = "ConflictException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "ConflictException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _ConflictException.prototype);  }};var ChangeProgressStageStatuses = {  COMPLETED: "COMPLETED",  FAILED: "FAILED",  IN_PROGRESS: "IN_PROGRESS",  PENDING: "PENDING"};var ChangeProgressStatuses = {  COMPLETED: "COMPLETED",  FAILED: "FAILED",  IN_PROGRESS: "IN_PROGRESS",  PENDING: "PENDING"};var InvalidPaginationTokenException = class _InvalidPaginationTokenException extends OSISServiceException {  static {    __name(this, "InvalidPaginationTokenException");  }  name = "InvalidPaginationTokenException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "InvalidPaginationTokenException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _InvalidPaginationTokenException.prototype);  }}; // src/protocols/Aws_restJson1.tsvar se_CreatePipelineCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {    "content-type": "application/json"  };  b.bp("/2022-01-01/osis/createPipeline");  let body;  body = JSON.stringify(    (0, import_smithy_client.take)(input, {      BufferOptions: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "BufferOptions"),      EncryptionAtRestOptions: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "EncryptionAtRestOptions"),      LogPublishingOptions: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "LogPublishingOptions"),      MaxUnits: [],      MinUnits: [],      PipelineConfigurationBody: [],      PipelineName: [],      PipelineRoleArn: [],      Tags: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "Tags"),      VpcOptions: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "VpcOptions")    })  );  b.m("POST").h(headers).b(body);  return b.build();}, "se_CreatePipelineCommand");var se_CreatePipelineEndpointCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {    "content-type": "application/json"  };  b.bp("/2022-01-01/osis/createPipelineEndpoint");  let body;  body = JSON.stringify(    (0, import_smithy_client.take)(input, {      PipelineArn: [],      VpcOptions: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "VpcOptions")    })  );  b.m("POST").h(headers).b(body);  return b.build();}, "se_CreatePipelineEndpointCommand");var se_DeletePipelineCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/2022-01-01/osis/deletePipeline/{PipelineName}");  b.p("PipelineName", () => input.PipelineName, "{PipelineName}", false);  let body;  b.m("DELETE").h(headers).b(body);  return b.build();}, "se_DeletePipelineCommand");var se_DeletePipelineEndpointCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/2022-01-01/osis/deletePipelineEndpoint/{EndpointId}");  b.p("EndpointId", () => input.EndpointId, "{EndpointId}", false);  let body;  b.m("DELETE").h(headers).b(body);  return b.build();}, "se_DeletePipelineEndpointCommand");var se_DeleteResourcePolicyCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/2022-01-01/osis/resourcePolicy/{ResourceArn}");  b.p("ResourceArn", () => input.ResourceArn, "{ResourceArn}", false);  let body;  b.m("DELETE").h(headers).b(body);  return b.build();}, "se_DeleteResourcePolicyCommand");var se_GetPipelineCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/2022-01-01/osis/getPipeline/{PipelineName}");  b.p("PipelineName", () => input.PipelineName, "{PipelineName}", false);  let body;  b.m("GET").h(headers).b(body);  return b.build();}, "se_GetPipelineCommand");var se_GetPipelineBlueprintCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/2022-01-01/osis/getPipelineBlueprint/{BlueprintName}");  b.p("BlueprintName", () => input.BlueprintName, "{BlueprintName}", false);  const query = (0, import_smithy_client.map)({    [_f]: [, input[_F]]  });  let body;  b.m("GET").h(headers).q(query).b(body);  return b.build();}, "se_GetPipelineBlueprintCommand");var se_GetPipelineChangeProgressCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/2022-01-01/osis/getPipelineChangeProgress/{PipelineName}");  b.p("PipelineName", () => input.PipelineName, "{PipelineName}", false);  let body;  b.m("GET").h(headers).b(body);  return b.build();}, "se_GetPipelineChangeProgressCommand");var se_GetResourcePolicyCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/2022-01-01/osis/resourcePolicy/{ResourceArn}");  b.p("ResourceArn", () => input.ResourceArn, "{ResourceArn}", false);  let body;  b.m("GET").h(headers).b(body);  return b.build();}, "se_GetResourcePolicyCommand");var se_ListPipelineBlueprintsCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/2022-01-01/osis/listPipelineBlueprints");  let body;  b.m("POST").h(headers).b(body);  return b.build();}, "se_ListPipelineBlueprintsCommand");var se_ListPipelineEndpointConnectionsCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/2022-01-01/osis/listPipelineEndpointConnections");  const query = (0, import_smithy_client.map)({    [_mR]: [() => input.MaxResults !== void 0, () => input[_MR].toString()],    [_nT]: [, input[_NT]]  });  let body;  b.m("GET").h(headers).q(query).b(body);  return b.build();}, "se_ListPipelineEndpointConnectionsCommand");var se_ListPipelineEndpointsCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/2022-01-01/osis/listPipelineEndpoints");  const query = (0, import_smithy_client.map)({    [_mR]: [() => input.MaxResults !== void 0, () => input[_MR].toString()],    [_nT]: [, input[_NT]]  });  let body;  b.m("GET").h(headers).q(query).b(body);  return b.build();}, "se_ListPipelineEndpointsCommand");var se_ListPipelinesCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/2022-01-01/osis/listPipelines");  const query = (0, import_smithy_client.map)({    [_mR]: [() => input.MaxResults !== void 0, () => input[_MR].toString()],    [_nT]: [, input[_NT]]  });  let body;  b.m("GET").h(headers).q(query).b(body);  return b.build();}, "se_ListPipelinesCommand");var se_ListTagsForResourceCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/2022-01-01/osis/listTagsForResource");  const query = (0, import_smithy_client.map)({    [_a]: [, (0, import_smithy_client.expectNonNull)(input[_A], `Arn`)]  });  let body;  b.m("GET").h(headers).q(query).b(body);  return b.build();}, "se_ListTagsForResourceCommand");var se_PutResourcePolicyCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {    "content-type": "application/json"  };  b.bp("/2022-01-01/osis/resourcePolicy/{ResourceArn}");  b.p("ResourceArn", () => input.ResourceArn, "{ResourceArn}", false);  let body;  body = JSON.stringify(    (0, import_smithy_client.take)(input, {      Policy: []    })  );  b.m("PUT").h(headers).b(body);  return b.build();}, "se_PutResourcePolicyCommand");var se_RevokePipelineEndpointConnectionsCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {    "content-type": "application/json"  };  b.bp("/2022-01-01/osis/revokePipelineEndpointConnections");  let body;  body = JSON.stringify(    (0, import_smithy_client.take)(input, {      EndpointIds: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "EndpointIds"),      PipelineArn: []    })  );  b.m("POST").h(headers).b(body);  return b.build();}, "se_RevokePipelineEndpointConnectionsCommand");var se_StartPipelineCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/2022-01-01/osis/startPipeline/{PipelineName}");  b.p("PipelineName", () => input.PipelineName, "{PipelineName}", false);  let body;  b.m("PUT").h(headers).b(body);  return b.build();}, "se_StartPipelineCommand");var se_StopPipelineCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/2022-01-01/osis/stopPipeline/{PipelineName}");  b.p("PipelineName", () => input.PipelineName, "{PipelineName}", false);  let body;  b.m("PUT").h(headers).b(body);  return b.build();}, "se_StopPipelineCommand");var se_TagResourceCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {    "content-type": "application/json"  };  b.bp("/2022-01-01/osis/tagResource");  const query = (0, import_smithy_client.map)({    [_a]: [, (0, import_smithy_client.expectNonNull)(input[_A], `Arn`)]  });  let body;  body = JSON.stringify(    (0, import_smithy_client.take)(input, {      Tags: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "Tags")    })  );  b.m("POST").h(headers).q(query).b(body);  return b.build();}, "se_TagResourceCommand");var se_UntagResourceCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {    "content-type": "application/json"  };  b.bp("/2022-01-01/osis/untagResource");  const query = (0, import_smithy_client.map)({    [_a]: [, (0, import_smithy_client.expectNonNull)(input[_A], `Arn`)]  });  let body;  body = JSON.stringify(    (0, import_smithy_client.take)(input, {      TagKeys: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "TagKeys")    })  );  b.m("POST").h(headers).q(query).b(body);  return b.build();}, "se_UntagResourceCommand");var se_UpdatePipelineCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {    "content-type": "application/json"  };  b.bp("/2022-01-01/osis/updatePipeline/{PipelineName}");  b.p("PipelineName", () => input.PipelineName, "{PipelineName}", false);  let body;  body = JSON.stringify(    (0, import_smithy_client.take)(input, {      BufferOptions: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "BufferOptions"),      EncryptionAtRestOptions: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "EncryptionAtRestOptions"),      LogPublishingOptions: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "LogPublishingOptions"),      MaxUnits: [],      MinUnits: [],      PipelineConfigurationBody: [],      PipelineRoleArn: []    })  );  b.m("PUT").h(headers).b(body);  return b.build();}, "se_UpdatePipelineCommand");var se_ValidatePipelineCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {    "content-type": "application/json"  };  b.bp("/2022-01-01/osis/validatePipeline");  let body;  body = JSON.stringify(    (0, import_smithy_client.take)(input, {      PipelineConfigurationBody: []    })  );  b.m("POST").h(headers).b(body);  return b.build();}, "se_ValidatePipelineCommand");var de_CreatePipelineCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    Pipeline: /* @__PURE__ */ __name((_) => de_Pipeline(_, context), "Pipeline")  });  Object.assign(contents, doc);  return contents;}, "de_CreatePipelineCommand");var de_CreatePipelineEndpointCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    EndpointId: import_smithy_client.expectString,    PipelineArn: import_smithy_client.expectString,    Status: import_smithy_client.expectString,    VpcId: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_CreatePipelineEndpointCommand");var de_DeletePipelineCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  await (0, import_smithy_client.collectBody)(output.body, context);  return contents;}, "de_DeletePipelineCommand");var de_DeletePipelineEndpointCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  await (0, import_smithy_client.collectBody)(output.body, context);  return contents;}, "de_DeletePipelineEndpointCommand");var de_DeleteResourcePolicyCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  await (0, import_smithy_client.collectBody)(output.body, context);  return contents;}, "de_DeleteResourcePolicyCommand");var de_GetPipelineCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    Pipeline: /* @__PURE__ */ __name((_) => de_Pipeline(_, context), "Pipeline")  });  Object.assign(contents, doc);  return contents;}, "de_GetPipelineCommand");var de_GetPipelineBlueprintCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    Blueprint: import_smithy_client._json,    Format: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_GetPipelineBlueprintCommand");var de_GetPipelineChangeProgressCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    ChangeProgressStatuses: /* @__PURE__ */ __name((_) => de_ChangeProgressStatusList(_, context), "ChangeProgressStatuses")  });  Object.assign(contents, doc);  return contents;}, "de_GetPipelineChangeProgressCommand");var de_GetResourcePolicyCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    Policy: import_smithy_client.expectString,    ResourceArn: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_GetResourcePolicyCommand");var de_ListPipelineBlueprintsCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    Blueprints: import_smithy_client._json  });  Object.assign(contents, doc);  return contents;}, "de_ListPipelineBlueprintsCommand");var de_ListPipelineEndpointConnectionsCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    NextToken: import_smithy_client.expectString,    PipelineEndpointConnections: import_smithy_client._json  });  Object.assign(contents, doc);  return contents;}, "de_ListPipelineEndpointConnectionsCommand");var de_ListPipelineEndpointsCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    NextToken: import_smithy_client.expectString,    PipelineEndpoints: import_smithy_client._json  });  Object.assign(contents, doc);  return contents;}, "de_ListPipelineEndpointsCommand");var de_ListPipelinesCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    NextToken: import_smithy_client.expectString,    Pipelines: /* @__PURE__ */ __name((_) => de_PipelineSummaryList(_, context), "Pipelines")  });  Object.assign(contents, doc);  return contents;}, "de_ListPipelinesCommand");var de_ListTagsForResourceCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    Tags: import_smithy_client._json  });  Object.assign(contents, doc);  return contents;}, "de_ListTagsForResourceCommand");var de_PutResourcePolicyCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    Policy: import_smithy_client.expectString,    ResourceArn: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_PutResourcePolicyCommand");var de_RevokePipelineEndpointConnectionsCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    PipelineArn: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_RevokePipelineEndpointConnectionsCommand");var de_StartPipelineCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    Pipeline: /* @__PURE__ */ __name((_) => de_Pipeline(_, context), "Pipeline")  });  Object.assign(contents, doc);  return contents;}, "de_StartPipelineCommand");var de_StopPipelineCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    Pipeline: /* @__PURE__ */ __name((_) => de_Pipeline(_, context), "Pipeline")  });  Object.assign(contents, doc);  return contents;}, "de_StopPipelineCommand");var de_TagResourceCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  await (0, import_smithy_client.collectBody)(output.body, context);  return contents;}, "de_TagResourceCommand");var de_UntagResourceCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  await (0, import_smithy_client.collectBody)(output.body, context);  return contents;}, "de_UntagResourceCommand");var de_UpdatePipelineCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    Pipeline: /* @__PURE__ */ __name((_) => de_Pipeline(_, context), "Pipeline")  });  Object.assign(contents, doc);  return contents;}, "de_UpdatePipelineCommand");var de_ValidatePipelineCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    Errors: import_smithy_client._json,    isValid: import_smithy_client.expectBoolean  });  Object.assign(contents, doc);  return contents;}, "de_ValidatePipelineCommand");var de_CommandError = /* @__PURE__ */ __name(async (output, context) => {  const parsedOutput = {    ...output,    body: await (0, import_core2.parseJsonErrorBody)(output.body, context)  };  const errorCode = (0, import_core2.loadRestJsonErrorCode)(output, parsedOutput.body);  switch (errorCode) {    case "AccessDeniedException":    case "com.amazonaws.osis#AccessDeniedException":      throw await de_AccessDeniedExceptionRes(parsedOutput, context);    case "DisabledOperationException":    case "com.amazonaws.osis#DisabledOperationException":      throw await de_DisabledOperationExceptionRes(parsedOutput, context);    case "InternalException":    case "com.amazonaws.osis#InternalException":      throw await de_InternalExceptionRes(parsedOutput, context);    case "LimitExceededException":    case "com.amazonaws.osis#LimitExceededException":      throw await de_LimitExceededExceptionRes(parsedOutput, context);    case "ResourceAlreadyExistsException":    case "com.amazonaws.osis#ResourceAlreadyExistsException":      throw await de_ResourceAlreadyExistsExceptionRes(parsedOutput, context);    case "ResourceNotFoundException":    case "com.amazonaws.osis#ResourceNotFoundException":      throw await de_ResourceNotFoundExceptionRes(parsedOutput, context);    case "ValidationException":    case "com.amazonaws.osis#ValidationException":      throw await de_ValidationExceptionRes(parsedOutput, context);    case "ConflictException":    case "com.amazonaws.osis#ConflictException":      throw await de_ConflictExceptionRes(parsedOutput, context);    case "InvalidPaginationTokenException":    case "com.amazonaws.osis#InvalidPaginationTokenException":      throw await de_InvalidPaginationTokenExceptionRes(parsedOutput, context);    default:      const parsedBody = parsedOutput.body;      return throwDefaultError({        output,        parsedBody,        errorCode      });  }}, "de_CommandError");var throwDefaultError = (0, import_smithy_client.withBaseException)(OSISServiceException);var de_AccessDeniedExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({});  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new AccessDeniedException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_AccessDeniedExceptionRes");var de_ConflictExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({});  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new ConflictException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_ConflictExceptionRes");var de_DisabledOperationExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({});  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new DisabledOperationException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_DisabledOperationExceptionRes");var de_InternalExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({});  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new InternalException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_InternalExceptionRes");var de_InvalidPaginationTokenExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({});  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new InvalidPaginationTokenException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_InvalidPaginationTokenExceptionRes");var de_LimitExceededExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({});  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new LimitExceededException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_LimitExceededExceptionRes");var de_ResourceAlreadyExistsExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({});  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new ResourceAlreadyExistsException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_ResourceAlreadyExistsExceptionRes");var de_ResourceNotFoundExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({});  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new ResourceNotFoundException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_ResourceNotFoundExceptionRes");var de_ValidationExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({});  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new ValidationException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_ValidationExceptionRes");var de_ChangeProgressStage = /* @__PURE__ */ __name((output, context) => {  return (0, import_smithy_client.take)(output, {    Description: import_smithy_client.expectString,    LastUpdatedAt: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "LastUpdatedAt"),    Name: import_smithy_client.expectString,    Status: import_smithy_client.expectString  });}, "de_ChangeProgressStage");var de_ChangeProgressStageList = /* @__PURE__ */ __name((output, context) => {  const retVal = (output || []).filter((e) => e != null).map((entry) => {    return de_ChangeProgressStage(entry, context);  });  return retVal;}, "de_ChangeProgressStageList");var de_ChangeProgressStatus = /* @__PURE__ */ __name((output, context) => {  return (0, import_smithy_client.take)(output, {    ChangeProgressStages: /* @__PURE__ */ __name((_) => de_ChangeProgressStageList(_, context), "ChangeProgressStages"),    StartTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "StartTime"),    Status: import_smithy_client.expectString,    TotalNumberOfStages: import_smithy_client.expectInt32  });}, "de_ChangeProgressStatus");var de_ChangeProgressStatusList = /* @__PURE__ */ __name((output, context) => {  const retVal = (output || []).filter((e) => e != null).map((entry) => {    return de_ChangeProgressStatus(entry, context);  });  return retVal;}, "de_ChangeProgressStatusList");var de_Pipeline = /* @__PURE__ */ __name((output, context) => {  return (0, import_smithy_client.take)(output, {    BufferOptions: import_smithy_client._json,    CreatedAt: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "CreatedAt"),    Destinations: import_smithy_client._json,    EncryptionAtRestOptions: import_smithy_client._json,    IngestEndpointUrls: import_smithy_client._json,    LastUpdatedAt: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "LastUpdatedAt"),    LogPublishingOptions: import_smithy_client._json,    MaxUnits: import_smithy_client.expectInt32,    MinUnits: import_smithy_client.expectInt32,    PipelineArn: import_smithy_client.expectString,    PipelineConfigurationBody: import_smithy_client.expectString,    PipelineName: import_smithy_client.expectString,    PipelineRoleArn: import_smithy_client.expectString,    ServiceVpcEndpoints: import_smithy_client._json,    Status: import_smithy_client.expectString,    StatusReason: import_smithy_client._json,    Tags: import_smithy_client._json,    VpcEndpointService: import_smithy_client.expectString,    VpcEndpoints: import_smithy_client._json  });}, "de_Pipeline");var de_PipelineSummary = /* @__PURE__ */ __name((output, context) => {  return (0, import_smithy_client.take)(output, {    CreatedAt: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "CreatedAt"),    Destinations: import_smithy_client._json,    LastUpdatedAt: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "LastUpdatedAt"),    MaxUnits: import_smithy_client.expectInt32,    MinUnits: import_smithy_client.expectInt32,    PipelineArn: import_smithy_client.expectString,    PipelineName: import_smithy_client.expectString,    Status: import_smithy_client.expectString,    StatusReason: import_smithy_client._json,    Tags: import_smithy_client._json  });}, "de_PipelineSummary");var de_PipelineSummaryList = /* @__PURE__ */ __name((output, context) => {  const retVal = (output || []).filter((e) => e != null).map((entry) => {    return de_PipelineSummary(entry, context);  });  return retVal;}, "de_PipelineSummaryList");var deserializeMetadata = /* @__PURE__ */ __name((output) => ({  httpStatusCode: output.statusCode,  requestId: output.headers["x-amzn-requestid"] ?? output.headers["x-amzn-request-id"] ?? output.headers["x-amz-request-id"],  extendedRequestId: output.headers["x-amz-id-2"],  cfId: output.headers["x-amz-cf-id"]}), "deserializeMetadata");var _A = "Arn";var _F = "Format";var _MR = "MaxResults";var _NT = "NextToken";var _a = "arn";var _f = "format";var _mR = "maxResults";var _nT = "nextToken"; // src/commands/CreatePipelineCommand.tsvar CreatePipelineCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "CreatePipeline", {}).n("OSISClient", "CreatePipelineCommand").f(void 0, void 0).ser(se_CreatePipelineCommand).de(de_CreatePipelineCommand).build() {  static {    __name(this, "CreatePipelineCommand");  }}; // src/commands/CreatePipelineEndpointCommand.ts   var CreatePipelineEndpointCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "CreatePipelineEndpoint", {}).n("OSISClient", "CreatePipelineEndpointCommand").f(void 0, void 0).ser(se_CreatePipelineEndpointCommand).de(de_CreatePipelineEndpointCommand).build() {  static {    __name(this, "CreatePipelineEndpointCommand");  }}; // src/commands/DeletePipelineCommand.ts   var DeletePipelineCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "DeletePipeline", {}).n("OSISClient", "DeletePipelineCommand").f(void 0, void 0).ser(se_DeletePipelineCommand).de(de_DeletePipelineCommand).build() {  static {    __name(this, "DeletePipelineCommand");  }}; // src/commands/DeletePipelineEndpointCommand.ts   var DeletePipelineEndpointCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "DeletePipelineEndpoint", {}).n("OSISClient", "DeletePipelineEndpointCommand").f(void 0, void 0).ser(se_DeletePipelineEndpointCommand).de(de_DeletePipelineEndpointCommand).build() {  static {    __name(this, "DeletePipelineEndpointCommand");  }}; // src/commands/DeleteResourcePolicyCommand.ts   var DeleteResourcePolicyCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "DeleteResourcePolicy", {}).n("OSISClient", "DeleteResourcePolicyCommand").f(void 0, void 0).ser(se_DeleteResourcePolicyCommand).de(de_DeleteResourcePolicyCommand).build() {  static {    __name(this, "DeleteResourcePolicyCommand");  }}; // src/commands/GetPipelineBlueprintCommand.ts   var GetPipelineBlueprintCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "GetPipelineBlueprint", {}).n("OSISClient", "GetPipelineBlueprintCommand").f(void 0, void 0).ser(se_GetPipelineBlueprintCommand).de(de_GetPipelineBlueprintCommand).build() {  static {    __name(this, "GetPipelineBlueprintCommand");  }}; // src/commands/GetPipelineChangeProgressCommand.ts   var GetPipelineChangeProgressCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "GetPipelineChangeProgress", {}).n("OSISClient", "GetPipelineChangeProgressCommand").f(void 0, void 0).ser(se_GetPipelineChangeProgressCommand).de(de_GetPipelineChangeProgressCommand).build() {  static {    __name(this, "GetPipelineChangeProgressCommand");  }}; // src/commands/GetPipelineCommand.ts   var GetPipelineCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "GetPipeline", {}).n("OSISClient", "GetPipelineCommand").f(void 0, void 0).ser(se_GetPipelineCommand).de(de_GetPipelineCommand).build() {  static {    __name(this, "GetPipelineCommand");  }}; // src/commands/GetResourcePolicyCommand.ts   var GetResourcePolicyCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "GetResourcePolicy", {}).n("OSISClient", "GetResourcePolicyCommand").f(void 0, void 0).ser(se_GetResourcePolicyCommand).de(de_GetResourcePolicyCommand).build() {  static {    __name(this, "GetResourcePolicyCommand");  }}; // src/commands/ListPipelineBlueprintsCommand.ts   var ListPipelineBlueprintsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "ListPipelineBlueprints", {}).n("OSISClient", "ListPipelineBlueprintsCommand").f(void 0, void 0).ser(se_ListPipelineBlueprintsCommand).de(de_ListPipelineBlueprintsCommand).build() {  static {    __name(this, "ListPipelineBlueprintsCommand");  }}; // src/commands/ListPipelineEndpointConnectionsCommand.ts   var ListPipelineEndpointConnectionsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "ListPipelineEndpointConnections", {}).n("OSISClient", "ListPipelineEndpointConnectionsCommand").f(void 0, void 0).ser(se_ListPipelineEndpointConnectionsCommand).de(de_ListPipelineEndpointConnectionsCommand).build() {  static {    __name(this, "ListPipelineEndpointConnectionsCommand");  }}; // src/commands/ListPipelineEndpointsCommand.ts   var ListPipelineEndpointsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "ListPipelineEndpoints", {}).n("OSISClient", "ListPipelineEndpointsCommand").f(void 0, void 0).ser(se_ListPipelineEndpointsCommand).de(de_ListPipelineEndpointsCommand).build() {  static {    __name(this, "ListPipelineEndpointsCommand");  }}; // src/commands/ListPipelinesCommand.ts   var ListPipelinesCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "ListPipelines", {}).n("OSISClient", "ListPipelinesCommand").f(void 0, void 0).ser(se_ListPipelinesCommand).de(de_ListPipelinesCommand).build() {  static {    __name(this, "ListPipelinesCommand");  }}; // src/commands/ListTagsForResourceCommand.ts   var ListTagsForResourceCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "ListTagsForResource", {}).n("OSISClient", "ListTagsForResourceCommand").f(void 0, void 0).ser(se_ListTagsForResourceCommand).de(de_ListTagsForResourceCommand).build() {  static {    __name(this, "ListTagsForResourceCommand");  }}; // src/commands/PutResourcePolicyCommand.ts   var PutResourcePolicyCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "PutResourcePolicy", {}).n("OSISClient", "PutResourcePolicyCommand").f(void 0, void 0).ser(se_PutResourcePolicyCommand).de(de_PutResourcePolicyCommand).build() {  static {    __name(this, "PutResourcePolicyCommand");  }}; // src/commands/RevokePipelineEndpointConnectionsCommand.ts   var RevokePipelineEndpointConnectionsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "RevokePipelineEndpointConnections", {}).n("OSISClient", "RevokePipelineEndpointConnectionsCommand").f(void 0, void 0).ser(se_RevokePipelineEndpointConnectionsCommand).de(de_RevokePipelineEndpointConnectionsCommand).build() {  static {    __name(this, "RevokePipelineEndpointConnectionsCommand");  }}; // src/commands/StartPipelineCommand.ts   var StartPipelineCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "StartPipeline", {}).n("OSISClient", "StartPipelineCommand").f(void 0, void 0).ser(se_StartPipelineCommand).de(de_StartPipelineCommand).build() {  static {    __name(this, "StartPipelineCommand");  }}; // src/commands/StopPipelineCommand.ts   var StopPipelineCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "StopPipeline", {}).n("OSISClient", "StopPipelineCommand").f(void 0, void 0).ser(se_StopPipelineCommand).de(de_StopPipelineCommand).build() {  static {    __name(this, "StopPipelineCommand");  }}; // src/commands/TagResourceCommand.ts   var TagResourceCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "TagResource", {}).n("OSISClient", "TagResourceCommand").f(void 0, void 0).ser(se_TagResourceCommand).de(de_TagResourceCommand).build() {  static {    __name(this, "TagResourceCommand");  }}; // src/commands/UntagResourceCommand.ts   var UntagResourceCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "UntagResource", {}).n("OSISClient", "UntagResourceCommand").f(void 0, void 0).ser(se_UntagResourceCommand).de(de_UntagResourceCommand).build() {  static {    __name(this, "UntagResourceCommand");  }}; // src/commands/UpdatePipelineCommand.ts   var UpdatePipelineCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "UpdatePipeline", {}).n("OSISClient", "UpdatePipelineCommand").f(void 0, void 0).ser(se_UpdatePipelineCommand).de(de_UpdatePipelineCommand).build() {  static {    __name(this, "UpdatePipelineCommand");  }}; // src/commands/ValidatePipelineCommand.ts   var ValidatePipelineCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("AmazonOpenSearchIngestionService", "ValidatePipeline", {}).n("OSISClient", "ValidatePipelineCommand").f(void 0, void 0).ser(se_ValidatePipelineCommand).de(de_ValidatePipelineCommand).build() {  static {    __name(this, "ValidatePipelineCommand");  }}; // src/OSIS.tsvar commands = {  CreatePipelineCommand,  CreatePipelineEndpointCommand,  DeletePipelineCommand,  DeletePipelineEndpointCommand,  DeleteResourcePolicyCommand,  GetPipelineCommand,  GetPipelineBlueprintCommand,  GetPipelineChangeProgressCommand,  GetResourcePolicyCommand,  ListPipelineBlueprintsCommand,  ListPipelineEndpointConnectionsCommand,  ListPipelineEndpointsCommand,  ListPipelinesCommand,  ListTagsForResourceCommand,  PutResourcePolicyCommand,  RevokePipelineEndpointConnectionsCommand,  StartPipelineCommand,  StopPipelineCommand,  TagResourceCommand,  UntagResourceCommand,  UpdatePipelineCommand,  ValidatePipelineCommand};var OSIS = class extends OSISClient {  static {    __name(this, "OSIS");  }};(0, import_smithy_client.createAggregatedClient)(commands, OSIS); // src/pagination/ListPipelineEndpointConnectionsPaginator.ts var paginateListPipelineEndpointConnections = (0, import_core.createPaginator)(OSISClient, ListPipelineEndpointConnectionsCommand, "NextToken", "NextToken", "MaxResults"); // src/pagination/ListPipelineEndpointsPaginator.ts var paginateListPipelineEndpoints = (0, import_core.createPaginator)(OSISClient, ListPipelineEndpointsCommand, "NextToken", "NextToken", "MaxResults"); // src/pagination/ListPipelinesPaginator.ts var paginateListPipelines = (0, import_core.createPaginator)(OSISClient, ListPipelinesCommand, "NextToken", "NextToken", "MaxResults");// Annotate the CommonJS export names for ESM import in node: 0 && (module.exports = {  OSISServiceException,  __Client,  OSISClient,  OSIS,  $Command,  CreatePipelineCommand,  CreatePipelineEndpointCommand,  DeletePipelineCommand,  DeletePipelineEndpointCommand,  DeleteResourcePolicyCommand,  GetPipelineBlueprintCommand,  GetPipelineChangeProgressCommand,  GetPipelineCommand,  GetResourcePolicyCommand,  ListPipelineBlueprintsCommand,  ListPipelineEndpointConnectionsCommand,  ListPipelineEndpointsCommand,  ListPipelinesCommand,  ListTagsForResourceCommand,  PutResourcePolicyCommand,  RevokePipelineEndpointConnectionsCommand,  StartPipelineCommand,  StopPipelineCommand,  TagResourceCommand,  UntagResourceCommand,  UpdatePipelineCommand,  ValidatePipelineCommand,  paginateListPipelineEndpointConnections,  paginateListPipelineEndpoints,  paginateListPipelines,  AccessDeniedException,  VpcEndpointManagement,  VpcEndpointServiceName,  PipelineStatus,  DisabledOperationException,  InternalException,  LimitExceededException,  ResourceAlreadyExistsException,  ResourceNotFoundException,  ValidationException,  PipelineEndpointStatus,  ConflictException,  ChangeProgressStageStatuses,  ChangeProgressStatuses,  InvalidPaginationTokenException});