use chrono::{DateTime, Utc};
use serde::{Deserialize, Serialize};
use sqlx::FromRow;
use uuid::Uuid;
#[derive(Debug, Clone, Serialize, Deserialize, FromRow)]
pub struct FileLockProjection {
pub id: Uuid,
pub file_id: Uuid,
pub user_id: Uuid,
pub locked_at: DateTime<Utc>,
pub expires_at: DateTime<Utc>,
pub refreshed_at: Option<DateTime<Utc>>,
pub status: LockStatus,
pub metadata: serde_json::Value,
pub projection_version: i64,
pub last_event_sequence: i64,
pub projection_updated_at: DateTime<Utc>,
}
impl FileLockProjection {
pub fn new(
id: Uuid,
file_id: Uuid,
user_id: Uuid,
locked_at: DateTime<Utc>,
expires_at: DateTime<Utc>,
refreshed_at: Option<DateTime<Utc>>,
status: LockStatus,
metadata: serde_json::Value
) -> Self {
Self {
id,
file_id,
user_id,
locked_at,
expires_at,
refreshed_at,
status,
metadata,
projection_version: 1,
last_event_sequence: 0,
projection_updated_at: Utc::now(),
}
}
pub fn id(&self) -> &Uuid {
&self.id
}
pub fn apply_event(&mut self, event_sequence: i64) {
self.projection_version += 1;
self.last_event_sequence = event_sequence;
self.projection_updated_at = Utc::now();
}
}
#[derive(Debug, Clone, Serialize, Deserialize, FromRow)]
pub struct FileLockSummary {
pub id: Uuid,
pub status: LockStatus,
}