Update index.js

index.js

@@ -1,3 +1,4 @@
+const fs = require('fs')
 const os = require('os')
 const mime = require('mime')
 const axios = require('axios')
@@ -12,6 +13,8 @@ app.set('json spaces', 4)
 app.use(morgan('dev'))
 app.use(express.json())
 
+app.use('/file', express.static(os.tmpdir()))
+
 app.all('/', (req, res) => {
 	const status = {}
 	const used = process.memoryUsage()
@@ -31,7 +34,7 @@ app.all('/', (req, res) => {
 
 app.post('/imagetopdf', async (req, res) => {
 	try {
-		console.log(req.body)
+		console.log(new Date().toLocaleString('id', { timeZone: 'Asia/Jakarta' }), '\n', req.body)
 		const { images } = req.body
 		if (!images) return res.json({ success: false, message: 'Required an array image url' })
 		
@@ -47,87 +50,19 @@ app.post('/imagetopdf', async (req, res) => {
 	}
 })
 
-app.all('/yt', async (req, res) => {
-	if (!['GET', 'POST'].includes(req.method)) return res.status(405).json({ success: false, message: 'Method Not Allowed' })
+app.all('/webp2png', async (req, res) => {
+	if (!['POST'].includes(req.method)) return res.status(405).json({ success: false, message: 'Method Not Allowed' })
 	
 	try {
-		const url = req.method !== 'GET' ? req.body.url : req.query.url
-		if (!url) return res.json({ success: false, message: 'Input parameter url' })
-		if (!/^https?:\/\//.test(url)) return res.json({ success: false, message: 'Invalid url' })
-		
-		const response = await fetch(`https://srvcdn3.2convert.me/api/json?url=${url}`, { headers: { referer: 'https://y2mate.is/' }})
-		const json = await response.json()
-		if (json.error) return res.json({ success: false, message: json.message || json.errorMessage })
-		
-		const { duration } = json.formats
-		const result = {
-			...json.formats,
-			lengthSeconds: +duration,
-			duration: new Date(duration * 1000).toUTCString().split(' ')[4],
-			video: {},
-			audio: {}
-		}
-		
-		for (const type of ['video', 'audio']) {
-			json.formats[type].forEach((data) => {
-				const { quality: q, fileType, needConvert, fileSize, url: dlUrl } = data
-				const quality = type === 'video' ? q : `${q}kbps`
-				
-				result[type][quality] = {
-					quality,
-					fileType,
-					fileSizeH: formatSize(fileSize),
-					fileSize,
-					needConvert,
-					url: !needConvert ? dlUrl : `https://${process.env.SPACE_HOST}${req.path}/convert?hash=${encodeURIComponent(dlUrl)}`
-				}
-			})
-		}
-		
-		res.json({ success: true, result })
-	} catch (e) {
-		console.log(e)
-		e = String(e)
-		res.status(500).json({ error: true, message: e === '[object Object]' ? 'Internal Server Error' : e })
-	}
-})
-
-app.get('/yt/convert', async (req, res) => {
-	try {
-		const { hash } = req.query
-		if (!hash) return res.json({ success: false, message: 'Invalid hash' })
+		const { file } = req.body
+		if (!(file && isBase64(file))) return res.json({ success: false, message: 'Payload body file must be filled in base64 format' })
 		
-		const fetchPost = (url, body) => (fetch(url, {
-			method: 'POST', body,
-			headers: {
-				'Content-Type': 'application/x-www-form-urlencoded',
-				'Referer': 'https://y2mate.is/'
-			}
-		}))
+		const fileBuffer = Buffer.from(file, 'base64')
+		const fileName = `${Math.random().toString(36)}.png`
+		const convertData = await sharp(fileBuffer).png().toBuffer()
 		
-		const reqTaskId = await fetchPost('https://srvcdn3.2convert.me/api/json', `hash=${encodeURIComponent(hash)}`)
-		if (!reqTaskId.ok) return res.json({ success: false, message: 'Hash not found' })
-		
-		const reqTaskJson = await reqTaskId.json()
-		if (reqTaskJson.error) return res.json({ success: false, message: reqTaskJson.message })
-		
-		let result
-		while (!result) {
-			const fetchTaskId = await fetchPost('https://srvcdn3.2convert.me/api/json/task', `taskId=${reqTaskJson.taskId}`)
-			const fetchTaskJson = await fetchTaskId.json()
-			console.log(fetchTaskJson)
-			if (fetchTaskJson.status === 'finished') {
-				result = fetchTaskJson
-				break
-			}
-			await new Promise(resolve => setTimeout(resolve, 1000))
-		}
-		
-		const { download, title, ext } = result
-		const response = await axios.get(download, { responseType: 'stream' })
-		res.setHeader('Content-Disposition', `attachment; filename=${encodeURIComponent(title)}.${ext}`)
-		res.setHeader('Content-Type', mime.types[ext])
-		response.data.pipe(res)
+		await fs.promises.writeFile(`${os.tmpdir()}/${fileName}`, convertData)
+		res.send(`https://${req.get('host')}/file/${fileName}`)
 	} catch (e) {
 		console.log(e)
 		e = String(e)
@@ -187,6 +122,14 @@ function formatSize(num) {
 	return bytes(+num || 0, { unitSeparator: ' ' })
 }
 
+function isBase64(str) {
+	try {
+		return btoa(atob(str)) === str
+	} catch {
+		return false
+	}
+}
+
 function toPDF(urls) {
 	return new Promise(async (resolve, reject) => {
 		try {