wehub-resource-sync
108 lines
2.9 KiB
TypeScript
108 lines
2.9 KiB
TypeScript
import { PerformDeploymentAlertsService } from "./alerts/performDeploymentAlerts.server";
|
|
import { BaseService } from "./baseService.server";
|
|
import { logger } from "~/services/logger.server";
|
|
import { type WorkerDeploymentStatus } from "@trigger.dev/database";
|
|
import { DeploymentService } from "./deployment.server";
|
|
import { recordDeploymentOutcome } from "./recordDeploymentOutcome.server";
|
|
|
|
const FINAL_DEPLOYMENT_STATUSES: WorkerDeploymentStatus[] = [
|
|
"CANCELED",
|
|
"DEPLOYED",
|
|
"FAILED",
|
|
"TIMED_OUT",
|
|
];
|
|
|
|
export class DeploymentIndexFailed extends BaseService {
|
|
public async call(
|
|
maybeFriendlyId: string,
|
|
error: {
|
|
name: string;
|
|
message: string;
|
|
stack?: string;
|
|
stderr?: string;
|
|
},
|
|
overrideCompletion = false
|
|
) {
|
|
const isFriendlyId = maybeFriendlyId.startsWith("deployment_");
|
|
|
|
const deployment = await this._prisma.workerDeployment.findFirst({
|
|
where: isFriendlyId
|
|
? {
|
|
friendlyId: maybeFriendlyId,
|
|
}
|
|
: {
|
|
id: maybeFriendlyId,
|
|
},
|
|
include: {
|
|
environment: {
|
|
include: {
|
|
project: true,
|
|
},
|
|
},
|
|
},
|
|
});
|
|
|
|
if (!deployment) {
|
|
logger.error("Worker deployment not found", { maybeFriendlyId });
|
|
return;
|
|
}
|
|
|
|
if (FINAL_DEPLOYMENT_STATUSES.includes(deployment.status)) {
|
|
if (overrideCompletion) {
|
|
logger.error("No support for overriding final deployment statuses just yet", {
|
|
id: deployment.id,
|
|
status: deployment.status,
|
|
previousError: deployment.errorData,
|
|
incomingError: error,
|
|
});
|
|
}
|
|
|
|
logger.error("Worker deployment already in final state", {
|
|
id: deployment.id,
|
|
status: deployment.status,
|
|
});
|
|
return;
|
|
}
|
|
|
|
const failedDeployment = await this._prisma.workerDeployment.update({
|
|
where: {
|
|
id: deployment.id,
|
|
},
|
|
data: {
|
|
status: "FAILED",
|
|
failedAt: new Date(),
|
|
errorData: error,
|
|
},
|
|
});
|
|
|
|
recordDeploymentOutcome({
|
|
status: "FAILED",
|
|
deploymentFriendlyId: deployment.friendlyId,
|
|
organizationId: deployment.environment.project.organizationId,
|
|
projectId: deployment.environment.projectId,
|
|
environmentId: deployment.environmentId,
|
|
environmentType: deployment.environment.type,
|
|
reason: error.message,
|
|
});
|
|
|
|
const deploymentService = new DeploymentService();
|
|
await deploymentService
|
|
.appendToEventLog(deployment.environment.project, failedDeployment, [
|
|
{
|
|
type: "finalized",
|
|
data: {
|
|
result: "failed",
|
|
message: error.message,
|
|
},
|
|
},
|
|
])
|
|
.orTee((error) => {
|
|
logger.error("Failed to append failed deployment event to event log", { error });
|
|
});
|
|
|
|
await PerformDeploymentAlertsService.enqueue(failedDeployment.id);
|
|
|
|
return failedDeployment;
|
|
}
|
|
}
|