feat(deploy): support specific commit deployments

and cache clearing

- Add `clear_cache` column to `deployments` table
- Allow specifying `commitSha` during deployment
  via API and UI
- Update `prepareSourceWorkspace` to support
  explicit git checkout
- Add unit tests for scaling engine
- Modularize Docker utilities for the scaling
  engine

Author: Lftobs

apps/api/src/api/deployments/index.ts

@@ -62,6 +62,10 @@ export const deploymentsRoutes = new Elysia()
 			const environment =
 				String(form.get("environment") ?? "").trim() ||
 				undefined;
+			const commitSha =
+				String(form.get("commitSha") ?? "").trim() ||
+				undefined;
+			const clearCache = form.get("clearCache") === "true";
 			if (
 				sourceType !== "git" &&
 				sourceType !== "upload" &&
@@ -86,6 +90,8 @@ export const deploymentsRoutes = new Elysia()
 					sourceRef: gitUrl,
 					branch,
 					environment,
+					commitSha,
+					clearCache,
 				});
 				orchestrator.enqueue(deployment.id);
 				return deployment;
@@ -118,6 +124,7 @@ export const deploymentsRoutes = new Elysia()
 				sourceRef: uploadPath,
 				branch,
 				environment,
+				clearCache,
 			});
 			orchestrator.enqueue(deployment.id);
 			return deployment;

apps/api/src/db/migrate.ts

@@ -47,6 +47,13 @@ export const migrate = async () => {
     console.log("[Migrate] Added projects.source_type column");
   }
 
+  const deploymentsTableInfo = sqlite.query("PRAGMA table_info('deployments')").all() as { name: string }[];
+  const deploymentsColumns = deploymentsTableInfo.map(r => r.name);
+  if (!deploymentsColumns.includes('clear_cache')) {
+    sqlite.exec("ALTER TABLE deployments ADD COLUMN clear_cache integer NOT NULL DEFAULT 0");
+    console.log("[Migrate] Added deployments.clear_cache column");
+  }
+
   await seedFromConfig();
 };
 

apps/api/src/db/repo/deployments.ts

@@ -20,6 +20,7 @@ const mapDeployment = (row: typeof deployments.$inferSelect): Deployment => ({
   replicas: row.replicas,
   environment: row.environment,
   failureReason: row.failureReason,
+  clearCache: Boolean(row.clearCache),
   createdAt: row.createdAt,
   updatedAt: row.updatedAt,
 });
@@ -38,6 +39,7 @@ export const createDeployment = async (input: CreateDeploymentInput): Promise<De
     branch: input.branch ?? null,
     commitSha: input.commitSha ?? null,
     environment: input.environment ?? null,
+    clearCache: input.clearCache ? 1 : 0,
     createdAt: timestamp,
     updatedAt: timestamp,
   }).run();

apps/api/src/db/repo/scaling.ts

@@ -28,6 +28,8 @@ export const upsertScalingPolicy = async (input: CreateScalingPolicyInput): Prom
     if (input.maxReplicas !== undefined) updates.maxReplicas = input.maxReplicas;
     if (input.cpuThresholdPercent !== undefined) updates.cpuThresholdPercent = input.cpuThresholdPercent;
     if (input.memoryThresholdPercent !== undefined) updates.memoryThresholdPercent = input.memoryThresholdPercent;
+    if (input.cooldownSeconds !== undefined) updates.cooldownSeconds = input.cooldownSeconds;
+    if (input.enabled !== undefined) updates.enabled = input.enabled ? 1 : 0;
     db.update(scalingPolicies).set(updates).where(eq(scalingPolicies.projectId, input.projectId)).run();
     return mapScalingPolicy(db.select().from(scalingPolicies).where(eq(scalingPolicies.projectId, input.projectId)).get()!);
   }
@@ -39,6 +41,8 @@ export const upsertScalingPolicy = async (input: CreateScalingPolicyInput): Prom
     maxReplicas: input.maxReplicas ?? 5,
     cpuThresholdPercent: input.cpuThresholdPercent ?? 70,
     memoryThresholdPercent: input.memoryThresholdPercent ?? 85,
+    cooldownSeconds: input.cooldownSeconds ?? 120,
+    enabled: input.enabled ? 1 : 1,
     createdAt: timestamp,
     updatedAt: timestamp,
   }).run();

apps/api/src/db/schema.ts

