fix: increase container startup timeout and optimize zip creation

- Increase entrypoint timeout from 60s to 300s to allow for long migrations/seeds
- Add process check in entrypoint to fail fast if backend dies
- Offload ZIP creation to worker thread to prevent event loop blocking

Author: gilberth

.gitignore

@@ -51,3 +51,11 @@ yarn-error.log*
 
 # Files
 CLAUDE.md
+.clinerules/byterover-rules.md
+.kilocode/rules/byterover-rules.md
+.roo/rules/byterover-rules.md
+.windsurf/rules/byterover-rules.md
+.cursor/rules/byterover-rules.mdc
+.kiro/steering/byterover-rules.md
+.qoder/rules/byterover-rules.md
+.augment/rules/byterover-rules.md

CLAUDE.md

@@ -306,4 +306,25 @@ feature/
 - **Frontend Health Monitoring**:
   - Luego de iniciar el frontend esperar cierto tiempo para validar si aun se encuentra activo, si no revisa el motivo de la caida del front
 
-Cada cambio que realice agregaro a CHANGELOG.md
+Cada cambio que realice agregaro a CHANGELOG.md
+
+[byterover-mcp]
+
+[byterover-mcp]
+
+You are given two tools from Byterover MCP server, including
+## 1. `byterover-store-knowledge`
+You `MUST` always use this tool when:
+
++ Learning new patterns, APIs, or architectural decisions from the codebase
++ Encountering error solutions or debugging techniques
++ Finding reusable code patterns or utility functions
++ Completing any significant task or plan implementation
+
+## 2. `byterover-retrieve-knowledge`
+You `MUST` always use this tool when:
+
++ Starting any new task or implementation to gather relevant context
++ Before making architectural decisions to understand existing patterns
++ When debugging issues to check for previous solutions
++ Working with unfamiliar parts of the codebase

backend/src/share/share.service.ts

@@ -6,10 +6,11 @@ import {
 } from "@nestjs/common";
 import { JwtService, JwtSignOptions } from "@nestjs/jwt";
 import { Share, User } from "@prisma/client";
-import * as archiver from "archiver";
 import * as argon from "argon2";
 import * as fs from "fs";
 import * as moment from "moment";
+import * as path from "path";
+import { Worker } from "worker_threads";
 import { ClamScanService } from "src/clamscan/clamscan.service";
 import { ConfigService } from "src/config/config.service";
 import { EmailService } from "src/email/email.service";
