test(runner): cover remote runner flow

Generated with [codeagent](https://github.com/qbox/codeagent)
Co-authored-by: Cai-Tang-www <106404101+Cai-Tang-www@users.noreply.github.com>

Author: xgopilot

internal/cli/runner_command_test.go

@@ -0,0 +1,75 @@
+package cli
+
+import (
+	"context"
+	"path/filepath"
+	"strings"
+	"testing"
+)
+
+func TestNewRunnerCommandForwardsFlags(t *testing.T) {
+	originalRunner := runRunnerCommandFn
+	t.Cleanup(func() { runRunnerCommandFn = originalRunner })
+
+	var captured runnerCommandOptions
+	runRunnerCommandFn = func(ctx context.Context, options runnerCommandOptions) error {
+		captured = options
+		return nil
+	}
+
+	cmd := newRunnerCommand()
+	cmd.SetArgs([]string{
+		"--gateway-address", "127.0.0.1:9000",
+		"--token-file", "/tmp/token",
+		"--runner-id", "runner-1",
+		"--runner-name", "Local Runner",
+		"--workdir", "/tmp/work",
+	})
+	if err := cmd.ExecuteContext(context.Background()); err != nil {
+		t.Fatalf("ExecuteContext() error = %v", err)
+	}
+	if captured.GatewayAddress != "127.0.0.1:9000" || captured.TokenFile != "/tmp/token" || captured.RunnerID != "runner-1" || captured.RunnerName != "Local Runner" || captured.Workdir != "/tmp/work" {
+		t.Fatalf("captured options = %#v", captured)
+	}
+}
+
+func TestDefaultRunRunnerReadsTokenFileError(t *testing.T) {
+	err := defaultRunRunner(context.Background(), runnerCommandOptions{TokenFile: filepath.Join(t.TempDir(), "missing.token")})
+	if err == nil || !strings.Contains(err.Error(), "read token file") {
+		t.Fatalf("defaultRunRunner() error = %v", err)
+	}
+}
+
+func TestRootCommandIncludesRunnerSubcommand(t *testing.T) {
+	cmd := NewRootCommand()
+	found := false
+	for _, child := range cmd.Commands() {
+		if child.Name() == "runner" {
+			found = true
+			break
+		}
+	}
+	if !found {
+		t.Fatal("runner subcommand not registered on root command")
+	}
+}
+
+func TestNewRunnerCommandAllowsDefaultFlags(t *testing.T) {
+	originalRunner := runRunnerCommandFn
+	t.Cleanup(func() { runRunnerCommandFn = originalRunner })
+
+	var captured runnerCommandOptions
+	runRunnerCommandFn = func(ctx context.Context, options runnerCommandOptions) error {
+		captured = options
+		return nil
+	}
+
+	cmd := newRunnerCommand()
+	cmd.SetArgs([]string{})
+	if err := cmd.ExecuteContext(context.Background()); err != nil {
+		t.Fatalf("ExecuteContext() error = %v", err)
+	}
+	if captured != (runnerCommandOptions{}) {
+		t.Fatalf("captured options = %#v, want zero-value defaults before runtime resolution", captured)
+	}
+}

internal/config/runner_test.go

@@ -0,0 +1,67 @@
+package config
+
+import (
+	"testing"
+	"time"
+)
+
+func TestRunnerConfigApplyDefaultsCloneAndDurations(t *testing.T) {
+	cfg := RunnerConfig{
+		WorkdirAllowlist: []string{"/tmp/work"},
+	}
+	defaults := defaultRunnerConfig()
+	cfg.ApplyDefaults(defaults)
+
+	if cfg.GatewayAddress != DefaultRunnerGatewayAddress {
+		t.Fatalf("GatewayAddress = %q", cfg.GatewayAddress)
+	}
+	if cfg.HeartbeatInterval() != 10*time.Second {
+		t.Fatalf("HeartbeatInterval() = %s", cfg.HeartbeatInterval())
+	}
+	if cfg.ReconnectBackoffMin() != 500*time.Millisecond {
+		t.Fatalf("ReconnectBackoffMin() = %s", cfg.ReconnectBackoffMin())
+	}
+	if cfg.ReconnectBackoffMax() != 10*time.Second {
+		t.Fatalf("ReconnectBackoffMax() = %s", cfg.ReconnectBackoffMax())
+	}
+	if cfg.RequestTimeout() != 30*time.Second {
+		t.Fatalf("RequestTimeout() = %s", cfg.RequestTimeout())
+	}
+
+	clone := cfg.Clone()
+	clone.WorkdirAllowlist[0] = "/changed"
+	if cfg.WorkdirAllowlist[0] != "/tmp/work" {
+		t.Fatal("Clone() did not deep copy WorkdirAllowlist")
+	}
+}
+
+func TestRunnerConfigValidate(t *testing.T) {
+	if err := (RunnerConfig{}).Validate(); err != nil {
+		t.Fatalf("disabled RunnerConfig.Validate() error = %v", err)
+	}
+
+	cases := []RunnerConfig{
+		{Enabled: true},
+		{Enabled: true, GatewayAddress: "127.0.0.1:8080", HeartbeatIntervalSec: -1},
+		{Enabled: true, GatewayAddress: "127.0.0.1:8080", HeartbeatIntervalSec: 1, ReconnectBackoffMinM: -1, ReconnectBackoffMaxM: 1},
+		{Enabled: true, GatewayAddress: "127.0.0.1:8080", HeartbeatIntervalSec: 1, ReconnectBackoffMinM: 2, ReconnectBackoffMaxM: 1},
+		{Enabled: true, GatewayAddress: "127.0.0.1:8080", HeartbeatIntervalSec: 1, ReconnectBackoffMinM: 1, ReconnectBackoffMaxM: 2, RequestTimeoutSec: -1},
+	}
+	for _, cfg := range cases {
+		if err := cfg.Validate(); err == nil {
+			t.Fatalf("Validate() error = nil for %#v", cfg)
+		}
+	}
+
+	valid := RunnerConfig{
+		Enabled:              true,
+		GatewayAddress:       "127.0.0.1:8080",
+		HeartbeatIntervalSec: 1,
+		ReconnectBackoffMinM: 1,
+		ReconnectBackoffMaxM: 2,
+		RequestTimeoutSec:    3,
+	}
+	if err := valid.Validate(); err != nil {
+		t.Fatalf("Validate() error = %v", err)
+	}
+}

internal/feishuadapter/runner_error_test.go

@@ -0,0 +1,18 @@
+package feishuadapter
+
+import "testing"
+
+func TestTranslateRunnerError(t *testing.T) {
+	cases := map[string]string{
+		"runner_offline":                "本机 Runner 未连接，请在电脑上启动 `neocode runner`",
+		"capability_denied":             "权限不足：当前能力令牌不允许此操作",
+		"tool_execution_failed: failed": "工具执行失败：tool_execution_failed: failed",
+		"timed out waiting for runner":  "本机 Runner 响应超时，请检查网络连接和 Runner 状态",
+		"other":                         "",
+	}
+	for input, want := range cases {
+		if got := translateRunnerError(input); got != want {
+			t.Fatalf("translateRunnerError(%q) = %q, want %q", input, got, want)
+		}
+	}
+}