github/plane
0
0
Fork 1
mirror of https://github.com/makeplane/plane synced 2024-06-14 14:31:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

dev: update issue notifications

Browse Source
This commit is contained in:
pablohashescobar 2023-07-03 17:28:09 +05:30
parent ebc9f36dc2
commit ea605cf48c
1 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
apiserver/plane/bgtasks/issue_activites_task.py
View File

@ -22,6 +22,7 @@ from plane.db.models import (
Module, Module,
IssueSubscriber, IssueSubscriber,
Notification, Notification,
IssueAssignee,
) )
from plane.api.serializers import IssueActivitySerializer, IssueFlatSerializer from plane.api.serializers import IssueActivitySerializer, IssueFlatSerializer
@ -960,6 +961,12 @@ def issue_activity(
actor = User.objects.get(pk=actor_id) actor = User.objects.get(pk=actor_id)
project = Project.objects.get(pk=project_id) project = Project.objects.get(pk=project_id)
# add the user to issue subscriber
try:
_ = IssueSubscriber.objects.create(issue_id=issue_id, subscriber=actor)
except Exception as e:
pass
ACTIVITY_MAPPER = { ACTIVITY_MAPPER = {
"issue.activity.created": create_issue_activity, "issue.activity.created": create_issue_activity,
"issue.activity.updated": update_issue_activity, "issue.activity.updated": update_issue_activity,
@ -1013,12 +1020,20 @@ def issue_activity(
# Create Notifications # Create Notifications
bulk_notifications = [] bulk_notifications = []
issue_subscribers = ( issue_subscribers = list(
IssueSubscriber.objects.filter(project=project, issue_id=issue_id) IssueSubscriber.objects.filter(project=project, issue_id=issue_id)
.exclude(subscriber_id=actor_id) .exclude(subscriber_id=actor_id)
.values_list("subscriber", flat=True) .values_list("subscriber", flat=True)
) )
issue_assignees = list(
IssueAssignee.objects.filter(project=project, issue_id=issue_id)
.exclude(assignee_id=actor_id)
.values_list("assignee", flat=True)
)
issue_subscribers = issue_subscribers + issue_assignees
issue = Issue.objects.get(project=project, pk=issue_id) issue = Issue.objects.get(project=project, pk=issue_id)
for subscriber in issue_subscribers: for subscriber in issue_subscribers:
for issue_activity in issue_activities_created: for issue_activity in issue_activities_created: