Serge NOEL
260 lines
10 KiB
Java
260 lines
10 KiB
Java
package jmri.jmrit.logixng.actions;
|
|
|
|
import static org.junit.jupiter.api.Assertions.assertEquals;
|
|
import static org.junit.jupiter.api.Assertions.assertNotNull;
|
|
import static org.junit.jupiter.api.Assertions.assertSame;
|
|
import static org.junit.jupiter.api.Assertions.assertThrows;
|
|
|
|
import java.io.IOException;
|
|
|
|
import jmri.*;
|
|
import jmri.jmrit.logixng.*;
|
|
import jmri.jmrit.logixng.implementation.DefaultConditionalNGScaffold;
|
|
import jmri.jmrit.logixng.util.parser.ParserException;
|
|
import jmri.util.JUnitUtil;
|
|
|
|
import org.junit.jupiter.api.AfterEach;
|
|
import org.junit.jupiter.api.BeforeEach;
|
|
import org.junit.jupiter.api.Test;
|
|
|
|
/**
|
|
* Test JsonDecode
|
|
*
|
|
* @author Daniel Bergqvist 2024
|
|
*/
|
|
public class JsonDecodeTest extends AbstractDigitalActionTestBase {
|
|
|
|
private static final String JSON_STRING = String.format(
|
|
"{%n" +
|
|
" \"id\":\"tk\",%n" +
|
|
" \"config\":{%n" +
|
|
" \"signature\":\"TK\",%n" +
|
|
" \"name\":\"Tr\\u00e4kvista\",%n" +
|
|
" \"destinations\":2,%n" +
|
|
" \"destination\":{%n" +
|
|
" \"A\":{%n" +
|
|
" \"tracks\":1,%n" +
|
|
" \"type\":\"single\",%n" +
|
|
" \"single\":{%n" +
|
|
" \"id\":\"blo\",%n" +
|
|
" \"tracks\":1,%n" +
|
|
" \"exit\":\"B\",%n" +
|
|
" \"track\":\"left\",%n" +
|
|
" \"distance\":1,%n" +
|
|
" \"list\":[\"a\",\"b\",\"c\",\"d\",\"e\",\"f\",\"g\"],%n" +
|
|
" \"signature\":\"BLO\",%n" +
|
|
" \"name\":\"Bilbo\",%n" +
|
|
" \"signalin\":\"22\",%n" +
|
|
" \"signalout\":\"U1\",%n" +
|
|
" \"blockout\":\"sa1\"%n" +
|
|
" }" +
|
|
" }%n" +
|
|
" },%n" +
|
|
" \"B\":[\"Something\"],%n" +
|
|
" \"C\":[1,2,3]%n" +
|
|
" }%n" +
|
|
"}%n");
|
|
|
|
private LogixNG _logixNG;
|
|
private ConditionalNG _conditionalNG;
|
|
private JsonDecode _jsonDecode;
|
|
private MaleSocket _maleSocket;
|
|
private Memory _memoryResult;
|
|
private Memory _memoryResult2;
|
|
|
|
@Override
|
|
public ConditionalNG getConditionalNG() {
|
|
return _conditionalNG;
|
|
}
|
|
|
|
@Override
|
|
public LogixNG getLogixNG() {
|
|
return _logixNG;
|
|
}
|
|
|
|
@Override
|
|
public MaleSocket getConnectableChild() {
|
|
DigitalMany action = new DigitalMany("IQDA999", null);
|
|
MaleSocket maleSocket =
|
|
InstanceManager.getDefault(DigitalActionManager.class).registerAction(action);
|
|
return maleSocket;
|
|
}
|
|
|
|
@Override
|
|
public String getExpectedPrintedTree() {
|
|
return String.format(
|
|
"Decode JSON in variable MyJsonVariable to variable MyResultVariable ::: Use default%n");
|
|
}
|
|
|
|
@Override
|
|
public String getExpectedPrintedTreeFromRoot() {
|
|
return String.format(
|
|
"LogixNG: A new logix for test%n" +
|
|
" ConditionalNG: A conditionalNG%n" +
|
|
" ! A%n" +
|
|
" Many ::: Use default%n" +
|
|
" ::: Local variable \"MyJsonVariable\", init to String \"" + JSON_STRING + "\"%n" +
|
|
" ::: Local variable \"MyResultVariable\", init to None \"null\"%n" +
|
|
" ! A1%n" +
|
|
" Decode JSON in variable MyJsonVariable to variable MyResultVariable ::: Use default%n" +
|
|
" ! A2%n" +
|
|
" Set memory IM_RESULT to the value of variable MyResultVariable ::: Use default%n" +
|
|
" ! A3%n" +
|
|
" Digital Formula: MyResultVariable = str( MyResultVariable{\"config\"}{\"destination\"}{\"A\"}{\"single\"}{\"list\"}[3] ) ::: Use default%n" +
|
|
" ?* E1%n" +
|
|
" Socket not connected%n" +
|
|
" ! A4%n" +
|
|
" Set memory IM_RESULT_2 to the value of variable MyResultVariable ::: Use default%n" +
|
|
" ! A5%n" +
|
|
" Socket not connected%n");
|
|
}
|
|
|
|
@Override
|
|
public NamedBean createNewBean(String systemName) {
|
|
return new JsonDecode(systemName, null);
|
|
}
|
|
|
|
@Override
|
|
public boolean addNewSocket() {
|
|
return false;
|
|
}
|
|
|
|
@Test
|
|
public void testCtor() {
|
|
JsonDecode t = new JsonDecode("IQDA321", null);
|
|
assertNotNull( t, "exists");
|
|
t = new JsonDecode("IQDA321", null);
|
|
assertNotNull( t, "exists");
|
|
}
|
|
|
|
@Test
|
|
public void testGetChild() {
|
|
assertEquals( 0, _jsonDecode.getChildCount(), "getChildCount() returns 0");
|
|
|
|
UnsupportedOperationException ex = assertThrows( UnsupportedOperationException.class, () ->
|
|
_jsonDecode.getChild(0), "Exception is thrown");
|
|
assertEquals( "Not supported.", ex.getMessage(), "Error message is correct");
|
|
}
|
|
|
|
@Test
|
|
public void testCategory() {
|
|
assertSame( LogixNG_Category.OTHER, _base.getCategory(), "Category matches");
|
|
}
|
|
|
|
@Test
|
|
public void testDescription() {
|
|
JsonDecode a1 = new JsonDecode("IQDA321", null);
|
|
assertEquals( "Decode JSON", a1.getShortDescription(), "strings are equal");
|
|
JsonDecode a2 = new JsonDecode("IQDA321", null);
|
|
assertEquals( "Decode JSON in variable null to variable null",
|
|
a2.getLongDescription(), "strings are equal");
|
|
}
|
|
|
|
@Test
|
|
public void testExecute()
|
|
throws IOException, SocketAlreadyConnectedException, ParserException {
|
|
|
|
// Execute the LogixNG
|
|
_logixNG.setEnabled(true);
|
|
|
|
assertEquals("com.fasterxml.jackson.databind.node.ObjectNode",
|
|
_memoryResult.getValue().getClass().getName());
|
|
assertEquals("{\"id\":\"tk\",\"config\":{\"signature\":\"TK\",\"name\":\"Träkvista\",\"destinations\":2,\"destination\":{\"A\":{\"tracks\":1,\"type\":\"single\",\"single\":{\"id\":\"blo\",\"tracks\":1,\"exit\":\"B\",\"track\":\"left\",\"distance\":1,\"list\":[\"a\",\"b\",\"c\",\"d\",\"e\",\"f\",\"g\"],\"signature\":\"BLO\",\"name\":\"Bilbo\",\"signalin\":\"22\",\"signalout\":\"U1\",\"blockout\":\"sa1\"}}},\"B\":[\"Something\"],\"C\":[1,2,3]}}",
|
|
_memoryResult.getValue().toString());
|
|
|
|
assertEquals("java.lang.String",
|
|
_memoryResult2.getValue().getClass().getName());
|
|
assertEquals("d",
|
|
_memoryResult2.getValue().toString());
|
|
}
|
|
|
|
@Test
|
|
@Override
|
|
public void testIsActive() {
|
|
_logixNG.setEnabled(true);
|
|
super.testIsActive();
|
|
}
|
|
|
|
@Test
|
|
@Override
|
|
public void testMaleSocketIsActive() {
|
|
_logixNG.setEnabled(true);
|
|
super.testMaleSocketIsActive();
|
|
}
|
|
|
|
@BeforeEach
|
|
public void setUp() throws SocketAlreadyConnectedException, ParserException {
|
|
JUnitUtil.setUp();
|
|
JUnitUtil.resetInstanceManager();
|
|
JUnitUtil.resetProfileManager();
|
|
JUnitUtil.initConfigureManager();
|
|
JUnitUtil.initInternalSensorManager();
|
|
JUnitUtil.initInternalTurnoutManager();
|
|
JUnitUtil.initLogixNGManager();
|
|
|
|
_memoryResult = InstanceManager.getDefault(MemoryManager.class).provide("IM_RESULT");
|
|
|
|
_memoryResult2 = InstanceManager.getDefault(MemoryManager.class).provide("IM_RESULT_2");
|
|
|
|
_category = LogixNG_Category.OTHER;
|
|
|
|
_logixNG = InstanceManager.getDefault(LogixNG_Manager.class).createLogixNG("A new logix for test"); // NOI18N
|
|
_conditionalNG = new DefaultConditionalNGScaffold("IQC1", "A conditionalNG"); // NOI18N;
|
|
InstanceManager.getDefault(ConditionalNG_Manager.class).register(_conditionalNG);
|
|
_conditionalNG.setEnabled(true);
|
|
_conditionalNG.setRunDelayed(false);
|
|
_logixNG.addConditionalNG(_conditionalNG);
|
|
|
|
DigitalMany many = new DigitalMany("IQDA101", null);
|
|
MaleSocket m = InstanceManager.getDefault(DigitalActionManager.class).registerAction(many);
|
|
m.addLocalVariable("MyJsonVariable", SymbolTable.InitialValueType.String, JSON_STRING);
|
|
m.addLocalVariable("MyResultVariable", SymbolTable.InitialValueType.None, null);
|
|
_conditionalNG.getChild(0).connect(m);
|
|
|
|
_jsonDecode = new JsonDecode("IQDA321", null);
|
|
_jsonDecode.setJsonLocalVariable("MyJsonVariable");
|
|
_jsonDecode.setResultLocalVariable("MyResultVariable");
|
|
_maleSocket =
|
|
InstanceManager.getDefault(DigitalActionManager.class).registerAction(_jsonDecode);
|
|
many.getChild(0).connect(_maleSocket);
|
|
_base = _jsonDecode;
|
|
_baseMaleSocket = _maleSocket;
|
|
|
|
ActionMemory memory = new ActionMemory("IQDA102", null);
|
|
memory.getSelectNamedBean().setNamedBean("IM_RESULT");
|
|
memory.setMemoryOperation(ActionMemory.MemoryOperation.CopyVariableToMemory);
|
|
memory.setOtherLocalVariable("MyResultVariable");
|
|
many.getChild(1).connect(InstanceManager.getDefault(DigitalActionManager.class).registerAction(memory));
|
|
|
|
DigitalFormula formula = new DigitalFormula("IQDA103", null);
|
|
formula.setFormula("MyResultVariable = str( MyResultVariable{\"config\"}{\"destination\"}{\"A\"}{\"single\"}{\"list\"}[3] )");
|
|
many.getChild(2).connect(InstanceManager.getDefault(DigitalActionManager.class).registerAction(formula));
|
|
|
|
memory = new ActionMemory("IQDA104", null);
|
|
memory.getSelectNamedBean().setNamedBean("IM_RESULT_2");
|
|
memory.setMemoryOperation(ActionMemory.MemoryOperation.CopyVariableToMemory);
|
|
memory.setOtherLocalVariable("MyResultVariable");
|
|
many.getChild(3).connect(InstanceManager.getDefault(DigitalActionManager.class).registerAction(memory));
|
|
|
|
_logixNG.activate();
|
|
_logixNG.setEnabled(false);
|
|
}
|
|
|
|
@AfterEach
|
|
public void tearDown() {
|
|
_logixNG.setEnabled(false);
|
|
jmri.jmrit.logixng.util.LogixNG_Thread.stopAllLogixNGThreads();
|
|
JUnitUtil.deregisterBlockManagerShutdownTask();
|
|
JUnitUtil.tearDown();
|
|
_category = null;
|
|
_logixNG = null;
|
|
_conditionalNG = null;
|
|
_jsonDecode = null;
|
|
_base = null;
|
|
_baseMaleSocket = null;
|
|
_maleSocket = null;
|
|
_memoryResult = null;
|
|
}
|
|
|
|
}
|