From 2064d219e19550cd885bee103a06e3f1cb7bc8e2 Mon Sep 17 00:00:00 2001
From: ilotterytea <iltsu@alright.party>
Date: Tue, 30 Apr 2024 01:16:41 +0500
Subject: feat: create a new db connection for each message and pass work to it

---
 src/main.cpp | 14 +++++++++++---
 1 file changed, 11 insertions(+), 3 deletions(-)

(limited to 'src/main.cpp')

diff --git a/src/main.cpp b/src/main.cpp
index c7e8e2f..67cf3a5 100644
--- a/src/main.cpp
+++ b/src/main.cpp
@@ -56,10 +56,18 @@ int main(int argc, char *argv[]) {
   conn.close();
 
   client.on<bot::irc::MessageType::Privmsg>(
-      [&client, &command_loader, &localization](
-          const bot::irc::Message<bot::irc::MessageType::Privmsg> &message) {
+      [&client, &command_loader, &localization,
+       &cfg](const bot::irc::Message<bot::irc::MessageType::Privmsg> &message) {
         bot::InstanceBundle bundle{client, localization};
-        bot::handlers::handle_private_message(bundle, command_loader, message);
+
+        pqxx::connection conn(GET_DATABASE_CONNECTION_URL(cfg));
+        pqxx::work work(conn);
+
+        bot::handlers::handle_private_message(bundle, command_loader, message,
+                                              work);
+
+        work.commit();
+        conn.close();
       });
 
   client.run();
-- 
cgit v1.2.3