fix(ui): use one status glyph mapping for every task view (#19329)

## Thinking Path

> - Paperclip is the open source app people use to manage AI agents for
work.
> - Task status is the main signal on every task surface: sidebar rows,
the task header, the status menu, lists, the inbox, pills and chat
cards.
> - One task state rendered different status icons in different views. A
blocked task that waits on an active sub-task showed the blue "in queue"
glyph in the task header. The status menu, the chat chip and the sidebar
rows showed the red "Blocked" glyph for the same task.
> - The cause: each view passed its own subset of the presentation
fields to `StatusIcon`. Many views dropped `blockerAttention` and some
dropped `externalConversationState`. The status menu rendered its
current row from the bare status. The summaries API did not return
`blockerAttention`, so the recent-task sidebar could not know the state.
> - This pull request puts the state-to-glyph/label mapping in one
resolver and makes every task view pass all of its fields.
> - The benefit is that the same state uses the same icon and label
everywhere.

## Linked Issues or Issue Description

No public issue. Found in a hands-on onboarding test on a staging cloud
workspace.

**What happened?**

The sidebar and the task pane/status menu showed different status icons
for the same state. On the test task (blocked, waiting on an active
sub-task), the task header and the status button showed the blue "in
queue" glyph. The selected "Blocked" row in the status menu showed the
red blocked glyph. The coordinator sidebar "Recents" and project rows
also showed the red blocked glyph, and the chat "Subtask created" chip
showed a red "Blocked" chip.

**Expected behavior**

The same underlying state uses the same icon and label everywhere.

**Steps to reproduce**

1. Create a task with a sub-task. Block the parent on the sub-task, and
let the sub-task's agent run (the parent is "blocked, covered").
2. Open the parent task. The header shows the blue "in queue" glyph.
3. Open the status menu. The current "Blocked" row shows the red glyph.
4. With the coordinator sidebar on, look at the task in Recents or in
its expanded project. It shows the red glyph.

**Paperclip version or commit**

`master` at 03eb49053f.

## What Changed

- Add `ui/src/lib/task-status-presentation.ts`.
`resolveTaskStatusPresentation()` is the one mapping from `status`,
`displayStatus`, `externalConversationState` and `blockerAttention` to
glyph, label and accessible copy. `taskStatusIconProps()` picks all four
fields from a task record.
- `StatusIcon` and `IssueStatusBadge` use the resolver. The status menu
draws the current row with the trigger's presentation (in queue, idle,
monitoring).
- `IssueStatusBadge` now accepts `blockerAttention`.
`taskStatusVar.in_queue` maps to the existing in-progress chip hue, the
same as the existing `--status-task-icon-in_queue` icon token.
- Task call sites spread `taskStatusIconProps(task)`: coordinator
sidebar recents and project rows, classic recent tasks, lists, rows,
columns, inbox, blocked inbox, my issues, dashboard, properties,
relation pills, search, sibling navigation, chat chips, case summaries,
status cards and user profile. Step/check statuses in protocol cards
stay unchanged because they are not task statuses.
- `GET /api/companies/:companyId/issues/summaries` returns
`blockerAttention` for blocked rows (at most five IDs, through the
existing `listBlockerAttention` service). `IssueSummary` gets the
optional field.
- Recent-task snapshots store and refresh `blockerAttention`. Sidebar
project rows request the `rows` projection, which includes blocker state
(the `index` projection skips it).
- Storybook: the Foundations/Status Language story gets a "Same state,
every view" section.

## Verification

Red on `master` (tests written first, then run against the unchanged
code):

```
cd ui && npx vitest run src/components/StatusIcon.picker.test.tsx src/components/CoordinatorSidebar.test.tsx src/lib/recent-tasks.test.ts
     × keeps the covered-blocker state so the sidebar shows the same queued glyph as the task pane (BUG-07)
     × marks the current row with the same glyph as the trigger for a covered-blocked task
     × marks the current row with the same glyph as the trigger for a waiting review and a monitored task
     × shows a covered-blocked recent task with the same queued glyph and label as the task pane
     × shows project tasks with their full status presentation
 FAIL  StatusIcon.picker.test.tsx > ... covered-blocked task
AssertionError: expected 'var(--status-task-icon-blocked)' to be 'var(--status-task-icon-in_queue)'
 FAIL  StatusIcon.picker.test.tsx > ... waiting review and a monitored task
AssertionError: expected 'var(--status-task-icon-in_review)' to be 'var(--status-task-icon-backlog)'
 FAIL  CoordinatorSidebar.test.tsx > ... covered-blocked recent task ...
AssertionError: expected 'var(--status-task-icon-blocked)' to be 'var(--status-task-icon-in_queue)'
 FAIL  CoordinatorSidebar.test.tsx > ... project tasks with their full status presentation
AssertionError: expected "vi.fn()" to be called with arguments: [ 'company', ObjectContaining{…} ]
 FAIL  recent-tasks.test.ts > ... keeps the covered-blocker state ...
AssertionError: expected undefined to deeply equal { state: 'covered', …(7) }
      Tests  5 failed | 32 passed (37)

cd server && npx vitest run src/__tests__/issue-summaries-routes.test.ts
     × projects the covered-blocker state so every task view picks the same queued glyph (BUG-07)
AssertionError: expected undefined to match object { state: 'covered', …(2) }
      Tests  1 failed | 14 passed (15)
```

