script.go RawHistoryFolder

1package executor
2
3import (
4	"bytes"
5	"context"
6	"fmt"
7	"os"
8	"os/exec"
9
10	"github.com/bnema/archup/internal/domain/ports"
11)
12
13// ScriptExecutor implements the ScriptExecutor port for shell scripts
14type ScriptExecutor struct {
15	fs        ports.FileSystem
16	cmdExec   ports.CommandExecutor
17	scriptDir string
18}
19
20// NewScriptExecutor creates a new script executor with dependencies
21func NewScriptExecutor(fs ports.FileSystem, cmdExec ports.CommandExecutor, scriptDir string) *ScriptExecutor {
22	return &ScriptExecutor{
23		fs:        fs,
24		cmdExec:   cmdExec,
25		scriptDir: scriptDir,
26	}
27}
28
29// ExecuteScript runs a shell script with environment variables
30func (se *ScriptExecutor) ExecuteScript(ctx context.Context, scriptPath string, env map[string]string) error {
31	// Verify script exists
32	if _, err := os.Stat(scriptPath); err != nil {
33		return fmt.Errorf("script not found: %w", err)
34	}
35
36	cmd := exec.CommandContext(ctx, "bash", scriptPath)
37	var stdout, stderr bytes.Buffer
38	cmd.Stdout = &stdout
39	cmd.Stderr = &stderr
40
41	// Build environment: start with current environment, then add/override with provided env
42	cmdEnv := os.Environ()
43	for key, value := range env {
44		cmdEnv = append(cmdEnv, fmt.Sprintf("%s=%s", key, value))
45	}
46	cmd.Env = cmdEnv
47
48	if err := cmd.Run(); err != nil {
49		return fmt.Errorf("script execution failed: %w (stdout: %s, stderr: %s)", err, stdout.String(), stderr.String())
50	}
51
52	return nil
53}