D-Net

package eu.dnetlib.enabling.datasources.rmi;

import eu.dnetlib.common.rmi.RMIException;

public class DatasourceManagerServiceException extends RMIException {

	/**

	 * 

	 */

	private static final long serialVersionUID = -5987839351772223236L;

	public DatasourceManagerServiceException(final String string) {

		super(string);

	}

	public DatasourceManagerServiceException(final String string, final Throwable exception) {

		super(string, exception);

	}

	public DatasourceManagerServiceException(final Throwable exception) {

		super(exception);

	}

}

<?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-rmi</artifactId>

	<packaging>jar</packaging>

	<version>4.0.2-SNAPSHOT</version>

	<scm>

	  <developerConnection>scm:svn:https://svn.driver.research-infrastructures.eu/driver/dnet45/modules/dnet-datasource-manager-rmi/trunk</developerConnection>

	</scm>

	<dependencies>

		<dependency>

			<groupId>eu.dnetlib</groupId>

			<artifactId>cnr-rmi-api</artifactId>

			<version>[2.0.0,3.0.0)</version>

		</dependency>

	</dependencies>

</project>

{"type_source": "SVN", "goal": "package -U -T 4C source:jar", "url": "http://svn-public.driver.research-infrastructures.eu/driver/dnet45/modules/dnet-datasource-manager-rmi/trunk/", "deploy_repository": "dnet45-snapshots", "version": "4", "mail": "sandro.labruzzo@isti.cnr.it,michele.artini@isti.cnr.it, claudio.atzori@isti.cnr.it, alessia.bardi@isti.cnr.it", "deploy_repository_url": "http://maven.research-infrastructures.eu/nexus/content/repositories/dnet45-snapshots", "name": "dnet-datasource-manager-rmi"}

package eu.dnetlib.enabling.datasources.rmi;

import javax.xml.bind.annotation.XmlRootElement;

@XmlRootElement

public class RepositoryMapEntry {

	private String id;

	private String name;

	private float lat;

	private float lng;

	public RepositoryMapEntry() {}

	public RepositoryMapEntry(final String id, final String name, final float lat, final float lng) {

		this.id = id;

		this.name = name;

		this.lat = lat;

		this.lng = lng;

	}

	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 float getLat() {

		return lat;

	}

	public void setLat(final float lat) {

		this.lat = lat;

	}

	public float getLng() {

		return lng;

	}

	public void setLng(final float lng) {

		this.lng = lng;

	}

}

package eu.dnetlib.enabling.datasources.rmi;

import javax.xml.bind.annotation.XmlRootElement;

@XmlRootElement

public class RepositoryMapEntry {

	private String id;

	private String name;

	private float lat;

	private float lng;

	public RepositoryMapEntry() {}

	public RepositoryMapEntry(final String id, final String name, final float lat, final float lng) {

		this.id = id;

		this.name = name;

		this.lat = lat;

		this.lng = lng;

	}

	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 float getLat() {

		return lat;

	}

	public void setLat(final float lat) {

		this.lat = lat;

	}

	public float getLng() {

		return lng;

	}

	public void setLng(final float lng) {

		this.lng = lng;

	}

}

package eu.dnetlib.enabling.datasources.rmi;

import javax.xml.bind.annotation.XmlRootElement;

@XmlRootElement

public class BrowsableField {

	private String id;

	private String label;

	public BrowsableField() {}

	public BrowsableField(final String id, final String label) {

		this.id = id;

		this.label = label;

	}

	public String getId() {

		return id;

	}

	public void setId(final String id) {

		this.id = id;

	}

	public String getLabel() {

		return label;

	}

	public void setLabel(final String label) {

		this.label = label;

	}

}

package eu.dnetlib.enabling.datasources.rmi;

import java.util.HashSet;

import java.util.Set;

import javax.xml.bind.annotation.XmlRootElement;

@XmlRootElement

public class SimpleDatasourceDesc implements Comparable<SimpleDatasourceDesc> {

	private String id;

	private String name;

	private String typology;