@@ -32,7 +33,7 @@ export class ShareService {
     private jwtService: JwtService,
     private reverseShareService: ReverseShareService,
     private clamScanService: ClamScanService,
-  ) {}
+  ) { }
 
   async create(share: CreateShareDTO, user?: User, reverseShareToken?: string) {
     if (!(await this.isShareIdAvailable(share.id)).isAvailable)
@@ -62,7 +63,7 @@ export class ShareService {
         maxExpiration.value !== 0 &&
         (expiresNever ||
           parsedExpiration >
-            moment().add(maxExpiration.value, maxExpiration.unit).toDate())
+          moment().add(maxExpiration.value, maxExpiration.unit).toDate())
       ) {
         throw new BadRequestException(
           "Expiration date exceeds maximum expiration date",
@@ -109,22 +110,36 @@ export class ShareService {
   async createZip(shareId: string) {
     if (this.config.get("s3.enabled")) return;
 
-    const path = `${SHARE_DIRECTORY}/${shareId}`;
-
     const files = await this.prisma.file.findMany({ where: { shareId } });
-    const archive = archiver("zip", {
-      zlib: { level: this.config.get("share.zipCompressionLevel") },
-    });
-    const writeStream = fs.createWriteStream(`${path}/archive.zip`);
 
-    for (const file of files) {
-      archive.append(fs.createReadStream(`${path}/${file.id}`), {
-        name: file.name,
+    return new Promise((resolve, reject) => {
+      const isTs = __filename.endsWith(".ts");
+      const workerFileName = isTs ? "zip.worker.ts" : "zip.worker.js";
+      const workerPath = path.join(__dirname, workerFileName);
+
+      const worker = new Worker(workerPath, {
+        workerData: {
+          shareId,
+          files,
+          shareDirectory: SHARE_DIRECTORY,
+          compressionLevel: this.config.get("share.zipCompressionLevel"),
+        },
+        execArgv: isTs ? ["-r", "ts-node/register"] : undefined,
       });
-    }
 
-    archive.pipe(writeStream);
-    await archive.finalize();
+      worker.on("message", (message) => {
+        if (typeof message === "object" && message.error) {
+          reject(new Error(message.error));
+        } else {
+          resolve(message);
+        }
+      });
+      worker.on("error", reject);
+      worker.on("exit", (code) => {
+        if (code !== 0)
+          reject(new Error(`Worker stopped with exit code ${code}`));
+      });
+    });
   }
 
   async complete(id: string, reverseShareToken?: string) {
@@ -165,7 +180,7 @@ export class ShareService {
 
     const notifyReverseShareCreator = share.reverseShare
       ? this.config.get("smtp.enabled") &&
-        share.reverseShare.sendEmailNotification
+      share.reverseShare.sendEmailNotification
       : undefined;
 
     if (notifyReverseShareCreator) {
@@ -323,7 +338,7 @@ export class ShareService {
     // Handle security updates
     if (updateData.security) {
       hasSecurityUpdates = true;
-      
+
       if (updateData.security.password) {
         updateSecurity.password = await argon.hash(updateData.security.password);
       }
@@ -341,11 +356,11 @@ export class ShareService {
         ...(hasSecurityUpdates && {
           security: existingShare.security
             ? {
-                update: updateSecurity,
-              }
+              update: updateSecurity,
+            }
             : {
-                create: updateSecurity,
-              },
+              create: updateSecurity,
+            },
         }),
       },
     });

backend/src/share/zip.worker.ts

@@ -0,0 +1,36 @@
+import { parentPort, workerData } from 'worker_threads';
+import * as archiver from 'archiver';
+import * as fs from 'fs';
+
+async function createZip() {
+  try {
+    const { shareId, files, shareDirectory, compressionLevel } = workerData;
+    const path = `${shareDirectory}/${shareId}`;
+
+    const archive = archiver('zip', {
+      zlib: { level: compressionLevel },
+    });
+    const writeStream = fs.createWriteStream(`${path}/archive.zip`);
+
+    for (const file of files) {
+      archive.append(fs.createReadStream(`${path}/${file.id}`), {
+        name: file.name,
+      });
+    }
+
+    archive.pipe(writeStream);
+    await archive.finalize();
+
+    if (parentPort) {
+      parentPort.postMessage('done');
+    }
+  } catch (error) {
+    if (parentPort) {
+      // Send error message or object
+      parentPort.postMessage({ error: error instanceof Error ? error.message : String(error) });
+    }
+    process.exit(1);
+  }
+}
+
+createZip();

scripts/docker/entrypoint.sh

@@ -11,8 +11,14 @@ cd ..
 
 # Wait for backend to be ready
 echo "Waiting for backend to be ready..."
-timeout=60
+timeout=300
 while [ $timeout -gt 0 ]; do
+  # Check if backend process is still running
+  if ! kill -0 $BACKEND_PID 2>/dev/null; then
+    echo "ERROR: Backend process died while waiting for it to be ready"
+    exit 1
+  fi
+
   if curl -sf http://localhost:8080/api/health > /dev/null 2>&1; then
     echo "Backend is ready!"
     break
@@ -23,7 +29,7 @@ while [ $timeout -gt 0 ]; do
 done
 
 if [ $timeout -le 0 ]; then
-  echo "Backend failed to start within 60 seconds"
+  echo "Backend failed to start within 300 seconds"
   exit 1
 fi