Add auth stuff

.gitignore

@@ -1,4 +1,2 @@
 /target
-package-lock.json
-node_modules/
-build/
+/persmgr_derive/target

Cargo.lock

@@ -83,7 +83,7 @@ dependencies = [
  "rustc-hash",
  "serde",
  "serde_derive",
- "syn",
+ "syn 2.0.106",
 ]
 
 [[package]]
@@ -122,7 +122,7 @@ checksum = "9035ad2d096bed7955a320ee7e2230574d28fd3c3a0f186cbea1ff3c7eed5dbb"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn",
+ "syn 2.0.106",
 ]
 
 [[package]]
@@ -209,7 +209,7 @@ checksum = "604fde5e028fea851ce1d8570bbdc034bec850d157f7569d10f347d06808c05c"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn",
+ "syn 2.0.106",
 ]
 
 [[package]]
@@ -416,6 +416,41 @@ dependencies = [
  "typenum",
 ]
 
+[[package]]
+name = "darling"
+version = "0.13.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a01d95850c592940db9b8194bc39f4bc0e89dee5c4265e4b1807c34a9aba453c"
+dependencies = [
+ "darling_core",
+ "darling_macro",
+]
+
+[[package]]
+name = "darling_core"
+version = "0.13.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "859d65a907b6852c9361e3185c862aae7fafd2887876799fa55f5f99dc40d610"
+dependencies = [
+ "fnv",
+ "ident_case",
+ "proc-macro2",
+ "quote",
+ "strsim",
+ "syn 1.0.109",
+]
+
+[[package]]
+name = "darling_macro"
+version = "0.13.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9c972679f83bdf9c42bd905396b6c3588a843a17f0f16dfcfa3e2c5d57441835"
+dependencies = [
+ "darling_core",
+ "quote",
+ "syn 1.0.109",
+]
+
 [[package]]
 name = "der"
 version = "0.7.10"
@@ -457,7 +492,7 @@ checksum = "97369cbbc041bc366949bc74d34658d6cda5621039731c6310521892a3a20ae0"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn",
+ "syn 2.0.106",
 ]
 
 [[package]]
@@ -617,7 +652,7 @@ checksum = "162ee34ebcb7c64a8abebc059ce0fee27c2262618d7b60ed8faf72fef13c3650"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn",
+ "syn 2.0.106",
 ]
 
 [[package]]
@@ -941,6 +976,12 @@ dependencies = [
  "zerovec",
 ]
 
+[[package]]
+name = "ident_case"
+version = "1.0.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b9e0384b61958566e926dc50660321d12159025e767c18e043daf26b70104c39"
+
 [[package]]
 name = "idna"
 version = "1.1.0"
@@ -1284,6 +1325,7 @@ dependencies = [
  "axum",
  "base64",
  "cfg-if",
+ "persmgr_derive",
  "pulldown-cmark",
  "rand 0.9.2",
  "serde",
@@ -1301,6 +1343,16 @@ dependencies = [
  "tracing-subscriber",
 ]
 
+[[package]]
+name = "persmgr_derive"
+version = "0.1.0"
+dependencies = [
+ "darling",
+ "proc-macro2",
+ "quote",
+ "syn 1.0.109",
+]
+
 [[package]]
 name = "pin-project-lite"
 version = "0.2.16"
@@ -1542,7 +1594,7 @@ checksum = "5b0276cf7f2c73365f7157c8123c21cd9a50fbbd844757af28ca1f5925fc2a00"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn",
+ "syn 2.0.106",
 ]
 
 [[package]]
@@ -1745,7 +1797,7 @@ dependencies = [
  "quote",
  "sqlx-core",
  "sqlx-macros-core",
- "syn",
+ "syn 2.0.106",
 ]
 
 [[package]]
@@ -1768,7 +1820,7 @@ dependencies = [
  "sqlx-mysql",
  "sqlx-postgres",
  "sqlx-sqlite",
- "syn",
+ "syn 2.0.106",
  "tokio",
  "url",
 ]
@@ -1893,12 +1945,29 @@ dependencies = [
  "unicode-properties",
 ]
 
+[[package]]
+name = "strsim"
+version = "0.10.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "73473c0e59e6d5812c5dfe2a064a6444949f089e20eec9a2e5506596494e4623"
+
 [[package]]
 name = "subtle"
 version = "2.6.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "13c2bddecc57b384dee18652358fb23172facb8a2c51ccc10d74c157bdea3292"
 
+[[package]]
+name = "syn"
+version = "1.0.109"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "72b64191b275b66ffe2469e8af2c1cfe3bafa67b529ead792a6d0160888b4237"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "unicode-ident",
+]
+
 [[package]]
 name = "syn"
 version = "2.0.106"
@@ -1924,7 +1993,7 @@ checksum = "728a70f3dbaf5bab7f0c4b1ac8d7ae5ea60a4b5549c8a5914361c99147a709d2"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn",
+ "syn 2.0.106",
 ]
 
 [[package]]
@@ -1944,7 +2013,7 @@ checksum = "6c5e1be1c48b9172ee610da68fd9cd2770e7a4056cb3fc98710ee6906f0c7960"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn",
+ "syn 2.0.106",
 ]
 
 [[package]]
@@ -2039,7 +2108,7 @@ checksum = "6e06d43f1345a3bcd39f6a56dbb7dcab2ba47e68e8ac134855e7e2bdbaf8cab8"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn",
+ "syn 2.0.106",
 ]
 
 [[package]]
@@ -2269,7 +2338,7 @@ checksum = "81383ab64e72a7a8b8e13130c49e3dab29def6d0c7d76a03087b3cf71c5c6903"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn",
+ "syn 2.0.106",
 ]
 
 [[package]]
@@ -2442,7 +2511,7 @@ dependencies = [
  "log",
  "proc-macro2",
  "quote",
- "syn",
+ "syn 2.0.106",
  "wasm-bindgen-shared",
 ]
 
@@ -2464,7 +2533,7 @@ checksum = "8ae87ea40c9f689fc23f209965b6fb8a99ad69aeeb0231408be24920604395de"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn",
+ "syn 2.0.106",
  "wasm-bindgen-backend",
  "wasm-bindgen-shared",
 ]
@@ -2677,7 +2746,7 @@ checksum = "38da3c9736e16c5d3c8c597a9aaa5d1fa565d0532ae05e27c24aa62fb32c0ab6"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn",
+ "syn 2.0.106",
  "synstructure",
 ]
 
@@ -2698,7 +2767,7 @@ checksum = "9ecf5b4cc5364572d7f4c329661bcc82724222973f2cab6f050a4e5c22f75181"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn",
+ "syn 2.0.106",
 ]
 
 [[package]]
@@ -2718,7 +2787,7 @@ checksum = "d71e5d6e06ab090c67b5e44993ec16b72dcbaabc526db883a360057678b48502"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn",
+ "syn 2.0.106",
  "synstructure",
 ]
 
@@ -2758,7 +2827,7 @@ checksum = "5b96237efa0c878c64bd89c436f661be4e46b2f3eff1ebb976f7ef2321d2f58f"
 dependencies = [
  "proc-macro2",
  "quote",
- "syn",
+ "syn 2.0.106",
 ]
 
 [[package]]

Cargo.toml

@@ -4,6 +4,8 @@ version = "0.1.0"
 edition = "2024"
 
 [dependencies]
+persmgr_derive.path="./persmgr_derive"
+
 anyhow = "1.0.99"
 argon2 = { version = "0.5.3", features = ["simple", "std"] }
 askama = "0.14.0"

migrations/20250906104612_users.down.sql

@@ -1,3 +0,0 @@
--- Add down migration script here
-
-DROP TABLE IF EXISTS users;

migrations/20250906104612_users.up.sql

