[JENKINS-73136] Adapt HTTP Request tests for Jetty 12 (EE 8)

pom.xml

@@ -57,6 +57,9 @@ THE SOFTWARE.
 		<spotbugs.failOnError>true</spotbugs.failOnError>
 		<spotbugs.threshold>Low</spotbugs.threshold>
 		<hpi.compatibleSinceVersion>1.16</hpi.compatibleSinceVersion>
+		<!-- TODO JENKINS-73339 until in parent POM -->
+		<jenkins-test-harness.version>2244.v77428109fd1f</jenkins-test-harness.version>
+		<maven.compiler.release>17</maven.compiler.release>
 	</properties>
 
 	<repositories>

src/test/java/jenkins/plugins/http_request/HttpRequestStepTest.java

@@ -20,13 +20,14 @@
 import java.nio.file.Paths;
 import java.util.ArrayList;
 import java.util.List;
-
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
+import java.util.concurrent.ExecutionException;
 
 import org.apache.commons.io.FilenameUtils;
 import org.apache.http.entity.ContentType;
+import org.eclipse.jetty.http.HttpStatus;
 import org.eclipse.jetty.server.Request;
+import org.eclipse.jetty.server.Response;
+import org.eclipse.jetty.util.Callback;
 import org.jenkinsci.plugins.workflow.cps.CpsFlowDefinition;
 import org.jenkinsci.plugins.workflow.job.WorkflowJob;
 import org.jenkinsci.plugins.workflow.job.WorkflowRun;
