From 594c09aa960a166b616833da57e91c372365ea62 Mon Sep 17 00:00:00 2001
From: Luca Frosini <luca.frosini@isti.cnr.it>
Date: Wed, 17 Feb 2016 15:36:37 +0000
Subject: [PATCH] Added test and facilities

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/private/luca.frosini/infrastructure-tests@124263 82a268e6-3cf1-43bd-a215-b396298e98cf
---
 .../couchdb/DeleteTestDocument.java           | 53 +++++++++++++++++++
 .../usagerecords}/AccountingTest.java         |  2 +-
 .../org/gcube/testutility/ScopedTest.java     |  1 +
 3 files changed, 55 insertions(+), 1 deletion(-)
 create mode 100644 src/test/java/org/gcube/accounting/analytics/persistence/couchdb/DeleteTestDocument.java
 rename src/test/java/org/gcube/accounting/{couchdb/query => datamodel/usagerecords}/AccountingTest.java (98%)

diff --git a/src/test/java/org/gcube/accounting/analytics/persistence/couchdb/DeleteTestDocument.java b/src/test/java/org/gcube/accounting/analytics/persistence/couchdb/DeleteTestDocument.java
new file mode 100644
index 0000000..498f678
--- /dev/null
+++ b/src/test/java/org/gcube/accounting/analytics/persistence/couchdb/DeleteTestDocument.java
@@ -0,0 +1,53 @@
+/**
+ * 
+ */
+package org.gcube.accounting.analytics.persistence.couchdb;
+
+import org.codehaus.jackson.JsonNode;
+import org.ektorp.DocumentNotFoundException;
+import org.ektorp.ViewQuery;
+import org.ektorp.ViewResult;
+import org.gcube.accounting.analytics.persistence.AccountingPersistenceBackendQueryConfiguration;
+import org.gcube.testutility.ScopedTest;
+import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * @author Luca Frosini (ISTI - CNR) http://www.lucafrosini.com/
+ *
+ */
+public class DeleteTestDocument extends ScopedTest {
+	
+	private static Logger logger = LoggerFactory.getLogger(DeleteTestDocument.class);
+	
+	//@Test
+	public void removeTestRecords() throws Exception {
+		AccountingPersistenceBackendQueryConfiguration persitenceConfiguration = new AccountingPersistenceBackendQueryConfiguration(AccountingPersistenceQueryCouchDB.class);
+		AccountingPersistenceQueryCouchDB accountingPersistenceQueryCouchDB = new AccountingPersistenceQueryCouchDB();
+		accountingPersistenceQueryCouchDB.prepareConnection(persitenceConfiguration);
+		
+		ViewQuery query = new ViewQuery().designDocId("_design/TestRecords");
+		query = query.viewName("testRecords");
+		query = query.includeDocs(true);
+		
+		ViewResult viewResult;
+		try {
+			viewResult = accountingPersistenceQueryCouchDB.query(query);
+		} catch (DocumentNotFoundException e) {
+			// Install VIEW if valid and does not exist
+			throw e;
+		}
+		
+		for (ViewResult.Row row : viewResult) {
+			String key = row.getKey();
+			JsonNode node = row.getValueAsNode();
+			logger.debug("Going to delete {}", node);
+			String rev = node.get("_rev").asText();
+			//accountingPersistenceQueryCouchDB.couchDbConnector.delete(key, rev);
+		}
+		
+	}
+	
+	
+}
diff --git a/src/test/java/org/gcube/accounting/couchdb/query/AccountingTest.java b/src/test/java/org/gcube/accounting/datamodel/usagerecords/AccountingTest.java
similarity index 98%
rename from src/test/java/org/gcube/accounting/couchdb/query/AccountingTest.java
rename to src/test/java/org/gcube/accounting/datamodel/usagerecords/AccountingTest.java
index d295ab6..d8ed2ff 100644
--- a/src/test/java/org/gcube/accounting/couchdb/query/AccountingTest.java
+++ b/src/test/java/org/gcube/accounting/datamodel/usagerecords/AccountingTest.java
@@ -1,7 +1,7 @@
 /**
  * 
  */
-package org.gcube.accounting.couchdb.query;
+package org.gcube.accounting.datamodel.usagerecords;
 
 import java.util.concurrent.TimeUnit;
 
diff --git a/src/test/java/org/gcube/testutility/ScopedTest.java b/src/test/java/org/gcube/testutility/ScopedTest.java
index 72a9a32..aa8bde4 100644
--- a/src/test/java/org/gcube/testutility/ScopedTest.java
+++ b/src/test/java/org/gcube/testutility/ScopedTest.java
@@ -18,6 +18,7 @@ public class ScopedTest {
 	public void before() throws Exception{
 		//SecurityTokenProvider.instance.set(TestUtility.TOKEN);
 		ScopeProvider.instance.set("/gcube/devsec");
+		ScopeProvider.instance.set("/gcube/devNext");
 	}
 	
 	@After