package jmri.jmrit.logixng.implementation;

import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;

import java.beans.*;
import java.io.*;
import java.util.*;

import jmri.*;
import jmri.jmrit.logixng.*;
import jmri.util.JUnitUtil;

import org.apache.commons.lang3.mutable.MutableInt;

import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;

import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.catchThrowable;

import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertTrue;

/**
 * Test AbstractFemaleSocket
 *
 * @author Daniel Bergqvist 2020
 */
public class AbstractFemaleSocketTest {

    private FemaleSocketListener _listener;
/*
    @Test
    public void testPropertyChangeListeners() {
        MyFemaleSocket socket = new MyFemaleSocket(null, null, "A1");

        boolean hasThrown = false;
        try {
            socket.addPropertyChangeListener(null);
        } catch (UnsupportedOperationException e) {
            hasThrown = true;
            Assert.assertEquals("Error message is correct", "Not supported", e.getMessage());
        }
        Assert.assertTrue("Exception thrown", hasThrown);

        hasThrown = false;
        try {
            socket.addPropertyChangeListener("", null);
        } catch (UnsupportedOperationException e) {
            hasThrown = true;
            Assert.assertEquals("Error message is correct", "Not supported", e.getMessage());
        }
        Assert.assertTrue("Exception thrown", hasThrown);

        hasThrown = false;
        try {
            socket.getPropertyChangeListeners();
        } catch (UnsupportedOperationException e) {
            hasThrown = true;
            Assert.assertEquals("Error message is correct", "Not supported", e.getMessage());
        }
        Assert.assertTrue("Exception thrown", hasThrown);

        hasThrown = false;
        try {
            socket.getPropertyChangeListeners("");
        } catch (UnsupportedOperationException e) {
            hasThrown = true;
            Assert.assertEquals("Error message is correct", "Not supported", e.getMessage());
        }
        Assert.assertTrue("Exception thrown", hasThrown);

        hasThrown = false;
        try {
            socket.removePropertyChangeListener(null);
        } catch (UnsupportedOperationException e) {
            hasThrown = true;
            Assert.assertEquals("Error message is correct", "Not supported", e.getMessage());
        }
        Assert.assertTrue("Exception thrown", hasThrown);

        hasThrown = false;
        try {
            socket.removePropertyChangeListener("", null);
        } catch (UnsupportedOperationException e) {
            hasThrown = true;
            Assert.assertEquals("Error message is correct", "Not supported", e.getMessage());
        }
        Assert.assertTrue("Exception thrown", hasThrown);
    }
*/
    @Test
    public void testIsActive() {
        MyBase base = new MyBase();
        MyFemaleSocket socket = new MyFemaleSocket(base, _listener, "A1");

        // Check isActive when parent is not null

        assertNotNull( socket.getParent(), "Parent is not null");

        base._active = false;
        socket._enabled = false;
        assertFalse( socket.isActive(), "Socket is not active");

        base._active = true;
        socket._enabled = false;
        assertFalse( socket.isActive(), "Socket is not active");

        base._active = false;
        socket._enabled = true;
        assertFalse( socket.isActive(), "Socket is not active");

        base._active = true;
        socket._enabled = true;
        assertTrue( socket.isActive(), "Socket is active");

/*
        // Check isActive when parent is null

        socket.setParent(null);
        Assert.assertNull("Parent is null", socket.getParent());

        socket._enabled = false;
        Assert.assertFalse("Socket is not active", socket.isActive());

        socket._enabled = true;
        Assert.assertTrue("Socket is active", socket.isActive());
*/
    }

    @Test
    public void testUnsupportedMethods() {
        MyBase base = new MyBase();
        MyFemaleSocket socket = new MyFemaleSocket(base, _listener, "A1");

        PropertyChangeListener l = (PropertyChangeEvent evt) -> {};

        Throwable thrown = catchThrowable( () -> socket.addPropertyChangeListener(l, "name", "ref"));
        assertThat(thrown)
                .withFailMessage("Method throws an exception")
                .isNotNull()
                .isInstanceOf(UnsupportedOperationException.class)
                .hasMessage("Not supported");

        thrown = catchThrowable( () -> socket.addPropertyChangeListener("propName", l, "name", "ref"));
        assertThat(thrown)
                .withFailMessage("Method throws an exception")
                .isNotNull()
                .isInstanceOf(UnsupportedOperationException.class)
                .hasMessage("Not supported");

        thrown = catchThrowable( () -> socket.updateListenerRef(l, "name"));
        assertThat(thrown)
                .withFailMessage("Method throws an exception")
                .isNotNull()
                .isInstanceOf(UnsupportedOperationException.class)
                .hasMessage("Not supported");

        thrown = catchThrowable( () -> passNullVetoableChangeToSocket(socket));
        assertThat(thrown)
                .withFailMessage("Method throws an exception")
                .isNotNull()
                .isInstanceOf(UnsupportedOperationException.class)
                .hasMessage("Not supported");

        thrown = catchThrowable( () -> socket.getListenerRef(l));
        assertThat(thrown)
                .withFailMessage("Method throws an exception")
                .isNotNull()
                .isInstanceOf(UnsupportedOperationException.class)
                .hasMessage("Not supported");

        thrown = catchThrowable( () -> socket.getListenerRefs());
        assertThat(thrown)
                .withFailMessage("Method throws an exception")
                .isNotNull()
                .isInstanceOf(UnsupportedOperationException.class)
                .hasMessage("Not supported");
/*
        thrown = catchThrowable( () -> socket.getNumPropertyChangeListeners());
        assertThat(thrown)
                .withFailMessage("Method throws an exception")
                .isNotNull()
                .isInstanceOf(UnsupportedOperationException.class)
                .hasMessage("Not supported");
*/
        thrown = catchThrowable( () -> socket.getPropertyChangeListenersByReference("ref"));
        assertThat(thrown)
                .withFailMessage("Method throws an exception")
                .isNotNull()
                .isInstanceOf(UnsupportedOperationException.class)
                .hasMessage("Not supported");
    }

