[K6.2] Store notifications mail in database to be sent by CRON #9555

Kunena · Aug 27, 2023 · e6968b3 · e6968b3
1 parent 38f3d08
commit e6968b3
Show file tree

Hide file tree

Showing 3 changed files with 70 additions and 1 deletion.
diff --git a/src/admin/install/kunena.install.upgrade.xml b/src/admin/install/kunena.install.upgrade.xml
@@ -217,6 +217,25 @@
             </query>
             <query mode="silenterror">ALTER TABLE `#__kunena_users` DROP `karma_time`;</query>
         </version>
+        <version version="6.2.0-DEV"
+                 versiondate="2023-08-27"
+                 versionname="Internal">
+            <query mode="silenterror">
+            CREATE TABLE IF NOT EXISTS `#__kunena_mails_queue`
+(
+    `id`             int(11)      NOT NULL auto_increment,
+    `subject`        varchar(150) NOT NULL,
+    `message_id`     int(11)      NULL,
+    `sent_to`        varchar(200) NOT NULL,
+    `message_url`    varchar(150) NOT NULL,
+    `is_sent`        int(11)      NULL,
+    PRIMARY KEY (id),
+)
+    ENGINE = InnoDB
+    DEFAULT CHARSET = utf8mb4
+    DEFAULT COLLATE = utf8mb4_unicode_ci;
+            </query>
+        </version>
         <version version="@kunenaversion@"
                  versiondate="@kunenaversiondate@"
                  versionname="@kunenaversionname@">

diff --git a/src/admin/sql/install/mysql/create_tables.utf8.sql b/src/admin/sql/install/mysql/create_tables.utf8.sql
@@ -214,6 +214,20 @@ CREATE TABLE IF NOT EXISTS `#__kunena_messages_text`
     ENGINE = InnoDB
     DEFAULT CHARSET = utf8mb4
     DEFAULT COLLATE = utf8mb4_unicode_ci;
+
+CREATE TABLE IF NOT EXISTS `#__kunena_mails_queue`
+(
+    `id`             int(11)      NOT NULL auto_increment,
+    `subject`        varchar(150) NOT NULL,
+    `message_id`     int(11)      NULL,
+    `sent_to`        varchar(200) NOT NULL,
+    `message_url`    varchar(150) NOT NULL,
+    `is_sent`        int(11)      NULL,
+    PRIMARY KEY (id),
+)
+    ENGINE = InnoDB
+    DEFAULT CHARSET = utf8mb4
+    DEFAULT COLLATE = utf8mb4_unicode_ci;
 
 CREATE TABLE IF NOT EXISTS `#__kunena_polls`
 (

diff --git a/src/libraries/kunena/src/Forum/Message/KunenaMessage.php b/src/libraries/kunena/src/Forum/Message/KunenaMessage.php
@@ -439,6 +439,7 @@ public function newReply($fields = [], $useridfromparent = 0, $safefields = null
     public function sendNotification($url = null, $approved = false)
     {
         $config = KunenaFactory::getConfig();
+        $db        = Factory::getDbo();
 
         if (!$config->sendEmails) {
             return false;
@@ -548,10 +549,45 @@ public function sendNotification($url = null, $approved = false)
                 KunenaEmail::send($mail, $receivers[0]);
             }
 
+            // Store the mails data for all subscribers in mail queue
+            $columns = array('subject', 'message_id', 'sent_to', 'message_url');
+
+            $values = array($subject, $this->id, $receivers[1], $url);
+
+            $query     = $db->getQuery(true)
+                ->insert($db->quoteName('#__mails_queue'))
+                ->columns($db->quoteName($columns))
+                ->values(implode(',', $values));
+
+            $db->setQuery($query);
+
+            try {
+                $db->execute();
+            } catch (ExecutionFailureException $e) {
+                KunenaError::displayDatabaseError($e);
+            }
+
+            // Store the mails data for all moderators in mail queue
+            $columns = array('subject', 'message_id', 'sent_to', 'message_url');
+
+            $values = array($subject, $this->id, $receivers[0], $url);
+
+            $query     = $db->getQuery(true)
+                ->insert($db->quoteName('#__mails_queue'))
+                ->columns($db->quoteName($columns))
+                ->values(implode(',', $values));
+
+            $db->setQuery($query);
+
+            try {
+                $db->execute();
+            } catch (ExecutionFailureException $e) {
+                KunenaError::displayDatabaseError($e);
+            }
+
             // Update subscriptions.
             if ($once && $sentusers) {
                 $sentusers = implode(',', $sentusers);
-                $db        = Factory::getDbo();
                 $query     = $db->getQuery(true)
                     ->update('#__kunena_user_topics')
                     ->set('subscribed=2')