support other methods for SSE and bodies

Author: ryber

unirest-bdd-tests/src/test/java/BehaviorTests/SSEStreamTest.java

@@ -25,6 +25,7 @@
 
 package BehaviorTests;
 
+import kong.unirest.core.HttpMethod;
 import kong.unirest.core.Unirest;
 import kong.unirest.core.java.Event;
 import org.junit.jupiter.api.BeforeEach;
@@ -110,4 +111,21 @@ void canSendLastEventIdHeader() {
         MockServer.lastRequest()
                 .assertHeader("Last-Event-ID", "42");
     }
+
+    @Test
+    void sendSSEAsAPost() {
+        MockServer.Sse.queueEvent("1", "message", "hi mom");
+
+        var events = Unirest.sse(MockServer.SSE, HttpMethod.POST)
+                .connect()
+                .collect(Collectors.toList());
+
+        assertThat(events)
+                .hasSize(2)
+                .containsExactly(
+                        new Event("", "connect", "Welcome to Server Sent Events"),
+                        new Event("1", "message", "hi mom")
+                );
+
+    }
 }

unirest-bdd-tests/src/test/java/BehaviorTests/TestSSEConsumer.java

@@ -76,6 +76,7 @@ public static void keepAlive(boolean value) {
 
     @Override
     public void accept(SseClient client) {
+        client.ctx().
         lastRequest = new RequestCapture(client.ctx());
         if(keepAlive) {
             client.keepAlive();

unirest/src/main/java/kong/unirest/core/Client.java

@@ -84,5 +84,6 @@ <T> CompletableFuture<HttpResponse<T>> request(HttpRequest request,
      */
     CompletableFuture<Void> sse(SseRequest request, SseHandler handler);
 
+    
     Stream<Event> sse(SseRequest request);
 }

unirest/src/main/java/kong/unirest/core/SseRequest.java

@@ -181,4 +181,10 @@ public interface SseRequest {
      * @return a stream of events
      */
     Stream<Event> connect();
+
+    /**
+     * The method of the request. Defaults to GET
+     * @return the method
+     */
+    HttpMethod getMethod();
 }

unirest/src/main/java/kong/unirest/core/SseRequestImpl.java

@@ -36,11 +36,11 @@
 public class SseRequestImpl implements SseRequest {
     private final Config config;
     private final Path url;
+    private final HttpMethod method;
     protected Headers headers = new Headers();
 
-
-
-    public SseRequestImpl(Config config, String url) {
+    public SseRequestImpl(Config config, String url, HttpMethod method) {
+        this.method = method;
         Objects.requireNonNull(config, "Config cannot be null");
         Objects.requireNonNull(url,    "URL cannot be null");
 
@@ -142,6 +142,11 @@ public Stream<Event> connect() {
         return config.getClient().sse(this);
     }
 
+    @Override
+    public HttpMethod getMethod() {
+        return method;
+    }
+
     @Override
     public Headers getHeaders() {
         return headers;

unirest/src/main/java/kong/unirest/core/Unirest.java

@@ -138,6 +138,10 @@ public static SseRequest sse(String url) {
         return primaryInstance.sse(url);
     }
 
+    public static SseRequest sse(String url, HttpMethod method) {
+        return primaryInstance.sse(url, method);
+    }
+
     /**
      * Spawn a new Unirest Instance with a new config.
      * Don't forget to shut it down when your done.

unirest/src/main/java/kong/unirest/core/UnirestInstance.java

@@ -158,6 +158,10 @@ public WebSocketRequest webSocket(String url) {
     }
 
     public SseRequestImpl sse(String url) {
-        return new SseRequestImpl(config, url);
+        return new SseRequestImpl(config, url, HttpMethod.GET);
+    }
+
+    public SseRequestImpl sse(String url, HttpMethod method) {
+        return new SseRequestImpl(config, url, method);
     }
 }

unirest/src/main/java/kong/unirest/core/java/SseRequestBuilder.java

@@ -26,19 +26,21 @@
 package kong.unirest.core.java;
 
 import kong.unirest.core.ContentType;
+import kong.unirest.core.HttpMethod;
 import kong.unirest.core.SseRequest;
 
 import java.net.URI;
 import java.net.http.HttpRequest;
 
 public class SseRequestBuilder {
     static java.net.http.HttpRequest getHttpRequest(SseRequest request) {
-        var accept = HttpRequest
+        var a = HttpRequest
                 .newBuilder()
                 .header("Accept", ContentType.EVENT_STREAMS.getMimeType())
-                .GET()
                 .uri(URI.create(request.getUrl()));
 
+        var accept = addMethod(request, a);
+
         request.getHeaders().all().forEach(h -> {
             accept.header(h.getName(), h.getValue());
         });
@@ -47,5 +49,13 @@ static java.net.http.HttpRequest getHttpRequest(SseRequest request) {
         return accept.build();
     }
 
+    private static HttpRequest.Builder addMethod(SseRequest request, HttpRequest.Builder a) {
+        if(request.getMethod().equals(HttpMethod.GET)){
+            return a.GET();
+        } else {
+            return a.method(request.getMethod().toString(), HttpRequest.BodyPublishers.noBody());
+        }
+    }
+
 
 }