File Explorer

1'use strict';2 3var client$1 = require('@aws-sdk/core/client');4var core = require('@smithy/core');5var client = require('@smithy/core/client');6var config = require('@smithy/core/config');7var endpoints = require('@smithy/core/endpoints');8var protocols = require('@smithy/core/protocols');9var retry = require('@smithy/core/retry');10var schema = require('@smithy/core/schema');11var httpAuthSchemeProvider = require('./auth/httpAuthSchemeProvider');12var runtimeConfig = require('./runtimeConfig');13var schemas_0 = require('./schemas/schemas_0');14var errors = require('./models/errors');15var KeyspacesStreamsServiceException = require('./models/KeyspacesStreamsServiceException');16 17const resolveClientEndpointParameters = (options) => {18    return Object.assign(options, {19        useFipsEndpoint: options.useFipsEndpoint ?? false,20        defaultSigningName: "cassandra",21    });22};23const commonParams = {24    UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" },25    Endpoint: { type: "builtInParams", name: "endpoint" },26    Region: { type: "builtInParams", name: "region" },27};28 29const getHttpAuthExtensionConfiguration = (runtimeConfig) => {30    const _httpAuthSchemes = runtimeConfig.httpAuthSchemes;31    let _httpAuthSchemeProvider = runtimeConfig.httpAuthSchemeProvider;32    let _credentials = runtimeConfig.credentials;33    return {34        setHttpAuthScheme(httpAuthScheme) {35            const index = _httpAuthSchemes.findIndex((scheme) => scheme.schemeId === httpAuthScheme.schemeId);36            if (index === -1) {37                _httpAuthSchemes.push(httpAuthScheme);38            }39            else {40                _httpAuthSchemes.splice(index, 1, httpAuthScheme);41            }42        },43        httpAuthSchemes() {44            return _httpAuthSchemes;45        },46        setHttpAuthSchemeProvider(httpAuthSchemeProvider) {47            _httpAuthSchemeProvider = httpAuthSchemeProvider;48        },49        httpAuthSchemeProvider() {50            return _httpAuthSchemeProvider;51        },52        setCredentials(credentials) {53            _credentials = credentials;54        },55        credentials() {56            return _credentials;57        },58    };59};60const resolveHttpAuthRuntimeConfig = (config) => {61    return {62        httpAuthSchemes: config.httpAuthSchemes(),63        httpAuthSchemeProvider: config.httpAuthSchemeProvider(),64        credentials: config.credentials(),65    };66};67 68const resolveRuntimeExtensions = (runtimeConfig, extensions) => {69    const extensionConfiguration = Object.assign(client$1.getAwsRegionExtensionConfiguration(runtimeConfig), client.getDefaultExtensionConfiguration(runtimeConfig), protocols.getHttpHandlerExtensionConfiguration(runtimeConfig), getHttpAuthExtensionConfiguration(runtimeConfig));70    extensions.forEach((extension) => extension.configure(extensionConfiguration));71    return Object.assign(runtimeConfig, client$1.resolveAwsRegionExtensionConfiguration(extensionConfiguration), client.resolveDefaultRuntimeConfig(extensionConfiguration), protocols.resolveHttpHandlerRuntimeConfig(extensionConfiguration), resolveHttpAuthRuntimeConfig(extensionConfiguration));72};73 74class KeyspacesStreamsClient extends client.Client {75    config;76    constructor(...[configuration]) {77        const _config_0 = runtimeConfig.getRuntimeConfig(configuration || {});78        super(_config_0);79        this.initConfig = _config_0;80        const _config_1 = resolveClientEndpointParameters(_config_0);81        const _config_2 = client$1.resolveUserAgentConfig(_config_1);82        const _config_3 = retry.resolveRetryConfig(_config_2);83        const _config_4 = config.resolveRegionConfig(_config_3);84        const _config_5 = client$1.resolveHostHeaderConfig(_config_4);85        const _config_6 = endpoints.resolveEndpointConfig(_config_5);86        const _config_7 = httpAuthSchemeProvider.resolveHttpAuthSchemeConfig(_config_6);87        const _config_8 = resolveRuntimeExtensions(_config_7, configuration?.extensions || []);88        this.config = _config_8;89        this.middlewareStack.use(schema.getSchemaSerdePlugin(this.config));90        this.middlewareStack.use(client$1.getUserAgentPlugin(this.config));91        this.middlewareStack.use(retry.getRetryPlugin(this.config));92        this.middlewareStack.use(protocols.getContentLengthPlugin(this.config));93        this.middlewareStack.use(client$1.getHostHeaderPlugin(this.config));94        this.middlewareStack.use(client$1.getLoggerPlugin(this.config));95        this.middlewareStack.use(client$1.getRecursionDetectionPlugin(this.config));96        this.middlewareStack.use(core.getHttpAuthSchemeEndpointRuleSetPlugin(this.config, {97            httpAuthSchemeParametersProvider: httpAuthSchemeProvider.defaultKeyspacesStreamsHttpAuthSchemeParametersProvider,98            identityProviderConfigProvider: async (config) => new core.DefaultIdentityProviderConfig({99                "aws.auth#sigv4": config.credentials,100            }),101        }));102        this.middlewareStack.use(core.getHttpSigningPlugin(this.config));103    }104    destroy() {105        super.destroy();106    }107}108 109class GetRecordsCommand extends client.Command110    .classBuilder()111    .ep(commonParams)112    .m(function (Command, cs, config, o) {113    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];114})115    .s("KeyspacesStreams", "GetRecords", {})116    .n("KeyspacesStreamsClient", "GetRecordsCommand")117    .sc(schemas_0.GetRecords$)118    .build() {119}120 121class GetShardIteratorCommand extends client.Command122    .classBuilder()123    .ep(commonParams)124    .m(function (Command, cs, config, o) {125    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];126})127    .s("KeyspacesStreams", "GetShardIterator", {})128    .n("KeyspacesStreamsClient", "GetShardIteratorCommand")129    .sc(schemas_0.GetShardIterator$)130    .build() {131}132 133class GetStreamCommand extends client.Command134    .classBuilder()135    .ep(commonParams)136    .m(function (Command, cs, config, o) {137    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];138})139    .s("KeyspacesStreams", "GetStream", {})140    .n("KeyspacesStreamsClient", "GetStreamCommand")141    .sc(schemas_0.GetStream$)142    .build() {143}144 145class ListStreamsCommand extends client.Command146    .classBuilder()147    .ep(commonParams)148    .m(function (Command, cs, config, o) {149    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];150})151    .s("KeyspacesStreams", "ListStreams", {})152    .n("KeyspacesStreamsClient", "ListStreamsCommand")153    .sc(schemas_0.ListStreams$)154    .build() {155}156 157const paginateGetStream = core.createPaginator(KeyspacesStreamsClient, GetStreamCommand, "nextToken", "nextToken", "maxResults");158 159const paginateListStreams = core.createPaginator(KeyspacesStreamsClient, ListStreamsCommand, "nextToken", "nextToken", "maxResults");160 161const commands = {162    GetRecordsCommand,163    GetShardIteratorCommand,164    GetStreamCommand,165    ListStreamsCommand,166};167const paginators = {168    paginateGetStream,169    paginateListStreams,170};171class KeyspacesStreams extends KeyspacesStreamsClient {172}173client.createAggregatedClient(commands, KeyspacesStreams, { paginators });174 175const OriginType = {176    REPLICATION: "REPLICATION",177    TTL: "TTL",178    USER: "USER",179};180const ValidationExceptionType = {181    ExpiredIterator: "ExpiredIterator",182    ExpiredNextToken: "ExpiredNextToken",183    InvalidFormat: "InvalidFormat",184    TrimmedDataAccess: "TrimmedDataAccess",185};186const ShardIteratorType = {187    AFTER_SEQUENCE_NUMBER: "AFTER_SEQUENCE_NUMBER",188    AT_SEQUENCE_NUMBER: "AT_SEQUENCE_NUMBER",189    LATEST: "LATEST",190    TRIM_HORIZON: "TRIM_HORIZON",191};192const ShardFilterType = {193    CHILD_SHARDS: "CHILD_SHARDS",194};195const StreamStatus = {196    DISABLED: "DISABLED",197    DISABLING: "DISABLING",198    ENABLED: "ENABLED",199    ENABLING: "ENABLING",200};201const StreamViewType = {202    KEYS_ONLY: "KEYS_ONLY",203    NEW_AND_OLD_IMAGES: "NEW_AND_OLD_IMAGES",204    NEW_IMAGE: "NEW_IMAGE",205    OLD_IMAGE: "OLD_IMAGE",206};207 208exports.$Command = client.Command;209exports.__Client = client.Client;210exports.KeyspacesStreamsServiceException = KeyspacesStreamsServiceException.KeyspacesStreamsServiceException;211exports.GetRecordsCommand = GetRecordsCommand;212exports.GetShardIteratorCommand = GetShardIteratorCommand;213exports.GetStreamCommand = GetStreamCommand;214exports.KeyspacesStreams = KeyspacesStreams;215exports.KeyspacesStreamsClient = KeyspacesStreamsClient;216exports.ListStreamsCommand = ListStreamsCommand;217exports.OriginType = OriginType;218exports.ShardFilterType = ShardFilterType;219exports.ShardIteratorType = ShardIteratorType;220exports.StreamStatus = StreamStatus;221exports.StreamViewType = StreamViewType;222exports.ValidationExceptionType = ValidationExceptionType;223exports.paginateGetStream = paginateGetStream;224exports.paginateListStreams = paginateListStreams;225Object.prototype.hasOwnProperty.call(schemas_0, '__proto__') &&226    !Object.prototype.hasOwnProperty.call(exports, '__proto__') &&227    Object.defineProperty(exports, '__proto__', {228        enumerable: true,229        value: schemas_0['__proto__']230    });231 232Object.keys(schemas_0).forEach(function (k) {233    if (k !== 'default' && !Object.prototype.hasOwnProperty.call(exports, k)) exports[k] = schemas_0[k];234});235Object.prototype.hasOwnProperty.call(errors, '__proto__') &&236    !Object.prototype.hasOwnProperty.call(exports, '__proto__') &&237    Object.defineProperty(exports, '__proto__', {238        enumerable: true,239        value: errors['__proto__']240    });241 242Object.keys(errors).forEach(function (k) {243    if (k !== 'default' && !Object.prototype.hasOwnProperty.call(exports, k)) exports[k] = errors[k];244});245