Compare commits
16 Commits
20251028
...
808da0fa97
| Author | SHA1 | Date | |
|---|---|---|---|
| 808da0fa97 | |||
| 02c7f764f5 | |||
| 7b8412682d | |||
| 5a05b547a8 | |||
| da2aa8aac2 | |||
| bc453cfd26 | |||
| 4b26a0ea12 | |||
| 242d725ad0 | |||
| ce4317299e | |||
| 14ede196c4 | |||
| 6d341069a0 | |||
| d4de81f1fb | |||
| 9a599fdde2 | |||
| 764ad3d5a1 | |||
| ffd93c5435 | |||
| 2a729d4153 |
2
.gitignore
vendored
2
.gitignore
vendored
@@ -1,3 +1,3 @@
|
|||||||
/target
|
/target
|
||||||
.idea
|
.idea
|
||||||
storage
|
/storage
|
||||||
|
|||||||
98
Cargo.lock
generated
98
Cargo.lock
generated
@@ -157,7 +157,7 @@ dependencies = [
|
|||||||
"futures-core",
|
"futures-core",
|
||||||
"futures-util",
|
"futures-util",
|
||||||
"mio",
|
"mio",
|
||||||
"socket2",
|
"socket2 0.5.8",
|
||||||
"tokio",
|
"tokio",
|
||||||
"tracing",
|
"tracing",
|
||||||
]
|
]
|
||||||
@@ -201,9 +201,9 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "actix-web"
|
name = "actix-web"
|
||||||
version = "4.11.0"
|
version = "4.12.0"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "a597b77b5c6d6a1e1097fddde329a83665e25c5437c696a3a9a4aa514a614dea"
|
checksum = "2233f53f6cb18ae038ce1f0713ca0c72ca0c4b71fe9aaeb59924ce2c89c6dd85"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"actix-codec",
|
"actix-codec",
|
||||||
"actix-http",
|
"actix-http",
|
||||||
@@ -236,7 +236,7 @@ dependencies = [
|
|||||||
"serde_json",
|
"serde_json",
|
||||||
"serde_urlencoded",
|
"serde_urlencoded",
|
||||||
"smallvec",
|
"smallvec",
|
||||||
"socket2",
|
"socket2 0.6.1",
|
||||||
"time",
|
"time",
|
||||||
"tracing",
|
"tracing",
|
||||||
"url",
|
"url",
|
||||||
@@ -400,9 +400,9 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "anyhow"
|
name = "anyhow"
|
||||||
version = "1.0.97"
|
version = "1.0.100"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "dcfed56ad506cb2c684a14971b8861fdc3baaaae314b9e5f9bb532cbe3ba7a4f"
|
checksum = "a23eb6b1614318a8071c9b2521f36b424b2c83db5eb3a0fead4a6c0809af6e61"
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "arrayref"
|
name = "arrayref"
|
||||||
@@ -660,9 +660,9 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "binstring"
|
name = "binstring"
|
||||||
version = "0.1.2"
|
version = "0.1.7"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "ed79c2a8151273c70956b5e3cdfdc1ff6c1a8b9779ba59c6807d281b32ee2f86"
|
checksum = "0669d5a35b64fdb5ab7fb19cae13148b6b5cbdf4b8247faf54ece47f699c8cef"
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "bitflags"
|
name = "bitflags"
|
||||||
@@ -808,9 +808,9 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "clap"
|
name = "clap"
|
||||||
version = "4.5.50"
|
version = "4.5.52"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "0c2cfd7bf8a6017ddaa4e32ffe7403d547790db06bd171c1c53926faab501623"
|
checksum = "aa8120877db0e5c011242f96806ce3c94e0737ab8108532a76a3300a01db2ab8"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"clap_builder",
|
"clap_builder",
|
||||||
"clap_derive",
|
"clap_derive",
|
||||||
@@ -818,9 +818,9 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "clap_builder"
|
name = "clap_builder"
|
||||||
version = "4.5.50"
|
version = "4.5.52"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "0a4c05b9e80c5ccd3a7ef080ad7b6ba7d6fc00a985b8b157197075677c82c7a0"
|
checksum = "02576b399397b659c26064fbc92a75fede9d18ffd5f80ca1cd74ddab167016e1"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"anstream",
|
"anstream",
|
||||||
"anstyle",
|
"anstyle",
|
||||||
@@ -973,9 +973,9 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "ct-codecs"
|
name = "ct-codecs"
|
||||||
version = "1.1.3"
|
version = "1.1.6"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "b916ba8ce9e4182696896f015e8a5ae6081b305f74690baa8465e35f5a142ea4"
|
checksum = "9b10589d1a5e400d61f9f38f12f884cfd080ff345de8f17efda36fe0e4a02aa8"
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "ctr"
|
name = "ctr"
|
||||||
@@ -1450,18 +1450,18 @@ checksum = "18492c9f6f9a560e0d346369b665ad2bdbc89fa9bceca75796584e79042694c3"
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "hmac-sha256"
|
name = "hmac-sha256"
|
||||||
version = "1.1.8"
|
version = "1.1.12"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "4a8575493d277c9092b988c780c94737fb9fd8651a1001e16bee3eccfc1baedb"
|
checksum = "ad6880c8d4a9ebf39c6e8b77007ce223f646a4d21ce29d99f70cb16420545425"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"digest",
|
"digest",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "hmac-sha512"
|
name = "hmac-sha512"
|
||||||
version = "1.1.6"
|
version = "1.1.7"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "b0b3a0f572aa8389d325f5852b9e0a333a15b0f86ecccbb3fdb6e97cd86dc67c"
|
checksum = "e89e8d20b3799fa526152a5301a771eaaad80857f83e01b23216ceaafb2d9280"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"digest",
|
"digest",
|
||||||
]
|
]
|
||||||
@@ -1598,7 +1598,7 @@ dependencies = [
|
|||||||
"http-body",
|
"http-body",
|
||||||
"hyper",
|
"hyper",
|
||||||
"pin-project-lite",
|
"pin-project-lite",
|
||||||
"socket2",
|
"socket2 0.5.8",
|
||||||
"tokio",
|
"tokio",
|
||||||
"tower-service",
|
"tower-service",
|
||||||
"tracing",
|
"tracing",
|
||||||
@@ -1886,9 +1886,9 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "jwt-simple"
|
name = "jwt-simple"
|
||||||
version = "0.12.12"
|
version = "0.12.13"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "731011e9647a71ff4f8474176ff6ce6e0d2de87a0173f15613af3a84c3e3401a"
|
checksum = "6ad8761f175784dfbb83709f322fc4daf6b27afd5bf375492f2876f9e925ef5a"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"anyhow",
|
"anyhow",
|
||||||
"binstring",
|
"binstring",
|
||||||
@@ -1906,7 +1906,7 @@ dependencies = [
|
|||||||
"serde",
|
"serde",
|
||||||
"serde_json",
|
"serde_json",
|
||||||
"superboring",
|
"superboring",
|
||||||
"thiserror 2.0.12",
|
"thiserror 2.0.17",
|
||||||
"zeroize",
|
"zeroize",
|
||||||
]
|
]
|
||||||
|
|
||||||
@@ -1932,9 +1932,9 @@ checksum = "d4345964bb142484797b161f473a503a434de77149dd8c7427788c6e13379388"
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "lazy-regex"
|
name = "lazy-regex"
|
||||||
version = "3.4.1"
|
version = "3.4.2"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "60c7310b93682b36b98fa7ea4de998d3463ccbebd94d935d6b48ba5b6ffa7126"
|
checksum = "191898e17ddee19e60bccb3945aa02339e81edd4a8c50e21fd4d48cdecda7b29"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"lazy-regex-proc_macros",
|
"lazy-regex-proc_macros",
|
||||||
"once_cell",
|
"once_cell",
|
||||||
@@ -1943,9 +1943,9 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "lazy-regex-proc_macros"
|
name = "lazy-regex-proc_macros"
|
||||||
version = "3.4.1"
|
version = "3.4.2"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "4ba01db5ef81e17eb10a5e0f2109d1b3a3e29bac3070fdbd7d156bf7dbd206a1"
|
checksum = "c35dc8b0da83d1a9507e12122c80dea71a9c7c613014347392483a83ea593e04"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"proc-macro2",
|
"proc-macro2",
|
||||||
"quote",
|
"quote",
|
||||||
@@ -1964,9 +1964,9 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "libc"
|
name = "libc"
|
||||||
version = "0.2.171"
|
version = "0.2.177"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "c19937216e9d3aa9956d9bb8dfc0b0c8beb6058fc4f7a4dc4d850edf86a237d6"
|
checksum = "2874a2af47a2325c2001a6e6fad9b16a53b802102b528163885171cf92b15976"
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "libm"
|
name = "libm"
|
||||||
@@ -2957,6 +2957,16 @@ dependencies = [
|
|||||||
"windows-sys 0.52.0",
|
"windows-sys 0.52.0",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "socket2"
|
||||||
|
version = "0.6.1"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "17129e116933cf371d018bb80ae557e889637989d8638274fb25622827b03881"
|
||||||
|
dependencies = [
|
||||||
|
"libc",
|
||||||
|
"windows-sys 0.60.2",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "spin"
|
name = "spin"
|
||||||
version = "0.9.8"
|
version = "0.9.8"
|
||||||
@@ -3080,11 +3090,11 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "thiserror"
|
name = "thiserror"
|
||||||
version = "2.0.12"
|
version = "2.0.17"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "567b8a2dae586314f7be2a752ec7474332959c6460e02bde30d702a66d488708"
|
checksum = "f63587ca0f12b72a0600bcba1d40081f830876000bb46dd2337a3051618f4fc8"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"thiserror-impl 2.0.12",
|
"thiserror-impl 2.0.17",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
@@ -3100,9 +3110,9 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "thiserror-impl"
|
name = "thiserror-impl"
|
||||||
version = "2.0.12"
|
version = "2.0.17"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "7f7cf42b4507d8ea322120659672cf1b9dbb93f8f2d4ecfd6e51350ff5b17a1d"
|
checksum = "3ff15c8ecd7de3849db632e14d18d2571fa09dfc5ed93479bc4485c7a517c913"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"proc-macro2",
|
"proc-macro2",
|
||||||
"quote",
|
"quote",
|
||||||
@@ -3163,7 +3173,7 @@ dependencies = [
|
|||||||
"parking_lot",
|
"parking_lot",
|
||||||
"pin-project-lite",
|
"pin-project-lite",
|
||||||
"signal-hook-registry",
|
"signal-hook-registry",
|
||||||
"socket2",
|
"socket2 0.5.8",
|
||||||
"windows-sys 0.52.0",
|
"windows-sys 0.52.0",
|
||||||
]
|
]
|
||||||
|
|
||||||
@@ -3611,7 +3621,7 @@ checksum = "4286ad90ddb45071efd1a66dfa43eb02dd0dfbae1545ad6cc3c51cf34d7e8ba3"
|
|||||||
dependencies = [
|
dependencies = [
|
||||||
"windows-result",
|
"windows-result",
|
||||||
"windows-strings",
|
"windows-strings",
|
||||||
"windows-targets 0.53.0",
|
"windows-targets 0.53.4",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
@@ -3650,6 +3660,15 @@ dependencies = [
|
|||||||
"windows-targets 0.52.6",
|
"windows-targets 0.52.6",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "windows-sys"
|
||||||
|
version = "0.60.2"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "f2f500e4d28234f72040990ec9d39e3a6b950f9f22d3dba18416c35882612bcb"
|
||||||
|
dependencies = [
|
||||||
|
"windows-targets 0.53.4",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "windows-targets"
|
name = "windows-targets"
|
||||||
version = "0.52.6"
|
version = "0.52.6"
|
||||||
@@ -3668,10 +3687,11 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "windows-targets"
|
name = "windows-targets"
|
||||||
version = "0.53.0"
|
version = "0.53.4"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "b1e4c7e8ceaaf9cb7d7507c974735728ab453b67ef8f18febdd7c11fe59dca8b"
|
checksum = "2d42b7b7f66d2a06854650af09cfdf8713e427a439c97ad65a6375318033ac4b"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
|
"windows-link 0.2.0",
|
||||||
"windows_aarch64_gnullvm 0.53.0",
|
"windows_aarch64_gnullvm 0.53.0",
|
||||||
"windows_aarch64_msvc 0.53.0",
|
"windows_aarch64_msvc 0.53.0",
|
||||||
"windows_i686_gnu 0.53.0",
|
"windows_i686_gnu 0.53.0",
|
||||||
@@ -3892,9 +3912,9 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "zeroize"
|
name = "zeroize"
|
||||||
version = "1.8.1"
|
version = "1.8.2"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "ced3678a2879b30306d323f4542626697a464a97c0a07c9aebf7ebca65cd4dde"
|
checksum = "b97154e67e32c85465826e8bcc1c59429aaaf107c1e4a9e53c8d8ccd5eff88d0"
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "zerovec"
|
name = "zerovec"
|
||||||
|
|||||||
@@ -8,10 +8,10 @@ edition = "2024"
|
|||||||
[dependencies]
|
[dependencies]
|
||||||
actix = "0.13.5"
|
actix = "0.13.5"
|
||||||
actix-identity = "0.9.0"
|
actix-identity = "0.9.0"
|
||||||
actix-web = "4.11.0"
|
actix-web = "4.12.0"
|
||||||
actix-session = { version = "0.11.0", features = ["cookie-session"] }
|
actix-session = { version = "0.11.0", features = ["cookie-session"] }
|
||||||
actix-remote-ip = "0.1.0"
|
actix-remote-ip = "0.1.0"
|
||||||
clap = { version = "4.5.50", features = ["derive", "env"] }
|
clap = { version = "4.5.52", features = ["derive", "env"] }
|
||||||
include_dir = "0.7.4"
|
include_dir = "0.7.4"
|
||||||
log = "0.4.28"
|
log = "0.4.28"
|
||||||
serde_json = "1.0.145"
|
serde_json = "1.0.145"
|
||||||
@@ -25,10 +25,10 @@ askama = "0.14.0"
|
|||||||
urlencoding = "2.1.3"
|
urlencoding = "2.1.3"
|
||||||
rand = "0.9.2"
|
rand = "0.9.2"
|
||||||
base64 = "0.22.1"
|
base64 = "0.22.1"
|
||||||
jwt-simple = { version = "0.12.12", default-features = false, features = ["pure-rust"] }
|
jwt-simple = { version = "0.12.13", default-features = false, features = ["pure-rust"] }
|
||||||
digest = "0.10.7"
|
digest = "0.10.7"
|
||||||
sha2 = "0.10.9"
|
sha2 = "0.10.9"
|
||||||
lazy-regex = "3.4.1"
|
lazy-regex = "3.4.2"
|
||||||
totp_rfc6238 = "0.6.1"
|
totp_rfc6238 = "0.6.1"
|
||||||
base32 = "0.5.1"
|
base32 = "0.5.1"
|
||||||
qrcode-generator = "5.0.0"
|
qrcode-generator = "5.0.0"
|
||||||
|
|||||||
18
README.md
18
README.md
@@ -67,10 +67,11 @@ You can add as much upstream provider as you want, using the following syntax in
|
|||||||
```yaml
|
```yaml
|
||||||
- id: gitlab
|
- id: gitlab
|
||||||
name: GitLab
|
name: GitLab
|
||||||
logo: gitlab # Can be either gitea, gitlab, github, microsoft, google or a full URL
|
logo: gitlab # Can be either openid, gitea, gitlab, github, microsoft, google or a full URL
|
||||||
client_id: CLIENT_ID_GIVEN_BY_PROVIDER
|
client_id: CLIENT_ID_GIVEN_BY_PROVIDER
|
||||||
client_secret: CLIENT_SECRET_GIVEN_BY_PROVIDER
|
client_secret: CLIENT_SECRET_GIVEN_BY_PROVIDER
|
||||||
configuration_url: https://gitlab.com/.well-known/openid-configuration
|
configuration_url: https://gitlab.com/.well-known/openid-configuration
|
||||||
|
allow_auto_account_creation: true
|
||||||
|
|
||||||
```
|
```
|
||||||
|
|
||||||
@@ -108,5 +109,20 @@ Corresponding client configuration:
|
|||||||
|
|
||||||
OAuth proxy can then be access on this URL: http://192.168.2.103:4180/
|
OAuth proxy can then be access on this URL: http://192.168.2.103:4180/
|
||||||
|
|
||||||
|
## Testing with upstream identity provider
|
||||||
|
The folder [sample_upstream_provider](sample_upstream_provider) contains a working scenario of authentication with an upstream provider.
|
||||||
|
|
||||||
|
Run the following command to run the scenario:
|
||||||
|
|
||||||
|
```bash
|
||||||
|
cd sample_upstream_provider
|
||||||
|
docker compose up
|
||||||
|
```
|
||||||
|
|
||||||
|
- Upstream provider (not to be directly used): http://localhost:9001
|
||||||
|
- BasicOIDC: http://localhost:8000
|
||||||
|
- Client 2: http://localhost:8012
|
||||||
|
- Client 1: http://localhost:8011
|
||||||
|
|
||||||
## Contributing
|
## Contributing
|
||||||
If you wish to contribute to this software, feel free to send an email to contact@communiquons.org to get an account on my system, managed by BasicOIDC :)
|
If you wish to contribute to this software, feel free to send an email to contact@communiquons.org to get an account on my system, managed by BasicOIDC :)
|
||||||
|
|||||||
@@ -14,7 +14,6 @@ body {
|
|||||||
/* background */
|
/* background */
|
||||||
@media screen and (min-width: 767px) {
|
@media screen and (min-width: 767px) {
|
||||||
.bg-login {
|
.bg-login {
|
||||||
background-image: url(/assets/img/forest.jpg);
|
|
||||||
width: 100%;
|
width: 100%;
|
||||||
height: 100%;
|
height: 100%;
|
||||||
position: fixed;
|
position: fixed;
|
||||||
|
|||||||
@@ -21,3 +21,7 @@ body {
|
|||||||
.form-control::placeholder {
|
.form-control::placeholder {
|
||||||
color: #555;
|
color: #555;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
.table-break-works td {
|
||||||
|
word-break: break-all;
|
||||||
|
}
|
||||||
1
assets/img/brands/openid.svg
Normal file
1
assets/img/brands/openid.svg
Normal file
@@ -0,0 +1 @@
|
|||||||
|
<svg role="img" viewBox="0 0 24 24" xmlns="http://www.w3.org/2000/svg"><title>OpenID</title><path d="M14.54.889l-3.63 1.773v18.17c-4.15-.52-7.27-2.78-7.27-5.5 0-2.58 2.8-4.75 6.63-5.41v-2.31C4.42 8.322 0 11.502 0 15.332c0 3.96 4.74 7.24 10.91 7.78l3.63-1.71V.888m.64 6.724v2.31c1.43.25 2.71.7 3.76 1.31l-1.97 1.11 7.03 1.53-.5-5.21-1.87 1.06c-1.74-1.06-3.96-1.81-6.45-2.11z"/></svg>
|
||||||
|
After Width: | Height: | Size: 382 B |
26
sample_upstream_provider/dex-provider/dex.config.yaml
Normal file
26
sample_upstream_provider/dex-provider/dex.config.yaml
Normal file
@@ -0,0 +1,26 @@
|
|||||||
|
issuer: http://127.0.0.1:9001/dex
|
||||||
|
|
||||||
|
storage:
|
||||||
|
type: memory
|
||||||
|
|
||||||
|
web:
|
||||||
|
http: 0.0.0.0:9001
|
||||||
|
|
||||||
|
oauth2:
|
||||||
|
# Automate some clicking
|
||||||
|
# Note: this might actually make some tests pass that otherwise wouldn't.
|
||||||
|
skipApprovalScreen: false
|
||||||
|
|
||||||
|
connectors:
|
||||||
|
# Note: this might actually make some tests pass that otherwise wouldn't.
|
||||||
|
- type: mockCallback
|
||||||
|
id: mock
|
||||||
|
name: Example
|
||||||
|
|
||||||
|
# Basic OP test suite requires two clients.
|
||||||
|
staticClients:
|
||||||
|
- id: foo
|
||||||
|
secret: bar
|
||||||
|
redirectURIs:
|
||||||
|
- http://localhost:8000/prov_cb
|
||||||
|
name: Auth
|
||||||
47
sample_upstream_provider/docker-compose.yaml
Normal file
47
sample_upstream_provider/docker-compose.yaml
Normal file
@@ -0,0 +1,47 @@
|
|||||||
|
services:
|
||||||
|
upstream:
|
||||||
|
image: dexidp/dex
|
||||||
|
user: "1000"
|
||||||
|
network_mode: host
|
||||||
|
volumes:
|
||||||
|
- ./dex-provider:/conf:ro
|
||||||
|
command: [ "dex", "serve", "/conf/dex.config.yaml" ]
|
||||||
|
|
||||||
|
client1:
|
||||||
|
image: pierre42100/oidc_test_client
|
||||||
|
user: "1000"
|
||||||
|
network_mode: host
|
||||||
|
environment:
|
||||||
|
- LISTEN_ADDR=0.0.0.0:8011
|
||||||
|
- PUBLIC_URL=http://127.0.0.1:8011
|
||||||
|
- CONFIGURATION_URL=http://localhost:8000/.well-known/openid-configuration
|
||||||
|
- CLIENT_ID=testclient1
|
||||||
|
- CLIENT_SECRET=secretone
|
||||||
|
|
||||||
|
client2:
|
||||||
|
image: pierre42100/oidc_test_client
|
||||||
|
user: "1000"
|
||||||
|
network_mode: host
|
||||||
|
environment:
|
||||||
|
- LISTEN_ADDR=0.0.0.0:8012
|
||||||
|
- PUBLIC_URL=http://127.0.0.1:8012
|
||||||
|
- CONFIGURATION_URL=http://localhost:8000/.well-known/openid-configuration
|
||||||
|
- CLIENT_ID=testclient2
|
||||||
|
- CLIENT_SECRET=secrettwo
|
||||||
|
|
||||||
|
basicoidc:
|
||||||
|
image: rust
|
||||||
|
user: "1000"
|
||||||
|
network_mode: host
|
||||||
|
environment:
|
||||||
|
- STORAGE_PATH=/storage
|
||||||
|
- DISABLE_LOCAL_LOGIN=true
|
||||||
|
#- RUST_LOG=debug
|
||||||
|
volumes:
|
||||||
|
- ../:/app
|
||||||
|
- ./storage:/storage
|
||||||
|
- ~/.cargo/registry:/usr/local/cargo/registry
|
||||||
|
command:
|
||||||
|
- bash
|
||||||
|
- -c
|
||||||
|
- cd /app && cargo run
|
||||||
1
sample_upstream_provider/storage/.gitignore
vendored
Normal file
1
sample_upstream_provider/storage/.gitignore
vendored
Normal file
@@ -0,0 +1 @@
|
|||||||
|
users.json
|
||||||
11
sample_upstream_provider/storage/clients.yaml
Normal file
11
sample_upstream_provider/storage/clients.yaml
Normal file
@@ -0,0 +1,11 @@
|
|||||||
|
- id: testclient1
|
||||||
|
name: Client 1
|
||||||
|
description: client1
|
||||||
|
secret: secretone
|
||||||
|
redirect_uri: http://127.0.0.1:8011/
|
||||||
|
granted_to_all_users: true
|
||||||
|
- id: testclient2
|
||||||
|
name: Client 2
|
||||||
|
description: client2
|
||||||
|
secret: secrettwo
|
||||||
|
redirect_uri: http://127.0.0.1:8012/
|
||||||
7
sample_upstream_provider/storage/providers.yaml
Normal file
7
sample_upstream_provider/storage/providers.yaml
Normal file
@@ -0,0 +1,7 @@
|
|||||||
|
- id: upstream
|
||||||
|
name: Upstream
|
||||||
|
logo: openid
|
||||||
|
client_id: foo
|
||||||
|
client_secret: bar
|
||||||
|
configuration_url: http://127.0.0.1:9001/dex/.well-known/openid-configuration
|
||||||
|
allow_auto_account_creation: true
|
||||||
@@ -17,7 +17,7 @@ use crate::data::provider::ProviderID;
|
|||||||
use crate::utils::string_utils::rand_str;
|
use crate::utils::string_utils::rand_str;
|
||||||
use crate::utils::time::time;
|
use crate::utils::time::time;
|
||||||
|
|
||||||
#[derive(Debug, Clone)]
|
#[derive(Debug, Clone, serde::Serialize)]
|
||||||
pub struct ProviderLoginState {
|
pub struct ProviderLoginState {
|
||||||
pub provider_id: ProviderID,
|
pub provider_id: ProviderID,
|
||||||
pub state_id: String,
|
pub state_id: String,
|
||||||
|
|||||||
@@ -1,10 +1,11 @@
|
|||||||
use std::net::IpAddr;
|
use std::net::IpAddr;
|
||||||
|
|
||||||
use crate::data::provider::{Provider, ProviderID};
|
use crate::data::provider::{Provider, ProviderID};
|
||||||
use actix::{Actor, Context, Handler, Message, MessageResult};
|
|
||||||
|
|
||||||
use crate::data::user::{FactorID, GeneralSettings, GrantedClients, TwoFactor, User, UserID};
|
use crate::data::user::{FactorID, GeneralSettings, GrantedClients, TwoFactor, User, UserID};
|
||||||
use crate::utils::err::Res;
|
use crate::utils::err::Res;
|
||||||
|
use crate::utils::string_utils::is_acceptable_login;
|
||||||
|
use actix::{Actor, Context, Handler, Message, MessageResult};
|
||||||
|
use light_openid::primitives::OpenIDUserInfo;
|
||||||
|
|
||||||
/// User storage interface
|
/// User storage interface
|
||||||
pub trait UsersSyncBackend {
|
pub trait UsersSyncBackend {
|
||||||
@@ -38,6 +39,8 @@ pub enum LoginResult {
|
|||||||
LocalAuthForbidden,
|
LocalAuthForbidden,
|
||||||
AuthFromProviderForbidden,
|
AuthFromProviderForbidden,
|
||||||
Success(Box<User>),
|
Success(Box<User>),
|
||||||
|
AccountAutoCreated(Box<User>),
|
||||||
|
CannotAutoCreateAccount(String),
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Message)]
|
#[derive(Message)]
|
||||||
@@ -51,6 +54,7 @@ pub struct LocalLoginRequest {
|
|||||||
#[rtype(LoginResult)]
|
#[rtype(LoginResult)]
|
||||||
pub struct ProviderLoginRequest {
|
pub struct ProviderLoginRequest {
|
||||||
pub email: String,
|
pub email: String,
|
||||||
|
pub user_info: OpenIDUserInfo,
|
||||||
pub provider: Provider,
|
pub provider: Provider,
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -104,7 +108,7 @@ pub struct AddSuccessful2FALogin(pub UserID, pub IpAddr);
|
|||||||
#[rtype(result = "bool")]
|
#[rtype(result = "bool")]
|
||||||
pub struct Clear2FALoginHistory(pub UserID);
|
pub struct Clear2FALoginHistory(pub UserID);
|
||||||
|
|
||||||
#[derive(Eq, PartialEq, Debug, Clone)]
|
#[derive(Eq, PartialEq, Debug, Clone, serde::Serialize)]
|
||||||
pub struct AuthorizedAuthenticationSources {
|
pub struct AuthorizedAuthenticationSources {
|
||||||
pub local: bool,
|
pub local: bool,
|
||||||
pub upstream: Vec<ProviderID>,
|
pub upstream: Vec<ProviderID>,
|
||||||
@@ -187,7 +191,86 @@ impl Handler<ProviderLoginRequest> for UsersActor {
|
|||||||
log::error!("Failed to find user! {e}");
|
log::error!("Failed to find user! {e}");
|
||||||
MessageResult(LoginResult::Error)
|
MessageResult(LoginResult::Error)
|
||||||
}
|
}
|
||||||
Ok(None) => MessageResult(LoginResult::AccountNotFound),
|
Ok(None) => {
|
||||||
|
// Check if automatic account creation is enabled for this provider
|
||||||
|
if !msg.provider.allow_auto_account_creation {
|
||||||
|
return MessageResult(LoginResult::AccountNotFound);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Extract username for account creation
|
||||||
|
let mut username = msg
|
||||||
|
.user_info
|
||||||
|
.preferred_username
|
||||||
|
.unwrap_or(msg.email.to_string());
|
||||||
|
|
||||||
|
// Determine username from email, if necessary
|
||||||
|
if !is_acceptable_login(&username)
|
||||||
|
|| matches!(
|
||||||
|
self.manager.find_by_username_or_email(&username),
|
||||||
|
Ok(Some(_))
|
||||||
|
)
|
||||||
|
{
|
||||||
|
username = msg.email.clone();
|
||||||
|
}
|
||||||
|
|
||||||
|
// Check if username is already taken
|
||||||
|
if matches!(
|
||||||
|
self.manager.find_by_username_or_email(&username),
|
||||||
|
Ok(Some(_))
|
||||||
|
) {
|
||||||
|
return MessageResult(LoginResult::CannotAutoCreateAccount(format!(
|
||||||
|
"username {username} is already taken!"
|
||||||
|
)));
|
||||||
|
}
|
||||||
|
|
||||||
|
if !is_acceptable_login(&username) {
|
||||||
|
return MessageResult(LoginResult::CannotAutoCreateAccount(
|
||||||
|
"could not determine acceptable login for user!".to_string(),
|
||||||
|
));
|
||||||
|
}
|
||||||
|
|
||||||
|
// Automatic account creation
|
||||||
|
let user_id = match self.manager.create_user_account(GeneralSettings {
|
||||||
|
uid: UserID::random(),
|
||||||
|
username,
|
||||||
|
first_name: msg.user_info.given_name.unwrap_or_default(),
|
||||||
|
last_name: msg.user_info.family_name.unwrap_or_default(),
|
||||||
|
email: msg.email.to_string(),
|
||||||
|
enabled: true,
|
||||||
|
two_factor_exemption_after_successful_login: false,
|
||||||
|
is_admin: false,
|
||||||
|
}) {
|
||||||
|
Ok(u) => u,
|
||||||
|
Err(e) => {
|
||||||
|
log::error!("Failed to create user account! {e}");
|
||||||
|
return MessageResult(LoginResult::CannotAutoCreateAccount(
|
||||||
|
"missing some user information".to_string(),
|
||||||
|
));
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
// Mark the provider as the only authorized source
|
||||||
|
if let Err(e) = self.manager.set_authorized_authentication_sources(
|
||||||
|
&user_id,
|
||||||
|
AuthorizedAuthenticationSources {
|
||||||
|
local: false,
|
||||||
|
upstream: vec![msg.provider.id],
|
||||||
|
},
|
||||||
|
) {
|
||||||
|
log::error!(
|
||||||
|
"Failed to set authorized authentication sources for newly created account! {e}"
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Extract user information to return them
|
||||||
|
let Ok(Some(user)) = self.manager.find_by_user_id(&user_id) else {
|
||||||
|
return MessageResult(LoginResult::CannotAutoCreateAccount(
|
||||||
|
"failed to get created user information".to_string(),
|
||||||
|
));
|
||||||
|
};
|
||||||
|
|
||||||
|
MessageResult(LoginResult::AccountAutoCreated(Box::new(user)))
|
||||||
|
}
|
||||||
Ok(Some(user)) => {
|
Ok(Some(user)) => {
|
||||||
if !user.can_login_from_provider(&msg.provider) {
|
if !user.can_login_from_provider(&msg.provider) {
|
||||||
return MessageResult(LoginResult::AuthFromProviderForbidden);
|
return MessageResult(LoginResult::AuthFromProviderForbidden);
|
||||||
|
|||||||
@@ -65,7 +65,9 @@ pub async fn delete_user(
|
|||||||
|
|
||||||
let res = users.send(DeleteUserRequest(req.0.user_id)).await.unwrap();
|
let res = users.send(DeleteUserRequest(req.0.user_id)).await.unwrap();
|
||||||
if res {
|
if res {
|
||||||
action_logger.log(Action::AdminDeleteUser(&user));
|
action_logger.log(Action::AdminDeleteUser {
|
||||||
|
user: user.loggable(),
|
||||||
|
});
|
||||||
HttpResponse::Ok().finish()
|
HttpResponse::Ok().finish()
|
||||||
} else {
|
} else {
|
||||||
HttpResponse::InternalServerError().finish()
|
HttpResponse::InternalServerError().finish()
|
||||||
|
|||||||
@@ -165,7 +165,10 @@ pub async fn users_route(
|
|||||||
let factors_to_keep = update.0.two_factor.split(';').collect::<Vec<_>>();
|
let factors_to_keep = update.0.two_factor.split(';').collect::<Vec<_>>();
|
||||||
for factor in &edited_user.two_factor {
|
for factor in &edited_user.two_factor {
|
||||||
if !factors_to_keep.contains(&factor.id.0.as_str()) {
|
if !factors_to_keep.contains(&factor.id.0.as_str()) {
|
||||||
logger.log(Action::AdminRemoveUserFactor(&edited_user, factor));
|
logger.log(Action::AdminRemoveUserFactor {
|
||||||
|
user: edited_user.loggable(),
|
||||||
|
factor: factor.loggable(),
|
||||||
|
});
|
||||||
users
|
users
|
||||||
.send(users_actor::Remove2FAFactor(
|
.send(users_actor::Remove2FAFactor(
|
||||||
edited_user.uid.clone(),
|
edited_user.uid.clone(),
|
||||||
@@ -186,10 +189,10 @@ pub async fn users_route(
|
|||||||
};
|
};
|
||||||
|
|
||||||
if edited_user.authorized_authentication_sources() != auth_sources {
|
if edited_user.authorized_authentication_sources() != auth_sources {
|
||||||
logger.log(Action::AdminSetAuthorizedAuthenticationSources(
|
logger.log(Action::AdminSetAuthorizedAuthenticationSources {
|
||||||
&edited_user,
|
user: edited_user.loggable(),
|
||||||
&auth_sources,
|
sources: &auth_sources,
|
||||||
));
|
});
|
||||||
users
|
users
|
||||||
.send(users_actor::SetAuthorizedAuthenticationSources(
|
.send(users_actor::SetAuthorizedAuthenticationSources(
|
||||||
edited_user.uid.clone(),
|
edited_user.uid.clone(),
|
||||||
@@ -216,10 +219,10 @@ pub async fn users_route(
|
|||||||
};
|
};
|
||||||
|
|
||||||
if edited_user.granted_clients() != granted_clients {
|
if edited_user.granted_clients() != granted_clients {
|
||||||
logger.log(Action::AdminSetNewGrantedClientsList(
|
logger.log(Action::AdminSetNewGrantedClientsList {
|
||||||
&edited_user,
|
user: edited_user.loggable(),
|
||||||
&granted_clients,
|
clients: &granted_clients,
|
||||||
));
|
});
|
||||||
users
|
users
|
||||||
.send(users_actor::SetGrantedClients(
|
.send(users_actor::SetGrantedClients(
|
||||||
edited_user.uid.clone(),
|
edited_user.uid.clone(),
|
||||||
@@ -231,7 +234,9 @@ pub async fn users_route(
|
|||||||
|
|
||||||
// Clear user 2FA history if requested
|
// Clear user 2FA history if requested
|
||||||
if update.0.clear_2fa_history.is_some() {
|
if update.0.clear_2fa_history.is_some() {
|
||||||
logger.log(Action::AdminClear2FAHistory(&edited_user));
|
logger.log(Action::AdminClear2FAHistory {
|
||||||
|
user: edited_user.loggable(),
|
||||||
|
});
|
||||||
users
|
users
|
||||||
.send(users_actor::Clear2FALoginHistory(edited_user.uid.clone()))
|
.send(users_actor::Clear2FALoginHistory(edited_user.uid.clone()))
|
||||||
.await
|
.await
|
||||||
@@ -242,7 +247,9 @@ pub async fn users_route(
|
|||||||
let new_password = match update.0.gen_new_password.is_some() {
|
let new_password = match update.0.gen_new_password.is_some() {
|
||||||
false => None,
|
false => None,
|
||||||
true => {
|
true => {
|
||||||
logger.log(Action::AdminResetUserPassword(&edited_user));
|
logger.log(Action::AdminResetUserPassword {
|
||||||
|
user: edited_user.loggable(),
|
||||||
|
});
|
||||||
|
|
||||||
let temp_pass = rand_str(TEMPORARY_PASSWORDS_LEN);
|
let temp_pass = rand_str(TEMPORARY_PASSWORDS_LEN);
|
||||||
users
|
users
|
||||||
@@ -269,11 +276,15 @@ pub async fn users_route(
|
|||||||
} else {
|
} else {
|
||||||
success = Some(match is_creating {
|
success = Some(match is_creating {
|
||||||
true => {
|
true => {
|
||||||
logger.log(Action::AdminCreateUser(&edited_user));
|
logger.log(Action::AdminCreateUser {
|
||||||
|
user: edited_user.loggable(),
|
||||||
|
});
|
||||||
format!("User {} was successfully created!", edited_user.full_name())
|
format!("User {} was successfully created!", edited_user.full_name())
|
||||||
}
|
}
|
||||||
false => {
|
false => {
|
||||||
logger.log(Action::AdminUpdateUser(&edited_user));
|
logger.log(Action::AdminUpdateUser {
|
||||||
|
user: edited_user.loggable(),
|
||||||
|
});
|
||||||
format!("User {} was successfully updated!", edited_user.full_name())
|
format!("User {} was successfully updated!", edited_user.full_name())
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|||||||
@@ -13,6 +13,7 @@ use crate::controllers::base_controller::{
|
|||||||
build_fatal_error_page, redirect_user, redirect_user_for_login,
|
build_fatal_error_page, redirect_user, redirect_user_for_login,
|
||||||
};
|
};
|
||||||
use crate::data::action_logger::{Action, ActionLogger};
|
use crate::data::action_logger::{Action, ActionLogger};
|
||||||
|
use crate::data::app_config::AppConfig;
|
||||||
use crate::data::force_2fa_auth::Force2FAAuth;
|
use crate::data::force_2fa_auth::Force2FAAuth;
|
||||||
use crate::data::login_redirect::{LoginRedirect, get_2fa_url};
|
use crate::data::login_redirect::{LoginRedirect, get_2fa_url};
|
||||||
use crate::data::provider::{Provider, ProvidersManager};
|
use crate::data::provider::{Provider, ProvidersManager};
|
||||||
@@ -21,46 +22,61 @@ use crate::data::user::User;
|
|||||||
use crate::data::webauthn_manager::WebAuthManagerReq;
|
use crate::data::webauthn_manager::WebAuthManagerReq;
|
||||||
use crate::utils::string_utils;
|
use crate::utils::string_utils;
|
||||||
|
|
||||||
pub struct BaseLoginPage<'a> {
|
pub struct BaseLoginPage {
|
||||||
pub danger: Option<String>,
|
pub danger: Option<String>,
|
||||||
pub success: Option<String>,
|
pub success: Option<String>,
|
||||||
|
pub background_image: &'static str,
|
||||||
pub page_title: &'static str,
|
pub page_title: &'static str,
|
||||||
pub app_name: &'static str,
|
pub app_name: &'static str,
|
||||||
pub redirect_uri: &'a LoginRedirect,
|
pub redirect_uri: LoginRedirect,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl Default for BaseLoginPage {
|
||||||
|
fn default() -> Self {
|
||||||
|
Self {
|
||||||
|
page_title: "Login",
|
||||||
|
danger: None,
|
||||||
|
success: None,
|
||||||
|
background_image: &AppConfig::get().login_background_image,
|
||||||
|
app_name: APP_NAME,
|
||||||
|
redirect_uri: LoginRedirect::default(),
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Template)]
|
#[derive(Template)]
|
||||||
#[template(path = "login/login.html")]
|
#[template(path = "login/login.html")]
|
||||||
struct LoginTemplate<'a> {
|
struct LoginTemplate {
|
||||||
p: BaseLoginPage<'a>,
|
p: BaseLoginPage,
|
||||||
login: String,
|
login: String,
|
||||||
|
show_local_login: bool,
|
||||||
providers: Vec<Provider>,
|
providers: Vec<Provider>,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Template)]
|
#[derive(Template)]
|
||||||
#[template(path = "login/password_reset.html")]
|
#[template(path = "login/password_reset.html")]
|
||||||
struct PasswordResetTemplate<'a> {
|
struct PasswordResetTemplate {
|
||||||
p: BaseLoginPage<'a>,
|
p: BaseLoginPage,
|
||||||
min_pass_len: usize,
|
min_pass_len: usize,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Template)]
|
#[derive(Template)]
|
||||||
#[template(path = "login/choose_second_factor.html")]
|
#[template(path = "login/choose_second_factor.html")]
|
||||||
struct ChooseSecondFactorTemplate<'a> {
|
struct ChooseSecondFactorTemplate<'a> {
|
||||||
p: BaseLoginPage<'a>,
|
p: BaseLoginPage,
|
||||||
user: &'a User,
|
user: &'a User,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Template)]
|
#[derive(Template)]
|
||||||
#[template(path = "login/otp_input.html")]
|
#[template(path = "login/otp_input.html")]
|
||||||
struct LoginWithOTPTemplate<'a> {
|
struct LoginWithOTPTemplate {
|
||||||
p: BaseLoginPage<'a>,
|
p: BaseLoginPage,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Template)]
|
#[derive(Template)]
|
||||||
#[template(path = "login/webauthn_input.html")]
|
#[template(path = "login/webauthn_input.html")]
|
||||||
struct LoginWithWebauthnTemplate<'a> {
|
struct LoginWithWebauthnTemplate {
|
||||||
p: BaseLoginPage<'a>,
|
p: BaseLoginPage,
|
||||||
opaque_state: String,
|
opaque_state: String,
|
||||||
challenge_json: String,
|
challenge_json: String,
|
||||||
}
|
}
|
||||||
@@ -111,7 +127,7 @@ pub async fn login_route(
|
|||||||
// Check if user session must be closed
|
// Check if user session must be closed
|
||||||
if let Some(true) = query.logout {
|
if let Some(true) = query.logout {
|
||||||
if let Some(id) = id {
|
if let Some(id) = id {
|
||||||
logger.log(Action::Signout);
|
logger.log(Action::SignOut);
|
||||||
id.logout();
|
id.logout();
|
||||||
}
|
}
|
||||||
success = Some("Goodbye!".to_string());
|
success = Some("Goodbye!".to_string());
|
||||||
@@ -141,8 +157,10 @@ pub async fn login_route(
|
|||||||
"Given login could not be processed, because it has an invalid format!".to_string(),
|
"Given login could not be processed, because it has an invalid format!".to_string(),
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
// Try to authenticate user
|
// Try to authenticate user (local login)
|
||||||
else if let Some(req) = &req {
|
else if let Some(req) = &req
|
||||||
|
&& !AppConfig::get().disable_local_login
|
||||||
|
{
|
||||||
login.clone_from(&req.login);
|
login.clone_from(&req.login);
|
||||||
let response: LoginResult = users
|
let response: LoginResult = users
|
||||||
.send(users_actor::LocalLoginRequest {
|
.send(users_actor::LocalLoginRequest {
|
||||||
@@ -155,14 +173,20 @@ pub async fn login_route(
|
|||||||
match response {
|
match response {
|
||||||
LoginResult::Success(user) => {
|
LoginResult::Success(user) => {
|
||||||
let status = if user.need_reset_password {
|
let status = if user.need_reset_password {
|
||||||
logger.log(Action::UserNeedNewPasswordOnLogin(&user));
|
logger.log(Action::UserNeedNewPasswordOnLogin {
|
||||||
|
user: user.loggable(),
|
||||||
|
});
|
||||||
SessionStatus::NeedNewPassword
|
SessionStatus::NeedNewPassword
|
||||||
} else if user.has_two_factor() && !user.can_bypass_two_factors_for_ip(remote_ip.0)
|
} else if user.has_two_factor() && !user.can_bypass_two_factors_for_ip(remote_ip.0)
|
||||||
{
|
{
|
||||||
logger.log(Action::UserNeed2FAOnLogin(&user));
|
logger.log(Action::UserNeed2FAOnLogin {
|
||||||
|
user: user.loggable(),
|
||||||
|
});
|
||||||
SessionStatus::Need2FA
|
SessionStatus::Need2FA
|
||||||
} else {
|
} else {
|
||||||
logger.log(Action::UserSuccessfullyAuthenticated(&user));
|
logger.log(Action::UserSuccessfullyAuthenticated {
|
||||||
|
user: user.loggable(),
|
||||||
|
});
|
||||||
SessionStatus::SignedIn
|
SessionStatus::SignedIn
|
||||||
};
|
};
|
||||||
|
|
||||||
@@ -172,7 +196,7 @@ pub async fn login_route(
|
|||||||
|
|
||||||
LoginResult::AccountDisabled => {
|
LoginResult::AccountDisabled => {
|
||||||
log::warn!("Failed login for username {} : account is disabled", &login);
|
log::warn!("Failed login for username {} : account is disabled", &login);
|
||||||
logger.log(Action::TryLoginWithDisabledAccount(&login));
|
logger.log(Action::TryLoginWithDisabledAccount { login: &login });
|
||||||
danger = Some("Your account is disabled!".to_string());
|
danger = Some("Your account is disabled!".to_string());
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -181,7 +205,7 @@ pub async fn login_route(
|
|||||||
"Failed login for username {} : attempted to use local auth, but it is forbidden",
|
"Failed login for username {} : attempted to use local auth, but it is forbidden",
|
||||||
&login
|
&login
|
||||||
);
|
);
|
||||||
logger.log(Action::TryLocalLoginFromUnauthorizedAccount(&login));
|
logger.log(Action::TryLocalLoginFromUnauthorizedAccount { login: &login });
|
||||||
danger = Some("You cannot login from local auth with your account!".to_string());
|
danger = Some("You cannot login from local auth with your account!".to_string());
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -191,7 +215,7 @@ pub async fn login_route(
|
|||||||
|
|
||||||
c => {
|
c => {
|
||||||
log::warn!("Failed login for ip {remote_ip:?} / username {login}: {c:?}");
|
log::warn!("Failed login for ip {remote_ip:?} / username {login}: {c:?}");
|
||||||
logger.log(Action::FailedLoginWithBadCredentials(&login));
|
logger.log(Action::FailedLoginWithBadCredentials { login: &login });
|
||||||
danger = Some("Login failed.".to_string());
|
danger = Some("Login failed.".to_string());
|
||||||
|
|
||||||
bruteforce
|
bruteforce
|
||||||
@@ -203,6 +227,10 @@ pub async fn login_route(
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
// If there is only a single provider, trigger auto-login
|
||||||
|
else if AppConfig::get().disable_local_login && providers.len() == 1 {
|
||||||
|
return redirect_user(&providers.cloned()[0].login_url(&query.redirect));
|
||||||
|
}
|
||||||
|
|
||||||
HttpResponse::Ok().content_type("text/html").body(
|
HttpResponse::Ok().content_type("text/html").body(
|
||||||
LoginTemplate {
|
LoginTemplate {
|
||||||
@@ -210,10 +238,11 @@ pub async fn login_route(
|
|||||||
page_title: "Login",
|
page_title: "Login",
|
||||||
danger,
|
danger,
|
||||||
success,
|
success,
|
||||||
app_name: APP_NAME,
|
redirect_uri: query.0.redirect,
|
||||||
redirect_uri: &query.redirect,
|
..Default::default()
|
||||||
},
|
},
|
||||||
login,
|
login,
|
||||||
|
show_local_login: !AppConfig::get().disable_local_login,
|
||||||
providers: providers.cloned(),
|
providers: providers.cloned(),
|
||||||
}
|
}
|
||||||
.render()
|
.render()
|
||||||
@@ -272,7 +301,7 @@ pub async fn reset_password_route(
|
|||||||
danger = Some("Failed to change password!".to_string());
|
danger = Some("Failed to change password!".to_string());
|
||||||
} else {
|
} else {
|
||||||
SessionIdentity(id.as_ref()).set_status(&http_req, SessionStatus::SignedIn);
|
SessionIdentity(id.as_ref()).set_status(&http_req, SessionStatus::SignedIn);
|
||||||
logger.log(Action::UserChangedPasswordOnLogin(&user_id));
|
logger.log(Action::UserChangedPasswordOnLogin { user_id: &user_id });
|
||||||
return redirect_user(query.redirect.get());
|
return redirect_user(query.redirect.get());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -283,9 +312,8 @@ pub async fn reset_password_route(
|
|||||||
p: BaseLoginPage {
|
p: BaseLoginPage {
|
||||||
page_title: "Password reset",
|
page_title: "Password reset",
|
||||||
danger,
|
danger,
|
||||||
success: None,
|
redirect_uri: query.0.redirect,
|
||||||
app_name: APP_NAME,
|
..Default::default()
|
||||||
redirect_uri: &query.redirect,
|
|
||||||
},
|
},
|
||||||
min_pass_len: MIN_PASS_LEN,
|
min_pass_len: MIN_PASS_LEN,
|
||||||
}
|
}
|
||||||
@@ -333,10 +361,8 @@ pub async fn choose_2fa_method(
|
|||||||
ChooseSecondFactorTemplate {
|
ChooseSecondFactorTemplate {
|
||||||
p: BaseLoginPage {
|
p: BaseLoginPage {
|
||||||
page_title: "Two factor authentication",
|
page_title: "Two factor authentication",
|
||||||
danger: None,
|
redirect_uri: query.0.redirect,
|
||||||
success: None,
|
..Default::default()
|
||||||
app_name: APP_NAME,
|
|
||||||
redirect_uri: &query.redirect,
|
|
||||||
},
|
},
|
||||||
user: &user,
|
user: &user,
|
||||||
}
|
}
|
||||||
@@ -395,7 +421,7 @@ pub async fn login_with_otp(
|
|||||||
{
|
{
|
||||||
logger.log(Action::OTPLoginAttempt {
|
logger.log(Action::OTPLoginAttempt {
|
||||||
success: false,
|
success: false,
|
||||||
user: &user,
|
user: user.loggable(),
|
||||||
});
|
});
|
||||||
danger = Some("Specified code is invalid!".to_string());
|
danger = Some("Specified code is invalid!".to_string());
|
||||||
} else {
|
} else {
|
||||||
@@ -412,7 +438,7 @@ pub async fn login_with_otp(
|
|||||||
session.set_status(&http_req, SessionStatus::SignedIn);
|
session.set_status(&http_req, SessionStatus::SignedIn);
|
||||||
logger.log(Action::OTPLoginAttempt {
|
logger.log(Action::OTPLoginAttempt {
|
||||||
success: true,
|
success: true,
|
||||||
user: &user,
|
user: user.loggable(),
|
||||||
});
|
});
|
||||||
return redirect_user(query.redirect.get());
|
return redirect_user(query.redirect.get());
|
||||||
}
|
}
|
||||||
@@ -424,8 +450,8 @@ pub async fn login_with_otp(
|
|||||||
danger,
|
danger,
|
||||||
success: None,
|
success: None,
|
||||||
page_title: "Two-Factor Auth",
|
page_title: "Two-Factor Auth",
|
||||||
app_name: APP_NAME,
|
redirect_uri: query.0.redirect,
|
||||||
redirect_uri: &query.redirect,
|
..Default::default()
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
.render()
|
.render()
|
||||||
@@ -487,11 +513,9 @@ pub async fn login_with_webauthn(
|
|||||||
HttpResponse::Ok().body(
|
HttpResponse::Ok().body(
|
||||||
LoginWithWebauthnTemplate {
|
LoginWithWebauthnTemplate {
|
||||||
p: BaseLoginPage {
|
p: BaseLoginPage {
|
||||||
danger: None,
|
|
||||||
success: None,
|
|
||||||
page_title: "Two-Factor Auth",
|
page_title: "Two-Factor Auth",
|
||||||
app_name: APP_NAME,
|
redirect_uri: query.0.redirect,
|
||||||
redirect_uri: &query.redirect,
|
..Default::default()
|
||||||
},
|
},
|
||||||
opaque_state: challenge.opaque_state,
|
opaque_state: challenge.opaque_state,
|
||||||
challenge_json: urlencoding::encode(&challenge_json).to_string(),
|
challenge_json: urlencoding::encode(&challenge_json).to_string(),
|
||||||
|
|||||||
@@ -239,7 +239,7 @@ pub async fn authorize(
|
|||||||
.unwrap();
|
.unwrap();
|
||||||
|
|
||||||
log::trace!("New OpenID session: {session:#?}");
|
log::trace!("New OpenID session: {session:#?}");
|
||||||
logger.log(Action::NewOpenIDSession { client: &client });
|
logger.log(Action::NewOpenIDSession { client: &client.id });
|
||||||
|
|
||||||
Ok(HttpResponse::Found()
|
Ok(HttpResponse::Found()
|
||||||
.append_header((
|
.append_header((
|
||||||
@@ -273,7 +273,7 @@ pub async fn authorize(
|
|||||||
};
|
};
|
||||||
|
|
||||||
log::trace!("New OpenID id token: {:#?}", &id_token);
|
log::trace!("New OpenID id token: {:#?}", &id_token);
|
||||||
logger.log(Action::NewOpenIDSuccessfulImplicitAuth { client: &client });
|
logger.log(Action::NewOpenIDSuccessfulImplicitAuth { client: &client.id });
|
||||||
|
|
||||||
Ok(HttpResponse::Found()
|
Ok(HttpResponse::Found()
|
||||||
.append_header((
|
.append_header((
|
||||||
|
|||||||
@@ -1,16 +1,10 @@
|
|||||||
use std::sync::Arc;
|
use std::sync::Arc;
|
||||||
|
|
||||||
use actix::Addr;
|
|
||||||
use actix_identity::Identity;
|
|
||||||
use actix_remote_ip::RemoteIP;
|
|
||||||
use actix_web::{HttpRequest, HttpResponse, Responder, web};
|
|
||||||
use askama::Template;
|
|
||||||
|
|
||||||
use crate::actors::bruteforce_actor::BruteForceActor;
|
use crate::actors::bruteforce_actor::BruteForceActor;
|
||||||
use crate::actors::providers_states_actor::{ProviderLoginState, ProvidersStatesActor};
|
use crate::actors::providers_states_actor::{ProviderLoginState, ProvidersStatesActor};
|
||||||
use crate::actors::users_actor::{LoginResult, UsersActor};
|
use crate::actors::users_actor::{LoginResult, UsersActor};
|
||||||
use crate::actors::{bruteforce_actor, providers_states_actor, users_actor};
|
use crate::actors::{bruteforce_actor, providers_states_actor, users_actor};
|
||||||
use crate::constants::{APP_NAME, MAX_FAILED_LOGIN_ATTEMPTS};
|
use crate::constants::MAX_FAILED_LOGIN_ATTEMPTS;
|
||||||
use crate::controllers::base_controller::{build_fatal_error_page, redirect_user};
|
use crate::controllers::base_controller::{build_fatal_error_page, redirect_user};
|
||||||
use crate::controllers::login_controller::BaseLoginPage;
|
use crate::controllers::login_controller::BaseLoginPage;
|
||||||
use crate::data::action_logger::{Action, ActionLogger};
|
use crate::data::action_logger::{Action, ActionLogger};
|
||||||
@@ -18,11 +12,16 @@ use crate::data::login_redirect::LoginRedirect;
|
|||||||
use crate::data::provider::{ProviderID, ProvidersManager};
|
use crate::data::provider::{ProviderID, ProvidersManager};
|
||||||
use crate::data::provider_configuration::ProviderConfigurationHelper;
|
use crate::data::provider_configuration::ProviderConfigurationHelper;
|
||||||
use crate::data::session_identity::{SessionIdentity, SessionStatus};
|
use crate::data::session_identity::{SessionIdentity, SessionStatus};
|
||||||
|
use actix::Addr;
|
||||||
|
use actix_identity::Identity;
|
||||||
|
use actix_remote_ip::RemoteIP;
|
||||||
|
use actix_web::{HttpRequest, HttpResponse, Responder, web};
|
||||||
|
use askama::Template;
|
||||||
|
|
||||||
#[derive(askama::Template)]
|
#[derive(askama::Template)]
|
||||||
#[template(path = "login/prov_login_error.html")]
|
#[template(path = "login/prov_login_error.html")]
|
||||||
struct ProviderLoginError<'a> {
|
struct ProviderLoginError<'a> {
|
||||||
p: BaseLoginPage<'a>,
|
p: BaseLoginPage,
|
||||||
message: &'a str,
|
message: &'a str,
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -30,11 +29,9 @@ impl<'a> ProviderLoginError<'a> {
|
|||||||
pub fn get(message: &'a str, redirect_uri: &'a LoginRedirect) -> HttpResponse {
|
pub fn get(message: &'a str, redirect_uri: &'a LoginRedirect) -> HttpResponse {
|
||||||
let body = Self {
|
let body = Self {
|
||||||
p: BaseLoginPage {
|
p: BaseLoginPage {
|
||||||
danger: None,
|
|
||||||
success: None,
|
|
||||||
page_title: "Upstream login",
|
page_title: "Upstream login",
|
||||||
app_name: APP_NAME,
|
redirect_uri: redirect_uri.clone(),
|
||||||
redirect_uri,
|
..Default::default()
|
||||||
},
|
},
|
||||||
message,
|
message,
|
||||||
}
|
}
|
||||||
@@ -275,7 +272,7 @@ pub async fn finish_login(
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Check if email was provided by the userinfo endpoint
|
// Check if email was provided by the userinfo endpoint
|
||||||
let email = match user_info.email {
|
let email = match &user_info.email {
|
||||||
Some(e) => e,
|
Some(e) => e,
|
||||||
None => {
|
None => {
|
||||||
logger.log(Action::ProviderMissingEmailInResponse {
|
logger.log(Action::ProviderMissingEmailInResponse {
|
||||||
@@ -295,6 +292,7 @@ pub async fn finish_login(
|
|||||||
let result: LoginResult = users
|
let result: LoginResult = users
|
||||||
.send(users_actor::ProviderLoginRequest {
|
.send(users_actor::ProviderLoginRequest {
|
||||||
email: email.clone(),
|
email: email.clone(),
|
||||||
|
user_info: user_info.clone(),
|
||||||
provider: provider.clone(),
|
provider: provider.clone(),
|
||||||
})
|
})
|
||||||
.await
|
.await
|
||||||
@@ -302,6 +300,13 @@ pub async fn finish_login(
|
|||||||
|
|
||||||
let user = match result {
|
let user = match result {
|
||||||
LoginResult::Success(u) => u,
|
LoginResult::Success(u) => u,
|
||||||
|
LoginResult::AccountAutoCreated(u) => {
|
||||||
|
logger.log(Action::ProviderAccountAutoCreated {
|
||||||
|
provider: &provider,
|
||||||
|
user: u.loggable(),
|
||||||
|
});
|
||||||
|
u
|
||||||
|
}
|
||||||
LoginResult::AccountNotFound => {
|
LoginResult::AccountNotFound => {
|
||||||
logger.log(Action::ProviderAccountNotFound {
|
logger.log(Action::ProviderAccountNotFound {
|
||||||
provider: &provider,
|
provider: &provider,
|
||||||
@@ -357,14 +362,18 @@ pub async fn finish_login(
|
|||||||
|
|
||||||
logger.log(Action::ProviderLoginSuccessful {
|
logger.log(Action::ProviderLoginSuccessful {
|
||||||
provider: &provider,
|
provider: &provider,
|
||||||
user: &user,
|
user: user.loggable(),
|
||||||
});
|
});
|
||||||
|
|
||||||
let status = if user.has_two_factor() && !user.can_bypass_two_factors_for_ip(remote_ip.0) {
|
let status = if user.has_two_factor() && !user.can_bypass_two_factors_for_ip(remote_ip.0) {
|
||||||
logger.log(Action::UserNeed2FAOnLogin(&user));
|
logger.log(Action::UserNeed2FAOnLogin {
|
||||||
|
user: user.loggable(),
|
||||||
|
});
|
||||||
SessionStatus::Need2FA
|
SessionStatus::Need2FA
|
||||||
} else {
|
} else {
|
||||||
logger.log(Action::UserSuccessfullyAuthenticated(&user));
|
logger.log(Action::UserSuccessfullyAuthenticated {
|
||||||
|
user: user.loggable(),
|
||||||
|
});
|
||||||
SessionStatus::SignedIn
|
SessionStatus::SignedIn
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|||||||
@@ -18,6 +18,7 @@ pub(crate) struct BaseSettingsPage<'a> {
|
|||||||
pub success_message: Option<String>,
|
pub success_message: Option<String>,
|
||||||
pub page_title: &'static str,
|
pub page_title: &'static str,
|
||||||
pub app_name: &'static str,
|
pub app_name: &'static str,
|
||||||
|
pub local_login_enabled: bool,
|
||||||
pub user: &'a User,
|
pub user: &'a User,
|
||||||
pub version: &'static str,
|
pub version: &'static str,
|
||||||
pub ip_location_api: Option<&'static str>,
|
pub ip_location_api: Option<&'static str>,
|
||||||
@@ -37,6 +38,7 @@ impl<'a> BaseSettingsPage<'a> {
|
|||||||
app_name: APP_NAME,
|
app_name: APP_NAME,
|
||||||
user,
|
user,
|
||||||
version: env!("CARGO_PKG_VERSION"),
|
version: env!("CARGO_PKG_VERSION"),
|
||||||
|
local_login_enabled: !AppConfig::get().disable_local_login,
|
||||||
ip_location_api: AppConfig::get().ip_location_service.as_deref(),
|
ip_location_api: AppConfig::get().ip_location_service.as_deref(),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,6 +1,5 @@
|
|||||||
use actix::Addr;
|
use actix::Addr;
|
||||||
use actix_web::{HttpResponse, Responder, web};
|
use actix_web::{HttpResponse, Responder, web};
|
||||||
use uuid::Uuid;
|
|
||||||
use webauthn_rs::prelude::RegisterPublicKeyCredential;
|
use webauthn_rs::prelude::RegisterPublicKeyCredential;
|
||||||
|
|
||||||
use crate::actors::users_actor;
|
use crate::actors::users_actor;
|
||||||
@@ -53,11 +52,13 @@ pub async fn save_totp_factor(
|
|||||||
}
|
}
|
||||||
|
|
||||||
let factor = TwoFactor {
|
let factor = TwoFactor {
|
||||||
id: FactorID(Uuid::new_v4().to_string()),
|
id: FactorID::random(),
|
||||||
name: factor_name,
|
name: factor_name,
|
||||||
kind: TwoFactorType::TOTP(key),
|
kind: TwoFactorType::TOTP(key),
|
||||||
};
|
};
|
||||||
logger.log(Action::AddNewFactor(&factor));
|
logger.log(Action::AddNewFactor {
|
||||||
|
factor: factor.loggable(),
|
||||||
|
});
|
||||||
|
|
||||||
let res = users
|
let res = users
|
||||||
.send(users_actor::Add2FAFactor(user.uid.clone(), factor))
|
.send(users_actor::Add2FAFactor(user.uid.clone(), factor))
|
||||||
@@ -100,11 +101,13 @@ pub async fn save_webauthn_factor(
|
|||||||
};
|
};
|
||||||
|
|
||||||
let factor = TwoFactor {
|
let factor = TwoFactor {
|
||||||
id: FactorID(Uuid::new_v4().to_string()),
|
id: FactorID::random(),
|
||||||
name: factor_name,
|
name: factor_name,
|
||||||
kind: TwoFactorType::WEBAUTHN(Box::new(key)),
|
kind: TwoFactorType::WEBAUTHN(Box::new(key)),
|
||||||
};
|
};
|
||||||
logger.log(Action::AddNewFactor(&factor));
|
logger.log(Action::AddNewFactor {
|
||||||
|
factor: factor.loggable(),
|
||||||
|
});
|
||||||
|
|
||||||
let res = users
|
let res = users
|
||||||
.send(users_actor::Add2FAFactor(user.uid.clone(), factor))
|
.send(users_actor::Add2FAFactor(user.uid.clone(), factor))
|
||||||
|
|||||||
@@ -11,21 +11,113 @@ use actix_web::{Error, FromRequest, HttpRequest, web};
|
|||||||
use crate::actors::providers_states_actor::ProviderLoginState;
|
use crate::actors::providers_states_actor::ProviderLoginState;
|
||||||
use crate::actors::users_actor;
|
use crate::actors::users_actor;
|
||||||
use crate::actors::users_actor::{AuthorizedAuthenticationSources, UsersActor};
|
use crate::actors::users_actor::{AuthorizedAuthenticationSources, UsersActor};
|
||||||
use crate::data::client::Client;
|
use crate::data::app_config::{ActionLoggerFormat, AppConfig};
|
||||||
|
use crate::data::client::ClientID;
|
||||||
use crate::data::provider::{Provider, ProviderID};
|
use crate::data::provider::{Provider, ProviderID};
|
||||||
|
|
||||||
use crate::data::session_identity::SessionIdentity;
|
use crate::data::session_identity::SessionIdentity;
|
||||||
use crate::data::user::{FactorID, GrantedClients, TwoFactor, User, UserID};
|
use crate::data::user::{FactorID, GrantedClients, TwoFactor, TwoFactorType, User, UserID};
|
||||||
|
use crate::utils::time::time;
|
||||||
|
|
||||||
|
#[derive(serde::Serialize)]
|
||||||
|
pub struct LoggableUser {
|
||||||
|
pub uid: UserID,
|
||||||
|
pub username: String,
|
||||||
|
pub email: String,
|
||||||
|
pub admin: bool,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl LoggableUser {
|
||||||
|
pub fn quick_identity(&self) -> String {
|
||||||
|
format!(
|
||||||
|
"{} {} {} ({:?})",
|
||||||
|
match self.admin {
|
||||||
|
true => "admin",
|
||||||
|
false => "user",
|
||||||
|
},
|
||||||
|
self.username,
|
||||||
|
self.email,
|
||||||
|
self.uid
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl User {
|
||||||
|
pub fn loggable(&self) -> LoggableUser {
|
||||||
|
LoggableUser {
|
||||||
|
uid: self.uid.clone(),
|
||||||
|
username: self.username.clone(),
|
||||||
|
email: self.email.clone(),
|
||||||
|
admin: self.admin,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Debug, serde::Serialize)]
|
||||||
|
pub enum LoggableFactorType {
|
||||||
|
TOTP,
|
||||||
|
WEBAUTHN,
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(serde::Serialize)]
|
||||||
|
pub struct LoggableFactor {
|
||||||
|
pub id: FactorID,
|
||||||
|
pub name: String,
|
||||||
|
pub kind: LoggableFactorType,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl LoggableFactor {
|
||||||
|
pub fn quick_description(&self) -> String {
|
||||||
|
format!(
|
||||||
|
"#{} of type {:?} and name '{}'",
|
||||||
|
self.id.0, self.kind, self.name
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl TwoFactor {
|
||||||
|
pub fn loggable(&self) -> LoggableFactor {
|
||||||
|
LoggableFactor {
|
||||||
|
id: self.id.clone(),
|
||||||
|
name: self.name.to_string(),
|
||||||
|
kind: match self.kind {
|
||||||
|
TwoFactorType::TOTP(_) => LoggableFactorType::TOTP,
|
||||||
|
TwoFactorType::WEBAUTHN(_) => LoggableFactorType::WEBAUTHN,
|
||||||
|
},
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(serde::Serialize)]
|
||||||
|
#[serde(tag = "type")]
|
||||||
pub enum Action<'a> {
|
pub enum Action<'a> {
|
||||||
AdminCreateUser(&'a User),
|
AdminCreateUser {
|
||||||
AdminUpdateUser(&'a User),
|
user: LoggableUser,
|
||||||
AdminDeleteUser(&'a User),
|
},
|
||||||
AdminResetUserPassword(&'a User),
|
AdminUpdateUser {
|
||||||
AdminRemoveUserFactor(&'a User, &'a TwoFactor),
|
user: LoggableUser,
|
||||||
AdminSetAuthorizedAuthenticationSources(&'a User, &'a AuthorizedAuthenticationSources),
|
},
|
||||||
AdminSetNewGrantedClientsList(&'a User, &'a GrantedClients),
|
AdminDeleteUser {
|
||||||
AdminClear2FAHistory(&'a User),
|
user: LoggableUser,
|
||||||
|
},
|
||||||
|
AdminResetUserPassword {
|
||||||
|
user: LoggableUser,
|
||||||
|
},
|
||||||
|
AdminRemoveUserFactor {
|
||||||
|
user: LoggableUser,
|
||||||
|
factor: LoggableFactor,
|
||||||
|
},
|
||||||
|
AdminSetAuthorizedAuthenticationSources {
|
||||||
|
user: LoggableUser,
|
||||||
|
sources: &'a AuthorizedAuthenticationSources,
|
||||||
|
},
|
||||||
|
AdminSetNewGrantedClientsList {
|
||||||
|
user: LoggableUser,
|
||||||
|
clients: &'a GrantedClients,
|
||||||
|
},
|
||||||
|
AdminClear2FAHistory {
|
||||||
|
user: LoggableUser,
|
||||||
|
},
|
||||||
LoginWebauthnAttempt {
|
LoginWebauthnAttempt {
|
||||||
success: bool,
|
success: bool,
|
||||||
user_id: UserID,
|
user_id: UserID,
|
||||||
@@ -58,6 +150,10 @@ pub enum Action<'a> {
|
|||||||
provider: &'a Provider,
|
provider: &'a Provider,
|
||||||
email: &'a str,
|
email: &'a str,
|
||||||
},
|
},
|
||||||
|
ProviderAccountAutoCreated {
|
||||||
|
provider: &'a Provider,
|
||||||
|
user: LoggableUser,
|
||||||
|
},
|
||||||
ProviderAccountDisabled {
|
ProviderAccountDisabled {
|
||||||
provider: &'a Provider,
|
provider: &'a Provider,
|
||||||
email: &'a str,
|
email: &'a str,
|
||||||
@@ -73,29 +169,45 @@ pub enum Action<'a> {
|
|||||||
},
|
},
|
||||||
ProviderLoginSuccessful {
|
ProviderLoginSuccessful {
|
||||||
provider: &'a Provider,
|
provider: &'a Provider,
|
||||||
user: &'a User,
|
user: LoggableUser,
|
||||||
|
},
|
||||||
|
SignOut,
|
||||||
|
UserNeed2FAOnLogin {
|
||||||
|
user: LoggableUser,
|
||||||
|
},
|
||||||
|
UserSuccessfullyAuthenticated {
|
||||||
|
user: LoggableUser,
|
||||||
|
},
|
||||||
|
UserNeedNewPasswordOnLogin {
|
||||||
|
user: LoggableUser,
|
||||||
|
},
|
||||||
|
TryLoginWithDisabledAccount {
|
||||||
|
login: &'a str,
|
||||||
|
},
|
||||||
|
TryLocalLoginFromUnauthorizedAccount {
|
||||||
|
login: &'a str,
|
||||||
|
},
|
||||||
|
FailedLoginWithBadCredentials {
|
||||||
|
login: &'a str,
|
||||||
|
},
|
||||||
|
UserChangedPasswordOnLogin {
|
||||||
|
user_id: &'a UserID,
|
||||||
},
|
},
|
||||||
Signout,
|
|
||||||
UserNeed2FAOnLogin(&'a User),
|
|
||||||
UserSuccessfullyAuthenticated(&'a User),
|
|
||||||
UserNeedNewPasswordOnLogin(&'a User),
|
|
||||||
TryLoginWithDisabledAccount(&'a str),
|
|
||||||
TryLocalLoginFromUnauthorizedAccount(&'a str),
|
|
||||||
FailedLoginWithBadCredentials(&'a str),
|
|
||||||
UserChangedPasswordOnLogin(&'a UserID),
|
|
||||||
OTPLoginAttempt {
|
OTPLoginAttempt {
|
||||||
user: &'a User,
|
user: LoggableUser,
|
||||||
success: bool,
|
success: bool,
|
||||||
},
|
},
|
||||||
NewOpenIDSession {
|
NewOpenIDSession {
|
||||||
client: &'a Client,
|
client: &'a ClientID,
|
||||||
},
|
},
|
||||||
NewOpenIDSuccessfulImplicitAuth {
|
NewOpenIDSuccessfulImplicitAuth {
|
||||||
client: &'a Client,
|
client: &'a ClientID,
|
||||||
},
|
},
|
||||||
ChangedHisPassword,
|
ChangedHisPassword,
|
||||||
ClearedHisLoginHistory,
|
ClearedHisLoginHistory,
|
||||||
AddNewFactor(&'a TwoFactor),
|
AddNewFactor {
|
||||||
|
factor: LoggableFactor,
|
||||||
|
},
|
||||||
Removed2FAFactor {
|
Removed2FAFactor {
|
||||||
factor_id: &'a FactorID,
|
factor_id: &'a FactorID,
|
||||||
},
|
},
|
||||||
@@ -104,35 +216,35 @@ pub enum Action<'a> {
|
|||||||
impl Action<'_> {
|
impl Action<'_> {
|
||||||
pub fn as_string(&self) -> String {
|
pub fn as_string(&self) -> String {
|
||||||
match self {
|
match self {
|
||||||
Action::AdminDeleteUser(user) => {
|
Action::AdminDeleteUser { user } => {
|
||||||
format!("deleted account of {}", user.quick_identity())
|
format!("deleted account of {}", user.quick_identity())
|
||||||
}
|
}
|
||||||
Action::AdminCreateUser(user) => {
|
Action::AdminCreateUser { user } => {
|
||||||
format!("created account of {}", user.quick_identity())
|
format!("created account of {}", user.quick_identity())
|
||||||
}
|
}
|
||||||
Action::AdminUpdateUser(user) => {
|
Action::AdminUpdateUser { user } => {
|
||||||
format!("updated account of {}", user.quick_identity())
|
format!("updated account of {}", user.quick_identity())
|
||||||
}
|
}
|
||||||
Action::AdminResetUserPassword(user) => {
|
Action::AdminResetUserPassword { user } => {
|
||||||
format!(
|
format!(
|
||||||
"set a temporary password for the account of {}",
|
"set a temporary password for the account of {}",
|
||||||
user.quick_identity()
|
user.quick_identity()
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
Action::AdminRemoveUserFactor(user, factor) => format!(
|
Action::AdminRemoveUserFactor { user, factor } => format!(
|
||||||
"removed 2 factor ({}) of user ({})",
|
"removed 2 factor ({}) of user ({})",
|
||||||
factor.quick_description(),
|
factor.quick_description(),
|
||||||
user.quick_identity()
|
user.quick_identity()
|
||||||
),
|
),
|
||||||
Action::AdminClear2FAHistory(user) => {
|
Action::AdminClear2FAHistory { user } => {
|
||||||
format!("cleared 2FA history of {}", user.quick_identity())
|
format!("cleared 2FA history of {}", user.quick_identity())
|
||||||
}
|
}
|
||||||
Action::AdminSetAuthorizedAuthenticationSources(user, sources) => format!(
|
Action::AdminSetAuthorizedAuthenticationSources { user, sources } => format!(
|
||||||
"update authorized authentication sources ({:?}) for user ({})",
|
"update authorized authentication sources ({:?}) for user ({})",
|
||||||
sources,
|
sources,
|
||||||
user.quick_identity()
|
user.quick_identity()
|
||||||
),
|
),
|
||||||
Action::AdminSetNewGrantedClientsList(user, clients) => format!(
|
Action::AdminSetNewGrantedClientsList { user, clients } => format!(
|
||||||
"set new granted clients list ({:?}) for user ({})",
|
"set new granted clients list ({:?}) for user ({})",
|
||||||
clients,
|
clients,
|
||||||
user.quick_identity()
|
user.quick_identity()
|
||||||
@@ -174,6 +286,11 @@ impl Action<'_> {
|
|||||||
"could not login using provider {} because the email {email} could not be associated to any account!",
|
"could not login using provider {} because the email {email} could not be associated to any account!",
|
||||||
&provider.id.0
|
&provider.id.0
|
||||||
),
|
),
|
||||||
|
Action::ProviderAccountAutoCreated { provider, user } => format!(
|
||||||
|
"triggered automatic account creation for {} from provider {} because it was not found in local accounts list!",
|
||||||
|
user.quick_identity(),
|
||||||
|
&provider.id.0
|
||||||
|
),
|
||||||
Action::ProviderAccountDisabled { provider, email } => format!(
|
Action::ProviderAccountDisabled { provider, email } => format!(
|
||||||
"could not login using provider {} because the account associated to the email {email} is disabled!",
|
"could not login using provider {} because the account associated to the email {email} is disabled!",
|
||||||
&provider.id.0
|
&provider.id.0
|
||||||
@@ -191,32 +308,32 @@ impl Action<'_> {
|
|||||||
provider.id.0,
|
provider.id.0,
|
||||||
user.quick_identity()
|
user.quick_identity()
|
||||||
),
|
),
|
||||||
Action::Signout => "signed out".to_string(),
|
Action::SignOut => "signed out".to_string(),
|
||||||
Action::UserNeed2FAOnLogin(user) => {
|
Action::UserNeed2FAOnLogin { user } => {
|
||||||
format!(
|
format!(
|
||||||
"successfully authenticated as user {:?} but need to do 2FA authentication",
|
"successfully authenticated as user {:?} but need to do 2FA authentication",
|
||||||
user.quick_identity()
|
user.quick_identity()
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
Action::UserSuccessfullyAuthenticated(user) => {
|
Action::UserSuccessfullyAuthenticated { user } => {
|
||||||
format!("successfully authenticated as {}", user.quick_identity())
|
format!("successfully authenticated as {}", user.quick_identity())
|
||||||
}
|
}
|
||||||
Action::UserNeedNewPasswordOnLogin(user) => format!(
|
Action::UserNeedNewPasswordOnLogin { user } => format!(
|
||||||
"successfully authenticated as {}, but need to set a new password",
|
"successfully authenticated as {}, but need to set a new password",
|
||||||
user.quick_identity()
|
user.quick_identity()
|
||||||
),
|
),
|
||||||
Action::TryLoginWithDisabledAccount(login) => {
|
Action::TryLoginWithDisabledAccount { login } => {
|
||||||
format!("successfully authenticated as {login}, but this is a DISABLED ACCOUNT")
|
format!("successfully authenticated as {login}, but this is a DISABLED ACCOUNT")
|
||||||
}
|
}
|
||||||
Action::TryLocalLoginFromUnauthorizedAccount(login) => {
|
Action::TryLocalLoginFromUnauthorizedAccount { login } => {
|
||||||
format!(
|
format!(
|
||||||
"successfully locally authenticated as {login}, but this is a FORBIDDEN for this account!"
|
"successfully locally authenticated as {login}, but this is a FORBIDDEN for this account!"
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
Action::FailedLoginWithBadCredentials(login) => {
|
Action::FailedLoginWithBadCredentials { login } => {
|
||||||
format!("attempted to authenticate as {login} but with a WRONG PASSWORD")
|
format!("attempted to authenticate as {login} but with a WRONG PASSWORD")
|
||||||
}
|
}
|
||||||
Action::UserChangedPasswordOnLogin(user_id) => {
|
Action::UserChangedPasswordOnLogin { user_id } => {
|
||||||
format!("set a new password at login as user {user_id:?}")
|
format!("set a new password at login as user {user_id:?}")
|
||||||
}
|
}
|
||||||
Action::OTPLoginAttempt { user, success } => match success {
|
Action::OTPLoginAttempt { user, success } => match success {
|
||||||
@@ -230,15 +347,15 @@ impl Action<'_> {
|
|||||||
),
|
),
|
||||||
},
|
},
|
||||||
Action::NewOpenIDSession { client } => {
|
Action::NewOpenIDSession { client } => {
|
||||||
format!("opened a new OpenID session with {:?}", client.id)
|
format!("opened a new OpenID session with {:?}", client)
|
||||||
}
|
}
|
||||||
Action::NewOpenIDSuccessfulImplicitAuth { client } => format!(
|
Action::NewOpenIDSuccessfulImplicitAuth { client } => format!(
|
||||||
"finished an implicit flow connection for client {:?}",
|
"finished an implicit flow connection for client {:?}",
|
||||||
client.id
|
client
|
||||||
),
|
),
|
||||||
Action::ChangedHisPassword => "changed his password".to_string(),
|
Action::ChangedHisPassword => "changed his password".to_string(),
|
||||||
Action::ClearedHisLoginHistory => "cleared his login history".to_string(),
|
Action::ClearedHisLoginHistory => "cleared his login history".to_string(),
|
||||||
Action::AddNewFactor(factor) => format!(
|
Action::AddNewFactor { factor } => format!(
|
||||||
"added a new factor to his account : {}",
|
"added a new factor to his account : {}",
|
||||||
factor.quick_description(),
|
factor.quick_description(),
|
||||||
),
|
),
|
||||||
@@ -247,6 +364,15 @@ impl Action<'_> {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[derive(serde::Serialize)]
|
||||||
|
struct JsonActionData<'a> {
|
||||||
|
time: u64,
|
||||||
|
ip: IpAddr,
|
||||||
|
user: Option<LoggableUser>,
|
||||||
|
#[serde(flatten)]
|
||||||
|
action: Action<'a>,
|
||||||
|
}
|
||||||
|
|
||||||
pub struct ActionLogger {
|
pub struct ActionLogger {
|
||||||
ip: IpAddr,
|
ip: IpAddr,
|
||||||
user: Option<User>,
|
user: Option<User>,
|
||||||
@@ -254,15 +380,27 @@ pub struct ActionLogger {
|
|||||||
|
|
||||||
impl ActionLogger {
|
impl ActionLogger {
|
||||||
pub fn log(&self, action: Action) {
|
pub fn log(&self, action: Action) {
|
||||||
log::info!(
|
match AppConfig::get().action_logger_format {
|
||||||
|
ActionLoggerFormat::Text => log::info!(
|
||||||
"{} from {} has {}",
|
"{} from {} has {}",
|
||||||
match &self.user {
|
match &self.user {
|
||||||
None => "Anonymous user".to_string(),
|
None => "Anonymous user".to_string(),
|
||||||
Some(u) => u.quick_identity(),
|
Some(u) => u.loggable().quick_identity(),
|
||||||
},
|
},
|
||||||
self.ip,
|
self.ip,
|
||||||
action.as_string()
|
action.as_string()
|
||||||
)
|
),
|
||||||
|
ActionLoggerFormat::Json => match serde_json::to_string(&JsonActionData {
|
||||||
|
time: time(),
|
||||||
|
ip: self.ip,
|
||||||
|
user: self.user.as_ref().map(User::loggable),
|
||||||
|
action,
|
||||||
|
}) {
|
||||||
|
Ok(j) => println!("{j}"),
|
||||||
|
Err(e) => log::error!("Failed to serialize event to JSON! {e}"),
|
||||||
|
},
|
||||||
|
ActionLoggerFormat::None => {}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -6,6 +6,15 @@ use crate::constants::{
|
|||||||
APP_NAME, CLIENTS_LIST_FILE, OIDC_PROVIDER_CB_URI, PROVIDERS_LIST_FILE, USERS_LIST_FILE,
|
APP_NAME, CLIENTS_LIST_FILE, OIDC_PROVIDER_CB_URI, PROVIDERS_LIST_FILE, USERS_LIST_FILE,
|
||||||
};
|
};
|
||||||
|
|
||||||
|
/// Action logger format
|
||||||
|
#[derive(Copy, Clone, Eq, PartialEq, Debug, clap::ValueEnum, Default)]
|
||||||
|
pub enum ActionLoggerFormat {
|
||||||
|
#[default]
|
||||||
|
Text,
|
||||||
|
Json,
|
||||||
|
None,
|
||||||
|
}
|
||||||
|
|
||||||
/// Basic OIDC provider
|
/// Basic OIDC provider
|
||||||
#[derive(Parser, Debug, Clone)]
|
#[derive(Parser, Debug, Clone)]
|
||||||
#[clap(author, version, about, long_about = None)]
|
#[clap(author, version, about, long_about = None)]
|
||||||
@@ -45,6 +54,19 @@ pub struct AppConfig {
|
|||||||
/// Example: "https://api.geoip.rs"
|
/// Example: "https://api.geoip.rs"
|
||||||
#[arg(long, short, env)]
|
#[arg(long, short, env)]
|
||||||
pub ip_location_service: Option<String>,
|
pub ip_location_service: Option<String>,
|
||||||
|
|
||||||
|
/// Action logger output format
|
||||||
|
#[arg(long, env, default_value_t, value_enum)]
|
||||||
|
pub action_logger_format: ActionLoggerFormat,
|
||||||
|
|
||||||
|
/// Login background image
|
||||||
|
#[arg(long, env, default_value = "/assets/img/forest.jpg")]
|
||||||
|
pub login_background_image: String,
|
||||||
|
|
||||||
|
/// Disable local login. If this option is set without any upstream providers set, it will be impossible
|
||||||
|
/// to authenticate
|
||||||
|
#[arg(long, env)]
|
||||||
|
pub disable_local_login: bool,
|
||||||
}
|
}
|
||||||
|
|
||||||
lazy_static::lazy_static! {
|
lazy_static::lazy_static! {
|
||||||
|
|||||||
@@ -26,6 +26,10 @@ pub struct Provider {
|
|||||||
///
|
///
|
||||||
/// (.well-known/openid-configuration endpoint)
|
/// (.well-known/openid-configuration endpoint)
|
||||||
pub configuration_url: String,
|
pub configuration_url: String,
|
||||||
|
|
||||||
|
/// Set to true if accounts on BasicOIDC should be automatically created from this provider
|
||||||
|
#[serde(default)]
|
||||||
|
pub allow_auto_account_creation: bool,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl Provider {
|
impl Provider {
|
||||||
@@ -42,6 +46,7 @@ impl Provider {
|
|||||||
"github" => "/assets/img/brands/github.svg",
|
"github" => "/assets/img/brands/github.svg",
|
||||||
"microsoft" => "/assets/img/brands/microsoft.svg",
|
"microsoft" => "/assets/img/brands/microsoft.svg",
|
||||||
"google" => "/assets/img/brands/google.svg",
|
"google" => "/assets/img/brands/google.svg",
|
||||||
|
"openid" => "/assets/img/brands/openid.svg",
|
||||||
s => s,
|
s => s,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -5,20 +5,15 @@ use serde::{Deserialize, Serialize};
|
|||||||
use crate::data::user::{User, UserID};
|
use crate::data::user::{User, UserID};
|
||||||
use crate::utils::time::time;
|
use crate::utils::time::time;
|
||||||
|
|
||||||
#[derive(Debug, Serialize, Deserialize, Eq, PartialEq)]
|
#[derive(Debug, Serialize, Deserialize, Eq, PartialEq, Default)]
|
||||||
pub enum SessionStatus {
|
pub enum SessionStatus {
|
||||||
|
#[default]
|
||||||
Invalid,
|
Invalid,
|
||||||
SignedIn,
|
SignedIn,
|
||||||
NeedNewPassword,
|
NeedNewPassword,
|
||||||
Need2FA,
|
Need2FA,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl Default for SessionStatus {
|
|
||||||
fn default() -> Self {
|
|
||||||
Self::Invalid
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug, Serialize, Deserialize, Default)]
|
#[derive(Debug, Serialize, Deserialize, Default)]
|
||||||
pub struct SessionIdentityData {
|
pub struct SessionIdentityData {
|
||||||
pub id: Option<UserID>,
|
pub id: Option<UserID>,
|
||||||
|
|||||||
@@ -14,6 +14,12 @@ use crate::utils::time::{fmt_time, time};
|
|||||||
#[derive(Clone, Debug, Eq, PartialEq, serde::Serialize, serde::Deserialize, Encode, Decode)]
|
#[derive(Clone, Debug, Eq, PartialEq, serde::Serialize, serde::Deserialize, Encode, Decode)]
|
||||||
pub struct UserID(pub String);
|
pub struct UserID(pub String);
|
||||||
|
|
||||||
|
impl UserID {
|
||||||
|
pub fn random() -> Self {
|
||||||
|
Self(uuid::Uuid::new_v4().to_string())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
#[derive(Debug, Clone)]
|
#[derive(Debug, Clone)]
|
||||||
pub struct GeneralSettings {
|
pub struct GeneralSettings {
|
||||||
pub uid: UserID,
|
pub uid: UserID,
|
||||||
@@ -26,7 +32,7 @@ pub struct GeneralSettings {
|
|||||||
pub is_admin: bool,
|
pub is_admin: bool,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Eq, PartialEq, Clone, Debug)]
|
#[derive(Eq, PartialEq, Clone, Debug, serde::Serialize)]
|
||||||
pub enum GrantedClients {
|
pub enum GrantedClients {
|
||||||
AllClients,
|
AllClients,
|
||||||
SomeClients(Vec<ClientID>),
|
SomeClients(Vec<ClientID>),
|
||||||
@@ -46,6 +52,12 @@ impl GrantedClients {
|
|||||||
#[derive(Clone, Debug, Eq, PartialEq, serde::Serialize, serde::Deserialize)]
|
#[derive(Clone, Debug, Eq, PartialEq, serde::Serialize, serde::Deserialize)]
|
||||||
pub struct FactorID(pub String);
|
pub struct FactorID(pub String);
|
||||||
|
|
||||||
|
impl FactorID {
|
||||||
|
pub fn random() -> Self {
|
||||||
|
Self(uuid::Uuid::new_v4().to_string())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
#[derive(Clone, Debug, serde::Serialize, serde::Deserialize)]
|
#[derive(Clone, Debug, serde::Serialize, serde::Deserialize)]
|
||||||
pub enum TwoFactorType {
|
pub enum TwoFactorType {
|
||||||
TOTP(TotpKey),
|
TOTP(TotpKey),
|
||||||
@@ -60,15 +72,6 @@ pub struct TwoFactor {
|
|||||||
}
|
}
|
||||||
|
|
||||||
impl TwoFactor {
|
impl TwoFactor {
|
||||||
pub fn quick_description(&self) -> String {
|
|
||||||
format!(
|
|
||||||
"#{} of type {} and name '{}'",
|
|
||||||
self.id.0,
|
|
||||||
self.type_str(),
|
|
||||||
self.name
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn type_str(&self) -> &'static str {
|
pub fn type_str(&self) -> &'static str {
|
||||||
match self.kind {
|
match self.kind {
|
||||||
TwoFactorType::TOTP(_) => "Authenticator app",
|
TwoFactorType::TOTP(_) => "Authenticator app",
|
||||||
@@ -170,19 +173,6 @@ impl User {
|
|||||||
format!("{} {}", self.first_name, self.last_name)
|
format!("{} {}", self.first_name, self.last_name)
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn quick_identity(&self) -> String {
|
|
||||||
format!(
|
|
||||||
"{} {} {} ({:?})",
|
|
||||||
match self.admin {
|
|
||||||
true => "admin",
|
|
||||||
false => "user",
|
|
||||||
},
|
|
||||||
self.username,
|
|
||||||
self.email,
|
|
||||||
self.uid
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
/// Get the list of sources from which a user can authenticate from
|
/// Get the list of sources from which a user can authenticate from
|
||||||
pub fn authorized_authentication_sources(&self) -> AuthorizedAuthenticationSources {
|
pub fn authorized_authentication_sources(&self) -> AuthorizedAuthenticationSources {
|
||||||
AuthorizedAuthenticationSources {
|
AuthorizedAuthenticationSources {
|
||||||
@@ -317,7 +307,7 @@ impl Eq for User {}
|
|||||||
impl Default for User {
|
impl Default for User {
|
||||||
fn default() -> Self {
|
fn default() -> Self {
|
||||||
Self {
|
Self {
|
||||||
uid: UserID(uuid::Uuid::new_v4().to_string()),
|
uid: UserID::random(),
|
||||||
first_name: "".to_string(),
|
first_name: "".to_string(),
|
||||||
last_name: "".to_string(),
|
last_name: "".to_string(),
|
||||||
username: "".to_string(),
|
username: "".to_string(),
|
||||||
|
|||||||
@@ -31,28 +31,25 @@ fn hash_password<P: AsRef<[u8]>>(pwd: P) -> Res<String> {
|
|||||||
}
|
}
|
||||||
|
|
||||||
fn verify_password<P: AsRef<[u8]>>(pwd: P, hash: &str) -> bool {
|
fn verify_password<P: AsRef<[u8]>>(pwd: P, hash: &str) -> bool {
|
||||||
match bcrypt::verify(pwd, hash) {
|
bcrypt::verify(pwd, hash).unwrap_or_else(|e| {
|
||||||
Ok(r) => r,
|
|
||||||
Err(e) => {
|
|
||||||
log::warn!("Failed to verify password! {e:?}");
|
log::warn!("Failed to verify password! {e:?}");
|
||||||
false
|
false
|
||||||
}
|
})
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
impl UsersSyncBackend for EntityManager<User> {
|
impl UsersSyncBackend for EntityManager<User> {
|
||||||
fn find_by_email(&self, u: &str) -> Res<Option<User>> {
|
fn find_by_username_or_email(&self, u: &str) -> Res<Option<User>> {
|
||||||
for entry in self.iter() {
|
for entry in self.iter() {
|
||||||
if entry.email.eq(u) {
|
if entry.username.eq(u) || entry.email.eq(u) {
|
||||||
return Ok(Some(entry.clone()));
|
return Ok(Some(entry.clone()));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
Ok(None)
|
Ok(None)
|
||||||
}
|
}
|
||||||
|
|
||||||
fn find_by_username_or_email(&self, u: &str) -> Res<Option<User>> {
|
fn find_by_email(&self, u: &str) -> Res<Option<User>> {
|
||||||
for entry in self.iter() {
|
for entry in self.iter() {
|
||||||
if entry.username.eq(u) || entry.email.eq(u) {
|
if entry.email.eq(u) {
|
||||||
return Ok(Some(entry.clone()));
|
return Ok(Some(entry.clone()));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -74,7 +71,7 @@ impl UsersSyncBackend for EntityManager<User> {
|
|||||||
|
|
||||||
fn create_user_account(&mut self, settings: GeneralSettings) -> Res<UserID> {
|
fn create_user_account(&mut self, settings: GeneralSettings) -> Res<UserID> {
|
||||||
let mut user = User {
|
let mut user = User {
|
||||||
uid: UserID(uuid::Uuid::new_v4().to_string()),
|
uid: UserID::random(),
|
||||||
..Default::default()
|
..Default::default()
|
||||||
};
|
};
|
||||||
user.update_general_settings(settings);
|
user.update_general_settings(settings);
|
||||||
|
|||||||
@@ -30,6 +30,12 @@
|
|||||||
font-size: 3.5rem;
|
font-size: 3.5rem;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@media screen and (min-width: 767px) {
|
||||||
|
.bg-login {
|
||||||
|
background-image: url({{ p.background_image }});
|
||||||
|
}
|
||||||
|
}
|
||||||
</style>
|
</style>
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -18,6 +18,8 @@
|
|||||||
|
|
||||||
</style>
|
</style>
|
||||||
|
|
||||||
|
<!-- Local login -->
|
||||||
|
{% if show_local_login %}
|
||||||
<form action="/login?redirect={{ p.redirect_uri.get_encoded() }}" method="post">
|
<form action="/login?redirect={{ p.redirect_uri.get_encoded() }}" method="post">
|
||||||
<div>
|
<div>
|
||||||
<div class="form-floating">
|
<div class="form-floating">
|
||||||
@@ -36,6 +38,7 @@
|
|||||||
<button class="w-100 btn btn-lg btn-primary" type="submit">Sign in</button>
|
<button class="w-100 btn btn-lg btn-primary" type="submit">Sign in</button>
|
||||||
|
|
||||||
</form>
|
</form>
|
||||||
|
{% endif %}
|
||||||
|
|
||||||
<!-- Upstream providers -->
|
<!-- Upstream providers -->
|
||||||
{% if !providers.is_empty() %}
|
{% if !providers.is_empty() %}
|
||||||
|
|||||||
@@ -24,7 +24,7 @@
|
|||||||
Account details
|
Account details
|
||||||
</a>
|
</a>
|
||||||
</li>
|
</li>
|
||||||
{% if p.user.allow_local_login %}
|
{% if p.user.allow_local_login && p.local_login_enabled %}
|
||||||
<li>
|
<li>
|
||||||
<a href="/settings/change_password" class="nav-link link-dark">
|
<a href="/settings/change_password" class="nav-link link-dark">
|
||||||
Change password
|
Change password
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
{% extends "base_settings_page.html" %}
|
{% extends "base_settings_page.html" %}
|
||||||
{% block content %}
|
{% block content %}
|
||||||
|
|
||||||
<table class="table table-hover" style="max-width: 800px;" aria-describedby="Clients list">
|
<table class="table table-hover table-break-works" style="max-width: 800px;" aria-describedby="Clients list">
|
||||||
<thead>
|
<thead>
|
||||||
<tr>
|
<tr>
|
||||||
<th scope="col">ID</th>
|
<th scope="col">ID</th>
|
||||||
|
|||||||
Reference in New Issue
Block a user