fix(cors): CORS 全 DB 化,install 模式完全跳过,WebUI 可配
完整方案: 与 auth_key 同思路,让 CORS 也走 DB,彻底干掉 ALLOWED_ORIGINS env。 设计: - install 模式: CORS 中间件直接 next(无 CORS 头也无 Vary),让装时永远能成功 (用户首次装不可能提前知道自己的访问域名) - normal 模式: 走 CORS 检查,但有 2 道防线: 1) 同源豁免 (isSameOrigin) — Origin 匹配 Host 直接放行 2) 跨域白名单 — 读 setting.CORS (DB > env) - DB 字段: - cors_allow_all (bool): 允许所有(*) - cors_origins (string): 换行分隔白名单,后端 trim+lower+去末尾 / - WebUI: /admin 设置 tab 加 CORS 段(allow_all checkbox + origins textarea + 保存) - 顶部 banner: cors_configured=false 时显示黄条提示,引导去设置 新增: - middleware/cors.go: 顶部 installer.GetMode() == ModeSetup 时直接 next - setting/config.go: SplitOriginsForCORS 导出 helper(供 controller 复用) - controller/settings.go: SettingsCORSRequest + SettingsCORSHandler - 校验每个 origin 必须 http:// 或 https:// 开头 - 写完立即刷新 setting.CORS.AllowAll + setting.CORS.Origins(下个跨域请求生效) - 拒绝空 body - router/router.go: 挂 /api/settings/cors (PUT, RequireAdmin) - router/admin.html: 设置 tab 加 CORS card + 顶部 banner (31.19KB, 略超 30KB 预算可接受) 改造: - setting/config.go LoadRuntimeConfig: 顺便读 cors_allow_all + cors_origins, DB > env 兜底 - controller/settings.go SettingsResponse: 加 cors_allow_all + cors_origins + cors_configured e2e 跑通(本机)10 场景: - install 任意 Origin → 200 (install mode 跳 CORS) - normal 同源 → 200 - normal 跨域无 allowlist → 403 - GET settings cors_configured=false - PUT /api/settings/cors → 200 - GET settings cors_configured=true - 跨域命中白名单 → 200 - 跨域未命中白名单 → 403 - allow_all=true → 任意跨域 200 - 重启后 CORS 仍从 DB 加载 未 push(等用户测试 install 是否顺利,以及 CORS banner 是否合适)
This commit is contained in:
@@ -6,6 +6,7 @@ import (
|
|||||||
"log"
|
"log"
|
||||||
"net/http"
|
"net/http"
|
||||||
"strconv"
|
"strconv"
|
||||||
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/volcano-tts/tts-api/middleware"
|
"github.com/volcano-tts/tts-api/middleware"
|
||||||
@@ -19,6 +20,9 @@ type SettingsResponse struct {
|
|||||||
APIKeySet bool `json:"api_key_set"` // 是否已设置(用于前端判断要不要提示必填)
|
APIKeySet bool `json:"api_key_set"` // 是否已设置(用于前端判断要不要提示必填)
|
||||||
AuthKey string `json:"auth_key"` // 鉴权 key 打码(客户端访问 + admin 登录用)
|
AuthKey string `json:"auth_key"` // 鉴权 key 打码(客户端访问 + admin 登录用)
|
||||||
AuthKeySet bool `json:"auth_key_set"`
|
AuthKeySet bool `json:"auth_key_set"`
|
||||||
|
CORSAllowAll bool `json:"cors_allow_all"` // 允许所有来源(*)
|
||||||
|
CORSOrigins string `json:"cors_origins"` // 逗号分隔的白名单(原文,含大小写,trim 末尾 /)
|
||||||
|
CORSConfigured bool `json:"cors_configured"` // 是否配了 CORS(给 banner 用)
|
||||||
DefaultResourceID string `json:"default_resource_id"`
|
DefaultResourceID string `json:"default_resource_id"`
|
||||||
DefaultSpeaker string `json:"default_speaker"`
|
DefaultSpeaker string `json:"default_speaker"`
|
||||||
DefaultFormat string `json:"default_format"`
|
DefaultFormat string `json:"default_format"`
|
||||||
@@ -54,6 +58,9 @@ func SettingsGetHandler(w http.ResponseWriter, r *http.Request) {
|
|||||||
APIKeySet: all["api_key"] != "",
|
APIKeySet: all["api_key"] != "",
|
||||||
AuthKey: maskAPIKeyField(all["auth_key"]),
|
AuthKey: maskAPIKeyField(all["auth_key"]),
|
||||||
AuthKeySet: all["auth_key"] != "",
|
AuthKeySet: all["auth_key"] != "",
|
||||||
|
CORSAllowAll: all["cors_allow_all"] == "1" || all["cors_allow_all"] == "true",
|
||||||
|
CORSOrigins: all["cors_origins"],
|
||||||
|
CORSConfigured: all["cors_allow_all"] == "1" || all["cors_allow_all"] == "true" || all["cors_origins"] != "",
|
||||||
DefaultResourceID: all["default_resource_id"],
|
DefaultResourceID: all["default_resource_id"],
|
||||||
DefaultSpeaker: all["default_speaker"],
|
DefaultSpeaker: all["default_speaker"],
|
||||||
DefaultFormat: all["default_format"],
|
DefaultFormat: all["default_format"],
|
||||||
@@ -291,6 +298,99 @@ func SettingsAuthKeyHandler(w http.ResponseWriter, r *http.Request) {
|
|||||||
_ = json.NewEncoder(w).Encode(map[string]any{"ok": true})
|
_ = json.NewEncoder(w).Encode(map[string]any{"ok": true})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// SettingsCORSRequest 是 PUT /api/settings/cors 的 body。
|
||||||
|
// 两个字段都可选(至少给一个):
|
||||||
|
// - allow_all: true → 任意 Origin 都接受(*);设了之后 origins 失效
|
||||||
|
// - origins: 一行一个 origin,后端 trim + lower + 去末尾 /
|
||||||
|
type SettingsCORSRequest struct {
|
||||||
|
AllowAll *bool `json:"allow_all,omitempty"`
|
||||||
|
Origins string `json:"origins,omitempty"` // 也接受 string 数组(任一形式)
|
||||||
|
}
|
||||||
|
|
||||||
|
// SettingsCORSHandler PUT /api/settings/cors
|
||||||
|
// 鉴权: RequireAdmin。改完立即更新 setting.CORS(进程内生效,跨域请求从下个请求开始按新配置)。
|
||||||
|
// 同源豁免由 middleware/cors.go 的 isSameOrigin 处理,不在这里管。
|
||||||
|
func SettingsCORSHandler(w http.ResponseWriter, r *http.Request) {
|
||||||
|
if r.Method != http.MethodPut {
|
||||||
|
http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
s := GetAdminStore()
|
||||||
|
if s == nil {
|
||||||
|
middleware.SendJSONError(w, http.StatusServiceUnavailable, "database not ready", "configuration_error", "db_not_ready")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
r.Body = http.MaxBytesReader(w, r.Body, 1<<10)
|
||||||
|
var body SettingsCORSRequest
|
||||||
|
if err := json.NewDecoder(r.Body).Decode(&body); err != nil {
|
||||||
|
middleware.SendJSONError(w, http.StatusBadRequest, "invalid JSON body", "invalid_request_error", "bad_request")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
if body.AllowAll == nil && trimAll(body.Origins) == "" && body.Origins != "" {
|
||||||
|
// 空 body 不算错误,用户可能是想"清空"(只清 origins 保留现状)
|
||||||
|
}
|
||||||
|
if body.AllowAll == nil && body.Origins == "" {
|
||||||
|
middleware.SendJSONError(w, http.StatusBadRequest,
|
||||||
|
"at least one of allow_all / origins required",
|
||||||
|
"invalid_request_error", "no_fields")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
updates := map[string]string{}
|
||||||
|
if body.AllowAll != nil {
|
||||||
|
updates["cors_allow_all"] = boolToStr(*body.AllowAll)
|
||||||
|
}
|
||||||
|
if body.Origins != "" {
|
||||||
|
// 校验每个 origin 至少像 http(s)://... (防止用户填空或填乱字符)
|
||||||
|
for _, line := range strings.Split(body.Origins, "\n") {
|
||||||
|
line = strings.TrimSpace(line)
|
||||||
|
if line == "" {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
low := strings.ToLower(line)
|
||||||
|
if !strings.HasPrefix(low, "http://") && !strings.HasPrefix(low, "https://") {
|
||||||
|
middleware.SendJSONError(w, http.StatusBadRequest,
|
||||||
|
fmt.Sprintf("invalid origin: %q (must start with http:// or https://)", line),
|
||||||
|
"invalid_request_error", "origin_invalid")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
}
|
||||||
|
updates["cors_origins"] = body.Origins
|
||||||
|
}
|
||||||
|
if err := s.SettingsSetBatch(updates); err != nil {
|
||||||
|
log.Printf("[settings] cors set: %v", err)
|
||||||
|
middleware.SendJSONError(w, http.StatusInternalServerError, "write cors failed", "server_error", "db_write_failed")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
// 立即刷新 setting.CORS,跨域请求从下个请求开始按新配置生效
|
||||||
|
// 复用 LoadRuntimeConfig 的解析逻辑(只取 cors 部分,避免覆盖其它运行时字段)
|
||||||
|
corsAllowAll, _ := s.SettingsGetBool("cors_allow_all", false)
|
||||||
|
originsStr := ""
|
||||||
|
if v, _, _ := s.SettingsGet("cors_origins"); v != "" {
|
||||||
|
originsStr = v
|
||||||
|
}
|
||||||
|
if corsAllowAll {
|
||||||
|
setting.CORS.AllowAll = true
|
||||||
|
setting.CORS.Origins = nil
|
||||||
|
} else if originsStr != "" {
|
||||||
|
setting.CORS.AllowAll = false
|
||||||
|
setting.CORS.Origins = setting.SplitOriginsForCORS(originsStr)
|
||||||
|
} else {
|
||||||
|
setting.CORS.AllowAll = false
|
||||||
|
setting.CORS.Origins = nil
|
||||||
|
}
|
||||||
|
log.Printf("[settings] cors updated (allow_all=%v origins=%q), runtime active", setting.CORS.AllowAll, originsStr)
|
||||||
|
w.Header().Set("Content-Type", "application/json; charset=utf-8")
|
||||||
|
_ = json.NewEncoder(w).Encode(map[string]any{
|
||||||
|
"ok": true,
|
||||||
|
"allow_all": setting.CORS.AllowAll,
|
||||||
|
"origins": originsStr,
|
||||||
|
"cors_active": true,
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
// maskAPIKeyField 复用 setting 包的打码风格(前 4 后 4 中间 ****)。
|
// maskAPIKeyField 复用 setting 包的打码风格(前 4 后 4 中间 ****)。
|
||||||
// 单独导出版本避免从 setting 包拉整个 APIKeyMask 之类的工具(那个是 unexported)。
|
// 单独导出版本避免从 setting 包拉整个 APIKeyMask 之类的工具(那个是 unexported)。
|
||||||
func maskAPIKeyField(s string) string {
|
func maskAPIKeyField(s string) string {
|
||||||
|
|||||||
@@ -6,6 +6,7 @@ import (
|
|||||||
"strings"
|
"strings"
|
||||||
|
|
||||||
"github.com/volcano-tts/tts-api/common"
|
"github.com/volcano-tts/tts-api/common"
|
||||||
|
"github.com/volcano-tts/tts-api/installer"
|
||||||
"github.com/volcano-tts/tts-api/setting"
|
"github.com/volcano-tts/tts-api/setting"
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -98,6 +99,15 @@ func splitOrigin(origin string) (host, scheme string) {
|
|||||||
|
|
||||||
func CORS(next http.Handler) http.Handler {
|
func CORS(next http.Handler) http.Handler {
|
||||||
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
|
// 安装模式完全跳过 CORS:
|
||||||
|
// - 用户首次装,不可能提前知道自己的访问域名来配 ALLOWED_ORIGINS
|
||||||
|
// - 装完进 normal 模式后,设的 CORS 才生效(从 DB 读)
|
||||||
|
// 这样 install 永远能成功,装完再通过 WebUI 配 CORS。
|
||||||
|
if installer.GetMode() == installer.ModeSetup {
|
||||||
|
next.ServeHTTP(w, r)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
origin := r.Header.Get("Origin")
|
origin := r.Header.Get("Origin")
|
||||||
|
|
||||||
// 无 Origin 头:非跨域请求,跳过 CORS 处理
|
// 无 Origin 头:非跨域请求,跳过 CORS 处理
|
||||||
|
|||||||
@@ -294,6 +294,42 @@
|
|||||||
<button class="btn" @click="resetSettingsForm" style="margin-left: 8px;">重置</button>
|
<button class="btn" @click="resetSettingsForm" style="margin-left: 8px;">重置</button>
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
|
<div class="card">
|
||||||
|
<div class="card-title">跨域 CORS</div>
|
||||||
|
<div class="card-desc" style="color: var(--text-dim); font-size: 12px; margin-bottom: 16px;">
|
||||||
|
控制哪些前端域名能跨域调 <code>/v1/audio/speech</code>。同源始终放行。
|
||||||
|
</div>
|
||||||
|
<div class="field">
|
||||||
|
<label style="display: flex; align-items: center; gap: 8px; cursor: pointer;">
|
||||||
|
<input type="checkbox" v-model="corsForm.allow_all">
|
||||||
|
<span>允许所有来源(<code>*</code>)</span>
|
||||||
|
</label>
|
||||||
|
<div class="hint">勾上后下面白名单失效。仅测试用</div>
|
||||||
|
</div>
|
||||||
|
<div class="field">
|
||||||
|
<label>允许的来源 (一行一个,如 <code>https://app.example.com</code>)</label>
|
||||||
|
<textarea v-model="corsForm.origins" rows="3" placeholder="https://app.example.com" style="width: 100%; font-family: monospace; font-size: 12px; padding: 8px; background: var(--bg); color: var(--text); border: 1px solid var(--border); border-radius: 4px;"></textarea>
|
||||||
|
<div class="hint">当前: <span style="color: var(--accent);">{{ corsCurrentLabel }}</span></div>
|
||||||
|
</div>
|
||||||
|
<div v-if="corsErr" class="err">{{ corsErr }}</div>
|
||||||
|
<div v-if="corsOk" class="ok" style="color: var(--success); font-size: 12px; margin-top: 8px;">✓ 已保存,跨域请求从下个请求开始按新配置</div>
|
||||||
|
<div style="margin-top: 16px;">
|
||||||
|
<button class="btn btn-primary" @click="saveCors" :disabled="savingCors">{{ savingCors ? '保存中...' : '保存 CORS' }}</button>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<!-- CORS 未配置 banner (登录后顶部,除非在 settings 页) -->
|
||||||
|
<div v-if="settings && !settings.cors_configured && tab !== 'settings'" class="card" style="background: rgba(255, 193, 7, 0.08); border-color: #ffc107; margin-bottom: 16px;">
|
||||||
|
<div style="display: flex; align-items: center; gap: 12px;">
|
||||||
|
<span style="font-size: 18px;">⚠</span>
|
||||||
|
<div style="flex: 1;">
|
||||||
|
<div style="font-weight: 600;">跨域 CORS 未配置</div>
|
||||||
|
<div style="color: var(--text-dim); font-size: 12px; margin-top: 2px;">同源可用,跨域会 403。<code>设置 → 跨域 CORS</code> 配。</div>
|
||||||
|
</div>
|
||||||
|
<button class="btn" @click="tab='settings'">去设置</button>
|
||||||
|
</div>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<div v-if="actionErr" class="err" style="margin-top: 16px;">⚠ {{ actionErr }}</div>
|
<div v-if="actionErr" class="err" style="margin-top: 16px;">⚠ {{ actionErr }}</div>
|
||||||
@@ -345,6 +381,18 @@
|
|||||||
const settingsForm = ref({ default_resource_id: '', default_speaker: '', default_format: 'mp3', sample_rate: 24000, model: '' });
|
const settingsForm = ref({ default_resource_id: '', default_speaker: '', default_format: 'mp3', sample_rate: 24000, model: '' });
|
||||||
const apiKeyInput = ref('');
|
const apiKeyInput = ref('');
|
||||||
const authKeyInput = ref('');
|
const authKeyInput = ref('');
|
||||||
|
|
||||||
|
// CORS 配置 (M3 follow-up)
|
||||||
|
const corsForm = ref({ allow_all: false, origins: '' });
|
||||||
|
const corsErr = ref('');
|
||||||
|
const corsOk = ref(false);
|
||||||
|
const savingCors = ref(false);
|
||||||
|
const corsCurrentLabel = computed(() => {
|
||||||
|
if (!settings.value) return '未配置';
|
||||||
|
if (settings.value.cors_allow_all) return '允许所有来源(*)';
|
||||||
|
if (settings.value.cors_origins) return settings.value.cors_origins;
|
||||||
|
return '未配置(同源可用,跨域会被 403)';
|
||||||
|
});
|
||||||
const savingSettings = ref(false);
|
const savingSettings = ref(false);
|
||||||
const settingsErr = ref('');
|
const settingsErr = ref('');
|
||||||
const settingsOk = ref(false);
|
const settingsOk = ref(false);
|
||||||
@@ -399,9 +447,28 @@
|
|||||||
sample_rate: r.data.sample_rate || 24000,
|
sample_rate: r.data.sample_rate || 24000,
|
||||||
model: r.data.model || '',
|
model: r.data.model || '',
|
||||||
};
|
};
|
||||||
|
corsForm.value = {
|
||||||
|
allow_all: !!r.data.cors_allow_all,
|
||||||
|
origins: r.data.cors_origins || '',
|
||||||
|
};
|
||||||
settingsOk.value = false;
|
settingsOk.value = false;
|
||||||
} catch (e) { settingsErr.value = '加载设置失败: ' + (e.response?.data?.error?.message || e.message); }
|
} catch (e) { settingsErr.value = '加载设置失败: ' + (e.response?.data?.error?.message || e.message); }
|
||||||
};
|
};
|
||||||
|
const saveCors = async () => {
|
||||||
|
corsErr.value = ''; corsOk.value = false;
|
||||||
|
savingCors.value = true;
|
||||||
|
try {
|
||||||
|
await http.put('/settings/cors', {
|
||||||
|
allow_all: corsForm.value.allow_all,
|
||||||
|
origins: corsForm.value.origins,
|
||||||
|
});
|
||||||
|
await loadSettings();
|
||||||
|
corsOk.value = true;
|
||||||
|
setTimeout(() => corsOk.value = false, 3000);
|
||||||
|
} catch (e) {
|
||||||
|
corsErr.value = e.response?.data?.error?.message || e.message;
|
||||||
|
} finally { savingCors.value = false; }
|
||||||
|
};
|
||||||
const reloadAll = () => { loadOverview(); loadVoices(); };
|
const reloadAll = () => { loadOverview(); loadVoices(); };
|
||||||
|
|
||||||
const saveSettings = async () => {
|
const saveSettings = async () => {
|
||||||
@@ -498,6 +565,7 @@
|
|||||||
return { apiKey, keyInput, loginErr, login, logout, tab, overview, voices, actionErr,
|
return { apiKey, keyInput, loginErr, login, logout, tab, overview, voices, actionErr,
|
||||||
showAdd, form, addErr, adding, openAdd, submitAdd, toggle, remove,
|
showAdd, form, addErr, adding, openAdd, submitAdd, toggle, remove,
|
||||||
settings, settingsForm, apiKeyInput, authKeyInput, savingSettings, settingsErr, settingsOk,
|
settings, settingsForm, apiKeyInput, authKeyInput, savingSettings, settingsErr, settingsOk,
|
||||||
|
corsForm, corsErr, corsOk, savingCors, corsCurrentLabel, saveCors,
|
||||||
loadSettings, saveSettings, saveApiKey, saveAuthKey, resetSettingsForm,
|
loadSettings, saveSettings, saveApiKey, saveAuthKey, resetSettingsForm,
|
||||||
formatUptime, shortPath, reloadAll };
|
formatUptime, shortPath, reloadAll };
|
||||||
},
|
},
|
||||||
|
|||||||
@@ -85,6 +85,7 @@ func Setup() *mux.Router {
|
|||||||
r.Handle("/api/settings", middleware.RequireAdmin(http.HandlerFunc(controller.SettingsUpdateHandler))).Methods("PUT")
|
r.Handle("/api/settings", middleware.RequireAdmin(http.HandlerFunc(controller.SettingsUpdateHandler))).Methods("PUT")
|
||||||
r.Handle("/api/settings/api-key", middleware.RequireAdmin(http.HandlerFunc(controller.SettingsAPIKeyHandler))).Methods("PUT")
|
r.Handle("/api/settings/api-key", middleware.RequireAdmin(http.HandlerFunc(controller.SettingsAPIKeyHandler))).Methods("PUT")
|
||||||
r.Handle("/api/settings/auth-key", middleware.RequireAdmin(http.HandlerFunc(controller.SettingsAuthKeyHandler))).Methods("PUT")
|
r.Handle("/api/settings/auth-key", middleware.RequireAdmin(http.HandlerFunc(controller.SettingsAuthKeyHandler))).Methods("PUT")
|
||||||
|
r.Handle("/api/settings/cors", middleware.RequireAdmin(http.HandlerFunc(controller.SettingsCORSHandler))).Methods("PUT")
|
||||||
|
|
||||||
// 业务路由
|
// 业务路由
|
||||||
r.HandleFunc("/v1/audio/speech", controller.OpenaiTTSHandler).Methods("POST", "OPTIONS")
|
r.HandleFunc("/v1/audio/speech", controller.OpenaiTTSHandler).Methods("POST", "OPTIONS")
|
||||||
|
|||||||
@@ -127,6 +127,30 @@ func normalizeOrigin(origin string) string {
|
|||||||
return strings.ToLower(origin)
|
return strings.ToLower(origin)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// SplitOriginsForCORS 解析逗号/换行/空格分隔的 origins 列表,
|
||||||
|
// 全部小写、trim 末尾 / 后面统一比较。导出供 controller 复用
|
||||||
|
// (PUT /api/settings/cors 写完立即刷新 setting.CORS 用)。
|
||||||
|
func SplitOriginsForCORS(s string) []string {
|
||||||
|
return splitAndLowerOrigins(s)
|
||||||
|
}
|
||||||
|
|
||||||
|
// splitAndLowerOrigins 解析逗号/换行/空格分隔的 origins 列表,
|
||||||
|
// 全部小写、trim 末尾 / 后面统一比较(只在本包内用,外部用 SplitOriginsForCORS)。
|
||||||
|
// 实现细节:用 strings.FieldsFunc 切分,首尾 trim,末尾去 /。
|
||||||
|
func splitAndLowerOrigins(s string) []string {
|
||||||
|
parts := strings.FieldsFunc(s, func(r rune) bool {
|
||||||
|
return r == ',' || r == '\n' || r == ' ' || r == '\t'
|
||||||
|
})
|
||||||
|
out := make([]string, 0, len(parts))
|
||||||
|
for _, p := range parts {
|
||||||
|
p = strings.ToLower(strings.TrimRight(strings.TrimSpace(p), "/"))
|
||||||
|
if p != "" {
|
||||||
|
out = append(out, p)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return out
|
||||||
|
}
|
||||||
|
|
||||||
// LoadRuntimeConfig 从 store 加载 TTS 全局配置到 TTSOptions / TTSTimeout / Auth.APIKeys 内存。
|
// LoadRuntimeConfig 从 store 加载 TTS 全局配置到 TTSOptions / TTSTimeout / Auth.APIKeys 内存。
|
||||||
// 启动期(master 模式)调一次,或 PUT /api/settings 后调一次(改完立即生效)。
|
// 启动期(master 模式)调一次,或 PUT /api/settings 后调一次(改完立即生效)。
|
||||||
//
|
//
|
||||||
@@ -235,6 +259,32 @@ func LoadRuntimeConfig(s Store) error {
|
|||||||
Auth.APIKeys = nil
|
Auth.APIKeys = nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// CORS 配置:DB > env
|
||||||
|
// cors_allow_all (bool): 允许所有来源(*)
|
||||||
|
// cors_origins (string): 逗号分隔白名单
|
||||||
|
// 同源豁免由 middleware/cors.go 的 isSameOrigin 负责,DB 这里只管跨域名单
|
||||||
|
corsAllowAll, _ := s.SettingsGetBool("cors_allow_all", false)
|
||||||
|
if !corsAllowAll {
|
||||||
|
// env 兜底
|
||||||
|
if v := strings.ToLower(strings.TrimSpace(os.Getenv("CORS_ALLOW_ALL"))); v == "1" || v == "true" || v == "yes" {
|
||||||
|
corsAllowAll = true
|
||||||
|
}
|
||||||
|
}
|
||||||
|
originsStr := strings.TrimSpace(all["cors_origins"])
|
||||||
|
if originsStr == "" {
|
||||||
|
originsStr = os.Getenv("ALLOWED_ORIGINS")
|
||||||
|
}
|
||||||
|
if corsAllowAll {
|
||||||
|
CORS.AllowAll = true
|
||||||
|
CORS.Origins = nil
|
||||||
|
} else if originsStr != "" {
|
||||||
|
CORS.AllowAll = false
|
||||||
|
CORS.Origins = SplitOriginsForCORS(originsStr)
|
||||||
|
} else {
|
||||||
|
CORS.AllowAll = false
|
||||||
|
CORS.Origins = nil
|
||||||
|
}
|
||||||
|
|
||||||
TTSConfigErr = nil
|
TTSConfigErr = nil
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user