start.sh

#!/usr/bin/env bash
set -e
export PGPASSWORD=$POSTGRES_PASSWORD
# Upload files
cloudStorageOps() {
	local LOCAL_STATE_FILE=state.txt
	local filepath=$1
	local cloudpath=$2

	case "${CLOUDPROVIDER}" in
	aws)
		aws s3 cp ${filepath} s3://${AWS_S3_BUCKET}/${cloudpath}
		echo s3://${AWS_S3_BUCKET}/${cloudpath} >${LOCAL_STATE_FILE}
		aws s3 cp ${LOCAL_STATE_FILE} s3://${AWS_S3_BUCKET}/${BACKUP_CLOUD_FOLDER}/state.txt
		;;
	gcp)
		gsutil cp ${filepath} gs://${GCP_STORAGE_BUCKET}/${cloudpath}
		echo "gs://${GCP_STORAGE_BUCKET}/${CLOUD_BACKUP_FILE}" >${LOCAL_STATE_FILE}
		gsutil cp ${LOCAL_STATE_FILE} gs://${GCP_STORAGE_BUCKET}/${BACKUP_CLOUD_FOLDER}/state.txt
		;;
	azure)
		az storage blob upload \
			--container-name ${AZURE_CONTAINER_NAME} \
			--file ${filepath} \
			--name ${cloudpath} \
			--output table
		echo "blob://${AZURE_STORAGE_ACCOUNT}/${AZURE_CONTAINER_NAME}/${CLOUD_BACKUP_FILE}" >${LOCAL_STATE_FILE}
		az storage blob upload \
			--container-name ${AZURE_CONTAINER_NAME} \
			--file ${LOCAL_STATE_FILE} \
			--name ${BACKUP_CLOUD_FOLDER}/state.txt \
			--output table
		;;
	esac
}

backupDB() {
	local LOCAL_BACKUP_FILE=${BACKUP_CLOUD_FILE}.sql.gz
	local CLOUD_BACKUP_FILE="${BACKUP_CLOUD_FOLDER}/${BACKUP_CLOUD_FILE}.sql.gz"
	if [ "$SET_DATE_AT_NAME" == "true" ]; then
		local CURRENT_DATE=$(date '+%Y%m%d-%H%M')
		LOCAL_BACKUP_FILE="${BACKUP_CLOUD_FILE}-${CURRENT_DATE}.sql.gz"
		CLOUD_BACKUP_FILE="${BACKUP_CLOUD_FOLDER}/${BACKUP_CLOUD_FILE}-${CURRENT_DATE}.sql.gz"
	fi

	# Backup database with max compression
	echo "Backing up DB ${POSTGRES_DB} into ${LOCAL_BACKUP_FILE}"
	pg_dump -h ${POSTGRES_HOST} -U ${POSTGRES_USER} ${POSTGRES_DB} | gzip -9 >${LOCAL_BACKUP_FILE}

	# Handle cloud storage based on the provider
	cloudStorageOps "${LOCAL_BACKUP_FILE}" "${CLOUD_BACKUP_FILE}"
}

restoreDB() {
	local CURRENT_DATE=$(date '+%Y%m%d-%H%M')
	local RESTORE_FILE="backup.sql.gz"
	local LOG_RESULT_FILE="restore_results-${CURRENT_DATE}.log"
	local flag=true

	while "$flag" = true; do
		pg_isready -h ${POSTGRES_HOST} -p 5432 >/dev/null 2>&2 || continue
		flag=false
		wget -O ${RESTORE_FILE} ${RESTORE_URL_FILE}
		echo "Restoring ${RESTORE_URL_FILE} in ${POSTGRES_DB}"
		gunzip -c <${RESTORE_FILE} | psql -h ${POSTGRES_HOST} -U ${POSTGRES_USER} -d ${POSTGRES_DB} | tee ${LOG_RESULT_FILE}
		# aws s3 cp ${LOG_RESULT_FILE} s3://${AWS_S3_BUCKET}/${LOG_RESULT_FILE}
		echo "Import data to ${POSTGRES_DB} has finished ..."
	done
}

delete_old_s3_files() {
	# Use RETENTION_DAYS from environment variable or default to 30 days
	if [ -z "${RETENTION_DAYS}" ]; then
		DAYS_AGO=30
	else
		DAYS_AGO="${RETENTION_DAYS}"
	fi

	echo "Files older than $DAYS_AGO days will be deleted."
	echo "Processing s3://${AWS_S3_BUCKET}/${BACKUP_CLOUD_FOLDER}/"
	TARGET_DATE=$(date -d "${DAYS_AGO} days ago" +%Y-%m-%d)
	aws s3 ls "s3://${AWS_S3_BUCKET}/${BACKUP_CLOUD_FOLDER}/" --recursive | while read -r line; do
		FILE_DATE=$(echo "$line" | awk '{print $1}')
		FILE_PATH=$(echo "$line" | awk '{print $4}')
		if [[ "$FILE_DATE" < "$TARGET_DATE" && ! -z "$FILE_PATH" ]]; then
			echo "Deleting ${FILE_PATH} which was modified on ${FILE_DATE}"
			aws s3 rm "s3://${AWS_S3_BUCKET}/${FILE_PATH}"
		fi
	done
}

# Main logic
case "${DB_ACTION}" in
backup)
	backupDB
	;;
restore)
	restoreDB
	;;
*)
	echo "Unknown action: ${DB_ACTION}"
	exit 1
	;;
esac

# Check for the CLEAN_BACKUPS var
if [ "$CLEANUP_BACKUPS" == "true" ]; then
	delete_old_s3_files
else
	echo "CLEANUP_BACKUPS is not set to true. Skipping deletion."
fi