Add task entity

src/entity/mod.rs

@@ -4,3 +4,4 @@ pub mod accounts;
 pub mod subscriptions;
 pub mod users;
 pub mod users_accounts;
+pub mod tasks;

src/entity/prelude.rs

@@ -1,4 +1,5 @@
 pub use super::accounts::Entity as Accounts;
 pub use super::subscriptions::Entity as Subscriptions;
+pub use super::tasks::Entity as Tasks;
 pub use super::users::Entity as Users;
 pub use super::users_accounts::Entity as UsersAccounts;

src/entity/tasks.rs

@@ -0,0 +1,37 @@
+use sea_orm::entity::prelude::*;
+use serde::{Deserialize, Serialize};
+
+#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize, EnumIter, DeriveActiveEnum)]
+#[sea_orm(rs_type = "i16", db_type = "Integer")]
+pub enum TaskState {
+    Created = 0,
+    Scheduled = 1,
+    Running = 2,
+    Failed = 3,
+    Canceled = 4,
+    Completed = 5,
+}
+
+#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq, Serialize, Deserialize)]
+#[sea_orm(table_name = "tasks")]
+pub struct Model {
+    #[sea_orm(primary_key)]
+    pub id: i64,
+    pub state: TaskState,
+    pub priority: i16,
+    pub attempt: i16,
+    pub max_attempts: i16,
+    pub created_at: DateTimeWithTimeZone,
+    pub attempted_at: Option<DateTimeWithTimeZone>,
+    pub scheduled_at: Option<DateTimeWithTimeZone>,
+    #[sea_orm(column_type = "Text")]
+    pub queue: String,
+    #[sea_orm(column_type = "Text")]
+    pub name: String,
+    pub payload: Json,
+}
+
+#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
+pub enum Relation {}
+
+impl ActiveModelBehavior for ActiveModel {}