1 files changed, 0 insertions, 288 deletions
diff --git a/controlloop/common/database/src/test/java/org/onap/policy/database/operationshistory/CountRecentOperationsPipTest.java b/controlloop/common/database/src/test/java/org/onap/policy/database/operationshistory/CountRecentOperationsPipTest.java
deleted file mode 100644
index 66b412028..000000000
--- a/controlloop/common/database/src/test/java/org/onap/policy/database/operationshistory/CountRecentOperationsPipTest.java
+++ /dev/null
@@ -1,288 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
-  * Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * 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.
- * ============LICENSE_END=========================================================
- */
-
-package org.onap.policy.database.operationshistory;
-
-import static org.junit.Assert.assertEquals;
-import static org.mockito.ArgumentMatchers.any;
-import static org.mockito.ArgumentMatchers.anyInt;
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.when;
-
-import com.att.research.xacml.api.Attribute;
-import com.att.research.xacml.api.AttributeValue;
-import com.att.research.xacml.api.XACML3;
-import com.att.research.xacml.api.pip.PIPException;
-import com.att.research.xacml.api.pip.PIPFinder;
-import com.att.research.xacml.api.pip.PIPRequest;
-import com.att.research.xacml.api.pip.PIPResponse;
-import com.att.research.xacml.std.pip.StdPIPResponse;
-import java.io.FileInputStream;
-import java.sql.Date;
-import java.time.Instant;
-import java.util.Collection;
-import java.util.Properties;
-import java.util.UUID;
-import javax.persistence.EntityManager;
-import javax.persistence.EntityManagerFactory;
-import javax.persistence.Persistence;
-import javax.persistence.Query;
-import org.junit.AfterClass;
-import org.junit.Before;
-import org.junit.BeforeClass;
-import org.junit.Test;
-import org.onap.policy.database.ToscaDictionary;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class CountRecentOperationsPipTest {
-    private static final String ID = "issuer";
-    private static final Logger LOGGER = LoggerFactory.getLogger(CountRecentOperationsPipTest.class);
-    private static final String ISSUER = ToscaDictionary.GUARD_ISSUER_PREFIX + "-my-issuer:tw:1:HOUR";
-    private static final String ACTOR = "Controller";
-    private static final String RECIPE = "operationA";
-    private static final String TARGET = "vnf-1";
-    private static final String EXPECTED_EXCEPTION = "expected exception";
-
-    private static MyPip pipEngine;
-    private static Properties properties;
-
-    private static EntityManagerFactory emf;
-    private static EntityManager em;
-
-    private PIPRequest req;
-
-    /**
-     * Create an instance of our engine and also the persistence
-     * factory.
-     *
-     * @throws Exception connectivity issues
-     */
-    @BeforeClass
-    public static void setUpBeforeClass() throws Exception {
-        LOGGER.info("Setting up PIP Testing");
-        //
-        // Create instance
-        //
-        pipEngine = new MyPip();
-        //
-        // Load our test properties to use
-        //
-        properties = new Properties();
-        try (FileInputStream is = new FileInputStream("src/test/resources/test.properties")) {
-            properties.load(is);
-        }
-        //
-        // Configure it using properties
-        //
-        pipEngine.configure(ID, properties);
-        LOGGER.info("PIP configured now creating our entity manager");
-        LOGGER.info("properties {}", properties);
-        //
-        // Connect to in-mem db
-        //
-        String persistenceUnit = CountRecentOperationsPip.ISSUER_NAME + ".persistenceunit";
-        LOGGER.info("persistenceunit {}", persistenceUnit);
-        emf = Persistence.createEntityManagerFactory(properties.getProperty(persistenceUnit), properties);
-        em = emf.createEntityManager();
-        //
-        //
-        //
-        LOGGER.info("Configured own entity manager");
-    }
-
-    @Before
-    public void setUp() {
-        req = mock(PIPRequest.class);
-        when(req.getIssuer()).thenReturn(ISSUER);
-    }
-
-    private Dbao createEntry(String cl, String target, String outcome) {
-        //
-        // Create entry
-        //
-        Dbao newEntry = new Dbao();
-        newEntry.setClosedLoopName(cl);
-        newEntry.setTarget(target);
-        newEntry.setOutcome(outcome);
-        newEntry.setActor(ACTOR);
-        newEntry.setOperation(RECIPE);
-        newEntry.setStarttime(Date.from(Instant.now().minusMillis(20000)));
-        newEntry.setEndtime(Date.from(Instant.now()));
-        newEntry.setRequestId(UUID.randomUUID().toString());
-        return newEntry;
-    }
-
-    @Test
-    public void testAttributesRequired() {
-        assertEquals(3, pipEngine.attributesRequired().size());
-    }
-
-    @Test
-    public void testGetAttributes_InvalidRequestInfo() throws PIPException {
-        // invalid request - null issuer
-        when(req.getIssuer()).thenReturn(null);
-        assertEquals(StdPIPResponse.PIP_RESPONSE_EMPTY, pipEngine.getAttributes(req, null));
-
-        /*
-         * Make a valid issuer in the request, for subsequent tests.
-         */
-        when(req.getIssuer()).thenReturn(ISSUER);
-
-        // null actor
-        MyPip pip = new MyPip() {
-            @Override
-            protected String getActor(PIPFinder pipFinder) {
-                return null;
-            }
-        };
-        pip.configure(ID, properties);
-        assertEquals(StdPIPResponse.PIP_RESPONSE_EMPTY, pip.getAttributes(req, null));
-
-        // null recipe
-        pip = new MyPip() {
-            @Override
-            protected String getRecipe(PIPFinder pipFinder) {
-                return null;
-            }
-        };
-        pip.configure(ID, properties);
-        assertEquals(StdPIPResponse.PIP_RESPONSE_EMPTY, pip.getAttributes(req, null));
-
-        // null target
-        pip = new MyPip() {
-            @Override
-            protected String getTarget(PIPFinder pipFinder) {
-                return null;
-            }
-        };
-        pip.configure(ID, properties);
-        assertEquals(StdPIPResponse.PIP_RESPONSE_EMPTY, pip.getAttributes(req, null));
-    }
-
-    @Test
-    public void testDoDatabaseQuery() throws Exception {
-
-        //
-        // No entries yet
-        //
-        assertEquals(0, getCount(pipEngine.getAttributes(req, null)));
-        //
-        // Add entry
-        //
-        em.getTransaction().begin();
-        em.persist(createEntry("cl-foobar-1", TARGET, "SUCCESS"));
-        em.getTransaction().commit();
-        //
-        // Directly check ground truth
-        //
-        Query queryCount = em.createNativeQuery("select count(*) as numops from operationshistory")
-                .setParameter(1, 1);
-        LOGGER.info("{} entries", queryCount.getSingleResult());
-        //
-        // Should count 1 entry now
-        //
-        assertEquals(1, getCount(pipEngine.getAttributes(req, null)));
-    }
-
-    @Test
-    public void testDoDatabaseQuery_InvalidTimeWindow() throws Exception {
-        when(req.getIssuer()).thenReturn(ISSUER + "invalid time window");
-
-        assertEquals(-1, getCount(pipEngine.getAttributes(req, null)));
-    }
-
-    @Test
-    public void testDoDatabaseQuery_NullEm() throws Exception {
-        assertEquals(-1, getCount(new MyPip().getAttributes(req, null)));
-    }
-
-    @Test
-    public void testDoDatabaseQuery_EmException() throws Exception {
-        MyPip pip = new MyPip() {
-            @Override
-            public void configure(String id, Properties properties) throws PIPException {
-                em = mock(EntityManager.class);
-                when(em.createNativeQuery(any())).thenThrow(new RuntimeException(EXPECTED_EXCEPTION));
-            }
-        };
-        pip.configure(ID, properties);
-
-        assertEquals(-1, getCount(pip.getAttributes(req, null)));
-    }
-
-    @Test
-    public void testDoDatabaseQuery_NonNumeric() throws Exception {
-        MyPip pip = new MyPip() {
-            @Override
-            public void configure(String id, Properties properties) throws PIPException {
-                em = mock(EntityManager.class);
-                Query query = mock(Query.class);
-                when(em.createNativeQuery(any())).thenReturn(query);
-                when(query.setParameter(anyInt(), any())).thenReturn(query);
-                when(query.getSingleResult()).thenReturn("200");
-            }
-        };
-        pip.configure(ID, properties);
-
-        assertEquals(200, getCount(pip.getAttributes(req, null)));
-    }
-
-    private int getCount(PIPResponse resp) {
-        Collection<Attribute> attrs = resp.getAttributes();
-        assertEquals(1, attrs.size());
-
-        Attribute attr = attrs.iterator().next();
-        assertEquals(XACML3.ID_ATTRIBUTE_CATEGORY_RESOURCE, attr.getCategory());
-        assertEquals(ToscaDictionary.ID_RESOURCE_GUARD_OPERATIONCOUNT, attr.getAttributeId());
-
-        Collection<AttributeValue<?>> values = attr.getValues();
-        assertEquals(1, values.size());
-
-        AttributeValue<?> value = values.iterator().next();
-        return ((Number) value.getValue()).intValue();
-    }
-
-    /**
-     * Close the entity manager.
-     */
-    @AfterClass
-    public static void cleanup() {
-        if (emf != null) {
-            emf.close();
-        }
-    }
-
-    private static class MyPip extends CountRecentOperationsPip {
-
-        @Override
-        protected String getActor(PIPFinder pipFinder) {
-            return ACTOR;
-        }
-
-        @Override
-        protected String getRecipe(PIPFinder pipFinder) {
-            return RECIPE;
-        }
-
-        @Override
-        protected String getTarget(PIPFinder pipFinder) {
-            return TARGET;
-        }
-    }
-}