	private String origId;

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

	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 getTypology() {

		return typology;

	}

	public void setTypology(final String typology) {

		this.typology = typology;

	}

	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 SimpleDatasourceDesc e) {

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

	}

}

package eu.dnetlib.enabling.datasources.rmi;

import javax.xml.bind.annotation.XmlRootElement;

@XmlRootElement

public class BrowsableField {

	private String id;

	private String label;

	public BrowsableField() {}

	public BrowsableField(final String id, final String label) {

		this.id = id;

		this.label = label;

	}

	public String getId() {

		return id;

	}

	public void setId(final String id) {

		this.id = id;

	}

	public String getLabel() {

		return label;

	}

	public void setLabel(final String label) {

		this.label = label;

	}

}

package eu.dnetlib.enabling.datasources.rmi;

public class DatasourceConstants {

	public static final String OVERRIDING_COMPLIANCE_FIELD = "overriding_compliance";

}

package eu.dnetlib.enabling.datasources.rmi;

import javax.xml.bind.annotation.XmlRootElement;

@XmlRootElement

public class SearchInterfacesEntry implements Comparable<SearchInterfacesEntry> {

	private String id;

	private String compliance;

	private String protocol;

	private boolean active;

	private String repoId = "unknown";

	private String repoName = "unknown";

	private String repoCountry = "-";

	private String repoPrefix = "";

	private String aggrDate = "";

	private int aggrTotal = 0;

	public SearchInterfacesEntry() {}

	public SearchInterfacesEntry(final String id, final String compliance, final String protocol, final boolean active, final String repoId,

			final String repoName, final String repoCountry,

			final String repoPrefix, final String aggrDate, final int aggrTotal) {

		this.id = id;

		this.compliance = compliance;

		this.protocol = protocol;

		this.active = active;

		this.repoId = repoId;

		this.repoName = repoName;

		this.repoCountry = repoCountry;

		this.repoPrefix = repoPrefix;

		this.aggrDate = aggrDate;

		this.aggrTotal = aggrTotal;

	}

	public String getId() {

		return id;

	}

	public void setId(final String id) {

		this.id = id;

	}

	public String getCompliance() {

		return compliance;

	}

	public void setCompliance(final String compliance) {

		this.compliance = compliance;

	}

	public boolean isActive() {

		return active;

	}

	public void setActive(final boolean active) {

		this.active = active;

	}

	public String getRepoId() {

		return repoId;

	}

	public void setRepoId(final String repoId) {

		this.repoId = repoId;

	}

	public String getRepoName() {

		return repoName;

	}

	public void setRepoName(final String repoName) {

		this.repoName = repoName;

	}

	public String getRepoCountry() {

		return repoCountry;

	}

	public void setRepoCountry(final String repoCountry) {

		this.repoCountry = repoCountry;

	}

	public String getRepoPrefix() {

		return repoPrefix;

	}

	public void setRepoPrefix(final String repoPrefix) {

		this.repoPrefix = repoPrefix;

	}

	@Override

	public int compareTo(final SearchInterfacesEntry e) {

		return compliance.compareTo(e.getCompliance());

	}

	public String getAggrDate() {

		return aggrDate;

	}

	public void setAggrDate(final String aggrDate) {

		this.aggrDate = aggrDate;

	}

	public int getAggrTotal() {

		return aggrTotal;

	}

	public void setAggrTotal(final int aggrTotal) {

		this.aggrTotal = aggrTotal;

	}

	public String getProtocol() {

		return protocol;

	}

	public void setProtocol(final String protocol) {

		this.protocol = protocol;

	}

}

package eu.dnetlib.enabling.datasources.rmi;

import java.util.Date;

import java.util.List;

import javax.jws.WebParam;

import javax.jws.WebService;

import eu.dnetlib.common.rmi.BaseService;

@WebService(targetNamespace = "http://services.dnetlib.eu/")

public interface DatasourceManagerService extends BaseService {

	/**

	 * Register a datasource.

	 * 

	 * @param ds

	 *            the new datasource

	 * @throws DatasourceManagerServiceException

	 */

