1fc5d2bd45
* refactor: folder structure for urls * chore: deleted the urls file * chore: proper naming for urls * chore: reset password url * dev: create refresh token endpoint and endpoint to get settings for user * dev: workspace member me serializer * dev: remove extra fields from project list and retrieve endpoints * dev: update the project list endpoint with member details and deploy boolean * dev: enable user favorite project endpoint and remove is_favorite from project list * dev: analytics refactoring * dev: revert is_favorite settings * dev: create new serializer for project list and add pagination from projects * dev: fix analytics api * dev: module and cycle * dev: update error message, fix module analytics and add null check for labels * dev: member serializer * dev: dynamic base serializer * dev: remove view issues endpoint * dev: url pattern updates * dev: add comments to delete this file * dev: last workspace id * dev: analytics export * dev: export analytics validation * dev: update python runtime * dev: update notification endpoints * dev: cycle and validation fix * dev: issue activity validation when creating updating and deleting issue and comments * dev: update issue activity logging for link and reactions * dev: update module issue activity logging * dev: update module issue activity --------- Co-authored-by: NarayanBavisetti <narayan3119@gmail.com>
1419 lines
50 KiB
Python
1419 lines
50 KiB
Python
# Python imports
|
|
import json
|
|
import requests
|
|
|
|
# Django imports
|
|
from django.conf import settings
|
|
from django.core.serializers.json import DjangoJSONEncoder
|
|
from django.utils import timezone
|
|
|
|
# Third Party imports
|
|
from celery import shared_task
|
|
from sentry_sdk import capture_exception
|
|
|
|
# Module imports
|
|
from plane.db.models import (
|
|
User,
|
|
Issue,
|
|
Project,
|
|
Label,
|
|
IssueActivity,
|
|
State,
|
|
Cycle,
|
|
Module,
|
|
IssueSubscriber,
|
|
Notification,
|
|
IssueAssignee,
|
|
IssueReaction,
|
|
CommentReaction,
|
|
IssueComment,
|
|
)
|
|
from plane.api.serializers import IssueActivitySerializer
|
|
|
|
|
|
# Track Chnages in name
|
|
def track_name(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
if current_instance.get("name") != requested_data.get("name"):
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="updated",
|
|
old_value=current_instance.get("name"),
|
|
new_value=requested_data.get("name"),
|
|
field="name",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"updated the name to {requested_data.get('name')}",
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
# Track changes in parent issue
|
|
def track_parent(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
if current_instance.get("parent") != requested_data.get("parent"):
|
|
if requested_data.get("parent") == None:
|
|
old_parent = Issue.objects.get(pk=current_instance.get("parent"))
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="updated",
|
|
old_value=f"{old_parent.project.identifier}-{old_parent.sequence_id}",
|
|
new_value=None,
|
|
field="parent",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"updated the parent issue to None",
|
|
old_identifier=old_parent.id,
|
|
new_identifier=None,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
else:
|
|
new_parent = Issue.objects.get(pk=requested_data.get("parent"))
|
|
old_parent = Issue.objects.filter(pk=current_instance.get("parent")).first()
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="updated",
|
|
old_value=f"{old_parent.project.identifier}-{old_parent.sequence_id}"
|
|
if old_parent is not None
|
|
else None,
|
|
new_value=f"{new_parent.project.identifier}-{new_parent.sequence_id}",
|
|
field="parent",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"updated the parent issue to {new_parent.name}",
|
|
old_identifier=old_parent.id if old_parent is not None else None,
|
|
new_identifier=new_parent.id,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
# Track changes in priority
|
|
def track_priority(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
if current_instance.get("priority") != requested_data.get("priority"):
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="updated",
|
|
old_value=current_instance.get("priority"),
|
|
new_value=requested_data.get("priority"),
|
|
field="priority",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"updated the priority to {requested_data.get('priority')}",
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
# Track chnages in state of the issue
|
|
def track_state(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
if current_instance.get("state") != requested_data.get("state"):
|
|
new_state = State.objects.get(pk=requested_data.get("state", None))
|
|
old_state = State.objects.get(pk=current_instance.get("state", None))
|
|
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="updated",
|
|
old_value=old_state.name,
|
|
new_value=new_state.name,
|
|
field="state",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"updated the state to {new_state.name}",
|
|
old_identifier=old_state.id,
|
|
new_identifier=new_state.id,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
# Track issue description
|
|
def track_description(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
if current_instance.get("description_html") != requested_data.get(
|
|
"description_html"
|
|
):
|
|
last_activity = (
|
|
IssueActivity.objects.filter(issue_id=issue_id)
|
|
.order_by("-created_at")
|
|
.first()
|
|
)
|
|
if (
|
|
last_activity is not None
|
|
and last_activity.field == "description"
|
|
and actor.id == last_activity.actor_id
|
|
):
|
|
last_activity.created_at = timezone.now()
|
|
last_activity.save(update_fields=["created_at"])
|
|
else:
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="updated",
|
|
old_value=current_instance.get("description_html"),
|
|
new_value=requested_data.get("description_html"),
|
|
field="description",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"updated the description to {requested_data.get('description_html')}",
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
# Track changes in issue target date
|
|
def track_target_date(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
if current_instance.get("target_date") != requested_data.get("target_date"):
|
|
if requested_data.get("target_date") == None:
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="updated",
|
|
old_value=current_instance.get("target_date"),
|
|
new_value=requested_data.get("target_date"),
|
|
field="target_date",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"updated the target date to None",
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
else:
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="updated",
|
|
old_value=current_instance.get("target_date"),
|
|
new_value=requested_data.get("target_date"),
|
|
field="target_date",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"updated the target date to {requested_data.get('target_date')}",
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
# Track changes in issue start date
|
|
def track_start_date(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
if current_instance.get("start_date") != requested_data.get("start_date"):
|
|
if requested_data.get("start_date") == None:
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="updated",
|
|
old_value=current_instance.get("start_date"),
|
|
new_value=requested_data.get("start_date"),
|
|
field="start_date",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"updated the start date to None",
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
else:
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="updated",
|
|
old_value=current_instance.get("start_date"),
|
|
new_value=requested_data.get("start_date"),
|
|
field="start_date",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"updated the start date to {requested_data.get('start_date')}",
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
# Track changes in issue labels
|
|
def track_labels(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
# Label Addition
|
|
if len(requested_data.get("labels_list")) > len(current_instance.get("labels")):
|
|
for label in requested_data.get("labels_list"):
|
|
if label not in current_instance.get("labels"):
|
|
label = Label.objects.get(pk=label)
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="updated",
|
|
old_value="",
|
|
new_value=label.name,
|
|
field="labels",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"added label {label.name}",
|
|
new_identifier=label.id,
|
|
old_identifier=None,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
# Label Removal
|
|
if len(requested_data.get("labels_list")) < len(current_instance.get("labels")):
|
|
for label in current_instance.get("labels"):
|
|
if label not in requested_data.get("labels_list"):
|
|
label = Label.objects.get(pk=label)
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="updated",
|
|
old_value=label.name,
|
|
new_value="",
|
|
field="labels",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"removed label {label.name}",
|
|
old_identifier=label.id,
|
|
new_identifier=None,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
# Track changes in issue assignees
|
|
def track_assignees(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
# Assignee Addition
|
|
if len(requested_data.get("assignees_list")) > len(
|
|
current_instance.get("assignees")
|
|
):
|
|
for assignee in requested_data.get("assignees_list"):
|
|
if assignee not in current_instance.get("assignees"):
|
|
assignee = User.objects.get(pk=assignee)
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="updated",
|
|
old_value="",
|
|
new_value=assignee.display_name,
|
|
field="assignees",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"added assignee {assignee.display_name}",
|
|
new_identifier=assignee.id,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
# Assignee Removal
|
|
if len(requested_data.get("assignees_list")) < len(
|
|
current_instance.get("assignees")
|
|
):
|
|
for assignee in current_instance.get("assignees"):
|
|
if assignee not in requested_data.get("assignees_list"):
|
|
assignee = User.objects.get(pk=assignee)
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="updated",
|
|
old_value=assignee.display_name,
|
|
new_value="",
|
|
field="assignees",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"removed assignee {assignee.display_name}",
|
|
old_identifier=assignee.id,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def create_issue_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"created the issue",
|
|
verb="created",
|
|
actor=actor,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def track_estimate_points(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
if current_instance.get("estimate_point") != requested_data.get("estimate_point"):
|
|
if requested_data.get("estimate_point") == None:
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="updated",
|
|
old_value=current_instance.get("estimate_point"),
|
|
new_value=requested_data.get("estimate_point"),
|
|
field="estimate_point",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"updated the estimate point to None",
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
else:
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="updated",
|
|
old_value=current_instance.get("estimate_point"),
|
|
new_value=requested_data.get("estimate_point"),
|
|
field="estimate_point",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"updated the estimate point to {requested_data.get('estimate_point')}",
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def track_archive_at(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
if requested_data.get("archived_at") is None:
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"has restored the issue",
|
|
verb="updated",
|
|
actor=actor,
|
|
field="archived_at",
|
|
old_value="archive",
|
|
new_value="restore",
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
else:
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"Plane has archived the issue",
|
|
verb="updated",
|
|
actor=actor,
|
|
field="archived_at",
|
|
old_value=None,
|
|
new_value="archive",
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def track_closed_to(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
if requested_data.get("closed_to") is not None:
|
|
updated_state = State.objects.get(
|
|
pk=requested_data.get("closed_to"), project=project
|
|
)
|
|
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="updated",
|
|
old_value=None,
|
|
new_value=updated_state.name,
|
|
field="state",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"Plane updated the state to {updated_state.name}",
|
|
old_identifier=None,
|
|
new_identifier=updated_state.id,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def update_issue_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
ISSUE_ACTIVITY_MAPPER = {
|
|
"name": track_name,
|
|
"parent": track_parent,
|
|
"priority": track_priority,
|
|
"state": track_state,
|
|
"description_html": track_description,
|
|
"target_date": track_target_date,
|
|
"start_date": track_start_date,
|
|
"labels_list": track_labels,
|
|
"assignees_list": track_assignees,
|
|
"estimate_point": track_estimate_points,
|
|
"archived_at": track_archive_at,
|
|
"closed_to": track_closed_to,
|
|
}
|
|
|
|
requested_data = json.loads(requested_data) if requested_data is not None else None
|
|
current_instance = (
|
|
json.loads(current_instance) if current_instance is not None else None
|
|
)
|
|
|
|
for key in requested_data:
|
|
func = ISSUE_ACTIVITY_MAPPER.get(key, None)
|
|
if func is not None:
|
|
func(
|
|
requested_data,
|
|
current_instance,
|
|
issue_id,
|
|
project,
|
|
actor,
|
|
issue_activities,
|
|
epoch,
|
|
)
|
|
|
|
|
|
def delete_issue_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"deleted the issue",
|
|
verb="deleted",
|
|
actor=actor,
|
|
field="issue",
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def create_comment_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
requested_data = json.loads(requested_data) if requested_data is not None else None
|
|
current_instance = (
|
|
json.loads(current_instance) if current_instance is not None else None
|
|
)
|
|
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"created a comment",
|
|
verb="created",
|
|
actor=actor,
|
|
field="comment",
|
|
new_value=requested_data.get("comment_html", ""),
|
|
new_identifier=requested_data.get("id", None),
|
|
issue_comment_id=requested_data.get("id", None),
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def update_comment_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
requested_data = json.loads(requested_data) if requested_data is not None else None
|
|
current_instance = (
|
|
json.loads(current_instance) if current_instance is not None else None
|
|
)
|
|
|
|
if current_instance.get("comment_html") != requested_data.get("comment_html"):
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"updated a comment",
|
|
verb="updated",
|
|
actor=actor,
|
|
field="comment",
|
|
old_value=current_instance.get("comment_html", ""),
|
|
old_identifier=current_instance.get("id"),
|
|
new_value=requested_data.get("comment_html", ""),
|
|
new_identifier=current_instance.get("id", None),
|
|
issue_comment_id=current_instance.get("id", None),
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def delete_comment_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"deleted the comment",
|
|
verb="deleted",
|
|
actor=actor,
|
|
field="comment",
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def create_cycle_issue_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
requested_data = json.loads(requested_data) if requested_data is not None else None
|
|
current_instance = (
|
|
json.loads(current_instance) if current_instance is not None else None
|
|
)
|
|
|
|
# Updated Records:
|
|
updated_records = current_instance.get("updated_cycle_issues", [])
|
|
created_records = json.loads(current_instance.get("created_cycle_issues", []))
|
|
|
|
for updated_record in updated_records:
|
|
old_cycle = Cycle.objects.filter(
|
|
pk=updated_record.get("old_cycle_id", None)
|
|
).first()
|
|
new_cycle = Cycle.objects.filter(
|
|
pk=updated_record.get("new_cycle_id", None)
|
|
).first()
|
|
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=updated_record.get("issue_id"),
|
|
actor=actor,
|
|
verb="updated",
|
|
old_value=old_cycle.name,
|
|
new_value=new_cycle.name,
|
|
field="cycles",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"updated cycle from {old_cycle.name} to {new_cycle.name}",
|
|
old_identifier=old_cycle.id,
|
|
new_identifier=new_cycle.id,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
for created_record in created_records:
|
|
cycle = Cycle.objects.filter(
|
|
pk=created_record.get("fields").get("cycle")
|
|
).first()
|
|
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=created_record.get("fields").get("issue"),
|
|
actor=actor,
|
|
verb="created",
|
|
old_value="",
|
|
new_value=cycle.name,
|
|
field="cycles",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"added cycle {cycle.name}",
|
|
new_identifier=cycle.id,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def delete_cycle_issue_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
requested_data = json.loads(requested_data) if requested_data is not None else None
|
|
current_instance = (
|
|
json.loads(current_instance) if current_instance is not None else None
|
|
)
|
|
|
|
cycle_id = requested_data.get("cycle_id", "")
|
|
cycle = Cycle.objects.filter(pk=cycle_id).first()
|
|
issues = requested_data.get("issues")
|
|
|
|
for issue in issues:
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue,
|
|
actor=actor,
|
|
verb="deleted",
|
|
old_value=cycle.name if cycle is not None else "",
|
|
new_value="",
|
|
field="cycles",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"removed this issue from {cycle.name if cycle is not None else None}",
|
|
old_identifier=cycle.id if cycle is not None else None,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def create_module_issue_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
requested_data = json.loads(requested_data) if requested_data is not None else None
|
|
current_instance = (
|
|
json.loads(current_instance) if current_instance is not None else None
|
|
)
|
|
|
|
# Updated Records:
|
|
updated_records = current_instance.get("updated_module_issues", [])
|
|
created_records = json.loads(current_instance.get("created_module_issues", []))
|
|
|
|
for updated_record in updated_records:
|
|
old_module = Module.objects.filter(
|
|
pk=updated_record.get("old_module_id", None)
|
|
).first()
|
|
new_module = Module.objects.filter(
|
|
pk=updated_record.get("new_module_id", None)
|
|
).first()
|
|
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=updated_record.get("issue_id"),
|
|
actor=actor,
|
|
verb="updated",
|
|
old_value=old_module.name,
|
|
new_value=new_module.name,
|
|
field="modules",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"updated module from {old_module.name} to {new_module.name}",
|
|
old_identifier=old_module.id,
|
|
new_identifier=new_module.id,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
for created_record in created_records:
|
|
module = Module.objects.filter(
|
|
pk=created_record.get("fields").get("module")
|
|
).first()
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=created_record.get("fields").get("issue"),
|
|
actor=actor,
|
|
verb="created",
|
|
old_value="",
|
|
new_value=module.name,
|
|
field="modules",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"added module {module.name}",
|
|
new_identifier=module.id,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def delete_module_issue_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
requested_data = json.loads(requested_data) if requested_data is not None else None
|
|
current_instance = (
|
|
json.loads(current_instance) if current_instance is not None else None
|
|
)
|
|
|
|
module_id = requested_data.get("module_id", "")
|
|
module = Module.objects.filter(pk=module_id).first()
|
|
issues = requested_data.get("issues")
|
|
|
|
for issue in issues:
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue,
|
|
actor=actor,
|
|
verb="deleted",
|
|
old_value=module.name if module is not None else "",
|
|
new_value="",
|
|
field="modules",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"removed this issue from {module.name if module is not None else None}",
|
|
old_identifier=module.id if module is not None else None,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def create_link_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
requested_data = json.loads(requested_data) if requested_data is not None else None
|
|
current_instance = (
|
|
json.loads(current_instance) if current_instance is not None else None
|
|
)
|
|
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"created a link",
|
|
verb="created",
|
|
actor=actor,
|
|
field="link",
|
|
new_value=requested_data.get("url", ""),
|
|
new_identifier=requested_data.get("id", None),
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def update_link_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
requested_data = json.loads(requested_data) if requested_data is not None else None
|
|
current_instance = (
|
|
json.loads(current_instance) if current_instance is not None else None
|
|
)
|
|
|
|
if current_instance.get("url") != requested_data.get("url"):
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"updated a link",
|
|
verb="updated",
|
|
actor=actor,
|
|
field="link",
|
|
old_value=current_instance.get("url", ""),
|
|
old_identifier=current_instance.get("id"),
|
|
new_value=requested_data.get("url", ""),
|
|
new_identifier=current_instance.get("id", None),
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def delete_link_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
current_instance = (
|
|
json.loads(current_instance) if current_instance is not None else None
|
|
)
|
|
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"deleted the link",
|
|
verb="deleted",
|
|
actor=actor,
|
|
field="link",
|
|
old_value=current_instance.get("url", ""),
|
|
new_value="",
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def create_attachment_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
requested_data = json.loads(requested_data) if requested_data is not None else None
|
|
current_instance = (
|
|
json.loads(current_instance) if current_instance is not None else None
|
|
)
|
|
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"created an attachment",
|
|
verb="created",
|
|
actor=actor,
|
|
field="attachment",
|
|
new_value=current_instance.get("asset", ""),
|
|
new_identifier=current_instance.get("id", None),
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def delete_attachment_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"deleted the attachment",
|
|
verb="deleted",
|
|
actor=actor,
|
|
field="attachment",
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def create_issue_reaction_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
requested_data = json.loads(requested_data) if requested_data is not None else None
|
|
if requested_data and requested_data.get("reaction") is not None:
|
|
issue_reaction = (
|
|
IssueReaction.objects.filter(
|
|
reaction=requested_data.get("reaction"), project=project, actor=actor
|
|
)
|
|
.values_list("id", flat=True)
|
|
.first()
|
|
)
|
|
if issue_reaction is not None:
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="created",
|
|
old_value=None,
|
|
new_value=requested_data.get("reaction"),
|
|
field="reaction",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment="added the reaction",
|
|
old_identifier=None,
|
|
new_identifier=issue_reaction,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def delete_issue_reaction_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
current_instance = (
|
|
json.loads(current_instance) if current_instance is not None else None
|
|
)
|
|
if current_instance and current_instance.get("reaction") is not None:
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="deleted",
|
|
old_value=current_instance.get("reaction"),
|
|
new_value=None,
|
|
field="reaction",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment="removed the reaction",
|
|
old_identifier=current_instance.get("identifier"),
|
|
new_identifier=None,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def create_comment_reaction_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
requested_data = json.loads(requested_data) if requested_data is not None else None
|
|
if requested_data and requested_data.get("reaction") is not None:
|
|
comment_reaction_id, comment_id = (
|
|
CommentReaction.objects.filter(
|
|
reaction=requested_data.get("reaction"), project=project, actor=actor
|
|
)
|
|
.values_list("id", "comment__id")
|
|
.first()
|
|
)
|
|
comment = IssueComment.objects.get(pk=comment_id, project=project)
|
|
if (
|
|
comment is not None
|
|
and comment_reaction_id is not None
|
|
and comment_id is not None
|
|
):
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=comment.issue_id,
|
|
actor=actor,
|
|
verb="created",
|
|
old_value=None,
|
|
new_value=requested_data.get("reaction"),
|
|
field="reaction",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment="added the reaction",
|
|
old_identifier=None,
|
|
new_identifier=comment_reaction_id,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def delete_comment_reaction_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
current_instance = (
|
|
json.loads(current_instance) if current_instance is not None else None
|
|
)
|
|
if current_instance and current_instance.get("reaction") is not None:
|
|
issue_id = (
|
|
IssueComment.objects.filter(
|
|
pk=current_instance.get("comment_id"), project=project
|
|
)
|
|
.values_list("issue_id", flat=True)
|
|
.first()
|
|
)
|
|
if issue_id is not None:
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="deleted",
|
|
old_value=current_instance.get("reaction"),
|
|
new_value=None,
|
|
field="reaction",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment="removed the reaction",
|
|
old_identifier=current_instance.get("identifier"),
|
|
new_identifier=None,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def create_issue_vote_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
requested_data = json.loads(requested_data) if requested_data is not None else None
|
|
if requested_data and requested_data.get("vote") is not None:
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="created",
|
|
old_value=None,
|
|
new_value=requested_data.get("vote"),
|
|
field="vote",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment="added the vote",
|
|
old_identifier=None,
|
|
new_identifier=None,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def delete_issue_vote_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
current_instance = (
|
|
json.loads(current_instance) if current_instance is not None else None
|
|
)
|
|
if current_instance and current_instance.get("vote") is not None:
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
actor=actor,
|
|
verb="deleted",
|
|
old_value=current_instance.get("vote"),
|
|
new_value=None,
|
|
field="vote",
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment="removed the vote",
|
|
old_identifier=current_instance.get("identifier"),
|
|
new_identifier=None,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def create_issue_relation_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
requested_data = json.loads(requested_data) if requested_data is not None else None
|
|
current_instance = (
|
|
json.loads(current_instance) if current_instance is not None else None
|
|
)
|
|
if current_instance is None and requested_data.get("related_list") is not None:
|
|
for issue_relation in requested_data.get("related_list"):
|
|
if issue_relation.get("relation_type") == "blocked_by":
|
|
relation_type = "blocking"
|
|
else:
|
|
relation_type = issue_relation.get("relation_type")
|
|
issue = Issue.objects.get(pk=issue_relation.get("issue"))
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_relation.get("related_issue"),
|
|
actor=actor,
|
|
verb="created",
|
|
old_value="",
|
|
new_value=f"{project.identifier}-{issue.sequence_id}",
|
|
field=relation_type,
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"added {relation_type} relation",
|
|
old_identifier=issue_relation.get("issue"),
|
|
)
|
|
)
|
|
issue = Issue.objects.get(pk=issue_relation.get("related_issue"))
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_relation.get("issue"),
|
|
actor=actor,
|
|
verb="created",
|
|
old_value="",
|
|
new_value=f"{project.identifier}-{issue.sequence_id}",
|
|
field=f'{issue_relation.get("relation_type")}',
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f'added {issue_relation.get("relation_type")} relation',
|
|
old_identifier=issue_relation.get("related_issue"),
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def delete_issue_relation_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
requested_data = json.loads(requested_data) if requested_data is not None else None
|
|
current_instance = (
|
|
json.loads(current_instance) if current_instance is not None else None
|
|
)
|
|
if current_instance is not None and requested_data.get("related_list") is None:
|
|
if current_instance.get("relation_type") == "blocked_by":
|
|
relation_type = "blocking"
|
|
else:
|
|
relation_type = current_instance.get("relation_type")
|
|
issue = Issue.objects.get(pk=current_instance.get("issue"))
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=current_instance.get("related_issue"),
|
|
actor=actor,
|
|
verb="deleted",
|
|
old_value=f"{project.identifier}-{issue.sequence_id}",
|
|
new_value="",
|
|
field=relation_type,
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"deleted {relation_type} relation",
|
|
old_identifier=current_instance.get("issue"),
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
issue = Issue.objects.get(pk=current_instance.get("related_issue"))
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=current_instance.get("issue"),
|
|
actor=actor,
|
|
verb="deleted",
|
|
old_value=f"{project.identifier}-{issue.sequence_id}",
|
|
new_value="",
|
|
field=f'{current_instance.get("relation_type")}',
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f'deleted {current_instance.get("relation_type")} relation',
|
|
old_identifier=current_instance.get("related_issue"),
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def create_draft_issue_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"drafted the issue",
|
|
field="draft",
|
|
verb="created",
|
|
actor=actor,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def update_draft_issue_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
requested_data = json.loads(requested_data) if requested_data is not None else None
|
|
current_instance = (
|
|
json.loads(current_instance) if current_instance is not None else None
|
|
)
|
|
if (
|
|
requested_data.get("is_draft") is not None
|
|
and requested_data.get("is_draft") == False
|
|
):
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"created the issue",
|
|
verb="updated",
|
|
actor=actor,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
else:
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
issue_id=issue_id,
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"updated the draft issue",
|
|
field="draft",
|
|
verb="updated",
|
|
actor=actor,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
def delete_draft_issue_activity(
|
|
requested_data, current_instance, issue_id, project, actor, issue_activities, epoch
|
|
):
|
|
issue_activities.append(
|
|
IssueActivity(
|
|
project=project,
|
|
workspace=project.workspace,
|
|
comment=f"deleted the draft issue",
|
|
field="draft",
|
|
verb="deleted",
|
|
actor=actor,
|
|
epoch=epoch,
|
|
)
|
|
)
|
|
|
|
|
|
# Receive message from room group
|
|
@shared_task
|
|
def issue_activity(
|
|
type,
|
|
requested_data,
|
|
current_instance,
|
|
issue_id,
|
|
actor_id,
|
|
project_id,
|
|
epoch,
|
|
subscriber=True,
|
|
):
|
|
try:
|
|
|
|
issue_activities = []
|
|
|
|
actor = User.objects.get(pk=actor_id)
|
|
project = Project.objects.get(pk=project_id)
|
|
|
|
if type not in [
|
|
"cycle.activity.created",
|
|
"cycle.activity.deleted",
|
|
"module.activity.created",
|
|
"module.activity.deleted",
|
|
"issue_reaction.activity.created",
|
|
"issue_reaction.activity.deleted",
|
|
"comment_reaction.activity.created",
|
|
"comment_reaction.activity.deleted",
|
|
"issue_vote.activity.created",
|
|
"issue_vote.activity.deleted",
|
|
]:
|
|
issue = Issue.objects.filter(pk=issue_id).first()
|
|
|
|
if issue is not None:
|
|
try:
|
|
issue.updated_at = timezone.now()
|
|
issue.save(update_fields=["updated_at"])
|
|
except Exception as e:
|
|
pass
|
|
|
|
if subscriber:
|
|
# add the user to issue subscriber
|
|
try:
|
|
_ = IssueSubscriber.objects.get_or_create(
|
|
issue_id=issue_id, subscriber=actor
|
|
)
|
|
except Exception as e:
|
|
pass
|
|
|
|
ACTIVITY_MAPPER = {
|
|
"issue.activity.created": create_issue_activity,
|
|
"issue.activity.updated": update_issue_activity,
|
|
"issue.activity.deleted": delete_issue_activity,
|
|
"comment.activity.created": create_comment_activity,
|
|
"comment.activity.updated": update_comment_activity,
|
|
"comment.activity.deleted": delete_comment_activity,
|
|
"cycle.activity.created": create_cycle_issue_activity,
|
|
"cycle.activity.deleted": delete_cycle_issue_activity,
|
|
"module.activity.created": create_module_issue_activity,
|
|
"module.activity.deleted": delete_module_issue_activity,
|
|
"link.activity.created": create_link_activity,
|
|
"link.activity.updated": update_link_activity,
|
|
"link.activity.deleted": delete_link_activity,
|
|
"attachment.activity.created": create_attachment_activity,
|
|
"attachment.activity.deleted": delete_attachment_activity,
|
|
"issue_relation.activity.created": create_issue_relation_activity,
|
|
"issue_relation.activity.deleted": delete_issue_relation_activity,
|
|
"issue_reaction.activity.created": create_issue_reaction_activity,
|
|
"issue_reaction.activity.deleted": delete_issue_reaction_activity,
|
|
"comment_reaction.activity.created": create_comment_reaction_activity,
|
|
"comment_reaction.activity.deleted": delete_comment_reaction_activity,
|
|
"issue_vote.activity.created": create_issue_vote_activity,
|
|
"issue_vote.activity.deleted": delete_issue_vote_activity,
|
|
"issue_draft.activity.created": create_draft_issue_activity,
|
|
"issue_draft.activity.updated": update_draft_issue_activity,
|
|
"issue_draft.activity.deleted": delete_draft_issue_activity,
|
|
}
|
|
|
|
func = ACTIVITY_MAPPER.get(type)
|
|
if func is not None:
|
|
func(
|
|
requested_data,
|
|
current_instance,
|
|
issue_id,
|
|
project,
|
|
actor,
|
|
issue_activities,
|
|
epoch,
|
|
)
|
|
|
|
# Save all the values to database
|
|
issue_activities_created = IssueActivity.objects.bulk_create(issue_activities)
|
|
# Post the updates to segway for integrations and webhooks
|
|
if len(issue_activities_created):
|
|
# Don't send activities if the actor is a bot
|
|
try:
|
|
if settings.PROXY_BASE_URL:
|
|
for issue_activity in issue_activities_created:
|
|
headers = {"Content-Type": "application/json"}
|
|
issue_activity_json = json.dumps(
|
|
IssueActivitySerializer(issue_activity).data,
|
|
cls=DjangoJSONEncoder,
|
|
)
|
|
_ = requests.post(
|
|
f"{settings.PROXY_BASE_URL}/hooks/workspaces/{str(issue_activity.workspace_id)}/projects/{str(issue_activity.project_id)}/issues/{str(issue_activity.issue_id)}/issue-activity-hooks/",
|
|
json=issue_activity_json,
|
|
headers=headers,
|
|
)
|
|
except Exception as e:
|
|
capture_exception(e)
|
|
|
|
if type not in [
|
|
"cycle.activity.created",
|
|
"cycle.activity.deleted",
|
|
"module.activity.created",
|
|
"module.activity.deleted",
|
|
"issue_reaction.activity.created",
|
|
"issue_reaction.activity.deleted",
|
|
"comment_reaction.activity.created",
|
|
"comment_reaction.activity.deleted",
|
|
"issue_vote.activity.created",
|
|
"issue_vote.activity.deleted",
|
|
]:
|
|
# Create Notifications
|
|
bulk_notifications = []
|
|
|
|
issue_subscribers = list(
|
|
IssueSubscriber.objects.filter(project=project, issue_id=issue_id)
|
|
.exclude(subscriber_id=actor_id)
|
|
.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.filter(pk=issue_id).first()
|
|
|
|
# Add bot filtering
|
|
if (
|
|
issue is not None
|
|
and issue.created_by_id is not None
|
|
and not issue.created_by.is_bot
|
|
and str(issue.created_by_id) != str(actor_id)
|
|
):
|
|
issue_subscribers = issue_subscribers + [issue.created_by_id]
|
|
|
|
for subscriber in list(set(issue_subscribers)):
|
|
for issue_activity in issue_activities_created:
|
|
bulk_notifications.append(
|
|
Notification(
|
|
workspace=project.workspace,
|
|
sender="in_app:issue_activities",
|
|
triggered_by_id=actor_id,
|
|
receiver_id=subscriber,
|
|
entity_identifier=issue_id,
|
|
entity_name="issue",
|
|
project=project,
|
|
title=issue_activity.comment,
|
|
data={
|
|
"issue": {
|
|
"id": str(issue_id),
|
|
"name": str(issue.name),
|
|
"identifier": str(issue.project.identifier),
|
|
"sequence_id": issue.sequence_id,
|
|
"state_name": issue.state.name,
|
|
"state_group": issue.state.group,
|
|
},
|
|
"issue_activity": {
|
|
"id": str(issue_activity.id),
|
|
"verb": str(issue_activity.verb),
|
|
"field": str(issue_activity.field),
|
|
"actor": str(issue_activity.actor_id),
|
|
"new_value": str(issue_activity.new_value),
|
|
"old_value": str(issue_activity.old_value),
|
|
"issue_comment": str(
|
|
issue_activity.issue_comment.comment_stripped
|
|
if issue_activity.issue_comment is not None
|
|
else ""
|
|
),
|
|
},
|
|
},
|
|
)
|
|
)
|
|
|
|
# Bulk create notifications
|
|
Notification.objects.bulk_create(bulk_notifications, batch_size=100)
|
|
|
|
return
|
|
except Exception as e:
|
|
# Print logs if in DEBUG mode
|
|
if settings.DEBUG:
|
|
print(e)
|
|
capture_exception(e)
|
|
return
|