File Explorer

/proc/self/root/var/runtime/node_modules/@aws-sdk/client-dsql/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 /.

index.js19.8 KB · 558 lines
'use strict'; var client$1 = require('@aws-sdk/core/client');var core = require('@smithy/core');var client = require('@smithy/core/client');var config = require('@smithy/core/config');var endpoints = require('@smithy/core/endpoints');var protocols = require('@smithy/core/protocols');var retry = require('@smithy/core/retry');var schema = require('@smithy/core/schema');var httpAuthSchemeProvider = require('./auth/httpAuthSchemeProvider');var runtimeConfig = require('./runtimeConfig');var schemas_0 = require('./schemas/schemas_0');var errors = require('./models/errors');var DSQLServiceException = require('./models/DSQLServiceException'); const resolveClientEndpointParameters = (options) => {    return Object.assign(options, {        useFipsEndpoint: options.useFipsEndpoint ?? false,        defaultSigningName: "dsql",    });};const commonParams = {    UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" },    Endpoint: { type: "builtInParams", name: "endpoint" },    Region: { type: "builtInParams", name: "region" },}; const getHttpAuthExtensionConfiguration = (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;        },    };};const resolveHttpAuthRuntimeConfig = (config) => {    return {        httpAuthSchemes: config.httpAuthSchemes(),        httpAuthSchemeProvider: config.httpAuthSchemeProvider(),        credentials: config.credentials(),    };}; const resolveRuntimeExtensions = (runtimeConfig, extensions) => {    const extensionConfiguration = Object.assign(client$1.getAwsRegionExtensionConfiguration(runtimeConfig), client.getDefaultExtensionConfiguration(runtimeConfig), protocols.getHttpHandlerExtensionConfiguration(runtimeConfig), getHttpAuthExtensionConfiguration(runtimeConfig));    extensions.forEach((extension) => extension.configure(extensionConfiguration));    return Object.assign(runtimeConfig, client$1.resolveAwsRegionExtensionConfiguration(extensionConfiguration), client.resolveDefaultRuntimeConfig(extensionConfiguration), protocols.resolveHttpHandlerRuntimeConfig(extensionConfiguration), resolveHttpAuthRuntimeConfig(extensionConfiguration));}; class DSQLClient extends client.Client {    config;    constructor(...[configuration]) {        const _config_0 = runtimeConfig.getRuntimeConfig(configuration || {});        super(_config_0);        this.initConfig = _config_0;        const _config_1 = resolveClientEndpointParameters(_config_0);        const _config_2 = client$1.resolveUserAgentConfig(_config_1);        const _config_3 = retry.resolveRetryConfig(_config_2);        const _config_4 = config.resolveRegionConfig(_config_3);        const _config_5 = client$1.resolveHostHeaderConfig(_config_4);        const _config_6 = endpoints.resolveEndpointConfig(_config_5);        const _config_7 = httpAuthSchemeProvider.resolveHttpAuthSchemeConfig(_config_6);        const _config_8 = resolveRuntimeExtensions(_config_7, configuration?.extensions || []);        this.config = _config_8;        this.middlewareStack.use(schema.getSchemaSerdePlugin(this.config));        this.middlewareStack.use(client$1.getUserAgentPlugin(this.config));        this.middlewareStack.use(retry.getRetryPlugin(this.config));        this.middlewareStack.use(protocols.getContentLengthPlugin(this.config));        this.middlewareStack.use(client$1.getHostHeaderPlugin(this.config));        this.middlewareStack.use(client$1.getLoggerPlugin(this.config));        this.middlewareStack.use(client$1.getRecursionDetectionPlugin(this.config));        this.middlewareStack.use(core.getHttpAuthSchemeEndpointRuleSetPlugin(this.config, {            httpAuthSchemeParametersProvider: httpAuthSchemeProvider.defaultDSQLHttpAuthSchemeParametersProvider,            identityProviderConfigProvider: async (config) => new core.DefaultIdentityProviderConfig({                "aws.auth#sigv4": config.credentials,            }),        }));        this.middlewareStack.use(core.getHttpSigningPlugin(this.config));    }    destroy() {        super.destroy();    }} class CreateClusterCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("DSQL", "CreateCluster", {})    .n("DSQLClient", "CreateClusterCommand")    .sc(schemas_0.CreateCluster$)    .build() {} class CreateStreamCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("DSQL", "CreateStream", {})    .n("DSQLClient", "CreateStreamCommand")    .sc(schemas_0.CreateStream$)    .build() {} class DeleteClusterCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("DSQL", "DeleteCluster", {})    .n("DSQLClient", "DeleteClusterCommand")    .sc(schemas_0.DeleteCluster$)    .build() {} class DeleteClusterPolicyCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("DSQL", "DeleteClusterPolicy", {})    .n("DSQLClient", "DeleteClusterPolicyCommand")    .sc(schemas_0.DeleteClusterPolicy$)    .build() {} class DeleteStreamCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("DSQL", "DeleteStream", {})    .n("DSQLClient", "DeleteStreamCommand")    .sc(schemas_0.DeleteStream$)    .build() {} class GetClusterCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("DSQL", "GetCluster", {})    .n("DSQLClient", "GetClusterCommand")    .sc(schemas_0.GetCluster$)    .build() {} class GetClusterPolicyCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("DSQL", "GetClusterPolicy", {})    .n("DSQLClient", "GetClusterPolicyCommand")    .sc(schemas_0.GetClusterPolicy$)    .build() {} class GetStreamCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("DSQL", "GetStream", {})    .n("DSQLClient", "GetStreamCommand")    .sc(schemas_0.GetStream$)    .build() {} class GetVpcEndpointServiceNameCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("DSQL", "GetVpcEndpointServiceName", {})    .n("DSQLClient", "GetVpcEndpointServiceNameCommand")    .sc(schemas_0.GetVpcEndpointServiceName$)    .build() {} class ListClustersCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("DSQL", "ListClusters", {})    .n("DSQLClient", "ListClustersCommand")    .sc(schemas_0.ListClusters$)    .build() {} class ListStreamsCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("DSQL", "ListStreams", {})    .n("DSQLClient", "ListStreamsCommand")    .sc(schemas_0.ListStreams$)    .build() {} class ListTagsForResourceCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("DSQL", "ListTagsForResource", {})    .n("DSQLClient", "ListTagsForResourceCommand")    .sc(schemas_0.ListTagsForResource$)    .build() {} class PutClusterPolicyCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("DSQL", "PutClusterPolicy", {})    .n("DSQLClient", "PutClusterPolicyCommand")    .sc(schemas_0.PutClusterPolicy$)    .build() {} class TagResourceCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("DSQL", "TagResource", {})    .n("DSQLClient", "TagResourceCommand")    .sc(schemas_0.TagResource$)    .build() {} class UntagResourceCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("DSQL", "UntagResource", {})    .n("DSQLClient", "UntagResourceCommand")    .sc(schemas_0.UntagResource$)    .build() {} class UpdateClusterCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("DSQL", "UpdateCluster", {})    .n("DSQLClient", "UpdateClusterCommand")    .sc(schemas_0.UpdateCluster$)    .build() {} const paginateListClusters = core.createPaginator(DSQLClient, ListClustersCommand, "nextToken", "nextToken", "maxResults"); const paginateListStreams = core.createPaginator(DSQLClient, ListStreamsCommand, "nextToken", "nextToken", "maxResults"); const checkState$3 = async (client$1, input) => {    let reason;    try {        let result = await client$1.send(new GetClusterCommand(input));        reason = result;        try {            const returnComparator = () => {                return result.status;            };            if (returnComparator() === "ACTIVE") {                return { state: client.WaiterState.SUCCESS, reason };            }        }        catch (e) { }    }    catch (exception) {        reason = exception;    }    return { state: client.WaiterState.RETRY, reason };};const waitForClusterActive = async (params, input) => {    const serviceDefaults = { minDelay: 2, maxDelay: 120 };    return client.createWaiter({ ...serviceDefaults, ...params }, input, checkState$3);};const waitUntilClusterActive = async (params, input) => {    const serviceDefaults = { minDelay: 2, maxDelay: 120 };    const result = await client.createWaiter({ ...serviceDefaults, ...params }, input, checkState$3);    return client.checkExceptions(result);}; const checkState$2 = async (client$1, input) => {    let reason;    try {        let result = await client$1.send(new GetClusterCommand(input));        reason = result;    }    catch (exception) {        reason = exception;        if (exception.name === "ResourceNotFoundException") {            return { state: client.WaiterState.SUCCESS, reason };        }    }    return { state: client.WaiterState.RETRY, reason };};const waitForClusterNotExists = async (params, input) => {    const serviceDefaults = { minDelay: 2, maxDelay: 120 };    return client.createWaiter({ ...serviceDefaults, ...params }, input, checkState$2);};const waitUntilClusterNotExists = async (params, input) => {    const serviceDefaults = { minDelay: 2, maxDelay: 120 };    const result = await client.createWaiter({ ...serviceDefaults, ...params }, input, checkState$2);    return client.checkExceptions(result);}; const checkState$1 = async (client$1, input) => {    let reason;    try {        let result = await client$1.send(new GetStreamCommand(input));        reason = result;        try {            const returnComparator = () => {                return result.status;            };            if (returnComparator() === "ACTIVE") {                return { state: client.WaiterState.SUCCESS, reason };            }        }        catch (e) { }    }    catch (exception) {        reason = exception;    }    return { state: client.WaiterState.RETRY, reason };};const waitForStreamActive = async (params, input) => {    const serviceDefaults = { minDelay: 2, maxDelay: 120 };    return client.createWaiter({ ...serviceDefaults, ...params }, input, checkState$1);};const waitUntilStreamActive = async (params, input) => {    const serviceDefaults = { minDelay: 2, maxDelay: 120 };    const result = await client.createWaiter({ ...serviceDefaults, ...params }, input, checkState$1);    return client.checkExceptions(result);}; const checkState = async (client$1, input) => {    let reason;    try {        let result = await client$1.send(new GetStreamCommand(input));        reason = result;    }    catch (exception) {        reason = exception;        if (exception.name === "ResourceNotFoundException") {            return { state: client.WaiterState.SUCCESS, reason };        }    }    return { state: client.WaiterState.RETRY, reason };};const waitForStreamNotExists = async (params, input) => {    const serviceDefaults = { minDelay: 2, maxDelay: 120 };    return client.createWaiter({ ...serviceDefaults, ...params }, input, checkState);};const waitUntilStreamNotExists = async (params, input) => {    const serviceDefaults = { minDelay: 2, maxDelay: 120 };    const result = await client.createWaiter({ ...serviceDefaults, ...params }, input, checkState);    return client.checkExceptions(result);}; const commands = {    CreateClusterCommand,    CreateStreamCommand,    DeleteClusterCommand,    DeleteClusterPolicyCommand,    DeleteStreamCommand,    GetClusterCommand,    GetClusterPolicyCommand,    GetStreamCommand,    GetVpcEndpointServiceNameCommand,    ListClustersCommand,    ListStreamsCommand,    ListTagsForResourceCommand,    PutClusterPolicyCommand,    TagResourceCommand,    UntagResourceCommand,    UpdateClusterCommand,};const paginators = {    paginateListClusters,    paginateListStreams,};const waiters = {    waitUntilClusterActive,    waitUntilClusterNotExists,    waitUntilStreamActive,    waitUntilStreamNotExists,};class DSQL extends DSQLClient {}client.createAggregatedClient(commands, DSQL, { paginators, waiters }); const ClusterStatus = {    ACTIVE: "ACTIVE",    CREATING: "CREATING",    DELETED: "DELETED",    DELETING: "DELETING",    FAILED: "FAILED",    IDLE: "IDLE",    INACTIVE: "INACTIVE",    PENDING_DELETE: "PENDING_DELETE",    PENDING_SETUP: "PENDING_SETUP",    UPDATING: "UPDATING",};const EncryptionStatus = {    ENABLED: "ENABLED",    ENABLING: "ENABLING",    KMS_KEY_INACCESSIBLE: "KMS_KEY_INACCESSIBLE",    UPDATING: "UPDATING",};const EncryptionType = {    AWS_OWNED_KMS_KEY: "AWS_OWNED_KMS_KEY",    CUSTOMER_MANAGED_KMS_KEY: "CUSTOMER_MANAGED_KMS_KEY",};const ValidationExceptionReason = {    CANNOT_PARSE: "cannotParse",    DELETION_PROTECTION_ENABLED: "deletionProtectionEnabled",    FIELD_VALIDATION_FAILED: "fieldValidationFailed",    OTHER: "other",    UNKNOWN_OPERATION: "unknownOperation",};const StreamFormat = {    JSON: "JSON",};const StreamOrdering = {    UNORDERED: "UNORDERED",};const StreamStatus = {    ACTIVE: "ACTIVE",    CREATING: "CREATING",    DELETED: "DELETED",    DELETING: "DELETING",    FAILED: "FAILED",    IMPAIRED: "IMPAIRED",};const StreamFailureErrorCode = {    CLUSTER_CMK_INACCESSIBLE: "CLUSTER_CMK_INACCESSIBLE",    INTERNAL_ERROR: "INTERNAL_ERROR",    KINESIS_ACCESS_DENIED: "KINESIS_ACCESS_DENIED",    KINESIS_KMS_ACCESS_DENIED: "KINESIS_KMS_ACCESS_DENIED",    KINESIS_OVERSIZE_RECORD: "KINESIS_OVERSIZE_RECORD",    KINESIS_STREAM_NOT_FOUND: "KINESIS_STREAM_NOT_FOUND",    KINESIS_THROUGHPUT_EXCEEDED: "KINESIS_THROUGHPUT_EXCEEDED",    ROLE_ACCESS_DENIED: "ROLE_ACCESS_DENIED",}; exports.$Command = client.Command;exports.__Client = client.Client;exports.DSQLServiceException = DSQLServiceException.DSQLServiceException;exports.ClusterStatus = ClusterStatus;exports.CreateClusterCommand = CreateClusterCommand;exports.CreateStreamCommand = CreateStreamCommand;exports.DSQL = DSQL;exports.DSQLClient = DSQLClient;exports.DeleteClusterCommand = DeleteClusterCommand;exports.DeleteClusterPolicyCommand = DeleteClusterPolicyCommand;exports.DeleteStreamCommand = DeleteStreamCommand;exports.EncryptionStatus = EncryptionStatus;exports.EncryptionType = EncryptionType;exports.GetClusterCommand = GetClusterCommand;exports.GetClusterPolicyCommand = GetClusterPolicyCommand;exports.GetStreamCommand = GetStreamCommand;exports.GetVpcEndpointServiceNameCommand = GetVpcEndpointServiceNameCommand;exports.ListClustersCommand = ListClustersCommand;exports.ListStreamsCommand = ListStreamsCommand;exports.ListTagsForResourceCommand = ListTagsForResourceCommand;exports.PutClusterPolicyCommand = PutClusterPolicyCommand;exports.StreamFailureErrorCode = StreamFailureErrorCode;exports.StreamFormat = StreamFormat;exports.StreamOrdering = StreamOrdering;exports.StreamStatus = StreamStatus;exports.TagResourceCommand = TagResourceCommand;exports.UntagResourceCommand = UntagResourceCommand;exports.UpdateClusterCommand = UpdateClusterCommand;exports.ValidationExceptionReason = ValidationExceptionReason;exports.paginateListClusters = paginateListClusters;exports.paginateListStreams = paginateListStreams;exports.waitForClusterActive = waitForClusterActive;exports.waitForClusterNotExists = waitForClusterNotExists;exports.waitForStreamActive = waitForStreamActive;exports.waitForStreamNotExists = waitForStreamNotExists;exports.waitUntilClusterActive = waitUntilClusterActive;exports.waitUntilClusterNotExists = waitUntilClusterNotExists;exports.waitUntilStreamActive = waitUntilStreamActive;exports.waitUntilStreamNotExists = waitUntilStreamNotExists;Object.prototype.hasOwnProperty.call(schemas_0, '__proto__') &&    !Object.prototype.hasOwnProperty.call(exports, '__proto__') &&    Object.defineProperty(exports, '__proto__', {        enumerable: true,        value: schemas_0['__proto__']    }); Object.keys(schemas_0).forEach(function (k) {    if (k !== 'default' && !Object.prototype.hasOwnProperty.call(exports, k)) exports[k] = schemas_0[k];});Object.prototype.hasOwnProperty.call(errors, '__proto__') &&    !Object.prototype.hasOwnProperty.call(exports, '__proto__') &&    Object.defineProperty(exports, '__proto__', {        enumerable: true,        value: errors['__proto__']    }); Object.keys(errors).forEach(function (k) {    if (k !== 'default' && !Object.prototype.hasOwnProperty.call(exports, k)) exports[k] = errors[k];});