@@ -636,11 +637,12 @@ public void testPostBody() throws Exception {
         //configure server
         registerHandler("/doPostBody", HttpMode.POST, new SimpleHandler() {
             @Override
-            void doHandle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response) throws IOException {
+            boolean doHandle(Request request, Response response, Callback callback) throws IOException, ExecutionException, InterruptedException {
                 assertEquals("POST", request.getMethod());
 
                 String body = requestBody(request);
-                body(response, HttpServletResponse.SC_OK, ContentType.TEXT_PLAIN, body);
+                body(response, HttpStatus.OK_200, ContentType.TEXT_PLAIN, body, callback);
+				return true;
             }
         });
 

src/test/java/jenkins/plugins/http_request/HttpRequestTest.java

@@ -34,7 +34,11 @@
 import org.apache.http.ProtocolVersion;
 import org.apache.http.entity.StringEntity;
 import org.apache.http.message.BasicHttpResponse;
+import org.eclipse.jetty.http.HttpCookie;
 import org.eclipse.jetty.server.Request;
+import org.eclipse.jetty.server.Response;
+import org.eclipse.jetty.util.Callback;
+import org.eclipse.jetty.util.Fields;
 import org.junit.Assert;
 import org.junit.Assume;
 import org.junit.Rule;
@@ -766,23 +770,28 @@ public void testFormAuthentication() throws Exception {
 
 		registerHandler("/form-auth", HttpMode.POST, new SimpleHandler() {
 			@Override
-			void doHandle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response) throws IOException {
-				String username = request.getParameter(paramUsername);
-				String password = request.getParameter(paramPassword);
+			boolean doHandle(Request request, Response response, Callback callback) throws Exception {
+				Fields allParameters = Request.getParameters(request);
+				String username = allParameters.getValue(paramUsername);
+				String password = allParameters.getValue(paramPassword);
+
 				if (!username.equals(valueUsername) || !password.equals(valuePassword)) {
 					response.setStatus(401);
-					return;
+					return false;
 				}
-				response.addCookie(new Cookie(sessionName, "ok"));
-				okAllIsWell(response);
+				HttpCookie cookie = HttpCookie.build(sessionName, "ok")
+						.build();
+				Response.addCookie(response, cookie);
+				okAllIsWell(response, callback);
+				return true;
 			}
 		});
 		registerHandler("/test-auth", HttpMode.GET, new SimpleHandler() {
 			@Override
-			void doHandle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response) throws IOException {
+			boolean doHandle(Request request, Response response, Callback callback) throws IOException {
 				String jsessionValue = "";
-				Cookie[] cookies = request.getCookies();
-				for (Cookie cookie : cookies) {
+				List<HttpCookie> cookies = Request.getCookies(request);
+				for (HttpCookie cookie : cookies) {
 					if (cookie.getName().equals(sessionName)) {
 						jsessionValue = cookie.getValue();
 						break;
@@ -791,9 +800,10 @@ void doHandle(String target, Request baseRequest, HttpServletRequest request, Ht
 
 				if (!jsessionValue.equals("ok")) {
 					response.setStatus(401);
-					return;
+					return false;
 				}
-				okAllIsWell(response);
+				okAllIsWell(response, callback);
+				return true;
 			}
 		});
 

src/test/java/jenkins/plugins/http_request/HttpRequestTestBase.java

@@ -1,24 +1,29 @@
 package jenkins.plugins.http_request;
 
-import java.io.BufferedReader;
+import static java.nio.charset.StandardCharsets.UTF_8;
+
 import java.io.IOException;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.ExecutionException;
 
-import javax.servlet.ServletException;
-import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 
 import org.apache.http.entity.ContentType;
+import org.eclipse.jetty.http.HttpStatus;
+import org.eclipse.jetty.io.Content;
 import org.eclipse.jetty.server.Connector;
 import org.eclipse.jetty.server.Handler;
 import org.eclipse.jetty.server.Request;
+import org.eclipse.jetty.server.Response;
 import org.eclipse.jetty.server.Server;
 import org.eclipse.jetty.server.ServerConnector;
 import org.eclipse.jetty.server.handler.ContextHandler;
 import org.eclipse.jetty.server.handler.DefaultHandler;
+import org.eclipse.jetty.util.Callback;
 import org.junit.After;
 import org.junit.AfterClass;
 import org.junit.Before;
@@ -31,7 +36,6 @@
 import com.cloudbees.plugins.credentials.SystemCredentialsProvider;
 import com.cloudbees.plugins.credentials.domains.Domain;
 import com.cloudbees.plugins.credentials.impl.UsernamePasswordCredentialsImpl;
-import org.apache.commons.io.IOUtils;
 
 /**
  * @author Martin d'Anjou
@@ -89,34 +93,33 @@ public void cleanHandlers() {
 		}
 	}
 
-	public static abstract class SimpleHandler extends DefaultHandler {
+	public static abstract class SimpleHandler extends Handler.Abstract {
 		@Override
-		public final void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {
-			doHandle(target, baseRequest, request, response);
-			baseRequest.setHandled(true);
+		public final boolean handle(Request request, Response response, Callback callback) throws Exception {
+			doHandle(request, response, callback);
+			return true;
 		}
 
-		String requestBody(HttpServletRequest request) throws IOException {
-			try (BufferedReader reader = request.getReader()) {
-				return IOUtils.toString(reader);
-			}
+		String requestBody(Request request) throws IOException, ExecutionException, InterruptedException {
+			CompletableFuture<String> completable = Content.Source.asStringAsync(request, UTF_8);
+			return completable.get();
 		}
 
-		void okAllIsWell(HttpServletResponse response) throws IOException {
-			okText(response, ALL_IS_WELL);
+		void okAllIsWell(Response response, Callback callback) throws IOException {
+			okText(response, ALL_IS_WELL, callback);
 		}
 
-		void okText(HttpServletResponse response, String body) throws IOException {
-			body(response, HttpServletResponse.SC_OK, ContentType.TEXT_PLAIN, body);
+		void okText(Response response, String body, Callback callback) throws IOException {
+			body(response, HttpStatus.OK_200, ContentType.TEXT_PLAIN, body, callback);
 		}
 
-		void body(HttpServletResponse response, int status, ContentType contentType, String body) throws IOException {
-			response.setContentType(contentType != null ? contentType.toString() : "");
+		void body(Response response, int status, ContentType contentType, String body, Callback callback) throws IOException {
+			response.getHeaders().put(String.valueOf(contentType), "text/plain; charset=UTF-8");
 			response.setStatus(status);
-			response.getWriter().append(body);
+			Content.Sink.write(response, true, body, callback);
 		}
 
-		abstract void doHandle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException;
+		abstract boolean doHandle(Request request, Response response, Callback callback) throws Exception;
 	}
 
 	private static final class ServerRunning {
@@ -134,17 +137,19 @@ private ServerRunning() throws Exception {
 			context.setContextPath("/");
 			context.setHandler(new DefaultHandler() {
 				@Override
-				public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {
+				public boolean handle(Request request, Response response, Callback callback) throws Exception {
+					String target = request.getHttpURI().getPath();
 					Map<HttpMode, Handler> handlerByMethod = handlersByMethodByTarget.get(target);
 					if (handlerByMethod != null) {
 						Handler handler = handlerByMethod.get(HttpMode.valueOf(request.getMethod()));
 						if (handler != null) {
-							handler.handle(target, baseRequest, request, response);
-							return;
+							handler.handle(request, response, callback);
+							return true;
 						}
 					}
 
-					super.handle(target, baseRequest, request, response);
+					super.handle(request, response, callback);
+					return true;
 				}
 			});
 			server.setHandler(context);