Added an adapter for PersistenceService to be used in unit tests

Change-Id: Ided127f848b97632b021ea1f1c88d912fe28492c

+/*
+ * Copyright 2015 Open Networking Laboratory
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onosproject.store.persistence;
+
+import org.onosproject.persistence.PersistenceService;
+import org.onosproject.persistence.PersistentMapBuilder;
+import org.onosproject.persistence.PersistentSetBuilder;
+
+/**
+ * Adapter for PersistenceService.
+ */
+public class PersistenceServiceAdapter implements PersistenceService {
+
+    @Override
+    public <K, V> PersistentMapBuilder<K, V> persistentMapBuilder() {
+        return null;
+    }
+
+    @Override
+    public <E> PersistentSetBuilder<E> persistentSetBuilder() {
+        return null;
+    }
+}

+/*
+ * Copyright 2015 Open Networking Laboratory
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onosproject.store.persistence;
+
+import java.util.Map;
+
+import org.onosproject.persistence.PersistentMapBuilder;
+import org.onosproject.persistence.PersistentSetBuilder;
+import org.onosproject.store.service.Serializer;
+
+import com.google.common.collect.Maps;
+
+/**
+ * PersistenceService that produces in memory maps for use in unit testing.
+ */
+public class TestPersistenceService extends PersistenceServiceAdapter {
+    @Override
+    public <K, V> PersistentMapBuilder<K, V> persistentMapBuilder() {
+        return new TestPersistentMapBuilder<K, V>();
+    }
+
+    @Override
+    public <E> PersistentSetBuilder<E> persistentSetBuilder() {
+        throw new UnsupportedOperationException();
+    }
+
+    private static class TestPersistentMapBuilder<K, V> implements PersistentMapBuilder<K, V> {
+
+        @Override
+        public PersistentMapBuilder<K, V> withName(String name) {
+            return this;
+        }
+
+        @Override
+        public PersistentMapBuilder<K, V> withSerializer(Serializer serializer) {
+            return this;
+        }
+
+        @Override
+        public Map<K, V> build() {
+            return Maps.newConcurrentMap();
+        }
+    }
+}

@@ -42,12 +42,13 @@ import org.onosproject.cluster.ControllerNode;
 import org.onosproject.cluster.DefaultControllerNode;
 import org.onosproject.cluster.DefaultControllerNode;
 import org.onosproject.cluster.NodeId;
 import org.onosproject.cluster.NodeId;
 import org.onosproject.event.AbstractEvent;
 import org.onosproject.event.AbstractEvent;
-import org.onosproject.persistence.impl.PersistenceManager;
+import org.onosproject.persistence.PersistenceService;
 import org.onosproject.store.Timestamp;
 import org.onosproject.store.Timestamp;
 import org.onosproject.store.cluster.messaging.ClusterCommunicationService;
 import org.onosproject.store.cluster.messaging.ClusterCommunicationService;
 import org.onosproject.store.cluster.messaging.ClusterCommunicationServiceAdapter;
 import org.onosproject.store.cluster.messaging.ClusterCommunicationServiceAdapter;
 import org.onosproject.store.cluster.messaging.MessageSubject;
 import org.onosproject.store.cluster.messaging.MessageSubject;
 import org.onosproject.store.impl.LogicalTimestamp;
 import org.onosproject.store.impl.LogicalTimestamp;
+import org.onosproject.store.persistence.TestPersistenceService;
 import org.onosproject.store.serializers.KryoNamespaces;
 import org.onosproject.store.serializers.KryoNamespaces;
 import org.onosproject.store.serializers.KryoSerializer;
 import org.onosproject.store.serializers.KryoSerializer;
 import org.onosproject.store.service.EventuallyConsistentMap;
 import org.onosproject.store.service.EventuallyConsistentMap;
@@ -82,7 +83,7 @@ public class EventuallyConsistentMapImplTest {
 
 
     private EventuallyConsistentMap<String, String> ecMap;
     private EventuallyConsistentMap<String, String> ecMap;
 
 
-    private PersistenceManager persistenceService;
+    private PersistenceService persistenceService;
     private ClusterService clusterService;
     private ClusterService clusterService;
     private ClusterCommunicationService clusterCommunicator;
     private ClusterCommunicationService clusterCommunicator;
     private SequentialClockService<String, String> clockService;
     private SequentialClockService<String, String> clockService;
@@ -138,8 +139,7 @@ public class EventuallyConsistentMapImplTest {
 
 
         clusterCommunicator = createMock(ClusterCommunicationService.class);
         clusterCommunicator = createMock(ClusterCommunicationService.class);
 
 
-        persistenceService = new PersistenceManager();
-        persistenceService.activate();
+        persistenceService = new TestPersistenceService();
         // Add expectation for adding cluster message subscribers which
         // Add expectation for adding cluster message subscribers which
         // delegate to our ClusterCommunicationService implementation. This
         // delegate to our ClusterCommunicationService implementation. This
         // allows us to get a reference to the map's internal cluster message
         // allows us to get a reference to the map's internal cluster message

@@ -46,9 +46,8 @@ import static org.slf4j.LoggerFactory.getLogger;
 @Service
 @Service
 public class PersistenceManager implements PersistenceService {
 public class PersistenceManager implements PersistenceService {
 
 
-    private static final String DATABASE_PATH = "../data/localDB";
-
-    private static final String ENCLOSING_FOLDER = "../data";
+    private static final String DATABASE_PATH = System.getProperty("karaf.data", "./data/localDB");
+    private static final String ENCLOSING_FOLDER = System.getProperty("karaf.data", "./data");
 
 
     static final String MAP_PREFIX = "map:";
     static final String MAP_PREFIX = "map:";