D-Net

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">

	<parent>

		<groupId>eu.dnetlib</groupId>

		<artifactId>dnet45-parent</artifactId>

		<version>1.0.0</version>

		<relativePath />

	</parent>

	<modelVersion>4.0.0</modelVersion>

	<groupId>eu.dnetlib</groupId>

	<artifactId>dnet-datasource-manager-common</artifactId>

	<packaging>jar</packaging>

	<version>2.0.2</version>

	<scm>

		<developerConnection>scm:svn:https://svn.driver.research-infrastructures.eu/driver/dnet45/modules/dnet-datasource-manager-common/tags/dnet-datasource-manager-common-2.0.2</developerConnection>

	</scm>

	<dependencies>

		<dependency>

			<groupId>com.google.guava</groupId>

			<artifactId>guava</artifactId>

			<version>23.3-jre</version>

		</dependency>

		<dependency>

			<groupId>com.google.code.gson</groupId>

			<artifactId>gson</artifactId>

			<version>2.8.0</version>

		</dependency>

		<dependency>

			<groupId>javax.persistence</groupId>

			<artifactId>persistence-api</artifactId>

			<version>1.0</version>

		</dependency>

	</dependencies>

</project>

package eu.dnetlib.enabling.datasources.common;

public abstract class AggregationInfo {

	private int numberOfRecords;

	private String date;

	private AggregationStage aggregationStage;

	private boolean indexedVersion = false;

	private boolean completedSuccessfully = true;

	public AggregationInfo() {}

	public int getNumberOfRecords() {

		return numberOfRecords;

	}

	public void setNumberOfRecords(final int numberOfRecords) {

		this.numberOfRecords = numberOfRecords;

	}

	public String getDate() {

		return date;

	}

	public void setDate(final String date) {

		this.date = date;

	}

	public AggregationStage getAggregationStage() {

		return aggregationStage;

	}

	public void setAggregationStage(final AggregationStage aggregationStage) {

		this.aggregationStage = aggregationStage;

	}

	public boolean isIndexedVersion() {

		return indexedVersion;

	}

	public void setIndexedVersion(final boolean indexedVersion) {

		this.indexedVersion = indexedVersion;

	}

	public boolean isCompletedSuccessfully() {

		return completedSuccessfully;

	}

	public void setCompletedSuccessfully(final boolean completedSuccessfully) {

		this.completedSuccessfully = completedSuccessfully;

	}

}

package eu.dnetlib.enabling.datasources.common;

import java.sql.Date;

import java.util.Set;

import javax.persistence.CascadeType;

import javax.persistence.Column;

import javax.persistence.FetchType;

import javax.persistence.Id;

import javax.persistence.JoinColumn;

import javax.persistence.JoinTable;

import javax.persistence.ManyToMany;

import javax.persistence.MappedSuperclass;

import javax.persistence.OneToMany;

import com.google.common.collect.Sets;

/**

 * Datasource

 */

@MappedSuperclass

public class Datasource<ORG extends Organization<?>, ID extends Identity, PIDSYSTEM extends PidSystem> {

	@Id

	protected String id;

	@Column(nullable = false)

	protected String officialname;

	protected String englishname;

	protected String websiteurl;

	protected String logourl;

	protected String contactemail;

	protected Double latitude;

	protected Double longitude;

	protected String timezone;

	protected String status;

	@Column(name = "namespaceprefix", columnDefinition = "bpchar(12)", nullable = false, updatable = false)

	protected String namespaceprefix;

	protected String languages;

	protected String collectedfrom;

	protected Date dateofvalidation;

	@Column(name = "eosc_datasource_type")

	protected String eoscDatasourceType;

	protected String provenanceaction;

	protected Date dateofcollection;

	protected String platform;

	@Column(name = "activationid")

	protected String activationId;

	protected String description;

	protected Date releasestartdate;

	protected Date releaseenddate;

	protected String missionstatementurl;

	protected String databaseaccesstype;

	protected String datauploadtype;

	protected String databaseaccessrestriction;

	protected String datauploadrestriction;

	protected String citationguidelineurl;

	@OneToMany(mappedBy = "id.service", cascade = CascadeType.ALL, fetch = FetchType.EAGER)

	protected Set<PIDSYSTEM> pidsystems = Sets.newHashSet();

	protected String certificates;

