Skip to content

Commit

Permalink
feat(clients): update clients as of 2022/02/18 (#3335)
Browse files Browse the repository at this point in the history
  • Loading branch information
trivikr committed Feb 18, 2022
1 parent a6d95f3 commit 717b06f
Show file tree
Hide file tree
Showing 308 changed files with 12,314 additions and 4,314 deletions.
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

0 comments on commit 717b06f

Please sign in to comment.