in java-app-backend/BackendFunction/src/main/java/com/webapp/function/CreateCollectionHandler.java [30:59]
public APIGatewayProxyResponseEvent handleRequest(final Map<String, Object> input, final Context context) {
String collectionId = (String) ((Map) input.get("ResourceProperties")).get("CollectionName");
if ("Delete".equals(input.get("RequestType"))) {
callGracefully(input, context, () -> {
DeleteCollectionResponse deleteCollectionResponse = client.deleteCollection(DeleteCollectionRequest.builder()
.collectionId(collectionId)
.build());
if (deleteCollectionResponse.statusCode() == 200) {
LOG.info("Resource deleted");
sendResponse(input, context, "SUCCESS");
}
});
} else {
callGracefully(input, context, () -> {
CreateCollectionResponse response = client.createCollection(CreateCollectionRequest.builder()
.collectionId(collectionId)
.build());
if (response.statusCode() == 200) {
LOG.info("Resource created");
sendResponse(input, context, "SUCCESS");
}
});
}
return null;
}