86 lines
2.8 KiB
Java
86 lines
2.8 KiB
Java
package eu.dnetlib.openaire.community.importer;
|
|
|
|
import java.io.IOException;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
import java.util.Set;
|
|
import java.util.stream.Collectors;
|
|
|
|
import org.apache.commons.logging.Log;
|
|
import org.apache.commons.logging.LogFactory;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
|
|
import org.springframework.web.bind.annotation.CrossOrigin;
|
|
import org.springframework.web.bind.annotation.GetMapping;
|
|
import org.springframework.web.bind.annotation.RequestParam;
|
|
import org.springframework.web.bind.annotation.RestController;
|
|
|
|
import com.google.common.collect.Sets;
|
|
|
|
import eu.dnetlib.openaire.common.ISClient;
|
|
import eu.dnetlib.openaire.community.model.DbOrganization;
|
|
import eu.dnetlib.openaire.exporter.exceptions.CommunityException;
|
|
import eu.dnetlib.openaire.exporter.model.context.Context;
|
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
|
|
|
@RestController
|
|
@CrossOrigin(origins = {
|
|
"*"
|
|
})
|
|
@ConditionalOnProperty(value = "openaire.exporter.enable.community", havingValue = "true")
|
|
@Tag(name = "OpenAIRE Communities: Migration API", description = "OpenAIRE Communities: Migration API")
|
|
public class CommunityImporterController {
|
|
|
|
public final static Set<String> communityBlackList = Sets.newHashSet("fet-fp7", "fet-h2020");
|
|
|
|
@Autowired
|
|
private CommunityImporterService importer;
|
|
|
|
@Autowired
|
|
private ISClient isClient;
|
|
|
|
private static final Log log = LogFactory.getLog(CommunityImporterController.class);
|
|
|
|
@GetMapping("/community_importer/communities")
|
|
public List<String> importProfiles() throws CommunityException {
|
|
try {
|
|
final Map<String, Context> contextMap = getContextMap();
|
|
|
|
final List<String> list = contextMap.keySet()
|
|
.stream()
|
|
.filter(id -> !communityBlackList.contains(id))
|
|
.collect(Collectors.toList());
|
|
|
|
list.forEach(id -> {
|
|
importer.importCommunity(contextMap.get(id));
|
|
});
|
|
|
|
return list;
|
|
} catch (final Throwable e) {
|
|
log.error("Error importing communities", e);
|
|
throw new CommunityException(e.getMessage());
|
|
}
|
|
}
|
|
|
|
@GetMapping("/community_importer/propagationOrgs")
|
|
public List<DbOrganization> importPropagationOrgs(@RequestParam final String profileId,
|
|
@RequestParam(required = false, defaultValue = "false") final boolean simulation) throws Exception {
|
|
try {
|
|
final String xml = isClient.getProfile(profileId);
|
|
return importer.importPropagationOrganizationsFromProfile(xml, simulation);
|
|
} catch (final Throwable e) {
|
|
log.error("Error importing communities", e);
|
|
throw new CommunityException(e.getMessage());
|
|
}
|
|
}
|
|
|
|
private Map<String, Context> getContextMap() throws CommunityException {
|
|
try {
|
|
return isClient.getCommunityContextMap();
|
|
} catch (final IOException e) {
|
|
throw new CommunityException(e);
|
|
}
|
|
}
|
|
|
|
}
|