MCPcopy
hub / github.com/Dokploy/dokploy / createDeploymentWorker

Function createDeploymentWorker

apps/dokploy/server/queues/deployments-queue.ts:17–84  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

15import { redisConfig } from "./redis-connection";
16
17const createDeploymentWorker = () =>
18 new Worker(
19 "deployments",
20 async (job: Job<DeploymentJob>) => {
21 try {
22 if (job.data.applicationType === "application") {
23 await updateApplicationStatus(job.data.applicationId, "running");
24
25 if (job.data.type === "redeploy") {
26 await rebuildApplication({
27 applicationId: job.data.applicationId,
28 titleLog: job.data.titleLog,
29 descriptionLog: job.data.descriptionLog,
30 });
31 } else if (job.data.type === "deploy") {
32 await deployApplication({
33 applicationId: job.data.applicationId,
34 titleLog: job.data.titleLog,
35 descriptionLog: job.data.descriptionLog,
36 });
37 }
38 } else if (job.data.applicationType === "compose") {
39 await updateCompose(job.data.composeId, {
40 composeStatus: "running",
41 });
42 if (job.data.type === "deploy") {
43 await deployCompose({
44 composeId: job.data.composeId,
45 titleLog: job.data.titleLog,
46 descriptionLog: job.data.descriptionLog,
47 });
48 } else if (job.data.type === "redeploy") {
49 await rebuildCompose({
50 composeId: job.data.composeId,
51 titleLog: job.data.titleLog,
52 descriptionLog: job.data.descriptionLog,
53 });
54 }
55 } else if (job.data.applicationType === "application-preview") {
56 await updatePreviewDeployment(job.data.previewDeploymentId, {
57 previewStatus: "running",
58 });
59
60 if (job.data.type === "redeploy") {
61 await rebuildPreviewApplication({
62 applicationId: job.data.applicationId,
63 titleLog: job.data.titleLog,
64 descriptionLog: job.data.descriptionLog,
65 previewDeploymentId: job.data.previewDeploymentId,
66 });
67 } else if (job.data.type === "deploy") {
68 await deployPreviewApplication({
69 applicationId: job.data.applicationId,
70 titleLog: job.data.titleLog,
71 descriptionLog: job.data.descriptionLog,
72 previewDeploymentId: job.data.previewDeploymentId,
73 });
74 }

Callers 1

Calls 9

updateApplicationStatusFunction · 0.90
rebuildApplicationFunction · 0.90
deployApplicationFunction · 0.90
updateComposeFunction · 0.90
deployComposeFunction · 0.90
rebuildComposeFunction · 0.90
updatePreviewDeploymentFunction · 0.90
deployPreviewApplicationFunction · 0.90

Tested by

no test coverage detected