[jb-remote] gp cli support

Author: akosyakov

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

@@ -0,0 +1,65 @@
+// Copyright (c) 2022 Gitpod GmbH. All rights reserved.
+// Licensed under the GNU Affero General Public License (AGPL).
+// See License-AGPL.txt in the project root for license information.
+
+package io.gitpod.jetbrains.remote
+
+import com.intellij.ide.BrowserUtil
+import com.intellij.ide.CommandLineProcessor
+import com.intellij.openapi.diagnostic.thisLogger
+import com.intellij.openapi.util.io.FileUtilRt
+import com.intellij.util.containers.ContainerUtil
+import io.netty.channel.ChannelHandlerContext
+import io.netty.handler.codec.http.FullHttpRequest
+import io.netty.handler.codec.http.QueryStringDecoder
+import org.jetbrains.ide.RestService
+import java.nio.file.InvalidPathException
+import java.nio.file.Path
+
+
+class GitpodCLIService : RestService() {
+
+    override fun getServiceName() = SERVICE_NAME
+
+    override fun execute(urlDecoder: QueryStringDecoder, request: FullHttpRequest, context: ChannelHandlerContext): String? {
+        val parameters = urlDecoder.parameters()
+        val operation = ContainerUtil.getLastItem(parameters["op"])
+        if (operation == "open") {
+            val fileStr = ContainerUtil.getLastItem(parameters["file"])
+            if (fileStr.isNullOrBlank()) {
+                return "file is missing"
+            }
+            val file = parseFilePath(fileStr) ?: return "invalid file"
+            val shouldWait = (ContainerUtil.getLastItem(parameters["wait"]) ?: "false").toBoolean()
+
+            CommandLineProcessor.doOpenFileOrProject(file, shouldWait).future.get()
+            return null
+        }
+        if (operation == "preview") {
+            val url = ContainerUtil.getLastItem(parameters["url"])
+            if (url.isNullOrBlank()) {
+                return "url is missing"
+            }
+            BrowserUtil.browse(url)
+            return null
+        }
+        return "invalid operation"
+    }
+
+    private fun parseFilePath(path: String): Path? {
+        return try {
+            var file: Path = Path.of(FileUtilRt.toSystemDependentName(path)) // handle paths like '/file/foo\qwe'
+            if (!file.isAbsolute) {
+                file = file.toAbsolutePath()
+            }
+            file.normalize()
+        } catch (e: InvalidPathException) {
+            thisLogger().warn("gitpod cli: failed to parse file path:", e)
+            null
+        }
+    }
+
+    companion object {
+        const val SERVICE_NAME = "gitpod/cli"
+    }
+}

components/ide/jetbrains/backend-plugin/src/main/resources/META-INF/plugin.xml

@@ -20,6 +20,7 @@
         <applicationService serviceImplementation="io.gitpod.jetbrains.remote.services.HeartbeatService" preload="true"/>
         <applicationService serviceImplementation="io.gitpod.jetbrains.remote.GitpodManager" preload="true"/>
         <notificationGroup id="Gitpod Notifications" displayType="STICKY_BALLOON" />
+        <httpRequestHandler implementation="io.gitpod.jetbrains.remote.GitpodCLIService"/>
     </extensions>
 
 </idea-plugin>

components/ide/jetbrains/idea-cli/BUILD.yaml

@@ -0,0 +1,12 @@
+packages:
+  - name: app
+    type: go
+    srcs:
+      - "**/*.go"
+      - "go.mod"
+      - "go.sum"
+    env:
+      - CGO_ENABLED=0
+      - GOOS=linux
+    config:
+      packaging: app

components/ide/jetbrains/idea-cli/cmd/open.go

@@ -0,0 +1,35 @@
+// Copyright (c) 2022 Gitpod GmbH. All rights reserved.
+// Licensed under the GNU Affero General Public License (AGPL).
+// See License-AGPL.txt in the project root for license information.
+
+package cmd
+
+import (
+	"fmt"
+	"log"
+	"net/http"
+
+	"github.com/spf13/cobra"
+)
+
+var wait bool
+
+var openCmd = &cobra.Command{
+	Use:  "open",
+	Args: cobra.ExactArgs(1),
+	Run: func(cmd *cobra.Command, args []string) {
+		file := args[0]
+		resp, err := http.Get(fmt.Sprintf("http://localhost:63342/api/gitpod/cli/op=open&file=%swait=%t", file, wait))
+		if err != nil {
+			log.Fatalf("%s", err)
+		}
+		if resp.StatusCode != http.StatusOK {
+			log.Fatalf("%s", resp.Status)
+		}
+	},
+}
+
+func init() {
+	rootCmd.AddCommand(openCmd)
+	openCmd.Flags().BoolVar(&wait, "wait", false, "")
+}

components/ide/jetbrains/idea-cli/cmd/preview.go

@@ -0,0 +1,31 @@
+// Copyright (c) 2022 Gitpod GmbH. All rights reserved.
+// Licensed under the GNU Affero General Public License (AGPL).
+// See License-AGPL.txt in the project root for license information.
+
+package cmd
+
+import (
+	"fmt"
+	"log"
+	"net/http"
+
+	"github.com/spf13/cobra"
+)
+
+var previewCmd = &cobra.Command{
+	Use: "preview",
+	Run: func(cmd *cobra.Command, args []string) {
+		url := args[0]
+		resp, err := http.Get(fmt.Sprintf("http://localhost:63342/api/gitpod/cli/op=preview&url=%s", url))
+		if err != nil {
+			log.Fatalf("%s", err)
+		}
+		if resp.StatusCode != http.StatusOK {
+			log.Fatalf("%s", resp.Status)
+		}
+	},
+}
+
+func init() {
+	rootCmd.AddCommand(previewCmd)
+}

components/ide/jetbrains/idea-cli/cmd/root.go

@@ -0,0 +1,24 @@
+// Copyright (c) 2022 Gitpod GmbH. All rights reserved.
+// Licensed under the GNU Affero General Public License (AGPL).
+// See License-AGPL.txt in the project root for license information.
+
+package cmd
+
+import (
+	"os"
+
+	"github.com/spf13/cobra"
+)
+
+var rootCmd = &cobra.Command{
+	Use: "idea-cli",
+}
+
+func Execute() {
+	err := rootCmd.Execute()
+	if err != nil {
+		os.Exit(1)
+	}
+}
+
+func init() {}

components/ide/jetbrains/idea-cli/go.mod

@@ -0,0 +1,9 @@
+module idea-cli
+
+go 1.17
+
+require (
+	github.com/inconshreveable/mousetrap v1.0.0 // indirect
+	github.com/spf13/cobra v1.3.0 // indirect
+	github.com/spf13/pflag v1.0.5 // indirect
+)