	public boolean addDatasource(@WebParam(name = "ds") DatasourceDesc ds) throws DatasourceManagerServiceException;

	/**

	 * Delete a datasource.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @throws DatasourceManagerServiceException

	 */

	public boolean deleteDatasource(@WebParam(name = "dsId") String dsId) throws DatasourceManagerServiceException;

	/**

	 * Returns a datasource.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @throws DatasourceManagerServiceException

	 */

	public DatasourceDesc getDatasource(@WebParam(name = "dsId") String dsId) throws DatasourceManagerServiceException;

	/**

	 * Returns all the datasources.

	 * 

	 * @return a list of XML profiles

	 * @throws DatasourceManagerServiceException

	 */

	public List<DatasourceDesc> listAllDatasources() throws DatasourceManagerServiceException;

	/**

	 * Returns the datasources with some properties.

	 * 

	 * @param compliance

	 *            the level of compliance (or NULL to skip the test)

	 * @param fileManagementMode

	 *            the fileManagementMode property (or NULL to skip the test)

	 * @param contentDescription

	 *            the contentDescription property (or NULL to skip the test)

	 * @param iisProcessingWorkflow

	 *            the iisProcessingWorkflow property (or NULL to skip the test)

	 * @param collectedFrom

	 *            the collectedFrom property (or NULL to skip the test)

	 * @return a list of XML profiles

	 * @throws DatasourceManagerServiceException

	 */

	public List<DatasourceDesc> listDatasourcesUsingFilter(@WebParam(name = "compliance") String compliance,

			@WebParam(name = "contentDescription") String contentDescription,

			@WebParam(name = "iisProcessingWorkflow") String iisProcessingWorkflow,

			@WebParam(name = "collectedFrom") String collectedFrom) throws DatasourceManagerServiceException;

