* @copyright 2020 Akeneo SAS (http://www.akeneo.com) * @license http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0) */ class ApiConnectionCount implements ApiConnectionCountQuery { /** @var Connection */ private $connection; public function __construct(Connection $connection) { $this->connection = $connection; } public function fetch(): array { $query = <<connection->executeQuery($query)->fetchAllAssociative(); return $this->normalize($data); } private function normalize(array $data): array { $normalized[FlowType::DATA_SOURCE] = ['tracked' => 0, 'untracked' => 0]; $normalized[FlowType::DATA_DESTINATION] = ['tracked' => 0, 'untracked' => 0]; $normalized[FlowType::OTHER] = ['tracked' => 0, 'untracked' => 0]; foreach ($data as $row) { $status = (bool) $row['auditable'] ? 'tracked':'untracked'; $normalized[$row['flow_type']][$status] = $row['flow_type_count']; } return $normalized; } }