Prerequisuites to Reputation api support

hive/indexer/blocks.py

@@ -43,6 +43,7 @@ class Blocks:
     _current_block_date = None
 
     _concurrent_flush = [
+      ('Posts', Posts.flush, Posts),
       ('PostDataCache', PostDataCache.flush, PostDataCache),
       ('Reputations', Reputations.flush, Reputations),
       ('Votes', Votes.flush, Votes), 
@@ -65,6 +66,7 @@ class Blocks:
         Votes.setup_db_access(sharedDbAdapter)
         Tags.setup_db_access(sharedDbAdapter)
         Follow.setup_db_access(sharedDbAdapter)
+        Posts.setup_db_access(sharedDbAdapter)
 
     @classmethod
     def head_num(cls):
@@ -126,11 +128,12 @@ class Blocks:
 
         log.info("#############################################################################")
         flush_time = register_time(flush_time, "Blocks", cls._flush_blocks())
-        flush_time = register_time(flush_time, "Posts", Posts.flush())
 
         folllow_items = len(Follow.follow_items_to_flush) + Follow.flush(trx=False)
         flush_time = register_time(flush_time, "Follow", folllow_items)
 
+        DB.query("COMMIT")
+
         completedThreads = 0;
 
         pool = ThreadPoolExecutor(max_workers = len(cls._concurrent_flush))
@@ -155,9 +158,9 @@ class Blocks:
         assert completedThreads == len(cls._concurrent_flush)
 
         if (not is_initial_sync) and (first_block > -1):
+            DB.query("START TRANSACTION")
             cls.on_live_blocks_processed( first_block, last_num )
-
-        DB.query("COMMIT")
+            DB.query("COMMIT")
 
         log.info(f"[PROCESS MULTI] {len(blocks)} blocks in {OPSM.stop(time_start) :.4f}s")