	/**

	 * updates the level of compliance of a datasource.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param ifaceId

	 *            the interface id

	 * @param level

	 *            the new level of compliance

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean updateLevelOfCompliance(@WebParam(name = "dsId") String dsId,

			@WebParam(name = "ifaceId") String ifaceId,

			@WebParam(name = "level") String level) throws DatasourceManagerServiceException;

	/**

	 * update the baseUrl of an interface.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param ifaceId

	 *            the interface id

	 * @param baseUrl

	 *            the new value

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean updateBaseUrl(@WebParam(name = "dsId") String dsId, @WebParam(name = "ifaceId") String ifaceId, @WebParam(name = "baseUrl") String baseUrl)

			throws DatasourceManagerServiceException;

	/**

	 * update the activation status of an interface (true = there is a related wf).

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param ifaceId

	 *            the interface id

	 * @param active

	 *            true if there is a related wf

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean updateActivationStatus(@WebParam(name = "dsId") String dsId,

			@WebParam(name = "ifaceId") String ifaceId,

			@WebParam(name = "active") boolean active) throws DatasourceManagerServiceException;

	/**

	 * update the "contentDescription" property of an interface.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param ifaceId

	 *            the interface id

	 * @param desc

	 *            the new value

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean updateContentDescription(@WebParam(name = "dsId") String dsId,

			@WebParam(name = "ifaceId") String ifaceId,

			@WebParam(name = "desc") String desc) throws DatasourceManagerServiceException;

	/**

	 * update the "iis_processing_workflow" property of an interface.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param ifaceId

	 *            the interface id

	 * @param wf

	 *            the new value

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean setIisProcessingWorkflow(@WebParam(name = "dsId") String dsId, @WebParam(name = "ifaceId") String ifaceId, @WebParam(name = "wf") String wf)

			throws DatasourceManagerServiceException;

	/**

	 * Set a generic extra field of an interface.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param ifaceId

	 *            the interface id

	 * @param field

	 *            the field name

	 * @param value

	 *            the new value (or null for removing it)

	 * @param preserveOriginal

	 *            preserve the original value in the DB (the value is stored in the "edited" column)

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean updateExtraField(@WebParam(name = "dsId") String dsId,

			@WebParam(name = "ifaceId") String ifaceId,

			@WebParam(name = "field") String field,

			@WebParam(name = "value") String value,

			@WebParam(name = "preserveOriginal") boolean preserveOriginal) throws DatasourceManagerServiceException;

	/**

	 * Update an access param of an interface.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param ifaceId

	 *            the interface id

	 * @param field

	 *            the field name

	 * @param value

	 *            the new value (or null for removing it)

	 * @param preserveOriginal

	 *            preserve the original value in the DB (the value is stored in the "edited" column)

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean updateAccessParam(@WebParam(name = "dsId") String dsId,

			@WebParam(name = "ifaceId") String ifaceId,

			@WebParam(name = "field") String field,

			@WebParam(name = "value") String value,

			@WebParam(name = "preserveOriginal") boolean preserveOriginal) throws DatasourceManagerServiceException;

	/**

	 * delete a generic extra field or an access param of an interface.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param ifaceId

	 *            the interface id

	 * @param field

	 *            the field name

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean deleteAccessParamOrExtraField(@WebParam(name = "dsId") String dsId,

			@WebParam(name = "ifaceId") String ifaceId,

			@WebParam(name = "field") String field) throws DatasourceManagerServiceException;

	/**

	 * Add an interface to a datasource.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param iface

	 *            the interface description

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean addInterface(@WebParam(name = "dsId") String dsId, @WebParam(name = "interface") IfaceDesc iface) throws DatasourceManagerServiceException;

	/**

	 * Delete the interface of a datasource.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param ifcId

	 *            the id of the interface

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean deleteInterface(@WebParam(name = "dsId") String dsId, @WebParam(name = "ifaceId") String ifaceId) throws DatasourceManagerServiceException;

	/**

	 * Perform a generic SQL update on a datasource.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param sql

	 *            the sql query to insert/update/delete the datasource

	 * @param delete

	 *            true if the profile must be deleted

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean updateSQL(@WebParam(name = "dsId") String dsId, @WebParam(name = "sql") String sql, @WebParam(name = "delete") boolean delete)

			throws DatasourceManagerServiceException;

	/**

	 * Calculate the next execution date of a related metaworkflow

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param ifcId

	 *            the id of the interface

	 * @return the date of the next scheduled execution (or null)

	 * @throws DatasourceManagerServiceException

	 */

	public Date findNextScheduledExecution(@WebParam(name = "dsId") String dsId, @WebParam(name = "ifaceId") String ifaceId) throws DatasourceManagerServiceException;

}

package eu.dnetlib.enabling.datasources.rmi;

import java.util.Date;

import java.util.List;

import java.util.Map;

import javax.jws.WebParam;

import javax.jws.WebService;

import eu.dnetlib.common.rmi.BaseService;

@WebService(targetNamespace = "http://services.dnetlib.eu/")

public interface DatasourceManagerService extends BaseService {

	/**

	 * Register a datasource.

	 * 

	 * @param ds

	 *            the new datasource

	 * @throws DatasourceManagerServiceException

	 */

	public boolean addDatasource(@WebParam(name = "ds") DatasourceDesc ds) throws DatasourceManagerServiceException;

	/**

	 * Delete a datasource.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @throws DatasourceManagerServiceException

	 */

	public boolean deleteDatasource(@WebParam(name = "dsId") String dsId) throws DatasourceManagerServiceException;

	/**

	 * Returns a datasource.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @throws DatasourceManagerServiceException

	 */

	public DatasourceDesc getDatasource(@WebParam(name = "dsId") String dsId) throws DatasourceManagerServiceException;

	/**

	 * Returns all the datasources.

	 * 

	 * @return a list of XML profiles

	 * @throws DatasourceManagerServiceException

	 */

	public List<DatasourceDesc> listAllDatasources() throws DatasourceManagerServiceException;

