Skip to content

Commit 48b2690

Browse files
committed
Fix delete build with releases
1 parent 6c87117 commit 48b2690

1 file changed

Lines changed: 22 additions & 0 deletions

File tree

  • src/routes/(api)/job/[jobId=idNumber]/build/[buildId=idNumber]

src/routes/(api)/job/[jobId=idNumber]/build/[buildId=idNumber]/+server.ts

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -145,6 +145,13 @@ export const DELETE: RequestHandler = async ({ params }) => {
145145
id: true,
146146
app_id: true
147147
}
148+
},
149+
release: {
150+
select: {
151+
id: true,
152+
build_guid: true,
153+
status: true
154+
}
148155
}
149156
}
150157
});
@@ -153,6 +160,11 @@ export const DELETE: RequestHandler = async ({ params }) => {
153160

154161
await prisma.build.delete({ where: { id: build.id } });
155162

163+
await prisma.$transaction([
164+
prisma.release.deleteMany({ where: { build: { id: build.id } } }),
165+
prisma.build.deleteMany({ where: { id: build.id } })
166+
]);
167+
156168
if (build.build_guid && build.status !== Build.Status.Completed) {
157169
await getQueues().Builds.add(`Cancel Build #${build.id}`, {
158170
type: BullMQ.JobType.Build_Cancel,
@@ -161,5 +173,15 @@ export const DELETE: RequestHandler = async ({ params }) => {
161173
});
162174
}
163175

176+
for (const release of build.release) {
177+
if (release.build_guid && release.status !== Release.Status.Completed) {
178+
await getQueues().Releases.add(`Cancel Release #${release.id}`, {
179+
type: BullMQ.JobType.Release_Cancel,
180+
guid: release.build_guid,
181+
release: { ...release, build }
182+
});
183+
}
184+
}
185+
164186
return new Response(JSON.stringify({}));
165187
};

0 commit comments

Comments
 (0)