diff options
| -rw-r--r-- | synapse/app/pusher.py | 5 | ||||
| -rw-r--r-- | synapse/replication/slave/storage/event_push_actions.py | 51 |
2 files changed, 1 insertions, 55 deletions
diff --git a/synapse/app/pusher.py b/synapse/app/pusher.py index fbed9763c0..27f878e429 100644 --- a/synapse/app/pusher.py +++ b/synapse/app/pusher.py @@ -23,7 +23,6 @@ from synapse.config.database import DatabaseConfig from synapse.config.logger import LoggingConfig from synapse.replication.slave.storage.events import SlavedEventStore from synapse.replication.slave.storage.pushers import SlavedPusherStore -from synapse.replication.slave.storage.event_push_actions import SlavedPushActionsStore from synapse.replication.slave.storage.receipts import SlavedReceiptsStore from synapse.storage.engines import create_engine from synapse.storage import DataStore @@ -60,9 +59,7 @@ class PusherSlaveConfig(SlaveConfig, LoggingConfig): class PusherSlaveStore( - SlavedPushActionsStore, - SlavedEventStore, SlavedPusherStore, - SlavedReceiptsStore + SlavedEventStore, SlavedPusherStore, SlavedReceiptsStore ): update_pusher_last_stream_ordering_and_success = ( DataStore.update_pusher_last_stream_ordering_and_success.__func__ diff --git a/synapse/replication/slave/storage/event_push_actions.py b/synapse/replication/slave/storage/event_push_actions.py deleted file mode 100644 index 8774feb94e..0000000000 --- a/synapse/replication/slave/storage/event_push_actions.py +++ /dev/null @@ -1,51 +0,0 @@ -# -*- coding: utf-8 -*- -# Copyright 2016 OpenMarket Ltd -# -# Licensed under the Apache License, Version 2.0 (the "License"); -# you may not use this file except in compliance with the License. -# You may obtain a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, -# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -# See the License for the specific language governing permissions and -# limitations under the License. - - -from .events import SlavedEventStore -from .receipts import SlavedReceiptsStore - -from synapse.storage import DataStore -from synapse.storage.event_push_actions import EventPushActionsStore - - -class SlavedPushActionsStore(SlavedEventStore, SlavedReceiptsStore): - get_unread_event_push_actions_by_room_for_user = ( - EventPushActionsStore.__dict__["get_unread_event_push_actions_by_room_for_user"] - ) - - get_unread_push_actions_for_user_in_range = ( - DataStore.get_unread_push_actions_for_user_in_range.__func__ - ) - - get_push_action_users_in_range = ( - DataStore.get_push_action_users_in_range.__func__ - ) - - def invalidate_caches_for_event(self, event, backfilled, reset_state): - self.get_unread_event_push_actions_by_room_for_user.invalidate_many( - (event.room_id,) - ) - super(SlavedPushActionsStore, self).invalidate_caches_for_event( - event, backfilled, reset_state - ) - - def invalidate_caches_for_receipt(self, room_id, receipt_type, user_id): - self.get_unread_event_push_actions_by_room_for_user.invalidate_many( - (room_id,) - ) - super(SlavedPushActionsStore, self).invalidate_caches_for_receipt( - room_id, receipt_type, user_id - ) |