	/**

	 * Returns the datasources with some properties.

	 * 

	 * @param compliance

	 *            the level of compliance (or NULL to skip the test)

	 * @param fileManagementMode

	 *            the fileManagementMode property (or NULL to skip the test)

	 * @param contentDescription

	 *            the contentDescription property (or NULL to skip the test)

	 * @param iisProcessingWorkflow

	 *            the iisProcessingWorkflow property (or NULL to skip the test)

	 * @param collectedFrom

	 *            the collectedFrom property (or NULL to skip the test)

	 * @return a list of XML profiles

	 * @throws DatasourceManagerServiceException

	 */

	public List<DatasourceDesc> listDatasourcesUsingFilter(@WebParam(name = "compliance") String compliance,

			@WebParam(name = "contentDescription") String contentDescription,

			@WebParam(name = "iisProcessingWorkflow") String iisProcessingWorkflow,

			@WebParam(name = "collectedFrom") String collectedFrom) throws DatasourceManagerServiceException;

	/**

	 * updates the level of compliance of a api.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param ifaceId

	 *            the interface id

	 * @param level

	 *            the new level of compliance

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean updateLevelOfCompliance(@WebParam(name = "dsId") String dsId,

			@WebParam(name = "ifaceId") String ifaceId,

			@WebParam(name = "level") String level) throws DatasourceManagerServiceException;

	/**

	 * Override the level of compliance of a api.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param ifaceId

	 *            the interface id

	 * @param level

	 *            the new level of compliance

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean overrideCompliance(@WebParam(name = "dsId") String dsId,

			@WebParam(name = "ifaceId") String ifaceId,

			@WebParam(name = "level") String level) throws DatasourceManagerServiceException;

	/**

	 * update the baseUrl of an interface.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param ifaceId

	 *            the interface id

	 * @param baseUrl

	 *            the new value

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean updateBaseUrl(@WebParam(name = "dsId") String dsId, @WebParam(name = "ifaceId") String ifaceId, @WebParam(name = "baseUrl") String baseUrl)

			throws DatasourceManagerServiceException;

	/**

	 * update the activation status of an interface (true = there is a related wf).

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param ifaceId

	 *            the interface id

	 * @param active

	 *            true if there is a related wf

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean updateActivationStatus(@WebParam(name = "dsId") String dsId,

			@WebParam(name = "ifaceId") String ifaceId,

			@WebParam(name = "active") boolean active) throws DatasourceManagerServiceException;

	/**

	 * update the "contentDescription" property of an interface.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param ifaceId

	 *            the interface id

	 * @param desc

	 *            the new value

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean updateContentDescription(@WebParam(name = "dsId") String dsId,

			@WebParam(name = "ifaceId") String ifaceId,

			@WebParam(name = "desc") String desc) throws DatasourceManagerServiceException;

	/**

	 * update the "iis_processing_workflow" property of an interface.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param ifaceId

	 *            the interface id

	 * @param wf

	 *            the new value

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean setIisProcessingWorkflow(@WebParam(name = "dsId") String dsId, @WebParam(name = "ifaceId") String ifaceId, @WebParam(name = "wf") String wf)

			throws DatasourceManagerServiceException;

	/**

	 * Set a generic extra field of an interface.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param ifaceId

	 *            the interface id

	 * @param field

	 *            the field name

	 * @param value

	 *            the new value (or null for removing it)

	 * @param preserveOriginal

	 *            preserve the original value in the DB (the value is stored in the "edited" column)

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean updateExtraField(@WebParam(name = "dsId") String dsId,

			@WebParam(name = "ifaceId") String ifaceId,

			@WebParam(name = "field") String field,

			@WebParam(name = "value") String value,

			@WebParam(name = "preserveOriginal") boolean preserveOriginal) throws DatasourceManagerServiceException;

	/**

	 * Update an access param of an interface.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param ifaceId

	 *            the interface id

	 * @param field

	 *            the field name

	 * @param value

	 *            the new value (or null for removing it)

	 * @param preserveOriginal

	 *            preserve the original value in the DB (the value is stored in the "edited" column)

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean updateAccessParam(@WebParam(name = "dsId") String dsId,

			@WebParam(name = "ifaceId") String ifaceId,

			@WebParam(name = "field") String field,

			@WebParam(name = "value") String value,

			@WebParam(name = "preserveOriginal") boolean preserveOriginal) throws DatasourceManagerServiceException;

	/**

	 * delete a generic extra field or an access param of an interface.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param ifaceId

	 *            the interface id

	 * @param field

	 *            the field name

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean deleteAccessParamOrExtraField(@WebParam(name = "dsId") String dsId,

			@WebParam(name = "ifaceId") String ifaceId,

			@WebParam(name = "field") String field) throws DatasourceManagerServiceException;

	/**

	 * Add an interface to a datasource.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param iface

	 *            the interface description

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean addInterface(@WebParam(name = "dsId") String dsId, @WebParam(name = "interface") IfaceDesc iface) throws DatasourceManagerServiceException;

	/**

	 * Delete the interface of a datasource.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param ifcId

	 *            the id of the interface

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean deleteInterface(@WebParam(name = "dsId") String dsId, @WebParam(name = "ifaceId") String ifaceId) throws DatasourceManagerServiceException;

	/**

	 * Perform a generic SQL update on a datasource.

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param sql

	 *            the sql query to insert/update/delete the datasource

	 * @param delete

	 *            true if the profile must be deleted

	 * @return true if the operation ends successfully

	 * @throws DatasourceManagerServiceException

	 */

