89 Commits

Author SHA1 Message Date
1a92085d70 chore(deps): update rust crate bcrypt to 0.19.0
All checks were successful
continuous-integration/drone/push Build is passing
2026-03-04 00:18:09 +00:00
2268e7cbff Merge pull request 'chore(deps): update rust crate chrono to 0.4.44' (#478) from renovate/chrono-0.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2026-02-27 00:11:31 +00:00
4801ed7cf9 chore(deps): update rust crate chrono to 0.4.44
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2026-02-26 00:12:15 +00:00
Pierre HUBERT
7391a4f488 feat: can add custom claims to access token
All checks were successful
continuous-integration/drone/push Build is passing
2026-02-24 15:17:40 +01:00
cc72ff64d2 Make OpenID sessions expire after one week
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/tag Build is passing
2026-02-23 18:44:34 +01:00
3482c53acf Merge pull request 'Update Rust crate clap to 4.5.60' (#477) from renovate/clap-4.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2026-02-21 00:12:25 +00:00
84c3415ad7 Update Rust crate clap to 4.5.60
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2026-02-20 00:12:08 +00:00
cc2c3d7626 Updated project dependencies
All checks were successful
continuous-integration/drone/push Build is passing
2026-02-19 17:37:03 +01:00
965a7dbe8b Merge pull request 'Update Rust crate clap to 4.5.59' (#476) from renovate/clap-4.x into master
Some checks failed
continuous-integration/drone/push Build is failing
2026-02-18 00:23:48 +00:00
bc6bdcbc7d Update Rust crate clap to 4.5.59
Some checks failed
continuous-integration/drone/push Build is failing
continuous-integration/drone/pr Build is failing
2026-02-17 00:24:47 +00:00
82ea79126a Merge pull request 'Update Rust crate digest to 0.11.0' (#474) from renovate/digest-0.x into master
Some checks failed
continuous-integration/drone/push Build is failing
2026-02-16 00:24:52 +00:00
141ec0ab4a Update Rust crate digest to 0.11.0
Some checks failed
continuous-integration/drone/push Build is failing
continuous-integration/drone/pr Build is failing
2026-02-15 00:24:30 +00:00
883120e076 Merge pull request 'Update Rust crate clap to 4.5.58' (#473) from renovate/clap-4.x into master
Some checks failed
continuous-integration/drone/push Build is failing
2026-02-14 00:23:40 +00:00
a64a1d8697 Update Rust crate clap to 4.5.58
Some checks failed
continuous-integration/drone/push Build is failing
continuous-integration/drone/pr Build is failing
2026-02-13 00:24:42 +00:00
df9ee10191 Merge pull request 'Update Rust crate anyhow to 1.0.101' (#472) from renovate/anyhow-1.x into master
Some checks failed
continuous-integration/drone/push Build is failing
2026-02-08 00:23:36 +00:00
cf482d15c2 Update Rust crate anyhow to 1.0.101
Some checks failed
continuous-integration/drone/push Build is failing
continuous-integration/drone/pr Build is failing
2026-02-07 00:24:05 +00:00
029e229387 Merge pull request 'Update Rust crate clap to 4.5.57' (#471) from renovate/clap-4.x into master
Some checks failed
continuous-integration/drone/push Build is failing
2026-02-06 00:24:12 +00:00
4bd238779b Update Rust crate clap to 4.5.57
Some checks failed
continuous-integration/drone/push Build is failing
continuous-integration/drone/pr Build is failing
2026-02-05 00:24:19 +00:00
4fdf1bdc6b Merge pull request 'Update Rust crate digest to 0.11.0-rc.11' (#469) from renovate/digest-0.x into master
Some checks failed
continuous-integration/drone/push Build is failing
2026-02-04 00:24:17 +00:00
c5ad96692a Update Rust crate digest to 0.11.0-rc.11
Some checks failed
continuous-integration/drone/push Build is failing
continuous-integration/drone/pr Build is failing
2026-02-03 00:24:33 +00:00
ec72f9350e Merge pull request 'Update Rust crate clap to 4.5.56' (#468) from renovate/clap-4.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2026-01-31 00:23:38 +00:00
731f85a33a Update Rust crate clap to 4.5.56
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2026-01-30 00:24:09 +00:00
35967751fe Merge pull request 'Update Rust crate askama to 0.15.4' (#467) from renovate/askama-0.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2026-01-30 00:23:35 +00:00
651f512408 Update Rust crate askama to 0.15.4
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2026-01-29 00:24:35 +00:00
8482e7ab1e Merge pull request 'Update Rust crate clap to 4.5.55' (#466) from renovate/clap-4.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2026-01-29 00:24:31 +00:00
5dfe6d4e85 Update Rust crate clap to 4.5.55
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2026-01-28 00:24:12 +00:00
0f7a63861d Merge pull request 'Update Rust crate uuid to 1.20.0' (#465) from renovate/uuid-1.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2026-01-28 00:24:06 +00:00
7917c90ece Update Rust crate uuid to 1.20.0
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2026-01-27 00:23:58 +00:00
804faa6497 Merge pull request 'Update Rust crate digest to 0.11.0-rc.9' (#464) from renovate/digest-0.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2026-01-27 00:23:29 +00:00
fca0e421b5 Update Rust crate digest to 0.11.0-rc.9
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2026-01-26 00:24:23 +00:00
4636bfe7c1 Merge pull request 'Update Rust crate sha2 to 0.11.0-rc.4' (#463) from renovate/sha2-0.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2026-01-26 00:24:19 +00:00
cbf13e02e2 Update Rust crate sha2 to 0.11.0-rc.4
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2026-01-25 00:24:58 +00:00
8804af3b3d Merge pull request 'Update Rust crate jwt-simple to 0.12.14' (#462) from renovate/jwt-simple-0.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2026-01-23 00:23:53 +00:00
2bcf9a3cce Update Rust crate jwt-simple to 0.12.14
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2026-01-22 00:25:02 +00:00
ea5b1e6371 Merge pull request 'Update Rust crate digest to 0.11.0-rc.7' (#461) from renovate/digest-0.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2026-01-22 00:24:18 +00:00
e811976b21 Update Rust crate digest to 0.11.0-rc.7
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2026-01-21 00:09:54 +00:00
320d65e8ff Merge pull request 'Update Rust crate chrono to 0.4.43' (#460) from renovate/chrono-0.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2026-01-16 00:23:32 +00:00
1e61b20249 Update Rust crate chrono to 0.4.43
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2026-01-15 00:26:45 +00:00
630a5271cd Merge pull request 'Update Rust crate rkyv to 0.8.14' (#459) from renovate/rkyv-0.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2026-01-15 00:26:33 +00:00
588a06ccbb Update Rust crate rkyv to 0.8.14
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2026-01-14 00:24:16 +00:00
ab1fa624b0 Merge pull request 'Update Rust crate bcrypt to 0.18.0' (#458) from renovate/bcrypt-0.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2026-01-13 00:23:17 +00:00
c8f7db0bee Update Rust crate bcrypt to 0.18.0
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2026-01-12 00:24:15 +00:00
294c6a5d3b Merge pull request 'Update Rust crate lazy-regex to 3.5.1' (#457) from renovate/lazy-regex-3.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2026-01-10 00:23:20 +00:00
4b02e84047 Update Rust crate lazy-regex to 3.5.1
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2026-01-09 00:19:54 +00:00
e646798996 Merge pull request 'Update Rust crate url to 2.5.8' (#456) from renovate/url-2.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2026-01-09 00:19:13 +00:00
029bb1140f Update Rust crate url to 2.5.8
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2026-01-08 00:20:10 +00:00
d4924efa67 Merge pull request 'Update Rust crate serde_json to 1.0.149' (#455) from renovate/serde_json-1.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2026-01-08 00:19:14 +00:00
20f7e4e706 Update Rust crate serde_json to 1.0.149
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2026-01-07 00:19:39 +00:00
4fb7b98d8a Merge pull request 'Update Rust crate rkyv to 0.8.13' (#454) from renovate/rkyv-0.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2026-01-07 00:19:09 +00:00
e9e9dc2a41 Update Rust crate rkyv to 0.8.13
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2026-01-06 00:20:00 +00:00
62f91a4f34 Merge pull request 'Update Rust crate clap to 4.5.54' (#453) from renovate/clap-4.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2026-01-06 00:19:17 +00:00
6191eb1682 Update Rust crate clap to 4.5.54
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2026-01-05 00:19:36 +00:00
2a0b20ad00 Update light-openid to version 1.1.0
All checks were successful
continuous-integration/drone/push Build is passing
2025-12-29 16:53:44 +01:00
a07c58955e Merge pull request 'Update Rust crate digest to 0.11.0-rc.5' (#450) from renovate/digest-0.x into master
Some checks failed
continuous-integration/drone/push Build is failing
2025-12-29 00:27:39 +00:00
adc9b6bee6 Update Rust crate digest to 0.11.0-rc.5
Some checks failed
continuous-integration/drone/push Build is failing
continuous-integration/drone/pr Build is failing
2025-12-28 00:27:15 +00:00
487c2febb7 Merge pull request 'Update Rust crate serde_json to 1.0.147' (#449) from renovate/serde_json-1.x into master
Some checks failed
continuous-integration/drone/push Build is failing
2025-12-27 00:27:22 +00:00
3856529abc Update Rust crate serde_json to 1.0.147
Some checks failed
continuous-integration/drone/push Build is failing
continuous-integration/drone/pr Build is failing
2025-12-25 00:27:44 +00:00
3aaaffd1a8 Merge pull request 'Update Rust crate askama to 0.15.0' (#448) from renovate/askama-0.x into master
Some checks failed
continuous-integration/drone/push Build is failing
2025-12-24 00:27:22 +00:00
7564702bd5 Update Rust crate askama to 0.15.0
Some checks failed
continuous-integration/drone/push Build is failing
continuous-integration/drone/pr Build is failing
2025-12-23 00:26:53 +00:00
98c63056e6 Merge pull request 'Update Rust crate bincode to v3' (#447) from renovate/bincode-3.x into master
Some checks failed
continuous-integration/drone/push Build is failing
2025-12-17 00:27:51 +00:00
f490d314e5 Update Rust crate bincode to v3
Some checks failed
renovate/artifacts Artifact file update failure
continuous-integration/drone/pr Build is failing
continuous-integration/drone/push Build is failing
2025-12-17 00:27:46 +00:00
6efd6a5abd Merge pull request 'Update Rust crate webauthn-rs to 0.5.4' (#446) from renovate/webauthn-rs-0.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2025-12-12 00:27:34 +00:00
cc79501f5a Update Rust crate webauthn-rs to 0.5.4
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2025-12-11 00:28:09 +00:00
9535ab754a Hide real build time of application
All checks were successful
continuous-integration/drone/push Build is passing
2025-12-05 10:10:00 +01:00
b72fa90b67 Fix Hex encoding of assets file digests
All checks were successful
continuous-integration/drone/push Build is passing
2025-12-04 19:21:18 +01:00
054fc0c4cc Use local fonts instead of google's one
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/tag Build is passing
2025-12-04 18:54:43 +01:00
3d19a0eba2 Optimize cache management
All checks were successful
continuous-integration/drone/push Build is passing
2025-12-04 18:51:46 +01:00
944e7dd00d Improve health endpoint 2025-12-04 18:20:05 +01:00
cb739ebe6d Can use Redis to store user sessions 2025-12-04 18:11:27 +01:00
a2af039759 Update dependencies
All checks were successful
continuous-integration/drone/push Build is passing
2025-12-04 16:29:30 +01:00
aac82d3415 Merge pull request 'Update Rust crate log to 0.4.29' (#445) from renovate/log-0.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2025-12-04 00:12:19 +00:00
259695c660 Update Rust crate log to 0.4.29
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2025-12-03 00:12:28 +00:00
d0a94d9e59 Merge pull request 'Update Rust crate actix-web to 4.12.1' (#444) from renovate/actix-web-4.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2025-11-28 00:12:19 +00:00
e717b44ebc Update Rust crate actix-web to 4.12.1
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2025-11-27 00:13:17 +00:00
1901238f87 Merge pull request 'Update Rust crate clap to 4.5.53' (#443) from renovate/clap-4.x into master
Some checks failed
continuous-integration/drone/push Build is failing
2025-11-21 00:06:51 +00:00
088d682b31 Update Rust crate clap to 4.5.53
Some checks failed
continuous-integration/drone/push Build is failing
continuous-integration/drone/pr Build is failing
2025-11-20 00:06:35 +00:00
02c7f764f5 Merge pull request 'Update Rust crate actix-web to 4.12.0' (#442) from renovate/actix-web-4.x into master
Some checks failed
continuous-integration/drone/push Build is failing
2025-11-18 00:07:30 +00:00
7b8412682d Update Rust crate actix-web to 4.12.0
Some checks failed
continuous-integration/drone/push Build is failing
continuous-integration/drone/pr Build is failing
2025-11-17 00:07:08 +00:00
5a05b547a8 Fix cargo clippy issue
All checks were successful
continuous-integration/drone/push Build is passing
2025-11-03 22:23:32 +01:00
da2aa8aac2 Merge pull request 'Update Rust crate lazy-regex to 3.4.2' (#441) from renovate/lazy-regex-3.x into master
Some checks failed
continuous-integration/drone/push Build is failing
2025-11-02 00:06:57 +00:00
bc453cfd26 Update Rust crate lazy-regex to 3.4.2
Some checks failed
continuous-integration/drone/push Build is failing
continuous-integration/drone/pr Build is failing
2025-11-01 00:07:09 +00:00
4b26a0ea12 Merge pull request 'Update Rust crate jwt-simple to 0.12.13' (#440) from renovate/jwt-simple-0.x into master
Some checks failed
continuous-integration/drone/push Build is failing
2025-11-01 00:06:34 +00:00
242d725ad0 Update Rust crate jwt-simple to 0.12.13
Some checks failed
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is failing
2025-10-31 00:33:01 +00:00
ce4317299e Merge pull request 'Update Rust crate clap to 4.5.51' (#439) from renovate/clap-4.x into master
All checks were successful
continuous-integration/drone/push Build is passing
2025-10-31 00:31:57 +00:00
14ede196c4 Update Rust crate clap to 4.5.51
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/pr Build is passing
2025-10-30 00:35:05 +00:00
6d341069a0 Fix appearance issue in clients list screen with long client ids
All checks were successful
continuous-integration/drone/push Build is passing
2025-10-29 12:34:47 +01:00
d4de81f1fb Can disable local login
All checks were successful
continuous-integration/drone/push Build is passing
2025-10-29 12:20:05 +01:00
9a599fdde2 Can create accounts automatically for a given upstream provider
All checks were successful
continuous-integration/drone/push Build is passing
2025-10-29 11:30:45 +01:00
764ad3d5a1 Add sample upstream provider 2025-10-29 09:34:10 +01:00
48 changed files with 1927 additions and 873 deletions

2
.gitignore vendored
View File

@@ -1,3 +1,3 @@
/target /target
.idea .idea
storage /storage

1987
Cargo.lock generated

File diff suppressed because it is too large Load Diff

View File

@@ -8,34 +8,35 @@ 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.13.0"
actix-session = { version = "0.11.0", features = ["cookie-session"] } actix-session = { version = "0.11.0", features = ["cookie-session", "redis-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.60", features = ["derive", "env"] }
include_dir = "0.7.4" include_dir = "0.7.4"
log = "0.4.28" log = "0.4.29"
serde_json = "1.0.145" serde_json = "1.0.149"
serde_yaml = "0.9.34" serde_yml = "0.0.12"
env_logger = "0.11.8" env_logger = "0.11.9"
serde = { version = "1.0.228", features = ["derive"] } serde = { version = "1.0.228", features = ["derive"] }
bcrypt = "0.17.1" bcrypt = "0.19.0"
uuid = { version = "1.18.1", features = ["v4"] } uuid = { version = "1.21.0", features = ["v4"] }
mime_guess = "2.0.5" mime_guess = "2.0.5"
askama = "0.14.0" askama = "0.15.4"
urlencoding = "2.1.3" urlencoding = "2.1.3"
rand = "0.9.2" rand = "0.10.0"
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.14", default-features = false, features = ["pure-rust"] }
digest = "0.10.7" sha2 = "0.11.0-rc.5"
sha2 = "0.10.9" lazy-regex = "3.6.0"
lazy-regex = "3.4.1"
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"
webauthn-rs = { version = "0.5.3", features = ["danger-allow-state-serialisation"] } webauthn-rs = { version = "0.5.4", features = ["danger-allow-state-serialisation"] }
url = "2.5.7" url = "2.5.8"
light-openid = { version = "1.0.4", features = ["crypto-wrapper"] } light-openid = { version = "1.1.0", features = ["crypto-wrapper"] }
bincode = "2.0.1" rkyv = "0.8.15"
chrono = "0.4.42" chrono = "0.4.44"
lazy_static = "1.5.0"
mailchecker = "6.0.19" mailchecker = "6.0.19"
httpdate = "1.0.3"
build-time = "0.1.3"
hex = "0.4.3"

View File

@@ -31,7 +31,7 @@ You can configure a list of clients (Relying Parties) in a `clients.yaml` file w
enforce_2fa_auth: true enforce_2fa_auth: true
# Optional, claims to be added to the ID token payload. # Optional, claims to be added to the ID token payload.
# The following placeholders can be set, they will the replaced when the token is created: # The following placeholders can be set, they will the replaced when the token is created:
# * {username}: user name of the user # * {username}: username of the user
# * {mail}: email address of the user # * {mail}: email address of the user
# * {first_name}: first name of the user # * {first_name}: first name of the user
# * {last_name}: last name of the user # * {last_name}: last name of the user
@@ -39,6 +39,11 @@ You can configure a list of clients (Relying Parties) in a `clients.yaml` file w
claims_id_token: claims_id_token:
groups: ["group_{user}"] groups: ["group_{user}"]
service: "auth" service: "auth"
# Optional, claims to be added to the access token payload
# The placeholders of `claims_id_token` can also be used here
claims_access_token:
groups: ["group_{user}"]
service: "auth"
# Optional, claims to be added to the user info endpoint response # Optional, claims to be added to the user info endpoint response
# The placeholders of `claims_id_token` can also be used here # The placeholders of `claims_id_token` can also be used here
claims_user_info: claims_user_info:
@@ -67,10 +72,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 +114,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 :)

View File

@@ -21,3 +21,7 @@ body {
.form-control::placeholder { .form-control::placeholder {
color: #555; color: #555;
} }
.table-break-works td {
word-break: break-all;
}

View File

@@ -11,7 +11,7 @@
* Copyright 2011-2024 The Bootstrap Authors * Copyright 2011-2024 The Bootstrap Authors
* Licensed under MIT (https://github.com/twbs/bootstrap/blob/main/LICENSE) * Licensed under MIT (https://github.com/twbs/bootstrap/blob/main/LICENSE)
*/ */
@import url("https://fonts.googleapis.com/css2?family=Roboto:wght@400;700&display=swap"); @import url("/assets/robotfont/font.css");
:root, :root,
[data-bs-theme=light] { [data-bs-theme=light] {
--bs-blue: #2a9fd6; --bs-blue: #2a9fd6;

View 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

View 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

View File

@@ -0,0 +1,63 @@
services:
redis:
image: redis
network_mode: host
volumes:
- ./redis/redis.conf:/redis.conf:ro
command: [ "redis-server", "/redis.conf" ]
healthcheck:
test: [ "CMD", "redis-cli", "ping" ]
interval: 10s
timeout: 30s
retries: 3
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
depends_on:
redis:
condition: service_healthy
environment:
- STORAGE_PATH=/storage
- DISABLE_LOCAL_LOGIN=true
- USE_REDIS=true
- REDIS_PASSWORD=secretsecret
#- RUST_LOG=debug
volumes:
- ../:/app
- ./storage:/storage
- ~/.cargo/registry:/usr/local/cargo/registry
command:
- bash
- -c
- cd /app && cargo run

View File

@@ -0,0 +1,3 @@
maxmemory 256mb
maxmemory-policy allkeys-lru
requirepass secretsecret

View File

@@ -0,0 +1 @@
users.json

View 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/

View 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

View File

@@ -5,7 +5,7 @@ use std::net::IpAddr;
use actix::{Actor, AsyncContext, Context, Handler, Message}; use actix::{Actor, AsyncContext, Context, Handler, Message};
use crate::constants::{FAIL_LOGIN_ATTEMPT_CLEANUP_INTERVAL, KEEP_FAILED_LOGIN_ATTEMPTS_FOR}; use crate::constants::{FAIL_LOGIN_ATTEMPT_CLEANUP_INTERVAL, KEEP_FAILED_LOGIN_ATTEMPTS_FOR};
use crate::utils::time::time; use crate::utils::time_utils::time;
#[derive(Message)] #[derive(Message)]
#[rtype(result = "()")] #[rtype(result = "()")]
@@ -87,7 +87,7 @@ mod test {
use std::net::{IpAddr, Ipv4Addr}; use std::net::{IpAddr, Ipv4Addr};
use crate::actors::bruteforce_actor::BruteForceActor; use crate::actors::bruteforce_actor::BruteForceActor;
use crate::utils::time::time; use crate::utils::time_utils::time;
const IP_1: IpAddr = IpAddr::V4(Ipv4Addr::new(192, 168, 1, 1)); const IP_1: IpAddr = IpAddr::V4(Ipv4Addr::new(192, 168, 1, 1));
const IP_2: IpAddr = IpAddr::V4(Ipv4Addr::new(192, 168, 1, 2)); const IP_2: IpAddr = IpAddr::V4(Ipv4Addr::new(192, 168, 1, 2));

View File

@@ -4,30 +4,33 @@ use actix::{Actor, AsyncContext, Context, Handler};
use crate::constants::*; use crate::constants::*;
use crate::data::access_token::AccessToken; use crate::data::access_token::AccessToken;
use crate::data::app_config::AppConfig; use crate::data::app_config::AppConfig;
use crate::data::client::ClientID; use crate::data::client::{Client, ClientID};
use crate::data::code_challenge::CodeChallenge; use crate::data::code_challenge::CodeChallenge;
use crate::data::jwt_signer::JWTSigner; use crate::data::jwt_signer::JWTSigner;
use crate::data::user::UserID; use crate::data::user::{User, UserID};
use crate::utils::err::Res; use crate::utils::err::Res;
use crate::utils::string_utils::rand_str; use crate::utils::string_utils::rand_str;
use crate::utils::time::time; use crate::utils::time_utils::time;
#[derive(Clone, Debug, serde::Serialize, serde::Deserialize, Eq, PartialEq)] #[derive(Clone, Debug, serde::Serialize, serde::Deserialize, Eq, PartialEq)]
pub struct SessionID(pub String); pub struct SessionID(pub String);
#[derive(Clone, Debug)] #[derive(Clone, Debug)]
pub struct Session { pub struct Session {
pub session_id: SessionID,
pub client: ClientID, pub client: ClientID,
pub user: UserID, pub user: UserID,
pub auth_time: u64, pub auth_time: u64,
pub redirect_uri: String, pub redirect_uri: String,
pub session_id: SessionID,
pub session_expire_at: u64,
pub authorization_code: String, pub authorization_code: String,
pub authorization_code_expire_at: u64, pub authorization_code_expire_at: u64,
pub access_token: Option<String>, pub access_token: Option<String>,
pub access_token_expire_at: u64, pub access_token_expire_at: u64,
pub refresh_token: String, pub refresh_token: String,
pub refresh_token_expire_at: u64, pub refresh_token_expire_at: u64,
@@ -37,19 +40,23 @@ pub struct Session {
impl Session { impl Session {
pub fn is_expired(&self) -> bool { pub fn is_expired(&self) -> bool {
self.authorization_code_expire_at < time() self.session_expire_at < time()
&& self.access_token_expire_at < time() || (self.authorization_code_expire_at < time()
&& self.refresh_token_expire_at < time() && self.access_token_expire_at < time()
&& self.refresh_token_expire_at < time())
} }
pub fn regenerate_access_and_refresh_tokens( pub fn regenerate_access_and_refresh_tokens(
&mut self, &mut self,
app_config: &AppConfig, app_config: &AppConfig,
jwt_signer: &JWTSigner, jwt_signer: &JWTSigner,
user: &User,
client: &Client,
) -> Res { ) -> Res {
let access_token = AccessToken { let access_token = AccessToken {
issuer: app_config.website_origin.to_string(), issuer: app_config.website_origin.to_string(),
subject_identifier: self.user.clone().0, user,
client,
issued_at: time(), issued_at: time(),
exp_time: time() + OPEN_ID_ACCESS_TOKEN_TIMEOUT, exp_time: time() + OPEN_ID_ACCESS_TOKEN_TIMEOUT,
rand_val: rand_str(OPEN_ID_ACCESS_TOKEN_LEN), rand_val: rand_str(OPEN_ID_ACCESS_TOKEN_LEN),

View File

@@ -15,7 +15,7 @@ use std::net::IpAddr;
use crate::data::login_redirect::LoginRedirect; use crate::data::login_redirect::LoginRedirect;
use crate::data::provider::ProviderID; 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_utils::time;
#[derive(Debug, Clone, serde::Serialize)] #[derive(Debug, Clone, serde::Serialize)]
pub struct ProviderLoginState { pub struct ProviderLoginState {

View File

@@ -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,
} }
@@ -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);

View File

@@ -64,7 +64,8 @@ pub const USERINFO_URI: &str = "/openid/userinfo";
/// Open ID constants /// Open ID constants
pub const OPEN_ID_SESSION_CLEANUP_INTERVAL: Duration = Duration::from_secs(60); pub const OPEN_ID_SESSION_CLEANUP_INTERVAL: Duration = Duration::from_secs(60);
pub const OPEN_ID_SESSION_LEN: usize = 40; pub const OPEN_ID_SESSION_ID_LEN: usize = 40;
pub const OPEN_ID_SESSION_MAX_DURATION: Duration = Duration::from_secs(3600 * 24 * 7);
pub const OPEN_ID_AUTHORIZATION_CODE_LEN: usize = 120; pub const OPEN_ID_AUTHORIZATION_CODE_LEN: usize = 120;
pub const OPEN_ID_AUTHORIZATION_CODE_TIMEOUT: u64 = 300; pub const OPEN_ID_AUTHORIZATION_CODE_TIMEOUT: u64 = 300;
pub const OPEN_ID_ACCESS_TOKEN_LEN: usize = 50; pub const OPEN_ID_ACCESS_TOKEN_LEN: usize = 50;

View File

@@ -1,7 +1,12 @@
use std::path::Path; use crate::utils::crypt_utils::sha256;
use crate::utils::time_utils;
use actix_web::{HttpResponse, web}; use actix_web::http::header;
use actix_web::{HttpRequest, HttpResponse, web};
use include_dir::{Dir, include_dir}; use include_dir::{Dir, include_dir};
use std::cmp::max;
use std::ops::Add;
use std::path::Path;
use std::time::Duration;
/// Assets directory /// Assets directory
static ASSETS_DIR: Dir = include_dir!("$CARGO_MANIFEST_DIR/assets"); static ASSETS_DIR: Dir = include_dir!("$CARGO_MANIFEST_DIR/assets");
@@ -12,14 +17,37 @@ pub async fn robots_txt() -> HttpResponse {
.body(include_str!("../../assets/robots.txt")) .body(include_str!("../../assets/robots.txt"))
} }
pub async fn assets_route(path: web::Path<String>) -> HttpResponse { pub async fn assets_route(req: HttpRequest, path: web::Path<String>) -> HttpResponse {
let path: &Path = path.as_ref().as_ref(); let path: &Path = path.as_ref().as_ref();
match ASSETS_DIR.get_file(path) { match ASSETS_DIR.get_file(path) {
None => HttpResponse::NotFound().body("404 Not found"), None => HttpResponse::NotFound().body("404 Not found"),
Some(file) => { Some(file) => {
let res = mime_guess::from_path(path).first_or_octet_stream(); let res = mime_guess::from_path(path).first_or_octet_stream();
let digest = hex::encode(sha256(file.contents()));
let file_time = max(time_utils::time_start_of_day(), time_utils::build_time());
// Check if the browser already knows the file by date
if let Some(c) = req.headers().get(header::IF_MODIFIED_SINCE) {
let date_str = c.to_str().unwrap_or("");
if let Ok(date) = httpdate::parse_http_date(date_str)
&& date.add(Duration::from_secs(1))
>= time_utils::unix_to_system_time(file_time)
{
return HttpResponse::NotModified().finish();
}
}
// Check if the browser already knows the etag
if let Some(c) = req.headers().get(header::IF_NONE_MATCH)
&& c.to_str().unwrap_or("") == digest
{
return HttpResponse::NotModified().finish();
}
HttpResponse::Ok() HttpResponse::Ok()
.content_type(res.to_string()) .content_type(res.to_string())
.insert_header(("etag", digest))
.insert_header(("last-modified", time_utils::unix_to_http_date(file_time)))
.body(file.contents()) .body(file.contents())
} }
} }

View File

@@ -49,6 +49,7 @@ impl Default for BaseLoginPage {
struct LoginTemplate { struct LoginTemplate {
p: BaseLoginPage, p: BaseLoginPage,
login: String, login: String,
show_local_login: bool,
providers: Vec<Provider>, providers: Vec<Provider>,
} }
@@ -156,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 {
@@ -224,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 {
@@ -235,6 +242,7 @@ pub async fn login_route(
..Default::default() ..Default::default()
}, },
login, login,
show_local_login: !AppConfig::get().disable_local_login,
providers: providers.cloned(), providers: providers.cloned(),
} }
.render() .render()

View File

@@ -26,7 +26,7 @@ use crate::data::login_redirect::{LoginRedirect, get_2fa_url};
use crate::data::session_identity::SessionIdentity; use crate::data::session_identity::SessionIdentity;
use crate::data::user::User; use crate::data::user::User;
use crate::utils::string_utils::rand_str; use crate::utils::string_utils::rand_str;
use crate::utils::time::time; use crate::utils::time_utils::time;
pub async fn get_configuration(req: HttpRequest) -> impl Responder { pub async fn get_configuration(req: HttpRequest) -> impl Responder {
let is_secure_request = req let is_secure_request = req
@@ -219,11 +219,12 @@ pub async fn authorize(
(_, "code") => { (_, "code") => {
// Save all authentication information in memory // Save all authentication information in memory
let session = Session { let session = Session {
session_id: SessionID(rand_str(OPEN_ID_SESSION_LEN)),
client: client.id.clone(), client: client.id.clone(),
user: user.uid.clone(), user: user.uid.clone(),
auth_time: SessionIdentity(Some(&id)).auth_time(), auth_time: SessionIdentity(Some(&id)).auth_time(),
redirect_uri, redirect_uri,
session_id: SessionID(rand_str(OPEN_ID_SESSION_ID_LEN)),
session_expire_at: time() + OPEN_ID_SESSION_MAX_DURATION.as_secs(),
authorization_code: rand_str(OPEN_ID_AUTHORIZATION_CODE_LEN), authorization_code: rand_str(OPEN_ID_AUTHORIZATION_CODE_LEN),
authorization_code_expire_at: time() + OPEN_ID_AUTHORIZATION_CODE_TIMEOUT, authorization_code_expire_at: time() + OPEN_ID_AUTHORIZATION_CODE_TIMEOUT,
access_token: None, access_token: None,
@@ -500,13 +501,7 @@ pub async fn token(
)); ));
} }
session.regenerate_access_and_refresh_tokens(AppConfig::get(), &jwt_signer)?; // Get user information
sessions
.send(openid_sessions_actor::UpdateSession(session.clone()))
.await
.unwrap();
let user: Option<User> = users let user: Option<User> = users
.send(users_actor::GetUserRequest(session.user.clone())) .send(users_actor::GetUserRequest(session.user.clone()))
.await .await
@@ -517,6 +512,18 @@ pub async fn token(
Some(u) => u, Some(u) => u,
}; };
// Refresh access and refresh tokens
session.regenerate_access_and_refresh_tokens(
AppConfig::get(),
&jwt_signer,
&user,
&client,
)?;
sessions
.send(openid_sessions_actor::UpdateSession(session.clone()))
.await
.unwrap();
// Generate id token // Generate id token
let id_token = IdToken { let id_token = IdToken {
issuer: AppConfig::get().website_origin.to_string(), issuer: AppConfig::get().website_origin.to_string(),
@@ -573,8 +580,24 @@ pub async fn token(
)); ));
} }
session.regenerate_access_and_refresh_tokens(AppConfig::get(), &jwt_signer)?; // Get user information
let user: Option<User> = users
.send(users_actor::GetUserRequest(session.user.clone()))
.await
.unwrap()
.0;
let user = match user {
None => return Ok(error_response(&query, "invalid_request", "User not found!")),
Some(u) => u,
};
// Regenerate user session
session.regenerate_access_and_refresh_tokens(
AppConfig::get(),
&jwt_signer,
&user,
&client,
)?;
sessions sessions
.send(openid_sessions_actor::UpdateSession(session.clone())) .send(openid_sessions_actor::UpdateSession(session.clone()))
.await .await

View File

@@ -1,11 +1,5 @@
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};
@@ -18,6 +12,11 @@ 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")]
@@ -273,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 {
@@ -293,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
@@ -300,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,

View File

@@ -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(),
} }
} }

View File

@@ -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,7 +52,7 @@ 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),
}; };
@@ -102,7 +101,7 @@ 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)),
}; };

View File

@@ -14,7 +14,7 @@ use crate::data::current_user::CurrentUser;
use crate::data::totp_key::TotpKey; use crate::data::totp_key::TotpKey;
use crate::data::user::User; use crate::data::user::User;
use crate::data::webauthn_manager::WebAuthManagerReq; use crate::data::webauthn_manager::WebAuthManagerReq;
use crate::utils::time::fmt_time; use crate::utils::time_utils::fmt_time;
#[derive(Template)] #[derive(Template)]
#[template(path = "settings/two_factors_page.html")] #[template(path = "settings/two_factors_page.html")]

View File

@@ -1,9 +1,12 @@
use crate::data::client::{AdditionalClaims, Client};
use crate::data::user::User;
use jwt_simple::claims::JWTClaims; use jwt_simple::claims::JWTClaims;
use jwt_simple::prelude::Duration; use jwt_simple::prelude::Duration;
pub struct AccessToken { pub struct AccessToken<'a> {
pub issuer: String, pub issuer: String,
pub subject_identifier: String, pub user: &'a User,
pub client: &'a Client,
pub issued_at: u64, pub issued_at: u64,
pub exp_time: u64, pub exp_time: u64,
pub rand_val: String, pub rand_val: String,
@@ -13,21 +16,26 @@ pub struct AccessToken {
#[derive(serde::Serialize, serde::Deserialize)] #[derive(serde::Serialize, serde::Deserialize)]
pub struct CustomAccessTokenClaims { pub struct CustomAccessTokenClaims {
rand_val: String, rand_val: String,
/// Additional claims
#[serde(skip_serializing_if = "Option::is_none")]
#[serde(flatten)]
pub additional_claims: Option<AdditionalClaims>,
} }
impl AccessToken { impl<'a> AccessToken<'a> {
pub fn to_jwt_claims(self) -> JWTClaims<CustomAccessTokenClaims> { pub fn to_jwt_claims(self) -> JWTClaims<CustomAccessTokenClaims> {
JWTClaims { JWTClaims {
issued_at: Some(Duration::from_secs(self.issued_at)), issued_at: Some(Duration::from_secs(self.issued_at)),
expires_at: Some(Duration::from_secs(self.exp_time)), expires_at: Some(Duration::from_secs(self.exp_time)),
invalid_before: None, invalid_before: None,
issuer: Some(self.issuer), issuer: Some(self.issuer),
subject: Some(self.subject_identifier), subject: Some(self.user.uid.0.to_string()),
audiences: None, audiences: None,
jwt_id: None, jwt_id: None,
nonce: self.nonce, nonce: self.nonce,
custom: CustomAccessTokenClaims { custom: CustomAccessTokenClaims {
rand_val: self.rand_val, rand_val: self.rand_val,
additional_claims: self.client.claims_access_token(self.user),
}, },
} }
} }

View File

@@ -17,7 +17,7 @@ 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, TwoFactorType, User, UserID}; use crate::data::user::{FactorID, GrantedClients, TwoFactor, TwoFactorType, User, UserID};
use crate::utils::time::time; use crate::utils::time_utils::time;
#[derive(serde::Serialize)] #[derive(serde::Serialize)]
pub struct LoggableUser { pub struct LoggableUser {
@@ -150,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,
@@ -282,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

View File

@@ -1,6 +1,6 @@
use std::path::{Path, PathBuf};
use clap::Parser; use clap::Parser;
use std::path::{Path, PathBuf};
use std::sync::OnceLock;
use crate::constants::{ 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,
@@ -62,25 +62,52 @@ pub struct AppConfig {
/// Login background image /// Login background image
#[arg(long, env, default_value = "/assets/img/forest.jpg")] #[arg(long, env, default_value = "/assets/img/forest.jpg")]
pub login_background_image: String, 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,
/// Use Redis to store cookie sessions
#[arg(long, env)]
pub use_redis: bool,
/// Redis connection hostname
#[clap(long, env, default_value = "localhost")]
redis_hostname: String,
/// Redis connection port
#[clap(long, env, default_value_t = 6379)]
redis_port: u16,
/// Redis database number
#[clap(long, env, default_value_t = 0)]
redis_db_number: i64,
/// Redis username
#[clap(long, env)]
redis_username: Option<String>,
/// Redis password
#[clap(long, env, default_value = "secretredis")]
redis_password: String,
} }
lazy_static::lazy_static! { static ARGS: OnceLock<AppConfig> = OnceLock::new();
static ref ARGS: AppConfig = {
let mut config = AppConfig::parse();
// In debug mode only, use dummy token
if cfg!(debug_assertions) && config.token_key.is_empty() {
config.token_key = String::from_utf8_lossy(&[32; 64]).to_string();
}
config
};
}
impl AppConfig { impl AppConfig {
/// Get parsed command line arguments /// Get parsed command line arguments
pub fn get() -> &'static AppConfig { pub fn get() -> &'static AppConfig {
&ARGS ARGS.get_or_init(|| {
let mut config = AppConfig::parse();
// In debug mode only, use dummy token
if cfg!(debug_assertions) && config.token_key.is_empty() {
config.token_key = String::from_utf8_lossy(&[32; 64]).to_string();
}
config
})
} }
pub fn secure_cookie(&self) -> bool { pub fn secure_cookie(&self) -> bool {
@@ -132,6 +159,21 @@ impl AppConfig {
let domain = self.domain_name(); let domain = self.domain_name();
domain.split_once(':').map(|i| i.0).unwrap_or(domain) domain.split_once(':').map(|i| i.0).unwrap_or(domain)
} }
/// Get Redis connection configuration
pub fn redis_connection_string(&self) -> Option<String> {
match self.use_redis {
true => Some(format!(
"redis://{}:{}@{}:{}/{}",
self.redis_username.as_deref().unwrap_or(""),
self.redis_password,
self.redis_hostname,
self.redis_port,
self.redis_db_number
)),
false => None,
}
}
} }
#[cfg(test)] #[cfg(test)]

View File

@@ -42,6 +42,9 @@ pub struct Client {
/// Additional claims to return with the id token /// Additional claims to return with the id token
claims_id_token: Option<AdditionalClaims>, claims_id_token: Option<AdditionalClaims>,
/// Additional claims to return with the access token
claims_access_token: Option<AdditionalClaims>,
/// Additional claims to return through the user info endpoint /// Additional claims to return through the user info endpoint
claims_user_info: Option<AdditionalClaims>, claims_user_info: Option<AdditionalClaims>,
} }
@@ -117,6 +120,11 @@ impl Client {
self.process_additional_claims(user, &self.claims_id_token) self.process_additional_claims(user, &self.claims_id_token)
} }
/// Get additional claims for access_token for a successful authentication
pub fn claims_access_token(&self, user: &User) -> Option<AdditionalClaims> {
self.process_additional_claims(user, &self.claims_access_token)
}
/// Get additional claims for user info for a successful authentication /// Get additional claims for user info for a successful authentication
pub fn claims_user_info(&self, user: &User) -> Option<AdditionalClaims> { pub fn claims_user_info(&self, user: &User) -> Option<AdditionalClaims> {
self.process_additional_claims(user, &self.claims_user_info) self.process_additional_claims(user, &self.claims_user_info)

View File

@@ -13,7 +13,7 @@ use crate::actors::users_actor::UsersActor;
use crate::constants::SECOND_FACTOR_EXPIRATION_FOR_CRITICAL_OPERATIONS; use crate::constants::SECOND_FACTOR_EXPIRATION_FOR_CRITICAL_OPERATIONS;
use crate::data::session_identity::SessionIdentity; use crate::data::session_identity::SessionIdentity;
use crate::data::user::User; use crate::data::user::User;
use crate::utils::time::time; use crate::utils::time_utils::time;
pub struct CurrentUser { pub struct CurrentUser {
user: User, user: User,

View File

@@ -36,7 +36,7 @@ where
file_path: path.as_ref().to_path_buf(), file_path: path.as_ref().to_path_buf(),
list: match Self::file_format(path.as_ref()) { list: match Self::file_format(path.as_ref()) {
FileFormat::Json => serde_json::from_str(&file_content)?, FileFormat::Json => serde_json::from_str(&file_content)?,
FileFormat::Yaml => serde_yaml::from_str(&file_content)?, FileFormat::Yaml => serde_yml::from_str(&file_content)?,
}, },
}) })
} }
@@ -47,7 +47,7 @@ where
&self.file_path, &self.file_path,
match Self::file_format(self.file_path.as_ref()) { match Self::file_format(self.file_path.as_ref()) {
FileFormat::Json => serde_json::to_string(&self.list)?, FileFormat::Json => serde_json::to_string(&self.list)?,
FileFormat::Yaml => serde_yaml::to_string(&self.list)?, FileFormat::Yaml => serde_yml::to_string(&self.list)?,
}, },
)?) )?)
} }

View File

@@ -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,
} }
} }

View File

@@ -9,7 +9,7 @@ use crate::data::app_config::AppConfig;
use crate::data::provider::Provider; use crate::data::provider::Provider;
use crate::utils::err::Res; use crate::utils::err::Res;
use crate::utils::time::time; use crate::utils::time_utils::time;
/// Provider configuration /// Provider configuration
#[derive(Debug, Clone)] #[derive(Debug, Clone)]

View File

@@ -3,22 +3,17 @@ use actix_web::{HttpMessage, HttpRequest};
use serde::{Deserialize, Serialize}; 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_utils::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>,

View File

@@ -1,11 +1,11 @@
use base32::Alphabet; use base32::Alphabet;
use rand::Rng; use rand::RngExt;
use totp_rfc6238::{HashAlgorithm, TotpGenerator}; use totp_rfc6238::{HashAlgorithm, TotpGenerator};
use crate::data::app_config::AppConfig; use crate::data::app_config::AppConfig;
use crate::data::user::User; use crate::data::user::User;
use crate::utils::err::Res; use crate::utils::err::Res;
use crate::utils::time::time; use crate::utils::time_utils::time;
const BASE32_ALPHABET: Alphabet = Alphabet::Rfc4648 { padding: true }; const BASE32_ALPHABET: Alphabet = Alphabet::Rfc4648 { padding: true };
const NUM_DIGITS: usize = 6; const NUM_DIGITS: usize = 6;

View File

@@ -1,4 +1,3 @@
use bincode::{Decode, Encode};
use std::collections::HashMap; use std::collections::HashMap;
use std::net::IpAddr; use std::net::IpAddr;
@@ -9,11 +8,27 @@ use crate::data::login_redirect::LoginRedirect;
use crate::data::provider::{Provider, ProviderID}; use crate::data::provider::{Provider, ProviderID};
use crate::data::totp_key::TotpKey; use crate::data::totp_key::TotpKey;
use crate::data::webauthn_manager::WebauthnPubKey; use crate::data::webauthn_manager::WebauthnPubKey;
use crate::utils::time::{fmt_time, time}; use crate::utils::time_utils::{fmt_time, time};
#[derive(Clone, Debug, Eq, PartialEq, serde::Serialize, serde::Deserialize, Encode, Decode)] #[derive(
Clone,
Debug,
Eq,
PartialEq,
serde::Serialize,
serde::Deserialize,
rkyv::Archive,
rkyv::Serialize,
rkyv::Deserialize,
)]
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,
@@ -46,6 +61,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),
@@ -295,7 +316,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(),

View File

@@ -4,7 +4,7 @@ use crate::actors::users_actor::{AuthorizedAuthenticationSources, UsersSyncBacke
use crate::data::entity_manager::EntityManager; use crate::data::entity_manager::EntityManager;
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, new_error}; use crate::utils::err::{Res, new_error};
use crate::utils::time::time; use crate::utils::time_utils::time;
impl EntityManager<User> { impl EntityManager<User> {
/// Update user information /// Update user information
@@ -71,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);

View File

@@ -1,7 +1,6 @@
use std::sync::Arc; use std::sync::Arc;
use actix_web::web; use actix_web::web;
use bincode::{Decode, Encode};
use light_openid::crypto_wrapper::CryptoWrapper; use light_openid::crypto_wrapper::CryptoWrapper;
use uuid::Uuid; use uuid::Uuid;
use webauthn_rs::prelude::{ use webauthn_rs::prelude::{
@@ -16,7 +15,7 @@ use crate::constants::{
use crate::data::app_config::AppConfig; use crate::data::app_config::AppConfig;
use crate::data::user::{User, UserID}; use crate::data::user::{User, UserID};
use crate::utils::err::Res; use crate::utils::err::Res;
use crate::utils::time::time; use crate::utils::time_utils::time;
#[derive(Clone, Debug, serde::Serialize, serde::Deserialize)] #[derive(Clone, Debug, serde::Serialize, serde::Deserialize)]
pub struct WebauthnPubKey { pub struct WebauthnPubKey {
@@ -28,7 +27,9 @@ pub struct RegisterKeyRequest {
pub creation_challenge: CreationChallengeResponse, pub creation_challenge: CreationChallengeResponse,
} }
#[derive(Debug, serde::Serialize, serde::Deserialize, Encode, Decode)] #[derive(
Debug, serde::Serialize, serde::Deserialize, rkyv::Archive, rkyv::Serialize, rkyv::Deserialize,
)]
struct RegisterKeyOpaqueData { struct RegisterKeyOpaqueData {
registration_state: String, registration_state: String,
user_id: UserID, user_id: UserID,
@@ -40,7 +41,7 @@ pub struct AuthRequest {
pub login_challenge: RequestChallengeResponse, pub login_challenge: RequestChallengeResponse,
} }
#[derive(Debug, Encode, Decode)] #[derive(Debug, rkyv::Archive, rkyv::Serialize, rkyv::Deserialize)]
struct AuthStateOpaqueData { struct AuthStateOpaqueData {
authentication_state: String, authentication_state: String,
user_id: UserID, user_id: UserID,

View File

@@ -1,12 +1,12 @@
use core::time::Duration; use core::time::Duration;
use std::sync::Arc; use std::sync::Arc;
use actix::Actor; use actix::{Actor, Addr};
use actix_identity::IdentityMiddleware; use actix_identity::IdentityMiddleware;
use actix_identity::config::LogoutBehavior; use actix_identity::config::LogoutBehavior;
use actix_remote_ip::RemoteIPConfig; use actix_remote_ip::RemoteIPConfig;
use actix_session::SessionMiddleware; use actix_session::SessionMiddleware;
use actix_session::storage::CookieSessionStore; use actix_session::storage::{CookieSessionStore, RedisSessionStore};
use actix_web::cookie::{Key, SameSite}; use actix_web::cookie::{Key, SameSite};
use actix_web::middleware::Logger; use actix_web::middleware::Logger;
use actix_web::{App, HttpResponse, HttpServer, get, middleware, web}; use actix_web::{App, HttpResponse, HttpServer, get, middleware, web};
@@ -14,6 +14,7 @@ use actix_web::{App, HttpResponse, HttpServer, get, middleware, web};
use basic_oidc::actors::bruteforce_actor::BruteForceActor; use basic_oidc::actors::bruteforce_actor::BruteForceActor;
use basic_oidc::actors::openid_sessions_actor::OpenIDSessionsActor; use basic_oidc::actors::openid_sessions_actor::OpenIDSessionsActor;
use basic_oidc::actors::providers_states_actor::ProvidersStatesActor; use basic_oidc::actors::providers_states_actor::ProvidersStatesActor;
use basic_oidc::actors::users_actor;
use basic_oidc::actors::users_actor::{UsersActor, UsersSyncBackend}; use basic_oidc::actors::users_actor::{UsersActor, UsersSyncBackend};
use basic_oidc::constants::*; use basic_oidc::constants::*;
use basic_oidc::controllers::assets_controller::assets_route; use basic_oidc::controllers::assets_controller::assets_route;
@@ -26,9 +27,20 @@ use basic_oidc::data::provider::ProvidersManager;
use basic_oidc::data::user::User; use basic_oidc::data::user::User;
use basic_oidc::data::webauthn_manager::WebAuthManager; use basic_oidc::data::webauthn_manager::WebAuthManager;
use basic_oidc::middlewares::auth_middleware::AuthMiddleware; use basic_oidc::middlewares::auth_middleware::AuthMiddleware;
use basic_oidc::middlewares::multi_session_store::MultiSessionStore;
#[get("/health")] #[get("/health")]
async fn health() -> &'static str { async fn health(users: web::Data<Addr<UsersActor>>) -> &'static str {
// Check users list is working
let users = users
.send(users_actor::GetAllUsers)
.await
.expect("Could not retrieve users list!");
if users.is_empty() {
log::error!("Got empty list of users!");
panic!("Got empty list of users!");
}
"Running" "Running"
} }
@@ -69,6 +81,18 @@ async fn main() -> std::io::Result<()> {
.expect("Failed to change default admin password!"); .expect("Failed to change default admin password!");
} }
let redis_store = match AppConfig::get().redis_connection_string() {
Some(s) => {
log::info!("Connect to Redis session store...");
Some(
RedisSessionStore::new(s)
.await
.expect("Failed to connect to Redis!"),
)
}
None => None,
};
let users_actor = UsersActor::new(users).start(); let users_actor = UsersActor::new(users).start();
let bruteforce_actor = BruteForceActor::default().start(); let bruteforce_actor = BruteForceActor::default().start();
let providers_states_actor = ProvidersStatesActor::default().start(); let providers_states_actor = ProvidersStatesActor::default().start();
@@ -91,7 +115,10 @@ async fn main() -> std::io::Result<()> {
HttpServer::new(move || { HttpServer::new(move || {
let session_mw = SessionMiddleware::builder( let session_mw = SessionMiddleware::builder(
CookieSessionStore::default(), match redis_store.clone() {
None => MultiSessionStore::Cookie(CookieSessionStore::default()),
Some(s) => MultiSessionStore::Redis(s),
},
Key::from(config.token_key.as_bytes()), Key::from(config.token_key.as_bytes()),
) )
.cookie_name(SESSION_COOKIE_NAME.to_string()) .cookie_name(SESSION_COOKIE_NAME.to_string())

View File

@@ -1 +1,2 @@
pub mod auth_middleware; pub mod auth_middleware;
pub mod multi_session_store;

View File

@@ -0,0 +1,63 @@
use actix_session::storage::{
CookieSessionStore, LoadError, RedisSessionStore, SaveError, SessionKey, SessionStore,
UpdateError,
};
use actix_web::cookie::time::Duration;
use jwt_simple::Error;
use std::collections::HashMap;
type SessionState = HashMap<String, String>;
/// Session store multiplexer.
///
/// Allows to easily support different store without having a lot of duplicate code
pub enum MultiSessionStore {
Cookie(CookieSessionStore),
Redis(RedisSessionStore),
}
impl SessionStore for MultiSessionStore {
async fn load(&self, session_key: &SessionKey) -> Result<Option<SessionState>, LoadError> {
match self {
MultiSessionStore::Cookie(c) => c.load(session_key).await,
MultiSessionStore::Redis(r) => r.load(session_key).await,
}
}
async fn save(
&self,
session_state: SessionState,
ttl: &Duration,
) -> Result<SessionKey, SaveError> {
match self {
MultiSessionStore::Cookie(c) => c.save(session_state, ttl).await,
MultiSessionStore::Redis(r) => r.save(session_state, ttl).await,
}
}
async fn update(
&self,
session_key: SessionKey,
session_state: SessionState,
ttl: &Duration,
) -> Result<SessionKey, UpdateError> {
match self {
MultiSessionStore::Cookie(c) => c.update(session_key, session_state, ttl).await,
MultiSessionStore::Redis(r) => r.update(session_key, session_state, ttl).await,
}
}
async fn update_ttl(&self, session_key: &SessionKey, ttl: &Duration) -> Result<(), Error> {
match self {
MultiSessionStore::Cookie(c) => c.update_ttl(session_key, ttl).await,
MultiSessionStore::Redis(r) => r.update_ttl(session_key, ttl).await,
}
}
async fn delete(&self, session_key: &SessionKey) -> Result<(), Error> {
match self {
MultiSessionStore::Cookie(c) => c.delete(session_key).await,
MultiSessionStore::Redis(r) => r.delete(session_key).await,
}
}
}

View File

@@ -1,4 +1,4 @@
use digest::Digest; use sha2::Digest;
#[inline] #[inline]
pub fn sha256(input: &[u8]) -> Vec<u8> { pub fn sha256(input: &[u8]) -> Vec<u8> {

View File

@@ -1,4 +1,4 @@
pub mod crypt_utils; pub mod crypt_utils;
pub mod err; pub mod err;
pub mod string_utils; pub mod string_utils;
pub mod time; pub mod time_utils;

View File

@@ -1,35 +0,0 @@
use chrono::DateTime;
use std::time::{SystemTime, UNIX_EPOCH};
/// Get the current time since epoch
pub fn time() -> u64 {
SystemTime::now()
.duration_since(UNIX_EPOCH)
.unwrap()
.as_secs()
}
/// Format unix timestamp to a human-readable string
pub fn fmt_time(timestamp: u64) -> String {
// Create a DateTime from the timestamp
let datetime =
DateTime::from_timestamp(timestamp as i64, 0).expect("Failed to parse timestamp!");
// Format the datetime how you want
datetime.format("%Y-%m-%d %H:%M:%S").to_string()
}
#[cfg(test)]
mod test {
use crate::utils::time::{fmt_time, time};
#[test]
fn test_time() {
assert!(time() > 10);
}
#[test]
fn test_fmt_time() {
assert_eq!(fmt_time(1693475465), "2023-08-31 09:51:05");
}
}

61
src/utils/time_utils.rs Normal file
View File

@@ -0,0 +1,61 @@
use chrono::{DateTime, Local, NaiveTime};
use std::time::{Duration, SystemTime, UNIX_EPOCH};
/// Get the current time since epoch
pub fn time() -> u64 {
SystemTime::now()
.duration_since(UNIX_EPOCH)
.unwrap()
.as_secs()
}
/// Format unix timestamp to a human-readable string
pub fn fmt_time(timestamp: u64) -> String {
// Create a DateTime from the timestamp
let datetime =
DateTime::from_timestamp(timestamp as i64, 0).expect("Failed to parse timestamp!");
// Format the datetime how you want
datetime.format("%Y-%m-%d %H:%M:%S").to_string()
}
/// Convert UNIX time to system time
pub fn unix_to_system_time(time: u64) -> SystemTime {
UNIX_EPOCH + Duration::from_secs(time)
}
/// Format UNIX time to HTTP date
pub fn unix_to_http_date(time: u64) -> String {
httpdate::fmt_http_date(unix_to_system_time(time))
}
/// Get build time in UNIX format
pub fn build_time() -> u64 {
let build_time = build_time::build_time_local!();
let date =
chrono::DateTime::parse_from_rfc3339(build_time).expect("Failed to parse compile date");
date.timestamp() as u64
}
/// Get the first second of the day (local time)
pub fn time_start_of_day() -> u64 {
let local: DateTime<Local> = Local::now()
.with_time(NaiveTime::from_hms_opt(0, 0, 0).unwrap())
.unwrap();
local.timestamp() as u64
}
#[cfg(test)]
mod test {
use crate::utils::time_utils::{fmt_time, time};
#[test]
fn test_time() {
assert!(time() > 10);
}
#[test]
fn test_fmt_time() {
assert_eq!(fmt_time(1693475465), "2023-08-31 09:51:05");
}
}

View File

@@ -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() %}

View File

@@ -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

View File

@@ -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>