Use a different logic when client is not using proxies to connect to Gitpod Server when using JetBrains IDEs

Also, use a fixed version on JetBrains backend-plugin to avoid unexpected API changes which could block Werft to build the main branch on Gitpod repository.

Author: mustard-mh

components/gitpod-protocol/java/src/main/java/io/gitpod/gitpodprotocol/api/GitpodServerLauncher.java

@@ -71,6 +71,37 @@ public GitpodServerConnection listen(
     ) throws Exception {
         String gitpodHost = URI.create(apiUrl).getHost();
         HttpClient httpClient;
+        if (sslContext == null && proxies.size() == 0) {
+            GitpodServerConnectionImpl connection = new GitpodServerConnectionImpl(gitpodHost);
+            connection.setSession(ContainerProvider.getWebSocketContainer().connectToServer(new Endpoint() {
+                @Override
+                public void onOpen(Session session, EndpointConfig config) {
+                    session.addMessageHandler(new WebSocketMessageHandler(messageReader, jsonHandler, remoteEndpoint));
+                    messageWriter.setSession(session);
+                    client.notifyConnect();
+                }
+
+                @Override
+                public void onClose(Session session, CloseReason closeReason) {
+                    connection.complete(closeReason);
+                }
+
+                @Override
+                public void onError(Session session, Throwable thr) {
+                    GitpodServerConnectionImpl.LOG.log(Level.WARNING, gitpodHost + ": connection error:", thr);
+                    connection.completeExceptionally(thr);
+                }
+            }, ClientEndpointConfig.Builder.create().configurator(new ClientEndpointConfig.Configurator() {
+                @Override
+                public void beforeRequest(final Map<String, List<String>> headers) {
+                    headers.put("Origin", Arrays.asList(origin));
+                    headers.put("Authorization", Arrays.asList("Bearer " + token));
+                    headers.put("User-Agent", Arrays.asList(userAgent));
+                    headers.put("X-Client-Version", Arrays.asList(clientVersion));
+                }
+            }).build(), URI.create(apiUrl)));
+            return connection;
+        }
         if (sslContext == null) {
             httpClient = new HttpClient();
         } else {

components/ide/jetbrains/backend-plugin/gradle-latest.properties

@@ -6,4 +6,4 @@ pluginUntilBuild=222.*
 # See https://jb.gg/intellij-platform-builds-list for available build versions.
 pluginVerifierIdeVersions=2022.2
 # Version from "com.jetbrains.intellij.idea" which can be found at https://www.jetbrains.com/intellij-repository/snapshots
-platformVersion=222-EAP-SNAPSHOT
+platformVersion=222.3345-EAP-CANDIDATE-SNAPSHOT

components/ide/jetbrains/backend-plugin/src/main/kotlin/io/gitpod/jetbrains/remote/latest/GitpodTerminalService.kt

@@ -208,6 +208,11 @@ class GitpodTerminalService(private val session: ClientProjectSession) {
                     thisLogger().error("gitpod: Failed to forward port $hostPort from Supervisor's Terminal " +
                             "${supervisorTerminal.pid}: $reason")
                 }
+
+                override fun onPortForwardingEnded(hostPort: Int) {
+                    thisLogger().info("gitpod: Port $hostPort from Supervisor's Terminal " +
+                            "${supervisorTerminal.pid} is not being forwarded anymore.")
+                }
             }
         }