From 6e8d898cb012fe70c4feefa035e39860c67d9d65 Mon Sep 17 00:00:00 2001 From: Luke Van Seters Date: Mon, 20 Dec 2021 12:37:20 -0500 Subject: [PATCH 1/2] Start listener from block lag --- listener.py | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/listener.py b/listener.py index d88a996..0965b1b 100644 --- a/listener.py +++ b/listener.py @@ -65,14 +65,10 @@ async def inspect_next_block( if last_written_block is None: # maintain lag if no blocks written yet - last_written_block = latest_block_number - 1 + last_written_block = latest_block_number - BLOCK_NUMBER_LAG - 1 if last_written_block < (latest_block_number - BLOCK_NUMBER_LAG): - block_number = ( - latest_block_number - if last_written_block is None - else last_written_block + 1 - ) + block_number = last_written_block + 1 logger.info(f"Writing block: {block_number}") From a2f8b5c08ead47793e9d3ad954a21cbe20085a52 Mon Sep 17 00:00:00 2001 From: Luke Van Seters Date: Mon, 20 Dec 2021 12:43:27 -0500 Subject: [PATCH 2/2] Remove PIDFILE after stop --- listener | 2 ++ 1 file changed, 2 insertions(+) diff --git a/listener b/listener index 0a86c50..218f401 100755 --- a/listener +++ b/listener @@ -23,6 +23,7 @@ case "$1" in stop) echo -n "Stopping daemon: "$NAME start-stop-daemon --stop --quiet --oknodo --pidfile $PIDFILE + rm $PIDFILE echo "." ;; tail) @@ -31,6 +32,7 @@ case "$1" in restart) echo -n "Restarting daemon: "$NAME start-stop-daemon --stop --quiet --oknodo --retry 30 --pidfile $PIDFILE + rm $PIDFILE start-stop-daemon \ --background \ --chdir /app \