Compare commits

..

194 Commits

Author SHA1 Message Date
5a05b547a8 Fix cargo clippy issue 2025-11-03 22:23:32 +01:00
da2aa8aac2 Merge pull request 'Update Rust crate lazy-regex to 3.4.2' () from renovate/lazy-regex-3.x into master 2025-11-02 00:06:57 +00:00
bc453cfd26 Update Rust crate lazy-regex to 3.4.2 2025-11-01 00:07:09 +00:00
4b26a0ea12 Merge pull request 'Update Rust crate jwt-simple to 0.12.13' () from renovate/jwt-simple-0.x into master 2025-11-01 00:06:34 +00:00
242d725ad0 Update Rust crate jwt-simple to 0.12.13 2025-10-31 00:33:01 +00:00
ce4317299e Merge pull request 'Update Rust crate clap to 4.5.51' () from renovate/clap-4.x into master 2025-10-31 00:31:57 +00:00
14ede196c4 Update Rust crate clap to 4.5.51 2025-10-30 00:35:05 +00:00
6d341069a0 Fix appearance issue in clients list screen with long client ids 2025-10-29 12:34:47 +01:00
d4de81f1fb Can disable local login 2025-10-29 12:20:05 +01:00
9a599fdde2 Can create accounts automatically for a given upstream provider 2025-10-29 11:30:45 +01:00
764ad3d5a1 Add sample upstream provider 2025-10-29 09:34:10 +01:00
ffd93c5435 Can customize login background image 2025-10-28 18:05:35 +01:00
2a729d4153 Can log actions in JSON format 2025-10-28 11:43:23 +01:00
a128e4a597 Auto-publish releases to Gitea 2025-10-28 10:06:55 +01:00
96f3773375 Remove useless dependency 2025-10-28 09:59:07 +01:00
5db16c2355 Make clients list file configurable 2025-10-28 09:56:52 +01:00
e93e3f4d9c Merge pull request 'Update Rust crate webauthn-rs to 0.5.3' () from renovate/webauthn-rs-0.x into master 2025-10-25 00:34:41 +00:00
5abe3bfbd5 Update Rust crate webauthn-rs to 0.5.3 2025-10-24 00:35:07 +00:00
4deb1a5536 Merge pull request 'Update Rust crate clap to 4.5.50' () from renovate/clap-4.x into master 2025-10-22 00:34:32 +00:00
83efd5ac56 Update Rust crate clap to 4.5.50 2025-10-21 00:35:19 +00:00
89f806a692 Merge pull request 'Update Rust crate mailchecker to 6.0.19' () from renovate/mailchecker-6.x into master 2025-10-21 00:35:14 +00:00
58a19c04e7 Update Rust crate mailchecker to 6.0.19 2025-10-20 00:33:39 +00:00
7d8931c365 Merge pull request 'Update Rust crate clap to 4.5.49' () from renovate/clap-4.x into master 2025-10-15 00:32:36 +00:00
05adc38408 Update Rust crate clap to 4.5.49 2025-10-14 00:34:54 +00:00
97ff967b87 Merge pull request 'Update Rust crate serde to 1.0.228' () from renovate/serde-1.x into master 2025-09-29 00:32:15 +00:00
c3215e0053 Update Rust crate serde to 1.0.228 2025-09-28 00:32:30 +00:00
fe968d6765 Merge pull request 'Update Rust crate serde to 1.0.227' () from renovate/serde-1.x into master 2025-09-27 00:34:05 +00:00
38bd624ef6 Update Rust crate serde to 1.0.227 2025-09-26 00:32:29 +00:00
e32b2be2b8 Merge pull request 'Update Rust crate serde to 1.0.226' () from renovate/serde-1.x into master 2025-09-22 00:32:37 +00:00
29f1c4d1f3 Update Rust crate serde to 1.0.226 2025-09-21 00:34:32 +00:00
27562c4fbf Merge pull request 'Update Rust crate clap to 4.5.48' () from renovate/clap-4.x into master 2025-09-21 00:34:19 +00:00
d329a8cf36 Update Rust crate clap to 4.5.48 2025-09-20 00:32:48 +00:00
d4253d897d Merge pull request 'Update Rust crate serde to 1.0.225' () from renovate/serde-1.x into master 2025-09-18 00:33:16 +00:00
b2c91467e5 Update Rust crate serde to 1.0.225 2025-09-17 00:32:39 +00:00
922cc4e45f Merge pull request 'Update Rust crate serde_json to 1.0.145' () from renovate/serde_json-1.x into master 2025-09-16 00:32:34 +00:00
e0ec825947 Update Rust crate serde_json to 1.0.145 2025-09-15 00:33:08 +00:00
e82efde2b9 Merge pull request 'Update Rust crate chrono to 0.4.42' () from renovate/chrono-0.x into master 2025-09-10 00:32:04 +00:00
890e1ef1f1 Update Rust crate chrono to 0.4.42 2025-09-09 00:32:39 +00:00
2503500800 Merge pull request 'Update Rust crate log to 0.4.28' () from renovate/log-0.x into master 2025-09-07 00:32:32 +00:00
988c15e32e Update Rust crate log to 0.4.28 2025-09-06 00:33:06 +00:00
5bb6bdccd0 Fix cargo clippy issue 2025-09-05 13:41:32 +02:00
068284c456 Merge pull request 'Update Rust crate uuid to 1.18.1' () from renovate/uuid-1.x into master 2025-09-04 00:25:24 +00:00
a9a9c26a3e Merge pull request 'Update Rust crate clap to 4.5.47' () from renovate/clap-4.x into master 2025-09-04 00:25:19 +00:00
34ce0fd1ae Update Rust crate uuid to 1.18.1 2025-09-03 00:24:54 +00:00
8ce29bbb63 Update Rust crate clap to 4.5.47 2025-09-03 00:24:52 +00:00
52bdb70a8a Merge pull request 'Update Rust crate actix-identity to 0.9.0' () from renovate/actix-identity-0.x into master 2025-08-31 00:24:36 +00:00
23c53a8548 Update Rust crate actix-identity to 0.9.0 2025-08-30 00:24:59 +00:00
28efebdff1 Merge pull request 'Update Rust crate clap to 4.5.46' () from renovate/clap-4.x into master 2025-08-30 00:24:33 +00:00
d44daf0c04 Update Rust crate clap to 4.5.46 2025-08-29 00:25:48 +00:00
1cdf10d548 Fix cargo clippy issue 2025-08-28 08:17:47 +02:00
0dcb86c538 Merge pull request 'Update Rust crate actix-session to 0.11.0' () from renovate/actix-session-0.x into master 2025-08-27 00:25:09 +00:00
4fd42d0e17 Update Rust crate actix-session to 0.11.0 2025-08-27 00:25:04 +00:00
9afeb3c67e Merge pull request 'Update Rust crate url to 2.5.7' () from renovate/url-2.x into master 2025-08-25 00:24:20 +00:00
7213096faf Update Rust crate url to 2.5.7 2025-08-24 00:24:51 +00:00
5d321e4cac Merge pull request 'Update Rust crate serde_json to 1.0.143' () from renovate/serde_json-1.x into master 2025-08-22 00:24:32 +00:00
77f7ba94ba Merge pull request 'Update Rust crate mailchecker to 6.0.18' () from renovate/mailchecker-6.x into master 2025-08-22 00:24:28 +00:00
830170303a Update Rust crate serde_json to 1.0.143 2025-08-21 00:25:14 +00:00
e6ad5b0090 Update Rust crate mailchecker to 6.0.18 2025-08-21 00:25:12 +00:00
7f42b9ca4f Merge pull request 'Update Rust crate bcrypt to 0.17.1' () from renovate/bcrypt-0.x into master 2025-08-20 00:24:23 +00:00
2e195cba32 Update Rust crate bcrypt to 0.17.1 2025-08-19 00:25:13 +00:00
f972a0c1fc Merge pull request 'Update Rust crate clap to 4.5.45' () from renovate/clap-4.x into master 2025-08-15 00:24:19 +00:00
90991c89be Update Rust crate clap to 4.5.45 2025-08-14 00:24:41 +00:00
505d76f804 Merge pull request 'Update Rust crate uuid to 1.18.0' () from renovate/uuid-1.x into master 2025-08-13 00:24:41 +00:00
76920f66d7 Update Rust crate uuid to 1.18.0 2025-08-12 00:24:35 +00:00
d86d53ad64 Merge pull request 'Update Rust crate clap to 4.5.43' () from renovate/clap-4.x into master 2025-08-08 00:12:00 +00:00
f63e0dd97b Update Rust crate clap to 4.5.43 2025-08-07 00:12:29 +00:00
e707b41e5e Merge pull request 'Update Rust crate serde_json to 1.0.142' () from renovate/serde_json-1.x into master 2025-08-02 00:12:09 +00:00
4f432402fb Update Rust crate serde_json to 1.0.142 2025-08-01 00:13:48 +00:00
ab0310347c Merge pull request 'Update Rust crate clap to 4.5.42' () from renovate/clap-4.x into master 2025-08-01 00:12:04 +00:00
06d46408b5 Update Rust crate clap to 4.5.42 2025-07-31 00:12:19 +00:00
ba55b66ed1 Merge pull request 'Update Rust crate rand to 0.9.2' () from renovate/rand-0.x into master 2025-07-21 00:13:42 +00:00
0eaca53a16 Update Rust crate rand to 0.9.2 2025-07-21 00:13:36 +00:00
e8e4aab0eb Merge pull request 'Update Rust crate serde_json to 1.0.141' () from renovate/serde_json-1.x into master 2025-07-19 00:13:53 +00:00
7abbb78dda Update Rust crate serde_json to 1.0.141 2025-07-19 00:13:40 +00:00
e26faee426 Merge pull request 'Update Rust crate webauthn-rs to 0.5.2' () from renovate/webauthn-rs-0.x into master 2025-07-10 00:23:56 +00:00
a7a761f32a Merge pull request 'Update Rust crate clap to 4.5.41' () from renovate/clap-4.x into master 2025-07-10 00:21:47 +00:00
c05718b2d7 Update Rust crate webauthn-rs to 0.5.2 2025-07-10 00:13:25 +00:00
0e83f64f24 Update Rust crate clap to 4.5.41 2025-07-10 00:13:16 +00:00
8a14521d6e Fix cargo clippy issues 2025-07-09 15:05:30 +02:00
e3e4e8280c Update Rust crate uuid to 1.17.0 2025-06-11 00:19:10 +00:00
03c538cc96 Update Rust crate clap to 4.5.40 2025-06-10 00:19:27 +00:00
77d3e49a94 Update Rust crate futures-util to 0.3.31 2025-06-09 00:19:16 +00:00
df40e5e6be Update Rust crate clap to 4.5.39 2025-06-07 00:18:47 +00:00
e5c6f0d372 Fix cargo clippy issues ()
Reviewed-on: 
2025-06-06 06:11:07 +00:00
46c561ca0b Update Rust crate actix-web to 4.11.0 2025-05-13 00:13:45 +00:00
4a3c1b62e0 Update Rust crate clap to 4.5.38 2025-05-12 00:13:25 +00:00
64e9844f65 Update Rust crate sha2 to 0.10.9 2025-05-01 00:16:56 +00:00
958a614f19 Update Rust crate chrono to 0.4.41 2025-04-30 00:16:57 +00:00
f869bbde07 Update Rust crate askama to 0.14.0 2025-04-24 00:17:03 +00:00
257c9c2b85 Update Rust crate clap to 4.5.37 2025-04-19 00:24:57 +00:00
96b3f35ad0 Update Rust crate rand to 0.9.1 2025-04-18 00:24:58 +00:00
658e6d498b Update Rust crate askama to 0.13.1 2025-04-16 00:24:41 +00:00
5241115f79 Update Rust crate webauthn-rs to 0.5.1 2025-04-15 00:24:36 +00:00
23e8f33069 Update Rust crate uuid to 1.16.0 2025-04-14 00:24:42 +00:00
77c3dc9e94 Update Rust crate url to 2.5.4 2025-04-13 00:24:38 +00:00
0a8fc3c805 Update Rust crate clap to 4.5.36 2025-04-12 00:24:42 +00:00
b820ca4b49 Update Rust crate totp_rfc6238 to 0.6.1 2025-04-11 00:24:41 +00:00
dc30d65d68 Update Rust crate serde_json to 1.0.140 2025-04-10 00:24:38 +00:00
dbea05552d Update Rust crate serde to 1.0.219 2025-04-09 00:24:42 +00:00
fc416752db Update Rust crate mime_guess to 2.0.5 2025-04-08 00:24:48 +00:00
99dd85c973 Update Rust crate mailchecker to 6.0.17 2025-04-07 00:30:22 +00:00
69cabe650e Update Rust crate lazy_static to 1.5.0 2025-04-06 00:30:35 +00:00
18e6ee16ae Update Rust crate clap to 4.5.35 2025-04-05 00:30:18 +00:00
1e5fc7acfe Update Rust crate lazy-regex to 3.4.1 2025-04-04 00:30:39 +00:00
e16e1a5a6a Update Rust crate jwt-simple to 0.12.12 2025-04-03 00:30:21 +00:00
80b9ffd4e0 Update Rust crate env_logger to 0.11.8 2025-04-02 00:30:28 +00:00
0a8f441ecb Update Rust crate include_dir to 0.7.4 2025-04-01 02:01:07 +00:00
ee00b31fd0 Update Rust crate chrono to 0.4.40 2025-03-31 20:46:52 +00:00
7b9ada9164 Update Rust crate base32 to 0.5.1 2025-03-31 00:30:31 +00:00
991f732f22 Update Rust crate actix-web to 4.10.2 2025-03-30 02:16:41 +00:00
e11a902c98 Update Rust crate actix-session to 0.10.1 2025-03-29 22:51:45 +00:00
dc0455c526 Update Rust crate actix to 0.13.5 2025-03-29 18:12:42 +00:00
4cefc7bb0a Update renovate.json 2025-03-29 17:33:18 +00:00
9bcdc84824 Update renovate.json 2025-03-29 13:02:15 +00:00
9c79c3d93c Cargo clippy on test code 2025-03-28 14:50:48 +01:00
bfe6c25f39 Cargo clippy 2025-03-28 14:42:04 +01:00
b77e7895b7 Rust Edition 2024 2025-03-28 14:40:35 +01:00
19f99cf9b9 Update all project dependencies 2025-03-28 14:37:47 +01:00
73988fe5ec Merge pull request 'Update Rust crate mailchecker to v6.0.17' () from renovate/mailchecker-6.x-lockfile into master
Reviewed-on: 
2025-03-28 13:01:09 +00:00
ad1ba1bf19 Merge pull request 'Update Rust crate uuid to v1.16.0' () from renovate/uuid-1.x-lockfile into master
Reviewed-on: 
2025-03-28 13:00:59 +00:00
cabb74b0a3 Merge pull request 'Update Rust crate clap to v4.5.33' () from renovate/clap-4.x-lockfile into master
Reviewed-on: 
2025-03-28 13:00:52 +00:00
2d7635668d Merge pull request 'Update Rust crate askama to 0.13.0' () from renovate/askama-0.x into master
Reviewed-on: 
2025-03-28 13:00:44 +00:00
eeb0594e80 Update Rust crate askama to 0.13.0 2025-03-28 00:22:19 +00:00
4f74e7cfc1 Update Rust crate clap to v4.5.33 2025-03-27 00:22:30 +00:00
10247deb2e Update Rust crate uuid to v1.16.0 2025-03-15 00:03:57 +00:00
286b982506 Update Rust crate mailchecker to v6.0.17 2025-03-13 00:03:58 +00:00
25f7221d0b Update all dependencies 2025-03-12 19:26:57 +01:00
c5b083f2df Merge pull request 'Update Rust crate actix-web to v4.10.2' () from renovate/actix-web-4.x-lockfile into master
Reviewed-on: 
2025-03-12 18:25:09 +00:00
2170d53bb4 Update Rust crate actix-web to v4.10.2 2025-03-12 00:17:31 +00:00
19a1fba460 Merge pull request 'Update Rust crate clap to v4.5.32' () from renovate/clap-4.x-lockfile into master
Reviewed-on: 
2025-03-11 13:13:04 +00:00
402bcbc4cd Merge pull request 'Update Rust crate env_logger to v0.11.7' () from renovate/env_logger-0.x-lockfile into master
Reviewed-on: 
2025-03-11 13:12:58 +00:00
19a7ae24cf Update Rust crate env_logger to v0.11.7 2025-03-11 00:17:37 +00:00
44de2d320a Update Rust crate clap to v4.5.32 2025-03-11 00:17:28 +00:00
b7310bd7ad Merge pull request 'Update Rust crate serde to v1.0.219' () from renovate/serde-1.x-lockfile into master
Reviewed-on: 
2025-03-10 18:04:11 +00:00
e9c14cf146 Update Rust crate serde to v1.0.219 2025-03-10 00:17:39 +00:00
ce07e8e0eb Merge pull request 'Update Rust crate light-openid to v1.0.3' () from renovate/light-openid-1.x-lockfile into master
Reviewed-on: 
2025-03-05 20:40:22 +00:00
5b58b70ca7 Update Rust crate light-openid to v1.0.3 2025-03-05 00:17:22 +00:00
1bbfe494d8 Updated all dependencies 2025-03-04 19:54:04 +01:00
80de6e224e Merge pull request 'Update Rust crate uuid to v1.15.1' () from renovate/uuid-1.x-lockfile into master
Reviewed-on: 
2025-03-04 18:48:09 +00:00
1bb417d02c Merge pull request 'Update Rust crate serde_json to v1.0.140' () from renovate/serde_json-1.x-lockfile into master
Reviewed-on: 
2025-03-04 18:48:04 +00:00
dd05ab563e Merge pull request 'Update Rust crate chrono to v0.4.40' () from renovate/chrono-0.x-lockfile into master
Reviewed-on: 
2025-03-04 18:47:57 +00:00
428a4f8f31 Update Rust crate serde_json to v1.0.140 2025-03-04 00:17:30 +00:00
89d0955137 Update Rust crate uuid to v1.15.1 2025-02-27 00:23:13 +00:00
ea34f867b0 Update Rust crate chrono to v0.4.40 2025-02-27 00:23:09 +00:00
cbda0db231 Merge pull request 'Update Rust crate clap to v4.5.31' () from renovate/clap-4.x-lockfile into master
Reviewed-on: 
2025-02-25 07:16:43 +00:00
91b468ee54 Update Rust crate clap to v4.5.31 2025-02-25 00:23:10 +00:00
c9d41f2517 Add CORS on token endpoint 2025-02-21 15:51:33 +01:00
1a1a41d5dc Disable client secret check when no secret is specified 2025-02-21 14:58:13 +01:00
d01311abf1 Can initiate code authentication without client secret 2025-02-21 14:49:45 +01:00
a73ad4bf41 Add CORS headers on OpenID configuration endpoint 2025-02-21 11:59:32 +01:00
4a248e84ac Merge pull request 'Update Rust crate uuid to v1.13.1' () from renovate/uuid-1.x-lockfile into master
Reviewed-on: 
2025-02-21 10:53:37 +00:00
e650fe0c29 Merge pull request 'Update Rust crate mailchecker to v6.0.16' () from renovate/mailchecker-6.x-lockfile into master
Reviewed-on: 
2025-02-21 10:53:29 +00:00
473abb2d38 Merge pull request 'Update Rust crate clap to v4.5.29' () from renovate/clap-4.x-lockfile into master
Reviewed-on: 
2025-02-21 10:53:23 +00:00
1b743c86bf Merge pull request 'Update Rust crate serde to v1.0.218' () from renovate/serde-1.x-lockfile into master
Reviewed-on: 
2025-02-21 10:53:16 +00:00
8c25e2aa4c Merge pull request 'Update Rust crate serde_json to v1.0.139' () from renovate/serde_json-1.x-lockfile into master
Reviewed-on: 
2025-02-21 10:53:07 +00:00
f7e4eb955c Update Rust crate serde_json to v1.0.139 2025-02-21 00:05:04 +00:00
7d521ef040 Update Rust crate serde to v1.0.218 2025-02-21 00:05:01 +00:00
c59e7b96db Update Rust crate mailchecker to v6.0.16 2025-02-18 00:04:45 +00:00
a0d204ad09 Update Rust crate clap to v4.5.29 2025-02-12 00:04:41 +00:00
a06be2e889 Update Rust crate uuid to v1.13.1 2025-02-06 00:08:38 +00:00
42862aea7f Merge pull request 'Update Rust crate clap to v4.5.28' () from renovate/clap-4.x-lockfile into master
Reviewed-on: 
2025-02-04 07:04:12 +00:00
8173ac5bc1 Update Rust crate clap to v4.5.28 2025-02-04 00:08:27 +00:00
79a00ff7ad Merge pull request 'Update Rust crate rand to 0.9.0' () from renovate/rand-0.x into master
Reviewed-on: 
2025-02-03 20:00:33 +00:00
f2e4d82f87 Fix rand breaking changes 2025-02-03 20:57:49 +01:00
022073f26a Update Rust crate rand to 0.9.0 2025-02-01 00:22:15 +00:00
c22fcdab74 Merge pull request 'Update Rust crate bcrypt to 0.17.0' () from renovate/bcrypt-0.x into master
Reviewed-on: 
2025-01-31 07:10:50 +00:00
672267d521 Merge pull request 'Update Rust crate serde_json to v1.0.138' () from renovate/serde_json-1.x-lockfile into master
Reviewed-on: 
2025-01-31 07:10:41 +00:00
c26a3af253 Update Rust crate bcrypt to 0.17.0 2025-01-31 00:22:28 +00:00
84d69de09b Update Rust crate serde_json to v1.0.138 2025-01-30 00:22:18 +00:00
76faa33c4e Update Rust crate uuid to v1.12.1 2025-01-22 00:22:26 +00:00
fb0ebde748 Update Rust crate clap to v4.5.27 2025-01-21 00:22:26 +00:00
e0f33c133b Update Rust crate serde_json to v1.0.137 2025-01-20 00:22:30 +00:00
8a0ef75295 Update Rust crate uuid to v1.12.0 2025-01-15 00:56:58 +00:00
a4f73db82e Update Rust crate log to v0.4.25 2025-01-15 00:30:18 +00:00
31ad52607f Update Rust crate uuid to v1.11.1 2025-01-11 00:30:21 +00:00
a201f175a2 Update Rust crate log to v0.4.24 2025-01-11 00:19:08 +00:00
f5eaecc189 Update Rust crate clap to v4.5.26 2025-01-10 00:19:07 +00:00
6c18a58c43 Update Rust crate serde_json to v1.0.135 2025-01-08 00:33:32 +00:00
677b4221eb Update Rust crate clap to v4.5.24 2025-01-08 00:24:08 +00:00
ae92f8f405 Update Rust crate mailchecker to v6.0.15 2025-01-04 00:20:22 +00:00
16083a7624 Update Rust crate lazy-regex to v3.4.1 2024-12-28 00:31:42 +00:00
09da003f35 Update Rust crate serde to v1.0.217 2024-12-28 00:20:30 +00:00
f5dde48e9f Update Rust crate serde_json to v1.0.134 2024-12-22 00:20:15 +00:00
c59c735291 Update Rust crate webauthn-rs to v0.5.1 2024-12-21 00:29:10 +00:00
c2dc140002 Update Rust crate env_logger to v0.11.6 2024-12-21 00:20:19 +00:00
d26c9ead7d Update Rust crate mailchecker to v6.0.14 2024-12-16 00:02:50 +00:00
5da918cc86 Merge pull request 'Update Rust crate serde to v1.0.216' () from renovate/serde-1.x-lockfile into master
Reviewed-on: 
2024-12-13 19:31:45 +00:00
f7d1115b5a Update Rust crate serde to v1.0.216 2024-12-12 00:02:56 +00:00
6d5f65559f Update Rust crate jwt-simple to v0.12.11 2024-12-10 00:32:26 +00:00
872fa25d77 Update Rust crate chrono to v0.4.39 2024-12-10 00:19:09 +00:00
6901803ae8 Update Rust crate clap to v4.5.23 2024-12-06 00:19:15 +00:00
2f8b02a866 Update Rust crate url to v2.5.4 2024-12-05 00:19:17 +00:00
6ce1b20ad0 Update Rust crate serde to v1.0.215 2024-12-04 00:30:25 +00:00
de3896b703 Update Rust crate clap to v4.5.22 2024-12-04 00:19:20 +00:00
50 changed files with 1675 additions and 1144 deletions

