[draft] DO NOT MERGE: rayapp test prototype

build_rayapp.sh

@@ -6,6 +6,6 @@ echo "--- Building rayapp"
 mkdir -p ci/bin
 go build -o ci/bin/rayapp ./rayapp/rayapp
 
-echo "--- Building template releases"
+echo "--- Running rayapp commands"
 rm -rf _build
 exec ci/bin/rayapp "$@"

rayapp/anyscale_cli.go

@@ -0,0 +1,35 @@
+package rayapp
+
+import (
+	"bytes"
+	"errors"
+	"fmt"
+	"os/exec"
+)
+
+var errAnyscaleNotInstalled = errors.New("anyscale is not installed")
+
+func isAnyscaleInstalled() bool {
+	_, err := exec.LookPath("anyscale")
+	return err == nil
+}
+
+// RunAnyscaleCLI runs the anyscale CLI with the given arguments.
+func RunAnyscaleCLI(args []string) (string, error) {
+	if !isAnyscaleInstalled() {
+		return "", errAnyscaleNotInstalled
+	}
+
+	cmd := exec.Command("anyscale", args...)
+
+	var stdout, stderr bytes.Buffer
+	cmd.Stdout = &stdout
+	cmd.Stderr = &stderr
+
+	err := cmd.Run()
+	if err != nil {
+		return "", fmt.Errorf("anyscale error: %v\nstderr: %s", err, stderr.String())
+	}
+
+	return stdout.String(), nil
+}

rayapp/anyscale_cli_test.go

@@ -0,0 +1,110 @@
+package rayapp
+
+import (
+	"errors"
+	"os"
+	"strings"
+	"testing"
+)
+
+// setupMockAnyscale creates a mock anyscale script and returns a cleanup function.
+func setupMockAnyscale(t *testing.T, script string) {
+	t.Helper()
+	tmp := t.TempDir()
+
+	if script != "" {
+		mockScript := tmp + "/anyscale"
+		if err := os.WriteFile(mockScript, []byte(script), 0755); err != nil {
+			t.Fatalf("failed to create mock script: %v", err)
+		}
+	}
+
+	origPath := os.Getenv("PATH")
+	t.Cleanup(func() { os.Setenv("PATH", origPath) })
+	os.Setenv("PATH", tmp)
+}
+
+func TestRunAnyscaleCLI(t *testing.T) {
+	tests := []struct {
+		name       string
+		script     string
+		args       []string
+		wantErr    error
+		wantSubstr string
+	}{
+		{
+			name:    "anyscale not installed",
+			script:  "", // empty PATH, no script
+			args:    []string{"--version"},
+			wantErr: errAnyscaleNotInstalled,
+		},
+		{
+			name:       "success",
+			script:     "#!/bin/sh\necho \"output: $@\"",
+			args:       []string{"service", "deploy"},
+			wantSubstr: "output: service deploy",
+		},
+		{
+			name:       "empty args",
+			script:     "#!/bin/sh\necho \"help\"",
+			args:       []string{},
+			wantSubstr: "help",
+		},
+		{
+			name:       "command fails with stderr",
+			script:     "#!/bin/sh\necho \"error msg\" >&2; exit 1",
+			args:       []string{"deploy"},
+			wantSubstr: "error msg",
+			wantErr:    errors.New("anyscale error"),
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			setupMockAnyscale(t, tt.script)
+
+			output, err := RunAnyscaleCLI(tt.args)
+
+			if tt.wantErr != nil {
+				if err == nil {
+					t.Fatal("expected error, got nil")
+				}
+				if errors.Is(tt.wantErr, errAnyscaleNotInstalled) {
+					if !errors.Is(err, errAnyscaleNotInstalled) {
+						t.Errorf("expected errAnyscaleNotInstalled, got: %v", err)
+					}
+				} else if !strings.Contains(err.Error(), tt.wantErr.Error()) {
+					t.Errorf("error %q should contain %q", err.Error(), tt.wantErr.Error())
+				}
+				// For error cases, also check wantSubstr against error message
+				if tt.wantSubstr != "" && !strings.Contains(err.Error(), tt.wantSubstr) {
+					t.Errorf("error %q should contain %q", err.Error(), tt.wantSubstr)
+				}
+				return
+			}
+
+			if err != nil {
+				t.Fatalf("unexpected error: %v", err)
+			}
+			if tt.wantSubstr != "" && !strings.Contains(output, tt.wantSubstr) {
+				t.Errorf("output %q should contain %q", output, tt.wantSubstr)
+			}
+		})
+	}
+}
+
+func TestIsAnyscaleInstalled(t *testing.T) {
+	t.Run("not installed", func(t *testing.T) {
+		setupMockAnyscale(t, "")
+		if isAnyscaleInstalled() {
+			t.Error("should return false when not in PATH")
+		}
+	})
+
+	t.Run("installed", func(t *testing.T) {
+		setupMockAnyscale(t, "#!/bin/sh\necho mock")
+		if !isAnyscaleInstalled() {
+			t.Error("should return true when in PATH")
+		}
+	})
+}