Add placement and scheduler in slim mode self-hosted tests

Signed-off-by: Anton Troshin <[email protected]>

Author: antontroshin

tests/e2e/standalone/commands.go

@@ -18,8 +18,10 @@ package standalone_test
 import (
 	"context"
 	"fmt"
+	"path/filepath"
 	"strings"
 
+	"github.com/dapr/cli/pkg/standalone"
 	"github.com/dapr/cli/tests/e2e/common"
 	"github.com/dapr/cli/tests/e2e/spawn"
 	"github.com/dapr/cli/utils"
@@ -46,6 +48,47 @@ func cmdDashboard(ctx context.Context, port string) error {
 	return fmt.Errorf("Dashboard could not be started: %s", errOutput)
 }
 
+func cmdProcess(ctx context.Context, executable string, log func(args ...any), args ...string) (string, error) {
+	path, err := GetExecutablePath(executable)
+	if err != nil {
+		return "", err
+	}
+
+	stdOutChan, stdErrChan, err := spawn.CommandWithContext(ctx, path, args...)
+	if err != nil {
+		return "", err
+	}
+
+	if log != nil {
+		go func() {
+			for {
+				select {
+				case output := <-stdOutChan:
+					if output != "" {
+						log(executable + ": " + output)
+					}
+				case output := <-stdErrChan:
+					if output != "" {
+						log(executable + ": " + output)
+					}
+				case <-ctx.Done():
+					return
+				}
+			}
+		}()
+	}
+
+	return "", nil
+}
+
+func GetExecutablePath(executable string) (string, error) {
+	path, err := standalone.GetDaprRuntimePath("")
+	if err != nil {
+		return "", err
+	}
+	return filepath.Join(path, "bin", executable), nil
+}
+
 // cmdInit installs Dapr with the init command and returns the command output and error.
 //
 // When DAPR_E2E_INIT_SLIM is true, it will install Dapr without Docker containers.

tests/e2e/standalone/run_test.go

@@ -16,6 +16,7 @@ limitations under the License.
 package standalone_test
 
 import (
+	"context"
 	"fmt"
 	"runtime"
 	"testing"
@@ -26,9 +27,23 @@ import (
 
 func TestStandaloneRun(t *testing.T) {
 	ensureDaprInstallation(t)
+
+	ctx, cancelFunc := context.WithCancel(context.Background())
+	defer cancelFunc()
+
+	if isSlimMode() {
+		output, err := cmdProcess(ctx, "placement", t.Log, "--metrics-port", "9091", "--healthz-port", "8081")
+		require.NoError(t, err)
+		t.Log(output)
+		output, err = cmdProcess(ctx, "scheduler", t.Log, "--metrics-port", "9092", "--healthz-port", "8082")
+		require.NoError(t, err)
+		t.Log(output)
+	}
 	t.Cleanup(func() {
 		// remove dapr installation after all tests in this function.
 		must(t, cmdUninstall, "failed to uninstall Dapr")
+		// Call cancelFunc to stop the processes
+		cancelFunc()
 	})
 	for _, path := range getSocketCases() {
 		t.Run(fmt.Sprintf("normal exit, socket: %s", path), func(t *testing.T) {