cloudfront_logs/referential/typed/
chrono.rs

1use crate::{borrowed::UnvalidatedChronoLogline as BorrowedLine, shared::validate_line, types::*};
2
3pub use crate::types::{Datelike, Timelike};
4
5/// A (thread safe) line string
6///
7/// We use a [`Arc<str>`] over [`String`] to communicate its immutability and fixedness.
8/// (`Arc<str>`/`Box<str>`/`&str` don't carry any capacity data, only the length.)
9///
10/// While `Box<str>` is also possible, the box is not thread safe and
11/// and both types have pretty similar performance characteristics.
12pub type LineStr = Arc<str>;
13
14self_cell::self_cell!(
15    struct Container {
16        owner: LineStr,
17
18        #[covariant]
19        dependent: BorrowedLine,
20    }
21
22    impl {Debug, PartialEq}
23);
24
25impl Clone for Container {
26    fn clone(&self) -> Self {
27        let input = Arc::clone(self.borrow_owner());
28        Self::new(input, |line| {
29            let dependent = BorrowedLine::try_from(line.as_ref())
30                .expect("invalid line input despite validation");
31            dependent
32        })
33    }
34}
35
36pub type UnvalidatedLogline = Logline<Unvalidated>;
37pub type ValidatedLogline = Logline<Validated>;
38
39#[derive(Debug, Clone, PartialEq)]
40pub struct Logline<V> {
41    inner: Container,
42    _marker: PhantomData<V>,
43}
44
45impl<V> Logline<V> {
46    pub fn view(&self) -> &BorrowedLine<'_> {
47        self.inner.borrow_dependent()
48    }
49
50    pub fn as_raw(&self) -> &str {
51        self.inner.borrow_owner()
52    }
53
54    pub fn into_raw(self) -> LineStr {
55        self.inner.into_owner()
56    }
57}
58
59macro_rules! impl_try_from {
60    ($in:ty, $out_v:ident, $out_u:ident) => {
61        impl TryFrom<$in> for $out_v {
62            type Error = &'static str;
63
64            fn try_from(line: $in) -> Result<Self, Self::Error> {
65                let line: LineStr = line.into();
66                validate_line(&line)?;
67                let container = Container::new(line, |line| {
68                    BorrowedLine::try_from(line.as_ref())
69                        .expect("invalid line input despite validation")
70                });
71                Ok($out_v {
72                    inner: container,
73                    _marker: PhantomData,
74                })
75            }
76        }
77
78        impl TryFrom<$in> for $out_u {
79            type Error = &'static str;
80
81            fn try_from(line: $in) -> Result<Self, Self::Error> {
82                let container = Container::new(line.into(), |line| {
83                    BorrowedLine::try_from(line.as_ref())
84                        .expect("invalid line input despite validation")
85                });
86                Ok($out_u {
87                    inner: container,
88                    _marker: PhantomData,
89                })
90            }
91        }
92    };
93}
94
95impl_try_from!(&str, ValidatedLogline, UnvalidatedLogline);
96impl_try_from!(String, ValidatedLogline, UnvalidatedLogline);
97impl_try_from!(Box<str>, ValidatedLogline, UnvalidatedLogline);
98impl_try_from!(Arc<str>, ValidatedLogline, UnvalidatedLogline);
cloudfront_logs/referential/typed/chrono.rs

cloudfront_logs/referential/typed/
chrono.rs