    @SuppressFBWarnings( value = "NP_NONNULL_PARAM_VIOLATION",
            justification = "Passing null to test exception handling")
    private void passNullVetoableChangeToSocket( MyFemaleSocket socket ) throws PropertyVetoException {
        socket.vetoableChange(null);
    }

    @BeforeEach
    public void setUp() {
        JUnitUtil.setUp();
        JUnitUtil.resetInstanceManager();
        JUnitUtil.resetProfileManager();
        JUnitUtil.initConfigureManager();
        JUnitUtil.initInternalSensorManager();
        JUnitUtil.initInternalTurnoutManager();
        JUnitUtil.initLogixNGManager();
        _listener = new FemaleSocketListener(){
            @Override
            public void connected(FemaleSocket socket) {
                // Do nothing
            }

            @Override
            public void disconnected(FemaleSocket socket) {
                // Do nothing
            }
        };
    }

    @AfterEach
    public void tearDown() {
        _listener = null;
        jmri.jmrit.logixng.util.LogixNG_Thread.stopAllLogixNGThreads();
        JUnitUtil.deregisterBlockManagerShutdownTask();
        JUnitUtil.tearDown();
    }


    private static class MyFemaleSocket extends AbstractFemaleSocket {

        boolean _enabled = false;

        MyFemaleSocket(Base parent, FemaleSocketListener listener, String name) {
            super(parent, listener, name);
        }

        @Override
        public boolean isEnabled() {
            return _enabled;
        }

        @Override
        public void disposeMe() {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public boolean isCompatible(MaleSocket socket) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public Map<Category, List<Class<? extends Base>>> getConnectableClasses() {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public String getShortDescription(Locale locale) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public String getLongDescription(Locale locale) {
            throw new UnsupportedOperationException("Not supported");
        }

    }


    private static class MyBase implements Base {

        boolean _active = false;

        @Override
        public boolean isActive() {
            return _active;
        }

        @Override
        public String getSystemName() {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public String getUserName() {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public void setUserName(String s) throws NamedBean.BadUserNameException {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public String getComment() {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public void setComment(String s) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public String getShortDescription(Locale locale) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public String getLongDescription(Locale locale) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public ConditionalNG getConditionalNG() {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public LogixNG getLogixNG() {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public Base getRoot() {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public Base getParent() {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public void setParent(Base parent) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public boolean setParentForAllChildren(List<String> errors) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public FemaleSocket getChild(int index) throws IllegalArgumentException, UnsupportedOperationException {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public int getChildCount() {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public Category getCategory() {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public void setup() {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public void dispose() {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public void printTree(PrintTreeSettings settings, PrintWriter writer, String indent, MutableInt lineNumber) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public void printTree(PrintTreeSettings settings, Locale locale, PrintWriter writer, String indent, MutableInt lineNumber) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public void printTree(PrintTreeSettings settings, Locale locale, PrintWriter writer, String indent, String currentIndent, MutableInt lineNumber) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public void addPropertyChangeListener(PropertyChangeListener listener) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public void addPropertyChangeListener(String propertyName, PropertyChangeListener listener) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public PropertyChangeListener[] getPropertyChangeListeners() {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public PropertyChangeListener[] getPropertyChangeListeners(String propertyName) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public void removePropertyChangeListener(PropertyChangeListener listener) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public void removePropertyChangeListener(String propertyName, PropertyChangeListener listener) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public void addPropertyChangeListener(PropertyChangeListener listener, String name, String listenerRef) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public void addPropertyChangeListener(String propertyName, PropertyChangeListener listener, String name, String listenerRef) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public void updateListenerRef(PropertyChangeListener l, String newName) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public void vetoableChange(PropertyChangeEvent evt) throws PropertyVetoException {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public String getListenerRef(PropertyChangeListener l) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public ArrayList<String> getListenerRefs() {
            throw new UnsupportedOperationException("Not supported");
        }

        /** {@inheritDoc} */
        @Override
        public void getListenerRefsIncludingChildren(List<String> list) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public int getNumPropertyChangeListeners() {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public PropertyChangeListener[] getPropertyChangeListenersByReference(String name) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public void registerListeners() {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public void unregisterListeners() {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public Base getDeepCopy(Map<String, String> map, Map<String, String> map1) throws JmriException {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public Base deepCopyChildren(Base base, Map<String, String> map, Map<String, String> map1) throws JmriException {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public void getUsageDetail(int level, NamedBean bean, List<jmri.NamedBeanUsageReport> report, NamedBean cdl) {
            throw new UnsupportedOperationException("Not supported");
        }

        @Override
        public void getUsageTree(int level, NamedBean bean, List<jmri.NamedBeanUsageReport> report, NamedBean cdl) {
            throw new UnsupportedOperationException("Not supported");
        }
    }

}