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 AppflowServiceException = require('./models/AppflowServiceException');16 17const resolveClientEndpointParameters = (options) => {18    return Object.assign(options, {19        useDualstackEndpoint: options.useDualstackEndpoint ?? false,20        useFipsEndpoint: options.useFipsEndpoint ?? false,21        defaultSigningName: "appflow",22    });23};24const commonParams = {25    UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" },26    Endpoint: { type: "builtInParams", name: "endpoint" },27    Region: { type: "builtInParams", name: "region" },28    UseDualStack: { type: "builtInParams", name: "useDualstackEndpoint" },29};30 31const getHttpAuthExtensionConfiguration = (runtimeConfig) => {32    const _httpAuthSchemes = runtimeConfig.httpAuthSchemes;33    let _httpAuthSchemeProvider = runtimeConfig.httpAuthSchemeProvider;34    let _credentials = runtimeConfig.credentials;35    return {36        setHttpAuthScheme(httpAuthScheme) {37            const index = _httpAuthSchemes.findIndex((scheme) => scheme.schemeId === httpAuthScheme.schemeId);38            if (index === -1) {39                _httpAuthSchemes.push(httpAuthScheme);40            }41            else {42                _httpAuthSchemes.splice(index, 1, httpAuthScheme);43            }44        },45        httpAuthSchemes() {46            return _httpAuthSchemes;47        },48        setHttpAuthSchemeProvider(httpAuthSchemeProvider) {49            _httpAuthSchemeProvider = httpAuthSchemeProvider;50        },51        httpAuthSchemeProvider() {52            return _httpAuthSchemeProvider;53        },54        setCredentials(credentials) {55            _credentials = credentials;56        },57        credentials() {58            return _credentials;59        },60    };61};62const resolveHttpAuthRuntimeConfig = (config) => {63    return {64        httpAuthSchemes: config.httpAuthSchemes(),65        httpAuthSchemeProvider: config.httpAuthSchemeProvider(),66        credentials: config.credentials(),67    };68};69 70const resolveRuntimeExtensions = (runtimeConfig, extensions) => {71    const extensionConfiguration = Object.assign(client$1.getAwsRegionExtensionConfiguration(runtimeConfig), client.getDefaultExtensionConfiguration(runtimeConfig), protocols.getHttpHandlerExtensionConfiguration(runtimeConfig), getHttpAuthExtensionConfiguration(runtimeConfig));72    extensions.forEach((extension) => extension.configure(extensionConfiguration));73    return Object.assign(runtimeConfig, client$1.resolveAwsRegionExtensionConfiguration(extensionConfiguration), client.resolveDefaultRuntimeConfig(extensionConfiguration), protocols.resolveHttpHandlerRuntimeConfig(extensionConfiguration), resolveHttpAuthRuntimeConfig(extensionConfiguration));74};75 76class AppflowClient extends client.Client {77    config;78    constructor(...[configuration]) {79        const _config_0 = runtimeConfig.getRuntimeConfig(configuration || {});80        super(_config_0);81        this.initConfig = _config_0;82        const _config_1 = resolveClientEndpointParameters(_config_0);83        const _config_2 = client$1.resolveUserAgentConfig(_config_1);84        const _config_3 = retry.resolveRetryConfig(_config_2);85        const _config_4 = config.resolveRegionConfig(_config_3);86        const _config_5 = client$1.resolveHostHeaderConfig(_config_4);87        const _config_6 = endpoints.resolveEndpointConfig(_config_5);88        const _config_7 = httpAuthSchemeProvider.resolveHttpAuthSchemeConfig(_config_6);89        const _config_8 = resolveRuntimeExtensions(_config_7, configuration?.extensions || []);90        this.config = _config_8;91        this.middlewareStack.use(schema.getSchemaSerdePlugin(this.config));92        this.middlewareStack.use(client$1.getUserAgentPlugin(this.config));93        this.middlewareStack.use(retry.getRetryPlugin(this.config));94        this.middlewareStack.use(protocols.getContentLengthPlugin(this.config));95        this.middlewareStack.use(client$1.getHostHeaderPlugin(this.config));96        this.middlewareStack.use(client$1.getLoggerPlugin(this.config));97        this.middlewareStack.use(client$1.getRecursionDetectionPlugin(this.config));98        this.middlewareStack.use(core.getHttpAuthSchemeEndpointRuleSetPlugin(this.config, {99            httpAuthSchemeParametersProvider: httpAuthSchemeProvider.defaultAppflowHttpAuthSchemeParametersProvider,100            identityProviderConfigProvider: async (config) => new core.DefaultIdentityProviderConfig({101                "aws.auth#sigv4": config.credentials,102            }),103        }));104        this.middlewareStack.use(core.getHttpSigningPlugin(this.config));105    }106    destroy() {107        super.destroy();108    }109}110 111class CancelFlowExecutionsCommand extends client.Command112    .classBuilder()113    .ep(commonParams)114    .m(function (Command, cs, config, o) {115    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];116})117    .s("SandstoneConfigurationServiceLambda", "CancelFlowExecutions", {})118    .n("AppflowClient", "CancelFlowExecutionsCommand")119    .sc(schemas_0.CancelFlowExecutions$)120    .build() {121}122 123class CreateConnectorProfileCommand extends client.Command124    .classBuilder()125    .ep(commonParams)126    .m(function (Command, cs, config, o) {127    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];128})129    .s("SandstoneConfigurationServiceLambda", "CreateConnectorProfile", {})130    .n("AppflowClient", "CreateConnectorProfileCommand")131    .sc(schemas_0.CreateConnectorProfile$)132    .build() {133}134 135class CreateFlowCommand extends client.Command136    .classBuilder()137    .ep(commonParams)138    .m(function (Command, cs, config, o) {139    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];140})141    .s("SandstoneConfigurationServiceLambda", "CreateFlow", {})142    .n("AppflowClient", "CreateFlowCommand")143    .sc(schemas_0.CreateFlow$)144    .build() {145}146 147class DeleteConnectorProfileCommand extends client.Command148    .classBuilder()149    .ep(commonParams)150    .m(function (Command, cs, config, o) {151    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];152})153    .s("SandstoneConfigurationServiceLambda", "DeleteConnectorProfile", {})154    .n("AppflowClient", "DeleteConnectorProfileCommand")155    .sc(schemas_0.DeleteConnectorProfile$)156    .build() {157}158 159class DeleteFlowCommand extends client.Command160    .classBuilder()161    .ep(commonParams)162    .m(function (Command, cs, config, o) {163    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];164})165    .s("SandstoneConfigurationServiceLambda", "DeleteFlow", {})166    .n("AppflowClient", "DeleteFlowCommand")167    .sc(schemas_0.DeleteFlow$)168    .build() {169}170 171class DescribeConnectorCommand extends client.Command172    .classBuilder()173    .ep(commonParams)174    .m(function (Command, cs, config, o) {175    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];176})177    .s("SandstoneConfigurationServiceLambda", "DescribeConnector", {})178    .n("AppflowClient", "DescribeConnectorCommand")179    .sc(schemas_0.DescribeConnector$)180    .build() {181}182 183class DescribeConnectorEntityCommand extends client.Command184    .classBuilder()185    .ep(commonParams)186    .m(function (Command, cs, config, o) {187    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];188})189    .s("SandstoneConfigurationServiceLambda", "DescribeConnectorEntity", {})190    .n("AppflowClient", "DescribeConnectorEntityCommand")191    .sc(schemas_0.DescribeConnectorEntity$)192    .build() {193}194 195class DescribeConnectorProfilesCommand extends client.Command196    .classBuilder()197    .ep(commonParams)198    .m(function (Command, cs, config, o) {199    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];200})201    .s("SandstoneConfigurationServiceLambda", "DescribeConnectorProfiles", {})202    .n("AppflowClient", "DescribeConnectorProfilesCommand")203    .sc(schemas_0.DescribeConnectorProfiles$)204    .build() {205}206 207class DescribeConnectorsCommand extends client.Command208    .classBuilder()209    .ep(commonParams)210    .m(function (Command, cs, config, o) {211    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];212})213    .s("SandstoneConfigurationServiceLambda", "DescribeConnectors", {})214    .n("AppflowClient", "DescribeConnectorsCommand")215    .sc(schemas_0.DescribeConnectors$)216    .build() {217}218 219class DescribeFlowCommand extends client.Command220    .classBuilder()221    .ep(commonParams)222    .m(function (Command, cs, config, o) {223    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];224})225    .s("SandstoneConfigurationServiceLambda", "DescribeFlow", {})226    .n("AppflowClient", "DescribeFlowCommand")227    .sc(schemas_0.DescribeFlow$)228    .build() {229}230 231class DescribeFlowExecutionRecordsCommand extends client.Command232    .classBuilder()233    .ep(commonParams)234    .m(function (Command, cs, config, o) {235    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];236})237    .s("SandstoneConfigurationServiceLambda", "DescribeFlowExecutionRecords", {})238    .n("AppflowClient", "DescribeFlowExecutionRecordsCommand")239    .sc(schemas_0.DescribeFlowExecutionRecords$)240    .build() {241}242 243class ListConnectorEntitiesCommand extends client.Command244    .classBuilder()245    .ep(commonParams)246    .m(function (Command, cs, config, o) {247    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];248})249    .s("SandstoneConfigurationServiceLambda", "ListConnectorEntities", {})250    .n("AppflowClient", "ListConnectorEntitiesCommand")251    .sc(schemas_0.ListConnectorEntities$)252    .build() {253}254 255class ListConnectorsCommand extends client.Command256    .classBuilder()257    .ep(commonParams)258    .m(function (Command, cs, config, o) {259    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];260})261    .s("SandstoneConfigurationServiceLambda", "ListConnectors", {})262    .n("AppflowClient", "ListConnectorsCommand")263    .sc(schemas_0.ListConnectors$)264    .build() {265}266 267class ListFlowsCommand extends client.Command268    .classBuilder()269    .ep(commonParams)270    .m(function (Command, cs, config, o) {271    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];272})273    .s("SandstoneConfigurationServiceLambda", "ListFlows", {})274    .n("AppflowClient", "ListFlowsCommand")275    .sc(schemas_0.ListFlows$)276    .build() {277}278 279class ListTagsForResourceCommand extends client.Command280    .classBuilder()281    .ep(commonParams)282    .m(function (Command, cs, config, o) {283    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];284})285    .s("SandstoneConfigurationServiceLambda", "ListTagsForResource", {})286    .n("AppflowClient", "ListTagsForResourceCommand")287    .sc(schemas_0.ListTagsForResource$)288    .build() {289}290 291class RegisterConnectorCommand extends client.Command292    .classBuilder()293    .ep(commonParams)294    .m(function (Command, cs, config, o) {295    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];296})297    .s("SandstoneConfigurationServiceLambda", "RegisterConnector", {})298    .n("AppflowClient", "RegisterConnectorCommand")299    .sc(schemas_0.RegisterConnector$)300    .build() {301}302 303class ResetConnectorMetadataCacheCommand extends client.Command304    .classBuilder()305    .ep(commonParams)306    .m(function (Command, cs, config, o) {307    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];308})309    .s("SandstoneConfigurationServiceLambda", "ResetConnectorMetadataCache", {})310    .n("AppflowClient", "ResetConnectorMetadataCacheCommand")311    .sc(schemas_0.ResetConnectorMetadataCache$)312    .build() {313}314 315class StartFlowCommand extends client.Command316    .classBuilder()317    .ep(commonParams)318    .m(function (Command, cs, config, o) {319    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];320})321    .s("SandstoneConfigurationServiceLambda", "StartFlow", {})322    .n("AppflowClient", "StartFlowCommand")323    .sc(schemas_0.StartFlow$)324    .build() {325}326 327class StopFlowCommand extends client.Command328    .classBuilder()329    .ep(commonParams)330    .m(function (Command, cs, config, o) {331    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];332})333    .s("SandstoneConfigurationServiceLambda", "StopFlow", {})334    .n("AppflowClient", "StopFlowCommand")335    .sc(schemas_0.StopFlow$)336    .build() {337}338 339class TagResourceCommand extends client.Command340    .classBuilder()341    .ep(commonParams)342    .m(function (Command, cs, config, o) {343    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];344})345    .s("SandstoneConfigurationServiceLambda", "TagResource", {})346    .n("AppflowClient", "TagResourceCommand")347    .sc(schemas_0.TagResource$)348    .build() {349}350 351class UnregisterConnectorCommand extends client.Command352    .classBuilder()353    .ep(commonParams)354    .m(function (Command, cs, config, o) {355    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];356})357    .s("SandstoneConfigurationServiceLambda", "UnregisterConnector", {})358    .n("AppflowClient", "UnregisterConnectorCommand")359    .sc(schemas_0.UnregisterConnector$)360    .build() {361}362 363class UntagResourceCommand extends client.Command364    .classBuilder()365    .ep(commonParams)366    .m(function (Command, cs, config, o) {367    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];368})369    .s("SandstoneConfigurationServiceLambda", "UntagResource", {})370    .n("AppflowClient", "UntagResourceCommand")371    .sc(schemas_0.UntagResource$)372    .build() {373}374 375class UpdateConnectorProfileCommand extends client.Command376    .classBuilder()377    .ep(commonParams)378    .m(function (Command, cs, config, o) {379    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];380})381    .s("SandstoneConfigurationServiceLambda", "UpdateConnectorProfile", {})382    .n("AppflowClient", "UpdateConnectorProfileCommand")383    .sc(schemas_0.UpdateConnectorProfile$)384    .build() {385}386 387class UpdateConnectorRegistrationCommand extends client.Command388    .classBuilder()389    .ep(commonParams)390    .m(function (Command, cs, config, o) {391    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];392})393    .s("SandstoneConfigurationServiceLambda", "UpdateConnectorRegistration", {})394    .n("AppflowClient", "UpdateConnectorRegistrationCommand")395    .sc(schemas_0.UpdateConnectorRegistration$)396    .build() {397}398 399class UpdateFlowCommand extends client.Command400    .classBuilder()401    .ep(commonParams)402    .m(function (Command, cs, config, o) {403    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];404})405    .s("SandstoneConfigurationServiceLambda", "UpdateFlow", {})406    .n("AppflowClient", "UpdateFlowCommand")407    .sc(schemas_0.UpdateFlow$)408    .build() {409}410 411const paginateDescribeConnectorProfiles = core.createPaginator(AppflowClient, DescribeConnectorProfilesCommand, "nextToken", "nextToken", "maxResults");412 413const paginateDescribeConnectors = core.createPaginator(AppflowClient, DescribeConnectorsCommand, "nextToken", "nextToken", "maxResults");414 415const paginateDescribeFlowExecutionRecords = core.createPaginator(AppflowClient, DescribeFlowExecutionRecordsCommand, "nextToken", "nextToken", "maxResults");416 417const paginateListConnectors = core.createPaginator(AppflowClient, ListConnectorsCommand, "nextToken", "nextToken", "maxResults");418 419const paginateListFlows = core.createPaginator(AppflowClient, ListFlowsCommand, "nextToken", "nextToken", "maxResults");420 421const commands = {422    CancelFlowExecutionsCommand,423    CreateConnectorProfileCommand,424    CreateFlowCommand,425    DeleteConnectorProfileCommand,426    DeleteFlowCommand,427    DescribeConnectorCommand,428    DescribeConnectorEntityCommand,429    DescribeConnectorProfilesCommand,430    DescribeConnectorsCommand,431    DescribeFlowCommand,432    DescribeFlowExecutionRecordsCommand,433    ListConnectorEntitiesCommand,434    ListConnectorsCommand,435    ListFlowsCommand,436    ListTagsForResourceCommand,437    RegisterConnectorCommand,438    ResetConnectorMetadataCacheCommand,439    StartFlowCommand,440    StopFlowCommand,441    TagResourceCommand,442    UnregisterConnectorCommand,443    UntagResourceCommand,444    UpdateConnectorProfileCommand,445    UpdateConnectorRegistrationCommand,446    UpdateFlowCommand,447};448const paginators = {449    paginateDescribeConnectorProfiles,450    paginateDescribeConnectors,451    paginateDescribeFlowExecutionRecords,452    paginateListConnectors,453    paginateListFlows,454};455class Appflow extends AppflowClient {456}457client.createAggregatedClient(commands, Appflow, { paginators });458 459const AggregationType = {460    NONE: "None",461    SINGLE_FILE: "SingleFile",462};463const AmplitudeConnectorOperator = {464    BETWEEN: "BETWEEN",465};466const OAuth2CustomPropType = {467    AUTH_URL: "AUTH_URL",468    TOKEN_URL: "TOKEN_URL",469};470const OAuth2GrantType = {471    AUTHORIZATION_CODE: "AUTHORIZATION_CODE",472    CLIENT_CREDENTIALS: "CLIENT_CREDENTIALS",473    JWT_BEARER: "JWT_BEARER",474};475const AuthenticationType = {476    APIKEY: "APIKEY",477    BASIC: "BASIC",478    CUSTOM: "CUSTOM",479    OAUTH2: "OAUTH2",480};481const CatalogType = {482    GLUE: "GLUE",483};484const ConnectionMode = {485    PRIVATE: "Private",486    PUBLIC: "Public",487};488const SalesforceDataTransferApi = {489    AUTOMATIC: "AUTOMATIC",490    BULKV2: "BULKV2",491    REST_SYNC: "REST_SYNC",492};493const ConnectorProvisioningType = {494    LAMBDA: "LAMBDA",495};496const ConnectorType = {497    AMPLITUDE: "Amplitude",498    CUSTOMCONNECTOR: "CustomConnector",499    CUSTOMERPROFILES: "CustomerProfiles",500    DATADOG: "Datadog",501    DYNATRACE: "Dynatrace",502    EVENTBRIDGE: "EventBridge",503    GOOGLEANALYTICS: "Googleanalytics",504    HONEYCODE: "Honeycode",505    INFORNEXUS: "Infornexus",506    LOOKOUTMETRICS: "LookoutMetrics",507    MARKETO: "Marketo",508    PARDOT: "Pardot",509    REDSHIFT: "Redshift",510    S3: "S3",511    SALESFORCE: "Salesforce",512    SAPODATA: "SAPOData",513    SERVICENOW: "Servicenow",514    SINGULAR: "Singular",515    SLACK: "Slack",516    SNOWFLAKE: "Snowflake",517    TRENDMICRO: "Trendmicro",518    UPSOLVER: "Upsolver",519    VEEVA: "Veeva",520    ZENDESK: "Zendesk",521};522const DataTransferApiType = {523    ASYNC: "ASYNC",524    AUTOMATIC: "AUTOMATIC",525    SYNC: "SYNC",526};527const SupportedDataTransferType = {528    FILE: "FILE",529    RECORD: "RECORD",530};531const Operators = {532    ADDITION: "ADDITION",533    BETWEEN: "BETWEEN",534    CONTAINS: "CONTAINS",535    DIVISION: "DIVISION",536    EQUAL_TO: "EQUAL_TO",537    GREATER_THAN: "GREATER_THAN",538    GREATER_THAN_OR_EQUAL_TO: "GREATER_THAN_OR_EQUAL_TO",539    LESS_THAN: "LESS_THAN",540    LESS_THAN_OR_EQUAL_TO: "LESS_THAN_OR_EQUAL_TO",541    MASK_ALL: "MASK_ALL",542    MASK_FIRST_N: "MASK_FIRST_N",543    MASK_LAST_N: "MASK_LAST_N",544    MULTIPLICATION: "MULTIPLICATION",545    NOT_EQUAL_TO: "NOT_EQUAL_TO",546    NO_OP: "NO_OP",547    PROJECTION: "PROJECTION",548    SUBTRACTION: "SUBTRACTION",549    VALIDATE_NON_NEGATIVE: "VALIDATE_NON_NEGATIVE",550    VALIDATE_NON_NULL: "VALIDATE_NON_NULL",551    VALIDATE_NON_ZERO: "VALIDATE_NON_ZERO",552    VALIDATE_NUMERIC: "VALIDATE_NUMERIC",553};554const ScheduleFrequencyType = {555    BYMINUTE: "BYMINUTE",556    DAILY: "DAILY",557    HOURLY: "HOURLY",558    MONTHLY: "MONTHLY",559    ONCE: "ONCE",560    WEEKLY: "WEEKLY",561};562const TriggerType = {563    EVENT: "Event",564    ONDEMAND: "OnDemand",565    SCHEDULED: "Scheduled",566};567const WriteOperationType = {568    DELETE: "DELETE",569    INSERT: "INSERT",570    UPDATE: "UPDATE",571    UPSERT: "UPSERT",572};573const Operator = {574    ADDITION: "ADDITION",575    BETWEEN: "BETWEEN",576    CONTAINS: "CONTAINS",577    DIVISION: "DIVISION",578    EQUAL_TO: "EQUAL_TO",579    GREATER_THAN: "GREATER_THAN",580    GREATER_THAN_OR_EQUAL_TO: "GREATER_THAN_OR_EQUAL_TO",581    LESS_THAN: "LESS_THAN",582    LESS_THAN_OR_EQUAL_TO: "LESS_THAN_OR_EQUAL_TO",583    MASK_ALL: "MASK_ALL",584    MASK_FIRST_N: "MASK_FIRST_N",585    MASK_LAST_N: "MASK_LAST_N",586    MULTIPLICATION: "MULTIPLICATION",587    NOT_EQUAL_TO: "NOT_EQUAL_TO",588    NO_OP: "NO_OP",589    PROJECTION: "PROJECTION",590    SUBTRACTION: "SUBTRACTION",591    VALIDATE_NON_NEGATIVE: "VALIDATE_NON_NEGATIVE",592    VALIDATE_NON_NULL: "VALIDATE_NON_NULL",593    VALIDATE_NON_ZERO: "VALIDATE_NON_ZERO",594    VALIDATE_NUMERIC: "VALIDATE_NUMERIC",595};596const DatadogConnectorOperator = {597    ADDITION: "ADDITION",598    BETWEEN: "BETWEEN",599    DIVISION: "DIVISION",600    EQUAL_TO: "EQUAL_TO",601    MASK_ALL: "MASK_ALL",602    MASK_FIRST_N: "MASK_FIRST_N",603    MASK_LAST_N: "MASK_LAST_N",604    MULTIPLICATION: "MULTIPLICATION",605    NO_OP: "NO_OP",606    PROJECTION: "PROJECTION",607    SUBTRACTION: "SUBTRACTION",608    VALIDATE_NON_NEGATIVE: "VALIDATE_NON_NEGATIVE",609    VALIDATE_NON_NULL: "VALIDATE_NON_NULL",610    VALIDATE_NON_ZERO: "VALIDATE_NON_ZERO",611    VALIDATE_NUMERIC: "VALIDATE_NUMERIC",612};613const DynatraceConnectorOperator = {614    ADDITION: "ADDITION",615    BETWEEN: "BETWEEN",616    DIVISION: "DIVISION",617    EQUAL_TO: "EQUAL_TO",618    MASK_ALL: "MASK_ALL",619    MASK_FIRST_N: "MASK_FIRST_N",620    MASK_LAST_N: "MASK_LAST_N",621    MULTIPLICATION: "MULTIPLICATION",622    NO_OP: "NO_OP",623    PROJECTION: "PROJECTION",624    SUBTRACTION: "SUBTRACTION",625    VALIDATE_NON_NEGATIVE: "VALIDATE_NON_NEGATIVE",626    VALIDATE_NON_NULL: "VALIDATE_NON_NULL",627    VALIDATE_NON_ZERO: "VALIDATE_NON_ZERO",628    VALIDATE_NUMERIC: "VALIDATE_NUMERIC",629};630const GoogleAnalyticsConnectorOperator = {631    BETWEEN: "BETWEEN",632    PROJECTION: "PROJECTION",633};634const InforNexusConnectorOperator = {635    ADDITION: "ADDITION",636    BETWEEN: "BETWEEN",637    DIVISION: "DIVISION",638    EQUAL_TO: "EQUAL_TO",639    MASK_ALL: "MASK_ALL",640    MASK_FIRST_N: "MASK_FIRST_N",641    MASK_LAST_N: "MASK_LAST_N",642    MULTIPLICATION: "MULTIPLICATION",643    NO_OP: "NO_OP",644    PROJECTION: "PROJECTION",645    SUBTRACTION: "SUBTRACTION",646    VALIDATE_NON_NEGATIVE: "VALIDATE_NON_NEGATIVE",647    VALIDATE_NON_NULL: "VALIDATE_NON_NULL",648    VALIDATE_NON_ZERO: "VALIDATE_NON_ZERO",649    VALIDATE_NUMERIC: "VALIDATE_NUMERIC",650};651const MarketoConnectorOperator = {652    ADDITION: "ADDITION",653    BETWEEN: "BETWEEN",654    DIVISION: "DIVISION",655    GREATER_THAN: "GREATER_THAN",656    LESS_THAN: "LESS_THAN",657    MASK_ALL: "MASK_ALL",658    MASK_FIRST_N: "MASK_FIRST_N",659    MASK_LAST_N: "MASK_LAST_N",660    MULTIPLICATION: "MULTIPLICATION",661    NO_OP: "NO_OP",662    PROJECTION: "PROJECTION",663    SUBTRACTION: "SUBTRACTION",664    VALIDATE_NON_NEGATIVE: "VALIDATE_NON_NEGATIVE",665    VALIDATE_NON_NULL: "VALIDATE_NON_NULL",666    VALIDATE_NON_ZERO: "VALIDATE_NON_ZERO",667    VALIDATE_NUMERIC: "VALIDATE_NUMERIC",668};669const PardotConnectorOperator = {670    ADDITION: "ADDITION",671    DIVISION: "DIVISION",672    EQUAL_TO: "EQUAL_TO",673    MASK_ALL: "MASK_ALL",674    MASK_FIRST_N: "MASK_FIRST_N",675    MASK_LAST_N: "MASK_LAST_N",676    MULTIPLICATION: "MULTIPLICATION",677    NO_OP: "NO_OP",678    PROJECTION: "PROJECTION",679    SUBTRACTION: "SUBTRACTION",680    VALIDATE_NON_NEGATIVE: "VALIDATE_NON_NEGATIVE",681    VALIDATE_NON_NULL: "VALIDATE_NON_NULL",682    VALIDATE_NON_ZERO: "VALIDATE_NON_ZERO",683    VALIDATE_NUMERIC: "VALIDATE_NUMERIC",684};685const S3ConnectorOperator = {686    ADDITION: "ADDITION",687    BETWEEN: "BETWEEN",688    DIVISION: "DIVISION",689    EQUAL_TO: "EQUAL_TO",690    GREATER_THAN: "GREATER_THAN",691    GREATER_THAN_OR_EQUAL_TO: "GREATER_THAN_OR_EQUAL_TO",692    LESS_THAN: "LESS_THAN",693    LESS_THAN_OR_EQUAL_TO: "LESS_THAN_OR_EQUAL_TO",694    MASK_ALL: "MASK_ALL",695    MASK_FIRST_N: "MASK_FIRST_N",696    MASK_LAST_N: "MASK_LAST_N",697    MULTIPLICATION: "MULTIPLICATION",698    NOT_EQUAL_TO: "NOT_EQUAL_TO",699    NO_OP: "NO_OP",700    PROJECTION: "PROJECTION",701    SUBTRACTION: "SUBTRACTION",702    VALIDATE_NON_NEGATIVE: "VALIDATE_NON_NEGATIVE",703    VALIDATE_NON_NULL: "VALIDATE_NON_NULL",704    VALIDATE_NON_ZERO: "VALIDATE_NON_ZERO",705    VALIDATE_NUMERIC: "VALIDATE_NUMERIC",706};707const SalesforceConnectorOperator = {708    ADDITION: "ADDITION",709    BETWEEN: "BETWEEN",710    CONTAINS: "CONTAINS",711    DIVISION: "DIVISION",712    EQUAL_TO: "EQUAL_TO",713    GREATER_THAN: "GREATER_THAN",714    GREATER_THAN_OR_EQUAL_TO: "GREATER_THAN_OR_EQUAL_TO",715    LESS_THAN: "LESS_THAN",716    LESS_THAN_OR_EQUAL_TO: "LESS_THAN_OR_EQUAL_TO",717    MASK_ALL: "MASK_ALL",718    MASK_FIRST_N: "MASK_FIRST_N",719    MASK_LAST_N: "MASK_LAST_N",720    MULTIPLICATION: "MULTIPLICATION",721    NOT_EQUAL_TO: "NOT_EQUAL_TO",722    NO_OP: "NO_OP",723    PROJECTION: "PROJECTION",724    SUBTRACTION: "SUBTRACTION",725    VALIDATE_NON_NEGATIVE: "VALIDATE_NON_NEGATIVE",726    VALIDATE_NON_NULL: "VALIDATE_NON_NULL",727    VALIDATE_NON_ZERO: "VALIDATE_NON_ZERO",728    VALIDATE_NUMERIC: "VALIDATE_NUMERIC",729};730const SAPODataConnectorOperator = {731    ADDITION: "ADDITION",732    BETWEEN: "BETWEEN",733    CONTAINS: "CONTAINS",734    DIVISION: "DIVISION",735    EQUAL_TO: "EQUAL_TO",736    GREATER_THAN: "GREATER_THAN",737    GREATER_THAN_OR_EQUAL_TO: "GREATER_THAN_OR_EQUAL_TO",738    LESS_THAN: "LESS_THAN",739    LESS_THAN_OR_EQUAL_TO: "LESS_THAN_OR_EQUAL_TO",740    MASK_ALL: "MASK_ALL",741    MASK_FIRST_N: "MASK_FIRST_N",742    MASK_LAST_N: "MASK_LAST_N",743    MULTIPLICATION: "MULTIPLICATION",744    NOT_EQUAL_TO: "NOT_EQUAL_TO",745    NO_OP: "NO_OP",746    PROJECTION: "PROJECTION",747    SUBTRACTION: "SUBTRACTION",748    VALIDATE_NON_NEGATIVE: "VALIDATE_NON_NEGATIVE",749    VALIDATE_NON_NULL: "VALIDATE_NON_NULL",750    VALIDATE_NON_ZERO: "VALIDATE_NON_ZERO",751    VALIDATE_NUMERIC: "VALIDATE_NUMERIC",752};753const ServiceNowConnectorOperator = {754    ADDITION: "ADDITION",755    BETWEEN: "BETWEEN",756    CONTAINS: "CONTAINS",757    DIVISION: "DIVISION",758    EQUAL_TO: "EQUAL_TO",759    GREATER_THAN: "GREATER_THAN",760    GREATER_THAN_OR_EQUAL_TO: "GREATER_THAN_OR_EQUAL_TO",761    LESS_THAN: "LESS_THAN",762    LESS_THAN_OR_EQUAL_TO: "LESS_THAN_OR_EQUAL_TO",763    MASK_ALL: "MASK_ALL",764    MASK_FIRST_N: "MASK_FIRST_N",765    MASK_LAST_N: "MASK_LAST_N",766    MULTIPLICATION: "MULTIPLICATION",767    NOT_EQUAL_TO: "NOT_EQUAL_TO",768    NO_OP: "NO_OP",769    PROJECTION: "PROJECTION",770    SUBTRACTION: "SUBTRACTION",771    VALIDATE_NON_NEGATIVE: "VALIDATE_NON_NEGATIVE",772    VALIDATE_NON_NULL: "VALIDATE_NON_NULL",773    VALIDATE_NON_ZERO: "VALIDATE_NON_ZERO",774    VALIDATE_NUMERIC: "VALIDATE_NUMERIC",775};776const SingularConnectorOperator = {777    ADDITION: "ADDITION",778    DIVISION: "DIVISION",779    EQUAL_TO: "EQUAL_TO",780    MASK_ALL: "MASK_ALL",781    MASK_FIRST_N: "MASK_FIRST_N",782    MASK_LAST_N: "MASK_LAST_N",783    MULTIPLICATION: "MULTIPLICATION",784    NO_OP: "NO_OP",785    PROJECTION: "PROJECTION",786    SUBTRACTION: "SUBTRACTION",787    VALIDATE_NON_NEGATIVE: "VALIDATE_NON_NEGATIVE",788    VALIDATE_NON_NULL: "VALIDATE_NON_NULL",789    VALIDATE_NON_ZERO: "VALIDATE_NON_ZERO",790    VALIDATE_NUMERIC: "VALIDATE_NUMERIC",791};792const SlackConnectorOperator = {793    ADDITION: "ADDITION",794    BETWEEN: "BETWEEN",795    DIVISION: "DIVISION",796    EQUAL_TO: "EQUAL_TO",797    GREATER_THAN: "GREATER_THAN",798    GREATER_THAN_OR_EQUAL_TO: "GREATER_THAN_OR_EQUAL_TO",799    LESS_THAN: "LESS_THAN",800    LESS_THAN_OR_EQUAL_TO: "LESS_THAN_OR_EQUAL_TO",801    MASK_ALL: "MASK_ALL",802    MASK_FIRST_N: "MASK_FIRST_N",803    MASK_LAST_N: "MASK_LAST_N",804    MULTIPLICATION: "MULTIPLICATION",805    NO_OP: "NO_OP",806    PROJECTION: "PROJECTION",807    SUBTRACTION: "SUBTRACTION",808    VALIDATE_NON_NEGATIVE: "VALIDATE_NON_NEGATIVE",809    VALIDATE_NON_NULL: "VALIDATE_NON_NULL",810    VALIDATE_NON_ZERO: "VALIDATE_NON_ZERO",811    VALIDATE_NUMERIC: "VALIDATE_NUMERIC",812};813const TrendmicroConnectorOperator = {814    ADDITION: "ADDITION",815    DIVISION: "DIVISION",816    EQUAL_TO: "EQUAL_TO",817    MASK_ALL: "MASK_ALL",818    MASK_FIRST_N: "MASK_FIRST_N",819    MASK_LAST_N: "MASK_LAST_N",820    MULTIPLICATION: "MULTIPLICATION",821    NO_OP: "NO_OP",822    PROJECTION: "PROJECTION",823    SUBTRACTION: "SUBTRACTION",824    VALIDATE_NON_NEGATIVE: "VALIDATE_NON_NEGATIVE",825    VALIDATE_NON_NULL: "VALIDATE_NON_NULL",826    VALIDATE_NON_ZERO: "VALIDATE_NON_ZERO",827    VALIDATE_NUMERIC: "VALIDATE_NUMERIC",828};829const VeevaConnectorOperator = {830    ADDITION: "ADDITION",831    BETWEEN: "BETWEEN",832    CONTAINS: "CONTAINS",833    DIVISION: "DIVISION",834    EQUAL_TO: "EQUAL_TO",835    GREATER_THAN: "GREATER_THAN",836    GREATER_THAN_OR_EQUAL_TO: "GREATER_THAN_OR_EQUAL_TO",837    LESS_THAN: "LESS_THAN",838    LESS_THAN_OR_EQUAL_TO: "LESS_THAN_OR_EQUAL_TO",839    MASK_ALL: "MASK_ALL",840    MASK_FIRST_N: "MASK_FIRST_N",841    MASK_LAST_N: "MASK_LAST_N",842    MULTIPLICATION: "MULTIPLICATION",843    NOT_EQUAL_TO: "NOT_EQUAL_TO",844    NO_OP: "NO_OP",845    PROJECTION: "PROJECTION",846    SUBTRACTION: "SUBTRACTION",847    VALIDATE_NON_NEGATIVE: "VALIDATE_NON_NEGATIVE",848    VALIDATE_NON_NULL: "VALIDATE_NON_NULL",849    VALIDATE_NON_ZERO: "VALIDATE_NON_ZERO",850    VALIDATE_NUMERIC: "VALIDATE_NUMERIC",851};852const ZendeskConnectorOperator = {853    ADDITION: "ADDITION",854    DIVISION: "DIVISION",855    GREATER_THAN: "GREATER_THAN",856    MASK_ALL: "MASK_ALL",857    MASK_FIRST_N: "MASK_FIRST_N",858    MASK_LAST_N: "MASK_LAST_N",859    MULTIPLICATION: "MULTIPLICATION",860    NO_OP: "NO_OP",861    PROJECTION: "PROJECTION",862    SUBTRACTION: "SUBTRACTION",863    VALIDATE_NON_NEGATIVE: "VALIDATE_NON_NEGATIVE",864    VALIDATE_NON_NULL: "VALIDATE_NON_NULL",865    VALIDATE_NON_ZERO: "VALIDATE_NON_ZERO",866    VALIDATE_NUMERIC: "VALIDATE_NUMERIC",867};868const PrivateConnectionProvisioningFailureCause = {869    ACCESS_DENIED: "ACCESS_DENIED",870    CONNECTOR_AUTHENTICATION: "CONNECTOR_AUTHENTICATION",871    CONNECTOR_SERVER: "CONNECTOR_SERVER",872    INTERNAL_SERVER: "INTERNAL_SERVER",873    VALIDATION: "VALIDATION",874};875const PrivateConnectionProvisioningStatus = {876    CREATED: "CREATED",877    FAILED: "FAILED",878    PENDING: "PENDING",879};880const FileType = {881    CSV: "CSV",882    JSON: "JSON",883    PARQUET: "PARQUET",884};885const PathPrefix = {886    EXECUTION_ID: "EXECUTION_ID",887    SCHEMA_VERSION: "SCHEMA_VERSION",888};889const PrefixFormat = {890    DAY: "DAY",891    HOUR: "HOUR",892    MINUTE: "MINUTE",893    MONTH: "MONTH",894    YEAR: "YEAR",895};896const PrefixType = {897    FILENAME: "FILENAME",898    PATH: "PATH",899    PATH_AND_FILENAME: "PATH_AND_FILENAME",900};901const S3InputFileType = {902    CSV: "CSV",903    JSON: "JSON",904};905const OperatorPropertiesKeys = {906    CONCAT_FORMAT: "CONCAT_FORMAT",907    DATA_TYPE: "DATA_TYPE",908    DESTINATION_DATA_TYPE: "DESTINATION_DATA_TYPE",909    EXCLUDE_SOURCE_FIELDS_LIST: "EXCLUDE_SOURCE_FIELDS_LIST",910    INCLUDE_NEW_FIELDS: "INCLUDE_NEW_FIELDS",911    LOWER_BOUND: "LOWER_BOUND",912    MASK_LENGTH: "MASK_LENGTH",913    MASK_VALUE: "MASK_VALUE",914    MATH_OPERATION_FIELDS_ORDER: "MATH_OPERATION_FIELDS_ORDER",915    ORDERED_PARTITION_KEYS_LIST: "ORDERED_PARTITION_KEYS_LIST",916    SOURCE_DATA_TYPE: "SOURCE_DATA_TYPE",917    SUBFIELD_CATEGORY_MAP: "SUBFIELD_CATEGORY_MAP",918    TRUNCATE_LENGTH: "TRUNCATE_LENGTH",919    UPPER_BOUND: "UPPER_BOUND",920    VALIDATION_ACTION: "VALIDATION_ACTION",921    VALUE: "VALUE",922    VALUES: "VALUES",923};924const TaskType = {925    ARITHMETIC: "Arithmetic",926    FILTER: "Filter",927    MAP: "Map",928    MAP_ALL: "Map_all",929    MASK: "Mask",930    MERGE: "Merge",931    PARTITION: "Partition",932    PASSTHROUGH: "Passthrough",933    TRUNCATE: "Truncate",934    VALIDATE: "Validate",935};936const DataPullMode = {937    COMPLETE: "Complete",938    INCREMENTAL: "Incremental",939};940const FlowStatus = {941    ACTIVE: "Active",942    DELETED: "Deleted",943    DEPRECATED: "Deprecated",944    DRAFT: "Draft",945    ERRORED: "Errored",946    SUSPENDED: "Suspended",947};948const ExecutionStatus = {949    CANCELED: "Canceled",950    CANCELSTARTED: "CancelStarted",951    ERROR: "Error",952    INPROGRESS: "InProgress",953    SUCCESSFUL: "Successful",954};955 956exports.$Command = client.Command;957exports.__Client = client.Client;958exports.AppflowServiceException = AppflowServiceException.AppflowServiceException;959exports.AggregationType = AggregationType;960exports.AmplitudeConnectorOperator = AmplitudeConnectorOperator;961exports.Appflow = Appflow;962exports.AppflowClient = AppflowClient;963exports.AuthenticationType = AuthenticationType;964exports.CancelFlowExecutionsCommand = CancelFlowExecutionsCommand;965exports.CatalogType = CatalogType;966exports.ConnectionMode = ConnectionMode;967exports.ConnectorProvisioningType = ConnectorProvisioningType;968exports.ConnectorType = ConnectorType;969exports.CreateConnectorProfileCommand = CreateConnectorProfileCommand;970exports.CreateFlowCommand = CreateFlowCommand;971exports.DataPullMode = DataPullMode;972exports.DataTransferApiType = DataTransferApiType;973exports.DatadogConnectorOperator = DatadogConnectorOperator;974exports.DeleteConnectorProfileCommand = DeleteConnectorProfileCommand;975exports.DeleteFlowCommand = DeleteFlowCommand;976exports.DescribeConnectorCommand = DescribeConnectorCommand;977exports.DescribeConnectorEntityCommand = DescribeConnectorEntityCommand;978exports.DescribeConnectorProfilesCommand = DescribeConnectorProfilesCommand;979exports.DescribeConnectorsCommand = DescribeConnectorsCommand;980exports.DescribeFlowCommand = DescribeFlowCommand;981exports.DescribeFlowExecutionRecordsCommand = DescribeFlowExecutionRecordsCommand;982exports.DynatraceConnectorOperator = DynatraceConnectorOperator;983exports.ExecutionStatus = ExecutionStatus;984exports.FileType = FileType;985exports.FlowStatus = FlowStatus;986exports.GoogleAnalyticsConnectorOperator = GoogleAnalyticsConnectorOperator;987exports.InforNexusConnectorOperator = InforNexusConnectorOperator;988exports.ListConnectorEntitiesCommand = ListConnectorEntitiesCommand;989exports.ListConnectorsCommand = ListConnectorsCommand;990exports.ListFlowsCommand = ListFlowsCommand;991exports.ListTagsForResourceCommand = ListTagsForResourceCommand;992exports.MarketoConnectorOperator = MarketoConnectorOperator;993exports.OAuth2CustomPropType = OAuth2CustomPropType;994exports.OAuth2GrantType = OAuth2GrantType;995exports.Operator = Operator;996exports.OperatorPropertiesKeys = OperatorPropertiesKeys;997exports.Operators = Operators;998exports.PardotConnectorOperator = PardotConnectorOperator;999exports.PathPrefix = PathPrefix;1000exports.PrefixFormat = PrefixFormat;1001exports.PrefixType = PrefixType;1002exports.PrivateConnectionProvisioningFailureCause = PrivateConnectionProvisioningFailureCause;1003exports.PrivateConnectionProvisioningStatus = PrivateConnectionProvisioningStatus;1004exports.RegisterConnectorCommand = RegisterConnectorCommand;1005exports.ResetConnectorMetadataCacheCommand = ResetConnectorMetadataCacheCommand;1006exports.S3ConnectorOperator = S3ConnectorOperator;1007exports.S3InputFileType = S3InputFileType;1008exports.SAPODataConnectorOperator = SAPODataConnectorOperator;1009exports.SalesforceConnectorOperator = SalesforceConnectorOperator;1010exports.SalesforceDataTransferApi = SalesforceDataTransferApi;1011exports.ScheduleFrequencyType = ScheduleFrequencyType;1012exports.ServiceNowConnectorOperator = ServiceNowConnectorOperator;1013exports.SingularConnectorOperator = SingularConnectorOperator;1014exports.SlackConnectorOperator = SlackConnectorOperator;1015exports.StartFlowCommand = StartFlowCommand;1016exports.StopFlowCommand = StopFlowCommand;1017exports.SupportedDataTransferType = SupportedDataTransferType;1018exports.TagResourceCommand = TagResourceCommand;1019exports.TaskType = TaskType;1020exports.TrendmicroConnectorOperator = TrendmicroConnectorOperator;1021exports.TriggerType = TriggerType;1022exports.UnregisterConnectorCommand = UnregisterConnectorCommand;1023exports.UntagResourceCommand = UntagResourceCommand;1024exports.UpdateConnectorProfileCommand = UpdateConnectorProfileCommand;1025exports.UpdateConnectorRegistrationCommand = UpdateConnectorRegistrationCommand;1026exports.UpdateFlowCommand = UpdateFlowCommand;1027exports.VeevaConnectorOperator = VeevaConnectorOperator;1028exports.WriteOperationType = WriteOperationType;1029exports.ZendeskConnectorOperator = ZendeskConnectorOperator;1030exports.paginateDescribeConnectorProfiles = paginateDescribeConnectorProfiles;1031exports.paginateDescribeConnectors = paginateDescribeConnectors;1032exports.paginateDescribeFlowExecutionRecords = paginateDescribeFlowExecutionRecords;1033exports.paginateListConnectors = paginateListConnectors;1034exports.paginateListFlows = paginateListFlows;1035Object.prototype.hasOwnProperty.call(schemas_0, '__proto__') &&1036    !Object.prototype.hasOwnProperty.call(exports, '__proto__') &&1037    Object.defineProperty(exports, '__proto__', {1038        enumerable: true,1039        value: schemas_0['__proto__']1040    });1041 1042Object.keys(schemas_0).forEach(function (k) {1043    if (k !== 'default' && !Object.prototype.hasOwnProperty.call(exports, k)) exports[k] = schemas_0[k];1044});1045Object.prototype.hasOwnProperty.call(errors, '__proto__') &&1046    !Object.prototype.hasOwnProperty.call(exports, '__proto__') &&1047    Object.defineProperty(exports, '__proto__', {1048        enumerable: true,1049        value: errors['__proto__']1050    });1051 1052Object.keys(errors).forEach(function (k) {1053    if (k !== 'default' && !Object.prototype.hasOwnProperty.call(exports, k)) exports[k] = errors[k];1054});1055