use std::ops::Add;
use schemars::JsonSchema;
use serde::{Deserialize, Serialize};
use vecdb::{CheckedSub, Formattable, Pco, PrintableIndex};
use super::{INDEX_EPOCH, Timestamp};
pub const HOUR1_INTERVAL: u32 = 3600;
#[derive(
Debug,
Default,
Clone,
Copy,
PartialEq,
Eq,
PartialOrd,
Ord,
Serialize,
Deserialize,
Pco,
JsonSchema,
)]
pub struct Hour1(u32);
impl Hour1 {
pub fn from_timestamp(ts: Timestamp) -> Self {
Self((*ts - INDEX_EPOCH) / HOUR1_INTERVAL)
}
pub fn to_timestamp(&self) -> Timestamp {
Timestamp::new(INDEX_EPOCH + self.0 * HOUR1_INTERVAL)
}
}
impl From<Hour1> for usize {
#[inline]
fn from(value: Hour1) -> Self {
value.0 as usize
}
}
impl From<usize> for Hour1 {
#[inline]
fn from(value: usize) -> Self {
Self(value as u32)
}
}
impl Add<usize> for Hour1 {
type Output = Self;
fn add(self, rhs: usize) -> Self::Output {
Self(self.0 + rhs as u32)
}
}
impl CheckedSub for Hour1 {
fn checked_sub(self, rhs: Self) -> Option<Self> {
self.0.checked_sub(rhs.0).map(Self)
}
}
impl PrintableIndex for Hour1 {
fn to_string() -> &'static str {
"hour1"
}
fn to_possible_strings() -> &'static [&'static str] {
&["1h", "hour", "hourly", "hour1"]
}
}
impl std::fmt::Display for Hour1 {
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 Hour1 {
#[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());
}
}