From 6de26597934c9497f5f2bb9487206b54b9a5bea1 Mon Sep 17 00:00:00 2001
From: Prateek Banga <prateekbanga@Prateeks-MacBook-Air.local>
Date: Mon, 18 Dec 2023 15:27:09 +0530
Subject: [PATCH] adds mock providers in project for benchmarking, fixes bug in
 scheduling

removes scheduling from array in schedulemessage task
---
 app/controllers/api/projects.php              | 48 +++++++++++++++++++
 .../Platform/Tasks/ScheduleMessage.php        |  2 +-
 2 files changed, 49 insertions(+), 1 deletion(-)

diff --git a/app/controllers/api/projects.php b/app/controllers/api/projects.php
index fe441e0e8c..38d23b2d2d 100644
--- a/app/controllers/api/projects.php
+++ b/app/controllers/api/projects.php
@@ -216,6 +216,54 @@ App::post('/v1/projects')
             }
             $dbForProject->createCollection($key, $attributes, $indexes);
         }
+        $emailProvider = new Document([
+            '$id' => ID::custom('mock-email-provider'),
+            'name' => 'mock',
+            'provider' => 'mock',
+            'type' => MESSAGE_TYPE_EMAIL,
+            'enabled' => true,
+            'credentials' => [
+                'username' => 'username',
+                'password' => 'password'
+            ],
+            'options' => [
+                'from' => 'sender-email'
+            ],
+        ]);
+        $smsProvider = new Document([
+            '$id' => ID::custom('mock-sms-provider'),
+            'name' => 'mock',
+            'provider' => 'mock',
+            'type' => MESSAGE_TYPE_SMS,
+            'enabled' => true,
+            'credentials' => [
+                'username' => 'username',
+                'password' => 'password'
+            ],
+            'options' => [
+                'from' => 'sender-email'
+            ],
+        ]);
+        $pushProvider = new Document([
+            '$id' => ID::custom('mock-push-provider'),
+            'name' => 'mock',
+            'provider' => 'mock',
+            'type' => MESSAGE_TYPE_PUSH,
+            'enabled' => true,
+            'credentials' => [
+                'username' => 'username',
+                'password' => 'password'
+            ],
+            'options' => [
+                'from' => 'sender-email'
+            ],
+        ]);
+        $dbForProject->createDocument('providers', $emailProvider);
+
+
+        $dbForProject->createDocument('providers', $smsProvider);
+
+        $dbForProject->createDocument('providers', $pushProvider);
 
         $response
             ->setStatusCode(Response::STATUS_CODE_CREATED)
diff --git a/src/Appwrite/Platform/Tasks/ScheduleMessage.php b/src/Appwrite/Platform/Tasks/ScheduleMessage.php
index cd29a1dcf8..8db2efe2de 100644
--- a/src/Appwrite/Platform/Tasks/ScheduleMessage.php
+++ b/src/Appwrite/Platform/Tasks/ScheduleMessage.php
@@ -133,7 +133,7 @@ class ScheduleMessage extends Action
                  */
                 $enqueueMessages = function () use (&$schedules, $pools, $dbForConsole) {
                     foreach ($schedules as $scheduleId => $schedule) {
-                        \go(function () use ($schedules, $schedule, $pools, $dbForConsole) {
+                        \go(function () use (&$schedules, $schedule, $pools, $dbForConsole) {
                             $queue = $pools->get('queue')->pop();
                             $connection = $queue->getResource();
                             $queueForMessaging = new Messaging($connection);