use crate::models;
use serde::{Deserialize, Serialize};
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize, bon::Builder)]
pub struct RunStepObject {
#[serde(rename = "id")]
pub id: String,
#[serde(rename = "object")]
pub object: Object,
#[serde(rename = "created_at")]
pub created_at: i32,
#[serde(rename = "assistant_id")]
pub assistant_id: String,
#[serde(rename = "thread_id")]
pub thread_id: String,
#[serde(rename = "run_id")]
pub run_id: String,
#[serde(rename = "type")]
pub r#type: Type,
#[serde(rename = "status")]
pub status: Status,
#[serde(rename = "step_details")]
pub step_details: Box<models::RunStepObjectStepDetails>,
#[serde(rename = "last_error", deserialize_with = "Option::deserialize")]
pub last_error: Option<Box<models::Object014>>,
#[serde(rename = "expired_at", deserialize_with = "Option::deserialize")]
pub expired_at: Option<i32>,
#[serde(rename = "cancelled_at", deserialize_with = "Option::deserialize")]
pub cancelled_at: Option<i32>,
#[serde(rename = "failed_at", deserialize_with = "Option::deserialize")]
pub failed_at: Option<i32>,
#[serde(rename = "completed_at", deserialize_with = "Option::deserialize")]
pub completed_at: Option<i32>,
#[serde(rename = "metadata", deserialize_with = "Option::deserialize")]
pub metadata: Option<std::collections::HashMap<String, String>>,
#[serde(rename = "usage", deserialize_with = "Option::deserialize")]
pub usage: Option<Box<models::RunStepCompletionUsage>>,
}
impl RunStepObject {
pub fn new(
id: String,
object: Object,
created_at: i32,
assistant_id: String,
thread_id: String,
run_id: String,
r#type: Type,
status: Status,
step_details: models::RunStepObjectStepDetails,
last_error: Option<models::Object014>,
expired_at: Option<i32>,
cancelled_at: Option<i32>,
failed_at: Option<i32>,
completed_at: Option<i32>,
metadata: Option<std::collections::HashMap<String, String>>,
usage: Option<models::RunStepCompletionUsage>,
) -> RunStepObject {
RunStepObject {
id,
object,
created_at,
assistant_id,
thread_id,
run_id,
r#type,
status,
step_details: Box::new(step_details),
last_error: last_error.map(Box::new),
expired_at,
cancelled_at,
failed_at,
completed_at,
metadata,
usage: usage.map(Box::new),
}
}
}
#[derive(Clone, Copy, Debug, Eq, PartialEq, Ord, PartialOrd, Hash, Serialize, Deserialize)]
pub enum Object {
#[serde(rename = "thread.run.step")]
ThreadRunStep,
}
impl Default for Object {
fn default() -> Object {
Self::ThreadRunStep
}
}
#[derive(Clone, Copy, Debug, Eq, PartialEq, Ord, PartialOrd, Hash, Serialize, Deserialize)]
pub enum Type {
#[serde(rename = "message_creation")]
MessageCreation,
#[serde(rename = "tool_calls")]
ToolCalls,
}
impl Default for Type {
fn default() -> Type {
Self::MessageCreation
}
}
#[derive(Clone, Copy, Debug, Eq, PartialEq, Ord, PartialOrd, Hash, Serialize, Deserialize)]
pub enum Status {
#[serde(rename = "in_progress")]
InProgress,
#[serde(rename = "cancelled")]
Cancelled,
#[serde(rename = "failed")]
Failed,
#[serde(rename = "completed")]
Completed,
#[serde(rename = "expired")]
Expired,
}
impl Default for Status {
fn default() -> Status {
Self::InProgress
}
}
impl std::fmt::Display for RunStepObject {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
match serde_json::to_string(self) {
Ok(s) => write!(f, "{}", s),
Err(_) => Err(std::fmt::Error),
}
}
}