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);