2 files changed, 98 insertions, 0 deletions
diff --git a/cmd/ask/main.go b/cmd/ask/main.go
new file mode 100644
index 0000000..73d3e04
--- /dev/null
+++ b/cmd/ask/main.go
@@ -0,0 +1,46 @@
+package main
+
+import (
+	"context"
+	"fmt"
+	"io"
+	"os"
+
+	"codeberg.org/snonux/hexai/internal/taskproxy"
+)
+
+type taskRunner func(context.Context, []string, io.Reader, io.Writer, io.Writer) (int, error)
+
+type askRunner struct {
+	runTask taskRunner
+}
+
+func newAskRunner() askRunner {
+	return askRunner{runTask: runAskTask}
+}
+
+func main() {
+	if exitCode := newAskRunner().run(os.Args[1:], os.Stdin, os.Stdout, os.Stderr); exitCode != 0 {
+		os.Exit(exitCode)
+	}
+}
+
+func (r askRunner) run(args []string, stdin io.Reader, stdout, stderr io.Writer) int {
+	runner := normalizeAskRunner(r)
+	exitCode, err := runner.runTask(context.Background(), args, stdin, stdout, stderr)
+	if err != nil {
+		fmt.Fprintln(stderr, err)
+	}
+	return exitCode
+}
+
+func normalizeAskRunner(r askRunner) askRunner {
+	if r.runTask == nil {
+		r.runTask = runAskTask
+	}
+	return r
+}
+
+func runAskTask(ctx context.Context, args []string, stdin io.Reader, stdout, stderr io.Writer) (int, error) {
+	return taskproxy.NewRunner("ask").Run(ctx, args, stdin, stdout, stderr)
+}
diff --git a/cmd/ask/main_test.go b/cmd/ask/main_test.go
new file mode 100644
index 0000000..65551cb
--- /dev/null
+++ b/cmd/ask/main_test.go
@@ -0,0 +1,52 @@
+package main
+
+import (
+	"bytes"
+	"context"
+	"errors"
+	"io"
+	"reflect"
+	"strings"
+	"testing"
+)
+
+func TestAskRunnerRun_ForwardsArgs(t *testing.T) {
+	var gotArgs []string
+	var stdout bytes.Buffer
+	runner := askRunner{
+		runTask: func(_ context.Context, args []string, stdin io.Reader, out, errOut io.Writer) (int, error) {
+			gotArgs = append([]string(nil), args...)
+			_, _ = io.WriteString(out, "task output")
+			return 0, nil
+		},
+	}
+
+	exitCode := runner.run([]string{"list", "limit:1"}, strings.NewReader(""), &stdout, &bytes.Buffer{})
+	if exitCode != 0 {
+		t.Fatalf("exitCode = %d, want 0", exitCode)
+	}
+	wantArgs := []string{"list", "limit:1"}
+	if !reflect.DeepEqual(gotArgs, wantArgs) {
+		t.Fatalf("args = %v, want %v", gotArgs, wantArgs)
+	}
+	if stdout.String() != "task output" {
+		t.Fatalf("stdout = %q, want %q", stdout.String(), "task output")
+	}
+}
+
+func TestAskRunnerRun_WritesErrorToStderr(t *testing.T) {
+	var stderr bytes.Buffer
+	runner := askRunner{
+		runTask: func(context.Context, []string, io.Reader, io.Writer, io.Writer) (int, error) {
+			return 1, errors.New("ask: must be run inside a git repository")
+		},
+	}
+
+	exitCode := runner.run([]string{"list"}, strings.NewReader(""), &bytes.Buffer{}, &stderr)
+	if exitCode != 1 {
+		t.Fatalf("exitCode = %d, want 1", exitCode)
+	}
+	if !strings.Contains(stderr.String(), "must be run inside a git repository") {
+		t.Fatalf("stderr = %q, want actionable repo guidance", stderr.String())
+	}
+}