feat: user_id fk in session table

entity/src/candidate.rs

@@ -37,6 +37,15 @@ pub struct Model {
 }
 
 #[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
-pub enum Relation {}
+pub enum Relation {
+    #[sea_orm(has_many = "super::session::Entity")]
+    Session,
+}
+
+impl Related<super::session::Entity> for Entity {
+    fn to() -> RelationDef {
+        Relation::Session.def()
+    }
+}
 
 impl ActiveModelBehavior for ActiveModel {}

entity/src/session.rs

@@ -14,6 +14,21 @@ pub struct Model {
 }
 
 #[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
-pub enum Relation {}
+pub enum Relation {
+    #[sea_orm(
+        belongs_to = "super::candidate::Entity",
+        from = "Column::UserId",
+        to = "super::candidate::Column::Application",
+        on_update = "Cascade",
+        on_delete = "Cascade"
+    )]
+    Candidate,
+}
+
+impl Related<super::candidate::Entity> for Entity {
+    fn to() -> RelationDef {
+        Relation::Candidate.def()
+    }
+}
 
 impl ActiveModelBehavior for ActiveModel {}

migration/src/lib.rs

@@ -5,6 +5,7 @@ mod m20221024_121621_create_candidate;
 mod m20221024_124701_create_parent;
 mod m20221024_134454_fill_admin;
 mod m20221025_154422_create_session;
+mod m20221027_194728_session_create_user_fk;
 
 pub struct Migrator;
 
@@ -17,6 +18,7 @@ impl MigratorTrait for Migrator {
             Box::new(m20221024_124701_create_parent::Migration),
             Box::new(m20221024_134454_fill_admin::Migration::default()),
             Box::new(m20221025_154422_create_session::Migration),
+            Box::new(m20221027_194728_session_create_user_fk::Migration),
         ]
     }
 }

migration/src/m20221024_121621_create_candidate.rs

@@ -50,7 +50,7 @@ impl MigrationTrait for Migration {
 
 /// Learn more at https://docs.rs/sea-query#iden
 #[derive(Iden)]
-enum Candidate {
+pub enum Candidate {
     Table,
     Application,
     Code,

migration/src/m20221025_154422_create_session.rs

@@ -1,11 +1,29 @@
 use sea_orm_migration::prelude::*;
 
+use crate::m20221024_121621_create_candidate::Candidate;
+
 #[derive(DeriveMigrationName)]
 pub struct Migration;
 
 #[async_trait::async_trait]
 impl MigrationTrait for Migration {
     async fn up(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        let table = Table::create()
+            .table(Session::Table)
+            .if_not_exists()
+            .col(
+                ColumnDef::new(Session::Id)
+                    .uuid()
+                    .not_null()
+                    .unique_key()
+                    .primary_key(),
+            )
+            .col(ColumnDef::new(Session::HashedToken).string().not_null())
+            .col(ColumnDef::new(Session::UserId).integer().not_null())
+            .col(ColumnDef::new(Session::CreatedAt).date_time().not_null())
+            .col(ColumnDef::new(Session::UpdatedAt).date_time().not_null())
+            .to_owned();
+
         manager
             .create_table(
                 Table::create()
@@ -36,7 +54,7 @@ impl MigrationTrait for Migration {
 
 /// Learn more at https://docs.rs/sea-query#iden
 #[derive(Iden)]
-enum Session {
+pub enum Session {
     Table,
     Id,
     HashedToken,

migration/src/m20221027_194728_session_create_user_fk.rs

@@ -0,0 +1,26 @@
+use sea_orm_migration::prelude::*;
+
+use crate::{m20221025_154422_create_session::Session, m20221024_121621_create_candidate::Candidate};
+
+#[derive(DeriveMigrationName)]
+pub struct Migration;
+
+#[async_trait::async_trait]
+impl MigrationTrait for Migration {
+    async fn up(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        manager.create_foreign_key(ForeignKey::create()
+            .name("user_fk")
+            .from(Session::Table, Session::UserId)
+            .to(Candidate::Table, Candidate::Application)
+            .on_delete(ForeignKeyAction::Cascade)
+            .on_update(ForeignKeyAction::Cascade)
+            .to_owned()).await
+    }
+
+    async fn down(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        manager.drop_foreign_key(ForeignKey::drop()
+            .name("user_fk")
+            .table(Session::Table)
+            .to_owned()).await
+    }
+}