Update app.js

app.js

@@ -8,107 +8,89 @@ const app = express();
 const cache = new NodeCache();
 let idCounter = 1;
 
-app.use(express.json());
+// Serve static files (HTML, CSS, JS)
+app.use(express.static(path.join(__dirname)));
 
-// Serve the HTML UI
+// Main UI
 app.get('/', (req, res) => {
   res.sendFile(path.join(__dirname, 'index.html'));
 });
 
-/**
- * Generate a unique short key composed of an incremental ID and random text.
- * Example: "23-ab12cd"
- */
+// Spotify Downloader UI
+// Generate unique short key
 function generateKey() {
   const id = idCounter++;
   const rand = crypto.randomBytes(3).toString('hex');
   return `${id}-${rand}`;
 }
 
-/**
- * Scrape helper: uses RapidAPI auto-download service to resolve media URLs
- * @param {string} url - Original social media link
- * @returns {object} - Parsed response with download URLs
- */
+// Scrape via RapidAPI using provided API key
 async function aio(url) {
-  if (!url || !url.includes('https://')) {
-    throw new Error('Url is required and must include https://');
-  }
-
-  const response = await axios.post(
+  if (!url || !url.startsWith('https://')) throw new Error('Invalid URL');
+  const apiKey = '1dda0d29d3mshc5f2aacec619c44p16f219jsn99a62a516f98';
+  const { data } = await axios.post(
     'https://auto-download-all-in-one.p.rapidapi.com/v1/social/autolink',
-    { url: url },
+    { url },
     {
       headers: {
+        'content-type': 'application/json; charset=utf-8',
         'accept-encoding': 'gzip',
         'cache-control': 'no-cache',
-        'content-type': 'application/json; charset=utf-8',
-        referer: 'https://auto-download-all-in-one.p.rapidapi.com/',
+        'referer': 'https://auto-download-all-in-one.p.rapidapi.com/',
         'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64)',
         'x-rapidapi-host': 'auto-download-all-in-one.p.rapidapi.com',
-        // TODO: replace with your actual RapidAPI key
-        'x-rapidapi-key': '1dda0d29d3mshc5f2aacec619c44p16f219jsn99a62a516f98'
+        'x-rapidapi-key': apiKey
       }
     }
   );
-  return response.data;
+  return data;
 }
 
 /**
- * Create a short proxy URL for downloading remote content. Optionally scrapes social links.
- * GET /proxy-url?url=<url>&ttlSeconds=<seconds>
+ * Endpoint to scrape & shorten media URLs
+ * GET /proxy-url?url=<source_url>&ttlSeconds=<seconds>
  */
 app.get('/proxy-url', async (req, res) => {
   const { url, ttlSeconds } = req.query;
-  if (!url || !url.startsWith('http')) {
-    return res.status(400).json({ error: 'Missing or invalid "url" query parameter' });
-  }
+  if (!url) return res.status(400).json({ error: 'Missing url parameter' });
 
-  let targetUrl = url;
   try {
-    const data = await aio(url);
-    if (data.url) {
-      targetUrl = data.url;
-    } else if (Array.isArray(data.data) && data.data[0] && data.data[0].url) {
-      targetUrl = data.data[0].url;
+    const result = await aio(url);
+    if (result.data && Array.isArray(result.data.medias)) {
+      result.data.medias = result.data.medias.map(media => {
+        const key = generateKey();
+        cache.set(key, media.url, ttlSeconds ? Number(ttlSeconds) : 0);
+        return { ...media, url: `${req.protocol}://${req.get('host')}/proxy-url/d/${key}` };
+      });
     }
+    res.json(result);
   } catch (err) {
-    console.warn('Scrape failed, using original URL:', err.message);
+    console.error('Error in proxy-url:', err.message);
+    res.status(500).json({ error: err.message });
   }
-
-  const key = generateKey();
-  const ttl = ttlSeconds ? Number(ttlSeconds) : 0;
-  cache.set(key, targetUrl, ttl);
-
-  const shortUrl = `${req.protocol}://${req.get('host')}/proxy-url/d/${key}`;
-  res.json({ shortUrl });
 });
 
 /**
- * Proxy endpoint to stream content by key
+ * Download proxy endpoint
  * GET /proxy-url/d/:key
  */
 app.get('/proxy-url/d/:key', async (req, res) => {
-  const { key } = req.params;
-  const url = cache.get(key);
-  if (!url) {
-    return res.status(404).send('Invalid or expired link');
-  }
+  const key = req.params.key;
+  const target = cache.get(key);
+  if (!target) return res.status(404).send('Link expired or invalid');
 
   try {
-    const response = await axios.get(url, { responseType: 'stream' });
-    Object.entries(response.headers).forEach(([name, value]) => {
-      res.setHeader(name, value);
-    });
+    const response = await axios.get(target, { responseType: 'stream' });
+    Object.entries(response.headers).forEach(([name, value]) => res.setHeader(name, value));
     response.data.pipe(res);
   } catch (err) {
     console.error('Download error:', err.message);
-    res.status(502).send('Failed to download the requested resource');
+    res.status(502).send('Download failed');
   }
 });
 
 // Health check
 app.get('/health', (req, res) => res.send('OK'));
 
-const PORT = process.env.PORT || 7860;
+const PORT = process.env.PORT || 3000;
 app.listen(PORT, () => console.log(`AIO Downloader running on port ${PORT}`));