Initial commit

2026-01-26 00:37:35 +01:00
commit f303cb46b7
30 changed files with 2251 additions and 0 deletions
--- a/Sources/ExodaiAcademy/Infrastructure/Base
+++ b/Sources/ExodaiAcademy/Infrastructure/Base
@@ -0,0 +1,268 @@
+//
+//  Countries.swift
+//  ExodaiAcademy
+//
+//  Created by Exodai on 22/01/2026.
+//
+
+import Foundation
+import Vapor
+
+enum CountryCode: String, Codable, CaseIterable {
+    case af = "AF" // Afghanistan
+    case ax = "AX" // Åland Islands
+    case al = "AL" // Albania
+    case dz = "DZ" // Algeria
+    case aS = "AS" // American Samoa
+    case ad = "AD" // Andorra
+    case ao = "AO" // Angola
+    case ai = "AI" // Anguilla
+    case aq = "AQ" // Antarctica
+    case ag = "AG" // Antigua and Barbuda
+    case ar = "AR" // Argentina
+    case am = "AM" // Armenia
+    case aw = "AW" // Aruba
+    case au = "AU" // Australia
+    case at = "AT" // Austria
+    case az = "AZ" // Azerbaijan
+    case bs = "BS" // Bahamas
+    case bh = "BH" // Bahrain
+    case bd = "BD" // Bangladesh
+    case bb = "BB" // Barbados
+    case by = "BY" // Belarus
+    case be = "BE" // Belgium
+    case bz = "BZ" // Belize
+    case bj = "BJ" // Benin
+    case bm = "BM" // Bermuda
+    case bt = "BT" // Bhutan
+    case bo = "BO" // Bolivia
+    case bq = "BQ" // Bonaire, Sint Eustatius and Saba
+    case ba = "BA" // Bosnia and Herzegovina
+    case bw = "BW" // Botswana
+    case bv = "BV" // Bouvet Island
+    case br = "BR" // Brazil
+    case io = "IO" // British Indian Ocean Territory
+    case bn = "BN" // Brunei
+    case bg = "BG" // Bulgaria
+    case bf = "BF" // Burkina Faso
+    case bi = "BI" // Burundi
+    case kh = "KH" // Cambodia
+    case cm = "CM" // Cameroon
+    case ca = "CA" // Canada
+    case cv = "CV" // Cape Verde
+    case ky = "KY" // Cayman Islands
+    case cf = "CF" // Central African Republic
+    case td = "TD" // Chad
+    case cl = "CL" // Chile
+    case cn = "CN" // China
+    case cx = "CX" // Christmas Island
+    case cc = "CC" // Cocos (Keeling) Islands
+    case co = "CO" // Colombia
+    case km = "KM" // Comoros
+    case cg = "CG" // Congo
+    case cd = "CD" // Congo (DRC)
+    case ck = "CK" // Cook Islands
+    case cr = "CR" // Costa Rica
+    case ci = "CI" // Côte d’Ivoire
+    case hr = "HR" // Croatia
+    case cu = "CU" // Cuba
+    case cw = "CW" // Curaçao
+    case cy = "CY" // Cyprus
+    case cz = "CZ" // Czech Republic
+    case dk = "DK" // Denmark
+    case dj = "DJ" // Djibouti
+    case dm = "DM" // Dominica
+    case dO = "DO" // Dominican Republic
+    case ec = "EC" // Ecuador
+    case eg = "EG" // Egypt
+    case sv = "SV" // El Salvador
+    case gq = "GQ" // Equatorial Guinea
+    case er = "ER" // Eritrea
+    case ee = "EE" // Estonia
+    case sz = "SZ" // Eswatini
+    case et = "ET" // Ethiopia
+    case fk = "FK" // Falkland Islands
+    case fo = "FO" // Faroe Islands
+    case fj = "FJ" // Fiji
+    case fi = "FI" // Finland
+    case fr = "FR" // France
+    case gf = "GF" // French Guiana
+    case pf = "PF" // French Polynesia
+    case tf = "TF" // French Southern Territories
+    case ga = "GA" // Gabon
+    case gm = "GM" // Gambia
+    case ge = "GE" // Georgia
+    case de = "DE" // Germany
+    case gh = "GH" // Ghana
+    case gi = "GI" // Gibraltar
+    case gr = "GR" // Greece
+    case gl = "GL" // Greenland
+    case gd = "GD" // Grenada
+    case gp = "GP" // Guadeloupe
+    case gu = "GU" // Guam
+    case gt = "GT" // Guatemala
+    case gg = "GG" // Guernsey
+    case gn = "GN" // Guinea
+    case gw = "GW" // Guinea-Bissau
+    case gy = "GY" // Guyana
+    case ht = "HT" // Haiti
+    case hm = "HM" // Heard Island and McDonald Islands
+    case va = "VA" // Vatican City
+    case hn = "HN" // Honduras
+    case hk = "HK" // Hong Kong
+    case hu = "HU" // Hungary
+    case iS = "IS" // Iceland
+    case iN = "IN" // India
+    case id = "ID" // Indonesia
+    case ir = "IR" // Iran
+    case iq = "IQ" // Iraq
+    case ie = "IE" // Ireland
+    case im = "IM" // Isle of Man
+    case il = "IL" // Israel
+    case it = "IT" // Italy
+    case jm = "JM" // Jamaica
+    case jp = "JP" // Japan
+    case je = "JE" // Jersey
+    case jo = "JO" // Jordan
+    case kz = "KZ" // Kazakhstan
+    case ke = "KE" // Kenya
+    case ki = "KI" // Kiribati
+    case kp = "KP" // North Korea
+    case kr = "KR" // South Korea
+    case kw = "KW" // Kuwait
+    case kg = "KG" // Kyrgyzstan
+    case la = "LA" // Laos
+    case lv = "LV" // Latvia
+    case lb = "LB" // Lebanon
+    case ls = "LS" // Lesotho
+    case lr = "LR" // Liberia
+    case ly = "LY" // Libya
+    case li = "LI" // Liechtenstein
+    case lt = "LT" // Lithuania
+    case lu = "LU" // Luxembourg
+    case mo = "MO" // Macao
+    case mg = "MG" // Madagascar
+    case mw = "MW" // Malawi
+    case my = "MY" // Malaysia
+    case mv = "MV" // Maldives
+    case ml = "ML" // Mali
+    case mt = "MT" // Malta
+    case mh = "MH" // Marshall Islands
+    case mq = "MQ" // Martinique
+    case mr = "MR" // Mauritania
+    case mu = "MU" // Mauritius
+    case yt = "YT" // Mayotte
+    case mx = "MX" // Mexico
+    case fm = "FM" // Micronesia
+    case md = "MD" // Moldova
+    case mc = "MC" // Monaco
+    case mn = "MN" // Mongolia
+    case me = "ME" // Montenegro
+    case ms = "MS" // Montserrat
+    case ma = "MA" // Morocco
+    case mz = "MZ" // Mozambique
+    case mm = "MM" // Myanmar
+    case na = "NA" // Namibia
+    case nr = "NR" // Nauru
+    case np = "NP" // Nepal
+    case nl = "NL" // Netherlands
+    case nc = "NC" // New Caledonia
+    case nz = "NZ" // New Zealand
+    case ni = "NI" // Nicaragua
+    case ne = "NE" // Niger
+    case ng = "NG" // Nigeria
+    case nu = "NU" // Niue
+    case nf = "NF" // Norfolk Island
+    case mk = "MK" // North Macedonia
+    case mp = "MP" // Northern Mariana Islands
+    case no = "NO" // Norway
+    case om = "OM" // Oman
+    case pk = "PK" // Pakistan
+    case pw = "PW" // Palau
+    case ps = "PS" // Palestine
+    case pa = "PA" // Panama
+    case pg = "PG" // Papua New Guinea
+    case py = "PY" // Paraguay
+    case pe = "PE" // Peru
+    case ph = "PH" // Philippines
+    case pn = "PN" // Pitcairn
+    case pl = "PL" // Poland
+    case pt = "PT" // Portugal
+    case pr = "PR" // Puerto Rico
+    case qa = "QA" // Qatar
+    case re = "RE" // Réunion
+    case ro = "RO" // Romania
+    case ru = "RU" // Russia
+    case rw = "RW" // Rwanda
+    case bl = "BL" // Saint Barthélemy
+    case sh = "SH" // Saint Helena
+    case kn = "KN" // Saint Kitts and Nevis
+    case lc = "LC" // Saint Lucia
+    case mf = "MF" // Saint Martin
+    case pm = "PM" // Saint Pierre and Miquelon
+    case vc = "VC" // Saint Vincent and the Grenadines
+    case ws = "WS" // Samoa
+    case sm = "SM" // San Marino
+    case st = "ST" // São Tomé and Príncipe
+    case sa = "SA" // Saudi Arabia
+    case sn = "SN" // Senegal
+    case rs = "RS" // Serbia
+    case sc = "SC" // Seychelles
+    case sl = "SL" // Sierra Leone
+    case sg = "SG" // Singapore
+    case sx = "SX" // Sint Maarten
+    case sk = "SK" // Slovakia
+    case si = "SI" // Slovenia
+    case sb = "SB" // Solomon Islands
+    case so = "SO" // Somalia
+    case za = "ZA" // South Africa
+    case gs = "GS" // South Georgia
+    case ss = "SS" // South Sudan
+    case es = "ES" // Spain
+    case lk = "LK" // Sri Lanka
+    case sd = "SD" // Sudan
+    case sr = "SR" // Suriname
+    case sj = "SJ" // Svalbard and Jan Mayen
+    case se = "SE" // Sweden
+    case ch = "CH" // Switzerland
+    case sy = "SY" // Syria
+    case tw = "TW" // Taiwan
+    case tj = "TJ" // Tajikistan
+    case tz = "TZ" // Tanzania
+    case th = "TH" // Thailand
+    case tl = "TL" // Timor-Leste
+    case tg = "TG" // Togo
+    case tk = "TK" // Tokelau
+    case to = "TO" // Tonga
+    case tt = "TT" // Trinidad and Tobago
+    case tn = "TN" // Tunisia
+    case tr = "TR" // Turkey
+    case tm = "TM" // Turkmenistan
+    case tc = "TC" // Turks and Caicos Islands
+    case tv = "TV" // Tuvalu
+    case ug = "UG" // Uganda
+    case ua = "UA" // Ukraine
+    case ae = "AE" // United Arab Emirates
+    case gb = "GB" // United Kingdom
+    case us = "US" // United States
+    case um = "UM" // U.S. Minor Outlying Islands
+    case uy = "UY" // Uruguay
+    case uz = "UZ" // Uzbekistan
+    case vu = "VU" // Vanuatu
+    case ve = "VE" // Venezuela
+    case vn = "VN" // Vietnam
+    case vg = "VG" // British Virgin Islands
+    case vi = "VI" // U.S. Virgin Islands
+    case wf = "WF" // Wallis and Futuna
+    case eh = "EH" // Western Sahara
+    case ye = "YE" // Yemen
+    case zm = "ZM" // Zambia
+    case zw = "ZW" // Zimbabwe
+}
+
+extension CountryCode {
+    /// Returns the localized full country name (e.g. "Germany", "Deutschland")
+    func fullName(locale: Locale = .current) -> String {
+        locale.localizedString(forRegionCode: self.rawValue) ?? self.rawValue
+    }
+}
--- a/Sources/ExodaiAcademy/Infrastructure/Base
+++ b/Sources/ExodaiAcademy/Infrastructure/Base
@@ -0,0 +1,26 @@
+//
+//  File.swift
+//  ExodaiAcademy
+//
+//  Created by Exodai on 22/01/2026.
+//
+
+import Foundation
+
+enum Database: String, Codable {
+    case users
+    case campuses
+    case courses
+    case sessions
+    case articles
+    case categories
+    case tags
+    case logs
+    case purchases
+    case products
+    case confirmations
+    case tokens
+    case folders
+    case files
+    
+}
--- a/Sources/ExodaiAcademy/Infrastructure/Base
+++ b/Sources/ExodaiAcademy/Infrastructure/Base
@@ -0,0 +1,17 @@
+//
+//  Role.swift
+//  ExodaiAcademy
+//
+//  Created by Exodai on 22/01/2026.
+//
+
+enum Role: String, Codable {
+    case admin
+    case editor
+    case leadEditor
+    case writer
+    case reviewer
+    case moderator
+    case user
+    case blocked
+}
--- a/Sources/ExodaiAcademy/Infrastructure/Base
+++ b/Sources/ExodaiAcademy/Infrastructure/Base
@@ -0,0 +1,16 @@
+//
+//  Status.swift
+//  ExodaiAcademy
+//
+//  Created by Exodai on 23/01/2026.
+//
+
+enum Status: String, Codable {
+    case published
+    case draft
+    case planned
+    case inReview
+    case archived
+    case trash
+    
+}
--- a/Sources/ExodaiAcademy/Infrastructure/Database/ArticleModel.swift
+++ b/Sources/ExodaiAcademy/Infrastructure/Database/ArticleModel.swift
@@ -0,0 +1,108 @@
+//
+//  ArticleModel.swift
+//  ExodaiAcademy
+//
+//  Created by Exodai on 23/01/2026.
+//
+
+import Fluent
+
+final class ArticleModel: Model, @unchecked Sendable {
+    static let schema: String = Database.articles.rawValue
+
+    // MARK: - ID
+
+    @ID(key: .id)
+    var id: UUID?
+
+    // MARK: - CMS Fields (all optional)
+
+    @OptionalField(key: FieldKeys.title)
+    var title: String?
+
+    @OptionalField(key: FieldKeys.description)
+    var description: String?
+
+    @OptionalField(key: FieldKeys.slug)
+    var slug: String?
+
+    @OptionalField(key: FieldKeys.excerpt)
+    var excerpt: String?
+
+    @OptionalField(key: FieldKeys.image)
+    var image: String?
+
+    @OptionalEnum(key: FieldKeys.status)
+    var status: Status?
+
+    @OptionalField(key: FieldKeys.authorID)
+    var authorID: UserModel.IDValue?
+
+    @OptionalField(key: FieldKeys.categories)
+    var categories: [CategoryModel.IDValue]?
+
+    @OptionalField(key: FieldKeys.tags)
+    var tags: [TagModel.IDValue]?
+
+    // MARK: - Timestamps
+
+    @Timestamp(key: FieldKeys.createdAt, on: .create)
+    var createdAt: Date?
+
+    @Timestamp(key: FieldKeys.updatedAt, on: .update)
+    var updatedAt: Date?
+
+    @OptionalField(key: FieldKeys.publishDate)
+    var publishDate: Date?
+
+    // MARK: - Initializer
+
+    init() {}
+}
+
+
+extension ArticleModel {
+    struct FieldKeys {
+        static var title: FieldKey { "title" }
+        static var description: FieldKey { "description" }
+        static var slug: FieldKey { "slug" }
+        static var excerpt: FieldKey { "excerpt" }
+        static var image: FieldKey { "image" }
+        static var status: FieldKey { "status" }
+        static var authorID: FieldKey { "authorID" }
+        static var categories: FieldKey { "categories" }
+        static var tags: FieldKey { "tags" }
+        static var createdAt: FieldKey { "createdAt" }
+        static var updatedAt: FieldKey { "updatedAt" }
+        static var publishDate: FieldKey { "publishDate" }
+    }
+}
+
+import Fluent
+
+extension ArticleModel {
+    struct Migration: AsyncMigration {
+
+        func prepare(on database: any FluentKit.Database) async throws {
+            try await database.schema(ArticleModel.schema)
+                .id()
+                .field(FieldKeys.title, .string)
+                .field(FieldKeys.description, .string)
+                .field(FieldKeys.slug, .string)
+                .field(FieldKeys.excerpt, .string)
+                .field(FieldKeys.image, .string)
+                .field(FieldKeys.status, .string)
+                .field(FieldKeys.authorID, .uuid)
+                .field(FieldKeys.categories, .array(of: .uuid))
+                .field(FieldKeys.tags, .array(of: .uuid))
+                .field(FieldKeys.createdAt, .datetime)
+                .field(FieldKeys.updatedAt, .datetime)
+                .field(FieldKeys.publishDate, .datetime)
+                .create()
+        }
+
+        func revert(on database: any FluentKit.Database) async throws {
+            try await database.schema(ArticleModel.schema).delete()
+        }
+    }
+}
--- a/Sources/ExodaiAcademy/Infrastructure/Database/CampusModel.swift
+++ b/Sources/ExodaiAcademy/Infrastructure/Database/CampusModel.swift
@@ -0,0 +1,107 @@
+//
+//  CampusModel.swift
+//  ExodaiAcademy
+//
+//  Created by Exodai on 23/01/2026.
+//
+
+import Fluent
+
+final class CampusModel: Model, @unchecked Sendable {
+    static let schema: String = Database.campuses.rawValue
+
+    // MARK: - ID
+
+    @ID(key: .id)
+    var id: UUID?
+
+    // MARK: - Data
+
+    @OptionalField(key: FieldKeys.title)
+    var title: String?
+
+    @OptionalField(key: FieldKeys.description)
+    var description: String?
+    
+    @OptionalField(key: FieldKeys.slug)
+    var slug: String?
+
+    @OptionalField(key: FieldKeys.content)
+    var content: String?
+
+    @Enum(key: FieldKeys.status)
+    var status: Status
+
+    @Field(key: FieldKeys.instructorID)
+    var instructorID: UserModel.IDValue
+
+    @OptionalField(key: FieldKeys.price)
+    var price: Double?
+
+    @OptionalField(key: FieldKeys.tags)
+    var tags: [TagModel.IDValue]?
+
+    @OptionalField(key: FieldKeys.categories)
+    var categories: [CategoryModel.IDValue]?
+
+    // MARK: - Timestamps
+
+    @Timestamp(key: FieldKeys.createdAt, on: .create)
+    var createdAt: Date?
+
+    @Timestamp(key: FieldKeys.updatedAt, on: .update)
+    var updatedAt: Date?
+
+    @Field(key: FieldKeys.publishDate)
+    var publishDate: Date?
+
+    // MARK: - Initializers
+
+    init() {}
+}
+
+extension CampusModel {
+    struct FieldKeys {
+        static var title: FieldKey { "title" }
+        static var description: FieldKey { "description" }
+        static var slug: FieldKey {"slug"}
+        static var content: FieldKey { "content" }
+        static var status: FieldKey { "status" }
+        static var instructorID: FieldKey { "instructorID" }
+        static var price: FieldKey { "price" }
+        static var tags: FieldKey { "tags" }
+        static var categories: FieldKey { "categories" }
+        static var createdAt: FieldKey { "createdAt" }
+        static var updatedAt: FieldKey { "updatedAt" }
+        static var publishDate: FieldKey { "publishDate" }
+    }
+}
+
+import Fluent
+
+extension CampusModel {
+    struct Migration: AsyncMigration {
+
+        func prepare(on database: any FluentKit.Database) async throws {
+            try await database.schema(CampusModel.schema)
+                .id()
+                .field(FieldKeys.title, .string)
+                .field(FieldKeys.description, .string)
+                .field(FieldKeys.slug, .string)
+                .field(FieldKeys.content, .string)
+                .field(FieldKeys.status, .string, .required)
+                .field(FieldKeys.instructorID, .uuid, .required)
+                .field(FieldKeys.price, .double)
+                .field(FieldKeys.tags, .array(of: .uuid))
+                .field(FieldKeys.categories, .array(of: .uuid))
+                .field(FieldKeys.createdAt, .datetime)
+                .field(FieldKeys.updatedAt, .datetime)
+                .field(FieldKeys.publishDate, .datetime)
+                .create()
+        }
+
+        func revert(on database: any FluentKit.Database) async throws {
+            try await database.schema(CampusModel.schema).delete()
+        }
+    }
+}
--- a/Sources/ExodaiAcademy/Infrastructure/Database/CategoryModel.swift
+++ b/Sources/ExodaiAcademy/Infrastructure/Database/CategoryModel.swift
@@ -0,0 +1,57 @@
+//
+//  CategoryModel.swift
+//  ExodaiAcademy
+//
+//  Created by Exodai on 23/01/2026.
+//
+
+import Fluent
+
+final class CategoryModel: Model, @unchecked Sendable {
+    static let schema: String = Database.categories.rawValue
+
+    // MARK: - ID
+
+    @ID(key: .id)
+    var id: UUID?
+
+    // MARK: - Data
+
+    @Field(key: FieldKeys.name)
+    var name: String
+
+    // MARK: - Initializers
+
+    init() {}
+
+    init(
+        id: UUID? = nil,
+        name: String
+    ) {
+        self.id = id
+        self.name = name
+    }
+}
+
+extension CategoryModel {
+    struct FieldKeys {
+        static var name: FieldKey { "name" }
+    }
+}
+
+extension CategoryModel {
+    struct Migration: AsyncMigration {
+
+        func prepare(on database: any FluentKit.Database) async throws {
+            try await database.schema(CategoryModel.schema)
+                .id()
+                .field(FieldKeys.name, .string, .required)
+                .unique(on: FieldKeys.name)
+                .create()
+        }
+
+        func revert(on database: any FluentKit.Database) async throws {
+            try await database.schema(CategoryModel.schema).delete()
+        }
+    }
+}
--- a/Sources/ExodaiAcademy/Infrastructure/Database/ConfirmationModel.swift
+++ b/Sources/ExodaiAcademy/Infrastructure/Database/ConfirmationModel.swift
@@ -0,0 +1,78 @@
+//
+//  ConfirmationModel.swift
+//  ExodaiAcademy
+//
+//  Created by Exodai on 23/01/2026.
+//
+
+import Fluent
+import Vapor
+
+import Fluent
+
+final class ConfirmationModel: Model, @unchecked Sendable {
+    static let schema: String = Database.confirmations.rawValue
+
+    @ID(key: .id)
+    var id: UUID?
+
+    @Field(key: FieldKeys.userID)
+    var userID: UserModel.IDValue
+
+    @Field(key: FieldKeys.confirmationCode)
+    var confirmationCode: String
+    
+    @Field(key: FieldKeys.email)
+    var email: String
+
+    @Timestamp(key: FieldKeys.createdAt, on: .create)
+    var createdAt: Date?
+
+    @Timestamp(key: FieldKeys.validTill, on: .none)
+    var validTill: Date?
+
+    @Field(key: FieldKeys.isConfirmed)
+    var isConfirmed: Bool
+
+    init() {}
+
+    init(id: UUID? = nil, userID: UserModel.IDValue, email: String?, confirmationCode: String, validTill: Date, isConfirmed: Bool = false) {
+        self.id = id
+        self.userID = userID
+        self.confirmationCode = confirmationCode
+        self.validTill = validTill
+        self.isConfirmed = isConfirmed
+    }
+}
+
+extension ConfirmationModel {
+    struct FieldKeys {
+        static var userID: FieldKey { "userID" }
+        static var confirmationCode: FieldKey { "confirmationCode" }
+        static var email: FieldKey { "email" }
+        static var createdAt: FieldKey { "createdAt" }
+        static var validTill: FieldKey { "validTill" }
+        static var isConfirmed: FieldKey { "isConfirmed" }
+    }
+}
+
+extension ConfirmationModel {
+    struct Migration: AsyncMigration {
+
+        func prepare(on database: any FluentKit.Database) async throws {
+            try await database.schema(ConfirmationModel.schema)
+                .id()
+                .field(FieldKeys.userID, .uuid, .required)
+                .field(FieldKeys.confirmationCode, .string, .required)
+                .field(FieldKeys.email, .string, .required)
+                .field(FieldKeys.createdAt, .datetime)
+                .field(FieldKeys.validTill, .datetime)
+                .field(FieldKeys.isConfirmed, .bool, .required)
+                .create()
+        }
+
+        func revert(on database: any FluentKit.Database) async throws {
+            try await database.schema(ConfirmationModel.schema).delete()
+        }
+    }
+}
--- a/Sources/ExodaiAcademy/Infrastructure/Database/CourseModel.swift
+++ b/Sources/ExodaiAcademy/Infrastructure/Database/CourseModel.swift
@@ -0,0 +1,103 @@
+//
+//  CourseModel.swift
+//  ExodaiAcademy
+//
+//  Created by Exodai on 23/01/2026.
+//
+
+import Fluent
+
+final class CourseModel: Model, @unchecked Sendable {
+    static let schema: String = Database.courses.rawValue
+
+    // MARK: - ID
+
+    @ID(key: .id)
+    var id: UUID?
+
+    // MARK: - Data
+
+    @OptionalField(key: FieldKeys.title)
+    var title: String?
+
+    @OptionalField(key: FieldKeys.description)
+    var description: String?
+
+    @OptionalField(key: FieldKeys.slug)
+    var slug: String?
+
+    @OptionalField(key: FieldKeys.excerpt)
+    var excerpt: String?
+
+    @OptionalField(key: FieldKeys.content)
+    var content: String?
+
+    @OptionalField(key: FieldKeys.campusID)
+    var campusID: CampusModel.IDValue?
+
+    @Field(key: FieldKeys.authorID)
+    var authorID: UserModel.IDValue
+
+    @OptionalField(key: FieldKeys.image)
+    var image: String?
+
+    @Enum(key: FieldKeys.status)
+    var status: Status
+
+    @Timestamp(key: FieldKeys.createdAt, on: .create)
+    var createdAt: Date?
+
+    @Timestamp(key: FieldKeys.updatedAt, on: .update)
+    var updatedAt: Date?
+
+    @OptionalField(key: FieldKeys.publishDate)
+    var publishDate: Date?
+
+    // MARK: - Initializers
+
+    init() {}
+}
+
+extension CourseModel {
+    struct FieldKeys {
+        static var title: FieldKey { "title" }
+        static var description: FieldKey { "description" }
+        static var slug: FieldKey { "slug" }
+        static var excerpt: FieldKey { "excerpt" }
+        static var content: FieldKey { "content" }
+        static var campusID: FieldKey { "campusID" }
+        static var authorID: FieldKey { "authorID" }
+        static var image: FieldKey { "image" }
+        static var status: FieldKey { "status" }
+        static var createdAt: FieldKey { "createdAt" }
+        static var updatedAt: FieldKey { "updatedAt" }
+        static var publishDate: FieldKey { "publishDate" }
+    }
+}
+
+extension CourseModel {
+    struct Migration: AsyncMigration {
+
+        func prepare(on database: any FluentKit.Database) async throws {
+            try await database.schema(CourseModel.schema)
+                .id()
+                .field(FieldKeys.title, .string)
+                .field(FieldKeys.description, .string)
+                .field(FieldKeys.slug, .string)
+                .field(FieldKeys.excerpt, .string)
+                .field(FieldKeys.content, .string)
+                .field(FieldKeys.campusID, .uuid)
+                .field(FieldKeys.authorID, .uuid, .required)
+                .field(FieldKeys.image, .string)
+                .field(FieldKeys.status, .string, .required)
+                .field(FieldKeys.createdAt, .datetime)
+                .field(FieldKeys.updatedAt, .datetime)
+                .field(FieldKeys.publishDate, .datetime)
+                .create()
+        }
+
+        func revert(on database: any FluentKit.Database) async throws {
+            try await database.schema(CourseModel.schema).delete()
+        }
+    }
+}
--- a/Sources/ExodaiAcademy/Infrastructure/Database/FileModel.swift
+++ b/Sources/ExodaiAcademy/Infrastructure/Database/FileModel.swift
@@ -0,0 +1,79 @@
+//
+//  FileModel.swift
+//  ExodaiAcademy
+//
+//  Created by Exodai on 24/01/2026.
+//
+
+import Fluent
+
+final class FileModel: Model, @unchecked Sendable {
+    static let schema: String = Database.files.rawValue
+
+    @ID(key: .id)
+    var id: UUID?
+
+    @Field(key: FieldKeys.folderID)
+    var folderID: FolderModel.IDValue
+
+    @Field(key: FieldKeys.name)
+    var name: String
+
+    @Field(key: FieldKeys.type)
+    var type: String
+
+    @Field(key: FieldKeys.mimeType)
+    var mimeType: String
+
+    @Field(key: FieldKeys.storageKey)
+    var storageKey: String
+
+    @Field(key: FieldKeys.size)
+    var size: Int64
+
+    @OptionalField(key: FieldKeys.metadata)
+    var metadata: String?
+
+    @Timestamp(key: FieldKeys.createdAt, on: .create)
+    var createdAt: Date?
+
+    init() {}
+}
+
+extension FileModel {
+    struct FieldKeys {
+        static var folderID: FieldKey { "folderID" }
+        static var name: FieldKey { "name" }
+        static var type: FieldKey { "type" }
+        static var mimeType: FieldKey { "mimeType" }
+        static var storageKey: FieldKey { "storageKey" }
+        static var size: FieldKey { "size" }
+        static var metadata: FieldKey { "metadata" }
+        static var createdAt: FieldKey { "createdAt" }
+    }
+}
+
+import Fluent
+
+extension FileModel {
+    struct Migration: AsyncMigration {
+
+        func prepare(on database: any FluentKit.Database) async throws {
+            try await database.schema(FileModel.schema)
+                .id()
+                .field(FieldKeys.folderID, .uuid, .required)
+                .field(FieldKeys.name, .string, .required)
+                .field(FieldKeys.type, .string, .required)
+                .field(FieldKeys.mimeType, .string, .required)
+                .field(FieldKeys.storageKey, .string, .required)
+                .field(FieldKeys.size, .int64, .required)
+                .field(FieldKeys.metadata, .string)
+                .field(FieldKeys.createdAt, .datetime)
+                .create()
+        }
+
+        func revert(on database: any FluentKit.Database) async throws {
+            try await database.schema(FileModel.schema).delete()
+        }
+    }
+}
--- a/Sources/ExodaiAcademy/Infrastructure/Database/FolderModel.swift
+++ b/Sources/ExodaiAcademy/Infrastructure/Database/FolderModel.swift
@@ -0,0 +1,59 @@
+//
+//  FolderModel.swift
+//  ExodaiAcademy
+//
+//  Created by Exodai on 24/01/2026.
+//
+
+import Fluent
+
+final class FolderModel: Model, @unchecked Sendable {
+    static let schema: String = Database.folders.rawValue
+
+    @ID(key: .id)
+    var id: UUID?
+
+    @Field(key: FieldKeys.name)
+    var name: String
+
+    @OptionalField(key: FieldKeys.parentFolderID)
+    var parentFolderID: FolderModel.IDValue?
+
+    @Timestamp(key: FieldKeys.createdAt, on: .create)
+    var createdAt: Date?
+
+    @Timestamp(key: FieldKeys.updatedAt, on: .update)
+    var updatedAt: Date?
+
+    init() {}
+}
+
+extension FolderModel {
+    struct FieldKeys {
+        static var name: FieldKey { "name" }
+        static var parentFolderID: FieldKey { "parentFolderID" }
+        static var createdAt: FieldKey { "createdAt" }
+        static var updatedAt: FieldKey { "updatedAt" }
+    }
+}
+
+import Fluent
+
+extension FolderModel {
+    struct Migration: AsyncMigration {
+
+        func prepare(on database: any FluentKit.Database) async throws {
+            try await database.schema(FolderModel.schema)
+                .id()
+                .field(FieldKeys.name, .string, .required)
+                .field(FieldKeys.parentFolderID, .uuid)
+                .field(FieldKeys.createdAt, .datetime)
+                .field(FieldKeys.updatedAt, .datetime)
+                .create()
+        }
+
+        func revert(on database: any FluentKit.Database) async throws {
+            try await database.schema(FolderModel.schema).delete()
+        }
+    }
+}
--- a/Sources/ExodaiAcademy/Infrastructure/Database/LogModel.swift
+++ b/Sources/ExodaiAcademy/Infrastructure/Database/LogModel.swift
@@ -0,0 +1,72 @@
+//
+//  LogModel.swift
+//  ExodaiAcademy
+//
+//  Created by Exodai on 24/01/2026.
+//
+
+import Fluent
+
+final class LogModel: Model, @unchecked Sendable {
+    static let schema: String = Database.logs.rawValue
+
+    @ID(key: .id)
+    var id: UUID?
+
+    @Field(key: FieldKeys.event)
+    var event: String
+
+    @OptionalField(key: FieldKeys.actorID)
+    var actorID: UserModel.IDValue?
+
+    @OptionalField(key: FieldKeys.targetType)
+    var targetType: String?
+
+    @OptionalField(key: FieldKeys.targetID)
+    var targetID: UUID?
+
+    @OptionalField(key: FieldKeys.context)
+    var context: String?
+    
+    @OptionalField(key: FieldKeys.ipAddress)
+    var ipAddress: String?
+
+    @Timestamp(key: FieldKeys.createdAt, on: .create)
+    var createdAt: Date?
+
+    init() {}
+}
+
+extension LogModel {
+    struct FieldKeys {
+        static var event: FieldKey { "event" }
+        static var actorID: FieldKey { "actorID" }
+        static var ipAddress: FieldKey { "ipAddress" }
+        static var targetType: FieldKey { "targetType" }
+        static var targetID: FieldKey { "targetID" }
+        static var context: FieldKey { "context" }
+        static var createdAt: FieldKey { "createdAt" }
+    }
+}
+
+extension LogModel {
+    struct Migration: AsyncMigration {
+
+        func prepare(on database: any FluentKit.Database) async throws {
+            try await database.schema(LogModel.schema)
+                .id()
+                .field(FieldKeys.event, .string, .required)
+                .field(FieldKeys.actorID, .uuid)
+                .field(FieldKeys.ipAddress, .string)
+                .field(FieldKeys.targetType, .string)
+                .field(FieldKeys.targetID, .uuid)
+                .field(FieldKeys.context, .string)
+                .field(FieldKeys.createdAt, .datetime)
+                .create()
+        }
+
+        func revert(on database: any FluentKit.Database) async throws {
+            try await database.schema(LogModel.schema).delete()
+        }
+    }
+}
--- a/Sources/ExodaiAcademy/Infrastructure/Database/PurchaseModel.swift
+++ b/Sources/ExodaiAcademy/Infrastructure/Database/PurchaseModel.swift
@@ -0,0 +1,83 @@
+//
+//  PurchaseModel.swift
+//  ExodaiAcademy
+//
+//  Created by Exodai on 24/01/2026.
+//
+
+import Fluent
+
+final class PurchaseModel: Model, @unchecked Sendable {
+    static let schema: String = Database.purchases.rawValue
+
+    @ID(key: .id)
+    var id: UUID?
+
+    @Field(key: FieldKeys.userID)
+    var userID: UserModel.IDValue
+
+    @Field(key: FieldKeys.courseID)
+    var courseID: CourseModel.IDValue
+
+    @Field(key: FieldKeys.pricePaid)
+    var pricePaid: Double
+
+    @Field(key: FieldKeys.currency)
+    var currency: String
+
+    @Field(key: FieldKeys.paymentProvider)
+    var paymentProvider: String
+
+    @Field(key: FieldKeys.paymentReference)
+    var paymentReference: String
+
+    @Timestamp(key: FieldKeys.purchasedAt, on: .create)
+    var purchasedAt: Date?
+
+    @OptionalField(key: FieldKeys.refundedAt)
+    var refundedAt: Date?
+
+    @Field(key: FieldKeys.grantedByAdmin)
+    var grantedByAdmin: Bool
+
+    init() {}
+}
+
+extension PurchaseModel {
+    struct FieldKeys {
+        static var userID: FieldKey { "userID" }
+        static var courseID: FieldKey { "courseID" }
+        static var pricePaid: FieldKey { "pricePaid" }
+        static var currency: FieldKey { "currency" }
+        static var paymentProvider: FieldKey { "paymentProvider" }
+        static var paymentReference: FieldKey { "paymentReference" }
+        static var purchasedAt: FieldKey { "purchasedAt" }
+        static var refundedAt: FieldKey { "refundedAt" }
+        static var grantedByAdmin: FieldKey { "grantedByAdmin" }
+    }
+}
+
+extension PurchaseModel {
+    struct Migration: AsyncMigration {
+
+        func prepare(on database: any FluentKit.Database) async throws {
+            try await database.schema(PurchaseModel.schema)
+                .id()
+                .field(FieldKeys.userID, .uuid, .required)
+                .field(FieldKeys.courseID, .uuid, .required)
+                .field(FieldKeys.pricePaid, .double, .required)
+                .field(FieldKeys.currency, .string, .required)
+                .field(FieldKeys.paymentProvider, .string, .required)
+                .field(FieldKeys.paymentReference, .string, .required)
+                .field(FieldKeys.purchasedAt, .datetime)
+                .field(FieldKeys.refundedAt, .datetime)
+                .field(FieldKeys.grantedByAdmin, .bool, .required)
+                .unique(on: FieldKeys.userID, FieldKeys.courseID)
+                .create()
+        }
+
+        func revert(on database: any FluentKit.Database) async throws {
+            try await database.schema(PurchaseModel.schema).delete()
+        }
+    }
+}
--- a/Sources/ExodaiAcademy/Infrastructure/Database/SessionModel.swift
+++ b/Sources/ExodaiAcademy/Infrastructure/Database/SessionModel.swift
@@ -0,0 +1,100 @@
+//
+//  SessionModel.swift
+//  ExodaiAcademy
+//
+//  Created by Exodai on 23/01/2026.
+//
+
+import Fluent
+
+final class SessionModel: Model, @unchecked Sendable {
+    static let schema: String = Database.sessions.rawValue
+
+    // MARK: - ID
+
+    @ID(key: .id)
+    var id: UUID?
+
+    // MARK: - CMS Fields (ALL optional)
+
+    @OptionalField(key: FieldKeys.title)
+    var title: String?
+
+    @OptionalField(key: FieldKeys.description)
+    var description: String?
+    
+    @OptionalField(key: FieldKeys.slug)
+    var slug: String?
+
+    @OptionalField(key: FieldKeys.mp4URL)
+    var mp4URL: String?
+
+    @OptionalField(key: FieldKeys.hlsURL)
+    var hlsURL: String?
+
+    @OptionalField(key: FieldKeys.content)
+    var content: String?
+
+    @OptionalEnum(key: FieldKeys.status)
+    var status: Status?
+
+    @OptionalField(key: FieldKeys.courseID)
+    var courseID: CourseModel.IDValue?
+
+    // MARK: - Timestamps
+
+    @Timestamp(key: FieldKeys.createdAt, on: .create)
+    var createdAt: Date?
+
+    @Timestamp(key: FieldKeys.updatedAt, on: .update)
+    var updatedAt: Date?
+
+    @OptionalField(key: FieldKeys.publishDate)
+    var publishDate: Date?
+
+    // MARK: - Initializer
+
+    init() {}
+}
+
+extension SessionModel {
+    struct FieldKeys {
+        static var title: FieldKey { "title" }
+        static var description: FieldKey { "description" }
+        static var slug: FieldKey { "slug" }
+        static var mp4URL: FieldKey { "mp4URL" }
+        static var hlsURL: FieldKey { "hlsURL" }
+        static var content: FieldKey { "content" }
+        static var status: FieldKey { "status" }
+        static var courseID: FieldKey { "courseID" }
+        static var createdAt: FieldKey { "createdAt" }
+        static var updatedAt: FieldKey { "updatedAt" }
+        static var publishDate: FieldKey { "publishDate" }
+    }
+}
+
+extension SessionModel {
+    struct Migration: AsyncMigration {
+
+        func prepare(on database: any FluentKit.Database) async throws {
+            try await database.schema(SessionModel.schema)
+                .id()
+                .field(FieldKeys.title, .string)
+                .field(FieldKeys.description, .string)
+                .field(FieldKeys.slug, .string)
+                .field(FieldKeys.mp4URL, .string)
+                .field(FieldKeys.hlsURL, .string)
+                .field(FieldKeys.content, .string)
+                .field(FieldKeys.status, .string)
+                .field(FieldKeys.courseID, .uuid)
+                .field(FieldKeys.createdAt, .datetime)
+                .field(FieldKeys.updatedAt, .datetime)
+                .field(FieldKeys.publishDate, .datetime)
+                .create()
+        }
+
+        func revert(on database: any FluentKit.Database) async throws {
+            try await database.schema(SessionModel.schema).delete()
+        }
+    }
+}
--- a/Sources/ExodaiAcademy/Infrastructure/Database/TagModel.swift
+++ b/Sources/ExodaiAcademy/Infrastructure/Database/TagModel.swift
@@ -0,0 +1,31 @@
+//
+//  TagModel.swift
+//  ExodaiAcademy
+//
+//  Created by Exodai on 23/01/2026.
+//
+
+import Fluent
+
+final class TagModel: Model, @unchecked Sendable {
+    static let schema: String = Database.tags.rawValue
+
+    @ID(key: .id)
+    var id: UUID?
+
+    @Field(key: FieldKeys.name)
+    var name: String
+
+    init() {}
+
+    init(id: UUID? = nil, name: String) {
+        self.id = id
+        self.name = name
+    }
+}
+
+extension TagModel {
+    struct FieldKeys {
+        static var name: FieldKey { "name" }
+    }
+}
--- a/Sources/ExodaiAcademy/Infrastructure/Database/TokenModel.swift
+++ b/Sources/ExodaiAcademy/Infrastructure/Database/TokenModel.swift
@@ -0,0 +1,45 @@
+//
+//  TokenModel.swift
+//  ExodaiAcademy
+//
+//  Created by Exodai on 23/01/2026.
+//
+
+import Fluent
+
+final class TokenModel: Model, @unchecked Sendable {
+    static let schema: String = Database.tokens.rawValue
+
+    @ID(key: .id)
+    var id: UUID?
+
+    @Field(key: FieldKeys.userID)
+    var userID: UserModel.IDValue
+
+    @Field(key: FieldKeys.value)
+    var value: String
+
+    @Timestamp(key: FieldKeys.createdAt, on: .create)
+    var createdAt: Date?
+
+    @Timestamp(key: FieldKeys.validTill, on: .none)
+    var validTill: Date?
+
+    init() {}
+
+    init(id: UUID? = nil, userID: UserModel.IDValue, value: String, validTill: Date?) {
+        self.id = id
+        self.userID = userID
+        self.value = value
+        self.validTill = validTill
+    }
+}
+
+extension TokenModel {
+    struct FieldKeys {
+        static var userID: FieldKey { "userID" }
+        static var value: FieldKey { "value" }
+        static var createdAt: FieldKey { "createdAt" }
+        static var validTill: FieldKey { "validTill" }
+    }
+}
--- a/Sources/ExodaiAcademy/Infrastructure/Database/UserModel.swift
+++ b/Sources/ExodaiAcademy/Infrastructure/Database/UserModel.swift
@@ -0,0 +1,177 @@
+//
+//  UserModel.swift
+//  ExodaiAcademy
+//
+//  Created by Exodai on 22/01/2026.
+//
+
+import Vapor
+import Fluent
+import FluentKit
+
+final class UserModel: Model, @unchecked Sendable  {
+    static let schema: String = Database.users.rawValue
+    
+    @ID(key: .id)
+    var id: UUID?
+    
+    @Field(key: FieldKeys.username)
+    var username: String
+    
+    @Field(key: FieldKeys.email)
+    var email: String
+    
+    @Field(key: FieldKeys.password)
+    var password: String
+    
+    @Field(key: FieldKeys.role)
+    var role: Role
+    
+    @OptionalField(key: FieldKeys.name)
+    var name: String?
+    
+    @OptionalField(key: FieldKeys.lastname)
+    var lastname: String?
+    
+    @OptionalField(key: FieldKeys.address)
+    var address: String?
+    
+    @OptionalField(key: FieldKeys.zipCode)
+    var zipCode: String?
+    
+    @OptionalField(key: FieldKeys.city)
+    var city: String?
+    
+    @OptionalEnum(key: FieldKeys.country)
+    var Country: CountryCode?
+    
+    @OptionalField(key: FieldKeys.stripeID)
+    var stripeID: String?
+    
+    @Timestamp(key: FieldKeys.createdAt, on: .create)
+    var createdAt: Date?
+    
+    @Timestamp(key: FieldKeys.updatedAt, on: .update)
+    var updatedAt: Date?
+    
+    @Timestamp(key: FieldKeys.deletedAt, on: .delete)
+    var deletedAt: Date?
+    
+    @Timestamp(key: FieldKeys.lastLogin, on: .none)
+    var lastLogin: Date?
+    
+    init() {
+        
+    }
+    
+    init(id: UUID? = nil, username: String, email: String, password: String, role: Role) {
+        self.id = id
+        self.username = username
+        self.email = email
+        self.password = password
+        self.role = role
+    }
+}
+
+extension UserModel {
+    struct FieldKeys {
+        static var username: FieldKey {"username"}
+        static var email: FieldKey {"email"}
+        static var password: FieldKey {"password"}
+        static var role: FieldKey {"role"}
+        static var name: FieldKey {"name"}
+        static var lastname: FieldKey {"lastname"}
+        static var address: FieldKey {"address"}
+        static var zipCode: FieldKey {"zipCode"}
+        static var city: FieldKey {"city"}
+        static var country: FieldKey {"country"}
+        static var stripeID: FieldKey {"stripeID"}
+        static var createdAt: FieldKey {"createdAt"}
+        static var updatedAt: FieldKey {"updatedAt"}
+        static var deletedAt: FieldKey {"deletedAt"}
+        static var lastLogin: FieldKey {"lastLogin"}
+    }
+}
+
+import Fluent
+
+extension UserModel {
+    struct Migration: AsyncMigration {
+
+        func prepare(on database: any FluentKit.Database) async throws {
+            try await database.schema(UserModel.schema)
+                .id()
+                .field(FieldKeys.username, .string, .required)
+                .field(FieldKeys.email, .string, .required)
+                .field(FieldKeys.password, .string, .required)
+                .field(FieldKeys.role, .string, .required)
+                .field(FieldKeys.name, .string)
+                .field(FieldKeys.lastname, .string)
+                .field(FieldKeys.address, .string)
+                .field(FieldKeys.zipCode, .string)
+                .field(FieldKeys.city, .string)
+                .field(FieldKeys.country, .string)
+                .field(FieldKeys.stripeID, .string)
+                .field(FieldKeys.createdAt, .datetime)
+                .field(FieldKeys.updatedAt, .datetime)
+                .field(FieldKeys.deletedAt, .datetime)
+                .field(FieldKeys.lastLogin, .datetime)
+                .unique(on: FieldKeys.username)
+                .unique(on: FieldKeys.email)
+                .create()
+        }
+
+        func revert(on database: any FluentKit.Database) async throws {
+            try await database.schema(UserModel.schema).delete()
+        }
+    }
+}
+
+extension UserModel {
+
+    struct Public: Content {
+        let id: UUID?
+        let username: String
+        let email: String
+        let role: Role
+        let name: String?
+        let lastname: String?
+        let address: String?
+        let zipCode: String?
+        let city: String?
+        let country: CountryCode?
+        let stripeID: String?
+        let createdAt: Date?
+        let updatedAt: Date?
+        let lastLogin: Date?
+    }
+}
+
+extension UserModel {
+
+    func convertToPublic() -> Public {
+        .init(
+            id: self.id,
+            username: self.username,
+            email: self.email,
+            role: self.role,
+            name: self.name,
+            lastname: self.lastname,
+            address: self.address,
+            zipCode: self.zipCode,
+            city: self.city,
+            country: self.Country,
+            stripeID: self.stripeID,
+            createdAt: self.createdAt,
+            updatedAt: self.updatedAt,
+            lastLogin: self.lastLogin
+        )
+    }
+}
+
+extension Collection where Element == UserModel {
+
+    func convertToPublic() -> [UserModel.Public] {
+        self.map { $0.convertToPublic() }
+    }
+}
--- a/Sources/ExodaiAcademy/Infrastructure/Repositories/User
+++ b/Sources/ExodaiAcademy/Infrastructure/Repositories/User
@@ -0,0 +1,66 @@
+//
+//  UserAuthRepository.swift
+//  ExodaiAcademy
+//
+//  Created by Exodai on 25/01/2026.
+//
+
+import Foundation
+
+protocol UserAuthRepository {
+    func findByEmail(_ email: String) async throws -> UserModel?
+    func findByUsername(_ username: String) async throws -> UserModel?
+    func create(
+        username: String,
+        email: String,
+        passwordHash: String,
+        role: Role
+    ) async throws -> UserModel
+    func updatePassword(userID: UUID, passwordHash: String) async throws
+    func delete(userID: UUID) async throws
+}
+
+import Fluent
+import Vapor
+
+struct FluentUserAuthRepository: UserAuthRepository {
+    let db: any FluentKit.Database
+
+    func findByEmail(_ email: String) async throws -> UserModel? {
+        try await UserModel.query(on: db)
+            .filter(\.$email == email)
+            .first()
+    }
+
+    func findByUsername(_ username: String) async throws -> UserModel? {
+        try await UserModel.query(on: db)
+            .filter(\.$username == username)
+            .first()
+    }
+
+    func create(username: String, email: String, passwordHash: String, role: Role) async throws -> UserModel {
+        let user = UserModel(
+            username: username,
+            email: email,
+            password: passwordHash,
+            role: role
+        )
+
+        try await user.create(on: db)
+        return user
+    }
+
+    func updatePassword(userID: UUID, passwordHash: String) async throws {
+        guard let user = try await UserModel.find(userID, on: db) else {
+            throw Abort(.notFound)
+        }
+
+        user.password = passwordHash
+        try await user.save(on: db)
+    }
+
+    func delete(userID: UUID) async throws {
+        try await UserModel.find(userID, on: db)?
+            .delete(on: db)
+    }
+}
--- a/Sources/ExodaiAcademy/Infrastructure/Repositories/User
+++ b/Sources/ExodaiAcademy/Infrastructure/Repositories/User
@@ -0,0 +1,46 @@
+//
+//  UserRepository.swift
+//  ExodaiAcademy
+//
+//  Created by Exodai on 25/01/2026.
+//
+
+import Foundation
+
+protocol UserRepository {
+    func find(id: UUID) async throws -> UserModel.Public?
+    func findByEmail(_ email: String) async throws -> UserModel.Public?
+    func findByUsername(_ username: String) async throws -> UserModel.Public?
+    func all() async throws -> [UserModel.Public]
+}
+
+import Fluent
+
+struct FluentUserRepository: UserRepository {
+    let db: any FluentKit.Database
+
+    func find(id: UUID) async throws -> UserModel.Public? {
+        try await UserModel.find(id, on: db)?
+            .convertToPublic()
+    }
+
+    func findByEmail(_ email: String) async throws -> UserModel.Public? {
+        try await UserModel.query(on: db)
+            .filter(\.$email == email)
+            .first()?
+            .convertToPublic()
+    }
+
+    func findByUsername(_ username: String) async throws -> UserModel.Public? {
+        try await UserModel.query(on: db)
+            .filter(\.$username == username)
+            .first()?
+            .convertToPublic()
+    }
+
+    func all() async throws -> [UserModel.Public] {
+        try await UserModel.query(on: db)
+            .all()
+            .convertToPublic()
+    }
+}