Update deno.ts

deno.ts

@@ -4,15 +4,6 @@ async function handle(request, connInfo) {
         "Access-Control-Allow-Origin": "*",
       },
     };
-  // 增强的 CORS 头部
-    // const corsHeaders = {
-    //   "Access-Control-Allow-Origin": "*",
-    //   "Access-Control-Allow-Methods": "GET, POST, PUT, DELETE, OPTIONS, HEAD, PATCH",
-    //   "Access-Control-Allow-Headers": "*",
-    //   "Access-Control-Expose-Headers": "*",
-    //   "Access-Control-Max-Age": "86400",
-    //   "Access-Control-Allow-Credentials": "false",
-    // };
     const corsOptionsHeaders = {
       "Access-Control-Allow-Origin": "*",
       "Access-Control-Allow-Methods": "GET, HEAD, POST, OPTIONS",
@@ -27,14 +18,13 @@ async function handle(request, connInfo) {
       let proxy = "";
       let proxy_enc = "";
       let enc = "";
-      let ip = "";
+      let ip = "no";
       let redirect = request.method === "POST" ? "manual" : "follow";
       let get_cookie = false;
       let cookie_plus = false;
-      let get_redirect = false;
       let remove_compression = false;
       let params = [];
-      let cdn_info = "cdn_pDvQc7ZT";
+      let cdn_info = "cdn_c8Bc9aMo";
       let user_agent = "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/132.0.0.0 Safari/537.36";
 
       if (api === "headers") {
@@ -44,7 +34,7 @@ async function handle(request, connInfo) {
           body += "connInfo" + " = " + JSON.stringify(connInfo.remoteAddr) + "\n";
         }
         body += "request_url" + " = " + request.url + "\n";
-        body += "worker_version = 1.12\n";
+        body += "apn_version = 1.11\n";
         return new Response(body, corsHeaders);
       }
 
@@ -86,11 +76,6 @@ async function handle(request, connInfo) {
           remove_compression = true;
           api_pos += 12;
           api = api.substring(12);
-        } else if (api.startsWith("get_redirect/")) {
-          get_redirect = true;
-          redirect = "manual";
-          api_pos += 13;
-          api = api.substring(13);
         } else if (api.startsWith("param?") || api.startsWith("param/")) {
           api_pos += 6;
           api = api.substring(6);
@@ -162,6 +147,22 @@ async function handle(request, connInfo) {
       const apiUrl = new URL(api);
       let apiBase = apiUrl.href.substring(0, apiUrl.href.lastIndexOf("/") + 1);
 
+      let clientUserAgent = request.headers.get("User-Agent") || '';
+      let clientOrigin = request.headers.get("Origin") || '';
+      if(
+            (/\blampishe\b|\bprisma_client\b/).test(clientUserAgent) ||
+            clientOrigin.endsWith("lampishe.cc") ||
+            clientOrigin.endsWith("prisma.ws") ||
+            clientOrigin.endsWith("bylampa.online")
+      ) {
+        let error = "Malformed URL";
+        return new Response(error + ": " + api, {
+          ...corsHeaders,
+          status: 404,
+          statusText: error,
+        });
+      }
+
       // Rewrite request to point to API URL. This also makes the request mutable
       // so you can add the correct Origin header to make the API server think
       // that this request is not cross-site.
@@ -237,6 +238,10 @@ async function handle(request, connInfo) {
       if (apiUrl.hostname === "kinoplay.site" || apiUrl.hostname === "kinoplay1.site" || apiUrl.hostname === "kinoplay2.site") {
         request.headers.set("Cookie", "invite=a246a3f46c82fe439a45c3dbbbb24ad5");
       }
+      if (apiUrl.pathname.endsWith(".m3u8") || apiUrl.pathname.endsWith(".m3u") || apiUrl.pathname.endsWith(".M3U8") || apiUrl.pathname.endsWith(".M3U") || apiUrl.pathname.endsWith(".mpd") || apiUrl.pathname.endsWith(".MPD")) {
+        request.headers.delete("Range");
+        remove_compression = true;
+      }
       if (remove_compression) {
         let encoding = (request.headers.get("Accept-Encoding") || "");
         if (encoding.includes("zstd") || encoding.includes("deflate")) {
@@ -256,7 +261,6 @@ async function handle(request, connInfo) {
       let response = await fetch(request, {
         redirect: redirect,
       });
-      let currentUrl = response.url;
 
       // Recreate the response so you can modify the headers
       response = new Response(response.body, response);
@@ -267,21 +271,11 @@ async function handle(request, connInfo) {
       // Append to/Add Vary header so browser will cache response correctly
       response.headers.append("Vary", "Origin");
 
-      if (response.status >= 200 && response.status < (get_redirect ? 400 : 300)) {
+      if (response.status >= 200 && response.status < 300) {
         let ctype = (response.headers.get("Content-Type") || "").split(";")[0].toLowerCase();
-        if (get_cookie || cookie_plus || get_redirect) {
+        if (get_cookie || cookie_plus) {
           let json = {};
-          json.currentUrl = currentUrl;
-          if (get_redirect) {
-            let target = response.headers.get("Location");
-            if (target) {
-                json.redirectUrl = fixLink(target, apiUrl, apiBase);
-                response.headers.set("Location", json.redirectUrl);
-            }
-          }
-          if (get_cookie || cookie_plus) {
-            json.cookie = response.headers.getSetCookie();
-          }
+          json.cookie = response.headers.getSetCookie();
           if (cookie_plus) {
             let headers = {};
             for (let key of response.headers.keys()) {
@@ -304,6 +298,20 @@ async function handle(request, connInfo) {
             },
           });
         }
+        if (["application/x-mpegurl", "application/vnd.apple.mpegurl"].indexOf(ctype) !== -1) {
+          let body = edit_m3u8(await response.text(), apiUrl, apiBase, proxy, proxy_enc, enc);
+          response.headers.delete("Content-Length");
+          response.headers.delete("Content-Range");
+          response.headers.set("Accept-Ranges", "none");
+          return new Response(body, response);
+        }
+        if (["application/dash+xml"].indexOf(ctype) !== -1) {
+          let body = edit_mpd(await response.text(), apiUrl, apiBase, proxy, proxy_enc, enc);
+          response.headers.delete("Content-Length");
+          response.headers.delete("Content-Range");
+          response.headers.set("Accept-Ranges", "none");
+          return new Response(body, response);
+        }
       }
 
       // Fix redirect URL
@@ -359,6 +367,66 @@ async function handle(request, connInfo) {
       return link;
     }
 
+    function edit_m3u8(m3u8, url, base, proxy, proxy_enc, enc) {
+      try {
+        return m3u8.split("\n").map(org_line => {
+          let line = org_line.trim();
+          if (line.charAt(0) === "#") {
+            return org_line.replace(/\bURI="([^"]*)"/g, (str, link) => {
+              link = link.trim();
+              if (link) {
+                return 'URI="' + proxyLink(fixLink(link, url, base), proxy, proxy_enc, enc) + '"';
+              }
+              return str;
+            });
+          } else if(line) {
+            return proxyLink(fixLink(line, url, base), proxy, proxy_enc, enc);
+          }
+          return org_line;
+        }).join("\n");
+      } catch (err) {
+        return m3u8;
+      }
+    }
+
+    function unescapeXml(str) {
+      return str.replace(/&lt;|&gt;|&amp;|&apos;|&quot;/g, function (c) {
+        switch (c) {
+          case "&lt;": return "<";
+          case "&gt;": return ">";
+          case "&amp;": return "&";
+          case "&apos;": return "'";
+          case "&quot;": return '"';
+        }
+      });
+    }
+
+    function escapeXml(str) {
+      return str.replace(/[<>&'"]/g, function (c) {
+        switch (c) {
+          case "<": return "&lt;";
+          case ">": return "&gt;";
+          case "&": return "&amp;";
+          case "'": return "&apos;";
+          case '"': return "&quot;";
+        }
+      });
+    }
+
+    function edit_mpd(mpd, url, base, proxy, proxy_enc, enc) {
+      try {
+        return mpd.replace(/<BaseURL>([^<]*)/g, (str, link) => {
+          link = link.trim();
+          if (link) {
+            return "<BaseURL>" + escapeXml(proxyLink(fixLink(unescapeXml(link), url, base), proxy, proxy_enc, (enc === "enc2" ? "enc1" : enc)));
+          }
+          return str;
+        });
+      } catch (err) {
+        return mpd;
+      }
+    }
+
     async function handleOptions(request, connInfo) {
       if (
         request.headers.get("Origin") !== null &&