mirrors/bookwyrm
1
0
Fork 1
mirror of https://github.com/bookwyrm-social/bookwyrm.git synced 2024-12-18 22:26:34 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #1328 from bookwyrm-social/unread-count

Browse source 
Increment unread count less wildly
This commit is contained in:
Mouse Reeve 2021-08-23 17:22:59 -06:00 committed by GitHub
commit ac3a989e37
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
bookwyrm/activitystreams.py
View file

@ -23,14 +23,15 @@ class ActivityStream(RedisStore):
"""statuses are sorted by date published""" """statuses are sorted by date published"""
return obj.published_date.timestamp() return obj.published_date.timestamp()
def add_status(self, status): def add_status(self, status, increment_unread=False):
"""add a status to users' feeds""" """add a status to users' feeds"""
# the pipeline contains all the add-to-stream activities # the pipeline contains all the add-to-stream activities
pipeline = self.add_object_to_related_stores(status, execute=False) pipeline = self.add_object_to_related_stores(status, execute=False)
for user in self.get_audience(status): if increment_unread:
# add to the unread status count for user in self.get_audience(status):
pipeline.incr(self.unread_id(user)) # add to the unread status count
pipeline.incr(self.unread_id(user))
# and go! # and go!
pipeline.execute() pipeline.execute()
@ -262,7 +263,7 @@ def add_status_on_create(sender, instance, created, *args, **kwargs):
return return
for stream in streams.values(): for stream in streams.values():
stream.add_status(instance) stream.add_status(instance, increment_unread=created)
if sender != models.Boost: if sender != models.Boost:
return return