Skip to content

feat(clients): update clients as of 2022/02/18 #3335

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 3 commits into from
Feb 18, 2022
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
82 changes: 82 additions & 0 deletions clients/client-appflow/src/models/models_0.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3778,6 +3778,82 @@ export namespace SalesforceDestinationProperties {
});
}

/**
* <p>Determines how Amazon AppFlow handles the success response that it gets
* from the connector after placing data.</p>
* <p>For example, this setting would determine
* where to write the response from the destination connector upon a successful insert
* operation.</p>
*/
export interface SuccessResponseHandlingConfig {
/**
* <p>The Amazon S3 bucket prefix.</p>
*/
bucketPrefix?: string;

/**
* <p>The name of the Amazon S3 bucket.</p>
*/
bucketName?: string;
}

export namespace SuccessResponseHandlingConfig {
/**
* @internal
*/
export const filterSensitiveLog = (obj: SuccessResponseHandlingConfig): any => ({
...obj,
});
}

/**
* <p>The properties that are applied when using SAPOData as a flow destination</p>
*/
export interface SAPODataDestinationProperties {
/**
* <p>The object path specified in the SAPOData flow destination.</p>
*/
objectPath: string | undefined;

/**
* <p>Determines how Amazon AppFlow handles the success response that it gets
* from the connector after placing data.</p>
* <p>For example, this setting would determine where to write the response from a destination
* connector upon a successful insert operation.</p>
*/
successResponseHandlingConfig?: SuccessResponseHandlingConfig;

/**
* <p> A list of field names that can be used as an ID field when performing a write operation.
* </p>
*/
idFieldNames?: string[];

/**
* <p> The settings that determine how Amazon AppFlow handles an error when placing data in the
* destination. For example, this setting would determine if the flow should fail after one
* insertion error, or continue and attempt to insert every record regardless of the initial
* failure. <code>ErrorHandlingConfig</code> is a part of the destination connector details.
* </p>
*/
errorHandlingConfig?: ErrorHandlingConfig;

/**
* <p> The possible write operations in the destination connector. When this value is not
* provided, this defaults to the <code>INSERT</code> operation. </p>
*/
writeOperationType?: WriteOperationType | string;
}

export namespace SAPODataDestinationProperties {
/**
* @internal
*/
export const filterSensitiveLog = (obj: SAPODataDestinationProperties): any => ({
...obj,
});
}

/**
* <p> The properties that are applied when Snowflake is being used as a destination. </p>
*/
Expand Down Expand Up @@ -3980,6 +4056,11 @@ export interface DestinationConnectorProperties {
* <p>The properties that are required to query the custom Connector.</p>
*/
CustomConnector?: CustomConnectorDestinationProperties;

/**
* <p>The properties required to query SAPOData.</p>
*/
SAPOData?: SAPODataDestinationProperties;
}

