tests/e2e/connections-presets-stdio.spec.ts

Rama main · réplica de lectura del repositorio original.

import { mockSettingsShell } from "./helpers/billing-settings-fixtures";
import { expect, test } from "@playwright/test";
import { enableScopedE2EAuth, scopedPath } from "./helpers/auth";
import {
  connectedUser,
  modelId,
  fulfillJson,
} from "./helpers/connections-presets-fixtures";

test.beforeEach(async ({ page }) => {
  await mockSettingsShell(page);
});

test("settings quick-add saves the Trigger.dev stdio preset with a personal access token", async ({
  page,
}) => {
  const connections: Array<Record<string, unknown>> = [];

  await enableScopedE2EAuth(page);

  await page.route("**/api/auth/user", (route) =>
    fulfillJson(route, { user: connectedUser })
  );
  await page.route("**/api/settings", (route) =>
    fulfillJson(route, { default_model: modelId, theme: "dark" })
  );
  await page.route("**/api/models", (route) =>
    fulfillJson(route, {
      models: [{ id: modelId, context_length: 128000 }],
      catalog: [{ id: modelId, context_length: 128000, is_enabled: true }],
    })
  );
  await page.route("**/api/connections", async (route) => {
    if (route.request().method() === "GET") {
      await fulfillJson(route, { connections });
      return;
    }

    const body = route.request().postDataJSON() as Record<string, string>;
    expect(body.source_preset).toBe("trigger");
    expect(body.mcp_transport).toBe("stdio");
    expect(body.mcp_url).toBeUndefined();
    expect(body.credentials).toBe("tr_pat_e2e_token");

    const created = {
      id: "conn-trigger-new",
      user_id: "user-1",
      name: "Trigger.dev",
      type: "mcp_server",
      base_url: null,
      auth_type: "bearer",
      auth_header: "Authorization",
      mcp_transport: "stdio",
      mcp_url: null,
      description: "Tasks, runs, deploys, and Trigger.dev docs search",
      is_enabled: true,
      health_status: "healthy",
      scope: "global",
      repo_id: null,
      oauth_client_id: null,
      oauth_authorize_url: null,
      oauth_token_url: null,
      oauth_scopes: null,
      oauth_authorized_at: null,
      oauth_token_expires_at: null,
      source_preset: "trigger",
      created_at: new Date().toISOString(),
      updated_at: new Date().toISOString(),
    };
    connections.splice(0, connections.length, created);
    await fulfillJson(route, { connection: created }, 201);
  });
  await page.route("**/api/connections/conn-trigger-new/test", (route) => {
    connections[0] = {
      ...connections[0],
      last_tested_at: new Date().toISOString(),
      last_test_tool_count: 60,
    };
    return fulfillJson(route, {
      healthy: true,
      summary: "60 tools detected",
      toolCount: 60,
    });
  });

  await page.goto(scopedPath("connections"));
  await page.waitForLoadState("networkidle");

  const presetCard = page.getByTestId("settings-preset-trigger");
  await presetCard.getByRole("button", { name: "+ Add" }).click();
  await expect(presetCard).toContainText(
    "Agents call these tools straight from Mogplex, no sandbox needed"
  );
  await expect(presetCard).toContainText("sandboxes and the Mogplex CLI");
  await expect(
    presetCard.getByRole("link", { name: "Get a token" })
  ).toHaveAttribute("href", "https://cloud.trigger.dev/account/tokens");
  await presetCard.getByPlaceholder("tr_pat_...").fill("tr_pat_e2e_token");
  await presetCard.getByRole("button", { name: "Add" }).click();

  await expect(presetCard).toContainText("Connected · 60 tools");
  await expect(page.getByText("preset · Trigger.dev")).toBeVisible();
  // The row reports the API tools instead of a bare "test passed".
  await expect(page.getByText("60 tools detected")).toBeVisible();
});