This commit is contained in:
Kenneth Kehl
2024-11-19 09:26:33 -08:00
parent 0d44f29904
commit 32e73f659c

View File

@@ -298,19 +298,17 @@ def get_notifications_for_service(
if client_reference is not None: if client_reference is not None:
filters.append(Notification.client_reference == client_reference) filters.append(Notification.client_reference == client_reference)
query = select(Notification).where(*filters) query = Notification.query.filter(*filters)
query = _filter_query(query, filter_dict) query = _filter_query(query, filter_dict)
if personalisation: if personalisation:
query = query.options(joinedload(Notification.template)) query = query.options(joinedload(Notification.template))
query = query.order_by(desc(Notification.created_at)) return query.order_by(desc(Notification.created_at)).paginate(
results = db.session.execute(query).scalars().all() page=page,
per_page=page_size,
page_size = current_app.config["PAGE_SIZE"] count=count_pages,
offset = (page - 1) * page_size error_out=error_out,
paginated_results = results[offset : offset + page_size] )
pagination = Pagination(paginated_results, page, page_size, len(results))
return pagination
def _filter_query(query, filter_dict=None): def _filter_query(query, filter_dict=None):