From 58bf687a7d2d6126a0424c979049fa69e223016a Mon Sep 17 00:00:00 2001 From: Isaak Date: Wed, 6 Mar 2024 12:48:22 -0500 Subject: [PATCH] 2312 updated INotificationDataSinkMigratorTest --- .../migrations/INotificationDataSinkMigratorTest.java | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/streampipes-extensions/streampipes-sinks-notifications-jvm/src/test/java/org/apache/streampipes/sinks/notifications/jvm/migrations/INotificationDataSinkMigratorTest.java b/streampipes-extensions/streampipes-sinks-notifications-jvm/src/test/java/org/apache/streampipes/sinks/notifications/jvm/migrations/INotificationDataSinkMigratorTest.java index d1e344c5ff..3079d8e100 100644 --- a/streampipes-extensions/streampipes-sinks-notifications-jvm/src/test/java/org/apache/streampipes/sinks/notifications/jvm/migrations/INotificationDataSinkMigratorTest.java +++ b/streampipes-extensions/streampipes-sinks-notifications-jvm/src/test/java/org/apache/streampipes/sinks/notifications/jvm/migrations/INotificationDataSinkMigratorTest.java @@ -3,11 +3,13 @@ import org.apache.streampipes.extensions.api.extractor.IDataSinkParameterExtractor; import org.apache.streampipes.model.graph.DataSinkInvocation; import org.apache.streampipes.model.migration.MigrationResult; +import org.apache.streampipes.model.staticproperty.FreeTextStaticProperty; import org.junit.Test; import java.util.ArrayList; +import static org.apache.streampipes.wrapper.standalone.StreamPipesNotificationSink.DEFAULT_WAITING_TIME_MINUTES; import static org.apache.streampipes.wrapper.standalone.StreamPipesNotificationSink.KEY_SILENT_PERIOD; import static org.junit.Assert.*; import static org.mockito.Mockito.mock; @@ -16,7 +18,7 @@ public class INotificationDataSinkMigratorTest { @Test - public void migrate() { + public void testNotificationDataSinkMigration() { INotificationDataSinkMigrator migrator = spy(INotificationDataSinkMigrator.class); IDataSinkParameterExtractor extractor = mock(IDataSinkParameterExtractor.class); @@ -26,7 +28,10 @@ public void migrate() { MigrationResult result = migrator.migrate(dataSinkInvocation, extractor); - assertEquals(result.element().getStaticProperties().size(), 1); - assertEquals(result.element().getStaticProperties().get(0).getInternalName(), KEY_SILENT_PERIOD); + assertEquals(1, result.element().getStaticProperties().size()); + + var property = (FreeTextStaticProperty) result.element().getStaticProperties().get(0); + assertEquals(KEY_SILENT_PERIOD, property.getInternalName()); + assertEquals(DEFAULT_WAITING_TIME_MINUTES, Integer.valueOf(property.getValue()).intValue()); } } \ No newline at end of file