Skip to content

Commit

Permalink
feat(plc4j/opcua): moved test to driver
Browse files Browse the repository at this point in the history
  • Loading branch information
sruehl committed Aug 3, 2023
1 parent 0dff535 commit 33aa723
Show file tree
Hide file tree
Showing 2 changed files with 49 additions and 67 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -31,17 +31,19 @@
import org.eclipse.milo.examples.server.ExampleServer;
import org.junit.jupiter.api.*;

import static org.apache.plc4x.java.opcua.OpcuaPlcDriver.INET_ADDRESS_PATTERN;
import static org.apache.plc4x.java.opcua.OpcuaPlcDriver.URI_PATTERN;
import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.fail;
import static org.junit.jupiter.api.Assumptions.assumeTrue;

import java.math.BigInteger;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.Arrays;
import java.util.concurrent.ExecutionException;
import java.util.stream.Stream;

import static org.apache.plc4x.java.opcua.OpcuaPlcDriver.INET_ADDRESS_PATTERN;
import static org.apache.plc4x.java.opcua.OpcuaPlcDriver.URI_PATTERN;
import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.fail;
import static org.junit.jupiter.api.Assumptions.assumeTrue;

public class OpcuaPlcDriverTest {

Expand Down Expand Up @@ -445,4 +447,45 @@ public void run() {
}
}

private final String[] validTCPOPC = {
"localhost",
"127.0.0.1",
"254.254.254.254"
};
private final int[] validPorts = {
1337,
42,
1,
24152
};
private final String[] nDiscoveryParams = {
"discovery=false"
};


@TestFactory
Stream<DynamicNode> testConnectionStringPattern() throws Exception {
return Arrays.stream(validTCPOPC)
.map(address -> DynamicContainer.dynamicContainer("Address: " + address, () -> Arrays.stream(validPorts)
.mapToObj(port -> DynamicTest.dynamicTest("Port: " + port, () -> {
assertThat("opcua:tcp://" + address + ":555?discovery=true").matches(URI_PATTERN);
assertThat("opcua:tcp://" + address + ":555?discovery=True").matches(URI_PATTERN);
assertThat("opcua:tcp://" + address + ":555?discovery=TRUE").matches(URI_PATTERN);
assertThat("opcua:tcp://" + address + ":555?Discovery=True").matches(URI_PATTERN);
//No Port Specified
assertThat("opcua:tcp://" + address + "?discovery=True").matches(URI_PATTERN);
//No Transport Specified
assertThat("opcua://" + address + ":647?discovery=True").matches(URI_PATTERN);
//No Params Specified
assertThat("opcua:tcp://" + address + ":111").matches(URI_PATTERN);
//No Transport and Params Specified
assertThat("opcua://" + address + ":754").matches(URI_PATTERN);
})
)
.map(DynamicNode.class::cast)
.iterator()
)
);
}

}

This file was deleted.

0 comments on commit 33aa723

Please sign in to comment.