mirror of
https://github.com/GSA/notifications-api.git
synced 2026-01-22 02:21:50 -05:00
55 lines
1.5 KiB
Python
55 lines
1.5 KiB
Python
from flask import (
|
|
Blueprint,
|
|
jsonify,
|
|
request
|
|
)
|
|
|
|
from notifications_utils.recipients import validate_and_format_phone_number
|
|
|
|
from app.dao.inbound_sms_dao import (
|
|
dao_get_inbound_sms_for_service,
|
|
dao_count_inbound_sms_for_service,
|
|
dao_get_inbound_sms_by_id
|
|
)
|
|
from app.errors import register_errors
|
|
|
|
inbound_sms = Blueprint(
|
|
'inbound_sms',
|
|
__name__,
|
|
url_prefix='/service/<uuid:service_id>/inbound-sms'
|
|
)
|
|
|
|
register_errors(inbound_sms)
|
|
|
|
|
|
@inbound_sms.route('')
|
|
def get_inbound_sms_for_service(service_id):
|
|
limit = request.args.get('limit')
|
|
user_number = request.args.get('user_number')
|
|
|
|
if user_number:
|
|
# we use this to normalise to an international phone number
|
|
user_number = validate_and_format_phone_number(user_number, international=True)
|
|
|
|
results = dao_get_inbound_sms_for_service(service_id, limit, user_number)
|
|
|
|
return jsonify(data=[row.serialize() for row in results])
|
|
|
|
|
|
@inbound_sms.route('/summary')
|
|
def get_inbound_sms_summary_for_service(service_id):
|
|
count = dao_count_inbound_sms_for_service(service_id)
|
|
most_recent = dao_get_inbound_sms_for_service(service_id, limit=1)
|
|
|
|
return jsonify(
|
|
count=count,
|
|
most_recent=most_recent[0].created_at.isoformat() if most_recent else None
|
|
)
|
|
|
|
|
|
@inbound_sms.route('/<uuid:inbound_sms_id>', methods=['GET'])
|
|
def get_inbound_by_id(service_id, inbound_sms_id):
|
|
inbound_sms = dao_get_inbound_sms_by_id(service_id, inbound_sms_id)
|
|
|
|
return jsonify(inbound_sms.serialize()), 200
|