Genarrative/server-rs/crates/module-game-distribution/src/commands.rs

use serde::{Deserialize, Serialize};

use crate::domain::normalize_id;
use crate::errors::GameDistributionFieldError;

#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)]
pub struct IdempotencyRequest {
    pub key: String,
    pub request_digest: String,
}

impl IdempotencyRequest {
    pub fn validate(&self) -> Result<(), GameDistributionFieldError> {
        if normalize_id(&self.key).is_none() {
            return Err(GameDistributionFieldError::MissingIdempotencyKey);
        }
        if normalize_id(&self.request_digest).is_none() {
            return Err(GameDistributionFieldError::MissingRequestDigest);
        }
        Ok(())
    }
}

#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)]
pub struct CreateGameInput {
    pub game_id: String,
    pub owner_user_id: String,
    pub idempotency: IdempotencyRequest,
    pub created_at_micros: i64,
}

#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)]
pub struct CreateVersionInput {
    pub game_id: String,
    pub owner_user_id: String,
    pub version_id: String,
    /// 用户可见的正整数版本标签；`None` 时按该游戏已有最大版本号 +1（旧客户端兼容）。
    /// 传入时只要求 `>= 1`：同一 gameId 的同一标签可以反复提交，每次都是一条新版本记录。
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub version_number: Option<u64>,
    pub package_sha256: String,
    pub package_bytes: u64,
    pub idempotency: IdempotencyRequest,
    pub created_at_micros: i64,
}

#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)]
pub enum ReviewDecision {
    Approve {
        expected_publication_revision: u64,
    },
    Reject {
        expected_publication_revision: u64,
        reason: String,
    },
}