	public boolean updateSQL(@WebParam(name = "dsId") String dsId, @WebParam(name = "sql") String sql, @WebParam(name = "delete") boolean delete)

			throws DatasourceManagerServiceException;

	/**

	 * Calculate the next execution date of a related metaworkflow

	 * 

	 * @param dsId

	 *            the OpenAireDataSourceId (example: opendoar____::2101)

	 * @param ifcId

	 *            the id of the interface

	 * @return the date of the next scheduled execution (or null)

	 * @throws DatasourceManagerServiceException

	 */

	public Date findNextScheduledExecution(@WebParam(name = "dsId") String dsId, @WebParam(name = "ifaceId") String ifaceId)

			throws DatasourceManagerServiceException;

	public boolean bulkUpdateApiExtraFields(@WebParam(name = "dsId") String dsId,

			@WebParam(name = "ifaceId") String ifaceId,

			@WebParam(name = "fields") Map<String, String> fields) throws DatasourceManagerServiceException;

	public boolean bulkUpdateApiAccessParams(@WebParam(name = "dsId") String dsId,

			@WebParam(name = "ifaceId") String ifaceId,

			@WebParam(name = "params") Map<String, String> params) throws DatasourceManagerServiceException;

	public List<BrowsableField> listBrowsableFields() throws DatasourceManagerServiceException;

	public List<BrowseTerm> browseField(@WebParam(name = "field") final String field) throws DatasourceManagerServiceException;

	public List<SearchInterfacesEntry> searchInterface(@WebParam(name = "field") final String field, @WebParam(name = "value") final String value)

			throws DatasourceManagerServiceException;

	public List<RepositoryMapEntry> getRepositoryMap() throws DatasourceManagerServiceException;

	public List<SimpleDatasourceDesc> simpleListDatasourcesByType(@WebParam(name = "type") String type) throws DatasourceManagerServiceException;

}

package eu.dnetlib.enabling.datasources.rmi;

public class DatasourceConstants {

	public static final String OVERRIDING_COMPLIANCE_FIELD = "overriding_compliance";

}

package eu.dnetlib.enabling.datasources.rmi;

import javax.xml.bind.annotation.XmlRootElement;

@XmlRootElement

public class BrowseTerm implements Comparable<BrowseTerm> {

	private String id;

	private String name;

	private int value;

	public BrowseTerm() {}

	public BrowseTerm(final String id, final String name, final int value) {

		this.id = id;

		this.name = name;

		this.value = value;

	}

	public String getId() {

		return id;

	}

	public void setId(final String id) {

		this.id = id;

	}