@@ -4,10 +4,57 @@ type: docker
name: default name: default
steps: steps:
- name: cargo_check # Code quality
- name: code_quality
image: rust image: rust
volumes:
- name: rust_registry
path: /usr/local/cargo/registry
commands: commands:
- rustup component add clippy - rustup component add clippy
- cargo clippy -- -D warnings - cargo clippy -- -D warnings
- cargo test - cargo test
# Build source code
- name: compile
image: rust
depends_on:
- code_quality
when:
event:
- tag
volumes:
- name: rust_registry
path: /usr/local/cargo/registry
- name: releases
path: /tmp/releases
commands:
- cargo build --release
- ls -lah target/release/basic-oidc
- cp target/release/basic-oidc /tmp/releases
# Auto-release to Gitea
- name: gitea_release
image: plugins/gitea-release
depends_on:
- compile
when:
event:
- tag
volumes:
- name: releases
path: /tmp/releases
environment:
PLUGIN_API_KEY:
from_secret: GITEA_API_KEY # needs permission write:repository
settings:
base_url: https://gitea.communiquons.org
files:
- /tmp/releases/basic-oidc
checksum: sha512
volumes:
- name: rust_registry
temp: { }
- name: releases
temp: {}

2
.gitignore vendored

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

1471
Cargo.lock generated

