createApp($id, $code); $client = $this->clientProvider->findOrCreateClient($app); $group = $this->createUserGroup->execute(\sprintf('app_%s', $code)); $role = $this->appRoleWithScopesFactory->createRole( $code, $scopes, ); $userId = $this->createUser->execute( $code, $app->getName(), [$group->getName()], [$role->getRole()], $id, ); $connection = $this->createConnection->execute( $code, $app->getName(), FlowType::OTHER, $client->getId(), $userId, ); $this->createApp->execute( $app, $scopes, $connection->code(), $group->getName(), $code, ); $user = $this->findConnectionUser($code); $this->OAuthStorage->createAuthCode($code, $client, $user, '', null); /** @var TokenInterface $token */ $token = $this->OAuthStorage->createAccessToken($code, $client, $user, null, \implode(' ', $scopes)); return new ConnectedAppWithValidToken( $id, $code, $token->getToken(), ); } private function createApp(string $id, string $code): App { return App::fromWebMarketplaceValues([ 'id' => $id, 'name' => $code, 'logo' => '/bundles/akeneoconnectivityconnection/img/app-prototype.png', 'author' => 'Akeneo', 'url' => 'http://marketplace.akeneo.com/foo', 'categories' => ['ecommerce'], 'activate_url' => 'http://example.com/activate', 'callback_url' => 'http://example.com/callback', 'connected' => true, 'isPending' => false, ]); } private function findConnectionUser(string $code): UserInterface { $query = <<dbalConnection->fetchOne($query, [ 'code' => $code, ]); return $this->userRepository->findOneById($id); } }