mirror of
https://github.com/getpaseo/paseo.git
synced 2026-08-14 12:23:16 +00:00
416 lines
11 KiB
Bash
Executable File
416 lines
11 KiB
Bash
Executable File
#!/usr/bin/env bash
|
|
set -euo pipefail
|
|
|
|
usage() {
|
|
cat <<'EOF'
|
|
Usage:
|
|
chat.sh room create --room ROOM [--title TITLE] [--purpose PURPOSE]
|
|
chat.sh room list
|
|
chat.sh room show --room ROOM
|
|
chat.sh post --room ROOM (--body TEXT | --body-file PATH) [--agent-id ID] [--agent-name NAME] [--reply-to MESSAGE_ID]
|
|
chat.sh read --room ROOM [--limit N] [--since ISO_TIMESTAMP] [--agent-id ID]
|
|
|
|
Options:
|
|
--root PATH Override chat root (default: ~/.paseo/chat)
|
|
EOF
|
|
exit 1
|
|
}
|
|
|
|
yaml_quote() {
|
|
local value="${1//\'/\'\'}"
|
|
printf "'%s'" "$value"
|
|
}
|
|
|
|
require_command() {
|
|
local name="$1"
|
|
command -v "$name" >/dev/null 2>&1 || {
|
|
echo "Error: required command not found: $name" >&2
|
|
exit 1
|
|
}
|
|
}
|
|
|
|
sanitize_room_path() {
|
|
local room="$1"
|
|
if [[ -z "$room" || "$room" == /* || "$room" == *".."* ]]; then
|
|
echo "Error: invalid room id: $room" >&2
|
|
exit 1
|
|
fi
|
|
}
|
|
|
|
load_body() {
|
|
local inline_value="$1"
|
|
local file_value="$2"
|
|
|
|
if [[ -n "$inline_value" && -n "$file_value" ]]; then
|
|
echo "Error: use either --body or --body-file, not both" >&2
|
|
exit 1
|
|
fi
|
|
|
|
if [[ -n "$file_value" ]]; then
|
|
[[ -f "$file_value" ]] || { echo "Error: --body-file not found: $file_value" >&2; exit 1; }
|
|
cat "$file_value"
|
|
return
|
|
fi
|
|
|
|
if [[ -n "$inline_value" ]]; then
|
|
printf '%s' "$inline_value"
|
|
return
|
|
fi
|
|
|
|
echo "Error: one of --body or --body-file is required" >&2
|
|
exit 1
|
|
}
|
|
|
|
frontmatter_value() {
|
|
local key="$1"
|
|
local file="$2"
|
|
awk -F': ' -v search_key="$key" '
|
|
BEGIN { in_frontmatter = 0 }
|
|
/^---$/ {
|
|
if (in_frontmatter == 0) {
|
|
in_frontmatter = 1
|
|
next
|
|
}
|
|
exit
|
|
}
|
|
in_frontmatter == 1 && $1 == search_key {
|
|
value = substr($0, length(search_key) + 3)
|
|
gsub(/^'\''|'\''$/, "", value)
|
|
print value
|
|
exit
|
|
}
|
|
' "$file"
|
|
}
|
|
|
|
print_message() {
|
|
local file="$1"
|
|
local created_at agent_id agent_name reply_to message_id
|
|
created_at="$(frontmatter_value "created_at" "$file")"
|
|
agent_id="$(frontmatter_value "agent_id" "$file")"
|
|
agent_name="$(frontmatter_value "agent_name" "$file")"
|
|
reply_to="$(frontmatter_value "reply_to" "$file")"
|
|
message_id="$(frontmatter_value "message_id" "$file")"
|
|
|
|
printf '### %s · %s' "$created_at" "$agent_id"
|
|
if [[ -n "$agent_name" ]]; then
|
|
printf ' (%s)' "$agent_name"
|
|
fi
|
|
printf '\n'
|
|
printf 'message_id: %s\n' "$message_id"
|
|
if [[ -n "$reply_to" ]]; then
|
|
printf 'reply_to: %s\n' "$reply_to"
|
|
fi
|
|
printf '\n'
|
|
|
|
awk '
|
|
BEGIN { delim_count = 0 }
|
|
/^---$/ {
|
|
delim_count += 1
|
|
next
|
|
}
|
|
delim_count >= 2 {
|
|
print
|
|
}
|
|
' "$file"
|
|
printf '\n'
|
|
}
|
|
|
|
require_room() {
|
|
local room="$1"
|
|
local room_dir="$rooms_root/$room"
|
|
[[ -d "$room_dir" ]] || { echo "Error: room not found: $room" >&2; exit 1; }
|
|
}
|
|
|
|
find_message_file_by_id() {
|
|
local room="$1"
|
|
local message_id="$2"
|
|
find "$rooms_root/$room/messages" -name '*.md' -type f -print0 |
|
|
while IFS= read -r -d '' file; do
|
|
if [[ "$(frontmatter_value "message_id" "$file")" == "$message_id" ]]; then
|
|
printf '%s\n' "$file"
|
|
return 0
|
|
fi
|
|
done
|
|
}
|
|
|
|
extract_mentions() {
|
|
local body="$1"
|
|
printf '%s\n' "$body" | grep -oE '@[A-Za-z0-9._:-]+' | sed 's/^@//' | awk '!seen[$0]++'
|
|
}
|
|
|
|
notify_agent() {
|
|
local target_agent_id="$1"
|
|
local room="$2"
|
|
local sender_agent_id="$3"
|
|
local sender_agent_name="$4"
|
|
local message_id="$5"
|
|
local reason="$6"
|
|
|
|
if [[ -z "$target_agent_id" || "$target_agent_id" == "manual" || "$target_agent_id" == "$sender_agent_id" ]]; then
|
|
return
|
|
fi
|
|
|
|
local sender_label="$sender_agent_id"
|
|
if [[ -n "$sender_agent_name" ]]; then
|
|
sender_label="$sender_agent_name ($sender_agent_id)"
|
|
fi
|
|
|
|
local notification="You have a new chat message.
|
|
|
|
Room: $room
|
|
From: $sender_label
|
|
Message ID: $message_id
|
|
Reason: $reason
|
|
|
|
To read it:
|
|
skills/paseo-chat/bin/chat.sh read --room $room --limit 10"
|
|
|
|
"$paseo_bin" send --no-wait "$target_agent_id" "$notification" >/dev/null 2>&1 || true
|
|
}
|
|
|
|
require_command uuidgen
|
|
|
|
chat_root="${HOME}/.paseo/chat"
|
|
paseo_bin="${PASEO_CHAT_PASEO_BIN:-paseo}"
|
|
|
|
if [[ $# -lt 1 ]]; then
|
|
usage
|
|
fi
|
|
|
|
if [[ "$1" == "--root" ]]; then
|
|
[[ $# -ge 3 ]] || usage
|
|
chat_root="$2"
|
|
shift 2
|
|
fi
|
|
|
|
rooms_root="${chat_root}/rooms"
|
|
mkdir -p "$rooms_root"
|
|
|
|
command_name="$1"
|
|
shift
|
|
|
|
case "$command_name" in
|
|
room)
|
|
[[ $# -ge 1 ]] || usage
|
|
room_subcommand="$1"
|
|
shift
|
|
|
|
case "$room_subcommand" in
|
|
create)
|
|
room=""
|
|
title=""
|
|
purpose=""
|
|
|
|
while [[ $# -gt 0 ]]; do
|
|
case "$1" in
|
|
--room) room="$2"; shift 2 ;;
|
|
--title) title="$2"; shift 2 ;;
|
|
--purpose) purpose="$2"; shift 2 ;;
|
|
*) echo "Unknown option: $1" >&2; usage ;;
|
|
esac
|
|
done
|
|
|
|
[[ -n "$room" ]] || { echo "Error: --room is required" >&2; exit 1; }
|
|
sanitize_room_path "$room"
|
|
|
|
room_dir="$rooms_root/$room"
|
|
messages_dir="$room_dir/messages"
|
|
mkdir -p "$messages_dir"
|
|
|
|
if [[ -z "$title" ]]; then
|
|
title="$room"
|
|
fi
|
|
|
|
created_at="$(date -u +'%Y-%m-%dT%H:%M:%SZ')"
|
|
room_file="$room_dir/room.md"
|
|
if [[ ! -f "$room_file" ]]; then
|
|
printf '%s\n' \
|
|
"---" \
|
|
"room: $(yaml_quote "$room")" \
|
|
"title: $(yaml_quote "$title")" \
|
|
"purpose: $(yaml_quote "$purpose")" \
|
|
"created_at: $(yaml_quote "$created_at")" \
|
|
"---" \
|
|
"" \
|
|
"# $(printf '%s' "$title")" \
|
|
"" \
|
|
"$(printf '%s' "$purpose")" > "$room_file"
|
|
fi
|
|
|
|
printf 'created room %s\n' "$room"
|
|
;;
|
|
|
|
list)
|
|
while IFS= read -r room_file; do
|
|
room_id="${room_file#"$rooms_root"/}"
|
|
room_id="${room_id%/room.md}"
|
|
printf '%s\n' "$room_id"
|
|
done < <(find "$rooms_root" -name room.md -type f | sort)
|
|
;;
|
|
|
|
show)
|
|
room=""
|
|
while [[ $# -gt 0 ]]; do
|
|
case "$1" in
|
|
--room) room="$2"; shift 2 ;;
|
|
*) echo "Unknown option: $1" >&2; usage ;;
|
|
esac
|
|
done
|
|
|
|
[[ -n "$room" ]] || { echo "Error: --room is required" >&2; exit 1; }
|
|
sanitize_room_path "$room"
|
|
require_room "$room"
|
|
|
|
room_file="$rooms_root/$room/room.md"
|
|
title="$(frontmatter_value "title" "$room_file")"
|
|
purpose="$(frontmatter_value "purpose" "$room_file")"
|
|
created_at="$(frontmatter_value "created_at" "$room_file")"
|
|
message_count="$(find "$rooms_root/$room/messages" -name '*.md' -type f | wc -l | tr -d ' ')"
|
|
|
|
printf 'room: %s\n' "$room"
|
|
printf 'title: %s\n' "$title"
|
|
printf 'purpose: %s\n' "$purpose"
|
|
printf 'created_at: %s\n' "$created_at"
|
|
printf 'messages: %s\n' "$message_count"
|
|
;;
|
|
|
|
*)
|
|
usage
|
|
;;
|
|
esac
|
|
;;
|
|
|
|
post)
|
|
room=""
|
|
body_input=""
|
|
body_file=""
|
|
agent_id="${PASEO_AGENT_ID:-manual}"
|
|
agent_name=""
|
|
reply_to=""
|
|
|
|
while [[ $# -gt 0 ]]; do
|
|
case "$1" in
|
|
--room) room="$2"; shift 2 ;;
|
|
--body) body_input="$2"; shift 2 ;;
|
|
--body-file) body_file="$2"; shift 2 ;;
|
|
--agent-id) agent_id="$2"; shift 2 ;;
|
|
--agent-name) agent_name="$2"; shift 2 ;;
|
|
--reply-to) reply_to="$2"; shift 2 ;;
|
|
*) echo "Unknown option: $1" >&2; usage ;;
|
|
esac
|
|
done
|
|
|
|
[[ -n "$room" ]] || { echo "Error: --room is required" >&2; exit 1; }
|
|
sanitize_room_path "$room"
|
|
require_room "$room"
|
|
body="$(load_body "$body_input" "$body_file")"
|
|
|
|
created_at="$(date -u +'%Y-%m-%dT%H:%M:%SZ')"
|
|
created_at_file="$(date -u +'%Y-%m-%dT%H-%M-%SZ')"
|
|
message_id="msg-$(uuidgen | tr '[:upper:]' '[:lower:]' | tr -d '-' | cut -c1-8)"
|
|
agent_slug="$(printf '%s' "$agent_id" | tr '/ :@' '_' | tr -cd '[:alnum:]_.-')"
|
|
[[ -n "$agent_slug" ]] || agent_slug="manual"
|
|
message_file="$rooms_root/$room/messages/${created_at_file}__${agent_slug}__${message_id}.md"
|
|
|
|
printf '%s\n' \
|
|
"---" \
|
|
"room: $(yaml_quote "$room")" \
|
|
"message_id: $(yaml_quote "$message_id")" \
|
|
"agent_id: $(yaml_quote "$agent_id")" \
|
|
"agent_name: $(yaml_quote "$agent_name")" \
|
|
"created_at: $(yaml_quote "$created_at")" \
|
|
"reply_to: $(yaml_quote "$reply_to")" \
|
|
"---" \
|
|
"" \
|
|
"$body" > "$message_file"
|
|
|
|
notified_agents=()
|
|
if [[ -n "$reply_to" ]]; then
|
|
reply_file="$(find_message_file_by_id "$room" "$reply_to" || true)"
|
|
if [[ -n "$reply_file" ]]; then
|
|
reply_target_agent_id="$(frontmatter_value "agent_id" "$reply_file")"
|
|
notify_agent "$reply_target_agent_id" "$room" "$agent_id" "$agent_name" "$message_id" "reply to $reply_to"
|
|
notified_agents+=("$reply_target_agent_id")
|
|
fi
|
|
fi
|
|
|
|
while IFS= read -r mentioned_agent_id; do
|
|
[[ -n "$mentioned_agent_id" ]] || continue
|
|
already_notified=false
|
|
for existing_id in "${notified_agents[@]}"; do
|
|
if [[ "$existing_id" == "$mentioned_agent_id" ]]; then
|
|
already_notified=true
|
|
break
|
|
fi
|
|
done
|
|
if [[ "$already_notified" == false ]]; then
|
|
notify_agent "$mentioned_agent_id" "$room" "$agent_id" "$agent_name" "$message_id" "direct mention"
|
|
notified_agents+=("$mentioned_agent_id")
|
|
fi
|
|
done < <(extract_mentions "$body")
|
|
|
|
printf '%s\n' "$message_id"
|
|
;;
|
|
|
|
read)
|
|
room=""
|
|
limit="20"
|
|
since=""
|
|
agent_id_filter=""
|
|
|
|
while [[ $# -gt 0 ]]; do
|
|
case "$1" in
|
|
--room) room="$2"; shift 2 ;;
|
|
--limit) limit="$2"; shift 2 ;;
|
|
--since) since="$2"; shift 2 ;;
|
|
--agent-id) agent_id_filter="$2"; shift 2 ;;
|
|
*) echo "Unknown option: $1" >&2; usage ;;
|
|
esac
|
|
done
|
|
|
|
[[ -n "$room" ]] || { echo "Error: --room is required" >&2; exit 1; }
|
|
sanitize_room_path "$room"
|
|
require_room "$room"
|
|
|
|
messages_dir="$rooms_root/$room/messages"
|
|
mapfile -t all_files < <(find "$messages_dir" -name '*.md' -type f | sort)
|
|
|
|
filtered_files=()
|
|
for file in "${all_files[@]}"; do
|
|
created_at="$(frontmatter_value "created_at" "$file")"
|
|
file_agent_id="$(frontmatter_value "agent_id" "$file")"
|
|
|
|
if [[ -n "$since" && "$created_at" < "$since" ]]; then
|
|
continue
|
|
fi
|
|
if [[ -n "$agent_id_filter" && "$file_agent_id" != "$agent_id_filter" ]]; then
|
|
continue
|
|
fi
|
|
|
|
filtered_files+=("$file")
|
|
done
|
|
|
|
start_index=0
|
|
if [[ "$limit" != "all" ]]; then
|
|
if ! [[ "$limit" =~ ^[0-9]+$ ]]; then
|
|
echo "Error: --limit must be a number or 'all'" >&2
|
|
exit 1
|
|
fi
|
|
if [[ "${#filtered_files[@]}" -gt "$limit" ]]; then
|
|
start_index=$((${#filtered_files[@]} - limit))
|
|
fi
|
|
fi
|
|
|
|
for ((index = start_index; index < ${#filtered_files[@]}; index += 1)); do
|
|
print_message "${filtered_files[$index]}"
|
|
if [[ $index -lt $((${#filtered_files[@]} - 1)) ]]; then
|
|
printf -- '---\n\n'
|
|
fi
|
|
done
|
|
;;
|
|
|
|
*)
|
|
usage
|
|
;;
|
|
esac
|