#!/bin/sh

# compress synapse database room graphs

# (cc) Peter 'grin' Gervai, 2020

ARG="$1"

source _config.sh

set -x

CMD="SELECT room_id, COUNT(*), type FROM state_groups_state GROUP BY 1,3 HAVING COUNT(*)>999999 ORDER BY 2 DESC;"

BASE="/root/matrix-synapse/clean_auto"

LOG="${BASE}/process.log"

savelog -c 4 $LOG

TMP=`mktemp /tmp/synapse_compress.XXXXXXXX`

echo "==== `date +%F_%T` now." 						>> ${LOG}

if [ "x$ARG" = "x" ]; then

	echo "Collecting room/state groups data..."				| tee -a ${LOG}

	if ! psql "${DB}" synapse -tAc "${CMD}" > $TMP; then

		echo "Error getting room stats. Exit."

		exit 1

	fi

else

	echo "Processing already collected data ${ARG}."

	rm "${TMP}"

	TMP="$ARG"

fi

awk -F'|' '{print $1}' < $TMP | while read room; do

	NOW=`date +%F_%T`

	echo "Processing room ${room}... into c${NOW}_compress.sql" 	| tee -a ${LOG}

	/usr/bin/time ../synapse-compress-state -o "c${NOW}_compress.sql" -p "${DB}" -t -r "${room}" 	| tee -a ${LOG}

	echo "Actually compressing (c${NOW}_compress.sql)..."		| tee -a ${LOG}

	/usr/bin/time psql "${DBRW}" synapse -f "c${NOW}_compress.sql" 	| tee -a ${LOG}

done

echo "We shall delete ${TMP} file."					| tee -a ${LOG}

set +x