Misago/misago/threads/api/postingendpoint/syncprivatethreads.py

from misago.categories.models import PRIVATE_THREADS_ROOT_NAME

from ...participants import set_users_unread_private_threads_sync
from . import PostingEndpoint, PostingMiddleware


class SyncPrivateThreadsMiddleware(PostingMiddleware):
    """
    Middleware that sets private thread participants to sync unread threads
    """
    def use_this_middleware(self):
        if self.mode == PostingEndpoint.REPLY:
            return self.thread.thread_type.root_name == PRIVATE_THREADS_ROOT_NAME
        return False

    def post_save(self, serializer):
        set_users_unread_private_threads_sync(
            participants=self.thread.participants_list,
            exclude_user=self.user
        )