	protected String aggregator;

	protected String issn;

	protected String eissn;

	protected String lissn;

	protected String registeredby;

	private Date registrationdate;

	protected String subjects;

	protected Boolean managed;

	@Column(name = "consenttermsofuse")

	protected Boolean consentTermsOfUse;

	@Column(name = "consenttermsofusedate")

	protected Date consentTermsOfUseDate;

	@Column(name = "lastconsenttermsofusedate")

	protected Date lastConsentTermsOfUseDate;

	@Column(name = "fulltextdownload")

	protected Boolean fullTextDownload;

	@ManyToMany(cascade = {

		CascadeType.PERSIST, CascadeType.MERGE

	}, fetch = FetchType.LAZY)

	@JoinTable(name = "dsm_service_organization", joinColumns = @JoinColumn(name = "service"), inverseJoinColumns = @JoinColumn(name = "organization"))

	protected Set<ORG> organizations;

	@ManyToMany(cascade = {

		CascadeType.PERSIST, CascadeType.MERGE

	}, fetch = FetchType.LAZY)

	@JoinTable(name = "dsm_servicepids", joinColumns = @JoinColumn(name = "service"), inverseJoinColumns = @JoinColumn(name = "pid"))

	protected Set<ID> identities;

	public Datasource() {}

	public String getId() {

		return id;

	}

	public String getOfficialname() {

		return officialname;

	}

	public String getEnglishname() {

		return englishname;

	}

	public String getWebsiteurl() {

		return websiteurl;

	}

	public String getLogourl() {

		return logourl;

	}

	public String getContactemail() {

		return contactemail;

	}

	public Double getLatitude() {

		return latitude;

	}

	public Double getLongitude() {

		return longitude;

	}

	public String getTimezone() {

		return timezone;

	}

	public String getNamespaceprefix() {

		return namespaceprefix;

	}

	public String getLanguages() {

		return languages;

	}

	public String getCollectedfrom() {

		return collectedfrom;

	}

	public Date getDateofvalidation() {

		return dateofvalidation;

	}

	public String getProvenanceaction() {

		return provenanceaction;

	}

	public Date getDateofcollection() {

		return dateofcollection;

	}

	public String getPlatform() {

		return platform;

	}

	public String getActivationId() {

		return activationId;

	}

	public String getDescription() {

		return description;

	}

	public Date getReleasestartdate() {

		return releasestartdate;

	}

	public Date getReleaseenddate() {

		return releaseenddate;

	}

	public String getMissionstatementurl() {

		return missionstatementurl;

	}

	public String getDatabaseaccesstype() {

		return databaseaccesstype;

	}

	public String getDatauploadtype() {

		return datauploadtype;

	}

	public String getDatabaseaccessrestriction() {

		return databaseaccessrestriction;

	}

	public String getDatauploadrestriction() {

		return datauploadrestriction;

	}

	public String getCitationguidelineurl() {

		return citationguidelineurl;

	}

	public Set<PIDSYSTEM> getPidsystems() {

		return pidsystems;

	}

	public String getCertificates() {

		return certificates;

	}

	public String getAggregator() {

		return aggregator;

	}

	public String getIssn() {

		return issn;

	}

	public String getEissn() {

		return eissn;

	}

	public String getLissn() {

		return lissn;

	}

	public String getRegisteredby() {

		return registeredby;

	}

	public Date getRegistrationdate() {

		return registrationdate;

	}

	public String getSubjects() {

		return subjects;

	}

	public Boolean getManaged() {

		return managed;

	}

	public Boolean getConsentTermsOfUse() {

		return consentTermsOfUse;

	}

	public Date getConsentTermsOfUseDate() {

		return consentTermsOfUseDate;

	}

	public Boolean getFullTextDownload() {

		return fullTextDownload;

	}

	public Set<ORG> getOrganizations() {

		return organizations;

	}

