darkhelm/notifications-api
1
0
Fork 0
mirror of https://github.com/GSA/notifications-api.git synced 2026-08-18 21:48:49 -04:00
Code Issues Packages Projects Releases Wiki Activity

try deactivating some letter routes

Browse Source
This commit is contained in:
stvnrlly
2022-12-08 09:55:21 -05:00
parent 14a1d499fa
commit 33bd3b3a31
7 changed files with 22 additions and 295 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
app/letters/rest.py
View File

@@ -1,6 +1,5 @@
from flask import Blueprint, jsonify, request
from app.celery.tasks import process_returned_letters_list
from app.config import QueueNames
from app.letters.letter_schemas import letter_references
from app.schema_validation import validate
@@ -14,15 +13,16 @@ register_errors(letter_job)
MAX_REFERENCES_PER_TASK = 5000
@letter_job.route('/letters/returned', methods=['POST'])
def create_process_returned_letters_job():
references = validate(request.get_json(), letter_references)['references']
# TODO: return deactivation notice
# @letter_job.route('/letters/returned', methods=['POST'])
# def create_process_returned_letters_job():
# references = validate(request.get_json(), letter_references)['references']
for start_index in range(0, len(references), MAX_REFERENCES_PER_TASK):
process_returned_letters_list.apply_async(
args=(references[start_index:start_index + MAX_REFERENCES_PER_TASK], ),
queue=QueueNames.DATABASE,
compression='zlib'
)
# for start_index in range(0, len(references), MAX_REFERENCES_PER_TASK):
# process_returned_letters_list.apply_async(
# args=(references[start_index:start_index + MAX_REFERENCES_PER_TASK], ),
# queue=QueueNames.DATABASE,
# compression='zlib'
# )
return jsonify(references=references), 200
# return jsonify(references=references), 200

16
app/service/rest.py
View File

@@ -122,10 +122,7 @@ from app.schemas import (
service_schema,
)
from app.service import statistics
from app.service.send_notification import (
send_one_off_notification,
send_pdf_letter_notification,
)
from app.service.send_notification import send_one_off_notification
from app.service.send_pdf_letter_schema import send_pdf_letter_request
from app.service.sender import send_notification_to_service_users
from app.service.service_contact_list_schema import (
@@ -749,11 +746,12 @@ def create_one_off_notification(service_id):
return jsonify(resp), 201
@service_blueprint.route('/<uuid:service_id>/send-pdf-letter', methods=['POST'])
def create_pdf_letter(service_id):
data = validate(request.get_json(), send_pdf_letter_request)
resp = send_pdf_letter_notification(service_id, data)
return jsonify(resp), 201
# TODO: return deactivation notice
# @service_blueprint.route('/<uuid:service_id>/send-pdf-letter', methods=['POST'])
# def create_pdf_letter(service_id):
# data = validate(request.get_json(), send_pdf_letter_request)
# resp = send_pdf_letter_notification(service_id, data)
# return jsonify(resp), 201
@service_blueprint.route('/<uuid:service_id>/email-reply-to', methods=["GET"])