D-Net

import eu.dnetlib.repo.manager.service.security.AaiUserRoleService;

import eu.dnetlib.repo.manager.service.security.AuthoritiesUpdater;

import org.springframework.context.annotation.Lazy;

import org.springframework.security.core.authority.SimpleGrantedAuthority;

import org.springframework.web.client.HttpClientErrorException;

    private static final Logger LOGGER = Logger.getLogger(RepositoryServiceImpl.class);

    private final AaiUserRoleService aaiUserRoleService;

    private final AaiRegistryService registryCalls;

    private final AuthoritiesUpdater authoritiesUpdater;

    private final RestTemplate restTemplate;

    private final VocabularyLoader vocabularyLoader;

    private final PiWikService piWikService;

    private final EmailUtils emailUtils;

    private final ValidatorService validatorService;

    private static final Map<String, List<String>> dataSourceClass = new HashMap<>();

    private static final Map<String, String> invertedDataSourceClass = new HashMap<>();

    private final String[] vocabularyNames = {"dnet:countries", "dnet:datasource_typologies", "dnet:compatibilityLevel"};

    private final Map<String, Vocabulary> vocabularyMap = new ConcurrentHashMap<>();

    private final Map<String, String> countriesMap = new HashMap<>();

    private final Map<String, String> inverseCountriesMap = new HashMap<>();

    private HttpHeaders httpHeaders;

    public RepositoryServiceImpl(AaiUserRoleService aaiUserRoleService,

                                 AaiRegistryService registryCalls,

                                 AuthoritiesUpdater authoritiesUpdater,

                                 VocabularyLoader vocabularyLoader, EmailUtils emailUtils,

                                 RestTemplate restTemplate,

                                 @Lazy ValidatorService validatorService,

                                 @Lazy PiWikService piWikService) {

        this.aaiUserRoleService = aaiUserRoleService;

        this.registryCalls = registryCalls;

        this.authoritiesUpdater = authoritiesUpdater;

        this.vocabularyLoader = vocabularyLoader;

        this.piWikService = piWikService;

        this.emailUtils = emailUtils;

        this.validatorService = validatorService;

        this.restTemplate = restTemplate;

    }

        // TODO: move the following code elsewhere (creation and assignment of role to user) ??

        // Create new role

        String newRoleName = aaiUserRoleService.getRoleIdByRepoId(repository.getId());

        Role newRole = new Role(newRoleName, repository.getOfficialName());

        Integer couId = null;

            couId = registryCalls.createRole(newRole);

        } catch (HttpClientErrorException e) {

            couId = registryCalls.getCouId(newRoleName);

            if (couId == null) {

                LOGGER.error(String.format("Could not create role '%s'", newRoleName), e);

            }

            LOGGER.error(String.format("Could not create role '%s'", newRoleName), e);

                // Add role to current user authorities

                authoritiesUpdater.addRole(aaiUserRoleService.convertRepoIdToAuthority(repository.getId()));