refactor: Modularize wallos-fetch.sh and add CSV output support
This commit is contained in:
Nick Heppler
parent
7517061922
commit
cf8042a5d7
160
wallos-fetch.sh
160
wallos-fetch.sh
@ -1,161 +1,123 @@
|
||||
#!/bin/bash
|
||||
|
||||
VERSION="2025.04"
|
||||
|
||||
# Configuration
|
||||
VERSION="2025.05"
|
||||
HOST="https://your-api-host.com"
|
||||
ENDPOINT="/api/subscriptions/get_subscriptions.php"
|
||||
API_KEY="${API_KEY:-$WALLOS_API_KEY}"
|
||||
|
||||
# Defaults
|
||||
MODE="md"
|
||||
FULL=false
|
||||
OUTPUT="" # Will set default per mode later
|
||||
OUTPUT=""
|
||||
TMP_FILE=$(mktemp)
|
||||
|
||||
# 🚨 Dependencies check
|
||||
for dep in curl jq; do
|
||||
command -v "$dep" >/dev/null 2>&1 || {
|
||||
echo "❌ Missing required dependency: $dep"
|
||||
exit 1
|
||||
}
|
||||
done
|
||||
|
||||
# Show help
|
||||
show_help() {
|
||||
cat << EOF
|
||||
ℹ️ Wallos Fetcher Script - v$VERSION
|
||||
|
||||
Usage: ./wallos-fetch.sh [OPTIONS]
|
||||
|
||||
Fetch and export subscription data from a Wallos instance.
|
||||
|
||||
Options:
|
||||
--json Output raw JSON
|
||||
--md Output Markdown table
|
||||
--full Include more fields in CSV/Markdown
|
||||
--csv Output CSV table
|
||||
--full Include more fields
|
||||
--output <file> Custom output filename
|
||||
--help Show this help message and exit
|
||||
--version Show version and exit
|
||||
|
||||
Default output is Markdown.
|
||||
--help Show this help message
|
||||
--version Show version
|
||||
EOF
|
||||
}
|
||||
|
||||
# Argument parser
|
||||
parse_args() {
|
||||
while [[ "$#" -gt 0 ]]; do
|
||||
case "$1" in
|
||||
--json) MODE="json" ;;
|
||||
--md) MODE="md" ;;
|
||||
--csv) MODE="csv" ;;
|
||||
--full) FULL=true ;;
|
||||
--output)
|
||||
shift
|
||||
OUTPUT="$1"
|
||||
;;
|
||||
--output) shift; OUTPUT="$1" ;;
|
||||
--help) show_help; exit 0 ;;
|
||||
--version) echo "❓ wallos-fetch v$VERSION"; exit 0 ;;
|
||||
*) echo "Unknown option: $1" && show_help && exit 1 ;;
|
||||
--version) echo "🧾 wallos-fetch v$VERSION"; exit 0 ;;
|
||||
*) echo "Unknown option: $1"; show_help; exit 1 ;;
|
||||
esac
|
||||
shift
|
||||
done
|
||||
|
||||
# Set default filenames if none specified
|
||||
if [[ -z "$OUTPUT" ]]; then
|
||||
case "$MODE" in
|
||||
json) OUTPUT="subscriptions.json" ;;
|
||||
md) OUTPUT="subscriptions.md" ;;
|
||||
csv) OUTPUT="subscriptions.csv" ;;
|
||||
esac
|
||||
fi
|
||||
# Set default output filename
|
||||
[[ -z "$OUTPUT" ]] && OUTPUT="subscriptions.${MODE}"
|
||||
}
|
||||
|
||||
# Construct the API URL
|
||||
fetch_data() {
|
||||
URL="${HOST}${ENDPOINT}?api_key=${API_KEY}"
|
||||
|
||||
# Perform the request
|
||||
RESPONSE=$(curl -s -w "\nHTTP_STATUS:%{http_code}" "$URL")
|
||||
BODY=$(echo "$RESPONSE" | sed -n '1,/^HTTP_STATUS:/p' | sed '$d')
|
||||
STATUS=$(echo "$RESPONSE" | tr -d '\n' | sed -e 's/.*HTTP_STATUS://')
|
||||
STATUS=$(echo "$RESPONSE" | sed -n 's/^HTTP_STATUS://p')
|
||||
BODY=$(echo "$RESPONSE" | sed '/^HTTP_STATUS:/d')
|
||||
|
||||
echo "HTTP Status: $STATUS"
|
||||
echo "$BODY" > "$TMP_FILE"
|
||||
|
||||
if [ "$STATUS" -eq 200 ]; then
|
||||
echo "$BODY" > temp_response.json
|
||||
if [[ "$STATUS" != "200" ]]; then
|
||||
echo "❌ API request failed with status: $STATUS"
|
||||
rm -f "$TMP_FILE"
|
||||
exit 1
|
||||
fi
|
||||
}
|
||||
|
||||
if [ "$MODE" == "json" ]; then
|
||||
mv temp_response.json "$OUTPUT"
|
||||
output_json() {
|
||||
mv "$TMP_FILE" "$OUTPUT"
|
||||
echo "💾 Saved JSON to $OUTPUT"
|
||||
}
|
||||
|
||||
elif [ "$MODE" == "md" ]; then
|
||||
# Write markdown header and description
|
||||
output_markdown() {
|
||||
{
|
||||
echo "# 🧾 Active Subscriptions Overview"
|
||||
echo ""
|
||||
echo "This document lists all recurring subscriptions tied to this household or individual. It includes costs, renewal dates, categories, and payment methods. This record is provided as a reference for financial planning, digital legacy management, or to assist family members in case of emergencies or estate matters."
|
||||
echo ""
|
||||
echo "_Last updated: $(date +'%Y-%m-%d')_"
|
||||
echo ""
|
||||
} > "$OUTPUT"
|
||||
|
||||
if [ "$FULL" = true ]; then
|
||||
if $FULL; then
|
||||
echo "| ID | Name | Price | Currency | Next Payment | Cycle | Auto Renew | Category | Payment Method |" >> "$OUTPUT"
|
||||
echo "|----|------|-------|----------|---------------|-------|-------------|----------|----------------|" >> "$OUTPUT"
|
||||
jq -r '
|
||||
.subscriptions[] | [
|
||||
.id,
|
||||
.name,
|
||||
(.price | tostring),
|
||||
.currency_id,
|
||||
.next_payment,
|
||||
.cycle,
|
||||
.auto_renew,
|
||||
(.category_name | gsub(">"; ">") | gsub("&"; "&")),
|
||||
.payment_method_name
|
||||
] | @tsv
|
||||
' temp_response.json | while IFS=$'\t' read -r id name price curr next cycle renew cat pay; do
|
||||
jq -r '.subscriptions[] | [.id, .name, .price, .currency_id, .next_payment, .cycle, .auto_renew, .category_name, .payment_method_name] | @tsv' "$TMP_FILE" |
|
||||
while IFS=$'\t' read -r id name price curr next cycle renew cat pay; do
|
||||
echo "| $id | $name | $price | $curr | $next | $cycle | $renew | $cat | $pay |" >> "$OUTPUT"
|
||||
done
|
||||
else
|
||||
echo "| ID | Name | Price | Next Payment | Category | Payment Method |" >> "$OUTPUT"
|
||||
echo "|----|------|-------|---------------|----------|----------------|" >> "$OUTPUT"
|
||||
jq -r '
|
||||
.subscriptions[] | [
|
||||
.id,
|
||||
.name,
|
||||
(.price | tostring),
|
||||
.next_payment,
|
||||
(.category_name | gsub(">"; ">") | gsub("&"; "&")),
|
||||
.payment_method_name
|
||||
] | @tsv
|
||||
' temp_response.json | while IFS=$'\t' read -r id name price next cat pay; do
|
||||
jq -r '.subscriptions[] | [.id, .name, .price, .next_payment, .category_name, .payment_method_name] | @tsv' "$TMP_FILE" |
|
||||
while IFS=$'\t' read -r id name price next cat pay; do
|
||||
echo "| $id | $name | $price | $next | $cat | $pay |" >> "$OUTPUT"
|
||||
done
|
||||
fi
|
||||
rm -f temp_response.json
|
||||
echo "💾 Saved Markdown table to $OUTPUT"
|
||||
echo "💾 Saved Markdown to $OUTPUT"
|
||||
rm -f "$TMP_FILE"
|
||||
}
|
||||
|
||||
else
|
||||
if [ "$FULL" = true ]; then
|
||||
output_csv() {
|
||||
if $FULL; then
|
||||
echo '"id","name","price","currency_id","next_payment","cycle","auto_renew","category_name","payment_method_name"' > "$OUTPUT"
|
||||
jq -r '
|
||||
.subscriptions[] | [
|
||||
.id,
|
||||
.name,
|
||||
.price,
|
||||
.currency_id,
|
||||
.next_payment,
|
||||
.cycle,
|
||||
.auto_renew,
|
||||
.category_name,
|
||||
.payment_method_name
|
||||
] | @csv
|
||||
' temp_response.json >> "$OUTPUT"
|
||||
jq -r '.subscriptions[] | [.id, .name, .price, .currency_id, .next_payment, .cycle, .auto_renew, .category_name, .payment_method_name] | @csv' "$TMP_FILE" >> "$OUTPUT"
|
||||
else
|
||||
echo '"id","name","price","next_payment","category_name","payment_method_name"' > "$OUTPUT"
|
||||
jq -r '
|
||||
.subscriptions[] | [
|
||||
.id,
|
||||
.name,
|
||||
.price,
|
||||
.next_payment,
|
||||
.category_name,
|
||||
.payment_method_name
|
||||
] | @csv
|
||||
' temp_response.json >> "$OUTPUT"
|
||||
jq -r '.subscriptions[] | [.id, .name, .price, .next_payment, .category_name, .payment_method_name] | @csv' "$TMP_FILE" >> "$OUTPUT"
|
||||
fi
|
||||
rm -f temp_response.json
|
||||
echo "💾 Saved CSV to $OUTPUT"
|
||||
fi
|
||||
else
|
||||
echo "❌ Request failed. Response not saved."
|
||||
fi
|
||||
rm -f "$TMP_FILE"
|
||||
}
|
||||
|
||||
# 🏁 Main
|
||||
parse_args "$@"
|
||||
fetch_data
|
||||
|
||||
case "$MODE" in
|
||||
json) output_json ;;
|
||||
md) output_markdown ;;
|
||||
csv) output_csv ;;
|
||||
esac
|
||||
|
||||
Loading…
Reference in New Issue
Block a user