darkhelm/notifications-api
1
0
Fork 0
mirror of https://github.com/GSA/notifications-api.git synced 2026-02-01 07:35:34 -05:00
Code Issues Packages Projects Releases Wiki Activity

Update SES callback to use autconfirm method

Browse Source
This commit is contained in:
Imdad Ahad
2017-05-09 14:21:57 +01:00
parent 37165e5b6a
commit 4d82512ec6
1 changed files with 7 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
app/notifications/notifications_ses_callback.py
View File

@@ -13,9 +13,8 @@ from app.clients.email.aws_ses import get_aws_responses
from app.dao import ( from app.dao import (
notifications_dao notifications_dao
) )
from app.notifications.process_client_response import validate_callback_data from app.notifications.process_client_response import validate_callback_data
from app.notifications.utils import confirm_subscription from app.notifications.utils import autoconfirm_subscription
ses_callback_blueprint = Blueprint('notifications_ses_callback', __name__) ses_callback_blueprint = Blueprint('notifications_ses_callback', __name__)
@@ -32,14 +31,12 @@ def process_ses_response():
try: try:
ses_request = json.loads(request.data) ses_request = json.loads(request.data)
if ses_request.get('Type') == 'SubscriptionConfirmation': subscribed_topic = autoconfirm_subscription(ses_request)
current_app.logger.info("SNS subscription confirmation url: {}".format(ses_request['SubscribeURL'])) if subscribed_topic:
subscribed_topic = confirm_subscription(ses_request) current_app.logger.info("Automatically subscribed to topic: {}".format(subscribed_topic))
if subscribed_topic: return jsonify(
current_app.logger.info("Automatically subscribed to topic: {}".format(subscribed_topic)) result="success", message="SES callback succeeded"
return jsonify( ), 200
result="success", message="SES callback succeeded"
), 200
errors = validate_callback_data(data=ses_request, fields=['Message'], client_name=client_name) errors = validate_callback_data(data=ses_request, fields=['Message'], client_name=client_name)
if errors: if errors: