chore: move log models under buck2 types (#1878)

Signed-off-by: lvy010 <17338770572@163.com>

Author: lvy010

api-model/src/buck2/types.rs

@@ -39,3 +39,75 @@ impl ProjectRelativePath {
         opt.map(|s| Self(s.to_owned()))
     }
 }
+
+/// Supported read modes for log APIs.
+#[derive(Debug, Clone, Serialize, Deserialize, ToSchema, PartialEq, Eq, Default)]
+#[serde(rename_all = "lowercase")]
+pub enum LogReadMode {
+    #[default]
+    Full,
+    Segment,
+}
+
+/// Log stream event emitted by Orion worker/build processing.
+#[derive(Debug, Clone, Serialize, Deserialize, ToSchema)]
+pub struct LogEvent {
+    pub task_id: String,
+    pub repo_name: String,
+    pub build_id: String,
+    pub line: String,
+    pub is_end: bool,
+}
+
+/// Log segment read result.
+#[derive(Debug, Clone, Serialize, Deserialize, ToSchema)]
+pub struct LogSegment {
+    pub build_id: String,
+    pub offset: u64,
+    pub len: usize,
+    pub data: String,
+    pub next_offset: u64,
+    pub file_size: u64,
+    /// Whether we reached end of file
+    pub eof: bool,
+}
+
+/// Query parameters for target log APIs.
+#[derive(Debug, Clone, Deserialize, ToSchema)]
+pub struct TargetLogQuery {
+    #[serde(default)]
+    pub r#type: LogReadMode,
+    pub offset: Option<usize>,
+    pub limit: Option<usize>,
+}
+
+/// Query parameters for task history log APIs.
+#[derive(Debug, Clone, Deserialize, ToSchema)]
+pub struct TaskHistoryQuery {
+    pub task_id: String,
+    pub build_id: String,
+    pub repo: String,
+    pub start: Option<usize>,
+    pub end: Option<usize>,
+}
+
+/// Log lines response for history reads.
+#[derive(Debug, Clone, Serialize, Deserialize, ToSchema)]
+pub struct LogLinesResponse {
+    pub data: Vec<String>,
+    pub len: usize,
+}
+
+/// Log lines response for target reads.
+#[derive(Debug, Clone, Serialize, Deserialize, ToSchema)]
+pub struct TargetLogLinesResponse {
+    pub data: Vec<String>,
+    pub len: usize,
+    pub build_id: String,
+}
+
+/// Error response for log-related APIs.
+#[derive(Debug, Clone, Serialize, Deserialize, ToSchema)]
+pub struct LogErrorResponse {
+    pub message: String,
+}

api-model/src/lib.rs

@@ -1,4 +1,3 @@
 pub mod buck2;
 pub mod common;
 pub mod git;
-pub mod orion;

api-model/src/orion/log.rs

@@ -4,7 +4,7 @@ use std::{
 };
 
 use anyhow::Result;
-use api_model::orion::log::{
+use api_model::buck2::types::{
     LogErrorResponse, LogEvent, LogLinesResponse, LogReadMode, TargetLogLinesResponse,
     TargetLogQuery, TaskHistoryQuery,
 };
@@ -263,10 +263,10 @@ pub async fn task_output_handler(
         ("end"  = Option<usize>, Query, description = "End line number"),
     ),
     responses(
-        (status = 200, description = "History Log", body = api_model::orion::log::LogLinesResponse),
-        (status = 400, description = "Invalid parameters", body = api_model::orion::log::LogErrorResponse),
-        (status = 404, description = "Log file not found", body = api_model::orion::log::LogErrorResponse),
-        (status = 500, description = "Failed to operate log file", body = api_model::orion::log::LogErrorResponse),
+        (status = 200, description = "History Log", body = api_model::buck2::types::LogLinesResponse),
+        (status = 400, description = "Invalid parameters", body = api_model::buck2::types::LogErrorResponse),
+        (status = 404, description = "Log file not found", body = api_model::buck2::types::LogErrorResponse),
+        (status = 500, description = "Failed to operate log file", body = api_model::buck2::types::LogErrorResponse),
     )
 )]
 pub async fn task_history_output_handler(
@@ -323,10 +323,10 @@ pub async fn task_history_output_handler(
         (
             status = 200,
             description = "Target log content",
-            body = api_model::orion::log::TargetLogLinesResponse
+            body = api_model::buck2::types::TargetLogLinesResponse
         ),
-        (status = 404, description = "Target or log not found", body = api_model::orion::log::LogErrorResponse),
-        (status = 500, description = "Failed to read log", body = api_model::orion::log::LogErrorResponse)
+        (status = 404, description = "Target or log not found", body = api_model::buck2::types::LogErrorResponse),
+        (status = 500, description = "Failed to read log", body = api_model::buck2::types::LogErrorResponse)
     )
 )]
 pub async fn target_logs_handler(

api-model/src/orion/mod.rs

@@ -1,6 +1,6 @@
 use std::{path::Path, sync::Arc};
 
-use api_model::orion::log::LogEvent;
+use api_model::buck2::types::LogEvent;
 use futures::{Stream, StreamExt};
 use tokio_stream::wrappers::BroadcastStream;
 

orion-server/src/api.rs

@@ -44,16 +44,15 @@ use crate::{
     components(
         schemas(
             crate::scheduler::BuildRequest,
-            api_model::orion::log::LogSegment,
-            api_model::orion::log::LogLinesResponse,
-            api_model::orion::log::TargetLogLinesResponse,
-            api_model::orion::log::LogErrorResponse,
+            api_model::buck2::types::LogLinesResponse,
+            api_model::buck2::types::TargetLogLinesResponse,
+            api_model::buck2::types::LogErrorResponse,
             api::TaskStatusEnum,
             api::BuildDTO,
             api::TargetDTO,
-            api_model::orion::log::TargetLogQuery,
-            api_model::orion::log::LogReadMode,
-            api_model::orion::log::TaskHistoryQuery,
+            api_model::buck2::types::TargetLogQuery,
+            api_model::buck2::types::LogReadMode,
+            api_model::buck2::types::TaskHistoryQuery,
             api::TaskInfoDTO,
             api::OrionClientInfo,
             api::OrionClientStatus,