''' defines relationships between users ''' from django.db import models from django.db.models import Q from django.dispatch import receiver from bookwyrm import activitypub from .base_model import ActivitypubMixin, BookWyrmModel from . import fields class UserRelationship(ActivitypubMixin, BookWyrmModel): ''' many-to-many through table for followers ''' user_subject = fields.ForeignKey( 'User', on_delete=models.PROTECT, related_name='%(class)s_user_subject', activitypub_field='actor', ) user_object = fields.ForeignKey( 'User', on_delete=models.PROTECT, related_name='%(class)s_user_object', activitypub_field='object', ) class Meta: ''' relationships should be unique ''' abstract = True constraints = [ models.UniqueConstraint( fields=['user_subject', 'user_object'], name='%(class)s_unique' ), models.CheckConstraint( check=~models.Q(user_subject=models.F('user_object')), name='%(class)s_no_self' ) ] activity_serializer = activitypub.Follow def get_remote_id(self, status=None):# pylint: disable=arguments-differ ''' use shelf identifier in remote_id ''' status = status or 'follows' base_path = self.user_subject.remote_id return '%s#%s/%d' % (base_path, status, self.id) def to_accept_activity(self): ''' generate an Accept for this follow request ''' return activitypub.Accept( id=self.get_remote_id(status='accepts'), actor=self.user_object.remote_id, object=self.to_activity() ).serialize() def to_reject_activity(self): ''' generate a Reject for this follow request ''' return activitypub.Reject( id=self.get_remote_id(status='rejects'), actor=self.user_object.remote_id, object=self.to_activity() ).serialize() class UserFollows(UserRelationship): ''' Following a user ''' status = 'follows' @classmethod def from_request(cls, follow_request): ''' converts a follow request into a follow relationship ''' return cls( user_subject=follow_request.user_subject, user_object=follow_request.user_object, remote_id=follow_request.remote_id, ) class UserFollowRequest(UserRelationship): ''' following a user requires manual or automatic confirmation ''' status = 'follow_request' def save(self, *args, **kwargs): ''' make sure the follow relationship doesn't already exist ''' try: UserFollows.objects.get( user_subject=self.user_subject, user_object=self.user_object ) return None except UserFollows.DoesNotExist: return super().save(*args, **kwargs) class UserBlocks(UserRelationship): ''' prevent another user from following you and seeing your posts ''' status = 'blocks' activity_serializer = activitypub.Block @receiver(models.signals.post_save, sender=UserBlocks) #pylint: disable=unused-argument def execute_after_save(sender, instance, created, *args, **kwargs): ''' remove follow or follow request rels after a block is created ''' UserFollows.objects.filter( Q(user_subject=instance.user_subject, user_object=instance.user_object) | \ Q(user_subject=instance.user_object, user_object=instance.user_subject) ).delete() UserFollowRequest.objects.filter( Q(user_subject=instance.user_subject, user_object=instance.user_object) | \ Q(user_subject=instance.user_object, user_object=instance.user_subject) ).delete()