fix: Run exec agent

cmd/ctrlc/root/run/exec/exec.go

@@ -2,7 +2,9 @@ package exec
 
 import (
 	"fmt"
+	"runtime"
 
+	"github.com/MakeNowJust/heredoc/v2"
 	"github.com/charmbracelet/log"
 	"github.com/ctrlplanedev/cli/internal/api"
 	"github.com/ctrlplanedev/cli/pkg/jobagent"
@@ -11,21 +13,39 @@ import (
 )
 
 func NewRunExecCmd() *cobra.Command {
-	return &cobra.Command{
+	var name string
+	var jobAgentType = "exec-bash"
+	if runtime.GOOS == "windows" {
+		jobAgentType = "exec-powershell"
+	}
+
+	cmd := &cobra.Command{
 		Use:   "exec",
 		Short: "Execute commands directly when a job is received",
+		Example: heredoc.Doc(`
+			$ ctrlc run exec --name "my-script-agent" --workspace 123e4567-e89b-12d3-a456-426614174000
+		`),
 		RunE: func(cmd *cobra.Command, args []string) error {
 			apiURL := viper.GetString("url")
 			apiKey := viper.GetString("api-key")
+			workspaceId := viper.GetString("workspace")
 			client, err := api.NewAPIKeyClientWithResponses(apiURL, apiKey)
 			if err != nil {
 				return fmt.Errorf("failed to create API client: %w", err)
 			}
+			if name == "" {
+				return fmt.Errorf("name is required")
+			}
+			if workspaceId == "" {
+				return fmt.Errorf("workspace is required")
+			}
+
 			ja, err := jobagent.NewJobAgent(
 				client,
 				api.UpsertJobAgentJSONRequestBody{
-					Name: "exec",
-					Type: "exec",
+					Name:        name,
+					Type:        jobAgentType,
+					WorkspaceId: workspaceId,
 				},
 				&ExecRunner{},
 			)
@@ -41,4 +61,8 @@ func NewRunExecCmd() *cobra.Command {
 			return nil
 		},
 	}
+
+	cmd.Flags().StringVar(&name, "name", "", "Name of the job agent")
+	cmd.MarkFlagRequired("name")
+	return cmd
 }

cmd/ctrlc/root/run/exec/runner.go

@@ -25,6 +25,10 @@ type ExecConfig struct {
 }
 
 func (r *ExecRunner) Status(job api.Job) (api.JobStatus, string) {
+	if job.ExternalId == nil {
+		return api.JobStatusExternalRunNotFound, fmt.Sprintf("external ID is nil: %v", job.ExternalId)
+	}
+
 	externalId, err := strconv.Atoi(*job.ExternalId)
 	if err != nil {
 		return api.JobStatusExternalRunNotFound, fmt.Sprintf("invalid process id: %v", err)
@@ -45,7 +49,7 @@ func (r *ExecRunner) Status(job api.Job) (api.JobStatus, string) {
 	return api.JobStatusInProgress, fmt.Sprintf("process running with pid %d", externalId)
 }
 
-func (r *ExecRunner) Start(job api.Job) (string, error) {
+func (r *ExecRunner) Start(job api.Job, jobDetails map[string]interface{}) (string, error) {
 	// Create temp script file
 	ext := ".sh"
 	if runtime.GOOS == "windows" {
@@ -73,7 +77,7 @@ func (r *ExecRunner) Start(job api.Job) (string, error) {
 	}
 
 	buf := new(bytes.Buffer)
-	if err := templatedScript.Execute(buf, job); err != nil {
+	if err := templatedScript.Execute(buf, jobDetails); err != nil {
 		return "", fmt.Errorf("failed to execute script template: %w", err)
 	}
 	script := buf.String()

pkg/jobagent/job_details.go

@@ -0,0 +1,35 @@
+package jobagent
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+
+	"github.com/ctrlplanedev/cli/internal/api"
+	"github.com/spf13/viper"
+)
+
+func fetchJobDetails(ctx context.Context, jobID string) (map[string]interface{}, error) {
+	client, err := api.NewAPIKeyClientWithResponses(viper.GetString("url"), viper.GetString("api-key"))
+	if err != nil {
+		return nil, fmt.Errorf("failed to create API client for job details: %w", err)
+	}
+
+	resp, err := client.GetJobWithResponse(ctx, jobID)
+	if err != nil {
+		return nil, fmt.Errorf("failed to get job details: %w", err)
+	}
+	if resp.JSON200 == nil {
+		return nil, fmt.Errorf("received empty response from job details API")
+	}
+
+	var details map[string]interface{}
+	detailsBytes, err := json.Marshal(resp.JSON200)
+	if err != nil {
+		return nil, fmt.Errorf("failed to marshal job response: %w", err)
+	}
+	if err := json.Unmarshal(detailsBytes, &details); err != nil {
+		return nil, fmt.Errorf("failed to unmarshal job details: %w", err)
+	}
+	return details, nil
+}

pkg/jobagent/runner.go

@@ -10,7 +10,7 @@ import (
 )
 
 type Runner interface {
-	Start(job api.Job) (string, error)
+	Start(job api.Job, jobDetails map[string]interface{}) (string, error)
 	Status(job api.Job) (api.JobStatus, string)
 }
 
@@ -29,10 +29,10 @@ func NewJobAgent(
 	}
 
 	ja := &JobAgent{
-		client: client,
-
+		client:      client,
 		id:          agent.JSON200.Id,
 		workspaceId: config.WorkspaceId,
+		runner:      runner,
 	}
 
 	return ja, nil
@@ -66,9 +66,14 @@ func (a *JobAgent) RunQueuedJobs() error {
 	var wg sync.WaitGroup
 	for _, job := range *jobs.JSON200.Jobs {
 		wg.Add(1)
+		jobDetails, err := fetchJobDetails(context.Background(), job.Id.String())
+		if err != nil {
+			log.Error("Failed to fetch job details", "error", err, "jobId", job.Id.String())
+			continue
+		}
 		go func(job api.Job) {
 			defer wg.Done()
-			externalId, err := a.runner.Start(job)
+			externalId, err := a.runner.Start(job, jobDetails)
 			if err != nil {
 				status := api.JobStatusInProgress
 				message := fmt.Sprintf("Failed to start job: %s", err.Error())