OJS - Trivial Notification Job patch

trivial-notification-job.patch

diff --git a/Jobs/Notifications/TrivialNotificationJob.php b/Jobs/Notifications/TrivialNotificationJob.php
new file mode 100644
index 000000000..36a63ef88
--- /dev/null
+++ b/Jobs/Notifications/TrivialNotificationJob.php
@@ -0,0 +1,70 @@
+<?php
+
+declare(strict_types=1);
+
+/**
+ * @file Jobs/Submissions/UpdateSubmissionSearchJob.php
+ *
+ * Copyright (c) 2014-2021 Simon Fraser University
+ * Copyright (c) 2000-2021 John Willinsky
+ * Distributed under the GNU GPL v3. For full terms see the file docs/COPYING.
+ *
+ * @class UpdateSubmissionSearchJob
+ * @ingroup jobs
+ *
+ * @brief Class to handle the Submission Search data update as a Job
+ */
+
+namespace PKP\Jobs\Notifications;
+
+use APP\notification\NotificationManager;
+use PKP\notification\PKPNotification;
+use PKP\Support\Jobs\BaseJob;
+
+class TrivialNotificationJob extends BaseJob
+{
+    /**
+     * @var string Notification Type
+     */
+    protected $notificationType;
+
+    /**
+     * @var int Target User Id
+     */
+    protected $targetUserId;
+
+    /**
+     * @var string Content Body
+     */
+    protected $body;
+
+    /**
+     * Create a new job instance.
+     *
+     */
+    public function __construct(
+        int $targetUserId,
+        string $body,
+        string $notificationType = PKPNotification::NOTIFICATION_TYPE_ERROR
+    ) {
+        parent::__construct();
+
+        $this->notificationType = $notificationType;
+        $this->targetUserId = $targetUserId;
+        $this->body = $body;
+    }
+
+    /**
+     * Execute the job.
+     *
+     */
+    public function handle(): void
+    {
+        $notificationMgr = new NotificationManager();
+        $notificationMgr->createTrivialNotification(
+            $this->targetUserId,
+            $this->notificationType,
+            ['contents' => $this->body]
+        );
+    }
+}
diff --git a/pages/admin/AdminHandler.inc.php b/pages/admin/AdminHandler.inc.php
index 85c6e7d62..be89765f4 100644
--- a/pages/admin/AdminHandler.inc.php
+++ b/pages/admin/AdminHandler.inc.php
@@ -20,11 +20,16 @@ use APP\handler\Handler;
 use APP\template\TemplateManager;
 use Illuminate\Support\Facades\DB;
 
+use PKP\Jobs\Submissions\UpdateSubmissionSearchJob;
 use PKP\scheduledTask\ScheduledTaskHelper;
 use PKP\security\authorization\PKPSiteAccessPolicy;
 use PKP\security\Role;
 use PKP\site\VersionCheck;
 
+use PKP\Jobs\Notifications\TrivialNotificationJob;
+
+use Illuminate\Support\Str;
+
 class AdminHandler extends Handler
 {
     /** @copydoc PKPHandler::_isBackendPage */
@@ -51,6 +56,7 @@ class AdminHandler extends Handler
                 'clearDataCache',
                 'downloadScheduledTaskLogFile',
                 'clearScheduledTaskLogFiles',
+                'add_job',
             ]
         );
     }
@@ -216,6 +222,29 @@ class AdminHandler extends Handler
         $templateMgr->display('admin/settings.tpl');
     }
 
+    public function add_job($args, $request)
+    {
+        $job = function (
+            $body,
+            string $type = PKP\notification\PKPNotification::NOTIFICATION_TYPE_ERROR
+        ) use ($request) {
+            return new TrivialNotificationJob(
+                $request->getUser()->getId(),
+                $body,
+                $type
+            );
+        };
+
+        // This will run as sync
+        dispatch(
+            $job('Job was dispatched', PKP\notification\PKPNotification::NOTIFICATION_TYPE_SUCCESS)
+        )->onConnection('sync');
+        // This will be added into jobs table
+        dispatch($job('Random message ' . PHP_EOL . Str::random(20)));
+
+        $this->settings($args, $request);
+    }
+
     /**
      * Business logic for site settings single/multiple contexts availability
      *
diff --git a/pages/admin/index.php b/pages/admin/index.php
index c7627e420..d264756de 100644
--- a/pages/admin/index.php
+++ b/pages/admin/index.php
@@ -29,6 +29,7 @@ switch ($op) {
     case 'clearDataCache':
     case 'downloadScheduledTaskLogFile':
     case 'clearScheduledTaskLogFiles':
+    case 'add_job':
         define('HANDLER_CLASS', 'AdminHandler');
         import('lib.pkp.pages.admin.AdminHandler');
         break;