Upload server.js

server.js

@@ -53,7 +53,7 @@ async function fetchText(url, timeoutMs, clientUA) {
       redirect: 'follow',
       signal: controller.signal,
       headers: {
-        'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36'
+        'user-agent': clientUA || 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36'
       }
     })
 
@@ -81,7 +81,7 @@ async function fetchText(url, timeoutMs, clientUA) {
   }
 }
 
-function jsWrapper(serverBase, baseUrl, transpiledCode, needRegenerator, useVpn, useEs5) {
+function jsWrapper(serverBase, baseUrl, transpiledCode, needRegenerator, useVpn, useEs5, useStream) {
   const safeServer = JSON.stringify(String(serverBase || ''))
   const safeBaseUrl = JSON.stringify(String(baseUrl || ''))
 
@@ -167,8 +167,9 @@ function jsWrapper(serverBase, baseUrl, transpiledCode, needRegenerator, useVpn,
     'var xhr=new _RealXHR();' +
     'var origOpen=xhr.open;' +
     'xhr.open=function(method,u,async,user,pass){' +
-    'try{u=proxyRaw(u);}catch(e){}' +
-    'return origOpen.call(xhr,method,u,(async===undefined?true:async),user,pass);' +
+    'var args=Array.prototype.slice.call(arguments);' +
+    'try{args[1]=proxyRaw(args[1]);}catch(e){}' +
+    'return origOpen.apply(xhr,args);' +
     '};' +
     'return xhr;' +
     '};' +
@@ -197,6 +198,23 @@ function jsWrapper(serverBase, baseUrl, transpiledCode, needRegenerator, useVpn,
     '}' +
     '}catch(e){}'
     ) : '') +
+    (useStream ? (
+    'try{' +
+    'if(Lampa&&Lampa.Player){' +
+    'if(!Lampa.hasOwnProperty("Player")) Lampa=Object.create(Lampa);' +
+    'var _RealPlayer=Lampa.Player;' +
+    'Lampa.Player=Object.create(_RealPlayer);' +
+    'Lampa.Player.play=function(data){' +
+    'try{' +
+    'if(data&&data.url&&typeof data.url==="string"&&data.url.indexOf(__es5_server)===-1&&data.url.indexOf("warp.cfhttp.top")===-1){' +
+    'data.url=__es5_server+"/r?url="+encodeURIComponent(data.url).replace(/%3A/gi, ":").replace(/%2F/gi, "/");' +
+    '}' +
+    '}catch(e){}' +
+    'return _RealPlayer.play.apply(this,arguments);' +
+    '};' +
+    '}' +
+    '}catch(e){}'
+    ) : '') +
     'try{' +
     'var __mock_script = document.createElement("script");' +
     '__mock_script.src = __es5_base;' +
@@ -316,6 +334,7 @@ app.get('/p', async (req, res) => {
 
   const useEs5 = req.query.es5 !== '0';
   const useVpn = req.query.vpn !== '0';
+  const useStream = req.query.stream === '1';
 
   try {
     const { text } = await fetchText(source, 25_000, req.headers['user-agent'])
@@ -348,7 +367,7 @@ app.get('/p', async (req, res) => {
     }
 
     const serverBase = getSelfBase(req)
-    const out = jsWrapper(serverBase, source, code, needRegenerator, useVpn, useEs5)
+    const out = jsWrapper(serverBase, source, code, needRegenerator, useVpn, useEs5, useStream)
 
     res.setHeader('content-type', 'application/javascript; charset=utf-8')
     res.setHeader('cache-control', 'public, max-age=600')
@@ -404,7 +423,9 @@ app.all('/r', async (req, res) => {
   const targetUrl = new URL(source);
   headers['origin'] = targetUrl.origin;
   headers['referer'] = targetUrl.origin + '/';
-  headers['user-agent'] = 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36';
+  if (!headers['user-agent']) {
+    headers['user-agent'] = 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36';
+  }
 
   let body
   if (method !== 'GET' && method !== 'HEAD') {
@@ -533,7 +554,9 @@ server.on('upgrade', (req, clientSocket, head) => {
       
       proxyHeaders['host'] = targetUrl.hostname;
       proxyHeaders['origin'] = targetUrl.protocol.replace('ws', 'http') + '//' + targetUrl.hostname;
-      proxyHeaders['user-agent'] = 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36';
+      if (!proxyHeaders['user-agent']) {
+        proxyHeaders['user-agent'] = 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36';
+      }
       
       const options = {
         port: targetUrl.port || (targetUrl.protocol === 'wss:' ? 443 : 80),