Update server.js

server.js

@@ -1,47 +1,94 @@
 import express from 'express';
 import multer from 'multer';
-import fs from 'fs';
+import sharp from 'sharp';
 import path from 'path';
 
 const app = express();
 const PORT = process.env.PORT || 7860;
 
-// Multer storage in memory (keeps files in RAM)
-const storage = multer.memoryStorage();
-const upload = multer({ storage });
+// Multer with memory storage (no disk needed)
+const upload = multer({ storage: multer.memoryStorage() });
 
-// Accept ANY files, any field name
-app.post('/upload', upload.any(), async (req, res) => {
+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' });
+    }
+
+    // Parse optional bg hex (for transparent images)
+    const bgHex = req.body.bg || '#FFFFFF';
+    let bgColor = [255, 255, 255]; // Default white
     try {
-        if (!req.files || req.files.length === 0) {
-            return res.status(400).json({ error: 'No files uploaded' });
-        }
-
-        // Save uploaded files locally for processing
-        const savedFiles = [];
-        for (const file of req.files) {
-            const filePath = path.join('/tmp', file.originalname);
-            fs.writeFileSync(filePath, file.buffer);
-            savedFiles.push(filePath);
-        }
-
-        // Here is where you process files (e.g., image conversion)
-        console.log('Files received:', savedFiles);
-
-        res.json({
-            message: 'Files uploaded successfully!',
-            files: savedFiles
-        });
-    } catch (err) {
-        console.error(err);
-        res.status(500).json({ error: 'File processing failed' });
+      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] });
+    }
+
+    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 is running and ready for uploads!');
+  res.send('Server ready for image conversions!');
 });
 
 app.listen(PORT, () => {
-    console.log(`Server running on port ${PORT}`);
-});
+  console.log(`Server running on port ${PORT}`);
+});