Compare commits

...

4 Commits

Author SHA1 Message Date
shokollm
b28ad78bd8 fix(queue): add --format=json and --limit flags to queue list 2026-04-08 06:20:52 +00:00
d152421d3f Merge pull request 'refactor(cli): restructure help text to show parent commands' (#255) from fix/issue-244 into main 2026-04-08 07:50:08 +02:00
shokollm
9f7da84915 refactor(cli): restructure help text to show parent commands
- kugetsu: show only parent commands, not all subcommands inline
- kugetsu <command> help: show help for specific command
- kugetsu queue: show queue subcommands (list, stats, clear, enqueue)
- kugetsu queue-daemon: show daemon subcommands (start, stop, restart, status, logs)
- kugetsu env: show env subcommands (list, get, set, rm)
- kugetsu server: show server subcommands (list, add, remove, default, get)

Closes #244
2026-04-08 05:12:51 +00:00
ab99647193 Merge pull request 'fix(shell): address shellcheck warnings, standardize error handling, add retry logic' (#253) from fix/issue-121 into main 2026-04-08 07:04:26 +02:00

View File

@@ -17,77 +17,129 @@ usage() {
kugetsu - OpenCode Session Manager (Issue-Driven) kugetsu - OpenCode Session Manager (Issue-Driven)
Usage: Usage:
kugetsu init [--force] Initialize base + pm-agent sessions (requires TTY) kugetsu <command> [subcommand] [options]
kugetsu start <issue-ref> <message> [--debug] Start task for issue (forks base session)
kugetsu continue <issue-ref> [message] [--debug] Continue existing task for issue Commands:
kugetsu delegate <message> Send message to PM agent (fire-and-forget) init [--force] Initialize base + pm-agent sessions (requires TTY)
kugetsu logs [n] Show recent delegation logs (default: 10) start <issue-ref> <message> [--debug] Start task for issue (forks base session)
kugetsu status Check kugetsu initialization status continue <issue-ref> [message] [--debug] Continue existing task for issue
kugetsu doctor [--fix] Diagnose and fix kugetsu issues delegate <message> Send message to PM agent (fire-and-forget)
kugetsu notify [list|clear] Show or clear notifications logs [n] Show recent delegation logs (default: 10)
kugetsu list List all tracked sessions status Check kugetsu initialization status
kugetsu prune [--force] Remove orphaned sessions (keeps base + pm-agent) doctor [--fix] Diagnose and fix kugetsu issues
kugetsu destroy <issue-ref> [-y] Delete session for issue notify [list|clear] Show or clear notifications
kugetsu destroy --pm-agent [-y] Delete pm-agent session (not recommended) list List all tracked sessions
kugetsu destroy --base [-y] Delete base session prune [--force] Remove orphaned sessions
kugetsu set-pr <issue-ref> <pr-url> Set PR URL for session (for PR tracking) destroy <target> [-y] Delete session (issue, pm-agent, or base)
kugetsu context <issue-ref> Show context for issue set-pr <issue-ref> <pr-url> Set PR URL for session
kugetsu queue [list|stats|clear] Show queue status or statistics context <issue-ref> Show context for issue
kugetsu queue enqueue <issue-ref> <message> Enqueue a task (normally via delegate) queue [subcommand] Queue management
kugetsu queue-daemon [start|stop|restart|status|logs] Manage queue daemon queue-daemon [subcommand] Queue daemon management
kugetsu env [get|set|list] Manage agent environment variables env [subcommand] Environment variable management
kugetsu server [list|add|remove|default|get] Manage git server configurations server [subcommand] Git server configuration
kugetsu help Show this help help [command] Show help for a command
Use 'kugetsu <command> help' for subcommand help.
Example: kugetsu queue help, kugetsu queue-daemon help
Issue Ref Format: Issue Ref Format:
instance/user/repo#number instance/user/repo#number
Example: github.com/shoko/kugetsu#14 Example: github.com/shoko/kugetsu#14
EOF
}
Commands: usage_queue() {
init Create base + pm-agent sessions via TUI. Requires terminal access. cat << 'EOF'
Use --force to reinitialize if sessions exist. kugetsu queue - Queue management
start Fork new session from base for specific issue.
Requires pm-agent to be running (created by init).
continue Continue work on existing issue session.
delegate Send message to PM agent for task coordination.
Fire-and-forget: returns immediately, runs in background.
Use 'kugetsu logs' to check output.
logs Show recent delegation logs.
Default: 10 most recent. Use 'kugetsu logs 20' for more.
status Check if kugetsu is initialized and PM agent is active.
doctor Diagnose kugetsu issues. Use --fix to attempt repairs.
notify Show or clear notifications from PM agent.
Use 'kugetsu notify list' to see unread notifications.
list Show all sessions (base + pm-agent + forked issues).
prune Remove sessions not in index (orphaned from opencode).
Use --force to skip confirmation.
destroy Delete specific issue, pm-agent, or base session.
Options: Usage:
--debug Show real-time debug output and capture to debug.log kugetsu queue [subcommand]
PM Context: Subcommands:
kugetsu reads ~/.kugetsu/pm-agent.md (if exists) and injects it list [--limit=N] [--format=json] Show pending tasks (default: 10 items, text format)
into the PM agent session at init time. This allows customizing PM stats Show queue statistics
behavior without recreating the session. clear Clear all queue items
enqueue <issue-ref> <message> Enqueue a task
help Show this help
Notifications: Options for list:
PM Agent writes task completion notifications to ~/.kugetsu/notifications.json --limit=N Number of items to return (default: 10)
Use 'kugetsu notify list' to see unread notifications. --format=json Output in JSON format with stats
Examples: Examples:
kugetsu init kugetsu queue list
kugetsu status kugetsu queue list --limit=50
kugetsu delegate "work on issue #5" kugetsu queue list --format=json
kugetsu logs kugetsu queue list --limit=20 --format=json
kugetsu logs 20 kugetsu queue stats
kugetsu doctor kugetsu queue clear
kugetsu doctor --fix kugetsu queue enqueue github.com/shoko/kugetsu#14 "fix bug"
kugetsu notify list EOF
kugetsu notify clear }
kugetsu start github.com/shoko/kugetsu#14 "fix bug"
kugetsu continue github.com/shoko/kugetsu#14 "add tests" usage_queue_daemon() {
kugetsu list cat << 'EOF'
kugetsu queue-daemon - Queue daemon management
Usage:
kugetsu queue-daemon [subcommand]
Subcommands:
start Start the queue daemon
stop Stop the queue daemon
restart Restart the queue daemon
status Check daemon status
logs Show recent daemon logs
help Show this help
Examples:
kugetsu queue-daemon start
kugetsu queue-daemon status
kugetsu queue-daemon logs
EOF
}
usage_env() {
cat << 'EOF'
kugetsu env - Environment variable management
Usage:
kugetsu env [subcommand]
Subcommands:
list List all environment variables
get <key> Get a specific variable
set <key> <value> Set a variable
rm <key> Remove a variable
help Show this help
Examples:
kugetsu env list
kugetsu env get GITEA_TOKEN
kugetsu env set CUSTOM_VAR "value"
kugetsu env rm CUSTOM_VAR
EOF
}
usage_server() {
cat << 'EOF'
kugetsu server - Git server configuration
Usage:
kugetsu server [subcommand]
Subcommands:
list List all configured servers (default)
add <name> <url> Add a new server
remove <name> Remove a server
default [<name>] Get or set default server
get [<name>] Get server URL
help Show this help
Examples:
kugetsu server list
kugetsu server add github.com https://github.com
kugetsu server default github.com
EOF EOF
} }
@@ -310,19 +362,25 @@ PYEOF
get_pending_tasks() { get_pending_tasks() {
local limit="${1:-10}" local limit="${1:-10}"
local format="${2:-text}"
if [ ! -d "$QUEUE_ITEMS_DIR" ]; then if [ ! -d "$QUEUE_ITEMS_DIR" ]; then
echo "[]" if [ "$format" = "json" ]; then
echo '{"items": [], "total": 0, "pending": 0}'
else
echo "No pending tasks in queue."
fi
return return
fi fi
python3 -c " python3 << PYEOF
import json import json
import os import os
import sys import sys
queue_dir = os.environ.get('QUEUE_ITEMS_DIR', '') queue_dir = os.environ.get('QUEUE_ITEMS_DIR', '')
limit = int(sys.argv[1]) if len(sys.argv) > 1 else 10 limit = int(sys.argv[1]) if len(sys.argv) > 1 else 10
format_type = sys.argv[2] if len(sys.argv) > 2 else 'text'
items = [] items = []
if os.path.isdir(queue_dir): if os.path.isdir(queue_dir):
@@ -334,13 +392,27 @@ if os.path.isdir(queue_dir):
data = json.load(f) data = json.load(f)
if data.get('state') == 'pending': if data.get('state') == 'pending':
items.append(data) items.append(data)
if len(items) >= limit:
break
except: except:
pass pass
print(json.dumps(items)) items.sort(key=lambda x: x.get('pending_since', ''))
" "$limit"
if format_type == 'json':
output = {
"items": items[:limit],
"total": len(items),
"pending": len(items)
}
print(json.dumps(output))
else:
if not items:
print("No pending tasks in queue.")
else:
print("Pending tasks:")
for t in items[:limit]:
msg = t.get('message', '')[:50]
print(f" {t.get('id')}: {t.get('issue_ref')} - {msg}...")
PYEOF
} }
get_queue_stats() { get_queue_stats() {
@@ -865,18 +937,34 @@ find_sessions_by_issue_number() {
} }
cmd_queue() { cmd_queue() {
local action="${1:-list}" local action="${1:-}"
shift
case "$action" in case "$action" in
""|help|--help|-h)
usage_queue
;;
help|--help|-h)
usage_queue
;;
list) list)
local pending_tasks=$(get_pending_tasks 10) local limit="10"
if [ "$pending_tasks" = "[]" ]; then local format="text"
echo "No pending tasks in queue."
else while [ $# -gt 0 ]; do
echo "Pending tasks:" case "$1" in
echo "$pending_tasks" | python3 -c "import sys, json; [print(f\" {t.get('id')}: {t.get('issue_ref')} - {t.get('message', '')[:50]}...\") for t in json.load(sys.stdin)]" --limit=*)
fi limit="${1#*=}"
;;
--format=json)
format="json"
;;
*)
;;
esac
shift
done
get_pending_tasks "$limit" "$format"
;; ;;
stats) stats)
local stats=$(get_queue_stats) local stats=$(get_queue_stats)
@@ -898,8 +986,8 @@ cmd_queue() {
echo "Queue cleared." echo "Queue cleared."
;; ;;
enqueue) enqueue)
local issue_ref="${1:-}" local issue_ref="${2:-}"
local message="${2:-}" local message="${3:-}"
if [ -z "$issue_ref" ] || [ -z "$message" ]; then if [ -z "$issue_ref" ] || [ -z "$message" ]; then
echo "Usage: kugetsu queue enqueue <issue-ref> <message>" >&2 echo "Usage: kugetsu queue enqueue <issue-ref> <message>" >&2
exit 1 exit 1
@@ -910,16 +998,20 @@ cmd_queue() {
check_task_timeouts check_task_timeouts
;; ;;
*) *)
echo "Usage: kugetsu queue [list|stats|clear|enqueue]" >&2 echo "Unknown queue subcommand: $action" >&2
usage_queue
exit 1 exit 1
;; ;;
esac esac
} }
cmd_queue_daemon() { cmd_queue_daemon() {
local action="${1:-status}" local action="${1:-}"
case "$action" in case "$action" in
""|help|--help|-h)
usage_queue_daemon
;;
start) start)
if [ -f "$QUEUE_DAEMON_PID_FILE" ]; then if [ -f "$QUEUE_DAEMON_PID_FILE" ]; then
local old_pid=$(cat "$QUEUE_DAEMON_PID_FILE") local old_pid=$(cat "$QUEUE_DAEMON_PID_FILE")
@@ -978,7 +1070,8 @@ cmd_queue_daemon() {
fi fi
;; ;;
*) *)
echo "Usage: kugetsu queue-daemon [start|stop|restart|status|logs]" >&2 echo "Unknown queue-daemon subcommand: $action" >&2
usage_queue_daemon
exit 1 exit 1
;; ;;
esac esac
@@ -1059,10 +1152,12 @@ set_debug_mode() {
} }
cmd_env() { cmd_env() {
local action="${1:-list}" local action="${1:-}"
shift
case "$action" in case "$action" in
""|help|--help|-h)
usage_env
;;
list) list)
echo "Agent environment variables:" echo "Agent environment variables:"
if [ -d "$ENV_DIR" ]; then if [ -d "$ENV_DIR" ]; then
@@ -1080,7 +1175,7 @@ cmd_env() {
fi fi
;; ;;
get) get)
local key="${1:-}" local key="${2:-}"
if [ -z "$key" ]; then if [ -z "$key" ]; then
echo "Usage: kugetsu env get <key>" >&2 echo "Usage: kugetsu env get <key>" >&2
exit 1 exit 1
@@ -1095,8 +1190,8 @@ cmd_env() {
fi fi
;; ;;
set) set)
local key="${1:-}" local key="${2:-}"
local value="${2:-}" local value="${3:-}"
if [ -z "$key" ] || [ -z "$value" ]; then if [ -z "$key" ] || [ -z "$value" ]; then
echo "Usage: kugetsu env set <key> <value>" >&2 echo "Usage: kugetsu env set <key> <value>" >&2
exit 1 exit 1
@@ -1105,8 +1200,8 @@ cmd_env() {
echo "${key}=${value}" >> "$ENV_DIR/default.env" echo "${key}=${value}" >> "$ENV_DIR/default.env"
echo "Set $key in $ENV_DIR/default.env" echo "Set $key in $ENV_DIR/default.env"
;; ;;
rm) rm|remove)
local key="${1:-}" local key="${2:-}"
if [ -z "$key" ]; then if [ -z "$key" ]; then
echo "Usage: kugetsu env rm <key>" >&2 echo "Usage: kugetsu env rm <key>" >&2
exit 1 exit 1
@@ -1117,7 +1212,8 @@ cmd_env() {
fi fi
;; ;;
*) *)
echo "Usage: kugetsu env [list|get|set|rm]" >&2 echo "Unknown env subcommand: $action" >&2
usage_env
exit 1 exit 1
;; ;;
esac esac
@@ -1127,7 +1223,10 @@ cmd_server() {
local action="${1:-}" local action="${1:-}"
case "$action" in case "$action" in
""|"list") ""|help|--help|-h)
usage_server
;;
"list")
if [ -z "${GIT_SERVERS+x}" ]; then if [ -z "${GIT_SERVERS+x}" ]; then
echo "No git servers configured" echo "No git servers configured"
return return
@@ -1204,14 +1303,8 @@ cmd_server() {
fi fi
;; ;;
*) *)
echo "Usage: kugetsu server <list|add|remove|default|get>" >&2 echo "Unknown server subcommand: $action" >&2
echo "" >&2 usage_server
echo "Commands:" >&2
echo " list List all configured git servers" >&2
echo " add <name> <url> Add a new git server" >&2
echo " remove <name> Remove a git server" >&2
echo " default [<name>] Get or set default server" >&2
echo " get [<name>] Get URL for a server (default: current default)" >&2
exit 1 exit 1
;; ;;
esac esac
@@ -1321,8 +1414,30 @@ main() {
case "$command" in case "$command" in
help|--help|-h) help|--help|-h)
local subcommand="${1:-}"
case "$subcommand" in
queue|"")
usage_queue
;;
queue-daemon)
usage_queue_daemon
;;
env)
usage_env
;;
server)
usage_server
;;
"")
usage usage
;; ;;
*)
echo "Help not available for '$subcommand'" >&2
usage
exit 1
;;
esac
;;
init) init)
cmd_init "$@" cmd_init "$@"
;; ;;