@@ -43,6 +43,7 @@ export const deployments = sqliteTable("deployments", {
   replicas: integer().notNull().default(1),
   environment: text(),
   failureReason: text("failure_reason"),
+  clearCache: integer("clear_cache").notNull().default(0),
   createdAt: text("created_at").notNull(),
   updatedAt: text("updated_at").notNull(),
 });

apps/api/src/orchestrator/pipeline.ts

@@ -316,21 +316,24 @@ export class PipelineOrchestrator {
 					deployment.sourceType ===
 					"git"
 				) {
-					const branchLabel =
-						deployment.branch
+					const commitLabel = deployment.commitSha
+						? ` (commit ${deployment.commitSha.slice(0, 7)})`
+						: deployment.branch
 							? ` (branch ${deployment.branch})`
 							: "";
 					await emitLog(
 						deploymentId,
 						"build",
-						`Cloning git repository: ${deployment.sourceRef}${branchLabel}`,
+						`Cloning git repository: ${deployment.sourceRef}${commitLabel}`,
 					);
 					workspacePath =
 						await prepareSourceWorkspace(
 							deploymentId,
 							deployment.sourceRef,
 							deployment.branch ??
 								undefined,
+							deployment.commitSha ??
+								undefined,
 						);
 					const sha = await getHeadSha(
 						workspacePath,
@@ -382,7 +385,7 @@ export class PipelineOrchestrator {
 						line,
 					);
 				},
-				{ cacheKey, sourceDir: project?.sourceDir, signal: controller.signal },
+				{ cacheKey, sourceDir: project?.sourceDir, signal: controller.signal, clearCache: deployment.clearCache },
 			);
 			} else {
 				await emitLog(

apps/api/src/orchestrator/railpack.ts

@@ -722,6 +722,7 @@ export const buildWithRailpack = async (
 		cacheKey?: string;
 		sourceDir?: string | null;
 		signal?: AbortSignal;
+		clearCache?: boolean;
 	},
 ): Promise<RailpackBuildResult> => {
 	await onLog(
@@ -731,13 +732,18 @@ export const buildWithRailpack = async (
 	// Ensure builder exists (persists across builds)
 	await ensureBuilder();
 
-	const cacheKey =
+	let cacheKey =
 		opts?.cacheKey ??
 		imageTag
 			.split(":")[0]
 			.replace(/-[0-9a-f]{8}$/i, "") // Strip unique deployment short ID suffix
 			.replace(/[^a-zA-Z0-9_-]/g, "-");
 
+	if (opts?.clearCache) {
+		cacheKey = `${cacheKey}-clear-${Date.now()}`;
+		await onLog(`Bypassing cache for clean build (cacheKey: ${cacheKey})`);
+	}
+
 	const cleanSourceDir = opts?.sourceDir
 		? opts.sourceDir.replace(/^\//, "")
 		: null;

apps/api/src/orchestrator/runtime.ts

@@ -94,6 +94,7 @@ export const ensureContainerRunning = async (containerName: string) => {
 };
 
 export const reloadCaddy = async () => {
+  if (process.env.NODE_ENV === 'test') return;
   const caddyContainer = await getCaddyContainer();
   await run(dockerBin, ['exec', caddyContainer, 'caddy', 'reload', '--config', '/etc/caddy/Caddyfile']);
 };

apps/api/src/orchestrator/source.ts

@@ -34,14 +34,19 @@ const run = (cmd: string, args: string[], cwd?: string) =>
     });
   });
 
-export const prepareSourceWorkspace = async (deploymentId: string, gitUrl: string, branch?: string) => {
+export const prepareSourceWorkspace = async (deploymentId: string, gitUrl: string, branch?: string, commitSha?: string) => {
   const root = join(config.workspaceRoot, deploymentId);
   await rm(root, { recursive: true, force: true });
   await mkdir(root, { recursive: true });
-  const args = ['clone', '--depth', '1'];
-  if (branch) args.push('--branch', branch);
-  args.push(gitUrl, root);
-  await run('git', args);
+  if (commitSha) {
+    await run('git', ['clone', gitUrl, root]);
+    await run('git', ['checkout', commitSha], root);
+  } else {
+    const args = ['clone', '--depth', '1'];
+    if (branch) args.push('--branch', branch);
+    args.push(gitUrl, root);
+    await run('git', args);
+  }
   return root;
 };