Green with this change (same commands):

```
 Test Files  3 passed (3)
      Tests  37 passed (37)
 Test Files  1 passed (1)        # server summaries route
      Tests  15 passed (15)
```

Neighbouring and broader checks:

- `StatusIcon`, `StatusBadge`, `StatusGlyph`, picker, sidebar and
recent-task suites: 73/73 pass.
- Full UI Vitest run: 11106 pass, 1 skipped. Three `IssuesList.test.tsx`
tests timed out at 5 s under full-suite load. The same file passes 73/73
when run alone.
- `tsc --noEmit` for `ui` and `server`: no errors in changed files.
Remaining errors are pre-existing (unbuilt
`@paperclipai/paperclip-runner`, generated Storybook catalog).
- `pnpm check:token-gates`: all gates clean.

Screenshots. The staging task before the fix: the status button is blue,
the current "Blocked" row in the menu is red.

| Staging task (before) | Staging status menu (before) |
| --- | --- |
| ![staging
before](https://raw.githubusercontent.com/paperclipai/paperclip/75e148aa1b100400d406d952e66cfac6c4afa5c3/before-staging-onb1.jpg)
| ![staging menu
before](https://raw.githubusercontent.com/paperclipai/paperclip/75e148aa1b100400d406d952e66cfac6c4afa5c3/before-staging-onb1-menu.png)
|

Storybook "Same state, every view" (Foundations/Status Language). Before
uses the `master` `StatusIcon`/`StatusBadge`; after uses this branch.

| Before (master) | After (this PR) |
| --- | --- |
| ![storybook
before](https://raw.githubusercontent.com/paperclipai/paperclip/75e148aa1b100400d406d952e66cfac6c4afa5c3/before-storybook-menu.jpg)
| ![storybook
after](https://raw.githubusercontent.com/paperclipai/paperclip/75e148aa1b100400d406d952e66cfac6c4afa5c3/after-storybook-menu.jpg)
|

Before: the row glyph is blue, but the chip and the current menu row are
red. After: the row glyph, the chip and the current menu row are all the
blue "in queue" glyph.

Review follow-up (commits 1d3a1a0a9e, d5c798ec53): blocker state on
summaries, search and case responses is glyph-only (state, reason,
counts). Blocker titles and IDs are never returned; a sampled identifier
stays only when the actor can read that blocker. Producer-level tests
failed before the follow-up and pass after it
(\`task-created-items.test.tsx\`,
\`CoordinatorTaskCommitment.test.tsx\`,
\`company-search-service.test.ts\`, \`cases-routes.test.ts\`,
private-blocker case in \`issue-summaries-routes.test.ts\`). Before
merge, the branch was test-merged locally with current \`master\`:
typecheck clean, 1095 UI and 80 server tests in the affected suites
pass.

## Risks

- Low risk. Presentation only. Status mutations still use the canonical
`status`.
- The summaries endpoint now runs the blocker-attention query for
blocked rows. The endpoint accepts at most five IDs and runs the query
only when a row is blocked.
- Sidebar project rows use the `rows` projection instead of `index`.
This adds the blocker and review attention reads for at most 12 rows,
and only when a person expands a project.
- `IssueStatusBadge` shows the blue "in queue" chip for covered-blocked
tasks where callers pass `blockerAttention`. The label stays "Blocked"
and the full reason is in the tooltip.

## Model Used

- Claude Opus 5.5 (`claude-opus-5-5`, Anthropic), through Claude Code
with tool use (shell, file edits, browser). Default context window.

## Checklist

- [x] I have included a thinking path that traces from project context
to this change
- [x] I have specified the model used (with version and capability
details)
- [x] I have checked ROADMAP.md and confirmed this PR does not duplicate
planned core work
- [x] I have searched GitHub for duplicate or related PRs and linked
them above
- [x] I have either (a) linked existing issues with `Fixes: #` / `Closes
#` / `Refs #` OR (b) described the issue in-PR following the relevant
issue template
- [x] I have not referenced internal/instance-local Paperclip issues or
links (only public GitHub `#NNN` / `github.com/paperclipai/paperclip`
URLs)
- [x] My branch name describes the change (e.g. `docs/...`, `fix/...`)
and contains no internal Paperclip ticket id or instance-derived details
- [x] I have run tests locally and they pass
- [x] I have added or updated tests where applicable
- [x] I have updated relevant documentation to reflect my changes
- [x] I have considered and documented any risks above
- [x] All Paperclip CI gates are green
- [x] Greptile is 5/5 with no open P2s, recommendations, or follow-ups
- [x] I will address all Greptile and reviewer comments before
requesting merge

🤖 Generated with [Claude Code](https://claude.com/claude-code)

---------

Co-authored-by: Claude Opus 5.5 <noreply@anthropic.com>
This commit is contained in:
DottaandClaude Opus 5.5 authored and GitHub committed 2026-11-05 14:42:11 -06:00
1 parent b4cc2d30d2
commit d807887534
49 files changed
+656 -143

No files matched your search

+29
View File
@@ -24,6 +24,7 @@ import {
documentRevisions,
heartbeatRuns,
instanceSettings,
issueRelations,
issues,
labels,
projects,
@@ -116,6 +117,7 @@ describeEmbeddedPostgres("cases routes", () => {
await db.delete(documents);
await db.delete(assets);
await db.delete(labels);
await db.delete(issueRelations);
await db.delete(issues);
await db.delete(heartbeatRuns);
await db.delete(projects);
@@ -969,6 +971,33 @@ describeEmbeddedPostgres("cases routes", () => {
expect(forIssue.body[0]).toMatchObject({ role: "work" });
expect(forIssue.body[0].case).toMatchObject({ id: child.body.id, identifier: child.body.identifier, status: child.body.status });
});
it("carries glyph-only blocker state on a blocked case task without blocker details (BUG-07)", async () => {
await enableCases();
const company = await seedCompany("WORK-BLOCKED");
const [work, blocker] = await db.insert(issues).values([
{ companyId: company.id, title: "Blocked case work", identifier: `${company.issuePrefix}-1`, status: "blocked" },
{ companyId: company.id, title: "Hidden case blocker", identifier: `${company.issuePrefix}-2`, status: "todo" },
]).returning();
await db.insert(issueRelations).values({ companyId: company.id, issueId: blocker!.id, relatedIssueId: work!.id, type: "blocks" });
const [record] = await db.insert(cases).values({ companyId: company.id, caseNumber: 1, identifier: `${company.issuePrefix}-C1`,
caseType: "factory", title: "Blocked case", workIssueId: work!.id }).returning();
const detail = await request(app(boardActor)).get(`/api/cases/${record!.id}`).expect(200);
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();
const company = await seedCompany("WORK-LIST");
@@ -10,6 +10,7 @@ import {
issueComments,
issueDocuments,
issueAccessGrants,
issueRelations,
issueLabels,
issueWorkProducts,
issues,
@@ -175,6 +176,29 @@ describeEmbeddedPostgres("companySearchService", () => {
return id;
}
it("returns glyph-only blocker state for blocked results without blocker details (BUG-07)", async () => {
const companyId = await createCompany();
const parent = await createIssue(companyId, { title: "Launch parent", status: "blocked" });
const blocker = await createIssue(companyId, { title: "Hidden blocker detail", status: "todo", identifier: "SRCH-2" });
const open = await createIssue(companyId, { title: "Launch open", status: "todo" });
await db.insert(issueRelations).values({ companyId, issueId: blocker, relatedIssueId: parent, type: "blocks" });
try {
const result = await svc.search(companyId, companySearchQuerySchema.parse({ q: "launch", scope: "issues" }));
const blocked = result.results.find((row) => row.id === parent)?.issue;
expect(blocked?.blockerAttention).toMatchObject({ state: "needs_attention", unresolvedBlockerCount: 1 });
expect(Object.keys(blocked!.blockerAttention!).sort()).toEqual([
"attentionBlockerCount", "coveredBlockerCount", "reason", "sampleBlockerIdentifier",
"sampleStalledBlockerIdentifier", "stalledBlockerCount", "state", "unresolvedBlockerCount",
]);
expect(blocked?.blockerAttention?.sampleBlockerIdentifier).toBeNull();
expect(JSON.stringify(result)).not.toContain("Hidden blocker detail");
expect(JSON.stringify(result)).not.toContain(blocker);
expect(result.results.find((row) => row.id === open)?.issue).not.toHaveProperty("blockerAttention");
} finally {
await db.delete(issueRelations);
}
});
it("paginates issue-result-only searches before unrelated entity competition", async () => {
const companyId = await createCompany();
const now = Date.now();
@@ -4,7 +4,7 @@ import request from "supertest";
import { eq } from "drizzle-orm";
import { afterAll, beforeAll, expect, it, vi } from "vitest";
import {
agents, chatConversations, chatEndpoints, issues, toolApplications, toolConnections,
agents, chatConversations, chatEndpoints, heartbeatRuns, issueRelations, issues, toolApplications, toolConnections,
} from "@paperclipai/db";
import { issueRoutes } from "../routes/issues.js";
import * as issueServices from "../services/issues.js";
@@ -110,4 +110,47 @@ describeEmbeddedPostgres("bounded issue summaries", () => {
expect(active.externalConversationState).toBe("active");
expect(active.updatedAt).toBe(waiting.updatedAt);
});
it("projects the covered-blocker state so every task view picks the same queued glyph (BUG-07)", async () => {
const f = await fixture();
const [agent] = await ctx.db.insert(agents).values({ companyId: f.companyId, name: "Builder", role: "engineer", adapterType: "process" }).returning();
const [parent] = await ctx.db.insert(issues).values({ companyId: f.companyId, title: "Parent", status: "blocked" }).returning();
const [child] = await ctx.db.insert(issues).values({
companyId: f.companyId, title: "Running child", identifier: "SUM-9", status: "todo", parentId: parent!.id, assigneeAgentId: agent!.id,
}).returning();
await ctx.db.insert(issueRelations).values({ companyId: f.companyId, issueId: child!.id, relatedIssueId: parent!.id, type: "blocks" });
const runId = randomUUID();
await ctx.db.insert(heartbeatRuns).values({ id: runId, companyId: f.companyId, agentId: agent!.id, status: "running", contextSnapshot: { issueId: child!.id } });
await ctx.db.update(issues).set({ executionRunId: runId }).where(eq(issues.id, child!.id));
const res = await request(app(f.actor)).get(url(f.companyId)).query({ ids: `${parent!.id},${f.rows[0]!.id}` }).expect(200);
expect(res.body[0].blockerAttention).toMatchObject({ state: "covered", reason: "active_child", sampleBlockerIdentifier: "SUM-9" });
// Only what the glyph needs: no blocker titles or IDs.
expect(Object.keys(res.body[0].blockerAttention).sort()).toEqual([
"attentionBlockerCount", "coveredBlockerCount", "reason", "sampleBlockerIdentifier",
"sampleStalledBlockerIdentifier", "stalledBlockerCount", "state", "unresolvedBlockerCount",
]);
expect(JSON.stringify(res.body)).not.toContain("Running child");
expect(JSON.stringify(res.body)).not.toContain(child!.id);
// Unblocked tasks keep the bounded summary shape.
expect(res.body[1]).not.toHaveProperty("blockerAttention");
});
it("does not disclose a private blocker through a readable blocked task's summary", async () => {
const f = await fixture();
const [parent] = await ctx.db.insert(issues).values({ companyId: f.companyId, title: "Public parent", status: "blocked" }).returning();
const privateId = randomUUID();
await ctx.db.insert(issues).values({
id: privateId, companyId: f.companyId, title: "Secret blocker title", status: "todo", visibility: "private",
privacyRootIssueId: privateId, responsibleUserId: "someone-else", createdByUserId: "someone-else",
});
await ctx.db.insert(issueRelations).values({ companyId: f.companyId, issueId: privateId, relatedIssueId: parent!.id, type: "blocks" });
const res = await request(app(f.actor)).get(url(f.companyId)).query({ ids: parent!.id }).expect(200);
expect(res.body).toHaveLength(1);
expect(res.body[0].blockerAttention?.state).toBeDefined();
expect(JSON.stringify(res.body)).not.toContain("Secret blocker title");
expect(JSON.stringify(res.body)).not.toContain(privateId);
expect(res.body[0].blockerAttention).not.toHaveProperty("terminalBlocker");
});
});
+23 -5
View File
@@ -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) => ({
+21 -10
View File
@@ -14,6 +14,7 @@ import { parseObject } from "../adapters/utils.js";
import { prepareRestrictedWorkspaceRetry } from "../services/restricted-workspace-retry.js";
import { issueSummariesQuerySchema, type IssueSummary } from "@paperclipai/shared";
import { listIssueSummaries } from "../services/issue-summaries.js";
import { listIssueStatusBlockerAttention } from "../services/issue-status-presentation.js";
import { assertNoCaseHandoffMutation } from "../services/heartbeat/case-handoff-lifecycle.js";
import { assertLegacyRunTaskOwnership } from "../legacy-run-task-ownership.js";
import { runRetainsIssueIdentity } from "../services/task-repository-acquisition.js";
@@ -8418,16 +8419,26 @@ export function issueRoutes(
}
const rows = await listIssueSummaries(db, companyId, parsed.data.ids, await issueReadSqlCondition(db, req.actor));
const visible = await filterIssuesForActor(req, rows);
const summaries: IssueSummary[] = visible.map((row) => ({
id: row.id,
companyId: row.companyId,
title: row.title,
identifier: row.identifier,
status: row.status as IssueSummary["status"],
displayStatus: row.displayStatus,
updatedAt: row.updatedAt,
externalConversationState: row.externalConversationState,
}));
// Blocked rows carry glyph-only blocker state so every task view resolves
// the same glyph (covered → "in queue") as the task pane. At most five IDs.
const blockerAttention = await listIssueStatusBlockerAttention(db, companyId, visible, async (ids) => new Set(
(await filterIssuesForActor(req, await listIssueSummaries(db, companyId, ids, await issueReadSqlCondition(db, req.actor))))
.map((row) => row.id),
));
const summaries: IssueSummary[] = visible.map((row) => {
const attention = blockerAttention.get(row.id);
return {
id: row.id,
companyId: row.companyId,
title: row.title,
identifier: row.identifier,
status: row.status as IssueSummary["status"],
displayStatus: row.displayStatus,
updatedAt: row.updatedAt,
externalConversationState: row.externalConversationState,
...(attention ? { blockerAttention: attention } : {}),
};
});
res.setHeader("Cache-Control", "private, no-store");
res.json(summaries);
});
+6 -1
View File
@@ -1,6 +1,7 @@
import { and, eq, getTableColumns, inArray } from "drizzle-orm";
import { agents, caseHandoffs, issues, workflows, type Db } from "@paperclipai/db";
import { authorizationService, issueReadSqlCondition, type AuthorizationActor } from "./authorization.js";
import { listIssueStatusBlockerAttention } from "./issue-status-presentation.js";
type CaseSummaryDb = Db | Parameters<Parameters<Db["transaction"]>[0]>[0];
type CaseWorkIdentity = { id: string; companyId: string; workIssueId: string | null; workflowId?: string | null };
@@ -35,6 +36,9 @@ export async function enrichCaseWork<T extends CaseWorkIdentity>(
})));
const visibleWork = workRows.filter((_, index) => workDecisions[index]?.allowed);
const workById = new Map(visibleWork.map(row => [row.id, row]));
// Glyph-only blocker state (no blocker titles, IDs or identifiers), so a
// covered-blocked case task shows the same "in queue" glyph as its task pane.
const blockerAttention = await listIssueStatusBlockerAttention(db as Db, companyId, visibleWork);
// A malformed/legacy link must not expose pending task instructions merely
// because its case is readable. The primary task has its own access boundary.
const primaryByCase = new Map(rows.map(row => [row.id, row.workIssueId]));
@@ -56,7 +60,8 @@ export async function enrichCaseWork<T extends CaseWorkIdentity>(
return {
...row,
workflow: row.workflowId ? workflowById.get(row.workflowId) ?? null : null,
workIssue: work ? { ...work, assigneeAgentName: work.assigneeAgentId ? names.get(work.assigneeAgentId) ?? null : null } : null,
workIssue: work ? { ...work, assigneeAgentName: work.assigneeAgentId ? names.get(work.assigneeAgentId) ?? null : null,
...(blockerAttention.has(work.id) ? { blockerAttention: blockerAttention.get(work.id)! } : {}) } : null,
pendingHandoff: pending ? { ...pending, fromAgentName: pending.fromAgentId ? names.get(pending.fromAgentId) ?? null : null,
toAgentName: pending.toAgentId ? names.get(pending.toAgentId) ?? null : null } : null,
};
+9 -1
View File
@@ -42,6 +42,7 @@ import { companyArtifactsService } from "./company-artifacts.js";
import { companySearchExtractService } from "./company-search-extract.js";
import { visibleIssueCondition } from "./issue-visibility.js";
import { parseTaskSearch, taskSearchCtes, taskSearchScore, taskSearchFieldMatch, taskSearchTermMatch } from "./task-search.js";
import { listIssueStatusBlockerAttention } from "./issue-status-presentation.js";
const SNIPPET_MAX_CHARS = 240;
export const COMPANY_SEARCH_BRANCH_FETCH_LIMIT = COMPANY_SEARCH_MAX_OFFSET + COMPANY_SEARCH_MAX_LIMIT + 1;
@@ -1155,8 +1156,15 @@ export function companySearchService(db: Db) {
const states = await db.select({ id: issues.id, state: externalConversationStateSql() }).from(issues)
.where(and(eq(issues.companyId, companyId), inArray(issues.id, issueIds)));
const byId = new Map(states.map((row) => [row.id, row.state]));
// Glyph-only blocker state (no blocker titles, IDs or identifiers), so a
// covered-blocked result shows the same "in queue" glyph as its task.
const blockerAttention = await listIssueStatusBlockerAttention(db, companyId,
paged.flatMap((result) => result.issue ? [result.issue] : []));
for (const result of paged) {
if (result.issue) result.issue.externalConversationState = byId.get(result.issue.id) ?? null;
if (!result.issue) continue;
result.issue.externalConversationState = byId.get(result.issue.id) ?? null;
const attention = blockerAttention.get(result.issue.id);
if (attention) result.issue.blockerAttention = attention;
}
}
return {
@@ -0,0 +1,56 @@
import { and, eq, inArray } from "drizzle-orm";
import { issues, type Db } from "@paperclipai/db";
import type { IssueBlockerAttention } from "@paperclipai/shared";
import { issueService } from "./issues.js";
/**
* Blocker state for task status glyphs on bounded summary surfaces (recent
* tasks, search results, case work). Every view resolves the same glyph from
* it (covered → "in queue"), so a blocked task never looks different in a
* sidebar than in its detail pane.
*
* The blocker walk is company-scoped, so the result carries only what the
* glyph needs: state, reason and counts. Blocker titles and IDs never leave
* this helper. A sampled blocker identifier is kept only when the caller
* confirms that the actor can read that blocker.
*/
export async function listIssueStatusBlockerAttention(
db: Db,
companyId: string,
rows: ReadonlyArray<{ id: string; status: string }>,
readableIssueIds?: (ids: string[]) => Promise<ReadonlySet<string>>,
): Promise<Map<string, IssueBlockerAttention>> {
const blockedIds = [...new Set(rows.filter((row) => row.status === "blocked").map((row) => row.id))];
if (blockedIds.length === 0) return new Map();
const nodes = await db.select({
id: issues.id,
companyId: issues.companyId,
parentId: issues.parentId,
identifier: issues.identifier,
title: issues.title,
status: issues.status,
executionRunId: issues.executionRunId,
assigneeAgentId: issues.assigneeAgentId,
assigneeUserId: issues.assigneeUserId,
}).from(issues).where(and(eq(issues.companyId, companyId), inArray(issues.id, blockedIds)));
const attention = await issueService(db).listBlockerAttention(companyId, nodes);
const sampledIds = [...new Set([...attention.values()].flatMap((item) => item.terminalBlocker ? [item.terminalBlocker.id] : []))];
const readable = readableIssueIds && sampledIds.length > 0 ? await readableIssueIds(sampledIds) : new Set<string>();
const result = new Map<string, IssueBlockerAttention>();
for (const [issueId, item] of attention) {
const sample = item.terminalBlocker;
const readableSample = sample && readable.has(sample.id) ? (sample.identifier ?? sample.id) : null;
result.set(issueId, {
state: item.state,
reason: item.reason,
unresolvedBlockerCount: item.unresolvedBlockerCount,
coveredBlockerCount: item.coveredBlockerCount,
stalledBlockerCount: item.stalledBlockerCount,
attentionBlockerCount: item.attentionBlockerCount,
sampleBlockerIdentifier: readableSample && item.sampleBlockerIdentifier === readableSample ? readableSample : null,
sampleStalledBlockerIdentifier: readableSample && item.sampleStalledBlockerIdentifier === readableSample ? readableSample : null,
});
}
return result;
}