feat: task ui basic done

apps/recorder/src/graphql/domains/subscribers.rs

@@ -267,6 +267,7 @@ where
     Box::new(
         move |context: &ResolverContext| -> SeaResult<Option<SeaValue>> {
             let field_name = context.field().name();
+            tracing::warn!("field_name: {:?}", field_name);
             if field_name == entity_create_one_mutation_field_name.as_str()
                 || field_name == entity_create_batch_mutation_field_name.as_str()
             {
@@ -291,7 +292,7 @@ where
 {
     let entity_key = get_entity_key::<T>(context);
     let entity_column_key = get_entity_column_key::<T>(context, column);
-    let column_name = context.entity_object.column_name.as_ref()(&entity_key, &entity_column_key);
+
     context.guards.entity_guards.insert(
         entity_key.clone(),
         guard_entity_with_subscriber_id::<T>(context, column),
@@ -311,13 +312,9 @@ where
         generate_subscriber_id_filter_condition::<T>(context, column),
     );
     context.types.input_none_conversions.insert(
-        column_name.clone(),
+        entity_column_key.clone(),
         generate_default_subscriber_id_input_conversion::<T>(context, column),
     );
-    context
-        .entity_input
-        .insert_skips
-        .push(entity_column_key.clone());
 
     context.entity_input.update_skips.push(entity_column_key);
 }

apps/recorder/src/graphql/schema.rs

@@ -121,6 +121,7 @@ pub fn build_schema(
             builder.register_enumeration::<downloaders::DownloaderCategory>();
             builder.register_enumeration::<downloads::DownloadMime>();
             builder.register_enumeration::<credential_3rd::Credential3rdType>();
+            builder.register_enumeration::<subscriber_tasks::SubscriberTaskStatus>();
         }
 
         builder = register_subscriptions_to_schema_builder(builder);

apps/recorder/src/models/subscriber_tasks.rs

@@ -1,7 +1,27 @@
 use async_trait::async_trait;
 use sea_orm::entity::prelude::*;
 
-pub use crate::task::{SubscriberTask, SubscriberTaskType};
+pub use crate::task::{
+    SubscriberTask, SubscriberTaskType, SubscriberTaskTypeEnum, SubscriberTaskTypeVariant,
+    SubscriberTaskTypeVariantIter,
+};
+
+#[derive(Clone, Debug, PartialEq, Eq, DeriveActiveEnum, EnumIter, DeriveDisplay)]
+#[sea_orm(rs_type = "String", db_type = "Text")]
+pub enum SubscriberTaskStatus {
+    #[sea_orm(string_value = "Pending")]
+    Pending,
+    #[sea_orm(string_value = "Scheduled")]
+    Scheduled,
+    #[sea_orm(string_value = "Running")]
+    Running,
+    #[sea_orm(string_value = "Done")]
+    Done,
+    #[sea_orm(string_value = "Failed")]
+    Failed,
+    #[sea_orm(string_value = "Killed")]
+    Killed,
+}
 
 #[derive(Clone, Debug, PartialEq, Eq, DeriveEntityModel)]
 #[sea_orm(table_name = "subscriber_tasks")]
@@ -11,7 +31,7 @@ pub struct Model {
     pub subscriber_id: i32,
     pub job: SubscriberTask,
     pub task_type: SubscriberTaskType,
-    pub status: String,
+    pub status: SubscriberTaskStatus,
     pub attempts: i32,
     pub max_attempts: i32,
     pub run_at: DateTimeUtc,