Cavemanon/piratepoet
8
Fork 0
Code Pull Requests Actions Releases 16 Activity

Load all statistics at once

Browse Source 
[MAILPOET-4673]
This commit is contained in:
David Remer
2022-10-11 09:26:16 +03:00
committed by Jan Jakeš
parent d077370086
commit 5600a2fef0
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
mailpoet/lib/Automation/Engine/Endpoints/Workflows/WorkflowsGetEndpoint.php
View File

@@ -7,6 +7,7 @@ use MailPoet\API\REST\Request;
use MailPoet\API\REST\Response; use MailPoet\API\REST\Response;
use MailPoet\Automation\Engine\API\Endpoint; use MailPoet\Automation\Engine\API\Endpoint;
use MailPoet\Automation\Engine\Data\Workflow; use MailPoet\Automation\Engine\Data\Workflow;
use MailPoet\Automation\Engine\Data\WorkflowStatistics;
use MailPoet\Automation\Engine\Storage\WorkflowStatisticsStorage; use MailPoet\Automation\Engine\Storage\WorkflowStatisticsStorage;
use MailPoet\Automation\Engine\Storage\WorkflowStorage; use MailPoet\Automation\Engine\Storage\WorkflowStorage;
use MailPoet\Validator\Builder; use MailPoet\Validator\Builder;
@@ -29,8 +30,9 @@ class WorkflowsGetEndpoint extends Endpoint {
public function handle(Request $request): Response { public function handle(Request $request): Response {
$status = $request->getParam('status') ? (array)$request->getParam('status') : null; $status = $request->getParam('status') ? (array)$request->getParam('status') : null;
$workflows = $this->workflowStorage->getWorkflows($status); $workflows = $this->workflowStorage->getWorkflows($status);
return new Response(array_map(function (Workflow $workflow) { $statistics = $this->statisticsStorage->getWorkflowStatisticsForWorkflows(...$workflows);
return $this->buildWorkflow($workflow); return new Response(array_map(function (Workflow $workflow) use ($statistics) {
return $this->buildWorkflow($workflow, $statistics[$workflow->getId()]);
}, $workflows)); }, $workflows));
} }
@@ -40,14 +42,14 @@ class WorkflowsGetEndpoint extends Endpoint {
]; ];
} }
private function buildWorkflow(Workflow $workflow): array { private function buildWorkflow(Workflow $workflow, WorkflowStatistics $statistics): array {
return [ return [
'id' => $workflow->getId(), 'id' => $workflow->getId(),
'name' => $workflow->getName(), 'name' => $workflow->getName(),
'status' => $workflow->getStatus(), 'status' => $workflow->getStatus(),
'created_at' => $workflow->getCreatedAt()->format(DateTimeImmutable::W3C), 'created_at' => $workflow->getCreatedAt()->format(DateTimeImmutable::W3C),
'updated_at' => $workflow->getUpdatedAt()->format(DateTimeImmutable::W3C), 'updated_at' => $workflow->getUpdatedAt()->format(DateTimeImmutable::W3C),
'stats' => $this->statisticsStorage->getWorkflowStats($workflow->getId())->toArray(), 'stats' => $statistics->toArray(),
'activated_at' => $workflow->getActivatedAt() ? $workflow->getActivatedAt()->format(DateTimeImmutable::W3C) : null, 'activated_at' => $workflow->getActivatedAt() ? $workflow->getActivatedAt()->format(DateTimeImmutable::W3C) : null,
'author' => [ 'author' => [
'id' => $workflow->getAuthor()->ID, 'id' => $workflow->getAuthor()->ID,