安装与使用 Ecat

use ecat::App;
use ecat_transport_http::HttpServer;
use ecat_transport_grpc::GrpcServer;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
    let app = App::builder()
        .name("my-service")
        .version("v1.0.0")
        .server(HttpServer::new("0.0.0.0:8000"))
        .server(GrpcServer::new("0.0.0.0:9000"))
        .on_start(|| async {
            tracing::info!("service started");
            Ok(())
        })
        .on_stop(|| async {
            tracing::info!("service stopped");
            Ok(())
        })
        .build()?;

    app.run().await?; // 阻塞到 SIGTERM 或 SIGINT
    Ok(())
}

use tower::ServiceBuilder;
use ecat_middleware::{RecoveryLayer, TracingLayer, LoggingLayer, TimeoutLayer};
use ecat_circuit_breaker::CircuitBreakerLayer;
use ecat_security::SecurityLayer;
use ecat_auth::JwtAuthLayer;
use std::time::Duration;

// JWT 密钥至少 32 字节
let jwt = JwtAuthLayer::new("change-me-32-bytes-minimum-secret")
    .expect("valid jwt secret");

// 顺序有影响
let layer = ServiceBuilder::new()
    .layer(RecoveryLayer)
    .layer(TracingLayer)
    .layer(LoggingLayer)
    .layer(TimeoutLayer::new(Duration::from_secs(30)))
    .layer(CircuitBreakerLayer::new())
    .layer(jwt)
    .layer(SecurityLayer::new());

use ecat_data_redis::{RedisCache, RedisConfig};
use ecat_data_sqlx::{SqlxClient, SqlxConfig};
use std::time::Duration;

// 从 JSON 或 YAML 加载配置
let config: serde_json::Value = serde_json::from_str(r#"{
    "redis": {"url": "redis://localhost:6379"},
    "sql":   {"url": "postgres://user:pass@localhost/db"}
}"#)?;

// Redis
let redis_cfg: RedisConfig = serde_json::from_value(config["redis"].clone())?;
let cache = RedisCache::from_config(redis_cfg).await?;
cache.set("key", b"value", Duration::from_secs(60)).await?;

// RDBMS
let sql_cfg: SqlxConfig = serde_json::from_value(config["sql"].clone())?;
let db = SqlxClient::from_config(sql_cfg).await?;
let rows = db.query("SELECT * FROM users").await?;

ecat new helloworld
ecat run --watch
ecat build
ecat upgrade

# 浏览形态
ecat pet list

# 输出单个 SVG
ecat pet show smile

# 导出全部 13 个
ecat pet export ./pet

use ecat_orm::query::{Op, Order};
use ecat_orm::{Entity, Migrator, create_table};
use time::OffsetDateTime;

#[derive(Entity, Debug, Clone)]
#[entity(table = "users")]
pub struct User {
    #[entity(pk, auto_increment)]
    pub id: i64,
    pub name: String,
    #[entity(created_at)]
    pub created_at: Option<OffsetDateTime>,
    #[entity(soft_delete)]
    pub deleted_at: Option<OffsetDateTime>,
    #[entity(version)]
    pub version: i64,
    #[entity(has_many = "Post", foreign_key = "user_id")]
    pub posts: Vec<Post>,
}

// 迁移建表；&db 与 &tx 共用同一套 CRUD
Migrator::new(&db)
    .add("001_users", create_table::<User>())
    .run().await?;

let id = User::insert(&db, &user).await?;
let mut got = User::find_by_id(&db, id).await?.unwrap();
got.name = "alice-v2".into();
User::update(&db, &got).await?;

// 分页 + 预加载：每个关联一条 IN 查询
let page = User::query()
    .filter("name", Op::Like, "ali%")?
    .order_by("id", Order::Desc)?
    .with(&[UserRelation::Posts])
    .paginate(&db, 1, 20)
    .await?;