updates with disabled tests

Author: samvaity

sdk/clientcore/annotation-processor-test/src/main/java/io/clientcore/annotation/processor/test/implementation/TestInterfaceClientImpl.java

@@ -5,7 +5,6 @@
 
 import io.clientcore.annotation.processor.test.implementation.models.Foo;
 import io.clientcore.annotation.processor.test.implementation.models.FooListResult;
-import io.clientcore.annotation.processor.test.implementation.models.HttpBinJSON;
 import io.clientcore.core.annotations.ServiceInterface;
 import io.clientcore.core.http.annotations.BodyParam;
 import io.clientcore.core.http.annotations.HeaderParam;
@@ -18,9 +17,7 @@
 import io.clientcore.core.http.models.RequestOptions;
 import io.clientcore.core.http.models.Response;
 import io.clientcore.core.http.pipeline.HttpPipeline;
-import io.clientcore.core.implementation.http.ContentType;
 import io.clientcore.core.models.binarydata.BinaryData;
-
 import java.io.InputStream;
 import java.lang.reflect.InvocationTargetException;
 import java.nio.ByteBuffer;
@@ -100,39 +97,5 @@ Response<List<Foo>> listFoo(@HostParam("uri") String uri, @QueryParam(value = "t
         @HttpRequestInformation(method = HttpMethod.GET, path = "{nextLink}", expectedStatusCodes = { 200 })
         Response<List<Foo>> listNextFoo(@PathParam(value = "nextLink", encoded = true) String nextLink,
                                         RequestOptions requestOptions);
-        // HttpClientTests
-        // Need to add RequestOptions to specify ResponseBodyMode, which is otherwise provided by convenience methods
-        @SuppressWarnings({ "unchecked", "cast" })
-        @HttpRequestInformation(method = HttpMethod.PUT, path = "put", expectedStatusCodes = {200})
-        default HttpBinJSON putConvenience(String uri, int putBody, RequestOptions options) {
-            return putResponse(uri, putBody, options).getValue();
-        }
-
-        @HttpRequestInformation(method = HttpMethod.PUT, path = "put", expectedStatusCodes = { 200 })
-        Response<HttpBinJSON> putResponse(@HostParam("uri") String uri,
-                                          @BodyParam(ContentType.APPLICATION_OCTET_STREAM) int putBody, RequestOptions options);
-
-        @HttpRequestInformation(method = HttpMethod.POST, path = "stream", expectedStatusCodes = { 200 })
-        default HttpBinJSON postStreamConvenience(@HostParam("uri") String uri,
-                                                  @BodyParam(ContentType.APPLICATION_OCTET_STREAM) int putBody, RequestOptions options) {
-            return postStreamResponse(uri, putBody, options).getValue();
-        }
-
-        @HttpRequestInformation(method = HttpMethod.POST, path = "stream", expectedStatusCodes = { 200 })
-        Response<HttpBinJSON> postStreamResponse(@HostParam("uri") String uri,
-                                                 @BodyParam(ContentType.APPLICATION_OCTET_STREAM) int putBody, RequestOptions options);
-
-        // Service 1
-        @HttpRequestInformation(method = HttpMethod.GET, path = "bytes/100", expectedStatusCodes = {200})
-        byte[] getByteArray(@HostParam("uri") String uri);
-
-        // Service 2
-        @HttpRequestInformation(method = HttpMethod.GET, path = "bytes/{numberOfBytes}", expectedStatusCodes = { 200 })
-        byte[] getByteArray(@HostParam("scheme") String scheme, @HostParam("hostName") String hostName,
-                            @PathParam("numberOfBytes") int numberOfBytes);
-
-        // Service 3
-        @HttpRequestInformation(method = HttpMethod.GET, path = "bytes/100", expectedStatusCodes = { 200 })
-        void getNothing(@HostParam("uri") String uri);
     }
 }

