mirrors/bookwyrm
1
0
Fork 1
mirror of https://github.com/bookwyrm-social/bookwyrm.git synced 2024-11-26 11:31:08 +00:00
Code Issues Projects Releases Wiki Activity

Remove ActivityStream.get_stores_for_object

Browse source 
I think this makes the code somewhat more understandable.
This commit is contained in:
Wesley Aptekar-Cassels 2023-04-05 23:18:36 -04:00
parent 7a93b5c315
commit 776c5526c8
1 changed files with 2 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
bookwyrm/activitystreams.py
View file

@ -154,10 +154,6 @@ class ActivityStream(RedisStore):
"""convert a list of user ids into redis store ids"""
return [self.stream_id(user_id) for user_id in user_ids]
def get_stores_for_object(self, obj):
"""the stores that an object belongs in"""
return [self.stream_id(user_id) for user_id in self.get_audience(obj)]
def get_statuses_for_user(self, user): # pylint: disable=no-self-use
"""given a user, what statuses should they see on this stream"""
return models.Status.privacy_filter(
@ -523,7 +519,7 @@ def remove_status_task(status_ids):
for stream in streams.values():
for status in statuses:
stream.remove_object_from_stores(
status, stream.get_stores_for_object(status)
status, stream.get_stores_for_users(stream.get_audience(status))
)
@ -573,7 +569,7 @@ def handle_boost_task(boost_id):
for stream in streams.values():
# people who should see the boost (not people who see the original status)
audience = stream.get_stores_for_object(instance)
audience = stream.get_stores_for_users(stream.get_audience(instance))
stream.remove_object_from_stores(boosted, audience)
for status in old_versions:
stream.remove_object_from_stores(status, audience)