@@ -1,13 +0,0 @@
--- Add up migration script here
-
-CREATE TABLE IF NOT EXISTS users (
-    id BIGSERIAL PRIMARY KEY,
-    email TEXT NOT NULL UNIQUE,
-    verified_email BOOLEAN NOT NULL,
-    username TEXT NOT NULL UNIQUE,
-    pw_hash TEXT NOT NULL,
-    pw_salt TEXT NOT NULL,
-    pfp_id BIGINT NOT NULL,
-    rank_id BIGINT NOT NULL
-);
-

migrations/20250906202709_sessions.down.sql

@@ -1,3 +0,0 @@
--- Add down migration script here
-
-DROP TABLE IF EXISTS sessions;

migrations/20250906202709_sessions.up.sql

@@ -1,8 +0,0 @@
--- Add up migration script here
-
-CREATE TABLE IF NOT EXISTS sessions (
-    user_id BIGINT NOT NULL,
-    session_key TEXT NOT NULL UNIQUE,
-    expires BIGINT NOT NULL,
-    CONSTRAINT fk_user FOREIGN KEY(user_id) REFERENCES users(id) ON DELETE CASCADE
-)

migrations/20250913111557_ranks.down.sql

@@ -1 +0,0 @@
-DROP TABLE IF EXISTS ranks;

migrations/20250913111557_ranks.up.sql

@@ -1,7 +0,0 @@
-CREATE TABLE IF NOT EXISTS ranks (
-    id BIGSERIAL PRIMARY KEY NOT NULL,
-    name TEXT NOT NULL,
-    description TEXT NOT NULL,
-    created_at BIGINT NOT NULL,
-    modified_at BIGINT NOT NULL
-);

migrations/20250913111613_awards.down.sql

@@ -1 +0,0 @@
-DROP TABLE IF EXISTS awards;

migrations/20250913111613_awards.up.sql

@@ -1,7 +0,0 @@
-CREATE TABLE IF NOT EXISTS awards (
-    id BIGSERIAL PRIMARY KEY NOT NULL,
-    name TEXT NOT NULL,
-    description TEXT NOT NULL,
-    created_at BIGINT NOT NULL,
-    modified_at BIGINT NOT NULL
-);

migrations/20250913111614_trainings.down.sql

@@ -1 +0,0 @@
-DROP TABLE IF EXISTS trainings;

migrations/20250913111614_trainings.up.sql

@@ -1,7 +0,0 @@
-CREATE TABLE IF NOT EXISTS trainings (
-    id BIGSERIAL PRIMARY KEY NOT NULL,
-    name TEXT NOT NULL,
-    description TEXT NOT NULL,
-    created_at BIGINT NOT NULL,
-    modified_at BIGINT NOT NULL
-);

migrations/20250913111615_missions.down.sql

@@ -1 +0,0 @@
-DROP TABLE IF EXISTS missions;

migrations/20250913111615_missions.up.sql

@@ -1,9 +0,0 @@
-CREATE TABLE IF NOT EXISTS missions (
-    id BIGSERIAL PRIMARY KEY NOT NULL,
-    name TEXT NOT NULL,
-    description TEXT NOT NULL,
-    starting_at BIGINT NOT NULL,
-    estimated_length BIGINT NOT NULL,
-    created_at BIGINT NOT NULL,
-    modified_at BIGINT NOT NULL
-);

migrations/20250913111617_qualifications.down.sql

@@ -1 +0,0 @@
-DROP TABLE IF EXISTS qualifications;

migrations/20250913111617_qualifications.up.sql

@@ -1,7 +0,0 @@
-CREATE TABLE IF NOT EXISTS qualifications (
-    id BIGSERIAL PRIMARY KEY NOT NULL,
-    name TEXT NOT NULL,
-    description TEXT NOT NULL,
-    created_at BIGINT NOT NULL,
-    modified_at BIGINT NOT NULL
-);

migrations/20250913111736_records_ranks.down.sql

@@ -1 +0,0 @@
-DROP TABLE IF EXISTS record_ranks;

migrations/20250913111736_records_ranks.up.sql

@@ -1,11 +0,0 @@
-CREATE TABLE IF NOT EXISTS records_ranks (
-    id BIGSERIAL PRIMARY KEY NOT NULL,
-    user_id BIGINT NOT NULL,
-    rank_id BIGINT NOT NULL,
-    author_id BIGINT NOT NULL,
-    created_at BIGINT NOT NULL,
-
-    CONSTRAINT fk_user FOREIGN KEY(user_id) REFERENCES users(id) ON DELETE CASCADE,
-    CONSTRAINT fk_author FOREIGN KEY(author_id) REFERENCES users(id) ON DELETE SET NULL,
-    CONSTRAINT fk_rank FOREIGN KEY (rank_id) REFERENCES ranks(id) ON DELETE CASCADE
-);

migrations/20250913111748_records_awards.down.sql

@@ -1 +0,0 @@
-DROP TABLE IF EXISTS record_awards;

migrations/20250913111748_records_awards.up.sql

@@ -1,11 +0,0 @@
-CREATE TABLE IF NOT EXISTS records_awards (
-    id BIGSERIAL PRIMARY KEY NOT NULL,
-    user_id BIGINT NOT NULL,
-    award_id BIGINT NOT NULL,
-    author_id BIGINT NOT NULL,
-    created_at BIGINT NOT NULL,
-
-    CONSTRAINT fk_user FOREIGN KEY(user_id) REFERENCES users(id) ON DELETE CASCADE,
-    CONSTRAINT fk_author FOREIGN KEY(author_id) REFERENCES users(id) ON DELETE SET NULL,
-    CONSTRAINT fk_award FOREIGN KEY (award_id) REFERENCES awards(id) ON DELETE CASCADE
-);

migrations/20250913111802_records_training.down.sql

@@ -1 +0,0 @@
-DROP TABLE IF EXISTS record_training;

migrations/20250913111802_records_training.up.sql

@@ -1,11 +0,0 @@
-CREATE TABLE IF NOT EXISTS records_trainings (
-    id BIGSERIAL PRIMARY KEY NOT NULL,
-    user_id BIGINT NOT NULL,
-    training_id BIGINT NOT NULL,
-    author_id BIGINT NOT NULL,
-    created_at BIGINT NOT NULL,
-
-    CONSTRAINT fk_user FOREIGN KEY(user_id) REFERENCES users(id) ON DELETE CASCADE,
-    CONSTRAINT fk_author FOREIGN KEY(author_id) REFERENCES users(id) ON DELETE SET NULL,
-    CONSTRAINT fk_training FOREIGN KEY (training_id) REFERENCES trainings(id) ON DELETE CASCADE
-);

migrations/20250913111810_records_qualifications.down.sql

@@ -1 +0,0 @@
-DROP TABLE IF EXISTS record_qualifications;

migrations/20250913111810_records_qualifications.up.sql

@@ -1,11 +0,0 @@
-CREATE TABLE IF NOT EXISTS records_qualifications (
-    id BIGSERIAL PRIMARY KEY NOT NULL,
-    user_id BIGINT NOT NULL,
-    qualification_id BIGINT NOT NULL,
-    author_id BIGINT NOT NULL,
-    created_at BIGINT NOT NULL,
-
-    CONSTRAINT fk_user FOREIGN KEY(user_id) REFERENCES users(id) ON DELETE CASCADE,
-    CONSTRAINT fk_author FOREIGN KEY(author_id) REFERENCES users(id) ON DELETE SET NULL,
-    CONSTRAINT fk_qualification FOREIGN KEY (qualification_id) REFERENCES qualifications(id) ON DELETE CASCADE
-);

migrations/20250913112041_records_missions.down.sql

@@ -1 +0,0 @@
-DROP TABLE IF EXISTS records_missions;

migrations/20250913112041_records_missions.up.sql