sdk/clientcore/annotation-processor-test/src/main/java/io/clientcore/annotation/processor/test/implementation/models/HttpBinJSON.java

@@ -65,6 +65,7 @@
 import java.util.regex.Pattern;
 import java.util.stream.Stream;
 import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Named;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.parallel.Execution;
@@ -873,6 +874,7 @@ public void putRequestWithBodyAndEqualContentLength() {
     }
 
     @Test
+    @Disabled("https://github.com/Azure/azure-sdk-for-java/issues/43728")
     public void putRequestWithBodyLessThanContentLength() {
         ByteBuffer body = ByteBuffer.wrap("test".getBytes(StandardCharsets.UTF_8));
         Exception unexpectedLengthException = assertThrows(Exception.class, () -> {
@@ -895,6 +897,7 @@ public void putRequestWithBodyMoreThanContentLength() {
     }
 
     @Test
+    @Disabled("https://github.com/Azure/azure-sdk-for-java/issues/43728")
     public void putRequestWithUnexpectedResponseAndNoFallthroughExceptionType() {
         HttpResponseException e = assertThrows(HttpResponseException.class, () -> createService(Service9.class)
             .putWithUnexpectedResponseAndNoFallthroughExceptionType(getRequestUri(), "I'm the body!"));
@@ -1047,6 +1050,7 @@ static Service13 getNewInstance(HttpPipeline pipeline) {
     private static final HttpHeaderName MY_OTHER_HEADER = HttpHeaderName.fromString("MyOtherHeader");
 
     @Test
+    @Disabled("https://github.com/Azure/azure-sdk-for-java/pull/44750")
     public void headersRequest() {
         final HttpBinJSON json = createService(Service13.class).get(getRequestUri());
 
@@ -1231,6 +1235,7 @@ public void service18GetStatus300WithExpectedResponse300() {
     }
 
     @Test
+    @Disabled("https://github.com/Azure/azure-sdk-for-java/issues/43728")
     public void service18GetStatus400() {
         assertThrows(HttpResponseException.class, () -> createService(Service18.class).getStatus400(getRequestUri()));
     }
@@ -1241,6 +1246,7 @@ public void service18GetStatus400WithExpectedResponse400() {
     }
 
     @Test
+    @Disabled("https://github.com/Azure/azure-sdk-for-java/issues/43728")
     public void service18GetStatus500() {
         assertThrows(HttpResponseException.class, () -> createService(Service18.class).getStatus500(getRequestUri()));
     }
@@ -1715,6 +1721,7 @@ static UnexpectedOKService getNewInstance(HttpPipeline pipeline) {
     }
 
     @Test
+    @Disabled("https://github.com/Azure/azure-sdk-for-java/issues/43728")
     public void unexpectedHTTPOK() {
         HttpResponseException e = assertThrows(HttpResponseException.class,
             () -> createService(UnexpectedOKService.class).getBytes(getRequestUri()));
@@ -1829,6 +1836,7 @@ Response<HttpBinJSON> put(@HostParam("uri") String host, @BodyParam("text/plain"
     }
 
     @Test
+    @Disabled("None of the provided serializers support the format: TEXT.")
     public void binaryDataUploadTest() throws Exception {
         Path filePath = Paths.get(getClass().getClassLoader().getResource("upload.txt").toURI());
         BinaryData data = BinaryData.fromFile(filePath);
@@ -2154,6 +2162,7 @@ static Service29 getNewInstance(HttpPipeline pipeline) {
 
     @ParameterizedTest
     @MethodSource("voidErrorReturnsErrorBodySupplier")
+    @Disabled("https://github.com/Azure/azure-sdk-for-java/issues/43728")
     public void voidErrorReturnsErrorBody(BiConsumer<String, Service29> executable) {
         HttpResponseException exception = assertThrows(HttpResponseException.class,
             () -> executable.accept(getServerUri(isSecure()), createService(Service29.class)));
@@ -2162,6 +2171,7 @@ public void voidErrorReturnsErrorBody(BiConsumer<String, Service29> executable)
     }
 
     @Test
+    @Disabled("https://github.com/Azure/azure-sdk-for-java/issues/44746")
     public void canReceiveServerSentEvents() throws IOException {
         final int[] i = { 0 };
         ServerSentEventService service = createService(ServerSentEventService.class);
@@ -2194,6 +2204,7 @@ public void canReceiveServerSentEvents() throws IOException {
      * Tests that eagerly converting implementation HTTP headers to Client Core Headers is done.
      */
     @Test
+    @Disabled("https://github.com/Azure/azure-sdk-for-java/issues/44746")
     public void canRecognizeServerSentEvent() throws IOException {
         BinaryData requestBody = BinaryData.fromString("test body");
         ServerSentEventService service = createService(ServerSentEventService.class);
@@ -2209,6 +2220,7 @@ public void canRecognizeServerSentEvent() throws IOException {
     }
 
     @Test
+    @Disabled("https://github.com/Azure/azure-sdk-for-java/issues/44746")
     public void onErrorServerSentEvents() throws IOException {
         ServerSentEventService service = createService(ServerSentEventService.class);
 
@@ -2230,6 +2242,7 @@ public void onError(Throwable throwable) {
     }
 
     @Test
+    @Disabled("https://github.com/Azure/azure-sdk-for-java/issues/44746")
     public void onRetryWithLastEventIdReceiveServerSentEvents() throws IOException {
         ServerSentEventService service = createService(ServerSentEventService.class);
 
@@ -2260,6 +2273,7 @@ public void onEvent(ServerSentEvent sse) {
      * Test throws Runtime exception for no listener attached.
      */
     @Test
+    @Disabled("https://github.com/Azure/azure-sdk-for-java/issues/44746")
     public void throwsExceptionForNoListener() {
         ServerSentEventService service = createService(ServerSentEventService.class);
         BinaryData requestBody = BinaryData.fromString("test body");
@@ -2279,7 +2293,7 @@ static Service30 getNewInstance(HttpPipeline pipeline) {
                 throw new IllegalArgumentException("pipeline cannot be null");
             }
             try {
-                Class<?> clazz = Class.forName("io.clientcore.annotation.processor.test.shared" +
+                Class<?> clazz = Class.forName("io.clientcore.annotation.processor.test.shared." +
                     "Service30Impl");
                 return (Service30) clazz
                     .getMethod("getNewInstance", HttpPipeline.class)
@@ -2314,7 +2328,7 @@ static ServerSentEventService getNewInstance(HttpPipeline pipeline) {
                 throw new IllegalArgumentException("pipeline cannot be null");
             }
             try {
-                Class<?> clazz = Class.forName("io.clientcore.annotation.processor.test.shared" +
+                Class<?> clazz = Class.forName("io.clientcore.annotation.processor.test.shared." +
                     "ServerSentEventServiceImpl");
                 return (ServerSentEventService) clazz
                     .getMethod("getNewInstance", HttpPipeline.class)

sdk/clientcore/annotation-processor-test/src/test/java/io/clientcore/annotation/processor/test/shared/HttpClientTests.java

@@ -0,0 +1 @@
+The quick brown fox jumps over the lazy dog

sdk/clientcore/annotation-processor-test/src/test/resources/upload.txt

@@ -197,9 +197,9 @@ private HttpRequestContext createHttpRequestContext(ExecutableElement requestMet
     }
 
     private static String getHost(TemplateInput templateInput, HttpRequestContext method, boolean isEncoded) {
-        String rawHost;
+        String rawHost = null;
         if (isEncoded) {
-            rawHost = method.getPath();
+            rawHost = templateInput.getHost() + "/" + method.getPath();
         } else {
             String host = templateInput.getHost();
             String path = method.getPath();