Total Complexity | 2 |
Total Lines | 41 |
Duplicated Lines | 0 % |
Changes | 0 |
1 | #!/usr/bin/env python3 |
||
2 | # -*- coding: utf-8 -*- |
||
3 | """ |
||
4 | Created on Thu Jun 27 11:52:37 2019 |
||
5 | |||
6 | @author: Paolo Cozzi <[email protected]> |
||
7 | """ |
||
8 | |||
9 | import asyncio |
||
10 | |||
11 | from common.constants import STATUSES |
||
12 | from common.helpers import send_message_to_websocket |
||
13 | |||
14 | |||
15 | def send_message(submission_obj, validation_message=None): |
||
16 | """ |
||
17 | Update submission.status and submission message using django |
||
18 | channels |
||
19 | |||
20 | Args: |
||
21 | submission_obj (image_app.models.Submission): an UID submission |
||
22 | object |
||
23 | validation_message (dict): set validation message |
||
24 | """ |
||
25 | |||
26 | # define a message to send |
||
27 | message = { |
||
28 | 'message': STATUSES.get_value_display(submission_obj.status), |
||
29 | 'notification_message': submission_obj.message, |
||
30 | } |
||
31 | |||
32 | # if validation message is needed, add to the final message |
||
33 | if validation_message: |
||
34 | message['validation_message'] = validation_message |
||
35 | |||
36 | # now send the message to its submission |
||
37 | asyncio.get_event_loop().run_until_complete( |
||
38 | send_message_to_websocket( |
||
39 | message, |
||
40 | submission_obj.pk |
||
41 | ) |
||
43 |