	public int getValue() {

		return value;

	}

	public void setValue(final int value) {

		this.value = value;

	}

	public String getName() {

		return name;

	}

	public void setName(final String name) {

		this.name = name;

	}

	@Override

	public int compareTo(final BrowseTerm o) {

		return Integer.compare(value, o.getValue());

	}

}

package eu.dnetlib.enabling.datasources.rmi;

import java.util.HashMap;

import java.util.Map;

import javax.xml.bind.annotation.XmlRootElement;

@XmlRootElement

public class IfaceDesc {

	private String id;

	private String typology;

	private String compliance;

	private String contentDescription;

	private String accessProtocol;

	private String baseUrl;

	private boolean active = false;

	private boolean removable = false;

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

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

	public IfaceDesc() {}

	public String getId() {

		return id;

	}

	public void setId(final String id) {

		this.id = id;

	}

	public String getTypology() {

		return typology;

	}

	public void setTypology(final String typology) {

		this.typology = typology;

	}

	public String getCompliance() {

		return compliance;

	}

	public void setCompliance(final String compliance) {

		this.compliance = compliance;

	}

	public String getContentDescription() {

		return contentDescription;

	}

	public void setContentDescription(final String contentDescription) {

		this.contentDescription = contentDescription;

	}

	public String getAccessProtocol() {

		return accessProtocol;

	}

	public void setAccessProtocol(final String accessProtocol) {

		this.accessProtocol = accessProtocol;

	}

	public String getBaseUrl() {

		return baseUrl;

	}

	public void setBaseUrl(final String baseUrl) {

		this.baseUrl = baseUrl;

	}

	public Map<String, String> getAccessParams() {

		return accessParams;

	}

	public void setAccessParams(final Map<String, String> accessParams) {

		this.accessParams = accessParams;

	}

	public Map<String, String> getExtraFields() {

		return extraFields;

	}

	public void setExtraFields(final Map<String, String> extraFields) {

		this.extraFields = extraFields;

	}

	public boolean getActive() {

		return active;

	}

	public void setActive(final boolean active) {

		this.active = active;

	}

	public boolean getRemovable() {

		return removable;

	}

	public void setRemovable(final boolean removable) {

		this.removable = removable;

	}

}

<?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>dnet-parent</artifactId>

		<version>1.0.0</version>

		<relativePath />

	</parent>

	<modelVersion>4.0.0</modelVersion>

	<groupId>eu.dnetlib</groupId>

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

	<packaging>jar</packaging>

	<version>3.0.1</version>

	<scm>

	  <developerConnection>scm:svn:https://svn.driver.research-infrastructures.eu/driver/dnet40/modules/dnet-datasource-manager-rmi/tags/dnet-datasource-manager-rmi-3.0.1</developerConnection>

	</scm>

	<dependencies>

		<dependency>

			<groupId>eu.dnetlib</groupId>

			<artifactId>cnr-rmi-api</artifactId>

			<version>[2.0.0,3.0.0)</version>

		</dependency>

	</dependencies>

</project>

package eu.dnetlib.enabling.datasources.rmi;

import java.util.HashMap;

import java.util.Map;

import javax.xml.bind.annotation.XmlRootElement;

@XmlRootElement

public class IfaceDesc {

	private String id;

	private String typology;

	private String compliance;

	private String contentDescription;

	private String accessProtocol;

	private String baseUrl;

	private boolean active = false;

	private boolean removable = false;

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

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

	public IfaceDesc() {}

	public String getId() {

		return id;

	}

	public void setId(final String id) {

		this.id = id;

	}

	public String getTypology() {

		return typology;

	}

	public void setTypology(final String typology) {

		this.typology = typology;

	}

	public String getCompliance() {

		return compliance;

	}

	public void setCompliance(final String compliance) {

		this.compliance = compliance;

	}

	public String getContentDescription() {

		return contentDescription;

	}

	public void setContentDescription(final String contentDescription) {

		this.contentDescription = contentDescription;

	}

	public String getAccessProtocol() {

		return accessProtocol;

	}

