use std::ops::Add;
use schemars::JsonSchema;
use serde::{Deserialize, Serialize};
use vecdb::{CheckedSub, Formattable, Pco, PrintableIndex};
use super::{INDEX_EPOCH, Timestamp};
pub const HOUR4_INTERVAL: u32 = 14400;
#[derive(
Debug,
Default,
Clone,
Copy,
PartialEq,
Eq,
PartialOrd,
Ord,
Serialize,
Deserialize,
Pco,
JsonSchema,
)]
pub struct Hour4(u32);
impl Hour4 {
pub fn from_timestamp(ts: Timestamp) -> Self {
Self((*ts - INDEX_EPOCH) / HOUR4_INTERVAL)
}
pub fn to_timestamp(&self) -> Timestamp {
Timestamp::new(INDEX_EPOCH + self.0 * HOUR4_INTERVAL)
}
}
impl From<Hour4> for usize {
#[inline]
fn from(value: Hour4) -> Self {
value.0 as usize
}
}
impl From<usize> for Hour4 {
#[inline]
fn from(value: usize) -> Self {
Self(value as u32)
}
}
impl Add<usize> for Hour4 {
type Output = Self;
fn add(self, rhs: usize) -> Self::Output {
Self(self.0 + rhs as u32)
}
}
impl CheckedSub for Hour4 {
fn checked_sub(self, rhs: Self) -> Option<Self> {
self.0.checked_sub(rhs.0).map(Self)
}
}
impl PrintableIndex for Hour4 {
fn to_string() -> &'static str {
"hour4"
}
fn to_possible_strings() -> &'static [&'static str] {
&["4h", "hour4"]
}
}
impl std::fmt::Display for Hour4 {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut buf = itoa::Buffer::new();
let str = buf.format(self.0);
f.write_str(str)
}
}
impl Formattable for Hour4 {
#[inline(always)]
fn write_to(&self, buf: &mut Vec<u8>) {
let mut b = itoa::Buffer::new();
buf.extend_from_slice(b.format(self.0).as_bytes());
}
}