mosaicstack/stack
1
0
Fork 0
Code Issues 88 Pull Requests Actions Packages Projects Releases 15 Wiki Activity

feat(framework): accept digest message class in agent-send.sh (W1) (#894)
Some checks failed
ci/woodpecker/push/publish Pipeline was canceled
Details
ci/woodpecker/push/ci Pipeline was canceled
Details

Browse Source 
Co-authored-by: jason.woltje <jason@diversecanvas.com>
Co-committed-by: jason.woltje <jason@diversecanvas.com>
This commit was merged in pull request #894.
This commit is contained in:
jason.woltje
2026-07-25 22:56:46 +00:00
committed by Mos
parent 48a0c86093
commit 1933c6cb1d
2 changed files with 23 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
packages/mosaic/framework/tools/tmux/agent-send.sh
View File

@@ -46,6 +46,7 @@
# actionable carries a decision/blocker/gate — deliver # actionable carries a decision/blocker/gate — deliver
# human from a human operator — deliver # human from a human operator — deliver
# reaction an emoji/ack reaction # reaction an emoji/ack reaction
# digest machine-wake, coalescible; batched wake/heartbeat signal
# Long form: --class CLASS (or --class=CLASS). When SET, the # Long form: --class CLASS (or --class=CLASS). When SET, the
# preamble carries a ` class=<CLASS>` token INSIDE the bracket: # preamble carries a ` class=<CLASS>` token INSIDE the bracket:
# [<src> -> <dst> class=terminal-log] <message> # [<src> -> <dst> class=terminal-log] <message>
@@ -58,7 +59,7 @@
# -h help # -h help
# #
# PREAMBLE GRAMMAR (for consumers / daemons mirroring this producer) # PREAMBLE GRAMMAR (for consumers / daemons mirroring this producer)
# ^\[(\S+) -> (\S+?)(?: class=(terminal-log|actionable|human|reaction))?\] (.*)$ # ^\[(\S+) -> (\S+?)(?: class=(terminal-log|actionable|human|reaction|digest))?\] (.*)$
# group 1 = src label group 2 = dst host:session # group 1 = src label group 2 = dst host:session
# group 3 = class (absent => actionable) group 4 = message body # group 3 = class (absent => actionable) group 4 = message body
# #
@@ -109,8 +110,8 @@ done
CLASS_TOKEN="" CLASS_TOKEN=""
if [ -n "$CLASS" ]; then if [ -n "$CLASS" ]; then
case "$CLASS" in case "$CLASS" in
terminal-log|actionable|human|reaction) CLASS_TOKEN=" class=${CLASS}" ;; terminal-log|actionable|human|reaction|digest) CLASS_TOKEN=" class=${CLASS}" ;;
*) echo "ERROR: invalid --class '$CLASS' (allowed: terminal-log, actionable, human, reaction)" >&2; exit 3 ;; *) echo "ERROR: invalid --class '$CLASS' (allowed: terminal-log, actionable, human, reaction, digest)" >&2; exit 3 ;;
esac esac
fi fi

21
packages/mosaic/framework/tools/tmux/agent-send.test.sh
View File

@@ -17,6 +17,9 @@
# 8. MOSAIC_AGENT_NAME is authoritative for sender identity. # 8. MOSAIC_AGENT_NAME is authoritative for sender identity.
# 9. sender fallback queries local tmux, never the destination -L socket. # 9. sender fallback queries local tmux, never the destination -L socket.
# 10. an undeterminable sender is stamped as "?". # 10. an undeterminable sender is stamped as "?".
# 11. --class digest is accepted (machine-wake, coalescible canon class).
# 12. -C digest short form parses identically.
# 13. the documented consumer regex parses producer output for class=digest.
set -uo pipefail set -uo pipefail
HERE=$(cd -- "$(dirname -- "$0")" && pwd) HERE=$(cd -- "$(dirname -- "$0")" && pwd)
@@ -65,7 +68,7 @@ run_auto() {
} }
# Documented consumer grammar — the daemon will mirror exactly this. # Documented consumer grammar — the daemon will mirror exactly this.
GRAMMAR='^\[(\S+) -> (\S+) class=(terminal-log|actionable|human|reaction)\] (.*)$' GRAMMAR='^\[(\S+) -> (\S+) class=(terminal-log|actionable|human|reaction|digest)\] (.*)$'
GRAMMAR_NOCLASS='^\[(\S+) -> (\S+)\] (.*)$' GRAMMAR_NOCLASS='^\[(\S+) -> (\S+)\] (.*)$'
# 1. REGRESSION BAR: classic preamble, byte-for-byte. # 1. REGRESSION BAR: classic preamble, byte-for-byte.
@@ -108,8 +111,22 @@ else
[ "$?" = 3 ] && ok "--class with no value => exit 3" || no "--class with no value => exit 3" "wrong rc" [ "$?" = 3 ] && ok "--class with no value => exit 3" || no "--class with no value => exit 3" "wrong rc"
fi fi
# 11. --class digest (space form) is accepted.
got=$(run -s mos --class digest -m "wake payload")
want='[a:src -> dsthost:mos class=digest] wake payload'
if [ "$got" = "$want" ]; then ok "--class digest emits token"
else no "--class digest emits token" "got=[$got] want=[$want]"
fi
# 12. -C digest short form.
got=$(run -s mos -C digest -m "coalesced wake")
want='[a:src -> dsthost:mos class=digest] coalesced wake'
if [ "$got" = "$want" ]; then ok "-C digest (short form)"
else no "-C digest (short form)" "got=[$got] want=[$want]"
fi
# 7. consumer grammar parses every class + classic line. # 7. consumer grammar parses every class + classic line.
for c in terminal-log actionable human reaction; do for c in terminal-log actionable human reaction digest; do
line=$(run -s mos --class "$c" -m "body $c") line=$(run -s mos --class "$c" -m "body $c")
[[ "$line" =~ $GRAMMAR ]] && [ "${BASH_REMATCH[3]}" = "$c" ] && [ "${BASH_REMATCH[4]}" = "body $c" ] \ [[ "$line" =~ $GRAMMAR ]] && [ "${BASH_REMATCH[3]}" = "$c" ] && [ "${BASH_REMATCH[4]}" = "body $c" ] \
&& ok "grammar parses class=$c" || no "grammar parses class=$c" "line=[$line]" && ok "grammar parses class=$c" || no "grammar parses class=$c" "line=[$line]"