@@ -1,11 +0,0 @@
-CREATE TABLE IF NOT EXISTS records_missions (
-    id BIGSERIAL PRIMARY KEY NOT NULL,
-    user_id BIGINT NOT NULL,
-    mission_id BIGINT NOT NULL,
-    author_id BIGINT NOT NULL,
-    created_at BIGINT NOT NULL,
-
-    CONSTRAINT fk_user FOREIGN KEY(user_id) REFERENCES users(id) ON DELETE CASCADE,
-    CONSTRAINT fk_author FOREIGN KEY(author_id) REFERENCES users(id) ON DELETE SET NULL,
-    CONSTRAINT fk_mission FOREIGN KEY (mission_id) REFERENCES missions(id) ON DELETE CASCADE
-);

migrations/20250913130129_attendance.down.sql

@@ -1 +0,0 @@
-DROP TABLE IF EXISTS attendance;

migrations/20250913130129_attendance.up.sql

@@ -1,10 +0,0 @@
-CREATE TABLE IF NOT EXISTS attendance (
-    id BIGSERIAL PRIMARY KEY NOT NULL,
-    user_id BIGINT NOT NULL,
-    mission_id BIGINT NOT NULL,
-    confirmed_at BIGINT NOT NULL,
-    attending BOOL NOT NULL,
-
-    CONSTRAINT fk_user FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE SET NULL,
-    CONSTRAINT fk_mission FOREIGN KEY (mission_id) REFERENCES missions(id) ON DELETE CASCADE
-);

migrations/20250914121222_main.down.sql

@@ -0,0 +1,14 @@
+DROP TABLE IF EXISTS users;
+DROP TABLE IF EXISTS sessions;
+DROP TABLE IF EXISTS ranks;
+DROP TABLE IF EXISTS awards;
+DROP TABLE IF EXISTS trainings;
+DROP TABLE IF EXISTS missions;
+DROP TABLE IF EXISTS qualifications;
+DROP TABLE IF EXISTS record_ranks;
+DROP TABLE IF EXISTS record_awards;
+DROP TABLE IF EXISTS record_training;
+DROP TABLE IF EXISTS record_qualifications;
+DROP TABLE IF EXISTS records_missions;
+DROP TABLE IF EXISTS attendance;
+DROP TABLE IF EXISTS roster_groups;

migrations/20250914121222_main.up.sql

@@ -0,0 +1,148 @@
+CREATE TABLE IF NOT EXISTS users (
+    id BIGSERIAL PRIMARY KEY,
+    email TEXT NOT NULL UNIQUE,
+    verified_email BOOLEAN NOT NULL,
+    username TEXT NOT NULL UNIQUE,
+    pw_hash TEXT NOT NULL,
+    pw_salt TEXT NOT NULL,
+    pfp_id BIGINT NOT NULL,
+    rank_id BIGINT NOT NULL,
+    group_id BIGINT NOT NULL
+    
+    -- NOTE: Constraint added later to deal with circular dependency
+    -- CONSTRAINT fk_group FOREIGN KEY (group_id) REFERENCES roster_group(id)
+    -- CONSTRAINT fk_rank FOREIGN KEY (rank_id) REFERENCES ranks(id)
+);
+
+CREATE TABLE IF NOT EXISTS sessions (
+    id BIGSERIAL NOT NULL PRIMARY KEY,
+    user_id BIGINT NOT NULL,
+    session_key TEXT NOT NULL UNIQUE,
+    expires BIGINT NOT NULL,
+    CONSTRAINT fk_user FOREIGN KEY(user_id) REFERENCES users(id) ON DELETE CASCADE
+);
+
+CREATE TABLE IF NOT EXISTS ranks (
+    id BIGSERIAL PRIMARY KEY NOT NULL,
+    name TEXT NOT NULL,
+    description TEXT NOT NULL,
+    created_at BIGINT NOT NULL,
+    modified_at BIGINT NOT NULL
+);
+CREATE TABLE IF NOT EXISTS awards (
+    id BIGSERIAL PRIMARY KEY NOT NULL,
+    name TEXT NOT NULL,
+    description TEXT NOT NULL,
+    created_at BIGINT NOT NULL,
+    modified_at BIGINT NOT NULL
+);
+CREATE TABLE IF NOT EXISTS trainings (
+    id BIGSERIAL PRIMARY KEY NOT NULL,
+    name TEXT NOT NULL,
+    description TEXT NOT NULL,
+    created_at BIGINT NOT NULL,
+    modified_at BIGINT NOT NULL
+);
+CREATE TABLE IF NOT EXISTS missions (
+    id BIGSERIAL PRIMARY KEY NOT NULL,
+    name TEXT NOT NULL,
+    description TEXT NOT NULL,
+    starting_at BIGINT NOT NULL,
+    estimated_length BIGINT NOT NULL,
+    created_at BIGINT NOT NULL,
+    modified_at BIGINT NOT NULL
+);
+CREATE TABLE IF NOT EXISTS qualifications (
+    id BIGSERIAL PRIMARY KEY NOT NULL,
+    name TEXT NOT NULL,
+    description TEXT NOT NULL,
+    created_at BIGINT NOT NULL,
+    modified_at BIGINT NOT NULL
+);
+
+CREATE TABLE IF NOT EXISTS attendance (
+    id BIGSERIAL PRIMARY KEY NOT NULL,
+    user_id BIGINT NOT NULL,
+    mission_id BIGINT NOT NULL,
+    confirmed_at BIGINT NOT NULL,
+    attending BOOL NOT NULL,
+
+    CONSTRAINT fk_user FOREIGN KEY(user_id) REFERENCES users(id) ON DELETE SET NULL,
+    CONSTRAINT fk_mission FOREIGN KEY(mission_id) REFERENCES missions(id) ON DELETE CASCADE
+);
+
+CREATE TABLE IF NOT EXISTS roster_groups (
+    id BIGSERIAL NOT NULL PRIMARY KEY,
+    name TEXT NOT NULL,
+    sort_order BIGINT NOT NULL,
+    manager_id BIGINT NOT NULL,
+
+    CONSTRAINT fk_manager FOREIGN KEY(manager_id) REFERENCES users(id) ON DELETE SET NULL
+);
+
+
+-- NOTE: For table 'users'
+ALTER TABLE users ADD FOREIGN KEY (group_id) REFERENCES roster_groups(id) ON DELETE SET NULL;
+ALTER TABLE users ADD FOREIGN KEY (rank_id) REFERENCES ranks(id) ON DELETE SET NULL;
+
+--------------------
+-- NOTE: Records
+--------------------
+
+
+CREATE TABLE IF NOT EXISTS records_ranks (
+    id BIGSERIAL PRIMARY KEY NOT NULL,
+    user_id BIGINT NOT NULL,
+    rank_id BIGINT NOT NULL,
+    author_id BIGINT NOT NULL,
+    created_at BIGINT NOT NULL,
+
+    CONSTRAINT fk_user FOREIGN KEY(user_id) REFERENCES users(id) ON DELETE CASCADE,
+    CONSTRAINT fk_author FOREIGN KEY(author_id) REFERENCES users(id) ON DELETE SET NULL,
+    CONSTRAINT fk_rank FOREIGN KEY (rank_id) REFERENCES ranks(id) ON DELETE CASCADE
+);
+CREATE TABLE IF NOT EXISTS records_awards (
+    id BIGSERIAL PRIMARY KEY NOT NULL,
+    user_id BIGINT NOT NULL,
+    award_id BIGINT NOT NULL,
+    author_id BIGINT NOT NULL,
+    created_at BIGINT NOT NULL,
+
+    CONSTRAINT fk_user FOREIGN KEY(user_id) REFERENCES users(id) ON DELETE CASCADE,
+    CONSTRAINT fk_author FOREIGN KEY(author_id) REFERENCES users(id) ON DELETE SET NULL,
+    CONSTRAINT fk_award FOREIGN KEY (award_id) REFERENCES awards(id) ON DELETE CASCADE
+);
+CREATE TABLE IF NOT EXISTS records_trainings (
+    id BIGSERIAL PRIMARY KEY NOT NULL,
+    user_id BIGINT NOT NULL,
+    training_id BIGINT NOT NULL,
+    author_id BIGINT NOT NULL,
+    created_at BIGINT NOT NULL,
+
+    CONSTRAINT fk_user FOREIGN KEY(user_id) REFERENCES users(id) ON DELETE CASCADE,
+    CONSTRAINT fk_author FOREIGN KEY(author_id) REFERENCES users(id) ON DELETE SET NULL,
+    CONSTRAINT fk_training FOREIGN KEY (training_id) REFERENCES trainings(id) ON DELETE CASCADE
+);
+CREATE TABLE IF NOT EXISTS records_qualifications (
+    id BIGSERIAL PRIMARY KEY NOT NULL,
+    user_id BIGINT NOT NULL,
+    qualification_id BIGINT NOT NULL,
+    author_id BIGINT NOT NULL,
+    created_at BIGINT NOT NULL,
+
+    CONSTRAINT fk_user FOREIGN KEY(user_id) REFERENCES users(id) ON DELETE CASCADE,
+    CONSTRAINT fk_author FOREIGN KEY(author_id) REFERENCES users(id) ON DELETE SET NULL,
+    CONSTRAINT fk_qualification FOREIGN KEY (qualification_id) REFERENCES qualifications(id) ON DELETE CASCADE
+);
+CREATE TABLE IF NOT EXISTS records_missions (
+    id BIGSERIAL PRIMARY KEY NOT NULL,
+    user_id BIGINT NOT NULL,
+    mission_id BIGINT NOT NULL,
+    author_id BIGINT NOT NULL,
+    created_at BIGINT NOT NULL,
+
+    CONSTRAINT fk_user FOREIGN KEY(user_id) REFERENCES users(id) ON DELETE CASCADE,
+    CONSTRAINT fk_author FOREIGN KEY(author_id) REFERENCES users(id) ON DELETE SET NULL,
+    CONSTRAINT fk_mission FOREIGN KEY (mission_id) REFERENCES missions(id) ON DELETE CASCADE
+);
+

