From 13ce09a5c50ddba8956dbeb838f9dd1bcafe184a Mon Sep 17 00:00:00 2001
From: retoor <retoor@molodetz.nl>
Date: Thu, 27 Mar 2025 20:20:48 +0100
Subject: [PATCH] Transactions.
---
src/snek/view/rpc.py | 2 ++
1 file changed, 2 insertions(+)
diff --git a/src/snek/view/rpc.py b/src/snek/view/rpc.py
index 27a8dcf..5720f04 100644
--- a/src/snek/view/rpc.py
+++ b/src/snek/view/rpc.py
@@ -203,7 +203,9 @@ class RPCView(BaseView):
if msg.type == web.WSMsgType.TEXT:
try:
async with Profiler():
+ self.app.db.begin()
await rpc(msg.json())
+ self.app.db.commit()
except Exception as ex:
print(ex, flush=True)
await self.services.socket.delete(ws)