2018-09-04 11:36:18 +02:00
|
|
|
package eu.eudat.logic.managers;
|
|
|
|
|
2019-09-25 17:31:41 +02:00
|
|
|
import com.fasterxml.jackson.databind.DeserializationFeature;
|
|
|
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
|
|
|
import eu.eudat.data.dao.criteria.RegistryCriteria;
|
2018-09-04 11:36:18 +02:00
|
|
|
import eu.eudat.data.entities.Registry;
|
2019-10-03 13:06:44 +02:00
|
|
|
import eu.eudat.logic.proxy.config.ExternalUrlCriteria;
|
2019-09-25 17:31:41 +02:00
|
|
|
import eu.eudat.logic.proxy.config.exceptions.HugeResultSet;
|
|
|
|
import eu.eudat.logic.proxy.config.exceptions.NoURLFound;
|
2018-09-04 11:36:18 +02:00
|
|
|
import eu.eudat.logic.services.ApiContext;
|
|
|
|
import eu.eudat.models.data.registries.RegistryModel;
|
2019-09-25 12:43:17 +02:00
|
|
|
import eu.eudat.models.data.security.Principal;
|
2019-03-05 16:33:59 +01:00
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
2019-02-01 17:56:55 +01:00
|
|
|
import org.springframework.stereotype.Component;
|
2018-09-04 11:36:18 +02:00
|
|
|
|
2019-10-04 13:34:59 +02:00
|
|
|
import java.util.LinkedList;
|
2019-09-25 17:31:41 +02:00
|
|
|
import java.util.List;
|
|
|
|
import java.util.Map;
|
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
2019-02-01 17:56:55 +01:00
|
|
|
@Component
|
2018-09-04 11:36:18 +02:00
|
|
|
public class RegistryManager {
|
2019-03-05 16:33:59 +01:00
|
|
|
|
|
|
|
private ApiContext apiContext;
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
public RegistryManager(ApiContext apiContext) {
|
|
|
|
this.apiContext = apiContext;
|
|
|
|
}
|
|
|
|
|
2019-09-25 12:43:17 +02:00
|
|
|
public Registry create(RegistryModel registryModel, Principal principal) throws Exception {
|
2019-11-06 11:05:40 +01:00
|
|
|
if (registryModel.getLabel() == null || registryModel.getAbbreviation() == null || registryModel.getUri() == null) {
|
|
|
|
throw new Exception("Missing mandatory entity.");
|
|
|
|
}
|
2018-09-04 11:36:18 +02:00
|
|
|
Registry registry = registryModel.toDataModel();
|
2019-09-25 12:43:17 +02:00
|
|
|
registry.getCreationUser().setId(principal.getId());
|
2018-09-04 11:36:18 +02:00
|
|
|
return apiContext.getOperationsContext().getDatabaseRepository().getRegistryDao().createOrUpdate(registry);
|
|
|
|
}
|
2019-09-25 17:31:41 +02:00
|
|
|
|
|
|
|
public List<RegistryModel> getRegistries(String query, String type, Principal principal) throws HugeResultSet, NoURLFound {
|
2019-10-03 13:06:44 +02:00
|
|
|
ExternalUrlCriteria externalUrlCriteria = new ExternalUrlCriteria(query);
|
2020-10-07 13:22:37 +02:00
|
|
|
List<Map<String, String>> remoteRepos = this.apiContext.getOperationsContext().getRemoteFetcher().getRegistries(externalUrlCriteria, type);
|
2019-09-25 17:31:41 +02:00
|
|
|
|
|
|
|
RegistryCriteria criteria = new RegistryCriteria();
|
|
|
|
if (!query.isEmpty()) criteria.setLike(query);
|
|
|
|
criteria.setCreationUserId(principal.getId());
|
2019-10-04 13:34:59 +02:00
|
|
|
List<RegistryModel> registryModels = new LinkedList<>();
|
|
|
|
if (type.equals("")) {
|
|
|
|
List<Registry> registryList = (this.apiContext.getOperationsContext().getDatabaseRepository().getRegistryDao().getWithCriteria(criteria)).toList();
|
|
|
|
registryModels = registryList.stream().map(item -> new RegistryModel().fromDataModel(item)).collect(Collectors.toList());
|
|
|
|
}
|
2019-09-25 17:31:41 +02:00
|
|
|
ObjectMapper mapper = new ObjectMapper().configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
|
|
|
|
registryModels.addAll(remoteRepos.stream().map(item -> mapper.convertValue(item, RegistryModel.class)).collect(Collectors.toList()));
|
|
|
|
|
|
|
|
return registryModels;
|
|
|
|
}
|
2018-09-04 11:36:18 +02:00
|
|
|
}
|