fix: harden telemetry failure and source projection

packages/contracts/src/evidence.ts

@@ -72,13 +72,13 @@ export type EvidenceContextSignal = z.infer<typeof EvidenceContextSignalSchema>;
 export const EvidenceAdjudicationSchema = z.object({
   candidateId: text.max(160),
   missionId: text.max(160),
-  claimId: text.max(160).nullable(),
+  claimId: text.max(160).nullable().default(null),
   relationship: EvidenceRelationshipV2Schema,
   statement: text.max(1_200),
-  excerpt: text.max(4_000).nullable(),
+  excerpt: text.max(4_000).nullable().default(null),
   confidence: z.number().min(0).max(1),
   relevance: z.number().min(0).max(1),
-  context: EvidenceContextSignalSchema.nullable(),
+  context: EvidenceContextSignalSchema.nullable().default(null),
 });
 export type EvidenceAdjudication = z.infer<typeof EvidenceAdjudicationSchema>;
 

packages/extraction/src/article-index.test.ts

@@ -0,0 +1,69 @@
+import { ArticleDocumentSchema } from "@perspectica/contracts";
+import { describe, expect, it } from "vitest";
+import { buildArticleIndex } from "./article-index";
+
+describe("ArticleIndex link classification", () => {
+  it("keeps sharing, embedded-audio, and app links out of editorial sources", () => {
+    const article = ArticleDocumentSchema.parse({
+      fingerprint: "article-links",
+      canonicalUrl: "https://www.foxnews.com/story",
+      title: "A story",
+      author: "Reporter",
+      publication: "Fox News",
+      publishedAt: null,
+      language: "en",
+      contentType: "news",
+      paragraphs: [
+        {
+          id: "p1",
+          index: 0,
+          kind: "paragraph",
+          speaker: null,
+          text: "The report described the event and cited an outside record.",
+        },
+      ],
+      links: [
+        {
+          id: "flipboard",
+          label: "Flipboard",
+          url: "https://share.flipboard.com/bookmarklet/popout?url=https%3A%2F%2Fwww.foxnews.com%2Fstory",
+          paragraphId: null,
+        },
+        {
+          id: "beyondwords",
+          label: "beyondwords.io",
+          url: "https://beyondwords.io/player/example",
+          paragraphId: null,
+        },
+        {
+          id: "app",
+          label: "CLICK HERE TO DOWNLOAD THE FOX NEWS APP",
+          url: "https://foxnews.onelink.me/example",
+          paragraphId: null,
+        },
+        {
+          id: "primary",
+          label: "Public record",
+          url: "https://example.gov/record",
+          paragraphId: "p1",
+        },
+      ],
+      extraction: {
+        extractorVersion: "test",
+        extractedAt: "2026-08-03T00:00:00.000Z",
+        wordCount: 10,
+        articleStatus: "article",
+        contentChars: 62,
+        contentTruncated: false,
+      },
+    });
+
+    const index = buildArticleIndex(article);
+    expect(Object.fromEntries(index.links.map((link) => [link.id, link.classification]))).toEqual({
+      flipboard: "social",
+      beyondwords: "promotional",
+      app: "promotional",
+      primary: "likely-primary",
+    });
+  });
+});

packages/extraction/src/article-index.ts

@@ -24,7 +24,16 @@ const SOCIAL_HOSTS = new Set([
   "twitter.com",
   "x.com",
   "youtube.com",
+  "flipboard.com",
+  "sharethis.com",
+  "addtoany.com",
+  "pinterest.com",
+  "t.me",
+  "telegram.me",
 ]);
