28e53d90fc
- 统一 OpenAI 兼容 /v1 中继 + 渠道/额度/令牌/流水 - 各领域包:relay 模型网关、model 数据层、controller 管理 API
135 lines
4.0 KiB
Go
135 lines
4.0 KiB
Go
package kitutil
|
|
|
|
import (
|
|
"net/url"
|
|
"regexp"
|
|
"strings"
|
|
)
|
|
|
|
var (
|
|
maskURLPattern = regexp.MustCompile(`(http|https)://[^\s/$.?#].[^\s]*`)
|
|
maskDomainPattern = regexp.MustCompile(`\b(?:[a-zA-Z0-9](?:[a-zA-Z0-9-]{0,61}[a-zA-Z0-9])?\.)+[a-zA-Z]{2,}\b`)
|
|
maskIPPattern = regexp.MustCompile(`\b(?:\d{1,3}\.){3}\d{1,3}\b`)
|
|
// maskApiKeyPattern matches patterns like 'api_key:xxx' or "api_key:xxx" to mask the API key value
|
|
maskApiKeyPattern = regexp.MustCompile(`(['"]?)api_key:([^\s'"]+)(['"]?)`)
|
|
)
|
|
|
|
// maskHostTail returns the tail parts of a domain/host that should be preserved.
|
|
// It keeps 2 parts for likely country-code TLDs (e.g., co.uk, com.cn), otherwise keeps only the TLD.
|
|
func maskHostTail(parts []string) []string {
|
|
if len(parts) < 2 {
|
|
return parts
|
|
}
|
|
lastPart := parts[len(parts)-1]
|
|
secondLastPart := parts[len(parts)-2]
|
|
if len(lastPart) == 2 && len(secondLastPart) <= 3 {
|
|
// Likely country code TLD like co.uk, com.cn
|
|
return []string{secondLastPart, lastPart}
|
|
}
|
|
return []string{lastPart}
|
|
}
|
|
|
|
// maskHostForURL collapses subdomains and keeps only masked prefix + preserved tail.
|
|
// Example: api.openai.com -> ***.com, sub.domain.co.uk -> ***.co.uk
|
|
func maskHostForURL(host string) string {
|
|
parts := strings.Split(host, ".")
|
|
if len(parts) < 2 {
|
|
return "***"
|
|
}
|
|
tail := maskHostTail(parts)
|
|
return "***." + strings.Join(tail, ".")
|
|
}
|
|
|
|
// maskHostForPlainDomain masks a plain domain and reflects subdomain depth with multiple ***.
|
|
// Example: openai.com -> ***.com, api.openai.com -> ***.***.com, sub.domain.co.uk -> ***.***.co.uk
|
|
func maskHostForPlainDomain(domain string) string {
|
|
parts := strings.Split(domain, ".")
|
|
if len(parts) < 2 {
|
|
return domain
|
|
}
|
|
tail := maskHostTail(parts)
|
|
numStars := len(parts) - len(tail)
|
|
if numStars < 1 {
|
|
numStars = 1
|
|
}
|
|
stars := strings.TrimSuffix(strings.Repeat("***.", numStars), ".")
|
|
return stars + "." + strings.Join(tail, ".")
|
|
}
|
|
|
|
// MaskSensitiveInfo masks sensitive information like URLs, IPs, and domain names in a string
|
|
// Example:
|
|
// http://example.com -> http://***.com
|
|
// https://api.test.org/v1/users/123?key=secret -> https://***.org/***/***/?key=***
|
|
// https://sub.domain.co.uk/path/to/resource -> https://***.co.uk/***/***
|
|
// 192.168.1.1 -> ***.***.***.***
|
|
// openai.com -> ***.com
|
|
// www.openai.com -> ***.***.com
|
|
// api.openai.com -> ***.***.com
|
|
func MaskSensitiveInfo(str string) string {
|
|
// Mask URLs
|
|
str = maskURLPattern.ReplaceAllStringFunc(str, func(urlStr string) string {
|
|
u, err := url.Parse(urlStr)
|
|
if err != nil {
|
|
return urlStr
|
|
}
|
|
|
|
host := u.Host
|
|
if host == "" {
|
|
return urlStr
|
|
}
|
|
|
|
// Mask host with unified logic
|
|
maskedHost := maskHostForURL(host)
|
|
|
|
result := u.Scheme + "://" + maskedHost
|
|
|
|
// Mask path
|
|
if u.Path != "" && u.Path != "/" {
|
|
pathParts := strings.Split(strings.Trim(u.Path, "/"), "/")
|
|
maskedPathParts := make([]string, len(pathParts))
|
|
for i := range pathParts {
|
|
if pathParts[i] != "" {
|
|
maskedPathParts[i] = "***"
|
|
}
|
|
}
|
|
if len(maskedPathParts) > 0 {
|
|
result += "/" + strings.Join(maskedPathParts, "/")
|
|
}
|
|
} else if u.Path == "/" {
|
|
result += "/"
|
|
}
|
|
|
|
// Mask query parameters
|
|
if u.RawQuery != "" {
|
|
values, err := url.ParseQuery(u.RawQuery)
|
|
if err != nil {
|
|
// If can't parse query, just mask the whole query string
|
|
result += "?***"
|
|
} else {
|
|
maskedParams := make([]string, 0, len(values))
|
|
for key := range values {
|
|
maskedParams = append(maskedParams, key+"=***")
|
|
}
|
|
if len(maskedParams) > 0 {
|
|
result += "?" + strings.Join(maskedParams, "&")
|
|
}
|
|
}
|
|
}
|
|
|
|
return result
|
|
})
|
|
|
|
// Mask domain names without protocol (like openai.com, www.openai.com)
|
|
str = maskDomainPattern.ReplaceAllStringFunc(str, func(domain string) string {
|
|
return maskHostForPlainDomain(domain)
|
|
})
|
|
|
|
// Mask IP addresses
|
|
str = maskIPPattern.ReplaceAllString(str, "***.***.***.***")
|
|
|
|
// Mask API keys (e.g., "api_key:AIzaSyAAAaUooTUni8AdaOkSRMda30n_Q4vrV70" -> "api_key:***")
|
|
str = maskApiKeyPattern.ReplaceAllString(str, "${1}api_key:***${3}")
|
|
|
|
return str
|
|
}
|