mirror of
https://github.com/hanzoai/ingress.git
synced 2026-10-26 02:47:15 +00:00
zeekay
ee53f0bd67
- CRD API group: traefik.io -> hanzo.ai (GroupName, apiVersion, RBAC)
- Docker/provider label prefix: traefik.* -> ingress.* (all providers)
- CRD kind: TraefikService -> IngressService
- Directory renames: traefikio/ -> hanzoai/ (types, generated code, listers, informers, clientset)
- Config root name: traefik -> ingress (KV stores, file paths, env prefix)
- Metrics prefix: traefik_ -> ingress_
- Kubernetes annotations: traefik.ingress.kubernetes.io/ -> ingress.kubernetes.io/
- Gateway annotations: traefik.io/ -> hanzo.ai/
- Internal provider package: provider/traefik -> provider/builtins
- Type renames: TraefikLog -> IngressLog, TraefikCmdConfiguration -> IngressCmdConfiguration
- Generated client methods: TraefikV1alpha1() -> HanzoV1alpha1(), Traefik() -> Hanzo()
- Sample configs: traefik.sample.{toml,yml} -> ingress.sample.{toml,yml}
- Config paths: /etc/traefik/ -> /etc/ingress/, ~/.config/traefik -> ~/.config/ingress
- Default cert CN: TRAEFIK DEFAULT CERT -> INGRESS DEFAULT CERT
66 lines
1.4 KiB
Go
66 lines
1.4 KiB
Go
package auth
|
|
|
|
import (
|
|
"os"
|
|
"strings"
|
|
)
|
|
|
|
// UserParser Parses a string and return a userName/userHash. An error if the format of the string is incorrect.
|
|
type UserParser func(user string) (string, string, error)
|
|
|
|
const (
|
|
defaultRealm = "ingress"
|
|
authorizationHeader = "Authorization"
|
|
)
|
|
|
|
func getUsers(fileName string, appendUsers []string, parser UserParser) (map[string]string, error) {
|
|
users, err := loadUsers(fileName, appendUsers)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
userMap := make(map[string]string)
|
|
for _, user := range users {
|
|
userName, userHash, err := parser(user)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
userMap[userName] = userHash
|
|
}
|
|
|
|
return userMap, nil
|
|
}
|
|
|
|
func loadUsers(fileName string, appendUsers []string) ([]string, error) {
|
|
var users []string
|
|
var err error
|
|
|
|
if fileName != "" {
|
|
users, err = getLinesFromFile(fileName)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
}
|
|
|
|
return append(users, appendUsers...), nil
|
|
}
|
|
|
|
func getLinesFromFile(filename string) ([]string, error) {
|
|
dat, err := os.ReadFile(filename)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// Trim lines and filter out blanks
|
|
rawLines := strings.Split(string(dat), "\n")
|
|
var filteredLines []string
|
|
for _, rawLine := range rawLines {
|
|
line := strings.TrimSpace(rawLine)
|
|
if line != "" && !strings.HasPrefix(line, "#") {
|
|
filteredLines = append(filteredLines, line)
|
|
}
|
|
}
|
|
|
|
return filteredLines, nil
|
|
}
|