From f933e31423f8b4d97fe54c52dcaff195bae6a56f Mon Sep 17 00:00:00 2001 From: Luca Frosini Date: Thu, 25 Feb 2016 17:08:44 +0000 Subject: [PATCH] Addes some tests git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/private/luca.frosini/infrastructure-tests@124590 82a268e6-3cf1-43bd-a215-b396298e98cf --- pom.xml | 6 ++ ...AccountingPersistenceQueryCouchDBTest.java | 1 - .../PersistenceBackendMonitorTest.java | 2 +- .../persistence/RenameFileTest.java | 65 +++++++++++++++++++ 4 files changed, 72 insertions(+), 2 deletions(-) create mode 100644 src/test/java/org/gcube/documentstore/persistence/RenameFileTest.java diff --git a/pom.xml b/pom.xml index dd92e3a..109962d 100644 --- a/pom.xml +++ b/pom.xml @@ -49,6 +49,12 @@ [1.0.1-SNAPSHOT, 2.0.0-SNAPSHOT) test + + org.gcube.common + couchdb-connector + [1.0.0-SNAPSHOT, 2.0.0-SNAPSHOT) + test + org.gcube.data.publishing document-store-lib-mongodb diff --git a/src/test/java/org/gcube/accounting/analytics/persistence/couchdb/AccountingPersistenceQueryCouchDBTest.java b/src/test/java/org/gcube/accounting/analytics/persistence/couchdb/AccountingPersistenceQueryCouchDBTest.java index 34d9647..42f5764 100644 --- a/src/test/java/org/gcube/accounting/analytics/persistence/couchdb/AccountingPersistenceQueryCouchDBTest.java +++ b/src/test/java/org/gcube/accounting/analytics/persistence/couchdb/AccountingPersistenceQueryCouchDBTest.java @@ -80,7 +80,6 @@ public class AccountingPersistenceQueryCouchDBTest extends ScopedTest { AccountingPersistenceBackendQueryConfiguration(AccountingPersistenceQueryCouchDB.class); configuration.addProperty(AccountingPersistenceQueryCouchDB.DB_NAME, "accounting-my-dev-test"); accountingPersistenceQueryCouchDB = new AccountingPersistenceQueryCouchDB(); - accountingPersistenceQueryCouchDB.prepareConnection(configuration); } diff --git a/src/test/java/org/gcube/documentstore/persistence/PersistenceBackendMonitorTest.java b/src/test/java/org/gcube/documentstore/persistence/PersistenceBackendMonitorTest.java index 8da1f23..a80bb45 100644 --- a/src/test/java/org/gcube/documentstore/persistence/PersistenceBackendMonitorTest.java +++ b/src/test/java/org/gcube/documentstore/persistence/PersistenceBackendMonitorTest.java @@ -73,7 +73,7 @@ public class PersistenceBackendMonitorTest extends ScopedTest { public void singleParsingTest() throws Exception { PersistenceBackendFactory.setFallbackLocation(null); PersistenceBackend persistenceBackend = PersistenceBackendFactory.getPersistenceBackend(TestUtility.getScope()); - persistenceBackend.setFallback((FallbackPersistenceBackend) persistenceBackend); + //persistenceBackend.setFallback((FallbackPersistenceBackend) persistenceBackend); PersistenceBackendMonitor temporalDataPersistenceBackendMonitor = new PersistenceBackendMonitor(persistenceBackend); temporalDataPersistenceBackendMonitor.run(); diff --git a/src/test/java/org/gcube/documentstore/persistence/RenameFileTest.java b/src/test/java/org/gcube/documentstore/persistence/RenameFileTest.java new file mode 100644 index 0000000..612c237 --- /dev/null +++ b/src/test/java/org/gcube/documentstore/persistence/RenameFileTest.java @@ -0,0 +1,65 @@ +/** + * + */ +package org.gcube.documentstore.persistence; + +import java.io.BufferedWriter; +import java.io.File; +import java.io.FileWriter; +import java.io.IOException; +import java.io.PrintWriter; +import java.util.Calendar; + +import org.gcube.accounting.persistence.AccountingPersistence; +import org.gcube.accounting.persistence.AccountingPersistenceFactory; +import org.gcube.common.scope.api.ScopeProvider; +import org.gcube.testutility.ScopedTest; +import org.gcube.testutility.TestUsageRecord; +import org.gcube.testutility.TestUtility; +import org.junit.Test; + +/** + * @author Luca Frosini (ISTI - CNR) http://www.lucafrosini.com/ + * + */ +public class RenameFileTest extends ScopedTest { + + private final static String ELABORATION_FILE_SUFFIX = ".ELABORATION"; + + public void printLine(File file, String line) throws Exception { + synchronized (file) { + try(FileWriter fw = new FileWriter(file, true); + BufferedWriter bw = new BufferedWriter(fw); + PrintWriter out = new PrintWriter(bw)){ + out.println(line); + out.flush(); + } catch( IOException e ){ + throw e; + } + } + } + + @Test + public void renameFileTest() throws Exception{ + File first = new File("./test.txt"); + Long timestamp = Calendar.getInstance().getTimeInMillis(); + File elaborationFile = new File(first.getAbsolutePath() + ELABORATION_FILE_SUFFIX + "." + timestamp.toString()); + first.renameTo(elaborationFile); + + printLine(first, "-FIRST-"); + for(int i=0; i<100; i++){ + printLine(elaborationFile, "-ELABORATION-" + i); + printLine(first, "-FIRST MOVED-"+i); + } + + } + + @Test + public void testPersistenceBackendMonitor() throws Exception{ + AccountingPersistenceFactory.setFallbackLocation("."); + AccountingPersistence accountingPersistence = AccountingPersistenceFactory.getPersistence(); + accountingPersistence.account(TestUsageRecord.createTestStorageUsageRecord()); + + } + +}