{{{#!/bin/sh -f
#Change this to reflect your cluster name, log file location, host, port number, and your user and db name!!!
SLONYCLUSTER=jsoc_example
ARCHIVEDIR=/surge/slony/jsoc_slave_logs
REPLICATIONUSER=postgres
PGDATABASE=jsoc
PGPORT=5444
PGHOST=myhost.stanford.edu
#End your changes
FILEPREFIX=slony1_log_2_
NEXTQUERY="select at_counter+1 from \"_${SLONYCLUSTER}\".sl_archive_tracking;"
nextseq=`psql -d ${PGDATABASE} -p ${PGPORT} -U ${REPLICATIONUSER} -h ${PGHOST} -A -t -c "${NEXTQUERY}"`
#last_counter=400000
while true; do
#while [ $nextseq -lt $last_counter ]; do
#Could do fewer selects/psqls I suppose, but better safe than sorry for the time being
  NEXTQUERY="select at_counter+1 from \"_${SLONYCLUSTER}\".sl_archive_tracking;"
  nextseq=`psql -d ${PGDATABASE} -p ${PGPORT} -U ${REPLICATIONUSER} -h ${PGHOST} -A -t -c "${NEXTQUERY}"`
  filespec=`printf "slony1_log_2_"%020d".sql" $nextseq`
  echo 'Looking for next file: ' ${filespec}
  if [ -f $ARCHIVEDIR/$filespec ]
        then
                echo "Found it!  Applying it to the log slave database..."
                echo $nextseq
                echo $last_counter
                psql -d ${PGDATABASE} -p ${PGPORT} -U ${REPLICATIONUSER} -h ${PGHOST} -f ${ARCHIVEDIR}/${filespec}
        else
                echo "Not found.  Going to sleep for a bit while we wait for the file to arrive..."
                sleep 10;
        fi
done}}}