	public void setAccessProtocol(final String accessProtocol) {

		this.accessProtocol = accessProtocol;

	}

	public String getBaseUrl() {

		return baseUrl;

	}

	public void setBaseUrl(final String baseUrl) {

		this.baseUrl = baseUrl;

	}

	public Map<String, String> getAccessParams() {

		return accessParams;

	}

	public void setAccessParams(final Map<String, String> accessParams) {

		this.accessParams = accessParams;

	}

	public Map<String, String> getExtraFields() {

		return extraFields;

	}

	public void setExtraFields(final Map<String, String> extraFields) {

		this.extraFields = extraFields;

	}

	public boolean getActive() {

		return active;

	}

	public void setActive(final boolean active) {

		this.active = active;

	}

	public boolean getRemovable() {

		return removable;

	}

	public void setRemovable(final boolean removable) {

		this.removable = removable;

	}

}

package eu.dnetlib.enabling.datasources.rmi;

import eu.dnetlib.common.rmi.RMIException;

public class DatasourceManagerServiceException extends RMIException {

	/**

	 * 

	 */

	private static final long serialVersionUID = -5987839351772223236L;

	public DatasourceManagerServiceException(final String string) {

		super(string);

	}

	public DatasourceManagerServiceException(final String string, final Throwable exception) {

		super(string, exception);

	}

	public DatasourceManagerServiceException(final Throwable exception) {

		super(exception);

	}

}

package eu.dnetlib.enabling.datasources.rmi;

import javax.xml.bind.annotation.XmlRootElement;

@XmlRootElement

public class SearchInterfacesEntry implements Comparable<SearchInterfacesEntry> {

	private String id;

	private String compliance;

	private String protocol;

	private boolean active;

	private String repoId = "unknown";

	private String repoName = "unknown";

	private String repoCountry = "-";

	private String repoPrefix = "";

	private String aggrDate = "";

	private int aggrTotal = 0;

	public SearchInterfacesEntry() {}

	public SearchInterfacesEntry(final String id, final String compliance, final String protocol, final boolean active, final String repoId,

			final String repoName, final String repoCountry,

			final String repoPrefix, final String aggrDate, final int aggrTotal) {

		this.id = id;

		this.compliance = compliance;

		this.protocol = protocol;

		this.active = active;

		this.repoId = repoId;

		this.repoName = repoName;

		this.repoCountry = repoCountry;

		this.repoPrefix = repoPrefix;

		this.aggrDate = aggrDate;

		this.aggrTotal = aggrTotal;

	}

	public String getId() {

		return id;

	}

	public void setId(final String id) {

		this.id = id;

	}

	public String getCompliance() {

		return compliance;

	}

	public void setCompliance(final String compliance) {

		this.compliance = compliance;

	}

	public boolean isActive() {

		return active;

	}

	public void setActive(final boolean active) {

		this.active = active;

	}

	public String getRepoId() {

		return repoId;

	}

	public void setRepoId(final String repoId) {

		this.repoId = repoId;

	}

	public String getRepoName() {

		return repoName;

	}

	public void setRepoName(final String repoName) {

		this.repoName = repoName;

	}

	public String getRepoCountry() {

		return repoCountry;

	}

	public void setRepoCountry(final String repoCountry) {

		this.repoCountry = repoCountry;

	}

	public String getRepoPrefix() {

		return repoPrefix;

	}

	public void setRepoPrefix(final String repoPrefix) {

		this.repoPrefix = repoPrefix;

	}

	@Override

	public int compareTo(final SearchInterfacesEntry e) {

		return compliance.compareTo(e.getCompliance());

	}

	public String getAggrDate() {

		return aggrDate;

	}

	public void setAggrDate(final String aggrDate) {

		this.aggrDate = aggrDate;

	}

	public int getAggrTotal() {

		return aggrTotal;

	}

	public void setAggrTotal(final int aggrTotal) {

		this.aggrTotal = aggrTotal;

	}

	public String getProtocol() {

		return protocol;

	}