Add extio

kylecarbs · kylecarbs · commit eae77d74ab09 · 2022-12-05T04:24:09.000Z
diff --git a/cli/extension.go b/cli/extension.go
@@ -0,0 +1,7 @@
+package cli
+
+import "github.com/spf13/cobra"
+
+func extension() *cobra.Command {
+	return &cobra.Command{}
+}
diff --git a/cli/vscodeipc/vscodeipc.go b/cli/vscodeipc/vscodeipc.go
@@ -0,0 +1,66 @@
+package vscodeipc
+
+import (
+	"context"
+	"io"
+	"net/http"
+
+	"github.com/go-chi/chi/v5"
+	"github.com/google/uuid"
+	"golang.org/x/xerrors"
+
+	"github.com/coder/coder/codersdk"
+)
+
+// It's a lil http server that listens for messages from the VS Code extension.
+// It can listen on macOS and Windows, and explicitly blocks any web requests.
+
+type Dial struct {
+	//
+}
+
+type PortForward struct {
+}
+
+type Exec struct {
+}
+
+type ExecRequest struct {
+	Command string
+}
+
+type PortForwardRequest struct {
+	Port string
+}
+
+type NetworkStats struct {
+	P2P           bool
+	Latency       float64
+	PreferredDERP int
+	DERPLatency   map[string]float64
+}
+
+func New(ctx context.Context, client *codersdk.Client, agentID uuid.UUID, options *codersdk.DialWorkspaceAgentOptions) (http.Handler, io.Closer, error) {
+	r := chi.NewRouter()
+	agentConn, err := client.DialWorkspaceAgent(ctx, agentID, &codersdk.DialWorkspaceAgentOptions{})
+	if err != nil {
+		return nil, nil, err
+	}
+	reachable := agentConn.AwaitReachable(ctx)
+	if !reachable {
+		return nil, nil, xerrors.New("we weren't reachable")
+	}
+	r.Get("/network", func(w http.ResponseWriter, r *http.Request) {
+		// This returns tracked network information!
+	})
+	r.Get("/port/{port}", func(w http.ResponseWriter, r *http.Request) {
+		// This transforms into a port forward!
+	})
+	r.Post("/exec", func(w http.ResponseWriter, r *http.Request) {
+		// This
+	})
+	r.Post("/stop", func(w http.ResponseWriter, r *http.Request) {
+
+	})
+	return r, agentConn, nil
+}
diff --git a/cli/vscodeipc/vscodeipc_test.go b/cli/vscodeipc/vscodeipc_test.go
@@ -0,0 +1,7 @@
+package vscodeipc_test
+
+import "testing"
+
+func TestVSCodeIPC(t *testing.T) {
+
+}
