adds mock providers in project for benchmarking, fixes bug in scheduling
removes scheduling from array in schedulemessage task
This commit is contained in:
parent
b8aa2faa7b
commit
6de2659793
2 changed files with 49 additions and 1 deletions
|
@ -216,6 +216,54 @@ App::post('/v1/projects')
|
||||||
}
|
}
|
||||||
$dbForProject->createCollection($key, $attributes, $indexes);
|
$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
|
$response
|
||||||
->setStatusCode(Response::STATUS_CODE_CREATED)
|
->setStatusCode(Response::STATUS_CODE_CREATED)
|
||||||
|
|
|
@ -133,7 +133,7 @@ class ScheduleMessage extends Action
|
||||||
*/
|
*/
|
||||||
$enqueueMessages = function () use (&$schedules, $pools, $dbForConsole) {
|
$enqueueMessages = function () use (&$schedules, $pools, $dbForConsole) {
|
||||||
foreach ($schedules as $scheduleId => $schedule) {
|
foreach ($schedules as $scheduleId => $schedule) {
|
||||||
\go(function () use ($schedules, $schedule, $pools, $dbForConsole) {
|
\go(function () use (&$schedules, $schedule, $pools, $dbForConsole) {
|
||||||
$queue = $pools->get('queue')->pop();
|
$queue = $pools->get('queue')->pop();
|
||||||
$connection = $queue->getResource();
|
$connection = $queue->getResource();
|
||||||
$queueForMessaging = new Messaging($connection);
|
$queueForMessaging = new Messaging($connection);
|
||||||
|
|
Loading…
Reference in a new issue