in aws-lightsail-disk/src/main/java/software/amazon/lightsail/disk/helpers/handler/DiskHandler.java [48:70]
protected ProgressEvent<ResourceModel, CallbackContext> preCreate(
final ProgressEvent<ResourceModel, CallbackContext> progress) {
// Create/Delete for the disks won't happen here, it will happen in its own resource.
val disk = new Disk(resourceModel, logger, proxyClient, resourceModelRequest);
if (callbackContext.getIsPreCheckDone(PRE_CHECK_CREATE)) {
return progress;
}
logger.log("Executing AWS-Lightsail-Disk::Create::PreExistence...");
return proxy
.initiate("AWS-Lightsail-Disk::Create::PreExistence", proxyClient, progress.getResourceModel(),
progress.getCallbackContext())
.translateToServiceRequest(Translator::translateToReadRequest).makeServiceCall((awsRequest, client) -> {
disk.read(awsRequest);
logger.log(String.format("%s has successfully been read.", ResourceModel.TYPE_NAME));
throw new CfnAlreadyExistsException(ResourceType.DISK.toString(),
((GetDiskRequest) awsRequest).diskName());
}).handleError((awsRequest, exception, client, model, context) -> {
callbackContext.getIsPreCheckDone().put(PRE_CHECK_CREATE, true);
return handleError(exception, model, callbackContext,
ImmutableList.of(InvalidInputException, NotFoundException), logger,
this.getClass().getSimpleName());
}).progress();
}