feat: add PTY CLI providers for Claude Code, Copilot, Codex, Gemini, Cursor

Implements CLIAdapter interface and ptyProvider driving AI CLI tools via
pseudo-terminal. Chat() runs non-interactively via -p flag; Stream() keeps
a PTY session alive for multi-turn conversation. Factory functions registered
in both ProviderRegistry implementations under types: claude_code, copilot_cli,
codex_cli, gemini_cli, cursor_cli. cfg.BaseURL repurposed as workDir.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: intel352

genkit/providers.go

@@ -4,7 +4,9 @@ import (
 	"context"
 	"fmt"
 	"os"
+	"os/exec"
 	"sync"
+	"time"
 
 	"github.com/GoCodeAlone/workflow-plugin-agent/provider"
 	gk "github.com/firebase/genkit/go/genkit"
@@ -317,6 +319,52 @@ func NewVertexAIProvider(ctx context.Context, projectID, region, model, credenti
 	}, nil
 }
 
+// newPTYProvider creates a ptyProvider for the given CLIAdapter.
+// workDir optionally sets the working directory for the CLI process.
+func newPTYProvider(adapter CLIAdapter, workDir string) (provider.Provider, error) {
+	binPath, err := exec.LookPath(adapter.Binary())
+	if err != nil {
+		return nil, fmt.Errorf("pty provider %s: binary %q not found in PATH: %w", adapter.Name(), adapter.Binary(), err)
+	}
+	return &ptyProvider{
+		adapter: adapter,
+		binPath: binPath,
+		workDir: workDir,
+		timeout: 5 * time.Minute,
+		authInfo: provider.AuthModeInfo{
+			Mode:        "none",
+			DisplayName: adapter.Name(),
+			Description: "CLI-driven provider via PTY",
+			ServerSafe:  false,
+		},
+	}, nil
+}
+
+// NewClaudeCodeProvider creates a provider backed by the `claude` CLI.
+func NewClaudeCodeProvider(workDir string) (provider.Provider, error) {
+	return newPTYProvider(ClaudeCodeAdapter{}, workDir)
+}
+
+// NewCopilotCLIProvider creates a provider backed by the `copilot` CLI.
+func NewCopilotCLIProvider(workDir string) (provider.Provider, error) {
+	return newPTYProvider(CopilotCLIAdapter{}, workDir)
+}
+
+// NewCodexCLIProvider creates a provider backed by the `codex` CLI.
+func NewCodexCLIProvider(workDir string) (provider.Provider, error) {
+	return newPTYProvider(CodexCLIAdapter{}, workDir)
+}
+
+// NewGeminiCLIProvider creates a provider backed by the `gemini` CLI.
+func NewGeminiCLIProvider(workDir string) (provider.Provider, error) {
+	return newPTYProvider(GeminiCLIAdapter{}, workDir)
+}
+
+// NewCursorCLIProvider creates a provider backed by the `agent` CLI (Cursor).
+func NewCursorCLIProvider(workDir string) (provider.Provider, error) {
+	return newPTYProvider(CursorCLIAdapter{}, workDir)
+}
+
 // NewBedrockProvider creates a provider for AWS Bedrock using an OpenAI-compatible endpoint.
 // Wraps existing Bedrock implementation as a provider.Provider until a native Genkit plugin is available.
 func NewBedrockProvider(ctx context.Context, region, model, accessKeyID, secretAccessKey, sessionToken, baseURL string, maxTokens int) (provider.Provider, error) {

genkit/pty_adapters.go

@@ -0,0 +1,232 @@
+package genkit
+
+import (
+	"regexp"
+	"strings"
+)
+
+// ansiEscape matches ANSI escape sequences for stripping from PTY output.
+var ansiEscape = regexp.MustCompile(`\x1b\[[0-9;]*[a-zA-Z]|\x1b[()][A-Z0-9]|\x1b[^[]`)
+
+// stripANSI removes ANSI escape codes from s.
+func stripANSI(s string) string {
+	return ansiEscape.ReplaceAllString(s, "")
+}
+
+// promptRegex matches a line starting with ❯ or > (prompt indicators).
+var promptRegex = regexp.MustCompile(`(?m)^[❯>]\s`)
+
+// detectPromptDefault returns true when a standard prompt character appears.
+func detectPromptDefault(output string) bool {
+	clean := stripANSI(output)
+	return promptRegex.MatchString(clean)
+}
+
+// detectResponseEndDefault returns true when the prompt reappears after content.
+// We require at least some non-whitespace content before the prompt.
+func detectResponseEndDefault(output string) bool {
+	clean := stripANSI(output)
+	// Find prompt positions
+	locs := promptRegex.FindAllStringIndex(clean, -1)
+	if len(locs) < 2 {
+		return false
+	}
+	// Check there's non-whitespace content between first and second prompt.
+	between := clean[locs[0][1]:locs[1][0]]
+	return strings.TrimSpace(between) != ""
+}
+
+// parseResponseDefault strips ANSI, trims whitespace, and removes spinner lines.
+func parseResponseDefault(raw string) string {
+	clean := stripANSI(raw)
+	var lines []string
+	for _, line := range strings.Split(clean, "\n") {
+		trimmed := strings.TrimSpace(line)
+		// Skip empty lines, prompt lines, and spinner/status indicators.
+		if trimmed == "" || promptRegex.MatchString(line) {
+			continue
+		}
+		lines = append(lines, trimmed)
+	}
+	return strings.Join(lines, "\n")
+}
+
+// ── Claude Code ──────────────────────────────────────────────────────────────
+
+// ClaudeCodeAdapter drives the `claude` CLI.
+type ClaudeCodeAdapter struct{}
+
+func (ClaudeCodeAdapter) Name() string { return "claude_code" }
+func (ClaudeCodeAdapter) Binary() string { return "claude" }
+
+func (ClaudeCodeAdapter) NonInteractiveArgs(msg string) []string {
+	return []string{"-p", msg, "--output-format", "text"}
+}
+
+func (ClaudeCodeAdapter) HealthCheckArgs() []string {
+	return []string{"-p", "say ok", "--output-format", "text"}
+}
+
+func (ClaudeCodeAdapter) DetectPrompt(output string) bool {
+	return detectPromptDefault(output)
+}
+
+func (ClaudeCodeAdapter) DetectResponseEnd(output string) bool {
+	return detectResponseEndDefault(output)
+}
+
+func (ClaudeCodeAdapter) ParseResponse(raw string) string {
+	return parseResponseDefault(raw)
+}
+
+// ── Copilot CLI ───────────────────────────────────────────────────────────────
+
+// CopilotCLIAdapter drives the `copilot` CLI.
+type CopilotCLIAdapter struct{}
+
+func (CopilotCLIAdapter) Name() string { return "copilot_cli" }
+func (CopilotCLIAdapter) Binary() string { return "copilot" }
+
+func (CopilotCLIAdapter) NonInteractiveArgs(msg string) []string {
+	return []string{"-p", msg}
+}
+
+func (CopilotCLIAdapter) HealthCheckArgs() []string {
+	return []string{"-p", "say ok"}
+}
+
+var copilotPromptRegex = regexp.MustCompile(`(?m)^>\s`)
+
+func (CopilotCLIAdapter) DetectPrompt(output string) bool {
+	clean := stripANSI(output)
+	return copilotPromptRegex.MatchString(clean)
+}
+
+func (CopilotCLIAdapter) DetectResponseEnd(output string) bool {
+	clean := stripANSI(output)
+	locs := copilotPromptRegex.FindAllStringIndex(clean, -1)
+	if len(locs) < 2 {
+		return false
+	}
+	between := clean[locs[0][1]:locs[1][0]]
+	return strings.TrimSpace(between) != ""
+}
+
+func (CopilotCLIAdapter) ParseResponse(raw string) string {
+	clean := stripANSI(raw)
+	var lines []string
+	for _, line := range strings.Split(clean, "\n") {
+		trimmed := strings.TrimSpace(line)
+		if trimmed == "" || copilotPromptRegex.MatchString(line) {
+			continue
+		}
+		lines = append(lines, trimmed)
+	}
+	return strings.Join(lines, "\n")
+}
+
+// ── Codex CLI ─────────────────────────────────────────────────────────────────
+
+// CodexCLIAdapter drives the `codex` CLI.
+type CodexCLIAdapter struct{}
+
+func (CodexCLIAdapter) Name() string { return "codex_cli" }
+func (CodexCLIAdapter) Binary() string { return "codex" }
+
+func (CodexCLIAdapter) NonInteractiveArgs(msg string) []string {
+	return []string{"exec", msg}
+}
+
+func (CodexCLIAdapter) HealthCheckArgs() []string {
+	return []string{"exec", "say ok"}
+}
+
+// codexPromptRegex matches Codex's composer input area indicator.
+var codexPromptRegex = regexp.MustCompile(`(?m)^[>❯]\s|composer|Type your`)
+
+func (CodexCLIAdapter) DetectPrompt(output string) bool {
+	clean := stripANSI(output)
+	return codexPromptRegex.MatchString(clean)
+}
+
+func (CodexCLIAdapter) DetectResponseEnd(output string) bool {
+	return detectResponseEndDefault(output)
+}
+
+func (CodexCLIAdapter) ParseResponse(raw string) string {
+	return parseResponseDefault(raw)
+}
+
+// ── Gemini CLI ────────────────────────────────────────────────────────────────
+
+// GeminiCLIAdapter drives the `gemini` CLI.
+type GeminiCLIAdapter struct{}
+
+func (GeminiCLIAdapter) Name() string { return "gemini_cli" }
+func (GeminiCLIAdapter) Binary() string { return "gemini" }
+
+func (GeminiCLIAdapter) NonInteractiveArgs(msg string) []string {
+	return []string{"-p", msg}
+}
+
+func (GeminiCLIAdapter) HealthCheckArgs() []string {
+	return []string{"-p", "say ok"}
+}
+
+func (GeminiCLIAdapter) DetectPrompt(output string) bool {
+	return detectPromptDefault(output)
+}
+
+func (GeminiCLIAdapter) DetectResponseEnd(output string) bool {
+	return detectResponseEndDefault(output)
+}
+
+func (GeminiCLIAdapter) ParseResponse(raw string) string {
+	return parseResponseDefault(raw)
+}
+
+// ── Cursor CLI ────────────────────────────────────────────────────────────────
+
+// CursorCLIAdapter drives the `agent` binary (Cursor's agent CLI).
+type CursorCLIAdapter struct{}
+
+func (CursorCLIAdapter) Name() string { return "cursor_cli" }
+func (CursorCLIAdapter) Binary() string { return "agent" }
+
+func (CursorCLIAdapter) NonInteractiveArgs(msg string) []string {
+	return []string{"-p", msg}
+}
+
+func (CursorCLIAdapter) HealthCheckArgs() []string {
+	return []string{"-p", "say ok"}
+}
+
+var cursorPromptRegex = regexp.MustCompile(`(?m)^>\s`)
+
+func (CursorCLIAdapter) DetectPrompt(output string) bool {
+	clean := stripANSI(output)
+	return cursorPromptRegex.MatchString(clean)
+}
+
+func (CursorCLIAdapter) DetectResponseEnd(output string) bool {
+	clean := stripANSI(output)
+	locs := cursorPromptRegex.FindAllStringIndex(clean, -1)
+	if len(locs) < 2 {
+		return false
+	}
+	between := clean[locs[0][1]:locs[1][0]]
+	return strings.TrimSpace(between) != ""
+}
+
+func (CursorCLIAdapter) ParseResponse(raw string) string {
+	clean := stripANSI(raw)
+	var lines []string
+	for _, line := range strings.Split(clean, "\n") {
+		trimmed := strings.TrimSpace(line)
+		if trimmed == "" || cursorPromptRegex.MatchString(line) {
+			continue
+		}
+		lines = append(lines, trimmed)
+	}
+	return strings.Join(lines, "\n")
+}