Update server.js

server.js

@@ -1,94 +1,41 @@
-import express from 'express';
-import multer from 'multer';
-import sharp from 'sharp';
-import path from 'path';
+import express from "express";
+import multer from "multer";
+import sharp from "sharp";
+import fs from "fs";
 
 const app = express();
-const PORT = process.env.PORT || 7860;
-
-// Multer with memory storage (no disk needed)
-const upload = multer({ storage: multer.memoryStorage() });
-
-app.post('/convert', upload.any(), async (req, res) => {
-  console.log('Received POST /convert request'); // Log for debugging in HF logs
-  try {
-    const files = req.files || [];
-    if (files.length === 0) {
-      console.log('No files received');
-      return res.status(400).json({ error: 'No files uploaded' });
-    }
-    if (files.length > 10) {
-      return res.status(400).json({ error: 'Max 10 files per request' });
-    }
+const upload = multer({ dest: "uploads/" });
 
-    // Parse optional bg hex (for transparent images)
-    const bgHex = req.body.bg || '#FFFFFF';
-    let bgColor = [255, 255, 255]; // Default white
+app.post("/convert", upload.single("file"), async (req, res) => {
     try {
-      const hex = bgHex.replace('#', '');
-      bgColor = [parseInt(hex.substr(0, 2), 16), parseInt(hex.substr(2, 2), 16), parseInt(hex.substr(4, 2), 16)];
-    } catch {}
-
-    const results = [];
-    const errors = [];
-
-    // Process each file concurrently
-    await Promise.all(files.map(async (file) => {
-      try {
-        console.log(`Processing file: ${file.originalname}`); // Debug log
-        let img = sharp(file.buffer);
-
-        // Flatten transparency onto background
-        img = img.flatten({ background: { r: bgColor[0], g: bgColor[1], b: bgColor[2] } });
-
-        // Convert to JPEG with high quality
-        const jpegBuffer = await img
-          .jpeg({
-            quality: 95,
-            mozjpeg: true, // Better compression with minimal loss
-            chromaSubsampling: '4:4:4', // Preserve color detail
-            progressive: true,
-            force: true,
-          })
-          .toBuffer();
-
-        // Base64 for response
-        const base64 = jpegBuffer.toString('base64');
-        const outputName = path.basename(file.originalname, path.extname(file.originalname)) + '.jpg';
-
-        results.push({ filename: outputName, data: base64 });
-      } catch (err) {
-        console.error(`Error processing ${file.originalname}: ${err.message}`);
-        errors.push({ filename: file.originalname, error: err.message });
-      }
-    }));
-
-    if (results.length === 0 && errors.length > 0) {
-      return res.status(500).json({ error: 'All conversions failed', details: errors });
-    }
-
-    console.log(`Conversion complete: ${results.length} successes, ${errors.length} errors`); // Debug log
-
-    // If single file, simplify response
-    if (results.length === 1 && errors.length === 0) {
-      return res.json({ message: 'Conversion successful', file: results[0] });
+        if (!req.file) {
+            return res.status(400).send("No file uploaded");
+        }
+
+        const outputPath = "converted.jpg";
+        
+        // Convert to JPG
+        await sharp(req.file.path)
+            .toFormat("jpeg")
+            .toFile(outputPath);
+
+        // Set correct headers so n8n/Postman downloads file
+        res.setHeader("Content-Type", "image/jpeg");
+        res.setHeader("Content-Disposition", 'attachment; filename="converted.jpg"');
+
+        const fileStream = fs.createReadStream(outputPath);
+        fileStream.pipe(res);
+
+        fileStream.on("close", () => {
+            fs.unlinkSync(req.file.path);
+            fs.unlinkSync(outputPath);
+        });
+
+    } catch (error) {
+        console.error(error);
+        res.status(500).send("Conversion failed");
     }
-
-    res.json({
-      message: 'Conversions successful',
-      files: results,
-      errors: errors.length > 0 ? errors : undefined,
-    });
-  } catch (err) {
-    console.error(`Server error: ${err.message}`);
-    res.status(500).json({ error: 'Server error' });
-  }
-});
-
-app.get('/', (req, res) => {
-  res.send('Server ready for image conversions!');
 });
 
-app.listen(PORT, () => {
-  console.log(`Server running on port ${PORT}`);
-});
+const PORT = process.env.PORT || 7860;
+app.listen(PORT, () => console.log(`Server running on port ${PORT}`));