/* ========================================================================
* Copyright (c) 2005-2025 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/
* ======================================================================*/
using NUnit.Framework;
using Opc.Ua.Redundancy.Server;
using Opc.Ua.Tests;
namespace Opc.Ua.Server.Tests.Redundancy
{
///
/// Unit tests for .
///
[TestFixture]
[Category("Distributed")]
[Parallelizable(ParallelScope.All)]
public class NodeStateSerializerTests
{
private const ushort NamespaceIndex = 1;
private SystemContext m_context = null!;
[OneTimeSetUp]
public void OneTimeSetUp()
{
ITelemetryContext telemetry = NUnitTelemetryContext.Create();
var messageContext = ServiceMessageContext.CreateEmpty(telemetry);
messageContext.NamespaceUris.GetIndexOrAppend("urn:test:serializer");
m_context = new SystemContext(telemetry)
{
NamespaceUris = messageContext.NamespaceUris,
ServerUris = messageContext.ServerUris,
EncodeableFactory = messageContext.Factory
};
}
[Test]
public void ObjectRoundTripsAsBaseObjectState()
{
var original = new BaseObjectState(null)
{
NodeId = new NodeId("obj", NamespaceIndex),
BrowseName = new QualifiedName("Obj", NamespaceIndex),
DisplayName = new LocalizedText("Obj")
};
ByteString payload = NodeStateSerializer.Serialize(m_context, original);
NodeState restored = NodeStateSerializer.Deserialize(m_context, payload);
Assert.That(restored, Is.InstanceOf());
Assert.That(restored.NodeClass, Is.EqualTo(NodeClass.Object));
Assert.That(restored.BrowseName, Is.EqualTo(original.BrowseName));
}
[Test]
public void VariableRoundTripsWithValue()
{
var original = new BaseDataVariableState(null)
{
NodeId = new NodeId("var", NamespaceIndex),
BrowseName = new QualifiedName("Var", NamespaceIndex),
DisplayName = new LocalizedText("Var"),
DataType = DataTypeIds.Double,
ValueRank = ValueRanks.Scalar,
Value = new Variant(2.5)
};
ByteString payload = NodeStateSerializer.Serialize(m_context, original);
NodeState restored = NodeStateSerializer.Deserialize(m_context, payload);
Assert.That(restored, Is.InstanceOf());
Assert.That(restored.NodeClass, Is.EqualTo(NodeClass.Variable));
var variable = (BaseDataVariableState)restored;
Assert.That(variable.Value, Is.EqualTo(new Variant(2.5)));
Assert.That(variable.DataType, Is.EqualTo(DataTypeIds.Double));
}
[Test]
public void MethodRoundTripsAsMethodState()
{
var original = new MethodState(null)
{
NodeId = new NodeId("m", NamespaceIndex),
BrowseName = new QualifiedName("DoIt", NamespaceIndex),
DisplayName = new LocalizedText("DoIt"),
Executable = true,
UserExecutable = true
};
ByteString payload = NodeStateSerializer.Serialize(m_context, original);
NodeState restored = NodeStateSerializer.Deserialize(m_context, payload);
Assert.That(restored, Is.InstanceOf());
Assert.That(((MethodState)restored).Executable, Is.True);
}
[Test]
public void DeserializeTooShortPayloadThrows()
{
var tooShort = ByteString.From(new byte[] { 1, 2 });
Assert.That(
() => NodeStateSerializer.Deserialize(m_context, tooShort),
Throws.TypeOf());
}
[Test]
public void SerializeThrowsOnNullContext()
{
var node = new BaseObjectState(null);
Assert.That(
() => NodeStateSerializer.Serialize(null!, node),
Throws.ArgumentNullException);
}
[Test]
public void SerializeThrowsOnNullNode()
{
Assert.That(
() => NodeStateSerializer.Serialize(m_context, null!),
Throws.ArgumentNullException);
}
[Test]
public void DeserializeThrowsOnNullContext()
{
var node = new BaseObjectState(null)
{
NodeId = new NodeId("obj", NamespaceIndex),
BrowseName = new QualifiedName("Obj", NamespaceIndex)
};
ByteString payload = NodeStateSerializer.Serialize(m_context, node);
Assert.That(
() => NodeStateSerializer.Deserialize(null!, payload),
Throws.ArgumentNullException);
}
[Test]
public void ViewRoundTripsAsViewState()
{
var original = new ViewState
{
NodeId = new NodeId("view", NamespaceIndex),
BrowseName = new QualifiedName("View", NamespaceIndex),
DisplayName = new LocalizedText("View"),
ContainsNoLoops = true
};
NodeState restored = RoundTrip(original);
Assert.That(restored, Is.InstanceOf());
Assert.That(restored.NodeClass, Is.EqualTo(NodeClass.View));
Assert.That(((ViewState)restored).ContainsNoLoops, Is.True);
}
[Test]
public void ObjectTypeRoundTripsAsBaseObjectTypeState()
{
var original = new BaseObjectTypeState
{
NodeId = new NodeId("otype", NamespaceIndex),
BrowseName = new QualifiedName("OType", NamespaceIndex),
DisplayName = new LocalizedText("OType"),
IsAbstract = true
};
NodeState restored = RoundTrip(original);
Assert.That(restored, Is.InstanceOf());
Assert.That(restored.NodeClass, Is.EqualTo(NodeClass.ObjectType));
Assert.That(((BaseObjectTypeState)restored).IsAbstract, Is.True);
}
[Test]
public void VariableTypeRoundTripsAsBaseDataVariableTypeState()
{
var original = new BaseDataVariableTypeState
{
NodeId = new NodeId("vtype", NamespaceIndex),
BrowseName = new QualifiedName("VType", NamespaceIndex),
DisplayName = new LocalizedText("VType"),
DataType = DataTypeIds.Int32,
ValueRank = ValueRanks.Scalar
};
NodeState restored = RoundTrip(original);
Assert.That(restored, Is.InstanceOf());
Assert.That(restored.NodeClass, Is.EqualTo(NodeClass.VariableType));
Assert.That(((BaseDataVariableTypeState)restored).DataType, Is.EqualTo(DataTypeIds.Int32));
}
[Test]
public void ReferenceTypeRoundTripsAsReferenceTypeState()
{
var original = new ReferenceTypeState
{
NodeId = new NodeId("rtype", NamespaceIndex),
BrowseName = new QualifiedName("RType", NamespaceIndex),
DisplayName = new LocalizedText("RType"),
InverseName = new LocalizedText("RTypeInverse"),
Symmetric = false
};
NodeState restored = RoundTrip(original);
Assert.That(restored, Is.InstanceOf());
Assert.That(restored.NodeClass, Is.EqualTo(NodeClass.ReferenceType));
Assert.That(((ReferenceTypeState)restored).InverseName, Is.EqualTo(original.InverseName));
}
[Test]
public void DataTypeRoundTripsAsDataTypeState()
{
var original = new DataTypeState
{
NodeId = new NodeId("dtype", NamespaceIndex),
BrowseName = new QualifiedName("DType", NamespaceIndex),
DisplayName = new LocalizedText("DType"),
IsAbstract = true
};
NodeState restored = RoundTrip(original);
Assert.That(restored, Is.InstanceOf());
Assert.That(restored.NodeClass, Is.EqualTo(NodeClass.DataType));
Assert.That(((DataTypeState)restored).IsAbstract, Is.True);
}
[Test]
public void DeserializeUnknownNodeClassThrows()
{
// A framed payload whose header is a NodeClass value the reconstructor does not support.
var payload = ByteString.From(new byte[] { 3, 0, 0, 0 });
Assert.That(
() => NodeStateSerializer.Deserialize(m_context, payload),
Throws.TypeOf());
}
private NodeState RoundTrip(NodeState original)
{
ByteString payload = NodeStateSerializer.Serialize(m_context, original);
return NodeStateSerializer.Deserialize(m_context, payload);
}
}
}