Function TestCrushEngineExecution

pkg/workflow/crush_engine_test.go:228–385

(t *testing.T)

}

func TestCrushEngineExecution(t *testing.T) {
	engine := NewCrushEngine()

	t.Run("basic execution", func(t *testing.T) {
		workflowData := &WorkflowData{
			Name: "test-workflow",
		}

		steps := engine.GetExecutionSteps(workflowData, "/tmp/test.log")
		require.Len(t, steps, 2, "Should generate config step and execution step")

		// steps[0] = Write Crush config, steps[1] = Execute Crush CLI
		stepContent := strings.Join(steps[1], "\n")

		assert.Contains(t, stepContent, "name: Execute Crush CLI", "Should have correct step name")
		assert.Contains(t, stepContent, "id: agentic_execution", "Should have agentic_execution ID")
		assert.Contains(t, stepContent, "crush run", "Should invoke crush run command")
		assert.Contains(t, stepContent, `"$(cat /tmp/gh-aw/aw-prompts/prompt.txt)"`, "Should include prompt argument")
		assert.Contains(t, stepContent, "/tmp/test.log", "Should include log file")
		assert.Contains(t, stepContent, "OPENAI_API_KEY: ${{ secrets.COPILOT_GITHUB_TOKEN }}", "Should set OPENAI_API_KEY from COPILOT_GITHUB_TOKEN")
		assert.Contains(t, stepContent, "NO_PROXY: localhost,127.0.0.1", "Should set NO_PROXY env var")
	})

	t.Run("basic execution with copilot-requests permission", func(t *testing.T) {
		workflowData := &WorkflowData{
			Name:        "test-workflow",
			Permissions: "permissions:\n  copilot-requests: write",
		}

		steps := engine.GetExecutionSteps(workflowData, "/tmp/test.log")
		require.Len(t, steps, 2, "Should generate config step and execution step")

		stepContent := strings.Join(steps[1], "\n")
		assert.Contains(t, stepContent, "OPENAI_API_KEY: ${{ github.token }}", "Should set OPENAI_API_KEY from github.token when permissions.copilot-requests is write")
	})

	t.Run("with model", func(t *testing.T) {
		workflowData := &WorkflowData{
			Name: "test-workflow",
			EngineConfig: &EngineConfig{
				Model: "anthropic/claude-sonnet-4-20250514",
			},
		}

		steps := engine.GetExecutionSteps(workflowData, "/tmp/test.log")
		require.Len(t, steps, 2, "Should generate config step and execution step")

		stepContent := strings.Join(steps[1], "\n")

		// Model is passed via the native CRUSH_MODEL env var
		assert.Contains(t, stepContent, "CRUSH_MODEL: anthropic/claude-sonnet-4-20250514", "Should set CRUSH_MODEL env var")
	})

	t.Run("without model no model env var", func(t *testing.T) {
		workflowData := &WorkflowData{
			Name: "test-workflow",
		}