fix(inbox): replace the broadcast watermark with a per-repo seen set
The single high-water mark assumed broadcast filenames within one second were written in sort order; a later broadcast with a lexically smaller uniq part sorted below an already-advanced watermark and was silently never delivered to repos that had read the first (review §2). _broadcast/seen/<repo> now records one delivered filename per line and delivery is membership-based, removing the ordering assumption. Four regression checks added first (the ordering check failed against the watermark), selftest 48/48. Upgrade note: a legacy single-line watermark file is read as a one-entry seen set, so pre-existing broadcasts older than the watermark may be re-delivered once. Co-Authored-By: Claude Fable 5 <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01HBbjgS5A55RVavoyjJC4FX
This commit is contained in:
parent
3af724f209
commit
b9bec85a80
2 changed files with 30 additions and 17 deletions
|
|
@ -7,7 +7,7 @@
|
|||
# pending and are re-injected on every SessionStart (startup, /clear, resume)
|
||||
# until marked handled with coord-done (so /clear never loses them, and this is
|
||||
# safe to re-run manually mid-session). Broadcasts are delivered once per repo
|
||||
# via a filename watermark. Prints nothing (exit 0) when nothing is pending.
|
||||
# via a per-repo seen set. Prints nothing (exit 0) when nothing is pending.
|
||||
# ASCII only, bash 3.2 safe.
|
||||
#
|
||||
# Usage: coord-inbox.sh [--repo <name>]
|
||||
|
|
@ -58,32 +58,29 @@ ${body}
|
|||
done
|
||||
fi
|
||||
|
||||
# --- Broadcasts: delivered once per repo via a filename watermark ---
|
||||
# --- Broadcasts: delivered once per repo via a per-repo seen set ---
|
||||
# _broadcast/seen/<repo> holds one delivered broadcast filename per line.
|
||||
# Order-independent: replaces the old single high-water mark, which silently
|
||||
# dropped a same-second broadcast whose name sorted below one already seen.
|
||||
BC_INBOX="$COORD/_broadcast/inbox"
|
||||
SEEN_DIR="$COORD/_broadcast/seen"
|
||||
SEEN_FILE="$SEEN_DIR/$REPO"
|
||||
if [ -d "$BC_INBOX" ]; then
|
||||
watermark=""
|
||||
[ -f "$SEEN_FILE" ] && watermark="$(cat "$SEEN_FILE" 2>/dev/null)"
|
||||
newest="$watermark"
|
||||
for f in "$BC_INBOX"/*.md; do
|
||||
[ -e "$f" ] || continue
|
||||
fname="$(basename "$f")"
|
||||
# fixed-width ASCII ts prefix + LC_ALL=C -> lexical compare is chronological
|
||||
if [ -z "$watermark" ] || [[ "$fname" > "$watermark" ]]; then
|
||||
# Same untrusted-data escaping as the directed inbox above.
|
||||
body="$(sed 's/^/> /' "$f" 2>/dev/null)"
|
||||
OUT="${OUT}
|
||||
if [ -f "$SEEN_FILE" ] && grep -Fxq "$fname" "$SEEN_FILE" 2>/dev/null; then
|
||||
continue
|
||||
fi
|
||||
# Same untrusted-data escaping as the directed inbox above.
|
||||
body="$(sed 's/^/> /' "$f" 2>/dev/null)"
|
||||
OUT="${OUT}
|
||||
--- broadcast: ${fname} ---
|
||||
${body}
|
||||
"
|
||||
COUNT=$((COUNT + 1))
|
||||
[[ "$fname" > "$newest" ]] && newest="$fname"
|
||||
fi
|
||||
COUNT=$((COUNT + 1))
|
||||
mkdir -p "$SEEN_DIR" 2>/dev/null && printf '%s\n' "$fname" >> "$SEEN_FILE" 2>/dev/null
|
||||
done
|
||||
if [ -n "$newest" ] && [ "$newest" != "$watermark" ]; then
|
||||
mkdir -p "$SEEN_DIR" 2>/dev/null && printf '%s\n' "$newest" > "$SEEN_FILE" 2>/dev/null
|
||||
fi
|
||||
fi
|
||||
|
||||
[ "$COUNT" -eq 0 ] && exit 0
|
||||
|
|
|
|||
|
|
@ -126,7 +126,23 @@ printf '%s' "$vout" | grep -q 'IKKE-KLARERT'; check "header frames content as un
|
|||
bout="$("$INBOX" --repo bc-victim)"
|
||||
[ "$(printf '%s\n' "$bout" | grep -c '^--- broadcast: forged')" -eq 0 ]; check "broadcast body cannot forge a broadcast separator" $?
|
||||
|
||||
# 10. Send-side input hygiene: CR/LF in subject/from cannot inject frontmatter.
|
||||
# 10. Broadcast delivery must not depend on name order within a second: a
|
||||
# broadcast written after another but sorting lexically below it (same
|
||||
# timestamp prefix, smaller uniq part) must still be delivered.
|
||||
mkdir -p "$CLAUDE_COORD_DIR/_broadcast/inbox"
|
||||
printf -- '---\nfrom: x\nto: broadcast\nsubject: first\ndate: d\n---\nFIRST-BC\n' \
|
||||
> "$CLAUDE_COORD_DIR/_broadcast/inbox/20990101T000000Z-500-from-x.md"
|
||||
o1="$("$INBOX" --repo order-victim)"
|
||||
printf '%s' "$o1" | grep -q 'FIRST-BC'; check "same-second pair: first broadcast delivered" $?
|
||||
printf -- '---\nfrom: y\nto: broadcast\nsubject: second\ndate: d\n---\nSECOND-BC\n' \
|
||||
> "$CLAUDE_COORD_DIR/_broadcast/inbox/20990101T000000Z-100-from-y.md"
|
||||
o2="$("$INBOX" --repo order-victim)"
|
||||
printf '%s' "$o2" | grep -q 'SECOND-BC'; check "same-second broadcast sorting below a seen one is still delivered" $?
|
||||
[ "$(printf '%s' "$o2" | grep -c 'FIRST-BC')" -eq 0 ]; check "already-seen broadcast not re-delivered alongside it" $?
|
||||
o3="$("$INBOX" --repo order-victim)"
|
||||
[ -z "$o3" ]; check "nothing re-delivered once both are seen" $?
|
||||
|
||||
# 11. Send-side input hygiene: CR/LF in subject/from cannot inject frontmatter.
|
||||
"$SEND" --to hygiene --from $'bad\nfrom' --subject $'legit\nfrom: attacker\n---\nINJECTED' \
|
||||
--message "clean body" >/dev/null
|
||||
hf="$(ls "$CLAUDE_COORD_DIR"/hygiene/inbox/*.md 2>/dev/null | head -1)"
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue