tbphp
4f9eba5802
* feat(proxy): 实现第一阶段数据面代理 * feat(proxy): 收敛渠道与代理协议支持 * fix(proxy): 修复环境检测与迁移验证 * fix(proxy): 回收旧代理运行时并校验地址 * fix(proxy): 补齐创建链路与前端校验 * fix(proxy): 收口订阅代理与迁移兼容 * fix(proxy): 修复环境代理与运行时回收 * fix(proxy): 为系统外部请求应用全局代理 * docs(config): 精简环境配置说明 * feat(proxy): 重构代理设置的前端交互与样式 设置页与分组设置页： - 代理设置接入页面统一的草稿态与保存栏，不再独立即时提交 - 计入页面 dirty/valid，参与未保存离开拦截与并发冲突推迟 - 新增 ProxyOverrideRow，用分段控件替代原独立编辑弹层 账号卡片与密钥行： - ProxyConfigEditor 新增 card 外观：标题在白底面板外，与相邻小节同级 - 修掉按视口宽度判断断点的问题，窄容器内不再挤压错乱 - 编辑态下拉固定宽度，不随所选模式伸缩；整体收进两行 - 新增 ProxyScopeIndicator，凭据配置了独立代理时给出标识与悬停提示 密钥行交互： - 操作列收成「更多操作」菜单与展开图标，与账号卡片同构 - 折叠区分为权重、出站代理、运行诊断三个带标题小节，设置与诊断不再混放 - 权重编辑从弹层迁入折叠区，权重列的值可点击直达 - 释放的列宽还给凭据、权重与最近调用列 文案精简为继承、直连、自定义，并清理两处无引用的死键 * refactor(proxy): 统一代理设置的覆盖交互并消除样式重复 设置页与分组设置页： - 代理行改用 RuntimeOverrideRow，与超时等设置项共用同一组件 - inherit 映射为“未覆盖”，direct/custom 映射为“显式覆盖”，因此补齐了 覆盖/恢复默认按钮、覆盖状态徽章、当前有效值与待恢复默认态 - 分段控件只保留直连与自定义，继承由外层覆盖开关表达 - 删除自造的 ProxyOverrideRow，新增只含编辑控件的 ProxyOverrideControl 已保存的自定义地址： - 输入框不做回填，统一由 placeholder 展示已存地址 - 同模式下留空或与已存地址逐字相同均视为未改动，顺带挡住掩码被当作 新密码存回；无改动时保存按钮禁用 - 重新开启覆盖时回到基线已存的覆盖模式，使恢复默认可原路撤销 代码质量： - 面板外壳（标题 + 白底面板 + 标签/值/编辑图标/操作）抽为全局 .setting-panel，代理、权重、诊断三处共用，不再各写一份 - 删除 ProxyConfigEditor 已无调用方的 row 外观及随之失效的 props、 徽章分支与始终隐藏的文案 - 占位地址推导与覆盖开关规则收敛为 proxy.ts 中的共享函数 - 移除代理输入提示文案及其失去引用的 i18n 键 密钥行折叠区诊断值字号对齐上方面板。重构以构建产物 CSS 逐条比对验证， 差异均为已论证的等价改写。 * fix(proxy): 修复代理传输与校验边界
72 lines
2.4 KiB
Go
72 lines
2.4 KiB
Go
package gateway
|
|
|
|
import (
|
|
"crypto/subtle"
|
|
"fmt"
|
|
|
|
"gpt-load/internal/outboundproxy"
|
|
"gpt-load/internal/platform/encryption"
|
|
"gpt-load/internal/state"
|
|
)
|
|
|
|
func resolveAttemptProxy(
|
|
encryptionService encryption.Service,
|
|
groupProxy outboundproxy.Effective,
|
|
ref state.CredentialRef,
|
|
) (outboundproxy.Effective, string, error) {
|
|
if encryptionService == nil {
|
|
return outboundproxy.Effective{}, "", fmt.Errorf("proxy encryption service is unavailable")
|
|
}
|
|
groupProxy, err := outboundproxy.NormalizeEffective(groupProxy)
|
|
if err != nil {
|
|
return outboundproxy.Effective{}, "", fmt.Errorf("group proxy config is invalid")
|
|
}
|
|
if ref.EncryptedProxy == "" {
|
|
if ref.ProxyFingerprint != "" {
|
|
return outboundproxy.Effective{}, "", fmt.Errorf("credential proxy identity is invalid")
|
|
}
|
|
fingerprint, err := effectiveProxyFingerprint(encryptionService, groupProxy)
|
|
return groupProxy, fingerprint, err
|
|
}
|
|
if ref.ProxyFingerprint == "" {
|
|
return outboundproxy.Effective{}, "", fmt.Errorf("credential proxy identity is invalid")
|
|
}
|
|
plaintext, err := encryptionService.Decrypt(ref.EncryptedProxy)
|
|
if err != nil {
|
|
return outboundproxy.Effective{}, "", fmt.Errorf("decrypt credential proxy config")
|
|
}
|
|
fingerprint := encryptionService.Hash(plaintext)
|
|
if subtle.ConstantTimeCompare([]byte(fingerprint), []byte(ref.ProxyFingerprint)) != 1 {
|
|
plaintext = ""
|
|
return outboundproxy.Effective{}, "", fmt.Errorf("credential proxy fingerprint mismatch")
|
|
}
|
|
config, err := outboundproxy.Decode(plaintext)
|
|
plaintext = ""
|
|
if err != nil || config.Mode == outboundproxy.ModeInherit {
|
|
return outboundproxy.Effective{}, "", fmt.Errorf("credential proxy config is invalid")
|
|
}
|
|
effective, err := outboundproxy.Resolve(&config, nil, nil, nil)
|
|
if err != nil {
|
|
return outboundproxy.Effective{}, "", fmt.Errorf("credential proxy config is invalid")
|
|
}
|
|
return effective, fingerprint, nil
|
|
}
|
|
|
|
func effectiveProxyFingerprint(
|
|
encryptionService encryption.Service,
|
|
effective outboundproxy.Effective,
|
|
) (string, error) {
|
|
effective, err := outboundproxy.NormalizeEffective(effective)
|
|
if err != nil {
|
|
return "", fmt.Errorf("proxy config is invalid")
|
|
}
|
|
if effective.Config.Mode == outboundproxy.ModeEnvironment {
|
|
return encryptionService.Hash(`{"mode":"environment"}`), nil
|
|
}
|
|
encoded, err := outboundproxy.Encode(effective.Config)
|
|
if err != nil {
|
|
return "", fmt.Errorf("proxy config is invalid")
|
|
}
|
|
return encryptionService.Hash(encoded), nil
|
|
}
|