mirror of
https://github.com/GSA/notifications-api.git
synced 2025-12-23 00:41:35 -05:00
3787e2954b
Adds an API endpoint `/letters/returned` that accepts a list of notification references and creates a task to update their status. Adds a new task that uses the list of references to update the status of notifications to 'returned-letter'. The update is currently done using a single query and logs the number of changed records (including notification history records). This could potentially be done within the `/letters/returned` endpoint, but creating a job right away allows us to extend this more easily in the future (e.g. logging missing notifications or adding callbacks). The job is using the database tasks queue.
40 lines
1.4 KiB
Python
40 lines
1.4 KiB
Python
from flask import Blueprint, jsonify
|
|
from flask import request
|
|
|
|
from app import notify_celery
|
|
from app.celery.tasks import process_returned_letters_list
|
|
from app.config import QueueNames, TaskNames
|
|
from app.dao.jobs_dao import dao_get_all_letter_jobs
|
|
from app.schemas import job_schema
|
|
from app.v2.errors import register_errors
|
|
from app.letters.letter_schemas import letter_job_ids, letter_references
|
|
from app.schema_validation import validate
|
|
|
|
letter_job = Blueprint("letter-job", __name__)
|
|
register_errors(letter_job)
|
|
|
|
|
|
@letter_job.route('/send-letter-jobs', methods=['POST'])
|
|
def send_letter_jobs():
|
|
job_ids = validate(request.get_json(), letter_job_ids)
|
|
notify_celery.send_task(name=TaskNames.DVLA_JOBS, args=(job_ids['job_ids'],), queue=QueueNames.PROCESS_FTP)
|
|
|
|
return jsonify(data={"response": "Task created to send files to DVLA"}), 201
|
|
|
|
|
|
@letter_job.route('/letter-jobs', methods=['GET'])
|
|
def get_letter_jobs():
|
|
letter_jobs = dao_get_all_letter_jobs()
|
|
data = job_schema.dump(letter_jobs, many=True).data
|
|
|
|
return jsonify(data=data), 200
|
|
|
|
|
|
@letter_job.route('/letters/returned', methods=['POST'])
|
|
def create_process_returned_letters_job():
|
|
references = validate(request.get_json(), letter_references)
|
|
|
|
process_returned_letters_list.apply_async([references['references']], queue=QueueNames.DATABASE)
|
|
|
|
return jsonify(references=references['references']), 200
|