in aws-transfer-workflow/src/main/java/software/amazon/transfer/workflow/Converter.java [58:109]
static WorkflowStep toSdk(
software.amazon.transfer.workflow.WorkflowStep workflowStep) {
if (workflowStep == null) {
return null;
}
WorkflowStep.Builder sdkWorkflowStep = WorkflowStep.builder();
String type = workflowStep.getType();
sdkWorkflowStep.type(type);
if (WorkflowStepType.COPY.toString().equals(type) && workflowStep.getCopyStepDetails() != null) {
sdkWorkflowStep.copyStepDetails(CopyStepDetails.builder()
.name(workflowStep.getCopyStepDetails().getName())
.destinationFileLocation(
(workflowStep.getCopyStepDetails().getDestinationFileLocation() == null) ?
null : InputFileLocation.builder()
.s3FileLocation((workflowStep.getCopyStepDetails()
.getDestinationFileLocation().getS3FileLocation() == null) ?
null : S3InputFileLocation.builder()
.bucket(workflowStep.getCopyStepDetails().getDestinationFileLocation()
.getS3FileLocation().getBucket())
.key(workflowStep.getCopyStepDetails().getDestinationFileLocation()
.getS3FileLocation().getKey())
.build())
.build())
.overwriteExisting(workflowStep.getCopyStepDetails().getOverwriteExisting())
.build());
}
if (WorkflowStepType.CUSTOM.toString().equals(type) && workflowStep.getCustomStepDetails() !=null) {
sdkWorkflowStep.customStepDetails(CustomStepDetails.builder()
.name(workflowStep.getCustomStepDetails().getName())
.target(workflowStep.getCustomStepDetails().getTarget())
.timeoutSeconds(workflowStep.getCustomStepDetails().getTimeoutSeconds())
.build());
}
if (WorkflowStepType.DELETE.toString().equals(type) && workflowStep.getDeleteStepDetails() != null) {
sdkWorkflowStep.deleteStepDetails(DeleteStepDetails.builder()
.name(workflowStep.getDeleteStepDetails().getName())
.build());
}
if (WorkflowStepType.TAG.toString().equals(type) && workflowStep.getTagStepDetails() != null) {
sdkWorkflowStep.tagStepDetails(TagStepDetails.builder()
.name(workflowStep.getTagStepDetails().getName())
.tags((workflowStep.getTagStepDetails().getTags() == null) ?
null : workflowStep.getTagStepDetails().getTags()
.stream()
.map(S3TagConverter::toSdk)
.collect(Collectors.toList()))
.build());
}
return sdkWorkflowStep.build();
}