* @copyright 2020 Akeneo SAS (http://www.akeneo.com) * @license http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0) */ class DbalUpdateEventsApiRequestCountQueryIntegration extends TestCase { public function test_it_updates_event_api_request_count_on_duplicate(): void { $this->getUpdateEventsApiRequestCountQuery()->execute( new \DateTimeImmutable('2020-12-09 17:01:00', new \DateTimeZone('UTC')), 6 ); $this->getUpdateEventsApiRequestCountQuery()->execute( new \DateTimeImmutable('2020-12-09 17:02:12', new \DateTimeZone('UTC')), 12 ); $this->getUpdateEventsApiRequestCountQuery()->execute( new \DateTimeImmutable('2020-12-09 17:02:59', new \DateTimeZone('UTC')), 18 ); $this->getUpdateEventsApiRequestCountQuery()->execute( new \DateTimeImmutable('2020-12-09 18:03:00', new \DateTimeZone('UTC')), 24 ); $this->getUpdateEventsApiRequestCountQuery()->execute( new \DateTimeImmutable('2020-12-11 18:03:12', new \DateTimeZone('UTC')), 24 ); $expectedEventApiRequestCounts = [ ['event_minute' => '1', 'event_count' => '6', 'updated' => '2020-12-09 17:01:00'], ['event_minute' => '2', 'event_count' => '30', 'updated' => '2020-12-09 17:02:59'], ['event_minute' => '3', 'event_count' => '24', 'updated' => '2020-12-11 18:03:12'], ]; $eventApiRequestCounts = $this->getEventApiRequestCounts(); Assert::assertCount(3, $eventApiRequestCounts); $this->assertEqualsEventApiRequestCount($expectedEventApiRequestCounts[0], $eventApiRequestCounts[0]); $this->assertEqualsEventApiRequestCount($expectedEventApiRequestCounts[1], $eventApiRequestCounts[1]); $this->assertEqualsEventApiRequestCount($expectedEventApiRequestCounts[2], $eventApiRequestCounts[2]); } private function getEventApiRequestCounts(): array { $sql = <<getDbalConnection()->fetchAllAssociative($sql); } private function assertEqualsEventApiRequestCount(array $expected, array $actual): void { Assert::assertEquals($expected['event_minute'], $actual['event_minute']); Assert::assertEquals($expected['event_count'], $actual['event_count']); Assert::assertEquals($expected['updated'], $actual['updated']); } protected function getConfiguration(): Configuration { return $this->catalog->useMinimalCatalog(); } private function getDbalConnection(): DbalConnection { return $this->get('database_connection'); } private function getUpdateEventsApiRequestCountQuery(): UpdateEventsApiRequestCountQueryInterface { return $this->get(DbalUpdateEventsApiRequestCountQuery::class); } }