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