From 94825d3547ee053fd8e22a25427d17f589c7524e Mon Sep 17 00:00:00 2001
From: Luke Van Seters <lukevanseters@gmail.com>
Date: Wed, 19 Jan 2022 16:48:12 -0500
Subject: [PATCH] Update mev_summary for all inspections

---
 listener.py                  | 2 --
 mev_inspect/crud/summary.py  | 4 ----
 mev_inspect/inspect_block.py | 8 ++++++++
 3 files changed, 8 insertions(+), 6 deletions(-)

diff --git a/listener.py b/listener.py
index 4874c7c..9da3a45 100644
--- a/listener.py
+++ b/listener.py
@@ -10,7 +10,6 @@ from mev_inspect.crud.latest_block_update import (
     find_latest_block_update,
     update_latest_block,
 )
-from mev_inspect.crud.summary import update_summary_for_block
 from mev_inspect.db import get_inspect_session, get_trace_session
 from mev_inspect.inspector import MEVInspector
 from mev_inspect.provider import get_base_provider
@@ -81,7 +80,6 @@ async def inspect_next_block(
             block=block_number,
         )
 
-        update_summary_for_block(inspect_db_session, block_number)
         update_latest_block(inspect_db_session, block_number)
 
         if healthcheck_url:
diff --git a/mev_inspect/crud/summary.py b/mev_inspect/crud/summary.py
index ce267c4..81f5614 100644
--- a/mev_inspect/crud/summary.py
+++ b/mev_inspect/crud/summary.py
@@ -71,10 +71,6 @@ INSERT INTO mev_summary (
 """
 
 
-def update_summary_for_block(db_session, block_number: int) -> None:
-    update_summary_for_block_range(db_session, block_number, block_number + 1)
-
-
 def update_summary_for_block_range(
     db_session,
     after_block_number: int,
diff --git a/mev_inspect/inspect_block.py b/mev_inspect/inspect_block.py
index f97de75..db24347 100644
--- a/mev_inspect/inspect_block.py
+++ b/mev_inspect/inspect_block.py
@@ -27,6 +27,7 @@ from mev_inspect.crud.punks import (
     write_punk_snipes,
 )
 from mev_inspect.crud.sandwiches import delete_sandwiches_for_blocks, write_sandwiches
+from mev_inspect.crud.summary import update_summary_for_block_range
 from mev_inspect.crud.swaps import delete_swaps_for_blocks, write_swaps
 from mev_inspect.crud.traces import (
     delete_classified_traces_for_blocks,
@@ -225,4 +226,11 @@ async def inspect_many_blocks(
         inspect_db_session, after_block_number, before_block_number
     )
     write_miner_payments(inspect_db_session, all_miner_payments)
+
+    update_summary_for_block_range(
+        inspect_db_session,
+        after_block_number,
+        before_block_number,
+    )
+
     logger.info("Done writing")