feat: 更新版本至 0.0.64，添加 getUrl 方法以简化 URL 处理

bun.config.ts

@@ -30,4 +30,12 @@ await buildWithBun({
   meta: import.meta,
   target: 'node',
   dts: true,
+})
+
+await buildWithBun({
+  naming: 'query-login-node',
+  entry: 'query/query-login/query-login-node.ts',
+  meta: import.meta,
+  target: 'node',
+  dts: true,
 })

bun.lock

@@ -0,0 +1,143 @@
+{
+  "lockfileVersion": 1,
+  "configVersion": 1,
+  "workspaces": {
+    "": {
+      "name": "@kevisual/api",
+      "dependencies": {
+        "@kevisual/context": "^0.0.8",
+        "@kevisual/js-filter": "^0.0.5",
+        "@kevisual/load": "^0.0.6",
+        "@paralleldrive/cuid2": "^3.3.0",
+        "es-toolkit": "^1.44.0",
+        "eventemitter3": "^5.0.4",
+        "fuse.js": "^7.1.0",
+        "nanoid": "^5.1.6",
+        "path-browserify-esm": "^1.0.6",
+        "sonner": "^2.0.7",
+        "spark-md5": "^3.0.2",
+        "zustand": "^5.0.11",
+      },
+      "devDependencies": {
+        "@kevisual/cache": "^0.0.5",
+        "@kevisual/code-builder": "^0.0.6",
+        "@kevisual/query": "^0.0.49",
+        "@kevisual/remote-app": "^0.0.4",
+        "@kevisual/router": "^0.0.83",
+        "@kevisual/types": "^0.0.12",
+        "@kevisual/use-config": "^1.0.30",
+        "@types/bun": "^1.3.9",
+        "@types/node": "^25.3.0",
+        "@types/spark-md5": "^3.0.5",
+        "dotenv": "^17.3.1",
+        "fast-glob": "^3.3.3",
+        "ws": "npm:@kevisual/ws",
+      },
+    },
+  },
+  "packages": {
+    "@kevisual/cache": ["@kevisual/cache@0.0.5", "", { "dependencies": { "idb-keyval": "^6.2.2", "lru-cache": "^11.2.4", "nanoid": "^5.1.6" } }, "sha512-fgtUYGUUq/DY0KFV4CkWszNqvQUaA8XvMTUjoR9ZXRpau5IIDolD/Wen2TFsZ7G3Rfy+lef5dnaiZVDkZwdVKg=="],
+
+    "@kevisual/code-builder": ["@kevisual/code-builder@0.0.6", "", { "bin": { "code-builder": "bin/code.js", "builder": "bin/code.js" } }, "sha512-0aqATB31/yw4k4s5/xKnfr4DKbUnx8e3Z3BmKbiXTrc+CqWiWTdlGe9bKI9dZ2Df+xNp6g11W4xM2NICNyyCCw=="],
+
+    "@kevisual/context": ["@kevisual/context@0.0.8", "", {}, "sha512-DTJpyHI34NE76B7g6f+QlIqiCCyqI2qkBMQE736dzeRDGxOjnbe2iQY9W+Rt2PE6kmymM3qyOmSfNovyWyWrkA=="],
+
+    "@kevisual/js-filter": ["@kevisual/js-filter@0.0.5", "", {}, "sha512-+S+Sf3K/aP6XtZI2s7TgKOr35UuvUvtpJ9YDW30a+mY0/N8gRuzyKhieBzQN7Ykayzz70uoMavBXut2rUlLgzw=="],
+
+    "@kevisual/load": ["@kevisual/load@0.0.6", "", { "dependencies": { "eventemitter3": "^5.0.1" } }, "sha512-+3YTFehRcZ1haGel5DKYMUwmi5i6f2psyaPZlfkKU/cOXgkpwoG9/BEqPCnPjicKqqnksEpixVRkyHJ+5bjLVA=="],
+
+    "@kevisual/query": ["@kevisual/query@0.0.49", "", {}, "sha512-GrWW+QlBO5lkiqvb7PjOstNtpTQVSR74EHHWjm7YoL9UdT1wuPQXGUApZHmMBSh3NIWCf0AL2G1hPWZMC7YeOQ=="],
+
+    "@kevisual/remote-app": ["@kevisual/remote-app@0.0.4", "", {}, "sha512-2yIlWY98pLCcxG+DJsqXXkd5YYEgymuOsyElH+31AoEPb7mlNREnYS81zN0KM9nvdSmU2G51vV4UVirJlYBZCQ=="],
+
+    "@kevisual/router": ["@kevisual/router@0.0.83", "", { "dependencies": { "es-toolkit": "^1.44.0" } }, "sha512-CVazzM1rXVyvU7QcMQr0/EuqacRNEGalThDDLGQcvKEVHyduJ9yWddn6kezgWFCpNlPKhzSCKkIFuZVixNVxDQ=="],
+
+    "@kevisual/types": ["@kevisual/types@0.0.12", "", {}, "sha512-zJXH2dosir3jVrQ6QG4i0+iLQeT9gJ3H+cKXs8ReWboxBSYzUZO78XssVeVrFPsJ33iaAqo4q3DWbSS1dWGn7Q=="],
+
+    "@kevisual/use-config": ["@kevisual/use-config@1.0.30", "", { "dependencies": { "@kevisual/load": "^0.0.6" }, "peerDependencies": { "dotenv": "^17" } }, "sha512-kPdna0FW/X7D600aMdiZ5UTjbCo6d8d4jjauSc8RMmBwUU6WliFDSPUNKVpzm2BsDX5Nth1IXFPYMqH+wxqAmw=="],
+
+    "@noble/hashes": ["@noble/hashes@2.0.1", "", {}, "sha512-XlOlEbQcE9fmuXxrVTXCTlG2nlRXa9Rj3rr5Ue/+tX+nmkgbX720YHh0VR3hBF9xDvwnb8D2shVGOwNx+ulArw=="],
+
+    "@nodelib/fs.scandir": ["@nodelib/fs.scandir@2.1.5", "", { "dependencies": { "@nodelib/fs.stat": "2.0.5", "run-parallel": "^1.1.9" } }, "sha512-vq24Bq3ym5HEQm2NKCr3yXDwjc7vTsEThRDnkp2DK9p1uqLR+DHurm/NOTo0KG7HYHU7eppKZj3MyqYuMBf62g=="],
+
+    "@nodelib/fs.stat": ["@nodelib/fs.stat@2.0.5", "", {}, "sha512-RkhPPp2zrqDAQA/2jNhnztcPAlv64XdhIp7a7454A5ovI7Bukxgt7MX7udwAu3zg1DcpPU0rz3VV1SeaqvY4+A=="],
+
+    "@nodelib/fs.walk": ["@nodelib/fs.walk@1.2.8", "", { "dependencies": { "@nodelib/fs.scandir": "2.1.5", "fastq": "^1.6.0" } }, "sha512-oGB+UxlgWcgQkgwo8GcEGwemoTFt3FIO9ababBmaGwXIoBKZ+GTy0pP185beGg7Llih/NSHSV2XAs1lnznocSg=="],
+
+    "@paralleldrive/cuid2": ["@paralleldrive/cuid2@3.3.0", "", { "dependencies": { "@noble/hashes": "^2.0.1", "bignumber.js": "^9.3.1", "error-causes": "^3.0.2" }, "bin": { "cuid2": "bin/cuid2.js" } }, "sha512-OqiFvSOF0dBSesELYY2CAMa4YINvlLpvKOz/rv6NeZEqiyttlHgv98Juwv4Ch+GrEV7IZ8jfI2VcEoYUjXXCjw=="],
+
+    "@types/bun": ["@types/bun@1.3.9", "", { "dependencies": { "bun-types": "1.3.9" } }, "sha512-KQ571yULOdWJiMH+RIWIOZ7B2RXQGpL1YQrBtLIV3FqDcCu6FsbFUBwhdKUlCKUpS3PJDsHlJ1QKlpxoVR+xtw=="],
+
+    "@types/node": ["@types/node@25.3.0", "", { "dependencies": { "undici-types": "~7.18.0" } }, "sha512-4K3bqJpXpqfg2XKGK9bpDTc6xO/xoUP/RBWS7AtRMug6zZFaRekiLzjVtAoZMquxoAbzBvy5nxQ7veS5eYzf8A=="],
+
+    "@types/spark-md5": ["@types/spark-md5@3.0.5", "", {}, "sha512-lWf05dnD42DLVKQJZrDHtWFidcLrHuip01CtnC2/S6AMhX4t9ZlEUj4iuRlAnts0PQk7KESOqKxeGE/b6sIPGg=="],
+
+    "bignumber.js": ["bignumber.js@9.3.1", "", {}, "sha512-Ko0uX15oIUS7wJ3Rb30Fs6SkVbLmPBAKdlm7q9+ak9bbIeFf0MwuBsQV6z7+X768/cHsfg+WlysDWJcmthjsjQ=="],
+
+    "braces": ["braces@3.0.3", "", { "dependencies": { "fill-range": "^7.1.1" } }, "sha512-yQbXgO/OSZVD2IsiLlro+7Hf6Q18EJrKSEsdoMzKePKXct3gvD8oLcOQdIzGupr5Fj+EDe8gO/lxc1BzfMpxvA=="],
+
+    "bun-types": ["bun-types@1.3.9", "", { "dependencies": { "@types/node": "*" } }, "sha512-+UBWWOakIP4Tswh0Bt0QD0alpTY8cb5hvgiYeWCMet9YukHbzuruIEeXC2D7nMJPB12kbh8C7XJykSexEqGKJg=="],
+
+    "dotenv": ["dotenv@17.3.1", "", {}, "sha512-IO8C/dzEb6O3F9/twg6ZLXz164a2fhTnEWb95H23Dm4OuN+92NmEAlTrupP9VW6Jm3sO26tQlqyvyi4CsnY9GA=="],
+
+    "error-causes": ["error-causes@3.0.2", "", {}, "sha512-i0B8zq1dHL6mM85FGoxaJnVtx6LD5nL2v0hlpGdntg5FOSyzQ46c9lmz5qx0xRS2+PWHGOHcYxGIBC5Le2dRMw=="],
+
+    "es-toolkit": ["es-toolkit@1.44.0", "", {}, "sha512-6penXeZalaV88MM3cGkFZZfOoLGWshWWfdy0tWw/RlVVyhvMaWSBTOvXNeiW3e5FwdS5ePW0LGEu17zT139ktg=="],
+
+    "eventemitter3": ["eventemitter3@5.0.4", "", {}, "sha512-mlsTRyGaPBjPedk6Bvw+aqbsXDtoAyAzm5MO7JgU+yVRyMQ5O8bD4Kcci7BS85f93veegeCPkL8R4GLClnjLFw=="],
+
+    "fast-glob": ["fast-glob@3.3.3", "", { "dependencies": { "@nodelib/fs.stat": "^2.0.2", "@nodelib/fs.walk": "^1.2.3", "glob-parent": "^5.1.2", "merge2": "^1.3.0", "micromatch": "^4.0.8" } }, "sha512-7MptL8U0cqcFdzIzwOTHoilX9x5BrNqye7Z/LuC7kCMRio1EMSyqRK3BEAUD7sXRq4iT4AzTVuZdhgQ2TCvYLg=="],
+
+    "fastq": ["fastq@1.20.1", "", { "dependencies": { "reusify": "^1.0.4" } }, "sha512-GGToxJ/w1x32s/D2EKND7kTil4n8OVk/9mycTc4VDza13lOvpUZTGX3mFSCtV9ksdGBVzvsyAVLM6mHFThxXxw=="],
+
+    "fill-range": ["fill-range@7.1.1", "", { "dependencies": { "to-regex-range": "^5.0.1" } }, "sha512-YsGpe3WHLK8ZYi4tWDg2Jy3ebRz2rXowDxnld4bkQB00cc/1Zw9AWnC0i9ztDJitivtQvaI9KaLyKrc+hBW0yg=="],
+
+    "fuse.js": ["fuse.js@7.1.0", "", {}, "sha512-trLf4SzuuUxfusZADLINj+dE8clK1frKdmqiJNb1Es75fmI5oY6X2mxLVUciLLjxqw/xr72Dhy+lER6dGd02FQ=="],
+
+    "glob-parent": ["glob-parent@5.1.2", "", { "dependencies": { "is-glob": "^4.0.1" } }, "sha512-AOIgSQCepiJYwP3ARnGx+5VnTu2HBYdzbGP45eLw1vr3zB3vZLeyed1sC9hnbcOc9/SrMyM5RPQrkGz4aS9Zow=="],
+
+    "idb-keyval": ["idb-keyval@6.2.2", "", {}, "sha512-yjD9nARJ/jb1g+CvD0tlhUHOrJ9Sy0P8T9MF3YaLlHnSRpwPfpTX0XIvpmw3gAJUmEu3FiICLBDPXVwyEvrleg=="],
+
+    "is-extglob": ["is-extglob@2.1.1", "", {}, "sha512-SbKbANkN603Vi4jEZv49LeVJMn4yGwsbzZworEoyEiutsN3nJYdbO36zfhGJ6QEDpOZIFkDtnq5JRxmvl3jsoQ=="],
+
+    "is-glob": ["is-glob@4.0.3", "", { "dependencies": { "is-extglob": "^2.1.1" } }, "sha512-xelSayHH36ZgE7ZWhli7pW34hNbNl8Ojv5KVmkJD4hBdD3th8Tfk9vYasLM+mXWOZhFkgZfxhLSnrwRr4elSSg=="],
+
+    "is-number": ["is-number@7.0.0", "", {}, "sha512-41Cifkg6e8TylSpdtTpeLVMqvSBEVzTttHvERD741+pnZ8ANv0004MRL43QKPDlK9cGvNp6NZWZUBlbGXYxxng=="],
+
+    "lru-cache": ["lru-cache@11.2.6", "", {}, "sha512-ESL2CrkS/2wTPfuend7Zhkzo2u0daGJ/A2VucJOgQ/C48S/zB8MMeMHSGKYpXhIjbPxfuezITkaBH1wqv00DDQ=="],
+
+    "merge2": ["merge2@1.4.1", "", {}, "sha512-8q7VEgMJW4J8tcfVPy8g09NcQwZdbwFEqhe/WZkoIzjn/3TGDwtOCYtXGxA3O8tPzpczCCDgv+P2P5y00ZJOOg=="],
+
+    "micromatch": ["micromatch@4.0.8", "", { "dependencies": { "braces": "^3.0.3", "picomatch": "^2.3.1" } }, "sha512-PXwfBhYu0hBCPw8Dn0E+WDYb7af3dSLVWKi3HGv84IdF4TyFoC0ysxFd0Goxw7nSv4T/PzEJQxsYsEiFCKo2BA=="],
+
+    "nanoid": ["nanoid@5.1.6", "", { "bin": { "nanoid": "bin/nanoid.js" } }, "sha512-c7+7RQ+dMB5dPwwCp4ee1/iV/q2P6aK1mTZcfr1BTuVlyW9hJYiMPybJCcnBlQtuSmTIWNeazm/zqNoZSSElBg=="],
+
+    "path-browserify-esm": ["path-browserify-esm@1.0.6", "", {}, "sha512-9nUwYvvu/yq1PYrUyYCihNWmpzacaRYF6gGbjLWErrZ4MRDWyfPN7RpE8E7tsw8eqBU/rr7mcoTXbS+Vih8uUA=="],
+
+    "picomatch": ["picomatch@2.3.1", "", {}, "sha512-JU3teHTNjmE2VCGFzuY8EXzCDVwEqB2a8fsIvwaStHhAWJEeVd1o1QD80CU6+ZdEXXSLbSsuLwJjkCBWqRQUVA=="],
+
+    "queue-microtask": ["queue-microtask@1.2.3", "", {}, "sha512-NuaNSa6flKT5JaSYQzJok04JzTL1CA6aGhv5rfLW3PgqA+M2ChpZQnAC8h8i4ZFkBS8X5RqkDBHA7r4hej3K9A=="],
+
+    "react": ["react@19.2.4", "", {}, "sha512-9nfp2hYpCwOjAN+8TZFGhtWEwgvWHXqESH8qT89AT/lWklpLON22Lc8pEtnpsZz7VmawabSU0gCjnj8aC0euHQ=="],
+
+    "react-dom": ["react-dom@19.2.4", "", { "dependencies": { "scheduler": "^0.27.0" }, "peerDependencies": { "react": "^19.2.4" } }, "sha512-AXJdLo8kgMbimY95O2aKQqsz2iWi9jMgKJhRBAxECE4IFxfcazB2LmzloIoibJI3C12IlY20+KFaLv+71bUJeQ=="],
+
+    "reusify": ["reusify@1.1.0", "", {}, "sha512-g6QUff04oZpHs0eG5p83rFLhHeV00ug/Yf9nZM6fLeUrPguBTkTQOdpAWWspMh55TZfVQDPaN3NQJfbVRAxdIw=="],
+
+    "run-parallel": ["run-parallel@1.2.0", "", { "dependencies": { "queue-microtask": "^1.2.2" } }, "sha512-5l4VyZR86LZ/lDxZTR6jqL8AFE2S0IFLMP26AbjsLVADxHdhB/c0GUsH+y39UfCi3dzz8OlQuPmnaJOMoDHQBA=="],
+
+    "scheduler": ["scheduler@0.27.0", "", {}, "sha512-eNv+WrVbKu1f3vbYJT/xtiF5syA5HPIMtf9IgY/nKg0sWqzAUEvqY/xm7OcZc/qafLx/iO9FgOmeSAp4v5ti/Q=="],
+
+    "sonner": ["sonner@2.0.7", "", { "peerDependencies": { "react": "^18.0.0 || ^19.0.0 || ^19.0.0-rc", "react-dom": "^18.0.0 || ^19.0.0 || ^19.0.0-rc" } }, "sha512-W6ZN4p58k8aDKA4XPcx2hpIQXBRAgyiWVkYhT7CvK6D3iAu7xjvVyhQHg2/iaKJZ1XVJ4r7XuwGL+WGEK37i9w=="],
+
+    "spark-md5": ["spark-md5@3.0.2", "", {}, "sha512-wcFzz9cDfbuqe0FZzfi2or1sgyIrsDwmPwfZC4hiNidPdPINjeUwNfv5kldczoEAcjl9Y1L3SM7Uz2PUEQzxQw=="],
+
+    "to-regex-range": ["to-regex-range@5.0.1", "", { "dependencies": { "is-number": "^7.0.0" } }, "sha512-65P7iz6X5yEr1cwcgvQxbbIw7Uk3gOy5dIdtZ4rDveLqhrdJP+Li/Hx6tyK0NEb+2GCyneCMJiGqrADCSNk8sQ=="],
+
+    "undici-types": ["undici-types@7.18.2", "", {}, "sha512-AsuCzffGHJybSaRrmr5eHr81mwJU3kjw6M+uprWvCXiNeN9SOGwQ3Jn8jb8m3Z6izVgknn1R0FTCEAP2QrLY/w=="],
+
+    "ws": ["@kevisual/ws@8.19.0", "", {}, "sha512-jLsL80wBBKkrJZrfk3SQpJ9JA/zREdlUROj7eCkmzqduAWKSI0wVcXuCKf+mLFCHB0Q0Tkh2rgzjSlurt3JQgw=="],
+
+    "zustand": ["zustand@5.0.11", "", { "peerDependencies": { "@types/react": ">=18.0.0", "immer": ">=9.0.6", "react": ">=18.0.0", "use-sync-external-store": ">=1.2.0" }, "optionalPeers": ["@types/react", "immer", "react", "use-sync-external-store"] }, "sha512-fdZY+dk7zn/vbWNCYmzZULHRrss0jx5pPFiOuMZ/5HJN6Yv3u+1Wswy/4MpZEkEGhtNH+pwxZB8OKgUBPzYAGg=="],
+  }
+}

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@kevisual/api",
-  "version": "0.0.52",
+  "version": "0.0.64",
   "description": "",
   "main": "mod.ts",
   "scripts": {
@@ -18,29 +18,29 @@
   "keywords": [],
   "author": "abearxiong <xiongxiao@xiongxiao.me> (https://www.xiongxiao.me)",
   "license": "MIT",
-  "packageManager": "pnpm@10.30.0",
+  "packageManager": "pnpm@10.32.1",
   "type": "module",
   "devDependencies": {
     "@kevisual/cache": "^0.0.5",
     "@kevisual/code-builder": "^0.0.6",
-    "@kevisual/query": "^0.0.47",
+    "@kevisual/query": "^0.0.53",
-    "@kevisual/remote-app": "^0.0.4",
+    "@kevisual/remote-app": "^0.0.6",
-    "@kevisual/router": "^0.0.75",
+    "@kevisual/router": "^0.1.1",
     "@kevisual/types": "^0.0.12",
     "@kevisual/use-config": "^1.0.30",
-    "@types/bun": "^1.3.9",
+    "@types/bun": "^1.3.10",
-    "@types/node": "^25.2.3",
+    "@types/node": "^25.4.0",
     "@types/spark-md5": "^3.0.5",
     "dotenv": "^17.3.1",
     "fast-glob": "^3.3.3",
     "ws": "npm:@kevisual/ws"
   },
   "dependencies": {
-    "@kevisual/context": "^0.0.6",
+    "@kevisual/context": "^0.0.8",
-    "@kevisual/js-filter": "^0.0.5",
+    "@kevisual/js-filter": "^0.0.6",
     "@kevisual/load": "^0.0.6",
     "@paralleldrive/cuid2": "^3.3.0",
-    "es-toolkit": "^1.44.0",
+    "es-toolkit": "^1.45.1",
     "eventemitter3": "^5.0.4",
     "fuse.js": "^7.1.0",
     "nanoid": "^5.1.6",
@@ -58,6 +58,7 @@
     "./secret": "./query/query-secret/index.ts",
     "./resources": "./query/query-resources/index.ts",
     "./utils-node": "./dist/utils-node.js",
+    "./query-login-node": "./dist/query-login-node.js",
     "./utils": "./dist/utils.js",
     "./query-secret": "./dist/query-secret.js",
     "./query-mark": "./dist/query-mark.js",

pnpm-lock.yaml

@@ -9,11 +9,11 @@ importers:
   .:
     dependencies:
       '@kevisual/context':
+        specifier: ^0.0.8
+        version: 0.0.8
+      '@kevisual/js-filter':
         specifier: ^0.0.6
         version: 0.0.6
-      '@kevisual/js-filter':
-        specifier: ^0.0.5
-        version: 0.0.5
       '@kevisual/load':
         specifier: ^0.0.6
         version: 0.0.6
@@ -21,8 +21,8 @@ importers:
         specifier: ^3.3.0
         version: 3.3.0
       es-toolkit:
-        specifier: ^1.44.0
+        specifier: ^1.45.1
-        version: 1.44.0
+        version: 1.45.1
       eventemitter3:
         specifier: ^5.0.4
         version: 5.0.4
@@ -52,14 +52,14 @@ importers:
         specifier: ^0.0.6
         version: 0.0.6
       '@kevisual/query':
-        specifier: ^0.0.47
+        specifier: ^0.0.53
-        version: 0.0.47
+        version: 0.0.53
       '@kevisual/remote-app':
-        specifier: ^0.0.4
+        specifier: ^0.0.6
-        version: 0.0.4
+        version: 0.0.6
       '@kevisual/router':
-        specifier: ^0.0.75
+        specifier: ^0.1.1
-        version: 0.0.75
+        version: 0.1.1
       '@kevisual/types':
         specifier: ^0.0.12
         version: 0.0.12
@@ -67,11 +67,11 @@ importers:
         specifier: ^1.0.30
         version: 1.0.30(dotenv@17.3.1)
       '@types/bun':
-        specifier: ^1.3.9
+        specifier: ^1.3.10
-        version: 1.3.9
+        version: 1.3.10
       '@types/node':
-        specifier: ^25.2.3
+        specifier: ^25.4.0
-        version: 25.2.3
+        version: 25.4.0
       '@types/spark-md5':
         specifier: ^3.0.5
         version: 3.0.5
@@ -114,11 +114,11 @@ packages:
     resolution: {integrity: sha512-0aqATB31/yw4k4s5/xKnfr4DKbUnx8e3Z3BmKbiXTrc+CqWiWTdlGe9bKI9dZ2Df+xNp6g11W4xM2NICNyyCCw==}
     hasBin: true
 
-  '@kevisual/context@0.0.6':
+  '@kevisual/context@0.0.8':
-    resolution: {integrity: sha512-w7HBOuO3JH37n6xT6W3FD7ykqHTwtyxOQzTzfEcKDCbsvGB1wVreSxFm2bvoFnnFLuxT/5QMpKlnPrwvmcTGnw==}
+    resolution: {integrity: sha512-DTJpyHI34NE76B7g6f+QlIqiCCyqI2qkBMQE736dzeRDGxOjnbe2iQY9W+Rt2PE6kmymM3qyOmSfNovyWyWrkA==}
 
-  '@kevisual/js-filter@0.0.5':
+  '@kevisual/js-filter@0.0.6':
-    resolution: {integrity: sha512-+S+Sf3K/aP6XtZI2s7TgKOr35UuvUvtpJ9YDW30a+mY0/N8gRuzyKhieBzQN7Ykayzz70uoMavBXut2rUlLgzw==}
+    resolution: {integrity: sha512-FcbOsmS1inhwrfgXMM/XLFTGTHUxBCss32JEMYdEFWQDYCar5rN8cxD1W8FuKDTVRlpA+zBpQ/BE6XT4UaeljA==}
 
   '@kevisual/load@0.0.6':
     resolution: {integrity: sha512-+3YTFehRcZ1haGel5DKYMUwmi5i6f2psyaPZlfkKU/cOXgkpwoG9/BEqPCnPjicKqqnksEpixVRkyHJ+5bjLVA==}
@@ -126,17 +126,17 @@ packages:
   '@kevisual/query@0.0.18':
     resolution: {integrity: sha512-I2vHTu0I6AyD9PJyr+vxyp9jIJ6rd2EZqLVHTv/+zrVKVc2SS76Tg7aGNkmAFqqLSCB8kLLsmMGtSJU1Qb8VVg==}
 
-  '@kevisual/query@0.0.47':
+  '@kevisual/query@0.0.53':
-    resolution: {integrity: sha512-ZR7WXeDDGUSzBtcGVU3J173sA0hCqrGTw5ybGbdNGlM0VyJV/XQIovCcSoZh1YpnciLRRqJvzXUgTnCkam+M3g==}
+    resolution: {integrity: sha512-PAhpCLBr0emz0lGNlTVHMbJiC5wrtGLbInPddRzgKE35fiyNt+SWSsUWABiD0DeNrLN/OxWyAFobt880Z/e5MQ==}
 
-  '@kevisual/remote-app@0.0.4':
+  '@kevisual/remote-app@0.0.6':
-    resolution: {integrity: sha512-2yIlWY98pLCcxG+DJsqXXkd5YYEgymuOsyElH+31AoEPb7mlNREnYS81zN0KM9nvdSmU2G51vV4UVirJlYBZCQ==}
+    resolution: {integrity: sha512-yc3BKAhtY+SzrvQSebeyR/QR93nPctndNMnW6ne1YPK+Kfpuf8gi7W4zlg18EJh7FEpDuDVHKqVp1klsWjESqQ==}
 
   '@kevisual/router@0.0.20':
     resolution: {integrity: sha512-uSwDYWh+kvAu6i0m0SJVgcLR/CYz7WvIWGz0nSF8Vg6smJuAgI+laHR4ESO8Fbz+Xn8bPHuSwmM//HHLMLx2FA==}
 
-  '@kevisual/router@0.0.75':
+  '@kevisual/router@0.1.1':
-    resolution: {integrity: sha512-WBDRKMjNYTP7ymkUUtiQwWYIcqnc+TGo3rFuRze8ovYV2UN5cQxIkIfsDbgWOdV1/v9b57gtiJvJRqWjCBWKRg==}
+    resolution: {integrity: sha512-+uaJc+Bf/T1mfxyfy9PmwuxJGPOLhVqrmsli2xUPqkkFvizrFIGB1vBTITuo5XP/FnwGqxgbjsitG57AMubm3w==}
 
   '@kevisual/types@0.0.10':
     resolution: {integrity: sha512-Q73uzzjk9UidumnmCvOpgzqDDvQxsblz22bIFuoiioUFJWwaparx8bpd8ArRyFojicYL1YJoFDzDZ9j9NN8grA==}
@@ -173,8 +173,8 @@ packages:
     resolution: {integrity: sha512-OqiFvSOF0dBSesELYY2CAMa4YINvlLpvKOz/rv6NeZEqiyttlHgv98Juwv4Ch+GrEV7IZ8jfI2VcEoYUjXXCjw==}
     hasBin: true
 
-  '@types/bun@1.3.9':
+  '@types/bun@1.3.10':
-    resolution: {integrity: sha512-KQ571yULOdWJiMH+RIWIOZ7B2RXQGpL1YQrBtLIV3FqDcCu6FsbFUBwhdKUlCKUpS3PJDsHlJ1QKlpxoVR+xtw==}
+    resolution: {integrity: sha512-0+rlrUrOrTSskibryHbvQkDOWRJwJZqZlxrUs1u4oOoTln8+WIXBPmAuCF35SWB2z4Zl3E84Nl/D0P7803nigQ==}
 
   '@types/node-fetch@2.6.12':
     resolution: {integrity: sha512-8nneRWKCg3rMtF69nLQJnOYUcbafYeFSjqkw3jCRLsqkWFlHaoQrr5mXmofFGOx3DKn7UfmBMyov8ySvLRVldA==}
@@ -188,8 +188,8 @@ packages:
   '@types/node@22.15.27':
     resolution: {integrity: sha512-5fF+eu5mwihV2BeVtX5vijhdaZOfkQTATrePEaXTcKqI16LhJ7gi2/Vhd9OZM0UojcdmiOCVg5rrax+i1MdoQQ==}
 
-  '@types/node@25.2.3':
+  '@types/node@25.4.0':
-    resolution: {integrity: sha512-m0jEgYlYz+mDJZ2+F4v8D1AyQb+QzsNqRuI7xg1VQX/KlKS0qT9r1Mo16yo5F/MtifXFgaofIFsdFMox2SxIbQ==}
+    resolution: {integrity: sha512-9wLpoeWuBlcbBpOY3XmzSTG3oscB6xjBEEtn+pYXTfhyXhIxC5FsBer2KTopBlvKEiW9l13po9fq+SJY/5lkhw==}
 
   '@types/spark-md5@3.0.5':
     resolution: {integrity: sha512-lWf05dnD42DLVKQJZrDHtWFidcLrHuip01CtnC2/S6AMhX4t9ZlEUj4iuRlAnts0PQk7KESOqKxeGE/b6sIPGg==}
@@ -212,8 +212,8 @@ packages:
     resolution: {integrity: sha512-yQbXgO/OSZVD2IsiLlro+7Hf6Q18EJrKSEsdoMzKePKXct3gvD8oLcOQdIzGupr5Fj+EDe8gO/lxc1BzfMpxvA==}
     engines: {node: '>=8'}
 
-  bun-types@1.3.9:
+  bun-types@1.3.10:
-    resolution: {integrity: sha512-+UBWWOakIP4Tswh0Bt0QD0alpTY8cb5hvgiYeWCMet9YukHbzuruIEeXC2D7nMJPB12kbh8C7XJykSexEqGKJg==}
+    resolution: {integrity: sha512-tcpfCCl6XWo6nCVnpcVrxQ+9AYN1iqMIzgrSKYMB/fjLtV2eyAVEg7AxQJuCq/26R6HpKWykQXuSOq/21RYcbg==}
 
   call-bind-apply-helpers@1.0.2:
     resolution: {integrity: sha512-Sp1ablJ0ivDkSzjcaJdxEunN5/XvksFJ2sMBFfq6x0ryhQV/2b/KwFe21cMpmHtPOSij8K99/wSfoEuTObmuMQ==}
@@ -254,8 +254,8 @@ packages:
     resolution: {integrity: sha512-j6vWzfrGVfyXxge+O0x5sh6cvxAog0a/4Rdd2K36zCMV5eJ+/+tOAngRO8cODMNWbVRdVlmGZQL2YS3yR8bIUA==}
     engines: {node: '>= 0.4'}
 
-  es-toolkit@1.44.0:
+  es-toolkit@1.45.1:
-    resolution: {integrity: sha512-6penXeZalaV88MM3cGkFZZfOoLGWshWWfdy0tWw/RlVVyhvMaWSBTOvXNeiW3e5FwdS5ePW0LGEu17zT139ktg==}
+    resolution: {integrity: sha512-/jhoOj/Fx+A+IIyDNOvO3TItGmlMKhtX8ISAHKE90c4b/k1tqaqEZ+uUqfpU8DMnW5cgNJv606zS55jGvza0Xw==}
 
   event-target-shim@5.0.1:
     resolution: {integrity: sha512-i/2XbnSz/uxRCU6+NdVJgKWDTM427+MqYbkQzD321DuCQJUqOuJKIA0IM2+W2xtYHdKOmZ4dR6fExsd4SXL+WQ==}
@@ -460,8 +460,8 @@ packages:
   undici-types@6.21.0:
     resolution: {integrity: sha512-iwDZqg0QAGrg9Rav5H4n0M64c3mkR59cJ6wQp+7C4nI0gsmExaedaYLNO44eT4AtBBwjbTiGPMlt2Md0T9H9JQ==}
 
-  undici-types@7.16.0:
+  undici-types@7.18.2:
-    resolution: {integrity: sha512-Zz+aZWSj8LE6zoxD+xrjh4VfkIG8Ya6LvYkZqtUQGJPZjYl53ypCaUwWqo7eI0x66KBGeRo+mlBEkMSeSZ38Nw==}
+    resolution: {integrity: sha512-AsuCzffGHJybSaRrmr5eHr81mwJU3kjw6M+uprWvCXiNeN9SOGwQ3Jn8jb8m3Z6izVgknn1R0FTCEAP2QrLY/w==}
 
   web-streams-polyfill@4.0.0-beta.3:
     resolution: {integrity: sha512-QW95TCTaHmsYfHDybGMwO5IJIM93I/6vTRk+daHTWFPhwh+C8Cg7j7XyKrwrj8Ib6vYXe0ocYNrmzY4xAAN6ug==}
@@ -501,9 +501,9 @@ snapshots:
 
   '@kevisual/code-builder@0.0.6': {}
 
-  '@kevisual/context@0.0.6': {}
+  '@kevisual/context@0.0.8': {}
 
-  '@kevisual/js-filter@0.0.5': {}
+  '@kevisual/js-filter@0.0.6': {}
 
   '@kevisual/load@0.0.6':
     dependencies:
@@ -517,18 +517,18 @@ snapshots:
       - ws
       - zod
 
-  '@kevisual/query@0.0.47': {}
+  '@kevisual/query@0.0.53': {}
 
-  '@kevisual/remote-app@0.0.4': {}
+  '@kevisual/remote-app@0.0.6': {}
 
   '@kevisual/router@0.0.20':
     dependencies:
       path-to-regexp: 8.2.0
       selfsigned: 2.4.1
 
-  '@kevisual/router@0.0.75':
+  '@kevisual/router@0.1.1':
     dependencies:
-      es-toolkit: 1.44.0
+      es-toolkit: 1.45.1
 
   '@kevisual/types@0.0.10': {}
 
@@ -561,9 +561,9 @@ snapshots:
       bignumber.js: 9.3.1
       error-causes: 3.0.2
 
-  '@types/bun@1.3.9':
+  '@types/bun@1.3.10':
     dependencies:
-      bun-types: 1.3.9
+      bun-types: 1.3.10
 
   '@types/node-fetch@2.6.12':
     dependencies:
@@ -582,9 +582,9 @@ snapshots:
     dependencies:
       undici-types: 6.21.0
 
-  '@types/node@25.2.3':
+  '@types/node@25.4.0':
     dependencies:
-      undici-types: 7.16.0
+      undici-types: 7.18.2
 
   '@types/spark-md5@3.0.5': {}
 
@@ -604,9 +604,9 @@ snapshots:
     dependencies:
       fill-range: 7.1.1
 
-  bun-types@1.3.9:
+  bun-types@1.3.10:
     dependencies:
-      '@types/node': 25.2.3
+      '@types/node': 25.4.0
 
   call-bind-apply-helpers@1.0.2:
     dependencies:
@@ -644,7 +644,7 @@ snapshots:
       has-tostringtag: 1.0.2
       hasown: 2.0.2
 
-  es-toolkit@1.44.0: {}
+  es-toolkit@1.45.1: {}
 
   event-target-shim@5.0.1: {}
 
@@ -818,7 +818,7 @@ snapshots:
 
   undici-types@6.21.0: {}
 
-  undici-types@7.16.0: {}
+  undici-types@7.18.2: {}
 
   web-streams-polyfill@4.0.0-beta.3: {}
 

query/query-login/browser-cache/cache-store.ts

@@ -0,0 +1,123 @@
+import { createStore, UseStore, get, set, del, clear, keys, values, entries, update, setMany, getMany, delMany } from 'idb-keyval';
+
+/**
+ * 缓存存储选项
+ */
+export type CacheStoreOpts = {
+  /**
+   * 数据库名称
+   */
+  dbName?: string;
+  /**
+   * 存储空间名称
+   */
+  storeName?: string;
+};
+export class BaseCacheStore {
+  store: UseStore;
+  constructor(opts?: CacheStoreOpts) {
+    this.store = createStore(opts?.dbName || 'default-db', opts?.storeName || 'cache-store');
+  }
+  async get(key: string) {
+    return get(key, this.store);
+  }
+  async set(key: string, value: any) {
+    return set(key, value, this.store);
+  }
+  async del(key: string) {
+    return del(key, this.store);
+  }
+  async clear() {
+    return clear(this.store);
+  }
+  async keys() {
+    return keys(this.store);
+  }
+  async values() {
+    return values(this.store);
+  }
+  async entries() {
+    return entries(this.store);
+  }
+  async update(key: string, updater: (value: any) => any) {
+    return update(key, updater, this.store);
+  }
+  async setMany(entries: [string, any][]) {
+    return setMany(entries, this.store);
+  }
+  async getMany(keys: string[]) {
+    return getMany(keys, this.store);
+  }
+  async delMany(keys: string[]) {
+    return delMany(keys, this.store);
+  }
+}
+
+/**
+ * 缓存存储
+ */
+export class CacheStore extends BaseCacheStore {
+  constructor(opts?: CacheStoreOpts) {
+    super(opts);
+  }
+  async getData<T = any>(key: string) {
+    const data = await this.get(key);
+    return data.data as T;
+  }
+  async setData(key: string, data: any) {
+    return this.set(key, data);
+  }
+  /**
+   * 获取缓存数据，并检查是否过期
+   * @param key 缓存键
+   * @returns 缓存数据
+   */
+  async getCheckData<T = any>(key: string) {
+    const data = await this.get(key);
+    if (data.expireTime && data.expireTime < Date.now()) {
+      await super.del(key);
+      return null;
+    }
+    return data.data as T;
+  }
+  /**
+   * 设置缓存数据，并检查是否过期
+   * @param key 缓存键
+   * @param data 缓存数据
+   * @param opts 缓存选项
+   * @returns 缓存数据
+   */
+  async setCheckData(key: string, data: any, opts?: { expireTime?: number; updatedAt?: number }) {
+    const now = Date.now();
+    const expireTime = now + (opts?.expireTime || 1000 * 60 * 60 * 24 * 10);
+    const newData = {
+      data,
+      updatedAt: opts?.updatedAt || Date.now(),
+      expireTime,
+    };
+    await this.set(key, newData);
+    return data;
+  }
+  async checkNew(key: string, data: any): Promise<boolean> {
+    const existing = await this.get(key);
+    if (!existing) {
+      return true;
+    }
+    if (!data?.updatedAt) {
+      return false;
+    }
+    const updatedAt = new Date(data.updatedAt).getTime();
+    if (isNaN(updatedAt)) {
+      return false;
+    }
+    return updatedAt > existing.updatedAt;
+  }
+  /**
+   * 删除缓存数据
+   * @param key 缓存键
+   * @returns 缓存数据
+   */
+  async delCheckData(key: string) {
+    return this.del(key);
+  }
+}

query/query-login/browser-cache/cache.ts

@@ -0,0 +1,29 @@
+export { CacheStore, BaseCacheStore } from './cache-store.ts'
+import { CacheStore } from './cache-store.ts'
+
+/**
+ * 一个简单的缓存类，用于存储字符串。
+ * 对数据进行添加对比内容。
+ */
+export class MyCache<T = any> extends CacheStore {
+  key: string;
+  constructor(opts?: { key?: string }) {
+    const { key, ...rest } = opts || {};
+    super(rest);
+    this.key = key || 'my-cache';
+  }
+  async getData<U = T>(key: string = this.key): Promise<U> {
+    return super.getCheckData<U>(key) as any;
+  }
+  /**
+   * 设置缓存数据，默认过期时间为10天
+   * @param data
+   * @param opts
+   */
+  async setData<U = T>(data: U, opts?: { expireTime?: number, updatedAt?: number }) {
+    super.setCheckData(this.key, data, opts);
+  }
+  async del(): Promise<void> {
+    await super.del(this.key);
+  }
+}

query/query-login/login-cache.ts

@@ -16,7 +16,7 @@ export interface Cache {
    */
   init?: () => Promise<any>;
 }
-type User = {
+export type User = {
   avatar?: string;
   description?: string;
   id?: string;
@@ -38,7 +38,7 @@ type CacheLogin = {
   loginUsers: CacheLoginUser[];
 } & CacheLoginUser;
 
-export type CacheStore<T = Cache> = {
+export type CacheStore<T extends Cache = Cache> = {
   name: string;
   /**
    * 缓存数据
@@ -82,29 +82,43 @@ export type CacheStore<T = Cache> = {
   getValue(): Promise<CacheLogin>;
   setValue(value: CacheLogin): Promise<CacheLogin>;
   delValue(): Promise<void>;
-  init(): Promise<any>;
+  init(): Promise<CacheLogin>;
+  getIsExpired(): Promise<boolean>;
 };
 
-export type LoginCacheStoreOpts = {
+export type LoginCacheStoreOpts<T extends Cache = Cache> = {
   name: string;
-  cache: Cache;
+  cache: T;
 };
-export class LoginCacheStore implements CacheStore<any> {
+const defaultCacheData: CacheLogin = {
-  cache: Cache;
+  loginUsers: [],
+  user: undefined,
+  id: undefined,
+  accessToken: undefined,
+  refreshToken: undefined,
+  accessTokenExpiresIn: undefined,
+  createdAt: undefined,
+}
+export class LoginCacheStore<T extends Cache = Cache> implements CacheStore<T> {
+  cache: T;
   name: string;
   cacheData: CacheLogin;
-  constructor(opts: LoginCacheStoreOpts) {
+  constructor(opts: LoginCacheStoreOpts<T>) {
     if (!opts.cache) {
       throw new Error('cache is required');
     }
     // @ts-ignore
     this.cache = opts.cache;
-    this.cacheData = {
+    this.cacheData = { ...defaultCacheData };
-      loginUsers: [],
+    this.name = opts.name;
-      user: undefined,
+  }
-      id: undefined,
+  /**
-      accessToken: undefined,
+   * 设置缓存
-      refreshToken: undefined,
+   * @param key
+   * @param value
+   * @returns
+      accessTokenExpiresIn: undefined,
+      createdAt: undefined,
     };
     this.name = opts.name;
   }
@@ -124,6 +138,7 @@ export class LoginCacheStore implements CacheStore<any> {
    */
   async delValue() {
     await this.cache.del();
+    this.cacheData = { ...defaultCacheData };
   }
   getValue(): Promise<CacheLogin> {
     return this.cache.get(this.name);
@@ -131,41 +146,38 @@ export class LoginCacheStore implements CacheStore<any> {
   /**
    * 初始化,设置默认值
    */
-  async init() {
+  async init(): Promise<CacheLogin> {
-    const defaultData = {
+    const defaultData: CacheLogin = { ...this.cacheData };
-      loginUsers: [],
+    return new Promise(async (resolve) => {
-      user: null,
+      if (this.cache.init) {
-      id: null,
+        try {
-      accessToken: null,
+          const cacheData = await this.cache.init();
-      refreshToken: null,
+          this.cacheData = cacheData || defaultData;
-    };
+        } catch (error) {
-    if (this.cache.init) {
+          console.log('cacheInit error', error);
-      try {
+        }
-        const cacheData = await this.cache.init();
+      } else {
-        this.cacheData = cacheData || defaultData;
+        this.cacheData = (await this.getValue()) || defaultData;
-      } catch (error) {
-        console.log('cacheInit error', error);
       }
-    } else {
+      resolve(this.cacheData);
-      this.cacheData = (await this.getValue()) || defaultData;
+    });
-    }
   }
   /**
    * 设置当前用户
    * @param user
    */
-  async setLoginUser(user: CacheLoginUser) {
+  async setLoginUser(loginUser: CacheLoginUser) {
-    const has = this.cacheData.loginUsers.find((u) => u.id === user.id);
+    const has = this.cacheData.loginUsers.find((u) => u.id === loginUser.id);
     if (has) {
-      this.cacheData.loginUsers = this.cacheData?.loginUsers?.filter((u) => u?.id && u.id !== user.id);
+      this.cacheData.loginUsers = this.cacheData?.loginUsers?.filter((u) => u?.id && u.id !== loginUser.id);
     }
-    this.cacheData.loginUsers.push(user);
+    this.cacheData.loginUsers.push(loginUser);
-    this.cacheData.user = user.user;
+    this.cacheData.user = loginUser.user;
-    this.cacheData.id = user.id;
+    this.cacheData.id = loginUser.id;
-    this.cacheData.accessToken = user.accessToken;
+    this.cacheData.accessToken = loginUser.accessToken;
-    this.cacheData.refreshToken = user.refreshToken;
+    this.cacheData.refreshToken = loginUser.refreshToken;
-    this.cacheData.accessTokenExpiresIn = user.accessTokenExpiresIn;
+    this.cacheData.accessTokenExpiresIn = loginUser.accessTokenExpiresIn;
-    this.cacheData.createdAt = user.createdAt;
+    this.cacheData.createdAt = loginUser.createdAt;
     await this.setValue(this.cacheData);
   }
 
@@ -184,6 +196,18 @@ export class LoginCacheStore implements CacheStore<any> {
     const cacheData = this.cacheData;
     return Promise.resolve(cacheData.accessToken || '');
   }
+  getIsExpired(): Promise<boolean> {
+    const cacheData = this.cacheData;
+    if (!cacheData.accessToken) {
+      return Promise.resolve(true);
+    }
+    if (!cacheData.createdAt || !cacheData.accessTokenExpiresIn) {
+      return Promise.resolve(false);
+    }
+    const now = Date.now();
+    const expiresIn = cacheData.createdAt + cacheData.accessTokenExpiresIn * 1000;
+    return Promise.resolve(now >= expiresIn);
+  }
 
   async clearCurrentUser() {
     const user = await this.getCurrentUser();
@@ -191,18 +215,22 @@ export class LoginCacheStore implements CacheStore<any> {
     if (has) {
       this.cacheData.loginUsers = this.cacheData?.loginUsers?.filter((u) => u?.id && u.id !== user.id);
     }
-    this.cacheData.user = undefined;
+    const hasOther = this.cacheData.loginUsers.length > 0;
-    this.cacheData.id = undefined;
+    const current = this.cacheData.loginUsers[this.cacheData.loginUsers.length - 1];
-    this.cacheData.accessToken = undefined;
+    if (hasOther && current) {
-    this.cacheData.refreshToken = undefined;
+      this.cacheData.user = current.user;
+      this.cacheData.id = current.id;
+      this.cacheData.accessToken = current.accessToken;
+      this.cacheData.refreshToken = current.refreshToken;
+      this.cacheData.accessTokenExpiresIn = current.accessTokenExpiresIn;
+      this.cacheData.createdAt = current.createdAt;
+    } else {
+      this.cacheData = { ...defaultCacheData };
+    }
     await this.setValue(this.cacheData);
   }
   async clearAll() {
-    this.cacheData.loginUsers = [];
+    this.cacheData = { ...defaultCacheData };
-    this.cacheData.user = undefined;
-    this.cacheData.id = undefined;
-    this.cacheData.accessToken = undefined;
-    this.cacheData.refreshToken = undefined;
     await this.setValue(this.cacheData);
   }
 }

query/query-login/login-node-cache.ts

@@ -2,9 +2,8 @@ import { Cache } from './login-cache.ts';
 import { homedir } from 'node:os';
 import { join, dirname } from 'node:path';
 import fs from 'node:fs';
-import { readFileSync, writeFileSync, accessSync } from 'node:fs';
+import { readFileSync, writeFileSync, accessSync, unlinkSync, mkdirSync } from 'node:fs';
-import { readFile, writeFile, unlink, mkdir } from 'node:fs/promises';
+export const fileExists = (
-export const fileExists = async (
   filePath: string,
   { createIfNotExists = true, isFile = true, isDir = false }: { createIfNotExists?: boolean; isFile?: boolean; isDir?: boolean } = {},
 ) => {
@@ -13,10 +12,10 @@ export const fileExists = async (
     return true;
   } catch (error) {
     if (createIfNotExists && isDir) {
-      await mkdir(filePath, { recursive: true });
+      mkdirSync(filePath, { recursive: true });
       return true;
     } else if (createIfNotExists && isFile) {
-      await mkdir(dirname(filePath), { recursive: true });
+      mkdirSync(dirname(filePath), { recursive: true });
       return false;
     }
     return false;
@@ -34,32 +33,50 @@ export const readConfigFile = (filePath: string) => {
 export const writeConfigFile = (filePath: string, data: any) => {
   writeFileSync(filePath, JSON.stringify(data, null, 2));
 };
-export const getHostName = () => {
+/**
+ * 获取主机名，
+ * 例如：https://kevisual.cn 返回 kevisual.cn
+ * 这里是读取默认的配置文件 ~/.config/envision/config.json 中的 baseURL 字段来获取主机名的，如果没有配置 baseURL 则默认使用 https://kevisual.cn
+ * @returns 主机名
+ */
+export const getHostName = (baseURL?: string) => {
   const configDir = join(homedir(), '.config', 'envision');
   const configFile = join(configDir, 'config.json');
   const config = readConfigFile(configFile);
-  const baseURL = config.baseURL || 'https://kevisual.cn';
+  const _baseURL = baseURL || config.baseURL || 'https://kevisual.cn';
-  const hostname = new URL(baseURL).hostname;
+  const hostname = new URL(_baseURL).hostname;
   return hostname;
 };
 export class StorageNode implements Storage {
   cacheData: any;
-  filePath: string;
+  filePath: string = '';
-  constructor() {
+  hostname: string = '';
+  constructor(opts?: { baseURL?: string, load?: boolean }) {
     this.cacheData = {};
-    const configDir = join(homedir(), '.config', 'envision');
+    const hostname = getHostName(opts?.baseURL);
-    const hostname = getHostName();
+    this.setHostName(hostname, { load: opts?.load });
-    this.filePath = join(configDir, 'config', `${hostname}-storage.json`);
-    fileExists(this.filePath, { isFile: true });
   }
-  async loadCache() {
+  setHostName(hostname: string, opts?: { load?: boolean }) {
+    const load = opts?.load ?? false;
+    if (hostname.startsWith('http')) {
+      hostname = new URL(hostname).hostname;
+    }
+    const configDir = join(homedir(), '.config', 'envision');
+    this.filePath = join(configDir, 'config', `${hostname}-storage.json`);
+    this.hostname = hostname;
+    fileExists(this.filePath, { isFile: true });
+    if (load) {
+      this.loadCache();
+    }
+  }
+  loadCache() {
     const filePath = this.filePath;
     try {
-      const data = await readConfigFile(filePath);
+      const data = readConfigFile(filePath);
       this.cacheData = data;
     } catch (error) {
       this.cacheData = {};
-      await writeFile(filePath, JSON.stringify(this.cacheData, null, 2));
+      writeFileSync(filePath, JSON.stringify(this.cacheData, null, 2));
     }
   }
   get length() {
@@ -70,15 +87,15 @@ export class StorageNode implements Storage {
   }
   setItem(key: string, value: any) {
     this.cacheData[key] = value;
-    writeFile(this.filePath, JSON.stringify(this.cacheData, null, 2));
+    writeFileSync(this.filePath, JSON.stringify(this.cacheData, null, 2));
   }
   removeItem(key: string) {
     delete this.cacheData[key];
-    writeFile(this.filePath, JSON.stringify(this.cacheData, null, 2));
+    writeFileSync(this.filePath, JSON.stringify(this.cacheData, null, 2));
   }
   clear() {
     this.cacheData = {};
-    writeFile(this.filePath, JSON.stringify(this.cacheData, null, 2));
+    writeFileSync(this.filePath, JSON.stringify(this.cacheData, null, 2));
   }
   key(index: number) {
     return Object.keys(this.cacheData)[index];
@@ -86,10 +103,12 @@ export class StorageNode implements Storage {
 }
 export class LoginNodeCache implements Cache {
   filepath: string;
-
+  constructor(opts?: { baseURL?: string, load?: boolean }) {
-  constructor(filepath?: string) {
+    this.filepath = join(homedir(), '.config', 'envision', 'config', `${getHostName(opts?.baseURL)}-login.json`);
-    this.filepath = filepath || join(homedir(), '.config', 'envision', 'config', `${getHostName()}-login.json`);
     fileExists(this.filepath, { isFile: true });
+    if (opts?.load) {
+      this.loadCache(this.filepath);
+    }
   }
   async get(_key: string) {
     try {
@@ -111,11 +130,11 @@ export class LoginNodeCache implements Cache {
     }
   }
   async del() {
-    await unlink(this.filepath);
+    unlinkSync(this.filepath);
   }
-  async loadCache(filePath: string) {
+  loadCache(filePath: string) {
     try {
-      const data = await readFile(filePath, 'utf-8');
+      const data = readFileSync(filePath, 'utf-8');
       const jsonData = JSON.parse(data);
       return jsonData;
     } catch (error) {
@@ -126,7 +145,7 @@ export class LoginNodeCache implements Cache {
       return defaultData;
     }
   }
-  async init() {
+  init() {
-    return await this.loadCache(this.filepath);
+    return this.loadCache(this.filepath);
   }
 }

query/query-login/query-login-browser.ts

@@ -1,5 +1,5 @@
 import { QueryLogin, QueryLoginOpts } from './query-login.ts';
-import { MyCache } from '@kevisual/cache';
+import { MyCache } from './browser-cache/cache.ts';
 type QueryLoginNodeOptsWithoutCache = Omit<QueryLoginOpts, 'cache'>;
 
 export class QueryLoginBrowser extends QueryLogin {

query/query-login/query-login-node.ts

@@ -1,14 +1,19 @@
 import { QueryLogin, QueryLoginOpts } from './query-login.ts';
 import { LoginNodeCache, StorageNode } from './login-node-cache.ts';
 type QueryLoginNodeOptsWithoutCache = Omit<QueryLoginOpts, 'cache'>;
-export const storage = new StorageNode();
+export { StorageNode }
-await storage.loadCache();
+export const cache = new LoginNodeCache();
-export class QueryLoginNode extends QueryLogin {
+export class QueryLoginNode extends QueryLogin<LoginNodeCache> {
+  declare storage: StorageNode;
   constructor(opts: QueryLoginNodeOptsWithoutCache) {
+    const baseURL = opts?.query?.baseURL;
+    const storage = new StorageNode({ baseURL, load: true });
+    const cache = new LoginNodeCache({ baseURL, load: true });
     super({
       ...opts,
+      isBrowser: false,
       storage,
-      cache: new LoginNodeCache(),
+      cache,
     });
   }
 }

query/query-login/query-login.ts

@@ -1,14 +1,15 @@
 import { Query, BaseQuery } from '@kevisual/query';
 import type { Result, DataOpts } from '@kevisual/query/query';
-import { LoginCacheStore, CacheStore } from './login-cache.ts';
+import { LoginCacheStore, CacheStore, User } from './login-cache.ts';
 import { Cache } from './login-cache.ts';
 import { BaseLoad } from '@kevisual/load';
-export type QueryLoginOpts = {
+import { EventEmitter } from 'eventemitter3'
+export type QueryLoginOpts<T extends Cache = Cache> = {
   query?: Query;
   isBrowser?: boolean;
   onLoad?: () => void;
   storage?: Storage;
-  cache: Cache;
+  cache: T;
 };
 export type QueryLoginData = {
   username?: string;
@@ -20,33 +21,53 @@ export type QueryLoginResult = {
   refreshToken: string;
 };
 
-export class QueryLogin extends BaseQuery {
+export class QueryLogin<T extends Cache = Cache> extends BaseQuery {
   /**
    * query login cache， 非实际操作， 一个cache的包裹模块
    */
-  cacheStore: CacheStore;
+  cacheStore: CacheStore<T>;
   isBrowser: boolean;
-  load?: boolean;
   storage: Storage;
+  load: boolean = false;
+  status: 'init' | 'logining' | 'loginSuccess' | 'loginError' = 'init';
   onLoad?: () => void;
+  emitter = new EventEmitter();
 
-  constructor(opts?: QueryLoginOpts) {
+  constructor(opts?: QueryLoginOpts<T>) {
     super({
       query: opts?.query || new Query(),
     });
-    this.cacheStore = new LoginCacheStore({ name: 'login', cache: opts?.cache! });
+    this.cacheStore = new LoginCacheStore<T>({ name: 'login', cache: opts?.cache! });
     this.isBrowser = opts?.isBrowser ?? true;
     this.init();
     this.onLoad = opts?.onLoad;
     this.storage = opts?.storage || globalThis?.localStorage;
+    if (!this.storage) {
+      throw new Error('storage is required');
+    }
+    this.cacheStore.init().then(() => {
+      this.onLoad?.();
+      this.load = true;
+      this.emitter.emit('load');
+    });
   }
   setQuery(query: Query) {
     this.query = query;
   }
-  private async init() {
+  async init() {
-    await this.cacheStore.init();
+    if (this.load) {
-    this.load = true;
+      return this.cacheStore.cacheData;
-    this.onLoad?.();
+    }
+    return new Promise(async (resolve) => {
+      const timer = setTimeout(() => {
+        resolve(this.cacheStore.cacheData);
+      }, 1000 * 20); // 20秒超时，避免一直等待
+      const listener = () => {
+        clearTimeout(timer);
+        resolve(this.cacheStore.cacheData);
+      }
+      this.emitter.once('load', listener);
+    });
   }
   async post<T = any>(data: any, opts?: DataOpts) {
     try {
@@ -104,6 +125,26 @@ export class QueryLogin extends BaseQuery {
     }
     return res;
   }
+  /**
+   * cnb登录， 适用于cnb的登录方式， 需要后端配合， 传入cnbToken， 后端验证cnbToken的有效性，并返回accessToken和refreshToken
+   * @param data 
+   * @returns 
+   */
+  async loginByCnb(data: { cnbToken: string }) {
+    const res = await this.post<QueryLoginResult>({
+      path: 'user',
+      key: 'cnb-login',
+      payload: {
+        data: data
+      }
+    });
+    if (res.code === 200) {
+      const { accessToken, refreshToken, accessTokenExpiresIn } = res?.data || {};
+      this.storage.setItem('token', accessToken || '');
+      await this.beforeSetLoginUser({ accessToken, refreshToken, accessTokenExpiresIn });
+    }
+    return res;
+  }
   /**
    * 检测微信登录，登陆成功后，调用onSuccess，否则调用onError
    * @param param0
@@ -125,7 +166,8 @@ export class QueryLogin extends BaseQuery {
    * 登陆成功，需要获取用户信息进行缓存
    * @param param0
    */
-  async beforeSetLoginUser({ accessToken, refreshToken, check401, accessTokenExpiresIn }: { accessTokenExpiresIn?: number, accessToken?: string; refreshToken?: string; check401?: boolean }) {
+  async beforeSetLoginUser(opts: { accessTokenExpiresIn?: number, accessToken?: string; refreshToken?: string; check401?: boolean }): Promise<Result<User>> {
+    const { accessToken, refreshToken, check401, accessTokenExpiresIn } = opts;
     if (accessToken && refreshToken) {
       const resUser = await this.getMe(accessToken, check401);
       if (resUser.code === 200) {
@@ -143,16 +185,43 @@ export class QueryLogin extends BaseQuery {
           console.error('登录失败');
         }
       }
+      return resUser;
     }
+    return {
+      code: 400,
+      message: '登录失败',
+    };
+  }
+  /**
+   * 刷新登录用户，获取新的token，并更新用户信息
+   * @param refreshToken 刷新token，如果不传，则从缓存中获取
+   * @returns 
+   */
+  async refreshLoginUser(opts?: { refreshToken?: string, accessToken?: string }) {
+    const res = await this.queryRefreshToken(opts);
+    if (res.code === 200) {
+      const { accessToken, refreshToken, accessTokenExpiresIn } = res?.data || {};
+      this.storage.setItem('token', accessToken || '');
+      await this.beforeSetLoginUser({ accessToken, refreshToken, accessTokenExpiresIn, check401: false });
+    }
+    return res;
   }
   /**
    * 刷新token
    * @param refreshToken
    * @returns
    */
-  async queryRefreshToken(refreshToken?: string) {
+  async queryRefreshToken(opts?: { refreshToken?: string, accessToken?: string }) {
-    const _refreshToken = refreshToken || this.cacheStore.getRefreshToken();
+    const refreshToken = opts?.refreshToken;
-    let data = { refreshToken: _refreshToken };
+    let accessToken = opts?.accessToken;
+    const _refreshToken = refreshToken ?? (await this.cacheStore.getRefreshToken());
+    let data: any = {};
+    if (accessToken) {
+      data.accessToken = accessToken;
+    }
+    if (_refreshToken) {
+      data.refreshToken = _refreshToken;
+    }
     if (!_refreshToken) {
       await this.cacheStore.clearCurrentUser();
       return {
@@ -183,7 +252,7 @@ export class QueryLogin extends BaseQuery {
     if (response?.code === 401) {
       const hasRefreshToken = await that.cacheStore.getRefreshToken();
       if (hasRefreshToken) {
-        const res = await that.queryRefreshToken(hasRefreshToken);
+        const res = await that.queryRefreshToken({ refreshToken: hasRefreshToken });
         if (res.code === 200) {
           const { accessToken, refreshToken, accessTokenExpiresIn } = res?.data || {};
           that.storage.setItem('token', accessToken || '');
@@ -302,6 +371,23 @@ export class QueryLogin extends BaseQuery {
     const token = this.storage.getItem('token');
     return !!token;
   }
+  async checkTokenValid(): Promise<null | string> {
+    const token = this.storage.getItem('token');
+    if (!token) {
+      return null;
+    }
+    const isExpired = await this.cacheStore.getIsExpired();
+    if (isExpired) {
+      console.log('token过期，正在刷新token', this.cacheStore.cacheData);
+      const res = await this.refreshLoginUser()
+      if (res.code === 200) {
+        // 刷新成功，返回新的token
+        return res.data?.accessToken || null;
+      }
+      return null;
+    }
+    return token;
+  }
   /**
    * 检查本地用户列表
    * @returns
@@ -310,6 +396,7 @@ export class QueryLogin extends BaseQuery {
     const token = this.storage.getItem('token');
     return token || '';
   }
+
   async beforeRequest(opts: any = {}) {
     const token = this.storage.getItem('token');
     if (token) {

query/query-login/test/expire.ts

@@ -0,0 +1,10 @@
+const cacheData = {
+  accessTokenExpiresIn: 604800,
+  createdAt: 1771926793545
+};
+
+const expiresIn = cacheData.createdAt + cacheData.accessTokenExpiresIn * 1000;
+console.log('expiresIn', expiresIn);
+const now = Date.now();
+console.log('now', now);
+console.log('isExpired', now >= expiresIn);

query/query-proxy/proxy.ts

@@ -4,6 +4,7 @@ import { filter } from '@kevisual/js-filter'
 import { EventEmitter } from 'eventemitter3';
 import { initApi } from './router-api-proxy.ts';
 import Fuse from 'fuse.js';
+import { cloneDeep } from 'es-toolkit';
 
 export const RouteTypeList = ['api', 'context', 'worker', 'page'] as const;
 export type RouterViewItemInfo = RouterViewApi | RouterViewContext | RouterViewWorker | RouteViewPage;
@@ -26,6 +27,10 @@ type RouteViewBase = {
    * 默认动作配置
    */
   action?: { path?: string; key?: string; id?: string; payload?: any;[key: string]: any };
+  /**
+   * 本地状态，loading、active、error等
+   */
+  routerStatus?: 'loading' | 'active' | 'inactive' | 'error';
 }
 export type RouterViewApi = {
   type: 'api',
@@ -67,7 +72,7 @@ export type RouterViewWorker = {
  * @returns 
  */
 export const pickRouterViewData = (item: RouterViewItem) => {
-  const { action, response, _id, ...rest } = item;
+  const { action, response, _id, ...rest } = cloneDeep(item);
   if (rest.type === 'api') {
     if (rest.api) {
       delete rest.api.query;
@@ -83,6 +88,7 @@ export const pickRouterViewData = (item: RouterViewItem) => {
       delete rest.context.router;
     }
   }
+  delete rest.routerStatus;
   return rest
 }
 /**
@@ -98,7 +104,7 @@ export type RouteViewPage = {
 export type RouterViewQuery = {
   id: string,
   query: string,
-  title: string
+  title: string,
 }
 /**
  * 后端存储结构
@@ -143,6 +149,7 @@ export class QueryProxy {
   }
 
   private initRouterView(item: RouterViewItem) {
+    item.routerStatus = 'loading';
     if (item.type === 'api' && item.api?.url) {
       const url = item.api.url;
       if (item?.api?.query) return item;
@@ -245,10 +252,14 @@ export class QueryProxy {
     // @ts-ignore
     const context = globalThis['context'] || {}
     const router = item?.context?.router || context[item?.context?.key] as QueryRouterServer;
+    if (item) {
+      item.routerStatus = router ? 'active' : 'error';
+    }
     if (!router) {
       console.warn(`未发现Context router ${item?.context?.key}`);
       return
     }
+
     const routes = router.getList();
     // TODO: args
     // const args = fromJSONSchema(r);
@@ -308,6 +319,9 @@ export class QueryProxy {
     }
     const viewItem = item.worker;
     const worker = viewItem?.worker;
+    if (item) {
+      item.routerStatus = worker ? 'active' : 'error';
+    }
     if (!worker) {
       console.warn('Worker not initialized');
       return;
@@ -377,11 +391,15 @@ export class QueryProxy {
     const url = item.page.url;
     try {
       if (typeof window !== 'undefined') {
-        await import(url).then((module) => { }).catch((err) => {
+        await import(url)
-          console.error('引入Page脚本失败:', url, err);
+        if (item) {
-        });
+          item.routerStatus = 'active';
+        }
       }
     } catch (e) {
+      if (item) {
+        item.routerStatus = 'error';
+      }
       console.warn('引入Page脚本失败:', url, e);
       return;
     }

query/query-proxy/router-api-proxy.ts

@@ -17,12 +17,16 @@ export const initApi = async (opts: {
   const token = opts?.token;
   const query = item?.api?.query || new Query({ url: item?.api?.url || '/api/router' })
   const res = await query.post<{ list: RouterItem[] }>({ path: "router", key: 'list', token: token });
+  if (item) {
+    item.routerStatus = res?.code === 200 ? 'active' : 'error';
+  }
   if (res.code !== 200) {
     return {
       code: res.code,
       message: `初始化路由失败: ${res.message}, url: ${query.url}`
     }
   }
+
   let _list = res.data?.list || []
   if (opts?.exclude) {
     if (opts?.exclude) {

query/query-resources/index.ts

@@ -26,6 +26,10 @@ export class QueryResources {
   setUsername(username: string) {
     this.prefix = `/${username}/resources/`;
   }
+  /**
+   * 设置prefix，类似  /{username}/resources/；
+   * @param prefix 
+   */
   setPrefix(prefix: string) {
     this.prefix = prefix;
   }
@@ -55,19 +59,25 @@ export class QueryResources {
       headers: this.header(opts?.headers),
     });
   }
+  getUrl(prefix: string): string {
+    if (prefix.startsWith('http')) {
+      return prefix;
+    }
+    return `${this.prefix}${prefix}`;
+  }
   async getList(prefix: string, data?: { recursive?: boolean }, opts?: DataOpts): Promise<Result<any[]>> {
     return this.get(data, {
-      url: `${this.prefix}${prefix}`,
+      url: this.getUrl(prefix),
       body: data,
       ...opts,
     });
   }
   async fetchFile(filepath: string, opts?: DataOpts): Promise<Result<any>> {
-    const url = `${this.prefix}${filepath}`;
+    const url = this.getUrl(filepath);
     return this.get({}, { url, method: 'GET', ...opts, headers: this.header(opts?.headers, false), isText: true });
   }
   async uploadFile(filepath: string, content: string | Blob, opts?: DataOpts & { chunkSize?: number, maxSize?: number }): Promise<Result<any>> {
-    const pathname = `${this.prefix}${filepath}`;
+    const pathname = this.getUrl(filepath);
     const filename = path.basename(pathname);
     const type = getContentType(filename);
     const url = new URL(pathname, window.location.origin);
@@ -110,12 +120,12 @@ export class QueryResources {
     return res;
   }
   async uploadChunkedFile(filepath: string, file: Blob, hash: string, opts?: DataOpts & { chunkSize?: number }): Promise<Result<any>> {
-    const pathname = `${this.prefix}${filepath}`;
+    const pathname = this.getUrl(filepath);
     const filename = path.basename(pathname);
     const url = new URL(pathname, window.location.origin);
     url.searchParams.set('hash', hash);
     url.searchParams.set('chunk', '1');
-    console.log(`url,`, url, hash);
+    // console.log(`url,`, url, hash);
     // 预留 eventSource 支持（暂不处理）
     // const createEventSource = opts?.createEventSource;
     const { chunkSize: _chunkSize, ...restOpts } = opts || {};
@@ -166,9 +176,20 @@ export class QueryResources {
     this.onProcess?.({ type: 'uploadFinish', filename, size: file.size, process: 100 });
     return { code: 200, message: '上传成功' };
   }
+  /**
+   * 移除 prefix，获取相对路径
+   * @param filepath 
+   * @returns 
+   */
+  getRelativePath(filepath: string): string {
+    if (filepath.startsWith(this.prefix)) {
+      return filepath.slice(this.prefix.length);
+    }
+    return filepath;
+  }
 
   async getStat(filepath: string, opts?: DataOpts): Promise<Result<Stat>> {
-    const url = `${this.prefix}${filepath}`;
+    const url = this.getUrl(filepath);
     return adapter({
       url,
       params: {
@@ -192,8 +213,8 @@ export class QueryResources {
     return this.uploadFile(filepath, '文件夹占位，其他文件不存在，文件夹不存在，如果有其他文件夹，删除当前文件夹占位文件即可', opts);
   }
   async rename(oldpath: string, newpath: string, opts?: DataOpts): Promise<Result<any>> {
-    const pathname = `${this.prefix}${oldpath}`;
+    const pathname = this.getUrl(oldpath);
-    const newName = `${this.prefix}${newpath}`;
+    const newName = this.getUrl(newpath);
     const params = {
       newName: newName,
     };
@@ -206,7 +227,7 @@ export class QueryResources {
     });
   }
   async deleteFile(filepath: string, opts?: DataOpts): Promise<Result<any>> {
-    const url = `${this.prefix}${filepath}`;
+    const url = this.getUrl(filepath);
     return adapter({
       url,
       method: 'DELETE' as any,