use chrono::{DateTime, TimeZone, Utc};
use crate::errors::ValidationError;
use crate::traits::{PrimitiveValue, ValueObject};
pub type UnixTimestampInput = i64;
#[derive(Debug, Clone, PartialEq, Eq, Hash)]
#[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
#[cfg_attr(feature = "serde", serde(try_from = "i64", into = "i64"))]
pub struct UnixTimestamp(i64);
impl ValueObject for UnixTimestamp {
type Input = UnixTimestampInput;
type Error = ValidationError;
fn new(value: Self::Input) -> Result<Self, Self::Error> {
if value < 0 {
return Err(ValidationError::invalid(
"UnixTimestamp",
&value.to_string(),
));
}
Ok(Self(value))
}
fn into_inner(self) -> Self::Input {
self.0
}
}
impl PrimitiveValue for UnixTimestamp {
type Primitive = i64;
fn value(&self) -> &i64 {
&self.0
}
}
impl UnixTimestamp {
pub fn as_datetime(&self) -> DateTime<Utc> {
Utc.timestamp_opt(self.0, 0)
.single()
.expect("valid timestamp")
}
}
impl TryFrom<i64> for UnixTimestamp {
type Error = ValidationError;
fn try_from(v: i64) -> Result<Self, Self::Error> {
Self::new(v)
}
}
#[cfg(feature = "serde")]
impl From<UnixTimestamp> for i64 {
fn from(v: UnixTimestamp) -> i64 {
v.0
}
}
impl TryFrom<&str> for UnixTimestamp {
type Error = ValidationError;
fn try_from(value: &str) -> Result<Self, Self::Error> {
let parsed = value
.trim()
.parse::<i64>()
.map_err(|_| ValidationError::invalid("UnixTimestamp", value))?;
Self::new(parsed)
}
}
impl std::fmt::Display for UnixTimestamp {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(f, "{}", self.0)
}
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn accepts_zero() {
let ts = UnixTimestamp::new(0).unwrap();
assert_eq!(*ts.value(), 0);
}
#[test]
fn accepts_positive() {
let ts = UnixTimestamp::new(1_700_000_000).unwrap();
assert_eq!(*ts.value(), 1_700_000_000);
}
#[test]
fn rejects_negative() {
assert!(UnixTimestamp::new(-1).is_err());
}
#[test]
fn into_inner_roundtrip() {
let ts = UnixTimestamp::new(42).unwrap();
assert_eq!(ts.into_inner(), 42);
}
#[test]
fn as_datetime_epoch() {
let ts = UnixTimestamp::new(0).unwrap();
assert_eq!(ts.as_datetime().timestamp(), 0);
}
#[test]
fn as_datetime_nonzero() {
let ts = UnixTimestamp::new(1_700_000_000).unwrap();
assert_eq!(ts.as_datetime().timestamp(), 1_700_000_000);
}
#[test]
fn display() {
let ts = UnixTimestamp::new(1_000).unwrap();
assert_eq!(ts.to_string(), "1000");
}
#[test]
fn try_from_parses_valid() {
let ts = UnixTimestamp::try_from("1700000000").unwrap();
assert_eq!(*ts.value(), 1_700_000_000);
}
#[test]
fn try_from_rejects_invalid_format() {
assert!(UnixTimestamp::try_from("abc").is_err());
}
#[test]
fn try_from_rejects_negative() {
assert!(UnixTimestamp::try_from("-1").is_err());
}
#[cfg(feature = "serde")]
#[test]
fn serde_roundtrip() {
let v = UnixTimestamp::new(1_700_000_000).unwrap();
let json = serde_json::to_string(&v).unwrap();
assert_eq!(json, "1700000000");
let back: UnixTimestamp = serde_json::from_str(&json).unwrap();
assert_eq!(v, back);
}
#[cfg(feature = "serde")]
#[test]
fn serde_deserialize_validates() {
let result: Result<UnixTimestamp, _> = serde_json::from_str("-1");
assert!(result.is_err());
}
}