KeiSei84
c347f329aa
Some checks are pending
CI (Forgejo Actions — self-hosted runner on Mac, host mode) / preflight (push) Waiting to run
CI (Forgejo Actions — self-hosted runner on Mac, host mode) / vps-smoke (push) Waiting to run
CI (Forgejo Actions — self-hosted runner on Mac, host mode) / rust-primitives (map[crates:frustration-matrix,kei-frustration-loop,kei-skill-importer,kei-projects-index,kei-projects-watcher,kei-gdrive-import,kei-leak-matrix,kei-skills,kei-gateway,kei-cron-scheduler,kei-export-trajectories,kei-backend-daytona,kei-d… (push) Blocked by required conditions
CI (Forgejo Actions — self-hosted runner on Mac, host mode) / rust-primitives (map[crates:kei-compute-baremetal,kei-compute-vultr,kei-compute-linode,kei-compute-digitalocean,kei-svc-systemd,kei-llm-bridge-mlx name:hosted-sleep-compute]) (push) Blocked by required conditions
CI (Forgejo Actions — self-hosted runner on Mac, host mode) / rust-primitives (map[crates:kei-diff,kei-scheduler,kei-watch,kei-prune,kei-discover,kei-brain-view,kei-hibernate,kei-ledger-sign,kei-fork name:wave13-15]) (push) Blocked by required conditions
CI (Forgejo Actions — self-hosted runner on Mac, host mode) / rust-primitives (map[crates:kei-git-gitea,kei-git-forgejo,kei-git-gitlab,kei-git-bitbucket,kei-memory-sled,kei-memory-redis,kei-memory-postgres,kei-memory-sqlite,kei-auth-google,kei-auth-apple,kei-auth-magiclink,kei-auth-webauthn,kei-notify-slack,kei-n… (push) Blocked by required conditions
CI (Forgejo Actions — self-hosted runner on Mac, host mode) / rust-primitives (map[crates:kei-ledger,kei-migrate,kei-changelog,kei-memory,kei-store,kei-conflict-scan,kei-refactor-engine,kei-graph-check,kei-shared,kei-dna-index,kei-pet name:core]) (push) Blocked by required conditions
CI (Forgejo Actions — self-hosted runner on Mac, host mode) / rust-primitives (map[crates:kei-machine-probe,kei-llm-ollama,kei-llm-llamacpp,kei-llm-mlx,kei-llm-router,kei-model name:llm-stack]) (push) Blocked by required conditions
CI (Forgejo Actions — self-hosted runner on Mac, host mode) / rust-primitives (map[crates:kei-router,kei-sage,kei-task,kei-chat-store,kei-crossdomain,kei-search-core,kei-content-store,kei-social-store,kei-curator,kei-auth,kei-artifact name:mcp-lbm]) (push) Blocked by required conditions
CI (Forgejo Actions — self-hosted runner on Mac, host mode) / rust-primitives (map[crates:keisei,kei-forge,kei-runtime,kei-runtime-core,kei-atom-discovery,kei-agent-runtime,kei-capability,kei-provision,kei-entity-store,kei-pipe,kei-cache,kei-spawn,kei-replay name:atom-substrate]) (push) Blocked by required conditions
Any Claude Code session can now message any other (not just Agent-Teams teammates), without tmux. Append-only jsonl bus + a UserPromptSubmit hook that pulls unread into each session's context per turn. - scripts/kei-message.sh: `kei message send [--to <name|all>] <text>` / inbox / list / channels. Identity = basename(cwd); broadcast channel "all". - hooks/mailbox-inject.sh: UserPromptSubmit. Injects messages addressed to this session (cwd-basename) or "all", since last turn; per-session cursor dedup; first turn sets baseline (no history dump); never echoes own messages. - bin/kei: `kei message ...` dispatch before splash. - lib-scaffold: copy ALL scripts/*.sh on install (picks up kei-message.sh). - settings-snippet: wire mailbox-inject under UserPromptSubmit. Store: ~/.claude/mailbox/messages.jsonl. Bypass: KEI_MAILBOX_BYPASS=1. Verified: addressed delivery, broadcast, first-turn no-dump, cursor dedup, no self-echo (2-session simulation). Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
57 lines
1.9 KiB
Bash
Executable file
57 lines
1.9 KiB
Bash
Executable file
#!/bin/sh
|
|
# mailbox-inject — pull-inbox for kei-message. On every UserPromptSubmit, inject
|
|
# any messages addressed to THIS session (by cwd-basename or the broadcast
|
|
# channel "all") that arrived since last turn, into the session context, so
|
|
# Claude sees what other sessions sent. Per-session read cursor dedups; first
|
|
# turn starts fresh (no history dump). Never blocks (always exit 0).
|
|
# Event: UserPromptSubmit. Bypass: KEI_MAILBOX_BYPASS=1.
|
|
|
|
[ "${KEI_MAILBOX_BYPASS:-}" = "1" ] && exit 0
|
|
command -v jq >/dev/null 2>&1 || exit 0
|
|
|
|
INPUT=$(cat)
|
|
SID=$(printf '%s' "$INPUT" | jq -r '.session_id // empty' 2>/dev/null)
|
|
CWD=$(printf '%s' "$INPUT" | jq -r '.cwd // empty' 2>/dev/null)
|
|
[ -n "$CWD" ] || CWD="$PWD"
|
|
me="$(basename "$CWD")"
|
|
|
|
MBOX="$HOME/.claude/mailbox"
|
|
LOG="$MBOX/messages.jsonl"
|
|
mkdir -p "$MBOX"
|
|
CUR="$MBOX/.cursor-${SID:-$me}"
|
|
|
|
# Highest id currently in the bus (0 if the log doesn't exist yet / is empty).
|
|
if [ -f "$LOG" ]; then
|
|
maxid=$(jq -s 'map(.id) | max // 0' "$LOG" 2>/dev/null || echo 0)
|
|
else
|
|
maxid=0
|
|
fi
|
|
[ -n "$maxid" ] || maxid=0
|
|
|
|
# First fire for this session: record baseline cursor, show nothing. Done even
|
|
# when the bus is still empty — so messages that arrive AFTER this point (but
|
|
# before the session's next turn) are not missed.
|
|
if [ ! -f "$CUR" ]; then
|
|
echo "$maxid" > "$CUR"
|
|
exit 0
|
|
fi
|
|
|
|
# Nothing to read yet.
|
|
[ -f "$LOG" ] || { echo "$maxid" > "$CUR"; exit 0; }
|
|
|
|
last=$(cat "$CUR" 2>/dev/null || echo 0)
|
|
case "$last" in ''|*[!0-9]*) last=0 ;; esac
|
|
|
|
new=$(jq -r --argjson last "$last" --arg me "$me" '
|
|
select(.id > $last)
|
|
| select(.to == $me or .to == "all")
|
|
| select(.from != $me)
|
|
| " • \(.from) -> \(.to): \(.body)"' "$LOG" 2>/dev/null)
|
|
|
|
# Advance cursor past everything seen this turn.
|
|
echo "$maxid" > "$CUR"
|
|
|
|
if [ -n "$new" ]; then
|
|
printf '[kei mailbox] new message(s) for this session (%s):\n%s\n (reply: kei message send --to <name> "...")\n' "$me" "$new"
|
|
fi
|
|
exit 0
|