mirror of
https://github.com/GSA/notifications-admin.git
synced 2026-09-09 07:23:12 -04:00
Add letter jobs page, client and test
This commit is contained in:
@@ -52,6 +52,7 @@ from app.notify_client.events_api_client import EventsApiClient
|
|||||||
from app.notify_client.provider_client import ProviderClient
|
from app.notify_client.provider_client import ProviderClient
|
||||||
from app.notify_client.organisations_client import OrganisationsClient
|
from app.notify_client.organisations_client import OrganisationsClient
|
||||||
from app.notify_client.models import AnonymousUser
|
from app.notify_client.models import AnonymousUser
|
||||||
|
from app.notify_client.letter_jobs_client import LetterJobsClient
|
||||||
|
|
||||||
login_manager = LoginManager()
|
login_manager = LoginManager()
|
||||||
csrf = CsrfProtect()
|
csrf = CsrfProtect()
|
||||||
@@ -69,6 +70,7 @@ provider_client = ProviderClient()
|
|||||||
organisations_client = OrganisationsClient()
|
organisations_client = OrganisationsClient()
|
||||||
asset_fingerprinter = AssetFingerprinter()
|
asset_fingerprinter = AssetFingerprinter()
|
||||||
statsd_client = StatsdClient()
|
statsd_client = StatsdClient()
|
||||||
|
letter_jobs_client = LetterJobsClient()
|
||||||
|
|
||||||
# The current service attached to the request stack.
|
# The current service attached to the request stack.
|
||||||
current_service = LocalProxy(partial(_lookup_req_object, 'service'))
|
current_service = LocalProxy(partial(_lookup_req_object, 'service'))
|
||||||
@@ -100,6 +102,7 @@ def create_app():
|
|||||||
events_api_client.init_app(application)
|
events_api_client.init_app(application)
|
||||||
provider_client.init_app(application)
|
provider_client.init_app(application)
|
||||||
organisations_client.init_app(application)
|
organisations_client.init_app(application)
|
||||||
|
letter_jobs_client.init_app(application)
|
||||||
|
|
||||||
login_manager.init_app(application)
|
login_manager.init_app(application)
|
||||||
login_manager.login_view = 'main.sign_in'
|
login_manager.login_view = 'main.sign_in'
|
||||||
|
|||||||
@@ -1,45 +1,31 @@
|
|||||||
from flask import (render_template, url_for, redirect, request, abort)
|
import datetime
|
||||||
|
|
||||||
|
from flask import render_template, request
|
||||||
|
from flask_login import login_required
|
||||||
|
|
||||||
|
from app import letter_jobs_client, format_datetime_24h
|
||||||
from app.main import main
|
from app.main import main
|
||||||
from app import convert_to_boolean
|
from app.utils import user_has_permissions
|
||||||
from flask_login import (login_required, current_user)
|
|
||||||
|
|
||||||
|
|
||||||
@main.route("/letter-jobs", methods=['GET', 'POST'])
|
@main.route("/letter-jobs", methods=['GET', 'POST'])
|
||||||
@login_required
|
@login_required
|
||||||
|
@user_has_permissions(admin_override=True)
|
||||||
def letter_jobs():
|
def letter_jobs():
|
||||||
letter_jobs_list = get_letter_jobs()
|
|
||||||
|
|
||||||
msg = ''
|
msg = ''
|
||||||
if request.method == 'POST':
|
letter_jobs_list = letter_jobs_client.get_letter_jobs()
|
||||||
send_letters = request.form.getlist('send_letter')
|
|
||||||
for job_id in send_letters:
|
|
||||||
job = [j for j in letter_jobs_list if job_id == j['job_id']][0]
|
|
||||||
job['send'] = True
|
|
||||||
|
|
||||||
msg = 'sending:{}'.format(send_letters)
|
if request.method == 'POST':
|
||||||
|
if len(request.form.getlist('job_id')) > 0:
|
||||||
|
job_ids = request.form.getlist('job_id')
|
||||||
|
|
||||||
|
response = letter_jobs_client.send_letter_jobs(job_ids)
|
||||||
|
msg = response['response']
|
||||||
|
|
||||||
|
for job_id in job_ids:
|
||||||
|
job = [j for j in letter_jobs_list if job_id == j['id']][0]
|
||||||
|
job['sending'] = 'sending'
|
||||||
|
else:
|
||||||
|
msg = 'No jobs selected'
|
||||||
|
|
||||||
return render_template('views/letter-jobs.html', letter_jobs_list=letter_jobs_list, message=msg)
|
return render_template('views/letter-jobs.html', letter_jobs_list=letter_jobs_list, message=msg)
|
||||||
|
|
||||||
|
|
||||||
def get_letter_jobs():
|
|
||||||
return [
|
|
||||||
{
|
|
||||||
'service_name': 'test_name',
|
|
||||||
'job_id': 'test_id',
|
|
||||||
'status': 'test_status',
|
|
||||||
'created_at': '2017-04-01'
|
|
||||||
},
|
|
||||||
{
|
|
||||||
'service_name': 'test_name 2',
|
|
||||||
'job_id': 'test_id 2',
|
|
||||||
'status': 'test_status 2',
|
|
||||||
'created_at': '2017-04-02'
|
|
||||||
|
|
||||||
},
|
|
||||||
{
|
|
||||||
'service_name': 'test_name 3',
|
|
||||||
'job_id': 'test_id 3',
|
|
||||||
'status': 'test_status 3',
|
|
||||||
'created_at': '2017-04-03'
|
|
||||||
}
|
|
||||||
]
|
|
||||||
|
|||||||
21
app/notify_client/letter_jobs_client.py
Normal file
21
app/notify_client/letter_jobs_client.py
Normal file
@@ -0,0 +1,21 @@
|
|||||||
|
from app.notify_client import NotifyAdminAPIClient
|
||||||
|
|
||||||
|
|
||||||
|
class LetterJobsClient(NotifyAdminAPIClient):
|
||||||
|
|
||||||
|
def __init__(self):
|
||||||
|
super().__init__("a", "b", "c")
|
||||||
|
|
||||||
|
def init_app(self, app):
|
||||||
|
self.base_url = app.config['API_HOST_NAME']
|
||||||
|
self.service_id = app.config['ADMIN_CLIENT_USER_NAME']
|
||||||
|
self.api_key = app.config['ADMIN_CLIENT_SECRET']
|
||||||
|
|
||||||
|
def get_letter_jobs(self):
|
||||||
|
return self.get(url='/letter-jobs')['data']
|
||||||
|
|
||||||
|
def send_letter_jobs(self, job_ids):
|
||||||
|
return self.post(
|
||||||
|
url='/send-letter-jobs',
|
||||||
|
data={"job_ids": job_ids}
|
||||||
|
)['data']
|
||||||
@@ -17,25 +17,31 @@
|
|||||||
<th>Service name</th>
|
<th>Service name</th>
|
||||||
<th>Job ID</th>
|
<th>Job ID</th>
|
||||||
<th>Status</th>
|
<th>Status</th>
|
||||||
<th colspan="2">Created at</th>
|
<th colspan="3">Created at</th>
|
||||||
</tr>
|
</tr>
|
||||||
</thead>
|
</thead>
|
||||||
|
<tbody>
|
||||||
{% for job in letter_jobs_list %}
|
{% for job in letter_jobs_list %}
|
||||||
<tr>
|
<tr>
|
||||||
<td>{{ job.service_name }}</td>
|
<td>{{ job.service_name.name }}</td>
|
||||||
<td>{{ job.job_id }}</td>
|
<td>{{ job.id }}</td>
|
||||||
<td>{{ job.status }}</td>
|
<td>{{ job.job_status }}</td>
|
||||||
<td>{{ job.created_at }}</td>
|
<td>{{ job.created_at|format_datetime_short }}</td>
|
||||||
<td><input name="send_letter" value='{{ job.job_id }}' type="checkbox"{% if job.send %} checked{% endif %}></td>
|
<td><input name="job_id" value='{{ job.id }}' type="checkbox"{% if job.send %} checked{% endif %}></td>
|
||||||
|
<td>{{ job.sending }}</td>
|
||||||
</tr>
|
</tr>
|
||||||
{% endfor %}
|
{% endfor %}
|
||||||
|
</tbody>
|
||||||
</table>
|
</table>
|
||||||
</p>
|
</p>
|
||||||
{{ page_footer('Send') }}
|
{{ page_footer('Send') }}
|
||||||
|
|
||||||
{% if message %}
|
{% if message %}
|
||||||
<p>
|
<p id='message'>
|
||||||
{{ message }}
|
{{ message }}
|
||||||
|
{% if message != 'No jobs selected' %}
|
||||||
|
<div>Refresh page to see status updates</div>
|
||||||
|
{% endif %}
|
||||||
</p>
|
</p>
|
||||||
{% endif %}
|
{% endif %}
|
||||||
</form>
|
</form>
|
||||||
|
|||||||
103
tests/app/main/views/test_letter_jobs.py
Normal file
103
tests/app/main/views/test_letter_jobs.py
Normal file
@@ -0,0 +1,103 @@
|
|||||||
|
from flask import url_for
|
||||||
|
from bs4 import BeautifulSoup
|
||||||
|
|
||||||
|
from app import format_datetime_short
|
||||||
|
|
||||||
|
valid_letter_jobs = [
|
||||||
|
{
|
||||||
|
'service_name': {'name': 'test_name'},
|
||||||
|
'template_version': 1,
|
||||||
|
'id': 'test_id',
|
||||||
|
'job_status': 'test_status',
|
||||||
|
'created_at': '2017-04-01T12:00:00'
|
||||||
|
},
|
||||||
|
{
|
||||||
|
'service_name': {'name': 'test_name 2'},
|
||||||
|
'template_version': 2,
|
||||||
|
'id': 'test_id 2',
|
||||||
|
'job_status': 'test_status 2',
|
||||||
|
'created_at': '2017-04-02T13:00:00'
|
||||||
|
},
|
||||||
|
{
|
||||||
|
'service_name': {'name': 'test_name 3'},
|
||||||
|
'template_version': 3,
|
||||||
|
'id': 'test_id 3',
|
||||||
|
'job_status': 'test_status 3',
|
||||||
|
'created_at': '2017-04-03T14:00:00'
|
||||||
|
}
|
||||||
|
]
|
||||||
|
|
||||||
|
send_letter_jobs_response = {"response": "Task created to send files to DVLA"}
|
||||||
|
|
||||||
|
|
||||||
|
def test_get_letter_jobs_returns_list_of_all_letter_jobs(logged_in_platform_admin_client, mocker):
|
||||||
|
mock_get_letters = mocker.patch('app.letter_jobs_client.get_letter_jobs', return_value=valid_letter_jobs)
|
||||||
|
|
||||||
|
response = logged_in_platform_admin_client.get(url_for('main.letter_jobs'))
|
||||||
|
|
||||||
|
assert mock_get_letters.called
|
||||||
|
assert response.status_code == 200
|
||||||
|
|
||||||
|
page = BeautifulSoup(response.data.decode('utf-8'), 'html.parser')
|
||||||
|
assert page.h1.string == 'Letter jobs'
|
||||||
|
|
||||||
|
table = page.find('table')
|
||||||
|
table_body = table.find('tbody')
|
||||||
|
rows = table_body.find_all('tr')
|
||||||
|
|
||||||
|
assert len(rows) == len(valid_letter_jobs)
|
||||||
|
|
||||||
|
for row_pos in range(len(rows)):
|
||||||
|
cols = rows[row_pos].find_all('td')
|
||||||
|
assert valid_letter_jobs[row_pos]['service_name']['name'] == cols[0].text
|
||||||
|
assert valid_letter_jobs[row_pos]['id'] == cols[1].text
|
||||||
|
assert valid_letter_jobs[row_pos]['job_status'] == cols[2].text
|
||||||
|
assert format_datetime_short(valid_letter_jobs[row_pos]['created_at']) == cols[3].text
|
||||||
|
|
||||||
|
|
||||||
|
def test_post_letter_jobs_select_1_letter_job_submits_1_job(logged_in_platform_admin_client, mocker):
|
||||||
|
letter_jobs_first_selected = {'job_id': ['test_id']}
|
||||||
|
|
||||||
|
mock_get_letters = mocker.patch('app.letter_jobs_client.get_letter_jobs', return_value=valid_letter_jobs)
|
||||||
|
mock_send_letters = mocker.patch('app.letter_jobs_client.send_letter_jobs', return_value=send_letter_jobs_response)
|
||||||
|
|
||||||
|
response = logged_in_platform_admin_client.post(url_for('main.letter_jobs'), data=letter_jobs_first_selected)
|
||||||
|
|
||||||
|
assert mock_get_letters.called
|
||||||
|
assert mock_send_letters.called
|
||||||
|
assert response.status_code == 200
|
||||||
|
|
||||||
|
page = BeautifulSoup(response.data.decode('utf-8'), 'html.parser')
|
||||||
|
|
||||||
|
table = page.find('table')
|
||||||
|
table_body = table.find('tbody')
|
||||||
|
rows = table_body.find_all('tr')
|
||||||
|
|
||||||
|
assert len(rows) == len(valid_letter_jobs)
|
||||||
|
|
||||||
|
colr0 = rows[0].find_all('td')
|
||||||
|
colr1 = rows[1].find_all('td')
|
||||||
|
colr2 = rows[2].find_all('td')
|
||||||
|
|
||||||
|
assert colr0[5].text == "sending"
|
||||||
|
assert colr1[5].text == ""
|
||||||
|
assert colr2[5].text == ""
|
||||||
|
|
||||||
|
message = page.find('p', attrs={'id': 'message'}).text
|
||||||
|
assert "Task created to send files to DVLA" in message
|
||||||
|
|
||||||
|
|
||||||
|
def test_post_letter_jobs_none_selected_shows_message(logged_in_platform_admin_client, mocker):
|
||||||
|
mock_get_letters = mocker.patch('app.letter_jobs_client.get_letter_jobs', return_value=valid_letter_jobs)
|
||||||
|
mock_send_letters = mocker.patch('app.letter_jobs_client.send_letter_jobs', return_value=send_letter_jobs_response)
|
||||||
|
|
||||||
|
response = logged_in_platform_admin_client.post(url_for('main.letter_jobs'), data={})
|
||||||
|
|
||||||
|
assert mock_get_letters.called
|
||||||
|
assert not mock_send_letters.called
|
||||||
|
assert response.status_code == 200
|
||||||
|
|
||||||
|
page = BeautifulSoup(response.data.decode('utf-8'), 'html.parser')
|
||||||
|
message = page.find('p', attrs={'id': 'message'}).text
|
||||||
|
|
||||||
|
assert "No jobs selected" in message
|
||||||
Reference in New Issue
Block a user