D-Net

import eu.dnetlib.data.objectstore.rmi.ObjectStoreFile;

import eu.dnetlib.data.objectstore.rmi.ObjectStoreServiceException;

import eu.dnetlib.enabling.resultset.ResultSetListener;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.bson.Document;

import java.nio.file.Files;

import java.nio.file.Path;

import java.nio.file.StandardCopyOption;

import java.util.concurrent.atomic.AtomicInteger;

import java.util.regex.Pattern;

    private final String s3EndPoint;

    private final String objectStoreBucket;

    private final MongoCollection<Document> mongoCollection;

    private static final Log log = LogFactory.getLog(S3ObjectStore.class);

        this.id = identifier;

        this.interpretation = interpretation;

        this.s3AccessKey = s3AccessKey;

        this.mongoCollection = mongoCollection;

        this.s3EndPoint = s3EndPoint;

        this.objectStoreBucket = objectStoreBucket;

    }

    @Override

    public String feedObjectRecord(ObjectStoreRecord objectStoreRecord) throws ObjectStoreServiceException {

        try {

            long start = System.currentTimeMillis();

                log.debug("Saving object with ID: " + objectStoreRecord.getFileMetadata().getObjectID() + " on s3 ");

                log.debug("Total time to put into the ObjectStore " + (System.currentTimeMillis() - start));

                log.debug("Saved object on s3 ");

                double timestamp = System.currentTimeMillis();

                Document metadata = new Document()

                        .append(ID_FIELD, objectStoreRecord.getFileMetadata().getObjectID())

            log.error("Error on put file in the objectStore", e);

            log.error(ExceptionUtils.getStackTrace(e));

            throw new ObjectStoreServiceException(e);

        }

        return null;

    }

        if (response == null)

            throw new ObjectStoreServiceException("Error document not found with objectId: "+objectId);

    }

    @Override

    @Override

    public boolean dropContent() throws ObjectStoreServiceException {

        final ListObjectsV2Request req = new ListObjectsV2Request().withBucketName(objectStoreBucket).withPrefix(id);

        ListObjectsV2Result result;

        do {

            for (S3ObjectSummary objectSummary : result.getObjectSummaries()) {

                log.debug(String.format(" - %s (size: %d)\n", objectSummary.getKey(), objectSummary.getSize()));

                log.debug("Object Deleted");

            }

            String token = result.getNextContinuationToken();

        this.mongoCollection.drop();

        return true;

    }

}

    @Value("${dnet.objectStore.s3.objectStoreBucket}")

    private String objectStoreBucket;

	private Document getObjectStoreMetadata(final String objectStoreId) {

        String find_id = objectStoreId;

        if (objectStoreId.length() == 36) {

        if ((resultQuery == null)) throw new ObjectStoreFileNotFoundException("the objectStore with identifier: "+objectStoreId+" was not found");

        final MongoCollection<Document> collection = getDb().getCollection(objectStoreId.substring(0,36));

        collection.createIndexes(metadataIndexes);

    }

    @Override

services.objectStore.mongodb.host=localhost

services.objectStore.mongodb.port=27017

services.objectStore.mongodb.db=objectStore

    <dependencies>

        <dependency>

            <groupId>com.amazonaws</groupId>

        </dependency>

        <dependency>

            <groupId>eu.dnetlib</groupId>

            <artifactId>dnet-modular-objectstore-service</artifactId>