V.Bolshakov
113 lines
3.6 KiB
Bash
113 lines
3.6 KiB
Bash
#!/bin/sh
|
|
# Import n8n workflows and credentials from backup directory
|
|
# This script runs inside the n8n-import container
|
|
#
|
|
# Credentials skip logic:
|
|
# После успешного импорта создаётся маркер в /home/node/.n8n/imported/
|
|
# При повторном запуске файл с существующим маркером пропускается.
|
|
# Это позволяет не перезатирать API-ключи при повторном деплое.
|
|
# Чтобы принудительно переимпортировать — удалить маркер или задать FORCE_IMPORT=true
|
|
|
|
set -e
|
|
|
|
MARKER_DIR="/home/node/.n8n/imported"
|
|
mkdir -p "$MARKER_DIR"
|
|
|
|
COUNTER_FILE=$(mktemp)
|
|
trap 'rm -f "$COUNTER_FILE"' EXIT
|
|
echo "0" > "$COUNTER_FILE"
|
|
|
|
# Import credentials first
|
|
echo 'Importing credentials...'
|
|
CRED_FILES=$(find /backup/credentials -maxdepth 1 -type f -not -name '.gitkeep' 2>/dev/null || true)
|
|
if [ -n "$CRED_FILES" ]; then
|
|
CRED_COUNT=$(echo "$CRED_FILES" | wc -l | tr -d ' ')
|
|
|
|
# Normalize credentials files (wrap object in array if needed)
|
|
echo "$CRED_FILES" | while IFS= read -r file; do
|
|
FIRST_CHAR=$(head -c 1 "$file")
|
|
if [ "$FIRST_CHAR" = "{" ]; then
|
|
TMPFILE=$(mktemp)
|
|
echo "[$(cat "$file")]" > "$TMPFILE"
|
|
mv "$TMPFILE" "$file"
|
|
fi
|
|
done
|
|
|
|
echo "0" > "$COUNTER_FILE"
|
|
echo "$CRED_FILES" | while IFS= read -r file; do
|
|
CURRENT=$(cat "$COUNTER_FILE")
|
|
CURRENT=$((CURRENT + 1))
|
|
echo "$CURRENT" > "$COUNTER_FILE"
|
|
filename=$(basename "$file")
|
|
MARKER="$MARKER_DIR/cred_$(echo "$filename" | tr '/' '_')"
|
|
|
|
printf "[%2d/%d] %s" "$CURRENT" "$CRED_COUNT" "$filename"
|
|
|
|
# Пропустить если уже импортировался и FORCE_IMPORT не задан
|
|
if [ -f "$MARKER" ] && [ "$FORCE_IMPORT" != "true" ]; then
|
|
echo " SKIPPED (already imported, set FORCE_IMPORT=true to override)"
|
|
continue
|
|
fi
|
|
|
|
OUTPUT_FILE=$(mktemp)
|
|
|
|
if n8n import:credentials --input="$file" > "$OUTPUT_FILE" 2>&1; then
|
|
echo " OK"
|
|
touch "$MARKER"
|
|
if [ -s "$OUTPUT_FILE" ]; then
|
|
echo " Details: $(cat "$OUTPUT_FILE" | tr '\n' ' ')"
|
|
fi
|
|
else
|
|
echo " FAILED"
|
|
echo " Error: $(cat "$OUTPUT_FILE" | tr '\n' ' ')"
|
|
fi
|
|
|
|
rm -f "$OUTPUT_FILE"
|
|
done
|
|
fi
|
|
|
|
# Import workflows
|
|
echo ''
|
|
echo 'Importing workflows...'
|
|
WORKFLOW_FILES=$(find /backup/workflows -maxdepth 1 -type f -not -name '.gitkeep' 2>/dev/null || true)
|
|
if [ -z "$WORKFLOW_FILES" ]; then
|
|
echo 'No workflows found to import.'
|
|
exit 0
|
|
fi
|
|
TOTAL_FOUND=$(echo "$WORKFLOW_FILES" | wc -l | tr -d ' ')
|
|
if [ -n "$IMPORT_LIMIT" ]; then
|
|
WORKFLOW_FILES=$(echo "$WORKFLOW_FILES" | head -n "$IMPORT_LIMIT")
|
|
fi
|
|
TOTAL=$(echo "$WORKFLOW_FILES" | wc -l | tr -d ' ')
|
|
echo "Importing $TOTAL of $TOTAL_FOUND workflows"
|
|
echo ''
|
|
echo "0" > "$COUNTER_FILE"
|
|
echo "$WORKFLOW_FILES" | while IFS= read -r file; do
|
|
CURRENT=$(cat "$COUNTER_FILE")
|
|
CURRENT=$((CURRENT + 1))
|
|
echo "$CURRENT" > "$COUNTER_FILE"
|
|
filename=$(basename "$file")
|
|
printf "[%3d/%d] %s" "$CURRENT" "$TOTAL" "$filename"
|
|
|
|
OUTPUT_FILE=$(mktemp)
|
|
|
|
if n8n import:workflow --input="$file" > "$OUTPUT_FILE" 2>&1; then
|
|
echo " OK"
|
|
if [ -s "$OUTPUT_FILE" ]; then
|
|
OUTPUT=$(cat "$OUTPUT_FILE")
|
|
if echo "$OUTPUT" | grep -q "id"; then
|
|
echo " Imported: $(echo "$OUTPUT" | tr '\n' ' ' | sed 's/[{}"]//g')"
|
|
else
|
|
echo " Details: $OUTPUT"
|
|
fi
|
|
fi
|
|
else
|
|
echo " FAILED"
|
|
echo " Error: $(cat "$OUTPUT_FILE" | tr '\n' ' ')"
|
|
fi
|
|
|
|
rm -f "$OUTPUT_FILE"
|
|
done
|
|
echo ''
|
|
echo 'Import complete!'
|