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

     	 */
     	@Override
     	public String feedObjectRecord(final ObjectStoreRecord record) throws ObjectStoreServiceException {
     		if (record == null || record.getFileMetadata() == null) { throw new ObjectStoreServiceException("Empty input Record"); }
     		if (record == null || record.getFileMetadata() == null) throw new ObjectStoreServiceException("Empty input Record");
     		if (existIDStartsWith(record.getFileMetadata().getObjectID())) {
     			log.debug("Object already exist ");
-...
     		long timestamp = System.currentTimeMillis();
     		String URI = "";
     		if (record.getInputStream() == null) { throw new ObjectStoreServiceException("missing inputstream on record " + record.getFileMetadata().getObjectID()); }
     		if (record.getInputStream() == null) throw new ObjectStoreServiceException("missing inputstream on record " + record.getFileMetadata().getObjectID());
     		final GridFSInputFile currentFile = collection.createFile(record.getInputStream());
     		currentFile.setId(record.getFileMetadata().getObjectID());
     		currentFile.setFilename(record.getFileMetadata().getObjectID());
-...
     		metadata.put("id", record.getFileMetadata().getObjectID());
     		metadata.put("mime", record.getFileMetadata().getMimeType());
     		metadata.put("originalObject", record.getFileMetadata().toJSON());
     		metadata.put("timestamp", timestamp);
     		try {
     			URI = baseURI + "?objectStore=" + URLEncoder.encode(id, "UTF-8") + "&objectId="
     					+ URLEncoder.encode(record.getFileMetadata().getObjectID(), "UTF-8");
     			metadata.put("uri", URI);
     			if (metadata.get("tags") == null) {
     				metadata.put("tags", Sets.newHashSet("UNVISITED"));
     			} else {
     				final BasicDBList tagList = (BasicDBList) metadata.get("tags");
     				final Set<String> inputSet = Sets.newHashSet();
     				for (final Object o : tagList) {
     					inputSet.add((String) o);
+    				}
     				inputSet.add("UNVISITED");
     				metadata.put("tags", inputSet);
+    			}
     			currentFile.setMetaData(metadata);
     			currentFile.save();
-...
     	 */
     	@Override
     	public int tagIds(final Iterable<String> ids, final String tag) {
     		if (ids == null) { return 0; }
     		if (ids == null) return 0;
     		int counter = 0;
     		for (final String id : ids) {
-...
     	 */
     	@Override
     	public int untagIds(final Iterable<String> ids, final String tag) {
     		if (ids == null) { return 0; }
     		if (ids == null) return 0;
     		int counter = 0;
     		for (final String id : ids) {
-...
     	 *             the object store file not found exception
     	 */
     	private void checkSingleItem(final String objectId, final List<GridFSDBFile> file) throws ObjectStoreFileNotFoundException {
     		if (file.isEmpty()) { throw new ObjectStoreFileNotFoundException(String.format("Object file not found with id: %s", objectId)); }
     		if (file.size() > 1) { throw new IllegalStateException(String.format("More than one objects found with id: %s", objectId)); }
     		if (file.isEmpty()) throw new ObjectStoreFileNotFoundException(String.format("Object file not found with id: %s", objectId));
     		if (file.size() > 1) throw new IllegalStateException(String.format("More than one objects found with id: %s", objectId));
+    	}
     	/**

     /**
      * The listener interface for receiving gridFSObjectstoreResultSet events. The class that is interested in processing a
      * gridFSObjectstoreResultSet event implements this interface, and the object created with that class is registered with a component using
      * the component's <code>addGridFSObjectstoreResultSetListener<code> method. When
      * the gridFSObjectstoreResultSet event occurs, that object's appropriate
      * method is invoked.
      * the component's <code>addGridFSObjectstoreResultSetListener<code> method. When the gridFSObjectstoreResultSet event occurs, that object's
      * appropriate method is invoked.
+     *
      * @see GridFSObjectstoreResultSetEvent
      */
-...
     	/*
     	 * (non-Javadoc)
+    	 *
+    	 *
     	 * @see eu.dnetlib.enabling.resultset.TypedResultSetListener#getResult(int, int)
     	 */
     	@Override
-...
     			List<GridFSDBFile> out = collection.find(q);
     			return MappedCollection.listMap(out, ObjectStoreFileUtility.asJSON(baseURI, objectStoreID));
     		} else if (tags != null || tags.isEmpty()) {
     		} else if (tags != null && !tags.isEmpty()) {
     			if (currentCursor == null || cursorPosition > from) {
     				createCurrentCursor(this.tags);
+    			}
-...
     	/*
     	 * (non-Javadoc)
+    	 *
+    	 *
     	 * @see eu.dnetlib.enabling.resultset.TypedResultSetListener#getSize()
     	 */
     	@Override
-...
     	/*
     	 * (non-Javadoc)
+    	 *
+    	 *
     	 * @see eu.dnetlib.enabling.resultset.ResultSetAware#setResultSet(eu.dnetlib.enabling.resultset.ResultSet)
     	 */
     	@Override

modules/dnet-gridfs-objectstore/branches/tag/src/main/java/eu/dnetlib/data/objectstore/modular/gridFS/GridFSObjectstoreDaoImpl.java
49	49	}
50	50	}
51	51	if (!hasTimestampIndex) {
52		coll.ensureIndex("metadata.timestamp");
	52	coll.createIndex("metadata.timestamp");
53	53	}
54	54	}
55	55

     	<groupId>eu.dnetlib</groupId>
     	<artifactId>dnet-gridfs-objectstore</artifactId>
     	<packaging>jar</packaging>
     	<version>4.0.2-SNAPSHOT</version>
     	<version>4.0.2-TAG-SNAPSHOT</version>
     	<scm>
     	  <developerConnection>scm:svn:https://svn.driver.research-infrastructures.eu/driver/dnet40/modules/dnet-gridfs-objectstore/trunk</developerConnection>
     	</scm>
-...
     		<dependency>
     			<groupId>eu.dnetlib</groupId>
     			<artifactId>dnet-modular-objectstore-service</artifactId>
     			<version>[4.0.0,5.0.0)</version>
     			<version>[4.0.2-TAG-SNAPSHOT]</version>
     		</dependency>
     		<dependency>
     			<groupId>eu.dnetlib</groupId>

modules/dnet-modular-objectstore-service/branches/tag/src/main/resources/eu/dnetlib/enabling/views/inspector/objectstore.st
34	34	<tr><td>Original URL :</td><td><a href="$it.downloadedURL$">$it.downloadedURL$</a></tr>
35	35	<tr><td>md5Sum :</td><td>$it.md5Sum$</td></tr>
36	36	<tr><td>file size :</td><td>$it.fileSizeKB$ kb</td></tr>
	37	<tr><td>Tags :</td><td>[$it.tags:{$it$ , }$]</td></tr>
37	38	</table>
38	39
39	40	</div>

     	<groupId>eu.dnetlib</groupId>
     	<artifactId>dnet-modular-objectstore-service</artifactId>
     	<packaging>jar</packaging>
     	<version>4.0.2-SNAPSHOT</version>
     	<version>4.0.2-TAG-SNAPSHOT</version>
     	<scm>
     	  <developerConnection>scm:svn:https://svn.driver.research-infrastructures.eu/driver/dnet40/modules/dnet-modular-objectstore-service/trunk</developerConnection>
     	</scm>
-...
     		<dependency>
     			<groupId>eu.dnetlib</groupId>
     			<artifactId>dnet-objectstore-rmi</artifactId>
     			<version>[2.0.0,3.0.0)</version>
     			<version>[2.0.5-TAG-SNAPSHOT]</version>
     		</dependency>
     		<dependency>
     			<groupId>eu.dnetlib</groupId>

Project

General

Profile

D-Net

Revision 39082

Added by Sandro La Bruzzo over 8 years ago