hive/db/db_state.py

@@ -107,12 +107,11 @@ class DbState:
             'hive_posts_payout_at_idx',
             'hive_posts_payout_idx',
             'hive_posts_promoted_idx',
-            'hive_posts_sc_trend_id_idx',
-            'hive_posts_sc_hot_id_idx',
+            'hive_posts_sc_trend_id_is_paidout_idx',
+            'hive_posts_sc_hot_id_is_paidout_idx',
             'hive_posts_block_num_idx',
             'hive_posts_cashout_time_id_idx',
             'hive_posts_updated_at_idx',
-            'hive_posts_is_paidout_idx',
             'hive_posts_payout_plus_pending_payout_id',
 
             'hive_votes_block_num_idx',

hive/db/schema.py

@@ -144,13 +144,12 @@ def build_metadata():
         sa.Index('hive_posts_payout_at_idx', 'payout_at'),
         sa.Index('hive_posts_payout_idx', 'payout'),
         sa.Index('hive_posts_promoted_idx', 'promoted'),
-        sa.Index('hive_posts_sc_trend_id_idx', 'sc_trend', 'id'),
-        sa.Index('hive_posts_sc_hot_id_idx', 'sc_hot', 'id'),
+        sa.Index('hive_posts_sc_trend_id_is_paidout_idx', 'sc_trend', 'id', 'is_paidout'),
+        sa.Index('hive_posts_sc_hot_id_is_paidout_idx', 'sc_hot', 'id', 'is_paidout'),
         sa.Index('hive_posts_created_at_idx', 'created_at'),
         sa.Index('hive_posts_block_num_idx', 'block_num'),
         sa.Index('hive_posts_cashout_time_id_idx', 'cashout_time', 'id'),
         sa.Index('hive_posts_updated_at_idx', sa.text('updated_at DESC')),
-        sa.Index('hive_posts_is_paidout_idx', 'is_paidout'),
         sa.Index('hive_posts_payout_plus_pending_payout_id', sa.text('(payout+pending_payout), id'))
     )
 

hive/db/sql_scripts/hive_posts_base_view.sql

@@ -20,7 +20,7 @@ CREATE OR REPLACE VIEW public.hive_posts_base_view
    FROM hive_posts hp
 ;
 
-DROP VIEW IF EXISTS public.hive_posts_pp_view;
+DROP VIEW IF EXISTS public.hive_posts_pp_view CASCADE;
 
 CREATE OR REPLACE VIEW public.hive_posts_pp_view
  AS

hive/server/common/helpers.py

@@ -16,6 +16,9 @@ class ApiError(Exception):
     # pylint: disable=unnecessary-pass
     pass
 
+# values -32768..-32000 are reserved
+ACCESS_TO_DELETED_POST_ERROR_CODE = -31999
+
 def return_error_info(function):
     """Async API method decorator which catches and formats exceptions."""
     @wraps(function)
@@ -26,7 +29,7 @@ def return_error_info(function):
         except (RaiseException) as e:
             msg = e.diag.message_primary
             if 'was deleted' in msg:
-                raise RPCApiError('Invalid parameters',-32199,msg) # deleted post
+                raise RPCApiError('Invalid parameters', ACCESS_TO_DELETED_POST_ERROR_CODE, msg)
             else:
                 raise AssertionError(msg)
         except (ApiError, AssertionError, TypeError, Exception) as e:

hive/server/common/mutes.py

@@ -3,6 +3,7 @@
 import logging
 from time import perf_counter as perf
 from urllib.request import urlopen, Request
+from hive.db.adapter import Db
 
 log = logging.getLogger(__name__)
 
@@ -64,7 +65,13 @@ class Mutes:
 
     def load(self):
         """Reload all accounts from irredeemables endpoint and global lists."""
-        # TODO: Refactor/remove this method
+        self.all_accounts.clear()
+        sql = "select id, name from hive_accounts"
+        db = Db.instance()
+        sql_result = db.query_all(sql)
+        for row in sql_result:
+            self.all_accounts[row['id']] = row['name']
+        self.fetched = perf()
 
     @classmethod
     def all(cls):

hive/server/condenser_api/get_state.py

@@ -137,7 +137,7 @@ async def get_state(context, path: str):
         assert not part[2], "unexpected discussion path part[2] %s" % path
         sort = valid_sort(part[0])
         tag = valid_tag(part[1].lower(), allow_empty=True)
-        pids = await get_posts_by_given_sort(db, sort, '', '', 20, tag)
+        pids = await get_posts_by_given_sort(context, sort, '', '', 20, tag)
         state['content'] = _keyed_posts(await load_posts(db, pids))
         state['discussion_idx'] = {tag: {sort: list(state['content'].keys())}}
         state['tag_idx'] = {'trending': await get_top_trending_tags_summary(context)}

tests_api @ ae53a82f

-Subproject commit b174c02c821e6f2386cf31ee0f17969b1fa94289
+Subproject commit ae53a82f46e6338a04e40b4966f8e7b0e64e6c86