Skip to content

Commit 0dcf438

Browse files
committed
732 Fix tests
1 parent cd207ed commit 0dcf438

File tree

3 files changed

+19
-20
lines changed

3 files changed

+19
-20
lines changed

server/libs/modules/components/wait/src/test/java/com/bytechef/component/wait/action/WaitAfterTimeIntervalActionTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ public void testPerformCallsSuspend() throws Exception {
5252
Mockito.when(inputParameters.getRequiredString(eq(UNIT)))
5353
.thenReturn("MINUTES");
5454

55-
ModifiableActionDefinition actionDefinition = WaitAfterTimeIntervalAction.of();
55+
ModifiableActionDefinition actionDefinition = WaitAfterTimeIntervalAction.ACTION_DEFINITION;
5656

5757
PerformFunction performFunction = (PerformFunction) actionDefinition.getPerform()
5858
.orElseThrow();
@@ -92,7 +92,7 @@ public void testResumePerform() throws Exception {
9292
Mockito.when(continueParameters.getString(eq("unit")))
9393
.thenReturn("MINUTES");
9494

95-
ModifiableActionDefinition actionDefinition = WaitAfterTimeIntervalAction.of();
95+
ModifiableActionDefinition actionDefinition = WaitAfterTimeIntervalAction.ACTION_DEFINITION;
9696

9797
ResumePerformFunction resumePerformFunction = actionDefinition.getResumePerform()
9898
.orElseThrow();

server/libs/modules/components/wait/src/test/java/com/bytechef/component/wait/action/WaitAtSpecifiedTimeActionTest.java

Lines changed: 8 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ public void testPerformCallsSuspend() throws Exception {
5454
Mockito.when(inputParameters.getRequiredLocalDateTime(eq(DATE_TIME)))
5555
.thenReturn(futureTime);
5656

57-
ModifiableActionDefinition actionDefinition = WaitAtSpecifiedTimeAction.of();
57+
ModifiableActionDefinition actionDefinition = WaitAtSpecifiedTimeAction.ACTION_DEFINITION;
5858

5959
PerformFunction performFunction = (PerformFunction) actionDefinition.getPerform()
6060
.orElseThrow();
@@ -70,15 +70,16 @@ public void testPerformCallsSuspend() throws Exception {
7070

7171
Assertions.assertNotNull(suspend);
7272
Assertions.assertNotNull(suspend.expiresAt());
73-
Assertions.assertNotNull(suspend.continueParameters());
74-
Assertions.assertTrue(suspend.continueParameters()
75-
.containsKey("expiresAt"));
73+
74+
Map<String, ?> continueParameters = suspend.continueParameters();
75+
76+
Assertions.assertNotNull(continueParameters);
77+
Assertions.assertTrue(continueParameters.containsKey("expiresAt"));
7678

7779
Instant expectedInstant = futureTime.atZone(ZoneId.systemDefault())
7880
.toInstant();
7981

80-
Assertions.assertEquals(expectedInstant.toEpochMilli(), suspend.continueParameters()
81-
.get("expiresAt"));
82+
Assertions.assertEquals(expectedInstant.toEpochMilli(), continueParameters.get("expiresAt"));
8283
}
8384

8485
@Test
@@ -94,7 +95,7 @@ public void testResumePerform() throws Exception {
9495
Mockito.when(continueParameters.getLong(eq("expiresAt")))
9596
.thenReturn(expiresAtMillis);
9697

97-
ModifiableActionDefinition actionDefinition = WaitAtSpecifiedTimeAction.of();
98+
ModifiableActionDefinition actionDefinition = WaitAtSpecifiedTimeAction.ACTION_DEFINITION;
9899

99100
ResumePerformFunction resumePerformFunction = actionDefinition.getResumePerform()
100101
.orElseThrow();

server/libs/modules/components/wait/src/test/java/com/bytechef/component/wait/action/WaitOnWebHookCallActionTest.java

Lines changed: 9 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ public void testPerformCallsSuspend() throws Exception {
5050
Mockito.when(inputParameters.getRequiredString(eq(UNIT)))
5151
.thenReturn("DAYS");
5252

53-
ModifiableActionDefinition actionDefinition = WaitOnWebHookCallAction.of();
53+
ModifiableActionDefinition actionDefinition = WaitOnWebHookCallAction.ACTION_DEFINITION;
5454

5555
PerformFunction performFunction = (PerformFunction) actionDefinition.getPerform()
5656
.orElseThrow();
@@ -71,13 +71,13 @@ public void testPerformCallsSuspend() throws Exception {
7171

7272
@Test
7373
public void testBeforeSuspendIsPresent() {
74-
ModifiableActionDefinition actionDefinition = WaitOnWebHookCallAction.of();
74+
ModifiableActionDefinition actionDefinition = WaitOnWebHookCallAction.ACTION_DEFINITION;
7575

76-
Assertions.assertTrue(actionDefinition.getBeforeSuspend()
77-
.isPresent());
76+
Assertions.assertTrue(
77+
actionDefinition.getBeforeSuspend()
78+
.isPresent());
7879
}
7980

80-
@SuppressWarnings("unchecked")
8181
@Test
8282
public void testResumePerformReturnsResumeData() throws Exception {
8383
Parameters inputParameters = Mockito.mock(Parameters.class);
@@ -92,20 +92,18 @@ public void testResumePerformReturnsResumeData() throws Exception {
9292
.when(data)
9393
.toMap();
9494

95-
ModifiableActionDefinition actionDefinition = WaitOnWebHookCallAction.of();
95+
ModifiableActionDefinition actionDefinition = WaitOnWebHookCallAction.ACTION_DEFINITION;
9696

9797
ResumePerformFunction resumePerformFunction = actionDefinition.getResumePerform()
9898
.orElseThrow();
9999

100-
Object result = resumePerformFunction.apply(
100+
Map<String, Object> result = resumePerformFunction.apply(
101101
inputParameters, connectionParameters, continueParameters, data, context);
102102

103103
Assertions.assertNotNull(result);
104104
Assertions.assertInstanceOf(Map.class, result);
105105

106-
Map<String, Object> resultMap = (Map<String, Object>) result;
107-
108-
Assertions.assertEquals(true, resultMap.get("resumed"));
109-
Assertions.assertEquals(dataMap, resultMap.get(ResumePerformFunction.ResumeResponse.DATA));
106+
Assertions.assertEquals(true, result.get("resumed"));
107+
Assertions.assertEquals(dataMap, result.get(ResumePerformFunction.ResumeResponse.DATA));
110108
}
111109
}

0 commit comments

Comments
 (0)