File Explorer

/proc/2/root/var/runtime/node_modules/@aws-sdk/client-apigatewaymanagementapi/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 /.
0 dirs
1 file
index.js19.8 KB
index.js19.8 KB · 484 lines
1const { awsEndpointFunctions, emitWarningIfUnsupportedVersion: emitWarningIfUnsupportedVersion$1, createDefaultUserAgentProvider, NODE_APP_ID_CONFIG_OPTIONS, getAwsRegionExtensionConfiguration, resolveAwsRegionExtensionConfiguration, resolveUserAgentConfig, resolveHostHeaderConfig, getUserAgentPlugin, getHostHeaderPlugin, getLoggerPlugin, getRecursionDetectionPlugin } = require("@aws-sdk/core/client");2const { getHttpAuthSchemeEndpointRuleSetPlugin, DefaultIdentityProviderConfig, getHttpSigningPlugin } = require("@smithy/core");3const { normalizeProvider, getSmithyContext, ServiceException, NoOpLogger, emitWarningIfUnsupportedVersion, loadConfigsForDefaultMode, getDefaultExtensionConfiguration, resolveDefaultRuntimeConfig, Client, makeBuilder, createAggregatedClient } = require("@smithy/core/client");4const { Command: $Command } = require("@smithy/core/client");5exports.$Command = $Command;6exports.__Client = Client;7const { resolveDefaultsModeConfig, loadConfig, NODE_USE_FIPS_ENDPOINT_CONFIG_OPTIONS, NODE_USE_DUALSTACK_ENDPOINT_CONFIG_OPTIONS, NODE_REGION_CONFIG_OPTIONS, NODE_REGION_CONFIG_FILE_OPTIONS, resolveRegionConfig } = require("@smithy/core/config");8const { BinaryDecisionDiagram, EndpointCache, decideEndpoint, customEndpointFunctions, resolveEndpointConfig, getEndpointPlugin } = require("@smithy/core/endpoints");9const { parseUrl, getHttpHandlerExtensionConfiguration, resolveHttpHandlerRuntimeConfig, getContentLengthPlugin } = require("@smithy/core/protocols");10const { DEFAULT_RETRY_MODE, NODE_RETRY_MODE_CONFIG_OPTIONS, NODE_MAX_ATTEMPT_CONFIG_OPTIONS, resolveRetryConfig, getRetryPlugin } = require("@smithy/core/retry");11const { TypeRegistry, getSchemaSerdePlugin } = require("@smithy/core/schema");12const { resolveAwsSdkSigV4Config, AwsSdkSigV4Signer, NODE_AUTH_SCHEME_PREFERENCE_OPTIONS } = require("@aws-sdk/core/httpAuthSchemes");13const { defaultProvider } = require("@aws-sdk/credential-provider-node");14const { toUtf8, fromUtf8, toBase64, fromBase64, calculateBodyLength } = require("@smithy/core/serde");15const { streamCollector, NodeHttpHandler } = require("@smithy/node-http-handler");16const { AwsRestJsonProtocol } = require("@aws-sdk/core/protocols");17const { Sha256 } = require("@smithy/core/checksum");18 19const defaultApiGatewayManagementApiHttpAuthSchemeParametersProvider = async (config, context, input) => {20    return {21        operation: getSmithyContext(context).operation,22        region: await normalizeProvider(config.region)() || (() => {23            throw new Error("expected `region` to be configured for `aws.auth#sigv4`");24        })(),25    };26};27function createAwsAuthSigv4HttpAuthOption(authParameters) {28    return {29        schemeId: "aws.auth#sigv4",30        signingProperties: {31            name: "execute-api",32            region: authParameters.region,33        },34        propertiesExtractor: (config, context) => ({35            signingProperties: {36                config,37                context,38            },39        }),40    };41}42const defaultApiGatewayManagementApiHttpAuthSchemeProvider = (authParameters) => {43    const options = [];44    switch (authParameters.operation) {45        default: {46            options.push(createAwsAuthSigv4HttpAuthOption(authParameters));47        }48    }49    return options;50};51const resolveHttpAuthSchemeConfig = (config) => {52    const config_0 = resolveAwsSdkSigV4Config(config);53    return Object.assign(config_0, {54        authSchemePreference: normalizeProvider(config.authSchemePreference ?? []),55    });56};57 58const resolveClientEndpointParameters = (options) => {59    return Object.assign(options, {60        useDualstackEndpoint: options.useDualstackEndpoint ?? false,61        useFipsEndpoint: options.useFipsEndpoint ?? false,62        defaultSigningName: "execute-api",63    });64};65const commonParams = {66    UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" },67    Endpoint: { type: "builtInParams", name: "endpoint" },68    Region: { type: "builtInParams", name: "region" },69    UseDualStack: { type: "builtInParams", name: "useDualstackEndpoint" },70};71 72var version = "3.1104.0";73var packageInfo = {74	version: version};75 76const k = "ref";77const a = -1, b = true, c = "isSet", d = "PartitionResult", e = "booleanEquals", f = "getAttr", g = { [k]: "Endpoint" }, h = { [k]: d }, i = {}, j = [{ [k]: "Region" }];78const _data = {79    conditions: [80        [c, [g]],81        [c, j],82        ["aws.partition", j, d],83        [e, [{ [k]: "UseFIPS" }, b]],84        [e, [{ [k]: "UseDualStack" }, b]],85        [e, [{ fn: f, argv: [h, "supportsDualStack"] }, b]],86        [e, [{ fn: f, argv: [h, "supportsFIPS"] }, b]]87    ],88    results: [89        [a],90        [a, "Invalid Configuration: FIPS and custom endpoint are not supported"],91        [a, "Invalid Configuration: Dualstack and custom endpoint are not supported"],92        [g, i],93        ["https://execute-api-fips.{Region}.{PartitionResult#dualStackDnsSuffix}", i],94        [a, "FIPS and DualStack are enabled, but this partition does not support one or both"],95        ["https://execute-api-fips.{Region}.{PartitionResult#dnsSuffix}", i],96        [a, "FIPS is enabled but this partition does not support FIPS"],97        ["https://execute-api.{Region}.{PartitionResult#dualStackDnsSuffix}", i],98        [a, "DualStack is enabled but this partition does not support DualStack"],99        ["https://execute-api.{Region}.{PartitionResult#dnsSuffix}", i],100        [a, "Invalid Configuration: Missing Region"]101    ]102};103const root = 2;104const r = 100_000_000;105const nodes = new Int32Array([106    -1, 1, -1,107    0, 12, 3,108    1, 4, r + 11,109    2, 5, r + 11,110    3, 8, 6,111    4, 7, r + 10,112    5, r + 8, r + 9,113    4, 10, 9,114    6, r + 6, r + 7,115    5, 11, r + 5,116    6, r + 4, r + 5,117    3, r + 1, 13,118    4, r + 2, r + 3,119]);120const bdd = BinaryDecisionDiagram.from(nodes, root, _data.conditions, _data.results);121 122const cache = new EndpointCache({123    size: 50,124    params: ["Endpoint", "Region", "UseDualStack", "UseFIPS"],125});126const defaultEndpointResolver = (endpointParams, context = {}) => {127    return cache.get(endpointParams, () => decideEndpoint(bdd, {128        endpointParams: endpointParams,129        logger: context.logger,130    }));131};132customEndpointFunctions.aws = awsEndpointFunctions;133 134class ApiGatewayManagementApiServiceException extends ServiceException {135    constructor(options) {136        super(options);137        Object.setPrototypeOf(this, ApiGatewayManagementApiServiceException.prototype);138    }139}140 141class ForbiddenException extends ApiGatewayManagementApiServiceException {142    name = "ForbiddenException";143    $fault = "client";144    constructor(opts) {145        super({146            name: "ForbiddenException",147            $fault: "client",148            ...opts,149        });150        Object.setPrototypeOf(this, ForbiddenException.prototype);151    }152}153class GoneException extends ApiGatewayManagementApiServiceException {154    name = "GoneException";155    $fault = "client";156    constructor(opts) {157        super({158            name: "GoneException",159            $fault: "client",160            ...opts,161        });162        Object.setPrototypeOf(this, GoneException.prototype);163    }164}165class LimitExceededException extends ApiGatewayManagementApiServiceException {166    name = "LimitExceededException";167    $fault = "client";168    constructor(opts) {169        super({170            name: "LimitExceededException",171            $fault: "client",172            ...opts,173        });174        Object.setPrototypeOf(this, LimitExceededException.prototype);175    }176}177class PayloadTooLargeException extends ApiGatewayManagementApiServiceException {178    name = "PayloadTooLargeException";179    $fault = "client";180    Message;181    constructor(opts) {182        super({183            name: "PayloadTooLargeException",184            $fault: "client",185            ...opts,186        });187        Object.setPrototypeOf(this, PayloadTooLargeException.prototype);188        this.Message = opts.Message;189    }190}191 192const _CA = "ConnectedAt";193const _CI = "ConnectionId";194const _D = "Data";195const _DC = "DeleteConnection";196const _DCR = "DeleteConnectionRequest";197const _FE = "ForbiddenException";198const _GC = "GetConnection";199const _GCR = "GetConnectionRequest";200const _GCRe = "GetConnectionResponse";201const _GE = "GoneException";202const _I = "Identity";203const _LAA = "LastActiveAt";204const _LEE = "LimitExceededException";205const _M = "Message";206const _PTC = "PostToConnection";207const _PTCR = "PostToConnectionRequest";208const _PTLE = "PayloadTooLargeException";209const _SI = "SourceIp";210const _UA = "UserAgent";211const _c = "client";212const _cA = "connectedAt";213const _e = "error";214const _h = "http";215const _hE = "httpError";216const _i = "identity";217const _jN = "jsonName";218const _lAA = "lastActiveAt";219const _m = "message";220const _s = "smithy.ts.sdk.synthetic.com.amazonaws.apigatewaymanagementapi";221const _sI = "sourceIp";222const _uA = "userAgent";223const n0 = "com.amazonaws.apigatewaymanagementapi";224const _s_registry = TypeRegistry.for(_s);225var ApiGatewayManagementApiServiceException$ = [-3, _s, "ApiGatewayManagementApiServiceException", 0, [], []];226_s_registry.registerError(ApiGatewayManagementApiServiceException$, ApiGatewayManagementApiServiceException);227const n0_registry = TypeRegistry.for(n0);228var ForbiddenException$ = [-3, n0, _FE,229    { [_e]: _c, [_hE]: 403 },230    [],231    []232];233n0_registry.registerError(ForbiddenException$, ForbiddenException);234var GoneException$ = [-3, n0, _GE,235    { [_e]: _c, [_hE]: 410 },236    [],237    []238];239n0_registry.registerError(GoneException$, GoneException);240var LimitExceededException$ = [-3, n0, _LEE,241    { [_e]: _c, [_hE]: 429 },242    [],243    []244];245n0_registry.registerError(LimitExceededException$, LimitExceededException);246var PayloadTooLargeException$ = [-3, n0, _PTLE,247    { [_e]: _c, [_hE]: 413 },248    [_M],249    [[0, { [_jN]: _m }]]250];251n0_registry.registerError(PayloadTooLargeException$, PayloadTooLargeException);252const errorTypeRegistries = [253    _s_registry,254    n0_registry,255];256var DeleteConnectionRequest$ = [3, n0, _DCR,257    0,258    [_CI],259    [[0, 1]], 1260];261var GetConnectionRequest$ = [3, n0, _GCR,262    0,263    [_CI],264    [[0, 1]], 1265];266var GetConnectionResponse$ = [3, n0, _GCRe,267    0,268    [_CA, _I, _LAA],269    [[5, { [_jN]: _cA }], [() => Identity$, { [_jN]: _i }], [5, { [_jN]: _lAA }]]270];271var Identity$ = [3, n0, _I,272    0,273    [_SI, _UA],274    [[0, { [_jN]: _sI }], [0, { [_jN]: _uA }]], 2275];276var PostToConnectionRequest$ = [3, n0, _PTCR,277    0,278    [_D, _CI],279    [[21, 16], [0, 1]], 2280];281var __Unit = "unit";282var DeleteConnection$ = [9, n0, _DC,283    { [_h]: ["DELETE", "/@connections/{ConnectionId}", 204] }, () => DeleteConnectionRequest$, () => __Unit284];285var GetConnection$ = [9, n0, _GC,286    { [_h]: ["GET", "/@connections/{ConnectionId}", 200] }, () => GetConnectionRequest$, () => GetConnectionResponse$287];288var PostToConnection$ = [9, n0, _PTC,289    { [_h]: ["POST", "/@connections/{ConnectionId}", 200] }, () => PostToConnectionRequest$, () => __Unit290];291 292const getRuntimeConfig$1 = (config) => {293    return {294        apiVersion: "2018-11-29",295        base64Decoder: config?.base64Decoder ?? fromBase64,296        base64Encoder: config?.base64Encoder ?? toBase64,297        disableHostPrefix: config?.disableHostPrefix ?? false,298        endpointProvider: config?.endpointProvider ?? defaultEndpointResolver,299        extensions: config?.extensions ?? [],300        httpAuthSchemeProvider: config?.httpAuthSchemeProvider ?? defaultApiGatewayManagementApiHttpAuthSchemeProvider,301        httpAuthSchemes: config?.httpAuthSchemes ?? [302            {303                schemeId: "aws.auth#sigv4",304                identityProvider: (ipc) => ipc.getIdentityProvider("aws.auth#sigv4"),305                signer: new AwsSdkSigV4Signer(),306            },307        ],308        logger: config?.logger ?? new NoOpLogger(),309        protocol: config?.protocol ?? AwsRestJsonProtocol,310        protocolSettings: config?.protocolSettings ?? {311            defaultNamespace: "com.amazonaws.apigatewaymanagementapi",312            errorTypeRegistries,313            version: "2018-11-29",314            serviceTarget: "ApiGatewayManagementApi",315        },316        serviceId: config?.serviceId ?? "ApiGatewayManagementApi",317        sha256: config?.sha256 ?? Sha256,318        urlParser: config?.urlParser ?? parseUrl,319        utf8Decoder: config?.utf8Decoder ?? fromUtf8,320        utf8Encoder: config?.utf8Encoder ?? toUtf8,321    };322};323 324const getRuntimeConfig = (config) => {325    emitWarningIfUnsupportedVersion(process.version);326    const defaultsMode = resolveDefaultsModeConfig(config);327    const defaultConfigProvider = () => defaultsMode().then(loadConfigsForDefaultMode);328    const clientSharedValues = getRuntimeConfig$1(config);329    emitWarningIfUnsupportedVersion$1(process.version);330    const loaderConfig = {331        profile: config?.profile,332        logger: clientSharedValues.logger,333    };334    return {335        ...clientSharedValues,336        ...config,337        runtime: "node",338        defaultsMode,339        authSchemePreference: config?.authSchemePreference ?? loadConfig(NODE_AUTH_SCHEME_PREFERENCE_OPTIONS, loaderConfig),340        bodyLengthChecker: config?.bodyLengthChecker ?? calculateBodyLength,341        credentialDefaultProvider: config?.credentialDefaultProvider ?? defaultProvider,342        defaultUserAgentProvider: config?.defaultUserAgentProvider ?? createDefaultUserAgentProvider({ serviceId: clientSharedValues.serviceId, clientVersion: packageInfo.version }),343        maxAttempts: config?.maxAttempts ?? loadConfig(NODE_MAX_ATTEMPT_CONFIG_OPTIONS, config),344        region: config?.region ?? loadConfig(NODE_REGION_CONFIG_OPTIONS, { ...NODE_REGION_CONFIG_FILE_OPTIONS, ...loaderConfig }),345        requestHandler: NodeHttpHandler.create(config?.requestHandler ?? defaultConfigProvider),346        retryMode: config?.retryMode ??347            loadConfig({348                ...NODE_RETRY_MODE_CONFIG_OPTIONS,349                default: async () => (await defaultConfigProvider()).retryMode || DEFAULT_RETRY_MODE,350            }, config),351        streamCollector: config?.streamCollector ?? streamCollector,352        useDualstackEndpoint: config?.useDualstackEndpoint ?? loadConfig(NODE_USE_DUALSTACK_ENDPOINT_CONFIG_OPTIONS, loaderConfig),353        useFipsEndpoint: config?.useFipsEndpoint ?? loadConfig(NODE_USE_FIPS_ENDPOINT_CONFIG_OPTIONS, loaderConfig),354        userAgentAppId: config?.userAgentAppId ?? loadConfig(NODE_APP_ID_CONFIG_OPTIONS, loaderConfig),355    };356};357 358const getHttpAuthExtensionConfiguration = (runtimeConfig) => {359    const _httpAuthSchemes = runtimeConfig.httpAuthSchemes;360    let _httpAuthSchemeProvider = runtimeConfig.httpAuthSchemeProvider;361    let _credentials = runtimeConfig.credentials;362    return {363        setHttpAuthScheme(httpAuthScheme) {364            const index = _httpAuthSchemes.findIndex((scheme) => scheme.schemeId === httpAuthScheme.schemeId);365            if (index === -1) {366                _httpAuthSchemes.push(httpAuthScheme);367            }368            else {369                _httpAuthSchemes.splice(index, 1, httpAuthScheme);370            }371        },372        httpAuthSchemes() {373            return _httpAuthSchemes;374        },375        setHttpAuthSchemeProvider(httpAuthSchemeProvider) {376            _httpAuthSchemeProvider = httpAuthSchemeProvider;377        },378        httpAuthSchemeProvider() {379            return _httpAuthSchemeProvider;380        },381        setCredentials(credentials) {382            _credentials = credentials;383        },384        credentials() {385            return _credentials;386        },387    };388};389const resolveHttpAuthRuntimeConfig = (config) => {390    return {391        httpAuthSchemes: config.httpAuthSchemes(),392        httpAuthSchemeProvider: config.httpAuthSchemeProvider(),393        credentials: config.credentials(),394    };395};396 397const resolveRuntimeExtensions = (runtimeConfig, extensions) => {398    const extensionConfiguration = Object.assign(getAwsRegionExtensionConfiguration(runtimeConfig), getDefaultExtensionConfiguration(runtimeConfig), getHttpHandlerExtensionConfiguration(runtimeConfig), getHttpAuthExtensionConfiguration(runtimeConfig));399    extensions.forEach((extension) => extension.configure(extensionConfiguration));400    return Object.assign(runtimeConfig, resolveAwsRegionExtensionConfiguration(extensionConfiguration), resolveDefaultRuntimeConfig(extensionConfiguration), resolveHttpHandlerRuntimeConfig(extensionConfiguration), resolveHttpAuthRuntimeConfig(extensionConfiguration));401};402 403class ApiGatewayManagementApiClient extends Client {404    config;405    constructor(...[configuration]) {406        const _config_0 = getRuntimeConfig(configuration || {});407        super(_config_0);408        this.initConfig = _config_0;409        const _config_1 = resolveClientEndpointParameters(_config_0);410        const _config_2 = resolveUserAgentConfig(_config_1);411        const _config_3 = resolveRetryConfig(_config_2);412        const _config_4 = resolveRegionConfig(_config_3);413        const _config_5 = resolveHostHeaderConfig(_config_4);414        const _config_6 = resolveEndpointConfig(_config_5);415        const _config_7 = resolveHttpAuthSchemeConfig(_config_6);416        const _config_8 = resolveRuntimeExtensions(_config_7, configuration?.extensions || []);417        this.config = _config_8;418        this.middlewareStack.use(getSchemaSerdePlugin(this.config));419        this.middlewareStack.use(getUserAgentPlugin(this.config));420        this.middlewareStack.use(getRetryPlugin(this.config));421        this.middlewareStack.use(getContentLengthPlugin(this.config));422        this.middlewareStack.use(getHostHeaderPlugin(this.config));423        this.middlewareStack.use(getLoggerPlugin(this.config));424        this.middlewareStack.use(getRecursionDetectionPlugin(this.config));425        this.middlewareStack.use(getHttpAuthSchemeEndpointRuleSetPlugin(this.config, {426            httpAuthSchemeParametersProvider: defaultApiGatewayManagementApiHttpAuthSchemeParametersProvider,427            identityProviderConfigProvider: async (config) => new DefaultIdentityProviderConfig({428                "aws.auth#sigv4": config.credentials,429            }),430        }));431        this.middlewareStack.use(getHttpSigningPlugin(this.config));432    }433    destroy() {434        super.destroy();435    }436}437 438const command = makeBuilder(commonParams, "ApiGatewayManagementApi", "ApiGatewayManagementApiClient", getEndpointPlugin);439const _ep0 = {};440const _mw0 = (Command, cs, config, o) => [];441 442class DeleteConnectionCommand extends command(_ep0, _mw0, "DeleteConnection", DeleteConnection$) {443}444 445class GetConnectionCommand extends command(_ep0, _mw0, "GetConnection", GetConnection$) {446}447 448class PostToConnectionCommand extends command(_ep0, _mw0, "PostToConnection", PostToConnection$) {449}450 451const commands = {452    DeleteConnectionCommand,453    GetConnectionCommand,454    PostToConnectionCommand,455};456class ApiGatewayManagementApi extends ApiGatewayManagementApiClient {457}458createAggregatedClient(commands, ApiGatewayManagementApi);459 460exports.ApiGatewayManagementApi = ApiGatewayManagementApi;461exports.ApiGatewayManagementApiClient = ApiGatewayManagementApiClient;462exports.ApiGatewayManagementApiServiceException = ApiGatewayManagementApiServiceException;463exports.ApiGatewayManagementApiServiceException$ = ApiGatewayManagementApiServiceException$;464exports.DeleteConnection$ = DeleteConnection$;465exports.DeleteConnectionCommand = DeleteConnectionCommand;466exports.DeleteConnectionRequest$ = DeleteConnectionRequest$;467exports.ForbiddenException = ForbiddenException;468exports.ForbiddenException$ = ForbiddenException$;469exports.GetConnection$ = GetConnection$;470exports.GetConnectionCommand = GetConnectionCommand;471exports.GetConnectionRequest$ = GetConnectionRequest$;472exports.GetConnectionResponse$ = GetConnectionResponse$;473exports.GoneException = GoneException;474exports.GoneException$ = GoneException$;475exports.Identity$ = Identity$;476exports.LimitExceededException = LimitExceededException;477exports.LimitExceededException$ = LimitExceededException$;478exports.PayloadTooLargeException = PayloadTooLargeException;479exports.PayloadTooLargeException$ = PayloadTooLargeException$;480exports.PostToConnection$ = PostToConnection$;481exports.PostToConnectionCommand = PostToConnectionCommand;482exports.PostToConnectionRequest$ = PostToConnectionRequest$;483exports.errorTypeRegistries = errorTypeRegistries;484