+const NON_EDITORIAL_HOSTS = new Set(["beyondwords.io"]);
+const PROMOTIONAL_PATTERN =
+  /\b(?:subscribe|newsletter|advert(?:isement)?|sponsor|shop|store|download|app|onelink|affiliate)\b/i;
 const NAVIGATION_PATH =
   /(?:^|\/)(?:search|tag|topic|category|author|login|account|subscribe)(?:\/|$)/i;
 const COMMON_CAPITALIZED = new Set([
@@ -195,7 +204,7 @@ function linkClassification(
   if ([...SOCIAL_HOSTS].some((domain) => linkHost === domain || linkHost.endsWith(`.${domain}`))) {
     return "social";
   }
-  if (/\b(?:subscribe|newsletter|advert|sponsor|shop|store)\b/i.test(`${link.label} ${link.url}`)) {
+  if (NON_EDITORIAL_HOSTS.has(linkHost) || PROMOTIONAL_PATTERN.test(`${link.label} ${link.url}`)) {
     return "promotional";
   }
   if (

packages/intelligence/src/evidence/adjudication.ts

@@ -10,7 +10,7 @@ import type { AnalysisPlan } from "@perspectica/contracts/report";
 import type { AnalysisBudget } from "../budgets";
 
 const AdjudicationOutputSchema = z.object({
-  decisions: z.array(EvidenceAdjudicationSchema).max(96),
+  decisions: z.array(EvidenceAdjudicationSchema).max(8),
 });
 
 export interface EvidenceAdjudicationInput {
@@ -51,7 +51,7 @@ function buildPrompt(input: EvidenceAdjudicationInput): string {
     .slice(0, Math.max(input.budget.maxSources * 4, 24))
     .map(
       (candidate) =>
-        `CANDIDATE ${candidate.id} mission=${candidate.missionId ?? "global-search"} url=${candidate.sourceUrl} title=${compact(candidate.title, 300)} kind=${candidate.contentKind} sourceType=${candidate.sourceType}\nCONTENT: ${compact(candidate.content, 4_000)}\nDISCOVERY: ${compact(candidate.discoveryContext ?? "", 2_000)}`,
+        `CANDIDATE ${candidate.id} mission=${candidate.missionId ?? "global-search"} url=${candidate.sourceUrl} title=${compact(candidate.title, 300)} kind=${candidate.contentKind} sourceType=${candidate.sourceType}\nCONTENT: ${compact(candidate.content, 2_400)}\nDISCOVERY: ${compact(candidate.discoveryContext ?? "", 600)}`,
     )
     .join("\n\n");
   return [
@@ -73,6 +73,7 @@ const SYSTEM_PROMPT = [
   "Supports, contradicts, and qualifies require an exact planned claim and a clear source-content anchor.",
   "Use context only for journalist-work, publication-history, comparable-coverage, or topic-context that is explicitly present in the candidate.",
   "Return no decision for irrelevant, ambiguous, self-referential, or discovery-only candidates. Do not write generic discovery prose such as 'surfaced a relevant source'.",
+  "Return at most one short decision per candidate. Keep source excerpts contiguous and as short as possible (preferably under 600 characters).",
   "Every candidateId and missionId must be copied exactly from the input. Do not invent IDs.",
 ].join(" ");
 
@@ -111,5 +112,16 @@ export async function adjudicateEvidence(
   input: EvidenceAdjudicationInput & { adjudicator?: EvidenceAdjudicator },
 ): Promise<EvidenceAdjudication[]> {
   if (!input.adjudicator || input.candidates.length === 0) return [];
-  return input.adjudicator.adjudicate(input);
+  const maxCandidatesPerCall = 6;
+  const decisions: EvidenceAdjudication[] = [];
+  for (let offset = 0; offset < input.candidates.length; offset += maxCandidatesPerCall) {
+    const batch = input.candidates.slice(offset, offset + maxCandidatesPerCall);
+    decisions.push(
+      ...(await input.adjudicator.adjudicate({
+        ...input,
+        candidates: batch,
+      })),
+    );
+  }
+  return decisions;
 }

packages/intelligence/src/pipeline.test.ts

@@ -175,6 +175,28 @@ describe("V2 intelligence pipeline", () => {
     expect(events.at(-1)?.type).toBe("analysis.cancelled");
   });
 
+  it("turns an empty provider error into a valid terminal failure event", async () => {
+    const events = [];
+    const emptyErrorAdjudicator: EvidenceAdjudicator = {
+      async adjudicate() {
+        throw new Error("");
+      },
+    };
+    for await (const event of analyzeArticle({
+      article: article(),
+      retriever: retriever(),
+      adjudicator: emptyErrorAdjudicator,
+      mode: "fast",
+      reasoningEffort: "low",
+    }))
+      events.push(event);
+
+    expect(events.at(-1)?.type).toBe("analysis.failed");
+    const failure = events.at(-1);
+    if (failure?.type === "analysis.failed")
+      expect(failure.data.message).toBe("The analysis pipeline failed.");
+  });
+
   it("retries only requested lanes from the existing artifacts", async () => {
     let artifacts: AnalysisArtifacts | undefined;
     const emptyRetriever = {

packages/intelligence/src/pipeline.ts

@@ -82,6 +82,11 @@ function isAbortError(error: unknown, signal?: AbortSignal): boolean {
   );
 }
 
+function pipelineErrorMessage(error: unknown, fallback: string): string {
+  const message = error instanceof Error ? error.message : typeof error === "string" ? error : "";
+  return (message.trim() || fallback).slice(0, 1_000);
+}
+
 export async function* analyzeArticle(input: AnalysisInput): AsyncGenerator<PipelineEvent> {
   const now = input.now ?? (() => new Date());
   const analysisId = input.analysisId ?? randomId("analysis");
@@ -279,7 +284,7 @@ export async function* analyzeArticle(input: AnalysisInput): AsyncGenerator<Pipe
       yield emit("analysis.cancelled", { message: "Analysis cancelled." });
       return;
     }
-    const message = error instanceof Error ? error.message : "The analysis pipeline failed.";
+    const message = pipelineErrorMessage(error, "The analysis pipeline failed.");
     yield emit("phase.changed", { phase: "failed", message });
     yield emit("analysis.failed", { message, retryable: true });
   }
@@ -414,7 +419,7 @@ export async function* retryArticleSections(
       yield emit("analysis.cancelled", { message: "Retry cancelled." });
       return;
     }
-    const message = error instanceof Error ? error.message : "The targeted retry failed.";
+    const message = pipelineErrorMessage(error, "The targeted retry failed.");
     yield emit("phase.changed", { phase: "failed", message });
     yield emit("analysis.failed", { message, retryable: true });
   }

packages/intelligence/src/report/projector.test.ts

@@ -65,6 +65,6 @@ describe("report source projection", () => {
       ],
     } as ArticleIndex);
 
-    expect(result.sources.map((source) => source.id)).toEqual(["external", "primary", "same"]);
+    expect(result.sources.map((source) => source.id)).toEqual(["external", "primary"]);
   });
 });

packages/intelligence/src/report/projector.ts

@@ -65,10 +65,7 @@ export function projectBias(plan: AnalysisPlan): BiasResult {
 
 export function projectSourceList(article: ArticleIndex): SourceListResult {
   const links = article.links
-    .filter((link) =>
-      ["external", "likely-primary", "same-publication"].includes(link.classification),
-    )
-    .filter((link) => link.classification !== "same-publication" || Boolean(link.paragraphId))
+    .filter((link) => ["external", "likely-primary"].includes(link.classification))
     .map((link) => ({
       id: link.id,
       label: link.label,