vibecoding/podx
1
0
Fork 0
Code Issues 4 Pull Requests Actions Packages Projects Releases Wiki Activity

Podx tools patch

Browse Source
This commit is contained in:
Tomas Kracmar
2025-09-11 15:42:44 +02:00
parent 0da1f74944
commit 4ff851aaa0
1 changed files with 165 additions and 391 deletions
Download Patch File Download Diff File Expand all files Collapse all files

524
scripts/podx-tools.sh
View File

@@ -1,17 +1,13 @@
#!/usr/bin/env bash #!/usr/bin/env bash
# podx-tools.sh — host-side helper for Meili + OpenWebUI # podx-tools.sh — host-side helper for Meili + OpenWebUI (+ worker switches)
# Usage: ./scripts/podx-tools.sh <command> [args...] # Usage: ./scripts/podx-tools.sh <command> [args...]
# Run without args to see help. # Run without args to see help.
set -euo pipefail set -euo pipefail
# Determine repo root early (used by temp dir and .env loader) # ------------------------------ Paths / tmp ------------------------------
ROOT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")/.." && pwd)" ROOT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")/.." && pwd)"
# Writable temp dir (override with PODX_TMP or TMPDIR); default to repo tmp/
: "${PODX_TMP:=${TMPDIR:-$ROOT_DIR/tmp}}" : "${PODX_TMP:=${TMPDIR:-$ROOT_DIR/tmp}}"
mkdir -p "$PODX_TMP" mkdir -p "$PODX_TMP"
# Curl timeouts used for OWUI/Meili requests (override via env if needed) # Curl timeouts used for OWUI/Meili requests (override via env if needed)
@@ -20,15 +16,12 @@ mkdir -p "$PODX_TMP"
CURL_TMO="--connect-timeout $PODX_CURL_CONNECT_TIMEOUT --max-time $PODX_CURL_MAX_TIME" CURL_TMO="--connect-timeout $PODX_CURL_CONNECT_TIMEOUT --max-time $PODX_CURL_MAX_TIME"
# Portable mktemp helper that always writes inside $PODX_TMP (macOS/GNU compatible) # Portable mktemp helper that always writes inside $PODX_TMP (macOS/GNU compatible)
_mktemp() { _mktemp() { mktemp "$PODX_TMP/podx.XXXXXX"; }
# mktemp on macOS doesn't support -p; use path template instead
mktemp "$PODX_TMP/podx.XXXXXX"
}
# ---------- Pretty-print JSON (no jq required) ---------- # ------------------------------ Pretty JSON ------------------------------
ppjson() { ppjson() {
if command -v python3 >/dev/null 2>&1; then if command -v python3 >/dev/null 2>&1; then
python3 -m json.tool || cat python3 -m json.tool 2>/dev/null || cat
elif command -v jq >/dev/null 2>&1; then elif command -v jq >/dev/null 2>&1; then
jq . jq .
elif command -v node >/dev/null 2>&1; then elif command -v node >/dev/null 2>&1; then
@@ -38,72 +31,40 @@ ppjson() {
fi fi
} }
# ---------- Load .env from repo root (robust, handles spaces & ${VAR}) ---------- # ------------------------------ Load .env ------------------------------
ENV_FILE="$ROOT_DIR/.env" ENV_FILE="$ROOT_DIR/.env"
if [ -f "$ENV_FILE" ]; then if [ -f "$ENV_FILE" ]; then
# Minimal .env parser:
# - ignores comments/blank lines
# - preserves spaces in values (quotes optional)
# - expands ${VAR} references using current environment / previously set keys
while IFS= read -r __line || [ -n "$__line" ]; do while IFS= read -r __line || [ -n "$__line" ]; do
# trim leading/trailing whitespace
__line="${__line#"${__line%%[![:space:]]*}"}" __line="${__line#"${__line%%[![:space:]]*}"}"
__line="${__line%"${__line##*[![:space:]]}"}" __line="${__line%"${__line##*[![:space:]]}"}"
# skip empty or comment
[ -z "$__line" ] && continue [ -z "$__line" ] && continue
[ "${__line:0:1}" = "#" ] && continue [ "${__line:0:1}" = "#" ] && continue
# split at first '='
case "$__line" in case "$__line" in
*=*) *=*) __key="${__line%%=*}"; __val="${__line#*=}";;
__key="${__line%%=*}" *) continue;;
__val="${__line#*=}"
;;
*)
continue
;;
esac esac
# strip surrounding quotes if present
if [[ "$__val" == \"*\" && "$__val" == *\" ]]; then if [[ "$__val" == \"*\" && "$__val" == *\" ]]; then
__val="${__val:1:${#__val}-2}" __val="${__val:1:${#__val}-2}"
elif [[ "$__val" == \'*\' && "$__val" == *\' ]]; then elif [[ "$__val" == \'*\' && "$__val" == *\' ]]; then
__val="${__val:1:${#__val}-2}" __val="${__val:1:${#__val}-2}"
fi fi
# expand ${VAR} references
eval "__val_expanded=\"${__val}\"" eval "__val_expanded=\"${__val}\""
export "${__key}=${__val_expanded}" export "${__key}=${__val_expanded}"
done < "$ENV_FILE" done < "$ENV_FILE"
unset __line __key __val __val_expanded unset __line __key __val __val_expanded
fi fi
# ---------- Defaults (can be overridden by .env) ---------- # ------------------------------ Defaults ------------------------------
: "${MEILI_URL:=http://localhost:7700}" : "${MEILI_URL:=http://localhost:7700}"
: "${MEILI_KEY:=${MEILI_MASTER_KEY:-}}" : "${MEILI_KEY:=${MEILI_MASTER_KEY:-}}"
: "${OPENWEBUI_URL:=http://localhost:3003}" : "${OPENWEBUI_URL:=http://localhost:3003}"
: "${OPENWEBUI_URL_HOST:=}" : "${OPENWEBUI_URL_HOST:=}"
: "${OPENWEBUI_API_KEY:=}" : "${OPENWEBUI_API_KEY:=}"
# Optional: explicit KB id to use for all KB operations (bypasses name resolution)
: "${OPENWEBUI_KB_ID:=}" : "${OPENWEBUI_KB_ID:=}"
# Max seconds to wait for OWUI to finish extracting file content before attach
: "${OPENWEBUI_WAIT_SECS:=180}" : "${OPENWEBUI_WAIT_SECS:=180}"
# Resolve a working OpenWebUI base URL (fallback from host.docker.internal -> localhost) # ------------------------------ Helpers ------------------------------
_owui_url() {
# If a host-only override is provided, prefer it unconditionally
local host_u="${OPENWEBUI_URL_HOST:-}"
if [ -n "$host_u" ]; then
echo "$host_u"
return
fi
# Otherwise use OPENWEBUI_URL (defaulting to localhost), and rewrite
# host.docker.internal -> localhost so it always resolves on the host
local u="${OPENWEBUI_URL:-http://localhost:3003}"
u="${u//host.docker.internal/localhost}"
echo "$u"
}
# ---------- Helpers ----------
_require() { _require() {
local name="$1" val="${2:-}" local name="$1" val="${2:-}"
if [ -z "$val" ]; then if [ -z "$val" ]; then
@@ -112,11 +73,20 @@ _require() {
fi fi
} }
_owui_url() {
local host_u="${OPENWEBUI_URL_HOST:-}"
if [ -n "$host_u" ]; then
echo "$host_u"; return
fi
local u="${OPENWEBUI_URL:-http://localhost:3003}"
u="${u//host.docker.internal/localhost}"
echo "$u"
}
_owui_get_kb_list() { _owui_get_kb_list() {
_require "OPENWEBUI_API_KEY" "$OPENWEBUI_API_KEY" _require "OPENWEBUI_API_KEY" "$OPENWEBUI_API_KEY"
_require "OPENWEBUI_URL" "$OPENWEBUI_URL" _require "OPENWEBUI_URL" "$OPENWEBUI_URL"
local url; url="$(_owui_url)/api/v1/knowledge/list" curl -sS $CURL_TMO -H "Authorization: Bearer $OPENWEBUI_API_KEY" "$(_owui_url)/api/v1/knowledge/list"
curl -sS $CURL_TMO -H "Authorization: Bearer $OPENWEBUI_API_KEY" "$url"
} }
_kb_create() { _kb_create() {
@@ -132,105 +102,72 @@ _kb_create() {
_kb_id_by_name() { _kb_id_by_name() {
local kb_name="$1" local kb_name="$1"
# If an explicit KB id is provided via env, use it directly
if [ -n "${OPENWEBUI_KB_ID:-}" ]; then if [ -n "${OPENWEBUI_KB_ID:-}" ]; then
echo "$OPENWEBUI_KB_ID" echo "$OPENWEBUI_KB_ID"; return 0
return 0
fi fi
local json; json="$(_owui_get_kb_list)" local json; json="$(_owui_get_kb_list)"
local __id="" local __id=""
__id=$(printf '%s' "$json" | python3 - "$kb_name" <<'PY' __id=$(printf '%s' "$json" | python3 - "$kb_name" <<'PY'
import sys, json, unicodedata as ud import sys, json, unicodedata as ud
def norm(s): return ud.normalize('NFKC', (s or '')).strip().casefold()
def norm(s: str) -> str:
s = ud.normalize('NFKC', s or '')
return s.strip().casefold()
want = norm(sys.argv[1] if len(sys.argv)>1 else '') want = norm(sys.argv[1] if len(sys.argv)>1 else '')
raw = sys.stdin.read().strip() raw = sys.stdin.read().strip()
if not raw: if not raw: print('', end=''); raise SystemExit(0)
print('', end=''); raise SystemExit(0) try: d = json.loads(raw)
try: except: print('', end=''); raise SystemExit(0)
d = json.loads(raw)
except Exception:
print('', end=''); raise SystemExit(0)
items = d.get('data') if isinstance(d, dict) and isinstance(d.get('data'), list) else (d if isinstance(d, list) else []) items = d.get('data') if isinstance(d, dict) and isinstance(d.get('data'), list) else (d if isinstance(d, list) else [])
# If only one KB exists, return it
if isinstance(items, list) and len(items)==1: if isinstance(items, list) and len(items)==1:
print(items[0].get('id',''), end=''); raise SystemExit(0) print(items[0].get('id',''), end=''); raise SystemExit(0)
# Prefer exact normalized name match
exact = [kb for kb in items if norm(kb.get('name')) == want] exact = [kb for kb in items if norm(kb.get('name')) == want]
if exact: if exact:
exact.sort(key=lambda kb: int(kb.get('updated_at') or kb.get('created_at') or 0), reverse=True) exact.sort(key=lambda kb: int(kb.get('updated_at') or kb.get('created_at') or 0), reverse=True)
print(exact[0].get('id',''), end=''); raise SystemExit(0) print(exact[0].get('id',''), end=''); raise SystemExit(0)
# Fallback: substring match
subs = [kb for kb in items if want and want in norm(kb.get('name'))] subs = [kb for kb in items if want and want in norm(kb.get('name'))]
if subs: if subs:
subs.sort(key=lambda kb: int(kb.get('updated_at') or kb.get('created_at') or 0), reverse=True) subs.sort(key=lambda kb: int(kb.get('updated_at') or kb.get('created_at') or 0), reverse=True)
print(subs[0].get('id',''), end=''); raise SystemExit(0) print(subs[0].get('id',''), end=''); raise SystemExit(0)
print('', end='') print('', end='')
PY PY
) )
if [ -z "${__id:-}" ] && command -v jq >/dev/null 2>&1; then
# If python resolution failed, try jq (if available)
if [ -z "${__id:-}" ]; then
if command -v jq >/dev/null 2>&1; then
__id=$(printf '%s' "$json" | jq -r ' __id=$(printf '%s' "$json" | jq -r '
if type=="array" and length==1 then .[0].id // empty if type=="array" and length==1 then .[0].id // empty
elif type=="array" then (map(select((.name // "")|ascii_downcase==("'"$kb_name"'"|ascii_downcase))) | .[0].id) // empty elif type=="array" then (map(select((.name // "")|ascii_downcase==("'"$kb_name"'"|ascii_downcase))) | .[0].id) // empty
elif has("data") and (.data|type=="array") and (.data|length==1) then .data[0].id // empty elif has("data") and (.data|type=="array") and (.data|length==1) then .data[0].id // empty
else empty end') else empty end')
fi fi
fi
# Last resort: naive sed/grep — take the first id field
if [ -z "${__id:-}" ]; then if [ -z "${__id:-}" ]; then
__id=$(printf '%s' "$json" | sed -n 's/.*"id"[[:space:]]*:[[:space:]]*"\([^"]\+\)".*/\1/p' | head -n1) __id=$(printf '%s' "$json" | sed -n 's/.*"id"[[:space:]]*:[[:space:]]*"\([^"]\+\)".*/\1/p' | head -n1)
fi fi
printf '%s' "${__id:-}" printf '%s' "${__id:-}"
} }
# --- OWUI file helpers ------------------------------------------------------- # ------------------------------ OWUI file helpers ------------------------------
_owui_file_get() { _owui_file_get() {
# usage: _owui_file_get <file_id>
local fid="$1" local fid="$1"
curl -sS -H "Authorization: Bearer $OPENWEBUI_API_KEY" \ curl -sS -H "Authorization: Bearer $OPENWEBUI_API_KEY" "$(_owui_url)/api/v1/files/$fid"
"$(_owui_url)/api/v1/files/$fid"
} }
_owui_wait_file() { _owui_wait_file() {
# usage: _owui_wait_file <file_id> [timeout_secs] local fid="$1" timeout="${2:-120}"
local fid="$1" local start="$(date +%s)"
local timeout="${2:-120}" # default 2 minutes
local start now status content_len
start="$(date +%s)"
while :; do while :; do
now="$(date +%s)" local now="$(date +%s)"
if [ $((now - start)) -ge "$timeout" ]; then if [ $((now - start)) -ge "$timeout" ]; then return 1; fi
return 1
fi
# Fetch status and content length
read -r status content_len <<EOF read -r status content_len <<EOF
$(_owui_file_get "$fid" \ $(_owui_file_get "$fid" | python3 -c 'import sys,json
| python3 -c 'import sys, json
d=json.load(sys.stdin) d=json.load(sys.stdin)
s=((d.get("data") or {}).get("status") or "") s=((d.get("data") or {}).get("status") or "")
c=len(((d.get("data") or {}).get("content") or "")) c=len(((d.get("data") or {}).get("content") or ""))
print(s, c)') print(s, c)')
EOF EOF
[ "$status" = "completed" ] && [ "${content_len:-0}" -gt 0 ] && return 0 [ "${status:-}" = "completed" ] && [ "${content_len:-0}" -gt 0 ] && return 0
sleep 2 sleep 2
done done
} }
# --- Redis helpers (for pause/resume switches) ----------------------------- # ------------------------------ Redis toggles ------------------------------
_redis_cli() { _redis_cli() {
# Prefer dockerized redis if available; otherwise fall back to local redis-cli
if command -v docker >/dev/null 2>&1 && docker compose ps redis >/dev/null 2>&1; then if command -v docker >/dev/null 2>&1 && docker compose ps redis >/dev/null 2>&1; then
docker compose exec -T redis redis-cli "$@" docker compose exec -T redis redis-cli "$@"
elif command -v redis-cli >/dev/null 2>&1; then elif command -v redis-cli >/dev/null 2>&1; then
@@ -240,9 +177,9 @@ _redis_cli() {
return 1 return 1
fi fi
} }
_transcribe_key="podx:transcribe:paused" _transcribe_key="podx:transcribe:paused"
# ------------------------------ Help ------------------------------
_help() { _help() {
cat <<EOF cat <<EOF
podx-tools — Meili & OpenWebUI helpers podx-tools — Meili & OpenWebUI helpers
@@ -262,10 +199,10 @@ OpenWebUI:
owui-kb-id "<KB Name>" # print the KB UUID by exact name owui-kb-id "<KB Name>" # print the KB UUID by exact name
owui-kb-id-all "<KB Name>" # list all matching KB ids (if duplicates exist) owui-kb-id-all "<KB Name>" # list all matching KB ids (if duplicates exist)
owui-kb-resolve "<KB Name>" # debug name->id resolution with raw listing owui-kb-resolve "<KB Name>" # debug name->id resolution with raw listing
# Name resolution is Unicode/space-insensitive and prefers the most recently updated match. owui-upload </abs/path/file> # upload a file, prints file JSON
owui-upload </abs/path/file> # upload a file, prints file_id owui-attach "<KB Name>" </abs/path/file> # upload + attach to KB (waits for extraction)
owui-attach "<KB Name>" </abs/path/file> # upload + attach to KB
owui-attach-id <KB_ID> </abs/path/file> # upload + attach using explicit KB id owui-attach-id <KB_ID> </abs/path/file> # upload + attach using explicit KB id
owui-kb-files "<KB Name>" # list files for a KB (best-effort)
owui-kb-create "<KB Name>" # create a KB (prints JSON with id) owui-kb-create "<KB Name>" # create a KB (prints JSON with id)
owui-kbs-raw # raw JSON from /knowledge/list owui-kbs-raw # raw JSON from /knowledge/list
owui-batch-attach "<KB Name>" <glob> # attach all files matching glob owui-batch-attach "<KB Name>" <glob> # attach all files matching glob
@@ -281,130 +218,100 @@ Examples:
./scripts/podx-tools.sh owui-attach "Homelab Library" /mnt/.../episode.txt ./scripts/podx-tools.sh owui-attach "Homelab Library" /mnt/.../episode.txt
./scripts/podx-tools.sh owui-kb-files "Homelab Library" ./scripts/podx-tools.sh owui-kb-files "Homelab Library"
Environment comes from .env at repo root (MEILI_URL/KEY, OPENWEBUI_URL/API_KEY). Environment comes from .env at repo root (MEILI_URL/KEY, OPENWEBUI_URL/API_KEY, OPENWEBUI_KB_ID).
EOF EOF
} }
# ---------- Commands ---------- # ------------------------------ Commands ------------------------------
cmd="${1:-}" cmd="${1:-}"
case "$cmd" in case "$cmd" in
""|-h|--help|help) ""|-h|--help|help) _help ;;
_help
;;
# ---- Meili ---- # ---------- Meili ----------
meili-health) meili-health)
_require "MEILI_URL" "$MEILI_URL" _require "MEILI_URL" "$MEILI_URL"
curl -sS "$MEILI_URL/health" | ppjson curl -sS "$MEILI_URL/health" | ppjson
;; ;;
meili-keys) meili-keys)
_require "MEILI_URL" "$MEILI_URL" _require "MEILI_URL" "$MEILI_URL"; _require "MEILI_KEY" "$MEILI_KEY"
_require "MEILI_KEY" "$MEILI_KEY"
curl -sS -H "Authorization: Bearer $MEILI_KEY" "$MEILI_URL/keys" | ppjson curl -sS -H "Authorization: Bearer $MEILI_KEY" "$MEILI_URL/keys" | ppjson
;; ;;
meili-stats) meili-stats)
_require "MEILI_URL" "$MEILI_URL" _require "MEILI_URL" "$MEILI_URL"; _require "MEILI_KEY" "$MEILI_KEY"
_require "MEILI_KEY" "$MEILI_KEY"
curl -sS -H "Authorization: Bearer $MEILI_KEY" "$MEILI_URL/indexes/library/stats" | ppjson curl -sS -H "Authorization: Bearer $MEILI_KEY" "$MEILI_URL/indexes/library/stats" | ppjson
;; ;;
meili-tasks) meili-tasks)
_require "MEILI_URL" "$MEILI_URL" _require "MEILI_URL" "$MEILI_URL"; _require "MEILI_KEY" "$MEILI_KEY"
_require "MEILI_KEY" "$MEILI_KEY"
curl -sS -H "Authorization: Bearer $MEILI_KEY" "$MEILI_URL/tasks?limit=20&from=0" | ppjson curl -sS -H "Authorization: Bearer $MEILI_KEY" "$MEILI_URL/tasks?limit=20&from=0" | ppjson
;; ;;
meili-init) meili-init)
_require "MEILI_URL" "$MEILI_URL" _require "MEILI_URL" "$MEILI_URL"; _require "MEILI_KEY" "$MEILI_KEY"
_require "MEILI_KEY" "$MEILI_KEY"
# Create index if missing (idempotent-ish)
curl -sS -X POST -H "Authorization: Bearer $MEILI_KEY" -H "Content-Type: application/json" \ curl -sS -X POST -H "Authorization: Bearer $MEILI_KEY" -H "Content-Type: application/json" \
--data '{"uid":"library"}' \ --data '{"uid":"library"}' "$MEILI_URL/indexes" | ppjson
"$MEILI_URL/indexes" | ppjson
;; ;;
meili-search) meili-search)
shift || true shift || true; q="${1:-}"; lim="${2:-5}"
q="${1:-}" [ -z "$q" ] && { echo "Usage: meili-search \"<query>\" [limit]" >&2; exit 1; }
lim="${2:-5}" _require "MEILI_URL" "$MEILI_URL"; _require "MEILI_KEY" "$MEILI_KEY"
if [ -z "$q" ]; then echo "Usage: meili-search \"<query>\" [limit]" >&2; exit 1; fi
_require "MEILI_URL" "$MEILI_URL"
_require "MEILI_KEY" "$MEILI_KEY"
curl -sS -X POST -H "Authorization: Bearer $MEILI_KEY" -H "Content-Type: application/json" \ curl -sS -X POST -H "Authorization: Bearer $MEILI_KEY" -H "Content-Type: application/json" \
--data "{\"q\":\"$q\",\"limit\":$lim}" \ --data "{\"q\":\"$q\",\"limit\":$lim}" \
"$MEILI_URL/indexes/library/search" | ppjson "$MEILI_URL/indexes/library/search" | ppjson
;; ;;
meili-reindex) meili-reindex)
# Run inside the worker container; index all /transcripts/*.json if ! command -v docker >/dev/null 2>&1; then echo "docker not found on host" >&2; exit 1; fi
if ! command -v docker >/dev/null 2>&1; then
echo "docker not found on host" >&2; exit 1
fi
docker compose exec -T podx-worker sh -lc ' docker compose exec -T podx-worker sh -lc '
python -c "import json,glob,worker,sys; n=0 python - <<PY
for p in glob.glob(\"/transcripts/*.json\"): import json,glob,sys,pathlib
try: try:
worker.index_meili(__import__(\"pathlib\").Path(p)) import worker
print(f\"[meili] indexed {__import__(\"pathlib\").Path(p).name}\") except Exception as e:
print("[meili] import worker failed:", e, file=sys.stderr); sys.exit(1)
n=0
for p in glob.glob("/transcripts/*.json"):
try:
worker.index_meili(pathlib.Path(p))
print(f"[meili] indexed {pathlib.Path(p).name}")
n+=1 n+=1
except Exception as e: except Exception as e:
print(f\"[meili] FAILED {p}: {e}\", file=sys.stderr) print(f"[meili] FAILED {p}: {e}", file=sys.stderr)
print(f\"Indexed {n} document(s).\")" print(f"Indexed {n} document(s).")
PY
' '
;; ;;
# ---- OpenWebUI ---- # ---------- OpenWebUI ----------
# (debug) show resolved OpenWebUI URL for host-side calls
# echo "Using OWUI URL: $(_owui_url)" >&2
owui-health) owui-health)
_require "OPENWEBUI_URL" "$OPENWEBUI_URL" _require "OPENWEBUI_URL" "$OPENWEBUI_URL"
curl -sS $CURL_TMO -o /dev/null -w "%{http_code}\n" "$(_owui_url)/api/health" curl -sS $CURL_TMO -o /dev/null -w "%{http_code}\n" "$(_owui_url)/api/health"
;; ;;
owui-kbs) owui-kbs)
_require "OPENWEBUI_URL" "$OPENWEBUI_URL" _require "OPENWEBUI_URL" "$OPENWEBUI_URL"; _require "OPENWEBUI_API_KEY" "$OPENWEBUI_API_KEY"
_require "OPENWEBUI_API_KEY" "$OPENWEBUI_API_KEY" curl -sS $CURL_TMO -H "Authorization: Bearer $OPENWEBUI_API_KEY" "$(_owui_url)/api/v1/knowledge/list" | ppjson
curl -sS $CURL_TMO -H "Authorization: Bearer $OPENWEBUI_API_KEY" \
"$(_owui_url)/api/v1/knowledge/list" | ppjson
;; ;;
owui-kbs-raw) owui-kbs-raw)
_owui_get_kb_list | ppjson _owui_get_kb_list | ppjson
;; ;;
owui-kb-create) owui-kb-create)
shift || true shift || true; name="${1:-}"
name="${1:-}" [ -z "$name" ] && { echo "Usage: owui-kb-create \"<KB Name>\"" >&2; exit 1; }
if [ -z "$name" ]; then echo "Usage: owui-kb-create \"<KB Name>\"" >&2; exit 1; fi
_kb_create "$name" | ppjson _kb_create "$name" | ppjson
;; ;;
owui-kb-id) owui-kb-id)
shift || true shift || true; name="${1:-}"
name="${1:-}" [ -z "$name" ] && { echo "Usage: owui-kb-id \"<KB Name>\"" >&2; exit 1; }
if [ -z "$name" ]; then echo "Usage: owui-kb-id \"<KB Name>\"" >&2; exit 1; fi
_id="$(_kb_id_by_name "$name")" _id="$(_kb_id_by_name "$name")"
if [ -z "$_id" ]; then echo "KB '$name' not found" >&2; exit 1; fi [ -z "$_id" ] && { echo "KB '$name' not found" >&2; exit 1; }
echo "$_id" echo "$_id"
;; ;;
owui-kb-id-all) owui-kb-id-all)
shift || true shift || true; name="${1:-}"
name="${1:-}" [ -z "$name" ] && { echo "Usage: owui-kb-id-all \"<KB Name>\"" >&2; exit 1; }
if [ -z "$name" ]; then echo "Usage: owui-kb-id-all \"<KB Name>\"" >&2; exit 1; fi
_require "OPENWEBUI_API_KEY" "$OPENWEBUI_API_KEY"
_require "OPENWEBUI_URL" "$OPENWEBUI_URL"
_owui_get_kb_list | python3 - "$name" <<'PY' || exit 0 _owui_get_kb_list | python3 - "$name" <<'PY' || exit 0
import sys, json import sys, json
want = (sys.argv[1] or "").strip() want = (sys.argv[1] or "").strip()
raw = sys.stdin.read().strip() raw = sys.stdin.read().strip()
try: try: d = json.loads(raw)
d = json.loads(raw) except: sys.exit(0)
except Exception:
sys.exit(0)
items = d.get("data") if isinstance(d, dict) and isinstance(d.get("data"), list) else (d if isinstance(d, list) else []) items = d.get("data") if isinstance(d, dict) and isinstance(d.get("data"), list) else (d if isinstance(d, list) else [])
def norm(s): return (s or "").strip().casefold() def norm(s): return (s or "").strip().casefold()
want_n = norm(want) want_n = norm(want)
@@ -413,11 +320,9 @@ for kb in matches:
print(f"{kb.get('id','')}\t{kb.get('name','')}\tcreated_at={kb.get('created_at','')}\tupdated_at={kb.get('updated_at','')}") print(f"{kb.get('id','')}\t{kb.get('name','')}\tcreated_at={kb.get('created_at','')}\tupdated_at={kb.get('updated_at','')}")
PY PY
;; ;;
owui-kb-resolve) owui-kb-resolve)
shift || true shift || true; name="${1:-}"
name="${1:-}" [ -z "$name" ] && { echo "Usage: owui-kb-resolve \"<KB Name>\"" >&2; exit 1; }
if [ -z "$name" ]; then echo "Usage: owui-kb-resolve \"<KB Name>\"" >&2; exit 1; fi
echo "[owui] base URL: $(_owui_url)" echo "[owui] base URL: $(_owui_url)"
echo "[owui] KBs returned:" echo "[owui] KBs returned:"
tmp_body="$(_mktemp)"; tmp_code="$(_mktemp)" tmp_body="$(_mktemp)"; tmp_code="$(_mktemp)"
@@ -430,62 +335,37 @@ PY
echo "[owui] http_code=$http_code bytes=$bytes" echo "[owui] http_code=$http_code bytes=$bytes"
json="$(cat "$tmp_body")"; rm -f "$tmp_body" json="$(cat "$tmp_body")"; rm -f "$tmp_body"
id="$(_kb_id_by_name "$name")" id="$(_kb_id_by_name "$name")"
if [ -n "$id" ]; then if [ -n "$id" ]; then echo "[owui] resolved id for \"$name\": $id"
echo "[owui] resolved id for \"$name\": $id" else echo "[owui] could not resolve an id for \"$name\"" >&2
else
echo "[owui] could not resolve an id for \"$name\"" >&2
fi fi
;; ;;
owui-upload) owui-upload)
shift || true shift || true; file="${1:-}"
file="${1:-}" [ -z "$file" ] || [ ! -f "$file" ] && { echo "Usage: owui-upload </abs/path/file>" >&2; exit 1; }
if [ -z "$file" ] || [ ! -f "$file" ]; then echo "Usage: owui-upload </abs/path/file>" >&2; exit 1; fi _require "OPENWEBUI_URL" "$OPENWEBUI_URL"; _require "OPENWEBUI_API_KEY" "$OPENWEBUI_API_KEY"
_require "OPENWEBUI_URL" "$OPENWEBUI_URL"
_require "OPENWEBUI_API_KEY" "$OPENWEBUI_API_KEY"
tmp_body="$(_mktemp)"; tmp_code="$(_mktemp)" tmp_body="$(_mktemp)"; tmp_code="$(_mktemp)"
# write response body to tmp_body; write HTTP code to tmp_code; capture exit code from $?
curl -sS -H "Authorization: Bearer $OPENWEBUI_API_KEY" \ curl -sS -H "Authorization: Bearer $OPENWEBUI_API_KEY" \
-F "file=@$file" \ -F "file=@$file" \
-w "%{http_code}" --output "$tmp_body" "$(_owui_url)/api/v1/files/" >"$tmp_code" || true -w "%{http_code}" --output "$tmp_body" "$(_owui_url)/api/v1/files/" >"$tmp_code" || true
curl_exit=$? curl_exit=$?; http_code="$(cat "$tmp_code" 2>/dev/null || echo 0)"
http_code="$(cat "$tmp_code" 2>/dev/null || echo 0)"
cat "$tmp_body" | ppjson cat "$tmp_body" | ppjson
rm -f "$tmp_body" "$tmp_code" rm -f "$tmp_body" "$tmp_code"
[ $curl_exit -ne 0 ] && { echo "Upload failed: curl exit $curl_exit" >&2; exit $curl_exit; }
if [ $curl_exit -ne 0 ]; then [ "$http_code" != "200" ] && { echo "Upload failed (HTTP $http_code)" >&2; exit 1; }
echo "Upload failed: curl exit $curl_exit" >&2
exit $curl_exit
fi
if [ "$http_code" != "200" ]; then
echo "Upload failed (HTTP $http_code)" >&2
exit 1
fi
;; ;;
owui-attach) owui-attach)
shift || true shift || true; kb_name="${1:-}"; file="${2:-}"
kb_name="${1:-}"; file="${2:-}" [ -z "$kb_name" ] || [ -z "$file" ] || [ ! -f "$file" ] && { echo "Usage: owui-attach \"<KB Name>\" </abs/path/file>" >&2; exit 1; }
if [ -z "$kb_name" ] || [ -z "$file" ] || [ ! -f "$file" ]; then _require "OPENWEBUI_URL" "$OPENWEBUI_URL"; _require "OPENWEBUI_API_KEY" "$OPENWEBUI_API_KEY"
echo "Usage: owui-attach \"<KB Name>\" </abs/path/file>" >&2; exit 1
fi
_require "OPENWEBUI_URL" "$OPENWEBUI_URL"
_require "OPENWEBUI_API_KEY" "$OPENWEBUI_API_KEY"
TMP_EXTRACT="" TMP_EXTRACT=""
# Decide how to send the file (force text/plain for .txt/.md; optionally extract JSON->text)
upload_flag=("-F" "file=@$file") upload_flag=("-F" "file=@$file")
ext="${file##*.}" ext="${file##*.}"; base="$(basename "$file")"
base="$(basename "$file")"
if [[ "$ext" =~ ^([Tt][Xx][Tt]|[Mm][Dd]|[Mm][Aa][Rr][Kk][Dd][Oo][Ww][Nn])$ ]]; then if [[ "$ext" =~ ^([Tt][Xx][Tt]|[Mm][Dd]|[Mm][Aa][Rr][Kk][Dd][Oo][Ww][Nn])$ ]]; then
upload_flag=("-F" "file=@$file;type=text/plain;filename=$base") upload_flag=("-F" "file=@$file;type=text/plain;filename=$base")
elif [[ "$ext" =~ ^([Jj][Ss][Oo][Nn])$ ]]; then elif [[ "$ext" =~ ^([Jj][Ss][Oo][Nn])$ ]]; then
# Try to extract human text from JSON and upload as text/plain
if command -v jq >/dev/null 2>&1; then if command -v jq >/dev/null 2>&1; then
tmp_txt="$(_mktemp)" tmp_txt="$(_mktemp)"
# Extract common transcript shapes: .text or .segments[].text (strings only)
if jq -er ' if jq -er '
if type=="object" and (.text|type=="string") then .text if type=="object" and (.text|type=="string") then .text
elif type=="object" and (.segments|type=="array") then elif type=="object" and (.segments|type=="array") then
@@ -495,19 +375,18 @@ PY
else empty end else empty end
' "$file" >"$tmp_txt"; then ' "$file" >"$tmp_txt"; then
if [ -s "$tmp_txt" ]; then if [ -s "$tmp_txt" ]; then
# Keep original stem but force .txt for OWUI indexing
stem="${base%.*}" stem="${base%.*}"
upload_flag=("-F" "file=@$tmp_txt;type=text/plain;filename=${stem}.txt") upload_flag=("-F" "file=@$tmp_txt;type=text/plain;filename=${stem}.txt")
echo "[owui] extracted text from JSON -> ${stem}.txt" echo "[owui] extracted text from JSON -> ${stem}.txt"
TMP_EXTRACT="$tmp_txt" TMP_EXTRACT="$tmp_txt"
else else
echo "[owui] WARNING: JSON had no extractable text, uploading raw JSON (may be rejected)" >&2 echo "[owui] WARNING: JSON had no extractable text, uploading raw JSON" >&2
fi fi
else else
echo "[owui] WARNING: jq failed to parse JSON, uploading raw JSON (may be rejected)" >&2 echo "[owui] WARNING: jq failed to parse JSON, uploading raw JSON" >&2
fi fi
else else
echo "[owui] NOTE: jq not installed; uploading raw JSON (may be rejected)" >&2 echo "[owui] NOTE: jq not installed; uploading raw JSON" >&2
fi fi
fi fi
@@ -519,34 +398,23 @@ PY
curl_exit=$?; http_code="$(cat "$tmp_code" 2>/dev/null || echo 0)" curl_exit=$?; http_code="$(cat "$tmp_code" 2>/dev/null || echo 0)"
FILE_JSON="$(cat "$tmp_body")" FILE_JSON="$(cat "$tmp_body")"
rm -f "$tmp_body" "$tmp_code" rm -f "$tmp_body" "$tmp_code"
echo "$FILE_JSON" | ppjson echo "$FILE_JSON" | ppjson
if [ $curl_exit -ne 0 ]; then [ $curl_exit -ne 0 ] && { echo "Upload failed: curl exit $curl_exit" >&2; exit $curl_exit; }
echo "Upload failed: curl exit $curl_exit" >&2; exit $curl_exit [ "$http_code" != "200" ] && { echo "Upload failed (HTTP $http_code)" >&2; exit 1; }
fi
if [ "$http_code" != "200" ]; then
echo "Upload failed (HTTP $http_code)" >&2; exit 1
fi
FILE_ID="$(python3 -c 'import sys,json; d=json.load(sys.stdin); print(d.get("id") or (d.get("data") or {}).get("id",""))' <<<"$FILE_JSON")" FILE_ID="$(python3 -c 'import sys,json; d=json.load(sys.stdin); print(d.get("id") or (d.get("data") or {}).get("id",""))' <<<"$FILE_JSON")"
if [ -z "$FILE_ID" ]; then echo "Upload failed (no file id)"; exit 1; fi [ -z "$FILE_ID" ] && { echo "Upload failed (no file id)"; exit 1; }
# Wait until OWUI finishes processing/extracting text for this file (prevents "content empty" 400) # Wait for content extraction (prevents EMPTY_CONTENT)
if ! _owui_wait_file "$FILE_ID" "$OPENWEBUI_WAIT_SECS"; then if ! _owui_wait_file "$FILE_ID" "$OPENWEBUI_WAIT_SECS"; then
echo "[owui] WARNING: timed out waiting for file content; attach may fail if OWUI hasn't extracted text yet" >&2 echo "[owui] WARNING: timed out waiting for file extraction; attach may fail" >&2
fi fi
# 2) Resolve KB and attach # 2) Resolve KB and attach
KB_ID="$(_kb_id_by_name "$kb_name")" KB_ID="$(_kb_id_by_name "$kb_name")"
echo "[owui] attaching to KB: $kb_name (id: $KB_ID)" echo "[owui] attaching to KB: $kb_name (id: ${KB_ID:-<none>})"
if [ -z "$KB_ID" ]; then [ -z "$KB_ID" ] && { echo "KB '$kb_name' not found (or ambiguous)." >&2; exit 1; }
echo "KB '$kb_name' not found (or ambiguous)." >&2
echo "Tip: run './scripts/podx-tools.sh owui-kb-resolve \"$kb_name\"' to inspect and resolve, or create one:" >&2
echo " ./scripts/podx-tools.sh owui-kb-create \"$kb_name\"" >&2
exit 1
fi
# Attach: capture headers, body, http code and curl exit
tmp_body="$(_mktemp)"; tmp_code="$(_mktemp)"; tmp_hdrs="$(_mktemp)" tmp_body="$(_mktemp)"; tmp_code="$(_mktemp)"; tmp_hdrs="$(_mktemp)"
curl -sS -X POST \ curl -sS -X POST \
-H "Authorization: Bearer $OPENWEBUI_API_KEY" \ -H "Authorization: Bearer $OPENWEBUI_API_KEY" \
@@ -556,56 +424,37 @@ PY
-w "%{http_code}" --output "$tmp_body" \ -w "%{http_code}" --output "$tmp_body" \
"$(_owui_url)/api/v1/knowledge/$KB_ID/file/add" >"$tmp_code" || true "$(_owui_url)/api/v1/knowledge/$KB_ID/file/add" >"$tmp_code" || true
curl_exit=$?; http_code="$(cat "$tmp_code" 2>/dev/null || echo 0)" curl_exit=$?; http_code="$(cat "$tmp_code" 2>/dev/null || echo 0)"
echo "[owui] response headers:"; sed -n '1,5p' "$tmp_hdrs" || true echo "[owui] response headers:"; sed -n '1,5p' "$tmp_hdrs" || true
RESP="$(cat "$tmp_body")" RESP="$(cat "$tmp_body")"
echo "$RESP" | ppjson echo "$RESP" | ppjson
rm -f "$tmp_body" "$tmp_code" "$tmp_hdrs" rm -f "$tmp_body" "$tmp_code" "$tmp_hdrs"
[ -n "${TMP_EXTRACT:-}" ] && rm -f "$TMP_EXTRACT"; unset TMP_EXTRACT [ -n "${TMP_EXTRACT:-}" ] && rm -f "$TMP_EXTRACT" || true
if [ $curl_exit -ne 0 ]; then [ $curl_exit -ne 0 ] && { echo "Attach failed: curl exit $curl_exit" >&2; exit $curl_exit; }
echo "Attach failed: curl exit $curl_exit" >&2; exit $curl_exit [ -z "$http_code" ] || [ "$http_code" = "000" ] && { echo "Attach failed: no HTTP code returned" >&2; exit 1; }
fi
# Some environments report curl(23) sporadically; treat missing code as non-200
if [ -z "$http_code" ] || [ "$http_code" = "000" ]; then
echo "Attach failed: no HTTP code returned" >&2; exit 1
fi
case "$http_code" in case "$http_code" in
200|201|204) 200|201|204) : ;;
: # success
;;
*) *)
if printf '%s' "$RESP" | grep -qi "Duplicate content"; then if printf '%s' "$RESP" | grep -qi "Duplicate content"; then
echo "[owui] duplicate content — already indexed. Treating as success." echo "[owui] duplicate content — already indexed. Treating as success."; exit 0
exit 0
fi fi
echo "Attach failed (HTTP $http_code)" >&2; exit 1 echo "Attach failed (HTTP $http_code)" >&2; exit 1
;; ;;
esac esac
;; ;;
owui-attach-id) owui-attach-id)
shift || true shift || true; kb_id="${1:-}"; file="${2:-}"
kb_id="${1:-}"; file="${2:-}" [ -z "$kb_id" ] || [ -z "$file" ] || [ ! -f "$file" ] && { echo "Usage: owui-attach-id <KB_ID> </abs/path/file>" >&2; exit 1; }
if [ -z "$kb_id" ] || [ -z "$file" ] || [ ! -f "$file" ]; then _require "OPENWEBUI_URL" "$OPENWEBUI_URL"; _require "OPENWEBUI_API_KEY" "$OPENWEBUI_API_KEY"
echo "Usage: owui-attach-id <KB_ID> </abs/path/file>" >&2; exit 1
fi
_require "OPENWEBUI_URL" "$OPENWEBUI_URL"
_require "OPENWEBUI_API_KEY" "$OPENWEBUI_API_KEY"
TMP_EXTRACT="" TMP_EXTRACT=""
# Decide how to send the file (force text/plain for .txt/.md; optionally extract JSON->text)
upload_flag=("-F" "file=@$file") upload_flag=("-F" "file=@$file")
ext="${file##*.}" ext="${file##*.}"; base="$(basename "$file")"
base="$(basename "$file")"
if [[ "$ext" =~ ^([Tt][Xx][Tt]|[Mm][Dd]|[Mm][Aa][Rr][Kk][Dd][Oo][Ww][Nn])$ ]]; then if [[ "$ext" =~ ^([Tt][Xx][Tt]|[Mm][Dd]|[Mm][Aa][Rr][Kk][Dd][Oo][Ww][Nn])$ ]]; then
upload_flag=("-F" "file=@$file;type=text/plain;filename=$base") upload_flag=("-F" "file=@$file;type=text/plain;filename=$base")
elif [[ "$ext" =~ ^([Jj][Ss][Oo][Nn])$ ]]; then elif [[ "$ext" =~ ^([Jj][Ss][Oo][Nn])$ ]]; then
# Try to extract human text from JSON and upload as text/plain
if command -v jq >/dev/null 2>&1; then if command -v jq >/dev/null 2>&1; then
tmp_txt="$(_mktemp)" tmp_txt="$(_mktemp)"
# Extract common transcript shapes: .text or .segments[].text (strings only)
if jq -er ' if jq -er '
if type=="object" and (.text|type=="string") then .text if type=="object" and (.text|type=="string") then .text
elif type=="object" and (.segments|type=="array") then elif type=="object" and (.segments|type=="array") then
@@ -615,48 +464,32 @@ PY
else empty end else empty end
' "$file" >"$tmp_txt"; then ' "$file" >"$tmp_txt"; then
if [ -s "$tmp_txt" ]; then if [ -s "$tmp_txt" ]; then
# Keep original stem but force .txt for OWUI indexing
stem="${base%.*}" stem="${base%.*}"
upload_flag=("-F" "file=@$tmp_txt;type=text/plain;filename=${stem}.txt") upload_flag=("-F" "file=@$tmp_txt;type=text/plain;filename=${stem}.txt")
echo "[owui] extracted text from JSON -> ${stem}.txt" echo "[owui] extracted text from JSON -> ${stem}.txt"
TMP_EXTRACT="$tmp_txt" TMP_EXTRACT="$tmp_txt"
else
echo "[owui] WARNING: JSON had no extractable text, uploading raw JSON (may be rejected)" >&2
fi fi
else
echo "[owui] WARNING: jq failed to parse JSON, uploading raw JSON (may be rejected)" >&2
fi fi
else
echo "[owui] NOTE: jq not installed; uploading raw JSON (may be rejected)" >&2
fi fi
fi fi
# 1) Upload
tmp_body="$(_mktemp)"; tmp_code="$(_mktemp)" tmp_body="$(_mktemp)"; tmp_code="$(_mktemp)"
curl -sS -H "Authorization: Bearer $OPENWEBUI_API_KEY" \ curl -sS -H "Authorization: Bearer $OPENWEBUI_API_KEY" \
"${upload_flag[@]}" \ "${upload_flag[@]}" \
-w "%{http_code}" --output "$tmp_body" "$(_owui_url)/api/v1/files/" >"$tmp_code" || true -w "%{http_code}" --output "$tmp_body" "$(_owui_url)/api/v1/files/" >"$tmp_code" || true
curl_exit=$?; http_code="$(cat "$tmp_code" 2>/dev/null || echo 0)" curl_exit=$?; http_code="$(cat "$tmp_code" 2>/dev/null || echo 0)"
FILE_JSON="$(cat "$tmp_body")" FILE_JSON="$(cat "$tmp_body")"; rm -f "$tmp_body" "$tmp_code"
rm -f "$tmp_body" "$tmp_code"
echo "$FILE_JSON" | ppjson echo "$FILE_JSON" | ppjson
if [ $curl_exit -ne 0 ]; then [ $curl_exit -ne 0 ] && { echo "Upload failed: curl exit $curl_exit" >&2; exit $curl_exit; }
echo "Upload failed: curl exit $curl_exit" >&2; exit $curl_exit [ "$http_code" != "200" ] && { echo "Upload failed (HTTP $http_code)" >&2; exit 1; }
fi
if [ "$http_code" != "200" ]; then
echo "Upload failed (HTTP $http_code)" >&2; exit 1
fi
FILE_ID="$(python3 -c 'import sys,json; d=json.load(sys.stdin); print(d.get("id") or (d.get("data") or {}).get("id",""))' <<<"$FILE_JSON")" FILE_ID="$(python3 -c 'import sys,json; d=json.load(sys.stdin); print(d.get("id") or (d.get("data") or {}).get("id",""))' <<<"$FILE_JSON")"
if [ -z "$FILE_ID" ]; then echo "Upload failed (no file id)"; exit 1; fi [ -z "$FILE_ID" ] && { echo "Upload failed (no file id)"; exit 1; }
# Wait until OWUI finishes processing/extracting text for this file (prevents "content empty" 400)
if ! _owui_wait_file "$FILE_ID" "$OPENWEBUI_WAIT_SECS"; then if ! _owui_wait_file "$FILE_ID" "$OPENWEBUI_WAIT_SECS"; then
echo "[owui] WARNING: timed out waiting for file content; attach may fail if OWUI hasn't extracted text yet" >&2 echo "[owui] WARNING: timed out waiting for file extraction; attach may fail" >&2
fi fi
# 2) Attach using explicit KB id
tmp_body="$(_mktemp)"; tmp_code="$(_mktemp)"; tmp_hdrs="$(_mktemp)" tmp_body="$(_mktemp)"; tmp_code="$(_mktemp)"; tmp_hdrs="$(_mktemp)"
curl -sS -X POST \ curl -sS -X POST \
-H "Authorization: Bearer $OPENWEBUI_API_KEY" \ -H "Authorization: Bearer $OPENWEBUI_API_KEY" \
@@ -666,118 +499,80 @@ PY
-w "%{http_code}" --output "$tmp_body" \ -w "%{http_code}" --output "$tmp_body" \
"$(_owui_url)/api/v1/knowledge/$kb_id/file/add" >"$tmp_code" || true "$(_owui_url)/api/v1/knowledge/$kb_id/file/add" >"$tmp_code" || true
curl_exit=$?; http_code="$(cat "$tmp_code" 2>/dev/null || echo 0)" curl_exit=$?; http_code="$(cat "$tmp_code" 2>/dev/null || echo 0)"
echo "[owui] response headers:"; sed -n '1,5p' "$tmp_hdrs" || true echo "[owui] response headers:"; sed -n '1,5p' "$tmp_hdrs" || true
RESP="$(cat "$tmp_body")" RESP="$(cat "$tmp_body")"; echo "$RESP" | ppjson
echo "$RESP" | ppjson
rm -f "$tmp_body" "$tmp_code" "$tmp_hdrs" rm -f "$tmp_body" "$tmp_code" "$tmp_hdrs"
[ -n "${TMP_EXTRACT:-}" ] && rm -f "$TMP_EXTRACT"; unset TMP_EXTRACT [ -n "${TMP_EXTRACT:-}" ] && rm -f "$TMP_EXTRACT" || true
if [ $curl_exit -ne 0 ]; then [ $curl_exit -ne 0 ] && { echo "Attach failed: curl exit $curl_exit" >&2; exit $curl_exit; }
echo "Attach failed: curl exit $curl_exit" >&2; exit $curl_exit [ -z "$http_code" ] || [ "$http_code" = "000" ] && { echo "Attach failed: no HTTP code returned" >&2; exit 1; }
fi
if [ -z "$http_code" ] || [ "$http_code" = "000" ]; then
echo "Attach failed: no HTTP code returned" >&2; exit 1
fi
case "$http_code" in case "$http_code" in
200|201|204) : ;; 200|201|204) : ;;
*) *)
if printf '%s' "$RESP" | grep -qi "Duplicate content"; then if printf '%s' "$RESP" | grep -qi "Duplicate content"; then
echo "[owui] duplicate content — already indexed. Treating as success." echo "[owui] duplicate content — already indexed. Treating as success."; exit 0
exit 0
fi fi
echo "Attach failed (HTTP $http_code)" >&2; exit 1 echo "Attach failed (HTTP $http_code)" >&2; exit 1
;; ;;
esac esac
;; ;;
owui-kb-files) owui-kb-files)
shift || true shift || true; kb_name="${1:-}"
kb_name="${1:-}" [ -z "$kb_name" ] && { echo "Usage: owui-kb-files \"<KB Name>\"" >&2; exit 1; }
if [ -z "$kb_name" ]; then echo "Usage: owui-kb-files \"<KB Name>\"" >&2; exit 1; fi _require "OPENWEBUI_URL" "$OPENWEBUI_URL"; _require "OPENWEBUI_API_KEY" "$OPENWEBUI_API_KEY"
_require "OPENWEBUI_URL" "$OPENWEBUI_URL" KB_ID="$(_kb_id_by_name "$kb_name")"; [ -z "$KB_ID" ] && { echo "KB '$kb_name' not found"; exit 1; }
_require "OPENWEBUI_API_KEY" "$OPENWEBUI_API_KEY"
KB_ID="$(_kb_id_by_name "$kb_name")"
if [ -z "$KB_ID" ]; then echo "KB '$kb_name' not found"; exit 1; fi
# First, fetch the KB object (includes files array in many OWUI versions)
tmp_body="$(_mktemp)"; tmp_code="$(_mktemp)" tmp_body="$(_mktemp)"; tmp_code="$(_mktemp)"
curl -sS $CURL_TMO -H "Authorization: Bearer $OPENWEBUI_API_KEY" \ curl -sS $CURL_TMO -H "Authorization: Bearer $OPENWEBUI_API_KEY" \
-w "%{http_code}" --output "$tmp_body" \ -w "%{http_code}" --output "$tmp_body" \
"$(_owui_url)/api/v1/knowledge/$KB_ID" >"$tmp_code" || true "$(_owui_url)/api/v1/knowledge/$KB_ID" >"$tmp_code" || true
http_code="$(cat "$tmp_code" 2>/dev/null || echo 0)" http_code="$(cat "$tmp_code" 2>/dev/null || echo 0)"; body="$(cat "$tmp_body" 2>/dev/null || echo '')"; rm -f "$tmp_code"
body="$(cat "$tmp_body" 2>/dev/null || echo '')"
rm -f "$tmp_code"
if [ "$http_code" = "200" ] && [ -n "$body" ]; then if [ "$http_code" = "200" ] && [ -n "$body" ]; then
# Try to extract and pretty-print just the files array if present
if command -v python3 >/dev/null 2>&1; then if command -v python3 >/dev/null 2>&1; then
python3 - <<'PY' 2>/dev/null || echo "$body" | ppjson python3 - <<'PY' 2>/dev/null || echo "$body" | ppjson
import sys, json import sys, json
d = json.loads(sys.stdin.read()) d = json.loads(sys.stdin.read())
files = d.get("files") files = d.get("files")
if files is None and isinstance(d.get("data"), dict): if files is None and isinstance(d.get("data"), dict):
# some versions pack file_ids under data.file_ids (UUIDs only)
fids = d["data"].get("file_ids") or [] fids = d["data"].get("file_ids") or []
files = [{"id": fid} for fid in fids] files = [{"id": fid} for fid in fids]
if files is None: if files is None: raise SystemExit(1)
raise SystemExit(1)
print(json.dumps(files, indent=2)) print(json.dumps(files, indent=2))
PY PY
else else
echo "$body" | ppjson echo "$body" | ppjson
fi fi
rm -f "$tmp_body" rm -f "$tmp_body"; exit 0
exit 0
fi fi
# Fallback to /files endpoint if the KB object route didn't yield JSON files
tmp_code2="$(_mktemp)" tmp_code2="$(_mktemp)"
curl -sS $CURL_TMO -H "Authorization: Bearer $OPENWEBUI_API_KEY" \ curl -sS $CURL_TMO -H "Authorization: Bearer $OPENWEBUI_API_KEY" \
-w "%{http_code}" --output "$tmp_body" \ -w "%{http_code}" --output "$tmp_body" \
"$(_owui_url)/api/v1/knowledge/$KB_ID/files" >"$tmp_code2" || true "$(_owui_url)/api/v1/knowledge/$KB_ID/files" >"$tmp_code2" || true
http_code2="$(cat "$tmp_code2" 2>/dev/null || echo 0)" http_code2="$(cat "$tmp_code2" 2>/dev/null || echo 0)"; body2="$(cat "$tmp_body" 2>/dev/null || echo '')"
body2="$(cat "$tmp_body" 2>/dev/null || echo '')"
rm -f "$tmp_body" "$tmp_code2" rm -f "$tmp_body" "$tmp_code2"
if [ "$http_code2" = "200" ] && [ -n "$body2" ]; then echo "$body2" | ppjson
if [ "$http_code2" = "200" ] && [ -n "$body2" ]; then else echo "Failed to fetch KB files (HTTP $http_code / $http_code2)" >&2; exit 1; fi
echo "$body2" | ppjson
else
echo "Failed to fetch KB files (HTTP $http_code / $http_code2)" >&2
exit 1
fi
;; ;;
owui-kb-debug) owui-kb-debug)
shift || true shift || true; name="${1:-}"
name="${1:-}" [ -z "$name" ] && { echo "Usage: owui-kb-debug \"<KB Name>\"" >&2; exit 1; }
if [ -z "$name" ]; then echo "Usage: owui-kb-debug \"<KB Name>\"" >&2; exit 1; fi
echo "[owui] base URL: $(_owui_url)" echo "[owui] base URL: $(_owui_url)"
echo "[owui] KBs returned:" echo "[owui] KBs returned:"
_owui_get_kb_list | ppjson _owui_get_kb_list | ppjson
id="$(_kb_id_by_name "$name")" id="$(_kb_id_by_name "$name")"
if [ -n "$id" ]; then if [ -n "$id" ]; then echo "[owui] resolved id for \"$name\": $id"
echo "[owui] resolved id for \"$name\": $id" else echo "[owui] could not resolve an id for \"$name\"" >&2
else
echo "[owui] could not resolve an id for \"$name\"" >&2
fi fi
;; ;;
owui-batch-attach) owui-batch-attach)
shift || true shift || true; kb_name="${1:-}"; glob_pat="${2:-}"
kb_name="${1:-}"; glob_pat="${2:-}" [ -z "$kb_name" ] || [ -z "$glob_pat" ] && { echo "Usage: owui-batch-attach \"<KB Name>\" <glob>" >&2; exit 1; }
if [ -z "$kb_name" ] || [ -z "$glob_pat" ]; then KB_ID="$(_kb_id_by_name "$kb_name")"; [ -z "$KB_ID" ] && { echo "KB '$kb_name' not found"; exit 1; }
echo "Usage: owui-batch-attach \"<KB Name>\" <glob>" >&2; exit 1 _require "OPENWEBUI_URL" "$OPENWEBUI_URL"; _require "OPENWEBUI_API_KEY" "$OPENWEBUI_API_KEY"
fi shopt -s nullglob; matched=($glob_pat); shopt -u nullglob
KB_ID="$(_kb_id_by_name "$kb_name")" [ ${#matched[@]} -eq 0 ] && { echo "No files match: $glob_pat"; exit 1; }
if [ -z "$KB_ID" ]; then echo "KB '$kb_name' not found"; exit 1; fi
_require "OPENWEBUI_URL" "$OPENWEBUI_URL"
_require "OPENWEBUI_API_KEY" "$OPENWEBUI_API_KEY"
shopt -s nullglob
matched=($glob_pat)
shopt -u nullglob
if [ ${#matched[@]} -eq 0 ]; then echo "No files match: $glob_pat"; exit 1; fi
for f in "${matched[@]}"; do for f in "${matched[@]}"; do
echo "[owui] uploading: $f" echo "[owui] uploading: $f"
tmp_body="$(_mktemp)"; tmp_code="$(_mktemp)" tmp_body="$(_mktemp)"; tmp_code="$(_mktemp)"
@@ -785,26 +580,18 @@ PY
-F "file=@$f" \ -F "file=@$f" \
-w "%{http_code}" --output "$tmp_body" "$(_owui_url)/api/v1/files/" >"$tmp_code" || true -w "%{http_code}" --output "$tmp_body" "$(_owui_url)/api/v1/files/" >"$tmp_code" || true
curl_up_exit=$?; code_up="$(cat "$tmp_code" 2>/dev/null || echo 0)" curl_up_exit=$?; code_up="$(cat "$tmp_code" 2>/dev/null || echo 0)"
FILE_JSON="$(cat "$tmp_body")" FILE_JSON="$(cat "$tmp_body")"; rm -f "$tmp_body" "$tmp_code"
rm -f "$tmp_body" "$tmp_code"
if [ $curl_up_exit -ne 0 ] || [ "$code_up" != "200" ]; then if [ $curl_up_exit -ne 0 ] || [ "$code_up" != "200" ]; then
echo " upload failed (curl=$curl_up_exit http=$code_up), skipping" echo " upload failed (curl=$curl_up_exit http=$code_up), skipping"; echo "$FILE_JSON" | ppjson; continue
echo "$FILE_JSON" | ppjson
continue
fi fi
FILE_ID="$(python3 -c 'import sys,json; d=json.loads(sys.stdin.read()); print(d.get("id") or (d.get("data") or {}).get("id",""))' <<<"$FILE_JSON")" FILE_ID="$(python3 -c 'import sys,json; d=json.loads(sys.stdin.read()); print(d.get("id") or (d.get("data") or {}).get("id",""))' <<<"$FILE_JSON")"
if [ -z "$FILE_ID" ]; then echo " upload failed (no id), skipping"; echo "$FILE_JSON" | ppjson; continue; fi if [ -z "$FILE_ID" ]; then echo " upload failed (no id), skipping"; echo "$FILE_JSON" | ppjson; continue; fi
tmp_body="$(_mktemp)"; tmp_code="$(_mktemp)" tmp_body="$(_mktemp)"; tmp_code="$(_mktemp)"
curl -sS -X POST -H "Authorization: Bearer $OPENWEBUI_API_KEY" -H "Content-Type: application/json" \ curl -sS -X POST -H "Authorization: Bearer $OPENWEBUI_API_KEY" -H "Content-Type: application/json" \
-d "{\"file_id\":\"$FILE_ID\"}" \ -d "{\"file_id\":\"$FILE_ID\"}" \
-w "%{http_code}" --output "$tmp_body" "$(_owui_url)/api/v1/knowledge/$KB_ID/file/add" >"$tmp_code" || true -w "%{http_code}" --output "$tmp_body" "$(_owui_url)/api/v1/knowledge/$KB_ID/file/add" >"$tmp_code" || true
curl_att_exit=$?; code_att="$(cat "$tmp_code" 2>/dev/null || echo 0)" curl_att_exit=$?; code_att="$(cat "$tmp_code" 2>/dev/null || echo 0)"; RESP="$(cat "$tmp_body")"
RESP="$(cat "$tmp_body")"
rm -f "$tmp_body" "$tmp_code" rm -f "$tmp_body" "$tmp_code"
echo "$RESP" | ppjson echo "$RESP" | ppjson
if [ "$code_att" != "200" ]; then if [ "$code_att" != "200" ]; then
echo " attach failed (HTTP $code_att)" echo " attach failed (HTTP $code_att)"
@@ -812,31 +599,18 @@ PY
done done
;; ;;
# ---------- Toggles ----------
transcribe-status) transcribe-status)
# Prints 'paused' if the switch key is set to a truthy value, else 'running'
val="$(_redis_cli GET "$_transcribe_key" 2>/dev/null || true)" val="$(_redis_cli GET "$_transcribe_key" 2>/dev/null || true)"
if [ -n "${val:-}" ] && [ "${val}" != "(nil)" ] && [ "${val}" != "0" ]; then if [ -n "${val:-}" ] && [ "${val}" != "(nil)" ] && [ "${val}" != "0" ]; then echo "paused"; else echo "running"; fi
echo "paused"
exit 0
fi
echo "running"
;; ;;
transcribe-pause) transcribe-pause)
if _redis_cli SET "$_transcribe_key" 1 >/dev/null; then if _redis_cli SET "$_transcribe_key" 1 >/dev/null; then echo "Transcription: paused"; else echo "Failed to set pause switch." >&2; exit 1; fi
echo "Transcription: paused"
else
echo "Failed to talk to redis to set pause switch." >&2
exit 1
fi
;; ;;
transcribe-resume) transcribe-resume)
if _redis_cli DEL "$_transcribe_key" >/dev/null; then if _redis_cli DEL "$_transcribe_key" >/dev/null; then echo "Transcription: resumed"; else echo "Failed to clear pause switch." >&2; exit 1; fi
echo "Transcription: resumed"
else
echo "Failed to talk to redis to clear pause switch." >&2
exit 1
fi
;; ;;
*) *)
echo "Unknown command: $cmd" >&2 echo "Unknown command: $cmd" >&2
_help _help