revert(webapp): drop mollifier listing-merge from runs list

The runs list (API and dashboard) is eventually consistent — buffered
runs were creating a sandwich problem where the head of the list could
include buffered rows while in-transit rows between PG replication and
ClickHouse went missing. Drop the merge so the list returns PG/
ClickHouse rows only; buffered visibility will return via a separate
global status indicator.

Reverts the merge wiring in api.v1.runs, api.v1.projects.$projectRef
.runs, and the dashboard runs index, and deletes listingMerge.server
and dashboardListingMerge.server. The MCP list_runs tool rides through
the API and inherits the same behaviour.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: d-cs

.server-changes/mollifier-listing-revert.md

@@ -0,0 +1,6 @@
+---
+area: webapp
+type: improvement
+---
+
+Runs list (API and dashboard) is eventually consistent: drop the mollifier-buffer merge so buffered runs no longer appear in `apiClient.listRuns` or the dashboard runs index. Buffered visibility will return via a separate global status indicator.

apps/webapp/app/routes/_app.orgs.$organizationSlug.projects.$projectParam.env.$envParam.runs._index/route.tsx

@@ -45,10 +45,6 @@ import { findProjectBySlug } from "~/models/project.server";
 import { findEnvironmentBySlug } from "~/models/runtimeEnvironment.server";
 import { getRunFiltersFromRequest } from "~/presenters/RunFilters.server";
 import { NextRunListPresenter } from "~/presenters/v3/NextRunListPresenter.server";
-import {
-  dashboardListCursor,
-  mergeBufferedIntoDashboardList,
-} from "~/v3/mollifier/dashboardListingMerge.server";
 import { clickhouseClient } from "~/services/clickhouseInstance.server";
 import {
   setRootOnlyFilterPreference,
@@ -93,44 +89,13 @@ export const loader = async ({ request, params }: LoaderFunctionArgs) => {
 
   const filters = await getRunFiltersFromRequest(request);
 
-  // Buffered-run pagination uses a compound cursor that wraps the PG
-  // presenter's own cursor. Decode here so the inner PG cursor is
-  // forwarded to the presenter; the merge helper reconstructs the
-  // outgoing cursor based on what fits on this page.
-  const decodedCursor = dashboardListCursor.decode(filters.cursor);
-  const pgCursor = decodedCursor ? decodedCursor.inner : filters.cursor;
-  const dashboardPageSize = 25;
-
   const presenter = new NextRunListPresenter($replica, clickhouseClient);
-  const baseList = presenter.call(project.organizationId, environment.id, {
+  const list = presenter.call(project.organizationId, environment.id, {
     userId,
     projectId: project.id,
     ...filters,
-    cursor: pgCursor,
   });
 
-  // Prepend mollifier-buffered runs so customers see freshly-triggered
-  // runs while the gate is diverting traffic. The merge happens inside
-  // the deferred promise so the page still streams.
-  const list = baseList.then((result) =>
-    mergeBufferedIntoDashboardList({
-      baseList: result,
-      envId: environment.id,
-      pageSize: dashboardPageSize,
-      cursor: filters.cursor,
-      filters: {
-        tasks: filters.tasks,
-        statuses: filters.statuses,
-        tags: filters.tags,
-        period: filters.period,
-        from: filters.from,
-        to: filters.to,
-        isTest: filters.isTest,
-        runId: filters.runId,
-      },
-    })
-  );
-
   // Only persist rootOnly when no tasks are filtered. While a task filter is active,
   // the toggle's URL value can be a temporary auto-flip (or a user override scoped to
   // the current task filter), and we don't want either bleeding into the saved

apps/webapp/app/routes/api.v1.projects.$projectRef.runs.ts

@@ -7,7 +7,6 @@ import {
   ApiRunListSearchParams,
 } from "~/presenters/v3/ApiRunListPresenter.server";
 import { createLoaderPATApiRoute } from "~/services/routeBuilders/apiBuilder.server";
-import { callRunListWithBufferMerge } from "~/v3/mollifier/listingMerge.server";
 
 const ParamsSchema = z.object({
   projectRef: z.string(),
@@ -40,35 +39,6 @@ export const loader = createLoaderPATApiRoute(
       return json({ error: "Project not found" }, { status: 404 });
     }
 
-    // For PAT-scoped lookups the environment isn't supplied by auth;
-    // it's resolved from `filter[env]`. The presenter already does this
-    // lookup internally and errors if no env can be resolved. We mirror
-    // that resolution here so the mollifier-buffer merge has the env
-    // context it needs (envId + slug for synthesised list items).
-    const envFilter = searchParams["filter[env]"];
-    let envForMerge:
-      | { id: string; organizationId: string; slug: string }
-      | undefined;
-    if (envFilter && envFilter.length > 0) {
-      const env = await $replica.runtimeEnvironment.findFirst({
-        where: { projectId: project.id, slug: { in: envFilter } },
-        select: { id: true, organizationId: true, slug: true },
-      });
-      if (env) envForMerge = env;
-    }
-
-    if (envForMerge) {
-      const result = await callRunListWithBufferMerge({
-        project,
-        searchParams,
-        apiVersion,
-        environment: envForMerge,
-      });
-      return json(result);
-    }
-
-    // No env resolvable — let the presenter throw its existing
-    // ServiceValidationError, preserving the legacy behaviour.
     const presenter = new ApiRunListPresenter();
     const result = await presenter.call(project, searchParams, apiVersion);
 

apps/webapp/app/routes/api.v1.runs.ts

@@ -1,11 +1,12 @@
 import { json } from "@remix-run/server-runtime";
-import { ApiRunListSearchParams } from "~/presenters/v3/ApiRunListPresenter.server";
-import { logger } from "~/services/logger.server";
+import {
+  ApiRunListPresenter,
+  ApiRunListSearchParams,
+} from "~/presenters/v3/ApiRunListPresenter.server";
 import {
   anyResource,
   createLoaderApiRoute,
 } from "~/services/routeBuilders/apiBuilder.server";
-import { callRunListWithBufferMerge } from "~/v3/mollifier/listingMerge.server";
 
 export const loader = createLoaderApiRoute(
   {
@@ -36,12 +37,13 @@ export const loader = createLoaderApiRoute(
     findResource: async () => 1, // This is a dummy function, we don't need to find a resource
   },
   async ({ searchParams, authentication, apiVersion }) => {
-    const result = await callRunListWithBufferMerge({
-      project: authentication.environment.project,
+    const presenter = new ApiRunListPresenter();
+    const result = await presenter.call(
+      authentication.environment.project,
       searchParams,
       apiVersion,
-      environment: authentication.environment,
-    });
+      authentication.environment
+    );
 
     return json(result);
   }