From bd5bb5ae65d6cb870d090382b106b705833d4cf1 Mon Sep 17 00:00:00 2001
From: retoor <retoor@molodetz.nl>
Date: Thu, 27 Mar 2025 20:10:05 +0100
Subject: [PATCH] Transaction.
---
src/snek/service/notification.py | 3 +++
1 file changed, 3 insertions(+)
diff --git a/src/snek/service/notification.py b/src/snek/service/notification.py
index 0b54a23..1392044 100644
--- a/src/snek/service/notification.py
+++ b/src/snek/service/notification.py
@@ -30,6 +30,7 @@ class NotificationService(BaseService):
uid=channel_message_uid
)
user = await self.services.user.get(uid=channel_message["user_uid"])
+ self.app.db.begin()
async for channel_member in self.services.channel_member.find(
channel_uid=channel_message["channel_uid"],
is_banned=False,
@@ -56,3 +57,5 @@ class NotificationService(BaseService):
await self.save(model)
except Exception as ex:
raise Exception(f"Failed to create notification: {model.errors}.")
+
+ self.app.db.commit()