in amazon-sns-trigger-server/src/main/java/jetbrains/buildServer/clouds/amazon/sns/trigger/controllers/AwsSnsHttpEndpointController.java [121:138]
private void doPost(
@NotNull final HttpServletRequest request,
@NotNull final SBuildType buildType,
@NotNull final BuildTriggerDescriptor buildTrigger
) throws AwsSnsHttpEndpointException {
CustomDataStorageWrapper cds = new CustomDataStorageWrapper(getCustomDataStorage(buildType, buildTrigger));
HashMap<String, Object> payload = readJson(request);
if (payload != null && AwsSnsMessageDetailsHelper.isValidSignature(payload, myServerApi)) {
if (AwsSnsMessageDetailsHelper.isSubscription(payload)) {
handleSubscription(request.getHeader(AwsSnsTriggerConstants.AWS_TOPIC_ARN_HEADER), cds, payload);
} else if (AwsSnsMessageDetailsHelper.isUnsubscribe(payload)) {
handleUnsubscribe(cds);
} else if (AwsSnsMessageDetailsHelper.isNotification(payload)) {
handleNotification(buildTrigger, cds, AwsSnsMessageDetailsHelper.convertToNotificationDto(request, payload));
}
}
}