Update index.js

index.js

@@ -12,45 +12,41 @@ app.use('/temp', express.static(tempDir));
 app.use(express.json());
 
 app.get("/", (req, res) => {
-	res.type("json");
-	const keluaran = {
-		success: true,
-		author: "Nex",
-		data: {
-			igdl: "/igdl"
-		},
-	};
-	res.send(keluaran);
+  res.type("json");
+  const keluaran = {
+    success: true,
+    author: "Nex",
+    data: {
+      igdl: "/igdl"
+    },
+  };
+  res.send(keluaran);
 });
 
 async function downloadImage(url) {
-	try {
-		const response = await axios.get(url, {
-			responseType: 'arraybuffer'
-		});
-		const randomCode = Math.random().toString(36).substring(7);
-		const imagePath = `downloaded_image_${randomCode}.png`;
-		fs.writeFileSync(path.join(tempDir, "/" + imagePath), Buffer.from(response.data, 'binary'));
-		return imagePath;
-	} catch (error) {
-		console.error('Error downloading image:', error.message);
-		throw error;
-	}
+  try {
+    const response = await axios.get(url, { responseType: 'arraybuffer' });
+    const randomCode = Math.random().toString(36).substring(7);
+    const imagePath = `downloaded_image_${randomCode}.png`;
+    fs.writeFileSync(path.join(tempDir, "/" + imagePath), Buffer.from(response.data, 'binary'));
+    return imagePath;
+  } catch (error) {
+    console.error('Error downloading image:', error.message);
+    throw error;
+  }
 }
 
 async function downloadVideo(url) {
-	try {
-		const response = await axios.get(url, {
-			responseType: 'arraybuffer'
-		});
-		const randomCode = Math.random().toString(36).substring(7);
-		const videoPath = `downloaded_video_${randomCode}.mp4`;
-		fs.writeFileSync(path.join(tempDir, "/" + videoPath), Buffer.from(response.data, 'binary'));
-		return videoPath;
-	} catch (error) {
-		console.error('Error downloading video:', error.message);
-		throw error;
-	}
+  try {
+    const response = await axios.get(url, { responseType: 'arraybuffer' });
+    const randomCode = Math.random().toString(36).substring(7);
+    const videoPath = `downloaded_video_${randomCode}.mp4`;
+    fs.writeFileSync(path.join(tempDir, "/" + videoPath), Buffer.from(response.data, 'binary'));
+    return videoPath;
+  } catch (error) {
+    console.error('Error downloading video:', error.message);
+    throw error;
+  }
 }
 
 const generateRandomIP = () => {
@@ -271,74 +267,68 @@ async function igdl4(url) {
 }
 
 const getInstagramDownloadLinks = async (url) => {
-	let result = await igdl1(url);
-	if (!result) {
-		result = await igdl2(url);
-	}
-	if (!result) {
-		result = await igdl3(url);
-	}
-	if (!result) {
-		result = await igdl4(url);
-	}
-	if (!result) {
-		result = {
-			message: "all server error"
-		};
-	}
-	return result;
+  let result = await igdl1(url);
+  if (!result) {
+    result = await igdl2(url);
+  }
+  if (!result) {
+    result = await igdl3(url);
+  }
+  if (!result) {
+    result = await igdl4(url);
+  }
+  if (!result) {
+    result = {
+      message: "all server error"
+    };
+  }
+  return result;
 };
 
 app.get('/igdl', async (req, res) => {
-	try {
-		const {
-			url
-		} = req.query;
-		if (!url) {
-			return res.status(400).json({
-				error: 'Parameter url is required'
-			});
-		}
-		if (!/https?:\/\/(www\.)?instagram\.com\/(p|reel|tv)/.test(url)) {
-			return res.status(400).json({
-				error: "Example: https://www.instagram.com/p/Cz1fTwMJFpx/?igsh=MXRrY2g4eWNucGoyZg=="
-			});
-		}
-		let result = await getInstagramDownloadLinks(url);
-		let result_upload = {
-			title: result?.title || 'untitled',
-			media: []
-		}
+  try {
+    const { url } = req.query;
+    if (!url) {
+      return res.status(400).json({ error: 'Parameter url is required' });
+    }
+    if (!/https?:\/\/(www\.)?instagram\.com\/(p|reel|tv)/.test(url)) {
+      return res.status(400).json({ error: "Example: https://www.instagram.com/p/Cz1fTwMJFpx/?igsh=MXRrY2g4eWNucGoyZg==" });
+    }
+    let result = await getInstagramDownloadLinks(url);
+    let result_upload = { 
+      title: result?.title || 'untitled',
+      media: []
+    }
 
-
-		for (let item of result.urls) {
-			if (item.type === "image") {
-				let unduh = await downloadImage(item.url)
-				result_upload.media.push({
-					type: item.type,
-					path: unduh,
-					url_path: `http://${process.env.SPACE_HOST}/temp/${path.basename(unduh)}`
-				})
-			} else if (item.type === "video") {
-				let unduh = await downloadVideo(item.url)
-				result_upload.media.push({
-					type: item.type,
-					path: unduh,
-					url_path: `http://${process.env.SPACE_HOST}/temp/${path.basename(unduh)}`
-				})
-			}
-		}
-
-		res.json(result_upload);
-	} catch (error) {
-		console.error('Error processing request:', error);
-		res.status(500).json({
-			error: 'Failed to process request\n' + error
-		});
-	}
+    for (let item of result.urls) {
+      if (item.type === "image") {
+        let unduh = await downloadImage(item.url);
+        result_upload.media.push({ type: item.type, path: unduh, url_path: `http://${process.env.SPACE_HOST}/temp/${path.basename(unduh)}` });
+      } else if (item.type === "video") { 
+        let unduh = await downloadVideo(item.url);
+        result_upload.media.push({ type: item.type, path: unduh, url_path: `http://${process.env.SPACE_HOST}/temp/${path.basename(unduh)}` });
+      }
+    }
+    
+    res.json(result_upload);
+    
+    for (let item of result_upload.media) {
+      try {
+        await new Promise(resolve => setTimeout(resolve, 10 * 60 * 1000)); // 10 minutes
+        await fs.unlink(item.path);
+        console.log(`File ${item.path} deleted.`);
+      } catch (error) {
+        console.error(`Error deleting file ${item.path}:`, error);
+      }
+    }
+  } catch (error) {
+    console.error('Error processing request:', error);
+    res.status(500).json({ error: 'Failed to process request\n' + error});
+  }
 });
 
-const hostname = `http://${process.env.SPACE_HOST}`; // Ganti dengan host yang sesuai
+
+const hostname = `http://${process.env.SPACE_HOST}`;  // Ganti dengan host yang sesuai
 app.listen(PORT, () => {
-	console.log(`Server is running on http://${hostname}:${PORT}`);
-});
+  console.log(`Server is running on http://${hostname}:${PORT}`);
+});