Merge pull request #1579 from GSA/track_costs

track message costs
This commit is contained in:
ccostino
2025-03-04 12:10:25 -05:00
committed by GitHub
9 changed files with 71 additions and 17 deletions
+7
View File
@@ -107,6 +107,12 @@ class AwsCloudwatchClient(Client):
provider_response = self._aws_value_or_default( provider_response = self._aws_value_or_default(
event, "delivery", "providerResponse" event, "delivery", "providerResponse"
) )
message_cost = self._aws_value_or_default(event, "delivery", "priceInUSD")
if message_cost is None or message_cost == "":
message_cost = 0.0
else:
message_cost = float(message_cost)
my_timestamp = self._aws_value_or_default(event, "notification", "timestamp") my_timestamp = self._aws_value_or_default(event, "notification", "timestamp")
return { return {
"notification.messageId": event["notification"]["messageId"], "notification.messageId": event["notification"]["messageId"],
@@ -114,6 +120,7 @@ class AwsCloudwatchClient(Client):
"delivery.phoneCarrier": phone_carrier, "delivery.phoneCarrier": phone_carrier,
"delivery.providerResponse": provider_response, "delivery.providerResponse": provider_response,
"@timestamp": my_timestamp, "@timestamp": my_timestamp,
"delivery.priceInUSD": message_cost,
} }
# Here is an example of how to get the events with log insights # Here is an example of how to get the events with log insights
+11 -3
View File
@@ -507,7 +507,7 @@ def insert_notification_history_delete_notifications(
SELECT id, job_id, job_row_number, service_id, template_id, template_version, api_key_id, SELECT id, job_id, job_row_number, service_id, template_id, template_version, api_key_id,
key_type, notification_type, created_at, sent_at, sent_by, updated_at, reference, billable_units, key_type, notification_type, created_at, sent_at, sent_by, updated_at, reference, billable_units,
client_reference, international, phone_prefix, rate_multiplier, notification_status, client_reference, international, phone_prefix, rate_multiplier, notification_status,
created_by_id, document_download_count created_by_id, document_download_count, message_cost
FROM notifications FROM notifications
WHERE service_id = :service_id WHERE service_id = :service_id
AND notification_type = :notification_type AND notification_type = :notification_type
@@ -842,7 +842,6 @@ def dao_update_delivery_receipts(receipts, delivered):
new_receipts.append(r) new_receipts.append(r)
receipts = new_receipts receipts = new_receipts
id_to_carrier = { id_to_carrier = {
r["notification.messageId"]: r["delivery.phoneCarrier"] for r in receipts r["notification.messageId"]: r["delivery.phoneCarrier"] for r in receipts
} }
@@ -851,9 +850,13 @@ def dao_update_delivery_receipts(receipts, delivered):
} }
id_to_timestamp = {r["notification.messageId"]: r["@timestamp"] for r in receipts} id_to_timestamp = {r["notification.messageId"]: r["@timestamp"] for r in receipts}
id_to_message_cost = {
r["notification.messageId"]: r["delivery.priceInUSD"] for r in receipts
}
status_to_update_with = NotificationStatus.DELIVERED status_to_update_with = NotificationStatus.DELIVERED
if not delivered: if not delivered:
status_to_update_with = NotificationStatus.FAILED status_to_update_with = NotificationStatus.FAILED
stmt = ( stmt = (
update(Notification) update(Notification)
.where(Notification.message_id.in_(id_to_carrier.keys())) .where(Notification.message_id.in_(id_to_carrier.keys()))
@@ -877,6 +880,12 @@ def dao_update_delivery_receipts(receipts, delivered):
for key, value in id_to_provider_response.items() for key, value in id_to_provider_response.items()
] ]
), ),
message_cost=case(
*[
(Notification.message_id == key, value)
for key, value in id_to_message_cost.items()
]
),
) )
) )
db.session.execute(stmt) db.session.execute(stmt)
@@ -908,7 +917,6 @@ def dao_close_out_delivery_receipts():
def dao_batch_insert_notifications(batch): def dao_batch_insert_notifications(batch):
db.session.bulk_save_objects(batch) db.session.bulk_save_objects(batch)
db.session.commit() db.session.commit()
current_app.logger.info(f"Batch inserted notifications: {len(batch)}") current_app.logger.info(f"Batch inserted notifications: {len(batch)}")
+2
View File
@@ -1508,6 +1508,7 @@ class Notification(db.Model):
created_at = db.Column(db.DateTime, index=True, unique=False, nullable=False) created_at = db.Column(db.DateTime, index=True, unique=False, nullable=False)
sent_at = db.Column(db.DateTime, index=False, unique=False, nullable=True) sent_at = db.Column(db.DateTime, index=False, unique=False, nullable=True)
sent_by = db.Column(db.String, nullable=True) sent_by = db.Column(db.String, nullable=True)
message_cost = db.Column(db.Float, nullable=True, default=0.0)
updated_at = db.Column( updated_at = db.Column(
db.DateTime, db.DateTime,
index=False, index=False,
@@ -1813,6 +1814,7 @@ class NotificationHistory(db.Model, HistoryModel):
created_at = db.Column(db.DateTime, unique=False, nullable=False) created_at = db.Column(db.DateTime, unique=False, nullable=False)
sent_at = db.Column(db.DateTime, index=False, unique=False, nullable=True) sent_at = db.Column(db.DateTime, index=False, unique=False, nullable=True)
sent_by = db.Column(db.String, nullable=True) sent_by = db.Column(db.String, nullable=True)
message_cost = db.Column(db.Float, nullable=True, default=0.0)
updated_at = db.Column( updated_at = db.Column(
db.DateTime, db.DateTime,
index=False, index=False,
@@ -0,0 +1,23 @@
"""
Revision ID: 0415_add_message_cost
Revises: 0414_change_total_message_limit
Create Date: 2025-02-28 11:35:22.873930
"""
import sqlalchemy as sa
from alembic import op
down_revision = "0414_change_total_message_limit"
revision = "0415_add_message_cost"
def upgrade():
op.add_column("notifications", sa.Column("message_cost", sa.Float))
op.add_column("notification_history", sa.Column("message_cost", sa.Float))
def downgrade():
op.drop_column("notifications", "message_cost")
op.add_column("notification_history", sa.Column("message_cost", sa.Float))
+3 -4
View File
@@ -571,9 +571,9 @@ def test_purge_bucket(mocker):
mock_s3_resource = MagicMock() mock_s3_resource = MagicMock()
mock_bucket = MagicMock() mock_bucket = MagicMock()
mock_s3_resource.Bucket.return_value = mock_bucket mock_s3_resource.Bucket.return_value = mock_bucket
mocker.patch('app.aws.s3.get_s3_resource', return_value=mock_s3_resource) mocker.patch("app.aws.s3.get_s3_resource", return_value=mock_s3_resource)
purge_bucket('my-bucket', 'access-key', 'secret-key', 'region') purge_bucket("my-bucket", "access-key", "secret-key", "region")
# Assert that the bucket's objects.all().delete() method was called # Assert that the bucket's objects.all().delete() method was called
mock_bucket.objects.all.return_value.delete.assert_called_once() mock_bucket.objects.all.return_value.delete.assert_called_once()
@@ -613,8 +613,7 @@ def test_get_s3_files_handles_exception(mocker):
# Make the first call succeed, second call should fail. # Make the first call succeed, second call should fail.
mock_read_s3_file = mocker.patch( mock_read_s3_file = mocker.patch(
"app.aws.s3.read_s3_file", "app.aws.s3.read_s3_file", side_effect=[None, Exception("exception here")]
side_effect=[None, Exception("exception here")]
) )
mock_thread_pool_executor = mocker.patch("app.aws.s3.ThreadPoolExecutor") mock_thread_pool_executor = mocker.patch("app.aws.s3.ThreadPoolExecutor")
+9 -3
View File
@@ -31,7 +31,7 @@ def side_effect(filterPattern, logGroupName, startTime, endTime):
{ {
"logStreamName": "89db9712-c6d1-49f9-be7c-4caa7ed9efb1", "logStreamName": "89db9712-c6d1-49f9-be7c-4caa7ed9efb1",
"message": '{"delivery":{"destination":"+1661","phoneCarrier":"ATT Mobility", ' "message": '{"delivery":{"destination":"+1661","phoneCarrier":"ATT Mobility", '
'"providerResponse":"Invalid phone number"}}', '"providerResponse":"Invalid phone number", "priceInUSD": "0.00881"}}',
"eventId": "37535432778099870001723210579798865345508698025292922880", "eventId": "37535432778099870001723210579798865345508698025292922880",
} }
] ]
@@ -44,7 +44,7 @@ def side_effect(filterPattern, logGroupName, startTime, endTime):
"logStreamName": "89db9712-c6d1-49f9-be7c-4caa7ed9efb1", "logStreamName": "89db9712-c6d1-49f9-be7c-4caa7ed9efb1",
"timestamp": 1683147017911, "timestamp": 1683147017911,
"message": '{"delivery":{"destination":"+1661","phoneCarrier":"ATT Mobility",' "message": '{"delivery":{"destination":"+1661","phoneCarrier":"ATT Mobility",'
'"providerResponse":"Phone accepted msg"}}', '"providerResponse":"Phone accepted msg", "priceInUSD": "0.00881"}}',
"ingestionTime": 1683147018026, "ingestionTime": 1683147018026,
"eventId": "37535432778099870001723210579798865345508698025292922880", "eventId": "37535432778099870001723210579798865345508698025292922880",
} }
@@ -131,6 +131,7 @@ def test_event_to_db_format_with_missing_fields():
"status": "UNKNOWN", "status": "UNKNOWN",
"delivery.phoneCarrier": "", "delivery.phoneCarrier": "",
"delivery.providerResponse": "", "delivery.providerResponse": "",
"delivery.priceInUSD": 0.0,
"@timestamp": "", "@timestamp": "",
} }
@@ -140,7 +141,11 @@ def test_event_to_db_format_with_string_input():
{ {
"notification": {"messageId": "67890", "timestamp": "2024-01-01T14:00:00Z"}, "notification": {"messageId": "67890", "timestamp": "2024-01-01T14:00:00Z"},
"status": "FAILED", "status": "FAILED",
"delivery": {"phoneCarrier": "Verizon", "providerResponse": "Error"}, "delivery": {
"phoneCarrier": "Verizon",
"providerResponse": "Error",
"priceInUSD": "0.00881",
},
} }
) )
result = aws_cloudwatch_client.event_to_db_format(event) result = aws_cloudwatch_client.event_to_db_format(event)
@@ -149,5 +154,6 @@ def test_event_to_db_format_with_string_input():
"status": "FAILED", "status": "FAILED",
"delivery.phoneCarrier": "Verizon", "delivery.phoneCarrier": "Verizon",
"delivery.providerResponse": "Error", "delivery.providerResponse": "Error",
"delivery.priceInUSD": 0.00881,
"@timestamp": "2024-01-01T14:00:00Z", "@timestamp": "2024-01-01T14:00:00Z",
} }
@@ -2019,8 +2019,8 @@ def test_notifications_not_yet_sent_return_no_rows(sample_service, notification_
def test_update_delivery_receipts(mocker): def test_update_delivery_receipts(mocker):
mock_session = mocker.patch("app.dao.notifications_dao.db.session") mock_session = mocker.patch("app.dao.notifications_dao.db.session")
receipts = [ receipts = [
'{"notification.messageId": "msg1", "delivery.phoneCarrier": "carrier1", "delivery.providerResponse": "resp1", "@timestamp": "2024-01-01T12:00:00"}', # noqa '{"notification.messageId": "msg1", "delivery.phoneCarrier": "carrier1", "delivery.providerResponse": "resp1", "@timestamp": "2024-01-01T12:00:00", "delivery.priceInUSD": "0.00881"}', # noqa
'{"notification.messageId": "msg2", "delivery.phoneCarrier": "carrier2", "delivery.providerResponse": "resp2", "@timestamp": "2024-01-01T13:00:00"}', # noqa '{"notification.messageId": "msg2", "delivery.phoneCarrier": "carrier2", "delivery.providerResponse": "resp2", "@timestamp": "2024-01-01T13:00:00", "delivery.priceInUSD": "0.00881"}', # noqa
] ]
delivered = True delivered = True
mock_update = MagicMock() mock_update = MagicMock()
@@ -2136,7 +2136,9 @@ def test_sanitize_successful_notification_by_id():
) )
def test_dao_get_notifications_by_recipient_or_reference_covers_sms_search_by_reference(notify_db_session): def test_dao_get_notifications_by_recipient_or_reference_covers_sms_search_by_reference(
notify_db_session,
):
""" """
This test: This test:
1. Creates a service and an SMS template. 1. Creates a service and an SMS template.
@@ -2153,7 +2155,7 @@ def test_dao_get_notifications_by_recipient_or_reference_covers_sms_search_by_re
data = { data = {
"id": uuid.uuid4(), "id": uuid.uuid4(),
"to": "1", "to": "1",
"normalised_to": "1", # phone is irrelevant here "normalised_to": "1", # phone is irrelevant here
"service_id": service.id, "service_id": service.id,
"service": service, "service": service,
"template_id": template.id, "template_id": template.id,
@@ -47,14 +47,19 @@ def test_fetch_notification_status_for_service_by_month(notify_db_session):
created_at=datetime(2018, 1, 1, 1, x, 0), created_at=datetime(2018, 1, 1, 1, x, 0),
status=NotificationStatus.DELIVERED, status=NotificationStatus.DELIVERED,
) )
create_notification( whats_this = create_notification(
service_1.templates[0], created_at=datetime(2018, 1, 1, 1, 1, 0) service_1.templates[0], created_at=datetime(2018, 1, 1, 1, 1, 0)
) )
create_notification( print(f"WTN status = {whats_this.status} type = {whats_this.notification_type}")
questionable_notification = create_notification(
service_1.templates[1], service_1.templates[1],
created_at=datetime(2018, 1, 1, 1, 1, 0), created_at=datetime(2018, 1, 1, 1, 1, 0),
status=NotificationStatus.DELIVERED, status=NotificationStatus.DELIVERED,
) )
print(
f"QN status = {questionable_notification.status} type = {questionable_notification.notification_type}"
)
create_notification( create_notification(
service_1.templates[0], service_1.templates[0],
created_at=datetime(2018, 2, 1, 1, 1, 0), created_at=datetime(2018, 2, 1, 1, 1, 0),
+3 -1
View File
@@ -831,7 +831,9 @@ def test_get_organization_users_returns_users_for_organization(
) )
assert len(response["data"]) == 2 assert len(response["data"]) == 2
assert response["data"][0]["id"] == str(first.id) response_ids = [response["data"][0]["id"], response["data"][1]["id"]]
assert str(first.id) in response_ids
assert str(second.id) in response_ids
@freeze_time("2019-12-24 13:30") @freeze_time("2019-12-24 13:30")