mirror of
https://github.com/steveiliop56/tinyauth.git
synced 2025-11-07 09:35:44 +00:00
Compare commits
4 Commits
refactor/d
...
refactor/a
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
59e997da26 | ||
|
|
9014be90aa | ||
|
|
f978ae155a | ||
|
|
0227af6d2b |
11
cmd/root.go
11
cmd/root.go
@@ -1,6 +1,7 @@
|
|||||||
package cmd
|
package cmd
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"os"
|
||||||
"strings"
|
"strings"
|
||||||
"tinyauth/internal/bootstrap"
|
"tinyauth/internal/bootstrap"
|
||||||
"tinyauth/internal/config"
|
"tinyauth/internal/config"
|
||||||
@@ -16,13 +17,14 @@ import (
|
|||||||
type rootCmd struct {
|
type rootCmd struct {
|
||||||
root *cobra.Command
|
root *cobra.Command
|
||||||
cmd *cobra.Command
|
cmd *cobra.Command
|
||||||
|
|
||||||
viper *viper.Viper
|
viper *viper.Viper
|
||||||
|
aclFlags map[string]string
|
||||||
}
|
}
|
||||||
|
|
||||||
func newRootCmd() *rootCmd {
|
func newRootCmd() *rootCmd {
|
||||||
return &rootCmd{
|
return &rootCmd{
|
||||||
viper: viper.New(),
|
viper: viper.New(),
|
||||||
|
aclFlags: make(map[string]string),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -32,6 +34,9 @@ func (c *rootCmd) Register() {
|
|||||||
Short: "The simplest way to protect your apps with a login screen",
|
Short: "The simplest way to protect your apps with a login screen",
|
||||||
Long: `Tinyauth is a simple authentication middleware that adds a simple login screen or OAuth with Google, Github or any other provider to all of your docker apps.`,
|
Long: `Tinyauth is a simple authentication middleware that adds a simple login screen or OAuth with Google, Github or any other provider to all of your docker apps.`,
|
||||||
Run: c.run,
|
Run: c.run,
|
||||||
|
FParseErrWhitelist: cobra.FParseErrWhitelist{
|
||||||
|
UnknownFlags: true,
|
||||||
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
c.viper.AutomaticEnv()
|
c.viper.AutomaticEnv()
|
||||||
@@ -116,7 +121,7 @@ func (c *rootCmd) run(cmd *cobra.Command, args []string) {
|
|||||||
log.Warn().Msg("Log level set to trace, this will log sensitive information!")
|
log.Warn().Msg("Log level set to trace, this will log sensitive information!")
|
||||||
}
|
}
|
||||||
|
|
||||||
app := bootstrap.NewBootstrapApp(conf)
|
app := bootstrap.NewBootstrapApp(conf, c.aclFlags)
|
||||||
|
|
||||||
err = app.Setup()
|
err = app.Setup()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -126,6 +131,8 @@ func (c *rootCmd) run(cmd *cobra.Command, args []string) {
|
|||||||
|
|
||||||
func Run() {
|
func Run() {
|
||||||
rootCmd := newRootCmd()
|
rootCmd := newRootCmd()
|
||||||
|
rootCmd.aclFlags = utils.ExtractACLFlags(os.Args[1:])
|
||||||
|
|
||||||
rootCmd.Register()
|
rootCmd.Register()
|
||||||
root := rootCmd.GetCmd()
|
root := rootCmd.GetCmd()
|
||||||
|
|
||||||
|
|||||||
@@ -38,12 +38,14 @@ type Service interface {
|
|||||||
|
|
||||||
type BootstrapApp struct {
|
type BootstrapApp struct {
|
||||||
config config.Config
|
config config.Config
|
||||||
|
aclFlags map[string]string
|
||||||
uuid string
|
uuid string
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewBootstrapApp(config config.Config) *BootstrapApp {
|
func NewBootstrapApp(config config.Config, aclFlags map[string]string) *BootstrapApp {
|
||||||
return &BootstrapApp{
|
return &BootstrapApp{
|
||||||
config: config,
|
config: config,
|
||||||
|
aclFlags: aclFlags,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -140,6 +142,7 @@ func (app *BootstrapApp) Setup() error {
|
|||||||
// Create services
|
// Create services
|
||||||
dockerService := service.NewDockerService()
|
dockerService := service.NewDockerService()
|
||||||
aclsService := service.NewAccessControlsService(dockerService)
|
aclsService := service.NewAccessControlsService(dockerService)
|
||||||
|
aclsService.SetACLFlags(app.aclFlags)
|
||||||
authService := service.NewAuthService(authConfig, dockerService, ldapService, database)
|
authService := service.NewAuthService(authConfig, dockerService, ldapService, database)
|
||||||
oauthBrokerService := service.NewOAuthBrokerService(oauthProviders)
|
oauthBrokerService := service.NewOAuthBrokerService(oauthProviders)
|
||||||
|
|
||||||
|
|||||||
@@ -4,7 +4,7 @@ import (
|
|||||||
"os"
|
"os"
|
||||||
"strings"
|
"strings"
|
||||||
"tinyauth/internal/config"
|
"tinyauth/internal/config"
|
||||||
"tinyauth/internal/utils/decoders"
|
"tinyauth/internal/utils"
|
||||||
|
|
||||||
"github.com/rs/zerolog/log"
|
"github.com/rs/zerolog/log"
|
||||||
)
|
)
|
||||||
@@ -12,62 +12,31 @@ import (
|
|||||||
type AccessControlsService struct {
|
type AccessControlsService struct {
|
||||||
docker *DockerService
|
docker *DockerService
|
||||||
envACLs config.Apps
|
envACLs config.Apps
|
||||||
|
aclFlags map[string]string
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewAccessControlsService(docker *DockerService) *AccessControlsService {
|
func NewAccessControlsService(docker *DockerService) *AccessControlsService {
|
||||||
return &AccessControlsService{
|
return &AccessControlsService{
|
||||||
docker: docker,
|
docker: docker,
|
||||||
|
aclFlags: make(map[string]string),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (acls *AccessControlsService) SetACLFlags(flags map[string]string) {
|
||||||
|
acls.aclFlags = flags
|
||||||
|
}
|
||||||
|
|
||||||
func (acls *AccessControlsService) Init() error {
|
func (acls *AccessControlsService) Init() error {
|
||||||
acls.envACLs = config.Apps{}
|
|
||||||
env := os.Environ()
|
env := os.Environ()
|
||||||
appEnvVars := []string{}
|
|
||||||
|
|
||||||
for _, e := range env {
|
apps, err := utils.GetACLsConfig(env, acls.aclFlags)
|
||||||
if strings.HasPrefix(e, "TINYAUTH_APPS_") {
|
|
||||||
appEnvVars = append(appEnvVars, e)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
err := acls.loadEnvACLs(appEnvVars)
|
|
||||||
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (acls *AccessControlsService) loadEnvACLs(appEnvVars []string) error {
|
|
||||||
if len(appEnvVars) == 0 {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
envAcls := map[string]string{}
|
|
||||||
|
|
||||||
for _, e := range appEnvVars {
|
|
||||||
parts := strings.SplitN(e, "=", 2)
|
|
||||||
if len(parts) != 2 {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
|
|
||||||
// Normalize key, this should use the same normalization logic as in utils/decoders/decoders.go
|
|
||||||
key := parts[0]
|
|
||||||
key = strings.ToLower(key)
|
|
||||||
key = strings.ReplaceAll(key, "_", ".")
|
|
||||||
value := parts[1]
|
|
||||||
envAcls[key] = value
|
|
||||||
}
|
|
||||||
|
|
||||||
apps, err := decoders.DecodeLabels(envAcls)
|
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
acls.envACLs = apps
|
acls.envACLs = apps
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -208,3 +208,53 @@ func GetOAuthProvidersConfig(env []string, args []string, appUrl string) (map[st
|
|||||||
// Return combined providers
|
// Return combined providers
|
||||||
return providers, nil
|
return providers, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func GetACLsConfig(env []string, flagsMap map[string]string) (config.Apps, error) {
|
||||||
|
apps := config.Apps{Apps: make(map[string]config.App)}
|
||||||
|
|
||||||
|
envMap := make(map[string]string)
|
||||||
|
|
||||||
|
for _, e := range env {
|
||||||
|
pair := strings.SplitN(e, "=", 2)
|
||||||
|
if len(pair) == 2 {
|
||||||
|
envMap[pair[0]] = pair[1]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
envApps, err := decoders.DecodeACLEnv[config.Apps](envMap, "apps")
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
return config.Apps{}, err
|
||||||
|
}
|
||||||
|
|
||||||
|
if envApps.Apps != nil {
|
||||||
|
maps.Copy(apps.Apps, envApps.Apps)
|
||||||
|
}
|
||||||
|
|
||||||
|
flagApps, err := decoders.DecodeACLFlags[config.Apps](flagsMap, "apps")
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
return config.Apps{}, err
|
||||||
|
}
|
||||||
|
|
||||||
|
if flagApps.Apps != nil {
|
||||||
|
maps.Copy(apps.Apps, flagApps.Apps)
|
||||||
|
}
|
||||||
|
|
||||||
|
return apps, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func ExtractACLFlags(args []string) map[string]string {
|
||||||
|
aclFlags := make(map[string]string)
|
||||||
|
|
||||||
|
for _, arg := range args {
|
||||||
|
if strings.HasPrefix(arg, "--apps-") || strings.HasPrefix(arg, "--tinyauth-apps-") {
|
||||||
|
pair := strings.SplitN(arg[2:], "=", 2)
|
||||||
|
if len(pair) == 2 {
|
||||||
|
aclFlags[pair[0]] = pair[1]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return aclFlags
|
||||||
|
}
|
||||||
|
|||||||
@@ -7,6 +7,71 @@ import (
|
|||||||
"github.com/stoewer/go-strcase"
|
"github.com/stoewer/go-strcase"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
func ParsePath(parts []string, idx int, t reflect.Type) []string {
|
||||||
|
if idx >= len(parts) {
|
||||||
|
return []string{}
|
||||||
|
}
|
||||||
|
|
||||||
|
if t.Kind() == reflect.Map {
|
||||||
|
|
||||||
|
if idx >= len(parts) {
|
||||||
|
return []string{}
|
||||||
|
}
|
||||||
|
|
||||||
|
elemType := t.Elem()
|
||||||
|
keyEndIdx := idx + 1
|
||||||
|
|
||||||
|
if elemType.Kind() == reflect.Struct {
|
||||||
|
for i := idx + 1; i < len(parts); i++ {
|
||||||
|
found := false
|
||||||
|
|
||||||
|
for j := 0; j < elemType.NumField(); j++ {
|
||||||
|
field := elemType.Field(j)
|
||||||
|
if strings.EqualFold(parts[i], field.Name) {
|
||||||
|
keyEndIdx = i
|
||||||
|
found = true
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if found {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
keyParts := parts[idx:keyEndIdx]
|
||||||
|
keyName := strings.ToLower(strings.Join(keyParts, "_"))
|
||||||
|
|
||||||
|
rest := ParsePath(parts, keyEndIdx, elemType)
|
||||||
|
result := append([]string{keyName}, rest...)
|
||||||
|
return result
|
||||||
|
}
|
||||||
|
|
||||||
|
if t.Kind() == reflect.Struct {
|
||||||
|
for i := 0; i < t.NumField(); i++ {
|
||||||
|
field := t.Field(i)
|
||||||
|
if field.Type.Kind() == reflect.Map {
|
||||||
|
rest := ParsePath(parts, idx, field.Type)
|
||||||
|
if len(rest) > 0 {
|
||||||
|
return rest
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
for i := 0; i < t.NumField(); i++ {
|
||||||
|
field := t.Field(i)
|
||||||
|
if strings.EqualFold(parts[idx], field.Name) {
|
||||||
|
rest := ParsePath(parts, idx+1, field.Type)
|
||||||
|
result := append([]string{strings.ToLower(field.Name)}, rest...)
|
||||||
|
return result
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return []string{}
|
||||||
|
}
|
||||||
|
|
||||||
func normalizeKeys[T any](input map[string]string, root string, sep string) map[string]string {
|
func normalizeKeys[T any](input map[string]string, root string, sep string) map[string]string {
|
||||||
knownKeys := getKnownKeys[T]()
|
knownKeys := getKnownKeys[T]()
|
||||||
normalized := make(map[string]string)
|
normalized := make(map[string]string)
|
||||||
@@ -74,3 +139,57 @@ func getKnownKeys[T any]() []string {
|
|||||||
|
|
||||||
return keys
|
return keys
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func normalizeACLKeys[T any](input map[string]string, root string, sep string) map[string]string {
|
||||||
|
normalized := make(map[string]string)
|
||||||
|
var t T
|
||||||
|
rootType := reflect.TypeOf(t)
|
||||||
|
|
||||||
|
for k, v := range input {
|
||||||
|
parts := strings.Split(strings.ToLower(k), sep)
|
||||||
|
|
||||||
|
if len(parts) < 2 {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
// Two cases:
|
||||||
|
// 1. Keys starting with "tinyauth" (env vars): tinyauth_apps_...
|
||||||
|
// 2. Keys starting with root directly (flags): apps-...
|
||||||
|
startIdx := 0
|
||||||
|
if parts[0] == "tinyauth" {
|
||||||
|
if len(parts) < 3 {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
if parts[1] != root {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
startIdx = 2 // Skip "tinyauth" and root
|
||||||
|
} else if parts[0] == root {
|
||||||
|
startIdx = 1 // Skip root only
|
||||||
|
} else {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
if startIdx < len(parts) {
|
||||||
|
parsedParts := ParsePath(parts[startIdx:], 0, rootType)
|
||||||
|
|
||||||
|
if len(parsedParts) == 0 {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
final := "tinyauth." + root
|
||||||
|
|
||||||
|
for _, part := range parsedParts {
|
||||||
|
if strings.Contains(part, "_") {
|
||||||
|
final += "." + part
|
||||||
|
} else {
|
||||||
|
final += "." + strcase.LowerCamelCase(part)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
normalized[final] = v
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return normalized
|
||||||
|
}
|
||||||
|
|||||||
@@ -17,3 +17,17 @@ func DecodeEnv[T any, C any](env map[string]string, subName string) (T, error) {
|
|||||||
|
|
||||||
return result, nil
|
return result, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func DecodeACLEnv[T any](env map[string]string, subName string) (T, error) {
|
||||||
|
var result T
|
||||||
|
|
||||||
|
normalized := normalizeACLKeys[T](env, subName, "_")
|
||||||
|
|
||||||
|
err := parser.Decode(normalized, &result, "tinyauth", "tinyauth."+subName)
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
return result, err
|
||||||
|
}
|
||||||
|
|
||||||
|
return result, nil
|
||||||
|
}
|
||||||
|
|||||||
@@ -21,6 +21,21 @@ func DecodeFlags[T any, C any](flags map[string]string, subName string) (T, erro
|
|||||||
return result, nil
|
return result, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func DecodeACLFlags[T any](flags map[string]string, subName string) (T, error) {
|
||||||
|
var result T
|
||||||
|
|
||||||
|
filtered := filterFlags(flags)
|
||||||
|
normalized := normalizeACLKeys[T](filtered, subName, "-")
|
||||||
|
|
||||||
|
err := parser.Decode(normalized, &result, "tinyauth", "tinyauth."+subName)
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
return result, err
|
||||||
|
}
|
||||||
|
|
||||||
|
return result, nil
|
||||||
|
}
|
||||||
|
|
||||||
func filterFlags(flags map[string]string) map[string]string {
|
func filterFlags(flags map[string]string) map[string]string {
|
||||||
filtered := make(map[string]string)
|
filtered := make(map[string]string)
|
||||||
for k, v := range flags {
|
for k, v := range flags {
|
||||||
|
|||||||
Reference in New Issue
Block a user