query = $this->get(SaveRevokedAccessTokensOfDisconnectedAppQuery::class); $this->connection = $this->get('database_connection'); $this->connectedAppLoader = $this->get('akeneo_connectivity.connection.fixtures.connected_app_loader'); } protected function getConfiguration(): Configuration { return $this->catalog->useMinimalCatalog(); } public function testItSavesAccessTokensOfAnAppInTheRevokedTable(): void { $this->connectedAppLoader->createConnectedAppWithUserAndTokens( '2677e764-f852-4956-bf9b-1a1ec1b0d145', 'magento', ); $this->connectedAppLoader->createConnectedAppWithUserAndTokens( '2677e764-f852-4956-bf9b-1a1ec1b0d146', 'shopify', ); $this->assertNoAccessTokensAreRevoked(); $this->query->execute('2677e764-f852-4956-bf9b-1a1ec1b0d145'); $this->assertAccessTokensAreSavedInTheRevokedTable([ 'magento', // The ConnectedAppLoader always create an access token using the app code ]); } private function assertNoAccessTokensAreRevoked(): void { $query = <<connection->fetchOne($query)); } private function assertAccessTokensAreSavedInTheRevokedTable(array $tokens): void { $query = <<connection->fetchFirstColumn($query)); } }