/var/runtime/node_modules/@aws-sdk/client-mwaa/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 /.
"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, CreateCliTokenCommand: () => CreateCliTokenCommand, CreateCliTokenResponseFilterSensitiveLog: () => CreateCliTokenResponseFilterSensitiveLog, CreateEnvironmentCommand: () => CreateEnvironmentCommand, CreateEnvironmentInputFilterSensitiveLog: () => CreateEnvironmentInputFilterSensitiveLog, CreateWebLoginTokenCommand: () => CreateWebLoginTokenCommand, CreateWebLoginTokenResponseFilterSensitiveLog: () => CreateWebLoginTokenResponseFilterSensitiveLog, DeleteEnvironmentCommand: () => DeleteEnvironmentCommand, EndpointManagement: () => EndpointManagement, EnvironmentFilterSensitiveLog: () => EnvironmentFilterSensitiveLog, EnvironmentStatus: () => EnvironmentStatus, GetEnvironmentCommand: () => GetEnvironmentCommand, GetEnvironmentOutputFilterSensitiveLog: () => GetEnvironmentOutputFilterSensitiveLog, InternalServerException: () => InternalServerException, InvokeRestApiCommand: () => InvokeRestApiCommand, InvokeRestApiRequestFilterSensitiveLog: () => InvokeRestApiRequestFilterSensitiveLog, InvokeRestApiResponseFilterSensitiveLog: () => InvokeRestApiResponseFilterSensitiveLog, ListEnvironmentsCommand: () => ListEnvironmentsCommand, ListTagsForResourceCommand: () => ListTagsForResourceCommand, LoggingLevel: () => LoggingLevel, MWAA: () => MWAA, MWAAClient: () => MWAAClient, MWAAServiceException: () => MWAAServiceException, PublishMetricsCommand: () => PublishMetricsCommand, ResourceNotFoundException: () => ResourceNotFoundException, RestApiClientException: () => RestApiClientException, RestApiMethod: () => RestApiMethod, RestApiServerException: () => RestApiServerException, TagResourceCommand: () => TagResourceCommand, Unit: () => Unit, UntagResourceCommand: () => UntagResourceCommand, UpdateEnvironmentCommand: () => UpdateEnvironmentCommand, UpdateEnvironmentInputFilterSensitiveLog: () => UpdateEnvironmentInputFilterSensitiveLog, UpdateStatus: () => UpdateStatus, ValidationException: () => ValidationException, WebserverAccessMode: () => WebserverAccessMode, WorkerReplacementStrategy: () => WorkerReplacementStrategy, __Client: () => import_smithy_client.Client, paginateListEnvironments: () => paginateListEnvironments});module.exports = __toCommonJS(index_exports); // src/MWAAClient.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: "airflow" });}, "resolveClientEndpointParameters");var commonParams = { UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" }, Endpoint: { type: "builtInParams", name: "endpoint" }, Region: { type: "builtInParams", name: "region" }, UseDualStack: { type: "builtInParams", name: "useDualstackEndpoint" }}; // src/MWAAClient.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/MWAAClient.tsvar MWAAClient = class extends import_smithy_client.Client { static { __name(this, "MWAAClient"); } /** * The resolved configuration of MWAAClient class. This is resolved and normalized from the {@link MWAAClientConfig | 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.defaultMWAAHttpAuthSchemeParametersProvider, 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/MWAA.ts // src/commands/CreateCliTokenCommand.ts var import_middleware_serde = require("@smithy/middleware-serde"); // src/models/models_0.ts // src/models/MWAAServiceException.ts var MWAAServiceException = class _MWAAServiceException extends import_smithy_client.ServiceException { static { __name(this, "MWAAServiceException"); } /** * @internal */ constructor(options) { super(options); Object.setPrototypeOf(this, _MWAAServiceException.prototype); }}; // src/models/models_0.tsvar AccessDeniedException = class _AccessDeniedException extends MWAAServiceException { static { __name(this, "AccessDeniedException"); } name = "AccessDeniedException"; $fault = "client"; Message; /** * @internal */ constructor(opts) { super({ name: "AccessDeniedException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _AccessDeniedException.prototype); this.Message = opts.Message; }};var ResourceNotFoundException = class _ResourceNotFoundException extends MWAAServiceException { static { __name(this, "ResourceNotFoundException"); } name = "ResourceNotFoundException"; $fault = "client"; /** * @internal */ constructor(opts) { super({ name: "ResourceNotFoundException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _ResourceNotFoundException.prototype); }};var EndpointManagement = { CUSTOMER: "CUSTOMER", SERVICE: "SERVICE"};var LoggingLevel = { CRITICAL: "CRITICAL", DEBUG: "DEBUG", ERROR: "ERROR", INFO: "INFO", WARNING: "WARNING"};var WebserverAccessMode = { PRIVATE_ONLY: "PRIVATE_ONLY", PUBLIC_ONLY: "PUBLIC_ONLY"};var InternalServerException = class _InternalServerException extends MWAAServiceException { static { __name(this, "InternalServerException"); } name = "InternalServerException"; $fault = "server"; /** * @internal */ constructor(opts) { super({ name: "InternalServerException", $fault: "server", ...opts }); Object.setPrototypeOf(this, _InternalServerException.prototype); }};var ValidationException = class _ValidationException extends MWAAServiceException { static { __name(this, "ValidationException"); } name = "ValidationException"; $fault = "client"; /** * @internal */ constructor(opts) { super({ name: "ValidationException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _ValidationException.prototype); }};var UpdateStatus = { FAILED: "FAILED", PENDING: "PENDING", SUCCESS: "SUCCESS"};var WorkerReplacementStrategy = { FORCED: "FORCED", GRACEFUL: "GRACEFUL"};var EnvironmentStatus = { AVAILABLE: "AVAILABLE", CREATE_FAILED: "CREATE_FAILED", CREATING: "CREATING", CREATING_SNAPSHOT: "CREATING_SNAPSHOT", DELETED: "DELETED", DELETING: "DELETING", MAINTENANCE: "MAINTENANCE", PENDING: "PENDING", ROLLING_BACK: "ROLLING_BACK", UNAVAILABLE: "UNAVAILABLE", UPDATE_FAILED: "UPDATE_FAILED", UPDATING: "UPDATING"};var RestApiMethod = { DELETE: "DELETE", GET: "GET", PATCH: "PATCH", POST: "POST", PUT: "PUT"};var RestApiClientException = class _RestApiClientException extends MWAAServiceException { static { __name(this, "RestApiClientException"); } name = "RestApiClientException"; $fault = "client"; /** * <p>The HTTP status code returned by the Apache Airflow REST API call.</p> * @public */ RestApiStatusCode; /** * <p>The error response data from the Apache Airflow REST API call, provided as a JSON * object.</p> * @public */ RestApiResponse; /** * @internal */ constructor(opts) { super({ name: "RestApiClientException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _RestApiClientException.prototype); this.RestApiStatusCode = opts.RestApiStatusCode; this.RestApiResponse = opts.RestApiResponse; }};var RestApiServerException = class _RestApiServerException extends MWAAServiceException { static { __name(this, "RestApiServerException"); } name = "RestApiServerException"; $fault = "client"; /** * <p>The HTTP status code returned by the Apache Airflow REST API call.</p> * @public */ RestApiStatusCode; /** * <p>The error response data from the Apache Airflow REST API call, provided as a JSON * object.</p> * @public */ RestApiResponse; /** * @internal */ constructor(opts) { super({ name: "RestApiServerException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _RestApiServerException.prototype); this.RestApiStatusCode = opts.RestApiStatusCode; this.RestApiResponse = opts.RestApiResponse; }};var Unit = { BITS: "Bits", BITS_PER_SECOND: "Bits/Second", BYTES: "Bytes", BYTES_PER_SECOND: "Bytes/Second", COUNT: "Count", COUNT_PER_SECOND: "Count/Second", GIGABITS: "Gigabits", GIGABITS_PER_SECOND: "Gigabits/Second", GIGABYTES: "Gigabytes", GIGABYTES_PER_SECOND: "Gigabytes/Second", KILOBITS: "Kilobits", KILOBITS_PER_SECOND: "Kilobits/Second", KILOBYTES: "Kilobytes", KILOBYTES_PER_SECOND: "Kilobytes/Second", MEGABITS: "Megabits", MEGABITS_PER_SECOND: "Megabits/Second", MEGABYTES: "Megabytes", MEGABYTES_PER_SECOND: "Megabytes/Second", MICROSECONDS: "Microseconds", MILLISECONDS: "Milliseconds", NONE: "None", PERCENT: "Percent", SECONDS: "Seconds", TERABITS: "Terabits", TERABITS_PER_SECOND: "Terabits/Second", TERABYTES: "Terabytes", TERABYTES_PER_SECOND: "Terabytes/Second"};var CreateCliTokenResponseFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({ ...obj, ...obj.CliToken && { CliToken: import_smithy_client.SENSITIVE_STRING }}), "CreateCliTokenResponseFilterSensitiveLog");var CreateEnvironmentInputFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({ ...obj, ...obj.AirflowConfigurationOptions && { AirflowConfigurationOptions: import_smithy_client.SENSITIVE_STRING }}), "CreateEnvironmentInputFilterSensitiveLog");var CreateWebLoginTokenResponseFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({ ...obj, ...obj.WebToken && { WebToken: import_smithy_client.SENSITIVE_STRING }}), "CreateWebLoginTokenResponseFilterSensitiveLog");var EnvironmentFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({ ...obj, ...obj.AirflowConfigurationOptions && { AirflowConfigurationOptions: import_smithy_client.SENSITIVE_STRING }}), "EnvironmentFilterSensitiveLog");var GetEnvironmentOutputFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({ ...obj, ...obj.Environment && { Environment: EnvironmentFilterSensitiveLog(obj.Environment) }}), "GetEnvironmentOutputFilterSensitiveLog");var InvokeRestApiRequestFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({ ...obj, ...obj.Body && { Body: import_smithy_client.SENSITIVE_STRING }}), "InvokeRestApiRequestFilterSensitiveLog");var InvokeRestApiResponseFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({ ...obj, ...obj.RestApiResponse && { RestApiResponse: import_smithy_client.SENSITIVE_STRING }}), "InvokeRestApiResponseFilterSensitiveLog");var UpdateEnvironmentInputFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({ ...obj, ...obj.AirflowConfigurationOptions && { AirflowConfigurationOptions: import_smithy_client.SENSITIVE_STRING }}), "UpdateEnvironmentInputFilterSensitiveLog"); // src/protocols/Aws_restJson1.tsvar import_core2 = require("@aws-sdk/core"); var se_CreateCliTokenCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/clitoken/{Name}"); b.p("Name", () => input.Name, "{Name}", false); let body; let { hostname: resolvedHostname } = await context.endpoint(); if (context.disableHostPrefix !== true) { resolvedHostname = "env." + resolvedHostname; if (!(0, import_protocol_http.isValidHostname)(resolvedHostname)) { throw new Error("ValidationError: prefixed hostname must be hostname compatible."); } } b.hn(resolvedHostname); b.m("POST").h(headers).b(body); return b.build();}, "se_CreateCliTokenCommand");var se_CreateEnvironmentCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = { "content-type": "application/json" }; b.bp("/environments/{Name}"); b.p("Name", () => input.Name, "{Name}", false); let body; body = JSON.stringify( (0, import_smithy_client.take)(input, { AirflowConfigurationOptions: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "AirflowConfigurationOptions"), AirflowVersion: [], DagS3Path: [], EndpointManagement: [], EnvironmentClass: [], ExecutionRoleArn: [], KmsKey: [], LoggingConfiguration: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "LoggingConfiguration"), MaxWebservers: [], MaxWorkers: [], MinWebservers: [], MinWorkers: [], NetworkConfiguration: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "NetworkConfiguration"), PluginsS3ObjectVersion: [], PluginsS3Path: [], RequirementsS3ObjectVersion: [], RequirementsS3Path: [], Schedulers: [], SourceBucketArn: [], StartupScriptS3ObjectVersion: [], StartupScriptS3Path: [], Tags: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "Tags"), WebserverAccessMode: [], WeeklyMaintenanceWindowStart: [] }) ); let { hostname: resolvedHostname } = await context.endpoint(); if (context.disableHostPrefix !== true) { resolvedHostname = "api." + resolvedHostname; if (!(0, import_protocol_http.isValidHostname)(resolvedHostname)) { throw new Error("ValidationError: prefixed hostname must be hostname compatible."); } } b.hn(resolvedHostname); b.m("PUT").h(headers).b(body); return b.build();}, "se_CreateEnvironmentCommand");var se_CreateWebLoginTokenCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/webtoken/{Name}"); b.p("Name", () => input.Name, "{Name}", false); let body; let { hostname: resolvedHostname } = await context.endpoint(); if (context.disableHostPrefix !== true) { resolvedHostname = "env." + resolvedHostname; if (!(0, import_protocol_http.isValidHostname)(resolvedHostname)) { throw new Error("ValidationError: prefixed hostname must be hostname compatible."); } } b.hn(resolvedHostname); b.m("POST").h(headers).b(body); return b.build();}, "se_CreateWebLoginTokenCommand");var se_DeleteEnvironmentCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/environments/{Name}"); b.p("Name", () => input.Name, "{Name}", false); let body; let { hostname: resolvedHostname } = await context.endpoint(); if (context.disableHostPrefix !== true) { resolvedHostname = "api." + resolvedHostname; if (!(0, import_protocol_http.isValidHostname)(resolvedHostname)) { throw new Error("ValidationError: prefixed hostname must be hostname compatible."); } } b.hn(resolvedHostname); b.m("DELETE").h(headers).b(body); return b.build();}, "se_DeleteEnvironmentCommand");var se_GetEnvironmentCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/environments/{Name}"); b.p("Name", () => input.Name, "{Name}", false); let body; let { hostname: resolvedHostname } = await context.endpoint(); if (context.disableHostPrefix !== true) { resolvedHostname = "api." + resolvedHostname; if (!(0, import_protocol_http.isValidHostname)(resolvedHostname)) { throw new Error("ValidationError: prefixed hostname must be hostname compatible."); } } b.hn(resolvedHostname); b.m("GET").h(headers).b(body); return b.build();}, "se_GetEnvironmentCommand");var se_InvokeRestApiCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = { "content-type": "application/json" }; b.bp("/restapi/{Name}"); b.p("Name", () => input.Name, "{Name}", false); let body; body = JSON.stringify( (0, import_smithy_client.take)(input, { Body: /* @__PURE__ */ __name((_) => se_RestApiRequestBody(_, context), "Body"), Method: [], Path: [], QueryParameters: /* @__PURE__ */ __name((_) => se_Document(_, context), "QueryParameters") }) ); let { hostname: resolvedHostname } = await context.endpoint(); if (context.disableHostPrefix !== true) { resolvedHostname = "env." + resolvedHostname; if (!(0, import_protocol_http.isValidHostname)(resolvedHostname)) { throw new Error("ValidationError: prefixed hostname must be hostname compatible."); } } b.hn(resolvedHostname); b.m("POST").h(headers).b(body); return b.build();}, "se_InvokeRestApiCommand");var se_ListEnvironmentsCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/environments"); const query = (0, import_smithy_client.map)({ [_NT]: [, input[_NT]], [_MR]: [() => input.MaxResults !== void 0, () => input[_MR].toString()] }); let body; let { hostname: resolvedHostname } = await context.endpoint(); if (context.disableHostPrefix !== true) { resolvedHostname = "api." + resolvedHostname; if (!(0, import_protocol_http.isValidHostname)(resolvedHostname)) { throw new Error("ValidationError: prefixed hostname must be hostname compatible."); } } b.hn(resolvedHostname); b.m("GET").h(headers).q(query).b(body); return b.build();}, "se_ListEnvironmentsCommand");var se_ListTagsForResourceCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/tags/{ResourceArn}"); b.p("ResourceArn", () => input.ResourceArn, "{ResourceArn}", false); let body; let { hostname: resolvedHostname } = await context.endpoint(); if (context.disableHostPrefix !== true) { resolvedHostname = "api." + resolvedHostname; if (!(0, import_protocol_http.isValidHostname)(resolvedHostname)) { throw new Error("ValidationError: prefixed hostname must be hostname compatible."); } } b.hn(resolvedHostname); b.m("GET").h(headers).b(body); return b.build();}, "se_ListTagsForResourceCommand");var se_PublishMetricsCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = { "content-type": "application/json" }; b.bp("/metrics/environments/{EnvironmentName}"); b.p("EnvironmentName", () => input.EnvironmentName, "{EnvironmentName}", false); let body; body = JSON.stringify( (0, import_smithy_client.take)(input, { MetricData: /* @__PURE__ */ __name((_) => se_MetricData(_, context), "MetricData") }) ); let { hostname: resolvedHostname } = await context.endpoint(); if (context.disableHostPrefix !== true) { resolvedHostname = "ops." + resolvedHostname; if (!(0, import_protocol_http.isValidHostname)(resolvedHostname)) { throw new Error("ValidationError: prefixed hostname must be hostname compatible."); } } b.hn(resolvedHostname); b.m("POST").h(headers).b(body); return b.build();}, "se_PublishMetricsCommand");var se_TagResourceCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = { "content-type": "application/json" }; b.bp("/tags/{ResourceArn}"); b.p("ResourceArn", () => input.ResourceArn, "{ResourceArn}", false); let body; body = JSON.stringify( (0, import_smithy_client.take)(input, { Tags: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "Tags") }) ); let { hostname: resolvedHostname } = await context.endpoint(); if (context.disableHostPrefix !== true) { resolvedHostname = "api." + resolvedHostname; if (!(0, import_protocol_http.isValidHostname)(resolvedHostname)) { throw new Error("ValidationError: prefixed hostname must be hostname compatible."); } } b.hn(resolvedHostname); b.m("POST").h(headers).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 = {}; b.bp("/tags/{ResourceArn}"); b.p("ResourceArn", () => input.ResourceArn, "{ResourceArn}", false); const query = (0, import_smithy_client.map)({ [_tK]: [(0, import_smithy_client.expectNonNull)(input.tagKeys, `tagKeys`) != null, () => input[_tK] || []] }); let body; let { hostname: resolvedHostname } = await context.endpoint(); if (context.disableHostPrefix !== true) { resolvedHostname = "api." + resolvedHostname; if (!(0, import_protocol_http.isValidHostname)(resolvedHostname)) { throw new Error("ValidationError: prefixed hostname must be hostname compatible."); } } b.hn(resolvedHostname); b.m("DELETE").h(headers).q(query).b(body); return b.build();}, "se_UntagResourceCommand");var se_UpdateEnvironmentCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = { "content-type": "application/json" }; b.bp("/environments/{Name}"); b.p("Name", () => input.Name, "{Name}", false); let body; body = JSON.stringify( (0, import_smithy_client.take)(input, { AirflowConfigurationOptions: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "AirflowConfigurationOptions"), AirflowVersion: [], DagS3Path: [], EnvironmentClass: [], ExecutionRoleArn: [], LoggingConfiguration: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "LoggingConfiguration"), MaxWebservers: [], MaxWorkers: [], MinWebservers: [], MinWorkers: [], NetworkConfiguration: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "NetworkConfiguration"), PluginsS3ObjectVersion: [], PluginsS3Path: [], RequirementsS3ObjectVersion: [], RequirementsS3Path: [], Schedulers: [], SourceBucketArn: [], StartupScriptS3ObjectVersion: [], StartupScriptS3Path: [], WebserverAccessMode: [], WeeklyMaintenanceWindowStart: [], WorkerReplacementStrategy: [] }) ); let { hostname: resolvedHostname } = await context.endpoint(); if (context.disableHostPrefix !== true) { resolvedHostname = "api." + resolvedHostname; if (!(0, import_protocol_http.isValidHostname)(resolvedHostname)) { throw new Error("ValidationError: prefixed hostname must be hostname compatible."); } } b.hn(resolvedHostname); b.m("PATCH").h(headers).b(body); return b.build();}, "se_UpdateEnvironmentCommand");var de_CreateCliTokenCommand = /* @__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, { CliToken: import_smithy_client.expectString, WebServerHostname: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_CreateCliTokenCommand");var de_CreateEnvironmentCommand = /* @__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, { Arn: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_CreateEnvironmentCommand");var de_CreateWebLoginTokenCommand = /* @__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, { AirflowIdentity: import_smithy_client.expectString, IamIdentity: import_smithy_client.expectString, WebServerHostname: import_smithy_client.expectString, WebToken: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_CreateWebLoginTokenCommand");var de_DeleteEnvironmentCommand = /* @__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_DeleteEnvironmentCommand");var de_GetEnvironmentCommand = /* @__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, { Environment: /* @__PURE__ */ __name((_) => de_Environment(_, context), "Environment") }); Object.assign(contents, doc); return contents;}, "de_GetEnvironmentCommand");var de_InvokeRestApiCommand = /* @__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, { RestApiResponse: /* @__PURE__ */ __name((_) => de_RestApiResponse(_, context), "RestApiResponse"), RestApiStatusCode: import_smithy_client.expectInt32 }); Object.assign(contents, doc); return contents;}, "de_InvokeRestApiCommand");var de_ListEnvironmentsCommand = /* @__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, { Environments: import_smithy_client._json, NextToken: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_ListEnvironmentsCommand");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_PublishMetricsCommand = /* @__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_PublishMetricsCommand");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_UpdateEnvironmentCommand = /* @__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, { Arn: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_UpdateEnvironmentCommand");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 "ResourceNotFoundException": case "com.amazonaws.mwaa#ResourceNotFoundException": throw await de_ResourceNotFoundExceptionRes(parsedOutput, context); case "InternalServerException": case "com.amazonaws.mwaa#InternalServerException": throw await de_InternalServerExceptionRes(parsedOutput, context); case "ValidationException": case "com.amazonaws.mwaa#ValidationException": throw await de_ValidationExceptionRes(parsedOutput, context); case "AccessDeniedException": case "com.amazonaws.mwaa#AccessDeniedException": throw await de_AccessDeniedExceptionRes(parsedOutput, context); case "RestApiClientException": case "com.amazonaws.mwaa#RestApiClientException": throw await de_RestApiClientExceptionRes(parsedOutput, context); case "RestApiServerException": case "com.amazonaws.mwaa#RestApiServerException": throw await de_RestApiServerExceptionRes(parsedOutput, context); default: const parsedBody = parsedOutput.body; return throwDefaultError({ output, parsedBody, errorCode }); }}, "de_CommandError");var throwDefaultError = (0, import_smithy_client.withBaseException)(MWAAServiceException);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_InternalServerExceptionRes = /* @__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 InternalServerException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_InternalServerExceptionRes");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_RestApiClientExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { RestApiResponse: /* @__PURE__ */ __name((_) => de_RestApiResponse(_, context), "RestApiResponse"), RestApiStatusCode: import_smithy_client.expectInt32 }); Object.assign(contents, doc); const exception = new RestApiClientException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_RestApiClientExceptionRes");var de_RestApiServerExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { RestApiResponse: /* @__PURE__ */ __name((_) => de_RestApiResponse(_, context), "RestApiResponse"), RestApiStatusCode: import_smithy_client.expectInt32 }); Object.assign(contents, doc); const exception = new RestApiServerException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_RestApiServerExceptionRes");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 se_MetricData = /* @__PURE__ */ __name((input, context) => { return input.filter((e) => e != null).map((entry) => { return se_MetricDatum(entry, context); });}, "se_MetricData");var se_MetricDatum = /* @__PURE__ */ __name((input, context) => { return (0, import_smithy_client.take)(input, { Dimensions: import_smithy_client._json, MetricName: [], StatisticValues: /* @__PURE__ */ __name((_) => se_StatisticSet(_, context), "StatisticValues"), Timestamp: /* @__PURE__ */ __name((_) => _.getTime() / 1e3, "Timestamp"), Unit: [], Value: import_smithy_client.serializeFloat });}, "se_MetricDatum");var se_RestApiRequestBody = /* @__PURE__ */ __name((input, context) => { return input;}, "se_RestApiRequestBody");var se_StatisticSet = /* @__PURE__ */ __name((input, context) => { return (0, import_smithy_client.take)(input, { Maximum: import_smithy_client.serializeFloat, Minimum: import_smithy_client.serializeFloat, SampleCount: [], Sum: import_smithy_client.serializeFloat });}, "se_StatisticSet");var se_Document = /* @__PURE__ */ __name((input, context) => { return input;}, "se_Document");var de_Environment = /* @__PURE__ */ __name((output, context) => { return (0, import_smithy_client.take)(output, { AirflowConfigurationOptions: import_smithy_client._json, AirflowVersion: import_smithy_client.expectString, Arn: import_smithy_client.expectString, CeleryExecutorQueue: import_smithy_client.expectString, CreatedAt: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "CreatedAt"), DagS3Path: import_smithy_client.expectString, DatabaseVpcEndpointService: import_smithy_client.expectString, EndpointManagement: import_smithy_client.expectString, EnvironmentClass: import_smithy_client.expectString, ExecutionRoleArn: import_smithy_client.expectString, KmsKey: import_smithy_client.expectString, LastUpdate: /* @__PURE__ */ __name((_) => de_LastUpdate(_, context), "LastUpdate"), LoggingConfiguration: import_smithy_client._json, MaxWebservers: import_smithy_client.expectInt32, MaxWorkers: import_smithy_client.expectInt32, MinWebservers: import_smithy_client.expectInt32, MinWorkers: import_smithy_client.expectInt32, Name: import_smithy_client.expectString, NetworkConfiguration: import_smithy_client._json, PluginsS3ObjectVersion: import_smithy_client.expectString, PluginsS3Path: import_smithy_client.expectString, RequirementsS3ObjectVersion: import_smithy_client.expectString, RequirementsS3Path: import_smithy_client.expectString, Schedulers: import_smithy_client.expectInt32, ServiceRoleArn: import_smithy_client.expectString, SourceBucketArn: import_smithy_client.expectString, StartupScriptS3ObjectVersion: import_smithy_client.expectString, StartupScriptS3Path: import_smithy_client.expectString, Status: import_smithy_client.expectString, Tags: import_smithy_client._json, WebserverAccessMode: import_smithy_client.expectString, WebserverUrl: import_smithy_client.expectString, WebserverVpcEndpointService: import_smithy_client.expectString, WeeklyMaintenanceWindowStart: import_smithy_client.expectString });}, "de_Environment");var de_LastUpdate = /* @__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"), Error: import_smithy_client._json, Source: import_smithy_client.expectString, Status: import_smithy_client.expectString, WorkerReplacementStrategy: import_smithy_client.expectString });}, "de_LastUpdate");var de_RestApiResponse = /* @__PURE__ */ __name((output, context) => { return output;}, "de_RestApiResponse");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 _MR = "MaxResults";var _NT = "NextToken";var _tK = "tagKeys"; // src/commands/CreateCliTokenCommand.tsvar CreateCliTokenCommand = 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("AmazonMWAA", "CreateCliToken", {}).n("MWAAClient", "CreateCliTokenCommand").f(void 0, CreateCliTokenResponseFilterSensitiveLog).ser(se_CreateCliTokenCommand).de(de_CreateCliTokenCommand).build() { static { __name(this, "CreateCliTokenCommand"); }}; // src/commands/CreateEnvironmentCommand.ts var CreateEnvironmentCommand = 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("AmazonMWAA", "CreateEnvironment", {}).n("MWAAClient", "CreateEnvironmentCommand").f(CreateEnvironmentInputFilterSensitiveLog, void 0).ser(se_CreateEnvironmentCommand).de(de_CreateEnvironmentCommand).build() { static { __name(this, "CreateEnvironmentCommand"); }}; // src/commands/CreateWebLoginTokenCommand.ts var CreateWebLoginTokenCommand = 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("AmazonMWAA", "CreateWebLoginToken", {}).n("MWAAClient", "CreateWebLoginTokenCommand").f(void 0, CreateWebLoginTokenResponseFilterSensitiveLog).ser(se_CreateWebLoginTokenCommand).de(de_CreateWebLoginTokenCommand).build() { static { __name(this, "CreateWebLoginTokenCommand"); }}; // src/commands/DeleteEnvironmentCommand.ts var DeleteEnvironmentCommand = 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("AmazonMWAA", "DeleteEnvironment", {}).n("MWAAClient", "DeleteEnvironmentCommand").f(void 0, void 0).ser(se_DeleteEnvironmentCommand).de(de_DeleteEnvironmentCommand).build() { static { __name(this, "DeleteEnvironmentCommand"); }}; // src/commands/GetEnvironmentCommand.ts var GetEnvironmentCommand = 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("AmazonMWAA", "GetEnvironment", {}).n("MWAAClient", "GetEnvironmentCommand").f(void 0, GetEnvironmentOutputFilterSensitiveLog).ser(se_GetEnvironmentCommand).de(de_GetEnvironmentCommand).build() { static { __name(this, "GetEnvironmentCommand"); }}; // src/commands/InvokeRestApiCommand.ts var InvokeRestApiCommand = 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("AmazonMWAA", "InvokeRestApi", {}).n("MWAAClient", "InvokeRestApiCommand").f(InvokeRestApiRequestFilterSensitiveLog, InvokeRestApiResponseFilterSensitiveLog).ser(se_InvokeRestApiCommand).de(de_InvokeRestApiCommand).build() { static { __name(this, "InvokeRestApiCommand"); }}; // src/commands/ListEnvironmentsCommand.ts var ListEnvironmentsCommand = 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("AmazonMWAA", "ListEnvironments", {}).n("MWAAClient", "ListEnvironmentsCommand").f(void 0, void 0).ser(se_ListEnvironmentsCommand).de(de_ListEnvironmentsCommand).build() { static { __name(this, "ListEnvironmentsCommand"); }}; // 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("AmazonMWAA", "ListTagsForResource", {}).n("MWAAClient", "ListTagsForResourceCommand").f(void 0, void 0).ser(se_ListTagsForResourceCommand).de(de_ListTagsForResourceCommand).build() { static { __name(this, "ListTagsForResourceCommand"); }}; // src/commands/PublishMetricsCommand.ts var PublishMetricsCommand = 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("AmazonMWAA", "PublishMetrics", {}).n("MWAAClient", "PublishMetricsCommand").f(void 0, void 0).ser(se_PublishMetricsCommand).de(de_PublishMetricsCommand).build() { static { __name(this, "PublishMetricsCommand"); }}; // 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("AmazonMWAA", "TagResource", {}).n("MWAAClient", "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("AmazonMWAA", "UntagResource", {}).n("MWAAClient", "UntagResourceCommand").f(void 0, void 0).ser(se_UntagResourceCommand).de(de_UntagResourceCommand).build() { static { __name(this, "UntagResourceCommand"); }}; // src/commands/UpdateEnvironmentCommand.ts var UpdateEnvironmentCommand = 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("AmazonMWAA", "UpdateEnvironment", {}).n("MWAAClient", "UpdateEnvironmentCommand").f(UpdateEnvironmentInputFilterSensitiveLog, void 0).ser(se_UpdateEnvironmentCommand).de(de_UpdateEnvironmentCommand).build() { static { __name(this, "UpdateEnvironmentCommand"); }}; // src/MWAA.tsvar commands = { CreateCliTokenCommand, CreateEnvironmentCommand, CreateWebLoginTokenCommand, DeleteEnvironmentCommand, GetEnvironmentCommand, InvokeRestApiCommand, ListEnvironmentsCommand, ListTagsForResourceCommand, PublishMetricsCommand, TagResourceCommand, UntagResourceCommand, UpdateEnvironmentCommand};var MWAA = class extends MWAAClient { static { __name(this, "MWAA"); }};(0, import_smithy_client.createAggregatedClient)(commands, MWAA); // src/pagination/ListEnvironmentsPaginator.ts var paginateListEnvironments = (0, import_core.createPaginator)(MWAAClient, ListEnvironmentsCommand, "NextToken", "NextToken", "MaxResults");// Annotate the CommonJS export names for ESM import in node: 0 && (module.exports = { MWAAServiceException, __Client, MWAAClient, MWAA, $Command, CreateCliTokenCommand, CreateEnvironmentCommand, CreateWebLoginTokenCommand, DeleteEnvironmentCommand, GetEnvironmentCommand, InvokeRestApiCommand, ListEnvironmentsCommand, ListTagsForResourceCommand, PublishMetricsCommand, TagResourceCommand, UntagResourceCommand, UpdateEnvironmentCommand, paginateListEnvironments, AccessDeniedException, ResourceNotFoundException, EndpointManagement, LoggingLevel, WebserverAccessMode, InternalServerException, ValidationException, UpdateStatus, WorkerReplacementStrategy, EnvironmentStatus, RestApiMethod, RestApiClientException, RestApiServerException, Unit, CreateCliTokenResponseFilterSensitiveLog, CreateEnvironmentInputFilterSensitiveLog, CreateWebLoginTokenResponseFilterSensitiveLog, EnvironmentFilterSensitiveLog, GetEnvironmentOutputFilterSensitiveLog, InvokeRestApiRequestFilterSensitiveLog, InvokeRestApiResponseFilterSensitiveLog, UpdateEnvironmentInputFilterSensitiveLog});