Report server and business failures to Sentry

web/actions/compose.ts

@@ -5,6 +5,7 @@ import { db } from "@/db";
 import { services } from "@/db/schema";
 import { requireDeveloperRole } from "@/lib/auth";
 import { parseComposeYaml } from "@/lib/compose-parser";
+import { reportServerError } from "@/lib/server-errors";
 import {
 	addServiceVolume,
 	createService,
@@ -144,6 +145,9 @@ export async function importCompose(
  volume.containerPath,
  );
  } catch (e) {
+ reportServerError(e, "compose-import.volume.add", {
+ tags: { serviceId: result.id },
+ });
  warnings.push({
  service: finalName,
  field: "volumes",
@@ -182,9 +186,16 @@ export async function importCompose(
  for (const serviceId of createdServiceIds) {
  try {
  await db.delete(services).where(eq(services.id, serviceId));
- } catch {}
+ } catch (cleanupError) {
+ reportServerError(cleanupError, "compose-import.cleanup", {
+ tags: { serviceId },
+ });
+ }
  }
 
+ reportServerError(error, "compose-import.create", {
+ tags: { projectId, environmentId },
+ });
  return {
  success: false,
  created: [],

web/actions/projects.ts

@@ -54,6 +54,7 @@ import {
 	cleanupRegistryArtifactsForService,
 	prepareRegistryArtifactCleanup,
 } from "@/lib/registry-retention";
+import { reportServerError } from "@/lib/server-errors";
 import {
 	deletePreviewService,
 	deletePreviewsForBaseService,
@@ -1748,6 +1749,9 @@ export async function abortRollout(serviceId: string) {
  try {
  await inngest.send(inngestEvents.rolloutCancelled.create({ rolloutId }));
  } catch (error) {
+ reportServerError(error, "rollout.cancellation.dispatch", {
+ tags: { rolloutId, serviceId },
+ });
  console.error(
  `[rollout:${rolloutId}] failed to send cancellation:`,
  error,

web/app/api/builds/[buildId]/logs/route.ts

@@ -1,5 +1,6 @@
 import { type NextRequest, NextResponse } from "next/server";
 import { invalidLogQueryResponse, normalizeLogSearch } from "@/lib/log-query";
+import { reportServerError } from "@/lib/server-errors";
 import { isLoggingEnabled, queryLogsByBuild } from "@/lib/victoria-logs";
 
 export async function GET(
@@ -28,6 +29,7 @@ export async function GET(
 
  return NextResponse.json({ logs });
 	} catch (error) {
+ reportServerError(error, "logs.build.query", { tags: { buildId } });
  console.error("Failed to fetch build logs:", error);
  return NextResponse.json(
  { message: "Failed to query build logs" },

web/app/api/deployments/[id]/logs/route.ts

@@ -5,6 +5,7 @@ import {
 	normalizeLogCursor,
 	parseLogLimit,
 } from "@/lib/log-query";
+import { reportServerError } from "@/lib/server-errors";
 import { isLoggingEnabled, queryLogsByDeployment } from "@/lib/victoria-logs";
 
 export async function GET(
@@ -50,6 +51,9 @@ export async function GET(
  hasMore: result.hasMore,
  });
 	} catch (error) {
+ reportServerError(error, "logs.deployment.query", {
+ tags: { deploymentId },
+ });
  console.error("[logs:deployment] failed to query logs:", error);
  return Response.json(
  { message: "Failed to query deployment logs" },

web/app/api/github/repos/route.ts

@@ -4,6 +4,7 @@ import { db } from "@/db";
 import { githubInstallations } from "@/db/schema";
 import { eq } from "drizzle-orm";
 import { getInstallationRepositories } from "@/lib/github";
+import { reportServerError } from "@/lib/server-errors";
 
 export async function GET() {
 	const session = await auth.api.getSession({
@@ -48,6 +49,9 @@ export async function GET() {
  });
  }
  } catch (error) {
+ reportServerError(error, "github.repositories.list", {
+ tags: { installationId: installation.installationId },
+ });
  console.error(
  `[github:repos] failed to fetch repos for installation ${installation.installationId}:`,
  error,

web/app/api/github/setup/route.ts

@@ -5,6 +5,7 @@ import { type NextRequest, NextResponse } from "next/server";
 import { db } from "@/db";
 import { githubInstallations } from "@/db/schema";
 import { requireRequestDeveloperRole } from "@/lib/api-auth";
+import { reportServerError } from "@/lib/server-errors";
 
 async function getInstallationDetails(installationId: number): Promise<{
 	account: { login: string; type: "User" | "Organization" };
@@ -40,6 +41,13 @@ async function getInstallationDetails(installationId: number): Promise<{
 	);
 
 	if (!response.ok) {
+ reportServerError(
+ new Error(
+ `GitHub installation lookup failed with status ${response.status}`,
+ ),
+ "github.installation.get",
+ { tags: { installationId } },
+ );
  console.error(
  `[github:setup] failed to get installation ${installationId}:`,
  await response.text(),

web/app/api/inngest/route.ts

@@ -25,6 +25,7 @@ import {
 	rolloutWorkflow,
 	scheduledBackupsCheck,
 	scheduledDeploymentsCheck,
+	sentryFailureWorkflow,
 	serviceDeletionWorkflow,
 	serviceCommandRetention,
 	serviceCronDispatcher,
@@ -52,6 +53,7 @@ export const { GET, POST, PUT } = serve({
  agentUpgradeTimeoutCheck,
  registryArtifactRetention,
  migrationWorkflow,
+ sentryFailureWorkflow,
  backupWorkflow,
  restoreWorkflow,
  onRestoreFailed,

web/app/api/rollouts/[rolloutId]/logs/route.ts

@@ -1,5 +1,6 @@
 import { type NextRequest, NextResponse } from "next/server";
 import { invalidLogQueryResponse, normalizeLogSearch } from "@/lib/log-query";
+import { reportServerError } from "@/lib/server-errors";
 import { isLoggingEnabled, queryLogsByRollout } from "@/lib/victoria-logs";
 
 export async function GET(
@@ -29,6 +30,7 @@ export async function GET(
 
  return NextResponse.json({ logs });
 	} catch (error) {
+ reportServerError(error, "logs.rollout.query", { tags: { rolloutId } });
  console.error("Failed to fetch rollout logs:", error);
  return NextResponse.json(
  { message: "Failed to query rollout logs" },

web/app/api/servers/[id]/logs/route.ts

@@ -1,6 +1,7 @@
 import { headers } from "next/headers";
 import { auth } from "@/lib/auth";
 import { invalidLogQueryResponse, parseLogListParams } from "@/lib/log-query";
+import { reportServerError } from "@/lib/server-errors";
 import { isLoggingEnabled, queryLogsByServer } from "@/lib/victoria-logs";
 
 export async function GET(
@@ -46,6 +47,7 @@ export async function GET(
  hasMore: result.hasMore,
  });
 	} catch (error) {
+ reportServerError(error, "logs.server.query", { tags: { serverId } });
  console.error("[logs:server] failed to query logs:", error);
  return Response.json(
  { message: "Failed to query server logs" },

web/app/api/servers/[id]/metrics/route.ts

@@ -1,6 +1,7 @@
 import { headers } from "next/headers";
 import { getServerDetails } from "@/db/queries";
 import { auth } from "@/lib/auth";
+import { reportServerError } from "@/lib/server-errors";
 import {
 	emptyHistory,
 	getMetricWindow,
@@ -61,6 +62,7 @@ export async function GET(
  range,
  });
 	} catch (error) {
+ reportServerError(error, "metrics.server.query", { tags: { serverId } });
  console.error("[metrics:server] failed to query metrics:", error);
  return Response.json({
  current: null,

web/app/api/services/[id]/backups/route.ts

@@ -2,6 +2,7 @@ import { NextRequest, NextResponse } from "next/server";
 import { desc, eq } from "drizzle-orm";
 import { db } from "@/db";
 import { volumeBackups, servers } from "@/db/schema";
+import { reportServerError } from "@/lib/server-errors";
 
 export async function GET(
 	request: NextRequest,
@@ -28,6 +29,8 @@ export async function GET(
 
  return NextResponse.json({ backups });
 	} catch (error) {
+ const { id: serviceId } = await params;
+ reportServerError(error, "backups.list", { tags: { serviceId } });
  console.error("[api:backups] failed to fetch backups:", error);
  return NextResponse.json(
  { error: "Failed to fetch backups" },

web/app/api/services/[id]/github/commits/route.ts

@@ -3,6 +3,7 @@ import { db } from "@/db";
 import { githubRepos, services } from "@/db/schema";
 import { requireRequestDeveloperRole } from "@/lib/api-auth";
 import { listGitHubCommits } from "@/lib/github";
+import { reportServerError } from "@/lib/server-errors";
 
 export async function GET(
 	request: Request,
@@ -41,6 +42,12 @@ export async function GET(
  );
  return Response.json({ branch, commits });
 	} catch (error) {
+ reportServerError(error, "github.commits.list", {
+ tags: {
+ installationId: result.githubRepo.installationId,
+ serviceId,
+ },
+ });
  return Response.json(
  {
  message:

web/app/api/services/[id]/logs/route.ts

@@ -1,6 +1,7 @@
 import { headers } from "next/headers";
 import { auth } from "@/lib/auth";
 import { invalidLogQueryResponse, parseLogListParams } from "@/lib/log-query";
+import { reportServerError } from "@/lib/server-errors";
 import {
 	isLoggingEnabled,
 	type LogType,
@@ -79,6 +80,7 @@ export async function GET(
  hasMore: result.hasMore,
  });
 	} catch (error) {
+ reportServerError(error, "logs.service.query", { tags: { serviceId } });
  console.error("[logs:service] failed to query logs:", error);
  return Response.json(
  { message: "Failed to query service logs" },

web/app/api/services/[id]/metrics/route.ts

@@ -1,6 +1,7 @@
 import { headers } from "next/headers";
 import { getService } from "@/db/queries";
 import { auth } from "@/lib/auth";
+import { reportServerError } from "@/lib/server-errors";
 import {
 	createEmptyServiceMetrics,
 	isMetricsEnabled,
@@ -45,6 +46,9 @@ export async function GET(
 	try {
  return Response.json(await queryServiceMetrics({ serviceId, range }));
 	} catch (error) {
+ reportServerError(error, "metrics.service.query", {
+ tags: { serviceId },
+ });
  console.error("[metrics:service] failed to query service metrics:", error);
  return Response.json(
  { message: "Service metrics unavailable" },

web/app/api/services/[id]/requests/route.ts

@@ -1,6 +1,7 @@
 import { headers } from "next/headers";
 import { auth } from "@/lib/auth";
 import { invalidLogQueryResponse, parseLogListParams } from "@/lib/log-query";
+import { reportServerError } from "@/lib/server-errors";
 import { isLoggingEnabled, queryLogsByService } from "@/lib/victoria-logs";
 
 export async function GET(
@@ -50,6 +51,7 @@ export async function GET(
  hasMore: result.hasMore,
  });
 	} catch (error) {
+ reportServerError(error, "logs.requests.query", { tags: { serviceId } });
  console.error("[logs:requests] failed to query HTTP logs:", error);
  return Response.json(
  { message: "Failed to query request logs" },

web/app/api/services/[id]/secrets/[secretId]/reveal/route.ts

@@ -4,6 +4,7 @@ import { secrets } from "@/db/schema";
 import { requireRequestDeveloperRole } from "@/lib/api-auth";
 import { decryptSecret } from "@/lib/crypto";
 import { EncryptionKeyUnavailableError } from "@/lib/kms";
+import { reportServerError } from "@/lib/server-errors";
 
 export async function POST(
 	request: Request,
@@ -40,6 +41,9 @@ export async function POST(
  },
  });
 	} catch (error) {
+ reportServerError(error, "secrets.reveal", {
+ tags: { serviceId, secretId },
+ });
  if (error instanceof EncryptionKeyUnavailableError) {
  console.error("Secret encryption key unavailable:", error);
  return Response.json(

web/app/api/v1/agent/backup/failed/route.ts

@@ -6,6 +6,7 @@ import { volumeBackups } from "@/db/schema";
 import { verifyAgentRequest } from "@/lib/agent-auth";
 import { inngest } from "@/lib/inngest/client";
 import { inngestEvents } from "@/lib/inngest/events";
+import { reportOperationFailure } from "@/lib/server-errors";
 
 export async function POST(request: NextRequest) {
 	const body = await request.text();
@@ -49,6 +50,11 @@ export async function POST(request: NextRequest) {
  return NextResponse.json({ ok: true });
 	}
 
+	reportOperationFailure("backup.failed", {
+ occurrenceId: backupId,
+ reason: "agent_reported_failure",
+ tags: { backupId, serviceId: backup.serviceId, serverId },
+	});
 	revalidatePath("/dashboard/projects");
 
 	await inngest.send(

web/app/api/v1/agent/builds/[id]/route.ts

@@ -8,6 +8,7 @@ import { cloneUrlForRevisionSource } from "@/lib/build-revision-source";
 import { inngest } from "@/lib/inngest/client";
 import { inngestEvents } from "@/lib/inngest/events";
 import { parseServiceRevisionSpec } from "@/lib/service-revision-changes";
+import { reportOperationFailure, reportServerError } from "@/lib/server-errors";
 import {
 	DEFAULT_BUILD_TIMEOUT_MINUTES,
 	SETTING_KEYS,
@@ -68,6 +69,16 @@ export async function POST(
  { status: 409 },
  );
  }
+ reportOperationFailure("build.failed", {
+ occurrenceId: buildId,
+ reason: "claim_failed",
+ tags: {
+ buildId,
+ serviceId: build.serviceId,
+ revisionId: build.serviceRevisionId,
+ serverId,
+ },
+ });
  await inngest.send(
  inngestEvents.buildCompleted.create(
  {
@@ -115,6 +126,14 @@ export async function POST(
 	try {
  specification = parseServiceRevisionSpec(revision.specification);
 	} catch (error) {
+ reportServerError(error, "agent.build.claim.parse-revision", {
+ tags: {
+ buildId,
+ serviceId: build.serviceId,
+ revisionId: build.serviceRevisionId,
+ serverId,
+ },
+ });
  console.error("[build:get] invalid service revision:", error);
  return failClaim("Invalid build service revision");
 	}
@@ -130,6 +149,14 @@ export async function POST(
 	try {
  cloneUrl = await cloneUrlForRevisionSource(specification.source);
 	} catch (error) {
+ reportServerError(error, "agent.build.claim.github-token", {
+ tags: {
+ buildId,
+ serviceId: build.serviceId,
+ revisionId: build.serviceRevisionId,
+ serverId,
+ },
+ });
  console.error("[build:get] failed to get installation token:", error);
  return failClaim("Failed to get GitHub installation token");
 	}