Compare commits
4
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
2565d45bb5
|
||
|
|
f4a06cdc44
|
||
|
|
75bfe77950
|
||
|
|
ca42d69704
|
@@ -42,6 +42,10 @@ Code ждёт меня прямо сейчас?**
|
|||||||
текстом `«Claude needs your permission»`. Различить их можно было бы только через
|
текстом `«Claude needs your permission»`. Различить их можно было бы только через
|
||||||
`PreToolUse` — ценой записи файла на каждый вызов инструмента.
|
`PreToolUse` — ценой записи файла на каждый вызов инструмента.
|
||||||
|
|
||||||
|
Чипов показывается три (настраивается), остальные сворачиваются в `+N`. Панель
|
||||||
|
живёт в центральном боксе рядом с часами, и без предела достаточно открытых
|
||||||
|
сессий сдвинули бы часы с центра.
|
||||||
|
|
||||||
Чипы идут по срочности, а внутри одного состояния первой стоит **самая
|
Чипы идут по срочности, а внутри одного состояния первой стоит **самая
|
||||||
давняя**: забывается та, что ждёт дольше всех, а не последняя. Время в
|
давняя**: забывается та, что ждёт дольше всех, а не последняя. Время в
|
||||||
состоянии показывается только у первого чипа: пять счётчиков рядом — это
|
состоянии показывается только у первого чипа: пять счётчиков рядом — это
|
||||||
@@ -178,31 +182,62 @@ gnome-extensions enable claude-code-status@git.vakhrushev.me
|
|||||||
|
|
||||||
## zellij
|
## zellij
|
||||||
|
|
||||||
Если сессии живут в табах zellij, меню показывает **имя таба**, а клик
|
Если сессии живут в табах zellij, меню называет **имя таба** — это лучший ответ
|
||||||
переключает на него. Поиск идёт через `zellij action dump-layout` — рабочий
|
на «в какой терминал идти», чем путь. Поиск идёт через `zellij action
|
||||||
каталог сессии сопоставляется с каталогами пейнов, потому что в дампе раскладки
|
dump-layout`: рабочий каталог сессии сопоставляется с каталогами пейнов, потому
|
||||||
нет id пейнов и `ZELLIJ_PANE_ID` для этого не годится. Отсюда следствия: две
|
что в дампе раскладки нет id пейнов и `ZELLIJ_PANE_ID` для этого не годится.
|
||||||
сессии в одном табе неразличимы, а сессия, сменившая `cwd` после открытия пейна,
|
Отсюда следствия: две сессии в одном табе неразличимы, а сессия, сменившая
|
||||||
не найдётся. Строки, которые не разрешились, остаются некликабельными — вместо
|
`cwd` после открытия пейна, не найдётся.
|
||||||
того чтобы делать вид, будто клик что-то делает.
|
|
||||||
|
Меню **ничего не делает** — только показывает. Ни строки, ни чипы не кликабельны:
|
||||||
|
переключение таба и подъём окна были написаны и убраны, потому что стоили заметной
|
||||||
|
логики (окна gnome-terminal нельзя сопоставить по pid — все они под одним
|
||||||
|
серверным процессом) ради экономии одного alt-tab.
|
||||||
|
|
||||||
Если zellij не используется, выключите в настройках: он стоит одного процесса
|
Если zellij не используется, выключите в настройках: он стоит одного процесса
|
||||||
раз в пару минут.
|
раз в пару минут.
|
||||||
|
|
||||||
|
## Аварийное завершение
|
||||||
|
|
||||||
|
`kill`, закрытое окно, перезагрузка — `SessionEnd` не приходит, и файл остаётся.
|
||||||
|
Разбор завалов проверен на каждом случае отдельно:
|
||||||
|
|
||||||
|
| Что осталось | Что с этим происходит |
|
||||||
|
|---|---|
|
||||||
|
| файл убитой сессии | процесса нет — файл и его `.lock` удаляются в пределах 20 с |
|
||||||
|
| файл из прошлой загрузки | pid сверяется по времени старта процесса, а не только по наличию |
|
||||||
|
| оборванная запись хука (`.tmp`) | удаляется, когда старше пяти минут |
|
||||||
|
| незакрытый `flock` | ядро снимает блокировку при смерти процесса — тупика не бывает |
|
||||||
|
|
||||||
|
Сверка по времени старта — не перестраховка. Файлы состояния переживают
|
||||||
|
перезагрузку, а pid после неё раздаются заново: проверка «есть ли `/proc/<pid>`»
|
||||||
|
отвечает лишь «какой-то процесс с таким номером есть». Без этой сверки сессия,
|
||||||
|
погибшая в аварии, висела бы в панели вечно, требуя ответа, которого некому дать.
|
||||||
|
Проверено подстановкой постороннего живого процесса на тот же pid.
|
||||||
|
|
||||||
|
Порог в пять минут для `.tmp` тоже осмысленный: хук может писать такой файл
|
||||||
|
прямо сейчас, и удаление свежего стоило бы потерянной записи.
|
||||||
|
|
||||||
|
Опознание самого процесса claude — отдельная тонкость. Хук запускается как
|
||||||
|
`/bin/sh -c /…/claude-status-hook.py`, поэтому в командной строке его родителя
|
||||||
|
слово «claude» **есть**, а сам он — не claude и живёт миллисекунды. Поэтому
|
||||||
|
совпадение ищется по отдельным аргументам (`argv[0]` называется `claude`, либо
|
||||||
|
`cli.js` внутри пути с `claude`), а не по строке целиком. Если опознать не
|
||||||
|
удалось, пишется pid 0.
|
||||||
|
|
||||||
|
Найденный pid сверяется на **каждом** событии, а не только при записи: сессия,
|
||||||
|
поднятая через `--resume`, получает новый pid, и без этой сверки файл сохранял бы
|
||||||
|
старый до ближайшей смены состояния — а читатель, не найдя того процесса, убрал бы
|
||||||
|
живую сессию из панели.
|
||||||
|
|
||||||
|
Если хук вообще не смог опознать процесс claude, он пишет pid 0 — «неизвестно»,
|
||||||
|
что никогда не путается с «мёртв»; такие записи истекают по возрасту, через
|
||||||
|
36 часов.
|
||||||
|
|
||||||
## Известные шероховатости
|
## Известные шероховатости
|
||||||
|
|
||||||
- **Протухшие сессии.** Убитый терминал не присылает `SessionEnd`. Живость
|
|
||||||
перепроверяется каждые 20 с по `/proc/<pid>`, файл удаляется — убитая сессия
|
|
||||||
исчезает в пределах этого окна, а не висит вечно. Если хук вообще не смог
|
|
||||||
опознать процесс claude, он записывает pid 0 — «неизвестно», что никогда не
|
|
||||||
путается с «мёртв», — и такие записи истекают по возрасту, через 36 часов.
|
|
||||||
- **`Stop` не отличает «закончил» от «сдался».** Оба читаются как «ждёт ввода»,
|
- **`Stop` не отличает «закончил» от «сдался».** Оба читаются как «ждёт ввода»,
|
||||||
и решение для вас в обоих случаях одно и то же.
|
и решение для вас в обоих случаях одно и то же.
|
||||||
- **Фокус ведёт к табу zellij, а не к окну.** gnome-terminal держит все окна под
|
|
||||||
одним общим серверным процессом, так что окно нельзя сопоставить по pid. Окно
|
|
||||||
поднимается, только если в его заголовке есть имя zellij-сессии; когда
|
|
||||||
совпадения нет, таб всё равно переключается, а фокус остаётся на месте —
|
|
||||||
поднять произвольный терминал хуже, чем не поднимать никакой.
|
|
||||||
|
|
||||||
## Тесты
|
## Тесты
|
||||||
|
|
||||||
@@ -225,5 +260,16 @@ tests/test-hook.sh # события -> состояния, бло
|
|||||||
будет дописываться в него:
|
будет дописываться в него:
|
||||||
|
|
||||||
```sh
|
```sh
|
||||||
touch ~/.local/state/claude-code-status/debug
|
touch ~/.local/state/claude-code-status/debug # включить
|
||||||
|
rm ~/.local/state/claude-code-status/debug # выключить
|
||||||
```
|
```
|
||||||
|
|
||||||
|
**Он пишет много лишнего о вас.** В лог попадают тексты ваших запросов целиком,
|
||||||
|
пути к транскриптам и командные строки шести процессов-предков — включая то, как
|
||||||
|
запущен claude, и адрес сокета zellij. Это диагностический инструмент, а не
|
||||||
|
телеметрия: включайте, когда что-то сломалось, и удаляйте файл после. Рост
|
||||||
|
ограничен восемью мегабайтами, дальше запись прекращается.
|
||||||
|
|
||||||
|
Сборка через `gnome-extensions pack` обязательна: `schemas/gschemas.compiled` не
|
||||||
|
хранится в репозитории, и zip, собранный вручную из чекаута, оставит расширение
|
||||||
|
без схемы настроек.
|
||||||
|
|||||||
+197
-39
@@ -21,6 +21,7 @@ Design notes that are easy to get wrong:
|
|||||||
* No stdlib import beyond what is needed: this runs once per tool call.
|
* No stdlib import beyond what is needed: this runs once per tool call.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
|
import errno
|
||||||
import fcntl
|
import fcntl
|
||||||
import json
|
import json
|
||||||
import os
|
import os
|
||||||
@@ -52,6 +53,36 @@ NOTIFICATION_STATES = {
|
|||||||
# inflate the count with TaskCreate, TaskUpdate and the like.
|
# inflate the count with TaskCreate, TaskUpdate and the like.
|
||||||
AGENT_TOOLS = {"Agent", "Task"}
|
AGENT_TOOLS = {"Agent", "Task"}
|
||||||
|
|
||||||
|
# Events that mean the question has been dealt with. Anything else leaves a
|
||||||
|
# "blocked" session blocked: a subagent finishing, or the next tool starting,
|
||||||
|
# says nothing about the prompt still sitting on your screen, and clearing it
|
||||||
|
# would hide the one state this indicator exists to surface.
|
||||||
|
BLOCK_CLEARING = {"PostToolUse", "UserPromptSubmit", "Stop", "SessionStart"}
|
||||||
|
|
||||||
|
# Nothing here is displayed at full length, and both ends of the pipe have to
|
||||||
|
# survive a hostile or merely absurd value: a multi-megabyte cwd would be copied
|
||||||
|
# into the state file, read back by the compositor and handed to Pango.
|
||||||
|
MAX_TEXT = 512
|
||||||
|
# A stored timestamp further ahead than this is not a concurrent write, it is
|
||||||
|
# corruption -- and left alone it would refuse every later event forever,
|
||||||
|
# freezing the session's displayed state for good.
|
||||||
|
FUTURE_SLACK = 60 # seconds
|
||||||
|
|
||||||
|
|
||||||
|
def number(value, default=0):
|
||||||
|
"""Coerce a value read back from disk. Files are ordinary user-writable
|
||||||
|
JSON: one corrupt field must not take the hook down for every session."""
|
||||||
|
try:
|
||||||
|
n = float(value)
|
||||||
|
except (TypeError, ValueError):
|
||||||
|
return default
|
||||||
|
return default if n != n or n in (float("inf"), float("-inf")) else n
|
||||||
|
|
||||||
|
|
||||||
|
def clip(value):
|
||||||
|
text = value if isinstance(value, str) else ""
|
||||||
|
return text[:MAX_TEXT]
|
||||||
|
|
||||||
EVENT_STATES = {
|
EVENT_STATES = {
|
||||||
# A session that has just opened is waiting for your first prompt, which is
|
# A session that has just opened is waiting for your first prompt, which is
|
||||||
# the same thing as one that has finished a turn: the input line is free
|
# the same thing as one that has finished a turn: the input line is free
|
||||||
@@ -74,11 +105,23 @@ def debug_log(event):
|
|||||||
environment, which cannot be changed without restarting the session.
|
environment, which cannot be changed without restarting the session.
|
||||||
"""
|
"""
|
||||||
marker = os.path.join(STATE_DIR, "debug")
|
marker = os.path.join(STATE_DIR, "debug")
|
||||||
if not os.path.exists(marker):
|
try:
|
||||||
|
# Not followed through a symlink, and not grown without limit: this
|
||||||
|
# records prompts verbatim and the command lines of ancestor processes.
|
||||||
|
if os.lstat(marker).st_size > 8 << 20:
|
||||||
|
return
|
||||||
|
except OSError:
|
||||||
return
|
return
|
||||||
try:
|
try:
|
||||||
with open(marker, "a") as fh:
|
fd = os.open(marker, os.O_WRONLY | os.O_APPEND | os.O_NOFOLLOW)
|
||||||
stamped = dict(event, _at=time.strftime("%H:%M:%S"))
|
with os.fdopen(fd, "a") as fh:
|
||||||
|
chain, pid = [], os.getppid()
|
||||||
|
for _ in range(6):
|
||||||
|
if pid <= 1:
|
||||||
|
break
|
||||||
|
chain.append("%d %s" % (pid, read_cmdline(pid)[:90]))
|
||||||
|
pid = parent_of(pid)
|
||||||
|
stamped = dict(event, _at=time.strftime("%H:%M:%S"), _ancestry=chain)
|
||||||
fh.write(json.dumps(stamped, sort_keys=True)[:2000] + "\n")
|
fh.write(json.dumps(stamped, sort_keys=True)[:2000] + "\n")
|
||||||
except OSError:
|
except OSError:
|
||||||
pass
|
pass
|
||||||
@@ -145,32 +188,78 @@ def parent_of(pid):
|
|||||||
return 0
|
return 0
|
||||||
|
|
||||||
|
|
||||||
|
def looks_like_claude(cmdline):
|
||||||
|
"""Is this command line the claude binary itself?
|
||||||
|
|
||||||
|
Matched per argument, never against the raw string. The hook is spawned as
|
||||||
|
`/bin/sh -c /.../claude-status-hook.py`, so its parent's command line
|
||||||
|
contains the word "claude" -- in a path -- without being claude at all.
|
||||||
|
Latching onto that shell records a pid that exits milliseconds later, and
|
||||||
|
the session then flickers in and out of the panel.
|
||||||
|
"""
|
||||||
|
for token in cmdline.split(" "):
|
||||||
|
if not token:
|
||||||
|
continue
|
||||||
|
base = os.path.basename(token)
|
||||||
|
if base == "claude":
|
||||||
|
return True
|
||||||
|
# npm-style install: node /path/to/claude-code/cli.js
|
||||||
|
if base == "cli.js" and "claude" in token:
|
||||||
|
return True
|
||||||
|
return False
|
||||||
|
|
||||||
|
|
||||||
def find_claude_pid():
|
def find_claude_pid():
|
||||||
"""Nearest ancestor that is the claude process itself, or 0 if unknown.
|
"""Nearest ancestor that is the claude process itself, or 0 if unknown.
|
||||||
|
|
||||||
The hook is spawned through a shell, so the immediate parent is usually not
|
The hook is spawned through a shell, so the immediate parent is not claude.
|
||||||
claude. Walking beyond a handful of levels risks latching onto an outer
|
Walking beyond a handful of levels risks latching onto an outer claude when
|
||||||
claude when one session drives another, so the search stops early.
|
one session drives another, so the search stops early.
|
||||||
|
|
||||||
Returning 0 rather than guessing matters: the reader deletes state files
|
Returning 0 rather than guessing matters: the reader deletes state files
|
||||||
whose pid is gone, and the obvious fallback -- the shell that spawned this
|
whose process is gone, and the obvious fallback -- the shell that spawned
|
||||||
hook -- exits milliseconds later, which would make the session flicker in
|
this hook -- exits immediately.
|
||||||
and out of the panel forever.
|
|
||||||
"""
|
"""
|
||||||
pid = os.getppid()
|
pid = os.getppid()
|
||||||
for _ in range(6):
|
for _ in range(6):
|
||||||
if pid <= 1:
|
if pid <= 1:
|
||||||
break
|
break
|
||||||
# Matched anywhere in the command line, not just argv[0]: installs that
|
if looks_like_claude(read_cmdline(pid)):
|
||||||
# run it as `node .../claude/cli.js` are just as valid as a direct one.
|
|
||||||
if "claude" in read_cmdline(pid):
|
|
||||||
return pid
|
return pid
|
||||||
pid = parent_of(pid)
|
pid = parent_of(pid)
|
||||||
return 0
|
return 0
|
||||||
|
|
||||||
|
|
||||||
def alive(pid):
|
def pid_start_time(pid):
|
||||||
return pid > 0 and os.path.exists("/proc/%d" % pid)
|
"""Field 22 of /proc/<pid>/stat: when the process started, in clock ticks.
|
||||||
|
|
||||||
|
Pins a pid to one particular process. Pids are reused, and state files
|
||||||
|
outlive reboots -- without this, a file left by a crashed session whose pid
|
||||||
|
is later handed to something unrelated reads as a live session forever.
|
||||||
|
"""
|
||||||
|
try:
|
||||||
|
with open("/proc/%d/stat" % pid) as fh:
|
||||||
|
data = fh.read()
|
||||||
|
except OSError:
|
||||||
|
return 0
|
||||||
|
# Field 2 is the command name, parenthesised, and may itself contain spaces
|
||||||
|
# and a ')'. Everything after the last ')' is field 3 onwards.
|
||||||
|
tail = data[data.rfind(")") + 2:].split()
|
||||||
|
try:
|
||||||
|
return int(tail[19])
|
||||||
|
except (IndexError, ValueError):
|
||||||
|
return 0
|
||||||
|
|
||||||
|
|
||||||
|
def alive(pid, start=0):
|
||||||
|
"""Is that pid still the process it was? Inputs come from disk, so both
|
||||||
|
arguments are coerced rather than trusted."""
|
||||||
|
pid = int(number(pid))
|
||||||
|
if pid <= 0 or not os.path.exists("/proc/%d" % pid):
|
||||||
|
return False
|
||||||
|
# A file written before start times were recorded has nothing to compare.
|
||||||
|
start = number(start)
|
||||||
|
return not start or pid_start_time(pid) == start
|
||||||
|
|
||||||
|
|
||||||
def sweep_dead(keep):
|
def sweep_dead(keep):
|
||||||
@@ -190,12 +279,21 @@ def sweep_dead(keep):
|
|||||||
path = os.path.join(STATE_DIR, name)
|
path = os.path.join(STATE_DIR, name)
|
||||||
try:
|
try:
|
||||||
with open(path, "r") as fh:
|
with open(path, "r") as fh:
|
||||||
pid = json.load(fh).get("pid", 0)
|
stale = json.load(fh)
|
||||||
|
if not isinstance(stale, dict):
|
||||||
|
continue
|
||||||
|
pid = stale.get("pid", 0)
|
||||||
except (OSError, ValueError, AttributeError):
|
except (OSError, ValueError, AttributeError):
|
||||||
continue
|
continue
|
||||||
|
except Exception:
|
||||||
|
# One unreadable file must not abort the sweep, and above all must
|
||||||
|
# not abort the caller: this runs before the hook writes its own
|
||||||
|
# state, so an exception here would stop new sessions appearing at
|
||||||
|
# all, for as long as the bad file sits there.
|
||||||
|
continue
|
||||||
# pid 0 means the hook could not identify the process; there is nothing
|
# pid 0 means the hook could not identify the process; there is nothing
|
||||||
# to test for liveness, so leave it to the reader's age cutoff.
|
# to test for liveness, so leave it to the reader's age cutoff.
|
||||||
if pid and not alive(pid):
|
if pid and not alive(pid, stale.get("pid_start", 0)):
|
||||||
for victim in (path, path + ".lock"):
|
for victim in (path, path + ".lock"):
|
||||||
try:
|
try:
|
||||||
os.unlink(victim)
|
os.unlink(victim)
|
||||||
@@ -210,6 +308,22 @@ def write_atomic(path, payload):
|
|||||||
os.replace(tmp, path)
|
os.replace(tmp, path)
|
||||||
|
|
||||||
|
|
||||||
|
def open_lock(path):
|
||||||
|
"""Open the lock file without following a symlink.
|
||||||
|
|
||||||
|
A plain open() on a symlinked lock path truncates whatever it points at.
|
||||||
|
Nothing is escalated by that on a single-user machine, but a status
|
||||||
|
indicator has no business truncating files it was pointed at.
|
||||||
|
"""
|
||||||
|
flags = os.O_RDWR | os.O_CREAT | os.O_NOFOLLOW
|
||||||
|
try:
|
||||||
|
return os.fdopen(os.open(path, flags, 0o600), "r+")
|
||||||
|
except OSError as exc:
|
||||||
|
if exc.errno in (errno.ELOOP, errno.EMLINK):
|
||||||
|
return None
|
||||||
|
raise
|
||||||
|
|
||||||
|
|
||||||
def apply_event(event, state, path, now):
|
def apply_event(event, state, path, now):
|
||||||
"""Read the current state, decide, and write. Must run under the lock."""
|
"""Read the current state, decide, and write. Must run under the lock."""
|
||||||
if event.get("hook_event_name") == "SessionStart":
|
if event.get("hook_event_name") == "SessionStart":
|
||||||
@@ -219,9 +333,11 @@ def apply_event(event, state, path, now):
|
|||||||
sweep_dead(keep=os.path.basename(path))
|
sweep_dead(keep=os.path.basename(path))
|
||||||
|
|
||||||
if state == "end":
|
if state == "end":
|
||||||
for victim in (path, path + ".lock"):
|
# Only the state file. Unlinking the lock while holding it drops mutual
|
||||||
|
# exclusion -- a hook already blocked on the old inode and one that
|
||||||
|
# creates a new file are then both inside the critical section.
|
||||||
try:
|
try:
|
||||||
os.unlink(victim)
|
os.unlink(path)
|
||||||
except OSError:
|
except OSError:
|
||||||
pass
|
pass
|
||||||
return
|
return
|
||||||
@@ -238,76 +354,115 @@ def apply_event(event, state, path, now):
|
|||||||
# Normalised here so the comparison below is against what would actually be
|
# Normalised here so the comparison below is against what would actually be
|
||||||
# stored: comparing a stored "" to a raw notification message rewrites the
|
# stored: comparing a stored "" to a raw notification message rewrites the
|
||||||
# file on every idle_prompt for no change at all.
|
# file on every idle_prompt for no change at all.
|
||||||
message = event.get("message", "") if state == "blocked" else ""
|
message = clip(event.get("message", "")) if state == "blocked" else ""
|
||||||
|
|
||||||
name = event.get("hook_event_name")
|
name = event.get("hook_event_name")
|
||||||
agents = int(previous.get("agents", 0)) if previous else 0
|
agents = int(number(previous.get("agents"))) if previous else 0
|
||||||
|
agents = max(0, min(agents, 999))
|
||||||
# Whether the main agent has finished its turn. Tracked separately from the
|
# Whether the main agent has finished its turn. Tracked separately from the
|
||||||
# state because with background subagents both are true at once: the turn is
|
# state because with background subagents both are true at once: the turn is
|
||||||
# over and work is still running.
|
# over and work is still running.
|
||||||
stopped = bool(previous.get("stopped")) if previous else False
|
stopped = bool(previous.get("stopped")) if previous else False
|
||||||
|
|
||||||
|
# An event that lost a race carries an older timestamp than what is already
|
||||||
|
# stored. Its *state* must not be applied -- that is last-writer-wins, and
|
||||||
|
# replaying an old one would resurrect a state the session has left.
|
||||||
|
previous_ts = number(previous.get("event_ts")) if previous else 0
|
||||||
|
if previous_ts > now + FUTURE_SLACK:
|
||||||
|
previous_ts = 0 # corrupt, and trusting it would freeze this session
|
||||||
|
stale = previous_ts > now
|
||||||
|
|
||||||
|
# The subagent count is different in kind: the mutations are deltas, and
|
||||||
|
# deltas commute, so every one has to land whatever order it arrives in.
|
||||||
|
# Dropping a "+1" because its timestamp lost a race leaves the count one
|
||||||
|
# short, and the batch then frees the session while a subagent is still
|
||||||
|
# running -- the exact failure counting was added to prevent. The timestamps
|
||||||
|
# cannot be trusted for this at all: each is taken when its hook process
|
||||||
|
# starts, tens of milliseconds before it reaches the lock.
|
||||||
if name in ("SessionStart", "UserPromptSubmit"):
|
if name in ("SessionStart", "UserPromptSubmit"):
|
||||||
# A new turn from you starts a new batch. This also bounds the damage
|
# A new turn from you starts a new batch. This also bounds the damage
|
||||||
# when a subagent dies without its SubagentStop ever arriving: the count
|
# when a subagent dies without its SubagentStop ever arriving: the count
|
||||||
# cannot leak past the next thing you type.
|
# cannot leak past the next thing you type.
|
||||||
agents, stopped = 0, False
|
agents = 0
|
||||||
elif name == "PreToolUse":
|
elif name == "PreToolUse":
|
||||||
agents += 1
|
agents += 1
|
||||||
elif name == "SubagentStop":
|
elif name == "SubagentStop":
|
||||||
agents = max(0, agents - 1)
|
agents = max(0, agents - 1)
|
||||||
|
|
||||||
|
if stale:
|
||||||
|
# Keep the stored state and flag; the delta above still gets persisted.
|
||||||
|
state = previous.get("state", state)
|
||||||
|
else:
|
||||||
|
if name in ("SessionStart", "UserPromptSubmit"):
|
||||||
|
stopped = False
|
||||||
elif name == "Stop":
|
elif name == "Stop":
|
||||||
stopped = True
|
stopped = True
|
||||||
elif name == "PostToolUse":
|
elif name == "PostToolUse":
|
||||||
stopped = False
|
stopped = False
|
||||||
|
|
||||||
if name == "SubagentStop":
|
if name == "SubagentStop":
|
||||||
# The last subagent finishing is what finally frees a session whose main
|
# The last subagent finishing is what finally frees a session whose
|
||||||
# agent stopped long ago.
|
# main agent stopped long ago.
|
||||||
state = "waiting" if (stopped and agents == 0) else "busy"
|
state = "waiting" if (stopped and agents == 0) else "busy"
|
||||||
elif state == "waiting" and agents > 0:
|
elif state == "waiting" and agents > 0:
|
||||||
# The turn ended but the batch is still running, and the session will
|
# The turn ended but the batch is still running, and the session
|
||||||
# pick the results up itself. Calling it "waiting" would send you to a
|
# will pick the results up itself. Calling it "waiting" would send
|
||||||
# terminal that does not need you.
|
# you to a terminal that does not need you.
|
||||||
state = "busy"
|
state = "busy"
|
||||||
|
|
||||||
|
# A pending question outlives everything except an answer to it.
|
||||||
|
if (previous and previous.get("state") == "blocked"
|
||||||
|
and state != "blocked" and name not in BLOCK_CLEARING):
|
||||||
|
state = "blocked"
|
||||||
|
message = previous.get("message", "")
|
||||||
|
|
||||||
|
# Resolved before the unchanged-check, not after, so that a pid which has
|
||||||
|
# changed forces a write. A session resumed under a new pid, or one whose
|
||||||
|
# pid was recorded wrongly, would otherwise keep the stale value for as
|
||||||
|
# long as its state happens not to change -- and the reader, finding that
|
||||||
|
# process gone, would drop a perfectly live session from the panel.
|
||||||
|
claude_pid = find_claude_pid()
|
||||||
|
|
||||||
if previous:
|
if previous:
|
||||||
# Auto-compaction raises SessionStart again, in the middle of a turn the
|
# Auto-compaction raises SessionStart again, in the middle of a turn the
|
||||||
# session is still working on. Taking it at face value would flip a busy
|
# session is still working on. Taking it at face value would flip a busy
|
||||||
# session to idle until the next tool call corrected it.
|
# session to waiting until the next tool call corrected it.
|
||||||
if event.get("hook_event_name") == "SessionStart" and event.get("source") == "compact":
|
if event.get("hook_event_name") == "SessionStart" and event.get("source") == "compact":
|
||||||
return
|
return
|
||||||
# Refuse events that lost a race with a newer one.
|
|
||||||
if previous.get("event_ts", 0) > now:
|
|
||||||
return
|
|
||||||
# Nothing new to publish: stay quiet so the directory monitor stays quiet.
|
# Nothing new to publish: stay quiet so the directory monitor stays quiet.
|
||||||
if (previous.get("state") == state
|
if (previous.get("state") == state
|
||||||
and previous.get("message", "") == message
|
and previous.get("message", "") == message
|
||||||
and previous.get("agents", 0) == agents
|
and previous.get("agents", 0) == agents
|
||||||
and bool(previous.get("stopped")) == stopped):
|
and bool(previous.get("stopped")) == stopped
|
||||||
|
and previous.get("pid", 0) == claude_pid):
|
||||||
return
|
return
|
||||||
|
|
||||||
claude_pid = find_claude_pid()
|
|
||||||
env = read_environ(claude_pid) if claude_pid else {}
|
env = read_environ(claude_pid) if claude_pid else {}
|
||||||
|
|
||||||
write_atomic(path, {
|
write_atomic(path, {
|
||||||
"session_id": event.get("session_id"),
|
"session_id": event.get("session_id"),
|
||||||
"state": state,
|
"state": state,
|
||||||
"cwd": event.get("cwd") or "",
|
"cwd": clip(event.get("cwd") or ""),
|
||||||
# Age is measured from the moment the state was entered, not from the
|
# Age is measured from the moment the state was entered, not from the
|
||||||
# last event, so "waiting 40 min" survives unrelated later writes.
|
# last event, so "waiting 40 min" survives unrelated later writes.
|
||||||
"since": previous["since"] if previous and previous.get("state") == state else now,
|
"since": previous["since"] if previous and previous.get("state") == state else now,
|
||||||
"event_ts": now,
|
# When the session itself began, as opposed to when it entered this
|
||||||
|
# state. Seniority between chips is decided on this: a session that
|
||||||
|
# changed state a moment ago has not become the younger of the two.
|
||||||
|
"started": (previous.get("started") if previous else None) or now,
|
||||||
|
"event_ts": max(now, previous_ts),
|
||||||
# 0 means "could not tell"; the reader must not take that for "dead".
|
# 0 means "could not tell"; the reader must not take that for "dead".
|
||||||
"pid": claude_pid,
|
"pid": claude_pid,
|
||||||
|
"pid_start": pid_start_time(claude_pid) if claude_pid else 0,
|
||||||
"event": event.get("hook_event_name", ""),
|
"event": event.get("hook_event_name", ""),
|
||||||
"notification_type": event.get("notification_type", ""),
|
"notification_type": event.get("notification_type", ""),
|
||||||
"message": message,
|
"message": clip(message),
|
||||||
"agents": agents,
|
"agents": agents,
|
||||||
"stopped": stopped,
|
"stopped": stopped,
|
||||||
"zellij_session": env.get("ZELLIJ_SESSION_NAME", ""),
|
# Kept from the previous write when this event could not identify the
|
||||||
"zellij_pane": env.get("ZELLIJ_PANE_ID", ""),
|
# process: a momentary failure should not blank out where the session is.
|
||||||
"transcript": event.get("transcript_path", ""),
|
"zellij_session": clip(env.get("ZELLIJ_SESSION_NAME")
|
||||||
|
or (previous.get("zellij_session", "") if previous else "")),
|
||||||
})
|
})
|
||||||
|
|
||||||
|
|
||||||
@@ -338,7 +493,10 @@ def main():
|
|||||||
# without a lock both processes read the same "previous" and the loser's
|
# without a lock both processes read the same "previous" and the loser's
|
||||||
# write still lands last, pinning a finished session at "busy". The lock is
|
# write still lands last, pinning a finished session at "busy". The lock is
|
||||||
# a separate file because write_atomic replaces the inode of the real one.
|
# a separate file because write_atomic replaces the inode of the real one.
|
||||||
with open(path + ".lock", "w") as lock:
|
lock = open_lock(path + ".lock")
|
||||||
|
if lock is None:
|
||||||
|
return 0
|
||||||
|
with lock:
|
||||||
fcntl.flock(lock, fcntl.LOCK_EX)
|
fcntl.flock(lock, fcntl.LOCK_EX)
|
||||||
apply_event(event, state, path, now)
|
apply_event(event, state, path, now)
|
||||||
return 0
|
return 0
|
||||||
|
|||||||
+27
-4
@@ -11,7 +11,9 @@ Usage: install.py [--uninstall] [--settings PATH]
|
|||||||
|
|
||||||
import json
|
import json
|
||||||
import os
|
import os
|
||||||
|
import shlex
|
||||||
import shutil
|
import shutil
|
||||||
|
import stat
|
||||||
import sys
|
import sys
|
||||||
|
|
||||||
HOOK = os.path.join(os.path.dirname(os.path.abspath(__file__)), "claude-status-hook.py")
|
HOOK = os.path.join(os.path.dirname(os.path.abspath(__file__)), "claude-status-hook.py")
|
||||||
@@ -42,7 +44,9 @@ EVENTS = {
|
|||||||
|
|
||||||
def entry(spec):
|
def entry(spec):
|
||||||
async_, matcher = spec
|
async_, matcher = spec
|
||||||
hook = {"type": "command", "command": HOOK, "timeout": 5}
|
# Claude Code runs the command through a shell, so a repository path
|
||||||
|
# containing a space -- or worse -- has to survive the trip.
|
||||||
|
hook = {"type": "command", "command": shlex.quote(HOOK), "timeout": 5}
|
||||||
if async_:
|
if async_:
|
||||||
hook["async"] = True
|
hook["async"] = True
|
||||||
return {"matcher": matcher, "hooks": [hook]}
|
return {"matcher": matcher, "hooks": [hook]}
|
||||||
@@ -50,7 +54,7 @@ def entry(spec):
|
|||||||
|
|
||||||
def is_ours(group):
|
def is_ours(group):
|
||||||
return any(
|
return any(
|
||||||
h.get("command", "").endswith("claude-status-hook.py")
|
h.get("command", "").rstrip("'\"").endswith("claude-status-hook.py")
|
||||||
for h in group.get("hooks", [])
|
for h in group.get("hooks", [])
|
||||||
if isinstance(h, dict)
|
if isinstance(h, dict)
|
||||||
)
|
)
|
||||||
@@ -60,7 +64,15 @@ def main():
|
|||||||
uninstall = "--uninstall" in sys.argv
|
uninstall = "--uninstall" in sys.argv
|
||||||
path = os.path.expanduser("~/.claude/settings.json")
|
path = os.path.expanduser("~/.claude/settings.json")
|
||||||
if "--settings" in sys.argv:
|
if "--settings" in sys.argv:
|
||||||
|
try:
|
||||||
path = sys.argv[sys.argv.index("--settings") + 1]
|
path = sys.argv[sys.argv.index("--settings") + 1]
|
||||||
|
except IndexError:
|
||||||
|
sys.exit("--settings needs a path")
|
||||||
|
# Written through, not over: a settings.json symlinked out of a dotfiles
|
||||||
|
# repository would otherwise be replaced by a regular file, silently
|
||||||
|
# detaching it from the repository that is supposed to manage it.
|
||||||
|
path = os.path.realpath(path)
|
||||||
|
os.makedirs(os.path.dirname(path), exist_ok=True)
|
||||||
|
|
||||||
try:
|
try:
|
||||||
with open(path) as fh:
|
with open(path) as fh:
|
||||||
@@ -70,8 +82,12 @@ def main():
|
|||||||
except ValueError as exc:
|
except ValueError as exc:
|
||||||
sys.exit("refusing to touch malformed %s: %s" % (path, exc))
|
sys.exit("refusing to touch malformed %s: %s" % (path, exc))
|
||||||
|
|
||||||
if os.path.exists(path):
|
# Kept from the first run only. Overwriting it on every run would, on the
|
||||||
|
# second run, replace the pristine copy with the already-modified one --
|
||||||
|
# which is exactly when someone reaches for a backup.
|
||||||
|
if os.path.exists(path) and not os.path.exists(path + ".bak"):
|
||||||
shutil.copyfile(path, path + ".bak")
|
shutil.copyfile(path, path + ".bak")
|
||||||
|
shutil.copymode(path, path + ".bak")
|
||||||
|
|
||||||
hooks = settings.setdefault("hooks", {})
|
hooks = settings.setdefault("hooks", {})
|
||||||
for event in EVENTS:
|
for event in EVENTS:
|
||||||
@@ -92,10 +108,17 @@ def main():
|
|||||||
with open(tmp, "w") as fh:
|
with open(tmp, "w") as fh:
|
||||||
json.dump(settings, fh, indent=2)
|
json.dump(settings, fh, indent=2)
|
||||||
fh.write("\n")
|
fh.write("\n")
|
||||||
|
# A replace discards the original's mode. settings.json may hold API keys
|
||||||
|
# and may have been deliberately narrowed to 0600; silently widening it to
|
||||||
|
# the umask default would undo that without a word.
|
||||||
|
try:
|
||||||
|
os.chmod(tmp, stat.S_IMODE(os.stat(path).st_mode))
|
||||||
|
except OSError:
|
||||||
|
pass
|
||||||
os.replace(tmp, path)
|
os.replace(tmp, path)
|
||||||
|
|
||||||
print("%s %s in %s" % ("removed" if uninstall else "installed", HOOK, path))
|
print("%s %s in %s" % ("removed" if uninstall else "installed", HOOK, path))
|
||||||
print("restart running claude sessions for the change to take effect")
|
print("running sessions pick this up on their own; no restart needed")
|
||||||
|
|
||||||
|
|
||||||
if __name__ == "__main__":
|
if __name__ == "__main__":
|
||||||
|
|||||||
+5
-2
@@ -13,9 +13,12 @@ const MAX = 3;
|
|||||||
|
|
||||||
/** Split on separators and camelCase humps: "pet-project-server", "outlineMcp". */
|
/** Split on separators and camelCase humps: "pet-project-server", "outlineMcp". */
|
||||||
function segments(name) {
|
function segments(name) {
|
||||||
|
// Unicode-aware: splitting on [^a-zA-Z0-9] makes every Cyrillic letter a
|
||||||
|
// separator, so "проект" reduces to nothing and every non-Latin project
|
||||||
|
// ends up sharing the label "?".
|
||||||
return name
|
return name
|
||||||
.replace(/([a-z0-9])([A-Z])/g, '$1 $2')
|
.replace(/(\p{Ll}|\p{N})(\p{Lu})/gu, '$1 $2')
|
||||||
.split(/[^a-zA-Z0-9]+/)
|
.split(/[^\p{L}\p{N}]+/u)
|
||||||
.filter(Boolean);
|
.filter(Boolean);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -12,7 +12,11 @@ export function formatAge(seconds) {
|
|||||||
if (m < 60)
|
if (m < 60)
|
||||||
return `${m}m`;
|
return `${m}m`;
|
||||||
const h = Math.floor(m / 60);
|
const h = Math.floor(m / 60);
|
||||||
|
if (h < 24)
|
||||||
return `${h}h ${m % 60}m`;
|
return `${h}h ${m % 60}m`;
|
||||||
|
// Days, or a session left over the weekend reads as "120h 0m" and widens
|
||||||
|
// the very row the chip cap exists to keep narrow.
|
||||||
|
return `${Math.floor(h / 24)}d ${h % 24}h`;
|
||||||
}
|
}
|
||||||
|
|
||||||
/** Last path segment, with ~ collapsed. Two worktrees of one repo share a
|
/** Last path segment, with ~ collapsed. Two worktrees of one repo share a
|
||||||
|
|||||||
+4
-4
@@ -1,8 +1,8 @@
|
|||||||
// State glyphs, drawn with cairo alone.
|
// State glyphs, drawn with cairo alone.
|
||||||
//
|
//
|
||||||
// The panel is monochrome, so shape is the only channel left and these four
|
// The panel is monochrome, so shape is the only channel left and the three
|
||||||
// have to stay apart at 14 px. Kept free of St/Clutter/GNOME imports so the
|
// states have to stay apart at 14 px. Kept free of St/Clutter/GNOME imports so
|
||||||
// shapes can be rendered to a file and looked at, rather than guessed about.
|
// the shapes can be rendered to a file and looked at, rather than guessed at.
|
||||||
|
|
||||||
/** Draw `state` filling the given box, in the colour passed as {r,g,b,a} 0..1. */
|
/** Draw `state` filling the given box, in the colour passed as {r,g,b,a} 0..1. */
|
||||||
export function drawState(cr, state, width, height, color) {
|
export function drawState(cr, state, width, height, color) {
|
||||||
@@ -21,7 +21,7 @@ export function drawState(cr, state, width, height, color) {
|
|||||||
|
|
||||||
switch (state) {
|
switch (state) {
|
||||||
case 'blocked':
|
case 'blocked':
|
||||||
// Disc inside a ring: the most ink of the four, for the only state
|
// Disc inside a ring: the most ink of the three, for the only state
|
||||||
// where a session is stuck until you act. The inner disc has to be
|
// where a session is stuck until you act. The inner disc has to be
|
||||||
// big enough to register at 14 px, or this reads as plain "working".
|
// big enough to register at 14 px, or this reads as plain "working".
|
||||||
cr.arc(cx, cy, radius, 0, 2 * Math.PI);
|
cr.arc(cx, cy, radius, 0, 2 * Math.PI);
|
||||||
|
|||||||
+69
-64
@@ -6,7 +6,6 @@ import Clutter from 'gi://Clutter';
|
|||||||
import GLib from 'gi://GLib';
|
import GLib from 'gi://GLib';
|
||||||
import Pango from 'gi://Pango';
|
import Pango from 'gi://Pango';
|
||||||
|
|
||||||
import * as Main from 'resource:///org/gnome/shell/ui/main.js';
|
|
||||||
import * as PanelMenu from 'resource:///org/gnome/shell/ui/panelMenu.js';
|
import * as PanelMenu from 'resource:///org/gnome/shell/ui/panelMenu.js';
|
||||||
import * as PopupMenu from 'resource:///org/gnome/shell/ui/popupMenu.js';
|
import * as PopupMenu from 'resource:///org/gnome/shell/ui/popupMenu.js';
|
||||||
import { gettext as _ } from 'resource:///org/gnome/shell/extensions/extension.js';
|
import { gettext as _ } from 'resource:///org/gnome/shell/extensions/extension.js';
|
||||||
@@ -27,11 +26,6 @@ function stateLabel(state) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
const TERMINAL_CLASSES = [
|
|
||||||
'gnome-terminal', 'org.gnome.terminal', 'kitty', 'alacritty',
|
|
||||||
'foot', 'wezterm', 'konsole', 'xterm', 'ghostty',
|
|
||||||
];
|
|
||||||
|
|
||||||
/** Paint a state glyph in the panel's own text colour.
|
/** Paint a state glyph in the panel's own text colour.
|
||||||
*
|
*
|
||||||
* Nothing here picks a colour: the foreground comes from the theme node, so
|
* Nothing here picks a colour: the foreground comes from the theme node, so
|
||||||
@@ -44,8 +38,13 @@ function drawStateDot(area, state) {
|
|||||||
try {
|
try {
|
||||||
const [w, h] = area.get_surface_size();
|
const [w, h] = area.get_surface_size();
|
||||||
const c = area.get_theme_node().get_foreground_color();
|
const c = area.get_theme_node().get_foreground_color();
|
||||||
|
// Normalised by inspection rather than by assumption: the colour struct
|
||||||
|
// behind this changed between shell versions, and a wrong guess either
|
||||||
|
// way paints the glyph invisible or fully saturated.
|
||||||
|
const scale = Math.max(c.red, c.green, c.blue, c.alpha) > 1 ? 255 : 1;
|
||||||
drawState(cr, state, w, h, {
|
drawState(cr, state, w, h, {
|
||||||
r: c.red / 255, g: c.green / 255, b: c.blue / 255, a: c.alpha / 255,
|
r: c.red / scale, g: c.green / scale,
|
||||||
|
b: c.blue / scale, a: c.alpha / scale,
|
||||||
});
|
});
|
||||||
} finally {
|
} finally {
|
||||||
cr.$dispose();
|
cr.$dispose();
|
||||||
@@ -69,6 +68,12 @@ class ClaudeStatusIndicator extends PanelMenu.Button {
|
|||||||
|
|
||||||
this._changedId = this._store.connect('changed', () => this._update());
|
this._changedId = this._store.connect('changed', () => this._update());
|
||||||
this._settingsChangedId = this._settings.connect('changed', () => this._update());
|
this._settingsChangedId = this._settings.connect('changed', () => this._update());
|
||||||
|
// Connected, not overridden: clutter_actor_destroy is not a vfunc, so a
|
||||||
|
// destroy() override only runs when JS calls it. An actor torn down any
|
||||||
|
// other way -- another extension rebuilding the panel boxes -- would
|
||||||
|
// leave the timer and the file monitor running against a disposed
|
||||||
|
// actor, screaming into the log every 20 seconds.
|
||||||
|
this.connect('destroy', () => this._onDestroy());
|
||||||
this._store.start();
|
this._store.start();
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -101,18 +106,24 @@ class ClaudeStatusIndicator extends PanelMenu.Button {
|
|||||||
style_class: 'ccs-dot',
|
style_class: 'ccs-dot',
|
||||||
y_align: Clutter.ActorAlign.CENTER,
|
y_align: Clutter.ActorAlign.CENTER,
|
||||||
});
|
});
|
||||||
dot.set_width(14);
|
// Size comes from the stylesheet so St scales it: setting it here would
|
||||||
dot.set_height(14);
|
// pin the glyph to physical pixels and halve it on a HiDPI display.
|
||||||
dot.connect('repaint', area => drawStateDot(area, session.state));
|
dot.connect('repaint', area => drawStateDot(area, session.state));
|
||||||
chip.add_child(dot);
|
chip.add_child(dot);
|
||||||
|
|
||||||
let age = null;
|
let age = null;
|
||||||
if (this._settings.get_boolean('show-project-name')) {
|
if (this._settings.get_boolean('show-project-name')) {
|
||||||
chip.add_child(new St.Label({
|
const text = new St.Label({
|
||||||
style_class: 'ccs-chip-label',
|
style_class: 'ccs-chip-label',
|
||||||
y_align: Clutter.ActorAlign.CENTER,
|
y_align: Clutter.ActorAlign.CENTER,
|
||||||
text: label,
|
text: label,
|
||||||
}));
|
});
|
||||||
|
// With shortening off the label is a whole project name, which can
|
||||||
|
// be arbitrarily long: an unbounded label in the panel pushes the
|
||||||
|
// clock aside and, past a point, hands Pango a width it cannot
|
||||||
|
// represent.
|
||||||
|
text.clutter_text.ellipsize = Pango.EllipsizeMode.END;
|
||||||
|
chip.add_child(text);
|
||||||
}
|
}
|
||||||
if (withAge) {
|
if (withAge) {
|
||||||
age = new St.Label({
|
age = new St.Label({
|
||||||
@@ -164,11 +175,15 @@ class ClaudeStatusIndicator extends PanelMenu.Button {
|
|||||||
_updatePanel(sessions) {
|
_updatePanel(sessions) {
|
||||||
const showAge = this._settings.get_boolean('show-age');
|
const showAge = this._settings.get_boolean('show-age');
|
||||||
const abbreviate = this._settings.get_boolean('abbreviate-names');
|
const abbreviate = this._settings.get_boolean('abbreviate-names');
|
||||||
|
const maxChips = this._settings.get_int('max-chips');
|
||||||
|
|
||||||
this._chipLabels = assignChips(
|
this._chipLabels = assignChips(
|
||||||
sessions.map(s => ({
|
sessions.map(s => ({
|
||||||
sessionId: s.sessionId,
|
sessionId: s.sessionId,
|
||||||
since: s.since,
|
// Session age, not time in the current state: seniority decides
|
||||||
|
// who keeps the clean label, and a session that changed state a
|
||||||
|
// second ago has not thereby become the youngest.
|
||||||
|
since: s.started || s.since,
|
||||||
base: projectName(s.cwd),
|
base: projectName(s.cwd),
|
||||||
})),
|
})),
|
||||||
this._chipLabels);
|
this._chipLabels);
|
||||||
@@ -181,28 +196,49 @@ class ClaudeStatusIndicator extends PanelMenu.Button {
|
|||||||
// than sitting there empty.
|
// than sitting there empty.
|
||||||
this.visible = sessions.length > 0;
|
this.visible = sessions.length > 0;
|
||||||
|
|
||||||
|
// Chips are ordered by urgency, so cutting the tail keeps the ones that
|
||||||
|
// need you soonest. Without a cap the row grows without bound, and it
|
||||||
|
// sits in the centre box -- enough sessions would shove the clock off
|
||||||
|
// centre. Labels are still assigned over every session, so the menu and
|
||||||
|
// the panel agree and a chip does not change when the cap does.
|
||||||
|
const shown = sessions.slice(0, maxChips);
|
||||||
|
const hidden = sessions.length - shown.length;
|
||||||
|
|
||||||
// Age rides on the first chip only. Sessions are sorted by urgency, so
|
// Age rides on the first chip only. Sessions are sorted by urgency, so
|
||||||
// that is the one whose age decides anything; five ages side by side
|
// that is the one whose age decides anything; five ages side by side
|
||||||
// would just be a wide row of numbers.
|
// would just be a wide row of numbers.
|
||||||
const ageOnFirst = showAge && sessions.length > 0;
|
const ageOnFirst = showAge && shown.length > 0;
|
||||||
const signature = sessions
|
const signature = shown
|
||||||
.map(s => `${s.sessionId}:${s.state}:${labelFor(s)}`)
|
.map(s => `${s.sessionId}:${s.state}:${labelFor(s)}`)
|
||||||
.join('|') + `|${ageOnFirst}`;
|
.join('|') + `|${ageOnFirst}|${hidden}`;
|
||||||
if (signature !== this._chipSignature) {
|
if (signature !== this._chipSignature) {
|
||||||
this._chipBox.destroy_all_children();
|
this._chipBox.destroy_all_children();
|
||||||
this._ageLabel = null;
|
this._ageLabel = null;
|
||||||
sessions.forEach((session, i) => {
|
shown.forEach((session, i) => {
|
||||||
const { chip, age } = this._buildChip(
|
const { chip, age } = this._buildChip(
|
||||||
session, labelFor(session), ageOnFirst && i === 0);
|
session, labelFor(session), ageOnFirst && i === 0);
|
||||||
if (age)
|
if (age)
|
||||||
this._ageLabel = { age, session };
|
this._ageLabel = { age, sessionId: session.sessionId };
|
||||||
this._chipBox.add_child(chip);
|
this._chipBox.add_child(chip);
|
||||||
});
|
});
|
||||||
|
if (hidden > 0) {
|
||||||
|
this._chipBox.add_child(new St.Label({
|
||||||
|
style_class: 'ccs-overflow',
|
||||||
|
y_align: Clutter.ActorAlign.CENTER,
|
||||||
|
text: `+${hidden}`,
|
||||||
|
}));
|
||||||
|
}
|
||||||
this._chipSignature = signature;
|
this._chipSignature = signature;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (this._ageLabel)
|
if (this._ageLabel) {
|
||||||
this._ageLabel.age.text = formatAge(this._ageOf(this._ageLabel.session));
|
// Looked up again rather than captured: a session that returns to
|
||||||
|
// the same state within one refresh keeps the signature unchanged,
|
||||||
|
// and a captured object would then show an age that stopped moving.
|
||||||
|
const current = sessions.find(s => s.sessionId === this._ageLabel.sessionId);
|
||||||
|
if (current)
|
||||||
|
this._ageLabel.age.text = formatAge(this._ageOf(current));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
_updateMenu(sessions) {
|
_updateMenu(sessions) {
|
||||||
@@ -210,15 +246,18 @@ class ClaudeStatusIndicator extends PanelMenu.Button {
|
|||||||
|
|
||||||
// Rebuild only when the set of sessions or their states changed; ages
|
// Rebuild only when the set of sessions or their states changed; ages
|
||||||
// alone are refreshed in place so an open menu does not flicker.
|
// alone are refreshed in place so an open menu does not flicker.
|
||||||
|
// The tab name is not in the signature: it only feeds the subtitle,
|
||||||
|
// which is refreshed in place below.
|
||||||
const signature = sessions
|
const signature = sessions
|
||||||
.map(s => `${s.sessionId}:${s.state}:${this._tabFor(s) ?? ''}:${this._chipLabels?.get(s.sessionId) ?? ''}`)
|
.map(s => `${s.sessionId}:${s.state}:${this._chipLabels?.get(s.sessionId) ?? ''}`)
|
||||||
.join('|');
|
.join('|');
|
||||||
if (signature !== this._rowSignature) {
|
if (signature !== this._rowSignature) {
|
||||||
this._rebuildRows(sessions);
|
this._rebuildRows(sessions);
|
||||||
this._rowSignature = signature;
|
this._rowSignature = signature;
|
||||||
}
|
}
|
||||||
|
const byId = new Map(sessions.map(s => [s.sessionId, s]));
|
||||||
for (const row of this._rows) {
|
for (const row of this._rows) {
|
||||||
const session = sessions.find(s => s.sessionId === row.sessionId);
|
const session = byId.get(row.sessionId);
|
||||||
if (!session)
|
if (!session)
|
||||||
continue;
|
continue;
|
||||||
row.age.text = formatAge(this._ageOf(session));
|
row.age.text = formatAge(this._ageOf(session));
|
||||||
@@ -259,13 +298,12 @@ class ClaudeStatusIndicator extends PanelMenu.Button {
|
|||||||
}
|
}
|
||||||
|
|
||||||
_buildRow(session) {
|
_buildRow(session) {
|
||||||
const tab = this._tabFor(session);
|
// The menu reports; it does not act. Rows are built inert rather than
|
||||||
// Reactivity is decided at construction, not patched afterwards:
|
// switched off afterwards, because PopupBaseMenuItem latches
|
||||||
// PopupBaseMenuItem latches _activatable in its constructor, so a row
|
// _activatable in its constructor and a row demoted later keeps the
|
||||||
// switched to reactive=false later keeps the styling of a clickable one
|
// styling of a clickable one.
|
||||||
// and still looks like it does something.
|
|
||||||
const item = new PopupMenu.PopupBaseMenuItem(
|
const item = new PopupMenu.PopupBaseMenuItem(
|
||||||
tab ? {} : { reactive: false, can_focus: false });
|
{ reactive: false, can_focus: false });
|
||||||
item.add_style_class_name('ccs-row');
|
item.add_style_class_name('ccs-row');
|
||||||
|
|
||||||
const column = new St.BoxLayout({ vertical: true, x_expand: true });
|
const column = new St.BoxLayout({ vertical: true, x_expand: true });
|
||||||
@@ -277,6 +315,7 @@ class ClaudeStatusIndicator extends PanelMenu.Button {
|
|||||||
style_class: `ccs-row-title ccs-${session.state}`,
|
style_class: `ccs-row-title ccs-${session.state}`,
|
||||||
x_expand: true,
|
x_expand: true,
|
||||||
});
|
});
|
||||||
|
title.clutter_text.ellipsize = Pango.EllipsizeMode.END;
|
||||||
const age = new St.Label({
|
const age = new St.Label({
|
||||||
text: formatAge(this._ageOf(session)),
|
text: formatAge(this._ageOf(session)),
|
||||||
style_class: 'ccs-row-age',
|
style_class: 'ccs-row-age',
|
||||||
@@ -296,9 +335,6 @@ class ClaudeStatusIndicator extends PanelMenu.Button {
|
|||||||
column.add_child(subtitle);
|
column.add_child(subtitle);
|
||||||
item.add_child(column);
|
item.add_child(column);
|
||||||
|
|
||||||
if (tab)
|
|
||||||
item.connect('activate', () => this._switchTo(session, tab));
|
|
||||||
|
|
||||||
this._rows.push({ sessionId: session.sessionId, age, subtitle });
|
this._rows.push({ sessionId: session.sessionId, age, subtitle });
|
||||||
return item;
|
return item;
|
||||||
}
|
}
|
||||||
@@ -360,41 +396,11 @@ class ClaudeStatusIndicator extends PanelMenu.Button {
|
|||||||
.catch(e => logError(e, 'claude-code-status: zellij refresh failed'));
|
.catch(e => logError(e, 'claude-code-status: zellij refresh failed'));
|
||||||
}
|
}
|
||||||
|
|
||||||
_switchTo(session, tab) {
|
|
||||||
this._zellij.goToTab(session.zellijSession, tab);
|
|
||||||
this._focusTerminal(session);
|
|
||||||
}
|
|
||||||
|
|
||||||
/** Best effort: raise a terminal window showing this zellij session.
|
|
||||||
*
|
|
||||||
* Matching by pid does not work for gnome-terminal, where every window
|
|
||||||
* belongs to one shared server process, so the window title is the only
|
|
||||||
* handle available -- and zellij puts the session name there.
|
|
||||||
*/
|
|
||||||
_focusTerminal(session) {
|
|
||||||
if (!session.zellijSession)
|
|
||||||
return;
|
|
||||||
// list_all_windows() rather than get_window_actors(): the latter is
|
|
||||||
// deprecated from GNOME 46 on, and this has to work across 45-48.
|
|
||||||
for (const win of global.display.list_all_windows()) {
|
|
||||||
const wmClass = (win.get_wm_class() ?? '').toLowerCase();
|
|
||||||
if (!TERMINAL_CLASSES.some(c => wmClass.includes(c)))
|
|
||||||
continue;
|
|
||||||
// Only a window that names this zellij session is raised. Falling
|
|
||||||
// back to any terminal at all would raise an unrelated one, which
|
|
||||||
// is worse than leaving focus where the user put it.
|
|
||||||
if ((win.get_title() ?? '').includes(session.zellijSession)) {
|
|
||||||
Main.activateWindow(win);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// ---- Visuals --------------------------------------------------------
|
|
||||||
|
|
||||||
// ---- Teardown -------------------------------------------------------
|
// ---- Teardown -------------------------------------------------------
|
||||||
|
|
||||||
destroy() {
|
_onDestroy() {
|
||||||
|
if (this._destroyed)
|
||||||
|
return;
|
||||||
this._destroyed = true;
|
this._destroyed = true;
|
||||||
this._zellij.destroy();
|
this._zellij.destroy();
|
||||||
if (this._changedId) {
|
if (this._changedId) {
|
||||||
@@ -406,6 +412,5 @@ class ClaudeStatusIndicator extends PanelMenu.Button {
|
|||||||
this._settingsChangedId = 0;
|
this._settingsChangedId = 0;
|
||||||
}
|
}
|
||||||
this._store.destroy();
|
this._store.destroy();
|
||||||
super.destroy();
|
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|||||||
+93
-12
@@ -27,6 +27,23 @@ const LIVENESS_INTERVAL = 20; // seconds
|
|||||||
// morning, which is exactly the case this indicator exists for.
|
// morning, which is exactly the case this indicator exists for.
|
||||||
const UNKNOWN_PID_MAX_AGE = 36 * 3600; // seconds
|
const UNKNOWN_PID_MAX_AGE = 36 * 3600; // seconds
|
||||||
|
|
||||||
|
// A hook killed between writing its temporary file and renaming it leaves the
|
||||||
|
// temporary behind. Old ones are swept; recent ones are left alone, because a
|
||||||
|
// hook may be part-way through writing one right now and deleting it would
|
||||||
|
// lose that update.
|
||||||
|
const TMP_MAX_AGE = 300; // seconds
|
||||||
|
|
||||||
|
// A state file is a few hundred bytes. Anything larger is corrupt or hostile,
|
||||||
|
// and reading it whole would happen inside the compositor: a symlink to
|
||||||
|
// /dev/zero took a test process past 4 GB in three seconds, which in
|
||||||
|
// gnome-shell is the session ending. The size is checked before the read.
|
||||||
|
const MAX_STATE_BYTES = 64 * 1024;
|
||||||
|
|
||||||
|
// Work here is on the compositor's main loop, and every session costs a menu
|
||||||
|
// row of five actors. Well past any real use, and cheap insurance against a
|
||||||
|
// directory someone filled up.
|
||||||
|
const MAX_SESSIONS = 64;
|
||||||
|
|
||||||
export function stateRank(state) {
|
export function stateRank(state) {
|
||||||
const i = STATES.indexOf(state);
|
const i = STATES.indexOf(state);
|
||||||
return i < 0 ? STATES.length : i;
|
return i < 0 ? STATES.length : i;
|
||||||
@@ -128,16 +145,20 @@ export const SessionStore = GObject.registerClass({
|
|||||||
let enumerator;
|
let enumerator;
|
||||||
try {
|
try {
|
||||||
enumerator = await this._dir.enumerate_children_async(
|
enumerator = await this._dir.enumerate_children_async(
|
||||||
'standard::name', Gio.FileQueryInfoFlags.NONE,
|
'standard::name,standard::size,time::modified', Gio.FileQueryInfoFlags.NONE,
|
||||||
GLib.PRIORITY_DEFAULT, cancellable);
|
GLib.PRIORITY_DEFAULT, cancellable);
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
// No directory yet means no sessions have ever run; not an error.
|
// No directory yet means no sessions have ever run; not an error.
|
||||||
if (e.matches?.(Gio.IOErrorEnum, Gio.IOErrorEnum.NOT_FOUND))
|
// NOT_DIRECTORY means something took the path -- also not worth a
|
||||||
|
// stack trace every 20 seconds for as long as it stays that way.
|
||||||
|
if (e.matches?.(Gio.IOErrorEnum, Gio.IOErrorEnum.NOT_FOUND) ||
|
||||||
|
e.matches?.(Gio.IOErrorEnum, Gio.IOErrorEnum.NOT_DIRECTORY))
|
||||||
return [];
|
return [];
|
||||||
throw e;
|
throw e;
|
||||||
}
|
}
|
||||||
|
|
||||||
const names = [];
|
const names = [];
|
||||||
|
const locks = [];
|
||||||
for (;;) {
|
for (;;) {
|
||||||
const batch = await enumerator.next_files_async(
|
const batch = await enumerator.next_files_async(
|
||||||
32, GLib.PRIORITY_DEFAULT, cancellable);
|
32, GLib.PRIORITY_DEFAULT, cancellable);
|
||||||
@@ -145,15 +166,31 @@ export const SessionStore = GObject.registerClass({
|
|||||||
break;
|
break;
|
||||||
for (const info of batch) {
|
for (const info of batch) {
|
||||||
const name = info.get_name();
|
const name = info.get_name();
|
||||||
// ".tmp" files are half-written state; "debug" is the hook's
|
// Only ".json" is state. ".lock" belongs to the hook, "debug"
|
||||||
// opt-in event log and is not a session.
|
// is its opt-in event log, and ".tmp" is an interrupted write.
|
||||||
if (name.endsWith('.json'))
|
if (name.endsWith('.json')) {
|
||||||
|
if (info.get_size() > MAX_STATE_BYTES) {
|
||||||
|
// Not read at all: the point is to never allocate it.
|
||||||
|
continue;
|
||||||
|
}
|
||||||
names.push(name);
|
names.push(name);
|
||||||
|
} else if (name.endsWith('.tmp')) {
|
||||||
|
this._sweepStale(info, name);
|
||||||
|
} else if (name.endsWith('.json.lock')) {
|
||||||
|
locks.push({ info, name });
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// A lock whose state file is gone belongs to nothing; the hook only
|
||||||
|
// removes the pair together, so nobody else would ever clear it.
|
||||||
|
for (const { info, name } of locks) {
|
||||||
|
if (!names.includes(name.slice(0, -'.lock'.length)))
|
||||||
|
this._sweepStale(info, name);
|
||||||
|
}
|
||||||
|
|
||||||
const sessions = [];
|
const sessions = [];
|
||||||
for (const name of names) {
|
for (const name of names.slice(0, MAX_SESSIONS)) {
|
||||||
const session = await this._readOne(name, cancellable);
|
const session = await this._readOne(name, cancellable);
|
||||||
if (session)
|
if (session)
|
||||||
sessions.push(session);
|
sessions.push(session);
|
||||||
@@ -161,6 +198,24 @@ export const SessionStore = GObject.registerClass({
|
|||||||
return sessions;
|
return sessions;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/** Delete an abandoned file, once it is old enough to be sure nobody is
|
||||||
|
* part-way through writing it. */
|
||||||
|
_sweepStale(info, name) {
|
||||||
|
const modified = info.get_modification_date_time?.();
|
||||||
|
if (!modified)
|
||||||
|
return;
|
||||||
|
const age = GLib.DateTime.new_now_local().difference(modified) / 1e6;
|
||||||
|
if (age < TMP_MAX_AGE)
|
||||||
|
return;
|
||||||
|
this._dir.get_child(name).delete_async(GLib.PRIORITY_LOW, null, (obj, res) => {
|
||||||
|
try {
|
||||||
|
obj.delete_finish(res);
|
||||||
|
} catch (e) {
|
||||||
|
// Gone already, or not ours to remove.
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
async _readOne(name, cancellable) {
|
async _readOne(name, cancellable) {
|
||||||
const file = this._dir.get_child(name);
|
const file = this._dir.get_child(name);
|
||||||
let raw;
|
let raw;
|
||||||
@@ -176,12 +231,13 @@ export const SessionStore = GObject.registerClass({
|
|||||||
return null;
|
return null;
|
||||||
|
|
||||||
const pid = Number(raw.pid) || 0;
|
const pid = Number(raw.pid) || 0;
|
||||||
|
const pidStart = Number(raw.pid_start) || 0;
|
||||||
const eventTs = Number(raw.event_ts) || 0;
|
const eventTs = Number(raw.event_ts) || 0;
|
||||||
const age = GLib.get_real_time() / 1e6 - eventTs;
|
const age = GLib.get_real_time() / 1e6 - eventTs;
|
||||||
// pid 0 is "the hook could not tell", not "dead": treating it as dead
|
// pid 0 is "the hook could not tell", not "dead": treating it as dead
|
||||||
// would hide a perfectly live session, so those fall back to an age
|
// would hide a perfectly live session, so those fall back to an age
|
||||||
// cutoff instead.
|
// cutoff instead.
|
||||||
const gone = pid > 0 ? !isAlive(pid) : age > UNKNOWN_PID_MAX_AGE;
|
const gone = pid > 0 ? !isAlive(pid, pidStart) : age > UNKNOWN_PID_MAX_AGE;
|
||||||
if (gone) {
|
if (gone) {
|
||||||
// The terminal was killed without a SessionEnd hook. Removing the
|
// The terminal was killed without a SessionEnd hook. Removing the
|
||||||
// file here (rather than only hiding it) keeps the directory from
|
// file here (rather than only hiding it) keeps the directory from
|
||||||
@@ -209,12 +265,10 @@ export const SessionStore = GObject.registerClass({
|
|||||||
state,
|
state,
|
||||||
cwd: String(raw.cwd ?? ''),
|
cwd: String(raw.cwd ?? ''),
|
||||||
since: Number(raw.since) || 0,
|
since: Number(raw.since) || 0,
|
||||||
|
started: Number(raw.started) || 0,
|
||||||
pid,
|
pid,
|
||||||
message: String(raw.message ?? ''),
|
|
||||||
agents: Math.max(0, Number(raw.agents) || 0),
|
agents: Math.max(0, Number(raw.agents) || 0),
|
||||||
notificationType: String(raw.notification_type ?? ''),
|
|
||||||
zellijSession: String(raw.zellij_session ?? ''),
|
zellijSession: String(raw.zellij_session ?? ''),
|
||||||
zellijPane: String(raw.zellij_pane ?? ''),
|
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -234,6 +288,33 @@ export const SessionStore = GObject.registerClass({
|
|||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
function isAlive(pid) {
|
/** Is this pid still the process the hook recorded?
|
||||||
return pid > 0 && GLib.file_test(`/proc/${pid}`, GLib.FileTest.EXISTS);
|
*
|
||||||
|
* Existence alone is not enough. State files outlive reboots, and a pid from a
|
||||||
|
* previous boot is very likely to belong to something else now -- a session
|
||||||
|
* that died in a crash would otherwise sit in the panel forever, waiting for
|
||||||
|
* an answer nobody can give. The start time pins the pid to one process.
|
||||||
|
*/
|
||||||
|
function isAlive(pid, startTime) {
|
||||||
|
if (pid <= 0 || !GLib.file_test(`/proc/${pid}`, GLib.FileTest.EXISTS))
|
||||||
|
return false;
|
||||||
|
// Files written before start times were recorded have nothing to compare.
|
||||||
|
if (!startTime)
|
||||||
|
return true;
|
||||||
|
return readStartTime(pid) === startTime;
|
||||||
|
}
|
||||||
|
|
||||||
|
function readStartTime(pid) {
|
||||||
|
try {
|
||||||
|
const [ok, bytes] = GLib.file_get_contents(`/proc/${pid}/stat`);
|
||||||
|
if (!ok)
|
||||||
|
return 0;
|
||||||
|
const data = new TextDecoder().decode(bytes);
|
||||||
|
// The command name is parenthesised and may contain spaces and ')',
|
||||||
|
// so fields are counted from after the last one.
|
||||||
|
const tail = data.slice(data.lastIndexOf(')') + 2).split(' ');
|
||||||
|
return Number(tail[19]) || 0;
|
||||||
|
} catch (e) {
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
+31
-14
@@ -1,8 +1,8 @@
|
|||||||
// Maps a session's working directory to the zellij tab it is running in.
|
// Maps a session's working directory to the zellij tab it is running in.
|
||||||
//
|
//
|
||||||
// Knowing a session waits for you is only half the answer; the other half is
|
// Knowing a session waits for you is only half the answer; the other half is
|
||||||
// where to look. When sessions live in zellij tabs, the tab name is a better
|
// where to look. When sessions live in zellij tabs, the tab name answers that
|
||||||
// answer than a path, and zellij can be told to switch to it.
|
// better than a path does.
|
||||||
//
|
//
|
||||||
// `zellij action dump-layout` prints tab names with each pane's cwd but no pane
|
// `zellij action dump-layout` prints tab names with each pane's cwd but no pane
|
||||||
// ids, so ZELLIJ_PANE_ID from the hook cannot be used for the lookup and the
|
// ids, so ZELLIJ_PANE_ID from the hook cannot be used for the lookup and the
|
||||||
@@ -20,12 +20,18 @@ Gio._promisify(Gio.Subprocess.prototype, 'communicate_utf8_async');
|
|||||||
// does not spawn a zellij process every time it runs.
|
// does not spawn a zellij process every time it runs.
|
||||||
const CACHE_TTL = 120; // seconds
|
const CACHE_TTL = 120; // seconds
|
||||||
|
|
||||||
|
// One subprocess per distinct zellij session named in the state directory.
|
||||||
|
// In real use that is one or two; the bound is there because the names come
|
||||||
|
// from files, and a directory full of them would fork a process per name.
|
||||||
|
const MAX_SESSIONS = 8;
|
||||||
|
|
||||||
export class ZellijTabs {
|
export class ZellijTabs {
|
||||||
constructor() {
|
constructor() {
|
||||||
this._cache = new Map(); // zellij session -> { at, tabs: [{name, cwds}] }
|
this._cache = new Map(); // zellij session -> { at, tabs: [{name, cwds}] }
|
||||||
this._inFlight = new Map();
|
this._inFlight = new Map();
|
||||||
this._available = null;
|
this._available = null;
|
||||||
this._cancellable = new Gio.Cancellable();
|
this._cancellable = new Gio.Cancellable();
|
||||||
|
this._children = new Set();
|
||||||
}
|
}
|
||||||
|
|
||||||
/** Tab name for a working directory, or null when unknown. */
|
/** Tab name for a working directory, or null when unknown. */
|
||||||
@@ -58,7 +64,7 @@ export class ZellijTabs {
|
|||||||
return;
|
return;
|
||||||
const now = GLib.get_monotonic_time() / 1e6;
|
const now = GLib.get_monotonic_time() / 1e6;
|
||||||
const work = [];
|
const work = [];
|
||||||
for (const name of new Set(zellijSessions)) {
|
for (const name of [...new Set(zellijSessions)].slice(0, MAX_SESSIONS)) {
|
||||||
if (!name)
|
if (!name)
|
||||||
continue;
|
continue;
|
||||||
const entry = this._cache.get(name);
|
const entry = this._cache.get(name);
|
||||||
@@ -97,10 +103,15 @@ export class ZellijTabs {
|
|||||||
const proc = Gio.Subprocess.new(
|
const proc = Gio.Subprocess.new(
|
||||||
['zellij', '--session', session, 'action', 'dump-layout'],
|
['zellij', '--session', session, 'action', 'dump-layout'],
|
||||||
Gio.SubprocessFlags.STDOUT_PIPE | Gio.SubprocessFlags.STDERR_SILENCE);
|
Gio.SubprocessFlags.STDOUT_PIPE | Gio.SubprocessFlags.STDERR_SILENCE);
|
||||||
|
this._children.add(proc);
|
||||||
|
try {
|
||||||
const [stdout] = await proc.communicate_utf8_async(null, this._cancellable);
|
const [stdout] = await proc.communicate_utf8_async(null, this._cancellable);
|
||||||
if (!proc.get_successful())
|
if (!proc.get_successful())
|
||||||
return null;
|
return null;
|
||||||
return stdout ?? '';
|
return stdout ?? '';
|
||||||
|
} finally {
|
||||||
|
this._children.delete(proc);
|
||||||
|
}
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
// zellij not installed, or not on the shell's PATH: stop trying.
|
// zellij not installed, or not on the shell's PATH: stop trying.
|
||||||
if (e.matches?.(GLib.SpawnError, GLib.SpawnError.NOENT))
|
if (e.matches?.(GLib.SpawnError, GLib.SpawnError.NOENT))
|
||||||
@@ -112,20 +123,14 @@ export class ZellijTabs {
|
|||||||
/** Abandon any layout dump still running; the extension is going away. */
|
/** Abandon any layout dump still running; the extension is going away. */
|
||||||
destroy() {
|
destroy() {
|
||||||
this._cancellable.cancel();
|
this._cancellable.cancel();
|
||||||
|
// Cancelling only abandons the read; the child keeps running. A wedged
|
||||||
|
// zellij server would otherwise outlive the extension being disabled.
|
||||||
|
for (const proc of this._children)
|
||||||
|
proc.force_exit();
|
||||||
|
this._children.clear();
|
||||||
this._cache.clear();
|
this._cache.clear();
|
||||||
this._inFlight.clear();
|
this._inFlight.clear();
|
||||||
}
|
}
|
||||||
|
|
||||||
/** Switch the given zellij session to a tab. Fire and forget. */
|
|
||||||
goToTab(session, tab) {
|
|
||||||
try {
|
|
||||||
Gio.Subprocess.new(
|
|
||||||
['zellij', '--session', session, 'action', 'go-to-tab-name', tab],
|
|
||||||
Gio.SubprocessFlags.STDOUT_SILENCE | Gio.SubprocessFlags.STDERR_SILENCE);
|
|
||||||
} catch (e) {
|
|
||||||
logError(e, 'claude-code-status: zellij go-to-tab-name failed');
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/** Extract tab names and their pane working directories from a KDL layout.
|
/** Extract tab names and their pane working directories from a KDL layout.
|
||||||
@@ -146,11 +151,23 @@ export function parseLayout(text) {
|
|||||||
tabs.push(current);
|
tabs.push(current);
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
// A dump ends with new_tab_template and swap_tiled_layout blocks, whose
|
||||||
|
// own `tab` lines carry no name. Their panes belong to no tab at all;
|
||||||
|
// left attached to whatever came before, they make the last tab in the
|
||||||
|
// dump answer for every unmatched directory -- confidently and wrongly.
|
||||||
|
if (/^\s*(tab\s|tab\s*\{|new_tab_template|swap_tiled_layout|swap_floating_layout)/.test(line)) {
|
||||||
|
current = null;
|
||||||
|
continue;
|
||||||
|
}
|
||||||
if (!current)
|
if (!current)
|
||||||
continue;
|
continue;
|
||||||
const paneMatch = line.match(/^\s*pane\s.*?\bcwd="([^"]*)"/);
|
const paneMatch = line.match(/^\s*pane\s.*?\bcwd="([^"]*)"/);
|
||||||
if (paneMatch) {
|
if (paneMatch) {
|
||||||
const cwd = paneMatch[1];
|
const cwd = paneMatch[1];
|
||||||
|
// A relative pane cwd is meaningless without the layout-level one;
|
||||||
|
// joining against "" yields a relative path that matches nothing.
|
||||||
|
if (!cwd.startsWith('/') && !base)
|
||||||
|
continue;
|
||||||
const absolute = cwd.startsWith('/')
|
const absolute = cwd.startsWith('/')
|
||||||
? cwd
|
? cwd
|
||||||
: GLib.build_filenamev([base, cwd]);
|
: GLib.build_filenamev([base, cwd]);
|
||||||
|
|||||||
@@ -24,6 +24,10 @@ export default class ClaudeCodeStatusPreferences extends ExtensionPreferences {
|
|||||||
dispGroup.add(this._switchRow(settings, 'abbreviate-names',
|
dispGroup.add(this._switchRow(settings, 'abbreviate-names',
|
||||||
_('Shorten names to three characters'),
|
_('Shorten names to three characters'),
|
||||||
_('“dev-skills” becomes “ds”. Collisions get a digit by seniority, so a label already on screen never changes.')));
|
_('“dev-skills” becomes “ds”. Collisions get a digit by seniority, so a label already on screen never changes.')));
|
||||||
|
dispGroup.add(this._spinRow(settings, 'max-chips',
|
||||||
|
_('Chips shown'),
|
||||||
|
_('The most urgent sessions get a chip; the rest are counted as “+N”.'),
|
||||||
|
1, 12));
|
||||||
dispGroup.add(this._switchRow(settings, 'show-age',
|
dispGroup.add(this._switchRow(settings, 'show-age',
|
||||||
_('Show time in state'),
|
_('Show time in state'),
|
||||||
_('Shown on the most urgent session only.')));
|
_('Shown on the most urgent session only.')));
|
||||||
@@ -36,7 +40,7 @@ export default class ClaudeCodeStatusPreferences extends ExtensionPreferences {
|
|||||||
|
|
||||||
zellijGroup.add(this._switchRow(settings, 'zellij-integration',
|
zellijGroup.add(this._switchRow(settings, 'zellij-integration',
|
||||||
_('Resolve tab names'),
|
_('Resolve tab names'),
|
||||||
_('Show the zellij tab in the menu and switch to it on click. Ignored when zellij is not installed.')));
|
_('Name the zellij tab each session runs in. Ignored when zellij is not installed.')));
|
||||||
|
|
||||||
// --- Hooks ---------------------------------------------------------
|
// --- Hooks ---------------------------------------------------------
|
||||||
// The indicator is only as good as the hooks feeding it, and a silent
|
// The indicator is only as good as the hooks feeding it, and a silent
|
||||||
@@ -81,6 +85,11 @@ export default class ClaudeCodeStatusPreferences extends ExtensionPreferences {
|
|||||||
|
|
||||||
_hooksStatus() {
|
_hooksStatus() {
|
||||||
const path = GLib.build_filenamev([GLib.get_home_dir(), '.claude', 'settings.json']);
|
const path = GLib.build_filenamev([GLib.get_home_dir(), '.claude', 'settings.json']);
|
||||||
|
// Checked before reading: file_get_contents throws on a missing file,
|
||||||
|
// so without this the person who has installed nothing -- the one who
|
||||||
|
// most needs the instructions -- is told the file cannot be parsed.
|
||||||
|
if (!GLib.file_test(path, GLib.FileTest.EXISTS))
|
||||||
|
return _('No ~/.claude/settings.json yet — run the install command below');
|
||||||
try {
|
try {
|
||||||
const [ok, bytes] = GLib.file_get_contents(path);
|
const [ok, bytes] = GLib.file_get_contents(path);
|
||||||
if (!ok)
|
if (!ok)
|
||||||
@@ -91,13 +100,24 @@ export default class ClaudeCodeStatusPreferences extends ExtensionPreferences {
|
|||||||
(g.hooks ?? []).some(h => (h.command ?? '').includes('claude-status-hook.py'))))
|
(g.hooks ?? []).some(h => (h.command ?? '').includes('claude-status-hook.py'))))
|
||||||
.map(([event]) => event);
|
.map(([event]) => event);
|
||||||
if (!events.length)
|
if (!events.length)
|
||||||
return _('Not installed — run the install command below, then restart your sessions');
|
return _('Not installed — run the install command below');
|
||||||
return `${_('Installed for')}: ${events.join(', ')}`;
|
return `${_('Installed for')}: ${events.join(', ')}`;
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
return _('~/.claude/settings.json could not be parsed');
|
return _('~/.claude/settings.json could not be parsed');
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
_spinRow(settings, key, title, subtitle, lower, upper) {
|
||||||
|
const row = new Adw.SpinRow({
|
||||||
|
title, subtitle,
|
||||||
|
adjustment: new Gtk.Adjustment({
|
||||||
|
lower, upper, step_increment: 1, page_increment: 1,
|
||||||
|
}),
|
||||||
|
});
|
||||||
|
settings.bind(key, row, 'value', Gio.SettingsBindFlags.DEFAULT);
|
||||||
|
return row;
|
||||||
|
}
|
||||||
|
|
||||||
_switchRow(settings, key, title, subtitle) {
|
_switchRow(settings, key, title, subtitle) {
|
||||||
const row = new Adw.SwitchRow({ title, subtitle });
|
const row = new Adw.SwitchRow({ title, subtitle });
|
||||||
settings.bind(key, row, 'active', Gio.SettingsBindFlags.DEFAULT);
|
settings.bind(key, row, 'active', Gio.SettingsBindFlags.DEFAULT);
|
||||||
|
|||||||
@@ -12,6 +12,12 @@
|
|||||||
<summary>Shorten project names to three characters</summary>
|
<summary>Shorten project names to three characters</summary>
|
||||||
<description>Chips show initials ("dev-skills" becomes "ds") so a row of sessions stays narrow. Sessions that would collide, including two in the same project, get a digit by seniority: the older one keeps its label. Turn off to show full project names.</description>
|
<description>Chips show initials ("dev-skills" becomes "ds") so a row of sessions stays narrow. Sessions that would collide, including two in the same project, get a digit by seniority: the older one keeps its label. Turn off to show full project names.</description>
|
||||||
</key>
|
</key>
|
||||||
|
<key name="max-chips" type="i">
|
||||||
|
<default>3</default>
|
||||||
|
<range min="1" max="12"/>
|
||||||
|
<summary>How many sessions get a chip</summary>
|
||||||
|
<description>Chips are ordered by urgency, so the ones shown are the ones that need you soonest; the rest are counted as "+N". Keeps the row from pushing the clock off centre when many sessions are open.</description>
|
||||||
|
</key>
|
||||||
<key name="show-age" type="b">
|
<key name="show-age" type="b">
|
||||||
<default>true</default>
|
<default>true</default>
|
||||||
<summary>Show how long the session has been in this state</summary>
|
<summary>Show how long the session has been in this state</summary>
|
||||||
@@ -20,7 +26,7 @@
|
|||||||
<key name="zellij-integration" type="b">
|
<key name="zellij-integration" type="b">
|
||||||
<default>true</default>
|
<default>true</default>
|
||||||
<summary>Resolve zellij tab names</summary>
|
<summary>Resolve zellij tab names</summary>
|
||||||
<description>Look up which zellij tab each session runs in, show it in the menu, and let a click switch to that tab. Requires the zellij command; harmless when it is absent.</description>
|
<description>Look up which zellij tab each session runs in and name it in the menu, which answers "which terminal" better than a path does. Requires the zellij command; harmless when it is absent.</description>
|
||||||
</key>
|
</key>
|
||||||
</schema>
|
</schema>
|
||||||
</schemalist>
|
</schemalist>
|
||||||
|
|||||||
@@ -34,6 +34,12 @@
|
|||||||
font-feature-settings: "tnum";
|
font-feature-settings: "tnum";
|
||||||
}
|
}
|
||||||
|
|
||||||
|
.ccs-overflow {
|
||||||
|
font-size: 0.9em;
|
||||||
|
opacity: 0.7;
|
||||||
|
font-feature-settings: "tnum";
|
||||||
|
}
|
||||||
|
|
||||||
.ccs-summary {
|
.ccs-summary {
|
||||||
font-weight: bold;
|
font-weight: bold;
|
||||||
}
|
}
|
||||||
|
|||||||
+34
-1
@@ -32,10 +32,40 @@ ev() { # event [extra json]
|
|||||||
echo "{\"session_id\":\"$SID\",\"hook_event_name\":\"$1\",\"cwd\":\"/tmp/proj\"${2:+,$2}}"
|
echo "{\"session_id\":\"$SID\",\"hook_event_name\":\"$1\",\"cwd\":\"/tmp/proj\"${2:+,$2}}"
|
||||||
}
|
}
|
||||||
|
|
||||||
|
# --- identifying the claude process ----------------------------------------
|
||||||
|
# The hook is spawned as `/bin/sh -c /.../claude-status-hook.py`, so its
|
||||||
|
# parent's command line contains "claude" in a path without being claude.
|
||||||
|
# Matching on the raw string latches onto that shell, which exits at once.
|
||||||
|
python3 - "$HOOK" <<'PY'
|
||||||
|
import importlib.util, sys
|
||||||
|
spec = importlib.util.spec_from_file_location("h", sys.argv[1])
|
||||||
|
h = importlib.util.module_from_spec(spec); spec.loader.exec_module(h)
|
||||||
|
cases = [
|
||||||
|
("/bin/sh -c /home/u/claude-code-gnome-extension/hooks/claude-status-hook.py ", False),
|
||||||
|
("/home/u/.local/bin/claude --resume ", True),
|
||||||
|
("bash /home/u/bin/claude ", True),
|
||||||
|
("node /usr/lib/node_modules/@anthropic-ai/claude-code/cli.js ", True),
|
||||||
|
("/home/u/bin/zellij --server /run/user/1000/zellij/x ", False),
|
||||||
|
("nvim /home/u/.claude/settings.json ", False),
|
||||||
|
]
|
||||||
|
bad = 0
|
||||||
|
for cmd, want in cases:
|
||||||
|
got = h.looks_like_claude(cmd)
|
||||||
|
print(("ok " if got == want else "FAIL ") + "claude in %r -> %s" % (cmd[:46], got))
|
||||||
|
bad += got != want
|
||||||
|
sys.exit(1 if bad else 0)
|
||||||
|
PY
|
||||||
|
check "command lines classified correctly" "0" "$?"
|
||||||
|
|
||||||
# --- state machine ---------------------------------------------------------
|
# --- state machine ---------------------------------------------------------
|
||||||
emit "$(ev SessionStart '"source":"startup"')"
|
emit "$(ev SessionStart '"source":"startup"')"
|
||||||
check "SessionStart -> waiting" "waiting" "$(field state)"
|
check "SessionStart -> waiting" "waiting" "$(field state)"
|
||||||
|
|
||||||
|
# Pins the recorded pid to one process, so a state file that outlives a reboot
|
||||||
|
# cannot be revived by whatever inherits that pid number next.
|
||||||
|
start=$(field pid_start)
|
||||||
|
check "process start time recorded" "yes" "$([ -n "$start" ] && [ "$start" != "0" ] && echo yes || echo no)"
|
||||||
|
|
||||||
emit "$(ev UserPromptSubmit '"prompt":"hi"')"
|
emit "$(ev UserPromptSubmit '"prompt":"hi"')"
|
||||||
check "UserPromptSubmit -> busy" "busy" "$(field state)"
|
check "UserPromptSubmit -> busy" "busy" "$(field state)"
|
||||||
|
|
||||||
@@ -164,7 +194,10 @@ check "hook proceeds once the lock is released" "waiting" "$(field state)"
|
|||||||
# --- teardown --------------------------------------------------------------
|
# --- teardown --------------------------------------------------------------
|
||||||
emit "$(ev SessionEnd '"reason":"other"')"
|
emit "$(ev SessionEnd '"reason":"other"')"
|
||||||
[ -e "$FILE" ]; check "SessionEnd removes the state file" "1" "$?"
|
[ -e "$FILE" ]; check "SessionEnd removes the state file" "1" "$?"
|
||||||
[ -e "$FILE.lock" ]; check "SessionEnd removes the lock file" "1" "$?"
|
# The lock deliberately stays. Unlinking it while holding it would drop mutual
|
||||||
|
# exclusion for any hook already blocked on the old inode; the reader sweeps it
|
||||||
|
# once it is orphaned and old.
|
||||||
|
[ -e "$FILE.lock" ]; check "SessionEnd keeps the lock inode" "0" "$?"
|
||||||
|
|
||||||
rm -rf "$XDG_STATE_HOME"
|
rm -rf "$XDG_STATE_HOME"
|
||||||
if [ "$failures" -gt 0 ]; then
|
if [ "$failures" -gt 0 ]; then
|
||||||
|
|||||||
+6
-4
@@ -48,7 +48,7 @@ const rows = [];
|
|||||||
const walk = widget => {
|
const walk = widget => {
|
||||||
for (let c = widget.get_first_child?.(); c; c = c.get_next_sibling()) {
|
for (let c = widget.get_first_child?.(); c; c = c.get_next_sibling()) {
|
||||||
const type = c.constructor.$gtype.name;
|
const type = c.constructor.$gtype.name;
|
||||||
if (type === 'AdwSwitchRow' || type === 'AdwActionRow')
|
if (type === 'AdwSwitchRow' || type === 'AdwSpinRow' || type === 'AdwActionRow')
|
||||||
rows.push({ type, title: c.title, subtitle: c.subtitle });
|
rows.push({ type, title: c.title, subtitle: c.subtitle });
|
||||||
walk(c);
|
walk(c);
|
||||||
}
|
}
|
||||||
@@ -65,11 +65,13 @@ function check(name, condition, detail = '') {
|
|||||||
for (const row of rows)
|
for (const row of rows)
|
||||||
print(` ${row.type.replace('Adw', '').padEnd(10)} ${row.title}`);
|
print(` ${row.type.replace('Adw', '').padEnd(10)} ${row.title}`);
|
||||||
|
|
||||||
// One switch per settings key, so a key added without a row is caught.
|
// One control per settings key, so a key added without a row to change it is
|
||||||
|
// caught here rather than by a user wondering why nothing happens.
|
||||||
const keys = schemas.lookup('org.gnome.shell.extensions.claude-code-status', true)
|
const keys = schemas.lookup('org.gnome.shell.extensions.claude-code-status', true)
|
||||||
.list_keys().length;
|
.list_keys().length;
|
||||||
const switches = rows.filter(r => r.type === 'AdwSwitchRow').length;
|
const controls = rows.filter(
|
||||||
check('a switch for every settings key', switches === keys, `${switches} of ${keys}`);
|
r => r.type === 'AdwSwitchRow' || r.type === 'AdwSpinRow').length;
|
||||||
|
check('a control for every settings key', controls === keys, `${controls} of ${keys}`);
|
||||||
|
|
||||||
// The hook status line is the reason this page is worth opening at all: a
|
// The hook status line is the reason this page is worth opening at all: a
|
||||||
// silent panel looks the same whether nothing runs or nothing is installed.
|
// silent panel looks the same whether nothing runs or nothing is installed.
|
||||||
|
|||||||
+23
-3
@@ -27,11 +27,12 @@ function check(name, condition, detail = '') {
|
|||||||
}
|
}
|
||||||
|
|
||||||
const now = GLib.get_real_time() / 1e6;
|
const now = GLib.get_real_time() / 1e6;
|
||||||
function write(id, state, cwd, agoSeconds, pid) {
|
function write(id, state, cwd, agoSeconds, pid, pidStart = 0) {
|
||||||
const payload = {
|
const payload = {
|
||||||
session_id: id, state, cwd, since: now - agoSeconds,
|
session_id: id, state, cwd, since: now - agoSeconds,
|
||||||
event_ts: now, pid, event: 'test', notification_type: '',
|
event_ts: now, pid, pid_start: pidStart, event: 'test',
|
||||||
message: '', zellij_session: 'ztest', zellij_pane: '1', transcript: '',
|
notification_type: '', message: '', zellij_session: 'ztest',
|
||||||
|
zellij_pane: '1', transcript: '',
|
||||||
};
|
};
|
||||||
GLib.file_set_contents(
|
GLib.file_set_contents(
|
||||||
GLib.build_filenamev([STATE, `${id}.json`]), JSON.stringify(payload));
|
GLib.build_filenamev([STATE, `${id}.json`]), JSON.stringify(payload));
|
||||||
@@ -50,6 +51,17 @@ write('s-dead', 'waiting', '/home/u/proj-dead', 5, deadPid);
|
|||||||
// Written by the older hook, which had a fourth state. Files like this
|
// Written by the older hook, which had a fourth state. Files like this
|
||||||
// survive an upgrade in a session that was already open.
|
// survive an upgrade in a session that was already open.
|
||||||
write('s-legacy', 'idle', '/home/u/proj-legacy', 5, livePid);
|
write('s-legacy', 'idle', '/home/u/proj-legacy', 5, livePid);
|
||||||
|
// Survived a reboot: the pid exists again, but belongs to something else now.
|
||||||
|
// Without an identity check this sits in the panel forever as a live session.
|
||||||
|
write('s-ghost', 'waiting', '/home/u/proj-ghost', 99999, livePid, 1);
|
||||||
|
// Left by a session that ended: the hook keeps the lock inode deliberately,
|
||||||
|
// so nobody but the reader would ever clear it.
|
||||||
|
GLib.file_set_contents(GLib.build_filenamev([STATE, 's-gone.json.lock']), '');
|
||||||
|
GLib.spawn_command_line_sync(
|
||||||
|
`touch -d '1 hour ago' ${GLib.build_filenamev([STATE, 's-gone.json.lock'])}`);
|
||||||
|
// A state file far larger than any real one must not be read at all.
|
||||||
|
GLib.file_set_contents(GLib.build_filenamev([STATE, 'huge.json']),
|
||||||
|
`{"session_id":"huge","state":"waiting","pid":1,"cwd":"${'x'.repeat(70000)}"}`);
|
||||||
GLib.file_set_contents(GLib.build_filenamev([STATE, 'notes.txt']), 'ignored');
|
GLib.file_set_contents(GLib.build_filenamev([STATE, 'notes.txt']), 'ignored');
|
||||||
GLib.file_set_contents(GLib.build_filenamev([STATE, 'half.json']), '{"broken');
|
GLib.file_set_contents(GLib.build_filenamev([STATE, 'half.json']), '{"broken');
|
||||||
|
|
||||||
@@ -67,6 +79,10 @@ store.connect('changed', () => {
|
|||||||
stateRank('waiting') < stateRank('busy'));
|
stateRank('waiting') < stateRank('busy'));
|
||||||
|
|
||||||
check('dead session dropped', !s.some(x => x.sessionId === 's-dead'));
|
check('dead session dropped', !s.some(x => x.sessionId === 's-dead'));
|
||||||
|
check('reused pid from a previous boot dropped',
|
||||||
|
!s.some(x => x.sessionId === 's-ghost'));
|
||||||
|
check('and its file removed',
|
||||||
|
!GLib.file_test(GLib.build_filenamev([STATE, 's-ghost.json']), GLib.FileTest.EXISTS));
|
||||||
check('truncated file skipped, others survive', s.length === 5,
|
check('truncated file skipped, others survive', s.length === 5,
|
||||||
`got ${s.length}: ${s.map(x => x.sessionId).join(',')}`);
|
`got ${s.length}: ${s.map(x => x.sessionId).join(',')}`);
|
||||||
check('non-json ignored', !s.some(x => x.sessionId.includes('notes')));
|
check('non-json ignored', !s.some(x => x.sessionId.includes('notes')));
|
||||||
@@ -82,6 +98,10 @@ store.connect('changed', () => {
|
|||||||
s[3]?.sessionId === 's-legacy', s[3]?.sessionId);
|
s[3]?.sessionId === 's-legacy', s[3]?.sessionId);
|
||||||
check('busy after waiting', s[4]?.sessionId === 's-busy', s[4]?.sessionId);
|
check('busy after waiting', s[4]?.sessionId === 's-busy', s[4]?.sessionId);
|
||||||
|
|
||||||
|
check('oversized state file not loaded', !s.some(x => x.sessionId === 'huge'));
|
||||||
|
check('orphaned lock swept',
|
||||||
|
!GLib.file_test(GLib.build_filenamev([STATE, 's-gone.json.lock']), GLib.FileTest.EXISTS));
|
||||||
|
|
||||||
check('dead session file removed from disk',
|
check('dead session file removed from disk',
|
||||||
!GLib.file_test(GLib.build_filenamev([STATE, 's-dead.json']), GLib.FileTest.EXISTS));
|
!GLib.file_test(GLib.build_filenamev([STATE, 's-dead.json']), GLib.FileTest.EXISTS));
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user