persmgr_derive/Cargo.lock

@@ -0,0 +1,101 @@
+# This file is automatically @generated by Cargo.
+# It is not intended for manual editing.
+version = 4
+
+[[package]]
+name = "darling"
+version = "0.13.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a01d95850c592940db9b8194bc39f4bc0e89dee5c4265e4b1807c34a9aba453c"
+dependencies = [
+ "darling_core",
+ "darling_macro",
+]
+
+[[package]]
+name = "darling_core"
+version = "0.13.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "859d65a907b6852c9361e3185c862aae7fafd2887876799fa55f5f99dc40d610"
+dependencies = [
+ "fnv",
+ "ident_case",
+ "proc-macro2",
+ "quote",
+ "strsim",
+ "syn",
+]
+
+[[package]]
+name = "darling_macro"
+version = "0.13.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9c972679f83bdf9c42bd905396b6c3588a843a17f0f16dfcfa3e2c5d57441835"
+dependencies = [
+ "darling_core",
+ "quote",
+ "syn",
+]
+
+[[package]]
+name = "fnv"
+version = "1.0.7"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3f9eec918d3f24069decb9af1554cad7c880e2da24a9afd88aca000531ab82c1"
+
+[[package]]
+name = "ident_case"
+version = "1.0.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b9e0384b61958566e926dc50660321d12159025e767c18e043daf26b70104c39"
+
+[[package]]
+name = "persmgr_derive"
+version = "0.1.0"
+dependencies = [
+ "darling",
+ "proc-macro2",
+ "quote",
+ "syn",
+]
+
+[[package]]
+name = "proc-macro2"
+version = "1.0.101"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "89ae43fd86e4158d6db51ad8e2b80f313af9cc74f5c0e03ccb87de09998732de"
+dependencies = [
+ "unicode-ident",
+]
+
+[[package]]
+name = "quote"
+version = "1.0.40"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1885c039570dc00dcb4ff087a89e185fd56bae234ddc7f056a945bf36467248d"
+dependencies = [
+ "proc-macro2",
+]
+
+[[package]]
+name = "strsim"
+version = "0.10.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "73473c0e59e6d5812c5dfe2a064a6444949f089e20eec9a2e5506596494e4623"
+
+[[package]]
+name = "syn"
+version = "1.0.109"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "72b64191b275b66ffe2469e8af2c1cfe3bafa67b529ead792a6d0160888b4237"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "unicode-ident",
+]
+
+[[package]]
+name = "unicode-ident"
+version = "1.0.19"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f63a545481291138910575129486daeaf8ac54aee4387fe7906919f7830c7d9d"

persmgr_derive/Cargo.toml

@@ -0,0 +1,13 @@
+[package]
+name = "persmgr_derive"
+version = "0.1.0"
+edition = "2024"
+
+[lib]
+proc-macro = true
+
+[dependencies]
+quote = "1"
+proc-macro2 = "1"
+syn = { version = "1", features = ["full"] }
+darling = "0.13"

persmgr_derive/src/lib.rs

@@ -0,0 +1,106 @@
+use darling::FromDeriveInput;
+use proc_macro::{self, TokenStream};
+use quote::quote;
+use syn::{Data, Expr, Fields, Type, parse_macro_input};
+
+#[derive(FromDeriveInput, Default)]
+#[darling(default, attributes(meta))]
+struct Opts {
+    table: String,
+    key_t: Option<Expr>,
+}
+
+#[proc_macro_derive(TableMeta, attributes(meta))]
+pub fn derive_table_meta(input: TokenStream) -> TokenStream {
+    let input = parse_macro_input!(input);
+    let opts = Opts::from_derive_input(&input)
+        .expect("Expected attribute #[meta(table=\"users\", key_t=i32)]");
+
+    let mut struct_items = Vec::new();
+
+    if let Data::Struct(data) = &input.data {
+        if let Fields::Named(fields) = &data.fields {
+            for field in &fields.named {
+                let ident = field.ident.as_ref().unwrap();
+                let s = ident.to_string();
+                if s.as_str() == "id" || s.as_str() == "created_at" {
+                    continue;
+                }
+                let mut should_deref = false;
+                if let Type::Path(tp) = &field.ty {
+                    if tp.path.segments.first().unwrap().ident == "ForeignKey" {
+                        should_deref = true;
+                    }
+                }
+
+                struct_items.push((ident, should_deref));
+            }
+        }
+    }
+
+    let ident = input.ident;
+    let table_name = opts.table;
+    let key_t = opts
+        .key_t
+        .unwrap_or_else(|| syn::parse_str::<Expr>("i64").unwrap());
+
+    // dbg!(&table_name);
+    //dbg!(&key_t);
+
+    let mut query = format!("UPDATE {table_name} SET ");
+    let mut query_args = quote!(self.id);
+    let mut i = 2;
+    let mut modified_update = false;
+    for (item, should_deref) in &struct_items {
+        let s = item.to_string();
+        //dbg!(&s);
+
+        if s.as_str() == "modified_at" {
+            modified_update = true;
+        }
+
+        if i != 2 {
+            query.push_str(", ");
+        }
+        query.push_str(s.as_str());
+        query.push_str(&format!(" = ${i} "));
+        i += 1;
+
+        let deref = if *should_deref { quote!(*) } else { quote!() };
+
+        query_args = quote! {
+            #query_args, #deref self.#item
+        };
+    }
+    query.push_str("WHERE id = $1 RETURNING *");
+
+    let mut modified_at = quote! {};
+
+    if modified_update {
+        modified_at = quote! {
+            self.modified_at = time::OffsetDateTime::now_utc().unix_timestamp();
+        }
+    }
+
+    let output = quote! {
+        impl TableMeta for #ident {
+            type PrimaryKey = #key_t;
+            const TABLE: &'static str = #table_name;
+            async fn update(&mut self, pool: &crate::db::CurrPool) -> anyhow::Result<Self> {
+                #modified_at
+                let session = sqlx::query_as!(
+                    #ident,
+                    #query,
+                    #query_args
+                )
+                .fetch_one(pool)
+                .await?;
+                Ok(session)
+            }
+        }
+    };
+
+    // eprintln!("{}", output.to_string());
+
+    output.into()
+}

