feat: some new api frame

Signed-off-by: Wangyan <topshihun@foxmail.com>

Author: topshihun

orion-server/src/api.rs

@@ -118,6 +118,10 @@ pub fn routers() -> Router<AppState> {
         )
         .route("/retry-build", post(build_retry_handler))
         .route("/v2/health", get(health_check_handler))
+        .route("/v2/task-retry/{id}", post(task_retry_handler))
+        .route("/v2/task/{cl}", get(task_get_handler))
+        .route("/v2/build-event/{task-id}", get(build_event_get_handler))
+        .route("/v2/target/{task-id}", get(target_get_handler))
 }
 
 /// Start queue management background task (event-driven + periodic cleanup)
@@ -1867,6 +1871,129 @@ async fn immediate_work(
     }
 }
 
+#[derive(ToSchema, Serialize)]
+pub struct MessageResponse {
+    pub message: String,
+}
+
+#[derive(ToSchema, Serialize)]
+pub struct BuildEventDTO {
+    pub id: String,
+    pub task_id: String,
+    pub retry_count: i32,
+    pub exit_code: Option<i32>,
+    pub log: Option<String>,
+    pub log_output_file: String,
+    pub start_at: String,
+    pub end_at: Option<String>,
+}
+
+#[derive(ToSchema, Serialize)]
+pub struct OrionTaskDTO {
+    pub id: String,
+    pub changes: String,
+    pub repo_name: String,
+    pub cl: String,
+    pub created_at: String,
+}
+
+#[derive(ToSchema, Serialize)]
+pub struct BuildTargetDTO {
+    pub id: String,
+    pub task_id: String,
+    pub path: String,
+    pub target_state: String,
+}
+
+#[utoipa::path(
+    post,
+    path = "/v2/task-retry/{id}",
+    params(("id" = String, description = "Task ID to retry task")),
+    responses(
+        (status = 200, description = "Inserted queque the task", body = MessageResponse),
+        (status = 400, description = "ID format error", body = MessageResponse),
+        (status = 404, description = "Not found this task ID", body = MessageResponse),
+    )
+)]
+pub async fn task_retry_handler(
+    State(_state): State<AppState>,
+    Path(_id): Path<String>,
+) -> impl IntoResponse {
+    let result_message = MessageResponse {
+        message: "todo".to_string(),
+    };
+    (
+        StatusCode::BAD_REQUEST,
+        serde_json::to_string(&result_message).unwrap(),
+    )
+}
+
+#[utoipa::path(
+    get,
+    path = "v2/task/{cl}",
+    params(("cl" = String, Path, description = "cl")),
+    responses(
+        (status = 200, description = "Get task successfully", body = OrionTaskDTO),
+        (status = 404, description = "Not found task", body = MessageResponse),
+    )
+)]
+pub async fn task_get_handler(
+    State(_state): State<AppState>,
+    Path(_cl): Path<String>,
+) -> impl IntoResponse {
+    let result_message = MessageResponse {
+        message: "todo".to_string(),
+    };
+    (
+        StatusCode::NOT_IMPLEMENTED,
+        serde_json::to_string(&result_message).unwrap(),
+    )
+}
+
+#[utoipa::path(
+    get,
+    path = "v2/build-event/{task-id}",
+    params(("task-id" = String, Path, description = "Task ID")),
+    responses(
+        (status = 200, description = "Get build event successfully", body = BuildEventDTO),
+        (status = 404, description = "Not found task", body = MessageResponse),
+    )
+)]
+pub async fn build_event_get_handler(
+    State(_state): State<AppState>,
+    Path(_cl): Path<String>,
+) -> impl IntoResponse {
+    let result_message = MessageResponse {
+        message: "todo".to_string(),
+    };
+    (
+        StatusCode::NOT_IMPLEMENTED,
+        serde_json::to_string(&result_message).unwrap(),
+    )
+}
+
+#[utoipa::path(
+    get,
+    path = "v2/target/{task-id}",
+    params(("task-id" = String, Path, description = "Task ID")),
+    responses(
+        (status = 200, description = "Get target successfully", body = BuildTargetDTO),
+        (status = 404, description = "Not found task", body = MessageResponse),
+    )
+)]
+pub async fn target_get_handler(
+    State(_state): State<AppState>,
+    Path(_task_id): Path<String>,
+) -> impl IntoResponse {
+    let result_message = MessageResponse {
+        message: "todo".to_string(),
+    };
+    (
+        StatusCode::NOT_IMPLEMENTED,
+        serde_json::to_string(&result_message).unwrap(),
+    )
+}
+
 #[cfg(test)]
 mod tests {
     /// Test random number generation for worker selection

orion-server/src/model/build_events.rs

@@ -0,0 +1,38 @@
+//! `SeaORM` Entity, @generated by sea-orm-codegen 1.1.19
+
+use sea_orm::entity::prelude::*;
+use serde::{Deserialize, Serialize};
+
+#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq, Serialize, Deserialize)]
+#[sea_orm(table_name = "build_events")]
+pub struct Model {
+    #[sea_orm(primary_key, auto_increment = false)]
+    pub id: Uuid,
+    pub task_id: Uuid,
+    pub retry_count: i32,
+    pub exit_code: Option<i32>,
+    pub log: Option<String>,
+    pub log_output_file: String,
+    pub start_at: DateTimeWithTimeZone,
+    pub end_at: Option<DateTimeWithTimeZone>,
+}
+
+#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
+pub enum Relation {
+    #[sea_orm(
+        belongs_to = "super::orion_tasks::Entity",
+        from = "Column::TaskId",
+        to = "super::orion_tasks::Column::Id",
+        on_update = "Cascade",
+        on_delete = "Cascade"
+    )]
+    OrionTasks,
+}
+
+impl Related<super::orion_tasks::Entity> for Entity {
+    fn to() -> RelationDef {
+        Relation::OrionTasks.def()
+    }
+}
+
+impl ActiveModelBehavior for ActiveModel {}

