Compare commits

..

4 Commits

Author SHA1 Message Date
Nicolas Meienberger
59e997da26 fix: decoders two cases. With tinyauth prefix for env and without for flags 2025-10-29 21:05:21 +01:00
Nicolas Meienberger
9014be90aa refactor: ignore unknown flags instead of filtering manually 2025-10-29 18:50:42 +01:00
Nicolas Meienberger
f978ae155a feat: parse apps acl flags and env dynamically 2025-10-28 19:30:39 +01:00
Stavros
0227af6d2b refactor: rework decoders logic for cleaner code (#431)
* refactor: rework decoders logic for cleaner code

* refactor: use strcase lib to handle text case conversions
2025-10-26 12:01:19 +02:00
7 changed files with 230 additions and 53 deletions

View File

@@ -1,6 +1,7 @@
package cmd
import (
"os"
"strings"
"tinyauth/internal/bootstrap"
"tinyauth/internal/config"
@@ -14,15 +15,16 @@ import (
)
type rootCmd struct {
root *cobra.Command
cmd *cobra.Command
viper *viper.Viper
root *cobra.Command
cmd *cobra.Command
viper *viper.Viper
aclFlags map[string]string
}
func newRootCmd() *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",
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,
FParseErrWhitelist: cobra.FParseErrWhitelist{
UnknownFlags: true,
},
}
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!")
}
app := bootstrap.NewBootstrapApp(conf)
app := bootstrap.NewBootstrapApp(conf, c.aclFlags)
err = app.Setup()
if err != nil {
@@ -126,6 +131,8 @@ func (c *rootCmd) run(cmd *cobra.Command, args []string) {
func Run() {
rootCmd := newRootCmd()
rootCmd.aclFlags = utils.ExtractACLFlags(os.Args[1:])
rootCmd.Register()
root := rootCmd.GetCmd()

View File

@@ -37,13 +37,15 @@ type Service interface {
}
type BootstrapApp struct {
config config.Config
uuid string
config config.Config
aclFlags map[string]string
uuid string
}
func NewBootstrapApp(config config.Config) *BootstrapApp {
func NewBootstrapApp(config config.Config, aclFlags map[string]string) *BootstrapApp {
return &BootstrapApp{
config: config,
config: config,
aclFlags: aclFlags,
}
}
@@ -140,6 +142,7 @@ func (app *BootstrapApp) Setup() error {
// Create services
dockerService := service.NewDockerService()
aclsService := service.NewAccessControlsService(dockerService)
aclsService.SetACLFlags(app.aclFlags)
authService := service.NewAuthService(authConfig, dockerService, ldapService, database)
oauthBrokerService := service.NewOAuthBrokerService(oauthProviders)

View File

@@ -4,70 +4,39 @@ import (
"os"
"strings"
"tinyauth/internal/config"
"tinyauth/internal/utils/decoders"
"tinyauth/internal/utils"
"github.com/rs/zerolog/log"
)
type AccessControlsService struct {
docker *DockerService
envACLs config.Apps
docker *DockerService
envACLs config.Apps
aclFlags map[string]string
}
func NewAccessControlsService(docker *DockerService) *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 {
acls.envACLs = config.Apps{}
env := os.Environ()
appEnvVars := []string{}
for _, e := range env {
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)
apps, err := utils.GetACLsConfig(env, acls.aclFlags)
if err != nil {
return err
}
acls.envACLs = apps
return nil
}

View File

@@ -208,3 +208,53 @@ func GetOAuthProvidersConfig(env []string, args []string, appUrl string) (map[st
// Return combined providers
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
}

View File

@@ -7,6 +7,71 @@ import (
"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 {
knownKeys := getKnownKeys[T]()
normalized := make(map[string]string)
@@ -74,3 +139,57 @@ func getKnownKeys[T any]() []string {
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
}

View File

@@ -17,3 +17,17 @@ func DecodeEnv[T any, C any](env map[string]string, subName string) (T, error) {
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
}

View File

@@ -21,6 +21,21 @@ func DecodeFlags[T any, C any](flags map[string]string, subName string) (T, erro
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 {
filtered := make(map[string]string)
for k, v := range flags {