src/api/files/create.rs

@@ -1,7 +1,6 @@
 use axum::{
-    body::{Body, Bytes},
-    extract::{Path, State},
-    http::{HeaderMap, HeaderValue, StatusCode},
+    extract::State,
+    http::StatusCode,
     response::{IntoResponse, Response},
 };
 use serde::Deserialize;
@@ -14,7 +13,7 @@ pub struct Data {
 }
 
 #[axum::debug_handler]
-pub async fn route(State(db): State<Database>) -> impl IntoResponse {
+pub async fn route(State(_db): State<Database>) -> impl IntoResponse {
     if false {
         return Response::builder()
             .status(StatusCode::NOT_FOUND)

src/api/files/delete.rs

@@ -1,7 +1,6 @@
 use axum::{
-    body::{Body, Bytes},
-    extract::{Path, State},
-    http::{HeaderMap, HeaderValue, StatusCode},
+    extract::State,
+    http::StatusCode,
     response::{IntoResponse, Response},
 };
 use serde::Deserialize;
@@ -27,4 +26,3 @@ pub async fn route(State(db): State<Database>) -> impl IntoResponse {
         .body(String::new())
         .unwrap()
 }
-

src/api/files/get_file.rs

@@ -1,7 +1,6 @@
 use axum::{
-    body::{Body, Bytes},
-    extract::{Path, State},
-    http::{HeaderMap, HeaderValue, StatusCode},
+    extract::State,
+    http::StatusCode,
     response::{IntoResponse, Response},
 };
 use serde::Deserialize;
@@ -27,4 +26,3 @@ pub async fn route(State(db): State<Database>) -> impl IntoResponse {
         .body(String::new())
         .unwrap()
 }
-

src/api/files/mkdir.rs

@@ -1,7 +1,6 @@
 use axum::{
-    body::{Body, Bytes},
-    extract::{Path, State},
-    http::{HeaderMap, HeaderValue, StatusCode},
+    extract::State,
+    http::StatusCode,
     response::{IntoResponse, Response},
 };
 use serde::Deserialize;
@@ -27,4 +26,3 @@ pub async fn route(State(db): State<Database>) -> impl IntoResponse {
         .body(String::new())
         .unwrap()
 }
-

src/api/files/rmdir.rs

@@ -1,7 +1,6 @@
 use axum::{
-    body::{Body, Bytes},
-    extract::{Path, State},
-    http::{HeaderMap, HeaderValue, StatusCode},
+    extract::State,
+    http::StatusCode,
     response::{IntoResponse, Response},
 };
 use serde::Deserialize;
@@ -27,4 +26,3 @@ pub async fn route(State(db): State<Database>) -> impl IntoResponse {
         .body(String::new())
         .unwrap()
 }
-

src/api/mod.rs

@@ -4,7 +4,7 @@ use axum::{Router, extract::State, http::StatusCode, routing::get};
 pub mod files;
 pub mod user;
 
-async fn root(State(state): State<Database>) -> (StatusCode, &'static str) {
+async fn root(State(_state): State<Database>) -> (StatusCode, &'static str) {
     (StatusCode::OK, "We Good twin :3c")
 }
 

src/api/user/login.rs

@@ -1,9 +1,4 @@
-use axum::{
-    body::Body,
-    extract::State,
-    http::{HeaderMap, HeaderValue, StatusCode},
-    response::{IntoResponse, Response},
-};
+use axum::{body::Body, extract::State, http::StatusCode, response::Response};
 
 use crate::db::Database;
 

src/api/user/mod.rs

@@ -1,7 +1,4 @@
-use axum::{
-    Router,
-    routing::{get, post},
-};
+use axum::{Router, routing::post};
 
 use crate::db::Database;
 

src/db/auth.rs

@@ -0,0 +1,82 @@
+use anyhow::bail;
+use axum::{
+    http::{Response, StatusCode},
+    response::{Html, IntoResponse},
+};
+
+use crate::db::{
+    Database,
+    tables::{sessions::Session, user::User},
+};
+
+pub enum AuthResultApi<R: Default> {
+    Ok(User),
+    Error(Response<R>),
+}
+
+pub enum AuthResultWeb {
+    Ok(User),
+    Error((StatusCode, Html<String>)),
+}
+
+#[derive(Debug)]
+pub struct Auth;
+
+impl Auth {
+    pub async fn check_auth(
+        db: &Database,
+        session: tower_sessions::Session,
+        token: &String,
+    ) -> anyhow::Result<User> {
+        let mut user_session: crate::Session = session
+            .get(crate::Session::KEY)
+            .await
+            .unwrap()
+            .unwrap_or_default();
+
+        if let Some(uid) = user_session.user_id {
+            return Ok(User::get_by_id(db.pool(), uid).await?);
+        }
+
+        if let Ok(session_token) = Session::get_by_session_key(db.pool(), token).await {
+            user_session.user_id = Some(session_token.user_id);
+            session
+                .insert(crate::Session::KEY, user_session)
+                .await
+                .unwrap();
+            return Ok(User::get_by_id(db.pool(), session_token.user_id).await?);
+        }
+
+        bail!("Unable to find user by this token")
+    }
+
+    pub async fn check_auth_api<R: Default>(
+        db: &Database,
+        session: tower_sessions::Session,
+        token: &String,
+    ) -> AuthResultApi<R> {
+        match Self::check_auth(db, session, token).await {
+            Ok(r) => AuthResultApi::Ok(r),
+            Err(_) => AuthResultApi::Error(
+                Response::builder()
+                    .status(StatusCode::UNAUTHORIZED)
+                    .header("Location", "/")
+                    .body(R::default())
+                    .unwrap(),
+            ),
+        }
+    }
+
+    pub async fn check_auth_web<R: Default>(
+        db: &Database,
+        session: tower_sessions::Session,
+        token: &String,
+    ) -> AuthResultWeb {
+        match Self::check_auth(db, session, token).await {
+            Ok(r) => AuthResultWeb::Ok(r),
+            Err(_) => {
+                AuthResultWeb::Error((StatusCode::UNAUTHORIZED, Html("UNAUTHORIZED".to_string())))
+            }
+        }
+    }
+}

src/db/mod.rs

@@ -1,8 +1,8 @@
 use anyhow::Result;
 use sqlx::{Pool, Postgres, postgres::PgPoolOptions};
 
+pub mod auth;
 pub mod tables;
-
 pub type CurrDb = Postgres;
 pub type CurrPool = Pool<CurrDb>;
 

src/db/tables/assignables/awards.rs

@@ -1,9 +1,11 @@
 use anyhow::Result;
+use persmgr_derive::TableMeta;
 use sqlx::prelude::FromRow;
 
 use crate::db::{CurrPool, tables::TableMeta};
 
-#[derive(Debug, Default, Clone, FromRow)]
+#[derive(Debug, Default, Clone, FromRow, TableMeta)]
+#[meta(table = "awards")]
 pub struct Award {
     pub id: i64,
     pub name: String,
@@ -12,11 +14,6 @@ pub struct Award {
     pub modified_at: i64,
 }
 
-impl TableMeta<'_> for Award {
-    type PrimaryKey = i64;
-    const TABLE: &'static str = "awards";
-}
-
 impl Award {
     pub async fn insert_new(&self, pool: &CurrPool) -> Result<Self> {
         let session = sqlx::query_as!(
@@ -42,25 +39,4 @@ impl Award {
             .await?;
         Ok(session)
     }
-    pub async fn update(&self, pool: &CurrPool) -> anyhow::Result<Self> {
-        let curr_time = time::OffsetDateTime::now_utc().unix_timestamp();
-        let session = sqlx::query_as!(
-            Award,
-            r#"
-                UPDATE awards SET 
-                name = $2,
-                description = $3,
-                modified_at = $4
-                WHERE id = $1
-                RETURNING *
-                "#,
-            self.id,
-            self.name,
-            self.description,
-            curr_time
-        )
-        .fetch_one(pool)
-        .await?;
-        Ok(session)
-    }
 }

src/db/tables/assignables/missions.rs

@@ -1,9 +1,11 @@
 use anyhow::Result;
+use persmgr_derive::TableMeta;
 use sqlx::prelude::FromRow;
 
 use crate::db::{CurrPool, tables::TableMeta};
 
-#[derive(Debug, Default, Clone, FromRow)]
+#[derive(Debug, Default, Clone, FromRow, TableMeta)]
+#[meta(table = "missions")]
 pub struct Mission {
     pub id: i64,
     pub name: String,
@@ -13,12 +15,6 @@ pub struct Mission {
     pub created_at: i64,
     pub modified_at: i64,
 }
-
-impl TableMeta<'_> for Mission {
-    type PrimaryKey = i64;
-    const TABLE: &'static str = "missions";
-}
-
 impl Mission {
     pub async fn insert_new(&self, pool: &CurrPool) -> Result<Self> {
         let session = sqlx::query_as!(
@@ -44,25 +40,4 @@ impl Mission {
             .await?;
         Ok(session)
     }
-    pub async fn update(&self, pool: &CurrPool) -> anyhow::Result<Self> {
-        let curr_time = time::OffsetDateTime::now_utc().unix_timestamp();
-        let session = sqlx::query_as!(
-            Mission,
-            r#"
-                UPDATE missions SET 
-                name = $2,
-                description = $3,
-                modified_at = $4
-                WHERE id = $1
-                RETURNING *
-                "#,
-            self.id,
-            self.name,
-            self.description,
-            curr_time
-        )
-        .fetch_one(pool)
-        .await?;
-        Ok(session)
-    }
 }

src/db/tables/assignables/qualifications.rs

@@ -1,9 +1,11 @@
 use anyhow::Result;
+use persmgr_derive::TableMeta;
 use sqlx::prelude::FromRow;
 
 use crate::db::{CurrPool, tables::TableMeta};
 
-#[derive(Debug, Default, Clone, FromRow)]
+#[derive(Debug, Default, Clone, FromRow, TableMeta)]
+#[meta(table = "qualifications")]
 pub struct Qualification {
     pub id: i64,
     pub name: String,
@@ -12,11 +14,6 @@ pub struct Qualification {
     pub modified_at: i64,
 }
 
-impl TableMeta<'_> for Qualification {
-    type PrimaryKey = i64;
-    const TABLE: &'static str = "qualifications";
-}
-
 impl Qualification {
     pub async fn insert_new(&self, pool: &CurrPool) -> Result<Self> {
         let session = sqlx::query_as!(
@@ -46,25 +43,4 @@ impl Qualification {
         .await?;
         Ok(session)
     }
-    pub async fn update(&self, pool: &CurrPool) -> anyhow::Result<Self> {
-        let curr_time = time::OffsetDateTime::now_utc().unix_timestamp();
-        let session = sqlx::query_as!(
-            Qualification,
-            r#"
-                UPDATE qualifications SET 
-                name = $2,
-                description = $3,
-                modified_at = $4
-                WHERE id = $1
-                RETURNING *
-                "#,
-            self.id,
-            self.name,
-            self.description,
-            curr_time
-        )
-        .fetch_one(pool)
-        .await?;
-        Ok(session)
-    }
 }

src/db/tables/assignables/ranks.rs

@@ -1,9 +1,11 @@
 use anyhow::Result;
+use persmgr_derive::TableMeta;
 use sqlx::prelude::FromRow;
 
 use crate::db::{CurrPool, tables::TableMeta};
 
-#[derive(Debug, Default, Clone, FromRow)]
+#[derive(Debug, Default, Clone, FromRow, TableMeta)]
+#[meta(table = "ranks")]
 pub struct Rank {
     pub id: i64,
     pub name: String,
@@ -12,11 +14,6 @@ pub struct Rank {
     pub modified_at: i64,
 }
 
-impl TableMeta<'_> for Rank {
-    type PrimaryKey = i64;
-    const TABLE: &'static str = "ranks";
-}
-
 impl Rank {
     pub async fn insert_new(&self, pool: &CurrPool) -> Result<Self> {
         let session = sqlx::query_as!(
@@ -42,25 +39,4 @@ impl Rank {
             .await?;
         Ok(session)
     }
-    pub async fn update(&self, pool: &CurrPool) -> anyhow::Result<Self> {
-        let curr_time = time::OffsetDateTime::now_utc().unix_timestamp();
-        let session = sqlx::query_as!(
-            Rank,
-            r#"
-                UPDATE ranks SET 
-                name = $2,
-                description = $3,
-                modified_at = $4
-                WHERE id = $1
-                RETURNING *
-                "#,
-            self.id,
-            self.name,
-            self.description,
-            curr_time
-        )
-        .fetch_one(pool)
-        .await?;
-        Ok(session)
-    }
 }

src/db/tables/assignables/trainings.rs

@@ -1,9 +1,11 @@
 use anyhow::Result;
+use persmgr_derive::TableMeta;
 use sqlx::prelude::FromRow;
 
 use crate::db::{CurrPool, tables::TableMeta};
 
-#[derive(Debug, Default, Clone, FromRow)]
+#[derive(Debug, Default, Clone, FromRow, TableMeta)]
+#[meta(table = "trainings")]
 pub struct Training {
     pub id: i64,
     pub name: String,
@@ -12,11 +14,6 @@ pub struct Training {
     pub modified_at: i64,
 }
 
-impl TableMeta<'_> for Training {
-    type PrimaryKey = i64;
-    const TABLE: &'static str = "trainings";
-}
-
 impl Training {
     pub async fn insert_new(&self, pool: &CurrPool) -> Result<Self> {
         let session = sqlx::query_as!(
@@ -42,25 +39,4 @@ impl Training {
             .await?;
         Ok(session)
     }
-    pub async fn update(&self, pool: &CurrPool) -> anyhow::Result<Self> {
-        let curr_time = time::OffsetDateTime::now_utc().unix_timestamp();
-        let session = sqlx::query_as!(
-            Training,
-            r#"
-                UPDATE trainings SET 
-                name = $2,
-                description = $3,
-                modified_at = $4
-                WHERE id = $1
-                RETURNING *
-                "#,
-            self.id,
-            self.name,
-            self.description,
-            curr_time
-        )
-        .fetch_one(pool)
-        .await?;
-        Ok(session)
-    }
 }

src/db/tables/groups.rs

@@ -0,0 +1,53 @@
+use anyhow::Result;
+use persmgr_derive::TableMeta;
+use sqlx::prelude::FromRow;
+
+use crate::db::{
+    CurrPool,
+    tables::{ForeignKey, TableMeta, user::User},
+};
+
+#[derive(Debug, Default, Clone, FromRow, TableMeta)]
+#[meta(table = "roster_groups")]
+pub struct Groups {
+    pub id: i64,
+    pub name: String,
+    pub manager_id: ForeignKey<User>,
+    pub sort_order: i64,
+}
+
+impl Groups {
+    pub async fn insert_new(&self, pool: &CurrPool) -> Result<Self> {
+        let session = sqlx::query_as!(
+            Groups,
+            r#"
+                INSERT INTO roster_groups (name, manager_id, sort_order)
+                VALUES ($1, $2, $3)
+                RETURNING *
+            "#,
+            self.name,
+            *self.manager_id,
+            self.sort_order,
+        )
+        .fetch_one(pool)
+        .await?;
+
+        Ok(session)
+    }
+    pub async fn get_by_id(pool: &CurrPool, id: i64) -> anyhow::Result<Self> {
+        let session = sqlx::query_as!(Groups, "SELECT * FROM roster_groups WHERE id = $1", id)
+            .fetch_one(pool)
+            .await?;
+        Ok(session)
+    }
+    pub async fn get_by_manager_id(pool: &CurrPool, id: i64) -> anyhow::Result<Vec<Self>> {
+        let session = sqlx::query_as!(
+            Groups,
+            "SELECT * FROM roster_groups WHERE manager_id = $1",
+            id
+        )
+        .fetch_all(pool)
+        .await?;
+        Ok(session)
+    }
+}

src/db/tables/mod.rs

@@ -4,29 +4,32 @@ use std::{
     ops::{Deref, DerefMut},
 };
 
-use sqlx::{Decode, Encode, QueryBuilder, Type, postgres::PgRow};
+use sqlx::{Decode, QueryBuilder, Type, postgres::PgRow};
 
 pub mod assignables;
 pub mod attendance;
+pub mod groups;
 pub mod records;
 pub mod sessions;
 pub mod user;
 
-pub trait TableMeta<'a>: for<'r> sqlx::FromRow<'r, PgRow> {
-    type PrimaryKey: Encode<'a, super::CurrDb> + Type<super::CurrDb> + Clone;
+pub trait TableMeta: for<'r> sqlx::FromRow<'r, PgRow> {
+    type PrimaryKey: Type<super::CurrDb> + Clone;
     const TABLE: &'static str;
+    async fn update(&mut self, pool: &crate::db::CurrPool) -> anyhow::Result<Self>;
 }
 
 #[derive(Debug, Clone, Default)]
-pub struct ForeignKey<'a, FK: TableMeta<'a>> {
+pub struct ForeignKey<FK: TableMeta> {
     id: FK::PrimaryKey,
     _ft: PhantomData<FK>,
 }
 
-impl<'a, FK: TableMeta<'a> + Send + for<'r> sqlx::FromRow<'r, PgRow> + Unpin + 'a>
-    ForeignKey<'a, FK>
-{
-    pub async fn extract(&self, db: &super::CurrPool) -> anyhow::Result<FK> {
+impl<'a, FK: TableMeta + Send + for<'r> sqlx::FromRow<'r, PgRow> + Unpin + 'a> ForeignKey<FK> {
+    pub async fn extract(&self, db: &super::CurrPool) -> anyhow::Result<FK>
+    where
+        <FK as TableMeta>::PrimaryKey: for<'b> sqlx::Encode<'b, super::CurrDb>,
+    {
         let id = self.id.clone();
 
         let res = QueryBuilder::new("")
@@ -40,39 +43,44 @@ impl<'a, FK: TableMeta<'a> + Send + for<'r> sqlx::FromRow<'r, PgRow> + Unpin + '
     }
 }
 
-impl<'a, TM: TableMeta<'a>> Type<super::CurrDb> for ForeignKey<'a, TM> {
+impl<'a, TM: TableMeta> Type<super::CurrDb> for ForeignKey<TM> {
     fn type_info() -> <super::CurrDb as sqlx::Database>::TypeInfo {
         TM::PrimaryKey::type_info()
     }
 }
 
-impl<'a, TM: TableMeta<'a>> Decode<'a, super::CurrDb> for ForeignKey<'a, TM>
+impl<'a, TM: TableMeta> Decode<'a, super::CurrDb> for ForeignKey<TM>
 where
     &'a str: Decode<'a, super::CurrDb>,
-    <TM as TableMeta<'a>>::PrimaryKey: sqlx::Decode<'a, super::CurrDb>,
+    <TM as TableMeta>::PrimaryKey: sqlx::Decode<'a, super::CurrDb>,
 {
     fn decode(
         value: <super::CurrDb as sqlx::Database>::ValueRef<'a>,
     ) -> Result<Self, Box<dyn Error + 'static + Send + Sync>> {
-        <TM::PrimaryKey as Decode<super::CurrDb>>::decode(value);
-        todo!()
+        match <TM::PrimaryKey as Decode<super::CurrDb>>::decode(value) {
+            Ok(v) => Ok(Self {
+                id: v,
+                _ft: PhantomData,
+            }),
+            Err(e) => Err(e),
+        }
     }
 }
 
-impl<'a, TM: TableMeta<'a>> Deref for ForeignKey<'a, TM> {
+impl<TM: TableMeta> Deref for ForeignKey<TM> {
     type Target = TM::PrimaryKey;
     fn deref(&self) -> &Self::Target {
         &self.id
     }
 }
 
-impl<'a, TM: TableMeta<'a>> DerefMut for ForeignKey<'a, TM> {
+impl<TM: TableMeta> DerefMut for ForeignKey<TM> {
     fn deref_mut(&mut self) -> &mut Self::Target {
         &mut self.id
     }
 }
 
-impl<'a, FK: TableMeta<'a, PrimaryKey = i64>> From<i64> for ForeignKey<'a, FK> {
+impl<FK: TableMeta<PrimaryKey = i64>> From<i64> for ForeignKey<FK> {
     fn from(value: FK::PrimaryKey) -> Self {
         Self {
             id: value,

src/db/tables/records/awards.rs

@@ -1,4 +1,5 @@
 use anyhow::Result;
+use persmgr_derive::TableMeta;
 use sqlx::prelude::FromRow;
 
 use crate::db::{
@@ -6,21 +7,17 @@ use crate::db::{
     tables::{ForeignKey, TableMeta, assignables::awards::Award, user::User},
 };
 
-#[derive(Debug, Default, Clone, FromRow)]
-pub struct AwardRecord<'a> {
+#[derive(Debug, Default, Clone, FromRow, TableMeta)]
+#[meta(table = "records_awards")]
+pub struct AwardRecord {
     pub id: i64,
-    pub user_id: ForeignKey<'a, User>,
-    pub award_id: ForeignKey<'a, Award>,
-    pub author_id: ForeignKey<'a, User>,
+    pub user_id: ForeignKey<User>,
+    pub award_id: ForeignKey<Award>,
+    pub author_id: ForeignKey<User>,
     pub created_at: i64,
 }
 
-impl<'a> TableMeta<'a> for AwardRecord<'a> {
-    type PrimaryKey = i64;
-    const TABLE: &'static str = "records_awards";
-}
-
-impl AwardRecord<'_> {
+impl AwardRecord {
     pub async fn insert_new(&self, pool: &CurrPool) -> Result<Self> {
         let session = sqlx::query_as!(
             AwardRecord,
@@ -37,7 +34,7 @@ impl AwardRecord<'_> {
         .fetch_one(pool)
         .await?;
 
-        self.author_id.extract(pool);
+        let user = self.author_id.extract(pool).await?;
 
         Ok(session)
     }

src/db/tables/records/missions.rs

@@ -1,4 +1,5 @@
 use anyhow::Result;
+use persmgr_derive::TableMeta;
 use sqlx::prelude::FromRow;
 
 use crate::db::{
@@ -6,21 +7,17 @@ use crate::db::{
     tables::{ForeignKey, TableMeta, assignables::missions::Mission, user::User},
 };
 
-#[derive(Debug, Default, Clone, FromRow)]
-pub struct MissionRecord<'a> {
+#[derive(Debug, Default, Clone, FromRow, TableMeta)]
+#[meta(table = "records_missions")]
+pub struct MissionRecord {
     pub id: i64,
-    pub user_id: ForeignKey<'a, User>,
-    pub mission_id: ForeignKey<'a, Mission>,
-    pub author_id: ForeignKey<'a, User>,
+    pub user_id: ForeignKey<User>,
+    pub mission_id: ForeignKey<Mission>,
+    pub author_id: ForeignKey<User>,
     pub created_at: i64,
 }
 
-impl TableMeta<'_> for MissionRecord<'_> {
-    type PrimaryKey = i64;
-    const TABLE: &'static str = "records_missions";
-}
-
-impl MissionRecord<'_> {
+impl MissionRecord {
     pub async fn insert_new(&self, pool: &CurrPool) -> Result<Self> {
         let session = sqlx::query_as!(
             MissionRecord,

src/db/tables/records/qualifications.rs

@@ -1,4 +1,5 @@
 use anyhow::Result;
+use persmgr_derive::TableMeta;
 use sqlx::prelude::FromRow;
 
 use crate::db::{
@@ -6,21 +7,17 @@ use crate::db::{
     tables::{ForeignKey, TableMeta, assignables::qualifications::Qualification, user::User},
 };
 
-#[derive(Debug, Default, Clone, FromRow)]
-pub struct QualificationRecord<'a> {
+#[derive(Debug, Default, Clone, FromRow, TableMeta)]
+#[meta(table = "records_qualifications")]
+pub struct QualificationRecord {
     pub id: i64,
-    pub user_id: ForeignKey<'a, User>,
-    pub author_id: ForeignKey<'a, User>,
-    pub qualification_id: ForeignKey<'a, Qualification>,
+    pub user_id: ForeignKey<User>,
+    pub author_id: ForeignKey<User>,
+    pub qualification_id: ForeignKey<Qualification>,
     pub created_at: i64,
 }
 
-impl<'a> TableMeta<'a> for QualificationRecord<'a> {
-    type PrimaryKey = i64;
-    const TABLE: &'static str = "records_qualifications";
-}
-
-impl<'a> QualificationRecord<'a> {
+impl QualificationRecord {
     pub async fn insert_new(&self, pool: &CurrPool) -> Result<Self> {
         let session = sqlx::query_as!(
             QualificationRecord,

src/db/tables/records/ranks.rs

@@ -1,4 +1,5 @@
 use anyhow::Result;
+use persmgr_derive::TableMeta;
 use sqlx::prelude::FromRow;
 
 use crate::db::{
@@ -6,21 +7,17 @@ use crate::db::{
     tables::{ForeignKey, TableMeta, assignables::ranks::Rank, user::User},
 };
 
-#[derive(Debug, Default, Clone, FromRow)]
-pub struct RankRecord<'a> {
+#[derive(Debug, Default, Clone, FromRow, TableMeta)]
+#[meta(table = "records_ranks")]
+pub struct RankRecord {
     pub id: i64,
-    pub user_id: ForeignKey<'a, User>,
-    pub rank_id: ForeignKey<'a, Rank>,
-    pub author_id: ForeignKey<'a, User>,
+    pub user_id: ForeignKey<User>,
+    pub rank_id: ForeignKey<Rank>,
+    pub author_id: ForeignKey<User>,
     pub created_at: i64,
 }
 
-impl<'a> TableMeta<'a> for RankRecord<'a> {
-    type PrimaryKey = i64;
-    const TABLE: &'static str = "records_ranks";
-}
-
-impl<'a> RankRecord<'a> {
+impl RankRecord {
     pub async fn insert_new(&self, pool: &CurrPool) -> Result<Self> {
         let session = sqlx::query_as!(
             RankRecord,

src/db/tables/records/trainings.rs

@@ -1,4 +1,5 @@
 use anyhow::Result;
+use persmgr_derive::TableMeta;
 use sqlx::prelude::FromRow;
 
 use crate::db::{
@@ -6,21 +7,17 @@ use crate::db::{
     tables::{ForeignKey, TableMeta, assignables::trainings::Training, user::User},
 };
 
-#[derive(Debug, Default, Clone, FromRow)]
-pub struct TrainingRecord<'a> {
+#[derive(Debug, Default, Clone, FromRow, TableMeta)]
+#[meta(table = "records_trainings")]
+pub struct TrainingRecord {
     pub id: i64,
-    pub user_id: ForeignKey<'a, User>,
-    pub training_id: ForeignKey<'a, Training>,
-    pub author_id: ForeignKey<'a, User>,
+    pub user_id: ForeignKey<User>,
+    pub training_id: ForeignKey<Training>,
+    pub author_id: ForeignKey<User>,
     pub created_at: i64,
 }
 
-impl<'a> TableMeta<'a> for TrainingRecord<'a> {
-    type PrimaryKey = i64;
-    const TABLE: &'static str = "records_trainings";
-}
-
-impl<'a> TrainingRecord<'a> {
+impl TrainingRecord {
     pub async fn insert_new(&self, pool: &CurrPool) -> Result<Self> {
         let session = sqlx::query_as!(
             TrainingRecord,

src/db/tables/sessions.rs

@@ -1,20 +1,18 @@
 use anyhow::Result;
+use persmgr_derive::TableMeta;
 use sqlx::prelude::FromRow;
 
 use crate::db::{CurrPool, tables::TableMeta};
 
-#[derive(Debug, Default, Clone, FromRow)]
+#[derive(Debug, Default, Clone, FromRow, TableMeta)]
+#[meta(table = "sessions")]
 pub struct Session {
+    pub id: i64,
     pub user_id: i64,
     pub session_key: String,
     pub expires: i64,
 }
 
-impl TableMeta<'_> for Session {
-    type PrimaryKey = i64;
-    const TABLE: &'static str = "sessions";
-}
-
 impl Session {
     pub async fn insert_new(&self, pool: &CurrPool) -> Result<Self> {
         let session = sqlx::query_as!(
@@ -43,7 +41,7 @@ impl Session {
         .await?;
         Ok(session)
     }
-    pub async fn get_by_session_key(pool: &CurrPool, session_key: String) -> anyhow::Result<Self> {
+    pub async fn get_by_session_key(pool: &CurrPool, session_key: &String) -> anyhow::Result<Self> {
         let session = sqlx::query_as!(
             Session,
             "SELECT * FROM sessions WHERE session_key = $1",

src/db/tables/user.rs

@@ -1,8 +1,12 @@
-use anyhow::bail;
+use persmgr_derive::TableMeta;
 use sqlx::prelude::FromRow;
 
-use crate::db::{CurrPool, tables::TableMeta};
-#[derive(Debug, Default, Clone, FromRow)]
+use crate::db::{
+    CurrPool,
+    tables::{ForeignKey, TableMeta, assignables::ranks::Rank, groups::Groups},
+};
+#[derive(Debug, Default, Clone, FromRow, TableMeta)]
+#[meta(table = "users")]
 pub struct User {
     pub id: i64,
     pub email: String,
@@ -11,12 +15,8 @@ pub struct User {
     pub pw_hash: String,
     pub pw_salt: String,
     pub pfp_id: i64,
-    pub rank_id: i64,
-}
-
-impl TableMeta<'_> for User {
-    type PrimaryKey = i64;
-    const TABLE: &'static str = "users";
+    pub rank_id: ForeignKey<Rank>,
+    pub group_id: ForeignKey<Groups>,
 }
 
 impl User {

src/main.rs

@@ -1,4 +1,5 @@
 use axum::Router;
+use serde::{Deserialize, Serialize};
 use tower::ServiceBuilder;
 use tower_cookies::cookie::time::Duration;
 use tower_http::{services::ServeDir, trace::TraceLayer};
@@ -10,6 +11,16 @@ mod api;
 mod db;
 mod pages;
 
+#[derive(Debug, Serialize, Deserialize, Default)]
+pub struct Session {
+    // None if unauthed yet
+    user_id: Option<i64>,
+}
+
+impl Session {
+    const KEY: &'static str = "user_session";
+}
+
 #[tokio::main]
 async fn main() {
     let sub = FmtSubscriber::builder()