check-equals

Author: Caideyipi

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaSink.java

@@ -313,7 +313,12 @@ private void customizeServer(final PipeParameters parameters) {
                       } else {
                         oldValue
                             .getRight()
-                            .checkEquals(user, password, securityDir, enableAnonymousAccess);
+                            .checkEquals(
+                                user,
+                                password,
+                                securityDir,
+                                enableAnonymousAccess,
+                                securityPolicies);
                         return oldValue;
                       }
                     } catch (final PipeException e) {

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/server/OpcUaNameSpace.java

@@ -49,6 +49,7 @@
 import org.eclipse.milo.opcua.sdk.server.util.SubscriptionModel;
 import org.eclipse.milo.opcua.stack.core.Identifiers;
 import org.eclipse.milo.opcua.stack.core.UaException;
+import org.eclipse.milo.opcua.stack.core.security.SecurityPolicy;
 import org.eclipse.milo.opcua.stack.core.types.builtin.DataValue;
 import org.eclipse.milo.opcua.stack.core.types.builtin.DateTime;
 import org.eclipse.milo.opcua.stack.core.types.builtin.LocalizedText;
@@ -65,6 +66,7 @@
 import java.util.Collections;
 import java.util.List;
 import java.util.Objects;
+import java.util.Set;
 import java.util.UUID;
 import java.util.stream.Collectors;
 
@@ -543,7 +545,9 @@ public void checkEquals(
       final String user,
       final String password,
       final String securityDir,
-      final boolean enableAnonymousAccess) {
-    builder.checkEquals(user, password, Paths.get(securityDir), enableAnonymousAccess);
+      final boolean enableAnonymousAccess,
+      final Set<SecurityPolicy> securityPolicies) {
+    builder.checkEquals(
+        user, password, Paths.get(securityDir), enableAnonymousAccess, securityPolicies);
   }
 }

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/server/OpcUaServerBuilder.java

@@ -310,14 +310,16 @@ void checkEquals(
       final String user,
       final String password,
       final Path securityDir,
-      final boolean enableAnonymousAccess) {
+      final boolean enableAnonymousAccess,
+      final Set<SecurityPolicy> securityPolicies) {
     checkEquals("user", this.user, user);
     checkEquals("password", this.password, password);
     checkEquals(
         "security dir",
         FileSystems.getDefault().getPath(this.securityDir.toAbsolutePath().toString()),
         FileSystems.getDefault().getPath(securityDir.toAbsolutePath().toString()));
     checkEquals("enableAnonymousAccess option", this.enableAnonymousAccess, enableAnonymousAccess);
+    checkEquals("securityPolicies", this.securityPolicies, securityPolicies);
   }
 
   private void checkEquals(final String attrName, final Object thisAttr, final Object thatAttr) {