{escape(text)}
" if text else "" +def normalize_structured_title(value, fallback): + title = value.strip() if isinstance(value, str) else "" + if not title: + return fallback + + heading_match = MARKDOWN_HEADING_PATTERN.match(title) + if heading_match: + return heading_match.group(1).strip() or fallback + + return title + + +def split_leading_markdown_heading(value): + if not isinstance(value, str): + return None, "" + + lines = value.splitlines() + leading_blank_count = 0 + for line in lines: + if line.strip(): + break + leading_blank_count += 1 + + if leading_blank_count >= len(lines): + return None, "" + + first_content_line = lines[leading_blank_count] + heading_match = MARKDOWN_HEADING_PATTERN.match(first_content_line) + if not heading_match: + return None, value.strip() + + body_lines = lines[leading_blank_count + 1 :] + while body_lines and not body_lines[0].strip(): + body_lines.pop(0) + + return heading_match.group(1).strip(), "\n".join(body_lines).strip() + + +def normalize_structured_block(block): + if not isinstance(block, dict): + return None + + block_type = block.get("type") + if block_type == "text": + extracted_title, body = split_leading_markdown_heading(block.get("body")) + title = normalize_structured_title(block.get("title") or extracted_title, "Раздел") + + return { + "id": str(block.get("id") or f"text-{title.lower().replace(' ', '-')}"), + "type": "text", + "title": title, + "body": body, + } + + if block_type == "checker": + title = normalize_structured_title(block.get("title"), "Чеклист") + raw_items = block.get("items") + items = [] + if isinstance(raw_items, list): + for item in raw_items: + if not isinstance(item, dict): + continue + text = item.get("text") + if not isinstance(text, str) or not text.strip(): + continue + items.append( + { + "id": str(item.get("id") or f"item-{len(items) + 1}"), + "text": text.strip(), + "checked": item.get("checked") is True, + } + ) + + return { + "id": str(block.get("id") or f"checker-{title.lower().replace(' ', '-')}"), + "type": "checker", + "title": title, + "items": items, + } + + return None + + +def normalize_structured_blocks(structured_blocks): + normalized_blocks = [] + for block in structured_blocks: + normalized_block = normalize_structured_block(block) + if normalized_block is None: + return None + normalized_blocks.append(normalized_block) + + return normalized_blocks + + def merge_structured_blocks(detail_layout, structured_blocks): if structured_blocks is None: return detail_layout or {} @@ -285,8 +453,12 @@ def merge_structured_blocks(detail_layout, structured_blocks): if not isinstance(structured_blocks, list): return None + normalized_blocks = normalize_structured_blocks(structured_blocks) + if normalized_blocks is None: + return None + updated_layout = dict(detail_layout or {}) - updated_layout[NODEDC_STRUCTURED_BLOCKS_KEY] = structured_blocks + updated_layout[NODEDC_STRUCTURED_BLOCKS_KEY] = normalized_blocks return updated_layout @@ -301,6 +473,72 @@ def update_issue_labels(issue, label_ids): return True +def normalize_label_color(value): + if isinstance(value, str) and HEX_COLOR_PATTERN.match(value.strip()): + return value.strip() + return DEFAULT_AGENT_LABEL_COLOR + + +def normalize_label_input(raw_label): + if isinstance(raw_label, str): + name = raw_label.strip() + color = DEFAULT_AGENT_LABEL_COLOR + elif isinstance(raw_label, dict): + name = raw_label.get("name").strip() if isinstance(raw_label.get("name"), str) else "" + color = normalize_label_color(raw_label.get("color")) + else: + return None + + if not name: + return None + + return { + "name": name[:255], + "color": color, + } + + +def ensure_project_labels(project, raw_labels, actor, agent_id): + if not isinstance(raw_labels, list) or not raw_labels or len(raw_labels) > 50: + return None + + ensured_labels = [] + for raw_label in raw_labels: + label_input = normalize_label_input(raw_label) + if label_input is None: + return None + + label = Label.objects.filter( + project=project, + name__iexact=label_input["name"], + deleted_at__isnull=True, + ).first() + + if label is None: + try: + label = Label( + project=project, + workspace=project.workspace, + name=label_input["name"], + color=label_input["color"], + external_source=AGENT_BOT_TYPE, + external_id=agent_id, + ) + label.save(created_by_id=actor.id) + except IntegrityError: + label = Label.objects.filter( + project=project, + name__iexact=label_input["name"], + deleted_at__isnull=True, + ).first() + if label is None: + return None + + ensured_labels.append(label) + + return ensured_labels + + def update_issue_assignees(issue, member_ids): project_members = list( ProjectMember.objects.filter( @@ -413,6 +651,42 @@ class NodeDCAgentProjectContextEndpoint(View): ) +@method_decorator(csrf_exempt, name="dispatch") +class NodeDCAgentProjectLabelsEnsureEndpoint(View): + def post(self, request, project_id): + error_response = validate_internal_request(request) + if error_response is not None: + return error_response + + payload = parse_json_body(request) + if payload is None: + return invalid_json_response() + + project = resolve_project(project_id, payload.get("workspace_slug")) + if project is None: + return validation_error("project_not_found", status=404) + + entitlement_error = validate_agent_workspace_entitlement(request, project.workspace.slug) + if entitlement_error is not None: + return entitlement_error + + actor = ensure_agent_actor(request, project.workspace, project, payload) + if actor is None: + return validation_error("missing_agent_headers") + + identity = get_agent_identity(request) + ensured_labels = ensure_project_labels( + project, + payload.get("labels"), + actor, + identity["agent_id"] if identity else "", + ) + if ensured_labels is None: + return validation_error("invalid_labels") + + return JsonResponse({"ok": True, "labels": [serialize_label(label) for label in ensured_labels]}, status=201) + + @method_decorator(csrf_exempt, name="dispatch") class NodeDCAgentIssueListEndpoint(View): def get(self, request): @@ -473,7 +747,7 @@ class NodeDCAgentIssueListEndpoint(View): return validation_error("invalid_structured_blocks") with transaction.atomic(): - actor = ensure_agent_actor(request, project.workspace, project) + actor = ensure_agent_actor(request, project.workspace, project, payload) if actor is None: return validation_error("missing_agent_headers") @@ -539,7 +813,7 @@ class NodeDCAgentIssueUpdateEndpoint(View): update_fields.append("detail_layout") if update_fields: - actor = ensure_agent_actor(request, project.workspace, project) + actor = ensure_agent_actor(request, project.workspace, project, payload) if actor is None: return validation_error("missing_agent_headers") issue.updated_by = actor @@ -575,7 +849,7 @@ class NodeDCAgentIssueMoveEndpoint(View): if state is None: return validation_error("state_not_found", status=404) - actor = ensure_agent_actor(request, project.workspace, project) + actor = ensure_agent_actor(request, project.workspace, project, payload) if actor is None: return validation_error("missing_agent_headers") @@ -615,7 +889,7 @@ class NodeDCAgentIssueCommentEndpoint(View): if not isinstance(body, str) or not body.strip(): return validation_error("body_required") - actor = ensure_agent_actor(request, project.workspace, project) + actor = ensure_agent_actor(request, project.workspace, project, payload) if actor is None: return validation_error("missing_agent_headers") @@ -659,7 +933,7 @@ class NodeDCAgentIssueLabelsEndpoint(View): if not update_issue_labels(issue, label_ids): return validation_error("label_not_found", status=404) - actor = ensure_agent_actor(request, project.workspace, project) + actor = ensure_agent_actor(request, project.workspace, project, payload) if actor is not None: issue.updated_by = actor issue.save(update_fields=["updated_by", "updated_at"], disable_auto_set_user=True) @@ -696,7 +970,7 @@ class NodeDCAgentIssueAssigneesEndpoint(View): if not update_issue_assignees(issue, member_ids): return validation_error("member_not_found", status=404) - actor = ensure_agent_actor(request, project.workspace, project) + actor = ensure_agent_actor(request, project.workspace, project, payload) if actor is not None: issue.updated_by = actor issue.save(update_fields=["updated_by", "updated_at"], disable_auto_set_user=True) diff --git a/plane-src/apps/api/plane/urls.py b/plane-src/apps/api/plane/urls.py index 8cffc77..96d2b2b 100644 --- a/plane-src/apps/api/plane/urls.py +++ b/plane-src/apps/api/plane/urls.py @@ -23,6 +23,7 @@ from plane.authentication.views.nodedc_agent_adapter import ( NodeDCAgentIssueMoveEndpoint, NodeDCAgentIssueUpdateEndpoint, NodeDCAgentProjectContextEndpoint, + NodeDCAgentProjectLabelsEnsureEndpoint, NodeDCAgentProjectResolveEndpoint, ) from plane.authentication.views.nodedc_workspace_adapter import ( @@ -94,6 +95,11 @@ urlpatterns = [ NodeDCAgentProjectContextEndpoint.as_view(), name="nodedc-agent-project-context", ), + path( + "api/internal/nodedc/agent/projects/