mirror of
				https://github.com/steveiliop56/tinyauth.git
				synced 2025-10-31 06:05:43 +00:00 
			
		
		
		
	Compare commits
	
		
			1 Commits
		
	
	
		
			feat/light
			...
			l10n_main
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
|   | 8aacadbb25 | 
| @@ -12,7 +12,7 @@ | |||||||
|     <link rel="manifest" href="/site.webmanifest" /> |     <link rel="manifest" href="/site.webmanifest" /> | ||||||
|     <title>Tinyauth</title> |     <title>Tinyauth</title> | ||||||
|   </head> |   </head> | ||||||
|   <body> |   <body class="dark"> | ||||||
|     <div id="root"></div> |     <div id="root"></div> | ||||||
|     <script type="module" src="/src/main.tsx"></script> |     <script type="module" src="/src/main.tsx"></script> | ||||||
|   </body> |   </body> | ||||||
|   | |||||||
| @@ -18,10 +18,9 @@ export const LanguageSelector = () => { | |||||||
|     setLanguage(option as SupportedLanguage); |     setLanguage(option as SupportedLanguage); | ||||||
|     i18n.changeLanguage(option as SupportedLanguage); |     i18n.changeLanguage(option as SupportedLanguage); | ||||||
|   }; |   }; | ||||||
|  |  | ||||||
|   return ( |   return ( | ||||||
|     <Select onValueChange={handleSelect} value={language}> |     <Select onValueChange={handleSelect} value={language}> | ||||||
|       <SelectTrigger className="bg-card"> |       <SelectTrigger className="absolute top-5 right-5"> | ||||||
|         <SelectValue placeholder="Select language" /> |         <SelectValue placeholder="Select language" /> | ||||||
|       </SelectTrigger> |       </SelectTrigger> | ||||||
|       <SelectContent> |       <SelectContent> | ||||||
|   | |||||||
| @@ -3,7 +3,6 @@ import { LanguageSelector } from "../language/language"; | |||||||
| import { Outlet } from "react-router"; | import { Outlet } from "react-router"; | ||||||
| import { useCallback, useEffect, useState } from "react"; | import { useCallback, useEffect, useState } from "react"; | ||||||
| import { DomainWarning } from "../domain-warning/domain-warning"; | import { DomainWarning } from "../domain-warning/domain-warning"; | ||||||
| import { ThemeSwitch } from "../theme-switch/theme-switch"; |  | ||||||
|  |  | ||||||
| const BaseLayout = ({ children }: { children: React.ReactNode }) => { | const BaseLayout = ({ children }: { children: React.ReactNode }) => { | ||||||
|   const { backgroundImage, title } = useAppContext(); |   const { backgroundImage, title } = useAppContext(); | ||||||
| @@ -21,10 +20,7 @@ const BaseLayout = ({ children }: { children: React.ReactNode }) => { | |||||||
|         backgroundPosition: "center", |         backgroundPosition: "center", | ||||||
|       }} |       }} | ||||||
|     > |     > | ||||||
|       <div className="absolute top-5 right-5 flex flex-row gap-2"> |       <LanguageSelector /> | ||||||
|         <ThemeSwitch /> |  | ||||||
|         <LanguageSelector /> |  | ||||||
|       </div> |  | ||||||
|       {children} |       {children} | ||||||
|     </div> |     </div> | ||||||
|   ); |   ); | ||||||
|   | |||||||
| @@ -1,53 +0,0 @@ | |||||||
| import React from "react"; |  | ||||||
| import { createContext, useEffect, useState } from "react"; |  | ||||||
|  |  | ||||||
| interface ThemeSchema { |  | ||||||
|   darkMode: boolean; |  | ||||||
|   setDarkMode: (darkMode: boolean) => void; |  | ||||||
| } |  | ||||||
|  |  | ||||||
| const ThemeContext = createContext<ThemeSchema | null>(null); |  | ||||||
|  |  | ||||||
| export const ThemeProvider = ({ children }: { children: React.ReactNode }) => { |  | ||||||
|   const [darkMode, setDarkMode] = useState<boolean>(false); |  | ||||||
|  |  | ||||||
|   useEffect(() => { |  | ||||||
|     const storedTheme = localStorage.getItem("tinyauth-theme"); |  | ||||||
|     if (storedTheme) { |  | ||||||
|       setDarkMode(storedTheme === "dark"); |  | ||||||
|       return; |  | ||||||
|     } |  | ||||||
|     const prefersDark = window.matchMedia( |  | ||||||
|       "(prefers-color-scheme: dark)", |  | ||||||
|     ).matches; |  | ||||||
|     setDarkMode(prefersDark); |  | ||||||
|   }, []); |  | ||||||
|  |  | ||||||
|   useEffect(() => { |  | ||||||
|     const rootElement = document.documentElement; |  | ||||||
|     rootElement.classList.remove("dark", "light"); |  | ||||||
|     rootElement.classList.add(darkMode ? "dark" : "light"); |  | ||||||
|   }, [darkMode]); |  | ||||||
|  |  | ||||||
|   const values = { |  | ||||||
|     darkMode, |  | ||||||
|     setDarkMode: (darkMode: boolean) => { |  | ||||||
|       localStorage.setItem("tinyauth-theme", darkMode ? "dark" : "light"); |  | ||||||
|       setDarkMode(darkMode); |  | ||||||
|     }, |  | ||||||
|   }; |  | ||||||
|  |  | ||||||
|   return ( |  | ||||||
|     <ThemeContext.Provider value={values}>{children}</ThemeContext.Provider> |  | ||||||
|   ); |  | ||||||
| }; |  | ||||||
|  |  | ||||||
| export const useTheme = () => { |  | ||||||
|   const context = React.useContext(ThemeContext); |  | ||||||
|  |  | ||||||
|   if (!context) { |  | ||||||
|     throw new Error("useTheme must be used within a ThemeProvider"); |  | ||||||
|   } |  | ||||||
|  |  | ||||||
|   return context; |  | ||||||
| }; |  | ||||||
| @@ -1,23 +0,0 @@ | |||||||
| import { MoonIcon, SunIcon } from "lucide-react"; |  | ||||||
| import { useTheme } from "../providers/theme-provider"; |  | ||||||
| import { Button } from "../ui/button"; |  | ||||||
|  |  | ||||||
| export const ThemeSwitch = () => { |  | ||||||
|   const { darkMode, setDarkMode } = useTheme(); |  | ||||||
|  |  | ||||||
|   const toggleTheme = () => { |  | ||||||
|     setDarkMode(!darkMode); |  | ||||||
|   }; |  | ||||||
|  |  | ||||||
|   return ( |  | ||||||
|     <Button |  | ||||||
|       className="bg-card hover:bg-card/90 text-card-foreground" |  | ||||||
|       aria-label={`Switch to ${darkMode ? "light" : "dark"} mode`} |  | ||||||
|       onClick={() => { |  | ||||||
|         toggleTheme(); |  | ||||||
|       }} |  | ||||||
|     > |  | ||||||
|       {darkMode ? <SunIcon /> : <MoonIcon />} |  | ||||||
|     </Button> |  | ||||||
|   ); |  | ||||||
| }; |  | ||||||
| @@ -6,7 +6,7 @@ import { cn } from "@/lib/utils"; | |||||||
| import { Loader2 } from "lucide-react"; | import { Loader2 } from "lucide-react"; | ||||||
|  |  | ||||||
| const buttonVariants = cva( | const buttonVariants = cva( | ||||||
|   "inline-flex items-center justify-center gap-2 whitespace-nowrap rounded-md text-sm font-medium transition-all disabled:pointer-events-none disabled:opacity-50 [&_svg]:pointer-events-none [&_svg:not([class*='size-'])]:size-4 shrink-0 [&_svg]:shrink-0 outline-none focus-visible:border-ring focus-visible:ring-ring/50 focus-visible:ring-[3px] aria-invalid:ring-destructive/20 dark:aria-invalid:ring-destructive/40 aria-invalid:border-destructive hover:cursor-pointer", |   "inline-flex items-center justify-center gap-2 whitespace-nowrap rounded-md text-sm font-medium transition-all disabled:pointer-events-none disabled:opacity-50 [&_svg]:pointer-events-none [&_svg:not([class*='size-'])]:size-4 shrink-0 [&_svg]:shrink-0 outline-none focus-visible:border-ring focus-visible:ring-ring/50 focus-visible:ring-[3px] aria-invalid:ring-destructive/20 dark:aria-invalid:ring-destructive/40 aria-invalid:border-destructive", | ||||||
|   { |   { | ||||||
|     variants: { |     variants: { | ||||||
|       variant: { |       variant: { | ||||||
|   | |||||||
| @@ -35,7 +35,7 @@ function SelectTrigger({ | |||||||
|       data-slot="select-trigger" |       data-slot="select-trigger" | ||||||
|       data-size={size} |       data-size={size} | ||||||
|       className={cn( |       className={cn( | ||||||
|         "hover:cursor-pointer border-input data-[placeholder]:text-card-foreground [&_svg:not([class*='text-'])]:text-card-foreground focus-visible:border-ring focus-visible:ring-ring/50 aria-invalid:ring-destructive/20 dark:aria-invalid:ring-destructive/40 aria-invalid:border-destructive dark:bg-card dark:hover:bg-card/90 flex w-fit items-center justify-between gap-2 rounded-md border bg-card hover:bg-card/90 px-3 py-2 text-sm whitespace-nowrap shadow-xs transition-[color,box-shadow] outline-none focus-visible:ring-[3px] disabled:cursor-not-allowed disabled:opacity-50 data-[size=default]:h-9 data-[size=sm]:h-8 *:data-[slot=select-value]:line-clamp-1 *:data-[slot=select-value]:flex *:data-[slot=select-value]:items-center *:data-[slot=select-value]:gap-2 [&_svg]:pointer-events-none [&_svg]:shrink-0 [&_svg:not([class*='size-'])]:size-4", |         "border-input data-[placeholder]:text-muted-foreground [&_svg:not([class*='text-'])]:text-muted-foreground focus-visible:border-ring focus-visible:ring-ring/50 aria-invalid:ring-destructive/20 dark:aria-invalid:ring-destructive/40 aria-invalid:border-destructive dark:bg-card dark:hover:bg-card/90 flex w-fit items-center justify-between gap-2 rounded-md border bg-card hover:bg-card/90 px-3 py-2 text-sm whitespace-nowrap shadow-xs transition-[color,box-shadow] outline-none focus-visible:ring-[3px] disabled:cursor-not-allowed disabled:opacity-50 data-[size=default]:h-9 data-[size=sm]:h-8 *:data-[slot=select-value]:line-clamp-1 *:data-[slot=select-value]:flex *:data-[slot=select-value]:items-center *:data-[slot=select-value]:gap-2 [&_svg]:pointer-events-none [&_svg]:shrink-0 [&_svg:not([class*='size-'])]:size-4", | ||||||
|         className, |         className, | ||||||
|       )} |       )} | ||||||
|       {...props} |       {...props} | ||||||
|   | |||||||
| @@ -1,9 +1,8 @@ | |||||||
| import { useTheme } from "../providers/theme-provider"; | import { useTheme } from "next-themes"; | ||||||
| import { Toaster as Sonner, ToasterProps } from "sonner"; | import { Toaster as Sonner, ToasterProps } from "sonner"; | ||||||
|  |  | ||||||
| const Toaster = ({ ...props }: ToasterProps) => { | const Toaster = ({ ...props }: ToasterProps) => { | ||||||
|   const { darkMode } = useTheme(); |   const { theme = "system" } = useTheme(); | ||||||
|   const theme = darkMode ? "dark" : "light"; |  | ||||||
|  |  | ||||||
|   return ( |   return ( | ||||||
|     <Sonner |     <Sonner | ||||||
|   | |||||||
| @@ -1,62 +1,62 @@ | |||||||
| { | { | ||||||
|     "loginTitle": "Welcome back, login with", |     "loginTitle": "Tervetuloa takaisin, kirjaudu sisään käyttäen", | ||||||
|     "loginTitleSimple": "Welcome back, please login", |     "loginTitleSimple": "Tervetuloa takaisin, ole hyvä ja kirjaudu", | ||||||
|     "loginDivider": "Or", |     "loginDivider": "Tai", | ||||||
|     "loginUsername": "Username", |     "loginUsername": "Käyttäjätunnus", | ||||||
|     "loginPassword": "Password", |     "loginPassword": "Salasana", | ||||||
|     "loginSubmit": "Login", |     "loginSubmit": "Kirjaudu", | ||||||
|     "loginFailTitle": "Failed to log in", |     "loginFailTitle": "Kirjautuminen epäonnistui", | ||||||
|     "loginFailSubtitle": "Please check your username and password", |     "loginFailSubtitle": "Tarkista käyttäjätunnuksesi ja salasanasi", | ||||||
|     "loginFailRateLimit": "You failed to login too many times. Please try again later", |     "loginFailRateLimit": "Kirjautuminen epäonnistui liian monta kertaa. Yritä myöhemmin uudelleen", | ||||||
|     "loginSuccessTitle": "Logged in", |     "loginSuccessTitle": "Olet kirjautunut sisään", | ||||||
|     "loginSuccessSubtitle": "Welcome back!", |     "loginSuccessSubtitle": "Tervetuloa takaisin!", | ||||||
|     "loginOauthFailTitle": "An error occurred", |     "loginOauthFailTitle": "Tapahtui virhe", | ||||||
|     "loginOauthFailSubtitle": "Failed to get OAuth URL", |     "loginOauthFailSubtitle": "OAuthin URL-osoitteen haku epäonnistui", | ||||||
|     "loginOauthSuccessTitle": "Redirecting", |     "loginOauthSuccessTitle": "Uudelleenohjataan", | ||||||
|     "loginOauthSuccessSubtitle": "Redirecting to your OAuth provider", |     "loginOauthSuccessSubtitle": "Uudelleenohjaus OAuth -palveluntarjoajallesi", | ||||||
|     "loginOauthAutoRedirectTitle": "OAuth Auto Redirect", |     "loginOauthAutoRedirectTitle": "Automaattinen OAuth -uudelleenohjaus", | ||||||
|     "loginOauthAutoRedirectSubtitle": "You will be automatically redirected to your OAuth provider to authenticate.", |     "loginOauthAutoRedirectSubtitle": "Sinut ohjataan automaattisesti OAuth -palveluntarjoajallesi todentamista varten.", | ||||||
|     "loginOauthAutoRedirectButton": "Redirect now", |     "loginOauthAutoRedirectButton": "Siirry nyt", | ||||||
|     "continueTitle": "Continue", |     "continueTitle": "Jatka", | ||||||
|     "continueRedirectingTitle": "Redirecting...", |     "continueRedirectingTitle": "Uudelleenohjataan...", | ||||||
|     "continueRedirectingSubtitle": "You should be redirected to the app soon", |     "continueRedirectingSubtitle": "Sinun pitäisi ohjautua sovellukseen pian", | ||||||
|     "continueRedirectManually": "Redirect me manually", |     "continueRedirectManually": "Siirrä minut manuaalisesti", | ||||||
|     "continueInsecureRedirectTitle": "Insecure redirect", |     "continueInsecureRedirectTitle": "Turvaton uudelleenohjaus", | ||||||
|     "continueInsecureRedirectSubtitle": "You are trying to redirect from <code>https</code> to <code>http</code> which is not secure. Are you sure you want to continue?", |     "continueInsecureRedirectSubtitle": "Yrität siirtyä suojatusta <code>https</code> -sivusta suojaamattomalle <code>http</code> -sivulle. Oletko varma, että haluat jatkaa?", | ||||||
|     "continueUntrustedRedirectTitle": "Untrusted redirect", |     "continueUntrustedRedirectTitle": "Ei-luotettu uudelleenohjaus", | ||||||
|     "continueUntrustedRedirectSubtitle": "You are trying to redirect to a domain that does not match your configured domain (<code>{{cookieDomain}}</code>). Are you sure you want to continue?", |     "continueUntrustedRedirectSubtitle": "Yrität uudelleenohjata domainiin, joka ei vastaa määritettyä verkkotunnusta (<code>{{cookieDomain}}</code>). Oletko varma, että haluat jatkaa?", | ||||||
|     "logoutFailTitle": "Failed to log out", |     "logoutFailTitle": "Uloskirjautuminen epäonnistui", | ||||||
|     "logoutFailSubtitle": "Please try again", |     "logoutFailSubtitle": "Ole hyvä ja yritä uudelleen", | ||||||
|     "logoutSuccessTitle": "Logged out", |     "logoutSuccessTitle": "Kirjauduttu ulos", | ||||||
|     "logoutSuccessSubtitle": "You have been logged out", |     "logoutSuccessSubtitle": "Sinut on kirjattu ulos", | ||||||
|     "logoutTitle": "Logout", |     "logoutTitle": "Kirjaudu ulos", | ||||||
|     "logoutUsernameSubtitle": "You are currently logged in as <code>{{username}}</code>. Click the button below to logout.", |     "logoutUsernameSubtitle": "Olet kirjautuneena sisään tunnuksella <code>{{username}}</code>. Kirjaudu ulos alla olevasta painikkeesta.", | ||||||
|     "logoutOauthSubtitle": "You are currently logged in as <code>{{username}}</code> using the {{provider}} OAuth provider. Click the button below to logout.", |     "logoutOauthSubtitle": "Olet kirjautuneena sisään tunnuksella <code>{{username}}</code> OAuth palvelun {{provider}} kautta. Kirjaudu ulos alla olevasta painikkeesta.", | ||||||
|     "notFoundTitle": "Page not found", |     "notFoundTitle": "Sivua ei löydy", | ||||||
|     "notFoundSubtitle": "The page you are looking for does not exist.", |     "notFoundSubtitle": "Sivua, jota etsit ei ole olemassa.", | ||||||
|     "notFoundButton": "Go home", |     "notFoundButton": "Palaa kotinäkymään", | ||||||
|     "totpFailTitle": "Failed to verify code", |     "totpFailTitle": "Koodin vahvistus epäonnistui", | ||||||
|     "totpFailSubtitle": "Please check your code and try again", |     "totpFailSubtitle": "Tarkista koodisi ja yritä uudelleen", | ||||||
|     "totpSuccessTitle": "Verified", |     "totpSuccessTitle": "Vahvistettu", | ||||||
|     "totpSuccessSubtitle": "Redirecting to your app", |     "totpSuccessSubtitle": "Uudelleenohjataan sovelluksellesi", | ||||||
|     "totpTitle": "Enter your TOTP code", |     "totpTitle": "Syötä TOTP -koodisi", | ||||||
|     "totpSubtitle": "Please enter the code from your authenticator app.", |     "totpSubtitle": "Ole hyvä ja syötä koodi todennussovelluksestasi.", | ||||||
|     "unauthorizedTitle": "Unauthorized", |     "unauthorizedTitle": "Ei sallittu", | ||||||
|     "unauthorizedResourceSubtitle": "The user with username <code>{{username}}</code> is not authorized to access the resource <code>{{resource}}</code>.", |     "unauthorizedResourceSubtitle": "Käyttäjällä <code>{{username}}</code> ei ole pääsyä kohteeseen <code>{{resource}}</code>.", | ||||||
|     "unauthorizedLoginSubtitle": "The user with username <code>{{username}}</code> is not authorized to login.", |     "unauthorizedLoginSubtitle": "Käyttäjällä <code>{{username}}</code> ei ole lupaa kirjautua.", | ||||||
|     "unauthorizedGroupsSubtitle": "The user with username <code>{{username}}</code> is not in the groups required by the resource <code>{{resource}}</code>.", |     "unauthorizedGroupsSubtitle": "Käyttäjä <code>{{username}}</code> ei ole ryhmässä, joka vaaditaan pääsyyn kohteeseen <code>{{resource}}</code>.", | ||||||
|     "unauthorizedIpSubtitle": "Your IP address <code>{{ip}}</code> is not authorized to access the resource <code>{{resource}}</code>.", |     "unauthorizedIpSubtitle": "IP osoitteestasi <code>{{ip}}</code> ei ole pääsyä kohteeseen <code>{{resource}}</code>.", | ||||||
|     "unauthorizedButton": "Try again", |     "unauthorizedButton": "Yritä uudelleen", | ||||||
|     "cancelTitle": "Cancel", |     "cancelTitle": "Peruuta", | ||||||
|     "forgotPasswordTitle": "Forgot your password?", |     "forgotPasswordTitle": "Unohditko salasanasi?", | ||||||
|     "failedToFetchProvidersTitle": "Failed to load authentication providers. Please check your configuration.", |     "failedToFetchProvidersTitle": "Todennuspalvelujen tarjoajien lataaminen epäonnistui. Tarkista määrityksesi.", | ||||||
|     "errorTitle": "An error occurred", |     "errorTitle": "Tapahtui virhe", | ||||||
|     "errorSubtitle": "An error occurred while trying to perform this action. Please check the console for more information.", |     "errorSubtitle": "Tapahtui virhe yritettäessä suorittaa tämä toiminto. Ole hyvä ja tarkista konsoli saadaksesi lisätietoja.", | ||||||
|     "forgotPasswordMessage": "You can reset your password by changing the `USERS` environment variable.", |     "forgotPasswordMessage": "Voit nollata salasanasi vaihtamalla ympäristömuuttujan `USERS`.", | ||||||
|     "fieldRequired": "This field is required", |     "fieldRequired": "Tämä kenttä on pakollinen", | ||||||
|     "invalidInput": "Invalid input", |     "invalidInput": "Virheellinen syöte", | ||||||
|     "domainWarningTitle": "Invalid Domain", |     "domainWarningTitle": "Virheellinen verkkotunnus", | ||||||
|     "domainWarningSubtitle": "This instance is configured to be accessed from <code>{{appUrl}}</code>, but <code>{{currentUrl}}</code> is being used. If you proceed, you may encounter issues with authentication.", |     "domainWarningSubtitle": "Tämä instanssi on määritelty käyttämään osoitetta <code>{{appUrl}}</code>, mutta nykyinen osoite on <code>{{currentUrl}}</code>. Jos jatkat, saatat törmätä ongelmiin autentikoinnissa.", | ||||||
|     "ignoreTitle": "Ignore", |     "ignoreTitle": "Jätä huomiotta", | ||||||
|     "goToCorrectDomainTitle": "Go to correct domain" |     "goToCorrectDomainTitle": "Siirry oikeaan verkkotunnukseen" | ||||||
| } | } | ||||||
| @@ -16,7 +16,6 @@ import { QueryClient, QueryClientProvider } from "@tanstack/react-query"; | |||||||
| import { AppContextProvider } from "./context/app-context.tsx"; | import { AppContextProvider } from "./context/app-context.tsx"; | ||||||
| import { UserContextProvider } from "./context/user-context.tsx"; | import { UserContextProvider } from "./context/user-context.tsx"; | ||||||
| import { Toaster } from "@/components/ui/sonner"; | import { Toaster } from "@/components/ui/sonner"; | ||||||
| import { ThemeProvider } from "./components/providers/theme-provider.tsx"; |  | ||||||
|  |  | ||||||
| const queryClient = new QueryClient(); | const queryClient = new QueryClient(); | ||||||
|  |  | ||||||
| @@ -25,27 +24,25 @@ createRoot(document.getElementById("root")!).render( | |||||||
|     <QueryClientProvider client={queryClient}> |     <QueryClientProvider client={queryClient}> | ||||||
|       <AppContextProvider> |       <AppContextProvider> | ||||||
|         <UserContextProvider> |         <UserContextProvider> | ||||||
|           <ThemeProvider> |           <BrowserRouter> | ||||||
|             <BrowserRouter> |             <Routes> | ||||||
|               <Routes> |               <Route element={<Layout />} errorElement={<ErrorPage />}> | ||||||
|                 <Route element={<Layout />} errorElement={<ErrorPage />}> |                 <Route path="/" element={<App />} /> | ||||||
|                   <Route path="/" element={<App />} /> |                 <Route path="/login" element={<LoginPage />} /> | ||||||
|                   <Route path="/login" element={<LoginPage />} /> |                 <Route path="/logout" element={<LogoutPage />} /> | ||||||
|                   <Route path="/logout" element={<LogoutPage />} /> |                 <Route path="/continue" element={<ContinuePage />} /> | ||||||
|                   <Route path="/continue" element={<ContinuePage />} /> |                 <Route path="/totp" element={<TotpPage />} /> | ||||||
|                   <Route path="/totp" element={<TotpPage />} /> |                 <Route | ||||||
|                   <Route |                   path="/forgot-password" | ||||||
|                     path="/forgot-password" |                   element={<ForgotPasswordPage />} | ||||||
|                     element={<ForgotPasswordPage />} |                 /> | ||||||
|                   /> |                 <Route path="/unauthorized" element={<UnauthorizedPage />} /> | ||||||
|                   <Route path="/unauthorized" element={<UnauthorizedPage />} /> |                 <Route path="/error" element={<ErrorPage />} /> | ||||||
|                   <Route path="/error" element={<ErrorPage />} /> |                 <Route path="*" element={<NotFoundPage />} /> | ||||||
|                   <Route path="*" element={<NotFoundPage />} /> |               </Route> | ||||||
|                 </Route> |             </Routes> | ||||||
|               </Routes> |           </BrowserRouter> | ||||||
|             </BrowserRouter> |           <Toaster /> | ||||||
|             <Toaster /> |  | ||||||
|           </ThemeProvider> |  | ||||||
|         </UserContextProvider> |         </UserContextProvider> | ||||||
|       </AppContextProvider> |       </AppContextProvider> | ||||||
|     </QueryClientProvider> |     </QueryClientProvider> | ||||||
|   | |||||||
							
								
								
									
										1
									
								
								go.mod
									
									
									
									
									
								
							
							
						
						
									
										1
									
								
								go.mod
									
									
									
									
									
								
							| @@ -47,7 +47,6 @@ require ( | |||||||
| 	github.com/quic-go/qpack v0.5.1 // indirect | 	github.com/quic-go/qpack v0.5.1 // indirect | ||||||
| 	github.com/quic-go/quic-go v0.54.1 // indirect | 	github.com/quic-go/quic-go v0.54.1 // indirect | ||||||
| 	github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec // indirect | 	github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec // indirect | ||||||
| 	github.com/stoewer/go-strcase v1.3.1 // indirect |  | ||||||
| 	github.com/xo/terminfo v0.0.0-20220910002029-abceb7e1c41e // indirect | 	github.com/xo/terminfo v0.0.0-20220910002029-abceb7e1c41e // indirect | ||||||
| 	go.opentelemetry.io/auto/sdk v1.1.0 // indirect | 	go.opentelemetry.io/auto/sdk v1.1.0 // indirect | ||||||
| 	go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.34.0 // indirect | 	go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.34.0 // indirect | ||||||
|   | |||||||
							
								
								
									
										2
									
								
								go.sum
									
									
									
									
									
								
							
							
						
						
									
										2
									
								
								go.sum
									
									
									
									
									
								
							| @@ -259,8 +259,6 @@ github.com/spf13/pflag v1.0.10 h1:4EBh2KAYBwaONj6b2Ye1GiHfwjqyROoF4RwYO+vPwFk= | |||||||
| github.com/spf13/pflag v1.0.10/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg= | github.com/spf13/pflag v1.0.10/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg= | ||||||
| github.com/spf13/viper v1.21.0 h1:x5S+0EU27Lbphp4UKm1C+1oQO+rKx36vfCoaVebLFSU= | github.com/spf13/viper v1.21.0 h1:x5S+0EU27Lbphp4UKm1C+1oQO+rKx36vfCoaVebLFSU= | ||||||
| github.com/spf13/viper v1.21.0/go.mod h1:P0lhsswPGWD/1lZJ9ny3fYnVqxiegrlNrEmgLjbTCAY= | github.com/spf13/viper v1.21.0/go.mod h1:P0lhsswPGWD/1lZJ9ny3fYnVqxiegrlNrEmgLjbTCAY= | ||||||
| github.com/stoewer/go-strcase v1.3.1 h1:iS0MdW+kVTxgMoE1LAZyMiYJFKlOzLooE4MxjirtkAs= |  | ||||||
| github.com/stoewer/go-strcase v1.3.1/go.mod h1:fAH5hQ5pehh+j3nZfvwdk2RgEgQjAoM8wodgtPmh1xo= |  | ||||||
| github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= | github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= | ||||||
| github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw= | github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw= | ||||||
| github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo= | github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo= | ||||||
|   | |||||||
| @@ -2,7 +2,6 @@ package bootstrap | |||||||
|  |  | ||||||
| import ( | import ( | ||||||
| 	"bytes" | 	"bytes" | ||||||
| 	"context" |  | ||||||
| 	"encoding/json" | 	"encoding/json" | ||||||
| 	"fmt" | 	"fmt" | ||||||
| 	"net/http" | 	"net/http" | ||||||
| @@ -14,13 +13,11 @@ import ( | |||||||
| 	"tinyauth/internal/config" | 	"tinyauth/internal/config" | ||||||
| 	"tinyauth/internal/controller" | 	"tinyauth/internal/controller" | ||||||
| 	"tinyauth/internal/middleware" | 	"tinyauth/internal/middleware" | ||||||
| 	"tinyauth/internal/model" |  | ||||||
| 	"tinyauth/internal/service" | 	"tinyauth/internal/service" | ||||||
| 	"tinyauth/internal/utils" | 	"tinyauth/internal/utils" | ||||||
|  |  | ||||||
| 	"github.com/gin-gonic/gin" | 	"github.com/gin-gonic/gin" | ||||||
| 	"github.com/rs/zerolog/log" | 	"github.com/rs/zerolog/log" | ||||||
| 	"gorm.io/gorm" |  | ||||||
| ) | ) | ||||||
|  |  | ||||||
| type Controller interface { | type Controller interface { | ||||||
| @@ -139,14 +136,12 @@ func (app *BootstrapApp) Setup() error { | |||||||
|  |  | ||||||
| 	// Create services | 	// Create services | ||||||
| 	dockerService := service.NewDockerService() | 	dockerService := service.NewDockerService() | ||||||
| 	aclsService := service.NewAccessControlsService(dockerService) |  | ||||||
| 	authService := service.NewAuthService(authConfig, dockerService, ldapService, database) | 	authService := service.NewAuthService(authConfig, dockerService, ldapService, database) | ||||||
| 	oauthBrokerService := service.NewOAuthBrokerService(oauthProviders) | 	oauthBrokerService := service.NewOAuthBrokerService(oauthProviders) | ||||||
|  |  | ||||||
| 	// Initialize services (order matters) | 	// Initialize services | ||||||
| 	services := []Service{ | 	services := []Service{ | ||||||
| 		dockerService, | 		dockerService, | ||||||
| 		aclsService, |  | ||||||
| 		authService, | 		authService, | ||||||
| 		oauthBrokerService, | 		oauthBrokerService, | ||||||
| 	} | 	} | ||||||
| @@ -248,7 +243,7 @@ func (app *BootstrapApp) Setup() error { | |||||||
|  |  | ||||||
| 	proxyController := controller.NewProxyController(controller.ProxyControllerConfig{ | 	proxyController := controller.NewProxyController(controller.ProxyControllerConfig{ | ||||||
| 		AppURL: app.config.AppURL, | 		AppURL: app.config.AppURL, | ||||||
| 	}, apiRouter, aclsService, authService) | 	}, apiRouter, dockerService, authService) | ||||||
|  |  | ||||||
| 	userController := controller.NewUserController(controller.UserControllerConfig{ | 	userController := controller.NewUserController(controller.UserControllerConfig{ | ||||||
| 		CookieDomain: cookieDomain, | 		CookieDomain: cookieDomain, | ||||||
| @@ -282,10 +277,6 @@ func (app *BootstrapApp) Setup() error { | |||||||
| 		go app.heartbeat() | 		go app.heartbeat() | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	// Start DB cleanup routine |  | ||||||
| 	log.Debug().Msg("Starting database cleanup routine") |  | ||||||
| 	go app.dbCleanup(database) |  | ||||||
|  |  | ||||||
| 	// Start server | 	// Start server | ||||||
| 	address := fmt.Sprintf("%s:%d", app.config.Address, app.config.Port) | 	address := fmt.Sprintf("%s:%d", app.config.Address, app.config.Port) | ||||||
| 	log.Info().Msgf("Starting server on %s", address) | 	log.Info().Msgf("Starting server on %s", address) | ||||||
| @@ -347,17 +338,3 @@ func (app *BootstrapApp) heartbeat() { | |||||||
| 		} | 		} | ||||||
| 	} | 	} | ||||||
| } | } | ||||||
|  |  | ||||||
| func (app *BootstrapApp) dbCleanup(db *gorm.DB) { |  | ||||||
| 	ticker := time.NewTicker(time.Duration(30) * time.Minute) |  | ||||||
| 	defer ticker.Stop() |  | ||||||
| 	ctx := context.Background() |  | ||||||
|  |  | ||||||
| 	for ; true; <-ticker.C { |  | ||||||
| 		log.Debug().Msg("Cleaning up old database sessions") |  | ||||||
| 		_, err := gorm.G[model.Session](db).Where("expiry < ?", time.Now().UnixMilli()).Delete(ctx) |  | ||||||
| 		if err != nil { |  | ||||||
| 			log.Error().Err(err).Msg("Failed to cleanup old sessions") |  | ||||||
| 		} |  | ||||||
| 	} |  | ||||||
| } |  | ||||||
|   | |||||||
| @@ -53,16 +53,16 @@ type Claims struct { | |||||||
| } | } | ||||||
|  |  | ||||||
| type OAuthServiceConfig struct { | type OAuthServiceConfig struct { | ||||||
| 	ClientID           string `field:"client-id"` | 	ClientID           string   `key:"client-id"` | ||||||
| 	ClientSecret       string | 	ClientSecret       string   `key:"client-secret"` | ||||||
| 	ClientSecretFile   string | 	ClientSecretFile   string   `key:"client-secret-file"` | ||||||
| 	Scopes             []string | 	Scopes             []string `key:"scopes"` | ||||||
| 	RedirectURL        string `field:"redirect-url"` | 	RedirectURL        string   `key:"redirect-url"` | ||||||
| 	AuthURL            string `field:"auth-url"` | 	AuthURL            string   `key:"auth-url"` | ||||||
| 	TokenURL           string `field:"token-url"` | 	TokenURL           string   `key:"token-url"` | ||||||
| 	UserinfoURL        string `field:"user-info-url"` | 	UserinfoURL        string   `key:"user-info-url"` | ||||||
| 	InsecureSkipVerify bool | 	InsecureSkipVerify bool     `key:"insecure-skip-verify"` | ||||||
| 	Name               string | 	Name               string   `key:"name"` | ||||||
| } | } | ||||||
|  |  | ||||||
| var OverrideProviders = map[string]string{ | var OverrideProviders = map[string]string{ | ||||||
|   | |||||||
| @@ -72,7 +72,6 @@ func (controller *OAuthController) oauthURLHandler(c *gin.Context) { | |||||||
| 		return | 		return | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	service.GenerateVerifier() |  | ||||||
| 	state := service.GenerateState() | 	state := service.GenerateState() | ||||||
| 	authURL := service.GetAuthURL(state) | 	authURL := service.GetAuthURL(state) | ||||||
| 	c.SetCookie(controller.config.CSRFCookieName, state, int(time.Hour.Seconds()), "/", fmt.Sprintf(".%s", controller.config.CookieDomain), controller.config.SecureCookie, true) | 	c.SetCookie(controller.config.CSRFCookieName, state, int(time.Hour.Seconds()), "/", fmt.Sprintf(".%s", controller.config.CookieDomain), controller.config.SecureCookie, true) | ||||||
|   | |||||||
| @@ -24,15 +24,15 @@ type ProxyControllerConfig struct { | |||||||
| type ProxyController struct { | type ProxyController struct { | ||||||
| 	config ProxyControllerConfig | 	config ProxyControllerConfig | ||||||
| 	router *gin.RouterGroup | 	router *gin.RouterGroup | ||||||
| 	acls   *service.AccessControlsService | 	docker *service.DockerService | ||||||
| 	auth   *service.AuthService | 	auth   *service.AuthService | ||||||
| } | } | ||||||
|  |  | ||||||
| func NewProxyController(config ProxyControllerConfig, router *gin.RouterGroup, acls *service.AccessControlsService, auth *service.AuthService) *ProxyController { | func NewProxyController(config ProxyControllerConfig, router *gin.RouterGroup, docker *service.DockerService, auth *service.AuthService) *ProxyController { | ||||||
| 	return &ProxyController{ | 	return &ProxyController{ | ||||||
| 		config: config, | 		config: config, | ||||||
| 		router: router, | 		router: router, | ||||||
| 		acls:   acls, | 		docker: docker, | ||||||
| 		auth:   auth, | 		auth:   auth, | ||||||
| 	} | 	} | ||||||
| } | } | ||||||
| @@ -76,21 +76,20 @@ func (controller *ProxyController) proxyHandler(c *gin.Context) { | |||||||
| 	proto := c.Request.Header.Get("X-Forwarded-Proto") | 	proto := c.Request.Header.Get("X-Forwarded-Proto") | ||||||
| 	host := c.Request.Header.Get("X-Forwarded-Host") | 	host := c.Request.Header.Get("X-Forwarded-Host") | ||||||
|  |  | ||||||
| 	// Get acls | 	labels, err := controller.docker.GetLabels(host) | ||||||
| 	acls, err := controller.acls.GetAccessControls(host) |  | ||||||
|  |  | ||||||
| 	if err != nil { | 	if err != nil { | ||||||
| 		log.Error().Err(err).Msg("Failed to get access controls for resource") | 		log.Error().Err(err).Msg("Failed to get labels from Docker") | ||||||
| 		controller.handleError(c, req, isBrowser) | 		controller.handleError(c, req, isBrowser) | ||||||
| 		return | 		return | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	log.Trace().Interface("acls", acls).Msg("ACLs for resource") | 	log.Trace().Interface("labels", labels).Msg("Labels for resource") | ||||||
|  |  | ||||||
| 	clientIP := c.ClientIP() | 	clientIP := c.ClientIP() | ||||||
|  |  | ||||||
| 	if controller.auth.IsBypassedIP(acls.IP, clientIP) { | 	if controller.auth.IsBypassedIP(labels.IP, clientIP) { | ||||||
| 		controller.setHeaders(c, acls) | 		controller.setHeaders(c, labels) | ||||||
| 		c.JSON(200, gin.H{ | 		c.JSON(200, gin.H{ | ||||||
| 			"status":  200, | 			"status":  200, | ||||||
| 			"message": "Authenticated", | 			"message": "Authenticated", | ||||||
| @@ -98,7 +97,7 @@ func (controller *ProxyController) proxyHandler(c *gin.Context) { | |||||||
| 		return | 		return | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	authEnabled, err := controller.auth.IsAuthEnabled(uri, acls.Path) | 	authEnabled, err := controller.auth.IsAuthEnabled(uri, labels.Path) | ||||||
|  |  | ||||||
| 	if err != nil { | 	if err != nil { | ||||||
| 		log.Error().Err(err).Msg("Failed to check if auth is enabled for resource") | 		log.Error().Err(err).Msg("Failed to check if auth is enabled for resource") | ||||||
| @@ -108,7 +107,7 @@ func (controller *ProxyController) proxyHandler(c *gin.Context) { | |||||||
|  |  | ||||||
| 	if !authEnabled { | 	if !authEnabled { | ||||||
| 		log.Debug().Msg("Authentication disabled for resource, allowing access") | 		log.Debug().Msg("Authentication disabled for resource, allowing access") | ||||||
| 		controller.setHeaders(c, acls) | 		controller.setHeaders(c, labels) | ||||||
| 		c.JSON(200, gin.H{ | 		c.JSON(200, gin.H{ | ||||||
| 			"status":  200, | 			"status":  200, | ||||||
| 			"message": "Authenticated", | 			"message": "Authenticated", | ||||||
| @@ -116,7 +115,7 @@ func (controller *ProxyController) proxyHandler(c *gin.Context) { | |||||||
| 		return | 		return | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	if !controller.auth.CheckIP(acls.IP, clientIP) { | 	if !controller.auth.CheckIP(labels.IP, clientIP) { | ||||||
| 		if req.Proxy == "nginx" || !isBrowser { | 		if req.Proxy == "nginx" || !isBrowser { | ||||||
| 			c.JSON(401, gin.H{ | 			c.JSON(401, gin.H{ | ||||||
| 				"status":  401, | 				"status":  401, | ||||||
| @@ -161,7 +160,7 @@ func (controller *ProxyController) proxyHandler(c *gin.Context) { | |||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	if userContext.IsLoggedIn { | 	if userContext.IsLoggedIn { | ||||||
| 		appAllowed := controller.auth.IsResourceAllowed(c, userContext, acls) | 		appAllowed := controller.auth.IsResourceAllowed(c, userContext, labels) | ||||||
|  |  | ||||||
| 		if !appAllowed { | 		if !appAllowed { | ||||||
| 			log.Warn().Str("user", userContext.Username).Str("resource", strings.Split(host, ".")[0]).Msg("User not allowed to access resource") | 			log.Warn().Str("user", userContext.Username).Str("resource", strings.Split(host, ".")[0]).Msg("User not allowed to access resource") | ||||||
| @@ -195,7 +194,7 @@ func (controller *ProxyController) proxyHandler(c *gin.Context) { | |||||||
| 		} | 		} | ||||||
|  |  | ||||||
| 		if userContext.OAuth { | 		if userContext.OAuth { | ||||||
| 			groupOK := controller.auth.IsInOAuthGroup(c, userContext, acls.OAuth.Groups) | 			groupOK := controller.auth.IsInOAuthGroup(c, userContext, labels.OAuth.Groups) | ||||||
|  |  | ||||||
| 			if !groupOK { | 			if !groupOK { | ||||||
| 				log.Warn().Str("user", userContext.Username).Str("resource", strings.Split(host, ".")[0]).Msg("User OAuth groups do not match resource requirements") | 				log.Warn().Str("user", userContext.Username).Str("resource", strings.Split(host, ".")[0]).Msg("User OAuth groups do not match resource requirements") | ||||||
| @@ -235,7 +234,7 @@ func (controller *ProxyController) proxyHandler(c *gin.Context) { | |||||||
| 		c.Header("Remote-Email", utils.SanitizeHeader(userContext.Email)) | 		c.Header("Remote-Email", utils.SanitizeHeader(userContext.Email)) | ||||||
| 		c.Header("Remote-Groups", utils.SanitizeHeader(userContext.OAuthGroups)) | 		c.Header("Remote-Groups", utils.SanitizeHeader(userContext.OAuthGroups)) | ||||||
|  |  | ||||||
| 		controller.setHeaders(c, acls) | 		controller.setHeaders(c, labels) | ||||||
|  |  | ||||||
| 		c.JSON(200, gin.H{ | 		c.JSON(200, gin.H{ | ||||||
| 			"status":  200, | 			"status":  200, | ||||||
| @@ -265,21 +264,21 @@ func (controller *ProxyController) proxyHandler(c *gin.Context) { | |||||||
| 	c.Redirect(http.StatusTemporaryRedirect, fmt.Sprintf("%s/login?%s", controller.config.AppURL, queries.Encode())) | 	c.Redirect(http.StatusTemporaryRedirect, fmt.Sprintf("%s/login?%s", controller.config.AppURL, queries.Encode())) | ||||||
| } | } | ||||||
|  |  | ||||||
| func (controller *ProxyController) setHeaders(c *gin.Context, acls config.App) { | func (controller *ProxyController) setHeaders(c *gin.Context, labels config.App) { | ||||||
| 	c.Header("Authorization", c.Request.Header.Get("Authorization")) | 	c.Header("Authorization", c.Request.Header.Get("Authorization")) | ||||||
|  |  | ||||||
| 	headers := utils.ParseHeaders(acls.Response.Headers) | 	headers := utils.ParseHeaders(labels.Response.Headers) | ||||||
|  |  | ||||||
| 	for key, value := range headers { | 	for key, value := range headers { | ||||||
| 		log.Debug().Str("header", key).Msg("Setting header") | 		log.Debug().Str("header", key).Msg("Setting header") | ||||||
| 		c.Header(key, value) | 		c.Header(key, value) | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	basicPassword := utils.GetSecret(acls.Response.BasicAuth.Password, acls.Response.BasicAuth.PasswordFile) | 	basicPassword := utils.GetSecret(labels.Response.BasicAuth.Password, labels.Response.BasicAuth.PasswordFile) | ||||||
|  |  | ||||||
| 	if acls.Response.BasicAuth.Username != "" && basicPassword != "" { | 	if labels.Response.BasicAuth.Username != "" && basicPassword != "" { | ||||||
| 		log.Debug().Str("username", acls.Response.BasicAuth.Username).Msg("Setting basic auth header") | 		log.Debug().Str("username", labels.Response.BasicAuth.Username).Msg("Setting basic auth header") | ||||||
| 		c.Header("Authorization", fmt.Sprintf("Basic %s", utils.GetBasicAuth(acls.Response.BasicAuth.Username, basicPassword))) | 		c.Header("Authorization", fmt.Sprintf("Basic %s", utils.GetBasicAuth(labels.Response.BasicAuth.Username, basicPassword))) | ||||||
| 	} | 	} | ||||||
| } | } | ||||||
|  |  | ||||||
|   | |||||||
| @@ -39,11 +39,6 @@ func setupProxyController(t *testing.T, middlewares *[]gin.HandlerFunc) (*gin.En | |||||||
|  |  | ||||||
| 	assert.NilError(t, dockerService.Init()) | 	assert.NilError(t, dockerService.Init()) | ||||||
|  |  | ||||||
| 	// Access controls |  | ||||||
| 	accessControlsService := service.NewAccessControlsService(dockerService) |  | ||||||
|  |  | ||||||
| 	assert.NilError(t, accessControlsService.Init()) |  | ||||||
|  |  | ||||||
| 	// Auth service | 	// Auth service | ||||||
| 	authService := service.NewAuthService(service.AuthServiceConfig{ | 	authService := service.NewAuthService(service.AuthServiceConfig{ | ||||||
| 		Users: []config.User{ | 		Users: []config.User{ | ||||||
| @@ -64,7 +59,7 @@ func setupProxyController(t *testing.T, middlewares *[]gin.HandlerFunc) (*gin.En | |||||||
| 	// Controller | 	// Controller | ||||||
| 	ctrl := controller.NewProxyController(controller.ProxyControllerConfig{ | 	ctrl := controller.NewProxyController(controller.ProxyControllerConfig{ | ||||||
| 		AppURL: "http://localhost:8080", | 		AppURL: "http://localhost:8080", | ||||||
| 	}, group, accessControlsService, authService) | 	}, group, dockerService, authService) | ||||||
| 	ctrl.SetupRoutes() | 	ctrl.SetupRoutes() | ||||||
|  |  | ||||||
| 	return router, recorder, authService | 	return router, recorder, authService | ||||||
|   | |||||||
| @@ -1,103 +0,0 @@ | |||||||
| package service |  | ||||||
|  |  | ||||||
| import ( |  | ||||||
| 	"os" |  | ||||||
| 	"strings" |  | ||||||
| 	"tinyauth/internal/config" |  | ||||||
| 	"tinyauth/internal/utils/decoders" |  | ||||||
|  |  | ||||||
| 	"github.com/rs/zerolog/log" |  | ||||||
| ) |  | ||||||
|  |  | ||||||
| type AccessControlsService struct { |  | ||||||
| 	docker  *DockerService |  | ||||||
| 	envACLs config.Apps |  | ||||||
| } |  | ||||||
|  |  | ||||||
| func NewAccessControlsService(docker *DockerService) *AccessControlsService { |  | ||||||
| 	return &AccessControlsService{ |  | ||||||
| 		docker: docker, |  | ||||||
| 	} |  | ||||||
| } |  | ||||||
|  |  | ||||||
| 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) |  | ||||||
|  |  | ||||||
| 	if err != nil { |  | ||||||
| 		return err |  | ||||||
| 	} |  | ||||||
|  |  | ||||||
| 	acls.envACLs = apps |  | ||||||
| 	return nil |  | ||||||
| } |  | ||||||
|  |  | ||||||
| func (acls *AccessControlsService) lookupEnvACLs(appDomain string) *config.App { |  | ||||||
| 	if len(acls.envACLs.Apps) == 0 { |  | ||||||
| 		return nil |  | ||||||
| 	} |  | ||||||
|  |  | ||||||
| 	for appName, appACLs := range acls.envACLs.Apps { |  | ||||||
| 		if appACLs.Config.Domain == appDomain { |  | ||||||
| 			return &appACLs |  | ||||||
| 		} |  | ||||||
|  |  | ||||||
| 		if strings.SplitN(appDomain, ".", 2)[0] == appName { |  | ||||||
| 			return &appACLs |  | ||||||
| 		} |  | ||||||
| 	} |  | ||||||
|  |  | ||||||
| 	return nil |  | ||||||
| } |  | ||||||
|  |  | ||||||
| func (acls *AccessControlsService) GetAccessControls(appDomain string) (config.App, error) { |  | ||||||
| 	// First check environment variables |  | ||||||
| 	envACLs := acls.lookupEnvACLs(appDomain) |  | ||||||
|  |  | ||||||
| 	if envACLs != nil { |  | ||||||
| 		log.Debug().Str("domain", appDomain).Msg("Found matching access controls in environment variables") |  | ||||||
| 		return *envACLs, nil |  | ||||||
| 	} |  | ||||||
|  |  | ||||||
| 	// Fallback to Docker labels |  | ||||||
| 	return acls.docker.GetLabels(appDomain) |  | ||||||
| } |  | ||||||
| @@ -1,8 +1,6 @@ | |||||||
| package service | package service | ||||||
|  |  | ||||||
| import ( | import ( | ||||||
| 	"context" |  | ||||||
| 	"errors" |  | ||||||
| 	"fmt" | 	"fmt" | ||||||
| 	"regexp" | 	"regexp" | ||||||
| 	"strings" | 	"strings" | ||||||
| @@ -43,7 +41,6 @@ type AuthService struct { | |||||||
| 	loginMutex    sync.RWMutex | 	loginMutex    sync.RWMutex | ||||||
| 	ldap          *LdapService | 	ldap          *LdapService | ||||||
| 	database      *gorm.DB | 	database      *gorm.DB | ||||||
| 	ctx           context.Context |  | ||||||
| } | } | ||||||
|  |  | ||||||
| func NewAuthService(config AuthServiceConfig, docker *DockerService, ldap *LdapService, database *gorm.DB) *AuthService { | func NewAuthService(config AuthServiceConfig, docker *DockerService, ldap *LdapService, database *gorm.DB) *AuthService { | ||||||
| @@ -57,7 +54,6 @@ func NewAuthService(config AuthServiceConfig, docker *DockerService, ldap *LdapS | |||||||
| } | } | ||||||
|  |  | ||||||
| func (auth *AuthService) Init() error { | func (auth *AuthService) Init() error { | ||||||
| 	auth.ctx = context.Background() |  | ||||||
| 	return nil | 	return nil | ||||||
| } | } | ||||||
|  |  | ||||||
| @@ -217,7 +213,7 @@ func (auth *AuthService) CreateSessionCookie(c *gin.Context, data *config.Sessio | |||||||
| 		OAuthName:   data.OAuthName, | 		OAuthName:   data.OAuthName, | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	err = gorm.G[model.Session](auth.database).Create(auth.ctx, &session) | 	err = auth.database.Create(&session).Error | ||||||
|  |  | ||||||
| 	if err != nil { | 	if err != nil { | ||||||
| 		return err | 		return err | ||||||
| @@ -235,10 +231,10 @@ func (auth *AuthService) DeleteSessionCookie(c *gin.Context) error { | |||||||
| 		return err | 		return err | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	_, err = gorm.G[model.Session](auth.database).Where("uuid = ?", cookie).Delete(auth.ctx) | 	res := auth.database.Unscoped().Where("uuid = ?", cookie).Delete(&model.Session{}) | ||||||
|  |  | ||||||
| 	if err != nil { | 	if res.Error != nil { | ||||||
| 		return err | 		return res.Error | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	c.SetCookie(auth.config.SessionCookieName, "", -1, "/", fmt.Sprintf(".%s", auth.config.CookieDomain), auth.config.SecureCookie, true) | 	c.SetCookie(auth.config.SessionCookieName, "", -1, "/", fmt.Sprintf(".%s", auth.config.CookieDomain), auth.config.SecureCookie, true) | ||||||
| @@ -253,13 +249,15 @@ func (auth *AuthService) GetSessionCookie(c *gin.Context) (config.SessionCookie, | |||||||
| 		return config.SessionCookie{}, err | 		return config.SessionCookie{}, err | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	session, err := gorm.G[model.Session](auth.database).Where("uuid = ?", cookie).First(auth.ctx) | 	var session model.Session | ||||||
|  |  | ||||||
| 	if err != nil { | 	res := auth.database.Unscoped().Where("uuid = ?", cookie).First(&session) | ||||||
| 		return config.SessionCookie{}, err |  | ||||||
|  | 	if res.Error != nil { | ||||||
|  | 		return config.SessionCookie{}, res.Error | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	if errors.Is(err, gorm.ErrRecordNotFound) { | 	if res.RowsAffected == 0 { | ||||||
| 		return config.SessionCookie{}, fmt.Errorf("session not found") | 		return config.SessionCookie{}, fmt.Errorf("session not found") | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| @@ -289,21 +287,21 @@ func (auth *AuthService) UserAuthConfigured() bool { | |||||||
| 	return len(auth.config.Users) > 0 || auth.ldap != nil | 	return len(auth.config.Users) > 0 || auth.ldap != nil | ||||||
| } | } | ||||||
|  |  | ||||||
| func (auth *AuthService) IsResourceAllowed(c *gin.Context, context config.UserContext, acls config.App) bool { | func (auth *AuthService) IsResourceAllowed(c *gin.Context, context config.UserContext, labels config.App) bool { | ||||||
| 	if context.OAuth { | 	if context.OAuth { | ||||||
| 		log.Debug().Msg("Checking OAuth whitelist") | 		log.Debug().Msg("Checking OAuth whitelist") | ||||||
| 		return utils.CheckFilter(acls.OAuth.Whitelist, context.Email) | 		return utils.CheckFilter(labels.OAuth.Whitelist, context.Email) | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	if acls.Users.Block != "" { | 	if labels.Users.Block != "" { | ||||||
| 		log.Debug().Msg("Checking blocked users") | 		log.Debug().Msg("Checking blocked users") | ||||||
| 		if utils.CheckFilter(acls.Users.Block, context.Username) { | 		if utils.CheckFilter(labels.Users.Block, context.Username) { | ||||||
| 			return false | 			return false | ||||||
| 		} | 		} | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	log.Debug().Msg("Checking users") | 	log.Debug().Msg("Checking users") | ||||||
| 	return utils.CheckFilter(acls.Users.Allow, context.Username) | 	return utils.CheckFilter(labels.Users.Allow, context.Username) | ||||||
| } | } | ||||||
|  |  | ||||||
| func (auth *AuthService) IsInOAuthGroup(c *gin.Context, context config.UserContext, requiredGroups string) bool { | func (auth *AuthService) IsInOAuthGroup(c *gin.Context, context config.UserContext, requiredGroups string) bool { | ||||||
| @@ -371,8 +369,8 @@ func (auth *AuthService) GetBasicAuth(c *gin.Context) *config.User { | |||||||
| 	} | 	} | ||||||
| } | } | ||||||
|  |  | ||||||
| func (auth *AuthService) CheckIP(acls config.AppIP, ip string) bool { | func (auth *AuthService) CheckIP(labels config.AppIP, ip string) bool { | ||||||
| 	for _, blocked := range acls.Block { | 	for _, blocked := range labels.Block { | ||||||
| 		res, err := utils.FilterIP(blocked, ip) | 		res, err := utils.FilterIP(blocked, ip) | ||||||
| 		if err != nil { | 		if err != nil { | ||||||
| 			log.Warn().Err(err).Str("item", blocked).Msg("Invalid IP/CIDR in block list") | 			log.Warn().Err(err).Str("item", blocked).Msg("Invalid IP/CIDR in block list") | ||||||
| @@ -384,7 +382,7 @@ func (auth *AuthService) CheckIP(acls config.AppIP, ip string) bool { | |||||||
| 		} | 		} | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	for _, allowed := range acls.Allow { | 	for _, allowed := range labels.Allow { | ||||||
| 		res, err := utils.FilterIP(allowed, ip) | 		res, err := utils.FilterIP(allowed, ip) | ||||||
| 		if err != nil { | 		if err != nil { | ||||||
| 			log.Warn().Err(err).Str("item", allowed).Msg("Invalid IP/CIDR in allow list") | 			log.Warn().Err(err).Str("item", allowed).Msg("Invalid IP/CIDR in allow list") | ||||||
| @@ -396,7 +394,7 @@ func (auth *AuthService) CheckIP(acls config.AppIP, ip string) bool { | |||||||
| 		} | 		} | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	if len(acls.Allow) > 0 { | 	if len(labels.Allow) > 0 { | ||||||
| 		log.Debug().Str("ip", ip).Msg("IP not in allow list, denying access") | 		log.Debug().Str("ip", ip).Msg("IP not in allow list, denying access") | ||||||
| 		return false | 		return false | ||||||
| 	} | 	} | ||||||
| @@ -405,8 +403,8 @@ func (auth *AuthService) CheckIP(acls config.AppIP, ip string) bool { | |||||||
| 	return true | 	return true | ||||||
| } | } | ||||||
|  |  | ||||||
| func (auth *AuthService) IsBypassedIP(acls config.AppIP, ip string) bool { | func (auth *AuthService) IsBypassedIP(labels config.AppIP, ip string) bool { | ||||||
| 	for _, bypassed := range acls.Bypass { | 	for _, bypassed := range labels.Bypass { | ||||||
| 		res, err := utils.FilterIP(bypassed, ip) | 		res, err := utils.FilterIP(bypassed, ip) | ||||||
| 		if err != nil { | 		if err != nil { | ||||||
| 			log.Warn().Err(err).Str("item", bypassed).Msg("Invalid IP/CIDR in bypass list") | 			log.Warn().Err(err).Str("item", bypassed).Msg("Invalid IP/CIDR in bypass list") | ||||||
|   | |||||||
| @@ -59,8 +59,10 @@ func (generic *GenericOAuthService) Init() error { | |||||||
| 	ctx := context.Background() | 	ctx := context.Background() | ||||||
|  |  | ||||||
| 	ctx = context.WithValue(ctx, oauth2.HTTPClient, httpClient) | 	ctx = context.WithValue(ctx, oauth2.HTTPClient, httpClient) | ||||||
|  | 	verifier := oauth2.GenerateVerifier() | ||||||
|  |  | ||||||
| 	generic.context = ctx | 	generic.context = ctx | ||||||
|  | 	generic.verifier = verifier | ||||||
| 	return nil | 	return nil | ||||||
| } | } | ||||||
|  |  | ||||||
| @@ -74,12 +76,6 @@ func (generic *GenericOAuthService) GenerateState() string { | |||||||
| 	return state | 	return state | ||||||
| } | } | ||||||
|  |  | ||||||
| func (generic *GenericOAuthService) GenerateVerifier() string { |  | ||||||
| 	verifier := oauth2.GenerateVerifier() |  | ||||||
| 	generic.verifier = verifier |  | ||||||
| 	return verifier |  | ||||||
| } |  | ||||||
|  |  | ||||||
| func (generic *GenericOAuthService) GetAuthURL(state string) string { | func (generic *GenericOAuthService) GetAuthURL(state string) string { | ||||||
| 	return generic.config.AuthCodeURL(state, oauth2.AccessTypeOffline, oauth2.S256ChallengeOption(generic.verifier)) | 	return generic.config.AuthCodeURL(state, oauth2.AccessTypeOffline, oauth2.S256ChallengeOption(generic.verifier)) | ||||||
| } | } | ||||||
|   | |||||||
| @@ -53,7 +53,10 @@ func (github *GithubOAuthService) Init() error { | |||||||
| 	httpClient := &http.Client{} | 	httpClient := &http.Client{} | ||||||
| 	ctx := context.Background() | 	ctx := context.Background() | ||||||
| 	ctx = context.WithValue(ctx, oauth2.HTTPClient, httpClient) | 	ctx = context.WithValue(ctx, oauth2.HTTPClient, httpClient) | ||||||
|  | 	verifier := oauth2.GenerateVerifier() | ||||||
|  |  | ||||||
| 	github.context = ctx | 	github.context = ctx | ||||||
|  | 	github.verifier = verifier | ||||||
| 	return nil | 	return nil | ||||||
| } | } | ||||||
|  |  | ||||||
| @@ -67,12 +70,6 @@ func (github *GithubOAuthService) GenerateState() string { | |||||||
| 	return state | 	return state | ||||||
| } | } | ||||||
|  |  | ||||||
| func (github *GithubOAuthService) GenerateVerifier() string { |  | ||||||
| 	verifier := oauth2.GenerateVerifier() |  | ||||||
| 	github.verifier = verifier |  | ||||||
| 	return verifier |  | ||||||
| } |  | ||||||
|  |  | ||||||
| func (github *GithubOAuthService) GetAuthURL(state string) string { | func (github *GithubOAuthService) GetAuthURL(state string) string { | ||||||
| 	return github.config.AuthCodeURL(state, oauth2.AccessTypeOffline, oauth2.S256ChallengeOption(github.verifier)) | 	return github.config.AuthCodeURL(state, oauth2.AccessTypeOffline, oauth2.S256ChallengeOption(github.verifier)) | ||||||
| } | } | ||||||
|   | |||||||
| @@ -48,7 +48,10 @@ func (google *GoogleOAuthService) Init() error { | |||||||
| 	httpClient := &http.Client{} | 	httpClient := &http.Client{} | ||||||
| 	ctx := context.Background() | 	ctx := context.Background() | ||||||
| 	ctx = context.WithValue(ctx, oauth2.HTTPClient, httpClient) | 	ctx = context.WithValue(ctx, oauth2.HTTPClient, httpClient) | ||||||
|  | 	verifier := oauth2.GenerateVerifier() | ||||||
|  |  | ||||||
| 	google.context = ctx | 	google.context = ctx | ||||||
|  | 	google.verifier = verifier | ||||||
| 	return nil | 	return nil | ||||||
| } | } | ||||||
|  |  | ||||||
| @@ -62,12 +65,6 @@ func (oauth *GoogleOAuthService) GenerateState() string { | |||||||
| 	return state | 	return state | ||||||
| } | } | ||||||
|  |  | ||||||
| func (google *GoogleOAuthService) GenerateVerifier() string { |  | ||||||
| 	verifier := oauth2.GenerateVerifier() |  | ||||||
| 	google.verifier = verifier |  | ||||||
| 	return verifier |  | ||||||
| } |  | ||||||
|  |  | ||||||
| func (google *GoogleOAuthService) GetAuthURL(state string) string { | func (google *GoogleOAuthService) GetAuthURL(state string) string { | ||||||
| 	return google.config.AuthCodeURL(state, oauth2.AccessTypeOffline, oauth2.S256ChallengeOption(google.verifier)) | 	return google.config.AuthCodeURL(state, oauth2.AccessTypeOffline, oauth2.S256ChallengeOption(google.verifier)) | ||||||
| } | } | ||||||
|   | |||||||
| @@ -11,7 +11,6 @@ import ( | |||||||
| type OAuthService interface { | type OAuthService interface { | ||||||
| 	Init() error | 	Init() error | ||||||
| 	GenerateState() string | 	GenerateState() string | ||||||
| 	GenerateVerifier() string |  | ||||||
| 	GetAuthURL(state string) string | 	GetAuthURL(state string) string | ||||||
| 	VerifyCode(code string) error | 	VerifyCode(code string) error | ||||||
| 	Userinfo() (config.Claims, error) | 	Userinfo() (config.Claims, error) | ||||||
|   | |||||||
| @@ -147,7 +147,7 @@ func GetOAuthProvidersConfig(env []string, args []string, appUrl string) (map[st | |||||||
| 		} | 		} | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	envProviders, err := decoders.DecodeEnv[config.Providers, config.OAuthServiceConfig](envMap, "providers") | 	envProviders, err := decoders.DecodeEnv(envMap) | ||||||
|  |  | ||||||
| 	if err != nil { | 	if err != nil { | ||||||
| 		return nil, err | 		return nil, err | ||||||
| @@ -167,7 +167,7 @@ func GetOAuthProvidersConfig(env []string, args []string, appUrl string) (map[st | |||||||
| 		} | 		} | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	flagProviders, err := decoders.DecodeFlags[config.Providers, config.OAuthServiceConfig](flagsMap, "providers") | 	flagProviders, err := decoders.DecodeFlags(flagsMap) | ||||||
|  |  | ||||||
| 	if err != nil { | 	if err != nil { | ||||||
| 		return nil, err | 		return nil, err | ||||||
|   | |||||||
| @@ -3,24 +3,29 @@ package decoders | |||||||
| import ( | import ( | ||||||
| 	"reflect" | 	"reflect" | ||||||
| 	"strings" | 	"strings" | ||||||
|  | 	"tinyauth/internal/config" | ||||||
| 	"github.com/stoewer/go-strcase" |  | ||||||
| ) | ) | ||||||
|  |  | ||||||
| func normalizeKeys[T any](input map[string]string, root string, sep string) map[string]string { | func NormalizeKeys(keys map[string]string, rootName string, sep string) map[string]string { | ||||||
| 	knownKeys := getKnownKeys[T]() |  | ||||||
| 	normalized := make(map[string]string) | 	normalized := make(map[string]string) | ||||||
|  | 	knownKeys := getKnownKeys() | ||||||
|  |  | ||||||
| 	for k, v := range input { | 	for k, v := range keys { | ||||||
| 		parts := []string{"tinyauth"} | 		var finalKey []string | ||||||
|  | 		var suffix string | ||||||
|  | 		var camelClientName string | ||||||
|  | 		var camelField string | ||||||
|  |  | ||||||
| 		key := strings.ToLower(k) | 		finalKey = append(finalKey, rootName) | ||||||
| 		key = strings.ReplaceAll(key, sep, "-") | 		finalKey = append(finalKey, "providers") | ||||||
|  | 		lowerKey := strings.ToLower(k) | ||||||
|  |  | ||||||
| 		suffix := "" | 		if !strings.HasPrefix(lowerKey, "providers"+sep) { | ||||||
|  | 			continue | ||||||
|  | 		} | ||||||
|  |  | ||||||
| 		for _, known := range knownKeys { | 		for _, known := range knownKeys { | ||||||
| 			if strings.HasSuffix(key, known) { | 			if strings.HasSuffix(lowerKey, strings.ReplaceAll(known, "-", sep)) { | ||||||
| 				suffix = known | 				suffix = known | ||||||
| 				break | 				break | ||||||
| 			} | 			} | ||||||
| @@ -30,47 +35,55 @@ func normalizeKeys[T any](input map[string]string, root string, sep string) map[ | |||||||
| 			continue | 			continue | ||||||
| 		} | 		} | ||||||
|  |  | ||||||
| 		parts = append(parts, root) | 		if strings.TrimSpace(strings.TrimSuffix(strings.TrimPrefix(lowerKey, "providers"+sep), strings.ReplaceAll(suffix, "-", sep))) == "" { | ||||||
|  |  | ||||||
| 		id := strings.TrimPrefix(key, root+"-") |  | ||||||
| 		id = strings.TrimSuffix(id, "-"+suffix) |  | ||||||
|  |  | ||||||
| 		if id == "" { |  | ||||||
| 			continue | 			continue | ||||||
| 		} | 		} | ||||||
|  |  | ||||||
| 		parts = append(parts, id) | 		clientNameParts := strings.Split(strings.TrimPrefix(strings.TrimSuffix(lowerKey, sep+strings.ReplaceAll(suffix, "-", sep)), "providers"+sep), sep) | ||||||
| 		parts = append(parts, suffix) |  | ||||||
|  |  | ||||||
| 		final := "" | 		for i, p := range clientNameParts { | ||||||
|  | 			if i == 0 { | ||||||
| 		for i, part := range parts { | 				camelClientName += p | ||||||
| 			if i > 0 { | 				continue | ||||||
| 				final += "." |  | ||||||
| 			} | 			} | ||||||
| 			final += strcase.LowerCamelCase(part) | 			if p == "" { | ||||||
|  | 				continue | ||||||
|  | 			} | ||||||
|  | 			camelClientName += strings.ToUpper(string([]rune(p)[0])) + string([]rune(p)[1:]) | ||||||
| 		} | 		} | ||||||
|  |  | ||||||
| 		normalized[final] = v | 		finalKey = append(finalKey, camelClientName) | ||||||
|  |  | ||||||
|  | 		fieldParts := strings.Split(suffix, "-") | ||||||
|  |  | ||||||
|  | 		for i, p := range fieldParts { | ||||||
|  | 			if i == 0 { | ||||||
|  | 				camelField += p | ||||||
|  | 				continue | ||||||
|  | 			} | ||||||
|  | 			if p == "" { | ||||||
|  | 				continue | ||||||
|  | 			} | ||||||
|  | 			camelField += strings.ToUpper(string([]rune(p)[0])) + string([]rune(p)[1:]) | ||||||
|  | 		} | ||||||
|  |  | ||||||
|  | 		finalKey = append(finalKey, camelField) | ||||||
|  | 		normalized[strings.Join(finalKey, ".")] = v | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	return normalized | 	return normalized | ||||||
| } | } | ||||||
|  |  | ||||||
| func getKnownKeys[T any]() []string { | func getKnownKeys() []string { | ||||||
| 	var keys []string | 	var known []string | ||||||
| 	var t T |  | ||||||
|  |  | ||||||
| 	v := reflect.ValueOf(t) | 	p := config.OAuthServiceConfig{} | ||||||
| 	typeOfT := v.Type() | 	v := reflect.ValueOf(p) | ||||||
|  | 	typeOfP := v.Type() | ||||||
|  |  | ||||||
| 	for field := range typeOfT.NumField() { | 	for field := range typeOfP.NumField() { | ||||||
| 		if typeOfT.Field(field).Tag.Get("field") != "" { | 		known = append(known, typeOfP.Field(field).Tag.Get("key")) | ||||||
| 			keys = append(keys, typeOfT.Field(field).Tag.Get("field")) |  | ||||||
| 			continue |  | ||||||
| 		} |  | ||||||
| 		keys = append(keys, strcase.KebabCase(typeOfT.Field(field).Name)) |  | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	return keys | 	return known | ||||||
| } | } | ||||||
|   | |||||||
							
								
								
									
										49
									
								
								internal/utils/decoders/decoders_test.go
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										49
									
								
								internal/utils/decoders/decoders_test.go
									
									
									
									
									
										Normal file
									
								
							| @@ -0,0 +1,49 @@ | |||||||
|  | package decoders_test | ||||||
|  |  | ||||||
|  | import ( | ||||||
|  | 	"testing" | ||||||
|  | 	"tinyauth/internal/utils/decoders" | ||||||
|  |  | ||||||
|  | 	"gotest.tools/v3/assert" | ||||||
|  | ) | ||||||
|  |  | ||||||
|  | func TestNormalizeKeys(t *testing.T) { | ||||||
|  | 	// Test with env | ||||||
|  | 	test := map[string]string{ | ||||||
|  | 		"PROVIDERS_CLIENT1_CLIENT_ID":                    "my-client-id", | ||||||
|  | 		"PROVIDERS_CLIENT1_CLIENT_SECRET":                "my-client-secret", | ||||||
|  | 		"PROVIDERS_MY_AWESOME_CLIENT_CLIENT_ID":          "my-awesome-client-id", | ||||||
|  | 		"PROVIDERS_MY_AWESOME_CLIENT_CLIENT_SECRET_FILE": "/path/to/secret", | ||||||
|  | 		"I_LOOK_LIKE_A_KEY_CLIENT_ID":                    "should-not-appear", | ||||||
|  | 		"PROVIDERS_CLIENT_ID":                            "should-not-appear", | ||||||
|  | 	} | ||||||
|  | 	expected := map[string]string{ | ||||||
|  | 		"tinyauth.providers.client1.clientId":                 "my-client-id", | ||||||
|  | 		"tinyauth.providers.client1.clientSecret":             "my-client-secret", | ||||||
|  | 		"tinyauth.providers.myAwesomeClient.clientId":         "my-awesome-client-id", | ||||||
|  | 		"tinyauth.providers.myAwesomeClient.clientSecretFile": "/path/to/secret", | ||||||
|  | 	} | ||||||
|  |  | ||||||
|  | 	normalized := decoders.NormalizeKeys(test, "tinyauth", "_") | ||||||
|  | 	assert.DeepEqual(t, normalized, expected) | ||||||
|  |  | ||||||
|  | 	// Test with flags (assume -- is already stripped) | ||||||
|  | 	test = map[string]string{ | ||||||
|  | 		"providers-client1-client-id":                    "my-client-id", | ||||||
|  | 		"providers-client1-client-secret":                "my-client-secret", | ||||||
|  | 		"providers-my-awesome-client-client-id":          "my-awesome-client-id", | ||||||
|  | 		"providers-my-awesome-client-client-secret-file": "/path/to/secret", | ||||||
|  | 		"providers-should-not-appear-client":             "should-not-appear", | ||||||
|  | 		"i-look-like-a-key-client-id":                    "should-not-appear", | ||||||
|  | 		"providers-client-id":                            "should-not-appear", | ||||||
|  | 	} | ||||||
|  | 	expected = map[string]string{ | ||||||
|  | 		"tinyauth.providers.client1.clientId":                 "my-client-id", | ||||||
|  | 		"tinyauth.providers.client1.clientSecret":             "my-client-secret", | ||||||
|  | 		"tinyauth.providers.myAwesomeClient.clientId":         "my-awesome-client-id", | ||||||
|  | 		"tinyauth.providers.myAwesomeClient.clientSecretFile": "/path/to/secret", | ||||||
|  | 	} | ||||||
|  |  | ||||||
|  | 	normalized = decoders.NormalizeKeys(test, "tinyauth", "-") | ||||||
|  | 	assert.DeepEqual(t, normalized, expected) | ||||||
|  | } | ||||||
| @@ -1,19 +1,20 @@ | |||||||
| package decoders | package decoders | ||||||
|  |  | ||||||
| import ( | import ( | ||||||
|  | 	"tinyauth/internal/config" | ||||||
|  |  | ||||||
| 	"github.com/traefik/paerser/parser" | 	"github.com/traefik/paerser/parser" | ||||||
| ) | ) | ||||||
|  |  | ||||||
| func DecodeEnv[T any, C any](env map[string]string, subName string) (T, error) { | func DecodeEnv(env map[string]string) (config.Providers, error) { | ||||||
| 	var result T | 	normalized := NormalizeKeys(env, "tinyauth", "_") | ||||||
|  | 	var providers config.Providers | ||||||
|  |  | ||||||
| 	normalized := normalizeKeys[C](env, subName, "_") | 	err := parser.Decode(normalized, &providers, "tinyauth", "tinyauth.providers") | ||||||
|  |  | ||||||
| 	err := parser.Decode(normalized, &result, "tinyauth", "tinyauth."+subName) |  | ||||||
|  |  | ||||||
| 	if err != nil { | 	if err != nil { | ||||||
| 		return result, err | 		return config.Providers{}, err | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	return result, nil | 	return providers, nil | ||||||
| } | } | ||||||
|   | |||||||
| @@ -9,29 +9,52 @@ import ( | |||||||
| ) | ) | ||||||
|  |  | ||||||
| func TestDecodeEnv(t *testing.T) { | func TestDecodeEnv(t *testing.T) { | ||||||
| 	// Setup | 	// Variables | ||||||
| 	env := map[string]string{ |  | ||||||
| 		"PROVIDERS_GOOGLE_CLIENT_ID":        "google-client-id", |  | ||||||
| 		"PROVIDERS_GOOGLE_CLIENT_SECRET":    "google-client-secret", |  | ||||||
| 		"PROVIDERS_MY_GITHUB_CLIENT_ID":     "github-client-id", |  | ||||||
| 		"PROVIDERS_MY_GITHUB_CLIENT_SECRET": "github-client-secret", |  | ||||||
| 	} |  | ||||||
|  |  | ||||||
| 	expected := config.Providers{ | 	expected := config.Providers{ | ||||||
| 		Providers: map[string]config.OAuthServiceConfig{ | 		Providers: map[string]config.OAuthServiceConfig{ | ||||||
| 			"google": { | 			"client1": { | ||||||
| 				ClientID:     "google-client-id", | 				ClientID:           "client1-id", | ||||||
| 				ClientSecret: "google-client-secret", | 				ClientSecret:       "client1-secret", | ||||||
|  | 				Scopes:             []string{"client1-scope1", "client1-scope2"}, | ||||||
|  | 				RedirectURL:        "client1-redirect-url", | ||||||
|  | 				AuthURL:            "client1-auth-url", | ||||||
|  | 				UserinfoURL:        "client1-user-info-url", | ||||||
|  | 				Name:               "Client1", | ||||||
|  | 				InsecureSkipVerify: false, | ||||||
| 			}, | 			}, | ||||||
| 			"myGithub": { | 			"client2": { | ||||||
| 				ClientID:     "github-client-id", | 				ClientID:           "client2-id", | ||||||
| 				ClientSecret: "github-client-secret", | 				ClientSecret:       "client2-secret", | ||||||
|  | 				Scopes:             []string{"client2-scope1", "client2-scope2"}, | ||||||
|  | 				RedirectURL:        "client2-redirect-url", | ||||||
|  | 				AuthURL:            "client2-auth-url", | ||||||
|  | 				UserinfoURL:        "client2-user-info-url", | ||||||
|  | 				Name:               "My Awesome Client2", | ||||||
|  | 				InsecureSkipVerify: false, | ||||||
| 			}, | 			}, | ||||||
| 		}, | 		}, | ||||||
| 	} | 	} | ||||||
|  | 	test := map[string]string{ | ||||||
|  | 		"PROVIDERS_CLIENT1_CLIENT_ID":            "client1-id", | ||||||
|  | 		"PROVIDERS_CLIENT1_CLIENT_SECRET":        "client1-secret", | ||||||
|  | 		"PROVIDERS_CLIENT1_SCOPES":               "client1-scope1,client1-scope2", | ||||||
|  | 		"PROVIDERS_CLIENT1_REDIRECT_URL":         "client1-redirect-url", | ||||||
|  | 		"PROVIDERS_CLIENT1_AUTH_URL":             "client1-auth-url", | ||||||
|  | 		"PROVIDERS_CLIENT1_USER_INFO_URL":        "client1-user-info-url", | ||||||
|  | 		"PROVIDERS_CLIENT1_NAME":                 "Client1", | ||||||
|  | 		"PROVIDERS_CLIENT1_INSECURE_SKIP_VERIFY": "false", | ||||||
|  | 		"PROVIDERS_CLIENT2_CLIENT_ID":            "client2-id", | ||||||
|  | 		"PROVIDERS_CLIENT2_CLIENT_SECRET":        "client2-secret", | ||||||
|  | 		"PROVIDERS_CLIENT2_SCOPES":               "client2-scope1,client2-scope2", | ||||||
|  | 		"PROVIDERS_CLIENT2_REDIRECT_URL":         "client2-redirect-url", | ||||||
|  | 		"PROVIDERS_CLIENT2_AUTH_URL":             "client2-auth-url", | ||||||
|  | 		"PROVIDERS_CLIENT2_USER_INFO_URL":        "client2-user-info-url", | ||||||
|  | 		"PROVIDERS_CLIENT2_NAME":                 "My Awesome Client2", | ||||||
|  | 		"PROVIDERS_CLIENT2_INSECURE_SKIP_VERIFY": "false", | ||||||
|  | 	} | ||||||
|  |  | ||||||
| 	// Execute | 	// Test | ||||||
| 	result, err := decoders.DecodeEnv[config.Providers, config.OAuthServiceConfig](env, "providers") | 	res, err := decoders.DecodeEnv(test) | ||||||
| 	assert.NilError(t, err) | 	assert.NilError(t, err) | ||||||
| 	assert.DeepEqual(t, result, expected) | 	assert.DeepEqual(t, expected, res) | ||||||
| } | } | ||||||
|   | |||||||
| @@ -2,23 +2,23 @@ package decoders | |||||||
|  |  | ||||||
| import ( | import ( | ||||||
| 	"strings" | 	"strings" | ||||||
|  | 	"tinyauth/internal/config" | ||||||
|  |  | ||||||
| 	"github.com/traefik/paerser/parser" | 	"github.com/traefik/paerser/parser" | ||||||
| ) | ) | ||||||
|  |  | ||||||
| func DecodeFlags[T any, C any](flags map[string]string, subName string) (T, error) { | func DecodeFlags(flags map[string]string) (config.Providers, error) { | ||||||
| 	var result T |  | ||||||
|  |  | ||||||
| 	filtered := filterFlags(flags) | 	filtered := filterFlags(flags) | ||||||
| 	normalized := normalizeKeys[C](filtered, subName, "_") | 	normalized := NormalizeKeys(filtered, "tinyauth", "-") | ||||||
|  | 	var providers config.Providers | ||||||
|  |  | ||||||
| 	err := parser.Decode(normalized, &result, "tinyauth", "tinyauth."+subName) | 	err := parser.Decode(normalized, &providers, "tinyauth", "tinyauth.providers") | ||||||
|  |  | ||||||
| 	if err != nil { | 	if err != nil { | ||||||
| 		return result, err | 		return config.Providers{}, err | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	return result, nil | 	return providers, nil | ||||||
| } | } | ||||||
|  |  | ||||||
| func filterFlags(flags map[string]string) map[string]string { | func filterFlags(flags map[string]string) map[string]string { | ||||||
|   | |||||||
| @@ -9,29 +9,52 @@ import ( | |||||||
| ) | ) | ||||||
|  |  | ||||||
| func TestDecodeFlags(t *testing.T) { | func TestDecodeFlags(t *testing.T) { | ||||||
| 	// Setup | 	// Variables | ||||||
| 	flags := map[string]string{ |  | ||||||
| 		"--providers-google-client-id":        "google-client-id", |  | ||||||
| 		"--providers-google-client-secret":    "google-client-secret", |  | ||||||
| 		"--providers-my-github-client-id":     "github-client-id", |  | ||||||
| 		"--providers-my-github-client-secret": "github-client-secret", |  | ||||||
| 	} |  | ||||||
|  |  | ||||||
| 	expected := config.Providers{ | 	expected := config.Providers{ | ||||||
| 		Providers: map[string]config.OAuthServiceConfig{ | 		Providers: map[string]config.OAuthServiceConfig{ | ||||||
| 			"google": { | 			"client1": { | ||||||
| 				ClientID:     "google-client-id", | 				ClientID:           "client1-id", | ||||||
| 				ClientSecret: "google-client-secret", | 				ClientSecret:       "client1-secret", | ||||||
|  | 				Scopes:             []string{"client1-scope1", "client1-scope2"}, | ||||||
|  | 				RedirectURL:        "client1-redirect-url", | ||||||
|  | 				AuthURL:            "client1-auth-url", | ||||||
|  | 				UserinfoURL:        "client1-user-info-url", | ||||||
|  | 				Name:               "Client1", | ||||||
|  | 				InsecureSkipVerify: false, | ||||||
| 			}, | 			}, | ||||||
| 			"myGithub": { | 			"client2": { | ||||||
| 				ClientID:     "github-client-id", | 				ClientID:           "client2-id", | ||||||
| 				ClientSecret: "github-client-secret", | 				ClientSecret:       "client2-secret", | ||||||
|  | 				Scopes:             []string{"client2-scope1", "client2-scope2"}, | ||||||
|  | 				RedirectURL:        "client2-redirect-url", | ||||||
|  | 				AuthURL:            "client2-auth-url", | ||||||
|  | 				UserinfoURL:        "client2-user-info-url", | ||||||
|  | 				Name:               "My Awesome Client2", | ||||||
|  | 				InsecureSkipVerify: false, | ||||||
| 			}, | 			}, | ||||||
| 		}, | 		}, | ||||||
| 	} | 	} | ||||||
|  | 	test := map[string]string{ | ||||||
|  | 		"--providers-client1-client-id":            "client1-id", | ||||||
|  | 		"--providers-client1-client-secret":        "client1-secret", | ||||||
|  | 		"--providers-client1-scopes":               "client1-scope1,client1-scope2", | ||||||
|  | 		"--providers-client1-redirect-url":         "client1-redirect-url", | ||||||
|  | 		"--providers-client1-auth-url":             "client1-auth-url", | ||||||
|  | 		"--providers-client1-user-info-url":        "client1-user-info-url", | ||||||
|  | 		"--providers-client1-name":                 "Client1", | ||||||
|  | 		"--providers-client1-insecure-skip-verify": "false", | ||||||
|  | 		"--providers-client2-client-id":            "client2-id", | ||||||
|  | 		"--providers-client2-client-secret":        "client2-secret", | ||||||
|  | 		"--providers-client2-scopes":               "client2-scope1,client2-scope2", | ||||||
|  | 		"--providers-client2-redirect-url":         "client2-redirect-url", | ||||||
|  | 		"--providers-client2-auth-url":             "client2-auth-url", | ||||||
|  | 		"--providers-client2-user-info-url":        "client2-user-info-url", | ||||||
|  | 		"--providers-client2-name":                 "My Awesome Client2", | ||||||
|  | 		"--providers-client2-insecure-skip-verify": "false", | ||||||
|  | 	} | ||||||
|  |  | ||||||
| 	// Execute | 	// Test | ||||||
| 	result, err := decoders.DecodeFlags[config.Providers, config.OAuthServiceConfig](flags, "providers") | 	res, err := decoders.DecodeFlags(test) | ||||||
| 	assert.NilError(t, err) | 	assert.NilError(t, err) | ||||||
| 	assert.DeepEqual(t, result, expected) | 	assert.DeepEqual(t, expected, res) | ||||||
| } | } | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user