File diff suppressed because it is too large Load Diff

@@ -1,42 +1,41 @@
[package] [package]
name = "basic-oidc" name = "basic-oidc"
version = "0.1.4" version = "0.1.5"
edition = "2021" edition = "2024"
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
[dependencies] [dependencies]
actix = "0.13.3" actix = "0.13.5"
actix-identity = "0.8.0" actix-identity = "0.9.0"
actix-web = "4.5.1" actix-web = "4.11.0"
actix-session = { version = "0.10.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.17", features = ["derive", "env"] } clap = { version = "4.5.51", features = ["derive", "env"] }
include_dir = "0.7.3" include_dir = "0.7.4"
log = "0.4.21" log = "0.4.28"
serde_json = "1.0.128" serde_json = "1.0.145"
serde_yaml = "0.9.34" serde_yaml = "0.9.34"
env_logger = "0.11.3" env_logger = "0.11.8"
serde = { version = "1.0.210", features = ["derive"] } serde = { version = "1.0.228", features = ["derive"] }
bcrypt = "0.16.0" bcrypt = "0.17.1"
uuid = { version = "1.8.0", features = ["v4"] } uuid = { version = "1.18.1", features = ["v4"] }
mime_guess = "2.0.4" mime_guess = "2.0.5"
askama = "0.12.1" askama = "0.14.0"
futures-util = "0.3.30"
urlencoding = "2.1.3" urlencoding = "2.1.3"
rand = "0.8.5" rand = "0.9.2"
base64 = "0.22.1" base64 = "0.22.1"
jwt-simple = { version = "0.12.10", 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.8" sha2 = "0.10.9"
lazy-regex = "3.3.0" lazy-regex = "3.4.2"
totp_rfc6238 = "0.6.0" totp_rfc6238 = "0.6.1"
base32 = "0.5.0" base32 = "0.5.1"
qrcode-generator = "5.0.0" qrcode-generator = "5.0.0"
webauthn-rs = { version = "0.5.0", features = ["danger-allow-state-serialisation"] } webauthn-rs = { version = "0.5.3", features = ["danger-allow-state-serialisation"] }
url = "2.5.0" url = "2.5.7"
light-openid = { version = "1.0.2", features = ["crypto-wrapper"] } light-openid = { version = "1.0.4", features = ["crypto-wrapper"] }
bincode = "2.0.0-rc.3" bincode = "2.0.1"
chrono = "0.4.38" chrono = "0.4.42"
lazy_static = "1.4.0" lazy_static = "1.5.0"
mailchecker = "6.0.8" mailchecker = "6.0.19"

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

@@ -20,4 +20,8 @@ body {
.form-control::placeholder { .form-control::placeholder {
color: #555; color: #555;
}
.table-break-works td {
word-break: break-all;
} }

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

(image error) Size: 382 B

@@ -1,9 +1,3 @@
{ {
"$schema": "https://docs.renovatebot.com/renovate-schema.json", "extends": ["local>renovate/presets"]
"packageRules": [ }
{
"matchUpdateTypes": ["major", "minor", "patch"],
"automerge": true
}
]
}

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

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

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

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

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

@@ -1,5 +1,5 @@
use std::collections::hash_map::Entry;
use std::collections::HashMap; use std::collections::HashMap;
use std::collections::hash_map::Entry;
use std::net::IpAddr; use std::net::IpAddr;
use actix::{Actor, AsyncContext, Context, Handler, Message}; use actix::{Actor, AsyncContext, Context, Handler, Message};

@@ -8,8 +8,8 @@ use crate::constants::{
OIDC_STATES_CLEANUP_INTERVAL, OIDC_STATES_CLEANUP_INTERVAL,
}; };
use actix::{Actor, AsyncContext, Context, Handler, Message}; use actix::{Actor, AsyncContext, Context, Handler, Message};
use std::collections::hash_map::Entry;
use std::collections::HashMap; use std::collections::HashMap;
use std::collections::hash_map::Entry;
use std::net::IpAddr; use std::net::IpAddr;
use crate::data::login_redirect::LoginRedirect; use crate::data::login_redirect::LoginRedirect;
@@ -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>,
@@ -151,7 +155,7 @@ impl Handler<LocalLoginRequest> for UsersActor {
fn handle(&mut self, msg: LocalLoginRequest, _ctx: &mut Self::Context) -> Self::Result { fn handle(&mut self, msg: LocalLoginRequest, _ctx: &mut Self::Context) -> Self::Result {
match self.manager.find_by_username_or_email(&msg.login) { match self.manager.find_by_username_or_email(&msg.login) {
Err(e) => { Err(e) => {
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) => MessageResult(LoginResult::AccountNotFound),
@@ -184,10 +188,89 @@ impl Handler<ProviderLoginRequest> for UsersActor {
fn handle(&mut self, msg: ProviderLoginRequest, _ctx: &mut Self::Context) -> Self::Result { fn handle(&mut self, msg: ProviderLoginRequest, _ctx: &mut Self::Context) -> Self::Result {
match self.manager.find_by_email(&msg.email) { match self.manager.find_by_email(&msg.email) {
Err(e) => { Err(e) => {
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);
@@ -210,7 +293,7 @@ impl Handler<CreateAccount> for UsersActor {
match self.manager.create_user_account(msg.0) { match self.manager.create_user_account(msg.0) {
Ok(id) => Some(id), Ok(id) => Some(id),
Err(e) => { Err(e) => {
log::error!("Failed to create user account! {}", e); log::error!("Failed to create user account! {e}");
None None
} }
} }
@@ -227,7 +310,7 @@ impl Handler<ChangePasswordRequest> for UsersActor {
{ {
Ok(_) => true, Ok(_) => true,
Err(e) => { Err(e) => {
log::error!("Failed to change user password! {:?}", e); log::error!("Failed to change user password! {e:?}");
false false
} }
} }
@@ -241,7 +324,7 @@ impl Handler<Add2FAFactor> for UsersActor {
match self.manager.add_2fa_factor(&msg.0, msg.1) { match self.manager.add_2fa_factor(&msg.0, msg.1) {
Ok(_) => true, Ok(_) => true,
Err(e) => { Err(e) => {
log::error!("Failed to add 2FA factor! {}", e); log::error!("Failed to add 2FA factor! {e}");
false false
} }
} }
@@ -255,7 +338,7 @@ impl Handler<Remove2FAFactor> for UsersActor {
match self.manager.remove_2fa_factor(&msg.0, msg.1) { match self.manager.remove_2fa_factor(&msg.0, msg.1) {
Ok(_) => true, Ok(_) => true,
Err(e) => { Err(e) => {
log::error!("Failed to remove 2FA factor! {}", e); log::error!("Failed to remove 2FA factor! {e}");
false false
} }
} }
@@ -272,7 +355,7 @@ impl Handler<AddSuccessful2FALogin> for UsersActor {
{ {
Ok(_) => true, Ok(_) => true,
Err(e) => { Err(e) => {
log::error!("Failed to save successful 2FA authentication! {}", e); log::error!("Failed to save successful 2FA authentication! {e}");
false false
} }
} }
@@ -309,10 +392,7 @@ impl Handler<SetAuthorizedAuthenticationSources> for UsersActor {
{ {
Ok(_) => true, Ok(_) => true,
Err(e) => { Err(e) => {
log::error!( log::error!("Failed to set authorized authentication sources for user! {e}");
"Failed to set authorized authentication sources for user! {}",
e
);
false false
} }
} }
@@ -325,7 +405,7 @@ impl Handler<SetGrantedClients> for UsersActor {
match self.manager.set_granted_2fa_clients(&msg.0, msg.1) { match self.manager.set_granted_2fa_clients(&msg.0, msg.1) {
Ok(_) => true, Ok(_) => true,
Err(e) => { Err(e) => {
log::error!("Failed to set granted 2FA clients! {}", e); log::error!("Failed to set granted 2FA clients! {e}");
false false
} }
} }
@@ -339,7 +419,7 @@ impl Handler<GetUserRequest> for UsersActor {
MessageResult(GetUserResult(match self.manager.find_by_user_id(&msg.0) { MessageResult(GetUserResult(match self.manager.find_by_user_id(&msg.0) {
Ok(r) => r, Ok(r) => r,
Err(e) => { Err(e) => {
log::error!("Failed to find user by id! {}", e); log::error!("Failed to find user by id! {e}");
None None
} }
})) }))
@@ -353,7 +433,7 @@ impl Handler<VerifyUserPasswordRequest> for UsersActor {
self.manager self.manager
.verify_user_password(&msg.0, &msg.1) .verify_user_password(&msg.0, &msg.1)
.unwrap_or_else(|e| { .unwrap_or_else(|e| {
log::error!("Failed to verify user password! {}", e); log::error!("Failed to verify user password! {e}");
false false
}) })
} }
@@ -367,7 +447,7 @@ impl Handler<FindUserByUsername> for UsersActor {
self.manager self.manager
.find_by_username_or_email(&msg.0) .find_by_username_or_email(&msg.0)
.unwrap_or_else(|e| { .unwrap_or_else(|e| {
log::error!("Failed to find user by username or email! {}", e); log::error!("Failed to find user by username or email! {e}");
None None
}), }),
)) ))
@@ -381,7 +461,7 @@ impl Handler<GetAllUsers> for UsersActor {
match self.manager.get_entire_users_list() { match self.manager.get_entire_users_list() {
Ok(r) => r, Ok(r) => r,
Err(e) => { Err(e) => {
log::error!("Failed to get entire users list! {}", e); log::error!("Failed to get entire users list! {e}");
vec![] vec![]
} }
} }
@@ -395,7 +475,7 @@ impl Handler<UpdateUserSettings> for UsersActor {
match self.manager.set_general_user_settings(msg.0) { match self.manager.set_general_user_settings(msg.0) {
Ok(_) => true, Ok(_) => true,
Err(e) => { Err(e) => {
log::error!("Failed to update general user information! {:?}", e); log::error!("Failed to update general user information! {e:?}");
false false
} }
} }
@@ -409,7 +489,7 @@ impl Handler<DeleteUserRequest> for UsersActor {
match self.manager.delete_account(&msg.0) { match self.manager.delete_account(&msg.0) {
Ok(_) => true, Ok(_) => true,
Err(e) => { Err(e) => {
log::error!("Failed to delete user account! {}", e); log::error!("Failed to delete user account! {e}");
false false
} }
} }

@@ -1,6 +1,6 @@
use crate::actors::users_actor; use crate::actors::users_actor;
use actix::Addr; use actix::Addr;
use actix_web::{web, HttpResponse, Responder}; use actix_web::{HttpResponse, Responder, web};
use crate::actors::users_actor::{DeleteUserRequest, FindUserByUsername, UsersActor}; use crate::actors::users_actor::{DeleteUserRequest, FindUserByUsername, UsersActor};
use crate::data::action_logger::{Action, ActionLogger}; use crate::data::action_logger::{Action, ActionLogger};
@@ -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()

@@ -2,7 +2,7 @@ use std::ops::Deref;
use std::sync::Arc; use std::sync::Arc;
use actix::Addr; use actix::Addr;
use actix_web::{web, HttpResponse, Responder}; use actix_web::{HttpResponse, Responder, web};
use askama::Template; use askama::Template;
use crate::actors::users_actor; use crate::actors::users_actor;
@@ -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())
} }
}); });

@@ -1,7 +1,7 @@
use std::path::Path; use std::path::Path;
use actix_web::{web, HttpResponse}; use actix_web::{HttpResponse, web};
use include_dir::{include_dir, Dir}; use include_dir::{Dir, include_dir};
/// Assets directory /// Assets directory
static ASSETS_DIR: Dir = include_dir!("$CARGO_MANIFEST_DIR/assets"); static ASSETS_DIR: Dir = include_dir!("$CARGO_MANIFEST_DIR/assets");

@@ -4,7 +4,7 @@ use crate::data::action_logger::{Action, ActionLogger};
use actix::Addr; use actix::Addr;
use actix_identity::Identity; use actix_identity::Identity;
use actix_remote_ip::RemoteIP; use actix_remote_ip::RemoteIP;
use actix_web::{web, HttpRequest, HttpResponse, Responder}; use actix_web::{HttpRequest, HttpResponse, Responder, web};
use webauthn_rs::prelude::PublicKeyCredential; use webauthn_rs::prelude::PublicKeyCredential;
use crate::data::session_identity::{SessionIdentity, SessionStatus}; use crate::data::session_identity::{SessionIdentity, SessionStatus};
@@ -47,7 +47,7 @@ pub async fn auth_webauthn(
HttpResponse::Ok().body("You are authenticated!") HttpResponse::Ok().body("You are authenticated!")
} }
Err(e) => { Err(e) => {
log::error!("Failed to authenticate user using webauthn! {:?}", e); log::error!("Failed to authenticate user using webauthn! {e:?}");
logger.log(Action::LoginWebauthnAttempt { logger.log(Action::LoginWebauthnAttempt {
success: false, success: false,
user_id, user_id,

@@ -1,7 +1,7 @@
use actix::Addr; use actix::Addr;
use actix_identity::Identity; use actix_identity::Identity;
use actix_remote_ip::RemoteIP; use actix_remote_ip::RemoteIP;
use actix_web::{web, HttpRequest, HttpResponse, Responder}; use actix_web::{HttpRequest, HttpResponse, Responder, web};
use askama::Template; use askama::Template;
use std::sync::Arc; use std::sync::Arc;
@@ -13,54 +13,70 @@ 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::{get_2fa_url, LoginRedirect}; use crate::data::login_redirect::{LoginRedirect, get_2fa_url};
use crate::data::provider::{Provider, ProvidersManager}; use crate::data::provider::{Provider, ProvidersManager};
use crate::data::session_identity::{SessionIdentity, SessionStatus}; use crate::data::session_identity::{SessionIdentity, SessionStatus};
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::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,13 +196,16 @@ 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());
} }
LoginResult::LocalAuthForbidden => { LoginResult::LocalAuthForbidden => {
log::warn!("Failed login for username {} : attempted to use local auth, but it is forbidden", &login); log::warn!(
logger.log(Action::TryLocalLoginFromUnauthorizedAccount(&login)); "Failed login for username {} : attempted to use local auth, but it is forbidden",
&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());
} }
@@ -187,13 +214,8 @@ pub async fn login_route(
} }
c => { c => {
log::warn!( log::warn!("Failed login for ip {remote_ip:?} / username {login}: {c:?}");
"Failed login for ip {:?} / username {}: {:?}", logger.log(Action::FailedLoginWithBadCredentials { login: &login });
remote_ip,
login,
c
);
logger.log(Action::FailedLoginWithBadCredentials(&login));
danger = Some("Login failed.".to_string()); danger = Some("Login failed.".to_string());
bruteforce bruteforce
@@ -205,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 {
@@ -212,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()
@@ -274,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());
} }
} }
@@ -285,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,
} }
@@ -335,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,
} }
@@ -397,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 {
@@ -414,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());
} }
@@ -426,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()
@@ -471,7 +495,7 @@ pub async fn login_with_webauthn(
let challenge = match manager.start_authentication(&user.uid, &pub_keys) { let challenge = match manager.start_authentication(&user.uid, &pub_keys) {
Ok(c) => c, Ok(c) => c,
Err(e) => { Err(e) => {
log::error!("Failed to generate webauthn challenge! {:?}", e); log::error!("Failed to generate webauthn challenge! {e:?}");
return HttpResponse::InternalServerError().body(build_fatal_error_page( return HttpResponse::InternalServerError().body(build_fatal_error_page(
"Failed to generate webauthn challenge", "Failed to generate webauthn challenge",
)); ));
@@ -481,7 +505,7 @@ pub async fn login_with_webauthn(
let challenge_json = match serde_json::to_string(&challenge.login_challenge) { let challenge_json = match serde_json::to_string(&challenge.login_challenge) {
Ok(r) => r, Ok(r) => r,
Err(e) => { Err(e) => {
log::error!("Failed to serialize challenge! {:?}", e); log::error!("Failed to serialize challenge! {e:?}");
return HttpResponse::InternalServerError().body("Failed to serialize challenge!"); return HttpResponse::InternalServerError().body("Failed to serialize challenge!");
} }
}; };
@@ -489,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(),

@@ -4,9 +4,9 @@ use std::sync::Arc;
use actix::Addr; use actix::Addr;
use actix_identity::Identity; use actix_identity::Identity;
use actix_web::error::ErrorUnauthorized; use actix_web::error::ErrorUnauthorized;
use actix_web::{web, HttpRequest, HttpResponse, Responder}; use actix_web::{HttpRequest, HttpResponse, Responder, web};
use base64::engine::general_purpose::STANDARD as BASE64_STANDARD;
use base64::Engine as _; use base64::Engine as _;
use base64::engine::general_purpose::STANDARD as BASE64_STANDARD;
use light_openid::primitives::{OpenIDConfig, OpenIDTokenResponse, OpenIDUserInfo}; use light_openid::primitives::{OpenIDConfig, OpenIDTokenResponse, OpenIDUserInfo};
use crate::actors::openid_sessions_actor::{OpenIDSessionsActor, Session, SessionID}; use crate::actors::openid_sessions_actor::{OpenIDSessionsActor, Session, SessionID};
@@ -16,12 +16,12 @@ use crate::constants::*;
use crate::controllers::base_controller::{build_fatal_error_page, redirect_user}; use crate::controllers::base_controller::{build_fatal_error_page, redirect_user};
use crate::data::action_logger::{Action, ActionLogger}; use crate::data::action_logger::{Action, ActionLogger};
use crate::data::app_config::AppConfig; use crate::data::app_config::AppConfig;
use crate::data::client::{AdditionalClaims, AuthenticationFlow, ClientID, ClientManager}; use crate::data::client::{AdditionalClaims, ClientID, ClientManager};
use crate::data::code_challenge::CodeChallenge; use crate::data::code_challenge::CodeChallenge;
use crate::data::current_user::CurrentUser; use crate::data::current_user::CurrentUser;
use crate::data::id_token::IdToken; use crate::data::id_token::IdToken;
use crate::data::jwt_signer::{JWTSigner, JsonWebKey}; use crate::data::jwt_signer::{JWTSigner, JsonWebKey};
use crate::data::login_redirect::{get_2fa_url, LoginRedirect}; 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;
@@ -50,37 +50,39 @@ pub async fn get_configuration(req: HttpRequest) -> impl Responder {
host host
); );
HttpResponse::Ok().json(OpenIDConfig { HttpResponse::Ok()
issuer: AppConfig::get().website_origin.clone(), .insert_header(("access-control-allow-origin", "*"))
authorization_endpoint: AppConfig::get().full_url(AUTHORIZE_URI), .json(OpenIDConfig {
token_endpoint: curr_origin.clone() + TOKEN_URI, issuer: AppConfig::get().website_origin.clone(),
userinfo_endpoint: Some(curr_origin.clone() + USERINFO_URI), authorization_endpoint: AppConfig::get().full_url(AUTHORIZE_URI),
jwks_uri: curr_origin + CERT_URI, token_endpoint: curr_origin.clone() + TOKEN_URI,
scopes_supported: Some(vec![ userinfo_endpoint: Some(curr_origin.clone() + USERINFO_URI),
"openid".to_string(), jwks_uri: curr_origin + CERT_URI,
"profile".to_string(), scopes_supported: Some(vec![
"email".to_string(), "openid".to_string(),
]), "profile".to_string(),
response_types_supported: vec![ "email".to_string(),
"code".to_string(), ]),
"id_token".to_string(), response_types_supported: vec![
"token id_token".to_string(), "code".to_string(),
], "id_token".to_string(),
subject_types_supported: vec!["public".to_string()], "token id_token".to_string(),
id_token_signing_alg_values_supported: vec!["RS256".to_string()], ],
token_endpoint_auth_methods_supported: Some(vec![ subject_types_supported: vec!["public".to_string()],
"client_secret_post".to_string(), id_token_signing_alg_values_supported: vec!["RS256".to_string()],
"client_secret_basic".to_string(), token_endpoint_auth_methods_supported: Some(vec![
]), "client_secret_post".to_string(),
claims_supported: Some(vec![ "client_secret_basic".to_string(),
"sub".to_string(), ]),
"name".to_string(), claims_supported: Some(vec![
"given_name".to_string(), "sub".to_string(),
"family_name".to_string(), "name".to_string(),
"email".to_string(), "given_name".to_string(),
]), "family_name".to_string(),
code_challenge_methods_supported: Some(vec!["plain".to_string(), "S256".to_string()]), "email".to_string(),
}) ]),
code_challenge_methods_supported: Some(vec!["plain".to_string(), "S256".to_string()]),
})
} }
#[derive(serde::Deserialize, Debug)] #[derive(serde::Deserialize, Debug)]
@@ -109,12 +111,7 @@ pub struct AuthorizeQuery {
} }
fn error_redirect(query: &AuthorizeQuery, error: &str, description: &str) -> HttpResponse { fn error_redirect(query: &AuthorizeQuery, error: &str, description: &str) -> HttpResponse {
log::warn!( log::warn!("Failed to process sign in request ({error} => {description}): {query:?}");
"Failed to process sign in request ({} => {}): {:?}",
error,
description,
query
);
HttpResponse::Found() HttpResponse::Found()
.append_header(( .append_header((
"Location", "Location",
@@ -218,8 +215,8 @@ pub async fn authorize(
)); ));
} }
match (client.auth_flow(), query.response_type.as_str()) { match (client.has_secret(), query.response_type.as_str()) {
(AuthenticationFlow::AuthorizationCode, "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)), session_id: SessionID(rand_str(OPEN_ID_SESSION_LEN)),
@@ -241,8 +238,8 @@ pub async fn authorize(
.await .await
.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((
@@ -261,7 +258,8 @@ pub async fn authorize(
.finish()) .finish())
} }
(AuthenticationFlow::Implicit, "id_token") => { // id_token is available only if user has no secret configured
(false, "id_token") => {
let id_token = IdToken { let id_token = IdToken {
issuer: AppConfig::get().website_origin.to_string(), issuer: AppConfig::get().website_origin.to_string(),
subject_identifier: user.uid.0.clone(), subject_identifier: user.uid.0.clone(),
@@ -275,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((
@@ -293,11 +291,11 @@ pub async fn authorize(
.finish()) .finish())
} }
(flow, code) => { (secret, code) => {
log::warn!( log::warn!(
"For client {:?}, configured with flow {:?}, made request with code {}", "For client {:?}, configured with secret {:?}, made request with code {}",
client.id, client.id,
flow, secret,
code code
); );
Ok(error_redirect( Ok(error_redirect(
@@ -316,12 +314,7 @@ struct ErrorResponse {
} }
pub fn error_response<D: Debug>(query: &D, error: &str, description: &str) -> HttpResponse { pub fn error_response<D: Debug>(query: &D, error: &str, description: &str) -> HttpResponse {
log::warn!( log::warn!("request failed: {error} - {description} => '{query:#?}'");
"request failed: {} - {} => '{:#?}'",
error,
description,
query
);
HttpResponse::BadRequest().json(ErrorResponse { HttpResponse::BadRequest().json(ErrorResponse {
error: error.to_string(), error: error.to_string(),
error_description: description.to_string(), error_description: description.to_string(),
@@ -366,9 +359,7 @@ pub async fn token(
let (client_id, client_secret) = let (client_id, client_secret) =
match (&query.client_id, &query.client_secret, authorization_header) { match (&query.client_id, &query.client_secret, authorization_header) {
// post authentication // post authentication
(Some(client_id), Some(client_secret), None) => { (Some(client_id), client_secret, None) => (client_id.clone(), client_secret.clone()),
(client_id.clone(), client_secret.to_string())
}
// Basic authentication // Basic authentication
(_, None, Some(v)) => { (_, None, Some(v)) => {
@@ -388,7 +379,7 @@ pub async fn token(
let decode = String::from_utf8_lossy(&match BASE64_STANDARD.decode(token) { let decode = String::from_utf8_lossy(&match BASE64_STANDARD.decode(token) {
Ok(d) => d, Ok(d) => d,
Err(e) => { Err(e) => {
log::error!("Failed to decode authorization header: {:?}", e); log::error!("Failed to decode authorization header: {e:?}");
return Ok(error_response( return Ok(error_response(
&query, &query,
"invalid_request", "invalid_request",
@@ -399,8 +390,8 @@ pub async fn token(
.to_string(); .to_string();
match decode.split_once(':') { match decode.split_once(':') {
None => (ClientID(decode), "".to_string()), None => (ClientID(decode), None),
Some((id, secret)) => (ClientID(id.to_string()), secret.to_string()), Some((id, secret)) => (ClientID(id.to_string()), Some(secret.to_string())),
} }
} }
@@ -418,7 +409,7 @@ pub async fn token(
.ok_or_else(|| ErrorUnauthorized("Client not found"))?; .ok_or_else(|| ErrorUnauthorized("Client not found"))?;
// Retrieving token requires the client to have a defined secret // Retrieving token requires the client to have a defined secret
if client.secret != Some(client_secret) { if client.secret != client_secret {
return Ok(error_response( return Ok(error_response(
&query, &query,
"invalid_request", "invalid_request",
@@ -608,8 +599,9 @@ pub async fn token(
}; };
Ok(HttpResponse::Ok() Ok(HttpResponse::Ok()
.append_header(("Cache-Control", "no-store")) .insert_header(("Cache-Control", "no-store"))
.append_header(("Pragam", "no-cache")) .insert_header(("Pragma", "no-cache"))
.insert_header(("access-control-allow-origin", "*"))
.json(token_response)) .json(token_response))
} }

@@ -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::{web, HttpRequest, HttpResponse, Responder};
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,
} }
@@ -96,14 +93,14 @@ pub async fn start_login(
let config = match ProviderConfigurationHelper::get_configuration(&provider).await { let config = match ProviderConfigurationHelper::get_configuration(&provider).await {
Ok(c) => c, Ok(c) => c,
Err(e) => { Err(e) => {
log::error!("Failed to load provider configuration! {}", e); log::error!("Failed to load provider configuration! {e}");
return HttpResponse::InternalServerError().body(build_fatal_error_page( return HttpResponse::InternalServerError().body(build_fatal_error_page(
"Failed to load provider configuration!", "Failed to load provider configuration!",
)); ));
} }
}; };
log::debug!("Provider configuration: {:?}", config); log::debug!("Provider configuration: {config:?}");
let url = config.auth_url(&provider, &state); let url = config.auth_url(&provider, &state);
log::debug!("Redirect user on {url} for authentication",); log::debug!("Redirect user on {url} for authentication",);
@@ -210,7 +207,7 @@ pub async fn finish_login(
let provider_config = match ProviderConfigurationHelper::get_configuration(&provider).await { let provider_config = match ProviderConfigurationHelper::get_configuration(&provider).await {
Ok(c) => c, Ok(c) => c,
Err(e) => { Err(e) => {
log::error!("Failed to load provider configuration! {}", e); log::error!("Failed to load provider configuration! {e}");
return HttpResponse::InternalServerError().body(build_fatal_error_page( return HttpResponse::InternalServerError().body(build_fatal_error_page(
"Failed to load provider configuration!", "Failed to load provider configuration!",
)); ));
@@ -222,7 +219,7 @@ pub async fn finish_login(
let token = match token { let token = match token {
Ok(t) => t, Ok(t) => t,
Err(e) => { Err(e) => {
log::error!("Failed to retrieve login token! {:?}", e); log::error!("Failed to retrieve login token! {e:?}");
bruteforce bruteforce
.send(bruteforce_actor::RecordFailedAttempt { .send(bruteforce_actor::RecordFailedAttempt {
@@ -247,7 +244,7 @@ pub async fn finish_login(
let user_info = match provider_config.get_userinfo(&token).await { let user_info = match provider_config.get_userinfo(&token).await {
Ok(info) => info, Ok(info) => info,
Err(e) => { Err(e) => {
log::error!("Failed to retrieve user information! {:?}", e); log::error!("Failed to retrieve user information! {e:?}");
logger.log(Action::ProviderFailedGetUserInfo { logger.log(Action::ProviderFailedGetUserInfo {
provider: &provider, provider: &provider,
@@ -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
}; };

@@ -1,6 +1,6 @@
use actix::Addr; use actix::Addr;
use actix_remote_ip::RemoteIP; use actix_remote_ip::RemoteIP;
use actix_web::{web, HttpResponse, Responder}; use actix_web::{HttpResponse, Responder, web};
use askama::Template; use askama::Template;
use crate::actors::bruteforce_actor::BruteForceActor; use crate::actors::bruteforce_actor::BruteForceActor;
@@ -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::{web, HttpResponse, Responder}; 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))
@@ -94,17 +95,19 @@ pub async fn save_webauthn_factor(
let key = match manager.finish_registration(&user, &form.0.opaque_state, form.0.credential) { let key = match manager.finish_registration(&user, &form.0.opaque_state, form.0.credential) {
Ok(k) => k, Ok(k) => k,
Err(e) => { Err(e) => {
log::error!("Failed to register security key! {:?}", e); log::error!("Failed to register security key! {e:?}");
return HttpResponse::InternalServerError().body("Failed to register key!"); return HttpResponse::InternalServerError().body("Failed to register key!");
} }
}; };
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))

@@ -2,8 +2,8 @@ use std::ops::Deref;
use actix_web::{HttpResponse, Responder}; use actix_web::{HttpResponse, Responder};
use askama::Template; use askama::Template;
use base64::engine::general_purpose::STANDARD as BASE64_STANDARD;
use base64::Engine as _; use base64::Engine as _;
use base64::engine::general_purpose::STANDARD as BASE64_STANDARD;
use qrcode_generator::QrCodeEcc; use qrcode_generator::QrCodeEcc;
use crate::constants::MAX_SECOND_FACTOR_NAME_LEN; use crate::constants::MAX_SECOND_FACTOR_NAME_LEN;
@@ -68,7 +68,7 @@ pub async fn add_totp_factor_route(_critical: CriticalRoute, user: CurrentUser)
let qr_code = match qr_code { let qr_code = match qr_code {
Ok(q) => q, Ok(q) => q,
Err(e) => { Err(e) => {
log::error!("Failed to generate QrCode! {:?}", e); log::error!("Failed to generate QrCode! {e:?}");
return HttpResponse::InternalServerError().body("Failed to generate QrCode!"); return HttpResponse::InternalServerError().body("Failed to generate QrCode!");
} }
}; };
@@ -95,7 +95,7 @@ pub async fn add_webauthn_factor_route(
let registration_request = match manager.start_register(&user) { let registration_request = match manager.start_register(&user) {
Ok(r) => r, Ok(r) => r,
Err(e) => { Err(e) => {
log::error!("Failed to request new key! {:?}", e); log::error!("Failed to request new key! {e:?}");
return HttpResponse::InternalServerError() return HttpResponse::InternalServerError()
.body("Failed to generate request for registration!"); .body("Failed to generate request for registration!");
} }
@@ -104,7 +104,7 @@ pub async fn add_webauthn_factor_route(
let challenge_json = match serde_json::to_string(&registration_request.creation_challenge) { let challenge_json = match serde_json::to_string(&registration_request.creation_challenge) {
Ok(r) => r, Ok(r) => r,
Err(e) => { Err(e) => {
log::error!("Failed to serialize challenge! {:?}", e); log::error!("Failed to serialize challenge! {e:?}");
return HttpResponse::InternalServerError().body("Failed to serialize challenge!"); return HttpResponse::InternalServerError().body("Failed to serialize challenge!");
} }
}; };

@@ -6,26 +6,118 @@ use actix::Addr;
use actix_identity::Identity; use actix_identity::Identity;
use actix_remote_ip::RemoteIP; use actix_remote_ip::RemoteIP;
use actix_web::dev::Payload; use actix_web::dev::Payload;
use actix_web::{web, Error, FromRequest, HttpRequest}; 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()
@@ -142,51 +254,86 @@ impl Action<'_> {
false => format!("performed FAILED webauthn attempt for user {user_id:?}"), false => format!("performed FAILED webauthn attempt for user {user_id:?}"),
}, },
Action::StartLoginAttemptWithOpenIDProvider { provider_id, state } => format!( Action::StartLoginAttemptWithOpenIDProvider { provider_id, state } => format!(
"started new authentication attempt through an OpenID provider (prov={} / state={state})", provider_id.0 "started new authentication attempt through an OpenID provider (prov={} / state={state})",
provider_id.0
), ),
Action::ProviderError { message } => Action::ProviderError { message } => {
format!("failed provider authentication with message '{message}'"), format!("failed provider authentication with message '{message}'")
Action::ProviderCBInvalidState { state } => }
format!("provided invalid callback state after provider authentication: '{state}'"), Action::ProviderCBInvalidState { state } => {
Action::ProviderRateLimited => "could not complete OpenID login because it has reached failed attempts rate limit!".to_string(), format!("provided invalid callback state after provider authentication: '{state}'")
Action::ProviderFailedGetToken {state, code} => format!("could not complete login from provider because the id_token could not be retrieved! (state={:?} code = {code})",state), }
Action::ProviderFailedGetUserInfo {provider} => format!("could not get user information from userinfo endpoint of provider {}!", provider.id.0), Action::ProviderRateLimited => {
Action::ProviderEmailNotValidated {provider}=>format!("could not login using provider {} because its email was marked as not validated!", provider.id.0), "could not complete OpenID login because it has reached failed attempts rate limit!"
Action::ProviderMissingEmailInResponse {provider}=>format!("could not login using provider {} because the email was not provided by userinfo endpoint!", provider.id.0), .to_string()
Action::ProviderAccountNotFound { provider, email } => }
format!("could not login using provider {} because the email {email} could not be associated to any account!", &provider.id.0), Action::ProviderFailedGetToken { state, code } => format!(
Action::ProviderAccountDisabled { provider, email } => "could not complete login from provider because the id_token could not be retrieved! (state={state:?} code = {code})"
format!("could not login using provider {} because the account associated to the email {email} is disabled!", &provider.id.0), ),
Action::ProviderAccountNotAllowedToLoginWithProvider { provider, email } => Action::ProviderFailedGetUserInfo { provider } => format!(
format!("could not login using provider {} because the account associated to the email {email} is not allowed to authenticate using this provider!", &provider.id.0), "could not get user information from userinfo endpoint of provider {}!",
Action::ProviderLoginFailed { provider, email } => provider.id.0
format!("could not login using provider {} with the email {email} for an unknown reason!", &provider.id.0), ),
Action::ProviderLoginSuccessful {provider, user} => Action::ProviderEmailNotValidated { provider } => format!(
format!("successfully authenticated using provider {} as {}", provider.id.0, user.quick_identity()), "could not login using provider {} because its email was marked as not validated!",
Action::Signout => "signed out".to_string(), provider.id.0
Action::UserNeed2FAOnLogin(user) => { ),
Action::ProviderMissingEmailInResponse { provider } => format!(
"could not login using provider {} because the email was not provided by userinfo endpoint!",
provider.id.0
),
Action::ProviderAccountNotFound { provider, email } => format!(
"could not login using provider {} because the email {email} could not be associated to any account!",
&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!(
"could not login using provider {} because the account associated to the email {email} is disabled!",
&provider.id.0
),
Action::ProviderAccountNotAllowedToLoginWithProvider { provider, email } => format!(
"could not login using provider {} because the account associated to the email {email} is not allowed to authenticate using this provider!",
&provider.id.0
),
Action::ProviderLoginFailed { provider, email } => format!(
"could not login using provider {} with the email {email} for an unknown reason!",
&provider.id.0
),
Action::ProviderLoginSuccessful { provider, user } => format!(
"successfully authenticated using provider {} as {}",
provider.id.0,
user.quick_identity()
),
Action::SignOut => "signed out".to_string(),
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!("successfully locally authenticated as {login}, but this is a FORBIDDEN for this account!") format!(
"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 {
@@ -200,12 +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!("finished an implicit flow connection for client {:?}", client.id), Action::NewOpenIDSuccessfulImplicitAuth { client } => format!(
"finished an implicit flow connection for client {:?}",
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(),
), ),
@@ -214,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>,
@@ -221,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 {
"{} from {} has {}", ActionLoggerFormat::Text => log::info!(
match &self.user { "{} from {} has {}",
None => "Anonymous user".to_string(), match &self.user {
Some(u) => u.quick_identity(), None => "Anonymous user".to_string(),
Some(u) => u.loggable().quick_identity(),
},
self.ip,
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}"),
}, },
self.ip.to_string(), ActionLoggerFormat::None => {}
action.as_string() }
)
} }
} }

@@ -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)]
@@ -18,6 +27,14 @@ pub struct AppConfig {
#[clap(short, long, env)] #[clap(short, long, env)]
pub storage_path: String, pub storage_path: String,
/// Overwrite clients list file path, if the file is not to be found in storage path
#[clap(long, env)]
pub clients_list_file_path: Option<String>,
/// Overwrite providers list file path, if the file is not to be found in storage path
#[clap(long, env)]
pub providers_list_file_path: Option<String>,
/// App token token /// App token token
#[clap(short, long, env, default_value = "")] #[clap(short, long, env, default_value = "")]
pub token_key: String, pub token_key: String,
@@ -32,11 +49,24 @@ pub struct AppConfig {
/// IP location service API /// IP location service API
/// ///
/// Up instance of IP location service : https://gitlab.com/pierre42100/iplocationserver /// Operating instance of IP location service : https://gitlab.com/pierre42100/iplocationserver
/// ///
/// 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! {
@@ -71,11 +101,17 @@ impl AppConfig {
} }
pub fn clients_file(&self) -> PathBuf { pub fn clients_file(&self) -> PathBuf {
self.storage_path().join(CLIENTS_LIST_FILE) match &self.clients_list_file_path {
None => self.storage_path().join(CLIENTS_LIST_FILE),
Some(p) => Path::new(p).to_path_buf(),
}
} }
pub fn providers_file(&self) -> PathBuf { pub fn providers_file(&self) -> PathBuf {
self.storage_path().join(PROVIDERS_LIST_FILE) match &self.providers_list_file_path {
None => self.storage_path().join(PROVIDERS_LIST_FILE),
Some(p) => Path::new(p).to_path_buf(),
}
} }
pub fn full_url(&self, uri: &str) -> String { pub fn full_url(&self, uri: &str) -> String {

@@ -7,12 +7,6 @@ use std::collections::HashMap;
#[derive(Clone, Debug, serde::Serialize, serde::Deserialize, Eq, PartialEq)] #[derive(Clone, Debug, serde::Serialize, serde::Deserialize, Eq, PartialEq)]
pub struct ClientID(pub String); pub struct ClientID(pub String);
#[derive(Debug, Copy, Clone, Eq, PartialEq)]
pub enum AuthenticationFlow {
AuthorizationCode,
Implicit,
}
pub type AdditionalClaims = HashMap<String, Value>; pub type AdditionalClaims = HashMap<String, Value>;
#[derive(Clone, Debug, serde::Serialize, serde::Deserialize)] #[derive(Clone, Debug, serde::Serialize, serde::Deserialize)]
@@ -61,12 +55,9 @@ impl PartialEq for Client {
impl Eq for Client {} impl Eq for Client {}
impl Client { impl Client {
/// Get the client authentication flow /// Check if the client has a secret defined
pub fn auth_flow(&self) -> AuthenticationFlow { pub fn has_secret(&self) -> bool {
match self.secret { self.secret.is_some()
None => AuthenticationFlow::Implicit,
Some(_) => AuthenticationFlow::AuthorizationCode,
}
} }
/// Process a single claim value /// Process a single claim value
@@ -134,7 +125,7 @@ impl Client {
pub type ClientManager = EntityManager<Client>; pub type ClientManager = EntityManager<Client>;
impl EntityManager<Client> { impl ClientManager {
pub fn find_by_id(&self, u: &ClientID) -> Option<Client> { pub fn find_by_id(&self, u: &ClientID) -> Option<Client> {
for entry in self.iter() { for entry in self.iter() {
if entry.id.eq(u) { if entry.id.eq(u) {

@@ -1,5 +1,5 @@
use base64::engine::general_purpose::URL_SAFE_NO_PAD as BASE64_URL_SAFE_NO_PAD;
use base64::Engine as _; use base64::Engine as _;
use base64::engine::general_purpose::URL_SAFE_NO_PAD as BASE64_URL_SAFE_NO_PAD;
use crate::utils::crypt_utils::sha256; use crate::utils::crypt_utils::sha256;
@@ -22,7 +22,7 @@ impl CodeChallenge {
encoded.eq(&self.code_challenge) encoded.eq(&self.code_challenge)
} }
s => { s => {
log::error!("Unknown code challenge method: {}", s); log::error!("Unknown code challenge method: {s}");
false false
} }
} }
@@ -40,8 +40,8 @@ mod test {
code_challenge: "text1".to_string(), code_challenge: "text1".to_string(),
}; };
assert_eq!(true, chal.verify_code("text1")); assert!(chal.verify_code("text1"));
assert_eq!(false, chal.verify_code("text2")); assert!(!chal.verify_code("text2"));
} }
#[test] #[test]
@@ -51,8 +51,8 @@ mod test {
code_challenge: "uSOvC48D8TMh6RgW-36XppMlMgys-6KAE_wEIev9W2g".to_string(), code_challenge: "uSOvC48D8TMh6RgW-36XppMlMgys-6KAE_wEIev9W2g".to_string(),
}; };
assert_eq!(true, chal.verify_code("HIwht3lCHfnsruA+7Sq8NP2mPj5cBZe0Ewf23eK9UQhK4TdCIt3SK7Fr/giCdnfjxYQILOPG2D562emggAa2lA==")); assert!(chal.verify_code("HIwht3lCHfnsruA+7Sq8NP2mPj5cBZe0Ewf23eK9UQhK4TdCIt3SK7Fr/giCdnfjxYQILOPG2D562emggAa2lA=="));
assert_eq!(false, chal.verify_code("text1")); assert!(!chal.verify_code("text1"));
} }
#[test] #[test]
@@ -62,10 +62,7 @@ mod test {
code_challenge: "E9Melhoa2OwvFrEMTJguCHaoeK1t8URWbuGJSstw-cM".to_string(), code_challenge: "E9Melhoa2OwvFrEMTJguCHaoeK1t8URWbuGJSstw-cM".to_string(),
}; };
assert_eq!( assert!(chal.verify_code("dBjftJeZ4CVP-mB92K27uhbUJU1p1r_wW1gFWFOEjXk"));
true, assert!(!chal.verify_code("text1"));
chal.verify_code("dBjftJeZ4CVP-mB92K27uhbUJU1p1r_wW1gFWFOEjXk")
);
assert_eq!(false, chal.verify_code("text1"));
} }
} }

@@ -1,6 +1,6 @@
use crate::data::current_user::CurrentUser; use crate::data::current_user::CurrentUser;
use crate::data::from_request_redirect::FromRequestRedirect; use crate::data::from_request_redirect::FromRequestRedirect;
use crate::data::login_redirect::{get_2fa_url, LoginRedirect}; use crate::data::login_redirect::{LoginRedirect, get_2fa_url};
use actix_web::dev::Payload; use actix_web::dev::Payload;
use actix_web::{FromRequest, HttpRequest}; use actix_web::{FromRequest, HttpRequest};
use std::future::Future; use std::future::Future;

@@ -6,7 +6,7 @@ use actix::Addr;
use actix_identity::Identity; use actix_identity::Identity;
use actix_web::dev::Payload; use actix_web::dev::Payload;
use actix_web::error::ErrorInternalServerError; use actix_web::error::ErrorInternalServerError;
use actix_web::{web, Error, FromRequest, HttpRequest}; use actix_web::{Error, FromRequest, HttpRequest, web};
use crate::actors::users_actor; use crate::actors::users_actor;
use crate::actors::users_actor::UsersActor; use crate::actors::users_actor::UsersActor;

@@ -20,7 +20,10 @@ where
/// Open entity /// Open entity
pub fn open_or_create<A: AsRef<Path>>(path: A) -> Res<Self> { pub fn open_or_create<A: AsRef<Path>>(path: A) -> Res<Self> {
if !path.as_ref().is_file() { if !path.as_ref().is_file() {
log::warn!("Entities at {:?} does not point to a file, creating a new empty entity container...", path.as_ref()); log::warn!(
"Entities at {:?} does not point to a file, creating a new empty entity container...",
path.as_ref()
);
return Ok(Self { return Ok(Self {
file_path: path.as_ref().to_path_buf(), file_path: path.as_ref().to_path_buf(),
list: vec![], list: vec![],

@@ -2,7 +2,7 @@ use crate::data::current_user::CurrentUser;
use crate::data::session_identity::SessionIdentity; use crate::data::session_identity::SessionIdentity;
use actix_identity::Identity; use actix_identity::Identity;
use actix_web::dev::Payload; use actix_web::dev::Payload;
use actix_web::{web, Error, FromRequest, HttpRequest}; use actix_web::{Error, FromRequest, HttpRequest, web};
use std::future::Future; use std::future::Future;
use std::pin::Pin; use std::pin::Pin;

@@ -1,12 +1,12 @@
use jwt_simple::algorithms::RSAKeyPairLike; use jwt_simple::algorithms::RSAKeyPairLike;
use jwt_simple::claims::JWTClaims; use jwt_simple::claims::JWTClaims;
use jwt_simple::prelude::RS256KeyPair; use jwt_simple::prelude::RS256KeyPair;
use serde::de::DeserializeOwned;
use serde::Serialize; use serde::Serialize;
use serde::de::DeserializeOwned;
use base64::Engine as _;
use base64::engine::general_purpose::URL_SAFE as BASE64_URL_URL_SAFE; use base64::engine::general_purpose::URL_SAFE as BASE64_URL_URL_SAFE;
use base64::engine::general_purpose::URL_SAFE_NO_PAD as BASE64_URL_SAFE_NO_PAD; use base64::engine::general_purpose::URL_SAFE_NO_PAD as BASE64_URL_SAFE_NO_PAD;
use base64::Engine as _;
use crate::utils::err::Res; use crate::utils::err::Res;
use crate::utils::string_utils::rand_str; use crate::utils::string_utils::rand_str;

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

@@ -26,7 +26,9 @@ impl ProviderConfiguration {
let state = urlencoding::encode(&state.state_id).to_string(); let state = urlencoding::encode(&state.state_id).to_string();
let callback_url = AppConfig::get().oidc_provider_redirect_url(); let callback_url = AppConfig::get().oidc_provider_redirect_url();
format!("{authorization_url}?response_type=code&scope=openid%20profile%20email&client_id={client_id}&state={state}&redirect_uri={callback_url}") format!(
"{authorization_url}?response_type=code&scope=openid%20profile%20email&client_id={client_id}&state={state}&redirect_uri={callback_url}"
)
} }
/// Retrieve the authorization token after a successful authentication, using an authorization code /// Retrieve the authorization token after a successful authentication, using an authorization code

@@ -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>,
@@ -46,7 +41,7 @@ impl SessionIdentity<'_> {
.map(|f| match f { .map(|f| match f {
Ok(d) => Some(d), Ok(d) => Some(d),
Err(e) => { Err(e) => {
log::warn!("Failed to deserialize session data! {:?}", e); log::warn!("Failed to deserialize session data! {e:?}");
None None
} }
}) })
@@ -65,7 +60,7 @@ impl SessionIdentity<'_> {
log::debug!("Will set user session data."); log::debug!("Will set user session data.");
if let Err(e) = Identity::login(&req.extensions(), s) { if let Err(e) = Identity::login(&req.extensions(), s) {
log::error!("Failed to set session data! {}", e); log::error!("Failed to set session data! {e}");
} }
log::debug!("Did set user session data."); log::debug!("Did set user session data.");
} }

@@ -1,5 +1,3 @@
use std::io::ErrorKind;
use base32::Alphabet; use base32::Alphabet;
use rand::Rng; use rand::Rng;
use totp_rfc6238::{HashAlgorithm, TotpGenerator}; use totp_rfc6238::{HashAlgorithm, TotpGenerator};
@@ -21,7 +19,7 @@ pub struct TotpKey {
impl TotpKey { impl TotpKey {
/// Generate a new TOTP key /// Generate a new TOTP key
pub fn new_random() -> Self { pub fn new_random() -> Self {
let random_bytes = rand::thread_rng().gen::<[u8; 20]>(); let random_bytes = rand::rng().random::<[u8; 20]>();
Self { Self {
encoded: base32::encode(BASE32_ALPHABET, &random_bytes), encoded: base32::encode(BASE32_ALPHABET, &random_bytes),
} }
@@ -80,7 +78,7 @@ impl TotpKey {
/// Get the code at a specific time /// Get the code at a specific time
fn get_code_at<F: Fn() -> u64>(&self, get_time: F) -> Res<String> { fn get_code_at<F: Fn() -> u64>(&self, get_time: F) -> Res<String> {
let gen = TotpGenerator::new() let generator = TotpGenerator::new()
.set_digit(NUM_DIGITS) .set_digit(NUM_DIGITS)
.unwrap() .unwrap()
.set_step(PERIOD) .set_step(PERIOD)
@@ -90,15 +88,14 @@ impl TotpKey {
let key = match base32::decode(BASE32_ALPHABET, &self.encoded) { let key = match base32::decode(BASE32_ALPHABET, &self.encoded) {
None => { None => {
return Err(Box::new(std::io::Error::new( return Err(Box::new(std::io::Error::other(
ErrorKind::Other,
"Failed to decode base32 secret!", "Failed to decode base32 secret!",
))); )));
} }
Some(k) => k, Some(k) => k,
}; };
Ok(gen.get_code_with(&key, get_time)) Ok(generator.get_code_with(&key, get_time))
} }
/// Check a code's validity /// Check a code's validity

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

@@ -3,7 +3,7 @@ use std::net::IpAddr;
use crate::actors::users_actor::{AuthorizedAuthenticationSources, UsersSyncBackend}; use crate::actors::users_actor::{AuthorizedAuthenticationSources, UsersSyncBackend};
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::{new_error, Res}; use crate::utils::err::{Res, new_error};
use crate::utils::time::time; use crate::utils::time::time;
impl EntityManager<User> { impl EntityManager<User> {
@@ -18,7 +18,7 @@ impl EntityManager<User> {
}; };
if let Err(e) = self.replace_entries(|u| u.uid.eq(id), &update(user)) { if let Err(e) = self.replace_entries(|u| u.uid.eq(id), &update(user)) {
log::error!("Failed to update user information! {:?}", e); log::error!("Failed to update user information! {e:?}");
return Err(e); return Err(e);
} }
@@ -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, log::warn!("Failed to verify password! {e:?}");
Err(e) => { false
log::warn!("Failed to verify password! {:?}", e); })
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);

@@ -1,4 +1,3 @@
use std::io::ErrorKind;
use std::sync::Arc; use std::sync::Arc;
use actix_web::web; use actix_web::web;
@@ -109,17 +108,11 @@ impl WebAuthManager {
) -> Res<WebauthnPubKey> { ) -> Res<WebauthnPubKey> {
let state: RegisterKeyOpaqueData = self.crypto_wrapper.decrypt(opaque_state)?; let state: RegisterKeyOpaqueData = self.crypto_wrapper.decrypt(opaque_state)?;
if state.user_id != user.uid { if state.user_id != user.uid {
return Err(Box::new(std::io::Error::new( return Err(Box::new(std::io::Error::other("Invalid user for pubkey!")));
ErrorKind::Other,
"Invalid user for pubkey!",
)));
} }
if state.expire < time() { if state.expire < time() {
return Err(Box::new(std::io::Error::new( return Err(Box::new(std::io::Error::other("Challenge has expired!")));
ErrorKind::Other,
"Challenge has expired!",
)));
} }
let res = self.core.finish_passkey_registration( let res = self.core.finish_passkey_registration(
@@ -157,17 +150,11 @@ impl WebAuthManager {
) -> Res { ) -> Res {
let state: AuthStateOpaqueData = self.crypto_wrapper.decrypt(opaque_state)?; let state: AuthStateOpaqueData = self.crypto_wrapper.decrypt(opaque_state)?;
if &state.user_id != user_id { if &state.user_id != user_id {
return Err(Box::new(std::io::Error::new( return Err(Box::new(std::io::Error::other("Invalid user for pubkey!")));
ErrorKind::Other,
"Invalid user for pubkey!",
)));
} }
if state.expire < time() { if state.expire < time() {
return Err(Box::new(std::io::Error::new( return Err(Box::new(std::io::Error::other("Challenge has expired!")));
ErrorKind::Other,
"Challenge has expired!",
)));
} }
self.core.finish_passkey_authentication( self.core.finish_passkey_authentication(

@@ -2,14 +2,14 @@ use core::time::Duration;
use std::sync::Arc; use std::sync::Arc;
use actix::Actor; use actix::Actor;
use actix_identity::config::LogoutBehaviour;
use actix_identity::IdentityMiddleware; use actix_identity::IdentityMiddleware;
use actix_identity::config::LogoutBehavior;
use actix_remote_ip::RemoteIPConfig; use actix_remote_ip::RemoteIPConfig;
use actix_session::storage::CookieSessionStore;
use actix_session::SessionMiddleware; use actix_session::SessionMiddleware;
use actix_session::storage::CookieSessionStore;
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::{get, middleware, web, App, HttpResponse, HttpServer}; 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;
@@ -51,7 +51,7 @@ async fn main() -> std::io::Result<()> {
// Create initial user if required // Create initial user if required
if users.is_empty() { if users.is_empty() {
log::info!("Create default {} user", DEFAULT_ADMIN_USERNAME); log::info!("Create default {DEFAULT_ADMIN_USERNAME} user");
let default_admin = User { let default_admin = User {
username: DEFAULT_ADMIN_USERNAME.to_string(), username: DEFAULT_ADMIN_USERNAME.to_string(),
authorized_clients: None, authorized_clients: None,
@@ -100,7 +100,7 @@ async fn main() -> std::io::Result<()> {
.build(); .build();
let identity_middleware = IdentityMiddleware::builder() let identity_middleware = IdentityMiddleware::builder()
.logout_behaviour(LogoutBehaviour::PurgeSession) .logout_behavior(LogoutBehavior::PurgeSession)
.visit_deadline(Some(Duration::from_secs(MAX_INACTIVITY_DURATION))) .visit_deadline(Some(Duration::from_secs(MAX_INACTIVITY_DURATION)))
.login_deadline(Some(Duration::from_secs(MAX_SESSION_DURATION))) .login_deadline(Some(Duration::from_secs(MAX_SESSION_DURATION)))
.build(); .build();

@@ -1,15 +1,15 @@
//! # Authentication middleware //! # Authentication middleware
use std::future::{ready, Future, Ready}; use std::future::{Future, Ready, ready};
use std::pin::Pin; use std::pin::Pin;
use std::rc::Rc; use std::rc::Rc;
use actix_identity::IdentityExt; use actix_identity::IdentityExt;
use actix_web::body::EitherBody; use actix_web::body::EitherBody;
use actix_web::http::{header, Method}; use actix_web::http::{Method, header};
use actix_web::{ use actix_web::{
dev::{forward_ready, Service, ServiceRequest, ServiceResponse, Transform},
Error, HttpResponse, Error, HttpResponse,
dev::{Service, ServiceRequest, ServiceResponse, Transform, forward_ready},
}; };
use crate::constants::{ use crate::constants::{
@@ -89,25 +89,21 @@ where
Box::pin(async move { Box::pin(async move {
// Check if POST request comes from another website (block invalid origins) // Check if POST request comes from another website (block invalid origins)
let origin = req.headers().get(header::ORIGIN); let origin = req.headers().get(header::ORIGIN);
if req.method() == Method::POST && req.path() != TOKEN_URI && req.path() != USERINFO_URI if req.method() == Method::POST
&& req.path() != TOKEN_URI
&& req.path() != USERINFO_URI
&& let Some(o) = origin
&& !o
.to_str()
.unwrap_or("bad")
.eq(&AppConfig::get().website_origin)
{ {
if let Some(o) = origin { log::warn!("Blocked POST request from invalid origin! Origin given {o:?}");
if !o return Ok(req.into_response(
.to_str() HttpResponse::Unauthorized()
.unwrap_or("bad") .body("POST request from invalid origin!")
.eq(&AppConfig::get().website_origin) .map_into_right_body(),
{ ));
log::warn!(
"Blocked POST request from invalid origin! Origin given {:?}",
o
);
return Ok(req.into_response(
HttpResponse::Unauthorized()
.body("POST request from invalid origin!")
.map_into_right_body(),
));
}
}
} }
if req.path().starts_with("/.git") { if req.path().starts_with("/.git") {
@@ -133,8 +129,8 @@ where
_ => ConnStatus::SignedOut, _ => ConnStatus::SignedOut,
}; };
log::trace!("Connection data: {:#?}", session_data); log::trace!("Connection data: {session_data:#?}");
log::debug!("Connection status: {:?}", session); log::debug!("Connection status: {session:?}");
// Redirect user to login page // Redirect user to login page
if !session.is_auth() if !session.is_auth()

@@ -1,14 +1,9 @@
use lazy_regex::regex_find; use lazy_regex::regex_find;
use rand::distributions::Alphanumeric; use rand::distr::{Alphanumeric, SampleString};
use rand::Rng;
/// Generate a random string of a given size /// Generate a random string of a given size
pub fn rand_str(len: usize) -> String { pub fn rand_str(len: usize) -> String {
rand::thread_rng() Alphanumeric.sample_string(&mut rand::rng(), len)
.sample_iter(&Alphanumeric)
.map(char::from)
.take(len)
.collect()
} }
/// Parse environment variables /// Parse environment variables
@@ -49,8 +44,10 @@ mod test {
const VAR_ONE: &str = "VAR_ONE"; const VAR_ONE: &str = "VAR_ONE";
#[test] #[test]
fn test_apply_env_var() { fn test_apply_env_var() {
env::set_var(VAR_ONE, "good"); unsafe {
let src = format!("This is ${{{}}}", VAR_ONE); env::set_var(VAR_ONE, "good");
}
let src = format!("This is ${{{VAR_ONE}}}");
assert_eq!("This is good", apply_env_vars(&src)); assert_eq!("This is good", apply_env_vars(&src));
} }
@@ -58,7 +55,7 @@ mod test {
#[test] #[test]
fn test_invalid_var_syntax() { fn test_invalid_var_syntax() {
let src = format!("This is ${{{}}}", VAR_INVALID); let src = format!("This is ${{{VAR_INVALID}}}");
assert_eq!(src, apply_env_vars(&src)); assert_eq!(src, apply_env_vars(&src));
} }

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