Skip to content

Commit f816ab0

Browse files
committed
Fix test: www.cyberpresse.ca now uses chunking and doesn't specify a Content-Length
1 parent eaf801d commit f816ab0

File tree

3 files changed

+8
-5
lines changed

3 files changed

+8
-5
lines changed

client/src/test/java/org/asynchttpclient/AuthTimeoutTest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
import static org.asynchttpclient.Dsl.*;
1717
import static org.asynchttpclient.test.TestUtils.*;
1818
import static org.testng.Assert.*;
19+
import io.netty.handler.codec.http.HttpHeaders;
1920

2021
import java.io.IOException;
2122
import java.io.OutputStream;
@@ -69,7 +70,7 @@ public void handle(String s, Request r, HttpServletRequest request, HttpServletR
6970
OutputStream out = response.getOutputStream();
7071
if (request.getHeader("X-Content") != null) {
7172
String content = request.getHeader("X-Content");
72-
response.setHeader("Content-Length", String.valueOf(content.getBytes(UTF_8).length));
73+
response.setHeader(HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(content.getBytes(UTF_8).length));
7374
out.write(content.substring(1).getBytes(UTF_8));
7475
} else {
7576
response.setStatus(200);

client/src/test/java/org/asynchttpclient/BasicAuthTest.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
import static org.asynchttpclient.Dsl.*;
2020
import static org.asynchttpclient.test.TestUtils.*;
2121
import static org.testng.Assert.*;
22+
import io.netty.handler.codec.http.HttpHeaders;
2223

2324
import java.io.ByteArrayInputStream;
2425
import java.io.IOException;
@@ -116,7 +117,7 @@ public void handle(String s, Request r, HttpServletRequest request, HttpServletR
116117
LOGGER.info("got redirected" + request.getRequestURI());
117118
response.setStatus(200);
118119
response.addHeader("X-Auth", request.getHeader("Authorization"));
119-
response.addHeader("X-Content-Length", String.valueOf(request.getContentLength()));
120+
response.addHeader("X-" + HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(request.getContentLength()));
120121
byte[] b = "content".getBytes(UTF_8);
121122
response.setContentLength(b.length);
122123
response.getOutputStream().write(b);
@@ -136,7 +137,7 @@ public void handle(String s, Request r, HttpServletRequest request, HttpServletR
136137

137138
} else {
138139
response.addHeader("X-Auth", request.getHeader("Authorization"));
139-
response.addHeader("X-Content-Length", String.valueOf(request.getContentLength()));
140+
response.addHeader("X-" + HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(request.getContentLength()));
140141
response.setStatus(200);
141142

142143
int size = 10 * 1024;

client/src/test/java/org/asynchttpclient/RemoteSiteTest.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
import static java.nio.charset.StandardCharsets.UTF_8;
1919
import static org.asynchttpclient.Dsl.*;
2020
import static org.testng.Assert.*;
21+
import io.netty.handler.codec.http.HttpHeaders;
2122

2223
import java.io.InputStream;
2324
import java.net.URLEncoder;
@@ -142,10 +143,10 @@ public void invalidStreamTest2() throws Exception {
142143
@Test(groups = "online")
143144
public void asyncFullBodyProperlyRead() throws Exception {
144145
try (AsyncHttpClient client = asyncHttpClient()) {
145-
Response r = client.prepareGet("http://www.cyberpresse.ca/").execute().get();
146+
Response r = client.prepareGet("http://www.typesafe.com/").execute().get();
146147

147148
InputStream stream = r.getResponseBodyAsStream();
148-
int contentLength = Integer.valueOf(r.getHeader("Content-Length"));
149+
int contentLength = Integer.valueOf(r.getHeader(HttpHeaders.Names.CONTENT_LENGTH));
149150

150151
assertEquals(contentLength, IOUtils.toByteArray(stream).length);
151152
}

0 commit comments

Comments
 (0)