added test for subscribeTopic with start and end time

Signed-off-by: Manish Dait <[email protected]>

Author: manishdait

hiero-enterprise-spring/src/test/java/com/openelements/hiero/spring/test/TopicClientTest.java

@@ -11,6 +11,8 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 
+import java.time.Duration;
+import java.time.Instant;
 import java.util.ArrayList;
 import java.util.List;
 
@@ -257,15 +259,50 @@ void testSubscribeTopicWithInvalidLimit() throws HieroException {
         final TopicId topicId = topicClient.createTopic();
         hieroTestUtils.waitForMirrorNodeRecords();
 
-        final IllegalArgumentException e = Assertions.assertThrows(IllegalArgumentException.class, () -> topicClient.subscribeTopic(
-                topicId, (message) -> {/**/}, limit
-        ));
+        final IllegalArgumentException e = Assertions.assertThrows(
+                IllegalArgumentException.class,
+                () -> topicClient.subscribeTopic(topicId, (message) -> {/**/}, limit)
+        );
 
         Assertions.assertEquals(msg, e.getMessage());
     }
 
     @Test
-    void testSubscribeTopicWithStartAndEndTime() {
-        //TODO
+    void testSubscribeTopicWithStartAndEndTime() throws HieroException {
+        final TopicId topicId = topicClient.createTopic();
+        hieroTestUtils.waitForMirrorNodeRecords();
+        final Instant start = Instant.now().plus(Duration.ofMinutes(10));
+        final Instant end = Instant.now().plus(Duration.ofDays(2));
+        final SubscriptionHandle handler = Assertions.assertDoesNotThrow(
+                () -> topicClient.subscribeTopic(topicId, (message) -> {}, start, end)
+        );
+
+        Assertions.assertNotNull(handler);
+    }
+
+    @Test
+    void testSubscribeTopicWithStartAndEndTimeWithInvalidParams() throws HieroException {
+        final TopicId topicId = topicClient.createTopic();
+        // Start time before Current time
+        final Instant invalidStart = Instant.now().minus(Duration.ofMinutes(10));
+        final Instant end = Instant.now().plus(Duration.ofDays(2));
+
+        final IllegalArgumentException e1 = Assertions.assertThrows(
+                IllegalArgumentException.class,
+                () -> topicClient.subscribeTopic(topicId, (message) -> {}, invalidStart, end)
+        );
+
+        Assertions.assertEquals("startTime must be greater than currentTime", e1.getMessage());
+
+        // End time before than Start time
+        final Instant start = Instant.now().plus(Duration.ofMinutes(10));
+        final Instant invalidEnd = start.minus(Duration.ofMinutes(1));
+
+        final IllegalArgumentException e2 = Assertions.assertThrows(
+                IllegalArgumentException.class,
+                () -> topicClient.subscribeTopic(topicId, (message) -> {}, start, invalidEnd)
+        );
+
+        Assertions.assertEquals("endTime must be greater than starTime", e2.getMessage());
     }
 }