osqa/forum/subscriptions.py

   1 import os\r
   2 import re\r
   3 import datetime\r
   4 from forum.models import User, Question, Comment, QuestionSubscription, SubscriptionSettings, Answer\r
   5 from forum.models.user import activity_record\r
   6 from forum.utils.mail import send_email\r
   7 from forum.views.readers import question_view\r
   8 from django.utils.translation import ugettext as _\r
   9 from django.conf import settings\r
  10 from django.db.models import Q, F\r
  11 from django.db.models.signals import post_save\r
  12 from django.contrib.contenttypes.models import ContentType\r
  13 import const\r
  14 \r
  15 def create_subscription_if_not_exists(question, user):\r
  16     try:\r
  17         subscription = QuestionSubscription.objects.get(question=question, user=user)\r
  18     except:\r
  19         subscription = QuestionSubscription(question=question, user=user)\r
  20         subscription.save()\r
  21 \r
  22 def apply_default_filters(queryset, excluded_id):\r
  23     return queryset.values('email', 'username').exclude(id=excluded_id)\r
  24 \r
  25 def create_recipients_dict(usr_list):\r
  26     return [(s['username'], s['email'], {'username': s['username']}) for s in usr_list]\r
  27 \r
  28 def question_posted(sender, instance, **kwargs):\r
  29     question = instance.content_object\r
  30 \r
  31     subscribers = User.objects.values('email', 'username').filter(\r
  32             Q(subscription_settings__enable_notifications=True, subscription_settings__new_question='i') |\r
  33             (Q(subscription_settings__new_question_watched_tags='i') &\r
  34               Q(marked_tags__name__in=question.tagnames.split(' ')) &\r
  35               Q(tag_selections__reason='good'))\r
  36     ).exclude(id=question.author.id).distinct()\r
  37 \r
  38     recipients = create_recipients_dict(subscribers)\r
  39 \r
  40     send_email(settings.EMAIL_SUBJECT_PREFIX + _("New question on %(app_name)s") % dict(app_name=settings.APP_SHORT_NAME),\r
  41                recipients, "notifications/newquestion.html", {\r
  42         'question': question,\r
  43     })\r
  44 \r
  45     if question.author.subscription_settings.questions_asked:\r
  46         subscription = QuestionSubscription(question=question, user=question.author)\r
  47         subscription.save()\r
  48 \r
  49     new_subscribers = User.objects.filter(\r
  50             Q(subscription_settings__all_questions=True) |\r
  51             Q(subscription_settings__all_questions_watched_tags=True,\r
  52                     marked_tags__name__in=question.tagnames.split(' '),\r
  53                     tag_selections__reason='good'))\r
  54 \r
  55     for user in new_subscribers:\r
  56         create_subscription_if_not_exists(question, user)\r
  57 \r
  58 activity_record.connect(question_posted, sender=const.TYPE_ACTIVITY_ASK_QUESTION, weak=False)\r
  59 \r
  60 \r
  61 def answer_posted(sender, instance, **kwargs):\r
  62     answer = instance.content_object\r
  63     question = answer.question\r
  64 \r
  65     subscribers = question.subscribers.values('email', 'username').filter(\r
  66             subscription_settings__enable_notifications=True,\r
  67             subscription_settings__notify_answers=True,\r
  68             subscription_settings__subscribed_questions='i'\r
  69     ).exclude(id=answer.author.id).distinct()\r
  70     recipients = create_recipients_dict(subscribers)\r
  71 \r
  72     send_email(settings.EMAIL_SUBJECT_PREFIX + _("New answer to '%(question_title)s'") % dict(question_title=question.title),\r
  73                recipients, "notifications/newanswer.html", {\r
  74         'question': question,\r
  75         'answer': answer\r
  76     })\r
  77 \r
  78     if answer.author.subscription_settings.questions_answered:\r
  79         create_subscription_if_not_exists(question, answer.author)\r
  80 \r
  81 activity_record.connect(answer_posted, sender=const.TYPE_ACTIVITY_ANSWER, weak=False)\r
  82 \r
  83 \r
  84 def comment_posted(sender, instance, **kwargs):\r
  85     comment = instance.content_object\r
  86     post = comment.content_object\r
  87 \r
  88     if post.__class__ == Question:\r
  89         question = post\r
  90     else:\r
  91         question = post.question\r
  92 \r
  93     subscribers = question.subscribers.values('email', 'username')\r
  94 \r
  95     q_filter = Q(subscription_settings__notify_comments=True) | Q(subscription_settings__notify_comments_own_post=True, id=post.author.id)\r
  96 \r
  97     inreply = re.search('@\w+', comment.comment)\r
  98     if inreply is not None:\r
  99         q_filter = q_filter | Q(subscription_settings__notify_reply_to_comments=True,\r
 100                                 username__istartswith=inreply.group(0)[1:],\r
 101                                 comments__object_id=post.id,\r
 102                                 comments__content_type=ContentType.objects.get_for_model(post.__class__)\r
 103                                 )\r
 104 \r
 105     subscribers = subscribers.filter(\r
 106             q_filter, subscription_settings__subscribed_questions='i', subscription_settings__enable_notifications=True \r
 107     ).exclude(id=comment.user.id).distinct()\r
 108 \r
 109     recipients = create_recipients_dict(subscribers)\r
 110 \r
 111     send_email(settings.EMAIL_SUBJECT_PREFIX + _("New comment on %(question_title)s") % dict(question_title=question.title),\r
 112                recipients, "notifications/newcomment.html", {\r
 113                 'comment': comment,\r
 114                 'post': post,\r
 115                 'question': question,\r
 116     })\r
 117 \r
 118     if comment.user.subscription_settings.questions_commented:\r
 119         create_subscription_if_not_exists(question, comment.user)\r
 120 \r
 121 activity_record.connect(comment_posted, sender=const.TYPE_ACTIVITY_COMMENT_QUESTION, weak=False)\r
 122 activity_record.connect(comment_posted, sender=const.TYPE_ACTIVITY_COMMENT_ANSWER, weak=False)\r
 123 \r
 124 \r
 125 def answer_accepted(instance, created, **kwargs):\r
 126     if not created and 'accepted' in instance.get_dirty_fields() and instance.accepted:\r
 127         question = instance.question\r
 128 \r
 129         subscribers = question.subscribers.values('email', 'username').filter(\r
 130                 subscription_settings__enable_notifications=True,\r
 131                 subscription_settings__notify_accepted=True,\r
 132                 subscription_settings__subscribed_questions='i'\r
 133         ).exclude(id=instance.accepted_by.id).distinct()\r
 134         recipients = create_recipients_dict(subscribers)\r
 135 \r
 136         send_email(settings.EMAIL_SUBJECT_PREFIX + _("An answer to '%(question_title)s' was accepted") % dict(question_title=question.title),\r
 137                    recipients, "notifications/answeraccepted.html", {\r
 138             'question': question,\r
 139             'answer': instance\r
 140         })\r
 141 \r
 142 post_save.connect(answer_accepted, sender=Answer)\r
 143 \r
 144 \r
 145 def member_joined(sender, instance, created, **kwargs):\r
 146     if not created:\r
 147         return\r
 148         \r
 149     subscribers = User.objects.values('email', 'username').filter(\r
 150             subscription_settings__enable_notifications=True,\r
 151             subscription_settings__member_joins='i'\r
 152     ).exclude(id=instance.id).distinct()\r
 153 \r
 154     recipients = create_recipients_dict(subscribers)\r
 155 \r
 156     send_email(settings.EMAIL_SUBJECT_PREFIX + _("%(username)s is a new member on %(app_name)s") % dict(username=instance.username, app_name=settings.APP_SHORT_NAME),\r
 157                recipients, "notifications/newmember.html", {\r
 158         'newmember': instance,\r
 159     })\r
 160 \r
 161     sub_settings = SubscriptionSettings(user=instance)\r
 162     sub_settings.save()\r
 163 \r
 164 post_save.connect(member_joined, sender=User, weak=False)\r
 165 \r
 166 def question_viewed(instance, user, **kwargs):\r
 167     if not user.is_authenticated():\r
 168         return\r
 169         \r
 170     try:\r
 171         subscription = QuestionSubscription.objects.get(question=instance, user=user)\r
 172         subscription.last_view = datetime.datetime.now()\r
 173         subscription.save()\r
 174     except:\r
 175         if user.subscription_settings.questions_viewed:\r
 176             subscription = QuestionSubscription(question=instance, user=user)\r
 177             subscription.save()\r
 178 \r
 179 question_view.connect(question_viewed)\r
 180 \r
 181 #todo: this stuff goes temporarily here\r
 182 from forum.models import Award, Answer\r
 183 \r
 184 def notify_award_message(instance, created, **kwargs):\r
 185     if created:\r
 186         user = instance.user\r
 187 \r
 188         msg = (u"Congratulations, you have received a badge '%s'. " \\r
 189                 + u"Check out <a href=\"%s\">your profile</a>.") \\r
 190                 % (instance.badge.name, user.get_profile_url())\r
 191 \r
 192         user.message_set.create(message=msg)\r
 193 \r
 194 post_save.connect(notify_award_message, sender=Award)\r
 195 \r
 196 #todo: translate this\r
 197 record_answer_event_re = re.compile("You have received (a|\d+) .*new response.*")\r
 198 def record_answer_event(instance, created, **kwargs):\r
 199     if created:\r
 200         q_author = instance.question.author\r
 201         found_match = False\r
 202         #print 'going through %d messages' % q_author.message_set.all().count()\r
 203         for m in q_author.message_set.all():\r
 204             #print m.message\r
 205             match = record_answer_event_re.search(m.message)\r
 206             if match:\r
 207                 found_match = True\r
 208                 try:\r
 209                     cnt = int(match.group(1))\r
 210                 except:\r
 211                     cnt = 1\r
 212                 m.message = u"You have received %d <a href=\"%s?sort=responses\">new responses</a>."\\r
 213                             % (cnt+1, q_author.get_profile_url())\r
 214 \r
 215                 m.save()\r
 216                 break\r
 217         if not found_match:\r
 218             msg = u"You have received a <a href=\"%s?sort=responses\">new response</a>."\\r
 219                     % q_author.get_profile_url()\r
 220 \r
 221             q_author.message_set.create(message=msg)\r
 222 \r
 223 post_save.connect(record_answer_event, sender=Answer)