#!/usr/bin/env bash
set -euo pipefail

script_dir=$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)
# shellcheck source=scripts/cluster/common.sh
source "$script_dir/common.sh"
load_cluster_env

cluster_ssh "$CLUSTER_NINGBO_HOST" 'bash -s' <<'REMOTE'
set -euo pipefail
snapshot_name=acceptance-$(date -u '+%Y%m%dT%H%M%SZ')
k3s etcd-snapshot save --name "$snapshot_name" >/dev/null
snapshot=$(find /var/lib/rancher/k3s/server/db/snapshots -maxdepth 1 -type f \
  -name "$snapshot_name-*" -printf '%T@ %p\n' | sort -rn | awk 'NR == 1 { sub(/^[^ ]+ /, ""); print }')
[[ -n $snapshot && -s $snapshot ]]
etcdutl=$(find /var/lib/rancher/k3s/data -type f -path '*/bin/etcdutl' -print -quit)
[[ -x $etcdutl ]]
working_directory=$(mktemp -d)
trap 'rm -rf -- "$working_directory"' EXIT
case $snapshot in
  *.zip)
    if command -v unzip >/dev/null 2>&1 && unzip -t "$snapshot" >/dev/null 2>&1; then
      unzip -p "$snapshot" >"$working_directory/snapshot.db"
    else
      gzip -dc "$snapshot" >"$working_directory/snapshot.db"
    fi
    ;;
  *) cp "$snapshot" "$working_directory/snapshot.db" ;;
esac
"$etcdutl" snapshot status "$working_directory/snapshot.db" -w json |
  jq -e '.hash != null and .totalKey > 0 and .totalSize > 0' >/dev/null
k3s etcd-snapshot ls --s3 | grep -F "$snapshot_name" >/dev/null
echo "etcd_backup_verification=PASS snapshot=$snapshot_name local=true oss=true"
REMOTE