set -uo pipefail

PM="/shared/projects/zion-pm"

VOICE="$PM/inbox/voice"; DONE="$VOICE/processed"

STT="${PM_STT_URL:-http://REDACTED-IP:8770/v1/audio/transcriptions}"

MODEL="${PM_STT_MODEL:-large-v3-turbo}"

mkdir -p "$VOICE" "$DONE"

shopt -s nullglob

files=("$VOICE"/*.{m4a,mp3,wav,ogg,flac,aac})

[ "${#files[@]}" -eq 0 ] && { echo "[intake-voice] no audio in $VOICE"; exit 0; }

for f in "${files[@]}"; do

  echo "[intake-voice] transcribing $(basename "$f")"

  TXT=$(curl -s -m 180 "$STT" -F "file=@$f" -F "model=$MODEL" -F "response_format=text" 2>/dev/null)

  TXT=$(printf '%s' "$TXT" | tr '\n' ' ' | sed 's/^[[:space:]]*//;s/[[:space:]]*$//')

  if [ -z "$TXT" ]; then

    echo "  -> empty transcript (STT down? check the sidecar). Leaving file in place."

    continue

  fi

  echo "  -> \"$TXT\""

  bash "$PM/bin/pm" add "$TXT" --type misc >/dev/null

  python3 - "$PM/state/activity.jsonl" "$(basename "$f")" "$TXT" <<'PY'

import json,sys,time

path,fn,txt=sys.argv[1:4]

open(path,"a").write(json.dumps({"ts":time.strftime("%Y-%m-%dT%H:%M:%S"),"event":"intake_voice","file":fn,"text":txt[:120]})+"\n")

PY

  mv "$f" "$DONE/"

done

echo "[intake-voice] done"