Hopes and dreams

This commit is contained in:
2026-02-28 00:40:54 -06:00
parent 6153efb3dd
commit ca02357b38
3 changed files with 25 additions and 11 deletions

View File

@@ -2,43 +2,58 @@
#shellcheck shell=dash #shellcheck shell=dash
# #
PAYLOAD=$(cat /tmp/es_state.inf) event_data=$(cat /tmp/es_state.inf)
REMOTE_BASE="saves:gamepi-tv" REMOTE_BASE="saves:gamepi-tv"
PIPE="/tmp/savesync_pipe" PIPE="/tmp/savesync_pipe"
#DEBUG=1
log() { log() {
# $1 = level # $1 = level
# $2 = message # $2 = message
printf "LOG:[%s] %s" "$1" "$2" >"$PIPE" printf "LOG:[%s] %s\n" "$1" "$2" >"$PIPE"
} }
log "INFO" "Event received: $PAYLOAD" log "INFO" "Starting based on event"
# Process the multi-line event data
# We use echo and a pipe to feed the while loop ## Iterate over the data
echo "$PAYLOAD" | tr -d '\r' | while IFS="=" read -r key val; do echo "$event_data" | while IFS='=' read -r key val; do
# Split each pair into key and value using '=' as the delimiter
# set variables and run functions based on the pairs
case "$key" in case "$key" in
"SystemId") sid="$val" ;; "SystemId")
sid="$val"
log "DEBUG" "Setting sid=$sid"
;;
"GamePath") "GamePath")
gp="$val" gp="$val"
sp=$(echo "$val" | sed 's|roms|saves|; s|\.[^.]*$|.srm|') sp=$(echo "$val" | sed 's|roms|saves|; s|\.[^.]*$|.srm|')
bp=$(echo "$sp" | sed 's|saves|archives|') bp=$(echo "$sp" | sed 's|saves|archives|')
log "DEBUG" "Setting values {gp=$gp, sp=$sp, bp=$bp}"
;;
"Action")
act="$val"
log "DEBUG" "Setting act=$act"
;; ;;
"Action") act="$val" ;;
"State") "State")
st="$val" st="$val"
log "DEBUG" "Setting st=$st"
log "DEBUG" "Starting logic tree"
if [ "$st" = "playing" ] && [ "$act" = "rungame" ]; then if [ "$st" = "playing" ] && [ "$act" = "rungame" ]; then
log "INFO" "Sync START: $(basename "$gp")" log "INFO" "Sync START: $(basename "$gp")"
remote_f="$REMOTE_BASE/$sid/$(basename "$sp")" remote_f="$REMOTE_BASE/$sid/$(basename "$sp")"
loc_sz=$(stat -c %s "$sp" 2>/dev/null || echo 0) loc_sz=$(stat -c %s "$sp" 2>/dev/null || echo 0)
log "DEBUG" "local_size = $loc_sz"
rem_sz=$(rclone lsjson "$remote_f" 2>/dev/null | grep -o '"Size":[0-9]*' | cut -d: -f2) rem_sz=$(rclone lsjson "$remote_f" 2>/dev/null | grep -o '"Size":[0-9]*' | cut -d: -f2)
: "${rem_sz:=0}" : "${rem_sz:=0}"
log "DEBUG" "remote_size = $rem_sz"
if [ "$loc_sz" -lt "$rem_sz" ]; then if [ "$loc_sz" -lt "$rem_sz" ]; then
log "WARN" "Cloud save larger ($rem_sz). Restoring..." log "WARN" "Cloud save larger ($rem_sz). Restoring..."
mkdir -p "$(dirname "$bp")" mkdir -p "$(dirname "$bp")"
log "DEBUG" "rclone copyto $remote_f $sp --backup-dir $(dirname $bp)" log "DEBUG" "rclone copyto $remote_f $sp --backup-dir $(dirname "$bp")"
rclone copyto "$remote_f" "$sp" --backup-dir "$(dirname "$bp")" rclone copyto "$remote_f" "$sp" --backup-dir "$(dirname "$bp")"
else else
log "INFO" "Local save current. Updating..." log "INFO" "Local save current. Updating..."
@@ -51,7 +66,6 @@ echo "$PAYLOAD" | tr -d '\r' | while IFS="=" read -r key val; do
log "DEBUG" "rclone update $sp $REMOTE_BASE/$sid/" log "DEBUG" "rclone update $sp $REMOTE_BASE/$sid/"
rclone update "$sp" "$REMOTE_BASE/$sid/" rclone update "$sp" "$REMOTE_BASE/$sid/"
log "INFO" "Final Sync Done." log "INFO" "Final Sync Done."
#mosquitto_pub -t "$RESPONSE_TOPIC" -m "SaveSync=0" 2>/dev/null
fi fi
;; ;;
esac esac