Use local mock server instead external ones

Signed-off-by: Matheus Cruz <[email protected]>

Author: mcruzdev

impl/http/src/main/java/io/serverlessworkflow/impl/executors/http/AbstractRequestSupplier.java

@@ -40,6 +40,10 @@ public WorkflowModel apply(
       Builder request, WorkflowContext workflow, TaskContext task, WorkflowModel model) {
     HttpModelConverter converter = HttpConverterResolver.converter(workflow, task);
 
+    if (!redirect) {
+      request.property("jersey.config.client.followRedirects", false);
+    }
+
     Response response = invokeRequest(request, converter, workflow, task, model);
     validateStatus(task, response);
     return workflow

impl/test/src/test/java/io/serverlessworkflow/impl/test/HTTPWorkflowDefinitionTest.java

@@ -367,7 +367,7 @@ void testWrongSchema_should_throw_illegal_argument() {
   }
 
   @Test
-  void testHeadCall() {
+  void testHeadCall() throws InterruptedException {
     mockServer.enqueue(
         new MockResponse(
             200,
@@ -380,6 +380,7 @@ void testHeadCall() {
                     "X-Custom-Header",
                     "CustomValue")),
             ""));
+
     assertDoesNotThrow(
         () -> {
           appl.workflowDefinition(
@@ -388,24 +389,33 @@ void testHeadCall() {
               .start()
               .join();
         });
+
+    RecordedRequest recordedRequest = mockServer.takeRequest();
+    SoftAssertions.assertSoftly(
+        softly -> {
+          softly.assertThat(recordedRequest.getMethod()).isEqualTo("HEAD");
+          softly.assertThat(recordedRequest.getUrl().toString()).contains("/users/1");
+        });
   }
 
   @Test
-  void testOptionsCall() {
+  void testOptionsCall() throws IOException, InterruptedException {
     mockServer.enqueue(new MockResponse(200, Headers.of("Allow", "GET, POST, OPTIONS"), ""));
+    appl.workflowDefinition(readWorkflowFromClasspath("workflows-samples/call-http-options.yaml"))
+        .instance(Map.of())
+        .start()
+        .join();
 
-    assertDoesNotThrow(
-        () -> {
-          appl.workflowDefinition(
-                  readWorkflowFromClasspath("workflows-samples/call-http-options.yaml"))
-              .instance(Map.of())
-              .start()
-              .join();
+    RecordedRequest recordedRequest = mockServer.takeRequest();
+    SoftAssertions.assertSoftly(
+        softly -> {
+          softly.assertThat(recordedRequest.getMethod()).isEqualTo("OPTIONS");
+          softly.assertThat(recordedRequest.getUrl().toString()).contains("/users/1");
         });
   }
 
   @Test
-  void testRedirectAsFalse() {
+  void testRedirect_should_throws_when_redirect_is_false_and_response_status_is_not_2xx() {
     mockServer.enqueue(
         new MockResponse(301, Headers.of("Location", "http://localhost:9876/redirected"), ""));
 
@@ -419,7 +429,6 @@ void testRedirectAsFalse() {
                     .instance(Map.of())
                     .start()
                     .join());
-
     assertThat(exception.getCause().getMessage())
         .contains(
             "The property 'redirect' is set to false but received status 301 (Redirection); expected status in the 200-299 range");

impl/test/src/test/resources/workflows-samples/call-http-delete.yaml

@@ -9,4 +9,4 @@ do:
       with:
         method: delete
         endpoint:
-          uri: https://localhost:9876/api/v1/authors/1
+          uri: http://localhost:9876/api/v1/authors/1