File Explorer

/proc/4/root/var/runtime/node_modules/@aws-sdk/client-networkmonitor/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.js45.3 KB · 1146 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,  AddressFamily: () => AddressFamily,  ConflictException: () => ConflictException,  CreateMonitorCommand: () => CreateMonitorCommand,  CreateProbeCommand: () => CreateProbeCommand,  DeleteMonitorCommand: () => DeleteMonitorCommand,  DeleteProbeCommand: () => DeleteProbeCommand,  GetMonitorCommand: () => GetMonitorCommand,  GetProbeCommand: () => GetProbeCommand,  InternalServerException: () => InternalServerException,  ListMonitorsCommand: () => ListMonitorsCommand,  ListTagsForResourceCommand: () => ListTagsForResourceCommand,  MonitorState: () => MonitorState,  NetworkMonitor: () => NetworkMonitor,  NetworkMonitorClient: () => NetworkMonitorClient,  NetworkMonitorServiceException: () => NetworkMonitorServiceException,  ProbeState: () => ProbeState,  Protocol: () => Protocol,  ResourceNotFoundException: () => ResourceNotFoundException,  ServiceQuotaExceededException: () => ServiceQuotaExceededException,  TagResourceCommand: () => TagResourceCommand,  ThrottlingException: () => ThrottlingException,  UntagResourceCommand: () => UntagResourceCommand,  UpdateMonitorCommand: () => UpdateMonitorCommand,  UpdateProbeCommand: () => UpdateProbeCommand,  ValidationException: () => ValidationException,  __Client: () => import_smithy_client.Client,  paginateListMonitors: () => paginateListMonitors});module.exports = __toCommonJS(index_exports); // src/NetworkMonitorClient.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: "networkmonitor"  });}, "resolveClientEndpointParameters");var commonParams = {  UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" },  Endpoint: { type: "builtInParams", name: "endpoint" },  Region: { type: "builtInParams", name: "region" },  UseDualStack: { type: "builtInParams", name: "useDualstackEndpoint" }}; // src/NetworkMonitorClient.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/NetworkMonitorClient.tsvar NetworkMonitorClient = class extends import_smithy_client.Client {  static {    __name(this, "NetworkMonitorClient");  }  /**   * The resolved configuration of NetworkMonitorClient class. This is resolved and normalized from the {@link NetworkMonitorClientConfig | 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.defaultNetworkMonitorHttpAuthSchemeParametersProvider,        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/NetworkMonitor.ts  // src/commands/CreateMonitorCommand.ts var import_middleware_serde = require("@smithy/middleware-serde");  // src/protocols/Aws_restJson1.tsvar import_core2 = require("@aws-sdk/core");  var import_uuid = require("uuid"); // src/models/NetworkMonitorServiceException.ts var NetworkMonitorServiceException = class _NetworkMonitorServiceException extends import_smithy_client.ServiceException {  static {    __name(this, "NetworkMonitorServiceException");  }  /**   * @internal   */  constructor(options) {    super(options);    Object.setPrototypeOf(this, _NetworkMonitorServiceException.prototype);  }}; // src/models/models_0.tsvar AccessDeniedException = class _AccessDeniedException extends NetworkMonitorServiceException {  static {    __name(this, "AccessDeniedException");  }  name = "AccessDeniedException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "AccessDeniedException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _AccessDeniedException.prototype);  }};var AddressFamily = {  IPV4: "IPV4",  IPV6: "IPV6"};var ConflictException = class _ConflictException extends NetworkMonitorServiceException {  static {    __name(this, "ConflictException");  }  name = "ConflictException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "ConflictException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _ConflictException.prototype);  }};var Protocol = {  ICMP: "ICMP",  TCP: "TCP"};var MonitorState = {  ACTIVE: "ACTIVE",  DELETING: "DELETING",  ERROR: "ERROR",  INACTIVE: "INACTIVE",  PENDING: "PENDING"};var InternalServerException = class _InternalServerException extends NetworkMonitorServiceException {  static {    __name(this, "InternalServerException");  }  name = "InternalServerException";  $fault = "server";  $retryable = {};  /**   * @internal   */  constructor(opts) {    super({      name: "InternalServerException",      $fault: "server",      ...opts    });    Object.setPrototypeOf(this, _InternalServerException.prototype);  }};var ServiceQuotaExceededException = class _ServiceQuotaExceededException extends NetworkMonitorServiceException {  static {    __name(this, "ServiceQuotaExceededException");  }  name = "ServiceQuotaExceededException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "ServiceQuotaExceededException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _ServiceQuotaExceededException.prototype);  }};var ThrottlingException = class _ThrottlingException extends NetworkMonitorServiceException {  static {    __name(this, "ThrottlingException");  }  name = "ThrottlingException";  $fault = "client";  $retryable = {    throttling: true  };  /**   * @internal   */  constructor(opts) {    super({      name: "ThrottlingException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _ThrottlingException.prototype);  }};var ValidationException = class _ValidationException extends NetworkMonitorServiceException {  static {    __name(this, "ValidationException");  }  name = "ValidationException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "ValidationException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _ValidationException.prototype);  }};var ProbeState = {  ACTIVE: "ACTIVE",  DELETED: "DELETED",  DELETING: "DELETING",  ERROR: "ERROR",  INACTIVE: "INACTIVE",  PENDING: "PENDING"};var ResourceNotFoundException = class _ResourceNotFoundException extends NetworkMonitorServiceException {  static {    __name(this, "ResourceNotFoundException");  }  name = "ResourceNotFoundException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "ResourceNotFoundException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _ResourceNotFoundException.prototype);  }}; // src/protocols/Aws_restJson1.tsvar se_CreateMonitorCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {    "content-type": "application/json"  };  b.bp("/monitors");  let body;  body = JSON.stringify(    (0, import_smithy_client.take)(input, {      aggregationPeriod: [],      clientToken: [true, (_) => _ ?? (0, import_uuid.v4)()],      monitorName: [],      probes: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "probes"),      tags: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "tags")    })  );  b.m("POST").h(headers).b(body);  return b.build();}, "se_CreateMonitorCommand");var se_CreateProbeCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {    "content-type": "application/json"  };  b.bp("/monitors/{monitorName}/probes");  b.p("monitorName", () => input.monitorName, "{monitorName}", false);  let body;  body = JSON.stringify(    (0, import_smithy_client.take)(input, {      clientToken: [true, (_) => _ ?? (0, import_uuid.v4)()],      probe: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "probe"),      tags: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "tags")    })  );  b.m("POST").h(headers).b(body);  return b.build();}, "se_CreateProbeCommand");var se_DeleteMonitorCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/monitors/{monitorName}");  b.p("monitorName", () => input.monitorName, "{monitorName}", false);  let body;  b.m("DELETE").h(headers).b(body);  return b.build();}, "se_DeleteMonitorCommand");var se_DeleteProbeCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/monitors/{monitorName}/probes/{probeId}");  b.p("monitorName", () => input.monitorName, "{monitorName}", false);  b.p("probeId", () => input.probeId, "{probeId}", false);  let body;  b.m("DELETE").h(headers).b(body);  return b.build();}, "se_DeleteProbeCommand");var se_GetMonitorCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/monitors/{monitorName}");  b.p("monitorName", () => input.monitorName, "{monitorName}", false);  let body;  b.m("GET").h(headers).b(body);  return b.build();}, "se_GetMonitorCommand");var se_GetProbeCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/monitors/{monitorName}/probes/{probeId}");  b.p("monitorName", () => input.monitorName, "{monitorName}", false);  b.p("probeId", () => input.probeId, "{probeId}", false);  let body;  b.m("GET").h(headers).b(body);  return b.build();}, "se_GetProbeCommand");var se_ListMonitorsCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/monitors");  const query = (0, import_smithy_client.map)({    [_nT]: [, input[_nT]],    [_mR]: [() => input.maxResults !== void 0, () => input[_mR].toString()],    [_s]: [, input[_s]]  });  let body;  b.m("GET").h(headers).q(query).b(body);  return b.build();}, "se_ListMonitorsCommand");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;  b.m("GET").h(headers).b(body);  return b.build();}, "se_ListTagsForResourceCommand");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")    })  );  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;  b.m("DELETE").h(headers).q(query).b(body);  return b.build();}, "se_UntagResourceCommand");var se_UpdateMonitorCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {    "content-type": "application/json"  };  b.bp("/monitors/{monitorName}");  b.p("monitorName", () => input.monitorName, "{monitorName}", false);  let body;  body = JSON.stringify(    (0, import_smithy_client.take)(input, {      aggregationPeriod: []    })  );  b.m("PATCH").h(headers).b(body);  return b.build();}, "se_UpdateMonitorCommand");var se_UpdateProbeCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {    "content-type": "application/json"  };  b.bp("/monitors/{monitorName}/probes/{probeId}");  b.p("monitorName", () => input.monitorName, "{monitorName}", false);  b.p("probeId", () => input.probeId, "{probeId}", false);  let body;  body = JSON.stringify(    (0, import_smithy_client.take)(input, {      destination: [],      destinationPort: [],      packetSize: [],      protocol: [],      state: []    })  );  b.m("PATCH").h(headers).b(body);  return b.build();}, "se_UpdateProbeCommand");var de_CreateMonitorCommand = /* @__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, {    aggregationPeriod: import_smithy_client.expectLong,    monitorArn: import_smithy_client.expectString,    monitorName: import_smithy_client.expectString,    state: import_smithy_client.expectString,    tags: import_smithy_client._json  });  Object.assign(contents, doc);  return contents;}, "de_CreateMonitorCommand");var de_CreateProbeCommand = /* @__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, {    addressFamily: import_smithy_client.expectString,    createdAt: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "createdAt"),    destination: import_smithy_client.expectString,    destinationPort: import_smithy_client.expectInt32,    modifiedAt: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "modifiedAt"),    packetSize: import_smithy_client.expectInt32,    probeArn: import_smithy_client.expectString,    probeId: import_smithy_client.expectString,    protocol: import_smithy_client.expectString,    sourceArn: import_smithy_client.expectString,    state: import_smithy_client.expectString,    tags: import_smithy_client._json,    vpcId: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_CreateProbeCommand");var de_DeleteMonitorCommand = /* @__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_DeleteMonitorCommand");var de_DeleteProbeCommand = /* @__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_DeleteProbeCommand");var de_GetMonitorCommand = /* @__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, {    aggregationPeriod: import_smithy_client.expectLong,    createdAt: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "createdAt"),    modifiedAt: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "modifiedAt"),    monitorArn: import_smithy_client.expectString,    monitorName: import_smithy_client.expectString,    probes: /* @__PURE__ */ __name((_) => de_ProbeList(_, context), "probes"),    state: import_smithy_client.expectString,    tags: import_smithy_client._json  });  Object.assign(contents, doc);  return contents;}, "de_GetMonitorCommand");var de_GetProbeCommand = /* @__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, {    addressFamily: import_smithy_client.expectString,    createdAt: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "createdAt"),    destination: import_smithy_client.expectString,    destinationPort: import_smithy_client.expectInt32,    modifiedAt: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "modifiedAt"),    packetSize: import_smithy_client.expectInt32,    probeArn: import_smithy_client.expectString,    probeId: import_smithy_client.expectString,    protocol: import_smithy_client.expectString,    sourceArn: import_smithy_client.expectString,    state: import_smithy_client.expectString,    tags: import_smithy_client._json,    vpcId: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_GetProbeCommand");var de_ListMonitorsCommand = /* @__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, {    monitors: import_smithy_client._json,    nextToken: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_ListMonitorsCommand");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_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_UpdateMonitorCommand = /* @__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, {    aggregationPeriod: import_smithy_client.expectLong,    monitorArn: import_smithy_client.expectString,    monitorName: import_smithy_client.expectString,    state: import_smithy_client.expectString,    tags: import_smithy_client._json  });  Object.assign(contents, doc);  return contents;}, "de_UpdateMonitorCommand");var de_UpdateProbeCommand = /* @__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, {    addressFamily: import_smithy_client.expectString,    createdAt: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "createdAt"),    destination: import_smithy_client.expectString,    destinationPort: import_smithy_client.expectInt32,    modifiedAt: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "modifiedAt"),    packetSize: import_smithy_client.expectInt32,    probeArn: import_smithy_client.expectString,    probeId: import_smithy_client.expectString,    protocol: import_smithy_client.expectString,    sourceArn: import_smithy_client.expectString,    state: import_smithy_client.expectString,    tags: import_smithy_client._json,    vpcId: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_UpdateProbeCommand");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.networkmonitor#AccessDeniedException":      throw await de_AccessDeniedExceptionRes(parsedOutput, context);    case "ConflictException":    case "com.amazonaws.networkmonitor#ConflictException":      throw await de_ConflictExceptionRes(parsedOutput, context);    case "InternalServerException":    case "com.amazonaws.networkmonitor#InternalServerException":      throw await de_InternalServerExceptionRes(parsedOutput, context);    case "ServiceQuotaExceededException":    case "com.amazonaws.networkmonitor#ServiceQuotaExceededException":      throw await de_ServiceQuotaExceededExceptionRes(parsedOutput, context);    case "ThrottlingException":    case "com.amazonaws.networkmonitor#ThrottlingException":      throw await de_ThrottlingExceptionRes(parsedOutput, context);    case "ValidationException":    case "com.amazonaws.networkmonitor#ValidationException":      throw await de_ValidationExceptionRes(parsedOutput, context);    case "ResourceNotFoundException":    case "com.amazonaws.networkmonitor#ResourceNotFoundException":      throw await de_ResourceNotFoundExceptionRes(parsedOutput, context);    default:      const parsedBody = parsedOutput.body;      return throwDefaultError({        output,        parsedBody,        errorCode      });  }}, "de_CommandError");var throwDefaultError = (0, import_smithy_client.withBaseException)(NetworkMonitorServiceException);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_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_ServiceQuotaExceededExceptionRes = /* @__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 ServiceQuotaExceededException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_ServiceQuotaExceededExceptionRes");var de_ThrottlingExceptionRes = /* @__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 ThrottlingException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_ThrottlingExceptionRes");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_Probe = /* @__PURE__ */ __name((output, context) => {  return (0, import_smithy_client.take)(output, {    addressFamily: import_smithy_client.expectString,    createdAt: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "createdAt"),    destination: import_smithy_client.expectString,    destinationPort: import_smithy_client.expectInt32,    modifiedAt: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "modifiedAt"),    packetSize: import_smithy_client.expectInt32,    probeArn: import_smithy_client.expectString,    probeId: import_smithy_client.expectString,    protocol: import_smithy_client.expectString,    sourceArn: import_smithy_client.expectString,    state: import_smithy_client.expectString,    tags: import_smithy_client._json,    vpcId: import_smithy_client.expectString  });}, "de_Probe");var de_ProbeList = /* @__PURE__ */ __name((output, context) => {  const retVal = (output || []).filter((e) => e != null).map((entry) => {    return de_Probe(entry, context);  });  return retVal;}, "de_ProbeList");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 _s = "state";var _tK = "tagKeys"; // src/commands/CreateMonitorCommand.tsvar CreateMonitorCommand = 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("NetworkMonitor", "CreateMonitor", {}).n("NetworkMonitorClient", "CreateMonitorCommand").f(void 0, void 0).ser(se_CreateMonitorCommand).de(de_CreateMonitorCommand).build() {  static {    __name(this, "CreateMonitorCommand");  }}; // src/commands/CreateProbeCommand.ts   var CreateProbeCommand = 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("NetworkMonitor", "CreateProbe", {}).n("NetworkMonitorClient", "CreateProbeCommand").f(void 0, void 0).ser(se_CreateProbeCommand).de(de_CreateProbeCommand).build() {  static {    __name(this, "CreateProbeCommand");  }}; // src/commands/DeleteMonitorCommand.ts   var DeleteMonitorCommand = 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("NetworkMonitor", "DeleteMonitor", {}).n("NetworkMonitorClient", "DeleteMonitorCommand").f(void 0, void 0).ser(se_DeleteMonitorCommand).de(de_DeleteMonitorCommand).build() {  static {    __name(this, "DeleteMonitorCommand");  }}; // src/commands/DeleteProbeCommand.ts   var DeleteProbeCommand = 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("NetworkMonitor", "DeleteProbe", {}).n("NetworkMonitorClient", "DeleteProbeCommand").f(void 0, void 0).ser(se_DeleteProbeCommand).de(de_DeleteProbeCommand).build() {  static {    __name(this, "DeleteProbeCommand");  }}; // src/commands/GetMonitorCommand.ts   var GetMonitorCommand = 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("NetworkMonitor", "GetMonitor", {}).n("NetworkMonitorClient", "GetMonitorCommand").f(void 0, void 0).ser(se_GetMonitorCommand).de(de_GetMonitorCommand).build() {  static {    __name(this, "GetMonitorCommand");  }}; // src/commands/GetProbeCommand.ts   var GetProbeCommand = 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("NetworkMonitor", "GetProbe", {}).n("NetworkMonitorClient", "GetProbeCommand").f(void 0, void 0).ser(se_GetProbeCommand).de(de_GetProbeCommand).build() {  static {    __name(this, "GetProbeCommand");  }}; // src/commands/ListMonitorsCommand.ts   var ListMonitorsCommand = 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("NetworkMonitor", "ListMonitors", {}).n("NetworkMonitorClient", "ListMonitorsCommand").f(void 0, void 0).ser(se_ListMonitorsCommand).de(de_ListMonitorsCommand).build() {  static {    __name(this, "ListMonitorsCommand");  }}; // 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("NetworkMonitor", "ListTagsForResource", {}).n("NetworkMonitorClient", "ListTagsForResourceCommand").f(void 0, void 0).ser(se_ListTagsForResourceCommand).de(de_ListTagsForResourceCommand).build() {  static {    __name(this, "ListTagsForResourceCommand");  }}; // 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("NetworkMonitor", "TagResource", {}).n("NetworkMonitorClient", "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("NetworkMonitor", "UntagResource", {}).n("NetworkMonitorClient", "UntagResourceCommand").f(void 0, void 0).ser(se_UntagResourceCommand).de(de_UntagResourceCommand).build() {  static {    __name(this, "UntagResourceCommand");  }}; // src/commands/UpdateMonitorCommand.ts   var UpdateMonitorCommand = 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("NetworkMonitor", "UpdateMonitor", {}).n("NetworkMonitorClient", "UpdateMonitorCommand").f(void 0, void 0).ser(se_UpdateMonitorCommand).de(de_UpdateMonitorCommand).build() {  static {    __name(this, "UpdateMonitorCommand");  }}; // src/commands/UpdateProbeCommand.ts   var UpdateProbeCommand = 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("NetworkMonitor", "UpdateProbe", {}).n("NetworkMonitorClient", "UpdateProbeCommand").f(void 0, void 0).ser(se_UpdateProbeCommand).de(de_UpdateProbeCommand).build() {  static {    __name(this, "UpdateProbeCommand");  }}; // src/NetworkMonitor.tsvar commands = {  CreateMonitorCommand,  CreateProbeCommand,  DeleteMonitorCommand,  DeleteProbeCommand,  GetMonitorCommand,  GetProbeCommand,  ListMonitorsCommand,  ListTagsForResourceCommand,  TagResourceCommand,  UntagResourceCommand,  UpdateMonitorCommand,  UpdateProbeCommand};var NetworkMonitor = class extends NetworkMonitorClient {  static {    __name(this, "NetworkMonitor");  }};(0, import_smithy_client.createAggregatedClient)(commands, NetworkMonitor); // src/pagination/ListMonitorsPaginator.ts var paginateListMonitors = (0, import_core.createPaginator)(NetworkMonitorClient, ListMonitorsCommand, "nextToken", "nextToken", "maxResults");// Annotate the CommonJS export names for ESM import in node: 0 && (module.exports = {  NetworkMonitorServiceException,  __Client,  NetworkMonitorClient,  NetworkMonitor,  $Command,  CreateMonitorCommand,  CreateProbeCommand,  DeleteMonitorCommand,  DeleteProbeCommand,  GetMonitorCommand,  GetProbeCommand,  ListMonitorsCommand,  ListTagsForResourceCommand,  TagResourceCommand,  UntagResourceCommand,  UpdateMonitorCommand,  UpdateProbeCommand,  paginateListMonitors,  AccessDeniedException,  AddressFamily,  ConflictException,  Protocol,  MonitorState,  InternalServerException,  ServiceQuotaExceededException,  ThrottlingException,  ValidationException,  ProbeState,  ResourceNotFoundException});