D-Net

{"type_source": "SVN", "goal": "package -U -T 4C source:jar", "url": "http://svn-public.driver.research-infrastructures.eu/driver/dnet45/modules/dnet-actionmanager-api/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-actionmanager-api"}

package eu.dnetlib.actionmanager.rmi;

import eu.dnetlib.common.rmi.RMIException;

public class ActionManagerException extends RMIException {

	/**

	 * 

	 */

	private static final long serialVersionUID = 9156582199919910574L;

	public ActionManagerException(String s) {

		super(s);

	}

	public ActionManagerException(String s, Throwable exception) {

		super(s, exception);

	}

	public ActionManagerException(Throwable exception) {

		super(exception);

	}

}

package eu.dnetlib.actionmanager.rmi;

import java.util.List;

import javax.jws.WebParam;

import javax.jws.WebService;

import eu.dnetlib.actionmanager.common.Agent;

import eu.dnetlib.actionmanager.common.Operation;

import eu.dnetlib.actionmanager.common.Provenance;

import eu.dnetlib.actionmanager.set.ActionManagerSet;

import eu.dnetlib.common.rmi.BaseService;

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

public interface ActionManagerService extends BaseService {

	String createSet(@WebParam(name = "set") ActionManagerSet set) throws ActionManagerException;

	boolean deleteSet(@WebParam(name = "setId") String setId) throws ActionManagerException;

	List<ActionManagerSet> ListSets() throws ActionManagerException;

}

package eu.dnetlib.actionmanager.common;

public enum Operation {

	INSERT, UPDATE

}

package eu.dnetlib.actionmanager.common;

public enum Provenance {

	sysimport_crosswalk_repository, 

	sysimport_crosswalk_aggregator, 

	sysimport_crosswalk_entityregistry, 

	sysimport_crosswalk_datasetarchive, 

	sysimport_crosswalk_cris, 

	sysimport_mining_repository, 

	sysimport_mining_aggregator, 

	sysimport_mining_entityregistry, 

	sysimport_mining_datasetarchive, 

	sysimport_mining_cris, 

	user_claim_pid,               

	user_claim_search,                       

	user_insert;

	/**

	 * Use this instead of original valueOf if term contain ":".

	 * 

	 * @param s

	 * @return

	 */

	public static Provenance convert(String s) {

		return Provenance.valueOf(s.replaceAll(":", "_"));

	}

	@Override

	public String toString() {

		return super.toString().replaceAll("_", ":");

	}

}

package eu.dnetlib.actionmanager.common;

import java.io.Serializable;

import javax.xml.bind.annotation.XmlRootElement;

@XmlRootElement

public class Agent implements Serializable {

	/**

	 * 

	 */

	private static final long serialVersionUID = 1307812329829682737L;

	public enum AGENT_TYPE {

		human, service, algo

	}

	private String id;

	private String name;

	private AGENT_TYPE type;

	public Agent() {

		super();

	}

	public Agent(String id, String name, AGENT_TYPE type) {

		super();

		this.id = id;

		this.name = name;

		this.type = type;

	}

	public String getId() {

		return id;

	}

	public void setId(String id) {

		this.id = id;

	}

	public String getName() {

		return name;

	}

	public void setName(String name) {

		this.name = name;

	}

	public AGENT_TYPE getType() {

		return type;

	}

	public void setType(AGENT_TYPE type) {

		this.type = type;

	}

}

package eu.dnetlib.actionmanager.set;

import java.io.Serializable;

import java.text.ParseException;

import java.util.*;

import javax.xml.bind.annotation.XmlRootElement;

import org.apache.commons.lang3.time.DateUtils;

@XmlRootElement

public class ActionManagerSet implements Serializable {

	/**

	 * 

	 */

	private static final long serialVersionUID = 7262893241919858735L;

	public static final String[] DATE_PATTERNS = new String[]{"yyyy-MM-dd\'T\'hh:mm:ss+00:00", "yyyy-MM-dd\'T\'hh:mm:ssXXX"};

	public enum ImpactTypes {

		ONLY_INSERT, INSERT_UPDATE

	}

	private String id;

	private String name;

	private ImpactTypes impact = ImpactTypes.INSERT_UPDATE;

	private String directory;

	private String pathToLatest;

	private RawSet latest;

	private TreeSet<RawSet> expired;

	public ActionManagerSet() {

		this.expired = new TreeSet<RawSet>(getRawSetComparator());

	}

	public ActionManagerSet(final String id, final String name, final String directory) {

		this(id, name, directory, ImpactTypes.INSERT_UPDATE, null);

	}

