env changes

src/index.ts

@@ -9,8 +9,12 @@ import { NS_runtime } from "../../../../packages/lib/env.runtime";
 
 await NS_runtime.set_env_var_db();
 
-const APP_ENV = process.env.APP_ENV;
-const APP_ORIGIN = process.env.APP_ORIGIN;
+const APP_ENV = () => NS_runtime.ENV_VAR_DB?.APP_ENV || process?.env?.APP_ENV;
+
+const APP_ORIGIN = () => NS_runtime.ENV_VAR_DB?.APP_ORIGIN || process?.env?.APP_ORIGIN;
+
+const REPO_ORIGIN = () => NS_runtime.ENV_VAR_DB?.REPO_ORIGIN || process.env.REPO_ORIGIN;
+
 const PORT = process.env.PORT;
 
 const app = new Elysia()

src/sub-router/proxima.ts

@@ -13,11 +13,17 @@ import { NS_error } from "../../../../../packages/lib/helpers/client/error";
 import { NS_proxy } from "../../../../../packages/lib/helpers/client/proxy";
 import { NS_html_proxima } from "../../../../../packages/lib/helpers/server/proxima/html";
 import ky from "ky";
+import { NS_runtime } from "../../../../../packages/lib/env.runtime";
 
-const APP_ENV = process.env.APP_ENV;
 const X_OFFLINE = process.env.X_OFFLINE;
-const APP_ORIGIN = process.env.APP_ORIGIN;
-const REPO_ORIGIN = process.env.REPO_ORIGIN;
+
+const APP_ENV = () => NS_runtime.ENV_VAR_DB?.APP_ENV || process?.env?.APP_ENV;
+
+const APP_ORIGIN = () =>
+  NS_runtime.ENV_VAR_DB?.APP_ORIGIN || process?.env?.APP_ORIGIN;
+
+const REPO_ORIGIN = () =>
+  NS_runtime.ENV_VAR_DB?.REPO_ORIGIN || process.env.REPO_ORIGIN;
 
 const sub_router = new Hono().basePath("/proxima");
 
@@ -34,7 +40,7 @@ sub_router.get(
     const query = ctx.req.query();
 
     const REQ0 = new URL(ctx.req.url);
-    const REQ_ORIGIN = APP_ORIGIN || REQ0.origin;
+    const REQ_ORIGIN = APP_ORIGIN() || REQ0.origin;
     const REQ_headers = ctx.req.raw.headers;
 
     const { proxima_encoded } = params;
@@ -94,9 +100,9 @@ sub_router.get(
     const fallback_env = "cloudflare"; // edgeone
 
     const fallback_proxy = await (async () => {
-      if (!fallback_env || REPO_ORIGIN === REQ_ORIGIN) return;
+      if (!fallback_env || REPO_ORIGIN() === REQ_ORIGIN) return;
 
-      const _ = new URL("/proxima/multiverse/next", REPO_ORIGIN);
+      const _ = new URL("/proxima/multiverse/next", REPO_ORIGIN());
       _.searchParams.set("service_env", fallback_env);
 
       const [E_, R_] = await NS_promise.F_catch_promise({
@@ -217,8 +223,8 @@ sub_router.get(
     if (query?.ops === "raw2") {
       const data = {
         app: "hono",
-        REPO_ORIGIN,
-        APP_ORIGIN,
+        REPO_ORIGIN: REPO_ORIGIN(),
+        APP_ORIGIN: APP_ORIGIN(),
         fallback_env,
         fallback_proxy,
         status: upstream.status,
@@ -355,7 +361,7 @@ sub_router.get(
       m3u8_content = R_ || m3u8_content || "";
 
       if (query.ops === "get-master-resolutions") {
-        const _ = NS_playback_helper.F_extract_resolutions_from_M3U8({
+        const _: any = NS_playback_helper.F_extract_resolutions_from_M3U8({
           m3u8Content: m3u8_content
         });
 
@@ -372,7 +378,7 @@ sub_router.get(
           content: m3u8_content
         });
       }
-            
+
       ctx.status(upstream.status as any);
 
       for (const key in res_headers_obj) {