Update src/index.js

src/index.js

@@ -5,28 +5,112 @@ const util = require('util')
 const uuid = require('uuid')
 const logger = require('morgan')
 const express = require('express')
-const puppeteer = require('puppeteer')
+const puppeteer = require('puppeteer').executablePath()
 const rateLimit = require('express-rate-limit')
-const CharacterAI = require('node_characterai')
 const { execSync } = require('child_process')
+const axios = require('axios');
+const cheerio = require('cheerio');
 
-const sessions = new Map()
 
 const app = express()
 app.set('trust proxy', 1)
 app.set('json spaces', 4)
 app.use(logger('dev'))
 app.use(express.urlencoded({ extended: true }))
-app.use(async (req, res, next) => {
-	for (let [sessionId, characterAI] of sessions) {
-		const timeReset = 10 * 60 * 1000 // 10 min
-		if (Date.now() - characterAI.lastFetch > timeReset) {
-			await characterAI.unauthenticate()
-			sessions.delete(sessionId)
+
+const headers = {
+	'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/94.0.4606.61 Safari/537.36'
+};
+
+async function extractVideoUrl(url) {
+	try {
+		let res = await axios.get(url, {
+			headers
+		});
+		let result = res.data;
+		let $ = cheerio.load(result);
+		let liElement = $('li[data-id]'); // Pilih elemen <li> dengan atribut data-id
+		let dataIdValue = liElement.attr('data-id'); // Dapatkan nilai atribut data-id
+
+		let final = new URL(dataIdValue, 'https://nhplayer.com').toString();
+		const response = await axios.get(final);
+		const html = response.data;
+		const $2 = cheerio.load(html);
+
+		const scriptContent = $2('script:contains("file: ")').html();
+		const match = scriptContent.match(/file:\s*["']([^"']+)["']/);
+
+		if (match && match[1]) {
+			const videoUrl = match[1];
+			return {
+				url: videoUrl
+			};
+		} else {
+			console.log('Tidak dapat menemukan URL video.');
+			return null;
+		}
+	} catch (error) {
+		console.error('Error:', error);
+		return {
+			msg: error
 		}
 	}
-	next()
-})
+}
+
+async function findChromiumPath() {
+	let cmd = execSync('nix eval nixpkgs.chromium.outPath --raw').toString();
+	return `${cmd.trim()}/bin/chromium`;
+}
+
+async function scrapeAndFindIframeSrc(main_url) {
+	//const chromiumPath = await findChromiumPath();
+
+	const browser = await puppeteer.launch({
+		//executablePath: chromiumPath,
+		headless: true,
+		args: [
+			'--no-sandbox',
+		]
+	});
+
+	const page = await browser.newPage();
+
+	try {
+		await page.goto(main_url);
+		await page.click('button.btn.uppercase');
+		await page.waitForNavigation();
+		await page.waitForSelector('.aspect-video.-lg\\:-mx-2.order-first iframe');
+
+		const iframeSrc = await page.$eval('.aspect-video.-lg\\:-mx-2.order-first iframe', iframe => iframe.src);
+
+		return {
+			url: iframeSrc
+		}
+	} catch (error) {
+		return {
+			msg: error
+		}
+	} finally {
+		await browser.close();
+	}
+}
+
+async function hentaitv(url) {
+	try {
+		var data = await scrapeAndFindIframeSrc(url)
+		var result = await extractVideoUrl(data.url)
+		return {
+			file_url: result.url
+		}
+	} catch (error) {
+		return {
+			msg: error
+		}
+	}
+}
+
+
+
 
 app.all('/', (req, res) => {
 	const obj = {}
@@ -51,62 +135,29 @@ app.all('/', (req, res) => {
 
 app.get('/ip', (req, res) => res.send(req.ip))
 
-app.get('/sessions', (_, res) => res.send(eval(Array.from(sessions))))
 
-app.all('/api', rateLimit(), async (req, res) => {
-	if (!['GET', 'POST'].includes(req.method)) return res.json({ success: false, message: 'Method not allowed' })
-	try {
-		const { characterId, text, sessionId } = req.query
-		if (!characterId) return res.json({ success: false, message: 'Input parameter characterId' })
-		if (!text) return res.json({ success: false, message: 'Input parameter text' })
-		
-		if (sessionId) {
-			if (!sessions.has(sessionId)) return res.json({ success: false, message: 'sessionId not found' })
-			const characterAI = sessions.get(sessionId)
-			sessions.set(sessionId, Object.assign(characterAI, { lastFetch: Date.now() }))
-			
-			const chat = await characterAI.createOrContinueChat(characterId)
-			const response = await chat.sendAndAwaitResponse(text, true)
-			const urlAvatar = `https://characterai.io/i/80/static/avatars/${response.srcAvatarFileName}`
-			
-			delete response.chat
-			res.json({
-				success: true,
-				message: 'sessionId will be deleted in 10 minutes if not used',
-				result: { ...response, urlAvatar, sessionId }
-			})
-			return
-		}
-		
-		const id = uuid.v4()
-		const characterAI = new CharacterAI()
-		characterAI.requester.puppeteerPath = puppeteer.executablePath()
-		await characterAI.authenticateAsGuest()
-		sessions.set(id, Object.assign(characterAI, { lastFetch: Date.now() }))
-		
-		const chat = await characterAI.createOrContinueChat(characterId)
-		const response = await chat.sendAndAwaitResponse(text, true)
-		const urlAvatar = `https://characterai.io/i/80/static/avatars/${response.srcAvatarFileName}`
-		
-		delete response.chat
-		res.json({
-			success: true,
-			message: 'sessionId will be deleted in 10 minutes if not used',
-			result: { ...response, urlAvatar, sessionId: id }
-		})
-	} catch (e) {
-		console.log(e)
-		e = String(e)
-		res.json({
-			error: true,
-			message: e === '[object Object]' ? 'Internal Server Error' : e
-		})
-	}
-})
+app.get('/htv', async (req, res) => {
+  try {
+  const { url } = req.query;
+  if (!url) {
+    return res.json({ success: false, message: 'Input parameter url' });
+  }
+  let datas = await hentaitv(url)
+  res.json({ success: true, result : datas });
+  } catch (error) {
+    console.error('Error:', error);
+    res.json({ success: false, message: 'An error occurred ' + error });
+  }
+});
+
+app.get('/ping', (req, res) => {
+  res.send('Pong');
+});
+
+
 
 const PORT = process.env.PORT || 7860
 app.listen(PORT, () => console.log('App running on port', PORT))
-
-// const { REPL_SLUG, REPL_OWNER } = process.env
-// if (REPL_SLUG && REPL_OWNER)
-	setInterval(() => fetch(`https://c-ai.team-skizo.repl.co`, { method: 'head' }).catch(console.log), 20 * 1000)
+	setInterval(() => fetch(`https://nultx-hent-ai.hf.space/ping`, { method: 'head' }).catch(console.log), 30 * 1000)
+	
+