orion-server/src/model/build_targets.rs

@@ -0,0 +1,36 @@
+//! `SeaORM` Entity, @generated by sea-orm-codegen 1.1.19
+
+use sea_orm::entity::prelude::*;
+use serde::{Deserialize, Serialize};
+
+#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq, Serialize, Deserialize)]
+#[sea_orm(table_name = "build_targets")]
+pub struct Model {
+    #[sea_orm(primary_key, auto_increment = false)]
+    pub id: Uuid,
+    pub task_id: Uuid,
+    #[sea_orm(column_type = "JsonBinary")]
+    pub path: Json,
+    #[sea_orm(column_type = "Text")]
+    pub target_state: String,
+}
+
+#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
+pub enum Relation {
+    #[sea_orm(
+        belongs_to = "super::orion_tasks::Entity",
+        from = "Column::TaskId",
+        to = "super::orion_tasks::Column::Id",
+        on_update = "Cascade",
+        on_delete = "Cascade"
+    )]
+    OrionTasks,
+}
+
+impl Related<super::orion_tasks::Entity> for Entity {
+    fn to() -> RelationDef {
+        Relation::OrionTasks.def()
+    }
+}
+
+impl ActiveModelBehavior for ActiveModel {}

orion-server/src/model/mod.rs

@@ -1,3 +1,6 @@
+// pub mod build_events;
+// pub mod build_targets;
 pub mod builds;
+// pub mod orion_tasks;
 pub mod targets;
 pub mod tasks;

orion-server/src/model/orion_tasks.rs

@@ -0,0 +1,38 @@
+//! `SeaORM` Entity, @generated by sea-orm-codegen 1.1.19
+
+use sea_orm::entity::prelude::*;
+use serde::{Deserialize, Serialize};
+
+#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq, Serialize, Deserialize)]
+#[sea_orm(table_name = "orion_tasks")]
+pub struct Model {
+    #[sea_orm(primary_key, auto_increment = false)]
+    pub id: Uuid,
+    #[sea_orm(column_type = "JsonBinary")]
+    pub changes: Json,
+    pub repo_name: String,
+    pub cl: String,
+    pub created_at: DateTimeWithTimeZone,
+}
+
+#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
+pub enum Relation {
+    #[sea_orm(has_many = "super::build_events::Entity")]
+    BuildEvents,
+    #[sea_orm(has_many = "super::build_targets::Entity")]
+    BuildTargets,
+}
+
+impl Related<super::build_events::Entity> for Entity {
+    fn to() -> RelationDef {
+        Relation::BuildEvents.def()
+    }
+}
+
+impl Related<super::build_targets::Entity> for Entity {
+    fn to() -> RelationDef {
+        Relation::BuildTargets.def()
+    }
+}
+
+impl ActiveModelBehavior for ActiveModel {}

orion-server/src/server.rs

@@ -43,7 +43,11 @@ use crate::{
         api::get_orion_clients_info,
         api::get_orion_client_status_by_id,
         api::build_retry_handler,
-        api::health_check_handler
+        api::health_check_handler,
+        api::task_retry_handler,
+        api::task_get_handler,
+        api::build_event_get_handler,
+        api::target_get_handler,
     ),
     components(
         schemas(
@@ -64,7 +68,11 @@ use crate::{
             api::CoreWorkerStatus,
             api::OrionClientQuery,
             crate::model::targets::TargetState,
-            TaskPhase
+            TaskPhase,
+            api::MessageResponse,
+            api::BuildEventDTO,
+            api::OrionTaskDTO,
+            api::BuildTargetDTO,
         )
     ),
     tags(