export namespace DestinationConnectorProperties {
Expand Down Expand Up @@ -4568,6 +4649,7 @@ export enum TaskType {
MAP_ALL = "Map_all",
MASK = "Mask",
MERGE = "Merge",
PASSTHROUGH = "Passthrough",
TRUNCATE = "Truncate",
VALIDATE = "Validate",
}
Expand Down
78 changes: 78 additions & 0 deletions clients/client-appflow/src/protocols/Aws_restJson1.ts
Original file line number Diff line number Diff line change
Expand Up @@ -173,6 +173,7 @@ import {
SalesforceSourceProperties,
SAPODataConnectorProfileCredentials,
SAPODataConnectorProfileProperties,
SAPODataDestinationProperties,
SAPODataMetadata,
SAPODataSourceProperties,
ScheduledTriggerProperties,
Expand All @@ -197,6 +198,7 @@ import {
SourceConnectorProperties,
SourceFieldProperties,
SourceFlowConfig,
SuccessResponseHandlingConfig,
SupportedFieldTypeDetails,
Task,
ThrottlingException,
Expand Down Expand Up @@ -3323,6 +3325,10 @@ const serializeAws_restJson1DestinationConnectorProperties = (
}),
...(input.S3 !== undefined &&
input.S3 !== null && { S3: serializeAws_restJson1S3DestinationProperties(input.S3, context) }),
...(input.SAPOData !== undefined &&
input.SAPOData !== null && {
SAPOData: serializeAws_restJson1SAPODataDestinationProperties(input.SAPOData, context),
}),
...(input.Salesforce !== undefined &&
input.Salesforce !== null && {
Salesforce: serializeAws_restJson1SalesforceDestinationProperties(input.Salesforce, context),
Expand Down Expand Up @@ -3836,6 +3842,32 @@ const serializeAws_restJson1SAPODataConnectorProfileProperties = (
};
};

const serializeAws_restJson1SAPODataDestinationProperties = (
input: SAPODataDestinationProperties,
context: __SerdeContext
): any => {
return {
...(input.errorHandlingConfig !== undefined &&
input.errorHandlingConfig !== null && {
errorHandlingConfig: serializeAws_restJson1ErrorHandlingConfig(input.errorHandlingConfig, context),
}),
...(input.idFieldNames !== undefined &&
input.idFieldNames !== null && {
idFieldNames: serializeAws_restJson1IdFieldNameList(input.idFieldNames, context),
}),
...(input.objectPath !== undefined && input.objectPath !== null && { objectPath: input.objectPath }),
...(input.successResponseHandlingConfig !== undefined &&
input.successResponseHandlingConfig !== null && {
successResponseHandlingConfig: serializeAws_restJson1SuccessResponseHandlingConfig(
input.successResponseHandlingConfig,
context
),
}),
...(input.writeOperationType !== undefined &&
input.writeOperationType !== null && { writeOperationType: input.writeOperationType }),
};
};

const serializeAws_restJson1SAPODataSourceProperties = (
input: SAPODataSourceProperties,
context: __SerdeContext
Expand Down Expand Up @@ -4079,6 +4111,16 @@ const serializeAws_restJson1SourceFlowConfig = (input: SourceFlowConfig, context
};
};

const serializeAws_restJson1SuccessResponseHandlingConfig = (
input: SuccessResponseHandlingConfig,
context: __SerdeContext
): any => {
return {
...(input.bucketName !== undefined && input.bucketName !== null && { bucketName: input.bucketName }),
...(input.bucketPrefix !== undefined && input.bucketPrefix !== null && { bucketPrefix: input.bucketPrefix }),
};
};

const serializeAws_restJson1TagMap = (input: { [key: string]: string }, context: __SerdeContext): any => {
return Object.entries(input).reduce((acc: { [key: string]: any }, [key, value]: [string, any]) => {
if (value === null) {
Expand Down Expand Up @@ -5046,6 +5088,10 @@ const deserializeAws_restJson1DestinationConnectorProperties = (
output.S3 !== undefined && output.S3 !== null
? deserializeAws_restJson1S3DestinationProperties(output.S3, context)
: undefined,
SAPOData:
output.SAPOData !== undefined && output.SAPOData !== null
? deserializeAws_restJson1SAPODataDestinationProperties(output.SAPOData, context)
: undefined,
Salesforce:
output.Salesforce !== undefined && output.Salesforce !== null
? deserializeAws_restJson1SalesforceDestinationProperties(output.Salesforce, context)
Expand Down Expand Up @@ -5696,6 +5742,28 @@ const deserializeAws_restJson1SAPODataConnectorProfileProperties = (
} as any;
};

const deserializeAws_restJson1SAPODataDestinationProperties = (
output: any,
context: __SerdeContext
): SAPODataDestinationProperties => {
return {
errorHandlingConfig:
output.errorHandlingConfig !== undefined && output.errorHandlingConfig !== null
? deserializeAws_restJson1ErrorHandlingConfig(output.errorHandlingConfig, context)
: undefined,
idFieldNames:
output.idFieldNames !== undefined && output.idFieldNames !== null
? deserializeAws_restJson1IdFieldNameList(output.idFieldNames, context)
: undefined,
objectPath: __expectString(output.objectPath),
successResponseHandlingConfig:
output.successResponseHandlingConfig !== undefined && output.successResponseHandlingConfig !== null
? deserializeAws_restJson1SuccessResponseHandlingConfig(output.successResponseHandlingConfig, context)
: undefined,
writeOperationType: __expectString(output.writeOperationType),
} as any;
};

const deserializeAws_restJson1SAPODataMetadata = (output: any, context: __SerdeContext): SAPODataMetadata => {
return {} as any;
};
Expand Down Expand Up @@ -5959,6 +6027,16 @@ const deserializeAws_restJson1SourceFlowConfig = (output: any, context: __SerdeC
} as any;
};

const deserializeAws_restJson1SuccessResponseHandlingConfig = (
output: any,
context: __SerdeContext
): SuccessResponseHandlingConfig => {
return {
bucketName: __expectString(output.bucketName),
bucketPrefix: __expectString(output.bucketPrefix),
} as any;
};

const deserializeAws_restJson1SupportedApiVersionList = (output: any, context: __SerdeContext): string[] => {
return (output || [])
.filter((e: any) => e != null)
Expand Down
Loading