mirror of
https://github.com/OPCFoundation/UA-.NETStandard.git
synced 2026-10-28 22:55:49 +08:00
Marc Schier
70b4498db8
* New certificate and secrete abstraction with certificate infrastructure and certificate/secret stores. * leak testing for certificate resources to validate new ref counting in every test assembly * Migration guide updated and documentation added for all * Remove IDisposable from Nodestate and UserIdentity. * UserCertificateTokenHandler now just points into certificate registry/stores, no dispose required * Fix CA2000 warnings and cleanup of other diagnostics, increase warning levels in .editorconfig
1246 lines
63 KiB
C#
1246 lines
63 KiB
C#
/* ========================================================================
|
|
* 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 System;
|
|
using System.IO;
|
|
using NUnit.Framework;
|
|
using Opc.Ua.PubSub.Configuration;
|
|
using Opc.Ua.Tests;
|
|
|
|
namespace Opc.Ua.PubSub.Tests.Configuration
|
|
{
|
|
[TestFixture(Description = "Tests for UaPubSubApplication class")]
|
|
[Parallelizable]
|
|
public class UaPubSubConfiguratorTests
|
|
{
|
|
internal static int CallCountPublishedDataSetAdded;
|
|
internal static int CallCountPublishedDataSetRemoved;
|
|
internal static int CallCountConnectionRemoved;
|
|
internal static int CallCountConnectionAdded;
|
|
internal static int CallCountDataSetReaderAdded;
|
|
internal static int CallCountDataSetReaderRemoved;
|
|
internal static int CallCountDataSetWriterAdded;
|
|
internal static int CallCountDataSetWriterRemoved;
|
|
internal static int CallCountReaderGroupAdded;
|
|
internal static int CallCountReaderGroupRemoved;
|
|
internal static int CallCountWriterGroupAdded;
|
|
internal static int CallCountWriterGroupRemoved;
|
|
|
|
internal static readonly string PublisherConfigurationFileName = Path.Combine(
|
|
"Configuration",
|
|
"PublisherConfiguration.xml");
|
|
|
|
internal static readonly string SubscriberConfigurationFileName = Path.Combine(
|
|
"Configuration",
|
|
"SubscriberConfiguration.xml");
|
|
|
|
private UaPubSubConfigurator m_uaPubSubConfigurator;
|
|
private PubSubConfigurationDataType m_pubConfigurationLoaded;
|
|
private PubSubConfigurationDataType m_subConfigurationLoaded;
|
|
|
|
[SetUp]
|
|
public void MyTestInitialize()
|
|
{
|
|
ITelemetryContext telemetry = NUnitTelemetryContext.Create();
|
|
m_uaPubSubConfigurator = new UaPubSubConfigurator(telemetry);
|
|
|
|
// Attach triggers that count calls
|
|
m_uaPubSubConfigurator.ConnectionAdded += (sender, e) => ++CallCountConnectionAdded;
|
|
m_uaPubSubConfigurator.ConnectionRemoved += (sender, e) => ++CallCountConnectionRemoved;
|
|
m_uaPubSubConfigurator.PublishedDataSetAdded
|
|
+= (sender, e) => ++CallCountPublishedDataSetAdded;
|
|
m_uaPubSubConfigurator.PublishedDataSetRemoved
|
|
+= (sender, e) => ++CallCountPublishedDataSetRemoved;
|
|
m_uaPubSubConfigurator.DataSetReaderAdded
|
|
+= (sender, e) => ++CallCountDataSetReaderAdded;
|
|
m_uaPubSubConfigurator.DataSetReaderRemoved
|
|
+= (sender, e) => ++CallCountDataSetReaderRemoved;
|
|
m_uaPubSubConfigurator.DataSetWriterAdded
|
|
+= (sender, e) => ++CallCountDataSetWriterAdded;
|
|
m_uaPubSubConfigurator.DataSetWriterRemoved
|
|
+= (sender, e) => ++CallCountDataSetWriterRemoved;
|
|
m_uaPubSubConfigurator.ReaderGroupAdded += (sender, e) => ++CallCountReaderGroupAdded;
|
|
m_uaPubSubConfigurator.ReaderGroupRemoved
|
|
+= (sender, e) => ++CallCountReaderGroupRemoved;
|
|
m_uaPubSubConfigurator.WriterGroupAdded += (sender, e) => ++CallCountWriterGroupAdded;
|
|
m_uaPubSubConfigurator.WriterGroupRemoved
|
|
+= (sender, e) => ++CallCountWriterGroupRemoved;
|
|
|
|
// A publisher configuration source
|
|
string publisherConfigFile = Utils.GetAbsoluteFilePath(
|
|
PublisherConfigurationFileName,
|
|
checkCurrentDirectory: true,
|
|
createAlways: false);
|
|
m_pubConfigurationLoaded = UaPubSubConfigurationHelper.LoadConfiguration(
|
|
publisherConfigFile,
|
|
telemetry);
|
|
// A subscriber configuration source
|
|
string subscriberConfigFile = Utils.GetAbsoluteFilePath(
|
|
SubscriberConfigurationFileName,
|
|
checkCurrentDirectory: true,
|
|
createAlways: false);
|
|
m_subConfigurationLoaded = UaPubSubConfigurationHelper.LoadConfiguration(
|
|
subscriberConfigFile,
|
|
telemetry);
|
|
}
|
|
|
|
[Test(Description = "Validate ConnectionAdded event is triggered")]
|
|
public void ValidateConnectionAdded()
|
|
{
|
|
int expected = CallCountConnectionAdded + 1;
|
|
StatusCode result = m_uaPubSubConfigurator.AddConnection(
|
|
new PubSubConnectionDataType { Enabled = true });
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
Assert.That(
|
|
CallCountConnectionAdded,
|
|
Is.EqualTo(expected).Within(0),
|
|
$"Expected value of CallCountConnectionAdded not equal to {expected}");
|
|
}
|
|
|
|
[Test(
|
|
Description = "Validate AddConnection returns code BadBrowseNameDuplicated if duplicate name connections added."
|
|
)]
|
|
public void ValidateAddConnectionReturnsBadBrowseNameDuplicated()
|
|
{
|
|
var connection1 = new PubSubConnectionDataType { Enabled = true, Name = "Name" };
|
|
StatusCode result = m_uaPubSubConfigurator.AddConnection(connection1);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
var connection2 = new PubSubConnectionDataType { Enabled = true, Name = "Name" };
|
|
result = m_uaPubSubConfigurator.AddConnection(connection2);
|
|
|
|
Assert.That(
|
|
result,
|
|
Is.EqualTo(StatusCodes.BadBrowseNameDuplicated),
|
|
CoreUtils.Format(
|
|
"Status code received {0} instead of BadBrowseNameDuplicated",
|
|
result));
|
|
}
|
|
|
|
[Test(Description = "Validate AddConnection throws ArgumentException if a connection is added twice")]
|
|
public void ValidateAddConnectionThrowsArgumentException()
|
|
{
|
|
var connection1 = new PubSubConnectionDataType { Enabled = true, Name = "Name" };
|
|
StatusCode result = m_uaPubSubConfigurator.AddConnection(connection1);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
Assert.Throws<ArgumentException>(
|
|
() => m_uaPubSubConfigurator.AddConnection(connection1),
|
|
"AddConnection shall throw ArgumentException if same connection is added twice");
|
|
}
|
|
|
|
[Test(Description = "Validate ConnectionRemoved event is triggered")]
|
|
public void ValidateConnectionRemoved()
|
|
{
|
|
int expected = CallCountConnectionRemoved + 1;
|
|
var newConnection = new PubSubConnectionDataType { Enabled = true };
|
|
m_uaPubSubConfigurator.AddConnection(newConnection);
|
|
uint lastAddedConnId = m_uaPubSubConfigurator.FindIdForObject(newConnection);
|
|
Assert.That(
|
|
StatusCode.IsGood(m_uaPubSubConfigurator.RemoveConnection(lastAddedConnId)),
|
|
Is.True);
|
|
Assert.That(CallCountConnectionRemoved, Is.EqualTo(expected).Within(0));
|
|
}
|
|
|
|
[Test(Description = "Validate PublishedDataSetAdded event is triggered")]
|
|
public void ValidatePublishedDataSetAdded()
|
|
{
|
|
int expected = CallCountPublishedDataSetAdded + 1;
|
|
StatusCode result = m_uaPubSubConfigurator.AddPublishedDataSet(
|
|
new PublishedDataSetDataType());
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
Assert.That(CallCountPublishedDataSetAdded, Is.EqualTo(expected).Within(0));
|
|
}
|
|
|
|
[Test(Description = "Validate AddPublishedDataSet returns AddPublishedDataSet")]
|
|
public void ValidateAddPublishedDataSetBadBrowseNameDuplicated()
|
|
{
|
|
var publishedDataSetDataType = new PublishedDataSetDataType { Name = "Name" };
|
|
StatusCode result = m_uaPubSubConfigurator.AddPublishedDataSet(
|
|
publishedDataSetDataType);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
var publishedDataSetDataType2 = new PublishedDataSetDataType { Name = "Name" };
|
|
result = m_uaPubSubConfigurator.AddPublishedDataSet(publishedDataSetDataType2);
|
|
Assert.That(
|
|
result,
|
|
Is.EqualTo(StatusCodes.BadBrowseNameDuplicated),
|
|
CoreUtils.Format(
|
|
"Status code received {0} instead of BadBrowseNameDuplicated",
|
|
result));
|
|
}
|
|
|
|
[Test(Description = "Validate PublishedDataSetRemoved event is triggered")]
|
|
public void ValidatePublishedDataSetRemoved()
|
|
{
|
|
int expected = CallCountPublishedDataSetRemoved + 1;
|
|
var publishedDataSet = new PublishedDataSetDataType();
|
|
StatusCode result = m_uaPubSubConfigurator.AddPublishedDataSet(publishedDataSet);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
uint lastAddedPubDsId = m_uaPubSubConfigurator.FindIdForObject(publishedDataSet);
|
|
result = m_uaPubSubConfigurator.RemovePublishedDataSet(lastAddedPubDsId);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
Assert.That(CallCountConnectionRemoved, Is.EqualTo(expected).Within(0));
|
|
}
|
|
|
|
[Test(Description = "Validate ReaderGroupAdded event is triggered")]
|
|
public void ValidateReaderGroupAdded()
|
|
{
|
|
int expected = CallCountReaderGroupAdded + 1;
|
|
var newConnection = new PubSubConnectionDataType { Enabled = true };
|
|
m_uaPubSubConfigurator.AddConnection(newConnection);
|
|
uint lastAddedConnId = m_uaPubSubConfigurator.FindIdForObject(newConnection);
|
|
Assert.That(
|
|
StatusCode.IsGood(m_uaPubSubConfigurator.AddReaderGroup(
|
|
lastAddedConnId,
|
|
new ReaderGroupDataType { Enabled = true })),
|
|
Is.True);
|
|
Assert.That(CallCountReaderGroupAdded, Is.EqualTo(expected).Within(0));
|
|
}
|
|
|
|
[Test(Description = "Validate ReaderGroupRemoved event is triggered")]
|
|
public void ValidateReaderGroupRemoved()
|
|
{
|
|
int expected = CallCountReaderGroupRemoved + 1;
|
|
var newConnection = new PubSubConnectionDataType { Enabled = true };
|
|
m_uaPubSubConfigurator.AddConnection(newConnection);
|
|
uint lastAddedConnId = m_uaPubSubConfigurator.FindIdForObject(newConnection);
|
|
var readerGroup = new ReaderGroupDataType { Enabled = true };
|
|
Assert.That(StatusCode.IsGood(
|
|
m_uaPubSubConfigurator.AddReaderGroup(lastAddedConnId, readerGroup)), Is.True);
|
|
Assert.That(StatusCode.IsGood(m_uaPubSubConfigurator.RemoveReaderGroup(readerGroup)), Is.True);
|
|
Assert.That(CallCountReaderGroupRemoved, Is.EqualTo(expected).Within(0));
|
|
}
|
|
|
|
[Test(Description = "Validate AddReaderGroup throws ArgumentException if a reader-group is added twice")]
|
|
public void ValidateAddReaderGroupThrowsArgumentExceptionIfAddedTwice()
|
|
{
|
|
var newConnection = new PubSubConnectionDataType { Enabled = true };
|
|
m_uaPubSubConfigurator.AddConnection(newConnection);
|
|
uint lastAddedConnId = m_uaPubSubConfigurator.FindIdForObject(newConnection);
|
|
var readerGroup1 = new ReaderGroupDataType { Enabled = true, Name = "Name" };
|
|
StatusCode result = m_uaPubSubConfigurator.AddReaderGroup(
|
|
lastAddedConnId,
|
|
readerGroup1);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
Assert.Throws<ArgumentException>(
|
|
() => m_uaPubSubConfigurator.AddReaderGroup(lastAddedConnId, readerGroup1),
|
|
"AddReaderGroup shall throw ArgumentException if same reader-group is added twice");
|
|
}
|
|
|
|
[Test(
|
|
Description = "Validate AddReaderGroup returns code BadBrowseNameDuplicated if duplicate name group added."
|
|
)]
|
|
public void ValidateAddReaderGroupReturnsBadBrowseNameDuplicated()
|
|
{
|
|
var newConnection = new PubSubConnectionDataType { Enabled = true };
|
|
m_uaPubSubConfigurator.AddConnection(newConnection);
|
|
uint lastAddedConnId = m_uaPubSubConfigurator.FindIdForObject(newConnection);
|
|
var readerGroup = new ReaderGroupDataType { Enabled = true, Name = "Name" };
|
|
StatusCode result = m_uaPubSubConfigurator.AddReaderGroup(lastAddedConnId, readerGroup);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
var readerGroup2 = new ReaderGroupDataType { Enabled = true, Name = "Name" };
|
|
result = m_uaPubSubConfigurator.AddReaderGroup(lastAddedConnId, readerGroup2);
|
|
|
|
Assert.That(
|
|
result,
|
|
Is.EqualTo(StatusCodes.BadBrowseNameDuplicated),
|
|
CoreUtils.Format(
|
|
"Status code received {0} instead of BadBrowseNameDuplicated",
|
|
result));
|
|
}
|
|
|
|
[Test(
|
|
Description = "Validate AddReaderGroup returns code BadInvalidArgument if parentConnectionId is not a connection object."
|
|
)]
|
|
public void ValidateAddReaderGroupReturnsBadInvalidArgument()
|
|
{
|
|
var readerGroup = new ReaderGroupDataType { Enabled = true, Name = "Name" };
|
|
StatusCode result = m_uaPubSubConfigurator.AddReaderGroup(1, readerGroup);
|
|
Assert.That(
|
|
result,
|
|
Is.EqualTo(StatusCodes.BadInvalidArgument),
|
|
CoreUtils.Format("Status code received {0} instead of BadInvalidArgument", result));
|
|
}
|
|
|
|
[Test(
|
|
Description = "Validate AddREaderGroup throws ArgumentException if parent id is unknown")]
|
|
public void ValidateAddReaderGroupThrowsArgumentExceptionIfInvalidParent()
|
|
{
|
|
const uint lastAddedConnId = 7;
|
|
var readerGroup = new ReaderGroupDataType { Enabled = true, Name = "Name" };
|
|
Assert.Throws<ArgumentException>(
|
|
() => m_uaPubSubConfigurator.AddReaderGroup(lastAddedConnId, readerGroup),
|
|
"AddReaderGroup shall throw ArgumentException if readerGroup is added to invalid parent id");
|
|
}
|
|
|
|
[Test(Description = "Validate WriterGroupAdded event is triggered")]
|
|
public void ValidateWriterGroupAdded()
|
|
{
|
|
int expected = CallCountWriterGroupAdded + 1;
|
|
var newConnection = new PubSubConnectionDataType { Enabled = true };
|
|
m_uaPubSubConfigurator.AddConnection(newConnection);
|
|
uint lastAddedConnId = m_uaPubSubConfigurator.FindIdForObject(newConnection);
|
|
Assert.That(
|
|
StatusCode.IsGood(m_uaPubSubConfigurator.AddWriterGroup(
|
|
lastAddedConnId,
|
|
new WriterGroupDataType { Enabled = true })),
|
|
Is.True);
|
|
Assert.That(CallCountWriterGroupAdded, Is.EqualTo(expected).Within(0));
|
|
}
|
|
|
|
[Test(Description = "Validate WriterGroupRemoved event is triggered")]
|
|
public void ValidateWriterGroupRemoved()
|
|
{
|
|
int expected = CallCountWriterGroupRemoved + 1;
|
|
var newConnection = new PubSubConnectionDataType { Enabled = true };
|
|
m_uaPubSubConfigurator.AddConnection(newConnection);
|
|
uint lastAddedConnId = m_uaPubSubConfigurator.FindIdForObject(newConnection);
|
|
var writerGrp = new WriterGroupDataType { Enabled = true };
|
|
Assert.That(
|
|
StatusCode.IsGood(
|
|
m_uaPubSubConfigurator.AddWriterGroup(lastAddedConnId, writerGrp)),
|
|
Is.True);
|
|
Assert.That(StatusCode.IsGood(m_uaPubSubConfigurator.RemoveWriterGroup(writerGrp)), Is.True);
|
|
Assert.That(CallCountWriterGroupRemoved, Is.EqualTo(expected).Within(0));
|
|
}
|
|
|
|
[Test(
|
|
Description = "Validate AddWriterGroup returns code BadBrowseNameDuplicated if duplicate name writer-group added."
|
|
)]
|
|
public void ValidateAddWriterGroupReturnsBadBrowseNameDuplicated()
|
|
{
|
|
var newConnection = new PubSubConnectionDataType { Enabled = true };
|
|
m_uaPubSubConfigurator.AddConnection(newConnection);
|
|
uint lastAddedConnId = m_uaPubSubConfigurator.FindIdForObject(newConnection);
|
|
var writerGroup1 = new WriterGroupDataType { Enabled = true, Name = "Name" };
|
|
StatusCode result = m_uaPubSubConfigurator.AddWriterGroup(
|
|
lastAddedConnId,
|
|
writerGroup1);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
var writerGroup2 = new WriterGroupDataType { Enabled = true, Name = "Name" };
|
|
result = m_uaPubSubConfigurator.AddWriterGroup(lastAddedConnId, writerGroup2);
|
|
|
|
Assert.That(
|
|
result,
|
|
Is.EqualTo(StatusCodes.BadBrowseNameDuplicated),
|
|
CoreUtils.Format("Status code received {0} instead of BadBrowseNameDuplicated", result));
|
|
}
|
|
|
|
[Test(
|
|
Description = "Validate AddWriterGroup returns code BadInvalidArgument if parentConnectionId is not a connection object."
|
|
)]
|
|
public void ValidateAddWriterGroupReturnsBadInvalidArgument()
|
|
{
|
|
var writerGroup1 = new WriterGroupDataType { Enabled = true, Name = "Name" };
|
|
StatusCode result = m_uaPubSubConfigurator.AddWriterGroup(1, writerGroup1);
|
|
Assert.That(
|
|
result,
|
|
Is.EqualTo(StatusCodes.BadInvalidArgument),
|
|
CoreUtils.Format("Status code received {0} instead of BadInvalidArgument", result));
|
|
}
|
|
|
|
[Test(Description = "Validate AddWriterGroup throws ArgumentException if a WriterGroup is added twice")]
|
|
public void ValidateAddWriterGroupThrowsArgumentExceptionIfAddedTwice()
|
|
{
|
|
var newConnection = new PubSubConnectionDataType { Enabled = true };
|
|
m_uaPubSubConfigurator.AddConnection(newConnection);
|
|
uint lastAddedConnId = m_uaPubSubConfigurator.FindIdForObject(newConnection);
|
|
var writerGroup1 = new WriterGroupDataType { Enabled = true, Name = "Name" };
|
|
StatusCode result = m_uaPubSubConfigurator.AddWriterGroup(
|
|
lastAddedConnId,
|
|
writerGroup1);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
Assert.Throws<ArgumentException>(
|
|
() => m_uaPubSubConfigurator.AddWriterGroup(lastAddedConnId, writerGroup1),
|
|
"AddWriterGroup shall throw ArgumentException if same writerGroup is added twice");
|
|
}
|
|
|
|
[Test(
|
|
Description = "Validate AddWriterGroup throws ArgumentException if parent id is unknown")]
|
|
public void ValidateAddWriterGroupThrowsArgumentExceptionIfInvalidParent()
|
|
{
|
|
const uint lastAddedConnId = 7;
|
|
var writerGroup1 = new WriterGroupDataType { Enabled = true, Name = "Name" };
|
|
Assert.Throws<ArgumentException>(
|
|
() => m_uaPubSubConfigurator.AddWriterGroup(lastAddedConnId, writerGroup1),
|
|
"AddWriterGroup shall throw ArgumentException if writerGroup is added to invalid parent id");
|
|
}
|
|
|
|
[Test(Description = "Validate DataSetReaderAdded event is triggered")]
|
|
public void ValidateDataSetReaderAdded()
|
|
{
|
|
int expected = CallCountDataSetReaderAdded + 1;
|
|
var newConnection = new PubSubConnectionDataType { Enabled = true };
|
|
m_uaPubSubConfigurator.AddConnection(newConnection);
|
|
uint lastAddedConnId = m_uaPubSubConfigurator.FindIdForObject(newConnection);
|
|
|
|
var newReaderGroup = new ReaderGroupDataType { Enabled = true };
|
|
m_uaPubSubConfigurator.AddReaderGroup(lastAddedConnId, newReaderGroup);
|
|
uint lastAddedReaderGroupId = m_uaPubSubConfigurator.FindIdForObject(newReaderGroup);
|
|
|
|
Assert.That(
|
|
StatusCode.IsGood(
|
|
m_uaPubSubConfigurator.AddDataSetReader(
|
|
lastAddedReaderGroupId,
|
|
new DataSetReaderDataType { Enabled = true })),
|
|
Is.True);
|
|
Assert.That(CallCountDataSetReaderAdded, Is.EqualTo(expected).Within(0));
|
|
}
|
|
|
|
[Test(Description = "Validate DataSetReaderRemoved event is triggered")]
|
|
public void ValidateDataSetReaderRemoved()
|
|
{
|
|
int expected = CallCountDataSetReaderRemoved + 1;
|
|
var newConnection = new PubSubConnectionDataType { Enabled = true };
|
|
m_uaPubSubConfigurator.AddConnection(newConnection);
|
|
uint lastAddedConnId = m_uaPubSubConfigurator.FindIdForObject(newConnection);
|
|
|
|
var newReaderGroup = new ReaderGroupDataType { Enabled = true };
|
|
m_uaPubSubConfigurator.AddReaderGroup(lastAddedConnId, newReaderGroup);
|
|
uint lastAddedReaderGroupId = m_uaPubSubConfigurator.FindIdForObject(newReaderGroup);
|
|
|
|
var dsReader = new DataSetReaderDataType { Enabled = true };
|
|
|
|
Assert.That(StatusCode.IsGood(
|
|
m_uaPubSubConfigurator.AddDataSetReader(lastAddedReaderGroupId, dsReader)), Is.True);
|
|
Assert.That(StatusCode.IsGood(m_uaPubSubConfigurator.RemoveDataSetReader(dsReader)), Is.True);
|
|
Assert.That(CallCountDataSetReaderRemoved, Is.EqualTo(expected).Within(0));
|
|
}
|
|
|
|
[Test(
|
|
Description = "Validate AddDataSetReader returns code BadBrowseNameDuplicated if duplicate name dataset added."
|
|
)]
|
|
public void ValidateAddDataSetReaderReturnsBadBrowseNameDuplicated()
|
|
{
|
|
var newConnection = new PubSubConnectionDataType { Enabled = true };
|
|
m_uaPubSubConfigurator.AddConnection(newConnection);
|
|
uint lastAddedConnId = m_uaPubSubConfigurator.FindIdForObject(newConnection);
|
|
var readerGroup1 = new ReaderGroupDataType { Enabled = true, Name = "Name" };
|
|
StatusCode result = m_uaPubSubConfigurator.AddReaderGroup(
|
|
lastAddedConnId,
|
|
readerGroup1);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
uint lastAddedGroup = m_uaPubSubConfigurator.FindIdForObject(readerGroup1);
|
|
var reader1 = new DataSetReaderDataType { Enabled = true, Name = "Name" };
|
|
result = m_uaPubSubConfigurator.AddDataSetReader(lastAddedGroup, reader1);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
var reader2 = new DataSetReaderDataType { Enabled = true, Name = "Name" };
|
|
result = m_uaPubSubConfigurator.AddDataSetReader(lastAddedGroup, reader2);
|
|
|
|
Assert.That(
|
|
result,
|
|
Is.EqualTo(StatusCodes.BadBrowseNameDuplicated),
|
|
CoreUtils.Format("Status code received {0} instead of BadBrowseNameDuplicated", result));
|
|
}
|
|
|
|
[Test(Description = "Validate AddDataSetReader throws ArgumentException if a dataset-reader is added twice")]
|
|
public void ValidateAddDataSetReaderThrowsArgumentException()
|
|
{
|
|
var newConnection = new PubSubConnectionDataType { Enabled = true };
|
|
m_uaPubSubConfigurator.AddConnection(newConnection);
|
|
uint lastAddedConnId = m_uaPubSubConfigurator.FindIdForObject(newConnection);
|
|
var readerGroup1 = new ReaderGroupDataType { Enabled = true, Name = "Name" };
|
|
StatusCode result = m_uaPubSubConfigurator.AddReaderGroup(
|
|
lastAddedConnId,
|
|
readerGroup1);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
uint lastAddedGroup = m_uaPubSubConfigurator.FindIdForObject(readerGroup1);
|
|
var reader1 = new DataSetReaderDataType { Enabled = true, Name = "Name" };
|
|
result = m_uaPubSubConfigurator.AddDataSetReader(lastAddedGroup, reader1);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
Assert.Throws<ArgumentException>(
|
|
() => m_uaPubSubConfigurator.AddDataSetReader(lastAddedGroup, reader1),
|
|
"AddDataSetReader shall throw ArgumentException if same dataset-reader is added twice");
|
|
}
|
|
|
|
[Test(
|
|
Description = "Validate AddDataSetReader returns code BadInvalidArgument if parentgroupId is not a reader-group object."
|
|
)]
|
|
public void ValidateAddDataSetReaderReturnsBadInvalidArgument()
|
|
{
|
|
var reader1 = new DataSetReaderDataType { Enabled = true, Name = "Name" };
|
|
StatusCode result = m_uaPubSubConfigurator.AddDataSetReader(1, reader1);
|
|
Assert.That(
|
|
result,
|
|
Is.EqualTo(StatusCodes.BadInvalidArgument),
|
|
CoreUtils.Format("Status code received {0} instead of BadInvalidArgument", result));
|
|
}
|
|
|
|
[Test(Description = "Validate DataSetWriterAdded event is triggered")]
|
|
public void ValidateDataSetWriterAdded()
|
|
{
|
|
int expected = CallCountDataSetWriterAdded + 1;
|
|
var newConnection = new PubSubConnectionDataType { Enabled = true };
|
|
m_uaPubSubConfigurator.AddConnection(newConnection);
|
|
|
|
uint lastAddedConnId = m_uaPubSubConfigurator.FindIdForObject(newConnection);
|
|
|
|
var newWriterGroup = new WriterGroupDataType { Enabled = true };
|
|
m_uaPubSubConfigurator.AddWriterGroup(lastAddedConnId, newWriterGroup);
|
|
uint lastAddedWriterGroupId = m_uaPubSubConfigurator.FindIdForObject(newWriterGroup);
|
|
|
|
Assert.That(
|
|
StatusCode.IsGood(
|
|
m_uaPubSubConfigurator.AddDataSetWriter(
|
|
lastAddedWriterGroupId,
|
|
new DataSetWriterDataType { Enabled = true })),
|
|
Is.True);
|
|
Assert.That(CallCountDataSetWriterAdded, Is.EqualTo(expected).Within(0));
|
|
}
|
|
|
|
[Test(Description = "Validate DataSetWriterRemoved event is triggered")]
|
|
public void ValidateDataSetWriterRemoved()
|
|
{
|
|
int expected = CallCountDataSetWriterRemoved + 1;
|
|
var newConnection = new PubSubConnectionDataType { Enabled = true };
|
|
m_uaPubSubConfigurator.AddConnection(newConnection);
|
|
|
|
uint lastAddedConnId = m_uaPubSubConfigurator.FindIdForObject(newConnection);
|
|
|
|
var newWriterGroup = new WriterGroupDataType { Enabled = true };
|
|
m_uaPubSubConfigurator.AddWriterGroup(lastAddedConnId, newWriterGroup);
|
|
uint lastAddedWriterGroupId = m_uaPubSubConfigurator.FindIdForObject(newWriterGroup);
|
|
|
|
var dsWriter = new DataSetWriterDataType { Enabled = true };
|
|
Assert.That(StatusCode.IsGood(
|
|
m_uaPubSubConfigurator.AddDataSetWriter(lastAddedWriterGroupId, dsWriter)), Is.True);
|
|
Assert.That(StatusCode.IsGood(m_uaPubSubConfigurator.RemoveDataSetWriter(dsWriter)), Is.True);
|
|
Assert.That(CallCountDataSetWriterRemoved, Is.EqualTo(expected).Within(0));
|
|
}
|
|
|
|
[Test(
|
|
Description = "Validate AddDataSetWriter returns code BadBrowseNameDuplicated if duplicate name dataset added."
|
|
)]
|
|
public void ValidateAddDataSetWriterReturnsBadBrowseNameDuplicated()
|
|
{
|
|
var newConnection = new PubSubConnectionDataType { Enabled = true };
|
|
m_uaPubSubConfigurator.AddConnection(newConnection);
|
|
uint lastAddedConnId = m_uaPubSubConfigurator.FindIdForObject(newConnection);
|
|
var writerGroup1 = new WriterGroupDataType { Enabled = true, Name = "Name" };
|
|
StatusCode result = m_uaPubSubConfigurator.AddWriterGroup(
|
|
lastAddedConnId,
|
|
writerGroup1);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
uint lastAddedGroup = m_uaPubSubConfigurator.FindIdForObject(writerGroup1);
|
|
var writer1 = new DataSetWriterDataType { Enabled = true, Name = "Name" };
|
|
result = m_uaPubSubConfigurator.AddDataSetWriter(lastAddedGroup, writer1);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
var writer2 = new DataSetWriterDataType { Enabled = true, Name = "Name" };
|
|
result = m_uaPubSubConfigurator.AddDataSetWriter(lastAddedGroup, writer2);
|
|
|
|
Assert.That(
|
|
result,
|
|
Is.EqualTo(StatusCodes.BadBrowseNameDuplicated),
|
|
CoreUtils.Format("Status code received {0} instead of BadBrowseNameDuplicated", result));
|
|
}
|
|
|
|
[Test(Description = "Validate AddDataSetWriter throws ArgumentException if a dataset-reader is added twice")]
|
|
public void ValidateAddDataSetWriterThrowsArgumentException()
|
|
{
|
|
var newConnection = new PubSubConnectionDataType { Enabled = true };
|
|
m_uaPubSubConfigurator.AddConnection(newConnection);
|
|
uint lastAddedConnId = m_uaPubSubConfigurator.FindIdForObject(newConnection);
|
|
var writerGroup1 = new WriterGroupDataType { Enabled = true, Name = "Name" };
|
|
StatusCode result = m_uaPubSubConfigurator.AddWriterGroup(
|
|
lastAddedConnId,
|
|
writerGroup1);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
uint lastAddedGroup = m_uaPubSubConfigurator.FindIdForObject(writerGroup1);
|
|
var writer1 = new DataSetWriterDataType { Enabled = true, Name = "Name" };
|
|
result = m_uaPubSubConfigurator.AddDataSetWriter(lastAddedGroup, writer1);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
Assert.Throws<ArgumentException>(
|
|
() => m_uaPubSubConfigurator.AddDataSetWriter(lastAddedGroup, writer1),
|
|
"AddDataSetWriter shall throw ArgumentException if same dataset-reader is added twice");
|
|
}
|
|
|
|
[Test(
|
|
Description = "Validate AddDataSetWriter returns code BadInvalidArgument if parentgroupId is not a reader-group object."
|
|
)]
|
|
public void ValidateAddDataSetWriterReturnsBadInvalidArgument()
|
|
{
|
|
var writer1 = new DataSetWriterDataType { Enabled = true, Name = "Name" };
|
|
StatusCode result = m_uaPubSubConfigurator.AddDataSetWriter(1, writer1);
|
|
Assert.That(
|
|
result,
|
|
Is.EqualTo(StatusCodes.BadInvalidArgument),
|
|
CoreUtils.Format("Status code received {0} instead of BadInvalidArgument", result));
|
|
}
|
|
|
|
[Test(Description = "Validate Publisher ConnectionAdded event is reflected in the parent UaPubSubApplication")]
|
|
public void ValidatePubConnectionAddedAndReflectedInApplication()
|
|
{
|
|
ITelemetryContext telemetry = NUnitTelemetryContext.Create();
|
|
// Prepare an empty configuration for testing the interaction between UaPubSubApplication
|
|
// and UaPubSubConfigurator
|
|
using var uaPubSubApplication = UaPubSubApplication.Create(telemetry);
|
|
|
|
int targetIdx = uaPubSubApplication.PubSubConnections.Count;
|
|
foreach (PubSubConnectionDataType pscon in m_pubConfigurationLoaded.Connections)
|
|
{
|
|
StatusCode result = uaPubSubApplication.UaPubSubConfigurator.AddConnection(pscon);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
Assert.That(
|
|
pscon,
|
|
Is.EqualTo(uaPubSubApplication.PubSubConnections[targetIdx].PubSubConnectionConfiguration));
|
|
|
|
targetIdx++;
|
|
}
|
|
}
|
|
|
|
[Test(
|
|
Description = "Validate Publisher ConnectionRemoved event is reflected in the parent UaPubSubApplication"
|
|
)]
|
|
public void ValidatePubConnectionRemovedAndReflectedInApplication()
|
|
{
|
|
ITelemetryContext telemetry = NUnitTelemetryContext.Create();
|
|
// Prepare an empty configuration for testing the interaction between UaPubSubApplication
|
|
// and UaPubSubConfigurator
|
|
using var uaPubSubApplication = UaPubSubApplication.Create(telemetry);
|
|
|
|
int initialCount = uaPubSubApplication.PubSubConnections.Count;
|
|
foreach (PubSubConnectionDataType pscon in m_pubConfigurationLoaded.Connections)
|
|
{
|
|
StatusCode result = uaPubSubApplication.UaPubSubConfigurator.AddConnection(pscon);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
result = uaPubSubApplication.UaPubSubConfigurator.RemoveConnection(pscon);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
Assert.That(uaPubSubApplication.PubSubConnections.Count, Is.EqualTo(initialCount));
|
|
}
|
|
}
|
|
|
|
[Test(Description = "Validate Publisher AddWriterGroup is reflected in the parent UaPubSubApplication")]
|
|
public void ValidateWriterGroupAddedAndReflectedInApplication()
|
|
{
|
|
ITelemetryContext telemetry = NUnitTelemetryContext.Create();
|
|
// Create an UaPubSubApplication with an empty configuration
|
|
using var uaPubSubApplication = UaPubSubApplication.Create(telemetry);
|
|
|
|
int targetIdx = uaPubSubApplication.PubSubConnections.Count;
|
|
foreach (PubSubConnectionDataType pscon in m_pubConfigurationLoaded.Connections)
|
|
{
|
|
PubSubConnectionDataType psconNew = CoreUtils.Clone(pscon);
|
|
|
|
StatusCode result = uaPubSubApplication.UaPubSubConfigurator
|
|
.AddConnection(psconNew);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
// Add the first writer group in the configuration and check that it is reflected in Application
|
|
int lastAddedWriterGroupIdx = uaPubSubApplication
|
|
.PubSubConnections[targetIdx]
|
|
.PubSubConnectionConfiguration
|
|
.WriterGroups
|
|
.Count;
|
|
|
|
WriterGroupDataType writerGroup = CoreUtils.Clone(psconNew.WriterGroups[0]);
|
|
writerGroup.Name += "_";
|
|
|
|
uint lastAddedConnId = uaPubSubApplication.UaPubSubConfigurator
|
|
.FindIdForObject(psconNew);
|
|
uaPubSubApplication.UaPubSubConfigurator
|
|
.AddWriterGroup(lastAddedConnId, writerGroup);
|
|
|
|
Assert.That(
|
|
psconNew,
|
|
Is.EqualTo(uaPubSubApplication.PubSubConnections[targetIdx].PubSubConnectionConfiguration));
|
|
Assert.That(
|
|
writerGroup,
|
|
Is.EqualTo(uaPubSubApplication.PubSubConnections[targetIdx].PubSubConnectionConfiguration
|
|
.WriterGroups[
|
|
lastAddedWriterGroupIdx
|
|
]));
|
|
break;
|
|
}
|
|
}
|
|
|
|
[Test(Description = "Validate Publisher RemoveWriterGroup is reflected in the parent UaPubSubApplication")]
|
|
public void ValidateWriterGroupRemovedAndReflectedInApplication()
|
|
{
|
|
ITelemetryContext telemetry = NUnitTelemetryContext.Create();
|
|
// Create an UaPubSubApplication with an empty configuration
|
|
using var uaPubSubApplication = UaPubSubApplication.Create(telemetry);
|
|
|
|
int targetIdx = uaPubSubApplication.PubSubConnections.Count;
|
|
foreach (PubSubConnectionDataType pscon in m_pubConfigurationLoaded.Connections)
|
|
{
|
|
PubSubConnectionDataType psconNew = CoreUtils.Clone(pscon);
|
|
|
|
StatusCode result = uaPubSubApplication.UaPubSubConfigurator
|
|
.AddConnection(psconNew);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
// Add the first writer group in the configuration and check that it is reflected in Application
|
|
|
|
WriterGroupDataType writerGroup = CoreUtils.Clone(psconNew.WriterGroups[0]);
|
|
writerGroup.Name += "_";
|
|
|
|
uint lastAddedConnId = uaPubSubApplication.UaPubSubConfigurator
|
|
.FindIdForObject(psconNew);
|
|
|
|
int nrInitialWriterGroups = uaPubSubApplication
|
|
.PubSubConnections[targetIdx]
|
|
.PubSubConnectionConfiguration
|
|
.WriterGroups
|
|
.Count;
|
|
|
|
result = uaPubSubApplication.UaPubSubConfigurator
|
|
.AddWriterGroup(lastAddedConnId, writerGroup);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
result = uaPubSubApplication.UaPubSubConfigurator.RemoveWriterGroup(writerGroup);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
int nrActualWriterGroups = uaPubSubApplication
|
|
.PubSubConnections[targetIdx]
|
|
.PubSubConnectionConfiguration
|
|
.WriterGroups
|
|
.Count;
|
|
|
|
Assert.That(nrActualWriterGroups, Is.EqualTo(nrInitialWriterGroups));
|
|
|
|
break;
|
|
}
|
|
}
|
|
|
|
[Test(Description = "Validate Publisher AddDataSetWriter is reflected in the parent UaPubSubApplication")]
|
|
public void ValidateDataSetWriterAddedAndReflectedInApplication()
|
|
{
|
|
ITelemetryContext telemetry = NUnitTelemetryContext.Create();
|
|
|
|
// Create an UaPubSubApplication with an empty configuration
|
|
using var uaPubSubApplication = UaPubSubApplication.Create(telemetry);
|
|
|
|
int targetIdx = uaPubSubApplication.PubSubConnections.Count;
|
|
foreach (PubSubConnectionDataType pscon in m_pubConfigurationLoaded.Connections)
|
|
{
|
|
PubSubConnectionDataType psconNew = CoreUtils.Clone(pscon);
|
|
|
|
StatusCode result = uaPubSubApplication.UaPubSubConfigurator
|
|
.AddConnection(psconNew);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
// Add the first writer group in the configuration and check that it is reflected in Application
|
|
int lastAddedWriterGroupIdx = uaPubSubApplication
|
|
.PubSubConnections[targetIdx]
|
|
.PubSubConnectionConfiguration
|
|
.WriterGroups
|
|
.Count;
|
|
|
|
WriterGroupDataType writerGroup = CoreUtils.Clone(psconNew.WriterGroups[0]);
|
|
uint lastAddedConnId = uaPubSubApplication.UaPubSubConfigurator
|
|
.FindIdForObject(psconNew);
|
|
writerGroup.Name += "_";
|
|
|
|
result = uaPubSubApplication.UaPubSubConfigurator
|
|
.AddWriterGroup(lastAddedConnId, writerGroup);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
uint addedWriterGroupId = uaPubSubApplication.UaPubSubConfigurator
|
|
.FindIdForObject(writerGroup);
|
|
Assert.That(
|
|
psconNew,
|
|
Is.EqualTo(uaPubSubApplication.PubSubConnections[targetIdx].PubSubConnectionConfiguration));
|
|
Assert.That(
|
|
writerGroup,
|
|
Is.EqualTo(uaPubSubApplication.PubSubConnections[targetIdx].PubSubConnectionConfiguration
|
|
.WriterGroups[
|
|
lastAddedWriterGroupIdx
|
|
]));
|
|
|
|
// Add the first data set writer in the configuration and check that it is reflected in Application
|
|
int lastAddedDataSetWriterIdx = uaPubSubApplication
|
|
.PubSubConnections[targetIdx]
|
|
.PubSubConnectionConfiguration
|
|
.WriterGroups[0]
|
|
.DataSetWriters
|
|
.Count;
|
|
DataSetWriterDataType dataSetWriter = CoreUtils.Clone(psconNew.WriterGroups[0].DataSetWriters[0]);
|
|
dataSetWriter.Name += "_";
|
|
result = uaPubSubApplication.UaPubSubConfigurator
|
|
.AddDataSetWriter(addedWriterGroupId, dataSetWriter);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
Assert.That(
|
|
dataSetWriter,
|
|
Is.EqualTo(uaPubSubApplication
|
|
.PubSubConnections[targetIdx]
|
|
.PubSubConnectionConfiguration
|
|
.WriterGroups[lastAddedWriterGroupIdx]
|
|
.DataSetWriters[lastAddedDataSetWriterIdx]));
|
|
break;
|
|
}
|
|
}
|
|
|
|
[Test(Description = "Validate Publisher RemoveDataSetWriter is reflected in the parent UaPubSubApplication")]
|
|
public void ValidateDataSetWriterRemovedAndReflectedInApplication()
|
|
{
|
|
ITelemetryContext telemetry = NUnitTelemetryContext.Create();
|
|
// Create an UaPubSubApplication with an empty configuration
|
|
using var uaPubSubApplication = UaPubSubApplication.Create(telemetry);
|
|
|
|
int targetIdx = uaPubSubApplication.PubSubConnections.Count;
|
|
foreach (PubSubConnectionDataType pscon in m_pubConfigurationLoaded.Connections)
|
|
{
|
|
PubSubConnectionDataType psconNew = CoreUtils.Clone(pscon);
|
|
|
|
StatusCode result = uaPubSubApplication.UaPubSubConfigurator
|
|
.AddConnection(psconNew);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
// Add the first writer group in the configuration and check that it is reflected in Application
|
|
int lastAddedWriterGroupIdx = uaPubSubApplication
|
|
.PubSubConnections[targetIdx]
|
|
.PubSubConnectionConfiguration
|
|
.WriterGroups
|
|
.Count;
|
|
|
|
WriterGroupDataType writerGroup = CoreUtils.Clone(psconNew.WriterGroups[0]);
|
|
uint lastAddedConnId = uaPubSubApplication.UaPubSubConfigurator
|
|
.FindIdForObject(psconNew);
|
|
writerGroup.Name += "_";
|
|
|
|
result = uaPubSubApplication.UaPubSubConfigurator
|
|
.AddWriterGroup(lastAddedConnId, writerGroup);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
uint addedWriterGroupId = uaPubSubApplication.UaPubSubConfigurator
|
|
.FindIdForObject(writerGroup);
|
|
Assert.That(
|
|
psconNew,
|
|
Is.EqualTo(uaPubSubApplication.PubSubConnections[targetIdx].PubSubConnectionConfiguration));
|
|
Assert.That(
|
|
writerGroup,
|
|
Is.EqualTo(uaPubSubApplication.PubSubConnections[targetIdx].PubSubConnectionConfiguration
|
|
.WriterGroups[
|
|
lastAddedWriterGroupIdx
|
|
]));
|
|
|
|
// Add the first data set writer in the configuration and check that it is reflected in Application
|
|
DataSetWriterDataType dataSetWriter = CoreUtils.Clone(psconNew.WriterGroups[0].DataSetWriters[0]);
|
|
dataSetWriter.Name += "_";
|
|
|
|
int nrInitialDsWriters = uaPubSubApplication
|
|
.PubSubConnections[targetIdx]
|
|
.PubSubConnectionConfiguration
|
|
.WriterGroups[0]
|
|
.DataSetWriters
|
|
.Count;
|
|
|
|
result = uaPubSubApplication.UaPubSubConfigurator
|
|
.AddDataSetWriter(addedWriterGroupId, dataSetWriter);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
result = uaPubSubApplication.UaPubSubConfigurator
|
|
.RemoveDataSetWriter(dataSetWriter);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
int nrActualDsWriters = uaPubSubApplication
|
|
.PubSubConnections[targetIdx]
|
|
.PubSubConnectionConfiguration
|
|
.WriterGroups[0]
|
|
.DataSetWriters
|
|
.Count;
|
|
|
|
Assert.That(nrActualDsWriters, Is.EqualTo(nrInitialDsWriters));
|
|
break;
|
|
}
|
|
}
|
|
|
|
[Test(Description = "Validate Publisher AddPublishedSet is reflected in the parent UaPubSubApplication")]
|
|
public void ValidatePublishedDataSetAddedAndReflectedInApplication()
|
|
{
|
|
ITelemetryContext telemetry = NUnitTelemetryContext.Create();
|
|
// Prepare an empty configuration for testing the interaction between UaPubSubApplication
|
|
// and UaPubSubConfigurator
|
|
var appConfPubSubConfiguration = new PubSubConfigurationDataType
|
|
{
|
|
Enabled = true,
|
|
Connections = [],
|
|
PublishedDataSets = []
|
|
};
|
|
using var uaPubSubApplication = UaPubSubApplication.Create(appConfPubSubConfiguration, telemetry);
|
|
|
|
int targetIdx = uaPubSubApplication.UaPubSubConfigurator.PubSubConfiguration
|
|
.PublishedDataSets
|
|
.Count;
|
|
foreach (PublishedDataSetDataType pds in m_pubConfigurationLoaded.PublishedDataSets)
|
|
{
|
|
StatusCode result = uaPubSubApplication.UaPubSubConfigurator
|
|
.AddPublishedDataSet(pds);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
Assert.That(
|
|
pds,
|
|
Is.EqualTo(uaPubSubApplication.UaPubSubConfigurator.PubSubConfiguration
|
|
.PublishedDataSets[targetIdx]));
|
|
|
|
targetIdx++;
|
|
}
|
|
}
|
|
|
|
[Test(Description = "Validate Publisher RemovePublishedSet is reflected in the parent UaPubSubApplication")]
|
|
public void ValidatePublishedDataSetRemovedAndReflectedInApplication()
|
|
{
|
|
ITelemetryContext telemetry = NUnitTelemetryContext.Create();
|
|
// Prepare an empty configuration for testing the interaction between UaPubSubApplication
|
|
// and UaPubSubConfigurator
|
|
var appConfPubSubConfiguration = new PubSubConfigurationDataType
|
|
{
|
|
Enabled = true,
|
|
Connections = [],
|
|
PublishedDataSets = []
|
|
};
|
|
using var uaPubSubApplication = UaPubSubApplication.Create(appConfPubSubConfiguration, telemetry);
|
|
|
|
int initialNrPublishedDs = uaPubSubApplication
|
|
.UaPubSubConfigurator
|
|
.PubSubConfiguration
|
|
.PublishedDataSets
|
|
.Count;
|
|
foreach (PublishedDataSetDataType pds in m_pubConfigurationLoaded.PublishedDataSets)
|
|
{
|
|
StatusCode result = uaPubSubApplication.UaPubSubConfigurator
|
|
.AddPublishedDataSet(pds);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
result = uaPubSubApplication.UaPubSubConfigurator.RemovePublishedDataSet(pds);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
}
|
|
int actualNrPublishedDs = uaPubSubApplication
|
|
.UaPubSubConfigurator
|
|
.PubSubConfiguration
|
|
.PublishedDataSets
|
|
.Count;
|
|
Assert.That(actualNrPublishedDs, Is.EqualTo(initialNrPublishedDs));
|
|
}
|
|
|
|
[Test(Description = "Validate Subscriber ConnectionAdded event is reflected in the parent UaPubSubApplication")]
|
|
public void ValidateSubConnectionAddedAndReflectedInApplication()
|
|
{
|
|
ITelemetryContext telemetry = NUnitTelemetryContext.Create();
|
|
// Prepare an empty configuration for testing the interaction between UaPubSubApplication
|
|
// and UaPubSubConfigurator
|
|
var appConfPubSubConfiguration = new PubSubConfigurationDataType
|
|
{
|
|
Enabled = true,
|
|
Connections = [],
|
|
PublishedDataSets = []
|
|
};
|
|
using var uaPubSubApplication = UaPubSubApplication.Create(appConfPubSubConfiguration, telemetry);
|
|
|
|
int targetIdx = uaPubSubApplication.PubSubConnections.Count;
|
|
foreach (PubSubConnectionDataType pscon in m_subConfigurationLoaded.Connections)
|
|
{
|
|
StatusCode result = uaPubSubApplication.UaPubSubConfigurator.AddConnection(pscon);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
Assert.That(
|
|
pscon,
|
|
Is.EqualTo(uaPubSubApplication.PubSubConnections[targetIdx].PubSubConnectionConfiguration));
|
|
|
|
targetIdx++;
|
|
}
|
|
}
|
|
|
|
[Test(
|
|
Description = "Validate Subscriber ConnectionRemoved event is reflected in the parent UaPubSubApplication"
|
|
)]
|
|
public void ValidateSubConnectionRemovedAndReflectedInApplication()
|
|
{
|
|
ITelemetryContext telemetry = NUnitTelemetryContext.Create();
|
|
// Prepare an empty configuration for testing the interaction between UaPubSubApplication
|
|
// and UaPubSubConfigurator
|
|
using var uaPubSubApplication = UaPubSubApplication.Create(telemetry);
|
|
|
|
int initialCount = uaPubSubApplication.PubSubConnections.Count;
|
|
foreach (PubSubConnectionDataType pscon in m_subConfigurationLoaded.Connections)
|
|
{
|
|
StatusCode result = uaPubSubApplication.UaPubSubConfigurator.AddConnection(pscon);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
result = uaPubSubApplication.UaPubSubConfigurator.RemoveConnection(pscon);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
Assert.That(uaPubSubApplication.PubSubConnections.Count, Is.EqualTo(initialCount));
|
|
}
|
|
}
|
|
|
|
[Test(Description = "Validate Subscriber AddReaderGroup is reflected in the parent UaPubSubApplication")]
|
|
public void ValidateReaderGroupAddedAndReflectedInApplication()
|
|
{
|
|
ITelemetryContext telemetry = NUnitTelemetryContext.Create();
|
|
// Prepare an empty configuration for testing the interaction between UaPubSubApplication
|
|
// and UaPubSubConfigurator
|
|
var appConfPubSubConfiguration = new PubSubConfigurationDataType
|
|
{
|
|
Enabled = true,
|
|
Connections = [],
|
|
PublishedDataSets = []
|
|
};
|
|
using var uaPubSubApplication = UaPubSubApplication.Create(appConfPubSubConfiguration, telemetry);
|
|
|
|
int targetIdx = uaPubSubApplication.PubSubConnections.Count;
|
|
foreach (PubSubConnectionDataType pscon in m_subConfigurationLoaded.Connections)
|
|
{
|
|
PubSubConnectionDataType psconNew = CoreUtils.Clone(pscon);
|
|
|
|
StatusCode result = uaPubSubApplication.UaPubSubConfigurator
|
|
.AddConnection(psconNew);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
// Add the first writer group in the configuration and check that it is reflected in Application
|
|
int lastAddedReaderGroupIdx = uaPubSubApplication
|
|
.PubSubConnections[targetIdx]
|
|
.PubSubConnectionConfiguration
|
|
.ReaderGroups
|
|
.Count;
|
|
|
|
ReaderGroupDataType readerGroup = CoreUtils.Clone(psconNew.ReaderGroups[0]);
|
|
readerGroup.Name += "_";
|
|
uint lastAddedConnId = uaPubSubApplication.UaPubSubConfigurator
|
|
.FindIdForObject(psconNew);
|
|
|
|
uaPubSubApplication.UaPubSubConfigurator
|
|
.AddReaderGroup(lastAddedConnId, readerGroup);
|
|
|
|
Assert.That(
|
|
psconNew,
|
|
Is.EqualTo(uaPubSubApplication.PubSubConnections[targetIdx].PubSubConnectionConfiguration));
|
|
Assert.That(
|
|
readerGroup,
|
|
Is.EqualTo(uaPubSubApplication.PubSubConnections[targetIdx].PubSubConnectionConfiguration
|
|
.ReaderGroups[
|
|
lastAddedReaderGroupIdx
|
|
]));
|
|
break;
|
|
}
|
|
}
|
|
|
|
[Test(Description = "Validate Subscriber RemoveReaderGroup is reflected in the parent UaPubSubApplication")]
|
|
public void ValidateReaderGroupRemovedAndReflectedInApplication()
|
|
{
|
|
ITelemetryContext telemetry = NUnitTelemetryContext.Create();
|
|
// Prepare an empty configuration for testing the interaction between UaPubSubApplication
|
|
// and UaPubSubConfigurator
|
|
var appConfPubSubConfiguration = new PubSubConfigurationDataType
|
|
{
|
|
Enabled = true,
|
|
Connections = [],
|
|
PublishedDataSets = []
|
|
};
|
|
using var uaPubSubApplication = UaPubSubApplication.Create(appConfPubSubConfiguration, telemetry);
|
|
|
|
int targetIdx = uaPubSubApplication.PubSubConnections.Count;
|
|
foreach (PubSubConnectionDataType pscon in m_subConfigurationLoaded.Connections)
|
|
{
|
|
PubSubConnectionDataType psconNew = CoreUtils.Clone(pscon);
|
|
|
|
StatusCode result = uaPubSubApplication.UaPubSubConfigurator
|
|
.AddConnection(psconNew);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
// Add the first writer group in the configuration and check that it is reflected in Application
|
|
ReaderGroupDataType readerGroup = CoreUtils.Clone(psconNew.ReaderGroups[0]);
|
|
readerGroup.Name += "_";
|
|
uint lastAddedConnId = uaPubSubApplication.UaPubSubConfigurator
|
|
.FindIdForObject(psconNew);
|
|
|
|
int nrInitialReaderGroups = uaPubSubApplication
|
|
.PubSubConnections[targetIdx]
|
|
.PubSubConnectionConfiguration
|
|
.ReaderGroups
|
|
.Count;
|
|
|
|
result = uaPubSubApplication.UaPubSubConfigurator
|
|
.AddReaderGroup(lastAddedConnId, readerGroup);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
result = uaPubSubApplication.UaPubSubConfigurator
|
|
.RemoveReaderGroup(readerGroup);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
int nrActualReaderGroups = uaPubSubApplication
|
|
.PubSubConnections[targetIdx]
|
|
.PubSubConnectionConfiguration
|
|
.ReaderGroups
|
|
.Count;
|
|
|
|
Assert.That(nrActualReaderGroups, Is.EqualTo(nrInitialReaderGroups));
|
|
break;
|
|
}
|
|
}
|
|
|
|
[Test(Description = "Validate Subscriber AddDataSetReader is reflected in the parent UaPubSubApplication")]
|
|
public void ValidateDataSetReaderAddedAndReflectedInApplication()
|
|
{
|
|
ITelemetryContext telemetry = NUnitTelemetryContext.Create();
|
|
// Create UaPubSubConfigurator with empty configuration
|
|
using var uaPubSubApplication = UaPubSubApplication.Create(telemetry);
|
|
|
|
int targetIdx = uaPubSubApplication.PubSubConnections.Count;
|
|
foreach (PubSubConnectionDataType pscon in m_subConfigurationLoaded.Connections)
|
|
{
|
|
PubSubConnectionDataType psconNew = CoreUtils.Clone(pscon);
|
|
|
|
StatusCode result = uaPubSubApplication.UaPubSubConfigurator
|
|
.AddConnection(psconNew);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
// Add the first Reader group in the configuration and check that it is reflected in Application
|
|
int lastAddedReaderGroupIdx = uaPubSubApplication
|
|
.PubSubConnections[targetIdx]
|
|
.PubSubConnectionConfiguration
|
|
.ReaderGroups
|
|
.Count;
|
|
|
|
ReaderGroupDataType readerGroup = CoreUtils.Clone(psconNew.ReaderGroups[0]);
|
|
readerGroup.Name += "_";
|
|
uint lastAddedConnId = uaPubSubApplication.UaPubSubConfigurator
|
|
.FindIdForObject(psconNew);
|
|
|
|
result = uaPubSubApplication.UaPubSubConfigurator
|
|
.AddReaderGroup(lastAddedConnId, readerGroup);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
Assert.That(
|
|
psconNew,
|
|
Is.EqualTo(uaPubSubApplication.PubSubConnections[targetIdx].PubSubConnectionConfiguration));
|
|
Assert.That(
|
|
readerGroup,
|
|
Is.EqualTo(uaPubSubApplication.PubSubConnections[targetIdx].PubSubConnectionConfiguration
|
|
.ReaderGroups[
|
|
lastAddedReaderGroupIdx
|
|
]));
|
|
|
|
// Add the first data set Reader in the configuration and check that it is reflected in Application
|
|
int lastAddedDataSetReaderIdx = uaPubSubApplication
|
|
.PubSubConnections[targetIdx]
|
|
.PubSubConnectionConfiguration
|
|
.ReaderGroups[0]
|
|
.DataSetReaders
|
|
.Count;
|
|
DataSetReaderDataType dataSetReader = CoreUtils.Clone(psconNew.ReaderGroups[0].DataSetReaders[0]);
|
|
dataSetReader.Name += "_";
|
|
uint addedReaderGroupId = uaPubSubApplication.UaPubSubConfigurator
|
|
.FindIdForObject(readerGroup);
|
|
result = uaPubSubApplication.UaPubSubConfigurator
|
|
.AddDataSetReader(addedReaderGroupId, dataSetReader);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
Assert.That(
|
|
dataSetReader,
|
|
Is.EqualTo(uaPubSubApplication
|
|
.PubSubConnections[targetIdx]
|
|
.PubSubConnectionConfiguration
|
|
.ReaderGroups[lastAddedReaderGroupIdx]
|
|
.DataSetReaders[lastAddedDataSetReaderIdx]));
|
|
break;
|
|
}
|
|
}
|
|
|
|
[Test(Description = "Validate Subscriber AddDataSetReader is reflected in the parent UaPubSubApplication")]
|
|
public void ValidateDataSetReaderRemovedAndReflectedInApplication()
|
|
{
|
|
ITelemetryContext telemetry = NUnitTelemetryContext.Create();
|
|
// Create UaPubSubConfigurator with empty configuration
|
|
using var uaPubSubApplication = UaPubSubApplication.Create(telemetry);
|
|
|
|
int targetIdx = uaPubSubApplication.PubSubConnections.Count;
|
|
foreach (PubSubConnectionDataType pscon in m_subConfigurationLoaded.Connections)
|
|
{
|
|
PubSubConnectionDataType psconNew = CoreUtils.Clone(pscon);
|
|
|
|
StatusCode result = uaPubSubApplication.UaPubSubConfigurator
|
|
.AddConnection(psconNew);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
// Add the first Reader group in the configuration and check that it is reflected in Application
|
|
int lastAddedReaderGroupIdx = uaPubSubApplication
|
|
.PubSubConnections[targetIdx]
|
|
.PubSubConnectionConfiguration
|
|
.ReaderGroups
|
|
.Count;
|
|
|
|
ReaderGroupDataType readerGroup = CoreUtils.Clone(psconNew.ReaderGroups[0]);
|
|
readerGroup.Name += "_";
|
|
uint lastAddedConnId = uaPubSubApplication.UaPubSubConfigurator
|
|
.FindIdForObject(psconNew);
|
|
|
|
result = uaPubSubApplication.UaPubSubConfigurator
|
|
.AddReaderGroup(lastAddedConnId, readerGroup);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
uint addedReaderGroupId = uaPubSubApplication.UaPubSubConfigurator
|
|
.FindIdForObject(readerGroup);
|
|
Assert.That(
|
|
psconNew,
|
|
Is.EqualTo(uaPubSubApplication.PubSubConnections[targetIdx].PubSubConnectionConfiguration));
|
|
Assert.That(
|
|
readerGroup,
|
|
Is.EqualTo(uaPubSubApplication.PubSubConnections[targetIdx].PubSubConnectionConfiguration
|
|
.ReaderGroups[
|
|
lastAddedReaderGroupIdx
|
|
]));
|
|
|
|
// Add the first data set Reader in the configuration and check that it is reflected in Application
|
|
DataSetReaderDataType dataSetReader = CoreUtils.Clone(psconNew.ReaderGroups[0].DataSetReaders[0]);
|
|
dataSetReader.Name += "_";
|
|
|
|
int nrInitialDsReaders = uaPubSubApplication
|
|
.PubSubConnections[targetIdx]
|
|
.PubSubConnectionConfiguration
|
|
.ReaderGroups[0]
|
|
.DataSetReaders
|
|
.Count;
|
|
|
|
result = uaPubSubApplication.UaPubSubConfigurator
|
|
.AddDataSetReader(addedReaderGroupId, dataSetReader);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
result = uaPubSubApplication.UaPubSubConfigurator
|
|
.RemoveDataSetReader(dataSetReader);
|
|
Assert.That(StatusCode.IsGood(result), Is.True, "Status code received: " + result);
|
|
|
|
int nrActualDsReaders = uaPubSubApplication
|
|
.PubSubConnections[targetIdx]
|
|
.PubSubConnectionConfiguration
|
|
.ReaderGroups[0]
|
|
.DataSetReaders
|
|
.Count;
|
|
|
|
Assert.That(nrActualDsReaders, Is.EqualTo(nrInitialDsReaders));
|
|
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|