/ - Diff - D-Net - D-Net project tracking tool

modules/dnet-modular-objectstore-service/tags/dnet-modular-objectstore-service-4.0.3-TAG/deploy.info

1

{"type_source": "SVN", "goal": "package -U -T 4C source:jar", "url": "http://svn-public.driver.research-infrastructures.eu/driver/dnet40/modules/dnet-modular-objectstore-service/trunk/", "deploy_repository": "dnet4-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/dnet4-snapshots", "name": "dnet-modular-objectstore-service"}

     package eu.dnetlib.data.objectstore.modular;
     import org.springframework.beans.factory.annotation.Required;
     import eu.dnetlib.enabling.tools.blackboard.BlackboardJob;
     import eu.dnetlib.enabling.tools.blackboard.BlackboardServerAction;
     import eu.dnetlib.enabling.tools.blackboard.BlackboardServerHandler;
     // TODO: Auto-generated Javadoc
     /**
      * The Class FeedCompleteObjectAction is responsible to execute the blacboard action of type FEED OBJECT which is Metadata created for WOS case of openaire.
      */
     public class FeedCompleteObjectAction extends AbstractObjectStoreAction implements BlackboardServerAction<ObjectStoreActions> {
     	/** The store feeder. */
     	private ModularObjectStoreFeeder storeFeeder;
     	/* (non-Javadoc)
     	 * @see eu.dnetlib.enabling.tools.blackboard.BlackboardServerAction#execute(eu.dnetlib.enabling.tools.blackboard.BlackboardServerHandler, eu.dnetlib.enabling.tools.blackboard.BlackboardJob)
     	 */
     	@Override
     	public void execute(final BlackboardServerHandler handler, final BlackboardJob job) throws Exception {
     		final String objStoreID = job.getParameters().get("obsID");
     		final String eprRs = job.getParameters().get("epr");
     		final String mime = job.getParameters().get("mime");
     		storeFeeder.feedMetadataObjectRecord(objStoreID, eprRs, mime);
     		handler.done(job);
+    	}
     	/**
     	 * Gets the store feeder.
+    	 *
     	 * @return the store feeder
     	 */
     	public ModularObjectStoreFeeder getStoreFeeder() {
     		return storeFeeder;
+    	}
     	/**
     	 * Sets the store feeder.
+    	 *
     	 * @param storeFeeder the new store feeder
     	 */
     	@Required
     	public void setStoreFeeder(final ModularObjectStoreFeeder storeFeeder) {
     		this.storeFeeder = storeFeeder;
+    	}
+    }

     package eu.dnetlib.data.objectstore.modular;
     import java.io.InputStream;
     import javax.annotation.Resource;
     import javax.xml.ws.wsaddressing.W3CEndpointReference;
     import org.springframework.beans.factory.annotation.Required;
     import eu.dnetlib.data.objectstore.modular.connector.ObjectStoreDao;
     import eu.dnetlib.data.objectstore.rmi.ObjectStoreFile;
     import eu.dnetlib.data.objectstore.rmi.ObjectStoreServiceException;
     import eu.dnetlib.enabling.resultset.ResultSetFactory;
     import eu.dnetlib.enabling.resultset.client.ResultSetClientFactory;
     /**
      * The Class ModularObjectStoreDeliver is responsible of delivering data from the object Store.
      */
     public class ModularObjectStoreDeliver {
     	/** The dao. */
     	private ObjectStoreDao dao;
     	/** The result set factory. */
     	@Resource
     	private ResultSetFactory resultSetFactory;
     	/** The result set client factory. */
     	private ResultSetClientFactory resultSetClientFactory;
     	/**
     	 * Gets the dao.
+    	 *
     	 * @return the dao
     	 */
     	public ObjectStoreDao getDao() {
     		return dao;
+    	}
     	/**
     	 * Sets the dao.
+    	 *
     	 * @param dao
     	 *            the new dao
     	 */
     	@Required
     	public void setDao(final ObjectStoreDao dao) {
     		this.dao = dao;
+    	}
     	/**
     	 * Deliver.
+    	 *
     	 * @param objectStoreID
     	 *            the object store id
     	 * @param from
     	 *            the from
     	 * @param until
     	 *            the until
     	 * @return the w3 c endpoint reference
     	 * @throws ObjectStoreServiceException
     	 */
     	public W3CEndpointReference deliver(final String objectStoreID, final Long from, final Long until) throws ObjectStoreServiceException {
     		return resultSetFactory.createResultSet(dao.getObjectStore(objectStoreID).deliver(from, until));
+    	}
     	/**
     	 * Deliver records by tags.
+    	 *
     	 * @param obsId
     	 *            the obs id
     	 * @param tags
     	 *            the tags
     	 * @return the string
     	 */
     	public W3CEndpointReference deliverRecordsByTags(final String obsId, final Iterable<String> tags) {
     		return resultSetFactory.createResultSet(dao.getObjectStore(obsId).deliverRecordsByTag(tags));
+    	}
     	/**
     	 * Deliver ids.
+    	 *
     	 * @param objectStoreID
     	 *            the object store id
     	 * @param eprId
     	 *            the epr id
     	 * @return the w3 c endpoint reference
     	 * @throws ObjectStoreServiceException
     	 */
     	public W3CEndpointReference deliverIds(final String objectStoreID, final W3CEndpointReference eprId) throws ObjectStoreServiceException {
     		Iterable<String> ids = resultSetClientFactory.getClient(eprId);
     		return resultSetFactory.createResultSet(dao.getObjectStore(objectStoreID).deliverIds(ids));
+    	}
     	/**
     	 * Exist id starts with.
+    	 *
     	 * @param obsId
     	 *            the obs id
     	 * @param startId
     	 *            the start id
     	 * @return true, if successful
     	 * @throws ObjectStoreServiceException
     	 */
     	public boolean existIDStartsWith(final String obsId, final String startId) throws ObjectStoreServiceException {
     		return dao.getObjectStore(obsId).existIDStartsWith(startId);
+    	}
     	/**
     	 * Deliver object.
+    	 *
     	 * @param objectStoreID
     	 *            the object store id
     	 * @param objectId
     	 *            the object id
     	 * @return the object store file
     	 * @throws ObjectStoreServiceException
     	 */
     	public ObjectStoreFile deliverObject(final String objectStoreID, final String objectId) throws ObjectStoreServiceException {
     		return dao.getObjectStore(objectStoreID).deliverObject(objectId);
+    	}
     	/**
     	 * Deliver stream.
+    	 *
     	 * @param objectStoreID
     	 *            the object store id
     	 * @param objectId
     	 *            the object id
     	 * @return the input stream
     	 * @throws ObjectStoreServiceException
     	 */
     	public InputStream deliverStream(final String objectStoreID, final String objectId) throws ObjectStoreServiceException {
     		return dao.getObjectStore(objectStoreID).deliverStream(objectId);
+    	}
     	/**
     	 * Gets the result set client factory.
+    	 *
     	 * @return the result set client factory
     	 */
     	public ResultSetClientFactory getResultSetClientFactory() {
     		return resultSetClientFactory;
+    	}
     	/**
     	 * Sets the result set client factory.
+    	 *
     	 * @param resultSetClientFactory
     	 *            the new result set client factory
     	 */
     	@Required
     	public void setResultSetClientFactory(final ResultSetClientFactory resultSetClientFactory) {
     		this.resultSetClientFactory = resultSetClientFactory;
+    	}
+    }

     package eu.dnetlib.data.objectstore.modular;
     import java.util.List;
     import javax.xml.ws.wsaddressing.W3CEndpointReference;
     import org.apache.commons.logging.Log;
     import org.apache.commons.logging.LogFactory;
     import org.springframework.beans.factory.annotation.Required;
     import com.google.common.base.Function;
     import com.google.common.collect.Iterables;
     import com.google.common.collect.Lists;
     import eu.dnetlib.data.objectstore.modular.connector.ObjectStore;
     import eu.dnetlib.data.objectstore.modular.connector.ObjectStoreDao;
     import eu.dnetlib.data.objectstore.rmi.MetadataObjectRecord;
     import eu.dnetlib.data.objectstore.rmi.ObjectStoreFile;
     import eu.dnetlib.data.objectstore.rmi.ObjectStoreServiceException;
     import eu.dnetlib.data.objectstore.rmi.Protocols;
     import eu.dnetlib.enabling.is.registry.rmi.ISRegistryService;
     import eu.dnetlib.enabling.locators.UniqueServiceLocator;
     import eu.dnetlib.enabling.resultset.client.ResultSetClientFactory;
     import eu.dnetlib.miscutils.datetime.DateUtils;
     /**
      * The Class ModularObjectStoreFeeder, responsible to feed data into the object Store.
      */
     public class ModularObjectStoreFeeder {
     	/** The Constant log. */
     	private static final Log log = LogFactory.getLog(ModularObjectStoreFeeder.class);
     	/** The dao of the objectStore. */
     	private ObjectStoreDao dao;
     	/** The result set client factory. */
     	private ResultSetClientFactory resultSetClientFactory;
     	/** The service locator. */
     	private UniqueServiceLocator serviceLocator;
     	/**
     	 * Gets the dao.
+    	 *
     	 * @return the dao
     	 */
     	public ObjectStoreDao getDao() {
     		return dao;
+    	}
     	/**
     	 * Sets the dao.
+    	 *
     	 * @param dao
     	 *            the new dao
     	 */
     	@Required
     	public void setDao(final ObjectStoreDao dao) {
     		this.dao = dao;
+    	}
     	/**
     	 * Gets the result set client factory.
+    	 *
     	 * @return the result set client factory
     	 */
     	public ResultSetClientFactory getResultSetClientFactory() {
     		return resultSetClientFactory;
+    	}
     	/**
     	 * Sets the result set client factory.
+    	 *
     	 * @param resultSetClientFactory
     	 *            the new result set client factory
     	 */
     	@Required
     	public void setResultSetClientFactory(final ResultSetClientFactory resultSetClientFactory) {
     		this.resultSetClientFactory = resultSetClientFactory;
+    	}
     	/**
     	 * Feed metadata object record.
+    	 *
     	 * @param objectStoreID
     	 *            the object store id
     	 * @param rsEpr
     	 *            the rs epr
     	 * @param mime
     	 *            the mime
     	 * @throws ObjectStoreServiceException
     	 *             the object store service exception
     	 */
     	public void feedMetadataObjectRecord(final String objectStoreID, final String rsEpr, final String mime) throws ObjectStoreServiceException {
     		final Iterable<String> records = resultSetClientFactory.getClient(rsEpr);
     		Iterable<MetadataObjectRecord> toIngest = Iterables.transform(records, new Function<String, MetadataObjectRecord>() {
     			@Override
     			public MetadataObjectRecord apply(final String input) {
     				MetadataObjectRecord record = MetadataObjectRecord.initFromJson(input);
     				if (record != null) {
     					record.setMime(mime);
     				} else {
     					log.error("An input record is null :" + input);
+    				}
     				return record;
+    			}
     		});
     		ObjectStore store = dao.getObjectStore(objectStoreID);
     		int size = store.feedMetadataRecord(toIngest, true);
     		touch(objectStoreID, size);
+    	}
     	/**
     	 * Feed object in the object store starting from an EPR of objectMetadata.
+    	 *
     	 * @param obsId
     	 *            the objectStore id
     	 * @param rsEpr
     	 *            the result set Endpoint-reference
     	 * @param protocol
     	 *            the protocol
     	 * @param login
     	 *            the login
     	 * @param password
     	 *            the password
     	 * @param mime
     	 *            the mime type
     	 * @throws ObjectStoreServiceException
     	 *             the object store service exception
     	 */
     	public void feed(final String obsId, final String rsEpr, final Protocols protocol, final String login, final String password, final String mime)
     			throws ObjectStoreServiceException {
     		final Iterable<String> records = resultSetClientFactory.getClient(rsEpr);
     		ObjectBroker objectBroker = new ObjectBroker(protocol, login, password, mime);
     		Iterable<ObjectStoreRecord> toIngest = Iterables.transform(records, objectBroker);
     		ObjectStore store = dao.getObjectStore(obsId);
     		int size = store.feed(toIngest, true);
     		touch(obsId, size);
+    	}
     	/**
     	 * Feed a single object in the object Stroe.
+    	 *
     	 * @param objectStoreID
     	 *            the object store id
     	 * @param objectID
     	 *            the object id
     	 * @param URIObject
     	 *            the URI of object
     	 * @param protocol
     	 *            the protocol
     	 * @param login
     	 *            the login
     	 * @param password
     	 *            the password
     	 * @param mime
     	 *            the mime type
     	 * @throws ObjectStoreServiceException
     	 *             the object store service exception
     	 */
     	public void feedObject(final String objectStoreID,
     			final String objectID,
     			final String URIObject,
     			final Protocols protocol,
     			final String login,
     			final String password,
     			final String mime) throws ObjectStoreServiceException {
     		ObjectStoreFile inputFile = new ObjectStoreFile();
     		inputFile.setURI(URIObject);
     		inputFile.setObjectID(objectID);
     		ObjectBroker objectBroker = new ObjectBroker(protocol, login, password, mime);
     		Iterable<ObjectStoreRecord> toIngest = Iterables.transform(Lists.newArrayList(inputFile.toJSON()), objectBroker);
     		ObjectStore store = dao.getObjectStore(objectStoreID);
     		int size = store.feed(toIngest, true);
     		touch(objectStoreID, size);
+    	}
     	/**
     	 * Feed object record.
+    	 *
     	 * @param objectStoreID
     	 *            the object store id
     	 * @param record
     	 *            the record
     	 * @return the string
     	 * @throws ObjectStoreServiceException
     	 *             the object store service exception
     	 */
     	public String feedObjectRecord(final String objectStoreID, final ObjectStoreRecord record) throws ObjectStoreServiceException {
     		ObjectStore store = dao.getObjectStore(objectStoreID);
     		return store.feedObjectRecord(record);
+    	}
     	/**
     	 * Tag ids.
+    	 *
     	 * @param objectStoreId
     	 *            the object store id
     	 * @param eprId
     	 *            the epr id
     	 * @param tag
     	 *            the tag
     	 * @return the int
     	 */
     	public int tagIds(final String objectStoreId, final W3CEndpointReference eprId, final String tag) {
     		final Iterable<String> records = resultSetClientFactory.getClient(eprId);
     		return this.dao.getObjectStore(objectStoreId).tagIds(records, tag);
+    	}
     	/**
     	 * Untag ids.
+    	 *
     	 * @param objectStoreId
     	 *            the object store id
     	 * @param eprId
     	 *            the epr id
     	 * @param tag
     	 *            the tag
     	 * @return the int
     	 */
     	public int untagIds(final String objectStoreId, final W3CEndpointReference eprId, final String tag) {
     		final Iterable<String> records = resultSetClientFactory.getClient(eprId);
     		return this.dao.getObjectStore(objectStoreId).untagIds(records, tag);
+    	}
     	/**
     	 * Tag object store.
+    	 *
     	 * @param objectStoreId
     	 *            the object store id
     	 * @param tag
     	 *            the tag
     	 * @return the int
     	 */
     	public int tagObjectStore(final String objectStoreId, final String tag) {
     		return this.dao.getObjectStore(objectStoreId).tagObjectstore(tag);
+    	}
     	/**
     	 * Untag object store.
+    	 *
     	 * @param objectStoreId
     	 *            the object store id
     	 * @param tag
     	 *            the tag
     	 * @return the int
     	 */
     	public int untagObjectStore(final String objectStoreId, final String tag) {
     		return this.dao.getObjectStore(objectStoreId).untagObjectstore(tag);
+    	}
     	/**
     	 * Sets the last modified date in the profile.
+    	 *
     	 * @param obsId
     	 *            the obs id
     	 * @param size
     	 *            the size
     	 */
     	public void touch(final String obsId, final int size) {
     		try {
     			final String now = DateUtils.now_ISO8601();
     			final String mdstoreXUpdate = "for $x in //RESOURCE_PROFILE[.//RESOURCE_IDENTIFIER/@value = '" + obsId + "']"
     					+ "return update value $x//LAST_STORAGE_DATE with '" + now + "'";
     			serviceLocator.getService(ISRegistryService.class, true).executeXUpdate(mdstoreXUpdate);
     			touchSize(obsId, size);
     		} catch (final Exception e) {
     			throw new IllegalStateException(e);
+    		}
+    	}
     	/**
     	 * Touch size.
+    	 *
     	 * @param obsId
     	 *            the obs id
     	 * @param size
     	 *            the size
     	 */
     	public void touchSize(final String obsId, final int size) {
     		try {
     			final String mdstoreNumberXUpdate = "for $x in //RESOURCE_PROFILE[.//RESOURCE_IDENTIFIER/@value = '" + obsId + "']"
     					+ "return update value $x//COUNT_STORE with '" + size + "'";
     			serviceLocator.getService(ISRegistryService.class, true).executeXUpdate(mdstoreNumberXUpdate);
     		} catch (final Exception e) {
     			throw new IllegalStateException(e);
+    		}
+    	}
     	/**
     	 * Gets the service locator.
+    	 *
     	 * @return the service locator
     	 */
     	public UniqueServiceLocator getServiceLocator() {
     		return serviceLocator;
+    	}
     	/**
     	 * Sets the service locator.
+    	 *
     	 * @param serviceLocator
     	 *            the new service locator
     	 */
     	@Required
     	public void setServiceLocator(final UniqueServiceLocator serviceLocator) {
     		this.serviceLocator = serviceLocator;
+    	}
     	public int tagObjectStorebyIds(final String objectStoreId, final List<String> ids, final String tag) {
     		return this.dao.getObjectStore(objectStoreId).tagIds(ids, tag);
+    	}
     	public int untagObjectStorebyIds(final String objectStoreId, final List<String> ids, final String tag) {
     		return this.dao.getObjectStore(objectStoreId).untagIds(ids, tag);
+    	}
+    }

     package eu.dnetlib.data.objectstore.modular;
     import java.io.InputStream;
     import eu.dnetlib.data.objectstore.rmi.ObjectStoreFile;
     /**
      * The Class ObjectStoreRecord is a serialization of the object to be ingested in the objectStore metadata + inputstream of the data.
      */
     public class ObjectStoreRecord {
     	/** The file metadata. */
     	private ObjectStoreFile fileMetadata;
     	/** The input stream. */
     	private InputStream inputStream;
     	/**
     	 * Gets the input stream.
+    	 *
     	 * @return the input stream
     	 */
     	public InputStream getInputStream() {
     		return inputStream;
+    	}
     	/**
     	 * Sets the input stream.
+    	 *
     	 * @param inputStream
     	 *            the new input stream
     	 */
     	public void setInputStream(final InputStream inputStream) {
     		this.inputStream = inputStream;
+    	}
     	/**
     	 * Gets the file metadata.
+    	 *
     	 * @return the file metadata
     	 */
     	public ObjectStoreFile getFileMetadata() {
     		return fileMetadata;
+    	}
     	/**
     	 * Sets the file metadata.
+    	 *
     	 * @param fileMetadata
     	 *            the new file metadata
     	 */
     	public void setFileMetadata(final ObjectStoreFile fileMetadata) {
     		this.fileMetadata = fileMetadata;
+    	}
+    }

     package eu.dnetlib.data.objectstore.modular;
     import eu.dnetlib.enabling.tools.blackboard.BlackboardJob;
     import eu.dnetlib.enabling.tools.blackboard.BlackboardServerAction;
     import eu.dnetlib.enabling.tools.blackboard.BlackboardServerHandler;
     /**
      * The Class DeleteObjectStoreAction is responsible to execute the blacboard action of type DELETE.
      */
     public class DeleteObjectStoreAction extends AbstractObjectStoreAction
     		implements BlackboardServerAction<ObjectStoreActions> {
     	/** The profile creator. */
     	private ObjectStoreProfileCreator profileCreator;
     	/* (non-Javadoc)
     	 * @see eu.dnetlib.enabling.tools.blackboard.BlackboardServerAction#execute(eu.dnetlib.enabling.tools.blackboard.BlackboardServerHandler, eu.dnetlib.enabling.tools.blackboard.BlackboardJob)
     	 */
     	@Override
     	public void execute(BlackboardServerHandler handler, BlackboardJob job)
     			throws Exception {
     		final String objID = job.getParameters().get("obsID");
     		getDao().deleteObjectStore(objID);
     		handler.done(job);
+    	}
     	/**
     	 * Gets the profile creator.
+    	 *
     	 * @return the profile creator
     	 */
     	public ObjectStoreProfileCreator getProfileCreator() {
     		return profileCreator;
+    	}
     	/**
     	 * Sets the profile creator.
+    	 *
     	 * @param profileCreator the new profile creator
     	 */
     	public void setProfileCreator(ObjectStoreProfileCreator profileCreator) {
     		this.profileCreator = profileCreator;
+    	}
+    }

     package eu.dnetlib.data.objectstore.modular;
     /**
      * The Enumeration of the blacboard action of the  ObjectStore.
      */
     public enum ObjectStoreActions {
     	/** The create. */
     	CREATE,
      /** The delete. */
      DELETE,
      /** The feed. */
      FEED,
      /** The feedobject. */
      FEEDOBJECT
+    }

     package eu.dnetlib.data.objectstore.modular;
     import javax.xml.ws.Endpoint;
     import org.antlr.stringtemplate.StringTemplate;
     import org.springframework.beans.factory.annotation.Required;
     import eu.dnetlib.enabling.is.registry.rmi.ISRegistryException;
     import eu.dnetlib.enabling.is.registry.rmi.ISRegistryService;
     import eu.dnetlib.enabling.locators.UniqueServiceLocator;
     import eu.dnetlib.soap.EndpointReferenceBuilder;
     // TODO: Auto-generated Javadoc
     /**
      * The Class ObjectStoreProfileCreator is responsible of creating profile of the ObjectStore
      */
     public class ObjectStoreProfileCreator {
     	/**
     	 * service locator.
     	 */
     	private UniqueServiceLocator serviceLocator;
     	/**
     	 * mdstore ds template.
     	 */
     	private StringTemplate objectstoreDsTemplate;
     	/**
     	 * service endpoint.
     	 */
     	private Endpoint endpoint;
     	/**
     	 * endpoint builder.
     	 */
     	private EndpointReferenceBuilder<Endpoint> eprBuilder;
     	/**
     	 * Register profile.
+    	 *
     	 * @param interpretation
     	 *            the interpretation
     	 * @return the string
     	 * @throws ISRegistryException
     	 *             the IS registry exception
     	 */
     	public String registerProfile(final String interpretation)
     			throws ISRegistryException {
     		// XXX: mini hack
     		StringTemplate template = new StringTemplate(
     				objectstoreDsTemplate.getTemplate());
     		template.setAttribute("serviceUri", eprBuilder.getAddress(endpoint));
     		template.setAttribute("interpretation", interpretation);
     		return serviceLocator.getService(ISRegistryService.class, true).registerProfile(template.toString());
+    	}
     	/**
     	 * Gets the endpoint.
+    	 *
     	 * @return the endpoint
     	 */
     	public Endpoint getEndpoint() {
     		return endpoint;
+    	}
     	/**
     	 * Sets the endpoint.
+    	 *
     	 * @param endpoint
     	 *            the new endpoint
     	 */
     	@Required
     	public void setEndpoint(final Endpoint endpoint) {
     		this.endpoint = endpoint;
+    	}
     	/**
     	 * Gets the epr builder.
+    	 *
     	 * @return the epr builder
     	 */
     	public EndpointReferenceBuilder<Endpoint> getEprBuilder() {
     		return eprBuilder;
+    	}
     	/**
     	 * Sets the epr builder.
+    	 *
     	 * @param eprBuilder
     	 *            the new epr builder
     	 */
     	@Required
     	public void setEprBuilder(final EndpointReferenceBuilder<Endpoint> eprBuilder) {
     		this.eprBuilder = eprBuilder;
+    	}
     	/**
     	 * Gets the objectstore ds template.
+    	 *
     	 * @return the objectstore ds template
     	 */
     	public StringTemplate getObjectstoreDsTemplate() {
     		return objectstoreDsTemplate;
+    	}
     	/**
     	 * Sets the objectstore ds template.
+    	 *
     	 * @param objectstoreDsTemplate
     	 *            the new objectstore ds template
     	 */
     	@Required
     	public void setObjectstoreDsTemplate(final StringTemplate objectstoreDsTemplate) {
     		this.objectstoreDsTemplate = objectstoreDsTemplate;
+    	}
     	public UniqueServiceLocator getServiceLocator() {
     		return serviceLocator;
+    	}
     	@Required
     	public void setServiceLocator(final UniqueServiceLocator serviceLocator) {
     		this.serviceLocator = serviceLocator;
+    	}
+    }

     package eu.dnetlib.data.objectstore.modular;
     import eu.dnetlib.data.objectstore.modular.connector.ObjectStoreDao;
     /**
      * The Class AbstractObjectStoreAction.
      */
     public class AbstractObjectStoreAction {
     	/** The object store dao. */
     	private ObjectStoreDao dao;
     	/**
     	 * Gets the dao.
+    	 *
     	 * @return the dao
     	 */
     	public ObjectStoreDao getDao() {
     		return dao;
+    	}
     	/**
     	 * Sets the dao.
+    	 *
     	 * @param dao the new dao
     	 */
     	public void setDao(ObjectStoreDao dao) {
     		this.dao = dao;
+    	}
+    }

     package eu.dnetlib.data.objectstore.modular;
     import eu.dnetlib.enabling.tools.blackboard.BlackboardJob;
     import eu.dnetlib.enabling.tools.blackboard.BlackboardServerAction;
     import eu.dnetlib.enabling.tools.blackboard.BlackboardServerHandler;
     /**
      * The Class CreateObjectStoreAction is responsible to execute the blacboard action of type CREATE.
      */
     public class CreateObjectStoreAction extends AbstractObjectStoreAction
     		implements BlackboardServerAction<ObjectStoreActions> {
     	/** The profile creator. */
     	private ObjectStoreProfileCreator profileCreator;
     	/* (non-Javadoc)
     	 * @see eu.dnetlib.enabling.tools.blackboard.BlackboardServerAction#execute(eu.dnetlib.enabling.tools.blackboard.BlackboardServerHandler, eu.dnetlib.enabling.tools.blackboard.BlackboardJob)
     	 */
     	@Override
     	public void execute(BlackboardServerHandler handler, BlackboardJob job)
     			throws Exception {
     		final String interpretation = job.getParameters().get("interpretation");
     		final String objID = profileCreator.registerProfile(interpretation);
     		getDao().createObjectStore(objID, interpretation);
     		job.getParameters().put("objectStoreId", objID);
     		handler.done(job);
+    	}
     	/**
     	 * Gets the profile creator.
+    	 *
     	 * @return the profile creator
     	 */
     	public ObjectStoreProfileCreator getProfileCreator() {
     		return profileCreator;
+    	}
     	/**
     	 * Sets the profile creator.
+    	 *
     	 * @param profileCreator the new profile creator
     	 */
     	public void setProfileCreator(ObjectStoreProfileCreator profileCreator) {
     		this.profileCreator = profileCreator;
+    	}
+    }

     package eu.dnetlib.data.objectstore.modular;
     import org.springframework.beans.factory.annotation.Required;
     import eu.dnetlib.data.objectstore.rmi.Protocols;
     import eu.dnetlib.enabling.tools.blackboard.BlackboardJob;
     import eu.dnetlib.enabling.tools.blackboard.BlackboardServerAction;
     import eu.dnetlib.enabling.tools.blackboard.BlackboardServerHandler;
     /**
      * The Class FeedObjectStoreAction to execute the blacboard action of type FEED.
      */
     public class FeedObjectStoreAction extends AbstractObjectStoreAction implements
     		BlackboardServerAction<ObjectStoreActions> {
     	/** The profile creator. */
     	private ObjectStoreProfileCreator profileCreator;
     	/** The store feeder. */
     	private ModularObjectStoreFeeder storeFeeder;
     	/* (non-Javadoc)
     	 * @see eu.dnetlib.enabling.tools.blackboard.BlackboardServerAction#execute(eu.dnetlib.enabling.tools.blackboard.BlackboardServerHandler, eu.dnetlib.enabling.tools.blackboard.BlackboardJob)
     	 */
     	@Override
     	public void execute(BlackboardServerHandler handler, BlackboardJob job)
     			throws Exception {
     		final String objStoreID = job.getParameters().get("obsID");
     		final String objID = job.getParameters().get("objID");
     		final String URI = job.getParameters().get("URI");
     		final String eprRs = job.getParameters().get("epr");
     		final String protocolString = job.getParameters().get("protocol");
     		final Protocols protocol;
     		if (protocolString == null)
     			protocol = Protocols.None;
     		else
     			protocol = Protocols.valueOf(job.getParameters().get("protocol"));
     		final String mime = job.getParameters().get("mime");
     		final String login = job.getParameters().get("login");
     		final String password = job.getParameters().get("password");
     		if (URI != null && URI.length() > 0) {
     			storeFeeder.feedObject(objStoreID, objID, URI, protocol, login,
     					password, mime);
     		} else if (eprRs != null && eprRs.length() > 0) {
     			storeFeeder
     					.feed(objStoreID, eprRs, protocol, login, password, mime);
+    		}
     		handler.done(job);
+    	}
     	/**
     	 * Gets the profile creator.
+    	 *
     	 * @return the profile creator
     	 */
     	public ObjectStoreProfileCreator getProfileCreator() {
     		return profileCreator;
+    	}
     	/**
     	 * Sets the profile creator.
+    	 *
     	 * @param profileCreator the new profile creator
     	 */
     	@Required
     	public void setProfileCreator(ObjectStoreProfileCreator profileCreator) {
     		this.profileCreator = profileCreator;
+    	}
     	/**
     	 * Gets the store feeder.
+    	 *
     	 * @return the store feeder
     	 */
     	public ModularObjectStoreFeeder getStoreFeeder() {
     		return storeFeeder;
+    	}
     	/**
     	 * Sets the store feeder.
+    	 *
     	 * @param storeFeeder the new store feeder
     	 */
     	@Required
     	public void setStoreFeeder(ModularObjectStoreFeeder storeFeeder) {
     		this.storeFeeder = storeFeeder;
+    	}
+    }

     package eu.dnetlib.data.objectstore.modular;
     import java.io.IOException;
     import java.io.InputStream;
     import javax.annotation.Resource;
     import javax.servlet.ServletOutputStream;
     import javax.servlet.http.HttpServletResponse;
     import org.apache.commons.io.IOUtils;
     import org.apache.commons.logging.Log;
     import org.apache.commons.logging.LogFactory;
     import org.springframework.stereotype.Controller;
     import org.springframework.web.bind.annotation.RequestMapping;
     import org.springframework.web.bind.annotation.RequestParam;
     import eu.dnetlib.data.objectstore.rmi.ObjectStoreFile;
     import eu.dnetlib.data.objectstore.rmi.ObjectStoreServiceException;
     import eu.dnetlib.miscutils.datetime.HumanTime;
     // TODO: Auto-generated Javadoc
     /**
      * The Class ModularObjectStoreRESTService implement the controller REST of the object Store.
      */
     @Controller
     public class ModularObjectStoreRESTService {
         /** The object store deliver. */
         @Resource
         ModularObjectStoreDeliver objectStoreDeliver;
         private static final Log log = LogFactory.getLog(ModularObjectStoreRESTService.class); // NOPMD by marko on 11/24/08 5:02 PM
         /**
          * Retrieve.
+         *
          * @param res
          *            the res
          * @param objectStoreId
          *            the object store id
          * @param objectId
          *            the object id
          * @throws IOException
          *             Signals that an I/O exception has occurred.
          * @throws ObjectStoreServiceException
          */
         @RequestMapping(value = "/**/objectStore/retrieve.do")
         public void retrieve(final HttpServletResponse res,
     			 @RequestParam(value = "objectStore", required = true) final String objectStoreId,
     			 @RequestParam(value = "objectId", required = true) final String objectId) throws IOException, ObjectStoreServiceException {
     	final long start = System.currentTimeMillis();
     	final ObjectStoreFile file = objectStoreDeliver.deliverObject(objectStoreId, objectId);
     	log.debug(String.format("deliverObject completed in %s, objId: %s", HumanTime.exactly(System.currentTimeMillis() - start), objectId));
     	if (file == null) throw new RuntimeException("The file with id " + objectId + " doesn't exist");
     	// res.setContentType(file.getMimeType());
     	InputStream is = objectStoreDeliver.deliverStream(objectStoreId, objectId);
     	ServletOutputStream outputStream = res.getOutputStream();
     	IOUtils.copy(is, outputStream);
     	try {
     	    is.close();
     	    if (log.isDebugEnabled()) {
     		log.debug(String.format("retrive.do completed in %s, objId: %s", HumanTime.exactly(System.currentTimeMillis() - start), objectId));
+    	    }
     	} catch (Throwable e) {
     	    log.error("unable to close input Stream", e);
+    	}
     	/*
     	 * while (true) { int readSize = is.read(buffer); if (readSize == -1) { break; } outputStream.write(buffer, 0, readSize); }
     	 */
+        }
+    }

     package eu.dnetlib.data.objectstore.modular.inspector;
     import static eu.dnetlib.miscutils.collections.MappedCollection.listMap;
     import java.util.List;
     import javax.annotation.Resource;
     import org.springframework.stereotype.Controller;
     import org.springframework.ui.Model;
     import org.springframework.web.bind.annotation.RequestMapping;
     import org.springframework.web.bind.annotation.RequestMethod;
     import org.springframework.web.bind.annotation.RequestParam;
     import com.google.gson.Gson;
     import eu.dnetlib.data.objectstore.modular.connector.ObjectStore;
     import eu.dnetlib.data.objectstore.modular.connector.ObjectStoreDao;
     import eu.dnetlib.data.objectstore.rmi.ObjectStoreFile;
     import eu.dnetlib.data.objectstore.rmi.ObjectStoreServiceException;
     import eu.dnetlib.enabling.inspector.AbstractInspectorController;
     import eu.dnetlib.enabling.resultset.ResultSetListener;
     import eu.dnetlib.miscutils.collections.MappedCollection;
     import eu.dnetlib.miscutils.functional.UnaryFunction;
     /**
      * The Class ObjectStoreInspector is the inspector controller of the objectStore.
      */
     @Controller
     public class ObjectStoreInspector extends AbstractInspectorController {
     	// private static final Log log = LogFactory.getLog(ObjectStoreInspector.class);
     	/** The object store dao. */
     	@Resource(name = "gridFSObjectstoreDao")
     	private ObjectStoreDao objectStoreDao;
     	/**
     	 * The Class ObjectStoreDescription.
     	 */
     	class ObjectStoreDescription {
     		/** The id. */
     		private String id;
     		/** The size. */
     		private int size;
     		/**
     		 * Instantiates a new object store description.
+    		 *
     		 * @param id
     		 *            the id
     		 * @param size
     		 *            the size
     		 */
     		public ObjectStoreDescription(final String id, final int size) {
     			this.id = id;
     			this.size = size;
+    		}
     		/**
     		 * Gets the interpretation.
+    		 *
     		 * @return the interpretation
     		 */
     		public String getInterpretation() {
     			ObjectStore objectStore = objectStoreDao.getObjectStore(id);
     			return objectStore.getInterpretation();
+    		}
     		/**
     		 * Gets the id.
+    		 *
     		 * @return the id
     		 */
     		public String getId() {
     			return id;
+    		}
     		/**
     		 * Sets the id.
+    		 *
     		 * @param id
     		 *            the new id
     		 */
     		public void setId(final String id) {
     			this.id = id;
+    		}
     		/**
     		 * Gets the size.
+    		 *
     		 * @return the size
     		 */
     		public int getSize() {
     			return size;
+    		}
     		/**
     		 * Sets the size.
+    		 *
     		 * @param size
     		 *            the new size
     		 */
     		public void setSize(final int size) {
     			this.size = size;
+    		}
+    	}
     	/**
     	 * Object stores.
+    	 *
     	 * @param model
     	 *            the model
     	 */
     	@RequestMapping(value = "/inspector/objectstores.do")
     	public void objectStores(final Model model) {
     		List<String> objectStores = objectStoreDao.listObjectStores();
     		model.addAttribute("objectstores", MappedCollection.listMap(objectStores, new UnaryFunction<ObjectStoreDescription, String>() {
     			@Override
     			public ObjectStoreDescription evaluate(final String id) {
     				ObjectStore objStore = objectStoreDao.getObjectStore(id);
     				try {
     					return new ObjectStoreDescription(id, objStore.getSize());
     				} catch (ObjectStoreServiceException e) {
     					return null;
+    				}
+    			}
     		}));
+    	}
     	/**
     	 * Object store.
+    	 *
     	 * @param model
     	 *            the model
     	 * @param id
     	 *            the id
     	 * @param startParam
     	 *            the start param
     	 * @param regex
     	 *            the regex
     	 * @throws ObjectStoreServiceException
     	 */
     	@RequestMapping(value = "/inspector/objectstore.do", method = RequestMethod.GET)
     	public void objectStore(final Model model,
     			@RequestParam("id") final String id,
     			@RequestParam(value = "start", required = false) final Integer startParam,
     			@RequestParam(value = "regex", required = false) final String regex) throws ObjectStoreServiceException {
     		int pageSize = 10;
     		int start = 0;
     		if (startParam != null) {
     			start = startParam;
+    		}
     		ObjectStore objctStore = objectStoreDao.getObjectStore(id);
     		ResultSetListener rs = objctStore.deliver((long) 0, System.currentTimeMillis());
     		List<String> page = rs.getResult((1 + start), (start + pageSize));
     		final Gson g = new Gson();
     		model.addAttribute("id", id);
     		model.addAttribute("start", start);
     		model.addAttribute("regex", regex);
     		model.addAttribute("nextPage", start + pageSize);
     		model.addAttribute("prevPage", Math.max(0, start - pageSize));
     		model.addAttribute("size", rs.getSize());
     		model.addAttribute("page", listMap(page, new UnaryFunction<ObjectStoreFile, String>() {
     			@Override
     			public ObjectStoreFile evaluate(final String json) {
     				return g.fromJson(json, ObjectStoreFile.class);
+    			}
     		}));
+    	}
     	/**
     	 * Gets the object store dao.
+    	 *
     	 * @return the object store dao
     	 */
     	public ObjectStoreDao getObjectStoreDao() {
     		return objectStoreDao;
+    	}
     	/**
     	 * Sets the object store dao.
+    	 *
     	 * @param objectStoreDao
     	 *            the new object store dao
     	 */
     	public void setObjectStoreDao(final ObjectStoreDao objectStoreDao) {
     		this.objectStoreDao = objectStoreDao;
+    	}
+    }

     package eu.dnetlib.data.objectstore.modular;
     import java.util.List;
     import javax.xml.ws.wsaddressing.W3CEndpointReference;
     import org.springframework.beans.factory.annotation.Required;
     import com.google.gson.Gson;
     import eu.dnetlib.data.objectstore.rmi.ObjectStoreFile;
     import eu.dnetlib.data.objectstore.rmi.ObjectStoreService;
     import eu.dnetlib.data.objectstore.rmi.ObjectStoreServiceException;
     import eu.dnetlib.enabling.tools.AbstractBaseService;
     import eu.dnetlib.enabling.tools.blackboard.NotificationHandler;
     /**
      * The Class ModularObjectStoreService is the implementation of the ObjectStoreService interface.
      */
     public class ModularObjectStoreService extends AbstractBaseService implements ObjectStoreService {
     	/** The feeder. */
     	private ModularObjectStoreFeeder feeder;
     	/** The object store deliver. */
     	private ModularObjectStoreDeliver objectStoreDeliver;
     	/** The notification handler. */
     	private NotificationHandler notificationHandler;
     	/*
     	 * (non-Javadoc)
+    	 *
     	 * @see eu.dnetlib.data.objectstore.rmi.ObjectStoreService#deliverObjects(java.lang.String, java.lang.Double, java.lang.Double)
     	 */
     	/**
     	 * Deliver objects.
+    	 *
     	 * @param obsId
     	 *            the obs id
     	 * @param from
     	 *            the from
     	 * @param until
     	 *            the until
     	 * @return the w3 c endpoint reference
     	 * @throws ObjectStoreServiceException
     	 *             the object store service exception
     	 */
     	@Override
     	public W3CEndpointReference deliverObjects(final String obsId, final Long from, final Long until) throws ObjectStoreServiceException {
     		return objectStoreDeliver.deliver(obsId, from, until);
+    	}
     	/*
     	 * (non-Javadoc)
+    	 *
     	 * @see eu.dnetlib.data.objectstore.rmi.ObjectStoreService#deliverObjectsByIds(java.lang.String,
     	 * javax.xml.ws.wsaddressing.W3CEndpointReference)
     	 */
     	/**
     	 * Deliver objects by ids.
+    	 *
     	 * @param obsId
     	 *            the obs id
     	 * @param eprId
     	 *            the epr id
     	 * @return the w3 c endpoint reference
     	 * @throws ObjectStoreServiceException
     	 *             the object store service exception
     	 */
     	@Override
     	public W3CEndpointReference deliverObjectsByIds(final String obsId, final W3CEndpointReference eprId) throws ObjectStoreServiceException {
     		return objectStoreDeliver.deliverIds(obsId, eprId);
+    	}
     	/*
     	 * (non-Javadoc)
+    	 *
     	 * @see eu.dnetlib.data.objectstore.rmi.ObjectStoreService#deliverRecord(java.lang.String, java.lang.String)
     	 */
     	/**
     	 * Deliver record.
+    	 *
     	 * @param obsId
     	 *            the obs id
     	 * @param objectId
     	 *            the object id
     	 * @return the string
     	 * @throws ObjectStoreServiceException
     	 *             the object store service exception
     	 */
     	@Override
     	public String deliverRecord(final String obsId, final String objectId) throws ObjectStoreServiceException {
     		return objectStoreDeliver.deliverObject(obsId, objectId).toJSON();
+    	}
     	/*
     	 * (non-Javadoc)
+    	 *
     	 * @see eu.dnetlib.data.objectstore.rmi.ObjectStoreService#getListOfObjectStores()
     	 */
     	/**
     	 * Gets the list of object stores.
+    	 *
     	 * @return the list of object stores
     	 */
     	@Override
     	public List<String> getListOfObjectStores() {
     		return objectStoreDeliver.getDao().listObjectStores();
+    	}
     	/**
     	 * Gets the feeder.
+    	 *
     	 * @return the feeder
     	 */
     	public ModularObjectStoreFeeder getFeeder() {
     		return feeder;
+    	}
     	/**
     	 * Sets the feeder.
+    	 *
     	 * @param feeder
     	 *            the new feeder
     	 */
     	@Required
     	public void setFeeder(final ModularObjectStoreFeeder feeder) {
     		this.feeder = feeder;
+    	}
     	/**
     	 * Gets the notification handler.
+    	 *
     	 * @return the notification handler
     	 */
     	public NotificationHandler getNotificationHandler() {
     		return notificationHandler;
+    	}
     	/**
     	 * Sets the notification handler.
+    	 *
     	 * @param notificationHandler
     	 *            the new notification handler
     	 */
     	@Required
     	public void setNotificationHandler(final NotificationHandler notificationHandler) {
     		this.notificationHandler = notificationHandler;
+    	}
     	/**
     	 * {@inheritDoc}
+    	 *
     	 * @see eu.dnetlib.enabling.tools.AbstractBaseService#notify(java.lang.String, java.lang.String, java.lang.String, java.lang.String)
     	 */
     	@Override
     	public void notify(final String subscriptionId, final String topic, final String isId, final String message) {
     		getNotificationHandler().notified(subscriptionId, topic, isId, message);
+    	}
     	/**
     	 * Gets the object store deliver.
+    	 *
     	 * @return the object store deliver
     	 */
     	public ModularObjectStoreDeliver getObjectStoreDeliver() {
     		return objectStoreDeliver;
+    	}
     	/**
     	 * Sets the object store deliver.
+    	 *
     	 * @param objectStoreDeliver
     	 *            the new object store deliver
     	 */
     	@Required
     	public void setObjectStoreDeliver(final ModularObjectStoreDeliver objectStoreDeliver) {
     		this.objectStoreDeliver = objectStoreDeliver;
+    	}
     	/*
     	 * (non-Javadoc)
+    	 *
     	 * @see eu.dnetlib.data.objectstore.rmi.ObjectStoreService#feedObject(java.lang.String, java.lang.String)
     	 */
     	/**
     	 * Feed object.

Project

General

Profile

D-Net

Revision 40903

Added by Sandro La Bruzzo almost 9 years ago