new server without ssl

pom.xml

@@ -43,6 +43,42 @@
 
 	<build>
 		<plugins>
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-shade-plugin</artifactId>
+				<version>3.2.0</version>
+				<executions>
+					<execution>
+						<phase>package</phase>
+						<goals>
+							<goal>shade</goal>
+						</goals>
+						<configuration>
+							<filters>
+								<filter>
+									<artifact>junit:junit</artifact>
+									<includes>
+										<include>junit/framework/**</include>
+										<include>org/junit/**</include>
+									</includes>
+									<excludes>
+										<exclude>org/junit/experimental/**</exclude>
+										<exclude>org/junit/runners/**</exclude>
+									</excludes>
+								</filter>
+								<filter>
+									<artifact>*:*</artifact>
+									<excludes>
+										<exclude>META-INF/*.SF</exclude>
+										<exclude>META-INF/*.DSA</exclude>
+										<exclude>META-INF/*.RSA</exclude>
+									</excludes>
+								</filter>
+							</filters>
+						</configuration>
+					</execution>
+				</executions>
+			</plugin>
 			<plugin>
 				<groupId>org.apache.maven.plugins</groupId>
 				<artifactId>maven-compiler-plugin</artifactId>
@@ -93,6 +129,8 @@
 							com.ur.urcap.api*;version="[1.0.0,2.0.0)",
 							*
 						</Import-Package>
+
+						<Embed-Dependency>*;scope=compile|runtime</Embed-Dependency>
 					</instructions>
 				</configuration>
 			</plugin>
@@ -109,8 +147,8 @@
 							<goal>exec</goal>
 						</goals>
 						<configuration>
-							<executable>cp</executable>
-							<commandlineArgs>target/${project.build.finalName}.jar target/${project.build.finalName}.urcap</commandlineArgs>
+							<executable>copy</executable>
+							<commandlineArgs>target\\${project.build.finalName}.jar target\\${project.build.finalName}.urcap</commandlineArgs>
 							<workingDirectory>.</workingDirectory>
 						</configuration>
 					</execution>
@@ -145,11 +183,6 @@
 			<artifactId>slf4j-simple</artifactId>
 			<version>1.7.25</version>
 		</dependency>
-		<dependency>
-			<groupId>org.apache.httpcomponents</groupId>
-			<artifactId>httpcore-nio</artifactId>
-			<version>4.4.10</version>
-		</dependency>
 		<dependency>
 			<groupId>org.opcfoundation.ua</groupId>
 			<artifactId>opc-ua-stack</artifactId>
@@ -158,13 +191,13 @@
 		<dependency>
 			<groupId>org.osgi</groupId>
 			<artifactId>org.osgi.core</artifactId>
-			<version>4.3.0</version>
+			<version>6.0.0</version>
 		</dependency>
 
 		<dependency>
 			<groupId>com.ur.urcap</groupId>
 			<artifactId>api</artifactId>
-			<version>1.0.0.30</version>
+			<version>1.4.0</version>
 			<scope>provided</scope>
 		</dependency>
 
@@ -178,7 +211,7 @@
 		<dependency>
 			<groupId>org.apache.httpcomponents</groupId>
 			<artifactId>httpclient</artifactId>
-			<version>4.5.5</version>
+			<version>4.5.6</version>
 		</dependency>
 	</dependencies>
 
@@ -237,7 +270,7 @@
 									<goal>exec</goal>
 								</goals>
 								<configuration>
-									<executable>cp</executable>
+									<executable>copy</executable>
 									<commandlineArgs>target/${project.build.finalName}.jar ${user.home}/.urcaps/${urcap.symbolicname}.jar</commandlineArgs>
 									<workingDirectory>.</workingDirectory>
 								</configuration>
@@ -263,7 +296,7 @@
 									<goal>exec</goal>
 								</goals>
 								<configuration>
-									<executable>cp</executable>
+									<executable>copy</executable>
 									<commandlineArgs>target/${project.build.finalName}.jar ${ursim.home}/.urcaps/${urcap.symbolicname}.jar</commandlineArgs>
 									<workingDirectory>.</workingDirectory>
 								</configuration>

src/main/java/at/acdp/opcur/OPCTest.java

@@ -264,7 +264,6 @@ public class OPCTest {
 
 
             KeyPair myHttpsCertificate = ExampleKeys.getHttpsCert("ServerExample1");
-
             application.getHttpsSettings().setKeyPair(myHttpsCertificate);
 
             // Add User Token Policies

src/main/java/at/acdp/opcur/OPCTestPlain.java

@@ -0,0 +1,319 @@
+package at.acdp.opcur;
+/*
+ * ======================================================================== Copyright (c) 2005-2015
+ * The OPC Foundation, Inc. All rights reserved.
+ *
+ * OPC Foundation MIT License 1.00
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of this software and
+ * associated documentation files (the "Software"), to deal in the Software without restriction,
+ * including without limitation the rights to use, copy, modify, merge, publish, distribute,
+ * sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is
+ * furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all copies or
+ * substantial portions of the Software. THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY
+ * KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+ * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
+ * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
+ * OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
+ * IN THE SOFTWARE.
+ *
+ * The complete license agreement can be found here: http://opcfoundation.org/License/MIT/1.00/
+ * ======================================================================
+ */
+
+
+import org.apache.http.conn.ssl.SSLSocketFactory;
+import org.opcfoundation.ua.application.Application;
+import org.opcfoundation.ua.application.Server;
+import org.opcfoundation.ua.builtintypes.*;
+import org.opcfoundation.ua.common.ServiceFaultException;
+import org.opcfoundation.ua.common.ServiceResultException;
+import org.opcfoundation.ua.core.*;
+import org.opcfoundation.ua.transport.endpoint.EndpointServiceRequest;
+import org.opcfoundation.ua.transport.security.*;
+import org.opcfoundation.ua.utils.CryptoUtil;
+import org.opcfoundation.ua.utils.EndpointUtil;
+import org.opcfoundation.ua.application.Application;
+
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.security.interfaces.RSAPrivateKey;
+import java.util.Random;
+import java.util.UUID;
+
+
+/**
+ * Simple Server example. This server responds to stack test and endpoint discover service requests.
+ *
+ */
+public class OPCTestPlain {
+
+
+    static class MyAttributeServiceHandler implements AttributeServiceSetHandler {
+
+        @Override
+        public void onHistoryRead(EndpointServiceRequest<HistoryReadRequest, HistoryReadResponse> req)
+                throws ServiceFaultException {
+
+        }
+
+        @Override
+        public void onHistoryUpdate(EndpointServiceRequest<HistoryUpdateRequest, HistoryUpdateResponse> req)
+                throws ServiceFaultException {
+
+        }
+
+        @Override
+        public void onRead(EndpointServiceRequest<ReadRequest, ReadResponse> req) throws ServiceFaultException {
+            ReadRequest request = req.getRequest();
+            ReadValueId[] nodesToRead = request.getNodesToRead();
+
+            DataValue[] results = new DataValue[nodesToRead.length];
+            for (int i = 0; i < nodesToRead.length; i++) {
+                if (Identifiers.RootFolder.equals(nodesToRead[i].getNodeId())) {
+                    if (Attributes.BrowseName.equals(nodesToRead[i].getAttributeId())) {
+                        results[i] = new DataValue(new Variant(new QualifiedName("Root")));
+                    } else if (Attributes.DisplayName.equals(nodesToRead[i].getAttributeId())) {
+                        results[i] = new DataValue(new Variant(new LocalizedText("Root", LocalizedText.NO_LOCALE)));
+                    } else {
+                        results[i] = new DataValue(new StatusCode(StatusCodes.Bad_AttributeIdInvalid));
+                    }
+                } else {
+                    results[i] = new DataValue(new StatusCode(StatusCodes.Bad_NodeIdUnknown));
+                }
+            }
+            ReadResponse response = new ReadResponse(null, results, null);
+            req.sendResponse(response);
+        }
+
+        @Override
+        public void onWrite(EndpointServiceRequest<WriteRequest, WriteResponse> req) throws ServiceFaultException {
+
+        }
+
+    };
+
+    static class MyNodeManagementServiceHandler implements NodeManagementServiceSetHandler {
+
+        @Override
+        public void onAddNodes(EndpointServiceRequest<AddNodesRequest, AddNodesResponse> req) throws ServiceFaultException {
+
+        }
+
+        @Override
+        public void onAddReferences(EndpointServiceRequest<AddReferencesRequest, AddReferencesResponse> req)
+                throws ServiceFaultException {
+
+        }
+
+        @Override
+        public void onBrowse(EndpointServiceRequest<BrowseRequest, BrowseResponse> req) throws ServiceFaultException {
+            BrowseRequest request = req.getRequest();
+            BrowseResult[] Results = new BrowseResult[request.getNodesToBrowse().length];
+            for (int i = 0; i < request.getNodesToBrowse().length; i++) {
+                StatusCode statusCode;
+                if (Identifiers.RootFolder.equals(request.getNodesToBrowse()[i].getNodeId())) {
+                    statusCode = StatusCode.GOOD;
+                } else {
+                    statusCode = new StatusCode(StatusCodes.Bad_NodeIdUnknown);
+                }
+                Results[i] = new BrowseResult(statusCode, null, null);
+            }
+            BrowseResponse response = new BrowseResponse(null, Results, null);
+            req.sendResponse(response);
+
+        }
+
+        @Override
+        public void onBrowseNext(EndpointServiceRequest<BrowseNextRequest, BrowseNextResponse> req)
+                throws ServiceFaultException {
+
+        }
+
+        @Override
+        public void onDeleteNodes(EndpointServiceRequest<DeleteNodesRequest, DeleteNodesResponse> req)
+                throws ServiceFaultException {
+
+        }
+
+        @Override
+        public void onDeleteReferences(EndpointServiceRequest<DeleteReferencesRequest, DeleteReferencesResponse> req)
+                throws ServiceFaultException {
+
+        }
+
+        @Override
+        public void onQueryFirst(EndpointServiceRequest<QueryFirstRequest, QueryFirstResponse> req)
+                throws ServiceFaultException {
+
+        }
+
+        @Override
+        public void onQueryNext(EndpointServiceRequest<QueryNextRequest, QueryNextResponse> req)
+                throws ServiceFaultException {
+
+        }
+
+        @Override
+        public void onRegisterNodes(EndpointServiceRequest<RegisterNodesRequest, RegisterNodesResponse> req)
+                throws ServiceFaultException {
+
+        }
+
+        @Override
+        public void onTranslateBrowsePathsToNodeIds(
+                EndpointServiceRequest<TranslateBrowsePathsToNodeIdsRequest, TranslateBrowsePathsToNodeIdsResponse> req)
+                throws ServiceFaultException {
+
+        }
+
+        @Override
+        public void onUnregisterNodes(EndpointServiceRequest<UnregisterNodesRequest, UnregisterNodesResponse> req)
+                throws ServiceFaultException {
+
+        }
+
+    }
+
+
+    static class MyServerExample extends Server implements SessionServiceSetHandler {
+
+        public MyServerExample(Application application) throws Exception {
+            super(application);
+            addServiceHandler(this);
+
+            // Add User Token Policies
+            addUserTokenPolicy(UserTokenPolicy.ANONYMOUS);
+            addUserTokenPolicy(UserTokenPolicy.SECURE_USERNAME_PASSWORD);
+
+            // Create an endpoint for each network interface
+            String hostname = EndpointUtil.getHostname();
+            String bindAddress, endpointAddress;
+            for (String addr : EndpointUtil.getInetAddressNames()) {
+                bindAddress = "http://" + addr + ":8443/UAExample";
+                endpointAddress = "http://" + hostname + ":8443/UAExample";
+                System.out.println(endpointAddress + " bound at " + bindAddress);
+                // The HTTPS ports are using NONE OPC security
+                bind(bindAddress, endpointAddress, SecurityMode.NONE);
+
+                bindAddress = "opc.tcp://" + addr + ":8666/UAExample";
+                endpointAddress = "opc.tcp://" + hostname + ":8666/UAExample";
+                System.out.println(endpointAddress + " bound at " + bindAddress);
+                bind(bindAddress, endpointAddress, SecurityMode.NONE);
+            }
+
+            //////////////////////////////////////
+        }
+
+        @Override
+        public void onActivateSession(EndpointServiceRequest<ActivateSessionRequest, ActivateSessionResponse> msgExchange)
+                throws ServiceFaultException {
+            ActivateSessionResponse res = new ActivateSessionResponse();
+            res.setServerNonce(CryptoUtil.createNonce(32));
+            res.setResults(new StatusCode[] {StatusCode.GOOD});
+            msgExchange.sendResponse(res);
+        }
+
+        @Override
+        public void onCancel(EndpointServiceRequest<CancelRequest, CancelResponse> msgExchange)
+                throws ServiceFaultException {
+
+        }
+
+        @Override
+        public void onCloseSession(EndpointServiceRequest<CloseSessionRequest, CloseSessionResponse> msgExchange)
+                throws ServiceFaultException {
+            CloseSessionResponse res = new CloseSessionResponse();
+            msgExchange.sendResponse(res);
+        }
+
+        @Override
+        public void onCreateSession(EndpointServiceRequest<CreateSessionRequest, CreateSessionResponse> msgExchange)
+                throws ServiceFaultException {
+            CreateSessionRequest req = msgExchange.getRequest();
+            CreateSessionResponse res = new CreateSessionResponse();
+            byte[] token = new byte[32];
+            byte[] nonce = new byte[32];
+            Random r = new Random();
+            r.nextBytes(nonce);
+            r.nextBytes(token);
+            res.setAuthenticationToken(new NodeId(0, token));
+            EndpointConfiguration endpointConfiguration = EndpointConfiguration.defaults();
+            res.setMaxRequestMessageSize(UnsignedInteger
+                    .valueOf(Math.max(endpointConfiguration.getMaxMessageSize(), req.getMaxResponseMessageSize().longValue())));
+            res.setRevisedSessionTimeout(Math.max(req.getRequestedSessionTimeout(), 60 * 1000));
+            KeyPair cert = getApplication().getApplicationInstanceCertificates()[0];
+            res.setServerCertificate(ByteString.valueOf(cert.getCertificate().getEncoded()));
+            res.setServerEndpoints(this.getEndpointDescriptions());
+            res.setServerNonce(ByteString.valueOf(nonce));
+
+            ByteString clientCertificate = req.getClientCertificate();
+            ByteString clientNonce = req.getClientNonce();
+            SecurityPolicy securityPolicy = msgExchange.getChannel().getSecurityPolicy();
+            res.setServerSignature(
+                    getServerSignature(clientCertificate, clientNonce, securityPolicy, cert.getPrivateKey().getPrivateKey()));
+
+            res.setServerSoftwareCertificates(getApplication().getSoftwareCertificates());
+            res.setSessionId(new NodeId(0, "Session-" + UUID.randomUUID()));
+            msgExchange.sendResponse(res);
+        }
+
+        private SignatureData getServerSignature(ByteString clientCertificate, ByteString clientNonce,
+                                                 SecurityPolicy securityPolicy, final RSAPrivateKey privateKey) throws ServiceFaultException {
+            if (clientCertificate != null) {
+                ByteArrayOutputStream s = new ByteArrayOutputStream();
+                try {
+                    s.write(clientCertificate.getValue());
+                } catch (IOException e) {
+                    throw new ServiceFaultException(ServiceFault.createServiceFault(StatusCodes.Bad_SecurityChecksFailed));
+                } catch (Exception e) {
+                    throw new ServiceFaultException(ServiceFault.createServiceFault(StatusCodes.Bad_NonceInvalid));
+                }
+                try {
+                    s.write(clientNonce.getValue());
+                } catch (IOException e) {
+                    throw new ServiceFaultException(ServiceFault.createServiceFault(StatusCodes.Bad_NonceInvalid));
+                } catch (Exception e) {
+                    throw new ServiceFaultException(ServiceFault.createServiceFault(StatusCodes.Bad_NonceInvalid));
+                }
+                try {
+                    SecurityAlgorithm algorithm = securityPolicy.getAsymmetricSignatureAlgorithm();
+                    return new SignatureData(algorithm.getUri(),
+                            ByteString.valueOf(CryptoUtil.getCryptoProvider().signAsymm(privateKey, algorithm, s.toByteArray())));
+
+                } catch (ServiceResultException e) {
+                    throw new ServiceFaultException(e);
+                }
+            }
+            return null;
+        }
+    }
+
+    public static void main(String[] args) throws Exception {
+        CryptoUtil.setSecurityProviderName("SunJCE");
+        ////////////// SERVER //////////////
+        // Create UA Server Application
+        // Create UA Service Server
+        Application myServerApplication = new Application();
+        MyServerExample myServer = new MyServerExample(myServerApplication);
+
+        myServer.addServiceHandler(new MyNodeManagementServiceHandler());
+        myServer.addServiceHandler(new MyAttributeServiceHandler());
+
+        //////////////////////////////////////
+        // Press enter to shutdown
+        System.out.println("Press enter to shutdown");
+        System.in.read();
+        //////////////////////////////////////
+
+
+        ///////////// SHUTDOWN /////////////
+        // Close the server by unbinding all endpoints
+        myServer.getApplication().close();
+        //////////////////////////////////////
+
+    }
+
+}