Initial lifecycle state machine.

Basic state machine and initial functionality to
transition to the Active state via Engine commands and
StateUpdate messages.

Change-Id: I8212bd264dbbea446d4e682918f9360e3984887f
Issue-ID: POLICY-1608
Signed-off-by: Jorge Hernandez <jorge.hernandez-herrero@att.com>
Signed-off-by: jhh <jorge.hernandez-herrero@att.com>

6 files changed, 802 insertions, 0 deletions

diff --git a/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleStateActiveTest.java b/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleStateActiveTest.java
new file mode 100644
index 00000000..eb83bc61
--- /dev/null
+++ b/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleStateActiveTest.java
@@ -0,0 +1,191 @@
+/*
+ * ============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.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ * =============LICENSE_END========================================================
+ */
+
+package org.onap.policy.drools.lifecycle;
+
+import static org.assertj.core.api.Assertions.assertThatIllegalArgumentException;
+import static org.awaitility.Awaitility.await;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+
+import java.util.Arrays;
+import java.util.List;
+import java.util.concurrent.Callable;
+import java.util.concurrent.TimeUnit;
+import org.junit.AfterClass;
+import org.junit.Before;
+import org.junit.BeforeClass;
+import org.junit.Test;
+import org.onap.policy.common.utils.coder.CoderException;
+import org.onap.policy.common.utils.coder.StandardCoder;
+import org.onap.policy.drools.persistence.SystemPersistence;
+import org.onap.policy.drools.utils.logging.LoggerUtil;
+import org.onap.policy.models.pdp.concepts.PdpStateChange;
+import org.onap.policy.models.pdp.concepts.PdpStatus;
+import org.onap.policy.models.pdp.enums.PdpMessageType;
+import org.onap.policy.models.pdp.enums.PdpState;
+
+/**
+ * Lifecycle State Active Test.
+ */
+public class LifecycleStateActiveTest {
+
+    private LifecycleFsm fsm;
+
+    @BeforeClass
+    public static void setUp() {
+        SystemPersistence.manager.setConfigurationDir("src/test/resources");
+        LoggerUtil.setLevel("org.onap.policy.common.endpoints", "WARN");
+    }
+
+    @AfterClass
+    public static void tearDown() {
+        SystemPersistence.manager.setConfigurationDir(null);
+    }
+
+    /**
+     * Start tests in the Active state.
+     */
+    @Before
+    public void startActive() throws CoderException {
+        fsm = new LifecycleFsm();
+        fsm.setStatusTimerSeconds(15);
+        assertTrue(fsm.start());
+
+        goActive();
+        assertActive();
+    }
+
+    private void goActive() throws CoderException {
+        PdpStateChange change = new PdpStateChange();
+        change.setPdpGroup("A");
+        change.setPdpSubgroup("a");
+        change.setState(PdpState.ACTIVE);
+        change.setName("test");
+
+        fsm.source.offer(new StandardCoder().encode(change));
+    }
+
+    @Test
+    public void constructor() {
+        assertThatIllegalArgumentException().isThrownBy(() -> new LifecycleStateActive(null));
+        fsm.shutdown();
+    }
+
+    @Test
+    public void start() {
+        assertActive();
+        assertFalse(fsm.start());
+        assertActive();
+
+        fsm.shutdown();
+    }
+
+    private void assertActive() {
+        assertEquals(PdpState.ACTIVE, fsm.state());
+        assertEquals("A", fsm.getPdpGroup());
+        assertEquals("a", fsm.getPdpSubgroup());
+        assertTrue(fsm.isAlive());
+        await().atMost(fsm.getStatusTimerSeconds() + 1, TimeUnit.SECONDS).until(isStatus(PdpState.ACTIVE));
+    }
+
+    @Test
+    public void stop() {
+        assertTrue(fsm.stop());
+        assertBasicTerminated();
+
+        fsm.shutdown();
+    }
+
+    private void assertBasicTerminated() {
+        assertEquals(PdpState.TERMINATED, fsm.state());
+        assertFalse(fsm.isAlive());
+        assertFalse(fsm.state.isAlive());
+        await().atMost(1, TimeUnit.SECONDS).until(isStatus(PdpState.TERMINATED));
+    }
+
+    @Test
+    public void shutdown() {
+        fsm.shutdown();
+
+        assertBasicTerminated();
+
+        assertTrue(fsm.statusTask.isCancelled());
+        assertTrue(fsm.statusTask.isDone());
+    }
+
+    private Callable<Boolean> isStatus(PdpState state) {
+        return () -> {
+            if (fsm.client.getSink().getRecentEvents().length == 0) {
+                return false;
+            }
+
+            List<String> events = Arrays.asList(fsm.client.getSink().getRecentEvents());
+            PdpStatus status =
+                new StandardCoder().decode(events.get(events.size() - 1), PdpStatus.class);
+
+            return status.getMessageName() == PdpMessageType.PDP_STATUS && state == status.getState();
+        };
+    }
+
+    @Test
+    public void status() {
+        await().atMost(fsm.getStatusTimerSeconds() + 1, TimeUnit.SECONDS).until(isStatus(PdpState.ACTIVE));
+        int preCount = fsm.client.getSink().getRecentEvents().length;
+
+        assertTrue(fsm.status());
+        assertEquals(preCount + 1, fsm.client.getSink().getRecentEvents().length);
+
+        fsm.shutdown();
+    }
+
+    @Test
+    public void stateChange() throws CoderException {
+        assertActive();
+
+        /* dup */
+        PdpStateChange change = new PdpStateChange();
+        change.setPdpGroup("B");
+        change.setPdpSubgroup("b");
+        change.setState(PdpState.ACTIVE);
+        change.setName("test");
+
+        fsm.source.offer(new StandardCoder().encode(change));
+        assertEquals(PdpState.ACTIVE, fsm.state());
+        assertEquals("B", fsm.getPdpGroup());
+        assertEquals("b", fsm.getPdpSubgroup());
+
+        change.setState(PdpState.SAFE);
+        fsm.source.offer(new StandardCoder().encode(change));
+        assertEquals(PdpState.ACTIVE, fsm.state());
+
+        change.setState(PdpState.TERMINATED);
+        fsm.source.offer(new StandardCoder().encode(change));
+        assertEquals(PdpState.ACTIVE, fsm.state());
+
+        change.setState(PdpState.PASSIVE);
+        fsm.source.offer(new StandardCoder().encode(change));
+        assertEquals(PdpState.PASSIVE, fsm.state());
+        await().atMost(fsm.getStatusTimerSeconds() + 1, TimeUnit.SECONDS).until(isStatus(PdpState.PASSIVE));
+
+        fsm.shutdown();
+    }
+}
diff --git a/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleStatePassiveTest.java b/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleStatePassiveTest.java
new file mode 100644
index 00000000..fbc2eeba
--- /dev/null
+++ b/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleStatePassiveTest.java
@@ -0,0 +1,221 @@
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * 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.drools.lifecycle;
+
+import static org.assertj.core.api.Assertions.assertThatIllegalArgumentException;
+import static org.assertj.core.api.Assertions.assertThatThrownBy;
+import static org.awaitility.Awaitility.await;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertTrue;
+
+import java.util.concurrent.Callable;
+import java.util.concurrent.TimeUnit;
+import org.awaitility.core.ConditionTimeoutException;
+import org.junit.AfterClass;
+import org.junit.Before;
+import org.junit.BeforeClass;
+import org.junit.Test;
+import org.onap.policy.common.utils.coder.CoderException;
+import org.onap.policy.common.utils.coder.StandardCoder;
+import org.onap.policy.common.utils.network.NetworkUtil;
+import org.onap.policy.drools.persistence.SystemPersistence;
+import org.onap.policy.drools.utils.logging.LoggerUtil;
+import org.onap.policy.models.pdp.concepts.PdpStateChange;
+import org.onap.policy.models.pdp.concepts.PdpStatus;
+import org.onap.policy.models.pdp.enums.PdpHealthStatus;
+import org.onap.policy.models.pdp.enums.PdpMessageType;
+import org.onap.policy.models.pdp.enums.PdpState;
+
+/**
+ * Lifecycle State Passive Tests.
+ */
+public class LifecycleStatePassiveTest {
+
+    private LifecycleFsm fsm;
+
+    @BeforeClass
+    public static void setUp() {
+        SystemPersistence.manager.setConfigurationDir("src/test/resources");
+        LoggerUtil.setLevel("org.onap.policy.common.endpoints", "WARN");
+    }
+
+    @AfterClass
+    public static void tearDown() {
+        SystemPersistence.manager.setConfigurationDir(null);
+    }
+
+    /**
+     * Start tests in the Passive state.
+     */
+    @Before
+    public void startPassive() {
+        /* start every test in passive mode */
+        fsm = new LifecycleFsm();
+        fsm.setStatusTimerSeconds(15L);
+        simpleStart();
+
+        assertEquals(0, fsm.client.getSink().getRecentEvents().length);
+    }
+
+    @Test
+    public void constructor() {
+        assertThatIllegalArgumentException().isThrownBy(() -> new LifecycleStatePassive(null));
+        fsm.shutdown();
+    }
+
+    @Test
+    public void start() {
+        assertEquals(0, fsm.client.getSink().getRecentEvents().length);
+        assertFalse(fsm.start());
+        assertBasicPassive();
+
+        fsm.shutdown();
+    }
+
+    private Callable<Boolean> isStatus(PdpState state, int count) {
+        return () -> {
+            if (!fsm.client.getSink().isAlive()) {
+                return false;
+            }
+
+            if (fsm.client.getSink().getRecentEvents().length != count) {
+                return false;
+            }
+
+            String[] events = fsm.client.getSink().getRecentEvents();
+            PdpStatus status =
+                new StandardCoder().decode(events[events.length - 1], PdpStatus.class);
+
+            return status.getMessageName() == PdpMessageType.PDP_STATUS && state == status.getState();
+        };
+    }
+
+    @Test
+    public void stop() {
+        simpleStop();
+        assertBasicTerminated();
+    }
+
+    private void simpleStart() {
+        assertTrue(fsm.start());
+        assertBasicPassive();
+    }
+
+    private void simpleStop() {
+        assertTrue(fsm.stop());
+        assertBasicTerminated();
+    }
+
+    @Test
+    public void shutdown() throws CoderException {
+        simpleStop();
+
+        fsm.shutdown();
+        assertExtendedTerminated();
+    }
+
+    @Test
+    public void status() {
+        status(PdpState.PASSIVE);
+        fsm.shutdown();
+    }
+
+    private void status(PdpState state) {
+        await()
+            .atMost(5, TimeUnit.SECONDS)
+            .until(isStatus(state, 1));
+
+        await()
+            .atMost(fsm.statusTimerSeconds + 2, TimeUnit.SECONDS)
+            .until(isStatus(state, 2));
+
+        await()
+            .atMost(fsm.statusTimerSeconds + 2, TimeUnit.SECONDS)
+            .until(isStatus(state, 3));
+
+        assertTrue(fsm.status());
+        await()
+            .atMost(200, TimeUnit.MILLISECONDS)
+            .until(isStatus(state, 4));
+    }
+
+    @Test
+    public void update() {
+        // TODO
+        fsm.shutdown();
+    }
+
+    @Test
+    public void stateChange() throws CoderException {
+        PdpStateChange change = new PdpStateChange();
+        change.setPdpGroup("A");
+        change.setPdpSubgroup("a");
+        change.setState(PdpState.ACTIVE);
+        change.setName("test");
+
+        fsm.source.offer(new StandardCoder().encode(change));
+        assertEquals(PdpState.ACTIVE, fsm.state.state());
+        assertEquals("A", fsm.pdpGroup);
+        assertEquals("a", fsm.pdpSubgroup);
+
+        fsm.shutdown();
+    }
+
+    private void assertBasicTerminated() {
+        assertEquals(PdpState.TERMINATED, fsm.state.state());
+        assertFalse(fsm.isAlive());
+        assertFalse(fsm.state.isAlive());
+    }
+
+    private void assertExtendedTerminated() throws CoderException {
+        assertBasicTerminated();
+        assertTrue(fsm.statusTask.isCancelled());
+        assertTrue(fsm.statusTask.isDone());
+
+        assertEquals(1, fsm.client.getSink().getRecentEvents().length);
+        PdpStatus status = new StandardCoder().decode(fsm.client.getSink().getRecentEvents()[0], PdpStatus.class);
+        assertEquals("drools", status.getPdpType());
+        assertEquals(PdpState.TERMINATED, status.getState());
+        assertEquals(PdpHealthStatus.HEALTHY, status.getHealthy());
+        assertEquals(NetworkUtil.getHostname(), status.getInstance());
+        assertEquals(PdpMessageType.PDP_STATUS, status.getMessageName());
+
+        assertThatThrownBy( () -> await()
+            .atMost(fsm.statusTimerSeconds + 5, TimeUnit.SECONDS)
+            .until(isStatus(PdpState.TERMINATED, 2))).isInstanceOf(ConditionTimeoutException.class);
+    }
+
+    private void assertBasicPassive() {
+        assertEquals(PdpState.PASSIVE, fsm.state.state());
+        assertNotNull(fsm.source);
+        assertNotNull(fsm.client);
+        assertNotNull(fsm.statusTask);
+
+        assertTrue(fsm.isAlive());
+        assertTrue(fsm.source.isAlive());
+        assertTrue(fsm.client.getSink().isAlive());
+
+        assertFalse(fsm.statusTask.isCancelled());
+        assertFalse(fsm.statusTask.isDone());
+    }
+}
diff --git a/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleStateSafeTest.java b/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleStateSafeTest.java
new file mode 100644
index 00000000..81ce85f1
--- /dev/null
+++ b/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleStateSafeTest.java
@@ -0,0 +1,52 @@
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * 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.drools.lifecycle;
+
+import static org.junit.Assert.assertEquals;
+
+import org.junit.Test;
+import org.onap.policy.models.pdp.enums.PdpState;
+
+/**
+ * TEST State Junits.
+ */
+public class LifecycleStateSafeTest extends LifecycleStateUnsupportedTest {
+
+    public LifecycleStateSafeTest() {
+        super(new LifecycleStateSafe(new LifecycleFsm()));
+    }
+
+    @Override
+    public LifecycleState create(LifecycleFsm fsm) {
+        return new LifecycleStateSafe(fsm);
+    }
+
+    @Test
+    public void constructor() {
+        super.constructor();
+        assertEquals(PdpState.SAFE, new LifecycleStateSafe(new LifecycleFsm()).state());
+    }
+
+    @Test
+    public void state() {
+        assertEquals(PdpState.SAFE, state.state());
+    }
+}
\ No newline at end of file
diff --git a/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleStateTerminatedTest.java b/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleStateTerminatedTest.java
new file mode 100644
index 00000000..b77fdcd9
--- /dev/null
+++ b/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleStateTerminatedTest.java
@@ -0,0 +1,178 @@
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * 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.drools.lifecycle;
+
+import static org.assertj.core.api.Assertions.assertThatIllegalArgumentException;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertNull;
+import static org.junit.Assert.assertTrue;
+
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
+import org.junit.Test;
+import org.onap.policy.drools.persistence.SystemPersistence;
+import org.onap.policy.drools.utils.logging.LoggerUtil;
+import org.onap.policy.models.pdp.concepts.PdpStateChange;
+import org.onap.policy.models.pdp.enums.PdpState;
+
+/**
+ * Lifecycle State Terminated Tests.
+ */
+public class LifecycleStateTerminatedTest {
+    private LifecycleFsm fsm = new LifecycleFsm();
+
+    @BeforeClass
+    public static void setUp() {
+        SystemPersistence.manager.setConfigurationDir("src/test/resources");
+        LoggerUtil.setLevel("org.onap.policy.common.endpoints", "WARN");
+    }
+
+    @AfterClass
+    public static void tearDown() {
+        SystemPersistence.manager.setConfigurationDir(null);
+    }
+
+    @Test
+    public void constructor() {
+        assertThatIllegalArgumentException().isThrownBy(() -> new LifecycleStateTerminated(null));
+
+        LifecycleState state = new LifecycleStateTerminated(new LifecycleFsm());
+        assertNull(state.fsm.source);
+        assertNull(state.fsm.client);
+        assertNull(state.fsm.statusTask);
+
+        assertEquals(PdpState.TERMINATED, state.state());
+        assertEquals(PdpState.TERMINATED, state.fsm.state.state());
+        assertFalse(state.isAlive());
+    }
+
+    @Test
+    public void stop() {
+        assertEquals(PdpState.TERMINATED, fsm.state.state());
+        assertFalse(fsm.isAlive());
+
+        simpleStop();
+    }
+
+    private void simpleStart() {
+        assertTrue(fsm.start());
+        assertBasicPassive();
+    }
+
+    private void simpleStop() {
+        assertTrue(fsm.stop());
+        assertBasicTerminated();
+    }
+
+    @Test
+    public void bounce() {
+        assertBasicTerminated();
+        simpleStart();
+        simpleStop();
+
+        assertFalse(fsm.source.isAlive());
+        assertFalse(fsm.client.getSink().isAlive());
+        assertExtendedTerminated();
+    }
+
+    @Test
+    public void doubleBounce() {
+        bounce();
+        bounce();
+    }
+
+    @Test
+    public void doubleStartBounce() {
+        simpleStart();
+        assertFalse(fsm.start());
+        assertBasicPassive();
+        simpleStop();
+    }
+
+    @Test
+    public void shutdown() {
+        assertBasicTerminated();
+        fsm.shutdown();
+        assertBasicTerminated();
+
+        fsm = new LifecycleFsm();
+    }
+
+    @Test
+    public void status() {
+        assertBasicTerminated();
+        assertFalse(fsm.status());
+        assertBasicTerminated();
+    }
+
+    @Test
+    public void changeState() {
+        assertFalse(fsm.state.transitionToState(new LifecycleStateTerminated(fsm)));
+        assertEquals(PdpState.TERMINATED, fsm.state.state());
+    }
+
+    @Test
+    public void update() {
+        // TODO
+    }
+
+    @Test
+    public void stateChange() {
+        PdpStateChange change = new PdpStateChange();
+        change.setPdpGroup("A");
+        change.setPdpSubgroup("a");
+        change.setState(PdpState.ACTIVE);
+        change.setName("test");
+
+        fsm.stateChange(change);
+
+        assertEquals(PdpState.TERMINATED, fsm.state.state());
+    }
+
+    private void assertBasicTerminated() {
+        assertEquals(PdpState.TERMINATED, fsm.state.state());
+        assertFalse(fsm.isAlive());
+        assertFalse(fsm.state.isAlive());
+    }
+
+    private void assertExtendedTerminated() {
+        assertBasicTerminated();
+        assertTrue(fsm.statusTask.isCancelled());
+        assertTrue(fsm.statusTask.isDone());
+        assertFalse(fsm.scheduler.isShutdown());
+    }
+
+    private void assertBasicPassive() {
+        assertEquals(PdpState.PASSIVE, fsm.state.state());
+        assertNotNull(fsm.source);
+        assertNotNull(fsm.client);
+        assertNotNull(fsm.statusTask);
+
+        assertTrue(fsm.isAlive());
+        assertTrue(fsm.source.isAlive());
+        assertTrue(fsm.client.getSink().isAlive());
+
+        assertFalse(fsm.statusTask.isCancelled());
+        assertFalse(fsm.statusTask.isDone());
+    }
+}
\ No newline at end of file
diff --git a/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleStateTestTest.java b/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleStateTestTest.java
new file mode 100644
index 00000000..c086dfb4
--- /dev/null
+++ b/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleStateTestTest.java
@@ -0,0 +1,52 @@
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * 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.drools.lifecycle;
+
+import static org.junit.Assert.assertEquals;
+
+import org.junit.Test;
+import org.onap.policy.models.pdp.enums.PdpState;
+
+/**
+ * TEST State Junits.
+ */
+public class LifecycleStateTestTest extends LifecycleStateUnsupportedTest {
+
+    public LifecycleStateTestTest() {
+        super(new LifecycleStateTest(new LifecycleFsm()));
+    }
+
+    @Override
+    public LifecycleState create(LifecycleFsm fsm) {
+        return new LifecycleStateTest(fsm);
+    }
+
+    @Test
+    public void constructor() {
+        super.constructor();
+        assertEquals(PdpState.TEST, new LifecycleStateTest(new LifecycleFsm()).state());
+    }
+
+    @Test
+    public void state() {
+        assertEquals(PdpState.TEST, state.state());
+    }
+}
\ No newline at end of file
diff --git a/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleStateUnsupportedTest.java b/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleStateUnsupportedTest.java
new file mode 100644
index 00000000..01efca32
--- /dev/null
+++ b/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleStateUnsupportedTest.java
@@ -0,0 +1,108 @@
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP
+ * ================================================================================
+ * 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.drools.lifecycle;
+
+import static org.assertj.core.api.Assertions.assertThatIllegalArgumentException;
+import static org.assertj.core.api.Java6Assertions.assertThatThrownBy;
+
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
+import org.junit.Test;
+import org.onap.policy.drools.persistence.SystemPersistence;
+import org.onap.policy.models.pdp.concepts.PdpStateChange;
+import org.onap.policy.models.pdp.concepts.PdpUpdate;
+
+/**
+ * Lifecycle State Unsupported Test.
+ */
+public abstract class LifecycleStateUnsupportedTest {
+
+    protected final LifecycleState state;
+
+    @BeforeClass
+    public static void setUp() {
+        SystemPersistence.manager.setConfigurationDir("src/test/resources");
+    }
+
+    @AfterClass
+    public static void tearDown() {
+        SystemPersistence.manager.setConfigurationDir(null);
+    }
+
+    public LifecycleStateUnsupportedTest(LifecycleState state) {
+        this.state = state;
+    }
+
+    public abstract LifecycleState create(LifecycleFsm fsm);
+
+    @Test
+    public void constructor() {
+        assertThatIllegalArgumentException().isThrownBy(() -> create(null));
+    }
+
+    @Test
+    public void start() {
+        assertThatThrownBy(() -> state.start())
+            .isInstanceOf(UnsupportedOperationException.class);
+    }
+
+    @Test
+    public void stop() {
+        assertThatThrownBy(() -> state.stop())
+            .isInstanceOf(UnsupportedOperationException.class);
+    }
+
+    @Test
+    public void shutdown() {
+        assertThatThrownBy(() -> state.shutdown())
+            .isInstanceOf(UnsupportedOperationException.class);
+    }
+
+    @Test
+    public void isAlive() {
+        assertThatThrownBy(() -> state.isAlive())
+            .isInstanceOf(UnsupportedOperationException.class);
+    }
+
+    @Test
+    public void status() {
+        assertThatThrownBy(() -> state.status())
+            .isInstanceOf(UnsupportedOperationException.class);
+    }
+
+    @Test
+    public void update() {
+        assertThatThrownBy(() -> state.update(new PdpUpdate()))
+            .isInstanceOf(UnsupportedOperationException.class);
+    }
+
+    @Test
+    public void stateChange() {
+        assertThatThrownBy(() -> state.stateChange(new PdpStateChange()))
+            .isInstanceOf(UnsupportedOperationException.class);
+    }
+
+    @Test
+    public void changeState() {
+        assertThatThrownBy(() -> state.transitionToState(new LifecycleStateActive(new LifecycleFsm())))
+            .isInstanceOf(UnsupportedOperationException.class);
+    }
+}