mirror of
https://github.com/paperclipai/paperclip.git
synced 2026-11-08 01:57:31 +01:00
fix(cases): carry glyph-only blocker state on case activity and related-task links (BUG-07)
Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
This commit is contained in:
1 parent
1d3a1a0a9e
commit
d5c798ec53
3 files changed
+39
-5
No files matched your search
@@ -985,6 +985,18 @@ describeEmbeddedPostgres("cases routes", () => {
|
||||
expect(detail.body.workIssue).toMatchObject({ id: work!.id, status: "blocked", blockerAttention: { state: "needs_attention", sampleBlockerIdentifier: null } });
|
||||
expect(JSON.stringify(detail.body.workIssue)).not.toContain("Hidden case blocker");
|
||||
expect(JSON.stringify(detail.body.workIssue)).not.toContain(blocker!.id);
|
||||
|
||||
// Related-task links and the activity feed row draw from the same state.
|
||||
await db.insert(caseIssueLinks).values({ companyId: company.id, caseId: record!.id, issueId: work!.id, role: "reference" });
|
||||
const withLink = await request(app(boardActor)).get(`/api/cases/${record!.id}`).expect(200);
|
||||
expect(withLink.body.issueLinks[0].issue).toMatchObject({ id: work!.id, blockerAttention: { state: "needs_attention", sampleBlockerIdentifier: null } });
|
||||
|
||||
await db.insert(caseEvents).values({ companyId: company.id, caseId: record!.id, kind: "issue_linked",
|
||||
actorType: "system", payload: { issueId: work!.id } });
|
||||
const events = await request(app(boardActor)).get(`/api/cases/${record!.id}/events`).expect(200);
|
||||
const linked = events.body.find((event: { kind: string }) => event.kind === "issue_linked");
|
||||
expect(linked.issue).toMatchObject({ id: work!.id, status: "blocked", blockerAttention: { state: "needs_attention", sampleBlockerIdentifier: null } });
|
||||
expect(JSON.stringify(linked.issue)).not.toContain("Hidden case blocker");
|
||||
});
|
||||
it("enriches case pages and detail with current work in bounded batch queries", async () => {
|
||||
await enableCases();
|
||||
|
||||
@@ -56,6 +56,8 @@ import type { StorageService } from "../storage/types.js";
|
||||
import { authorizationService, issueReadSqlCondition, type AuthorizationActor } from "../services/authorization.js";
|
||||
import { assertActorCanReadCase, assertActorCanWriteCase, caseReadSqlCondition, filterCasesForActor, retainCaseAccessSource } from "../services/case-access.js";
|
||||
import { enrichCaseWork } from "../services/case-work-summary.js";
|
||||
import { listIssueStatusBlockerAttention } from "../services/issue-status-presentation.js";
|
||||
import type { IssueBlockerAttention } from "@paperclipai/shared";
|
||||
import { listCaseTaskDocuments } from "../services/case-task-documents.js";
|
||||
import { authorizeCaseCreation, authorizeCaseMutation } from "../services/case-mutation-authorization.js";
|
||||
import { logger } from "../middleware/logger.js";
|
||||
@@ -270,6 +272,19 @@ async function resolveAgentNames(db: CaseRouteDb, agentIds: (string | null)[]) {
|
||||
return new Map(rows.map((row) => [row.id, row.name]));
|
||||
}
|
||||
|
||||
type CaseAttributedIssue = { id: string; identifier: string; title: string; status: string; blockerAttention?: IssueBlockerAttention };
|
||||
|
||||
/** Glyph-only blocker state so a case activity row draws the same status glyph as the task pane. */
|
||||
async function withStatusBlockerAttention(db: CaseRouteDb, companyId: string, map: Map<string, CaseAttributedIssue>) {
|
||||
const attention = await listIssueStatusBlockerAttention(db as Db, companyId, [...map.values()]);
|
||||
if (attention.size === 0) return map;
|
||||
for (const [key, issue] of map) {
|
||||
const item = attention.get(issue.id);
|
||||
if (item) map.set(key, { ...issue, blockerAttention: item });
|
||||
}
|
||||
return map;
|
||||
}
|
||||
|
||||
/**
|
||||
* Batch resolve run → issue attribution. Mirrors resolveIssueForRun's precedence
|
||||
* (latest-updated issue whose execution/checkout/origin run matches), but for a
|
||||
@@ -277,7 +292,7 @@ async function resolveAgentNames(db: CaseRouteDb, agentIds: (string | null)[]) {
|
||||
*/
|
||||
async function resolveIssuesForRuns(db: CaseRouteDb, companyId: string, runIds: (string | null)[], actor: AuthorizationActor) {
|
||||
const valid = [...new Set(runIds.filter((id): id is string => !!id && isUuidLike(id)))];
|
||||
const map = new Map<string, { id: string; identifier: string; title: string; status: string }>();
|
||||
const map = new Map<string, CaseAttributedIssue>();
|
||||
if (valid.length === 0) return map;
|
||||
const rows = await db
|
||||
.select({
|
||||
@@ -314,7 +329,7 @@ async function resolveIssuesForRuns(db: CaseRouteDb, companyId: string, runIds:
|
||||
map.set(runId, { id: match.id, identifier: match.identifier ?? match.id, title: match.title, status: match.status });
|
||||
}
|
||||
}
|
||||
return map;
|
||||
return withStatusBlockerAttention(db, companyId, map);
|
||||
}
|
||||
|
||||
function payloadIssueIdForEvent(kind: string, payload: Record<string, unknown> | null | undefined) {
|
||||
@@ -325,7 +340,7 @@ function payloadIssueIdForEvent(kind: string, payload: Record<string, unknown> |
|
||||
|
||||
async function resolveIssuesByIds(db: CaseRouteDb, companyId: string, issueIds: (string | null)[], actor: AuthorizationActor) {
|
||||
const valid = [...new Set(issueIds.filter((id): id is string => !!id && isUuidLike(id)))];
|
||||
const map = new Map<string, { id: string; identifier: string; title: string; status: string }>();
|
||||
const map = new Map<string, CaseAttributedIssue>();
|
||||
if (valid.length === 0) return map;
|
||||
const rows = await db
|
||||
.select({
|
||||
@@ -342,7 +357,7 @@ async function resolveIssuesByIds(db: CaseRouteDb, companyId: string, issueIds:
|
||||
for (const [index, row] of rows.entries()) {
|
||||
if (readDecisions[index]?.allowed) map.set(row.id, { id: row.id, identifier: row.identifier ?? row.id, title: row.title, status: row.status });
|
||||
}
|
||||
return map;
|
||||
return withStatusBlockerAttention(db, companyId, map);
|
||||
}
|
||||
|
||||
async function autoLinkRunIssue(db: CaseRouteDb, input: {
|
||||
@@ -468,18 +483,21 @@ async function loadCaseDetail(db: CaseRouteDb, row: typeof cases.$inferSelect, a
|
||||
type: "issue" as const, companyId: row.companyId, issueId: item.issue.id,
|
||||
})));
|
||||
const [workSummary] = await enrichCaseWork(db, row.companyId, [row], actor);
|
||||
const visibleLinks = linkRows.filter((_, index) => linkDecisions[index]?.allowed);
|
||||
const linkBlockerAttention = await listIssueStatusBlockerAttention(db as Db, row.companyId, visibleLinks.map((item) => item.issue));
|
||||
return {
|
||||
...workSummary!,
|
||||
...taskDocumentRollup,
|
||||
parent: visibleParent,
|
||||
labels: labelRows.map((item) => item.label),
|
||||
issueLinks: linkRows.filter((_, index) => linkDecisions[index]?.allowed).map((item) => ({
|
||||
issueLinks: visibleLinks.map((item) => ({
|
||||
...item.link,
|
||||
issue: {
|
||||
id: item.issue.id,
|
||||
identifier: item.issue.identifier,
|
||||
title: item.issue.title,
|
||||
status: item.issue.status,
|
||||
...(linkBlockerAttention.has(item.issue.id) ? { blockerAttention: linkBlockerAttention.get(item.issue.id)! } : {}),
|
||||
},
|
||||
})),
|
||||
documents: documentRows.map((item) => ({
|
||||
|
||||
@@ -102,6 +102,8 @@ export interface CaseIssueLink {
|
||||
identifier: string;
|
||||
title: string;
|
||||
status: string;
|
||||
/** Glyph-only blocker state; present for blocked tasks. */
|
||||
blockerAttention?: IssueBlockerAttention;
|
||||
};
|
||||
}
|
||||
|
||||
@@ -185,6 +187,8 @@ export interface CaseAttributionIssue {
|
||||
identifier: string;
|
||||
title: string;
|
||||
status: string;
|
||||
/** Glyph-only blocker state; present for blocked tasks. */
|
||||
blockerAttention?: IssueBlockerAttention;
|
||||
}
|
||||
|
||||
export interface CaseEvent {
|
||||
|
||||
Reference in new issue
Block a user