	public Set<ID> getIdentities() {

		return identities;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setId(final String id) {

		this.id = id;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setOfficialname(final String officialname) {

		this.officialname = officialname;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setEnglishname(final String englishname) {

		this.englishname = englishname;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setWebsiteurl(final String websiteurl) {

		this.websiteurl = websiteurl;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setLogourl(final String logourl) {

		this.logourl = logourl;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setContactemail(final String contactemail) {

		this.contactemail = contactemail;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setLatitude(final Double latitude) {

		this.latitude = latitude;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setLongitude(final Double longitude) {

		this.longitude = longitude;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setTimezone(final String timezone) {

		this.timezone = timezone;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setNamespaceprefix(final String namespaceprefix) {

		this.namespaceprefix = namespaceprefix;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setLanguages(final String languages) {

		this.languages = languages;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setCollectedfrom(final String collectedfrom) {

		this.collectedfrom = collectedfrom;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setDateofvalidation(final Date dateofvalidation) {

		this.dateofvalidation = dateofvalidation;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setProvenanceaction(final String provenanceaction) {

		this.provenanceaction = provenanceaction;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setDateofcollection(final Date dateofcollection) {

		this.dateofcollection = dateofcollection;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setPlatform(final String platform) {

		this.platform = platform;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setActivationId(final String activationId) {

		this.activationId = activationId;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setDescription(final String description) {

		this.description = description;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setReleasestartdate(final Date releasestartdate) {

		this.releasestartdate = releasestartdate;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setReleaseenddate(final Date releaseenddate) {

		this.releaseenddate = releaseenddate;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setMissionstatementurl(final String missionstatementurl) {

		this.missionstatementurl = missionstatementurl;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setDatabaseaccesstype(final String databaseaccesstype) {

		this.databaseaccesstype = databaseaccesstype;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setDatauploadtype(final String datauploadtype) {

		this.datauploadtype = datauploadtype;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setDatabaseaccessrestriction(final String databaseaccessrestriction) {

		this.databaseaccessrestriction = databaseaccessrestriction;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setDatauploadrestriction(final String datauploadrestriction) {

		this.datauploadrestriction = datauploadrestriction;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setCitationguidelineurl(final String citationguidelineurl) {

		this.citationguidelineurl = citationguidelineurl;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setPidsystems(final Set<PIDSYSTEM> pidsystems) {

		this.pidsystems = pidsystems;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setCertificates(final String certificates) {

		this.certificates = certificates;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setAggregator(final String aggregator) {

		this.aggregator = aggregator;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setIssn(final String issn) {

		this.issn = issn;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setEissn(final String eissn) {

		this.eissn = eissn;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setLissn(final String lissn) {

		this.lissn = lissn;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setRegisteredby(final String registeredby) {

		this.registeredby = registeredby;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setRegistrationdate(final Date registrationdate) {

		this.registrationdate = registrationdate;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setSubjects(final String subjects) {

		this.subjects = subjects;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setManaged(final Boolean managed) {

		this.managed = managed;

		return this;

	}

	public void setConsentTermsOfUse(final Boolean consentTermsOfUse) {

		this.consentTermsOfUse = consentTermsOfUse;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setConsentTermsOfUseDate(final Date consentTermsOfUseDate) {

		this.consentTermsOfUseDate = consentTermsOfUseDate;

		return this;

	}

	public void setFullTextDownload(final Boolean fullTextDownload) {

		this.fullTextDownload = fullTextDownload;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setOrganizations(final Set<ORG> organizations) {

		this.organizations = organizations;

		return this;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setIdentities(final Set<ID> identities) {

		this.identities = identities;

		return this;

	}

	public String getEoscDatasourceType() {

		return eoscDatasourceType;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setEoscDatasourceType(final String eoscDatasourceType) {

		this.eoscDatasourceType = eoscDatasourceType;

		return this;

	}

	public String getStatus() {

		return status;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setStatus(final String status) {

		this.status = status;

		return this;

	}

	public Date getLastConsentTermsOfUseDate() {

		return lastConsentTermsOfUseDate;

	}

	public Datasource<ORG, ID, PIDSYSTEM> setLastConsentTermsOfUseDate(final Date lastConsentTermsOfUseDate) {

		this.lastConsentTermsOfUseDate = lastConsentTermsOfUseDate;

		return this;

	}

}

package eu.dnetlib.enabling.datasources.common;

import java.sql.Timestamp;

import java.util.Objects;

import java.util.Set;

import javax.persistence.CascadeType;

import javax.persistence.Column;

import javax.persistence.FetchType;

import javax.persistence.Id;

import javax.persistence.MappedSuperclass;

import javax.persistence.OneToMany;

import javax.persistence.Transient;

import com.google.common.collect.ComparisonChain;

import com.google.common.collect.Sets;

import com.google.gson.Gson;

/**

 * Api

 */

@MappedSuperclass

public class Api<AP extends ApiParam> implements Comparable<Api<AP>> {

	@Id

	protected String id = null;

	protected String protocol = null;

	@Column(name = "service")

	protected String datasource = null;

	protected String contentdescription = null;

	protected Boolean active = false;

	protected Boolean removable = true;

	protected String compatibility;

	@Transient

	protected boolean compatibilityOverrided = false;

	@Column(name = "metadata_identifier_path")

	protected String metadataIdentifierPath;

	@Column(name = "last_collection_total")

	protected Integer lastCollectionTotal;

	@Column(name = "last_collection_date")

	protected Timestamp lastCollectionDate;

	@Column(name = "last_collection_mdid")

	protected String lastCollectionMdid;

	@Column(name = "last_aggregation_total")

	protected Integer lastAggregationTotal;

	@Column(name = "last_aggregation_date")

	protected Timestamp lastAggregationDate;

	@Column(name = "last_aggregation_mdid")

	protected String lastAggregationMdid;

	@Column(name = "last_download_total")

	protected Integer lastDownloadTotal;

	@Column(name = "last_download_date")

	protected Timestamp lastDownloadDate;

	@Column(name = "last_download_objid")

	protected String lastDownloadObjid;

	@Column(name = "last_validation_job")

	protected String lastValidationJob;

	protected String baseurl = null;

	@OneToMany(mappedBy = "id.api", cascade = CascadeType.ALL, fetch = FetchType.EAGER)

	protected Set<AP> apiParams = Sets.newHashSet();

	public Api() {}

	public String getId() {

		return id;

	}

	public String getProtocol() {

		return protocol;

	}

	public String getDatasource() {

		return datasource;

	}

	public String getContentdescription() {

		return contentdescription;

	}

	public Boolean getActive() {

		return active;

	}

	public Boolean getRemovable() {

		return removable;

	}

	public String getCompatibility() {

		return compatibility;

	}

	public boolean isCompatibilityOverrided() {

		return compatibilityOverrided;

	}

	public String getMetadataIdentifierPath() {

		return metadataIdentifierPath;

	}

	public Integer getLastCollectionTotal() {

		return lastCollectionTotal;

	}

	public Timestamp getLastCollectionDate() {

		return lastCollectionDate;

	}

	public String getLastCollectionMdid() {

		return lastCollectionMdid;

	}

	public Integer getLastAggregationTotal() {

		return lastAggregationTotal;

	}

	public Timestamp getLastAggregationDate() {

		return lastAggregationDate;

	}

	public String getLastAggregationMdid() {

		return lastAggregationMdid;

	}

	public Integer getLastDownloadTotal() {

		return lastDownloadTotal;

	}

	public Timestamp getLastDownloadDate() {

		return lastDownloadDate;

	}

	public String getLastDownloadObjid() {

		return lastDownloadObjid;

	}

	public String getLastValidationJob() {

		return lastValidationJob;

	}

	public String getBaseurl() {

		return baseurl;

	}

	public Set<AP> getApiParams() {

		return apiParams;

	}

	public Api<AP> setId(final String id) {

		this.id = id;

		return this;

	}

	public Api<AP> setProtocol(final String protocol) {

		this.protocol = protocol;

		return this;

	}

	public Api<AP> setDatasource(final String datasource) {

		this.datasource = datasource;

		return this;

	}

	public Api<AP> setContentdescription(final String contentdescription) {

		this.contentdescription = contentdescription;

		return this;

	}

	public Api<AP> setActive(final Boolean active) {

		this.active = active;

		return this;

	}

	public Api<AP> setRemovable(final Boolean removable) {

		this.removable = removable;

		return this;

	}

	public Api<AP> setCompatibility(final String compatibility) {

		this.compatibility = compatibility;

		return this;

	}

	public Api<AP> setCompatibilityOverrided(final boolean compatibilityOverrided) {

		this.compatibilityOverrided = compatibilityOverrided;

		return this;

	}

	public Api<AP> setMetadataIdentifierPath(final String metadataIdentifierPath) {

		this.metadataIdentifierPath = metadataIdentifierPath;

		return this;

	}

	public Api<AP> setLastCollectionTotal(final Integer lastCollectionTotal) {

		this.lastCollectionTotal = lastCollectionTotal;

		return this;

	}

	public Api<AP> setLastCollectionDate(final Timestamp lastCollectionDate) {

		this.lastCollectionDate = lastCollectionDate;

		return this;

	}

	public Api<AP> setLastCollectionMdid(final String lastCollectionMdid) {

		this.lastCollectionMdid = lastCollectionMdid;

		return this;

	}

	public Api<AP> setLastAggregationTotal(final Integer lastAggregationTotal) {

		this.lastAggregationTotal = lastAggregationTotal;

		return this;

	}

	public Api<AP> setLastAggregationDate(final Timestamp lastAggregationDate) {

		this.lastAggregationDate = lastAggregationDate;

		return this;

	}

	public Api<AP> setLastAggregationMdid(final String lastAggregationMdid) {

		this.lastAggregationMdid = lastAggregationMdid;

		return this;

	}

	public Api<AP> setLastDownloadTotal(final Integer lastDownloadTotal) {

		this.lastDownloadTotal = lastDownloadTotal;

		return this;

	}

	public Api<AP> setLastDownloadDate(final Timestamp lastDownloadDate) {

		this.lastDownloadDate = lastDownloadDate;

		return this;

	}

	public Api<AP> setLastDownloadObjid(final String lastDownloadObjid) {

		this.lastDownloadObjid = lastDownloadObjid;

		return this;

	}

	public Api<AP> setLastValidationJob(final String lastValidationJob) {

		this.lastValidationJob = lastValidationJob;

		return this;

	}

	public Api<AP> setBaseurl(final String baseurl) {

		this.baseurl = baseurl;

		return this;

	}

	public Api<AP> setApiParams(final Set<AP> apiParams) {

		this.apiParams = apiParams;

		return this;

	}

	@Override

	public boolean equals(final Object o) {

		if (this == o) { return true; }

		if (o == null || getClass() != o.getClass()) { return false; }

		final Api<?> api = (Api<?>) o;

		return Objects.equals(this.id, api.id);

	}

	/*

	 * (non-Javadoc)

	 *

	 * @see eu.dnetlib.openaire.exporter.model.datasource.db.ApiInterface#hashCode()

	 */

	@Override

	public int hashCode() {

		return Objects.hash(id);

	}

	@Override

	public String toString() {

		return new Gson().toJson(this);

	}

	@Override

	public int compareTo(final Api<AP> a) {

		return ComparisonChain.start()

			.compare(getId(), a.getId())

			.result();

	}

}

package eu.dnetlib.enabling.datasources.common;

import java.util.List;

public interface DatasourceManagerCommon<DS extends Datasource<?, ?, ?>, API extends Api<?>> {

	DS getDs(String id) throws DsmException;

	DS getDsByNsPrefix(String prefix) throws DsmException;

	List<? extends API> getApis(String dsId) throws DsmException;

	void deleteDs(String dsId) throws DsmException;

	void deleteApi(String dsId, String apiId) throws DsmForbiddenException, DsmNotFoundException;

	void addApi(API api) throws DsmException;

	void setManaged(String id, boolean managed) throws DsmException;

	boolean isManaged(String id) throws DsmException;

	void saveDs(DS datasource) throws DsmException;

	void updateCompliance(String dsId, String apiId, String compliance, boolean override) throws DsmException;

}

package eu.dnetlib.enabling.datasources.common;

import java.util.Date;

import java.util.List;

import java.util.Map;

import java.util.Set;

public interface LocalDatasourceManager<DS extends Datasource<?, ?, ?>, API extends Api<?>> extends DatasourceManagerCommon<DS, API> {

	Set<String> listManagedDatasourceIds() throws DsmRuntimeException;

	List<SimpleDatasource> searchDatasourcesByType(String type) throws DsmException;

	List<? extends SearchApisEntry> searchApis(String field, Object value) throws DsmException;

	List<? extends BrowsableField> listBrowsableFields() throws DsmException;

	List<? extends BrowseTerm> browseField(String field) throws DsmException;

	void setActive(String dsId, String apiId, boolean active) throws DsmException;

	boolean isActive(String dsId, String apiId) throws DsmException;

	void setLastCollectionInfo(String dsId, String apiId, String mdId, Integer size, Date date) throws DsmException;

	void setLastAggregationInfo(String dsId, String apiId, String mdId, Integer size, Date date) throws DsmException;

	void setLastDownloadInfo(String dsId, String apiId, String objId, Integer size, Date date) throws DsmException;

	void setLastValidationJob(String dsId, String apiId, String jobId) throws DsmException;

	void updateApiDetails(String dsId, String apiId, String metadataIdentifierPath, String baseUrl, Map<String, String> params) throws DsmException;

	boolean isRemovable(String dsId, String apiId) throws DsmException;

	void regenerateProfiles() throws DsmException;

}

package eu.dnetlib.enabling.datasources.common;

import java.sql.Date;

import java.util.Set;

import javax.persistence.CascadeType;

import javax.persistence.FetchType;

import javax.persistence.Id;

import javax.persistence.ManyToMany;

import javax.persistence.MappedSuperclass;

@MappedSuperclass

public class Organization<DS extends Datasource<?, ?, ?>> {

	@Id

	protected String id;

	protected String legalshortname;

	protected String legalname;

	protected String websiteurl;

	protected String logourl;

	protected String country;

	protected String collectedfrom;

	protected Date dateofcollection;

	protected String provenanceaction;

	@ManyToMany(cascade = {

		CascadeType.PERSIST, CascadeType.MERGE

	}, fetch = FetchType.EAGER, mappedBy = "organizations")

	protected Set<DS> datasources;

	public Organization() {}

	public String getId() {

		return id;

	}

	public String getLegalshortname() {

		return legalshortname;

	}

	public String getLegalname() {

		return legalname;

	}

	public String getWebsiteurl() {

		return websiteurl;

	}

	public String getLogourl() {

		return logourl;

	}

	public String getCountry() {

		return country;

	}

	public String getCollectedfrom() {

		return collectedfrom;

	}

	public Date getDateofcollection() {

		return dateofcollection;

	}

	public String getProvenanceaction() {

		return provenanceaction;

	}

	public Organization<DS> setId(final String id) {

		this.id = id;

		return this;

	}

	public Organization<DS> setLegalshortname(final String legalshortname) {

		this.legalshortname = legalshortname;

		return this;

	}

	public Organization<DS> setLegalname(final String legalname) {

		this.legalname = legalname;

		return this;

	}

	public Organization<DS> setWebsiteurl(final String websiteurl) {

		this.websiteurl = websiteurl;

		return this;

	}

	public Organization<DS> setLogourl(final String logourl) {

		this.logourl = logourl;

		return this;

	}

	public Organization<DS> setCountry(final String country) {

		this.country = country;

		return this;

	}

	public Organization<DS> setCollectedfrom(final String collectedfrom) {

		this.collectedfrom = collectedfrom;

		return this;

	}

	public Organization<DS> setDateofcollection(final Date dateofcollection) {

		this.dateofcollection = dateofcollection;

		return this;

	}

	public Organization<DS> setProvenanceaction(final String provenanceaction) {

		this.provenanceaction = provenanceaction;

		return this;

	}

	public Set<DS> getDatasources() {

		return datasources;

	}

	public void setDatasources(final Set<DS> datasources) {

		this.datasources = datasources;

	}

}

package eu.dnetlib.enabling.datasources.common;

public interface PidSystem {

	String getType();

	void setType(String type);

	String getScheme();

	void setScheme(String scheme);

}

package eu.dnetlib.enabling.datasources.common;

import java.util.HashSet;

import java.util.Set;

public class SimpleDatasource implements Comparable<SimpleDatasource> {

	private String id;

	private String name;

	private String eoscDatasourceType;

	private String origId;

	private Set<String> apis = new HashSet<>();

	private boolean valid;

	public String getId() {

		return id;

	}

	public void setId(final String id) {

		this.id = id;

	}

	public String getName() {

		return name;

	}

	public void setName(final String name) {

		this.name = name;

	}

	public boolean isValid() {

		return valid;

	}

	public void setValid(final boolean valid) {

		this.valid = valid;

	}

	public String getEoscDatasourceType() {

		return eoscDatasourceType;

	}

	public void setEoscDatasourceType(final String eoscDatasourceType) {

		this.eoscDatasourceType = eoscDatasourceType;

	}

	public String getOrigId() {

		return origId;

	}

	public void setOrigId(final String origId) {

		this.origId = origId;

	}

	public Set<String> getApis() {

		return apis;

	}

	public void setApis(final Set<String> apis) {

		this.apis = apis;

	}

	@Override

	public int compareTo(final SimpleDatasource e) {

		return getName().compareTo(e.getName());

	}

}

package eu.dnetlib.enabling.datasources.common;

public class DsmNotFoundException extends DsmException {

	public DsmNotFoundException(int code, String msg) {

		super(code, msg);

	}

	public DsmNotFoundException(int code, Throwable e) {

		super(code, e);

	}

	public DsmNotFoundException(int code, String msg, Throwable e) {

		super(code, msg, e);

	}

	public DsmNotFoundException(String msg) {

		this(404, msg);

	}

}

package eu.dnetlib.enabling.datasources.common;

public class DsmForbiddenException extends DsmException {

	public DsmForbiddenException(int code, String msg) {

		super(code, msg);

	}

	public DsmForbiddenException(int code, Throwable e) {

		super(code, e);

	}

	public DsmForbiddenException(int code, String msg, Throwable e) {

		super(code, msg, e);

	}

	public DsmForbiddenException(String msg) {

		this(403, msg);

	}

}

package eu.dnetlib.enabling.datasources.common;

/**

 * Created by claudio on 12/09/16.

 */

public enum AggregationStage {

	COLLECT, TRANSFORM;

	public static AggregationStage parse(final String s) {

		switch (s) {

			case "collect":

			case "collection":

			case "COLLECT":

			case "COLLECTION":

				return AggregationStage.COLLECT;

			case "transform":

			case "transformation":

			case "TRANSFORM":

			case "TRANSFORMATION":

			case "transformDatasets":

			case "transformPublications":

				return AggregationStage.TRANSFORM;

		}

		throw new IllegalArgumentException("invalid AggregationStage: " + s);

	}

}

package eu.dnetlib.enabling.datasources.common;

public class DsmException extends Exception {

	/**

	 * 

	 */

	private static final long serialVersionUID = 8980196353591772127L;

	private int code;

	public DsmException(int code, String msg) {

		super(msg);

		this.code = code;

	}

	public DsmException(int code, Throwable e) {

		super(e);

		this.code = code;

	}

	public DsmException(int code, String msg, Throwable e) {

		super(msg, e);

		this.code = code;

	}

	public DsmException(String msg) {

		this(500, msg);

	}

	public int getCode() {

		return code;

	}

	public void setCode(final int code) {

		this.code = code;

	}

}

package eu.dnetlib.enabling.datasources.common;

public class DsmRuntimeException extends RuntimeException {

	/**

	 *

	 */

	private static final long serialVersionUID = 8980196353591772127L;

	public DsmRuntimeException(String msg) {

		super(msg);

	}

	public DsmRuntimeException(String msg, Throwable e) {

		super(msg, e);

	}

	public DsmRuntimeException(Throwable e) {

		super(e);

	}

}

package eu.dnetlib.enabling.datasources.common;

public class ApiParamImpl implements ApiParam {

	private String param;

	private String value;

	@Override

	public String getParam() {

		return param;

	}

	@Override

	public void setParam(final String param) {

		this.param = param;

	}

	@Override

	public String getValue() {

		return value;

	}

	@Override

	public void setValue(final String value) {

		this.value = value;

	}

}

package eu.dnetlib.enabling.datasources.common;

public interface ApiParam {

	String getValue();

	void setValue(String value);

	String getParam();

	void setParam(String param);

}

package eu.dnetlib.enabling.datasources.common;

public class BrowseTermImpl implements BrowseTerm {

	private String term;

	private long total;

	public BrowseTermImpl() {}

	public BrowseTermImpl(final String term, final int total) {

		this.term = term;

		this.total = total;

	}

	public String getTerm() {

		return term;

	}

	public void setTerm(final String term) {

		this.term = term;

	}

	public long getTotal() {

		return total;

	}

	public void setTotal(final long total) {

		this.total = total;

	}

}

package eu.dnetlib.enabling.datasources.common;

public interface BrowseTerm {

	String getTerm();

	void setTerm(String term);

	long getTotal();

	void setTotal(long total);

}

package eu.dnetlib.enabling.datasources.common;