catalog->useMinimalCatalog(); } protected function setUp(): void { parent::setUp(); $this->connection = $this->get('database_connection'); $this->connectionLoader = $this->get('akeneo_connectivity.connection.fixtures.connection_loader'); $this->query = $this->get(UpdateConnectionWebhookQuery::class); } public function test_it_updates_a_webhook(): void { $magento = $this->connectionLoader->createConnection('magento', 'Magento Connector', FlowType::DATA_DESTINATION, false); $this->assertWebhookIsInDatabase($magento->code(), false); $numberOfUpdatedRows = $this->query->execute(new ConnectionWebhook( $magento->code(), true, 'http://any-url.com', true )); Assert::assertEquals(1, $numberOfUpdatedRows); $this->assertWebhookIsInDatabase($magento->code(), true, 'http://any-url.com', true); } private function assertWebhookIsInDatabase( string $code, bool $enabled, ?string $url = null, bool $isUsingUuid = false, ): void { $selectQuery = <<connection->executeQuery($selectQuery, ['code' => $code])->fetchAssociative(); Assert::assertEquals($enabled, (bool) $webhook['webhook_enabled']); Assert::assertEquals($url, $webhook['webhook_url']); Assert::assertEquals($isUsingUuid, (bool) $webhook['webhook_is_using_uuid']); } }