	public ActionManagerSet(final String id, final String name, final String directory, final ImpactTypes impact, final RawSet latest) {

		this(id, name, directory, impact, null, latest);

	}

	public ActionManagerSet(final String id, final String name, final String directory, final ImpactTypes impact, final String pathToLatest, final RawSet latest) {

		super();

		this.id = id;

		this.name = name;

		this.directory = directory;

		this.impact = impact;

		this.pathToLatest = pathToLatest;

		this.latest = latest;

		this.expired = new TreeSet<RawSet>(getRawSetComparator());

	}

	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 ImpactTypes getImpact() {

		return impact;

	}

	public void setImpact(final ImpactTypes impact) {

		this.impact = impact;

	}

	public String getPathToLatest() {

		return pathToLatest;

	}

	public void setPathToLatest(final String pathToLatest) {

		this.pathToLatest = pathToLatest;

	}

	@Override

	public String toString() {

		return "[ id: " + id + ", name: " + name + ", impact: " + impact + " ]";

	}

	public RawSet getLatest() {

		return latest;

	}

	public void setLatest(final RawSet latest) {

		this.latest = latest;

	}

	public void setLatest(final String rawSetId, final String creationDate, final String lastUpdate) {

		setLatest(new RawSet(rawSetId.trim(), creationDate.trim(), lastUpdate.trim()));

	}

	private Comparator<RawSet> getRawSetComparator() {

		return (o1, o2) -> {

			try {

				final Date d1 = DateUtils.parseDate(o1.getLastUpdate(), DATE_PATTERNS);

				final Date d2 = DateUtils.parseDate(o2.getLastUpdate(), DATE_PATTERNS);

				return d1.compareTo(d2);

			} catch (ParseException e) {

				throw new RuntimeException(

						String.format("unable to parse dates: %s, %s. Known patterns: %s", o1.getLastUpdate(), o2.getLastUpdate(), Arrays.asList(DATE_PATTERNS)));

			}

		};

	}

	public Set<RawSet> getExpired() {

		return expired;

	}

	public void addExpired(final String rawSetId, final String creationDate, final String lastUpdate) {

		addExpired(new RawSet(rawSetId.trim(), creationDate.trim(), lastUpdate.trim()));

	}

	public void addExpired(final RawSet rawSet) {

		getExpired().add(rawSet);

	}

	public String getDirectory() {

		return directory;

	}

	public void setDirectory(final String directory) {

		this.directory = directory;

	}

}

package eu.dnetlib.actionmanager.set;

import java.util.UUID;

import javax.xml.bind.annotation.XmlRootElement;

import eu.dnetlib.miscutils.datetime.DateUtils;

@XmlRootElement

public class RawSet {

	public static final String RAWSET_PREFIX = "rawset";

	private String id = null;

	private String creationDate = null;

	private String lastUpdate = null;

	public RawSet() {

	}

	protected RawSet(final String id, final String creationDate, final String lastUpdate) {

		super();

		this.id = id;

		this.creationDate = creationDate;

		this.lastUpdate = lastUpdate;

	}

	public String getId() {

		return id;

	}

	public void setId(final String id) {

		this.id = id;

	}

	public String getCreationDate() {

		return creationDate;

	}

	public void setCreationDate(final String creationDate) {

		this.creationDate = creationDate;

	}

	public String getLastUpdate() {

		return lastUpdate;

	}

	public void setLastUpdate(final String lastUpdate) {

		this.lastUpdate = lastUpdate;

	}

	public static RawSet newInstance() {

		long now = DateUtils.now();

		return new RawSet(RAWSET_PREFIX + "_" + UUID.randomUUID() + "_" + now, DateUtils.calculate_ISO8601(now), null);

	}

	public static RawSet newInstance(final String id, final String creationDate, final String lastUpdate) {

		return new RawSet(id, creationDate, lastUpdate);

	}

}

<?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-actionmanager-api</artifactId>

	<packaging>jar</packaging>

	<version>4.0.3</version>

	<scm>

	  <developerConnection>scm:svn:https://svn.driver.research-infrastructures.eu/driver/dnet45/modules/dnet-actionmanager-api/tags/dnet-actionmanager-api-4.0.3</developerConnection>

	</scm>

	<dependencies>

		<dependency>

			<groupId>eu.dnetlib</groupId>

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

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

		</dependency>

		<dependency>

			<groupId>eu.dnetlib</groupId>

			<artifactId>cnr-misc-utils</artifactId>

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

		</dependency>

	</dependencies>

</project>